获取活码

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

 package com.gic.haoban.manage.api.service.chat;
 
 import com.gic.api.base.commons.ServiceResponse;
+import com.gic.haoban.manage.api.dto.chat.GroupChatHmDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityHmQDTO;
 import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityShareBindQDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityShareQDTO;
+import org.checkerframework.checker.units.qual.C;
+
+import java.util.List;
 
 /**
  * Created by wangzubo on 2022/10/31.
@@ -13,6 +19,19 @@ public interface GroupChatActivityShareApiService {
      * 绑定分享关系
      * @param shareBind
      */
-    ServiceResponse<Void> shareBing(GroupChatActivityShareBindQDTO shareBind);
+    ServiceResponse<Void> shareBind(GroupChatActivityShareBindQDTO shareBind);
+
+    /**
+     * 获取入群活码列表
+     * @param activityHmQDTO
+     * @return
+     */
+    ServiceResponse<List<GroupChatHmDTO>> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO);
 
+    /**
+     * 社群入群MQ
+     * @param param
+     * @return
+     */
+    ServiceResponse<Void> shareGroupChatInviteMQ(String param);
 }

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

@@ -107,10 +107,10 @@ public interface GroupChatActivityService {
      */
     void activityQuartzUpdateStatus();
 
-//    /**
-//     * 获取入群活码列表
-//     * @param activityHmQDTO
-//     * @return
-//     */
-//    List<GroupChatHmBO> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO) throws BusinessException;
+    /**
+     * 获取入群活码列表
+     * @param activityHmQDTO
+     * @return
+     */
+    List<GroupChatHmBO> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO) throws BusinessException;
 }

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

@@ -23,6 +23,7 @@ import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityJoinQDTO;
 import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityQDTO;
 import com.gic.haoban.manage.api.qdto.chat.GroupChatActivitySearchQDTO;
 import com.gic.haoban.manage.service.context.chat.BusinessManager;
+import com.gic.haoban.manage.service.context.chat.JoinRuleManager;
 import com.gic.haoban.manage.service.dao.mapper.chat.GroupChatActivityMapper;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivity;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityJoin;
@@ -67,8 +68,8 @@ public class GroupChatActivityServiceImpl implements GroupChatActivityService {
     private GroupChatActivityJoinService groupChatActivityJoinService;
     @Autowired
     private BusinessManager businessManager;
-//    @Autowired
-//    private JoinRuleManager joinRuleManager;
+    @Autowired
+    private JoinRuleManager joinRuleManager;
 
 
     @Override
@@ -372,15 +373,15 @@ public class GroupChatActivityServiceImpl implements GroupChatActivityService {
         }
     }
 
-//    @Override
-//    public List<GroupChatHmBO> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO) throws BusinessException{
-//        Long chatActivityId = activityHmQDTO.getChatActivityId();
-//        String enterpriseId = activityHmQDTO.getEnterpriseId();
-//        GroupChatActivityDTO chatActivity = getActivityDetail(enterpriseId,chatActivityId);
-//        if (chatActivity == null) {
-//            return Collections.emptyList();
-//        }
-//        activityHmQDTO.setChatActivity(chatActivity);
-//        return joinRuleManager.listGroupHm(activityHmQDTO);
-//    }
+    @Override
+    public List<GroupChatHmBO> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO) throws BusinessException{
+        Long chatActivityId = activityHmQDTO.getChatActivityId();
+        String enterpriseId = activityHmQDTO.getEnterpriseId();
+        GroupChatActivityDTO chatActivity = getActivityDetailCache(enterpriseId,chatActivityId);
+        if (chatActivity == null) {
+            return Collections.emptyList();
+        }
+        activityHmQDTO.setChatActivity(chatActivity);
+        return joinRuleManager.listGroupHm(activityHmQDTO);
+    }
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/chat/GroupChatActivityShareServiceImpl.java → 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;
+import com.gic.haoban.manage.api.dto.chat.GroupChatHmDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityHmQDTO;
 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.GroupChatHmBO;
+import com.gic.haoban.manage.service.service.chat.GroupChatActivityInviteLogService;
+import com.gic.haoban.manage.service.service.chat.GroupChatActivityService;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityShareBindService;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Objects;
+
 @Service("groupChatActivityShareApiService")
-public class GroupChatActivityShareServiceImpl implements GroupChatActivityShareApiService {
+public class GroupChatActivityShareApiServiceImpl implements GroupChatActivityShareApiService {
 
     @Autowired
     private GroupChatActivityShareBindService activityShareBindService;
+    @Autowired
+    private GroupChatActivityService groupChatActivityService;
+    @Autowired
+    private GroupChatActivityInviteLogService groupChatActivityInviteLogService;
 
     @Override
-    public ServiceResponse<Void> shareBing(GroupChatActivityShareBindQDTO shareBind) {
+    public ServiceResponse<Void> shareBind(GroupChatActivityShareBindQDTO shareBind) {
         String enterpriseId = shareBind.getEnterpriseId();
         Long chatActivityId = shareBind.getChatActivityId();
         String inviterMemberId = shareBind.getInviterMemberId();
@@ -26,7 +41,31 @@ public class GroupChatActivityShareServiceImpl implements GroupChatActivityShare
             return ServiceResponse.failure("500","参数异常");
         }
         TabGroupChatActivityShareBind bind = EntityUtil.changeEntityNew(TabGroupChatActivityShareBind.class, shareBind);
-        activityShareBindService.shareBing(bind);
+        activityShareBindService.shareBind(bind);
+        return ServiceResponse.success();
+    }
+
+    @Override
+    public ServiceResponse<List<GroupChatHmDTO>> listGroupChatHm(GroupChatActivityHmQDTO activityHmQDTO) {
+        if (StringUtils.isAnyBlank(activityHmQDTO.getEnterpriseId(),
+                activityHmQDTO.getInviterMemberId()) || activityHmQDTO.getChatActivityId() == null) {
+            return ServiceResponse.failure("500", "参数异常");
+        }
+        if (Objects.equals(activityHmQDTO.getInviterMemberId(), activityHmQDTO.getInviteeMemberId())) {
+            return ServiceResponse.failure("500", "无法邀请自己");
+        }
+        try {
+            List<GroupChatHmBO> hmBOList = groupChatActivityService.listGroupChatHm(activityHmQDTO);
+            return ServiceResponse.success(EntityUtil.changeEntityListNew(GroupChatHmDTO.class,hmBOList));
+        } catch (BusinessException e) {
+            return ServiceResponse.failure(e.getCode(), e.getMessage());
+        }
+    }
+
+    @Override
+    public ServiceResponse<Void> shareGroupChatInviteMQ(String param) {
+        GroupChatActivityBaseContext chatActivityContext = JSONObject.parseObject(param, GroupChatActivityBaseContext.class);
+        groupChatActivityInviteLogService.groupChatInvite(chatActivityContext);
         return ServiceResponse.success();
     }
 }