diff --git a/cloud-modules/saas/pom.xml b/cloud-modules/saas/pom.xml index 83f4ea5..47561c5 100644 --- a/cloud-modules/saas/pom.xml +++ b/cloud-modules/saas/pom.xml @@ -16,6 +16,21 @@ saas-server + + + + org.springframework.integration + spring-integration-mqtt + 6.2.5 + + + + + org.springframework.kafka + spring-kafka + + + 17 17 diff --git a/cloud-modules/saas/saas-common/pom.xml b/cloud-modules/saas/saas-common/pom.xml index bda0d95..cb74eaa 100644 --- a/cloud-modules/saas/saas-common/pom.xml +++ b/cloud-modules/saas/saas-common/pom.xml @@ -32,6 +32,12 @@ swagger-annotations 2.2.8 + + com.muyu.server + saas-server + 3.6.3 + compile + diff --git a/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/config/MqttConfigure.java b/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/config/MqttConfigure.java new file mode 100644 index 0000000..12d4867 --- /dev/null +++ b/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/config/MqttConfigure.java @@ -0,0 +1,75 @@ +package com.muyu.common.config; + +import cn.hutool.json.JSONObject; +import com.muyu.server.service.TemplateService; +import lombok.extern.log4j.Log4j2; +import org.eclipse.paho.client.mqttv3.*; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +/** + * @Author：liuxinyue + * @Package：com.muyu.mqtt.configure + * @Project：cloud-server + * @name：MqttConfigure + * @Date：2024/9/28 16:10 + */ +@Log4j2 +@Component +public class MqttConfigure { + + @Autowired + private TemplateService templateService; + + + @PostConstruct + public void MQTTMonitoring(){ + String topic = "vehicle"; + int qos = 2; + String broker = "tcp://47.101.53.251:1883"; + String clientId = "hhhhhh"; + try { + MqttClient sampleClient = new MqttClient(broker, clientId); + MqttConnectOptions connOpts = new MqttConnectOptions(); + //是否清空session + connOpts.setCleanSession(true); + log.info("Connecting to broker: " + broker); + //连接 + sampleClient.connect(connOpts); + sampleClient.subscribe(topic,qos); + sampleClient.setCallback(new MqttCallback() { + //连接丢失(报错) + @Override + public void connectionLost(Throwable throwable) { + log.error("error:"+throwable.getMessage()); + } + //消息已经接收到 + @Override + public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { + // 将MQTT消息转换为字符串 + String messageContent = new String(mqttMessage.getPayload()); + // 解析JSON字符串 + JSONObject jsonObject = new JSONObject(messageContent); + // 从JSON对象中获取"msg"字段的值 + String msgValue = jsonObject.getStr("msg"); + templateService.messageParsing(msgValue); + log.info("接收到的值为:"+msgValue); + } + //交付完成 + @Override + public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { + + } + }); + } catch(MqttException me) { + System.out.println("reason "+me.getReasonCode()); + System.out.println("msg "+me.getMessage()); + System.out.println("loc "+me.getLocalizedMessage()); + System.out.println("cause "+me.getCause()); + System.out.println("excep "+me); + me.printStackTrace(); + } + } +} diff --git a/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/domain/SysCar.java b/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/domain/SysCar.java index 9041490..c2e5e47 100644 --- a/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/domain/SysCar.java +++ b/cloud-modules/saas/saas-common/src/main/java/com/muyu/common/domain/SysCar.java @@ -26,5 +26,9 @@ public class SysCar extends BaseEntity { private String carBatteryModel; private Long strategyId; private Long groupId; + /** + * 模版ID + */ + private Integer templateId; } diff --git a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/CarTypeController.java b/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/CarTypeController.java index 9935d0b..53c3655 100644 --- a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/CarTypeController.java +++ b/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/CarTypeController.java @@ -43,7 +43,7 @@ public class CarTypeController { return Result.success(carTypeService.selectCarTypeRespList(id)); } - /**1 + /** * 根据类型ID获取车辆类型 * @param carTypeId * @return diff --git a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/TemplateService.java b/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/TemplateService.java deleted file mode 100644 index 74bf79a..0000000 --- a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/TemplateService.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.muyu.server.controller; - -import com.alibaba.fastjson.JSONObject; - -/** - * @Author：liuxinyue - * @Package：com.muyu.controller - * @Project：cloud-server - * @name：TemplateService - * @Date：2024/9/22 22:02 - */ -public class TemplateService { - - public void messageParsing(String templateMessage){ - - //创建一个JSON对象 - JSONObject jsonObject = new JSONObject(); - if(templateMessage.length()<18){ - throw new RuntimeException("错误VIN码,不存在此车"); - } - - //将报文进行切割 - String[] split = templateMessage.split(" "); - StringBuilder stringBuilder = new StringBuilder(); - for (String s : split) { - - int i = Integer.parseInt(s, 16); - stringBuilder.append((char)i); - - } - //取出车辆的VIN码值 - - - } - - public static void main(String[] args) { - - } - - -} diff --git a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateServiceImpl.java b/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateServiceImpl.java index 8eb8c21..31b3b5a 100644 --- a/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateServiceImpl.java +++ b/cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/TemplateServiceImpl.java @@ -1,10 +1,14 @@ 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.common.domain.MessageTemplateType; +import com.muyu.common.domain.SysCar; import com.muyu.common.domain.Template; import com.muyu.server.mapper.TemplateMapper; import com.muyu.server.service.MessageTemplateTypeService; +import com.muyu.server.service.SysCarService; import com.muyu.server.service.TemplateService; import lombok.extern.log4j.Log4j2; import org.apache.iotdb.rpc.IoTDBConnectionException; @@ -31,7 +35,8 @@ public class TemplateServiceImpl extends ServiceImpl i @Autowired private static TemplateMapper templateMapper; - + @Autowired + private SysCarService sysCarService; @Autowired private MessageTemplateTypeService messageTemplateTypeService; @@ -43,42 +48,62 @@ public class TemplateServiceImpl extends ServiceImpl i @Override public void messageParsing(String templateMessage) throws SQLException, IoTDBConnectionException, ClassNotFoundException, StatementExecutionException, ExecutionException, InterruptedException { - List templateList = templateMapper.findTemplateById(1); - String[] split = templateMessage.split(" "); - String[] strings = new String[split.length]; + //给一个JSON对象 + JSONObject jsonObject = new JSONObject(); + //先截取出VIN码 然后根据VIN码查询这个车属于什么类型 + if (templateMessage.length() < 18) { + throw new RuntimeException("The vehicle message is incorrect"); + } + //将报文进行切割 + String[] hexArray = templateMessage.split(" "); + StringBuilder result = new StringBuilder(); + for (String hex : hexArray) { + int decimal = Integer.parseInt(hex, 16); + result.append((char) decimal); + } + //取出VIN码 + String carVin = result.substring(0, 18 - 1); + log.info("carVin码为:" + carVin); + //根据VIN码获取车辆信息 + SysCar carByVin = sysCarService.findCarByVin(carVin); + //对应车辆所对应的报文模版 + Integer templateId = carByVin.getTemplateId(); - List> futures = new ArrayList<>(); - for (MessageTemplateType templateType : templateList) { + List templateTypeList; - futures.add(CompletableFuture.supplyAsync(() -> { - int startIndex = Integer.parseInt(String.valueOf(templateType.getStartIndex())) - 1; - int endIndex = Integer.parseInt(String.valueOf(templateType.getEndIndex())); - StringBuilder hexBuilder = new StringBuilder(); - for (int j = startIndex; j < endIndex; j++) { - hexBuilder.append(split[j]); - } - // 创建16进制的对象 - String hex = hexBuilder.toString(); - // 转橙字符数组 - char[] result = new char[hex.length() / 2]; - for (int x = 0; x < hex.length(); x += 2) { - // 先转十进制 - int high = Character.digit(hex.charAt(x), 16); - // 转二进制 - int low = Character.digit(hex.charAt(x + 1), 16); - // 转字符 - result[x / 2] = (char) ((high << 4) + low); - } - return new String(result); - })); + //key + String redisKey = "messageTemplateType" + templateId; + + //key存在 + if (redisTemplate.hasKey(redisKey)) { + + List list = redisTemplate.opsForList().range(redisKey, 0, -1); + + templateTypeList = list.stream().map(o -> JSON.parseObject(o.toString(), MessageTemplateType.class)) + .toList(); + + } else { + List templateTypeList1 = messageTemplateTypeService.findTemplateById(templateId); + templateTypeList = templateTypeList1; + templateTypeList.forEach( + templateType -> + redisTemplate.opsForList().rightPush( + redisKey, com.alibaba.fastjson.JSON.toJSONString(templateType) + ) + ); + } + //将模版里面有的配置进行循环 + for (MessageTemplateType messageTemplateType : templateTypeList) { + //开始位置 + Integer startIndex = messageTemplateType.getStartIndex() - 1; + //结束位置 + Integer endIndex = messageTemplateType.getEndIndex(); + //将每个解析后的字段都存入到JSON对象中 + jsonObject.put(messageTemplateType.getMessageField(), result.substring(startIndex, endIndex)); } - for (int i = 0; i < futures.size(); i++) { - strings[i] = futures.get(i).get(); - } + log.info("解析后的报文是:" + jsonObject); - System.out.println("哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈哈"); - log.info("结果是:"+strings); }