kazelee
2025-06-23 6b9801e47304eac1640cf737ef6bc039ff104dd1
api/DebugController.cs
@@ -11,7 +11,10 @@
using Newtonsoft.Json;
using SqlSugar;
using static HH.WCS.Mobox3.DSZSH.api.ApiModel;
using static HH.WCS.Mobox3.DSZSH.api.OtherModel;
using static HH.WCS.Mobox3.DSZSH.core.Monitor;
namespace HH.WCS.Mobox3.DSZSH.api {
@@ -19,8 +22,7 @@
    /// 测试用:如果项目中要和设备对接,前期设备无法测试,用接口模拟
    /// </summary>
    [RoutePrefix("api")]
    public class DebugController : ApiController
    {
    public class DebugController : ApiController {
        /// <summary>
        /// AGV状态一键回报134562
        /// </summary>
@@ -29,22 +31,15 @@
        [HttpPost]
        [Route("AGVSeriesReports")]
        public ReturnResults AGVSeriesReports(UpdateTaskState model) {
            //var db = new SqlHelper<object>().GetInstance();
            //var task = db.Queryable<TN_Task>().Where(t => t.S_CODE == model.TaskID).First();
            //if (task == null) return new ReturnResults();
            //if (task.S_B_STATE == "完成" && task.N_B_STATE == 3 || task.S_B_STATE == "错误" && task.N_B_STATE == 4) {
            //    return new ReturnResults();
            //}
            ReturnResults returnResult = new ReturnResults();
            returnResult.ResultList = new List<ReturnResult>();
            var agvTaskState = new AgvTaskState() {
                task_no = model.TaskID,
                forklift_no = model.ForkliftNo,
                state = 1
            };
            ReturnResults returnResult = new ReturnResults();
            returnResult.ResultList = new List<ReturnResult>();
            agvTaskState.state = 1;
            var temp1 = WCSCore.OperateAgvTaskStatus(agvTaskState);
            returnResult.ResultList.Add(temp1);
@@ -67,6 +62,73 @@
            agvTaskState.state = 2;
            var temp2 = WCSCore.OperateAgvTaskStatus(agvTaskState);
            returnResult.ResultList.Add(temp2);
            return returnResult;
        }
        /// <summary>
        /// 模拟AGV回报任务状态(指定下一个状态,用于需要分段测试的场景)<br/>
        /// 性能相对较差,仅用于测试,一般不使用
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("AgvReports")]
        public ReturnResults AgvReports(AgvReportsInfo model) {
            var db = new SqlHelper<object>().GetInstance();
            ReturnResults returnResult = new ReturnResults();
            returnResult.ResultList = new List<ReturnResult>();
            var agvTaskState = new AgvTaskState() {
                task_no = model.TaskId,
                forklift_no = model.ForkliftNo,
            };
            var taskAction = db.Queryable<TN_Task_Action>()
                .Where(t => t.S_TASK_CODE == model.TaskId)
                .OrderBy(t => new { create = SqlFunc.Desc(t.T_CREATE) }).First(); // 最后一个Action状态
            var lastState = taskAction?.N_ACTION_CODE ?? 0;
            if (model.NextState <= 0 || model.NextState >= 7) {
                LogHelper.Info("小车回报状态不在134562的范围内");
            }
            // 0 ==> 1,3,4,5,6,2
            if (lastState == 0 && model.NextState >= 1) {
                agvTaskState.state = 1;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            // 0,1 ==> 3,4,5,6,2
            if (lastState < 2 && model.NextState >= 2) {
                agvTaskState.state = 3;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            // 0,1,3 ==> 4,5,6,2
            if (lastState < 4 && lastState != 2 && (model.NextState >= 3 || model.NextState == 2)) {
                agvTaskState.state = 4;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            // 0,1,3,4 ==> 5,6,2
            if (lastState < 5 && lastState != 2 && (model.NextState >= 4 || model.NextState == 2)) {
                agvTaskState.state = 5;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            // 0,1,3,4,5 ==> 6,2
            if (lastState < 6 && lastState != 2 && (model.NextState >= 5 || model.NextState == 2)) {
                agvTaskState.state = 6;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            // 0,1,3,4,5,6 ==> 2
            if (lastState != 2 && model.NextState == 2) {
                agvTaskState.state = 2;
                var temp = WCSCore.OperateAgvTaskStatus(agvTaskState);
                returnResult.ResultList.Add(temp);
            }
            return returnResult;
        }
@@ -137,47 +199,13 @@
        /// <returns></returns>
        [HttpPost]
        [Route("CreateDatabase")]
        public string CreateDatabase(FalseOk model) {
        public string CreateDatabase() {
            try {
                if (model.JumpOut) {
                    return "跳出";
                }
                var db = new SqlHelper<object>().GetInstance();
                var entityTypes = new Type[] {
                    //typeof(TN_CAR_IN),
                    //typeof(TN_CG_Detail),
                    //typeof(TN_Container),
                    //typeof(TN_Loc_Container),
                    //typeof(TN_Location),
                    //typeof(TN_Task),
                    //typeof(TN_Task_Action),
                    //typeof(SysHelper.OI_SYS_MAXID),
                var entityTypes = new Type[] { };
                    //typeof(TN_Inbound_Order),
                    //typeof(TN_Check_Detail),
                    //typeof(TN_Check_Order),
                    //typeof(TN_CNTR_ITEM),
                    //typeof(TN_Outbound_Detail),
                    //typeof(TN_Outbound_Order),
                    //typeof(TN_Shift_Order),
                    //typeof(TN_Shift_Detail)
                    //typeof(TN_Container_Item),
                };
                //using (var tran = db.Ado.UseTran()) {
                //    //db.CodeFirst.InitTables(entityTypes);
                //    if (db.Insertable<TN_Location>(locationList).ExecuteCommand() <= 0) {
                //        tran.RollbackTran();
                //        return "失败";
                //    }
                //    tran.CommitTran();
                //}
                //db.CodeFirst.InitTables(entityTypes);
            }
            catch (Exception ex) {
                LogHelper.Info($"发生了异常");
@@ -203,45 +231,8 @@
            const string cntrType = "托盘";
            try {
                //var itemCode = model.ItemCode;
                //var batchNo = model.BatchNo;
                var cntrCode = model.CntrCode;
                var startLocCode = model.StartLoc;
                //var cgDetail = new TN_CG_Detail {
                //    S_ITEM_CODE = itemCode,
                //    S_BATCH_NO = batchNo,
                //    S_CNTR_CODE = cntrCode,
                //};
                //var needInsertContainer = false;
                //var needUpdateContainer = false;
                // 查容器信息表是否已经有这个容器
                //var cntr = db.Queryable<TN_Container>()
                //    .Where(c => c.S_CODE == cntrCode).First();
                // 如果找不到该容器,需要添加,并且将容器来源设置为任务名称
                //if (cntr == null) {
                //    needInsertContainer = true;
                //    LogHelper.Info($"轮询:{taskName}:容器:{cntrCode},在容器表中没有登记,登记并设置容器来源为:{taskName}");
                //    cntr = new TN_Container {
                //        S_CODE = cntrCode,
                //        S_TYPE = "托盘",
                //        S_SPEC = itemCode,
                //        S_SOURCE = taskName,
                //    };
                //}
                //else {
                //    // 如果找到该容器,但容器物料类型与下线物料不符,记录并直接覆盖(待定)
                //    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != itemCode) {
                //        needUpdateContainer = true;
                //        LogHelper.Info($"轮询:{taskName}:容器表中容器{cntrCode}对应的物料信息:{cntr.S_SPEC}," +
                //            $"与所需要的物料信息{itemCode}不符,直接覆盖结果");
                //        cntr.S_SPEC = itemCode;
                //        cntr.S_SOURCE = taskName;
                //    }
                //}
                var startLoc = db.Queryable<TN_Location>()
                    .Where(l => l.S_CODE == startLocCode)
@@ -297,29 +288,6 @@
                            return info;
                        }
                    }
                    //if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
                    //    tran.RollbackTran();
                    //    info = $"插入容器货品信息表失败:物料编码{cgDetail.S_ITEM_CODE},容器编码{cgDetail.S_CNTR_CODE}";
                    //    LogHelper.Info(info);
                    //    return info;
                    //}
                    //if (needInsertContainer) {
                    //    if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                    //        info = $"插入容器表失败:" + JsonConvert.SerializeObject(cntr);
                    //        tran.RollbackTran();
                    //        LogHelper.Info(info);
                    //        return info;
                    //    }
                    //}
                    //else if (needUpdateContainer) {
                    //    if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
                    //        info = $"更新容器表失败:" + JsonConvert.SerializeObject(cntr);
                    //        tran.RollbackTran();
                    //        LogHelper.Info(info);
                    //        return info;
                    //    }
                    //}
                    if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
                        tran.RollbackTran();
@@ -366,6 +334,89 @@
                return ex.Message;
            }
        }
        /// <summary>
        /// 模拟Erp下发出库计划单
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("TestErpSendOutboundPlan")]
        public ErpResult TestErpSendOutboundPlan(TestErpSendOutboundPlanInfo model) {
            var apiName = "ERP下发出库计划单";
            //LogHelper.InfoApi(apiName, model);
            var erpModel = new ErpSendOutboundPlanInfo();
            erpModel.jhdh = model.PlanNo;
            erpModel.cpdm = model.ItemCode;
            erpModel.pzjs = model.ItemNum;
            LogHelper.InfoApi(apiName, erpModel);
            return ApiHelper.ErpSendOutboundPlan(erpModel);
        }
        /// <summary>
        /// (内部方法请勿调用)模拟取货完成反馈Erp回报结果(默认为success)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("PickUpReturn")]
        public TestErpResult PickUpReturn(PickUpReturnErpInfo model) {
            if (model.sfjs == 0) {
                return new TestErpResult {
                    code = 1,
                    message = "实发件数未确定"
                };
            }
            return new TestErpResult {
                code = 0,
                message = "success"
            };
        }
        /// <summary>
        /// (内部方法请勿调用)模拟任务创建完成反馈Erp回报结果(默认为success)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("CreateTaskReturn")]
        public TestErpResult CreateTaskReturn(CreateTaskReturnErpInfo model) {
            if (model.hw == "") {
                return new TestErpResult {
                    code = 1,
                    message = "货位信息未提供"
                };
            }
            return new TestErpResult {
                code = 0,
                message = "success"
            };
        }
    }
    public class TestErpSendOutboundPlanInfo {
        /// <summary>
        /// 出库计划单号(计划单号 jhdh)
        /// </summary>
        public string PlanNo { get; set; } = string.Empty;
        /// <summary>
        /// 物料编码(产品代码 cpdm)
        /// </summary>
        public string ItemCode { get; set; } = string.Empty;
        /// <summary>
        /// 物料数量(派装件数 pzjs)
        /// </summary>
        public float ItemNum { get; set; } = 0;
    }
    public class TestErpResult {
        public int code { get; set; }
        public string message { get; set; }
    }
    public class AddInboundTaskInfo {
@@ -405,6 +456,21 @@
        //public int NextState { set; get; }
    }
    public class AgvReportsInfo {
        /// <summary>
        /// 任务号
        /// </summary>
        public string TaskId { set; get; }
        /// <summary>
        /// AGV 小车号
        /// </summary>
        public string ForkliftNo { get; set; }
        /// <summary>
        /// AGV 下一状态(任务回报号)
        /// </summary>
        public int NextState { set; get; } = 0;
    }
    public class FalseOk {
        public bool JumpOut { set; get; } = true;
    }