数据迁移 地址 正式

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -68,11 +68,14 @@ public class DataImpl {
     DMTAuthorizationRecordsService dmtAuthorizationRecordsService;
 
 
-    private static final String SQL_URL = "jdbc:mysql://zhengzairead.rwlb.rds.aliyuncs.com:3306/prod_ln_scene";
-    private static final String SQL_USER = "readonly";
-    private static final String SQL_PWD = "ZWDsf8Fy";
-    private static final String PHP_DB = "mall";
-
+    private static final String SQL_URL = "jdbc:mysql://39.107.71.112:3308/test_ln_scene";
+    private static final String SQL_USER = "testmall";
+    private static final String SQL_PWD = "zhengzai!mYT";
+    private static final String PHP_DB = "testmall";
+//    private static final String SQL_URL = "jdbc:mysql://zhengzairead.rwlb.rds.aliyuncs.com:3306/prod_ln_scene";
+//    private static final String SQL_USER = "readonly";
+//    private static final String SQL_PWD = "ZWDsf8Fy";
+//    private static final String PHP_DB = "mall";
     //迁移场地和场地认领关系
     public void fieldData() {
         try {
@@ -463,6 +466,7 @@ public class DataImpl {
         Query query = Query.query(Criteria.where("fieldId").is(fieldId));
         Document document = (Document) mongoConverter.convertToMongoType(vo);
         Update update = Update.fromDocument(document);
+        mongoTemplate.remove(Query.query(Criteria.where("fieldId").is(fieldId)), SlimeFieldsVo.class, SlimeFieldsVo.class.getSimpleName());
         mongoTemplate.upsert(query, update, SlimeFieldsVo.class, SlimeFieldsVo.class.getSimpleName());
         // MerchantFieldsVo REDIS
         redisDataSourceUtil.getRedisKylinUtil().set(SlimeRedisConst.INFO_FIELD.concat(fieldId), vo);