修复bug

This commit is contained in:
18942506660
2023-12-20 16:29:32 +08:00
parent dcba2aa380
commit 428257d1e7
8 changed files with 37 additions and 16 deletions

View File

@@ -80,7 +80,7 @@ namespace WMS.Web.Domain.Entitys
/// 同步成功或者失败 默认是失败状态 /// 同步成功或者失败 默认是失败状态
/// </summary> /// </summary>
[Column("SuccessSync")] [Column("SuccessSync")]
public SyncStatus SuccessSync { get; set; } = SyncStatus.Fail; public SyncStatus SuccessSync { get; set; } = SyncStatus.SyncIng;
///// <summary> ///// <summary>
///// 同步失败的源订单号(默认就包含所有来源单号) ///// 同步失败的源订单号(默认就包含所有来源单号)
///// </summary> ///// </summary>

View File

@@ -49,7 +49,7 @@ namespace WMS.Web.Domain.Entitys
/// 同步成功或者失败 默认是失败状态 /// 同步成功或者失败 默认是失败状态
/// </summary> /// </summary>
[Column("SuccessSync")] [Column("SuccessSync")]
public SyncStatus SuccessSync { get; set; } = SyncStatus.Fail; public SyncStatus SuccessSync { get; set; } = SyncStatus.SyncIng;
/// <summary> /// <summary>
/// 同步到金蝶后金蝶的单据Id /// 同步到金蝶后金蝶的单据Id
/// </summary> /// </summary>

View File

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

View File

@@ -196,7 +196,12 @@ namespace WMS.Web.Domain.Services
return Result.ReFailure(ResultCodes.DateWriteError); return Result.ReFailure(ResultCodes.DateWriteError);
if (entity.Type == OutStockType.Sal) if (entity.Type == OutStockType.Sal)
await SalOutStock(entity, loginInfo); {
Task.Run(async () =>
{
await SalOutStock(entity, loginInfo);
}).GetAwaiter().GetResult();
}
return Result.ReSuccess(); return Result.ReSuccess();
} }
@@ -210,7 +215,10 @@ namespace WMS.Web.Domain.Services
var list = await _outStockRepositories.GetEntityList(dto.Ids); var list = await _outStockRepositories.GetEntityList(dto.Ids);
foreach (var entity in list) foreach (var entity in list)
{ {
await SalOutStock(entity, loginInfo); Task.Run(async () =>
{
await SalOutStock(entity, loginInfo);
}).GetAwaiter().GetResult();
} }
return Result.ReSuccess(); return Result.ReSuccess();
} }

View File

@@ -136,8 +136,12 @@ namespace WMS.Web.Domain.Services
//同步金蝶 //同步金蝶
foreach (var entity in list) foreach (var entity in list)
{ {
var res = await Loss_Profit(entity); Task.Run(async () =>
if (!res.IsSuccess) return res; {
var res = await Loss_Profit(entity);
if (!res.IsSuccess)
_logger.LogError($"盘点同步失败:{res.Message}");
}).GetAwaiter().GetResult();
} }
return Result.ReSuccess(); return Result.ReSuccess();
@@ -151,11 +155,15 @@ namespace WMS.Web.Domain.Services
public async Task<Result> Sync(OperateRequest dto) public async Task<Result> Sync(OperateRequest dto)
{ {
var list = await _takeStockRepositories.GetEntityList(dto.Ids); var list = await _takeStockRepositories.GetEntityList(dto.Ids);
list = list.Where(w => w.SuccessSync == SyncStatus.Fail).ToList(); list = list.Where(w => w.SuccessSync == SyncStatus.Fail|| w.SuccessSync == SyncStatus.SyncIng).ToList();
foreach (var entity in list) foreach (var entity in list)
{ {
var res = await Loss_Profit(entity); Task.Run(async () =>
if (!res.IsSuccess) return res; {
var res = await Loss_Profit(entity);
if (!res.IsSuccess)
_logger.LogError($"盘点同步失败:{res.Message}");
}).GetAwaiter().GetResult();
} }
return Result.ReSuccess(); return Result.ReSuccess();

View File

@@ -8,18 +8,18 @@ namespace WMS.Web.Domain.Values
/// <summary> /// <summary>
/// 同步金蝶状态 /// 同步金蝶状态
/// </summary> /// </summary>
public enum SyncStatus public enum SyncStatus
{ {
/// <summary> /// <summary>
/// 失败(保存失败 未保存) /// 失败(保存失败 未保存)
/// </summary> /// </summary>
[EnumRemark("失败")] [EnumRemark("失败")]
Fail =0, Fail = 0,
/// <summary> /// <summary>
/// 成功 /// 成功
/// </summary> /// </summary>
[EnumRemark("成功")] [EnumRemark("成功")]
Success =1, Success = 1,
/// <summary> /// <summary>
/// 提交失败 /// 提交失败
/// </summary> /// </summary>
@@ -29,6 +29,11 @@ namespace WMS.Web.Domain.Values
/// 审核失败 /// 审核失败
/// </summary> /// </summary>
[EnumRemark("审核失败")] [EnumRemark("审核失败")]
CheckFail = 3 CheckFail = 3,
/// <summary>
/// 同步中
/// </summary>
[EnumRemark("同步中")]
SyncIng = 4
} }
} }

View File

@@ -165,7 +165,7 @@ namespace WMS.Web.Repositories
Type = s.order.Type.GetRemark(), Type = s.order.Type.GetRemark(),
Creator = _singleDataService.GetSingleData(SingleAction.Staffs, companyId, s.order.CreatorId), Creator = _singleDataService.GetSingleData(SingleAction.Staffs, companyId, s.order.CreatorId),
CreateTime = s.order.CreateTime.DateToStringSeconds(), CreateTime = s.order.CreateTime.DateToStringSeconds(),
SuccessSync = s.order.SuccessSync == SyncStatus.Success ? "成功" : "失败", SuccessSync = s.order.SuccessSync == SyncStatus.Success ? "成功" : (s.order.SuccessSync == SyncStatus.SyncIng ? "同步中" : "失败"),
Stock = _singleDataService.GetSingleData(SingleAction.StocksJoinOrgCode, companyId, s.order.StockCode + s.order.OrgCode), Stock = _singleDataService.GetSingleData(SingleAction.StocksJoinOrgCode, companyId, s.order.StockCode + s.order.OrgCode),
SourceBillNoList = s.detail.ErpDetails.Select(s => s.SourceBillNo).ToList(), SourceBillNoList = s.detail.ErpDetails.Select(s => s.SourceBillNo).ToList(),
SaleBillNoList = s.detail.ErpDetails.Select(s => s.SaleBillNo).ToList(), SaleBillNoList = s.detail.ErpDetails.Select(s => s.SaleBillNo).ToList(),

View File

@@ -214,7 +214,7 @@ namespace WMS.Web.Repositories
FailRemark=s.order.FailRemark, FailRemark=s.order.FailRemark,
Creator = _singleDataService.GetSingleData(SingleAction.Staffs, _loginRepositories.CompanyId, s.order.CreatorId), Creator = _singleDataService.GetSingleData(SingleAction.Staffs, _loginRepositories.CompanyId, s.order.CreatorId),
Date = s.order.Date.DateToStringSeconds(), Date = s.order.Date.DateToStringSeconds(),
SuccessSync = s.order.SuccessSync== SyncStatus.Success ? "成功":"失败", SuccessSync = s.order.SuccessSync == SyncStatus.Success ? "成功" : (s.order.SuccessSync == SyncStatus.SyncIng ? "同步中" : "失败"),
#endregion #endregion
}).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync(); }).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();