package com.ruoyi.unattended.access.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.unattended.access.dto.AccessVerifyRequest;
|
import com.ruoyi.unattended.access.mapper.AccessGateMapper;
|
import com.ruoyi.unattended.access.mapper.AccessRecordMapper;
|
import com.ruoyi.unattended.access.mapper.AccessVehicleMapper;
|
import com.ruoyi.unattended.access.pojo.AccessGate;
|
import com.ruoyi.unattended.access.pojo.AccessRecord;
|
import com.ruoyi.unattended.access.pojo.AccessVehicle;
|
import com.ruoyi.unattended.access.service.AccessService;
|
import com.ruoyi.unattended.pojo.UnattendedOperation;
|
import com.ruoyi.unattended.service.UnattendedOperationService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.StringUtils;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
public class AccessServiceImpl implements AccessService {
|
|
@Resource
|
private AccessGateMapper accessGateMapper;
|
|
@Resource
|
private AccessRecordMapper accessRecordMapper;
|
|
@Resource
|
private AccessVehicleMapper accessVehicleMapper;
|
|
@Resource
|
private UnattendedOperationService unattendedOperationService;
|
|
@Override
|
public IPage<AccessGate> gatePage(Page<AccessGate> page, AccessGate query) {
|
LambdaQueryWrapper<AccessGate> wrapper = Wrappers.<AccessGate>lambdaQuery()
|
.like(StringUtils.hasText(query.getGateName()), AccessGate::getGateName, query.getGateName())
|
.like(StringUtils.hasText(query.getArea()), AccessGate::getArea, query.getArea())
|
.orderByDesc(AccessGate::getCreateTime);
|
return accessGateMapper.selectPage(page, wrapper);
|
}
|
|
@Override
|
public boolean gateSave(AccessGate gate) {
|
if (!StringUtils.hasText(gate.getDeviceStatus())) {
|
gate.setDeviceStatus("online");
|
}
|
if (!StringUtils.hasText(gate.getGateType())) {
|
gate.setGateType("all");
|
}
|
return accessGateMapper.insert(gate) > 0;
|
}
|
|
@Override
|
public boolean gateUpdate(AccessGate gate) {
|
return accessGateMapper.updateById(gate) > 0;
|
}
|
|
@Override
|
public boolean gateRemove(List<Long> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return false;
|
}
|
return accessGateMapper.deleteBatchIds(ids) > 0;
|
}
|
|
/* ---------- 车辆通行授权 ---------- */
|
|
@Override
|
public IPage<AccessVehicle> vehiclePage(Page<AccessVehicle> page, AccessVehicle query) {
|
LambdaQueryWrapper<AccessVehicle> wrapper = Wrappers.<AccessVehicle>lambdaQuery()
|
.like(StringUtils.hasText(query.getPlateNumber()), AccessVehicle::getPlateNumber, query.getPlateNumber())
|
.like(StringUtils.hasText(query.getRfidTag()), AccessVehicle::getRfidTag, query.getRfidTag())
|
.like(StringUtils.hasText(query.getCarrierName()), AccessVehicle::getCarrierName, query.getCarrierName())
|
.eq(StringUtils.hasText(query.getStatus()), AccessVehicle::getStatus, query.getStatus())
|
.orderByDesc(AccessVehicle::getId);
|
return accessVehicleMapper.selectPage(page, wrapper);
|
}
|
|
@Override
|
public boolean vehicleSave(AccessVehicle vehicle) {
|
if (!StringUtils.hasText(vehicle.getStatus())) {
|
vehicle.setStatus("valid");
|
}
|
return accessVehicleMapper.insert(vehicle) > 0;
|
}
|
|
@Override
|
public boolean vehicleUpdate(AccessVehicle vehicle) {
|
return accessVehicleMapper.updateById(vehicle) > 0;
|
}
|
|
@Override
|
public boolean vehicleRemove(List<Long> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return false;
|
}
|
return accessVehicleMapper.deleteBatchIds(ids) > 0;
|
}
|
|
private AccessVehicle matchVehicle(String plateNumber, String rfidTag) {
|
AccessVehicle byPlate = null;
|
if (StringUtils.hasText(plateNumber)) {
|
byPlate = accessVehicleMapper.selectOne(Wrappers.<AccessVehicle>lambdaQuery()
|
.eq(AccessVehicle::getPlateNumber, plateNumber).last("limit 1"));
|
}
|
if (byPlate != null) {
|
return byPlate;
|
}
|
if (StringUtils.hasText(rfidTag)) {
|
return accessVehicleMapper.selectOne(Wrappers.<AccessVehicle>lambdaQuery()
|
.eq(AccessVehicle::getRfidTag, rfidTag).last("limit 1"));
|
}
|
return null;
|
}
|
|
/**
|
* 识别核验 + 放行判定 + 记录。
|
*
|
* 车辆：车牌识别 + RFID 双要素，识别到即放行；在车辆档案中的车辆补充承运商信息；
|
* 人员：人脸识别 + 工卡刷卡 双要素；
|
* 地磅联动：指定 weighbridgeRecordId 时，校验该地磅记录存在且红外检测无异常。
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public AccessRecord verify(AccessVerifyRequest request) {
|
AccessRecord record = new AccessRecord();
|
record.setAccessTime(LocalDateTime.now());
|
record.setGateId(request.getGateId());
|
record.setDirection(StringUtils.hasText(request.getDirection()) ? request.getDirection() : "in");
|
record.setCarrierName(request.getCarrierName());
|
record.setWeighbridgeRecordId(request.getWeighbridgeRecordId());
|
record.setWeighbridgeLinked(Boolean.TRUE.equals(request.getWeighbridgeLinked()) ? 1 : 0);
|
|
AccessGate gate = request.getGateId() == null ? null : accessGateMapper.selectById(request.getGateId());
|
if (gate != null) {
|
record.setGateName(gate.getGateName());
|
}
|
|
List<String> methods = new ArrayList<>();
|
List<String> rejects = new ArrayList<>();
|
boolean verified = false;
|
|
if ("person".equalsIgnoreCase(request.getAccessType())) {
|
record.setAccessType("person");
|
record.setPersonName(request.getPersonName());
|
record.setWorkCardNo(request.getWorkCardNo());
|
record.setIdCardFace(request.getIdCardFace());
|
if ("matched".equalsIgnoreCase(request.getIdCardFace())) {
|
methods.add("人脸识别");
|
}
|
if (StringUtils.hasText(request.getWorkCardNo())) {
|
methods.add("工卡");
|
}
|
// 双要素：人脸 + 工卡
|
if (!StringUtils.hasText(request.getPersonName()) || !"matched".equalsIgnoreCase(request.getIdCardFace())) {
|
rejects.add("人脸识别未通过");
|
}
|
if (!StringUtils.hasText(request.getWorkCardNo())) {
|
rejects.add("未刷工卡");
|
}
|
verified = rejects.isEmpty();
|
} else {
|
record.setAccessType("vehicle");
|
record.setPlateNumber(request.getPlateNumber());
|
record.setRfidTag(request.getRfidTag());
|
// 车牌识别 + RFID 双因子，识别到即视为通过；未登记车辆不拦截
|
if (StringUtils.hasText(request.getPlateNumber())) {
|
methods.add("车牌识别");
|
} else {
|
rejects.add("车牌识别失败");
|
}
|
if (StringUtils.hasText(request.getRfidTag())) {
|
methods.add("RFID");
|
} else {
|
rejects.add("RFID标签未识别");
|
}
|
if (rejects.isEmpty()) {
|
AccessVehicle vehicle = matchVehicle(request.getPlateNumber(), request.getRfidTag());
|
if (vehicle != null) {
|
if (!StringUtils.hasText(record.getCarrierName()) && StringUtils.hasText(vehicle.getCarrierName())) {
|
record.setCarrierName(vehicle.getCarrierName());
|
}
|
if ("disabled".equalsIgnoreCase(vehicle.getStatus())) {
|
rejects.add("该车辆通行授权已停用");
|
}
|
}
|
}
|
verified = rejects.isEmpty();
|
}
|
|
// 地磅联动校验
|
if (Boolean.TRUE.equals(request.getWeighbridgeLinked())) {
|
if (request.getWeighbridgeRecordId() == null) {
|
rejects.add("缺少关联地磅记录");
|
verified = false;
|
} else {
|
UnattendedOperation op = unattendedOperationService.getById(request.getWeighbridgeRecordId());
|
if (op == null) {
|
rejects.add("关联地磅记录不存在");
|
verified = false;
|
} else {
|
if (StringUtils.hasText(op.getCarrierName())) {
|
record.setCarrierName(op.getCarrierName());
|
}
|
if (op.getCheatFlag() != null && op.getCheatFlag() == 1) {
|
rejects.add("地磅检测异常:" + (op.getCheatReason() == null ? "车辆位置偏移" : op.getCheatReason()));
|
verified = false;
|
}
|
if ("alarm".equalsIgnoreCase(op.getInfraredStatus())) {
|
rejects.add("红外检测报警");
|
verified = false;
|
}
|
}
|
}
|
}
|
|
record.setVerifyMethod(methods.isEmpty() ? null : String.join("+", methods));
|
|
if (verified && rejects.isEmpty()) {
|
record.setVerifyResult("pass");
|
record.setReleaseStatus("released");
|
record.setRejectReason(null);
|
} else {
|
record.setVerifyResult("reject");
|
record.setReleaseStatus("blocked");
|
record.setRejectReason(String.join("；", rejects));
|
}
|
accessRecordMapper.insert(record);
|
|
if ("vehicle".equals(record.getAccessType()) && "released".equals(record.getReleaseStatus())) {
|
log.info("[门禁放行] 车牌={} 门禁={} 方式={}", record.getPlateNumber(), record.getGateName(), record.getVerifyMethod());
|
}
|
return record;
|
}
|
|
@Override
|
public IPage<AccessRecord> recordPage(Page<AccessRecord> page, AccessRecord query) {
|
LambdaQueryWrapper<AccessRecord> wrapper = Wrappers.<AccessRecord>lambdaQuery()
|
.like(StringUtils.hasText(query.getPlateNumber()), AccessRecord::getPlateNumber, query.getPlateNumber())
|
.like(StringUtils.hasText(query.getPersonName()), AccessRecord::getPersonName, query.getPersonName())
|
.eq(StringUtils.hasText(query.getAccessType()), AccessRecord::getAccessType, query.getAccessType())
|
.eq(StringUtils.hasText(query.getGateId() == null ? null : String.valueOf(query.getGateId())),
|
AccessRecord::getGateId, query.getGateId())
|
.orderByDesc(AccessRecord::getAccessTime);
|
return accessRecordMapper.selectPage(page, wrapper);
|
}
|
}
|
