wlzboy
2025-11-01 8b005a808d6ab8fae1480ed57bdfd68af2dafcd4
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java
@@ -6,6 +6,8 @@
import org.springframework.stereotype.Component;
import com.ruoyi.system.service.ILegacySystemSyncService;
import com.ruoyi.system.service.ITaskStatusSyncService;
import com.ruoyi.system.service.ITaskStatusPushService;
/**
 * 旧系统同步定时任务
@@ -20,6 +22,12 @@
    
    @Autowired
    private ILegacySystemSyncService legacySystemSyncService;
    @Autowired
    private ITaskStatusSyncService taskStatusSyncService;
    @Autowired
    private ITaskStatusPushService taskStatusPushService;
    
    /**
     * 批量同步未同步的急救转运任务到旧系统
@@ -80,4 +88,44 @@
            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);
        }
    }
}