1.修改锁时间
2.修改判断企业不维护时,返回空
This commit is contained in:
@@ -58,9 +58,9 @@ public class ESJobSearchImpl implements IESJobSearchService
|
||||
// 锁的key(唯一标识ES索引初始化)
|
||||
private static final String ES_INIT_LOCK_KEY = "es:job_document:init:lock";
|
||||
// 锁过期时间(30分钟,确保初始化完成)
|
||||
private static final Integer LOCK_EXPIRE_SECONDS = 1800;
|
||||
private static final Integer LOCK_EXPIRE_SECONDS = 600;//1800
|
||||
// 等待锁时间(5分钟,避免无限等待)
|
||||
private static final Integer WAIT_LOCK_SECONDS = 300;
|
||||
private static final Integer WAIT_LOCK_SECONDS = 1;//300
|
||||
|
||||
|
||||
@Autowired
|
||||
@@ -114,7 +114,7 @@ public class ESJobSearchImpl implements IESJobSearchService
|
||||
*/
|
||||
private void releaseDistributedLock() {
|
||||
try {
|
||||
redisCache.deleteObject(ES_INIT_LOCK_KEY);
|
||||
//redisCache.deleteObject(ES_INIT_LOCK_KEY);//不删除锁,30分钟自动过期
|
||||
logger.info("已释放ES初始化分布式锁,key:{}", ES_INIT_LOCK_KEY);
|
||||
} catch (Exception e) {
|
||||
logger.error("释放ES初始化锁异常", e);
|
||||
@@ -225,10 +225,15 @@ public class ESJobSearchImpl implements IESJobSearchService
|
||||
|
||||
ESJobSearch newSearch = new ESJobSearch();
|
||||
BeanUtils.copyProperties(esJobSearch,newSearch);
|
||||
boolean isCompanyUser = StringUtil.IS_COMPANY_USER.equals(esJobSearch.getUserType());
|
||||
boolean isCompanyUser = false;
|
||||
//查询
|
||||
if(SiteSecurityUtils.isLogin()){
|
||||
AppUser appUser = appUserService.selectAppUserByUserId(SiteSecurityUtils.getUserId());
|
||||
//判断为企业并且code为空时,返回null
|
||||
isCompanyUser=StringUtil.IS_COMPANY_USER.equals(appUser.getIsCompanyUser());
|
||||
if (isCompanyUser && StringUtil.isEmptyOrNull(esJobSearch.getCode())) {
|
||||
return new ArrayList<>();
|
||||
}
|
||||
if (!StringUtil.isEmptyOrNull(esJobSearch.getCode())) {
|
||||
newSearch.setCode(esJobSearch.getCode());
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user