每天清理一次昨天的周转建议

AutoGeneratePurchaseAdvise/GeneratePurchaseAdviseBackgroundService.cs

@@ -77,7 +77,7 @@ namespace AutoGeneratePurchaseAdvise
                 if (now.Hour == 08 && now.Minute == 55)
                 {
                     Console.WriteLine($"开始 推送采购建议 任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    PurchaseAdviseServices.Generate(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00")));
+                    PurchaseAdviseServices.Generate(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00")),is_clear_data: true);
                     Console.WriteLine($"结束 推送采购建议 任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                 }
 

AutoTurnOver.DB/purchase_advise.cs

@@ -436,7 +436,13 @@ and t1.quantity_init_advise>=0 and ( t3.buyer_name in ('张莹霞1') and t1.ware
 
         }
 
-        public static void ImportDetailed(int mainID, DateTime date)
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="mainID"></param>
+        /// <param name="date"></param>
+        /// <param name="is_clear_data">是否清理历史数据</param>
+        public static void ImportDetailed(int mainID, DateTime date, bool is_clear_data = false)
         {
             // 刷新商品moq汇总数据
             _connection.Execute(@" -- 刷新 刷新商品moq汇总数据
@@ -579,6 +585,17 @@ and ( t5.`status`=0 or t5.`status` is null ) and t7.sum_quantity_init_advise>0
 ", new { main_id = mainID, btime = date }, commandTimeout: 0).ToList();
             Console.WriteLine("开始出建议 完");
 
+            if (is_clear_data)
+            {
+                var initDate = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00"));
+                // 清理历史数据
+                _connection.Execute(@"update dc_auto_purchase_advise_detailed set `status`=-1 where main_id in (
+	select id from dc_auto_purchase_advise where buy_sys_plan_no in ('Generate')
+)
+and `status`=0 and bailun_sku_warehouse_code not in @bailun_sku_warehouse_codes and create_time<@initDate
+", new { initDate = initDate,bailun_sku_warehouse_codes = datas1.Select(s=>$"{s.bailun_sku}{s.warehouse_code}")});
+            }
+
             if (datas1 != null && datas1.Count >= 1)
             {
                 WritePurchaseAdvise(datas1);

AutoTurnOver.Services/PurchaseAdviseServices.cs

@@ -17,7 +17,7 @@ namespace AutoTurnOver.Services
         /// <summary>
         /// 创建采购计划
         /// </summary>
-        public static void Generate(DateTime date,bool is_bak = true)
+        public static void Generate(DateTime date,bool is_bak = true,bool is_clear_data  =false)
         {
             try
             {
@@ -31,7 +31,7 @@ namespace AutoTurnOver.Services
                 var mainID = purchase_advise.Add(new dc_auto_purchase_advise { create_time = DateTime.Now, no = purchase_advise.GenerateOrderNo() ,buy_sys_plan_no = "Generate" });
                 if (mainID == null) throw new Exception("创建采购建议失败");
 
-                purchase_advise.ImportDetailed(mainID.Value,date);
+                purchase_advise.ImportDetailed(mainID.Value,date, is_clear_data:true);
 
                 if (is_bak)
                 {

AutoTurnOver.Services/SkuAutoTurnServices.cs

@@ -531,7 +531,7 @@ namespace AutoTurnOver.Services
                     bailun_sku_warehouse_codes = bailun_sku_warehouse_codes
                 }, commandTimeout: 0);
                 // 出周转建议
-                PurchaseAdviseServices.Generate(btime,false);
+                PurchaseAdviseServices.Generate(btime,is_bak: false);
             }
            
 
@@ -613,7 +613,7 @@ namespace AutoTurnOver.Services
                     bailun_sku_warehouse_codes = bailun_sku_warehouse_codes
                 }, commandTimeout: 0);
                 // 出周转建议
-                PurchaseAdviseServices.Generate(btime, false);
+                PurchaseAdviseServices.Generate(btime,is_bak: false);
             }