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

Skip to content

L
liquidnet-bus-v1
Commit 8ec49361 authored by anjiabin's avatar anjiabin
Browse files
Options

redis多数据源

parent c0bb7280
Hide whitespace changes
Inline Side-by-side
Showing with 134 additions and 135 deletions
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/adam/AdamMemberCodeAdminController.java
View file @ 8ec49361
...@@ -41,7 +41,7 @@ public class AdamMemberCodeAdminController extends BaseController { ...@@ -41,7 +41,7 @@ public class AdamMemberCodeAdminController extends BaseController {
IAdamMemberPriceAdminService adamMemberPriceAdminService; IAdamMemberPriceAdminService adamMemberPriceAdminService;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@GetMapping("mgt") @GetMapping("mgt")
public String viewCodeMgt(@RequestParam String memberId, ModelMap mmap) { public String viewCodeMgt(@RequestParam String memberId, ModelMap mmap) {
...@@ -172,9 +172,9 @@ public class AdamMemberCodeAdminController extends BaseController { ...@@ -172,9 +172,9 @@ public class AdamMemberCodeAdminController extends BaseController {
// ArrayList<String> updateCodeList = CollectionUtil.arrayListString(); // ArrayList<String> updateCodeList = CollectionUtil.arrayListString();
// optParam.getCodes().forEach(r -> { // optParam.getCodes().forEach(r -> {
// String key = AdamRedisConst.INFO_MEMBER_CODE.concat(r); // String key = AdamRedisConst.INFO_MEMBER_CODE.concat(r);
// AdamMemberCodeVo vo = (AdamMemberCodeVo) redisUtil.get(key); // AdamMemberCodeVo vo = (AdamMemberCodeVo) redisDataSourceUtil.getRedisKylinUtil().get(key);
// if (null != vo && vo.getState() == beforeState) { // if (null != vo && vo.getState() == beforeState) {
// redisUtil.del(key); // redisDataSourceUtil.getRedisKylinUtil().del(key);
// //
// updateCodeList.add(vo.getCode()); // updateCodeList.add(vo.getCode());
// } // }
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/adam/AdamUserMemberAdminController.java
View file @ 8ec49361
...@@ -29,14 +29,14 @@ import java.util.List; ...@@ -29,14 +29,14 @@ import java.util.List;
@RequestMapping("adam/umember") @RequestMapping("adam/umember")
public class AdamUserMemberAdminController { public class AdamUserMemberAdminController {
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@Log(title = "会员管理:会员黑名单:列表", businessType = BusinessType.LIST) @Log(title = "会员管理:会员黑名单:列表", businessType = BusinessType.LIST)
@RequiresPermissions("adam:umember:blk:lis") @RequiresPermissions("adam:umember:blk:lis")
@ApiOperation(value = "列表") @ApiOperation(value = "列表")
@PostMapping("blk/lis") @PostMapping("blk/lis")
public ResponseDto<List<String>> listBlack() { public ResponseDto<List<String>> listBlack() {
return ResponseDto.success((List<String>) redisUtil.get(AdamRedisConst.BLK_LIST_MEMBER_UID)); return ResponseDto.success((List<String>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.BLK_LIST_MEMBER_UID));
} }
@Log(title = "会员管理:会员黑名单:添加", businessType = BusinessType.INSERT) @Log(title = "会员管理:会员黑名单:添加", businessType = BusinessType.INSERT)
...@@ -53,14 +53,14 @@ public class AdamUserMemberAdminController { ...@@ -53,14 +53,14 @@ public class AdamUserMemberAdminController {
invalidList.add(uid); invalidList.add(uid);
} }
} }
List<String> blacklist = (List<String>) redisUtil.get(AdamRedisConst.BLK_LIST_MEMBER_UID); List<String> blacklist = (List<String>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.BLK_LIST_MEMBER_UID);
if (CollectionUtils.isEmpty(blacklist)) { if (CollectionUtils.isEmpty(blacklist)) {
blacklist = existList; blacklist = existList;
} else { } else {
blacklist.addAll(existList); blacklist.addAll(existList);
} }
if (!CollectionUtils.isEmpty(blacklist)) { if (!CollectionUtils.isEmpty(blacklist)) {
redisUtil.set(AdamRedisConst.BLK_LIST_MEMBER_UID, blacklist); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.BLK_LIST_MEMBER_UID, blacklist);
} else { } else {
log.warn("###blacklist.add:failed,invalidList:{},existList:{},opts:{}", invalidList.size(), existList.size(), opts); log.warn("###blacklist.add:failed,invalidList:{},existList:{},opts:{}", invalidList.size(), existList.size(), opts);
} }
...@@ -73,12 +73,12 @@ public class AdamUserMemberAdminController { ...@@ -73,12 +73,12 @@ public class AdamUserMemberAdminController {
@PostMapping("blk/del") @PostMapping("blk/del")
public ResponseDto<List<String>> delBlack(@NotBlank(message = "会员ID不能为空") @RequestParam String opts) { public ResponseDto<List<String>> delBlack(@NotBlank(message = "会员ID不能为空") @RequestParam String opts) {
String[] uidArr = opts.split(","); String[] uidArr = opts.split(",");
List<String> blacklist = (List<String>) redisUtil.get(AdamRedisConst.BLK_LIST_MEMBER_UID); List<String> blacklist = (List<String>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.BLK_LIST_MEMBER_UID);
if (!CollectionUtils.isEmpty(blacklist)) { if (!CollectionUtils.isEmpty(blacklist)) {
for (String uid : uidArr) { for (String uid : uidArr) {
blacklist.remove(uid); blacklist.remove(uid);
} }
redisUtil.set(AdamRedisConst.BLK_LIST_MEMBER_UID, blacklist); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.BLK_LIST_MEMBER_UID, blacklist);
} }
return ResponseDto.success(blacklist); return ResponseDto.success(blacklist);
} }
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/candy/CandyCouponCodeAdminController.java
View file @ 8ec49361
...@@ -41,7 +41,7 @@ public class CandyCouponCodeAdminController extends BaseController { ...@@ -41,7 +41,7 @@ public class CandyCouponCodeAdminController extends BaseController {
private String prefix = "zhengzai/candy/coupon/code"; private String prefix = "zhengzai/candy/coupon/code";
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private ICandyCouponCodeAdminService candyCouponCodeAdminService; private ICandyCouponCodeAdminService candyCouponCodeAdminService;
@Autowired @Autowired
...@@ -117,10 +117,10 @@ public class CandyCouponCodeAdminController extends BaseController { ...@@ -117,10 +117,10 @@ public class CandyCouponCodeAdminController extends BaseController {
List<String> ccodeUpdateList = CollectionUtil.arrayListString(); List<String> ccodeUpdateList = CollectionUtil.arrayListString();
list.forEach(r -> { list.forEach(r -> {
String key = CandyRedisConst.BASIC_COUPON_CODE.concat(r.getCcode()); String key = CandyRedisConst.BASIC_COUPON_CODE.concat(r.getCcode());
CandyCouponCodeDto dto = (CandyCouponCodeDto) redisUtil.get(key); CandyCouponCodeDto dto = (CandyCouponCodeDto) redisDataSourceUtil.getRedisKylinUtil().get(key);
if (null != dto && dto.getState() == 0) { if (null != dto && dto.getState() == 0) {
dto.setState(4); dto.setState(4);
redisUtil.set(key, dto); redisDataSourceUtil.getRedisKylinUtil().set(key, dto);
ccodeUpdateList.add(dto.getCcode()); ccodeUpdateList.add(dto.getCcode());
} }
}); });
...@@ -160,7 +160,7 @@ public class CandyCouponCodeAdminController extends BaseController { ...@@ -160,7 +160,7 @@ public class CandyCouponCodeAdminController extends BaseController {
List<String> ccodeUpdateList = CollectionUtil.arrayListString(); List<String> ccodeUpdateList = CollectionUtil.arrayListString();
list.forEach(r -> { list.forEach(r -> {
String uckey = CandyRedisConst.BASIC_USER_COUPON.concat(r.getRedeemUid()); String uckey = CandyRedisConst.BASIC_USER_COUPON.concat(r.getRedeemUid());
List<CandyUserCouponBasicDto> vos = (List<CandyUserCouponBasicDto>) redisUtil.get(uckey); List<CandyUserCouponBasicDto> vos = (List<CandyUserCouponBasicDto>) redisDataSourceUtil.getRedisKylinUtil().get(uckey);
if (!CollectionUtils.isEmpty(vos)) { if (!CollectionUtils.isEmpty(vos)) {
vos.removeIf(rv -> rv.getUcouponId().equals(r.getUcouponId())); vos.removeIf(rv -> rv.getUcouponId().equals(r.getUcouponId()));
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberCodeAdminServiceImpl.java
View file @ 8ec49361
...@@ -27,7 +27,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa ...@@ -27,7 +27,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
@Autowired @Autowired
AdamMemberCodeMapper memberCodeMapper; AdamMemberCodeMapper memberCodeMapper;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@Override @Override
public boolean createGiftCode(AdamMemberCodeGenParam param) { public boolean createGiftCode(AdamMemberCodeGenParam param) {
...@@ -41,7 +41,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa ...@@ -41,7 +41,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
do { do {
mCode = MemberUtil.freeCode(); mCode = MemberUtil.freeCode();
String key = AdamRedisConst.INFO_MEMBER_CODE.concat(mCode); String key = AdamRedisConst.INFO_MEMBER_CODE.concat(mCode);
exists = redisUtil.hasKey(key); exists = redisDataSourceUtil.getRedisKylinUtil().hasKey(key);
} while (exists); } while (exists);
AdamMemberCode initMemberCode = new AdamMemberCode(); AdamMemberCode initMemberCode = new AdamMemberCode();
...@@ -60,7 +60,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa ...@@ -60,7 +60,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
memberCodeList.add(initMemberCode); memberCodeList.add(initMemberCode);
codeList.add(mCode); codeList.add(mCode);
//redisUtil.set(AdamRedisConst.INFO_MEMBER_CODE.concat(mCode), AdamMemberCodeVo.getNew().copy(initMemberCode)); //redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_CODE.concat(mCode), AdamMemberCodeVo.getNew().copy(initMemberCode));
} }
if (this.saveBatch(memberCodeList, memberCodeList.size())) { if (this.saveBatch(memberCodeList, memberCodeList.size())) {
...@@ -71,7 +71,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa ...@@ -71,7 +71,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
list.forEach(r -> { list.forEach(r -> {
r.setMemberNo(getNextMemberNo(param.getMemberId())); r.setMemberNo(getNextMemberNo(param.getMemberId()));
redisUtil.set(AdamRedisConst.INFO_MEMBER_CODE.concat(r.getCode()), AdamMemberCodeVo.getNew().copy(r)); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_CODE.concat(r.getCode()), AdamMemberCodeVo.getNew().copy(r));
}); });
this.updateBatchById(list, list.size()); this.updateBatchById(list, list.size());
return true; return true;
...@@ -115,15 +115,15 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa ...@@ -115,15 +115,15 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
} }
private int getMaxMemberNo() { private int getMaxMemberNo() {
Object o = redisUtil.get(AdamRedisConst.INCR_MEMBER_NO); Object o = redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.INCR_MEMBER_NO);
return null == o ? -1 : (int) o; return null == o ? -1 : (int) o;
} }
public boolean setMaxMemberNo(int val) { public boolean setMaxMemberNo(int val) {
return redisUtil.set(AdamRedisConst.INCR_MEMBER_NO, val); return redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INCR_MEMBER_NO, val);
} }
public int incrMemberNo() { public int incrMemberNo() {
return (int) redisUtil.incr(AdamRedisConst.INCR_MEMBER_NO, 1); return (int) redisDataSourceUtil.getRedisKylinUtil().incr(AdamRedisConst.INCR_MEMBER_NO, 1);
} }
} }
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberOrderAdminServiceImpl.java
View file @ 8ec49361
...@@ -64,7 +64,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder ...@@ -64,7 +64,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
private AdamMemberRefundMapper adamMemberRefundMapper; private AdamMemberRefundMapper adamMemberRefundMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Value("${liquidnet.url-refund.apply}") @Value("${liquidnet.url-refund.apply}")
private String applyUrl; private String applyUrl;
...@@ -175,7 +175,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder ...@@ -175,7 +175,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
adamMemberOrderMapper.updateById(updateInfoMemberOrder); adamMemberOrderMapper.updateById(updateInfoMemberOrder);
String moKey = AdamRedisConst.INFO_MEMBER_ORDER + memberOrder.getUid(); String moKey = AdamRedisConst.INFO_MEMBER_ORDER + memberOrder.getUid();
ArrayList<AdamMemberOrderVo> vos = (ArrayList<AdamMemberOrderVo>) redisUtil.get(moKey); ArrayList<AdamMemberOrderVo> vos = (ArrayList<AdamMemberOrderVo>) redisDataSourceUtil.getRedisKylinUtil().get(moKey);
int idx = IntStream.range(0, vos.size()) int idx = IntStream.range(0, vos.size())
.filter(i -> vos.get(i).getOrderNo().equals(memberOrder.getOrderNo())) .filter(i -> vos.get(i).getOrderNo().equals(memberOrder.getOrderNo()))
.findFirst().orElse(-1); .findFirst().orElse(-1);
...@@ -183,7 +183,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder ...@@ -183,7 +183,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
vo.setState(4); vo.setState(4);
vo.setUpdatedAt(now); vo.setUpdatedAt(now);
vos.set(idx, vo); vos.set(idx, vo);
redisUtil.set(moKey, vos); redisDataSourceUtil.getRedisKylinUtil().set(moKey, vos);
if (memberRefund.getRenewable() == 2) {// 拉黑用户，直接更新用户会员状态信息 if (memberRefund.getRenewable() == 2) {// 拉黑用户，直接更新用户会员状态信息
AdamUserMember updateUserMember = new AdamUserMember(); AdamUserMember updateUserMember = new AdamUserMember();
...@@ -197,20 +197,20 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder ...@@ -197,20 +197,20 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
adamUserMemberMapper.update(updateUserMember, userMemberLambdaUpdateWrapper); adamUserMemberMapper.update(updateUserMember, userMemberLambdaUpdateWrapper);
String umkey = AdamRedisConst.INFO_USER_MEMBER + memberOrder.getUid(); String umkey = AdamRedisConst.INFO_USER_MEMBER + memberOrder.getUid();
AdamUserMemberVo userMemberVo = (AdamUserMemberVo) redisUtil.get(umkey); AdamUserMemberVo userMemberVo = (AdamUserMemberVo) redisDataSourceUtil.getRedisKylinUtil().get(umkey);
userMemberVo.setState(2); userMemberVo.setState(2);
userMemberVo.setExpiryAt(now); userMemberVo.setExpiryAt(now);
userMemberVo.setUpdatedAt(now); userMemberVo.setUpdatedAt(now);
redisUtil.set(umkey, userMemberVo); redisDataSourceUtil.getRedisKylinUtil().set(umkey, userMemberVo);
List<String> uidBlackList = (List<String>) redisUtil.get(AdamRedisConst.BLK_LIST_MEMBER_UID); List<String> uidBlackList = (List<String>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.BLK_LIST_MEMBER_UID);
if (CollectionUtils.isEmpty(uidBlackList)) { if (CollectionUtils.isEmpty(uidBlackList)) {
uidBlackList = CollectionUtil.arrayListString(); uidBlackList = CollectionUtil.arrayListString();
} }
uidBlackList.add(memberOrder.getUid()); uidBlackList.add(memberOrder.getUid());
redisUtil.set(AdamRedisConst.BLK_LIST_MEMBER_UID, uidBlackList); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.BLK_LIST_MEMBER_UID, uidBlackList);
} }
return AjaxResult.success(); return AjaxResult.success();
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberPriceAdminServiceImpl.java
View file @ 8ec49361
...@@ -31,7 +31,7 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice ...@@ -31,7 +31,7 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice
@Autowired @Autowired
private AdamMemberMapper adamMemberMapper; private AdamMemberMapper adamMemberMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
// public AdamMemberPriceVo add(AdamMemberPrice info) { // public AdamMemberPriceVo add(AdamMemberPrice info) {
// List<AdamMemberPrice> existList = adamMemberPriceMapper.selectList( // List<AdamMemberPrice> existList = adamMemberPriceMapper.selectList(
...@@ -43,7 +43,7 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice ...@@ -43,7 +43,7 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice
// //
// AdamMemberPriceVo vo = AdamMemberPriceVo.getNew().copy(info); // AdamMemberPriceVo vo = AdamMemberPriceVo.getNew().copy(info);
// //
// redisUtil.set(AdamRedisConst.INFO_MEMBER_PRICE.concat(vo.getMemberPriceId()), vo); // redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_PRICE.concat(vo.getMemberPriceId()), vo);
// //
// return vo; // return vo;
// } // }
...@@ -98,11 +98,11 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice ...@@ -98,11 +98,11 @@ public class AdamMemberPriceAdminServiceImpl extends ServiceImpl<AdamMemberPrice
String memberPriceId = saveOrUpdateInfo.getMemberPriceId(); String memberPriceId = saveOrUpdateInfo.getMemberPriceId();
String mpKey = AdamRedisConst.INFO_MEMBER_PRICE.concat(memberId); String mpKey = AdamRedisConst.INFO_MEMBER_PRICE.concat(memberId);
List<AdamMemberPriceVo> vos = (List<AdamMemberPriceVo>) redisUtil.get(mpKey); List<AdamMemberPriceVo> vos = (List<AdamMemberPriceVo>) redisDataSourceUtil.getRedisKylinUtil().get(mpKey);
vos.removeIf(r -> (r.getMemberId().equals(memberId) && r.getMemberPriceId().equals(memberPriceId))); vos.removeIf(r -> (r.getMemberId().equals(memberId) && r.getMemberPriceId().equals(memberPriceId)));
vos.add(AdamMemberPriceVo.getNew().copy(saveOrUpdateInfo)); vos.add(AdamMemberPriceVo.getNew().copy(saveOrUpdateInfo));
redisUtil.set(mpKey, vos); redisDataSourceUtil.getRedisKylinUtil().set(mpKey, vos);
return true; return true;
} }
throw new LiquidnetServiceException("-1", "会员价格编辑失败"); throw new LiquidnetServiceException("-1", "会员价格编辑失败");
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberRightsAdminServiceImpl.java
View file @ 8ec49361
...@@ -27,7 +27,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh ...@@ -27,7 +27,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh
@Autowired @Autowired
private AdamMemberRightsMapper adamMemberRightsMapper; private AdamMemberRightsMapper adamMemberRightsMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Override @Override
public boolean edit(AdamMemberRightsBuildParam param) { public boolean edit(AdamMemberRightsBuildParam param) {
...@@ -75,7 +75,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh ...@@ -75,7 +75,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh
if (saveOrUpadateRst) { if (saveOrUpadateRst) {
// 同步REDIS:用户端:购买会员详情页:权益列表 // 同步REDIS:用户端:购买会员详情页:权益列表
List<AdamMemberRightsVo> vos = (List<AdamMemberRightsVo>) redisUtil.get(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(param.getMemberId())); List<AdamMemberRightsVo> vos = (List<AdamMemberRightsVo>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(param.getMemberId()));
if (CollectionUtils.isEmpty(vos)) { if (CollectionUtils.isEmpty(vos)) {
vos = new ArrayList<>(); vos = new ArrayList<>();
} }
...@@ -105,7 +105,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh ...@@ -105,7 +105,7 @@ public class AdamMemberRightsAdminServiceImpl extends ServiceImpl<AdamMemberRigh
} }
} }
} }
redisUtil.set(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(param.getMemberId()), vos); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(param.getMemberId()), vos);
} }
return saveOrUpadateRst; return saveOrUpadateRst;
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberServiceAdminImpl.java
View file @ 8ec49361
...@@ -4,7 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -4,7 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.client.admin.zhengzai.adam.service.IAdamMemberAdminService; import com.liquidnet.client.admin.zhengzai.adam.service.IAdamMemberAdminService;
import com.liquidnet.common.cache.redis.util.RedisUtil; import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.commons.lang.util.IDGenerator; import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.service.adam.constant.AdamRedisConst; import com.liquidnet.service.adam.constant.AdamRedisConst;
import com.liquidnet.service.adam.dto.admin.AdamMemberBuildParam; import com.liquidnet.service.adam.dto.admin.AdamMemberBuildParam;
...@@ -18,7 +18,6 @@ import org.springframework.stereotype.Service; ...@@ -18,7 +18,6 @@ import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List; import java.util.List;
@Slf4j @Slf4j
...@@ -27,7 +26,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad ...@@ -27,7 +26,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad
@Autowired @Autowired
AdamMemberMapper adamMemberMapper; AdamMemberMapper adamMemberMapper;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@Override @Override
public void add(AdamMemberBuildParam parameter) { public void add(AdamMemberBuildParam parameter) {
...@@ -45,7 +44,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad ...@@ -45,7 +44,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad
AdamMemberVo vo = AdamMemberVo.getNew().copy(adamMember); AdamMemberVo vo = AdamMemberVo.getNew().copy(adamMember);
adamMemberMapper.insert(adamMember); adamMemberMapper.insert(adamMember);
redisUtil.set(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(vo.getMemberId()), vo); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(vo.getMemberId()), vo);
} }
@Override @Override
...@@ -64,8 +63,8 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad ...@@ -64,8 +63,8 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad
adamMember = adamMemberMapper.selectOne(updateMemberWrapper); adamMember = adamMemberMapper.selectOne(updateMemberWrapper);
AdamMemberVo vo = AdamMemberVo.getNew().copy(adamMember); AdamMemberVo vo = AdamMemberVo.getNew().copy(adamMember);
redisUtil.set(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(vo.getMemberId()), vo); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(vo.getMemberId()), vo);
redisUtil.del(AdamRedisConst.INFO_MEMBER_SIMPLE); redisDataSourceUtil.getRedisKylinUtil().del(AdamRedisConst.INFO_MEMBER_SIMPLE);
return true; return true;
} }
return false; return false;
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/admin/service/impl/AdminUpushServiceImpl.java
View file @ 8ec49361
...@@ -65,7 +65,7 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp ...@@ -65,7 +65,7 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
MongoTemplate mongoTemplate; MongoTemplate mongoTemplate;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
public Boolean create(UpushParam upushParam) { public Boolean create(UpushParam upushParam) {
try { try {
...@@ -94,12 +94,12 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp ...@@ -94,12 +94,12 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
LinkedList<AdminUpushVo> pushList = new LinkedList<>(); LinkedList<AdminUpushVo> pushList = new LinkedList<>();
LinkedList<AdminUpushVo> pushList2 = new LinkedList<>(); LinkedList<AdminUpushVo> pushList2 = new LinkedList<>();
if (upushParam.getPushRange() == 1) { // all if (upushParam.getPushRange() == 1) { // all
pushList = (LinkedList<AdminUpushVo>) redisUtil.get(redisKeyIos); pushList = (LinkedList<AdminUpushVo>) redisDataSourceUtil.getRedisKylinUtil().get(redisKeyIos);
pushList2 = (LinkedList<AdminUpushVo>) redisUtil.get(redisKeyAndroid); pushList2 = (LinkedList<AdminUpushVo>) redisDataSourceUtil.getRedisKylinUtil().get(redisKeyAndroid);
} else if (upushParam.getPushRange() == 2) { // ios } else if (upushParam.getPushRange() == 2) { // ios
pushList = (LinkedList<AdminUpushVo>) redisUtil.get(redisKeyIos); pushList = (LinkedList<AdminUpushVo>) redisDataSourceUtil.getRedisKylinUtil().get(redisKeyIos);
} else if(upushParam.getPushRange() == 3) { // android } else if(upushParam.getPushRange() == 3) { // android
pushList = (LinkedList<AdminUpushVo>) redisUtil.get(redisKeyAndroid); pushList = (LinkedList<AdminUpushVo>) redisDataSourceUtil.getRedisKylinUtil().get(redisKeyAndroid);
} }
if (null == pushList) { if (null == pushList) {
...@@ -130,12 +130,12 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp ...@@ -130,12 +130,12 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
pushList.addFirst(adminUpushVo); pushList.addFirst(adminUpushVo);
} }
if (upushParam.getPushRange() == 1) { // all if (upushParam.getPushRange() == 1) { // all
redisUtil.set(redisKeyIos, pushList); redisDataSourceUtil.getRedisKylinUtil().set(redisKeyIos, pushList);
redisUtil.set(redisKeyAndroid, pushList2); redisDataSourceUtil.getRedisKylinUtil().set(redisKeyAndroid, pushList2);
} else if (upushParam.getPushRange() == 2) { // ios } else if (upushParam.getPushRange() == 2) { // ios
redisUtil.set(redisKeyIos, pushList); redisDataSourceUtil.getRedisKylinUtil().set(redisKeyIos, pushList);
} else if(upushParam.getPushRange() == 3) { // android } else if(upushParam.getPushRange() == 3) { // android
redisUtil.set(redisKeyAndroid, pushList); redisDataSourceUtil.getRedisKylinUtil().set(redisKeyAndroid, pushList);
} }
// 推送 // 推送
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/candy/service/impl/CandyMgtCouponAdminServiceImpl.java
View file @ 8ec49361
...@@ -45,7 +45,7 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa ...@@ -45,7 +45,7 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa
private CandyCouponMapper candyCouponMapper; private CandyCouponMapper candyCouponMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private ICandyCouponAdminService candyCouponAdminService; private ICandyCouponAdminService candyCouponAdminService;
...@@ -371,7 +371,7 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa ...@@ -371,7 +371,7 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa
List<AdamMemberRightsCouponRuleVo> memberRightsCouponRuleVoList = this.copyFromCandyCouponRule(initCouponRuleList); List<AdamMemberRightsCouponRuleVo> memberRightsCouponRuleVoList = this.copyFromCandyCouponRule(initCouponRuleList);
List<AdamMemberRightsCouponVo> memberRightsCouponVoList = List<AdamMemberRightsCouponVo> memberRightsCouponVoList =
(List<AdamMemberRightsCouponVo>) redisUtil.get(AdamRedisConst.INFO_MEMBER_RIGHTS_COUPON.concat(updateMgtCoupon.getMcouponId())); (List<AdamMemberRightsCouponVo>) redisDataSourceUtil.getRedisKylinUtil().get(AdamRedisConst.INFO_MEMBER_RIGHTS_COUPON.concat(updateMgtCoupon.getMcouponId()));
if (editing) {// 编辑操作 if (editing) {// 编辑操作
memberRightsCouponVoList.removeIf(r -> r.getCouponId().equals(updateCoupon.getCouponId())); memberRightsCouponVoList.removeIf(r -> r.getCouponId().equals(updateCoupon.getCouponId()));
} else {// 新增操作 } else {// 新增操作
...@@ -400,6 +400,6 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa ...@@ -400,6 +400,6 @@ public class CandyMgtCouponAdminServiceImpl extends ServiceImpl<CandyMgtCouponMa
} }
} }
redisUtil.set(AdamRedisConst.INFO_MEMBER_RIGHTS_COUPON.concat(updateMgtCoupon.getMcouponId()), memberRightsCouponVoList); redisDataSourceUtil.getRedisKylinUtil().set(AdamRedisConst.INFO_MEMBER_RIGHTS_COUPON.concat(updateMgtCoupon.getMcouponId()), memberRightsCouponVoList);
} }
} }
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinBannersServiceImpl.java
View file @ 8ec49361
...@@ -55,7 +55,7 @@ public class KylinBannersServiceImpl extends ServiceImpl<KylinBannersMapper, Kyl ...@@ -55,7 +55,7 @@ public class KylinBannersServiceImpl extends ServiceImpl<KylinBannersMapper, Kyl
MongoTemplate mongoTemplate; MongoTemplate mongoTemplate;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
public boolean create(BannersParam bannersParam) { public boolean create(BannersParam bannersParam) {
try { try {
...@@ -123,7 +123,7 @@ public class KylinBannersServiceImpl extends ServiceImpl<KylinBannersMapper, Kyl ...@@ -123,7 +123,7 @@ public class KylinBannersServiceImpl extends ServiceImpl<KylinBannersMapper, Kyl
banner.setPositionList(pListStr); banner.setPositionList(pListStr);
banner.setProvincesList(proListStr); banner.setProvincesList(proListStr);
} }
redisUtil.set(KylinRedisConst.ADMIN_BANNER_LIST, bannerList); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ADMIN_BANNER_LIST, bannerList);
} }
public boolean update(BannersParam bannersParam) { public boolean update(BannersParam bannersParam) {
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinDamaiServiceImpl.java
View file @ 8ec49361
...@@ -59,7 +59,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl ...@@ -59,7 +59,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
@Autowired @Autowired
private KylinTicketStatusMapper ticketStatusMapper; private KylinTicketStatusMapper ticketStatusMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Override @Override
public Boolean sycPerformance(String performanceId) { public Boolean sycPerformance(String performanceId) {
...@@ -81,7 +81,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl ...@@ -81,7 +81,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
} else if (performanceData.getCityId().equals(3833)) { } else if (performanceData.getCityId().equals(3833)) {
obj1.setCityId(520100L); obj1.setCityId(520100L);
} else {//520100 } else {//520100
obj1.setCityId(Long.parseLong(redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelationData.getFieldId(), "ad_code").toString())); obj1.setCityId(Long.parseLong(redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelationData.getFieldId(), "ad_code").toString()));
} }
obj1.setSupplierSecret(taobaoTicketUtils.getSupplierSecret()); obj1.setSupplierSecret(taobaoTicketUtils.getSupplierSecret());
obj1.setSystemId(taobaoTicketUtils.getSystemId()); obj1.setSystemId(taobaoTicketUtils.getSystemId());
...@@ -133,9 +133,9 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl ...@@ -133,9 +133,9 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
// } else { // } else {
// return 0L; // return 0L;
// } // }
obj1.setVenueId(Long.parseLong(redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "id").toString())); obj1.setVenueId(Long.parseLong(redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "id").toString()));
obj1.setVenueName(redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "name").toString()); obj1.setVenueName(redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "name").toString());
obj1.setVenueAddress(redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "address").toString()); obj1.setVenueAddress(redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + fieldId, "address").toString());
req.setPushVenueParam(obj1); req.setPushVenueParam(obj1);
AlibabaDamaiMevOpenPushvenueResponse rsp = client.execute(req); AlibabaDamaiMevOpenPushvenueResponse rsp = client.execute(req);
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundExecuteServiceImpl.java
View file @ 8ec49361
...@@ -44,7 +44,7 @@ public class KylinRefundExecuteServiceImpl { ...@@ -44,7 +44,7 @@ public class KylinRefundExecuteServiceImpl {
private KylinOrderRefundBatchesMapper kylinOrderRefundBatchesMapper; private KylinOrderRefundBatchesMapper kylinOrderRefundBatchesMapper;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private KylinOrderRefundsServiceImpl kylinOrderRefundsServiceImpl; private KylinOrderRefundsServiceImpl kylinOrderRefundsServiceImpl;
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundPerformancesAdminServiceImpl.java
View file @ 8ec49361
...@@ -63,7 +63,7 @@ public class KylinRefundPerformancesAdminServiceImpl { ...@@ -63,7 +63,7 @@ public class KylinRefundPerformancesAdminServiceImpl {
private KylinRefundExecuteServiceImpl kylinRefundExecuteServiceImpl; private KylinRefundExecuteServiceImpl kylinRefundExecuteServiceImpl;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
public ResponseDto refundBatchApply(RefundBatchApplyParam refundBatchApplyParam) { public ResponseDto refundBatchApply(RefundBatchApplyParam refundBatchApplyParam) {
String targetId = refundBatchApplyParam.getTargetId(); String targetId = refundBatchApplyParam.getTargetId();
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinZhengzaiAppVersionsServiceImpl.java
View file @ 8ec49361
...@@ -44,7 +44,7 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner ...@@ -44,7 +44,7 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner
private KylinZhengzaiAppVersionsMapper kylinZhengzaiAppVersionsMapper; private KylinZhengzaiAppVersionsMapper kylinZhengzaiAppVersionsMapper;
@Autowired @Autowired
RedisUtil redisUtil; RedisDataSourceUtil redisDataSourceUtil;
public boolean create(ZhengzaiAppVersionsParam zhengzaiAppVersionsParam) { public boolean create(ZhengzaiAppVersionsParam zhengzaiAppVersionsParam) {
try { try {
...@@ -127,18 +127,18 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner ...@@ -127,18 +127,18 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner
ZhengzaiAppVersionsListDao infoIos = kylinZhengzaiAppVersionsMapper.getLastInfo(1); ZhengzaiAppVersionsListDao infoIos = kylinZhengzaiAppVersionsMapper.getLastInfo(1);
ZhengzaiAppVersionsListDao infoAndroid = kylinZhengzaiAppVersionsMapper.getLastInfo(2); ZhengzaiAppVersionsListDao infoAndroid = kylinZhengzaiAppVersionsMapper.getLastInfo(2);
ZhengzaiAppVersionsVo zhengzaiAppVersionsVo = new ZhengzaiAppVersionsVo(); ZhengzaiAppVersionsVo zhengzaiAppVersionsVo = new ZhengzaiAppVersionsVo();
redisUtil.del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_IOS); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_IOS);
if (null != infoIos) { if (null != infoIos) {
BeanUtils.copyProperties(infoIos, zhengzaiAppVersionsVo); BeanUtils.copyProperties(infoIos, zhengzaiAppVersionsVo);
redisUtil.set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_IOS, zhengzaiAppVersionsVo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_IOS, zhengzaiAppVersionsVo);
} }
redisUtil.del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_ANDROID); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_ANDROID);
if (null != infoAndroid) { if (null != infoAndroid) {
String newPath = appUrl + infoAndroid.getFilePath(); String newPath = appUrl + infoAndroid.getFilePath();
infoAndroid.setFilePath(newPath); infoAndroid.setFilePath(newPath);
BeanUtils.copyProperties(infoAndroid, zhengzaiAppVersionsVo); BeanUtils.copyProperties(infoAndroid, zhengzaiAppVersionsVo);
redisUtil.set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_ANDROID, zhengzaiAppVersionsVo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_ANDROID, zhengzaiAppVersionsVo);
} }
return true; return true;
...@@ -148,18 +148,18 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner ...@@ -148,18 +148,18 @@ public class KylinZhengzaiAppVersionsServiceImpl extends ServiceImpl<KylinBanner
ZhengzaiAppVersionsListDao infoIos = kylinZhengzaiAppVersionsMapper.getLastInfoCheck(1); ZhengzaiAppVersionsListDao infoIos = kylinZhengzaiAppVersionsMapper.getLastInfoCheck(1);
ZhengzaiAppVersionsListDao infoAndroid = kylinZhengzaiAppVersionsMapper.getLastInfoCheck(2); ZhengzaiAppVersionsListDao infoAndroid = kylinZhengzaiAppVersionsMapper.getLastInfoCheck(2);
ZhengzaiAppVersionsVo zhengzaiAppVersionsVo = new ZhengzaiAppVersionsVo(); ZhengzaiAppVersionsVo zhengzaiAppVersionsVo = new ZhengzaiAppVersionsVo();
redisUtil.del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_IOS); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_IOS);
if (null != infoIos) { if (null != infoIos) {
BeanUtils.copyProperties(infoIos, zhengzaiAppVersionsVo); BeanUtils.copyProperties(infoIos, zhengzaiAppVersionsVo);
redisUtil.set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_IOS, zhengzaiAppVersionsVo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_IOS, zhengzaiAppVersionsVo);
} }
redisUtil.del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_ANDROID); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_ANDROID);
if (null != infoAndroid) { if (null != infoAndroid) {
String newPath = appUrl + infoAndroid.getFilePath(); String newPath = appUrl + infoAndroid.getFilePath();
infoAndroid.setFilePath(newPath); infoAndroid.setFilePath(newPath);
BeanUtils.copyProperties(infoAndroid, zhengzaiAppVersionsVo); BeanUtils.copyProperties(infoAndroid, zhengzaiAppVersionsVo);
redisUtil.set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_ANDROID, zhengzaiAppVersionsVo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_ANDROID, zhengzaiAppVersionsVo);
} }
return true; return true;
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/DataUtils.java
View file @ 8ec49361
...@@ -29,7 +29,7 @@ public class DataUtils { ...@@ -29,7 +29,7 @@ public class DataUtils {
@Autowired @Autowired
private MongoTemplate mongoTemplate; private MongoTemplate mongoTemplate;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private MongoVoUtils mongoVoUtils; private MongoVoUtils mongoVoUtils;
...@@ -40,7 +40,7 @@ public class DataUtils { ...@@ -40,7 +40,7 @@ public class DataUtils {
* @param totalGeneral 普通库存 * @param totalGeneral 普通库存
*/ */
public void setSurplusGeneral(String ticketId, int totalGeneral) { public void setSurplusGeneral(String ticketId, int totalGeneral) {
redisUtil.set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, totalGeneral); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, totalGeneral);
} }
/** /**
...@@ -50,7 +50,7 @@ public class DataUtils { ...@@ -50,7 +50,7 @@ public class DataUtils {
* @return 普通剩余库存 * @return 普通剩余库存
*/ */
public int getSurplusGeneral(String ticketId) { public int getSurplusGeneral(String ticketId) {
return (int) redisUtil.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL); return (int) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL);
} }
/** /**
...@@ -61,7 +61,7 @@ public class DataUtils { ...@@ -61,7 +61,7 @@ public class DataUtils {
* @return 普通剩余库存 * @return 普通剩余库存
*/ */
public int changeSurplusGeneral(String ticketId, int surplusGeneral) { public int changeSurplusGeneral(String ticketId, int surplusGeneral) {
return (int) redisUtil.incr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, surplusGeneral); return (int) redisDataSourceUtil.getRedisKylinUtil().incr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, surplusGeneral);
} }
/** /**
...@@ -71,7 +71,7 @@ public class DataUtils { ...@@ -71,7 +71,7 @@ public class DataUtils {
* @param totalExchange 兑换库存 * @param totalExchange 兑换库存
*/ */
public void setSurplusExchange(String ticketId, int totalExchange) { public void setSurplusExchange(String ticketId, int totalExchange) {
redisUtil.set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE, totalExchange); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE, totalExchange);
} }
/** /**
...@@ -80,7 +80,7 @@ public class DataUtils { ...@@ -80,7 +80,7 @@ public class DataUtils {
* @param performanceId * @param performanceId
*/ */
public void delPerformanceRedis(String performanceId) { public void delPerformanceRedis(String performanceId) {
redisUtil.del(KylinRedisConst.PERFORMANCES + performanceId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES + performanceId);
} }
/** /**
...@@ -90,7 +90,7 @@ public class DataUtils { ...@@ -90,7 +90,7 @@ public class DataUtils {
* @param isTrueName * @param isTrueName
*/ */
public void setPerformanceIsTrueName(String performanceId, int isTrueName) { public void setPerformanceIsTrueName(String performanceId, int isTrueName) {
redisUtil.set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName);
} }
/** /**
...@@ -99,7 +99,7 @@ public class DataUtils { ...@@ -99,7 +99,7 @@ public class DataUtils {
* @param ticketTimeId * @param ticketTimeId
*/ */
public void delTicketTimesRedis(String ticketTimeId) { public void delTicketTimesRedis(String ticketTimeId) {
redisUtil.del(KylinRedisConst.TIMES + ticketTimeId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.TIMES + ticketTimeId);
} }
/** /**
...@@ -108,15 +108,15 @@ public class DataUtils { ...@@ -108,15 +108,15 @@ public class DataUtils {
* @param ticketId * @param ticketId
*/ */
public void delTicketRedis(String ticketId) { public void delTicketRedis(String ticketId) {
redisUtil.del(KylinRedisConst.TICKET + ticketId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.TICKET + ticketId);
} }
public void setOrderList(String userId, List<KylinOrderListVo> vo) { public void setOrderList(String userId, List<KylinOrderListVo> vo) {
redisUtil.set(KylinRedisConst.ORDER_LIST + userId, vo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER_LIST + userId, vo);
} }
public List<KylinOrderListVo> getOrderList(String userId) { public List<KylinOrderListVo> getOrderList(String userId) {
if (redisUtil.hasKey(KylinRedisConst.ORDER_LIST + userId)) { if (redisDataSourceUtil.getRedisKylinUtil().hasKey(KylinRedisConst.ORDER_LIST + userId)) {
} else { } else {
List<KylinOrderListVo> voList = mongoTemplate.find(Query.query(Criteria.where("userId").is(userId)) List<KylinOrderListVo> voList = mongoTemplate.find(Query.query(Criteria.where("userId").is(userId))
.with(Sort.by(Sort.Direction.DESC, "createdAt")).limit(40), .with(Sort.by(Sort.Direction.DESC, "createdAt")).limit(40),
...@@ -124,9 +124,9 @@ public class DataUtils { ...@@ -124,9 +124,9 @@ public class DataUtils {
for (KylinOrderListVo item : voList) { for (KylinOrderListVo item : voList) {
item.setStatus(item.getStatus()); item.setStatus(item.getStatus());
} }
redisUtil.set(KylinRedisConst.ORDER_LIST + userId, voList); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER_LIST + userId, voList);
} }
return (List<KylinOrderListVo>) redisUtil.get(KylinRedisConst.ORDER_LIST + userId); return (List<KylinOrderListVo>) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.ORDER_LIST + userId);
} }
/** /**
...@@ -136,14 +136,14 @@ public class DataUtils { ...@@ -136,14 +136,14 @@ public class DataUtils {
* @return * @return
*/ */
public KylinOrderTicketVo getOrderTicketVo(String orderId) { public KylinOrderTicketVo getOrderTicketVo(String orderId) {
if (redisUtil.hasKey(KylinRedisConst.ORDER + orderId)) { if (redisDataSourceUtil.getRedisKylinUtil().hasKey(KylinRedisConst.ORDER + orderId)) {
} else { } else {
KylinOrderTicketVo ticketData = mongoTemplate.findOne(Query.query(Criteria.where("orderTicketsId").is(orderId)), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName()); KylinOrderTicketVo ticketData = mongoTemplate.findOne(Query.query(Criteria.where("orderTicketsId").is(orderId)), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
List<KylinOrderTicketEntitiesVo> kylinOrderTicketEntitiesVoList = mongoTemplate.find(Query.query(Criteria.where("orderId").is(orderId)), KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName()); List<KylinOrderTicketEntitiesVo> kylinOrderTicketEntitiesVoList = mongoTemplate.find(Query.query(Criteria.where("orderId").is(orderId)), KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
ticketData.setEntitiesVoList(kylinOrderTicketEntitiesVoList); ticketData.setEntitiesVoList(kylinOrderTicketEntitiesVoList);
redisUtil.set(KylinRedisConst.ORDER + orderId, ticketData); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER + orderId, ticketData);
} }
return (KylinOrderTicketVo) redisUtil.get(KylinRedisConst.ORDER + orderId); return (KylinOrderTicketVo) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.ORDER + orderId);
} }
/** /**
...@@ -152,7 +152,7 @@ public class DataUtils { ...@@ -152,7 +152,7 @@ public class DataUtils {
* @param orderId * @param orderId
*/ */
public void delOrderTicketRedis(String orderId) { public void delOrderTicketRedis(String orderId) {
redisUtil.del(KylinRedisConst.ORDER + orderId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ORDER + orderId);
} }
/** /**
...@@ -161,7 +161,7 @@ public class DataUtils { ...@@ -161,7 +161,7 @@ public class DataUtils {
* @param orderEntitiesId * @param orderEntitiesId
*/ */
public void delOrderTicketEntitiesRedis(String orderEntitiesId) { public void delOrderTicketEntitiesRedis(String orderEntitiesId) {
redisUtil.del(KylinRedisConst.ORDER_ENTITIES + orderEntitiesId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ORDER_ENTITIES + orderEntitiesId);
} }
/** /**
...@@ -170,7 +170,7 @@ public class DataUtils { ...@@ -170,7 +170,7 @@ public class DataUtils {
* @param checkUserId * @param checkUserId
*/ */
public void delCheckUserRedis(String checkUserId) { public void delCheckUserRedis(String checkUserId) {
redisUtil.del(KylinRedisConst.CHECK_USER + checkUserId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.CHECK_USER + checkUserId);
} }
/** /**
...@@ -179,7 +179,7 @@ public class DataUtils { ...@@ -179,7 +179,7 @@ public class DataUtils {
* @param checkUserId * @param checkUserId
*/ */
public void delCheckUserRelationRedis(String checkUserId) { public void delCheckUserRelationRedis(String checkUserId) {
redisUtil.del(KylinRedisConst.CHECK_USER_RELATION + checkUserId); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.CHECK_USER_RELATION + checkUserId);
} }
public void updatePerformanceMongo(String performanceIds, KylinPerformanceVo paramVo) { public void updatePerformanceMongo(String performanceIds, KylinPerformanceVo paramVo) {
...@@ -205,14 +205,14 @@ public class DataUtils { ...@@ -205,14 +205,14 @@ public class DataUtils {
} }
try { try {
//删除redis //删除redis
redisUtil.del(KylinRedisConst.PERFORMANCES + performanceIds); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES + performanceIds);
// 大龙相关 演出列表 // 大龙相关 演出列表
redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_CITYNAME + vo.getCityName()); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_LIST_CITYNAME + vo.getCityName());
redisUtil.del(KylinRedisConst.PERFORMANCES_ROADLIST + vo.getRoadShowId()); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_ROADLIST + vo.getRoadShowId());
redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_SYSTEM_RECOMMEND); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_LIST_SYSTEM_RECOMMEND);
redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_RECOMMEND); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_LIST_RECOMMEND);
redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_NOTICE); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_LIST_NOTICE);
redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_EXCLUSIVE); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.PERFORMANCES_LIST_EXCLUSIVE);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
...@@ -227,12 +227,12 @@ public class DataUtils { ...@@ -227,12 +227,12 @@ public class DataUtils {
* @return * @return
*/ */
public KylinPerformanceVo getPerformanceVo(String performanceId) { public KylinPerformanceVo getPerformanceVo(String performanceId) {
if (redisUtil.hasKey(KylinRedisConst.PERFORMANCES + performanceId)) { if (redisDataSourceUtil.getRedisKylinUtil().hasKey(KylinRedisConst.PERFORMANCES + performanceId)) {
} else { } else {
KylinPerformanceVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName()); KylinPerformanceVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
redisUtil.set(KylinRedisConst.PERFORMANCES + performanceId, performanceData); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.PERFORMANCES + performanceId, performanceData);
} }
return (KylinPerformanceVo) redisUtil.get(KylinRedisConst.PERFORMANCES + performanceId); return (KylinPerformanceVo) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.PERFORMANCES + performanceId);
} }
/** /**
...@@ -241,12 +241,12 @@ public class DataUtils { ...@@ -241,12 +241,12 @@ public class DataUtils {
* @param performanceId * @param performanceId
*/ */
public int getPerformanceIsTrueName(String performanceId) { public int getPerformanceIsTrueName(String performanceId) {
Object obj = redisUtil.get(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId); Object obj = redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId);
if (obj != null) { if (obj != null) {
return (int) obj; return (int) obj;
} else { } else {
int isTrueName = getPerformanceVo(performanceId).getIsTrueName(); int isTrueName = getPerformanceVo(performanceId).getIsTrueName();
redisUtil.set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName);
return isTrueName; return isTrueName;
} }
} }
...@@ -286,14 +286,14 @@ public class DataUtils { ...@@ -286,14 +286,14 @@ public class DataUtils {
String performanceIdKey = redisKey + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId; String performanceIdKey = redisKey + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId;
String ticketIdKey = redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId; String ticketIdKey = redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId;
// String ticketUseTimeKey = ticketIdKey + ":" + KylinRedisConst.USE_TIME; // String ticketUseTimeKey = ticketIdKey + ":" + KylinRedisConst.USE_TIME;
// redisUtil.set(ticketUseTimeKey, useTime); // redisDataSourceUtil.getRedisKylinUtil().set(ticketUseTimeKey, useTime);
if (buyCount > 0) { if (buyCount > 0) {
redisUtil.incr(ticketIdKey, buyCount); redisDataSourceUtil.getRedisKylinUtil().incr(ticketIdKey, buyCount);
redisUtil.incr(performanceIdKey, buyCount); redisDataSourceUtil.getRedisKylinUtil().incr(performanceIdKey, buyCount);
} else { } else {
redisUtil.decr(ticketIdKey, Math.abs(buyCount)); redisDataSourceUtil.getRedisKylinUtil().decr(ticketIdKey, Math.abs(buyCount));
redisUtil.decr(performanceIdKey, Math.abs(buyCount)); redisDataSourceUtil.getRedisKylinUtil().decr(performanceIdKey, Math.abs(buyCount));
} }
} }
...@@ -305,12 +305,12 @@ public class DataUtils { ...@@ -305,12 +305,12 @@ public class DataUtils {
*/ */
public void setOrderExpressInfo(String orderId, KylinOrderExpressVo kylinOrderExpressVo) { public void setOrderExpressInfo(String orderId, KylinOrderExpressVo kylinOrderExpressVo) {
String redisKey = KylinRedisConst.ORDER_EXPRESS_INFO.concat(orderId); String redisKey = KylinRedisConst.ORDER_EXPRESS_INFO.concat(orderId);
redisUtil.set(redisKey, kylinOrderExpressVo); redisDataSourceUtil.getRedisKylinUtil().set(redisKey, kylinOrderExpressVo);
} }
public void delOrderExpressInfo(String orderId) { public void delOrderExpressInfo(String orderId) {
String redisKey = KylinRedisConst.ORDER_EXPRESS_INFO.concat(orderId); String redisKey = KylinRedisConst.ORDER_EXPRESS_INFO.concat(orderId);
redisUtil.del(redisKey); redisDataSourceUtil.getRedisKylinUtil().del(redisKey);
} }
/** /**
...@@ -318,19 +318,19 @@ public class DataUtils { ...@@ -318,19 +318,19 @@ public class DataUtils {
*/ */
public void delOrderRefundVo(List<String> orderRefundIds) { public void delOrderRefundVo(List<String> orderRefundIds) {
for (String id : orderRefundIds) { for (String id : orderRefundIds) {
redisUtil.del(KylinRedisConst.ORDER_REFUND.concat(id)); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ORDER_REFUND.concat(id));
} }
} }
public void delOrderRefundVoByOrderId(List<String> orderIds) { public void delOrderRefundVoByOrderId(List<String> orderIds) {
for (String id : orderIds) { for (String id : orderIds) {
redisUtil.del(KylinRedisConst.ORDER_REFUND_BY_ORDER_ID.concat(id)); redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ORDER_REFUND_BY_ORDER_ID.concat(id));
} }
} }
public void delOrderIdUserIdRedis(List<String> orderTicketIdList, List<String> userIdList) { public void delOrderIdUserIdRedis(List<String> orderTicketIdList, List<String> userIdList) {
redisUtil.delList(orderTicketIdList); redisDataSourceUtil.getRedisKylinUtil().delList(orderTicketIdList);
redisUtil.delList(userIdList); redisDataSourceUtil.getRedisKylinUtil().delList(userIdList);
} }
/** /**
...@@ -360,13 +360,13 @@ public class DataUtils { ...@@ -360,13 +360,13 @@ public class DataUtils {
// 获取 快递地址 // 获取 快递地址
public OrderRefundAddress getRefundAddress(){ public OrderRefundAddress getRefundAddress(){
Object obj = redisUtil.get(KylinRedisConst.ORDER_REFUND_ADDRESS); Object obj = redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.ORDER_REFUND_ADDRESS);
if(obj==null){ if(obj==null){
OrderRefundAddress vo = OrderRefundAddress.getNew(); OrderRefundAddress vo = OrderRefundAddress.getNew();
vo.setName("张三"); vo.setName("张三");
vo.setPhone("010 124412"); vo.setPhone("010 124412");
vo.setAddress("北京 北京市朝阳区广渠路3-12"); vo.setAddress("北京 北京市朝阳区广渠路3-12");
redisUtil.set(KylinRedisConst.ORDER_REFUND_ADDRESS,vo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER_REFUND_ADDRESS,vo);
return vo; return vo;
}else{ }else{
return (OrderRefundAddress)obj; return (OrderRefundAddress)obj;
...@@ -376,7 +376,7 @@ public class DataUtils { ...@@ -376,7 +376,7 @@ public class DataUtils {
// 获取 用户维度 演出购买数量 // 获取 用户维度 演出购买数量
public int getUserPBuyCount(String userId, String performanceId) { public int getUserPBuyCount(String userId, String performanceId) {
try { try {
return (int) redisUtil.get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId); return (int) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId);
} catch (Exception e) { } catch (Exception e) {
return 0; return 0;
} }
...@@ -385,7 +385,7 @@ public class DataUtils { ...@@ -385,7 +385,7 @@ public class DataUtils {
// 获取 用户维度 票种购买数量 // 获取 用户维度 票种购买数量
public int getUserTBuyCount(String userId, String ticketId) { public int getUserTBuyCount(String userId, String ticketId) {
try { try {
return (int) redisUtil.get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId); return (int) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId);
} catch (Exception e) { } catch (Exception e) {
return 0; return 0;
} }
...@@ -394,7 +394,7 @@ public class DataUtils { ...@@ -394,7 +394,7 @@ public class DataUtils {
// 获取 证件维度 演出购买数量 // 获取 证件维度 演出购买数量
public int getIdCardPBuyCount(String idCard, String performanceId) { public int getIdCardPBuyCount(String idCard, String performanceId) {
try { try {
return (int) redisUtil.get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId); return (int) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId);
} catch (Exception e) { } catch (Exception e) {
return 0; return 0;
} }
...@@ -403,7 +403,7 @@ public class DataUtils { ...@@ -403,7 +403,7 @@ public class DataUtils {
// 获取 证件维度 票种购买数量 // 获取 证件维度 票种购买数量
public int getIdCardTBuyCount(String idCard, String ticketId) { public int getIdCardTBuyCount(String idCard, String ticketId) {
try { try {
return (int) redisUtil.get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId); return (int) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId);
} catch (Exception e) { } catch (Exception e) {
return 0; return 0;
} }
...@@ -415,13 +415,13 @@ public class DataUtils { ...@@ -415,13 +415,13 @@ public class DataUtils {
String redisKey = KylinRedisConst.ORDER_IMPORT_FAIL.concat(importId); String redisKey = KylinRedisConst.ORDER_IMPORT_FAIL.concat(importId);
PageInfo<OrderOutLineVo> vo = new PageInfo(vos); PageInfo<OrderOutLineVo> vo = new PageInfo(vos);
vo.setTotal(vos.size()); vo.setTotal(vos.size());
redisUtil.set(redisKey, vo); redisDataSourceUtil.getRedisKylinUtil().set(redisKey, vo);
} }
//获取 订单导入错误数据 //获取 订单导入错误数据
public PageInfo<OrderOutLineVo> getOrderImportFail(String importId) { public PageInfo<OrderOutLineVo> getOrderImportFail(String importId) {
String redisKey = KylinRedisConst.ORDER_IMPORT_FAIL.concat(importId); String redisKey = KylinRedisConst.ORDER_IMPORT_FAIL.concat(importId);
Object obj = redisUtil.get(redisKey); Object obj = redisDataSourceUtil.getRedisKylinUtil().get(redisKey);
if (obj == null) { if (obj == null) {
return new PageInfo(); return new PageInfo();
} else { } else {
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/MongoVoUtils.java
View file @ 8ec49361
...@@ -39,7 +39,7 @@ public class MongoVoUtils { ...@@ -39,7 +39,7 @@ public class MongoVoUtils {
@Autowired @Autowired
private KylinTicketRelationsMapper ticketRelationsMapper; private KylinTicketRelationsMapper ticketRelationsMapper;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private DataUtils dataUtils; private DataUtils dataUtils;
...@@ -53,12 +53,12 @@ public class MongoVoUtils { ...@@ -53,12 +53,12 @@ public class MongoVoUtils {
KylinPerformanceRelations p3 = performanceRelationsMapper.selectOne(new UpdateWrapper<KylinPerformanceRelations>().eq("performance_id", performancesId)); KylinPerformanceRelations p3 = performanceRelationsMapper.selectOne(new UpdateWrapper<KylinPerformanceRelations>().eq("performance_id", performancesId));
//场地相关数据 //场地相关数据
KylinFields fields = new KylinFields(); KylinFields fields = new KylinFields();
String cityName = (String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name"); String cityName = (String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name");
fields.setCityId(null); fields.setCityId(null);
fields.setLatitude((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "latitude")); fields.setLatitude((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "latitude"));
fields.setLongitude((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "longitude")); fields.setLongitude((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "longitude"));
fields.setCityName((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name")); fields.setCityName((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name"));
fields.setName((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "name")); fields.setName((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "name"));
//相关状态时间初始变量 //相关状态时间初始变量
LocalDateTime stopSellTime = null; LocalDateTime stopSellTime = null;
...@@ -93,7 +93,7 @@ public class MongoVoUtils { ...@@ -93,7 +93,7 @@ public class MongoVoUtils {
ticketList.add(kylinTicketVo); ticketList.add(kylinTicketVo);
//票种 库存redis //票种 库存redis
// if (!redisUtil.hasKey(KylinRedisConst.PERFORMANCES_INVENTORY + kylinTicketVo.getTicketsId() + ":" + KylinRedisConst.SURPLUS_GENERAL)) { // if (!redisDataSourceUtil.getRedisKylinUtil().hasKey(KylinRedisConst.PERFORMANCES_INVENTORY + kylinTicketVo.getTicketsId() + ":" + KylinRedisConst.SURPLUS_GENERAL)) {
// dataUtils.setSurplusGeneral(kylinTicketVo.getTicketsId(), t2.getTotalGeneral()); // dataUtils.setSurplusGeneral(kylinTicketVo.getTicketsId(), t2.getTotalGeneral());
// dataUtils.setSurplusExchange(kylinTicketVo.getTicketsId(), t2.getSurplusExchange()); // dataUtils.setSurplusExchange(kylinTicketVo.getTicketsId(), t2.getSurplusExchange());
// } // }
...@@ -168,13 +168,13 @@ public class MongoVoUtils { ...@@ -168,13 +168,13 @@ public class MongoVoUtils {
KylinOrderTicketVo data; KylinOrderTicketVo data;
if (dataSingle == null) { if (dataSingle == null) {
data = (KylinOrderTicketVo) dataUtils.getOrderTicketVo(orderId); data = (KylinOrderTicketVo) dataUtils.getOrderTicketVo(orderId);
// data = (KylinOrderTicketVo) redisUtil.get(KylinRedisConst.ORDER + orderId); // data = (KylinOrderTicketVo) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.ORDER + orderId);
} else { } else {
data = dataSingle; data = dataSingle;
} }
BeanUtils.copyProperties(data, voItem); BeanUtils.copyProperties(data, voItem);
List<KylinOrderListVo> redisData = (List<KylinOrderListVo>) dataUtils.getOrderList(userId); List<KylinOrderListVo> redisData = (List<KylinOrderListVo>) dataUtils.getOrderList(userId);
// List<KylinOrderListVo> redisData = (List<KylinOrderListVo>) redisUtil.get(KylinRedisConst.ORDER_LIST + userId); // List<KylinOrderListVo> redisData = (List<KylinOrderListVo>) redisDataSourceUtil.getRedisKylinUtil().get(KylinRedisConst.ORDER_LIST + userId);
if (type == 1) { if (type == 1) {
redisVo.add(voItem); redisVo.add(voItem);
if (redisData.size() > 0) { if (redisData.size() > 0) {
...@@ -201,7 +201,7 @@ public class MongoVoUtils { ...@@ -201,7 +201,7 @@ public class MongoVoUtils {
if (redisVo.size() == 0) { if (redisVo.size() == 0) {
vo.add(voItem); vo.add(voItem);
} }
redisUtil.set(KylinRedisConst.ORDER_LIST + userId, vo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER_LIST + userId, vo);
return true; return true;
case 2: case 2:
for (int i = 0; i < redisVo.size(); i++) { for (int i = 0; i < redisVo.size(); i++) {
...@@ -214,7 +214,7 @@ public class MongoVoUtils { ...@@ -214,7 +214,7 @@ public class MongoVoUtils {
vo.add(redisVo.get(i)); vo.add(redisVo.get(i));
} }
} }
redisUtil.set(KylinRedisConst.ORDER_LIST + userId, vo); redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER_LIST + userId, vo);
return true; return true;
default: default:
return false; return false;
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/PerformanceVoUtils.java
View file @ 8ec49361
...@@ -53,7 +53,7 @@ public class PerformanceVoUtils { ...@@ -53,7 +53,7 @@ public class PerformanceVoUtils {
@Autowired @Autowired
private MongoVoUtils mongoVoUtils; private MongoVoUtils mongoVoUtils;
@Autowired @Autowired
private RedisUtil redisUtil; private RedisDataSourceUtil redisDataSourceUtil;
@Autowired @Autowired
private KylinPerformancesMapper performancesMapper; private KylinPerformancesMapper performancesMapper;
...@@ -250,8 +250,8 @@ public class PerformanceVoUtils { ...@@ -250,8 +250,8 @@ public class PerformanceVoUtils {
BeanUtils.copyProperties(performanceUpdateMisVo, performanceRelations); BeanUtils.copyProperties(performanceUpdateMisVo, performanceRelations);
performances.setDetails(performanceUpdateMisVo.getDetails()); performances.setDetails(performanceUpdateMisVo.getDetails());
performances.setCityName((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelations.getFieldId(), "city_name")); performances.setCityName((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelations.getFieldId(), "city_name"));
performances.setCityId(Integer.parseInt((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelations.getFieldId(), "city_id"))); performances.setCityId(Integer.parseInt((String) redisDataSourceUtil.getRedisKylinUtil().getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + performanceRelations.getFieldId(), "city_id")));
performances.setCreatedAt(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getCreatedAt()))); performances.setCreatedAt(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getCreatedAt())));
performances.setTimeStart(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getTimeStart()))); performances.setTimeStart(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getTimeStart())));
performances.setTimeEnd(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getTimeEnd()))); performances.setTimeEnd(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(performanceUpdateMisVo.getTimeEnd())));
......
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