| | |
| | | //是否执行 |
| | | 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())) { |
| | | if (String.valueOf(dayOfWeek).equals(conf.getSyncDay99())) { |
| | | isExecute = true; |
| | | |
| | | //开始时间提前7天 |
| | |
| | | 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())) { |
| | | if (String.valueOf(hourOfDay).equals(conf.getSyncHour99())) { |
| | | isExecute = true; |
| | | |
| | | if (!isUpdateStart) { |
| | |
| | | if (String.valueOf(minute).equals(conf.getSyncMinute99())) { |
| | | isExecute = true; |
| | | if (!isUpdateStart) { |
| | | start = DateUtils.addHours(start, -1); |
| | | start = DateUtils.addHours(start, -2); |
| | | } |
| | | } else { |
| | | isExecute = false; |
| | |
| | | return; |
| | | } |
| | | |
| | | log.debug("业务数据同步---开始查询业务数据进行同步<<<<<<<<<<<<<-------"); |
| | | ApiParam param = new ApiParam(); |
| | | param.setSyncProtocol(conf.getSyncProtocol()); |
| | | param.setPushProtocol(conf.getPushProtocol()); |