blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
hudong
2025-05-12 0e2425d59ffe4c698182f134a47dc84585bc8439 
 api/WmsSpaHelper.cs


@@ -33,6 +33,7 @@


using WHTest;


using System.Net;


using SqlSugar;


using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto;




namespace HH.WCS.Mobox3.pinggao.api


{


@@ -654,6 +655,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>


        /// <param name="model"></param>


@@ -706,7 +788,7 @@


                        iTEM.SCDDH = item.SCDDH;


                        iTEM.GC = item.GC;


                        iTEM.MSGCODE = "1";


                        iTEM.MSGDESP = $"{item.SCDDH}不存在";


                        iTEM.MSGDESP = $"{item.SCDDH}已存在";


                        tEMs.Add(iTEM);


                    }


                    iTEM.SCDDH = item.SCDDH;


@@ -1733,6 +1815,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();


@@ -1743,7 +1826,6 @@


                    return result;




                }




                //根据不同出库类型 回调sap


                if (po.S_OUT_TYPE == "冲销出库")


                {


@@ -1921,35 +2003,52 @@


                    //回参物料信息


                    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.WLBH = item.item_code;




                        ckbitem.SL = item.qty;


                        ckbitem.CBZX = po.S_CBZX;


                        ckbitem.SL = item.qty;




                        ckbitem.KCDD = podetail?.S_KCDD;


                        ckbitem.ZZKM = po.S_ZZKM;


                        ckbitem.GC = po.S_FACTORY;


                        ckbitem.GZRY = po.S_CREATOR_NAME;


                        ckbitem.PZRQ = DateTime.Now.ToString();




                        ckbitem.KCDD = podetail?.S_KCDD;


                        ckbitem.PC = podetail?.S_BATCH_NO;


                        ckbitem.PZRQ = PZZDRQ;


                        ckbitem.GZRQ = GZRQ;






                        List<CBcenterBackDto.ITEM> listitem1 = new List<CBcenterBackDto.ITEM>();




                        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(',');


                        foreach (var xlhValue in xlhValues)


                        {


                            CBcenterBackDto.ITEM newItem = new CBcenterBackDto.ITEM { XLH = xlhValue };


                            listitem1.Add(newItem);


                        }


                       // 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);




@@ -1964,33 +2063,53 @@


                    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();


                    //// 创建 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代理类实例


                    ZSCM2_CBZX service = new ZSCM2_CBZX();


                    //  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);




                    // 解析Output中的凭证号等信息




                    #endregion


                    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());




                    //添加凭证记录表


                    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();


@@ -1998,7 +2117,7 @@


                catch (Exception ex)


                {


                    db.RollbackTran();


                    LogHelper.Info("计划外退料回调报错" + ex.Message);


                    LogHelper.Info("成本中心回调报错" + ex.Message);


                    Console.WriteLine(ex.Message);




                    throw;


@@ -2050,14 +2169,7 @@


                        {


                            HEAD = new JHWBackDto.HEAD


                            {


                                //KEY = "KeyExample",


                                //GZRQ = "2023-04-01",


                                //PZZDRQ = "2023-04-02",


                                //YHM = "Username",


                                //PZTTWB = "HeaderText",


                                //YDLX = "MovementType",


                                //TSKCBS = "SpecialStock"




                              


                                KEY = po.S_NO,


                                GZRQ = GZRQ,


                                PZZDRQ = PZZDRQ,


@@ -2082,9 +2194,7 @@


                        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;


@@ -2095,7 +2205,6 @@


                        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


@@ -2136,20 +2245,36 @@




                    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();


                    //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代理类实例


                    ZSCM2_SCFLJHW service = new ZSCM2_SCFLJHW();


                    //  service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234");


                    // 准备请求参数


                    ZscmScflJhw request = new ZscmScflJhw();


                    request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml;


                    LogHelper.Info($"计划外SAP回调");


                    // 调用Web Service


                    ZscmScflJhwResponse responses = service.ZscmScflJhw(request);




                    // 处理响应


                    LogHelper.Info("SAP返回结果: " + responses.Output);




                    // 解析Output中的凭证号等信息




                    #endregion




                    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());


                    //添加凭证记录表


@@ -2391,18 +2516,18 @@


                        ckbitem.GC = po.S_FACTORY;


                        ckbitem.KCDD = podetail?.S_KCDD;




                        List<CkBcakDto.ITEM1> listitem1 = new List<CkBcakDto.ITEM1>();


                        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));


                        string[] xlhValues = item.S_SERIAL_NO.Split(',');


                        foreach (var xlhValue in xlhValues)


                        {


                            CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue };


                            listitem1.Add(newItem);


                        }


                        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);




@@ -2544,8 +2669,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_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);


@@ -3531,15 +3656,13 @@


                            JHWBackDto.ITEM ckbitem = new JHWBackDto.ITEM();


                            ckbitem.WLBH = item.S_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.F_QTY;


                            ckbitem.DW = podetail?.S_UOM;


                            ckbitem.DDH = podetail?.S_DDH;


                            //ckbitem.PH = podetail?.S_PH;


                            // ckbitem.TSKCBS = podetail?.S_TSKCBS;


                            //ckbitem.DDHXM = (podetail?.N_ROW_NO);


                            ckbitem.WBS = podetail?.S_WBS;


                            ckbitem.KCDD = podetail?.S_KCDD;