| | |
| | | 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; |
| | |
| | | } |
| | | } |
| | | |
| | | //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选择终点货位 |
| | |
| | | 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(); |
| | |
| | | |
| | | 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 { |
| | |
| | | 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) { |
| | |
| | | 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); // 备用函数,如果甲方要求任务执行中也取消,再调用 |
| | | } |
| | | |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | 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, "测试"); |