编写接收SAP下发入库单接口

wxw

2 天以前 22428c74e4b57c87a979a8f2f199e0e8e34dbb86

 Wms/Wms/Controllers/UpApiController.cs

@@ -28,6 +28,8 @@
using WMS.IBLL;
using ZXing.QrCode.Internal;
using System.Xml.Linq;
using WMS.IBLL.ISysServer;
using ZXing;

namespace Wms.Controllers
{
@@ -45,11 +47,14 @@
        private readonly IStockCheckServer _stockCheckSvc;//盘点单Svc 
        private readonly IProcurePlanServer _procurePlanSvc;//采购单Svs
        private readonly IPdaAsnServer _pdaAsnServer;// PDA
        private readonly IMaterialsServer _materialSvc;//物料Svc 
        private readonly ICustomerServer _customerSvc;//客户Svc 
        private readonly IHttpServer _http;


        private string logStr = $@".\log\SAP赋码\Sap下发报文" + DateTime.Now.ToString("yyyyMMdd") + ".txt";

        public UpApiController(IOptions<ApiUrlConfig> setting, IExportNoticeServer exNoticeSvc, IArrivalNoticeServer arrivalNoticeServer, IStockCheckServer stockCheckSvc, IProcurePlanServer procurePlanSvc, IPdaAsnServer pdaAsnServer, IHttpServer http)
        public UpApiController(IOptions<ApiUrlConfig> setting, IExportNoticeServer exNoticeSvc, IArrivalNoticeServer arrivalNoticeServer, IStockCheckServer stockCheckSvc, IProcurePlanServer procurePlanSvc, IPdaAsnServer pdaAsnServer, IMaterialsServer materialSvc, ICustomerServer customerSvc, IHttpServer http)
        {
            _config = setting.Value;
            _exNoticeSvc = exNoticeSvc;
@@ -57,6 +62,8 @@
            _stockCheckSvc = stockCheckSvc;
            _procurePlanSvc = procurePlanSvc;
            _pdaAsnServer = pdaAsnServer;
            _materialSvc = materialSvc;
            _customerSvc = customerSvc;
            _http = http;
        }
        #endregion
@@ -69,11 +76,23 @@
        /// <returns></returns>
        [AllowAnonymous]
        [HttpPost]
        public IActionResult CreateSku(object model)
        public async Task<IActionResult> CreateSku(SapSkuInfoVm model)
        {
            var logStr = $@".\log\SAP\物料主数据下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
            try
            {
                LogFile.SaveLogToFile($"Sap物料主数据：( {model} ),", logStr);
                var jsonData = JsonConvert.SerializeObject(model);
                LogFile.SaveLogToFile($"Sap物料主数据：( {jsonData} ),", logStr);;

                var str = await _materialSvc.AddSkuSap(model.data);

                var list = new { Success = 0, Message = "下发成功" };
                if (!str.Contains("0"))
                {
                    list = new { Success = -1, Message = str };
                }

                LogFile.SaveLogToFile($"SAP物料主数据下发：( {JsonConvert.SerializeObject(list)} ),", logStr);
                return Ok(new { result = true, code = "1" ,message = "success" });
            }
            catch (Exception e)
@@ -90,13 +109,30 @@
        /// <returns></returns>
        [AllowAnonymous]
        [HttpPost]
        public IActionResult CreateCustomer(object model)
        public async Task<IActionResult> CreateCustomer(SapCustomerVm model)
        {
             
            var logStr = $@".\log\SAP\客户供应商主数据同步" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
            try
            {
                LogFile.SaveLogToFile($"Sap客户信息主数据：( {model} ),", logStr);
                return Ok(new { result = true, code = "1", message = "success" });
                var jsonData = JsonConvert.SerializeObject(model);
                LogFile.SaveLogToFile($"Sap客户信息主数据：( {jsonData} ),", logStr);

                var str = await _customerSvc.AddCustomerSap(model.data);

                var list = new { Success = 0, Message = "下发成功" };
                if (!str.Contains("0"))
                {
                    list = new { Success = -1, Message = str };

                    LogFile.SaveLogToFile($"客户供应商主数据同步：( {JsonConvert.SerializeObject(list)} ),", logStr);
                    return Ok(new { result = false, code = "400", message = str });
                }
                else
                {
                    LogFile.SaveLogToFile($"客户供应商主数据同步：( {JsonConvert.SerializeObject(list)} ),", logStr);

                    return Ok(new { result = true, code = "1", message = "success" });
                }                
            }
            catch (Exception e)
            {
@@ -112,13 +148,29 @@
        /// <returns></returns>
        [AllowAnonymous]
        [HttpPost]
        public IActionResult CreateAsn(object model)
        public IActionResult CreateAsn(SapAsnVm model)
        {

            var logStr = $@".\log\SAP\入库单下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
            try
            {
                LogFile.SaveLogToFile($"Sap入库单下发：( {model} ),", logStr);
                return Ok(new { result = true, code = "1", message = "success" });
                var jsonData = JsonConvert.SerializeObject(model);
                LogFile.SaveLogToFile($"Sap入库单下发：( {jsonData} ),", logStr);

                var _result = _arrivalNoticeSvc.CreateAsn(model.data, model.@operator);

                var list = new { Success = 0, Message = "下发成功" };
                if (_result.Success == 0)
                {
                    LogFile.SaveLogToFile($"客户供应商主数据同步：( {JsonConvert.SerializeObject(list)} ),", logStr);
                    return Ok(new { result = true, code = "1", message = "success" });
                }
                else
                {
                    list = new { Success = -1, Message = _result.Message };

                    LogFile.SaveLogToFile($"客户供应商主数据同步：( {JsonConvert.SerializeObject(list)} ),", logStr);
                    return Ok(new { result = false, code = "400", message = _result.Message });
                }                
            }
            catch (Exception e)
            {