删除无用

back_recharge
lvxinran 2021-06-10 16:36:46 +08:00
parent 4d146a767b
commit 62ddfec982
1 changed files with 49 additions and 49 deletions

View File

@ -25,55 +25,55 @@ import java.util.Set;
public class Cmd_recharge extends GmAbstract {
@Override
public boolean exec(String[] args) throws Exception {
int serverId = GameApplication.serverId;
MongoTemplate monogTemplate = MongoUtil.getInstence().getMonogTemplate(serverId);
MongoTemplate coreMongoTemplate = MongoUtil.getCoreMongoTemplate();
Query query = new Query(Criteria.where("_id").ne("100000"));
query.fields().include("playerManager");
long count = monogTemplate.count(query, User.class, "user");
int pageSize = 10;
//分页
for(int i = 0 ; i <count/pageSize+1;i++){
Pageable pageable = new PageRequest(i,pageSize);
List<User> allByCondition = monogTemplate.find(query.with(pageable), User.class,"user");
for(User user:allByCondition){
PlayerManager playerInfoManager = user.getPlayerInfoManager();
System.out.println(user.getId());
NewRechargeInfo newRechargeInfo = playerInfoManager.getNewRechargeInfo();
RechargeInfo rechargeInfo = playerInfoManager.getRechargeInfo();
double rr = (rechargeInfo==null?0:rechargeInfo.getSaveAmt())+(newRechargeInfo==null?0:newRechargeInfo.getRr());
if(rr==0){
continue;
}
//判断是否有其他服已经加入过充值信息
Query rechargeQuery = new Query(Criteria.where("_id").is(playerInfoManager.getOpenId()));
Recharge recharge = coreMongoTemplate.findOne(rechargeQuery, Recharge.class, "recharge");
if(recharge==null){
recharge = new Recharge();
recharge.setId(playerInfoManager.getOpenId());
recharge.setRr(rr);
Set<Integer> serverIds = new HashSet<>();
serverIds.add(serverId);
recharge.setServerId(serverIds);
}else{
Set<Integer> serverIds = recharge.getServerId();
if(serverIds!=null&&serverIds.contains(serverId)){
continue;
}
recharge.setRr(recharge.getRr()+rr);
recharge.getServerId().add(serverId);
}
coreMongoTemplate.save(recharge,"recharge");
}
}
System.out.println();
// int serverId = GameApplication.serverId;
// MongoTemplate monogTemplate = MongoUtil.getInstence().getMonogTemplate(serverId);
// MongoTemplate coreMongoTemplate = MongoUtil.getCoreMongoTemplate();
//
// Query query = new Query(Criteria.where("_id").ne("100000"));
// query.fields().include("playerManager");
// long count = monogTemplate.count(query, User.class, "user");
//
// int pageSize = 10;
//
// //分页
// for(int i = 0 ; i <count/pageSize+1;i++){
// Pageable pageable = new PageRequest(i,pageSize);
// List<User> allByCondition = monogTemplate.find(query.with(pageable), User.class,"user");
//
// for(User user:allByCondition){
// PlayerManager playerInfoManager = user.getPlayerInfoManager();
// System.out.println(user.getId());
// NewRechargeInfo newRechargeInfo = playerInfoManager.getNewRechargeInfo();
// RechargeInfo rechargeInfo = playerInfoManager.getRechargeInfo();
// double rr = (rechargeInfo==null?0:rechargeInfo.getSaveAmt())+(newRechargeInfo==null?0:newRechargeInfo.getRr());
// if(rr==0){
// continue;
// }
// //判断是否有其他服已经加入过充值信息
// Query rechargeQuery = new Query(Criteria.where("_id").is(playerInfoManager.getOpenId()));
// Recharge recharge = coreMongoTemplate.findOne(rechargeQuery, Recharge.class, "recharge");
// if(recharge==null){
// recharge = new Recharge();
// recharge.setId(playerInfoManager.getOpenId());
// recharge.setRr(rr);
// Set<Integer> serverIds = new HashSet<>();
// serverIds.add(serverId);
// recharge.setServerId(serverIds);
// }else{
// Set<Integer> serverIds = recharge.getServerId();
// if(serverIds!=null&&serverIds.contains(serverId)){
// continue;
// }
// recharge.setRr(recharge.getRr()+rr);
// recharge.getServerId().add(serverId);
// }
// coreMongoTemplate.save(recharge,"recharge");
// }
//
// }
//
//
// System.out.println();
return true;
}
}