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 |  437 +++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 302 insertions(+), 135 deletions(-)

diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index d3ab124..a43f215 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -654,7 +654,87 @@
             }
             return simpleResults;
         }
-   
+        /// <summary>
+        /// sap-wmsg渚涘簲鍟嗘伅娣诲姞SimpleResult
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        internal static Orderback.Root GYS_In(GYSDto.Root model)
+        {
+            var orderResponse = new Orderback.Root
+            {
+                ROOT = new Orderback.ROOT
+                {
+                    ITEM = new List<Orderback.ITEM> { }
+
+                }
+            };
+
+            List<Orderback.ITEM> tEMs = new List<Orderback.ITEM>();
+            var db = new SqlHelper<object>().GetInstance();
+            try
+            {
+                db.BeginTran();
+                foreach (var item in model.ROOT.GYSXX)
+                {
+                    Orderback.ITEM iTEM = new Orderback.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
+                    {
+                        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";
+                    iTEM.MSGDESP = $"鎴愬姛";
+                    tEMs.Add(iTEM);
+                }
+                orderResponse.ROOT.ITEM = tEMs;
+                db.CommitTran();
+            }
+            catch (Exception e)
+            {
+                Orderback.ITEM iTEM = new Orderback.ITEM();
+                iTEM.SCDDH = "";
+                iTEM.GC = "";
+                iTEM.MSGCODE = "1";
+                iTEM.MSGDESP = e.Message;
+                tEMs.Add(iTEM);
+                orderResponse.ROOT.ITEM = tEMs;
+                db.RollbackTran();
+                return orderResponse;
+                throw;
+            }
+            return orderResponse;
+        }
         /// <summary>
         /// sap-wms鐢熶骇璁㈠崟淇℃伅娣诲姞SimpleResult
         /// </summary>
@@ -741,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)
                     {
@@ -769,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;
         }
 
 
@@ -1042,8 +1167,6 @@
                         var po = WMSHelper.GetInboundOrder(itemwlpz.HEAD.WLPZH);
                         if (po == null)
                         {
-
-
                             #region MyRegion
                             po = new TN_Inbound_Order { S_NO = itemwlpz.HEAD.WLPZH, S_WLPZND = itemwlpz.HEAD.ND, S_FACTORY = itemwlpz.ITEM[0].GC, S_IN_TYPE = "鍐呴噰鍏ュ簱", S_BS_TYPE = itemwlpz.HEAD.YDLX };
                             po.Details = new List<TN_Inbound_Detail>();
@@ -1051,28 +1174,7 @@
                             {
                                 itemwlpz.ITEM.ForEach(a =>
                                 {
-                                    //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//鍒ゆ柇搴忓垪鍙锋槸鍚︿负澶氫釜
-                                    //{
-                                    //    foreach (var item in a.ITEM1.Select(s => s.XLH))
-                                    //    {
-                                    //        po.Details.Add(new TN_Inbound_Detail
-                                    //        {
-                                    //            S_IO_NO = model.ROOT.WLPZ.HEAD.WLPZBH,
-                                    //            N_ROW_NO = po.Details.Count + 1,
-                                    //            S_ITEM_CODE = a.WLH,
-                                    //            F_QTY = a.SL,
-                                    //            S_ITEM_STATE = "鐗╂枡",
-                                    //            S_ITEM_NAME = "鐗╂枡",
-                                    //            F_ACC_B_QTY = 0,
-                                    //            S_KCDD = a.KCDD,
-                                    //            S_UOM = a.JBJLDW,//璁¢噺鍗曚綅
-                                    //            S_SERIAL_NO = item,
-                                    //            S_BATCH_NO = a.PC,
-                                    //        });
-                                    //    }
-                                    //}
-                                    //else
-                                    //{
+                              
                                     po.Details.Add(new TN_Inbound_Detail
                                     {
                                         S_IO_NO = itemwlpz.HEAD.WLPZH,
@@ -1114,7 +1216,6 @@
                                     {
                                         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
@@ -1125,7 +1226,7 @@
                                             N_ROW_NO = a.WLPZHXM,
                                             S_ITEM_CODE = a.WLBM,
                                             F_QTY = a.SL,
-                                            S_ITEM_STATE = "鐗╂枡",
+                                            S_ITEM_STATE = "姝e父",
                                             S_ITEM_NAME = "鐗╂枡",
                                             S_CKPZKJND = a.CKPZND,
                                             F_ACC_B_QTY = 0,
@@ -1146,9 +1247,6 @@
                             }
                         }
                     }
-
-
-
                     result.resultMsg = "鎴愬姛";
                     result.WLPZBH = itemwlpz.HEAD.WLPZH;
                     result.WLPZND = itemwlpz.HEAD.ND;
@@ -1161,7 +1259,6 @@
             catch (Exception e)
             {
                 var result = new SimpleResult();
-
                 result.resultMsg = "澶辫触";
                 result.WLPZBH = "";
                 result.WLPZND = "0";
@@ -1697,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 = "",
@@ -1735,6 +1832,7 @@
                     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();
@@ -1745,7 +1843,7 @@
                     return result;
 
                 }
-                po.S_OUT_TYPE = "鎴愭湰涓績鍑哄簱";
+               
                 //鏍规嵁涓嶅悓鍑哄簱绫诲瀷 鍥炶皟sap
                 if (po.S_OUT_TYPE == "鍐查攢鍑哄簱")
                 {
@@ -1785,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>();
@@ -1797,8 +1896,8 @@
                         if (cntr.Count() > 0)
                         {
                             db.BeginTran();
-                            //1.鏌ョ湅鏄惁鏈夌浉鍚岀墿鏂欐壒娆$殑淇℃伅锛屽鏋滄湁瑕佺疮鍑忓皯锛屼笉鍚屾壒娆$殑鍙互鍒嗗紑
-                            var cir = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code && a.S_ITEM_CODE == item.item_code && a.N_BS_ROW_NO == item.N_ROW_NO).First();//&& a.S_BATCH_NO == item.S_BATCH_NO
+                            //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;
@@ -1923,21 +2022,36 @@
                     //鍥炲弬鐗╂枡淇℃伅
                     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.WLBH = item.item_code;
+                        ckbitem.KEY = arrival_no;
 
-                        ckbitem.SL = item.qty;
                         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.S_CREATOR_NAME;
-                        ckbitem.PZRQ = DateTime.Now.ToString();
+                        ckbitem.GZRY = po.UNAME;
 
-                        ckbitem.KCDD = podetail?.S_KCDD;
                         ckbitem.PC = podetail?.S_BATCH_NO;
+                        ckbitem.PZRQ = PZZDRQ;
+                        ckbitem.GZRQ = GZRQ;
+
 
 
                         CBcenterBackDto.ITEM listitem1 = new CBcenterBackDto.ITEM();
@@ -1947,7 +2061,7 @@
                         //                .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(',');
+                       // string[] xlhValues = item.S_SERIAL_NO.Split(',');
                         listitem1.XLH= podetail?.S_SERIAL_NO.Split(',').ToList();
                         //foreach (var xlhValue in xlhValues)
                         //{
@@ -2001,16 +2115,20 @@
                     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;
-                    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.ROOT.ITEM.MSGCODE == 0)
+                    {
+                        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();
@@ -2018,7 +2136,7 @@
                 catch (Exception ex)
                 {
                     db.RollbackTran();
-                    LogHelper.Info("璁″垝澶栭�鏂欏洖璋冩姤閿� + ex.Message);
+                    LogHelper.Info("鎴愭湰涓績鍥炶皟鎶ラ敊" + ex.Message);
                     Console.WriteLine(ex.Message);
 
                     throw;
@@ -2144,7 +2262,7 @@
                     //json杞瑇ml
                     string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml;
 
-                    LogHelper.Info($"鍑鸿鍒掑鍙戞枡鍑哄簱xml鏁版嵁{xml}");
+                    LogHelper.Info($"璁″垝澶栧彂鏂欏嚭搴搙ml鏁版嵁{xml}");
                     // 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml"
                     //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml");
                     //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData";
@@ -2181,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();
@@ -2226,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();
                     //鏍规嵁鍏ュ簱鏌ョ湅鍑瘉缂栧彿淇℃伅
@@ -2235,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();
@@ -2533,7 +2695,10 @@
 
                 try
                 {
-
+                    if (MaterList.Count()<1)
+                    {
+                        throw new Exception("绱鐮佺洏鏁伴噺鐗╂枡鏁版嵁涓虹┖");
+                    }
                     foreach (var item in MaterList)
                     {
                         var allInfolist = db.Queryable<TN_Inbound_Detail>()
@@ -2570,8 +2735,8 @@
                                     }
                                     else
                                     {
-                                        //2.鎻掑叆鏂扮殑瀹瑰櫒鐗╂枡淇℃伅锛堝鍣ㄥ彿涓嶅彉锛�-                                        cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_BATCH_NO = item.S_BATCH_NO, S_SERIAL_NO = item.S_SERIAL_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 };
+                                        //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 };
                                         db.Insertable<CntrItemRel>(cir).ExecuteCommand();
                                     }
                                     var count = db.Queryable<CntrItemRel>().Count(a => a.S_CNTR_CODE == cntr.S_CODE);
@@ -2900,7 +3065,7 @@
                     else
                     {
                         //var az = db.Queryable<AZInventory>().ToList();
-                        var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(), S_FACTORY = po.S_FACTORY, 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)
@@ -2914,8 +3079,10 @@
                                         S_DO_NO = po1.S_NO,
                                         S_AREA_CODE = "HJQ",
                                         N_ROW_NO = a.N_ROW_NO,
+                                        S_KCDD = a.S_KCDD,
                                         S_ITEM_CODE = a.S_ITEM_CODE,
                                         S_ITEM_NAME = a.S_ITEM_NAME,
+                                        S_UOM = a.S_UOM,
                                         F_QTY = a.F_QTY - a.F_ACC_D_QTY,
                                         S_BATCH_NO = a.S_BATCH_NO,
                                         S_SERIAL_NO = a.S_SERIAL_NO,
@@ -3793,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 = "杩囪处浜哄憳濮撳悕"
                                 }
                             }
                         };
@@ -3849,7 +4016,7 @@
                 }
                 catch (Exception ex)
                 {
-                    LogHelper.Info($"鍏ュ簱鍥炶皟鎶ラ敊{ex.Message}");
+                    LogHelper.Info($"鍐查攢鍥炲簱鍥炶皟鎶ラ敊{ex.Message}");
                     db.RollbackTran();
                     throw;
                 }

--
Gitblit v1.9.1