From ffa5f49a2bcb6311486d00777b3629538eb3e6f0 Mon Sep 17 00:00:00 2001
From: kongdeqiang <123456>
Date: 星期一, 18 三月 2024 17:28:19 +0800
Subject: [PATCH] 新增心跳缓存
---
src/main/java/com/boying/service/impl/BarrierServiceImpl.java | 28 +++++++++++++++++++++-------
1 files changed, 21 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/boying/service/impl/BarrierServiceImpl.java b/src/main/java/com/boying/service/impl/BarrierServiceImpl.java
index 1d83789..6303eac 100644
--- a/src/main/java/com/boying/service/impl/BarrierServiceImpl.java
+++ b/src/main/java/com/boying/service/impl/BarrierServiceImpl.java
@@ -14,10 +14,12 @@
import com.boying.mapper.ParkMapper;
import com.boying.service.BarrierService;
import com.boying.service.EnterParkService;
+import com.boying.util.RedisJsonUtil;
import lombok.AllArgsConstructor;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
+import java.io.IOException;
import java.time.ZoneId;
import java.util.Date;
import java.util.List;
@@ -37,17 +39,29 @@
private OutParkMapper outParkMapper;
private StringRedisTemplate redisTemplate;
private ParkMapper parkMapper;
+ private RedisJsonUtil redisJsonUtil;
@Override
public Barrier findByCode(String code) {
- QueryWrapper<Barrier> wrapper = new QueryWrapper<>();
- wrapper.lambda()
- .eq(Barrier::getCode,code);
- List<Barrier> list = list(wrapper);
- if(list.size()>0){
- return list.get(0);
- }else {
+ Barrier barrier = null;
+ try {
+ barrier = redisJsonUtil.get("barrier-"+code,Barrier.class);
+ if(barrier != null){
+ return barrier;
+ }else {
+ QueryWrapper<Barrier> wrapper = new QueryWrapper<>();
+ wrapper.lambda()
+ .eq(Barrier::getCode,code);
+ List<Barrier> list = list(wrapper);
+ if(list.size()>0){
+ redisJsonUtil.set("barrier-"+code,list.get(0));
+ return list.get(0);
+ }
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
return null;
}
+ return null;
}
@Override
--
Gitblit v1.9.1