提交 数据迁移

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

@@ -2,9 +2,13 @@ package com.liquidnet.service.platform.controller.kylin;
 
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.platform.service.impl.kylin.DataImpl;
+import com.liquidnet.service.slime.dto.vo.SlimeFieldAppliesVo;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -18,7 +22,8 @@ public class DataController {
 
     @Autowired
     private DataImpl data;
-
+    @Autowired
+    private MongoTemplate mongoTemplate;
 
     @PostMapping("fieldData")
     @ApiOperation("场地数据迁移")

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

@@ -207,10 +207,10 @@ public class DataImpl {
                     appliesVo = SlimeFieldAppliesVo.getNew().copy(applies);
                 }
                 //MYSQL
-                slimeFieldsMapper.delete(Wrappers.lambdaQuery(SlimeFields.class).eq(SlimeFields::getFieldId,fields.getFieldId()));
+                slimeFieldsMapper.delete(Wrappers.lambdaQuery(SlimeFields.class).eq(SlimeFields::getFieldId, fields.getFieldId()));
                 slimeFieldsMapper.insert(fields);
                 if (fields.getClaimStatus() != 0) {
-                    slimeFieldAppliesMapper.delete(Wrappers.lambdaQuery(SlimeFieldApplies.class).eq(SlimeFieldApplies::getFieldId,applies.getFieldId()));
+                    slimeFieldAppliesMapper.delete(Wrappers.lambdaQuery(SlimeFieldApplies.class).eq(SlimeFieldApplies::getFieldId, applies.getFieldId()));
                     slimeFieldAppliesMapper.insert(applies);
                 }
                 //OTHER
@@ -265,18 +265,18 @@ public class DataImpl {
                         Wrappers.lambdaUpdate(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getMerchantId, merchantId));
 
                 HashMap<String, Object> map = CollectionUtil.mapStringObject();
-                map.put("merchantId", merchantId);
+                map.put("merchantId", uid);
                 //修改vo
                 Query voQuery = Query.query(Criteria.where("merchantId").is(merchantId));
                 BasicDBObject objectVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
-                mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
+                mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateMany(
                         voQuery.getQueryObject(),
                         objectVo
                 );
                 //修改partnerVo
                 Query partnerVoQuery = Query.query(Criteria.where("merchantId").is(merchantId));
                 BasicDBObject objectPartnerVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
-                mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
+                mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
                         partnerVoQuery.getQueryObject(),
                         objectPartnerVo
                 );
@@ -367,7 +367,9 @@ public class DataImpl {
                     SlimeSponsorAppliesVo sponsorAppliesVo = SlimeSponsorAppliesVo.getNew().copy(sponsorApplies);
 
                     //MYSQL
+                    slimeSponsorsMapper.delete(Wrappers.lambdaQuery(SlimeSponsors.class).eq(SlimeSponsors::getSponsorId, sponsors.getSponsorId()));
                     slimeSponsorsMapper.insert(sponsors);
+                    slimeSponsorAppliesMapper.delete(Wrappers.lambdaQuery(SlimeSponsorApplies.class).eq(SlimeSponsorApplies::getSponsorId, sponsorApplies.getSponsorId()));
                     slimeSponsorAppliesMapper.insert(sponsorApplies);
                     //OTHER
                     judgeSponsor(sponsorApplies.getSponsorId(), sponsorApplies.getUid(), sponsorAppliesVo, vo);
@@ -422,6 +424,7 @@ public class DataImpl {
 
     private void judgeSponsor(String sponsorId, String uid, SlimeSponsorAppliesVo appliesVo, SlimeSponsorsVo vo) {
         //MerchantSponsorAppliesVo MONGO
+        mongoTemplate.remove(Query.query(Criteria.where("sponsorId").is(appliesVo.getSponsorId())), SlimeSponsorAppliesVo.class, SlimeSponsorAppliesVo.class.getSimpleName());
         mongoTemplate.insert(appliesVo, SlimeSponsorAppliesVo.class.getSimpleName());
         // MerchantSponsorsVo MONGO
         Query query = Query.query(Criteria.where("sponsorId").is(sponsorId));
@@ -440,6 +443,7 @@ public class DataImpl {
     private void judgeFields(String fieldId, String uid, SlimeFieldAppliesVo appliesVo, SlimeFieldsVo vo) {
         if (appliesVo != null) {
             //MerchantFieldAppliesVo MONGO
+            mongoTemplate.remove(Query.query(Criteria.where("fieldId").is(appliesVo.getFieldId())), SlimeFieldAppliesVo.class, SlimeFieldAppliesVo.class.getSimpleName());
             mongoTemplate.insert(appliesVo, SlimeFieldAppliesVo.class.getSimpleName());
             //MerchantFieldAppliesVo REDIS
             Object obj = redisDataSourceUtil.getRedisKylinUtil().get(SlimeRedisConst.INFO_FIELD_APPLIES.concat(uid));