提交chime社交相关

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

@@ -22,4 +22,6 @@ public interface IChimeUserService {
     JSONObject register(ChimeUserRegisterReqDto reqDto);
 
     ChimeUserInfoDto createChimeUserInfo(ChimeUserRegisterReqDto reqDto);
+
+    boolean updateUserTags(String userId,String tags);
 }

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

@@ -69,4 +69,18 @@ public class ChimeUserController {
         }
         return ResponseDto.success(respDto);
     }
+
+    @ApiOperationSupport(order = 5)
+    @ApiOperation(value = "用户兴趣标签修改同步")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "userId", value = "用户id"),
+            @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "tags", value = "兴趣标签(多个用逗号隔开)")
+    })
+    @PostMapping(value = {"updateUserTags"})
+    public ResponseDto<Boolean> updateUserTags(@RequestParam @Validated String userId
+            , @RequestParam @Validated String tags
+    ) {
+        boolean rs = chimeUserService.updateUserTags(userId,tags);
+        return ResponseDto.success(rs);
+    }
 }

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

@@ -105,5 +105,20 @@ public class ChimeUserServiceImpl implements IChimeUserService {
         return null;
     }
 
-
+    @Override
+    public boolean updateUserTags(String userId,String tags) {
+        //插入userTagMapping
+        List<ChimeUserTagsMappingVo> userTagList = new ArrayList<>();
+        if(StringUtil.isNotEmpty(tags)){
+            List<String> list = Arrays.asList(tags.split(","));
+            for(String tagCode:list){
+                ChimeUserTagsMappingVo tempvo = ChimeUserTagsMappingVo.getNew();
+                tempvo.setUserId(userId);
+                tempvo.setTagCode(tagCode);
+                tempvo.setTagDesc("描述"+tagCode);
+                userTagList.add(tempvo);
+            }
+        }
+        return dataUtils.updateUserTagMapping(userId,userTagList);
+    }
 }

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

@@ -18,6 +18,7 @@ import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Component;
 
+import java.util.Collection;
 import java.util.List;
 
 @Slf4j
@@ -46,6 +47,15 @@ public class DataUtils {
         mongoTemplate.insert(chimeUserTagsMappingVoList,ChimeUserTagsMappingVo.class.getSimpleName());
     }
 
+    public boolean updateUserTagMapping(String userId,List<ChimeUserTagsMappingVo> chimeUserTagsMappingVoList){
+
+        Query query = Query.query(Criteria.where("userId").is(userId));
+        //  根据条件删除（可删除多条）
+        mongoTemplate.remove(query,ChimeUserTagsMappingVo.class.getSimpleName());
+        Collection rsList = mongoTemplate.insert(chimeUserTagsMappingVoList,ChimeUserTagsMappingVo.class.getSimpleName());
+        return rsList.size()>0;
+    }
+
     /**
      * 根据订单id 获取 订单vo 详情
      *