调整品种获取

czt

2025-07-26 f495e422b1de10b1d1810158fca1c63f9b60fe45

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

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

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

        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;
//
//                //开始时间提前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;
//        }
        //是否执行
        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.getSyncDay99())) {
                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.getSyncHour99())) {
                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, -2);
            }
        } else {
            isExecute = false;
        }

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

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