奖励明细

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/chat/GroupChatActivityRewardLogDTO.java

@@ -2,6 +2,7 @@ package com.gic.haoban.manage.api.dto.chat;
 
 import java.io.Serializable;
 import java.util.Date;
+import java.util.List;
 
 /**
  * @author shangfeng
@@ -50,6 +51,8 @@ public class GroupChatActivityRewardLogDTO implements Serializable {
 
     private Date updateTime;
 
+    private List<GroupChatActivityRewardDetailLogDTO> rewardDetailLogDTOList;
+
     public Long getChatActivityRewardId() {
         return chatActivityRewardId;
     }
@@ -121,4 +124,12 @@ public class GroupChatActivityRewardLogDTO implements Serializable {
     public void setUpdateTime(Date updateTime) {
         this.updateTime = updateTime;
     }
+
+    public List<GroupChatActivityRewardDetailLogDTO> getRewardDetailLogDTOList() {
+        return rewardDetailLogDTOList;
+    }
+
+    public void setRewardDetailLogDTOList(List<GroupChatActivityRewardDetailLogDTO> rewardDetailLogDTOList) {
+        this.rewardDetailLogDTOList = rewardDetailLogDTOList;
+    }
 }

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/qdto/chat/GroupChatActivityRewardDetailLogQDTO.java

+package com.gic.haoban.manage.api.qdto.chat;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author shangfeng
+ * @date 2024-10-09 10:41:40
+ */
+public class GroupChatActivityRewardDetailLogQDTO implements Serializable {
+
+    private static final long serialVersionUID = -2314846257775934409L;
+
+    private List<Long> rewardLogIdList;
+
+    public List<Long> getRewardLogIdList() {
+        return rewardLogIdList;
+    }
+
+    public void setRewardLogIdList(List<Long> rewardLogIdList) {
+        this.rewardLogIdList = rewardLogIdList;
+    }
+}

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/qdto/chat/GroupChatActivityRewardLogQDTO.java

@@ -21,7 +21,29 @@ public class GroupChatActivityRewardLogQDTO extends BasePageInfo implements Seri
     /**
      * 邀请人会员ID
      */
-    private String inviterMemberId;
+    private String memberId;
 
+    public String getEnterpriseId() {
+        return enterpriseId;
+    }
 
+    public void setEnterpriseId(String enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public Long getChatActivityId() {
+        return chatActivityId;
+    }
+
+    public void setChatActivityId(Long chatActivityId) {
+        this.chatActivityId = chatActivityId;
+    }
+
+    public String getMemberId() {
+        return memberId;
+    }
+
+    public void setMemberId(String memberId) {
+        this.memberId = memberId;
+    }
 }

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

@@ -13,7 +13,6 @@ import java.util.List;
  */
 public interface GroupChatActivityInviteLogApiService {
 
-
     /**
      * 查询C端邀请人数据
      *

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

+package com.gic.haoban.manage.api.service.chat;
+
+import com.gic.api.base.commons.Page;
+import com.gic.api.base.commons.ServiceResponse;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author shangfeng
+ * @date 2024-10-09 10:59:53
+ */
+public interface GroupChatActivityRewardLogApiService {
+
+    /**
+     * 查询奖励详情
+     *
+     * @param rewardLogQDTO
+     * @return
+     */
+    ServiceResponse<Page<GroupChatActivityRewardLogDTO>> queryRewardLogDetails(GroupChatActivityRewardLogQDTO rewardLogQDTO);
+}

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/chat/GroupChatActivityRewardDetailLogMapper.java

 package com.gic.haoban.manage.service.dao.mapper.chat;
 
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardDetailLogQDTO;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityRewardDetailLog;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.data.domain.Pageable;
@@ -63,5 +64,12 @@ public interface GroupChatActivityRewardDetailLogMapper {
      */
     int deleteById(Long chatActivityRewardDetailId);
 
+    /**
+     * 批量查询奖励明细
+     *
+     * @param rewardDetailLogQDTO
+     * @return
+     */
+    List<TabGroupChatActivityRewardDetailLog> queryList(GroupChatActivityRewardDetailLogQDTO rewardDetailLogQDTO);
 }
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/chat/GroupChatActivityRewardLogMapper.java

 package com.gic.haoban.manage.service.dao.mapper.chat;
 
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
 import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityRewardLog;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.data.domain.Pageable;
@@ -63,5 +65,12 @@ public interface GroupChatActivityRewardLogMapper {
      */
     int deleteById(Long chatActivityRewardId);
 
+    /**
+     * 查询奖励数据
+     *
+     * @param rewardLogQDTO
+     * @return
+     */
+    List<TabGroupChatActivityRewardLog> queryList(GroupChatActivityRewardLogQDTO rewardLogQDTO);
 }
 

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

 package com.gic.haoban.manage.service.service.chat;
 
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardDetailLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardDetailLogQDTO;
+
+import java.util.List;
+
 /**
  * 社群活动完成奖励明细表(TabHaobanGroupChatActivityRewardDetailLog)表服务接口
  *
@@ -8,4 +13,12 @@ package com.gic.haoban.manage.service.service.chat;
  */
 public interface GroupChatActivityRewardDetailLogService {
 
+    /**
+     * 查询奖励明细数据
+     *
+     * @param rewardDetailLogQDTO
+     * @return
+     */
+    List<GroupChatActivityRewardDetailLogDTO> queryList(GroupChatActivityRewardDetailLogQDTO rewardDetailLogQDTO);
+
 }

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

@@ -2,6 +2,7 @@ package com.gic.haoban.manage.service.service.chat;
 
 import com.gic.api.base.commons.Page;
 import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
 
 /**
  * 内容活动完成奖励表(TabHaobanGroupChatActivityRewardLog)表服务接口
@@ -12,5 +13,12 @@ import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
 public interface GroupChatActivityRewardLogService {
 
 
-    Page<GroupChatActivityRewardLogDTO> queryRewardLogDetails();
+    /**
+     * 奖励明细
+     *
+     * @param rewardLogQDTO
+     * @return
+     */
+    Page<GroupChatActivityRewardLogDTO> queryRewardLogDetails(GroupChatActivityRewardLogQDTO rewardLogQDTO);
+
 }

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

 package com.gic.haoban.manage.service.service.chat.impl;
 
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityInviteLogDTO;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardDetailLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardDetailLogQDTO;
 import com.gic.haoban.manage.service.dao.mapper.chat.GroupChatActivityRewardDetailLogMapper;
+import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityInviteLog;
+import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityRewardDetailLog;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityRewardDetailLogService;
+import com.google.common.collect.Lists;
+import org.apache.commons.collections.CollectionUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 社群活动完成奖励明细表(TabHaobanGroupChatActivityRewardDetailLog)表服务实现类
@@ -17,4 +27,18 @@ public class GroupChatActivityRewardDetailLogServiceImpl implements GroupChatAct
     @Resource
     private GroupChatActivityRewardDetailLogMapper groupChatActivityRewardDetailLogMapper;
 
+    private GroupChatActivityRewardDetailLogDTO convertToDTO(TabGroupChatActivityRewardDetailLog tabGroupChatActivityRewardDetailLog){
+        GroupChatActivityRewardDetailLogDTO groupChatActivityRewardDetailLogDTO = new GroupChatActivityRewardDetailLogDTO();
+        BeanUtils.copyProperties(tabGroupChatActivityRewardDetailLog,groupChatActivityRewardDetailLogDTO);
+        return groupChatActivityRewardDetailLogDTO;
+    }
+
+    @Override
+    public List<GroupChatActivityRewardDetailLogDTO> queryList(GroupChatActivityRewardDetailLogQDTO rewardDetailLogQDTO) {
+        List<TabGroupChatActivityRewardDetailLog> rewardDetailLogDTOList = groupChatActivityRewardDetailLogMapper.queryList(rewardDetailLogQDTO);
+        if(CollectionUtils.isEmpty(rewardDetailLogDTOList)){
+            return Lists.newArrayList();
+        }
+        return rewardDetailLogDTOList.stream().map(this::convertToDTO).collect(Collectors.toList());
+    }
 }

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

 package com.gic.haoban.manage.service.service.chat.impl;
 
+import com.gic.api.base.commons.Page;
+import com.gic.commons.util.PageHelperUtils;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityInviteLogDTO;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardDetailLogDTO;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardDetailLogQDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
 import com.gic.haoban.manage.service.dao.mapper.chat.GroupChatActivityRewardLogMapper;
+import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityInviteLog;
+import com.gic.haoban.manage.service.entity.chat.TabGroupChatActivityRewardLog;
+import com.gic.haoban.manage.service.service.chat.GroupChatActivityRewardDetailLogService;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityRewardLogService;
+import com.github.pagehelper.PageHelper;
+import com.google.common.collect.Maps;
+import org.apache.commons.collections.CollectionUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * 内容活动完成奖励表(TabHaobanGroupChatActivityRewardLog)表服务实现类
@@ -14,7 +31,45 @@ import javax.annotation.Resource;
  */
 @Service("groupChatActivityRewardLogService")
 public class GroupChatActivityRewardLogServiceImpl implements GroupChatActivityRewardLogService {
+
     @Resource
     private GroupChatActivityRewardLogMapper groupChatActivityRewardLogMapper;
 
+    @Resource
+    private GroupChatActivityRewardDetailLogService groupChatActivityRewardDetailLogService;
+
+    private GroupChatActivityRewardLogDTO convertToDTO(TabGroupChatActivityRewardLog tabGroupChatActivityRewardLog) {
+        GroupChatActivityRewardLogDTO groupChatActivityRewardLogDTO = new GroupChatActivityRewardLogDTO();
+        BeanUtils.copyProperties(tabGroupChatActivityRewardLog, groupChatActivityRewardLogDTO);
+        return groupChatActivityRewardLogDTO;
+    }
+
+    @Override
+    public Page<GroupChatActivityRewardLogDTO> queryRewardLogDetails(GroupChatActivityRewardLogQDTO rewardLogQDTO) {
+        PageHelper.startPage(rewardLogQDTO);
+        List<TabGroupChatActivityRewardLog> rewardLogList = groupChatActivityRewardLogMapper.queryList(rewardLogQDTO);
+        if (CollectionUtils.isEmpty(rewardLogList)) {
+            return PageHelperUtils.changePageHelperToCurrentPage(rewardLogList, GroupChatActivityRewardLogDTO.class);
+        }
+        List<Long> rewardLogIdList = rewardLogList.stream()
+                .map(TabGroupChatActivityRewardLog::getChatActivityRewardId).collect(Collectors.toList());
+        GroupChatActivityRewardDetailLogQDTO rewardDetailLogQDTO = new GroupChatActivityRewardDetailLogQDTO();
+        rewardDetailLogQDTO.setRewardLogIdList(rewardLogIdList);
+        List<GroupChatActivityRewardDetailLogDTO> rewardDetailLogDTOList = groupChatActivityRewardDetailLogService.queryList(rewardDetailLogQDTO);
+        Map<Long, List<GroupChatActivityRewardDetailLogDTO>> rewardDetailLogDTOMap = Maps.newHashMap();
+        if (CollectionUtils.isNotEmpty(rewardDetailLogDTOList)) {
+            rewardDetailLogDTOMap = rewardDetailLogDTOList.stream()
+                    .collect(Collectors.groupingBy(GroupChatActivityRewardDetailLogDTO::getChatActivityRewardId));
+        }
+        Map<Long, List<GroupChatActivityRewardDetailLogDTO>> finalRewardDetailLogDTOMap = rewardDetailLogDTOMap;
+
+        List<GroupChatActivityRewardLogDTO> rewardLogDTOList = rewardLogList.stream().map(tabGroupChatActivityRewardLog -> {
+            GroupChatActivityRewardLogDTO rewardLogDTO = convertToDTO(tabGroupChatActivityRewardLog);
+            rewardLogDTO.setRewardDetailLogDTOList(finalRewardDetailLogDTOMap.get(rewardLogDTO.getChatActivityRewardId()));
+            return rewardLogDTO;
+
+        }).collect(Collectors.toList());
+
+        return PageHelperUtils.changePageHelperToCurrentPage(rewardLogDTOList, GroupChatActivityRewardLogDTO.class);
+    }
 }

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

+package com.gic.haoban.manage.service.service.out.impl.chat;
+
+import com.gic.api.base.commons.Page;
+import com.gic.api.base.commons.ServiceResponse;
+import com.gic.haoban.manage.api.dto.chat.GroupChatActivityRewardLogDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
+import com.gic.haoban.manage.api.service.chat.GroupChatActivityRewardLogApiService;
+import com.gic.haoban.manage.service.service.chat.GroupChatActivityRewardLogService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * @author shangfeng
+ * @date 2024-10-09 11:02:50
+ */
+@Service("groupChatActivityRewardLogApiService")
+public class GroupChatActivityRewardLogApiServiceImpl implements GroupChatActivityRewardLogApiService {
+
+    @Resource
+    private GroupChatActivityRewardLogService groupChatActivityRewardLogService;
+
+    @Override
+    public ServiceResponse<Page<GroupChatActivityRewardLogDTO>> queryRewardLogDetails(GroupChatActivityRewardLogQDTO rewardLogQDTO) {
+        return ServiceResponse.success(groupChatActivityRewardLogService.queryRewardLogDetails(rewardLogQDTO));
+    }
+}

haoban-manage3-service/src/main/resources/dubbo-haoban-manage-service.xml

@@ -247,5 +247,6 @@
     <!--  社群邀请有礼  -->
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatActivityInviteLogApiService"
                    ref="groupChatActivityInviteLogApiService" timeout="10000"/>
-
+    <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatActivityRewardLogApiService"
+                   ref="groupChatActivityRewardLogApiService" timeout="10000"/>
 </beans>
\ No newline at end of file

haoban-manage3-service/src/main/resources/mapper/chat/GroupChatActivityRewardDetailLogMapper.xml

@@ -21,6 +21,14 @@
         <result property="deleteFlag" column="delete_flag" jdbcType="INTEGER"/>
     </resultMap>
 
+    <sql id="Base_Column_List">
+        chat_activity_reward_detail_id
+        , chat_activity_reward_id, chat_activity_id,
+        activity_reward_id, member_id, reward_type, reward_value,
+            reward_name, reward_remark, reward_business_id,
+        success_flag, enterprise_id, wx_enterprise_id, create_time, update_time, delete_flag
+    </sql>
+
     <!--查询单个-->
     <select id="queryById" resultMap="TabHaobanGroupChatActivityRewardDetailLogMap">
         select chat_activity_reward_detail_id, chat_activity_reward_id, chat_activity_id, activity_reward_id, member_id, reward_type, reward_value, reward_name, reward_remark, reward_business_id, success_flag, enterprise_id, wx_enterprise_id, create_time, update_time, delete_flag
@@ -227,5 +235,18 @@
         from tab_haoban_group_chat_activity_reward_detail_log
         where chat_activity_reward_detail_id = #{chatActivityRewardDetailId}
     </delete>
+
+    <select id="queryList" resultMap="TabHaobanGroupChatActivityRewardDetailLogMap">
+        select
+        <include refid="Base_Column_List"></include>
+        from tab_haoban_group_chat_activity_reward_detail_log
+        where delete_flag = 0
+        <if test="rewardLogIdList != null">
+           and chat_activity_reward_id in
+            <foreach collection="rewardLogIdList" item="rewardLogId" separator="," open="(" close=")">
+                #{rewardLogId}
+            </foreach>
+        </if>
+    </select>
 </mapper>
 

haoban-manage3-service/src/main/resources/mapper/chat/GroupChatActivityRewardLogMapper.xml

@@ -14,6 +14,14 @@
         <result property="deleteFlag" column="delete_flag" jdbcType="INTEGER"/>
     </resultMap>
 
+    <sql id="Base_Column_List">
+        chat_activity_reward_id
+        , chat_activity_id,
+            member_id, reward_invite, invite_level,
+        enterprise_id, wx_enterprise_id,
+            create_time, update_time, delete_flag
+    </sql>
+
     <!--查询单个-->
     <select id="queryById" resultMap="TabHaobanGroupChatActivityRewardLogMap">
         select chat_activity_reward_id, chat_activity_id, member_id, reward_invite, invite_level, enterprise_id, wx_enterprise_id, create_time, update_time, delete_flag
@@ -140,5 +148,22 @@
         from tab_haoban_group_chat_activity_reward_log
         where chat_activity_reward_id = #{chatActivityRewardId}
     </delete>
+
+    <select id="queryList" resultMap="TabHaobanGroupChatActivityRewardLogMap">
+        select
+        <include refid="Base_Column_List"></include>
+        from tab_haoban_group_chat_activity_reward_log
+        where delete_flag = 0
+        <if test="enterpriseId != null and enterpriseId != ''">
+            and enterprise_id = #{enterpriseId}
+        </if>
+        <if test="chatActivityId != null">
+            and chat_activity_id = #{chatActivityId}
+        </if>
+        <if test="memberId != null and memberId != ''">
+            and member_id = #{memberId}
+        </if>
+        order by create_time desc
+    </select>
 </mapper>
 

haoban-manage3-service/src/test/java/GroupChatInviteActivityTest.java

 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.dto.chat.GroupChatActivityRewardLogDTO;
 import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityInviteLogQDTO;
+import com.gic.haoban.manage.api.qdto.chat.GroupChatActivityRewardLogQDTO;
 import com.gic.haoban.manage.api.service.chat.GroupChatActivityInviteLogApiService;
+import com.gic.haoban.manage.api.service.chat.GroupChatActivityRewardLogApiService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -22,6 +25,9 @@ public class GroupChatInviteActivityTest {
     @Autowired
     private GroupChatActivityInviteLogApiService groupChatActivityInviteLogApiService;
 
+    @Autowired
+    private GroupChatActivityRewardLogApiService groupChatActivityRewardLogApiService;
+
     @Test
     public void queryMaxBatchInviteLog(){
         GroupChatActivityInviteLogQDTO inviteLogQDTO = new GroupChatActivityInviteLogQDTO();
@@ -44,4 +50,15 @@ public class GroupChatInviteActivityTest {
         ServiceResponse<Page<GroupChatActivityInviteLogDTO>> listServiceResponse = groupChatActivityInviteLogApiService.queryInviteLogDetails(inviteLogQDTO);
         System.out.println(listServiceResponse.getResult());
     }
+
+    @Test
+    public void queryRewardLogDetails(){
+        GroupChatActivityRewardLogQDTO inviteLogQDTO = new GroupChatActivityRewardLogQDTO();
+        inviteLogQDTO.setEnterpriseId("111");
+        inviteLogQDTO.setChatActivityId(1L);
+        inviteLogQDTO.setMemberId("111");
+        ServiceResponse<Page<GroupChatActivityRewardLogDTO>> listServiceResponse = groupChatActivityRewardLogApiService.queryRewardLogDetails(inviteLogQDTO);
+        System.out.println(listServiceResponse.getResult());
+    }
+
 }