| | |
|---|
| | | import com.fzzy.api.data.PushProtocol; |
|---|
| | | import com.fzzy.api.utils.*; |
|---|
| | | import com.fzzy.api.view.repository.ApiLogRep; |
|---|
| | | import com.fzzy.gateway.data.BaseResp; |
|---|
| | | import com.fzzy.gateway.service.GatewayConfService; |
|---|
| | | import com.fzzy.gateway.util.GatewayHttpUtil; |
|---|
| | | import com.fzzy.gateway.api.GatewayRemoteService; |
|---|
| | |
|---|
| | | |
|---|
| | | CloudResp respKey = JSONObject.parseObject(jsonStr, CloudResp.class); |
|---|
| | | |
|---|
| | | if (ScConstant.CODE_200 == respKey.getCode()) { |
|---|
| | | if (BaseResp.CODE_200 == respKey.getCode()) { |
|---|
| | | JSONObject object = respKey.getData(); |
|---|
| | | String pubKey = (String) object.get("pubKey"); |
|---|
| | | String priKey = (String) object.get("priKey"); |
|---|
| | |
|---|
| | | log.info("---获取AccessToken接口-返回---{}", jsonStr); |
|---|
| | | CloudResp respToken = JSONObject.parseObject(jsonStr, CloudResp.class); |
|---|
| | | |
|---|
| | | if (ScConstant.CODE_200 == respToken.getCode()) { |
|---|
| | | if (BaseResp.CODE_200 == respToken.getCode()) { |
|---|
| | | JSONObject object = respKey.getData(); |
|---|
| | | if (null != object) { |
|---|
| | | String token = (String) object.get("token"); |
|---|
| | |
|---|
| | | String url = gatewayConf.getApiUrl() + "reserver/api/iot/equipment/heartbeat"; |
|---|
| | | |
|---|
| | | String jsonStr = GatewayHttpUtil.doGet(url, params); |
|---|
| | | log.info("---网关心跳接口-返回---{}", jsonStr); |
|---|
| | | // log.info("---网关心跳接口-返回---{}", jsonStr); |
|---|
| | | |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("------网关心跳接口--执行失败-----{}", e); |
|---|
