From 847a7773ef1a8ad418c6934d35b5f205a97c04d0 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期六, 06 十二月 2025 17:03:24 +0800
Subject: [PATCH] fix:在任务状态更新时，需要更新日志到旧系统
---
ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java | 32 ++++++++++++++++++++++++++++++--
1 files changed, 30 insertions(+), 2 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java b/ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java
index 8a14ec2..c46d1d8 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java
@@ -7,13 +7,21 @@
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.system.domain.SysMessage;
+import com.ruoyi.system.domain.SysTask;
+import com.ruoyi.system.domain.SysTaskEmergency;
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.IWechatTaskNotifyService;
+
+import java.util.HashMap;
/**
* 浠诲姟娑堟伅鐩戝惉鍣�
@@ -32,6 +40,15 @@
@Autowired
private SysUserMapper sysUserMapper;
+
+ @Autowired
+ private SysTaskMapper sysTaskMapper;
+
+ @Autowired
+ private SysTaskEmergencyMapper sysTaskEmergencyMapper;
+
+ @Autowired
+ private IWechatTaskNotifyService wechatTaskNotifyService;
/**
* 鐩戝惉浠诲姟鍒涘缓浜嬩欢
@@ -75,6 +92,8 @@
}
}
+
+
/**
* 鐩戝惉浠诲姟鍒嗛厤浜嬩欢
*
@@ -93,7 +112,7 @@
return;
}
- // 缁欐瘡涓墽琛屼汉鍙戦�佹秷鎭�
+ // 缁欐瘡涓墽琛屼汉鍙戦�佺珯鍐呮秷鎭�
for (int i = 0; i < event.getAssigneeIds().size(); i++) {
Long assigneeId = event.getAssigneeIds().get(i);
@@ -104,7 +123,7 @@
continue;
}
- // 鍒涘缓娑堟伅
+ // 鍒涘缓绔欏唴娑堟伅
SysMessage message = new SysMessage();
message.setMessageType("PUSH");
message.setMessageTitle("浠诲姟鎺ㄩ��");
@@ -123,6 +142,15 @@
sysMessageMapper.insertSysMessage(message);
log.info("浠诲姟鍒嗛厤娑堟伅宸蹭繚瀛橈紝娑堟伅ID锛歿}锛屾帴鏀朵汉锛歿}", message.getMessageId(), assignee.getNickName());
}
+
+ // 鍙戦�佸井淇¤闃呮秷鎭紙鎺掗櫎鍒涘缓浜猴級
+ try {
+ SysTask task = sysTaskMapper.selectSysTaskByTaskId(event.getTaskId());
+ Long creatorId = task != null ? task.getCreatorId() : null;
+ wechatTaskNotifyService.sendTaskNotifyMessage(event.getTaskId(), event.getAssigneeIds(), creatorId);
+ } catch (Exception e) {
+ log.error("澶勭悊浠诲姟鍒嗛厤浜嬩欢鏃跺彂閫佸井淇¤闃呮秷鎭け璐�", e);
+ }
} catch (Exception e) {
log.error("澶勭悊浠诲姟鍒嗛厤浜嬩欢澶辫触", e);
--
Gitblit v1.9.1