From 6f656da3cee02475084f412e218d58936f5cba67 Mon Sep 17 00:00:00 2001
From: IPC-610 <IPC-610@DESKTOP-6LEOOS3>
Date: 星期三, 25 九月 2024 18:52:44 +0800
Subject: [PATCH] 插码程序编写

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |  377 +++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 303 insertions(+), 74 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index 74c5438..a9e5568 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -1,4 +1,5 @@
 锘�
+using Dm.filter;
 using DocumentFormat.OpenXml.Bibliography;
 using Elastic.Clients.Elasticsearch.Tasks;
 using Furion.Logging;
@@ -35,8 +36,8 @@
                 case PLCTypeEnum.AGV:
                     AGV(mod);                                       // AGV璋冨害
                     break;
-                case PLCTypeEnum.RobotPalletizer:
-                    RobotPalletizer(mod);                             // 鐮佸灈鏈哄櫒浜�
+                case PLCTypeEnum.BoxConveyorLine:
+                    BoxConveyorLine(mod);                             // 鐮佸灈鏈哄櫒浜�
                     break;
                 case PLCTypeEnum.StackingRobot:
                     PalletMachine(mod);
@@ -1387,58 +1388,51 @@
     }
 
     /// <summary>
-    /// 鐮佸灈鏈哄櫒浜轰笟鍔″鐞�
+    /// 浠剁杈撻�佸拰鐮佸灈鏈哄櫒浜轰笟鍔″鐞�  閰嶇疆鐨勬槸浠剁杈撻��
     /// </summary>
     /// <param name="modDevice"></param>
-    private static void RobotPalletizer(WcsDeviceDto modDevice) 
+    private static async void BoxConveyorLine(WcsDeviceDto modDevice) 
     {
         var plcConn = modDevice.PLCUtil;
-        switch (modDevice.Value.ToString())
+
+        if (modDevice.DbNumber == "DB101")
         {
-            case "1":
-                // 涓绘壂鐢宠鍒嗛亾 wcs鍐欏叆2
-                {
-
-                    var taskModel = "";
-                    // 鍒ゆ柇鏄惁婕旂ず妯″紡
-                    if (PLCTaskAction.boDemo)
+            // 涓绘壂浜や簰娴佺▼
+            switch (modDevice.Value.ToString())
+            {
+                case "1":
+                    // 涓绘壂鐢宠鍒嗛亾 wcs鍐欏叆2
                     {
-                        // 婕旂ず妯″紡
-                        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()))
+                        // 鍒ゆ柇鏄惁婕旂ず妯″紡 true锛氭紨绀烘ā寮�   false:鐢熶骇妯″紡
+                        if (PLCTaskAction.boDemo)   
                         {
-                            // 绠辩爜涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙�
-                            var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
+                            // 閫氶亾鍙�
+                            var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�");
+
+                            // 婕旂ず妯″紡鐩存帴鍐欏叆1鍒嗛亾
+                            var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "1");
                             if (ret.IsSucceed)
                             {
                                 // 鍐欏叆娴佺▼鎺у埗瀛� 2
                                 var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
                                 if (retVal.IsSucceed)
                                 {
-                                    Log.Error("绠辩爜涓簄ull杩涜鍓旈櫎");
+                                    Log.Error("婕旂ず妯″紡鍐欏叆鍒嗛亾鍙峰け璐�!");
                                     break;
                                 }
                             }
                         }
-                        else 
+                        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)
+                            // 閫氶亾鍙�
+                            var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�");
+
+                            // 璇诲彇plc绠辩爜
+                            var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辩爜");
+                            var (res, boxNo) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos);
+                            if (string.IsNullOrWhiteSpace(boxNo.ToString()))
                             {
-                                // 绠变俊鎭负null鍐欏叆鍓旈櫎閫氶亾鍙�
+                                // 绠辩爜涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙�
                                 var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
                                 if (ret.IsSucceed)
                                 {
@@ -1446,59 +1440,294 @@
                                     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换鍔★紝杩涜鍓旈櫎銆�");
+                                        Log.Error("绠辩爜涓簄ull杩涜鍓旈櫎");
                                         break;
                                     }
                                 }
                             }
                             else
                             {
-                                // 涓巔lc浜や簰鍐欏叆鍒嗛亾鍙峰拰娴佺▼鎺у埗瀛�
-                                var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.RoboatNo);
-                                if (ret.IsSucceed)
+                                // 鏍规嵁绠辩爜鑾峰彇绠卞唴淇℃伅
+                                string boxNoVal = boxNo.ToString();
+                                var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNoVal && string.IsNullOrEmpty(w.PalletNo));
+                                if (boxInfo == null)
                                 {
-                                    // 鍐欏叆娴佺▼鎺у埗瀛� 2
-                                    var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
-                                    if (retVal.IsSucceed)
+                                    // 绠变俊鎭负null鍐欏叆鍓旈櫎閫氶亾鍙�
+                                    var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
+                                    if (ret.IsSucceed)
                                     {
-                                        break;
+                                        // 鍐欏叆娴佺▼鎺у埗瀛� 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;
+                default: break;
+            }
+        } 
+        else  
+        {
+            // 鎻掔爜浜や簰
+            switch (modDevice.Value.ToString()) 
+            {
+                case "1":
+                    // 鎵樼洏鏉$爜鍙
+                    {
+                        // 鑾峰彇鎵樼洏鏉$爜閰嶇疆
+                        var modPalletNo = modDevice.listStation.FirstOrDefault(m => m.Text == "鎵樼洏鏉$爜");
+                        // 璇诲彇PLC鎵樼洏鏉$爜鍙�
+                        var (res, palletVal) = plcConn.GetPlcDBValue(modPalletNo.PosType, modDevice.DbNumber, modPalletNo.PlcPos);
+                        string palletNo = palletVal.ToString();
+                        if (string.IsNullOrEmpty(palletNo)) 
+                        {
+                            Log.Error(string.Format("{0}锛岃鍙栫殑鎵樼洏鍙蜂负null", modDevice.Text));
+                            break;
+                        }
 
-                }
-                break;
-            case "240":
-                {
+                        // 鏍规嵁宸ヤ綅鍙峰皢鎵樼洏鍙蜂繚瀛樺湪鍒嗛亾琛�
+                        var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
+                        if (checkTaskMedel == null) 
+                        {
+                            Log.Error(string.Format("鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栧垎閬撳け璐�!", modDevice.StationNum));
+                            break;
+                        }
+                        checkTaskMedel.PalletNo = palletNo;
+                        var rowCount = _db.Updateable(checkTaskMedel).ExecuteCommand();
+                        if (rowCount > 0 ) 
+                        {
+                            // plc鍐欏叆璇诲彇鎴愬姛琛ㄧず 2
+                            var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
+                            if (retVal.IsSucceed) 
+                            {
+                                // liudl  姝ゅ闇�娣诲姞
+                                // 閫氱煡鍒嗘嫞鐮佸灈椤垫洿鏂�
+                            }
+                        }
+                    }
+                    break;
+                case "20":
+                    // 鐢宠鎻掔爜
+                    {
+                        // 鑾峰彇鎵樼洏鏉$爜閰嶇疆
+                        var modAddCode = modDevice.listStation.FirstOrDefault(m => m.Text == "鎻掔爜缁撴灉");
+                        // 鍒ゆ柇鏄惁婕旂ず妯″紡 true锛氭紨绀烘ā寮�   false:鐢熶骇妯″紡
+                        if (PLCTaskAction.boDemo)
+                        {
+                            // 婕旂ず妯″紡鐩存帴鍐欏叆鎻掔爜缁撴灉 1锛氭垚鍔�
+                            var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1");
+                            break;
+                        }
+                        else 
+                        {
+                            // 鑾峰彇绠辨潯鐮�
+                            // 鑾峰彇绠辨潯鐮侀厤缃�
+                            var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辨潯鐮�");
+                            var (res, boxVal) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos);
+                            string boxNo = boxVal.ToString();
+                            if (string.IsNullOrEmpty(boxNo)) 
+                            {
+                                Log.Error(string.Format("鐮佸灈宸ヤ綅{0}锛岀鐮佷负null鎻掔爜澶辫触!璇蜂汉宸ュ己鍒剁粨鎵广��"), modDevice.StationNum);
+                                // 鍐欏叆鎻掑叆缁撴灉 2锛氭彃鐮佸け璐�
+                                var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
+                                break;
+                            }
+                            // 楠岃瘉绠辩爜琛ㄦ槸鍚﹀瓨鍦ㄦ绠辩爜
+                            var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNo);
+                            if (boxInfo == null) 
+                            {
+                                Log.Error(string.Format("鐮佸灈宸ヤ綅{0}锛岀鐮亄1}涓嶅瓨鍦�!璇蜂汉宸ュ己鍒剁粨鎵广��"), modDevice.StationNum,boxNo);
+                                // 鍐欏叆鎻掑叆缁撴灉 2锛氭彃鐮佸け璐�
+                                var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
+                                break;
+                            }
+                            // 鑾峰彇褰撳墠鍒嗛亾鎵樼洏鍙�
+                            var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
+                            if (checkTaskMedel == null)
+                            {
+                                Log.Error(string.Format("鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栧垎閬撳け璐�!", modDevice.StationNum));
+                                break;
+                            }
+                            string palletNo = checkTaskMedel.PalletNo;
+                            if (string.IsNullOrEmpty(palletNo)) 
+                            {
+                                Log.Error(string.Format("鑾峰彇鐮佸灈宸ヤ綅{0}涓婄殑鎵樼洏鍙峰け璐ワ紒",modDevice.StationNum));
+                                break;
+                            }
+                            // 淇敼鎻掔爜琛�
+                            boxInfo.PalletNo = palletNo;
+                            boxInfo.UpdateTime = DateTime.Now;
+                            var rowCount = _db.Updateable(boxInfo).ExecuteCommand();
+                            if (rowCount > 0)
+                            {
+                                // 鎻掔爜鎴愬姛
+                                var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1");
+                            }
+                            else 
+                            {
+                                // 鎻掔爜澶辫触
+                                Log.Error(string.Format("绠辩爜{0};鐮佸灈宸ヤ綅{1}锛屾彃鐮佸け璐ワ紝璇峰己鍒剁粨鎵�"),boxNo,modDevice.StationNum);
+                                var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
+                            }
+                        }
+                    }
+                    break;
+                case "40":
+                    // 璇锋眰缁勬墭锛岀敵璇峰叆搴�
+                    {
+                        // 鏍规嵁宸ヤ綅鍙凤紝鑾峰彇鎵樼洏鍙�
+                        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);
+                        if (checkTaskMedel == null)
+                        {
+                            Log.Error(string.Format("缁勬墭澶辫触鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栨墭鐩樺彿澶辫触!", modDevice.StationNum));
 
-                }
-                break;
-            default: break;
-        }
+                            // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃
+                            var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
+                            if (retVal.IsSucceed) 
+                            {
+                                // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
+                            }
+                            break;
+                        }
+
+                        // 鐮佸灈宸ヤ綅鎵樼洏鍙�
+                        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"))
+                            {
+                                Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0};鍘熷洜{1}", modDevice.StationNum, strMsg));
+                                break;
+                            }
+                            else 
+                            {
+                                // 鑾峰彇鍏ュ簱浠诲姟淇℃伅
+                                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");     // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+
+                                    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湪鎵ц
+                                        taskModel.Status = TaskStatusEnum.Doing;
+                                        _db.Updateable(taskModel).ExecuteCommand();
+                                    }
+                                }   
+                            }
+                        }
+                        else 
+                        {
+                            // 鏍规嵁鎵樼洏鍙凤紝灏嗙粍鎵樹俊鎭彃鍏oxinfolog琛� 骞跺垹闄oxinfo琛ㄦ暟鎹�
+                            var boxInfoList = await _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToListAsync();
+                            if (boxInfoList.Count <= 0)
+                            {
+                                Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0}锛岀鐮佷俊鎭笉瀛樺湪", modDevice.StationNum));
+
+                                // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃
+                                var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
+                                if (retVal.IsSucceed)
+                                {
+                                    // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                    retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
+                                }
+                                break;
+                            }
+                            string sqlStr = $"insert into WCSBoxInfoLog select * from WCSBoxInfo where IsDelete=0 and PalletNo='{palletNo}'";
+                            int insertCount = _db.Ado.ExecuteCommand(sqlStr);
+                            if (insertCount > 0)
+                            {
+                                string sqlStr2 = $"delete from WCSBoxInfo where  IsDelete=0 and PalletNo='{palletNo}'";
+                                _db.Ado.ExecuteCommand(sqlStr2);
+                            }
+                            // 鍚慦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"))
+                            {
+                                Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0};鍘熷洜{1}", modDevice.StationNum, strMsg));
+                                break;
+                            }
+                            else
+                            {
+                                // 鑾峰彇鍏ュ簱浠诲姟淇℃伅
+                                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");     // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                    var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue);
+                                    if (retVal.IsSucceed)
+                                    {
+                                        // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                        retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
+                                        if (retVal.IsSucceed) 
+                                        {
+                                            // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
+                                            taskModel.Status = TaskStatusEnum.Doing;
+                                            _db.Updateable(taskModel).ExecuteCommand();
+                                        }
+                                    }
+                                }
+                            }
+                        }
+                    }
+                    break;
+                default:break;
+            }
+        }        
     }
 
     /// <summary>

--
Gitblit v1.8.0