From 6b43055b5aa32dbea0dacee5a0235b0d5a76c293 Mon Sep 17 00:00:00 2001 From: kazelee <1847801760@qq.com> Date: 星期五, 30 五月 2025 17:19:35 +0800 Subject: [PATCH] 优化后台报错信息,空箱入库容器号增加检查逻辑 --- api/ApiHelper.cs | 1165 +++++++++++++++++++++++++-------------------------------- 1 files changed, 511 insertions(+), 654 deletions(-) diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs index 0d86eb0..fa5a44d 100644 --- a/api/ApiHelper.cs +++ b/api/ApiHelper.cs @@ -1,60 +1,63 @@ 锘縰sing System; using System.Collections.Generic; using System.Linq; -using System.Text; -using System.Threading.Tasks; using HH.WCS.Mobox3.DSZSH.models; using HH.WCS.Mobox3.DSZSH.util; using HH.WCS.Mobox3.DSZSH.wms; using Newtonsoft.Json; -using SqlSugar; -using Swashbuckle.Swagger; +using SqlSugar; using static HH.WCS.Mobox3.DSZSH.api.ApiModel; using static HH.WCS.Mobox3.DSZSH.api.OtherModel; -using static HH.WCS.Mobox3.DSZSH.Config; - namespace HH.WCS.Mobox3.DSZSH.api { public class ApiHelper { /// <summary> - /// 濂借繍绠�婊℃墭涓嬬嚎鍏ュ簱(PDA) + /// 濂借繍绠�婊$涓嬬嚎鍏ュ簱(PDA) /// </summary> - /// <param name="model"></param> + /// <param name="model">鍖呭惈锛氱墿鏂欎俊鎭�璧风偣璐т綅</param> /// <returns></returns> public static SimpleResult GoodpackOffline(GoodpackOfflineInfo model) { - var taskName = TaskName.濂借繍绠盻婊$涓嬬嚎鍏ュ簱; // 鐢ㄤ簬鐢熸垚浠诲姟绫诲瀷銆佹墦鍗版棩蹇椾俊鎭� var db = new SqlHelper<object>().GetInstance(); var info = ""; + + var taskName = TaskName.H濂借繍绠盻婊$涓嬬嚎鍏ュ簱; // 鐢ㄤ簬鐢熸垚浠诲姟绫诲瀷銆佹墦鍗版棩蹇椾俊鎭�+ var startAreaName = AreaName.M婊$鎿嶄綔鍖� // 璧风偣璐у尯 + var endAreaName = AreaName.M婊$璐ф灦鍖� // 缁堢偣璐у尯 + try { + // 璐存爣鏈轰細鎻愬墠灏嗙墿鏂欎俊鎭啓鍏G_Detail琛ㄤ腑 // 灏哖DA鎻愪緵鐨勭墿鏂欑紪鐮佷笌璐存爣鏈虹殑淇℃伅姣斿 var cgDetail = db.Queryable<TN_CG_Detail>() .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.BatchNo) // 鎸囧畾锛氱墿鏂欑紪鐮併�鎵规鍙�- .Where(d => d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "寰呮") // NOTE 鍐椾綑妫�煡锛氱墿鏂欑姸鎬佸簲璇ヤ负 1寰呮 + .Where(d => d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "寰呮") // 鏂板鐗╂枡锛屾晠鐗╂枡鐘舵�搴旇涓�1寰呮 + // TODO model 涓�鏁伴噺銆佽鏍兼槸鍚︿篃鍙備笌姣斿 寰呭悗缁姹� .First(); - + // 濡傛灉鎵句笉鍒版寚瀹氱殑鐗╂枡锛岃鏄庝俊鎭笉涓�嚧锛屾姤閿� if (cgDetail == null) { info = $"PDA鎵爜鐗╂枡淇℃伅涓庤创鏍囨満浼犻�鐨勪俊鎭笉涓�嚧锛� + JsonConvert.SerializeObject(model); LogHelper.Info(info); - return NewSimpleResult(1, info); + return NewSimpleResult(2, info); } + // 鏌ヨ璧风偣璐т綅锛屾槸鍚︾鍚堣姹傦紙鍒濇涓嬬嚎瑕佹眰璐т綅鏃犲鍣級 var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == model.StartLoc) // 鎸囧畾锛氳捣鐐硅揣浣嶅彿 .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 0) // 璧风偣缁戝畾鍓嶆病鏈夊鍣�+ .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 .First(); if (startLoc == null) { - info = $"璧风偣浣嶇疆 '{model.StartLoc}' 涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣峽model.StartLoc}锛屾垨涓嶅叿澶囧彇璐ц姹傦細鏈笂閿併�缁戝畾鍓嶆棤璐х墿"; LogHelper.Info(info); return NewSimpleResult(3, info); } - // 缁戝畾璐т綅鍜屽鍣ㄥ彿 + // 缁戝畾璐т綅鍜屽鍣ㄥ彿锛堟弧绠变笅绾垮埌鎿嶄綔鍖猴紝姝ゆ椂灏氭湭缁戝畾锛� var locCntrRel = new TN_Loc_Container { S_LOC_CODE = model.StartLoc, S_CNTR_CODE = cgDetail.S_CNTR_CODE, @@ -63,14 +66,14 @@ // TODO 婊$鍏ュ簱绠楁硶寰呬紭鍖� var endLoc = db.Queryable<TN_Location>() - .Where(a => Settings.AreaMap[AreaName.婊℃墭瀛樻斁鍖篯.Contains(a.S_AREA_CODE)) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 0) // 绛涢�锛氱┖璐т綅 - .OrderBy(l => l.N_LAYER) + .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) // 缁堢偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 + .Where(l => l.N_CURRENT_NUM == 0) // 绛涢�锛氱┖璐т綅 + .OrderBy(l => l.N_LAYER) // 鎸夎揣鏋舵渶浣庢帓搴� .First(); if (endLoc == null) { - info = "婊$鍏ュ簱鏆傛椂娌℃湁鍚堥�鐨勮揣浣嶅彲浠ュ叆搴�; + info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�鏃犺揣鐗�; LogHelper.Info(info); return NewSimpleResult(4, info); } @@ -78,8 +81,246 @@ var cntId = locCntrRel.S_CNTR_CODE; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿�+ + using (var tran = db.Ado.UseTran()) { + if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { + info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); + tran.RollbackTran(); + LogHelper.Info(info); + return NewSimpleResult(5, info); + } + + 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(); + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + LogHelper.Info(info); + return NewSimpleResult(5, info); + } + + 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(); + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + LogHelper.Info(info); + return NewSimpleResult(5, 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); + } + + tran.CommitTran(); + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + LogHelper.Info(info); + return NewSimpleResult(0, info); + } + } + catch (Exception ex) { + info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; + LogHelper.InfoEx(ex); + return NewSimpleResult(1, info); + } + } + + /// <summary> + /// 鎵樼洏-绌烘墭鍏ュ簱(PDA) + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + public static SimpleResult EmptyInboundPallet(EmptyInboundInfo model) { + var db = new SqlHelper<object>().GetInstance(); + var info = ""; + + var taskName = TaskName.T鎵樼洏_绌烘墭鍏ュ簱; + var startAreaName = AreaName.K绌烘墭鍏ュ簱鎺ラ┏鍖� + var endAreaName = AreaName.K绌烘墭瀛樻斁鍖� + + try { + // 鐜板湪PDA娌℃湁鍗曠嫭鐨勭粦瀹氭祦绋嬶紝缁戝畾鍦ㄥ叆搴撴椂瀹屾垚 + var startLoc = db.Queryable<TN_Location>() + .Where(l => l.S_CODE == model.StartLoc) // 鎸囧畾锛氳捣鐐硅揣浣�+ .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 + .Where(l => l.N_CURRENT_NUM == 0) // 缁戝畾鍓嶈揣浣嶄负绌�+ .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .First(); + + if (startLoc == null) { + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣峽model.StartLoc}锛屾垨涓嶅叿澶囪姹傦細鏈笂閿併�缁戝畾鍓嶆棤璐х墿"; + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + + //// 鏌ョ湅瀹瑰櫒鏄惁宸叉湁鐗╂枡缁戝畾 + //var cgDetail = db.Queryable<TN_CG_Detail>() + // .Where(d => d.S_CNTR_CODE == model.CntrCode).First(); + //// 濡傛灉鏈夌粦瀹氱墿鏂欙紝鎶ラ敊锛屽洜涓虹┖鎵樹笉搴旇鏈夌墿鏂�+ //if (cgDetail != null) { + // info = $"瀹瑰櫒{model.CntrCode}宸茬粡缁戝畾浜嗙墿鏂檣cgDetail.S_ITEM_CODE}锛屼笉鏄┖鎵樻棤娉曞叆搴�; + // LogHelper.Info(info); + // return NewSimpleResult(3, info); + //} + + // 鍋囧畾浜哄伐涓嶄細灏嗘湁鐗╂枡鐨勭瀛愭斁鍦ㄧ┖绠卞叆搴撴帴椹充綅锛屾病鏈夊繀瑕佹鏌�+ // 濡傛灉浜哄伐灏嗗嚭搴撳悗鐨勬墭鐩樺叆搴擄紝杩欐椂鐗╂枡淇℃伅骞舵病鏈夊垹闄わ紝闇�灏嗘墭鐩樼墿鏂欑殑鍏崇郴瑙i櫎 + var cgDetail = db.Queryable<TN_CG_Detail>() + .Where(d => d.S_CNTR_CODE == model.CntrCode).First(); + var needDeleteDetail = cgDetail != null; + + // 缁戝畾璐т綅鍜屽鍣ㄥ彿锛圥DA鍦ㄦ帴椹充綅缁戝畾 + var locCntrRel = new TN_Loc_Container { + S_LOC_CODE = model.StartLoc, + S_CNTR_CODE = model.CntrCode, + S_CNTR_TYPE = "鎵樼洏", + }; + + // TODO 鏆傚畾閫夋嫨鏈�綆灞傛寜鍖轰綅椤哄簭鍏ュ簱锛屽悗闈㈠緟淇敼 + var endLoc = db.Queryable<TN_Location>() + .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) // 缁堢偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 + .Where(l => l.N_CURRENT_NUM == 0) + .OrderBy(l => new { l.N_LAYER, l.N_ROW, l.N_COL }) + .First(); + + if (endLoc == null) { + info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�鏃犺揣鐗�; + LogHelper.Info(info); + 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); // 缁堢偣鍏ュ簱閿�+ + using (var tran = db.Ado.UseTran()) { + if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { + info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); + tran.RollbackTran(); + LogHelper.Info(info); + return NewSimpleResult(5, info); + } + + 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(); + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + LogHelper.Info(info); + return NewSimpleResult(5, info); + } + + 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(); + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + LogHelper.Info(info); + return NewSimpleResult(5, 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); + } + + tran.CommitTran(); + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + LogHelper.Info(info); + return NewSimpleResult(0, info); + } + } + catch (Exception ex) { + info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; + LogHelper.InfoEx(ex); + return NewSimpleResult(1, info); + } + } + + /// <summary> + /// 濂借繍绠�绌虹鍏ュ簱(PDA) + /// </summary> + /// <returns></returns> + public static SimpleResult EmptyInboundGoodpack(EmptyInboundInfo model) { + var db = new SqlHelper<object>().GetInstance(); + var info = ""; + + var taskName = TaskName.H濂借繍绠盻绌虹鍏ュ簱; + var startAreaName = AreaName.K绌虹鍏ュ簱鎺ラ┏鍖� + var endAreaName = AreaName.K绌虹璐ф灦鍖� + + try { + var startLoc = db.Queryable<TN_Location>() + .Where(l => l.S_CODE == model.StartLoc) + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") + .Where(l => l.N_CURRENT_NUM == 0) // 缁戝畾鍓嶈揣浣嶄负绌�+ .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .First(); + + if (startLoc == null) { + info = $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�; + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + + // 鏌ョ湅瀹瑰櫒鏄惁宸叉湁鐗╂枡缁戝畾 + var cgDetail = db.Queryable<TN_CG_Detail>() + .Where(d => d.S_CNTR_CODE == model.CntrCode).First(); + // 濡傛灉鏈夌粦瀹氱墿鏂欙紝鎶ラ敊锛屽洜涓虹┖绠变笉搴旇鏈夌墿鏂�+ if (cgDetail != null) { + info = $"瀹瑰櫒{model.CntrCode}宸茬粡缁戝畾浜嗙墿鏂檣cgDetail.S_ITEM_CODE}锛屼笉鏄┖绠辨棤娉曞叆搴�; + LogHelper.Info(info); + return NewSimpleResult(3, info); + } + + // 缁戝畾璐т綅鍜屽鍣ㄥ彿 + var locCntrRel = new TN_Loc_Container { + S_LOC_CODE = model.StartLoc, + S_CNTR_CODE = model.CntrCode, + S_CNTR_TYPE = "濂借繍绠�, + }; + + // TODO 鏆傚畾閫夋嫨鏈�綆灞傞『搴忓叆搴擄紝鍚庨潰寰呬慨鏀�+ var endLoc = db.Queryable<TN_Location>() + .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") + .Where(l => l.N_CURRENT_NUM == 0) + .OrderBy(l => new { l.N_LAYER }) + .First(); + + if (endLoc == null) { + info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�鏃犺揣鐗�; + LogHelper.Info(info); + 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); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { @@ -133,345 +374,63 @@ } } - ///// <summary> - ///// 绌烘墭鐩樼粦瀹�PDA) - ///// </summary> - ///// <param name="model"></param> - ///// <returns></returns> - //public static SimpleResult EmptyBindPallet(EmptyBindInfo model) { - // var db = DbHelper.GetDbClient(); - - // try { - // var loc = db.Queryable<TN_Location>() - // .Where(ExprHelper.LocCode(model.LocCode)) - // .Where(ExprHelper.LocBelongsToArea(AreaName.绌烘墭鐩樻帴椹冲尯)) - // .Where(ExprHelper.LocIsFree) - // .Where(ExprHelper.LocIsEmpty).First(); - - // if (loc == null) { - // return BuildSimpleResult(2, $"褰撳墠璐т綅 '{model.LocCode}' 鏃犳硶鍐嶇粦瀹氬鍣�); - // } - - // var locCntrRel = db.Queryable<TN_Loc_Container>() - // .Where(lc => lc.S_CNTR_CODE == model.LocCode).First(); - - // if (locCntrRel != null) { - // return BuildSimpleResult(3, $"褰撳墠瀹瑰櫒 '{model.CntrCode}' 宸茬粡涓�'{locCntrRel.S_LOC_CODE}' 缁戝畾"); - // } - - // //loc.N_CURRENT_NUM = model.PalletCount; - - // locCntrRel = new TN_Loc_Container { - // S_LOC_CODE = model.LocCode, - // S_CNTR_CODE = model.CntrCode - // }; - - // using (var tran = db.Ado.UseTran()) { - // if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() > 0 - // && db.Updateable<TN_Location>(loc).UpdateColumns(it => it.N_CURRENT_NUM).ExecuteCommand() > 0) { - // tran.CommitTran(); - // return BuildSimpleResult(0, $"缁戝畾瀹瑰櫒 '{model.CntrCode}' 涓庤揣浣�'{model.LocCode}' 鎴愬姛"); - // } - // else { - // tran.RollbackTran(); - // return BuildSimpleResult(4, $"缁戝畾瀹瑰櫒 '{model.CntrCode}' 涓庤揣浣�'{model.LocCode}' 澶辫触"); - // } - // } - // } - // catch (Exception ex) { - // return BuildSimpleEx(ex); - // } - //} - - ///// <summary> - ///// 绌虹缁戝畾(PDA) - ///// </summary> - ///// <param name="model"></param> - ///// <returns></returns> - //public static SimpleResult EmptyBindGoodpack(EmptyBindInfo model) { - // var db = DbHelper.GetDbClient(); - - // try { - // var loc = db.Queryable<TN_Location>() - // .Where(ExprHelper.LocCode(model.LocCode)) - // .Where(ExprHelper.LocBelongsToArea(AreaName.绌虹鎺ラ┏鍖�) - // .Where(ExprHelper.LocIsFree) - // .Where(ExprHelper.LocIsEmpty).First(); - - // if (loc == null) { - // return BuildSimpleResult(2, $"褰撳墠璐т綅 '{model.LocCode}' 鏃犳硶鍐嶇粦瀹氬鍣�); - // } - - // var locCntrRel = db.Queryable<TN_Loc_Container>() - // .Where(lc => lc.S_CNTR_CODE == model.LocCode).First(); - - // if (locCntrRel != null) { - // return BuildSimpleResult(3, $"褰撳墠瀹瑰櫒 '{model.CntrCode}' 宸茬粡涓�'{locCntrRel.S_LOC_CODE}' 缁戝畾"); - // } - - // loc.N_CURRENT_NUM = 1; // 绌虹缁戝畾鏃跺鍣ㄦ暟蹇呯劧涓�1 - - // locCntrRel = new TN_Loc_Container { - // S_LOC_CODE = model.LocCode, - // S_CNTR_CODE = model.CntrCode - // }; - - // using (var tran = db.Ado.UseTran()) { - // if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() > 0 - // && db.Updateable<TN_Location>(loc).UpdateColumns(it => it.N_CURRENT_NUM).ExecuteCommand() > 0) { - // tran.CommitTran(); - // return BuildSimpleResult(0, $"缁戝畾瀹瑰櫒 '{model.CntrCode}' 涓庤揣浣�'{model.LocCode}' 鎴愬姛"); - // } - // else { - // tran.RollbackTran(); - // return BuildSimpleResult(4, $"缁戝畾瀹瑰櫒 '{model.CntrCode}' 涓庤揣浣�'{model.LocCode}' 澶辫触"); - // } - // } - // } - // catch (Exception ex) { - // return BuildSimpleEx(ex); - // } - //} - - /// <summary> - /// 鎵樼洏-绌烘墭鍏ュ簱(PDA) - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - public static SimpleResult EmptyInboundPallet(EmptyInboundInfo model) { - var taskName = TaskName.鎵樼洏_绌烘墭鍏ュ簱; - var db = new SqlHelper<object>().GetInstance(); - var info = ""; - try { - var startLoc = db.Queryable<TN_Location>() - .Where(a => a.S_CODE == model.StartLoc) // 鎸囧畾锛氳捣鐐硅揣浣�- .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 1) - .First(); - - if (startLoc == null) { - info = $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�; - LogHelper.Info(info); - return NewSimpleResult(2, info); - } - - // 鏌ョ湅瀹瑰櫒涓庤捣鐐硅揣浣嶆槸鍚︾粦瀹�- var locCntrRel = db.Queryable<TN_Loc_Container>() - .Where(c => c.S_LOC_CODE == model.StartLoc && c.S_CNTR_CODE == model.CntrCode) - .First(); - - if (locCntrRel == null) { - info = $"璧风偣浣嶇疆{model.StartLoc}娌℃湁缁戝畾瀹瑰櫒{model.CntrCode}"; - LogHelper.Info(info); - return NewSimpleResult(3, info); - } - - // TODO 鏆傚畾閫夋嫨鏈�綆灞傛寜鍖轰綅椤哄簭鍏ュ簱锛屽悗闈㈠緟淇敼 - var endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.绌烘墭瀛樻斁鍖篯.Contains(l.S_AREA_CODE)) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 0) - .OrderBy(l => l.N_LAYER) - .First(); - - if (endLoc == null) { - info = $"鏆傛椂娌℃湁绗﹀悎鏉′欢鐨勭粓鐐规斁璐т綅"; - LogHelper.Info(info); - return NewSimpleResult(4, info); - } - - 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(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; - LogHelper.Info(info); - return NewSimpleResult(4, info); - } - - 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(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; - LogHelper.Info(info); - return NewSimpleResult(4, 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(4, info); - } - - tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; - LogHelper.Info(info); - return NewSimpleResult(0, info); - } - } - catch (Exception ex) { - info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; - LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); - } - } - - /// <summary> - /// 濂借繍绠�绌虹鍏ュ簱(PDA) - /// </summary> - /// <returns></returns> - public static SimpleResult EmptyInboundGoodpack(EmptyInboundInfo model) { - var taskName = TaskName.濂借繍绠盻绌虹鍏ュ簱; - var db = new SqlHelper<object>().GetInstance(); - var info = ""; - try { - var startLoc = db.Queryable<TN_Location>() - .Where(a => a.S_CODE == model.StartLoc) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 1) // 绛涢�锛氭湁璐ц揣浣�- .First(); - - if (startLoc == null) { - info = $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�; - LogHelper.Info(info); - return NewSimpleResult(2, info); - } - - // 鏌ョ湅瀹瑰櫒涓庤捣鐐硅揣浣嶆槸鍚︾粦瀹�- var locCntrRel = db.Queryable<TN_Loc_Container>() - .Where(c => c.S_LOC_CODE == model.StartLoc && c.S_CNTR_CODE == model.CntrCode) - .First(); - - if (locCntrRel == null) { - info = $"璧风偣浣嶇疆{model.StartLoc}娌℃湁缁戝畾瀹瑰櫒{model.CntrCode}"; - LogHelper.Info(info); - return NewSimpleResult(3, info); - } - - // TODO 鏆傚畾閫夋嫨鏈�綆灞傛寜鍖轰綅椤哄簭鍏ュ簱锛屽悗闈㈠緟淇敼 - var endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.绌虹瀛樻斁鍖篯.Contains(l.S_AREA_CODE)) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 0) - .OrderBy(l => new { l.N_LAYER }) - .First(); - - if (endLoc == null) { - return NewSimpleResult(4, $"鏆傛椂娌℃湁绗﹀悎鏉′欢鐨勭粓鐐规斁璐т綅"); - } - - 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(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; - LogHelper.Info(info); - return NewSimpleResult(4, info); - } - - 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(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; - LogHelper.Info(info); - return NewSimpleResult(4, 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(4, info); - } - - tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; - LogHelper.Info(info); - return NewSimpleResult(0, info); - } - } - catch (Exception ex) { - info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; - LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); - } - } - /// <summary> /// 鎵樼洏-绌烘墭涓婄嚎(PDA) /// </summary> /// <param name="model"></param> /// <returns></returns> public static SimpleResult EmptyOnlinePallet(EmptyOnlinePalletInfo model) { - var taskName = TaskName.鎵樼洏_绌烘墭涓婄嚎; var db = new SqlHelper<object>().GetInstance(); - var taskInfo = Settings.TaskMap[taskName]; var info = ""; + + var taskName = TaskName.T鎵樼洏_绌烘墭涓婄嚎; + var startAreaName = AreaName.K绌烘墭瀛樻斁鍖� + var endAreaName = AreaName.B鍖呰鍖� + try { - // TODO 绗﹀悎鐗╂枡淇℃伅鐨勮揣浣�+ // 鏌ュ鍣�鐗╂枡绫诲瀷琛�+ var cntrItemRel = db.Queryable<TN_Container_ItemType>() + .Where(i => i.S_CNTR_CODE == model.CntId && i.S_CNTR_TYPE == "鎵樼洏") + .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); + } + var startLoc = db.Queryable<TN_Location>() - .Where(l => taskInfo.StartAreas.Contains(l.S_AREA_CODE)) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 1) // 绛涢�锛氭湁璐ц揣浣�+ .LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE) // 鑱旇〃锛氳揣浣嶅鍣ㄥ叧绯昏〃 + .Where((l, c) => c.S_CNTR_CODE == model.CntId) // 鎵炬寚瀹氬鍣ㄥ彿 + .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 闄愬畾鍦ㄧ┖鎵樺瓨鏀惧尯涓壘瀹瑰櫒璐т綅 + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭病鏈夐攣鐘舵� + .Where(l => l.N_CURRENT_NUM == 1) // 绛涢�锛氭湁璐ц揣浣� .First(); if (startLoc == null) { - return NewSimpleResult(2, $"娌℃湁鍚堥�鐨勮捣鐐逛綅缃�); - } - - var locCntrRel = db.Queryable<TN_Loc_Container>().First( - a => a.S_LOC_CODE == startLoc.S_CODE - && a.S_CNTR_CODE == model.CntId); - - if (locCntrRel == null) { - return NewSimpleResult(3, $"璧风偣浣嶇疆 '{startLoc.S_CODE}' 娌℃湁缁戝畾瀹瑰櫒 '{model.CntId}'"); + info = $"鍦ㄧ┖鎵樺瓨鏀惧尯涓紝鎵句笉鍒扮鍚坽model.ItemCode}鐗╂枡锛屼笖缂栫爜涓簕model.CntId}鐨勭┖鎵樼洏"; + LogHelper.Info(info); + return NewSimpleResult(3, info); } var endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.鍖呰鍖篯.Contains(l.S_AREA_CODE)) - .Where(l => taskInfo.EndAreas.Contains(l.S_AREA_CODE)) + .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 0) // 绛涢�锛氱┖璐т綅 .First(); if (endLoc == null) { - return NewSimpleResult(4, $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�); + info = $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�; + LogHelper.Info(info); + return NewSimpleResult(4, info); } - var cntId = locCntrRel.S_CNTR_CODE; + var cntId = model.CntId; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -524,45 +483,45 @@ /// <param name="model"></param> /// <returns></returns> public static SimpleResult EmptyOnlineGoodpack(EmptyOnlineGoodpackInfo model) { - var taskName = TaskName.濂借繍绠盻绌虹涓婄嚎; var db = new SqlHelper<object>().GetInstance(); - var taskInfo = Settings.TaskMap[taskName]; var info = ""; + + var taskName = TaskName.H濂借繍绠盻绌虹涓婄嚎; + var startAreaName = AreaName.K绌烘墭瀛樻斁鍖� + var endAreaName = AreaName.K绌虹鎿嶄綔鍖� + try { - // TODO 绗﹀悎鐗╂枡淇℃伅鐨勮揣浣� var startLoc = db.Queryable<TN_Location>() - .Where(l => taskInfo.StartAreas.Contains(l.S_AREA_CODE)) - .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - .Where(a => a.N_CURRENT_NUM == 1).First(); + .LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE) + .Where((l, c) => c.S_CNTR_CODE == model.CntId) + .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") + .Where(l => l.N_CURRENT_NUM == 1) + .First(); if (startLoc == null) { - return NewSimpleResult(2, $"娌℃湁鍚堥�鐨勮捣鐐逛綅缃�); - } - - var locCntrRel = db.Queryable<TN_Loc_Container>().First( - a => a.S_LOC_CODE == startLoc.S_CODE - && a.S_CNTR_CODE == model.CntId); - - if (locCntrRel == null) { - return NewSimpleResult(3, $"璧风偣浣嶇疆 '{startLoc.S_CODE}' 娌℃湁缁戝畾瀹瑰櫒 '{model.CntId}'"); + info = $"鍦�{startAreaName}'涓紝鎵句笉鍒扮紪鐮佷负{model.CntId}鐨勭┖濂借繍绠�; + LogHelper.Info(info); + return NewSimpleResult(2, info); } var endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.鍖呰鍖篯.Contains(l.S_AREA_CODE)) - .Where(l => taskInfo.EndAreas.Contains(l.S_AREA_CODE)) + .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 0) .First(); if (endLoc == null) { - return NewSimpleResult(4, $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�); + info = $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�; + LogHelper.Info(info); + return NewSimpleResult(4, info); } - var cntId = locCntrRel.S_CNTR_CODE; + var cntId = model.CntId; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -609,89 +568,19 @@ } } - /// <summary> - /// 鍒涘缓鎶芥鍗�- /// </summary> - /// <param name="model"></param> - /// <returns></returns> - public static SimpleResult CreateCheckOrder(CreateCheckOrderInfo model) { - var billName = "鎶芥鍗�; - var db = new SqlHelper<object>().GetInstance(); - var info = ""; - try { - var orderNo = GenerateOrderNo("鎶芥鍗曞彿", "CN"); - - var order = new TN_Check_Order { - S_NO = orderNo, - S_ITEM_CODE = model.ItemCode, - //S_ITEM_NAME = model.ItemName, - S_BATCH_NO = model.BatchNo, - N_COUNT = model.Qty, - S_END_AREA = model.EndArea, - }; - - var cgDetailList = SelectCgByTotalQty(model); - if (cgDetailList.Count == 0) { - return NewSimpleResult(3, "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ユ娊妫�); - } - - var detailList = new List<TN_Check_Detail>(); - foreach (var cgDetail in cgDetailList) { - var detail = new TN_Check_Detail { - S_NO = orderNo, - S_ITEM_CODE = cgDetail.S_ITEM_CODE, - S_BATCH_NO = cgDetail.S_BATCH_NO, - S_CNTR_CODE = cgDetail.S_CNTR_CODE, - S_END_AREA = model.EndArea, - }; - - detailList.Add(detail); - - cgDetail.N_ITEM_STATE = 3; - cgDetail.S_ITEM_STATE = "鎶介獙涓�; - } - - using (var tran = db.Ado.UseTran()) { - if (db.Insertable<TN_Check_Order>(order).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚{billName}澶辫触锛� + JsonConvert.SerializeObject(order); - LogHelper.Info(info); - return NewSimpleResult(2, info); - } - - if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚{billName}鏄庣粏澶辫触"; - LogHelper.Info(info); - return NewSimpleResult(4, info); - } - - if (db.Updateable<TN_CG_Detail>(cgDetailList).UpdateColumns(it => new { - it.N_ITEM_STATE, it.S_ITEM_STATE }).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鏇存柊鐗╂枡鐘舵�澶辫触"; - - } - - tran.CommitTran(); - } - return NewSimpleResult(0, $"鍒涘缓 鎶芥鍗�鎴愬姛"); - } - catch (Exception ex) { - info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; - LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); - } - } + /// <summary> /// 鎶芥-鍚堟牸鍥炲簱(PDA) /// </summary> /// <param name="model"></param> /// <returns></returns> public static SimpleResult QualifiedBack(QualifiedBackInfo model) { - var taskName = TaskName.鎶芥_鍚堟牸鍥炲簱; var db = new SqlHelper<object>().GetInstance(); var info = ""; + + var taskName = TaskName.C鎶芥_鍚堟牸鍥炲簱; + var startAreaName = AreaName.C鎶芥鍖� + try { var cgDetail = db.Queryable<TN_CG_Detail>() .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_CNTR_CODE == model.CntrCode) @@ -705,20 +594,15 @@ .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE) .First(); - //var startLoc = db.Queryable<TN_Location>() - // .LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE) - // .Where((l, c) => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE) // 鎸囧畾瀹瑰櫒鍙�- // .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 - // .First(); - var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 1) + .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 .First(); if (startLoc == null) { - info = "娌℃湁鎵惧埌鍚堥�鐨勮捣鐐硅揣浣�; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒板鍣▄model.CntrCode}鐨勮捣鐐硅揣浣嶏紝鎴栦笉鍏峰鍙栬揣瑕佹眰锛氭湭涓婇攣銆佹湁璐х墿"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -726,14 +610,14 @@ var endLoc = new TN_Location(); if (locCntrRel.S_CNTR_TYPE == "鎵樼洏") { endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.婊℃墭瀛樻斁鍖篯.Contains(l.S_AREA_CODE)) + .Where(l => Settings.AreaMap[AreaName.M婊℃墭璐ф灦鍖篯.Contains(l.S_AREA_CODE)) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 0) // 绛涢�锛氱┖璐т綅 .First(); } else if (locCntrRel.S_CNTR_TYPE == "濂借繍绠�) { endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.婊$瀛樻斁鍖篯.Contains(l.S_AREA_CODE)) + .Where(l => Settings.AreaMap[AreaName.M婊$璐ф灦鍖篯.Contains(l.S_AREA_CODE)) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 0) .First(); @@ -742,9 +626,10 @@ return NewSimpleResult(2, $"鎵樼洏绫诲瀷{locCntrRel.S_CNTR_TYPE}涓嶅悎娉曪細鎵樼洏鍙穥locCntrRel.S_CNTR_CODE}"); } - if (endLoc == null) { - return NewSimpleResult(3, "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"); + info = "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"; + LogHelper.Info(info); + return NewSimpleResult(3, info); } cgDetail.N_ITEM_STATE = 0; @@ -753,8 +638,8 @@ var cntId = locCntrRel.S_CNTR_CODE; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_CG_Detail>(cgDetail).UpdateColumns(it => @@ -809,16 +694,25 @@ } } public static SimpleResult UnqualifiedShift(UnqualifiedShiftInfo model) { - var taskName = TaskName.鎶芥_涓嶅悎鏍肩Щ搴� var db = new SqlHelper<object>().GetInstance(); var info = ""; + + var taskName = TaskName.C鎶芥_涓嶅悎鏍肩Щ搴� + try { + + if (!Settings.AreaMap[AreaName.C鎶芥寮傚父鍖篯.Contains(model.EndArea)) { + info = $"缁堢偣搴撳尯{model.EndArea}涓嶅睘浜巤AreaName.C鎶芥寮傚父鍖簘"; + LogHelper.Info(info); + return NewSimpleResult(1, info); + } var cgDetail = db.Queryable<TN_CG_Detail>() .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_CNTR_CODE == model.CntrCode) .First(); if (cgDetail == null) { + return NewSimpleResult(2, "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡"); } @@ -836,6 +730,7 @@ .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE) .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 .Where(l => l.N_CURRENT_NUM == 1) + .Where(l => Settings.AreaMap[AreaName.C鎶芥鍖篯.Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 .First(); if (startLoc == null) { @@ -860,8 +755,8 @@ var cntId = locCntrRel.S_CNTR_CODE; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_CG_Detail>(cgDetail).UpdateColumns(it => @@ -917,9 +812,11 @@ } public static SimpleResult RestBack(RestBackInfo model) { - var taskName = TaskName.灏剧鍥炲簱; var db = new SqlHelper<object>().GetInstance(); var info = ""; + + var taskName = TaskName.W灏剧鍥炲簱; + try { var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == model.StartLoc) @@ -932,21 +829,40 @@ .First(); if (locCntrRel == null) { - return NewSimpleResult(2, $"璧风偣璐т綅 {model.StartLoc}"); + info = $"娌℃湁鎵惧埌璧风偣璐т綅{model.StartLoc}锛屾垨涓嶅叿澶囧彇璐ц姹傦細鏈笂閿併�鏈夎揣鐗�; + LogHelper.Info(info); + return NewSimpleResult(3, info); } - var endLoc = db.Queryable<TN_Location, TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE) - .Where((l, c) => c.S_CNTR_TYPE == locCntrRel.S_CNTR_TYPE) - .First(); + var endLoc = new TN_Location(); + if (locCntrRel.S_CNTR_TYPE == "鎵樼洏") { + endLoc = db.Queryable<TN_Location>() + .Where(l => Settings.AreaMap[AreaName.M婊℃墭璐ф灦鍖篯.Contains(l.S_AREA_CODE)) + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 + .Where(l => l.N_CURRENT_NUM == 0) // 璧风偣缁戝畾鍓嶆病鏈夊鍣�+ .First(); + } + else if (locCntrRel.S_CNTR_TYPE =="濂借繍绠�){ + endLoc = db.Queryable<TN_Location>() + .Where(l => Settings.AreaMap[AreaName.M婊$璐ф灦鍖篯.Contains(l.S_AREA_CODE)) + .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣 + .Where(l => l.N_CURRENT_NUM == 0) // 璧风偣缁戝畾鍓嶆病鏈夊鍣�+ .First(); + } + else { + endLoc = null; + } if (endLoc == null) { - return NewSimpleResult(3, $"涓嶅瓨鍦ㄥ悎閫傜殑缁堢偣璐т綅鍙互鍥炲簱"); + info = "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"; + LogHelper.Info(info); + return NewSimpleResult(3, info); } var cntId = locCntrRel.S_CNTR_CODE; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�- LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+ LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�+ LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -994,58 +910,8 @@ } } - public static List<TN_CG_Detail> SelectCgByTotalQty(CreateCheckOrderInfo model) { - var db = new SqlHelper<object>().GetInstance(); - var result = new List<TN_CG_Detail>(); - var targetNum = model.Qty; - - try { - var targetCg = db.Queryable<TN_CG_Detail>().Where(a => a.S_ITEM_CODE == model.ItemCode - && a.N_ITEM_NUM > targetNum). - OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc).First(); - if (targetCg != null) //鍒氬ソ鏈変竴琛屾弧瓒虫潯浠�- { - result.Add(targetCg); - return result; - } - - var sortedMaterials = new List<TN_CG_Detail>(); - - sortedMaterials = db.Queryable<TN_CG_Detail, TN_Loc_Container>((d, c) => d.S_CNTR_CODE == c.S_CNTR_CODE) - .Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.BatchNo && d.N_ITEM_NUM > 0) - .Where((d, c) => c.S_CNTR_TYPE == model.CntrType) - .Where(d => d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "寰呮") - .OrderBy(d => d.N_ITEM_NUM, OrderByType.Desc) - .OrderBy(d => d.N_ITEM_STATE, OrderByType.Asc).ToList(); - - if (sortedMaterials.Count == 0) //娌℃湁婊¤冻鏉′欢鐨�- { - return result; - } - - int countNum = 0; - foreach (var mat in sortedMaterials) { - countNum += mat.N_ITEM_NUM; - result.Add(mat); - if (countNum >= targetNum) { - break; - } - } - if (result.Sum(a => a.N_ITEM_NUM) >= targetNum) { - return result; - } - else { - result.Clear(); - return result; - } - } - catch (Exception ex) { - throw ex; - } - } - /// <summary> - /// 鎴愬搧鑳跺嚭搴�WMS) + /// 鎴愬搧鑳跺嚭搴�PDA) /// </summary> /// <remarks> /// WMS鎻愪緵鍑哄簱鐨勭墿鏂欑被鍨嬩笌鏁伴噺锛岃皟鐢ㄦ帴鍙g敱WCS鐢熸垚鍏蜂綋鐨勫嚭搴撲换鍔★紝鐒跺悗WCS鍚庡彴杞澶勭悊 @@ -1054,14 +920,12 @@ /// <returns></returns> public static SimpleResult FinishedOutbound(FinishedOutboundInfo model) { var db = new SqlHelper<object>().GetInstance(); - var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); var info = ""; + + var taskName = TaskName.C鎴愬搧鑳跺嚭搴� + try { - if (string.IsNullOrEmpty(orderNo)) { - info = "鍑哄簱鍗曞彿涓嶈兘涓虹┖"; - LogHelper.Info(info); - return NewSimpleResult(2, info); - } + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); var cgDetailList = SelectCgByTotalQty(model); @@ -1076,7 +940,6 @@ S_ITEM_CODE = model.ItemCode, S_BATCH = model.BatchNo, N_END_NUM = model.Qty, - //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY), S_END_AREA = model.EndArea }; @@ -1111,7 +974,9 @@ tran.CommitTran(); } - return NewSimpleResult(0, "鐢熸垚鍑哄簱鍗曟垚鍔�); + info = "鐢熸垚鍑哄簱鍗曟垚鍔�; + LogHelper.Info(info); + return NewSimpleResult(0, info); } catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; @@ -1126,54 +991,63 @@ /// <returns></returns> public static SimpleResult FinishedOutboundForce(FinishedOutboundInfo model) { var db = new SqlHelper<object>().GetInstance(); - var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); var info = ""; + + var taskName = TaskName.C鎴愬搧鑳跺嚭搴� + try { - if (string.IsNullOrEmpty(orderNo)) { - return NewSimpleResult(2, "鍑哄簱鍗曞彿涓嶈兘涓虹┖"); + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); + + var cgDetailList = SelectCgByTotalQty(model); + + if (cgDetailList.Count == 0) { + info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�; + LogHelper.Info(info); + return NewSimpleResult(3, info); + } + + var order = new TN_Outbound_Order { + S_NO = orderNo, + S_ITEM_CODE = model.ItemCode, + S_BATCH = model.BatchNo, + N_END_NUM = model.Qty, + S_END_AREA = model.EndArea + }; + + var detailList = new List<TN_Outbound_Detail>(); + foreach (var cgDetail in cgDetailList) { + var detail = new TN_Outbound_Detail { + S_OO_NO = orderNo, + S_ITEM_CODE = cgDetail.S_ITEM_CODE, + S_BATCH_NO = cgDetail.S_BATCH_NO, + S_CNTR_CODE = cgDetail.S_CNTR_CODE, + N_COUNT = cgDetail.N_ITEM_NUM, + S_END_AREA = model.EndArea + }; + detailList.Add(detail); } using (var tran = db.Ado.UseTran()) { - - var cgDetailList = SelectCgByTotalQty(model); - - if (cgDetailList.Count == 0) { - return NewSimpleResult(3, "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�); - } - - foreach (var cgDetail in cgDetailList) { - var detail = new TN_Outbound_Detail { - S_OO_NO = orderNo, - S_ITEM_CODE = cgDetail.S_ITEM_CODE, - S_BATCH_NO = cgDetail.S_BATCH_NO, - S_CNTR_CODE = cgDetail.S_CNTR_CODE, - S_END_AREA = model.EndArea - }; - - if (db.Insertable<TN_Outbound_Detail>(detail).ExecuteCommand() <= 0) { - tran.RollbackTran(); - return NewSimpleResult(4, "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐ワ細" + JsonConvert.SerializeObject(detail)); - } - } - - var order = new TN_Outbound_Order { - S_NO = orderNo, - S_ITEM_CODE = model.ItemCode, - S_BATCH = model.BatchNo, - N_END_NUM = model.Qty, - //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY), - S_END_AREA = model.EndArea - }; - if (db.Insertable<TN_Outbound_Order>(order).ExecuteCommand() <= 0) { tran.RollbackTran(); - return NewSimpleResult(5, "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order)); + info = "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order); + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + + if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) { + tran.RollbackTran(); + info = "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐�; + LogHelper.Info(info); + return NewSimpleResult(4, info); } tran.CommitTran(); } - return NewSimpleResult(0, "鐢熸垚鍑哄簱鍗曟垚鍔�); + info = "鐢熸垚鍑哄簱鍗曟垚鍔�; + LogHelper.Info(info); + return NewSimpleResult(0, info); } catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; @@ -1188,9 +1062,10 @@ var targetNum = model.Qty; var info = ""; try { - var targetCg = db.Queryable<TN_CG_Detail>().Where(a => a.S_ITEM_CODE == model.ItemCode - && a.N_ITEM_NUM > targetNum). - OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc).First(); + var targetCg = db.Queryable<TN_CG_Detail>() + .Where(a => a.S_ITEM_CODE == model.ItemCode && a.S_BATCH_NO == model.BatchNo) + .Where(a => a.N_ITEM_NUM > targetNum) + .OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc).First(); if (targetCg != null) //鍒氬ソ鏈変竴琛屾弧瓒虫潯浠� { result.Add(targetCg); @@ -1248,106 +1123,10 @@ } } - /// <summary> - /// 绉诲簱-鍒涘缓绉诲簱浠诲姟(WMS) - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - public static SimpleResult CreateShiftOrder(CreateShiftOrderInfo model) { - var billName = "鎶芥鍗�; - var db = new SqlHelper<object>().GetInstance(); - var info = ""; - try { - var orderNo = GenerateOrderNo("鎶芥鍗曞彿", "CN"); - - var order = new TN_Check_Order { - S_NO = orderNo, - S_ITEM_CODE = model.ItemCode, - //S_ITEM_NAME = model.ItemName, - S_BATCH_NO = model.BatchNo, - //N_COUNT = model.Qty, - S_END_AREA = model.EndArea, - }; - - var cgDetailList = SelectShiftItem(model); - if (cgDetailList.Count == 0) { - return NewSimpleResult(3, "娌℃湁绗﹀悎瑕佹眰鐨勭墿鏂欓渶瑕佺Щ搴�); - } - - var detailList = new List<TN_Check_Detail>(); - foreach (var cgDetail in cgDetailList) { - var detail = new TN_Check_Detail { - S_NO = orderNo, - S_ITEM_CODE = cgDetail.S_ITEM_CODE, - S_BATCH_NO = cgDetail.S_BATCH_NO, - S_CNTR_CODE = cgDetail.S_CNTR_CODE, - S_END_AREA = model.EndArea, - }; - - detailList.Add(detail); - - cgDetail.N_ITEM_STATE = 3; - cgDetail.S_ITEM_STATE = "鎶介獙涓�; - } - - using (var tran = db.Ado.UseTran()) { - if (db.Insertable<TN_Check_Order>(order).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚{billName}澶辫触锛� + JsonConvert.SerializeObject(order); - LogHelper.Info(info); - return NewSimpleResult(2, info); - } - - if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚{billName}鏄庣粏澶辫触"; - LogHelper.Info(info); - return NewSimpleResult(4, info); - } - - if (db.Updateable<TN_CG_Detail>(cgDetailList).UpdateColumns(it => new { - it.N_ITEM_STATE, it.S_ITEM_STATE }).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鏇存柊鐗╂枡鐘舵�澶辫触"; - - } - - tran.CommitTran(); - } - return NewSimpleResult(0, $"鍒涘缓 鎶芥鍗�鎴愬姛"); - } - catch (Exception ex) { - info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; - LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); - } - } - - public static List<TN_CG_Detail> SelectShiftItem(CreateShiftOrderInfo model) { - var db = new SqlHelper<object>().GetInstance(); - var result = new List<TN_CG_Detail>(); - var info = ""; - try { - var targetItemList = db.Queryable<TN_CG_Detail>() - .Where(a => a.S_ITEM_CODE == model.ItemCode) - .Where(a => a.S_BATCH_NO == model.BatchNo) - .Where(a => a.N_ITEM_STATE != 3 && a.S_ITEM_CODE != "鎶芥涓�) - .OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc) - .ToList(); - - return targetItemList; - } - catch (Exception ex) { - info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; - LogHelper.InfoEx(ex); - return result; - } - } - private static string GenerateOrderNo(string snType, string prefix) { var id = SYSHelper.GetSerialNumber(snType, prefix); var date = DateTime.Now.ToString("yyMMdd"); - return $"ON{date}{id.ToString().PadLeft(4, '0')}"; + return $"{prefix}{date}{id.ToString().PadLeft(4, '0')}"; } /// <summary> @@ -1355,7 +1134,7 @@ /// </summary> /// <param name="model"></param> /// <returns></returns> - public static WmsResult CgInfoSync(CgInfoSyncInfo model) { + public static MesResult CgInfoSync(CgInfoSyncInfo model) { var db = new SqlHelper<object>().GetInstance(); var random = new Random(); var info = ""; @@ -1382,7 +1161,7 @@ if (db.Insertable<TN_CG_Detail>(detail).ExecuteCommand() <= 0) { tran.RollbackTran(); info = "鎻掑叆鐗╂枡淇℃伅澶辫触锛� + JsonConvert.SerializeObject(detail); - return NewWmsResult(2, info); + return NewMesResult(2, info); } //if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { @@ -1395,12 +1174,90 @@ } info = "鎻掑叆鐗╂枡淇℃伅鎴愬姛"; - return NewWmsResult(0, info); + return NewMesResult(0, info); } catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewWmsResult(1, info); + return NewMesResult(1, info); + } + } + + public static ErpResult ErpSendOutboundOrder(ErpSendOutboundOrderInfo model) { + var db = new SqlHelper<object>().GetInstance(); + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); + var info = ""; + try { + if (string.IsNullOrEmpty(orderNo)) { + info = "鍑哄簱鍗曞彿涓嶈兘涓虹┖"; + LogHelper.Info(info); + return NewErpResult(2, info); + } + + var cgDetailList = SelectCgByTotalQty(new FinishedOutboundInfo { + BatchNo = model.BatchNo, + CntrType= model.CntrType, + ItemCode= model.ItemCode, + EndArea= model.EndArea, + ForcedOut= model.ForcedOut, + Qty= model.Qty, + Spe = model.Spe + }); + + if (cgDetailList.Count == 0) { + info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�; + LogHelper.Info(info); + return NewErpResult(3, info); + } + + var order = new TN_Outbound_Order { + S_NO = orderNo, + S_ITEM_CODE = model.ItemCode, + S_BATCH = model.BatchNo, + N_END_NUM = model.Qty, + //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY), + S_END_AREA = model.EndArea, + S_BS_NO = model.ErpNo, + S_BS_TYPE = "ERP", + }; + + var detailList = new List<TN_Outbound_Detail>(); + foreach (var cgDetail in cgDetailList) { + var detail = new TN_Outbound_Detail { + S_OO_NO = orderNo, + S_ITEM_CODE = cgDetail.S_ITEM_CODE, + S_BATCH_NO = cgDetail.S_BATCH_NO, + S_CNTR_CODE = cgDetail.S_CNTR_CODE, + N_COUNT = cgDetail.N_ITEM_NUM, + S_END_AREA = model.EndArea + }; + detailList.Add(detail); + } + + using (var tran = db.Ado.UseTran()) { + if (db.Insertable<TN_Outbound_Order>(order).ExecuteCommand() <= 0) { + tran.RollbackTran(); + info = "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order); + LogHelper.Info(info); + return NewErpResult(2, info); + } + + if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) { + tran.RollbackTran(); + info = "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐�; + LogHelper.Info(info); + return NewErpResult(4, info); + } + + tran.CommitTran(); + } + + return NewErpResult(0, "鐢熸垚鍑哄簱鍗曟垚鍔�); + } + catch (Exception ex) { + info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; + LogHelper.InfoEx(ex); + return NewErpResult(1, info); } } } -- Gitblit v1.9.1