逻辑仓库增加调出在途数和30天内调出数

Bailun.DC.LogicWareHouse/Services.cs

@@ -53,7 +53,7 @@ namespace Bailun.DC.LogicWareHouse
 
                     
 
-                    cn.Execute("delete from dc_skuwarehouse_stock_sales", 20 * 60);
+                    cn.Execute("TRUNCATE dc_skuwarehouse_stock_sales", 20 * 60);
 
                     var page = 1;
                     var pagesize = 5000;
@@ -63,23 +63,25 @@ namespace Bailun.DC.LogicWareHouse
                     while (page == 1 || (resultcount > 0))
                     {
                         var strlimit = (((page - 1) * pagesize) + "," + pagesize);
-                        var sql = $@"select t1.bailun_sku,t1.warehouse_code,t4.warehouse_name,t4.hq_type,(t1.usable_stock) usable_stock,(t1.usable_stock*t1.unit_price) amount_stock,(t2.quantity_purchase) quantity_purchase,(t2.quantity_purchase*t1.unit_price) purchase_amount,(t2.quantity_transfer) quantity_transfer,(t2.quantity_transfer*t1.unit_price) amount_transit,(t5.oneday_total_sales) oneday_total_sales,(t5.oneday_total_sales*t1.unit_price) amount_onedaysale,(t5.sevenday_total_sales) sevenday_total_sales,(t5.fourteenday_total_sales) fourteenday_total_sales,(t5.thirtyday_total_sales) thirtyday_total_sales
+                        var sql = $@"select t1.bailun_sku,t1.warehouse_code,t4.warehouse_name,t4.hq_type,(t1.usable_stock) usable_stock,(t1.usable_stock*t1.unit_price) amount_stock,(t2.quantity_purchase) quantity_purchase,(t2.quantity_purchase*t1.unit_price) purchase_amount,(t2.quantity_transfer) quantity_transfer,(t2.quantity_transfer*t1.unit_price) amount_transit,(t5.oneday_total_sales) oneday_total_sales,(t5.oneday_total_sales*t1.unit_price) amount_onedaysale,(t5.sevenday_total_sales) sevenday_total_sales,(t5.fourteenday_total_sales) fourteenday_total_sales,(t5.thirtyday_total_sales) thirtyday_total_sales,t6.quantity_transfer as quantity_tuneout_onway,t6.quantity_transfer_inbound as quantity_tuneout_30days
                                 from (select t01.bailun_sku,t01.warehouse_code,t01.usable_stock,t02.unit_price from dc_base_stock t01 
                                 join dc_base_sku t02 on t01.bailun_sku=t02.bailun_sku and t02.company_id=1 order by t01.id
                                 limit {strlimit}) t1
                                 left join dc_mid_transit t2 on t1.warehouse_code=t2.warehouse_code and t1.bailun_sku=t2.bailun_sku 
                                 left join dc_daily_sales t5 on t5.record_date = '{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' and t1.warehouse_code=t5.warehouse_code and t1.bailun_sku =t5.bailun_sku 
-                                join dc_base_warehouse t4 on t1.warehouse_code=t4.warehouse_code";
+                                join dc_base_warehouse t4 on t1.warehouse_code=t4.warehouse_code
+                                left join dc_daily_transit_from t6 on t1.warehouse_code=t6.warehouse_code and t1.bailun_sku=t6.bailun_sku and t6.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}'
+                                ";
 
 
                         var liststock = cn.Query<Models.Warehouse.dc_skuwarehouse_stock_sales>(sql, null, null, true, 30 * 60);
 
                         resultcount = liststock.AsList().Count;
 
-                        var str = @"insert dc_skuwarehouse_stock_sales (bailun_sku,warehouse_code,warehouse_name,hq_type,usable_stock,amount_stock,quantity_purchase,purchase_amount,quantity_transfer,amount_transit,oneday_total_sales,amount_onedaysale,sevenday_total_sales,fourteenday_total_sales,thirtyday_total_sales) values ";
+                        var str = @"insert dc_skuwarehouse_stock_sales (bailun_sku,warehouse_code,warehouse_name,hq_type,usable_stock,amount_stock,quantity_purchase,purchase_amount,quantity_transfer,amount_transit,oneday_total_sales,amount_onedaysale,sevenday_total_sales,fourteenday_total_sales,thirtyday_total_sales,quantity_tuneout_onway,quantity_tuneout_30days) values ";
                         foreach (var item in liststock)
                         {
-                            str += $@"('{item.bailun_sku}','{item.warehouse_code}','{item.warehouse_name}','{item.hq_type}',{item.usable_stock ?? 0},{item.amount_stock ?? 0},{(item.quantity_purchase ?? 0)},{item.purchase_amount ?? 0},{item.quantity_transfer ?? 0},{item.amount_transit ?? 0},{(item.oneday_total_sales ?? 0)},{item.amount_onedaysale ?? 0},{item.sevenday_total_sales ?? 0},{item.fourteenday_total_sales ?? 0},{item.thirtyday_total_sales ?? 0}),";
+                            str += $@"('{item.bailun_sku}','{item.warehouse_code}','{item.warehouse_name}','{item.hq_type}',{item.usable_stock ?? 0},{item.amount_stock ?? 0},{(item.quantity_purchase ?? 0)},{item.purchase_amount ?? 0},{item.quantity_transfer ?? 0},{item.amount_transit ?? 0},{(item.oneday_total_sales ?? 0)},{item.amount_onedaysale ?? 0},{item.sevenday_total_sales ?? 0},{item.fourteenday_total_sales ?? 0},{item.thirtyday_total_sales ?? 0},{item.quantity_tuneout_onway??0},{item.quantity_tuneout_30days??0}),";
                         }
                         if (resultcount > 0)
                         {

Bailun.DC.Models/Stock/mLogicWarehouse.cs

@@ -80,5 +80,15 @@ namespace Bailun.DC.Models.Stock
         /// 过去30天销量
         /// </summary>
         public int? thirtyday_total_sales { get; set; }
+
+        /// <summary>
+        /// 调出在途数
+        /// </summary>
+        public int? stock_tuneout_onway { get; set; }
+
+        /// <summary>
+        /// 30天库存调出数
+        /// </summary>
+        public int? stock_tuneout_30days { get; set; }
     }
 }

Bailun.DC.Models/Warehouse/dc_skuwarehouse_stock_sales.cs

@@ -38,6 +38,16 @@ namespace Bailun.DC.Models.Warehouse
 
         public int? thirtyday_total_sales { get; set; }
 
+        /// <summary>
+        /// 调出在途数
+        /// </summary>
+        public int? quantity_tuneout_onway { get; set; }
+
+        /// <summary>
+        /// 30天内调出数量
+        /// </summary>
+        public int? quantity_tuneout_30days { get; set; }
+
         public DateTime? createtime { get; set; }
 
     }

Bailun.DC.Services/WareHouseServices.cs

@@ -77,7 +77,7 @@ namespace Bailun.DC.Services
         {
             var sqlparam = new DynamicParameters();
             var sqlwhere = " where 1=1 ";
-            var sql = @"select hq_type,warehouse_code,warehouse_name,sum(usable_stock) usable_stock,sum(amount_stock) amount_stock,sum(quantity_purchase) quantity_purchase,sum(purchase_amount) purchase_amount,sum(quantity_transfer) quantity_transfer,sum(amount_transit) amount_transit,sum(oneday_total_sales) oneday_total_sales,sum(amount_onedaysale) amount_onedaysale,sum(sevenday_total_sales) sevenday_total_sales,sum(fourteenday_total_sales) fourteenday_total_sales,sum(thirtyday_total_sales) thirtyday_total_sales from dc_skuwarehouse_stock_sales  ";
+            var sql = @"select t1.hq_type,t1.warehouse_code,t1.warehouse_name,sum(t1.usable_stock) usable_stock,sum(t1.amount_stock) amount_stock,sum(t1.quantity_purchase) quantity_purchase,sum(t1.purchase_amount) purchase_amount,sum(t1.quantity_transfer) quantity_transfer,sum(t1.amount_transit) amount_transit,sum(t1.oneday_total_sales) oneday_total_sales,sum(t1.amount_onedaysale) amount_onedaysale,sum(t1.sevenday_total_sales) sevenday_total_sales,sum(t1.fourteenday_total_sales) fourteenday_total_sales,sum(t1.thirtyday_total_sales) thirtyday_total_sales from dc_skuwarehouse_stock_sales t1 ";
 
             //var sqlcount = "select t1.warehouse_code from dc_skuwarehouse_stock_sales t1 ";