添加 客服第一次回复时间 和 会话结束的时间

jim-server/src/main/java/org/jim/server/command/handler/processor/chat/AutoMessageProcessor.java

@@ -32,7 +32,7 @@ public class AutoMessageProcessor implements CmdProcessor, ImConst {
      * 自动消息处理方法
      */
     public void handler(Group group) {
-        log.info("执行自动消息处理方法...");
+        log.info("AutoMessageProcessor : 执行自动消息处理方法...");
         String group_id = group.getGroup_id();
         String accountRoleDepartmentId = group.getServiceAccountRoleDepartmentId();
         ServiceAccountRoleDepartmentMiddle accountRoleDepartment

jim-server/src/main/java/org/jim/server/model/GroupConversationMiddle.java

@@ -0,0 +1,11 @@
+package org.jim.server.model;
+
+import com.jfinal.plugin.activerecord.Model;
+
+/**
+ * @author Darren
+ * @date 2020/2/11 18:29
+ */
+public class GroupConversationMiddle extends Model<GroupConversationMiddle> {
+    public static final GroupConversationMiddle dao = new GroupConversationMiddle();
+}

server-chat/src/main/java/com/cn/config/PropertyDataBaseConfigBuilder.java

@@ -48,6 +48,7 @@ public class PropertyDataBaseConfigBuilder {
         );
         arp.addMapping("sw_visitor_department_middle","id",VisitorDepartmentMiddle.class);
         arp.addMapping("sw_auto_reply_message","id",AutoReplyMessage.class);
+        arp.addMapping("sw_group_conversation_middle","id",GroupConversationMiddle.class);
 
         // 与 jfinal web 环境唯一的不同是要手动调用一次相关插件的start()方法
         druidPlugin.start();

server-chat/src/main/java/com/cn/listener/IMChatGroupListener.java

@@ -1,5 +1,6 @@
 package com.cn.listener;
 
+import org.jim.server.enums.MessageStateEnum;
 import org.jim.server.model.ChatGroup;
 import org.jim.common.ImAio;
 import org.jim.common.ImPacket;
@@ -10,10 +11,14 @@ import org.jim.server.enums.ConsumerTypeEnum;
 import org.jim.server.enums.GroupStateEnum;
 import org.jim.server.enums.VisitTypeEnum;
 import org.jim.server.listener.ImGroupListener;
+import org.jim.server.model.Conversation;
+import org.jim.server.model.GroupConversationMiddle;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.tio.core.ChannelContext;
 
+import java.sql.Timestamp;
+
 /**
  * @author Darren
  * @date 2020/2/6 15:53
@@ -59,6 +64,34 @@ public class IMChatGroupListener extends ImGroupListener {
                         .set("group_state", GroupStateEnum.OFF_LINE.getKey())
                         .set("consumer_type", ConsumerTypeEnum.OFF_LINE.getKey())
                         .update();
+
+                if(MessageStateEnum.NO.getKey() == chatGroup.getInt("message_state")){
+                    //群组状态 为 非留言状态
+                    //修改 sw_conversation 表中的  end_time 和 conversation_lenth
+                    StringBuilder sql = new StringBuilder();
+                    sql.append(" select * from sw_group_conversation_middle where group_id = " + group)
+                            .append(" order by create_time desc limit 1");
+                    GroupConversationMiddle groupConversation = GroupConversationMiddle.dao.findFirst(sql.toString());
+                    if( null != groupConversation ){
+                        Conversation conversation = Conversation.dao.findById(groupConversation.getLong("conversation_id"));
+                        Timestamp endTime = conversation.getTimestamp("end_time");
+                        Integer conversationLenth = conversation.getInt("conversation_lenth");
+                        if( null == endTime && null == conversationLenth ){
+                            //需要更改会话结束时间 和 对话时长
+                            long currentTimeMillis = System.currentTimeMillis();
+                            //当前时间的格林威治时间 毫秒数
+                            Timestamp currentTime = new Timestamp(currentTimeMillis);
+                            Timestamp createTime = conversation.getTimestamp("create_time");
+                            //会话创建时间的格林威治时间 毫秒数
+                            long createTimeMillis = createTime.getTime();
+                            if(currentTimeMillis > createTimeMillis){
+                                conversation.set("end_time",currentTime);
+                                conversation.set("conversation_lenth",Integer.valueOf( String.valueOf( (currentTimeMillis - createTimeMillis)/1000 )));
+                            }
+                        }
+                    }
+                }
+
             }
         }
 

server-chat/src/main/java/com/cn/processor/IMChatAsyncChatMessageProcessor.java

@@ -10,11 +10,13 @@ import org.jim.common.packets.ChatType;
 import org.jim.common.packets.User;
 import org.jim.server.command.handler.processor.chat.DefaultAsyncChatMessageProcessor;
 import org.jim.server.enums.VisitTypeEnum;
+import org.jim.server.model.GroupConversationMiddle;
 import org.jim.server.util.SnowflakeIdUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.tio.core.ChannelContext;
 
+import java.sql.Timestamp;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
@@ -35,7 +37,6 @@ public class IMChatAsyncChatMessageProcessor extends DefaultAsyncChatMessageProc
     public void doHandler(ChatBody chatBody, ChannelContext channelContext) {
 
         log.info("聊天记录持久化... 开始:" + sdf.format(new Date()));
-
         //聊天类型(如 0:未知 1:群聊、2:私聊)
         Integer chatType = chatBody.getChatType();
         //消息类型;(如：0:text、1:image、2:voice、3:vedio、4:music、5:news)
@@ -44,54 +45,106 @@ public class IMChatAsyncChatMessageProcessor extends DefaultAsyncChatMessageProc
             //群聊
             ChatGroup group = ChatGroup.dao.findById(chatBody.getGroup_id());
             if( null != group){
-                Conversation conversation = Conversation.dao.findById(group.getLong("conversation_id"));
-                if( null != conversation){
-                    Map<String, Object> conversationRecordAttrs = new HashMap<>();
-                    conversationRecordAttrs.put("id", SnowflakeIdUtils.getInstance().nextId());
-                    conversationRecordAttrs.put("chat_body_id",chatBody.getId());
-                    conversationRecordAttrs.put("content",chatBody.getContent());
-                    conversationRecordAttrs.put("is_recall",0);
-                    String fromId = chatBody.getFrom();
-                    // customerDepartmentId  visitorDepartmentId  serviceAccountRoleDepartmentId
-                    User user = ImAio.getUser(fromId);
-                    String visitType = user.getVisitType();
-                    if(VisitTypeEnum.CUSTOMER.getKey().equals(visitType)){
-                        // CUSTOMER 客户  发送的消息
-                        String companyId = user.getExtras().getString("customerId");
-                        conversationRecordAttrs.put("from_id",Long.valueOf(companyId));
-                        conversationRecordAttrs.put("to_id",conversation.getLong("service_account_id"));
-                        conversationRecordAttrs.put("type",0);
-
-                    }else if(VisitTypeEnum.VISITOR.getKey().equals(visitType)){
-                        // VISITOR 游客  发送的消息
-                        String visitorId = user.getExtras().getString("visitorId");
-                        conversationRecordAttrs.put("from_id",Long.valueOf(visitorId));
-                        conversationRecordAttrs.put("to_id",conversation.getLong("service_account_id"));
-                        conversationRecordAttrs.put("type",0);
-                    }else{
-                        //SERVICEACCOUNT 客服  发送的消息
-                        String serviceAccountId = user.getExtras().getString("serviceAccountId");
-                        conversationRecordAttrs.put("from_id",Long.valueOf(serviceAccountId));
-                        conversationRecordAttrs.put("to_id",conversation.getLong("user_id"));
-                        JSONObject jsonObject = chatBody.getExtras();
-                        if( null != jsonObject && jsonObject.size() > 0 ){
-                            //客服自动发送的消息
-                            Integer sendType = jsonObject.getInteger("sendType");
-                            if( null != sendType && sendType == 2 ){
-                                conversationRecordAttrs.put("type",sendType);
-                            }
-                        }else{
-                            conversationRecordAttrs.put("type",1);
-                        }
+                GroupConversationMiddle groupConversationMiddle
+                        = getGroupConversationMiddleByGroupId(group.getLong("group_id"));
+                if( null != groupConversationMiddle ){
+                    Conversation conversation = Conversation.dao.findById(groupConversationMiddle.getLong("conversation_id"));
+                    if( null != conversation){
+                        ConversationRecord.dao
+                                ._setAttrs(this.getConversationRecordAttrs(chatBody,conversation,groupConversationMiddle))
+                                .save();
                     }
-                    conversationRecordAttrs.put("conversation_id",group.getLong("conversation_id"));
-                    ConversationRecord.dao._setAttrs(conversationRecordAttrs).save();
                 }
             }
-
         }
 
         log.info("聊天记录持久化... 结束:" + sdf.format(new Date()));
 
     }
+
+    /**
+     * 组装ConversationRecord数据
+     * @param chatBody
+     * @param conversation
+     * @return
+     */
+    private Map<String, Object> getConversationRecordAttrs(ChatBody chatBody, Conversation conversation, GroupConversationMiddle groupConversationMiddle){
+        Map<String, Object> conversationRecordAttrs = new HashMap<>();
+        conversationRecordAttrs.put("id", SnowflakeIdUtils.getInstance().nextId());
+        conversationRecordAttrs.put("chat_body_id",chatBody.getId());
+        conversationRecordAttrs.put("content",chatBody.getContent());
+        conversationRecordAttrs.put("is_recall",0);
+        String fromId = chatBody.getFrom();
+        // customerDepartmentId  visitorDepartmentId  serviceAccountRoleDepartmentId
+        User user = ImAio.getUser(fromId);
+        String visitType = user.getVisitType();
+        if(VisitTypeEnum.CUSTOMER.getKey().equals(visitType)){
+            // CUSTOMER 客户  发送的消息
+            String companyId = user.getExtras().getString("customerId");
+            conversationRecordAttrs.put("from_id",Long.valueOf(companyId));
+            conversationRecordAttrs.put("to_id",conversation.getLong("service_account_id"));
+            conversationRecordAttrs.put("type",0);
+
+        }else if(VisitTypeEnum.VISITOR.getKey().equals(visitType)){
+            // VISITOR 游客  发送的消息
+            String visitorId = user.getExtras().getString("visitorId");
+            conversationRecordAttrs.put("from_id",Long.valueOf(visitorId));
+            conversationRecordAttrs.put("to_id",conversation.getLong("service_account_id"));
+            conversationRecordAttrs.put("type",0);
+        }else{
+            //SERVICEACCOUNT 客服  发送的消息
+            String serviceAccountId = user.getExtras().getString("serviceAccountId");
+            conversationRecordAttrs.put("from_id",Long.valueOf(serviceAccountId));
+            conversationRecordAttrs.put("to_id",conversation.getLong("user_id"));
+            JSONObject jsonObject = chatBody.getExtras();
+            if(
+                       null != jsonObject
+                    && jsonObject.size() > 0
+                    && Integer.valueOf(2).equals(jsonObject.getInteger("sendType"))
+            ){
+                //客服自动发送的消息
+                conversationRecordAttrs.put("type",jsonObject.getInteger("sendType"));
+            }else{
+                //客服手动发送的消息
+                conversationRecordAttrs.put("type",1);
+                //判断 客服 是否第一次回复 (依据:是之前 first_answer_time 字段 和 first_answer_lenth 字段 值 是否为空 )
+                Timestamp firstAnswerTime = conversation.getTimestamp("first_answer_time");
+                Integer firstAnswerLenth = conversation.getInt("first_answer_lenth");
+                if( null == firstAnswerTime && null == firstAnswerLenth ){
+                    //说明客服是第一次回复
+                    long currentTimeMillis = System.currentTimeMillis();
+                    //当前时间的格林威治时间 毫秒数
+                    Timestamp currentTime = new Timestamp(currentTimeMillis);
+                    Timestamp createTime = conversation.getTimestamp("create_time");
+                    //会话创建时间的格林威治时间 毫秒数
+                    long createTimeMillis = createTime.getTime();
+                    if(currentTimeMillis > createTimeMillis){
+                        conversation.set("first_answer_time",currentTime);
+                        conversation.set("first_answer_lenth",Integer.valueOf( String.valueOf( (currentTimeMillis - createTimeMillis)/1000 )));
+                    }
+
+                }
+            }
+        }
+        conversationRecordAttrs.put(
+                "conversation_id"
+                ,groupConversationMiddle.getLong("conversation_id")
+        );
+        return conversationRecordAttrs;
+    }
+
+    /**
+     * 获取最新的 GroupConversationMiddle 对象 (根据groupId)
+     * @param
+     * @return {@link {@link GroupConversationMiddle}}
+     * @author Darren
+     * @date 2020/2/11 19:03
+     */
+    private GroupConversationMiddle getGroupConversationMiddleByGroupId(Long groupId){
+        StringBuilder sql = new StringBuilder();
+        sql.append(" select * from sw_group_conversation_middle where group_id = " + groupId)
+                .append(" order by create_time desc limit 1");
+        return GroupConversationMiddle.dao.findFirst(sql.toString());
+    }
+
 }

server-chat/src/main/java/com/cn/service/IMChatLoginServiceProcessor.java

@@ -424,8 +424,12 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
                 = ServiceAccountRoleDepartmentMiddle.dao.findById(group.getServiceAccountRoleDepartmentId());
         attrs.put("service_account_id", pojo.getLong("service_account_id"));
         Conversation.dao._setAttrs(attrs).save();
-        //保存 会话id 存入user中
-        ChatGroup.dao.findById(group.getGroup_id()).set("conversation_id",conversationId).update();
+        // 添加 sw_group_conversation_middle 数据
+        GroupConversationMiddle.dao
+                .set("id",SnowflakeIdUtils.getInstance().nextId())
+                .set("group_id",group.getGroup_id())
+                .set("conversation_id",conversationId)
+                .save();
     }
 
     /**