18923810322/WMS-Api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调整erp同步接口

Browse Source
This commit is contained in:
18942506660
2023-11-02 15:09:29 +08:00
parent 85c7a13bc2
commit a26e6b89f9
2 changed files with 10 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/WMS.Web.Domain/IService/Public/IErpService.cs
View File

@@ -29,9 +29,7 @@ namespace WMS.Web.Domain.IService.Public
/// </summary>
/// <returns></returns>
Task<ResultList<ErpStockDto>> BillQueryForStock();
//盘盈
Task<Result> TakeStock_Profit(TakeStock entity);
//盘亏
Task<Result> TakeStock_Loss(TakeStock entity);
//同步数据(保存提交审核)
Task<Result> Sync<T>(T dto, string formId);
}
}

59
src/WMS.Web.Domain/Services/Public/ErpService.cs
View File

@@ -254,65 +254,30 @@ namespace WMS.Web.Domain.Services.Public
}
}
/// <summary>
/// 盘盈
/// 同步数据(保存提交审核)
/// </summary>
/// <param name="entity"></param>
/// <param name="dto"></param>
/// <param name="formId"></param>
/// <returns></returns>
public async Task<Result> TakeStock_Profit(TakeStock entity)
public async Task<Result> Sync<T>(T dto,string formId)
{
try
{
//获取金蝶仓库仓位编码
var stockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.StockId);
var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.SubStockId);
var res = await this.BillQueryForStock();
var stock = res.Data.FirstOrDefault(f => f.Code == stockCode);//需要根据单点code搜索
var subStock = res.Data.FirstOrDefault(f => f.Code == subStockCode);//需要根据单点code搜索
if (stock == null || subStock == null) return Result.ReFailure(ResultCodes.ErpStockNoData);
//组装dto
#region 组装dto
List<ErpTakeStockDetailsSaveDto> detils = new List<ErpTakeStockDetailsSaveDto>();
detils.Add(new ErpTakeStockDetailsSaveDto()
{
FOwnerid = stock.OrgId.ToString(),
FKeeperId = stock.OrgId.ToString(),
MaterialId = entity.MaterialId.ToString(),
UnitId = entity.UnitId.ToString(),
StockId = stock.Id.ToString(),
SubStockId = subStock.Id.ToString(),
BeforeQty = entity.BeforeQty,
AfterQty = entity.AfterQty,
FinalQty = entity.FinalQty,
Fnote = ""
});
ErpTakeStockSaveDto dto = new ErpTakeStockSaveDto()
{
BillNo = entity.BillNo,
StockOrgId = stock.OrgId.ToString(),
Type = "PY01_SYS",
Date = entity.Date,
Details = detils
};
#endregion
var token_result = await this.Init();
if (!token_result.IsSuccess)
return token_result;
var query = new ErpBillQueryDto(token_result.Data);
var param = new ErpSave<ErpTakeStockSaveDto>(FormIdParam.STK_StockCountGain.ToString(), dto);
var param = new ErpSave<T>(formId, dto);
query.Data = JsonConvert.SerializeObject(param);
//保存
var result_json = await _client.SaveAsync(JsonConvert.SerializeObject(query));
//提交
var sparam = new ErpSubmitDto(FormIdParam.STK_StockCountGain.ToString(), "");
var sparam = new ErpSubmitDto(formId, "");
query.Data = JsonConvert.SerializeObject(sparam);
result_json = await _client.SubmitAsync(JsonConvert.SerializeObject(query));
//审核
result_json = await _client.AuditAsync(JsonConvert.SerializeObject(query));
return Result.ReSuccess();
}
@@ -321,14 +286,6 @@ namespace WMS.Web.Domain.Services.Public
return Result.ReFailure("错误", 10002);
}
}
/// <summary>
/// 盘亏
/// </summary>
/// <param name="entity"></param>
/// <returns></returns>
public async Task<Result> TakeStock_Loss(TakeStock entity)
{
return Result.ReSuccess();
}
}
}