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) {