内存战力强制修改
parent
7389d9f0a8
commit
fc90b4d129
|
@ -8,18 +8,21 @@ import com.ljsd.jieling.logic.OnlineUserManager;
|
|||
import com.ljsd.jieling.logic.dao.UserManager;
|
||||
import com.ljsd.jieling.logic.dao.root.User;
|
||||
import com.ljsd.jieling.network.session.ISession;
|
||||
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 org.apache.thrift.TException;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.io.File;
|
||||
import java.lang.reflect.Method;
|
||||
import java.util.ArrayList;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Random;
|
||||
|
@ -35,6 +38,17 @@ public class GmService implements RPCRequestGMIFace.Iface {
|
|||
String[] arg = cmd.split(" ");
|
||||
GmInterface obj;
|
||||
try {
|
||||
|
||||
if(cmd.contains("force")){
|
||||
InnerMessageUtil.broadcastWithRandom(new AyyncWorker() {
|
||||
@Override
|
||||
public void work(User user) throws Exception {
|
||||
user.getPlayerInfoManager().setMaxForce(0);
|
||||
}
|
||||
}, new ArrayList<>(OnlineUserManager.sessionMap.keySet()), 10);
|
||||
return result;
|
||||
}
|
||||
|
||||
obj = (GmInterface) Class.forName(
|
||||
GmInterface.class.getPackage().getName() + ".Cmd_"
|
||||
+ arg[0].toLowerCase()).newInstance();
|
||||
|
|
|
@ -91,7 +91,7 @@ public class ExchangeCdkHandler extends BaseHandler<PlayerInfoProto.ExchangeCdkR
|
|||
|
||||
long size = MongoUtil.getCoreMongoTemplate().count(new BasicQuery(new BasicDBObject("uid", uid).append("goodsId", goodsId)), CdkUseInfo.class);
|
||||
if (size >= scdkInfo.getRoleUseNum()) {
|
||||
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "已达角色兑换上线");
|
||||
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "已达角色兑换上限");
|
||||
return;
|
||||
}
|
||||
|
||||
|
|
|
@ -127,7 +127,7 @@ public abstract class AbstractActivity implements IActivity, IEventHandler {
|
|||
//take rewards check
|
||||
if (!takeRewardsProcess(session, sActivityRewardConfig, activityProgressInfo)) {
|
||||
LOGGER.error("the uid={} the misionId={},the missionProgress={},the require is={} ", session.getUid(), sActivityRewardConfig.getId(), activityProgressInfo.getProgrss(), sActivityRewardConfig.getValues());
|
||||
MessageUtil.sendErrorResponse(session, 0, rewardResponseValue, "value illegality");
|
||||
MessageUtil.sendErrorResponse(session, 0, rewardResponseValue, "未达到领取条件");
|
||||
return false;
|
||||
}
|
||||
//up miss
|
||||
|
|
Loading…
Reference in New Issue