新增批量设置默认头程调拨方式的接口

AutoTurnOver.DB/db_config.cs

@@ -2000,5 +2000,50 @@ where 1 = 1 ";
                 ids = input_data.ids
             });
         }
+
+        /// <summary>
+        /// 在调拨系统批量设置默认调拨方式
+        /// </summary>
+        /// <param name="input"></param>
+        public static void ApiBatchHeadTransport(api_batch_head_transport_input_dto input)
+        {
+            foreach (var item in input.bailun_skus)
+            {
+                // 查询是否已经有数据
+                var dc_base_head_transport_config_old_data = _connection.QuerySingleOrDefault<dc_base_head_transport_config>(" select * from dc_base_head_transport_config where bailun_sku=@bailun_sku and warehouse_code=@warehouse_code and is_delete=0 limit 1 ", new
+                {
+                    bailun_sku = item,
+                    warehouse_code = input.warehouse_code
+                });
+                if (dc_base_head_transport_config_old_data != null)
+                {
+                    dc_base_head_transport_config_old_data.is_delete = 1;
+                    dc_base_head_transport_config_old_data.delete_date = DateTime.Now;
+                    dc_base_head_transport_config_old_data.delete_user = input.user_name?? "trans-sys (user null)";
+                    _connection.Update(dc_base_head_transport_config_old_data);
+                }
+
+                _connection.Insert(new dc_base_head_transport_config
+                {
+                    create_date = DateTime.Now,
+                    delete_user = "",
+                    delete_date = null,
+                    bailun_sku = item,
+                    warehouse_code = input.warehouse_code,
+                    create_user = input.user_name ?? "trans-sys (user null)",
+                    head_transport = input.head_transport ?? "",
+                    is_delete = 0,
+                    logistics_code = ""
+                });
+            }
+
+            _connection.Execute(" update dc_auto_turnover set head_transport_type=@head_transport_type,head_transport_logistics_code=@head_transport_logistics_code where warehouse_code = @warehouse_code and bailun_sku in @bailun_skus ", new
+            {
+                head_transport_type = input.head_transport ?? "",
+                head_transport_logistics_code = "",
+                bailun_skus = input.bailun_skus,
+                warehouse_code = input.warehouse_code,
+            });
+        }
     }
 }

AutoTurnOver.Models/dc_base_head_transport_config.cs

@@ -29,4 +29,17 @@ namespace AutoTurnOver.Models
 
         public List<string> ids { get; set; }
     }
+
+    public class api_batch_head_transport_input_dto
+    {
+        public string user_name { get; set; }
+        public string warehouse_code { get; set; }
+
+        /// <summary>
+        /// 默认调拨方式
+        /// </summary>
+        public string head_transport { get; set; }
+
+        public List<string> bailun_skus { get; set; }
+    }
 }

AutoTurnOver.Services/ConfigServices.cs

@@ -906,5 +906,9 @@ namespace AutoTurnOver.Services
         {
             DB.db_config.BatchSetHeadTransport(input_data, user);
         }
+        public void ApiBatchHeadTransport(api_batch_head_transport_input_dto input_data)
+        {
+            DB.db_config.ApiBatchHeadTransport(input_data);
+        }
     }
 }

AutoTurnOver/Controllers/ApiController.cs

@@ -164,5 +164,14 @@ namespace AutoTurnOver.Controllers
                 });
             }
         }
+
+
+        [HttpPost("ApiBatchHeadTransport")]
+        public ActionResult<RequestResultDto> ApiBatchHeadTransport([FromBody] api_batch_head_transport_input_dto search)
+        {
+            new ConfigServices().ApiBatchHeadTransport(search);
+            return new RequestResultDto { success = true};
+        }
+
     }
 }
\ No newline at end of file