back_recharge
wangyuan 2019-09-18 19:02:03 +08:00
parent 1368c28d55
commit 89efd6a239
1 changed files with 4 additions and 4 deletions

View File

@ -47,7 +47,7 @@ public class GmService implements RPCRequestGMIFace.Iface {
int uid = Integer.valueOf(arg[1]); int uid = Integer.valueOf(arg[1]);
List<Integer> uids = new LinkedList<>(); List<Integer> uids = new LinkedList<>();
uids.add(uid); uids.add(uid);
InnerMessageUtil.broadcastWithRandom(new AyyncWorker() { /* InnerMessageUtil.broadcastWithRandom(new AyyncWorker() {
@Override @Override
public void work(User user) throws Exception { public void work(User user) throws Exception {
int teamForce = HeroLogic.getInstance().calTeamTotalForce(user, 1, false); int teamForce = HeroLogic.getInstance().calTeamTotalForce(user, 1, false);
@ -56,7 +56,7 @@ public class GmService implements RPCRequestGMIFace.Iface {
String key = RedisKey.getKey(RedisKey.FORCE_RANK, "", false); String key = RedisKey.getKey(RedisKey.FORCE_RANK, "", false);
RedisUtil.getInstence().zsetAddOne(key, String.valueOf(user.getId()), teamForce); RedisUtil.getInstence().zsetAddOne(key, String.valueOf(user.getId()), teamForce);
} }
},uids , 10); },uids , 10);*/
return result; return result;
} }
@ -70,14 +70,14 @@ public class GmService implements RPCRequestGMIFace.Iface {
} }
sendIds.add(user1.getId()); sendIds.add(user1.getId());
} }
InnerMessageUtil.broadcastWithRandom(new AyyncWorker() { /* InnerMessageUtil.broadcastWithRandom(new AyyncWorker() {
@Override @Override
public void work(User user) throws Exception { public void work(User user) throws Exception {
LOGGER.info("hotfix user={}",user.getId()); LOGGER.info("hotfix user={}",user.getId());
MongoUtil.getLjsdMongoTemplate().save(user); MongoUtil.getLjsdMongoTemplate().save(user);
} }
}, sendIds, Math.min(10, 10)); }, sendIds, Math.min(10, 10));
result.setResultCode(1); result.setResultCode(1);*/
return result; return result;
} }