diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java index a57a611..c3aa107 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java +++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java @@ -220,13 +220,9 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService { } } else { List communicateDataOld = communicateFeignClient.getRawDataEnd(lineParam).getData(); - if (communicateDataOld.size() > 0) { - DateTime parse = DateUtil.parse(communicateDataOld.get(0).getTime()); - long differ = DateUtil.between(date, parse, DateUnit.MINUTE); - if (offline.equals(communicateDataOld.get(0).getType())) { - minute = (int) differ; - }else{ - minute = (int) (InfluxDBPublicParam.DAY_MINUTE-differ); + if (communicateDataOld.size() > 0){ + if (online.equals(communicateDataOld.get(0).getType())){ + minute = InfluxDBPublicParam.DAY_MINUTE; } } }