From 62ddfec982d6c69e8e48440958f78c1f25551712 Mon Sep 17 00:00:00 2001 From: lvxinran Date: Thu, 10 Jun 2021 16:36:46 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ljsd/jieling/kefu/Cmd_recharge.java | 98 +++++++++---------- 1 file changed, 49 insertions(+), 49 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_recharge.java b/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_recharge.java index d153f5108..3f138a06f 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_recharge.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_recharge.java @@ -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 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 serverIds = new HashSet<>(); - serverIds.add(serverId); - recharge.setServerId(serverIds); - }else{ - Set 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 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 serverIds = new HashSet<>(); +// serverIds.add(serverId); +// recharge.setServerId(serverIds); +// }else{ +// Set 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; } }