six-vehicle
/
cloud-server
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():修改缓存实现类结构， 

手动测试添加redis缓存数据（
CarMessageValueCacheService报文数据=》key(报文模版id（templateId）)，value(查询到的数据集合List);
CarVehicleCacheService车辆信息=》key(VehicleVin车辆VIN码)，value(Vehicle车辆实体类数据);
CarVehicleTypeCacheService车辆类型=》key(VehicleTypeId车辆类型ID)，value(查询到的集合List)
）。
之后连接MQTT接收到车辆模拟传过来的数据--》查询redis--》解析数据--》传递kafka
dev.analysis
LQS 2024-10-09 16:19:28 +08:00
parent ff31f5abc9
commit f0f6cf006f
34 changed files with 514 additions and 251 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
JavaSample-tcp1061513671883/.lck 100644
View File

2
cloud-common/cloud-common-cache/pom.xml
View File

@ -12,7 +12,7 @@
<artifactId>cloud-common-cache</artifactId>
<description>
cloud-common-cache redis缓存架构
cloud-common-cache 缓存基准模块
</description>
<dependencies>

31
cloud-common/cloud-common-cache/src/main/java/com/muyu/common/cache/config/CacheAbsBasic.java vendored
View File

@ -12,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;
public abstract class CacheAbsBasic<K,V> implements CacheBasic<K,V> {
@ -21,16 +22,44 @@ public abstract class CacheAbsBasic<K,V> implements CacheBasic<K,V> {
@Override
public void put(K key, V value) {
redisService.setCacheObject(encode(key),value);
try {
redisService.setCacheObject(encode(key), value,30L, TimeUnit.MINUTES);
} catch (Exception e) {
throw new RuntimeException("运行时异常，异常信息为：{}"+e.getMessage());
}
}
@Override
public V get(K key) {
try {
return redisService.getCacheObject(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常，异常信息为：{}"+e.getMessage());
}
}
@Override
public void remove(K key) {
try {
redisService.deleteObject(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常，异常信息为：{}"+e.getMessage());
}
}
@Override
public boolean hashKey(K key){
Boolean b = false;
try {
b = redisService.hasKey(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常，异常信息为：{}"+e.getMessage());
}
return b;
}
}

1
cloud-common/cloud-common-cache/src/main/java/com/muyu/common/cache/config/CacheBasic.java vendored
View File

@ -18,5 +18,6 @@ public interface CacheBasic<K,V> extends PrimaryKeyBasic<K>{
void remove(K key);
boolean hashKey(K key);
}

20
cloud-common/cloud-common-cache/src/main/java/com/muyu/common/cache/config/PrimaryKeyBasic.java vendored
View File

@ -9,26 +9,28 @@ package com.muyu.common.cache.config;
*/
public interface PrimaryKeyBasic <K>{
/**
* key 前缀
* 主键前缀
* @return
*/
public String keyPre();
/**
* 编码
* @param key 缓存键
* @return 装修键
* 主键编码
* @param key 缓存建
* @return 装修建
*/
public default String encode(K key){
return keyPre() + key.toString();
}
/**
* 解码 Key
* @param key 解码后的key
* @return
* 主键解码
* @param key 缓存建
* @return 装修建
*/
public K decode(String key);
public default K decode(String key) {
return (K) key.substring(keyPre().length());
}

7
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/pom.xml
View File

@ -18,17 +18,16 @@
</properties>
<description>
cloud-modules-enterprise-cache redis 缓存平台
cloud-modules-enterprise-cache redis 缓存基准服务
</description>
<dependencies>
<!-- cache缓存基准模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-cache</artifactId>
</dependency>
<!-- 企业业务平台服务 - 公共依赖 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-common</artifactId>

28
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarManageCacheService.java vendored
View File

@ -1,28 +0,0 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarManage;
/**
* redis报文业务层
* @ClassName CarManageCacheService
* @Description CarManageCacheService:类的描述
* @Date 2024/10/3 15:22
* @author MingWei.Zong
*/
public class CarManageCacheService extends CacheAbsBasic<String, CarManage> {
@Override
public String keyPre() {
return "carManage:info:";
}
@Override
public String decode(String key) {
return key.replace("carManage:info:","");
}
}

30
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarMessageCacheService.java vendored
View File

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

43
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarMessageValueCacheService.java vendored 100644
View File

@ -0,0 +1,43 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.CarTemplate;
import com.muyu.enterprise.domain.car.MessageValue;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import java.util.List;
/**
* 报文类型缓存---实现类
*
*
* @ClassName CarTemplateCacheService
* @Description CarTemplateCacheService:类的描述
* @Date 2024/10/3 15:22
* @author MingWei.Zong
*/
public class CarMessageValueCacheService extends CacheAbsBasic<String,List<MessageValueListResp>> {
/**
* 前缀
* @return
*/
@Override
public String keyPre()
{
return "messageValue:info";
}
@Override
public String encode(String key)
{
return super.encode(key);
}
@Override
public String decode(String key)
{
return key.replace("messageValue:info:","");
}
}

29
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarTemplateCacheService.java vendored
View File

@ -1,29 +0,0 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.CarTemplate;
/**
* redis报文模版业务层
* @ClassName CarTemplateCacheService
* @Description CarTemplateCacheService:类的描述
* @Date 2024/10/3 15:22
* @author MingWei.Zong
*/
public class CarTemplateCacheService extends CacheAbsBasic<String, CarTemplate> {
@Override
public String keyPre() {
return "carTemplate:info:";
}
@Override
public String decode(String key) {
return key.replace("carTemplate:info:","");
}
}

32
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarVehicleCacheService.java vendored 100644
View File

@ -0,0 +1,32 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.car.Vehicle;
/**
* 车辆管理---实现类
*
*
* @ClassName CarMessageCacheService
* @Description CarMessageCacheService:类的描述
* @Date 2024/9/30 11:42
* @author MingWei.Zong
*/
public class CarVehicleCacheService extends CacheAbsBasic<String, Vehicle> {
@Override
public String keyPre(){
return "sysCar:info";
}
@Override
public String encode(String key){
return super.encode(key);
}
@Override
public String decode(String key){
return super.decode(key);
}
}

37
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/CarVehicleTypeCacheService.java vendored 100644
View File

@ -0,0 +1,37 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.config.CacheAbsBasic;
import com.muyu.enterprise.domain.CarManage;
import com.muyu.enterprise.domain.car.VehicleType;
/**
* 车辆类型的缓存---实现类
*
*
* @ClassName CarManageCacheService
* @Description CarManageCacheService:类的描述
* @Date 2024/10/3 15:22
* @author MingWei.Zong
*/
public class CarVehicleTypeCacheService extends CacheAbsBasic<String, VehicleType> {
@Override
public String keyPre()
{
return "sysCarType:info";
}
@Override
public String encode(String key)
{
return super.encode(key);
}
@Override
public String decode(String key)
{
return super.decode(key);
}
}

6
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@ -1,7 +1,7 @@
com.muyu.enterprise.cache.CarCompanyCacheService
com.muyu.enterprise.cache.CarFaultCacheService
com.muyu.enterprise.cache.CarManageCacheService
com.muyu.enterprise.cache.CarMessageCacheService
com.muyu.enterprise.cache.CarTemplateCacheService
com.muyu.enterprise.cache.CarVehicleTypeCacheService
com.muyu.enterprise.cache.CarVehicleCacheService
com.muyu.enterprise.cache.CarMessageValueCacheService
com.muyu.enterprise.cache.CarWarnCacheService
com.muyu.enterprise.cache.ElectronicFenceCacheService

1
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-remote/src/main/java/com/muyu/enterprise/remote/RemoteMessageValueService.java
View File

@ -12,6 +12,7 @@ import java.util.List;
/**
* 报文数据服务
*
* @Author：李庆帅
* @Package：com.muyu.analysis.parsing.feign
* @Project：cloud-server

2
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

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

28
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/CarManageController.java
View File

@ -3,8 +3,10 @@ package com.muyu.enterprise.controller;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.RandomUtil;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
import com.muyu.enterprise.domain.CarManage;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.domain.dto.CarDTO;
import com.muyu.enterprise.domain.vo.CarVO;
import com.muyu.enterprise.service.CarCompanyService;
@ -15,6 +17,7 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.utils.SecurityUtils;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@ -35,7 +38,7 @@ import java.util.List;
@Tag(name = "CarManageController", description = "车辆管理")
public class CarManageController extends BaseController {
private final CarManageCacheService carManageCacheService;
private final CarVehicleTypeCacheService carManageCacheService;
private final CarCompanyService sysCarCompanyService;
@ -116,6 +119,27 @@ public class CarManageController extends BaseController {
sysCarService.removeBatchByIds(ids);
return Result.success("车辆删除成功");
}
/**
* 导出所有车辆数据
* @param response 请求对象
*/
@PostMapping("/export")
public void export(HttpServletResponse response) {
List<CarManage> list = sysCarService.list();
ExcelUtil<CarManage> util = new ExcelUtil<>(CarManage.class);
util.exportExcel(response, list, "车辆数据");
}
/**
* 通过车辆vin码查询模板id
* @param carManageVin 请求对象
* @return 返回结果
*/
@GetMapping("/findByCarManageVin/{carManageVin}")
@Operation(description = "通过车辆vin码查询模板id")
public Result<Long> findByCarManageVin(@PathVariable("vehicleVin") String carManageVin) {
Long byCarManageVin = sysCarService.findByCarManageVin(carManageVin);
return Result.success(byCarManageVin);
}
}

9
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/CarMessageController.java
View File

@ -3,9 +3,10 @@ package com.muyu.enterprise.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.enterprise.cache.CarMessageCacheService;
import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
import com.muyu.enterprise.cache.CarVehicleCacheService;
import com.muyu.enterprise.domain.CarMessage;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.service.CarMessageService;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
@ -28,7 +29,7 @@ import java.util.List;
@Tag(name = "报文",description = "报文模块")
public class CarMessageController extends BaseController {
private final CarMessageCacheService carMessageCacheService;
private final CarVehicleCacheService carMessageCacheService;
private final CarMessageService sysCarMessageService;
@Autowired
private CarMessageService carMessageService;
@ -70,7 +71,7 @@ public class CarMessageController extends BaseController {
public Result insertMessage(@RequestBody CarMessage carMessage){
sysCarMessageService.save(carMessage);
//报文 redis
carMessageCacheService.put(carMessage.getMessageType(),new CarMessage());
carMessageCacheService.put(carMessage.getMessageType(),new Vehicle());
return Result.success("添加成功");
}
/**

14
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/car/MessageValueController.java
View File

@ -4,6 +4,7 @@ package com.muyu.enterprise.controller.car;
import cn.hutool.json.JSONObject;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.cache.CarMessageValueCacheService;
import com.muyu.enterprise.domain.car.MessageValue;
import com.muyu.enterprise.domain.req.car.MessageValueAddReq;
import com.muyu.enterprise.domain.req.car.MessageValueReq;
@ -37,18 +38,22 @@ public class MessageValueController extends BaseController
@Autowired
private MessageValueService messageValueService;
@Autowired
private CarMessageValueCacheService carMessageValueCacheService;
/**
* 报文数据列表查询
* 报文数据条件查询
* @param messageValueReq 请求对象
* @return 返回结果
*/
@RequestMapping(value = "/list", method = RequestMethod.POST)
@Operation(summary = "报文数据列表", description = "根据报文类别, 报文模版筛选报文数据")
@Operation(summary = "报文数据条件查询", description = "根据报文类别, 报文模版筛选报文数据")
public Result<List<MessageValueListResp>> findAll(@RequestBody MessageValueReq messageValueReq) {
List<MessageValueListResp> list = messageValueService.findAll(messageValueReq);
return Result.success(list);
}
/**
* 提供预警和故障使用
* @return 返回结果
@ -111,6 +116,11 @@ public class MessageValueController extends BaseController
@Operation(summary = "根据报文模版id查询报文数据", description = "根据报文模版id查询报文数据")
public Result<List<MessageValueListResp>> findByTemplateId(@PathVariable("templateId") Long templateId){
List<MessageValueListResp> list = messageValueService.findByTemplateId(templateId);
//存入缓存中com.muyu.enterprise.cache.CarMessageValueCacheService
carMessageValueCacheService.put(
String.valueOf(
templateId
), list);
return Result.success(list);
}

9
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/car/VehicleController.java
View File

@ -7,6 +7,7 @@ import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.log.annotation.Log;
import com.muyu.enterprise.cache.CarVehicleCacheService;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.domain.req.car.VehicleAddReq;
import com.muyu.enterprise.domain.req.car.VehicleManageReq;
@ -41,6 +42,9 @@ public class VehicleController extends BaseController
@Autowired
private VehicleService vehicleService;
@Autowired
private CarVehicleCacheService carVehicleCacheService;
/**
* 查询车辆管理列表
* @param vehicleManageReq 请求对象
@ -74,7 +78,10 @@ public class VehicleController extends BaseController
@GetMapping("/{vehicleId}")
@Operation(summary = "通过id查询车辆信息", description = "通过id查询车辆信息")
public Result<Vehicle> findById(@PathVariable("vehicleId") Long vehicleId) {
return Result.success(vehicleService.getById(vehicleId));
Vehicle byId = vehicleService.getById(vehicleId);
//存入缓存中com.muyu.enterprise.cache.carVehicleCacheService
carVehicleCacheService.put(String.valueOf(byId.getVehicleVin()), byId);
return Result.success(byId);
}
/**

13
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/controller/car/VehicleTypeController.java
View File

@ -3,6 +3,7 @@ package com.muyu.enterprise.controller.car;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
import com.muyu.enterprise.domain.car.VehicleType;
import com.muyu.enterprise.service.car.VehicleTypeService;
import io.swagger.v3.oas.annotations.Operation;
@ -33,14 +34,22 @@ public class VehicleTypeController extends BaseController
@Autowired
private VehicleTypeService vehicleTypeService;
@Autowired
private CarVehicleTypeCacheService carVehicleTypeCacheService;
/**
* 车辆类型查询
* @return 返回结果
*/
@RequestMapping(path = "/", method = RequestMethod.POST)
@RequestMapping(value = "/findAll", method = RequestMethod.POST)
@Operation(summary = "车辆类型列表",description = "车辆类型列表")
public Result<List<VehicleType>> findAll(){
return Result.success(vehicleTypeService.list());
List<VehicleType> list = vehicleTypeService.list();
for (VehicleType vehicleType : list) {
//存入缓存中com.muyu.enterprise.cache.CarVehicleTypeCacheService
carVehicleTypeCacheService.put(String.valueOf(vehicleType.getVehicleTypeId()),vehicleType);
}
return Result.success();
}

9
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/mapper/CarManageMapper.java
View File

@ -9,6 +9,7 @@ import com.muyu.enterprise.domain.dto.CarDTO;
import com.muyu.enterprise.domain.vo.CarVO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.util.List;
@ -21,5 +22,11 @@ import java.util.List;
*/
@Mapper
public interface CarManageMapper extends MPJBaseMapper<CarManage> {
/**
* 通过车辆vin码查询模板id
* @param carManageVin 请求对象
* @return 返回结果
*/
@Select("SELECT t.template_id FROM car_manage v LEFT JOIN car_type t ON v.car_type_id = t.car_type_id WHERE v.car_vin = #{carManageVin}")
Long findByCarManageVin(String carManageVin);
}

8
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/CarManageService.java
View File

@ -34,4 +34,12 @@ public interface CarManageService extends IService<CarManage> {
* @return
*/
void insertCar(CarManage carVO);
/**
* 通过车辆vin码查询模板id
* @param carManageVin 请求对象
* @return 返回结果
*/
Long findByCarManageVin(String carManageVin);
}

24
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/CarManageServiceImpl.java
View File

@ -3,20 +3,17 @@ package com.muyu.enterprise.service.impl;
import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.enterprise.controller.CarCompanyController;
import com.muyu.enterprise.cache.CarVehicleCacheService;
import com.muyu.enterprise.domain.CarCompany;
import com.muyu.enterprise.domain.CarConfig;
import com.muyu.enterprise.domain.CarManage;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.domain.dto.CarDTO;
import com.muyu.enterprise.domain.vo.CarVO;
import com.muyu.enterprise.mapper.CarManageMapper;
import com.muyu.enterprise.service.CarCompanyService;
import com.muyu.enterprise.service.CarConfigService;
import com.muyu.enterprise.service.CarManageService;
import com.muyu.common.redis.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -40,7 +37,7 @@ public class CarManageServiceImpl extends ServiceImpl<CarManageMapper, CarManage
@Autowired
private CarConfigService carConfigService;
@Autowired
private CarManageCacheService carManageCacheService;
private CarVehicleCacheService carManageCacheService;
@Autowired
private CarManageMapper carManageMapper;
@ -75,7 +72,7 @@ public class CarManageServiceImpl extends ServiceImpl<CarManageMapper, CarManage
CarCompany carCompany = carCompanyService.selectCompanyByCompanyId(carVO.getEnterpriseId());
carVO.setCompanyName(carCompany.getCompanyName());
// 存到 redis
carManageCacheService.put(carVO.getCarVin(),new CarManage());
carManageCacheService.put(carVO.getCarVin(),new Vehicle());
});
@ -107,8 +104,17 @@ public class CarManageServiceImpl extends ServiceImpl<CarManageMapper, CarManage
public void insertCar(CarManage carVO) {
save(carVO);
// 存到缓存中去
carManageCacheService.put(carVO.getCarVin(),new CarManage());
carManageCacheService.put(carVO.getCarVin(),new Vehicle());
}
/**
* 通过车辆vin码查询模板id
* @param carManageVin 请求对象
* @return 返回结果
*/
@Override
public Long findByCarManageVin(String carManageVin) {
Long templateId = carManageMapper.findByCarManageVin(carManageVin);
return templateId;
}
}

3
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/carImpl/MessageTemplateServiceImpl.java
View File

@ -9,12 +9,13 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
/**
* 报文类型业务实现层
* @Author：李庆帅
* @Package：com.muyu.car.service.impl
* @Project：cloud-server
* @name：MessageTemplateServiceImpl
* @Date：2024/9/26 22:31
* @Description: 报文类型业务层
* @Description:
*/
@Log4j2
@Service

4
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/carImpl/MessageValueServiceImpl.java
View File

@ -5,6 +5,7 @@ import cn.hutool.json.JSONObject;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.enterprise.cache.CarMessageValueCacheService;
import com.muyu.enterprise.domain.car.MessageValue;
import com.muyu.enterprise.domain.req.car.MessageValueReq;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
@ -22,6 +23,7 @@ import java.util.List;
import java.util.Map;
/**
* 报文数据业务实现层
* @Author：李庆帅
* @Package：com.muyu.car.service.impl
* @Project：cloud-server
@ -45,6 +47,8 @@ extends ServiceImpl<MessageValueMapper,
*/
@Resource
private RedisTemplate<String, Object> redisTemplate;
@Autowired
private CarMessageValueCacheService carMessageValueCacheService;
public MessageValueServiceImpl(MessageValueMapper messageValueMapper) {

3
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/carImpl/VehicleServiceImpl.java
View File

@ -16,12 +16,13 @@ import org.springframework.stereotype.Service;
import java.util.List;
/**
* 车辆管理业务实现层
* @Author：李庆帅
* @Package：com.muyu.car.service.impl
* @Project：cloud-server
* @name：VehicleServiceImpl
* @Date：2024/9/26 22:35
* @Description: 车辆管理业务层
* @Description:
*/
@Log4j2
@Service

3
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/carImpl/VehicleTypeServiceImpl.java
View File

@ -8,12 +8,13 @@ import lombok.extern.log4j.Log4j2;
import org.springframework.stereotype.Service;
/**
* 车辆类型业务实现层
* @Author：李庆帅
* @Package：com.muyu.car.service.impl
* @Project：cloud-server
* @name：VehicleTypeServiceImpl
* @Date：2024/9/26 22:36
* @Description: 车辆类型实现层
* @Description:
*/
@Log4j2
@Service

1
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/resources/mapper/car/CarManageMapper.xml
View File

@ -5,4 +5,5 @@
<mapper namespace="com.muyu.enterprise.mapper.CarManageMapper">
</mapper>

4
cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOnlineConsumer.java
View File

@ -1,7 +1,7 @@
package com.muyu.event.process.consumer;
import com.muyu.enterprise.cache.CarFaultCacheService;
import com.muyu.enterprise.cache.CarManageCacheService;
import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
import com.muyu.enterprise.cache.CarWarnCacheService;
import com.muyu.enterprise.cache.ElectronicFenceCacheService;
import com.muyu.event.process.constant.CacheHandlerConstants;
@ -35,7 +35,7 @@ public class GoOnlineConsumer {
/**
* 车辆管理缓存服务
*/
private final CarManageCacheService carManageCacheService;
private final CarVehicleTypeCacheService carManageCacheService;
/**
* 车辆故障缓存服务

17
cloud-modules/cloud-modules-protocol-analysis/pom.xml
View File

@ -22,8 +22,6 @@
</description>
<dependencies>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
@ -89,41 +87,56 @@
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-common</artifactId>
</dependency>
<!-- mybatis-plus-join依赖 -->
<dependency>
<groupId>com.github.yulichang</groupId>
<artifactId>mybatis-plus-join</artifactId>
</dependency>
<!-- 核心模块 - 公共依赖 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<!-- kafka依赖 - 公共依赖 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
</dependency>
<!-- mqtt消息队列遥测传输协议服务 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-mqtt</artifactId>
</dependency>
<!-- Spring Boot的缓存启动器 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<!-- 高性能的Java缓存库缓存解决方案 -->
<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
</dependency>
<!-- 企业远程模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-remote</artifactId>
</dependency>
<!-- 缓存基准服务 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-cache</artifactId>
</dependency>
</dependencies>
<build>

1
cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/ProtocolAnalysisApplication.java
View File

@ -4,6 +4,7 @@ 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.cloud.openfeign.EnableFeignClients;
/**
* 协议解析启动类

200
cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/AnalysisMQTT.java 100644
View File

@ -0,0 +1,200 @@
//package com.muyu.analysis.parsing.mqtt;
//
//import com.muyu.common.mqtt.MQTTConnect;
//import com.muyu.enterprise.cache.CarMessageValueCacheService;
//import com.muyu.enterprise.cache.CarVehicleCacheService;
//import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
//import com.muyu.enterprise.domain.car.MessageValue;
//import com.muyu.enterprise.domain.car.Vehicle;
//import com.muyu.enterprise.domain.car.VehicleType;
//import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
//import com.muyu.enterprise.remote.RemoteMessageValueService;
//import com.muyu.enterprise.remote.RemoteVehicleService;
//import jakarta.annotation.PostConstruct;
//import jakarta.annotation.Resource;
//import cn.hutool.json.JSONObject;
//import lombok.extern.log4j.Log4j2;
//import org.apache.kafka.clients.producer.KafkaProducer;
//import org.apache.kafka.clients.producer.ProducerRecord;
//import org.eclipse.paho.client.mqttv3.*;
//import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.List;
//
///**
// * 协议解析处理数据发送传送到队列
// * @Author：李庆帅
// * @Package：com.muyu.analysis.parsing.mqtt
// * @Project：cloud-server
// * @name：AnalysisMQTT
// * @Date：2024/10/8 20:52
// */
//@Log4j2
//@Component
//public class AnalysisMQTT {
//
// private final static String topic = "sysCar_vin_topic";
//
// @Resource
// private RedisTemplate<String, Object> redisTemplate;
//
// @Resource
// private KafkaProducer<String, String> kafkaProducer;
//
// @Resource
// private RemoteVehicleService remoteVehicleService;
//
// @Resource
// private RemoteMessageValueService remoteMessageValueService;
//
// //车辆信息
// @Resource
// private CarVehicleCacheService vehicleCacheService;
//
// //车辆类型信息
// @Resource
// private CarVehicleTypeCacheService vehicleTypeCacheService;
//
// //报文模版信息
// @Resource
// private CarMessageValueCacheService allMessageValueCacheService;
//
//
// // MQTT主题
// private static final String TOPIC = "vehicle";
// // MQTT Broker地址
// private static final String BROKER = "tcp://106.15.136.7:1883";
// // MQTT客户端ID
// private static final String CLIENT_ID = "JavaSample";
// // MQTT客户端
// private MqttClient mqttClient;
//
// /**
// * MQTT连接选项
// */
// public AnalysisMQTT(CarVehicleCacheService vehicleCacheService, CarVehicleTypeCacheService vehicleTypeCacheService, CarMessageValueCacheService allMessageValueCacheService) {
// this.vehicleCacheService = vehicleCacheService;
// this.vehicleTypeCacheService = vehicleTypeCacheService;
// this.allMessageValueCacheService = allMessageValueCacheService;
// }
//
// /**
// * 初始化MQTT连接
// */
// @PostConstruct
// public void init() {
// connectToMqttBroker();
// }
//
// /**
// * 连接MQTT Broker
// */
// private void connectToMqttBroker() {
// try {
// mqttClient = new MqttClient(BROKER, CLIENT_ID, new MemoryPersistence());
// MqttConnectOptions connOpts = new MqttConnectOptions();
// connOpts.setCleanSession(true);
// log.info("连接到协议: " + BROKER);
// mqttClient.connect(connOpts);
// mqttClient.subscribe(TOPIC, 0);
// mqttClient.setCallback(new MqttCallbackHandler());
// } catch (MqttException me) {
// log.error("连接MQTT Broker失败: [{}]", me.getMessage());
// }
// }
//
// /**
// * MQTT回调处理器
// */
// private class MqttCallbackHandler implements MqttCallback {
//
// // 连接丢失
// @Override
// public void connectionLost(Throwable throwable) {
// log.error("连接丢失: [{}]", throwable.getMessage());
// }
//
// // 连接成功
// @Override
// public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
// handleMqttMessage(mqttMessage);
// }
//
//
// // 接收信息
// @Override
// public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
//
// }
// }
//
// /**
// * 处理MQTT消息
// *
// * @param mqttMessage
// */
// private void handleMqttMessage(MqttMessage mqttMessage) {
// // 解析MQTT消息
// String messageStr = new String(mqttMessage.getPayload());
// log.info("接收到MQTT消息: " + messageStr);
// // 解析协议
// JSONObject parseMessage = parseProtocol(messageStr);
// // 发送Kafka消息
// sendKafkaMessage(parseMessage);
// }
//
// /**
// * 解析协议
// *
// * @param messageStr
// * @return
// */
// private JSONObject parseProtocol(String messageStr) {
// String[] hexArray = messageStr.split(" ");
// // 遍历十六进制数据转换为字符
// StringBuilder stringBuilder = new StringBuilder();
// for (String hex : hexArray) {
// int decimal = Integer.parseInt(hex, 16);
// stringBuilder.append((char) decimal);
// }
// // 取出车辆VIN码
// String vehicleVin = stringBuilder.substring(1, 18);
// log.info("车辆VIN码: {}", vehicleVin);
// // 根据车辆VIN码查询车辆信息
// Vehicle vehicle = vehicleCacheService.get(vehicleVin);
// VehicleType vehicleType = vehicleTypeCacheService.get(String.valueOf(vehicle.getVehicleTypeId()));
// Long templateId = vehicleType.getMessageTemplateId();
// List<MessageValueListResp> templateList = allMessageValueCacheService.get(String.valueOf(templateId));
// // 判断报文模板列表不为空
// if (templateList.isEmpty()) {
// throw new RuntimeException("报文模版为空");
// }
// // 存储报文模版解析后的数据
// JSONObject jsonObject = new JSONObject();
// for (MessageValueListResp messageValue : templateList) {
// // 起始位下标
// Integer startIndex = messageValue.getMessageStartIndex() - 1;
// // 结束位下标
// Integer endIndex = messageValue.getMessageEndIndex();
// // 根据报文模版截取数据
// String value = stringBuilder.substring(startIndex, endIndex);
// // 存入数据
// jsonObject.put(messageValue.getMessageLabel(), value);
// }
// return jsonObject;
// }
//
// /**
// * 发送Kafka消息
// * @param parseMessage
// */
// private void sendKafkaMessage(JSONObject parseMessage) {
// ProducerRecord<String, String> producerRecord = new ProducerRecord<>("zeshi", parseMessage.toString());
// kafkaProducer.send(producerRecord);
// log.info("发送Kafka消息: " + parseMessage);
// }
//
//
//}

52
cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java
View File

@ -4,6 +4,11 @@ import com.muyu.common.core.constant.KafkaConstants;
import com.muyu.common.core.constant.RedisConstants;
import com.muyu.common.core.domain.Result;
import com.muyu.common.mqtt.MQTTConnect;
import com.muyu.enterprise.cache.CarMessageValueCacheService;
import com.muyu.enterprise.cache.CarVehicleCacheService;
import com.muyu.enterprise.cache.CarVehicleTypeCacheService;
import com.muyu.enterprise.domain.car.Vehicle;
import com.muyu.enterprise.domain.car.VehicleType;
import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
import com.muyu.enterprise.remote.RemoteMessageValueService;
import com.muyu.enterprise.remote.RemoteVehicleService;
@ -32,6 +37,9 @@ import java.util.List;
@Component
public class ParsingMQTT {
private final static String topic = "sysCar_vin_topic";
@Resource
private RedisTemplate<String, Object> redisTemplate;
@ -44,6 +52,18 @@ public class ParsingMQTT {
@Resource
private RemoteMessageValueService remoteMessageValueService;
//车辆信息
@Resource
private CarVehicleCacheService vehicleCacheService;
//车辆类型信息
@Resource
private CarVehicleTypeCacheService vehicleTypeCacheService;
//报文模版信息
@Resource
private CarMessageValueCacheService allMessageValueCacheService;
/**
* 协议解析
*/
@ -99,33 +119,11 @@ public class ParsingMQTT {
String vehicleVin = result.substring(1, 18);
log.info("车辆VIN码: " + vehicleVin);
//根据车辆VIN码查询报文模板ID
Result<Long> byVehicleVin = remoteVehicleService.findByVehicleVin(vehicleVin);
Long templateId = byVehicleVin.getData();
List<MessageValueListResp> templateList;
//从redis缓存中获取报文模板数据
try {
String redisKey = RedisConstants.MESSAGE_TEMPLATE + templateId;
if (redisTemplate.hasKey(redisKey)) {
List<Object> list = redisTemplate.opsForList().range(redisKey, 0, -1);
templateList = list.stream()
.map(obj -> JSON.parseObject(obj.toString(), MessageValueListResp.class))
.toList();
log.info("Redis缓存查询成功");
} else {
Result<List<MessageValueListResp>> byTemplateId = remoteMessageValueService.findByTemplateId(templateId);
templateList = byTemplateId.getData();
templateList.forEach(
listResp ->
redisTemplate.opsForList().rightPush(
redisKey, JSON.toJSONString(listResp)
)
);
log.info("数据库查询成功："+byTemplateId);
}
} catch (Exception e) {
log.info("获取报文模板失败");
throw new RuntimeException("获取报文模板失败");
}
// 根据车辆VIN码查询车辆信息
Vehicle vehicle = vehicleCacheService.get(vehicleVin);
VehicleType vehicleType = vehicleTypeCacheService.get(String.valueOf(vehicle.getVehicleTypeId()));
Long templateId = vehicleType.getMessageTemplateId();
List<MessageValueListResp> templateList = allMessageValueCacheService.get(String.valueOf(templateId));
//判断报文模板列表不为空
if (templateList.isEmpty()) {
log.info("报文模版为空");

86
cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/Test2.java
View File

@ -1,86 +0,0 @@
package com.muyu.analysis.parsing.mqtt;
import com.alibaba.fastjson2.JSONObject;
import lombok.extern.log4j.Log4j2;
import org.w3c.dom.stylesheets.LinkStyle;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
* @Author：李庆帅
* @Package：com.muyu.analysis.parsing.mqtt
* @Project：cloud-server
* @name：Test2
* @Date：2024/10/6 20:36
*/
@Log4j2
public class Test2
{
private static final int DURATION_SECONDS = 5;
private static List<JSONObject> receivedStrings = new ArrayList<>();
private static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
private static int elapsedSeconds = 0;
private static String file = "elapsed" ;
public static void main(String[] args){
//定义一个任务，每秒执行一次
Runnable task = new Runnable() {
@Override
public void run() {
JSONObject stringFromSource = getStringFromSource();
receivedStrings.add(stringFromSource);
System.out.println("Received："+stringFromSource);
//清理超过的数据
cleanUpOIdStrings();
//检查超速条件
checkForSpeeding();
}
};
//每个1秒执行一次任务
scheduler.scheduleAtFixedRate(task,0,1, TimeUnit.SECONDS);
}
//模拟从某个源获取字符串的方法
private static JSONObject getStringFromSource(){
JSONObject jsonObject = new JSONObject();
jsonObject.put("message","Hello World");
jsonObject.put("time",System.currentTimeMillis());
jsonObject.put("elapsed",elapsedSeconds);
return jsonObject;
}
//清理超过60秒的数据
private static void cleanUpOIdStrings(){
long currentTime = System.currentTimeMillis();
receivedStrings.removeIf(jsonObject ->currentTime-jsonObject.getLong("time")>TimeUnit.SECONDS.toMicros(DURATION_SECONDS));
}
//检查是否有超速情况
private static void checkForSpeeding()
{
if(receivedStrings.size() < 2)return;//如果数据不足，直接返回
JSONObject jsonObject = new JSONObject();
jsonObject.put("message","你好");
jsonObject.put("time",System.currentTimeMillis());
jsonObject.put("elapsed",10);
for (int i = 0; i < receivedStrings.size(); i++) {
JSONObject current = receivedStrings.get(i);
JSONObject next = receivedStrings.get(i + 1);
Short currentElapsed = current.getShort(file);
Short nextElapsed = next.getShort(file);
receivedStrings.add(jsonObject);
//检查条件，如果相差大于12，则记录错误
if (nextElapsed - currentElapsed > 12) {
System.out.println("出错啦！出错啦！车子超速啦！！！");
}
}
}
}