From f3ad86fe50a0d2ba81b203517184264eea7bf0c0 Mon Sep 17 00:00:00 2001 From: hudong <Administrator@PC-20250329JZUF> Date: 星期四, 05 六月 2025 17:04:44 +0800 Subject: [PATCH] 入库审核逻辑更改 代码修改 --- api/WmsSpaHelper.cs | 2605 +++++++++++++++++++++++++++++++++++------------------------ 1 files changed, 1,542 insertions(+), 1,063 deletions(-) diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs index 98d4402..ca8958c 100644 --- a/api/WmsSpaHelper.cs +++ b/api/WmsSpaHelper.cs @@ -30,11 +30,11 @@ using System.Security.Policy; using HH.WCS.Mobox3.pinggao.models; using static HH.WCS.Mobox3.pinggao.wms.WMSHelper; -using WHTest; using System.Net; using SqlSugar; using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto; using System.Web.Services.Protocols; +using System.Web.Http.ValueProviders; namespace HH.WCS.Mobox3.pinggao.api { @@ -45,6 +45,34 @@ } + public static bool MaterPanduan(string ItemCode,double count) { + bool panduan = true; + var db = new SqlHelper<object>().GetInstance(); + + var po = db.Queryable<TN_Material_KC>().Where(a => a.S_ITEM_CODE == ItemCode).First(); + + var po1 = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == ItemCode).First(); + if (po != null) + { + if (po1!=null) + { + double sl= po1.F_QTY + count; + if (sl>po.N_COUNT) + { + panduan = false; + } + } + if (count > po.N_COUNT) + { + panduan = false; + } + } + else + { + panduan = false; + } + return panduan; + } /// <summary> /// 鏁版嵁 /// </summary> @@ -382,210 +410,102 @@ //else //{ //鍒ゆ柇鍐查攢鍑瘉缂栧彿 鏄惁涓虹┖ 濡傛灉涓虹┖ 鍒欎负鍐查攢(瀹℃牳鍓嶆墠鑳藉啿閿�紝闈炲緟鎵ц鐘舵�鎻愮ず鎵ц涓笉鍙啿閿� 涓嶄负绌�鍒欎负澶栭噰鍏ュ簱 - - if ((items.ITEM.Where(s => s.CXPZH != null && s.CXPZH != "").Count() > 0)) + if (items.HEAD.YDLX != "124") { - //鍒ゆ柇鍐查攢鐗╂枡鏄惁涓哄悓涓�釜鍏ュ簱鍗�- if (items.ITEM.Select(s => s.CXPZH).Distinct().Count() > 1) + if ((items.ITEM.Where(s => s.CXPZH != null && s.CXPZH != "").Count() > 0)) { - result.WLPZBH = items.HEAD.WLPZH; - result.WLPZND = items.HEAD.WLPZND; - result.resultCode = 1; - result.resultMsg = "鍐查攢鐗╂枡涓嶅睘浜庡悓涓�鍗�; - result.resultMsg = "澶辫触"; - simpleResults.Add(result); - continue; - } - //鍐查攢鍑瘉鍗曞彿 - var cxpzbh = items.ITEM[0].CXPZH; - var po = WMSHelper.GetInboundOrder(cxpzbh); - //鍒ゆ柇鏄惁鎵ц 鎵ц涓鍗曞厑璁稿啿閿�- if (po == null) - { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.WLPZND = items.HEAD.WLPZND; - result.resultCode = 1; - result.resultMsg = "鏈壘鍒版璁㈠崟"; - simpleResults.Add(result); - continue; - } - if (po.N_B_STATE != 0 && po.N_B_STATE != 7) - { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.resultCode = 1; - result.WLPZND = items.HEAD.WLPZND; - result.resultMsg = "鎵ц涓鍗曚笉鍏佽鎿嶄綔"; - simpleResults.Add(result); - continue; - } - foreach (var item in items.ITEM) - { - ///鍒ゆ柇鏄惁閮芥湁鍐查攢鍑瘉缂栧彿 - if (string.IsNullOrEmpty(item.CXPZH)) + //鍒ゆ柇鍐查攢鐗╂枡鏄惁涓哄悓涓�釜鍏ュ簱鍗�+ if (items.ITEM.Select(s => s.CXPZH).Distinct().Count() > 1) + { + result.WLPZBH = items.HEAD.WLPZH; + result.WLPZND = items.HEAD.WLPZND; + result.resultCode = 1; + result.resultMsg = "鍐查攢鐗╂枡涓嶅睘浜庡悓涓�鍗�; + result.resultMsg = "澶辫触"; + simpleResults.Add(result); + continue; + } + //鍐查攢鍑瘉鍗曞彿 + var cxpzbh = items.ITEM[0].CXPZH; + var po = WMSHelper.GetInboundOrder(cxpzbh); + //鍒ゆ柇鏄惁鎵ц 鎵ц涓鍗曞厑璁稿啿閿�+ if (po == null) + { + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.WLPZND = items.HEAD.WLPZND; + result.resultCode = 1; + result.resultMsg = "鏈壘鍒版璁㈠崟"; + simpleResults.Add(result); + continue; + } + if (po.N_B_STATE != 0 && po.N_B_STATE != 7) { result.resultMsg = "澶辫触"; result.WLPZBH = items.HEAD.WLPZH; result.resultCode = 1; result.WLPZND = items.HEAD.WLPZND; - result.resultMsg = "鍐查攢鍗曟湁鐗╂枡鍐查攢缂栧彿涓虹┖"; + result.resultMsg = "鎵ц涓鍗曚笉鍏佽鎿嶄綔"; simpleResults.Add(result); continue; } - var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); - if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//鏁伴噺澶т簬鏄庣粏 + foreach (var item in items.ITEM) { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.WLPZND = items.HEAD.WLPZND; - result.resultMsg = $"鍐查攢鐗╂枡{item.WLBM}鏁伴噺{item.SL}澶т簬瀛樺叆鏁伴噺"; - simpleResults.Add(result); - continue; - } - else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//鏁伴噺==鏄庣粏 鍒犻櫎褰撲笅鍏ュ簱鍗曠墿鏂欐暟鎹�- { - db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); - } - else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//鏁伴噺灏忎簬鏄庣粏 - { - //褰撳墠鐗╂枡鏄庣粏 - var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); - rkd.F_QTY = rkd.F_QTY - item.SL; - db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); - } - var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); - int ssss = po1.Details.Count(); - if (po1.Details.Count() == 0) - { - po1.N_B_STATE = 7; - db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); - } - } - db.CommitTran(); - } - else if ( items.HEAD.YDLX == "124") - { - - //鍐查攢鍑瘉鍗曞彿 - var cxpzbh = items.HEAD.WLPZH; - var po = WMSHelper.GetInboundOrder(cxpzbh); - //鍒ゆ柇鏄惁鎵ц 鎵ц涓鍗曞厑璁稿啿閿�- if (po == null) - { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.WLPZND = items.HEAD.WLPZND; - result.resultCode = 1; - result.resultMsg = "鏈壘鍒版璁㈠崟"; - simpleResults.Add(result); - continue; - } - if (po.N_B_STATE != 0 && po.N_B_STATE != 7) - { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.resultCode = 1; - result.WLPZND = items.HEAD.WLPZND; - result.resultMsg = "鎵ц涓鍗曚笉鍏佽鎿嶄綔"; - simpleResults.Add(result); - continue; - } - foreach (var item in items.ITEM) - { - var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); - if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//鏁伴噺澶т簬鏄庣粏 - { - result.resultMsg = "澶辫触"; - result.WLPZBH = items.HEAD.WLPZH; - result.WLPZND = items.HEAD.WLPZND; - result.resultMsg = $"閫�揣鐗╂枡{item.WLBM}鏁伴噺{item.SL}澶т簬瀛樺叆鏁伴噺"; - simpleResults.Add(result); - continue; - } - else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//鏁伴噺==鏄庣粏 鍒犻櫎褰撲笅鍏ュ簱鍗曠墿鏂欐暟鎹�- { - db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); - } - else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//鏁伴噺灏忎簬鏄庣粏 - { - //褰撳墠鐗╂枡鏄庣粏 - var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); - rkd.F_QTY = rkd.F_QTY - item.SL; - db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); - } - var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); - int ssss = po1.Details.Count(); - if (po1.Details.Count() == 0) - { - po1.N_B_STATE = 7; - db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); - } - } - db.CommitTran(); - } - else - { - //鍒涘缓鍏ュ簱鍗曚富瀛愯〃 - var po = WMSHelper.GetInboundOrder(items.HEAD.WLPZH); - if (po == null) - { - po = new TN_Inbound_Order { S_NO = items.HEAD.WLPZH, S_WLPZND = items.HEAD.WLPZND, S_FACTORY = items.HEAD.GC, S_IN_TYPE = "澶栭噰鍏ュ簱", S_BS_TYPE = items.HEAD.YDLX }; - po.Details = new List<TN_Inbound_Detail>(); - if (items.ITEM.Count > 0) - { - items.ITEM.ForEach(a => + ///鍒ゆ柇鏄惁閮芥湁鍐查攢鍑瘉缂栧彿 + if (string.IsNullOrEmpty(item.CXPZH)) { - po.Details.Add(new TN_Inbound_Detail - { - S_IO_NO = items.HEAD.WLPZH, - N_ROW_NO = a.WLPZHXM, - S_ITEM_CODE = a.WLBM, - F_QTY = a.SL, - S_ITEM_STATE = "鐗╂枡", - S_ITEM_NAME = "鐗╂枡", - F_ACC_B_QTY = 0, - S_KCDD = a.KCDD, - S_UOM = a.DW,//璁¢噺鍗曚綅 - //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), - S_BATCH_NO = a.PC == null ? "" : a.PC, - S_CGPZH = a.CGPZH, - S_CGPZXMBH = a.CGPZXMBH, - S_CKPZKJND = a.CKPZKJND, - S_CKPZXM = a.CKPZHXM, - S_CXWLPZBH = a.CKPZH, - S_HWSJJYZT = a.HWSJJYZT, - S_GYSZHH = a.GYSZHH, - S_JYPBH = a.JYPBH, - S_KJPZSSRQ = a.KJPZSSRQ, - S_KJPZSRSJ = a.KJPZSRSJ, - }); - //} - - }); - db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); - db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); - db.CommitTran(); - + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.resultCode = 1; + result.WLPZND = items.HEAD.WLPZND; + result.resultMsg = "鍐查攢鍗曟湁鐗╂枡鍐查攢缂栧彿涓虹┖"; + simpleResults.Add(result); + continue; + } + var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); + if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//鏁伴噺澶т簬鏄庣粏 + { + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.WLPZND = items.HEAD.WLPZND; + result.resultMsg = $"鍐查攢鐗╂枡{item.WLBM}鏁伴噺{item.SL}澶т簬瀛樺叆鏁伴噺"; + simpleResults.Add(result); + continue; + } + else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//鏁伴噺==鏄庣粏 鍒犻櫎褰撲笅鍏ュ簱鍗曠墿鏂欐暟鎹�+ { + db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); + } + else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//鏁伴噺灏忎簬鏄庣粏 + { + //褰撳墠鐗╂枡鏄庣粏 + var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); + rkd.F_QTY = rkd.F_QTY - item.SL; + db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); + } + var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); + int ssss = po1.Details.Count(); + if (po1.Details.Count() == 0) + { + po1.N_B_STATE = 7; + db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); + } } } + else { - var Details = new List<TN_Inbound_Detail>(); - if (items.ITEM.Count > 0) + //鍒涘缓鍏ュ簱鍗曚富瀛愯〃 + var po = WMSHelper.GetInboundOrder(items.HEAD.WLPZH); + if (po == null) { - items.ITEM.ForEach(a => + po = new TN_Inbound_Order { S_NO = items.HEAD.WLPZH, S_WLPZND = items.HEAD.WLPZND, S_FACTORY = items.HEAD.GC, S_IN_TYPE = "澶栭噰鍏ュ簱", S_BS_TYPE = items.HEAD.YDLX }; + po.Details = new List<TN_Inbound_Detail>(); + if (items.ITEM.Count > 0) { - if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0) + items.ITEM.ForEach(a => { - var poq = po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).FirstOrDefault(); - poq.F_QTY = a.SL; - - db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); - } - else - { - Details.Add(new TN_Inbound_Detail + po.Details.Add(new TN_Inbound_Detail { S_IO_NO = items.HEAD.WLPZH, N_ROW_NO = a.WLPZHXM, @@ -596,7 +516,6 @@ F_ACC_B_QTY = 0, S_KCDD = a.KCDD, S_UOM = a.DW,//璁¢噺鍗曚綅 - //S_UOM = a.JBJLDW,//璁¢噺鍗曚綅 //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), S_BATCH_NO = a.PC == null ? "" : a.PC, S_CGPZH = a.CGPZH, @@ -610,32 +529,144 @@ S_KJPZSSRQ = a.KJPZSSRQ, S_KJPZSRSJ = a.KJPZSRSJ, }); - } + //} - }); - db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); - db.CommitTran(); + }); + db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); + db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); + + } } - //result.resultMsg = "鎴愬姛"; - //result.WLPZBH = items.HEAD.WLPZH; - //result.WLPZND = items.HEAD.WLPZND; - //result.resultCode = 0; - //result.resultMsg = ""; - //simpleResults.Add(result); - //continue; + else + { + var Details = new List<TN_Inbound_Detail>(); + if (items.ITEM.Count > 0) + { + items.ITEM.ForEach(a => + { + if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0) + { + var poq = po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).FirstOrDefault(); + poq.F_QTY = a.SL; + + db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); + } + else + { + Details.Add(new TN_Inbound_Detail + { + S_IO_NO = items.HEAD.WLPZH, + N_ROW_NO = a.WLPZHXM, + S_ITEM_CODE = a.WLBM, + F_QTY = a.SL, + S_ITEM_STATE = "鐗╂枡", + S_ITEM_NAME = "鐗╂枡", + F_ACC_B_QTY = 0, + S_KCDD = a.KCDD, + S_UOM = a.DW,//璁¢噺鍗曚綅 + //S_UOM = a.JBJLDW,//璁¢噺鍗曚綅 + //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), + S_BATCH_NO = a.PC == null ? "" : a.PC, + S_CGPZH = a.CGPZH, + S_CGPZXMBH = a.CGPZXMBH, + S_CKPZKJND = a.CKPZKJND, + S_CKPZXM = a.CKPZHXM, + S_CXWLPZBH = a.CKPZH, + S_HWSJJYZT = a.HWSJJYZT, + S_GYSZHH = a.GYSZHH, + S_JYPBH = a.JYPBH, + S_KJPZSSRQ = a.KJPZSSRQ, + S_KJPZSRSJ = a.KJPZSRSJ, + }); + } + + }); + db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); + + + } + //result.resultMsg = "鎴愬姛"; + //result.WLPZBH = items.HEAD.WLPZH; + //result.WLPZND = items.HEAD.WLPZND; + //result.resultCode = 0; + //result.resultMsg = ""; + //simpleResults.Add(result); + //continue; + } + } + }else + { + //鍐查攢鍑瘉鍗曞彿 + foreach (var item1 in items.ITEM) + { + var cxpzbh = item1.CKPZH; + var po = WMSHelper.GetInboundOrder(cxpzbh); + //鍒ゆ柇鏄惁鎵ц 鎵ц涓鍗曞厑璁稿啿閿�+ if (po == null) + { + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.WLPZND = items.HEAD.WLPZND; + result.resultCode = 1; + result.resultMsg = "鏈壘鍒版璁㈠崟"; + simpleResults.Add(result); + continue; + } + if (po.N_B_STATE != 0 && po.N_B_STATE != 7) + { + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.resultCode = 1; + result.WLPZND = items.HEAD.WLPZND; + result.resultMsg = "鎵ц涓鍗曚笉鍏佽鎿嶄綔"; + simpleResults.Add(result); + continue; + } + + foreach (var item in items.ITEM) + { + //s.S_ITEM_CODE == item.WLBM&& + var rkdmx = po.Details.Where(s => s.S_CKPZXM == item.CKPZHXM).ToList(); + if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//鏁伴噺澶т簬鏄庣粏 + { + result.resultMsg = "澶辫触"; + result.WLPZBH = items.HEAD.WLPZH; + result.WLPZND = items.HEAD.WLPZND; + result.resultMsg = $"閫�揣鐗╂枡{item.WLBM}鏁伴噺{item.SL}澶т簬瀛樺叆鏁伴噺"; + simpleResults.Add(result); + continue; + } + else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//鏁伴噺==鏄庣粏 鍒犻櫎褰撲笅鍏ュ簱鍗曠墿鏂欐暟鎹�+ { + db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); + } + else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//鏁伴噺灏忎簬鏄庣粏 + { + //褰撳墠鐗╂枡鏄庣粏 + var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); + rkd.F_QTY = rkd.F_QTY - item.SL; + db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); + } + var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); + int ssss = po1.Details.Count(); + if (po1.Details.Count() == 0) + { + po1.N_B_STATE = 7; + db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); + } + } + } } - - //} - result.resultMsg = "鎴愬姛"; result.WLPZBH = items.HEAD.WLPZH; result.WLPZND = items.HEAD.WLPZND; result.resultCode = 0; result.resultMsg = ""; + db.CommitTran(); simpleResults.Add(result); } @@ -660,61 +691,70 @@ /// </summary> /// <param name="model"></param> /// <returns></returns> - internal static Orderback.Root GYS_In(GYSDto.Root model) + internal static GYSReturnRoot.Root GYS_In(GYSDto.Root model) { - var orderResponse = new Orderback.Root + var orderResponse = new GYSReturnRoot.Root { - ROOT = new Orderback.ROOT + ROOT = new GYSReturnRoot.ROOT { - ITEM = new List<Orderback.ITEM> { } + ITEM = new List<GYSReturnRoot.ITEM> { } } }; - List<Orderback.ITEM> tEMs = new List<Orderback.ITEM>(); + List<GYSReturnRoot.ITEM> tEMs = new List<GYSReturnRoot.ITEM>(); var db = new SqlHelper<object>().GetInstance(); try { db.BeginTran(); foreach (var item in model.ROOT.GYSXX) { - Orderback.ITEM iTEM = new Orderback.ITEM(); + GYSReturnRoot.ITEM iTEM = new GYSReturnRoot.ITEM(); - + //鍒涘缓鍏ュ簱鍗曚富瀛愯〃 - var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM); - if (po == null) - { - po = new TN_Supplier { S_GYSBM= item.JBXX.GYSBM , S_MDMBM = item.JBXX.MDMBM, }; - po.Details = new List<TN_Supplier_detial>(); - if (item.GYSHB.Count > 0) - { - item.GYSHB.ForEach(a => - { - po.Details.Add(new TN_Supplier_detial - { - S_DO_GYSBM = a.GYSBM, - S_CGZZ = a.CGZZ, - S_HB = a.HB, - - }); - //} - }); - db.Insertable<TN_Supplier>(po).ExecuteCommand(); - db.Insertable<TN_Supplier_detial>(po.Details).ExecuteCommand(); - } - } - else + // var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM); + var po= db.Queryable<TN_Supplier>().Includes(a => a.Details).Where(a => a.S_GYSBM == item.JBXX.GYSBM).First(); + if (po != null) { db.Deleteable<TN_Supplier>().Where(it => it.S_GYSBM == po.S_GYSBM).ExecuteCommand(); db.Deleteable<TN_Supplier_detial>().Where(it => it.S_DO_GYSBM == po.S_GYSBM).ExecuteCommand(); - //iTEM.SCDDH = item.JBXX.GYSBM; - //iTEM.MSGCODE = "1"; - //iTEM.MSGDESP = $"{item.JBXX.GYSBM}宸插瓨鍦�; - //tEMs.Add(iTEM); + } - iTEM.SCDDH = item.JBXX.GYSBM; - iTEM.MSGCODE = "0"; + po = new TN_Supplier { S_GYSBM = item.JBXX.GYSBM, S_MDMBM = item.JBXX.MDMBM, S_GYSMC=item.JBXX.GYSMC, S_YHGJ=item.JBXX.YHGJ, S_YHDM = item.JBXX.YHDM , + S_KHH = item.JBXX.KHH, + S_YHJD = item.JBXX.YHJD, + S_YHCS = item.JBXX.YHCS, + S_KHHZH = item.JBXX.KHHZH, + S_DZ = item.JBXX.DZ, + S_YZBM = item.JBXX.YZBM, + S_CS = item.JBXX.CS, + S_GJDM = item.JBXX.GJDM, + S_GJ = item.JBXX.GJ, + S_DQDM = item.JBXX.DQDM, + S_DQMC = item.JBXX.DQMC, + S_SH = item.JBXX.SH, + S_ZZSDJH = item.JBXX.ZZSDJH, + }; + po.Details = new List<TN_Supplier_detial>(); + if (item.GYSHB.Count > 0) + { + item.GYSHB.ForEach(a => + { + po.Details.Add(new TN_Supplier_detial + { + S_DO_GYSBM = a.GYSBM, + S_CGZZ = a.CGZZ, + S_HB = a.HB, + + }); + //} + }); + db.Insertable<TN_Supplier>(po).ExecuteCommand(); + db.Insertable<TN_Supplier_detial>(po.Details).ExecuteCommand(); + } + iTEM.GYSBM = item.JBXX.GYSBM; + iTEM.MSGCODE = 0; iTEM.MSGDESP = $"鎴愬姛"; tEMs.Add(iTEM); } @@ -723,10 +763,9 @@ } catch (Exception e) { - Orderback.ITEM iTEM = new Orderback.ITEM(); - iTEM.SCDDH = ""; - iTEM.GC = ""; - iTEM.MSGCODE = "1"; + GYSReturnRoot.ITEM iTEM = new GYSReturnRoot.ITEM(); + iTEM.GYSBM = ""; + iTEM.MSGCODE = 1; iTEM.MSGDESP = e.Message; tEMs.Add(iTEM); orderResponse.ROOT.ITEM = tEMs; @@ -768,6 +807,7 @@ { TN_GENERATE_ORDER tnorder = new TN_GENERATE_ORDER(); tnorder.S_GC = item.GC; + tnorder.S_SCDDH = item.SCDDH; tnorder.S_SCDDH = item.SCDDH; tnorder.S_DZMC = item.DZMC; tnorder.S_SCDDCMS = item.SCDDCMS; @@ -831,7 +871,7 @@ { ITEM = new List<WLReturnRoot.ITEM> { - + } } }; @@ -1121,9 +1161,9 @@ result.resultCode = 1; result.resultMsg = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�; - result.resultMsg = "澶辫触"; result.WLPZBH = itemwlpz.HEAD.WLPZH; result.WLPZND = itemwlpz.HEAD.ND; + simpleResults.Add(result); continue; /* throw new Exception($"鐗╂枡{a.WLH}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�)*/ ; @@ -1173,9 +1213,10 @@ po.Details = new List<TN_Inbound_Detail>(); if (itemwlpz.ITEM.Count > 0) { - itemwlpz.ITEM.ForEach(a => + foreach (var a in itemwlpz.ITEM) + { - + po.Details.Add(new TN_Inbound_Detail { S_IO_NO = itemwlpz.HEAD.WLPZH, @@ -1197,7 +1238,7 @@ }); //} - }); + } db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); db.CommitTran(); @@ -1211,7 +1252,7 @@ var Details = new List<TN_Inbound_Detail>(); if (itemwlpz.ITEM.Count > 0) { - itemwlpz.ITEM.ForEach(a => + foreach (var a in itemwlpz.ITEM) { if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0) { @@ -1241,19 +1282,20 @@ }); } - }); + } db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); db.CommitTran(); } } } - result.resultMsg = "鎴愬姛"; - result.WLPZBH = itemwlpz.HEAD.WLPZH; - result.WLPZND = itemwlpz.HEAD.ND; - result.resultCode = 0; - result.resultMsg = ""; - simpleResults.Add(result); + + var result2 = new SimpleResult(); + result2.resultMsg = "鎴愬姛"; + result2.WLPZBH = itemwlpz.HEAD.WLPZH; + result2.WLPZND = itemwlpz.HEAD.ND; + result2.resultCode = 0; + simpleResults.Add(result2); db.CommitTran(); } } @@ -1315,12 +1357,14 @@ var po = WMSHelper.GetInboundOrder(itemwlpz.HEAD.WLPZBH); if (po == null) { - po = new TN_Inbound_Order { S_NO = itemwlpz.HEAD.WLPZBH, S_WLPZND=itemwlpz.HEAD.WLPZNF, S_WLPZNF = itemwlpz.HEAD.WLPZNF, S_FACTORY = itemwlpz.ITEM[0].GC, S_IN_TYPE = "鍏朵粬鍏ュ簱", S_BS_TYPE = itemwlpz.ITEM[0].YDLX }; + po = new TN_Inbound_Order { S_NO = itemwlpz.HEAD.WLPZBH, S_WLPZND = itemwlpz.HEAD.WLPZNF, S_WLPZNF = itemwlpz.HEAD.WLPZNF, S_FACTORY = itemwlpz.ITEM[0].GC, S_IN_TYPE = "鍏朵粬鍏ュ簱", S_BS_TYPE = itemwlpz.ITEM[0].YDLX }; po.Details = new List<TN_Inbound_Detail>(); if (itemwlpz.ITEM.Count > 0) { - itemwlpz.ITEM.ForEach(a => + foreach (var a in itemwlpz.ITEM) + { + #region 涓嶉渶瑕� //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//鍒ゆ柇搴忓垪鍙锋槸鍚︿负澶氫釜 //{ @@ -1367,12 +1411,12 @@ S_CXWLPZHXM = a.CXPZHXM, S_CXPZNF = a.CXPZNF, - S_SERIAL_NO = a.ITEM1==null?"": string.Join(",", a.ITEM1.XLH), + S_SERIAL_NO = a.ITEM1 == null ? "" : string.Join(",", a.ITEM1.XLH), }); //} - }); + } db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); db.CommitTran(); @@ -1384,7 +1428,8 @@ var Details = new List<TN_Inbound_Detail>(); if (itemwlpz.ITEM.Count > 0) { - itemwlpz.ITEM.ForEach(a => + foreach (var a in itemwlpz.ITEM) + { if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBH).Count() > 0) { @@ -1419,7 +1464,7 @@ }); } - }); + } db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); db.CommitTran(); @@ -1648,7 +1693,7 @@ result12.resultMsg = $"鐗╂枡{a.WLBH}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�; simples.Add(result12); continue; - // throw new Exception($"鐗╂枡{a.WLBH}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�); + // throw new Exception($"鐗╂枡{a.WLBH}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�); } TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail { @@ -1719,11 +1764,21 @@ internal static SimpleResult InboundOrderSorting(MPSorting model) { var result = new SimpleResult(); + foreach (var a in model.MaterList) + { + bool v = MaterPanduan(a.item_code, a.qty); + if (v) + { + result.resultMsg = $"鐗╂枡{a.item_code}鏁伴噺瓒呰繃 搴撳瓨鎬绘暟"; + return result; + } + } //鍒ゆ柇璧峰搴撲綅鏄惁閿佸畾 // var db = new SqlHelper<object>().GetInstance(); using (var db = new SqlHelper<object>().GetInstance()) { var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First(); + if (locinfo?.N_LOCK_STATE != 0) { result.resultCode = 3; @@ -1742,7 +1797,7 @@ result.resultMsg = "鎴愬姛"; result.resultCode = 0; //鏍¢獙鍏ュ簱鍗曟暟閲忥紝涓嶅彲浠ヨ秴锛屾垚鍔熷悗鎻掑叆鎵樼洏鐗╂枡琛紝鏇存柊鍏ュ簱鍗曠疮璁℃暟閲�- result = AddInboundOrder(model.MaterList, model.cntr_code); + result = AddInboundOrder(model.MaterList, model.cntr_code,model.cntr_type); #region MyRegion @@ -1811,16 +1866,16 @@ } } - /// <summary> /// 鍒嗘嫞 /// </summary> /// <param name="model"></param> /// <returns></returns> - internal static async Task<SimpleResult> OutboundOrderSorting(FJSorting model) + internal static async Task<SimpleResult> KtSorting(KtSorting model) { + var result = new SimpleResult(); - + // var db = new SqlHelper<object>().GetInstance(); using (var db = new SqlHelper<object>().GetInstance()) @@ -1828,137 +1883,200 @@ try { - - result.resultMsg = "鎴愬姛"; - result.resultCode = 0; - if (string.IsNullOrEmpty(model.arrival_no)) - { - result.resultMsg = "鍑哄簱鍗曞彿涓嶈兘涓虹┖"; - result.resultCode = 1; - return result; - } - - //浜哄伐鍒嗘嫞 瀹瑰櫒璐у搧琛ㄦ暟閲忋�鍒嗛厤閲忓崌闄�- //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == model.arrival_no).First(); - if (po == null) - { - result.resultMsg = "鏈壘鍒版鍑哄簱鍗�; - result.resultCode = 1; - return result; - } - - //鏍规嵁涓嶅悓鍑哄簱绫诲瀷 鍥炶皟sap - if (po.S_OUT_TYPE == "鍐查攢鍑哄簱") - { - result = await CXAddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.start); - } - else - if (po.S_OUT_TYPE == "鍑哄簱")//鏅�鍑哄簱 - { + result.resultMsg = "鎴愬姛"; + result.resultCode = 0; + var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First(); - result = await AddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.start); - } - else if (po.S_OUT_TYPE == "璁″垝澶栧彂鏂欏嚭搴�) - { - result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); - } - else if (po.S_OUT_TYPE == "鎴愭湰涓績鍑哄簱") - { - result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); - } - - //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛 - result = await TYAddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE); - #region 鍗囬檷閲�- - bool adds = true; - - //var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == model.cntr_code).ToList(); - if (model.MaterList.Count > 0) - { - var url = Settings.MoboxSeverUrl + "inventory/AddChange"; - //浠撳簱閲忚〃鍗囬噺 - var req = new AddChangeModel { op_type = 4 }; - //搴撳尯閲忚〃鍗囬噺 - var req2 = new AddChangeModel { op_type = 7 }; - model.MaterList.ForEach(a => + if (locinfo?.N_LOCK_STATE != 0) { - LogHelper.Info($"濉厖鏁版嵁"); - LogHelper.Info($"鍑忎粨搴撻噺琛ㄦ暟鎹�浠撳簱{po.S_WH_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}"); - req.item_info.Add(new AddChangeModel.itemModel - { - wh_code = po.S_WH_CODE, - item_code = a.item_code, - item_name = "", - qty = a.qty - }); - LogHelper.Info($"鍑忓簱鍖洪噺琛ㄦ暟鎹�搴撳尯{po.S_AREA_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}"); - req2.item_info.Add(new AddChangeModel.itemModel - { - wh_code = po.S_WH_CODE, - area_code = po.S_AREA_CODE, - item_code = a.item_code, - item_name = "", - qty = a.qty - }); - }); - var reqData = JsonConvert.SerializeObject(req); - var AppKey = Settings.AppKey; - var AppSecret = Settings.AppSecret; - var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); - //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); - LogHelper.Info($"鍔犲瘑鍓�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}"); - var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime); - LogHelper.Info($"鍔犲瘑鍚�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}"); - var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify); - if (!string.IsNullOrEmpty(res)) + result.resultCode = 3; + result.resultMsg = $"璧峰搴撲綅宸查攣/涓嶅瓨鍦�; + return result; + } + //鍒ゆ柇鎵樼洏鏄惁宸茬粡鐢熸垚浠诲姟锛屽鏋滄病鏈夊垯鐢熸垚 + if (!string.IsNullOrEmpty(model.cntr_code)) { - LogHelper.Info($"mobox 浠撳簱闄嶉噺鎺ュ彛杩斿洖 {res}"); - var moboxres = JsonConvert.DeserializeObject<moboxres>(res); - if (moboxres.err_code != 0) + var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code); + if (wmsTaskcs != null) { - adds = false; + result.resultCode = 3; + result.resultMsg = $"璧风偣{model.start} 鎵樼洏{model.cntr_code}宸茬粡鍒涘缓浠诲姟锛岃鍕块噸澶嶇敵璇�; + return result; } } - else + + //鍑哄簱 + if (model.Type==2) { - LogHelper.Info($"mobox 浠撳簱闄嶉噺鎺ュ彛杩斿洖涓虹┖"); - - } - var reqData2 = JsonConvert.SerializeObject(req2); - var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); - //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); - LogHelper.Info($"鍔犲瘑鍓�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}"); - var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2); - LogHelper.Info($"鍔犲瘑鍚�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}"); - var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2); - if (!string.IsNullOrEmpty(res2)) - { - LogHelper.Info($"mobox 搴撳尯闄嶉噺鎺ュ彛杩斿洖 {res2}"); - var moboxres = JsonConvert.DeserializeObject<moboxres>(res); - if (moboxres.err_code != 0) + Location start = new Location(); + if (!string.IsNullOrEmpty(model.cntr_code)) { - adds = false; + var loc= db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntr_code).First(); + + + if (loc==null) + { + LogHelper.Info($"瀹瑰櫒{model.cntr_code}鎵句笉鍒板搴旇揣浣�); + result.resultMsg = $"瀹瑰櫒{model.cntr_code}鎵句笉鍒板搴旇揣浣�; + result.resultCode = 1; + return result; + } + else + { + start= db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First(); + } } + else if (!string.IsNullOrEmpty(model.item_code)) + { + start = db.Queryable<LocCntrRel>() + .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE&&cir.S_CNTR_TYPE=="鍗婃墭") + .Where((lcr, cir) => cir.S_CNTR_CODE != null) + .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ") + .OrderBy((lcr, cir) => cir.T_CREATE) + .Select((lcr, cir, loc) => loc).ToList() // 杩斿洖 Location 瀵硅薄 + .FirstOrDefault(); // 鎴栬� Take(1).ToList()[0] + } + else + { + #region MyRegion + //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray(); + //var S_LOC_CODElist = db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray(); + //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First(); + + //// 鑾峰彇鎵�湁琚崰鐢ㄧ殑瀹瑰櫒缂栫爜 + //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList(); + + //// 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜 + //var availableLocationCodes = db.Queryable<LocCntrRel>() + // .Where(s => !usedContainerCodes.Contains(s.S_CNTR_CODE)) + // .Select(s => s.S_LOC_CODE) + // .ToList(); + + //// 鑾峰彇绗竴涓彲鐢ㄨ揣浣嶏紙濡傛灉娌℃湁鍒欒繑鍥瀗ull锛�+ //var startLocation = db.Queryable<Location>() + // .Where(it => availableLocationCodes.Contains(it.S_CODE)) + // .ToList().FirstOrDefault(); + + + #endregion + start = db.Queryable<LocCntrRel>() + .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE) + .Where((lcr, cir) => cir.S_CNTR_CODE == null) // 鎵惧嚭鏈鍗犵敤鐨勫鍣�+ .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ") + .Select((lcr, cir, loc) => loc).ToList() // 杩斿洖 Location 瀵硅薄 + .FirstOrDefault(); // 鎴栬� Take(1).ToList()[0] + } + if (start==null) + { + LogHelper.Info($"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�); + result.resultMsg = $"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�; + result.resultCode = 1; + return result; + } + //搴撲綅淇℃伅 + + var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First(); + var wmsTask = new WMSTask + { + S_CNTR_CODE = model.cntr_code, + S_CODE = WMSHelper.GenerateTaskNo(), + S_START_LOC = start.S_CODE, + S_START_AREA = start.S_AREA_CODE, + S_START_WH = start.S_WH_CODE, + S_END_LOC = endinfo.S_CODE, + S_END_AREA = endinfo.S_AREA_CODE, + S_END_WH = endinfo.S_WH_CODE, + + N_TYPE = 2, + // S_TYPE = WMSTask.GetTypeStr(1), + S_TYPE = "鍑哄簱绌烘墭鐩�, + S_OP_DEF_CODE = "", + S_OP_DEF_NAME = "pda鍑哄簱" + }; + if (WMSHelper.CreateWmsTask(wmsTask)) + { + LocationHelper.LockLoc(start.S_CODE, 2); + result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}"; + } + + } - else + else //鍏ュ簱 { - LogHelper.Info($"mobox 搴撳尯闄嶉噺鎺ュ彛杩斿洖涓虹┖"); + Location end = new Location(); + if (!string.IsNullOrEmpty(model.cntr_code)) + { + + #region MyRegion + //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray(); + //var S_LOC_CODElist = db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray(); + //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First(); + + //// 鑾峰彇鎵�湁琚崰鐢ㄧ殑瀹瑰櫒缂栫爜 + //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList(); + + // 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜 + var availableLocationCodes = db.Queryable<LocCntrRel>() + .Select(s => s.S_LOC_CODE) + .ToList(); + + // 鑾峰彇绗竴涓彲鐢ㄨ揣浣嶏紙濡傛灉娌℃湁鍒欒繑鍥瀗ull锛�+ end = db.Queryable<Location>() + .Where(it => !availableLocationCodes.Contains(it.S_CODE)&&it.S_AREA_CODE== "HJQ") + .ToList().FirstOrDefault(); + + + #endregion + } + else + { + LogHelper.Info($"鍏ュ簱 瀹瑰櫒{model.cntr_code}涓嶈兘涓虹┖"); + result.resultMsg = $"鍏ュ簱 瀹瑰櫒{model.cntr_code}涓嶈兘涓虹┖"; + result.resultCode = 1; + return result; + + } + if (end==null) + { + LogHelper.Info($"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�); + result.resultMsg = $"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�; + result.resultCode = 1; + return result; + } + var sart = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First(); + var wmsTask = new WMSTask + { + S_CNTR_CODE = model.cntr_code, + S_CODE = WMSHelper.GenerateTaskNo(), + S_START_LOC = sart.S_CODE, + S_START_AREA = sart.S_AREA_CODE, + S_START_WH = sart.S_WH_CODE, + S_END_LOC = end.S_CODE, + S_END_AREA = end.S_AREA_CODE, + S_END_WH = end.S_WH_CODE, + + N_TYPE = 1, + // S_TYPE = WMSTask.GetTypeStr(1), + S_TYPE = "鍏ュ簱绌烘墭鐩�, + S_OP_DEF_CODE = "", + S_OP_DEF_NAME = "pda鍏ュ簱" + }; + if (WMSHelper.CreateWmsTask(wmsTask)) + { + LocationHelper.LockLoc(end.S_CODE, 1); + result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}"; + } } - if (adds) addOnShelves(po, model.cntr_code, 2); + //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛 - } - else LogHelper.Info($"鎵樼洏{model.cntr_code}鏃犻渶瑕佸崌闄嶉噺鐨勭墿鏂�); - db.CommitTran(); - #endregion return result; - + } catch (Exception e) - {result.resultMsg=e.Message; + { + result.resultMsg = e.Message; db.RollbackTran(); return result; throw; @@ -1966,117 +2084,323 @@ } } - public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE) + /// <summary> + /// 鍒嗘嫞 + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + internal static async Task<SimpleResult> OutboundOrderSorting(FJSorting model) + { + + var result = new SimpleResult(); + + // var db = new SqlHelper<object>().GetInstance(); + + using (var db = new SqlHelper<object>().GetInstance()) + { + try + { + + + result.resultMsg = "鎴愬姛"; + result.resultCode = 0; + if (string.IsNullOrEmpty(model.arrival_no)) + { + result.resultMsg = "鍑哄簱鍗曞彿涓嶈兘涓虹┖"; + result.resultCode = 1; + return result; + } + + //浜哄伐鍒嗘嫞 瀹瑰櫒璐у搧琛ㄦ暟閲忋�鍒嗛厤閲忓崌闄�+ //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == model.arrival_no).First(); + if (po == null) + { + result.resultMsg = "鏈壘鍒版鍑哄簱鍗�; + result.resultCode = 1; + return result; + + } + LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}"); + //鏍规嵁涓嶅悓鍑哄簱绫诲瀷 鍥炶皟sap + if (po.S_OUT_TYPE == "鍐查攢鍑哄簱") + { + result = await CXAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); + } + else + if (po.S_OUT_TYPE == "鍑哄簱")//鏅�鍑哄簱 + { + LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}"); + result = await AddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); + } + else if (po.S_OUT_TYPE == "璁″垝澶栧彂鏂欏嚭搴�) + { + result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); + } + else if (po.S_OUT_TYPE == "鎴愭湰涓績鍑哄簱") + { + result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); + } + + //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛 + result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE,model.cntr_type); + if (result.resultCode==1) + { + return result; + } + #region 鍗囬檷閲�+ + bool adds = true; + + //var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == model.cntr_code).ToList(); + if (model.MaterList.Count > 0) + { + var url = Settings.MoboxSeverUrl + "inventory/AddChange"; + //浠撳簱閲忚〃鍗囬噺 + var req = new AddChangeModel { op_type = 4 }; + //搴撳尯閲忚〃鍗囬噺 + var req2 = new AddChangeModel { op_type = 7 }; + var S_WH_CODE = ""; + var S_AREA_CODE = ""; + if (string.IsNullOrEmpty(po.S_WH_CODE)) + { + S_WH_CODE = util.Settings.WHCode; + } + else + { + S_WH_CODE = po.S_WH_CODE; + } + if (string.IsNullOrEmpty(po.S_AREA_CODE)) + { + S_AREA_CODE = util.Settings.AREACode; + } + else + { + S_AREA_CODE = po.S_AREA_CODE; + } + model.MaterList.ForEach(a => + { + LogHelper.Info($"濉厖鏁版嵁{util.Settings.WHCode}"); + LogHelper.Info($"鍑忎粨搴撻噺{util.Settings.AREACode}琛ㄦ暟鎹�浠撳簱{po.S_WH_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}"); + req.item_info.Add(new AddChangeModel.itemModel + { + wh_code = S_WH_CODE, + item_code = a.item_code, + item_name = "", + qty = a.qty + }); + LogHelper.Info($"鍑忓簱鍖洪噺琛ㄦ暟鎹�搴撳尯{po.S_AREA_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}"); + req2.item_info.Add(new AddChangeModel.itemModel + { + wh_code = S_WH_CODE, + area_code = S_AREA_CODE, + item_code = a.item_code, + item_name = "", + qty = a.qty + }); + }); + var reqData = JsonConvert.SerializeObject(req); + var AppKey = Settings.AppKey; + var AppSecret = Settings.AppSecret; + var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); + //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); + LogHelper.Info($"鍔犲瘑鍓�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}"); + var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime); + LogHelper.Info($"鍔犲瘑鍚�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}"); + var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify); + if (!string.IsNullOrEmpty(res)) + { + LogHelper.Info($"mobox 浠撳簱闄嶉噺鎺ュ彛杩斿洖 {res}"); + var moboxres = JsonConvert.DeserializeObject<moboxres>(res); + if (moboxres.err_code != 0) + { + adds = false; + } + } + else + { + LogHelper.Info($"mobox 浠撳簱闄嶉噺鎺ュ彛杩斿洖涓虹┖"); + + } + var reqData2 = JsonConvert.SerializeObject(req2); + var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); + //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); + LogHelper.Info($"鍔犲瘑鍓�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}"); + var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2); + LogHelper.Info($"鍔犲瘑鍚�AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}"); + var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2); + if (!string.IsNullOrEmpty(res2)) + { + LogHelper.Info($"mobox 搴撳尯闄嶉噺鎺ュ彛杩斿洖 {res2}"); + var moboxres = JsonConvert.DeserializeObject<moboxres>(res); + if (moboxres.err_code != 0) + + { + adds = false; + } + } + else + { + LogHelper.Info($"mobox 搴撳尯闄嶉噺鎺ュ彛杩斿洖涓虹┖"); + + } + //if (adds) addOnShelves(po, model.cntr_code, 2); + + } + else LogHelper.Info($"鎵樼洏{model.cntr_code}鏃犻渶瑕佸崌闄嶉噺鐨勭墿鏂�); + db.CommitTran(); + #endregion + return result; + + } + catch (Exception e) + { + LogHelper.Info($"鎶ラ敊{e.Message}"); + result.resultMsg = e.Message; + db.RollbackTran(); + return result; + throw; + } + } + + } + public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE,string cntr_type) { // var db = new SqlHelper<object>().GetInstance(); //using (var db = new SqlHelper<object>().GetInstance()) //{ - var result = new SimpleResult(); + var result = new SimpleResult(); - try + try + { + //搴撲綅淇℃伅 + var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); + //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + //鍒嗘嫞鍗�+ //var popp = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_BS_NO == arrival_no&&a.S_SORT_TYPE=="鏈垎绫� && a.N_B_STATE == 2).First(); + + //鍥炲弬鐗╂枡淇℃伅 + List<OutboundRecord> records = new List<OutboundRecord>(); + var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); + foreach (var item in MaterList) { - //搴撲綅淇℃伅 - var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); - //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); - //鍒嗘嫞鍗�- //var popp = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_BS_NO == arrival_no&&a.S_SORT_TYPE=="鏈垎绫� && a.N_B_STATE == 2).First(); - - //鍥炲弬鐗╂枡淇℃伅 - List<OutboundRecord> records = new List<OutboundRecord>(); - var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); - foreach (var item in MaterList) + // 鎻掑叆鍒版墭鐩樻槑缁嗚〃 + var cntr = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code).ToList(); + if (cntr.Count() > 0) { - // 鎻掑叆鍒版墭鐩樻槑缁嗚〃 - var cntr = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code).ToList(); - if (cntr.Count() > 0) + db.BeginTran(); + //1.鏌ョ湅鏄惁鏈夌浉鍚岀墿鏂欐壒娆$殑淇℃伅锛屽鏋滄湁瑕佺疮鍑忓皯锛屼笉鍚屾壒娆$殑鍙互鍒嗗紑&& a.N_BS_ROW_NO == item.N_ROW_NO + var cir = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code && a.S_ITEM_CODE == item.item_code).First();//&& a.S_BATCH_NO == item.S_BATCH_NO + if (cir != null) { - db.BeginTran(); - //1.鏌ョ湅鏄惁鏈夌浉鍚岀墿鏂欐壒娆$殑淇℃伅锛屽鏋滄湁瑕佺疮鍑忓皯锛屼笉鍚屾壒娆$殑鍙互鍒嗗紑&& a.N_BS_ROW_NO == item.N_ROW_NO - var cir = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code && a.S_ITEM_CODE == item.item_code ).First();//&& a.S_BATCH_NO == item.S_BATCH_NO - if (cir != null) + cir.F_QTY -= item.qty; + cir.S_CNTR_TYPE = cntr_type; + cir.F_ALLOC_QTY -= item.qty; + cir.T_MODIFY = DateTime.Now; + if (cir.F_QTY == 0) { - cir.F_QTY -= item.qty; - cir.F_ALLOC_QTY -= item.qty; - cir.T_MODIFY = DateTime.Now; - if (cir.F_QTY == 0) - { - db.Deleteable(cir).ExecuteCommand(); - } - else - { - db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand(); - //娣诲姞鍥炲簱浣滀笟 - - - } + db.Deleteable(cir).ExecuteCommand(); } else { - db.RollbackTran(); - result.resultCode = 1; - result.resultMsg = $"鐗╂枡涓嶅瓨鍦▄item.item_code}"; - LogHelper.Info($"鐗╂枡涓嶅瓨鍦▄item.item_code}"); - return result; + db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand(); + //娣诲姞鍥炲簱浣滀笟 } - if (isHK) - { - var wmsTask = new WMSTask - { - S_CNTR_CODE = cntr_code, - S_CODE = WMSHelper.GenerateTaskNo(), - S_START_LOC = start, - S_START_AREA = startinfo.S_AREA_CODE, - S_START_WH = startinfo.S_WH_CODE, - S_END_LOC = startinfo.S_CODE, - S_END_AREA = startinfo.S_AREA_CODE, - S_END_WH = startinfo.S_WH_CODE, + } + else + { + db.RollbackTran(); + result.resultCode = 1; + result.resultMsg = $"鐗╂枡涓嶅瓨鍦▄item.item_code}"; + LogHelper.Info($"鐗╂枡涓嶅瓨鍦▄item.item_code}"); + return result; + } + + OutboundRecord outboundRecord = new OutboundRecord(); + outboundRecord.S_WLPZBH = pz?.S_WLPZBH; + outboundRecord.S_WLPZND = pz?.S_WLPZND; + outboundRecord.S_TYPE = S_OUT_TYPE; - N_TYPE = 1, - // S_TYPE = WMSTask.GetTypeStr(1), - S_TYPE = "鍥炲簱", - S_OP_DEF_CODE = "", - S_OP_DEF_NAME = "pda鍏ュ簱" - }; - if (WMSHelper.CreateWmsTask(wmsTask)) - { - LocationHelper.LockLoc(start, 1); - result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}"; - } - } - OutboundRecord outboundRecord = new OutboundRecord(); - outboundRecord.S_WLPZBH = pz?.S_WLPZBH; - outboundRecord.S_WLPZND = pz?.S_WLPZND; - outboundRecord.S_TYPE = S_OUT_TYPE; - - outboundRecord.S_NO = arrival_no; - outboundRecord.S_WLBM = item.item_code; - outboundRecord.S_SL = item.qty; - outboundRecord.S_CNTR_CODE = cntr_code; - records.Add(outboundRecord); + outboundRecord.S_NO = arrival_no; + outboundRecord.S_WLBM = item.item_code; + outboundRecord.S_SL = item.qty; + outboundRecord.S_CNTR_CODE = cntr_code; + records.Add(outboundRecord); + } + else + { + result.resultCode = 1; + result.resultMsg = $"鑾峰彇鎵樼洏淇℃伅澶辫触{cntr_code}"; + LogHelper.Info($"鑾峰彇鎵樼洏淇℃伅澶辫触{cntr_code}"); + return result; + } + } + if (isHK) + { + var locs= db.Queryable<WCSTask>().Where(a =>a.S_TYPE.Contains("鍑哄簱")&& a.S_CNTR_CODE == cntr_code&&a.N_B_STATE==3).OrderByDescending(s=>s.T_END_TIME).First(); + if (locs!=null) + { + var cntr= db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_DC_NO== locs.S_BS_NO).First(); + if (cntr!=null) + { + cntr.S_SORT_TYPE = "宸插垎鎷�; + db.Updateable(cntr).UpdateColumns(it => new { it.S_SORT_TYPE }).ExecuteCommand(); } else { result.resultCode = 1; - result.resultMsg = $"鑾峰彇鎵樼洏淇℃伅澶辫触{cntr_code}"; - LogHelper.Info($"鑾峰彇鎵樼洏淇℃伅澶辫触{cntr_code}"); + result.resultMsg += $"浠诲姟{locs.S_CODE}鏉ユ簮鍙穥locs.S_BS_NO}鎵句笉鍒伴厤鐩樹俊鎭�; return result; } + //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First(); + var wmsTask = new WMSTask + { + S_CNTR_CODE = cntr_code, + S_CODE = WMSHelper.GenerateTaskNo(), + S_START_LOC = start, + S_START_AREA = startinfo.S_AREA_CODE, + S_START_WH = startinfo.S_WH_CODE, + S_END_LOC = locs?.S_START_LOC, + S_END_AREA = locs?.S_START_AREA, + S_END_WH = locs?.S_START_WH, + + N_TYPE = 1, + // S_TYPE = WMSTask.GetTypeStr(1), + S_TYPE = "鍥炲簱", + S_OP_DEF_CODE = "", + S_OP_DEF_NAME = "pda鍏ュ簱" + }; + if (WMSHelper.CreateWmsTask(wmsTask)) + { + LocationHelper.LockLoc(start, 1); + result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}"; + } } - db.Insertable<OutboundRecord>(records).ExecuteCommand(); - - //db.CommitTran(); + else + { + result.resultCode = 1; + result.resultMsg += $"鎵句笉鍒板鍣ㄥ搴斾换鍔′俊鎭瘂cntr_code}"; + return result; + } + } - catch (Exception ex) - { - //db.RollbackTran(); - LogHelper.Info("鐗╂枡淇℃伅缁戝畾鍒版弧瀹瑰櫒涓� + ex.Message); - Console.WriteLine(ex.Message); - - throw; - } - return result; + var sss= db.Insertable<OutboundRecord>(records).ExecuteCommand(); + + //db.CommitTran(); } + catch (Exception ex) + { + //db.RollbackTran(); + LogHelper.Info("鐗╂枡淇℃伅缁戝畾鍒版弧瀹瑰櫒涓� + ex.Message); + result.resultCode = 1; + result.resultMsg += ex.Message; + Console.WriteLine(ex.Message); + + throw; + } + return result; + } //} @@ -2094,169 +2418,171 @@ { //using (var db = new SqlHelper<object>().GetInstance()) //{ - // var db = new SqlHelper<object>().GetInstance(); - var result = new SimpleResult(); + // var db = new SqlHelper<object>().GetInstance(); + var result = new SimpleResult(); - try + try + { + //搴撲綅淇℃伅 + var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); + //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); + //鍑哄簱鍥炶皟鍏ュ弬 + var cbCenterBackDto = new CBcenterBackDto.Root { - //搴撲綅淇℃伅 - var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); - //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); - //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); - //鍑哄簱鍥炶皟鍏ュ弬 - var cbCenterBackDto = new CBcenterBackDto.Root + ROOT = new CBcenterBackDto.ROOT { - ROOT = new CBcenterBackDto.ROOT + HEAD = new List<CBcenterBackDto.HEADItem> { - HEAD = new List<CBcenterBackDto.HEADItem> - { - } } - }; - //鍥炲弬鐗╂枡淇℃伅 - List<CBcenterBackDto.HEADItem> iTEMs = new List<CBcenterBackDto.HEADItem>(); - List<OutboundRecord> records = new List<OutboundRecord>(); - string GZRQ = ""; - string PZZDRQ = ""; - if (po.BUDAT != null) - { - GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); } - if (po.BLDAT != null) - { - PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); + }; + //鍥炲弬鐗╂枡淇℃伅 + List<CBcenterBackDto.HEADItem> iTEMs = new List<CBcenterBackDto.HEADItem>(); + List<OutboundRecord> records = new List<OutboundRecord>(); + string GZRQ = ""; + string PZZDRQ = ""; + if (po.BUDAT != null) + { + GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); + } + if (po.BLDAT != null) + { + PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); - } + } + foreach (var item in MaterList) + { + var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); + CBcenterBackDto.HEADItem ckbitem = new CBcenterBackDto.HEADItem(); + ckbitem.KEY = arrival_no; + + ckbitem.CBZX = po.S_CBZX; + ckbitem.WLBH = item.item_code; + ckbitem.SL = item.qty; + ckbitem.KCDD = podetail?.S_KCDD; + ckbitem.LRZX = po.S_LRZX; + ckbitem.ZZKM = po.S_ZZKM; + ckbitem.GC = po.S_FACTORY; + ckbitem.GZRY = po.UNAME; + + ckbitem.PC = podetail?.S_BATCH_NO; + ckbitem.PZRQ = PZZDRQ; + ckbitem.GZRQ = GZRQ; + + + + CBcenterBackDto.ITEM listitem1 = new CBcenterBackDto.ITEM(); + // List<CBcenterBackDto.ITEM> listitem1 = new List<CBcenterBackDto.ITEM>(); + //string[] xlhValues = item.S_SERIAL_NO.Split(','); + //var serialNos = string.Join(",", CntrItemRels + // .Where(s => s.S_ITEM_CODE == item.item_code) + // .Select(s => s.S_SERIAL_NO)); + //string[] xlhValues = serialNos.Split(','); + // string[] xlhValues = item.S_SERIAL_NO.Split(','); + listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); + //foreach (var xlhValue in xlhValues) + //{ + // CBcenterBackDto.ITEM newItem = new CBcenterBackDto.ITEM { XLH = xlhValue }; + // listitem1.Add(newItem); + //} + ckbitem.ITEM = listitem1; + iTEMs.Add(ckbitem); + + + } + cbCenterBackDto.ROOT.HEAD = iTEMs; + //db.Insertable<OutboundRecord>(records).ExecuteCommand(); + #region wms-sap鍥炶皟 + //绫昏浆json + var json = JsonConvert.SerializeObject(cbCenterBackDto.ROOT); + //json杞瑇ml + string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; + + LogHelper.Info($"鎴愭湰涓績鍑哄簱xml鏁版嵁{xml}"); + //// 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" + //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); + //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; + //string responseXml = ""; + //using (HttpClient client = new HttpClient()) + //{ + // // 鍙戦� POST 璇锋眰骞舵帴鏀跺搷搴�+ // HttpResponseMessage responsess = await client.PostAsync(url, content); + // responseXml = await responsess.Content.ReadAsStringAsync(); + + //} + + #region sap鍥炶皟 + // 鍒涘缓Web Service浠g悊绫诲疄渚�+ ZSCM2_CBZX service = new ZSCM2_CBZX(); + service.PreAuthenticate = true; + service.Url = service.Url + "?sap-language=ZH"; + // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); + // 鍑嗗璇锋眰鍙傛暟 + ZfmScm2CbzxMm001 request = new ZfmScm2CbzxMm001(); + request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; + LogHelper.Info($"鎴愭湰涓績鍑哄簱SAP鍥炶皟"); + // 璋冪敤Web Service + ZfmScm2CbzxMm001Response responses = service.ZfmScm2CbzxMm001(request); + + // 澶勭悊鍝嶅簲 + LogHelper.Info("SAP杩斿洖缁撴灉: " + responses.Output); + + // 瑙f瀽Output涓殑鍑瘉鍙风瓑淇℃伅 + + #endregion + XmlDocument xmlDoc = new XmlDocument(); + xmlDoc.LoadXml(responses.Output.ToString()); + JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); + var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString()); + + //娣诲姞鍑瘉璁板綍琛�+ result.resultMsg = data.ROOT.ITEM.MSGDESP; + result.resultCode = data.ROOT.ITEM.MSGCODE; + if (data.ROOT.ITEM.MSGCODE == 0) + { + foreach (var item in MaterList) { - var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); - CBcenterBackDto.HEADItem ckbitem = new CBcenterBackDto.HEADItem(); - ckbitem.KEY = arrival_no; - - ckbitem.CBZX = po.S_CBZX; - ckbitem.WLBH = item.item_code; - ckbitem.SL = item.qty; - ckbitem.KCDD = podetail?.S_KCDD; - ckbitem.LRZX = po.S_LRZX; - ckbitem.ZZKM = po.S_ZZKM; - ckbitem.GC = po.S_FACTORY; - ckbitem.GZRY = po.UNAME; - - ckbitem.PC = podetail?.S_BATCH_NO; - ckbitem.PZRQ = PZZDRQ; - ckbitem.GZRQ = GZRQ; - - - - CBcenterBackDto.ITEM listitem1 = new CBcenterBackDto.ITEM(); - // List<CBcenterBackDto.ITEM> listitem1 = new List<CBcenterBackDto.ITEM>(); - //string[] xlhValues = item.S_SERIAL_NO.Split(','); - //var serialNos = string.Join(",", CntrItemRels - // .Where(s => s.S_ITEM_CODE == item.item_code) - // .Select(s => s.S_SERIAL_NO)); - //string[] xlhValues = serialNos.Split(','); - // string[] xlhValues = item.S_SERIAL_NO.Split(','); - listitem1.XLH= podetail?.S_SERIAL_NO.Split(',').ToList(); - //foreach (var xlhValue in xlhValues) - //{ - // CBcenterBackDto.ITEM newItem = new CBcenterBackDto.ITEM { XLH = xlhValue }; - // listitem1.Add(newItem); - //} - ckbitem.ITEM = listitem1; - iTEMs.Add(ckbitem); - - - } - cbCenterBackDto.ROOT.HEAD = iTEMs; - //db.Insertable<OutboundRecord>(records).ExecuteCommand(); - #region wms-sap鍥炶皟 - //绫昏浆json - var json = JsonConvert.SerializeObject(cbCenterBackDto.ROOT); - //json杞瑇ml - string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; - - LogHelper.Info($"鎴愭湰涓績鍑哄簱xml鏁版嵁{xml}"); - //// 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" - //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); - //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; - //string responseXml = ""; - //using (HttpClient client = new HttpClient()) - //{ - // // 鍙戦� POST 璇锋眰骞舵帴鏀跺搷搴�- // HttpResponseMessage responsess = await client.PostAsync(url, content); - // responseXml = await responsess.Content.ReadAsStringAsync(); - - //} - - #region sap鍥炶皟 - // 鍒涘缓Web Service浠g悊绫诲疄渚�- ZSCM2_CBZX service = new ZSCM2_CBZX(); - service.PreAuthenticate = true; - service.Url = service.Url + "?sap-language=ZH"; - // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); - // 鍑嗗璇锋眰鍙傛暟 - ZfmScm2CbzxMm001 request = new ZfmScm2CbzxMm001(); - request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; - LogHelper.Info($"鎴愭湰涓績鍑哄簱SAP鍥炶皟"); - // 璋冪敤Web Service - ZfmScm2CbzxMm001Response responses = service.ZfmScm2CbzxMm001(request); - - // 澶勭悊鍝嶅簲 - LogHelper.Info("SAP杩斿洖缁撴灉: " + responses.Output); - - // 瑙f瀽Output涓殑鍑瘉鍙风瓑淇℃伅 - - #endregion - XmlDocument xmlDoc = new XmlDocument(); - xmlDoc.LoadXml(responses.Output.ToString()); - JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); - var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString()); - - //娣诲姞鍑瘉璁板綍琛�- result.resultMsg = data.ROOT.ITEM.MSGDESP; - result.resultCode = data.ROOT.ITEM.MSGCODE; - if (data.ROOT.ITEM.MSGCODE == 0) - { - - foreach (var item in MaterList) - { - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = po.S_NO; - materialVoucher.S_TYPE = po.S_OUT_TYPE; - materialVoucher.S_WLBM = item.item_code; - materialVoucher.S_WLH = item.N_ROW_NO; - materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; - materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_TYPE = po.S_OUT_TYPE; + materialVoucher.S_WLBM = item.item_code; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH; + materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; materialVoucher.S_WH_CODE = po.S_WH_CODE; materialVoucher.S_AREA_CODE = po.S_AREA_CODE; materialVoucher.F_QTY = item.qty; materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); - } - //MaterialVoucher materialVoucher = new MaterialVoucher(); - //materialVoucher.S_NO = po.S_NO; - //materialVoucher.S_TYPE = po.S_OUT_TYPE; - //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; - //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; - //materialVoucher.STATUS = 0; - //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + materialVoucher.S_GZRQ = po.BUDAT; + materialVoucher.UNAME = po.UNAME; + db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); } - #endregion - - //db.CommitTran(); + //MaterialVoucher materialVoucher = new MaterialVoucher(); + //materialVoucher.S_NO = po.S_NO; + //materialVoucher.S_TYPE = po.S_OUT_TYPE; + //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; + //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; + //materialVoucher.STATUS = 0; + //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); } - catch (Exception ex) - { - //db.RollbackTran(); - LogHelper.Info("鎴愭湰涓績鍥炶皟鎶ラ敊" + ex.Message); - Console.WriteLine(ex.Message); + #endregion - throw; - } - return result; + //db.CommitTran(); } + catch (Exception ex) + { + //db.RollbackTran(); + LogHelper.Info("鎴愭湰涓績鍥炶皟鎶ラ敊" + ex.Message); + Console.WriteLine(ex.Message); + + throw; + } + return result; + } //} /// <summary> @@ -2271,182 +2597,184 @@ { //using (var db = new SqlHelper<object>().GetInstance()) //{ - // var db = new SqlHelper<object>().GetInstance(); - var result = new SimpleResult(); - try + // var db = new SqlHelper<object>().GetInstance(); + var result = new SimpleResult(); + try + { + //搴撲綅淇℃伅 + var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); + //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + + var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); + //鍑哄簱鍥炶皟鍏ュ弬 + + DateTime dateTime; + DateTime dateTime1; + string GZRQ = ""; + string PZZDRQ = ""; + if (po.BUDAT != null) { - //搴撲綅淇℃伅 - var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); - //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); + } + if (po.BLDAT != null) + { + PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); - var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); - //鍑哄簱鍥炶皟鍏ュ弬 - - DateTime dateTime; - DateTime dateTime1; - string GZRQ = ""; - string PZZDRQ = ""; - if (po.BUDAT != null) + } + JHWBackDto.Root myRoot = new JHWBackDto.Root + { + ROOT = new JHWBackDto.ROOT { - GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); - } - if (po.BLDAT != null) - { - PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); - - } - JHWBackDto.Root myRoot = new JHWBackDto.Root - { - ROOT = new JHWBackDto.ROOT + HEAD = new JHWBackDto.HEAD { - HEAD = new JHWBackDto.HEAD - { - - KEY = po.S_NO, - GZRQ = GZRQ, - PZZDRQ = PZZDRQ, - YHM = po.UNAME, - PZTTWB = po.BKTXT, - YDLX = po.S_BS_TYPE, - TSKCBS = po.SOBKZ, - ITEM = new List<JHWBackDto.ITEM> - { - } - }, - - } - }; - //鍥炲弬鐗╂枡淇℃伅 - List<JHWBackDto.ITEM> iTEMs = new List<JHWBackDto.ITEM>(); + KEY = po.S_NO, + GZRQ = GZRQ, + PZZDRQ = PZZDRQ, + YHM = po.UNAME, + PZTTWB = po.BKTXT, + YDLX = po.S_BS_TYPE, + TSKCBS = po.SOBKZ, + ITEM = new List<JHWBackDto.ITEM> + { + + } + }, + + } + }; + //鍥炲弬鐗╂枡淇℃伅 + List<JHWBackDto.ITEM> iTEMs = new List<JHWBackDto.ITEM>(); + foreach (var item in MaterList) + { + var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); + JHWBackDto.ITEM ckbitem = new JHWBackDto.ITEM(); + ckbitem.WLBH = item.item_code; + ckbitem.GC = po.S_FACTORY; + //ckbitem.PH = podetail?.S_PH; + //ckbitem.TSKCBS = podetail?.S_TSKCBS; + ckbitem.XSDD = podetail?.S_XSDD; + ckbitem.XSDDHXM = podetail?.S_XSDDXMBH; + ckbitem.SL = item.qty; + ckbitem.DW = podetail?.S_UOM; + ckbitem.DDH = podetail?.S_DDH; + //ckbitem.DDHXM = (podetail?.N_ROW_NO); + ckbitem.WBS = podetail?.S_WBS; + ckbitem.KCDD = podetail?.S_KCDD; + ckbitem.PC = podetail?.S_BATCH_NO; + JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); + //string[] xlhValues = item.S_SERIAL_NO.Split(','); + //var serialNos = string.Join(",", CntrItemRels + // .Where(s => s.S_ITEM_CODE == item.item_code) + // .Select(s => s.S_SERIAL_NO)); + //string[] xlhValues = serialNos.Split(','); + string[] xlhValues = podetail?.S_SERIAL_NO.Split(','); + //foreach (var xlhValue in xlhValues) + //{ + // JHWBackDto.ITEM1 newItem = new JHWBackDto.ITEM1 { XLH = xlhValue }; + // listitem1.Add(newItem); + //} + listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); + ckbitem.ITEM1 = listitem1; + iTEMs.Add(ckbitem); + + //娣诲姞鍑哄簱褰曞嚟璇佽〃 + //var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); + //OutboundRecord outboundRecord = new OutboundRecord(); + //outboundRecord.S_WLPZBH = pz.S_WLPZBH; + //outboundRecord.S_WLPZND = pz.S_WLPZND; + //outboundRecord.S_TYPE = "璁″垝澶栭�鏂�; + + //outboundRecord.S_NO = arrival_no; + //outboundRecord.S_WLBM = item.item_code; + //outboundRecord.S_SL = item.qty; + //outboundRecord.S_CNTR_CODE = cntr_code; + //records.Add(outboundRecord); + + } + myRoot.ROOT.HEAD.ITEM = iTEMs; + //db.Insertable<OutboundRecord>(records).ExecuteCommand(); + #region wms-sap鍥炶皟 + //绫昏浆json + + var json = JsonConvert.SerializeObject(myRoot.ROOT); + //json杞瑇ml + string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; + + LogHelper.Info($"璁″垝澶栧彂鏂欏嚭搴搙ml鏁版嵁{xml}"); + // 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" + //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); + //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; + //string responseXml = ""; + //using (HttpClient client = new HttpClient()) + //{ + // // 鍙戦� POST 璇锋眰骞舵帴鏀跺搷搴�+ // HttpResponseMessage responsess = await client.PostAsync(url, content); + // responseXml = await responsess.Content.ReadAsStringAsync(); + + //} + #region sap鍥炶皟 + // 鍒涘缓Web Service浠g悊绫诲疄渚�+ ZSCM2_SCFLJHW service = new ZSCM2_SCFLJHW(); + service.PreAuthenticate = true; + service.Url = service.Url + "?sap-language=ZH"; + // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); + // 鍑嗗璇锋眰鍙傛暟 + ZscmScflJhw request = new ZscmScflJhw(); + request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; + LogHelper.Info($"璁″垝澶朣AP鍥炶皟"); + // 璋冪敤Web Service + ZscmScflJhwResponse responses = service.ZscmScflJhw(request); + + // 澶勭悊鍝嶅簲 + LogHelper.Info("SAP杩斿洖缁撴灉: " + responses.Output); + + // 瑙f瀽Output涓殑鍑瘉鍙风瓑淇℃伅 + + #endregion + + XmlDocument xmlDoc = new XmlDocument(); + xmlDoc.LoadXml(responses.Output.ToString()); + JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); + var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); + //娣诲姞鍑瘉璁板綍琛�+ result.resultMsg = data.ROOT.ITEM.MSGDESP; + result.resultCode = data.ROOT.ITEM.MSGCODE; + if (data.ROOT.ITEM.MSGCODE == 0) + { foreach (var item in MaterList) { - var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); - JHWBackDto.ITEM ckbitem = new JHWBackDto.ITEM(); - ckbitem.WLBH = item.item_code; - ckbitem.GC = po.S_FACTORY; - //ckbitem.PH = podetail?.S_PH; - //ckbitem.TSKCBS = podetail?.S_TSKCBS; - ckbitem.XSDD = podetail?.S_XSDD; - ckbitem.XSDDHXM = podetail?.S_XSDDXMBH; - ckbitem.SL = item.qty; - ckbitem.DW = podetail?.S_UOM; - ckbitem.DDH = podetail?.S_DDH; - //ckbitem.DDHXM = (podetail?.N_ROW_NO); - ckbitem.WBS = podetail?.S_WBS; - ckbitem.KCDD = podetail?.S_KCDD; - ckbitem.PC = podetail?.S_BATCH_NO; - JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); - //string[] xlhValues = item.S_SERIAL_NO.Split(','); - //var serialNos = string.Join(",", CntrItemRels - // .Where(s => s.S_ITEM_CODE == item.item_code) - // .Select(s => s.S_SERIAL_NO)); - //string[] xlhValues = serialNos.Split(','); - string[] xlhValues = podetail?.S_SERIAL_NO.Split(','); - //foreach (var xlhValue in xlhValues) - //{ - // JHWBackDto.ITEM1 newItem = new JHWBackDto.ITEM1 { XLH = xlhValue }; - // listitem1.Add(newItem); - //} - listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); - ckbitem.ITEM1 = listitem1; - iTEMs.Add(ckbitem); - - //娣诲姞鍑哄簱褰曞嚟璇佽〃 - //var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); - //OutboundRecord outboundRecord = new OutboundRecord(); - //outboundRecord.S_WLPZBH = pz.S_WLPZBH; - //outboundRecord.S_WLPZND = pz.S_WLPZND; - //outboundRecord.S_TYPE = "璁″垝澶栭�鏂�; - - //outboundRecord.S_NO = arrival_no; - //outboundRecord.S_WLBM = item.item_code; - //outboundRecord.S_SL = item.qty; - //outboundRecord.S_CNTR_CODE = cntr_code; - //records.Add(outboundRecord); - - } - myRoot.ROOT.HEAD.ITEM = iTEMs; - //db.Insertable<OutboundRecord>(records).ExecuteCommand(); - #region wms-sap鍥炶皟 - //绫昏浆json - - var json = JsonConvert.SerializeObject(myRoot.ROOT); - //json杞瑇ml - string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; - - LogHelper.Info($"璁″垝澶栧彂鏂欏嚭搴搙ml鏁版嵁{xml}"); - // 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" - //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); - //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; - //string responseXml = ""; - //using (HttpClient client = new HttpClient()) - //{ - // // 鍙戦� POST 璇锋眰骞舵帴鏀跺搷搴�- // HttpResponseMessage responsess = await client.PostAsync(url, content); - // responseXml = await responsess.Content.ReadAsStringAsync(); - - //} - #region sap鍥炶皟 - // 鍒涘缓Web Service浠g悊绫诲疄渚�- ZSCM2_SCFLJHW service = new ZSCM2_SCFLJHW(); - service.PreAuthenticate = true; - service.Url = service.Url + "?sap-language=ZH"; - // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); - // 鍑嗗璇锋眰鍙傛暟 - ZscmScflJhw request = new ZscmScflJhw(); - request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; - LogHelper.Info($"璁″垝澶朣AP鍥炶皟"); - // 璋冪敤Web Service - ZscmScflJhwResponse responses = service.ZscmScflJhw(request); - - // 澶勭悊鍝嶅簲 - LogHelper.Info("SAP杩斿洖缁撴灉: " + responses.Output); - - // 瑙f瀽Output涓殑鍑瘉鍙风瓑淇℃伅 - - #endregion - - XmlDocument xmlDoc = new XmlDocument(); - xmlDoc.LoadXml(responses.Output.ToString()); - JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); - var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); - //娣诲姞鍑瘉璁板綍琛�- result.resultMsg = data.ROOT.ITEM.MSGDESP; - result.resultCode = data.ROOT.ITEM.MSGCODE; - if (data.ROOT.ITEM.MSGCODE == 0) - { - foreach (var item in MaterList) - { - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = po.S_NO; - materialVoucher.S_TYPE = po.S_OUT_TYPE; - materialVoucher.S_WLBM = item.item_code; - materialVoucher.S_WLH = item.N_ROW_NO; - materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; - materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_TYPE = po.S_OUT_TYPE; + materialVoucher.S_WLBM = item.item_code; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; + materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; materialVoucher.S_WH_CODE = po.S_WH_CODE; materialVoucher.S_AREA_CODE = po.S_AREA_CODE; + materialVoucher.S_GZRQ = po.BUDAT; + materialVoucher.UNAME = po.UNAME; materialVoucher.F_QTY = item.qty; materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); - } + db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); } - #endregion - - //db.CommitTran(); } - catch (Exception ex) - { - //db.RollbackTran(); - LogHelper.Info("璁″垝澶栭�鏂欏洖璋冩姤閿� + ex.Message); - Console.WriteLine(ex.Message); + #endregion - throw; - } - return result; + //db.CommitTran(); } + catch (Exception ex) + { + //db.RollbackTran(); + LogHelper.Info("璁″垝澶栭�鏂欏洖璋冩姤閿� + ex.Message); + Console.WriteLine(ex.Message); + + throw; + } + return result; + } //} /// <summary> @@ -2460,53 +2788,53 @@ public static async Task<SimpleResult> CXAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, string start) { // var db = new SqlHelper<object>().GetInstance(); - - var result = new SimpleResult(); + + var result = new SimpleResult(); - try + try + { + //搴撲綅淇℃伅 + var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); + //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + + string GZRQ = ""; + if (po.BUDAT != null) { - //搴撲綅淇℃伅 - var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); - //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); + } - string GZRQ = ""; - if (po.BUDAT != null) + //鏉ユ簮鍐查攢鍑瘉瀵瑰簲鐨勭墿鏂欏嚟璇佷俊鎭�+ //var poIn = db.Queryable<TN_Inbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == po.S_BS_NO).First(); + //鏍规嵁鍏ュ簱鏌ョ湅鍑瘉缂栧彿淇℃伅 + //var poIPz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == poIn.S_NO).First(); + //鍑哄簱鍥炶皟鍏ュ弬 + CXCkBackDto.Root myRoot = new CXCkBackDto.Root + { + ROOT = new CXCkBackDto.ROOT { - GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); - } - - //鏉ユ簮鍐查攢鍑瘉瀵瑰簲鐨勭墿鏂欏嚟璇佷俊鎭�- //var poIn = db.Queryable<TN_Inbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == po.S_BS_NO).First(); - //鏍规嵁鍏ュ簱鏌ョ湅鍑瘉缂栧彿淇℃伅 - //var poIPz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == poIn.S_NO).First(); - //鍑哄簱鍥炶皟鍏ュ弬 - CXCkBackDto.Root myRoot = new CXCkBackDto.Root - { - ROOT = new CXCkBackDto.ROOT + HEAD = new List<CXCkBackDto.HEAD> { - HEAD = new List<CXCkBackDto.HEAD> - { - //GZRQ = GZRQ, - //SRRQ = PZZDRQ, - //WLPZ = po.S_WLPZ, - //WLPZNF = po.S_WLPZNF, - //WLPZXM = MaterList[0].N_ROW_NO, + //GZRQ = GZRQ, + //SRRQ = PZZDRQ, + //WLPZ = po.S_WLPZ, + //WLPZNF = po.S_WLPZNF, + //WLPZXM = MaterList[0].N_ROW_NO, - //GZRY = po.UNAME - } + //GZRY = po.UNAME } - }; - List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); - //鍑哄簱鍗曡鎯�- var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO).ToList(); - foreach (var item in MaterList) - { - CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD(); - hEAD.GZRQ = GZRQ; - hEAD.SRSJ = DateTime.Now.ToString("yyyyMMdd"); + } + }; + List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); + //鍑哄簱鍗曡鎯�+ var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); + foreach (var item in MaterList) + { + CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD(); + hEAD.GZRQ = GZRQ; + hEAD.SRSJ = DateTime.Now.ToString("yyyyMMdd"); //hEAD.WLPZ = porecord.Where(s => s.S_WLBM == item.item_code && s.S_WLH == item.N_ROW_NO).First()?.S_WLPZBH; //hEAD.WLPZNF = porecord.Where(s=>s.S_WLBM==item.item_code&&s.S_WLH==item.N_ROW_NO).First()?.S_WLPZND; @@ -2514,109 +2842,116 @@ //hEAD.WLPZ = porecord.First()?.S_WLPZBH; //hEAD.WLPZNF = porecord.First()?.S_WLPZND; - hEAD.WLPZ = po.S_WLPZ; - hEAD.WLPZNF = po.S_WLPZND; + hEAD.WLPZ = porecord.FirstOrDefault()?.S_WLPZBH; + hEAD.WLPZNF = porecord.FirstOrDefault()?.S_WLPZND; hEAD.WLPZXM = item.N_ROW_NO; - hEAD.GZRY = po.UNAME; - listhead.Add(hEAD); - } - myRoot.ROOT.HEAD = listhead; - - #region wms-sap鍥炶皟 - - - - //绫昏浆json - var json = JsonConvert.SerializeObject(myRoot.ROOT); - //json杞瑇ml - string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; - - LogHelper.Info($"鍐查攢鍑哄簱鍥炶皟xml鏁版嵁{xml}"); - - ZSCM2_CXPZ service = new ZSCM2_CXPZ(); - service.PreAuthenticate = true; - service.Url = service.Url + "?sap-language=ZH"; - // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); - // 鍑嗗璇锋眰鍙傛暟 - ZfmScm2CxpzMm001 request = new ZfmScm2CxpzMm001(); - request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; - LogHelper.Info($"閫氱敤鍐查攢SAP鍥炶皟"); - // 璋冪敤Web Service - ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); - - // 澶勭悊鍝嶅簲 - LogHelper.Info("閫氱敤鍐查攢SAP杩斿洖缁撴灉: " + responses.Output); - - XmlDocument xmlDoc = new XmlDocument(); - xmlDoc.LoadXml(responses.Output.ToString()); - JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); - var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); - var resmeg = ""; - int rescode = 0; - //娣诲姞鍑瘉璁板綍琛�- if (data!=null) - { - List<MaterialVoucher> materiallist = new List<MaterialVoucher>(); - foreach (var item in data.ROOT.ITEM) - { - if (item.MSGCODE == 0) - { - - var onr = MaterList.Where(s => s.N_ROW_NO == item.WLPZHXM).First(); - - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = po.S_NO; - materialVoucher.S_TYPE = po.S_OUT_TYPE; - materialVoucher.S_WLPZBH = item?.WLPZBH; - materialVoucher.S_WLPZND = item?.WLPZND; - materialVoucher.S_WLPZHXM = item?.WLPZHXM; - - materialVoucher.S_YWLPZBH = item?.YWLPZBH; - materialVoucher.S_YWLPZND = item?.YWLPZND; - materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; - materialVoucher.S_WH_CODE = po.S_WH_CODE; - materialVoucher.S_AREA_CODE = po.S_AREA_CODE; - materialVoucher.F_QTY = onr.qty; - //materialVoucher.STATUS = 0; - resmeg += item?.MSGDESP; - materiallist.Add(materialVoucher); - - - } - else { - rescode = 1; - } - - - } - if (materiallist.Count()>0) - { - - db.Insertable<MaterialVoucher>(materiallist).ExecuteCommand(); - } - } - - - - - result.resultMsg = resmeg; - result.resultCode = rescode; - #endregion - - //db.CommitTran(); + hEAD.GZRY = po.UNAME; + listhead.Add(hEAD); } - catch (Exception ex) + myRoot.ROOT.HEAD = listhead; + + #region wms-sap鍥炶皟 + + + + //绫昏浆json + var json = JsonConvert.SerializeObject(myRoot.ROOT); + //json杞瑇ml + string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; + + LogHelper.Info($"鍐查攢鍑哄簱鍥炶皟xml鏁版嵁{xml}"); + + ZSCM2_CXPZ service = new ZSCM2_CXPZ(); + service.PreAuthenticate = true; + service.Url = service.Url + "?sap-language=ZH"; + // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); + // 鍑嗗璇锋眰鍙傛暟 + ZfmScm2CxpzMm001 request = new ZfmScm2CxpzMm001(); + request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; + LogHelper.Info($"閫氱敤鍐查攢SAP鍥炶皟"); + // 璋冪敤Web Service + ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); + + // 澶勭悊鍝嶅簲 + LogHelper.Info("閫氱敤鍐查攢SAP杩斿洖缁撴灉: " + responses.Output); + + XmlDocument xmlDoc = new XmlDocument(); + xmlDoc.LoadXml(responses.Output.ToString()); + JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); + EnsureArrayFormat(jsonObject, "ITEM", ""); + var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); + var resmeg = ""; + int rescode = 0; + //娣诲姞鍑瘉璁板綍琛�+ if (data != null) { - //db.RollbackTran(); - LogHelper.Info("閫氱敤鍐查攢鍥炶皟鎶ラ敊" + ex.Message); - Console.WriteLine(ex.Message); + List<MaterialVoucher> materiallist = new List<MaterialVoucher>(); + foreach (var item in data.ROOT.ITEM) + { + if (item.MSGCODE == 0) + { - throw; + var onr = MaterList.Where(s => s.N_ROW_NO == item.WLPZHXM).FirstOrDefault(); + + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_TYPE = po.S_OUT_TYPE; + materialVoucher.S_WLPZBH = item?.WLPZBH; + materialVoucher.S_WLPZND = item?.WLPZND; + materialVoucher.S_WLPZHXM = item?.WLPZHXM; + + materialVoucher.S_YWLPZBH = item?.YWLPZBH; + materialVoucher.S_YWLPZND = item?.YWLPZND; + materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; + materialVoucher.S_WH_CODE = po.S_WH_CODE; + materialVoucher.S_AREA_CODE = po.S_AREA_CODE; + materialVoucher.S_GZRQ = po.BUDAT; + materialVoucher.UNAME = po.UNAME; + materialVoucher.S_AREA_CODE = po.S_AREA_CODE; + + materialVoucher.F_QTY = onr == null ? 0 : onr.qty; + //materialVoucher.STATUS = 0; + resmeg += item?.MSGDESP; + materiallist.Add(materialVoucher); + + + } + else + { + rescode = 1; + resmeg += item?.MSGDESP; + } + + + } + if (materiallist.Count() > 0) + { + + db.Insertable<MaterialVoucher>(materiallist).ExecuteCommand(); + } } - return result; - } - + + + + result.resultMsg = resmeg; + result.resultCode = rescode; + #endregion + + //db.CommitTran(); + } + catch (Exception ex) + { + //db.RollbackTran(); + LogHelper.Info("閫氱敤鍐查攢鍥炶皟鎶ラ敊" + ex.Message); + Console.WriteLine(ex.Message); + + throw; + } + return result; + } + + /// <summary> /// 鏅�鍥炶皟鎺ュ彛 @@ -2630,26 +2965,26 @@ { //using (var db = new SqlHelper<object>().GetInstance()) //{ - // var db = new SqlHelper<object>().GetInstance(); - var result = new SimpleResult(); - - try - { - //搴撲綅淇℃伅 - var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); - //鍑哄簱鍗曡鎯�- var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); + // var db = new SqlHelper<object>().GetInstance(); + var result = new SimpleResult(); + + try + { + //搴撲綅淇℃伅 + var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); + //鍑哄簱鍗曡鎯�+ var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); string GZRQ = ""; string PZZDRQ = ""; - if (po.BUDAT != null) - { - GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); - } - if (po.BLDAT != null) - { - PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); + //if (po.Details[0].S_CJRQ != null) + //{ + // GZRQ = DateTime.Parse(po.Details[0].S_CJRQ.ToString()).ToString("yyyyMMdd"); + //} + //if (po.Details[0].S_XQRQ != null) + //{ + // PZZDRQ = DateTime.Parse(po.Details[0].S_XQRQ.ToString()).ToString("yyyyMMdd"); - } + //} CkBcakDto.Root myRoot = new CkBcakDto.Root { ROOT = new CkBcakDto.ROOT @@ -2657,10 +2992,10 @@ WLPZ = new CkBcakDto.WLPZ { KEY = po.S_NO, - ZYWLX = "涓氬姟绫诲瀷鍊�, - PZRQ = PZZDRQ, - GZRQ = GZRQ, // 鍋囪鏃ユ湡鏍煎紡涓�骞�鏈�鏃� - GZRY = po.UNAME, + ZYWLX = "2", + PZRQ = DateTime.Now.ToString("yyyyMMdd"), + GZRQ =DateTime.Now.ToString("yyyyMMdd"), // 鍋囪鏃ユ湡鏍煎紡涓�骞�鏈�鏃� + GZRY = po.S_CREATOR_NAME, ITEM = new List<CkBcakDto.ITEM> { } @@ -2671,45 +3006,49 @@ //鍥炲弬鐗╂枡淇℃伅 List<CkBcakDto.ITEM> iTEMs = new List<CkBcakDto.ITEM>(); - foreach (var item in MaterList) - { - - db.BeginTran(); - + foreach (var item in MaterList) + { - var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); - CkBcakDto.ITEM ckbitem = new CkBcakDto.ITEM(); - ckbitem.SCDD = podetail?.S_SCDD; - ckbitem.ZJBM = podetail?.S_ZJBM; - ckbitem.FHSL = item.qty; - ckbitem.DW = podetail?.S_UOM; - ckbitem.YLBH = podetail?.S_YLBH; - ckbitem.YLXMH = podetail?.S_YLXMH; - ckbitem.GC = po.S_FACTORY; - ckbitem.KCDD = podetail?.S_KCDD; + db.BeginTran(); - CkBcakDto.ITEM1 listitem1 = new CkBcakDto.ITEM1(); - //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.item_code&&a.N_ROW_NO==item.N_ROW_NO).ToList(); - ////string[] xlhValues = item.S_SERIAL_NO.Split(','); - //var serialNos = string.Join(",", CntrItemRels - // .Where(s => s.S_ITEM_CODE == item.item_code) - // .Select(s => s.S_SERIAL_NO)); - listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); - //foreach (var xlhValue in xlhValues) - //{ - // CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue }; - // listitem1.Add(newItem); - //} - ckbitem.ITEM1 = listitem1; - iTEMs.Add(ckbitem); - } + + var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); + CkBcakDto.ITEM ckbitem = new CkBcakDto.ITEM(); + ckbitem.SCDD = podetail?.S_SCDD; + ckbitem.ZJBM = podetail?.S_ZJBM; + ckbitem.FHSL = item.qty; + ckbitem.DW = podetail?.S_UOM; + ckbitem.YLBH = podetail?.S_YLBH; + ckbitem.YLXMH = podetail?.S_YLXMH; + ckbitem.GC = po.S_FACTORY; + ckbitem.KCDD = podetail?.S_KCDD; + + CkBcakDto.ITEM1 listitem1 = new CkBcakDto.ITEM1(); + //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.item_code&&a.N_ROW_NO==item.N_ROW_NO).ToList(); + ////string[] xlhValues = item.S_SERIAL_NO.Split(','); + //var serialNos = string.Join(",", CntrItemRels + // .Where(s => s.S_ITEM_CODE == item.item_code) + // .Select(s => s.S_SERIAL_NO)); + listitem1.XLH = podetail?.S_SERIAL_NO==null?null: podetail?.S_SERIAL_NO.Split(',').ToList(); + //foreach (var xlhValue in xlhValues) + //{ + // CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue }; + // listitem1.Add(newItem); + //} + ckbitem.ITEM1 = listitem1; + iTEMs.Add(ckbitem); + } myRoot.ROOT.WLPZ.ITEM = iTEMs; + if (myRoot.ROOT.WLPZ.ITEM.Where(s=>!string.IsNullOrEmpty(s.SCDD) && !string.IsNullOrEmpty(s.YLBH) && !string.IsNullOrEmpty(s.YLXMH)).Count()==0) + { + myRoot.ROOT.WLPZ.ZYWLX = "2"; + } //db.Insertable<OutboundRecord>(records).ExecuteCommand(); #region wms-sap鍥炶皟 //绫昏浆json var json = JsonConvert.SerializeObject(myRoot.ROOT); - //json杞瑇ml - string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; + //json杞瑇ml + string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; LogHelper.Info($"鍑哄簱xml鏁版嵁{xml}"); //// 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" @@ -2738,55 +3077,57 @@ LogHelper.Info("鍑哄簱SAP杩斿洖缁撴灉: " + responses.Output); XmlDocument xmlDoc = new XmlDocument(); - xmlDoc.LoadXml(responses.Output.ToString()); - JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); - var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); - //娣诲姞鍑瘉璁板綍琛�- result.resultMsg = data.ROOT.ITEM.MSGDESP; - result.resultCode = data.ROOT.ITEM.MSGCODE; - if (data.ROOT.ITEM.MSGCODE == 0) - { - foreach (var item in MaterList) - { - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = po.S_NO; - materialVoucher.S_TYPE = po.S_OUT_TYPE; - materialVoucher.S_WLBM = item.item_code; - materialVoucher.S_WLH = item.N_ROW_NO; - materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; - materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; - materialVoucher.S_WH_CODE = po.S_WH_CODE; - materialVoucher.S_AREA_CODE = po.S_AREA_CODE; - materialVoucher.F_QTY = item.qty; - materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); - } - } - ////娣诲姞鍑瘉璁板綍琛�- //result.resultMsg = data.ROOT.ITEM.MSGDESP; - //result.resultCode = data.ROOT.ITEM.MSGCODE; - //MaterialVoucher materialVoucher = new MaterialVoucher(); - //materialVoucher.S_NO = po.S_NO; - //materialVoucher.S_TYPE = po.S_OUT_TYPE; - //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; - //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; - //materialVoucher.STATUS = 0; - //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); - #endregion - - //db.CommitTran(); - } - catch (Exception ex) + xmlDoc.LoadXml(responses.Output.ToString()); + JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); + var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); + //娣诲姞鍑瘉璁板綍琛�+ result.resultMsg = data.ROOT.ITEM.MSGDESP; + result.resultCode = data.ROOT.ITEM.MSGCODE; + if (data.ROOT.ITEM.MSGCODE == 0) { - //db.RollbackTran(); - LogHelper.Info("鏅�鍑哄簱鍥炶皟" + - "" + ex.Message); - Console.WriteLine(ex.Message); - - throw; + foreach (var item in MaterList) + { + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_TYPE = po.S_OUT_TYPE; + materialVoucher.S_WLBM = item.item_code; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; + materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; + materialVoucher.S_WH_CODE = po.S_WH_CODE; + materialVoucher.S_AREA_CODE = po.S_AREA_CODE; + materialVoucher.F_QTY = item.qty; + materialVoucher.S_GZRQ = po.BUDAT; + materialVoucher.UNAME = po.UNAME; + materialVoucher.STATUS = 0; + db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + } } - return result; + ////娣诲姞鍑瘉璁板綍琛�+ //result.resultMsg = data.ROOT.ITEM.MSGDESP; + //result.resultCode = data.ROOT.ITEM.MSGCODE; + //MaterialVoucher materialVoucher = new MaterialVoucher(); + //materialVoucher.S_NO = po.S_NO; + //materialVoucher.S_TYPE = po.S_OUT_TYPE; + //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; + //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; + //materialVoucher.STATUS = 0; + //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + #endregion + + //db.CommitTran(); } + catch (Exception ex) + { + //db.RollbackTran(); + LogHelper.Info("鏅�鍑哄簱鍥炶皟" + + "" + ex.Message); + Console.WriteLine(ex.Message); + + throw; + } + return result; + } //} @@ -2801,16 +3142,16 @@ /// <param name="cntr_code"></param> /// <returns></returns> [ApiExplorerSettings(IgnoreApi = true)] - public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code) + public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code,string S_CNTR_TYPE) { - var result = new SimpleResult(); + var result = new SimpleResult(); // var db = new SqlHelper<object>().GetInstance(); using (var db = new SqlHelper<object>().GetInstance()) { try { - if (MaterList.Count()<1) + if (MaterList.Count() < 1) { throw new Exception("绱鐮佺洏鏁伴噺鐗╂枡鏁版嵁涓虹┖"); } @@ -2846,12 +3187,13 @@ if (cir != null) { cir.F_QTY += item.qty; - db.Updateable(cir).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); + cir.S_CNTR_TYPE = S_CNTR_TYPE; + db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE }).ExecuteCommand(); } else { //2.鎻掑叆鏂扮殑瀹瑰櫒鐗╂枡淇℃伅锛堝鍣ㄥ彿涓嶅彉S_SERIAL_NO = item.S_SERIAL_NO,锛�- cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM=info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no }; + cir = new CntrItemRel { S_CNTR_TYPE= S_CNTR_TYPE, S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no }; db.Insertable<CntrItemRel>(cir).ExecuteCommand(); } var count = db.Queryable<CntrItemRel>().Count(a => a.S_CNTR_CODE == cntr.S_CODE); @@ -2958,16 +3300,44 @@ S_AREA_CODE = "HJQ", N_ROW_NO = "", S_ITEM_CODE = a.WLBM, - S_ITEM_NAME = item.S_ITEM_NAME, + S_ITEM_NAME = item?.S_ITEM_NAME, F_QTY = a.XQSL, + S_ZJBM = a.ZJBM, + S_YLBH = a.YLBH, + S_YLXMH = a.YLHXM, S_BATCH_NO = "", S_ERP_WH_CODE = a.KCDD, + S_ZJWLTH = a.ZJWLTH, + S_ZJWLMS = a.ZJWLMS, + S_ZHFHBS = a.ZHFHBS, + S_CJRQ = a.CJRQ, + S_LLDSCBS = a.LLDSCBS, + S_SCGLY = a.SCGLY, + S_GXH = a.GXH, + S_XQRQ = a.XQRQ, N_ITEM_STATE = 1 }); } - - var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0; - db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); + if (po.Details.Count()>0) + { + LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM(); + lLDReturnRoot1.GC = itemscddll.GC; + lLDReturnRoot1.LLDH = itemscddll.LLDH; + lLDReturnRoot1.MSGCODE = 0; + lLDReturnRoot1.MSGDESP = $"鎴愬姛"; + iTEMs.Add(lLDReturnRoot1); + var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0; + db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); + } + else + { + LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM(); + lLDReturnRoot1.GC = itemscddll.GC; + lLDReturnRoot1.LLDH = itemscddll.LLDH; + lLDReturnRoot1.MSGCODE = 0; + lLDReturnRoot1.MSGDESP = $"鎴愬姛,鏃犳暟鎹坊鍔�; + iTEMs.Add(lLDReturnRoot1); + } } } @@ -3015,6 +3385,17 @@ S_ITEM_CODE = a.WLBM, S_ITEM_NAME = item.S_ITEM_NAME, F_QTY = a.XQSL, + S_ZJBM = a.ZJBM, + S_YLBH = a.YLBH, + S_YLXMH = a.YLHXM, + S_ZJWLTH = a.ZJWLTH, + S_ZJWLMS = a.ZJWLMS, + S_ZHFHBS = a.ZHFHBS, + S_CJRQ = a.CJRQ, + S_LLDSCBS = a.LLDSCBS, + S_GXH = a.GXH, + S_XQRQ = a.XQRQ, + S_SCGLY = a.SCGLY, S_BATCH_NO = "鏃�, S_ERP_WH_CODE = a.KCDD, N_ITEM_STATE = 1 @@ -3065,7 +3446,7 @@ lLDReturnRoots.MSGCODE = 1; lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡鏁版嵁涓嶅瓨鍦�鏃犳硶鍒犻櫎"; iTEMs.Add(lLDReturnRoots); - continue; + break; } } else @@ -3084,7 +3465,7 @@ lLDReturnRoots.MSGCODE = 1; lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�; iTEMs.Add(lLDReturnRoots); - continue; + break; } TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail { @@ -3094,6 +3475,17 @@ S_ITEM_CODE = a.WLBM, S_ITEM_NAME = item.S_ITEM_NAME, F_QTY = a.XQSL, + S_ZJBM = a.ZJBM, + S_YLBH = a.YLBH, + S_YLXMH = a.YLHXM, + S_ZJWLTH = a.ZJWLTH, + S_ZJWLMS = a.ZJWLMS, + S_ZHFHBS = a.ZHFHBS, + S_CJRQ = a.CJRQ, + S_LLDSCBS = a.LLDSCBS, + S_SCGLY = a.SCGLY, + S_GXH = a.GXH, + S_XQRQ = a.XQRQ, S_BATCH_NO = "鏃�, S_ERP_WH_CODE = a.KCDD, N_ITEM_STATE = 1 @@ -3112,9 +3504,26 @@ //娣诲姞鏁版嵁 if (listtn.Count() > 0) { + LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM(); + lLDReturnRoot1.GC = itemscddll.GC; + lLDReturnRoot1.LLDH = itemscddll.LLDH; + lLDReturnRoot1.MSGCODE = 0; + lLDReturnRoot1.MSGDESP = $"鎴愬姛"; + iTEMs.Add(lLDReturnRoot1); db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand(); } + else + { + LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM(); + lLDReturnRoot1.GC = itemscddll.GC; + lLDReturnRoot1.LLDH = itemscddll.LLDH; + lLDReturnRoot1.MSGCODE = 0; + lLDReturnRoot1.MSGDESP = $"鎴愬姛,鏃犳暟鎹坊鍔�; + iTEMs.Add(lLDReturnRoot1); + } } + + db.CommitTran(); } @@ -3180,7 +3589,7 @@ else { //var az = db.Queryable<AZInventory>().ToList(); - var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(),UNAME=po.UNAME, S_FACTORY = po.S_FACTORY,S_CBZX=po.S_CBZX,S_ZZKM=po.S_ZZKM,S_LRZX=po.S_LRZX, BLDAT = po.BLDAT, BUDAT=po.BUDAT, S_OUT_TYPE = po.S_OUT_TYPE, S_BS_TYPE = po.S_BS_TYPE, S_AREA_CODE = po.S_AREA_CODE, S_BS_NO = po.S_NO }; + var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(), UNAME = po.UNAME, S_FACTORY = po.S_FACTORY, S_CBZX = po.S_CBZX, S_ZZKM = po.S_ZZKM, S_LRZX = po.S_LRZX, BLDAT = po.BLDAT, BUDAT = po.BUDAT, S_OUT_TYPE = po.S_OUT_TYPE, S_BS_TYPE = po.S_BS_TYPE, S_AREA_CODE = po.S_AREA_CODE, S_BS_NO = po.S_NO }; po1.Details = new List<TN_Outbound_Detail>(); if (po.Details.Count() > 0) @@ -3202,6 +3611,17 @@ S_BATCH_NO = a.S_BATCH_NO, S_SERIAL_NO = a.S_SERIAL_NO, S_CGPZH = a.S_CGPZH, + S_ZJBM = a.S_ZJBM, + S_YLBH = a.S_YLBH, + S_ZJWLTH = a.S_ZJWLTH, + S_ZJWLMS = a.S_ZJWLMS, + S_ZHFHBS = a.S_ZHFHBS, + S_CJRQ = a.S_CJRQ, + S_LLDSCBS = a.S_LLDSCBS, + S_SCGLY = a.S_SCGLY, + S_GXH = a.S_GXH, + S_XQRQ = a.S_XQRQ, + S_YLXMH = a.S_YLXMH, S_CGPZXMBH = a.S_CGPZXMBH, S_ERP_WH_CODE = a.S_ERP_WH_CODE, N_ITEM_STATE = a.N_ITEM_STATE @@ -3547,7 +3967,7 @@ MaterialVoucher materialVoucher = new MaterialVoucher(); materialVoucher.S_NO = model.S_NO; materialVoucher.S_TYPE = po.S_IN_TYPE; - materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; + materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; materialVoucher.STATUS = 0; db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); @@ -3654,7 +4074,6 @@ } else LogHelper.Info($"鍏ュ簱鍗曟槑缁嗘棤鍊�); #endregion - var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == model.S_NO).ToList(); if (po == null) { @@ -3662,6 +4081,10 @@ result.resultMsg = "鏁版嵁涓嶅瓨鍦�; return result; } + po.Details= po.Details.Where(d => model.Wlist.Any(w => + w.S_ITEM_CODE == d.S_ITEM_CODE && + w.N_ROW_NO == d.N_ROW_NO)) + .ToList(); if (po.S_IN_TYPE == "鍐呴噰鍏ュ簱") { List<NcRkDto.ITEM> listitem = new List<NcRkDto.ITEM>(); @@ -3765,7 +4188,7 @@ // 鍑嗗璇锋眰鍙傛暟 ZscmNc request = new ZscmNc(); request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; - LogHelper.Info($"鍐呴噰SAP鍥炶皟"); + LogHelper.Info($"鍐呴噰SAP鍥炶皟{service.Url}"); // 璋冪敤Web Service ZscmNcResponse responses = service.ZscmNc(request); @@ -3783,35 +4206,52 @@ //娣诲姞鍑瘉璁板綍琛� result.resultMsg = data.ROOT.ITEM.MSGDESP; result.resultCode = data.ROOT.ITEM.MSGCODE; - MaterialVoucher materialVoucher = new MaterialVoucher(); + //MaterialVoucher materialVoucher = new MaterialVoucher(); if (data.ROOT.ITEM.MSGCODE == 0) { - materialVoucher.S_NO = model.S_NO; - materialVoucher.S_TYPE = po.S_IN_TYPE; - materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; - materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; - materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + //materialVoucher.S_NO = model.S_NO; + //materialVoucher.S_TYPE = po.S_IN_TYPE; + //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; + //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; + //materialVoucher.STATUS = 0; + //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + List<MaterialVoucher> materials = new List<MaterialVoucher>(); + foreach (var item in model.Wlist) + { + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_WLBM = item.S_ITEM_CODE; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_TYPE = po.S_IN_TYPE; + materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; + materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; + materialVoucher.STATUS = 0; + materials.Add(materialVoucher); + } + + if (materials.Count() > 0) + { + + db.Insertable<MaterialVoucher>(materials).ExecuteCommand(); + } } } - else - - if (po.S_IN_TYPE == "璁″垝澶栭�鏂欏叆搴�) + else if (po.S_IN_TYPE == "璁″垝澶栭�鏂欏叆搴�) { DateTime dateTime; - DateTime dateTime1 ; + DateTime dateTime1; string GZRQ = ""; string PZZDRQ = ""; - if (po.BUDAT!=null) + if (po.BUDAT != null) { GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); } if (po.BLDAT != null) { PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); - + } JHWBackDto.Root myRoot = new JHWBackDto.Root { @@ -3831,7 +4271,7 @@ } }, - + } }; //鍥炲弬鐗╂枡淇℃伅 @@ -3854,7 +4294,7 @@ ckbitem.KCDD = podetail?.S_KCDD; ckbitem.PC = podetail?.S_BATCH_NO; #region MyRegion - // List<JHWBackDto.ITEM1> listitem1 = new List<JHWBackDto.ITEM1>(); + // List<JHWBackDto.ITEM1> listitem1 = new List<JHWBackDto.ITEM1>(); JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); ////string[] xlhValues = item.S_SERIAL_NO.Split(','); @@ -3879,9 +4319,9 @@ ////绫昏浆json var json = JsonConvert.SerializeObject(myRoot.ROOT); ////json杞瑇ml - string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; + string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; - LogHelper.Info($"璁″垝澶栭�鏂檟ml鏁版嵁{xml}"); + LogHelper.Info($"璁″垝澶栭�鏂檟ml鏁版嵁{xml}"); //// 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml" //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; @@ -3923,13 +4363,25 @@ result.resultCode = data.ROOT.ITEM.MSGCODE; if (data.ROOT.ITEM.MSGCODE == 0) { - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = po.S_NO; - materialVoucher.S_TYPE = po.S_IN_TYPE; - materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; - materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; - materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + List< MaterialVoucher > materials = new List< MaterialVoucher >(); + foreach (var item in model.Wlist) + { + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_WLBM = item.S_ITEM_CODE; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_TYPE = po.S_IN_TYPE; + materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; + materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; + materialVoucher.STATUS = 0; + materials.Add( materialVoucher ); + } + + if (materials.Count() > 0) + { + + db.Insertable<MaterialVoucher>(materials).ExecuteCommand(); + } } #endregion @@ -4054,13 +4506,34 @@ result.resultCode = data.ROOT.ITEM.MSGCODE; if (data.ROOT.ITEM.MSGCODE == 0) { - MaterialVoucher materialVoucher = new MaterialVoucher(); - materialVoucher.S_NO = model.S_NO; - materialVoucher.S_TYPE = po.S_IN_TYPE; - materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; - materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; - materialVoucher.STATUS = 0; - db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + //MaterialVoucher materialVoucher = new MaterialVoucher(); + //materialVoucher.S_NO = model.S_NO; + //materialVoucher.S_TYPE = po.S_IN_TYPE; + //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH; + //LogHelper.Info("鍊�: " + data.ROOT.ITEM?.WLPZH); + //LogHelper.Info("鍊�: " + materialVoucher.S_WLPZBH); + //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; + //materialVoucher.STATUS = 0; + //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); + List<MaterialVoucher> materials = new List<MaterialVoucher>(); + foreach (var item in model.Wlist) + { + MaterialVoucher materialVoucher = new MaterialVoucher(); + materialVoucher.S_NO = po.S_NO; + materialVoucher.S_WLBM = item.S_ITEM_CODE; + materialVoucher.S_WLH = item.N_ROW_NO; + materialVoucher.S_TYPE = po.S_IN_TYPE; + materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; + materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; + materialVoucher.STATUS = 0; + materials.Add(materialVoucher); + } + if (materials.Count() > 0) + { + + db.Insertable<MaterialVoucher>(materials).ExecuteCommand(); + } + } //else //{ @@ -4077,14 +4550,14 @@ else if (po.S_IN_TYPE == "鍐查攢鍏ュ簱") { - //var materpz = db.Queryable<TN_Inbound_Order>().Where(s => s.S_NO == po.S_NO).First(); + var materpz = db.Queryable<TN_Inbound_Order>().Where(s => s.S_NO == po.S_NO).First(); string GZRQ = ""; LogHelper.Info($"鍐查攢鍏ュ簱鍏ュ簱{po.BUDAT}"); if (po.BUDAT != null) { GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); } - + //鍑哄簱鍥炶皟鍏ュ弬 CXCkBackDto.Root roots = new CXCkBackDto.Root { @@ -4098,7 +4571,7 @@ List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); //鍑哄簱鍗曡鎯� LogHelper.Info($"鍐查攢鍏ュ簱鍏ュ簱{GZRQ}"); - var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); + var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO && a.STATUS == 0).ToList(); //var podet = db.Queryable<tn_i>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); LogHelper.Info($"鏁伴噺{porecord.Count()}"); LogHelper.Info($"鏁伴噺{po.Details.Count()}"); @@ -4134,7 +4607,7 @@ // 纭繚HTTP鎴愬姛鐘舵�鍊� response.EnsureSuccessStatusCode(); LogHelper.Info($"鍐查攢鍏ュ簱xml鏁版嵁{xml}"); - + ZSCM2_CXPZ service = new ZSCM2_CXPZ(); service.PreAuthenticate = true; @@ -4145,17 +4618,22 @@ LogHelper.Info($"閫氱敤鍐查攢SAP鍥炶皟"); // 璋冪敤Web Service ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); - + // 澶勭悊鍝嶅簲 LogHelper.Info("閫氱敤鍐查攢SAP杩斿洖缁撴灉: " + responses.Output); + + + //string xmlqqq = "<ROOT>\r\n\t<ITEM>\r\n\t\t<YWLPZBH>490062947</YWLPZBH>\r\n\t\t<YWLPZND>2025</YWLPZND>\r\n\t\t<YWLPZHXM>001</YWLPZHXM>\r\n\t\t<WLPZBH>490062949</WLPZBH>\r\n\t\t<WLPZND>\r\n\t\t</WLPZND>\r\n\t\t<WLPZHXM>D0001</WLPZHXM>\r\n\t\t<MSGCODE>0</MSGCODE>\r\n\t\t<MSGDESP>鏁版嵁鎺ユ敹鎴愬姛,骞跺啿涓攢鎴愬姛!</MSGDESP>\r\n\t</ITEM>\r\n</ROOT>"; // 灏�XmlDocument 杞崲涓�JSON 瀛楃涓� //JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); XmlDocument xmlDoc = new XmlDocument(); xmlDoc.LoadXml(responses.Output.ToString()); JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); + + EnsureArrayFormat(jsonObject, "ITEM", ""); //var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); var resmeg = ""; @@ -4169,7 +4647,7 @@ if (item.MSGCODE == 0) { - var onr = po.Details.Where(s => s.N_ROW_NO == item.WLPZHXM).First(); + var onr = po.Details.Where(s => s.N_ROW_NO == item.WLPZHXM).FirstOrDefault(); MaterialVoucher materialVoucher = new MaterialVoucher(); materialVoucher.S_NO = po.S_NO; @@ -4183,7 +4661,7 @@ materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; materialVoucher.S_WH_CODE = po.S_WH_CODE; materialVoucher.S_AREA_CODE = po.S_AREA_CODE; - materialVoucher.F_QTY = onr.F_QTY; + materialVoucher.F_QTY = onr != null ? onr.F_QTY : 0; //materialVoucher.STATUS = 0; resmeg += item?.MSGDESP; materiallist.Add(materialVoucher); @@ -4192,7 +4670,7 @@ } else { - rescode = 1; + rescode = 1; resmeg += item?.MSGDESP; } @@ -4268,17 +4746,18 @@ var po = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == S_CNTR_CODE && a.S_BS_NO == taskno).ToList(); LogHelper.Info("娣诲姞鍏ュ簱璁板綍琛╬o" + po.Count()); - var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).First(); - var ass = pz == null; + var pzs = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).ToList(); + var ass = pzs == null; LogHelper.Info("娣诲姞鍏ュ簱璁板綍琛╬z" + ass); List<OutboundRecord> records = new List<OutboundRecord>(); foreach (var item in po) { + var pz= pzs.Where(s=>s.S_WLBM==item.S_ITEM_CODE&&s.S_WLH==item.N_BS_ROW_NO).First(); OutboundRecord outboundRecord = new OutboundRecord(); outboundRecord.S_NO = item.S_BS_NO; outboundRecord.S_TYPE = pz?.S_TYPE; - outboundRecord.S_WLPZBH = pz?.S_WLPZBH; + outboundRecord.S_WLPZBH = pz?.S_WLBM; outboundRecord.S_WLPZND = pz?.S_WLPZND; outboundRecord.S_WLBM = item.S_ITEM_CODE; outboundRecord.S_SL = item.F_QTY; -- Gitblit v1.9.1