提交chime社交相关

liquidnet-bus-api/liquidnet-service-chime-api/src/main/java/com/liquidnet/service/chime/dto/ChimeJoinUserCountDto.java

+package com.liquidnet.service.chime.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: ChimeJoinUserCountDto
+ * @Package com.liquidnet.service.chime.dto
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/9/12 15:49
+ */
+@Data
+public class ChimeJoinUserCountDto{
+    private String performancesId;
+    private Integer count;
+    private List<String> avatarImgList;
+}

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/biz/ChimeUserBiz.java

@@ -4,14 +4,18 @@ import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.liquidnet.commons.lang.util.StringUtil;
+import com.liquidnet.service.chime.dto.ChimeJoinUserCountDto;
 import com.liquidnet.service.chime.dto.PerformanceDto;
+import com.liquidnet.service.chime.utils.DataUtils;
 import com.liquidnet.service.chime.vo.mongo.ChimeUserTagsMappingVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -25,6 +29,8 @@ import java.util.List;
 @Slf4j
 @Component
 public class ChimeUserBiz {
+    @Autowired
+    private DataUtils dataUtils;
     /**
      * Json转换list
      * @param tags
@@ -55,6 +61,14 @@ public class ChimeUserBiz {
      */
     public List<PerformanceDto> buildPerformanceDtoList(List<KylinPerformanceVo> performanceVoList){
         List<PerformanceDto> performanceDtoList = new ArrayList<>();
+        //获取在场用户加入人数和指定头像列表
+        if(StringUtil.isEmpty(performanceVoList)){
+            return null;
+        }
+        List<String> performancesIdList = performanceVoList.stream().map(KylinPerformanceVo::getPerformancesId).collect(Collectors.toList());
+        //获取在场用户人数统计
+        List<ChimeJoinUserCountDto> joinUserCountDtoList =  dataUtils.getJoinUserCountList(performancesIdList);
+
         for(KylinPerformanceVo performanceVo:performanceVoList){
             PerformanceDto dto = PerformanceDto.getNew();
             dto.setPerformancesId(performanceVo.getPerformancesId());
@@ -63,14 +77,23 @@ public class ChimeUserBiz {
             dto.setTimeStart(performanceVo.getTimeStart());
             dto.setTimeEnd(performanceVo.getTimeEnd());
             dto.setCityName(performanceVo.getCityName());
-            dto.setJoinUserCount(123);
-            List<String> imgList = new ArrayList<>();
-            imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
-            imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
-            imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
-            imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
-            imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
-            dto.setAvatarImgList(imgList);
+            if(StringUtil.isNotEmpty(joinUserCountDtoList)){
+                joinUserCountDtoList.stream().forEach(joinUserCountDto -> {
+                    if(joinUserCountDto.getPerformancesId().equalsIgnoreCase(performanceVo.getPerformancesId())){
+                        dto.setJoinUserCount(joinUserCountDto.getCount());
+                        dto.setAvatarImgList(joinUserCountDto.getAvatarImgList());
+                    }
+                });
+            }else{
+                dto.setJoinUserCount(123);
+                List<String> imgList = new ArrayList<>();
+                imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
+                imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
+                imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
+                imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
+                imgList.add("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
+                dto.setAvatarImgList(imgList);
+            }
             performanceDtoList.add(dto);
         }
         return performanceDtoList;

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/utils/DataUtils.java

@@ -4,14 +4,11 @@ import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.BeanUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.chime.constant.ChimeConstant;
+import com.liquidnet.service.chime.dto.ChimeJoinUserCountDto;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
 import com.liquidnet.service.chime.dto.ChimeUserTagDto;
 import com.liquidnet.service.chime.vo.mongo.ChimeUserInfoVo;
 import com.liquidnet.service.chime.vo.mongo.ChimeUserTagsMappingVo;
-import com.liquidnet.service.kylin.constant.KylinRedisConst;
-import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
-import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
-import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
@@ -100,41 +97,7 @@ public class DataUtils {
         return mongoTemplate.find(query, ChimeUserTagDto.class,ChimeUserTagsMappingVo.class.getSimpleName());
     }
 
-
-
-    /**
-     * 根据订单id 获取 订单vo 详情
-     *
-     * @param orderId
-     * @return
-     */
-    public KylinOrderTicketVo getOrderTicketVo(String orderId) {
-        Object obj = redisUtil.get(KylinRedisConst.ORDER + orderId);
-        if (obj!=null) {
-            return (KylinOrderTicketVo) obj;
-        } else {
-            KylinOrderTicketVo ticketData = mongoTemplate.findOne(Query.query(Criteria.where("orderTicketsId").is(orderId)), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
-            List<KylinOrderTicketEntitiesVo> kylinOrderTicketEntitiesVoList = mongoTemplate.find(Query.query(Criteria.where("orderId").is(orderId)), KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
-            ticketData.setEntitiesVoList(kylinOrderTicketEntitiesVoList);
-            redisUtil.set(KylinRedisConst.ORDER + orderId, ticketData);
-            return ticketData;
-        }
-    }
-
-    /**
-     * 根据演出id 获取 演出vo 详情
-     *
-     * @param performanceId
-     * @return
-     */
-    public KylinPerformanceVo getPerformanceVo(String performanceId) {
-        Object obj = redisUtil.get(KylinRedisConst.PERFORMANCES + performanceId);
-        if (obj!=null) {
-            return (KylinPerformanceVo)obj;
-        } else {
-            KylinPerformanceVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
-            redisUtil.set(KylinRedisConst.PERFORMANCES + performanceId, performanceData);
-            return performanceData;
-        }
+    public List<ChimeJoinUserCountDto> getJoinUserCountList(List<String> performanceIdList){
+        return null;
     }
 }

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/test/java/com/liquidnet/service/chime/test/TestDataUtils.java

+package com.liquidnet.service.chime.test;
+
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: TestDataUtils
+ * @Package com.liquidnet.service.chime.test
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/9/12 15:44
+ */
+@Slf4j
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest
+public class TestDataUtils {
+    @Test
+    public void getPerformanceCount(){
+
+    }
+
+    @Test
+    public void getUserImgList(){
+
+    }
+}