using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using Rhea.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel.Design;
|
using System.Linq;
|
using System.Security.Policy;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Tiger.Model;
|
using Tiger.Model.Minsun;
|
using Tiger.IBusiness;
|
|
namespace Tiger.Business
|
{
|
public partial class Biz
|
{
|
public partial class ErpT100
|
{
|
|
/// <summary>
|
/// 从T100获取供应商接口
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public T100ActionResult<resultStd_data<VenderParameterR>> GetVenderInfo(VenderInputParameter input)
|
{
|
var t100Action = new T100Action<actionStd_data<VenderParameter>>
|
{
|
key = Guid.NewGuid().ToString("N"),
|
type = "sync",
|
host = new host
|
{
|
prod = "MES",
|
ip = "",
|
lang = "zh_CN",
|
acct = "tiptop",
|
timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
|
},
|
datakey = input.datakey,
|
service = new Service
|
{
|
ip = "",
|
prod = "T100",
|
id = "topprd",
|
name = "wms_erp_wms_getven"
|
},
|
payload = new PayloadData<actionStd_data<VenderParameter>>
|
{
|
std_data = new actionStd_data<VenderParameter>
|
{
|
parameter = input.parameter
|
}
|
}
|
};
|
var requestJson = JsonConvert.SerializeObject(t100Action);
|
var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
|
var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<VenderParameterR>>>(response.Message);
|
return result;
|
}
|
|
public ApiAction GetVenderInfoToDDL(iVenderParams input)
|
{
|
var action = new ApiAction();
|
try
|
{
|
var t100Res = GetVenderInfo(new VenderInputParameter
|
{
|
parameter = new VenderParameter
|
{
|
site = input.company,
|
startdt = input.startDate,
|
enddt = input.endDate
|
},
|
datakey = new Datakey
|
{
|
EntId = ApiConfig.IsTestServer ? "108" : "88",
|
CompanyId = input.company
|
}
|
});
|
if (t100Res.payload.std_data.execution.code == "0")
|
{
|
var list = t100Res.payload.std_data.parameter.@return;
|
action.Data = list;
|
List<BAS_SUPPLIER> suppliers = new List<BAS_SUPPLIER>();
|
var allList = Db.Queryable<BAS_SUPPLIER>().Where(x => x.AUTH_ORG == input.company).ToList();
|
foreach (var item in list)
|
{
|
var query = allList.Where(x => x.SUPP_CODE == item.pmab001).FirstOrDefault();
|
BAS_SUPPLIER entity = query ?? new BAS_SUPPLIER()
|
{
|
SUPP_CODE = item.pmab001,
|
SUPP_NAME_CN = item.pmaal003,
|
AUTH_ORG = input.company
|
};
|
suppliers.Add(entity);
|
}
|
var db = Business.Biz.Db;
|
//数据库处理操作
|
if (action.IsSuccessed)
|
{
|
action.Message = $"供应商信息同步成功";
|
var dbTran = db.UseTran(() =>
|
{
|
db.Storageable(suppliers,"Interface").ExecuteCommand();
|
|
});
|
if (!dbTran.IsSuccess)
|
{
|
action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
|
}
|
}
|
}
|
else {
|
action.IsSuccessed = false;
|
action.Message = $"T100返回信息错误:{t100Res.payload.std_data.execution.description}";
|
}
|
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"数据处理失败");
|
}
|
return action;
|
}
|
}
|
}
|
}
|
