using Microsoft.Extensions.Logging;
|
using NetTaste;
|
using Newtonsoft.Json;
|
using Org.BouncyCastle.Ocsp;
|
using SqlSugar.Extensions;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection.Emit;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_DTO.Basic;
|
using WIDESEA_IBasicService;
|
using WIDESEA_Model.Models;
|
using WIDESEA_Model.Models.Basic;
|
|
namespace WIDESEA_BasicService
|
{
|
public class ErpApiService : IErpApiService
|
{
|
private readonly IHttpClientFactory _httpClientFactory;
|
private readonly ISupplierInfoService _supplierInfoService;
|
private readonly IMaterialUnitService _materialUnitService;
|
private readonly IMaterielInfoService _materielInfoService;
|
private readonly ILogger<ErpApiService> _logger;
|
|
public ErpApiService(IHttpClientFactory httpClientFactory, ISupplierInfoService supplierInfoService, IMaterialUnitService materialUnitService, IMaterielInfoService materielInfoService, ILogger<ErpApiService> logger)
|
{
|
_httpClientFactory = httpClientFactory;
|
_supplierInfoService = supplierInfoService;
|
_materialUnitService = materialUnitService;
|
_materielInfoService = materielInfoService;
|
_logger = logger;
|
}
|
|
/// <summary>
|
/// 获取token
|
/// </summary>
|
/// <returns></returns>
|
public async Task<string> GetTokenAsync()
|
{
|
try
|
{
|
//erp 测试环境
|
//var request = new TokenRequest { appId = "BG_SYSTEM", secretKey = "7e9239c1e132462a9cf03bfa342a044aMTcxODE5MzgxODI4Mw" };
|
////erp 正式环境
|
var request = new TokenRequest { appId = "BG_SYSTEM", secretKey = "9a3d0b5a37Bfc6dAM4b34ODb8ebDOSb937106d1b19DS29098" };
|
var response = await PostAsync<TokenRequest, TokenResponse>("auth/getAccessToken", request, includeToken: false);
|
var _token = response?.data?.access_token;
|
return _token ?? "";
|
|
}
|
catch (Exception ex)
|
{
|
_logger.LogInformation("ErpApiService GetTokenAsync失败: " + ex.Message);
|
return "";
|
}
|
|
}
|
|
/// <summary>
|
/// 获取供应商信息
|
/// </summary>
|
/// <param name="vendorCode"></param>
|
/// <returns></returns>
|
public async Task GetSuppliersAsync(string vendorCode = null)
|
{
|
try
|
{
|
var req = new SupplierRequest { vendorCode = vendorCode };
|
var result = await PostAsync<SupplierRequest, SupplierResponse>("erp/getVendorInfo", req, includeToken: true);
|
if (result != null && result.data != null && result.data.Any())
|
{
|
var dblists = _supplierInfoService.Repository.QueryData();
|
var excepts = dblists.Select(O => O.SupplierCode).Except(result.data.Select(o => o.vendorCode));
|
foreach (var except in excepts)
|
{
|
var first = dblists.FirstOrDefault(o => o.SupplierCode == except);
|
if (first != null)
|
{
|
_supplierInfoService.Repository.DeleteData(first);
|
}
|
}
|
foreach (var item in result.data)
|
{
|
var first = dblists.FirstOrDefault(o => o.SupplierCode == item.vendorCode);
|
if (first != null)
|
{
|
first.SupplierCode = item.vendorCode;
|
first.SupplierName = item.vendorName;
|
first.SupplierShortName = item.vendorShortName;
|
first.Status = item.effective.ObjToInt();
|
first.CreateDate = item.createDate.ObjToDate();
|
first.ModifyDate = item.modifyDate.ObjToDate();
|
_supplierInfoService.Repository.UpdateData(first);
|
}
|
else
|
{
|
Dt_SupplierInfo dt_SupplierInfo = new()
|
{
|
SupplierCode = item.vendorCode,
|
SupplierName = item.vendorName,
|
SupplierShortName = item.vendorShortName,
|
Status = item.effective.ObjToInt(),
|
CreateDate = item.createDate.ObjToDate(),
|
Creater = "ERP",
|
Modifier = "ERP",
|
ModifyDate = item.modifyDate.ObjToDate()
|
};
|
_supplierInfoService.Repository.AddData(dt_SupplierInfo);
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
_logger.LogInformation("ErpApiService GetSuppliersAsync失败: " + ex.Message);
|
|
}
|
|
}
|
|
/// <summary>
|
/// 获取物料单位转换
|
/// </summary>
|
/// <param name="vendorCode"></param>
|
/// <returns></returns>
|
public async Task GetMaterialUnitAsync(string itemNo = null)
|
{
|
try
|
{
|
var req = new MaterialUnitRequest { itemNo = itemNo };
|
var result = await PostAsync<MaterialUnitRequest, MaterialUnitResponse>("erp/getMaterialUnit", req, true);
|
if (result != null && result.data != null && result.data.Any())
|
{
|
var dblists = _materialUnitService.Repository.QueryData();
|
var excepts = dblists.Select(O => O.ItemNo).Except(result.data.Select(o => o.itemNo));
|
foreach (var except in excepts)
|
{
|
var first = dblists.FirstOrDefault(o => o.ItemNo == except);
|
if (first != null)
|
{
|
_materialUnitService.Repository.DeleteData(first);
|
}
|
}
|
foreach (var item in result.data)
|
{
|
var first = dblists.FirstOrDefault(o => o.ItemNo == item.itemNo);
|
if (first != null)
|
{
|
first.ItemNo = item.itemNo;
|
first.ProductName = item.productName;
|
first.FromUom = item.fromUom;
|
first.ToUom = item.toUom;
|
first.Ratio = item.ratio.ObjToDecimal();
|
first.Creater = "ERP";
|
first.Modifier = "ERP";
|
first.CreateDate = item.createDate.ObjToDate();
|
first.ModifyDate = item.modifyDate.ObjToDate();
|
_materialUnitService.Repository.UpdateData(first);
|
}
|
else
|
{
|
Dt_MaterialUnit dt_MaterialUnit = new()
|
{
|
ItemNo = item.itemNo,
|
ProductName = item.productName,
|
FromUom = item.fromUom,
|
ToUom = item.toUom,
|
Ratio = item.ratio.ObjToDecimal(),
|
CreateDate = item.createDate.ObjToDate(),
|
Creater = "ERP",
|
Modifier = "ERP",
|
ModifyDate = item.modifyDate.ObjToDate()
|
};
|
_materialUnitService.Repository.AddData(dt_MaterialUnit);
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
_logger.LogInformation("ErpApiService GetMaterialUnitAsync 失败: " + ex.Message);
|
|
}
|
|
}
|
public async Task GetMaterialInfoAsync(MaterialRequest materialRequest)
|
{
|
try
|
{
|
var first = WIDESEA_Core.Helper.AppSettings.GetValue("FirstMaterialSync").ObjToBool();
|
if (first)
|
{
|
var _token = await GetTokenAsync();
|
for (int i = 1; i < 400; i++)
|
{
|
materialRequest.pageNum = i;
|
materialRequest.pageSize = 5000;
|
var result = await PostAsync<MaterialRequest, MaterialResponse>("erp/getMaterialInfo", materialRequest, _token, true);
|
if (result != null && result.data != null && result.data.Any())
|
{
|
foreach (var item in result.data)
|
{
|
Dt_MaterielInfo dt_MaterielInfo = new Dt_MaterielInfo()
|
{
|
MaterielModel = item.productModel,
|
MaterielCode = item.itemNo,
|
MaterielName = item.productName,
|
MaterielSpec = item.spec,
|
productTypeDesc = item.productTypeDesc,
|
productFamilyName = item.productFamilyName,
|
productFamilyShortName = item.productFamilyShortName,
|
plcode = item.plcode,
|
pl = item.pl,
|
drawingNo = item.drawingNo,
|
mversion = item.mversion,
|
warehouseName = item.warehouseName,
|
usageUOM = item.usageUOM,
|
purchaseUOM = item.purchaseUOM,
|
inventoryUOM = item.inventoryUOM,
|
CreateDate = item.createDate.ObjToDate(),
|
ModifyDate = item.modifyDate.ObjToDate(),
|
};
|
_materielInfoService.Repository.AddData(dt_MaterielInfo);
|
}
|
}
|
}
|
}
|
else
|
{
|
//materialRequest.modifyDateStart = DateTime.Now.AddDays(-1).Date.ToString("yyyy-MM-dd") + " 00:00:01";
|
//materialRequest.modifyDateEnd = DateTime.Now.ToString("yyyy-MM-dd HH:mm") + ":01";
|
//materialRequest.pageNum = 1;
|
//materialRequest.pageSize = 5000;
|
|
var result = await PostAsync<MaterialRequest, MaterialResponse>("erp/getMaterialInfo", materialRequest, true, true);
|
if (result != null && result.data != null && result.data.Any())
|
{
|
foreach (var item in result.data)
|
{
|
var dbfirst = _materielInfoService.Repository.QueryData(x => x.MaterielModel == item.productModel && x.MaterielCode == item.itemNo).FirstOrDefault();
|
if (dbfirst != null)
|
{
|
dbfirst.MaterielModel = item.productModel;
|
dbfirst.MaterielCode = item.itemNo;
|
dbfirst.MaterielName = item.productName;
|
dbfirst.MaterielSpec = item.spec;
|
dbfirst.productTypeDesc = item.productTypeDesc;
|
dbfirst.productFamilyName = item.productFamilyName;
|
dbfirst.productFamilyShortName = item.productFamilyShortName;
|
dbfirst.plcode = item.plcode;
|
dbfirst.pl = item.pl;
|
dbfirst.drawingNo = item.drawingNo;
|
dbfirst.mversion = item.mversion;
|
dbfirst.warehouseName = item.warehouseName;
|
dbfirst.usageUOM = item.usageUOM;
|
dbfirst.purchaseUOM = item.purchaseUOM;
|
dbfirst.inventoryUOM = item.inventoryUOM;
|
dbfirst.CreateDate = item.createDate.ObjToDate();
|
dbfirst.ModifyDate = item.modifyDate.ObjToDate();
|
_materielInfoService.Repository.UpdateData(dbfirst);
|
}
|
else
|
{
|
Dt_MaterielInfo dt_MaterielInfo = new Dt_MaterielInfo()
|
{
|
MaterielModel = item.productModel,
|
MaterielCode = item.itemNo,
|
MaterielName = item.productName,
|
MaterielSpec = item.spec,
|
productTypeDesc = item.productTypeDesc,
|
productFamilyName = item.productFamilyName,
|
productFamilyShortName = item.productFamilyShortName,
|
plcode = item.plcode,
|
pl = item.pl,
|
drawingNo = item.drawingNo,
|
mversion = item.mversion,
|
warehouseName = item.warehouseName,
|
usageUOM = item.usageUOM,
|
purchaseUOM = item.purchaseUOM,
|
inventoryUOM = item.inventoryUOM,
|
CreateDate = item.createDate.ObjToDate(),
|
ModifyDate = item.modifyDate.ObjToDate(),
|
};
|
_materielInfoService.Repository.AddData(dt_MaterielInfo);
|
}
|
|
}
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
_logger.LogInformation("ErpApiService GetMaterialInfoAsync 失败: " + ex.Message);
|
|
}
|
}
|
|
private async Task<TResponse> PostAsync<TRequest, TResponse>(string url, TRequest request, string _token, bool isNullSerialize = false)
|
{
|
var json = "";
|
if (isNullSerialize)
|
{
|
json = JsonConvert.SerializeObject(request, new JsonSerializerSettings
|
{
|
DefaultValueHandling = DefaultValueHandling.Ignore,
|
ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
|
});
|
}
|
else
|
{
|
json = JsonConvert.SerializeObject(request);
|
}
|
|
var content = new StringContent(json, Encoding.UTF8, "application/json");
|
var _client = _httpClientFactory.CreateClient("ERPUrl");
|
_client.DefaultRequestHeaders.Clear();
|
|
|
string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
string base64Header = Convert.ToBase64String(Encoding.UTF8.GetBytes(timestamp));
|
_client.DefaultRequestHeaders.Add("X-Custom-Header", base64Header);
|
|
_client.DefaultRequestHeaders.Add("ACCESS-TOKEN", _token);
|
|
_client.DefaultRequestHeaders.Add("Accept", "application/json");
|
|
using var response = await _client.PostAsync(url, content);
|
string body = await response.Content.ReadAsStringAsync();
|
|
if (!response.IsSuccessStatusCode)
|
{
|
throw new HttpRequestException(body);
|
}
|
|
return JsonConvert.DeserializeObject<TResponse>(body);
|
}
|
|
private async Task<TResponse> PostAsync<TRequest, TResponse>(string url, TRequest request, bool includeToken = true, bool isNullSerialize = false)
|
{
|
|
var json = "";
|
if (isNullSerialize)
|
{
|
json = JsonConvert.SerializeObject(request, new JsonSerializerSettings
|
{
|
DefaultValueHandling = DefaultValueHandling.Ignore,
|
ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
|
});
|
}
|
else
|
{
|
json = JsonConvert.SerializeObject(request);
|
}
|
|
var content = new StringContent(json, Encoding.UTF8, "application/json");
|
var _client = _httpClientFactory.CreateClient("ERPUrl");
|
_client.DefaultRequestHeaders.Clear();
|
|
|
string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
string base64Header = Convert.ToBase64String(Encoding.UTF8.GetBytes(timestamp));
|
_client.DefaultRequestHeaders.Add("X-Custom-Header", base64Header);
|
|
if (includeToken)
|
{
|
var _token = await GetTokenAsync();
|
_client.DefaultRequestHeaders.Add("ACCESS-TOKEN", _token);
|
}
|
|
|
_client.DefaultRequestHeaders.Add("Accept", "application/json");
|
|
using var response = await _client.PostAsync(url, content);
|
string body = await response.Content.ReadAsStringAsync();
|
|
if (!response.IsSuccessStatusCode)
|
{
|
|
throw new HttpRequestException(body);
|
}
|
|
return JsonConvert.DeserializeObject<TResponse>(body);
|
}
|
}
|
}
|
