From 99d001bbf2a0371373e15c97d3c6c7dcf45e97e3 Mon Sep 17 00:00:00 2001 From: kazelee <1847801760@qq.com> Date: 星期五, 13 六月 2025 15:44:22 +0800 Subject: [PATCH] 修复空托上线与满托下线联调的逻辑错误 --- api/ApiHelper.cs | 827 ++++++++++++++++++++++++++++++++++------------------------ 1 files changed, 485 insertions(+), 342 deletions(-) diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs index a24a1cb..d851211 100644 --- a/api/ApiHelper.cs +++ b/api/ApiHelper.cs @@ -19,7 +19,9 @@ /// 濂借繍绠�婊$涓嬬嚎鍏ュ簱(PDA) /// </summary> /// <remarks> - /// 娴佺▼锛氫汉宸ュ皢婊$浠庝骇绾挎惉杩愬埌鎿嶄綔鍖哄悗锛屼娇鐢≒DA璋冪敤鎺ュ彛锛屽懠鍙獳GV灏嗘弧绠辨惉杩愬埌璐ф灦鍖猴紙涓嶆寚瀹氱粓鐐硅揣鍖猴級 + /// 浜哄伐锛氫骇绾�=>婊$鎿嶄綔鍖�br/> + /// PDA锛氳皟鐢ㄦ帴鍙o紝鍛煎彨AGV<br/> + /// AGV锛氭弧绠辨搷浣滃尯==鎼繍==>璐ф灦鍖猴紙涓嶆寚瀹氱粓鐐硅揣鍖猴級 /// </remarks> /// <param name="model">鍖呭惈锛氱墿鏂欎俊鎭�璧风偣璐т綅</param> /// <returns></returns> @@ -27,100 +29,73 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.H濂借繍绠盻婊$涓嬬嚎鍏ュ簱; // 鐢ㄤ簬鐢熸垚浠诲姟绫诲瀷銆佹墦鍗版棩蹇椾俊鎭�- var startAreaName = AreaName.M婊$鎿嶄綔鍖� // 璧风偣璐у尯 - var endAreaName = AreaName.M婊$璐ф灦鍖� // 缁堢偣璐у尯 + const string taskName = TaskName.H濂借繍绠盻婊$涓嬬嚎鍏ュ簱; + const string startAreaName = AreaName.M婊$鎿嶄綔鍖� + const string endAreaName = AreaName.M婊$璐ф灦鍖� try { - // 璐存爣鏈轰細鎻愬墠灏嗙墿鏂欎俊鎭啓鍏G_Detail琛ㄤ腑 - // 灏哖DA鎻愪緵鐨勭墿鏂欑紪鐮佷笌璐存爣鏈虹殑淇℃伅姣斿 + if (model.Num <= 0) { + info = $"鐗╂枡鏁伴噺'{model.Num}'涓嶅悎娉曪細鐗╂枡鏁伴噺搴旇澶т簬0"; + LogHelper.Info(info); + return NewSimpleResult(400, info); + } + 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 == "寰呮") // 鏂板鐗╂枡锛屾晠鐗╂枡鐘舵�搴旇涓�1寰呮 + .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 == "寰呮") .First(); // TODO model 涓�鏁伴噺銆佽鏍兼槸鍚︿篃鍙備笌姣斿 寰呭悗缁姹� - // 濡傛灉鎵句笉鍒版寚瀹氱殑鐗╂枡锛岃鏄庝俊鎭笉涓�嚧锛屾姤閿� if (cgDetail == null) { info = $"PDA鎵爜鐗╂枡淇℃伅涓庤创鏍囨満浼犻�鐨勪俊鎭笉涓�嚧锛� + JsonConvert.SerializeObject(model); LogHelper.Info(info); - return NewSimpleResult(2, info); + return NewSimpleResult(1, info); } - // 鏌ヨ璧风偣璐т綅锛屾槸鍚︾鍚堣姹傦紙鍒濇涓嬬嚎瑕佹眰璐т綅鏃犲鍣級 - // 娉細璧风偣璐т綅缁戝畾鍓嶆病鏈夎揣鐗╋紝鏁伴噺涓�0 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)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .Where(l => l.S_CODE == model.StartLoc) + .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 == 0) // 缁戝畾鍓� .First(); if (startLoc == null) { - info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣峽model.StartLoc}锛屾垨涓嶅叿澶囧彇璐ц姹傦細鏈笂閿併�缁戝畾鍓嶆棤璐х墿"; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣�{model.StartLoc}'锛屾垨涓嶆弧瓒宠姹傦細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0"; LogHelper.Info(info); - return NewSimpleResult(3, info); - } + return NewSimpleResult(2, info); + } - startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚庯紝淇敼璧风偣璐т綅鏁伴噺涓�1 + startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚� - // 缁戝畾璐т綅鍜屽鍣ㄥ彿锛堟弧绠变笅绾垮埌鎿嶄綔鍖猴紝姝ゆ椂灏氭湭缁戝畾锛� var locCntrRel = new TN_Loc_Container { - S_LOC_CODE = model.StartLoc, + S_LOC_CODE = startLoc.S_CODE, S_CNTR_CODE = cgDetail.S_CNTR_CODE, S_CNTR_TYPE = "濂借繍绠�, }; - // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級 - // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�- // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�- var cntrItemRel = db.Queryable<TN_Container_ItemType>() - .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First(); - var insertContainerItemType = false; - if (cntrItemRel == null) { - insertContainerItemType = true; - cntrItemRel = new TN_Container_ItemType { - S_ITEM_CODE = cgDetail.S_ITEM_CODE, // 鐗╂枡绫诲瀷瀵逛簬濂借繍绠辫�瑷�叾瀹炰笉鐢紝涓昏鏄被鍨�- S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE, - S_CNTR_CODE = locCntrRel.S_CNTR_CODE, - }; - } - - // 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) // 绛涢�锛氱┖璐т綅 + .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(); + .First();// TODO 婊$鍏ュ簱绠楁硶寰呬紭鍖� if (endLoc == null) { - info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�鏃犺揣鐗�; + info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0"; LogHelper.Info(info); - return NewSimpleResult(4, info); - } + return NewSimpleResult(3, info); + } - // 鏁版嵁搴撴搷浣滈儴鍒�- var cntId = locCntrRel.S_CNTR_CODE; + LocationHelper.LockStartLoc(ref startLoc); + LocationHelper.LockEndLoc(ref endLoc); + 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 (insertContainerItemType) { - if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel); - tran.RollbackTran(); - LogHelper.Info(info); - return NewSimpleResult(5, info); - } - } - if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); + info = $"鎻掑叆銆愯揣浣嶅鍣ㄧ粦瀹氥�琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(locCntrRel); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -133,30 +108,30 @@ tran.RollbackTran(); info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, 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 + it.T_MODIFY, }).ExecuteCommand() <= 0) { tran.RollbackTran(); info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } - + if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -164,7 +139,7 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -175,39 +150,56 @@ /// 浜哄伐灏嗙┖鎵樼洏閫氳繃鎺ラ┏浣嶅叆搴擄紝闇�鏂扮粦瀹氬鍣ㄨ揣浣�br/> /// 鐢变簬绌烘墭鐩樹竴鑸槸鍑哄簱鍗歌揣鍚庤幏寰楋紝鑰屽嚭搴撴椂娌℃湁鎵嬪姩鍗歌揣鐨勯�杈戯紝鎵�互闇�鍦ㄥ叆搴撶殑鏃跺�鍐嶅垹闄ゆ棫缁戝畾淇℃伅 /// </remarks> - /// <param name="model"></param> + /// <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绌烘墭瀛樻斁鍖� + const string taskName = TaskName.T鎵樼洏_绌烘墭鍏ュ簱; + const string startAreaName = AreaName.K绌烘墭鍏ュ簱鎺ラ┏鍖� + const string endAreaName = AreaName.K绌烘墭瀛樻斁鍖� + const string cntrType = "鎵樼洏"; 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)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .Where(l => l.S_CODE == model.StartLoc) + .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 == 0) .First(); if (startLoc == null) { - info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣峽model.StartLoc}锛屾垨涓嶅叿澶囪姹傦細鏈笂閿併�缁戝畾鍓嶆棤璐х墿"; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣�{model.StartLoc}'锛屾垨涓嶅叿澶囪捣鐐瑰彇璐ц姹傦細鏈笂閿併�缁戝畾鍓嶆棤璐х墿"; + LogHelper.Info(info); + return NewSimpleResult(1, info); + } + + var cntr = db.Queryable<TN_Container>() + .Where(c => c.S_CODE == model.CntrCode) // 瀵逛簬鍓嶅彴绋嬪簭鑰岃█锛孲_CODE灏辨槸涓婚敭锛岀淮鎶ゆ椂蹇呭畾鍞竴 + .First(); + + if (cntr == null) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄣ�瀹瑰櫒琛ㄣ�涓笉瀛樺湪锛岃鍦ㄥ墠鍙伴〉闈腑缁存姢锛�; LogHelper.Info(info); return NewSimpleResult(2, info); + } + if (cntr.S_TYPE != cntrType) { // 绌烘墭鍏ュ簱 + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄣ�瀹瑰櫒琛ㄣ�涓殑绫诲瀷涓�{cntr.S_TYPE}'锛屼笌杈撳叆鐨勫鍣ㄧ被鍨�{cntrType}'涓嶅悓锛�; + LogHelper.Info(info); + return NewSimpleResult(3, info); } // 鍋囧畾浜哄伐涓嶄細灏嗘湁鐗╂枡鐨勭瀛愭斁鍦ㄧ┖绠卞叆搴撴帴椹充綅锛屾病鏈夊繀瑕佹鏌� // 濡傛灉浜哄伐灏嗗嚭搴撳悗鐨勬墭鐩樺叆搴擄紝杩欐椂鐗╂枡淇℃伅骞舵病鏈夊垹闄わ紝闇�灏嗘墭鐩樼墿鏂欑殑鍏崇郴瑙i櫎 var cgDetailOld = db.Queryable<TN_CG_Detail>() - .Where(d => d.S_CNTR_CODE == model.CntrCode).First(); + .Where(d => d.S_CNTR_CODE == model.CntrCode) + .First(); // 濡傛灉浜哄伐灏嗗嚭搴撳悗鐨勬墭鐩樺叆搴擄紝姝ゆ椂瀹瑰櫒浠嶇劧涓庢棫鐨勫嚭搴撹揣浣嶇粦瀹氾紝闇�妫�煡 var locCntrRelOld = db.Queryable<TN_Loc_Container>() - .Where(c => c.S_CNTR_CODE == model.CntrCode).First(); + .Where(c => c.S_CNTR_CODE == model.CntrCode) + .First(); TN_Location locOld = null; if (locCntrRelOld != null) { // 濡傛灉闇�瑙g粦瀹瑰櫒璐т綅锛屼篃闇�淇敼璐т綅淇℃伅 @@ -215,105 +207,83 @@ .Where(l => l.S_CODE == locCntrRelOld.S_LOC_CODE).First(); if (locOld != null) { locOld.N_CURRENT_NUM = 0; // 濡傛灉鏃ц揣浣嶅瓨鍦紝灏嗘棫璐т綅鐨勬暟閲忚缃负 0 + locOld.T_MODIFY = DateTime.Now; } } // 缁戝畾璐т綅鍜屽鍣ㄥ彿锛圥DA鍦ㄦ帴椹充綅缁戝畾锛� var locCntrRel = new TN_Loc_Container { - S_LOC_CODE = model.StartLoc, - S_CNTR_CODE = model.CntrCode, - S_CNTR_TYPE = "鎵樼洏", + S_LOC_CODE = startLoc.S_CODE, + S_CNTR_CODE = cntr.S_CODE, + S_CNTR_TYPE = cntrType, // 绌烘墭鍏ュ簱 }; - // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級 - // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�- // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�- var cntrItemRel = db.Queryable<TN_Container_ItemType>() - .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First(); - var insertContainerItemType = false; - if (cntrItemRel == null) { - insertContainerItemType = true; - cntrItemRel = new TN_Container_ItemType { - S_ITEM_CODE = "", // 绌烘墭鐩樺垰鍏ュ簱锛屾病鏈夌墿鏂欑被鍨嬶紝灏遍粯璁ゅ厛涓虹┖ - S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE, - S_CNTR_CODE = locCntrRel.S_CNTR_CODE, - }; - } + startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚� - // 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 => 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 }) + .OrderBy(l => new { l.N_LAYER, l.N_ROW, l.N_COL }) // TODO 鏆傚畾閫夋嫨鏈�綆灞傛寜鍖轰綅椤哄簭鍏ュ簱锛屽悗闈㈠緟淇敼 .First(); if (endLoc == null) { - info = $"鍦�{endAreaName}'涓病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛岄渶瑕佹弧瓒筹細鏈笂閿併�鏃犺揣鐗�; + info = $"鍦ㄣ�{endAreaName}銆戜腑娌℃湁鎵惧埌鍚堥�鐨勩�缁堢偣璐т綅銆戯紝闇�婊¤冻锛氭湭涓婇攣銆佹棤璐х墿"; LogHelper.Info(info); return NewSimpleResult(4, info); } - var cntId = locCntrRel.S_CNTR_CODE; + LocationHelper.LockStartLoc(ref startLoc); + LocationHelper.LockEndLoc(ref endLoc); + 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 (insertContainerItemType) { - if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel); - tran.RollbackTran(); - LogHelper.Info(info); - return NewSimpleResult(5, info); - } - } - if (cgDetailOld != null) { if (db.Deleteable<TN_CG_Detail>(cgDetailOld).ExecuteCommand() <= 0) { - info = $"鍒犻櫎鏃х墿鏂欎俊鎭け璐ワ細" + JsonConvert.SerializeObject(cgDetailOld); + info = $"鍒犻櫎銆愭棫鐗╂枡淇℃伅銆戝け璐ワ細" + JsonConvert.SerializeObject(cgDetailOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } if (locCntrRelOld != null) { if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0) { - info = $"鍒犻櫎鏃ц揣浣嶅鍣ㄥ叧绯诲け璐ワ細" + JsonConvert.SerializeObject(locCntrRelOld); + info = $"鍒犻櫎銆愭棫璐т綅瀹瑰櫒鍏崇郴銆戝け璐ワ細" + JsonConvert.SerializeObject(locCntrRelOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } if (locOld != null) { - if (db.Updateable<TN_Location>(locOld).UpdateColumns(l => l.N_CURRENT_NUM).ExecuteCommand() <= 0) { - info = $"鏇存柊鏃ц揣浣嶅鍣ㄦ暟閲忓け璐ワ細" + JsonConvert.SerializeObject(locOld); + if (db.Updateable<TN_Location>(locOld).UpdateColumns(l => new { l.N_CURRENT_NUM, l.T_MODIFY }).ExecuteCommand() <= 0) { + info = $"鏇存柊鏃ц揣浣嶃�瀹瑰櫒鏁伴噺銆戝け璐ワ細" + JsonConvert.SerializeObject(locOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); + info = $"鎻掑叆銆愯揣浣嶅鍣ㄥ叧绯汇�澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, 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 + it.T_MODIFY, + it.N_CURRENT_NUM }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -323,28 +293,28 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(0, info); + return NewSimpleResult(0, info); } } catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -352,7 +322,7 @@ /// 濂借繍绠�绌虹鍏ュ簱(PDA) /// </summary> /// <remarks> - /// 浜哄伐灏嗙┖绠遍�杩囨帴椹充綅鍏ュ簱锛岄渶瑕佹柊缁戝畾瀹瑰櫒璐т綅<br/> + /// 浜哄伐锛氱┖绠�=鎼繍==>鍏ュ簱鎺ラ┏浣嶏紝闇�鏂扮粦瀹氬鍣ㄨ揣浣�br/> /// 鐢变簬绌虹涓�埇鏄嚭搴撳嵏璐у悗鑾峰緱锛岃�鍑哄簱鏃舵病鏈夋墜鍔ㄥ嵏璐х殑閫昏緫锛屾墍浠ラ渶瑕佸湪鍏ュ簱鐨勬椂鍊欏啀鍒犻櫎鏃х粦瀹氫俊鎭� /// </remarks> /// <returns></returns> @@ -360,20 +330,36 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.H濂借繍绠盻绌虹鍏ュ簱; - var startAreaName = AreaName.K绌虹鍏ュ簱鎺ラ┏鍖� - var endAreaName = AreaName.K绌虹璐ф灦鍖� + const string taskName = TaskName.H濂借繍绠盻绌虹鍏ュ簱; + const string startAreaName = AreaName.K绌虹鍏ュ簱鎺ラ┏鍖� + const string endAreaName = AreaName.K绌虹璐ф灦鍖� + const string cntrType = "濂借繍绠�; try { var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == model.StartLoc) + .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 == 0) // 缁戝畾鍓嶈揣浣嶄负绌�- .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 + .Where(l => l.N_CURRENT_NUM == 0) // 缁戝畾鍓� .First(); if (startLoc == null) { - info = $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣�{model.StartLoc}'锛屾垨涓嶆弧瓒宠姹傦細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0"; + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + + var cntr = db.Queryable<TN_Container>() + .Where(c => c.S_CODE == model.CntrCode) // 瀵逛簬鍓嶅彴绋嬪簭鑰岃█锛孲_CODE灏辨槸涓婚敭锛岀淮鎶ゆ椂蹇呭畾鍞竴 + .First(); + + if (cntr == null) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄥ鍣ㄨ〃涓笉瀛樺湪锛岃鍦ㄥ墠鍙伴〉闈腑缁存姢锛�; + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + if (cntr.S_TYPE != cntrType) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄥ鍣ㄨ〃涓殑绫诲瀷涓�{cntr.S_TYPE}'锛屼笌杈撳叆鐨勫鍣ㄧ被鍨�{cntrType}'涓嶅悓锛�; LogHelper.Info(info); return NewSimpleResult(2, info); } @@ -398,32 +384,18 @@ // 缁戝畾璐т綅鍜屽鍣ㄥ彿 var locCntrRel = new TN_Loc_Container { - S_LOC_CODE = model.StartLoc, - S_CNTR_CODE = model.CntrCode, - S_CNTR_TYPE = "濂借繍绠�, + S_LOC_CODE = startLoc.S_CODE, + S_CNTR_CODE = cntr.S_CODE, + S_CNTR_TYPE = cntrType, }; - // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級 - // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�- // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�- var cntrItemRel = db.Queryable<TN_Container_ItemType>() - .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First(); - var insertContainerItemType = false; - if (cntrItemRel == null) { - insertContainerItemType = true; - cntrItemRel = new TN_Container_ItemType { - S_ITEM_CODE = "", // 绌烘墭鐩樺垰鍏ュ簱锛屾病鏈夌墿鏂欑被鍨嬶紝灏遍粯璁ゅ厛涓虹┖ - S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE, - S_CNTR_CODE = locCntrRel.S_CNTR_CODE, - }; - } + startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚� - // 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 }) + .OrderBy(l => new { l.N_LAYER }) // TODO 鏆傚畾閫夋嫨鏈�綆灞傞『搴忓叆搴擄紝鍚庨潰寰呬慨鏀� .First(); if (endLoc == null) { @@ -433,65 +405,58 @@ } var cntId = locCntrRel.S_CNTR_CODE; + + LocationHelper.LockStartLoc(ref startLoc); + LocationHelper.LockEndLoc(ref endLoc); var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); - LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�- LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿�- using (var tran = db.Ado.UseTran()) { - if (insertContainerItemType) { - if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel); - tran.RollbackTran(); - LogHelper.Info(info); - return NewSimpleResult(5, info); - } - } - + // 瀛樺湪鏃с�鐗╂枡鏄庣粏銆戣〃鏃讹紝鍒犻櫎鏃ц〃 if (cgDetailOld != null) { if (db.Deleteable<TN_CG_Detail>(cgDetailOld).ExecuteCommand() <= 0) { - info = $"鍒犻櫎鏃х墿鏂欎俊鎭け璐ワ細" + JsonConvert.SerializeObject(cgDetailOld); + info = $"鍒犻櫎銆愭棫鐗╂枡淇℃伅銆戝け璐ワ細" + JsonConvert.SerializeObject(cgDetailOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } - + // 瀛樺湪鏃с�璐т綅瀹瑰櫒缁戝畾銆戣〃鏃讹紝鍒犻櫎鏃ц〃 if (locCntrRelOld != null) { if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0) { - info = $"鍒犻櫎鏃ц揣浣嶅鍣ㄥ叧绯诲け璐ワ細" + JsonConvert.SerializeObject(locCntrRelOld); + info = $"鍒犻櫎銆愭棫璐т綅瀹瑰櫒鍏崇郴銆戝け璐ワ細" + JsonConvert.SerializeObject(locCntrRelOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } if (locOld != null) { if (db.Updateable<TN_Location>(locOld).UpdateColumns(l => l.N_CURRENT_NUM).ExecuteCommand() <= 0) { - info = $"鏇存柊鏃ц揣浣嶅鍣ㄦ暟閲忓け璐ワ細" + JsonConvert.SerializeObject(locOld); + info = $"鏇存柊鏃ц揣浣嶃�瀹瑰櫒鏁伴噺銆戝け璐ワ細" + JsonConvert.SerializeObject(locOld); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(5, info); + return NewSimpleResult(500, info); } } if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) { - info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); + info = $"鎻掑叆銆愯揣浣嶅鍣ㄥ叧绯汇�澶辫触锛� + JsonConvert.SerializeObject(locCntrRel); tran.RollbackTran(); LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, 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 + it.T_MODIFY, + it.N_CURRENT_NUM }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -501,20 +466,20 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -522,7 +487,7 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -532,62 +497,96 @@ /// <remarks> /// 浜哄伐鏍规嵁褰撳墠鐢熶骇鐗╂枡鎵�渶鐨勫鍣ㄧ被鍨嬶紝鍛煎彨AGV浠庣┖瀹瑰櫒璐ф灦涓彨涓�釜绗﹀悎瑕佹眰鐨勬墭鐩� /// </remarks> - /// <param name="model"></param> + /// <param name="model">鍖呭惈锛氬鍣ㄥ彿銆佺墿鏂欑紪鐮�/param> /// <returns></returns> public static SimpleResult EmptyOnlinePallet(EmptyOnlinePalletInfo model) { var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.T鎵樼洏_绌烘墭涓婄嚎; - var startAreaName = AreaName.K绌烘墭瀛樻斁鍖� - var endAreaName = AreaName.B鍖呰鍖� + const string taskName = TaskName.T鎵樼洏_绌烘墭涓婄嚎; + const string startAreaName = AreaName.K绌烘墭瀛樻斁鍖� + const string endAreaName = AreaName.B鍖呰鍖� + const string cntrType = "鎵樼洏"; try { - // 鏌ュ鍣�鐗╂枡绫诲瀷琛�- var cntrItemRel = db.Queryable<TN_Container_ItemType>() - .Where(i => i.S_CNTR_CODE == model.CntId && i.S_CNTR_TYPE == "鎵樼洏") + var cntr = db.Queryable<TN_Container>() + .Where(c => c.S_CODE == model.CntId) .First(); - // 濡傛灉琛ㄤ腑瀛樺湪杩欎釜鎵樼洏淇℃伅锛屼笖鐗╂枡绫诲瀷涓庝笂绾挎墍闇�墿鏂欎笉绗︼紝鎶ラ敊 - // 濡傛灉涓嶅瓨鍦紝涓嶄綔闄愬埗锛堣浣滅涓�涓婄嚎锛�- if (cntrItemRel != null && cntrItemRel.S_ITEM_CODE != model.ItemCode) { - info = $"瀹瑰櫒{model.CntId}宸茬粡涓庣墿鏂欑被鍨媨cntrItemRel.S_ITEM_CODE}缁戝畾锛屾棤娉曠敤浜庤杞界墿鏂檣model.ItemCode}"; + + if (cntr == null) { + info = $"瀹瑰櫒'{model.CntId}'鍦ㄥ鍣ㄨ〃涓笉瀛樺湪锛岃鍦ㄥ墠鍙伴〉闈腑缁存姢锛�; + LogHelper.Info(info); + return NewSimpleResult(1, info); + } + if (cntr.S_TYPE != cntrType) { // 瀹瑰櫒绫诲瀷榛樿涓嶄細涓虹┖ + info = $"瀹瑰櫒'{model.CntId}'鍦ㄥ鍣ㄨ〃涓殑绫诲瀷鏄�{cntr.S_TYPE}锛屼笉鏄�{cntrType}'锛�; LogHelper.Info(info); return NewSimpleResult(2, info); } + var needUpdateContainer = false; + if (string.IsNullOrEmpty(cntr.S_SPEC)) { + // TEMP 鐩墠娴佺▼锛氬鏋滃鍣ㄨ〃涓鏍硷紙鐗╂枡缂栫爜锛変负绌猴紝鏍规嵁娴佺▼鐨勭墿鏂欎俊鎭啓鍏�+ // 寰呭畾锛氬悗闈㈠彲鑳戒細鏇存敼娴佺▼锛屾垨鑰呯敤鍏朵粬淇℃伅锛堝鐗╂枡绫诲瀷/瑙勬牸锛変綔涓哄鍣ㄧ殑瑙勬牸 + + needUpdateContainer = true; + info = $"瀹瑰櫒'{model.CntId}'鍦ㄥ鍣ㄨ〃涓�瑙勬牸锛堢墿鏂欑紪鐮侊級涓虹┖锛屽皢鐗╂枡缂栫爜'{model.ItemCode}'鍐欏叆瀹瑰櫒鐨勮鏍�; + LogHelper.Info(info); + + cntr.S_SPEC = model.ItemCode; + } + else if (cntr.S_SPEC != model.ItemCode) { + info = $"瀹瑰櫒'{model.CntId}'宸茬粡涓庣墿鏂欑被鍨�{cntr.S_SPEC}'缁戝畾锛屾棤娉曠敤浜庤杞界墿鏂�{model.ItemCode}'"; + LogHelper.Info(info); + return NewSimpleResult(3, info); + } + 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 == 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) // 绛涢�锛氭湁璐ц揣浣�+ .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) { - info = $"鍦ㄧ┖鎵樺瓨鏀惧尯涓紝鎵句笉鍒扮鍚坽model.ItemCode}鐗╂枡锛屼笖缂栫爜涓簕model.CntId}鐨勭┖鎵樼洏"; + info = $"鍦�{startAreaName}'涓紝鎵句笉鍒伴�鐢ㄤ簬{model.ItemCode}鐗╂枡銆佷笖缂栫爜涓簕model.CntId}鐨勭┖鎵樼洏"; LogHelper.Info(info); return NewSimpleResult(3, info); } 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) // 绛涢�锛氱┖璐т綅 + .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) { - info = $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�; + info = $"鍦�{endAreaName}'涓紝鎵句笉鍒板悎閫傜殑銆愮粓鐐硅揣浣嶃�锛岄渶瑕佹弧瓒筹細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0"; LogHelper.Info(info); return NewSimpleResult(4, info); } var cntId = model.CntId; - var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿� LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿�+ var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); + + cntr.S_SOURCE = task.S_CODE; // 鐢ㄤ换鍔″彿浣滀负瀹瑰櫒鏇存柊鐨勪緷鎹�+ cntr.T_MODIFY = DateTime.Now; using (var tran = db.Ado.UseTran()) { + if (needUpdateContainer) { + if (db.Updateable<TN_Container>(cntr) + .UpdateColumns(c => new { c.S_SPEC, c.S_SOURCE, c.T_MODIFY }).ExecuteCommand() <= 0) { + tran.RollbackTran(); + info = $"鏇存柊琛ㄥ鍣ㄨ〃澶辫触锛� + JsonConvert.SerializeObject(cntr); + LogHelper.Info(info); + return NewSimpleResult(500, info); + } + } + if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE, @@ -595,9 +594,9 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -607,20 +606,20 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -628,7 +627,7 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -641,21 +640,37 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.H濂借繍绠盻绌虹涓婄嚎; - var startAreaName = AreaName.K绌虹璐ф灦鍖� - var endAreaName = AreaName.K绌虹鎿嶄綔鍖� + const string taskName = TaskName.H濂借繍绠盻绌虹涓婄嚎; + const string startAreaName = AreaName.K绌虹璐ф灦鍖� + const string endAreaName = AreaName.K绌虹鎿嶄綔鍖� + const string cntrType = "濂借繍绠�; try { + var cntr = db.Queryable<TN_Container>() + .Where(c => c.S_CODE == model.CntId) + .First(); + + if (cntr == null) { + info = $"瀹瑰櫒'{model.CntId}'鍦ㄣ�瀹瑰櫒琛ㄣ�涓笉瀛樺湪锛岃鍦ㄥ墠鍙伴〉闈腑缁存姢锛�; + LogHelper.Info(info); + return NewSimpleResult(1, info); + } + if (cntr.S_TYPE != cntrType) { + info = $"瀹瑰櫒'{model.CntId}'鍦ㄣ�瀹瑰櫒琛ㄣ�涓殑绫诲瀷={cntr.S_TYPE}锛屼笉鏄�{cntrType}'锛�; + LogHelper.Info(info); + return NewSimpleResult(2, info); + } + 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 == model.CntId) + .Where((l, c) => c.S_CNTR_CODE == model.CntId && c.S_CNTR_TYPE == "濂借繍绠�) .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) { - info = $"鍦�{startAreaName}'涓紝鎵句笉鍒扮紪鐮佷负{model.CntId}鐨勭┖濂借繍绠�; + info = $"鍦�{startAreaName}'涓紝鎵句笉鍒板瓨鏀惧鍣ㄧ紪鐮�{model.CntId}鐨勭┖濂借繍绠辩殑銆愯捣鐐硅揣浣嶃�锛屾垨涓嶆弧瓒筹細鏈笂閿併�褰撳墠鏁伴噺=1"; LogHelper.Info(info); return NewSimpleResult(2, info); } @@ -667,7 +682,7 @@ .First(); if (endLoc == null) { - info = $"缁堢偣浣嶇疆 涓嶅瓨鍦ㄦ垨涓嶅叿澶囨斁璐ц姹�; + info = $"鍦�{endAreaName}'涓紝鎵句笉鍒板悎閫傜殑銆愮粓鐐硅揣浣嶃�锛岄渶瑕佹弧瓒筹細鏈笂閿併�褰撳墠鏁伴噺=0"; LogHelper.Info(info); return NewSimpleResult(4, info); } @@ -686,9 +701,9 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -698,20 +713,20 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -719,7 +734,7 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -733,8 +748,9 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.C鎶芥_鍚堟牸鍥炲簱; - var startAreaName = AreaName.C鎶芥鍖� + const string taskName = TaskName.C鎶芥_鍚堟牸鍥炲簱; + const string startAreaName = AreaName.C鎶芥鍖� + var endAreaName = ""; try { var cgDetail = db.Queryable<TN_CG_Detail>() @@ -742,12 +758,20 @@ .First(); if (cgDetail == null) { - return NewSimpleResult(2, "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡锛� + JsonConvert.SerializeObject(model)); + info = "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡锛� + JsonConvert.SerializeObject(model); + LogHelper.Info(info); + return NewSimpleResult(2, info); } var locCntrRel = db.Queryable<TN_Loc_Container>() .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE) .First(); + + if (locCntrRel == null) { + info = $"瀹瑰櫒{model.CntrCode}鍦ㄨ揣浣嶅鍣ㄥ叧绯昏〃涓笉瀛樺湪"; + LogHelper.Info(info); + return NewSimpleResult(3, info); + } var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE) @@ -759,36 +783,39 @@ if (startLoc == null) { info = $"鍦�{startAreaName}'涓病鏈夋壘鍒板鍣▄model.CntrCode}鐨勮捣鐐硅揣浣嶏紝鎴栦笉鍏峰鍙栬揣瑕佹眰锛氭湭涓婇攣銆佹湁璐х墿"; LogHelper.Info(info); - return NewSimpleResult(0, info); + return NewSimpleResult(4, info); } - var endLoc = new TN_Location(); + TN_Location endLoc = null; if (locCntrRel.S_CNTR_TYPE == "鎵樼洏") { + endAreaName = AreaName.M婊℃墭璐ф灦鍖� endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.M婊℃墭璐ф灦鍖篯.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(); } else if (locCntrRel.S_CNTR_TYPE == "濂借繍绠�) { + endAreaName = AreaName.M婊$璐ф灦鍖� endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.M婊$璐ф灦鍖篯.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(); } else { - return NewSimpleResult(2, $"鎵樼洏绫诲瀷{locCntrRel.S_CNTR_TYPE}涓嶅悎娉曪細鎵樼洏鍙穥locCntrRel.S_CNTR_CODE}"); + return NewSimpleResult(-1, $"鎵樼洏绫诲瀷{locCntrRel.S_CNTR_TYPE}涓嶅悎娉曪細鎵樼洏鍙穥locCntrRel.S_CNTR_CODE}"); } if (endLoc == null) { - info = "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"; + info = $"鍦ㄣ�{endAreaName}銆戜腑娌℃湁鎵惧埌鍚堥�鐨勩�缁堢偣璐т綅銆戯紝鎴栦笉婊¤冻瑕佹眰锛氭湭涓婇攣銆佸綋鍓嶅鍣ㄦ暟閲忎负 0"; LogHelper.Info(info); return NewSimpleResult(3, info); } cgDetail.N_ITEM_STATE = 0; cgDetail.S_ITEM_STATE = "鍚堟牸"; + cgDetail.T_MODIFY = DateTime.Now; var cntId = locCntrRel.S_CNTR_CODE; var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); @@ -798,11 +825,11 @@ using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_CG_Detail>(cgDetail).UpdateColumns(it => - new { it.N_ITEM_STATE, it.S_ITEM_STATE }).ExecuteCommand() <= 0) { + new { it.N_ITEM_STATE, it.S_ITEM_STATE, it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = "淇敼鐗╂枡鐘舵�涓哄悎鏍�澶辫触"; + info = $"鐢熸垚'{taskName}'澶辫触锛氫慨鏀圭墿鏂欑姸鎬佷负'鍚堟牸'澶辫触"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -812,9 +839,9 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -823,29 +850,29 @@ it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - return NewSimpleResult(0, - $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"); + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={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); + return NewSimpleResult(-1, info); } } @@ -858,12 +885,14 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.C鎶芥_涓嶅悎鏍肩Щ搴� + const string taskName = TaskName.C鎶芥_涓嶅悎鏍肩Щ搴� + const string startAreaName = AreaName.C鎶芥鍖� + const string endAreaName = AreaName.C鎶芥寮傚父鍖� try { - if (!Settings.AreaMap[AreaName.C鎶芥寮傚父鍖篯.Contains(model.EndArea)) { - info = $"缁堢偣搴撳尯{model.EndArea}涓嶅睘浜巤AreaName.C鎶芥寮傚父鍖簘"; + if (!Settings.AreaMap[endAreaName].Contains(model.EndArea)) { + info = $"杈撳叆鐨勭粓鐐瑰簱鍖�{model.EndArea}'涓嶅睘浜�{endAreaName}'!"; LogHelper.Info(info); return NewSimpleResult(1, info); } @@ -873,25 +902,32 @@ .First(); if (cgDetail == null) { - - return NewSimpleResult(2, "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡"); + info = $"娌℃湁鍦ㄧ墿鏂欐槑缁嗚〃涓紝鎵惧埌鐗╂枡缂栫爜={model.ItemCode}銆佸鍣ㄧ紪鐮�{model.CntrCode}鐨勭墿鏂�; + LogHelper.Info(info); + return NewSimpleResult(2, info); } var locCntrRel = db.Queryable<TN_Loc_Container>() .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE) .First(); + if (locCntrRel == null) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄨ揣浣嶅鍣ㄥ叧绯昏〃涓笉瀛樺湪"; + LogHelper.Info(info); + return NewSimpleResult(3, info); + } + var startLoc = db.Queryable<TN_Location>() .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE) + .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) - .Where(l => Settings.AreaMap[AreaName.C鎶芥鍖篯.Contains(l.S_AREA_CODE)) // 璧风偣璐у尯绗﹀悎浠诲姟瑕佹眰 .First(); if (startLoc == null) { - info = "娌℃湁鎵惧埌鍚堥�鐨勮捣鐐硅揣浣�; + info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣�{locCntrRel.S_LOC_CODE}'锛屾垨涓嶆弧瓒宠姹傦細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0"; LogHelper.Info(info); - return NewSimpleResult(0, info); + return NewSimpleResult(2, info); } var endLoc = db.Queryable<TN_Location>() @@ -901,7 +937,9 @@ .First(); if (endLoc == null) { - return NewSimpleResult(3, "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"); + info = $"鍦ㄧ粓鐐硅揣鍖�{model.EndArea}'涓紝娌℃湁鎵惧埌鍚堥�鐨勩�缁堢偣璐т綅銆戯紝闇�婊¤冻瑕佹眰锛氭湭涓婇攣銆佸綋鍓嶅鍣ㄦ暟閲�0"; + LogHelper.Info(info); + return NewSimpleResult(3, info); } cgDetail.N_ITEM_STATE = 2; @@ -917,9 +955,9 @@ if (db.Updateable<TN_CG_Detail>(cgDetail).UpdateColumns(it => new { it.N_ITEM_STATE, it.S_ITEM_STATE }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = "淇敼鐗╂枡鐘舵�涓哄悎鏍�澶辫触"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氫慨鏀圭墿鏂欑姸鎬佷负'涓嶅悎鏍�澶辫触"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -929,9 +967,9 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -940,29 +978,29 @@ it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - return NewSimpleResult(0, - $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"); + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={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); + return NewSimpleResult(-1, info); } } @@ -975,7 +1013,8 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.W灏剧鍥炲簱; + const string taskName = TaskName.W灏剧鍥炲簱; + var endAreaName = ""; try { var startLoc = db.Queryable<TN_Location>() @@ -1000,25 +1039,23 @@ return NewSimpleResult(3, info); } - //var endLoc = new TN_Location(); TN_Location endLoc = null; if (locCntrRel.S_CNTR_TYPE == "鎵樼洏") { + endAreaName = AreaName.M婊℃墭璐ф灦鍖� endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.M婊℃墭璐ф灦鍖篯.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) // 璧风偣缁戝畾鍓嶆病鏈夊鍣�+ .Where(l => l.N_CURRENT_NUM == 0) .First(); } - else if (locCntrRel.S_CNTR_TYPE =="濂借繍绠�){ + else if (locCntrRel.S_CNTR_TYPE == "濂借繍绠�){ + endAreaName = AreaName.M婊$璐ф灦鍖� endLoc = db.Queryable<TN_Location>() - .Where(l => Settings.AreaMap[AreaName.M婊$璐ф灦鍖篯.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) // 璧风偣缁戝畾鍓嶆病鏈夊鍣�+ .Where(l => l.N_CURRENT_NUM == 0) .First(); } - //else { - // endLoc = null; - //} if (endLoc == null) { info = "鏌ヨ锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅"; @@ -1027,10 +1064,10 @@ } var cntId = locCntrRel.S_CNTR_CODE; - var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿� LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿�+ var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); using (var tran = db.Ado.UseTran()) { if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { @@ -1040,9 +1077,9 @@ it.T_MODIFY }).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { @@ -1051,22 +1088,21 @@ it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) { - tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣�{endLoc.S_CODE}'閿佺姸鎬佸け璐�; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) { tran.RollbackTran(); - info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); - return NewSimpleResult(4, info); + return NewSimpleResult(500, info); } tran.CommitTran(); - info = $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}"; + info = $"鐢熸垚浠诲姟'{taskName}'鎴愬姛锛屼换鍔″彿={task.S_CODE}锛屽鍣ㄥ彿={cntId}锛岃捣鐐�{startLoc.S_CODE}锛岀粓鐐�{endLoc.S_CODE}"; LogHelper.Info(info); return NewSimpleResult(0, info); } @@ -1074,7 +1110,7 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewSimpleResult(1, info); + return NewSimpleResult(-1, info); } } @@ -1090,12 +1126,12 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.C鎴愬搧鑳跺嚭搴� + const string taskName = TaskName.C鎴愬搧鑳跺嚭搴� try { - var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "CKD"); - var cgDetailList = SelectCgByTotalQty(model); + var cgDetailList = SelectCgByTotalQty(model.Qty, model.ItemCode, model.BatchNo, model.CntrType, model.ForcedOut); if (cgDetailList.Count == 0) { info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�; @@ -1161,12 +1197,12 @@ var db = new SqlHelper<object>().GetInstance(); var info = ""; - var taskName = TaskName.C鎴愬搧鑳跺嚭搴� + const string taskName = TaskName.C鎴愬搧鑳跺嚭搴� try { - var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "CKD"); - var cgDetailList = SelectCgByTotalQty(model); + var cgDetailList = SelectCgByTotalQty(model.Qty, model.ItemCode, model.BatchNo, model.CntrType, model.ForcedOut); if (cgDetailList.Count == 0) { info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�; @@ -1224,14 +1260,14 @@ } } - public static List<TN_CG_Detail> SelectCgByTotalQty(FinishedOutboundInfo model) { + public static List<TN_CG_Detail> SelectCgByTotalQty(int qty, string itemCode, string batchNo, string cntrType = "", bool forcedOut = true) { var db = new SqlHelper<object>().GetInstance(); var result = new List<TN_CG_Detail>(); - var targetNum = model.Qty; + var targetNum = qty; var info = ""; try { var targetCg = db.Queryable<TN_CG_Detail>() - .Where(a => a.S_ITEM_CODE == model.ItemCode && a.S_BATCH_NO == model.BatchNo) + .Where(a => a.S_ITEM_CODE == itemCode && a.S_BATCH_NO == batchNo) .Where(a => a.N_ITEM_NUM > targetNum) .OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc).First(); if (targetCg != null) //鍒氬ソ鏈変竴琛屾弧瓒虫潯浠�@@ -1244,10 +1280,18 @@ var sortedMaterials = new List<TN_CG_Detail>(); - if (model.ForcedOut) { + var cntrTypeList = new List<string>(); + if (cntrType == "") { + cntrTypeList = new List<string> { "鎵樼洏", "濂借繍绠� }; // 涓嶆寚瀹氭墭鐩樼被鍨嬶紝浜岃�鍧囧彲 + } + else { + cntrTypeList.Add(cntrType); + } + + if (forcedOut) { 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.S_ITEM_CODE == itemCode && d.S_BATCH_NO == batchNo && d.N_ITEM_NUM > 0) + .Where((d, c) => cntrTypeList.Contains(c.S_CNTR_TYPE)) .Where(d => d.N_ITEM_STATE == 0 && d.S_ITEM_STATE == "鍚堟牸" || d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "寰呮") .OrderBy(d => d.N_ITEM_NUM, OrderByType.Desc) @@ -1255,13 +1299,12 @@ } else { 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.S_ITEM_CODE == itemCode && d.S_BATCH_NO == batchNo && d.N_ITEM_NUM > 0) + .Where((d, c) => cntrTypeList.Contains(c.S_CNTR_TYPE)) .Where(d => d.N_ITEM_STATE == 0 && 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) //娌℃湁婊¤冻鏉′欢鐨� { @@ -1307,12 +1350,49 @@ var info = ""; try { + if (string.IsNullOrEmpty(model.ItemCode)) { + info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氱墿鏂欑紪鐮侊紙itemCode锛変笉鑳戒负绌�; + LogHelper.Info(info); + return NewMesResult(400, info); + } + if (string.IsNullOrEmpty(model.CntrCode)) { + info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氬鍣ㄧ紪鐮侊紙CntrCode锛変笉鑳戒负绌�; + LogHelper.Info(info); + return NewMesResult(400, info); + } + if (string.IsNullOrEmpty(model.BatchNo)) { + info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氭壒娆″彿锛圔atchNo锛変笉鑳戒负绌�; + LogHelper.Info(info); + return NewMesResult(400, info); + } + if (model.ItemNum <= 0) { + info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氳揣鍝佹暟閲忥紙ItemNum锛夊簲璇ュぇ浜�0"; + LogHelper.Info(info); + return NewMesResult(400, info); + } + + // TEMP 鐩墠娴佺▼锛氬鍗氬疄涓嬪彂鐨勪俊鎭篃杩涜妫�煡锛屾湭鎵惧埌灏辨姤閿欙紝鍚庨潰鏈夐渶姹傚啀鏇存敼 + var cntr = db.Queryable<TN_Container>() + .Where(c => c.S_CODE == model.CntrCode) // 瀵逛簬鍓嶅彴绋嬪簭鑰岃█锛孲_CODE灏辨槸涓婚敭锛岀淮鎶ゆ椂蹇呭畾鍞竴 + .First(); + + if (cntr == null) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄥ鍣ㄨ〃涓笉瀛樺湪锛岃鍦ㄥ墠鍙伴〉闈腑缁存姢锛�; + LogHelper.Info(info); + return NewMesResult(1, info); + } + if (cntr.S_TYPE != "濂借繍绠�) { + info = $"瀹瑰櫒'{model.CntrCode}'鍦ㄥ鍣ㄨ〃涓殑绫诲瀷涓�{cntr.S_TYPE}'锛屼笌褰撳墠瀹瑰櫒绫诲瀷'濂借繍绠�涓嶅悓锛�; + LogHelper.Info(info); + return NewMesResult(2, info); + } + // 灏嗕笅鍙戠殑淇℃伅鍏堝瓨鍌ㄥ埌CG琛ㄤ腑锛堟鏃舵墭鐩樻病鏈変笌浜х嚎澶勭殑璐т綅缁戝畾锛� var detail = new TN_CG_Detail { - S_ITEM_CODE = model.ItemCode, - S_ITEM_NAME = model.ItemName, - S_CNTR_CODE = model.CntrCode, // 鏂欑缂栧彿锛堝緟瀹氾紝鐜板湪鏆傛椂璁惧畾涓哄崥瀹炰笅鍙戯級 - S_BATCH_NO = model.BatchNo, + S_ITEM_CODE = model.ItemCode, // NOT NULL + S_ITEM_NAME = model.ItemName, + S_CNTR_CODE = model.CntrCode, // NOT NULL 鏂欑缂栧彿锛堝緟瀹氾紝鐜板湪鏆傛椂璁惧畾涓哄崥瀹炰笅鍙戯級 + S_BATCH_NO = model.BatchNo, // NOT NULL S_STANDARD = model.Standard, S_NET_WEIGHT = model.NetWeight, S_QUALITY_GRADE = model.QualityGrade, @@ -1335,7 +1415,7 @@ if (db.Insertable<TN_CG_Detail>(detail).ExecuteCommand() <= 0) { tran.RollbackTran(); info = "鎻掑叆鐗╂枡淇℃伅澶辫触锛� + JsonConvert.SerializeObject(detail); - return NewMesResult(2, info); + return NewMesResult(500, info); } tran.CommitTran(); @@ -1347,30 +1427,82 @@ catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; LogHelper.InfoEx(ex); - return NewMesResult(1, info); + return NewMesResult(-1, info); } } - public static ErpResult ErpSendOutboundOrder(ErpSendOutboundOrderInfo model) { + public static ErpResult ErpSendOutboundPlan(ErpSendOutboundPlanInfo model) { var db = new SqlHelper<object>().GetInstance(); - var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON"); + var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "CKD"); var info = ""; try { - if (string.IsNullOrEmpty(orderNo)) { - info = "鍑哄簱鍗曞彿涓嶈兘涓虹┖"; + // 鍙傛暟鍚堟硶鎬х‘璁ら儴鍒嗭細閿欒缂栫爜锛�00 + if (model.pzsl <= 0) { + info = $"鐗╂枡鏁伴噺(pzsl){model.pzsl}涓嶅悎娉曪細鐗╂枡鏁伴噺搴旇澶т簬 0"; LogHelper.Info(info); - return NewErpResult(2, info); + return NewErpResult(400, 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 - }); + var outboundPlan = new TN_Outbound_Plan { + JHDH = model.jhdh, // 璁″垝鍗曞彿锛堝敮涓�爣璇嗭級 + CKZT = model.ckzt, // 鍑哄簱鐘舵� + JHLB = model.jhlb, // 璁″垝绫诲埆 + CKDH = model.ckdh, // 鍙傝�鍗曞彿 + CPH = model.cph, // 杞︾墝鍙�+ YSFS = model.ysfs, // 杩愯緭鏂瑰紡 + CPZT = model.cpzt, // 浜у搧鐘舵� + MDDW = model.mddw, // 涔版柇鍗曚綅 + CPDM = model.cpdm, // 浜у搧浠g爜 + CPLB = model.cplb, // 浜у搧绫诲埆 + CPLBMX = model.cplbmx, // 浜у搧绫诲埆鏄庣粏 + PP = model.pp, // 鍝佺墝 + DJ = model.dj, // 绛夌骇 + GH = model.gh, // 缃愬彿 + PH = model.ph, // 鎵瑰彿 + BZLX = model.bzlx, // 鍖呰绫诲瀷 + PZDH = model.pzdh, // 娲捐鍗曞彿 + PZD_DW = model.pzd_dw, // 娲捐鍗曞崟浣�+ PZD_DYBH = model.pzd_dybh, // 娲捐鍗曡皟杩愮紪鍙�+ PZJS = model.pzjs, // 娲捐浠舵暟 + PZSL = model.pzsl, // 娲捐鏁伴噺 + PZ_RQ = model.pz_rq, // 娲捐鏃ユ湡(yyyy-mm-dd) + PZ_CZRQ = model.pz_czrq, // 娲捐鎿嶄綔鏃ユ湡 + PZ_ZFBJ = model.pz_zfbj, // 娲捐浣滃簾鏍囪 + PZ_ZFRQ = model.pz_zfrq, // 娲捐浣滃簾鏃ユ湡 + PZ_BZ = model.pz_bz, // 娲捐澶囨敞 + CKDBH = model.ckdbh, // 鍑哄簱鍗曠紪鍙�+ SFJS = model.sfjs, // 瀹炲彂浠舵暟 + SFSL = model.sfsl, // 瀹炲彂鏁伴噺 + SFCS = model.sfcs, // 瀹炲彂杞︽暟 + ZCSJ = model.zcsj, // 瑁呰溅鏃堕棿 + JLDW = model.jldw, // 璁¢噺鍗曚綅 + FHRQ = model.fhrq, // 鍙戣揣鏃ユ湡 + CKDM = model.ckdm, // 浠撳簱浠g爜 + FHR = model.fhr, // 鍙戣揣浜�+ CZYDM = model.czydm, // 鎿嶄綔鍛�+ SHR_USERNAME = model.shr_username, // 瀹℃牳浜�+ SHRQ = model.shrq, // 瀹℃牳鏃ユ湡 + ZFBJ = model.zfbj, // 浣滃簾鏍囪 + ZFRQ = model.zfrq, // 浣滃簾鏃ユ湡 + JSDW = model.jsdw, // 缁撶畻鍗曚綅 + SHDW = model.shdw, // 鏀惰揣鍗曚綅 + YSDW = model.ysdw, // 杩愯緭鍗曚綅 + LXR = model.lxr, // 鑱旂郴浜�+ RY_ZXG = model.ry_zxg, // 瑁呭嵏宸�+ RY_CCSJ = model.ry_ccsj, // 鍙夎溅鍙告満 + ERPHX_JHDH = model.erphx_jhdh, // erp浜よ揣鍗曞彿 + ERPHX_WLBM = model.erphx_wlbm, // erp鐗╂枡缂栫爜 + ERPHX_WLMC = model.erphx_wlmc, // erp鐗╂枡鍚嶇О + ERPHX_CJRQ = model.erphx_cjrq, // erp鍒涘缓鏃ユ湡 + HW = model.hw, // 璐т綅 + HWZT = model.hwzt // 璐т綅鐘舵� + }; + + var cgDetailList = SelectCgByTotalQty( + qty: (int)model.pzsl, + itemCode: model.cpdm, + batchNo: model.ph + ); if (cgDetailList.Count == 0) { info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�; @@ -1380,12 +1512,12 @@ var order = new TN_Outbound_Order { S_NO = orderNo, - S_ITEM_CODE = model.ItemCode, - S_BATCH = model.BatchNo, - N_END_NUM = model.Qty, + S_ITEM_CODE = model.cpdm, + S_BATCH = model.ph, + N_END_NUM = (int)model.pzsl, //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY), - S_END_AREA = model.EndArea, - S_BS_NO = model.ErpNo, + S_END_AREA = model.ysfs == "姹借溅" ? "QCCKQ" : "HCCKQ", // 鏆傛椂鐢ㄨ繍杈撴柟寮忥紙鐏溅/姹借溅锛夋潵鍖哄垎缁堢偣璐у尯 + S_BS_NO = model.jhdh, S_BS_TYPE = "ERP", }; @@ -1397,7 +1529,9 @@ 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 + S_END_AREA = order.S_END_AREA, // order涓篸etail鐨勬瘡涓�釜璐т綅璁剧疆缁堢偣鍊�+ S_BS_NO = order.S_BS_NO, + S_BS_TYPE= order.S_BS_TYPE, }; detailList.Add(detail); } @@ -1407,20 +1541,29 @@ tran.RollbackTran(); info = "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order); LogHelper.Info(info); - return NewErpResult(2, info); + return NewErpResult(500, info); } if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) { tran.RollbackTran(); info = "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐�; LogHelper.Info(info); - return NewErpResult(4, info); + return NewErpResult(500, info); + } + + if (db.Insertable<TN_Outbound_Plan>(outboundPlan).ExecuteCommand() <= 0) { + tran.RollbackTran(); + info = "鐢熸垚鍑哄簱鍗曡鍒掕褰曡〃澶辫触"; + LogHelper.Info(info); + return NewErpResult(500, info); } tran.CommitTran(); } - return NewErpResult(0, "鐢熸垚鍑哄簱鍗曟垚鍔�); + info = $"鐢熸垚鍑哄簱鍗曟垚鍔�; + LogHelper.Info(info); + return NewErpResult(0, info); } catch (Exception ex) { info = $"鍙戠敓浜嗗紓甯革細{ex.Message}"; -- Gitblit v1.9.1