增加家口 根据券id集合获取数据

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/KylinCandyParam.java

+package com.liquidnet.service.kylin.dto.param;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+@ApiModel
+@Data
+public class KylinCandyParam implements Serializable, Cloneable {
+
+    @ApiModelProperty(value = "券id集合")
+    private List<String> couponList;
+    @ApiModelProperty(value = "巡演id")
+    private String roadShowId;
+
+    private static final KylinCandyParam obj = new KylinCandyParam();
+
+    public static KylinCandyParam getNew() {
+        try {
+            return (KylinCandyParam) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinCandyParam();
+        }
+    }
+
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/mongo/KylinCandyVo.java

+package com.liquidnet.service.kylin.dto.vo.mongo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@ApiModel
+@Data
+public class KylinCandyVo implements Serializable, Cloneable {
+
+    @ApiModelProperty(value = "券id")
+    private String couponId;
+    @ApiModelProperty(value = "巡演id")
+    private String roadShowId;
+
+    private static final KylinCandyVo obj = new KylinCandyVo();
+
+    public static KylinCandyVo getNew() {
+        try {
+            return (KylinCandyVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinCandyVo();
+        }
+    }
+
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinPerformancesService.java

 package com.liquidnet.service.kylin.service;
 
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCandyVo;
+
+import java.util.List;
 
 /**
  * <p>
@@ -24,4 +27,6 @@ public interface IKylinPerformancesService {
     ResponseDto<String> subscribe(String performancesId, Integer sourceType);
 
     ResponseDto<Integer> isSubscribe(String performancesId);
+
+    ResponseDto<List<KylinCandyVo>> kylinCandy(List<String> data, String roadShowId);
 }

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

@@ -4,6 +4,8 @@ package com.liquidnet.service.kylin.controller;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.dto.param.KylinCandyParam;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCandyVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.returns.PayDetailVo;
 import com.liquidnet.service.kylin.service.IKylinLackRegistersService;
@@ -262,4 +264,10 @@ public class KylinPerformancesController {
         return iKylinPerformancesService.getPerformanceIdByInfo(useScope, busiId);
     }
 
+    @PostMapping("kylinCandy")
+    @ApiOperation("根据券id集合获取数据")
+    public ResponseDto<List<KylinCandyVo>> kylinCandy(@RequestBody KylinCandyParam param) {
+        return iKylinPerformancesService.kylinCandy(param.getCouponList(), param.getRoadShowId());
+    }
+
 }

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

@@ -12,6 +12,7 @@ import com.liquidnet.service.kylin.constant.KylinPerformanceStatusEnum;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCandyVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketExpressModuleVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
@@ -741,4 +742,20 @@ public class KylinPerformancesServiceImpl implements IKylinPerformancesService {
         Integer subscribe = dataUtils.getSubscribe(uid, performancesId);
         return ResponseDto.success(subscribe);
     }
+
+    @Override
+    public ResponseDto<List<KylinCandyVo>> kylinCandy(List<String> data, String roadShowId) {
+        List<KylinCandyVo> voList = ObjectUtil.kylinCandyVos();
+        for (String couponId : data) {
+            List<String> roadShowIds = dataUtils.getCouponRoad(couponId);
+            if (roadShowIds.size() == 0 || roadShowIds.contains(roadShowId)) {
+                KylinCandyVo vo = KylinCandyVo.getNew();
+                vo.setCouponId(couponId);
+                vo.setRoadShowId(roadShowIds.contains(roadShowId) ? roadShowId : "");
+                voList.add(vo);
+            }
+        }
+
+        return ResponseDto.success(voList);
+    }
 }

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

@@ -906,41 +906,43 @@ public class DataUtils {
     }
 
     //万青补偿id 获取
-    public Integer getWqOrderId(String orderId){
+    public Integer getWqOrderId(String orderId) {
         String rdk = KylinRedisConst.REDIS_WQ_ORDER_FIX.concat(orderId);
         Object obj = redisUtil.get(rdk);
-        if(obj==null){
+        if (obj == null) {
             return 0;
-        }else{
+        } else {
             return 1;
         }
     }
 
     //万青补偿id 添加
-    public void setWqOrderId(String orderId){
+    public void setWqOrderId(String orderId) {
         String rdk = KylinRedisConst.REDIS_WQ_ORDER_FIX.concat(orderId);
-        redisUtil.set(rdk,orderId);
+        redisUtil.set(rdk, orderId);
     }
 
     //万青补偿id 删除
-    public void delWqOrderId(String orderId){
+    public void delWqOrderId(String orderId) {
         String rdk = KylinRedisConst.REDIS_WQ_ORDER_FIX.concat(orderId);
-        redisUtil.del(rdk,orderId);
+        redisUtil.del(rdk, orderId);
     }
+
     // 万青补偿vo覆盖
-    public void setWqOrderVo(WqTempVo vo){
+    public void setWqOrderVo(WqTempVo vo) {
         String rdk = KylinRedisConst.REDIS_WQ_ORDER_EXPRESS.concat(vo.getOrderId());
-        redisUtil.set(rdk,vo);
+        redisUtil.set(rdk, vo);
     }
+
     // 万青补偿vo获取
-    public WqTempVo getWqOrderVo(String orderId){
+    public WqTempVo getWqOrderVo(String orderId) {
         String rdk = KylinRedisConst.REDIS_WQ_ORDER_EXPRESS.concat(orderId);
         Object obj = redisUtil.get(rdk);
-        if(obj==null){
+        if (obj == null) {
             WqTempVo vo = WqTempVo.getNew();
             vo.setIsTemp(getWqOrderId(orderId));
             return vo;
-        }else{
+        } else {
             WqTempVo vo = (WqTempVo) obj;
             vo.setIsTemp(getWqOrderId(orderId));
             return vo;
@@ -949,20 +951,34 @@ public class DataUtils {
 
     // 获取用户状态
     public String getUserStatus(String userId) {
-        return (String) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_USER+ userId);
+        return (String) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_USER + userId);
     }
+
     //获得 ar券
-    public KylinTicketActive getArTicket(String code){
-       return (KylinTicketActive) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_TICKET+code);
+    public KylinTicketActive getArTicket(String code) {
+        return (KylinTicketActive) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_TICKET + code);
     }
+
     //设置 tikcet
-    public void setArTicket(KylinTicketActive kylinTicketActive){
-        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_TICKET+kylinTicketActive.getCode(),kylinTicketActive);
+    public void setArTicket(KylinTicketActive kylinTicketActive) {
+        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_TICKET + kylinTicketActive.getCode(), kylinTicketActive);
     }
+
     //设置用户状态。
-    public void setUser(String userId,String value){
-        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_USER+userId,value);
+    public void setUser(String userId, String value) {
+        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_USER + userId, value);
+    }
 
+
+    //根据 券id 获取 可用巡演id数组
+    public List<String> getCouponRoad(String couponId) {
+        String rdk = KylinRedisConst.COUPON_ROADSHOWS.concat(couponId);
+        Object obj = redisUtil.get(rdk);
+        if (obj == null) {
+            return CollectionUtil.arrayListString();
+        } else {
+            return (List<String>) obj;
+        }
     }
 
 }

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

@@ -6,6 +6,7 @@ import com.liquidnet.service.kylin.dto.vo.KylinApiCameraDevicesVo;
 import com.liquidnet.service.kylin.dto.vo.admin.OrderRefundPoundage;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCandyVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.returns.*;
 import com.liquidnet.service.kylin.entity.KylinBanners;
@@ -32,7 +33,11 @@ public class ObjectUtil {
     private static final ArrayList<OrderRefundPoundage> orderRefundPoundageArrayList = new ArrayList<>();
     private static final ArrayList<KylinOrderCoupons> kylinOrderCouponsArrayList = new ArrayList<>();
     private static final ArrayList<KylinApiCameraDevicesVo> kylinApiCameraDevicesVoArrayList = new ArrayList<>();
+    private static final ArrayList<KylinCandyVo> kylinCandyVos = new ArrayList<>();
 
+    public static ArrayList<KylinCandyVo> kylinCandyVos() {
+        return (ArrayList<KylinCandyVo>) kylinCandyVos.clone();
+    }
 
     public static ArrayList<KylinStationPerformanceVo> getKylinStationPerformanceVoArrayList() {
         return (ArrayList<KylinStationPerformanceVo>) kylinStationPerformanceVoArrayList.clone();