From 8c28530cf4e15bf6cfb7ab80f52a9b9405bdc2dc Mon Sep 17 00:00:00 2001 From: wxyclub Date: Mon, 13 Nov 2023 20:04:09 +0800 Subject: [PATCH] =?UTF-8?q?bug:=20=E6=90=9C=E7=B4=A2=E4=B8=AD=E5=BF=83?= =?UTF-8?q?=E5=AD=97=E6=AE=B5=E6=8E=92=E5=BA=8F=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/adc/da/mq/SendBussMQService.java | 4 ++-- .../src/main/java/com/adc/da/mq/SendStandMQService.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/mq/SendBussMQService.java b/adc-da-slrs/src/main/java/com/adc/da/mq/SendBussMQService.java index 6d24d3fd..ccf787c4 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/mq/SendBussMQService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/mq/SendBussMQService.java @@ -133,8 +133,8 @@ public class SendBussMQService { Date putTime = null; try { putTime = sdf.parse(infoEO.getPutTime()); - String putTimeStr = String.valueOf(putTime.getTime() / 1000); - if (putTimeStr.length() > 9) { + String putTimeStr = String.valueOf(putTime.getTime()); + if (putTimeStr.length() > 12) { saveMap.put("put_time_data",putTimeStr); } else { saveMap.put("put_time_data","0" + putTimeStr); diff --git a/adc-da-slrs/src/main/java/com/adc/da/mq/SendStandMQService.java b/adc-da-slrs/src/main/java/com/adc/da/mq/SendStandMQService.java index 80256a6d..f0e8b79f 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/mq/SendStandMQService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/mq/SendStandMQService.java @@ -319,9 +319,9 @@ public class SendStandMQService { if (entry.getValue() != null && StringUtils.isNotBlank(entry.getValue().toString())) { try { Date parse = sdf.parse(entry.getValue().toString()); - value = String.valueOf(parse.getTime() / 1000); + value = String.valueOf(parse.getTime()); // ES中的排序问题，时间戳需要补0 - if (value.length() <= 9) { + if (value.length() <= 12) { value = "0" + value; } } catch (ParseException e) {