Compare commits

...

80 Commits

Author SHA1 Message Date
微醺 4ca2fd7e7e 1.feat(): 添加:
a.添加了自定义的一个预警类
b.添加了远调的代码,连同熔断
2.fix(): 修复了:
a.修改了redis在列表通过vin码存储
b.修改了redis的存储类型
c.优化了一些代码

更新时间10081949
2024-10-10 11:22:59 +08:00
微醺 4f52c6c4ac 1.feat(): 添加:
a.添加了自定义的一个预警类
b.添加了远调的代码,连同熔断
2.fix(): 修复了:
a.修改了redis在列表通过vin码存储
b.修改了redis的存储类型
c.优化了一些代码

更新时间10081949
2024-10-08 20:22:35 +08:00
微醺 0534db9f37 Merge branch 'dev.entBusiness' into dev
# Conflicts:
#	cloud-common/cloud-common-core/src/main/java/com/muyu/common/core/constant/ServiceNameConstants.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarFaultCacheService.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarWarnCacheService.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/CarTemplate.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/CloudEnterpriseApplication.java
#	pom.xml
2024-10-08 20:15:16 +08:00
xinzirun 7207dcc01c fix(): 修改nacos命名空间 2024-10-08 00:22:14 +08:00
xinzirun b74b18a615 fix(): 修复监听日志 2024-10-07 22:48:16 +08:00
LQS ec41019824 fix(): 解决企业缓存编译错误问题 2024-10-07 22:14:46 +08:00
LQS b491045ebf feat(): 新增企业远程调用模块,重构远程调用代码 2024-10-07 21:58:01 +08:00
LQS 580172aa76 Merge remote-tracking branch 'origin/dev.analysis' into dev
# Conflicts:
#	cloud-common/pom.xml
2024-10-07 20:33:09 +08:00
LQS 3202af6ebb feat(): 完善mqtt的投递 2024-10-07 20:30:44 +08:00
crj c08a1376d6 fix():整理代码格式 2024-10-07 20:14:44 +08:00
crj 9bb39ec32a fix():解决故障规则报错 2024-10-07 20:12:05 +08:00
crj 6e0ed3b883 Merge remote-tracking branch 'origin/dev.entOperation' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/pom.xml
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/CarMessageController.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/FaultRuleController.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/FaultRuleService.java
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/FaultRuleServiceImpl.java
#	cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/banner.txt
2024-10-07 20:09:21 +08:00
crj 94d04e3a35 feat():解决冲突 2024-10-07 20:00:27 +08:00
xinzirun a9bfdc1670 Merge remote-tracking branch 'origin/dev' into dev 2024-10-07 19:48:57 +08:00
xinzirun 111129e777 fix(): 修复故障规则 2024-10-07 19:48:11 +08:00
微醺 0bafed3671 1.feat(): 添加:
2.fix(): 修复了: 之前添加的封装的缓存

更新时间10071938
2024-10-07 19:43:07 +08:00
微醺 0db37dc190 Merge branch 'dev.entBusiness' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
2024-10-07 19:40:07 +08:00
xinzirun 22e068cfc5 Merge branch 'dev' of https://gitea.qinmian.online/six-vehicle/cloud-server into dev 2024-10-07 19:31:57 +08:00
xinzirun 9f0f373594 fix(): 处理事件监听器执行异常问题 2024-10-07 19:31:18 +08:00
crj a2f2d2ec52 fix():故障规则重构 2024-10-07 19:31:18 +08:00
xinzirun 26c0d3d4c8 fix(): 优化上下线监听 2024-10-07 19:31:18 +08:00
xinzirun 7fa71097fd fix(): 解决配置冲突问题 2024-10-07 19:31:18 +08:00
liuyibo e018d60115 build():添加车辆连接获取车辆信息存入数据库中,发送rabbitmq消息队列 2024-10-07 19:31:17 +08:00
xinzirun 20977536e3 fix(): 处理事件监听器执行异常问题 2024-10-07 19:29:12 +08:00
crj 222b2ad30f fix():故障规则重构 2024-10-07 18:53:10 +08:00
xinzirun eef7d19aeb fix(): 优化上下线监听 2024-10-07 13:55:46 +08:00
xinzirun 19f67a389c fix(): 解决配置冲突问题 2024-10-07 09:45:59 +08:00
xinzirun f7f54bf0c1 Merge remote-tracking branch 'origin/dev.eventProcess' into dev 2024-10-07 09:16:12 +08:00
xinzirun a1894bb013 feat(): 新增车辆上线消费者和识别故障监听器 2024-10-07 09:02:38 +08:00
xinzirun ca8bd65148 fix(): 优化时间处理流程,修复bug 2024-10-07 09:01:57 +08:00
xinzirun a0c2d916f2 fix(): 修改事件处理基类架构 2024-10-07 09:01:19 +08:00
xinzirun 8888b7430c fix(): 修改故障规则命名 2024-10-07 09:00:43 +08:00
liuyibo a8222a4c88 build():添加车辆连接获取车辆信息存入数据库中,发送rabbitmq消息队列 2024-10-06 11:08:48 +08:00
liuyibo 98fa19923d build():添加车辆连接获取车辆信息存入数据库中,发送rabbitmq消息队列 2024-10-06 10:57:27 +08:00
xinzirun 3378b4c216 feat(): 添加车辆下线监听消费者
fix(): 解决依赖冲突
2024-10-06 09:57:22 +08:00
微醺 688527037d 1.feat(): 添加: 电子围栏的redis
2.fix(): 修复了: 暂无

更新时间10060935
2024-10-06 09:35:54 +08:00
微醺 d896e9b26d Merge branch 'dev.entBusiness' of https://gitea.qinmian.online/six-vehicle/cloud-server into dev
# Conflicts:
#	cloud-common/pom.xml
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/CloudEnterpriseApplication.java
#	cloud-modules/cloud-modules-event-process/src/main/resources/banner.txt
#	pom.xml
2024-10-06 09:22:15 +08:00
crj 3fb0158cfa feax:()添加企业表的同时将数据同步进去 企业列表展示 2024-10-05 20:41:45 +08:00
xinzirun 5d66ce181f feat(): 新增本地缓存工具类 2024-10-04 20:45:34 +08:00
crj 46689d02e1 feax:()添加企业表的同时将数据同步进去 企业列表展示 2024-10-04 11:09:33 +08:00
xinzirun 576befa0ee fix(): 修改nacos命名空间配置 2024-10-02 16:50:55 +08:00
xinzirun 6f95055a6b feat(): 新增rabbitmq公共模块代码 2024-10-02 16:49:39 +08:00
xinzirun 17245c91b3 fix(): 解决代码冲突问题 2024-09-30 20:09:05 +08:00
xinzirun ff3f1e8ac2 fix(): 解决代码冲突问题 2024-09-30 20:07:32 +08:00
xinzirun 147dbe2c99 fix(): 解决依赖冲突问题 2024-09-30 20:07:17 +08:00
liuyibo b9529234e9 Merge branch 'dev' of https://gitea.qinmian.online/six-vehicle/cloud-server into dev.vehicleGateway
# Conflicts:
#	pom.xml
2024-09-30 19:06:12 +08:00
liuyibo 0ed0f872e9 build():依赖版本号放到公共层统一管理 2024-09-30 19:05:30 +08:00
xinzirun 7e2ad67a64 fix(): 解决代码冲突问题 2024-09-30 19:00:17 +08:00
xinzirun c67d648a8a Merge branch 'dev.eventProcessing' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/pom.xml
#	cloud-modules/pom.xml
2024-09-30 18:10:51 +08:00
xinzirun 5203c69a90 fix(): 修改nacos命名空间 2024-09-30 18:04:49 +08:00
xinzirun 3ebd1d2c39 fix(): 修复时间处理基础架构 2024-09-30 18:03:48 +08:00
crj 0c7795ea71 feax:()添加企业的时候添加一个单独的库和表 2024-09-30 16:41:06 +08:00
liuyibo add31c49fa feat():程序启动时可以通过新创的服务器id查询到ip和状态 2024-09-30 09:22:25 +08:00
xinzirun 7100bf71bf feat(): 添加事件处理业务 2024-09-30 00:52:20 +08:00
LQS 497de4ade9 Merge remote-tracking branch 'origin/dev.analysis' into dev 2024-09-29 18:05:15 +08:00
LQS 940e41b297 fix():修复与dev.analysis合并报错(Move or commit them before Merge) 2024-09-29 18:04:46 +08:00
LQS 514c94b398 feat():修改日志打印方式 2024-09-29 17:45:01 +08:00
LQS 7e02675028 feat(新增kafka、redis常量类):完善MQTT接收之后解析报文传递kafka 2024-09-29 17:32:46 +08:00
liuyibo 22675757b3 feat():启动创建ECS服务器模块,停止删除ECS服务器模块 2024-09-29 16:33:04 +08:00
xinzirun 6594363a91 fix(): 修复cloud-data-process数据处理微服务模块 ---> cloud-event-process事件处理微服务模块 2024-09-29 16:06:24 +08:00
crj 517c18f215 feax:()删除fault模块 2024-09-29 15:07:11 +08:00
LQS e2d710fbb6 Merge remote-tracking branch 'origin/dev.vehicles' into dev 2024-09-29 12:17:44 +08:00
LQS 9f01b76182 feat():移除废模块包 2024-09-29 12:15:41 +08:00
LQS fedc3c4ea7 feat():添加依赖注释 2024-09-29 12:10:28 +08:00
xinzirun 423836afb7 fix(): 修复IoTDB基础类 2024-09-29 11:58:18 +08:00
liuyibo cb79600bc0 style():优化代码 2024-09-29 11:20:00 +08:00
LQS a18ba509d8 fix():修复依赖注入问题 2024-09-29 11:18:39 +08:00
LQS 5979dbea8f fix():修复远调降级处理影响启动类无法运行问题 2024-09-29 11:10:37 +08:00
liuyibo 782f31446b feat():项目启动添加ecs实例,停止删除ecs实例 2024-09-29 10:25:30 +08:00
xinzirun 47567ff055 feat(): 新增IoTDB配置类、基础业务类 2024-09-29 00:55:53 +08:00
LQS 1378aeeb06 fate():!! 2024-09-28 23:23:20 +08:00
LQS 51cfc6ab2d Merge remote-tracking branch 'origin/dev.vehicles' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/CarMessageController.java
2024-09-28 23:21:08 +08:00
LQS 681c88db28 fate():新增协议解析模块:MQTT连接,数据转换JSON数据 2024-09-28 23:11:55 +08:00
crj 2d0f557398 feax:()修改代码规范 2024-09-28 22:14:45 +08:00
xinzirun 9c059750b6 Merge remote-tracking branch 'origin/dev.dataProcessing' into dev 2024-09-28 21:24:40 +08:00
xinzirun 38a096ea72 feat(): 新增kafka配置模块 2024-09-28 21:23:24 +08:00
crj cd46940e70 feax:()修改代码规范(注释) 2024-09-28 20:12:04 +08:00
LQS b70a552b6a fate():MQTT链接测试 2024-09-28 17:04:31 +08:00
LQS d054119692 fate():修改模块 2024-09-28 16:30:58 +08:00
liuyibo e9a19e94e9 连接MQTT,接收车辆的数据 2024-09-28 12:28:19 +08:00
217 changed files with 9896 additions and 246 deletions

1
.gitignore vendored
View File

@ -26,6 +26,7 @@ logs
*.iws
*.iml
*.ipr
*.yml
### JRebel ###
rebel.xml

View File

@ -76,19 +76,18 @@ public class SysLoginService {
if (Result.FAIL == userResult.getCode()) {
throw new ServiceException(userResult.getMsg());
}
LoginUser userInfo = userResult.getData();
SysUser user = userResult.getData().getSysUser();
if (UserStatus.DELETED.getCode().equals(user.getDelFlag())) {
recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, "对不起,您的账号已被删除");
throw new ServiceException("对不起,您的账号:" + username + " 已被删除");
if(UserStatus.DELETED.getCode().equals(user.getDelFlag())){
recordLogService.recordLogininfor(username,Constants.LOGIN_FAIL,"对不起,您的账号已被删除");
throw new ServiceException("对不起,您的账号:" + username + " 已被删除 ");
}
if (UserStatus.DISABLE.getCode().equals(user.getStatus())) {
recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, "用户已停用,请联系管理员");
throw new ServiceException("对不起,您的账号" + username + " 已停用");
if(UserStatus.DISABLE.getCode().equals(user.getStatus())){
recordLogService.recordLogininfor(username,Constants.LOGIN_FAIL,"用户已停用,请联系管理官");
throw new ServiceException("对不起,您的账号:" + username + " 已停用");
}
passwordService.validate(user, password);
recordLogService.recordLogininfor(username, Constants.LOGIN_SUCCESS, "登录成功");
passwordService.validate(user,password);
recordLogService.recordLogininfor(username,Constants.LOGIN_SUCCESS,"登录成功");
return userInfo;
}
@ -128,16 +127,16 @@ public class SysLoginService {
throw new ServiceException("密码长度必须在5到20个字符之间");
}
// 注册用户信息
//注册用户信息
SysUser sysUser = new SysUser();
sysUser.setUserName(username);
sysUser.setNickName(username);
sysUser.setPassword(SecurityUtils.encryptPassword(password));
Result<?> registerResult = remoteUserService.registerUserInfo(registerBody, SecurityConstants.INNER);
Result<Boolean> registerResult = remoteUserService.registerUserInfo(registerBody, SecurityConstants.INNER);
if (Result.FAIL == registerResult.getCode()) {
throw new ServiceException(registerResult.getMsg());
}
recordLogService.recordLogininfor(username, Constants.REGISTER, "注册成功");
recordLogService.recordLogininfor(username,Constants.REGISTER,"注册成功");
}
}

View File

@ -2,6 +2,7 @@
server:
port: 9500
# nacos线上地址
nacos:
addr: 106.15.136.7:8848
user-name: nacos

View File

@ -1,5 +1,7 @@
package com.muyu.common.cache.config;
import com.muyu.common.core.text.StrFormatter;
/**
*
* @ClassName PrimaryKeyBasic
@ -13,13 +15,18 @@ public interface PrimaryKeyBasic <K>{
*/
public String keyPre();
/**
* key
*/
public String keyPost();
/**
*
* @param key
* @return
*/
public default String encode(K key){
return keyPre() + key.toString();
return StrFormatter.format("{}:vin{}:{}", keyPre(), key.toString(), keyPost());
}
/**

View File

@ -0,0 +1,19 @@
package com.muyu.common.core.constant;
/**
* kafka
* @Author
* @Packagecom.muyu.common.core.constant
* @Projectcloud-server
* @nameKafkaConstants
* @Date2024/9/29 16:41
*/
public class KafkaConstants {
/**
* ()
*/
public final static String MESSAGE_PARSING = "MessageParsing";
}

View File

@ -0,0 +1,17 @@
package com.muyu.common.core.constant;
/**
* redis
* @Author
* @Packagecom.muyu.common.core.constant
* @Projectcloud-server
* @nameRedisConstants
* @Date2024/9/29 17:28
*/
public class RedisConstants {
/**
* redisKey()
*/
public final static String MESSAGE_TEMPLATE = "messageTemplate";
}

View File

@ -20,9 +20,9 @@ public class ServiceNameConstants {
* serviceid
*/
public static final String FILE_SERVICE = "cloud-file";
/**
* serviceid
* serviceid
*/
public static final String ENTERPRISE_SERVICE = "cloud-enterprise";
}

View File

@ -0,0 +1,37 @@
<?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>
<description>
cloud-common-kafka模块
</description>
<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>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<!-- kafka客户端 -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,102 @@
package com.muyu.common.kafka.config;
import com.muyu.common.core.text.StrFormatter;
import com.muyu.common.kafka.constant.KafkaConfigConstants;
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.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
/**
* @Author: zi run
* @Date 2024/9/28 20:32
* @Description Kafka
*/
@Configuration
public class KafkaConsumerConfig {
/**
* IP
*/
@Value("${kafka.consumer.bootstrap-servers-ip}")
private String bootstrapServersIP;
/**
*
*/
@Value("${kafka.consumer.bootstrap-servers-port}")
private String bootstrapServersPort;
/**
*
*/
@Value("${kafka.consumer.enable-auto-commit}")
private Boolean enableAutoCommit;
/**
*
*/
@Value("${kafka.consumer.auto-commit-interval}")
private Integer autoCommitInterval;
/**
*
*/
@Value("${kafka.consumer.auto-offset-reset}")
private String autoOffsetReset;
/**
*
*/
@Value("${kafka.consumer.fetch-max-wait}")
private Integer fetchMaxWait;
/**
*
*/
@Value("${kafka.consumer.fetch-min-size}")
private Integer fetchMinSize;
/**
*
*/
@Value("${kafka.consumer.heartbeat-interval}")
private Integer heartbeatInterval;
/**
* poll
*/
@Value("${kafka.consumer.max-poll-records}")
private Integer maxPollRecords;
/**
*
*/
@Value("${kafka.consumer.group-id}")
private String groupId;
/**
* Kafka
* @return Kafka
*/
@Bean
public KafkaConsumer<String, String> kafkaConsumer() {
HashMap<String, Object> configs = new HashMap<>();
configs.put(KafkaConfigConstants.BOOTSTRAP_SERVERS,
StrFormatter.format("{}:{}", bootstrapServersIP, bootstrapServersPort));
configs.put(KafkaConfigConstants.ENABLE_AUTO_COMMIT, enableAutoCommit);
configs.put(KafkaConfigConstants.AUTO_COMMIT_INTERVAL, autoCommitInterval);
configs.put(KafkaConfigConstants.AUTO_OFFSET_RESET, autoOffsetReset);
configs.put(KafkaConfigConstants.FETCH_MAX_WAIT, fetchMaxWait);
configs.put(KafkaConfigConstants.FETCH_MIN_SIZE, fetchMinSize);
configs.put(KafkaConfigConstants.HEARTBEAT_INTERVAL, heartbeatInterval);
configs.put(KafkaConfigConstants.MAX_POLL_RECORDS, maxPollRecords);
configs.put(KafkaConfigConstants.GROUP_ID, groupId);
Deserializer<String> keyDeserializer = new StringDeserializer();
Deserializer<String> valueDeserializer = new StringDeserializer();
return new KafkaConsumer<>(configs, keyDeserializer, valueDeserializer);
}
}

View File

@ -0,0 +1,74 @@
package com.muyu.common.kafka.config;
import com.muyu.common.core.text.StrFormatter;
import com.muyu.common.kafka.constant.KafkaConfigConstants;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.common.serialization.Serializer;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
/**
* @Author: zi run
* @Date 2024/9/28 16:35
* @Description Kafka
*/
@Configuration
public class KafkaProducerConfig {
/**
* IP
*/
@Value("${kafka.producer.bootstrap-servers-ip}")
private String bootstrapServersIP;
/**
*
*/
@Value("${kafka.producer.bootstrap-servers-port}")
private String bootstrapServersPort;
/**
*
*/
@Value("${kafka.producer.retries}")
private Integer retries;
/**
*
*/
@Value("${kafka.producer.batch-size}")
private Integer batchSize;
/**
*
*/
@Value("${kafka.producer.buffer-memory}")
private Integer bufferMemory;
/**
*
*/
@Value("${kafka.producer.acks}")
private String acks;
/**
* Kafka
* @return kafka
*/
@Bean
public KafkaProducer<String, String> kafkaProducer() {
HashMap<String, Object> configs = new HashMap<>();
configs.put(KafkaConfigConstants.BOOTSTRAP_SERVERS,
StrFormatter.format("{}:{}", bootstrapServersIP, bootstrapServersPort));
configs.put(KafkaConfigConstants.RETRIES, retries);
configs.put(KafkaConfigConstants.BATCH_SIZE, batchSize);
configs.put(KafkaConfigConstants.BUFFER_MEMORY, bufferMemory);
configs.put(KafkaConfigConstants.ACKS, acks);
Serializer<String> keySerializer = new StringSerializer();
Serializer<String> valueSerializer = new StringSerializer();
return new KafkaProducer<>(configs, keySerializer, valueSerializer);
}
}

View File

@ -0,0 +1,74 @@
package com.muyu.common.kafka.constant;
/**
* @Author: zi run
* @Date 2024/9/28 20:07
* @Description Kafka
*/
public class KafkaConfigConstants {
/**
* ip+
*/
public static final String BOOTSTRAP_SERVERS = "bootstrap.servers";
/**
*
*/
public static final String RETRIES = "retries";
/**
*
*/
public static final String BATCH_SIZE = "batch.size";
/**
*
*/
public static final String BUFFER_MEMORY = "buffer-memory";
/**
*
*/
public static final String ACKS = "acks";
/**
*
*/
public static final String ENABLE_AUTO_COMMIT = "enable.auto.commit";
/**
*
*/
public static final String AUTO_COMMIT_INTERVAL = "auto.commit.interval";
/**
*
*/
public static final String AUTO_OFFSET_RESET = "auto.offset.reset";
/**
*
*/
public static final String FETCH_MAX_WAIT = "fetch.max.wait";
/**
*
*/
public static final String FETCH_MIN_SIZE = "fetch.min.size";
/**
*
*/
public static final String HEARTBEAT_INTERVAL = "heartbeat-interval";
/**
* poll
*/
public static final String MAX_POLL_RECORDS = "max.poll.records";
/**
*
*/
public static final String GROUP_ID = "group.id";
}

View File

@ -0,0 +1,2 @@
com.muyu.common.kafka.config.KafkaProducerConfig
com.muyu.common.kafka.config.KafkaConsumerConfig

View File

@ -0,0 +1,31 @@
<?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-mqtt</artifactId>
<description>
cloud-common-mqtt消息队列遥测传输协议
</description>
<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>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,31 @@
package com.muyu.common.mqtt;
/**
* mqtt
* @Author
* @Packagecom.muyu.common.mqtt
* @Projectcloud-server
* @nameMQTTConnect
* @Date2024/10/2 9:40
*/
public class MQTTConnect
{
/**
* String topic = "vehicle";
* String broker = "tcp://106.15.136.7:1883";
* String clientId = "JavaSample";
*/
/**
* MQTT
*/
public static final String TOPIC="vehicle";
/**
*IP
*/
public static final String BROKER="tcp://106.15.136.7:1883";
/**
*ID,MQTT
*/
public static final String CLIENT_ID ="JavaSample";
}

View File

@ -0,0 +1,44 @@
package com.muyu.common.rabbit.callback;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
/**
* @Author: zi run
* @Date 2024/10/2 9:26
* @Description broker
*/
@Slf4j
@Component
public class ConfirmCallback implements RabbitTemplate.ConfirmCallback {
@Resource
private RabbitTemplate rabbitTemplate;
/**
*
*/
@PostConstruct
public void init() {
this.rabbitTemplate.setConfirmCallback(this);
}
/**
*
* @param correlationData
* @param ack truebrokerfalsebroker
* @param cause ackfalseacktrue
*/
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
if (ack) {
log.info("消息发送到broker成功");
} else {
log.info("消息发送到broker失败失败原因{}", cause);
}
}
}

View File

@ -0,0 +1,39 @@
package com.muyu.common.rabbit.callback;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.ReturnedMessage;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
/**
* @Author: zi run
* @Date 2024/10/2 9:33
* @Description
*/
@Slf4j
@Component
public class ReturnsCallback implements RabbitTemplate.ReturnsCallback {
@Resource
private RabbitTemplate rabbitTemplate;
/**
*
*/
@PostConstruct
public void init() {
rabbitTemplate.setReturnsCallback(this);
}
/**
*
* @param returnedMessage
*/
@Override
public void returnedMessage(ReturnedMessage returnedMessage) {
log.info("消息:{}被交换机:{}回退!回退原因:{}", returnedMessage.getMessage().toString(),
returnedMessage.getExchange(), returnedMessage.getReplyText());
}
}

View File

@ -0,0 +1,72 @@
package com.muyu.common.rabbit.config;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @Author: zi run
* @Date 2024/10/2 16:41
* @Description RabbitMQ
*/
@Configuration
public class RabbitAdminConfig {
/**
* RabbitMQ
*/
@Value("${spring.rabbitmq.host}")
private String host;
/**
* RabbitMQ
*/
@Value("${spring.rabbitmq.username}")
private String username;
/**
* RabbitMQ
*/
@Value("${spring.rabbitmq.password}")
private String password;
/**
* RabbitMQ
*/
@Value("${spring.rabbitmq.virtualhost}")
private String virtualhost;
/**
* RabbitAdmin
*
* @return RabbitAdmin
*/
@Bean
public RabbitAdmin rabbitAdmin() {
RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory());
rabbitAdmin.setAutoStartup(true);
return rabbitAdmin;
}
/**
* RabbitMQ
*
* @return ConnectionFactory
*/
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setAddresses(host);
connectionFactory.setUsername(username);
connectionFactory.setPassword(password);
connectionFactory.setVirtualHost(virtualhost);
// 配置发送确认回调时次配置必须配置否则即使在RabbitTemplate配置了ConfirmCallback也不会生效
connectionFactory.setPublisherConfirmType(CachingConnectionFactory.ConfirmType.CORRELATED);
connectionFactory.setPublisherReturns(true);
return connectionFactory;
}
}

View File

@ -1,28 +1,41 @@
package com.muyu.common.rabbit;
package com.muyu.common.rabbit.config;
import org.springframework.amqp.rabbit.annotation.RabbitListenerConfigurer;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.converter.MappingJackson2MessageConverter;
import org.springframework.messaging.handler.annotation.support.DefaultMessageHandlerMethodFactory;
/**
* @Author: zi run
* @Date 2024/10/2 10:06
* @Description rabbitMQ
*/
@Configuration
public class RabbitListenerConfigurer implements org.springframework.amqp.rabbit.annotation.RabbitListenerConfigurer {
public class RabbitListenerConfig implements RabbitListenerConfigurer {
static {
// 设置为信任所有类型的反序列化,确保消息能够正确反序列化
System.setProperty("spring.amqp.deserialization.trust.all", "true");
}
//以下配置RabbitMQ消息服务
/**
* RabbitMQ
*/
@Autowired
public ConnectionFactory connectionFactory;
@Autowired
private MessageConverter jsonMessageConverter;
/**
*
* @return
* bean
*
* @return DefaultMessageHandlerMethodFactory
*/
@Bean
public DefaultMessageHandlerMethodFactory handlerMethodFactory() {
@ -32,8 +45,14 @@ public class RabbitListenerConfigurer implements org.springframework.amqp.rabbit
return factory;
}
/**
* RabbitMQ
*
* @param rabbitListenerEndpointRegistrar
*/
@Override
public void configureRabbitListeners(RabbitListenerEndpointRegistrar rabbitListenerEndpointRegistrar) {
// 注册自定义的消息处理方法工厂
rabbitListenerEndpointRegistrar.setMessageHandlerMethodFactory(handlerMethodFactory());
}

View File

@ -0,0 +1,26 @@
package com.muyu.common.rabbit.config;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @Author: zi run
* @Date 2024/10/2 9:17
* @Description rabbitMQ
*/
@Configuration
public class RabbitMQMessageConverterConfig {
/**
*
*
* @return
*/
@Bean
public MessageConverter jsonMessageConverter() {
return new Jackson2JsonMessageConverter();
}
}

View File

@ -1 +1,3 @@
com.muyu.common.rabbit.RabbitListenerConfigurer
com.muyu.common.rabbit.config.RabbitAdminConfig
com.muyu.common.rabbit.config.RabbitListenerConfig
com.muyu.common.rabbit.config.RabbitMQMessageConverterConfig

View File

@ -91,21 +91,19 @@ public class ManyDataSource implements ApplicationRunner {
@Bean
public DynamicDataSource dynamicDataSource(DruidDataSourceFactory druidDataSourceFactory) {
List<EntInfo> entInfoList = dataSourceInfoList();
if(StringUtils.isEmpty(entInfoList)){
throw new SaaSException("数据信息列表为空或为null");
if (StringUtils.isNotEmpty(entInfoList)) {
throw new SaaSException("数据信息列表为空或为null");
}
Map<Object, Object> dataSourceMap = dataSourceInfoList().stream()
Map<Object,Object> dataSourceMap = dataSourceInfoList().stream()
.map(entInfo -> DataSourceInfo.hostAndPortBuild(
entInfo.getEntCode(),
entInfo.getIp(),
entInfo.getPort()
)
entInfo.getEntCode(),
entInfo.getIp(),
entInfo.getPort()
)
.collect(Collectors.toMap(
).collect(Collectors.toMap(
dataSourceInfo -> dataSourceInfo.getKey(),
dataSourceInfo -> druidDataSourceFactory.create(dataSourceInfo)
));
//设置动态数据源
DynamicDataSource dynamicDataSource = new DynamicDataSource();
dynamicDataSource.setTargetDataSources(dataSourceMap);

View File

@ -1,8 +1,9 @@
package com.muyu.cloud.common.many.datasource.constents;
/**
* @Author: zi run
* @Date 2024/9/20 14:52
*
* @Author chenruijia
* @Date 2024/9/29 17:52
* @Description
*/
public class DatasourceContent {

View File

@ -8,6 +8,7 @@ import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author: zi run
* @Date 2024/9/20 14:52
* @Description

View File

@ -8,6 +8,7 @@ import org.springframework.stereotype.Component;
import java.sql.SQLException;
/**
* Druid
* @Author: zi run
* @Date 2024/9/20 14:52
* @Description Druid

View File

@ -4,6 +4,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.util.Assert;
/**
*
* @Author: zi run
* @Date 2024/9/20 14:52
* @Description

View File

@ -6,6 +6,7 @@ import org.springframework.context.annotation.Import;
import java.lang.annotation.*;
/**
*
* @ClassName EnableCustomSwagger2
* @Description EnableCustomSwagger2:
* @Date 2024/10/6 22:16

View File

@ -22,6 +22,7 @@ import java.util.function.Predicate;
/**
*
* @ClassName SwaggerAutoConfiguration
* @Description SwaggerAutoConfiguration:
* @Date 2024/10/6 22:16

View File

@ -13,6 +13,7 @@ import java.util.stream.Collectors;
/**
* BEAN
* @ClassName SwaggerBeanPostProcessor
* @Description SwaggerBeanPostProcessor:
* @Date 2024/10/6 22:16

View File

@ -7,6 +7,7 @@ import java.util.List;
/**
* SWAGGER
* @ClassName SwaggerProperties
* @Description SwaggerProperties:
* @Date 2024/10/6 22:16

View File

@ -5,6 +5,7 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
/**
*
* @ClassName SwaggerWebConfiguration
* @Description SwaggerWebConfiguration:
* @Date 2024/10/6 22:16

View File

@ -21,8 +21,10 @@
<module>cloud-common-system</module>
<module>cloud-common-xxl</module>
<module>cloud-common-rabbit</module>
<module>cloud-common-kafka</module>
<module>cloud-common-cache</module>
<module>cloud-common-swagger</module>
<module>cloud-common-mqtt</module>
</modules>
<artifactId>cloud-common</artifactId>

View File

@ -16,7 +16,7 @@
<dependencies>
<!-- SpringCloud Gateway -->
<!-- SpringCloud Gateway -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>

View File

@ -2,6 +2,7 @@
server:
port: 8080
# nacos线上地址
nacos:
addr: 106.15.136.7:8848
user-name: nacos

View File

@ -1,29 +0,0 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.CarManage;
/**
* redis
* @ClassName CarCompanyCacheService
* @Description CarCompanyCacheService:
* @Date 2024/10/3 15:22
* @author MingWei.Zong()
*/
public class CarCompanyCacheService extends CacheAbsBasic<String, CarCompany> {
@Override
public String keyPre() {
return "CarCompany:info:";
}
@Override
public String decode(String key) {
return key.replace("CarCompany:info:","");
}
}

View File

@ -16,13 +16,18 @@ import com.muyu.enterprise.domain.SysCarFault;
public class CarFaultCacheService extends CacheAbsBasic<String, SysCarFault> {
@Override
public String keyPre() {
return "sysCarFault:info:";
return "vehicleDeterminationStandard";
}
@Override
public String keyPost() {
return "fault";
}
@Override
public String decode(String key) {
return key.replace("faultType:info:","");
return "";
}

View File

@ -1,30 +1,33 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarManage;
import com.muyu.enterprise.domain.vo.CarVO;
import java.util.List;
/**
* redis
* redis
* @ClassName CarManageCacheService
* @Description CarManageCacheService:
* @Date 2024/10/3 15:22
* @author MingWei.Zong()
*/
public class CarManageCacheService extends CacheAbsBasic<String, List<CarManage>> {
public class CarManageCacheService extends CacheAbsBasic<String, List<CarVO>> {
@Override
public String keyPre() {
return "carManage:info:";
return "vehicleDeterminationStandard";
}
@Override
public String keyPost() {
return "carManage";
}
@Override
public String decode(String key) {
return key.replace("carManage:info:","");
return "";
}

View File

@ -1,30 +0,0 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarMessage;
/**
* redis
* @ClassName CarMessageCacheService
* @Description CarMessageCacheService:
* @Date 2024/9/30 11:42
* @author MingWei.Zong()
*/
public class CarMessageCacheService extends CacheAbsBasic<String, CarMessage> {
@Override
public String keyPre() {
return "carMessage:info:";
}
// @Override
// public String encode(String key) {
// return super.encode(key);
// }
@Override
public String decode(String key) {
return key.replace("carMessage:info:","");
}
}

View File

@ -3,6 +3,7 @@ package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.CarTemplate;
import com.muyu.enterprise.domain.vo.CarTemplateVO;
/**
* redis
@ -12,17 +13,21 @@ import com.muyu.enterprise.domain.CarTemplate;
* @author MingWei.Zong()
*/
public class CarTemplateCacheService extends CacheAbsBasic<String, CarTemplate> {
public class CarTemplateCacheService extends CacheAbsBasic<String, CarTemplateVO> {
@Override
public String keyPre() {
return "carTemplate:info:";
return "vehicleDeterminationStandard";
}
@Override
public String keyPost() {
return "messageTemplate";
}
@Override
public String decode(String key) {
return key.replace("carTemplate:info:","");
return "";
}

View File

@ -15,13 +15,18 @@ import com.muyu.enterprise.domain.vo.WarnVo;
public class CarWarnCacheService extends CacheAbsBasic<String, WarnVo> {
@Override
public String keyPre() {
return "warnStrategy:info:";
return "vehicleDeterminationStandard";
}
@Override
public String keyPost() {
return "warn";
}
@Override
public String decode(String key) {
return key.replace("warnStrategy:info:","");
return "";
}

View File

@ -0,0 +1,33 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.dateBase.ElectronicFence;
/**
* redis
* @ClassName ElectronicFenceCacheService
* @Description ElectronicFenceCacheService:
* @Date 2024/10/3 15:22
* @author MingWei.Zong
*/
public class ElectronicFenceCacheService extends CacheAbsBasic<String, ElectronicFence> {
@Override
public String keyPre() {
return "vehicleDeterminationStandard";
}
@Override
public String keyPost() {
return "electronicFence";
}
@Override
public String decode(String key) {
return "";
}
}

View File

@ -1,6 +1,5 @@
com.muyu.enterprise.cache.CarCompanyCacheService
com.muyu.enterprise.cache.CarFaultCacheService
com.muyu.enterprise.cache.CarManageCacheService
com.muyu.enterprise.cache.CarMessageCacheService
com.muyu.enterprise.cache.CarTemplateCacheService
com.muyu.enterprise.cache.CarWarnCacheService
com.muyu.enterprise.cache.ElectronicFenceCacheService
com.muyu.enterprise.cache.CarManageCacheService

View File

@ -11,6 +11,10 @@
<artifactId>cloud-modules-enterprise-common</artifactId>
<description>
cloud-modules-enterprise-common企业业务平台服务
</description>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
@ -25,6 +29,7 @@
<artifactId>cloud-common-core</artifactId>
</dependency>
<!--swagger3依赖-->
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations-jakarta</artifactId>

View File

@ -28,7 +28,7 @@ public class CarType {
* id
*/
@TableId(value = "car_type_id",type = IdType.AUTO)
private Integer carTypeId;
private long carTypeId;
/**
*
@ -38,7 +38,7 @@ public class CarType {
/**
* id
*/
private Integer templateId;
private long templateId;
}

View File

@ -12,7 +12,7 @@ import lombok.experimental.SuperBuilder;
*
* @Author: chenruijia
* @Date 2024/9/28 12.23
* @Description FaultrRule:
* @Description FaultRule:
*/
@Data
@SuperBuilder
@ -21,7 +21,7 @@ import lombok.experimental.SuperBuilder;
@TableName(value = "fault_rule",autoResultMap = true)
@EqualsAndHashCode(callSuper = true)
@Tag(name = "故障规则")
public class FaultrRule extends BaseEntity {
public class FaultRule extends BaseEntity {
/**
* ID
*/
@ -29,18 +29,40 @@ public class FaultrRule extends BaseEntity {
@Schema(defaultValue = "故障规则ID",type = "Long",description = "故障规则ID")
private Long faultRuleId;
/**
*
* ID
*/
@Schema(defaultValue = "故障规则名称",type = "String",description = "故障规则名称")
private String faultRuleName;
@Schema(defaultValue = "车辆类型ID",type = "Integer",description = "车辆类型ID")
private Integer carTypeId;
/**
* ID
*/
@Schema(defaultValue = "故障名称ID",type = "Integer",description = "故障名称ID")
private Integer faultId;
/**
*
*/
@Schema(defaultValue = "故障条件",type = "String",description = "故障条件")
private String faultConditions;
/**
*
*/
@Schema(defaultValue = "故障规则参数",type = "String",description = "故障规则参数")
private String faultRuleParameter;
private String ruleParameters;
/**
*
*
*/
@Schema(defaultValue = "故障规则描述",type = "String",description = "故障规则描述")
private String faultRuleDescription;
@Schema(defaultValue = "车辆类型名称",type = "String",description = "车辆类型名称")
private String carTypeName;
/**
*
*/
@Schema(defaultValue = "故障名称",type = "String",description = "故障名称")
private String faultName;
/**
* VIN
*/
@Schema(defaultValue = "车辆VIN",type = "String",description = "车辆VIN")
private String carVin;
}

View File

@ -3,6 +3,7 @@ package com.muyu.enterprise.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 com.muyu.common.core.web.domain.BaseEntity;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
@ -42,6 +43,11 @@ public class SysCarFault extends BaseEntity {
*/
@Schema(defaultValue = "车辆故障类型ID",type = "Integer",description = "车辆故障类型ID")
private Integer faultTypeId;
/**
* ID
*/
@Schema(defaultValue = "车辆故障规则ID",type = "Integer",description = "车辆故障规则ID")
public Integer faultRuleId;
/**
* VIN
*/

View File

@ -0,0 +1,59 @@
package com.muyu.enterprise.domain.car;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.enterprise.domain.req.car.MessageTemplateAddReq;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
*
* @Author
* @Packagecom.muyu.car.domain
* @Projectcloud-server
* @nameMessageTemplate
* @Date2024/9/26 20:27
* @Description:
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@TableName(value = "message_template", autoResultMap = true)
public class MessageTemplate extends BaseEntity
{
/**
*
*/
@TableId(value = "message_template_id", type = IdType.AUTO)
private String messageTemplateId;
/**
*
*/
private String messageTemplateName;
/**
*
*/
private String messageTemplateDescribe;
/**
*
* @param messageTemplateAddReq
* @return
*/
public static MessageTemplate addBuild(MessageTemplateAddReq messageTemplateAddReq){
return MessageTemplate.builder()
.messageTemplateName(messageTemplateAddReq.getMessageTemplateName())
.messageTemplateDescribe(messageTemplateAddReq.getMessageTemplateDescribe())
.build();
}
}

View File

@ -0,0 +1,83 @@
package com.muyu.enterprise.domain.car;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.enterprise.domain.req.car.MessageValueAddReq;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
* @Author
* @Packagecom.muyu.car.domain
* @Projectcloud-server
* @nameMessageValue
* @Date2024/9/26 20:29
*
* message_type
*
*/
/**
*
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@TableName(value = "message_value", autoResultMap = true)
public class MessageValue extends BaseEntity
{
/**
*
*/
@TableId(value = "message_id", type = IdType.AUTO)
private Long messageId;
/**
*
*/
private Long templateId;
/**
*
*/
private String messageType;
/**
*
*/
private String messageCode;
/**
*
*/
private String messageLabel;
/**
*
*/
private Integer messageStartIndex;
/**
*
*/
private Integer messageEndIndex;
public static MessageValue addBuild(MessageValueAddReq messageValueAddReq){
return MessageValue.builder()
.templateId(messageValueAddReq.getTemplateId())
.messageType(messageValueAddReq.getMessageType())
.messageCode(messageValueAddReq.getMessageCode())
.messageLabel(messageValueAddReq.getMessageLabel())
.messageStartIndex(messageValueAddReq.getMessageStartIndex())
.messageEndIndex(messageValueAddReq.getMessageEndIndex())
.build();
}
}

View File

@ -0,0 +1,145 @@
package com.muyu.enterprise.domain.car;
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 com.muyu.common.core.annotation.Excel.ColumnType;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.enterprise.domain.req.car.VehicleAddReq;
import com.muyu.enterprise.domain.req.car.VehicleUpdReq;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.function.Supplier;
/**
*
* @Author
* @Packagecom.muyu.car.domain
* @Projectcloud-server
* @nameVehicle
* @Date2024/9/26 20:30
* @Description:
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
@TableName(value = "vehicle", autoResultMap = true)
public class Vehicle extends BaseEntity
{
/**
*
*/
@Excel(name = "车辆主键", cellType = ColumnType.NUMERIC)
@TableId(value = "vehicle_id", type = IdType.AUTO)
private Long vehicleId;
/**
*
*/
@Excel(name = "车牌号")
private String licenceNumber;
/**
*
*/
@Excel(name = "车辆颜色")
private String vehicleColor;
/**
* VIN
*/
@Excel(name = "车辆VIN")
private String vehicleVin;
/**
*
*/
@Excel(name = "车辆类型外键")
private Long vehicleTypeId;
/**
*
*/
@Excel(name = "车辆品牌")
private String vehicleBrand;
/**
*
*/
@Excel(name = "车辆型号")
private String vehicleModel;
/**
*
*/
@Excel(name = "车辆行驶证")
private String vehicleLicense;
/**
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date vehicleLicenseDueDate;
/**
*
*/
@Excel(name = "车辆状态")
private String vehicleStatus;
/**
*
*/
private Long companyId;
/**
*
*/
private Integer fenceGroupId;
public static Vehicle addBuild(VehicleAddReq vehicleAddReq){
return Vehicle.builder()
.licenceNumber(vehicleAddReq.getLicenceNumber())
.vehicleColor(vehicleAddReq.getVehicleColor())
.vehicleVin(vehicleAddReq.getVehicleVin())
.vehicleTypeId(vehicleAddReq.getVehicleTypeId())
.vehicleBrand(vehicleAddReq.getVehicleBrand())
.vehicleModel(vehicleAddReq.getVehicleModel())
.vehicleLicense(vehicleAddReq.getVehicleLicense())
.vehicleLicenseDueDate(vehicleAddReq.getVehicleLicenseDueDate())
.vehicleStatus(vehicleAddReq.getVehicleStatus())
.companyId(vehicleAddReq.getCompanyId())
.fenceGroupId(vehicleAddReq.getFenceGroupId())
.build();
}
public static Vehicle updBuild(VehicleUpdReq vehicleUpdReq, Supplier<Long> idSupplier){
return Vehicle.builder()
.vehicleId(idSupplier.get())
.licenceNumber(vehicleUpdReq.getLicenceNumber())
.vehicleColor(vehicleUpdReq.getVehicleColor())
.vehicleVin(vehicleUpdReq.getVehicleVin())
.vehicleTypeId(vehicleUpdReq.getVehicleTypeId())
.vehicleBrand(vehicleUpdReq.getVehicleBrand())
.vehicleModel(vehicleUpdReq.getVehicleModel())
.vehicleLicense(vehicleUpdReq.getVehicleLicense())
.vehicleLicenseDueDate(vehicleUpdReq.getVehicleLicenseDueDate())
.vehicleStatus(vehicleUpdReq.getVehicleStatus())
.companyId(vehicleUpdReq.getCompanyId())
.fenceGroupId(vehicleUpdReq.getFenceGroupId())
.build();
}
}

View File

@ -0,0 +1,50 @@
package com.muyu.enterprise.domain.car;
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 com.muyu.common.core.annotation.Excel.ColumnType;
import com.muyu.common.core.web.domain.BaseEntity;
import lombok.*;
import lombok.experimental.SuperBuilder;
import java.util.Date;
/**
*
* @Author
* @Packagecom.muyu.car.domain
* @Projectcloud-server
* @nameVehicleType
* @Date2024/9/26 20:31
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@TableName(value = "vehicle_type", autoResultMap = true)
public class VehicleType
{
/**
*
*/
@TableId(value = "vehicle_type_id", type = IdType.AUTO)
private Long vehicleTypeId;
/**
*
*/
private String vehicleTypeName;
/**
*
*/
private Long messageTemplateId;
}

View File

@ -0,0 +1,127 @@
package com.muyu.enterprise.domain.dateBase;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.enterprise.domain.req.ElectroicFenceAddReq;
import com.muyu.enterprise.domain.req.ElectroicFenceUpdReq;
import com.muyu.enterprise.domain.resp.ElectronicFenceResp;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.function.Supplier;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectronicFence
* @Date2024/9/17 16:34
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@EqualsAndHashCode(callSuper = true)
@SuperBuilder
@TableName(value = "electronic_fence",autoResultMap = true)
public class ElectronicFence extends BaseEntity {
/**
* id
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private String name;
/**
*
*/
private String fenceType;
/**
*
*/
private String longitudeLatitude;
/**
*
*/
private String status;
// /**
// * 电子围栏的开始时间
// */
//
// private Date startTime;
// /**
// * 电子围栏的结束时间
// */
// private Date endTime;
/**
*
*/
private String fenceDesc;
public static ElectronicFenceResp bullerResp(ElectronicFence electronicFence){
return ElectronicFenceResp.builder()
.id(electronicFence.getId())
.name(electronicFence.getName())
.status(electronicFence.getStatus())
.fenceType(electronicFence.getFenceType())
.longitudeLatitude(electronicFence.getLongitudeLatitude())
.desc(electronicFence.getFenceDesc())
.build();
}
public static ElectronicFence buildElectroicAdd(ElectroicFenceAddReq electroicFenceAddReq){
return ElectronicFence.builder()
.name(electroicFenceAddReq.getName())
.fenceDesc(electroicFenceAddReq.getFenceDesc())
.status(electroicFenceAddReq.getStatus())
.longitudeLatitude(electroicFenceAddReq.getLongitudeLatitude())
.fenceType(electroicFenceAddReq.getFenceType())
.build();
}
public static ElectronicFence buildByElectronicUpd(ElectroicFenceUpdReq electroicFenceUpdReq, Supplier<Long> longSupplier){
return ElectronicFence.builder()
.id(longSupplier.get())
.name(electroicFenceUpdReq.getName())
.status(electroicFenceUpdReq.getStatus())
.fenceDesc(electroicFenceUpdReq.getFenceDesc())
.longitudeLatitude(electroicFenceUpdReq.getLongitudeLatitude())
.build();
}
}

View File

@ -0,0 +1,118 @@
package com.muyu.enterprise.domain.dateBase;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.enterprise.domain.req.ElectronicFenceGroupAddReq;
import com.muyu.enterprise.domain.req.ElectronicFenceGroupUpdReq;
import com.muyu.enterprise.domain.resp.ElectronicFenceGroupResp;
import com.muyu.enterprise.domain.resp.GroupFenceListresp;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.function.Supplier;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectronicFenceGroup
* @Date2024/9/18 11:14
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@TableName(value = "electronic_fence_group",autoResultMap = true)
public class ElectronicFenceGroup extends BaseEntity {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
public static GroupFenceListresp buildGroupFence(ElectronicFenceGroup electronicFenceGroup){
return GroupFenceListresp.builder()
.id(electronicFenceGroup.getId())
.groupName(electronicFenceGroup.groupName)
.priority(electronicFenceGroup.getPriority())
.status(electronicFenceGroup.getStatus())
.groupType(electronicFenceGroup.groupType)
.build();
}
public static ElectronicFenceGroupResp buildElectronicFenceGroupResp (ElectronicFenceGroup electronicFenceGroup){
return ElectronicFenceGroupResp.builder()
.id(electronicFenceGroup.getId())
.groupName(electronicFenceGroup.groupName)
.priority(electronicFenceGroup.getPriority())
.status(electronicFenceGroup.getStatus())
.groupType(electronicFenceGroup.groupType)
.build();
}
public static ElectronicFenceGroup buildByAdd(ElectronicFenceGroupAddReq addReq){
return ElectronicFenceGroup.builder()
.groupName(addReq.getGroupName())
.groupType(addReq.getGroupType())
.status(addReq.getStatus())
.priority(addReq.getPriority())
.build();
}
public static ElectronicFenceGroup buildByUpd(ElectronicFenceGroupUpdReq updReq, Supplier<Long> ids){
return ElectronicFenceGroup.builder()
.id(ids.get())
.groupName(updReq.getGroupName())
.groupType(updReq.getGroupType())
.status(updReq.getStatus())
.priority(updReq.getPriority())
.build();
}
}

View File

@ -0,0 +1,36 @@
package com.muyu.enterprise.domain.dateBase;
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.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameFenceGroupMid
* @Date2024/9/19 21:01
*/
/**
*
*/
@Tag(name = "围栏组连接表")
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "fence_group_mid",autoResultMap = true)
public class FenceGroupMid {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
private Long groupId;
private Long fenceId;
}

View File

@ -0,0 +1,78 @@
package com.muyu.enterprise.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;
import java.util.Date;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectroicAdd
* @Date2024/9/17 20:53
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectroicFenceAddReq {
/**
* id
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private String name;
/**
*
*/
private String fenceType;
/**
*
*/
private String longitudeLatitude;
/**
*
*/
private String status;
/**
*
*/
private String fenceDesc;
/**
*
*/
private Date startTime;
/**
*
*/
private Date endTime;
}

View File

@ -0,0 +1,68 @@
package com.muyu.enterprise.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectroicFenceReq
* @Date2024/9/17 20:04
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectroicFenceListReq {
/**
*
*/
private String name;
/**
*
*/
private String fenceType;
/**
*
*/
private String longitudeLatitude;
/**
*
*/
private String status;
/**
*
*/
private Date startTime;
/**
*
*/
private Date endTime;
}

View File

@ -0,0 +1,73 @@
package com.muyu.enterprise.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectroicFenceUpdReq
* @Date2024/9/17 21:03
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectroicFenceUpdReq {
/**
* id
*/
private Long id;
/**
*
*/
private String name;
/**
*
*/
private String fenceType;
/**
*
*/
private String longitudeLatitude;
/**
*
*/
private String status;
/**
*
*/
private String fenceDesc;
}

View File

@ -0,0 +1,64 @@
package com.muyu.enterprise.domain.req;
import com.muyu.enterprise.domain.resp.ElectronicFenceResp;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectronicFenceGroupAddReq
* @Date2024/9/20 19:14
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectronicFenceGroupAddReq {
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
/**
*
*/
List<ElectronicFenceResp> electronicFenceRespList;
}

View File

@ -0,0 +1,59 @@
package com.muyu.enterprise.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;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectronicFenceGroupListReq
* @Date2024/9/20 16:06
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectronicFenceGroupListReq {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
}

View File

@ -0,0 +1,69 @@
package com.muyu.enterprise.domain.req;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.muyu.enterprise.domain.resp.ElectronicFenceResp;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameElectronicFenceGroupAddReq
* @Date2024/9/20 19:14
*/
/**
*
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ElectronicFenceGroupUpdReq {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
/**
*
*/
List<ElectronicFenceResp> electronicFenceRespList;
}

View File

@ -0,0 +1,39 @@
package com.muyu.enterprise.domain.req;
import com.muyu.enterprise.domain.resp.ElectronicFenceResp;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameFenceAndGroupBoundReq
* @Date2024/9/21 9:05
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "用于绑定围栏和围栏组的请求")
public class FenceAndGroupBoundReq {
/**
*
*/
private Long id;
/**
*
*/
private List<ElectronicFenceResp> electronicFenceRespList;
}

View File

@ -0,0 +1,24 @@
package com.muyu.enterprise.domain.req;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameFenceWay
* @Date2024/9/20 9:27
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class FenceWayReq {
private Long id;
private String longitudeLatitude;
}

View File

@ -0,0 +1,35 @@
package com.muyu.enterprise.domain.req.car;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameMessageTemplateAddReq
* @Date2024/9/26 20:34
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "新增报文模版请求参数", description = "根据入参进行报文模版的添加")
public class MessageTemplateAddReq
{
/**
*
*/
private String messageTemplateName;
/**
*
*/
private String messageTemplateDescribe;
}

View File

@ -0,0 +1,55 @@
package com.muyu.enterprise.domain.req.car;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameMessageValueAddReq
* @Date2024/9/26 20:35
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "新增报文数据请求参数", description = "根据入参进行报文数据的添加")
public class MessageValueAddReq
{
/**
*
*/
private Long templateId;
/**
*
*/
private String messageType;
/**
*
*/
private String messageCode;
/**
*
*/
private String messageLabel;
/**
*
*/
private Integer messageStartIndex;
/**
*
*/
private Integer messageEndIndex;
}

View File

@ -0,0 +1,37 @@
package com.muyu.enterprise.domain.req.car;
import com.muyu.common.core.annotation.Excel;
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;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameMessageValueReq
* @Date2024/9/26 20:39
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "报文数据请求参数", description = "根据入参进行报文数据的查询")
public class MessageValueReq
{
/** 报文模版主键 */
@Schema(title = "报文模版主键", type = "Long", defaultValue = "1", description = "报文模版主键")
private Long messageTemplateId;
/** 报文分类 */
@Schema(title = "报文分类", type = "String", defaultValue = "basics", description = "报文分类")
private String messageType;
}

View File

@ -0,0 +1,101 @@
package com.muyu.enterprise.domain.req.car;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.common.core.annotation.Excel;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.constraints.NotEmpty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameVehicleAddReq
* @Date2024/9/26 20:39
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "录入车辆请求参数", description = "根据入参进行车辆管理的添加")
public class VehicleAddReq
{
/**
*
*/
@NotEmpty(message = "车牌号不可为空")
@Schema(title = "车牌号", type = "String", defaultValue = "冀A93827", description = "车牌号")
private String licenceNumber;
/**
*
*/
@Schema(title = "车辆颜色", type = "String", defaultValue = "RED", description = "车牌颜色")
private String vehicleColor;
/**
* VIN
*/
@Schema(title = "车辆VIN", type = "String", defaultValue = "LDC913L2240606423", description = "车辆VIN")
private String vehicleVin;
/**
*
*/
@Schema(title = "车辆类型", type = "BigInt", defaultValue = "1", description = "车辆类型")
private Long vehicleTypeId;
/**
*
*/
@Schema(title = "车辆品牌", type = "String", defaultValue = "1", description = "车辆品牌")
private String vehicleBrand;
/**
*
*/
@Schema(title = "车辆型号", type = "String", defaultValue = "1", description = "车辆型号")
private String vehicleModel;
/**
*
*/
@Schema(title = "车辆行驶证", type = "String", defaultValue = "111111", description = "车辆行驶证")
private String vehicleLicense;
/**
*
*/
@Schema(title = "行驶证到期日期", type = "Date", defaultValue = "2024-01-01 00:00:00", description = "行驶证到期日期")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date vehicleLicenseDueDate;
/**
*
*/
@Schema(title = "车辆状态", type = "String", defaultValue = "OFFLINE", description = "车辆状态")
private String vehicleStatus;
/**
*
*/
@Schema(title = "车辆所属企业外键", type = "BigInt", defaultValue = "1", description = "车辆所属企业外键")
private Long companyId;
/**
*
*/
@Schema(title = "电子围栏外键", type = "Integer", defaultValue = "1", description = "电子围栏外键")
private Integer fenceGroupId;
}

View File

@ -0,0 +1,45 @@
package com.muyu.enterprise.domain.req.car;
//import com.muyu.common.core.domain.req.PageReq;
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;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameVehicleManageReq
* @Date2024/9/26 20:41
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "车辆管理查询条件", description = "负责车辆查询条件的实体类")
public class VehicleManageReq
{
/**
*
*/
@Schema(type = "String", defaultValue = "冀A93827", description = "车牌号")
private String licenceNumber;
/**
* VIN
*/
@Schema(type = "String", defaultValue = "LDC913L2240606423", description = "车辆VIN")
private String vehicleVin;
/**
*
*/
@Schema(type = "String", defaultValue = "", description = "车辆状态")
private String vehicleStatus;
}

View File

@ -0,0 +1,100 @@
package com.muyu.enterprise.domain.req.car;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.common.core.annotation.Excel;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.constraints.NotEmpty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*
* @Author
* @Packagecom.muyu.car.domain.req
* @Projectcloud-server
* @nameVehicleUpdReq
* @Date2024/9/26 20:57
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "修改车辆信息参数", description = "根据入参信息修改车辆信息")
public class VehicleUpdReq
{
/**
*
*/
@NotEmpty(message = "车牌号不可为空")
@Schema(title = "车牌号", type = "String", defaultValue = "冀A93827", description = "车牌号")
private String licenceNumber;
/**
*
*/
@Schema(title = "车牌颜色", type = "String", defaultValue = "RED", description = "车牌颜色")
private String vehicleColor;
/**
* VIN
*/
@Schema(title = "车辆VIN", type = "String", defaultValue = "LDC913L2240606423", description = "车辆VIN")
private String vehicleVin;
/**
*
*/
@Schema(title = "车辆类型", type = "BigInt", defaultValue = "1", description = "车辆类型")
private Long vehicleTypeId;
/**
*
*/
@Schema(title = "车辆品牌", type = "String", defaultValue = "1", description = "车辆品牌")
private String vehicleBrand;
/**
*
*/
@Schema(title = "车辆型号", type = "String", defaultValue = "1", description = "车辆型号")
private String vehicleModel;
/**
*
*/
@Schema(title = "车辆行驶证", type = "String", defaultValue = "111111", description = "车辆行驶证")
private String vehicleLicense;
/**
*
*/
@Schema(title = "行驶证到期日期", type = "Date", defaultValue = "2024-01-01 00:00:00", description = "行驶证到期日期")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date vehicleLicenseDueDate;
/**
*
*/
@Schema(title = "车辆状态", type = "String", defaultValue = "OFFLINE", description = "车辆状态")
private String vehicleStatus;
/**
*
*/
@Schema(title = "车辆所属企业外键", type = "BigInt", defaultValue = "1", description = "车辆所属企业外键")
private Long companyId;
/**
*
*/
@Schema(title = "电子围栏外键", type = "Integer", defaultValue = "1", description = "电子围栏外键")
private Integer fenceGroupId;
}

View File

@ -0,0 +1,64 @@
package com.muyu.enterprise.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.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.domain.resp
* @Projectcloud-server
* @nameElectronicFenceGroupResp
* @Date2024/9/22 10:22
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "回显围栏组及绑定的电子围栏")
public class ElectronicFenceGroupResp {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
/**
*
*/
List<ElectronicFenceResp> electronicFenceRespList;
}

View File

@ -0,0 +1,71 @@
package com.muyu.enterprise.domain.resp;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectronicFence
* @Date2024/9/17 16:34
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class ElectronicFenceResp {
/**
* id
*/
private Long id;
/**
*
*/
private String name;
/**
*
*/
private String fenceType;
/**
*
*/
private String longitudeLatitude;
/**
*
*/
private String status;
/**
*
*/
private String desc;
//private String groupType;
//
//private int priority;
}

View File

@ -0,0 +1,96 @@
package com.muyu.enterprise.domain.resp;
import com.muyu.common.core.annotation.Excel;
import com.muyu.enterprise.domain.SysCarFault;
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.function.Supplier;
/**
*
* @author chenruijia
* @Date 2024/9/28 21:11
* @Description FaultResp:
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "故障返回")
public class FaultResp {
/**
*
*/
@Schema(defaultValue = "车辆故障码",type = "String",description = "车辆故障码")
private String faultCode;
/**
* ID
*/
@Schema(defaultValue = "车辆故障那类型ID",type = "Integer",description = "车辆故障类型ID")
private Integer faultTypeId;
/**
* ID
*/
@Schema(defaultValue = "车辆故障规则ID",type = "Integer",description = "车辆故障规则ID")
public Integer faultRuleId;
/**
* VIN
*/
@Schema(defaultValue = "故障VIN编码",type = "String",description = "故障VIN编码")
public String carVin;
/**
*
*/
@Schema(defaultValue = "车辆故障标签",type = "String",description = "车辆故障标签")
public String faultLabel;
/**
*
*/
@Schema(defaultValue = "车辆故障位",type = "String",description = "车辆故障位")
public String faultBit;
/**
*
*/
@Schema(defaultValue = "车辆故障值",type = "String",description = "车辆故障值")
public String faultValue;
/**
* v
*/
@Schema(defaultValue = "故障级别",type = "String",description = "故障级别")
public String faultWarn;
/**
*
*/
@Schema(defaultValue = "报警状态",type = "String",description = "报警状态")
public String warnStatus;
/**
*
*/
@Schema(defaultValue = "故障描述信息",type = "String",description = "故障描述信息")
public String faultDesc;
/**
*
*/
@Schema(defaultValue = "启用状态",type = "Integer",description = "启用状态")
public Integer state;
/**
*
*/
@Schema(defaultValue = "故障规则名称",type = "String",description = "故障规则名称")
public String faultRuleName;
/**
*
*/
@Schema(defaultValue = "故障规则参数",type = "String",description = "故障规则参数")
public String faultRuleParameter;
/**
*
*/
@Schema(defaultValue = "故障规则描述",type = "String",description = "故障规则描述")
public String faultRuleDescription;
}

View File

@ -0,0 +1,57 @@
package com.muyu.enterprise.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.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author
* @Packagecom.muyu.fence.domain.req
* @Projectcloud-server
* @nameGroupFenceListresp
* @Date2024/9/20 9:04
*
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "围栏组列表")
public class GroupFenceListresp {
/**
*
*/
@TableId(value = "id",type = IdType.AUTO)
private Long id;
/**
*
*/
private Integer priority;
/**
*
*/
private String groupName;
/**
*
*/
private String groupType;
/**
*
*/
private String status;
}

View File

@ -0,0 +1,56 @@
package com.muyu.enterprise.domain.resp.car;
import com.muyu.enterprise.domain.car.MessageTemplate;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.car.domain.resp
* @Projectcloud-server
* @nameMessageTemplateListResp
* @Date2024/9/26 20:32
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "报文模版列表", description = "负责报文模版管理列表的相应数据")
public class MessageTemplateListResp
{
/**
*
*/
private String messageTemplateId;
/**
*
*/
private String messageTemplateName;
/**
*
*/
private String messageTemplateDescribe;
/**
*
* @param messageTemplate
* @return
*/
public static MessageTemplateListResp messageTemplateBuild(MessageTemplate messageTemplate) {
return MessageTemplateListResp.builder()
.messageTemplateId(messageTemplate.getMessageTemplateId())
.messageTemplateName(messageTemplate.getMessageTemplateName())
.messageTemplateDescribe(messageTemplate.getMessageTemplateDescribe())
.build();
}
}

View File

@ -0,0 +1,68 @@
package com.muyu.enterprise.domain.resp.car;
import com.muyu.enterprise.domain.car.MessageValue;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Author
* @Packagecom.muyu.car.domain.resp
* @Projectcloud-server
* @nameMessageValueListResp
* @Date2024/9/26 20:33
* @Description:
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Tag(name = "报文数据列表", description = "负责报文数据管理列表的相应数据")
public class MessageValueListResp
{
/**
*
*/
private Long messageId;
/**
*
*/
private String messageType;
/**
*
*/
private String messageCode;
/**
*
*/
private String messageLabel;
/**
*
*/
private Integer messageStartIndex;
/**
*
*/
private Integer messageEndIndex;
public static MessageValueListResp valueBuild(MessageValue messageValue){
return MessageValueListResp.builder()
.messageId(messageValue.getMessageId())
.messageType(messageValue.getMessageType())
.messageCode(messageValue.getMessageCode())
.messageLabel(messageValue.getMessageLabel())
.messageStartIndex(messageValue.getMessageStartIndex())
.messageEndIndex(messageValue.getMessageEndIndex())
.build();
}
}

View File

@ -0,0 +1,75 @@
package com.muyu.enterprise.domain.resp.car;
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;
/**
*
* @Author
* @Packagecom.muyu.car.domain.resp
* @Projectcloud-server
* @nameVehicleManageResp
* @Date2024/9/26 20:33
*
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@Tag(name = "车辆管理列表",description = "负责车辆管理列表的相应数据")
public class VehicleManageResp
{
/**
*
*/
@Schema(type = "Long",defaultValue = "1",description = "车辆主键")
private Long vehicleId;
/**
*
*/
@Schema(type = "String", defaultValue = "冀A93827", description = "车牌号")
private String licenceNumber;
/**
*
*/
@Schema(type = "String", defaultValue = "", description = "车辆颜色")
private String vehicleColor;
/**
* VIN
*/
@Schema(type = "String", defaultValue = "LDC913L2240606423", description = "车辆VIN")
private String vehicleVin;
/**
*
*/
@Schema(type = "Long", defaultValue = "新能源", description = "车辆类型")
private String vehicleTypeName;
/**
*
*/
@Schema(title = "车辆品牌", type = "String", defaultValue = "1", description = "车辆品牌")
private String vehicleBrand;
/**
*
*/
@Schema(title = "车辆型号", type = "String", defaultValue = "1", description = "车辆型号")
private String vehicleModel;
/**
*
*/
@Schema(type = "String", defaultValue = "", description = "车辆状态")
private String vehicleStatus;
}

View File

@ -0,0 +1,75 @@
package com.muyu.enterprise.domain.utils;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectricFenceModel
* @Date2024/9/17 17:27
*/
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ElectricFenceModel implements Comparable<ElectricFenceModel> {
//车架号
private String vin = "";
//电子围栏结果表UUID
private Long uuid = -999999L;
//上次状态 0 里面 1 外面
private int lastStatus = -999999;
//当前状态 0 里面 1 外面
private int nowStatus = -999999;
//位置时间 yyyy-MM-dd HH:mm:ss
private String gpsTime = "";
//位置纬度--
private Double lat = -999999D;
//位置经度--
private Double lng = -999999D;
//电子围栏ID
private int eleId = -999999;
//电子围栏名称
private String eleName = "";
//中心点地址
private String address = "";
//中心点纬度
private Double latitude;
//中心点经度
private Double longitude = -999999D;
//电子围栏半径
private Float radius = -999999F;
//出围栏时间
private String outEleTime = null;
//进围栏时间
private String inEleTime = null;
//是否在mysql结果表中
private Boolean inMysql = false;
//状态报警 0出围栏 1进围栏
private int statusAlarm = -999999;
//报警信息
private String statusAlarmMsg = "";
//终端时间
private String terminalTime = "";
// 扩展字段 终端时间
private Long terminalTimestamp = -999999L;
@Override
public int compareTo(ElectricFenceModel o) {
if(this.getTerminalTimestamp() > o.getTerminalTimestamp()){
return 1;
}
else if(this.getTerminalTimestamp() < o.getTerminalTimestamp()){
return -1;
}else{
return 0;
}
}
}

View File

@ -0,0 +1,53 @@
package com.muyu.enterprise.domain.utils;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectricFenceResultTmp
* @Date2024/9/17 17:57
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ElectricFenceResultTmp {
//电子围栏id
private int id;
//电子围栏名称
private String name;
//电子围栏中心地址
private String address;
//电子围栏半径
private float radius;
//电子围栏中心点的经度
private double longitude;
//电子围栏中心点的维度
private double latitude;
//电子围栏的开始时间
private Date startTime;
//电子围栏的结束时间
private Date endTime;
@Override
public String toString() {
return "ElectricFenceResultTmp{" +
"id=" + id +
", name='" + name + '\'' +
", address='" + address + '\'' +
", radius=" + radius +
", longitude=" + longitude +
", latitude=" + latitude +
", startTime=" + startTime +
", endTime=" + endTime +
'}';
}
}

View File

@ -0,0 +1,54 @@
package com.muyu.enterprise.domain.utils;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectronicFenceResult
* @Date2024/9/17 17:43
*/
/**
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class ElectronicFenceResult {
/**
*
*/
private Long id;
/**
*
*/
private String vin;
/**
*
*/
private String inTime;
private String outTime;
/**
* gps
*/
private Date gpsTime;
private Double lat;
private Double lng;
private Integer eleId;
private String eleName;
private String address;
private Double latitude;
private Double longitude;
private Double radius;
private String terminalTime;
private Date processTime;
}

View File

@ -0,0 +1,63 @@
package com.muyu.enterprise.domain.utils;
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;
/**
*
* @Author
* @Packagecom.muyu.fence.domain
* @Projectcloud-server
* @nameElectronicFenceSetting
* @Date2024/9/17 16:47
*/
@Data
@SuperBuilder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "electronic_fence_setting",autoResultMap = true)
public class ElectronicFenceSetting {
/**
* id
*/
@TableId(value = "id",type = IdType.AUTO)
private String id;
/**
*
*/
private String name;
/**
*
*/
private String address;
/**
*
*/
private String radius;
/**
*
*/
private String longitude;
/**
*
*/
private String latitude;
/**
*
*/
private String startTime;
/**
*
*/
private String endTime;
/**
* (,)
*/
private String status;
}

View File

@ -0,0 +1,28 @@
package com.muyu.enterprise.domain.utils;
/**
*
* @Author
* @Packagecom.muyu.car.utils
* @Projectcloud-server
* @nameVehicleConstant
* @Date2024/9/26 20:26
*/
public class VehicleConstant
{
/**
*
*/
public static final String DATA_PACK_SEPARATOR = "#$&";
/**
*
*/
public static final String MSG_START = "7E";
/**
*
*/
public static final String MSG_END = "7E";
}

View File

@ -0,0 +1,61 @@
package com.muyu.enterprise.domain.vo;
/**
*
*
* @ClassName CarTemplateVO
* @PATH com.muyu.enterprise.domain.vo:
* @Date 2024/10/9 20:42
* @author MingWei.Zong()
*/
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.*;
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@TableName(value = "car_template",autoResultMap = true)
public class CarTemplateVO {
/**
*
*/
@TableId(value = "template_id",type = IdType.AUTO)
private Long templateId;
/**
*
*/
private String templateName;
/**
*
*/
private String templateDescribe;
/**
*
*/
private String remark;
/**
*
*/
private Long messageId;
/**
*
*/
private String messageType;
/**
*
*/
private Integer messageStartIndex;
/**
*
*/
private Integer messageEndIndex;
/**
*
*/
private String messageLabel;
}

View File

@ -0,0 +1,31 @@
<?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-remote</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>
<description>
cloud-modules-enterprise-remote 企业远程调用模块
</description>
<dependencies>
<!-- 企业公共模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-common</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,38 @@
package com.muyu.enterprise.remote;
import com.muyu.enterprise.remote.factory.RemoteMessageValueServiceFactory;
import com.muyu.common.core.constant.ServiceNameConstants;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.analysis.parsing.feign
* @Projectcloud-server
* @nameRemoteServiceClient
* @Date2024/9/28 20:38
*/
@FeignClient(
path = "/messageValue",
contextId = "remoteMessageValueService",
value = ServiceNameConstants.ENTERPRISE_SERVICE,
fallbackFactory= RemoteMessageValueServiceFactory.class
)
public interface RemoteMessageValueService {
/**
* id
* @param templateId
* @return
*/
@GetMapping("/findByTemplateId/{templateId}")
// @Operation(summary = "根据报文模版id查询报文数据", description = "根据报文模版id查询报文数据")
public Result<List<MessageValueListResp>> findByTemplateId(@PathVariable("templateId") Long templateId);
}

View File

@ -0,0 +1,33 @@
package com.muyu.enterprise.remote;
import com.muyu.common.core.constant.ServiceNameConstants;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.remote.factory.RemoteVehicleServiceFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
*
* @Author
* @Packagecom.muyu.enterprise.remote
* @Projectcloud-server
* @nameRemoteVehicleService
* @Date2024/10/7 20:53
*/
@FeignClient(
path = "/vehicleManage",
contextId = "remoteVehicleService",
value = ServiceNameConstants.ENTERPRISE_SERVICE,
fallbackFactory= RemoteVehicleServiceFactory.class
)
public interface RemoteVehicleService {
/**
* vinid
* @param vehicleVin
* @return
*/
@GetMapping("/findByVehicleVin/{vehicleVin}")
public Result<Long> findByVehicleVin(@PathVariable("vehicleVin") String vehicleVin);
}

View File

@ -0,0 +1,37 @@
package com.muyu.enterprise.remote.factory;
import com.muyu.enterprise.remote.RemoteMessageValueService;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.openfeign.FallbackFactory;
import org.springframework.stereotype.Component;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.analysis.parsing.remote.factory
* @Projectcloud-server
* @nameRemoteServiceClientFactory
* @Date2024/9/28 21:16
*/
@Component
public class RemoteMessageValueServiceFactory
implements FallbackFactory<RemoteMessageValueService>
{
private static final Logger log = LoggerFactory.getLogger(RemoteMessageValueServiceFactory.class);
@Override
public RemoteMessageValueService create(Throwable throwable) {
log.error("报文模版传参调用失败:{}", throwable.getMessage());
return new RemoteMessageValueService(){
@Override
public Result<List<MessageValueListResp>> findByTemplateId(Long templateId) {
return Result.error("报文模版传参调用失败" + throwable.getMessage());
}
};
}
}

View File

@ -0,0 +1,34 @@
package com.muyu.enterprise.remote.factory;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import com.muyu.enterprise.remote.RemoteVehicleService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.openfeign.FallbackFactory;
import org.springframework.stereotype.Component;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.enterprise.remote.factory
* @Projectcloud-server
* @nameRemoteVehicleServiceFactory
* @Date2024/10/7 20:57
*/
@Component
public class RemoteVehicleServiceFactory implements FallbackFactory<RemoteVehicleService> {
private static final Logger log = LoggerFactory.getLogger(RemoteVehicleServiceFactory.class);
@Override
public RemoteVehicleService create(Throwable throwable) {
return new RemoteVehicleService() {
@Override
public Result<Long> findByVehicleVin(String vehicleVin) {
return Result.error("报文模版传参调用失败" + throwable.getMessage());
}
};
}
}

View File

@ -0,0 +1,2 @@
com.muyu.enterprise.remote.factory.RemoteVehicleServiceFactory
com.muyu.enterprise.remote.factory.RemoteMessageValueServiceFactory

View File

@ -22,6 +22,12 @@
</description>
<dependencies>
<!-- mybatis-plus-join依赖 -->
<dependency>
<groupId>com.github.yulichang</groupId>
<artifactId>mybatis-plus-join-boot-starter</artifactId>
<version>1.4.11</version>
</dependency>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
@ -95,7 +101,7 @@
<artifactId>cloud-modules-enterprise-common</artifactId>
</dependency>
<!-- MyBatisPlus - 依赖包 -->
<!-- MyBatisPlusJoin 依赖包 -->
<dependency>
<groupId>com.github.yulichang</groupId>
<artifactId>mybatis-plus-join</artifactId>

View File

@ -8,7 +8,8 @@ import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
/**
*
*
*
* @author muyu
*/
@EnableCustomConfig
@ -24,4 +25,7 @@ public class CloudEnterpriseApplication {
public RestTemplate restTemplate() {
return new RestTemplate();
}
}

View File

@ -1,23 +1,17 @@
package com.muyu.enterprise.controller;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.RandomUtil;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.enterprise.domain.CarManage;
import com.muyu.enterprise.domain.CarMessage;
import com.muyu.enterprise.domain.dto.CarDTO;
import com.muyu.enterprise.domain.vo.CarVO;
import com.muyu.enterprise.service.CarCompanyService;
import com.muyu.enterprise.service.CarManageService;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.utils.SecurityUtils;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@ -100,7 +94,8 @@ public class CarManageController extends BaseController {
// 随机生成VIN码
String key2 = RandomUtil.randomNumbers(17);
carVO.setCarVin(key2);
carManageService.insertCar(carVO);
// carVO
// carManageService.insertCar();
return Result.success("添加成功");
}

View File

@ -3,12 +3,11 @@ package com.muyu.enterprise.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.enterprise.cache.CarMessageCacheService;
import com.muyu.enterprise.domain.CarMessage;
import com.muyu.enterprise.service.CarMessageService;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@ -27,8 +26,10 @@ import java.util.List;
@Tag(name = "报文",description = "报文模块")
public class CarMessageController extends BaseController {
private final CarMessageCacheService carMessageCacheService;
// private final CarMessageCacheService carMessageCacheService;
private final CarMessageService sysCarMessageService;
@Autowired
private CarMessageService carMessageService;
/**
*
@ -67,7 +68,7 @@ public class CarMessageController extends BaseController {
public Result insertMessage(@RequestBody CarMessage carMessage){
sysCarMessageService.save(carMessage);
//报文 redis
carMessageCacheService.put(carMessage.getMessageType(),new CarMessage());
// carMessageCacheService.put(carMessage.getMessageType(),new CarMessage());
return Result.success("添加成功");
}
/**

View File

@ -45,10 +45,20 @@ public class CarTypeController {
* @return
*/
@PostMapping("/catTypeId")
private Result<CarType> catTypeId(@RequestParam("catTypeId") Integer catTypeId) {
private Result<CarType> catTypeId(@RequestParam("catTypeId") Long catTypeId) {
CarType carType = carTypeService.findById(catTypeId);
return Result.success(carType);
}
/**
* id
* @param templateId
* @return
*/
@PostMapping("/selectCarTemplateByTemplateId")
private Result<CarType> selectCarTemplateByTemplateId(@RequestParam("templateId") Long templateId) {
CarType carType = carTypeService.SelectCarTemplateByTemplateId(templateId);
return Result.success(carType);
}
}

View File

@ -0,0 +1,145 @@
package com.muyu.enterprise.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.dateBase.ElectronicFence;
import com.muyu.enterprise.domain.req.ElectroicFenceAddReq;
import com.muyu.enterprise.domain.req.ElectroicFenceListReq;
import com.muyu.enterprise.domain.req.ElectroicFenceUpdReq;
import com.muyu.enterprise.domain.req.FenceWayReq;
import com.muyu.enterprise.domain.resp.ElectronicFenceResp;
import com.muyu.enterprise.service.ElectronicFenceService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.controller
* @Projectcloud-server
* @nameFenceEtlController
* @Date2024/9/17 16:28
*/
/**
*
*/
@Log4j2
@Tag(name = "电子围栏控制层")
@RestController
@RequestMapping("/fence")
@RequiredArgsConstructor
public class ElectronicFenceController {
/**
*
*/
@Resource
private ElectronicFenceService electronicFenceService;
@PostMapping("/fenceArray")
@Operation(description = "查询所有可用的围栏")
public Result<List<ElectronicFenceResp>> fenceArray() {
System.out.println("=====>" + "hgfvhgjy");
return Result.success(electronicFenceService.fenceArray());
}
@PostMapping("/fenceselectList")
@Operation(description = "列表")
public Result<List<ElectronicFenceResp>> fenceselectList(@RequestBody ElectroicFenceListReq electroicFenceListReq) {
System.out.println("=====>" + "hgfvhgjy");
return Result.success(electronicFenceService.fenceselectList(electroicFenceListReq));
}
@PostMapping("/add")
@Operation(description = "添加")
public Result AddFence(@RequestBody ElectroicFenceAddReq electroicFenceAddReq) {
electronicFenceService.unquireFence(electroicFenceAddReq.getName());
electronicFenceService.AddFence(electroicFenceAddReq);
return Result.success();
}
@PostMapping("/upd/{id}")
@Operation(description = "修改")
public Result UpdFence(@PathVariable("id") Long id, @RequestBody ElectroicFenceUpdReq electroicFenceUpdReq) {
electronicFenceService.updateById(ElectronicFence.buildByElectronicUpd(electroicFenceUpdReq, () -> id));
return Result.success();
}
@PostMapping("/findElectronicByid/{id}")
@Operation(description = "通过id回显围栏信息")
public Result<ElectronicFence> findElectronicByid(@PathVariable("id") Long id) {
ElectronicFence electronicFence= electronicFenceService.findElectronicByid(id);
return Result.success(electronicFence);
}
// @PostMapping("/delElectronById/{id}")
// @Operation(description = "通过id删除围栏")
// public Result delElectronById(@PathVariable("id") Long id) {
//
// electronicFenceService.delElectronById(id);
//
// return Result.success();
// }
/**
*
* @param electronicFenceId
* @return
*/
@DeleteMapping("/{electronicFenceId}")
@Operation(summary = "电子围栏表信息表删除",
description = "通过ID删除电子围栏表信息")
public Result<String> remove(@PathVariable("electronicFenceId") Long electronicFenceId)
{
boolean b = electronicFenceService.removeById(electronicFenceId);
return Result.success(null, "操作成功");
}
@PostMapping("/open/{id}")
@Operation(description = "开启围栏")
public Result openFence(@PathVariable("id") Long id) {
electronicFenceService.openFence(id);
return Result.success();
}
@PostMapping("/close/{id}")
@Operation(description = "关闭围栏")
public Result closeFence(@PathVariable("id") Long id) {
electronicFenceService.closeFence(id);
return Result.success();
}
@PostMapping("/setFenceWay")
@Operation(description = "设置电子围栏的位置")
public Result setFenceWay(@RequestBody FenceWayReq fenceWayReq) {
Long id = fenceWayReq.getId();
String longitudeLatitude = fenceWayReq.getLongitudeLatitude();
log.info("接收到的数据,:{}" + id + "====" + longitudeLatitude);
electronicFenceService.setFenceWay(id, longitudeLatitude);
return Result.success();
}
}

View File

@ -0,0 +1,132 @@
package com.muyu.enterprise.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.dateBase.ElectronicFenceGroup;
import com.muyu.enterprise.domain.req.ElectronicFenceGroupAddReq;
import com.muyu.enterprise.domain.req.ElectronicFenceGroupListReq;
import com.muyu.enterprise.domain.req.ElectronicFenceGroupUpdReq;
import com.muyu.enterprise.domain.resp.ElectronicFenceGroupResp;
import com.muyu.enterprise.domain.resp.GroupFenceListresp;
import com.muyu.enterprise.service.ElectronicFenceGroupService;
import com.muyu.enterprise.service.FenceGroupMidService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @Author
* @Packagecom.muyu.fence.controller
* @Projectcloud-server
* @nameFenceGroupController
* @Date2024/9/18 15:15
*/
/**
*
*/
@Log4j2
@RestController
@RequestMapping("/group")
@Tag(name = "围栏组控制层")
public class ElectronicFenceGroupController {
/**
*
*/
@Autowired
private ElectronicFenceGroupService electronicFenceGroupService;
@Autowired
private FenceGroupMidService fenceGroupMidService;
@PostMapping("/selectGroupList")
public Result<List<GroupFenceListresp>> selectGroupList(@RequestBody ElectronicFenceGroupListReq req) {
//查询所有的围栏组
List<ElectronicFenceGroup> fenceListList = electronicFenceGroupService.selectGroupList(req);
List<GroupFenceListresp> list = fenceListList.stream().map(ElectronicFenceGroup::buildGroupFence).toList();
return Result.success(list);
}
@Transactional
@PostMapping("/addGroup")
public Result addGroup(@RequestBody ElectronicFenceGroupAddReq addReq) {
ElectronicFenceGroup electronicFenceGroup = ElectronicFenceGroup.buildByAdd(addReq);
//添加围栏组返回添加后的主键自增id
electronicFenceGroupService.save(electronicFenceGroup);
Long id = electronicFenceGroup.getId();
//添加中间表
fenceGroupMidService.addGroupAndFenceMid(id, addReq.getElectronicFenceRespList());
return Result.success();
}
@PostMapping("/findGroupByid/{id}")
@Operation(description = "通过id回显围栏组信息")
public Result<ElectronicFenceGroupResp> findGroupByid(@PathVariable("id") Long id) {
ElectronicFenceGroupResp fenceGroupResp = electronicFenceGroupService.findGroupByid(id);
return Result.success(fenceGroupResp);
}
@Transactional
@PostMapping("/updGroup/{id}")
@Operation(description = "修改")
public Result UpdFence(@PathVariable("id") Long id, @RequestBody ElectronicFenceGroupUpdReq req) {
electronicFenceGroupService.updateById(ElectronicFenceGroup.buildByUpd(req, () -> id));
if (!CollectionUtils.isEmpty(req.getElectronicFenceRespList())) {
//删除中间表
fenceGroupMidService.deliteMid(id);
//增加中间表
fenceGroupMidService.addGroupAndFenceMid(id, req.getElectronicFenceRespList());
}
return Result.success();
}
/**
*
* @param findGroupId
* @return
*/
@DeleteMapping("/{findGroupId}")
@Operation(summary = "围栏组表信息表删除",
description = "通过ID删除围栏组表信息")
public Result<String> remove(@PathVariable("findGroupId") Long findGroupId)
{
boolean b = electronicFenceGroupService.removeById(findGroupId);
return Result.success(null, "操作成功");
}
/**
*
* @param findId
* @return
*/
@DeleteMapping("/findId/{findId}")
@Operation(summary = "围栏链信息表删除",
description = "通过ID删除围栏链表信息")
public Result<String> findId(@PathVariable("findId") Long findId)
{
boolean b = fenceGroupMidService.removeById(findId);
return Result.success(null, "操作成功");
}
}

View File

@ -2,8 +2,8 @@ package com.muyu.enterprise.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.enterprise.domain.FaultrRule;
import com.muyu.enterprise.service.FaultrRuleService;
import com.muyu.enterprise.domain.FaultRule;
import com.muyu.enterprise.service.FaultRuleService;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@ -14,42 +14,44 @@ import java.util.List;
*
* @author chenruijia
* @Date 2024/9/28 11:58
* @Description FaultrRuleController:
* @Description FaultRuleController:
*/
@RestController
@RequestMapping("/rule")
@Tag(name = "故障的规则",description = "对故障数据规则的判断")
public class FaultrRuleController {
public class FaultRuleController {
@Autowired
private FaultrRuleService faultrRuleService;
private FaultRuleService faultRuleList;
/**
*
*/
@RequestMapping(value = "/faultRuleList", method = RequestMethod.GET)
public Result<List<FaultrRule>> faultRuleList(FaultrRule faultrRule)
public Result<List<FaultRule>> faultRuleList(FaultRule faultRule)
{
List<FaultrRule> list = faultrRuleService.faultRuleList(faultrRule);
List<FaultRule> list = faultRuleList.faultRuleList(faultRule);
return Result.success(list);
}
/**
*
* @param faultrRule
* @param faultRule
* @return
*/
@RequestMapping(value = "/insertRule",method = RequestMethod.POST)
public Result insertRule(@RequestBody FaultrRule faultrRule){
return Result.success(faultrRuleService.save(faultrRule));
public Result insertRule(@RequestBody FaultRule faultRule){
return Result.success(faultRuleList.save(faultRule));
}
/**
*
* @param faultrRule
* @param faultRule
* @return
*/
@RequestMapping(value = "/updateRule",method = RequestMethod.POST)
public Result updateRule(@RequestBody FaultrRule faultrRule){
return Result.success(faultrRuleService.updateById(faultrRule));
public Result updateRule(@RequestBody FaultRule faultRule){
return Result.success(faultRuleList.updateById(faultRule));
}
/**
@ -59,7 +61,7 @@ public class FaultrRuleController {
*/
@RequestMapping(value = "/byidRuleId/{faultRuleId}",method = RequestMethod.GET)
public Result byidRuleId(@PathVariable Long faultRuleId){
FaultrRule byid = faultrRuleService.byidRuleId(faultRuleId);
FaultRule byid = faultRuleList.byidRuleId(faultRuleId);
return Result.success(byid);
}
@ -69,7 +71,7 @@ public class FaultrRuleController {
@RequestMapping(value = "/remove/{ids}",method = RequestMethod.DELETE)
public Result<Integer> remove(@PathVariable("ids") Long[] ids)
{
faultrRuleService.removeBatchByIds(Arrays.asList(ids));
faultRuleList.removeBatchByIds(Arrays.asList(ids));
return Result.success();
}

View File

@ -7,6 +7,7 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.enterprise.domain.WarnLogs;
import com.muyu.enterprise.service.IWarnLogsService;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
@ -23,6 +24,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/logs")
@Tag(name = "车辆预警日志",description = "用来记录车辆预警的日志")
public class WarnLogsController extends BaseController
{
@Resource

View File

@ -8,6 +8,7 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.enterprise.domain.WarnRule;
import com.muyu.enterprise.service.IWarnRuleService;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
@ -24,6 +25,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/rule")
@Tag(name = "车辆预警规则",description = "用来客户添加或者修改规则")
public class WarnRuleController extends BaseController
{
@Resource

View File

@ -6,6 +6,7 @@ import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.enterprise.service.IWarnStrategyService;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
@ -22,6 +23,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/strategy")
@Tag(name = "故障策略",description = "故障策略对应车辆类型用来客户选择")
public class WarnStrategyController extends BaseController
{

View File

@ -0,0 +1,85 @@
package com.muyu.enterprise.controller.car;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.domain.car.MessageTemplate;
import com.muyu.enterprise.domain.req.car.MessageTemplateAddReq;
import com.muyu.enterprise.domain.resp.car.MessageTemplateListResp;
import com.muyu.enterprise.service.car.MessageTemplateService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.car.controller
* @Projectcloud-server
* @nameMessageTemplateController
* @Date2024/9/26 22:08
* @Description:
*/
@Log4j2
@RestController
@RequestMapping("messageTemplate")
@Tag(name = "报文模版控制层", description = "进行报文模版操作")
public class MessageTemplateController extends BaseController
{
@Autowired
private MessageTemplateService messageTemplateService;
/**
*
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.POST)
@Operation(summary = "报文模版列表查询", description = "报文模版列表查询")
public Result<List<MessageTemplateListResp>> findAll() {
List<MessageTemplate> list = messageTemplateService.list();
List<MessageTemplateListResp> messageTemplateListRespList = list.stream()
.map(template -> MessageTemplateListResp.messageTemplateBuild(
template
)
)
.toList();
return Result.success(messageTemplateListRespList);
}
/**
*
* @param messageTemplateAddReq
* @return
*/
@Transactional
@PostMapping("/")
@Operation(summary = "新增添加报文模版", description = "新增添加报文模版")
public Result<String> save(@RequestBody MessageTemplateAddReq messageTemplateAddReq) {
messageTemplateService.save(MessageTemplate.addBuild(messageTemplateAddReq));
return Result.success("添加成功");
}
/**
*
* @param messageTemplateId
* @return
*/
@Transactional
@DeleteMapping("/{messageTemplateId}")
@Operation(summary = "删除报文模版", description = "删除报文模版")
public Result<String> delete(@PathVariable("messageTemplateId") Long messageTemplateId) {
messageTemplateService.removeById(messageTemplateId);
return Result.success("删除成功");
}
}

View File

@ -0,0 +1,121 @@
package com.muyu.enterprise.controller.car;
import cn.hutool.json.JSONObject;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.domain.car.MessageValue;
import com.muyu.enterprise.domain.req.car.MessageValueAddReq;
import com.muyu.enterprise.domain.req.car.MessageValueReq;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import com.muyu.enterprise.service.car.MessageValueService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import java.nio.charset.StandardCharsets;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.car.controller
* @Projectcloud-server
* @nameMessageValueController
* @Date2024/9/26 22:11
* @Description:
*/
@Log4j2
@RestController
@RequestMapping("/messageValue")
@Tag(name = "报文数据控制层", description = "进行报文数据操作")
public class MessageValueController extends BaseController
{
@Autowired
private MessageValueService messageValueService;
/**
*
* @param messageValueReq
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.POST)
@Operation(summary = "报文数据列表", description = "根据报文类别, 报文模版筛选报文数据")
public Result<List<MessageValueListResp>> findAll(@RequestBody MessageValueReq messageValueReq) {
List<MessageValueListResp> list = messageValueService.findAll(messageValueReq);
return Result.success(list);
}
/**
* 使
* @return
*/
@GetMapping("/allList")
@Operation(summary = "报文数据下拉框", description = "全部报文数据下拉框")
public Result<List<MessageValueListResp>> findAllList() {
List<MessageValueListResp> list = messageValueService.list().stream().map(
value -> MessageValueListResp.valueBuild(
value
)
).toList();
return Result.success(list);
}
/**
*
* @param messageValueAddReq
* @return
*/
@Transactional
@PostMapping("/add")
@Operation(summary = "添加报文数据", description = "新增报文数据")
public Result<String> save(@RequestBody MessageValueAddReq messageValueAddReq) {
messageValueService.save(MessageValue.addBuild(messageValueAddReq));
return Result.success("添加成功");
}
/**
* id
* @param messageId
* @return
*/
@DeleteMapping("/{messageId}")
@Operation(summary = "删除报文数据", description = "删除报文数据")
public Result<String> delete(@PathVariable Long messageId) {
messageValueService.removeById(messageId);
return Result.success("删除成功");
}
//7E 56 49 4e 31 32 33 34 35 36 37 38 39 31 32 33 34 35 32 33 35 36 37 38 39 31 32 33 34 35 31 31 36 2e 36 36 34 30 35 33 30 33 39 2e 35 33 31 37 39 31 30 32 30 30 2e 30 30 35 38 36 37 38 33 37 2e 33 32 34 36 33 35 2e 31 32 33 39 2e 34 39 31 36 38 37 39 38 2e 35 36 50 30 39 30 38 31 39 2e 39 39 39 39 2e 38 36 30 39 39 39 39 39 31 30 30 30 31 33 39 2e 34 36 31 34 2e 36 38 31 31 33 36 39 2e 38 39 31 30 30 2e 30 30 31 30 30 2e 30 30 31 30 30 2e 30 30 31 33 31 34 2e 36 35 33 36 30 2e 35 38 34 2e 35 36 33 2e 32 35 31 30 30 2e 30 30 39 38 2e 32 33 30 33 36 2e 32 36 30 30 30 30 30 30 30 30 30 30 30 30 30 30 30 30 30 30 76 7E
/**
*
* @param testStr
* @return
*/
@PostMapping("/analysis/{testStr}")
@Operation(summary = "测试解析报文", description = "解析报文测试")
public Result<JSONObject> analysis(@PathVariable("testStr") String testStr){
JSONObject messageValue = messageValueService.analysis(testStr);
return Result.success(messageValue);
}
/**
* id
* @param templateId
* @return
*/
@GetMapping("/findByTemplateId/{templateId}")
@Operation(summary = "根据报文模版id查询报文数据", description = "根据报文模版id查询报文数据")
public Result<List<MessageValueListResp>> findByTemplateId(@PathVariable("templateId") Long templateId){
List<MessageValueListResp> list = messageValueService.findByTemplateId(templateId);
return Result.success(list);
}
}

View File

@ -0,0 +1,142 @@
package com.muyu.enterprise.controller.car;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.log.annotation.Log;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.domain.req.car.VehicleAddReq;
import com.muyu.enterprise.domain.req.car.VehicleManageReq;
import com.muyu.enterprise.domain.req.car.VehicleUpdReq;
import com.muyu.enterprise.domain.resp.car.VehicleManageResp;
import com.muyu.enterprise.service.car.VehicleService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.car.controller
* @Projectcloud-server
* @nameVehicleController
* @Date2024/9/26 22:17
* @Description:
*/
@Log4j2
@RestController
@RequestMapping("/vehicleManage")
@Tag(name = "车辆管理控制层", description = "进行车辆管理操作")
public class VehicleController extends BaseController
{
@Autowired
private VehicleService vehicleService;
/**
*
* @param vehicleManageReq
* @return
*/
@RequestMapping(path = "/list", method = RequestMethod.POST)
@Operation(summary = "车辆管理列表", description = "根据车牌号、VIN码、车辆状态筛选车辆")
public Result<TableDataInfo<VehicleManageResp>> getVehicleList(@RequestBody VehicleManageReq vehicleManageReq) {
startPage();
List<VehicleManageResp> list = vehicleService.getVehicleList(vehicleManageReq);
return getDataTable(list);
}
/**
*
* @param vehicleAddReq
* @return
*/
@PostMapping("/")
@Operation(summary = "新增车辆", description = "录入车辆信息")
public Result<String> save(@RequestBody VehicleAddReq vehicleAddReq) {
vehicleService.save(Vehicle.addBuild(vehicleAddReq));
return Result.success("录入成功");
}
/**
* id
* @param vehicleId
* @return
*/
@GetMapping("/{vehicleId}")
@Operation(summary = "通过id查询车辆信息", description = "通过id查询车辆信息")
public Result<Vehicle> findById(@PathVariable("vehicleId") Long vehicleId) {
return Result.success(vehicleService.getById(vehicleId));
}
/**
*
* @param vehicleId
* @param vehicleUpdReq
* @return
*/
@PutMapping("/{vehicleId}")
@Operation(summary = "修改车辆信息", description = "修改车辆信息")
public Result<String> update(
@PathVariable("vehicleId") Long vehicleId,
@RequestBody @Validated VehicleUpdReq vehicleUpdReq) {
vehicleService.updateById(Vehicle.updBuild(vehicleUpdReq, () -> vehicleId));
return Result.success("修改成功");
}
/**
* id
* @param vehicleId
* @return
*/
@DeleteMapping("/{vehicleId}")
@Operation(summary = "通过车辆id删除车辆信息", description = "通过车辆id删除车辆信息")
public Result<String> delete(@PathVariable("vehicleId") Long vehicleId) {
vehicleService.removeById(vehicleId);
return Result.success("删除成功");
}
/**
*
* @param vehicleIds
* @return
*/
@DeleteMapping("/batchDelete")
@Operation(summary = "批量删除车辆")
public Result<String> batchDelete(@RequestBody List<Long> vehicleIds) {
vehicleService.removeBatchByIds(vehicleIds);
return Result.success("批量删除成功");
}
/**
*
* @param response
*/
@PostMapping("/export")
public void export(HttpServletResponse response) {
List<Vehicle> list = vehicleService.list();
ExcelUtil<Vehicle> util = new ExcelUtil<>(Vehicle.class);
util.exportExcel(response, list, "车辆数据");
}
/**
* vinid
* @param vehicleVin
* @return
*/
@GetMapping("/findByVehicleVin/{vehicleVin}")
@Operation(description = "通过车辆vin码查询模板id")
public Result<Long> findByVehicleVin(@PathVariable("vehicleVin") String vehicleVin) {
Long byVehicleVin = vehicleService.findByVehicleVin(vehicleVin);
return Result.success(byVehicleVin);
}
}

View File

@ -0,0 +1,48 @@
package com.muyu.enterprise.controller.car;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.domain.car.VehicleType;
import com.muyu.enterprise.service.car.VehicleTypeService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
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.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
*
* @Author
* @Packagecom.muyu.car.controller
* @Projectcloud-server
* @nameVehicleTypeController
* @Date2024/9/26 22:23
* @Description:
*/
@Log4j2
@RestController
@RequestMapping("/vehicleType")
@Tag(name = "车辆类型控制层", description = "车辆类型控制层")
public class VehicleTypeController extends BaseController
{
@Autowired
private VehicleTypeService vehicleTypeService;
/**
*
* @return
*/
@RequestMapping(path = "/", method = RequestMethod.POST)
@Operation(summary = "车辆类型列表",description = "车辆类型列表")
public Result<List<VehicleType>> findAll(){
return Result.success(vehicleTypeService.list());
}
}

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