增加车辆实例控制层

增加车辆列表查询接口

src/main/java/com/muyu/controller/VehicleInstanceController.java

@@ -0,0 +1,39 @@
+package com.muyu.controller;
+
+import com.muyu.common.Result;
+import com.muyu.domain.req.VehicleInstanceListReq;
+import com.muyu.domain.resp.VehicleInstanceResp;
+import com.muyu.service.VehicleInstanceService;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+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 java.util.List;
+
+/**
+ * @author DongZl
+ * @description: 车辆实例控制层
+ * @Date 2023-11-25 上午 10:01
+ */
+@Log4j2
+@RestController
+@RequestMapping("/instance")
+public class VehicleInstanceController {
+
+    @Autowired
+    private VehicleInstanceService vehicleInstanceService;
+
+    /**
+     * 查询车辆集合
+     * @param vehicleInstanceListReq 车辆列表查询对象
+     * @return 结果
+     */
+    @PostMapping("/list")
+    public Result<List<VehicleInstanceResp>> list(@RequestBody VehicleInstanceListReq vehicleInstanceListReq){
+        List<VehicleInstanceResp> list = vehicleInstanceService.queryList(vehicleInstanceListReq);
+        return Result.success(list);
+    }
+}

src/main/java/com/muyu/domain/req/VehicleInstanceListReq.java

@@ -0,0 +1,23 @@
+package com.muyu.domain.req;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author DongZl
+ * @description: 车辆请求
+ * @Date 2023-11-25 上午 10:03
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class VehicleInstanceListReq {
+
+    /**
+     * VIN
+     */
+    private String vin;
+}

src/main/java/com/muyu/domain/resp/VehicleInstanceResp.java

@@ -0,0 +1,30 @@
+package com.muyu.domain.resp;
+
+import com.muyu.vehicle.VehicleInstance;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author DongZl
+ * @description: 车辆实例控制层响应结果
+ * @Date 2023-11-25 上午 10:04
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class VehicleInstanceResp {
+
+    /**
+     * VIN
+     */
+    private String vin;
+
+    public static VehicleInstanceResp instanceBuild (VehicleInstance vehicleInstance) {
+        return VehicleInstanceResp.builder()
+                .vin(vehicleInstance.getVin())
+                .build();
+    }
+}

src/main/java/com/muyu/service/VehicleInstanceService.java

@@ -1,6 +1,10 @@
 package com.muyu.service;
 
 import com.muyu.domain.Vehicle;
+import com.muyu.domain.req.VehicleInstanceListReq;
+import com.muyu.domain.resp.VehicleInstanceResp;
+
+import java.util.List;
 
 /**
  * @author DongZeLiang
@@ -21,4 +25,11 @@ public interface VehicleInstanceService {
      * @param vin 车辆VIN
      */
     public void initClient(String vin);
+
+    /**
+     * 车辆结果对象
+     * @param vehicleInstanceListReq 车辆查询
+     * @return 车辆对象
+     */
+    List<VehicleInstanceResp> queryList (VehicleInstanceListReq vehicleInstanceListReq);
 }

src/main/java/com/muyu/service/impl/VehicleInstanceServiceImpl.java

@@ -1,6 +1,8 @@
 package com.muyu.service.impl;
 
 import com.muyu.domain.Vehicle;
+import com.muyu.domain.req.VehicleInstanceListReq;
+import com.muyu.domain.resp.VehicleInstanceResp;
 import com.muyu.service.VehicleInstanceService;
 import com.muyu.vehicle.VehicleInstance;
 import com.muyu.vehicle.core.LocalContainer;
@@ -9,6 +11,8 @@ import com.muyu.vehicle.model.properties.MqttProperties;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * @author DongZeLiang
  * @version 1.0
@@ -50,11 +54,18 @@ public class VehicleInstanceServiceImpl implements VehicleInstanceService {
     }
 
     /**
+     * 车辆结果对象
      *
+     * @param vehicleInstanceListReq 车辆查询
      *
-     *
+     * @return 车辆对象
-     *
-     *
-     *
      */
+    @Override
+    public List<VehicleInstanceResp> queryList (VehicleInstanceListReq vehicleInstanceListReq) {
+        return LocalContainer.vehicleDataMap.values()
+                .stream()
+                .map(VehicleInstanceResp::instanceBuild)
+                .toList();
+    }
+
 }

src/main/java/com/muyu/vehicle/Test.java

@@ -39,7 +39,7 @@ public class Test {
         long genVinStartTime = System.currentTimeMillis();
         List<String> list = new ArrayList<>();
 //        list.add("VIN12345678912345");
-        for (int i = 0; i < 100; i++) {
+        for (int i = 0; i < 10; i++) {
             list.add(VehicleUtils.genVin());
         }
         log.info("生成VIN结束：[{}MS]", System.currentTimeMillis()-genVinStartTime);