| | |
| | | using HH.WCS.Mobox3.DSZSH.Helpers.Model; |
| | | using HH.WCS.Mobox3.DSZSH.Models; |
| | | |
| | | using Org.BouncyCastle.Asn1.X509; |
| | | |
| | | namespace HH.WCS.Mobox3.DSZSH.ServiceCore { |
| | | /// <summary> |
| | | /// 定时轮询任务:抽检业务核心 |
| | | /// </summary> |
| | | public class CheckCore { |
| | | /// <summary> |
| | | /// 轮询查看抽检单是否有执行中的项目 |
| | | /// </summary> |
| | | public void CheckOrderState() { |
| | | public static void CheckOrderState() { |
| | | var db = DbHelper.GetDbClient(); |
| | | try { |
| | | var orderList = db.Queryable<TN_Check_Order>() |
| | | .Where(c => c.N_B_STATE == 0) |
| | | .OrderBy(c => c.T_CREATE).ToList(); |
| | | var order = db.Queryable<TN_Check_Order>() |
| | | .Where(c => c.N_B_STATE == SpotStateCode.已执行待生成任务) |
| | | .OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc).First(); |
| | | |
| | | if (order == null) { |
| | | LogHelper.Info("暂无待执行的抽检单"); |
| | | return; |
| | | } |
| | | |
| | | var detailList = db.Queryable<TN_Check_Detail>() |
| | | .Where(d => d.S_NO == order.S_NO && d.N_B_STATE == SpotStateCode.已执行待生成任务).ToList(); |
| | | |
| | | if (detailList.Count == 0) { |
| | | order.N_B_STATE = SpotStateCode.任务执行中; |
| | | db.Updateable<TN_Check_Order>(order).UpdateColumns(it => it.N_B_STATE).ExecuteCommand(); |
| | | return; |
| | | } |
| | | |
| | | foreach (var detail in detailList) { |
| | | var startLocCntrRel = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail> |
| | | ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE) |
| | | .Where((l, c, d) => d.S_CG_ID == detail.S_CG_ID && d.S_BATCH_NO == detail.S_BATCH_NO) |
| | | .Select((l, c) => c) // 选择 LocCntrRel |
| | | .First(); // 随机抽检,不排序 |
| | | |
| | | if (startLocCntrRel == null) { |
| | | LogHelper.Info("没有找到合适的起点货位"); |
| | | continue; |
| | | } |
| | | |
| | | var endLoc = db.Queryable<TN_Location>() |
| | | .Where(l => l.S_AREA_CODE == detail.S_END_AREA) |
| | | .Where(ExprHelper.LocIsFree) |
| | | .Where(ExprHelper.LocIsEmpty).First(); |
| | | |
| | | if (endLoc == null) { |
| | | LogHelper.Info("查询:没有找到合适的终点货位"); |
| | | continue; |
| | | } |
| | | |
| | | using (var tran = db.Ado.UseTran()) { |
| | | foreach (var order in orderList) { |
| | | var startLocList = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail> |
| | | ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE) |
| | | .Where((l, c, d) => d.S_CG_ID == order.S_CG_ID && d.S_BATCH_NO == order.S_BATCH_NO) |
| | | .Select((l, c) => new { Location = l, Container = c }) |
| | | .Take(order.N_QTY).ToList(); // 获取指定数量的货位数,随机抽取故无需排序 |
| | | |
| | | if (startLocList.Count < order.N_QTY) { |
| | | LogHelper.Info($"轮询 | 当前可抽检的物料数量 {startLocList.Count} 无法满足抽检单数量 {order.N_QTY} 要求"); |
| | | return; |
| | | detail.N_B_STATE = SpotStateCode.任务执行中; |
| | | if (db.Updateable<TN_Check_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) { |
| | | tran.RollbackTran(); |
| | | LogHelper.Info($"更新失败:修改抽检单明细表状态为完成"); |
| | | } |
| | | |
| | | var endLocList = db.Queryable<TN_Location>() |
| | | .Where(l => l.S_AREA_CODE == order.S_END_AREA) |
| | | .Where(ExprHelper.LocIsFree) |
| | | .Where(ExprHelper.LocIsEmpty) |
| | | .Take(order.N_QTY).ToList(); // 获取指定数量的货位数 |
| | | |
| | | if (endLocList.Count < order.N_QTY) { |
| | | LogHelper.Info($"轮询 | 终点区域可用货位 {startLocList.Count} 无法满足抽检单数量 {order.N_QTY} 要求"); |
| | | return; |
| | | if (TaskHelper.LogCreateTask(startLocCntrRel.S_LOC_CODE, startLocCntrRel.S_CNTR_CODE, |
| | | endLoc.S_CODE, TaskName.抽检)) { |
| | | tran.CommitTran(); |
| | | } |
| | | |
| | | // TODO 参考出库,如果要求任务顺序也要新创建表存储,有需求再更新 |
| | | for (var i = 0; i < order.N_QTY; i++) { |
| | | if (!TaskHelper.LogCreateTask(startLocList[i].Location.S_CODE, startLocList[i].Container.S_CNTR_CODE, |
| | | endLocList[i].S_CODE, TaskName.抽检)) { |
| | | else { |
| | | tran.RollbackTran(); |
| | | } |
| | | } |
| | | |
| | | order.N_B_STATE = 1; |
| | | db.Updateable<TN_Check_Order>(endLocList).UpdateColumns(c => c.N_B_STATE); |
| | | tran.CommitTran(); |
| | | } |
| | | } |
| | | } |
| | |
| | | LogHelper.InfoEx(ex); |
| | | } |
| | | } |
| | | |
| | | public static void UpdateTaskState(int spotStateCode) { |
| | | var db = DbHelper.GetDbClient(); |
| | | |
| | | var detail = db.Queryable<TN_Check_Detail>() |
| | | .First(d => d.N_B_STATE == SpotStateCode.任务执行中); |
| | | |
| | | if (detail == null) { |
| | | LogHelper.Info("当前没有执行中的抽检单明细项目"); |
| | | return; |
| | | } |
| | | |
| | | using (var tran = db.Ado.UseTran()) { |
| | | detail.N_B_STATE = spotStateCode; |
| | | db.Updateable<TN_Check_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand(); |
| | | |
| | | if (db.Queryable<TN_Check_Detail>().Count(d => d.S_NO == detail.S_NO && d.N_B_STATE == 2) == |
| | | db.Queryable<TN_Check_Detail>().Count(d => d.S_NO == detail.S_NO)) { |
| | | |
| | | if (db.Updateable<TN_Check_Order>().SetColumns(it => it.N_B_STATE == SpotStateCode.任务执行完成) |
| | | .Where(it => it.S_NO == detail.S_NO) |
| | | .ExecuteCommand() <= 0) { |
| | | tran.RollbackTran(); |
| | | LogHelper.Info("修改Order状态错误"); |
| | | } |
| | | } |
| | | |
| | | tran.CommitTran(); |
| | | } |
| | | } |
| | | } |
| | | } |