| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import com.ruoyi.system.service.ILegacySystemSyncService; |
| | | import com.ruoyi.system.service.ITaskStatusSyncService; |
| | | import com.ruoyi.system.service.ITaskStatusPushService; |
| | | |
| | | /** |
| | | * 旧系统同步定时任务 |
| | |
| | | |
| | | @Autowired |
| | | private ILegacySystemSyncService legacySystemSyncService; |
| | | |
| | | @Autowired |
| | | private ITaskStatusSyncService taskStatusSyncService; |
| | | |
| | | @Autowired |
| | | private ITaskStatusPushService taskStatusPushService; |
| | | |
| | | /** |
| | | * 批量同步未同步的急救转运任务到旧系统 |
| | |
| | | log.error("旧系统调度单同步异常", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 批量同步任务状态(从旧系统到新系统) |
| | | * |
| | | * 使用示例: |
| | | * 在系统管理 -> 定时任务中添加: |
| | | * 任务名称: 任务状态同步 |
| | | * 任务组名: DEFAULT |
| | | * 调用目标字符串: legacySystemSyncTask.syncTaskStatusFromLegacy() |
| | | * cron表达式: 0 0/5 * * * ? (每5分钟执行一次) |
| | | */ |
| | | public void syncTaskStatusFromLegacy() { |
| | | log.info("开始执行任务状态同步定时任务(从旧系统到新系统)"); |
| | | try { |
| | | int successCount = taskStatusSyncService.batchSyncTaskStatusFromLegacy(); |
| | | log.info("任务状态同步完成,成功同步: {} 个任务", successCount); |
| | | } catch (Exception e) { |
| | | log.error("任务状态同步异常", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 批量推送任务状态(从新系统到旧系统) |
| | | * |
| | | * 使用示例: |
| | | * 在系统管理 -> 定时任务中添加: |
| | | * 任务名称: 任务状态推送 |
| | | * 任务组名: DEFAULT |
| | | * 调用目标字符串: legacySystemSyncTask.pushTaskStatusToLegacy() |
| | | * cron表达式: 0 0/3 * * * ? (每3分钟执行一次) |
| | | */ |
| | | public void pushTaskStatusToLegacy() { |
| | | log.info("开始执行任务状态推送定时任务(从新系统到旧系统)"); |
| | | try { |
| | | int successCount = taskStatusPushService.batchPushTaskStatusToLegacy(); |
| | | log.info("任务状态推送完成,成功推送: {} 个任务", successCount); |
| | | } catch (Exception e) { |
| | | log.error("任务状态推送异常", e); |
| | | } |
| | | } |
| | | } |