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