记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 9190389d authored by 张国柄's avatar 张国柄
Browse files
Options

~admin:编辑、删除标签，同步更新、删除关联商品数据;

parent a383e3b9
Hide whitespace changes
Inline Side-by-side
Showing with 75 additions and 10 deletions
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/service/impl/GoblinSelfGoodsTagServiceImpl.java
View file @ 9190389d
......@@ -4,12 +4,16 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.client.admin.zhengzai.goblin.service.IGoblinSelfTagService;
import com.liquidnet.common.cache.redis.util.AbstractRedisUtil;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.common.exception.LiquidnetServiceException;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.goblin.constant.GoblinRedisConst;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodsInfoVo;
import com.liquidnet.service.goblin.dto.vo.GoblinSelfTagVo;
import com.liquidnet.service.goblin.entity.GoblinGoodsTag;
import com.liquidnet.service.goblin.entity.GoblinSelfTag;
import com.liquidnet.service.goblin.mapper.GoblinGoodsTagMapper;
import com.liquidnet.service.goblin.mapper.GoblinSelfTagMapper;
import com.mongodb.client.result.UpdateResult;
import lombok.extern.slf4j.Slf4j;
......@@ -20,8 +24,10 @@ import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import java.util.List;
import java.util.stream.Collectors;
/**
* <p>
......@@ -40,6 +46,8 @@ public class GoblinSelfGoodsTagServiceImpl extends ServiceImpl<GoblinSelfTagMapp
private RedisDataSourceUtil redisDataSourceUtil;
@Autowired
private GoblinSelfTagMapper goblinSelfTagMapper;
@Autowired
private GoblinGoodsTagMapper goblinGoodsTagMapper;
@Transactional
@Override
......@@ -70,15 +78,42 @@ public class GoblinSelfGoodsTagServiceImpl extends ServiceImpl<GoblinSelfTagMapp
Query.query(Criteria.where("tagId").is(selfTag.getTagId()).and("tagBelong").is(selfTag.getTagBelong()).and("delFlg").is("0")).getQueryObject(),
Update.update("tagType", selfTag.getTagType()).set("tagName", selfTag.getTagName()).set("tagPic", selfTag.getTagPic()).getUpdateObject()
);
// log.info("店铺管理:标签管理:编辑[selfTag={},MONGO.UpdateResult={}]", JsonUtils.toJson(selfTag), JsonUtils.toJson(updateResult));
if (updateResult.getModifiedCount() <= 0) {
log.error("店铺管理:标签管理:编辑:MDB更新失败[selfTag={}]", JsonUtils.toJson(selfTag));
throw new LiquidnetServiceException();
}
redisDataSourceUtil.getRedisGoblinUtil().del(GoblinRedisConst.BASIC_SELF_EXTAG);
log.info("店铺管理:标签管理:编辑[selfTag={},MONGO.UpdateResult={}]", JsonUtils.toJson(selfTag), JsonUtils.toJson(updateResult));
AbstractRedisUtil redisGoblinUtil = redisDataSourceUtil.getRedisGoblinUtil();
redisGoblinUtil.del(GoblinRedisConst.BASIC_SELF_EXTAG);
try {
boolean isTagFlg = selfTag.getTagBelong().equals("0");
String subDocName = isTagFlg ? "tagVoList" : "extagVoList";
Query query = Query.query(Criteria.where(subDocName.concat(".tagId")).is(selfTag.getTagId()));
query.fields().include("spuId");
List<GoblinGoodsInfoVo> matchedGoodsInfoVoList = mongoTemplate.find(query, GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName());
if (!CollectionUtils.isEmpty(matchedGoodsInfoVoList)) {
List<String> matchedSpuIdList = matchedGoodsInfoVoList.stream().map(GoblinGoodsInfoVo::getSpuId).collect(Collectors.toList());
Update update = Update.update(subDocName.concat(".$.tagName"), selfTag.getTagName())
.set(subDocName.concat(".$.tagPic"), selfTag.getTagPic());
if (!isTagFlg) {
update.set(subDocName.concat(".$.tagType"), selfTag.getTagType());
}
UpdateResult updateRelateGoodsResult = mongoTemplate.updateMulti(Query.query(Criteria.where(subDocName.concat(".tagId")).is(selfTag.getTagId())),
update, GoblinGoodsInfoVo.class.getSimpleName());
log.info("店铺管理:标签管理:编辑:MDB更新关联商品[匹配={},更新={}]",
updateRelateGoodsResult.getMatchedCount(), updateRelateGoodsResult.getModifiedCount());
if (updateRelateGoodsResult.getModifiedCount() > 0) {
matchedSpuIdList.forEach(spuId -> {
redisGoblinUtil.del(GoblinRedisConst.BASIC_GOODS.concat(spuId));
redisGoblinUtil.del(GoblinRedisConst.BASIC_GOODS_UNSHELVES.concat(spuId));
});
}
}
} catch (Exception e) {
log.error("店铺管理:标签管理:编辑:更新关联商品异常[selfTag={}]", JsonUtils.toJson(selfTag), e);
}
return true;
}
return false;
......@@ -99,16 +134,46 @@ public class GoblinSelfGoodsTagServiceImpl extends ServiceImpl<GoblinSelfTagMapp
Update.update("delFlg", "1"),
GoblinSelfTagVo.class.getSimpleName()
);
// log.info("店铺管理:标签管理:删除[tagIdArr={},tagBelong={},MONGO.UpdateResult={}]", JsonUtils.toJson(tagIdArr), tagBelong, JsonUtils.toJson(updateResult));
if (updateResult.getModifiedCount() <= 0) {
log.error("店铺管理:标签管理:删除:MDB更新失败[tagBelong={},tagIdArr={}]", tagBelong, JsonUtils.toJson(tagIdArr));
throw new LiquidnetServiceException();
}
redisDataSourceUtil.getRedisGoblinUtil().del(GoblinRedisConst.BASIC_SELF_EXTAG);
log.info("店铺管理:标签管理:删除[tagIdArr={},tagBelong={},MONGO.UpdateResult={}]", JsonUtils.toJson(tagIdArr), tagBelong, JsonUtils.toJson(updateResult));
AbstractRedisUtil redisGoblinUtil = redisDataSourceUtil.getRedisGoblinUtil();
redisGoblinUtil.del(GoblinRedisConst.BASIC_SELF_EXTAG);
try {
GoblinGoodsTag updateRelateGoods = new GoblinGoodsTag();
updateRelateGoods.setDelFlg("1");
int updateRelateGoodsCount = goblinGoodsTagMapper.update(updateRelateGoods, Wrappers.lambdaUpdate(GoblinGoodsTag.class)
.in(GoblinGoodsTag::getTagId, tagIdArr).eq(GoblinGoodsTag::getTagBelong, tagBelong).eq(GoblinGoodsTag::getDelFlg, "0"));
String subDocName = tagBelong.equals("0") ? "tagVoList" : "extagVoList";
Query query = Query.query(Criteria.where(subDocName.concat(".tagId")).in(tagIdArr));
query.fields().include("spuId");
List<GoblinGoodsInfoVo> matchedGoodsInfoVoList = mongoTemplate.find(query, GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName());
if (!CollectionUtils.isEmpty(matchedGoodsInfoVoList)) {
List<String> matchedSpuIdList = matchedGoodsInfoVoList.stream().map(GoblinGoodsInfoVo::getSpuId).collect(Collectors.toList());
UpdateResult updateRelateGoodsResult = mongoTemplate.updateMulti(Query.query(Criteria.where("spuId").in(matchedSpuIdList)),
new Update().pull(subDocName, Query.query(Criteria.where("tagId").in(tagIdArr))),
GoblinGoodsInfoVo.class.getSimpleName());
log.info("店铺管理:标签管理:删除:MDB更新关联商品[匹配={},更新={},MYSQL更新={}]",
updateRelateGoodsResult.getMatchedCount(), updateRelateGoodsResult.getModifiedCount(), updateRelateGoodsCount);
if (updateRelateGoodsResult.getModifiedCount() > 0) {
matchedSpuIdList.forEach(spuId -> {
redisGoblinUtil.del(GoblinRedisConst.BASIC_GOODS.concat(spuId));
redisGoblinUtil.del(GoblinRedisConst.BASIC_GOODS_UNSHELVES.concat(spuId));
});
}
}
} catch (Exception e) {
log.error("店铺管理:标签管理:删除:更新关联商品异常[tagBelong={},tagIdArr={}]", tagBelong, JsonUtils.toJson(tagIdArr), e);
}
return true;
}
return rmvResultFlg;
return false;
}
@Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment