huanghai
/
dsProject
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

'commit'

Browse Source
main
HuangHai 3 months ago
parent 8e2f490929
commit 01aeb21990
4 changed files with 11 additions and 147 deletions
Show Stats Download Patch File Download Diff File

122
dsBase/pom.xml
Unescape View File

@ -123,16 +123,11 @@
<version>2.0.45</version>
</dependency>
<!--引用poi-->
<!-- https://mvnrepository.com/artifact/cn.idev.excel/fastexcel -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>5.2.5</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>5.2.5</version>
<groupId>cn.idev.excel</groupId>
<artifactId>fastexcel</artifactId>
<version>1.1.0</version>
</dependency>
<!--引用jsoup防止xss攻击-->
@ -141,20 +136,6 @@
<artifactId>jsoup</artifactId>
<version>1.17.2</version>
</dependency>
<!--强制升级httpclient和httpcore-->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.14</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.4.15</version>
</dependency>
<!--引用gson-->
<dependency>
<groupId>com.google.code.gson</groupId>
@ -185,13 +166,7 @@
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>5.1.0</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpmime</artifactId>
<version>4.5.14</version>
<version>5.2.0</version>
</dependency>
<dependency>
@ -206,62 +181,11 @@
<version>2.20.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.web3j/core -->
<dependency>
<groupId>org.web3j</groupId>
<artifactId>core</artifactId>
<version>5.0.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>4.12.0</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.36</version>
</dependency>
<!--生成测试数据-->
<dependency>
<groupId>com.github.javafaker</groupId>
<artifactId>javafaker</artifactId>
<version>1.0.2</version>
</dependency>
<!--引入kafka-->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>3.6.1</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-api</artifactId>
<version>2.4.2.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-embedded</artifactId>
<version>2.4.2.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-connector-mysql</artifactId>
<version>2.4.2.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-connector-postgres</artifactId>
<version>2.4.2.Final</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
@ -273,44 +197,14 @@
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
<version>2.14.2</version>
<!--升级到新版本时Debezium启动失败！-->
</dependency>
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
<version>1.18.38</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.hiforce.pixel.open</groupId>
<artifactId>pixel-force-open-client</artifactId>
<version>1.0.6</version>
</dependency>
<dependency>
<groupId>com.hiforce.pixel.open</groupId>
<artifactId>pixel-force-open-sample</artifactId>
<version>1.0.6</version>
</dependency>
<dependency>
<groupId>org.glassfish</groupId>
<artifactId>jakarta.json</artifactId>
<version>2.0.1</version>
</dependency>
<dependency>
<groupId>com.hankcs</groupId>
<artifactId>hanlp</artifactId>
<version>portable-1.8.4</version>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
<version>4.7.3</version>
</dependency>
</dependencies>
<build>
<plugins>

1
dsBase/src/main/java/Tools/Init/clearDataBase.java
Unescape View File

@ -4,7 +4,6 @@ import cn.hutool.core.date.DateTime;
import com.dsideal.dsBase.Start;
import com.dsideal.dsBase.Util.CommonUtil;
import com.dsideal.dsBase.Util.PkUtil;
import com.github.javafaker.DateAndTime;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.CaseInsensitiveContainerFactory;

4
dsBase/src/main/java/com/dsideal/dsBase/Global/Controller/GlobalController.java
Unescape View File

@ -1,5 +1,6 @@
package com.dsideal.dsBase.Global.Controller;
import cn.hutool.core.codec.Base64;
import com.alibaba.fastjson.JSONObject;
import com.dsideal.dsBase.Global.Model.GlobalModel;
import com.dsideal.dsBase.Interceptor.*;
@ -11,7 +12,6 @@ import com.jfinal.ext.interceptor.POST;
import com.jfinal.plugin.activerecord.Page;
import com.jfinal.plugin.activerecord.Record;
import org.apache.commons.lang.StringUtils;
import org.bouncycastle.util.encoders.Base64;
import java.util.List;
@ -174,7 +174,9 @@ public class GlobalController extends Controller {
@EmptyInterface({"global_codes"})
public void getGlobalByCodes(String global_codes) {
if (CommonUtil.isBase64(global_codes)) {
//对global_codes进行Base64解码
byte[] decode = Base64.decode(global_codes);
global_codes = new String(decode);
}
List<Record> records = model.getGlobalByCodes(global_codes);

31
dsBase/src/main/java/com/dsideal/dsBase/Util/KafkaProducerThread.java
Unescape View File

@ -1,31 +0,0 @@
package com.dsideal.dsBase.Util;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class KafkaProducerThread implements Runnable {
private Logger log = LoggerFactory.getLogger(KafkaProducerThread.class);
private KafkaProducer producer;
private ProducerRecord record;
KafkaProducerThread(KafkaProducer producer, ProducerRecord record) {
this.producer = producer;
this.record = record;
}
@Override
public void run() {
//异步写
producer.send(record, (metadata, exception) -> {
if (null != exception) {
exception.printStackTrace();
}
if (null != metadata) {
log.info("消息发送成功 ： " + String.format("offset: %s, partition:%s, topic:%s timestamp:%s",
metadata.offset(), metadata.partition(), metadata.topic(), metadata.timestamp()));
}
});
}
}
Write Preview
Loading…
Cancel
Save