kazelee
2025-05-12 968d603a08117e7e6707ffe07c6da9c325e36c08
ServiceCore/CheckCore.cs
@@ -9,56 +9,67 @@
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();
                    } 
                }
            }
@@ -66,5 +77,35 @@
                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();
            }
        }
    }
}