| | |
| | | public List<InfluxModelResultVO> queryModelResults(InfluxModelResultPOJO pojo, Date startTime, Date endTime) { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.set(Calendar.MILLISECOND, 0); |
| | | String start = startTime.getTime() - calendar.getTime().getTime() + "ms"; |
| | | if (endTime==null){ |
| | | endTime= new Date(); |
| | | String start = startTime.toInstant().toString(); |
| | | |
| | | if (startTime.getTime() == endTime.getTime()) { |
| | | // 如果相等,则engTime加1毫秒,负责influxdb报错(因为influxdb的range函数是左闭右开区间,所以将engTime加一毫秒,才可以查到startTime时间点的数据) |
| | | endTime.setTime(endTime.getTime() + 1); |
| | | } |
| | | String stop = endTime.getTime() - calendar.getTime().getTime() + "ms"; |
| | | String stop = endTime.toInstant().toString(); |
| | | |
| | | List<InfluxModelResultVO> dataList = new ArrayList<>(); |
| | | String measurement = MeasurementUtils.getMeasurement(pojo.getType()); |