From 48f43f7c4d4c596c5c1eaf6258875e90bffbe94a Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 4 Mar 2024 19:25:37 +0800 Subject: [PATCH] =?UTF-8?q?redis=20key=E8=BF=87=E6=9C=9F=20=E7=9B=91?= =?UTF-8?q?=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/ysk/cashier/config/RedisConfig.java | 22 ++++++++---- .../config/RedisKeyExpirationListener.java | 17 +++++++++ .../order/TbCashierCartController.java | 18 +++++----- .../order/TbOrderDetailController.java | 18 +++++----- .../order/TbOrderInfoController.java | 25 ++++++------- .../ysk/cashier/dto/order/TbOrderInfoDto.java | 7 ++-- .../ysk/cashier/pojo/order/TbOrderDetail.java | 2 +- .../order/TbCashierCartRepository.java | 7 ---- .../order/TbOrderDetailRepository.java | 7 ++++ .../impl/order/TbOrderInfoServiceImpl.java | 35 ++++++++++--------- .../java/cn/ysk/cashier/vo/TbOrderInfoVo.java | 4 +-- 11 files changed, 96 insertions(+), 66 deletions(-) create mode 100644 eladmin-common/src/main/java/cn/ysk/cashier/config/RedisKeyExpirationListener.java diff --git a/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisConfig.java b/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisConfig.java index b2651602..f60b92ec 100644 --- a/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisConfig.java +++ b/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisConfig.java @@ -21,6 +21,7 @@ import com.alibaba.fastjson.parser.ParserConfig; import com.alibaba.fastjson.serializer.SerializerFeature; import lombok.extern.slf4j.Slf4j; import org.apache.commons.codec.digest.DigestUtils; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.data.redis.RedisProperties; @@ -36,6 +37,8 @@ import org.springframework.data.redis.cache.RedisCacheConfiguration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.RedisOperations; import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.listener.PatternTopic; +import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.data.redis.serializer.RedisSerializationContext; import org.springframework.data.redis.serializer.RedisSerializer; import reactor.util.annotation.Nullable; @@ -57,6 +60,9 @@ import java.util.Map; @EnableConfigurationProperties(RedisProperties.class) public class RedisConfig extends CachingConfigurerSupport { + @Autowired + private RedisKeyExpirationListener redisKeyExpirationListener; + /** * 设置 redis 数据默认过期时间，默认2小时 * 设置@cacheable 序列化方式 @@ -83,16 +89,10 @@ public class RedisConfig extends CachingConfigurerSupport { // fastjson 升级到 1.2.83 后需要指定序列化白名单 ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.pojo"); ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.service"); - // 模块内的实体类 -// ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.mnt.domain"); -// ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.quartz.domain"); -// ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.system.domain"); - // 模块内的 Dto ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.mnt"); ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.system"); ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.quartz"); ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.config"); -// ParserConfig.getGlobalInstance().addAccept("cn.ysk.cashier.system.service.dto"); // key的序列化采用StringRedisSerializer template.setKeySerializer(new StringRedisSerializer()); template.setHashKeySerializer(new StringRedisSerializer()); @@ -100,6 +100,16 @@ public class RedisConfig extends CachingConfigurerSupport { return template; } + //redis key失效监听 + @Bean + public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) { + RedisMessageListenerContainer container = new RedisMessageListenerContainer(); + container.setConnectionFactory(connectionFactory); + // 监听特定键的过期事件 + container.addMessageListener(redisKeyExpirationListener, new PatternTopic("__keyevent@0__:expired")); + return container; + } + /** * 自定义缓存key生成策略，默认将使用该策略 */ diff --git a/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisKeyExpirationListener.java b/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisKeyExpirationListener.java new file mode 100644 index 00000000..95b6e090 --- /dev/null +++ b/eladmin-common/src/main/java/cn/ysk/cashier/config/RedisKeyExpirationListener.java @@ -0,0 +1,17 @@ +package cn.ysk.cashier.config; + +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.connection.Message; +import org.springframework.data.redis.connection.MessageListener; + +@Configuration +public class RedisKeyExpirationListener implements MessageListener { + + @Override + public void onMessage(Message message, byte[] pattern) { + String expiredKey = new String(message.getBody()); + System.out.println("过期的Key为: " + expiredKey); + // 在这里添加处理键过期事件的逻辑 + } + +} \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbCashierCartController.java b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbCashierCartController.java index f1ba8751..0f4657a6 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbCashierCartController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbCashierCartController.java @@ -36,7 +36,7 @@ import javax.servlet.http.HttpServletResponse; **/ @RestController @RequiredArgsConstructor -@Api(tags = "/cashierCart管理") +@Api(tags = "购物车管理") @RequestMapping("/api/tbCashierCart") public class TbCashierCartController { @@ -50,30 +50,30 @@ public class TbCashierCartController { } @GetMapping - @Log("查询/cashierCart") - @ApiOperation("查询/cashierCart") + @Log("查询购物车") + @ApiOperation("查询购物车") public ResponseEntity queryTbCashierCart(TbCashierCartQueryCriteria criteria, Pageable pageable){ return new ResponseEntity<>(tbCashierCartService.queryAll(criteria,pageable),HttpStatus.OK); } @PostMapping - @Log("新增/cashierCart") - @ApiOperation("新增/cashierCart") + @Log("新增购物车") + @ApiOperation("新增购物车") public ResponseEntity createTbCashierCart(@Validated @RequestBody TbCashierCart resources){ return new ResponseEntity<>(tbCashierCartService.create(resources),HttpStatus.CREATED); } @PutMapping - @Log("修改/cashierCart") - @ApiOperation("修改/cashierCart") + @Log("修改购物车") + @ApiOperation("修改购物车") public ResponseEntity updateTbCashierCart(@Validated @RequestBody TbCashierCart resources){ tbCashierCartService.update(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); } @DeleteMapping - @Log("删除/cashierCart") - @ApiOperation("删除/cashierCart") + @Log("删除购物车") + @ApiOperation("删除购物车") public ResponseEntity deleteTbCashierCart(@RequestBody Integer[] ids) { tbCashierCartService.deleteAll(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderDetailController.java b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderDetailController.java index 29d65dfa..aaad587c 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderDetailController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderDetailController.java @@ -36,7 +36,7 @@ import javax.servlet.http.HttpServletResponse; **/ @RestController @RequiredArgsConstructor -@Api(tags = "/orderDetail管理") +@Api(tags = "订单详情") @RequestMapping("/api/tbOrderDetail") public class TbOrderDetailController { @@ -50,30 +50,30 @@ public class TbOrderDetailController { } @GetMapping - @Log("查询/orderDetail") - @ApiOperation("查询/orderDetail") + @Log("查询订单详情") + @ApiOperation("查询订单详情") public ResponseEntity queryTbOrderDetail(TbOrderDetailQueryCriteria criteria, Pageable pageable){ return new ResponseEntity<>(tbOrderDetailService.queryAll(criteria,pageable),HttpStatus.OK); } @PostMapping - @Log("新增/orderDetail") - @ApiOperation("新增/orderDetail") + @Log("新增订单详情") + @ApiOperation("新增订单详情") public ResponseEntity createTbOrderDetail(@Validated @RequestBody TbOrderDetail resources){ return new ResponseEntity<>(tbOrderDetailService.create(resources),HttpStatus.CREATED); } @PutMapping - @Log("修改/orderDetail") - @ApiOperation("修改/orderDetail") + @Log("修改订单详情") + @ApiOperation("修改订单详情") public ResponseEntity updateTbOrderDetail(@Validated @RequestBody TbOrderDetail resources){ tbOrderDetailService.update(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); } @DeleteMapping - @Log("删除/orderDetail") - @ApiOperation("删除/orderDetail") + @Log("删除订单详情") + @ApiOperation("删除订单详情") public ResponseEntity deleteTbOrderDetail(@RequestBody Integer[] ids) { tbOrderDetailService.deleteAll(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java index 1d6e003c..ec101a23 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java @@ -16,6 +16,7 @@ package cn.ysk.cashier.controller.order; import cn.ysk.cashier.annotation.Log; +import cn.ysk.cashier.dto.order.TbOrderInfoDto; import cn.ysk.cashier.pojo.order.TbOrderInfo; import cn.ysk.cashier.service.order.TbOrderInfoService; import cn.ysk.cashier.dto.order.TbOrderInfoQueryCriteria; @@ -36,7 +37,7 @@ import javax.servlet.http.HttpServletResponse; **/ @RestController @RequiredArgsConstructor -@Api(tags = "/orderInfo管理") +@Api(tags = "订单管理") @RequestMapping("/api/tbOrderInfo") public class TbOrderInfoController { @@ -50,37 +51,37 @@ public class TbOrderInfoController { } @GetMapping - @Log("查询/orderInfo") - @ApiOperation("查询/orderInfo") + @Log("查询订单") + @ApiOperation("查询订单") public ResponseEntity queryTbOrderInfo(TbOrderInfoQueryCriteria criteria, Pageable pageable){ return new ResponseEntity<>(tbOrderInfoService.queryAll(criteria,pageable),HttpStatus.OK); } @GetMapping("/{id}") - @Log("查询/orderInfo") - @ApiOperation("查询/orderInfo") - public Object queryTbOrderInfo(@PathVariable("id") Integer id){ + @Log("通过Id查询订单") + @ApiOperation("通过Id查询订单") + public TbOrderInfoDto queryTbOrderInfo(@PathVariable("id") Integer id){ return tbOrderInfoService.findById(id); } @PostMapping - @Log("新增/orderInfo") - @ApiOperation("新增/orderInfo") + @Log("新增订单") + @ApiOperation("新增订单") public ResponseEntity createTbOrderInfo(@Validated @RequestBody TbOrderInfo resources){ return new ResponseEntity<>(tbOrderInfoService.create(resources),HttpStatus.CREATED); } @PutMapping - @Log("修改/orderInfo") - @ApiOperation("修改/orderInfo") + @Log("修改订单") + @ApiOperation("修改订单") public ResponseEntity updateTbOrderInfo(@Validated @RequestBody TbOrderInfo resources){ tbOrderInfoService.update(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); } @DeleteMapping - @Log("删除/orderInfo") - @ApiOperation("删除/orderInfo") + @Log("删除订单") + @ApiOperation("删除订单") public ResponseEntity deleteTbOrderInfo(@RequestBody Integer[] ids) { tbOrderInfoService.deleteAll(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoDto.java b/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoDto.java index f614d069..7bc567c1 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoDto.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoDto.java @@ -15,8 +15,9 @@ */ package cn.ysk.cashier.dto.order; +import cn.ysk.cashier.pojo.order.TbOrderDetail; +import io.swagger.annotations.ApiModelProperty; import lombok.Data; -import cn.ysk.cashier.pojo.order.TbCashierCart; import java.math.BigDecimal; import java.io.Serializable; @@ -34,8 +35,8 @@ public class TbOrderInfoDto implements Serializable { private Integer id; /** 订单编号 */ + @ApiModelProperty(value = "订单编号") private String orderNo; - /** 商户结算金额 */ private BigDecimal settlementAmount; @@ -154,5 +155,5 @@ public class TbOrderInfoDto implements Serializable { private String remark; - private List cartList; + private List detailList; } \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/pojo/order/TbOrderDetail.java b/eladmin-system/src/main/java/cn/ysk/cashier/pojo/order/TbOrderDetail.java index 1e70f970..039ea857 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/pojo/order/TbOrderDetail.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/pojo/order/TbOrderDetail.java @@ -43,7 +43,7 @@ public class TbOrderDetail implements Serializable { private Integer id; @Column(name = "`order_id`") - @ApiModelProperty(value = "orderId") + @ApiModelProperty(value = "订单id") private Integer orderId; @Column(name = "`shop_id`") diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbCashierCartRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbCashierCartRepository.java index 003161a7..f45552b7 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbCashierCartRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbCashierCartRepository.java @@ -18,10 +18,6 @@ package cn.ysk.cashier.repository.order; import cn.ysk.cashier.pojo.order.TbCashierCart; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; -import org.springframework.data.jpa.repository.Query; -import org.springframework.data.repository.query.Param; - -import java.util.List; /** * @website https://eladmin.vip @@ -29,7 +25,4 @@ import java.util.List; * @date 2024-03-02 **/ public interface TbCashierCartRepository extends JpaRepository, JpaSpecificationExecutor { - - @Query("SELECT cart FROM TbCashierCart cart WHERE cart.orderId = :orderId") - List searchCartByOrderId(@Param("orderId")Integer orderId); } \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbOrderDetailRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbOrderDetailRepository.java index c41a032e..40e8cfb0 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbOrderDetailRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/order/TbOrderDetailRepository.java @@ -18,6 +18,10 @@ package cn.ysk.cashier.repository.order; import cn.ysk.cashier.pojo.order.TbOrderDetail; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; +import org.springframework.data.jpa.repository.Query; +import org.springframework.data.repository.query.Param; + +import java.util.List; /** * @website https://eladmin.vip @@ -25,4 +29,7 @@ import org.springframework.data.jpa.repository.JpaSpecificationExecutor; * @date 2024-03-02 **/ public interface TbOrderDetailRepository extends JpaRepository, JpaSpecificationExecutor { + + @Query("SELECT cart FROM TbOrderDetail cart WHERE cart.orderId = :orderId") + List searchDetailByOrderId(@Param("orderId")Integer orderId); } \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java index 21747018..690b2298 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java @@ -15,32 +15,32 @@ */ package cn.ysk.cashier.service.impl.order; -import cn.ysk.cashier.pojo.order.TbCashierCart; -import cn.ysk.cashier.repository.order.TbCashierCartRepository; +import cn.ysk.cashier.dto.order.TbOrderInfoDto; +import cn.ysk.cashier.dto.order.TbOrderInfoQueryCriteria; +import cn.ysk.cashier.mapper.order.TbOrderInfoMapper; +import cn.ysk.cashier.pojo.order.TbOrderDetail; import cn.ysk.cashier.pojo.order.TbOrderInfo; +import cn.ysk.cashier.repository.order.TbOrderDetailRepository; +import cn.ysk.cashier.repository.order.TbOrderInfoRepository; +import cn.ysk.cashier.service.order.TbOrderInfoService; import cn.ysk.cashier.utils.FileUtil; import cn.ysk.cashier.utils.PageUtil; import cn.ysk.cashier.utils.QueryHelp; import cn.ysk.cashier.utils.ValidationUtil; import cn.ysk.cashier.vo.TbOrderInfoVo; import lombok.RequiredArgsConstructor; -import cn.ysk.cashier.repository.order.TbOrderInfoRepository; -import cn.ysk.cashier.service.order.TbOrderInfoService; -import cn.ysk.cashier.dto.order.TbOrderInfoDto; -import cn.ysk.cashier.dto.order.TbOrderInfoQueryCriteria; -import cn.ysk.cashier.mapper.order.TbOrderInfoMapper; import org.springframework.beans.BeanUtils; -import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; -import java.util.List; -import java.util.Map; -import java.io.IOException; import javax.servlet.http.HttpServletResponse; +import java.io.IOException; import java.util.ArrayList; import java.util.LinkedHashMap; +import java.util.List; +import java.util.Map; /** * @website https://eladmin.vip @@ -54,15 +54,16 @@ public class TbOrderInfoServiceImpl implements TbOrderInfoService { private final TbOrderInfoRepository tbOrderInfoRepository; private final TbOrderInfoMapper tbOrderInfoMapper; - private final TbCashierCartRepository tbCashierCartRepository; + + private final TbOrderDetailRepository tbOrderDetailRepository; @Override public Map queryAll(TbOrderInfoQueryCriteria criteria, Pageable pageable){ Page page = tbOrderInfoRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root,criteria,criteriaBuilder),pageable); List orderInfoVoList = new ArrayList<>(); for (TbOrderInfo tbOrderInfo : page.getContent()) { TbOrderInfoVo orderInfoVo=new TbOrderInfoVo(); - List tbCashierCarts = tbCashierCartRepository.searchCartByOrderId(tbOrderInfo.getId()); - orderInfoVo.setCartList(tbCashierCarts); + List details = tbOrderDetailRepository.searchDetailByOrderId(tbOrderInfo.getId()); + orderInfoVo.setDetailList(details); BeanUtils.copyProperties(tbOrderInfo, orderInfoVo); orderInfoVoList.add(orderInfoVo); } @@ -80,8 +81,8 @@ public class TbOrderInfoServiceImpl implements TbOrderInfoService { TbOrderInfo tbOrderInfo = tbOrderInfoRepository.findById(id).orElseGet(TbOrderInfo::new); ValidationUtil.isNull(tbOrderInfo.getId(),"TbOrderInfo","id",id); TbOrderInfoDto dto = tbOrderInfoMapper.toDto(tbOrderInfo); - List tbCashierCarts = tbCashierCartRepository.searchCartByOrderId(tbOrderInfo.getId()); - dto.setCartList(tbCashierCarts); + List details = tbOrderDetailRepository.searchDetailByOrderId(tbOrderInfo.getId()); + dto.setDetailList(details); return dto; } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/vo/TbOrderInfoVo.java b/eladmin-system/src/main/java/cn/ysk/cashier/vo/TbOrderInfoVo.java index 62d1531f..139cb711 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/vo/TbOrderInfoVo.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/vo/TbOrderInfoVo.java @@ -15,8 +15,8 @@ */ package cn.ysk.cashier.vo; +import cn.ysk.cashier.pojo.order.TbOrderDetail; import lombok.Data; -import cn.ysk.cashier.pojo.order.TbCashierCart; import java.math.BigDecimal; import java.util.List; @@ -112,5 +112,5 @@ public class TbOrderInfoVo { private String remark; - private List cartList; + private List detailList; }