From 50f6cb0f96f04f505b9493f7621d8e49ad5add9d Mon Sep 17 00:00:00 2001
From: chengsc <Demo@DESKTOP-CPA90BF>
Date: 星期一, 04 十一月 2024 08:13:32 +0800
Subject: [PATCH] Merge branch 'master' of http://47.95.120.53:8083/r/WCSNet6

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |  327 +++++++++++++++++++++++++++--------------------------
 1 files changed, 167 insertions(+), 160 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index c34b5ad..01ea309 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -20,6 +20,7 @@
 namespace WCS.Application;
 public static class PLCService
 {
+    private static readonly object OLock = new object();
 
     private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
 
@@ -1705,7 +1706,7 @@
                                     }
                                 }
                                 // 鏍规嵁绠卞唴鍝佺鍙疯幏鍙栫爜韬茬粦瀹氬伐浣嶅強瀵瑰簲鐨勫垎閬撳彿
-                                var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo);
+                                var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo && w.Status == "1");
                                 if (checkTaskInfo == null)
                                 {
                                     // 缁戝畾淇℃伅涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙�
@@ -1868,181 +1869,184 @@
                 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 && m.PlcId != modDevice.PlcId);
-                        var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "鐩殑宸ヤ綅" && m.IsDelete == false);
-                        if (checkTaskMedel == null)
+                        lock (OLock) 
                         {
-                            Log.Error(string.Format("缁勬墭澶辫触鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栨墭鐩樺彿澶辫触!", modDevice.StationNum));
-
-                            // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃
-                            var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
-                            if (retVal.IsSucceed) 
+                            // 鏍规嵁宸ヤ綅鍙凤紝鑾峰彇鎵樼洏鍙�
+                            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 && m.PlcId != modDevice.PlcId);
+                            var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "鐩殑宸ヤ綅" && m.IsDelete == false);
+                            if (checkTaskMedel == null)
                             {
-                                // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
-                                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 || m.Status == TaskStatusEnum.Doing));
-                                if (taskModel != null) 
-                                {
-                                    // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
-                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");
-
-                                    var listResult = new List<Result>();
-
-                                    // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
-                                    listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue));    // 鐩爣宸ヤ綅
-                                    var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false);
-                                    listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
-                                    var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false);
-                                    var taskTypeStr = (int)taskModel.TaskType;
-                                    listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
-
-                                    if (listResult.All(s => s.IsSucceed))
-                                    {
-                                        // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
-                                        var retVal1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
-                                        if (retVal1.IsSucceed)
-                                        {
-                                            // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
-                                            taskModel.Status = TaskStatusEnum.Doing;
-                                            _db.Updateable(taskModel).ExecuteCommand();
-
-                                            // 鎻掑叆浠诲姟鏄庣粏 
-                                            var modInsertTaskMonitor = new WcsTaskMonitor()
-                                            {
-                                                TaskNo = TaskNo,
-                                                PlcId = modDevice.Id,
-                                                PlcName = modDevice.Text,
-                                                InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�",
-                                                PalletNo = palletNo,
-                                                Status = TaskStatusEnum.Complete,
-                                                StartLocat = modDevice.StationNum,
-                                                EndLocat = strMsg,
-                                            };
-                                            // 鎻掑叆浜や簰鏃ュ織
-                                            _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
-                                            // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
-                                            HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
-                                        }
-                                    }
-
-                                    //// 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
-                                    //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));
+                                Log.Error(string.Format("缁勬墭澶辫触鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栨墭鐩樺彿澶辫触!", modDevice.StationNum));
 
                                 // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃
                                 var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
-                                if (retVal.IsSucceed)
+                                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 palletNo = checkTaskMedel.PalletNo;
+
+                            // 鏄惁婕旂ず妯″紡
+                            if (PLCTaskAction.boDemo)
                             {
-                                // 缁勬墭鎴愬姛鍚庡皢淇℃伅瀛樺埌log琛�
-                                string sqlStr2 = $"delete from WCSBoxInfoLog where  IsDelete=0 and PalletNo='{palletNo}'";
-                                _db.Ado.ExecuteCommand(sqlStr2);
-                            }
-                            // 鍚慦MS鐢宠宸烽亾
-                            var http = new HttpService();
-                            string TaskNo = "", EndLocate = "";
-                            string strMsg = http.BindRequestRoadWay(checkTaskMedel.OrderNo,palletNo, checkTaskMedel.BoxCount.ToDecimal(),"0", checkTaskMedel.SkuNo, checkTaskMedel.LotNo, "","", boxInfoList, 
-                                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)
+                                // 鐩存帴绠眞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"))
                                 {
-                                    // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
-                                    string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");
+                                    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 || m.Status == TaskStatusEnum.Doing));
+                                    if (taskModel != null) 
+                                    {
+                                        // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅
+                                        string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");
 
-                                    var listResult = new List<Result>();
-                                    // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
-                                    listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue));    // 鐩爣宸ヤ綅
-                                    var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false);
-                                    listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
-                                    var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false);
-                                    var taskTypeStr = (int)taskModel.TaskType;
-                                    listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
+                                        var listResult = new List<Result>();
 
-                                    if (listResult.All(s => s.IsSucceed))
+                                        // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
+                                        listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue));    // 鐩爣宸ヤ綅
+                                        var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false);
+                                        listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
+                                        var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false);
+                                        var taskTypeStr = (int)taskModel.TaskType;
+                                        listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
+
+                                        if (listResult.All(s => s.IsSucceed))
+                                        {
+                                            // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                            var retVal1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
+                                            if (retVal1.IsSucceed)
+                                            {
+                                                // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
+                                                taskModel.Status = TaskStatusEnum.Doing;
+                                                _db.Updateable(taskModel).ExecuteCommand();
+
+                                                // 鎻掑叆浠诲姟鏄庣粏 
+                                                var modInsertTaskMonitor = new WcsTaskMonitor()
+                                                {
+                                                    TaskNo = TaskNo,
+                                                    PlcId = modDevice.Id,
+                                                    PlcName = modDevice.Text,
+                                                    InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�",
+                                                    PalletNo = palletNo,
+                                                    Status = TaskStatusEnum.Complete,
+                                                    StartLocat = modDevice.StationNum,
+                                                    EndLocat = strMsg,
+                                                };
+                                                // 鎻掑叆浜や簰鏃ュ織
+                                                _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
+                                                // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
+                                                HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                                            }
+                                        }
+
+                                        //// 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
+                                        //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 = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToList();
+                                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)
                                     {
                                         // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
-                                        var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
-                                        if (retVal.IsSucceed) 
-                                        {
-                                            // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
-                                            taskModel.Status = TaskStatusEnum.Doing;
-                                            _db.Updateable(taskModel).ExecuteCommand();
+                                        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)
+                                {
+                                    // 缁勬墭鎴愬姛鍚庡皢淇℃伅瀛樺埌log琛�
+                                    string sqlStr2 = $"delete from WCSBoxInfoLog where  IsDelete=0 and PalletNo='{palletNo}'";
+                                    _db.Ado.ExecuteCommand(sqlStr2);
+                                }
+                                // 鍚慦MS鐢宠宸烽亾
+                                var http = new HttpService();
+                                string TaskNo = "", EndLocate = "";
+                                string strMsg = http.BindRequestRoadWay(checkTaskMedel.OrderNo,palletNo, checkTaskMedel.BoxCount.ToDecimal(),"0", checkTaskMedel.SkuNo, checkTaskMedel.LotNo, "","", boxInfoList, 
+                                    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 modInsertTaskMonitor = new WcsTaskMonitor()
+                                        var listResult = new List<Result>();
+                                        // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅}
+                                        listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue));    // 鐩爣宸ヤ綅
+                                        var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false);
+                                        listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
+                                        var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false);
+                                        var taskTypeStr = (int)taskModel.TaskType;
+                                        listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
+
+                                        if (listResult.All(s => s.IsSucceed))
+                                        {
+                                            // 鍐欏叆缁勬墭鍥炲娴佺▼瀛�
+                                            var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
+                                            if (retVal.IsSucceed) 
                                             {
-                                                TaskNo = TaskNo,
-                                                PlcId = modDevice.Id,
-                                                PlcName = modDevice.Text,
-                                                InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�",
-                                                PalletNo = palletNo,
-                                                Status = TaskStatusEnum.Complete,
-                                                StartLocat = modDevice.StationNum,
-                                                EndLocat = strMsg,
-                                            };
-                                            // 鎻掑叆浜や簰鏃ュ織
-                                            _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
-                                            // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
-                                            HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                                                // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц
+                                                taskModel.Status = TaskStatusEnum.Doing;
+                                                _db.Updateable(taskModel).ExecuteCommand();
+
+                                                // 鎻掑叆浠诲姟鏄庣粏 
+                                                var modInsertTaskMonitor = new WcsTaskMonitor()
+                                                {
+                                                    TaskNo = TaskNo,
+                                                    PlcId = modDevice.Id,
+                                                    PlcName = modDevice.Text,
+                                                    InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�",
+                                                    PalletNo = palletNo,
+                                                    Status = TaskStatusEnum.Complete,
+                                                    StartLocat = modDevice.StationNum,
+                                                    EndLocat = strMsg,
+                                                };
+                                                // 鎻掑叆浜や簰鏃ュ織
+                                                _db.Insertable(modInsertTaskMonitor).ExecuteCommand();
+                                                // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
+                                                HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+                                            }
                                         }
                                     }
                                 }
@@ -2114,11 +2118,11 @@
     }
 
     /// <summary>
-    /// 鑷姩缁撴壒
+    /// 鑷姩缁撴壒 骞� 瑙g粦鍒嗛亾
     /// </summary>
     /// <param name="lotNo">鎵规鍙�</param>
     /// <param name="plcConn">Plc杩炴帴</param>
-    /// <param name="status">鏄惁瑙g粦鍒嗛亾 0锛氳В缁�  1锛氱粦瀹�</param>
+    /// <param name="status">鏄惁瑙g粦鍒嗛亾 0锛氳В缁�  1锛氱粦瀹�</param> 
     private static void AutoEndLot(string lotNo,PLCUtil plcConn,string status) 
     {
         try
@@ -2135,7 +2139,10 @@
             foreach (var item in checkTaskList)
             {
                 #region#缁橮LC鍐欏叆缁撴壒鎵规鍙�
+                // 鍐欏叆缁撴壒淇″彿
                 var ret = plcConn.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "1");
+                // 鍒嗛亾瑙g粦锛屾姄绠卞搧绉嶅啓鍏�0
+                var ret1 = plcConn.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PlcPos, "0");
                 if (ret.IsSucceed)
                 {
                     //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟    liudl 鏈�鍚庝竴鎵樼洏鐢宠瀹屽叆搴撴墠鍙竻绌�
@@ -2146,7 +2153,7 @@
                     //item.SkuName = "";
                     //item.BoxType = "";
                     //item.Qty = 0;
-                    //item.PZNo = "";
+                    item.PZNo = "";
                     item.Status = status;      // 缁戝畾鍒嗛亾 0锛氳В缁�  1锛氱粦瀹� 
 
                     //鏇存柊鍒嗘嫞浠诲姟

--
Gitblit v1.8.0