vince
2024-09-19 1346ece340481c2489dbc4ada7ddd73971991d44
src/main/java/com/fzzy/gateway/GatewayTimerScheduled.java
@@ -107,8 +107,8 @@
     * 粮情每天8点采集粮情
     *
     */
//    @Scheduled(cron = "0 32 11 ? * *")
    @Scheduled(cron = "0 32 11 ? * 2,5 *")
    @Scheduled(cron = "0 30 5 ? * *")
//    @Scheduled(cron = "0 32 11 ? * 1,4")
    public void scheduledGrain2() {
        //获取设备配置,只针对粮情设备进行执行
        log.info("定时粮情采集kafka推送");
@@ -147,9 +147,13 @@
     */
    @Scheduled(cron = "0/3 * * * * ?")
    public void scheduled3() {
        try{
            //执行HTTP地磅请求
            exeHttpWeightReq();
        }catch (Exception e){
            log.error(e.getMessage(),e);
        }
        //执行HTTP地磅请求
        exeHttpWeightReq();
    }
@@ -240,17 +244,14 @@
        BaseReqData reqData;
        for (GatewayDevice device : list) {
            if (!GatewayDeviceProtocol.DEVICE_WEIGHT_HTTP.getCode().equals(device.getSyncProtocol())) {
                continue;
            }
            reqData = new BaseReqData();
            reqData.setDevice(device);
            reqData.setDeviceName(device.getDeviceName());
            reqData.setProductId(device.getProductId());
            reqData.setDeviceId(device.getDeviceId());
            gatewayRemoteManager.getSyncWeightService(device.getSyncProtocol()).syncWeightInfo(reqData);
        }
    }