接口刷新

This commit is contained in:
tongfei
2024-03-21 10:53:36 +08:00
parent a8edf2afcc
commit 46b35b7620

View File

@@ -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<InStockTaskService> logger,
IBasicsRepositories basicsRepositories, ILogger<InStockTaskService> 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
/// <returns></returns>
public async Task<Result> Sysn(List<string> billNos = null)
{
var info = _redisClientService.GetStringKey<bool>($"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;