新数据中心

datacenter-base/base-sync-fee/src/main/java/com/bailuntec/job/SyncFeeApp.java

@@ -15,7 +15,7 @@ import org.springframework.scheduling.annotation.EnableScheduling;
  * @since 2020/8/29 3:29 下午
  */
 @SpringBootApplication
-//@EnableScheduling
+@EnableScheduling
 @ComponentScan("com.bailuntec")
 @EnableFeignClients(basePackages = {"com.bailuntec.api", "com.bailuntec.*.api"})
 public class SyncFeeApp {

datacenter-base/base-sync-fee/src/main/java/com/bailuntec/job/service/SyncFeeService.java

@@ -60,6 +60,7 @@ public class SyncFeeService {
         Integer pageNum = 1;
         Integer pageSize = 100;
         for (; ; ) {
+
             CostResult<List<CostDto>> result = costApi.getCostList(dcJobConfig.getStartTimeStr(),
                     dcJobConfig.getEndTimeStr(),
                     pageNum,
@@ -70,8 +71,15 @@ public class SyncFeeService {
             }
             result.getData().forEach(costDto -> {
                 DcBaseFinanceFee dcBaseFinanceFee = new DcBaseFinanceFee();
-                BeanUtils.copyProperties(costDto, dcBaseFinanceFee, "id");
+                BeanUtils.copyProperties(costDto, dcBaseFinanceFee);
+
                 dcBaseFinanceFee.setCreateTime(LocalDateTime.ofInstant(costDto.getCreateTime().toInstant(), ZoneId.systemDefault()));
+                if (costDto.getPayTime() != null) {
+                    dcBaseFinanceFee.setPayTime(LocalDateTime.ofInstant(costDto.getPayTime().toInstant(), ZoneId.systemDefault()));
+                }
+                if (costDto.getAuditTime() != null) {
+                    dcBaseFinanceFee.setAuditTime(LocalDateTime.ofInstant(costDto.getAuditTime().toInstant(), ZoneId.systemDefault()));
+                }
                 dcBaseFinanceFee.setBjModified(LocalDateTime.now());
                 //更新
                 int update = dcBaseFinanceFeeMapper.update(dcBaseFinanceFee, new LambdaQueryWrapper<DcBaseFinanceFee>()
@@ -83,6 +91,7 @@ public class SyncFeeService {
                 }
                 log.info("同步一条费用单,costNo:{}", costDto.getCostNo());
             });
+
             pageNum++;
         }
 

datacenter-mid/mid-calculate-transit/pom.xml

@@ -3,10 +3,11 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>datacenter-base</artifactId>
+        <artifactId>datacenter-mid</artifactId>
         <groupId>com.bailuntec</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>
+
     <modelVersion>4.0.0</modelVersion>
     <artifactId>mid-calculate-transit</artifactId>
 
@@ -17,6 +18,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven-surefire-plugin.version>2.18.1</maven-surefire-plugin.version>
         <maven.build.timestamp.format>yyyyMMddHHmm</maven.build.timestamp.format>
+        <skipTests>true</skipTests>
     </properties>
 
     <build>

datacenter-mid/mid-calculate-transit/src/test/java/com/bailuntec/job/service/MidCalculateTransitServiceTest.java

+package com.bailuntec.job.service;
+
+import com.bailuntec.job.MidCalculateTransitApp;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.cloud.netflix.hystrix.EnableHystrix;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import javax.annotation.Resource;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author robbendev
+ * @since 2020/12/12 10:59 上午
+ */
+@EnableHystrix
+@ActiveProfiles(value = "test")
+@Slf4j
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = MidCalculateTransitApp.class)
+class MidCalculateTransitServiceTest {
+
+    @Resource
+    MidCalculateTransitService midCalculateTransitService;
+
+    @Test
+    void midCalculateOutStockQuantity() {
+        midCalculateTransitService.midCalculateOutStockQuantity();
+    }
+
+    @Test
+    void midCalculatePurchaseTransitQuantity() {
+        midCalculateTransitService.midCalculatePurchaseTransitQuantity();
+    }
+
+    @Test
+    void midCalculateTransferTransitQuantity() {
+        midCalculateTransitService.midCalculateTransferTransitQuantity();
+    }
+
+    @Test
+    void midCalculateNoShippedQuantity() {
+        midCalculateTransitService.midCalculateNoShippedQuantity();
+    }
+}