每日库存和每日在途新增SKU当天的单价

data-common/src/main/java/com/bailuntec/mapper/DcBaseStockMapper.java

@@ -142,4 +142,6 @@ public interface DcBaseStockMapper {
     long countByParam(@Param("jobParameter") String jobParameter);
 
     long countByWarehouseCode(@Param("warehouseCode")String warehouseCode);
+
+    void updateSkuUnitPrice();
 }
\ No newline at end of file

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

@@ -1219,6 +1219,10 @@
 	    dc_base_stock
   </insert>
 
+  <update id="updateSkuUnitPrice">
+        update dc_daily_stock t1, dc_base_sku t2 set t1.unit_price = t2.unit_price WHERE t1.record_time = DATE_SUB( CURDATE( ), INTERVAL 1 DAY ) and t1.bailun_sku=t2.bailun_sku
+  </update>
+
 
   <select id="listNoChinaWarehouse" resultType="com.bailuntec.domain.entity.DcBaseStock">
     SELECT * FROM dc_base_stock tb1 inner join dc_base_warehouse tb2 on tb1.warehouse_code = tb2.warehouse_code and tb2.hq_type in ('FBA仓','海外仓','第三方仓库') order by type_id desc limit #{v1}, #{v2}

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

@@ -147,4 +147,6 @@ public interface DcMidTransitMapper {
     void updateOldUnshippedToZero(@Param("unshippedModified") LocalDateTime unshippedModified);
 
     void calculateUnshipped();
+
+    void updateSkuUnitPrice();
 }
\ No newline at end of file

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

@@ -749,6 +749,10 @@
       FROM dc_mid_transit
   </insert>
 
+  <update id="updateSkuUnitPrice">
+         update dc_daily_transit t1, dc_base_sku t2 set t1.unit_price = t2.unit_price WHERE t1.record_time = DATE_SUB( CURDATE( ), INTERVAL 1 DAY ) and t1.bailun_sku=t2.bailun_sku
+  </update>
+
   <insert id="calculateOutStock">
     insert into dc_mid_transit(bailun_sku, warehouse_code, quantity_out_stock,gmt_out_stock_modified)
     SELECT

data-mid/mid-calculate-transit/src/main/java/com/bailuntec/job/DailyTransitJob.java

@@ -13,6 +13,7 @@ public class DailyTransitJob extends PointJob {
         try {
             DcMidTransitMapper mapper = SessionUtil.getSession().getMapper(DcMidTransitMapper.class);
             mapper.insertMidDailyTransit();
+            mapper.updateSkuUnitPrice();
         } catch (Exception e) {
             e.printStackTrace();
             throw new RuntimeException("MYBATIS操作DB失败",e);

data-mid/mid-daily-stock/src/main/java/com/bailuntec/job/DailyStockJob.java

@@ -13,7 +13,7 @@ public class DailyStockJob implements SimpleJob {
         try {
             DcBaseStockMapper mapper = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
             mapper.insertDailyStock();
-            SessionUtil.getSession().commit();
+            mapper.updateSkuUnitPrice();
         } catch (Exception e) {
             e.printStackTrace();
             throw new RuntimeException("MYBATIS操作DB失败", e);