From b67787b031e357c60565d3e1aa8b829706e520e2 Mon Sep 17 00:00:00 2001
From: 海波 张 <2956280567@qq.com>
Date: 星期五, 11 七月 2025 17:30:56 +0800
Subject: [PATCH] Mes接口修改

---
 wms/TaskHelper.cs |   63 +++++++++++++++++++++++++------
 1 files changed, 51 insertions(+), 12 deletions(-)

diff --git a/wms/TaskHelper.cs b/wms/TaskHelper.cs
index ee18278..12578b6 100644
--- a/wms/TaskHelper.cs
+++ b/wms/TaskHelper.cs
@@ -425,7 +425,7 @@
                     LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓鎴愬姛", "浠诲姟");
                     var db = new SqlHelper<object>().GetInstance();
                     db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
-
+                    LogHelper.Info($"鍥炴姤{task1.S_OP_CODE}", "鍥炴姤Mes浠诲姟");
                     TaskHelper.opMesTask(task1, 0);
                 }
                 else
@@ -597,16 +597,48 @@
                 var cntrItem = ContainerHelper.GetCntrItem(task.S_CNTR_CODE);
                 if (cntrItem == null)
                 {
-                    LogHelper.Info($"浠诲姟{task.S_CODE}娌℃煡鍒板鍣ㄧ墿鏂檣task.S_CNTR_CODE}", "涓婁笅鏋惰褰�);
+                    LogHelper.Info($"浠诲姟{task.S_CODE}娌℃煡鍒板鍣ㄧ墿鏂檣task.S_CNTR_CODE}", "鍥炴姤Mes浠诲姟");
                     return false;
                 }
+
+                var work = TaskHelper.GetWmsWork(task.S_OP_CODE);
+
+                if (work == null) {
+                    LogHelper.Info($"浠诲姟{task.S_CODE}娌℃煡鍒颁綔涓歿task.S_OP_CODE}", "鍥炴姤Mes浠诲姟");
+                    return false;
+                }
+                var endArea = "";
+
+                if (LocationHelper.GetErroArea(task.S_END_AREA))
+                {
+                    if (task.S_TYPE.Contains("鍑哄簱"))
+                    {
+                        endArea = task.S_END_LOC;
+                    }
+                    else {
+                        endArea = task.S_END_AREA;
+                    }
+
+                    
+                }
+                else {
+                    if (task.S_TYPE.Contains("鍑哄簱"))
+                    {
+                        endArea = task.S_END_LOC;
+                    }
+                    else {
+                        endArea = work.S_END_AREA;
+                    }
+                }
+
+
 
 
                 var interact = new
                 {
                     taskNo = task.S_OP_CODE,//浠诲姟鍙�                     updater = "WMS",// 鎿嶄綔浜�濡俉MS/MES绛�-                    endStock = task.S_END_LOC,//缁堢偣
+                    endStock = endArea,//缁堢偣
                     taskStatus = state,//0锛氬垵濮嬬姸鎬侊紝1锛氳繘琛屼腑锛�锛氬畬鎴愶紝3锛氫换鍔″彇娑�                     updateTime = DateTime.Now.ToString(),//鎿嶄綔鏃堕棿
                     TurnCardNum  = cntrItem.TurnCardNum,//鍛ㄨ浆鍗″彿
@@ -798,6 +830,22 @@
                 LocationHelper.LockLoc(task.S_END_LOC, "鍑哄簱閿�, 2);
             }
 
+            if (task.S_SCHEDULE_TYPE.Contains("agv"))
+            {
+
+                if (LocationHelper.GetErroArea(task.S_END_AREA))
+                {
+                    db.Deleteable<Container>().Where(it => it.S_CODE == task.S_CNTR_CODE).ExecuteCommand();
+                    db.Deleteable<LocCntrRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
+                    db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
+                }
+                else
+                {
+                    TaskHelper.opMesTask(task, 2);
+                }
+            }
+         
+
             if (task.S_TYPE.Contains("鍑哄簱") && task.S_SCHEDULE_TYPE.Contains("agv"))
             {
                 var location = db.Queryable<Location>().Where(a => a.S_CODE == task.S_END_LOC).First();
@@ -807,15 +855,6 @@
                 db.Deleteable<LocCntrRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
                 db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
             }
-
-
-            if (LocationHelper.GetErroArea(task.S_END_AREA)) {
-                db.Deleteable<Container>().Where(it => it.S_CODE == task.S_CNTR_CODE).ExecuteCommand();
-                db.Deleteable<LocCntrRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
-                db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
-            }
-
-
         }
 
 

--
Gitblit v1.9.1