wlzboy
2026-01-24 2f09efc660bf2cc94cbc5291ad25ca06fc9bdadf
ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java
@@ -65,6 +65,9 @@
    @Autowired
    private ISysTaskAssigneeService taskAssigneeService;
    @Autowired
    private ITaskStatusPushService taskStatusPushService;
    @Async
    @EventListener
    public void handleTaskDispatchEvent(TaskDispatchSyncEvent event) {
@@ -80,7 +83,7 @@
                   sendDispatchNotify(assigneeIds, task.getCreatorId(), event.getTaskId(),task.getShowTaskCode(), buildNotifyContent(task, emergency));
               }
            }
            syncDispatchActualStartTime(emergency, task);
            Long taskId= event.getTaskId();
            Long dispatchOrdId= event.getDispatchOrderId();
            Long serviceOrdId= event.getServiceOrderId();
@@ -91,6 +94,19 @@
            log.error("处理任务派发同步事件失败", ex);
        }
    }
    private void syncDispatchActualStartTime(SysTaskEmergency emergency, SysTask task) {
        try {
            //这里也同步一下实际时间
            Long disatpchOrdId = emergency.getLegacyDispatchOrdId();
            Date actualTime = task.getActualStartTime();
            legacySystemSyncService.updateDispatchActualTime(disatpchOrdId, actualTime);
        }catch (Exception ex){
        log.error("同步实际时间失败", ex);
        }
    }
    /**
     * 监听任务创建事件
     * 
@@ -436,7 +452,8 @@
    private void sendTaskStatusToLegacy(Long taskId) {
        try{
            taskStatusSyncService.syncTaskStatusFromLegacy(taskId);
            log.info("任务状态同步到旧系统开始 taskId:{}",taskId);
           taskStatusPushService.pushTaskStatusToLegacy(taskId);
        }catch (Exception e){
            log.error("任务状态同步到旧系统异常 taskId:{}",taskId, e);
        }