wlzboy
2025-12-23 355dda1f90c70ab04c4517688da37d1a4236f112
ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java
@@ -418,6 +418,8 @@
        return content.toString();
    }
    @Autowired
    private ITaskStatusSyncService taskStatusSyncService;
    /**
     * 监听任务状态变更事件
     * 
@@ -426,10 +428,27 @@
    @Async
    @EventListener
    public void handleTaskStatusChangedEvent(TaskStatusChangedEvent event) {
        sendTaskStatusToLocal(event);
        sendTaskStatusToLegacy(event.getTaskId());
    }
    private void sendTaskStatusToLegacy(Long taskId) {
        try{
            taskStatusSyncService.syncTaskStatusFromLegacy(taskId);
        }catch (Exception e){
            log.error("任务状态同步到旧系统异常 taskId:{}",taskId, e);
        }
    }
    private  void sendTaskStatusToLocal(TaskStatusChangedEvent event) {
        try {
            log.info("收到任务状态变更事件,任务ID:{},旧状态:{},新状态:{}", 
                    event.getTaskId(), event.getOldStatus(), event.getNewStatus());
            //发起状态同步
            // 构建状态变更内容
            String statusContent = getStatusChangeContent(event.getNewStatus(), event.getNewStatusDesc());