cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java

@@ -7,7 +7,6 @@ import com.muyu.auth.form.RegisterBody;
 import com.muyu.auth.service.SysFirmService;
 import com.muyu.auth.service.SysLoginService;
 import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
-import com.muyu.common.core.constant.SecurityConstants;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.core.utils.JwtUtils;
 import com.muyu.common.core.utils.StringUtils;
@@ -15,10 +14,6 @@ import com.muyu.common.security.auth.AuthUtil;
 import com.muyu.common.security.service.TokenService;
 import com.muyu.common.security.utils.SecurityUtils;
 import com.muyu.common.system.domain.LoginUser;
-import com.muyu.common.system.domain.SysUser;
-import com.muyu.common.system.remote.RemoteUserService;
-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.core.io.ClassPathResource;
@@ -35,7 +30,6 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
 import java.sql.Statement;
-import java.util.Date;
 
 /**
  * token 控制
@@ -44,7 +38,6 @@ import java.util.Date;
  */
 @Log4j2
 @RestController
-@Tag(name = "auth",description = "auth")
 public class TokenController {
     @Autowired
     private TokenService tokenService;
@@ -55,11 +48,7 @@ public class TokenController {
     @Autowired
     private SysFirmService sysFirmService;
 
-    @Autowired
-    private RemoteUserService remoteUserService;
-
     @PostMapping("login")
-    @Operation(summary = "登录", description = "登录")
     public Result<?> login (@RequestBody LoginBody form) {
         //查询企业是否存在
         Firm firm = sysFirmService.findFirmByName(form.getFirmName());
@@ -73,7 +62,6 @@ public class TokenController {
     }
 
     @DeleteMapping("logout")
-    @Operation(summary = "退出", description = "退出")
     public Result<?> logout (HttpServletRequest request) {
         String token = SecurityUtils.getToken(request);
         if (StringUtils.isNotEmpty(token)) {
@@ -87,7 +75,6 @@ public class TokenController {
     }
 
     @PostMapping("refresh")
-    @Operation(summary = "刷新token", description = "刷新token")
     public Result<?> refresh (HttpServletRequest request) {
         LoginUser loginUser = tokenService.getLoginUser(request);
         if (StringUtils.isNotNull(loginUser)) {
@@ -99,7 +86,6 @@ public class TokenController {
     }
 
     @PostMapping("register")
-    @Operation(summary = "注册用户", description = "注册用户")
     public Result<?> register (@RequestBody RegisterBody registerBody) {
         // 用户注册
         sysLoginService.register(registerBody.getUsername(), registerBody.getPassword());
@@ -112,7 +98,6 @@ public class TokenController {
      * @return
      */
     @PostMapping("/enterprise")
-    @Operation(summary = "企业入驻", description = "企业入驻")
     public Result<?> enterprise( @RequestBody EnterpriseSettlement settlement){
 
         String createDatabaseUrl="jdbc:mysql://"+ DatasourceContent.IP+":"+DatasourceContent.PORT+"?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8";
@@ -127,13 +112,6 @@ public class TokenController {
             } else {
                 log.warn("数据库 {} 创建成功", settlement.getDatabaseName());
 
-
-                SysUser sysUser = new SysUser();
-                sysUser.setCreateTime(new Date());
-                sysUser.setUserName(settlement.getFirmName());
-                sysUser.setDatabaseName(settlement.getDatabaseName());
-                remoteUserService.addUser(sysUser, SecurityConstants.INNER);
-
                 // 切换到新的数据库连接
                 Connection connection = null;
                 try {

cloud-auth/src/main/java/com/muyu/auth/service/SysLoginService.java

@@ -1,6 +1,6 @@
 package com.muyu.auth.service;
 
-
+import com.muyu.auth.form.EnterpriseSettlement;
 import com.muyu.common.core.constant.CacheConstants;
 import com.muyu.common.core.constant.Constants;
 import com.muyu.common.core.constant.SecurityConstants;
@@ -13,10 +13,8 @@ import com.muyu.common.core.utils.StringUtils;
 import com.muyu.common.core.utils.ip.IpUtils;
 import com.muyu.common.redis.service.RedisService;
 import com.muyu.common.security.utils.SecurityUtils;
-
+import com.muyu.common.system.domain.Enterprise;
-
 import com.muyu.common.system.remote.RemoteUserService;
-import com.muyu.common.system.domain.Business;
 import com.muyu.common.system.domain.SysUser;
 import com.muyu.common.system.domain.LoginUser;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -146,7 +144,7 @@ public class SysLoginService {
         if (fileName.length() < UserConstants.Firm_NAME_MIN_LENGTH || fileName.length() > UserConstants.Firm_NAME_MAX_LENGTH) {
             throw new ServiceException("企业名称长度必须在2到20个字符之间");
         }
-        Business settlement = new Business();
+        Enterprise settlement = new Enterprise();
         settlement.setDatabaseName(databaseName);
         settlement.setFirmName(fileName);
 

cloud-auth/src/main/resources/bootstrap.yml

@@ -7,7 +7,7 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: four
+  namespace: lxy
 # Spring
 spring:
   application:

cloud-common/cloud-common-kafka/src/main/java/com/muyu/common/kafka/config/KafkaConsumerConfig.java

@@ -1,5 +1,7 @@
 package com.muyu.common.kafka.config;
 
+
+
 import com.muyu.common.core.constant.KafkaConstant;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.common.serialization.StringDeserializer;
@@ -11,11 +13,11 @@ import java.util.HashMap;
 import java.util.Map;
 
 /**
- * kafka消费者配置类
+* kafka消费者配置类
- * @program: cloud-server
+* @program: cloud-server
- * @author: cuiyongxing
+* @author: cuiyongxing
- * @create: 2024-09-28 14:28
+* @create: 2024-09-28 14:28
- **/
+**/
 @Configuration
 public class KafkaConsumerConfig {
 

cloud-common/cloud-common-kafka/src/main/java/com/muyu/common/kafka/config/KafkaProducerConfig.java

@@ -49,6 +49,8 @@ public class KafkaProducerConfig {
     private String acks;
 
 
+
+
     @Bean
     public KafkaProducer kafkaProducer() {
         Map<String, Object> configs = new HashMap<>();

cloud-common/cloud-common-rabbit/pom.xml

@@ -34,8 +34,6 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-redis</artifactId>
         </dependency>
-
-
     </dependencies>
 
 </project>

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/DelayedQueueConfig.java

@@ -0,0 +1,83 @@
+package com.muyu.common.rabbit.config;
+
+
+import com.muyu.common.rabbit.constants.RabbitmqConstants;
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+
+/**
+ * @ClassName: DelayedQueueConfig
+ * @Description: 延迟队列配置类
+ */
+@Configuration
+public class DelayedQueueConfig {
+
+
+    @Resource
+    private RabbitAdmin rabbitAdmin;
+
+    /**
+     * 声明队列
+     * @return 返回队列
+     */
+    @Bean
+    public Queue delayedQueue() {
+        Queue queue = new Queue(RabbitmqConstants.DELAYED_QUEUE_NAME);
+        rabbitAdmin.declareQueue(queue);
+        return queue;
+    }
+
+    /**
+     * 声明交换机
+     * @return 返回交换机
+     */
+    @Bean
+    public Exchange delayedExchange() {
+        HashMap<String, Object> arguments = new HashMap<>(3);
+
+        arguments.put("x-delayed-type", "direct");
+
+        /**
+         * 声明自定义交换机
+         * 第一个参数：交换机的名称
+         * 第二个参数：交换机的类型
+         * 第三个参数：是否需要持久化
+         * 第四个参数：是否自动删除
+         * 第五个参数：其他参数
+         */
+        CustomExchange customExchange = new CustomExchange(
+                RabbitmqConstants.DELAYED_EXCHANGE_NAME,
+                "x-delayed-message",
+                true,
+                false,
+                arguments);
+        rabbitAdmin.declareExchange(customExchange);
+        return customExchange;
+    }
+
+    /**
+     * 绑定交换机
+     * @param delayedQueue 队列对象
+     * @param delayedExchange 交换机对象
+     */
+    @Bean
+    public Binding delayedQueueBindingDelayedExchange(
+            @Qualifier("delayedQueue") Queue delayedQueue,
+            @Qualifier("delayedExchange") Exchange delayedExchange) {
+
+        Binding noargs = BindingBuilder.bind(delayedQueue)
+                .to(delayedExchange)
+                .with(RabbitmqConstants.DELAYED_ROUTING_KEY)
+                .noargs();
+        rabbitAdmin.declareBinding(noargs);
+        return noargs;
+    }
+
+
+}

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/MyConfirmCallback.java

@@ -1,4 +1,4 @@
-package com.muyu.rabbitmq.config;
+package com.muyu.common.rabbit.config;
 
 import lombok.AllArgsConstructor;
 import org.springframework.amqp.rabbit.connection.CorrelationData;

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/RabbitAdminConfig.java

@@ -1,4 +1,4 @@
-package com.muyu.rabbitmq.config;
+package com.muyu.common.rabbit.config;
 
 
 
@@ -21,16 +21,16 @@ public class RabbitAdminConfig {
     private String username;
     @Value("${spring.rabbitmq.password}")
     private String password;
-    @Value("${spring.rabbitmq.port}")
+    @Value("${spring.rabbitmq.virtualhost}")
-    private Integer port;
+    private String virtualHost;
 
     @Bean
     public ConnectionFactory connectionFactory() {
         CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
         cachingConnectionFactory.setHost(host);
-        cachingConnectionFactory.setPort(port);
         cachingConnectionFactory.setUsername(username);
         cachingConnectionFactory.setPassword(password);
+        cachingConnectionFactory.setVirtualHost(virtualHost);
         return cachingConnectionFactory;
 
     }

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/RabbitmqConfig.java

@@ -1,4 +1,4 @@
-package com.muyu.rabbitmq.config;
+package com.muyu.common.rabbit.config;
 
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/ReturnCallbackConfig.java

@@ -1,4 +1,4 @@
-package com.muyu.rabbitmq.config;
+package com.muyu.common.rabbit.config;
 
 import lombok.AllArgsConstructor;
 import org.springframework.amqp.core.ReturnedMessage;

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/config/TopicConfig.java

@@ -0,0 +1,75 @@
+package com.muyu.common.rabbit.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @Author: WangXin
+ * @Time: 2024/4/22 11:55
+ * @Description: 主题模式配置
+ */
+@Configuration
+public class TopicConfig {
+
+    /**
+     * 主题模式交换机
+     * @return exchange
+     */
+    @Bean(name = "topicExchange")
+    public Exchange getTopicExchange(){
+        return ExchangeBuilder
+                .topicExchange("exchange_topic")
+                .build();
+    }
+
+    /**
+     * 主题队列 01
+     * @return queue
+     */
+    @Bean(name = "topicQueue01")
+    public Queue getTopicQueue01(){
+        return QueueBuilder
+                .durable("queue_topic_01")
+                .build();
+    }
+
+    /**
+     * 主题队列 02
+     * @return queue
+     */
+    @Bean(name = "topicQueue02")
+    public Queue getTopicQueue02(){
+        return QueueBuilder
+                .durable("queue_topic_02")
+                .build();
+    }
+
+    /**
+     * 绑定队列 01
+     * @return binding
+     */
+    @Bean
+    public Binding getTopicBinding01(){
+        return BindingBuilder
+                .bind(getTopicQueue01())
+                .to(getTopicExchange())
+                //路由键 队列1接收debug级别的消息
+                .with("front.#")
+                .noargs();
+    }
+
+    /**
+     * 绑定队列 02
+     * @return binding
+     */
+    @Bean
+    public Binding getTopicBinding02(){
+        return BindingBuilder
+                .bind(getTopicQueue02())
+                .to(getTopicExchange())
+                // 路由键 队列2接收info级别的消息
+                .with("back.order.*")
+                .noargs();
+    }
+}

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/constants/RabbitmqConstants.java

@@ -1,4 +1,4 @@
-package com.muyu.rabbitmq.constants;
+package com.muyu.common.rabbit.constants;
 
 /**
  *

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/consumer/RabbitMQConsumerUtil.java

@@ -1,15 +1,11 @@
-package com.muyu.rabbitmq.consumer;
+package com.muyu.common.rabbit.consumer;
 
 import com.alibaba.fastjson2.JSONObject;
 import com.muyu.common.redis.service.RedisService;
-//import com.muyu.rabbitmq.util.CacheUtil;
 import com.rabbitmq.client.Channel;
 import lombok.AllArgsConstructor;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.Queue;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
@@ -26,9 +22,6 @@ public class RabbitMQConsumerUtil {
 
     private final RedisService redisService;
 
-//    @Autowired
-//    private CacheUtil cacheUtil;
-
 
     /**
      * 普通消费者
@@ -36,30 +29,17 @@ public class RabbitMQConsumerUtil {
      * @param message
      * @param channel
      */
-//    @RabbitListener(queuesToDeclare = @Queue(name = "basic"))
+    public void rabbitMQBasicConsumer(Object data ,Message message , Channel channel) {
-    public void rabbitMQBasicConsumer(String data ,Message message , Channel channel) {
         log.info("当前时间：{} ：RabbitMQConsumerUtil : {}", new Date(), message);
         try {
             // 获取到消息 开始消费
             log.info("消息消费者接收到消息，消息内容：{}", JSONObject.toJSONString(data));
 
-
             Long add = redisService.redisTemplate.opsForSet().add(data, message.getMessageProperties().getMessageId());
 
             if (add != 1) {
                 return;
             }
-
-            /**
-             * -----------------------------------以下为异步业务操作----------------------------
-             */
-            String carList = (String) redisService.redisTemplate.opsForValue().get("carList");
-
-
-
-            /**
-             * ------------------------------------------------------------------------------
-             */
             // 消费消息成功之后需要确认
             // long deliveryTag  消息投递序号  自增的数字  在整个队列中唯一 拿到这个序号就相当于拿到这条消息
             // boolean multiple  是否批量确认  true 批量  确认小于等于当前投递序号的消息   false 单个确认
@@ -86,7 +66,6 @@ public class RabbitMQConsumerUtil {
         }
     }
 
-
     /**
      * 普通消费者
      * @param data 数据类型
@@ -106,7 +85,6 @@ public class RabbitMQConsumerUtil {
                 return;
             }
 
-
             /**
              * -----------------------------------以下为异步业务操作----------------------------
              */

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/common/rabbit/producer/RabbitMQProducerUtil.java

@@ -0,0 +1,172 @@
+package com.muyu.common.rabbit.producer;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.common.rabbit.constants.RabbitmqConstants;
+import lombok.AllArgsConstructor;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.amqp.core.MessageProperties;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.UUID;
+
+/**
+ * @ClassName: RabbitMQProducer
+ * @Description: rabbitmq生产者
+ */
+@Component
+@AllArgsConstructor
+@Log4j2
+public class RabbitMQProducerUtil {
+    //redis工具类对象
+
+    //rabbit
+    private final RabbitTemplate rabbitTemplate;
+
+    /**
+     * 简单模型
+     *
+     * @param param 传递的消息 （如果是对象需要序列化）
+     * @return 结果集
+     * 一对一消费，只有一个消费者能接收到
+     */
+    public Result<?> basicSendMessage(String queueName, Object param, String msg) {
+
+        log.info("【简单模型mq】 : method: 【 basicSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", RabbitmqConstants.BASIC_QUEUE_NAME, param, msg);
+        // 发送简单模型消息
+        // 第一个参数： 绑定规则 相当于 队列名称
+        // 第二个参数：消息内容
+        rabbitTemplate.convertAndSend(queueName, param, message -> {
+             message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+             return message;
+        } );
+
+        log.info("【简单模型mq】 : method: 【 basicSendMessage 】- queue: 【 {} 】 ---> 【 消息发送成功 】", RabbitmqConstants.BASIC_QUEUE_NAME);
+
+        return Result.success(msg!=null?msg:"消息发送成功");
+    }
+
+    /**
+     * Work queue 工作模型
+     *
+     * @param obj 传递的消息 （如果是对象需要序列化）
+     * @return 结果集
+     * 多个消费者，你一个我一个分配消费消息，有预取机制，默认公平消费，可配置 能者多劳模式（），谁完成的快，谁多做一点
+     */
+    public Result<?> workSendMessage(String queueName, Object obj, String msg) {
+
+        log.info("【工作模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", queueName, obj, msg);
+        // 发送简单模型消息
+        // 第一个参数： 绑定规则 相当于 队列名称
+        // 第二个参数：消息内容
+        rabbitTemplate.convertAndSend(queueName, obj, message -> {
+            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+            return message;
+        } );
+
+        log.info("【工作模型mq】 : method: 【 workSendMessage 】- queue: 【 {} 】 ---> 【 消息发送成功 】", queueName);
+
+        return Result.success("消息发送成功");
+    }
+
+    /**
+     * Publish/Subscribe  发布订阅者模型
+     * 多个消费者，多个消费者可以同时接收到消息  有交换机  类型  fanout
+     * @param exchange 交换机名称
+     * @param obj      发送的消息Object
+     * @param msg      响应的内容
+     * @return 结果集
+     */
+    public Result<?> publishSubscribeSendMessage(String exchange, Object obj, String msg) {
+
+        log.info("【订阅模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", exchange, obj, msg);
+        // 发送简单模型消息
+        // 第一个参数： exchange 交换机的名称
+        // 第二个参数： 绑定规则 发布订阅者模型 不写  默认 "" 只要绑定就行 不需要规则
+        // 第三个参数：消息内容
+        rabbitTemplate.convertAndSend(exchange, "", obj, message -> {
+            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+            return message;
+        } );
+
+        log.info("【订阅模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
+
+        return Result.success("消息发送成功");
+    }
+
+    /**
+     * Routing路由模型
+     * 使用的是 Direct 类型的交换机，会将接收到的消息根据 规则 路由到指定的Queue(队列)，因此称为路由模式
+     *
+     * @param exchange 交换机名称
+     * @param rule     绑定规则  一个字符串即可
+     * @param obj      发送的消息Object
+     * @param msg      响应的内容
+     * @return 结果集
+     */
+    public Result<?> routingSendMessage(String exchange, String rule, Object obj, String msg) {
+
+        log.info("【路由模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", exchange, obj, msg);
+        // 发送简单模型消息
+        // 第一个参数： 绑定规则 相当于 队列名称
+        // 第二个参数：消息内容
+        rabbitTemplate.convertAndSend(exchange, rule, obj, message -> {
+            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+            return message;
+        } );
+
+        log.info("【路由模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
+
+        return Result.success("消息发送成功");
+    }
+
+
+    /**
+     * Topic主题模型模型
+     * 使用的是 topic 类型的交换机
+     *
+     * @param exchange 交换机名称
+     * @param rule     绑定规则  可以绑定多个单词以 . 拼接 也可以使用 #(匹配 零个 一个 或 多个 单词) 或 *(匹配 一个 单词) 通配符（例如：name.msg, *.msg, age.# ）
+     * @param obj      发送的消息Object
+     * @param msg      响应的内容
+     * @return 结果集
+     */
+    public Result<?> topicSendMessage(String exchange, String rule, Object obj) {
+
+        log.info("【主题模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {} 】 ---> 【 消息发送中。。。 】", exchange, obj);
+        // 发送简单模型消息
+        // 第一个参数： 绑定规则 相当于 队列名称
+        // 第二个参数：消息内容
+        rabbitTemplate.convertAndSend(exchange, rule, obj, message -> {
+            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+            return message;
+        } );
+
+        log.info("【主题模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
+
+        return Result.success(obj,"消息发送成功");
+    }
+
+
+    /**
+     * 延迟队列模型
+     * @param param 传输内容
+     * @param delayTime 延迟时间
+     * @return 结果集
+     */
+    public Result<?> delayedSendMessage(Long delayTime,  Object param) {
+        log.info("【延迟队列模型】 : method: 【 delayedSendMessage 】 消息内容:{}---> 【 消息发送中。。。 】",param);
+
+        rabbitTemplate.convertAndSend(RabbitmqConstants.DELAYED_EXCHANGE_NAME, RabbitmqConstants.DELAYED_ROUTING_KEY,param, message -> {
+            MessageProperties messageProperties = message.getMessageProperties();
+            messageProperties.setMessageId(UUID.randomUUID().toString());
+            messageProperties.setDelayLong(delayTime);
+            return message;
+        });
+        log.info("【延迟队列模型】 : method: 【 delayedSendMessage 】 消息内容:{}---> 【 消息发送成功 】",param);
+
+        return Result.success(param,"消息发送成功");
+
+    }
+
+}

cloud-common/cloud-common-rabbit/src/main/java/com/muyu/rabbitmq/producer/RabbitMQProducerUtil.java

@@ -1,174 +0,0 @@
-package com.muyu.rabbitmq.producer;
-
-import com.muyu.common.core.domain.Result;
-import com.muyu.rabbitmq.constants.RabbitmqConstants;
-import lombok.AllArgsConstructor;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.amqp.core.MessageProperties;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.stereotype.Component;
-
-import java.util.UUID;
-
-/**
- * @ClassName: RabbitMQProducer
- * @Description: rabbitmq生产者
- */
-@Component
-@AllArgsConstructor
-@Log4j2
-public class RabbitMQProducerUtil {
-    //redis工具类对象
-
-    //rabbit
-    private final RabbitTemplate rabbitTemplate;
-
-
-    /**
-     * 简单模型
-     *
-     * @param param 传递的消息 （如果是对象需要序列化）
-     * @return 结果集
-     * 一对一消费，只有一个消费者能接收到
-     */
-    public void basicSendMessage(String queueName, String param) {
-
-        log.info("【简单模型mq】 : method: 【 basicSendMessage 】 - ages: 【 String : {}, Object : {}】 ---> 【 消息发送中。。。 】", RabbitmqConstants.BASIC_QUEUE_NAME, param);
-        // 发送简单模型消息
-        // 第一个参数： 绑定规则 相当于 队列名称
-        // 第二个参数：消息内容
-        rabbitTemplate.convertAndSend(queueName, param, message -> {
-             message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-             return message;
-        } );
-
-        log.info("【简单模型mq】 : method: 【 basicSendMessage 】- queue: 【 {} 】 ---> 【 消息发送成功 】", RabbitmqConstants.BASIC_QUEUE_NAME);
-
-
-    }
-
-//    /**
-//     * Work queue 工作模型
-//     *
-//     * @param obj 传递的消息 （如果是对象需要序列化）
-//     * @return 结果集
-//     * 多个消费者，你一个我一个分配消费消息，有预取机制，默认公平消费，可配置 能者多劳模式（），谁完成的快，谁多做一点
-//     */
-//    public Result<?> workSendMessage(String queueName, Object obj, String msg) {
-//
-//        log.info("【工作模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", queueName, obj, msg);
-//        // 发送简单模型消息
-//        // 第一个参数： 绑定规则 相当于 队列名称
-//        // 第二个参数：消息内容
-//        rabbitTemplate.convertAndSend(queueName, obj, message -> {
-//            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-//            return message;
-//        } );
-//
-//        log.info("【工作模型mq】 : method: 【 workSendMessage 】- queue: 【 {} 】 ---> 【 消息发送成功 】", queueName);
-//
-//        return Result.success("消息发送成功");
-//    }
-//
-//    /**
-//     * Publish/Subscribe  发布订阅者模型
-//     * 多个消费者，多个消费者可以同时接收到消息  有交换机  类型  fanout
-//     *
-//     * @param exchange 交换机名称
-//     * @param obj      发送的消息Object
-//     * @param msg      响应的内容
-//     * @return 结果集
-//     */
-//    public Result<?> publishSubscribeSendMessage(String exchange, Object obj, String msg) {
-//
-//        log.info("【订阅模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", exchange, obj, msg);
-//        // 发送简单模型消息
-//        // 第一个参数： exchange 交换机的名称
-//        // 第二个参数： 绑定规则 发布订阅者模型 不写  默认 "" 只要绑定就行 不需要规则
-//        // 第三个参数：消息内容
-//        rabbitTemplate.convertAndSend(exchange, "", obj, message -> {
-//            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-//            return message;
-//        } );
-//
-//        log.info("【订阅模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
-//
-//        return Result.success("消息发送成功");
-//    }
-//
-//    /**
-//     * Routing路由模型
-//     * 使用的是 Direct 类型的交换机，会将接收到的消息根据 规则 路由到指定的Queue(队列)，因此称为路由模式
-//     *
-//     * @param exchange 交换机名称
-//     * @param rule     绑定规则  一个字符串即可
-//     * @param obj      发送的消息Object
-//     * @param msg      响应的内容
-//     * @return 结果集
-//     */
-//    public Result<?> routingSendMessage(String exchange, String rule, Object obj, String msg) {
-//
-//        log.info("【路由模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {}, String : {} 】 ---> 【 消息发送中。。。 】", exchange, obj, msg);
-//        // 发送简单模型消息
-//        // 第一个参数： 绑定规则 相当于 队列名称
-//        // 第二个参数：消息内容
-//        rabbitTemplate.convertAndSend(exchange, rule, obj, message -> {
-//            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-//            return message;
-//        } );
-//
-//        log.info("【路由模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
-//
-//        return Result.success("消息发送成功");
-//    }
-//
-//
-//    /**
-//     * Topic主题模型模型
-//     * 使用的是 topic 类型的交换机
-//     *
-//     * @param exchange 交换机名称
-//     * @param rule     绑定规则  可以绑定多个单词以 . 拼接 也可以使用 #(匹配 零个 一个 或 多个 单词) 或 *(匹配 一个 单词) 通配符（例如：name.msg, *.msg, age.# ）
-//     * @param obj      发送的消息Object
-//     * @param msg      响应的内容
-//     * @return 结果集
-//     */
-//    public Result<?> topicSendMessage(String exchange, String rule, Object obj) {
-//
-//        log.info("【主题模型mq】 : method: 【 workSendMessage 】 - ages: 【 String : {}, Object : {} 】 ---> 【 消息发送中。。。 】", exchange, obj);
-//        // 发送简单模型消息
-//        // 第一个参数： 绑定规则 相当于 队列名称
-//        // 第二个参数：消息内容
-//        rabbitTemplate.convertAndSend(exchange, rule, obj, message -> {
-//            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-//            return message;
-//        } );
-//
-//        log.info("【主题模型mq】 : method: 【 workSendMessage 】- exchange: 【 {} 】 ---> 【 消息发送成功 】", exchange);
-//
-//        return Result.success(obj,"消息发送成功");
-//    }
-
-
-    /**
-     * 延迟队列模型
-     * @param param 传输内容
-     * @param delayTime 延迟时间
-     * @return 结果集
-     */
-//    public Result<?> delayedSendMessage(Long delayTime,  Object param) {
-//        log.info("【延迟队列模型】 : method: 【 delayedSendMessage 】 消息内容:{}---> 【 消息发送中。。。 】",param);
-//
-//        rabbitTemplate.convertAndSend(RabbitmqConstants.DELAYED_EXCHANGE_NAME, RabbitmqConstants.DELAYED_ROUTING_KEY,param, message -> {
-//            MessageProperties messageProperties = message.getMessageProperties();
-//            messageProperties.setMessageId(UUID.randomUUID().toString());
-//            messageProperties.setDelayLong(delayTime);
-//            return message;
-//        });
-//        log.info("【延迟队列模型】 : method: 【 delayedSendMessage 】 消息内容:{}---> 【 消息发送成功 】",param);
-//
-//        return Result.success(param,"消息发送成功");
-//
-//    }
-
-}

cloud-common/cloud-common-rabbit/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -2,5 +2,6 @@ com.muyu.rabbitmq.producer.RabbitMQProducerUtil
 com.muyu.rabbitmq.consumer.RabbitMQConsumerUtil
 com.muyu.rabbitmq.config.RabbitmqConfig
 com.muyu.rabbitmq.config.MyConfirmCallback
+com.muyu.rabbitmq.config.DelayedQueueConfig
 com.muyu.rabbitmq.config.RabbitAdminConfig
 com.muyu.rabbitmq.config.ReturnCallbackConfig

cloud-common/cloud-common-saas/pom.xml

@@ -33,10 +33,9 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-security</artifactId>
         </dependency>
-        <dependency>
+
-            <groupId>com.mysql</groupId>
+
-            <artifactId>mysql-connector-j</artifactId>
+
-        </dependency>
 
 
     </dependencies>

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/many/datasource/ManyDataSource.java

@@ -5,17 +5,17 @@ import com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration;
 import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
 import com.muyu.cloud.common.many.datasource.domain.model.DataSourceInfo;
 import com.muyu.cloud.common.many.datasource.factory.DruidDataSourceFactory;
-import com.muyu.cloud.common.many.datasource.init.InitDataSource;
 import com.muyu.cloud.common.many.datasource.role.DynamicDataSource;
-import com.muyu.cloud.common.saas.domain.Datasource;
 import com.muyu.cloud.common.saas.domain.model.EntInfo;
 import com.muyu.cloud.common.saas.exception.SaaSException;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.core.utils.SpringUtils;
+import com.muyu.common.system.domain.Datasource;
+import com.muyu.common.system.domain.SysUser;
 import com.muyu.common.system.remote.RemoteSaaSService;
+import com.muyu.common.system.remote.RemoteUserService;
 import lombok.extern.log4j.Log4j2;
 import org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
@@ -35,14 +35,9 @@ import java.util.Map;
 @Component
 @AutoConfiguration(before = {MybatisPlusAutoConfiguration.class, MybatisAutoConfiguration.class})
 public class ManyDataSource implements ApplicationRunner{
-
-    @Autowired
-    private InitDataSource initDataSource;
-
-
     private List<EntInfo> dataSourceInfoList(){
         RemoteSaaSService remoteSaaSService = SpringUtils.getBean(RemoteSaaSService.class);
-        Result<List<Datasource>> tableDataInfoResult = initDataSource.initDatasource();
+        Result<List<Datasource>> tableDataInfoResult = remoteSaaSService.findDatabaseList();
         if (tableDataInfoResult==null){
             throw new SaaSException("saas远调数据源错误");
         }

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/many/datasource/constents/DatasourceContent.java

@@ -16,4 +16,8 @@ public class DatasourceContent {
     public final static String IP = "47.101.53.251";
 
     public final static Integer PORT = 3306;
+
+    public static String getDatasourceUrl(String databaseName) {
+        return String.format(DATASOURCE_URL,USER_NAME,PASSWORD,IP,PORT, databaseName);
+    }
 }

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/many/datasource/init/InitDataSource.java

@@ -1,58 +0,0 @@
-package com.muyu.cloud.common.many.datasource.init;
-
-
-import com.muyu.cloud.common.saas.domain.Datasource;
-import com.muyu.common.core.domain.Result;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Primary;
-import org.springframework.stereotype.Component;
-
-import java.sql.*;
-import java.util.ArrayList;
-import java.util.List;
-
-@Component
-@Log4j2
-public class InitDataSource {
-
-    public static final String USER="root";
-    public static final String PASSWORD="Lw030106";
-
-    @Bean
-    @Primary
-    public Result<List<Datasource>> initDatasource(){
-        ArrayList<Datasource> list = new ArrayList<>();
-
-        try {
-            DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver());
-            Connection connection= DriverManager.getConnection("jdbc:mysql://47.101.53.251:3306/datasource?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT&useSSL=false",USER,PASSWORD);
-            String sql="select * from `datasource` ";
-
-            Statement stmt = connection.createStatement();
-            ResultSet rs = stmt.executeQuery(sql);
-
-            while (rs.next()){
-                Datasource datasource = new Datasource();
-                datasource.setId(rs.getInt("id"));
-                datasource.setFirmName(rs.getString("firm_name"));
-                datasource.setDatabaseName(rs.getString("database_name"));
-                list.add(datasource);
-            }
-
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-        return Result.success(list);
-    };
-
-
-
-
-
-
-
-
-
-
-}

cloud-common/cloud-common-saas/src/main/java/com/muyu/cloud/common/saas/interceptor/SaaSInterceptor.java

@@ -1,9 +1,10 @@
 package com.muyu.cloud.common.saas.interceptor;
 
-import com.muyu.cloud.common.many.datasource.holder.DynamicDataSourceHolder;
+import com.alibaba.fastjson2.JSONObject;
-import com.muyu.cloud.common.many.datasource.role.DynamicDataSource;
 import com.muyu.cloud.common.saas.contents.SaaSConstant;
+import com.muyu.cloud.common.many.datasource.holder.DynamicDataSourceHolder;
 import com.muyu.cloud.common.saas.exception.SaaSException;
+import com.muyu.cloud.common.many.datasource.role.DynamicDataSource;
 import com.muyu.common.core.utils.ServletUtils;
 import com.muyu.common.core.utils.SpringUtils;
 import jakarta.servlet.http.HttpServletRequest;

cloud-common/cloud-common-saas/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -1,4 +1,3 @@
 com.muyu.cloud.common.saas.interceptor.WebMvcSaaSConfig
 com.muyu.cloud.common.many.datasource.ManyDataSource
 com.muyu.cloud.common.many.datasource.factory.DruidDataSourceFactory
-com.muyu.cloud.common.many.datasource.init.InitDataSource

cloud-common/cloud-common-system/src/main/java/com/muyu/common/system/domain/Enterprise.java

@@ -21,7 +21,7 @@ import lombok.experimental.SuperBuilder;
 @NoArgsConstructor
 @AllArgsConstructor
 @EqualsAndHashCode(callSuper = true)
-public class Business extends BaseEntity {
+public class Enterprise extends BaseEntity {
     private static final long serialVersionUID = 1L;
 
     /**

cloud-common/cloud-common-system/src/main/java/com/muyu/common/system/remote/RemoteUserService.java

@@ -3,12 +3,13 @@ package com.muyu.common.system.remote;
 import com.muyu.common.core.constant.SecurityConstants;
 import com.muyu.common.core.constant.ServiceNameConstants;
 import com.muyu.common.core.domain.Result;
-import com.muyu.common.system.domain.Business;
+import com.muyu.common.core.web.page.TableDataInfo;
+import com.muyu.common.system.domain.Enterprise;
+import com.muyu.common.system.domain.SysFirmUser;
 import com.muyu.common.system.domain.SysUser;
 import com.muyu.common.system.remote.factory.RemoteUserFallbackFactory;
 import com.muyu.common.system.domain.LoginUser;
 import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
@@ -52,13 +53,5 @@ public interface RemoteUserService {
      * @return
      */
     @PostMapping("/user/enterprise")
-    Result<Boolean>settlementEnterpriseInfo(@RequestBody Business enterprise, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
+    Result<Boolean>settlementEnterpriseInfo(@RequestBody Enterprise enterprise, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
-
-    /**
-     * 用户添加
-     * @param sysUser
-     * @return
-     */
-    @PostMapping("/user/addUser")
-    public Result<Integer> addUser(@RequestBody SysUser sysUser,@RequestHeader(SecurityConstants.FROM_SOURCE)String source);
 }

cloud-common/cloud-common-system/src/main/java/com/muyu/common/system/remote/factory/RemoteUserFallbackFactory.java

@@ -1,7 +1,9 @@
 package com.muyu.common.system.remote.factory;
 
 import com.muyu.common.core.domain.Result;
-import com.muyu.common.system.domain.Business;
+import com.muyu.common.core.web.page.TableDataInfo;
+import com.muyu.common.system.domain.Enterprise;
+import com.muyu.common.system.domain.SysFirmUser;
 import com.muyu.common.system.remote.RemoteUserService;
 import com.muyu.common.system.domain.SysUser;
 import com.muyu.common.system.domain.LoginUser;
@@ -41,16 +43,10 @@ public class RemoteUserFallbackFactory implements FallbackFactory<RemoteUserServ
             }
 
             @Override
-            public Result<Boolean> settlementEnterpriseInfo(Business enterprise, String source) {
+            public Result<Boolean> settlementEnterpriseInfo(Enterprise enterprise, String source) {
                 return Result.error("入驻企业失败");
             }
 
-            @Override
-            public Result<Integer> addUser(SysUser sysUser, String source) {
-                return Result.error("用户添加失败");
-            }
-
-
         };
     }
 }

cloud-gateway/src/main/resources/bootstrap.yml

@@ -7,7 +7,7 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: four
+  namespace: lxy
 
 # Spring
 spring:

cloud-modules/cloud-event/pom.xml

@@ -127,12 +127,6 @@
             <scope>compile</scope>
         </dependency>
 
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>saas-cache</artifactId>
-            <version>3.6.3</version>
-        </dependency>
-
     </dependencies>
 
     <build>

cloud-modules/cloud-event/src/main/java/com/muyu/event/basic/EventPublisher.java

@@ -28,4 +28,6 @@ public class EventPublisher implements ApplicationEventPublisherAware {
         publisher.publishEvent(event);
     }
 
+
+
 }

cloud-modules/cloud-event/src/main/java/com/muyu/event/config/IoTDBConfig.java

@@ -66,7 +66,9 @@ public class IoTDBConfig {
             measurements.add("car_vin");
             measurements.add("information");
 
+
             session.insertRecord(TABLENAME,System.currentTimeMillis(),measurements,list);
+
             //关闭连接
             session.close();
         } catch (IoTDBConnectionException e) {

cloud-modules/cloud-event/src/main/java/com/muyu/event/consumer/MessageConsumer.java

@@ -1,7 +1,7 @@
 package com.muyu.event.consumer;
-
 import com.alibaba.fastjson2.JSONObject;
 import com.muyu.event.basic.EventPublisher;
+import com.muyu.event.service.IncidentService;
 import lombok.extern.log4j.Log4j2;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
@@ -9,14 +9,11 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.stereotype.Component;
-
 import java.time.Duration;
 import java.util.Collections;
 import java.util.List;
-
 import static org.bouncycastle.asn1.x500.style.RFC4519Style.l;
-
+/*
-/**
  * kafka监听
  * @author 刘武
  * @package：com.muyu.event.consumer
@@ -34,18 +31,27 @@ public class MessageConsumer implements ApplicationRunner {
 
     private final String topic="four_car";
 
+    @Autowired
+    private IncidentService incidentService;
+
     @Override
     public void run(ApplicationArguments args) throws Exception {
         List<String> list = Collections.singletonList(topic);
         consumer.subscribe(list);
-
         while (true){
             ConsumerRecords<String,String> consumerRecords = consumer.poll(Duration.ofMillis(100));
             consumerRecords.forEach(record -> {
                 String value = record.value();
                 JSONObject jsonObject = JSONObject.parseObject(value);
                 log.info("value:{}",value);
-                eventPublisher.publishEvent(jsonObject);
+//                eventPublisher.publishEvent(jsonObject);
+                try {
+                    //预警
+                    incidentService.warnEventProcess(jsonObject);
+
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
             });
         }
     }

cloud-modules/cloud-event/src/main/java/com/muyu/event/consumer/MqConsumer.java

@@ -1,90 +0,0 @@
-package com.muyu.event.consumer;
-
-import com.alibaba.fastjson2.JSONObject;
-import com.muyu.cache.ElectronicFenceGroupCacheService;
-import com.muyu.cache.SysCarCacheService;
-import com.muyu.common.domain.database.ElectronicFenceGroup;
-import com.muyu.common.domain.resp.SysCarVo;
-import com.muyu.common.redis.service.RedisService;
-import com.muyu.rabbitmq.consumer.RabbitMQConsumerUtil;
-import com.rabbitmq.client.Channel;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.Queue;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.io.IOException;
-import java.util.Date;
-import java.util.List;
-
-/**
- * rabbitmq 监听器
- * @author 刘武
- * @package：com.muyu.event.consumer
- * @name：MqConsumer
- * @date：2024/10/2 14:17
- */
-
-@Component
-@Log4j2
-public class MqConsumer {
-
-    @Autowired
-    private RedisService redisService;
-
-    @Autowired
-    private SysCarCacheService sysCarCacheService;
-    @Autowired
-    private ElectronicFenceGroupCacheService electronicFenceGroupCacheService;
-
-    @RabbitListener(queuesToDeclare = @Queue(name = "basic"))
-    public void rabbitMQBasicConsumer(String data , Message message , Channel channel) {
-        log.info("当前时间：{} ：RabbitMQConsumerUtil : {}", new Date(), message);
-        try {
-            // 获取到消息 开始消费
-            log.info("消息消费者接收到消息，消息内容：{}", JSONObject.toJSONString(data));
-
-            Long add = redisService.redisTemplate.opsForSet().add(data, message.getMessageProperties().getMessageId());
-
-            if (add != 1) {
-                return;
-            }
-
-            /**
-             * -----------------------------------以下为异步业务操作----------------------------
-             */
-
-
-            /**
-             * ------------------------------------------------------------------------------
-             */
-            // 消费消息成功之后需要确认
-            // long deliveryTag  消息投递序号  自增的数字  在整个队列中唯一 拿到这个序号就相当于拿到这条消息
-            // boolean multiple  是否批量确认  true 批量  确认小于等于当前投递序号的消息   false 单个确认
-            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            log.info("xxx消费者接收到消息，消息内容：{}，消费成功...", message);
-
-        } catch (Exception e) {
-            log.error("xxx消费者接收到消息，消息内容：{}，消费消息异常，异常信息：{}", message, e);
-            // 消息回退  拒绝消费消息
-            // long deliveryTag  消息投递序号  自增的数字  在整个队列中唯一 拿到这个序号就相当于拿到这条消息
-            // boolean requeue   是否回到原来的队列
-            try {
-                channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
-//                channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
-            } catch (IOException ex) {
-                log.error("xxx消费者接收到消息，消息内容：{}，回退消息异常，异常信息：{}", message, ex);
-            }
-        }finally {
-            try {
-                channel.close();
-            } catch (Exception e) {
-                log.error("xxx消费者关闭Channel异常，消息内容：{}，异常信息：{}", message, e);
-            }
-        }
-    }
-
-
-}

cloud-modules/cloud-event/src/main/java/com/muyu/event/consumer/OnlineConsumer.java

@@ -18,6 +18,4 @@ public class OnlineConsumer {
 
 
 
-
-
 }

cloud-modules/cloud-event/src/main/java/com/muyu/event/controller/DataController.java

@@ -4,13 +4,11 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
- * 数据处理
  * @author 刘武
  * @package：com.muyu.event.controller
  * @name：DataController
  * @date：2024/9/29 20:16
  */
-
 @RestController
 @RequestMapping("data")
 public class DataController {

cloud-modules/cloud-event/src/main/java/com/muyu/event/controller/IoTDBController.java

@@ -19,12 +19,13 @@ import java.util.List;
  * @name：ItodbController
  * @date：2024/9/28 19:17
  */
-@RestController
+@RestController()
 public class IoTDBController {
 
     @Autowired
     private IoTDBService tdbService;
 
+
     /**
      * 查询实时车辆信息列表
      * @return list
@@ -46,6 +47,7 @@ public class IoTDBController {
         return Result.success(carInformation);
     };
 
+
     /**
      * 车辆添加
      * @param addCarInformation
@@ -57,4 +59,16 @@ public class IoTDBController {
         return Result.success("添加成功");
     };
 
+
+
+
+
+
+
+
+
+
+
+
+
 }

cloud-modules/cloud-event/src/main/java/com/muyu/event/controller/TestController.java

@@ -2,17 +2,20 @@ package com.muyu.event.controller;
 
 
 import com.alibaba.fastjson2.JSONObject;
-import com.muyu.rabbitmq.producer.RabbitMQProducerUtil;
+import com.muyu.event.service.TestService;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
-
+import java.text.SimpleDateFormat;
+import java.util.Date;
 
 /**
- * 测试
  * @author 刘武
  * @package：com.muyu.event.controller
  * @name：TestController
@@ -23,33 +26,25 @@ public class TestController {
 
     @Resource
     private KafkaProducer kafkaProducer;
-    @Resource
+
-    private RabbitMQProducerUtil rabbitMQProducerUtil;
 
 
     private static final String topic="four_car";
 
-    @GetMapping("sendKafka")
+    @GetMapping("send")
     public String sendKafka(){
 
         String message="发送一条信息";
         JSONObject jsonObject = new JSONObject();
-        jsonObject.put("cj","hh");
+        jsonObject.put("cj","sb");
-        ProducerRecord<String, String> producerRecord = new ProducerRecord<String, String>(topic,jsonObject.toString());
+
+
+        ProducerRecord<String, String> producerRecord = new ProducerRecord<String, String>(topic,jsonObject.toJSONString());
         kafkaProducer.send(producerRecord);
 
         return "success";
     }
 
-    @GetMapping("sendMq")
-    public String sendMq(){
-        String message="发送一条信息-mq";
-        rabbitMQProducerUtil.basicSendMessage("basic",message);
-        return "success-mq";
-    };
-
-
-
 
 
 

cloud-modules/cloud-event/src/main/java/com/muyu/event/domian/Event.java

@@ -13,13 +13,7 @@ import org.springframework.format.annotation.DateTimeFormat;
 
 import java.util.Date;
 
-/**
+
- * 事件实体类
- * @author 刘武
- * @package：com.muyu.event.domain
- * @name：Event
- * @date：2024/9/28 23:10
- */
 @Data
 @AllArgsConstructor
 @NoArgsConstructor

cloud-modules/cloud-event/src/main/java/com/muyu/event/listener/AddDatabaseListener.java

@@ -28,10 +28,6 @@ public class AddDatabaseListener implements EventListener {
             keys.add(key);
             values.add((String) value);
         });
-
-
-
-
     }
 
     @Override

cloud-modules/cloud-modules-system/src/main/java/com/muyu/system/controller/SysUserController.java

@@ -138,7 +138,7 @@ public class SysUserController extends BaseController {
      */
     @InnerAuth
     @PostMapping("/enterprise")
-    public Result<Boolean> enterprise (@RequestBody Business enterprise){
+    public Result<Boolean> enterprise (@RequestBody Enterprise enterprise){
 
         return Result.success(userService.enterprise(enterprise));
     }
@@ -302,11 +302,4 @@ public class SysUserController extends BaseController {
     public Result deptTree (SysDept dept) {
         return success(deptService.selectDeptTreeList(dept));
     }
-
-
-    @PostMapping("/addUser")
-    public Result<Integer> addUser(@RequestBody SysUser sysUser){
-        Integer i = userService.addUser(sysUser);
-        return Result.success(i);
-    }
 }

cloud-modules/cloud-modules-system/src/main/java/com/muyu/system/mapper/SysUserMapper.java

@@ -1,7 +1,7 @@
 package com.muyu.system.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.muyu.common.system.domain.Business;
+import com.muyu.common.system.domain.Enterprise;
 import com.muyu.common.system.domain.SysUser;
 import org.apache.ibatis.annotations.Param;
 
@@ -72,14 +72,14 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
      * @param enterprise
      * @return
      */
-    int enterprise(Business enterprise);
+    int enterprise(Enterprise enterprise);
 
     /**
      * 企业管理添加
      * @param enterprise
      * @return
      */
-    int enterPriseAdd(Business enterprise);
+    int enterPriseAdd(Enterprise enterprise);
 
     /**
      * 修改用户信息
@@ -158,8 +158,5 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
     List<SysUser> selectCompanyList();
 
 
-    Integer addUser(SysUser sysUser);
-
-
 
 }

cloud-modules/cloud-modules-system/src/main/java/com/muyu/system/service/SysUserService.java

@@ -1,7 +1,7 @@
 package com.muyu.system.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.muyu.common.system.domain.Business;
+import com.muyu.common.system.domain.Enterprise;
 import com.muyu.common.system.domain.SysUser;
 
 import java.util.List;
@@ -134,7 +134,7 @@ public interface SysUserService extends IService<SysUser> {
      */
     boolean registerUser(SysUser user);
 
-    boolean enterprise(Business enterprise);
+    boolean enterprise(Enterprise enterprise);
     /**
      * 修改用户信息
      *
@@ -230,6 +230,5 @@ public interface SysUserService extends IService<SysUser> {
 
     List<SysUser> selectCompanyList();
 
-    Integer addUser(SysUser sysUser);
 
 }

cloud-modules/cloud-modules-system/src/main/java/com/muyu/system/service/impl/SysUserServiceImpl.java

@@ -8,7 +8,7 @@ import com.muyu.common.core.utils.StringUtils;
 import com.muyu.common.core.utils.bean.BeanValidators;
 import com.muyu.common.datascope.annotation.DataScope;
 import com.muyu.common.security.utils.SecurityUtils;
-import com.muyu.common.system.domain.Business;
+import com.muyu.common.system.domain.Enterprise;
 import com.muyu.common.system.domain.SysRole;
 import com.muyu.common.system.domain.SysUser;
 import com.muyu.system.domain.SysPost;
@@ -264,7 +264,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
      * @return
      */
     @Override
-    public boolean enterprise(Business enterprise){
+    public boolean enterprise(Enterprise enterprise){
         userMapper.enterPriseAdd(enterprise);
         return userMapper.enterprise(enterprise) > 0;
     }
@@ -518,9 +518,4 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
         return userMapper.selectCompanyList();
     }
 
-    @Override
-    public Integer addUser(SysUser sysUser) {
-        return userMapper.addUser(sysUser);
-    }
-
 }

cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml

@@ -7,7 +7,7 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: four
+  namespace: lxy
 # SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
 # Spring
 spring:

cloud-modules/cloud-modules-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -24,7 +24,6 @@
         <result property="updateBy" column="update_by"/>
         <result property="updateTime" column="update_time"/>
         <result property="remark" column="remark"/>
-        <result property="databaseName" column="database_name"/>
         <association property="dept" javaType="com.muyu.common.system.domain.SysDept" resultMap="deptResult"/>
         <collection property="roles" javaType="java.util.List" resultMap="RoleResult"/>
     </resultMap>
@@ -205,7 +204,6 @@
         <if test="status != null and status != ''">status,</if>
         <if test="createBy != null and createBy != ''">create_by,</if>
         <if test="remark != null and remark != ''">remark,</if>
-        <if test="databaseName !=null and databaseName!=''">database_name,</if>
         create_time
         )values(
         <if test="userId != null and userId != ''">#{userId},</if>
@@ -220,7 +218,6 @@
         <if test="status != null and status != ''">#{status},</if>
         <if test="createBy != null and createBy != ''">#{createBy},</if>
         <if test="remark != null and remark != ''">#{remark},</if>
-        <if test="databaseName!=null and databaseName!=''">#{databaseName}</if>
         sysdate()
         )
     </insert>
@@ -231,11 +228,6 @@
         INSERT INTO `saas`.`tb_enterprise` (`enterprise_id`, `enterprise_name`, `enterprise_car_count`, `enterprise_fence_count`, `enterprise_database_name`)
         VALUES (NULL, #{firmName}, 0, 0, #{databaseName});
     </insert>
-    <insert id="addUser">
-        INSERT INTO `four`.`sys_user`
-        (`dept_id`, `user_name`, `nick_name`, `user_type`, `email`, `phonenumber`, `sex`, `avatar`, `password`, `status`, `del_flag`, `login_ip`, `login_date`, `create_by`, `create_time`, `update_by`, `update_time`, `remark`, `database_name`)
-        VALUES ( 105, #{userName}, '若依', '00', 'ry@qq.com', '15666666666', '1', '', '$2a$10$7JB720yubVSZvUI0rEqK/.VqGOZTH.ulu33dHOiBE8ByOhJIrdAu2', '0', '0', '47.101.53.251', '2024-05-23 15:08:18', 'admin', #{createTime}, '', NULL, '测试员', #{databaseName});
-    </insert>
 
     <update id="updateUser" parameterType="com.muyu.common.system.domain.SysUser">
         update sys_user

cloud-modules/cloud-modules-vehiclegateway/pom.xml

@@ -131,18 +131,6 @@
             <version>4.2.0</version><!-- 请根据实际情况使用最新的版本 -->
         </dependency>
 
-        <dependency>
-            <groupId>com.muyu.server</groupId>
-            <artifactId>saas-server</artifactId>
-            <version>3.6.3</version>
-        </dependency>
-
-        <!-- Forest HTTP Client -->
-        <dependency>
-            <groupId>com.dtflys.forest</groupId>
-            <artifactId>forest-spring-boot-starter</artifactId>
-            <version>1.5.36</version>
-        </dependency>
 
     </dependencies>
 

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/VehicleGatewayApplication.java

@@ -6,7 +6,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
 @EnableMyFeignClients
-
 public class VehicleGatewayApplication {
     public static void main(String[] args) {
         SpringApplication.run(VehicleGatewayApplication.class,args);

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/ManageInstance.java

@@ -1,15 +1,15 @@
 package com.muyu.vehicle;
 
-import com.alibaba.fastjson.JSONObject;
+
 import com.aliyun.ecs20140526.Client;
 import com.aliyun.ecs20140526.models.*;
 import com.aliyun.tea.TeaException;
+import com.aliyun.teaopenapi.models.Config;
 import com.aliyun.teautil.Common;
 import com.aliyun.teautil.models.RuntimeOptions;
-import com.muyu.common.redis.service.RedisService;
-import com.muyu.vehicle.config.SelectInstance;
 import com.muyu.vehicle.domain.InstanceInfo;
-import com.muyu.vehicle.utils.CreateClient;
+import com.muyu.vehicle.service.OpenInstance;
+import com.muyu.vehicle.service.SelectInstance;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
@@ -19,49 +19,73 @@ import org.springframework.stereotype.Component;
 import java.util.ArrayList;
 import java.util.List;
 
-
-
 @Component
 @Log4j2
-/**
- * 项目启动创建实例
- */
 public class ManageInstance implements ApplicationRunner {
-    @Autowired
+
-    private RedisService redisService;
+    /**
+     * ACCESS_KEY_ID
+     */
+    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID="LTAI5tGabdxedjfCh2uXHNrw";
+
+    /**
+     *ACCESS_KEY_SECRET
+     */
+    public static final String ACCESS_KEY_SECRET="NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
+
 
     /**
      * 镜像ID
      */
-    public static final String IMAGE_ID = "m-uf6ffgkry85fwu4znr6s";
+    public static final String IMAGE_ID="m-uf6agr9i6g27gj23om34";
 
     /**
      * 实例类型
      */
-    public static final String INSTANCE_TYPE = "ecs.e-c1m1.large";
+    public static final String INSTANCE_TYPE="ecs.e-c1m1.large";
 
     /**
      * 安全组ID
      */
-    public static final String SECURITY_GROUP_ID = "sg-uf6glo8c4k17szhxu7sk";
+    public static final String SECURITY_GROUP_ID="sg-uf6glo8c4k17szhxu7sk";
 
     /**
      *交换机ID
      */
-    public static final String V_SWITCH_ID = "vsw-uf6xy4rbt9ggcz93t6oib";
+    public static final String V_SWITCH_ID="vsw-uf6xy4rbt9ggcz93t6oib";
 
 
     /**
      * 实例付费类型
      */
-    public static final String INSTANCE_CHARGE_TY = "PostPaid";
+    public static final String INSTANCE_CHARGE_TY="PostPaid";
 
-    public static List<String> generateInstance() throws Exception {
+
+
+    /**
+     * 使用AK&SK初始化账号Client
+     * @return Client
+     * @throws Exception
+     */
+
+    public static Client createClient() throws Exception {
+        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+        Config config = new Config()
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+                .setAccessKeySecret(ACCESS_KEY_SECRET);
+        // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+        config.endpoint = "ecs-cn-hangzhou.aliyuncs.com";
+        return new com.aliyun.ecs20140526.Client(config);
+    }
+
+
+    public static void generateInstance() throws Exception {
         // 创建阿里云ECS客户端
-        // 创建ECS客户端对象，用于后续调用ECS相关API
+        Client client = ManageInstance.createClient();
-        Client client = CreateClient.createClient();
         // 配置系统盘参数
-        RunInstancesRequest.RunInstancesRequestSystemDisk systemDisk =
+        RunInstancesRequest.RunInstancesRequestSystemDisk systemDisk=
                 new RunInstancesRequest.RunInstancesRequestSystemDisk()
                         .setSize("40")
                         .setCategory("cloud_essd");
@@ -85,7 +109,7 @@ public class ManageInstance implements ApplicationRunner {
 
 
         //创建运行时选择对象
-        RuntimeOptions runTime =
+        RuntimeOptions runTime=
                 new RuntimeOptions();
         // 尝试执行创建实例请求
         try {
@@ -97,7 +121,6 @@ public class ManageInstance implements ApplicationRunner {
                 list.add(instance);
             }
             log.info("ESC创建成功,实例ID为:" + list);
-            return list;
         } catch (TeaException error) {
             // 错误 message
             log.info(error.getMessage());
@@ -108,27 +131,43 @@ public class ManageInstance implements ApplicationRunner {
             TeaException error = new TeaException(_error.getMessage(), _error);
             // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
             // 错误 message
-            log.info("实例创建失败:" + error.getMessage());
+            log.info("实例创建失败:"+error.getMessage());
         }
-        return null;
     }
 
+    private static List<InstanceInfo> selectInstance() throws Exception {
+        Client client = ManageInstance.createClient();
+        ArrayList<InstanceInfo> instanceInfos = new ArrayList<>();// 实例基础信息
+        DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
+                .setRegionId("cn-shanghai")
+                .setInternetChargeType("PayByTraffic")
+                .setInstanceChargeType("PostPaid")
+                .setInstanceName("cloud-MQTT") // 设置实例名称
+                ;
+        // 创建运行时选项对象
+        RuntimeOptions runtime = new RuntimeOptions();
+        //实例ID Instances.Instance.InstanceId
+        //实例IP Instances.Instance.PublicIpAddress.IpAddress
+        //状态 Instances.Instance.Status
+        DescribeInstancesResponse resp =client.describeInstancesWithOptions(describeInstancesRequest, runtime);
+        DescribeInstancesResponseBody body = resp.getBody();
 
+        for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()){
+            InstanceInfo instanceInfo = new InstanceInfo();
+            instanceInfo.setInstanceId(instance.getInstanceId());
+            instanceInfo.setIpAddress(String.valueOf(instance.getPublicIpAddress().getIpAddress()));
+            instanceInfo.setStatus(instance.getStatus());
+            instanceInfos.add(instanceInfo);
+
+        }
+        log.info("实例信息为:"+Common.toJSONString(instanceInfos));
+        return instanceInfos;
+    }
 
     @Override
     public void run(ApplicationArguments args) throws Exception {
-            List<String> list = generateInstance();
+        generateInstance();
-            log.info("创建实例成功");
+        selectInstance();
-            log.info("正在加载实例");
-            Thread.sleep(30000);
-            List<InstanceInfo> instanceInfos = SelectInstance.selectInstance(list);
-            log.info("实例信息查询成功");
-            for (InstanceInfo instanceInfo : instanceInfos) {
-                redisService.setCacheObject("FourInstanceIdKey:"+instanceInfo.getInstanceId(),instanceInfo);
-            }
-            System.out.println("实例信息:"+instanceInfos);
-            log.info("实例信息:", JSONObject.toJSONString(instanceInfos));
-        }
     }
-
+}
 

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/ConnectFluxMq.java

@@ -1,54 +0,0 @@
-package com.muyu.vehicle.config;
-
-import com.muyu.vehicle.domain.MqttServerModel;
-import feign.Client;
-import lombok.extern.log4j.Log4j2;
-import org.eclipse.paho.client.mqttv3.*;
-
-/**
- * 链接fluxMq
- */
-@Log4j2
-public class ConnectFluxMq {
-
-
-
-    public void FluxMqConnect(String IP,String vin){
-        String topic        = "car";
-        String broker       = "tcp://"+IP+":1883";
-        String clientId     = vin+"vehicleGateway";
-        MqttClient client;
-        try {
-            //创建
-         client = new MqttClient(broker,clientId);
-            //设置连接参数
-            MqttConnectOptions options = new MqttConnectOptions();
-            options.setCleanSession(true);
-            //连接到Broker
-            client.connect(options);
-            log.info("Connecting to broker: " + broker);
-            //连接
-            client.subscribe(topic,0);
-            client.setCallback(new MqttCallback() {
-                @Override
-                public void connectionLost(Throwable throwable) {
-                    
-                }
-
-                @Override
-                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
-
-                }
-
-                @Override
-                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
-
-                }
-            });
-
-        } catch (MqttException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/CreateExchange.java

@@ -1,41 +0,0 @@
-package com.muyu.vehicle.config;
-
-import lombok.extern.log4j.Log4j2;
-import org.springframework.amqp.core.*;
-import org.springframework.amqp.rabbit.connection.ConnectionFactory;
-import org.springframework.amqp.rabbit.core.RabbitAdmin;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.stereotype.Component;
-
-@Log4j2
-@Component
-public class CreateExchange implements ApplicationRunner {
-
-    @Autowired
-    private ConnectionFactory connectionFactory;
-
-    @Override
-    public void run(ApplicationArguments args) throws Exception {
-        log.info("=====>开始创建交换机");
-
-        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
-
-        // 创建Fanout类型的交换机
-        FanoutExchange exchange = new FanoutExchange("ONLINE_EXCHANGE", true, false);
-
-        rabbitAdmin.declareExchange(exchange);
-
-        // 创建队列
-        Queue queue = new Queue("GO_ONLINE", true, false, false);
-
-        rabbitAdmin.declareQueue(queue);
-
-        // Fanout交换机绑定
-        rabbitAdmin.declareBinding(BindingBuilder.bind(queue).to(exchange));
-
-        log.info("=====>交换机创建成功");
-        log.info("=====>队列创建成功并绑定到交换机");
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/SelectInstance.java

@@ -1,63 +0,0 @@
-package com.muyu.vehicle.config;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.aliyun.ecs20140526.Client;
-import com.aliyun.ecs20140526.models.DescribeInstancesRequest;
-import com.aliyun.ecs20140526.models.DescribeInstancesResponse;
-import com.aliyun.ecs20140526.models.DescribeInstancesResponseBody;
-import com.aliyun.teautil.Common;
-import com.aliyun.teautil.models.RuntimeOptions;
-import com.muyu.common.core.exception.ServiceException;
-import com.muyu.common.redis.service.RedisService;
-import com.muyu.vehicle.domain.InstanceInfo;
-import com.muyu.vehicle.utils.CreateClient;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 查询实例信息
- */
-
-/**
- * 查询实例信息
- */
-
-@Log4j2
-public class SelectInstance {
-    public static List<InstanceInfo> selectInstance(List<String> instanceIds) throws Exception {
-        // 创建ECS客户端对象，用于后续调用ECS相关API
-        Client client = CreateClient.createClient();
-        ArrayList<InstanceInfo> instanceInfos = new ArrayList<>();// 实例基础信息
-        com.aliyun.ecs20140526.models.DescribeInstancesRequest describeInstancesRequest = new com.aliyun.ecs20140526.models.DescribeInstancesRequest()
-                .setInstanceIds(JSON.toJSONString(instanceIds))
-                .setRegionId("cn-shanghai");
-        // 创建运行时选项对象
-        RuntimeOptions runtime = new RuntimeOptions();
-        //实例ID Instances.Instance.InstanceId
-        //实例IP Instances.Instance.PublicIpAddress.IpAddress
-        //状态 Instances.Instance.Status
-        DescribeInstancesResponse resp = client.describeInstancesWithOptions(describeInstancesRequest, runtime);
-        DescribeInstancesResponseBody body = resp.getBody();
-
-        ArrayList<InstanceInfo> list = new ArrayList<>();
-        for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()){
-            InstanceInfo instanceInfo = new InstanceInfo();
-            instanceInfo.setInstanceId(instance.getInstanceId());
-            log.info("实例ID:{}",instanceInfo.getInstanceId());
-            instanceInfo.setStatus(instance.getStatus());
-            log.info("实例状态:{}",instanceInfo.getStatus());
-            instanceInfo.setIpAddress(String.valueOf(instance.getPublicIpAddress().getIpAddress()));
-            log.info("实例IP:{}",instanceInfo.getIpAddress());
-            list.add(instanceInfo);
-        }
-        System.out.println("实例信息:"+list);
-        log.info("实例信息:",list);
-        return list;
-    }
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/controller/CarInstanceController.java

@@ -1,26 +0,0 @@
-package com.muyu.vehicle.controller;
-import com.muyu.common.core.domain.Result;
-import com.muyu.vehicle.domain.MqttServerModel;
-import com.muyu.vehicle.domain.req.VehicleConnectionReq;
-import com.muyu.vehicle.service.VehicleConnectService;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-
-@Log4j2
-@RestController
-@RequestMapping("/carInstance")
-public class CarInstanceController {
-
-    @Autowired
-    private VehicleConnectService vehicleConnectService;
-
-
-    @PostMapping("/receiveMsg")
-    public Result receiveMsg(@RequestBody VehicleConnectionReq vehicleConnectionReq){
-        log.info("=======>"+vehicleConnectionReq);
-        Result<MqttServerModel> connect = vehicleConnectService.getConnect(vehicleConnectionReq);
-        return Result.success(connect);
-    }
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/domain/FluxMqProperties.java

@@ -1,40 +0,0 @@
-package com.muyu.vehicle.domain;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * fluxMq配置
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-public class FluxMqProperties {
-
-
-    /**
-     * 节点
-     */
-    private String broker;
-
-    /**
-     * 主题
-     */
-    private String topic;
-    /**
-     * 密码
-     */
-    private String password;
-
-    /**
-     * 节点ID
-     */
-    private String clientId;
-
-
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/domain/InstanceInfo.java

@@ -4,9 +4,6 @@ import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
-/**
- * 网关实例信息
- */
 @Data
 @AllArgsConstructor
 @NoArgsConstructor

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/domain/MqttServerModel.java

@@ -1,31 +0,0 @@
-package com.muyu.vehicle.domain;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- *  Mqtt服务器模型
- * @author YunFei.Du
- * @date  22:08 2024/5/29
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-public class MqttServerModel {
-
-    /**
-     * MQTT服务节点
-     */
-    private String broker;
-
-
-    /**
-     * MQTT订阅主题
-     */
-    private String topic;
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/domain/req/VehicleConnectionReq.java

@@ -1,58 +0,0 @@
-package com.muyu.vehicle.domain.req;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * 车辆连接信息
- */
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@TableName(value = "vehicle_connection")
-public class VehicleConnectionReq {
-
-    /**
-     * ID
-     */
-    @TableId(type = IdType.AUTO)
-    private Integer id;
-
-
-    /**
-     * 车辆VIN
-     */
-    private String vehicleVin;
-
-    /**
-     * 时间戳
-     */
-
-    private String timestamp;
-
-    /**
-     * 用户名
-     */
-
-    private String username;
-
-
-    /**
-     * 随机字符串
-     */
-    private String nonce;
-
-
-    /**
-     * 密码
-     */
-    private String password;
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/mapper/VehicleConnectMapper.java

@@ -1,12 +0,0 @@
-package com.muyu.vehicle.mapper;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.muyu.vehicle.domain.req.VehicleConnectionReq;
-import org.apache.ibatis.annotations.Mapper;
-
-@Mapper
-public interface VehicleConnectMapper extends BaseMapper<VehicleConnectionReq> {
-
-    VehicleConnectionReq selectByVehicleVin(String vin);
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/service/CloseInstance.java

@@ -1,4 +1,6 @@
-package com.muyu.vehicle.config;
+package com.muyu.vehicle.service;
+
+
 import com.aliyun.ecs20140526.Client;
 import com.aliyun.ecs20140526.models.DeleteInstancesRequest;
 import com.aliyun.ecs20140526.models.DescribeInstancesRequest;
@@ -8,33 +10,42 @@ import com.aliyun.tea.TeaException;
 import com.aliyun.teaopenapi.models.Config;
 import com.aliyun.teautil.Common;
 import com.aliyun.teautil.models.RuntimeOptions;
-import com.muyu.vehicle.utils.CreateClient;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.DisposableBean;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
 
-/**
- * 删除实例信息
- */
 
 @Component
 @Log4j2
-public class CloseInstance implements DisposableBean{
+public class CloseInstance implements DisposableBean {
+    /**
+     * ACCESS_KEY_ID
+     */
+    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID="LTAI5tGabdxedjfCh2uXHNrw";
 
     /**
-     * <b>description</b> :
+     *ACCESS_KEY_SECRET
-     * <p>使用AK&amp;SK初始化账号Client</p>
-     * @return Client
-     *
-     * @throws Exception
      */
+    public static final String ACCESS_KEY_SECRET="NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
+    public static Client createClient() throws Exception {
+        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+        // 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378657.html。
+        Config config = new Config()
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+                .setAccessKeySecret(ACCESS_KEY_SECRET);
+        // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+        config.endpoint = "ecs.cn-shanghai.aliyuncs.com";
+        return new Client(config);
+    }
+
     public static void delInstance() throws Exception {
 
         // 创建ECS客户端对象，用于后续调用ECS相关API
-        Client client = CreateClient.createClient();
+       Client client = CloseInstance.createClient();
 
         DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
                 .setRegionId("cn-shanghai");
@@ -50,7 +61,7 @@ public class CloseInstance implements DisposableBean{
         DescribeInstancesResponseBody body = describeInstancesResponse.getBody();
 
         for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()) {
-            if (!instance.getInstanceId().equals("i-uf68jwsbbqq4b4xc893s")) {
+            if (!instance.getInstanceId().equals("i-uf68jwsbbqq4b4xc893s")){
                 list.add(instance.getInstanceId());
             }
         }
@@ -97,4 +108,3 @@ public class CloseInstance implements DisposableBean{
         delInstance();
     }
 }
-

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/service/OpenInstance.java

@@ -0,0 +1,129 @@
+package com.muyu.vehicle.service;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.RunInstancesRequest;
+import com.aliyun.ecs20140526.models.RunInstancesResponse;
+import com.aliyun.ecs20140526.models.RunInstancesResponseBody;
+import com.aliyun.tea.TeaException;
+import com.aliyun.teaopenapi.models.Config;
+import com.aliyun.teautil.Common;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.muyu.vehicle.ManageInstance;
+import lombok.extern.log4j.Log4j2;
+
+import java.util.ArrayList;
+
+@Log4j2
+public class OpenInstance {
+    /**
+     * ACCESS_KEY_ID
+     */
+    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID="LTAI5tGabdxedjfCh2uXHNrw";
+
+    /**
+     *ACCESS_KEY_SECRET
+     */
+    public static final String ACCESS_KEY_SECRET="NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
+
+
+    /**
+     * 镜像ID
+     */
+    public static final String IMAGE_ID="m-uf6agr9i6g27gj23om34";
+
+    /**
+     * 实例类型
+     */
+    public static final String INSTANCE_TYPE="ecs.e-c1m1.large";
+
+    /**
+     * 安全组ID
+     */
+    public static final String SECURITY_GROUP_ID="sg-uf6glo8c4k17szhxu7sk";
+
+    /**
+     *交换机ID
+     */
+    public static final String V_SWITCH_ID="vsw-uf6xy4rbt9ggcz93t6oib";
+
+
+    /**
+     * 实例付费类型
+     */
+    public static final String INSTANCE_CHARGE_TY="PostPaid";
+
+
+
+    /**
+     * 使用AK&SK初始化账号Client
+     * @return Client
+     * @throws Exception
+     */
+
+    public static Client createClient() throws Exception {
+        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+        Config config = new Config()
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+                .setAccessKeySecret(ACCESS_KEY_SECRET);
+        // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+        config.endpoint = "ecs-cn-hangzhou.aliyuncs.com";
+        return new com.aliyun.ecs20140526.Client(config);
+    }
+
+
+    public static void generateInstance() throws Exception {
+        // 创建阿里云ECS客户端
+        Client client = OpenInstance.createClient();
+        // 配置系统盘参数
+        RunInstancesRequest.RunInstancesRequestSystemDisk systemDisk=
+                new RunInstancesRequest.RunInstancesRequestSystemDisk()
+                        .setSize("40")
+                        .setCategory("cloud_essd");
+
+        // 创建创建实例请求对象并设置参数
+
+        RunInstancesRequest runInstancesRequest = new RunInstancesRequest()
+                .setRegionId("cn-shanghai") // 设置地域ID
+                .setImageId(IMAGE_ID) // 设置镜像ID
+                .setInstanceType(INSTANCE_TYPE) // 设置实例类型
+                .setSecurityGroupId(SECURITY_GROUP_ID) // 设置安全组ID
+                .setVSwitchId(V_SWITCH_ID) // 设置虚拟交换机ID
+                .setInstanceName("cloud-MQTT") // 设置实例名称
+                .setInstanceChargeType(INSTANCE_CHARGE_TY) // 设置实例付费类型为后付费按量付费
+                .setSystemDisk(systemDisk) // 设置系统盘配置
+                .setHostName("root") // 设置主机名
+                .setPassword("2112A-four") // 设置实例密码
+                .setAmount(2) // 设置创建实例的数量
+                .setInternetChargeType("PayByTraffic")
+                .setInternetMaxBandwidthOut(1);
+
+
+        //创建运行时选择对象
+        RuntimeOptions runTime=
+                new RuntimeOptions();
+        // 尝试执行创建实例请求
+        try {
+            ArrayList<String> list = new ArrayList<>();
+            // 复制代码运行请自行打印 API 的返回值
+            RunInstancesResponse runInstancesResponse = client.runInstancesWithOptions(runInstancesRequest, runTime);
+            RunInstancesResponseBody body = runInstancesResponse.getBody();
+            for (String instance : body.getInstanceIdSets().getInstanceIdSet()) {
+                list.add(instance);
+                log.info("ESC创建成功,实例ID为:" + list);
+            }
+        } catch (TeaException error) {
+            // 错误 message
+            log.info(error.getMessage());
+            // 诊断地址
+            log.info(error.getData().get("Recommend"));
+            Common.assertAsString(error.message);
+        } catch (Exception _error) {
+            TeaException error = new TeaException(_error.getMessage(), _error);
+            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+            // 错误 message
+            log.info("实例创建失败:"+error.getMessage());
+        }
+    }
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/service/SelectInstance.java

@@ -0,0 +1,66 @@
+package com.muyu.vehicle.service;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.DescribeInstancesRequest;
+import com.aliyun.ecs20140526.models.DescribeInstancesResponse;
+import com.aliyun.ecs20140526.models.DescribeInstancesResponseBody;
+import com.aliyun.teaopenapi.models.Config;
+import com.aliyun.teautil.Common;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.muyu.vehicle.domain.InstanceInfo;
+import lombok.extern.log4j.Log4j2;
+
+import java.util.ArrayList;
+
+@Log4j2
+public class SelectInstance {
+    /**
+     * ACCESS_KEY_ID
+     */
+    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID="LTAI5tGabdxedjfCh2uXHNrw";
+
+    /**
+     *ACCESS_KEY_SECRET
+     */
+    public static final String ACCESS_KEY_SECRET="NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
+
+    public static Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
+        Config config = new com.aliyun.teaopenapi.models.Config()
+                // 必填，您的 AccessKey ID
+                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+                // 必填，您的 AccessKey Secret
+                .setAccessKeySecret(ACCESS_KEY_SECRET);
+        // 访问的域名
+        config.endpoint = "ecs-cn-hangzhou.aliyuncs.com";
+        return new Client(config);
+    }
+
+    public static void main(String[] args_) throws Exception {
+        java.util.List<String> args = java.util.Arrays.asList(args_);
+        // 请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID 和 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议使用更安全的 STS 方式
+         Client client = SelectInstance.createClient(ALIBABA_CLOUD_ACCESS_KEY_ID, ACCESS_KEY_SECRET);
+         DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
+                .setRegionId("cn-shanghai")
+                .setInternetChargeType("PayByTraffic")
+                .setInstanceChargeType("PostPaid")
+                 .setInstanceName("cloud-MQTT") // 设置实例名称
+                 ;
+         //实例ID Instances.Instance.InstanceId
+        //实例IP Instances.Instance.PublicIpAddress.IpAddress
+        //状态 Instances.Instance.Status
+        RuntimeOptions runtime = new RuntimeOptions();
+        DescribeInstancesResponse resp = client.describeInstancesWithOptions(describeInstancesRequest, runtime);
+        DescribeInstancesResponseBody body = resp.getBody();
+        ArrayList<InstanceInfo> instanceInfos = new ArrayList<>();// 实例基础信息
+        for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()){
+
+            InstanceInfo instanceInfo = new InstanceInfo();
+            instanceInfo.setInstanceId(instance.getInstanceId());
+            instanceInfo.setIpAddress(String.valueOf(instance.getPublicIpAddress().getIpAddress()));
+            instanceInfo.setStatus(instance.getStatus());
+            instanceInfos.add(instanceInfo);
+        }
+        log.info(Common.toJSONString(instanceInfos));
+    }
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/service/VehicleConnectService.java

@@ -1,12 +0,0 @@
-package com.muyu.vehicle.service;
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.muyu.common.core.domain.Result;
-import com.muyu.vehicle.domain.MqttServerModel;
-import com.muyu.vehicle.domain.req.VehicleConnectionReq;
-
-public interface VehicleConnectService extends IService<VehicleConnectionReq> {
-
-    Result<MqttServerModel> getConnect(VehicleConnectionReq vehicleConnectionReq);
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/service/impl/VehicleConnectServiceImpl.java

@@ -1,36 +0,0 @@
-package com.muyu.vehicle.service.impl;
-
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.muyu.common.core.domain.Result;
-import com.muyu.vehicle.domain.MqttServerModel;
-import com.muyu.vehicle.domain.req.VehicleConnectionReq;
-import com.muyu.vehicle.mapper.VehicleConnectMapper;
-import com.muyu.vehicle.service.VehicleConnectService;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-@Service
-@Log4j2
-public class VehicleConnectServiceImpl extends ServiceImpl<VehicleConnectMapper, VehicleConnectionReq> implements VehicleConnectService {
-   @Autowired
-   private VehicleConnectMapper vehicleConnectMapper;
-
-    @Override
-    public Result<MqttServerModel> getConnect(VehicleConnectionReq vehicleConnectionReq) {
-        log.info("车辆连接信息:{}", vehicleConnectionReq);
-        //生成密码
-        vehicleConnectionReq.setPassword(vehicleConnectionReq.getVehicleVin() + vehicleConnectionReq.getTimestamp()
-                + vehicleConnectionReq.getNonce());
-
-        VehicleConnectionReq connection = vehicleConnectMapper.selectByVehicleVin(vehicleConnectionReq.getVehicleVin());
-        if (connection==null){
-            vehicleConnectMapper.insert(vehicleConnectionReq);
-            log.info("车辆预上线成功");
-        }else {
-            log.info("车辆已预上线成功,禁止重复");
-        }
-        return null;
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/utils/CreateClient.java

@@ -1,33 +0,0 @@
-
-package com.muyu.vehicle.utils;
-
-import com.aliyun.ecs20140526.Client;
-import com.aliyun.teaopenapi.models.Config;
-
-/**
- *  创建ECS客户端对象
- */
-public class CreateClient {
-    /**
-     * ACCESS_KEY_ID
-     */
-    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tGabdxedjfCh2uXHNrw";
-
-    /**
-     *ACCESS_KEY_SECRET
-     */
-    public static final String ACCESS_KEY_SECRET = "NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
-
-    public static Client createClient() throws Exception {
-        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
-        // 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378657.html。
-        Config config = new Config()
-                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
-                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
-                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
-                .setAccessKeySecret(ACCESS_KEY_SECRET);
-        // Endpoint 请参考 https://api.aliyun.com/product/Ecs
-        config.endpoint = "ecs.cn-shanghai.aliyuncs.com";
-        return new Client(config);
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/resources/bootstrap.yml

@@ -7,12 +7,10 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: sx
+  namespace: lxy
 
 # Spring
 spring:
-  main:
-    allow-bean-definition-overriding: true
   application:
     # 应用名称
     name: cloud-vehicleGateway

cloud-modules/saas/pom.xml

@@ -51,16 +51,6 @@
         <groupId>org.apache.kafka</groupId>
         <artifactId>kafka-clients</artifactId>
     </dependency>
-
-<!--    <dependency>-->
-<!--        <groupId>com.baomidou</groupId>-->
-<!--        <artifactId>mybatis-plus-boot-starter</artifactId>-->
-<!--        <version>3.5.1</version>-->
-<!--    </dependency>-->
-
-
-
-
 </dependencies>
 
     <properties>

cloud-modules/saas/saas-server/pom.xml

@@ -42,11 +42,6 @@
             <version>3.6.3</version>
         </dependency>
 
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-saas</artifactId>
-        </dependency>
-
         <!-- SpringCloud Alibaba Nacos -->
         <dependency>
             <groupId>com.alibaba.cloud</groupId>
@@ -106,7 +101,6 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-xxl</artifactId>
         </dependency>
-
         <dependency>
             <groupId>org.apache.iotdb</groupId>
             <artifactId>service-rpc</artifactId>

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/SaasApplication.java

@@ -1,14 +1,7 @@
 package com.muyu.server;
-
-
-import com.alibaba.druid.spring.boot3.autoconfigure.DruidDataSourceAutoConfigure;
-import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceAutoConfiguration;
-import com.muyu.common.security.annotation.EnableCustomConfig;
 import com.muyu.common.security.annotation.EnableMyFeignClients;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
-
 /**
  * saas模块启动类
  * @author YuPing
@@ -16,12 +9,7 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  * @Version 1.0
  * @Data 2024-09-28 17:34:31
  */
-@SpringBootApplication(exclude = {
+@SpringBootApplication
-        DataSourceAutoConfiguration.class,
-        DruidDataSourceAutoConfigure.class,
-        DynamicDataSourceAutoConfiguration.class
-})
-@EnableCustomConfig
 @EnableMyFeignClients
 public class SaasApplication {
     public static void main(String[] args) {

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/CarTypeController.java

@@ -21,6 +21,8 @@ import java.util.List;
  * @Date 2024/9/29 12:06
  */
 
+
+
 @RestController
 @RequestMapping("/carType")
 @AllArgsConstructor

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/EnterpriseController.java

@@ -1,13 +1,8 @@
 package com.muyu.server.controller;
 
 import cn.hutool.core.bean.BeanUtil;
-import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
-import com.muyu.common.core.constant.SecurityConstants;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.domain.Enterprise;
-import com.muyu.common.system.domain.Business;
-import com.muyu.common.system.domain.SysUser;
-import com.muyu.common.system.remote.RemoteUserService;
 import com.muyu.common.util.PageUtils;
 import com.muyu.server.controller.form.DeleteEnterpriseByIds;
 import com.muyu.server.controller.form.InsertEnterprise;
@@ -19,16 +14,8 @@ import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.validation.Valid;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.core.io.ClassPathResource;
-import org.springframework.core.io.support.EncodedResource;
-import org.springframework.jdbc.datasource.init.ScriptUtils;
 import org.springframework.web.bind.annotation.*;
 
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -48,9 +35,6 @@ public class EnterpriseController {
     @Autowired
     private EnterpriseService enterpriseService;
 
-    @Autowired
-    private RemoteUserService remoteUserService;
-
 
     /**
      * 查询分页企业信息
@@ -88,56 +72,6 @@ public class EnterpriseController {
         enterprise.setEnterpriseFenceCount(form.getEnterpriseFenceCount());
 
         int rows = enterpriseService.insert(enterprise);
-        if (rows == 0){
-            return Result.error("新增失败");
-        }
-
-        Business business = new Business();
-        business.setFirmName(form.getEnterpriseName());
-        business.setDatabaseName(form.getEnterpriseDatabaseName());
-        remoteUserService.settlementEnterpriseInfo(business, SecurityConstants.INNER);
-
-        SysUser sysUser = new SysUser();
-        sysUser.setDatabaseName(form.getEnterpriseDatabaseName());
-        sysUser.setUserName(form.getEnterpriseName());
-        sysUser.setCreateTime(new Date());
-        remoteUserService.addUser(sysUser, SecurityConstants.INNER);
-        String createDatabaseUrl="jdbc:mysql://"+ DatasourceContent.IP+":"+DatasourceContent.PORT+"?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8";
-        String createDatabaseSql = "CREATE DATABASE IF NOT EXISTS " + form.getEnterpriseDatabaseName() + ";";
-
-        try (Connection adminConn = DriverManager.getConnection(createDatabaseUrl, DatasourceContent.USER_NAME, DatasourceContent.PASSWORD);
-             Statement stmt = adminConn.createStatement()) {
-
-            boolean success = stmt.execute(createDatabaseSql);
-            if (success) {
-                log.info("数据库 {} 创建失败", form.getEnterpriseDatabaseName());
-
-            } else {
-                log.warn("数据库 {} 创建成功", form.getEnterpriseDatabaseName());
-
-                // 切换到新的数据库连接
-                Connection connection = null;
-                try {
-                    String url = "jdbc:mysql://47.101.53.251:3306/" + form.getEnterpriseDatabaseName() + "?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8";
-                    String user = "root";
-                    String pwd = "Lw030106";
-                    String driverClassName = "com.mysql.cj.jdbc.Driver";
-                    Class.forName(driverClassName);
-                    connection = DriverManager.getConnection(url, user, pwd);
-                } catch (ClassNotFoundException e) {
-                    throw new RuntimeException(e);
-                }
-                ClassPathResource rc = new ClassPathResource("static/saas.sql");
-                EncodedResource er = new EncodedResource(rc, "utf-8");
-                ScriptUtils.executeSqlScript(connection, er);
-
-
-            }
-
-        } catch (SQLException e) {
-            e.printStackTrace();
-            log.error("连接数据库时发生错误或创建数据库失败", e);
-        }
         return Result.success(rows);
     }
 

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/SysCarFaultController.java

@@ -85,7 +85,7 @@ public class SysCarFaultController extends BaseController
             @Validated @RequestBody SysCarFault sysCarFault)
     {
         //判断故障码是否重复
-        List<SysCarFault> selectFaultByFaultCode = sysCarFaultService.selectFaultByFaultCode(sysCarFault.getFaultCode());
+        SysCarFault selectFaultByFaultCode = sysCarFaultService.selectFaultByFaultCode(sysCarFault.getFaultCode());
         if (selectFaultByFaultCode!=null){
             return error("新增车辆故障 ,故障码已存在");
         }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/TemplateController.java

@@ -1,5 +1,6 @@
 package com.muyu.server.controller;
 
+import com.muyu.cache.TemplateCacheService;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.domain.Template;
 import com.muyu.server.service.TemplateService;
@@ -34,6 +35,9 @@ public class TemplateController {
     @Autowired
     private TemplateService templateService;
 
+    @Autowired
+    private TemplateCacheService templateCacheService;
+
     /**
      * 报文模版列表
      * @return
@@ -41,24 +45,19 @@ public class TemplateController {
     @PostMapping("/templateList")
     @Operation(summary = "报文模版列表",description = "报文模版列表")
     public Result<List<Template>> templateList() {
-        return Result.success(templateService.list());
+
+        List<Template> list = templateService.list();
+
+        templateCacheService.put("List",list);
+
+        return Result.success(list);
     }
 
 
-    /**
+
-     * 解析报文
-     * @param templateMessage
-     * @return
-     */
-    @PostMapping("/messageParsing")
-    @Operation(summary = "报文解析",description = "报文解析")
-    public Result messageParsing(@RequestParam("templateMessage") String templateMessage) throws SQLException, IoTDBConnectionException, ClassNotFoundException, StatementExecutionException, ExecutionException, InterruptedException {
-        templateService.messageParsing(templateMessage);
-        return Result.success();
-    }
 
     /**
-     * 报文模版添加0002222220
+     * 报文模版添加
      * @param template
      * @return
      */

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/WarnStrategyController.java

@@ -5,9 +5,6 @@ import javax.annotation.Resource;
 import com.muyu.common.domain.WarnStrategy;
 import com.muyu.common.domain.req.WarnStrategyReq;
 import com.muyu.server.service.WarnStrategyService;
-import io.swagger.v3.oas.annotations.Operation;
-import io.swagger.v3.oas.annotations.tags.Tag;
-import lombok.extern.log4j.Log4j2;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.DeleteMapping;
@@ -26,8 +23,6 @@ import com.muyu.common.core.domain.Result;
  */
 @RestController
 @RequestMapping("/strategy")
-@Log4j2
-@Tag(name = "预警策略管理",description = "预警策略管理")
 public class WarnStrategyController extends BaseController
 {
     @Resource
@@ -37,7 +32,6 @@ public class WarnStrategyController extends BaseController
      * 查询预警策略列表
      */
     @PostMapping("/selectWarnStrategyList")
-    @Operation(summary = "预警策略列表",description = "预警策略列表")
     public Result selectWarnStrategyList(@RequestBody WarnStrategyReq warnStrategyReq)
     {
       return Result.success(warnStrategyService.selectWarnStrategyList(warnStrategyReq));
@@ -48,7 +42,6 @@ public class WarnStrategyController extends BaseController
      * 获取预警策略详细信息
      */
     @GetMapping( "selectById/{id}")
-    @Operation(summary = "预警策略详细信息",description = "预警策略详细信息")
     public Result selectById(@PathVariable("id") Long id)
     {
         return success(warnStrategyService.selectWarnStrategyById(id));
@@ -58,7 +51,6 @@ public class WarnStrategyController extends BaseController
      * 新增预警策略
      */
     @PostMapping("/addWarnStrategy")
-    @Operation(summary = "预警策略添加",description = "预警策略添加")
     public Result addWarnStrategy(@RequestBody WarnStrategy warnStrategy)
     {
         Integer i = warnStrategyService.addWarnStrategy(warnStrategy);
@@ -69,7 +61,6 @@ public class WarnStrategyController extends BaseController
      * 修改预警策略
      */
     @PostMapping("/updWarnStrategy")
-    @Operation(summary = "预警策略修改",description = "预警策略修改")
     public Result updWarnStrategy(@RequestBody WarnStrategy warnStrategy)
     {
         Integer i = warnStrategyService.updWarnStrategy(warnStrategy);
@@ -80,7 +71,6 @@ public class WarnStrategyController extends BaseController
      * 删除预警策略
      */
 	@DeleteMapping("deleteWarnStrategy/{id}")
-    @Operation(summary = "预警策略删除",description = "预警策略删除")
     public Result deleteWarnStrategy(@PathVariable("id") Long id)
     {
         Integer i = warnStrategyService.deleteWarnStrategy(id);
@@ -93,7 +83,6 @@ public class WarnStrategyController extends BaseController
      * 根据车辆类型ID查询策略
      */
     @GetMapping("/selectListByCarType/{carTypeId}")
-    @Operation(summary = "根据车辆类型ID查询策略",description = "根据车辆类型ID查询策略")
     public Result selectListByCarType(@PathVariable("carTypeId") Long carTypeId) {
         return Result.success(warnStrategyService.selectListByCarType(carTypeId));
     }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/EnterpriseDao.java

@@ -9,14 +9,14 @@ import java.util.HashMap;
 import java.util.Map;
 
 /**
- * 企业信息Mapper接口
+ * 企业信息 Mapper接口
  * @author yupnig
  * @package com.muyu.server.mapper
- * @name EnterpriseMapper
+ * @name EnterpriseDao
  * @date 2024-09-29 14:31:06
  */
 @Mapper
-public interface EnterpriseMapper {
+public interface EnterpriseDao {
     // 查询分页信息
     public ArrayList<HashMap> selectEnterprise(Map param);
     //查询企业记录总数

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/SysCarFaultMapper.java

@@ -17,6 +17,16 @@ import java.util.List;
 @Mapper
 public interface SysCarFaultMapper extends BaseMapper<SysCarFault> {
 
+    //根据添加的故障码进行查询
+    @Select("select fault_code from sys_car_fault where fault_code=#{faultCode}")
+    SysCarFault selectFaultByFaultCode(String faultCode);
+
+    /**
+     *  查询故障码信息
+     * @param ids 故障码信息主键
+     * @return 故障码信息
+     */
+    public List<SysCarFault> selectSysCarFaultIds(String[] ids);
 
 
 

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/SysCarFaultMessageMapper.java

@@ -17,8 +17,12 @@ import java.util.List;
 @Mapper
 public interface SysCarFaultMessageMapper extends BaseMapper<SysCarFaultMessage> {
 
-
+    // 查询状态等于1的记录
-
+    @Select("select * from sys_car_fault_message where status=1")
+    public List<SysCarFaultMessage>listStatusOnt( );
+    //查询状态等于2的记录
+    @Select("select * from sys_car_fault_message where status=2")
+    public List<SysCarFaultMessage>listStatusTwo( );
 
 
 

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/SysCarMapper.java

@@ -28,6 +28,6 @@ public interface SysCarMapper extends BaseMapper<SysCar> {
 
     SysCar findCarByVin(@Param("carVin") String carVin);
 
-
+    SysCar selectByCarVin(@Param("carVin") String carVin);
 
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/TemplateMapper.java

@@ -19,6 +19,6 @@ import java.util.List;
 @Mapper
 public interface TemplateMapper extends BaseMapper<Template> {
 
-
+    List<MessageTemplateType> findTemplateById(@Param("templateId") Integer templateId);
 
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/TemplateNeedMapper.java

@@ -1,6 +1,5 @@
 package com.muyu.server.mapper;
 
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.muyu.common.domain.MessageTemplateType;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -15,6 +14,6 @@ import java.util.List;
  * @date 2024-09-29 14:44:57
  */
 @Mapper
-public interface TemplateNeedMapper extends BaseMapper<MessageTemplateType> {
+public interface TemplateNeedMapper {
-
+    List<MessageTemplateType> selectByTemplateId(@Param("templateId")Long templateId);
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/WarnStrategyMapper.java

@@ -12,7 +12,7 @@ import java.util.List;
 
 /**
  * 预警策略Mapper接口
- * @author sx
+ * @author muyu
  * @package com.muyu.server.mapper
  * @name WarnStrategyMapper
  * @date 2024-09-20

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/SysCarFaultService.java

@@ -36,7 +36,7 @@ public interface SysCarFaultService extends IService<SysCarFault> {
      * @return 结果
      */
 
-    List<SysCarFault> selectFaultByFaultCode(String faultCode);
+    SysCarFault selectFaultByFaultCode(String faultCode);
 
 
 

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/TemplateNeedService.java

@@ -1,6 +1,5 @@
 package com.muyu.server.service;
 
-import com.baomidou.mybatisplus.extension.service.IService;
 import com.muyu.common.domain.MessageTemplateType;
 
 import java.util.List;
@@ -13,6 +12,6 @@ import java.util.List;
  * @date 2024-09-29 15:31:55
  */
 
-public interface TemplateNeedService extends IService<MessageTemplateType> {
+public interface TemplateNeedService {
     List<MessageTemplateType> selectByTemplateId(Long templateId);
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/CarTypeServiceImpl.java

@@ -10,7 +10,6 @@ import com.muyu.server.service.CarTypeService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.Resource;
 import java.util.List;
 
 /**

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/EnterpriseServiceImpl.java

@@ -4,7 +4,7 @@ import cn.hutool.core.map.MapUtil;
 import com.muyu.cache.EnterpriseCacheService;
 import com.muyu.common.domain.Enterprise;
 import com.muyu.common.util.PageUtils;
-import com.muyu.server.mapper.EnterpriseMapper;
+import com.muyu.server.mapper.EnterpriseDao;
 import com.muyu.server.service.EnterpriseService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -22,7 +22,7 @@ import java.util.*;
 public class EnterpriseServiceImpl implements EnterpriseService {
 
     @Autowired
-    private EnterpriseMapper enterpriseDao;
+    private EnterpriseDao enterpriseDao;
 
     @Autowired
     private EnterpriseCacheService enterpriseCacheService;

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/SysCarFaultMessageServiceImpl.java

@@ -50,9 +50,8 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
     @Override
     public List<SysCarFaultMessage> listStatusOnt( ) {
 
-        LambdaQueryWrapper<SysCarFaultMessage> wrapper = new LambdaQueryWrapper<>();
+        List<SysCarFaultMessage> list = baseMapper.listStatusOnt();
-        wrapper.eq(SysCarFaultMessage::getStatus,1);
+        return list;
-        return this.list(wrapper);
     }
 
     /**
@@ -61,9 +60,7 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
      */
     @Override
     public List<SysCarFaultMessage> listStatusTwo( ) {
-
+        List<SysCarFaultMessage> list = baseMapper.listStatusTwo();
-        LambdaQueryWrapper<SysCarFaultMessage> wrapper = new LambdaQueryWrapper<>();
+        return list;
-        wrapper.eq(SysCarFaultMessage::getStatus,2);
-        return this.list(wrapper);
     }
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/SysCarFaultServiceImpl.java

@@ -91,12 +91,9 @@ public class SysCarFaultServiceImpl
      */
 
     @Override
-    public List<SysCarFault> selectFaultByFaultCode(String faultCode) {
+    public SysCarFault selectFaultByFaultCode(String faultCode) {
-        LambdaQueryWrapper<SysCarFault> wrapper = new LambdaQueryWrapper<>();
+        return mapper.selectFaultByFaultCode(faultCode);
-        wrapper.eq(SysCarFault::getFaultCode, faultCode);
-        return this.list(wrapper);
     }
 
 
-
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/SysCarServiceImpl.java

@@ -13,16 +13,9 @@ import com.muyu.server.service.SysCarService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-
+import java.util.Collections;
 import java.util.List;
 
-/**
- * 车辆管理 服务层处理
- * @author sx
- * @package com.muyu.server.service.impl
- * @name SysCarServiceImpl
- * @date 2024-09-29 14:31:06
- */
 @DS("lizzDB")
 @Service
 public class SysCarServiceImpl extends ServiceImpl<SysCarMapper, SysCar> implements SysCarService {

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateNeedServiceImpl.java

@@ -1,7 +1,5 @@
 package com.muyu.server.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.cache.MessageTemplateTypeCacheService;
 import com.muyu.common.domain.MessageTemplateType;
 import com.muyu.server.mapper.TemplateNeedMapper;
@@ -19,21 +17,14 @@ import java.util.List;
  * @date 2024/9/22 14:36
  */
 @Service
-public class TemplateNeedServiceImpl extends ServiceImpl<TemplateNeedMapper, MessageTemplateType> implements TemplateNeedService {
+public class TemplateNeedServiceImpl implements TemplateNeedService {
-
 
+    @Autowired
+    private TemplateNeedMapper templateNeedMapper;
 
     @Override
     public List<MessageTemplateType> selectByTemplateId(Long templateId) {
-
+        List<MessageTemplateType> messageTemplateTypes = templateNeedMapper.selectByTemplateId(templateId);
-        LambdaQueryWrapper<MessageTemplateType> wrapper = new LambdaQueryWrapper<>();
+        return messageTemplateTypes;
-
-
-        wrapper.eq(MessageTemplateType::getTemplateId, templateId);
-
-        return this.list(wrapper);
     }
-
-
-
 }

cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateServiceImpl.java

@@ -3,6 +3,7 @@ package com.muyu.server.service.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson2.JSON;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.cache.SysCarCacheService;
 import com.muyu.common.domain.MessageTemplateType;
 import com.muyu.common.domain.SysCar;
 import com.muyu.common.domain.Template;
@@ -20,8 +21,7 @@ import java.sql.*;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 /**
- * 报文模版 服务层处理
+ * @Author：liuxinyue
- * @author liuxinyue
  * @Package：com.template.service.impl
  * @Project：cloud-server-c
  * @name：TemplateServiceImp
@@ -31,7 +31,8 @@ import java.util.concurrent.ExecutionException;
 @Service
 public class TemplateServiceImpl extends ServiceImpl<TemplateMapper, Template> implements TemplateService {
 
-
+    @Autowired
+    private static TemplateMapper templateMapper;
 
     @Autowired
     private SysCarService sysCarService;

cloud-modules/saas/saas-server/src/main/resources/bootstrap.yml

@@ -7,7 +7,7 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: four
+  namespace: lxy
 # SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
 # Spring
 spring:

cloud-modules/saas/saas-server/src/main/resources/mapper/CarTypeMapper.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.muyu.server.mapper.CarTypeMapper">
+
+
+
+</mapper>

cloud-modules/saas/saas-server/src/main/resources/mapper/EnterpriseMapper.xml

@@ -6,7 +6,7 @@
 1.在mybats的开发中namespace有特殊的意思，一定要是对应接口的全限定名
 	通过namespace可以简历mapper.xml和接口之间的关系(名字不重要，位置不重要)
  -->
-<mapper namespace="com.muyu.server.mapper.EnterpriseMapper">
+<mapper namespace="com.muyu.server.mapper.EnterpriseDao">
 
     <!--查询企业信息-->
     <select id="selectEnterprise" resultType="HashMap" parameterType="Map">
@@ -27,18 +27,19 @@
     </select>
 
     <!--新增企业信息-->
-    <insert id="insert" parameterType="com.muyu.server.mapper.EnterpriseMapper">
+    <insert id="insert" parameterType="com.muyu.server.mapper.EnterpriseDao">
         insert into tb_enterprise
             set enterprise_name = #{enterpriseName},
                 enterprise_car_count = #{enterpriseCarCount},
-                enterprise_fence_count = #{enterpriseFenceCount}
+                enterprise_fence_count = #{enterpriseFenceCount},
+                enterprise_database_name=#{enterpriseDatabaseName}
     </insert>
 
 
 
     <!--根据编号查询企业信息-->
     <select id="searchById" resultType="java.util.HashMap">
-        select enterprise_id,enterprise_name,enterprise_car_count,enterprise_fence_count
+        select enterprise_id,enterprise_name,enterprise_car_count,enterprise_fence_count,enterprise_database_name
         from tb_enterprise
         where enterprise_id = #{enterpriseId}
     </select>
@@ -47,7 +48,8 @@
         update tb_enterprise
         set enterprise_name = #{enterpriseName},
             enterprise_car_count = #{enterpriseCarCount},
-            enterprise_fence_count = #{enterpriseFenceCount}
+            enterprise_fence_count = #{enterpriseFenceCount},
+            enterprise_database_name=#{enterpriseDatabaseName}
         where enterprise_id = #{enterpriseId} and enterprise_id != 0
     </update>
 

cloud-modules/saas/saas-server/src/main/resources/static/saas.sql

@@ -1,374 +0,0 @@
-/*
- Navicat Premium Data Transfer
-
- Source Server         : 组
- Source Server Type    : MySQL
- Source Server Version : 80401
- Source Host           : 47.101.53.251:3306
- Source Schema         : saas
-
- Target Server Type    : MySQL
- Target Server Version : 80401
- File Encoding         : 65001
-
- Date: 04/10/2024 16:01:07
-*/
-
-SET NAMES utf8mb4;
-SET FOREIGN_KEY_CHECKS = 0;
-
--- ----------------------------
--- Table structure for car_type
--- ----------------------------
-DROP TABLE IF EXISTS `car_type`;
-CREATE TABLE `car_type`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '车辆类型Id',
-  `type_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆类型',
-  `template_id` int NULL DEFAULT NULL COMMENT '报文模版Id',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆类型' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for data_type
--- ----------------------------
-DROP TABLE IF EXISTS `data_type`;
-CREATE TABLE `data_type`  (
-  `data_type_id` int NOT NULL AUTO_INCREMENT COMMENT '报文数据类型Id',
-  `data_type_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报文数据类型',
-  PRIMARY KEY (`data_type_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '报文数据类型' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for electronic_fence
--- ----------------------------
-DROP TABLE IF EXISTS `electronic_fence`;
-CREATE TABLE `electronic_fence`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '围栏主键',
-  `name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '围栏名称',
-  `fence_type` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '围栏类型（驶入，驶出）',
-  `longitude_latitude` text CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL COMMENT '经纬度信息',
-  `status` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '电子围栏状态（正常，停用）',
-  `fence_desc` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '描述信息',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '更新人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '更新时间',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '备注',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 11 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_bin COMMENT = '电子围栏' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for electronic_fence_group
--- ----------------------------
-DROP TABLE IF EXISTS `electronic_fence_group`;
-CREATE TABLE `electronic_fence_group`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '自增主键',
-  `group_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '围栏组名称',
-  `group_type` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '围栏组类型',
-  `priority` int NULL DEFAULT NULL COMMENT '围栏组优先级(0-99)',
-  `status` varchar(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '启用状态',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '更新人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '更新时间',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NULL DEFAULT NULL COMMENT '备注',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 11 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_bin COMMENT = '围栏组' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for fence_group_mid
--- ----------------------------
-DROP TABLE IF EXISTS `fence_group_mid`;
-CREATE TABLE `fence_group_mid`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `group_id` int NULL DEFAULT NULL COMMENT '围栏组外键',
-  `fence_id` int NULL DEFAULT NULL COMMENT '电子围栏外键',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 23 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '电子围栏-围栏组（中间表）' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for message_template
--- ----------------------------
-DROP TABLE IF EXISTS `message_template`;
-CREATE TABLE `message_template`  (
-  `message_id` int(10) UNSIGNED ZEROFILL NOT NULL AUTO_INCREMENT,
-  `vin_code` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'VIN 码',
-  `time_stamp` datetime NULL DEFAULT NULL COMMENT '时间戳',
-  `long_itude` double NULL DEFAULT NULL COMMENT '经度',
-  `latitude` double NULL DEFAULT NULL COMMENT '纬度',
-  `speed_vehicle` double NULL DEFAULT NULL COMMENT '车速',
-  `total_mileage` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '总里程',
-  `total_voltage` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '总电压',
-  `combined_current` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '总电流',
-  `insulation_resistance` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '绝缘电阻',
-  `gear_position` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '档位',
-  `accelerator_pedal_travel_value` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '加速踏板行程值',
-  `brake_pedal_travel_value` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '制动踏板行程值',
-  `specific_fuel_consumption` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '燃料消耗率',
-  `motor_controller_temperature` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机控制器温度',
-  `motor_speed` double NULL DEFAULT NULL COMMENT '电机转速',
-  `motor_torque` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机转矩',
-  `motor_temperature` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机温度',
-  `motor_voltage` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机电压',
-  `motor_current` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机电流',
-  `power_battery_remaining_soc` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '剩余电池电量',
-  `maximum_feedback_power` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最大反馈功率',
-  `maximum_discharge_power` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最大放电功率',
-  `bms_self_check_counter` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'BMS自检计数器',
-  `power_battery` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '动力电池',
-  `total_voltage_load_side` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '总电压负载侧',
-  `maximum_voltage` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最大电压',
-  `minimum_voltage` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最小电压',
-  `maximum_temperature` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最高温度',
-  `minimum_temperature` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最低温度',
-  `available_capacity` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '可用功率',
-  `vehicle_status` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆状态',
-  `charging_state` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '充电状态',
-  `operational_status` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '行驶状态',
-  `soc` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '单芯片系统',
-  `energy_storage_devices` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '能源存储设备',
-  `drive_motor_condition` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '驱动电机转态',
-  `whether_works` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '是否有效',
-  `eas` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电子防窃系统',
-  `ptc` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '正常温度系数',
-  `eps` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '蓄电池',
-  `abs` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '防抱死制动系统',
-  `mcu` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '单片机',
-  `heating_state` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '加热状态',
-  `power_battery_status` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT '' COMMENT '电源电池状态',
-  `state_battery_insulation` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '状态电池绝缘',
-  `dcdc` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '直流直流变换器',
-  `chg` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '变化',
-  `check_digit` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '校验数位',
-  `cutoff_bit` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '截止点',
-  PRIMARY KEY (`message_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '报文模版' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for message_template_type
--- ----------------------------
-DROP TABLE IF EXISTS `message_template_type`;
-CREATE TABLE `message_template_type`  (
-  `message_template_type_id` int NOT NULL AUTO_INCREMENT,
-  `message_code` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '编码',
-  `message_field` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '标签',
-  `start_index` int NULL DEFAULT NULL COMMENT '起始位',
-  `end_index` int NULL DEFAULT NULL COMMENT '终值位',
-  `data_type_id` int NULL DEFAULT NULL COMMENT '报文数据类型Id',
-  `data_type_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报文数据类型名称',
-  `fixed_value` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最小值',
-  `range_value` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '最大值',
-  `template_id` int NULL DEFAULT NULL COMMENT '模版Id',
-  `message_class` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报文类别',
-  PRIMARY KEY (`message_template_type_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 76 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '报文模版类型' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for message_value
--- ----------------------------
-DROP TABLE IF EXISTS `message_value`;
-CREATE TABLE `message_value`  (
-  `message_id` bigint NOT NULL AUTO_INCREMENT COMMENT '报文主键',
-  `template_id` bigint NULL DEFAULT NULL COMMENT '模版外键',
-  `message_code` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '报文编码',
-  `message_label` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '报文标签',
-  `message_start_index` int NULL DEFAULT NULL COMMENT '起始位',
-  `message_end_index` int NULL DEFAULT NULL COMMENT '终止位',
-  `create_by` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  `update_by` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '更新人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '更新时间',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '备注',
-  `message_class` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
-  PRIMARY KEY (`message_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 61 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '报文' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for sys_car
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car`;
-CREATE TABLE `sys_car`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `car_vin` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'VIN码',
-  `car_type_id` int NULL DEFAULT NULL COMMENT '车辆类型Id',
-  `state` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '状态',
-  `fence_id` int NULL DEFAULT NULL COMMENT '电子围栏',
-  `car_motor_manufacturer` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆电机厂商',
-  `car_motor_model` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电机型号',
-  `car_battery_manufacturer` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆电池厂商',
-  `car_battery_model` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '电池型号',
-  `strategy_id` int NULL DEFAULT NULL COMMENT '策略ID',
-  `group_id` int NULL DEFAULT NULL COMMENT '围栏组ID',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '修改人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '修改时间',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '备注',
-  `template_id` int NULL DEFAULT NULL COMMENT '报文模版ID',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆基础信息表' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for sys_car_enterprise
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car_enterprise`;
-CREATE TABLE `sys_car_enterprise`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `enterprise_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '企业名称',
-  `name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '用户姓名',
-  `position` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '用户职位',
-  `province` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '公司所在省',
-  `city` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '公司所在市',
-  `county` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '公司所在县/区',
-  `address` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '公司详细地址',
-  `credit_code` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '统一社会信用代码',
-  `business_license` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '营业执照',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '企业' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for sys_car_fault
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car_fault`;
-CREATE TABLE `sys_car_fault`  (
-  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '参数主键',
-  `fault_code` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '故障码编码',
-  `fault_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '故障名',
-  `type_id` int NULL DEFAULT NULL COMMENT '故障类型',
-  `fault_label` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '故障标签',
-  `fault_bit` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '故障位',
-  `fault_value` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '故障值',
-  `fault_rank` int NULL DEFAULT NULL COMMENT '故障级别 (0.低 ，1.中 ，2.高)',
-  `fault_desc` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '故障描述信息',
-  `fault_min_threshold` int NULL DEFAULT NULL COMMENT '故障最小阈值',
-  `fault_max_threshold` int NULL DEFAULT NULL COMMENT '故障最大阈值',
-  `status` int NULL DEFAULT 1 COMMENT '启用状态(1.待处理 2.处理中 3.已处理 4.忽略)',
-  `warn_status` int NULL DEFAULT 0 COMMENT '是否警告(0.开启 1.禁止)',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '备注',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '创建者',
-  `create_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '更新者',
-  `update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
-  `car_type_id` int NULL DEFAULT NULL COMMENT '车辆类型',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 17 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '故障码' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for sys_car_fault_log
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car_fault_log`;
-CREATE TABLE `sys_car_fault_log`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `sys_car_fault_id` int NOT NULL COMMENT '故障码编号',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '开始时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '修改人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '结束时间',
-  `vin` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT 'VIN码',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '内容',
-  `status` int NULL DEFAULT 2 COMMENT '1- 解决 2- 处理中 3-忽略',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '故障日志表' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for sys_car_fault_message
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car_fault_message`;
-CREATE TABLE `sys_car_fault_message`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `content` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '内容',
-  `status` int NULL DEFAULT NULL COMMENT '1-已读 2-未读',
-  `create_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '开始时间',
-  `update_by` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '修改人',
-  `update_time` datetime NULL DEFAULT NULL COMMENT '结束时间',
-  `remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '备注',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '站内信' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for sys_car_log
--- ----------------------------
-DROP TABLE IF EXISTS `sys_car_log`;
-CREATE TABLE `sys_car_log`  (
-  `id` int NOT NULL AUTO_INCREMENT,
-  `car_vin` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'VIN码',
-  `start_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  `end_time` datetime NULL DEFAULT NULL COMMENT '结束时间',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆日志表' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for t_template
--- ----------------------------
-DROP TABLE IF EXISTS `t_template`;
-CREATE TABLE `t_template`  (
-  `template_id` int NOT NULL AUTO_INCREMENT,
-  `house_id` int NULL DEFAULT NULL,
-  `template_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报文模版名称',
-  `template_describe` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报文模版描述',
-  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
-  PRIMARY KEY (`template_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '报文模版表' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for tb_enterprise
--- ----------------------------
-DROP TABLE IF EXISTS `tb_enterprise`;
-CREATE TABLE `tb_enterprise`  (
-  `enterprise_id` int NOT NULL AUTO_INCREMENT COMMENT '企业编号',
-  `enterprise_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '企业名称',
-  `enterprise_car_count` int NULL DEFAULT 0 COMMENT '企业车辆数量',
-  `enterprise_fence_count` int NULL DEFAULT 0 COMMENT '企业电子围栏数量',
-  `enterprise_database_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '企业数据库',
-  PRIMARY KEY (`enterprise_id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 18 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '企业运营' ROW_FORMAT = Dynamic;
-
--- ----------------------------
--- Table structure for warn_logs
--- ----------------------------
-DROP TABLE IF EXISTS `warn_logs`;
-CREATE TABLE `warn_logs`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '预警日志id',
-  `vin` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆vin码',
-  `warn_rule_id` int NULL DEFAULT NULL COMMENT '规则id',
-  `start_time` datetime NULL DEFAULT NULL COMMENT '开始时间',
-  `end_time` datetime NULL DEFAULT NULL COMMENT '结束时间',
-  `max_value` int NULL DEFAULT NULL COMMENT '最大值',
-  `min_value` int NULL DEFAULT NULL COMMENT '最小值',
-  `avg_value` int NULL DEFAULT NULL COMMENT '平均值',
-  `median_value` int NULL DEFAULT NULL COMMENT '中位数',
-  `status` int NULL DEFAULT NULL COMMENT '是否发送预警',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆预警记录表' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for warn_rule
--- ----------------------------
-DROP TABLE IF EXISTS `warn_rule`;
-CREATE TABLE `warn_rule`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '规则id',
-  `rule_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '规则名称',
-  `strategy_id` int NULL DEFAULT NULL COMMENT '策略id',
-  `msg_type_id` int NULL DEFAULT NULL COMMENT '报文数据类型id',
-  `slide_time` int NULL DEFAULT NULL COMMENT '滑窗时间',
-  `slide_frequency` int NULL DEFAULT NULL COMMENT '滑窗频率',
-  `growth_rate` int NULL DEFAULT NULL COMMENT '增长率',
-  `volatility_rate` int NULL DEFAULT NULL COMMENT '波动率',
-  `decrease_rate` int NULL DEFAULT NULL COMMENT '下降率',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆预警规则表' ROW_FORMAT = DYNAMIC;
-
--- ----------------------------
--- Table structure for warn_strategy
--- ----------------------------
-DROP TABLE IF EXISTS `warn_strategy`;
-CREATE TABLE `warn_strategy`  (
-  `id` int NOT NULL AUTO_INCREMENT COMMENT '策略id',
-  `car_type_id` int NULL DEFAULT NULL COMMENT '车辆类型id',
-  `strategy_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '策略名称',
-  `template_id` int NULL DEFAULT NULL COMMENT '报文模版id',
-  PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB AUTO_INCREMENT = 8 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆预警策略表' ROW_FORMAT = DYNAMIC;
-
-SET FOREIGN_KEY_CHECKS = 1;