kazelee
2025-06-06 a949debc0abbe90adfda1af653b7b5c2ab27d997
api/ApiHelper.cs
@@ -32,6 +32,13 @@
            var endAreaName = AreaName.M满箱货架区; // 终点货区
            try {
                // 参数合法性确认部分:错误编码:400
                if (model.Num <= 0 ) {
                    info = $"物料数量{model.Num}不合法:物料数量应该大于 0";
                    LogHelper.Info(info);
                    return NewSimpleResult(400, info);
                }
                // 贴标机会提前将物料信息写入CG_Detail表中
                // 将PDA提供的物料编码与贴标机的信息比对
                var cgDetail = db.Queryable<TN_CG_Detail>()
@@ -70,21 +77,44 @@
                    S_CNTR_TYPE = "好运箱",
                };
                // 每个新插入容器的逻辑,都需要查询这个表是否存在,如果不存在也加入,如果存在:暂不更新结果(待定)
                // 更详细的,是空箱入库,和满料下线这两个流程的容器可能是新的,其余容器一定是旧的,无需再判断
                // 严格来说,容器类型应该放在Container里面的,Loc_Container表只放关系,不过暂时先这样改吧
                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
                var insertContainerItemType = false;
                if (cntrItemRel == null) {
                    insertContainerItemType = true;
                    cntrItemRel = new TN_Container_ItemType {
                        S_ITEM_CODE = cgDetail.S_ITEM_CODE, // 物料类型对于好运箱而言其实不用,主要是类型
                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
                var needInsertContainer = false;
                var needUpdateContainer = false;
                // 查容器信息表是否已经有这个容器
                var cntr = db.Queryable<TN_Container>()
                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
                // 如果找不到该容器,需要添加,并且将容器来源设置为任务名称
                if (cntr == null) {
                    needInsertContainer = true;
                    LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中没有登记,登记并设置容器来源为:{taskName}");
                    cntr = new TN_Container {
                        S_CODE = locCntrRel.S_CNTR_CODE,
                        S_SPEC = cgDetail.S_ITEM_CODE, // 登记容器对应的物料编号
                        S_TYPE = "料箱", // 容器类型:料箱(好运箱)
                        S_SOURCE = taskName,
                    };
                }
                else {
                    // 如果容器存在,但没有类型或没有适用的物料编号,需要更新,并将容器来源设置为任务名称
                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
                        needUpdateContainer = true;
                        LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中登记但没有类型," +
                            $"更新类型为:料箱,并设置容器来源为:{taskName}");
                        cntr.S_TYPE = "料箱"; // 容器类型:料箱(好运箱)
                        cntr.S_SOURCE = taskName;
                    }
                    if (string.IsNullOrEmpty(cntr.S_SPEC)) {
                        needUpdateContainer = true;
                        LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中登记但没有适用物料编码," +
                            $"更新物料编码为:{cgDetail.S_ITEM_CODE},并设置容器来源为:{taskName}");
                        cntr.S_SPEC = cgDetail.S_ITEM_CODE; // 规格:物料编号
                        cntr.S_SOURCE = taskName;
                    }
                }
                // TODO 满箱入库算法待优化
                var endLoc = db.Queryable<TN_Location>()
                    .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) // 终点货区符合任务要求
@@ -99,20 +129,29 @@
                    return NewSimpleResult(4, info);
                }
                // 数据库操作部分
                var cntId = locCntrRel.S_CNTR_CODE;
                var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
                LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁
                LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
                // 数据库操作事务部分:错误编码:500
                using (var tran = db.Ado.UseTran()) {
                    if (insertContainerItemType) {
                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
                            info = $"插入容器信息失败:" + JsonConvert.SerializeObject(cntrItemRel);
                    if (needInsertContainer) {
                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"插入容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(5, info);
                            return NewSimpleResult(500, info);
                        }
                    }
                    else if (needUpdateContainer) {
                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"更新容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(500, info);
                        }
                    }
@@ -120,7 +159,7 @@
                        info = $"插入货位容器关系失败:" + JsonConvert.SerializeObject(locCntrRel);
                        tran.RollbackTran();
                        LogHelper.Info(info);
                        return NewSimpleResult(5, info);
                        return NewSimpleResult(500, info);
                    }
                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
@@ -133,7 +172,7 @@
                        tran.RollbackTran();
                        info = $"生成任务'{taskName}'失败:更新起点货位{startLoc.S_CODE}锁状态失败";
                        LogHelper.Info(info);
                        return NewSimpleResult(5, info);
                        return NewSimpleResult(500, info);
                    }
                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
@@ -145,14 +184,14 @@
                        tran.RollbackTran();
                        info = $"生成任务'{taskName}'失败:更新终点货位{endLoc.S_CODE}锁状态失败";
                        LogHelper.Info(info);
                        return NewSimpleResult(5, info);
                        return NewSimpleResult(500, info);
                    }
                    
                    if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        info = $"生成任务'{taskName}'失败,容器号{cntId},起点{startLoc.S_CODE},终点货架{endLoc.S_CODE}";
                        LogHelper.Info(info);
                        return NewSimpleResult(5, info);
                        return NewSimpleResult(500, info);
                    }
                    tran.CommitTran();
@@ -175,7 +214,7 @@
        /// 人工将空托盘通过接驳位入库,需要新绑定容器货位<br/>
        /// 由于空托盘一般是出库卸货后获得,而出库时没有手动卸货的逻辑,所以需要在入库的时候再删除旧绑定信息
        /// </remarks>
        /// <param name="model"></param>
        /// <param name="model">包含:起点货位、容器号、容器类型、终点货区</param>
        /// <returns></returns>
        public static SimpleResult EmptyInboundPallet(EmptyInboundInfo model) {
            var db = new SqlHelper<object>().GetInstance();
@@ -225,19 +264,34 @@
                    S_CNTR_TYPE = "托盘",
                };
                // 每个新插入容器的逻辑,都需要查询这个表是否存在,如果不存在也加入,如果存在:暂不更新结果(待定)
                // 更详细的,是空箱入库,和满料下线这两个流程的容器可能是新的,其余容器一定是旧的,无需再判断
                // 严格来说,容器类型应该放在Container里面的,Loc_Container表只放关系,不过暂时先这样改吧
                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
                var insertContainerItemType = false;
                if (cntrItemRel == null) {
                    insertContainerItemType = true;
                    cntrItemRel = new TN_Container_ItemType {
                        S_ITEM_CODE = "", // 空托盘刚入库,没有物料类型,就默认先为空
                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
                var needInsertContainer = false;
                var needUpdateContainer = false;
                // 查容器信息表是否已经有这个容器
                var cntr = db.Queryable<TN_Container>()
                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
                // 如果找不到该容器,需要添加,并且将容器来源设置为任务名称
                if (cntr == null) {
                    needInsertContainer = true;
                    LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中没有登记,登记并设置容器来源为:{taskName}");
                    cntr = new TN_Container {
                        S_CODE = locCntrRel.S_CNTR_CODE,
                        S_SPEC = "", // 空托,物料编码先设置为空
                        S_TYPE = locCntrRel.S_CNTR_TYPE, // 容器类型:托盘
                        S_SOURCE = taskName,
                    };
                }
                else {
                    // 如果容器存在,但没有类型或没有适用的物料编号,需要更新,并将容器来源设置为任务名称
                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
                        needUpdateContainer = true;
                        LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中登记但没有类型," +
                            $"更新类型为:托盘,并设置容器来源为:{taskName}");
                        cntr.S_TYPE = "托盘"; // 容器类型:托盘
                    }
                    // 空托不更新物料编码
                }
                // TODO 暂定选择最低层按区位顺序入库,后面待修改
@@ -261,12 +315,20 @@
                LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
                using (var tran = db.Ado.UseTran()) {
                    if (insertContainerItemType) {
                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
                            info = $"插入容器信息失败:" + JsonConvert.SerializeObject(cntrItemRel);
                    if (needInsertContainer) {
                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"插入容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(5, info);
                            return NewSimpleResult(500, info);
                        }
                    }
                    else if (needUpdateContainer) {
                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"更新容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(500, info);
                        }
                    }
@@ -403,19 +465,34 @@
                    S_CNTR_TYPE = "好运箱",
                };
                // 每个新插入容器的逻辑,都需要查询这个表是否存在,如果不存在也加入,如果存在:暂不更新结果(待定)
                // 更详细的,是空箱入库,和满料下线这两个流程的容器可能是新的,其余容器一定是旧的,无需再判断
                // 严格来说,容器类型应该放在Container里面的,Loc_Container表只放关系,不过暂时先这样改吧
                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
                var insertContainerItemType = false;
                if (cntrItemRel == null) {
                    insertContainerItemType = true;
                    cntrItemRel = new TN_Container_ItemType {
                        S_ITEM_CODE = "", // 空托盘刚入库,没有物料类型,就默认先为空
                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
                var needInsertContainer = false;
                var needUpdateContainer = false;
                // 查容器信息表是否已经有这个容器
                var cntr = db.Queryable<TN_Container>()
                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
                // 如果找不到该容器,需要添加,并且将容器来源设置为任务名称
                if (cntr == null) {
                    needInsertContainer = true;
                    LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中没有登记,登记并设置容器来源为:{taskName}");
                    cntr = new TN_Container {
                        S_CODE = locCntrRel.S_CNTR_CODE,
                        S_SPEC = "", // 空箱,物料编码先设置为空
                        S_TYPE = locCntrRel.S_CNTR_TYPE, // 容器类型:料箱(好运箱)
                        S_SOURCE = taskName,
                    };
                }
                else {
                    // 如果容器存在,但没有类型或没有适用的物料编号,需要更新,并将容器来源设置为任务名称
                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
                        needUpdateContainer = true;
                        LogHelper.Info($"起点货位的容器:{locCntrRel.S_CNTR_CODE},在容器表中登记但没有类型," +
                            $"更新类型为:料箱,并设置容器来源为:{taskName}");
                        cntr.S_TYPE = "料箱"; // 容器类型:料箱(好运箱)
                    }
                    // 空箱不更新物料编码
                }
                // TODO 暂定选择最低层顺序入库,后面待修改
@@ -439,12 +516,20 @@
                LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
                using (var tran = db.Ado.UseTran()) {
                    if (insertContainerItemType) {
                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
                            info = $"插入容器信息失败:" + JsonConvert.SerializeObject(cntrItemRel);
                    if (needInsertContainer) {
                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"插入容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(5, info);
                            return NewSimpleResult(500, info);
                        }
                    }
                    else if (needUpdateContainer) {
                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                            info = $"更新容器表失败:" + JsonConvert.SerializeObject(cntr);
                            tran.RollbackTran();
                            LogHelper.Info(info);
                            return NewSimpleResult(500, info);
                        }
                    }
@@ -532,7 +617,7 @@
        /// <remarks>
        /// 人工根据当前生产物料所需的容器类型,呼叫AGV从空容器货架中叫一个符合要求的托盘
        /// </remarks>
        /// <param name="model"></param>
        /// <param name="model">b包含:容器号、物料编码</param>
        /// <returns></returns>
        public static SimpleResult EmptyOnlinePallet(EmptyOnlinePalletInfo model) {
            var db = new SqlHelper<object>().GetInstance();
@@ -543,16 +628,24 @@
            var endAreaName = AreaName.B包装区;
            try {
                // 查容器-物料类型表
                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
                    .Where(i => i.S_CNTR_CODE == model.CntId && i.S_CNTR_TYPE == "托盘")
                    .First();
                // 如果表中存在这个托盘信息,且物料类型与上线所需物料不符,报错
                // 查容器信息表是否已经有这个容器
                var cntr = db.Queryable<TN_Container>()
                    .Where(c => c.S_CODE == model.CntId).First();
                // 如果表中存在这个托盘信息,但容器类型、物料类型与上线所需物料不符,报错
                // 如果不存在,不作限制(视作第一次上线)
                if (cntrItemRel != null && cntrItemRel.S_ITEM_CODE != model.ItemCode) {
                    info = $"容器{model.CntId}已经与物料类型{cntrItemRel.S_ITEM_CODE}绑定,无法用于装载物料{model.ItemCode}";
                    LogHelper.Info(info);
                    return NewSimpleResult(2, info);
                if (cntr != null) {
                    // 如果存在容器号,但类型不是托盘,报错
                    if (!string.IsNullOrEmpty(cntr.S_TYPE) && cntr.S_TYPE != "托盘") {
                        info = $"容器在容器表中找到,但类型是:{cntr.S_TYPE},不是{taskName}所需的:托盘";
                        LogHelper.Info(info);
                        return NewSimpleResult(1, info);
                    }
                    // 如果表中物料编码不为空,且与上线所需物料不一致,报错
                    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != model.ItemCode) {
                        info = $"容器{model.CntId}已经与物料类型{cntr.S_SPEC}绑定,无法用于装载物料{model.ItemCode}";
                        LogHelper.Info(info);
                        return NewSimpleResult(2, info);
                    }
                }
                var startLoc = db.Queryable<TN_Location>()
@@ -742,12 +835,20 @@
                    .First();
                if (cgDetail == null) {
                    return NewSimpleResult(2, "没有找到待回库的抽检物料:" + JsonConvert.SerializeObject(model));
                    info = "没有找到待回库的抽检物料:" + JsonConvert.SerializeObject(model);
                    LogHelper.Info(info);
                    return NewSimpleResult(2, info);
                }
                var locCntrRel = db.Queryable<TN_Loc_Container>()
                    .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE)
                    .First();
                if (locCntrRel == null) {
                    info = $"容器{model.CntrCode}在货位容器关系表中不存在";
                    LogHelper.Info(info);
                    return NewSimpleResult(3, info);
                }
                var startLoc = db.Queryable<TN_Location>()
                    .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE)
@@ -759,7 +860,7 @@
                if (startLoc == null) {
                    info = $"在'{startAreaName}'中没有找到容器{model.CntrCode}的起点货位,或不具备取货要求:未上锁、有货物";
                    LogHelper.Info(info);
                    return NewSimpleResult(0, info);
                    return NewSimpleResult(4, info);
                }
                var endLoc = new TN_Location();
@@ -778,7 +879,7 @@
                        .First();
                }
                else {
                    return NewSimpleResult(2, $"托盘类型{locCntrRel.S_CNTR_TYPE}不合法:托盘号{locCntrRel.S_CNTR_CODE}");
                    return NewSimpleResult(-1, $"托盘类型{locCntrRel.S_CNTR_TYPE}不合法:托盘号{locCntrRel.S_CNTR_CODE}");
                }
                if (endLoc == null) {
@@ -880,6 +981,12 @@
                var locCntrRel = db.Queryable<TN_Loc_Container>()
                    .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE)
                    .First();
                if (locCntrRel == null) {
                    info = $"容器{model.CntrCode}在货位容器关系表中不存在";
                    LogHelper.Info(info);
                    return NewSimpleResult(3, info);
                }
                var startLoc = db.Queryable<TN_Location>()
                    .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE)
@@ -1307,12 +1414,33 @@
            var info = "";
            try {
                if (string.IsNullOrEmpty(model.ItemCode)) {
                    info = $"博实下发物料信息:参数不合法:物料编码(itemCode)不能为空";
                    LogHelper.Info(info);
                    return NewMesResult(400, info);
                }
                if (string.IsNullOrEmpty(model.CntrCode)) {
                    info = $"博实下发物料信息:参数不合法:容器编码(CntrCode)不能为空";
                    LogHelper.Info(info);
                    return NewMesResult(400, info);
                }
                if (string.IsNullOrEmpty(model.BatchNo)) {
                    info = $"博实下发物料信息:参数不合法:批次号(BatchNo)不能为空";
                    LogHelper.Info(info);
                    return NewMesResult(400, info);
                }
                if (model.ItemNum <= 0) {
                    info = $"博实下发物料信息:参数不合法:货品数量(ItemNum)应该大于 0";
                    LogHelper.Info(info);
                    return NewMesResult(400, info);
                }
                // 将下发的信息先存储到CG表中(此时托盘没有与产线处的货位绑定)
                var detail = new TN_CG_Detail {
                    S_ITEM_CODE = model.ItemCode,
                    S_ITEM_NAME = model.ItemName,
                    S_CNTR_CODE = model.CntrCode, // 料箱编号(待定,现在暂时设定为博实下发)
                    S_BATCH_NO = model.BatchNo,
                    S_ITEM_CODE = model.ItemCode, // NOT NULL
                    S_ITEM_NAME = model.ItemName,
                    S_CNTR_CODE = model.CntrCode, // NOT NULL 料箱编号(待定,现在暂时设定为博实下发)
                    S_BATCH_NO = model.BatchNo,   // NOT NULL
                    S_STANDARD = model.Standard,
                    S_NET_WEIGHT = model.NetWeight,
                    S_QUALITY_GRADE = model.QualityGrade,
@@ -1335,7 +1463,7 @@
                    if (db.Insertable<TN_CG_Detail>(detail).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
                        info = "插入物料信息失败:" + JsonConvert.SerializeObject(detail);
                        return NewMesResult(2, info);
                        return NewMesResult(500, info);
                    }
                    tran.CommitTran();