记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 1f573f03 authored by Tice's avatar Tice
Browse files
Options

切换 redis 数据源

parent 065d7e52
Hide whitespace changes
Inline Side-by-side
Showing with 23 additions and 23 deletions
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/merchant/utils/MerchantRedisUtil.java
View file @ 1f573f03
package com.liquidnet.client.admin.zhengzai.merchant.utils; package com.liquidnet.client.admin.zhengzai.merchant.utils;
import com.liquidnet.common.cache.redis.util.RedisUtil; import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.service.merchant.constant.MerchantRedisConst; import com.liquidnet.service.merchant.constant.MerchantRedisConst;
import com.liquidnet.service.merchant.dto.vo.*; import com.liquidnet.service.merchant.dto.vo.*;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -16,7 +16,7 @@ import java.util.stream.IntStream; ...@@ -16,7 +16,7 @@ import java.util.stream.IntStream;
@Service @Service
public class MerchantRedisUtil { public class MerchantRedisUtil {
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
MerchantMongoUtil mongoUtil; MerchantMongoUtil mongoUtil;
...@@ -28,18 +28,18 @@ public class MerchantRedisUtil { ...@@ -28,18 +28,18 @@ public class MerchantRedisUtil {
} }
String key = MerchantRedisConst.INFO_FIELD.concat(fieldId); String key = MerchantRedisConst.INFO_FIELD.concat(fieldId);
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
MerchantFieldsVo vo = (MerchantFieldsVo) redisUtil.get(key); MerchantFieldsVo vo = (MerchantFieldsVo) redisDataSourceUtil.getRedisKylinUtil().get(key);
log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s); log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
if (null == vo) { if (null == vo) {
vo = mongoUtil.getFieldsVoByFieldId(fieldId); vo = mongoUtil.getFieldsVoByFieldId(fieldId);
redisUtil.set(key, vo); redisDataSourceUtil.getRedisKylinUtil().set(key, vo);
} }
return vo; return vo;
} }
// 【场地】更新详情 // 【场地】更新详情
public boolean setFieldsVoByFieldId(String fieldId, MerchantFieldsVo vo) { public boolean setFieldsVoByFieldId(String fieldId, MerchantFieldsVo vo) {
return redisUtil.set(MerchantRedisConst.INFO_FIELD.concat(fieldId), vo); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD.concat(fieldId), vo);
} }
...@@ -50,18 +50,18 @@ public class MerchantRedisUtil { ...@@ -50,18 +50,18 @@ public class MerchantRedisUtil {
} }
String key = MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid); String key = MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid);
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
List<MerchantFieldAppliesVo> vos = (List<MerchantFieldAppliesVo>) redisUtil.get(key); List<MerchantFieldAppliesVo> vos = (List<MerchantFieldAppliesVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s); log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
if (null == vos) { if (null == vos) {
vos = mongoUtil.getFieldAppliesVosByUid(uid); vos = mongoUtil.getFieldAppliesVosByUid(uid);
redisUtil.set(key, vos); redisDataSourceUtil.getRedisKylinUtil().set(key, vos);
} }
return vos; return vos;
} }
// 【场地认领】更新我的列表 // 【场地认领】更新我的列表
public boolean setFieldAppliesVosByUid(String uid, List<MerchantFieldAppliesVo> vos) { public boolean setFieldAppliesVosByUid(String uid, List<MerchantFieldAppliesVo> vos) {
return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
} }
// 【场地申请】新增 // 【场地申请】新增
...@@ -70,7 +70,7 @@ public class MerchantRedisUtil { ...@@ -70,7 +70,7 @@ public class MerchantRedisUtil {
vos = new ArrayList<>(); vos = new ArrayList<>();
} }
vos.add(vo); vos.add(vo);
return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
} }
// 【场地申请】删除 // 【场地申请】删除
...@@ -79,7 +79,7 @@ public class MerchantRedisUtil { ...@@ -79,7 +79,7 @@ public class MerchantRedisUtil {
return true; return true;
} }
vos.removeIf(r -> r.getFieldApplyId().equals(vo.getFieldApplyId())); vos.removeIf(r -> r.getFieldApplyId().equals(vo.getFieldApplyId()));
return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
} }
// 【场地申请】更新 // 【场地申请】更新
...@@ -94,7 +94,7 @@ public class MerchantRedisUtil { ...@@ -94,7 +94,7 @@ public class MerchantRedisUtil {
return false; return false;
} }
vos.set(idx, vo); vos.set(idx, vo);
return redisUtil.set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_APPLIES.concat(uid), vos);
} }
...@@ -102,7 +102,7 @@ public class MerchantRedisUtil { ...@@ -102,7 +102,7 @@ public class MerchantRedisUtil {
public List<MerchantFieldCheckersVo> getFieldCheckersVosByFieldId(String fieldId) { public List<MerchantFieldCheckersVo> getFieldCheckersVosByFieldId(String fieldId) {
String key = MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId); String key = MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId);
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
List<MerchantFieldCheckersVo> vos = (List<MerchantFieldCheckersVo>) redisUtil.get(key); List<MerchantFieldCheckersVo> vos = (List<MerchantFieldCheckersVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s); log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
return vos; return vos;
} }
...@@ -113,7 +113,7 @@ public class MerchantRedisUtil { ...@@ -113,7 +113,7 @@ public class MerchantRedisUtil {
vos = new ArrayList<>(); vos = new ArrayList<>();
} }
vos.add(vo); vos.add(vo);
return redisUtil.set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
} }
// 【场地默认验票员】删除 // 【场地默认验票员】删除
...@@ -122,7 +122,7 @@ public class MerchantRedisUtil { ...@@ -122,7 +122,7 @@ public class MerchantRedisUtil {
return true; return true;
} }
vos.removeIf(r -> r.getFieldCheckerId().equals(vo.getFieldCheckerId())); vos.removeIf(r -> r.getFieldCheckerId().equals(vo.getFieldCheckerId()));
return redisUtil.set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
} }
// 【主办】详情 // 【主办】详情
...@@ -132,18 +132,18 @@ public class MerchantRedisUtil { ...@@ -132,18 +132,18 @@ public class MerchantRedisUtil {
} }
String key = MerchantRedisConst.INFO_SPONSOR.concat(sponsorId); String key = MerchantRedisConst.INFO_SPONSOR.concat(sponsorId);
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
MerchantSponsorsVo vo = (MerchantSponsorsVo) redisUtil.get(key); MerchantSponsorsVo vo = (MerchantSponsorsVo) redisDataSourceUtil.getRedisKylinUtil().get(key);
log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s); log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
if (null == vo) { if (null == vo) {
vo = mongoUtil.getSponsorsVoBySponsorId(sponsorId); vo = mongoUtil.getSponsorsVoBySponsorId(sponsorId);
redisUtil.set(key, vo); redisDataSourceUtil.getRedisKylinUtil().set(key, vo);
} }
return vo; return vo;
} }
// 【主办】更新详情 // 【主办】更新详情
public boolean setSponsorsVoBySponsorId(String sponsorId, MerchantSponsorsVo vo) { public boolean setSponsorsVoBySponsorId(String sponsorId, MerchantSponsorsVo vo) {
return redisUtil.set(MerchantRedisConst.INFO_SPONSOR.concat(sponsorId), vo); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR.concat(sponsorId), vo);
} }
// 【主办申请】我的列表 // 【主办申请】我的列表
...@@ -153,18 +153,18 @@ public class MerchantRedisUtil { ...@@ -153,18 +153,18 @@ public class MerchantRedisUtil {
} }
String key = MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid); String key = MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid);
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
List<MerchantSponsorAppliesVo> vos = (List<MerchantSponsorAppliesVo>) redisUtil.get(key); List<MerchantSponsorAppliesVo> vos = (List<MerchantSponsorAppliesVo>) redisDataSourceUtil.getRedisKylinUtil().get(key);
log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s); log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
if (null == vos) { if (null == vos) {
vos = mongoUtil.getSponsorAppliesVosByUid(uid); vos = mongoUtil.getSponsorAppliesVosByUid(uid);
redisUtil.set(key, vos); redisDataSourceUtil.getRedisKylinUtil().set(key, vos);
} }
return vos; return vos;
} }
// 【主办申请】更新我的列表 // 【主办申请】更新我的列表
public boolean setSponsorAppliesVosByUid(String uid, List<MerchantSponsorAppliesVo> vos) { public boolean setSponsorAppliesVosByUid(String uid, List<MerchantSponsorAppliesVo> vos) {
return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
} }
// 【主办申请】新增 // 【主办申请】新增
...@@ -173,7 +173,7 @@ public class MerchantRedisUtil { ...@@ -173,7 +173,7 @@ public class MerchantRedisUtil {
vos = new ArrayList<>(); vos = new ArrayList<>();
} }
vos.add(vo); vos.add(vo);
return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
} }
// 【主办申请】删除 // 【主办申请】删除
...@@ -182,7 +182,7 @@ public class MerchantRedisUtil { ...@@ -182,7 +182,7 @@ public class MerchantRedisUtil {
return true; return true;
} }
vos.removeIf(r -> r.getSponsorApplyId().equals(vo.getSponsorApplyId())); vos.removeIf(r -> r.getSponsorApplyId().equals(vo.getSponsorApplyId()));
return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
} }
// 【主办申请】更新 // 【主办申请】更新
...@@ -197,7 +197,7 @@ public class MerchantRedisUtil { ...@@ -197,7 +197,7 @@ public class MerchantRedisUtil {
return false; return false;
} }
vos.set(idx, vo); vos.set(idx, vo);
return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos); return redisDataSourceUtil.getRedisKylinUtil().set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment