数据同步

YYC

2025-01-03 d7eda377a257a18bca0429d3fae2a71d4160565b

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

@@ -81,7 +81,7 @@
            isExecute = true;
        } else {
            int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
            if (String.valueOf(dayOfWeek).equals(conf.getPushDay11())) {
            if (String.valueOf(dayOfWeek).equals(conf.getPushDay99())) {
                isExecute = true;

                //开始时间提前7天
@@ -102,7 +102,7 @@
            isExecute = true;
        } else {
            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
            if (String.valueOf(hourOfDay).equals(conf.getPushHour11())) {
            if (String.valueOf(hourOfDay).equals(conf.getPushHour99())) {
                isExecute = true;

                if (!isUpdateStart) {
@@ -114,7 +114,7 @@
            }
        }
        if (!isExecute) {
            log.debug("------->>>>>>>>>> 业务数据推送---时间配置小时不匹配");
            log.debug("------->>>>>>>>>> 基础数据推送---时间配置小时不匹配");
            return;
        }

@@ -123,17 +123,18 @@
        if (String.valueOf(minute).equals(conf.getPushMinute99())) {
            isExecute = true;
            if (!isUpdateStart) {
                start = DateUtils.addHours(start, -1);
                start = DateUtils.addHours(start, -2);
            }
        } else {
            isExecute = false;
        }

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

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

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

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