连接关闭之后 删除临时群组(离线群组不可删除)

jim-server/src/main/java/org/jim/server/enums/ServiceAccountOfflineType.java

@@ -5,7 +5,7 @@ package org.jim.server.enums;
  * @author Darren
  * @date 2020/2/5 20:13
  */
-public enum ServiceAccountOfflineType {
+public enum ServiceAccountOfflineTypeEnum {
 
     YES(1, "是离线状态"),
     NO(0, "不是离线状态");
@@ -13,7 +13,7 @@ public enum ServiceAccountOfflineType {
     private int key;
     private String desc;
 
-    private ServiceAccountOfflineType(int key, String desc) {
+    private ServiceAccountOfflineTypeEnum(int key, String desc) {
         this.key = key;
         this.desc = desc;
     }

server-chat/src/main/java/com/cn/ServerChatStart.java

@@ -1,6 +1,7 @@
 package com.cn;
 
 import com.cn.config.PropertyDataBaseConfigBuilder;
+import com.cn.listener.IMChatGroupListener;
 import com.cn.model.ServiceAccountRoleDepartmentMiddle;
 import com.cn.processor.IMChatWsHandshakeProcessor;
 import com.cn.service.IMChatLoginServiceProcessor;
@@ -41,7 +42,7 @@ public class ServerChatStart {
         ImConfig imConfig = new PropertyImConfigBuilder("jim.properties").build();
 
         //设置群组监听器，非必须，根据需要自己选择性实现;
-        //imConfig.setImGroupListener(new ImDemoGroupListener());
+        imConfig.setImGroupListener(new IMChatGroupListener());
 
         ImServerStarter imServerStarter = new ImServerStarter(imConfig);
         /*****************start 以下处理器根据业务需要自行添加与扩展，每个Command都可以添加扩展,此处为demo中处理**********************************/

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

@@ -0,0 +1,55 @@
+package com.cn.listener;
+
+import com.cn.model.ChatGroup;
+import org.jim.common.ImAio;
+import org.jim.common.ImPacket;
+import org.jim.common.ImSessionContext;
+import org.jim.common.packets.*;
+import org.jim.server.enums.ServiceAccountOfflineTypeEnum;
+import org.jim.server.enums.VisitTypeEnum;
+import org.jim.server.listener.ImGroupListener;
+import org.tio.core.ChannelContext;
+
+/**
+ * @author Darren
+ * @date 2020/2/6 15:53
+ */
+public class IMChatGroupListener extends ImGroupListener {
+
+
+    @Override
+    public void onAfterUnbind(ChannelContext channelContext, String group) throws Exception {
+
+        ImSessionContext imSessionContext = (ImSessionContext)channelContext.getAttribute();
+        ExitGroupNotifyRespBody exitGroupNotifyRespBody = new ExitGroupNotifyRespBody();
+        exitGroupNotifyRespBody.setGroup(group);
+        Client client = imSessionContext.getClient();
+        if(client == null){
+            return;
+        }
+        User clientUser = client.getUser();
+        if(clientUser == null) {
+            return;
+        }
+        //访问类型 (SERVICEACCOUNT 客服 / CUSTOMER 客户 / VISITOR 游客)
+        String visitType = clientUser.getVisitType();
+        if( !VisitTypeEnum.SERVICEACCOUNT.equals(visitType) ){
+            //客户 / 游客 关闭连接 退出群组 后 删除临时群组
+            ChatGroup chatGroup = ChatGroup.dao.findById(group);
+            Integer serviceAccountType = chatGroup.getInt("service_account_type");
+            if( ServiceAccountOfflineTypeEnum.NO.getKey() == serviceAccountType ){
+                //在线群组 才可以删除
+                ChatGroup.dao.deleteById(group);
+            }
+        }
+
+        User notifyUser = new User(clientUser.getId(),clientUser.getNick());
+        exitGroupNotifyRespBody.setUser(notifyUser);
+
+        RespBody respBody = new RespBody(Command.COMMAND_EXIT_GROUP_NOTIFY_RESP,exitGroupNotifyRespBody);
+        ImPacket imPacket = new ImPacket(Command.COMMAND_EXIT_GROUP_NOTIFY_RESP, respBody.toByte());
+        ImAio.sendToGroup(group, imPacket);
+    }
+
+
+}

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

@@ -165,7 +165,7 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
             Group group = this.createGroup(user);
             //把 Group 转成 Map 用于 jfianl框架的 添加使用
             Map<String, Object> attrs = groupToMap(group);
-            attrs.put("service_account_type",ServiceAccountOfflineType.NO.getKey());
+            attrs.put("service_account_type", ServiceAccountOfflineTypeEnum.NO.getKey());
             //jfianl框架的 保存
             ChatGroup.dao._setAttrs(attrs).save();
             groups.add(group);
@@ -247,7 +247,7 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
                 //把 Group 转成 Map 用于 jfianl框架的 添加使用
                 Map<String, Object> attrs = groupToMap(group);
                 //客服是否是离线状态 1: 是 0: 否
-                attrs.put("service_account_type",ServiceAccountOfflineType.NO.getKey());
+                attrs.put("service_account_type", ServiceAccountOfflineTypeEnum.NO.getKey());
                 //jfianl框架的 保存
                 ChatGroup.dao._setAttrs(attrs).save();
                 groups.add(group);
@@ -269,7 +269,7 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
                     //把 Group 转成 Map 用于 jfianl框架的 添加使用
                     Map<String, Object> attrs = groupToMap(group);
                     //客服是否是离线状态 1: 是 0: 否
-                    attrs.put("service_account_type",ServiceAccountOfflineType.YES.getKey());
+                    attrs.put("service_account_type", ServiceAccountOfflineTypeEnum.YES.getKey());
                     //jfianl框架的 保存
                     ChatGroup.dao._setAttrs(attrs).save();
                     groups.add(group);
@@ -294,22 +294,22 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
     private void createConversation(Group group,User user) {
         ServiceAccountRoleDepartmentMiddle dao = ServiceAccountRoleDepartmentMiddle.dao;
         Map<String, Object> attrs = new HashMap<>();
-        attrs.put("id", group.getGroup_id());
+        attrs.put("id", Long.valueOf(group.getGroup_id()));
         //会话状态 0：游客会话 1：客户会话  群组类型 0:游客-客服 类型 1:客户-客服 类型
         attrs.put("state", group.getGroupType());
         if(VisitTypeEnum.CUSTOMER.getKey().equals(user.getVisitType())){
-            attrs.put("user_id", user.getExtras().getString("customerId"));
+            attrs.put("user_id", Long.valueOf(user.getExtras().getString("customerId")));
         }
         if(VisitTypeEnum.VISITOR.getKey().equals(user.getVisitType())){
-            attrs.put("user_id", user.getExtras().getString("visitorId"));
+            attrs.put("user_id", Long.valueOf(user.getExtras().getString("visitorId")));
         }
         attrs.put("user_nickname", user.getNick());
         attrs.put("user_phone", user.getExtras().getString("phone"));
-        attrs.put("company_id", group.getCompanyId());
-        attrs.put("department_id", group.getDepartmentId());
+        attrs.put("company_id", Long.valueOf(group.getCompanyId()));
+        attrs.put("department_id", Long.valueOf(group.getDepartmentId()));
         ServiceAccountRoleDepartmentMiddle pojo
                 = dao.findById(group.getServiceAccountRoleDepartmentId());
-        attrs.put("service_account_id", pojo.get("service_account_id"));
+        attrs.put("service_account_id", Long.valueOf(pojo.get("service_account_id")));
         dao._setAttrs(attrs).save();
     }
 
@@ -556,7 +556,7 @@ public class IMChatLoginServiceProcessor implements LoginCmdProcessor {
         if( !CollectionUtils.isEmpty(chatGroups) ){
             for (ChatGroup chatGroup : chatGroups) {
                 ChatGroup.dao.findById(chatGroup.getStr("group_id"))
-                        .set("service_account_type", ServiceAccountOfflineType.NO.getKey())
+                        .set("service_account_type", ServiceAccountOfflineTypeEnum.NO.getKey())
                         .update();
             }
         }