暂时提交

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

@@ -4,9 +4,16 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.vo.KylinPerformanceVo;
+import com.liquidnet.service.kylin.dto.vo.KylinTicketTimesVo;
+import com.liquidnet.service.kylin.dto.vo.KylinTicketVo;
 import com.liquidnet.service.kylin.entity.KylinBuyNotice;
+import com.liquidnet.service.kylin.entity.KylinTicketTimes;
 import com.liquidnet.service.kylin.mapper.KylinBuyNoticeMapper;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
@@ -16,6 +23,8 @@ public class DataUtils {
 
     @Autowired
     private KylinBuyNoticeMapper buyNoticeMapper;
+    @Autowired
+    private MongoTemplate mongoTemplate;
 
     @Autowired
     private RedisUtil redisUtil;
@@ -93,4 +102,31 @@ public class DataUtils {
         return (int) redisUtil.hincr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId, KylinRedisConst.SURPLUS_GENERAL, surplusExchange);
     }
 
+    public KylinPerformanceVo getPerformanceVo(String performanceId){
+        if(redisUtil.hHasKey(KylinRedisConst.PERFORMANCES,performanceId)){
+        }else{
+            KylinPerformanceVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+            redisUtil.hset(KylinRedisConst.PERFORMANCES,performanceId,performanceData);
+        }
+        return (KylinPerformanceVo) redisUtil.hget(KylinRedisConst.PERFORMANCES,performanceId);
+    }
+
+    public KylinTicketTimesVo getTicketTimesVo(String ticketTimeId){
+        if(redisUtil.hHasKey(KylinRedisConst.TIMES,ticketTimeId)){
+        }else{
+            KylinTicketTimesVo ticketTimesData = mongoTemplate.findOne(Query.query(Criteria.where("ticketTimesId").is(ticketTimeId)), KylinTicketTimesVo.class, KylinTicketTimes.class.getSimpleName());
+            redisUtil.hset(KylinRedisConst.TIMES,ticketTimeId,ticketTimesData);
+        }
+        return (KylinTicketTimesVo) redisUtil.hget(KylinRedisConst.TIMES,ticketTimeId);
+    }
+
+    public KylinTicketVo getTicketVo(String ticketId){
+        if(redisUtil.hHasKey(KylinRedisConst.TICKET,ticketId)){
+        }else{
+            KylinTicketVo ticketData = mongoTemplate.findOne(Query.query(Criteria.where("ticketsId").is(ticketId)), KylinTicketVo.class, KylinTicketVo.class.getSimpleName());
+            redisUtil.hset(KylinRedisConst.TICKET,ticketId,ticketData);
+        }
+        return (KylinTicketVo) redisUtil.hget(KylinRedisConst.TICKET,ticketId);
+    }
+
 }