提交chime社交相关

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

-package com.liquidnet.service.chime.dto;
-
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
-
-import java.io.Serializable;
-
-@Data
-@ApiModel(value = "ChimeTagVo", description = "标签库")
-public class ChimeTagVo implements Serializable, Cloneable {
-    private static final long serialVersionUID = 5852327873275898342L;
-
-    @ApiModelProperty(position = 0, value = "用户ID[64]")
-    private String userId;
-    @ApiModelProperty(position = 11, value = "标签Key")
-    private String tagCode;
-    @ApiModelProperty(position = 12, value = "标签名称")
-    private String tagDesc;
-
-    private static final ChimeTagVo obj = new ChimeTagVo();
-
-    public static ChimeTagVo getNew() {
-        try {
-            return (ChimeTagVo) obj.clone();
-        } catch (CloneNotSupportedException e) {
-            e.printStackTrace();
-        }
-        return new ChimeTagVo();
-    }
-}

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

@@ -34,7 +34,7 @@ public class ChimeUserInfoDto {
     @ApiModelProperty(position = 5, value = "在场ID")
     private String joinPerformanceId;
     @ApiModelProperty(position = 5, value = "用户标签")
-    private List<ChimeTagVo> userTags;
+    private List<ChimeUserTagDto> userTags;
 
     private static final ChimeUserInfoDto obj = new ChimeUserInfoDto();
     public static ChimeUserInfoDto getNew() {

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

@@ -5,9 +5,11 @@ import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
 import com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto;
+import com.liquidnet.service.chime.dto.ChimeUserTagDto;
 import com.liquidnet.service.chime.service.IChimePerformanceService;
 import com.liquidnet.service.chime.utils.ObjectUtil;
 import com.liquidnet.service.chime.vo.mongo.ChimeUserInfoVo;
+import com.liquidnet.service.chime.vo.mongo.ChimeUserTagsMappingVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.PageRequest;
@@ -16,6 +18,7 @@ import org.springframework.data.domain.Sort;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.aggregation.*;
 import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -90,7 +93,10 @@ public class ChimePerformanceServiceImpl implements IChimePerformanceService{
                 ChimeUserInfoDto voData = ChimeUserInfoDto.getNew();
                 BeanUtil.copy(item,voData);
                 voData.setPassWord("123456");
-                voData.setUserTags(null);
+                //获取标签
+                Query query= Query.query(Criteria.where("userId").is(item.getUserId())).with(Sort.by(Sort.Order.asc("tagCode")));
+                List<ChimeUserTagDto> tagVoList = mongoTemplate.find(query, ChimeUserTagDto.class,ChimeUserTagsMappingVo.class.getSimpleName());
+                voData.setUserTags(tagVoList);
                 dtoList.add(voData);
             }
             pagedResult.setList(dtoList).setTotal(count, pageSize);