From bccd25039a08f8833b72ff906d156da63018db98 Mon Sep 17 00:00:00 2001 From: kongdeqiang <123456> Date: 星期二, 19 三月 2024 15:10:13 +0800 Subject: [PATCH] 新增心跳缓存 --- src/main/java/com/boying/service/impl/OutParkServiceImpl.java | 63 ++++++++++++------------------- 1 files changed, 25 insertions(+), 38 deletions(-) diff --git a/src/main/java/com/boying/service/impl/OutParkServiceImpl.java b/src/main/java/com/boying/service/impl/OutParkServiceImpl.java index affe3db..bd3bbbc 100644 --- a/src/main/java/com/boying/service/impl/OutParkServiceImpl.java +++ b/src/main/java/com/boying/service/impl/OutParkServiceImpl.java @@ -118,45 +118,32 @@ @Override public OutPark count4(Integer bId) { -// OutPark outPark = null; -// try { -// String s = redisTemplate.opsForValue().get("outPark-"+bId); -// if(!StringUtil.isNullOrEmpty(s)){ -// outPark = JSON.parseObject(s, OutPark.class); -// return outPark; -// }else { -// QueryWrapper<OutPark> wrapper = new QueryWrapper<>(); -// wrapper.lambda() -// .eq(OutPark::getBarrierId,bId) -// .eq(OutPark::getStatus,1) -// .eq(OutPark::getStatus2,0) -// .orderByDesc(OutPark::getCreateTime); -// List<OutPark> outParks = outParkMapper.selectList(wrapper); -// if(outParks.size()>0){ -// String jsonValue = JSON.toJSONString(outParks.get(0)); -// redisTemplate.opsForValue().set("outPark-"+bId, jsonValue); -// return outParks.get(0); -// }else{ -// return null; -// } -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } -// return null; - - QueryWrapper<OutPark> wrapper = new QueryWrapper<>(); - wrapper.lambda() - .eq(OutPark::getBarrierId,bId) - .eq(OutPark::getStatus,1) - .eq(OutPark::getStatus2,0) - .orderByDesc(OutPark::getCreateTime); - List<OutPark> outParks = outParkMapper.selectList(wrapper); - if(outParks.size()>0){ - return outParks.get(0); - }else{ - return null; + OutPark outPark = null; + try { + String s = redisTemplate.opsForValue().get("outPark-"+bId); + if(!StringUtil.isNullOrEmpty(s)){ + outPark = JSON.parseObject(s, OutPark.class); + return outPark; + }else { + return null; + } + } catch (Exception e) { + e.printStackTrace(); } + return null; +// +// QueryWrapper<OutPark> wrapper = new QueryWrapper<>(); +// wrapper.lambda() +// .eq(OutPark::getBarrierId,bId) +// .eq(OutPark::getStatus,1) +// .eq(OutPark::getStatus2,0) +// .orderByDesc(OutPark::getCreateTime); +// List<OutPark> outParks = outParkMapper.selectList(wrapper); +// if(outParks.size()>0){ +// return outParks.get(0); +// }else{ +// return null; +// } } @Override -- Gitblit v1.9.1