we commited on
Commit
d7c74f7
·
1 Parent(s): 025f1a2
Dockerfile CHANGED
@@ -11,8 +11,8 @@ RUN mvn clean package -DskipTests
11
  FROM openjdk:11-jdk-slim
12
  COPY --from=build /target/demo-0.0.1-SNAPSHOT.jar demo.jar
13
  COPY --from=build /user.properties user.properties
14
- COPY --from=build /truyna.properties truyna.properties
15
- COPY --from=build /cronjob_78184.html cronjob_78184.html
16
  # ENV PORT=8080
17
  EXPOSE 8081
18
  ENTRYPOINT ["java","-Dfile.encoding=UTF-8","-jar","demo.jar"]
 
11
  FROM openjdk:11-jdk-slim
12
  COPY --from=build /target/demo-0.0.1-SNAPSHOT.jar demo.jar
13
  COPY --from=build /user.properties user.properties
14
+ COPY --from=build /urls.txt urls.txt
15
+ COPY --from=build /mydb.db mydb.db
16
  # ENV PORT=8080
17
  EXPOSE 8081
18
  ENTRYPOINT ["java","-Dfile.encoding=UTF-8","-jar","demo.jar"]
log.txt ADDED
@@ -0,0 +1 @@
 
 
1
+ 22:45:49 status 200
mydb.db ADDED
Binary file (5.12 kB). View file
 
nbactions.xml ADDED
@@ -0,0 +1,55 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ <?xml version="1.0" encoding="UTF-8"?>
2
+ <actions>
3
+ <action>
4
+ <actionName>run</actionName>
5
+ <packagings>
6
+ <packaging>jar</packaging>
7
+ </packagings>
8
+ <goals>
9
+ <goal>process-classes</goal>
10
+ <goal>org.codehaus.mojo:exec-maven-plugin:3.0.0:exec</goal>
11
+ </goals>
12
+ <properties>
13
+ <exec.vmArgs></exec.vmArgs>
14
+ <exec.args>${exec.vmArgs} -classpath %classpath ${exec.mainClass} ${exec.appArgs}</exec.args>
15
+ <exec.appArgs></exec.appArgs>
16
+ <exec.mainClass>com.example.demo.DemoApplication</exec.mainClass>
17
+ <exec.executable>java</exec.executable>
18
+ </properties>
19
+ </action>
20
+ <action>
21
+ <actionName>debug</actionName>
22
+ <packagings>
23
+ <packaging>jar</packaging>
24
+ </packagings>
25
+ <goals>
26
+ <goal>process-classes</goal>
27
+ <goal>org.codehaus.mojo:exec-maven-plugin:3.0.0:exec</goal>
28
+ </goals>
29
+ <properties>
30
+ <exec.vmArgs>-agentlib:jdwp=transport=dt_socket,server=n,address=${jpda.address}</exec.vmArgs>
31
+ <exec.args>${exec.vmArgs} -classpath %classpath ${exec.mainClass} ${exec.appArgs}</exec.args>
32
+ <exec.appArgs></exec.appArgs>
33
+ <exec.mainClass>com.example.demo.DemoApplication</exec.mainClass>
34
+ <exec.executable>java</exec.executable>
35
+ <jpda.listen>true</jpda.listen>
36
+ </properties>
37
+ </action>
38
+ <action>
39
+ <actionName>profile</actionName>
40
+ <packagings>
41
+ <packaging>jar</packaging>
42
+ </packagings>
43
+ <goals>
44
+ <goal>process-classes</goal>
45
+ <goal>org.codehaus.mojo:exec-maven-plugin:3.0.0:exec</goal>
46
+ </goals>
47
+ <properties>
48
+ <exec.vmArgs></exec.vmArgs>
49
+ <exec.args>${exec.vmArgs} -classpath %classpath ${exec.mainClass} ${exec.appArgs}</exec.args>
50
+ <exec.mainClass>com.example.demo.DemoApplication</exec.mainClass>
51
+ <exec.executable>java</exec.executable>
52
+ <exec.appArgs></exec.appArgs>
53
+ </properties>
54
+ </action>
55
+ </actions>
pom-b.xml CHANGED
@@ -53,6 +53,16 @@
53
  <groupId>org.postgresql</groupId>
54
  <artifactId>postgresql</artifactId>
55
  <scope>runtime</scope>
 
 
 
 
 
 
 
 
 
 
56
  </dependency>
57
  <dependency>
58
  <groupId>org.springframework.boot</groupId>
 
53
  <groupId>org.postgresql</groupId>
54
  <artifactId>postgresql</artifactId>
55
  <scope>runtime</scope>
56
+ </dependency>
57
+ <dependency>
58
+ <groupId>org.xerial</groupId>
59
+ <artifactId>sqlite-jdbc</artifactId>
60
+ <version>3.7.2</version>
61
+ </dependency>
62
+ <dependency>
63
+ <groupId>com.h2database</groupId>
64
+ <artifactId>h2</artifactId>
65
+ <scope>compile</scope>
66
  </dependency>
67
  <dependency>
68
  <groupId>org.springframework.boot</groupId>
pom.xml CHANGED
@@ -54,6 +54,16 @@
54
  <artifactId>postgresql</artifactId>
55
  <scope>runtime</scope>
56
  </dependency>
 
 
 
 
 
 
 
 
 
 
57
  <dependency>
58
  <groupId>org.springframework.boot</groupId>
59
  <artifactId>spring-boot-starter-test</artifactId>
@@ -65,10 +75,23 @@
65
  <artifactId>json-simple</artifactId>
66
  <version>1.1.1</version>
67
  </dependency>
68
- <dependency>
 
 
 
 
 
 
 
 
 
 
 
 
 
69
  <groupId>org.apache.httpcomponents</groupId>
70
  <artifactId>httpcore</artifactId>
71
- <version>4.0-alpha6</version>
72
  </dependency>
73
 
74
  </dependencies>
 
54
  <artifactId>postgresql</artifactId>
55
  <scope>runtime</scope>
56
  </dependency>
57
+ <dependency>
58
+ <groupId>org.xerial</groupId>
59
+ <artifactId>sqlite-jdbc</artifactId>
60
+ <version>3.7.2</version>
61
+ </dependency>
62
+ <dependency>
63
+ <groupId>com.h2database</groupId>
64
+ <artifactId>h2</artifactId>
65
+ <scope>compile</scope>
66
+ </dependency>
67
  <dependency>
68
  <groupId>org.springframework.boot</groupId>
69
  <artifactId>spring-boot-starter-test</artifactId>
 
75
  <artifactId>json-simple</artifactId>
76
  <version>1.1.1</version>
77
  </dependency>
78
+ <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
79
+ <dependency>
80
+ <groupId>org.apache.httpcomponents</groupId>
81
+ <artifactId>httpclient</artifactId>
82
+ <version>4.5.13</version>
83
+ </dependency>
84
+ <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpmime -->
85
+ <dependency>
86
+ <groupId>org.apache.httpcomponents</groupId>
87
+ <artifactId>httpmime</artifactId>
88
+ <version>4.5.12</version>
89
+ </dependency>
90
+
91
+ <dependency>
92
  <groupId>org.apache.httpcomponents</groupId>
93
  <artifactId>httpcore</artifactId>
94
+ <version>4.4.14</version>
95
  </dependency>
96
 
97
  </dependencies>
src/main/java/com/example/demo/DemoApplication.java CHANGED
@@ -25,6 +25,8 @@ import java.io.OutputStreamWriter;
25
  import java.io.Writer;
26
  import java.net.URL;
27
  import java.net.UnknownHostException;
 
 
28
  import java.util.List;
29
  import java.util.logging.Level;
30
  import java.util.logging.Logger;
@@ -39,6 +41,15 @@ import tqtk.XuLy.XuLyPacket;
39
  import tqtk.XuLy.login.LayThongTinSession;
40
  import java.util.ArrayList;
41
  import java.util.Collections;
 
 
 
 
 
 
 
 
 
42
  @SpringBootApplication
43
  @RestController
44
  public class DemoApplication {
@@ -46,11 +57,52 @@ public class DemoApplication {
46
  public static int count = 0;
47
 
48
  public static ApplicationContext context;
 
49
 
50
  public static void main(String[] args) {
 
51
  context = SpringApplication.run(DemoApplication.class, args);
52
  }
53
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
54
  @GetMapping("exit")
55
  public String getExit() throws IOException {
56
  List<SessionEntity> ss = Tqtk.listSession;
@@ -79,49 +131,47 @@ public class DemoApplication {
79
  }
80
  return "ok";
81
  }
82
-
83
- @GetMapping("cronjob_78184.html")
84
  public String cronjob_78184() throws Exception {
85
  return "cronjob.de";
86
  }
87
-
88
  @RequestMapping(value = "/stopAll", method = RequestMethod.GET)
89
  @ResponseBody
90
  public String stopAll() throws IOException, UnknownHostException, InterruptedException, Exception {
91
  try {
92
-
93
- for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
94
- synchronized (Tqtk.listWorker.get(i).lock) {
95
- Tqtk.listWorker.get(i).isStop = true;
96
- }
97
- }
98
  } catch (Exception e) {
99
- return "not-ok";
100
  }
101
  return "ok";
102
  }
103
-
104
-
105
- @RequestMapping(value = "/resumeAll", method = RequestMethod.GET)
106
  @ResponseBody
107
  public String resumeAll() throws IOException, UnknownHostException, InterruptedException, Exception {
108
  try {
109
- Tqtk.listSession = new ArrayList<>();
110
- Tqtk.listSession = Collections.synchronizedList(Tqtk.listSession);
111
- for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
112
- synchronized (Tqtk.listWorker.get(i).lock) {
113
- Tqtk.listWorker.get(i).setSs(Tqtk.listSession.get(i));
114
- Tqtk.listWorker.get(i).createSocket(Tqtk.listSession.get(i));
115
- Tqtk.listWorker.get(i).isStop = false;
116
- Tqtk.listWorker.get(i).lock.notify();
117
- }
118
- }
119
  } catch (Exception e) {
120
- return e.getMessage();
121
  }
122
  return "ok";
123
  }
124
-
125
 
126
  @RequestMapping(value = "/updateInfo", method = RequestMethod.GET)
127
  @ResponseBody
@@ -145,6 +195,12 @@ public class DemoApplication {
145
  }
146
  return "not-ok";
147
  }
 
 
 
 
 
 
148
 
149
  @RequestMapping(value = "/sendcmd1", method = RequestMethod.POST)
150
  @ResponseBody
@@ -199,20 +255,20 @@ public class DemoApplication {
199
  @GetMapping("setSessionId")
200
  public String setSessionId(@RequestParam(value = "id", required = true) String id,
201
  @RequestParam(value = "session", required = true) String session) throws Exception {
202
-
203
- try {
204
-
205
- for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
206
- if (id.equals(Tqtk.listWorker.get(i).getSs().getUserId())) {
207
-
208
- Tqtk.listWorker.get(i).getSs().setSessionKey(session);
209
- return "ok";
210
- }
211
- }
212
  } catch (Exception e) {
213
- return e.getMessage();
214
  }
215
-
216
  return "not-ok";
217
  }
218
 
@@ -229,6 +285,29 @@ public class DemoApplication {
229
 
230
  }
231
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
232
  public String executeCommand(String command) {
233
 
234
  StringBuffer output = new StringBuffer();
 
25
  import java.io.Writer;
26
  import java.net.URL;
27
  import java.net.UnknownHostException;
28
+ import java.time.LocalTime;
29
+ import java.time.format.DateTimeFormatter;
30
  import java.util.List;
31
  import java.util.logging.Level;
32
  import java.util.logging.Logger;
 
41
  import tqtk.XuLy.login.LayThongTinSession;
42
  import java.util.ArrayList;
43
  import java.util.Collections;
44
+ import org.apache.http.HttpResponse;
45
+ import org.apache.http.NameValuePair;
46
+ import org.apache.http.client.HttpClient;
47
+ import org.apache.http.client.methods.CloseableHttpResponse;
48
+ import org.apache.http.client.methods.HttpPost;
49
+ import org.apache.http.impl.client.DefaultHttpClient;
50
+ import org.apache.http.util.EntityUtils;
51
+ import tqtk.Utils.Doc_file_kieu_txt;
52
+
53
  @SpringBootApplication
54
  @RestController
55
  public class DemoApplication {
 
57
  public static int count = 0;
58
 
59
  public static ApplicationContext context;
60
+ static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("HH:mm:ss");
61
 
62
  public static void main(String[] args) {
63
+
64
  context = SpringApplication.run(DemoApplication.class, args);
65
  }
66
 
67
+ @GetMapping("start_spam")
68
+ public String startSpam() throws IOException {
69
+ LocalTime now = LocalTime.now();
70
+ new Thread() {
71
+ @Override
72
+ public void run() {
73
+ List<String> lists = Doc_file_kieu_txt.readFile("urls.txt");
74
+ int i = 0;
75
+ while (true) {
76
+ i = ++i % lists.size();
77
+ spam(lists.get(i));
78
+ try {
79
+ Thread.sleep(4000);
80
+ } catch (InterruptedException ex) {
81
+ Logger.getLogger(DemoApplication.class.getName()).log(Level.SEVERE, null, ex);
82
+ }
83
+ }
84
+ }
85
+ }.start();
86
+ return "ok";
87
+ }
88
+
89
+ @GetMapping("stop_spam")
90
+ public String stopSpam() throws IOException {
91
+ List<SessionEntity> ss = Tqtk.listSession;
92
+ for (int i = 0; i < ss.size(); ++i) {
93
+ ss.get(i).getSocket().close();
94
+ }
95
+ SpringApplication.exit(context);
96
+ return "exit";
97
+ }
98
+
99
+ @GetMapping("doc_log")
100
+ public String readLog() throws IOException {
101
+ List arrayList = Doc_file_kieu_txt.readFile("log.txt");
102
+ String str = String.join("\n", arrayList);
103
+ return str;
104
+ }
105
+
106
  @GetMapping("exit")
107
  public String getExit() throws IOException {
108
  List<SessionEntity> ss = Tqtk.listSession;
 
131
  }
132
  return "ok";
133
  }
134
+
135
+ @GetMapping("cronjob_78184.html")
136
  public String cronjob_78184() throws Exception {
137
  return "cronjob.de";
138
  }
139
+
140
  @RequestMapping(value = "/stopAll", method = RequestMethod.GET)
141
  @ResponseBody
142
  public String stopAll() throws IOException, UnknownHostException, InterruptedException, Exception {
143
  try {
144
+
145
+ for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
146
+ synchronized (Tqtk.listWorker.get(i).lock) {
147
+ Tqtk.listWorker.get(i).isStop = true;
148
+ }
149
+ }
150
  } catch (Exception e) {
151
+ return "not-ok";
152
  }
153
  return "ok";
154
  }
155
+
156
+ @RequestMapping(value = "/resumeAll", method = RequestMethod.GET)
 
157
  @ResponseBody
158
  public String resumeAll() throws IOException, UnknownHostException, InterruptedException, Exception {
159
  try {
160
+ Tqtk.listSession = new ArrayList<>();
161
+ Tqtk.listSession = Collections.synchronizedList(Tqtk.listSession);
162
+ for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
163
+ synchronized (Tqtk.listWorker.get(i).lock) {
164
+ Tqtk.listWorker.get(i).setSs(Tqtk.listSession.get(i));
165
+ Tqtk.listWorker.get(i).createSocket(Tqtk.listSession.get(i));
166
+ Tqtk.listWorker.get(i).isStop = false;
167
+ Tqtk.listWorker.get(i).lock.notify();
168
+ }
169
+ }
170
  } catch (Exception e) {
171
+ return e.getMessage();
172
  }
173
  return "ok";
174
  }
 
175
 
176
  @RequestMapping(value = "/updateInfo", method = RequestMethod.GET)
177
  @ResponseBody
 
195
  }
196
  return "not-ok";
197
  }
198
+
199
+ @RequestMapping(value = "/githook", method = RequestMethod.POST)
200
+ public String githook() throws IOException, UnknownHostException, InterruptedException {
201
+
202
+ return "ok";
203
+ }
204
 
205
  @RequestMapping(value = "/sendcmd1", method = RequestMethod.POST)
206
  @ResponseBody
 
255
  @GetMapping("setSessionId")
256
  public String setSessionId(@RequestParam(value = "id", required = true) String id,
257
  @RequestParam(value = "session", required = true) String session) throws Exception {
258
+
259
+ try {
260
+
261
+ for (int i = 0; i < Tqtk.listWorker.size(); ++i) {
262
+ if (id.equals(Tqtk.listWorker.get(i).getSs().getUserId())) {
263
+
264
+ Tqtk.listWorker.get(i).getSs().setSessionKey(session);
265
+ return "ok";
266
+ }
267
+ }
268
  } catch (Exception e) {
269
+ return e.getMessage();
270
  }
271
+
272
  return "not-ok";
273
  }
274
 
 
285
 
286
  }
287
 
288
+ public static void spam(String url) {
289
+ String response;
290
+ HttpClient httpClient = new DefaultHttpClient();
291
+ try {
292
+ HttpPost get = new HttpPost(url);
293
+
294
+ get.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/85.0.4183.121 Safari/537.36");
295
+
296
+ get.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9");
297
+ get.setHeader("Sec-Fetch-Dest", "empty");
298
+ get.setHeader("Sec-Fetch-Mode", "cors");
299
+ get.setHeader("Sec-Fetch-Site", "same-origin");
300
+ get.setHeader("X-Same-Domain", "1");
301
+
302
+ CloseableHttpResponse Cresponse = (CloseableHttpResponse) httpClient.execute(get);
303
+ int s = Cresponse.getStatusLine().getStatusCode();
304
+ Util.writeFile(LocalTime.now().format(formatter) + " status " + s, "/log.txt");
305
+ return;
306
+ } catch (IOException ex) {
307
+ ex.getMessage();
308
+ }
309
+ }
310
+
311
  public String executeCommand(String command) {
312
 
313
  StringBuffer output = new StringBuffer();
src/main/java/com/sqlite/config/DBConfig.java ADDED
@@ -0,0 +1,18 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ package com.sqlite.config;
2
+
3
+ import javax.sql.DataSource;
4
+ import org.springframework.boot.jdbc.DataSourceBuilder;
5
+
6
+ import org.springframework.context.annotation.Bean;
7
+ import org.springframework.context.annotation.Configuration;
8
+
9
+ @Configuration
10
+ public class DBConfig {
11
+ @Bean
12
+ public DataSource dataSource() {
13
+ DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
14
+ dataSourceBuilder.driverClassName("org.sqlite.JDBC");
15
+ dataSourceBuilder.url("jdbc:sqlite:mydb.db");
16
+ return dataSourceBuilder.build();
17
+ }
18
+ }
src/main/java/com/sqlite/config/DBInitializeConfig.java ADDED
@@ -0,0 +1,47 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ package com.sqlite.config;
2
+
3
+ import java.sql.Connection;
4
+ import java.sql.SQLException;
5
+ import java.sql.Statement;
6
+
7
+ import javax.annotation.PostConstruct;
8
+ import javax.sql.DataSource;
9
+
10
+ import org.springframework.beans.factory.annotation.Autowired;
11
+ import org.springframework.context.annotation.Configuration;
12
+
13
+ @Configuration
14
+ public class DBInitializeConfig {
15
+
16
+ @Autowired
17
+ private DataSource dataSource;
18
+
19
+ @PostConstruct
20
+ public void initialize() {
21
+ // try {
22
+ // Connection connection = dataSource.getConnection();
23
+ // Statement statement = connection.createStatement();
24
+ // statement.execute("DROP TABLE IF EXISTS UserLogin");
25
+ // statement.executeUpdate(
26
+ // "CREATE TABLE UserLogin("
27
+ // + "id INTEGER Primary key, "
28
+ // + "userName varchar(30) not null,"
29
+ // + "password varchar(30) not null,"
30
+ // + "firstName varchar(30) not null, "
31
+ // + "lastName varchar(30) not null,"
32
+ // + "email varchar(100) not null,"
33
+ // + "mobile varchar(30) not null)"
34
+ // );
35
+ // statement.executeUpdate(
36
+ // "INSERT INTO UserLogin "
37
+ // + "(userName,password,firstName,lastName,email,mobile) "
38
+ // + "VALUES " + "('bharat0126','dbase123','Bharat','Verma',"
39
+ // + " '[email protected]','8861456151')"
40
+ // );
41
+ // statement.close();
42
+ // connection.close();
43
+ // } catch (SQLException e) {
44
+ // e.printStackTrace();
45
+ // }
46
+ }
47
+ }
src/main/java/com/sqlite/config/MvcConfig.java ADDED
@@ -0,0 +1,37 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ /*
2
+ * To change this license header, choose License Headers in Project Properties.
3
+ * To change this template file, choose Tools | Templates
4
+ * and open the template in the editor.
5
+ */
6
+ package com.sqlite.config;
7
+
8
+ import java.util.List;
9
+ import org.springframework.context.annotation.Configuration;
10
+ import org.springframework.format.FormatterRegistry;
11
+ import org.springframework.http.converter.HttpMessageConverter;
12
+ import org.springframework.validation.MessageCodesResolver;
13
+ import org.springframework.validation.Validator;
14
+ import org.springframework.web.method.support.HandlerMethodArgumentResolver;
15
+ import org.springframework.web.method.support.HandlerMethodReturnValueHandler;
16
+ import org.springframework.web.servlet.HandlerExceptionResolver;
17
+ import org.springframework.web.servlet.config.annotation.AsyncSupportConfigurer;
18
+ import org.springframework.web.servlet.config.annotation.ContentNegotiationConfigurer;
19
+ import org.springframework.web.servlet.config.annotation.CorsRegistry;
20
+ import org.springframework.web.servlet.config.annotation.DefaultServletHandlerConfigurer;
21
+ import org.springframework.web.servlet.config.annotation.EnableWebMvc;
22
+ import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
23
+ import org.springframework.web.servlet.config.annotation.PathMatchConfigurer;
24
+ import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
25
+ import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;
26
+ import org.springframework.web.servlet.config.annotation.ViewResolverRegistry;
27
+ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
28
+
29
+
30
+ public class MvcConfig {
31
+
32
+ public void addResourceHandlers(ResourceHandlerRegistry registry) {
33
+
34
+ }
35
+
36
+
37
+ }
src/main/java/com/sqlite/config/SQLiteDialect.java ADDED
@@ -0,0 +1,155 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ package com.sqlite.config;
2
+
3
+ import java.sql.Types;
4
+
5
+ import org.hibernate.dialect.Dialect;
6
+ import org.hibernate.dialect.function.SQLFunctionTemplate;
7
+ import org.hibernate.dialect.function.StandardSQLFunction;
8
+ import org.hibernate.dialect.function.VarArgsSQLFunction;
9
+ import org.hibernate.type.StringType;
10
+
11
+ public class SQLiteDialect extends Dialect {
12
+ public SQLiteDialect() {
13
+ registerColumnType(Types.BIT, "integer");
14
+ registerColumnType(Types.TINYINT, "tinyint");
15
+ registerColumnType(Types.SMALLINT, "smallint");
16
+ registerColumnType(Types.INTEGER, "integer");
17
+ registerColumnType(Types.BIGINT, "bigint");
18
+ registerColumnType(Types.FLOAT, "float");
19
+ registerColumnType(Types.REAL, "real");
20
+ registerColumnType(Types.DOUBLE, "double");
21
+ registerColumnType(Types.NUMERIC, "numeric");
22
+ registerColumnType(Types.DECIMAL, "decimal");
23
+ registerColumnType(Types.CHAR, "char");
24
+ registerColumnType(Types.VARCHAR, "varchar");
25
+ registerColumnType(Types.LONGVARCHAR, "longvarchar");
26
+ registerColumnType(Types.DATE, "date");
27
+ registerColumnType(Types.TIME, "time");
28
+ registerColumnType(Types.TIMESTAMP, "timestamp");
29
+ registerColumnType(Types.BINARY, "blob");
30
+ registerColumnType(Types.VARBINARY, "blob");
31
+ registerColumnType(Types.LONGVARBINARY, "blob");
32
+ // registerColumnType(Types.NULL, "null");
33
+ registerColumnType(Types.BLOB, "blob");
34
+ registerColumnType(Types.CLOB, "clob");
35
+ registerColumnType(Types.BOOLEAN, "integer");
36
+
37
+ registerFunction( "concat", new VarArgsSQLFunction(StringType.INSTANCE, "", "||", "") );
38
+ registerFunction( "mod", new SQLFunctionTemplate( StringType.INSTANCE, "?1 % ?2" ) );
39
+ registerFunction( "substr", new StandardSQLFunction("substr", StringType.INSTANCE) );
40
+ registerFunction( "substring", new StandardSQLFunction( "substr", StringType.INSTANCE) );
41
+ }
42
+
43
+ public boolean supportsIdentityColumns() {
44
+ return true;
45
+ }
46
+
47
+ /*
48
+ public boolean supportsInsertSelectIdentity() {
49
+ return true; // As specify in NHibernate dialect
50
+ }
51
+ */
52
+
53
+ public boolean hasDataTypeInIdentityColumn() {
54
+ return false; // As specify in NHibernate dialect
55
+ }
56
+
57
+ /*
58
+ public String appendIdentitySelectToInsert(String insertString) {
59
+ return new StringBuffer(insertString.length()+30). // As specify in NHibernate dialect
60
+ append(insertString).
61
+ append("; ").append(getIdentitySelectString()).
62
+ toString();
63
+ }
64
+ */
65
+
66
+ public String getIdentityColumnString() {
67
+ // return "integer primary key autoincrement";
68
+ return "integer";
69
+ }
70
+
71
+ public String getIdentitySelectString() {
72
+ return "select last_insert_rowid()";
73
+ }
74
+
75
+ public boolean supportsLimit() {
76
+ return true;
77
+ }
78
+
79
+ protected String getLimitString(String query, boolean hasOffset) {
80
+ return new StringBuffer(query.length()+20).
81
+ append(query).
82
+ append(hasOffset ? " limit ? offset ?" : " limit ?").
83
+ toString();
84
+ }
85
+
86
+ public boolean supportsTemporaryTables() {
87
+ return true;
88
+ }
89
+
90
+ public String getCreateTemporaryTableString() {
91
+ return "create temporary table if not exists";
92
+ }
93
+
94
+ public boolean dropTemporaryTableAfterUse() {
95
+ return false;
96
+ }
97
+
98
+ public boolean supportsCurrentTimestampSelection() {
99
+ return true;
100
+ }
101
+
102
+ public boolean isCurrentTimestampSelectStringCallable() {
103
+ return false;
104
+ }
105
+
106
+ public String getCurrentTimestampSelectString() {
107
+ return "select current_timestamp";
108
+ }
109
+
110
+ public boolean supportsUnionAll() {
111
+ return true;
112
+ }
113
+
114
+ public boolean hasAlterTable() {
115
+ return false; // As specify in NHibernate dialect
116
+ }
117
+
118
+ public boolean dropConstraints() {
119
+ return false;
120
+ }
121
+
122
+ public String getAddColumnString() {
123
+ return "add column";
124
+ }
125
+
126
+ public String getForUpdateString() {
127
+ return "";
128
+ }
129
+
130
+ public boolean supportsOuterJoinForUpdate() {
131
+ return false;
132
+ }
133
+
134
+ public String getDropForeignKeyString() {
135
+ throw new UnsupportedOperationException("No drop foreign key syntax supported by SQLiteDialect");
136
+ }
137
+
138
+ public String getAddForeignKeyConstraintString(String constraintName,
139
+ String[] foreignKey, String referencedTable, String[] primaryKey,
140
+ boolean referencesPrimaryKey) {
141
+ throw new UnsupportedOperationException("No add foreign key syntax supported by SQLiteDialect");
142
+ }
143
+
144
+ public String getAddPrimaryKeyConstraintString(String constraintName) {
145
+ throw new UnsupportedOperationException("No add primary key syntax supported by SQLiteDialect");
146
+ }
147
+
148
+ public boolean supportsIfExistsBeforeTableName() {
149
+ return true;
150
+ }
151
+
152
+ public boolean supportsCascadeDelete() {
153
+ return false;
154
+ }
155
+ }
src/main/java/tqtk/Utils/Doc_file_kieu_txt.java CHANGED
@@ -26,7 +26,9 @@ public class Doc_file_kieu_txt {
26
  br = new BufferedReader(new FileReader(path));
27
 
28
  while ((read = br.readLine()) != null) {
29
- lists.add(read);
 
 
30
  }
31
  return lists;
32
 
 
26
  br = new BufferedReader(new FileReader(path));
27
 
28
  while ((read = br.readLine()) != null) {
29
+ if (!Util.isBlank(read)) {
30
+ lists.add(read);
31
+ }
32
  }
33
  return lists;
34
 
src/main/java/tqtk/Utils/Util.java CHANGED
@@ -9,8 +9,10 @@ import com.fasterxml.jackson.databind.DeserializationFeature;
9
  import com.fasterxml.jackson.databind.ObjectMapper;
10
  import java.io.BufferedInputStream;
11
  import java.io.BufferedReader;
 
12
  import java.io.DataOutputStream;
13
  import java.io.FileInputStream;
 
14
  import java.io.FileReader;
15
  import java.io.IOException;
16
  import java.io.InputStream;
@@ -34,6 +36,8 @@ import javax.net.ssl.HttpsURLConnection;
34
  import org.apache.commons.lang3.StringUtils;
35
  import tqtk.Entity.SessionEntity;
36
  import java.io.FileReader;
 
 
37
  import java.util.Iterator;
38
  import java.util.regex.Matcher;
39
  import java.util.regex.Pattern;
@@ -56,6 +60,25 @@ public class Util {
56
  msCookieManager = new CookieManager();
57
  }
58
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
59
  public void setCookie(CookieManager msCookieManager) {
60
  CookieHandler.setDefault(msCookieManager);
61
  }
@@ -377,7 +400,7 @@ public class Util {
377
  JSONParser jsonParser = new JSONParser();
378
  JSONObject jSONObjecttemp = null;
379
  String x = "/" + file_name;
380
- try (FileReader reader = new FileReader(x)) {
381
  //Read JSON file
382
  jSONObject = (org.json.simple.JSONObject) jsonParser.parse(reader);
383
 
@@ -809,7 +832,7 @@ public class Util {
809
  public static boolean checkIdRunUyPhai(String id) throws Exception {
810
  boolean rs = false;
811
  try {
812
- final URL obj = new URL("http://subsixcyber13.pythonanywhere.com/check-uy-phai?id="+id);
813
  // Proxy proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress("0.0.0.0", 1080));
814
  HttpURLConnection con;
815
  if (obj.getProtocol().equals("http")) {
 
9
  import com.fasterxml.jackson.databind.ObjectMapper;
10
  import java.io.BufferedInputStream;
11
  import java.io.BufferedReader;
12
+ import java.io.BufferedWriter;
13
  import java.io.DataOutputStream;
14
  import java.io.FileInputStream;
15
+ import java.io.FileNotFoundException;
16
  import java.io.FileReader;
17
  import java.io.IOException;
18
  import java.io.InputStream;
 
36
  import org.apache.commons.lang3.StringUtils;
37
  import tqtk.Entity.SessionEntity;
38
  import java.io.FileReader;
39
+ import java.io.FileWriter;
40
+ import java.io.PrintWriter;
41
  import java.util.Iterator;
42
  import java.util.regex.Matcher;
43
  import java.util.regex.Pattern;
 
60
  msCookieManager = new CookieManager();
61
  }
62
 
63
+ public static boolean isBlank(String s) {
64
+ return s == null || s.trim().length() == 0;
65
+ }
66
+
67
+ public static synchronized void writeFile(final String content, final String name) throws FileNotFoundException, UnsupportedEncodingException, IOException {
68
+ PrintWriter out = null;
69
+ try {
70
+ // out = new PrintWriter(new BufferedWriter(new FileWriter(System.getProperty("user.dir") + "\\" + name, true)));
71
+ out = new PrintWriter(new BufferedWriter(new FileWriter( name, true)));
72
+ out.println(content);
73
+ } catch (IOException e) {
74
+ throw e;
75
+ } finally {
76
+ if (out != null) {
77
+ out.close();
78
+ }
79
+ }
80
+ }
81
+
82
  public void setCookie(CookieManager msCookieManager) {
83
  CookieHandler.setDefault(msCookieManager);
84
  }
 
400
  JSONParser jsonParser = new JSONParser();
401
  JSONObject jSONObjecttemp = null;
402
  String x = "/" + file_name;
403
+ try ( FileReader reader = new FileReader(x)) {
404
  //Read JSON file
405
  jSONObject = (org.json.simple.JSONObject) jsonParser.parse(reader);
406
 
 
832
  public static boolean checkIdRunUyPhai(String id) throws Exception {
833
  boolean rs = false;
834
  try {
835
+ final URL obj = new URL("http://subsixcyber13.pythonanywhere.com/check-uy-phai?id=" + id);
836
  // Proxy proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress("0.0.0.0", 1080));
837
  HttpURLConnection con;
838
  if (obj.getProtocol().equals("http")) {
src/main/java/tqtk/XuLy/Worker.java CHANGED
@@ -1150,7 +1150,7 @@ public class Worker extends Thread {
1150
  if (Chinhchien == 1) {
1151
  Chinhchien = 0;
1152
  List<String> list1 = new ArrayList<>();
1153
- list1.add(0, "1924");
1154
  list1.add(1, "0");
1155
 
1156
  try {
@@ -1856,7 +1856,12 @@ public class Worker extends Thread {
1856
  NhanThuong();
1857
  GianKhoan();
1858
  GianKhoan();
1859
- // FarmDoLv60();
 
 
 
 
 
1860
  ThuThue();
1861
 
1862
  ChiemMo();
 
1150
  if (Chinhchien == 1) {
1151
  Chinhchien = 0;
1152
  List<String> list1 = new ArrayList<>();
1153
+ list1.add(0, "5708");
1154
  list1.add(1, "0");
1155
 
1156
  try {
 
1856
  NhanThuong();
1857
  GianKhoan();
1858
  GianKhoan();
1859
+
1860
+ if (!ss.getUserId().equals("2301252106191710") && !ss.getUserId().equals("2301252112453620")) {
1861
+ FarmDoLv60();
1862
+ }
1863
+
1864
+
1865
  ThuThue();
1866
 
1867
  ChiemMo();
src/main/resources/application.properties CHANGED
@@ -1,10 +1,8 @@
1
  server.tomcat.accesslog.enabled=true
2
 
3
- spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.PostgreSQLDialect
4
- spring.jpa.hibernate.ddl-auto=update
5
- spring.jpa.hibernate.show-sql=true
6
-
7
- spring.datasource.url=jdbc:postgresql://dpg-ck973mf0vg2c738gb0ig-a.singapore-postgres.render.com:5432/test1_979r
8
- spring.datasource.username=usssss
9
- spring.datasource.password=HnrVi6LMZ0zJXZcibSCQrdUiYZihAQK4
10
- spring.datasource.driver-class-name=org.postgresql.Driver
 
1
  server.tomcat.accesslog.enabled=true
2
 
3
+ spring.profiles.active=dev
4
+ spring.jpa.database-platform=com.sqlite.config.SQLiteDialect
5
+ #spring.jpa.hibernate.ddl-auto=create-drop
6
+ spring.jpa.hibernate.ddl-auto=create
7
+ spring.jpa.show-sql=true
8
+ spring.jpa.hibernate.naming-strategy=org.hibernate.cfg.EJB3NamingStrategy
 
 
urls.txt ADDED
@@ -0,0 +1 @@
 
 
1
+