From e0f1a1411f20e89623a7be06200c01bbbd8a3f91 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Tue, 29 Oct 2024 10:29:48 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-3114)=20-=20=E5=AE=8C=E5=96=84?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8F=90=E7=A4=BA=E5=86=85=E5=AE=B9=E6=A0=BC?=
 =?UTF-8?q?=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../callback/keyword/impl/GroupRegisterKeywordProcessor.java  | 2 +-
 .../callback/robot/strategy/impl/TransferToMQStrategy.java    | 4 ++--
 .../service/impl/ThirdDingtalkConversationServiceImpl.java    | 4 ++++
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/keyword/impl/GroupRegisterKeywordProcessor.java b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/keyword/impl/GroupRegisterKeywordProcessor.java
index 8f04b04..1000999 100644
--- a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/keyword/impl/GroupRegisterKeywordProcessor.java
+++ b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/keyword/impl/GroupRegisterKeywordProcessor.java
@@ -39,7 +39,7 @@ public class GroupRegisterKeywordProcessor extends AbstractKeywordProcessor {
                 "  \n  " +
                 "  \n  " +
                 "### 使用示例:  \n  " +
-                "appReg workflowEngine");
+                "groupReg workflowEngine");
     }
 
     /**
diff --git a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/robot/strategy/impl/TransferToMQStrategy.java b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/robot/strategy/impl/TransferToMQStrategy.java
index 34b65d3..febb9c6 100644
--- a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/robot/strategy/impl/TransferToMQStrategy.java
+++ b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/callback/robot/strategy/impl/TransferToMQStrategy.java
@@ -41,7 +41,7 @@ public class TransferToMQStrategy extends AbstractRobotHandleStrategy {
     private String activeProfile;
     @Resource
     private ThirdDingtalkConversationService thirdDingtalkConversationService;
-    private final Map</*会话 ID*/String, ThirdDingtalkConversation> conversationMap = new HashMap<>();
+    public static final Map</*会话 ID*/String, ThirdDingtalkConversation> conversationMap = new HashMap<>();
 
     @PostConstruct
     public void init() {
@@ -62,7 +62,7 @@ public class TransferToMQStrategy extends AbstractRobotHandleStrategy {
 
         ThirdDingtalkConversation conversation = checkConversationExists(chatbotMessage);
         if (Objects.isNull(conversation)) {
-            return SampleText.from("当前群未关联后端服务，请@机器人发送“groupRegister”或“群注册”");
+            return SampleText.from("当前群未关联后端服务，请@机器人发送“groupReg”或“群注册”查看注册帮助！");
         }
 
         SampleMessageQueue messageQueue = SampleMessageQueue.from(conversation.getApplicationName(), getContent(chatbotMessage));
diff --git a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/service/impl/ThirdDingtalkConversationServiceImpl.java b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/service/impl/ThirdDingtalkConversationServiceImpl.java
index 96310bb..5d4edee 100644
--- a/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/service/impl/ThirdDingtalkConversationServiceImpl.java
+++ b/riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/service/impl/ThirdDingtalkConversationServiceImpl.java
@@ -18,6 +18,8 @@ import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
 
+import static cn.axzo.riven.dingtalk.callback.robot.strategy.impl.TransferToMQStrategy.conversationMap;
+
 /**
  * 三方钉钉群会话信息
  *
@@ -29,6 +31,7 @@ import java.util.Objects;
 public class ThirdDingtalkConversationServiceImpl implements ThirdDingtalkConversationService {
     private final ThirdDingtalkConversationMapper thirdDingtalkConversationMapper;
 
+
     @Override
     public void upsert(ThirdDingtalkConversation conversation) {
         ThirdDingtalkConversation oldEntity = thirdDingtalkConversationMapper
@@ -39,6 +42,7 @@ public class ThirdDingtalkConversationServiceImpl implements ThirdDingtalkConver
             thirdDingtalkConversationMapper.updateById(oldEntity);
         } else {
             thirdDingtalkConversationMapper.insert(conversation);
+            conversationMap.put(conversation.getConversationId(), conversation);
         }
     }