caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of gitee.com:beijing_hongye_huicheng/lilishop

Browse Source
This commit is contained in:
Chopper 2022-06-02 09:16:46 +08:00
commit 519a608316
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
framework/src/main/java/cn/lili/modules/goods/serviceimpl/GoodsServiceImpl.java
View File

@ -278,6 +278,7 @@ public class GoodsServiceImpl extends ServiceImpl<GoodsMapper, Goods> implements
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean auditGoods(List<String> goodsIds, GoodsAuthEnum goodsAuthEnum) { public boolean auditGoods(List<String> goodsIds, GoodsAuthEnum goodsAuthEnum) {
List<String> goodsCacheKeys = new ArrayList<>();
boolean result = false; boolean result = false;
for (String goodsId : goodsIds) { for (String goodsId : goodsIds) {
Goods goods = this.checkExist(goodsId); Goods goods = this.checkExist(goodsId);
@ -285,12 +286,13 @@ public class GoodsServiceImpl extends ServiceImpl<GoodsMapper, Goods> implements
result = this.updateById(goods); result = this.updateById(goods);
goodsSkuService.updateGoodsSkuStatus(goods); goodsSkuService.updateGoodsSkuStatus(goods);
//删除之前的缓存 //删除之前的缓存
cache.remove(CachePrefix.GOODS.getPrefix() + goodsId); goodsCacheKeys.add(CachePrefix.GOODS.getPrefix() + goodsId);
//商品审核消息 //商品审核消息
String destination = rocketmqCustomProperties.getGoodsTopic() + ":" + GoodsTagsEnum.GOODS_AUDIT.name(); String destination = rocketmqCustomProperties.getGoodsTopic() + ":" + GoodsTagsEnum.GOODS_AUDIT.name();
//发送mq消息 //发送mq消息
rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(goods), RocketmqSendCallbackBuilder.commonCallback()); rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(goods), RocketmqSendCallbackBuilder.commonCallback());
} }
cache.multiDel(goodsCacheKeys);
return result; return result;
} }
@ -382,14 +384,15 @@ public class GoodsServiceImpl extends ServiceImpl<GoodsMapper, Goods> implements
LambdaQueryWrapper<Goods> queryWrapper = this.getQueryWrapperByStoreAuthority(); LambdaQueryWrapper<Goods> queryWrapper = this.getQueryWrapperByStoreAuthority();
queryWrapper.in(Goods::getId, goodsIds); queryWrapper.in(Goods::getId, goodsIds);
List<Goods> goodsList = this.list(queryWrapper); List<Goods> goodsList = this.list(queryWrapper);
List<String> goodsCacheKeys = new ArrayList<>();
for (Goods goods : goodsList) { for (Goods goods : goodsList) {
//修改SKU状态 //修改SKU状态
goodsSkuService.updateGoodsSkuStatus(goods); goodsSkuService.updateGoodsSkuStatus(goods);
cache.remove(CachePrefix.GOODS.getPrefix() + goods.getId()); goodsCacheKeys.add(CachePrefix.GOODS.getPrefix() + goods.getId());
} }
//删除缓存
cache.multiDel(goodsCacheKeys);
this.deleteEsGoods(goodsIds); this.deleteEsGoods(goodsIds);
return true; return true;
} }
@ -494,12 +497,12 @@ public class GoodsServiceImpl extends ServiceImpl<GoodsMapper, Goods> implements
* @param goodsList 商品列表 * @param goodsList 商品列表
*/ */
private void updateGoodsStatus(List<String> goodsIds, GoodsStatusEnum goodsStatusEnum, List<Goods> goodsList) { private void updateGoodsStatus(List<String> goodsIds, GoodsStatusEnum goodsStatusEnum, List<Goods> goodsList) {
List<String> goodsCacheKeys = new ArrayList<>();
for (Goods goods : goodsList) { for (Goods goods : goodsList) {
if (GoodsStatusEnum.DOWN.equals(goodsStatusEnum)) { goodsCacheKeys.add(CachePrefix.GOODS.getPrefix() + goods.getId());
cache.remove(CachePrefix.GOODS.getPrefix() + goods.getId());
}
goodsSkuService.updateGoodsSkuStatus(goods); goodsSkuService.updateGoodsSkuStatus(goods);
} }
cache.multiDel(goodsCacheKeys);
if (GoodsStatusEnum.DOWN.equals(goodsStatusEnum)) { if (GoodsStatusEnum.DOWN.equals(goodsStatusEnum)) {
this.deleteEsGoods(goodsIds); this.deleteEsGoods(goodsIds);