报文解析

2024-09-29 08:32:58 +08:00 · 2024-09-28 16:29:34 +08:00
14 changed files with 308 additions and 178 deletions
--- a/cloud-modules/cloud-modules-car/pom.xml
+++ b/cloud-modules/cloud-modules-car/pom.xml
@ -66,17 +66,13 @@
            <artifactId>cloud-common-log</artifactId>
        </dependency>

-
-        <!-- XllJob定时任务 -->
+        <!--apache.kafka<-->
        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-xxl</artifactId>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
        </dependency>

-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-rabbit</artifactId>
-        </dependency>
+

        <!-- MuYu Common System-->
        <dependency>
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/CarApplication.java
@ -1,18 +1,23 @@
 package com.muyu.car;

+import com.muyu.car.service.CarMessageService;
 import com.muyu.common.security.annotation.EnableCustomConfig;
 import com.muyu.common.security.annotation.EnableMyFeignClients;
 import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
+
+import javax.annotation.Resource;

@EnableCustomConfig
@EnableMyFeignClients
@SpringBootApplication
+@EnableCaching
 public class CarApplication {
    public static void main(String[] args){
        SpringApplication.run(CarApplication.class,args);
    }

-
 }
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarMessageController.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/controller/CarMessageController.java
@ -1,5 +1,6 @@
 package com.muyu.car.controller;

+import com.alibaba.fastjson.JSONObject;
 import com.muyu.car.domain.CarMessage;
 import com.muyu.car.service.CarMessageService;
 import com.muyu.common.core.domain.Result;
@ -7,10 +8,7 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;

 import javax.annotation.Resource;
 import java.util.List;
@ -29,8 +27,8 @@ public class CarMessageController {
     */
    @PostMapping("/selectCarMessageList")
    @Operation(summary = "报文模板展示列表")
-    public Result<List<CarMessage>> selectCarMessageList(){
-        List<CarMessage> carMessages = carMessageService.selectCarMessageList();
+    public Result<List<CarMessage>> selectCarMessageList(Integer carMessageCartype){
+        List<CarMessage> carMessages = carMessageService.selectCarMessageList(carMessageCartype);
        return Result.success(carMessages);
    }

@ -66,58 +64,22 @@ public class CarMessageController {
        return Result.success(updateCarMessage,"修改成功");
    }

+    /**
+     * 测试分割字符
+     */
+    @PostMapping("/inciseCarMessage")
+    @Operation(summary = "解析报文处理", description = "解析报文测试")
+    public Result<JSONObject> inciseCarMessage(@RequestParam(name = "testString") String testString){
+        JSONObject carMessage = carMessageService.inciseCarMessage(testString);
+        return Result.success(carMessage);
+
+    }

    /**
     * 测试分割字符
     */
-    public class MessageParser{
-        public static void main(String[] args) {
-            String message = "01,02,03," +
-                    "04,05,06,07,08,09," +
-                    "10,11,12,13,14,15,16" +
-                    ",17,18,19,20,21,22,23," +
-                    "24,25,26,27,28,29,30" +
-                    ",31,32,33,34,35,36,37," +
-                    "38,39,40,41,42,43,44,45," +
-                    "46";


-            String[] split = message.split(",");
-            for (int i = 0; i < split.length; i++) {
-                System.out.println(split[i]);
-                if(i == 0){
-                    System.out.println("开始");
-                }else if(i == split.length - 1){
-                    System.out.println("结束");
-                }
-            }
-            System.out.println(split.length);
-            System.out.println(message.length());
-
-            System.out.println(message.substring(0,1));
-            System.out.println(message.substring(1,2));
-            System.out.println(message.substring(2,3));
-            System.out.println(message.substring(3,4));
-            System.out.println(message.substring(4,5));
-            System.out.println(message.substring(5,6));
-            System.out.println(message.substring(6,7));
-            System.out.println(message.substring(7,8));
-            System.out.println(message.substring(8,9));
-            System.out.println(message.substring(9,10));
-            System.out.println(message.substring(10,11));
-            System.out.println(message.substring(11,12));
-            System.out.println(message.substring(12,13));
-            System.out.println(message.substring(13,14));
-            System.out.println(message.substring(14,15));
-            System.out.println(message.substring(15,16));
-
-
-
-
-        }
-
-
-    }



--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/resp/CarINdsa.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/resp/CarINdsa.java
@ -0,0 +1,105 @@
+package com.muyu.car.domain.resp;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.bouncycastle.crypto.Digest;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Tag(
+        name = "测试代码行",
+        description = "车INdsa"
+)
+public class CarINdsa {
+
+    private Long  testmessageId;
+    private String  testmessagename;
+    private Integer  testmessagetodo;
+    private String  testmessageagon;
+    private Integer  testmessagetest;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date dayend;
+    private String  testmessagehid;
+    private Integer  testmessageyou;
+    private Digest testmessageertug;
+    private String  testmessagebug;
+    private Integer  testmessagedata;
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+}
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/resp/CarReq.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/domain/resp/CarReq.java
@ -1,99 +0,0 @@
-package com.muyu.car.domain.resp;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-@Builder
-public class CarReq {
-
-    private String EatImagtion;
-    private String imgTion;
-    private String EatIma6ion;
-    private String EatImagtFformion;
-    private String EatTailImagtion;
-    private String EatImagertion;
-    private String EatImagtodoion;
-    private String EatasImagtion;
-    private String EatImageartion;
-    private String imagtionId;
-    private String Eagtion;
-    private String EatImag;
-    private String tImag;
-    private String agtizyRon;
-    private String EatImagcdtion;
-    private String agtigagtion;
-    private String EatImfhgdfagtion;
-    private String EffatImagtion;
-    private String EatImadfggtion;
-    private String EatImagfgtion;
-    private String EatImaggdtion;
-    private String EatImagdfgtion;
-    private String EatImfdgadfggtion;
-    private String EatIfdgmagtion;
-    private String EatIfdgfgmagtion;
-    private String EatImagdffggtion;
-    private String EatImaggfdtion;
-    private String EatImagtigon;
-    private String EatImagtbjion;
-    private String EatImagt_fdgion;
-    private String EatrgImagtion;
-    private String EatIdgmagtion;
-    private String EatImafggtion;
-    private String EgatImgagtion;
-    private String EatImggagtion;
-    private String EatImagfdgtion;
-    private String EatdfgImadfggtion;
-    private String EatIgdmagtion;
-    private String EatImagd;
-    private String EatdfgImagtion;
-    private String EatIgfgmagtion;
-    private String EatIsdmagtion;
-    private String EatfImagtion;
-    private String EadatImagtion;
-    private String EatdgImagtion;
-    private String EatdImagtion;
-    private String EatIafmagtion;
-    private String EatIagffmagtion;
-    private String EatgsImagtion;
-    private String EatasdImagtion;
-    private String EatIadmagtion;
-    private String EatadImagtion;
-    private String EatIcvmagtion;
-    private String EatImagtfion;
-    private String EatImagation;
-    private String EatImfagtion;
-    private String EatImagyution;
-    private Integer other;
-    private Integer othjjer;
-    private Integer otmkdowedher;
-    private Integer desother;
-private Integer otsmkeher;
-private Integer othsmer;
-private Integer oedednjihyther;
-private Integer othhuer;
-private Integer othmkjoer;
-private Integer othnjiu8er;
-private Integer othhubhyer;
-private Integer othejkihjur;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-}
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarInformationMapper.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarInformationMapper.java
@ -2,14 +2,17 @@ package com.muyu.car.mapper;


 import com.muyu.car.domain.CarInformation;
+import com.muyu.car.domain.CarMessage;
 import com.muyu.car.domain.req.CarInformationAddReq;
 import com.muyu.car.domain.req.CarInformationListReq;
 import com.muyu.car.domain.req.CarInformationUpdReq;
+import io.swagger.v3.oas.annotations.tags.Tag;
 import org.apache.ibatis.annotations.Mapper;

 import java.util.List;

@Mapper
+@Tag(name = "车辆基础信息表")
 public interface CarInformationMapper {
 /**
 * 企业车辆管理列表
@ -64,5 +67,4 @@ public interface CarInformationMapper {



-
 }
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarMessageMapper.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/CarMessageMapper.java
@ -1,7 +1,9 @@
 package com.muyu.car.mapper;

+import com.muyu.car.domain.CarInformation;
 import com.muyu.car.domain.CarMessage;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;

 import java.util.List;

@ -12,7 +14,7 @@ public interface CarMessageMapper {
     * @param
     * @return
     */
-    List<CarMessage> selectCarMessageList();
+    List<CarMessage> selectCarMessageList(@Param("carMessageCartype")Integer carMessageCartype);


    /**
@ -31,4 +33,24 @@ public interface CarMessageMapper {
     */
    Integer updateCarMessage(CarMessage carMessage);

+
+    //报文切割
+    /**
+     * 查询报文ID
+     * @param carInformationVIN
+     * @return
+     *  根据车辆VIN值查列表
+     * 根据给定的车辆VIN号获取对应的车辆类型ID-->模板参数
+     */
+    List<CarInformation> selectcarInformationType(String carInformationVIN);
+
+    /**
+     *根据VIN查询报文作用哪个车辆类型
+     */
+    Long selectcarMessageCartype(String carInformationVIN);
+
+
+
+
+
 }
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/PackettemplateMapper.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/mapper/PackettemplateMapper.java
@ -2,11 +2,13 @@ package com.muyu.car.mapper;

 import com.muyu.car.domain.Packettemplate;
 import com.muyu.car.domain.req.PackettemplateAddReq;
+import io.swagger.v3.oas.annotations.tags.Tag;
 import org.apache.ibatis.annotations.Mapper;

 import java.util.List;

@Mapper
+@Tag(name = "保温分类表")
 public interface PackettemplateMapper {

    /**
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/CarMessageService.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/CarMessageService.java
@ -1,5 +1,6 @@
 package com.muyu.car.service;

+import com.alibaba.fastjson.JSONObject;
 import com.muyu.car.domain.CarMessage;
 import com.muyu.common.core.domain.Result;

@ -12,7 +13,7 @@ public interface CarMessageService {
     * @param
     * @return
     */
-    List<CarMessage> selectCarMessageList();
+    List<CarMessage> selectCarMessageList(Integer carMessageCartype);


    /**
@ -34,9 +35,14 @@ public interface CarMessageService {


    /**
-     * 分割字符串获取报文模板信息
+     *
     */

+    /**
+     * 分割字符串获取报文信息
+     */
+    JSONObject inciseCarMessage(String testString);
+


 }
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarInformationServiceImpl.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarInformationServiceImpl.java
@ -11,7 +11,9 @@ import com.muyu.car.mapper.CarInformationMapper;
 import com.muyu.car.service.CarInformationService;
 import com.muyu.common.core.domain.Result;
 import jakarta.servlet.http.HttpServletResponse;
+import org.apache.poi.ss.formula.functions.IDStarAlgorithm;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.stereotype.Service;

 import javax.annotation.Resource;
@ -52,6 +54,14 @@ public class CarInformationServiceImpl implements CarInformationService {
    }


+    public Result adfv(IDStarAlgorithm starAlgorithm){
+        String str="afavav sdvaedvgafa sefse";
+
+        return Result.success(starAlgorithm);
+        return Result.error(402,"添加车辆失败");
+
+    }
+
    @Override
    public Result updatecarInformation(CarInformationUpdReq carInformationUpdReq) {
        Integer updatecarInformation = carInformationMapper.updatecarInformation(carInformationUpdReq);
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarMessageServiceImpl.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/CarMessageServiceImpl.java
@ -1,22 +1,39 @@
 package com.muyu.car.service.Impl;

+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.muyu.car.domain.CarInformation;
 import com.muyu.car.domain.CarMessage;
+import com.muyu.car.mapper.CarInformationMapper;
 import com.muyu.car.mapper.CarMessageMapper;
 import com.muyu.car.service.CarMessageService;
 import com.muyu.common.core.domain.Result;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;

 import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Collection;
 import java.util.List;
+import java.util.Objects;

@Service
+@Log4j2
 public class CarMessageServiceImpl implements CarMessageService {
    @Resource
    private CarMessageMapper carMessageMapper;
+    @Resource
+    private CarInformationMapper carInformationMapper;
+
+    @Resource
+    private RedisTemplate<String, Objects> redisTemplate;
+

    @Override
-    public List<CarMessage> selectCarMessageList() {
-        return  carMessageMapper.selectCarMessageList();
+    public List<CarMessage> selectCarMessageList(Integer carMessageCartype) {
+        return  carMessageMapper.selectCarMessageList(carMessageCartype);
    }

    @Override
@ -48,7 +65,67 @@ public class CarMessageServiceImpl implements CarMessageService {
    }


+    @Override
+    public JSONObject inciseCarMessage(String testString) {
+        //根据空格拆分切割数据字符串
+        String[] split = testString.split(" ");
+        StringBuilder stringBuilder = new StringBuilder();
+        for (String conversion : split) {
+            //将16进制字符串转换为对应的10进制
+            int inciseindex = Integer.parseInt(conversion, 16);
+            // 将10进制转换为对应的字符
+            stringBuilder.append((char) inciseindex);
+        }
+        //切取车辆VIN
+        String substring = stringBuilder.substring(0, 17);
+        log.info("车辆的VIN码:" + substring);
+       //根据给定的vehicleVin（车辆VIN号）获取对应的模板车辆分类carMessageCartype
+        Long selectcared = carMessageMapper.selectcarMessageCartype(substring);
+        //根据给定的vehicleVin（车辆VIN号）获取对应的模板信息
+     //   List<CarInformation> carInformations = carMessageMapper.selectcarInformationType(substring);
+        //创建接受数据的数组
+        List<CarMessage> carMessagesList ;

+               try{
+            String redisKey = "carMessageList" + selectcared;
+             if (redisTemplate.hasKey(redisKey)){
+            List<Objects> list = redisTemplate.opsForList().range(redisKey ,  0, -1);
+                 carMessagesList =
+                         list.stream().map(objects ->
+                         JSON.parseObject(objects.toString(), CarMessage.class))
+                         .toList();
+                 log.info("Redis缓存查询成功");
+              }else {
+                     carMessagesList  = carMessageMapper.selectCarMessageList(Math.toIntExact(selectcared));
+
+                     carMessagesList.forEach(
+                             listReq -> redisTemplate.opsForList().rightPushAll(redisKey, (Collection<Objects>) listReq)
+                     );
+                 log.info("数据库查询成功");
+        }
+             log.info("获取失败,请重试");
+        }catch(Exception e){
+        throw  new RuntimeException("获取报文模板失败");
+    }
+    //判断报文模板 列表 不为空
+        if(carMessagesList.isEmpty()){
+            throw new RuntimeException("报文模版为空");
+        }
+    //存储报文模板解析后的数据
+        JSONObject jsonObject = new JSONObject();
+        for (CarMessage carMessage : carMessagesList) {
+            //起始位下标
+            Integer startIndex = carMessage.getCarMessageStartIndex();
+            //结束位下标
+            Integer endIndex = carMessage.getCarMessageEndIndex();
+            //根据报文模板获取保温截取位置
+            String value = stringBuilder.substring(startIndex, endIndex);
+            //存入数据
+            jsonObject.put(carMessage.getMessageTypeName(), value);
+
+        }
+        return jsonObject;
+    }



--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/PackertemplateServiceImpl.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/service/Impl/PackertemplateServiceImpl.java
@ -15,7 +15,7 @@ import java.util.List;
@Log4j2
 public class PackertemplateServiceImpl implements PackertemplateService {
    @Resource
-    public PackettemplateMapper packettemplateMapper;
+    private PackettemplateMapper packettemplateMapper;

    /**
     *分类模板
--- a/cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarInformationMapper.xml
+++ b/cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarInformationMapper.xml
@ -104,6 +104,8 @@
        FROM  `car_information`
    </select>

+
+
    <insert id="addCarInformation">
        INSERT INTO  `car_information`
            (
--- a/cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarMessageMapper.xml
+++ b/cloud-modules/cloud-modules-car/src/main/resources/mapper/car/CarMessageMapper.xml
@ -7,17 +7,17 @@

 <mapper namespace="com.muyu.car.mapper.CarMessageMapper">
    <resultMap id="carMessageResult" type="com.muyu.car.domain.CarMessage">
-        <result property="messageTypeId"      column="message_type_id"/>
-        <result property="messageTypeCode"    column="message_type_code"/>
-        <result property="messageTypeName"    column="message_type_name"/>
-        <result property="messageTypeBelongs" column="message_type_belongs"/>
-        <result property="messageTypeClass"   column="message_type_class"/>
-        <result property="carMessageId"       column="car_message_id"/>
-        <result property="carMessageCartype"  column="car_message_cartype"/>
-        <result property="carMessageType"     column="car_message_type"/>
-      <result property="carMessageStartIndex" column="car_message_start_index"/>
-        <result property="carMessageEndIndex" column="car_message_end_index"/>
-        <result property="carMessageState"   column= "car_message_state"/>
+        <result  property="messageTypeId"         column="message_type_id"/>
+        <result  property="messageTypeCode"       column="message_type_code"/>
+        <result  property="messageTypeName"       column="message_type_name"/>
+        <result  property="messageTypeBelongs"    column="message_type_belongs"/>
+        <result  property="messageTypeClass"      column="message_type_class"/>
+        <result  property="carMessageId"          column="car_message_id"/>
+        <result  property="carMessageCartype"     column="car_message_cartype"/>
+        <result  property="carMessageType"        column="car_message_type"/>
+        <result  property="carMessageStartIndex"  column="car_message_start_index"/>
+        <result  property="carMessageEndIndex"    column="car_message_end_index"/>
+        <result  property="carMessageState"       column= "car_message_state"/>
    </resultMap>

    <insert id="insertCarMessage">
@ -89,6 +89,46 @@
            ON `car_message`.car_message_type = `car_message_type`.message_type_id
            LEFT JOIN  `car_type`
            ON `car_message` .car_message_cartype = `car_type`.car_type_id
+        WHERE
+            `car_message`.car_message_cartype  = #{carMessageCartype}
+    </select>
+
+
+
+
+    <select id="selectcarInformationType" resultType="com.muyu.car.domain.CarInformation">
+        SELECT
+            car_information_VIN,
+            car_information_type,
+            car_type_id,
+            car_type_name,
+            car_message_id,
+            car_message_cartype,
+            car_message_type,
+            car_message_start_index,
+            car_message_end_index,
+            message_type_class,
+            car_message_state
+        FROM `car_information`
+        LEFT JOIN `car_type`
+        ON  `car_information`.  car_information_type
+                =`car_type`.   car_type_id
+        LEFT JOIN  `car_message`
+        ON  `car_message`.car_message_cartype
+                =`car_type`.   car_type_id
+        WHERE
+            `car_information`.car_information_VIN = #{carInformationVIN}

    </select>
+
+    <select id="selectcarMessageCartype" resultType="java.lang.Long">
+        SELECT  `car_information`.car_Information_Type
+        FROM `car_information`
+        WHERE  `car_information`.car_information_VIN = #{carInformationVIN}
+    </select>
+
+
+
+
+
 </mapper>
Author	SHA1	Message	Date
Aaaaaaaa	d3810706f5	报文解析	2024-09-29 08:32:58 +08:00
Aaaaaaaa	ad84ffb8c2	报文解析	2024-09-28 16:29:34 +08:00