kazelee
2025-05-15 1af49bdb3cdaa44a7e44ebdc843fb8180596365f
Services/MoboxService.cs
@@ -18,45 +18,6 @@
namespace HH.WCS.Mobox3.DSZSH.Services {
    public class MoboxService {
        #region 模板功能
        public static SimpleResult BaseBound(StartCntEndInfo model) {
            var taskName = ""; // 用于生成任务类型、打印日志信息
            var db = DbHelper.GetDbClient();
            try {
                var startLoc = db.Queryable<TN_Location>()
                    .Where(ExprHelper.LocCode(model.StartLoc))
                    .Where(ExprHelper.LocIsFree)
                    .Where(ExprHelper.LocIsEmpty.Negate()).First();
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 '{model.StartLoc}' 不存在或不具备取货要求");
                }
                var locCntrRel = db.Queryable<TN_Loc_Container>()
                    .Where(ExprHelper.LocCntrIsBind(startLoc.S_CODE, model.CntId)).First();
                if (locCntrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 '{startLoc.S_CODE}' 没有绑定容器 '{model.CntId}'");
                }
                var endLoc = db.Queryable<TN_Location>()
                    .Where(ExprHelper.LocCode(model.EndLoc))
                    .Where(ExprHelper.LocIsFree)
                    .Where(ExprHelper.LocIsEmpty).First();
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 '{model.EndLoc}' 不存在或不具备放货要求");
                }
                return TaskHelper.SimpleCreateTask(startLoc.S_CODE, locCntrRel.S_CNTR_CODE, endLoc.S_CODE, taskName);
            }
            catch (Exception ex) {
                return BuildSimpleEx(ex);
            }
        }
        #endregion
        #region PDA 功能
        /// <summary>
        /// 好运箱-满托下线入库(PDA)
@@ -82,10 +43,9 @@
                // 查看容器与起点货位是否绑定
                var locCntrRel = db.Queryable<TN_Loc_Container>().First(
                    a => a.S_LOC_CODE == model.StartLoc
                    && a.S_CNTR_CODE == model.CntId);
                    a => a.S_LOC_CODE == startLoc.S_CODE);
                if (locCntrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 '{model.StartLoc}' 没有绑定容器 '{model.CntId}' ,无可出库的物料");
                    return BuildSimpleResult(3, $"起点位置 '{model.StartLoc}' 无可出库的物料");
                }
                // TODO 满箱入库算法待优化
@@ -133,7 +93,7 @@
                    return BuildSimpleResult(3, $"当前容器 '{model.CntrCode}' 已经与 '{locCntrRel.S_LOC_CODE}' 绑定");
                }
                loc.N_CURRENT_NUM = model.PalletCount;
                //loc.N_CURRENT_NUM = model.PalletCount;
                locCntrRel = new TN_Loc_Container {
                    S_LOC_CODE = model.LocCode,
@@ -325,13 +285,13 @@
                }
                var endLoc = db.Queryable<TN_Location>()
                    .Where(ExprHelper.LocCode(model.EndLoc))
                    .Where(ExprHelper.LocBelongsToArea(AreaName.包装区))
                    .Where(l => taskInfo.EndAreas.Contains(l.S_AREA_CODE))
                    .Where(ExprHelper.LocIsFree)
                    .Where(ExprHelper.LocIsEmpty).First();
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 '{model.EndLoc}' 不存在或不具备放货要求");
                    return BuildSimpleResult(4, $"终点位置 不存在或不具备放货要求");
                }
                return TaskHelper.SimpleCreateTask(startLoc.S_CODE, locCntrRel.S_CNTR_CODE, endLoc.S_CODE, taskName);
@@ -371,13 +331,13 @@
                }
                var endLoc = db.Queryable<TN_Location>()
                    .Where(ExprHelper.LocCode(model.EndLoc))
                    .Where(ExprHelper.LocBelongsToArea(AreaName.包装区))
                    .Where(l => taskInfo.EndAreas.Contains(l.S_AREA_CODE))
                    .Where(ExprHelper.LocIsFree)
                    .Where(ExprHelper.LocIsEmpty).First();
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 '{model.EndLoc}' 不存在或不具备放货要求");
                    return BuildSimpleResult(4, $"终点位置 不存在或不具备放货要求");
                }
                return TaskHelper.SimpleCreateTask(startLoc.S_CODE, locCntrRel.S_CNTR_CODE, endLoc.S_CODE, taskName);
@@ -399,11 +359,11 @@
                using (var tran = db.Ado.UseTran()) {
                    var order = new TN_Check_Order {
                        S_NO = model.No,
                        S_CG_ID = model.CgId,
                        S_ITEM_NAME = model.ItemName,
                        S_NO = GenerateOrderNo("抽检单号", "CN"),
                        S_ITEM_CODE = model.ItemCode,
                        //S_ITEM_NAME = model.ItemName,
                        S_BATCH_NO = model.BatchNo,
                        N_COUNT = model.N_QTY,
                        N_COUNT = model.Qty,
                        S_END_AREA = model.EndArea,
                    };
@@ -412,10 +372,10 @@
                        return BuildSimpleResult(2, "生成 抽检单 失败:" + JsonConvert.SerializeObject(order));
                    }
                    for (int i = 0; i < model.N_QTY; i++) {
                    for (int i = 0; i < model.Qty; i++) {
                        var detail = new TN_Check_Detail {
                            S_NO = model.No,
                            S_CG_ID = model.CgId,
                            S_NO = order.S_NO,
                            S_ITEM_CODE = model.ItemCode,
                            S_BATCH_NO = model.BatchNo,
                            S_END_AREA = model.EndArea
                        };
@@ -428,7 +388,7 @@
                    tran.CommitTran();
                }
                return BuildSimpleResult(0, $"创建 抽检单 成功:单号 {model.No}");
                return BuildSimpleResult(0, $"创建 抽检单 成功");
            }
            catch (Exception ex) {
                return BuildSimpleEx(ex);
@@ -437,6 +397,7 @@
        public static SimpleResult QualifiedBack(QualifiedBackInfo model) {
            var db = DbHelper.GetDbClient();
            try {
                var cgDetail = db.Queryable<TN_CG_Detail>()
@@ -549,6 +510,34 @@
            }
        }
        public static SimpleResult RestBack(RestBackInfo model) {
            var db = DbHelper.GetDbClient();
            try {
                var locCntrRel = db.Queryable<TN_Loc_Container>()
                    .Where(c => c.S_LOC_CODE == model.StartLoc)
                    .First();
                if (locCntrRel == null) {
                    return BuildSimpleResult(2, $"起点货位 {model.StartLoc}");
                }
                var endLoc = db.Queryable<TN_Location, TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
                    .Where((l, c) => c.S_CNTR_TYPE == locCntrRel.S_CNTR_TYPE)
                    .First();
                if (endLoc == null) {
                    return BuildSimpleResult(3, $"不存在合适的终点货位可以回库");
                }
                return TaskHelper.SimpleCreateTask(locCntrRel.S_LOC_CODE, locCntrRel.S_CNTR_CODE, endLoc.S_CODE, TaskName.尾箱回库);
            }
            catch (Exception ex) {
                return BuildSimpleEx(ex);
            }
        }
        #endregion
        #region Mobox 功能
@@ -598,7 +587,7 @@
                        S_ITEM_CODE = model.ItemCode,
                        S_BATCH_NO = model.BatchNo,
                        F_QTY = model.Qty,
                        F_OUT_QTY = cgDetailList.Sum(a => a.F_QTY),
                        F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY),
                        S_END_AREA = model.EndArea
                    };
@@ -659,7 +648,7 @@
                        S_ITEM_CODE = model.ItemCode,
                        S_BATCH_NO = model.BatchNo,
                        F_QTY = model.Qty,
                        F_OUT_QTY = cgDetailList.Sum(a => a.F_QTY),
                        F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY),
                        S_END_AREA = model.EndArea
                    };
@@ -685,8 +674,8 @@
            try {
                var targetCg = db.Queryable<TN_CG_Detail>().Where(a => a.S_ITEM_CODE == model.ItemCode
                && a.F_QTY > targetNum).
                OrderBy(a => a.F_QTY, OrderByType.Asc).First();
                && a.N_QTY > targetNum).
                OrderBy(a => a.N_QTY, OrderByType.Asc).First();
                if (targetCg != null) //刚好有一行满足条件
                {
                    result.Add(targetCg);
@@ -695,12 +684,12 @@
                // NOTE 根据总量选detail时,是否需要考虑货位的高低?
                var sortedMaterials = db.Queryable<TN_CG_Detail, TN_Loc_Container>((d, c) => d.S_CNTR_CODE == c.S_CNTR_CODE)
                    .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.BatchNo && d.F_QTY > 0)
                    .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.BatchNo && d.N_QTY > 0)
                    .Where((d, c) => c.S_CNTR_TYPE == model.CntrType)
                    .Where(d => (model.ForcedOut && d.N_ITEM_STATE == 0 && d.S_ITEM_STATE == "合格")
                        || (!model.ForcedOut && (d.N_ITEM_STATE == 0 && d.S_ITEM_STATE == "合格"
                        || d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "待检")))
                    .OrderBy(d => d.F_QTY, OrderByType.Desc)
                    .OrderBy(d => d.N_QTY, OrderByType.Desc)
                    .OrderBy(d => d.N_ITEM_STATE, OrderByType.Asc).ToList();
                if (sortedMaterials.Count == 0)//没有满足条件的
@@ -710,13 +699,13 @@
                float countNum = 0;
                foreach (var mat in sortedMaterials) {
                    countNum += mat.F_QTY;
                    countNum += mat.N_QTY;
                    result.Add(mat);
                    if (countNum >= targetNum) {
                        break;
                    }
                }
                if (result.Sum(a => a.F_QTY) >= targetNum) {
                if (result.Sum(a => a.N_QTY) >= targetNum) {
                    return result;
                }
                else {
@@ -729,6 +718,64 @@
            }
        }
        /// <summary>
        /// 移库-创建移库任务(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static SimpleResult CreateShiftOrder(CreateShiftOrderInfo model) {
            var db = DbHelper.GetDbClient();
            try {
                var locCntrRelList = db.Queryable<TN_Loc_Container, TN_CG_Detail>((c, d) => c.S_CNTR_CODE == d.S_CNTR_CODE)
                    .Where((c, d) => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.ItemCode)
                    .ToList();
                if (locCntrRelList.Count == 0) {
                    return BuildSimpleResult(2, "没有找到待移库的物料");
                }
                // 绑定操作:插入出库单、所有的出库单明细
                using (var tran = db.Ado.UseTran()) {
                    var order = new TN_Shift_Order {
                        S_NO = GenerateOrderNo("移库单号", "SN"),
                        S_ITEM_CODE = model.ItemCode,
                        //S_ITEM_NAME = model.ItemName,
                        S_BATCH_NO = model.BatchNo,
                        N_COUNT = locCntrRelList.Count,
                        S_END_AREA = model.EndArea,
                    };
                    if (db.Insertable<TN_Shift_Order>(order).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(2, "生成 移库单 失败:" + JsonConvert.SerializeObject(order));
                    }
                    foreach (var locCntrRel in locCntrRelList) {
                        var detail = new TN_Shift_Detail {
                            S_NO = order.S_NO,
                            S_ITEM_CODE = model.ItemCode,
                            S_LOC_CODE = locCntrRel.S_LOC_CODE,
                            S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
                            S_BATCH_NO = model.BatchNo,
                            S_END_AREA = model.EndArea
                        };
                        if (db.Insertable<TN_Shift_Detail>(detail).ExecuteCommand() <= 0) {
                            tran.RollbackTran();
                            return BuildSimpleResult(3, "生成 移库单明细 失败:" + JsonConvert.SerializeObject(detail));
                        }
                    }
                    tran.CommitTran();
                }
                return BuildSimpleResult(0, $"创建 移库单 成功");
            }
            catch (Exception ex) {
                return BuildSimpleEx(ex);
            }
        }
        private static string GenerateOrderNo(string snType, string prefix) {
            var id = SysHelper.GetSerialNumber(snType, prefix);
            var date = DateTime.Now.ToString("yyMMdd");