有数数据同步及推送

CZT

2024-03-02 3a7fd31b5beadda5b3c12450935db9913a52bd92

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

@@ -36,7 +36,8 @@
     * <p>
     * 固定时间：0分钟和30分钟执行
     */
    @Scheduled(cron = "0 0,30 * * * ? ")
//    @Scheduled(cron = "0 0,30 * * * ? ")
    @Scheduled(cron = "0 * * * * ? ")
    public void scheduled() {

        log.info("系统执行定时数据同步操作<<<<<<<<<<<<<--------");
@@ -72,67 +73,68 @@

        Date start = exeDate;

        //是否执行
        boolean isExecute = false;
        boolean isUpdateStart = false;
        //核对天是否匹配
        if (conf.getSyncDay99().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
            if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
                isExecute = true;
//        //是否执行
//        boolean isExecute = false;
//        boolean isUpdateStart = false;
//        //核对天是否匹配
//        if (conf.getSyncDay99().equals(ApiConfs.TIME_ALL)) {
//            isExecute = true;
//        } else {
//            int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
//            if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
//                isExecute = true;
//
//                //开始时间提前7天
//                start = DateUtils.addDays(start, -7);
//                isUpdateStart = true;
//            } else {
//                isExecute = false;
//            }
//        }
//
//        if (!isExecute) {
//            log.debug("业务数据同步---时间配置天不匹配<<<<<<<<<<<<<-------");
//            return;
//        }
//
//        //核对时间是否匹配
//        if (conf.getSyncHour99().equals(ApiConfs.TIME_ALL)) {
//            isExecute = true;
//        } else {
//            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
//            if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
//                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.getSyncMinute99())) {
//            isExecute = true;
//            if (!isUpdateStart) {
//                start = DateUtils.addHours(start, -1);
//            }
//        } else {
//            isExecute = false;
//        }
//
//        if (!isExecute) {
//            log.debug("业务数据同步---时间配置分钟不匹配<<<<<<<<<<<<<-------");
//            return;
//        }

                //开始时间提前7天
                start = DateUtils.addDays(start, -7);
                isUpdateStart = true;
            } else {
                isExecute = false;
            }
        }

        if (!isExecute) {
            log.debug("业务数据同步---时间配置天不匹配<<<<<<<<<<<<<-------");
            return;
        }

        //核对时间是否匹配
        if (conf.getSyncHour99().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
            if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
                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.getSyncMinute99())) {
            isExecute = true;
            if (!isUpdateStart) {
                start = DateUtils.addHours(start, -1);
            }
        } else {
            isExecute = false;
        }

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

        log.debug("业务数据同步---开始查询业务数据进行同步<<<<<<<<<<<<<-------");
        ApiParam param = new ApiParam();
        param.setSyncProtocol(conf.getSyncProtocol());
        param.setPushProtocol(conf.getPushProtocol());