| | |
| | | */ |
| | | // @Scheduled(cron = "0 30 5 ? * *") |
| | | // @Scheduled(cron = "0 32 11 ? * 1,4") |
| | | @Scheduled(cron = "0 32 11 ? * *") |
| | | @Scheduled(cron = "0 32 7 ? * *") |
| | | public void scheduledGrain2() { |
| | | //获取设备配置,只针对粮情设备进行执行 |
| | | //获取设备配置,只针对粮情设备进行执行vie |
| | | log.info("定时粮情采集kafka推送"); |
| | | List<GatewayDevice> list = gatewayDeviceTestPR.listAll(); |
| | | |
| | |
| | | log.error("为获取到系统中设备配置,取消执行\""); |
| | | return ; |
| | | } |
| | | BaseReqData reqData = new BaseReqData(); |
| | | BaseReqData reqData ; |
| | | BaseResp resp; |
| | | |
| | | for (int i = 0 ;i<3;i++){ |
| | |
| | | if( i>0 && !(device.getDeviceId().startsWith("91510704731594658J001") ||device.getDeviceId().startsWith("91510704731594658J002") || device.getDeviceId().startsWith("91510700205404914T001"))){ |
| | | continue; |
| | | } |
| | | reqData = new BaseReqData(); |
| | | reqData.setDeviceId(device.getDeviceId()); |
| | | reqData.setProductId(device.getProductId()); |
| | | reqData.setDeviceName(device.getDeviceName()); |