From 350507ac0a6ccfa0463612996731f4165fe55601 Mon Sep 17 00:00:00 2001
From: wxw <Administrator@DESKTOP-5BIMHQ3>
Date: 星期三, 25 九月 2024 09:18:22 +0800
Subject: [PATCH] 工作台增加滚筒反转开关

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |  269 +++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 237 insertions(+), 32 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index 2a7f4c4..74c5438 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.Entity;
 using WCS.Application.Util;
 
 namespace WCS.Application;
@@ -26,16 +27,16 @@
             switch (mod.Type)
             {
                 case PLCTypeEnum.StackingMachine:
-                    StackingMachine(mod);
+                    StackingMachine(mod);                           // 璺烘満
                     break;
                 case PLCTypeEnum.ConveyorLine:
-                    ConveyorLine(mod);
+                    ConveyorLine(mod);                              // 鎵樼洏杈撻�佺嚎
                     break;
                 case PLCTypeEnum.AGV:
-                    AGV(mod);
+                    AGV(mod);                                       // AGV璋冨害
                     break;
-                case PLCTypeEnum.PalletMachine:
-                    PalletMachine(mod);
+                case PLCTypeEnum.RobotPalletizer:
+                    RobotPalletizer(mod);                             // 鐮佸灈鏈哄櫒浜�
                     break;
                 case PLCTypeEnum.StackingRobot:
                     PalletMachine(mod);
@@ -223,13 +224,13 @@
                             if (startStationRes.IsSucceed)
                             {
                                 // 鏍规嵁宸ヤ綅鍙疯幏鍙栧搴旂殑杈撻�佺嚎IP
-                                var plcConveyorConn = PLCCommon.GetPlcIp(startStationVal.ToString());
+                                PLCUtil plcConveyorConn = PLCCommon.GetPlcIp(startStationVal.ToString());
                                 if (plcConveyorConn.Connected)
                                 {
                                     // 鍚戝彇璐у伐浣嶅啓鍏ユ祦绋嬪瓧640  鍙栬揣宸插畬鎴�
                                     var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal.ToString()
                                                             && m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == false);
-                                    var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640");
+
                                     var modcTaskMonitor = new WcsTaskMonitor()
                                     {
                                         TaskNo = modTask.TaskNo,
@@ -240,9 +241,21 @@
                                         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();
                                         //涓嬪彂浠诲姟鏃ュ織
@@ -250,43 +263,56 @@
                                         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;                  // 鏀捐揣宸ヤ綅
-
-                            // 鎻掑叆浜や簰鏃ュ織
-                            _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
                             //涓嬪彂浠诲姟鏃ュ織
                             HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
                         }
@@ -378,8 +404,7 @@
                                         }
                                     }
                                     // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
-                                    var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == modTask.TaskNo);
-                                    modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();
+                                    modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();
 
                                     // 鎻掑叆浜や簰鏃ュ織
                                     _db.Insertable(modTaskMonitor).ExecuteCommand();
@@ -453,6 +478,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;
                                                 }
                                             }
@@ -817,7 +850,6 @@
             }
         }
     }
-
 
     /// <summary>
     /// 杈撻�佺嚎涓氬姟澶勭悊
@@ -1221,9 +1253,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();
@@ -1247,27 +1282,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
                 }
@@ -1293,7 +1362,143 @@
     /// <param name="modDevice"></param>
     private static void PalletMachine(WcsDeviceDto modDevice)
     {
+        var plcConn = modDevice.PLCUtil;
+        switch (modDevice.Value.ToString()) 
+        {
+            case "220":
+                // 娉ㄩ噴1
+                {
+                    
+                }
+                break;
+            case "230":
+                // 娉ㄩ噴2
+                { 
+                
+                }
+                break;
+            case "240":
+                {
 
+                }
+                break;
+            default: break;
+        }
+    }
+
+    /// <summary>
+    /// 鐮佸灈鏈哄櫒浜轰笟鍔″鐞�
+    /// </summary>
+    /// <param name="modDevice"></param>
+    private static void RobotPalletizer(WcsDeviceDto modDevice) 
+    {
+        var plcConn = modDevice.PLCUtil;
+        switch (modDevice.Value.ToString())
+        {
+            case "1":
+                // 涓绘壂鐢宠鍒嗛亾 wcs鍐欏叆2
+                {
+
+                    var taskModel = "";
+                    // 鍒ゆ柇鏄惁婕旂ず妯″紡
+                    if (PLCTaskAction.boDemo)
+                    {
+                        // 婕旂ず妯″紡
+                        taskModel = "1";
+
+                        // 鐩存帴
+                    }
+                    else 
+                    {
+                        // 閫氶亾鍙�
+                        var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�");
+
+                        // 璇诲彇plc绠辩爜
+                        var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辩爜");
+                        var (res, boxNo) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modBoxNo.PlcPos);
+                        if (string.IsNullOrWhiteSpace(boxNo.ToString()))
+                        {
+                            // 绠辩爜涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙�
+                            var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
+                            if (ret.IsSucceed)
+                            {
+                                // 鍐欏叆娴佺▼鎺у埗瀛� 2
+                                var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
+                                if (retVal.IsSucceed)
+                                {
+                                    Log.Error("绠辩爜涓簄ull杩涜鍓旈櫎");
+                                    break;
+                                }
+                            }
+                        }
+                        else 
+                        {
+                            // 鏍规嵁绠辩爜鑾峰彇绠卞唴淇℃伅
+                            string boxNoVal = boxNo.ToString();
+                            var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNoVal && string.IsNullOrEmpty(w.PalletNo));
+                            if (boxInfo == null)
+                            {
+                                // 绠变俊鎭负null鍐欏叆鍓旈櫎閫氶亾鍙�
+                                var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
+                                if (ret.IsSucceed)
+                                {
+                                    // 鍐欏叆娴佺▼鎺у埗瀛� 2
+                                    var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
+                                    if (retVal.IsSucceed)
+                                    {
+                                        Log.Error("绠辩爜涓簄ull鎴栧凡缁戝畾鎵樼洏锛岃繘琛屽墧闄ゃ��");
+                                        break;
+                                    }
+                                }
+                            }
+                            // 鏍规嵁绠卞唴鍝佺鍙疯幏鍙栫爜韬茬粦瀹氬伐浣嶅強瀵瑰簲鐨勫垎閬撳彿
+                            var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo);
+                            if (checkTaskInfo == null)
+                            {
+                                // 缁戝畾淇℃伅涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙�
+                                var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
+                                if (ret.IsSucceed)
+                                {
+                                    // 鍐欏叆娴佺▼鎺у埗瀛� 2
+                                    var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
+                                    if (retVal.IsSucceed)
+                                    {
+                                        Log.Error("绠辩爜鏈粦瀹氬垎鎷d换鍔★紝杩涜鍓旈櫎銆�");
+                                        break;
+                                    }
+                                }
+                            }
+                            else
+                            {
+                                // 涓巔lc浜や簰鍐欏叆鍒嗛亾鍙峰拰娴佺▼鎺у埗瀛�
+                                var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.RoboatNo);
+                                if (ret.IsSucceed)
+                                {
+                                    // 鍐欏叆娴佺▼鎺у埗瀛� 2
+                                    var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
+                                    if (retVal.IsSucceed)
+                                    {
+                                        break;
+                                    }
+                                }
+                            }                            
+                        }
+                    }
+                }
+                break;
+            case "230":
+                // 娉ㄩ噴2
+                {
+
+                }
+                break;
+            case "240":
+                {
+
+                }
+                break;
+            default: break;
+        }
     }
 
     /// <summary>

--
Gitblit v1.8.0