private static int RANK_CACHETTL = 3600*24*30; // RANK类缓存有效期1个月
private static final Log logger = LogFactory.getLog(RedisService.class);
@Autowired
private MFrameworkService mframeworkservice;
@Autowired
protected MBeanService mbeanservice;
// 保存redis记录（当数值是int类型时）
public void saveRank(String key,int number,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Long count = jedis.zadd(key, number, userid);
if(count!=null && count==1){ // 首次创建时，设置过期时间
jedis.expire(key, RANK_CACHETTL);
}
}
//保存redis记录（当数值是long类型时）
public void saveRank(String key,long number,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Long count = jedis.zadd(key, number, userid);
if(count!=null && count==1){ // 首次创建时，设置过期时间
jedis.expire(key, RANK_CACHETTL);
}
}
//获取当前名次（第一名是0,以此类推）
public Long getRankNumber(String key,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
return jedis.zrevrank(key, userid);
}
//获取当前名次的百分比
public float getRankPercent(String key,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Long rankNumber = getRankNumber(key, userid);
Long size = jedis.zcount(key, 0, 999999999);//获取参与的总人数
// 1-用户当前的排名/活动参与总人数=当前用户所占的百分比
logger.info("RedisRankService,rankNumber:"+rankNumber+",size:"+size);
//排名为空,获取的分数不是空，同时size不是0(分母不能为0)
if(!StringUtils.isEmpty(rankNumber) && !StringUtils.isEmpty(size)&&size!=0)
return Float.parseFloat(String.valueOf(rankNumber))/Float.parseFloat(String.valueOf(size));
return 0f;
}
//获取分数
public Double getRankValue(String key,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Double value = jedis.zscore(key, userid);
return (StringUtils.isEmpty(value)||value==null)?0d:value;
}
//更新排行榜中某一条数据并返回更新后的值
public Double refreshRankValue(String key,int number,String userid){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Double value = jedis.zincrby(key, number, userid);
return (StringUtils.isEmpty(value)||value==null)?0d:value;
}
//获取排行榜public JSONArray getRank(String key,int RankNumber,int orderby){
JSONArray josna = new JSONArray();
JSONObject json = null;RankVo vo = null;
JedisCluster jedis = RedisClusterCache.getJedisCluster();Setfset;
if(orderby==0)//正序
fset= jedis.zrangeWithScores(key, 0, RankNumber-1);
else//倒叙
fset= jedis.zrevrangeWithScores(key, 0, RankNumber-1);
for (Tuple s : fset) {
String userid = s.getElement();
UserInfo userinfo = mframeworkservice.get(UserInfo.class, userid);
if(StringUtils.isEmpty(userinfo))
continue;
vo = RankVo.newInstance(RankVo.class);
vo.setAvatarurl(userinfo.getAvatarurl());
vo.setUserid(userid);
vo.setNickname(userinfo.getNickname());
vo.setMobile(userinfo.getMobile());
vo.setGames_total(CommonUtils.get2Float(s.getScore()/100f));
json = JSONBeanUtils.getBeanJSONObject(BeanInfo.getBeanInfo(RankVo.class), vo);
josna.put(json);
}
return josna;
}
//获取帮我支持的列表public JSONArray getShareRecord(String key,int RankNumber,int orderby){
JSONArray josna = new JSONArray();
JSONObject json = null;RankVo vo = null;
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Setfset;
if(orderby==0)//正序
fset= jedis.zrangeWithScores(key, 0, RankNumber-1);
else//倒叙
fset= jedis.zrevrangeWithScores(key, 0, RankNumber-1);
for (Tuple s : fset) {
String userid = s.getElement();
UserInfo userinfo = mframeworkservice.get(UserInfo.class, userid);
if(StringUtils.isEmpty(userinfo))
continue;
vo = RankVo.newInstance(RankVo.class);
vo.setAvatarurl(userinfo.getAvatarurl());
vo.setUserid(userid);
vo.setNickname(userinfo.getNickname());
vo.setMobile(userinfo.getMobile());
long time =new Double(s.getScore()).longValue();
vo.setCreatetime(new Date(time));
String total = jedis.get(key.substring(0,32)+time+s.getElement());
if(StringUtils.isEmpty(total)||"null".equals(total))
total = jedis.get(key.substring(0,32)+time+"");
if(StringUtils.isEmpty(total)||"null".equals(total))
total = jedis.get(time+"");
if(StringUtils.isEmpty(total)||"null".equals(total))
continue;
vo.setGames_total(CommonUtils.get2Float(Float.parseFloat(total)/100f));
json = JSONBeanUtils.getBeanJSONObject(BeanInfo.getBeanInfo(RankVo.class), vo);
josna.put(json);
}
return josna;
}
//获取中奖记录列表public JSONArray getPrizeRecord(String key,int RankNumber,int orderby,BeanInfo beanInfo){
JSONArray josna = new JSONArray();
JSONObject json = null;PrizeRecordVo vo = null;if(key.length()<32)return josna;
JedisCluster jedis = RedisClusterCache.getJedisCluster();Setfset;
if(orderby==0)//正序
fset= jedis.zrangeWithScores(key, 0, RankNumber-1);
else//倒叙
fset= jedis.zrevrangeWithScores(key, 0, RankNumber-1);
for (Tuple s : fset) {
String userid = s.getElement().substring(0,32);
UserInfo userinfo = mframeworkservice.get(UserInfo.class, userid);
if(StringUtils.isEmpty(userinfo))
continue;
vo = PrizeRecordVo.newInstance(PrizeRecordVo.class);
vo.setAvatarurl(userinfo.getAvatarurl());
vo.setUserid(userid);
vo.setNickname(userinfo.getNickname());
vo.setMobile(userinfo.getMobile());
long time =new Double(s.getScore()).longValue();
vo.setCreatetime(new Date(time));
String prizeid = jedis.get(key.substring(0,32)+time+s.getElement());
if(StringUtils.isEmpty(prizeid)||"null".equals(prizeid))
prizeid = jedis.get(time+"");
if(StringUtils.isEmpty(prizeid)||"null".equals(prizeid))
continue;
MBeanBase bean = mbeanservice.get(beanInfo, prizeid);
if(bean!=null){
vo.setPrize_title(bean.get("prize_title").toString());
vo.setPrize_imgurl(bean.get("prize_imgurl").toString());
}
json = JSONBeanUtils.getBeanJSONObject(BeanInfo.getBeanInfo(PrizeRecordVo.class), vo);
josna.put(json);
}
return josna;
}
//获取redis记录
public String getBykey(String key){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
return jedis.get(key);
}
//获取redis记录
public int getIntBykey(String key){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
return StringUtils.isEmpty(jedis.get(key))?0:Integer.parseInt(jedis.get(key));
}
// 保存redis记录
// add by dbb, 过期时间：15日
public void saveByKey(String key,String value){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
// jedis.set(key, value);
jedis.setex(key, 3600*24*30, value);
}
//获取当前排行榜中一个区间范围的人数
public int getRankCount(String key){
JedisCluster jedis = RedisClusterCache.getJedisCluster();
Long size = jedis.zcount(key, 0, 9999999999999d);
return StringUtils.isEmpty(size)?0:size.intValue();
}
