Browse Source

准生产环境的交付数据,同步至客户生产环境 代码规范化

lvxianyun 3 years ago
parent
commit
72d91c5b19

+ 1 - 1
src/main/java/com/persagy/proxy/migration/constant/MigrationConstant.java

@@ -8,7 +8,7 @@ package com.persagy.proxy.migration.constant;
  */
 public class MigrationConstant {
 
-    public final static int batchSubmitDataCount = 500;
+    public final static int BATCH_SUBMIT_DATA_COUNT = 500;
     /** 数据拼接 用于list->map 时key和value拼接 **/
     public final static String SPLITER = "_";
 

+ 6 - 6
src/main/java/com/persagy/proxy/migration/handler/ObjectRelationMigration.java

@@ -267,17 +267,17 @@ public class ObjectRelationMigration extends MigrationAbstractServiceImpl<Object
         if(StrUtil.isBlank(migrationInfo.getTargetUrl())){
             return null;
         }
-        StringBuilder uRL = new StringBuilder(migrationInfo.getTargetUrl());
+        StringBuilder url = new StringBuilder(migrationInfo.getTargetUrl());
         if(type.equals(MigrationType.QUERY.getCode())) {
-            uRL.append(MigrationConstant.DT_RELATION);
+            url.append(MigrationConstant.DT_RELATION);
         }else if(type.equals(MigrationType.INSERT.getCode())){
-            uRL.append(MigrationConstant.DT_RELATION_INSERT);
+            url.append(MigrationConstant.DT_RELATION_INSERT);
         }else if(type.equals(MigrationType.UPDATE.getCode())){
-            uRL.append(MigrationConstant.DT_RELATION_UPDATE);
+            url.append(MigrationConstant.DT_RELATION_UPDATE);
         }else{
-            uRL.append(MigrationConstant.DT_RELATION_DELETE);
+            url.append(MigrationConstant.DT_RELATION_DELETE);
         }
-        return commonUrl(context, uRL.toString(), migrationInfo);
+        return commonUrl(context, url.toString(), migrationInfo);
     }
 
 

+ 4 - 4
src/main/java/com/persagy/proxy/migration/service/Impl/MigrationAbstractServiceImpl.java

@@ -240,19 +240,19 @@ public class MigrationAbstractServiceImpl<T> implements MigrationAbstractService
      */
     private DataMigrationResponse saveOrUpdateCommProcess(List vos,  Class<T> clazz, String url){
         DataMigrationResponse dataMigrationResponse = DataMigrationResponse.success();
-        if(vos.size() <= MigrationConstant.batchSubmitDataCount){
+        if(vos.size() <= MigrationConstant.BATCH_SUBMIT_DATA_COUNT){
             DataMigrationResponse temp = processProjectData(vos,null, clazz, url);
             if(CollUtil.isNotEmpty(temp.getData())){
                 dataMigrationResponse.addData(temp.getData());
             }
         }else{
-            int count= vos.size() / MigrationConstant.batchSubmitDataCount;
+            int count= vos.size() / MigrationConstant.BATCH_SUBMIT_DATA_COUNT;
             for(int k = 0; k< count + 1 ;k++){
-                int end = (k+1)  * MigrationConstant.batchSubmitDataCount - 1;
+                int end = (k+1)  * MigrationConstant.BATCH_SUBMIT_DATA_COUNT - 1;
                 if(end > vos.size()){
                     end = vos.size();
                 }
-                List admDataSub = vos.subList(k * MigrationConstant.batchSubmitDataCount, end);
+                List admDataSub = vos.subList(k * MigrationConstant.BATCH_SUBMIT_DATA_COUNT, end);
                 DataMigrationResponse responseTemp = processProjectData(admDataSub,null, clazz, url);
                 if(CollUtil.isNotEmpty(responseTemp.getData())){
                     dataMigrationResponse.addData(responseTemp.getData());