From 3222b3ed2eed148d2d18e94689518701d586e644 Mon Sep 17 00:00:00 2001 From: JangCan <2862008188@qq.com> Date: Sat, 30 Mar 2024 08:29:32 +0800 Subject: [PATCH] =?UTF-8?q?demo=E8=8E=B7=E5=8F=96=E6=8A=A5=E6=96=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/resolver/domain/VehicleData.java | 172 ++++++++++++++++++ zhilian-modules/zhilian-online/pom.xml | 4 +- .../com/zhilian/ZhiLianOnLineApplication.java | 11 ++ .../src/main/java/com/zhilian/online/aa.java | 4 + zhilian-modules/zhilian-resolver/pom.xml | 7 + .../ResolverReportInfoController.java | 3 +- .../resolverReport/ResolverMqttMsg.java | 49 +++++ 7 files changed, 247 insertions(+), 3 deletions(-) create mode 100644 zhilian-common/zhilian-common-resolver/src/main/java/com/zhilian/common/resolver/domain/VehicleData.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/ZhiLianOnLineApplication.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/aa.java create mode 100644 zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/resolverReport/ResolverMqttMsg.java diff --git a/zhilian-common/zhilian-common-resolver/src/main/java/com/zhilian/common/resolver/domain/VehicleData.java b/zhilian-common/zhilian-common-resolver/src/main/java/com/zhilian/common/resolver/domain/VehicleData.java new file mode 100644 index 0000000..e1ac34b --- /dev/null +++ b/zhilian-common/zhilian-common-resolver/src/main/java/com/zhilian/common/resolver/domain/VehicleData.java @@ -0,0 +1,172 @@ +package com.zhilian.common.resolver.domain; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; + +@Data +@NoArgsConstructor +@AllArgsConstructor +@Builder +public class VehicleData { + /** + * 车辆编码 + */ + private String vin; + + /** + * 行驶路线 + */ + private String drivingRoute; + + /** + * 经度 + */ + private String latitude; + + /** + * 速度 + */ + private String speed; + + /** + * 里程 + */ + private BigDecimal 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 BigDecimal remainingBattery; + + /** + * 电池总容量 + */ + private BigDecimal batteryLevel; + + /** + * 当前状态允许的最大反馈功率 + */ + 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; + + + +} diff --git a/zhilian-modules/zhilian-online/pom.xml b/zhilian-modules/zhilian-online/pom.xml index d4c232f..41017a2 100644 --- a/zhilian-modules/zhilian-online/pom.xml +++ b/zhilian-modules/zhilian-online/pom.xml @@ -9,6 +9,8 @@ 3.6.3 + jar + zhilian-online @@ -105,4 +107,4 @@ - \ No newline at end of file + diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/ZhiLianOnLineApplication.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/ZhiLianOnLineApplication.java new file mode 100644 index 0000000..5868695 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/ZhiLianOnLineApplication.java @@ -0,0 +1,11 @@ +package com.zhilian; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class ZhiLianOnLineApplication { + public static void main(String[] args) { + SpringApplication.run(ZhiLianOnLineApplication.class); + } +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/aa.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/aa.java new file mode 100644 index 0000000..b7e6e8d --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/aa.java @@ -0,0 +1,4 @@ +package com.zhilian.online; + +public class aa { +} diff --git a/zhilian-modules/zhilian-resolver/pom.xml b/zhilian-modules/zhilian-resolver/pom.xml index 98c3836..2224898 100644 --- a/zhilian-modules/zhilian-resolver/pom.xml +++ b/zhilian-modules/zhilian-resolver/pom.xml @@ -110,6 +110,13 @@ elasticsearch-rest-high-level-client + + + org.eclipse.paho + org.eclipse.paho.client.mqttv3 + 1.2.5 + + diff --git a/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/controller/ResolverReportInfoController.java b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/controller/ResolverReportInfoController.java index 08d5c71..8c899fb 100644 --- a/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/controller/ResolverReportInfoController.java +++ b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/controller/ResolverReportInfoController.java @@ -34,7 +34,7 @@ public class ResolverReportInfoController extends BaseController { /** * @Description 查询报文列表 * @Param [report] - * @Return com.zhilian.common.core.web.controller.Result> + * @Return Result> */ @Log(title = "报文信息", businessType = BusinessType.OTHER) //// @RequiresPermissions("resolver:report:list") @@ -44,5 +44,4 @@ public class ResolverReportInfoController extends BaseController { List list = reportService.pageQuery(report); return getDataTable(list); } - } diff --git a/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/resolverReport/ResolverMqttMsg.java b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/resolverReport/ResolverMqttMsg.java new file mode 100644 index 0000000..7116cdb --- /dev/null +++ b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/resolverReport/ResolverMqttMsg.java @@ -0,0 +1,49 @@ +package com.zhilian.resolver.resolverReport; + + +import lombok.extern.slf4j.Slf4j; +import org.eclipse.paho.client.mqttv3.*; + +@Slf4j +public class ResolverMqttMsg { + private static final String BROKER_URL = "tcp://111.229.33.194:1883"; + private static final String CLIENT_ID = "mqttx_e9f5976f"; + + public static void main(String[] args) { + try { + MqttClient mqttClient = new MqttClient(BROKER_URL, CLIENT_ID); + + MqttConnectOptions options = new MqttConnectOptions(); + + options.setCleanSession(true); + mqttClient.connect(options); + + mqttClient.setCallback(new MqttCallback() { + @Override + public void connectionLost(Throwable throwable) { + log.info("连接断开"); + } + + @Override + public void messageArrived(String topic, MqttMessage message) throws Exception { + log.info("Message received from topic '{}': {}", topic, new String(message.getPayload())); + } + + @Override + public void deliveryComplete(IMqttDeliveryToken token) { + log.info("消息已成功投递：{}",token); + } + }); + + mqttClient.subscribe("cartest",1); + + Thread.sleep(1000*60*10); + + mqttClient.disconnect(); + } catch (MqttException e) { + e.printStackTrace(); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } +}