diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java index 9f55f3c64..4ea4ff7d5 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java @@ -298,9 +298,6 @@ public class AreaLineServiceImpl implements AreaLineService { return TerminalRunningVO.empty(); } -// List pqsOnlinerateList = pqsOnlinerateQuery.selectList(Arrays.asList("dev_id", "offlinemin", "onlinemin"), -// devIdOr(deviceIndexList), -// timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime()))); List pqsOnlinerateList = rStatOnlinerateDMapper.getOnlineRateByDevIds(deviceIndexList,beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime())); List pqDeviceList = pqDeviceMapper.queryRunFlagByDeviceIndexs(deviceIndexList); @@ -328,8 +325,7 @@ public class AreaLineServiceImpl implements AreaLineService { } terminalRunningInfoVO.setOnlineRate(computingDeviceOnlineRate(pqsOnlinerateList).apply(deviceIndexes)); return terminalRunningInfoVO; - }).sorted(TerminalRunningInfoVO.sortAscAreaName()) - .collect(Collectors.toCollection(() -> Collections.synchronizedList(new ArrayList<>()))); + }).collect(Collectors.toCollection(() -> Collections.synchronizedList(new ArrayList<>()))); Integer terminalSum = terminalRun.stream().mapToInt(TerminalRunningInfoVO::getNumberOfTerminals) .sum(); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java index 670d8bd4d..88e8dafae 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java @@ -53,9 +53,8 @@ import static org.influxdb.querybuilder.BuiltQuery.QueryBuilder.ne; public class AreaStatisticalServiceImpl implements AreaStatisticalService { private final GeneralDeviceInfoClient generalDeviceInfoClient; - private final PqsEventDetailQuery pqsEventDetailQuery; - private final EventDetailService eventDetailService; + private final DicDataFeignClient dicDataFeignClient; /** @@ -70,7 +69,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { DictData data = dicDataFeignClient.getDicDataByCode(DicDataEnum.RECORDING_WAVE.getCode()).getData(); // 获取指定部门下的监测点集合 - List generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData(); + List generalDeviceDTOList = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData(); if (CollUtil.isEmpty(generalDeviceDTOList)) { return AreaStatisticalVO.empty(); } @@ -78,12 +77,6 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { if (CollUtil.isEmpty(lineIds)) { return AreaStatisticalVO.empty(); } - -// List clauseList = new ArrayList<>(timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime()))); -// clauseList.add(ne("wave_type",5)); -// List cc = pqsEventDetailQuery.selectList(Arrays.asList("line_id", "eventass_index"), -// lineIdOr(lineIds),clauseList); - //数据暂降查询 List info = eventDetailService.list(new LambdaQueryWrapper() .in(RmpEventDetailPO::getMeasurementPointId, lineIds) @@ -103,7 +96,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { deviceInfoParam.getStatisticalType().setCode(StatisticsEnum.VOLTAGE_LEVEL.getCode()); - List voltageLevelList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData(); + List voltageLevelList = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData(); VoltageStatisticsVO voltageStatisticsVO = statisticalVoltageLevelInfo(voltageLevelList, eventDetailList); return AreaStatisticalVO.buildVO(areaStatisticsVO, voltageStatisticsVO, monthCalculationVOS); @@ -201,7 +194,7 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService { calculationVO.computeSarfi90(); return calculationVO; - }).sorted(AreaCalculationVO.sortAscAreaName()).collect(Collectors.toCollection(() -> Collections.synchronizedList(new ArrayList<>()))); + }).collect(Collectors.toCollection(() -> Collections.synchronizedList(new ArrayList<>()))); // 求和暂降次数 Long frequencySum = areaCalculation.stream().mapToLong(AreaCalculationVO::getFrequency).sum(); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java index a58aeae28..a7df7f2db 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java @@ -200,6 +200,8 @@ public class TransientServiceImpl implements TransientService { ip=monitorVO.getIp(); } + + System.out.println(eventDetail.getEventId()); String waveName = eventDetail.getWavePath(); String cfgPath, datPath; if (generalInfo.getBusinessFileStorage() == GeneralConstant.LOCAL_DISK) { @@ -215,7 +217,9 @@ public class TransientServiceImpl implements TransientService { } else { cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG; datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT; + System.out.println("波形路径-------------------"+cfgPath); try ( + InputStream cfgStream = fileStorageUtil.downloadStream(cfgPath); InputStream datStream = fileStorageUtil.downloadStream(datPath) ) { diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/ExportModelController.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/ExportModelController.java index 384220c8e..61c45cefe 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/ExportModelController.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/ExportModelController.java @@ -35,6 +35,7 @@ import sun.misc.BASE64Encoder; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.text.SimpleDateFormat; +import java.time.LocalDateTime; import java.util.*; @@ -177,6 +178,13 @@ public class ExportModelController extends BaseController { } catch (Exception e1) { log.info("获取报表发生异常,异常是" + e1.getMessage()); } + + log.error(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); + log.info(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); + log.error(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); + log.info(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); + log.error(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); + log.info(LocalDateTime.now()+"----------------------------------rtfPath"+rtfPath); File tmpfile = new File(rtfPath); if (!tmpfile.exists()) { return "pathfail";