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