using Admin.NET.Application; using iWareCC.Common.Helper; using iWareCC.StationService; using iWareCommon.Common.Globle; using iWareCommon.Utils; using iWareModel; using iWareSql.DBModel; using iWareSql.WmsDBModel; using System; using System.Collections.Generic; using System.Linq; using System.Net.NetworkInformation; using System.Reflection.Emit; using System.ServiceModel.Configuration; using System.Text; using System.Threading; using System.Threading.Tasks; using XiGang.Core.Model; namespace iWareCC.ThreadService { /// /// BZ01工位(清灰,洗板后工位) /// public static class DataProcess_BZ01 { /// /// BZ01工位(清灰,洗板后工位) /// public static async void Handler() { var alertMsg = ""; LogType logType = LogType.DataProcess_BZ01; while (true) { Thread.Sleep(1000);//休眠2秒,将休眠写到前面,是为了下面的continue方法执行后不显示错误信息的提示!!!【EditBy shaocx,2022-05-24】 SystemWarningMsg._lbl_alert_DataProcess_BZ01 = string.Empty; try { if (SystemValue.isStartedModel)//SystemValue.isAllowRuning_DataProcess_BZ01 && { if (FormCC.IsAllowRunOutMode == true) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"正在干出库模式,此方法暂停。。 "; continue; } var rgvLocation = StationLocationEnum.BZ01.ToString(); /* * 1、从数据库中判断是否齐套 * 2、根据齐套结果,推送给PLC */ var obj = FormCC.stationView.R_StationForReadCommList.Where(x => x.StationCode == rgvLocation.ToString()).FirstOrDefault(); if (obj.R_ReqParseData) { var result = obj.R_ReadCodeResult; if (string.IsNullOrEmpty(result)) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-请求了解码,但是结果是空的,此次循环结束"; continue; } var upiCode = result; var qitaoReault = false; using (WmsDBModel wmsDB = new WmsDBModel()) { var upiObj = wmsDB.mes_batchOrderUPI_new.Where(x => x.UPI == upiCode).FirstOrDefault(); if (upiObj == null) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()},根据UPI:{upiCode}没有找到对象 "; continue; } var isAllow = IsAllloRunOutTaskMode(wmsDB, upiObj); if (isAllow) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()},判断要执行出库模式了,此方法暂停。。 "; continue; } //查询是否齐包 var allList = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList(); var isQiTaoList = allList.Where(x => x.AreaCode == (int)AreaCodeEnum.待缓存分拣区 || x.AreaCode == (int)AreaCodeEnum.缓存分拣区 || x.AreaCode == (int)AreaCodeEnum.码垛区域 || x.AreaCode == (int)AreaCodeEnum.机器人岛缓存区域 ).ToList(); if (isQiTaoList.Count() != allList.Count()) {//不齐包 qitaoReault = false; upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区; } else {//齐包 qitaoReault = true; upiObj.AreaCode = (int)AreaCodeEnum.码垛区域; } using (StationServiceClient client = new StationServiceClient()) { var res = await client.WriteQiTaoInfoAsync((int)EDevice.Station, rgvLocation, qitaoReault); if (!res.result) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-推送齐套结果失败,WriteQiTaoInfoAsync返回:{res.resMsg}"; continue; } else { Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-推送齐套结果成功,WriteQiTaoInfoAsync,参数: 站点{rgvLocation},齐套结果:{qitaoReault}"); } } //更新UPI状态 var upiObjList = wmsDB.mes_batchOrderUPI_new.Where(x => x.UPI == upiCode).ToList(); foreach (var item in upiObjList) { if (qitaoReault) { item.UpiStatus = (int)UpiStatusEnum.已齐包; } else { item.UpiStatus = (int)UpiStatusEnum.不齐包; } } //更新 最后一次在 BZ_01的系统处理的板件 数据 var rbRunMode = wmsDB.wms_rbline_runmode.FirstOrDefault(); rbRunMode.PlanNo = upiObj.PlanNo; rbRunMode.OrderId = upiObj.OrderId; rbRunMode.PackageCode = upiObj.PackageCode; WmsRecordUpiProcessHandler.SaveWmsRecordUpiProcess(wmsDB, upiObj, "BZ01", "齐包验证:" + (qitaoReault ? "齐包" : "不齐包")); wmsDB.SaveChanges(); } } else { using (WmsDBModel wmsDB = new WmsDBModel()) { var isAllow = IsAllloRunOutTaskMode(wmsDB, null); } } } } catch (Exception ex) { SystemWarningMsg._lbl_alert_DataProcess_BZ01 += " 出现异常:" + ex.Message + SysGloble.SPLIT_STR; Log4NetHelper.WriteErrorLog(logType, " 出现异常:" + ex.Message, ex); } } } /// /// 是否可以执行出库模式 /// /// /// /// private static bool IsAllloRunOutTaskMode(WmsDBModel wmsDB, mes_batchOrderUPI_new curUpiObj) { //首先查询数据库中是否有 要出库的数据 var isExistOutTaskForNewCreated = wmsDB.wms_rbline_task.Where(x => x.RbTaskType == (int)RbTaskTypeEnum.出库任务 && x.TaskStatus == (int)TaskStatusEnum.新建 ).Count(); if (isExistOutTaskForNewCreated == 0) { FormCC.IsAllowRunOutMode = false; return false;//不能执行 出库模式 } var rbRunMode = wmsDB.wms_rbline_runmode.FirstOrDefault(); var lastUpi = rbRunMode.UPI; var lastPackageCode = rbRunMode.PackageCode; if (curUpiObj == null) {//表示此时无新板过来 if (!string.IsNullOrEmpty(lastUpi)) { var lastObj = wmsDB.mes_batchOrderUPI_new.Where(x => x.UPI == lastUpi).FirstOrDefault(); if (lastObj.UpiStatus == (int)UpiStatusEnum.不齐包 || lastObj.UpiStatus == (int)UpiStatusEnum.初始) {//表示最后过去的板是不齐包的板 //可以运行执行 出库模式 } else {//表示最后过去的板是齐包的板 //要继续判断后面 待分拣区域还存在相同包的板数据吗 var isExistSamePackageCode = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == lastPackageCode && x.AreaCode == (int)AreaCodeEnum.待缓存分拣区).Count(); if (isExistSamePackageCode > 0) { FormCC.IsAllowRunOutMode = false; return false;//不能执行 出库模式 } else { //可以运行执行 出库模式 } } } else { //可以运行执行 出库模式 } } else {//表示此时有新板过来 if (!string.IsNullOrEmpty(lastUpi)) { if (lastPackageCode == curUpiObj.PackageCode) { FormCC.IsAllowRunOutMode = false; return false;//不能执行 出库模式 } else {//新包过来了 //可以运行执行 出库模式 } } else { //可以运行执行 出库模式 } } FormCC.IsAllowRunOutMode = true; return true; } } }