From fe941b73b9496f6cfab1a8957f319f74ea09fe1d Mon Sep 17 00:00:00 2001
From: Huangxiaoqiang-03 <1247017146@qq.com>
Date: 星期一, 04 十一月 2024 17:34:32 +0800
Subject: [PATCH] 1

---
 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs |   99 ++++++++++++++++++++++++++++++-------------------
 1 files changed, 60 insertions(+), 39 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs"
index 897c659..3b7fac9 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs"
@@ -12,6 +12,7 @@
 using System.Reflection.Metadata;
 using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
 using SkiaSharp;
+using System.Collections;
 
 namespace WIDESEA_TaskInfoService
 {
@@ -156,14 +157,31 @@
                 _unitOfWorkManage.BeginTran();
                 //鍒ゆ柇绉诲簱
                 (List<Dt_Task>?, List<Dt_Task>?) result=RelocationTasks(tasks.OrderBy(x=>x.Depth).ToList());
-
-                if(result.Item1 != null)
+                if (result.Item1 != null && result.Item1.Count >0)
                 {
-
+                    AddData(result.Item1);
+                    var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item1, "鍏ュ簱浠诲姟涓嬪彂");
+                    if (!response.Status)
+                    {
+                        _unitOfWorkManage.RollbackTran();
+                        return content = WebResponseContent.Instance.Error($"{response.Message}");
+                    }
                 }
-                for (int i = 0; i < result.Item2.Count; i++)
+                if(result.Item2 != null&&result.Item2.Count>0)
                 {
-
+                    for (int i = 0; i < result.Item2.Count; i++)
+                    {
+                        Dt_LocationInfo location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == result.Item2[i].SourceAddress && x.RoadwayNo == result.Item2[i].Roadway);
+                        _basicService.LocationInfoService.UpdateLocationLock(location, result.Item2[i].TaskNum, StockChangeType.Outbound.ObjToInt(), false);
+                        
+                    }
+                    AddData(result.Item2);
+                    var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item2, "鍏ュ簱浠诲姟涓嬪彂");
+                    if (!response.Status)
+                    {
+                        _unitOfWorkManage.RollbackTran();
+                        return content = WebResponseContent.Instance.Error($"{response.Message}");
+                    }
                 }
 
                 
@@ -215,8 +233,8 @@
                         int befoStatus=location.LocationStatus.ObjToInt();
                         if (location != null)
                         {
-                            Dt_LocationInfo result = isDepth(location);
-                            if (result != null && result.LocationStatus == LocationStatusEnum.Lock.ObjToInt() && result.LocationStatus != LocationStatusEnum.PalletLock.ObjToInt() && result.LocationStatus != LocationStatusEnum.Free.ObjToInt())
+                            Dt_LocationInfo result = _basicService.LocationInfoService.isDepth(location);
+                            if (result != null && result.LocationStatus != LocationStatusEnum.Lock.ObjToInt() && result.LocationStatus != LocationStatusEnum.PalletLock.ObjToInt() && result.LocationStatus != LocationStatusEnum.Free.ObjToInt())
                             {
                                 int sum = 0;
                                 for (int j = 0; j < task.Count; j++)
@@ -230,8 +248,8 @@
                                 {
                                     Dt_Task relocariontask = RelocationTask(result);
                                     task[i].Grade=1;
-                                    tasks.Add(task[i]);
                                     relocationList.Add(relocariontask);
+                                    relocationList.Add(task[i]);
                                 }
                                 else
                                 {
@@ -270,7 +288,7 @@
                             break;
                         }
                     }
-                    return (tasks, relocationList);
+                    return (relocationList,tasks);
                 }
                 else
                 {
@@ -309,8 +327,12 @@
                             TargetAddress = locationInfos.LocationCode,
                             TaskStatus = InTaskStatusEnum.RelocationNew.ObjToInt(),
                             TaskType = TaskTypeEnum.Relocation.ObjToInt(),
+                            Depth= location.Depth,
                             TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum))
                         };
+                        _basicService.LocationInfoService.RelocationLock(location, locationInfos, tasks.TaskNum);
+                        stockInfo.StockStatus= StockStatusEmun.绉诲簱閿佸畾.ObjToInt();
+                        _stockService.StockInfoService.Repository.UpdateData(stockInfo);
                         return tasks;
                     }
                     else
@@ -418,20 +440,46 @@
                     TaskType = TaskTypeEnum.PalletOutbound.ObjToInt(),
                     Depth = locationInfo.Depth,
                     TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum))
-
                 };
                 int beforeStatus = locationInfo.LocationStatus;
                 _unitOfWorkManage.BeginTran();
                 stockInfo.StockStatus = StockStatusEmun.鍑哄簱閿佸畾.ObjToInt();
                 locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt();
-                BaseDal.AddData(task);
+                List<Dt_Task> tasks=new List<Dt_Task>();
+                tasks.Add(task);
+                (List<Dt_Task>?, List<Dt_Task>?) result = RelocationTasks(tasks.OrderBy(x => x.Depth).ToList());
+                if (result.Item1 != null && result.Item1.Count > 0)
+                {
+                    AddData(result.Item1);
+                    var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item1, "鍏ュ簱浠诲姟涓嬪彂");
+                    if (!response.Status)
+                    {
+                        _unitOfWorkManage.RollbackTran();
+                        return  WebResponseContent.Instance.Error($"{response.Message}");
+                    }
+                }
+                if (result.Item2 != null && result.Item2.Count > 0)
+                {
+                    for (int i = 0; i < result.Item2.Count; i++)
+                    {
+                        Dt_LocationInfo location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == result.Item2[i].SourceAddress && x.RoadwayNo == result.Item2[i].Roadway);
+                        _basicService.LocationInfoService.UpdateLocationLock(location, result.Item2[i].TaskNum, StockChangeType.Outbound.ObjToInt(), false);
+
+                    }
+                    AddData(result.Item2);
+                    var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item2, "鍏ュ簱浠诲姟涓嬪彂");
+                    if (!response.Status)
+                    {
+                        _unitOfWorkManage.RollbackTran();
+                        return  WebResponseContent.Instance.Error($"{response.Message}");
+                    }
+                }
                 _stockService.StockInfoService.UpdateData(stockInfo);
 
                 _basicService.LocationInfoService.UpdateData(locationInfo);
 
                 _basicService.LocationInfoService.UpdateLocationLock(locationInfo, task.TaskNum, StockChangeType.Outbound.ObjToInt(), false);
                 _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Outbound.ObjToInt(), "", task.TaskNum);
-
                 _unitOfWorkManage.CommitTran();
                 return WebResponseContent.Instance.OK();
             }
@@ -439,33 +487,6 @@
             {
                 return WebResponseContent.Instance.Error(ex.Message);
             }
-        }
-
-        public Dt_LocationInfo isDepth(Dt_LocationInfo locationInfo)
-        {
-            if (locationInfo.Depth == 2)
-            {
-                if (locationInfo.Row == 1 || locationInfo.Row == 5)
-                {
-                    Dt_LocationInfo dt_LocationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.Row == locationInfo.Row + 1 && x.Layer == locationInfo.Layer && x.Column == locationInfo.Column && x.RoadwayNo == locationInfo.RoadwayNo);
-
-                    if (dt_LocationInfo != null)
-                    {
-                        return dt_LocationInfo;
-                    }
-                    
-                }
-                else if (locationInfo.Row == 4 || locationInfo.Row == 8)
-                {
-                    Dt_LocationInfo dt_LocationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.Row == locationInfo.Row + 1 && x.Layer == locationInfo.Layer && x.Column == locationInfo.Column && x.RoadwayNo == locationInfo.RoadwayNo);
-
-                    if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.InStock.ObjToInt())
-                    {
-                        return dt_LocationInfo;
-                    }
-                }
-            }
-            return null;
         }
     }
 }

--
Gitblit v1.9.3