2

Dockerfile

@@ -11,6 +11,7 @@ RUN mvn clean package -DskipTests
 FROM openjdk:11-jdk-slim
 COPY --from=build /target/demo-0.0.1-SNAPSHOT.jar demo.jar
 COPY --from=build /user.properties user.properties
+COPY --from=build /truyna.properties truyna.properties
 # ENV PORT=8080 
 EXPOSE 8081
 ENTRYPOINT ["java","-Dfile.encoding=UTF-8","-jar","demo.jar"]

src/main/java/tqtk/Entity/SessionEntity.java

@@ -24,6 +24,15 @@ public class SessionEntity {
     private Socket socket;
     private boolean isConnected;
     private String stringName;
+    private Socket socketTN;
+
+    public Socket getSocketTN() {
+        return socketTN;
+    }
+
+    public void setSocketTN(Socket socketTN) {
+        this.socketTN = socketTN;
+    }
 
     public String getStringName() {
         return stringName;
@@ -32,8 +41,7 @@ public class SessionEntity {
     public void setStringName(String stringName) {
         this.stringName = stringName;
     }
-    
-    
+
     public SessionEntity(String stringName, String pass) {
         this.stringName = stringName;
         this.pass = pass;

src/main/java/tqtk/Tqtk.java

@@ -43,6 +43,7 @@ public class Tqtk {
             List<SessionEntity> ss = LayThongTinSession.getListSession();
             
             Util.setData("user.properties",ss);
+            loaiTruyna = Util.docFileTruyNa("truyna.properties");
 
             final ScheduledExecutorService executor = Executors.newScheduledThreadPool(ss.size());
             for (int i = 0; i < ss.size(); ++i) {

src/main/java/tqtk/Utils/Util.java

@@ -448,6 +448,18 @@ public class Util {
             throw e;
         }
     }
+    
+     public static List<String> docFileTruyNa(String file_name) {
+        //window
+//        String x = "D:\\7-Project\\Java\\1. Netbean\\2. nghien-cuu\\TQTK\\tqtk-render.com-main\\"+file_name;
+        //heroku
+        String x = file_name;
+        try {
+            return Doc_file_kieu_txt.readFile(x);
+        } catch (Exception e) {
+            return null;
+        }
+    }
 
     public String test1(String url) throws Exception {
         HttpURLConnection con = null;

src/main/java/tqtk/XuLy/Worker.java

@@ -22,7 +22,7 @@ import tqtk.Tqtk;
 import tqtk.Utils.Util;
 import tqtk.XuLy.login.LayThongTinSession;
 import static tqtk.XuLy.XuLyPacket.GuiPacket;
-
+import static tqtk.XuLy.XuLyPacket.GuiPacketTN;
 import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQ;
 import tqtk.exception.JsonException;
 
@@ -231,80 +231,158 @@ public class Worker extends Thread {
 
     }
 
-    public void TruyNa() {
+    public void TruyNa1() {
         //if (Truyna == 1) {
         //    Truyna = 0;
-            List<String> list1 = new ArrayList<>();
-            list1.add(0, "0");
-            try {
-                Thread.sleep(5000);
-                StringBuilder rs1 = GuiPacket(ss, "60605", null);
-                if (rs1 != null) {
-                    try {
-                        String[] temp = rs1.toString().split("");
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacket(ss, "60605", null);
+            if (rs1 != null) {
+                try {
+                    String[] temp = rs1.toString().split("");
+
+                    ObjectMapper mapper = new ObjectMapper();
+                    Map<String, Object> carMap = null;
+                    int h = 0;
+                    for (String string : temp) {
+                        carMap = mapper.readValue(string, new TypeReference<Map<String, Object>>() {
+                        });
+                        h = (int) carMap.get("h");
+                        if (h == Integer.parseInt("60605")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("wantedMemberList");
+                    int idarea = 0;
+                    int id = 0;
+                    int attactNum = 0;
+                    int level = 0;
+                    int isAttacked = 0;
+                    long playerId = 0;
+                    Tqtk.sendMessage("tn " + ss.getStringName());
+                    for (Object object : carMap1) {
+                        idarea = (int) ((Map<Object, Object>) object).get("areaId");
+                        id = (int) ((Map<Object, Object>) object).get("id");
+                        attactNum = (int) ((Map<Object, Object>) object).get("attactNum");
+                        level = (int) ((Map<Object, Object>) object).get("playerLevel");
+                        isAttacked = (int) ((Map<Object, Object>) object).get("hasAttact");
+                        playerId = (long) ((Map<Object, Object>) object).get("playerId");
+                        list1.set(0, Integer.toString(id));
+
+                        synchronized (tqtk.Tqtk.loaiTruyna) {
+                            if (id != 0 && !Tqtk.loaiTruyna.contains(Long.toString(playerId))
+                                    && attactNum != 0
+                                    //                                    && idarea == -1
+                                    && isAttacked == 0
+                                    && level < 54) {
+                                rs1 = GuiPacket(ss, "60606", list1);
+
+                                if (rs1.toString().contains("に負けました")) {
+                                    tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
+                                }
+                                Thread.sleep(5000);
 
-                        ObjectMapper mapper = new ObjectMapper();
-                        Map<String, Object> carMap = null;
-                        int h = 0;
-                        for (String string : temp) {
-                            carMap = mapper.readValue(string, new TypeReference<Map<String, Object>>() {
-                            });
-                            h = (int) carMap.get("h");
-                            if (h == Integer.parseInt("60605")) {
-                                break;
                             }
                         }
+                        MuaLinh();
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
 
-                        List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("wantedMemberList");
-                        int idarea = 0;
-                        int id = 0;
-                        int attactNum = 0;
-                        int level = 0;
-                        int isAttacked = 0;
-                        long playerId = 0;
-                        Tqtk.sendMessage("tn " + ss.getStringName());
-                        for (Object object : carMap1) {
-                            idarea = (int) ((Map<Object, Object>) object).get("areaId");
-                            id = (int) ((Map<Object, Object>) object).get("id");
-                            attactNum = (int) ((Map<Object, Object>) object).get("attactNum");
-                            level = (int) ((Map<Object, Object>) object).get("playerLevel");
-                            isAttacked = (int) ((Map<Object, Object>) object).get("hasAttact");
-                            playerId = (long) ((Map<Object, Object>) object).get("playerId");
-                            list1.set(0, Integer.toString(id));
-
-                            synchronized (tqtk.Tqtk.loaiTruyna) {
-                                if (id != 0 && !Tqtk.loaiTruyna.contains(Long.toString(playerId))
-                                        && attactNum != 0
-                                        //                                    && idarea == -1
-                                        && isAttacked == 0
-                                        && level < 54) {
-                                    rs1 = GuiPacket(ss, "60606", list1);
-                                    
-                                    if (rs1.toString().contains("に負けました")) {
-                                        tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
-                                    }
-									Thread.sleep(5000);
+                //}
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+
+                System.out.println("loi TruyNa " + ss.getStringName() + ex.getMessage());
+            } else {
+
+                System.out.println("loi TruyNa json " + ss.getStringName() + ex.getMessage());
+            }
+        }
+        //}
+    }
+
+    public void TruyNa() {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacketTN(ss, "60605", null);
+            if (rs1 != null) {
+                try {
+                    String[] temp = rs1.toString().split("");
 
+                    ObjectMapper mapper = new ObjectMapper();
+                    Map<String, Object> carMap = null;
+                    int h = 0;
+                    for (String string : temp) {
+                        carMap = mapper.readValue(string, new TypeReference<Map<String, Object>>() {
+                        });
+                        h = (int) carMap.get("h");
+                        if (h == Integer.parseInt("60605")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("wantedMemberList");
+                    int idarea = 0;
+                    int id = 0;
+                    int attactNum = 0;
+                    int level = 0;
+                    int isAttacked = 0;
+                    long playerId = 0;
+                    String playerName = "";
+                    String tmp = "";
+                    Tqtk.sendMessage("tn " + ss.getStringName());
+                    for (Object object : carMap1) {
+                        idarea = (int) ((Map<Object, Object>) object).get("areaId");
+                        id = (int) ((Map<Object, Object>) object).get("id");
+                        attactNum = (int) ((Map<Object, Object>) object).get("attactNum");
+                        level = (int) ((Map<Object, Object>) object).get("playerLevel");
+                        isAttacked = (int) ((Map<Object, Object>) object).get("hasAttact");
+                        playerId = (long) ((Map<Object, Object>) object).get("playerId");
+                        playerName = (String) ((Map<Object, Object>) object).get("playerName");
+                        playerName = playerName.toLowerCase();
+                        list1.set(0, Integer.toString(id));
+
+                        synchronized (tqtk.Tqtk.loaiTruyna) {
+                            if (id != 0 && !Tqtk.loaiTruyna.contains(playerName)
+                                    && !Tqtk.loaiTruyna.contains(Long.toString(playerId))
+                                    && attactNum != 0
+                                    //                                    && idarea == -1
+                                    && isAttacked == 0
+                                    && level < 61) {
+                                rs1 = GuiPacketTN(ss, "60606", list1);
+                                Thread.sleep(5000);
+                                tmp = rs1.toString();
+                                if (tmp.contains("\"winside\":2") || tmp.contains("\"winside\": 2")) {
+                                    tqtk.Tqtk.loaiTruyna.add(playerName);
+                                    tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
                                 }
+
                             }
-							MuaLinh();
                         }
-                    } catch (Exception e) {
-                        throw new JsonException();
                     }
-
-                    //}
+                } catch (Exception e) {
+                    throw new JsonException();
                 }
-            } catch (Exception ex) {
-                if (!(ex instanceof JsonException)) {
 
-                    System.out.println("loi TruyNa " + ss.getStringName() + ex.getMessage());
-                } else {
+                //}
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
 
-                    System.out.println("loi TruyNa json " + ss.getStringName() + ex.getMessage());
-                }
+                System.out.println("loi TruyNa " + ss.getStringName() + ex.getMessage());
+            } else {
+
+                System.out.println("loi TruyNa json " + ss.getStringName() + ex.getMessage());
             }
-        //}
+        }
     }
 
     public void NangNha() {
@@ -1074,6 +1152,15 @@ public class Worker extends Thread {
         ss.setSocket(socket);
     }
 
+    public void taoSocketTruyNa() throws Exception {
+        Socket socket = new Socket();
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), ss.getPorts()), 7000);
+        if (ss.getSocketTN() != null) {
+            ss.getSocketTN().close();
+        }
+        ss.setSocketTN(socket);
+    }
+
     public void CapNhatThongTin() throws IOException, UnknownHostException, InterruptedException, Exception {
         try {
             Thread.sleep(5000);
@@ -1232,15 +1319,15 @@ public class Worker extends Thread {
                         // value = gia ruong , id = 1 dong ruong, id = 2 sat ruong
                         if (boxtype == 1
                                 && value < 5000
-                                && id ==1) {
+                                && id == 1) {
                             list1.set(0, "3");
                             list1.set(1, Integer.toString(id));
                             list1.set(2, "1");
                             GuiPacket(ss, "48111", list1);
                         }
-                           if (boxtype == 1
+                        if (boxtype == 1
                                 && value < 7500
-                                   && id == 2) {
+                                && id == 2) {
                             list1.set(0, "3");
                             list1.set(1, Integer.toString(id));
                             list1.set(2, "1");
@@ -1269,7 +1356,19 @@ public class Worker extends Thread {
         try {
             dangNhapLayThongTin();
             GuiPacketDeLogin();
-
+            taoSocketTruyNa();
+            new Thread() {
+                @Override
+                public void run() {
+                    try {
+                        while (true) {
+                            TruyNa();
+                        }
+                    } catch (Exception e) {
+                        System.out.println("TruyNa .run() " + ss.getStringName());
+                    }
+                }
+            }.start();
             while (true) {
 
                 MuaLinh();
@@ -1277,10 +1376,6 @@ public class Worker extends Thread {
 //                DanhQuanDoan2();
 //                DanhQuanDoan3();
                 NangItem();
-                TruyNa();
-				TruyNa();
-				TruyNa();
-				TruyNa();
                 LuyenTuong();
                 NangNha();
                 NangKiNang();
@@ -1288,7 +1383,7 @@ public class Worker extends Thread {
 //                GianKhoan();
                 FarmDoLv60();
 //                ThuThue();
-                
+
                 ChiemMo();
                 ChiemRuong();
                 MuaRuong();

src/main/java/tqtk/XuLy/XuLyPacket.java

@@ -76,8 +76,7 @@ public class XuLyPacket {
         }
 
     }
-	
-	
+
     public static String GuiPacket1(SessionEntity ss, String code, List<String> list) throws UnknownHostException, IOException, InterruptedException {
         BufferedWriter wr = null;
         String rp = "";
@@ -119,4 +118,40 @@ public class XuLyPacket {
         }
         return rp;
     }
+
+    public static StringBuilder GuiPacketTN(SessionEntity ss, String code, List<String> list) throws UnknownHostException, IOException, InterruptedException {
+        BufferedWriter wr = null;
+        StringBuilder rp = null;
+        String message = "";
+        try {
+            message = Util.TaoMsg(code, list, ss);
+            Thread.sleep(3 * 1000);
+            wr = new BufferedWriter(new OutputStreamWriter(ss.getSocketTN().getOutputStream(), "UTF8"));
+            wr.write(message);
+            wr.flush();
+
+            rp = new StringBuilder("");
+            if (ss.getSocketTN().isConnected()) {
+                Thread.sleep(3 * 1000);
+                InputStream instr = ss.getSocketTN().getInputStream();
+                int buffSize = ss.getSocketTN().getReceiveBufferSize();
+                if (buffSize > 0) {
+                    byte[] buff = new byte[buffSize];
+                    int ret_read = instr.read(buff);
+                    if (ret_read != -1) {
+                        rp.append(new String(buff, 0, ret_read));
+                    }
+                }
+            }
+            return rp;
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+
+//            if (e.getMessage().contains("socket write error")) {
+//            }
+            return null;
+        }
+
+    }
+
 }

truyna.properties

@@ -0,0 +1,9 @@
+manato
+zyto
+doraemon
+風見
+maruto
+芽依五郎
+樹共
+ahihi2
+だんでぃ～さかの

user.properties

@@ -4,7 +4,7 @@
       "server_id": 8,
       "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301232337316215&userid=2301232337316215&GameId=2001&ServerId=s17&Time=1675980791&al=1&from=gesoten&siteurl=gesoten.com&Sign=610ccdb56341636eb0568ecb58e3e008&nickname=gesoten-2301232337316215",
       "password": "12081989",
-      "SessionKey": "b0bf389cb791b742b525005ca079eb1e",
+      "SessionKey": "6be692141d9cfa9cc9fe532796b94197",
       "UserId": "2301232337316215",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"
@@ -13,7 +13,7 @@
       "server_id": 9,
       "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301190819097479&userid=2301190819097479&GameId=2001&ServerId=s17&Time=1675982026&al=1&from=gesoten&siteurl=gesoten.com&Sign=c31d19f752715495a480bdd83601193d&nickname=gesoten-2301190819097479",
       "password": "12081989",
-      "SessionKey": "a2e6d79e817d3953f11e4a368e81f0c8",
+      "SessionKey": "ec0d00a99ba0ff5cb5192d831c25463a",
       "UserId": "2301190819097479",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"
@@ -22,7 +22,7 @@
       "server_id": 10,
       "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301211923397199&userid=2301211923397199&GameId=2001&ServerId=s17&Time=1675982135&al=1&from=gesoten&siteurl=gesoten.com&Sign=2c096cc405fe90a2ddc4183500c39079&nickname=gesoten-2301211923397199",
       "password": "12081989",
-      "SessionKey": "cdeb3695e2a1679a07f3b4bccc8d7fd1",
+      "SessionKey": "1c5d9eac3deef142ef00348e567a7787",
       "UserId": "2301211923397199",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"
@@ -31,7 +31,7 @@
       "server_id": 11,
       "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301230011011923&userid=2301230011011923&GameId=2001&ServerId=s17&Time=1675982238&al=1&from=gesoten&siteurl=gesoten.com&Sign=8868e04af73c9c8f3992a9149caacee1&nickname=gesoten-2301230011011923",
       "password": "12081989",
-      "SessionKey": "8afa92e33e9d74b6953bd9917942f234",
+      "SessionKey": "4df70eafde5dd3458a330bc912249883",
       "UserId": "2301230011011923",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"
@@ -40,7 +40,7 @@
       "server_id": 351,
       "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301181933399764&userid=2301181933399764&GameId=2001&ServerId=s17&Time=1675658917&al=1&from=gesoten&siteurl=gesoten.com&Sign=d4e6bd8518630feb3fd2f546a6c2884e&nickname=gesoten-2301181933399764",
       "password": "12081989",
-      "SessionKey": "10f3acf1d3b2c343c42f9450551f78d0",
+      "SessionKey": "b704ecfd4dd31866d20247ce8b6a221c",
       "UserId": "2301181933399764",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"
@@ -49,7 +49,7 @@
       "server_id": 352,
       "username": "http://mixi.sengokugifu.jp/play.php?accid=32572016266&hash=0416ae30795b66a055d4726794fef2b8&sid=17",
       "password": "12081989",
-      "SessionKey": "35189594301d68605fef0d9f69d44bb8",
+      "SessionKey": "16c2c22f2dc709102f744b7a0f23b002",
       "UserId": "32572016266",
       "Port": "6017",
       "Ip": "s17.sengokugifu.jp"