统计数据

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/chat/GroupChatActivityDataController.java

@@ -24,6 +24,7 @@ import com.gic.haoban.manage.web.handle.GroupChatActivityRewardHandle;
 import com.gic.haoban.manage.web.qo.chat.GroupChatActivityDataInviterDetailReq;
 import com.gic.haoban.manage.web.qo.chat.GroupChatActivityDataOverviewReq;
 import com.gic.haoban.manage.web.qo.chat.GroupChatActivityDataRewardLevelReq;
+import com.gic.haoban.manage.web.qo.chat.GroupChatActivityJoinDataReq;
 import com.gic.haoban.manage.web.vo.chat.*;
 import com.gic.member.api.constant.RewardResultTypeEnum;
 import com.gic.member.api.dto.MemberDTO;
@@ -76,6 +77,50 @@ public class GroupChatActivityDataController {
     @Resource
     private GroupChatActivityRewardHandle groupChatActivityRewardHandle;
 
+    /**
+     * 数据概览
+     *
+     * @param joinDataReq
+     * @return
+     */
+    @RequestMapping("get-join-data-list")
+    @ResponseBody
+    public RestResponse<List<GroupChatActivityJoinDataVO>> getJoinDataList(@RequestBody GroupChatActivityJoinDataReq joinDataReq) {
+        WebLoginDTO user = AuthWebRequestUtil.getLoginUser();
+
+        GroupChatActivityDataOverviewReq overviewReq = new GroupChatActivityDataOverviewReq();
+        overviewReq.setEnterpriseId(user.getEnterpriseId());
+        overviewReq.setChatActivityId(StringUtils.join(joinDataReq.getChatActivityIdList(), ","));
+
+        Map<String, Object> res = DataApiUtils.http(JSON.toJSONString(overviewReq), StatisticsApolloKeyConstant.data_mkt_group_chat_data_overview);
+        Map<String, GroupChatDataOverviewVO> map = Maps.newHashMap();
+        List<GroupChatDataOverviewVO> list = DataApiUtils.parsePageDataList(res, GroupChatDataOverviewVO.class);
+
+        if (CollectionUtils.isNotEmpty(list)) {
+            map = list.stream().collect(Collectors.toMap(GroupChatDataOverviewVO::getChatActivityId, groupChatDataOverviewVO -> groupChatDataOverviewVO));
+        }
+        Map<String, GroupChatDataOverviewVO> finalMap = map;
+        List<GroupChatActivityJoinDataVO> joinDataVOList = joinDataReq.getChatActivityIdList().stream().map(chatActivityId -> {
+            GroupChatActivityJoinDataVO groupChatActivityJoinDataVO = new GroupChatActivityJoinDataVO();
+            groupChatActivityJoinDataVO.setChatActivityId(chatActivityId);
+            GroupChatDataOverviewVO groupChatDataOverviewVO = finalMap.get(chatActivityId.toString());
+            if(Objects.nonNull(groupChatDataOverviewVO)){
+                if(StringUtils.isNotEmpty(groupChatDataOverviewVO.getInviterNum())){
+                    groupChatActivityJoinDataVO.setInviterNum(Integer.parseInt(groupChatDataOverviewVO.getInviterNum()));
+                }
+                if(StringUtils.isNotEmpty(groupChatDataOverviewVO.getInviteeNum())){
+                    groupChatActivityJoinDataVO.setInviteeNum(Integer.parseInt(groupChatDataOverviewVO.getInviteeNum()));
+                }
+                if(StringUtils.isNotEmpty(groupChatDataOverviewVO.getEffectiveInviteeNum())){
+                    groupChatActivityJoinDataVO.setEffectiveInviteeNum(Integer.parseInt(groupChatDataOverviewVO.getEffectiveInviteeNum()));
+                }
+            }
+            return groupChatActivityJoinDataVO;
+        }).collect(Collectors.toList());
+
+        return RestResponse.successResult(joinDataVOList);
+    }
+
 
     /**
      * 数据概览

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/qo/chat/GroupChatActivityJoinDataReq.java

+package com.gic.haoban.manage.web.qo.chat;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author shangfeng
+ * @date 2024-10-12 10:12:32
+ */
+public class GroupChatActivityJoinDataReq implements Serializable {
+
+    private static final long serialVersionUID = 8101720675682708878L;
+
+    private List<Long> chatActivityIdList;
+
+    public List<Long> getChatActivityIdList() {
+        return chatActivityIdList;
+    }
+
+    public void setChatActivityIdList(List<Long> chatActivityIdList) {
+        this.chatActivityIdList = chatActivityIdList;
+    }
+}

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/vo/chat/GroupChatActivityJoinDataVO.java

+package com.gic.haoban.manage.web.vo.chat;
+
+import java.io.Serializable;
+
+/**
+ * @author shangfeng
+ * @date 2024-10-12 10:07:35
+ */
+public class GroupChatActivityJoinDataVO implements Serializable {
+
+    private static final long serialVersionUID = 753629197049532832L;
+
+    private Long chatActivityId;
+
+    /**
+     * 参与人数
+     */
+    private Integer inviterNum = 0;
+
+    /**
+     * 邀请进群人数
+     */
+    private Integer inviteeNum = 0;
+
+    /**
+     * 有效邀请人数
+     */
+    private Integer effectiveInviteeNum = 0;
+
+    public Long getChatActivityId() {
+        return chatActivityId;
+    }
+
+    public void setChatActivityId(Long chatActivityId) {
+        this.chatActivityId = chatActivityId;
+    }
+
+    public Integer getInviterNum() {
+        return inviterNum;
+    }
+
+    public void setInviterNum(Integer inviterNum) {
+        this.inviterNum = inviterNum;
+    }
+
+    public Integer getInviteeNum() {
+        return inviteeNum;
+    }
+
+    public void setInviteeNum(Integer inviteeNum) {
+        this.inviteeNum = inviteeNum;
+    }
+
+    public Integer getEffectiveInviteeNum() {
+        return effectiveInviteeNum;
+    }
+
+    public void setEffectiveInviteeNum(Integer effectiveInviteeNum) {
+        this.effectiveInviteeNum = effectiveInviteeNum;
+    }
+}

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/vo/chat/GroupChatDataOverviewVO.java

@@ -65,5 +65,91 @@ public class GroupChatDataOverviewVO implements Serializable {
      */
     private String cardCnt;
 
+    public String getChatActivityId() {
+        return chatActivityId;
+    }
 
+    public void setChatActivityId(String chatActivityId) {
+        this.chatActivityId = chatActivityId;
+    }
+
+    public String getShareNum() {
+        return shareNum;
+    }
+
+    public void setShareNum(String shareNum) {
+        this.shareNum = shareNum;
+    }
+
+    public String getInviterNum() {
+        return inviterNum;
+    }
+
+    public void setInviterNum(String inviterNum) {
+        this.inviterNum = inviterNum;
+    }
+
+    public String getInviteeNum() {
+        return inviteeNum;
+    }
+
+    public void setInviteeNum(String inviteeNum) {
+        this.inviteeNum = inviteeNum;
+    }
+
+    public String getEffectiveInviteeNum() {
+        return effectiveInviteeNum;
+    }
+
+    public void setEffectiveInviteeNum(String effectiveInviteeNum) {
+        this.effectiveInviteeNum = effectiveInviteeNum;
+    }
+
+    public String getInviteeMemberNum() {
+        return inviteeMemberNum;
+    }
+
+    public void setInviteeMemberNum(String inviteeMemberNum) {
+        this.inviteeMemberNum = inviteeMemberNum;
+    }
+
+    public String getInviteeNonMemberNum() {
+        return inviteeNonMemberNum;
+    }
+
+    public void setInviteeNonMemberNum(String inviteeNonMemberNum) {
+        this.inviteeNonMemberNum = inviteeNonMemberNum;
+    }
+
+    public String getNewMemberNum() {
+        return newMemberNum;
+    }
+
+    public void setNewMemberNum(String newMemberNum) {
+        this.newMemberNum = newMemberNum;
+    }
+
+    public String getIntegralCnt() {
+        return integralCnt;
+    }
+
+    public void setIntegralCnt(String integralCnt) {
+        this.integralCnt = integralCnt;
+    }
+
+    public String getGrowCnt() {
+        return growCnt;
+    }
+
+    public void setGrowCnt(String growCnt) {
+        this.growCnt = growCnt;
+    }
+
+    public String getCardCnt() {
+        return cardCnt;
+    }
+
+    public void setCardCnt(String cardCnt) {
+        this.cardCnt = cardCnt;
+    }
 }