1

pom-local.xml

@@ -0,0 +1,95 @@
+<?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>
+    <groupId>com.example</groupId>
+    <artifactId>demo</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>demo</name>
+    <description>Demo project for Spring Boot</description>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </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</groupId>
+            <artifactId>spring-webmvc</artifactId>
+            <version>4.3.2.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jdbc</artifactId>
+            <version>4.3.3.RELEASE</version>
+           
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-jpa</artifactId>
+            <version>1.10.2.RELEASE</version>      
+        </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>
+
+    <repositories>
+        <repository>
+            <id>central</id>
+            <name>Central Repository</name>
+            <url>https://repo.maven.apache.org/maven2</url>
+            <layout>default</layout>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </repository>
+    </repositories>
+    <pluginRepositories>
+        <pluginRepository>
+            <id>central</id>
+            <name>Central Repository</name>
+            <url>https://repo.maven.apache.org/maven2</url>
+            <layout>default</layout>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+            <releases>
+                <updatePolicy>never</updatePolicy>
+            </releases>
+        </pluginRepository>
+    </pluginRepositories>
+
+</project>

src/main/java/com/example/demo/DemoApplication.java

@@ -1,6 +1,6 @@
 package com.example.demo;
 
-import com.example.demo.entity.User;
+import com.example.demo.entity.User_test;
 import com.example.demo.repository.UserRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
@@ -32,6 +32,8 @@ import org.springframework.context.ApplicationContext;
 import tqtk.Entity.SessionEntity;
 import tqtk.Entity.Params;
 import tqtk.Tqtk;
+import static tqtk.Tqtk.listSession;
+import tqtk.Utils.Util;
 import tqtk.XuLy.Worker;
 import tqtk.XuLy.XuLyPacket;
 import tqtk.XuLy.login.LayThongTinSession;
@@ -50,10 +52,9 @@ public class DemoApplication {
 
     @GetMapping("exit")
     public String getExit() throws IOException {
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             ss.get(i).getSocket().close();
-            ss.get(i).getSocketApi().close();
         }
         SpringApplication.exit(context);
         return "exit";
@@ -67,7 +68,7 @@ public class DemoApplication {
 
     @GetMapping("start")
     public String start() {
-        if (LayThongTinSession.getListSession().size() < 1) {
+        if (Tqtk.listSession.size() < 1) {
             Thread t = new Thread() {
                 public void run() {
                     tqtk.Tqtk.main();
@@ -78,11 +79,20 @@ public class DemoApplication {
         return "ok";
     }
 
+    @RequestMapping(value = "/updateInfo", method = RequestMethod.POST)
+    @ResponseBody
+    public String updateInfo(
+            @RequestParam(value = "id", required = true) String id) throws IOException, UnknownHostException, InterruptedException, Exception {
+
+        Util.updateData(id);
+        return "ok";
+    }
+
     @RequestMapping(value = "/sendcmd", method = RequestMethod.POST)
     @ResponseBody
     public String sendcmd(@RequestBody String cmd,
             @RequestParam(value = "id", required = true) String id) throws IOException, UnknownHostException, InterruptedException {
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             if (id.equals(ss.get(i).getUserId())) {
                 XuLyPacket.GuiPacketHTTP(ss.get(i), cmd);
@@ -113,12 +123,12 @@ public class DemoApplication {
 //                }
 //            }
 //        }.start();
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             if (id.equals(ss.get(i).getUserId())) {
                 try {
                     XuLyPacket.GuiPacketHTTP2(ss.get(i), cmd);
-                     return "ok";
+                    return "ok";
                 } catch (IOException ex) {
                     Logger.getLogger(DemoApplication.class.getName()).log(Level.SEVERE, null, ex);
                 } catch (InterruptedException ex) {
@@ -132,7 +142,7 @@ public class DemoApplication {
     @GetMapping("createSocket")
     public String createSocket(@RequestParam(value = "id", required = true) String id) throws Exception {
         String output = "";
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             if (id.equals(ss.get(i).getUserId())) {
                 Worker.createSocket(ss.get(i));
@@ -145,7 +155,7 @@ public class DemoApplication {
     @GetMapping("createSocketapi")
     public String createSocketApi(@RequestParam(value = "id", required = true) String id) throws Exception {
         String output = "";
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             if (id.equals(ss.get(i).getUserId())) {
                 Worker.createSocketApi(ss.get(i));
@@ -159,7 +169,7 @@ public class DemoApplication {
     public String setSessionId(@RequestParam(value = "id", required = true) String id,
             @RequestParam(value = "session", required = true) String session) throws Exception {
         String output = "";
-        List<SessionEntity> ss = LayThongTinSession.getListSession();
+        List<SessionEntity> ss = Tqtk.listSession;
         for (int i = 0; i < ss.size(); ++i) {
             if (id.equals(ss.get(i).getUserId())) {
                 ss.get(i).setSessionKey(session);

src/main/java/com/example/demo/Test.java

@@ -0,0 +1,52 @@
+package com.example.demo;
+
+import com.example.demo.entity.User_test;
+import com.example.demo.repository.UserRepository;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.BufferedInputStream;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.UnknownHostException;
+import java.util.List;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import javax.net.ssl.HttpsURLConnection;
+import org.apache.http.util.ByteArrayBuffer;
+import org.springframework.context.ApplicationContext;
+import tqtk.Entity.Accounts;
+import tqtk.Entity.SessionEntity;
+import tqtk.Entity.Params;
+import tqtk.Tqtk;
+import tqtk.XuLy.Worker;
+import tqtk.XuLy.XuLyPacket;
+import tqtk.XuLy.login.LayThongTinSession;
+
+public class Test {
+
+    
+
+    public  void main(String[] args) throws Exception {
+        tqtk.Tqtk.main();
+    }
+
+}

src/main/java/com/example/demo/entity/User_test.java

@@ -0,0 +1,9 @@
+package com.example.demo.entity;
+
+
+import java.io.Serializable;
+
+
+public class User_test implements Serializable {
+
+}

src/main/java/tqtk/Entity/Accounts.java

@@ -0,0 +1,29 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package tqtk.Entity;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.List;
+
+/**
+ *
+ * @author Alex
+ */
+public class Accounts {
+
+    @JsonProperty("accounts")
+    List<SessionEntity> accounts;
+
+    public List<SessionEntity> getAccounts() {
+        return accounts;
+    }
+
+    public void setAccounts(List<SessionEntity> accounts) {
+        this.accounts = accounts;
+    }
+    
+    
+}

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

@@ -5,10 +5,12 @@
  */
 package tqtk.Entity;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
 import java.net.Socket;
+import java.util.List;
 
 /**
  *
@@ -16,17 +18,97 @@ import java.net.Socket;
  */
 public class SessionEntity {
 
-    private String userId;
-    private String pass;
-    private String ip;
-    private int ports;
-    private String sessionKey;
+    @JsonProperty("Ip")
+    String Ip;
+    @JsonProperty("Port")
+    String Port;
+    @JsonProperty("SessionKey")
+    String SessionKey;
+    @JsonProperty("UserId")
+    String UserId;
+    @JsonProperty("ItemIds")
+    List<String> ItemIds;
+    @JsonProperty("HeroIds")
+    List<String> HeroIds;
+    @JsonProperty("BuildingIds")
+    List<String> BuildingIds;
+    @JsonProperty("SkillIds")
+    List<String> SkillIds;
+
     private Socket socket;
     private boolean isConnected;
     private String stringName;
     private Socket socketApi;
     private Socket socketTN;
 
+    public String getIp() {
+        return Ip;
+    }
+
+    public void setIp(String Ip) {
+        this.Ip = Ip;
+    }
+
+    public String getPort() {
+        return Port;
+    }
+
+    public void setPort(String Port) {
+        this.Port = Port;
+    }
+
+    public String getSessionKey() {
+        return SessionKey;
+    }
+
+    public void setSessionKey(String SessionKey) {
+        this.SessionKey = SessionKey;
+    }
+
+    public String getUserId() {
+        return UserId;
+    }
+
+    public void setUserId(String UserId) {
+        this.UserId = UserId;
+    }
+
+    public List<String> getItemIds() {
+        return ItemIds;
+    }
+
+    public void setItemIds(List<String> ItemIds) {
+        this.ItemIds = ItemIds;
+    }
+
+  
+
+    public List<String> getHeroIds() {
+        return HeroIds;
+    }
+
+    public void setHeroIds(List<String> HeroIds) {
+        this.HeroIds = HeroIds;
+    }
+
+    public List<String> getBuildingIds() {
+        return BuildingIds;
+    }
+
+    public void setBuildingIds(List<String> BuildingIds) {
+        this.BuildingIds = BuildingIds;
+    }
+
+    public List<String> getSkillIds() {
+        return SkillIds;
+    }
+
+    public void setSkillIds(List<String> SkillIds) {
+        this.SkillIds = SkillIds;
+    }
+
+    
+    
     public Socket getSocketTN() {
         return socketTN;
     }
@@ -51,10 +133,6 @@ public class SessionEntity {
         this.stringName = stringName;
     }
 
-    public SessionEntity(String stringName, String pass) {
-        this.stringName = stringName;
-        this.pass = pass;
-    }
 
     public SessionEntity() {
     }
@@ -62,16 +140,9 @@ public class SessionEntity {
     public void resetSocket() throws IOException {
         this.socket.close();
         this.socket = new Socket();
-        this.socket.connect(new InetSocketAddress(InetAddress.getByName(ip), ports), 7000);
+        this.socket.connect(new InetSocketAddress(InetAddress.getByName(Ip), Integer.parseInt(Port)), 7000);
     }
 
-    public String getPass() {
-        return pass;
-    }
-
-    public void setPass(String pass) {
-        this.pass = pass;
-    }
 
     public boolean isIsConnected() {
         return isConnected;
@@ -98,37 +169,4 @@ public class SessionEntity {
     public void setMessage(StringBuilder message) {
         this.message = message;
     }
-
-    public String getUserId() {
-        return userId;
-    }
-
-    public void setUserId(String userId) {
-        this.userId = userId;
-    }
-
-    public String getIp() {
-        return ip;
-    }
-
-    public void setIp(String ip) {
-        this.ip = ip;
-    }
-
-    public int getPorts() {
-        return ports;
-    }
-
-    public void setPorts(int ports) {
-        this.ports = ports;
-    }
-
-    public String getSessionKey() {
-        return sessionKey;
-    }
-
-    public void setSessionKey(String sessionKey) {
-        this.sessionKey = sessionKey;
-    }
-
 }

src/main/java/tqtk/Entity/User.java

@@ -0,0 +1,100 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package tqtk.Entity;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.List;
+
+/**
+ *
+ * @author Alex
+ */
+@JsonIgnoreProperties
+public class User {
+
+    @JsonProperty("Ip")
+    String Ip;
+    @JsonProperty("Port")
+    String Port;
+    @JsonProperty("SessionKey")
+    String SessionKey;
+    @JsonProperty("UserId")
+    String UserId;
+    @JsonProperty("ItemId")
+    List<String> ItemId;
+    @JsonProperty("HeroIds")
+    List<String> HeroIds;
+    @JsonProperty("BuildingIds")
+    List<String> BuildingIds;
+    @JsonProperty("SkillIds")
+    List<String> SkillIds;
+
+    public List<String> getHeroIds() {
+        return HeroIds;
+    }
+
+    public void setHeroIds(List<String> HeroIds) {
+        this.HeroIds = HeroIds;
+    }
+
+    public List<String> getBuildingIds() {
+        return BuildingIds;
+    }
+
+    public void setBuildingIds(List<String> BuildingIds) {
+        this.BuildingIds = BuildingIds;
+    }
+
+    public List<String> getSkillIds() {
+        return SkillIds;
+    }
+
+    public void setSkillIds(List<String> SkillIds) {
+        this.SkillIds = SkillIds;
+    }
+
+    public String getIp() {
+        return Ip;
+    }
+
+    public void setIp(String Ip) {
+        this.Ip = Ip;
+    }
+
+    public String getPort() {
+        return Port;
+    }
+
+    public void setPort(String Port) {
+        this.Port = Port;
+    }
+
+    public String getSessionKey() {
+        return SessionKey;
+    }
+
+    public void setSessionKey(String SessionKey) {
+        this.SessionKey = SessionKey;
+    }
+
+    public String getUserId() {
+        return UserId;
+    }
+
+    public void setUserId(String UserId) {
+        this.UserId = UserId;
+    }
+
+    public List<String> getItemId() {
+        return ItemId;
+    }
+
+    public void setItemId(List<String> ItemId) {
+        this.ItemId = ItemId;
+    }
+
+}

src/main/java/tqtk/Tqtk.java

@@ -5,6 +5,7 @@
  */
 package tqtk;
 
+import com.example.demo.entity.User_test;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
 import java.net.Socket;
@@ -33,31 +34,54 @@ public class Tqtk {
     public static List<String> loaiTruyna = new ArrayList<>();
     public static List<TruyNa> listtruyna = new ArrayList<>();
     public static List<Object> listruong = new ArrayList<>();
+    public static List<User_test> listUser = new ArrayList<>();
+    public static List<SessionEntity> listSession = new ArrayList<>();
+    public static List<Worker> listWorker = new ArrayList<>();
 
     static {
         loaiTruyna = Collections.synchronizedList(loaiTruyna);
         listruong = Collections.synchronizedList(listruong);
         listtruyna = Collections.synchronizedList(listtruyna);
+        listUser = Collections.synchronizedList(listUser);
+        listSession = Collections.synchronizedList(listSession);
     }
 
     public static void main() {
         // TODO code application logic here
         try {
-
-            List<SessionEntity> ss = LayThongTinSession.getListSession();
-            String x = GetTextFromGit.getStringFromGithubRaw("https://raw.githubusercontent.com/alexTvirus/Static-Resource/main/user-main");
-            Util.setData1(x, ss);
+            listSession = Util.setData1(listSession);
             loaiTruyna = Util.docFileTruyNa("truyna.properties");
 
-            final ScheduledExecutorService executor = Executors.newScheduledThreadPool(ss.size());
-            for (int i = 0; i < ss.size(); ++i) {
-                Runnable worker = new Worker(ss.get(i));
-                executor.schedule(worker, 300L, TimeUnit.MILLISECONDS);
+            for (int i = 0; i < listSession.size(); ++i) {
+                Runnable worker = new Worker(listSession.get(i));
+                listWorker.add((Worker) worker);
             }
-            executor.shutdown();
-            while (!executor.isTerminated()) {
+           ScheduledExecutorService executor = null;
+            while (true) {
+                try {
+					executor =   Executors.newScheduledThreadPool(listSession.size());
+                    for (int i = 0; i < listSession.size(); ++i) {
+                        executor.schedule(listWorker.get(i), 300L, TimeUnit.MILLISECONDS);
+                    }
+                    executor.shutdown();
+                    while (!executor.isTerminated()) {
+                    }
+                    for (Worker worker : listWorker) {
+                        if (!worker.getSs().getUserId().equals("2301230011011923")) {
+                            worker.getIdTruyNa();
+                        }
+                        if (worker.getSs().getUserId().equals("2301230011011923")) {
+                            worker.TruyNa();
+                        } else {
+                            worker.TruyNa2();
+                        }
+
+                    }
+                } catch (Exception e) {
+                    System.out.println(e.getMessage());
+                }
+
             }
-            System.out.println("tqtk.Tqtk.main()");
 
         } catch (Exception ex) {
             System.out.println(ex.getMessage());

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

@@ -5,6 +5,9 @@
  */
 package tqtk.Utils;
 
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.BufferedInputStream;
 import java.io.BufferedReader;
 import java.io.DataOutputStream;
 import java.io.FileInputStream;
@@ -32,32 +35,34 @@ import org.apache.commons.lang3.StringUtils;
 import tqtk.Entity.SessionEntity;
 import java.io.FileReader;
 import java.util.Iterator;
+import org.apache.http.util.ByteArrayBuffer;
 import org.json.simple.JSONArray;
 import org.json.simple.JSONObject;
 
 import org.json.simple.parser.JSONParser;
+import tqtk.Entity.Accounts;
 
 /**
  *
  * @author Alex
  */
 public class Util {
-
+    
     public CookieManager msCookieManager = null;
-
+    
     public Util() {
         msCookieManager = new CookieManager();
     }
-
+    
     public void setCookie(CookieManager msCookieManager) {
         CookieHandler.setDefault(msCookieManager);
     }
-
+    
     public String getPageSource(String url) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(url);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -71,10 +76,10 @@ public class Util {
             con.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -82,13 +87,13 @@ public class Util {
                     response.append(inputLine);
                 }
                 in.close();
-
+                
                 return response.toString();
-
+                
             } else {
                 return "Hệ thống đang quá tải vui lòng";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");
@@ -96,7 +101,7 @@ public class Util {
             throw e;
         }
     }
-
+    
     public static String getToken(String htmlCode) {
         String prefix = "name=\"_token\" value=\"";
         int index = htmlCode.indexOf(prefix);
@@ -104,7 +109,7 @@ public class Util {
             // Could not find the prefix string.
             return null;
         }
-
+        
         index += prefix.length();
 
         // Login token has a fixed length of 40.
@@ -113,11 +118,11 @@ public class Util {
             // Given html code is not long enough.
             return null;
         }
-
+        
         String token = htmlCode.substring(index, index + TokenLength);
         return token;
     }
-
+    
     public static String getRefer(String htmlCode) throws UnsupportedEncodingException {
         String prefix = "action=\"";
         int prefixIndex = htmlCode.indexOf(prefix);
@@ -127,19 +132,19 @@ public class Util {
         }
         String suffix = "\" accept-charset";
         int suffixIndex = htmlCode.indexOf(suffix);
-
+        
         int beginIndex = prefixIndex + prefix.length();
         int endIndex = suffixIndex;
         String address = htmlCode.substring(beginIndex, endIndex);
         String result = java.net.URLDecoder.decode(address, StandardCharsets.UTF_8.toString());
         return result.replace("&amp;", "&");
     }
-
+    
     public String dangNhap(String url, String user, String pass, String token, String Refer) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(Refer);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -159,14 +164,14 @@ public class Util {
             con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             DataOutputStream wr = new DataOutputStream(con.getOutputStream());
             wr.write(postData);
             wr.flush();
             wr.close();
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -174,13 +179,13 @@ public class Util {
                     response.append(inputLine);
                 }
                 in.close();
-
+                
                 return response.toString();
-
+                
             } else {
                 return "Hệ thống đang quá tải vui lòng";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");
@@ -188,12 +193,12 @@ public class Util {
             throw e;
         }
     }
-
+    
     public String getThongTinFrame(String url) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(url);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -207,10 +212,10 @@ public class Util {
 //            con.setRequestProperty("Upgrade-Insecure-Requests", "1");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -218,13 +223,13 @@ public class Util {
                     response.append(inputLine);
                 }
                 in.close();
-
+                
                 return response.toString();
-
+                
             } else {
                 return "Hệ thống đang quá tải vui lòng";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");
@@ -232,12 +237,12 @@ public class Util {
             throw e;
         }
     }
-
+    
     public String getThongTinPort(String url) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(url);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -252,10 +257,10 @@ public class Util {
             con.setRequestProperty("Upgrade-Insecure-Requests", "1");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -264,11 +269,11 @@ public class Util {
                 }
                 in.close();
                 return response.toString();
-
+                
             } else {
                 return "Hệ thống đang quá tải vui lòng";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");
@@ -276,7 +281,7 @@ public class Util {
             throw e;
         }
     }
-
+    
     public static String getFrameString(String htmlCode) throws UnsupportedEncodingException {
         String prefix = "src=\"";
         int index = htmlCode.indexOf(prefix);
@@ -284,40 +289,40 @@ public class Util {
             // Could not find the prefix string.
             return null;
         }
-
+        
         index += prefix.length();
         int suffixIndex = htmlCode.indexOf("\" frameborder");
         if (suffixIndex == -1) {
             // Could not find the suffix string.
             return null;
         }
-
+        
         String address = htmlCode.substring(index, suffixIndex);
         return java.net.URLDecoder.decode(address, StandardCharsets.UTF_8.toString()).replace("&amp;", "&");
     }
-
+    
     public static String getInfoSocket(String htmlCode, String token) {
         token = token + " : ";
         int index = htmlCode.indexOf(token);
         if (index == -1) {
             return null;
         }
-
+        
         index += token.length();
         int suffixIndex = htmlCode.indexOf(",", index);
         if (suffixIndex == -1) {
             return null;
         }
-
+        
         String value = htmlCode.substring(index, suffixIndex);
         value = value.replaceAll("[\'||\"]", "");
         return value;
     }
-
+    
     public static String TaoMsg(String commandId, List<String> list, SessionEntity ss) throws NoSuchAlgorithmException, UnsupportedEncodingException {
         String what_is_this = "5dcd73d391c90e8769618d42a916ea1b";
         String input = commandId + ss.getUserId();
-
+        
         String msg = String.format("%s\u0001%s\t%s\u0002", commandId, ss.getUserId(), ss.getSessionKey());
         Date date = new Date();
         long millisecondsSinceEpoch = date.getTime();
@@ -327,17 +332,17 @@ public class Util {
                 msg += string + '\t';
             }
         }
-
+        
         input += what_is_this;
         if (list != null && list.size() > 0) {
             msg = msg.substring(0, msg.length());
         }
-
+        
         String checksum = hash(input);
         msg += String.format("\u0003%s\u0004%d\u0005\0", checksum, millisecondsSinceEpoch);
         return msg;
     }
-
+    
     public static String hash(String input) throws NoSuchAlgorithmException, UnsupportedEncodingException {
         MessageDigest md = MessageDigest.getInstance("MD5");
         byte[] buffer = md.digest(input.getBytes("UTF8"));
@@ -347,9 +352,9 @@ public class Util {
         }
         return builder.toString();
     }
-
+    
     public static Properties loadProperties(String file_name) {
-
+        
         final Properties pr = new Properties();
         //window
 //        String x = "D:\\7-Project\\Java\\1. Netbean\\2. nghien-cuu\\TQTK\\runshell\\"+file_name;
@@ -364,7 +369,7 @@ public class Util {
         }
         return pr;
     }
-
+    
     public static void setData(String file_name, List<SessionEntity> ss) {
         org.json.simple.JSONObject jSONObject = null;
         JSONParser jsonParser = new JSONParser();
@@ -373,49 +378,68 @@ public class Util {
         try (FileReader reader = new FileReader(x)) {
             //Read JSON file
             jSONObject = (org.json.simple.JSONObject) jsonParser.parse(reader);
-
+            
             JSONArray jSONArray = (JSONArray) jSONObject.get("accounts");
-
+            
             for (Iterator it = jSONArray.iterator(); it.hasNext();) {
                 jSONObject = (JSONObject) it.next();
-                SessionEntity s1 = new SessionEntity((String) jSONObject.get("UserId"), (String) jSONObject.get("UserId"));
+                SessionEntity s1 = new SessionEntity();
                 s1.setIp((String) jSONObject.get("Ip"));
-                s1.setPorts(Integer.parseInt((String) jSONObject.get("Port")));
+                s1.setPort((String) jSONObject.get("Port"));
                 s1.setSessionKey((String) jSONObject.get("SessionKey"));
                 s1.setUserId((String) jSONObject.get("UserId"));
                 ss.add(s1);
             }
-
+            
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
-
-    public static void setData1(String content, List<SessionEntity> ss) {
-        org.json.simple.JSONObject jSONObject = null;
-        JSONParser jsonParser = new JSONParser();
-        JSONObject jSONObjecttemp = null;
+    
+    public static List<SessionEntity> setData1(List<SessionEntity> ss) throws Exception {
         try {
-            //Read JSON file
-            jSONObject = (org.json.simple.JSONObject) jsonParser.parse(content);
-
-            JSONArray jSONArray = (JSONArray) jSONObject.get("accounts");
-
-            for (Iterator it = jSONArray.iterator(); it.hasNext();) {
-                jSONObject = (JSONObject) it.next();
-                SessionEntity s1 = new SessionEntity((String) jSONObject.get("UserId"), (String) jSONObject.get("UserId"));
-                s1.setIp((String) jSONObject.get("Ip"));
-                s1.setPorts(Integer.parseInt((String) jSONObject.get("Port")));
-                s1.setSessionKey((String) jSONObject.get("SessionKey"));
-                s1.setUserId((String) jSONObject.get("UserId"));
-                ss.add(s1);
+            
+            String x = HttpURLConnectionGet("http://subsixcyber13.pythonanywhere.com/main");
+            ObjectMapper mapper = new ObjectMapper();
+            mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
+            Accounts response = mapper.readValue(x, Accounts.class);
+            ss = response.getAccounts();
+            return response.getAccounts();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+    
+    public static void updateData(String id) throws Exception {
+        try {
+            
+            String x = HttpURLConnectionGet("http://subsixcyber13.pythonanywhere.com/main");
+            ObjectMapper mapper = new ObjectMapper();
+            mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
+            Accounts response = mapper.readValue(x, Accounts.class);
+            List<SessionEntity> ss = response.getAccounts();
+            SessionEntity entity = null;
+            for (int i = 0; i < ss.size(); ++i) {
+                if (id.equals(ss.get(i).getUserId())) {
+                    entity = ss.get(i);
+                }
             }
-
+            for (SessionEntity item : tqtk.Tqtk.listSession) {
+                if (id.equals(item.getUserId())) {
+                    item.setBuildingIds(entity.getBuildingIds());
+                    item.setHeroIds(entity.getHeroIds());
+                    item.setItemIds(entity.getItemIds());
+                    item.setSkillIds(entity.getSkillIds());
+                    item.setSessionKey(entity.getSessionKey());
+                }
+            }
+            
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
-
+    
     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;
@@ -427,9 +451,47 @@ public class Util {
             return null;
         }
     }
-
+    
+    private static String HttpURLConnectionGet(final String url) throws Exception {
+        try {
+            final URL obj = new URL(url);
+            HttpURLConnection con;
+            if (obj.getProtocol().equals("http")) {
+                con = (HttpURLConnection) obj.openConnection();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setRequestMethod("GET");
+            con.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36");
+            con.setRequestProperty("Host", "subsixcyber13.pythonanywhere.com");
+            
+            int responseCode = con.getResponseCode();
+            if (200 <= responseCode && responseCode <= 399) {
+                String queryResult = "";
+                BufferedInputStream bis = new BufferedInputStream(con.getInputStream());
+                ByteArrayBuffer baf = new ByteArrayBuffer(50);
+                int read = 0;
+                int bufSize = 512;
+                byte[] buffer = new byte[bufSize];
+                while (true) {
+                    read = bis.read(buffer);
+                    if (read == -1) {
+                        break;
+                    }
+                    baf.append(buffer, 0, read);
+                }
+                queryResult = new String(baf.toByteArray());
+                return queryResult;
+            }
+            
+        } catch (Exception e) {
+            e.getMessage();
+        }
+        return null;
+    }
+    
     public static List<String> docFileCauHoiThuThue(String file_name) {
-
+        
         final Properties pr = new Properties();
         //window
 //        String x = "D:\\7-Project\\Java\\1. Netbean\\2. nghien-cuu\\TQTK\\runshell\\cauhoi\\"+file_name;
@@ -441,12 +503,12 @@ public class Util {
             return null;
         }
     }
-
+    
     public String test2(String url) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(url);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -461,10 +523,10 @@ public class Util {
             con.setRequestProperty("Upgrade-Insecure-Requests", "1");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -473,11 +535,11 @@ public class Util {
                 }
                 in.close();
                 return con.getHeaderField("Location");
-
+                
             } else {
                 return "rea2";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");
@@ -485,12 +547,12 @@ public class Util {
             throw e;
         }
     }
-
+    
     public String test1(String url) throws Exception {
         HttpURLConnection con = null;
         try {
             URL obj = new URL(url);
-
+            
             String pro = obj.getProtocol();
             if (pro.equals("http")) {
                 con = (HttpURLConnection) obj.openConnection();
@@ -505,10 +567,10 @@ public class Util {
             con.setRequestProperty("Upgrade-Insecure-Requests", "1");
             con.setUseCaches(false);
             con.setDoOutput(true);
-
+            
             int responseCode = con.getResponseCode();
             if (200 <= responseCode && responseCode <= 399) {
-
+                
                 BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));
                 StringBuffer response = new StringBuffer();
                 String inputLine;
@@ -517,11 +579,11 @@ public class Util {
                 }
                 in.close();
                 return response.toString();
-
+                
             } else {
                 return "tre1";
             }
-
+            
         } catch (Exception e) {
             if (e instanceof SocketTimeoutException) {
                 throw new SocketTimeoutException("");

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

@@ -44,6 +44,14 @@ public class Worker extends Thread {
     int Mo = 0;
     int areaId = 0;
 
+    public SessionEntity getSs() {
+        return ss;
+    }
+
+    public void setSs(SessionEntity ss) {
+        this.ss = ss;
+    }
+
     public Worker(SessionEntity ss) {
 
         this.ss = ss;
@@ -52,7 +60,7 @@ public class Worker extends Thread {
     public void GuiPacketDeLogin() throws InterruptedException, IOException, Exception {
         // packet duy tri dang nhap , neu muon truy cap vao 1 acc tu` nhieu noi thi , phai co'
         // 1 noi dang nhap truoc roi , luc nay se ko can chay packet  10100
-        Thread.sleep(5000);
+//        Thread.sleep(5000);
         GuiPacketKhongKQ(ss, "10100", null);
         // packet cap nhat thong tin lien tuc tu server
         Thread.sleep(5000);
@@ -72,6 +80,41 @@ public class Worker extends Thread {
     }
 
     public void LuyenTuong() {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "1");
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+        list2.add(1, "1");
+        list2.add(2, "1");
+
+        try {
+            for (String entry : ss.getHeroIds()) {
+                list1.set(0, entry);
+                list2.set(0, entry);
+
+                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 ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("loi LuyenTuong " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("loi LuyenTuong json" + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    public void LuyenTuong1() {
         List<String> list1 = new ArrayList<>();
         list1.add(0, "0");
         List<String> list2 = new ArrayList<>();
@@ -98,18 +141,19 @@ public class Worker extends Thread {
                     }
 
                     List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("general");
-					
-					Tqtk.sendMessage("lt " + ss.getStringName());
-					
+
+                    Tqtk.sendMessage("lt " + ss.getStringName());
+
                     int idhero = 0;
                     String name = "";
                     int trainflag = 0;
                     int lvhero = 0;
 
                     list1.add(1, "1");
-					if(carMap1!=null)
-						Collections.reverse(carMap1);
-                    
+                    if (carMap1 != null) {
+                        Collections.reverse(carMap1);
+                    }
+
                     for (Object object : carMap1) {
 
                         idhero = (int) ((Map<Object, Object>) object).get("generalid");
@@ -148,22 +192,17 @@ public class Worker extends Thread {
                                 GuiPacket(ss, "41102", list2);
                                 Thread.sleep(5000);
 
-                            } 
-							
-							else if ("伊奈忠次".equals(name) && trainflag == 0) {
+                            } else if ("伊奈忠次".equals(name) && trainflag == 0) {
                                 // quach gia
 
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                            
 
-                            }
-							else if ("村上義清".equals(name) && trainflag == 0) {
+                            } else if ("村上義清".equals(name) && trainflag == 0) {
                                 // luu bieu
 
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                               
 
                             } else if ("島津忠直--".equals(name) && trainflag == 0) {
                                 // y tich
@@ -187,7 +226,6 @@ public class Worker extends Thread {
                                 // hoa ham
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                               
 
                             } else if ("旭姫".equals(name) && trainflag == 0) {
                                 // vu co
@@ -202,7 +240,6 @@ public class Worker extends Thread {
                                 // thai diem
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                             
 
                             } else if ("内藤正成--".equals(name) && trainflag == 0) {
                                 // duong tu
@@ -230,17 +267,13 @@ public class Worker extends Thread {
                                 // ha hau uyen tdxk
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                             
 
-                            }else if ("服部半藏".equals(name) && trainflag == 0) {
+                            } else if ("服部半藏".equals(name) && trainflag == 0) {
                                 // tao thao
                                 GuiPacket(ss, "41101", list1);
                                 Thread.sleep(5000);
-                              
 
                             }
-							
-							
 
                         }
                     }
@@ -335,134 +368,11 @@ public class Worker extends Thread {
         }
         //}
     }
-	
-	public void TruyNa2() {
-    if (Truyna == 1) {
-        Truyna = 0;
-        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 tmp = "";
-					String playerName="";
-                    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(Long.toString(playerId)) &&
-                                attactNum != 0
-                                //                                    && idarea == -1
-                                &&
-                                isAttacked == 0 &&
-                                level < 88) {
-                                 rs1 = GuiPacketTN(ss, "60606", list1);
-                                    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));
-                                    }else{
-										break;
-									}
-                                
-
-                            }
-                        }
-						Thread.sleep(5000);
-                        MuaLinh();
-                    }
-                } catch (Exception e) {
-                    throw new JsonException();
-                }
-
-                //}
-            }
-        } 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() throws InterruptedException, IOException {
-        try {
-            GuiPacketTN(ss, "11102", null);
-            Thread.sleep(5000);
-        } catch (Exception e) {
-        }
+    public void TruyNa2() {
+        if (Truyna == 1) {
 
-        if (ss.getUserId().equals("2301230011011923")) {
-            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);
-                    }
-                }
-            } catch (Exception e) {
-                System.out.println("GuiPacketTN 2 " + e.getMessage());
-            }
-        } else if (ss.getUserId().equals("2301211923397199")) {
-
-            List<String> list1 = new ArrayList<>();
+            List< String> list1 = new ArrayList<>();
             list1.add(0, "0");
             try {
                 Thread.sleep(5000);
@@ -472,10 +382,10 @@ public class Worker extends Thread {
                         String[] temp = rs1.toString().split("");
 
                         ObjectMapper mapper = new ObjectMapper();
-                        Map<String, Object> carMap = null;
+                        Map< String, Object> carMap = null;
                         int h = 0;
                         for (String string : temp) {
-                            carMap = mapper.readValue(string, new TypeReference<Map<String, Object>>() {
+                            carMap = mapper.readValue(string, new TypeReference< Map< String, Object>>() {
                             });
                             h = (int) carMap.get("h");
                             if (h == Integer.parseInt("60605")) {
@@ -483,46 +393,33 @@ public class Worker extends Thread {
                             }
                         }
 
-                        List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("wantedMemberList");
+                        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 = "";
-                        TruyNa tn = null;
+                        String playerName = "";
                         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");
+                            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));
 
-                            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))
+                                if (id != 0 && !Tqtk.loaiTruyna.contains(Long.toString(playerId))
                                         && attactNum != 0
                                         //                                    && idarea == -1
                                         && isAttacked == 0
-                                        && level < 61) {
+                                        && level < 88) {
                                     rs1 = GuiPacketTN(ss, "60606", list1);
                                     if (rs1 != null) {
                                         tmp = rs1.toString();
@@ -530,10 +427,15 @@ public class Worker extends Thread {
                                     if (tmp.contains("\"winside\":2") || tmp.contains("\"winside\": 2")) {
                                         tqtk.Tqtk.loaiTruyna.add(playerName);
                                         tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
+                                    } else {
+                                        Truyna = 0;
+                                        break;
                                     }
+
                                 }
                             }
                             Thread.sleep(5000);
+                            MuaLinh();
                         }
                     } catch (Exception e) {
                         throw new JsonException();
@@ -553,9 +455,132 @@ public class Worker extends Thread {
         }
     }
 
+    public void TruyNa() throws InterruptedException, IOException {
+        if (Truyna == 1) {
+            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);
+                                Truyna = 0;
+                            }
+
+                        }
+                        Thread.sleep(2000);
+                    }
+                }
+            } catch (Exception e) {
+                System.out.println("GuiPacketTN 2 " + e.getMessage());
+            }
+        }
+
+    }
+
+    public void getIdTruyNa() {
+        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 = "";
+                    TruyNa tn = null;
+                    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));
+
+                        tn = new TruyNa();
+                        tn.setAttactNum(attactNum);
+                        tn.setId(Long.toString(id));
+                        tn.setPlayerId(Long.toString(playerId));
+                        tn.setPlayerName(playerName);
+                        Tqtk.listtruyna.add(tn);
+
+                        Thread.sleep(1000);
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+                //}
+            }
+        } 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 NangNha() {
         List<String> list1 = new ArrayList<>();
 
+        try {
+            list1.add(0, "5");
+            for (String buildingId : ss.getBuildingIds()) {
+                list1.set(0, buildingId);
+                Thread.sleep(5000);
+                GuiPacket(ss, "12100", list1);
+            }
+
+        } catch (Exception e) {
+            System.out.println("NangNha " + ss.getStringName() + e.getMessage());
+        }
+    }
+
+    public void NangNha1() {
+        List<String> list1 = new ArrayList<>();
+
         try {
             // nha chinh
             list1.add(0, "5");
@@ -584,6 +609,22 @@ public class Worker extends Thread {
     }
 
     public void NangKiNang() {
+        List<String> list1 = new ArrayList<>();
+        try {
+            //binh khi , 42200 ,3
+            list1.add(0, "13");
+            Tqtk.sendMessage("nang kn " + ss.getStringName());
+            for (String skillId : ss.getSkillIds()) {
+                list1.set(0, skillId);
+                Thread.sleep(5000);
+                GuiPacket(ss, "42200", list1);
+            }
+        } catch (Exception e) {
+            System.out.println("NangKiNang " + ss.getStringName() + e.getMessage());
+        }
+    }
+
+    public void NangKiNang1() {
         List<String> list1 = new ArrayList<>();
         try {
             //binh khi , 42200 ,3
@@ -851,13 +892,13 @@ public class Worker extends Thread {
                             tqtk.Tqtk.listruong = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("resource");
 
                             Tqtk.sendMessage("chiem ruong " + ss.getStringName());
-                            Object playerId = 0;
+                            String playername = "";
                             int resourceid = 0;
                             if (tqtk.Tqtk.listruong != null) {
                                 for (Object object : tqtk.Tqtk.listruong) {
-                                    playerId = ((Map<Object, Object>) object).get("playerid");
+                                    playername = (String) ((Map<Object, Object>) object).get("playername");
                                     resourceid = (int) ((Map<Object, Object>) object).get("resourceid");
-                                    if (playerId instanceof Integer) {
+                                    if (playername.equals("地方勢力")) {
                                         break;
                                     }
                                 }
@@ -922,13 +963,13 @@ public class Worker extends Thread {
                         List<Object> listmo = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("city");
 
                         Tqtk.sendMessage("chiem mo " + ss.getStringName());
-                        Object playerId = 0;
+                        String playername = "";
                         int resourceid = 0;
                         if (listmo != null) {
                             for (Object object : listmo) {
-                                playerId = ((Map<Object, Object>) object).get("playerid");
+                                playername = (String) ((Map<Object, Object>) object).get("playername");
                                 resourceid = (int) ((Map<Object, Object>) object).get("index");
-                                if (playerId instanceof Integer) {
+                                if (playername.equals("地方勢力")) {
                                     break;
                                 }
                             }
@@ -1011,6 +1052,65 @@ public class Worker extends Thread {
     }
 
     public void NangItem() throws IOException, UnknownHostException, InterruptedException, Exception {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        list1.add(2, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacket(ss, "39301", list1);
+            if (rs1 != null && rs1.toString() != "") {
+                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("39301")) {
+                            break;
+                        }
+                    }
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("equip");
+                    Object Magic = (Object) ((Map<String, Object>) carMap.get("m")).get("magic");
+                    int Upgradecdusable = (int) ((Map<String, Object>) carMap.get("m")).get("upgradecdusable");
+                    Tqtk.sendMessage("nang item " + ss.getStringName());
+                    for (String object : ss.getItemIds()) {
+
+                        list1.set(0, object);
+                        list1.set(2, Magic.toString());
+                        if (Upgradecdusable == 1 && (int) Magic >= 89) {
+                            GuiPacket(ss, "39302", list1);
+                            Thread.sleep(5000);
+                            GuiPacket(ss, "39302", list1);
+                            Thread.sleep(5000);
+                        }
+
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+            } else {
+                dangNhapLayThongTin();
+                GuiPacketDeLogin();
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("NangItem " + ss.getStringName() + ex.getMessage());
+                dangNhapLayThongTin();
+                GuiPacketDeLogin();
+            } else {
+                System.out.println("NangItem json " + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    public void NangItem1() throws IOException, UnknownHostException, InterruptedException, Exception {
         List<String> list1 = new ArrayList<>();
         list1.add(0, "0");
         list1.add(1, "0");
@@ -1142,14 +1242,14 @@ public class Worker extends Thread {
 
     public void dangNhapLayThongTin() throws Exception {
         Socket socket = new Socket();
-        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), ss.getPorts()), 7000);
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
         if (ss.getSocket() != null) {
             ss.getSocket().close();
         }
         ss.setSocket(socket);
 
         Socket socket1 = new Socket();
-        socket1.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), ss.getPorts()), 7000);
+        socket1.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
         if (ss.getSocketApi() != null) {
             ss.getSocketApi().close();
         }
@@ -1158,7 +1258,7 @@ public class Worker extends Thread {
 
     public void taoSocketTruyNa() throws Exception {
         Socket socket = new Socket();
-        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), ss.getPorts()), 7000);
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
         if (ss.getSocketTN() != null) {
             ss.getSocketTN().close();
         }
@@ -1356,17 +1456,8 @@ public class Worker extends Thread {
     }
 
     public static void createSocket(SessionEntity session) throws Exception {
-        Socket socket1 = new Socket();
-        socket1.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), session.getPorts()), 7000);
-        socket1.setSoTimeout(350000);
-        try {
-            session.getSocketApi().close();
-        } catch (Exception e) {
-        }
-        session.setSocketApi(socket1);
-
         Socket socket = new Socket();
-        socket.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), session.getPorts()), 7000);
+        socket.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), Integer.parseInt(session.getPort())), 7000);
         socket.setSoTimeout(350000);
         try {
             session.getSocket().close();
@@ -1377,7 +1468,7 @@ public class Worker extends Thread {
 
     public static void createSocketApi(SessionEntity session) throws Exception {
         Socket socket1 = new Socket();
-        socket1.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), session.getPorts()), 7000);
+        socket1.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), Integer.parseInt(session.getPort())), 7000);
         socket1.setSoTimeout(350000);
         try {
             session.getSocketApi().close();
@@ -1391,28 +1482,10 @@ public class Worker extends Thread {
         try {
             dangNhapLayThongTin();
             GuiPacketDeLogin();
-            taoSocketTruyNa();
-            new Thread() {
-                @Override
-                public void run() {
-					while (true) {
-                    try {
-                        
-                            TruyNa2();
-                        
-                    } catch (Exception e) {
-                        System.out.println("TruyNa .run() " + e.getMessage() + " " + ss.getStringName());
-                    }
-					}
-                }
-            }.start();
-            while (true) {
-				try {
+            try {
 
                 MuaLinh();
-//                DanhQuanDoan1();
-//                DanhQuanDoan2();
-//                DanhQuanDoan3();
+
                 NangItem();
                 LuyenTuong();
                 NangNha();
@@ -1426,10 +1499,9 @@ public class Worker extends Thread {
                 ChiemRuong();
                 MuaRuong();
                 CapNhatThongTin();
-                Thread.sleep(55 * 1000);
-				 } catch (Exception ex) {
-            System.out.println("all " + ss.getStringName() + ex.getMessage());
-        }
+                
+            } catch (Exception ex) {
+                System.out.println("all " + ss.getStringName() + ex.getMessage());
             }
         } catch (Exception ex) {
             System.out.println("all " + ss.getStringName() + ex.getMessage());

src/main/java/tqtk/XuLy/login/LayThongTinSession.java

@@ -32,7 +32,7 @@ import static tqtk.Tqtk.sendMessage;
  */
 public class LayThongTinSession {
 
-    private static List<SessionEntity> ListSession = new ArrayList<>();
+   
 
     public static synchronized SessionEntity getSessionEntity(String user, String pass, int id, Util u) throws Exception {
         // login va lay thong tin session
@@ -48,16 +48,11 @@ public class LayThongTinSession {
         String userID = Util.getInfoSocket(html, "userID");
         SessionEntity ss = new SessionEntity();
         ss.setIp(ip);
-        ss.setPorts(Integer.parseInt(ports));
+        ss.setPort(ports);
         ss.setSessionKey(sessionKey);
         ss.setUserId(userID);
         ss.setStringName(user);
         u.setCookie(null);
         return ss;
     }
-
-    public static List<SessionEntity> getListSession() {
-        return ListSession;
-    }
-
 }

truyna-b.properties

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

truyna.properties

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