using HH.WCS.QingXigongchang.device; using HH.WCS.QingXigongchang.dispatch; using HH.WCS.QingXigongchang.process; using HH.WCS.QingXigongchang.util; using HH.WCS.QingXigongchang.wms; using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; using static HH.WCS.QingXigongchang.api.ApiModel; namespace HH.WCS.QingXigongchang.core { internal class TaskCore { public static ReturnResult OperateTaskStatus(AgvTaskState model) { var r = new ReturnResult(); if (string.IsNullOrEmpty(model.No)) { //无任务号请求(交管) //DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State == 1023); DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State); } else { var wmsTask = TaskHelper.GetTask(model.No); if (wmsTask != null && wmsTask.S_B_STATE.Trim() != "失败" && wmsTask.S_B_STATE.Trim() != "推送异常" && wmsTask.S_B_STATE.Trim() != "完成" && wmsTask.S_B_STATE.Trim() != "强制完成" && wmsTask.S_B_STATE.Trim() != "取消") { if (model.State < 10 || model.State > 1000) { if (model.State < 7 && string.IsNullOrEmpty(model.ForkliftNo)) { LogHelper.Info($"{model.No} 没有车号，忽略"); r.ResultMsg = $"{model.No} 没有车号，忽略"; return r; } if (model.State < 7 && model.State > 1) { var aLER = TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, model.State + ""); if (aLER) { LogHelper.Info($"{wmsTask.S_TASK_NO}-{model.State} 已经报过了，忽略"); return r; } } //有任务号请求 switch (model.State) { case -1: TaskProcess.OperateStatus(wmsTask, 7); TaskHelper.SetTaskState(wmsTask, "推送异常"); break; case 1: TaskHelper.Begin(wmsTask); break; #region MyRegion case 3: TaskHelper.UpdateStatus(wmsTask, "开始取货"); break; case 4: TaskHelper.UpdateStatus(wmsTask, "取货完成"); TaskProcess.OperateStatus(wmsTask, 4); var plcTSJ = Settings.GetDeviceInfoList().Find(x => x.deviceType == 13 && (x.deviceName.Contains("T1") || x.deviceName.Contains("T2")) && x.location.Contains(wmsTask.S_END_LOC)); if (plcTSJ != null) { PlcHelper.SendHex(plcTSJ.address, "3F00" + "31" + "0d0a"); } break; case 5: TaskHelper.UpdateStatus(wmsTask, "开始卸货"); TaskProcess.OperateStatus(wmsTask, 5); break; case 6: TaskHelper.UpdateStatus(wmsTask, "卸货完成"); TaskProcess.OperateStatus(wmsTask, 6); break; #endregion case 2: TaskHelper.End(wmsTask); break; case 7: TaskProcess.OperateStatus(wmsTask, 7); wmsTask.T_END_TIME = DateTime.Now; TaskHelper.UpdateStatus(wmsTask, "取消"); try { if (wmsTask.S_TYPE.Contains("注塑满托-入库")) { var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_START_LOC)).FirstOrDefault(); if (plc != null) { for (var i = 0; i < plc.location.Length; i++) { if (wmsTask.S_START_LOC == plc.location[i]) { PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a"); break; } } } } else if (wmsTask.S_TYPE.Contains("注塑空拖-出库")) { var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_END_LOC)).FirstOrDefault(); if (plc != null) { for (var i = 0; i < plc.location.Length; i++) { if (wmsTask.S_END_LOC == plc.location[i]) { PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a"); break; } } } } else if (wmsTask.S_TYPE.Contains("瓶坯翻斗机满托-出库")) { var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_END_LOC)).FirstOrDefault(); if (plc != null) { PlcHelper.SendHex(plc.address, "3F00110D0A"); } } else if (wmsTask.S_TYPE.Contains("瓶坯翻斗机空托-入库")) { var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_START_LOC)).FirstOrDefault(); if (plc != null) { PlcHelper.SendHex(plc.address, "3F00110D0A"); } } } catch (Exception ex) { throw; } break; case 8://强制完成 - 未使用 r = TaskProcess.OperateStatus(wmsTask, 8); if (r.ResultCode != -1) TaskHelper.BeEnd(wmsTask); break; case 9://强制取消 //起点解绑锁释放 终点锁释放 // var R = NDCHelper.CancelS(model.No); r = TaskProcess.OperateStatus(wmsTask, 9); if (r.ResultCode != -1) { wmsTask.T_END_TIME = DateTime.Now; TaskHelper.UpdateStatus(wmsTask, "取消"); } break; case 1101://取货申请 - { NDCHelper.ChangeParam(wmsTask.S_TASK_NO, 1101, 18); var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(wmsTask.S_START_LOC.Trim()) && a.enable == 1).FirstOrDefault(); if (plc != null && plc.deviceType == 9) { PlcHelper.SendHex(plc.address, "3F00" + "11" + "0d0a"); } } break; case 1103://卸货申请 - 未使用 { NDCHelper.ChangeParam(wmsTask.S_TASK_NO, 1103, 18); var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(wmsTask.S_END_LOC.Trim()) && a.enable == 1).FirstOrDefault(); if (plc != null && plc.deviceType == 9) { PlcHelper.SendHex(plc.address, "3F00" + "21" + "0d0a"); } } break; case 1102://取货完成 - 未使用 case 1104://取货完成 - 未使用 { string loc__ = wmsTask.S_START_LOC.Trim(); if (model.State == 1104) loc__ = wmsTask.S_END_LOC.Trim(); var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(loc__) && a.enable == 1).FirstOrDefault(); if (plc != null) { if (plc.deviceType == 9) for (int i = 0; i < plc.location.Length; i++) { if (plc.location[i] == loc__) { PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a"); break; } } } } break; } //if (r.ResultCode != -1) { TaskHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData); //调用第三方接口（如果有）TaskProcess.ReportStatus TaskHelper.lOCReSetValue((WMSTask x) => x.S_TASK_NO.Trim() == model.No.Trim(), delegate (WMSTask x) { x.S_EQ_NO = model.ForkliftNo; }); } wmsTask.S_EQ_NO = model.ForkliftNo; if (model.State < 8) { TaskProcess.GeneralInterFaceFunc(wmsTask, model.State.ToString()); } } else { //安全请求等 TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData); } } else { if (wmsTask == null) { r = new ReturnResult() { ResultCode = -1, ResultMsg = "任务号不存在。" }; } else { r = new ReturnResult() { ResultCode = -1, ResultMsg = $"任务状态：{wmsTask.S_B_STATE},无法操作 " }; } } } return r; } /// /// 任务分发 /// internal static void Dispatch() { //查询任务 //获取所有未执行的任务 var list = TaskHelper.GetTaskListByState("未执行"); if (list.Count > 0) { //foreach (var mst in list) //{ // var dinfo = Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 13); // if (dinfo.Find(x => x.location.Contains(mst.S_START_LOC)) != null) // mst.N_PRIORITY = 99; // else // if (dinfo.Find(x => x.location.Contains(mst.S_END_LOC)) != null) // mst.N_PRIORITY = 98; //} //list = list.OrderByDescending(x => x.N_PRIORITY).ToList(); list.ForEach(task => { if (!TaskProcess.Intercept(task)) { //使用自定义任务推送 TaskProcess.SendTask(task); } }); } } internal static void ChargeHostAgv() { //查询任务 //获取所有未执行的任务 var list = TaskHelper.GetTaskListByState2("已推送"); if (list.Count > 0) { if (!string.IsNullOrEmpty(Settings.AgvSqlServer)) list.ForEach(task => { var _agvtask = TaskHelper.GetAgvTask(task); if (_agvtask != null) { if (!String.IsNullOrEmpty(_agvtask.CN_S_ERR) && _agvtask.CN_S_ERR.Contains("指令多次发送未成功")) { if (DateTime.Now.Subtract(_agvtask.CN_DT_CREATE).TotalMinutes < 10) TaskProcess.OperateStatus(task, 7); TaskHelper.SetTaskState(task, "推送异常"); } } else { LogHelper.Info($"hostAGV 数据库中找不到该任务。"); } }); } } /// /// 60分钟更新一次库容 /// /// public static void CheckKuRong(int min) { try { Console.WriteLine("CheckKurRong"); //如果表内没有数据就初始化一下，有数据了modify时间和当前时间超过30min再统计一次 var db = new SqlHelper().GetInstance(); var info = db.Queryable().First(); if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min) { //1、查到小板库区下面所有的库位 var totalX = 0; var totalRows = 0; var list = new List(); var areas = db.Queryable().Select(x => x.S_AREA_CODE).ToList().FindAll(x => System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas(); areas.ForEach(area => { totalX += db.Queryable().Count(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")); totalRows += db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")).Select(b => b.N_ROW).Distinct().Count(); var aresList = db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_")).Select(b => b.S_AREA_CODE).Distinct().ToList(); aresList = aresList.Select(a => a.Split('_')[0]).Distinct().ToList(); aresList.ForEach(a => { //b => b.S_AREA_CODE == a + "_X" Console.WriteLine("area:" + a); // && b.S_AREA_CODE.EndsWith("X") var rows = db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList(); if (rows.Count > 0) { Console.WriteLine(string.Join(",", rows)); rows.ForEach(b => { var kr = new KuRong() { StorageLoc = a.Split('-')[1] + "-" + b, T_MODIFY = DateTime.Now }; Console.WriteLine(kr.StorageLoc); //每一排要查一下有没有托盘 var listLoc = db.Queryable().Where(c => c.S_AREA_CODE.Contains(c.S_AREA_CODE) && c.N_ROW == b && c.N_CURRENT_NUM > 0).ToList(); if (!listLoc.Any()) { //没托盘，默认最大容量是小板的数量 var count = db.Queryable().Count(c => c.S_AREA_CODE == a + "_X" && c.N_ROW == b) * 2 * 2;//2层2托 kr.MaxCapacity = count; kr.AvailableCapacity = count; kr.ProductItem = ""; } else { //有托盘 判断是叠2层还是3层，要获取物料信息 var lcr = db.Queryable().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == listLoc[0].S_LOC_CODE).First(); if (lcr != null && lcr.CntrItemRel != null) { var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? listLoc[0].N_CAPACITY; var total = db.Queryable().Count(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b) * maxLayer * 2; var count = db.Queryable().Where(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2; // 指定统计字段 kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE; kr.MaxCapacity = total; kr.FilledCapacity = count; kr.AvailableCapacity = total - count; } } list.Add(kr); }); } else { Console.WriteLine("area:" + a + ":未获取到排"); } }); }); var ordersCount = db.Queryable().Where(a => a.SQL_State == "执行中").Count(); var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows); LogHelper.Error($"成品小板区总货位是{totalX},总排数是{totalRows},当前执行工单数量是{ordersCount}", null); var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity); var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity; list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; }); if (info == null) { /*​SQL Server​ 1000 条/批次 单个 INSERT 语句最多支持 1000 条 VALUES 子句，超出会报语法错误。*/ db.Insertable(list).ExecuteCommand(); } else { //更新 list.ForEach(a => { var old = db.Queryable().Where(b => b.StorageLoc == a.StorageLoc).First(); if (old != null) { old.MaxCapacity = a.MaxCapacity; old.AvailableCapacity = a.AvailableCapacity; old.FilledCapacity = a.FilledCapacity; old.ProductItem = a.ProductItem; old.DesiredCapacity = a.DesiredCapacity; old.CRC = a.CRC; old.RAC = a.RAC; old.T_MODIFY = DateTime.Now; db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand(); } else { db.Insertable(a).ExecuteCommand(); } }); } } } catch (Exception ex) { Console.WriteLine(ex.Message); LogHelper.Error(ex.Message, ex); } //统计当前产线 } internal static void Kuronggg() { int min = 60; try { LogHelper.Info("Run>>CheckKurRong"); //如果表内没有数据就初始化一下，有数据了modify时间和当前时间超过30min再统计一次 var db = new SqlHelper().GetInstance(); var info = db.Queryable().First(); if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min) { db.Deleteable().ExecuteCommand(); info = null; //1、查到小板库区下面所有的库位 var totalX = 0; var totalRows = 0; var list = new List(); var areas = db.Queryable().Select(x => x.S_AREA_CODE).ToList().FindAll(x => x != null && System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas(); LogHelper.Info($"KurRongCalc List {JsonConvert.SerializeObject(areas)}"); areas.ForEach(area => { totalX += db.Queryable().Count(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")); totalRows += db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")).Select(b => b.N_ROW).Distinct().Count(); var aresList = db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_")).Select(b => b.S_AREA_CODE).Distinct().ToList(); aresList = aresList.Select(a => a.Split('_')[0]).Distinct().ToList(); LogHelper.Info($"KurRongCalc aresList {JsonConvert.SerializeObject(aresList)}"); aresList.ForEach(a => { //b => b.S_AREA_CODE == a + "_X" Console.WriteLine("area:" + a); // && b.S_AREA_CODE.EndsWith("X") var rows = db.Queryable().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList(); if (rows.Count > 0) { Console.WriteLine(string.Join(",", rows)); rows.ForEach(b => { var kr = new KuRong() { StorageLoc = a.Split('-')[1] + "-" + b, T_MODIFY = DateTime.Now }; Console.WriteLine(kr.StorageLoc); //每一排要查一下有没有托盘 var listLoc = db.Queryable().Where(c => c.S_AREA_CODE.Contains(a) && c.N_ROW == b).ToList();//&& c.N_CURRENT_NUM > 0 //如果有正常物料排，就用， 没有或者 空排 ，就用小板 var norAreacode = ""; foreach (var arl in listLoc.GroupBy(x => x.S_AREA_CODE)) { if (arl.ToList().Find(x => x.S_LOCK_STATE.Contains("空间锁")) == null) { if (arl.ToList().Find(x => x.N_CURRENT_NUM > 0) != null) { norAreacode = arl.Key; break; } } } LogHelper.Info($"KurRongCalc [{a}]-{b} 统计是否正常{norAreacode}"); if (string.IsNullOrEmpty(norAreacode)) { norAreacode = a + "_X"; //没托盘，默认最大容量是小板的数量 var count = db.Queryable().Count(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b) * 2 * 2;//2层2托 kr.MaxCapacity = count; kr.AvailableCapacity = count; kr.ProductItem = ""; } else { var locode = listLoc.Find(x => x.S_AREA_CODE == norAreacode && x.N_CURRENT_NUM > 0); //有托盘 判断是叠2层还是3层，要获取物料信息 var lcr = db.Queryable().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == locode.S_LOC_CODE).First(); LogHelper.Info($"KurRongCalc {norAreacode}-{locode.S_LOC_CODE}-获取到托盘物料信息？：{lcr != null}"); if (lcr != null && lcr.CntrItemRel != null) { var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? 0; //LogHelper.Info($"KurRongCalc {norAreacode}-{lcr.CntrItemRel.S_ITEM_NAME}-{lcr.CntrItemRel.S_ITEM_CODE}-maxlayer:{maxLayer}-{locode.S_LOC_CODE}-{locode.N_CAPACITY}"); if (maxLayer <= 0) { maxLayer = locode.N_CAPACITY; } var total = db.Queryable().Count(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b) * maxLayer * 2; //LogHelper.Info($"KurRongCalc {norAreacode}-{locode.S_LOC_CODE}"); var count = db.Queryable().Where(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2; // 指定统计字段 kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE; if (!string.IsNullOrEmpty(lcr.CntrItemRel.S_ITEM_NAME)) kr.ProductItem = lcr.CntrItemRel.S_ITEM_NAME; kr.MaxCapacity = total; kr.FilledCapacity = count; kr.AvailableCapacity = total - count; } } list.Add(kr); }); } else { Console.WriteLine("area:" + a + ":未获取到排"); } }); }); var ordersCount = 0;// db.Queryable().Where(a => a.SQL_State == "执行中").Count(); foreach (var pline in Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 9)) { ordersCount += db.Queryable().Where(a => a.SQL_PLineNo == pline.deviceName && a.SQL_State == "执行中").Count(); } var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows); LogHelper.Error($"成品小板区总货位是{totalX},总排数是{totalRows},当前执行工单数量是{ordersCount}", new Exception("Kurong")); //var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity); //var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity; //list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; }); var totalAvailableCapacity = list.Sum(a => a.MaxCapacity);// AvailableCapacity); var DRC = list.Sum(x => x.FilledCapacity); var totalAssignableCapacity = totalAvailableCapacity - DRC - totalDesiredCapacity; var BAC = list.Sum(x => x.AvailableCapacity); list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; a.BAC = BAC; a.DRC = DRC; }); if (info == null) { /*​SQL Server​ 1000 条/批次 单个 INSERT 语句最多支持 1000 条 VALUES 子句，超出会报语法错误。*/ for (int i = 0; i < list.Count; i += 1000) { db.Insertable(list.Skip(i).Take(1000).ToList()).ExecuteCommand(); } } else { //更新 list.ForEach(a => { var old = db.Queryable().Where(b => b.StorageLoc == a.StorageLoc).First(); if (old != null) { old.MaxCapacity = a.MaxCapacity; old.AvailableCapacity = a.AvailableCapacity; old.FilledCapacity = a.FilledCapacity; old.ProductItem = a.ProductItem; old.DesiredCapacity = a.DesiredCapacity; old.CRC = a.CRC; old.RAC = a.RAC; old.T_MODIFY = DateTime.Now; db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand(); } else { db.Insertable(a).ExecuteCommand(); } }); } } LogHelper.Info("OVER<