自动周转SKU-仓库准备添加对在途数据的扫描

data-mid/mid-auto-turnover-prepare/src/main/java/com/bailuntec/job/AutoTurnoverPrepareJob.java

@@ -19,6 +19,7 @@ public class AutoTurnoverPrepareJob implements SimpleJob {
             mapper.supplementOrderSku();
             mapper.supplementPurchaseSku();
             mapper.supplementSkumsSku();
+            mapper.supplementTransitSku();
         } catch (Exception e) {
             e.printStackTrace();
             throw new RuntimeException("MYBATIS操作DB失败",e);

data-mid/mid-auto-turnover-prepare/src/main/java/com/bailuntec/mapper/DcBaseStockMapper.java

@@ -129,4 +129,6 @@ public interface DcBaseStockMapper {
     void supplementPurchaseSku();
 
     void supplementSkumsSku();
+
+    void supplementTransitSku();
 }
\ No newline at end of file

data-mid/mid-auto-turnover-prepare/src/main/java/com/bailuntec/mapper/DcBaseStockMapper.xml

@@ -1160,7 +1160,7 @@
     insert into dc_base_stock (bailun_sku,warehouse_code)
     SELECT
         tbo.bailun_sku,
-        tbo.warehouse_code FROM ( SELECT bailun_sku, warehouse_code FROM dc_base_oms_sku WHERE paid_time >=  DATE_SUB(curdate(),INTERVAL 1 DAY) and warehouse_code != '' and bailun_sku != '' GROUP BY bailun_sku, warehouse_code ) tbo
+        tbo.warehouse_code FROM ( SELECT bailun_sku, warehouse_code FROM dc_base_oms_sku WHERE paid_time >=  DATE_SUB(curdate(),INTERVAL 10 DAY) and warehouse_code != '' and bailun_sku != '' GROUP BY bailun_sku, warehouse_code ) tbo
         LEFT JOIN (SELECT bailun_sku,warehouse_code FROM dc_base_stock) tbs  ON tbs.bailun_sku = tbo.bailun_sku
         AND tbs.warehouse_code = tbo.warehouse_code
     WHERE
@@ -1171,7 +1171,7 @@
 	SELECT
 	tbo.bailun_sku,
 	tbo.warehouse_code FROM
-	(SELECT bailun_sku,warehouse_code FROM dc_base_purchase WHERE create_time  >=  DATE_SUB(curdate(),INTERVAL 1 DAY) and  warehouse_code != '' and bailun_sku != '' GROUP BY bailun_sku, warehouse_code ) tbo
+	(SELECT bailun_sku,warehouse_code FROM dc_base_purchase WHERE create_time  >=  DATE_SUB(curdate(),INTERVAL 10 DAY) and  warehouse_code != '' and bailun_sku != '' GROUP BY bailun_sku, warehouse_code ) tbo
     LEFT JOIN (SELECT bailun_sku,warehouse_code FROM dc_base_stock) tbs  ON tbs.bailun_sku = tbo.bailun_sku
         AND tbs.warehouse_code = tbo.warehouse_code
     WHERE
@@ -1181,7 +1181,17 @@
     insert into dc_base_stock (bailun_sku,warehouse_code)
     SELECT
         tbo.bailun_sku,
-        tbo.warehouse_code FROM (SELECT bailun_sku,warehouse_code  FROM dc_base_sku WHERE  gmt_modified >=  DATE_SUB(curdate(),INTERVAL 1 DAY) and  warehouse_code != '' and bailun_sku != '' and source in(1,2,3,4,6,7)) tbo
+        tbo.warehouse_code FROM (SELECT bailun_sku,warehouse_code  FROM dc_base_sku WHERE  gmt_modified >=  DATE_SUB(curdate(),INTERVAL 10 DAY) and  warehouse_code != '' and bailun_sku != '' and source in(1,2,3,4,6,7)) tbo
+        LEFT JOIN (SELECT bailun_sku,warehouse_code FROM dc_base_stock) tbs  ON tbs.bailun_sku = tbo.bailun_sku
+        AND tbs.warehouse_code = tbo.warehouse_code
+    WHERE
+	tbs.bailun_sku IS NULL;
+  </insert>
+  <insert id="supplementTransitSku">
+  insert into dc_base_stock (bailun_sku,warehouse_code)
+    SELECT
+        tbo.bailun_sku,
+        tbo.warehouse_code FROM (SELECT bailun_sku,warehouse_code  FROM dc_mid_transit WHERE   warehouse_code != '' and bailun_sku != '' ) tbo
         LEFT JOIN (SELECT bailun_sku,warehouse_code FROM dc_base_stock) tbs  ON tbs.bailun_sku = tbo.bailun_sku
         AND tbs.warehouse_code = tbo.warehouse_code
     WHERE