查询订单实时数据 方法加缓存

This commit is contained in:
2023-06-02 16:51:23 +08:00
parent 75f1822635
commit 7cae317501
2 changed files with 34 additions and 2 deletions

View File

@@ -1,8 +1,11 @@
package com.jsowell.pile.service.impl;
import com.jsowell.common.constant.CacheConstants;
import com.jsowell.common.core.redis.RedisCache;
import com.jsowell.pile.domain.OrderMonitorData;
import com.jsowell.pile.mapper.OrderMonitorDataMapper;
import com.jsowell.pile.service.OrderMonitorDataService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@@ -13,6 +16,9 @@ public class OrderMonitorDataServiceImpl implements OrderMonitorDataService {
@Resource
private OrderMonitorDataMapper orderMonitorDataMapper;
@Autowired
private RedisCache redisCache;
@Override
public int deleteByPrimaryKey(Integer id) {
return orderMonitorDataMapper.deleteByPrimaryKey(id);
@@ -35,12 +41,34 @@ public class OrderMonitorDataServiceImpl implements OrderMonitorDataService {
@Override
public OrderMonitorData selectByOrderCode(String orderCode) {
return orderMonitorDataMapper.selectByOrderCode(orderCode);
String redisKey = CacheConstants.ORDER_MONITOR_DATA_BY_ORDER_CODE + orderCode;
OrderMonitorData orderMonitorData = redisCache.getCacheObject(redisKey);
if (orderMonitorData == null) {
orderMonitorData = orderMonitorDataMapper.selectByOrderCode(orderCode);
if (orderMonitorData != null) {
// 放缓存
redisCache.setCacheObject(redisKey, orderMonitorData, CacheConstants.cache_expire_time_12h);
String redisKey2 = CacheConstants.ORDER_MONITOR_DATA_BY_TRANSACTION_CODE + orderMonitorData.getTransactionCode();
redisCache.setCacheObject(redisKey2, orderMonitorData, CacheConstants.cache_expire_time_12h);
}
}
return orderMonitorData;
}
@Override
public OrderMonitorData selectByTransactionCode(String transactionCode) {
return orderMonitorDataMapper.selectByTransactionCode(transactionCode);
String redisKey = CacheConstants.ORDER_MONITOR_DATA_BY_TRANSACTION_CODE + transactionCode;
OrderMonitorData orderMonitorData = redisCache.getCacheObject(redisKey);
if (orderMonitorData == null) {
orderMonitorData = orderMonitorDataMapper.selectByTransactionCode(transactionCode);
if (orderMonitorData != null) {
// 放缓存
redisCache.setCacheObject(redisKey, orderMonitorData, CacheConstants.cache_expire_time_12h);
String redisKey2 = CacheConstants.ORDER_MONITOR_DATA_BY_ORDER_CODE + orderMonitorData.getOrderCode();
redisCache.setCacheObject(redisKey2, orderMonitorData, CacheConstants.cache_expire_time_12h);
}
}
return orderMonitorData;
}
}