up

Dockerfile

@@ -12,4 +12,4 @@ FROM openjdk:11-jdk-slim
 COPY --from=build /target/demo-0.0.1-SNAPSHOT.jar demo.jar
 # ENV PORT=8080
 EXPOSE 8080
-ENTRYPOINT ["java","-jar","demo.jar"]
+ENTRYPOINT ["java","-Dfile.encoding=UTF-8","-jar","demo.jar"]

pom.xml

@@ -17,6 +17,30 @@
 		<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>

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

@@ -8,6 +8,10 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import tqtk.Entity.SessionEntity;
+import tqtk.Tqtk;
+import tqtk.XuLy.login.LayThongTinSession;
+
 @SpringBootApplication
 @RestController
 public class DemoApplication {
@@ -21,5 +25,18 @@ public class DemoApplication {
 		count++;
 		return "Number of users = "+ count;
 	}
+	
+	@GetMapping("start")
+	public String start(){
+		if (LayThongTinSession.getListSession().size() < 1) {
+            Thread t = new Thread() {
+                public void run() {
+                    tqtk.Tqtk.main();
+                }
+            };
+            t.start();
+        }
+		return "ok";
+	}
 
 }

src/main/java/tqtk/Entity/Barrack.java

@@ -0,0 +1,26 @@
+/*
+ * 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 java.util.List;
+
+/**
+ *
+ * @author Alex
+ */
+public class Barrack {
+    public List<Hero> General;
+
+    public List<Hero> getGeneral() {
+        return General;
+    }
+
+    public void setGeneral(List<Hero> General) {
+        this.General = General;
+    }
+    
+    
+}

src/main/java/tqtk/Entity/Hero.java

@@ -0,0 +1,37 @@
+/*
+ * 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;
+
+/**
+ *
+ * @author Alex
+ */
+public class Hero {
+    public String Generalid;
+    public String Generalname;
+
+    public String getGeneralid() {
+        return Generalid;
+    }
+
+    public void setGeneralid(String Generalid) {
+        this.Generalid = Generalid;
+    }
+
+
+
+
+
+    public String getGeneralname() {
+        return Generalname;
+    }
+
+    public void setGeneralname(String Generalname) {
+        this.Generalname = Generalname;
+    }
+    
+    
+}

src/main/java/tqtk/Entity/JsonObject.java

@@ -0,0 +1,42 @@
+/*
+ * 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;
+
+/**
+ *
+ * @author Alex
+ */
+public class JsonObject {
+
+    public Object u;
+    public Object r;
+    public Barrack m;
+
+    public Barrack getM() {
+        return m;
+    }
+
+    public void setM(Barrack m) {
+        this.m = m;
+    }
+
+    public Object getU() {
+        return u;
+    }
+
+    public void setU(Object u) {
+        this.u = u;
+    }
+
+    public Object getR() {
+        return r;
+    }
+
+    public void setR(Object r) {
+        this.r = r;
+    }
+
+}

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

@@ -0,0 +1,117 @@
+/*
+ * 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 java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+
+/**
+ *
+ * @author Alex
+ */
+public class SessionEntity {
+
+    private String userId;
+    private String pass;
+    private String ip;
+    private int ports;
+    private String sessionKey;
+    private Socket socket;
+    private boolean isConnected;
+    private String stringName;
+
+    public String getStringName() {
+        return stringName;
+    }
+
+    public void setStringName(String stringName) {
+        this.stringName = stringName;
+    }
+    
+    
+    public SessionEntity(String stringName, String pass) {
+        this.stringName = stringName;
+        this.pass = pass;
+    }
+
+    public SessionEntity() {
+    }
+
+    public void resetSocket() throws IOException {
+        this.socket.close();
+        this.socket = new Socket();
+        this.socket.connect(new InetSocketAddress(InetAddress.getByName(ip), ports), 7000);
+    }
+
+    public String getPass() {
+        return pass;
+    }
+
+    public void setPass(String pass) {
+        this.pass = pass;
+    }
+
+    public boolean isIsConnected() {
+        return isConnected;
+    }
+
+    public void setIsConnected(boolean isConnected) {
+        this.isConnected = isConnected;
+    }
+
+    public Socket getSocket() {
+        return socket;
+    }
+
+    public void setSocket(Socket socket) {
+        this.socket = socket;
+    }
+
+    private StringBuilder message = new StringBuilder();
+
+    public StringBuilder getMessage() {
+        return message;
+    }
+
+    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/Tqtk.java

@@ -0,0 +1,73 @@
+/*
+ * 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;
+
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Properties;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import tqtk.Entity.SessionEntity;
+import tqtk.Utils.Util;
+import tqtk.XuLy.Worker;
+import tqtk.XuLy.login.LayThongTinSession;
+
+/**
+ *
+ * @author Alex
+ */
+public class Tqtk {
+
+    public static List<String> loaiTruyna = new ArrayList<>();
+    public static List<Object> listruong = new ArrayList<>();
+
+    static {
+        loaiTruyna = Collections.synchronizedList(loaiTruyna);
+        listruong = Collections.synchronizedList(listruong);
+    }
+
+    public static void main() {
+        // TODO code application logic here
+        try {
+//            Properties pr = Util.loadProperties("user.properties");
+//            String value = "";
+//            String[] temp = new String[2];
+//            for (int i = 0; (value = pr.getProperty("user" + "." + i)) != null; i++) {
+//                temp = value.split("\\|");
+//                LayThongTinSession.getListSession().add(new SessionEntity(temp[0], temp[1]));
+//            }
+
+            LayThongTinSession.getListSession().add(new SessionEntity("n", "p"));
+            
+            List<SessionEntity> ss = LayThongTinSession.getListSession();
+
+            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);
+            }
+            executor.shutdown();
+            while (!executor.isTerminated()) {
+            }
+            System.out.println("tqtk.Tqtk.main()");
+            
+        } catch (Exception ex) {
+            System.out.println(ex.getMessage());
+        }
+    }
+
+    public static synchronized void sendMessage(final String ms) {
+        System.out.println(ms);
+    }
+
+}

src/main/java/tqtk/Utils/Doc_file_kieu_txt.java

@@ -0,0 +1,59 @@
+package tqtk.Utils;
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ *
+ * @author Alex
+ */
+public class Doc_file_kieu_txt {
+
+    public static List<String> readFile(String path) {
+        BufferedReader br = null;
+        FileReader fr = null;
+        List<String> lists = new ArrayList<String>();
+        try {
+
+            fr = new FileReader(path);
+            br = new BufferedReader(fr);
+
+            String read = "";
+
+            br = new BufferedReader(new FileReader(path));
+
+            while ((read = br.readLine()) != null) {
+                lists.add(read);
+            }
+            return lists;
+
+        } catch (IOException e) {
+
+            e.printStackTrace();
+
+        } finally {
+
+            try {
+
+                if (br != null) {
+                    br.close();
+                }
+
+                if (fr != null) {
+                    fr.close();
+                }
+
+            } catch (IOException ex) {
+
+                ex.printStackTrace();
+
+            }
+
+        }
+        return null;
+    }
+
+}

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

@@ -0,0 +1,461 @@
+/*
+ * 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.Utils;
+
+import java.io.BufferedReader;
+import java.io.DataOutputStream;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
+import java.net.CookieHandler;
+import java.net.CookieManager;
+import java.net.HttpCookie;
+import java.net.HttpURLConnection;
+import java.net.SocketTimeoutException;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.Properties;
+import javax.net.ssl.HttpsURLConnection;
+import org.apache.commons.lang3.StringUtils;
+import tqtk.Entity.SessionEntity;
+
+/**
+ *
+ * @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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            con.setRequestMethod("GET");
+//            con.setRequestProperty("Host", "app.slg.vn");
+            con.setRequestProperty("Upgrade-Insecure-Requests", "1");
+            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;
+                while ((inputLine = in.readLine()) != null) {
+                    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("");
+            }
+            throw e;
+        }
+    }
+
+    public static String getToken(String htmlCode) {
+        String prefix = "name=\"_token\" value=\"";
+        int index = htmlCode.indexOf(prefix);
+        if (index == -1) {
+            // Could not find the prefix string.
+            return null;
+        }
+
+        index += prefix.length();
+
+        // Login token has a fixed length of 40.
+        int TokenLength = 40;
+        if (htmlCode.length() < index + TokenLength) {
+            // 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);
+        if (prefixIndex == -1) {
+            // Could not find the prefix string.
+            return null;
+        }
+        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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            String urlParameters = "_token=" + token + "&callback=&email=" + user + "&password=" + pass;
+            byte[] postData = urlParameters.getBytes(StandardCharsets.UTF_8);
+            int postDataLength = postData.length;
+            con.setRequestMethod("POST");
+            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", "id.slg.vn");
+            con.setRequestProperty("Content-Length", Integer.toString(postDataLength));
+            con.setRequestProperty("Upgrade-Insecure-Requests", "1");
+            con.setRequestProperty("Referer", Refer);
+            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;
+                while ((inputLine = in.readLine()) != null) {
+                    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("");
+            }
+            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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            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", "app.slg.vn");
+//            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;
+                while ((inputLine = in.readLine()) != null) {
+                    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("");
+            }
+            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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            con.setRequestMethod("GET");
+//            con.setRequestProperty("Host", "app.slg.vn");
+            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", "api.tamquoc.slg.vn");
+            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;
+                while ((inputLine = in.readLine()) != null) {
+                    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("");
+            }
+            throw e;
+        }
+    }
+
+    public static String getFrameString(String htmlCode) throws UnsupportedEncodingException {
+        String prefix = "src=\"";
+        int index = htmlCode.indexOf(prefix);
+        if (index == -1) {
+            // 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();
+        if (list != null && list.size() > 0) {
+            for (String string : list) {
+                input += string;
+                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"));
+        StringBuilder builder = new StringBuilder(input.length() * 2);
+        for (byte b : buffer) {
+            builder.append(String.format("%02x", b));
+        }
+        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;
+        //heroku
+        String x = "/app/" + file_name;
+        try {
+            final InputStream fin = new FileInputStream(x);
+            pr.load(fin);
+            fin.close();
+        } catch (final IOException ioe) {
+            return null;
+        }
+        return pr;
+    }
+
+    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;
+        //heroku
+        String x = "/app/cauhoi/" + file_name;
+        try {
+            return Doc_file_kieu_txt.readFile(x);
+        } catch (Exception e) {
+            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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            con.setRequestMethod("GET");
+//            con.setRequestProperty("Host", "app.slg.vn");
+            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", "api.tamquoc.slg.vn");
+            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;
+                while ((inputLine = in.readLine()) != null) {
+                    response.append(inputLine);
+                }
+                in.close();
+                return con.getHeaderField("Location");
+
+            } else {
+                return "rea2";
+            }
+
+        } catch (Exception e) {
+            if (e instanceof SocketTimeoutException) {
+                throw new SocketTimeoutException("");
+            }
+            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();
+            } else {
+                con = (HttpsURLConnection) obj.openConnection();
+            }
+            con.setConnectTimeout(7000);
+            con.setRequestMethod("GET");
+//            con.setRequestProperty("Host", "app.slg.vn");
+            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", "api.sengokugifu.jp");
+            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;
+                while ((inputLine = in.readLine()) != null) {
+                    response.append(inputLine);
+                }
+                in.close();
+                return response.toString();
+
+            } else {
+                return "tre1";
+            }
+
+        } catch (Exception e) {
+            if (e instanceof SocketTimeoutException) {
+                throw new SocketTimeoutException("");
+            }
+            throw e;
+        }
+    }
+}

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

@@ -0,0 +1,911 @@
+package tqtk.XuLy;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import tqtk.Entity.Barrack;
+import tqtk.Entity.Hero;
+import tqtk.Entity.JsonObject;
+import tqtk.Entity.SessionEntity;
+import tqtk.Tqtk;
+import tqtk.Utils.Util;
+import tqtk.XuLy.login.LayThongTinSession;
+import static tqtk.XuLy.XuLyPacket.GuiPacket;
+
+import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQ;
+import tqtk.exception.JsonException;
+
+/**
+ *
+ * @author Alex
+ */
+public class Worker extends Thread {
+
+    SessionEntity ss;
+
+    public Worker(SessionEntity ss) {
+
+        this.ss = ss;
+    }
+
+    public void GuiPacketDeLogin() throws InterruptedException, IOException {
+        // 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);
+        GuiPacketKhongKQ(ss, "10100", null);
+        // packet cap nhat thong tin lien tuc tu server
+        Thread.sleep(5000);
+        GuiPacketKhongKQ(ss, "11102", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQ(ss, "52103", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQ(ss, "10108", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQ(ss, "20101", null);
+        Thread.sleep(5000);
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "1");
+        StringBuilder rs1 = GuiPacket(ss, "12200", list1);
+        list1 = null;
+
+    }
+
+    public void LuyenTuong() {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+        list2.add(1, "1");
+        list2.add(2, "1");
+
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "41100", list1);
+            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("41100")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("general");
+                    int idhero = 0;
+                    String name = "";
+                    int trainflag = 0;
+                    int lvhero = 0;
+
+                    list1.add(1, "1");
+                    Tqtk.sendMessage("lt " + ss.getStringName());
+                    for (Object object : carMap1) {
+
+                        idhero = (int) ((Map<Object, Object>) object).get("generalid");
+                        name = (String) ((Map<Object, Object>) object).get("generalname");
+                        trainflag = (int) ((Map<Object, Object>) object).get("trainflag");
+                        lvhero = (int) ((Map<Object, Object>) object).get("generallevel");
+                        list1.set(0, Integer.toString(idhero));
+                        list2.set(0, Integer.toString(idhero));
+                        Tqtk.sendMessage("lt " + name);
+                        if (name != null) {
+                            if ("武田信虎 --".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("織田信行 --".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("井伊直盛 --".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("彦坂元正 --".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("大久保忠員".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("内藤正成".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("Thái Diễm ".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            } else if ("Tư Mã Chiêu ".equals(name) && trainflag == 0) {
+                                rs1 = GuiPacket(ss, "41101", list1);
+                                Thread.sleep(5000);
+                                rs1 = GuiPacket(ss, "41102", list2);
+                                Thread.sleep(5000);
+
+                            }
+                        }
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+            }
+        } 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 TruyNa() {
+        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;
+                    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");
+                        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) {
+                            rs1 = GuiPacket(ss, "60606", list1);
+                            Thread.sleep(5000);
+                            if (rs1.toString().contains("đã thất bại khi chiến đấu")) {
+                                tqtk.Tqtk.loaiTruyna.add(Long.toString(playerId));
+                            }
+
+                        }
+                        //}
+                    }
+                } 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 {
+            // nha chinh
+            list1.add(0, "5");
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacket(ss, "12100", list1);
+            Tqtk.sendMessage("nang nha " + ss.getStringName());
+            // nang cua tiem
+            list1.set(0, "6");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "12100", list1);
+            // nang thao truong
+            list1.set(0, "3");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "12100", list1);
+            // nang nang binh doanh
+            list1.set(0, "2");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "12100", list1);
+			
+			list1.set(0, "1");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "12100", list1);
+
+  
+
+        } catch (Exception e) {
+            System.out.println("NangNha " + ss.getStringName() + e.getMessage());
+        }
+    }
+
+    public void NangKiNang() {
+        List<String> list1 = new ArrayList<>();
+        try {
+            //binh khi , 42200 ,3
+            list1.add(0, "3");
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacket(ss, "42200", list1);
+            Tqtk.sendMessage("nang kn " + ss.getStringName());
+            // nang ki nang , vu khi , 42200 ,1
+            list1.set(0, "1");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "42200", list1);
+            // lenh ki , 42200 ,2
+            list1.set(0, "2");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "42200", list1);
+            //  giap , 42200 ,4
+            list1.set(0, "4");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "42200", list1);
+            //  xung phong , 42200 ,5
+            list1.set(0, "5");
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "42200", list1);
+           
+
+        } catch (Exception e) {
+            System.out.println("NangKiNang " + ss.getStringName() + e.getMessage());
+        }
+    }
+
+    public void MuaLinh() {
+        List<String> list1 = new ArrayList<>();
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "14101", null);
+
+            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("14101")) {
+                    break;
+                }
+            }
+
+            double tile = (double) ((Map<String, Object>) carMap.get("m")).get("recruits");
+            int max = (int) ((Map<String, Object>) carMap.get("m")).get("forcemax");
+            max = max / 3;
+            list1.add(0, Integer.toString((int) max));
+            list1.add(1, Integer.toString((int) Math.round(max * tile)));
+            Thread.sleep(5000);
+            rs1 = GuiPacket(ss, "14102", list1);
+            Tqtk.sendMessage("mualinh " + ss.getStringName());
+            Thread.sleep(5000);
+            GuiPacket(ss, "14100", null);
+            Thread.sleep(5000);
+
+        } catch (Exception e) {
+            System.out.println("MuaLinh " + ss.getStringName() + e.getMessage());
+        }
+    }
+
+    public void DanhQuanDoan() {
+        // danh quan doan vu van thi toc
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "900038");
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "34100", list1);
+            Thread.sleep(5000);
+            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("34100")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("team");
+                    long idhero = 0;
+
+                    Tqtk.sendMessage("qd " + ss.getStringName());
+
+                    if (carMap1 != null && carMap1.size() > 0) {
+                        Object object = carMap1.get(0);
+                        idhero = (long) ((Map<Object, Object>) object).get("teamid");
+                        list2.set(0, Long.toString(idhero));
+
+                        rs1 = GuiPacket(ss, "34102", list2);
+                        Thread.sleep(5000);
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+    }
+
+    public void DanhQuanDoan1() {
+        if (ss != null && ss.getStringName().equals("[email protected]")) {
+            // danh quan doan duong binh
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "900016");
+//            list1.add(1, "4:0;1");
+
+            List<String> list2 = new ArrayList<>();
+            list2.add(0, "0");
+
+            try {
+                StringBuilder rs1 = GuiPacket(ss, "34100", list1);
+                Thread.sleep(5000);
+                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("34100")) {
+                                break;
+                            }
+                        }
+
+                        List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("team");
+                        long idhero = 0;
+
+                        Tqtk.sendMessage("qd " + ss.getStringName());
+
+                        if (carMap1 != null && carMap1.size() > 0) {
+                            Object object = carMap1.get(0);
+                            idhero = (long) ((Map<Object, Object>) object).get("teamid");
+                            list2.set(0, Long.toString(idhero));
+
+                            rs1 = GuiPacket(ss, "34102", list2);
+                            Thread.sleep(5000);
+                        }
+                    } catch (Exception e) {
+                        throw new JsonException();
+                    }
+
+                }
+            } catch (Exception ex) {
+                if (!(ex instanceof JsonException)) {
+                    System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+                } else {
+                    System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+                }
+
+            }
+        }
+    }
+
+    public void DanhQuanDoan2() {
+
+        if (ss != null && ss.getStringName().equals("[email protected]")) {
+            // danh quan doan duong binh
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "900015");
+            List<String> list2 = new ArrayList<>();
+            list2.add(0, "0");
+
+            try {
+                StringBuilder rs1 = GuiPacket(ss, "34100", list1);
+                Thread.sleep(5000);
+                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("34100")) {
+                                break;
+                            }
+                        }
+
+                        List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("team");
+                        long idhero = 0;
+
+                        Tqtk.sendMessage("qd " + ss.getStringName());
+
+                        if (carMap1 != null && carMap1.size() > 0) {
+                            Object object = carMap1.get(0);
+                            idhero = (long) ((Map<Object, Object>) object).get("teamid");
+                            list2.set(0, Long.toString(idhero));
+
+                            rs1 = GuiPacket(ss, "34102", list2);
+                            Thread.sleep(5000);
+                        }
+                    } catch (Exception e) {
+                        throw new JsonException();
+                    }
+
+                }
+            } catch (Exception ex) {
+                if (!(ex instanceof JsonException)) {
+                    System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+                } else {
+                    System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+                }
+
+            }
+
+        }
+
+    }
+
+    public void DanhQuanDoan3() {
+
+        if ((ss != null && ss.getStringName().contains("@gmail.com") && !ss.getStringName().equals("[email protected]")) || ss != null && ss.getStringName().contains("itf.edu.vn")) {
+            // danh quan doan duong binh
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "900013");
+            List<String> list2 = new ArrayList<>();
+            list2.add(0, "0");
+
+            try {
+                StringBuilder rs1 = GuiPacket(ss, "34100", list1);
+                Thread.sleep(5000);
+                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("34100")) {
+                                break;
+                            }
+                        }
+
+                        List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("team");
+                        long idhero = 0;
+
+                        Tqtk.sendMessage("qd " + ss.getStringName());
+
+                        if (carMap1 != null && carMap1.size() > 0) {
+                            Object object = carMap1.get(0);
+                            idhero = (long) ((Map<Object, Object>) object).get("teamid");
+                            list2.set(0, Long.toString(idhero));
+
+                            rs1 = GuiPacket(ss, "34102", list2);
+                            Thread.sleep(5000);
+                        }
+                    } catch (Exception e) {
+                        throw new JsonException();
+                    }
+
+                }
+            } catch (Exception ex) {
+                if (!(ex instanceof JsonException)) {
+                    System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+                } else {
+                    System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+                }
+
+            }
+
+        }
+
+    }
+
+    public void ThuThue() {
+        // danh quan doan vu van thi toc
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "12401", list1);
+            Thread.sleep(5000);
+            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("12401")) {
+                            break;
+                        }
+                    }
+
+                    Map<String, Object> carMap1 = (Map<String, Object>) ((Map<String, Object>) carMap.get("m")).get("larrydto");
+
+                    Tqtk.sendMessage("thuthue " + ss.getStringName());
+
+                    if (carMap1 != null) {
+                        String optdisc1 = (String) carMap1.get("optdisc1");
+                        String optdisc2 = (String) carMap1.get("optdisc2");
+
+                        List<String> cauhoi = Util.docFileCauHoiThuThue("thu_thue_dan_tam.txt");
+
+                        for (String item : cauhoi) {
+                            if (optdisc1.contains(item)) {
+                                list2.set(0, "1");
+                                rs1 = GuiPacket(ss, "12406", list2);
+                                Thread.sleep(5000);
+                                break;
+                            } else if (optdisc2.contains(item)) {
+                                list2.set(0, "2");
+                                rs1 = GuiPacket(ss, "12406", list2);
+                                Thread.sleep(5000);
+                                break;
+                            } else {
+                                list2.set(0, "1");
+                                rs1 = GuiPacket(ss, "12406", list2);
+                                Thread.sleep(5000);
+                                break;
+                            }
+                        }
+
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+    }
+
+    public void ChiemRuong() {
+        // danh quan doan vu van thi toc
+        List<String> list1 = new ArrayList<>();
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "31103", null);
+            Thread.sleep(5000);
+            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("31103")) {
+                            break;
+                        }
+                    }
+                    synchronized (tqtk.Tqtk.listruong) {
+                        tqtk.Tqtk.listruong = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("resource");
+
+                        Tqtk.sendMessage("chiem ruong " + ss.getStringName());
+                        Object playerId = 0;
+                        int resourceid = 0;
+                        if (tqtk.Tqtk.listruong != null) {
+                            for (Object object : tqtk.Tqtk.listruong) {
+                                playerId = ((Map<Object, Object>) object).get("playerid");
+                                resourceid = (int) ((Map<Object, Object>) object).get("resourceid");
+                                if (playerId instanceof Integer) {
+                                    break;
+                                }
+                            }
+                        }
+                        list2.set(0, Integer.toString(resourceid));
+                        rs1 = GuiPacket(ss, "31104", list2);
+                        Thread.sleep(5000);
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("loi qd " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("loi qd json" + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+    }
+
+    public void FarmDo() {
+        if (false && ss != null && ss.getStringName().equals("[email protected]")) {
+            // danh map ngo
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "2817");
+            list1.add(1, "0");
+
+            try {
+                StringBuilder rs1 = GuiPacket(ss, "33101", list1);
+                Thread.sleep(5000);
+
+            } catch (Exception ex) {
+                System.out.println("loi FarmDo " + ss.getStringName() + ex.getMessage());
+            }
+        } else if (ss != null && ss.getStringName().contains("@gmail.com") && !ss.getStringName().equals("[email protected]")) {
+            // danh lu bo
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "2216");
+            list1.add(1, "0");
+
+            try {
+                StringBuilder rs1 = GuiPacket(ss, "33101", list1);
+                Thread.sleep(5000);
+                list1.set(0, "2529");
+                GuiPacket(ss, "33101", list1);
+                Thread.sleep(5000);
+
+            } catch (Exception ex) {
+                System.out.println("loi FarmDo " + ss.getStringName() + ex.getMessage());
+            }
+        }
+
+    }
+
+    public void NangItem() throws IOException, UnknownHostException, InterruptedException, Exception {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        list1.add(2, "30");
+        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");
+                    int lv = 0;
+                    String name = "";
+                    Integer storeid = 0;
+                    String generalname = "";
+                    Tqtk.sendMessage("nang item " + ss.getStringName());
+                    for (Object object : carMap1) {
+                        lv = (int) ((Map<Object, Object>) object).get("equipAllLevel");
+                        name = (String) ((Map<Object, Object>) object).get("equipname");
+                        storeid = (Integer) ((Map<Object, Object>) object).get("storeid");
+                        generalname = (String) ((Map<Object, Object>) object).get("generalname");
+                        Tqtk.sendMessage(lv + " " + name + " " + storeid + " " + generalname);
+                        list1.set(0, Integer.toString(storeid));
+                        list1.set(2, Magic.toString());
+                        if (generalname != null) {
+                            if ((ss != null)) {
+//                                if ((int) Magic > 87 && "武田信虎".equals(generalname)) {
+                                if ((int) Magic > 87 && "武田信虎".equals(generalname)) {
+                                    rs1 = GuiPacket(ss, "39302", list1);
+                                    Thread.sleep(5000);
+                                } 
+								else if (Upgradecdusable == 1 && (int) Magic > 87 && "織田信行 --".equals(generalname) && lv <= 80) {
+                                    rs1 = GuiPacket(ss, "39302", list1);
+                                    Thread.sleep(5000);
+                                } 
+								else if (Upgradecdusable == 1 && (int) Magic > 87 && "井伊直盛 --".equals(generalname) && lv <= 80) {
+                                    rs1 = GuiPacket(ss, "39302", list1);
+                                    Thread.sleep(5000);
+                                } else if (Upgradecdusable == 1 && (int) Magic > 87 && "Y Tịch ".equals(generalname) && lv <= 80) {
+                                    rs1 = GuiPacket(ss, "39302", list1);
+                                    Thread.sleep(5000);
+                                } else if (Upgradecdusable == 1 && (int) Magic > 87 && "Lưu Biểu ".equals(generalname) && lv <= 80) {
+                                    rs1 = 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 GianKhoan() {
+        List<String> list1 = new ArrayList<>();
+        list1.add("3");
+        list1.add("101");
+        List<String> list2 = new ArrayList<>();
+        list2.add("3");
+        list2.add("101");
+        list2.add("0");
+        list2.add("0");
+        // lay phan thuong khoan
+        try {
+            StringBuilder rs = GuiPacket(ss, "62007", list1);
+            Thread.sleep(5000);
+            if (rs != null) {
+                if (!rs.toString().contains("Đang khai thác")) {
+                    Tqtk.sendMessage("gian khoan " + ss.getStringName());
+                    // bat dau khoan
+                    GuiPacket(ss, "62006", list2);
+                }
+            } else {
+
+            }
+
+        } catch (Exception ex) {
+            System.out.println(ex.getMessage());
+        }
+    }
+
+    public void CapNhatThongTin() {
+
+        try {
+            // packet cap nhat thong tin lien tuc tu server
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(ss, "10100", null);
+            // packet cap nhat thong tin lien tuc tu server
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(ss, "11102", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(ss, "52103", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(ss, "10108", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(ss, "20101", null);
+            Thread.sleep(5000);
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            StringBuilder rs1 = GuiPacket(ss, "12200", list1);
+            list1 = null;
+        } catch (Exception ex) {
+            System.out.println(ex.getMessage());
+        }
+    }
+
+    public void dangNhapLayThongTin() throws Exception {
+        Util u = new Util();
+        this.ss = LayThongTinSession.getSessionEntity(ss.getStringName(), ss.getPass(), 22, u);
+        Socket socket = new Socket();
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), ss.getPorts()), 7000);
+        if (ss.getSocket() != null) {
+            ss.getSocket().close();
+        }
+        ss.setSocket(socket);
+    }
+
+    @Override
+    public void run() {
+        try {
+            dangNhapLayThongTin();
+            GuiPacketDeLogin();
+
+            while (true) {
+
+//                MuaLinh();
+//                DanhQuanDoan1();
+//                DanhQuanDoan2();
+//                DanhQuanDoan3();
+                NangItem();
+//                TruyNa();
+                LuyenTuong();
+                NangNha();
+                NangKiNang();
+//                GianKhoan();
+                //FarmDo();
+//                ThuThue();
+//                ChiemRuong();
+//                CapNhatThongTin();
+                Thread.sleep(55 * 1000);
+            }
+        } catch (Exception ex) {
+            System.out.println("all " + ss.getStringName() + ex.getMessage());
+        }
+    }
+
+}

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

@@ -0,0 +1,76 @@
+/*
+ * 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.XuLy;
+
+import java.io.BufferedWriter;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStreamWriter;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.util.List;
+import tqtk.Entity.SessionEntity;
+import tqtk.Utils.Util;
+
+/**
+ *
+ * @author Alex
+ */
+public class XuLyPacket {
+
+    public static void GuiPacketKhongKQ(SessionEntity ss, String code, List<String> list) throws UnknownHostException, IOException, InterruptedException {
+        BufferedWriter wr = null;
+        try {
+            String message = Util.TaoMsg(code, list, ss);
+            Thread.sleep(2 * 1000);
+            wr = new BufferedWriter(new OutputStreamWriter(ss.getSocket().getOutputStream(), "UTF8"));
+            wr.write(message);
+            wr.flush();
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+//            if (e.getMessage().contains("socket write error")) {
+            ss.resetSocket();
+//            }
+        }
+
+    }
+
+    public static StringBuilder GuiPacket(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.getSocket().getOutputStream(), "UTF8"));
+            wr.write(message);
+            wr.flush();
+
+            rp = new StringBuilder("");
+            if (ss.getSocket().isConnected()) {
+                Thread.sleep(3 * 1000);
+                InputStream instr = ss.getSocket().getInputStream();
+                int buffSize = ss.getSocket().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;
+        }
+
+    }
+}

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

@@ -0,0 +1,63 @@
+/*
+ * 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.XuLy.login;
+
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStreamWriter;
+import tqtk.Utils.Util;
+import java.net.CookieManager;
+import java.net.HttpURLConnection;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import tqtk.Entity.SessionEntity;
+import static tqtk.Tqtk.sendMessage;
+
+/**
+ *
+ * @author Alex
+ */
+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
+        u.setCookie(u.msCookieManager);
+//        String html = u.test2("http://api.sengokugifu.jp/home/login/login?Uname=32572016266&userid=32572016266&GameId=2001&ServerId=s17&Time=1673956339&al=1&from=mixi&siteurl=&Sign=1da179d1f5c90a6dfcf76f8a5a15139c");
+        String html = u.test2("http://api.sengokugifu.jp/home/login/login?Uname=32572016266&userid=32572016266&GameId=2001&ServerId=s17&Time=1674435608&al=1&from=mixi&siteurl=&Sign=26e75a5bcb87e01104bef31dbe32d0ce");
+        
+        html = u.test1(html);
+
+        String ip = Util.getInfoSocket(html, "ip");
+        String ports = Util.getInfoSocket(html, "ports");
+        String sessionKey = Util.getInfoSocket(html, "sessionKey");
+        String userID = Util.getInfoSocket(html, "userID");
+        SessionEntity ss = new SessionEntity();
+        ss.setIp(ip);
+        ss.setPorts(Integer.parseInt(ports));
+        ss.setSessionKey(sessionKey);
+        ss.setUserId(userID);
+        ss.setStringName(user);
+        u.setCookie(null);
+        return ss;
+    }
+
+    public static List<SessionEntity> getListSession() {
+        return ListSession;
+    }
+
+}

src/main/java/tqtk/exception/JsonException.java

@@ -0,0 +1,14 @@
+/*
+ * 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.exception;
+
+/**
+ *
+ * @author Alex
+ */
+public class JsonException extends Exception{
+    
+}