实时缺货计算新增速卖通缺货数据

data-common/src/main/java/com/bailuntec/domain/dto/OutStockQuantity.java

@@ -10,5 +10,6 @@ public class OutStockQuantity {
     private String bailunSku;
     private String warehouseCode;
     private Integer quantityOutStock;
+    private Integer aliexpressQuantity;
     private LocalDateTime gmtOutStockModified;
 }

data-common/src/main/java/com/bailuntec/mapper/DcMidTransitMapper.xml

@@ -690,11 +690,11 @@
   </insert>
 
   <insert id="calculateOutStock">
-    insert into dc_mid_transit(bailun_sku, warehouse_code, quantity_out_stock,gmt_out_stock_modified)
+    insert into dc_mid_transit(bailun_sku, warehouse_code, quantity_out_stock,gmt_out_stock_modified, quantity_out_stock_aliexpress)
     values
     <foreach collection="list" item="item" index="index" separator=",">
       (
-      #{item.bailunSku,jdbcType=VARCHAR}, #{item.warehouseCode,jdbcType=VARCHAR}, #{item.quantityOutStock,jdbcType=INTEGER}, #{localDateTime,jdbcType=TIMESTAMP}
+      #{item.bailunSku,jdbcType=VARCHAR}, #{item.warehouseCode,jdbcType=VARCHAR}, #{item.quantityOutStock,jdbcType=INTEGER}, #{localDateTime,jdbcType=TIMESTAMP}, #{item.aliexpressQuantity, jdbcType=INTEGER}
       )
     </foreach>
     ON DUPLICATE KEY 	UPDATE  quantity_out_stock = values(quantity_out_stock) ,gmt_out_stock_modified =  values(gmt_out_stock_modified)
@@ -722,11 +722,13 @@
     SELECT
       t1.bailun_sku as bailunSku,
       t1.warehouse_code as warehouseCode,
-    t1.bailun_sku_quantity_ordered - t1.bailun_sku_quantity_pushed - t2.usable_stock - t2.occupy_stock + ifnull(t3.safe_stock, 0) as quantityOutStock
+    t1.bailun_sku_quantity_ordered - t1.bailun_sku_quantity_pushed - t2.usable_stock - t2.occupy_stock + ifnull(t3.safe_stock, 0) as quantityOutStock,
+    if((t1.aliexpress_quantity - t2.usable_stock - t2.occupy_stock + ifnull(t3.safe_stock, 0)) &lt; 0, 0, (t1.aliexpress_quantity - t2.usable_stock - t2.occupy_stock + ifnull(t3.safe_stock, 0))) as aliexpressQuantity
       FROM
       (
       SELECT
-      bailun_sku,warehouse_code,SUM(bailun_sku_quantity_ordered) AS bailun_sku_quantity_ordered,SUM(bailun_sku_quantity_pushed) AS bailun_sku_quantity_pushed
+      bailun_sku,warehouse_code,SUM(bailun_sku_quantity_ordered) AS bailun_sku_quantity_ordered,SUM(bailun_sku_quantity_pushed) AS bailun_sku_quantity_pushed,
+      sum(case when platform_type = 'Aliexpress' then bailun_sku_quantity_ordered - bailun_sku_quantity_pushed else 0 end) as aliexpress_quantity
       FROM
       dc_base_oms_sku
       WHERE
@@ -811,7 +813,7 @@
 
 
   <update id="updateOldOutStockToZero">
-    update  dc_mid_transit set quantity_out_stock =0 where gmt_out_stock_modified &lt; #{outStockModified,jdbcType=TIMESTAMP}
+    update  dc_mid_transit set quantity_out_stock =0, quantity_out_stock_aliexpress = 0 where gmt_out_stock_modified &lt; #{outStockModified,jdbcType=TIMESTAMP}
   </update>
   <update id="updateOldTransferToZero">
     update  dc_mid_transit set quantity_transfer =0 where gmt_transfer_modified &lt; #{transferModified,jdbcType=TIMESTAMP}