增加 创建 分批购活动 名称效验

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinListServiceImpl.java

@@ -115,6 +115,10 @@ public class GoblinListServiceImpl implements IGoblinListService {
         if (param.getItemParams().size() > 1) {
             return ResponseDto.failure("只能配置一个sku");
         }
+        //判断重名
+        if(mongoUtils.hasGoblinListDetailsVoByName(param.getName())){
+            return ResponseDto.failure("活动名称重复");
+        }
         String skuId = param.getItemParams().get(0).getSkuId();
         GoblinGoodsSkuInfoVo skuInfoVo = redisUtils.getGoodsSkuInfoVo(skuId);
         LocalDateTime st = LocalDateTime.parse(param.getTimeStart(), DTF_YMD_HMS);

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinMongoUtils.java

@@ -62,14 +62,14 @@ public class GoblinMongoUtils {
         HashMap<String, Object> info = CollectionUtil.mapStringObject();
         Pageable pageable = PageRequest.of(goblinGoodsAnticipateValueParam.getPageNum() - 1, 20, Sort.by(Sort.Direction.DESC, "createdDate"));
         Criteria criteria = Criteria.where("delTag").is(0).and("uid").is(uid);
-        if (goblinGoodsAnticipateValueParam.getType()!=null){
-            if (goblinGoodsAnticipateValueParam.getType()==1){
+        if (goblinGoodsAnticipateValueParam.getType() != null) {
+            if (goblinGoodsAnticipateValueParam.getType() == 1) {
                 //预约提醒
                 criteria = criteria.and("type").is(goblinGoodsAnticipateValueParam.getType());
-            }else if (goblinGoodsAnticipateValueParam.getType()==2){
+            } else if (goblinGoodsAnticipateValueParam.getType() == 2) {
                 //预约购买
                 criteria = criteria.and("type").is(2).and("peopleType").is(0);
-            }else if(goblinGoodsAnticipateValueParam.getType()==3){
+            } else if (goblinGoodsAnticipateValueParam.getType() == 3) {
                 //预约助力
                 criteria = criteria.and("type").is(2).and("peopleType").gt(0);
             }
@@ -207,14 +207,14 @@ public class GoblinMongoUtils {
     /**
      * 存入用户创建分享 不需要mongodb存储
      */
-    public void setGoblinGoodsAnticipateShareVo(GoblinGoodsAnticipateShareVo goblinGoodsAnticipateShareVo){
-        mongoTemplate.insert(goblinGoodsAnticipateShareVo,GoblinGoodsAnticipateShareVo.class.getSimpleName());
+    public void setGoblinGoodsAnticipateShareVo(GoblinGoodsAnticipateShareVo goblinGoodsAnticipateShareVo) {
+        mongoTemplate.insert(goblinGoodsAnticipateShareVo, GoblinGoodsAnticipateShareVo.class.getSimpleName());
     }
 
     /**
      * 根据创建id查询分享信息
      */
-    public GoblinGoodsAnticipateShareVo getShareVoBySid(String sid){
+    public GoblinGoodsAnticipateShareVo getShareVoBySid(String sid) {
         return mongoTemplate.findOne(Query.query(Criteria.where("sid").is(sid)),
                 GoblinGoodsAnticipateShareVo.class, GoblinGoodsAnticipateShareVo.class.getSimpleName());
     }
@@ -222,17 +222,18 @@ public class GoblinMongoUtils {
     /**
      * 分享id和助力人id 查询助力信息  不存mongodb
      */
-    public GoblinGoodsAnticipateHelpVo getHelpVo(String sid,String uid){
+    public GoblinGoodsAnticipateHelpVo getHelpVo(String sid, String uid) {
         return mongoTemplate.findOne(Query.query(Criteria.where("sid").is(sid).and("helpUid").is(uid)),
                 GoblinGoodsAnticipateHelpVo.class, GoblinGoodsAnticipateHelpVo.class.getSimpleName());
     }
 
     /**
      * 助力vo   之后删去不需要储存
+     *
      * @param goodsAnticipateHelpVo
      */
-    public void setHelpVo(GoblinGoodsAnticipateHelpVo goodsAnticipateHelpVo){
-        mongoTemplate.insert(goodsAnticipateHelpVo,GoblinGoodsAnticipateHelpVo.class.getSimpleName());
+    public void setHelpVo(GoblinGoodsAnticipateHelpVo goodsAnticipateHelpVo) {
+        mongoTemplate.insert(goodsAnticipateHelpVo, GoblinGoodsAnticipateHelpVo.class.getSimpleName());
     }
 
     /* ---------------------------------------- 平台分类数据源 ---------------------------------------- */
@@ -1171,7 +1172,7 @@ public class GoblinMongoUtils {
         if (spuName != null) {
             Query q1 = Query.query(Criteria.where("name").regex(".*" + spuName + ".*"));
             q1.fields().include("spuId");
-            List<String> spuIds = mongoTemplate.find(q1,GoblinGoodsInfoVo.class,GoblinGoodsInfoVo.class.getSimpleName()).stream().map(GoblinGoodsInfoVo::getSpuId).collect(Collectors.toList());
+            List<String> spuIds = mongoTemplate.find(q1, GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName()).stream().map(GoblinGoodsInfoVo::getSpuId).collect(Collectors.toList());
             criteriaCount = criteriaCount.and("spuId").in(spuIds);
         }
         //查询总数量
@@ -1620,9 +1621,9 @@ public class GoblinMongoUtils {
             criteria.and("name").regex(pattern);
         }
         if (StringUtils.isNotBlank(filterParam.getShelvesStatus())) {
-            if ("4".equals(filterParam.getShelvesStatus())){
+            if ("4".equals(filterParam.getShelvesStatus())) {
                 criteria.and("shelvesStatus").is("3").and("saleStartTime").gte(now());
-            }else {
+            } else {
                 criteria.and("shelvesStatus").is(filterParam.getShelvesStatus());
             }
         }
@@ -1650,10 +1651,10 @@ public class GoblinMongoUtils {
                         continue;
                     }
                     GoblinGoodsSkuInfoVo itemVo = redisUtils.getGoodsSkuInfoVo(skuIdItem);
-                    if("4".equals(filterParam.getShelvesStatus())) {
+                    if ("4".equals(filterParam.getShelvesStatus())) {
                         stock += redisUtils.getSkuAllStatusStockStatus4(itemVo);
-                    }else {
-                        stock += redisUtils.getSkuAllStatusStock(itemVo,null);
+                    } else {
+                        stock += redisUtils.getSkuAllStatusStock(itemVo, null);
                     }
                 }
                 mgtGoodsSkuListVo.setSurplusStock(stock);
@@ -1697,6 +1698,12 @@ public class GoblinMongoUtils {
         mongoTemplate.insert(vo, GoblinListDetailsVo.class.getSimpleName());
     }
 
+    public Boolean hasGoblinListDetailsVoByName(String name) {
+        Criteria criteria = Criteria.where("name").is(name);
+        Query query = Query.query(criteria);
+        return mongoTemplate.exists(query, GoblinListDetailsVo.class, GoblinListDetailsVo.class.getSimpleName());
+    }
+
     public void removeGoblinListDetailsVo(String listId) {
         mongoTemplate.remove(Query.query(Criteria.where("listId").is(listId)), GoblinListDetailsVo.class.getSimpleName());
     }