优化WCSHelper / 序列号生成逻辑 , 添加强制任务处理模块

kazelee

昨天 fc25dda9baf3b5f4df23d35914f3dd343cf492e3

 api/DebugController.cs

@@ -16,12 +16,12 @@

using static HH.WCS.Mobox3.DSZSH.api.ApiModel;
using static HH.WCS.Mobox3.DSZSH.api.OtherModel;
using static HH.WCS.Mobox3.DSZSH.Config;
using static HH.WCS.Mobox3.DSZSH.core.Monitor;
using static HH.WCS.Mobox3.DSZSH.util.Config;

namespace HH.WCS.Mobox3.DSZSH.api {
    /// <summary>
    /// 测试用：如果项目中要和设备对接，前期设备无法测试，用接口模拟
    /// 测试用:如果项目中要和设备对接,前期设备无法测试,用接口模拟
    /// </summary>
    [RoutePrefix("api")]
    public class DebugController : ApiController {
@@ -90,18 +90,18 @@
        }

        /// <summary>
        /// DEBUG：模拟输送线产线满托盘下线流程
        /// DEBUG:模拟输送线产线满托盘下线流程
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("AddInboundTask")]
        public string AddInboundTask(AddInboundTaskInfo model) {
            return WCSCore.CreateInboundTask(model.StartLoc, model.CntrCode).Content;
            return WCSCore.CreateInboundTask(model.StartLoc, model.CntrCode).Item2;
        }

        /// <summary>
        /// DEBUG：模拟人工将料箱搬运到产线上线口（直接修改数据库）
        /// DEBUG:模拟人工将料箱搬运到产线上线口 (直接修改数据库) 
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
@@ -111,23 +111,23 @@

            var db = new SqlHelper<object>().GetInstance();
            try {
                // 查询起点货位：数量=0
                // 查询起点货位:数量=0
                var startLoc = db.Queryable<TN_Location>().LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
                    .Where((l,c) => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y" && l.S_CODE == model.StartLoc && l.N_CURRENT_NUM == 1 && c.S_CNTR_CODE == model.CntrCode).First();
                    .Where((l, c) => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y" && l.S_CODE == model.StartLoc && l.N_CURRENT_NUM == 1 && c.S_CNTR_CODE == model.CntrCode).First();
                if (startLoc == null) {
                    return $"没有找到起点货位'{model.StartLoc}'！要求：锁状态='无'，当前容器数量=1";
                    return $"没有找到起点货位'{model.StartLoc}'!要求:锁状态='无',当前容器数量=1";
                }

                // 查询终点货位
                // Order：按货位层数，从小到大排列
                // Order:按货位层数,从小到大排列
                var endLoc = db.Queryable<TN_Location>().Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y" && l.N_CURRENT_NUM == 0).First();
                if (endLoc == null) {
                    return $"没有找到合适的终点货位！要求：锁状态='无'，当前容器数量=0";
                    return $"没有找到合适的终点货位!要求:锁状态='无',当前容器数量=0";
                }

                var locCntrRel = db.Queryable<TN_Loc_Container>().Where(c => c.S_CNTR_CODE == model.CntrCode).First() ;
                if (locCntrRel == null) {
                    return $"该容器不存在绑定的货位！";
                    return $"该容器不存在绑定的货位!";
                }

                locCntrRel.S_LOC_CODE = model.StartLoc;
@@ -140,21 +140,20 @@
                        db.Updateable(locCntrRel).ExecuteCommand() <= 0) {
                        
                        tran.RollbackTran();
                        return "数据库操作失败！";
                        return "数据库操作失败!";
                    }

                    tran.CommitTran() ;
                    tran.CommitTran();
                    return "数据库操作成功";
                }
            }
            catch (Exception ex) {

                return ex.Message;
            }
        }

        /// <summary>
        /// DEBUG：模拟Erp下发出库计划单
        /// DEBUG:模拟Erp下发出库计划单
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
@@ -175,7 +174,7 @@
        }

        /// <summary>
        /// （内部方法请勿调用）模拟取货完成反馈Erp回报结果（默认为success）
        ///  (内部方法请勿调用) 模拟取货完成反馈Erp回报结果 (默认为success) 
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
@@ -196,7 +195,7 @@
        }

        /// <summary>
        /// （内部方法请勿调用）模拟任务创建完成反馈Erp回报结果（默认为success）
        ///  (内部方法请勿调用) 模拟任务创建完成反馈Erp回报结果 (默认为success) 
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
@@ -215,6 +214,22 @@
                message = "success"
            };
        }

        [HttpPost]
        public string TestDb() {
            var db = new SqlHelper<object>().GetInstance();
            var startAreas = new List<string> { "HJQ", "CKQ" };
            //var locationQuery = db.Queryable<TN_Location>().Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y" && startAreas.Contains(l.S_AREA_CODE) && l.N_CURRENT_NUM == 1).LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE).Where((l, c) => c.S_CNTR_CODE == "a" && c.S_CNTR_TYPE == "b");
            //LogHelper.Info(locationQuery.ToSqlString());
            ////var location = locationQuery.First();
            //var newLocationQuery = DbQuery.StartLoc(db, "a", startAreas);
            //LogHelper.Info(newLocationQuery.ToSqlString());
            //locationQuery = db.Queryable<TN_Location>().LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE).Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y" && startAreas.Contains(l.S_AREA_CODE) && l.N_CURRENT_NUM == 1).Where((l, c) => c.S_CNTR_CODE == "a" && c.S_CNTR_TYPE == "b");

            var locationQuery = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: startAreas));
            LogHelper.Info(locationQuery.ToSqlString());
            return locationQuery.ToSqlString();
        }
    }

    public class GoodpackToProdLineInfo {
@@ -225,15 +240,15 @@

    public class TestErpSendOutboundPlanInfo {
        /// <summary>
        /// 出库计划单号（计划单号 jhdh）
        /// 出库计划单号 (计划单号 jhdh) 
        /// </summary>
        public string PlanNo { get; set; } = string.Empty;
        /// <summary>
        /// 物料编码（产品代码 cpdm）
        /// 物料编码 (产品代码 cpdm) 
        /// </summary>
        public string ItemCode { get; set; } = string.Empty;
        /// <summary>
        /// 物料数量（派装件数 pzjs）
        /// 物料数量 (派装件数 pzjs) 
        /// </summary>
        public float ItemNum { get; set; } = 0;
    }
@@ -245,11 +260,11 @@

    public class AddInboundTaskInfo {
        /// <summary>
        /// 物料编码（暂时没用）
        /// 物料编码 (暂时没用) 
        /// </summary>
        public string ItemCode { get; set; }
        /// <summary>
        /// 批次号（暂时没用）
        /// 批次号 (暂时没用) 
        /// </summary>
        public string BatchNo { get; set; }
        /// <summary>
@@ -263,7 +278,7 @@
    }

    /// <summary>
    /// 模拟 AGV 传递信号，用于更改任务状态
    /// 模拟 AGV 传递信号,用于更改任务状态
    /// </summary>
    public class UpdateTaskState {
        /// <summary>
@@ -286,7 +301,7 @@
        /// </summary>
        public string ForkliftNo { get; set; }
        /// <summary>
        /// AGV 下一状态（任务回报号）
        /// AGV 下一状态 (任务回报号) 
        /// </summary>
        public int NextState { set; get; } = 0;
    }