From 7fb01e7407706d0362e2fd382d497fd52be0a176 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周六, 23 11月 2024 13:35:34 +0800
Subject: [PATCH] 222

---
 CC/iWareCC_ASRS/ThreadService/02_BZ39工位(补板后工位)/Outbound/1、DataProcess_RobotBuffer_AutoQiTaoOutbound.cs |  112 +++++++++++++++++++++++++------------------------------
 1 files changed, 51 insertions(+), 61 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/1\343\200\201DataProcess_RobotBuffer_AutoQiTaoOutbound.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/1\343\200\201DataProcess_RobotBuffer_AutoQiTaoOutbound.cs"
index a63b897..da14603 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/1\343\200\201DataProcess_RobotBuffer_AutoQiTaoOutbound.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/1\343\200\201DataProcess_RobotBuffer_AutoQiTaoOutbound.cs"
@@ -20,90 +20,80 @@
         public static async void Handler()
         {
             var alertMsg = "";
-            LogType logType = LogType.DataProcess_RobotBuffer_FinishTaskForOutbound;
+            LogType logType = LogType.DataProcess_RobotBuffer_AutoQiTaoOutbound;
             while (true)
             {
                 Thread.Sleep(2000);//浼戠湢2绉掞紝灏嗕紤鐪犲啓鍒板墠闈紝鏄负浜嗕笅闈㈢殑continue鏂规硶鎵ц鍚庝笉鏄剧ず閿欒淇℃伅鐨勬彁绀猴紒锛侊紒銆怑ditBy shaocx,2022-05-24銆�
-                SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound = string.Empty;
+                SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_AutoQiTaoOutbound = string.Empty;
                 try
                 {
-                    if (SystemValue.isAllowRuning_DataProcess_RobotBuffer_FinishTaskForOutbound && SystemValue.isStartedModel)
+                    if (SystemValue.isAllowRuning_DataProcess_RobotBuffer_AutoQiTaoOutbound && SystemValue.isStartedModel)
                     {
-                        var rgvLocation = StationLocationEnum.BZ39.ToString();
-                        var obj = FormCC.stationView.R_StationForReadCommList.Where(x => x.StationCode == rgvLocation.ToString()).FirstOrDefault();
-                        if (obj.R_OutboundFinish)
+
+                        using (WmsDBModel wmsDB = new WmsDBModel())
                         {
-                            var result = obj.R_OutboundNumber;
-                            if (string.IsNullOrEmpty(result))
+                            List<wms_stock_quan> qunList = wmsDB.wms_stock_quan.Where(x => x.StockStatus == (int)StockStatusEnum.鍦ㄥ簱).ToList();
+                            var queryPageckCodeList = qunList.Select(x => x.PackageCode).Distinct().ToList();
+                            List<mes_batchOrderUPI_new> upiList = wmsDB.mes_batchOrderUPI_new.Where(x => queryPageckCodeList.Contains(x.PackageCode)).ToList();
+                            var groups = qunList.GroupBy(x => x.PackageCode);
+                            foreach (var group in groups)
                             {
-                                SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound = $"{rgvLocation.ToString()}- 鍑哄簱搴撲綅鍙锋槸绌虹殑,姝ゆ寰幆缁撴潫";
-                                continue;
-                            }
-
-                            using (WmsDBModel wmsDB = new WmsDBModel())
-                            {
-                                List<wms_stock_quan> qunList = wmsDB.wms_stock_quan.Where(x => x.StockStatus == (int)StockStatusEnum.鍦ㄥ簱).ToList();
-                                var queryPageckCodeList = qunList.Select(x => x.PackageCode).Distinct().ToList();
-                                List<mes_batchOrderUPI_new> upiList = wmsDB.mes_batchOrderUPI_new.Where(x => queryPageckCodeList.Contains(x.PackageCode)).ToList();
-                                var groups = qunList.GroupBy(x => x.PackageCode);
-                                foreach (var group in groups)
+                                var packageCode = group.Key;
+                                var allCount = upiList.Where(x => x.PackageCode == packageCode).Count();
+                                if (allCount == group.ToList().Count())
                                 {
-                                    var packageCode = group.Key;
-                                    var allCount = upiList.Where(x => x.PackageCode == packageCode).Count();
-                                    if (allCount == group.ToList().Count())
+                                    //婊¤冻榻愬锛屽嚭搴�
+                                    group.ToList().ForEach(x =>
                                     {
-                                        //婊¤冻榻愬锛屽嚭搴�
-                                        group.ToList().ForEach(x =>
+                                        x.StockStatus = (int)StockStatusEnum.榻愬寘寰呭嚭搴�;
+
+                                        //鐢熸垚鍑哄簱浠诲姟
+                                        //璁板綍浠诲姟
+                                        var _id = Yitter.IdGenerator.YitIdHelper.NextId();
+                                        var plcTaskNo = BusinessHelper.CreatePlcTaskIdForSrmTask();
+                                        var new_task = new wms_rbline_task()
                                         {
-                                            x.StockStatus = (int)StockStatusEnum.榻愬寘寰呭嚭搴�;
+                                            Id = _id,
+                                            TaskNo = plcTaskNo,
 
-                                            //鐢熸垚鍑哄簱浠诲姟
-                                            //璁板綍浠诲姟
-                                            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,
-                                                IssueTime = DateTime.Now,
-                                                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 = "鍏ュ簱",
+                                            UPI = x.Upi,
+                                            Length = x.Length,
+                                            Width = x.Width,
+                                            Thk = x.Thk,
+                                            IssueTime = DateTime.Now,
+                                            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.閿佸畾;
+                                    });
                                 }
-
-                                wmsDB.SaveChanges();
                             }
+
+                            wmsDB.SaveChanges();
                         }
+
                     }
                 }
                 catch (Exception ex)
                 {
-                    SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound += " 鍑虹幇寮傚父:" + ex.Message + SysGloble.SPLIT_STR;
+                    SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_AutoQiTaoOutbound += " 鍑虹幇寮傚父:" + ex.Message + SysGloble.SPLIT_STR;
                     Log4NetHelper.WriteErrorLog(logType, " 鍑虹幇寮傚父锛�" + ex.Message, ex);
                 }
             }

--
Gitblit v1.9.3