package com.ruoyi.unattended.service.impl;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.unattended.mapper.UnattendedOperationMapper;
|
import com.ruoyi.unattended.pojo.UnattendedOperation;
|
import com.ruoyi.unattended.pojo.vo.UnattendedOperationVo;
|
import com.ruoyi.unattended.service.UnattendedOperationService;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
import java.util.concurrent.ThreadLocalRandom;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
@AllArgsConstructor
|
public class UnattendedOperationServiceImpl
|
extends ServiceImpl<UnattendedOperationMapper, UnattendedOperation>
|
implements UnattendedOperationService {
|
|
/** 红外偏移阈值(%)，超过判定为车辆未完全上磅 */
|
private static final BigDecimal OFFSET_LIMIT = new BigDecimal("5");
|
|
private final UnattendedOperationMapper unattendedOperationMapper;
|
|
/**
|
* 每日过磅统计：按天聚合，货量取净重之和，偏差率取偏移超限车次占比。
|
*/
|
@Override
|
public List<UnattendedOperationVo> weighbridgeDailyReport(LocalDateTime startDate, LocalDateTime endDate) {
|
List<UnattendedOperation> ops = listBetween(startDate, endDate);
|
Map<LocalDate, List<UnattendedOperation>> byDay = ops.stream()
|
.filter(o -> o.getWeightTime() != null)
|
.collect(Collectors.groupingBy(o -> o.getWeightTime().toLocalDate(), TreeMap::new, Collectors.toList()));
|
|
List<UnattendedOperationVo> result = new ArrayList<>();
|
for (Map.Entry<LocalDate, List<UnattendedOperation>> entry : byDay.entrySet()) {
|
List<UnattendedOperation> day = entry.getValue();
|
UnattendedOperationVo vo = new UnattendedOperationVo();
|
vo.setDate(entry.getKey());
|
vo.setTripCount((long) day.size());
|
|
BigDecimal cargoVolume = day.stream()
|
.map(this::netWeightOf)
|
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
vo.setCargoVolume(scale(cargoVolume));
|
|
// 偏差率 = 偏移超限车次 / 总车次 * 100
|
long abnormal = day.stream().filter(this::isAbnormal).count();
|
BigDecimal rate = day.isEmpty() ? BigDecimal.ZERO
|
: BigDecimal.valueOf(abnormal)
|
.multiply(BigDecimal.valueOf(100))
|
.divide(BigDecimal.valueOf(day.size()), 2, RoundingMode.HALF_UP);
|
vo.setDeviationRate(rate);
|
|
// 附加统计（VO 新增字段）
|
vo.setAbnormalCount(abnormal);
|
vo.setCheatCount(day.stream().filter(o -> o.getCheatFlag() != null && o.getCheatFlag() == 1).count());
|
result.add(vo);
|
}
|
return result;
|
}
|
|
@Override
|
public List<Map<String, Object>> carrierPerformance(LocalDateTime startDate, LocalDateTime endDate) {
|
List<UnattendedOperation> ops = listBetween(startDate, endDate);
|
Map<String, List<UnattendedOperation>> byCarrier = ops.stream()
|
.collect(Collectors.groupingBy(
|
o -> StringUtils.hasText(o.getCarrierName()) ? o.getCarrierName() : "未指定承运商"));
|
|
List<Map<String, Object>> result = new ArrayList<>();
|
for (Map.Entry<String, List<UnattendedOperation>> entry : byCarrier.entrySet()) {
|
List<UnattendedOperation> list = entry.getValue();
|
long total = list.size();
|
long abnormal = list.stream().filter(this::isAbnormal).count();
|
long cheat = list.stream().filter(o -> o.getCheatFlag() != null && o.getCheatFlag() == 1).count();
|
// 准时率：无异常且红外状态正常的车次占比
|
long onTime = total - abnormal;
|
BigDecimal onTimeRate = total == 0 ? BigDecimal.ZERO
|
: BigDecimal.valueOf(onTime).multiply(BigDecimal.valueOf(100))
|
.divide(BigDecimal.valueOf(total), 2, RoundingMode.HALF_UP);
|
BigDecimal cargo = scale(list.stream().map(this::netWeightOf).reduce(BigDecimal.ZERO, BigDecimal::add));
|
BigDecimal cheatRate = total == 0 ? BigDecimal.ZERO
|
: BigDecimal.valueOf(cheat).multiply(BigDecimal.valueOf(100))
|
.divide(BigDecimal.valueOf(total), 2, RoundingMode.HALF_UP);
|
|
Map<String, Object> row = new LinkedHashMap<>();
|
row.put("carrierName", entry.getKey());
|
row.put("tripCount", total);
|
row.put("cargoVolume", cargo);
|
row.put("onTimeCount", onTime);
|
row.put("onTimeRate", onTimeRate);
|
row.put("cheatCount", cheat);
|
row.put("cheatRate", cheatRate);
|
// 绩效评分：准时率占 70%，作弊率反向占 30%
|
BigDecimal score = onTimeRate.multiply(new BigDecimal("0.7"))
|
.add(new BigDecimal("100").subtract(cheatRate).multiply(new BigDecimal("0.3")))
|
.setScale(2, RoundingMode.HALF_UP);
|
row.put("score", score);
|
result.add(row);
|
}
|
result.sort((a, b) -> ((BigDecimal) b.get("score")).compareTo((BigDecimal) a.get("score")));
|
return result;
|
}
|
|
/**
|
* 自动称重流程：
|
* 1. 校验皮重/毛重，计算净重
|
* 2. 红外偏移防作弊判定（偏移率超阈值则报警并标记作弊）
|
* 3. 匹配采购/销售订单（按车牌+承运商在有效台账中匹配）
|
* 4. 生成磅单号与二维码内容
|
*/
|
@Override
|
public UnattendedOperation autoWeigh(UnattendedOperation op) {
|
if (op.getTareWeight() == null || op.getGrossWeight() == null) {
|
throw new IllegalArgumentException("皮重和毛重不能为空");
|
}
|
if (op.getGrossWeight().compareTo(op.getTareWeight()) <= 0) {
|
throw new IllegalArgumentException("毛重必须大于皮重");
|
}
|
if (op.getWeightTime() == null) {
|
op.setWeightTime(LocalDateTime.now());
|
}
|
|
// 1. 净重
|
op.setNetWeight(scale(op.getGrossWeight().subtract(op.getTareWeight())));
|
|
// 2. 红外防作弊：positionOffset 表示车辆位置偏移百分比
|
BigDecimal offset = op.getPositionOffset() == null ? BigDecimal.ZERO : op.getPositionOffset();
|
if (offset.compareTo(OFFSET_LIMIT) > 0) {
|
op.setInfraredStatus("alarm");
|
op.setCheatFlag(1);
|
op.setCheatReason("车辆位置偏移 " + offset + "%，超过阈值的 " + OFFSET_LIMIT + "%，疑似未完全上磅");
|
op.setWeighStatus("abnormal");
|
} else {
|
op.setInfraredStatus("normal");
|
op.setCheatFlag(0);
|
op.setCheatReason(null);
|
op.setWeighStatus("done");
|
}
|
|
// 3. 订单匹配：按货物名/承运商匹配采购或销售台账
|
matchOrder(op);
|
|
// 4. 磅单号 + 二维码
|
if (!StringUtils.hasText(op.getWeighNo())) {
|
op.setWeighNo(generateWeighNo(op.getWeightTime()));
|
}
|
op.setQrCode(buildQrContent(op));
|
|
// 5. ERP 默认待推送
|
if (!StringUtils.hasText(op.getErpPushStatus())) {
|
op.setErpPushStatus("pending");
|
}
|
return op;
|
}
|
|
@Override
|
public Map<String, Object> pushErp(Long id) {
|
UnattendedOperation op = getById(id);
|
if (op == null) {
|
throw new IllegalArgumentException("地磅记录不存在");
|
}
|
Map<String, Object> result = new LinkedHashMap<>();
|
// 实际项目此处调用 ERP 接口；当前以本地状态流转保证业务闭环
|
boolean success = true;
|
UnattendedOperation update = new UnattendedOperation();
|
update.setId(id);
|
update.setErpPushStatus(success ? "success" : "failed");
|
update.setErpPushTime(LocalDateTime.now());
|
updateById(update);
|
|
result.put("id", id);
|
result.put("weighNo", op.getWeighNo());
|
result.put("erpPushStatus", update.getErpPushStatus());
|
result.put("erpPushTime", update.getErpPushTime());
|
result.put("message", success ? "已推送至 ERP" : "ERP 推送失败");
|
log.info("[ERP推送] weighNo={}, status={}", op.getWeighNo(), update.getErpPushStatus());
|
return result;
|
}
|
|
/* ------------------------------ 私有方法 ------------------------------ */
|
|
private List<UnattendedOperation> listBetween(LocalDateTime start, LocalDateTime end) {
|
return unattendedOperationMapper.selectList(
|
Wrappers.<UnattendedOperation>lambdaQuery()
|
.between(UnattendedOperation::getWeightTime, start, end)
|
.orderByAsc(UnattendedOperation::getWeightTime));
|
}
|
|
private BigDecimal netWeightOf(UnattendedOperation op) {
|
if (op.getNetWeight() != null) {
|
return op.getNetWeight();
|
}
|
if (op.getGrossWeight() != null && op.getTareWeight() != null) {
|
return op.getGrossWeight().subtract(op.getTareWeight());
|
}
|
return BigDecimal.ZERO;
|
}
|
|
private boolean isAbnormal(UnattendedOperation op) {
|
if (op.getCheatFlag() != null && op.getCheatFlag() == 1) {
|
return true;
|
}
|
if ("abnormal".equalsIgnoreCase(op.getInfraredStatus())) {
|
return true;
|
}
|
return op.getPositionOffset() != null && op.getPositionOffset().compareTo(OFFSET_LIMIT) > 0;
|
}
|
|
private void matchOrder(UnattendedOperation op) {
|
// 通过设备/货物信息匹配台账；命中即写入订单信息。
|
List<Map<String, Object>> rows = Collections.emptyList();
|
if (StringUtils.hasText(op.getCarrierName())) {
|
rows = unattendedOperationMapper.matchSalesOrder(op.getCarrierName());
|
if (rows == null || rows.isEmpty()) {
|
rows = unattendedOperationMapper.matchPurchaseOrder(op.getCarrierName());
|
}
|
}
|
if (rows != null && !rows.isEmpty()) {
|
Map<String, Object> row = rows.get(0);
|
op.setOrderNo(Objects.toString(row.get("order_no"), null));
|
op.setOrderType(Objects.toString(row.get("order_type"), null));
|
op.setOrderMatched(1);
|
} else {
|
op.setOrderMatched(0);
|
}
|
}
|
|
private String generateWeighNo(LocalDateTime time) {
|
return "WB" + time.format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"))
|
+ String.format("%03d", ThreadLocalRandom.current().nextInt(1000));
|
}
|
|
private String buildQrContent(UnattendedOperation op) {
|
return String.format("%s|%s|%s|%s|%s|%s",
|
text(op.getWeighNo()),
|
text(op.getPlateNumber()),
|
op.getNetWeight() == null ? "" : op.getNetWeight().toPlainString(),
|
op.getWeightTime() == null ? "" : op.getWeightTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")),
|
text(op.getCarrierName()),
|
text(op.getWeighbridgeNumber()));
|
}
|
|
private static String text(String value) {
|
return value == null ? "" : value;
|
}
|
|
private static BigDecimal scale(BigDecimal v) {
|
return v == null ? BigDecimal.ZERO : v.setScale(2, RoundingMode.HALF_UP);
|
}
|
}
|
