From c20b17fee68aa391bbbdaed34d1ee22f1ed21448 Mon Sep 17 00:00:00 2001
From: 16639036659 <577530412@qq.com>
Date: 星期日, 07 四月 2024 13:23:58 +0800
Subject: [PATCH] 日报功能开启
---
src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java
index dd91e79..40d8623 100644
--- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java
+++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java
@@ -3,6 +3,7 @@
import com.gkhy.fourierSpecialGasMonitor.commons.domain.Result;
import com.gkhy.fourierSpecialGasMonitor.commons.domain.SearchResult;
import com.gkhy.fourierSpecialGasMonitor.commons.enums.ResultCode;
+import com.gkhy.fourierSpecialGasMonitor.commons.enums.SystemCacheKeyEnum;
import com.gkhy.fourierSpecialGasMonitor.commons.exception.BusinessException;
import com.gkhy.fourierSpecialGasMonitor.commons.model.PageQuery;
import com.gkhy.fourierSpecialGasMonitor.domain.account.entity.User;
@@ -76,7 +77,7 @@
}
@Override
- public Result createGasCategory(CreateGasCategoryReqDTO reqDto) {
+ public synchronized Result createGasCategory(CreateGasCategoryReqDTO reqDto) {
if (reqDto == null)
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"参数不能为空");
if (StringUtils.isBlank(reqDto.getMolecularFormula()))
@@ -107,7 +108,7 @@
gasCategoryMolecularFormulaRepeatlock.unlock();
}
//清除redis缓存
- RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");
+ RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());
if (bucket.isExists()) {
bucket.delete();
}
@@ -147,7 +148,7 @@
gasCategoryMolecularFormulaRepeatlock.unlock();
}
//清除redis缓存
- RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");
+ RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());
if (bucket.isExists()) {
bucket.delete();
}
@@ -179,7 +180,7 @@
@Override
public Result gasCategoryList() {
Result success = Result.success();
- RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");
+ RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());
List<GasCategory> categories = bucket.get();
if (CollectionUtils.isEmpty(categories)){
categories = gasCategoryRepository.findAll();
--
Gitblit v1.9.2