社群邀请逻辑

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/GroupChatActivityInviteLogService.java

 package com.gic.haoban.manage.service.service.chat;
 
 import com.gic.api.base.commons.Page;
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.haoban.manage.api.dto.chat.GroupChatActivityInviteLogDTO;
 import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityInviteLogQDTO;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatUser;

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatActivityInviteLogServiceImpl.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.Constant;
 import com.gic.api.base.commons.Page;
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.GICMQClientUtil;
 import com.gic.commons.util.PageHelperUtils;

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatServiceImpl.java

@@ -15,6 +15,7 @@ import com.gic.enterprise.api.service.StoreService;
 import com.gic.haoban.manage.service.dao.mapper.WxEnterpriseMapper;
 import com.gic.haoban.manage.service.service.*;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityInviteLogService;
+import com.gic.haoban.manage.service.util.ExecuteServiceUtil;
 import com.gic.member.ext.api.enums.growth.GrowthRuleEnum;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
@@ -752,7 +753,7 @@ public class GroupChatServiceImpl implements GroupChatService {
             }
             if (CollectionUtils.isNotEmpty(needAddUserList)) {
                 this.groupChatUserMapper.batchInsert(needAddUserList);
-                groupChatActivityInviteLogService.groupChatInviteMQ(needAddUserList);
+                ExecuteServiceUtil.executeService(() -> groupChatActivityInviteLogService.groupChatInviteMQ(needAddUserList), "社群邀请异常");
             }
             // 删除退群的人
             List<Long> deleteIdList = new ArrayList<>();

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/chat/GroupChatActivityShareApiServiceImpl.java

 package com.gic.haoban.manage.service.service.out.impl.chat;
 
+import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.BusinessException;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
@@ -9,6 +10,7 @@ import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityShareBindQDTO;
 import com.gic.haoban.manage.api.service.chat.GroupChatActivityShareApiService;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityShareBind;
 //import com.gic.haoban.manage.service.pojo.bo.chat.GroupChatActivityBaseContext;
+import com.gic.haoban.manage.service.pojo.bo.chat.GroupChatActivityBaseContext;
 import com.gic.haoban.manage.service.pojo.bo.chat.GroupChatHmBO;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityInviteLogService;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityService;
@@ -63,8 +65,8 @@ public class GroupChatActivityShareApiServiceImpl implements GroupChatActivitySh
 
     @Override
     public ServiceResponse<Void> shareGroupChatInviteMQ(String param) {
-//        GroupChatActivityBaseContext chatActivityContext = JSONObject.parseObject(param, GroupChatActivityBaseContext.class);
-//        groupChatActivityInviteLogService.groupChatInvite(chatActivityContext);
+        GroupChatActivityBaseContext chatActivityContext = JSONObject.parseObject(param, GroupChatActivityBaseContext.class);
+        groupChatActivityInviteLogService.groupChatInvite(chatActivityContext);
         return ServiceResponse.success();
     }
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/util/ExecuteServiceUtil.java

@@ -23,4 +23,11 @@ public class ExecuteServiceUtil {
         }
     }
 
+    public static void executeService(Runnable serviceCall, String errorMsg) {
+        try {
+            serviceCall.run();
+        } catch (Exception e) {
+            logger.error(errorMsg, e);
+        }
+    }
 }