From a9cbca0c002cdc270a0642c125d879aad456f72c Mon Sep 17 00:00:00 2001 From: wxyclub Date: Mon, 13 Nov 2023 19:47:41 +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 --- .../java/com/adc/da/mq/SendBussMQService.java | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 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 74610dcb..6d24d3fd 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 @@ -130,11 +130,17 @@ public class SendBussMQService { } if (put_time_data != null) { // ES对比按照字符串比较，因此9位时间戳前加0 - String putTimeStr = String.valueOf(infoEO.getPutTime()); - if (putTimeStr.length() > 9) { - saveMap.put("put_time_data",putTimeStr); - } else { - saveMap.put("put_time_data","0" + putTimeStr); + Date putTime = null; + try { + putTime = sdf.parse(infoEO.getPutTime()); + String putTimeStr = String.valueOf(putTime.getTime() / 1000); + if (putTimeStr.length() > 9) { + saveMap.put("put_time_data",putTimeStr); + } else { + saveMap.put("put_time_data","0" + putTimeStr); + } + } catch (ParseException e) { + saveMap.put("put_time_data",-1000000000000000000L); } }else{ saveMap.put("put_time_data",-1000000000000000000L);