From 3c3e4d195d0621bf1406c39c805fe18fdc4ac3de Mon Sep 17 00:00:00 2001 From: rouchen <3133657697@qq.com> Date: Thu, 6 Jun 2024 22:17:31 +0800 Subject: [PATCH] =?UTF-8?q?feat=20=E6=8E=A5=E5=8F=97=E6=8A=A5=E6=96=87=20?= =?UTF-8?q?=E8=A7=A3=E6=9E=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 6 + .../com/muyu/controller/UserController.java | 143 ++++++ src/main/java/com/muyu/domain/User.java | 98 ++++ src/main/java/com/muyu/mapper/UserMapper.java | 16 + .../com/muyu/mqtt/MessageCallbackService.java | 35 ++ src/main/java/com/muyu/mqtt/MqttFactory.java | 46 ++ .../java/com/muyu/mqtt/MqttProperties.java | 40 ++ src/main/java/com/muyu/mqtt/MsgHandler.java | 39 ++ src/main/java/com/muyu/mqtt/RabbitConfig.java | 37 ++ .../muyu/rabbitmq/SubscriptionHandler.java | 35 ++ .../muyu/rabbitmq/confilg/RabbitmqConfig.java | 53 ++ .../java/com/muyu/service/UserService.java | 16 + .../muyu/service/impl/UserServiceImpl.java | 20 + .../java/com/muyu/utils/ConversionUtil.java | 10 +- .../java/com/muyu/vehicle/VehicleData.java | 484 ++++++++++++++++++ .../java/com/muyu/vehicle/core/Config.java | 10 + .../model/properties/MqttProperties.java | 1 + src/main/resources/application.yml | 3 + 18 files changed, 1087 insertions(+), 5 deletions(-) create mode 100644 src/main/java/com/muyu/controller/UserController.java create mode 100644 src/main/java/com/muyu/domain/User.java create mode 100644 src/main/java/com/muyu/mapper/UserMapper.java create mode 100644 src/main/java/com/muyu/mqtt/MessageCallbackService.java create mode 100644 src/main/java/com/muyu/mqtt/MqttFactory.java create mode 100644 src/main/java/com/muyu/mqtt/MqttProperties.java create mode 100644 src/main/java/com/muyu/mqtt/MsgHandler.java create mode 100644 src/main/java/com/muyu/mqtt/RabbitConfig.java create mode 100644 src/main/java/com/muyu/rabbitmq/SubscriptionHandler.java create mode 100644 src/main/java/com/muyu/rabbitmq/confilg/RabbitmqConfig.java create mode 100644 src/main/java/com/muyu/service/UserService.java create mode 100644 src/main/java/com/muyu/service/impl/UserServiceImpl.java create mode 100644 src/main/java/com/muyu/vehicle/VehicleData.java create mode 100644 src/main/java/com/muyu/vehicle/core/Config.java diff --git a/pom.xml b/pom.xml index 00549bc..5e55758 100644 --- a/pom.xml +++ b/pom.xml @@ -23,6 +23,12 @@ + + + org.springframework.boot + spring-boot-starter-amqp + + org.springframework.boot spring-boot-starter-web diff --git a/src/main/java/com/muyu/controller/UserController.java b/src/main/java/com/muyu/controller/UserController.java new file mode 100644 index 0000000..8aac8fd --- /dev/null +++ b/src/main/java/com/muyu/controller/UserController.java @@ -0,0 +1,143 @@ +package com.muyu.controller; + + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.muyu.common.Result; +import com.muyu.domain.User; +import com.muyu.service.UserService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * com.muyu.controller 测试 + * + */ +@RestController +@RequestMapping("/user") +public class UserController { + + /** + * 构造方法注入 + */ + @Autowired + UserService userService; + + + @PostMapping("/login") + public Result login(){ + return Result.success(); + } + @PostMapping("/info") + public Result info(){ + return Result.success(); + } + + /** + * 保存数据 + * + * @return + */ + @GetMapping("/save") + public Result save() { + User user = new User(); + user.setId(10); + user.setUsername("miaolinlin"); + user.setPwd("121212"); + userService.save(user); + return Result.success(user); + } + + /** + * 修改数据 + * + * @param id + * @return + */ + @GetMapping("/update") + public Result update(Integer id) { + User user = new User(); + user.setId(id); + user.setPwd("1111111111"); + userService.updateById(user); + return Result.success("{}"); + } + + @GetMapping("/list") + public Result list() { + // 返回所有 + List list = userService.list(); + return Result.success(list); + } + + @GetMapping("/listByContion") + public Result listByContion() { + /** + * 条件查询， 通过QueryWrapper来实现查询的条件： + * eq: 代表相等 + * like: 模糊匹配 + * orderBy: 排序 + * in, notin + * 大于，小于，between等 + */ + List list = userService.list(new LambdaQueryWrapper() + // 查询年龄=11的 + .eq(User::getUsername, "miao") + // 模糊匹配 + .like(User::getPwd, "%111%") + // 排序，按照创建时间 + .orderByDesc(User::getCreateTime) + ); + return Result.success(list); + } + + /** + * 根据id获取数据 + * + * @param id + * @return + */ + @GetMapping("/getById") + public Result getById(Integer id) { + User user = userService.getById(id); + return Result.success(user); + } + + /** + * 删除数据 + * + * @param id + * @return + */ + @GetMapping("/delete") + public Result delete(Integer id) { + userService.removeById(id); + return Result.success("success"); + } + + /** + * 分页查询 + * + * @param pageNum + * @param pageSize + * @param name + * @return + */ + @GetMapping("/page") + public Result page(int pageNum, int pageSize, String name) { + IPage page = new Page<>(pageNum, pageSize); + + IPage page1 = userService.page(page, new LambdaQueryWrapper() + // 主要演示这里可以加条件。在name不为空的时候执行 + .like(StringUtils.isNotEmpty(name), User::getUsername, "%" + name + "%")); + + return Result.success(page1); + } +} diff --git a/src/main/java/com/muyu/domain/User.java b/src/main/java/com/muyu/domain/User.java new file mode 100644 index 0000000..b328d47 --- /dev/null +++ b/src/main/java/com/muyu/domain/User.java @@ -0,0 +1,98 @@ +package com.muyu.domain; + +import com.baomidou.mybatisplus.annotation.*; +import com.fasterxml.jackson.annotation.JsonFormat; + +import java.io.Serializable; +import java.util.Date; + +/** + *

+ * 用户表 + *

+ * + * @author Leo825 + * @since 2022-07-05 + */ +@TableName("t_user") +public class User implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 用户主键 + */ + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 用户名称 + */ + private String username; + + /** + * 密码 + */ + private String pwd; + + /** + * 创建时间，MyMetaObjectHandler 配合使用，入库的时候自动填充 + */ + @TableField(value = "create_time", fill = FieldFill.INSERT) + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + private Date createTime; + + /** + * 修改时间，MyMetaObjectHandler 配合使用，入库的时候自动填充 + */ + @TableField(value = "update_time", fill = FieldFill.INSERT_UPDATE) + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + private Date updateTime; + + public Integer getId() { + return id; + } + + public void setId(Integer id) { + this.id = id; + } + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + public String getPwd() { + return pwd; + } + + public void setPwd(String pwd) { + this.pwd = pwd; + } + public Date getCreateTime() { + return createTime; + } + + public void setCreateTime(Date createTime) { + this.createTime = createTime; + } + public Date getUpdateTime() { + return updateTime; + } + + public void setUpdateTime(Date updateTime) { + this.updateTime = updateTime; + } + + @Override + public String toString() { + return "User{" + + "id=" + id + + ", username=" + username + + ", pwd=" + pwd + + ", createTime=" + createTime + + ", updateTime=" + updateTime + + "}"; + } +} diff --git a/src/main/java/com/muyu/mapper/UserMapper.java b/src/main/java/com/muyu/mapper/UserMapper.java new file mode 100644 index 0000000..216ec1e --- /dev/null +++ b/src/main/java/com/muyu/mapper/UserMapper.java @@ -0,0 +1,16 @@ +package com.muyu.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.domain.User; + +/** + *

+ * 用户表 Mapper 接口 + *

+ * + * @author Leo825 + * @since 2022-07-05 + */ +public interface UserMapper extends BaseMapper { + +} diff --git a/src/main/java/com/muyu/mqtt/MessageCallbackService.java b/src/main/java/com/muyu/mqtt/MessageCallbackService.java new file mode 100644 index 0000000..5396163 --- /dev/null +++ b/src/main/java/com/muyu/mqtt/MessageCallbackService.java @@ -0,0 +1,35 @@ +package com.muyu.mqtt; + +import com.muyu.utils.ConversionUtil; +import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; +import org.eclipse.paho.client.mqttv3.MqttCallback; +import org.eclipse.paho.client.mqttv3.MqttMessage; +import org.springframework.stereotype.Service; + +/** + * 回执消息类 MessageCallbackService + * + * @author Yangle + * Date 2024/6/6 15:08 + */ +@Service +public class MessageCallbackService implements MqttCallback { + @Override + public void connectionLost(Throwable cause) { + System.out.println("connectionLost:"+cause.getMessage()); + } + + @Override + public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception { + System.out.println("topic:"+topic); + System.out.println("Qos:"+mqttMessage.getQos()); + System.out.println("message content:"+new String(mqttMessage.getPayload())); + String s = new String(mqttMessage.getPayload()); + ConversionUtil.main(s); + } + + @Override + public void deliveryComplete(IMqttDeliveryToken token) { + System.out.println("deliveryComplete---------" + token.isComplete()); + } +} diff --git a/src/main/java/com/muyu/mqtt/MqttFactory.java b/src/main/java/com/muyu/mqtt/MqttFactory.java new file mode 100644 index 0000000..9554ff5 --- /dev/null +++ b/src/main/java/com/muyu/mqtt/MqttFactory.java @@ -0,0 +1,46 @@ +package com.muyu.mqtt; + +import lombok.AllArgsConstructor; +import org.eclipse.paho.client.mqttv3.MqttClient; +import org.eclipse.paho.client.mqttv3.MqttConnectOptions; +import org.eclipse.paho.client.mqttv3.MqttException; +import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; +import org.springframework.stereotype.Service; + +/** + * mqtt配置 MqttFactory + * + * @author Yangle + * Date 2024/6/6 15:10 + */ +@Service +@AllArgsConstructor +public class MqttFactory { + + private final MessageCallbackService messageCallbackService; + + public MqttClient creatClient(MqttProperties mqttProperties) { + MqttClient client =null; + try { + client = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientid(), new MemoryPersistence()); + MqttConnectOptions options = new MqttConnectOptions(); + + // 连接参数 + if (mqttProperties.isLong()) + { + options.setUserName(mqttProperties.getUsername()); + options.setPassword(mqttProperties.getPassword().toCharArray()); + } + options.setConnectionTimeout(60); + options.setKeepAliveInterval(60); + client.connect(options); + client.setCallback(messageCallbackService); + client.subscribe(mqttProperties.getTopic(),0); + + } catch (MqttException e) { + throw new RuntimeException(e); + } + + return client; + } +} diff --git a/src/main/java/com/muyu/mqtt/MqttProperties.java b/src/main/java/com/muyu/mqtt/MqttProperties.java new file mode 100644 index 0000000..0fade3d --- /dev/null +++ b/src/main/java/com/muyu/mqtt/MqttProperties.java @@ -0,0 +1,40 @@ +package com.muyu.mqtt; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; +import org.apache.commons.lang3.StringUtils; + +/** + * 配置文件 MqttProperties + * + * @author Yangle + * Date 2024/5/29 20:06 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class MqttProperties { + + private String broker; + private String topic ; + private String username; + private String password; + private String clientid; + + public static MqttProperties configBuild(String ip,String topic){ + return MqttProperties.builder() + .broker("tcp://"+ip+":1883") + .topic(topic) + .clientid("protocol-parsing") + .build(); + } + + public boolean isLong(){ + return !StringUtils.isBlank(this.username) && !StringUtils.isBlank(this.password); + } + + +} diff --git a/src/main/java/com/muyu/mqtt/MsgHandler.java b/src/main/java/com/muyu/mqtt/MsgHandler.java new file mode 100644 index 0000000..0d3c07a --- /dev/null +++ b/src/main/java/com/muyu/mqtt/MsgHandler.java @@ -0,0 +1,39 @@ +package com.muyu.mqtt; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import lombok.extern.log4j.Log4j2; +import org.eclipse.paho.client.mqttv3.MqttClient; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 消费处理器 MsgHandler + * + * @author Yangle + * Date 2024/6/6 15:15 + */ +@Log4j2 +@Component +public class MsgHandler { + @Autowired + private MqttFactory mqttFactory; + @RabbitListener(queues = "ip") + public void msg(String msg){ + log.info("接收到消息：{}",msg); + + String[] split = msg.split(","); + for (String s : split) { + MqttProperties mqttProperties = MqttProperties.configBuild( + s, + "test1" + ); + log.error("接收到消息初始化信息:{}",mqttProperties); + MqttClient mqttClient = mqttFactory.creatClient(mqttProperties); + log.error("client创建成功:{}",mqttClient.getClientId()); + } + + + } +} diff --git a/src/main/java/com/muyu/mqtt/RabbitConfig.java b/src/main/java/com/muyu/mqtt/RabbitConfig.java new file mode 100644 index 0000000..3013e94 --- /dev/null +++ b/src/main/java/com/muyu/mqtt/RabbitConfig.java @@ -0,0 +1,37 @@ +package com.muyu.mqtt; + +import org.springframework.amqp.core.Binding; +import org.springframework.amqp.core.BindingBuilder; +import org.springframework.amqp.core.DirectExchange; +import org.springframework.amqp.core.Queue; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * RabbitConfig + * + * @author Yangle + * Date 2024/6/6 15:17 + */ +@Configuration +public class RabbitConfig { + + @Bean + public Queue autoDeleteQueue1() { + return new Queue("create.topic", true); + } + + @Bean + public DirectExchange directExchange() { + return new DirectExchange("topic.direct"); + } + + @Bean + public Binding binding(DirectExchange directExchange, + Queue autoDeleteQueue1 ) { + return BindingBuilder.bind(autoDeleteQueue1) + .to(directExchange) + .with("protocol-parsing"); + } + +} diff --git a/src/main/java/com/muyu/rabbitmq/SubscriptionHandler.java b/src/main/java/com/muyu/rabbitmq/SubscriptionHandler.java new file mode 100644 index 0000000..e14fb50 --- /dev/null +++ b/src/main/java/com/muyu/rabbitmq/SubscriptionHandler.java @@ -0,0 +1,35 @@ +package com.muyu.rabbitmq; + +import com.muyu.rabbitmq.confilg.RabbitmqConfig; +import com.rabbitmq.client.impl.AMQImpl; +import lombok.extern.log4j.Log4j2; +import org.springframework.amqp.core.Message; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.stereotype.Component; + + +/** + * 监听车辆上线的信息 SubscriptionHandler + * + * @author Yangle + * Date 2024/6/6 14:24 + */ +@Component +@Log4j2 +public class SubscriptionHandler { + + @RabbitListener(queues = {RabbitmqConfig.QUEUE_INFORM_EMAIL}) + public void receive_email(Object msg, Message message, AMQImpl.Channel channel){ + System.out.println("QUEUE_INFORM_EMAIL msg"+msg); + } + //监听sms队列 + @RabbitListener(queues = "subscription") + public void receiveSms(Message message) { + try { + log.info("消费者得到的消息: {}" , new String(message.getBody())); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + +} diff --git a/src/main/java/com/muyu/rabbitmq/confilg/RabbitmqConfig.java b/src/main/java/com/muyu/rabbitmq/confilg/RabbitmqConfig.java new file mode 100644 index 0000000..78c24b3 --- /dev/null +++ b/src/main/java/com/muyu/rabbitmq/confilg/RabbitmqConfig.java @@ -0,0 +1,53 @@ +package com.muyu.rabbitmq.confilg; + +import org.springframework.amqp.core.*; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + + +/** + * rabbitMQ配置 RabbitmqConfig + * + * @author Yangle + * Date 2024/5/28 21:42 + */ +@Configuration +public class RabbitmqConfig { + public static final String QUEUE_INFORM_EMAIL = "queue_inform_email"; + public static final String QUEUE_INFORM_SMS = "disconnect_connect"; + public static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform"; + public static final String ROUTINGKEY_EMAIL="inform.#.email.#"; + public static final String ROUTINGKEY_SMS="inform.#.sms.#"; + + + @Bean(EXCHANGE_TOPICS_INFORM) + public Exchange EXCHANGE_TOPICS_INFORM(){ + //durable(true) 持久化，mq重启之后交换机还在 + return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build(); + } + + //声明QUEUE_INFORM_EMAIL队列 + @Bean(QUEUE_INFORM_EMAIL) + public Queue QUEUE_INFORM_EMAIL(){ + return new Queue(QUEUE_INFORM_EMAIL); + } + //声明QUEUE_INFORM_SMS队列 + @Bean(QUEUE_INFORM_SMS) + public Queue QUEUE_INFORM_SMS(){ + return new Queue(QUEUE_INFORM_SMS); + } + + //ROUTINGKEY_EMAIL队列绑定交换机，指定routingKey + @Bean + public Binding BINDING_QUEUE_INFORM_EMAIL(@Qualifier(QUEUE_INFORM_EMAIL) Queue queue, + @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){ + return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_EMAIL).noargs(); + } + //ROUTINGKEY_SMS队列绑定交换机，指定routingKey + @Bean + public Binding BINDING_ROUTINGKEY_SMS(@Qualifier(QUEUE_INFORM_SMS) Queue queue, + @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){ + return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_SMS).noargs(); + } +} diff --git a/src/main/java/com/muyu/service/UserService.java b/src/main/java/com/muyu/service/UserService.java new file mode 100644 index 0000000..2e32554 --- /dev/null +++ b/src/main/java/com/muyu/service/UserService.java @@ -0,0 +1,16 @@ +package com.muyu.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.domain.User; + +/** + *

+ * 用户表 服务类 + *

+ * + * @author Leo825 + * @since 2022-07-05 + */ +public interface UserService extends IService { + +} diff --git a/src/main/java/com/muyu/service/impl/UserServiceImpl.java b/src/main/java/com/muyu/service/impl/UserServiceImpl.java new file mode 100644 index 0000000..c6d436f --- /dev/null +++ b/src/main/java/com/muyu/service/impl/UserServiceImpl.java @@ -0,0 +1,20 @@ +package com.muyu.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.domain.User; +import com.muyu.mapper.UserMapper; +import com.muyu.service.UserService; +import org.springframework.stereotype.Service; + +/** + *

+ * 用户表 服务实现类 + *

+ * + * @author Leo825 + * @since 2022-07-05 + */ +@Service +public class UserServiceImpl extends ServiceImpl implements UserService { + +} diff --git a/src/main/java/com/muyu/utils/ConversionUtil.java b/src/main/java/com/muyu/utils/ConversionUtil.java index 805e615..9c5c304 100644 --- a/src/main/java/com/muyu/utils/ConversionUtil.java +++ b/src/main/java/com/muyu/utils/ConversionUtil.java @@ -1,6 +1,5 @@ package com.muyu.utils; -import com.muyu.vehicle.model.VehicleData; import lombok.extern.log4j.Log4j2; import java.nio.charset.StandardCharsets; @@ -24,7 +23,7 @@ public class ConversionUtil { return sb.toString(); } - public static void main (String[] args) { + public static void main (String args) { // String str = "\n" + // "Sinus
80No Change0"; // String strToSixteen = strToSixteen(str); @@ -32,10 +31,11 @@ public class ConversionUtil { // System.out.println(str.length()); // System.out.println(strToSixteen); // System.out.println(strToSixteen.replace(" ", "").length()); + String hexStr = "7E 48 58 49 54 48 58 55 51 52 32 54 55 43 30 58 33 55 31 37 31 37 35 38 39 32 35 37 35 35 31 31 31 36 2e 37 36 34 36 35 30 30 33 39 2e 35 37 34 38 38 30 30 32 37 30 2e 30 30 32 30 2e 33 35 30 30 30 30 30 30 32 37 36 30 30 30 38 30 30 30 30 32 32 30 38 30 30 30 30 30 44 31 30 30 30 39 2e 30 30 30 33 32 30 30 30 30 34 34 37 34 39 37 38 36 30 31 30 39 30 30 30 32 32 32 30 30 35 32 38 34 30 30 30 30 37 35 38 38 34 2e 33 32 30 30 30 30 31 33 30 30 30 30 31 31 34 30 30 30 30 36 39 39 30 30 30 34 30 30 30 33 30 30 30 35 30 30 30 30 30 35 30 30 30 30 30 32 33 30 30 30 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 11 7E"; - String hexStringToString = hexStringToString(hexStr); - System.out.println(hexStr); - System.out.println(hexStr.length()); + String hexStringToString = hexStringToString(args); + System.out.println(args); + System.out.println(args.length()); System.out.println(hexStringToString); System.out.println(hexStringToString.length()); //截取第一位和最后两位 diff --git a/src/main/java/com/muyu/vehicle/VehicleData.java b/src/main/java/com/muyu/vehicle/VehicleData.java new file mode 100644 index 0000000..511abdd --- /dev/null +++ b/src/main/java/com/muyu/vehicle/VehicleData.java @@ -0,0 +1,484 @@ +package com.muyu.vehicle; + + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @author 牧鱼 + * @Classname VehicleData + * @Description 车辆模拟数据对象 + * @Date 2021/8/5 + */ +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class VehicleData { + /** + * VIN + */ + private String vin; + /** + * 行驶路线 + */ + private String drivingRoute; + + /** + * 经度 + */ + private String longitude; + + /** + * 维度 + */ + private String latitude; + + /** + * 速度 + */ + private String speed; + + /** + * 里程 + */ + private String mileage; + + /** + * 总电压 + */ + private String voltage; + + /** + * 总电流 + */ + private String current; + + /** + * 绝缘电阻 + */ + private String resistance; + + /** + * 档位 + */ + private String gear; + + /** + * 加速踏板行程值 + */ + private String accelerationPedal; + + /** + * 制动踏板行程值 + */ + private String brakePedal; + + /** + * 燃料消耗率 + */ + private String fuelConsumptionRate; + + /** + * 电机控制器温度 + */ + private String motorControllerTemperature; + + /** + * 电机转速 + */ + private String motorSpeed; + + /** + * 电机转矩 + */ + private String motorTorque; + + /** + * 电机温度 + */ + private String motorTemperature; + + /** + * 电机电压 + */ + private String motorVoltage; + + /** + * 电机电流 + */ + private String motorCurrent; + + /** + * 动力电池剩余电量SOC + */ + private String remainingBattery; + + /** + * 当前状态允许的最大反馈功率 + */ + private String maximumFeedbackPower; + + /** + * 当前状态允许最大放电功率 + */ + private String maximumDischargePower; + + /** + * BMS自检计数器 + */ + private String selfCheckCounter; + + /** + * 动力电池充放电电流 + */ + private String totalBatteryCurrent; + + /** + * 动力电池负载端总电压V3 + */ + private String totalBatteryVoltage; + + /** + * 单次最大电压 + */ + private String singleBatteryMaxVoltage; + + /** + * 单体电池最低电压 + */ + private String singleBatteryMinVoltage; + + /** + * 单体电池最高温度 + */ + private String singleBatteryMaxTemperature; + + /** + * 单体电池最低温度 + */ + private String singleBatteryMinTemperature; + + /** + * 动力电池可用容量 + */ + private String availableBatteryCapacity; + + /** + * 车辆状态 + */ + private int vehicleStatus; + + /** + * 充电状态 + */ + private int chargingStatus; + + /** + * 运行状态 + */ + private int operatingStatus; + + /** + * SOC + */ + private int socStatus; + + /** + * 可充电储能装置工作状态 + */ + private int chargingEnergyStorageStatus; + + /** + * 驱动电机状态 + */ + private int driveMotorStatus; + + /** + * 定位是否有效 + */ + private int positionStatus; + + /** + * EAS(汽车防盗系统)状态 + */ + private int easStatus; + + /** + * PTC(电动加热器)状态 + */ + private int ptcStatus; + + /** + * EPS(电动助力系统)状态 + */ + private int epsStatus; + + /** + * ABS(防抱死)状态 + */ + private int absStatus; + + /** + * MCU(电机/逆变器)状态 + */ + private int mcuStatus; + + /** + * 动力电池加热状态 + */ + private int heatingStatus; + + /** + * 动力电池当前状态 + */ + private int batteryStatus; + + /** + * 动力电池保温状态 + */ + private int batteryInsulationStatus; + + /** + * DCDC(电力交换系统)状态 + */ + private int dcdcStatus; + + /** + * CHG(充电机)状态 + */ + private int chgStatus; + + /** + * 车辆状态 报文 + */ + private String vehicleStatusMsg; + /** + * 智能硬件 报文 + */ + private String smartHardwareMsg; + /** + * 电池报文 + */ + private String batteryMsg; + + public String getMsg(){ + StringBuilder sb = new StringBuilder(); + //第一位VIN + sb.append(vin); + //第二位经度 longitude latitude + sb.append(getValue(longitude ,11)); + //第三位维度 longitude latitude + sb.append(getValue(latitude ,10)); + //车速 + sb.append(getValue(speed,6)); + //总里程 + sb.append(getValue(mileage,11)); + // 总电压 + sb.append(getValue(voltage,6)); + //总电流 + sb.append(getValue(current,5)); + //绝缘电阻 79 - 87 + sb.append(getValue(resistance,9)); + //档位 + sb.append(gear); + // 加速踏板行程值 + sb.append(getValue(accelerationPedal,2)); + // 制动踏板行程值 + sb.append(getValue(brakePedal,2)); + // 燃料消耗率 + sb.append(getValue(fuelConsumptionRate,5)); + //电机控制器温度 + sb.append(getValue(motorControllerTemperature,6)); + //电机转速 + sb.append(getValue(motorSpeed,5)); + //点击转矩 + sb.append(getValue(motorTorque,4)); + //电机温度 + sb.append(getValue(motorTemperature,6)); + //电机电压 + sb.append(getValue(motorVoltage,5)); + //电机电流 + sb.append(getValue(motorCurrent,8)); + //动力电池剩余电量SOC + sb.append(getValue(remainingBattery,6)); + //当前状态允许的最大反馈功率 + sb.append(getValue(maximumFeedbackPower,6)); + //当前状态允许最大放电功率 + sb.append(getValue(maximumDischargePower,6)); + //BMS自检计数器 + sb.append(getValue(selfCheckCounter,2)); + //动力电池充放电电流 + sb.append(getValue(totalBatteryCurrent,5)); + //动力电池负载端总电压V3 + sb.append(getValue(totalBatteryVoltage,6)); + //单次最大电压 + sb.append(getValue(singleBatteryMaxVoltage,4)); + //单体电池最低电压 + sb.append(getValue(singleBatteryMinVoltage,4)); + //单体电池最高温度 + sb.append(getValue(singleBatteryMaxTemperature,6)); + //单体电池最低温度 + sb.append(getValue(singleBatteryMinTemperature,6)); + //动力电池可用容量 + sb.append(getValue(availableBatteryCapacity,6)); + //车辆状态 + sb.append(vehicleStatus); + //充电状态 + sb.append(chargingStatus); + //运行状态 + sb.append(operatingStatus); + //SOC + sb.append(socStatus); + //可充电储能装置工作状态 + sb.append(chargingEnergyStorageStatus); + //驱动电机状态 + sb.append(driveMotorStatus); + //定位是否有效 + sb.append(positionStatus); + //EAS + sb.append(easStatus); + //PTC + sb.append(ptcStatus); + //EPS + sb.append(epsStatus); + //ABS + sb.append(absStatus); + //MCU + sb.append(mcuStatus); + //动力电池加热状态 + sb.append(heatingStatus); + //动力电池当前状态 + sb.append(batteryStatus); + //动力电池保温状态 + sb.append(batteryInsulationStatus); + //DCDC + sb.append(dcdcStatus); + //CHG + sb.append(chgStatus); + return sb.toString(); + } + + public String getValue(String val , int valLength){ + int length = val.length(); + if (length > valLength){ + return val.substring( 0 , valLength); + } + val = val + "0".repeat(valLength - length); + return val; + } + + /** + VIN + vin; + 行驶路线 + drivingRoute; + 经度 + longitude; + 维度 + latitude; + 速度 + speed; + 里程 + mileage; + 总电压 + voltage; + 总电流 + current; + 绝缘电阻 + resistance; + 档位 + gear; + 加速踏板行程值 + accelerationPedal; + 制动踏板行程值 + brakePedal; + 燃料消耗率 + fuelConsumptionRate; + */ + + /** + 电机控制器温度 + motorControllerTemperature; + 电机转速 + motorSpeed; + 电机转矩 + motorTorque; + 电机温度 + motorTemperature; + 电机电压 + motorVoltage; + 电机电流 + motorCurrent; + */ + + /** + 动力电池剩余电量SOC + remainingBattery; + 当前状态允许的最大反馈功率 + maximumFeedbackPower; + 当前状态允许最大放电功率 + maximumDischargePower; + BMS自检计数器 + selfCheckCounter; + 动力电池充放电电流 + totalBatteryCurrent; + 动力电池负载端总电压V3 + totalBatteryVoltage; + 单次最大电压 + singleBatteryMaxVoltage; + 单体电池最低电压 + singleBatteryMinVoltage; + 单体电池最高温度 + singleBatteryMaxTemperature; + 单体电池最低温度 + singleBatteryMinTemperature; + 动力电池可用容量 + availableBatteryCapacity; + */ + + /** + 车辆状态 + vehicleStatus; + 充电状态 + chargingStatus; + 运行状态 + operatingStatus; + SOC + socStatus; + 可充电储能装置工作状态 + chargingEnergyStorageStatus; + 驱动电机状态 + driveMotorStatus; + 定位是否有效 + positionStatus; + */ + + /** + EAS(汽车防盗系统)状态 + easStatus; + PTC(电动加热器)状态 + ptcStatus; + EPS(电动助力系统)状态 + epsStatus; + ABS(防抱死)状态 + absStatus; + MCU(电机/逆变器)状态 + mcuStatus; + */ + + /** + 动力电池加热状态 + heatingStatus; + 动力电池当前状态 + batteryStatus; + 动力电池保温状态 + batteryInsulationStatus; + DCDC(电力交换系统)状态 + dcdcStatus; + CHG(充电机)状态 + chgStatus; + */ +} diff --git a/src/main/java/com/muyu/vehicle/core/Config.java b/src/main/java/com/muyu/vehicle/core/Config.java new file mode 100644 index 0000000..d238064 --- /dev/null +++ b/src/main/java/com/muyu/vehicle/core/Config.java @@ -0,0 +1,10 @@ +package com.muyu.vehicle.core; + +/** + * @author DongZeLiang + * @version 1.0 + * @description 配置 + * @date 2023/11/9 + */ +public class Config { +} diff --git a/src/main/java/com/muyu/vehicle/model/properties/MqttProperties.java b/src/main/java/com/muyu/vehicle/model/properties/MqttProperties.java index 58daa7c..9dfc12c 100644 --- a/src/main/java/com/muyu/vehicle/model/properties/MqttProperties.java +++ b/src/main/java/com/muyu/vehicle/model/properties/MqttProperties.java @@ -43,5 +43,6 @@ public class MqttProperties { * 节点ID */ private String clientId; + private int qos = 0; } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 64ff6e1..acd1ce3 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -7,6 +7,9 @@ spring: host: 115.159.211.196 port: 6379 password: yl030509 + rabbitmq: + host: 115.159.211.196 + port: 5672 datasource: username: muyu password: 123456