增加更新逻辑仓库半成品的销量信息服务

Bailun.DC.LogicWareHouse/Services.cs

@@ -159,5 +159,22 @@ namespace Bailun.DC.LogicWareHouse
             return true;
 
         }
+
+        /// <summary>
+        /// 更新缺货数
+        /// </summary>
+        private void UpdateOutStock()
+        {
+
+
+        }
+
+        /// <summary>
+        /// 更新待发货数
+        /// </summary>
+        private void UpdateNoShipping()
+        {
+
+        }
     }
 }

Bailun.DC.SemiSkuWarehouseSales/Services.cs

@@ -33,6 +33,9 @@ namespace Bailun.DC.SemiSkuWarehouseSales
                 if (now.Minute == 45)  //每小时跑一次
                 {
                     Init();
+
+                    //更新逻辑仓库的半成品销量信息
+                    UpdateLogicWareHouseSemiSale();
                 }
             }
             catch (Exception ex)
@@ -133,5 +136,24 @@ namespace Bailun.DC.SemiSkuWarehouseSales
             Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " 结束任务");
         }
 
+
+        public void UpdateLogicWareHouseSemiSale()
+        {
+            var sql = @"update dc_skuwarehouse_stock_sales t1
+                join dc_semi_stock_sales_shipping t2 on t2.warehouse_name=t1.warehouse_name and t1.bailun_sku=t2.sku
+                set t1.quantity_purchase=t2.on_the_way_count,t1.purchase_amount=t2.on_the_way_amount,t1.oneday_total_sales=t2.sales_1,t1.amount_onedaysale=t2.stock_amount_1,t1.sevenday_total_sales=t2.sales_7,t1.fourteenday_total_sales=t2.sales_14,t1.thirtyday_total_sales=t2.sales_30,t1.nostockcount=t2.out_of_stock,t1.noshippingcount=t2.need_quantity,t1.quantity_tuneout_30days=t2.out_stock_30,t1.quantity_tunein_30days=t2.put_stock_30;";
+
+            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+            {
+                if (cn.State == System.Data.ConnectionState.Closed)
+                {
+                    cn.Open();
+                }
+
+                cn.Execute(sql);
+            }
+
+
+        }
     }
 }