htr commited on
Commit
b9a58b3
·
1 Parent(s): 719b709
Files changed (2) hide show
  1. src/main/java/tqtk/XuLy/Worker.java +136 -30
  2. user.properties +60 -58
src/main/java/tqtk/XuLy/Worker.java CHANGED
@@ -1,4 +1,5 @@
1
  package tqtk.XuLy;
 
2
  import com.fasterxml.jackson.core.type.TypeReference;
3
  import com.fasterxml.jackson.databind.ObjectMapper;
4
  import java.io.IOException;
@@ -27,7 +28,7 @@ import static tqtk.XuLy.XuLyPacket.GuiPacketKhongKQ;
27
  import tqtk.exception.JsonException;
28
  import java.io.*;
29
  import java.util.*;
30
-
31
  /**
32
  *
33
  * @author Alex
@@ -35,7 +36,7 @@ import java.util.*;
35
  public class Worker extends Thread {
36
 
37
  public boolean isfinish = false;
38
- public boolean isStop = false;
39
  public Object lock;
40
  SessionEntity ss;
41
 
@@ -701,7 +702,6 @@ public class Worker extends Thread {
701
  // event mo ruong
702
  //Thread.sleep(5000);
703
  //GuiPacket(ss, "48113", list1);
704
-
705
  // nhiem vu thuong ngay
706
  Thread.sleep(5000);
707
 
@@ -723,12 +723,12 @@ public class Worker extends Thread {
723
  Thread.sleep(2000);
724
  GuiPacket(ss, "49007", list1);
725
  // ki ten
726
- //Thread.sleep(2000);
727
- //GuiPacket(ss, "60701", null);
728
- //Thread.sleep(5000);
729
- //GuiPacket(ss, "60702", null);
730
- //Thread.sleep(5000);
731
- //GuiPacket(ss, "60703", null);
732
 
733
  } catch (Exception e) {
734
  System.out.println("NhanThuong " + ss.getUserId() + e.getMessage());
@@ -1075,10 +1075,10 @@ public class Worker extends Thread {
1075
  }
1076
 
1077
  public void NangItem() throws IOException, UnknownHostException, InterruptedException, Exception {
1078
- if(ss.getItemIds().size()== 0){
1079
- return;
1080
- }
1081
-
1082
  List<String> list1 = new ArrayList<>();
1083
  list1.add(0, "0");
1084
  list1.add(1, "0");
@@ -1109,7 +1109,7 @@ public class Worker extends Thread {
1109
 
1110
  list1.set(0, object);
1111
  list1.set(2, Magic.toString());
1112
- if (Upgradecdusable == 1 && (int) Magic >= 89) {
1113
  GuiPacket(ss, "39302", list1);
1114
  Thread.sleep(5000);
1115
  GuiPacket(ss, "39302", list1);
@@ -1228,6 +1228,60 @@ public class Worker extends Thread {
1228
 
1229
  }
1230
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1231
  public void GianKhoan() {
1232
  List<String> list1 = new ArrayList<>();
1233
  list1.add("3");
@@ -1274,13 +1328,6 @@ public class Worker extends Thread {
1274
  ss.getSocket().close();
1275
  }
1276
  ss.setSocket(socket);
1277
-
1278
- Socket socket1 = new Socket();
1279
- socket1.connect(new InetSocketAddress(InetAddress.getByName(ss.getIp()), Integer.parseInt(ss.getPort())), 7000);
1280
- if (ss.getSocketApi() != null) {
1281
- ss.getSocketApi().close();
1282
- }
1283
- ss.setSocketApi(socket1);
1284
  }
1285
 
1286
  public void taoSocketTruyNa() throws Exception {
@@ -1296,6 +1343,15 @@ public class Worker extends Thread {
1296
  try {
1297
  Thread.sleep(5000);
1298
  String rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
 
 
 
 
 
 
 
 
 
1299
  if (rs1 != null && rs1 != "") {
1300
  try {
1301
  String[] temp = rs1.toString().split("");
@@ -1322,6 +1378,8 @@ public class Worker extends Thread {
1322
  throw new JsonException();
1323
  }
1324
  }
 
 
1325
  } catch (Exception ex) {
1326
  if (!(ex instanceof JsonException)) {
1327
  System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
@@ -1333,6 +1391,31 @@ public class Worker extends Thread {
1333
 
1334
  }
1335
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1336
  }
1337
 
1338
  public void ChoDen() throws IOException, UnknownHostException, InterruptedException, Exception {
@@ -1491,9 +1574,30 @@ public class Worker extends Thread {
1491
  } catch (Exception e) {
1492
  }
1493
  session.setSocket(socket);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1494
  }
1495
-
1496
- public void createSocket1(SessionEntity session) throws Exception {
1497
  Socket socket = new Socket();
1498
  socket.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), Integer.parseInt(session.getPort())), 7000);
1499
  socket.setSoTimeout(350000);
@@ -1525,6 +1629,8 @@ public class Worker extends Thread {
1525
  //if (!ss.getUserId().equals("2301230011011923")) {
1526
  // TruyNa2();
1527
  //}
 
 
1528
  MuaLinh();
1529
 
1530
  NangItem();
@@ -1532,7 +1638,7 @@ public class Worker extends Thread {
1532
  NangNha();
1533
  NangKiNang();
1534
  NhanThuong();
1535
- GianKhoan();
1536
  // FarmDoLv60();
1537
  // ThuThue();
1538
 
@@ -1540,18 +1646,18 @@ public class Worker extends Thread {
1540
  ChiemRuong();
1541
  MuaRuong();
1542
  CapNhatThongTin();
1543
-
1544
- synchronized (this.lock) {
1545
- if(this.isStop)
1546
- lock.wait();
 
1547
  }
1548
-
1549
  //synchronized (lock) {
1550
  // isfinish = true;
1551
  // lock.wait();
1552
  //}
1553
  //isfinish = false;
1554
-
1555
  } catch (Exception ex) {
1556
  System.out.println("all " + ss.getUserId() + ex.getMessage());
1557
  }
 
1
  package tqtk.XuLy;
2
+
3
  import com.fasterxml.jackson.core.type.TypeReference;
4
  import com.fasterxml.jackson.databind.ObjectMapper;
5
  import java.io.IOException;
 
28
  import tqtk.exception.JsonException;
29
  import java.io.*;
30
  import java.util.*;
31
+ import java.util.Collections;
32
  /**
33
  *
34
  * @author Alex
 
36
  public class Worker extends Thread {
37
 
38
  public boolean isfinish = false;
39
+ public boolean isStop = false;
40
  public Object lock;
41
  SessionEntity ss;
42
 
 
702
  // event mo ruong
703
  //Thread.sleep(5000);
704
  //GuiPacket(ss, "48113", list1);
 
705
  // nhiem vu thuong ngay
706
  Thread.sleep(5000);
707
 
 
723
  Thread.sleep(2000);
724
  GuiPacket(ss, "49007", list1);
725
  // ki ten
726
+ Thread.sleep(2000);
727
+ GuiPacket(ss, "60701", null);
728
+ Thread.sleep(5000);
729
+ GuiPacket(ss, "60702", null);
730
+ Thread.sleep(5000);
731
+ GuiPacket(ss, "60703", null);
732
 
733
  } catch (Exception e) {
734
  System.out.println("NhanThuong " + ss.getUserId() + e.getMessage());
 
1075
  }
1076
 
1077
  public void NangItem() throws IOException, UnknownHostException, InterruptedException, Exception {
1078
+ if (ss.getItemIds().size() == 0) {
1079
+ return;
1080
+ }
1081
+
1082
  List<String> list1 = new ArrayList<>();
1083
  list1.add(0, "0");
1084
  list1.add(1, "0");
 
1109
 
1110
  list1.set(0, object);
1111
  list1.set(2, Magic.toString());
1112
+ if (Upgradecdusable == 1 && (int) Magic >= 95) {
1113
  GuiPacket(ss, "39302", list1);
1114
  Thread.sleep(5000);
1115
  GuiPacket(ss, "39302", list1);
 
1228
 
1229
  }
1230
 
1231
+ public void UyPhai() throws IOException, UnknownHostException, InterruptedException, Exception {
1232
+ List<String> list1 = new ArrayList<>();
1233
+ list1.add(0, "0");
1234
+ list1.add(1, "0");
1235
+ try {
1236
+ Thread.sleep(5000);
1237
+ StringBuilder rs1 = GuiPacket(ss, "40101", null);
1238
+ if (rs1 != null && rs1.toString() != "") {
1239
+ try {
1240
+ String[] temp = rs1.toString().split("");
1241
+
1242
+ ObjectMapper mapper = new ObjectMapper();
1243
+ Map<String, Object> carMap = null;
1244
+ int h = 0;
1245
+ for (String string : temp) {
1246
+ carMap = mapper.readValue(string, new TypeReference<Map<String, Object>>() {
1247
+ });
1248
+ h = (int) carMap.get("h");
1249
+ if (h == Integer.parseInt("40101")) {
1250
+ break;
1251
+ }
1252
+ }
1253
+ List<Object> carMap1 = (List<Object>) ((Map<String, Object>) carMap.get("m")).get("merchant");
1254
+ int merchantid = 1;
1255
+ List mer = new ArrayList();
1256
+ for (Object object : carMap1) {
1257
+ merchantid = (int) ((Map<Object, Object>) object).get("merchantid");
1258
+ if (merchantid < 6) {
1259
+ mer.add(merchantid);
1260
+ }
1261
+ }
1262
+ System.out.println("UyPhai " + ss.getUserId() + " "+ mer.get(mer.size() - 1).toString());
1263
+ Collections.sort(mer);
1264
+ list1.set(0, mer.get(mer.size() - 1).toString());
1265
+ GuiPacket(ss, "40102", list1);
1266
+ Thread.sleep(4000);
1267
+ GuiPacket(ss, "40103", null);
1268
+ } catch (Exception e) {
1269
+ throw new JsonException();
1270
+ }
1271
+ }
1272
+ } catch (Exception ex) {
1273
+ if (!(ex instanceof JsonException)) {
1274
+ System.out.println("UyPhai " + ss.getUserId() + ex.getMessage());
1275
+ dangNhapLayThongTin();
1276
+ GuiPacketDeLogin();
1277
+ } else {
1278
+ System.out.println("UyPhai json " + ss.getUserId() + ex.getMessage());
1279
+ }
1280
+
1281
+ }
1282
+
1283
+ }
1284
+
1285
  public void GianKhoan() {
1286
  List<String> list1 = new ArrayList<>();
1287
  list1.add("3");
 
1328
  ss.getSocket().close();
1329
  }
1330
  ss.setSocket(socket);
 
 
 
 
 
 
 
1331
  }
1332
 
1333
  public void taoSocketTruyNa() throws Exception {
 
1343
  try {
1344
  Thread.sleep(5000);
1345
  String rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
1346
+
1347
+ tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
1348
+
1349
+ List<String> list1 = new ArrayList<>();
1350
+ list1.add(0, "1");
1351
+ GuiPacket(ss, "12200", list1);
1352
+ list1 = null;
1353
+
1354
+ rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
1355
  if (rs1 != null && rs1 != "") {
1356
  try {
1357
  String[] temp = rs1.toString().split("");
 
1378
  throw new JsonException();
1379
  }
1380
  }
1381
+
1382
+
1383
  } catch (Exception ex) {
1384
  if (!(ex instanceof JsonException)) {
1385
  System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
 
1391
 
1392
  }
1393
 
1394
+ }
1395
+
1396
+
1397
+ public static void StaticCapNhatThongTin(SessionEntity ss) throws IOException, UnknownHostException, InterruptedException, Exception {
1398
+ try {
1399
+ Thread.sleep(5000);
1400
+ String rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
1401
+
1402
+ tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "12400", null);
1403
+
1404
+ List<String> list1 = new ArrayList<>();
1405
+ list1.add(0, "1");
1406
+ GuiPacket(ss, "12200", list1);
1407
+ list1 = null;
1408
+
1409
+ rs1 = tqtk.XuLy.XuLyPacket.GuiPacket1(ss, "11102", null);
1410
+ } catch (Exception ex) {
1411
+ if (!(ex instanceof JsonException)) {
1412
+ System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
1413
+ } else {
1414
+ System.out.println("CapNhatThongTin " + ss.getUserId() + ex.getMessage());
1415
+ }
1416
+
1417
+ }
1418
+
1419
  }
1420
 
1421
  public void ChoDen() throws IOException, UnknownHostException, InterruptedException, Exception {
 
1574
  } catch (Exception e) {
1575
  }
1576
  session.setSocket(socket);
1577
+
1578
+
1579
+ try {
1580
+ GuiPacketKhongKQ(session, "10100", null);
1581
+ // packet cap nhat thong tin lien tuc tu server
1582
+ Thread.sleep(5000);
1583
+ StaticCapNhatThongTin(session);
1584
+ Thread.sleep(5000);
1585
+ GuiPacketKhongKQ(session, "52103", null);
1586
+ Thread.sleep(5000);
1587
+ GuiPacketKhongKQ(session, "10108", null);
1588
+ Thread.sleep(5000);
1589
+ GuiPacketKhongKQ(session, "20101", null);
1590
+ Thread.sleep(5000);
1591
+ List<String> list1 = new ArrayList<>();
1592
+ list1.add(0, "1");
1593
+ StringBuilder rs1 = GuiPacket(session, "12200", list1);
1594
+ list1 = null;
1595
+ } catch (Exception e) {
1596
+ }
1597
+
1598
  }
1599
+
1600
+ public void createSocket1(SessionEntity session) throws Exception {
1601
  Socket socket = new Socket();
1602
  socket.connect(new InetSocketAddress(InetAddress.getByName(session.getIp()), Integer.parseInt(session.getPort())), 7000);
1603
  socket.setSoTimeout(350000);
 
1629
  //if (!ss.getUserId().equals("2301230011011923")) {
1630
  // TruyNa2();
1631
  //}
1632
+
1633
+
1634
  MuaLinh();
1635
 
1636
  NangItem();
 
1638
  NangNha();
1639
  NangKiNang();
1640
  NhanThuong();
1641
+ GianKhoan();
1642
  // FarmDoLv60();
1643
  // ThuThue();
1644
 
 
1646
  ChiemRuong();
1647
  MuaRuong();
1648
  CapNhatThongTin();
1649
+
1650
+ synchronized (this.lock) {
1651
+ if (this.isStop) {
1652
+ lock.wait();
1653
+ }
1654
  }
1655
+
1656
  //synchronized (lock) {
1657
  // isfinish = true;
1658
  // lock.wait();
1659
  //}
1660
  //isfinish = false;
 
1661
  } catch (Exception ex) {
1662
  System.out.println("all " + ss.getUserId() + ex.getMessage());
1663
  }
user.properties CHANGED
@@ -1,58 +1,60 @@
1
- {
2
- "accounts": [
3
- {
4
- "server_id": 8,
5
- "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301232337316215&userid=2301232337316215&GameId=2001&ServerId=s17&Time=1675980791&al=1&from=gesoten&siteurl=gesoten.com&Sign=610ccdb56341636eb0568ecb58e3e008&nickname=gesoten-2301232337316215",
6
- "password": "12081989",
7
- "SessionKey": "6be692141d9cfa9cc9fe532796b94197",
8
- "UserId": "2301232337316215",
9
- "Port": "6017",
10
- "Ip": "s17.sengokugifu.jp"
11
- },
12
- {
13
- "server_id": 9,
14
- "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301190819097479&userid=2301190819097479&GameId=2001&ServerId=s17&Time=1675982026&al=1&from=gesoten&siteurl=gesoten.com&Sign=c31d19f752715495a480bdd83601193d&nickname=gesoten-2301190819097479",
15
- "password": "12081989",
16
- "SessionKey": "ec0d00a99ba0ff5cb5192d831c25463a",
17
- "UserId": "2301190819097479",
18
- "Port": "6017",
19
- "Ip": "s17.sengokugifu.jp"
20
- },
21
- {
22
- "server_id": 10,
23
- "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301211923397199&userid=2301211923397199&GameId=2001&ServerId=s17&Time=1675982135&al=1&from=gesoten&siteurl=gesoten.com&Sign=2c096cc405fe90a2ddc4183500c39079&nickname=gesoten-2301211923397199",
24
- "password": "12081989",
25
- "SessionKey": "1c5d9eac3deef142ef00348e567a7787",
26
- "UserId": "2301211923397199",
27
- "Port": "6017",
28
- "Ip": "s17.sengokugifu.jp"
29
- },
30
- {
31
- "server_id": 11,
32
- "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301230011011923&userid=2301230011011923&GameId=2001&ServerId=s17&Time=1675982238&al=1&from=gesoten&siteurl=gesoten.com&Sign=8868e04af73c9c8f3992a9149caacee1&nickname=gesoten-2301230011011923",
33
- "password": "12081989",
34
- "SessionKey": "4df70eafde5dd3458a330bc912249883",
35
- "UserId": "2301230011011923",
36
- "Port": "6017",
37
- "Ip": "s17.sengokugifu.jp"
38
- },
39
- {
40
- "server_id": 351,
41
- "username": "http://api.sengokugifu.jp/home/login/login?Uname=2301181933399764&userid=2301181933399764&GameId=2001&ServerId=s17&Time=1675658917&al=1&from=gesoten&siteurl=gesoten.com&Sign=d4e6bd8518630feb3fd2f546a6c2884e&nickname=gesoten-2301181933399764",
42
- "password": "12081989",
43
- "SessionKey": "b704ecfd4dd31866d20247ce8b6a221c",
44
- "UserId": "2301181933399764",
45
- "Port": "6017",
46
- "Ip": "s17.sengokugifu.jp"
47
- },
48
- {
49
- "server_id": 352,
50
- "username": "http://mixi.sengokugifu.jp/play.php?accid=32572016266&hash=0416ae30795b66a055d4726794fef2b8&sid=17",
51
- "password": "12081989",
52
- "SessionKey": "16c2c22f2dc709102f744b7a0f23b002",
53
- "UserId": "32572016266",
54
- "Port": "6017",
55
- "Ip": "s17.sengokugifu.jp"
56
- }
57
- ]
58
- }
 
 
 
1
+ 法廷をおさえる
2
+ 国獣として祀り上げる
3
+ 怒りを抑えられ
4
+ 急ぎの約束があるため
5
+ 自ら現場に赴き
6
+ 祭壇を建て
7
+ 医者を探し治療を依頼する
8
+ 静かに立ち去る
9
+ 緊急で撤退するを支援する
10
+ 大いに怒り自ら追跡して
11
+ 時間をかけて尋問し
12
+ 大事になる前に和解させる
13
+ 礼を尽くして招く
14
+ 確かな行いは民衆を豊かに導
15
+ すぐに盗賊をとらえる
16
+ 死ぬ時も同じでありたい
17
+ 自ら兵士の先頭に立ち
18
+ 防犯をが強化するために民家を立てる
19
+ 諫言で国を乱そうとしているな
20
+ 其れを国教とする
21
+ 思い入れのあるものは
22
+ 三拝九拝の礼をとる
23
+ 全国民が天子に謁見する
24
+ 民衆と共に祝いの宴を催す
25
+ 肥沃な土地は多
26
+ 自らの身をもって被災地に支援を行う
27
+ 食料を支援する
28
+ 民衆を連れ開墾する
29
+ 詳細に調べて見極める
30
+ 予定通り実行する
31
+ 民衆に教育を行い
32
+ 拝月神教が世の中を席巻するだろう
33
+ 民を中心にして
34
+ 急いで援助を行う
35
+ 命は大事であるため、放任する
36
+ 自ら軍を率
37
+ 所詮占いであり
38
+ 他の場所を探す
39
+ 自ら民を率いて修復する
40
+ 尋問する人がない
41
+ 全て受け入れる
42
+ 民を助けるのが基本
43
+ 兵力が足りないため徴兵して利用する
44
+ 我の命は我の物で
45
+ 共に抗議する
46
+ 早々に立ち退かせる
47
+ 殴る。教育する
48
+ 親民と共に平安を祝賀する
49
+ 西方の祭日を排除して
50
+ 軍人はスープを作る
51
+ 厳粛に法を執行
52
+ 踊りがうまいからといって何になるのか
53
+ 考えるまでも無
54
+ 自ら救援
55
+ 宴会を催すが
56
+ 安全のため輸送経路を変更する
57
+ 滅多に見れない絶景
58
+ これも縁だと受け入れる
59
+ 全力で救援を行う
60
+ 運命に逆らおうとする