| | |
| | | |
| | | import com.ruoyi.common.core.domain.entity.SysDept; |
| | | import com.ruoyi.common.utils.DeptUtil; |
| | | import com.ruoyi.common.utils.LongUtil; |
| | | import com.ruoyi.system.domain.*; |
| | | import com.ruoyi.system.event.TaskDispatchSyncEvent; |
| | | import com.ruoyi.system.service.ISysDeptService; |
| | | import com.ruoyi.system.service.ISysTaskAssigneeService; |
| | | import com.ruoyi.system.event.*; |
| | | import com.ruoyi.system.service.*; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | import org.springframework.stereotype.Component; |
| | | import com.ruoyi.common.utils.DateUtils; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.system.event.TaskCreatedEvent; |
| | | import com.ruoyi.system.event.TaskAssignedEvent; |
| | | import com.ruoyi.system.event.TaskStatusChangedEvent; |
| | | import com.ruoyi.system.mapper.SysMessageMapper; |
| | | import com.ruoyi.system.mapper.SysUserMapper; |
| | | import com.ruoyi.system.mapper.SysTaskMapper; |
| | | import com.ruoyi.system.mapper.SysTaskEmergencyMapper; |
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
| | | import com.ruoyi.system.service.INotifyTaskService; |
| | | import com.ruoyi.system.service.INotifyDispatchService; |
| | | |
| | | import java.text.DateFormat; |
| | | import java.text.SimpleDateFormat; |
| | |
| | | sendDispatchNotify(assigneeIds, task.getCreatorId(), event.getTaskId(),task.getShowTaskCode(), buildNotifyContent(task, emergency)); |
| | | } |
| | | } |
| | | |
| | | Long taskId= event.getTaskId(); |
| | | Long dispatchOrdId= event.getDispatchOrderId(); |
| | | Long serviceOrdId= event.getServiceOrderId(); |
| | | Integer oaUserID= event.getOaUserId(); |
| | | legacySystemSyncService.syncTaskAttachment(taskId, dispatchOrdId, serviceOrdId, oaUserID); |
| | | |
| | | }catch (Exception ex){ |
| | | log.error("处理任务派发同步事件失败", ex); |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @Autowired |
| | | private ILegacySystemSyncService legacySystemSyncService; |
| | | |
| | | @Async |
| | | @EventListener |
| | | public void handleTaskUpdateEvent(TaskUpdateEvent event){ |
| | | log.info("收到任务更新事件,任务ID:{},任务编号:{}", event.getTaskId(), event.getTaskCode()); |
| | | legacySystemSyncService.resyncDispatchOrderToLegacy(event.getTaskId()); |
| | | |
| | | } |
| | | //在这里监听派发的事件 |
| | | @Async |
| | | @EventListener |
| | | public void handleTaskServiceOrderSyncEvent(TaskServiceOrderSyncEvent event) { |
| | | // log.info("收到任务服务单同步事件,任务ID:{},任务编号:{},服务单ID:{}", event.getTaskId(), event.getTaskCode(), event.getServiceOrderId()); |
| | | Long dispatchOrderId= legacySystemSyncService.syncDispatchOrderToLegacy(event.getTaskId()); |
| | | // if(LongUtil.isNotEmpty(dispatchOrderId)){ |
| | | // //更新needsync为0 |
| | | // |
| | | // } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 监听任务分配事件 |
| | | * 创建通知任务,由通知分发服务决定发送渠道 |