linh thu

Signed-off-by: htr <[email protected]>

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

@@ -136,7 +136,7 @@ public class DemoApplication {
         return "ok";
     }
 
-    @RequestMapping(value = "/updateInfo", method = RequestMethod.POST)
+    @RequestMapping(value = "/updateInfo", method = RequestMethod.GET)
     @ResponseBody
     public String updateInfo(
             @RequestParam(value = "id", required = true) String id) throws IOException, UnknownHostException, InterruptedException, Exception {
@@ -209,19 +209,6 @@ public class DemoApplication {
         return "not-ok";
     }
 
-    @GetMapping("createSocketapi")
-    public String createSocketApi(@RequestParam(value = "id", required = true) String id) throws Exception {
-        String output = "";
-        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));
-                return "ok";
-            }
-        }
-        return "not-ok";
-    }
-
     @GetMapping("setSessionId")
     public String setSessionId(@RequestParam(value = "id", required = true) String id,
             @RequestParam(value = "session", required = true) String session) throws Exception {

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

@@ -12,6 +12,7 @@ import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.util.List;
 import java.util.ArrayList;
+
 /**
  *
  * @author Alex
@@ -27,19 +28,37 @@ public class SessionEntity {
     @JsonProperty("UserId")
     String UserId;
     @JsonProperty("ItemIds")
-    List<String> ItemIds= new ArrayList();
+    List<String> ItemIds = new ArrayList();
     @JsonProperty("HeroIds")
-    List<String> HeroIds= new ArrayList();
+    List<String> HeroIds = new ArrayList();
     @JsonProperty("BuildingIds")
-    List<String> BuildingIds= new ArrayList();
+    List<String> BuildingIds = new ArrayList();
     @JsonProperty("SkillIds")
     List<String> SkillIds = new ArrayList();
+    @JsonProperty("LinhThuKoHa")
+    List<String> LinhThuKoHa = new ArrayList();
 
     private Socket socket;
     private boolean isConnected;
     private String stringName;
     private Socket socketApi;
-    private Socket socketTN;
+    private Socket socketNuoiLinhThu;
+
+    public Socket getSocketNuoiLinhThu() {
+        return socketNuoiLinhThu;
+    }
+
+    public void setSocketNuoiLinhThu(Socket socketNuoiLinhThu) {
+        this.socketNuoiLinhThu = socketNuoiLinhThu;
+    }
+
+    public List<String> getLinhThuKoHa() {
+        return LinhThuKoHa;
+    }
+
+    public void setLinhThuKoHa(List<String> LinhThuKoHa) {
+        this.LinhThuKoHa = LinhThuKoHa;
+    }
 
     public String getIp() {
         return Ip;
@@ -81,8 +100,6 @@ public class SessionEntity {
         this.ItemIds = ItemIds;
     }
 
-  
-
     public List<String> getHeroIds() {
         return HeroIds;
     }
@@ -107,15 +124,6 @@ public class SessionEntity {
         this.SkillIds = SkillIds;
     }
 
-    
-    
-    public Socket getSocketTN() {
-        return socketTN;
-    }
-
-    public void setSocketTN(Socket socketTN) {
-        this.socketTN = socketTN;
-    }
 
     public Socket getSocketApi() {
         return socketApi;
@@ -133,7 +141,6 @@ public class SessionEntity {
         this.stringName = stringName;
     }
 
-
     public SessionEntity() {
     }
 
@@ -143,7 +150,6 @@ public class SessionEntity {
         this.socket.connect(new InetSocketAddress(InetAddress.getByName(Ip), Integer.parseInt(Port)), 7000);
     }
 
-
     public boolean isIsConnected() {
         return isConnected;
     }

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

@@ -496,7 +496,7 @@ public class Util {
         //window
 //        String x = "D:\\7-Project\\Java\\1. Netbean\\2. nghien-cuu\\TQTK\\runshell\\cauhoi\\"+file_name;
         //heroku
-        String x = "/" + file_name;
+        String x = file_name;
         try {
             return Doc_file_kieu_txt.readFile(x);
         } catch (Exception e) {

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

@@ -1,3 +1,4 @@
+
 package tqtk.XuLy;
 
 import com.fasterxml.jackson.core.type.TypeReference;
@@ -25,10 +26,13 @@ import tqtk.XuLy.login.LayThongTinSession;
 import static tqtk.XuLy.XuLyPacket.GuiPacket;
 import static tqtk.XuLy.XuLyPacket.GuiPacketTN;
 import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQ;
+import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQLinhThu;
+import static tqtk.XuLy.XuLyPacket.GuiPacketLinhThu;
 import tqtk.exception.JsonException;
 import java.io.*;
 import java.util.*;
 import java.util.Collections;
+
 /**
  *
  * @author Alex
@@ -90,6 +94,27 @@ public class Worker extends Thread {
 
     }
 
+    public void GuiPacketDeLogin2(SessionEntity ss) 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);
+        // packet cap nhat thong tin lien tuc tu server
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "11102", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "52103", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "10108", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "20101", null);
+        Thread.sleep(5000);
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "1");
+        StringBuilder rs1 = GuiPacketLinhThu(ss, "12200", list1);
+        list1 = null;
+
+    }
+
     public void LuyenTuong() {
         List<String> list1 = new ArrayList<>();
         list1.add(0, "0");
@@ -683,6 +708,10 @@ public class Worker extends Thread {
         List<String> list1 = new ArrayList<>();
         list1.add(0, "17");
         list1.add(1, "1");
+		
+		List<String> list2 = new ArrayList<>();
+        list2.add(0, "1");
+		
         try {
 
             Tqtk.sendMessage("nhan thuong " + ss.getUserId());
@@ -725,10 +754,14 @@ public class Worker extends Thread {
             // ki ten
             Thread.sleep(2000);
             GuiPacket(ss, "60701", null);
-            Thread.sleep(5000);
+            Thread.sleep(2000);
             GuiPacket(ss, "60702", null);
-            Thread.sleep(5000);
+            Thread.sleep(2000);
             GuiPacket(ss, "60703", null);
+			
+			// quay so
+			Thread.sleep(2000);
+            GuiPacket(ss, "64002", list2);
 
         } catch (Exception e) {
             System.out.println("NhanThuong " + ss.getUserId() + e.getMessage());
@@ -811,6 +844,58 @@ public class Worker extends Thread {
 
     }
 
+    public boolean CheckThuThue() {
+        // danh quan doan vu van thi toc
+
+        try {
+            StringBuilder rs1 = GuiPacket(ss, "12400", 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("12400")) {
+                            break;
+                        }
+                    }
+					if(carMap == null){
+						return false;
+					}
+                    Map<String, Object> carMap1 = (Map<String, Object>) ((Map<String, Object>) carMap.get("m")).get("imposedto");
+
+                    
+
+                    if (carMap1 != null) {
+                        Integer imposenum = (Integer) carMap1.get("imposenum");
+					    if(imposenum>38){
+							return true;
+						}
+						return false;
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+
+            }
+			return false;
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("loi qd " + ss.getUserId() + ex.getMessage());
+            } else {
+                System.out.println("loi qd json" + ss.getUserId() + ex.getMessage());
+            }
+			return false;
+        }
+    }
+
+
     public void ThuThue() {
         // danh quan doan vu van thi toc
         List<String> list1 = new ArrayList<>();
@@ -820,7 +905,8 @@ public class Worker extends Thread {
         list2.add(0, "0");
 
         try {
-            StringBuilder rs1 = GuiPacket(ss, "12401", list1);
+			if(CheckThuThue()){
+			StringBuilder rs1 = GuiPacket(ss, "12401", list1);
             Thread.sleep(5000);
             if (rs1 != null) {
                 try {
@@ -846,7 +932,7 @@ public class Worker extends Thread {
                         String optdisc1 = (String) carMap1.get("optdisc1");
                         String optdisc2 = (String) carMap1.get("optdisc2");
 
-                        List<String> cauhoi = Util.docFileCauHoiThuThue("thu_thue_dan_tam.txt");
+                        List<String> cauhoi = Util.docFileCauHoiThuThue("user.properties");
 
                         for (String item : cauhoi) {
                             if (optdisc1.contains(item)) {
@@ -873,6 +959,10 @@ public class Worker extends Thread {
                 }
 
             }
+				
+				
+			}
+
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("loi qd " + ss.getUserId() + ex.getMessage());
@@ -1121,14 +1211,12 @@ public class Worker extends Thread {
                     throw new JsonException();
                 }
             } else {
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+               
             }
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("NangItem " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+              
             } else {
                 System.out.println("NangItem json " + ss.getUserId() + ex.getMessage());
             }
@@ -1212,14 +1300,12 @@ public class Worker extends Thread {
                     throw new JsonException();
                 }
             } else {
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+              
             }
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("NangItem " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+              
             } else {
                 System.out.println("NangItem json " + ss.getUserId() + ex.getMessage());
             }
@@ -1259,9 +1345,9 @@ public class Worker extends Thread {
                             mer.add(merchantid);
                         }
                     }
-					System.out.println("UyPhai " + ss.getUserId() + " "+ mer.get(mer.size() - 1).toString());
+                    System.out.println("UyPhai " + ss.getUserId() + " " + mer.get(mer.size() - 1).toString());
                     Collections.sort(mer);
-                    list1.set(0,  mer.get(mer.size() - 1).toString());
+                    list1.set(0, mer.get(mer.size() - 1).toString());
                     GuiPacket(ss, "40102", list1);
                     Thread.sleep(4000);
                     GuiPacket(ss, "40103", null);
@@ -1272,8 +1358,7 @@ public class Worker extends Thread {
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("UyPhai " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+               
             } else {
                 System.out.println("UyPhai json " + ss.getUserId() + ex.getMessage());
             }
@@ -1296,14 +1381,14 @@ public class Worker extends Thread {
             StringBuilder rs = GuiPacket(ss, "62007", list1);
             Thread.sleep(5000);
             if (rs != null) {
-                if (!rs.toString().contains("掘削中です")) {
-                    Tqtk.sendMessage("gian khoan " + ss.getUserId());
+				Tqtk.sendMessage("gian khoan " + ss.getUserId());
                     // bat dau khoan
-                    GuiPacket(ss, "62006", list2);
+                GuiPacket(ss, "62006", list2);
+				
+                if (!rs.toString().contains("掘削中です")) {
+                   
                 }
-            } else {
-
-            }
+            } 
 
         } catch (Exception ex) {
             System.out.println(ex.getMessage());
@@ -1330,28 +1415,37 @@ public class Worker extends Thread {
         ss.setSocket(socket);
     }
 
+    public void dangNhapLayThongTin2(SessionEntity ss) throws Exception {
+        Socket socket = new Socket();
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
+        if (ss.getSocketNuoiLinhThu() != null) {
+            ss.getSocketNuoiLinhThu().close();
+        }
+        ss.setSocketNuoiLinhThu(socket);
+    }
+
     public void taoSocketTruyNa() throws Exception {
         Socket socket = new Socket();
         socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
-        if (ss.getSocketTN() != null) {
-            ss.getSocketTN().close();
+        if (ss.getSocket() != null) {
+            ss.getSocket().close();
         }
-        ss.setSocketTN(socket);
+        ss.setSocket(socket);
     }
 
     public void CapNhatThongTin() throws IOException, UnknownHostException, InterruptedException, Exception {
         try {
             Thread.sleep(5000);
             String rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
-   
-			tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
-			
-			List<String> list1 = new ArrayList<>();
-			list1.add(0, "1");
-			GuiPacket(ss, "12200", list1);
-			list1 = null;
-			
-			rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
+
+            tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
+
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            GuiPacket(ss, "12200", list1);
+            list1 = null;
+
+            rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
             if (rs1 != null && rs1 != "") {
                 try {
                     String[] temp = rs1.toString().split("");
@@ -1378,13 +1472,11 @@ public class Worker extends Thread {
                     throw new JsonException();
                 }
             }
-			
-			
+
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+               
             } else {
                 System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
             }
@@ -1392,21 +1484,69 @@ public class Worker extends Thread {
         }
 
     }
-	
-	
-	public static void StaticCapNhatThongTin(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
+
+    public void CapNhatThongTin2() throws IOException, UnknownHostException, InterruptedException, Exception {
+        try {
+            Thread.sleep(5000);
+            GuiPacketKhongKQLinhThu(ss, "11102", null);
+
+            GuiPacketKhongKQLinhThu(ss, "12400", null);
+
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            GuiPacketKhongKQLinhThu(ss, "12200", list1);
+            list1 = null;
+
+            GuiPacketKhongKQLinhThu(ss, "11102", null);
+
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            } else {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    public static void StaticCapNhatThongTin(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
         try {
             Thread.sleep(5000);
             String rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
-   
-			tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
-			
-			List<String> list1 = new ArrayList<>();
-			list1.add(0, "1");
-			GuiPacket(ss, "12200", list1);
-			list1 = null;
-			
-			rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
+
+            tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
+
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            GuiPacket(ss, "12200", list1);
+            list1 = null;
+
+            rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            } else {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            }
+
+        }
+
+    }
+	
+	 public static void StaticCapNhatThongTinLinhThu(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
+        try {
+            Thread.sleep(5000);
+            GuiPacketLinhThu(ss, "11102", null);
+
+            GuiPacketLinhThu(ss, "12400", null);
+
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            GuiPacketLinhThu(ss, "12200", list1);
+            list1 = null;
+
+            GuiPacketLinhThu(ss, "11102", null);
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
@@ -1483,8 +1623,7 @@ public class Worker extends Thread {
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("cho den " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+            
             } else {
                 System.out.println("cho den json " + ss.getUserId() + ex.getMessage());
             }
@@ -1493,6 +1632,7 @@ public class Worker extends Thread {
 
     }
 
+   
     public void MuaRuong() throws IOException, UnknownHostException, InterruptedException, Exception {
         List<String> list1 = new ArrayList<>();
         list1.add(0, "3");
@@ -1555,8 +1695,7 @@ public class Worker extends Thread {
         } catch (Exception ex) {
             if (!(ex instanceof JsonException)) {
                 System.out.println("cho den " + ss.getUserId() + ex.getMessage());
-                dangNhapLayThongTin();
-                GuiPacketDeLogin();
+               
             } else {
                 System.out.println("cho den json " + ss.getUserId() + ex.getMessage());
             }
@@ -1564,6 +1703,90 @@ public class Worker extends Thread {
         }
 
     }
+	
+	
+	public void NangHaLinhThu(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        list1.add(2, "40");
+
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+        list2.add(1, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacket(ss, "49101", 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("49101")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("formationguardequipdto");
+
+                    if (carMap1 == null) {
+                        return;
+                    }
+                    System.out.println("setup linh thu");
+                    Object Magic = (Object) ((Map<String, Object>) carMap.get("m")).get("magic");
+                    String[] tmp = Magic.toString().split(",");
+                    String sMagic = "";
+
+                    int lv = 0;
+                    int lvmagic = 0;
+                    Integer storeid = 0;
+
+                    for (Object object : carMap1) {
+                        storeid = (Integer) ((Map<Object, Object>) object).get("storeid");
+                        lvmagic = (Integer) ((Map<Object, Object>) object).get("equiplevel");
+                        sMagic = tmp[lvmagic - 1];
+                        lvmagic = Integer.parseInt(sMagic);
+                        if (lvmagic > 75) {
+                            list1.set(0, Integer.toString(storeid));
+                            list1.set(2, sMagic);
+                            list2.set(0, Integer.toString(storeid));
+                            if (storeid != null && ss != null) {
+                                System.out.println("nang linh thu " + ss.getUserId());
+                                // nang
+                                GuiPacket(ss, "49105", list1);
+                                Thread.sleep(5000);
+                                // ha
+                                if (ss.getLinhThuKoHa().contains(storeid.toString())) {
+                                    break;
+                                }
+                                GuiPacket(ss, "49106", list2);
+                                Thread.sleep(5000);
+
+                            }
+                        }
+
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("NangItem " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("NangItem json " + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+
+    }
+	
 
     public static void createSocket(SessionEntity session) throws Exception {
         Socket socket = new Socket();
@@ -1574,24 +1797,56 @@ public class Worker extends Thread {
         } catch (Exception e) {
         }
         session.setSocket(socket);
+
+        try {
+            GuiPacketKhongKQ(session, "10100", null);
+            // packet cap nhat thong tin lien tuc tu server
+            Thread.sleep(5000);
+            StaticCapNhatThongTin(session);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(session, "52103", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(session, "10108", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQ(session, "20101", null);
+            Thread.sleep(5000);
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            StringBuilder rs1 = GuiPacket(session, "12200", list1);
+            list1 = null;
+        } catch (Exception e) {
+        }
 		
-		
-		 try {
-             GuiPacketKhongKQ(session, "10100", null);
-        // packet cap nhat thong tin lien tuc tu server
-        Thread.sleep(5000);
-        StaticCapNhatThongTin(session);
-        Thread.sleep(5000);
-        GuiPacketKhongKQ(session, "52103", null);
-        Thread.sleep(5000);
-        GuiPacketKhongKQ(session, "10108", null);
-        Thread.sleep(5000);
-        GuiPacketKhongKQ(session, "20101", null);
-        Thread.sleep(5000);
-        List<String> list1 = new ArrayList<>();
-        list1.add(0, "1");
-        StringBuilder rs1 = GuiPacket(session, "12200", list1);
-        list1 = null;
+
+    }
+	
+	
+	public static void createSocketLinhThu(SessionEntity session) throws Exception {
+        Socket socket = new Socket();
+        socket.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), Integer.parseInt(session.getPort())), 7000);
+        socket.setSoTimeout(350000);
+        try {
+            session.getSocketNuoiLinhThu().close();
+        } catch (Exception e) {
+        }
+        session.setSocketNuoiLinhThu(socket);
+
+        try {
+            
+            // packet cap nhat thong tin lien tuc tu server
+            Thread.sleep(5000);
+            StaticCapNhatThongTinLinhThu(session);
+            Thread.sleep(5000);
+            GuiPacketKhongKQLinhThu(session, "52103", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQLinhThu(session, "10108", null);
+            Thread.sleep(5000);
+            GuiPacketKhongKQLinhThu(session, "20101", null);
+            Thread.sleep(5000);
+            List<String> list1 = new ArrayList<>();
+            list1.add(0, "1");
+            StringBuilder rs1 = GuiPacketLinhThu(session, "12200", list1);
+            list1 = null;
         } catch (Exception e) {
         }
 
@@ -1624,15 +1879,15 @@ public class Worker extends Thread {
         try {
             dangNhapLayThongTin();
             GuiPacketDeLogin();
+
             while (true) {
                 try {
                     //if (!ss.getUserId().equals("2301230011011923")) {
                     //    TruyNa2();
                     //}
-             
 
                     MuaLinh();
-
+					NangHaLinhThu(ss);
                     NangItem();
                     LuyenTuong();
                     NangNha();
@@ -1640,7 +1895,7 @@ public class Worker extends Thread {
                     NhanThuong();
                     GianKhoan();
 //                FarmDoLv60();
-//                ThuThue();
+					ThuThue();
 
                     ChiemMo();
                     ChiemRuong();

src/main/java/tqtk/XuLy/WorkerLinhThu.java

@@ -0,0 +1,229 @@
+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.TruyNa;
+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.GuiPacketTN;
+import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQ;
+import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQLinhThu;
+import static tqtk.XuLy.XuLyPacket.GuiPacketLinhThu;
+import tqtk.exception.JsonException;
+import java.io.*;
+import java.util.*;
+import java.util.Collections;
+
+/**
+ *
+ * @author Alex
+ */
+public class WorkerLinhThu extends Thread {
+
+    SessionEntity ss;
+
+    public SessionEntity getSs() {
+        return ss;
+    }
+
+    public void setSs(SessionEntity ss) {
+        this.ss = ss;
+    }
+
+    public WorkerLinhThu(SessionEntity ss) {
+
+        this.ss = ss;
+    }
+
+    public void GuiPacketDeLogin2(SessionEntity ss) 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);
+        // packet cap nhat thong tin lien tuc tu server
+        Thread.sleep(5000);
+        CapNhatThongTin2();
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "52103", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "10108", null);
+        Thread.sleep(5000);
+        GuiPacketKhongKQLinhThu(ss, "20101", null);
+        Thread.sleep(5000);
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "1");
+        StringBuilder rs1 = GuiPacketLinhThu(ss, "12200", list1);
+        list1 = null;
+
+    }
+
+    public void dangNhapLayThongTin2(SessionEntity ss) throws Exception {
+        Socket socket = new Socket();
+        socket.setSoTimeout(9999999);
+        socket.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
+        if (ss.getSocketNuoiLinhThu() != null) {
+            ss.getSocketNuoiLinhThu().close();
+        }
+        ss.setSocketNuoiLinhThu(socket);
+    }
+
+    public void CapNhatThongTin2() throws IOException, UnknownHostException, InterruptedException, Exception {
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacketLinhThu(ss, "11102", null);
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            } else {
+                System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    public void ChoDen() throws IOException, UnknownHostException, InterruptedException, Exception {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        list1.add(2, "0");
+        list1.add(3, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacketLinhThu(ss, "48116", list1);
+
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("cho den " + ss.getStringName() + ex.getMessage());
+
+            } else {
+                System.out.println("cho den json " + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    public void NangHaLinhThu(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
+        List<String> list1 = new ArrayList<>();
+        list1.add(0, "0");
+        list1.add(1, "0");
+        list1.add(2, "40");
+
+        List<String> list2 = new ArrayList<>();
+        list2.add(0, "0");
+        list2.add(1, "0");
+        try {
+            Thread.sleep(5000);
+            StringBuilder rs1 = GuiPacketLinhThu(ss, "49101", 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("49101")) {
+                            break;
+                        }
+                    }
+
+                    List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("formationguardequipdto");
+
+                    if (carMap1 == null) {
+                        return;
+                    }
+                    System.out.println("setup linh thu");
+                    Object Magic = (Object) ((Map<String, Object>) carMap.get("m")).get("magic");
+                    String[] tmp = Magic.toString().split(",");
+                    String sMagic = "";
+
+                    int lv = 0;
+                    int lvmagic = 0;
+                    Integer storeid = 0;
+
+                    for (Object object : carMap1) {
+                        storeid = (Integer) ((Map<Object, Object>) object).get("storeid");
+                        lvmagic = (Integer) ((Map<Object, Object>) object).get("equiplevel");
+                        sMagic = tmp[lvmagic - 1];
+                        lvmagic = Integer.parseInt(sMagic);
+                        if (lvmagic > 75) {
+                            list1.set(0, Integer.toString(storeid));
+                            list1.set(2, sMagic);
+                            list2.set(0, Integer.toString(storeid));
+                            if (storeid != null && ss != null) {
+                                System.out.println("nang linh thu " + ss.getUserId());
+                                // nang
+                                GuiPacketLinhThu(ss, "49105", list1);
+                                Thread.sleep(10000);
+                                // ha
+                                if (ss.getLinhThuKoHa().contains(storeid.toString())) {
+                                    break;
+                                }
+                                GuiPacketLinhThu(ss, "49106", list2);
+                                Thread.sleep(10000);
+
+                            }
+                        }
+
+                    }
+                } catch (Exception e) {
+                    throw new JsonException();
+                }
+            }
+        } catch (Exception ex) {
+            if (!(ex instanceof JsonException)) {
+                System.out.println("NangItem " + ss.getStringName() + ex.getMessage());
+            } else {
+                System.out.println("NangItem json " + ss.getStringName() + ex.getMessage());
+            }
+
+        }
+
+    }
+
+    @Override
+    public void run() {
+        try {
+            dangNhapLayThongTin2(ss);
+            GuiPacketDeLogin2(ss);
+            while (true) {
+                try {
+                    ChoDen();
+                    Thread.sleep(10000);
+                    NangHaLinhThu(ss);
+                    Thread.sleep(10000);
+                    CapNhatThongTin2();
+					Thread.sleep(10000);
+
+                } catch (Exception ex) {
+                    System.out.println("all lthu " + ss.getUserId() + ex.getMessage());
+                }
+            }
+        } catch (Exception ex) {
+            System.out.println("all lthu " + ss.getUserId() + ex.getMessage());
+        }
+    }
+
+}

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

@@ -36,9 +36,30 @@ public class XuLyPacket {
             wr.write(message);
             wr.flush();
         } catch (Exception e) {
-            System.out.println(e.getMessage());
+            System.out.println("GuiPacketKhongKQ "+e.getMessage());
 //            if (e.getMessage().contains("socket write error")) {
-            ss.resetSocket();
+			try {
+            //tqtk.XuLy.Worker.createSocket(ss);
+			} catch (Exception e1) {}
+//            }
+        }
+
+    }
+    
+    public static void GuiPacketKhongKQLinhThu(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.getSocketNuoiLinhThu().getOutputStream(), "UTF8"));
+            wr.write(message);
+            wr.flush();
+        } catch (Exception e) {
+            System.out.println("GuiPacketKhongKQLinhThu "+e.getMessage());
+//            if (e.getMessage().contains("socket write error")) {
+            try {
+            //tqtk.XuLy.Worker.createSocket(ss);
+			} catch (Exception e1) {}
 //            }
         }
 
@@ -70,14 +91,51 @@ public class XuLyPacket {
             }
             return rp;
         } catch (Exception e) {
-            System.out.println(e.getMessage());
-			
+            try {
+            //tqtk.XuLy.Worker.createSocket(ss);
+			} catch (Exception e1) {}
+            return null;
+        }
+
+    }
+
+    public static StringBuilder GuiPacketLinhThu(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.getSocketNuoiLinhThu().getOutputStream(), "UTF8"));
+            wr.write(message);
+            wr.flush();
+
+            rp = new StringBuilder("");
+            if (ss.getSocketNuoiLinhThu().isConnected()) {
+                Thread.sleep(3 * 1000);
+                InputStream instr = ss.getSocketNuoiLinhThu().getInputStream();
+                int buffSize = ss.getSocketNuoiLinhThu().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("GuiPacketLinhThu "+e.getMessage());
+		 try {
+            //tqtk.XuLy.Worker.createSocket(ss);
+			} catch (Exception e1) {}
 			
             return null;
         }
 
     }
 
+    
     public static String GuiPacketHTTP(SessionEntity ss, String message) throws UnknownHostException, IOException, InterruptedException {
         BufferedWriter wr = null;
         StringBuilder rp = null;
@@ -289,14 +347,14 @@ public class XuLyPacket {
         try {
             message = Util.TaoMsg(code, list, ss);
             Thread.sleep(3 * 1000);
-            wr = new BufferedWriter(new OutputStreamWriter(ss.getSocketTN().getOutputStream(), "UTF8"));
+            wr = new BufferedWriter(new OutputStreamWriter(ss.getSocket().getOutputStream(), "UTF8"));
             wr.write(message);
             wr.flush();
 
-            if (ss.getSocketTN().isConnected()) {
+            if (ss.getSocket().isConnected()) {
                 Thread.sleep(3 * 1000);
-                InputStream instr = ss.getSocketTN().getInputStream();
-                int buffSize = ss.getSocketTN().getReceiveBufferSize();
+                InputStream instr = ss.getSocket().getInputStream();
+                int buffSize = ss.getSocket().getReceiveBufferSize();
                 if (buffSize > 0) {
                     byte[] buff = new byte[buffSize];
                     int ret_read = instr.read(buff);

src/main/resources/application.properties

@@ -4,7 +4,7 @@ spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.PostgreSQLDialec
 spring.jpa.hibernate.ddl-auto=update
 spring.jpa.hibernate.show-sql=true
 
-spring.datasource.url=jdbc:postgresql://dpg-cf82kq6n6mplr40r4p5g-a.singapore-postgres.render.com:5432/pgtest_1y8z
-spring.datasource.username=pgtest_1y8z_user
-spring.datasource.password=L97pbnHfex5lEg0qOuPUwwiZnvR8qdHA
-spring.datasource.driver-class-name=org.postgresql.Driver
+spring.datasource.url=jdbc:postgresql://dpg-ch4givpn852hpi3144tg-a.singapore-postgres.render.com:5432/test_3ff6
+spring.datasource.username=test_3ff6_user
+spring.datasource.password=QwKqYo57zAPII3h1TFHBOIbxonGPJuIo
+spring.datasource.driver-class-name=org.postgresql.Driver