From e3aaaa22a7cee2b7c7a33e98f843abc0cd15fb1b Mon Sep 17 00:00:00 2001
From: 刘磊 <1161824510@qq.com>
Date: 星期二, 05 八月 2025 13:36:12 +0800
Subject: [PATCH] 同步

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs |  279 +++++++++++++++++++++++++++----------------------------
 1 files changed, 139 insertions(+), 140 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
index b568d0c..d57a2d1 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
@@ -5,10 +5,12 @@
 using System.Diagnostics;
 using System.Text.RegularExpressions;
 using System.Threading.Tasks;
+using WIDESEA_Comm.WCSInterface.Requst;
 using WIDESEA_Core.Const;
 using WIDESEA_DTO.WMS;
 using WIDESEA_IServices;
 using WIDESEA_IStoragIntegrationServices;
+using WIDESEA_StoragIntegrationServices;
 using WIDESEAWCS_BasicInfoRepository;
 using WIDESEAWCS_Model.Models;
 using WIDESEAWCS_QuartzJob.Models;
@@ -28,19 +30,21 @@
     private readonly IDt_StationManagerRepository _stationManagerRepository;
     private readonly ISys_ConfigService _configService;
     private readonly IDt_PalletStockInfoRepository _palletStockInfoRepository;
+    private readonly IDt_PalletStockInfoDetailRepository _palletStockInfoDetailRepository;
+    private readonly IDt_PalletStockInfo_htyRepository _palletStockInfo_HtyRepository;
+    private readonly IBoxingInfoRepository _boxingInfoRepository;
+
+    public static string AGV_Interface = "http://192.168.1.195:10200/";
 
     public Dt_TaskService(IDt_TaskRepository BaseDal,
                                 IUnitOfWorkManage unitOfWorkManage,
-                                IDt_OutOrderRepository outOrderRepository,
-                                IStockInfoRepository stockInfoRepository,
                                 IDt_Task_HtyRepository task_HtyRepository,
                                 IMapper mapper,
                                 ILocationInfoRepository locationRepository,
                                 ITaskExecuteDetailRepository taskExecuteDetailRepository,
                                 ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
-                                IStockInfoDetailRepository stockInfoDetailRepository,
                                 IDt_StationManagerRepository stationManagerRepository,
-                                ISys_ConfigService configService, IDt_PalletStockInfoRepository palletStockInfoRepository) : base(BaseDal)
+                                ISys_ConfigService configService, IDt_PalletStockInfoRepository palletStockInfoRepository, IDt_PalletStockInfo_htyRepository palletStockInfo_HtyRepository, IBoxingInfoRepository boxingInfoRepository, IDt_PalletStockInfoDetailRepository palletStockInfoDetailRepository) : base(BaseDal)
 
     {
         _unitOfWorkManage = unitOfWorkManage;
@@ -52,12 +56,14 @@
         _stationManagerRepository = stationManagerRepository;
         _configService = configService;
         _palletStockInfoRepository = palletStockInfoRepository;
+        _palletStockInfo_HtyRepository = palletStockInfo_HtyRepository;
+        _boxingInfoRepository = boxingInfoRepository;
+        _palletStockInfoDetailRepository = palletStockInfoDetailRepository;
     }
 
     #region 澶栭儴鎺ュ彛鏂规硶
 
     #region 鍏ュ簱浠诲姟瀹屾垚
-
     /// <summary>
     /// 瀹屾垚鍏ュ簱浠诲姟
     /// </summary>
@@ -70,8 +76,7 @@
         try
         {
 
-            // 鑾峰彇MES淇℃伅鍜岀洰鏍囦綅缃俊鎭�
-            //var mes_Wheels = await _InWheels_MesRepository.QueryFirstNavAsync(x => x.Wheels_Num == task.PalletCode);
+            // 鑾峰彇搴撲綅淇℃伅
             var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
 
             int lastStatus = locationInf.LocationStatus;
@@ -81,14 +86,24 @@
             // 鍒涘缓鍘嗗彶浠诲姟瀹炰緥妯″瀷
             var taskHty = CreateHistoricalTask(task);
 
+            //鑾峰彇缁勭洏淇℃伅
+            var boxinginfo = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
+
             // 鏍规嵁鍒涘缓搴撳瓨瀹炰緥妯″瀷
+            var boxDetail = boxinginfo.BoxingInfoDetails.Adapt<List<Dt_PalletStockInfoDetail>>();
             Dt_PalletStockInfo palletStockInfo = new Dt_PalletStockInfo
             {
-
+                CreateDate = DateTime.Now,
+                Creater = task.Creater,
+                LocationCode = task.TargetAddress,
+                StockStatus = 2,
+                PalletCode = task.PalletCode,
+                AreaCode = task.Roadway,
+                StockInfoDetails = boxDetail
             };
 
             // 鎵ц鏁版嵁搴撲簨鍔�
-            bool isResult = await ExecuteTransaction(palletStockInfo, taskHty, locationInf, task.TaskId);
+            bool isResult = await ExecuteTransaction(palletStockInfo, taskHty, locationInf, task.TaskId, boxinginfo);
             if (isResult)
             {
                 _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(locationInf, lastStatus, (int)StatusChangeTypeEnum.AutomaticStorage, task.TaskNum);
@@ -111,28 +126,43 @@
     #endregion 鍏ュ簱浠诲姟瀹屾垚
 
     #region 鍑哄簱浠诲姟瀹屾垚
-    public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task, Dt_PalletStockInfo stock)
+    public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task)
     {
         WebResponseContent content = new WebResponseContent();
         try
         {
             // 鏇存柊搴撲綅鐘舵�佷笌浠诲姟鐘舵��
-            //(var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
-            //var taskHty = task.Adapt<Dt_Task_Hty>();
-            //taskHty.FinishTime = DateTime.Now;
-            //taskHty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+            var stock = _palletStockInfoRepository.QueryFirst(x => x.PalletCode == task.PalletCode);
 
-            //Dt_WheelsStock_hty stockInfo_Hty = stock.Adapt<Dt_WheelsStock_hty>();
-            //stockInfo_Hty.FinishWheelDate = DateTime.Now;
-            //stockInfo_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+            (var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
+            var taskHty = task.Adapt<Dt_Task_Hty>();
+            taskHty.FinishTime = DateTime.Now;
+            taskHty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
 
-            //// 浜嬪姟澶勭悊
-            //await _unitOfWorkManage.UseTranAsync(async () =>
-            //{
-            //    var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc);                      //鏇存柊搴撲綅
-            //    //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId);                         //鍒犻櫎浠诲姟
-            //    var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;                        //鍔犲叆鍘嗗彶浠诲姟
-            //});
+            Dt_PalletStockInfo_hty stockInfo_Hty = stock.Adapt<Dt_PalletStockInfo_hty>();
+            stockInfo_Hty.FinishTime = DateTime.Now;
+            stockInfo_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+
+            var boxinfo = _boxingInfoRepository.QueryFirst(x => x.PalletCode == task.PalletCode);
+
+            // 浜嬪姟澶勭悊
+            await _unitOfWorkManage.UseTranAsync(async () =>
+            {
+                var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc);                      //鏇存柊搴撲綅
+                var isPalletHty = await _palletStockInfo_HtyRepository.AddDataAsync(stockInfo_Hty);         //娣诲姞鍘嗗彶搴撳瓨璁板綍
+                //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId);                       //鍒犻櫎浠诲姟
+                await BaseDal.UpdateDataAsync(task);                                                        //鍙栨秷鍒犻櫎浠诲姟锛屾敼涓哄畬鎴愮姸鎬侊紱骞禬MS鐣岄潰鐢变汉宸ョ‘璁ゅ畬鎴�
+                var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;                        //鍔犲叆鍘嗗彶浠诲姟
+                var isDelete = await _palletStockInfoRepository.DeleteDataAsync(stock);                     //鍒犻櫎搴撳瓨
+                await DeleteStockInfoDetailsAsync(stock.StockInfoDetails);                                  //鍒犻櫎搴撳瓨鏄庣粏
+                //if (boxinfo != null)
+                //{
+                //    var isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxinfo.Id)
+                //                         .Include(x => x.BoxingInfoDetails)
+                //                         .ExecuteCommandAsync();                                           //鍒犻櫎缁勭洏
+                //}
+
+            });
 
             return content.OK("浠诲姟瀹屾垚鎴愬姛", task.Remark);
         }
@@ -143,7 +173,7 @@
         }
     }
 
-    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(Dt_WheelsStock stock, Dt_Task task)
+    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(Dt_PalletStockInfo stock, Dt_Task task)
     {
         var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
         int lastStatus = location.LocationStatus;
@@ -184,22 +214,18 @@
 
 
         // 楠岃瘉搴撳瓨鏄惁瀛樺湪
-        var stock = await _palletStockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
+        //var stock = await _palletStockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
 
         // 鏍规嵁浠诲姟绫诲瀷璋冪敤鐩稿簲鐨勫畬鎴愪换鍔℃柟娉�
         switch (task.TaskType)
         {
             case (int)TaskInboundTypeEnum.Inbound:
-            case (int)TaskInboundTypeEnum.InWheels:
-            case (int)TaskInboundTypeEnum.InBrake:
                 LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍏ュ簱浠诲姟", "");
                 return await CompleteInboundTaskAsync(task);
 
             case (int)TaskOutboundTypeEnum.Outbound:
-            case (int)TaskOutboundTypeEnum.OutBrake:
-            case (int)TaskOutboundTypeEnum.OutWheels:
                 LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
-                return await CompleteStackTaskAsync(task, stock);
+                return await CompleteStackTaskAsync(task);
             default:
                 return content.Error("浠诲姟绫诲瀷涓嶅瓨鍦�");
         }
@@ -208,11 +234,6 @@
     #endregion 浠诲姟瀹屾垚
 
     #region 璇锋眰浠诲姟鍏ュ簱
-
-    #region
-
-    #endregion 璇锋眰浠诲姟鍏ュ簱
-
     /// <summary>
     /// 鏇存柊浠诲姟璐т綅
     /// </summary>
@@ -227,7 +248,7 @@
             if (task == null)
                 return content.Error($"鏆傛湭鎵惧埌銆恵input.PalletCode}銆戠殑浠诲姟");
 
-            return content = await UpdateExistingTask(input, task);
+            return content; //= await UpdateExistingTask(input, task);
         }
         catch (Exception err)
         {
@@ -237,29 +258,6 @@
 
     #endregion 澶栭儴鎺ュ彛鏂规硶
 
-    #region 璇锋眰鍑哄簱锛堝疄鐩橈級
-
-
-    /// <summary>
-    /// 鍒涘缓浠诲姟DTO
-    /// </summary>
-    private WMSTaskDTO CreateTaskDTO(Dt_Task task)
-    {
-        return new WMSTaskDTO
-        {
-            TaskNum = task.TaskNum.Value,
-            Grade = task.Grade.Value,
-            PalletCode = task.PalletCode,
-            RoadWay = task.Roadway,
-            SourceAddress = task.SourceAddress,
-            TargetAddress = task.TargetAddress,
-            TaskState = task.TaskState.Value,
-            Id = 0,
-            TaskType = task.TaskType
-        };
-    }
-
-    #endregion 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
 
     #region 浠诲姟鐘舵�佹洿鏀�
 
@@ -328,9 +326,9 @@
                 return content.Error("鏈煡璇㈠埌瀵瑰簲鐨勫簱瀛樹俊鎭�");
             }
 
-            if (stockInfo.StockStatus != 1) return content.Error("鎸囧畾澶辫触锛氬綋鍓嶇姸鎬佷笉鍏佽鎸囧畾鍑哄簱");
+            if (stockInfo.StockStatus != 2) return content.Error("鎸囧畾澶辫触锛氬綋鍓嶇姸鎬佷笉鍏佽鎸囧畾鍑哄簱");
 
-            stockInfo.StockStatus = 4;
+            stockInfo.StockStatus = 3;
 
             //鏌ヨ搴撲綅鏄惁閿佸畾锛�
             var location = _locationRepository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode);
@@ -344,67 +342,80 @@
             {
                 return content.Error($"銆恵palletCode}銆戝凡瀛樺湪浠诲姟");
             }
-            // var stationInfo = _stationManagerRepository.QueryFirst(x => x.stationChildCode == station);
+
+            var stationInfo = _stationManagerRepository.QueryFirst(x => x.stationChildCode == station);
+
 
             // 鍒涘缓骞舵坊鍔犱换鍔″埌鏁版嵁搴�
+            string agvId = Guid.NewGuid().ToString().Replace("-", "").Take(16);
             task = new Dt_Task
             {
                 Grade = 1,
-                Roadway = "SC1",
-                TargetAddress = station,
+                Roadway = stationInfo.Roadway,
+                TargetAddress = stationInfo.stationLocation,
                 Dispatchertime = DateTime.Now,
                 MaterialNo = "",
-                NextAddress = "2010",
+                NextAddress = stationInfo.stationLocation,
                 OrderNo = null,
                 PalletCode = stockInfo.PalletCode,
                 SourceAddress = stockInfo.LocationCode,
                 CurrentAddress = stockInfo.LocationCode,
                 TaskState = (int)TaskOutStatusEnum.OutNew,
-                TaskType = (int)TaskOutboundTypeEnum.OutWheels,
+                TaskType = (int)TaskOutboundTypeEnum.Outbound,
                 TaskNum = BaseDal.GetTaskNo().Result,
                 Creater = "System",
                 CreateDate = DateTime.Now,
                 TaskId = 0,
-                //task_bak1 = JsonConvert.SerializeObject(checkInfo)
+                AGVtaskId = agvId
             };
 
-            // 鍒涘缓浠诲姟浼犺緭鐢ㄧ殑DTO瀵硅薄
-            var taskDTO = CreateTaskDTO(task);
 
-            // 鑾峰彇WMS IP鍦板潃鐢ㄤ簬鍙戦�佷换鍔¤姹�
-            var wmsIpAddress = GetWCSIpReceiveTask();
-            if (wmsIpAddress == null)
+            addtask schedulingTask = new addtask
             {
-                throw new InvalidOperationException("WMS IP 鏈厤缃�");
-            }
+                task_id = task.AGVtaskId,
+                task_type = task.TaskType == (int)TaskTypeEnum.Inbound ? "push" : "pop",
+                work_begin = task.SourceAddress,
+                work_end = task.TargetAddress
+            };
 
-            var tasks = new List<WMSTaskDTO>() { taskDTO };
-            // 鍙戦�佷换鍔¤姹傚埌WMS
-            var result = HttpHelper.Post(wmsIpAddress, tasks.ToJsonString());
+            string address = AGV_Interface + "add_task";
+
+            string result = HttpsClient.PostAsync(address, schedulingTask.ToDictionary()).Result;
+
             content = JsonConvert.DeserializeObject<WebResponseContent>(result);
-            if (content.Status)
+
+            if (content.ack != 0)
             {
-                // 娣诲姞浠诲姟鍒版暟鎹簱
-                BaseDal.AddData(task);
-                // 鏇存柊搴撲綅浣嶇疆鐘舵�佷负涓嶅彲鐢�
-                _locationRepository.UpdateData(location);
-                _palletStockInfoRepository.UpdateData(stockInfo);
+                Console.WriteLine($"璇锋眰RCS寮傚父锛歿content.msg}");
+                LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"\r\r--------------------------------------");
+                LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"璇锋眰鍙傛暟锛歿schedulingTask.ToJsonString()}");
+                LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"鍝嶅簲鍙傛暟锛歿content.ToJsonString()}");
+                throw new Exception(content.msg);
             }
+
+            _unitOfWorkManage.BeginTran();
+            // 娣诲姞浠诲姟鍒版暟鎹簱
+            BaseDal.AddData(task);
+            // 鏇存柊搴撲綅浣嶇疆鐘舵�佷负涓嶅彲鐢�
+            _locationRepository.UpdateData(location);
+            _palletStockInfoRepository.UpdateData(stockInfo);
+
+            _unitOfWorkManage.CommitTran();
         }
         catch (Exception ex)
         {
+            _unitOfWorkManage.RollbackTran();
             Console.WriteLine($"鍙戠敓寮傚父: {ex.Message}");
             content.Error(ex.Message);
         }
-
         return content;
     }
 
-    private string GetWCSIpReceiveTask()
+    private string GetAGVIpReceiveTask()
     {
         var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
-        var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
-        var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
+        var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.AGVIPAddress)?.ConfigValue;
+        var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.addTask)?.ConfigValue;
         if (wmsBase == null || ipAddress == null)
         {
             return null;
@@ -600,6 +611,20 @@
 
     #region private 鍐呴儴鏂规硶
 
+
+    private async Task DeleteStockInfoDetailsAsync(IEnumerable<Dt_PalletStockInfoDetail> details)
+    {
+        if (details != null)
+        {
+            var ids = details.Select(x => (object)x.Id).ToArray();
+            var isStockDetailUpdated = await _palletStockInfoDetailRepository.DeleteDataByIdsAsync(ids);
+            if (!isStockDetailUpdated)
+            {
+                throw new Exception("搴撳瓨璇︽儏淇℃伅鏇存柊澶辫触");
+            }
+        }
+    }
+
     /// <summary>
     /// 鍒涘缓鍘嗗彶浠诲姟璁板綍
     /// </summary>
@@ -625,27 +650,6 @@
         return taskHty;
     }
 
-    /// <summary>
-    /// 鏇存柊搴撳瓨浣嶇疆
-    /// </summary>
-    /// <param name="stock">搴撳瓨瀵硅薄</param>
-    /// <param name="toLocation">鐩爣浣嶇疆</param>
-    // 鏇存柊搴撳瓨鍜屼綅缃俊鎭�
-    private (Dt_WheelsStock, DtLocationInfo, DtLocationInfo) UpdateStockLocation(Dt_WheelsStock stock, Dt_Task task)
-    {
-        //淇敼鏉ユ簮搴撲綅鍜� 鐩爣搴撲綅鐘舵��
-        var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
-        fromLocation.LocationStatus = (int)LocationEnum.Free;
-        var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
-        toLocation.LocationStatus = (int)LocationEnum.InStock;
-
-        // 灏嗗簱瀛樹綅缃缃负鐩爣浣嶇疆
-        stock.Wheels_Location = task.TargetAddress;
-
-        // 杩斿洖鏇存柊鍚庣殑搴撳瓨鍜屼綅缃俊鎭�
-        return (stock, fromLocation, toLocation);
-    }
-
     #region 鎵ц鏁版嵁搴撲簨鍔�
     /// <summary>
     /// 鎵ц鏁版嵁搴撲簨鍔�
@@ -654,30 +658,25 @@
     /// <param name="taskHty">鍘嗗彶浠诲姟瀵硅薄</param>
     /// <param name="taskId">浠诲姟ID</param>
     /// <returns></returns>
-    private async Task<bool> ExecuteTransaction(Dt_PalletStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId /*Dt_InWheels_mes inWheels_Mes = null*/)
+    private async Task<bool> ExecuteTransaction(Dt_PalletStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId, DtBoxingInfo boxingInfo)
     {
         _unitOfWorkManage.BeginTran();
         try
         {
-            var isUpdateStock = false;
-            var isDeleteWheelsMes = false;
-
-
+            var isUpdateStock = true;
+            var isDeleteBoxing = true;
             // 娣诲姞搴撳瓨
-            isUpdateStock = _palletStockInfoRepository.AddData(stock) > 0;
-            //if (inWheels_Mes != null)
-            //{
-            //    isDeleteWheelsMes = _InWheels_MesRepository.DeleteData(inWheels_Mes);
+            isUpdateStock = await _palletStockInfoRepository.AddDataNavAsync(stock);
 
-            //    //var wheels_Mes_Hty = inWheels_Mes.Adapt<Dt_InWheels_mes_hty>();
-
-            //    //wheels_Mes_Hty.Wheels_CurrentStatue = "2";
-            //    //wheels_Mes_Hty.FinishDate = DateTime.Now;
-            //    //wheels_Mes_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
-
-            //    //_InWheels_Mes_HtyRepository.AddData(wheels_Mes_Hty);
-            //}
-
+            //鍒犻櫎缁勭洏鏁版嵁
+            if (boxingInfo != null)
+            {
+                boxingInfo.CurrentStatue = 5;
+                isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxingInfo.Id)
+                                        .Include(x => x.BoxingInfoDetails)
+                                        .ExecuteCommandAsync();
+            }
+            //var box = _boxingInfoRepository.dele(boxingInfo);
 
             // 娣诲姞鍘嗗彶浠诲姟
             var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
@@ -689,7 +688,7 @@
             var isTaskDelete = await Delete(taskId);
 
             // 鎻愪氦鎴栧洖婊氫簨鍔�
-            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteWheelsMes)
+            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteBoxing)
             {
                 LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊鎴栨坊鍔犲簱瀛橈細{isUpdateStock},淇敼鍏ュ簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
                 _unitOfWorkManage.CommitTran();
@@ -733,24 +732,24 @@
                 var content = new WebResponseContent();
 
                 // 鑾峰彇搴撲綅
-                var location = RequestLocation(input);
-                if (location == null)
-                {
-                    return content.Error("鏃犳硶鑾峰彇璐т綅淇℃伅");
-                }
+                //var location = RequestLocation(input);
+                //if (location == null)
+                //{
+                //    return content.Error("鏃犳硶鑾峰彇璐т綅淇℃伅");
+                //}
 
-                string toAddress = location.LocationCode;
-                int taskState = (int)TaskInStatusEnum.Line_InFinish;
-                int beforeStatus = location.LocationStatus;
-                // 鏇存柊璐т綅淇℃伅
-                location.LocationStatus = (int)LocationEnum.Lock;
+                //string toAddress = location.LocationCode;
+                //int taskState = (int)TaskInStatusEnum.Line_InFinish;
+                //int beforeStatus = location.LocationStatus;
+                //// 鏇存柊璐т綅淇℃伅
+                //location.LocationStatus = (int)LocationEnum.Lock;
 
                 // 鏇存柊浠诲姟淇℃伅
-                MapTaskProperties(task, input, toAddress, taskState);
+                //MapTaskProperties(task, input, toAddress, taskState);
 
                 _unitOfWorkManage.BeginTran();
                 // 寮�濮嬩簨鍔�
-                var isResult = await UpdateTaskAsync(task, location, beforeStatus);
+                var isResult = false; //await UpdateTaskAsync(task, location, beforeStatus);
                 if (!isResult)
                 {
                     _unitOfWorkManage.RollbackTran();

--
Gitblit v1.9.3