有数数据同步及推送

CZT

2024-03-02 3a7fd31b5beadda5b3c12450935db9913a52bd92

 src/main/java/com/fzzy/api/timer/PushDataScheduled.java

@@ -97,43 +97,7 @@
            return;
        }

        //核对时间是否匹配
        if (conf.getPushHour99().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
            if (String.valueOf(hourOfDay).equals(conf.getPushHour11())) {
                isExecute = true;

                if (!isUpdateStart) {
                    start = DateUtils.addDays(start, -1);
                    isUpdateStart = true;
                }
            } else {
                isExecute = false;
            }
        }
        if (!isExecute) {
            log.debug("------->>>>>>>>>> 业务数据推送---时间配置小时不匹配");
            return;
        }

        //核对时间分钟是否匹配
        int minute = ContextUtil.getMinuteOfHour(exeDate);
        if (String.valueOf(minute).equals(conf.getPushMinute99())) {
            isExecute = true;
            if (!isUpdateStart) {
                start = DateUtils.addHours(start, -1);
            }
        } else {
            isExecute = false;
        }

        if (!isExecute) {
            log.debug("------->>>>>>>>>> 业务数据推送---时间配置分钟不匹配");
            return;
        }

        log.info("------->>>>>>>>>> 业务数据推送---开始查询相关业务数据进行推送");
        ApiParam param = new ApiParam();
        param.setPushProtocol(conf.getPushProtocol());
        param.setKqdm(conf.getKqdm());
@@ -229,6 +193,8 @@
            return;
        }

        log.info("------->>>>>>>>>> 基础数据推送---开始查询相关基础数据进行推送");

        ApiParam param = new ApiParam();
        param.setPushProtocol(conf.getPushProtocol());
        param.setKqdm(conf.getKqdm());