From 281b8003e2d26451793c22f7c7c0c4d13ea40da1 Mon Sep 17 00:00:00 2001 From: kongdeqiang <kongdeqiang960204@163.com> Date: 星期三, 20 三月 2024 08:30:34 +0800 Subject: [PATCH] 提交更新 --- src/main/java/com/boying/controller/BarrierController.java | 40 +++++++++++++++++++++++++++++++++++++++- 1 files changed, 39 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/boying/controller/BarrierController.java b/src/main/java/com/boying/controller/BarrierController.java index 3858b25..7089007 100644 --- a/src/main/java/com/boying/controller/BarrierController.java +++ b/src/main/java/com/boying/controller/BarrierController.java @@ -1,5 +1,6 @@ package com.boying.controller; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.boying.common.R; @@ -8,11 +9,14 @@ import com.boying.service.BarrierService; import com.boying.service.OutParkService; import com.boying.service.ParkService; +import com.boying.util.RedisJsonUtil; import lombok.RequiredArgsConstructor; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.io.IOException; import java.time.LocalDateTime; import java.time.ZoneOffset; import java.util.List; @@ -25,6 +29,8 @@ private final BarrierService barrierService; private final OutParkService outParkService; private final ParkService parkService; + private StringRedisTemplate redisTemplate; + @PostMapping("findPage") public Object findPage(Page page, String parkId) { @@ -36,7 +42,7 @@ for(Barrier barrier:records){ long l = System.currentTimeMillis() - barrier.getUpdateTime().toInstant(ZoneOffset.of("+8")).toEpochMilli(); System.out.println(l); - if(l>10000){ + if(l>20000){ barrier.setStatus(1); } } @@ -48,12 +54,20 @@ public Object save(Barrier barrier) { barrier.setUpdateTime(LocalDateTime.now()); barrierService.saveOrUpdate(barrier); + try { + String jsonValue = JSON.toJSONString(barrier); + redisTemplate.opsForValue().set("barrier-"+barrier.getCode(), jsonValue); + } catch (Exception e) { + e.printStackTrace(); + } return R.ok("淇濆瓨鎴愬姛"); } @PostMapping("delete") public Object delete(Integer id) { + Barrier byId = barrierService.getById(id); barrierService.removeById(id); + redisTemplate.delete("barrier-"+byId.getCode()); return R.ok("鍒犻櫎鎴愬姛"); } @@ -77,6 +91,12 @@ b.setType2(1); b.setUpdateTime(LocalDateTime.now()); barrierService.saveOrUpdate(b); + try { + String jsonValue = JSON.toJSONString(b); + redisTemplate.opsForValue().set("barrier-"+b.getCode(), jsonValue); + } catch (Exception e) { + e.printStackTrace(); + } return R.ok("璇锋眰鎴愬姛"); } @@ -104,6 +124,12 @@ b.setType2(1); b.setUpdateTime(LocalDateTime.now()); barrierService.saveOrUpdate(b); + try { + String jsonValue = JSON.toJSONString(b); + redisTemplate.opsForValue().set("barrier-"+b.getCode(), jsonValue); + } catch (Exception e) { + e.printStackTrace(); + } return R.ok("璇锋眰鎴愬姛"); }else { System.out.println("鎵嬪姩寮�鍑哄彛闂�"); @@ -119,12 +145,24 @@ b.setType2(1); b.setUpdateTime(LocalDateTime.now()); barrierService.saveOrUpdate(b); + try { + String jsonValue = JSON.toJSONString(b); + redisTemplate.opsForValue().set("barrier-"+b.getCode(), jsonValue); + } catch (Exception e) { + e.printStackTrace(); + } return R.ok("璇锋眰鎴愬姛"); }else { //璁¤垂 b.setType2(1); b.setUpdateTime(LocalDateTime.now()); barrierService.saveOrUpdate(b); + try { + String jsonValue = JSON.toJSONString(b); + redisTemplate.opsForValue().set("barrier-"+b.getCode(), jsonValue); + } catch (Exception e) { + e.printStackTrace(); + } return R.ok("璇锋眰鎴愬姛"); } } -- Gitblit v1.9.1