kazelee
2025-06-19 0e829f4a5321c10900e1f4130a80f2e8c804a08e
api/ApiHelper.cs
@@ -3,6 +3,8 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using HH.WCS.Mobox3.AnGang.dispatch;
using HH.WCS.Mobox3.AnGang.models;
using HH.WCS.Mobox3.AnGang.util;
using HH.WCS.Mobox3.AnGang.wms;
@@ -105,11 +107,11 @@
            }
        }
        //internal static string GenerateNo(string snType, string prefix) {
        //    var id = SYSHelper.GetSerialNumber(snType, prefix);
        //    var date = DateTime.Now.ToString("yyMMdd");
        //    return $"TN{date}{id.ToString().PadLeft(4, '0')}";
        //}
        internal static string GenerateNo(string snType, string prefix) {
            var id = SYSHelper.GetSerialNumber(snType, prefix);
            var date = DateTime.Now.ToString("yyMMdd");
            return $"{prefix}{date}-{id.ToString().PadLeft(5, '0')}"; // 形如:CN250525-00011
        }
        /// <summary>
        /// PDA选择终点货位
@@ -183,13 +185,13 @@
                using (var tran = db.Ado.UseTran()) {
                    if (db.Updateable<TN_Task>(task).UpdateColumns(a => a.S_END_LOC).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(7, $"任务{task.S_CODE}修改失败,修改终点位置为{endLoc.S_CODE}");
                        return BuildSimpleResult(500, $"任务{task.S_CODE}修改失败,修改终点位置为{endLoc.S_CODE}");
                    }
                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
                        it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(7, $"任务{task.S_CODE}修改失败,修改终点位置为{endLoc.S_CODE}");
                        return BuildSimpleResult(500, $"任务{task.S_CODE}修改失败,修改终点位置为{endLoc.S_CODE}");
                    }
                    tran.CommitTran();
@@ -239,6 +241,8 @@
                LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
                LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
                var res = GZRobot.QueryInteractInfo(3);
                using (var tran = db.Ado.UseTran()) {
                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
@@ -353,16 +357,16 @@
                    task.N_B_STATE = 4;
                    task.S_B_STATE = "取消";
                    var starloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_START_LOC);
                    var startloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_START_LOC);
                    var endloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_END_LOC);
                    //var locCnt = db.Queryable<TN_Loc_Container>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
                    //var cg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
                    if (starloc != null) {
                        starloc.N_LOCK_STATE = 0;
                        starloc.S_LOCK_STATE = "无";
                    if (startloc != null) {
                        startloc.N_LOCK_STATE = 0;
                        startloc.S_LOCK_STATE = "无";
                        //starloc.N_CURRENT_NUM = 0;
                        starloc.T_MODIFY = System.DateTime.Now;
                        startloc.T_MODIFY = System.DateTime.Now;
                    }
                    if (endloc != null) {
@@ -372,45 +376,45 @@
                        endloc.T_MODIFY = System.DateTime.Now;
                    }
                    if (!int.TryParse(task.S_EQ_TASK_CODE, out var code)) {
                        return BuildSimpleResult(1, $"当前任务{task.S_CODE}没有找到对应的国自AGV orderId!");
                    }
                    var res = GZRobot.CancelGZOrder(code);
                    if (!res) {
                        return BuildSimpleResult(2, $"国自AGV取消任务失败!");
                    }
                    using (var tran = db.Ado.UseTran()) {
                        if (db.Updateable<TN_Location>(starloc).ExecuteCommand() <= 0) {
                        if (db.Updateable<TN_Location>(startloc).ExecuteCommand() <= 0) {
                            tran.RollbackTran();
                            info = $"任务{task.S_CODE}取消失败";
                            return BuildSimpleResult(0, info);
                            info = $"任务{task.S_CODE}取消失败:修改起点货位锁状态失败";
                            return BuildSimpleResult(500, info);
                        }
                        if (endloc != null) {
                            if (db.Updateable<TN_Location>(endloc).ExecuteCommand() <= 0) {
                                tran.RollbackTran();
                                info = $"任务{task.S_CODE}取消失败";
                                return BuildSimpleResult(0, info);
                                info = $"任务{task.S_CODE}取消失败:修改终点货位锁状态失败";
                                return BuildSimpleResult(500, info);
                            }
                        }
                        if (db.Updateable<TN_Task>(task).ExecuteCommand() <= 0) {
                            if (db.Updateable<TN_Location>(endloc).ExecuteCommand() <= 0) {
                                tran.RollbackTran();
                                info = $"任务{task.S_CODE}取消失败";
                                return BuildSimpleResult(0, info);
                            }
                            tran.RollbackTran();
                            info = $"任务{task.S_CODE}取消失败";
                            return BuildSimpleResult(500, info);
                        }
                        tran.CommitTran();
                        info = $"任务{task.S_CODE}取消成功";
                        return BuildSimpleResult(0, info);
                    }
                }
                else {
                    return BuildSimpleResult(3, $"只有任务号状态为 等待 或 已推送 的任务才能取消");
                    // return CancelTaskIfForced(model, task); // 备用函数,如果甲方要求任务执行中也取消,再调用
                }
            }
@@ -419,271 +423,268 @@
            }
        }
        public static SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
            var db = new SqlHelper<object>().GetInstance();
            try {
                var countPlan = new TN_Count_Plan() {
                    S_CP_NO = GenerateNo("盘点计划", "CP"),
                    S_TYPE = model.countType,
                };
                if (model.countType == "货位") {
                    countPlan.S_LOC_CODE = model.targetId;
                }
                else if (model.countType == "物料") {
                    countPlan.S_ITEM_CODE = model.targetId;
                }
                else {
                    return BuildSimpleResult(2, $"创建盘点计划失败:不合法的盘点类型 '{model.countType}'");
                }
                if (db.Insertable<TN_Count_Plan>(countPlan).ExecuteCommand() <= 0) {
                    return BuildSimpleResult(2, "创建盘点计划失败");
                }
                return BuildSimpleResult(0, "创建盘点计划成功");
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, ex.Message);
            }
        public static SimpleResult CancelTaskIfForced(CancleTaskInfo model, TN_Task task) {
            return BuildSimpleResult(3, $"只有任务号状态为 等待 或 已推送 的任务才能取消");
        }
        public static SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
            var db = new SqlHelper<object>().GetInstance();
            var info = "";
            try {
                var countPlan = db.Queryable<TN_Count_Plan>()
                    .Where(a => a.S_CP_NO == model.planId).First();
        //public static SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
        //    var db = new SqlHelper<object>().GetInstance();
        //    try {
                if (countPlan == null) {
                    return BuildSimpleResult(2, $"盘点计划单号 '{model.planId}' 不存在");
                }
        //        var countPlan = new TN_Count_Plan() {
        //            S_CP_NO = GenerateNo("盘点计划", "CP"),
        //            S_TYPE = model.countType,
        //        };
                var countOrder = new TN_Count_Order() {
                    S_CP_NO = model.planId,
                    S_COUNT_NO = GenerateNo("盘点单", "CN"),
                };
        //        if (model.countType == "货位") {
        //            countPlan.S_LOC_CODE = model.targetId;
        //        }
        //        else if (model.countType == "物料") {
        //            countPlan.S_ITEM_CODE = model.targetId;
        //        }
        //        else {
        //            return BuildSimpleResult(2, $"创建盘点计划失败:不合法的盘点类型 '{model.countType}'");
        //        }
                var countDetailList = new List<TN_Count_CG_Detail>();
                if (countPlan.S_TYPE == "货位") {
                    var cgDetail = 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 => l.S_CODE == countPlan.S_LOC_CODE)
                        .Select((l, c, d) => d).First();
        //        if (db.Insertable<TN_Count_Plan>(countPlan).ExecuteCommand() <= 0) {
        //            return BuildSimpleResult(2, "创建盘点计划失败");
        //        }
                    var countDetail = new TN_Count_CG_Detail {
                        S_COUNT_NO = countOrder.S_COUNT_NO,
                        S_CNTR_CODE = cgDetail.S_CNTR_CODE,
                        S_ITEM_CODE = cgDetail.S_ITEM_CODE,
                    };
        //        return BuildSimpleResult(0, "创建盘点计划成功");
                    countDetailList.Add(countDetail);
                }
                else if (countPlan.S_TYPE == "物料") {
                    var cgDetailList = db.Queryable<TN_CG_Detail>()
                        .Where(d => d.S_ITEM_CODE == countPlan.S_ITEM_CODE).ToList();
        //    }
        //    catch (Exception ex) {
                    foreach (var cgDetail in cgDetailList) {
                        var countDetail = new TN_Count_CG_Detail {
                            S_COUNT_NO = countOrder.S_COUNT_NO,
                            S_CNTR_CODE = cgDetail.S_CNTR_CODE,
                            S_ITEM_CODE = cgDetail.S_ITEM_CODE,
                        };
        //        return BuildSimpleResult(1, ex.Message);
        //    }
        //}
                        countDetailList.Add(countDetail);
                    }
                }
                else {
                    return BuildSimpleResult(3, $"计划单'{model.planId}'的类型{countPlan.S_TYPE}不合法");
                }
        //public static SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
        //    var db = new SqlHelper<object>().GetInstance();
        //    var info = "";
        //    try {
        //        var countPlan = db.Queryable<TN_Count_Plan>()
        //            .Where(a => a.S_CP_NO == model.planId).First();
                using (var tran = db.Ado.UseTran()) {
                    if (db.Insertable<TN_Count_Order>(countOrder).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        info = "创建盘点单失败";
                        return BuildSimpleResult(2, info);
                    }
        //        if (countPlan == null) {
        //            return BuildSimpleResult(2, $"盘点计划单号 '{model.planId}' 不存在");
        //        }
                    if (db.Insertable<TN_Count_CG_Detail>(countDetailList).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        info = "创建盘点单明细失败";
                        return BuildSimpleResult(3, info);
                    }
        //        var countOrder = new TN_Count_Order() {
        //            S_CP_NO = model.planId,
        //            S_COUNT_NO = GenerateNo("盘点单", "CN"),
        //        };
                    tran.CommitTran();
                }
        //        var countDetailList = new List<TN_Count_CG_Detail>();
        //        if (countPlan.S_TYPE == "货位") {
        //            var cgDetail = 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 => l.S_CODE == countPlan.S_LOC_CODE)
        //                .Select((l, c, d) => d).First();
                return BuildSimpleResult(0, "创建盘点单成功");
            }
            catch (Exception ex) {
        //            var countDetail = new TN_Count_CG_Detail {
        //                S_COUNT_NO = countOrder.S_COUNT_NO,
        //                S_CNTR_CODE = cgDetail.S_CNTR_CODE,
        //                S_ITEM_CODE = cgDetail.S_ITEM_CODE,
        //            };
                return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
            }
        }
        //            countDetailList.Add(countDetail);
        //        }
        //        else if (countPlan.S_TYPE == "物料") {
        //            var cgDetailList = db.Queryable<TN_CG_Detail>()
        //                .Where(d => d.S_ITEM_CODE == countPlan.S_ITEM_CODE).ToList();
        public static SimpleResult CountProduct(CountProductInfo model) {
            var db = new SqlHelper<object>().GetInstance();
            try {
                var cgDetail = db.Queryable<TN_CG_Detail>()
                    .Where(d => d.S_CNTR_CODE == model.cntrCode).First();
        //            foreach (var cgDetail in cgDetailList) {
        //                var countDetail = new TN_Count_CG_Detail {
        //                    S_COUNT_NO = countOrder.S_COUNT_NO,
        //                    S_CNTR_CODE = cgDetail.S_CNTR_CODE,
        //                    S_ITEM_CODE = cgDetail.S_ITEM_CODE,
        //                };
                if (cgDetail == null) {
                    return BuildSimpleResult(2, $"找不到容器号'{model.cntrCode}'对应的物料");
                }
        //                countDetailList.Add(countDetail);
        //            }
        //        }
        //        else {
        //            return BuildSimpleResult(3, $"计划单'{model.planId}'的类型{countPlan.S_TYPE}不合法");
        //        }
                var countDiff = new TN_Count_Diff {
                    S_CNTR_CODE = cgDetail.S_CNTR_CODE,
                    F_QTY = cgDetail.F_QTY,
                    F_ACTUAL_QTY = model.qty
                };
        //        using (var tran = db.Ado.UseTran()) {
        //            if (db.Insertable<TN_Count_Order>(countOrder).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                info = "创建盘点单失败";
        //                return BuildSimpleResult(2, info);
        //            }
                if (db.Insertable<TN_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
                    return BuildSimpleResult(3, $"插入盘点差异表失败");
                }
        //            if (db.Insertable<TN_Count_CG_Detail>(countDetailList).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                info = "创建盘点单明细失败";
        //                return BuildSimpleResult(3, info);
        //            }
                return BuildSimpleResult(0, "盘点差异完成");
        //            tran.CommitTran();
        //        }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
            }
        }
        //        return BuildSimpleResult(0, "创建盘点单成功");
        //    }
        //    catch (Exception ex) {
        internal static string GenerateNo(string snType, string prefix) {
            var id = SYSHelper.GetSerialNumber(snType, prefix);
            var date = DateTime.Now.ToString("yyMMdd");
            return $"{prefix}{date}-{id.ToString().PadLeft(5, '0')}"; // 形如:CN250525-00011
        }
        //        return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
        //    }
        //}
        /// <summary>
        /// 盘点理货出库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult CheckOutbound(CheckOutboundInfo model) {
            var taskName = TaskName.盘点理货出库;
            var db = new SqlHelper<object>().GetInstance();
        //public static SimpleResult CountProduct(CountProductInfo model) {
        //    var db = new SqlHelper<object>().GetInstance();
        //    try {
        //        var cgDetail = db.Queryable<TN_CG_Detail>()
        //            .Where(d => d.S_CNTR_CODE == model.cntrCode).First();
            try {
                // 起点位置:取放货区(有货物、没有锁、已启用)
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合出库条件");
                }
        //        if (cgDetail == null) {
        //            return BuildSimpleResult(2, $"找不到容器号'{model.cntrCode}'对应的物料");
        //        }
                var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                if (locCntrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器,无可回库的物料");
                }
        //        var countDiff = new TN_Count_Diff {
        //            S_CNTR_CODE = cgDetail.S_CNTR_CODE,
        //            F_QTY = cgDetail.F_QTY,
        //            F_ACTUAL_QTY = model.qty
        //        };
                // 终点位置:货架(没有货物,没有锁)
                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }
        //        if (db.Insertable<TN_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
        //            return BuildSimpleResult(3, $"插入盘点差异表失败");
        //        }
                var cntID = locCntrRel.S_CNTR_CODE;
                var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
                LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
                LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
        //        return BuildSimpleResult(0, "盘点差异完成");
                using (var tran = db.Ado.UseTran()) {
                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
                        it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货位 {endLoc.S_CODE}");
                    }
        //    }
        //    catch (Exception ex) {
        //        return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
        //    }
        //}
                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
                        it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                    }
        ///// <summary>
        ///// 盘点理货出库(WMS)
        ///// </summary>
        ///// <param name="model"></param>
        ///// <returns></returns>
        //internal static SimpleResult CheckOutbound(CheckOutboundInfo model) {
        //    var taskName = TaskName.盘点理货出库;
        //    var db = new SqlHelper<object>().GetInstance();
                    if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                    }
        //    try {
        //        // 起点位置:取放货区(有货物、没有锁、已启用)
        //        var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
        //        if (startLoc == null) {
        //            return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合出库条件");
        //        }
                    tran.CommitTran();
                    return BuildSimpleResult(0,
                        $"生成 {taskName} 成功,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
            }
        }
        //        var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
        //        if (locCntrRel == null) {
        //            return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器,无可回库的物料");
        //        }
        /// <summary>
        /// 盘点理货回库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult CheckInbound(CheckInboundInfo model) {
            var taskName = TaskName.盘点理货回库;
            var db = new SqlHelper<object>().GetInstance();
        //        // 终点位置:货架(没有货物,没有锁)
        //        var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
        //        if (endLoc == null) {
        //            return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
        //        }
            try {
                // 起点位置:取放货区(有货物、没有锁、已启用)
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合回库条件");
                }
        //        var cntID = locCntrRel.S_CNTR_CODE;
        //        var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
        //        LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
        //        LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
                var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                if (locCntrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器,无可回库的物料");
                }
        //        using (var tran = db.Ado.UseTran()) {
        //            if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
        //                it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货位 {endLoc.S_CODE}");
        //            }
                // 终点位置:货架(没有货物,没有锁)
                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }
        //            if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
        //                it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //            }
                var cntID = locCntrRel.S_CNTR_CODE;
                var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
                LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
                LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
        //            if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //            }
                using (var tran = db.Ado.UseTran()) {
                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
                        it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货位 {endLoc.S_CODE}");
                    }
        //            tran.CommitTran();
        //            return BuildSimpleResult(0,
        //                $"生成 {taskName} 成功,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //        }
        //    }
        //    catch (Exception ex) {
        //        return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
        //    }
        //}
                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
                        it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                    }
        ///// <summary>
        ///// 盘点理货回库(WMS)
        ///// </summary>
        ///// <param name="model"></param>
        ///// <returns></returns>
        //internal static SimpleResult CheckInbound(CheckInboundInfo model) {
        //    var taskName = TaskName.盘点理货回库;
        //    var db = new SqlHelper<object>().GetInstance();
                    if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        return BuildSimpleResult(500,
                            $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                    }
        //    try {
        //        // 起点位置:取放货区(有货物、没有锁、已启用)
        //        var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
        //        if (startLoc == null) {
        //            return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合回库条件");
        //        }
                    tran.CommitTran();
                    return BuildSimpleResult(0,
                        $"生成 {taskName} 成功,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
            }
        }
        //        var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
        //        if (locCntrRel == null) {
        //            return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器,无可回库的物料");
        //        }
        //        // 终点位置:货架(没有货物,没有锁)
        //        var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
        //        if (endLoc == null) {
        //            return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
        //        }
        //        var cntID = locCntrRel.S_CNTR_CODE;
        //        var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
        //        LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
        //        LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
        //        using (var tran = db.Ado.UseTran()) {
        //            if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
        //                it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货位 {endLoc.S_CODE}");
        //            }
        //            if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
        //                it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //            }
        //            if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
        //                tran.RollbackTran();
        //                return BuildSimpleResult(500,
        //                    $"生成 {taskName} 失败,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //            }
        //            tran.CommitTran();
        //            return BuildSimpleResult(0,
        //                $"生成 {taskName} 成功,容器号 {cntID} ,起点 {startLoc.S_CODE} ,终点货架 {endLoc.S_CODE}");
        //        }
        //    }
        //    catch (Exception ex) {
        //        return BuildSimpleResult(1, $"发生了异常:{ex.Message}");
        //    }
        //}
        public static ErpResult InboundDataSync(InboundDataSyncInfo model) {
            //return BuildErpResult(1, "测试");