| | |
| | | * cron表达式: 0 0/10 * * * ? (每10分钟执行一次) |
| | | */ |
| | | public void syncAdditionalFeeToLegacy() { |
| | | log.info("开始执行附加费用同步定时任务(新系统 -> 旧系统)"); |
| | | log.info("开始执行新系统附加费用同步定时任务(新系统 -> 旧系统)"); |
| | | try { |
| | | int successCount = additionalFeeSyncService.batchSyncAdditionalFeeToLegacy(); |
| | | log.info("附加费用同步完成,成功同步: {} 条记录", successCount); |
| | |
| | | * cron表达式: 0 0/15 * * * ? (每15分钟执行一次) |
| | | */ |
| | | public void syncAdditionalFeeFromLegacy() { |
| | | log.info("开始执行附加费用同步定时任务(旧系统 -> 新系统)"); |
| | | log.info("开始执行旧系统附加费用同步定时任务(旧系统 -> 新系统)"); |
| | | try { |
| | | // 同步最近24小时内的记录 |
| | | int successCount = additionalFeeSyncService.batchSyncAdditionalFeeFromLegacy(24); |
| | | log.info("附加费用同步完成,成功同步: {} 条记录", successCount); |
| | | int successCount = additionalFeeSyncService.batchSyncAdditionalFeeFromLegacy(72); |
| | | log.info("旧系统附加费用同步完成,成功同步: {} 条记录", successCount); |
| | | } catch (Exception e) { |
| | | log.error("附加费用同步异常", e); |
| | | } |