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-21 11:13:02 +08:00
parent c51ce14345
commit f698909f9e
2 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -210,17 +210,17 @@ namespace WMS.Web.Domain.Services
/// <param name="dto"></param> /// <param name="dto"></param>
/// <returns></returns> /// <returns></returns>
public Task<Result> Sync(OperateRequest dto, LoginInDto loginInfo) public Task<Result> Sync(OperateRequest dto, LoginInDto loginInfo)
{
Task.Run(async () =>
{ {
var list = _outStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult(); var list = _outStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult();
foreach (var entity in list) foreach (var entity in list)
{
Task.Run(async () =>
{ {
var res = await SalOutStock(entity, loginInfo); var res = await SalOutStock(entity, loginInfo);
if (!res.IsSuccess) if (!res.IsSuccess)
_logger.LogError($"出库单同步失败:{res.Message}"); _logger.LogError($"出库单同步失败:{res.Message}");
});
} }
});
return Task.FromResult(Result.ReSuccess()); return Task.FromResult(Result.ReSuccess());
} }

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

@@ -149,18 +149,19 @@ namespace WMS.Web.Domain.Services
/// <param name="dto"></param> /// <param name="dto"></param>
/// <returns></returns> /// <returns></returns>
public Task<Result> Sync(OperateRequest dto) public Task<Result> Sync(OperateRequest dto)
{
Task.Run(async () =>
{ {
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)
{
Task.Run(async () =>
{ {
var res = await Loss_Profit(entity); var res = await Loss_Profit(entity);
if (!res.IsSuccess) if (!res.IsSuccess)
_logger.LogError($"盘点同步失败:{res.Message}"); _logger.LogError($"盘点同步失败:{res.Message}");
});
} }
});
return Task.FromResult(Result.ReSuccess()); return Task.FromResult(Result.ReSuccess());
} }