Browse Source

新增同意和不同意的识别

anderx 5 months ago
parent
commit
a427ece2e6

+ 3 - 1
src/main/java/com/kede/common/enums/WechatSmgTypeEnum.java

@@ -12,7 +12,9 @@ public enum WechatSmgTypeEnum {
     image("image","图片"),
     video("video","视频"),
     revoke("revoke","撤回消息"),
-    voice("voice","语音");
+    voice("voice","语音"),
+    disagree("disagree","不同意会话存储"),
+    agree("agree","同意会话存储");
     private String code;
     private String desc;
     private static Map<String,WechatSmgTypeEnum> status=new HashMap<String,WechatSmgTypeEnum>();

+ 1 - 0
src/main/java/com/kede/common/task/ConversationContentTask.java

@@ -91,6 +91,7 @@ public class ConversationContentTask {
             //获取发送这名称
 //            System.out.println("====>"+chatMsg);
             Map<String, Object> map = conversationContentService.pushGetChatName(from);
+            //
             String chatName=map.get("name").toString();
             String tolist = chatMsg.getTolist();
             String roomName=null;

+ 6 - 1
src/main/java/com/kede/wechat/service/impl/ConversationContentServiceImpl.java

@@ -254,13 +254,18 @@ public class ConversationContentServiceImpl extends BaseMybatisDao<ChatMsgUserMa
             {
                 String url=pushFileUrl(sdk, msgtype, jsonObject);
                 chatMsg.setMsgurl(url);
+            } else if (msgtype.equals("agree"))
+            {
+                chatMsg.setContent("[同意会话聊天]");
+            } else if (msgtype.equals("disagree"))
+                chatMsg.setContent("[不同意会话聊天]");
             } else {
                 if (!jsonObject.getString("action").equals("switch")&&!jsonObject.getString("action").equals("recall")) {
                     chatMsg.setContent(jsonObject.toJSONString());
                 }
 
             }
-        }
+
     }
 
     private String pushCharset(String content1) {