package com.xiaopeng.operation.service.impl;
|
|
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
|
import com.xiaopeng.api.model.operation.XpElectronicFenceArea;
|
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.operation.config.UidVinBindingConfig;
|
import com.xiaopeng.operation.dto.PriorityMatchResult;
|
import com.xiaopeng.operation.dto.PriorityMatchResult.FailReason;
|
import com.xiaopeng.operation.service.IXpElectronicFenceAreaService;
|
import com.xiaopeng.operation.service.UidVinPriorityMatcher;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.Objects;
|
|
/**
|
* UID-VIN 优先匹配执行器实现
|
* <p>
|
* 匹配流程：查绑定配置 → 查询车辆状态 → 校验可用条件 → 返回结果
|
* </p>
|
*/
|
@Slf4j
|
@Service
|
public class UidVinPriorityMatcherImpl implements UidVinPriorityMatcher {
|
|
@Resource
|
private UidVinBindingConfig uidVinBindingConfig;
|
|
@Resource
|
private XpVehicleClient xpVehicleClient;
|
|
@Resource
|
private IXpElectronicFenceAreaService xpElectronicFenceAreaService;
|
|
@Override
|
public PriorityMatchResult tryPriorityMatch(String uid, String orderNo, String electronicAreaId) {
|
log.info("[人车订单绑定测试] ===== 开始优先匹配, uid={}, orderNo={}, electronicAreaId={} =====", uid, orderNo, electronicAreaId);
|
|
// 1. 查询绑定配置
|
log.info("[人车订单绑定测试] 步骤1: 查询UID绑定配置, uid={}", uid);
|
String vin = uidVinBindingConfig.getBoundVin(uid);
|
if (vin == null) {
|
log.info("[人车订单绑定测试] 步骤1结果: 该UID无绑定VIN, uid={}, orderNo={}", uid, orderNo);
|
return PriorityMatchResult.fail(FailReason.NO_BINDING);
|
}
|
log.info("[人车订单绑定测试] 步骤1结果: 找到绑定关系, uid={}, vin={}", uid, vin);
|
|
// 2. 查询车辆状态
|
log.info("[人车订单绑定测试] 步骤2: 调用车队服务查询车辆状态, vin={}", vin);
|
R<XpVehicle> vehicleR = xpVehicleClient.findByVehicleVin(vin);
|
log.info("[人车订单绑定测试] 步骤2: 车队服务返回, code={}, data={}", vehicleR.getCode(), vehicleR.getData() != null ? "有数据" : "null");
|
if (vehicleR.getCode() != R.SUCCESS || vehicleR.getData() == null) {
|
log.info("[人车订单绑定测试] 步骤2结果: 车辆不存在或查询失败, uid={}, vin={}, orderNo={}, responseCode={}", uid, vin, orderNo, vehicleR.getCode());
|
return PriorityMatchResult.fail(FailReason.VEHICLE_NOT_FOUND);
|
}
|
|
XpVehicle vehicle = vehicleR.getData();
|
log.info("[人车订单绑定测试] 步骤2结果: 车辆信息获取成功, vin={}, plateNumber={}, operatingStatus={}, state={}, vehicleType={}, electronicId={}",
|
vin, vehicle.getPlateNumber(), vehicle.getOperatingStatus(), vehicle.getState(), vehicle.getVehicleType(), vehicle.getElectronicId());
|
|
// 3. 校验车辆可用条件：operatingStatus=1, state=0, vehicleType!=1
|
log.info("[人车订单绑定测试] 步骤3: 校验车辆可用条件 (operatingStatus==1 && state==0 && vehicleType!=1)");
|
if (!isVehicleAvailable(vehicle)) {
|
if (!Objects.equals(vehicle.getState(), 0)) {
|
log.info("[人车订单绑定测试] 步骤3结果: 车辆已接单(state={}), 当前有未完成订单, 无法指派, uid={}, vin={}, plateNumber={}, orderNo={}",
|
vehicle.getState(), uid, vin, vehicle.getPlateNumber(), orderNo);
|
} else {
|
log.info("[人车订单绑定测试] 步骤3结果: 车辆不可用, uid={}, vin={}, orderNo={}, operatingStatus={}, state={}, vehicleType={}",
|
uid, vin, orderNo, vehicle.getOperatingStatus(), vehicle.getState(), vehicle.getVehicleType());
|
}
|
return PriorityMatchResult.fail(FailReason.VEHICLE_UNAVAILABLE);
|
}
|
log.info("[人车订单绑定测试] 步骤3结果: 车辆可用条件校验通过");
|
|
// 4. 校验电子围栏一致性：将 areaId 转换为 fenceId，与车辆的 electronicId 比较
|
log.info("[人车订单绑定测试] 步骤4: 校验电子围栏一致性, 订单围栏区域ID={}, 车辆围栏ID={}", electronicAreaId, vehicle.getElectronicId());
|
if (!isSameElectronicFence(vehicle, electronicAreaId)) {
|
log.info("[人车订单绑定测试] 步骤4结果: 围栏不一致, uid={}, vin={}, orderNo={}, vehicleElectronicId={}, electronicAreaId={}",
|
uid, vin, orderNo, vehicle.getElectronicId(), electronicAreaId);
|
return PriorityMatchResult.fail(FailReason.WRONG_AREA);
|
}
|
log.info("[人车订单绑定测试] 步骤4结果: 围栏校验通过");
|
|
// 5. 所有校验通过
|
log.info("[人车订单绑定测试] ===== 匹配成功, uid={}, vin={}, orderNo={} =====", uid, vin, orderNo);
|
return PriorityMatchResult.success(vin);
|
}
|
|
/**
|
* 校验车辆是否可用：运营中(1)、空闲(0)、非测试车(!=1)
|
*/
|
private boolean isVehicleAvailable(XpVehicle vehicle) {
|
return Objects.equals(vehicle.getOperatingStatus(), 1)
|
&& Objects.equals(vehicle.getState(), 0)
|
&& !Objects.equals(vehicle.getVehicleType(), 1);
|
}
|
|
/**
|
* 校验车辆是否在同一电子围栏内
|
* <p>
|
* electronicAreaId 是围栏区域ID，需要通过 IXpElectronicFenceAreaService 查询
|
* 对应的围栏ID（electronicId），再与车辆的 electronicId 比较。
|
*/
|
private boolean isSameElectronicFence(XpVehicle vehicle, String electronicAreaId) {
|
if (electronicAreaId == null || vehicle.getElectronicId() == null) {
|
log.info("[人车订单绑定测试] 围栏校验: 参数为空, electronicAreaId={}, vehicleElectronicId={}", electronicAreaId, vehicle.getElectronicId());
|
return false;
|
}
|
try {
|
XpElectronicFenceArea area = xpElectronicFenceAreaService.getById(Long.parseLong(electronicAreaId));
|
if (area == null || area.getElectronicId() == null) {
|
log.info("[人车订单绑定测试] 围栏校验: 围栏区域不存在或无关联围栏, electronicAreaId={}", electronicAreaId);
|
return false;
|
}
|
boolean same = Objects.equals(vehicle.getElectronicId(), area.getElectronicId());
|
log.info("[人车订单绑定测试] 围栏校验: 车辆围栏ID={}, 区域关联围栏ID={}, 是否一致={}", vehicle.getElectronicId(), area.getElectronicId(), same);
|
return same;
|
} catch (NumberFormatException e) {
|
log.info("[人车订单绑定测试] 围栏校验: electronicAreaId格式异常, electronicAreaId={}", electronicAreaId);
|
return false;
|
}
|
}
|
}
|
