调整自产采购发货在途的服务

Bailun.DC.DailySelfProduceDeliver/Program.cs

@@ -26,5 +26,12 @@ namespace Bailun.DC.DailySelfProducePurchaseDeliver
             await builder.RunConsoleAsync();
         }
 
+
+        //static void Main(string[] args)
+        //{
+        //    var _service = new Services();
+        //    _service.Init(DateTime.Parse("2020-09-25"));
+        //}
+
     }
 }

Bailun.DC.DailySelfProduceDeliver/Services.cs

@@ -28,7 +28,7 @@ namespace Bailun.DC.DailySelfProducePurchaseDeliver
                 if (now.Hour == 23 && now.Minute == 45)  //23:45分启动
                 {
                     Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    Init();
+                    Init(now);
                     Console.WriteLine("任务运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                 }
             }
@@ -42,29 +42,40 @@ namespace Bailun.DC.DailySelfProducePurchaseDeliver
         /// <summary>
         /// 保存昨天的自产采购发货在途明细
         /// </summary>
-        public void Init()
+        public void Init(DateTime day)
         {
-            var sql = $@"insert into dc_daily_purchase_semi_deliveronway (purchase_id,bailun_sku,count,price,createtime,day) 
-	                    select t1.purchase_id,t1.bailun_sku,t1.count-t2.count as count,t5.price,NOW() as createtime,date_format(now(),'%Y-%m-%d') as day from (select t1.purchase_id,t1.bailun_sku,sum(t1.count) as count from dc_base_purchase_delivery t1 join dc_base_purchase t5 on t1.purchase_id=t5.purchase_id and t1.bailun_sku=t5.bailun_sku and t5.buy_status=3 group by t1.purchase_id,t1.bailun_sku) t1
+            try
+            {
+                var sql = $@"insert into dc_daily_purchase_semi_deliveronway (purchase_id,bailun_sku,count,price,createtime,day) 
+	                    select t1.purchase_id,t1.bailun_sku,t1.count-t2.count as count,t5.price,NOW() as createtime,'{day.ToString("yyyy-MM-dd")}' as day from (select t1.purchase_id,t1.bailun_sku,sum(t1.count) as count from dc_base_purchase_delivery t1 join dc_base_purchase t5 on t1.purchase_id=t5.purchase_id and t1.bailun_sku=t5.bailun_sku and t5.buy_status=3 group by t1.purchase_id,t1.bailun_sku) t1
 	                    join dc_base_purchase t5 on t1.purchase_id=t5.purchase_id and t1.bailun_sku=t5.bailun_sku and t5.buy_status=3
 	                    join dc_base_sku t3 on t1.bailun_sku=t3.bailun_sku and t3.buyer_name in ('张莹霞','张莹霞1')
 	                    left join (select t2.purchase_id,t2.bailun_sku,sum(t2.count) as count from dc_base_purchase_inbound t2 join dc_base_purchase t5 on t2.purchase_id=t5.purchase_id and t2.bailun_sku=t5.bailun_sku and t5.buy_status=3 where t2.status=1 group by t2.purchase_id,t2.bailun_sku) t2 on t1.purchase_id=t2.purchase_id and t1.bailun_sku=t2.bailun_sku and t1.count>t2.count
 	                    where t1.count>t2.count";
 
-            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
-            {
-                if (cn.State == System.Data.ConnectionState.Closed)
+                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
                 {
-                    cn.Open();
-                }
+                    if (cn.State == System.Data.ConnectionState.Closed)
+                    {
+                        cn.Open();
+                    }
+
+                    //删除昨天的数据
+                    cn.Execute("delete from dc_daily_purchase_semi_deliveronway where day='" + day.ToString("yyyy-MM-dd") + "'");
 
-                //删除昨天的数据
-                cn.Execute("delete from dc_daily_purchase_semi_deliveronway where day='" + DateTime.Now.ToString("yyyy-MM-dd") + "'");
+                    //保存最新数据
+                    var result = cn.Execute(sql);
 
-                //保存最新数据
-                cn.Execute(sql);
+                    Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " 受影响行数" + result);
 
+                }
             }
+            catch (Exception ex)
+            {
+                Console.WriteLine("出现异常，异常信息："+ex.Message);
+                Init(day);
+            }
+            
             
         }
 

Bailun.DC.LogicWareHouse/Program.cs

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