diff --git a/src/main/java/com/techsor/datacenter/sender/service/CsdjService.java b/src/main/java/com/techsor/datacenter/sender/service/CsdjService.java index ccfb460..3cfe7de 100644 --- a/src/main/java/com/techsor/datacenter/sender/service/CsdjService.java +++ b/src/main/java/com/techsor/datacenter/sender/service/CsdjService.java @@ -45,6 +45,12 @@ public class CsdjService { public void handle(CsdjEntity csdjEntity) { try { + // terminalId 不足3位左侧补0 + String tid = csdjEntity.getTerminalId(); + if (tid != null && tid.length() < 3) { + csdjEntity.setTerminalId(String.format("%3s", tid).replace(' ', '0')); + } + log.info("[CSDJ] 开始处理 CSDJ 数据,terminalId:{}, data:{}", csdjEntity.getTerminalId(), csdjEntity.getData());