From cda66b452fda201ab0ecc7fb5c94bbc2288b8877 Mon Sep 17 00:00:00 2001
From: hudong <Administrator@PC-20250329JZUF>
Date: 星期三, 14 五月 2025 16:08:47 +0800
Subject: [PATCH] 1.主物料信息获取 2.物料凭证表数据逻辑修改 3.物料凭证表添加新字段 4.冲销回调实现（为完全实现）
---
api/WmsSpaHelper.cs | 259 +++++++++++++++++++++++++++++++++++----------------
1 files changed, 176 insertions(+), 83 deletions(-)
diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index 6a2b796..a43f215 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -821,17 +821,28 @@
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
- internal static SimpleResult Mater_In(MaterDto.Root model)
+ internal static WLReturnRoot.Root Mater_In(MaterDto.Root model)
{
var db = new SqlHelper<object>().GetInstance();
- var result = new SimpleResult();
- result.resultMsg = "鎴愬姛";
- try
+ var response = new WLReturnRoot.Root
{
- db.BeginTran();
- List<TN_Material> list = new List<TN_Material>();
- foreach (var item in model.ROOT.ITEM)
+ ROOT = new WLReturnRoot.ROOT
{
+ ITEM = new List<WLReturnRoot.ITEM>
+ {
+
+ }
+ }
+ };
+ db.BeginTran();
+ List<WLReturnRoot.ITEM> list = new List<WLReturnRoot.ITEM>();
+ foreach (var item in model.ROOT.ITEM)
+ {
+ try
+ {
+
+ var result = new WLReturnRoot.ITEM();
+
var materlist = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.WLBM).First();
if (materlist == null)
{
@@ -849,20 +860,54 @@
tN_Material.S_CPZ = item.CPZ;
tN_Material.S_CPZMS = item.CPZMS;
tN_Material.S_ITEM_NAME = item.VTEXT;
- list.Add(tN_Material);
+ db.Insertable<TN_Material>(tN_Material).ExecuteCommand();
+ result.MSGDESP = "鎴愬姛";
+ result.MSGCODE = 0;
+ result.GCBM = item.GCBM;
+ result.WLBM = item.WLBM;
+ list.Add(result);
}
-
+ else
+ {
+ materlist.S_ITEM_CODE = item.WLBM;
+ materlist.S_GCBM = item.GCBM;
+ materlist.S_WLZBM = item.WLZBM;
+ materlist.S_WLZMS = item.WLZMS;
+ materlist.S_WLLX = item.WLLX;
+ materlist.S_WLMS = item.WLMS;
+ materlist.S_WLCMS = item.WLCMS;
+ materlist.S_DWBM = item.DWBM;
+ materlist.S_DWMS = item.DWMS;
+ materlist.S_JBM = item.JBM;
+ materlist.S_CPZ = item.CPZ;
+ materlist.S_CPZMS = item.CPZMS;
+ materlist.S_ITEM_NAME = item.VTEXT;
+ db.Updateable<TN_Material>(materlist).ExecuteCommand();
+ result.MSGDESP = "鎴愬姛";
+ result.MSGCODE = 0;
+ result.GCBM = item.GCBM;
+ result.WLBM = item.WLBM;
+ list.Add(result);
+ }
}
- db.Insertable<TN_Material>(list).ExecuteCommand();
- db.CommitTran();
+ catch (Exception e)
+ {
+ var result = new WLReturnRoot.ITEM();
+ result.MSGDESP = e.Message;
+ result.MSGCODE = 1;
+ result.GCBM = item.GCBM;
+ result.WLBM = item.WLBM;
+ list.Add(result);
+ db.RollbackTran();
+ throw;
+ }
+ }
+ response.ROOT.ITEM = list;
+ //db.Insertable<TN_Material>(list).ExecuteCommand();
+ db.CommitTran();
- }
- catch (Exception e)
- {
- db.RollbackTran();
- throw;
- }
- return result;
+
+ return response;
}
@@ -1749,7 +1794,7 @@
S_START_AREA = locinfo.S_AREA_CODE,
S_START_WH = locinfo.S_WH_CODE,
S_END_LOC = model.start,
- //S_BS_NO = model.arrival_no,
+ S_BS_NO = model.MaterList[0].arrival_no,
N_TYPE = 1,
S_TYPE = WMSTask.GetTypeStr(1),
S_OP_DEF_CODE = "",
@@ -1838,7 +1883,8 @@
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>();
@@ -2253,13 +2299,19 @@
//娣诲姞鍑瘉璁板綍琛� 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();
+ 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.STATUS = 0;
+ db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+ }
+
#endregion
db.CommitTran();
@@ -2298,6 +2350,13 @@
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)
+ {
+ 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();
//鏍规嵁鍏ュ簱鏌ョ湅鍑瘉缂栧彿淇℃伅
@@ -2307,71 +2366,102 @@
{
ROOT = new CXCkBackDto.ROOT
{
- HEAD = new CXCkBackDto.HEAD
+ HEAD = new List<CXCkBackDto.HEAD>
{
- WLPZ = po.S_WLPZ,
- WLPZNF = po.S_WLPZNF,
- WLPZXM = MaterList[0].N_ROW_NO,
- GZRQ = "2025-03-20",
- SRRQ = "2025-03-19",
- GZRY = "杩囪处浜哄憳濮撳悕"
+
+ //GZRQ = GZRQ,
+ //SRRQ = PZZDRQ,
+ //WLPZ = po.S_WLPZ,
+ //WLPZNF = po.S_WLPZNF,
+ //WLPZXM = MaterList[0].N_ROW_NO,
+
+ //GZRY = po.UNAME
}
}
};
- //鍥炲弬鐗╂枡淇℃伅
- //List<OutboundRecord> records = new List<OutboundRecord>();
- //foreach (var item in MaterList)
- //{
+ List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>();
+ foreach (var item in po.Details)
+ {
+ CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD();
+ hEAD.GZRQ = GZRQ;
+ hEAD.SRRQ = DateTime.Now.ToString("yyyyMMdd");
+ hEAD.WLPZ = po.S_NO;
+ hEAD.WLPZNF = po.S_WLPZND;
+ hEAD.WLPZXM = item.N_ROW_NO;
+ hEAD.GZRY = po.UNAME;
+ listhead.Add(hEAD);
+ }
+ myRoot.ROOT.HEAD = listhead;
- // db.BeginTran();
- // //鍑哄簱璁板綍
- // 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_NO = arrival_no;
- // outboundRecord.S_WLBM = item.item_code;
- // outboundRecord.S_SL = item.qty;
- // outboundRecord.S_CNTR_CODE = cntr_code;
- // records.Add(outboundRecord);
-
- //}
- //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($"鍐查攢鍑哄簱鍥炶皟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();
- }
+ ZSCM2_CXPZ service = new ZSCM2_CXPZ();
+ // 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(responseXml.ToString());
+ xmlDoc.LoadXml(responses.Output.ToString());
JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc));
- var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString());
+ var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString());
+ var resmeg = "";
+ int rescode = 0;
//娣诲姞鍑瘉璁板綍琛�- 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();
+ if (data!=null)
+ {
+ List<MaterialVoucher> materiallist = new List<MaterialVoucher>();
+ foreach (var item in data.ROOT.ITEM)
+ {
+ if (item.MSGCODE == 0)
+ {
+ 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.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();
@@ -2605,7 +2695,10 @@
try
{
-
+ if (MaterList.Count()<1)
+ {
+ throw new Exception("绱鐮佺洏鏁伴噺鐗╂枡鏁版嵁涓虹┖");
+ }
foreach (var item in MaterList)
{
var allInfolist = db.Queryable<TN_Inbound_Detail>()
@@ -3867,14 +3960,14 @@
{
ROOT = new CXCkBackDto.ROOT
{
- HEAD = new CXCkBackDto.HEAD
+ HEAD = new List<CXCkBackDto.HEAD>
{
- WLPZ = materpz.S_WLPZ,
- WLPZNF = materpz.S_WLPZNF,
- WLPZXM = null,
- GZRQ = "2025-03-20",
- SRRQ = DateTime.Now.ToString(),
- GZRY = "杩囪处浜哄憳濮撳悕"
+ //WLPZ = materpz.S_WLPZ,
+ //WLPZNF = materpz.S_WLPZNF,
+ //WLPZXM = null,
+ //GZRQ = "2025-03-20",
+ //SRRQ = DateTime.Now.ToString(),
+ //GZRY = "杩囪处浜哄憳濮撳悕"
}
}
};
@@ -3923,7 +4016,7 @@
}
catch (Exception ex)
{
- LogHelper.Info($"鍏ュ簱鍥炶皟鎶ラ敊{ex.Message}");
+ LogHelper.Info($"鍐查攢鍥炲簱鍥炶皟鎶ラ敊{ex.Message}");
db.RollbackTran();
throw;
}
--
Gitblit v1.9.1