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

Commit b5277267 authored by 周焕's avatar 周焕

Merge branch 'pre' into 'master'

Pre

See merge request !200
parents e8b557d5 86efde6d
...@@ -463,8 +463,8 @@ public class GoblinFrontServiceImpl implements GoblinFrontService { ...@@ -463,8 +463,8 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
// query.addCriteria(Criteria.where("name").regex(pattern).and("spuAppear").is("0").and("delFlg").is("0").and("shelvesStatus").is("3")); // query.addCriteria(Criteria.where("name").regex(pattern).and("spuAppear").is("0").and("delFlg").is("0").and("shelvesStatus").is("3"));
query.addCriteria(Criteria.where("spuAppear").is("0").and("delFlg").is("0").and("shelvesStatus").is("3").and("marketId").is(null)); query.addCriteria(Criteria.where("spuAppear").is("0").and("delFlg").is("0").and("shelvesStatus").is("3").and("marketId").is(null));
query.with(Sort.by( query.with(Sort.by(
Sort.Order.desc("count"), //Sort.Order.desc("count"),
Sort.Order.desc("createdAt") Sort.Order.desc("shelvesAt")
)); ));
List<GoblinGoodsInfoVo> list = mongoTemplate.find(query, GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName()); List<GoblinGoodsInfoVo> list = mongoTemplate.find(query, GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName());
ArrayList<GoblinGoodsInfoListVo> list1=ObjectUtil.getGoblinGoodsInfoListVo(); ArrayList<GoblinGoodsInfoListVo> list1=ObjectUtil.getGoblinGoodsInfoListVo();
...@@ -689,7 +689,7 @@ public class GoblinFrontServiceImpl implements GoblinFrontService { ...@@ -689,7 +689,7 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
if(sortType==1){ if(sortType==1){
sortName = Sort.by(Sort.Direction.DESC, "shelvesAt"); sortName = Sort.by(Sort.Direction.DESC, "shelvesAt");
}else if(sortType==2){ }else if(sortType==2){
sortName = Sort.by(Sort.Direction.DESC, "count"); sortName = Sort.by(Sort.Direction.DESC, "count","createdAt");
}else if(sortType==3){ }else if(sortType==3){
Document source = new Document(); Document source = new Document();
source.put("locale", "zh"); source.put("locale", "zh");
......
...@@ -105,6 +105,21 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService { ...@@ -105,6 +105,21 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
String pre = GoblinStatusConst.MarketPreStatus.getPre(skuId); String pre = GoblinStatusConst.MarketPreStatus.getPre(skuId);
int surplusGeneral = redisUtils.decrSkuStock(pre, skuId, number); int surplusGeneral = redisUtils.decrSkuStock(pre, skuId, number);
skuAndPreListAndNumber.add(skuId + "," + pre + "," + number); skuAndPreListAndNumber.add(skuId + "," + pre + "," + number);
// 判断库存
GoblinGoodsSkuInfoVo skuVo = redisUtils.getGoodsSkuInfoVo(skuParam.getSkuId());
int limitCount = skuVo.getBuyLimit() == 0 ? Integer.MAX_VALUE : skuVo.getBuyLimit();
//判断限购
if (orderUtils.noZhengzaiOrder(uid)) {
String res1 = orderUtils.judgeOrderLimit(uid, skuParam.getSkuId(), skuParam.getNumber(), limitCount);
if (!res1.equals("")) {
throw new Exception("已超出限购数量");
}
//权限限购
Boolean res2 = orderUtils.judgeOrderRose(isMember, skuParam.getSkuId(), StringUtils.defaultString(((String) CurrentUtil.getTokenClaims().get("mobile")), ""), Integer.parseInt(skuVo.getBuyFactor()));
if (!res2) {
throw new Exception("无权购买");
}
}
//库存回滚 //库存回滚
if (surplusGeneral < 0) { if (surplusGeneral < 0) {
return orderUtils.orderException(skuAndPreListAndNumber, platformCodeList, storeCodeList, uid, "库存不足"); return orderUtils.orderException(skuAndPreListAndNumber, platformCodeList, storeCodeList, uid, "库存不足");
...@@ -219,20 +234,6 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService { ...@@ -219,20 +234,6 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
if (!(skuVo.getStatus().equals("3") && skuVo.getShelvesStatus().equals("3")) || skuVo.getDelFlg().equals("1")) { if (!(skuVo.getStatus().equals("3") && skuVo.getShelvesStatus().equals("3")) || skuVo.getDelFlg().equals("1")) {
throw new Exception("不可购买"); throw new Exception("不可购买");
} }
// 判断库存
int limitCount = skuVo.getBuyLimit() == 0 ? Integer.MAX_VALUE : skuVo.getBuyLimit();
//判断限购
if (orderUtils.noZhengzaiOrder(uid)) {
String res1 = orderUtils.judgeOrderLimit(uid, skuParam.getSkuId(), skuParam.getNumber(), limitCount);
if (!res1.equals("")) {
throw new Exception("已超出限购数量");
}
//权限限购
Boolean res2 = orderUtils.judgeOrderRose(isMember, skuParam.getSkuId(), StringUtils.defaultString(((String) CurrentUtil.getTokenClaims().get("mobile")), ""), Integer.parseInt(skuVo.getBuyFactor()));
if (!res2) {
throw new Exception("无权购买");
}
}
marketId = spuVo.getMarketId(); marketId = spuVo.getMarketId();
marketType = pre; marketType = pre;
skuName = skuName.concat(skuVo.getName()).concat(","); skuName = skuName.concat(skuVo.getName()).concat(",");
......
package com.liquidnet.service.platform.service.impl.goblin; package com.liquidnet.service.platform.service.impl.goblin;
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;
import com.liquidnet.service.platform.utils.QueueUtils; import com.liquidnet.service.platform.utils.QueueUtils;
...@@ -59,6 +60,9 @@ public class SpuGoodsInfoImpl { ...@@ -59,6 +60,9 @@ public class SpuGoodsInfoImpl {
obj); obj);
} }
log.info("执行完毕"); log.info("执行完毕");
goblinRedisUtils.del(GoblinRedisConst.SELECT_GOODS_SPUIDS);
goblinRedisUtils.del(GoblinRedisConst.SELECT_GOODS_PAGE1);
goblinRedisUtils.del(GoblinRedisConst.SELECT_GOODS_SPUIDS_ISHAVE);
return true; return true;
} }
} }
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