fix

netflix-dao/src/main/java/com/cyksj/model/entity/CorpKfAccountSessionChat.java

@@ -14,6 +14,8 @@ import lombok.Setter;
 public class CorpKfAccountSessionChat extends BaseEntity{
 	private String openKfId;
 
+	private String msgid;
+
 	private String servicerUserid;
 
 	private String externalUserid;

netflix-dao/src/main/java/com/cyksj/model/kf/WxCorpChatMsg.java

@@ -16,6 +16,8 @@ import java.util.List;
 public class WxCorpChatMsg {
 	private String title;
 
+	private String msgid;
+
 	private String external_userid;
 
 	private String servicer_userid;

netflix-dao/src/main/java/com/cyksj/model/kf/WxCpKfMsgListResp.java

@@ -42,6 +42,7 @@ public class WxCpKfMsgListResp {
     private String externalUserId;
     @JsonProperty("send_time")
     private Long sendTime;
+    //消息来源。3-微信客户发送的消息 4-系统推送的事件消息 5-接待人员在企业微信客户端发送的消息
     private Integer origin;
     @JsonProperty("servicer_userid")
     private String servicerUserId;

netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpServiceImpl.java

@@ -596,6 +596,7 @@ public class CorpServiceImpl implements CorpService {
 				WxCorpChatMsg mergedMsg = item.getMergedMsg();
 				mergedMsg.setServicer_userid(item.getServicerUserId());
 				mergedMsg.setExternal_userid(item.getExternalUserId());
+				mergedMsg.setMsgid(item.getMsgId());
 				mergedMsgs.add(mergedMsg);
 			}
 		}
@@ -627,6 +628,7 @@ public class CorpServiceImpl implements CorpService {
 				corpKfAccountSessionChat.setOpenKfId(openKfId);
 				corpKfAccountSessionChat.setMsgType(item.getMsgtype());
 				corpKfAccountSessionChat.setMsgContent(item.getMsg_content());
+				corpKfAccountSessionChat.setMsgid(mergedMsg.getMsgid());
 				corpKfAccountSessionChatMapper.insert(corpKfAccountSessionChat);
 			}
 		}