订单信息发生变化,清除缓存

This commit is contained in:
2023-04-15 09:36:02 +08:00
parent c5f017c478
commit 6e27b782d0
3 changed files with 26 additions and 14 deletions

View File

@@ -65,6 +65,9 @@ public interface IOrderBasicInfoService {
*/
int updateOrderBasicInfo(OrderBasicInfo orderBasicInfo);
// 清订单缓存
void cleanCacheByOrderCode(String orderCode, String transactionCode);
/**
* 批量删除订单
*

View File

@@ -388,13 +388,24 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
@Override
public int updateOrderBasicInfo(OrderBasicInfo orderBasicInfo) {
// 清缓存
String redisKey = CacheConstants.GET_ORDER_INFO_BY_ORDER_CODE + orderBasicInfo.getOrderCode();
redisCache.deleteObject(redisKey);
String redisKey2 = CacheConstants.GET_ORDER_INFO_BY_TRANSACTION_CODE + orderBasicInfo.getTransactionCode();
redisCache.deleteObject(redisKey2);
this.cleanCacheByOrderCode(orderBasicInfo.getOrderCode(), orderBasicInfo.getTransactionCode());
return orderBasicInfoMapper.updateOrderBasicInfo(orderBasicInfo);
}
@Override
public void cleanCacheByOrderCode(String orderCode, String transactionCode) {
List<String> keys = Lists.newArrayList();
if (StringUtils.isNotBlank(orderCode)) {
keys.add(CacheConstants.GET_ORDER_INFO_BY_ORDER_CODE + orderCode);
}
if (StringUtils.isNotBlank(transactionCode)) {
keys.add(CacheConstants.GET_ORDER_INFO_BY_TRANSACTION_CODE + transactionCode);
}
if (CollectionUtils.isNotEmpty(keys)) {
redisCache.deleteObject(keys);
}
}
/**
* 批量删除订单
*
@@ -969,6 +980,10 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
.collect(Collectors.toList());
// 修改订单状态
updateOrderStatusById(orderIdList, OrderStatusEnum.ORDER_CLOSE_TIMEOUT.getValue());
for (OrderBasicInfo orderBasicInfo : orderList) {
this.cleanCacheByOrderCode(orderBasicInfo.getOrderCode(), orderBasicInfo.getTransactionCode());
}
}
return orderList.size();
}