From cff60cb1cccf70fe33ed9c951c46143fe41fc43a Mon Sep 17 00:00:00 2001
From: IPC-610 <IPC-610@DESKTOP-6LEOOS3>
Date: 星期四, 26 九月 2024 19:09:52 +0800
Subject: [PATCH] 设备呼叫空托跺

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |  115 ++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 104 insertions(+), 11 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index 740df09..e0ef176 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -1217,8 +1217,8 @@
                     #endregion
                 }
                 break;
-            #region 鍑哄簱浜や簰
 
+            #region 鍑哄簱浜や簰
             case "420":
                 {
                     #region 鎵樼洏鍒拌揪鎷i�夊伐浣�/鍑哄簱鍙�
@@ -1345,6 +1345,95 @@
 
             #endregion
 
+            #region 鍙┖鎵樼洏璺�
+            case "50":
+                // plc鐢宠绌烘墭
+                {
+                    // 璋冪敤WMS绌烘墭鍑哄簱鎺ュ彛锛岃繑鍥炲嚭搴撲换鍔″瓨鍏ュ嚭搴撹〃
+                    var strMsg = "";
+                    var http = new HttpService();
+                    strMsg = http.IssuePlnOutHouseWcs("1", "205");
+                    if (!strMsg.Contains("-1"))
+                    {
+                        // 鍐欏叆plc娴佺▼瀛�60
+                        var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "60");
+                    }
+                    else
+                    {
+                        // 鐢宠宸烽亾澶辫触锛丩ED鏄剧ず
+                        Log.Error(string.Format($"宸ヤ綅鍙凤細{modDevice.StationNum}鐢宠绌烘墭璺哄け璐�:{strMsg};"));
+                    }                    
+                }
+                break;
+            case "80":
+                // 绌烘墭鐩樿泛宸插埌浣�
+                {
+                    // 璋冪敤wms浠诲姟鍑哄簱浠诲姟瀹屾垚
+                    // 鑾峰彇璺烘満鐐逛綅閰嶇疆
+                    var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "浠诲姟鍙�");
+                    var (res, val) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos);
+                    // 鏍规嵁浠诲姟鍙疯幏鍙栦换鍔′俊鎭�
+                    if (res.IsSucceed)
+                    {
+                        string tasknoVal = val.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($"宸ヤ綅鍙凤細{modDevice.StationNum}绌烘墭鐩樺埌杈撅紝鏈壘鍒板搴旂殑浠诲姟!浠诲姟鍙穥tasknoVal};"));
+                            break;
+                        }
+                        // 鍐欏叆plc娴佺▼瀛�90
+                        var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "90");
+                        if (ret.IsSucceed)
+                        {
+                            // 鏀瑰彉浠诲姟鐘舵��
+                            modTask.Status = TaskStatusEnum.Complete;
+                            modTask.FinishDate = DateTime.Now;
+                            _db.Updateable(modTask).ExecuteCommand();
+
+                            HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());
+                            var modTaskMonitor = new WcsTaskMonitor()
+                            {
+                                TaskNo = modTask.TaskNo,
+                                PlcId = modDevice.Id,
+                                PlcName = modDevice.Text,
+                                PalletNo = modTask.PalletNo,
+                                Status = TaskStatusEnum.Complete,
+                                StartLocat = modTask.StartLocate,
+                                EndLocat = modTask.EndLocate,
+                                InteractiveMsg = $"浠诲姟瀹屾垚"
+                            };
+                            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)
+                                {
+                                    modTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
+                                }
+                                else
+                                {
+                                    Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg));
+                                }
+                            }
+                            // 鎻掑叆浜や簰鏃ュ織
+                            _db.Insertable(modTaskMonitor).ExecuteCommand();
+                            //涓嬪彂浠诲姟鏃ュ織
+                            HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                        }
+                    }                    
+                }
+                break;
+            #endregion
+
             default: break;
         }
 
@@ -1415,7 +1504,7 @@
                             {
                                 // 鍐欏叆娴佺▼鎺у埗瀛� 2
                                 var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
-                                if (retVal.IsSucceed)
+                                if (!retVal.IsSucceed)
                                 {
                                     Log.Error("婕旂ず妯″紡鍐欏叆鍒嗛亾鍙峰け璐�!");
                                     break;
@@ -1614,9 +1703,9 @@
                     {
                         // 鏍规嵁宸ヤ綅鍙凤紝鑾峰彇鎵樼洏鍙�
                         var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
-                        // 鏍规嵁宸ヤ綅鍙疯幏鍙栨墭鐩樼嚎璇ュ伐浣嶅彿鐨勯厤缃俊鎭�
-                        var numModel = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business);
-                        var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "鐩爣宸ヤ綅" && m.IsDelete == false);
+                        // 鏍规嵁宸ヤ綅鍙疯幏鍙� 鎵樼洏绾胯宸ヤ綅鍙风殑閰嶇疆淇℃伅
+                        var numModel = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId != modDevice.PlcId);
+                        var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "鐩殑宸ヤ綅" && m.IsDelete == false);
                         if (checkTaskMedel == null)
                         {
                             Log.Error(string.Format("缁勬墭澶辫触鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栨墭鐩樺彿澶辫触!", modDevice.StationNum));
@@ -1634,13 +1723,14 @@
                         // 鐮佸灈宸ヤ綅鎵樼洏鍙�
                         string palletNo = checkTaskMedel.PalletNo;
 
+                        // 鏄惁婕旂ず妯″紡
                         if (PLCTaskAction.boDemo)
                         {
                             // 鐩存帴绠眞ms鐢宠宸烽亾
                             var http = new HttpService();
                             string TaskNo = "", EndLocate = "";
                             string strMsg = http.RequestRoadWay(palletNo, modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo);
-                            if (!strMsg.Contains("-1"))
+                            if (strMsg.Contains("-1"))
                             {
                                 Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0};鍘熷洜{1}", modDevice.StationNum, strMsg));
                                 break;
@@ -1651,13 +1741,14 @@
                                 var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && m.Status == TaskStatusEnum.Wait);
                                 if (taskModel != null) 
                                 {
-                                    // 鍐欏叆鐮佸灈宸ヤ綅鐩爣宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱
-                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");     // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                    // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");     
 
+                                    // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
                                     var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue);
                                     if (retVal.IsSucceed)
                                     {
-                                        // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                        // 鍐欏叆鐮佸灈浜や簰-缁勬墭鍥炲娴佺▼瀛�
                                         retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
 
                                         // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
@@ -1707,8 +1798,10 @@
                                 var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && m.Status == TaskStatusEnum.Wait);
                                 if (taskModel != null)
                                 {
-                                    // 鍐欏叆鐮佸灈宸ヤ綅鐩爣宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱
-                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");     // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                    // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");     
+
+                                    // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
                                     var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue);
                                     if (retVal.IsSucceed)
                                     {

--
Gitblit v1.8.0