新增挑拨暂存数据的抓取

AutoTurnOver.DB/dc_base_trans_temp_schedule_dao.cs

@@ -14,7 +14,7 @@ namespace AutoTurnOver.DB
         /// </summary>
         public static void SynchroTransTempScheduleData()
         {
-            var task_name = "SynchroTransTempScheduleData";
+            var task_name = "SynchroTransTempScheduleData_v1";
             var conn = _connection;
             // 查询最后一次成功抓取的记录
             var last_task_synchro_log = conn.QuerySingleOrDefault<task_synchro_log>(" select  * from task_synchro_log where task_name=@task_name and status=1 order by end_time desc limit 1 ", new { task_name = task_name });
@@ -77,7 +77,9 @@ namespace AutoTurnOver.DB
                             status = 0,
                             target_ware_name = item.targetWareName,
                             target_ware_no = item.targetWareNo,
-                            time_stamp = DateTime.Now
+                            time_stamp = DateTime.Now,
+                            create_state = item.createState,
+                            temp_delivery_count = item.tempDeliveryCount
                         };
 
                         data_skus.Add(db_data);
@@ -101,9 +103,9 @@ namespace AutoTurnOver.DB
             {
                 // 计算相关sku的总在途
                 var temp_datas = _connection.Query<temp_sum_dto>(@"select sku_ware_no,sku as 'bailun_sku',target_ware_no as 'warehouse_code',sum(product_num) as 'count' from dc_base_trans_temp_schedule 
-where is_delete=0 and is_temp_data=1 and is_exception=0
+where is_delete=0 and is_temp_data=1 and is_exception=0 and create_state=@create_state
 and sku_ware_no in @sku_ware_nos
-GROUP BY sku_ware_no", new { sku_ware_nos = data_skus.Select(s=>s.sku_ware_no).Distinct().ToList() });
+GROUP BY sku_ware_no", new { sku_ware_nos = data_skus.Select(s=>s.sku_ware_no).Distinct().ToList(), create_state =(int)dc_base_trans_temp_schedule_create_state_enum.未创建 });
 
                 foreach (var item in temp_datas)
                 {
@@ -127,6 +129,35 @@ GROUP BY sku_ware_no", new { sku_ware_nos = data_skus.Select(s=>s.sku_ware_no).D
                         });
                     }
                 }
+
+                // 计算相关sku的总暂存
+                var temp_datas2 = _connection.Query<temp_sum_dto>(@"select sku_ware_no,sku as 'bailun_sku',target_ware_no as 'warehouse_code',sum(temp_delivery_count) as 'count' from dc_base_trans_temp_schedule 
+where is_delete=0 and is_temp_data=1 and is_exception=0 and create_state=@create_state
+and sku_ware_no in @sku_ware_nos
+GROUP BY sku_ware_no", new { sku_ware_nos = data_skus.Select(s => s.sku_ware_no).Distinct().ToList(), create_state = (int)dc_base_trans_temp_schedule_create_state_enum.已暂存 });
+
+                foreach (var item in temp_datas2)
+                {
+                    _connection.Execute("update dc_mid_transit set quantity_transfer_temporary_storage=@quantity_transfer_temporary_storage where bailun_sku=@bailun_sku and  warehouse_code=@warehouse_code ", new
+                    {
+                        bailun_sku = item.bailun_sku,
+                        warehouse_code = item.warehouse_code,
+                        quantity_transfer_temporary_storage = item.count
+                    });
+                }
+
+                var data_1 = data_skus.Where(s => !temp_datas2.Any(v => v.sku_ware_no == s.sku_ware_no)).ToList();
+                if (data_1 != null && data_0.Count >= 1)
+                {
+                    foreach (var item in data_0.Select(s => new { s.sku, s.target_ware_no }).Distinct())
+                    {
+                        _connection.Execute("update dc_mid_transit set quantity_transfer_temporary_storage=0 where bailun_sku=@bailun_sku and  warehouse_code=@warehouse_code ", new
+                        {
+                            bailun_sku = item.sku,
+                            warehouse_code = item.target_ware_no
+                        });
+                    }
+                }
             }
 
             new_task_synchro_log.count = count;

AutoTurnOver.Models/ApiDto/api_temp_schedule_response_dto.cs

@@ -53,6 +53,16 @@ namespace AutoTurnOver.Models.ApiDto
             public DateTime timeStamp { get; set; }
             public string remarks { get; set; }
 
+            /// <summary>
+            /// 创建状态
+            /// </summary>
+            public int createState { get; set; }
+
+            /// <summary>
+            /// 待发货数量
+            /// </summary>
+            public int tempDeliveryCount { get; set; }
+
             public List<sku_dto> allotScheduleProducts { get; set; }
             public class sku_dto
             {

AutoTurnOver.Models/dc_base_trans_temp_schedule.cs

@@ -31,5 +31,15 @@ namespace AutoTurnOver.Models
         public int status { get; set; }
         public DateTime gmt_create_date { get; set; }
         public DateTime gmt_update_date { get; set; }
+        public int create_state { get; set; }
+        public int temp_delivery_count { get; set; }
+    }
+
+    public enum dc_base_trans_temp_schedule_create_state_enum
+    {
+        未创建 = 0,
+        已暂存 = 1,
+        已创建 = 2,
+        已作废 = 3,
     }
 }

AutoTurnOver.Purchase.AverageTarget/Program.cs

@@ -28,7 +28,8 @@ namespace AutoTurnOver.Purchase.AverageTarget
 
                 //report.ResetTransExpectArrivaltime();
 
-                //PurchaseAverageTargetServices.CalculationTransfer("944913201");
+                //PurchaseAverageTargetServices.CalculationTransfer();
+
             }
             catch (Exception ex)
             {