新增全链路在途的更新服务

AutoTurnOver.DB/dc_base_full_link_wait_order_dao.cs

@@ -174,7 +174,7 @@ from dc_base_transfer_plan as t1
 left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code
 where  t1.`status`=1 and t2.hq_type not IN ('国内仓') and t1.deleted=0
  ";
-            var temp_datas = _connection.Query<dc_base_full_link_wait_order_temp>(sql).ToList().Where(s => s.transfer_quantity_not_inbound > 0).ToList();
+            var temp_datas = _connection.Query<dc_base_full_link_wait_order_temp>(sql).ToList().Where(s => s.transfer_plan_quantity > 0).ToList();
 
             // 剔除临时数据跟暂存数据
             temp_datas = temp_datas.Where(s=> !tempOrderDatas.Any(v=>v.bailun_sku_warehouse_code==s.bailun_sku_warehouse_code 
@@ -237,7 +237,7 @@ from dc_base_trans_temp_schedule as t1
 left join dc_base_warehouse as t2 on t1.target_ware_no = t2.warehouse_code
 where  t1.is_delete=0 and t1.is_temp_data=1 and t1.is_exception=0 and t2.hq_type in ('fba仓') and t1.create_state in (0,1)
  ";
-            var temp_datas = _connection.Query<dc_base_full_link_wait_order_temp>(sql).ToList().Where(s => s.transfer_quantity_not_inbound > 0).ToList();
+            var temp_datas = _connection.Query<dc_base_full_link_wait_order_temp>(sql).ToList().Where(s => s.transfer_temp_purchase_quantity > 0 || s.transfer_temp_schedule_quantity > 0).ToList();
 
             foreach (var item in temp_datas)
             {

AutoTurnOver.Models/dc_base_full_link_wait_order.cs

@@ -158,6 +158,9 @@ namespace AutoTurnOver.Models
         public string transfer_plan_no { get; set; }
         public string transfer_temp_schedule_no { get; set; }
         public string transfer_temp_purchase_no { get; set; }
+        public int? transfer_temp_schedule_quantity { get; set; }
+        public int? transfer_temp_purchase_quantity { get; set; }
+        public int? transfer_plan_quantity { get; set; }
     }
 
 

ResetOutofstock/Program.cs

@@ -33,7 +33,7 @@ namespace ResetOutofstock
                 //dc_base_mother_sku_dao.SynchroCalculationTurnOver();
                 //dc_base_mother_sku_dao.ResetTurnOver("M-test123", "MMDUSFBA");
                 //dc_base_transfer_extend_dao.SynchroLmsTransferOrder();
-                dc_base_full_link_wait_order_dao.ResetDatas();
+                //dc_base_full_link_wait_order_dao.ResetDatas();
             }
             catch (Exception ex)
             {

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -316,6 +316,27 @@ namespace ResetOutofstock
                 }
             });
 
+            Task.Factory.StartNew(() =>
+            {
+                while (true)
+                {
+                    Thread.Sleep(10 * 60 * 1000);
+                    try
+                    {
+                        Console.WriteLine($"开始刷新 全链路在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                        dc_base_full_link_wait_order_dao.ResetDatas();
+                        Console.WriteLine($"结束刷新 全链路在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine("全链路在途:" + ex.Message);
+                        Console.WriteLine("全链路在途:" + ex.StackTrace);
+                    }
+
+                   
+                }
+            });
+