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

Commit d1910a2f authored by 张国柄's avatar 张国柄

~SPU销量更新逻辑调整;

parent 57a9b479
package com.liquidnet.service.platform.service.impl.goblin; package com.liquidnet.service.platform.service.impl.goblin;
import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.service.goblin.constant.GoblinRedisConst; import com.liquidnet.service.goblin.constant.GoblinRedisConst;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodsInfoVo; import com.liquidnet.service.goblin.dto.vo.GoblinGoodsInfoVo;
import com.liquidnet.service.platform.utils.GoblinRedisUtils; import com.liquidnet.service.platform.utils.GoblinRedisUtils;
...@@ -13,6 +14,7 @@ import org.springframework.data.mongodb.core.query.Criteria; ...@@ -13,6 +14,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List; import java.util.List;
...@@ -48,13 +50,16 @@ public class SpuGoodsInfoImpl { ...@@ -48,13 +50,16 @@ public class SpuGoodsInfoImpl {
for(GoblinGoodsInfoVo goblinGoodsInfoVo:voList){ for(GoblinGoodsInfoVo goblinGoodsInfoVo:voList){
//查询数量 //查询数量
Integer counts=goblinRedisUtils.getSpuSaleCount(goblinGoodsInfoVo.getSpuId()); Integer counts=goblinRedisUtils.getSpuSaleCount(goblinGoodsInfoVo.getSpuId());
HashMap<String, Object> updateMdbMap = CollectionUtil.mapStringObject();
if(counts==null){ if(counts==null){
goblinGoodsInfoVo.setCount(0); updateMdbMap.put("count", 0);
// goblinGoodsInfoVo.setCount(0);
}else{ }else{
goblinGoodsInfoVo.setCount(counts); updateMdbMap.put("count", counts);
// goblinGoodsInfoVo.setCount(counts);
} }
//修改mongodb //修改mongodb
BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(goblinGoodsInfoVo)); BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(updateMdbMap));
mongoTemplate.getCollection(GoblinGoodsInfoVo.class.getSimpleName()).updateOne( mongoTemplate.getCollection(GoblinGoodsInfoVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("spuId").is(goblinGoodsInfoVo.getSpuId())).getQueryObject(), Query.query(Criteria.where("spuId").is(goblinGoodsInfoVo.getSpuId())).getQueryObject(),
obj); obj);
......
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