Browse Source

游戏派排名

master
6 years ago
parent
commit
7e9e42bca3
  1. 8
      game/src/main/java/com/ccsens/game/service/ClientService.java
  2. 7
      game/src/main/java/com/ccsens/game/service/ScreenService.java
  3. 2
      game/src/main/java/com/ccsens/game/util/SendMsg.java

8
game/src/main/java/com/ccsens/game/service/ClientService.java

@ -51,16 +51,12 @@ public class ClientService implements IClientService {
@Autowired
private GameUserJoinDao gameUserJoinDao;
@Autowired
private GameRecordDao gameRecordDao;
@Autowired
private Snowflake snowflake;
@Autowired
private RedisUtil redisUtil;
@Autowired
private TallFeignClient tallFeignClient;
@Autowired
private SendMsg sendMsg;
@Autowired
private IScreenService screenService;
@ -157,7 +153,7 @@ public class ClientService implements IClientService {
ClientVo.CompletedData completedData = new ClientVo.CompletedData();
completedData.setTimes(join.getTimes());
completedData.setScore(join.getScore());
Integer sort = gameUserJoinDao.getRanking(join.getUserId(), join.getUserId());
Integer sort = gameUserJoinDao.getRanking(join.getUserId(), gameRecord.getId());
if(ObjectUtil.isNotNull(sort)){
completedData.setSort(sort);
}else {
@ -167,7 +163,7 @@ public class ClientService implements IClientService {
GameUserJoinExample joinExample = new GameUserJoinExample();
joinExample.createCriteria().andRecordIdEqualTo(gameRecord.getId());
long count = gameUserJoinDao.countByExample(joinExample);
completedData.setOver((int) (low/count * 100));
completedData.setOver((int) (low * 100/count));
joinVo.setCompletedData(completedData);
break;
default: break;

7
game/src/main/java/com/ccsens/game/service/ScreenService.java

@ -11,7 +11,6 @@ import com.ccsens.game.bean.dto.ScreenDto;
import com.ccsens.game.bean.dto.message.BaseMessageDto;
import com.ccsens.game.bean.dto.message.ChromeMessageDto;
import com.ccsens.game.bean.po.*;
import com.ccsens.game.bean.vo.ClientVo;
import com.ccsens.game.bean.vo.ScreenVo;
import com.ccsens.game.persist.dao.*;
import com.ccsens.game.util.GameConstant;
@ -25,7 +24,6 @@ import com.ccsens.util.exception.BaseException;
import com.fasterxml.jackson.core.JsonProcessingException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Service;
@ -36,6 +34,9 @@ import java.io.File;
import java.util.*;
import java.util.concurrent.*;
/**
* @author zy
*/
@Slf4j
@Service
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
@ -62,8 +63,6 @@ public class ScreenService implements IScreenService{
@Autowired
private Snowflake snowflake;
@Autowired
private RabbitTemplate rabbitTemplate;
@Autowired
private SendMsg sendMsg;
@Autowired
private RedisUtil redisUtil;

2
game/src/main/java/com/ccsens/game/util/SendMsg.java

@ -113,7 +113,7 @@ public class SendMsg {
user.setScore(type.getScore().intValue());
log.info("{} score: {}", type.getValue(), type.getScore());
Long sort = redisUtil.zsReverseRank(userKey, type.getValue());
user.setSort(sort == null ? 1 : sort.intValue());
user.setSort(sort == null ? 1 : sort.intValue() + 1);
//超过
Set<Object> overs = redisUtil.zsGetByScore(userKey, 0, user.getScore() - 1);
Long total = redisUtil.zsGetSize(userKey);

Loading…
Cancel
Save