优化粮温检测

vince

2025-06-04 0d9a7c8974add02c61d2471642e4e5a04013ab7b

 src/main/java/com/fzzy/gateway/GatewayTimerScheduled.java

@@ -109,9 +109,9 @@
     */
//    @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();

@@ -119,27 +119,34 @@
            log.error("为获取到系统中设备配置，取消执行\"");
            return ;
        }
        BaseReqData reqData = new BaseReqData();
        BaseReqData reqData ;
        BaseResp resp;
        for (GatewayDevice device : list) {
            try{
                //如果不是粮情分机跳过
                if (!GatewayDeviceType.TYPE_07.getCode().equals(device.getType())) {
                    continue;

        for (int i = 0 ;i<3;i++){
            for (GatewayDevice device : list) {
                    try{
                        //如果不是粮情分机跳过
                        if (!GatewayDeviceType.TYPE_07.getCode().equals(device.getType())) {
                            continue;
                        }
                        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());
                        reqData.setDevice(device);
                        reqData.setAutoReplay(true);
                        GatewaySyncGranService syncGrainService = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol());
                        resp = syncGrainService.syncGrain(reqData);
                        log.info("命令发送结果："+resp.toString());
                        Thread.sleep(120000);
                    }catch (Exception e){
                        log.error(e.getMessage(),e);
                    }
                }
                reqData.setDeviceId(device.getDeviceId());
                reqData.setProductId(device.getProductId());
                reqData.setDeviceName(device.getDeviceName());
                reqData.setDevice(device);
                reqData.setAutoReplay(true);
                GatewaySyncGranService syncGrainService = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol());
                 resp = syncGrainService.syncGrain(reqData);
                log.info("命令发送结果："+resp.toString());
                Thread.sleep(30000);
            }catch (Exception e){
                log.error(e.getMessage(),e);
            }
        }
    }

    /**