每10分钟刷一次调拨计划在途

AutoTurnOver.DB/report.cs

@@ -4108,16 +4108,25 @@ 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='fba仓' and t1.create_state in (0,1)
 ").ToList();
 
+            // 查询计划单
+            var temp_p_datas2 = _connection.Query<dc_base_trans_expectarrivaltime_temp>(@"select 
+'' as 'purchase_id',
+t1.bailun_sku as 'bailun_sku',
+t1.warehouse_code as 'warehouse_code',
+t1.count as 'count',
+'' as 'transfer_order_id',
+'1991-01-01' as 'expectarrivaltime'
+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 ('国内仓','fba仓') and t1.deleted=0
+").ToList();
+            if(temp_p_datas2!=null && temp_p_datas2.Count >= 1)
+            {
+                temp_p_datas.AddRange(temp_p_datas2);
+            }
             // 查询已经有调拨的采购单
             foreach (var item in temp_p_datas.GroupBy(s=>s.purchase_id))
             {
-                // 查询是否已经调拨
-                //var exists_trans = _connection.QueryFirstOrDefault<int>("  select count(1) from  dc_base_transfer_info as t_tran where t_tran.purchasecode like @purchasecode ",new { purchasecode  = $"%{item.Key}%"});
-                //if (exists_trans <= 0)
-                //{
-
-                //}
-
                 foreach (var itemSku in item.AsEnumerable())
                 {
                     itemSku.transfer_order_id = "v - " + itemSku.purchase_id;

AutoTurnOver.Purchase.AverageTarget/AverageTargetBackgrounService.cs

@@ -75,13 +75,31 @@ namespace AutoTurnOver.Purchase.AverageTarget
                     {
 
                         dc_base_transfer_freight_dao.SynchroOrderBailunTransferLog(5);
-
                     }
                     catch (Exception ex)
                     {
                         Console.WriteLine("同步掉系统入库日志：" + ex.Message);
                     }
 
+                    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.ResetTransExpectArrivaltime();
+                        Console.WriteLine($"结束 刷新调拨计划在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine("刷新调拨计划在途：" + ex.Message);
+                    }
 
                     Thread.Sleep(10 * 60 * 1000);
                 }
@@ -95,19 +113,7 @@ namespace AutoTurnOver.Purchase.AverageTarget
             try
             {
                 var now = DateTime.Now;
-                // 计算周转前半小时，计算fba调拨在途
-                if (now.Hour == 23 && now.Minute == 29)
-                {
-                    Console.WriteLine($"开始 fba调拨在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    report.ResetTransExpectArrivaltime();
-                    Console.WriteLine($"开始 fba调拨在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                }
-                if (now.Hour == 13 && now.Minute == 30)
-                {
-                    Console.WriteLine($"开始 fba调拨在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    report.ResetTransExpectArrivaltime();
-                    Console.WriteLine($"开始 fba调拨在途，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                }
+
 
                 if (now.Hour == 23 && now.Minute == 01)
                 {

AutoTurnOver.Purchase.AverageTarget/Program.cs

@@ -23,8 +23,7 @@ namespace AutoTurnOver.Purchase.AverageTarget
             Console.WriteLine("采购平均值计算任务启动...");
             try
             {
-
-              
+                //report.ResetTransExpectArrivaltime();
             }
             catch (Exception ex)
             {

AutoTurnOver.Services/SkuAutoTurnServices.cs

@@ -654,7 +654,6 @@ namespace AutoTurnOver.Services
                 }
 
             }
-
             if (bailun_sku_warehouse_codes != null && bailun_sku_warehouse_codes.Count >= 1)
             {
                 // 等待周转跑完
@@ -664,6 +663,7 @@ namespace AutoTurnOver.Services
                 {
                     bailun_sku_warehouse_codes = bailun_sku_warehouse_codes
                 }, commandTimeout: 0);
+
                 // 出周转建议
                 PurchaseAdviseServices.Generate($"调拨单刷新 {DateTime.Now.ToString("HH:mm")}",btime,is_bak: false);
             }