逻辑仓库数据统计服务增加半年以上库龄的数量和金额

Bailun.DC.LogicWareHouse/Program.cs

@@ -7,45 +7,45 @@ namespace Bailun.DC.LogicWareHouse
 {
     class Program
     {
-        //static async Task Main(string[] args)
-        //{
-        //    Console.WriteLine("进入 逻辑仓库");
-        //    var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
-        //    {
-        //        services.AddHostedService<Services>();
-        //    });
+        static async Task Main(string[] args)
+        {
+            Console.WriteLine("进入 逻辑仓库");
+            var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
+            {
+                services.AddHostedService<Services>();
+            });
 
-        //    await builder.RunConsoleAsync();
-        //}
+            await builder.RunConsoleAsync();
+        }
 
-        static void Main(string[] args)
-        {
-            var _service = new Services();
+        //static void Main(string[] args)
+        //{
+        //    var _service = new Services();
 
-            _service.Save();
+        //    _service.Save();
 
-            //半成品库存
-            //_service.SemiStock();
+        //    //半成品库存
+        //    //_service.SemiStock();
 
-            //半成品销量
-            //_service.UpdateSemiSale();
+        //    //半成品销量
+        //    //_service.UpdateSemiSale();
 
-            //更新半成品销量和现金流
-            //_service.UpdateLogicWareHouseSemiSale();
+        //    //更新半成品销量和现金流
+        //    //_service.UpdateLogicWareHouseSemiSale();
 
-            // 更新缺货数和待发货数据
-            //_service.UpdateOutStockAndNoShipping();
+        //    // 更新缺货数和待发货数据
+        //    //_service.UpdateOutStockAndNoShipping();
 
-            //更新30天现金流
-            //_service.UpdateCash30Days();
+        //    //更新30天现金流
+        //    //_service.UpdateCash30Days();
 
-            //更新逻辑仓的可用天数
-            //_service.UpdateAvailableDays();
+        //    //更新逻辑仓的可用天数
+        //    //_service.UpdateAvailableDays();
 
-            //保存每日数据快照
-            //_service.SaleWHDailySnaps();
+        //    //保存每日数据快照
+        //    //_service.SaleWHDailySnaps();
 
 
-        }
+        //}
     }
 }

Bailun.DC.LogicWareHouse/Services.cs

@@ -139,6 +139,10 @@ namespace Bailun.DC.LogicWareHouse
                 //保存每日数据快照
                 SaleWHDailySnaps();
 
+                //更新半年以上库龄的sku数量
+                UpdateStockAge();
+
+
                 return true;
                 
             }
@@ -534,5 +538,35 @@ select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1
             }
         }
 
+        public void UpdateStockAge()
+        {
+            Console.WriteLine("【开始】更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+
+            var sql = $@"update (select bailun_sku,warehouse_code,sum(stock) stock from dc_mid_stock_age where day<'{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by bailun_sku,warehouse_code) t1
+                    join dc_skuwarehouse_stock_sales t2 on t1.bailun_sku=t2.bailun_sku and t1.warehouse_code=t2.warehouse_code and t2.hq_type!='半成品仓'
+                    join dc_base_sku t3 on t1.bailun_sku = t3.bailun_sku
+                    set t2.stock_age_6months=t1.stock,t2.stock_age_6months_amount=t1.stock*t3.unit_price";
+
+
+            try
+            {
+                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+                {
+                    if (cn.State == System.Data.ConnectionState.Closed)
+                    {
+                        cn.Open();
+                    }
+
+                    cn.Execute(sql, null, null, 6 * 60);
+                }
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine("更新库龄超过6个月的库存数据服务失败，异常信息：" + ex.Message);
+                UpdateStockAge();
+            }
+
+            Console.WriteLine("【完成】更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+        }
     }
 }