bug:smileSchoolVo存储mongodb修改

liquidnet-bus-api/liquidnet-service-smile-api/src/main/java/com/liquidnet/service/goblin/dto/vo/SmileSchoolVo.java

@@ -21,6 +21,8 @@ public class SmileSchoolVo implements Serializable {
 
     private Long id;
 
+    private String schoolId;
+
     /**
      * 学校名称
      */
@@ -76,6 +78,7 @@ public class SmileSchoolVo implements Serializable {
         SmileSchoolVo smileSchoolVo = new SmileSchoolVo();
         if (null==smileSchool) return null;
         smileSchoolVo.setId(smileSchool.getId());
+        smileSchoolVo.setSchoolId(smileSchool.getId().toString());
         smileSchoolVo.setName(smileSchool.getName());
         smileSchoolVo.setAddress(smileSchool.getAddress());
         smileSchoolVo.setProvinceKey(smileSchool.getProvinceId());

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/test/java/com.liquidnet.client.admin/TestLocal.java

 package com.liquidnet.client.admin;
 
-import com.liquidnet.client.admin.common.utils.security.Md5Utils;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.commons.lang.constant.LnsEnum;
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.commons.lang.util.MD5;
+import com.liquidnet.service.goblin.dto.vo.SmileSchoolVo;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
+import com.liquidnet.service.smile.entity.SmileSchool;
+import com.liquidnet.service.smile.mapper.SmileSchoolMapper;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.result.UpdateResult;
 import org.junit.Test;
@@ -23,6 +27,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.time.LocalDateTime;
 import java.util.Arrays;
+import java.util.List;
 
 /**
  * Test
@@ -69,4 +74,18 @@ public class TestLocal {
         boolean contains = Arrays.asList(LnsEnum.ENV.dev.name(), LnsEnum.ENV.test.name()).contains(environment.getProperty(CurrentUtil.CK_ENV_ACTIVE));
         System.out.println(contains);
     }
+
+    @Autowired
+    private SmileSchoolMapper smileSchoolMapper;
+
+    @Test
+    public void testSaveSmileSchoolMongodb(){
+        LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class);
+        queryWrapper.eq(SmileSchool::getDelTag,0);
+        List<SmileSchool> smileSchools = smileSchoolMapper.selectList(queryWrapper);
+        smileSchools.forEach(smileSchool->{
+            SmileSchoolVo smileSchoolVo = new SmileSchoolVo().copy(smileSchool);
+            mongoTemplate.insert(smileSchoolVo, SmileSchoolVo.class.getSimpleName());
+        });
+    };
 }

liquidnet-bus-service/liquidnet-service-smile/liquidnet-service-smile-impl/docu/mongo_db_ddl.sql

@@ -2,10 +2,13 @@ use test_ln_scene;
 // ================================================== 创建集合
 db.createCollection("SmileSellDataDetailVO");
 db.createCollection("SmileSellDataVO");
+db.createCollection("SmileSchoolVo");
 // ================================================== 创建索引
 db.SmileSellDataDetailVO.createIndex({dataId:"hashed"});
 db.SmileSellDataVO.createIndex({sellDataId:"hashed"});
+db.SmileSchoolVo.createIndex({schoolId:"hashed"})
  ================================================== 创建分片
 sh.enableSharding("test_ln_scene");
 sh.shardCollection("test_ln_scene.SmileSellDataDetailVO",{"dataId":"hashed"});
-sh.shardCollection("test_ln_scene.SmileSellDataVO",{"sellDataId":"hashed"});
+sh.shardCollection("test_ln_scene.SmileSellDataVO",{"sellDataId":"hashed"});
\ No newline at end of file
+sh.shardCollection("test_ln_scene.SmileSchoolVo",{"schoolId":"hashed"});
\ No newline at end of file