| | |
| | | * cron表达式: 0 0/10 * * * ? (每10分钟执行一次) |
| | | */ |
| | | public void syncPendingTasks() { |
| | | log.info("开始执行旧系统任务同步定时任务"); |
| | | // log.info("开始执行旧系统任务同步定时任务"); |
| | | try { |
| | | int successCount = legacySystemSyncService.batchSyncPendingTasks(); |
| | | log.info("旧系统任务同步完成,成功同步: {} 个任务", successCount); |
| | | // log.info("旧系统任务同步完成,成功同步: {} 个任务", successCount); |
| | | } catch (Exception e) { |
| | | log.error("旧系统任务同步异常", e); |
| | | } |
| | |
| | | * cron表达式: 0 0/5 * * * ? (每5分钟执行一次) |
| | | */ |
| | | public void syncTaskStatusFromLegacy() { |
| | | log.info("开始执行任务状态同步定时任务(从旧系统到新系统)"); |
| | | // log.info("开始执行任务状态同步定时任务(从旧系统到新系统)"); |
| | | try { |
| | | int successCount = taskStatusSyncService.batchSyncTaskStatusFromLegacy(); |
| | | log.info("任务状态同步完成,成功同步: {} 个任务", successCount); |
| | | // log.info("任务状态同步完成,成功同步: {} 个任务", successCount); |
| | | } catch (Exception e) { |
| | | log.error("任务状态同步异常", e); |
| | | } |