修改bug

puzhibing

2026-03-01 58863a52aacb90c6dc9b01d2755aa2dc78b5bc7c

1
2
3
4
5
6
7
8
9
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package com.xiaopeng.automaticPilot.controller;
 
 
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
import com.xiaopeng.automaticPilot.dto.CheckL4AvailableRequest;
import com.xiaopeng.automaticPilot.dto.L4CapabilityVO;
import com.xiaopeng.automaticPilot.dto.XpCommonResponse;
import com.xiaopeng.automaticPilot.dto.XpuInitStatusRequest;
import com.xiaopeng.automaticPilot.util.XPUUtil;
import com.xiaopeng.common.core.domain.R;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
 
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
 
@Slf4j
@RestController
@RequestMapping("")
public class XpuVinController {
 
    @Resource
    private XPUUtil xpuUtil;
 
    @Resource
    private XpVehicleClient xpVehicleClient;
 
 
    /**
     * 根据车辆VIN查询XPUID
     * @param vin
     * @return
     */
    @GetMapping("/xpu/getXpuIdByVin")
    public R<String> getXpuIdByVin(@RequestParam("vin") String vin){
        String xpuId = xpuUtil.getXpuIdByVin(vin);
        return R.ok(xpuId);
    }
 
    /**
     * 判断车辆是否能启动L4自动驾驶能力
     */
    @PostMapping("/xpu/v1/autopilot/L4/checkAvailable")
    public XpCommonResponse<L4CapabilityVO> checkL4Available(@RequestBody @Valid CheckL4AvailableRequest request) {
        log.info("Check L4 available request: {}", request);
        L4CapabilityVO vo = new L4CapabilityVO();
        vo.setVin(request.getVin());
        vo.setUid(request.getUserId());
        
        List<String> capabilities = new ArrayList<>();
        // 默认支持VPD
        capabilities.add("VPD");
        
        try {
            R<XpVehicle> vehicleR = xpVehicleClient.findByVehicleVin(request.getVin());
            if (vehicleR != null && vehicleR.getCode() == 200 && vehicleR.getData() != null) {
                XpVehicle vehicle = vehicleR.getData();
                // 车辆类型：1=待完善 2=运营车辆
                // 只有运营车辆才支持RT
                if (Objects.equals(vehicle.getVehicleType(), 2)) {
                    capabilities.add("RT");
                }
            } else {
                log.warn("Vehicle not found for vin: {}", request.getVin());
            }
        } catch (Exception e) {
            log.error("Error querying vehicle info", e);
        }
        
        vo.setL4Capability(capabilities);
        return XpCommonResponse.ok(vo);
    }
 
    /**
     * XPU初始化状态上报
     */
    @PostMapping("/xpu/v1/autopilot/L4/init")
    public XpCommonResponse<Void> initXpuStatus(@RequestBody @Valid XpuInitStatusRequest request) {
        log.info("XPU init status report: {}", request);
        return XpCommonResponse.ok(null);
    }
}