| | |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | reqData = new BaseReqData(); |
|---|
| | | reqData.setProductId(device.getProductId()); |
|---|
| | | reqData.setDeviceName(device.getDeviceName()); |
|---|
| | | reqData.setDeviceId(param.getDeviceId()); |
|---|
| | | reqData.setDayTime(param.getDayTime()); |
|---|
| | | reqData.setDevice(device); |
|---|
| | | |
|---|
| | | //获取到 |
|---|
| | | resp = gatewayRemoteManager.getGatewayTestService(device.getPushProtocol()).testGrainKafka(reqData); |
|---|
| | | |
|---|
| | | log.info("resp = "+resp.toString()); |
|---|
| | | //自动推送 |
|---|
| | | if (BaseResp.CODE_200 == resp.getCode()) { |
|---|
| | | reqData.setData(resp.getData()); |
|---|
| | | gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportGrainDataByKafka(reqData); |
|---|
| | | gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportGrainDataByHand(reqData); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
