From 7c790c248c137a2fa5525bf66ed04c25043cded7 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期三, 03 十二月 2025 09:32:19 +0800
Subject: [PATCH] feat:用户附加同步
---
ruoyi-system/src/main/java/com/ruoyi/system/listener/TaskMessageListener.java | 30 ++++++++++++++++++++++++++++--
1 files changed, 28 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..87a04f4 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;
/**
* 鐩戝惉浠诲姟鍒涘缓浜嬩欢
@@ -93,7 +110,7 @@
return;
}
- // 缁欐瘡涓墽琛屼汉鍙戦�佹秷鎭�
+ // 缁欐瘡涓墽琛屼汉鍙戦�佺珯鍐呮秷鎭�
for (int i = 0; i < event.getAssigneeIds().size(); i++) {
Long assigneeId = event.getAssigneeIds().get(i);
@@ -104,7 +121,7 @@
continue;
}
- // 鍒涘缓娑堟伅
+ // 鍒涘缓绔欏唴娑堟伅
SysMessage message = new SysMessage();
message.setMessageType("PUSH");
message.setMessageTitle("浠诲姟鎺ㄩ��");
@@ -123,6 +140,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