diff --git a/game_web/robot_mgr/src/main/java/com/group/MainServer.java b/game_web/robot_mgr/src/main/java/com/group/MainServer.java index 87b0804..88bdc1c 100644 --- a/game_web/robot_mgr/src/main/java/com/group/MainServer.java +++ b/game_web/robot_mgr/src/main/java/com/group/MainServer.java @@ -10,15 +10,17 @@ import java.util.concurrent.TimeUnit; import com.data.cache.AccountCache; import com.data.cache.GroupCache; import com.taurus.core.entity.ITArray; +import com.taurus.core.entity.ITObject; import com.taurus.core.plugin.database.DataBase; import com.taurus.core.plugin.redis.Redis; import com.taurus.core.routes.Extension; import com.taurus.core.routes.Routes; import com.taurus.permanent.TPServer; -import hunan.DoTest; +//import hunan.DoTest; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import redis.clients.jedis.Jedis; import taurus.client.NetManager; @@ -75,7 +77,7 @@ public class MainServer extends Extension { @Override public void run() { try { - System.out.println("开始创建机器人连接..."); + System.out.println("开始创建机器人连接1111111"); // QingChu qingChu = new QingChu(); // qingChu.qingchu(); @@ -114,19 +116,46 @@ public class MainServer extends Extension { * 把机器人加载到redis2 */ private void loadGroupRobot(){ - + Jedis jedis2 = Redis.use("group1_db2").getJedis(); try { - String sql = String.format("SELECT id FROM `account` WHERE jiqiren=9998 and start = 0"); + String sql = String.format("SELECT id,acc,nick,portrait,password FROM `account` WHERE jiqiren=9998 and start = 0"); ITArray robotIds = DataBase.use().executeQueryByTArray(sql); + HashMap robotMap = new HashMap<>(); + //遍历机器人, for(int i = 0; i < robotIds.size(); ++i) { - //把机器人按group 分类好 存放到redis2 +// //把机器人按group 分类好 存放到redis2 + ITObject robot = robotIds.getTObject(i); + Integer robotId = robot.getInt("id"); + String robotAcc = robot.getString("acc"); + String robotNick = robot.getString("nick"); + String robotPortrait = robot.getString("portrait"); + String robotPassword = robot.getString("password"); + + robotMap.put("acc", robotAcc); + robotMap.put("nick", robotNick); + robotMap.put("portrait", robotPortrait); + robotMap.put("password", robotPassword); + jedis2.hmset("{robot}:" + robotId , robotMap); + +// String sqls = String.format("UPDATE `account` SET start = %d WHERE id = %d", 1, robotId); +// DataBase.use().executeUpdate(sqls); } - } catch (SQLException e) { + + Map gRobotMap = new HashMap<>(); + gRobotMap.put("start", "0"); + gRobotMap.put("pid", "66"); + jedis2.hmset("{Grobot}:"+101666, gRobotMap); + + + + } catch (SQLException e) { throw new RuntimeException(e); - } + }finally { + jedis2.close(); + } }