From 7034a245073f2b1c09e21885c63b7b71a8acd24a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E5=A4=A7=E4=B8=BE?= <13970129+huandgaju@user.noreply.gitee.com> Date: Thu, 4 Apr 2024 16:24:40 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E5=A4=84=E7=90=86:=E5=AE=8C?= =?UTF-8?q?=E6=88=90=E5=AD=98=E5=82=A8=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/muyu/analyze/consumer/Consumer.java | 40 +++++++++++--- .../com/muyu/analyze/domian/VehicleData.java | 12 +++- .../muyu/analyze/mapper/VehicleMapper.java | 32 +++++++++++ .../muyu/analyze/service/VehicleService.java | 21 +++++++ .../analyze/service/impl/BreakdownImpl.java | 28 ++++++++++ .../analyze/service/impl/FenceAlarmImpl.java | 29 ++++++++++ .../service/impl/RealTimeDataEventImpl.java | 29 ++++++++++ .../analyze/service/impl/StoredEventImpl.java | 55 +++++++++++++++++++ .../com/muyu/analyze/utils/AnalyzeUtils.java | 4 +- 9 files changed, 237 insertions(+), 13 deletions(-) create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/mapper/VehicleMapper.java create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/service/VehicleService.java create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/service/impl/BreakdownImpl.java create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/service/impl/FenceAlarmImpl.java create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/service/impl/RealTimeDataEventImpl.java create mode 100644 muyu-analyze/src/main/java/com/muyu/analyze/service/impl/StoredEventImpl.java diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/consumer/Consumer.java b/muyu-analyze/src/main/java/com/muyu/analyze/consumer/Consumer.java index 0f4fad8..743092b 100644 --- a/muyu-analyze/src/main/java/com/muyu/analyze/consumer/Consumer.java +++ b/muyu-analyze/src/main/java/com/muyu/analyze/consumer/Consumer.java @@ -1,13 +1,18 @@ package com.muyu.analyze.consumer; import com.muyu.analyze.domian.VehicleData; +import com.muyu.analyze.service.VehicleService; import com.muyu.analyze.utils.AnalyzeUtils; +import com.muyu.common.core.utils.SpringUtils; +import net.bytebuddy.agent.builder.AgentBuilder; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.PostMapping; -import java.math.BigDecimal; -import java.util.regex.Matcher; -import java.util.regex.Pattern; +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.List; /** * 类说明 @@ -17,14 +22,31 @@ import java.util.regex.Pattern; */ @Component public class Consumer { - @KafkaListener(topics="test", groupId = "group",properties = {"bootstrap.servers=10.10.26.5:9092"}) - public void getMessage(String message) { - - VehicleData analyze = AnalyzeUtils.analyze(message); - System.out.println("kafka 消费者监听，接收到消息:" + analyze); - } + List list = new ArrayList<>(); + + { + list.add("storedEvent"); + list.add("realTimeDataEvent"); + list.add("breakdown"); + list.add("fenceAlarm"); + } + + + @KafkaListener(topics = "test", groupId = "group", properties = {"bootstrap.servers = 10.10.26.5:9092"}) + @PostMapping("/msg") + public void getMessage(String msg) { + VehicleData analyze = AnalyzeUtils.analyze(msg); + for (String s : list) { + VehicleService vehicleService = SpringUtils.getBean(s); + vehicleService.eventResolution(analyze); + } + + } + + + diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/domian/VehicleData.java b/muyu-analyze/src/main/java/com/muyu/analyze/domian/VehicleData.java index c40181c..6bff468 100644 --- a/muyu-analyze/src/main/java/com/muyu/analyze/domian/VehicleData.java +++ b/muyu-analyze/src/main/java/com/muyu/analyze/domian/VehicleData.java @@ -2,6 +2,10 @@ package com.muyu.analyze.domian; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.web.domain.BaseEntity; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; @@ -20,7 +24,11 @@ import java.math.BigDecimal; @Builder @NoArgsConstructor @AllArgsConstructor -public class VehicleData { +public class VehicleData{ + + + + private Long id; /** * VIN */ @@ -123,7 +131,7 @@ public class VehicleData { /** * 动力电池剩余电量SOC */ - private BigDecimal remainingBattery; + private String remainingBattery; /** * 电池总容量 diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/mapper/VehicleMapper.java b/muyu-analyze/src/main/java/com/muyu/analyze/mapper/VehicleMapper.java new file mode 100644 index 0000000..d7b457b --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/mapper/VehicleMapper.java @@ -0,0 +1,32 @@ +package com.muyu.analyze.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.analyze.domian.VehicleData; +import org.apache.ibatis.annotations.Mapper; + +import java.util.ArrayList; +import java.util.List; + +/** + * @ProjectName: cloud-vehicles + * @PackageName: com.muyu.analyze.mapper + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 09:48 + * @Version 1.0 + */ +@Mapper +public interface VehicleMapper{ + Boolean addVehicleStoredEvent(ArrayList list); + + + + +// void addVehicleStoredEvent(VehicleData analyze); + + +// void addVehicleStoredEvent1(ArrayList list); + + + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/service/VehicleService.java b/muyu-analyze/src/main/java/com/muyu/analyze/service/VehicleService.java new file mode 100644 index 0000000..4e199f5 --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/service/VehicleService.java @@ -0,0 +1,21 @@ +package com.muyu.analyze.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.analyze.domian.VehicleData; + +/** + * @ProjectName: cloud-vehicles + * @PackageName: com.muyu.analyze.service + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 09:30 + * @Version 1.0 + */ +public interface VehicleService { + + void eventResolution(VehicleData analyze); + + + + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/BreakdownImpl.java b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/BreakdownImpl.java new file mode 100644 index 0000000..5f2535f --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/BreakdownImpl.java @@ -0,0 +1,28 @@ +package com.muyu.analyze.service.impl; + +import com.muyu.analyze.domian.VehicleData; +import com.muyu.analyze.service.VehicleService; +import org.springframework.stereotype.Service; + +/** + * @ProjectName: cloud-vehicles + * @PackageName: com.muyu.analyze.service.impl.historicalTrack + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 09:36 + * @Version 1.0 + */ +@Service("breakdown") +public class BreakdownImpl implements VehicleService{ + + + + @Override + public void eventResolution(VehicleData analyze) { + System.out.println("我是故障报警"); + } + + + + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/FenceAlarmImpl.java b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/FenceAlarmImpl.java new file mode 100644 index 0000000..fc5513e --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/FenceAlarmImpl.java @@ -0,0 +1,29 @@ +package com.muyu.analyze.service.impl; + +import com.muyu.analyze.domian.VehicleData; +import com.muyu.analyze.service.VehicleService; +import org.springframework.stereotype.Service; + +/** + * @ProjectName: cloud-vehicles + * @PackageName: com.muyu.analyze.service.impl + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 16:02 + * @Version 1.0 + */ +@Service("fenceAlarm") +public class FenceAlarmImpl implements VehicleService { + + @Override + public void eventResolution(VehicleData analyze) { + + System.out.println("电子围栏报警事件开启"); + } + + + + + + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/RealTimeDataEventImpl.java b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/RealTimeDataEventImpl.java new file mode 100644 index 0000000..ec8f282 --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/RealTimeDataEventImpl.java @@ -0,0 +1,29 @@ +package com.muyu.analyze.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.analyze.domian.VehicleData; +import com.muyu.analyze.mapper.VehicleMapper; +import com.muyu.analyze.service.VehicleService; +import org.springframework.stereotype.Service; + +/** + * @ProjectName: cloud-vehicles + * @PackageName: com.muyu.analyze.service.impl.realTimeDataEvent + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 09:35 + * @Version 1.0 + */ +@Service("realTimeDataEvent") +public class RealTimeDataEventImpl implements VehicleService { + + @Override + public void eventResolution(VehicleData analyze) { + System.out.println("我是实时数据"); + System.out.println(analyze); + + + + } + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/StoredEventImpl.java b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/StoredEventImpl.java new file mode 100644 index 0000000..980b37d --- /dev/null +++ b/muyu-analyze/src/main/java/com/muyu/analyze/service/impl/StoredEventImpl.java @@ -0,0 +1,55 @@ +package com.muyu.analyze.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.analyze.domian.VehicleData; +import com.muyu.analyze.mapper.VehicleMapper; +import com.muyu.analyze.service.VehicleService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Service; + +import java.math.BigDecimal; +import java.util.ArrayList; +import java.util.List; + +/** + * @ProjectName: cloud-vehicles 事件存储 + * @PackageName: com.muyu.analyze.service + * @Description TODO + * @Author HuangDaJu + * @Date 2024/4/4 09:30 + * @Version 1.0 + */ +@Service("storedEvent") +@Slf4j +public class StoredEventImpl implements VehicleService { + + private final ArrayList list = new ArrayList<>(); + + @Autowired + private VehicleMapper vehicleMapper; + @Override + public void eventResolution(VehicleData analyze) { + + + list.add(analyze); + if (list.size() >= 50) { + log.info("集合满50,存储事件开始"); + Boolean i= vehicleMapper.addVehicleStoredEvent(list); + + if (i) { + list.clear(); + log.info("存储事件结束"); + + } + + } + + + + } + + + +} diff --git a/muyu-analyze/src/main/java/com/muyu/analyze/utils/AnalyzeUtils.java b/muyu-analyze/src/main/java/com/muyu/analyze/utils/AnalyzeUtils.java index e0a9102..c54979f 100644 --- a/muyu-analyze/src/main/java/com/muyu/analyze/utils/AnalyzeUtils.java +++ b/muyu-analyze/src/main/java/com/muyu/analyze/utils/AnalyzeUtils.java @@ -165,7 +165,7 @@ public class AnalyzeUtils { */ String remainingBattery = aa.substring(132, 138); - vehicleData.setRemainingBattery(new BigDecimal(remainingBattery)); + vehicleData.setRemainingBattery(remainingBattery); // 当前状态允许的最大反馈功率: 400000 @@ -312,7 +312,7 @@ public class AnalyzeUtils { // CHG: 1 String chgStatus = aa.substring(205, 206); vehicleData.setChgStatus(Integer.parseInt(chgStatus)); - System.out.println(vehicleData); + return vehicleData; } }