| | |
| | | |
| | | 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 { |
| | |
| | | /// 测试用:如果项目中要和设备对接,前期设备无法测试,用接口模拟 |
| | | /// </summary> |
| | | [RoutePrefix("api")] |
| | | public class DebugController : ApiController |
| | | { |
| | | public class DebugController : ApiController { |
| | | /// <summary> |
| | | /// AGV状态一键回报134562 |
| | | /// </summary> |
| | |
| | | [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); |
| | | |
| | |
| | | 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; |
| | | } |
| | |
| | | /// <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($"发生了异常"); |
| | |
| | | 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) |
| | |
| | | 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(); |
| | |
| | | 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 { |
| | |
| | | //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; |
| | | } |