exit

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

@@ -189,9 +189,22 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
         sendRedis("goblin_goods_anticipate_value_delete", sqlValue);
         //删除mongodb
         goblinMongoUtils.delGoodsAnticipateValueVo(skuId);
+        //删除用户预约sku相关的数据
+        delUserBySkuId(skuId);
         return ResponseDto.success();
     }
 
+    private void delUserBySkuId(String skuId) {
+        //删除redis 和mongodb
+        goblinMongoUtils.delUserBySkuId(skuId);
+        //数据库修改  用户预约过该skuId的表字段全部修改未 1
+        LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
+        sqlValue.add(new Object[]{
+                skuId
+        });
+        sendRedis("goblin_goods_anticipate_user_update_sku",sqlValue);
+    }
+
     @Override
     public ResponseDto<Object> userAbout(String skuId, String uid, String phone, Integer state) {
         //查询该用户是否预

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

@@ -3,6 +3,7 @@ package com.liquidnet.service.goblin.util;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.service.base.PagedResult;
+import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.constant.GoblinStatusConst;
 import com.liquidnet.service.goblin.dto.manage.*;
 import com.liquidnet.service.goblin.dto.manage.vo.GoblinGoodsAnticipateValueVo;
@@ -125,8 +126,6 @@ public class GoblinMongoUtils {
         mongoTemplate.remove(query, GoblinGoodsAnticipateValueVo.class.getSimpleName()).getDeletedCount();
     }
 
-
-
     /**
      * 根据antId修改  预约人数
      */
@@ -136,8 +135,6 @@ public class GoblinMongoUtils {
         mongoTemplate.updateFirst(query, update, GoblinGoodsAnticipateVo.class.getSimpleName());
     }
 
-
-
     /**
      * 根据活动id查询关联
      */
@@ -155,6 +152,17 @@ public class GoblinMongoUtils {
         mongoTemplate.remove(query, GoblinGoodsAnticipateVo.class.getSimpleName()).getDeletedCount();
     }
 
+    public void delUserBySkuId(String skuId) {
+        Query query = Query.query(Criteria.where("skuId").is(skuId));
+        List<GoblinGoodAnticipateUserVo> goblinGoodAnticipateUserVos = mongoTemplate.find(query, GoblinGoodAnticipateUserVo.class, GoblinGoodAnticipateUserVo.class.getSimpleName());
+        if (goblinGoodAnticipateUserVos.size()>0){
+            goblinGoodAnticipateUserVos.forEach(goblinGoodAnticipateUserVo ->{
+                redisUtils.del(GoblinRedisConst.USER_ANTICIPATE_STATE.concat(goblinGoodAnticipateUserVo.getSkuId()).concat(goblinGoodAnticipateUserVo.getUid()));
+            });
+            mongoTemplate.remove(query,GoblinGoodAnticipateUserVo.class.getSimpleName()).getDeletedCount();
+        }
+    }
+
     /**
      * 根据预约ID获取预约详情
      */

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/resources/sqlmap.properties

@@ -140,3 +140,4 @@ goblin_goods_anticipate_value_update_proper=UPDATE goblin_goods_anticipate_value
 goblin_goods_anticipate_value_delete=UPDATE goblin_goods_anticipate_value SET `del_tag` = 1,update_date = NOW()  WHERE sku_id = ? 
 goblin_goods_anticipate_user=INSERT INTO goblin_goods_anticipate_user(uid,sku_id,phone,state) VALUES(?,?,?,?) 
 goblin_goods_anticipate_user_update=UPDATE goblin_goods_anticipate_user SET state = 1 WHERE uid = ? AND sku_id = ? 
+goblin_goods_anticipate_user_update_sku=UPDATE goblin_goods_anticipate_user SET state = 1 WHERE sku_id = ?