| | |
|---|
| | | BaseReqData reqData; |
|---|
| | | BaseResp resp; |
|---|
| | | for (GatewayDevice device : list) { |
|---|
| | | |
|---|
| | | //如果不是粮情分机跳过 |
|---|
| | | if (!GatewayDeviceType.TYPE_07.getCode().equals(device.getType())) { |
|---|
| | | 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); |
|---|
| | | |
|---|
| | | //自动推送 |
|---|
| | | if (BaseResp.CODE_200 == resp.getCode()) { |
|---|
| | | reqData.setData(resp.getData()); |
|---|
| | | gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportGrainDataByKafka(reqData); |
|---|
| | | gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportGrainDataByHand(reqData); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
