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

调整盘点不同步金蝶

Browse Source
This commit is contained in:
18942506660
2024-01-05 10:23:38 +08:00
parent 760677dbbf
commit 85ee8bd112
2 changed files with 27 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/WMS.Web.Domain/Entitys/TakeStock.cs
View File

@@ -39,7 +39,7 @@ namespace WMS.Web.Domain.Entitys
/// 同步状态 /// 同步状态
/// </summary> /// </summary>
[Column("SuccessSync")] [Column("SuccessSync")]
public SyncStatus SuccessSync { get; set; } = SyncStatus.SyncIng; public SyncStatus SuccessSync { get; set; } = SyncStatus.Success;
/// <summary> /// <summary>
/// 盘点结果类型：1为盘盈，2位盘亏 /// 盘点结果类型：1为盘盈，2位盘亏
/// 盘点数量-系统库存 大于0为盘盈 小于0为盘亏 /// 盘点数量-系统库存 大于0为盘盈 小于0为盘亏

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

@@ -146,10 +146,10 @@ namespace WMS.Web.Domain.Services
if (!isSuccess) if (!isSuccess)
return Result.ReFailure(ResultCodes.DateWriteError); return Result.ReFailure(ResultCodes.DateWriteError);
//同步金蝶 ////同步金蝶
OperateRequest oRequest = new OperateRequest(); //OperateRequest oRequest = new OperateRequest();
oRequest.Ids = list.Select(s => s.Id).ToList(); //oRequest.Ids = list.Select(s => s.Id).ToList();
await Sync(oRequest, false); //await Sync(oRequest, false);
return Result.ReSuccess(); return Result.ReSuccess();
} }
@@ -161,27 +161,28 @@ namespace WMS.Web.Domain.Services
/// <returns></returns> /// <returns></returns>
public Task<Result> Sync(OperateRequest dto, bool isRepeatSync = true) public Task<Result> Sync(OperateRequest dto, bool isRepeatSync = true)
{ {
var list = _takeStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult(); return Task.FromResult(Result.ReSuccess());
var isSuccess = true; //var list = _takeStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult();
if (isRepeatSync) //var isSuccess = true;
{ //if (isRepeatSync)
list = list.Where(w => w.SuccessSync == SyncStatus.Fail).ToList(); //{
list.ForEach(f => f.RepeatSync()); // list = list.Where(w => w.SuccessSync == SyncStatus.Fail).ToList();
isSuccess = _takeStockRepositories.EditEntityList(list, true).GetAwaiter().GetResult(); // list.ForEach(f => f.RepeatSync());
} // isSuccess = _takeStockRepositories.EditEntityList(list, true).GetAwaiter().GetResult();
Task.Run(async () => //}
{ //Task.Run(async () =>
foreach (var entity in list) // {
{ // foreach (var entity in list)
var res = await Loss_Profit(entity); // {
if (!res.IsSuccess) // var res = await Loss_Profit(entity);
_logger.LogError($"盘点同步失败:{res.Message}"); // if (!res.IsSuccess)
} // _logger.LogError($"盘点同步失败:{res.Message}");
}); // }
if (isSuccess) // });
return Task.FromResult(Result.ReSuccess()); //if (isSuccess)
else // return Task.FromResult(Result.ReSuccess());
return Task.FromResult(Result.ReFailure(ResultCodes.DateWriteError)); //else
// return Task.FromResult(Result.ReFailure(ResultCodes.DateWriteError));
} }
/// <summary> /// <summary>