修改查询接口

main
grimm 2025-04-30 15:46:57 +08:00
parent 9ec5d64857
commit a8ae5876c8
1 changed files with 4 additions and 3 deletions

View File

@ -2059,14 +2059,15 @@ public class PayController {
for(CoreUserInfo user : list){
String serverId = String.valueOf(user.getServerid());
BasicQuery serverQuery = new BasicQuery(new BasicDBObject("server_id", serverId));
ServerInfo serverInfo = mongoTemplate.findOne(query, ServerInfo.class, "server_info");
ServerInfo serverInfo = mongoTemplate.findOne(serverQuery, ServerInfo.class, "server_info");
String uid = String.valueOf(user.getUid());
if(serverInfo == null){
LOGGER.info("f5GetRole--02, user serverInfo not exist uid={}",uid);
continue;
}
String uid = String.valueOf(user.getUid());
PlayerInfoCache cache = RedisUtil.getInstence().getMapValue(RedisUserKey.PLAYER_INFO_CACHE + RedisUserKey.Delimiter_colon, "",uid, PlayerInfoCache.class,-1);
if(cache == null){
LOGGER.error("f5GetRole--02, user not exist uid={}",uid);
LOGGER.info("f5GetRole--03, user cache not exist uid={}",uid);
continue;
}
JSONObject serverObj = new JSONObject();