common-frame/hcframe
17
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

feat: add page data cache and limit

Browse Source
This commit is contained in:
taixingyiji
2025-02-28 13:21:45 +08:00
parent 57551e9521
commit 30aaef565c
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/common/config/FrameConfig.java
View File

@@ -14,4 +14,6 @@ public class FrameConfig {
private Boolean multiDataSource = true;
private Boolean cas = false;
private Boolean singleClientLogin= false;
private Integer pageMaxCache = 100000;
private Integer pageCacheTime = 60;
}

8
hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/common/utils/MyPageHelper.java
View File

@@ -5,6 +5,7 @@ import cn.hutool.json.JSONUtil;
import com.github.pagehelper.PageInfo;
import com.taixingyiji.base.common.WebPageInfo;
import com.github.pagehelper.PageHelper;
import com.taixingyiji.base.common.config.FrameConfig;
import com.taixingyiji.base.module.cache.CacheService;
import com.taixingyiji.base.module.cache.base.BaseCache;
import com.taixingyiji.base.module.cache.emum.CacheType;
@@ -24,6 +25,9 @@ public class MyPageHelper {
@Autowired
BaseCache baseCache;
@Autowired
FrameConfig frameConfig;
@PostConstruct
public void init() {
myPageHelper = this;
@@ -69,13 +73,15 @@ public class MyPageHelper {
PageInfo<Map<String, Object>> result = myStart(webPageInfo, querySupplier);
jsonObject.set("time", currentTime);
jsonObject.set("count", result.getTotal());
if(result.getTotal() > myPageHelper.frameConfig.getPageMaxCache()){
myPageHelper.baseCache.add(CacheType.pageCache.toString(), sql, jsonObject.toString(), String.class);
}
return result;
} else {
JSONObject cacheJson = JSONUtil.parseObj(data);
Long saveTime = (Long) cacheJson.get("time");
long timeDiffInSeconds = (currentTime - saveTime) / 1000;
if (timeDiffInSeconds > 60) {
if (timeDiffInSeconds > myPageHelper.frameConfig.getPageCacheTime()) {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {