xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

undeal向redis中缓存第一次开始处理时间戳，key值名称修改

Browse Source
This commit is contained in:
qiaoqinzheng 2024-01-11 11:09:56 +08:00
parent 62d448c294
commit 4e6bd1dd6e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jeecg-module-auto-process/src/main/java/org/jeecg/modules/UndealHandleManager.java
View File

@ -128,9 +128,9 @@ public class UndealHandleManager{
long createMillis = currentMillis; long createMillis = currentMillis;
//判断redis是否包含文件名称 key //判断redis是否包含文件名称 key
if (spectrumServiceQuotes.getRedisStreamUtil().hasKey(spectrumFile.getName())) { if (spectrumServiceQuotes.getRedisStreamUtil().hasKey(spectrumFile.getName())) {
createMillis = (long) spectrumServiceQuotes.getRedisStreamUtil().get(spectrumFile.getName()); createMillis = (long) spectrumServiceQuotes.getRedisStreamUtil().get(spectrumFile.getName()+"-undeal");
} else { } else {
spectrumServiceQuotes.getRedisStreamUtil().set(spectrumFile.getName(), currentMillis); spectrumServiceQuotes.getRedisStreamUtil().set(spectrumFile.getName()+"-undeal", currentMillis);
} }
try { try {
//解析文件 //解析文件
@ -148,7 +148,7 @@ public class UndealHandleManager{
this.taskLatch.countDown(); this.taskLatch.countDown();
//满足undeal文件处理周期时长会删除源文件 //满足undeal文件处理周期时长会删除源文件
if ((currentMillis - createMillis) >= taskProperties.getUndealFileTimeOut()) { if ((currentMillis - createMillis) >= taskProperties.getUndealFileTimeOut()) {
spectrumServiceQuotes.getRedisStreamUtil().del(spectrumFile.getName()); spectrumServiceQuotes.getRedisStreamUtil().del(spectrumFile.getName()+"-undeal");
spectrumFile.delete(); spectrumFile.delete();
} }
} }