Kaynağa Gözat

微信会话内容存储开发

anderx 6 ay önce
ebeveyn
işleme
877d4d42ee

+ 1 - 0
src/main/java/com/kede/common/dao/ChatMsgMapper.java

@@ -81,5 +81,6 @@ public interface ChatMsgMapper {
      */
     int deleteById(Integer id);
 
+    ChatMsg selectByMsgId(String msgid);
 }
 

+ 8 - 1
src/main/java/com/kede/common/mapper/ChatMsgMapper.xml

@@ -18,7 +18,7 @@
     </resultMap>
 
     <sql id="ChatMsgAllSql">
-        id, msgid, action, from, from_name, tolist, tolist_name, roomid, msgtime, msgtype, content, create_time
+        id, msgid, `action`, `from`, from_name, tolist, tolist_name, roomid, msgtime, msgtype, content, create_time
     </sql>
 
     <!--查询单个-->
@@ -205,6 +205,7 @@
         </where>
     </select>
 
+
     <!--通过主键删除-->
     <delete id="deleteById">
         delete
@@ -212,5 +213,11 @@
         where id = #{id}
     </delete>
 
+    <select id="selectByMsgId"  resultMap="ChatMsgMap">
+        select
+        <include refid="ChatMsgAllSql"/>
+        from chat_msg
+        where msgid = #{id}
+    </select>
 </mapper>
 

+ 19 - 13
src/main/java/com/kede/common/task/ConversationContentTask.java

@@ -1,6 +1,7 @@
 package com.kede.common.task;
 
 import com.kede.common.model.ChatMsg;
+import com.kede.common.utils.StringUtils;
 import com.kede.wechat.bo.InputChatMsg;
 import com.kede.wechat.service.ConversationContentService;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -69,19 +70,24 @@ public class ConversationContentTask {
                     stringJoiner.add(tolistName1);
                 }
             }
-            ChatMsg in= new ChatMsg();
-            in.setMsgid(chatMsg.getMsgid());
-            in.setAction(chatMsg.getAction());
-            in.setFrom(chatMsg.getFrom());
-            in.setFromName(chatName);
-            in.setTolist(tolist);
-            in.setTolistName(stringJoiner.toString());
-            in.setRoomid(chatMsg.getRoomid());
-            in.setMsgtime(chatMsg.getMsgtime());
-            in.setMsgtype(chatMsg.getMsgtype());
-            in.setContent(chatMsg.getContent());
-            in.setCreateTime(new Date());
-            chatMsgMapper.insert(in);
+            if (StringUtils.isEmpty(chatName)){
+                ChatMsg chatMsg1 = chatMsgMapper.selectByMsgId(chatMsg.getMsgid());
+                if (chatMsg1 == null){
+                    ChatMsg in= new ChatMsg();
+                    in.setMsgid(chatMsg.getMsgid());
+                    in.setAction(chatMsg.getAction());
+                    in.setFrom(chatMsg.getFrom());
+                    in.setFromName(chatName);
+                    in.setTolist(tolist);
+                    in.setTolistName(stringJoiner.toString());
+                    in.setRoomid(chatMsg.getRoomid());
+                    in.setMsgtime(chatMsg.getMsgtime());
+                    in.setMsgtype(chatMsg.getMsgtype());
+                    in.setContent(chatMsg.getContent());
+                    in.setCreateTime(new Date());
+                    chatMsgMapper.insert(in);
+                }
+            }
         }
     }
 

BIN
src/main/resources/lib/WeWorkFinanceSdk.dll


BIN
src/main/resources/lib/libcurl-x64.dll