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

Skip to content

L
liquidnet-bus-v1
Commit feddcdb7 authored by GaoHu's avatar GaoHu
Browse files
Options

exit

parent b6085670
Show whitespace changes
Inline Side-by-side
Showing with 187 additions and 56 deletions
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java
View file @ feddcdb7
......@@ -15,7 +15,6 @@ import com.liquidnet.client.admin.zhengzai.slime.service.ISlimeAuthorizationReco
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.kylin.constant.KylinRedisConst;
import com.liquidnet.service.kylin.dao.*;
import com.liquidnet.service.kylin.dto.param.*;
......@@ -622,7 +621,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
List<String> collect = kylinPerformances.stream().map(KylinPerformances::getPerformancesId).collect(Collectors.toList());
String perId = StringUtils.join(collect,",");
if (!"".equals(perId)){
smileRedisUtils.set(SmileRedisConst.SMILE_SHOW,perId);
smileRedisUtils.setShowIds(perId);
}
return true;
} catch (Exception e) {
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/SaleDataVo.java
View file @ feddcdb7
......@@ -20,6 +20,11 @@ public class SaleDataVo {
*/
private String title;
/**
* 演出打款状态
*/
private Integer priceStatus;
/**
* 票提设置集合
*/
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/UserData.java
View file @ feddcdb7
......@@ -33,6 +33,11 @@ public class UserData {
*/
private Integer type;
/**
* 打款状态
*/
private Integer priceStatus;
@ApiModelProperty(value = "活动名字")
private String activeName;
@ApiModelProperty(value = "id(用户+活动id)")
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileAgentServiceImpl.java
View file @ feddcdb7
......@@ -9,7 +9,6 @@ import com.liquidnet.client.admin.common.utils.StringUtils;
import com.liquidnet.client.admin.zhengzai.smile.dto.SmileAgentDao;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmileAgentService;
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SmileAgentVo;
import com.liquidnet.service.kylin.entity.KylinTickets;
import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
......@@ -75,7 +74,7 @@ public class SmileAgentServiceImpl extends ServiceImpl<SmileAgentMapper, SmileAg
smileAgentMapper.updateAgentById(smileAgent.getId(),smileAgent.getTotalCarry(),smileAgent.getOrdCarry());
SmileAgentVo smileAgentVo = new SmileAgentVo();
BeanUtils.copyProperties(smileAgent, smileAgentVo);
smileRedisUtils.set(SmileRedisConst.SMILE_AGENT.concat(smileAgent.getPerformanceId()).concat(":").concat(smileAgent.getTicketId()), smileAgentVo);
smileRedisUtils.setAgent(smileAgent.getPerformanceId(),smileAgent.getTicketId(), smileAgentVo);
log.debug("create create Agent id：{},PerformanceId:{},TicketId:{}",
smileAgent.getId(),
smileAgent.getPerformanceId(),
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileOrganizationServiceImpl.java
View file @ feddcdb7
......@@ -15,7 +15,6 @@ import com.liquidnet.client.admin.zhengzai.smile.dto.SmileUserVoOrg;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmileOrganizationService;
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SmileUserVO;
import com.liquidnet.service.smile.entity.SmileOrganization;
import com.liquidnet.service.smile.entity.SmileUser;
......@@ -64,7 +63,7 @@ public class SmileOrganizationServiceImpl extends ServiceImpl<SmileOrganizationM
log.info("organizationList orgId:{}", smileOrganization.getId());
//根据代理id 用户uid查询用户名称
if (StringUtils.isNotEmpty(smileOrganization.getAgentId())){
SmileUserVO smileUserVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + smileOrganization.getAgentId());
SmileUserVO smileUserVO = smileRedisUtils.getSmileUserVO(smileOrganization.getAgentId());
if (smileUserVO != null) {
smileOrganizationVo.setAgentName(smileUserVO.getName());
}
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileSchoolServiceImpl.java
View file @ feddcdb7
......@@ -10,7 +10,6 @@ import com.liquidnet.client.admin.zhengzai.smile.dto.SmileSchoolParam;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmileSchoolService;
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SmileSchoolVo;
import com.liquidnet.service.smile.entity.SmileSchool;
import com.liquidnet.service.smile.entity.SmileUser;
......@@ -74,8 +73,9 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
queryWrapper.eq(SmileSchool::getName, smileSchool.getName());
queryWrapper.eq(SmileSchool::getDelTag,0);
if (smileSchoolMapper.selectOne(queryWrapper) == null) {
int id = smileSchoolMapper.insert(smileSchool);
smileRedisUtils.set(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(String.valueOf(smileSchool.getId())),smileSchool.getName());
smileSchoolMapper.insert(smileSchool);
//保存学校
smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()),smileSchool.getName());
updateSchoolRedis();
return AjaxResult.success();
}
......@@ -91,7 +91,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
if (smileSchoolMapper.update(smileSchool, queryWrapper) > 0) {
//更新User表 根据学校id修改用户学校名称
smileUserMapper.updateUserSchoolBySchoolId(smileSchool.getId().toString(), smileSchool.getName());
smileRedisUtils.set(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(String.valueOf(smileSchool.getId())),smileSchool.getName());
smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()),smileSchool.getName());
//更新redis
updateSchoolRedis();
return AjaxResult.success();
......@@ -111,8 +111,8 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
}
//学校没有被使用 可以删除
smileSchoolMapper.updateDel(id);
smileRedisUtils.del(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(String.valueOf(id)));
smileRedisUtils.delSchool(String.valueOf(id));
updateSchoolRedis();
return AjaxResult.success();
}
......@@ -128,7 +128,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
e.printStackTrace();
}
});
smileRedisUtils.set(SmileRedisConst.SMILE_SCHOOL, smileSchoolVos);
smileRedisUtils.setSchoolAll(smileSchoolVos);
}
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileShowServiceImpl.java
View file @ feddcdb7
......@@ -10,7 +10,6 @@ import com.liquidnet.client.admin.common.utils.StringUtils;
import com.liquidnet.client.admin.zhengzai.smile.dto.*;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmileShowService;
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SellDataVO;
import com.liquidnet.service.kylin.dao.KylinOrderTicketAndAgentVo;
import com.liquidnet.service.kylin.dao.TicketAndStatusDao;
......@@ -105,7 +104,7 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//城市
vo.setCityName(kylinPerformances.getCityName());
//根据演出id 查询所有订单
List<KylinOrderTicketAndAgentVo> kylinOrderTicketsList = kylinOrderTicketsMapper.selectListByPerformanceId(kylinPerformances.getPerformancesId(),null);
List<KylinOrderTicketAndAgentVo> kylinOrderTicketsList = kylinOrderTicketsMapper.selectListByPerformanceId(kylinPerformances.getPerformancesId(), null);
int open = 0;
BigDecimal totalSalePrice = BigDecimal.valueOf(0);
......@@ -119,12 +118,8 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
}
}
vo.setOpen(open);
//缓存redis
smileRedisUtils.set(SmileRedisConst.SELL_SHOW_POEN.concat(kylinPerformances.getPerformancesId()), open);
vo.setTotalSalePrice(totalSalePrice);
//缓存redis
smileRedisUtils.set(SmileRedisConst.SELL_SHOW_TOTAL_SALE_PRICE.concat(kylinPerformances.getPerformancesId()), totalSalePrice);
//根据演出id查询销售代理
List<Long> ordNum = kylinOrderTicketRelationsMapper.concatByAgentDed(kylinPerformances.getPerformancesId());
......@@ -136,11 +131,11 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//演出状态
LambdaQueryWrapper<KylinPerformanceStatus> queryWrapper = Wrappers.lambdaQuery(KylinPerformanceStatus.class);
queryWrapper.eq(KylinPerformanceStatus::getPerformanceId,kylinPerformances.getPerformancesId());
queryWrapper.eq(KylinPerformanceStatus::getPerformanceId, kylinPerformances.getPerformancesId());
vo.setShowStatus(kylinPerformanceStatusMapper.selectOne(queryWrapper).getStatus());
//打款状态
vo.setStatus((String) smileRedisUtils.get(SmileRedisConst.SMILE_SHOW.concat(kylinPerformances.getPerformancesId())));
vo.setStatus(smileRedisUtils.getShowStatus(kylinPerformances.getPerformancesId()));
//演出顺序
vo.setComment(kylinPerformances.getComment());
......@@ -160,7 +155,8 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//获取排序演出id
List<String> collect = kylinPerformancesMapper.selectPerIdByAgent().stream().map(KylinPerformances::getPerformancesId).collect(Collectors.toList());
String perId = StringUtils.join(collect, ",");
smileRedisUtils.set(SmileRedisConst.SMILE_SHOW, perId);
//保存所有演出id带顺序
smileRedisUtils.setShowIds(perId);
log.info("redis show key:{}", perId);
return AjaxResult.success();
}
......@@ -169,19 +165,26 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
public AjaxResult price(SmilePriceParam smilePriceParam) {
SmilePrice smilePrice = new SmilePrice();
BeanUtils.copyProperties(smilePriceParam, smilePrice);
Integer status = smileRedisUtils.getShowPriceUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
if (smilePriceParam.getStatus().equals(status)) {
return AjaxResult.warn("不可重复打款");
}
//查询该用户的佣金
SellDataVO sellDataVO = smileRedisUtils.getSellDataVO(smilePriceParam.getUid(), smilePriceParam.getPerformancesId());
smilePrice.setPrice(sellDataVO.getTotalCommission());
if (smilePriceParam.getStatus().equals(0)){
smilePrice.setCreatedDate(LocalDateTime.now());
smilePriceMapper.insert(smilePrice);
smileRedisUtils.set(SmileRedisConst.SELL_SHOW_PAYMENT.concat(smilePriceParam.getPerformancesId()).concat(":").concat(smilePriceParam.getUid()), 1);
}else {
smileRedisUtils.setPriceByUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
} else {
//删除打款信息
smileRedisUtils.del(SmileRedisConst.SELL_SHOW_PAYMENT.concat(smilePriceParam.getPerformancesId()).concat(":").concat(smilePriceParam.getUid()));
LambdaQueryWrapper<SmilePrice> queryWrapper =Wrappers.lambdaQuery(SmilePrice.class);
queryWrapper.eq(SmilePrice::getPerformancesId,smilePriceParam.getPerformancesId());
queryWrapper.eq(SmilePrice::getUid,smilePriceParam.getUid());
smileRedisUtils.delPriceByUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
LambdaQueryWrapper<SmilePrice> queryWrapper = Wrappers.lambdaQuery(SmilePrice.class);
queryWrapper.eq(SmilePrice::getPerformancesId, smilePriceParam.getPerformancesId());
queryWrapper.eq(SmilePrice::getUid, smilePriceParam.getUid());
smilePrice.setUpdatedDate(LocalDateTime.now());
smilePrice.setDelTag(1);
smilePriceMapper.update(smilePrice,queryWrapper);
smilePriceMapper.update(smilePrice, queryWrapper);
}
return AjaxResult.success();
}
......@@ -207,7 +210,7 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//代理票的id
List<String> ticketsIdList = smileAgents.stream().map(SmileAgent::getTicketId).collect(Collectors.toList());
if (ticketsIdList.size()>0){
if (ticketsIdList.size() > 0) {
//根据票提IDs查询票信息
List<TicketAndStatusDao> ticketAndStatusDaoList = kylinTicketsMapper.selectTicketsByIds(ticketsIdList);
......@@ -226,7 +229,7 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
showTicketVo.setTotalGeneral(ticketAndStatusDao.getTotalGeneral());
//根据演出id查询处所有订单
List<KylinOrderTicketAndAgentVo> kylinOrderTicketsList = kylinOrderTicketsMapper.selectListByPerformanceId(performancesId,ticketAndStatusDao.getTicketsId());
List<KylinOrderTicketAndAgentVo> kylinOrderTicketsList = kylinOrderTicketsMapper.selectListByPerformanceId(performancesId, ticketAndStatusDao.getTicketsId());
//代理销售数量
int agentSaleNum = 0;
//总销售金额
......@@ -286,8 +289,12 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
if (!StringUtils.isEmpty(performancesId)) {
SaleDataVo saleDataVo = new SaleDataVo();
//设置演出状态
saleDataVo.setPriceStatus(smileRedisUtils.getShowPriceId(performancesId));
List<SmileAgent> smileAgents = getSmileAgentsByProId(performancesId);
if (smileAgents.size() == 0) {
return AjaxResult.error("该演出未开启代理");
}
Map<String, SmileAgent> map = getSmileAgentMap(smileAgents);
List<String> ticketsIdList = smileAgents.stream().map(SmileAgent::getTicketId).collect(Collectors.toList());
......@@ -317,23 +324,20 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
@Override
public AjaxResult allPrice(String performancesId) {
//缓存redis
String allPrice = (String)smileRedisUtils.get(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId));
if (StringUtils.isNotEmpty(allPrice)){
smileRedisUtils.set(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId),1);
}else {
smileRedisUtils.del(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId));
}
smileRedisUtils.setShowPriceId(performancesId);
return AjaxResult.success();
}
private UserData getUserData(String performancesId, SmileUser smileUser) {
UserData userData = new UserData();
SellDataVO sellDataVO = (SellDataVO) smileRedisUtils.get(SmileRedisConst.SELL_DATA.concat(smileUser.getUid()).concat(performancesId));
SellDataVO sellDataVO = smileRedisUtils.getSellDataVO(smileUser.getUid(), performancesId);
BeanUtils.copyProperties(sellDataVO, userData);
userData.setUid(smileUser.getUid());
userData.setUsername(smileUser.getName());
userData.setCityName(smileUser.getCity());
userData.setType(smileUser.getType());
//设置打款状态
userData.setPriceStatus(smileRedisUtils.getShowPriceUid(performancesId, smileUser.getUid()));
return userData;
}
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileUserServiceImpl.java
View file @ feddcdb7
......@@ -9,8 +9,8 @@ import com.liquidnet.client.admin.common.utils.StringUtils;
import com.liquidnet.client.admin.zhengzai.smile.dto.*;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmileUserService;
import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SmileUserVO;
import com.liquidnet.service.smile.entity.SmileOrganization;
import com.liquidnet.service.smile.entity.SmileSchool;
......@@ -37,6 +37,9 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
@Autowired
SmileUserMapper smileUserMapper;
@Autowired
RedisDataSourceUtil redisDataSourceUtil;
@Autowired
SmileRedisUtils smileRedisUtils;
......@@ -71,7 +74,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
private String getSchoolNameById(String schoolId) {
//从redis获取学校名称
String schoolName = (String) smileRedisUtils.get(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(schoolId));
String schoolName = smileRedisUtils.getSchoolNameById(schoolId);
if (StringUtils.isEmpty(schoolName)) {
//查询数据库
LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class);
......@@ -79,7 +82,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
SmileSchool smileSchool = smileSchoolMapper.selectOne(queryWrapper);
schoolName = smileSchool.getName();
//缓存redis中
smileRedisUtils.set(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(schoolId), smileSchool.getName());
smileRedisUtils.setSchool(schoolId, schoolName);
}
return schoolName;
}
......@@ -205,8 +208,9 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
if (smileUsers != null && smileUsers.size() > 0) {
//更新普代redis缓存
smileUsers.forEach(smileUser -> {
SmileUserVO userVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER.concat(smileUser.getUid()));
userVO.setAgentId(smileOrganization.getAgentId());
SmileUserVO smileUserVO = smileRedisUtils.getSmileUserVO(smileUser.getUid());
smileUserVO.setAgentId(smileOrganization.getAgentId());
smileRedisUtils.setSmileUserVO(smileUser.getUid(),smileUserVO);
});
}
}
......@@ -236,7 +240,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
SmileUserVO smileUserVO = new SmileUserVO();
BeanUtils.copyProperties(smileUser, smileUserVO);
//存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + smileUser.getUid(), smileUserVO);
smileRedisUtils.setSmileUserVO(smileUser.getUid(),smileUserVO);
}
//更新redis中的用户数据
......@@ -252,23 +256,20 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
//存入总代理id
smileUserVO.setAgentId(agentId);
//存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
smileRedisUtils.setSmileUserVO(uid, smileUserVO);
}
//跟新redis中的用户 0：正常，1：黑名单
private void updateRedisSetUser(SmileUserVO smileUserVO, String uid, Integer state) {
SmileUserVO smileUserVO1 = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + uid);
SmileUserVO smileUserVO1 = smileRedisUtils.getSmileUserVO(uid);
if (StringUtils.isNotNull(smileUserVO1)) {
smileUserVO1.setState(state);
//存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO1);
} else {
//状态 0：正常，1：黑名单
if (StringUtils.isNotNull(state)) smileUserVO.setState(state);
//存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
}
//存入黑白名单状态
smileRedisUtils.setSmileUserVO(uid,smileUserVO1);
}
//审核失败插入原因
......@@ -276,6 +277,6 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
//审核失败原因
if (StringUtils.isNotNull(reason)) smileUserVO.setErrorReason(reason);
//存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
smileRedisUtils.setSmileUserVO(uid, smileUserVO);
}
}
\ No newline at end of file
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/utils/SmileRedisUtils.java
View file @ feddcdb7
package com.liquidnet.client.admin.zhengzai.smile.utils;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.service.goblin.constant.SmileRedisConst;
import com.liquidnet.service.goblin.dto.vo.SellDataVO;
import com.liquidnet.service.goblin.dto.vo.SmileAgentVo;
import com.liquidnet.service.goblin.dto.vo.SmileSchoolVo;
import com.liquidnet.service.goblin.dto.vo.SmileUserVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
......@@ -12,7 +17,121 @@ public class SmileRedisUtils {
@Autowired
RedisDataSourceUtil redisDataSourceUtil;
public Boolean set(String key, Object value){
/**
* redis保存用户
*/
public void setSmileUserVO(String uid, SmileUserVO smileUserVO){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_USER.concat(uid), smileUserVO);
}
/**
* redis获取SmileUserVO
*/
public SmileUserVO getSmileUserVO(String uid){
return (SmileUserVO)redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SMILE_USER.concat(uid));
}
/**
* 根据学校id获取学校名称
*/
public String getSchoolNameById(String schoolId){
return (String) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(schoolId));
}
/**
* 保存/更新学校
*/
public void setSchool(String schoolId, String schoolName){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(schoolId), schoolName);
}
/**
* 保存全部学校
*/
public void setSchoolAll(List<SmileSchoolVo> smileSchoolVos){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_SCHOOL,smileSchoolVos);
}
/**
* 删除学校
*/
public void delSchool(String schoolId){
redisDataSourceUtil.getRedisSweetUtil().del(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(schoolId));
}
/**
* 获取演出打款状态
*/
public String getShowStatus(String performancesId){
return (String) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SMILE_SHOW.concat(performancesId));
}
/**
* 保存演出ids
*/
public void setShowIds(String perId){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_SHOW, perId);
}
/**
* 保存个人打款
*/
public void setPriceByUid(String performancesId,String uid){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId).concat(":").concat(uid),1);
}
/**
* 获取个人打款状态
*/
public Integer getShowPriceUid(String performancesId,String uid){
return (Integer) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId).concat(":").concat(uid));
}
/**
* 删除个人打款状态
*/
public void delPriceByUid(String performancesId,String uid){
redisDataSourceUtil.getRedisSweetUtil().del(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId).concat(":").concat(uid));
}
/**
* 总共演出打款
*/
public void setShowPriceId(String performancesId){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId),1);
}
/**
* 总共演出打款删除
*/
public void delShowPriceId(String performancesId){
redisDataSourceUtil.getRedisSweetUtil().del(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId));
}
/**
*获取演出打款状态
*/
public Integer getShowPriceId(String performancesId){
return (Integer) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId));
}
/**
* 获取用户数据
*/
public SellDataVO getSellDataVO(String uid,String performancesId){
return (SellDataVO) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_DATA.concat(uid).concat(performancesId));
}
/**
* 保存票提
*/
public void setAgent(String performancesId,String ticketId, SmileAgentVo smileAgentVo){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_AGENT.concat(performancesId).concat(":").concat(ticketId), smileAgentVo);
}
/*public Boolean set(String key, Object value){
return redisDataSourceUtil.getRedisSweetUtil().set(key, value);
}
......@@ -54,5 +173,5 @@ public class SmileRedisUtils {
public boolean hasKey(String key) {
return redisDataSourceUtil.getRedisSweetUtil().hasKey(key);
}
}*/
}
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