diff --git a/src/WMS.Web.Domain/Services/InStockTaskService.cs b/src/WMS.Web.Domain/Services/InStockTaskService.cs index 8ed8f3fa..90ca997d 100644 --- a/src/WMS.Web.Domain/Services/InStockTaskService.cs +++ b/src/WMS.Web.Domain/Services/InStockTaskService.cs @@ -17,6 +17,7 @@ using WMS.Web.Domain.Entitys; using WMS.Web.Domain.Infrastructure; using WMS.Web.Domain.IService; using WMS.Web.Domain.IService.Public; +using WMS.Web.Domain.Services.Public; using WMS.Web.Domain.Values; namespace WMS.Web.Domain.Services @@ -33,12 +34,14 @@ namespace WMS.Web.Domain.Services private readonly IBasicsRepositories _basicsRepositories; private readonly IInStockRepositories _inStockRepositories; private readonly IInStockTaskRepositories _inStockTaskRepositories; + private readonly RedisClientService _redisClientService; public InStockTaskService(IMapper mapper, IErpService erpService, ILoginService loginService, - IBasicsRepositories basicsRepositories, ILogger logger, + IBasicsRepositories basicsRepositories, ILogger logger, RedisClientService redisClientService, IInStockRepositories inStockRepositories, IInStockTaskRepositories inStockTaskRepositories) { this._logger = logger; _mapper = mapper; + _redisClientService = redisClientService; _erpService = erpService; _loginService = loginService; _basicsRepositories = basicsRepositories; @@ -201,6 +204,9 @@ namespace WMS.Web.Domain.Services /// public async Task Sysn(List billNos = null) { + var info = _redisClientService.GetStringKey($"wms_instock_sync"); + if (info == true) return Result.ReFailure(ResultCodes.ErpSyns); + _redisClientService.SetStringKey($"wms_instock_sync", true, TimeSpan.FromMinutes(5)); //1.事务 IDbContextTransaction _transaction = _basicsRepositories.GetTransaction(); bool isRollback = false;