From 227f4259effd028b9c8d917c8e59a3e79a19d10f Mon Sep 17 00:00:00 2001
From: chenyong <chenyong@hnkhzn.com>
Date: 星期四, 15 五月 2025 09:18:09 +0800
Subject: [PATCH] 三楼大屏

---
 CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs |  121 +++++++++++++++++++++++++++++----------
 1 files changed, 89 insertions(+), 32 deletions(-)

diff --git a/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs b/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
index 58f94ff..497571a 100644
--- a/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
+++ b/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -3,6 +3,7 @@
 using SixLabors.Fonts.Tables.AdvancedTypographic;
 using SqlSugar;
 using System.Text.RegularExpressions;
+using System.Threading.Tasks;
 using WIDESEA_Cache;
 using WIDESEA_Core;
 using WIDESEA_Core.Const;
@@ -352,7 +353,7 @@
         WebResponseContent content = new WebResponseContent();
         try
         {
-            if (task.TaskType == (int)TaskInboundTypeEnum.InNG || task.TaskType == (int)TaskInboundTypeEnum.InQuality)
+            if (task.TaskType == (int)TaskInboundTypeEnum.InNG)
             {
                 task.TaskState = (int)TaskInStatusEnum.SC_InFinish;
                 // 鍒涘缓鍘嗗彶浠诲姟瀹炰緥妯″瀷
@@ -419,6 +420,9 @@
             Console.WriteLine(err.Message.ToString());
             LogFactory.GetLog("浠诲姟瀹屾垚").Error(true, err);
             content.Error(err.Message);
+            task.ErrorMessage = err.Message;
+            task.TaskState = (int)TaskInStatusEnum.SC_InExecuting;
+            await BaseDal.Update(task);
         }
         return content;
     }
@@ -1646,12 +1650,35 @@
 
     #endregion
 
+    #region 鏌ヨ闈欑疆绌洪棽搴撲綅
+    public WebResponseContent QueryLocationFreeJZ(string RoadwayNo)
+    {
+        WebResponseContent content = new WebResponseContent();
+        try
+        {
+            var result = _locationRepository.QueryData(x => x.EnalbeStatus != (int)EnableEnum.Disable && x.LocationStatus == (int)LocationEnum.Free && x.RoadwayNo.Contains("JZSC"));
+            LogFactory.GetLog($"闈欑疆{RoadwayNo}鏌ヨ绌洪棽搴撲綅").Info(true, $"{JsonConvert.SerializeObject(result)}");
+            if (result.Count > 5)
+            {
+                return content.OK();
+            }
+            return content.Error("搴撲綅宸叉弧");
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
+    }
+
+    #endregion
+
     #region 澶у睆鎺ュ彛
 
     /// <summary>
     /// 鑾峰彇浠诲姟淇℃伅
     /// </summary>
     /// <returns></returns>
+    ///
     public WebResponseContent GetTaskInfo()
     {
         WebResponseContent content = new WebResponseContent();
@@ -1709,20 +1736,50 @@
             return content.Error(ex.Message);
         }
     }
+    /// <summary>
+    /// 鑾峰彇璐т綅鐘舵��
+    /// </summary>
+    /// <returns></returns>
+    public WebResponseContent GetStockQuantity() {
+        WebResponseContent content = new WebResponseContent();
+        try {
+            var location= _locationRepository.Db.Queryable<DtLocationInfo>().ToList();
 
+            return content.OK(data: location);
 
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
+    }
+    public WebResponseContent Getproductionvolume()
+    {
+        WebResponseContent content = new WebResponseContent();
+        try {
+            var now = DateTime.Now;
+            var startOfDay = new DateTime(now.Year, now.Month, now.Day);
+            var endOfDay1 = startOfDay.AddDays(-7);
+            var taskHty= _task_HtyRepository.Db.Queryable<Dt_Task_Hty>().Where(it=>it.CreateDate> endOfDay1).ToList();
+            return content.OK(data: taskHty);
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
 
+    }
     #endregion
 
-    #endregion 澶栭儴鎺ュ彛鏂规硶
+        #endregion 澶栭儴鎺ュ彛鏂规硶
 
-    #region 鍐呴儴璋冪敤鏂规硶
+        #region 鍐呴儴璋冪敤鏂规硶
 
-    /// <summary>
-    /// 鍒涘缓涓�涓柊鐨勪换鍔�
-    /// </summary>
-    /// <param name="model">浠诲姟妯″瀷</param>
-    /// <returns>鍒涘缓鐨勪换鍔�</returns>
+        /// <summary>
+        /// 鍒涘缓涓�涓柊鐨勪换鍔�
+        /// </summary>
+        /// <param name="model">浠诲姟妯″瀷</param>
+        /// <returns>鍒涘缓鐨勪换鍔�</returns>
     public async Task<Dt_Task> Create(Dt_Task model)
     {
         return await BaseDal.Create(model);
@@ -2007,32 +2064,32 @@
             }
 
             #region 鏇存柊搴撳瓨淇℃伅锛堟殏鏃朵笉闇�瑕侊級
-            //if (stock.IsFull)
-            //{
-            //    // 鏌ヨ绗﹀悎鏉′欢鐨勫簱瀛樹俊鎭�
-            //    var stocks = _stockInfoRepository.QueryData(x => x.AreaCode == stock.AreaCode && x.ProductionLine == stock.ProductionLine && x.SpecialParameterDuration != stock.SpecialParameterDuration);
+            if (stock.IsFull)
+            {
+                // 鏌ヨ绗﹀悎鏉′欢鐨勫簱瀛樹俊鎭�
+                var stocks = _stockInfoRepository.QueryData(x => x.AreaCode == stock.AreaCode && x.ProductionLine == stock.ProductionLine && x.SpecialParameterDuration != stock.SpecialParameterDuration);
 
-            //    // 鏌ヨ浠诲姟淇℃伅
-            //    var tasks = BaseDal.QueryData(x => x.PalletCode != stock.PalletCode && x.ProductionLine == stock.ProductionLine).Select(x => x.PalletCode).ToList();
+                // 鏌ヨ浠诲姟淇℃伅
+                var tasks = BaseDal.QueryData(x => x.PalletCode != stock.PalletCode && x.ProductionLine == stock.ProductionLine).Select(x => x.PalletCode).ToList();
 
-            //    if (stocks != null && stocks.Count > 0)
-            //    {
-            //        // 杩囨护鍑洪渶瑕佹洿鏂扮殑搴撳瓨淇℃伅
-            //        var stocksToUpdate = stocks.Where(item => !tasks.Contains(item.PalletCode)).ToList();
-            //        foreach (var item in stocksToUpdate)
-            //        {
-            //            // 鏇存柊搴撳瓨淇℃伅鐨勭壒瀹氬弬鏁�
-            //            item.SpecialParameterDuration = stock.SpecialParameterDuration;
-            //            item.ParameterInfos = stock.ParameterInfos;
-            //            item.OutboundTime = Convert.ToDateTime(item.LinedProcessFeedbackTime == null ? item.CreateDate : item.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(stock.SpecialParameterDuration));
-            //        }
-            //        if (stocksToUpdate.Count > 0)
-            //        {
-            //            // 寮傛鏇存柊搴撳瓨淇℃伅
-            //            var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocksToUpdate);
-            //        }
-            //    }
-            //}
+                if (stocks != null && stocks.Count > 0)
+                {
+                    // 杩囨护鍑洪渶瑕佹洿鏂扮殑搴撳瓨淇℃伅
+                    var stocksToUpdate = stocks.Where(item => !tasks.Contains(item.PalletCode)).ToList();
+                    foreach (var item in stocksToUpdate)
+                    {
+                        // 鏇存柊搴撳瓨淇℃伅鐨勭壒瀹氬弬鏁�
+                        item.SpecialParameterDuration = stock.SpecialParameterDuration;
+                        item.ParameterInfos = stock.ParameterInfos;
+                        item.OutboundTime = Convert.ToDateTime(item.LinedProcessFeedbackTime == null ? item.CreateDate : item.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(stock.SpecialParameterDuration));
+                    }
+                    if (stocksToUpdate.Count > 0)
+                    {
+                        // 寮傛鏇存柊搴撳瓨淇℃伅
+                        var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocksToUpdate);
+                    }
+                }
+            }
             #endregion
 
             // 娣诲姞鍘嗗彶浠诲姟

--
Gitblit v1.9.3