ly
/
Stwzhj-Cloud-Plus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

省厅位置汇聚consumer过滤时间2000秒以外的数据

stwzhj
luyya 2026-01-05 17:42:26 +08:00
parent 09e390b79d
commit 1b0876d735
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
View File

@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions; import cn.hutool.core.bean.copier.CopyOptions;
import cn.hutool.core.convert.ConvertException; import cn.hutool.core.convert.ConvertException;
import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONObject; import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
@ -102,6 +103,9 @@ public class ConsumerWorker implements Runnable {
}catch (Exception e){ }catch (Exception e){
logger.error("error_msg={}",e.getMessage()); logger.error("error_msg={}",e.getMessage());
} }
if(DateUtil.between(esGpsInfo.getGpsTime(), new Date(), DateUnit.SECOND) > 2000L){
return;
}
logger.info("esGpsInfo={}",esGpsInfo); logger.info("esGpsInfo={}",esGpsInfo);
boolean offer = linkedBlockingDeque.offer(esGpsInfo); boolean offer = linkedBlockingDeque.offer(esGpsInfo);
R response = R.ok(offer); R response = R.ok(offer);