场地通过审核提交

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

@@ -68,7 +68,7 @@ public class DataImpl {
     DMTAuthorizationRecordsService dmtAuthorizationRecordsService;
 
 
-    private static final String SQL_URL = "jdbc:mysql://39.107.71.112:3308/dev_ln_scene";
+    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";
@@ -128,6 +128,9 @@ public class DataImpl {
                 String contactMobile = row.getString("contact_mobile");
                 //判断场地认领逻辑
                 if (null != contactMobile && !contactMobile.isEmpty()) {
+                    if (contactMobile.equals("15810312145")) {
+                        contactMobile = "15810579150";
+                    }
                     MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                     params.add("mobile", contactMobile);
                     MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
@@ -204,8 +207,10 @@ public class DataImpl {
                     appliesVo = SlimeFieldAppliesVo.getNew().copy(applies);
                 }
                 //MYSQL
+                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.insert(applies);
                 }
                 //OTHER
@@ -240,6 +245,10 @@ public class DataImpl {
                 String merchantId = row.getString("merchant_id");
                 if (mobile == null) {
                     continue;
+                } else {
+                    if (mobile.equals("15810312145")) {
+                        mobile = "15810579150";
+                    }
                 }
                 //获取java用户id
                 MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
@@ -318,6 +327,9 @@ public class DataImpl {
                     String contactMobile = rowSponsor.getString("mobile");
                     //判断场地认领逻辑
                     if (null != contactMobile && !contactMobile.isEmpty()) {
+                        if (contactMobile.equals("15810312145")) {
+                            contactMobile = "15810579150";
+                        }
                         MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                         params.add("mobile", contactMobile);
                         MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
@@ -371,9 +383,8 @@ public class DataImpl {
         }
     }
 
-    //相关权限迁移
+    //相关权限迁移-验票
     public void checkTicket() {
-//        initPermission("check", "585768981301944329909622", "201357233419837447752118", null, "王斐", "3065512271283404835770393", "18518013286");
         try {
             String sql = "select kcup.performance_id,kcu.mobile,kpr.merchant_id\n" +
                     "from kylin_check_user_performances kcup\n" +
@@ -390,6 +401,10 @@ public class DataImpl {
                 String performanceId = row.getString("performance_id");
                 if (mobile == null) {
                     continue;
+                } else {
+                    if (mobile.equals("15810312145")) {
+                        mobile = "15810579150";
+                    }
                 }
                 MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                 params.add("mobile", mobile);
@@ -405,7 +420,6 @@ public class DataImpl {
         }
     }
 
-
     private void judgeSponsor(String sponsorId, String uid, SlimeSponsorAppliesVo appliesVo, SlimeSponsorsVo vo) {
         //MerchantSponsorAppliesVo MONGO
         mongoTemplate.insert(appliesVo, SlimeSponsorAppliesVo.class.getSimpleName());
@@ -555,7 +569,7 @@ public class DataImpl {
         getAndSyncAuthorizationPerformanceVo(performanceId, authorizationRecordsVo.getUid());
     }
 
-    public SlimeAuthorizationPerformanceVo getAndSyncAuthorizationPerformanceVo(String performanceId, String uid) {
+    private SlimeAuthorizationPerformanceVo getAndSyncAuthorizationPerformanceVo(String performanceId, String uid) {
         // 聚合角色及权限
         Query recordsQuery = Query.query(Criteria.where("performanceId").is(performanceId).and("uid").is(uid).and("deletedAt").is(null));
         List<SlimeAuthorizationRecordsVo> authorizationRecordsVos = mongoTemplate.find(recordsQuery, SlimeAuthorizationRecordsVo.class, SlimeAuthorizationRecordsVo.class.getSimpleName());