热卖列表页返回vip标识

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinPerformancesServiceImpl.java

 package com.liquidnet.service.kylin.service.impl;
 
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.liquidnet.commons.lang.CommonConst;
-import com.liquidnet.commons.lang.constant.LnsEnum;
-import com.liquidnet.commons.lang.constant.UpushTargetType;
 import com.liquidnet.commons.lang.util.*;
-import com.liquidnet.commons.lang.util.upush.AndroidNotification;
-import com.liquidnet.commons.lang.util.upush.PushClient;
-import com.liquidnet.commons.lang.util.upush.android.AndroidBroadcast;
-import com.liquidnet.commons.lang.util.upush.ios.IOSBroadcast;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.UserPathDto;
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient;
 import com.liquidnet.service.goblin.dto.vo.GoblinGoodsSkuInfoVo;
 import com.liquidnet.service.goblin.dto.vo.NoticeGoblinMixDetailsVo;
 import com.liquidnet.service.goblin.dto.vo.SmileUserVO;
 import com.liquidnet.service.kylin.constant.KylinPerformanceStatusEnum;
-import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.param.KylinCandyItemParam;
 import com.liquidnet.service.kylin.dto.param.KylinPerformanceSubscribeParam;
@@ -31,7 +24,6 @@ import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketExpressModuleVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.returns.PayDetailVo;
-import com.liquidnet.service.kylin.entity.AdminUpush;
 import com.liquidnet.service.kylin.service.IKylinPerformancesService;
 import com.liquidnet.service.kylin.utils.DataUtils;
 import com.liquidnet.service.kylin.utils.ObjectUtil;
@@ -41,7 +33,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.core.env.Environment;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
@@ -56,7 +48,6 @@ import org.springframework.util.MultiValueMap;
 
 import javax.servlet.http.HttpServletRequest;
 import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -81,6 +72,10 @@ public class KylinPerformancesServiceImpl implements IKylinPerformancesService {
     @Autowired
     private QueueUtils queueUtils;
 
+    @Autowired
+    @Lazy
+    private FeignAdamBaseClient feignAdamBaseClient;
+
     @Value("${liquidnet.service.smile.url}")
     private String smileUrl;
 
@@ -223,9 +218,25 @@ public class KylinPerformancesServiceImpl implements IKylinPerformancesService {
         newList.put("threeDayNftList", threeDayNftList);
         newList.put("toDayCombinationList", toDayCombinationList);
         newList.put("threeDayCombinationList", threeDayCombinationList);
+        newList.put("isVip", isVip());
         return newList;
     }
 
+    private boolean isVip() {
+        final String currentUid = CurrentUtil.getCurrentUid();
+        if (!StringUtils.isBlank(currentUid)) {
+            try {
+                ResponseDto<Boolean> member = feignAdamBaseClient.isMember(currentUid);
+                if (member.isSuccess()) {
+                    return member.getData();
+                }
+            } catch (Exception e) {
+                log.error("获取用户会员状态错误。", e);
+            }
+        }
+        return false;
+    }
+
     public HashMap<String, Object> setNoticeIds() {
         return dataUtils.setNoticeIds();
     }