From 9863192570e0356541235a2cb8177cae00edbc12 Mon Sep 17 00:00:00 2001
From: IPC-610 <IPC-610@DESKTOP-6LEOOS3>
Date: 星期一, 23 九月 2024 19:15:15 +0800
Subject: [PATCH] 修改测试问题

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |  240 ++++++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 178 insertions(+), 62 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index da065a4..5e49384 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -10,6 +10,7 @@
 using System;
 using System.Data;
 using System.Reflection.Emit;
+using WCS.Application.Util;
 
 namespace WCS.Application;
 public static class PLCService
@@ -70,7 +71,7 @@
                     }
 
                     // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞�
-                    PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(),
+                    PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, ((int)modTask.TaskType).ToString(),
                         modTask.StartRoadway, modTask.EndRoadway);
 
                     // 鐩爣宸ヤ綅涓嶄负null锛岄渶鍏堝垽鏂斁璐у伐浣嶆槸鍚︾┖闂�
@@ -104,8 +105,8 @@
                         }
                     }
 
-                    // 鑾峰彇杞崲鍚庣殑璧峰鎺掑垪灞�
-                    PlcTaskInfo startTaskInfo = PLCCommon.GetEndPai(modTask.StartLocate.Substring(1, 2),
+                    // 鑾峰彇杞崲鍚庣殑璧峰鎺掑垪灞� 06010101
+                    PlcTaskInfo startTaskInfo = PLCCommon.GetEndPai(modTask.StartRoadway.Substring(1, 2), modTask.StartLocate.Substring(2, 2),
                     modTask.StartLocate.Substring(0, 2), modTask.StartLocate.Substring(4, 2),
                     modTask.StartLocate.Substring(6, 2));
 
@@ -135,7 +136,7 @@
                     if (listResult.All(s => s.IsSucceed))
                     {
                         // 鍐欏叆璺烘満浠诲姟涓嬪彂瀹屾垚
-                        plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "830");
+                        var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "830");
 
                         // 灏嗙Щ搴撲换鍔″緟鎵ц鏀逛负姝e湪鎵ц
                         _db.Updateable<WcsTask>()
@@ -192,12 +193,12 @@
                     var (res, val) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos);
 
                     var modPosEndStation = modDevice.listStation.FirstOrDefault(m => m.Text == "鐩殑宸ヤ綅");
-                    var (endStationRes, endStation) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos);
+                    var (endStationRes, endStation) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosEndStation.PlcPos);
                     if (res.IsSucceed)
                     {
                         // 鑾峰彇浠诲姟淇℃伅
                         string tasknoVal = val.ToString();
-                        var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == true);
+                        var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
                         if (modTask == null)
                         {
                             Log.Error(string.Format("PLC鎺у埗瀛�840:鏈壘鍒板搴旂殑浠诲姟銆�"));
@@ -218,17 +219,17 @@
                         {
                             // 鑾峰彇璺烘満璧峰宸ヤ綅鐐逛綅閰嶇疆,璇诲彇璧峰宸ヤ綅
                             var modPosStartStation = modDevice.listStation.FirstOrDefault(m => m.Text == "璧峰宸ヤ綅");
-                            var (startStationRes, startStationVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosStartStation.PlcPos);
+                            var (startStationRes, startStationVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.Short, modDevice.DbNumber, modPosStartStation.PlcPos);
                             if (startStationRes.IsSucceed)
                             {
                                 // 鏍规嵁宸ヤ綅鍙疯幏鍙栧搴旂殑杈撻�佺嚎IP
-                                var plcConveyorConn = PLCCommon.GetPlcIp(startStationVal);
+                                PLCUtil plcConveyorConn = PLCCommon.GetPlcIp(startStationVal.ToString());
                                 if (plcConveyorConn.Connected)
                                 {
                                     // 鍚戝彇璐у伐浣嶅啓鍏ユ祦绋嬪瓧640  鍙栬揣宸插畬鎴�
-                                    var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal
-                                                            && m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == true);
-                                    var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640");
+                                    var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal.ToString()
+                                                            && m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == false);
+
                                     var modcTaskMonitor = new WcsTaskMonitor()
                                     {
                                         TaskNo = modTask.TaskNo,
@@ -236,12 +237,24 @@
                                         PlcName = ConveyorMod.Text,
                                         PalletNo = modTask.PalletNo,
                                         Status = TaskStatusEnum.Complete,
-                                        StartLocat = startStationVal,
+                                        StartLocat = startStationVal.ToString(),
                                         EndLocat = modTask.EndLocate                  // 鐩爣鍌ㄤ綅鍦板潃
                                     };
+
+                                    // 璇诲彇wcs鎺у埗瀛�
+                                    var (ress, va1s) = plcConveyorConn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos);
+                                    if (va1s.ToString() == "630") 
+                                    {
+                                        modcTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚:640", startStationVal);
+                                        // 鎻掑叆浜や簰鏃ュ織
+                                        _db.Insertable(modcTaskMonitor).ExecuteCommand();
+                                    }
+
+                                    var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640");
+
                                     if (!retc.IsSucceed)
                                     {
-                                        modcTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触绛夊緟鍦ㄦ鍐欏叆", startStationVal);
+                                        modcTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触", startStationVal);
                                         // 鎻掑叆浜や簰鏃ュ織
                                         _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                                         //涓嬪彂浠诲姟鏃ュ織
@@ -249,40 +262,58 @@
                                         break;
                                     }
 
-                                    modcTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640鎴愬姛", startStationVal);
-                                    // 鎻掑叆浜や簰鏃ュ織
-                                    _db.Insertable(modcTaskMonitor).ExecuteCommand();
                                     //涓嬪彂浠诲姟鏃ュ織
                                     HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                                }
+
+                                // 璇诲彇wcs鎺у埗瀛�
+                                var (resss, va1ss) = plcConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos);
+                                if (va1ss.ToString() == "830") 
+                                {
+                                    modInsertTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0}璺烘満鍙栬揣瀹屾垚鍐欏叆850", startStationVal);
+                                    modInsertTaskMonitor.EndLocat = modTask.EndLocate;                  // 鐩爣鍌ㄤ綅鍦板潃
+                                                                                                        // 鎻掑叆浜や簰鏃ュ織
+                                    _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                                 }
 
                                 // 鍐欏叆娴佺▼鎺у埗瀛�
                                 var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850");
                                 if (!ret.IsSucceed)
                                 {
+                                    modInsertTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0}璺烘満鍙栬揣瀹屾垚鍐欏叆850澶辫触,绛夊緟鍐嶆鍐欏叆銆�", startStationVal);
+                                    modInsertTaskMonitor.EndLocat = modTask.EndLocate;                  // 鐩爣鍌ㄤ綅鍦板潃
+                                                                                                        // 鎻掑叆浜や簰鏃ュ織
+                                    _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                                     break;              // 鍐欏叆澶辫触璺冲嚭绛夊緟鍐嶆鍐欏叆
                                 }
 
-                                modInsertTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0}璺烘満鍙栬揣瀹屾垚850鎴愬姛", startStationVal);
-                                modInsertTaskMonitor.EndLocat = modTask.EndLocate;                  // 鐩爣鍌ㄤ綅鍦板潃
-                                                                                                    // 鎻掑叆浜や簰鏃ュ織
-                                _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                                 //涓嬪彂浠诲姟鏃ュ織
                                 HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
                             }
                         }
                         else if (modTask.TaskType == TaskTypeEnum.Out)
                         {
+                            // 璇诲彇wcs鎺у埗瀛�
+                            var (resss, va1ss) = plcConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos);
+                            if (va1ss.ToString() == "830")
+                            {
+                                // 璁板綍浠诲姟鏄庣粏
+                                modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚鍐欏叆850", modTask.StartLocate);
+                                modInsertTaskMonitor.EndLocat = endStation;                  // 鏀捐揣宸ヤ綅
+                            }
                             // 鍐欏叆娴佺▼鎺у埗瀛�
                             var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850");
                             if (!ret.IsSucceed)
                             {
+                                modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚鍐欏叆850澶辫触,绛夊緟鍐嶆鍐欏叆銆�", modTask.StartLocate);
+                                modInsertTaskMonitor.EndLocat = modTask.EndLocate;                  // 鐩爣鍌ㄤ綅鍦板潃
+                                                                                                    // 鎻掑叆浜や簰鏃ュ織
+                                _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                                 break;              // 鍐欏叆澶辫触璺冲嚭绛夊緟鍐嶆鍐欏叆
                             }
 
-                            // 璁板綍浠诲姟鏄庣粏
-                            modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚", modTask.StartLocate);
-                            modInsertTaskMonitor.EndLocat = endStation;                  // 鏀捐揣宸ヤ綅
+                            //涓嬪彂浠诲姟鏃ュ織
+                            HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
                         }
                         else
                         {
@@ -295,12 +326,13 @@
 
                             modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚", modTask.StartLocate);
                             modInsertTaskMonitor.EndLocat = endStation;                  // 鐩爣鍌ㄤ綅
-                        }
 
-                        // 鎻掑叆浜や簰鏃ュ織
-                        _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
-                        //涓嬪彂浠诲姟鏃ュ織
-                        HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                            // 鎻掑叆浜や簰鏃ュ織
+                            _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
+                            //涓嬪彂浠诲姟鏃ュ織
+                            HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                        }
+                        
                         //淇敼led灞忎俊鎭�
                         //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo);
                     }
@@ -315,7 +347,7 @@
                     if (res.IsSucceed)
                     {
                         string tasknoVal = val.ToString();
-                        var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == true);
+                        var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
                         if (modTask == null)
                         {
                             Log.Error(string.Format("璺烘満鎺у埗瀛�860:鏈壘鍒板搴旂殑浠诲姟銆�"));
@@ -352,24 +384,34 @@
                                     if (modTask.Origin == "WMS")
                                     {
                                         // 鍙嶉WMS
-                                        var requestMode = new TaskRequest()
+                                        var requestMode = new TaskRequestWMS()
                                         {
                                             TaskNo = modTask.TaskNo,
                                             PalletNo = modTask.PalletNo,
-                                            TaskType = TaskTypeEnum.In,
-                                            TaskStatus = TaskStatusEnum.Complete
+                                            TaskType = ((int)TaskTypeEnum.In).ToString(),
+                                            TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
                                         };
                                         HttpService httpService = new HttpService();
                                         var modResponseTask = httpService.RequestTask(requestMode).Result;
-                                        if (modResponseTask.StatusCode == "0")
+                                        if (modResponseTask.StatusCode == 0)
                                         {
                                             modTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
                                         }
+                                        else 
+                                        {
+                                            Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg));
+                                        }
                                     }
+                                    // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                                    modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();
+
                                     // 鎻掑叆浜や簰鏃ュ織
                                     _db.Insertable(modTaskMonitor).ExecuteCommand();
                                     //涓嬪彂浠诲姟鏃ュ織
                                     HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+
+                                    // led鏄剧ず鍐呭
+                                    LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.StartLocate, "鍏ュ簱瀹屾垚 " + $"浠诲姟瀹屾垚:{modTask.TaskNo}", "鎵樼洏鍙�:" + modTask.PalletNo);
 
                                     // 姝ゅ娣诲姞涓嶇┖璺戜笟鍔�
                                 }
@@ -384,7 +426,7 @@
                                     if (plcConveyorConn.Connected)
                                     {
                                         // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞�
-                                        PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(),
+                                        PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, ((int)modTask.TaskType).ToString(),
                                             modTask.StartRoadway, modTask.EndRoadway);
                                         // 鏍规嵁宸ヤ綅鍙疯幏鍙栧伐浣嶄俊鎭�
                                         var wcsDevice = PLCTaskAction.plcDevices.First(s => s.PlcId == plcConveyorConn.PlcId && s.Level == DeviceLevelEnum.Station && s.StationNum == taskInfo.EndStation);
@@ -395,19 +437,19 @@
                                         var listResult = new List<Result>();
                                         //浠诲姟鍙�
                                         var modPosTask = listPos.FirstOrDefault(s => s.Text == "浠诲姟鍙�");
-                                        listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
+                                        listResult.Add(plcConveyorConn.SetPlcDBValue(modPosTask.PosType, wcsDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
                                         //浠诲姟绫诲瀷
                                         var modPosTaskType = listPos.FirstOrDefault(s => s.Text == "浠诲姟绫诲瀷");
-                                        listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, modDevice.DbNumber, modPosTaskType.PlcPos, ((int)modTask.TaskType).ToString()));
+                                        listResult.Add(plcConveyorConn.SetPlcDBValue(modPosTaskType.PosType, wcsDevice.DbNumber, modPosTaskType.PlcPos, ((int)modTask.TaskType).ToString()));
                                         //鎵樼洏鍙�
                                         var modPosPalletNo = listPos.FirstOrDefault(s => s.Text == "鎵樼洏鐮�");
-                                        listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
+                                        listResult.Add(plcConveyorConn.SetPlcDBValue(modPosPalletNo.PosType, wcsDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
                                         //璧峰宸ヤ綅
                                         var modPosLocatNo = listPos.FirstOrDefault(s => s.Text == "璧峰宸ヤ綅");
-                                        listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, taskInfo.EndStation));
+                                        listResult.Add(plcConveyorConn.SetPlcDBValue(modPosLocatNo.PosType, wcsDevice.DbNumber, modPosLocatNo.PlcPos, taskInfo.EndStation));
                                         // 鐩爣宸ヤ綅
                                         var modPosEndLocatNo = listPos.FirstOrDefault(s => s.Text == "鐩殑宸ヤ綅");
-                                        listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
+                                        listResult.Add(plcConveyorConn.SetPlcDBValue(modPosEndLocatNo.PosType, wcsDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
 
                                         // 鏄惁鍐欏叆鎴愬姛
                                         if (listResult.All(s => s.IsSucceed))
@@ -435,6 +477,14 @@
                                                     _db.Insertable(modcTaskMonitor).ExecuteCommand();
                                                     //涓嬪彂浠诲姟鏃ュ織
                                                     HubUtil.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+
+                                                    // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                                                    var taskModel = _db.Queryable<WcsTask>().First(w => w.TaskNo == modTask.TaskNo);
+                                                    modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskModel.StartLocate).Select(s => s.LedIP).First();
+
+                                                    // led鏄剧ず鍐呭
+                                                    LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍑哄簱涓� ", "鎵樼洏鍙�:" + modTask.PalletNo);
+
                                                     break;
                                                 }
                                             }
@@ -478,16 +528,16 @@
                                     if (modTask.Origin == "WMS")
                                     {
                                         // 鍙嶉WMS
-                                        var requestMode = new TaskRequest()
+                                        var requestMode = new TaskRequestWMS()
                                         {
                                             TaskNo = modTask.TaskNo,
                                             PalletNo = modTask.PalletNo,
-                                            TaskType = TaskTypeEnum.Move,
-                                            TaskStatus = TaskStatusEnum.Complete
+                                            TaskType = TaskTypeEnum.Move.ToString(),
+                                            TaskStatus = TaskStatusEnum.Complete.ToString()
                                         };
                                         HttpService httpService = new HttpService();
                                         var modResponseTask = httpService.RequestTask(requestMode).Result;
-                                        if (modResponseTask.StatusCode == "0")
+                                        if (modResponseTask.StatusCode == 0)
                                         {
                                             modcTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
                                             //淇敼鍌ㄤ綅淇℃伅 浠诲姟绫诲瀷 鎵ц鐘舵�� 璧峰浣嶇疆 鐩爣浣嶇疆
@@ -752,6 +802,10 @@
 
                     if (!strMsg.Contains("-1"))
                     {
+                        // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                        var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == TaskNo);
+                        modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();
+
                         // 鍐欏叆330
                         var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "330");
 
@@ -775,9 +829,8 @@
 
                             // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
                             HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
-                            // led鏇存柊鍐呭
-                            //DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and  StationNum = '{EndLocat}'")[0];
-                            //LedDisplay(ConveyorsRow10["LedIP"].ToString(), "宸ヤ綅:" + EndLocat, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿StartLocat}", "鎵樼洏鍙�:" + PalletNo);
+                            // led鏄剧ず鍐呭
+                            LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鐢宠鍏ュ簱 " + $"鐩爣宸烽亾锛歿EndLocate}", "鎵樼洏鍙�:" + palletVal);
                         }
 
                     }
@@ -790,6 +843,7 @@
                 break;
             case "330":
                 {
+                   
                     // 鍐欏叆浠诲姟 鎵樼洏绉诲姩 340
 
                     // 鑾峰彇宸ヤ綅鎵樼洏鐮佷俊鎭�
@@ -838,6 +892,8 @@
 
                         var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "340");
 
+                        // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                        modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();
 
                         if (ret.IsSucceed)
                         {
@@ -860,8 +916,8 @@
                             // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
                             HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
 
-                            // led鏇存柊鍐呭
-                            //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo);
+                            // led鏄剧ず鍐呭
+                            LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍏ュ簱涓� " + $"鐩爣宸烽亾锛歿endLocatVlue}", "鎵樼洏鍙�:" + palletVal);
                         }
                     }
 
@@ -896,6 +952,11 @@
                     string TaskNo = "";
                     // 鍚慦MS鐢宠鍌ㄤ綅淇℃伅
                     strMsg = http.RequestLocate(palletVal, modDevice.StationNum, taskModel, roadway, ref TaskNo);
+
+                    // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                    var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == TaskNo);
+                    modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();
+
                     if (!strMsg.Contains("-1"))
                     {
                         // 鍐欏叆娴佺▼瀛� 630
@@ -921,9 +982,8 @@
 
                             // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
                             HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
-                            // led鏇存柊鍐呭
-                            //DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and  StationNum = '{EndLocat}'")[0];
-                            //LedDisplay(ConveyorsRow10["LedIP"].ToString(), "宸ヤ綅:" + EndLocat, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿StartLocat}", "鎵樼洏鍙�:" + PalletNo);
+                            // led鏄剧ず鍐呭
+                            LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍏ュ簱涓� " + $"鐢宠鍌ㄤ綅鍦板潃:{strMsg}", "鎵樼洏鍙�:" + palletVal);
                         }
                     }
                     else
@@ -982,7 +1042,9 @@
                         string lie = int.Parse(endLocate.Substring(2, 2)).ToString();
                         string ceng = int.Parse(endLocate.Substring(4, 2)).ToString();
 
-                        var djMod = PLCTaskAction.plcDevices.First(m => m.StationNum == modTask.EndRoadway
+                        var djmodel = _db.Queryable<WcsPlc>().First(m => m.IP == sInfo.Ip);
+
+                        var djMod = PLCTaskAction.plcDevices.First(m => m.PlcId == djmodel.Id
                             && m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == false);
                         var djInfos = PLCTaskAction.plcPositions.Where(m => m.IsDelete == false && m.DeviceId == djMod.Id).ToList();
                         var djInfo = djInfos.First(m => m.Text == "PLC娴佺▼瀛�");
@@ -990,7 +1052,7 @@
                         // 鑾峰彇璺烘満褰撳墠鐘舵��
                         var (djRes, djVal) = plcStackeConn.GetPlcDBValue(djMod.PosType, djMod.DbNumber, djMod.PlcPos);
 
-                        if (!djRes.IsSucceed || djVal != "820")
+                        if (!djRes.IsSucceed || djVal.ToString() != "820")
                         {
                             // 璺烘満闈炵┖闂茬瓑寰�
                             break;
@@ -1004,7 +1066,7 @@
                         var modPosTaskType = djInfos.FirstOrDefault(s => s.Text == "浠诲姟绫诲瀷");
                         var taskTypeStr = (int)modTask.TaskType;
                         listResult.Add(plcStackeConn.SetPlcDBValue(modPosTaskType.PosType, djMod.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
-                        var modPosPalletNo = djInfos.FirstOrDefault(s => s.Text == "鎵樼洏鍙�");
+                        var modPosPalletNo = djInfos.FirstOrDefault(s => s.Text == "鎵樼洏鐮�");
                         listResult.Add(plcStackeConn.SetPlcDBValue(modPosPalletNo.PosType, djMod.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
 
                         //璧峰宸ヤ綅
@@ -1108,9 +1170,12 @@
                         // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
                         HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
 
-                        // led鏇存柊鍐呭
-                        //DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and  StationNum = '{EndLocat}'")[0];
-                        //LedDisplay(ConveyorsRow10["LedIP"].ToString(), "宸ヤ綅:" + EndLocat, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿StartLocat}", "鎵樼洏鍙�:" + PalletNo);
+                        // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
+                        var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == modInsertTaskMonitor.TaskNo);
+                        modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();
+
+                        // led鏄剧ず鍐呭
+                        LedDisplay(modDevice.LedIP, "鍒拌揪宸ヤ綅:" + modDevice.StationNum, "鍑哄簱瀹屾垚 " + $"鍌ㄤ綅鍦板潃锛歿modInsertTaskMonitor.StartLocat}", "鎵樼洏鍙�:" + palletVal);
                     }
                     // 鍙嶉WMS鍑哄簱瀹屾垚
                     //TaskReques taskReques = new TaskReques();
@@ -1134,27 +1199,61 @@
                         var (res2, palletVal) = plcConn.GetPlcDBValue(modPosPallet.PosType, modDevice.DbNumber, modPosPallet.PlcPos);
                         var modPosStarStationNum = modDevice.listStation.FirstOrDefault(m => m.Text == "璧峰宸ヤ綅");
                         var (res3, starVal) = plcConn.GetPlcDBValue(modPosStarStationNum.PosType, modDevice.DbNumber, modPosStarStationNum.PlcPos);
+
+                        string tasknoVal = taskVal.ToString();
+                        var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
+                        if (modTask == null)
+                        {
+                            Log.Error(string.Format("杈撻�佺嚎440:鏈壘鍒板搴旂殑浠诲姟銆�"));
+                            break;
+                        }
+                        // 鏀瑰彉浠诲姟鐘舵��
+                        modTask.Status = TaskStatusEnum.Complete;
+                        modTask.FinishDate = DateTime.Now;
+                        _db.Updateable(modTask).ExecuteCommand();
+                        HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());
                         // 鎻掑叆浠诲姟鏄庣粏 
                         var modInsertTaskMonitor = new WcsTaskMonitor()
                         {
-                            TaskNo = taskVal,
+                            TaskNo = modTask.TaskNo,
                             PlcId = modDevice.Id,
                             PlcName = modDevice.Text,
                             InteractiveMsg = $"鍐欏叆鎸囦护450锛歿modDevice.StationNum}鎷i�夊畬鎴�,鎵樼洏绂诲紑宸ヤ綅",
                             PalletNo = palletVal,
                             Status = TaskStatusEnum.Complete,
-                            StartLocat = starVal,
+                            StartLocat = starVal.ToString(),
                             EndLocat = modDevice.StationNum,
                         };
+                        if (modTask.Origin == "WMS")
+                        {
+                            // 鍙嶉WMS
+                            var requestMode = new TaskRequestWMS()
+                            {
+                                TaskNo = modTask.TaskNo,
+                                PalletNo = modTask.PalletNo,
+                                TaskType = ((int)TaskTypeEnum.Out).ToString(),
+                                TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
+                            };
+                            HttpService httpService = new HttpService();
+                            var modResponseTask = httpService.RequestTask(requestMode).Result;
+                            if (modResponseTask.StatusCode == 0)
+                            {
+                                modInsertTaskMonitor.InteractiveMsg += "锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
+                            }
+                            else
+                            {
+                                Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg));
+                            }
+                        }
 
                         // 鎻掑叆浜や簰鏃ュ織
                         _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
 
                         // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
                         HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
-                        // led鏇存柊鍐呭
-                        //DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and  StationNum = '{EndLocat}'")[0];
-                        //LedDisplay(ConveyorsRow10["LedIP"].ToString(), "宸ヤ綅:" + EndLocat, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿StartLocat}", "鎵樼洏鍙�:" + PalletNo);
+                        // led鏄剧ず鍐呭
+                        modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();
+                        LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.StartLocate, $"鎷i�夊畬鎴愶紝鎵樼洏绂诲紑宸ヤ綅", "鎵樼洏鍙�:" + modTask.PalletNo);
                     }
                     #endregion
                 }
@@ -1202,6 +1301,23 @@
         }
     }
 
+    /// <summary>
+    /// Led灞忓睍绀轰俊鎭�
+    /// </summary>
+    /// <param name="ip">鍦板潃</param>
+    /// <param name="top">涓婃柟鍖哄煙</param>
+    /// <param name="content">涓棿鍖哄煙</param>
+    /// <param name="foot">搴曢儴鍖哄煙</param>
+    private static void LedDisplay(string ip, string top, string content, string foot)
+    {
+        try
+        {
+            LedDll Led = new LedDll();
+            Led.LEDstr(ip, top, content, foot);
+        }
+        catch { }
+    }
+
     private static void Test(WcsDeviceDto modDevice)
     {
         //鍐欐娴嬭瘯璇籹tring

--
Gitblit v1.8.0