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

修复bug

Browse Source
This commit is contained in:
18942506660
2023-12-20 17:31:36 +08:00
parent c71b06ca3a
commit 93c533d86d
2 changed files with 23 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/WMS.Web.Domain/Services/OutStockService.cs
View File

@@ -197,7 +197,9 @@ namespace WMS.Web.Domain.Services
if (entity.Type == OutStockType.Sal) if (entity.Type == OutStockType.Sal)
{ {
await Sync(entity, loginInfo); OperateRequest oRequest = new OperateRequest();
oRequest.Ids.Add(entity.Id);
await Sync(oRequest, loginInfo);
} }
return Result.ReSuccess(); return Result.ReSuccess();
@@ -207,25 +209,19 @@ namespace WMS.Web.Domain.Services
/// </summary> /// </summary>
/// <param name="dto"></param> /// <param name="dto"></param>
/// <returns></returns> /// <returns></returns>
public async Task<Result> Sync(OperateRequest dto, LoginInDto loginInfo) public Task<Result> Sync(OperateRequest dto, LoginInDto loginInfo)
{ {
var list = await _outStockRepositories.GetEntityList(dto.Ids); var list = _outStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult();
foreach (var entity in list) foreach (var entity in list)
{ {
await Sync(entity, loginInfo); Task.Run(async () =>
{
var res = await SalOutStock(entity, loginInfo);
if (!res.IsSuccess)
_logger.LogError($"出库单同步失败:{res.Message}");
});
} }
return Result.ReSuccess(); return Task.FromResult(Result.ReSuccess());
}
private Task Sync(OutStock entity, LoginInDto loginInfo)
{
Task.Run(async () =>
{
var res = await SalOutStock(entity, loginInfo);
if (!res.IsSuccess)
_logger.LogError($"出库单同步失败:{res.Message}");
});
return Task.CompletedTask;
} }
/// <summary> /// <summary>

28
src/WMS.Web.Domain/Services/TakeStockService.cs
View File

@@ -135,10 +135,9 @@ namespace WMS.Web.Domain.Services
return Result.ReFailure(ResultCodes.DateWriteError); return Result.ReFailure(ResultCodes.DateWriteError);
//同步金蝶 //同步金蝶
foreach (var entity in list) OperateRequest oRequest = new OperateRequest();
{ oRequest.Ids = list.Select(s => s.Id).ToList();
await Sync(entity); await Sync(oRequest);
}
return Result.ReSuccess(); return Result.ReSuccess();
} }
@@ -148,27 +147,22 @@ namespace WMS.Web.Domain.Services
/// </summary> /// </summary>
/// <param name="dto"></param> /// <param name="dto"></param>
/// <returns></returns> /// <returns></returns>
public async Task<Result> Sync(OperateRequest dto) public Task<Result> Sync(OperateRequest dto)
{ {
var list = _takeStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult(); var list = _takeStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult();
list = list.Where(w => w.SuccessSync == SyncStatus.Fail || w.SuccessSync == SyncStatus.SyncIng).ToList(); list = list.Where(w => w.SuccessSync == SyncStatus.Fail || w.SuccessSync == SyncStatus.SyncIng).ToList();
foreach (var entity in list) foreach (var entity in list)
{ {
await Sync(entity); Task.Run(async () =>
{
var res = await Loss_Profit(entity);
if (!res.IsSuccess)
_logger.LogError($"盘点同步失败:{res.Message}");
});
} }
return Result.ReSuccess(); return Task.FromResult(Result.ReSuccess());
} }
private Task Sync(TakeStock entity)
{
Task.Run(async () =>
{
var res = await Loss_Profit(entity);
if (!res.IsSuccess)
_logger.LogError($"盘点同步失败:{res.Message}");
});
return Task.CompletedTask;
}
/// <summary> /// <summary>
/// 盘盈盘亏同步金蝶 /// 盘盈盘亏同步金蝶
/// </summary> /// </summary>