Compare commits

...

80 Commits

Author SHA1 Message Date
Aaaaaaaa 6c2daa0d7e Merge branch 'master' into xxy
# Conflicts:
#	cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mqtt/Demo.java
2024-10-02 10:23:47 +08:00
Aaaaaaaa 5a64054615 Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 2024-10-02 10:22:59 +08:00
张腾 903fecc2cc 121 2024-10-02 10:22:41 +08:00
张腾 e46b6325c4 整合 Kafka依赖并更新版本管理
- 在 cloud-common-kafka模块中添加 cloud-common-core依赖
- 移除 cloud-modules-carData 中的 Kafka 依赖版本声明
- 在根 pom.xml 中统一管理 Kafka 依赖版本
- 更新 cloud-common-kafka 依赖版本为 3.6.3
2024-10-02 10:10:10 +08:00
Aaaaaaaa 217ffd81ab Merge branch 'master' into xxy 2024-10-02 10:00:30 +08:00
Aaaaaaaa b2c16300f4 Merge remote-tracking branch 'origin/master'
# Conflicts:
#	cloud-common/cloud-common-kafka/pom.xml
#	cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
2024-10-02 09:58:47 +08:00
Aaaaaaaa b07b7a1d2d 添加Kafka消息队列配置和常量类
- 新增KafkaConstants类,定义Kafka主题和消费组常量
- 新增KafkaConsumerConfig类,配置Kafka消费者
- 新增KafkaProviderConfig类,配置Kafka生产者
- 添加AutoConfiguration.imports文件,导入Kafka配置类
- 创建cloud-common-kafka模块的pom.xml文件,添加依赖
2024-10-02 09:58:09 +08:00
张腾 614ddceebc 删除了IoTDB相关的实体类、接口和注解。这些代码可能已经移动到另一个位置或者不再需要这些结构。受影响的代码包括:
- 删除了`com.muyu.carData.domain.IoTDBRecord`实体类,它用于定义IoT数据库记录。
- 删除了`com.muyu.carData.interfaces.IoTDBRecordable`接口,它定义了如何将对象转换为IoTDBRecord。
- 删除了`com.muyu.carData.annotation.IoTTableName`注解,它用于标记类对应IoT数据库表的名称。
- 删除了`com.muyu.carData.constract.IoTDBTableParam`类,它包含IoT数据库表参数的常量定义。
2024-10-02 09:43:00 +08:00
张腾 a17d1b4557 feat():修复合并代码 2024-10-02 09:38:43 +08:00
Aaaaaaaa 057ad3ded5 Merge branch 'master' into xxy 2024-10-02 09:31:55 +08:00
张腾 1542f34db3 Merge remote-tracking branch 'origin/dev.carData' into dev
# Conflicts:
#	cloud-common/pom.xml
2024-10-02 09:28:58 +08:00
张腾 87b3eccff5 feat():更新最新代码 2024-10-02 09:12:44 +08:00
Aaaaaaaa 735e7f56e0 协议解析:完成解析方法实现kafka的投产,并拆入自己的模块 2024-09-30 20:58:08 +08:00
张腾 af798f18e5 feat():编辑卡夫卡代码 2024-09-30 16:52:26 +08:00
Aaaaaaaa 0d82041676 Merge branch 'xxy' into dev 2024-09-30 10:12:22 +08:00
Aaaaaaaa 7a88f1da14 修改报错 2024-09-30 10:11:40 +08:00
niuwu666 b4f832925c Merge pull request 'dev.carData' (#4) from dev.carData into dev
Reviewed-on: #4
2024-09-30 09:04:26 +08:00
张腾 5ab005839c commit()yml 2024-09-30 09:03:40 +08:00
张腾 6f52789cc0 commit()yml 2024-09-30 09:03:17 +08:00
WeiRan 4aebd67ebc 更新 2024-09-29 22:46:04 +08:00
WeiRan 207125c795 Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/FaultRuleServiceImpl.java
2024-09-29 22:23:10 +08:00
WeiRan 3bf6f0d929 更新 2024-09-29 22:18:34 +08:00
Yueng f07d95abeb fine()代码修改 2024-09-29 22:17:00 +08:00
WeiRan f27b14dc33 更新 2024-09-29 17:51:53 +08:00
Yueng aedee04643 fine()配置类提交 2024-09-29 17:16:32 +08:00
WeiRan 1627aa3dab 修改bug 2024-09-29 16:53:08 +08:00
niuwu666 fa3b9b2244 Merge pull request 'dev.carData' (#3) from dev.carData into master
Reviewed-on: #3
2024-09-29 10:21:36 +08:00
WeiRan 8d7ad9cdb9 修改pom配置 2024-09-29 10:19:55 +08:00
Yueng 13bb25f4da fine()配置类提交 2024-09-29 10:14:43 +08:00
张腾 25bc628f8f 时序性数据库测试成功 2024-09-29 01:17:24 +08:00
Yueng 5688271d2c fine()修改mybatis plus 2024-09-29 00:10:46 +08:00
WeiRan 83312b8e37 修改代码,mybatis->mybatis-plus 2024-09-28 22:33:22 +08:00
WeiRan fa36d029af 所有注释补全 2024-09-28 19:28:54 +08:00
WeiRan 07a60444aa 所有注释补全 2024-09-28 17:41:48 +08:00
Yueng 60b63b758e fine()修改mybatis plus 2024-09-28 17:35:25 +08:00
张腾 b299c8d3a1 配置 2024-09-28 12:30:20 +08:00
Yueng ac21236123 fine()sass模块初始化 2024-09-28 12:28:53 +08:00
Yueng 016887afc2 Merge remote-tracking branch 'origin/psr'
# Conflicts:
#	cloud-gateway/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-Saas-Service/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-Vehicle-Simulation/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarInformationController.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarMessageController.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/CarMessage.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarInformationMapper.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/CarMessageService.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarInformationServiceImpl.java
#	cloud-modules/cloud-modules-car/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarInformationMapper.xml
#	cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml
#	cloud-modules/pom.xml
#	pom.xml
2024-09-27 12:07:08 +08:00
Yueng 52dbb5a08b fine()配置 2024-09-27 11:52:47 +08:00
Yueng c415b7676f Merge remote-tracking branch 'origin/dev.wei'
# Conflicts:
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarInformationController.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarMessageController.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/CarMessage.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarInformationMapper.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/CarMessageService.java
#	cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarInformationServiceImpl.java
#	cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarInformationMapper.xml
#	pom.xml
2024-09-27 11:52:11 +08:00
Yueng 5b1c1a27a9 Merge branch 'dev.yang' 2024-09-27 11:01:15 +08:00
Aaaaaaaa 22b3d12010 Merge remote-tracking branch 'origin/dev.xxy'
# Conflicts:
#	cloud-modules/pom.xml
2024-09-26 15:18:21 +08:00
Aaaaaaaa f6c1de2c6b 车辆管理 2024-09-26 15:05:48 +08:00
Yueng 29c84f90ef Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev.yang
# Conflicts:
#	cloud-auth/src/main/resources/bootstrap.yml
#	cloud-common/pom.xml
#	cloud-gateway/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml
#	cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml
2024-09-26 14:57:53 +08:00
yuan 122049419c feat():连接车辆管理 2024-09-26 14:53:11 +08:00
WeiRan 1d8aea440b 更新 2024-09-26 14:47:00 +08:00
niuwu666 49fe2961f0 Merge pull request 'saas1提交' (#2) from dev.zhang into master
Reviewed-on: #2
2024-09-26 14:46:44 +08:00
weiran 25ad7f9da0 删除 cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml 2024-09-26 10:13:24 +08:00
weiran 01aaf7f926 删除 cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml 2024-09-26 10:12:37 +08:00
weiran 1185868ce5 删除 cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml 2024-09-26 10:12:18 +08:00
weiran 0c7287f19d 删除 cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml 2024-09-26 10:12:03 +08:00
weiran 803ea0fe80 删除 cloud-gateway/src/main/resources/bootstrap.yml 2024-09-26 10:11:14 +08:00
weiran 59b64e816c 删除 cloud-auth/src/main/resources/bootstrap.yml 2024-09-26 10:10:38 +08:00
Aaaaaaaa 4a094775d4 报文管理 2024-09-25 22:44:25 +08:00
WeiRan 66adba7bdc Merge branch 'dev.zhang' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev.wei 2024-09-25 21:18:01 +08:00
WeiRan 6727b1896a 更改故障测试的bug 2024-09-25 21:14:33 +08:00
niuwu666 67988ff16f Merge pull request 'saas初始' (#1) from dev.zhang into master
Reviewed-on: #1
2024-09-25 20:24:04 +08:00
Yueng 178d4966b5 Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev.yang
# Conflicts:
#	cloud-auth/src/main/resources/bootstrap.yml
#	cloud-common/pom.xml
#	cloud-gateway/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml
#	cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml
2024-09-25 19:54:42 +08:00
Yueng c174e8adab 添加解绑操作 2024-09-25 19:53:11 +08:00
WeiRan c66b84bc6c 故障模块测试 2024-09-25 15:53:55 +08:00
WeiRan ab2f94acbd 初始化 2024-09-25 09:41:03 +08:00
Yueng 10981bc80d 查询中间表,添加车辆中间表围栏组围栏表信息 2024-09-24 11:08:21 +08:00
WeiRan 97b20e395a 初始化 2024-09-24 10:49:45 +08:00
Aaaaaaaa 15b99b27c4 报文管理 2024-09-24 10:11:43 +08:00
WeiRan 3d8b02a00e fex():修改故障判断代码 2024-09-24 09:30:39 +08:00
yuan 347018d602 feat():连接车辆类型与模板 2024-09-24 09:24:11 +08:00
yuan 833e554722 feat():连接车辆类型与模板 2024-09-23 10:59:43 +08:00
WeiRan 5edc2a8c05 feat():故障规则 2024-09-22 22:22:48 +08:00
Aaaaaaaa e8377904b5 报文管理 2024-09-22 09:37:52 +08:00
Aaaaaaaa b227854496 车辆管理/报文 二次修改 2024-09-23 00:25:45 +08:00
Yueng 41918d6303 初始化 2024-09-21 20:47:42 +08:00
Yueng 86eb16420b 初始化 2024-09-21 20:47:11 +08:00
WeiRan 10b63954a4 Merge branch 'dev.wei' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev.wei 2024-09-21 12:44:48 +08:00
WeiRan 19ca5b409f 初始化 2024-09-21 12:43:38 +08:00
Aaaaaaaa 6f17adbcf3 Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into dev.xxy
# Conflicts:
#	cloud-modules/pom.xml
2024-09-21 12:06:05 +08:00
Aaaaaaaa 97d5dac0a2 车辆管理/报文基础设置 2024-09-21 12:04:04 +08:00
yuan b3ce3825ad Merge branch 'master' of https://gitea.qinmian.online/a_bazu/cloud-server-8 into psr
# Conflicts:
#	cloud-common/pom.xml
#	cloud-modules/pom.xml
2024-09-21 12:01:55 +08:00
yuan 6a413e0ce0 feat():初始化 2024-09-21 11:51:40 +08:00
Aaaaaaaa f07a9bd208 车辆管理基础业务实体类 2024-09-18 20:58:51 +08:00
Aaaaaaaa 3c7ba5744d 车辆管理基础设置 2024-09-18 19:16:32 +08:00
1843 changed files with 199736 additions and 147 deletions

3
.gitignore vendored
View File

@ -12,6 +12,8 @@ out
###################################################################### ######################################################################
# IDE # IDE
### STS ### ### STS ###
.apt_generated .apt_generated
.classpath .classpath
@ -26,6 +28,7 @@ logs
*.iws *.iws
*.iml *.iml
*.ipr *.ipr
*.yml
### JRebel ### ### JRebel ###
rebel.xml rebel.xml

View File

@ -30,6 +30,10 @@ public class RegisterBody extends LoginBody {
/** /**
* *
*/ */
private String phoneNumber; private String phonenumber;
/**
*
*/
private String nickName;
} }

View File

@ -127,10 +127,18 @@ public class SysLoginService {
// 注册用户信息 // 注册用户信息
SysUser sysUser = new SysUser(); SysUser sysUser = new SysUser();
//公司账号
sysUser.setUserName(registerBody.getUsername()); sysUser.setUserName(registerBody.getUsername());
//公司邮箱
sysUser.setEmail(registerBody.getEmail()); sysUser.setEmail(registerBody.getEmail());
sysUser.setPhonenumber(registerBody.getPhoneNumber()); //公司号码
sysUser.setPhonenumber(registerBody.getPhonenumber());
//密码
sysUser.setPassword(SecurityUtils.encryptPassword(registerBody.getPassword())); sysUser.setPassword(SecurityUtils.encryptPassword(registerBody.getPassword()));
//公司注册人名称
sysUser.setNickName(registerBody.getNickName());
//企业名称
sysUser.setFirmName(registerBody.getFirmName());
Result<?> registerResult = remoteUserService.registerUserInfo(sysUser, SecurityConstants.INNER); Result<?> registerResult = remoteUserService.registerUserInfo(sysUser, SecurityConstants.INNER);
if (Result.FAIL == registerResult.getCode()) { if (Result.FAIL == registerResult.getCode()) {

View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848 addr: 159.75.188.178:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: eight namespace: xxy
# Spring # Spring
spring: spring:
application: application:

View File

@ -501,4 +501,5 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
} }
return sb.toString(); return sb.toString();
} }
} }

View File

@ -0,0 +1,33 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-common</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-common-kafka</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.0.0</version>
</dependency>
<!-- 项目公共核心 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,54 @@
package com.muyu.common.kafka.config;
import com.muyu.common.kafka.constants.KafkaConstants;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.Deserializer;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
/**
* kafka
*/
@Configuration
public class KafkaConsumerConfig {
@Bean
public KafkaConsumer kafkaConsumer() {
Map<String, Object> configs = new HashMap<>();
//kafka服务端的IP和端口,格式:(ip:port)
configs.put("bootstrap.servers", "60.204.221.52:9092");
//开启consumer的偏移量(offset)自动提交到Kafka
configs.put("enable.auto.commit", true);
//consumer的偏移量(offset) 自动提交的时间间隔,单位毫秒
configs.put("auto.commit.interval", 5000);
//在Kafka中没有初始化偏移量或者当前偏移量不存在情况
//earliest, 在偏移量无效的情况下, 自动重置为最早的偏移量
//latest, 在偏移量无效的情况下, 自动重置为最新的偏移量
//none, 在偏移量无效的情况下, 抛出异常.
configs.put("auto.offset.reset", "latest");
//请求阻塞的最大时间(毫秒)
configs.put("fetch.max.wait", 500);
//请求应答的最小字节数
configs.put("fetch.min.size", 1);
//心跳间隔时间(毫秒)
configs.put("heartbeat-interval", 3000);
//一次调用poll返回的最大记录条数
configs.put("max.poll.records", 500);
//指定消费组
configs.put("group.id", KafkaConstants.KafkaGrop);
//指定key使用的反序列化类
Deserializer keyDeserializer = new StringDeserializer();
//指定value使用的反序列化类
Deserializer valueDeserializer = new StringDeserializer();
//创建Kafka消费者
KafkaConsumer kafkaConsumer = new KafkaConsumer(configs, keyDeserializer, valueDeserializer);
return kafkaConsumer;
}
}

View File

@ -0,0 +1,45 @@
package com.muyu.common.kafka.config;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.common.serialization.Serializer;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
/**
* kafka
*/
@Configuration
public class KafkaProviderConfig {
@Bean
public KafkaProducer kafkaProducer() {
Map<String, Object> configs = new HashMap<>();
//#kafka服务端的IP和端口,格式:(ip:port)
configs.put("bootstrap.servers", "47.116.173.119:9092");
//客户端发送服务端失败的重试次数
configs.put("retries", 2);
//多个记录被发送到同一个分区时,生产者将尝试将记录一起批处理成更少的请求.
//此设置有助于提高客户端和服务器的性能,配置控制默认批量大小(以字节为单位)
configs.put("batch.size", 16384);
//生产者可用于缓冲等待发送到服务器的记录的总内存字节数(以字节为单位)
configs.put("buffer-memory", 33554432);
//生产者producer要求leader节点在考虑完成请求之前收到的确认数,用于控制发送记录在服务端的持久化
//acks=0,设置为0,则生产者producer将不会等待来自服务器的任何确认.该记录将立即添加到套接字(socket)缓冲区并视为已发送.在这种情况下,无法保证服务器已收到记录,并且重试配置(retries)将不会生效(因为客户端通常不会知道任何故障),每条记录返回的偏移量始终设置为-1.
//acks=1,设置为1,leader节点会把记录写入本地日志,不需要等待所有follower节点完全确认就会立即应答producer.在这种情况下,在follower节点复制前,leader节点确认记录后立即失败的话,记录将会丢失.
//acks=all,acks=-1,leader节点将等待所有同步复制副本完成再确认记录,这保证了只要至少有一个同步复制副本存活,记录就不会丢失.
configs.put("acks", "-1");
//指定key使用的序列化类
Serializer keySerializer = new StringSerializer();
//指定value使用的序列化类
Serializer valueSerializer = new StringSerializer();
//创建Kafka生产者
KafkaProducer kafkaProducer = new KafkaProducer(configs, keySerializer, valueSerializer);
return kafkaProducer;
}
}

View File

@ -0,0 +1,9 @@
package com.muyu.common.kafka.constants;
public class KafkaConstants {
public final static String KafkaTopic = "carJsons";
// public final static String KafkaGrop = "kafka_grop";
}

View File

@ -0,0 +1,76 @@
package com.muyu.kafkaconfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
/**
* @Author
* @Packagecom.muyu.carData.config.kafkaconfig
* @Projectcloud-server-8
* @nameKafkaConfig
* @Date2024/9/28 12:19
*/
@Configuration
public class KafkaConfig {
@Bean
public KafkaProducer kafkaProducer(){
HashMap<String, Object> configs = new HashMap<>();
configs.put("bootstrap.servers","60.204.221.52:9092");
configs.put("retries",2);
configs.put("batch.size",16384);
//生产者可用于缓冲等待发送到服务器的记录的总内存字节数
configs.put("buffer-memory",3554432);
/**
* ,
*acks=0,0,producer.(socket)
* .,,(retries)(),-1.
*acks=1,1,leader,followerproducer.,
* follower,leader,.
*/
configs.put("acks","-1");
//指定key使用的序列化类
StringSerializer keySerializer = new StringSerializer();
//指定value使用的序列化类
StringSerializer valueSerializer = new StringSerializer();
//创建kafka生产者
return new KafkaProducer(configs, keySerializer, valueSerializer);
}
@Bean
public KafkaConsumer kafkaConsumer(){
HashMap<String, Object> configs = new HashMap<>();
configs.put("bootstrap.servers","60.204.221.52:9092");
//开启consumer的偏移量offset自动提交到kafka
configs.put("enable.auto.commit",true);
//偏移量自动提交的时间间隔,单位毫秒
configs.put("auto.commit.interval",5000);
//在Kafka中没有初始化偏移量或者当前偏移量不存在情况
//earliest, 在偏移量无效的情况下, 自动重置为最早的偏移量
//latest, 在偏移量无效的情况下, 自动重置为最新的偏移量
//none, 在偏移量无效的情况下, 抛出异常.
configs.put("auto.offset.reset","latest");
//请求阻塞的最大时间(毫秒)
configs.put("fetch.max.wait",500);
//请求应答的最小字节数
configs.put("fetch.min.size",1);
//心跳间隔时间(毫秒)
configs.put("heartbeat-interval",3000);
//一次调用poll返回的最大记录条数
configs.put("max.poll.records",500);
//指定消费组
configs.put("group.id","firstGroup");
//指定key使用的反序列化类
StringDeserializer keyDeserializer = new StringDeserializer();
//指定value使用的反序列化类
StringDeserializer valueDeserializer = new StringDeserializer();
//创建kafka消费者
return new KafkaConsumer(configs,keyDeserializer,valueDeserializer);
}
}

View File

@ -87,7 +87,6 @@ public class SysUser extends BaseEntity {
* ID * ID
*/ */
private Integer firmId; private Integer firmId;
/** /**
* *
*/ */
@ -145,6 +144,12 @@ public class SysUser extends BaseEntity {
*/ */
private Long roleId; private Long roleId;
/**
*
* @param userId
*/
private String firmName;
public SysUser (Long userId) { public SysUser (Long userId) {
this.userId = userId; this.userId = userId;
} }

View File

@ -0,0 +1,62 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-common</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-common-wechat</artifactId>
<packaging>jar</packaging>
<name>cloud-common-wechat</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- MuYu Common Core-->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>org.dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.1.3</version>
</dependency>
<!-- 帮助将java对象转换为xml字符串-->
<!-- 依赖冲突会导致InaccessibleObjectException异常更新到适用版本-->
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
<version>1.4.20</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>4.9.3</version>
</dependency>
<!-- Alibaba Fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.83</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,23 @@
package com.muyu.common.wechat.domain;
import lombok.Data;
/**
* @author 24415
*/
@Data
public class AccessToken {
private String access_token;
private Long expires_in;
public void setExpiresTime(Long expiresIn) {
this.expires_in = System.currentTimeMillis()+expiresIn*1000;
}
public boolean isExpired(Long expiresIn){
long now = System.currentTimeMillis();
return now>expiresIn;
}
}

View File

@ -0,0 +1,38 @@
package com.muyu.common.wechat.domain;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameArticles
* @Date2024/9/18 10:14
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("item")
public class Articles {
// <Articles>
// <item>
// <Title><![CDATA[title1]]></Title>
// <Description><![CDATA[description1]]></Description>
// <PicUrl><![CDATA[picurl]]></PicUrl>
// <Url><![CDATA[url]]></Url>
// </item>
// </Articles>
@XStreamAlias("Title")
private String title ;
@XStreamAlias("Description")
private String description ;
@XStreamAlias("PicUrl")
private String picUrl ;
@XStreamAlias("Url")
private String url ;
}

View File

@ -0,0 +1,50 @@
package com.muyu.common.wechat.domain;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameImageText
* @Date2024/9/18 9:27
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("xml")
public class NewsMessage {
// <ToUserName><![CDATA[toUser]]></ToUserName>
// <FromUserName><![CDATA[fromUser]]></FromUserName>
// <CreateTime>12345678</CreateTime>
// <MsgType><![CDATA[news]]></MsgType>
// <ArticleCount>1</ArticleCount>
// <Articles>
// <item>
// <Title><![CDATA[title1]]></Title>
// <Description><![CDATA[description1]]></Description>
// <PicUrl><![CDATA[picurl]]></PicUrl>
// <Url><![CDATA[url]]></Url>
// </item>
// </Articles>
@XStreamAlias("ToUserName")
private String toUserName ;
@XStreamAlias("FromUserName")
private String fromUserName ;
@XStreamAlias("CreateTime")
private long createTime ;
@XStreamAlias("MsgType")
private String msgType ;
@XStreamAlias("ArticleCount")
private Integer articleCount ;
@XStreamAlias("Articles")
private List<Articles> articles ;
}

View File

@ -0,0 +1,40 @@
package com.muyu.common.wechat.domain;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameTextMessage
* @Date2024/9/18 11:33
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("xml")
public class TextMessage {
//起一个别名 因为我们微信返回信息与java代码格式规范发生冲突
//微信格式 ToUserName
//JAVA格式 toUserName
@XStreamAlias("ToUserName")
private String toUserName;
@XStreamAlias("FromUserName")
private String fromUserName;
@XStreamAlias("CreateTime")
private long createTime;
@XStreamAlias("MsgType")
private String msgType;
@XStreamAlias("Content")
private String content;
}
// <ToUserName><![CDATA[toUser]]></ToUserName>
// <FromUserName><![CDATA[fromUser]]></FromUserName>
// <CreateTime>12345678</CreateTime>
// <MsgType><![CDATA[text]]></MsgType>
// <Content><![CDATA[你好]]></Content>

View File

@ -0,0 +1,38 @@
package com.muyu;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
/**
* Unit test for simple App.
*/
public class AppTest
extends TestCase
{
/**
* Create the test case
*
* @param testName name of the test case
*/
public AppTest( String testName )
{
super( testName );
}
/**
* @return the suite of tests being tested
*/
public static Test suite()
{
return new TestSuite( AppTest.class );
}
/**
* Rigourous Test :-)
*/
public void testApp()
{
assertTrue( true );
}
}

View File

@ -21,6 +21,8 @@
<module>cloud-common-xxl</module> <module>cloud-common-xxl</module>
<module>cloud-common-rabbit</module> <module>cloud-common-rabbit</module>
<module>cloud-common-saas</module> <module>cloud-common-saas</module>
<module>cloud-common-wechat</module>
<module>cloud-common-kafka</module>
</modules> </modules>
<artifactId>cloud-common</artifactId> <artifactId>cloud-common</artifactId>

View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848 addr: 159.75.188.178:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: eight namespace: xxy
# Spring # Spring
spring: spring:

View File

@ -9,14 +9,17 @@
<version>3.6.3</version> <version>3.6.3</version>
</parent> </parent>
<artifactId>cloud-test</artifactId> <artifactId>cloud-modules-carData</artifactId>
<description>
数据处理模块
</description>
<properties> <properties>
<maven.compiler.source>17</maven.compiler.source> <maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target> <maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties> </properties>
<dependencies> <dependencies>
<!-- SpringCloud Alibaba Nacos --> <!-- SpringCloud Alibaba Nacos -->
@ -72,5 +75,29 @@
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-common-api-doc</artifactId> <artifactId>cloud-common-api-doc</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
<version>2.9.3</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.apache.iotdb</groupId>
<artifactId>iotdb-session</artifactId>
<version>0.13.1</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-rabbit</artifactId>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -0,0 +1,24 @@
package com.muyu.carData;
import com.muyu.carData.listener.MyListener;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @Author
* @Packagecom.muyu.carData
* @Projectcloud-server-8
* @nameCarDataApplication
* @Date2024/9/26 15:33
*/
@SpringBootApplication
@EnableMyFeignClients
public class CarDataApplication {
public static void main(String[] args) {
SpringApplication application = new SpringApplication(CarDataApplication.class);
application.addListeners(new MyListener());
application.run(args);
}
}

View File

@ -0,0 +1,29 @@
package com.muyu.carData.config.cacheconfig;
import com.github.benmanes.caffeine.cache.Expiry;
import org.checkerframework.checker.index.qual.NonNegative;
import java.util.concurrent.TimeUnit;
/**
* @Author
* @Packagecom.muyu.carData.cacheconfig
* @Projectcloud-server-8
* @nameCacheExpiry
* @Date2024/9/26 23:46
*/
public class CacheExpiry implements Expiry<String,ExpiryTime>{
@Override
public long expireAfterCreate(String key, ExpiryTime value, long currentTime) {
return TimeUnit.SECONDS.toNanos(value.getExpiryTime());
}
@Override
public long expireAfterUpdate(String key, ExpiryTime value, long currentTime, @NonNegative long currentDuration) {
return TimeUnit.SECONDS.toNanos(value.getRefreshTime());
}
@Override
public long expireAfterRead(String key, ExpiryTime value, long currentTime, @NonNegative long currentDuration) {
return TimeUnit.SECONDS.toNanos(value.getRefreshTime());
}
}

View File

@ -0,0 +1,26 @@
package com.muyu.carData.config.cacheconfig;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @Author
* @Packagecom.muyu.carData.cacheconfig
* @Projectcloud-server-8
* @nameCaffeineConfig
* @Date2024/9/26 23:51
*/
@Configuration
public class CaffeineConfig {
@Bean
public Cache<String, ? extends ExpiryTime> caffeineCache(){
CacheExpiry cacheExpiry = new CacheExpiry();
return Caffeine.newBuilder()
.expireAfter(cacheExpiry)
.initialCapacity(128)
.build();
}
}

View File

@ -0,0 +1,33 @@
package com.muyu.carData.config.cacheconfig;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
* @Author
* @Packagecom.muyu.carData.cacheconfig
* @Projectcloud-server-8
* @nameExpiryTime
* @Date2024/9/26 23:44
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
public class ExpiryTime {
/**
* 30
*/
@Builder.Default
private long expiryTime = 30 * 60;
/**
* 15
*/
@Builder.Default
private long refreshTime = 15 * 60;
}

View File

@ -0,0 +1,86 @@
package com.muyu.carData.config.lotdbconfig;
import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.session.Session;
import org.apache.iotdb.session.pool.SessionPool;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.carData.lotdbconfig
* @Projectcloud-server-8
* @nameIotDBSessionConfig
* @Date2024/9/27 12:25
* IotDB线
*/
@Component
@Configuration
public class IotDBSessionConfig {
private static Logger logger = LoggerFactory.getLogger(IotDBSessionConfig.class);
/**
*
*/
@Value("${spring.iotdb.username}")
private String username;
/**
*
*/
@Value("${spring.iotdb.password}")
private String password;
/**
* ip
*/
@Value("${spring.iotdb.ip}")
private String ip;
/**
*
*/
@Value("${spring.iotdb.port}")
private Integer port;
/**
*
*/
@Value("${spring.iotdb.maxSize}")
private Integer maxSize;
/**
*
*/
@Value("${spring.iotdb.fetchSize}")
private int fetchSize;
@Bean
public Session iotSession(){
Session session = new Session(ip, port, username, password);
try {
session.open();
} catch (IoTDBConnectionException e) {
logger.error(String.valueOf(e.getCause()));
}
return session;
}
}

View File

@ -0,0 +1,56 @@
package com.muyu.carData.consumer;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.nacos.shaded.com.google.common.collect.Lists;
import com.muyu.carData.pojo.Student;
import lombok.extern.log4j.Log4j2;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Collection;
/**
* @Author
* @Packagecom.muyu.carData.consumer
* @Projectcloud-server-8
* @nameMyKafkaConsumer
* @Date2024/9/26 15:42
*/
@Component
@Log4j2
public class MyKafkaConsumer implements InitializingBean {
@Autowired
private KafkaConsumer kafkaConsumer;
private final String topicName = "carJsons";
@Override
public void afterPropertiesSet() throws Exception {
log.info("启动线程开始监听topic:{}",topicName);
Thread thread = new Thread(() -> {
ThreadUtil.sleep(1000);
Collection<String> topics = Lists.newArrayList(topicName);
kafkaConsumer.subscribe(topics);
while (true){
ConsumerRecords<String,String> consumerRecords = kafkaConsumer.poll(Duration.ofMillis(1000));
for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {
//从consumerRecord中获取消费数据
String value = consumerRecord.value();
log.info("从Kafka中消费的原始数据===============>>{}",value);
}
}
});
thread.start();
log.info("启动线程结束监听topic:{}",topicName);
}
}

View File

@ -0,0 +1,44 @@
package com.muyu.carData.controller;
import com.github.benmanes.caffeine.cache.Cache;
import com.muyu.carData.config.cacheconfig.CaffeineConfig;
import com.muyu.carData.pojo.Student;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Author
* @Packagecom.muyu.carData.controller
* @Projectcloud-server-8
* @nameTestController
* @Date2024/9/26 23:56
*/
@RestController
@RequestMapping("/testCache")
@Log4j2
public class CacheController {
@Autowired
private CaffeineConfig caffeineConfig;
@RequestMapping("/caffeine")
public String caffeine() throws InterruptedException {
Cache<String, Student> stringCache = (Cache<String, Student>) caffeineConfig.caffeineCache();
Student build = Student.builder().id(1)
.name("小马")
.sex("男")
.expiryTime(20 * 60)
.refreshTime(15 * 30)
.build();
stringCache.put("1", build);
Thread.sleep(1000);
//返回缓存的个数
log.info(stringCache.estimatedSize());
//返回缓存的数据
log.info(stringCache.getIfPresent("1"));
return "111";
}
}

View File

@ -0,0 +1,113 @@
package com.muyu.carData.controller;
import com.muyu.carData.config.lotdbconfig.IotDBSessionConfig;
import lombok.extern.log4j.Log4j2;
import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.rpc.StatementExecutionException;
import org.apache.iotdb.session.Session;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.write.record.Tablet;
import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.carData.testcontroller
* @Projectcloud-server-8
* @nameIotDBController
* @Date2024/9/28 23:58
*/
@RequestMapping("/iotdb")
@RestController
@Log4j2
public class IotDBController {
@Autowired
private IotDBSessionConfig iotDBSessionConfig;
/**
*
* @param insertSize
* @param count
* @return
* @throws IoTDBConnectionException
* @throws StatementExecutionException
*/
@GetMapping("/insertData/{insertSize}/{count}")
public String insert(@PathVariable(name = "insertSize") int insertSize,@PathVariable(name = "count") int count) throws IoTDBConnectionException, StatementExecutionException {
Session session = iotDBSessionConfig.iotSession();
//schemaList 属性及类型
List<MeasurementSchema> schemaList = new ArrayList<>();
schemaList.add(new MeasurementSchema("id", TSDataType.INT32));
schemaList.add(new MeasurementSchema("name", TSDataType.TEXT));
schemaList.add(new MeasurementSchema("sex", TSDataType.TEXT));
//tablet 封装数据
Tablet tablet = new Tablet("root.yang.baling", schemaList);
//以当前时间戳作为插入的起始时间戳
long timestamp = System.currentTimeMillis();
long beginTime = System.currentTimeMillis();
for (long row = 0;row < count; row++){
int rowIndex = tablet.rowSize++;
tablet.addTimestamp(rowIndex,timestamp); //批量插入的时间戳是数组形式所以需要使用rowIndex来指定插入的位置
tablet.addValue("id", rowIndex, ((row & 1) == 0 ? 1 : 0));
tablet.addValue("name", rowIndex, "name<=>" + row);
tablet.addValue("sex", rowIndex, "男");
if (tablet.rowSize == insertSize){
long bg = System.currentTimeMillis();
session.insertTablet(tablet);
tablet.reset();
log.info("已经插入了"+(row + 1)+",插入耗时:" + (System.currentTimeMillis() - bg));
}
timestamp++;
}
if (tablet.rowSize != 0){
session.insertTablet(tablet);
log.info("插入完成,耗时:" + (System.currentTimeMillis() - beginTime));
tablet.reset();
}
long endTime = System.currentTimeMillis();
log.info("插入了"+insertSize+"条数据,每次插入"+count+"条数据,总耗时:"+(endTime - beginTime));
return "时序性数据库测试success";
}
/* @GetMapping("/batchInsertRecords/{num}")
public String batchInsertRecords(@PathVariable Integer num){
String deviceId = "root.yang";
//属性(字段)
List<String> schemaList = new ArrayList<>();
schemaList.add("id");
schemaList.add("name");
schemaList.add("age");
ArrayList<TSDataType> tsDataTypes = new ArrayList<>();
tsDataTypes.add(TSDataType.INT32);
tsDataTypes.add(TSDataType.TEXT);
tsDataTypes.add(TSDataType.INT32);
List<Object> value = new ArrayList<>();
value.add(1);
value.add("张腾");
value.add(18);
ArrayList<String> deviceIds = new ArrayList<>();
ArrayList<Long> times = new ArrayList<>();
ArrayList<List<TSDataType>> typeList = new ArrayList<>();
ArrayList<List<Object>> valueList = new ArrayList<>();
for (int i = 0; i < num; i++) {
deviceIds.add()
}
}*/
}

View File

@ -0,0 +1,45 @@
package com.muyu.carData.controller;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.log4j.Log4j2;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Author
* @Packagecom.muyu.carData.testcontroller
* @Projectcloud-server-8
* @nameKafkaProducerController
* @Date2024/9/28 15:10
*/
@RestController
@RequestMapping("/produce")
@Log4j2
public class KafkaProducerController {
@Autowired
private KafkaProducer kafkaProducer;
private final String topicName = "carJsons";
@GetMapping("/producer")
public String produceTest(JSONObject data) {
try {
log.info("Topic:{}", topicName);
log.info("转换为JSON{}",data);
//使用KafkaProducer发送消息
ProducerRecord<String, String> stringProducerRecord = new ProducerRecord(topicName, data);
kafkaProducer.send(stringProducerRecord);
}catch (Exception e){
log.error("Producer写入Topic异常,异常信息是:{}",e.getMessage());
}
return "消息发送成功";
}
}

View File

@ -0,0 +1,22 @@
package com.muyu.carData.event;
import com.alibaba.fastjson.JSONObject;
import org.springframework.context.ApplicationEvent;
/**
* @Author
* @Packagecom.muyu.carData.event
* @Projectcloud-server-8
* @nameEsSaveEvent
* @Date2024/9/29 21:15
*/
public class EsSaveEvent extends ApplicationEvent {
private JSONObject data;
public EsSaveEvent(JSONObject source) {
super(source);
this.data = source;
}
}

View File

@ -0,0 +1,22 @@
package com.muyu.carData.listener;
import com.muyu.carData.event.EsSaveEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
/**
* @Author
* @Packagecom.muyu.carData.listener
* @Projectcloud-server-8
* @nameCustomEventListener
* @Date2024/9/29 23:49
*/
@Component
public class CustomEventListener {
@EventListener
public void handMyEvent(EsSaveEvent event){
//处理事件详情
}
}

View File

@ -0,0 +1,20 @@
package com.muyu.carData.listener;
import com.muyu.carData.event.EsSaveEvent;
import lombok.extern.log4j.Log4j2;
import org.springframework.context.ApplicationListener;
/**
* @Author
* @Packagecom.muyu.carData.listener
* @Projectcloud-server-8
* @nameMyListener
* @Date2024/9/29 21:18
*/
@Log4j2
public class MyListener implements ApplicationListener<EsSaveEvent> {
@Override
public void onApplicationEvent(EsSaveEvent event) {
log.info("监听到自定义事件........");
}
}

View File

@ -0,0 +1,41 @@
package com.muyu.carData.pojo;
import com.muyu.carData.config.cacheconfig.ExpiryTime;
import lombok.*;
import lombok.experimental.SuperBuilder;
/**
* @Author
* @Packagecom.muyu.carData.pojo
* @Projectcloud-server-8
* @nameStudent
* @Date2024/9/27 0:40
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
public class Student extends ExpiryTime{
/**
*
*/
private Integer id;
/**
*
*/
private String name;
/**
*
*/
private String sex;
/**
*
*/
private long time = System.currentTimeMillis();
}

View File

@ -0,0 +1,29 @@
package com.muyu.carData.pulisher;
import com.alibaba.fastjson.JSONObject;
import com.muyu.carData.event.EsSaveEvent;
import lombok.AllArgsConstructor;
import lombok.extern.log4j.Log4j2;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;
/**
* @Author
* @Packagecom.muyu.carData.pulisher
* @Projectcloud-server-8
* @nameCustomEventPublisher
* @Date2024/9/29 23:51
*/
@Log4j2
@Component
@AllArgsConstructor
public class CustomEventPublisher {
private ApplicationEventPublisher applicationEventPublisher;
public void publish(JSONObject data){
EsSaveEvent esSaveEvent = new EsSaveEvent(data);
applicationEventPublisher.publishEvent(esSaveEvent);
log.info("事件发布成功 - 消息是:{}",data);
}
}

View File

@ -0,0 +1,2 @@
Spring Boot Version: ${spring-boot.version}
Spring Application Name: ${spring.application.name}

View File

@ -0,0 +1,63 @@
# Tomcat
server:
port: 9702
# nacos线上地址
nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: eight
# SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
# Spring
spring:
iotdb:
username: root
password: root
ip: 60.204.221.52
port: 6667
maxSize: 100
fetchSize: 10000
main:
allow-bean-definition-overriding: true
application:
# 应用名称
name: cloud-carData
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
config:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
# 系统共享配置
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# 系统环境Config共享配置
- application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# xxl-job 配置文件
- application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# rabbit 配置文件
- application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
logging:
level:
com.muyu.system.mapper: DEBUG

View File

@ -0,0 +1,74 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-carData"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

View File

@ -0,0 +1,81 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-carData"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

View File

@ -0,0 +1,81 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-carData"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

View File

@ -0,0 +1,62 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-modules-enterprise-common</artifactId>
<version>1.0.0</version>
<description>
cloud-modules-enterprise-common 企业业务common
</description>
<properties>
<maven.compiler.source>21</maven.compiler.source>
<maven.compiler.target>21</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- MuYu Common Core-->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations-jakarta</artifactId>
<version>2.2.8</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.1.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
<version>1.4.20</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>4.9.3</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.83</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-system</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,25 @@
package com.muyu.domain;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.Data;
/**
* ()
*/
@Data
@Tag(name = "连接微信服务器")
public class AccessToken {
private String access_token;
private Long expires_in;
public void setExpiresTime(Long expiresIn) {
this.expires_in = System.currentTimeMillis()+expiresIn*1000;
}
public boolean isExpired(Long expiresIn){
long now = System.currentTimeMillis();
return now>expiresIn;
}
}

View File

@ -0,0 +1,41 @@
package com.muyu.domain;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* ()
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameArticles
* @Date2024/9/18 10:14
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("item")
@Tag(name = "发送图文回复消息内容")
public class Articles {
// <Articles>
// <item>
// <Title><![CDATA[title1]]></Title>
// <Description><![CDATA[description1]]></Description>
// <PicUrl><![CDATA[picurl]]></PicUrl>
// <Url><![CDATA[url]]></Url>
// </item>
// </Articles>
@XStreamAlias("Title")
private String title ;
@XStreamAlias("Description")
private String description ;
@XStreamAlias("PicUrl")
private String picUrl ;
@XStreamAlias("Url")
private String url ;
}

View File

@ -0,0 +1,213 @@
package com.muyu.domain;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* ()
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.faultrule
* @Projectcloud-server-8
* @namePureElectricCar
* @Date2024/9/20 20:22
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "故障规则测试类")
public class CarFaultRule {
/**
* VINVINVIN
*/
private String vin;
/**
*
*/
private long timestamp;
/**
*
*/
private double longitude;
/**
*
*/
private double latitude;
/**
*
*/
private double speed;
/**
*
*/
private Long tm;
/**
*
*/
private double tv;
/**
*
*/
private double cc;
/**
*
*/
private double ir;
/**
*
*/
private String gp;
/**
*
*/
private double aptv;
/**
*
*/
private double bptv;
/**
*
*/
private double sfc;
/**
*
*/
private double mct;
/**
*
*/
private int ms;
/**
*
*/
private double mto;
/**
*
*/
private double mte;
/**
*
*/
private double mv;
/**
*
*/
private double mc;
/**
* SOCSOCSOC
*/
private double pbrsoc;
/**
*
*/
private double macsfp;
/**
*
*/
private double csatmdp;
/**
* BMSBMSBMS
*/
private int bms;
/**
*
*/
private double cadc;
/**
* V3V3V3
*/
private double pbletvv3;
/**
*
*/
private double smv;
/**
*
*/
private double mvoab;
/**
*
*/
private double maxbt;
/**
*
*/
private double minbt;
/**
*
*/
private double pbac;
/**
*
*/
private String vs;
/**
*
*/
private String cs;
/**
*
*/
private String rs;
/**
* SOCSOCSOC
*/
private double soc;
/**
*
*/
private String resdwc;
/**
* EASEASEAS
*/
private String eas;
/**
* PTCPTCPTC
*/
private String ptc;
/**
* EPSEPSEPS
*/
private String eps;
/**
* ABSABSABS
*/
private String abs;
/**
* MCUMCUMCU
*/
private String mcu;
/**
*
*/
private String pbhs;
/**
*
*/
private String pbcs;
/**
*
*/
private String pbis;
/**
* DCDCDCDCDCDC
*/
private String dcdc;
/**
* CHGCHGCHG
*/
private String chg;
/**
*
*/
private byte chb;
/**
*
*/
private byte cub;
}

View File

@ -0,0 +1,105 @@
package com.muyu.domain;
import com.alibaba.fastjson2.annotation.JSONField;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.*;
import lombok.experimental.SuperBuilder;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.EqualsAndHashCode;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.List;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-electronic
* @nameCarFence
* @Date2024/9/17 16:08
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "电子围栏类")
@TableName(value = "car_fence",autoResultMap = true)
public class CarFence {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
/**
*
*/
private String name;
/**
* ID
*/
private Integer clazzId;
/**
*
*/
@TableField(exist = false)
private String clazzName;
/**
* ID
*/
private Integer typeId;
/**
*
*/
@TableField(exist = false)
private String typeName;
/**
*
*/
private String fenceText;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceStart;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceEnd;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy/MM/dd hh:mm:ss")
@JsonFormat(pattern = "yyyy/MM/dd hh:mm:ss")
private Date fenceCreate;
/**
* ID
*/
private Integer middleId;
/**
*
*/
@TableField(exist = false)
private List<CarFenceGroup> carFenceGroups;
public static CarFence carFenceBuild(CarFence carFence) {
return CarFence.builder()
.id(carFence.getId())
.name(carFence.getName())
.clazzId(carFence.getClazzId())
.typeId(carFence.getTypeId())
.fenceText(carFence.getFenceText())
.fenceStart(carFence.getFenceStart())
.fenceCreate(carFence.getFenceCreate())
.middleId(carFence.getMiddleId())
.build();
}
}

View File

@ -0,0 +1,40 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-electronic
* @nameCarFenceClazz
* @Date2024/9/17 16:41
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "电子业务类型")
@TableName(value = "car_fence_clazz",autoResultMap = true)
public class CarFenceClazz {
/**
* ID
*/
private Integer clazzId;
/**
*
*/
private String clazzName;
public static CarFenceClazz carFenceClazzBuild(CarFenceClazz carFenceClazz) {
return CarFenceClazz.builder()
.clazzId(carFenceClazz.getClazzId())
.clazzName(carFenceClazz.getClazzName())
.build();
}
}

View File

@ -0,0 +1,55 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-server-8
* @namecarFenceGroup
* @Date2024/9/22 10:20
*/
//weilabzu
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "电子围栏组类")
@TableName(value = "car_fence_group",autoResultMap = true)
public class CarFenceGroup {
/**
* ID
*/
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
/**
*
*/
private Integer priority;
/**
*
*/
private String status;
/**
*
*/
private String groupType;
public static CarFenceGroup carFenceBuild(CarFenceGroup carFenceGroup) {
return CarFenceGroup.builder()
.id(carFenceGroup.getId())
.priority(carFenceGroup.getPriority())
.status(carFenceGroup.getStatus())
.groupType(carFenceGroup.getGroupType())
.build();
}
}

View File

@ -0,0 +1,40 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-electronic
* @nameType
* @Date2024/9/17 16:40
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "电子围栏类型")
@TableName(value = "car_fence_type",autoResultMap = true)
public class CarFenceType {
/**
* ID
*/
private Integer typeId;
/**
*
*/
private String typeName;
public static CarFenceType carFenceTypeBuild(CarFenceType carFenceType) {
return CarFenceType.builder()
.typeId(carFenceType.getTypeId())
.typeName(carFenceType.getTypeName())
.build();
}
}

View File

@ -0,0 +1,150 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.domain.req.CarInformationAddReq;
import com.muyu.domain.req.CarInformationUpdReq;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.function.Supplier;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-server-8
* @nameCarInformation
* @Date2024/9/22 22:18
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "企业车辆管理实体类")
@TableName(value = "car_information",autoResultMap = true)
public class CarInformation {
/**
* ID
*/
@TableId(value = "car_information_id",type = IdType.AUTO)
private Long carInformationId;
/**
* VIN
*/
// @TableName(value = "car_information_VIN")
@TableField(value = "car_information_VIN")
private String carInformationVIN;
/**
*
*/
private String carInformationLicensePlate;
/**
*
*/
private String carInformationColor;
/**
*
*/
private String carInformationDriver;
/**
* ID
*/
@Schema(title = "车辆电子围栏外键ID", type = "Integer")
private Integer carInformationFence;
/**
*
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private Date carInformationExamineEnddata;
/**
* ID
*/
@Schema(title = "车辆类型外键ID", type = "Integer")
private Integer carInformationType;
/**
*
*/
private String carInformationBrand;
/**
* (0 1 )
*/
private Integer carInformationFocus;
/**
*
*/
private String carInformationMotorManufacturer;
/**
*
*/
private String carInformationMotorModel;
/**
*
*/
private String carInformationBatteryManufacturer;
/**
*
*/
private String carInformationBatteryModel;
/**
* (1.线 2.线 3. 4. 5.)
*/
private Integer carInformationState;
public static CarInformation carInformationBuilder(CarInformation carInformation) {
return CarInformation.builder()
.carInformationId(carInformation.getCarInformationId())
.carInformationLicensePlate(carInformation.getCarInformationLicensePlate())
.build();
}
public static CarInformation carInformationUpdBuilder(CarInformationUpdReq carInformation, Supplier<Long> idSupplier) {
return CarInformation.builder()
.carInformationId(idSupplier.get())
.carInformationBrand(carInformation.getCarInformationBrand())
.carInformationColor(carInformation.getCarInformationColor())
.carInformationDriver(carInformation.getCarInformationDriver())
.carInformationMotorManufacturer(carInformation.getCarInformationMotorManufacturer())
.carInformationMotorModel(carInformation.getCarInformationMotorModel())
.carInformationBatteryManufacturer(carInformation.getCarInformationBatteryManufacturer())
.carInformationBatteryModel(carInformation.getCarInformationBatteryModel())
.carInformationFence(carInformation.getCarInformationFence())
.carInformationType(carInformation.getCarInformationType())
.carInformationFocus(carInformation.getCarInformationFocus())
.carInformationMotorModel(carInformation.getCarInformationMotorModel())
.build();
}
public static CarInformation carInformationAddBuilder(CarInformationAddReq carInformation) {
return CarInformation.builder()
.carInformationVIN(carInformation.getCarInformationVIN())
.carInformationLicensePlate(carInformation.getCarInformationLicensePlate())
.carInformationBrand(carInformation.getCarInformationBrand())
.carInformationColor(carInformation.getCarInformationColor())
.carInformationDriver(carInformation.getCarInformationDriver())
.carInformationMotorManufacturer(carInformation.getCarInformationMotorManufacturer())
.carInformationMotorModel(carInformation.getCarInformationMotorModel())
.carInformationBatteryManufacturer(carInformation.getCarInformationBatteryManufacturer())
.carInformationBatteryModel(carInformation.getCarInformationBatteryModel())
.carInformationFence(carInformation.getCarInformationFence())
.carInformationType(carInformation.getCarInformationType())
.carInformationMotorModel(carInformation.getCarInformationMotorModel())
.build();
}
}

View File

@ -0,0 +1,135 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.function.Supplier;
/**
*
*
* @author 17353
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆报文模板实体类")
@TableName(value = "car_message", autoResultMap = true)
public class CarMessage {
//报文类型模块表
/**
*
*/
private Long messageTypeId;
/**
*
*/
private String messageTypeCode;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeBelongs;
//报文拆分位置主表
/**
*
*/
private Long carMessageId;
/**
*
*/
private Integer carMessageCartype;
/**
*
*/
private Integer carMessageType;
/**
*
*/
private Integer carMessageStartIndex;
/**
*
*/
private Integer carMessageEndIndex;
/**
* ( )
*/
private String messageTypeClass;
/**
* (0 1)
*/
private Integer carMessageState;
private String carMessageName;
/**
*
*
* @param carMessage
* @param supplier
* @return
*/
public static CarMessage carMessageUpdBuilder(CarMessage carMessage, Supplier<Long> supplier) {
return CarMessage.builder()
.messageTypeId(supplier.get())
.messageTypeCode(carMessage.messageTypeCode)
.messageTypeName(carMessage.messageTypeName)
.messageTypeBelongs(carMessage.messageTypeBelongs)
.carMessageId(carMessage.carMessageId)
.carMessageCartype(carMessage.carMessageCartype)
.carMessageType(carMessage.carMessageType)
.carMessageStartIndex(carMessage.carMessageStartIndex)
.carMessageEndIndex(carMessage.carMessageEndIndex)
.messageTypeClass(carMessage.messageTypeClass)
.carMessageState(carMessage.carMessageState)
.build();
}
/**
*
*
* @param carMessage
* @return
*/
public static CarMessage carMessageAddBuilder(CarMessage carMessage) {
return CarMessage.builder()
.messageTypeCode(carMessage.messageTypeCode)
.messageTypeName(carMessage.messageTypeName)
.messageTypeBelongs(carMessage.messageTypeBelongs)
.carMessageId(carMessage.carMessageId)
.carMessageCartype(carMessage.carMessageCartype)
.carMessageType(carMessage.carMessageType)
.carMessageStartIndex(carMessage.carMessageStartIndex)
.carMessageEndIndex(carMessage.carMessageEndIndex)
.messageTypeClass(carMessage.messageTypeClass)
.carMessageState(carMessage.carMessageState)
.build();
}
/*
private Long messageTypeId ;
private String messageTypeCode ;
private String messageTypeName ;
private String messageTypeBelongs ;
private String messageTypeClass ;
private Long carMessageId ;
private Integer carMessageCartype ;
private Integer carMessageType ;
private Integer carMessageStartIndex ;
private Integer carMessageEndIndex ;
private Integer carMessageState ;
*/
}

View File

@ -0,0 +1,43 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.warn.domain.car
* @Projectcloud-server-8
* @nameCarMessage
* @Date2024/9/22 3:07
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆报文所属类型")
@TableName(value = "car_message_type",autoResultMap = true)
public class CarMessageType {
/**
*
*/
private Integer messageTypeId ;
/**
*
*/
private String messageTypeCode ;
/**
*
*/
private String messageTypeName ;
/**
*
*/
private String messageTypeBelongs ;
}

View File

@ -0,0 +1,54 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-electronic
* @namecarMiddle
* @Date2024/9/20 16:30
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆电子组中间表")
@TableName(value = "car_middle",autoResultMap = true)
public class CarMiddle {
/**
* ID
*/
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
/**
* ID
*/
private Integer fenceGroupId;
/**
* ID
*/
private Long carInformationId;
public CarMiddle(Integer fenceGroupId, Long carInformationId) {
this.fenceGroupId = fenceGroupId;
this.carInformationId = carInformationId;
}
public static CarMiddle carMiddleBuilder(CarMiddle carMiddle) {
return CarMiddle.builder()
.id(carMiddle.getId())
.fenceGroupId(carMiddle.getFenceGroupId())
.carInformationId(carMiddle.getCarInformationId())
.build();
}
}

View File

@ -0,0 +1,54 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain
* @Projectcloud-server-8
* @namecarMiddleGroup
* @Date2024/9/22 10:35
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "围栏组中间表围栏")
@TableName(value = "car_middle_group",autoResultMap = true)
public class CarMiddleGroup {
/**
* ID
*/
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
/**
* ID
*/
private Integer carFenceId;
/**
*
*/
private Integer fenceGroupId;
public CarMiddleGroup(Integer carFenceId, Integer fenceGroupId) {
this.carFenceId = carFenceId;
this.fenceGroupId = fenceGroupId;
}
public static CarMiddleGroup carMiddleGroupBuilder(CarMiddleGroup carMiddleGroup) {
return CarMiddleGroup.builder()
.id(carMiddleGroup.getId())
.carFenceId(carMiddleGroup.getCarFenceId())
.fenceGroupId(carMiddleGroup.getFenceGroupId())
.build();
}
}

View File

@ -0,0 +1,39 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-server-8
* @nameCarType
* @Date2024/9/21 19:01
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_type",autoResultMap = true)
@Tag(name ="车辆类型表")
public class CarType {
/**
* ID
*/
private long carTypeId;
/**
*
*/
private String carTypeName;
/**
* ID
*/
private long carTypeRules;
}

View File

@ -0,0 +1,122 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.domain.req.FaultCodeAddReq;
import com.muyu.domain.req.FaultCodeUpdReq;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-faultmanage
* @nameFaultCode
* @Date2024/9/17 14:55
*/
/**
*
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_faultcode",autoResultMap = true)
@Tag(name = "故障码")
public class FaultCode {
/**
*Id
*/
@TableId(value = "faultcode_id",type = IdType.AUTO)
private long faultcodeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultcodeNumber;
/**
*
*/
private String faultGroup;
/**
*
*/
private String faultBit;
/**
*
*/
private String faultValue;
/**
*
*/
private Integer isWarning;
/**
*
*/
@TableField(exist = false)
private String faulttypeName;
/**
*
*/
@TableField(exist = false)
private String messageTypeName;
/**
*
*/
@TableField(exist = false)
private String messageTypeCode;
/**
*
*/
@TableField(exist = false)
private String messageTypeBelongs;
public static FaultCode addfaultcode(FaultCodeAddReq faultCodeAddReq){
return FaultCode.builder()
.faultcodeId(0)
.messageTypeId(faultCodeAddReq.getMessageTypeId())
.faultcodeNumber(faultCodeAddReq.getFaultcodeNumber())
.faultGroup(faultCodeAddReq.getFaultGroup())
.faultBit(faultCodeAddReq.getFaultBit())
.faultValue(faultCodeAddReq.getFaultValue())
.isWarning(faultCodeAddReq.getIsWarning())
.build();
}
public static FaultCode updfaultcode(FaultCodeUpdReq faultCodeUpdReq){
return FaultCode.builder()
.faultcodeId(0)
.messageTypeId(faultCodeUpdReq.getMessageTypeId())
.faultcodeNumber(faultCodeUpdReq.getFaultcodeNumber())
.faultGroup(faultCodeUpdReq.getFaultGroup())
.faultBit(faultCodeUpdReq.getFaultBit())
.faultValue(faultCodeUpdReq.getFaultValue())
.isWarning(faultCodeUpdReq.getIsWarning())
.build();
}
public static FaultCode faultCodeBuilder(FaultCode faultCode) {
return FaultCode.builder()
.faultcodeId(faultCode.getFaultcodeId())
.messageTypeId(faultCode.getMessageTypeId())
.faultcodeNumber(faultCode.getFaultcodeNumber())
.faultGroup(faultCode.faultGroup)
.faultBit(faultCode.faultBit)
.faultValue(faultCode.faultValue)
.isWarning(faultCode.isWarning)
.build();
}
}

View File

@ -0,0 +1,95 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.domain.req.FaultConditionAddReq;
import com.muyu.domain.req.FaultConditionUpdReq;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.math.BigDecimal;
import java.util.function.Supplier;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-server-8
* @nameFaultCondition
* @Date2024/9/21 19:51
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_fault_condition",autoResultMap = true)
@Tag(name = "故障规则")
public class FaultCondition {
/**
* Id
*/
@TableId(value = "carcondition_id",type = IdType.AUTO)
private long carconditionId;
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultconditionIdentification;
/**
*
*/
private BigDecimal faultconditionParameter;
/**
*
*/
@TableField(exist = false)
private String carTypeName;
/**
*
*/
@TableField(exist = false)
private String messageTypeName;
/**
*
*/
@TableField(exist = false)
private String messageTypeCode;
public static FaultCondition faultConditionadd(FaultConditionAddReq faultConditionAddReq){
return FaultCondition.builder()
.carTypeId(faultConditionAddReq.getCarTypeId())
.messageTypeId(faultConditionAddReq.getMessageTypeId())
.faultconditionIdentification(faultConditionAddReq.getFaultconditionIdentification())
.faultconditionParameter(faultConditionAddReq.getFaultconditionParameter())
.build();
}
public static FaultCondition faultConditionupd(FaultConditionUpdReq faultConditionUpdReq, Supplier<Long> idSupplier){
return FaultCondition.builder()
.carconditionId(faultConditionUpdReq.getCarconditionId())
.carTypeId(faultConditionUpdReq.getCarTypeId())
.messageTypeId(faultConditionUpdReq.getMessageTypeId())
.faultconditionIdentification(faultConditionUpdReq.getFaultconditionIdentification())
.faultconditionParameter(faultConditionUpdReq.getFaultconditionParameter())
.build();
}
}

View File

@ -0,0 +1,62 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.domain.req.FaultCodeAddReq;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-faultmanage
* @nameFaultLabel
* @Date2024/9/17 15:06
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_fault_label",autoResultMap = true)
@Tag(name = "故障标签")
public class FaultLabel {
/**
*
*/
@TableId(value = "message_type_id",type = IdType.AUTO)
private long messageTypeId;
/**
*
*/
private String messageTypeCode;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeBelongs;
public static FaultLabel addfaultLabel(FaultCodeAddReq faultCodeAddReq){
return FaultLabel.builder()
.messageTypeId(0)
.messageTypeId(faultCodeAddReq.getMessageTypeId())
.messageTypeCode(faultCodeAddReq.getMessageTypeCode())
.messageTypeName(faultCodeAddReq.getMessageTypeName())
.messageTypeBelongs(faultCodeAddReq.getMessageTypeBelongs())
.build();
}
}

View File

@ -0,0 +1,73 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-server-8
* @nameFaultLog
* @Date2024/9/19 0:42
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_fault_log",autoResultMap = true)
@Tag(name = "故障日志")
public class FaultLog {
/**
* Id
*/
@TableId(value = "log_id",type = IdType.AUTO)
private long logId;
/**
* Id
*/
private long faultcodeId;
/**
* Id
*/
private long carInformationId;
/**
* VIN
*/
private String carVin;
/**
*
*/
private String faultcodeNumber;
/**
* VIN
*/
private String carInformationVIN;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "开始报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date startwarningTime;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "结束报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date endwarningTime;
}

View File

@ -0,0 +1,34 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-faultmanage
* @nameFaultType
* @Date2024/9/17 15:03
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_fault_type",autoResultMap = true)
public class FaultType {
/**
*Id
*/
@TableId(value = "faulttype_id",type = IdType.AUTO)
private long faulttypeId;
/**
*
*/
private String faulttypeName;
}

View File

@ -0,0 +1,40 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.firmmanage.domain
* @Projectcloud-server-8
* @nameFirm
* @Date2024/9/27 12:29
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
public class Firm {
/**
* ID
*/
@TableId(value = "firm_id")
private Long firmId;
/**
*
*/
@TableField(exist = false)
private String firmName;
/**
*
*/
private String databaseName;
}

View File

@ -0,0 +1,17 @@
package com.muyu.domain;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class KafKaData {
private String key;
private String type;
private String label;
private String value;
}

View File

@ -0,0 +1,53 @@
package com.muyu.domain ;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* ()
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameImageText
* @Date2024/9/18 9:27
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("xml")
@Tag(name = "图文信息")
public class NewsMessage {
// <ToUserName><![CDATA[toUser]]></ToUserName>
// <FromUserName><![CDATA[fromUser]]></FromUserName>
// <CreateTime>12345678</CreateTime>
// <MsgType><![CDATA[news]]></MsgType>
// <ArticleCount>1</ArticleCount>
// <Articles>
// <item>
// <Title><![CDATA[title1]]></Title>
// <Description><![CDATA[description1]]></Description>
// <PicUrl><![CDATA[picurl]]></PicUrl>
// <Url><![CDATA[url]]></Url>
// </item>
// </Articles>
@XStreamAlias("ToUserName")
private String toUserName ;
@XStreamAlias("FromUserName")
private String fromUserName ;
@XStreamAlias("CreateTime")
private long createTime ;
@XStreamAlias("MsgType")
private String msgType ;
@XStreamAlias("ArticleCount")
private Integer articleCount ;
@XStreamAlias("Articles")
private List<Articles> articles ;
}

View File

@ -0,0 +1,119 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.common.core.web.domain.BaseEntity;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.firmmanage.domain
* @Projectcloud-server-8
* @nameSysUser
* @Date2024/9/28 22:37
*/
@EqualsAndHashCode(callSuper = true)
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "用户信息")
@TableName("sys_user")
public class SysUser extends BaseEntity {
/**
* ID
*/
@TableId(value = "user_id")
private Long userId;
/**
* ID
*/
private Long deptId;
/**
*
*/
private String userName;
/**
*
*/
private String nickName;
/**
* 00
*/
private String userType;
/**
*
*/
private String email;
/**
*
*/
private String phonenumber;
/**
* 0 1 2
*/
private Integer sex;
/**
*
*/
private String avatar;
/**
*
*/
private String password;
/**
* 0 1
*/
private Integer status;
/**
* 0 2
*/
private String delFlag;
/**
* IP
*/
private String loginIp;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date loginDate;
/**
*
*/
private String databaseName;
/**
* ID
*/
private Long firmId;
/**
*
*/
@TableField(exist = false)
private String firmName;
}

View File

@ -0,0 +1,43 @@
package com.muyu.common.wechat.domain;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* ()
* @Author
* @Packagecom.muyu.wxapplication.massage
* @ProjectWXApplication
* @nameTextMessage
* @Date2024/9/18 11:33
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@XStreamAlias("xml")
@Tag(name = "文本信息")
public class TextMessage {
//起一个别名 因为我们微信返回信息与java代码格式规范发生冲突
//微信格式 ToUserName
//JAVA格式 toUserName
@XStreamAlias("ToUserName")
private String toUserName;
@XStreamAlias("FromUserName")
private String fromUserName;
@XStreamAlias("CreateTime")
private long createTime;
@XStreamAlias("MsgType")
private String msgType;
@XStreamAlias("Content")
private String content;
}
// <ToUserName><![CDATA[toUser]]></ToUserName>
// <FromUserName><![CDATA[fromUser]]></FromUserName>
// <CreateTime>12345678</CreateTime>
// <MsgType><![CDATA[text]]></MsgType>
// <Content><![CDATA[你好]]></Content>

View File

@ -0,0 +1,32 @@
package com.muyu.domain;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain
* @Projectcloud-server-8
* @nameVehicle
* @Date2024/9/20 20:44
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "故障查询信息结果返回对象")
public class Vehicle {
/**
* VIN
*/
private String VIN;
/**
*
*/
private String faultmessage;
}

View File

@ -0,0 +1,107 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.common.core.annotation.Excel;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
*
* @Author
* @Packagecom.muyu.warn.domain
* @Projectcloud-server-8
* @nameWarnLogs
* @Date2024/9/20 7:11
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("warn_logs")
@Tag(name = "预警日志")
public class WarnLogs {
/**
* id
*/
@Excel(name = "预警日志id", cellType = Excel.ColumnType.NUMERIC)
@TableId(type = IdType.AUTO)
private Long id;
/**
* vin
*/
@Excel(name = "车辆vin码")
private String vin;
/**
* id
*/
@Excel(name = "规则id")
private Long warnRuleId;
/**
*
*/
@Excel(name = "开始时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date startTime ;
/**
*
*/
@Excel(name = "结束时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date endTime ;
/**
*
*/
@Excel(name = "最大值")
private Long maxValue ;
/**
*
*/
@Excel(name = "最小值")
private Long minValue ;
/**
*
*/
@Excel(name = "平均值")
private Long avgValue ;
/**
*
*/
@Excel(name = "中位数")
private Long medianValue ;
/**
*
*/
@Excel(name = "是否发送预警")
private Long status ;
// /**
// * 创建人
// */
// @Excel(name = "创建人")
// private String createBy ;
// /**
// * 创建时间
// */
// @Excel(name = "创建时间")
// private String createTime ;
// /**
// * 更新人
// */
// @Excel(name = "更新人")
// private String updateBy ;
// /**
// * 更新时间
// */
// @Excel(name = "更新时间")
// private String updateTime ;
}

View File

@ -0,0 +1,53 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.annotation.Excel;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.warn.domain
* @Projectcloud-server-8
* @nameWarnRule
* @Date2024/9/20 7:20
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("warn_rule")
@Tag(name = "预警规则")
public class WarnRule {
@TableId(type = IdType.AUTO)
private Long id;
private String ruleName;
private Long strategyId;
private Long msgTypeId;
private Long slideTime;
private Long slideFrequency;
private Long maxValue;
private Long minValue;
// /**
// * 创建人
// */
// private String createBy ;
// /**
// * 创建时间
// */
// private String createTime ;
// /**
// * 更新人
// */
// private String updateBy ;
// /**
// * 更新时间
// */
// private String updateTime ;
}

View File

@ -0,0 +1,53 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.annotation.Excel;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.warn.domain
* @Projectcloud-server-8
* @nameWarnStrategy
* @Date2024/9/20 7:27
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("warn_strategy")
@Tag(name = "预警策略")
public class WarnStrategy {
/**
* Id
*/
@TableId( type = IdType.AUTO)
private Long id;
private Long carTypeId ;
private String strategyName ;
private Long msgId ;
// /**
// * 创建人
// */
// private String createBy ;
// /**
// * 创建时间
// */
// private String createTime ;
// /**
// * 更新人
// */
// private String updateBy ;
// /**
// * 更新时间
// */
// private String updateTime ;
}

View File

@ -0,0 +1,81 @@
package com.muyu.domain.message;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.message
* @Projectcloud-server-8
* @nameMessage
* @Date2024/9/22 10:40
*/
@Tag(name = "站内信")
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "car_fault_message",autoResultMap = true)
public class Message {
/**
* id
*/
@TableId(value = "id",type = IdType.AUTO)
private long id;
/**
*
*/
private String sender;
/**
*
*/
private String receiver;
/**
*
*/
private String content;
/**
*
*/
private Integer status;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "消息创建时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date createTime;
/**
* Id
*/
private long userId;
public static Message messageBuilder(Message message) {
return Message.builder()
.id(message.getId())
.sender(message.getSender())
.receiver(message.getReceiver())
.content(message.getContent())
.status(message.getStatus())
.createTime(message.getCreateTime())
.userId(message.getUserId())
.build();
}
}

View File

@ -0,0 +1,32 @@
package com.muyu.domain.message;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.message
* @Projectcloud-server-8
* @nameMessageReq
* @Date2024/9/22 11:00
*/
@Tag(name = "消息状态")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class MessageReq {
/**
*
*/
private Integer status;
/**
* Id
*/
private long userId;
}

View File

@ -0,0 +1,51 @@
package com.muyu.domain.message;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.message
* @Projectcloud-server-8
* @nameMessageReq
* @Date2024/9/22 11:00
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "消息发送参数")
public class MessageSendReq {
/**
*
*/
private String sender;
/**
*
*/
private String receiver;
/**
*
*/
private String content;
/**
* Id
*/
private long userId;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "消息创建时间",defaultValue = "2024-8-9 10:47:57",type = "String")
private Date createTime;
}

View File

@ -0,0 +1,29 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.req
* @Projectcloud-server-8
* @nameCarFenceGroupReq
* @Date2024/9/24 14:36
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆电子围栏组请求对象")
public class CarFenceGroupReq {
/**
* ID
*/
private Integer carId;
/**
* ID
*/
private Integer id;
}

View File

@ -0,0 +1,46 @@
package com.muyu.domain.req;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.req
* @Projectcloud-electronic
* @nameCarFenceReq
* @Date2024/9/17 16:26
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "电子围栏请求对象")
public class CarFenceReq {
/**
*
*/
private String name;
/**
* ID
*/
private String clazzId;
/**
* ID
*/
private String typeName;
/**
*
*/
@Schema(title = "当前页数", type = "Integer", defaultValue = "1", description = "当前页数")
private Integer pageNum=1;
/**
*
*/
@Schema(title = "分页条数", type = "Integer", defaultValue = "10", description = "每页有多少条")
private Integer pageSize=10;
}

View File

@ -0,0 +1,29 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.req
* @Projectcloud-server-8
* @nameCarFenceGroupDel
* @Date2024/9/24 11:49
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "围栏组电子围栏请求对象")
public class CarGroupIdReq {
/**
* Id
*/
private Integer ids;
/**
* ID
*/
private Integer id;
}

View File

@ -0,0 +1,35 @@
package com.muyu.domain.req;
import com.muyu.domain.CarFenceGroup;
import com.muyu.domain.CarInformation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.req
* @Projectcloud-server-8
* @nameCarGroupReq
* @Date2024/9/23 12:01
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆电子围栏请求对象")
public class CarGroupReq {
/**
*
*/
private List<CarInformation> carInformations;
/**
*
*/
private List<CarFenceGroup> carFenceGroups;
}

View File

@ -0,0 +1,86 @@
package com.muyu.domain.req;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆管理信息添加请求对象")
public class CarInformationAddReq {
/**
* VIN
*/
private String carInformationVIN;
/**
*
*/
private String carInformationLicensePlate;
/**
*
*/
private String carInformationBrand;
/**
*
*/
private String carInformationColor;
/**
*
*/
private String carInformationDriver;
/**
*
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private String carInformationExamineEnddata;
/**
*
*/
private String carInformationMotorManufacturer;
/**
*
*/
private String carInformationMotorModel;
/**
*
*/
private String carInformationBatteryManufacturer;
/**
*
*/
private String carInformationBatteryModel;
/**
* ID
*/
private Integer carInformationFence;
/**
* ID
*/
private Integer carInformationType;
}

View File

@ -0,0 +1,112 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name="车辆管理列表请求对象")
public class CarInformationListReq {
/**
* VIN
*/
@Schema(
description = "车辆唯一VIN",
type = "String"
)
private String carInformationVIN;
/**
* ID
*/
@Schema(
description = "车辆类型ID",
type = "Interger"
)
private Integer carTypeId;
/**
* ID
*/
@Schema(
description = "车辆电子围栏外键ID",
type = "Interger"
)
private Integer carInformationFence;
/**
* (1.线 2.线 3. 4. 5.)
*/
@Schema(
description = "启用状态(1.在线 2.离线 3.已断开 4.待连接 5.维修中)",
type = "Interger"
)
private Integer carInformationState;
/**
*
*/
@Schema(
description = "车辆电机厂商",
type = "String"
)
private String carInformationMotorManufacturer;
/**
*
*/
@Schema(
description = "车辆电机型号",
type = "String"
)
private String carInformationMotorModel;
/**
*
*/
@Schema(
description = "车辆电池厂商",
type = "String"
)
private String carInformationBatteryManufacturer;
/**
*
*/
@Schema(
description = "车辆电池型号",
type = "String"
)
private String carInformationBatteryModel;
//分页页数
private Integer pageNum = 1;
//分页条数
private Integer pageSize = 5;
}

View File

@ -0,0 +1,102 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "车辆管理修改操作请求对象")
public class CarInformationUpdReq {
/**
* ID
*/
@Schema(title = "车辆管理主键", type = "Long")
private Long carInformationId;
/**
*
*/
@Schema(title = "车辆品牌", type = "String")
private String carInformationBrand;
/**
*
*/
@Schema(title = "车辆颜色", type = "String")
private String carInformationColor;
/**
*
*/
@Schema(title = "车辆驾驶员", type = "String")
private String carInformationDriver;
/**
*
*/
@Schema(title = "车辆电机厂商", type = "String")
private String carInformationMotorManufacturer;
/**
*
*/
@Schema(title = "车辆电机型号", type = "String")
private String carInformationMotorModel;
/**
*
*/
@Schema(title = "车辆电池厂商", type = "String")
private String carInformationBatteryManufacturer;
/**
*
*/
@Schema(title = "车辆电池型号", type = "String")
private String carInformationBatteryModel;
/**
* ID
*/
@Schema(title = "车辆电子围栏外键ID", type = "Integer")
private Integer carInformationFence;
/**
* ID
*/
@Schema(title = "车辆类型外键ID", type = "Integer")
private Integer carInformationType;
/**
* (0 1 )
*/
@Schema(title = "是否重点车辆 (0否默认 1是 )", type = "Integer")
private Integer carInformationFocus;
/**
* (1.线 2.线 3. 4. 5.)
*/
@Schema(title = "启用状态(1.在线 2.离线 3.已断开 4.待连接 5.维修中)", type = "Integer")
private Integer carInformationState;
}

View File

@ -0,0 +1,71 @@
package com.muyu.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultCodeAddReq
* @Date2024/9/18 10:12
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultCodeAddReq {
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeCode;
/**
*
*/
private String faultcodeNumber;
/**
* Id
*/
private long faulttypeId;
/**
*
*/
private Integer isWarning;
/**
*
*/
private String faultContent;
/**
*
*/
private String faultGroup;
/**
*
*/
private String faultBit;
/**
*
*/
private String faultValue;
/**
*
*/
private String messageTypeBelongs;
}

View File

@ -0,0 +1,43 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-faultmanage
* @nameFaultCodeListReq
* @Date2024/9/17 15:55
*/
@Tag(name = "故障码列表请求对象")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultCodeListReq {
/**
*
*/
private String faultcodeNumber;
/**
*
*/
private String faultBit;
/**
* 1
*/
private Integer pageNum=1;
/**
*
*/
private Integer pageSize=10;
}

View File

@ -0,0 +1,81 @@
package com.muyu.domain.req;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultCodeAddReq
* @Date2024/9/18 10:12
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultCodeUpdReq {
/**
*Id
*/
private long faultcodeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeCode;
/**
*
*/
private String faultcodeNumber;
/**
* Id
*/
private long faulttypeId;
/**
*
*/
private Integer isWarning;
/**
*
*/
private String faultContent;
/**
*
*/
private Integer faultStatus;
/**
*
*/
private String faultGroup;
/**
*
*/
private String faultBit;
/**
*
*/
private String faultValue;
/**
*
*/
private String messageTypeBelongs;
}

View File

@ -0,0 +1,46 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultConditionAddReq
* @Date2024/9/21 21:02
*/
@Tag(name = "故障规则制定请求对象")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultConditionAddReq {
/**
* Id
*/
private long carconditionId;
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultconditionIdentification;
/**
*
*/
private BigDecimal faultconditionParameter;
}

View File

@ -0,0 +1,43 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultCondition
* @Date2024/9/21 20:02
*/
@Tag(name = "故障规则列表请求对象")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultConditionListReq {
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
* 1
*/
private Integer pageNum=1;
/**
*
*/
private Integer pageSize=10;
}

View File

@ -0,0 +1,46 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultConditionUpdReq
* @Date2024/9/22 9:38
*/
@Tag(name = "故障规则修改请求对象")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultConditionUpdReq {
/**
* Id
*/
private long carconditionId;
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultconditionIdentification;
/**
*
*/
private BigDecimal faultconditionParameter;
}

View File

@ -0,0 +1,58 @@
package com.muyu.domain.req;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.req
* @Projectcloud-server-8
* @nameFaultLogReq
* @Date2024/9/20 9:38
*/
@Tag(name = "故障日志列表请求对象")
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class FaultLogListReq {
/**
* Id
*/
private long faultcodeId;
/**
* VIN
*/
private String carVin;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "开始报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date startwarningTime;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "结束报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date endwarningTime;
/**
* 1
*/
private Integer pageNum=1;
/**
*
*/
private Integer pageSize=10;
}

View File

@ -0,0 +1,34 @@
package com.muyu.domain.req;
import com.muyu.domain.CarFence;
import com.muyu.domain.CarFenceGroup;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.req
* @Projectcloud-server-8
* @nameFenceGroupReq
* @Date2024/9/24 1:09
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "围栏组围栏请求对象")
public class FenceGroupReq {
/**
*
*/
private List<CarFence> carFences;
/**
*
*/
private List<CarFenceGroup> carFenceGroups;
}

View File

@ -0,0 +1,37 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authorweiran
* @Packagecom.muyu.firmmanage.domain.req
* @Projectcloud-server-8
* @nameFirmListReq
* @Date2024/9/27 19:19
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "公司信息请求对象",description = "公司信息请求对象")
public class FirmListReq {
/**
*
*/
private String firmName;
/**
* 1
*/
private Integer pageNum=1;
/**
*
*/
private Integer pageSize=10;
}

View File

@ -0,0 +1,38 @@
package com.muyu.domain.req;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.warn.domain.req
* @Projectcloud-server-8
* @nameWarnStrategyReq
* @Date2024/9/25 10:28
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "预警策略请求对象")
public class WarnStrategyReq {
/**
* id
*/
private Long id;
/**
*
*/
private String carTypeId;
/**
*
*/
private String strategyName;
}

View File

@ -0,0 +1,97 @@
package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.domain.CarFenceGroup;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.List;
/**
* -
* @Authoryang
* @Packagecom.muyu.domain.resq
* @Projectcloud-server-8
* @nameCarFenceGroupReq
* @Date2024/9/24 1:45
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "电子围栏-围栏组列表")
public class CarFenceGroupResp {
/**
*
*/
private Integer id;
/**
*
*/
private String name;
/**
* ID
*/
private Integer clazzId;
/**
*
*/
@TableField(exist = false)
private String clazzName;
/**
* ID
*/
private Integer typeId;
/**
*
*/
@TableField(exist = false)
private String typeName;
/**
*
*/
private String fenceText;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceStart;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceEnd;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy/MM/dd hh:mm:ss")
@JsonFormat(pattern = "yyyy/MM/dd hh:mm:ss")
private Date fenceCreate;
/**
* ID
*/
private Integer middleId;
/**
*
*/
@TableField(exist = false)
private List<CarFenceGroup> carFenceGroups;
/**
*
*/
private Integer priority;
/**
*
*/
private String status;
/**
*
*/
private String groupType;
}

View File

@ -0,0 +1,50 @@
package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* -
* @Authoryang
* @Packagecom.muyu.domain.resq
* @Projectcloud-server-8
* @nameCarFenceGroupsResq
* @Date2024/9/25 21:08
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆-围栏组列表")
public class CarFenceGroupsResp {
/**
* ID
*/
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
/**
*
*/
private Integer priority;
/**
*
*/
private String status;
/**
*
*/
private String groupType;
/**
* VIN
*/
// @TableName(value = "car_information_VIN")
private String carInformationLicensePlate;
/**
*
*/
private String fenceText;
}

View File

@ -0,0 +1,77 @@
package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.domain.CarFence;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.resq
* @Projectcloud-electronic
* @nameCarFenceResq
* @Date2024/9/17 16:35
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "电子围栏列表")
@TableName(value = "car_fence",autoResultMap = true)
public class CarFenceResp {
/**
*
*/
private Integer id;
/**
*
*/
private String name;
/**
*
*/
private String clazzName;
/**
*
*/
private String typeName;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceStart;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy-MM-dd hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")
private Date fenceEnd;
/**
*
*/
@DateTimeFormat(fallbackPatterns = "yyyy/MM/dd hh:mm:ss")
@JsonFormat(pattern = "yyyy/MM/dd hh:mm:ss")
private Date fenceCreate;
public static CarFenceResp carFenceResqListBuilder(CarFence etlDataScore) {
return CarFenceResp.builder()
.id(etlDataScore.getId())
.name(etlDataScore.getName())
.clazzName(etlDataScore.getClazzName())
.typeName(etlDataScore.getTypeName())
.fenceStart(etlDataScore.getFenceStart())
.fenceEnd(etlDataScore.getFenceEnd())
.fenceCreate(etlDataScore.getFenceCreate())
.build();
}
}

View File

@ -0,0 +1,128 @@
package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
*
* @Authoryang
* @Packagecom.muyu.domain.resq
* @Projectcloud-server-8
* @nameCarInformationResp
* @Date2024/9/28 12:08
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆基础信息列表")
public class CarInformationResp {
/**
* ID
*/
@TableId(value = "car_information_id",type = IdType.AUTO)
private Long carInformationId;
/**
* VIN
*/
// @TableName(value = "car_information_VIN")
@TableField(value = "car_information_VIN")
private String carInformationVin;
/**
*
*/
private String carInformationLicensePlate;
/**
*
*/
private String carInformationColor;
/**
*
*/
private String carInformationDriver;
/**
* ID
*/
private Integer carInformationFence;
/**
*
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private Date carInformationExamineEnddata;
/**
* ID
*/
private Integer carInformationType;
/**
*
*/
private String carInformationBrand;
/**
* (0 1 )
*/
private Integer carInformationFocus;
/**
*
*/
private String carInformationMotorManufacturer;
/**
*
*/
private String carInformationMotorModel;
/**
*
*/
private String carInformationBatteryManufacturer;
/**
*
*/
private String carInformationBatteryModel;
/**
* (1.线 2.线 3. 4. 5.)
*/
private Integer carInformationState;
//车辆类型表
/**
* ID
*/
@TableField(value = "car_information_type")
private Integer carTypeId;
/**
*
*/
@TableField(exist = false)
private String carTypeName;
/**
* ID
*/
private long carTypeRules;
//电子围栏
/**
*ID
*/
private Integer id;
/**
*
*/
private String name;
}

View File

@ -0,0 +1,57 @@
package com.muyu.domain.resp;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* ()
* @Author
* @Packagecom.muyu.warn.domain.car
* @Projectcloud-server-8
* @nameresp
* @Date2024/9/22 7:12
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆报文信息")
public class CarMessageResp {
/**
*
*/
private Integer carMessageId ;
/**
*
*/
private Integer carMessageCartype ;
/**
*
*/
private Integer carMessageType ;
/**
*
*/
private String messageTypeName ;
/**
*
*/
private Integer carMessageStartIndex ;
/**
*
*/
private Integer carMessageEndIndex ;
/**
* ( )
*/
private String messageTypeClass ;
/**
* (0 1)
*/
private Integer carMessageState ;
}

View File

@ -0,0 +1,92 @@
package com.muyu.domain.resp;
import com.muyu.domain.FaultCode;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.resp
* @Projectcloud-faultmanage
* @nameFaultCodeListResp
* @Date2024/9/17 15:41
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name="故障码信息响应对象",description = "故障码查询的响应结果")
public class FaultCodeListResp {
/**
*Id
*/
private long faultcodeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultcodeNumber;
/**
*
*/
private String faultGroup;
/**
*
*/
private String faultBit;
/**
*
*/
private String faultValue;
/**
*
*/
private Integer isWarning;
/**
*
*/
private String faulttypeName;
/**
*
*/
private String messageTypeCode;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeBelongs;
/**
*
* @param faultCode
* @return
*/
public static FaultCodeListResp faultCodeListResp(FaultCode faultCode){
return FaultCodeListResp.builder()
.faultcodeId(faultCode.getFaultcodeId())
.messageTypeId(faultCode.getMessageTypeId())
.faultcodeNumber(faultCode.getFaultcodeNumber())
.faultGroup(faultCode.getFaultGroup())
.faultBit(faultCode.getFaultBit())
.faultValue(faultCode.getFaultValue())
.isWarning(faultCode.getIsWarning())
.faulttypeName(faultCode.getFaulttypeName())
.messageTypeName(faultCode.getMessageTypeName())
.messageTypeCode(faultCode.getMessageTypeCode())
.messageTypeBelongs(faultCode.getMessageTypeBelongs())
.build();
}
}

View File

@ -0,0 +1,43 @@
package com.muyu.domain.resp;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.List;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.resp
* @Projectcloud-faultmanage
* @nameFaultCodeTotalListResp
* @Date2024/9/17 15:44
*/
@Data
@SuperBuilder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name="故障码数据总数列表",description = "数据和总数的响应")
public class FaultCodeTotalListResp {
/**
*
*/
private List<FaultCodeListResp> faultCodeListRespList;
private long total;
public static FaultCodeTotalListResp faultCodeTotalListResp(List<FaultCodeListResp> faultCodeListRespList,long total){
FaultCodeTotalListResp faultCodeTotalListResp = new FaultCodeTotalListResp();
faultCodeTotalListResp.setFaultCodeListRespList(faultCodeListRespList);
faultCodeTotalListResp.setTotal(total);
return faultCodeTotalListResp;
}
}

View File

@ -0,0 +1,76 @@
package com.muyu.domain.resp;
import com.muyu.domain.FaultCondition;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import java.math.BigDecimal;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.resp
* @Projectcloud-server-8
* @nameFaultConditionResp
* @Date2024/9/21 19:59
*/
@Data
@Builder
@AllArgsConstructor
@Tag(name="故障规则信息响应对象",description = "故障规则查询的响应结果")
public class FaultConditionListResp {
/**
* Id
*/
private long carconditionId;
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultconditionIdentification;
/**
*
*/
private BigDecimal faultconditionParameter;
/**
*
*/
private String carTypeName;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeCode;
/**
*
* @param faultCondition
* @return
*/
public static FaultConditionListResp faultConditionListResp(FaultCondition faultCondition){
return FaultConditionListResp.builder()
.carconditionId(faultCondition.getCarconditionId())
.carTypeId(faultCondition.getCarTypeId())
.messageTypeId(faultCondition.getMessageTypeId())
.faultconditionParameter(faultCondition.getFaultconditionParameter())
.faultconditionIdentification(faultCondition.getFaultconditionIdentification())
.carTypeName(faultCondition.getCarTypeName())
.messageTypeName(faultCondition.getMessageTypeName())
.messageTypeCode(faultCondition.getMessageTypeCode())
.build();
}
}

View File

@ -0,0 +1,58 @@
package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
* @Authoryang
* @Packagecom.muyu.domain.resp
* @Projectcloud-server-8
* @nameFaultConditionResp
* @Date2024/9/28 16:53
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name="故障规则表",description = "数据响应")
public class FaultConditionResp {
/**
* Id
*/
@TableId(value = "carcondition_id",type = IdType.AUTO)
private long carconditionId;
/**
* Id
*/
private long carTypeId;
/**
*Id
*/
private long messageTypeId;
/**
*
*/
private String faultconditionIdentification;
/**
*
*/
private BigDecimal faultconditionParameter;
/**
*
*/
private String carTypeName;
/**
*
*/
private String messageTypeName;
/**
*
*/
private String messageTypeCode;
}

View File

@ -0,0 +1,49 @@
package com.muyu.domain.resp;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.List;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.resp
* @Projectcloud-server-8
* @nameFaultConditionTotalListResp
* @Date2024/9/21 20:00
*/
@Data
@SuperBuilder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name="故障规则数据总数列表",description = "数据和总数的响应")
public class FaultConditionTotalListResp {
/**
*
*/
private List<FaultConditionListResp> faultConditionListRespList;
/**
*
*/
private long total;
/**
*
* @param faultConditionListRespList
* @param total
* @return
*/
public static FaultConditionTotalListResp faultConditionTotalListResp(List<FaultConditionListResp> faultConditionListRespList,long total){
FaultConditionTotalListResp faultConditionTotalListResp = new FaultConditionTotalListResp();
faultConditionTotalListResp.setFaultConditionListRespList(faultConditionListRespList);
faultConditionTotalListResp.setTotal(total);
return faultConditionTotalListResp;
}
}

View File

@ -0,0 +1,83 @@
package com.muyu.domain.resp;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.domain.FaultLog;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import java.util.Date;
/**
*
* @Authorweiran
* @Packagecom.muyu.cloud.faultmanage.domain.resp
* @Projectcloud-server-8
* @nameFaultLogResp
* @Date2024/9/20 9:43
*/
@Data
@Builder
@AllArgsConstructor
@Tag(name="故障日志信息响应对象",description = "故障日志的响应结果")
public class FaultLogListResp {
/**
* Id
*/
private long logId;
/**
* Id
*/
private long faultcodeId;
/**
* Id
*/
private long carInformationId;
/**
* VIN
*/
private String carVin;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "开始报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date startwarningTime;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "结束报警时间",defaultValue = "2024-8-9 10:47:57",type = "Date")
private Date endwarningTime;
/**
*
*/
private String faultcodeNumber;
/**
* vin
*/
private String carInformationVIN;
/**
*
* @param faultLog
* @return
*/
public static FaultLogListResp faultLogListResp(FaultLog faultLog){
return FaultLogListResp.builder()
.logId(faultLog.getLogId())
.faultcodeId(faultLog.getFaultcodeId())
.carInformationId(faultLog.getCarInformationId())
.carVin(faultLog.getCarVin())
.startwarningTime(faultLog.getStartwarningTime())
.endwarningTime(faultLog.getEndwarningTime())
.faultcodeNumber(faultLog.getFaultcodeNumber())
.carInformationVIN(faultLog.getCarInformationVIN())
.build();
}
}

Some files were not shown because too many files have changed in this diff Show More