2

pom - Copy.xml

@@ -0,0 +1,121 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.7.7-SNAPSHOT</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.example</groupId>
+    <artifactId>demo</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>demo</name>
+    <description>Demo project for Spring Boot</description>
+    <properties>
+        <java.version>11</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.9</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-annotations</artifactId>
+            <version>2.13.3</version>
+           
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>2.13.3</version>
+           
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.12.7.1</version>
+           
+        </dependency>
+	
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/com.googlecode.json-simple/json-simple -->
+        <dependency>
+            <groupId>com.googlecode.json-simple</groupId>
+            <artifactId>json-simple</artifactId>
+            <version>1.1.1</version>
+        </dependency>
+		 <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+            <version>4.0-alpha6</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+    <repositories>
+        <repository>
+            <id>spring-milestones</id>
+            <name>Spring Milestones</name>
+            <url>https://repo.spring.io/milestone</url>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </repository>
+        <repository>
+            <id>spring-snapshots</id>
+            <name>Spring Snapshots</name>
+            <url>https://repo.spring.io/snapshot</url>
+            <releases>
+                <enabled>false</enabled>
+            </releases>
+        </repository>
+    </repositories>
+    <pluginRepositories>
+        <pluginRepository>
+            <id>spring-milestones</id>
+            <name>Spring Milestones</name>
+            <url>https://repo.spring.io/milestone</url>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </pluginRepository>
+        <pluginRepository>
+            <id>spring-snapshots</id>
+            <name>Spring Snapshots</name>
+            <url>https://repo.spring.io/snapshot</url>
+            <releases>
+                <enabled>false</enabled>
+            </releases>
+        </pluginRepository>
+    </pluginRepositories>
+
+</project>

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

@@ -213,7 +213,30 @@ public class Worker extends Thread {
                                 GuiPacket(ss, "41102", list2);
                                 Thread.sleep(5000);
 
+                            } else if ("瀬名姫".equals(name) && trainflag == 0) {
+                                // tmc stun
+                                GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("渡辺守綱".equals(name) && trainflag == 0) {
+                                // ha hau uyen tdxk
+                                GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+                                GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
                             }
+
                         }
                     }
                 } catch (Exception e) {
@@ -309,21 +332,44 @@ public class Worker extends Thread {
     }
 
     public void TruyNa() throws InterruptedException, IOException {
+        try {
+            GuiPacketTN(ss, "11102", null);
+            Thread.sleep(5000);
+        } catch (Exception e) {
+        }
+
         if (ss.getUserId().equals("2301230011011923")) {
-            List<String> list1 = new ArrayList<>();
-            list1.add(0, "0");
-            for (TruyNa tn : Tqtk.listtruyna) {
-                synchronized (tqtk.Tqtk.loaiTruyna) {
-                    if (!Tqtk.loaiTruyna.contains(tn.getPlayerName())
-                            && !Tqtk.loaiTruyna.contains(tn.getPlayerId())
-                            && tn.getAttactNum() != 0) {
-                        list1.set(0, tn.getId());
-                        GuiPacketTN(ss, "60606", list1);
+            try {
+                List<String> list1 = new ArrayList<>();
+                list1.add(0, "0");
+
+                if (Tqtk.listtruyna.size() > 0 && Tqtk.loaiTruyna.size() > 0) {
+                    String id = "";
+                    String PlayerName = "";
+                    String PlayerId = "";
+                    int AttactNum = 0;
+                    for (TruyNa tn : Tqtk.listtruyna) {
+                        id = tn.getId();
+                        AttactNum = tn.getAttactNum();
+                        PlayerName = tn.getPlayerName();
+                        PlayerId = tn.getPlayerId();
+                        Tqtk.sendMessage("tn " + PlayerName + " " + PlayerId + " " + AttactNum + " " + id);
+                        synchronized (Tqtk.listtruyna) {
+                            if (!Tqtk.loaiTruyna.contains(PlayerName)
+                                    && !Tqtk.loaiTruyna.contains(PlayerId)
+                                    && AttactNum != 0) {
+                                list1.set(0, id);
+                                GuiPacketTN(ss, "60606", list1);
+                            }
+
+                        }
+                        Thread.sleep(5000);
                     }
                 }
-                Thread.sleep(5000);
+            } catch (Exception e) {
+                System.out.println("GuiPacketTN 2 " + e.getMessage());
             }
-        } else {
+        } else if (ss.getUserId().equals("2301211923397199")) {
 
             List<String> list1 = new ArrayList<>();
             list1.add(0, "0");
@@ -355,6 +401,7 @@ public class Worker extends Thread {
                         long playerId = 0;
                         String playerName = "";
                         String tmp = "";
+                        TruyNa tn = null;
                         Tqtk.sendMessage("tn " + ss.getStringName());
                         for (Object object : carMap1) {
                             idarea = (int) ((Map<Object, Object>) object).get("areaId");
@@ -366,14 +413,18 @@ public class Worker extends Thread {
                             playerName = (String) ((Map<Object, Object>) object).get("playerName");
                             playerName = playerName.toLowerCase();
                             list1.set(0, Integer.toString(id));
-                            if (ss.getUserId().equals("2301232337316215")) {
-                                TruyNa tn = new TruyNa();
-                                tn.setAttactNum(attactNum);
-                                tn.setId(Long.toString(id));
-                                tn.setPlayerId(Long.toString(playerId));
-                                tn.setPlayerName(playerName);
-                                Tqtk.listtruyna.add(tn);
+
+                            if (ss.getUserId().equals("2301211923397199")) {
+                                synchronized (Tqtk.listtruyna) {
+                                    tn = new TruyNa();
+                                    tn.setAttactNum(attactNum);
+                                    tn.setId(Long.toString(id));
+                                    tn.setPlayerId(Long.toString(playerId));
+                                    tn.setPlayerName(playerName);
+                                    Tqtk.listtruyna.add(tn);
+                                }
                             }
+
                             synchronized (tqtk.Tqtk.loaiTruyna) {
                                 if (id != 0 && !Tqtk.loaiTruyna.contains(playerName)
                                         && !Tqtk.loaiTruyna.contains(Long.toString(playerId))
@@ -382,12 +433,13 @@ public class Worker extends Thread {
                                         && isAttacked == 0
                                         && level < 61) {
                                     rs1 = GuiPacketTN(ss, "60606", list1);
-                                    tmp = rs1.toString();
+                                    if (rs1 != null) {
+                                        tmp = rs1.toString();
+                                    }
                                     if (tmp.contains("\"winside\":2") || tmp.contains("\"winside\": 2")) {
                                         tqtk.Tqtk.loaiTruyna.add(playerName);
                                         tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
                                     }
-
                                 }
                             }
                             Thread.sleep(5000);
@@ -1428,7 +1480,7 @@ public class Worker extends Thread {
                             TruyNa();
                         }
                     } catch (Exception e) {
-                        System.out.println("TruyNa .run() " + ss.getStringName());
+                        System.out.println("TruyNa .run() " + e.getMessage() + " " + ss.getStringName());
                     }
                 }
             }.start();

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

@@ -285,7 +285,7 @@ public class XuLyPacket {
 
     public static StringBuilder GuiPacketTN(SessionEntity ss, String code, List<String> list) throws UnknownHostException, IOException, InterruptedException {
         BufferedWriter wr = null;
-        StringBuilder rp = null;
+        StringBuilder rp = new StringBuilder("");
         String message = "";
         try {
             message = Util.TaoMsg(code, list, ss);
@@ -294,7 +294,6 @@ public class XuLyPacket {
             wr.write(message);
             wr.flush();
 
-            rp = new StringBuilder("");
             if (ss.getSocketTN().isConnected()) {
                 Thread.sleep(3 * 1000);
                 InputStream instr = ss.getSocketTN().getInputStream();
@@ -317,4 +316,5 @@ public class XuLyPacket {
         }
 
     }
+
 }