[bug]修复业务字典修改时缓存不清空的问题

master
liuqingkun 3 years ago
parent 29c9adb5ba
commit aa258ffd03
  1. 6
      src/main/java/org/springblade/common/cache/DictBizCache.java
  2. 6
      src/main/java/org/springblade/modules/business/controller/ApmRecordController.java
  3. 1
      src/main/java/org/springblade/modules/system/controller/DictBizController.java

@ -124,7 +124,7 @@ public class DictBizCache {
* @return * @return
*/ */
public static Integer getDictValueWithOffset(String dictCode) { public static Integer getDictValueWithOffset(String dictCode) {
Integer value = CacheUtil.get(DICT_VALUE, dictCode, COMMON_BUSINESS_DICT_KEY, () -> null); int value = Integer.parseInt(getValue(dictCode, COMMON_BUSINESS_DICT_KEY));
if (Func.isEmpty(value)) { if (Func.isEmpty(value)) {
String valueStr = dictService.getValue(dictCode, DictBizCache.COMMON_BUSINESS_DICT_KEY); String valueStr = dictService.getValue(dictCode, DictBizCache.COMMON_BUSINESS_DICT_KEY);
@ -152,8 +152,4 @@ public class DictBizCache {
return value; return value;
} }
public static void cleanCacheWithOffset(String dictCode) {
CacheUtil.evict(DICT_VALUE, dictCode, COMMON_BUSINESS_DICT_KEY);
}
} }

@ -7,6 +7,7 @@ import io.swagger.annotations.*;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springblade.common.cache.DeptCache; import org.springblade.common.cache.DeptCache;
import org.springblade.common.cache.DictBizCache;
import org.springblade.common.constant.BusinessConstant; import org.springblade.common.constant.BusinessConstant;
import org.springblade.common.constant.CommonConstant; import org.springblade.common.constant.CommonConstant;
import org.springblade.common.enums.ApmRecordStatusEnum; import org.springblade.common.enums.ApmRecordStatusEnum;
@ -207,7 +208,10 @@ public class ApmRecordController extends BladeController {
String checkMsg = recordService.checkApmRecordSave(apmRecordList); String checkMsg = recordService.checkApmRecordSave(apmRecordList);
if (Func.isBlank(checkMsg)) { if (Func.isBlank(checkMsg)) {
recordService.saveBatch(apmRecordList); recordService.saveBatch(apmRecordList);
return R.status(true); int blacklistOutdate = DictBizCache.getDictValueWithOffset(BusinessConstant.DICT_KEY_BLACKLIST_OUTDATE);
Map<String, Object> result = new HashMap<>();
result.put("blacklistOutDate", blacklistOutdate);
return R.data(result);
} }
return R.fail(checkMsg); return R.fail(checkMsg);
} }

@ -141,7 +141,6 @@ public class DictBizController extends BladeController {
@ApiOperation(value = "新增或修改", notes = "传入dict") @ApiOperation(value = "新增或修改", notes = "传入dict")
public R submit(@Valid @RequestBody DictBiz dict) { public R submit(@Valid @RequestBody DictBiz dict) {
CacheUtil.clear(DICT_CACHE); CacheUtil.clear(DICT_CACHE);
DictBizCache.cleanCacheWithOffset(dict.getCode());
return R.status(dictService.submit(dict)); return R.status(dictService.submit(dict));
} }

Loading…
Cancel
Save