using Admin.NET.Application; using iWareCC.StationService; using iWareCommon.Common.Globle; using iWareCommon.Utils; using iWareModel; using iWareSql.WmsDBModel; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace iWareCC.ThreadService._04_BZ21_搬运整垛机器人_ { public class DataProcess_BZ21_FinishTask { public static void Handler() { var alertMsg = ""; LogType logType = LogType.DataProcess_BZ21_FinishTask; while (true) { Thread.Sleep(2000);//休眠2秒,将休眠写到前面,是为了下面的continue方法执行后不显示错误信息的提示!!!【EditBy shaocx,2022-05-24】 SystemWarningMsg._lbl_Alert_DataProcess_BZ21_FinishTask = string.Empty; try { if (SystemValue.isStartedModel) { var rgvLocation = StationLocationEnum.BZ21.ToString(); if (FormCC.stationView == null) { SystemWarningMsg._lbl_Alert_DataProcess_BZ21_FinishTask = $"{rgvLocation.ToString()}-获取PLC对象为null"; continue; } var obj = FormCC.stationView.R_StationForReadCommList.Where(x => x.StationCode == rgvLocation.ToString()).FirstOrDefault(); if (obj.R_SurrouondTaskFinish) //if (true)//模拟 { //var result = obj.R_InboundNumber; //if (string.IsNullOrEmpty(result)) //{ // SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = $"{rgvLocation.ToString()}- 入库库位号是空的,此次循环结束"; // continue; //} //obj.R_Inbound_TaskID = 17797;//模拟 var result2 = obj.R_SurrouondTaskNo; if (result2 == 0) { SystemWarningMsg._lbl_Alert_DataProcess_BZ21_FinishTask = $"{rgvLocation.ToString()}- 码板任务号是空的,此次循环结束"; continue; } var qitaoReault = false; using (WmsDBModel wmsDB = new WmsDBModel()) { var task = wmsDB.wms_rbline_task.Where(x => x.TaskNo == obj.R_SurrouondTaskNo.ToString() && x.RbTaskType == (int)RbTaskTypeEnum.合包任务 ).OrderByDescending(x => x.Id).FirstOrDefault(); if (task == null) { SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = $"{rgvLocation.ToString()},根据 R_InboundNumber:{obj.R_InboundNumber}没有找到已下发的任务 "; continue; } else { if (task.TaskStatus == (int)TaskStatusEnum.已完成) { //给PLC推送任务完成确认信号 using (StationServiceClient client = new StationServiceClient()) { var res = client.SetSurroundTaskFinishAck((int)EDevice.Station, true, rgvLocation); } continue; } } var upiobj = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == task.PackageCode).ToList(); if (upiobj.Count > 0) { foreach (var item in upiobj) { item.UpiStatus = (int)UpiStatusEnum.已合包; item.AreaCode = (int)AreaCodeEnum.包装线区域; } } task.TaskStatus = (int)TaskStatusEnum.已完成; task.TaskStatusName = TaskStatusEnum.已完成.ToString(); task.FinishedTime = DateTime.Now; //给PLC推送任务完成确认信号 using (StationServiceClient client = new StationServiceClient()) { var res = client.SetSurroundTaskFinishAck((int)EDevice.Station, true, rgvLocation); if (!res.result) { SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = $"{rgvLocation.ToString()}-下发码板任务 失败,SetPalletizingTaskFinishAck 返回:{res.resMsg}"; continue; } else { Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-下发入库任务 成功,SetPalletizingTaskFinishAck,参数: 站点{rgvLocation}"); } } wmsDB.SaveChanges(); } } else { //给PLC推送任务完成确认信号 using (StationServiceClient client = new StationServiceClient()) { var res = client.SetSurroundTaskFinishAck((int)EDevice.Station, false, rgvLocation); //if (!res.result) //{ // SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = $"{rgvLocation.ToString()}-下发码板任务 失败,SetPalletizingTaskFinishAck 返回:{res.resMsg}"; // continue; //} //else //{ // Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-下发入库任务 成功,SetPalletizingTaskFinishAck,参数: 站点{rgvLocation}"); //} } } } } catch (Exception ex) { SystemWarningMsg._lbl_Alert_DataProcess_BZ21_FinishTask += " 出现异常:" + ex.Message + SysGloble.SPLIT_STR; Log4NetHelper.WriteErrorLog(logType, " 出现异常:" + ex.Message, ex); } } } } }