From 9862f9e1237c3d360cb4fb5547d8b11e33578d39 Mon Sep 17 00:00:00 2001
From: czw <selecti@yeah.net>
Date: 星期三, 18 六月 2025 22:49:38 +0800
Subject: [PATCH] qx

---
 HH.WCS.QingXiNongfu/wms/TaskHelper.cs |   68 +++++++++++++++++++++++----------
 1 files changed, 47 insertions(+), 21 deletions(-)

diff --git a/HH.WCS.QingXiNongfu/wms/TaskHelper.cs b/HH.WCS.QingXiNongfu/wms/TaskHelper.cs
index 3a93956..76c1125 100644
--- a/HH.WCS.QingXiNongfu/wms/TaskHelper.cs
+++ b/HH.WCS.QingXiNongfu/wms/TaskHelper.cs
@@ -1,11 +1,14 @@
-锘縰sing HH.WCS.QingXigongchang.process;
+锘縰sing HH.WCS.QingXigongchang.dispatch;
+using HH.WCS.QingXigongchang.process;
 using HH.WCS.QingXigongchang.util;
 using Newtonsoft.Json;
+using NLog.Fluent;
 using SqlSugar;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Linq.Expressions;
+using System.Threading.Tasks;
 
 namespace HH.WCS.QingXigongchang.wms
 {
@@ -86,6 +89,10 @@
         {
             var fromLoc = LocationHelper.GetLoc(from);
             var endLoc = LocationHelper.GetLoc(to);
+
+            //NDCHelper.ChangeParam(taskNo, agvsite, 2);
+            //NDCHelper.ChangeParam(taskNo, 2, 6);
+
             if (fromLoc.S_AREA_CODE == "YWLRGDD")
             {
                 //鏌ヨ浠诲姟琛� 瑕佹眰鏄彧鑳界敓鎴愪袱涓换鍔�璧风偣搴撳尯涓篩WLRGDD  hh_plg  2025骞�鏈�鏃�
@@ -123,6 +130,12 @@
                         return false;
                     }
                 }
+                if (!taskType.Contains("鎴愬搧婊℃-鍏ュ簱"))
+                    if (endLoc.N_CURRENT_NUM >= endLayer || fromLoc.N_CURRENT_NUM < startLayer)
+                    {
+                        LogHelper.Info($"CreateTransport-  CreateTask Error" + $"璧风偣鏁伴噺{fromLoc.N_CURRENT_NUM}<{startLayer}鎴栬�{endLoc.N_CURRENT_NUM}>={endLayer} ");
+                        return false;
+                    }
             }
             WMSTask wmsTask = new WMSTask()
             {
@@ -146,6 +159,8 @@
             };
 
             LogHelper.Info($"CreateTransport-  CreateTask" + $"{JsonConvert.SerializeObject(wmsTask)}");
+            LogHelper.Info($"CreateTransport-  CreateTask {wmsTask.S_TASK_NO} 璧风偣:{JsonConvert.SerializeObject(from)}");
+            LogHelper.Info($"CreateTransport-  CreateTask {wmsTask.S_TASK_NO} 缁堢偣:{JsonConvert.SerializeObject(to)}");
             return CreateTask(wmsTask, lockLoc);
         }
         internal static string GetDeptName(string taskType)
@@ -227,37 +242,48 @@
         internal static void End(WMSTask task)
         {
             var db = new SqlHelper<WMSTask>().GetInstance();
-            if (task != null)
-            {
-                task.S_B_STATE = "瀹屾垚";
-                task.T_END_TIME = DateTime.Now;
-                db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE, it.T_END_TIME }).ExecuteCommand();
-            }
+
 
             //plg 2025骞�鏈�3鏃�10:42:24
             if (task.S_END_LAREA == "YWLWJJB" && task.S_START_LAREA != "YWLRGDD")
             {
                 var model = db.Queryable<Location>().Where(a => a.S_LOC_CODE == task.S_TWO_END_LOC).First();
-                //鍏堣В閿佺粓鐐�鍦ㄩ攣瀹�-                //db.Ado.BeginTran();
-                //try
-                //{
-                //    model.S_LOCK_STATE = "鏃�;
-                //    var res = db.Updateable(model).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0;
-                //    LogHelper.Info(task.S_TWO_END_LOC + "LockLoc:閿佺粨鏋� + res);
-                //    db.Ado.CommitTran();
-                //}
-                //catch (Exception ex)
-                //{
-                //    db.Ado.RollbackTran();
-                //    LogHelper.Info("CreateTask 澶辫触 " + ex.Message);
-                //}
                 if (model != null)
                 {
+                    //鍏堣В閿佺粓鐐�鍦ㄩ攣瀹�+                    db.Ado.BeginTran();
+                    try
+                    {
+                        model.S_LOCK_STATE = "鏃�;
+                        var res = db.Updateable(model).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0;
+                        LogHelper.Info(task.S_TWO_END_LOC + "LockLoc:閿佺粨鏋� + res);
+                        db.Ado.CommitTran();
+                    }
+                    catch (Exception ex)
+                    {
+                        db.Ado.RollbackTran();
+                        LogHelper.Info("CreateTask 澶辫触 " + ex.Message);
+                    }
+
                     LogHelper.Info(task.S_TWO_END_LOC + "浜屾浠诲姟 寮�銆�");
                     var b = TaskProcess.CreateTransport(task.S_SRC_NO, task.S_END_LOC, task.S_TWO_END_LOC, "鍘熺墿鏂欐惉杩�绾哥", task.S_CNTRS.Split(',').ToList(), task.N_START_LAYER, 1, task.N_CNTR_COUNT, task.N_PRIORITY);
+                    //if (b)
+                    //{
+                    //    if (task != null)
+                    //    {
+                    //        task.S_B_STATE = "瀹屾垚";
+                    //        task.T_END_TIME = DateTime.Now;
+                    //        db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE, it.T_END_TIME }).ExecuteCommand();
+                    //    }
+                    //}
                 }
             }
+            if (task != null)
+            {
+                task.S_B_STATE = "瀹屾垚";
+                task.T_END_TIME = DateTime.Now;
+                db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE, it.T_END_TIME }).ExecuteCommand();
+            }
         }
         internal static void Fail(WMSTask task)
         {

--
Gitblit v1.9.1