From 59e58e5206c254c2c25a868c643537cf0497a8e3 Mon Sep 17 00:00:00 2001 From: Joshi <3040996759@qq.com> Date: Mon, 8 Jun 2026 17:45:10 +0800 Subject: [PATCH 1/2] =?UTF-8?q?feat(warning):=20=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E9=92=A2=E5=8D=B7=E5=91=8A=E8=AD=A6=E6=A3=80=E6=9F=A5=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=E6=94=AF=E6=8C=81=E5=8A=A8=E6=80=81=E9=98=88=E5=80=BC?= =?UTF-8?q?=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在 WmsMaterialCoilBo 中新增 specThickness 字段用于存储规格厚度 - 修改 checkAndInsertWarnings 方法签名以传递 BO 对象 - 将长度和厚度告警阈值改为从系统配置表动态读取 - 长度告警阈值配置键为 material.warning.length,默认值 0.1 - 厚度告警阈值配置键为 material.warning.thickness,默认值 -0.01 - 厚度检查逻辑改为理论厚度与规格厚度对比 - 钢卷创建和更新流程中传递 BO 对象到告警检查方法 - 优化告警消息内容以反映阈值检查而非固定比例 - 移除原有的实测厚度检查规则,统一使用规格厚度作为参考标准 --- .../com/klp/domain/bo/WmsMaterialCoilBo.java | 5 + .../service/IWmsMaterialWarningService.java | 6 +- .../impl/WmsMaterialCoilServiceImpl.java | 13 +-- .../impl/WmsMaterialWarningServiceImpl.java | 99 +++++++++---------- 4 files changed, 62 insertions(+), 61 deletions(-) diff --git a/klp-wms/src/main/java/com/klp/domain/bo/WmsMaterialCoilBo.java b/klp-wms/src/main/java/com/klp/domain/bo/WmsMaterialCoilBo.java index 2ca363f0..93f5942a 100644 --- a/klp-wms/src/main/java/com/klp/domain/bo/WmsMaterialCoilBo.java +++ b/klp-wms/src/main/java/com/klp/domain/bo/WmsMaterialCoilBo.java @@ -382,6 +382,11 @@ public class WmsMaterialCoilBo extends BaseEntity { private Long specId; private Long versionId; + /** + * 规格厚度(单位:毫米),从规格字符串解析如 0.70*1250 中的 0.70,仅传参不持久化 + */ + private BigDecimal specThickness; + /** * 理论厚度(单位:毫米) */ diff --git a/klp-wms/src/main/java/com/klp/service/IWmsMaterialWarningService.java b/klp-wms/src/main/java/com/klp/service/IWmsMaterialWarningService.java index be80f90d..4ba2a2d0 100644 --- a/klp-wms/src/main/java/com/klp/service/IWmsMaterialWarningService.java +++ b/klp-wms/src/main/java/com/klp/service/IWmsMaterialWarningService.java @@ -2,6 +2,7 @@ package com.klp.service; import com.klp.domain.WmsMaterialCoil; import com.klp.domain.WmsMaterialWarning; +import com.klp.domain.bo.WmsMaterialCoilBo; import com.klp.domain.vo.WmsMaterialWarningVo; import com.klp.domain.bo.WmsMaterialWarningBo; import com.klp.common.core.page.TableDataInfo; @@ -52,7 +53,8 @@ public interface IWmsMaterialWarningService { * 检查钢卷长度/厚度偏差并批量插入告警记录 * 在 calculateTheoretical 计算出理论长度和理论厚度后调用 * - * @param coil 钢卷实体(需已填充 theoreticalLength/theoreticalThickness/actualLength/actualThickness/coilId) + * @param coil 钢卷实体 + * @param bo 钢卷BO(携带 specThickness 等临时计算值) */ - void checkAndInsertWarnings(WmsMaterialCoil coil); + void checkAndInsertWarnings(WmsMaterialCoil coil, WmsMaterialCoilBo bo); } diff --git a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialCoilServiceImpl.java b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialCoilServiceImpl.java index c4f7106d..e01000d7 100644 --- a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialCoilServiceImpl.java +++ b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialCoilServiceImpl.java @@ -1117,6 +1117,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { BigDecimal width = new BigDecimal(specWidth); BigDecimal volume = weight.multiply(new BigDecimal("1000")).divide(new BigDecimal("7.85"), 10, RoundingMode.HALF_UP); + bo.setSpecThickness(thickness); // 计算理论厚度(需要实测长度) if (bo.getTheoreticalThickness() == null && bo.getActualLength() != null) { BigDecimal length = new BigDecimal(bo.getActualLength()); @@ -1523,7 +1524,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { } // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(add); + materialWarningService.checkAndInsertWarnings(add, bo); // 设置返回用的ID并更新二维码内容中的coilId bo.setCoilId(add.getCoilId()); @@ -1738,7 +1739,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { } // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(updateCoil); + materialWarningService.checkAndInsertWarnings(updateCoil, bo); // 如果实际库区id为-1或状态为1,则清空钢卷上的实际库区绑定 if ((bo.getActualWarehouseId() != null && bo.getActualWarehouseId().equals(-1L)) @@ -1848,7 +1849,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { } // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(newCoil); + materialWarningService.checkAndInsertWarnings(newCoil, bo); // 如果实际库区id为-1,则清空钢卷上的实际库区绑定 if (bo.getActualWarehouseId() != null && bo.getActualWarehouseId().equals(-1L)) { @@ -2109,7 +2110,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { baseMapper.insert(newCoil); // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(newCoil); + materialWarningService.checkAndInsertWarnings(newCoil, newCoilBo); newCoils.add(newCoil); @@ -2251,7 +2252,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { baseMapper.insert(newCoil); // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(newCoil); + materialWarningService.checkAndInsertWarnings(newCoil, bo); newCoils.add(newCoil); @@ -5105,7 +5106,7 @@ public class WmsMaterialCoilServiceImpl implements IWmsMaterialCoilService { baseMapper.insert(childCoil); // 检查长度/厚度偏差并插入告警 - materialWarningService.checkAndInsertWarnings(childCoil); + materialWarningService.checkAndInsertWarnings(childCoil, childCoilBo); // 插入子钢卷的异常信息 if (childCoilBo.getAbnormals() != null && !childCoilBo.getAbnormals().isEmpty()) { diff --git a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java index 1278d7b0..1d28d9fc 100644 --- a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java +++ b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java @@ -6,6 +6,7 @@ import com.klp.common.core.domain.PageQuery; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.klp.common.core.service.ConfigService; import com.klp.common.utils.StringUtils; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -14,6 +15,7 @@ import com.klp.domain.bo.WmsMaterialWarningBo; import com.klp.domain.vo.WmsMaterialWarningVo; import com.klp.domain.WmsMaterialCoil; import com.klp.domain.WmsMaterialWarning; +import com.klp.domain.bo.WmsMaterialCoilBo; import com.klp.mapper.WmsMaterialWarningMapper; import com.klp.service.IWmsMaterialWarningService; @@ -36,6 +38,7 @@ import java.util.Collection; public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService { private final WmsMaterialWarningMapper baseMapper; + private final ConfigService configService; /** * 查询钢卷通用维度告警(长度/厚度/宽度) @@ -128,21 +131,21 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService /** * 检查钢卷长度/厚度偏差并批量插入告警记录 * - * 长度规则:ABS((实测长度 - 理论长度) / 理论长度) > 0.1 → 告警 - * 厚度规则: - * 1. 实测厚度 < 理论厚度 → 偏薄告警(ERROR) - * 2. (实测厚度 - 理论厚度) / 理论厚度 > 0.1 → 偏厚告警(WARNING) + * 长度规则:ABS((实测长度 - 理论长度) / 理论长度) > 阈值 → WARNING + * 阈值从 sys_config(material.warning.length) 读取,默认 0.1 + * 厚度规则:理论厚度 - 实测厚度 > 阈值 → ERROR + * 阈值从 sys_config(material.warning.thickness) 读取(绝对值差 mm),默认 -0.01 */ @Override - public void checkAndInsertWarnings(WmsMaterialCoil coil) { + public void checkAndInsertWarnings(WmsMaterialCoil coil, WmsMaterialCoilBo bo) { try { - doCheckAndInsertWarnings(coil); + doCheckAndInsertWarnings(coil, bo); } catch (Exception e) { log.error("钢卷告警检查异常, coilId={}, 不影响原流程", coil != null ? coil.getCoilId() : null, e); } } - private void doCheckAndInsertWarnings(WmsMaterialCoil coil) { + private void doCheckAndInsertWarnings(WmsMaterialCoil coil, WmsMaterialCoilBo bo) { if (coil == null || coil.getCoilId() == null) { return; } @@ -153,7 +156,7 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService checkLength(coil, warnings); // ========== 厚度检查 ========== - checkThickness(coil, warnings); + checkThickness(coil, bo, warnings); // 批量插入 if (!warnings.isEmpty()) { @@ -168,7 +171,8 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService /** * 长度偏差检查 - * ABS((actualLength - theoreticalLength) / theoreticalLength) > 0.1 → WARNING + * ABS((actualLength - theoreticalLength) / theoreticalLength) > 阈值 → WARNING + * 阈值从 sys_config(material.warning.length) 读取,默认 0.1 */ private void checkLength(WmsMaterialCoil coil, List warnings) { Long actualLength = coil.getActualLength(); @@ -179,12 +183,20 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService return; } + // 读取配置阈值,默认 0.1(10%) + BigDecimal threshold; + try { + String val = configService.getConfigValue("material.warning.length"); + threshold = StringUtils.isNotBlank(val) ? new BigDecimal(val.trim()) : new BigDecimal("0.1"); + } catch (Exception e) { + log.warn("读取长度告警阈值失败,使用默认值 0.1", e); + threshold = new BigDecimal("0.1"); + } + BigDecimal actual = new BigDecimal(actualLength); BigDecimal diff = actual.subtract(theoreticalLength).abs(); BigDecimal rate = diff.divide(theoreticalLength, 10, RoundingMode.HALF_UP); - // 偏差率 > 0.1(即超过10%) - BigDecimal threshold = new BigDecimal("0.1"); if (rate.compareTo(threshold) > 0) { WmsMaterialWarning warning = new WmsMaterialWarning(); warning.setCoilId(coil.getCoilId()); @@ -195,7 +207,7 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService warning.setDeviationValue(actual.subtract(theoreticalLength)); warning.setDeviationRate(rate.multiply(new BigDecimal("100")).setScale(4, RoundingMode.HALF_UP)); warning.setWarningLevel("WARNING"); - warning.setWarningMsg("钢卷长度偏差超过10%,理论长度=" + theoreticalLength + "m,实测长度=" + actualLength + "mm"); + warning.setWarningMsg("钢卷长度偏差超过阈值,理论长度=" + theoreticalLength + "m,实测长度=" + actualLength + "mm"); warning.setWarningStatus(0); warnings.add(warning); } @@ -203,62 +215,43 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService /** * 厚度偏差检查 - * 1. 实测厚度 < 理论厚度 → ERROR(不能比原来薄) - * 2. (实测厚度 - 理论厚度) / 理论厚度 > 0.1 → WARNING(不能厚太多) + * 规则:理论厚度 - 规格厚度 > 阈值 → WARNING + * 规格厚度从 BO 中取得(calculateTheoretical 已解析) + * 阈值从 sys_config(material.warning.thickness) 读取,默认 -0.01 */ - private void checkThickness(WmsMaterialCoil coil, List warnings) { - String actualThicknessStr = coil.getActualThickness(); + private void checkThickness(WmsMaterialCoil coil, WmsMaterialCoilBo bo, List warnings) { BigDecimal theoreticalThickness = coil.getTheoreticalThickness(); - - if (actualThicknessStr == null || theoreticalThickness == null - || theoreticalThickness.compareTo(BigDecimal.ZERO) == 0) { + BigDecimal specThickness = bo != null ? bo.getSpecThickness() : null; + if (theoreticalThickness == null || specThickness == null + || specThickness.compareTo(BigDecimal.ZERO) == 0) { return; } - BigDecimal actualThickness; + // 读取配置阈值(单位 mm),默认 -0.01 + BigDecimal threshold; try { - actualThickness = new BigDecimal(actualThicknessStr.trim()); - } catch (NumberFormatException e) { - log.warn("实测厚度无法解析为数值, coilId={}, actualThickness={}", coil.getCoilId(), actualThicknessStr); - return; + String val = configService.getConfigValue("material.warning.thickness"); + threshold = StringUtils.isNotBlank(val) ? new BigDecimal(val.trim()) : new BigDecimal("-0.01"); + } catch (Exception e) { + log.warn("读取厚度告警阈值失败,使用默认值 -0.01", e); + threshold = new BigDecimal("-0.01"); } - BigDecimal threshold = new BigDecimal("0.1"); - - // 规则1:实测厚度 < 理论厚度 → 偏薄 ERROR - if (actualThickness.compareTo(theoreticalThickness) < 0) { + // 理论厚度 - 规格厚度 > 阈值 → 触发 + BigDecimal diff = theoreticalThickness.subtract(specThickness); + if (diff.compareTo(threshold) > 0) { WmsMaterialWarning warning = new WmsMaterialWarning(); warning.setCoilId(coil.getCoilId()); warning.setWarningType("THICKNESS"); warning.setTheoreticalVal(theoreticalThickness); - warning.setActualVal(actualThickness); - warning.setAllowDeviation(BigDecimal.ZERO); - warning.setDeviationValue(actualThickness.subtract(theoreticalThickness)); - BigDecimal rate = theoreticalThickness.subtract(actualThickness) - .divide(theoreticalThickness, 10, RoundingMode.HALF_UP) + warning.setActualVal(specThickness); + warning.setAllowDeviation(threshold); + warning.setDeviationValue(specThickness.subtract(theoreticalThickness)); + BigDecimal rate = diff.divide(specThickness, 10, RoundingMode.HALF_UP) .multiply(new BigDecimal("100")).setScale(4, RoundingMode.HALF_UP); warning.setDeviationRate(rate); - warning.setWarningLevel("ERROR"); - warning.setWarningMsg("钢卷实测厚度偏薄,理论厚度=" + theoreticalThickness + "mm,实测厚度=" + actualThickness + "mm"); - warning.setWarningStatus(0); - warnings.add(warning); - return; // 偏薄已经足够严重,不再重复判断偏厚 - } - - // 规则2:(实测厚度 - 理论厚度) / 理论厚度 > 0.1 → 偏厚超10% - BigDecimal diff = actualThickness.subtract(theoreticalThickness); - BigDecimal rate = diff.divide(theoreticalThickness, 10, RoundingMode.HALF_UP); - if (rate.compareTo(threshold) > 0) { - WmsMaterialWarning warning = new WmsMaterialWarning(); - warning.setCoilId(coil.getCoilId()); - warning.setWarningType("THICKNESS"); - warning.setTheoreticalVal(theoreticalThickness); - warning.setActualVal(actualThickness); - warning.setAllowDeviation(threshold); - warning.setDeviationValue(diff); - warning.setDeviationRate(rate.multiply(new BigDecimal("100")).setScale(4, RoundingMode.HALF_UP)); warning.setWarningLevel("WARNING"); - warning.setWarningMsg("钢卷实测厚度偏厚超过10%,理论厚度=" + theoreticalThickness + "mm,实测厚度=" + actualThickness + "mm"); + warning.setWarningMsg("钢卷厚度偏差超出允许范围,理论厚度=" + theoreticalThickness + "mm,规格厚度=" + specThickness + "mm"); warning.setWarningStatus(0); warnings.add(warning); } From 20966157c585d1610b0d5d9a24ab4d401672192c Mon Sep 17 00:00:00 2001 From: Joshi <3040996759@qq.com> Date: Mon, 8 Jun 2026 18:02:52 +0800 Subject: [PATCH 2/2] =?UTF-8?q?fix(wms):=20=E4=BF=AE=E6=AD=A3=E6=9D=90?= =?UTF-8?q?=E6=96=99=E9=A2=84=E8=AD=A6=E6=9C=8D=E5=8A=A1=E4=B8=AD=E7=9A=84?= =?UTF-8?q?=E6=95=B0=E5=80=BC=E7=B2=BE=E5=BA=A6=E8=AE=A1=E7=AE=97=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 为理论值、实际值、允许偏差和偏差值设置统一的3位小数精度 - 将偏差率计算精度从4位小数调整为1位小数 - 修正厚度偏差计算公式中的减法运算顺序 - 在警告消息中应用相同的数值精度格式化 - 确保所有BigDecimal运算都使用HALF_UP舍入模式 --- .../impl/WmsMaterialWarningServiceImpl.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java index 1d28d9fc..e4c92449 100644 --- a/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java +++ b/klp-wms/src/main/java/com/klp/service/impl/WmsMaterialWarningServiceImpl.java @@ -201,13 +201,13 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService WmsMaterialWarning warning = new WmsMaterialWarning(); warning.setCoilId(coil.getCoilId()); warning.setWarningType("LENGTH"); - warning.setTheoreticalVal(theoreticalLength); - warning.setActualVal(actual); - warning.setAllowDeviation(threshold); - warning.setDeviationValue(actual.subtract(theoreticalLength)); - warning.setDeviationRate(rate.multiply(new BigDecimal("100")).setScale(4, RoundingMode.HALF_UP)); + warning.setTheoreticalVal(theoreticalLength.setScale(3, RoundingMode.HALF_UP)); + warning.setActualVal(actual.setScale(3, RoundingMode.HALF_UP)); + warning.setAllowDeviation(threshold.setScale(3, RoundingMode.HALF_UP)); + warning.setDeviationValue(actual.subtract(theoreticalLength).setScale(3, RoundingMode.HALF_UP)); + warning.setDeviationRate(rate.multiply(new BigDecimal("100")).setScale(1, RoundingMode.HALF_UP)); warning.setWarningLevel("WARNING"); - warning.setWarningMsg("钢卷长度偏差超过阈值,理论长度=" + theoreticalLength + "m,实测长度=" + actualLength + "mm"); + warning.setWarningMsg("钢卷长度偏差超过阈值,理论长度=" + theoreticalLength.setScale(3, RoundingMode.HALF_UP) + "m,实测长度=" + actualLength + "mm"); warning.setWarningStatus(0); warnings.add(warning); } @@ -243,15 +243,15 @@ public class WmsMaterialWarningServiceImpl implements IWmsMaterialWarningService WmsMaterialWarning warning = new WmsMaterialWarning(); warning.setCoilId(coil.getCoilId()); warning.setWarningType("THICKNESS"); - warning.setTheoreticalVal(theoreticalThickness); - warning.setActualVal(specThickness); - warning.setAllowDeviation(threshold); - warning.setDeviationValue(specThickness.subtract(theoreticalThickness)); + warning.setTheoreticalVal(theoreticalThickness.setScale(3, RoundingMode.HALF_UP)); + warning.setActualVal(specThickness.setScale(3, RoundingMode.HALF_UP)); + warning.setAllowDeviation(threshold.setScale(3, RoundingMode.HALF_UP)); + warning.setDeviationValue(theoreticalThickness.subtract(specThickness).setScale(3, RoundingMode.HALF_UP)); BigDecimal rate = diff.divide(specThickness, 10, RoundingMode.HALF_UP) - .multiply(new BigDecimal("100")).setScale(4, RoundingMode.HALF_UP); + .multiply(new BigDecimal("100")).setScale(1, RoundingMode.HALF_UP); warning.setDeviationRate(rate); warning.setWarningLevel("WARNING"); - warning.setWarningMsg("钢卷厚度偏差超出允许范围,理论厚度=" + theoreticalThickness + "mm,规格厚度=" + specThickness + "mm"); + warning.setWarningMsg("钢卷厚度偏差超出允许范围,理论厚度=" + theoreticalThickness.setScale(3, RoundingMode.HALF_UP) + "mm,规格厚度=" + specThickness.setScale(3, RoundingMode.HALF_UP) + "mm"); warning.setWarningStatus(0); warnings.add(warning); }