新增 商品报表库存字段增量刷新

AutoTurnOver.DB/report.cs

@@ -4251,7 +4251,10 @@ truncate table dc_report_goods_temp;
             var rows = 1000;
             while (true)
             {
-                var datas = _connection.Query<SynchroReportGoodsStockDataDto>($" select t2.product_code,t1.warehouse_code from dc_base_stock where as t1 left join dc_base_sku as t2 where t1.bailun_sku = t2.bailun_sku where t1.gmt_modified>=@start_time and t1.gmt_modified<=@end_time limit {(page-1)*rows},{rows} ").ToList();
+                var datas = _connection.Query<SynchroReportGoodsStockDataDto>($" select t2.product_code,t1.warehouse_code from dc_base_stock as t1   left join dc_base_sku as t2 on t1.bailun_sku = t2.bailun_sku where t1.gmt_modified>=@start_time and t1.gmt_modified<=@end_time limit {(page-1)*rows},{rows} ",new {
+                    end_time = new_task_synchro_log.end_time,
+                    start_time = new_task_synchro_log.start_time
+                }).ToList();
                 if (datas == null || datas.Count <= 0)
                 {
                     break;
@@ -4272,7 +4275,7 @@ truncate table dc_report_goods_temp;
                             product_code = item.product_code,
                             warehouse_code = item.warehouse_code
                         }) ?? 0;
-
+                        dc_report_goods_data.stock_update_time = DateTime.Now;
                         _connection.Update<dc_report_goods>(dc_report_goods_data);
                     }
                     count++;

AutoTurnOver.Models/dc_report_goods.cs

@@ -16,6 +16,7 @@ namespace AutoTurnOver.Models
         public  string warehouse_code { get; set; }
         public  string warehouse_name { get; set; }
         public  int stock { get; set; }
+        public  DateTime? stock_update_time { get; set; }
         public  int on_the_way_quantity { get; set; }
         public  decimal unit_price { get; set; }
         public  decimal weight { get; set; }

ResetOutofstock/Program.cs

@@ -32,7 +32,7 @@ namespace ResetOutofstock
                 //dc_aims_transfer_warehouse_dao.TransferWarehouseTask();
                 //daily.ResetFbaExtendReview(DateTime.Now);
                 //report.PurchaseWeekBackUp();
-                //report.GenerateReportGoods();
+                report.SynchroReportGoodsStockData();
 
                 //dc_auto_turnover.ResetHistory();
             }

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -18,7 +18,7 @@ namespace ResetOutofstock
             Task.Factory.StartNew(() =>
             {
                 Console.WriteLine($"init 开始  ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                report.GenerateReportGoods();
+                //report.GenerateReportGoods();
                 Console.WriteLine($"init 结束，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
             });
             //Task.Factory.StartNew(() =>
@@ -255,6 +255,24 @@ namespace ResetOutofstock
                     Thread.Sleep(10 * 60 * 1000);
                 }
             });
+            Task.Factory.StartNew(() =>
+            {
+                while (true)
+                {
+                    try
+                    {
+                        Console.WriteLine($"开始刷新 商品报表库存字段增量刷新，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                        report.SynchroReportGoodsStockData();
+                        Console.WriteLine($"结束刷新 商品报表库存字段增量刷新，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine(ex.Message);
+                    }
+
+                    Thread.Sleep(60 * 1000);
+                }
+            });
 
 
             return Task.CompletedTask;