diff --git a/serverlogic/src/main/java/com/ljsd/GmService.java b/serverlogic/src/main/java/com/ljsd/GmService.java index bb693fcc6..6832cfdc2 100644 --- a/serverlogic/src/main/java/com/ljsd/GmService.java +++ b/serverlogic/src/main/java/com/ljsd/GmService.java @@ -9,6 +9,7 @@ import com.ljsd.jieling.kefu.GmGlobleAbstract; import com.ljsd.jieling.kefu.GmInterface; import com.ljsd.jieling.kefu.GmRoleAbstract; import com.ljsd.jieling.logic.OnlineUserManager; +import com.ljsd.jieling.logic.dao.RechargeInfo; import com.ljsd.jieling.logic.dao.UserManager; import com.ljsd.jieling.logic.dao.root.User; import com.ljsd.jieling.logic.hero.HeroLogic; @@ -26,12 +27,11 @@ import org.apache.thrift.TException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.BufferedReader; import java.io.File; +import java.io.FileReader; import java.lang.reflect.Method; -import java.util.ArrayList; -import java.util.LinkedList; -import java.util.List; -import java.util.Random; +import java.util.*; public class GmService implements RPCRequestGMIFace.Iface { private static final Logger LOGGER = LoggerFactory.getLogger(GmService.class); @@ -59,6 +59,39 @@ public class GmService implements RPCRequestGMIFace.Iface { if (obj instanceof GmRoleAbstract) { + //todo + File file = new File("../conf/BuyGoodsLogic.log"); + BufferedReader bufferedReader = new BufferedReader(new FileReader(file)); + Map rechargeInfoMap = new HashMap<>(); + String readLine = null; + while ( (readLine= bufferedReader.readLine())!=null){ + if(readLine.contains("class")){ + continue; + } + String[] split = readLine.split(","); + String uidStr = split[0].split("=")[1]; + int uid = Integer.parseInt(uidStr); + RechargeInfo rechargeInfo = rechargeInfoMap.get(uid); + if( rechargeInfo == null){ + rechargeInfo = new RechargeInfo(); + rechargeInfoMap.put(uid,rechargeInfo); + } + String goodStr = split[1].split("=")[1]; + int goodID = Integer.parseInt(goodStr); + if(goodID == 8 || goodID == 7){ + rechargeInfo.setHadBuyFound(1); + }else{ + Map buyGoodsTimes = rechargeInfo.getBuyGoodsTimes(); + Integer buyCount = buyGoodsTimes.get(goodID); + if(buyCount == null){ + buyCount =1; + } + buyCount++; + buyGoodsTimes.put(goodID,buyCount); + } + } + + List sendIds = new LinkedList<>(); if (obj instanceof GmGlobleAbstract) { for (ISession session : OnlineUserManager.sessionMap.values()) {