百伦帐号同步

data-base/base-sync-company/src/main/java/com/bailuntec/Application.java

@@ -35,7 +35,9 @@ public class Application {
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
-        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE")));
+        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(
+                new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"),
+                        propertiesUtil.getPropertyAsString("NAME_SPACE")));
         regCenter.init();
         return regCenter;
     }

data-base/base-sync-company/src/main/resources/job.properties

@@ -12,7 +12,7 @@ NAME_SPACE=data-center
 
 JOB_NAME_COMPANY_INFO=base-sync-company-info
 JOB_NAME_COMPANY_STAFF=base-sync-company-staff
-JOB_NAME_COMPANY_ACCOUNT=base-sync-company-account
+JOB_NAME_COMPANY_ACCOUNT=base-sync-company-account-info
 JOB_NAME_PAYPAL_ACCOUNT=base-sync-paypal-account
 
 JOB_CRON_COMPANY_INFO=0 0 2/2 * * ? *

data-base/base-sync-oms-order/src/main/java/com/bailuntec/job/OrderSyncJob.java

@@ -30,7 +30,6 @@ import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
-import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.LinkedHashMap;
 import java.util.List;
@@ -51,11 +50,11 @@ public class OrderSyncJob extends PointJob {
         /*map.put("TimeFrom", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getStartTime().minusMinutes(3)));
         map.put("TimeTo", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getEndTime()));
         map.put("DateType", "purchaseTime");*/
-        map.put("BailunLastUpdateTimeFrom", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getStartTime().minusMinutes(3)));
-        map.put("BailunLastUpdateTimeTo", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getEndTime()));
+//        map.put("BailunLastUpdateTimeFrom", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getStartTime().minusMinutes(3)));
+//        map.put("BailunLastUpdateTimeTo", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getEndTime()));
 
-//        map.put("BailunLastUpdateTimeFrom", "2020-08-24 00:00:00");
-//        map.put("BailunLastUpdateTimeTo", "2020-08-26 11:00:00");
+        map.put("BailunLastUpdateTimeFrom", "2020-07-24 00:00:00");
+        map.put("BailunLastUpdateTimeTo", "2020-07-25 00:00:00");
         do {
             map.put("pageIndex", jobPointLog.getPageIndex().equals(0) ? "1" : jobPointLog.getPageIndex().toString());
             Response response = null;
@@ -576,6 +575,8 @@ public class OrderSyncJob extends PointJob {
                 dcBaseOmsSkuException.setLastUpdateTime(LocalDateTime.now());
                 dcBaseOmsSkuExceptionMapper.insert(dcBaseOmsSkuException);
                 log.error("解析订单异常 message:{}, 订单号:{}", e.getMessage(), omsResult.getOriginOrderId(), e);
+            } finally {
+                SessionUtil.closeSession();
             }
         });
     }

data-base/base-sync-oms-order/src/test/java/com/bailuntec/job/OrderSyncJobTest.java

@@ -47,6 +47,7 @@ public class OrderSyncJobTest {
                 .newAndCreateCriteria()
                 .andJobNameEqualTo(shardingContext.getJobName()).example());
 
+        jobPointLog.setPageIndex(0);
         orderSyncJob.executeJob(shardingContext, jobPointLog);
         sqlSession.close();
     }