From 2225959bc5c3588407e90a6285ab2c32b3481d90 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周四, 05 12月 2024 12:59:12 +0800
Subject: [PATCH] 222

---
 CC/iWareCC_ASRS/ThreadService/02_BZ39工位(补板后工位)/Outbound/4、DataProcess_RobotBuffer_ForceOutbound.cs |  137 +++++++++++++++++++++++----------------------
 1 files changed, 70 insertions(+), 67 deletions(-)

diff --git "a/CC/iWareCC_ASRS/ThreadService/02_BZ39\345\267\245\344\275\215\357\274\210\350\241\245\346\235\277\345\220\216\345\267\245\344\275\215\357\274\211/Outbound/4\343\200\201DataProcess_RobotBuffer_ForceOutbound.cs" "b/CC/iWareCC_ASRS/ThreadService/02_BZ39\345\267\245\344\275\215\357\274\210\350\241\245\346\235\277\345\220\216\345\267\245\344\275\215\357\274\211/Outbound/4\343\200\201DataProcess_RobotBuffer_ForceOutbound.cs"
index 7d144ce..f674a99 100644
--- "a/CC/iWareCC_ASRS/ThreadService/02_BZ39\345\267\245\344\275\215\357\274\210\350\241\245\346\235\277\345\220\216\345\267\245\344\275\215\357\274\211/Outbound/4\343\200\201DataProcess_RobotBuffer_ForceOutbound.cs"
+++ "b/CC/iWareCC_ASRS/ThreadService/02_BZ39\345\267\245\344\275\215\357\274\210\350\241\245\346\235\277\345\220\216\345\267\245\344\275\215\357\274\211/Outbound/4\343\200\201DataProcess_RobotBuffer_ForceOutbound.cs"
@@ -13,90 +13,93 @@
 namespace iWareCC.ThreadService
 {
     /// <summary>
-    /// 鏈哄櫒浜虹紦瀛樺矝 浜哄伐寮哄埗鍑哄簱 澶勭悊
+    /// 鏈哄櫒浜虹紦瀛樺矝 浜哄伐寮哄埗寰呭嚭搴� 澶勭悊
     /// </summary>
     public static class DataProcess_RobotBuffer_ForceOutbound
     {
-        public static  bool Handler(string packageCode, ref string alertMsg)
+        public static async void Handler()
         {
-            alertMsg = "";
-            LogType logType = LogType.DataProcess_RobotBuffer_AutoQiTaoOutbound;
-
-            try
+            var alertMsg = "";
+            LogType logType = LogType.DataProcess_RobotBuffer_ForceOutbound;
+            while (true)
             {
-
-                var rgvLocation = StationLocationEnum.BZ39.ToString();
-                var obj = FormCC.stationView.R_StationForReadCommList.Where(x => x.StationCode == rgvLocation.ToString()).FirstOrDefault();
-                if (obj.R_ForceOutboundMode == false)
-                {
-                    alertMsg = "PLC涓嶆槸寮哄埗鍑哄簱妯″紡";
-                    return false;
-                }
-                using (WmsDBModel wmsDB = new WmsDBModel())
-                {
-                    List<wms_stock_quan> qunList = wmsDB.wms_stock_quan.Where(x => x.StockStatus == (int)StockStatusEnum.鍦ㄥ簱
-                        && x.PackageCode == packageCode
-                    ).ToList();
-
-                    foreach (var x in qunList)
+                Thread.Sleep(2000);//浼戠湢2绉掞紝灏嗕紤鐪犲啓鍒板墠闈紝鏄负浜嗕笅闈㈢殑continue鏂规硶鎵ц鍚庝笉鏄剧ず閿欒淇℃伅鐨勬彁绀猴紒锛侊紒銆怑ditBy shaocx,2022-05-24銆�
+                SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_ForceOutbound = string.Empty;
+                try
+                {//SystemValue.isAllowRuning_DataProcess_RobotBuffer_AutoQiTaoOutbound && 
+                    if (SystemValue.isStartedModel)
                     {
-                        x.StockStatus = (int)StockStatusEnum.浜哄伐寮哄埗寰呭嚭搴�;
 
-                        //鐢熸垚鍑哄簱浠诲姟
-                        //璁板綍浠诲姟
-                        var _id = Yitter.IdGenerator.YitIdHelper.NextId();
-                        var plcTaskNo = BusinessHelper.CreatePlcTaskIdForSrmTask();
-                        var new_task = new wms_rbline_task()
+                        var rgvLocation = StationLocationEnum.BZ39.ToString();
+                        var obj = FormCC.stationView.R_StationForReadCommList.Where(x => x.StationCode == rgvLocation.ToString()).FirstOrDefault();
+                        if (obj.R_ForceOutboundMode == false)
                         {
-                            Id = _id,
-                            TaskNo = plcTaskNo,
+                            alertMsg = "PLC涓嶆槸寮哄埗鍑哄簱妯″紡";
+                            continue;
+                        }
+                        using (WmsDBModel wmsDB = new WmsDBModel())
+                        {
+                            List<wms_stock_quan> qunList = wmsDB.wms_stock_quan.Where(x => x.StockStatus == (int)StockStatusEnum.浜哄伐寮哄埗寰呭嚭搴�
+                            ).OrderBy(x => x.PackageCode).ToList();
 
-                            UPI = x.Upi,
-                            Length = x.Length,
-                            Width = x.Width,
-                            Thk = x.Thk,
-                           
-                            PlanNo = x.PlanNo,
-                            OrderId = x.OrderId,
-                            PackageCode = x.PackageCode,
-                            PlaceCode = x.PlaceCode,
-                            RbTaskType = (int)RbTaskTypeEnum.寮哄埗鍑哄簱浠诲姟,
-                            RbTaskTypeEnumName = RbTaskTypeEnum.寮哄埗鍑哄簱浠诲姟.ToString(),
-                            TaskStatus = (int)TaskStatusEnum.鏂板缓,
-                            TaskStatusName = TaskStatusEnum.鏂板缓.ToString(),
-                            TaskMsg = "浜哄伐寮哄埗寰呭嚭搴�",
+                            foreach (var x in qunList)
+                            {
+                                x.StockStatus = (int)StockStatusEnum.浜哄伐寮哄埗浠诲姟宸插垱寤�;
+                                x.StockStatusName = StockStatusEnum.浜哄伐寮哄埗浠诲姟宸插垱寤�.ToString();
+
+                                //鐢熸垚鍑哄簱浠诲姟
+                                //璁板綍浠诲姟
+                                var _id = Yitter.IdGenerator.YitIdHelper.NextId();
+                                var plcTaskNo = BusinessHelper.CreatePlcTaskIdForSrmTask();
+                                var new_task = new wms_rbline_task()
+                                {
+                                    Id = _id,
+                                    TaskNo = plcTaskNo,
+
+                                    UPI = x.Upi,
+                                    Length = x.Length,
+                                    Width = x.Width,
+                                    Thk = x.Thk,
+
+                                    PlanNo = x.PlanNo,
+                                    OrderId = x.OrderId,
+                                    PackageCode = x.PackageCode,
+                                    PlaceCode = x.PlaceCode,
+                                    RbTaskType = (int)RbTaskTypeEnum.寮哄埗鍑哄簱浠诲姟,
+                                    RbTaskTypeEnumName = RbTaskTypeEnum.寮哄埗鍑哄簱浠诲姟.ToString(),
+                                    TaskStatus = (int)TaskStatusEnum.鏂板缓,
+                                    TaskStatusName = TaskStatusEnum.鏂板缓.ToString(),
+                                    TaskMsg = "浜哄伐寮哄埗寰呭嚭搴�",
 
 
-                            CreateTime = DateTime.Now,
-                            CreateUserName = "CC",
-                            UpdateTime = DateTime.Now,
-                            UpdateUserName = "CC",
-                        };
+                                    CreateTime = DateTime.Now,
+                                    CreateUserName = "CC",
+                                    UpdateTime = DateTime.Now,
+                                    UpdateUserName = "CC",
+                                };
 
-                        wmsDB.wms_rbline_task.Add(new_task);
+                                wmsDB.wms_rbline_task.Add(new_task);
 
-                        var place = StationHandler.GetPlaceByPlaceCode(x.PlaceCode, wmsDB);
-                        place.PlaceStatus = (int)PlaceStatusEnum.閿佸畾;
+                                var place = StationHandler.GetPlaceByPlaceCode(x.PlaceCode, wmsDB);
+                                place.PlaceStatus = (int)PlaceStatusEnum.閿佸畾;
 
-                        Thread.Sleep(100);
+                                Thread.Sleep(100);
+                            }
+
+
+
+                            wmsDB.SaveChanges();
+                        }
+
                     }
-
-
-
-                    wmsDB.SaveChanges();
                 }
-
-                return true;
-
-            }
-            catch (Exception ex)
-            {
-                alertMsg = " 鍑虹幇寮傚父:" + ex.Message;
-                SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_AutoQiTaoOutbound += " 鍑虹幇寮傚父:" + ex.Message + SysGloble.SPLIT_STR;
-                Log4NetHelper.WriteErrorLog(logType, " 鍑虹幇寮傚父锛�" + ex.Message, ex);
-
-                return false;
+                catch (Exception ex)
+                {
+                    SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_ForceOutbound += " 鍑虹幇寮傚父:" + ex.Message + SysGloble.SPLIT_STR;
+                    Log4NetHelper.WriteErrorLog(logType, " 鍑虹幇寮傚父锛�" + ex.Message, ex);
+                }
             }
         }
+
     }
 }

--
Gitblit v1.9.3