记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 1f1176f8 authored by anjiabin's avatar anjiabin
Browse files
Options

提交chime社交相关

parent 6e57aee1
Hide whitespace changes
Inline Side-by-side
Showing with 52 additions and 53 deletions
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/docu/mongo_db_ddl-prod.sql
View file @ 1f1176f8
...@@ -6,9 +6,10 @@ db.createCollection("ChimeUserInfoVo"); ...@@ -6,9 +6,10 @@ db.createCollection("ChimeUserInfoVo");
#创建索引 #创建索引
db.ChimeUserInfoVo.createIndex({userId:"hashed"}); db.ChimeUserInfoVo.createIndex({userId:"hashed"});
db.ChimeUserInfoVo.createIndex({sex:"hashed"}); db.ChimeUserInfoVo.createIndex({sex:"hashed"});
db.ChimeUserInfoVo.createIndex( {"userTagsVoList.tagCode": 1});
db.ChimeUserInfoVo.createIndex({joinPerformanceId:"hashed"}); db.ChimeUserInfoVo.createIndex({joinPerformanceId:"hashed"});
#创建分片 #创建分片
sh.enableSharding("dev_ln_scene"); sh.enableSharding("prod_ln_scene");
sh.shardCollection("dev_ln_scene.ChimeUserInfoVo",{"userId":"hashed"}); sh.shardCollection("prod_ln_scene.ChimeUserInfoVo",{"userId":"hashed"});
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/test/java/com/liquidnet/service/chime/test/TestDataUtils.java
View file @ 1f1176f8
...@@ -80,25 +80,24 @@ public class TestDataUtils { ...@@ -80,25 +80,24 @@ public class TestDataUtils {
int num = i+1; int num = i+1;
Future future = executorService.submit(new Callable(){ Future future = executorService.submit(new Callable(){
public Object call() throws Exception { public Object call() throws Exception {
ChimeUserInfoDto chimeUserInfoDto = ChimeUserInfoDto.getNew(); ChimeUserInfoDto chimeUserInfoVo = ChimeUserInfoDto.getNew();
chimeUserInfoDto.setUserId("TEST"+ IDGenerator.nextTimeId()); chimeUserInfoVo.setUserId("TEST"+ IDGenerator.nextTimeId());
chimeUserInfoDto.setPassWord("123456"); chimeUserInfoVo.setPassWord("123456");
chimeUserInfoDto.setSex("男"); chimeUserInfoVo.setSex("男");
chimeUserInfoDto.setUserName("TestName"+num); // chimeUserInfoVo.setUserName("TestName"+num);
chimeUserInfoDto.setUserMobile("1381111"+num); // chimeUserInfoVo.setUserMobile("1381111"+num);
chimeUserInfoDto.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png"); chimeUserInfoVo.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
chimeUserInfoDto.setUserCover("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png"); chimeUserInfoVo.setUserCover("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
chimeUserInfoDto.setBirthday("2021-09-01"); chimeUserInfoVo.setBirthday("2021-09-01");
chimeUserInfoDto.setSignature("测试签名"); chimeUserInfoVo.setSignature("测试签名");
chimeUserInfoDto.setArea("山西省 太原市 迎泽区"); chimeUserInfoVo.setArea("山西省 太原市 迎泽区");
chimeUserInfoDto.setJoinPerformanceId("-1"); chimeUserInfoVo.setJoinPerformanceId("-1");
// easemobUtil.createUser(chimeUserInfoDto.getUserId(),chimeUserInfoDto.getPassWord()); // easemobUtil.createUser(chimeUserInfoVo.getUserId(),chimeUserInfoVo.getPassWord());
dataUtils.createChimeUser(chimeUserInfoDto); dataUtils.createChimeUser(chimeUserInfoVo);
//插入userTagMapping //插入userTagMapping
List<ChimeUserTagsMappingVo> userTagList = new ArrayList<>(); List<ChimeUserTagsMappingVo> userTagList = new ArrayList<>();
for(int j=0;j<5;j++){ for(int j=0;j<5;j++){
ChimeUserTagsMappingVo chimeUserTagDto = ChimeUserTagsMappingVo.getNew(); ChimeUserTagsMappingVo chimeUserTagDto = ChimeUserTagsMappingVo.getNew();
chimeUserTagDto.setUserId(chimeUserInfoDto.getUserId());
chimeUserTagDto.setTagCode("tags"+(j+1)); chimeUserTagDto.setTagCode("tags"+(j+1));
chimeUserTagDto.setTagDesc("标签"+(j+1)); chimeUserTagDto.setTagDesc("标签"+(j+1));
userTagList.add(chimeUserTagDto); userTagList.add(chimeUserTagDto);
...@@ -109,29 +108,29 @@ public class TestDataUtils { ...@@ -109,29 +108,29 @@ public class TestDataUtils {
}); });
// Future future = executorService.submit(new Runnable() { // Future future = executorService.submit(new Runnable() {
// public void run() { // public void run() {
// ChimeUserInfoDto chimeUserInfoDto = ChimeUserInfoDto.getNew(); // chimeUserInfoVo chimeUserInfoVo = chimeUserInfoVo.getNew();
// chimeUserInfoDto.setUserId("TEST"+ IDGenerator.nextTimeId()); // chimeUserInfoVo.setUserId("TEST"+ IDGenerator.nextTimeId());
// chimeUserInfoDto.setPassWord("123456"); // chimeUserInfoVo.setPassWord("123456");
// chimeUserInfoDto.setSex("男"); // chimeUserInfoVo.setSex("男");
// chimeUserInfoDto.setUserName("TestName"+num); // chimeUserInfoVo.setUserName("TestName"+num);
// chimeUserInfoDto.setUserMobile("1381111"+num); // chimeUserInfoVo.setUserMobile("1381111"+num);
// chimeUserInfoDto.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png"); // chimeUserInfoVo.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
// chimeUserInfoDto.setUserCover("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png"); // chimeUserInfoVo.setUserCover("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
// chimeUserInfoDto.setBirthday("2021-09-01"); // chimeUserInfoVo.setBirthday("2021-09-01");
// chimeUserInfoDto.setSignature("测试签名"); // chimeUserInfoVo.setSignature("测试签名");
// chimeUserInfoDto.setArea("山西省 太原市 迎泽区"); // chimeUserInfoVo.setArea("山西省 太原市 迎泽区");
// chimeUserInfoDto.setJoinPerformanceId("-1"); // chimeUserInfoVo.setJoinPerformanceId("-1");
// List<ChimeUserTagDto> imgList = new ArrayList<>(); // List<ChimeUserTagDto> imgList = new ArrayList<>();
// for(int j=0;j<5;j++){ // for(int j=0;j<5;j++){
// ChimeUserTagDto chimeUserTagDto = ChimeUserTagDto.getNew(); // ChimeUserTagDto chimeUserTagDto = ChimeUserTagDto.getNew();
// chimeUserTagDto.setUserId(chimeUserInfoDto.getUserId()); // chimeUserTagDto.setUserId(chimeUserInfoVo.getUserId());
// chimeUserTagDto.setTagCode("tags"+(j+1)); // chimeUserTagDto.setTagCode("tags"+(j+1));
// chimeUserTagDto.setTagDesc("标签"+(j+1)); // chimeUserTagDto.setTagDesc("标签"+(j+1));
// imgList.add(chimeUserTagDto); // imgList.add(chimeUserTagDto);
// } // }
// chimeUserInfoDto.setUserTags(imgList); // chimeUserInfoVo.setUserTags(imgList);
//// easemobUtil.createUser(chimeUserInfoDto.getUserId(),chimeUserInfoDto.getPassWord()); //// easemobUtil.createUser(chimeUserInfoVo.getUserId(),chimeUserInfoVo.getPassWord());
// dataUtils.createChimeUser(chimeUserInfoDto); // dataUtils.createChimeUser(chimeUserInfoVo);
// } // }
// }); // });
try { try {
...@@ -155,7 +154,7 @@ public class TestDataUtils { ...@@ -155,7 +154,7 @@ public class TestDataUtils {
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
List<ChimeUserInfoVo> voNewList = new ArrayList<>(); List<ChimeUserInfoVo> voNewList = new ArrayList<>();
int totalNum = 200000; int totalNum = 400000;
int pageSize = 1000; int pageSize = 1000;
int pageNum = 1; int pageNum = 1;
int totalPage = totalNum % pageSize == 0 ? totalNum / pageSize : (totalNum / pageSize) + 1;; int totalPage = totalNum % pageSize == 0 ? totalNum / pageSize : (totalNum / pageSize) + 1;;
...@@ -163,27 +162,26 @@ public class TestDataUtils { ...@@ -163,27 +162,26 @@ public class TestDataUtils {
try { try {
int num = i+1; int num = i+1;
ChimeUserInfoVo chimeUserInfoDto = ChimeUserInfoVo.getNew(); ChimeUserInfoVo chimeUserInfoVo = ChimeUserInfoVo.getNew();
chimeUserInfoDto.setUserId("TEST"+ IDGenerator.nextTimeId()); chimeUserInfoVo.setUserId("TEST"+ IDGenerator.nextTimeId());
chimeUserInfoDto.setSex("男"); chimeUserInfoVo.setSex("男");
chimeUserInfoDto.setUserName("TestName"+num); // chimeUserInfoVo.setUserName("TestName"+num);
chimeUserInfoDto.setUserMobile("1381111"+num); // chimeUserInfoVo.setUserMobile("1381111"+num);
chimeUserInfoDto.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png"); // chimeUserInfoVo.setAvatar("https://img.zhengzai.tv/user/2021/07/27/a4cc2a4e6dcd44d1812dc60e079086b4.png");
chimeUserInfoDto.setBirthday("2021-09-01"); // chimeUserInfoVo.setBirthday("2021-09-01");
chimeUserInfoDto.setSignature("测试签名"); // chimeUserInfoVo.setSignature("测试签名");
chimeUserInfoDto.setArea("山西省 太原市 迎泽区"); // chimeUserInfoVo.setArea("山西省 太原市 迎泽区");
chimeUserInfoDto.setJoinPerformanceId("-1"); chimeUserInfoVo.setJoinPerformanceId("-1");
// easemobUtil.createUser(chimeUserInfoDto.getUserId(),chimeUserInfoDto.getPassWord()); // easemobUtil.createUser(chimeUserInfoVo.getUserId(),chimeUserInfoVo.getPassWord());
List<ChimeUserTagsMappingVo> userTagList = new ArrayList<>(); List<ChimeUserTagsMappingVo> userTagList = new ArrayList<>();
for(int j=0;j<5;j++){ for(int j=0;j<5;j++){
ChimeUserTagsMappingVo chimeUserTagDto = ChimeUserTagsMappingVo.getNew(); ChimeUserTagsMappingVo chimeUserTagDto = ChimeUserTagsMappingVo.getNew();
chimeUserTagDto.setUserId(chimeUserInfoDto.getUserId()); chimeUserTagDto.setTagCode("tags"+ RandomUtil.getRandomInt(1,10)+j);
chimeUserTagDto.setTagCode("tags"+ RandomUtil.getRandomInt(2,10)); chimeUserTagDto.setTagDesc("标签"+ RandomUtil.getRandomInt(1,10)+j);
chimeUserTagDto.setTagDesc("标签"+ RandomUtil.getRandomInt(2,10));
userTagList.add(chimeUserTagDto); userTagList.add(chimeUserTagDto);
} }
chimeUserInfoDto.setUserTagsVoList(userTagList); chimeUserInfoVo.setUserTagsVoList(userTagList);
voNewList.add(chimeUserInfoDto); voNewList.add(chimeUserInfoVo);
if(num%pageSize==0){ if(num%pageSize==0){
...@@ -219,11 +217,11 @@ public class TestDataUtils { ...@@ -219,11 +217,11 @@ public class TestDataUtils {
// reqDto.setPerformanceId("-1"); // reqDto.setPerformanceId("-1");
reqDto.setPerformanceId("-1"); reqDto.setPerformanceId("-1");
reqDto.setPageNum(1); reqDto.setPageNum(1);
reqDto.setPageSize(20); reqDto.setPageSize(50);
reqDto.setOrderItem(null); reqDto.setOrderItem(null);
reqDto.setOrderSc(null); reqDto.setOrderSc(null);
reqDto.setSex(""); reqDto.setSex("男");
reqDto.setTags("tags12"); // reqDto.setTags("tags40,tags80");
NewPageResult<ChimeUserInfoDto> pageInfo = chimePerformanceService.getUserListByCon(reqDto); NewPageResult<ChimeUserInfoDto> pageInfo = chimePerformanceService.getUserListByCon(reqDto);
log.info("总共获取总数pagecount:{}",pageInfo.getList().size()); log.info("总共获取总数pagecount:{}",pageInfo.getList().size());
pageInfo.getList().parallelStream().forEach(dto -> { pageInfo.getList().parallelStream().forEach(dto -> {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment