提交 删除场次 票

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/service/MerchantRdmService.java

 package com.liquidnet.service.merchant.service;
 
-import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
+import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.merchant.constant.MerchantRedisConst;
 import com.liquidnet.service.merchant.dto.vo.*;
 import com.liquidnet.service.merchant.util.ObjectUtil;
@@ -16,7 +16,7 @@ import java.util.List;
 public class MerchantRdmService {
 
     @Autowired
-    RedisDataSourceUtil redisDataSourceUtil;
+    RedisUtil redisUtil;
 
     @Autowired
     private MerchantMongoService merchantMongoService;
@@ -28,18 +28,18 @@ public class MerchantRdmService {
         }
         String key = MerchantRedisConst.INFO_FIELD.concat(fieldId);
         long s = System.currentTimeMillis();
-        MerchantFieldsVo vo = (MerchantFieldsVo) redisDataSourceUtil.getRedisKylinUtil().get(key);
+        MerchantFieldsVo vo = (MerchantFieldsVo) redisUtil.get(key);
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         if (null == vo) {
             vo = merchantMongoService.getFieldsVoByFieldId(fieldId);
-            redisDataSourceUtil.getRedisKylinUtil().set(key, vo);
+            redisUtil.set(key, vo);
         }
         return vo;
     }
 
     // 【场地】更新详情
     public boolean setFieldsVoByFieldId(String fieldId, MerchantFieldsVo vo) {
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD.concat(fieldId), vo);
+        return redisUtil.set(MerchantRedisConst.INFO_FIELD.concat(fieldId), vo);
     }
 
 
@@ -50,11 +50,11 @@ public class MerchantRdmService {
         }
         String key = MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid);
         long s = System.currentTimeMillis();
-        List<MerchantFieldAppliesVo> vos = (List<MerchantFieldAppliesVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
+        List<MerchantFieldAppliesVo> vos = (List<MerchantFieldAppliesVo>) redisUtil.get(key);
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         if (null == vos) {
             vos = merchantMongoService.getFieldAppliesVosByUid(uid);
-            redisDataSourceUtil.getRedisKylinUtil().set(key, vos);
+            redisUtil.set(key, vos);
         }
         return vos;
     }
@@ -65,7 +65,7 @@ public class MerchantRdmService {
             vos = ObjectUtil.getMerchantFieldAppliesVoArrayList();
         }
         vos.add(vo);
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
     }
 
     // 【场地申请】删除
@@ -74,7 +74,7 @@ public class MerchantRdmService {
             return true;
         }
         vos.removeIf(r -> r.getFieldApplyId().equals(vo.getFieldApplyId()));
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
     }
 
 
@@ -82,7 +82,7 @@ public class MerchantRdmService {
     public List<MerchantFieldCheckersVo> getFieldCheckersVosByFieldId(String fieldId) {
         String key = MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId);
         long s = System.currentTimeMillis();
-        List<MerchantFieldCheckersVo> vos = (List<MerchantFieldCheckersVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
+        List<MerchantFieldCheckersVo> vos = (List<MerchantFieldCheckersVo>)redisUtil.get(key);
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         return vos;
     }
@@ -93,7 +93,7 @@ public class MerchantRdmService {
             vos = ObjectUtil.getMerchantFieldCheckersVoArrayList();
         }
         vos.add(vo);
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
     }
 
     // 【场地默认验票员】删除
@@ -102,7 +102,7 @@ public class MerchantRdmService {
             return true;
         }
         vos.removeIf(r -> r.getFieldCheckerId().equals(vo.getFieldCheckerId()));
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
     }
 
     // 【主办】详情
@@ -112,18 +112,18 @@ public class MerchantRdmService {
         }
         String key = MerchantRedisConst.INFO_SPONSOR.concat(sponsorId);
         long s = System.currentTimeMillis();
-        MerchantSponsorsVo vo = (MerchantSponsorsVo) redisDataSourceUtil.getRedisKylinUtil().get(key);
+        MerchantSponsorsVo vo = (MerchantSponsorsVo) redisUtil.get(key);
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         if (null == vo) {
             vo = merchantMongoService.getSponsorsVoBySponsorId(sponsorId);
-            redisDataSourceUtil.getRedisKylinUtil().set(key, vo);
+            redisUtil.set(key, vo);
         }
         return vo;
     }
 
     // 【主办】更新详情
     public boolean setSponsorsVoBySponsorId(String sponsorId, MerchantSponsorsVo vo) {
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR.concat(sponsorId), vo);
+        return redisUtil.set(MerchantRedisConst.INFO_SPONSOR.concat(sponsorId), vo);
     }
 
     // 【主办申请】我的列表
@@ -133,11 +133,11 @@ public class MerchantRdmService {
         }
         String key = MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid);
         long s = System.currentTimeMillis();
-        List<MerchantSponsorAppliesVo> vos = (List<MerchantSponsorAppliesVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
+        List<MerchantSponsorAppliesVo> vos = (List<MerchantSponsorAppliesVo>) redisUtil.get(key);
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         if (null == vos) {
             vos = merchantMongoService.getSponsorAppliesVosByUid(uid);
-            redisDataSourceUtil.getRedisKylinUtil().set(key, vos);
+            redisUtil.set(key, vos);
         }
         return vos;
     }
@@ -148,7 +148,7 @@ public class MerchantRdmService {
             vos = ObjectUtil.getMerchantSponsorAppliesVoArrayList();
         }
         vos.add(vo);
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
     }
 
     // 【主办申请】删除
@@ -157,6 +157,6 @@ public class MerchantRdmService {
             return true;
         }
         vos.removeIf(r -> r.getSponsorApplyId().equals(vo.getSponsorApplyId()));
-        return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
+        return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
     }
 }