优化接口

This commit is contained in:
tongfei
2024-04-10 10:01:09 +08:00
parent 618191f245
commit 5e52ec1411
3 changed files with 15 additions and 11 deletions

View File

@@ -25,7 +25,6 @@ namespace WMS.Web.Core.Dto.InStock
/// <summary> /// <summary>
/// 客户编码 /// 客户编码
/// </summary> /// </summary>
[Required(ErrorMessage = "客户编码不能为空")]
public string CustomerCode { get; set; } public string CustomerCode { get; set; }
/// <summary> /// <summary>

View File

@@ -784,6 +784,7 @@ namespace WMS.Web.Domain.Services
{ {
try try
{ {
_logger.LogInformation($"入库单->开始下推 单号:{billNo} erp明细Id:{erpDetail.ErpDetailId} 数据: {JsonConvert.SerializeObject(dto)}");
//下推动作 //下推动作
var res = await sc_erpService.Push(dto); var res = await sc_erpService.Push(dto);
if (!res.IsSuccess) if (!res.IsSuccess)
@@ -795,7 +796,8 @@ namespace WMS.Web.Domain.Services
var resPurchaseInStock = await sc_erpService.BillQueryForPurchaseInStock(id); var resPurchaseInStock = await sc_erpService.BillQueryForPurchaseInStock(id);
var purchaseInStock = resPurchaseInStock.Data; var purchaseInStock = resPurchaseInStock.Data;
purchaseInStock.Details[0].Qty = erpDetail.Qty; purchaseInStock.Details[0].Qty = erpDetail.Qty;
string formId = dto.TargetFormId.ToString();
//批号生成和同步
if (string.IsNullOrEmpty(erpDetail.BatchBillNo)) if (string.IsNullOrEmpty(erpDetail.BatchBillNo))
{ {
var current_erp_material = await sc_erpService.BillQueryForMaterialByNumber(erpDetail.MaterialNumber); var current_erp_material = await sc_erpService.BillQueryForMaterialByNumber(erpDetail.MaterialNumber);
@@ -803,12 +805,13 @@ namespace WMS.Web.Domain.Services
{ {
//1.获取最新的erp明细信息 //1.获取最新的erp明细信息
var billNo_new = await sc_inStockRepositories.GetLastBillNo(); var billNo_new = await sc_inStockRepositories.GetLastBillNo();
//erp明细生成批号 //erp明细最新批号
int new_firstBillNo = billNo_new == null ? 0 : (billNo_new.FirstBillNo.HasValue ? billNo_new.FirstBillNo.Value : 0); int new_firstBillNo = billNo_new == null ? 0 : (billNo_new.FirstBillNo.HasValue ? billNo_new.FirstBillNo.Value : 0);
int new_lastBillNo = billNo_new == null ? 0 : (billNo_new.LastBillNo.HasValue ? billNo_new.LastBillNo.Value : 0); int new_lastBillNo = billNo_new == null ? 0 : (billNo_new.LastBillNo.HasValue ? billNo_new.LastBillNo.Value : 0);
//生成批号
erpDetail.GenerateBatchBillNo(new_firstBillNo, new_lastBillNo, current_erp_material.IsBatchManage); erpDetail.GenerateBatchBillNo(new_firstBillNo, new_lastBillNo, current_erp_material.IsBatchManage);
_logger.LogInformation($"入库单->批号{erpDetail.BatchBillNo}"); //赋值批号
if (!string.IsNullOrEmpty(erpDetail.BatchBillNo)) if (!string.IsNullOrEmpty(erpDetail.BatchBillNo))
{ {
purchaseInStock.Details[0].Lot = new ErpLotSaveDto(); purchaseInStock.Details[0].Lot = new ErpLotSaveDto();
@@ -821,13 +824,12 @@ namespace WMS.Web.Domain.Services
purchaseInStock.Details[0].Lot = new ErpLotSaveDto(); purchaseInStock.Details[0].Lot = new ErpLotSaveDto();
purchaseInStock.Details[0].Lot.Number = erpDetail.BatchBillNo; purchaseInStock.Details[0].Lot.Number = erpDetail.BatchBillNo;
} }
string formId = dto.TargetFormId.ToString(); _logger.LogInformation($"入库单->下推成功 开始保存 单号:{billNo} erp明细Id:{erpDetail.ErpDetailId} 数据: {JsonConvert.SerializeObject(purchaseInStock)}");
_logger.LogInformation($"入库单->开始同步金蝶 单号:{billNo} erp明细Id:{erpDetail.ErpDetailId} 数据: {JsonConvert.SerializeObject(dto)}");
var res_s = await sc_erpService.Save<ErpPurchaseInStockSaveDto>(purchaseInStock, formId); var res_s = await sc_erpService.Save<ErpPurchaseInStockSaveDto>(purchaseInStock, formId);
if (!res_s.IsSuccess) if (!res_s.IsSuccess)
{ {
_logger.LogInformation($"入库单->修改数量失败 单号:{billNo} erp明细Id:{erpDetail.ErpDetailId} 错误:{res_s.Message}"); _logger.LogInformation($"入库单->保存失败 单号:{billNo} erp明细Id:{erpDetail.ErpDetailId} 错误:{res_s.Message}");
return (Result.ReFailure(res_s.Message, res_s.Status), SyncStatus.SubmitFail, id); return (Result.ReFailure(res_s.Message, res_s.Status), SyncStatus.SubmitFail, id);
} }
//提交 //提交

View File

@@ -1565,11 +1565,12 @@ namespace WMS.Web.Domain.Services.Public
var query = new ErpBillQueryDto(token_result.Data, formId); var query = new ErpBillQueryDto(token_result.Data, formId);
var param = new ErpSave<T>(formId, dto); var param = new ErpSave<T>(formId, dto);
query.Data = JsonConvert.SerializeObject(param); query.Data = JsonConvert.SerializeObject(param);
_logger.LogInformation("同步数据保存:测试" + JsonConvert.SerializeObject(query));
//保存 //保存
var result_json = await _client.SaveAsync(JsonConvert.SerializeObject(query)); var result_json = await _client.SaveAsync(JsonConvert.SerializeObject(query));
_logger.LogInformation("入库单->开始同步金蝶:保存参数" + JsonConvert.SerializeObject(query)+" 结果->"+ result_json);
JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json); JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true") if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
@@ -1605,6 +1606,7 @@ namespace WMS.Web.Domain.Services.Public
//提交 //提交
query.Data = JsonConvert.SerializeObject(dto); query.Data = JsonConvert.SerializeObject(dto);
var result_json = await _client.SubmitAsync(JsonConvert.SerializeObject(query)); var result_json = await _client.SubmitAsync(JsonConvert.SerializeObject(query));
_logger.LogInformation("入库单->开始同步金蝶:提交参数" + JsonConvert.SerializeObject(query) + " 结果->" + result_json);
JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json); JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true") if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
@@ -1636,6 +1638,7 @@ namespace WMS.Web.Domain.Services.Public
//提交 //提交
query.Data = JsonConvert.SerializeObject(dto); query.Data = JsonConvert.SerializeObject(dto);
var result_json = await _client.AuditAsync(JsonConvert.SerializeObject(query)); var result_json = await _client.AuditAsync(JsonConvert.SerializeObject(query));
_logger.LogInformation("入库单->开始同步金蝶:审核参数" + JsonConvert.SerializeObject(query) + " 结果->" + result_json);
JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json); JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true") if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
@@ -1730,7 +1733,7 @@ namespace WMS.Web.Domain.Services.Public
//下推 //下推
string json = JsonConvert.SerializeObject(query); string json = JsonConvert.SerializeObject(query);
var result_json = await _client.PushAsync(json); var result_json = await _client.PushAsync(json);
_logger.LogInformation("入库单->开始同步金蝶:提交参数" + json + " 结果->" + result_json);
JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json); JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower(); var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();