| | |
| | | @Autowired |
| | | private ISysTaskAssigneeService taskAssigneeService; |
| | | |
| | | @Autowired |
| | | private ITaskStatusPushService taskStatusPushService; |
| | | |
| | | @Async |
| | | @EventListener |
| | | public void handleTaskDispatchEvent(TaskDispatchSyncEvent event) { |
| | |
| | | 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(); |
| | |
| | | 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); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 监听任务创建事件 |
| | | * |
| | |
| | | |
| | | private void sendTaskStatusToLegacy(Long taskId) { |
| | | try{ |
| | | taskStatusSyncService.syncTaskStatusFromLegacy(taskId); |
| | | log.info("任务状态同步到旧系统开始 taskId:{}",taskId); |
| | | taskStatusPushService.pushTaskStatusToLegacy(taskId); |
| | | }catch (Exception e){ |
| | | log.error("任务状态同步到旧系统异常 taskId:{}",taskId, e); |
| | | } |