exit

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/dto/manage/GoblinGoodsAnticipateParam.java

@@ -32,6 +32,11 @@ public class GoblinGoodsAnticipateParam{
     /**
      * 预约名称
      */
+    @ApiModelProperty("预约名称")
     private String name;
 
+
+
+
+
 }

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

@@ -113,7 +113,8 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
 
             //mongodb新增
             goblinMongoUtils.setGoblinGoodsAnticipateVo(goodsAnticipateVo);
-            return ResponseDto.success();
+            //返回预约id
+            return ResponseDto.success(antId);
         }
         return ResponseDto.failure("参数有误");
     }
@@ -210,7 +211,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
     public ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
         if (list != null && list.size() > 0) {
             for (GoblinGoodsAnticipateValueParam vo : list) {
-                if (goblinRedisUtils.getAnticipate(vo.getAntId(), vo.getSkuId()))
+                if (goblinRedisUtils.getAnticipate(vo.getSkuId()))
                     return ResponseDto.failure("该预约已选择该sku");
             }
             list.forEach(item -> {
@@ -221,7 +222,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                 goodsAnticipateValueVo.setDelTag(0);
                 //redis消息
                 //redis标识存入该sku处于预约列表
-                goblinRedisUtils.setAnticipateValue(goodsAnticipateValueVo.getAntId(), goodsAnticipateValueVo.getSkuId());
+                goblinRedisUtils.setAnticipateValue(goodsAnticipateValueVo.getSkuId());
 
                 //保存mysql中间表
                 LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
@@ -257,13 +258,13 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                     //删除该sku关联
                     goblinMongoUtils.delAnticipateValueVo(goodsAnticipateValueVo);
                     //删除redis
-                    goblinRedisUtils.delAnticipateValue(goodsAnticipateValueVo.getAntId(), goodsAnticipateValueVo.getSkuId());
+                    goblinRedisUtils.delAnticipateValue(goodsAnticipateValueVo.getSkuId());
                     //删除mysql中的关联数据
                     sqlValue.add(new Object[]{
                             goodsAnticipateValueVo.getAntId(),
                             goodsAnticipateValueVo.getSkuId()
                     });
-                    sendRedis("goblin_goods_anticipate_value_delete_by_antId_and_skuId",sqlValue);
+                    sendRedis("goblin_goods_anticipate_value_delete_by_antId_and_skuId", sqlValue);
                 } else {
                     //保存mysql中间表
                     sqlValue.add(new Object[]{

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

@@ -164,6 +164,13 @@ public class GoblinMongoUtils {
      */
     public void delAnticipateValues(String antId){
         Query query = Query.query(Criteria.where("antId").is(antId));
+        //查询处所有的sku关联信息
+        List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues = getGoodsAnticipateValues(antId);
+        if (goodsAnticipateValues != null && goodsAnticipateValues.size()>0){
+            goodsAnticipateValues.forEach(item -> {
+               redisUtils.delAnticipateValue(item.getSkuId());
+            });
+        }
         mongoTemplate.remove(query, GoblinGoodsAnticipateValueVo.class.getSimpleName()).getDeletedCount();
     }
 

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

@@ -47,15 +47,15 @@ public class GoblinRedisUtils {
     /**
      * 该skuId已开启预约
      */
-    public void setAnticipateValue(String antId, String skuId){
-        redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID.concat(antId).concat(skuId),1);
+    public void setAnticipateValue(String skuId){
+        redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID.concat(skuId),1);
     }
 
     /**
      * 删除skuId已开启预约
      */
-    public void delAnticipateValue(String antId, String skuId){
-        redisUtil.del(GoblinRedisConst.ANTICIPATE_SKUID.concat(antId).concat(skuId));
+    public void delAnticipateValue(String skuId){
+        redisUtil.del(GoblinRedisConst.ANTICIPATE_SKUID.concat(skuId));
     }
 
 
@@ -63,8 +63,8 @@ public class GoblinRedisUtils {
     /**
      * 获取关联
      */
-    public boolean getAnticipate(String antId, String skuId){
-       return redisUtil.get(GoblinRedisConst.ANTICIPATE_SKUID.concat(antId).concat(skuId)) != null;
+    public boolean getAnticipate(String skuId){
+       return redisUtil.get(GoblinRedisConst.ANTICIPATE_SKUID.concat(skuId)) != null;
     }
 
     public GoblinGoodAnticipateUserVo getUserAboutAut(String skuId, String uid) {