wuzudaniu
/
cloud-plus-server
6
0
Fork 0
Code Issues Pull Requests 4 Packages Projects Releases Wiki Activity

feat():提取公共依赖在最大的pom

dev.gateway
ruyaxie 2024-10-07 15:43:26 +08:00
parent 761fd61725
commit 04450b84e6
8 changed files with 42 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-common/cloud-common-cache/src/main/java/com/muyu/common/cache/CacheAbsBasic.java vendored
View File

@ -22,7 +22,7 @@ public abstract class CacheAbsBasic <K, V> implements CacheBasic<K, V>{
public void put(K key, V value) {
try {
redisService.setCacheObject(encode(key), value,30L,TimeUnit.MINUTES);
redisService.setCacheObject(encode(key), value);
} catch (Exception e) {
throw new RuntimeException("运行时异常，异常信息为：{}"+e.getMessage());
}

4
cloud-modules/cloud-modules-data-process/cloud-modules-data-process-common/src/main/java/com/muyu/data/domain/EnterpriseCommon.java
View File

@ -42,4 +42,8 @@ public class EnterpriseCommon {
*/
private List<FenceAndGroupMiddle> fenceAndGroupMiddles;
/**
* 故障信息和车辆
*/
}

1
cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/pom.xml
View File

@ -86,7 +86,6 @@
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
</dependencies>

1
cloud-modules/cloud-modules-enterprise/enterpise-service/pom.xml
View File

@ -96,7 +96,6 @@
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
</dependencies>

4
cloud-modules/cloud-modules-parse/pom.xml
View File

@ -93,26 +93,22 @@
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-remote</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 实体类 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-common</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 缓存框架 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- kafka 公共配置 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>${muyu.version}</version>
</dependency>
</dependencies>

6
cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/configure/MqttConsumerConfig.java
View File

@ -10,6 +10,7 @@ import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
/**
* @version 1.0
@ -32,6 +33,9 @@ public class MqttConsumerConfig {
String broker = "tcp://123.57.152.124:1883";
String clientId = "xyr123456789";
@Resource
private ProcessData processData;
@PostConstruct
public void connect() {
try {
@ -55,7 +59,7 @@ public class MqttConsumerConfig {
public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
String s1 = new String(mqttMessage.getPayload());
System.out.println("接收到的主题是:" + s + "内容是:{}" + s1);
ProcessData.DataConversion(s1);
processData.DataConversion(s1);
}

14
cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java
View File

@ -14,6 +14,7 @@ import lombok.extern.log4j.Log4j2;
import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
import org.springframework.context.annotation.Configuration;
import javax.annotation.Resource;
import java.util.List;
@ -26,28 +27,29 @@ import java.util.List;
* @注释
*/
@Log4j2
@Configuration
public class ProcessData {
//报文模版信息
@Resource
private static MessageValueCacheService messageValueCacheService;
private MessageValueCacheService messageValueCacheService;
//车辆信息
@Resource
private static SysCarCacheService sysCarCacheService;
private SysCarCacheService sysCarCacheService;
//车辆类型信息
@Resource
private static SysCarTypeCacheService sysCarTypeCacheService;
private SysCarTypeCacheService sysCarTypeCacheService;
@Resource
private static KafkaProducerConfig kafkaProducerConfig;
private KafkaProducerConfig kafkaProducerConfig;
private final static String topic = "sysCar_vin_topic";
public static void DataConversion(String jsonVin ) {
public void DataConversion(String jsonVin ) {
//设置数组存储车辆数据
JSONObject jsonObject = new JSONObject();
String vin = DataParseUtil.dataParsing(jsonVin);
@ -80,7 +82,7 @@ public class ProcessData {
private static void sendKafkaMessage(JSONObject jsonObject){
private void sendKafkaMessage(JSONObject jsonObject){
ProducerRecord<Object, JSONObject> producerRecord = new ProducerRecord<>(topic, jsonObject);
try {
kafkaProducerConfig.kafkaProducer().send(new ProducerRecord<>(topic,jsonObject.toString()));

29
pom.xml
View File

@ -277,11 +277,30 @@
<version>${muyu.version}</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>enterpise-common</artifactId>-->
<!-- <version>${muyu.version}</version>-->
<!-- </dependency>-->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-remote</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 实体类 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-common</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 缓存框架 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- kafka 公共配置 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>${muyu.version}</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>