From 48d66a079c307356997fb400d27907ff6d363b7b Mon Sep 17 00:00:00 2001
From: liudl <673013083@qq.com>
Date: 星期一, 20 一月 2025 08:35:37 +0800
Subject: [PATCH] 修改2楼分拣和1楼拆垛时获取拆垛信息接口

---
 Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs |  118 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 115 insertions(+), 3 deletions(-)

diff --git a/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs b/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
index bc02898..5dd75ac 100644
--- a/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
+++ b/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
@@ -2,10 +2,13 @@
 using AngleSharp.Dom;
 using COSXML.Network;
 using DocumentFormat.OpenXml.Drawing.Charts;
+using DocumentFormat.OpenXml.Math;
+using Elastic.Clients.Elasticsearch.Inference;
 using Elastic.Clients.Elasticsearch.Tasks;
 using Furion.DatabaseAccessor;
 using Furion.Logging;
 using Microsoft.AspNetCore.SignalR;
+using NewLife;
 using WCS.Application.Entity;
 using WCS.Application.Service.WcsTask.Dto;
 
@@ -53,7 +56,9 @@
             .WhereIF(!string.IsNullOrWhiteSpace(input.PalletNo), u => u.PalletNo.Contains(input.PalletNo.Trim()))
             .WhereIF(!string.IsNullOrWhiteSpace(input.Origin), u => u.Origin.Contains(input.Origin.Trim()))
             .Select<WcsTaskOutput>();
-        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
+        return await query.OrderBy(o=>o.Levels).OrderByDescending(o=>o.CreateTime)
+            .OrderByDescending(m=>m.Status).OrderBy(m=>m.TaskNo)
+            .ToPagedListAsync(input.Page, input.PageSize);
     }
 
     /// <summary>
@@ -196,6 +201,7 @@
                 modTask.CancelDate = DateTime.Now;//鍙栨秷鏃堕棿
             }
             modTask.Status = input.Status;
+            modTask.Levels = 999;
             await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Status, s.IsSuccess, s.FinishDate, s.CancelDate, s.UpdateTime, s.UpdateUserId, s.UpdateUserName }).ExecuteCommandAsync();
             //鍐欏叆浠诲姟鏄庣粏琛�
             WcsTaskMonitor modTaskMonitor = new WcsTaskMonitor()
@@ -262,9 +268,15 @@
         {
             TaskNo = modTask.TaskNo,
             PalletNo = modTask.PalletNo,
-            TaskType = ((int)TaskTypeEnum.In).ToString(),
+            TaskType = ((int)modTask.TaskType).ToString(),
             TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
         };
+        //鍑哄簱鏃讹紝浠诲姟鍙峰瓧娈靛鍔犲嚭搴撳彛
+        var taskno = modTask.TaskNo;
+        if (modTask.TaskType == TaskTypeEnum.Out)
+        {
+            taskno = taskno + modTask.EndLocate;
+        }
         //浠诲姟璇︽儏
         var modTaskMonitor = new WcsTaskMonitor()
         {
@@ -293,12 +305,112 @@
         //涓嬪彂浠诲姟鏃ュ織
         HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
     }
+    /// <summary>
+    /// 浠诲姟缃《
+    /// </summary>
+    /// <param name="input"></param>
+    /// <returns></returns>
+    [HttpPost]
+    [ApiDescriptionSettings(Name = "TopUpTask")]
+    [DisplayName("浠诲姟缃《")]
+    public async Task TopUpTask(UpdateWcsTaskInput input)
+    {
+        var modTask = await _wcsTaskRep.GetByIdAsync(input.Id);
+        if (modTask.Status != TaskStatusEnum.Wait)
+        {
+            throw Oops.Oh("鍙湁绛夊緟鎵ц鐨勪换鍔℃墠鑳界疆椤讹紒");
+        }
+        int editNum = 1;
+        List<string> _editTaskNoList = new List<string>();
+        //鍌ㄤ綅娣卞害
+        string locatDepth = "";
+        if (modTask.TaskType == TaskTypeEnum.Out || modTask.TaskType == TaskTypeEnum.Move)//鍑哄簱浠诲姟鎴栧叆搴撲换鍔�
+        {
+            locatDepth = modTask.StartLocate.Substring(modTask.StartLocate.Length - 1, 1);//璧峰鍌ㄤ綅娣卞害
+            if (locatDepth == "2")//鍒ゆ柇褰撳墠鍌ㄤ綅鏄惁娣卞害涓�2锛屽唴渚у偍浣�
+            {
+                string locatString = modTask.StartLocate.Substring(0, modTask.StartLocate.Length - 1) + "1";//鑾峰彇澶栦晶鍌ㄤ綅鍦板潃
+                //鍒ゆ柇澶栦晶鍌ㄤ綅鏄惁鏈夌瓑寰呮墽琛岀殑浠诲姟锛屾湁灏变紭鍏堟墽琛�
+                var modTask2 = _db.Queryable<WcsTask>().First(w => w.IsDelete == false && w.Status == TaskStatusEnum.Wait && w.StartLocate == locatString);
+                if (modTask2 != null)
+                {
+                    modTask2.Levels = 1;
+                    await _wcsTaskRep.Context.Updateable(modTask2).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask2.TaskNo);
+
+                    modTask.Levels = 2;
+                    await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask.TaskNo);
+
+                    editNum = 2;
+                }
+                else
+                {
+                    modTask.Levels = 1;
+                    await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask.TaskNo);
+                }
+            }
+            else
+            {
+                modTask.Levels = 1;
+                await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                _editTaskNoList.Add(modTask.TaskNo);
+            }
+        }
+        if (modTask.TaskType == TaskTypeEnum.In)//鍏ュ簱浠诲姟
+        {
+            if (string.IsNullOrEmpty(modTask.EndLocate))
+            {
+                throw Oops.Oh("璇ュ叆搴撲换鍔¤繕鏈垎閰嶅偍浣嶏紝缃《澶辫触锛�");
+            }
+            locatDepth = modTask.EndLocate.Substring(modTask.EndLocate.Length - 1, 1);//鐩爣鍌ㄤ綅娣卞害
+            if (locatDepth == "1")//鍒ゆ柇褰撳墠鍌ㄤ綅鏄惁娣卞害涓�1锛屽渚у偍浣�
+            {
+                string locatString = modTask.EndLocate.Substring(0, modTask.EndLocate.Length - 1) + "2";//鑾峰彇鍐呬晶鍌ㄤ綅鍦板潃
+                //鍒ゆ柇鍐呬晶鍌ㄤ綅鏄惁鏈夌瓑寰呮墽琛岀殑浠诲姟锛屾湁灏变紭鍏堟墽琛�
+                var modTask2 = _db.Queryable<WcsTask>().First(w => w.IsDelete == false && w.Status == TaskStatusEnum.Wait && (w.StartLocate == locatString || w.EndLocate == locatString));
+                if (modTask2 != null)
+                {
+                    modTask2.Levels = 1;
+                    await _wcsTaskRep.Context.Updateable(modTask2).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask2.TaskNo);
+
+                    modTask.Levels = 2;
+                    await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask.TaskNo);
+
+                    editNum = 2;
+                }
+                else
+                {
+                    modTask.Levels = 1;
+                    await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                    _editTaskNoList.Add(modTask.TaskNo);
+                }
+            }
+            else
+            {
+                modTask.Levels = 1;
+                await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+                _editTaskNoList.Add(modTask.TaskNo);
+            }
+        }
+        //椤哄欢鍏朵粬缃《浠诲姟
+        var modTaskList = _db.Queryable<WcsTask>().Where(w => w.IsDelete == false && w.Status == TaskStatusEnum.Wait && w.Levels != 999 && !_editTaskNoList.Contains(w.TaskNo)).ToList();
+        foreach (var item in modTaskList)
+        {
+            item.Levels += editNum;
+        }
+        await _wcsTaskRep.Context.Updateable(modTaskList).UpdateColumns(s => new { s.Levels }).ExecuteCommandAsync();
+    }
 
     /// <summary>
     /// 鑷姩鐢熸垚浠诲姟鍙�
     /// </summary>
     /// <param name="codeFlag"></param>
     /// <returns></returns>
+    [NonAction]
     public string GetTaskCode(string codeFlag="WCS")
     {
         var list = _db.Queryable<WcsTask>().Where(m => m.TaskNo.StartsWith("WCS")).ToList();
@@ -319,7 +431,7 @@
             if (maxNo.Length==12 && maxNo.Substring(0, 8) == date)
             {
                 int lastNo = Convert.ToInt32(maxNo.Substring(8, 4)) + 1;
-                no = codeFlag + date + (lastNo.ToString().PadLeft(3, '0'));
+                no = codeFlag + date + (lastNo.ToString().PadLeft(4, '0'));
             }
             else
             {

--
Gitblit v1.8.0