内存数据修复

back_recharge
zhangshanxue 2019-09-20 17:39:55 +08:00
parent 23cd3657e2
commit 5d487705da
1 changed files with 12 additions and 5 deletions

View File

@ -20,13 +20,11 @@ import com.ljsd.jieling.protocols.MessageTypeProto;
import com.ljsd.jieling.thrift.idl.InvalidOperException;
import com.ljsd.jieling.thrift.idl.RPCRequestGMIFace;
import com.ljsd.jieling.thrift.idl.Result;
import com.ljsd.jieling.util.AyyncWorker;
import com.ljsd.jieling.util.InnerMessageUtil;
import com.ljsd.jieling.util.MathUtils;
import com.ljsd.jieling.util.MessageUtil;
import com.ljsd.jieling.util.*;
import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.ZSetOperations;
import java.io.BufferedReader;
import java.io.File;
@ -98,7 +96,6 @@ public class GmService implements RPCRequestGMIFace.Iface {
}
List<Integer> sendIds = new LinkedList<>();
if (obj instanceof GmGlobleAbstract) {
for (ISession session : OnlineUserManager.sessionMap.values()) {
@ -116,12 +113,22 @@ public class GmService implements RPCRequestGMIFace.Iface {
}
}else if(cmd.contains("recharge")){
sendIds.addAll(rechargeInfoMap.keySet());
}else if(cmd.contains("force")){
Set<ZSetOperations.TypedTuple<String>> rankInfo = RedisUtil.getInstence().getZsetreverseRangeWithScores(RedisKey.FORCE_RANK, "", 0, 60);
for (ZSetOperations.TypedTuple<String> item : rankInfo) {
String value = item.getValue();
int uid = Integer.parseInt(value);
sendIds.add(uid);
}
} else{
String[] ids = parameters[0].split("#");
for (String id : ids) {
sendIds.add(Integer.valueOf(id));
}
}
}
int randomTime = sendIds.size() * 1;
//两分钟内发完所有协议