资产负债

datacenter-mid/mid-calculate-turnover-prepare/src/main/java/com/bailuntec/job/TurnoverPrepareJob.java

@@ -23,7 +23,7 @@ public class TurnoverPrepareJob {
      * 到库存表
      * </p>
      */
-    @Scheduled(cron = "0 0/10 * * * ? ")
+    @Scheduled(cron = "0 0/1 * * * ? ")
     public void syncBaseStock() {
         try {
             log.info("每10分钟同步oms存在sku但环球库存不存在的库存到库存表 开始");
@@ -42,7 +42,7 @@ public class TurnoverPrepareJob {
      * 到库存表
      * </p>
      */
-    @Scheduled(cron = "0 0/10 * * * ? ")
+    @Scheduled(cron = "0 0/1 * * * ? ")
     public void supplyPurchaseSku() {
         try {
             log.info("每10分钟同步采购存在sku但环球库存不存在的库存到库存表 开始");
@@ -61,7 +61,7 @@ public class TurnoverPrepareJob {
      * 到库存表
      * </p>
      */
-    @Scheduled(cron = "0 0/10 * * * ? ")
+    @Scheduled(cron = "0 0/1 * * * ? ")
     public void supplyTransitSku() {
         try {
             log.info("每10分钟同步在途存在sku但环球库存不存在的库存到库存表 开始");

datacenter-mid/mid-calculate-turnover-prepare/src/main/java/com/bailuntec/job/service/TurnoverPrepareService.java

@@ -46,6 +46,9 @@ public class TurnoverPrepareService {
             }
             dcBaseStockService.saveBatch(dcBaseStockList);
             pageNum++;
+
+            dcJobConfig.setPageNum(pageNum);
+            dcJobConfigMapper.updateById(dcJobConfig);
         }
         dcJobConfigMapper.updateById(dcJobConfig.refresh());
     }
@@ -62,6 +65,8 @@ public class TurnoverPrepareService {
             }
             dcBaseStockService.saveBatch(dcBaseStockList);
             pageNum++;
+            dcJobConfig.setPageNum(pageNum);
+            dcJobConfigMapper.updateById(dcJobConfig);
         }
 
         dcJobConfigMapper.updateById(dcJobConfig.refresh());
@@ -80,6 +85,8 @@ public class TurnoverPrepareService {
             }
             dcBaseStockService.saveBatch(dcBaseStockList);
             pageNum++;
+            dcJobConfig.setPageNum(pageNum);
+            dcJobConfigMapper.updateById(dcJobConfig);
         }
         dcJobConfigMapper.updateById(dcJobConfig.refresh());
     }

datacenter-mid/mid-daily-snapshot/src/main/java/com/bailuntec/job/service/DailySnapshotService.java

 package com.bailuntec.job.service;
 
+import com.bailuntec.application.IDcDailyStockService;
+import com.bailuntec.common.ListUtil;
+import com.bailuntec.domain.DcDailyStock;
+import com.bailuntec.domain.DcJobConfig;
+import com.bailuntec.infrastructure.mapper.DcDailyStockMapper;
+import com.bailuntec.infrastructure.mapper.DcJobConfigMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+import java.util.List;
+
 /**
  * <p>
  *
@@ -16,6 +25,15 @@ import org.springframework.stereotype.Service;
 @Service
 public class DailySnapshotService {
 
+    @Resource
+    IDcDailyStockService dcDailyStockService;
+    @Resource
+    DcDailyStockMapper dcDailyStockMapper;
+    @Resource
+    DcJobConfigMapper dcJobConfigMapper;
+
+    private static String midDailyBaseStockSnapshot = "mid-daily-base-stock-snapshot";
+
 
     /**
      * 每天0点10分
@@ -23,6 +41,21 @@ public class DailySnapshotService {
      */
     @Scheduled(cron = "0 10 0 * * ? * ")
     public void saveDcBastStockDailySnapshot() {
+
+        DcJobConfig dcJobConfig = dcJobConfigMapper.selectByName(midDailyBaseStockSnapshot);
+        int pageNum = dcJobConfig.getPageNum();
+        int pageSize = dcJobConfig.getPageSize();
+
+        dcDailyStockMapper.clearSnapShot();
+        for (; ; ) {
+            List<DcDailyStock> dcBaseStockList = dcDailyStockMapper.selectSnapShot((pageNum - 1) * pageSize, pageSize);
+            if (ListUtil.isEmpty(dcBaseStockList)) {
+                break;
+            }
+            dcDailyStockService.saveBatch(dcBaseStockList);
+            pageNum++;
+        }
+        dcJobConfigMapper.updateById(dcJobConfig.refresh());
     }
 
     /**

datacenter-mid/mid-daily-snapshot/src/test/java/com/bailuntec/job/service/DailySnapshotServiceTest.java

+package com.bailuntec.job.service;
+
+import com.bailuntec.job.DailySnapshotApp;
+import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit4.SpringRunner;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author robbendev
+ * @since 2020/12/9 7:14 下午
+ */
+@ActiveProfiles("test")
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = DailySnapshotApp.class)
+public class DailySnapshotServiceTest {
+
+    @Test
+    void saveDcBastStockDailySnapshot() {
+    }
+
+    @Test
+    void saveDcBaseOmsSku30SnapShot() {
+    }
+}