back_recharge
wangyuan 2019-09-18 19:05:50 +08:00
parent 89efd6a239
commit f4376dc49c
1 changed files with 18 additions and 0 deletions

View File

@ -1,6 +1,7 @@
package com.ljsd;
import com.ljsd.jieling.core.HandlerLogicThread;
import com.ljsd.jieling.db.mongo.MongoUtil;
import com.ljsd.jieling.db.redis.RedisKey;
import com.ljsd.jieling.db.redis.RedisUtil;
@ -11,6 +12,7 @@ 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.logic.hero.HeroLogic;
import com.ljsd.jieling.network.server.ProtocolsManager;
import com.ljsd.jieling.network.session.ISession;
import com.ljsd.jieling.protocols.MessageTypeProto;
import com.ljsd.jieling.thrift.idl.InvalidOperException;
@ -57,6 +59,22 @@ public class GmService implements RPCRequestGMIFace.Iface {
RedisUtil.getInstence().zsetAddOne(key, String.valueOf(user.getId()), teamForce);
}
},uids , 10);*/
AyyncWorker ayyncWorker = new AyyncWorker() {
@Override
public void work(User user) throws Exception {
int teamForce = HeroLogic.getInstance().calTeamTotalForce(user, 1, false);
LOGGER.info("cmd_________fore"+user.getId()+":"+teamForce);
user.getPlayerInfoManager().setMaxForce(teamForce);
String key = RedisKey.getKey(RedisKey.FORCE_RANK, "", false);
RedisUtil.getInstence().zsetAddOne(key, String.valueOf(user.getId()), teamForce);
}
};
ayyncWorker.setTask(true);
ayyncWorker.setUser(UserManager.getUser(uid));
ProtocolsManager instance = ProtocolsManager.getInstance();
HandlerLogicThread handlerThread = instance.handlerThreads[uid % instance.HANDLER_THREAD_NUM];
handlerThread.addAyyncWorker(ayyncWorker);
return result;
}