exit

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

@@ -210,7 +210,9 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                     state
             });
             sendRedis("goblin_goods_anticipate_user", sqlValue);
-        } else {
+            goblinRedisUtils.setSkuIdPeople(skuId, state);
+        }
+        if (state.equals(GoblinGoodAnticipateUserVo.STATE_INVALID)&&userVo != null) {
             //mysql删除用户记录
             sqlValue.add(new Object[]{
                     uid,
@@ -219,9 +221,8 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
             sendRedis("goblin_goods_anticipate_user_update", sqlValue);
             //删除缓存  redis和mongodb
             goblinRedisUtils.delUserAboutSku(skuId, uid);
-        }
             goblinRedisUtils.setSkuIdPeople(skuId, state);
-
+        }
         return ResponseDto.success();
     }
 

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

@@ -64,7 +64,7 @@ public class GoblinMongoUtils {
         Pageable pageable = PageRequest.of(goblinGoodsAnticipateValueParam.getPageNum() - 1, goblinGoodsAnticipateValueParam.getPageSize(), Sort.by(Sort.Direction.DESC,"createdDate"));
         Criteria criteria = Criteria.where("delTag").is(0);
         if (StringUtils.isNotBlank(goblinGoodsAnticipateValueParam.getName())) {
-            criteria = criteria.and("name").is(goblinGoodsAnticipateValueParam.getName());
+            criteria = criteria.and("skuName").is(goblinGoodsAnticipateValueParam.getName());
         }
         if (StringUtils.isNotBlank(goblinGoodsAnticipateValueParam.getCreatedDate())) {
             LocalDateTime createDt = DateUtil.Formatter.yyyy_MM_dd.parse(goblinGoodsAnticipateValueParam.getCreatedDate());