From 6870c2ccc3212e643739126fa9f5649ab9efe059 Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Wed, 22 Jun 2022 09:14:52 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=96=B0=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../njcn/common/pojo/constant/ServerInfo.java | 1 +
.../common/pojo/enums/common/ServerEnum.java | 2 +
.../com/njcn/common/utils/wave/AnalyWave.java | 2 +-
pqs-common/common-echarts/pom.xml | 4 +
.../njcn/influxdb/utils/InfluxDbUtils.java | 2 -
.../common-influxdb/src/test/java/test.java | 230 ++-
pqs-common/common-poi/pom.xml | 4 +
.../swagger/config/Knife4jSwaggerConfig.java | 3 +-
.../java/com/njcn/web/utils/RequestUtil.java | 3 +-
pqs-common/pom.xml | 3 +-
.../njcn/device/pojo/param/TerminalParam.java | 33 +
.../device/pojo/vo/LineDistributionVO.java | 13 +-
.../device/pojo/vo/TerminalMaintainVO.java | 2 +
.../controller/ProgramVersionController.java | 11 +
.../TerminalMaintainController.java | 36 +-
.../device/mapper/ProgramVersionMapper.java | 5 +
.../mapper/mapping/ProgramVersionMapper.xml | 7 +-
.../mapper/mapping/TerminalMaintainMapper.xml | 10 +-
.../device/service/ProgramVersionService.java | 6 +
.../service/TerminalMaintainService.java | 12 +-
.../device/service/impl/LineServiceImpl.java | 28 +-
.../impl/ProgramVersionServiceImpl.java | 9 +
.../service/impl/TerminalBaseServiceImpl.java | 214 +--
.../impl/TerminalMaintainServiceImpl.java | 55 +-
.../service/impl/HighAnalyticServiceImpl.java | 13 +-
pqs-gateway/src/main/resources/bootstrap.yml | 8 +
.../impl/HistoryResultServiceImpl.java | 175 +-
pqs-quality/pom.xml | 26 +
pqs-quality/quality-api/pom.xml | 45 +
.../api/EleAirStrategyFeignClient.java | 27 +
.../quality/api/EleIntegrityFeignClient.java | 27 +
.../quality/api/EleOnlineRateFeignClient.java | 26 +
.../EleAirStrategyFallbackFactory.java | 41 +
.../fallback/EleIntegrityFallbackFactory.java | 48 +
.../EleOnlineRateFallbackFactory.java | 44 +
.../quality/enums/EleStatisticalSetEnum.java | 26 +
.../quality/enums/EnergyResponseEnum.java | 79 +
.../java/com/njcn/quality/enums/LoadEnum.java | 33 +
.../njcn/quality/param/AirStrategyParam.java | 90 +
.../njcn/quality/param/DataArrayParam.java | 57 +
.../njcn/quality/param/DataGroupParam.java | 28 +
.../com/njcn/quality/param/DataHisParam.java | 33 +
.../njcn/quality/param/DataModelParam.java | 71 +
.../com/njcn/quality/param/DataSetParam.java | 72 +
.../com/njcn/quality/param/DevCfgParam.java | 117 ++
.../njcn/quality/param/DevLineQueryParam.java | 33 +
.../njcn/quality/param/DevVersionParam.java | 87 +
.../com/njcn/quality/param/DictParam.java | 67 +
.../njcn/quality/param/ElDataBindParam.java | 18 +
.../java/com/njcn/quality/param/EleParam.java | 25 +
.../njcn/quality/param/ElectComparaParam.java | 58 +
.../njcn/quality/param/EnergyBaseParam.java | 45 +
.../com/njcn/quality/param/GroupArrParam.java | 36 +
.../com/njcn/quality/param/HardwareParam.java | 107 ++
.../com/njcn/quality/param/JobInfoParam.java | 21 +
.../com/njcn/quality/param/LineParam.java | 87 +
.../quality/param/LoadStatisticParam.java | 54 +
.../com/njcn/quality/param/NetDevParam.java | 108 ++
.../njcn/quality/pojo/constant/ApiParam.java | 59 +
.../njcn/quality/pojo/constant/DataType.java | 68 +
.../quality/pojo/constant/ModelState.java | 58 +
.../njcn/quality/pojo/constant/TableName.java | 21 +
.../com/njcn/quality/pojo/dto/ACtrlDTO.java | 42 +
.../com/njcn/quality/pojo/dto/AccessDTO.java | 53 +
.../njcn/quality/pojo/dto/AccessParamDTO.java | 25 +
.../njcn/quality/pojo/dto/AirStrategyDTO.java | 29 +
.../com/njcn/quality/pojo/dto/AlmDTO.java | 28 +
.../com/njcn/quality/pojo/dto/AskDataDTO.java | 47 +
.../quality/pojo/dto/AskDataParamDTO.java | 25 +
.../com/njcn/quality/pojo/dto/CpuInfoDTO.java | 29 +
.../com/njcn/quality/pojo/dto/CtrlDTO.java | 48 +
.../com/njcn/quality/pojo/dto/CuDevDTO.java | 25 +
.../com/njcn/quality/pojo/dto/CuIdDTO.java | 27 +
.../njcn/quality/pojo/dto/DataArrayDTO.java | 24 +
.../quality/pojo/dto/DataArrayListDTO.java | 21 +
.../com/njcn/quality/pojo/dto/DataSetDTO.java | 40 +
.../com/njcn/quality/pojo/dto/DevCfgDTO.java | 27 +
.../com/njcn/quality/pojo/dto/DevDTO.java | 79 +
.../com/njcn/quality/pojo/dto/DevInfoDTO.java | 32 +
.../com/njcn/quality/pojo/dto/DeviceDTO.java | 67 +
.../quality/pojo/dto/DeviceOperateDTO.java | 28 +
.../java/com/njcn/quality/pojo/dto/DiDTO.java | 21 +
.../njcn/quality/pojo/dto/DiskInfoDTO.java | 27 +
.../java/com/njcn/quality/pojo/dto/DoDTO.java | 29 +
.../njcn/quality/pojo/dto/ElePublicDTO.java | 20 +
.../com/njcn/quality/pojo/dto/EpdPqdDTO.java | 46 +
.../com/njcn/quality/pojo/dto/EvtDTO.java | 30 +
.../com/njcn/quality/pojo/dto/EvtParam.java | 31 +
.../com/njcn/quality/pojo/dto/LineDTO.java | 50 +
.../java/com/njcn/quality/pojo/dto/MdDTO.java | 43 +
.../com/njcn/quality/pojo/dto/MemInfoDTO.java | 26 +
.../quality/pojo/dto/NetAndDevByLineDTO.java | 18 +
.../com/njcn/quality/pojo/dto/NetDevDTO.java | 60 +
.../njcn/quality/pojo/dto/OnlineRateDTO.java | 27 +
.../com/njcn/quality/pojo/dto/ParamDTO.java | 49 +
.../njcn/quality/pojo/dto/PublicParamDTO.java | 42 +
.../njcn/quality/pojo/dto/RegisterDTO.java | 51 +
.../quality/pojo/dto/RegisterParamDTO.java | 50 +
.../njcn/quality/pojo/dto/SoftInfoDTO.java | 36 +
.../com/njcn/quality/pojo/dto/StsDTO.java | 36 +
.../njcn/quality/pojo/dto/TemplateDTO.java | 30 +
.../pojo/dto/TemplateDataArrayDTO.java | 32 +
.../com/njcn/quality/pojo/dto/ThreadDTO.java | 21 +
.../com/njcn/quality/pojo/dto/TopicDTO.java | 22 +
.../njcn/quality/pojo/dto/TopicParamDTO.java | 21 +
.../com/njcn/quality/pojo/dto/TpListDTO.java | 31 +
.../com/njcn/quality/pojo/dto/UserCfgDTO.java | 33 +
.../java/com/njcn/quality/pojo/po/AirSet.java | 19 +
.../com/njcn/quality/pojo/po/AirStrategy.java | 28 +
.../com/njcn/quality/pojo/po/DataArray.java | 83 +
.../com/njcn/quality/pojo/po/DataGroup.java | 36 +
.../com/njcn/quality/pojo/po/DataMould.java | 52 +
.../com/njcn/quality/pojo/po/DataSet.java | 46 +
.../com/njcn/quality/pojo/po/DevVersion.java | 53 +
.../java/com/njcn/quality/pojo/po/EleALM.java | 29 +
.../com/njcn/quality/pojo/po/EleActrl.java | 41 +
.../com/njcn/quality/pojo/po/EleBind.java | 22 +
.../com/njcn/quality/pojo/po/EleCtrl.java | 45 +
.../java/com/njcn/quality/pojo/po/EleDi.java | 37 +
.../com/njcn/quality/pojo/po/EleDict.java | 32 +
.../java/com/njcn/quality/pojo/po/EleDo.java | 39 +
.../com/njcn/quality/pojo/po/EleEpdPqd.java | 40 +
.../java/com/njcn/quality/pojo/po/EleEvt.java | 28 +
.../com/njcn/quality/pojo/po/EleEvtParm.java | 29 +
.../njcn/quality/pojo/po/EleInformation.java | 41 +
.../njcn/quality/pojo/po/EleIntegrity.java | 31 +
.../com/njcn/quality/pojo/po/EleLine.java | 91 +
.../com/njcn/quality/pojo/po/EleLoadSet.java | 18 +
.../com/njcn/quality/pojo/po/EleLogs.java | 51 +
.../java/com/njcn/quality/pojo/po/EleMd.java | 38 +
.../njcn/quality/pojo/po/EleOnlineRate.java | 28 +
.../com/njcn/quality/pojo/po/EleParm.java | 42 +
.../com/njcn/quality/pojo/po/EleRateSet.java | 20 +
.../quality/pojo/po/EleStatisticalSet.java | 18 +
.../java/com/njcn/quality/pojo/po/EleSts.java | 35 +
.../com/njcn/quality/pojo/po/EleTopic.java | 28 +
.../com/njcn/quality/pojo/po/GroupArray.java | 23 +
.../com/njcn/quality/pojo/po/Hardware.java | 132 ++
.../com/njcn/quality/pojo/po/LogicAccess.java | 34 +
.../com/njcn/quality/pojo/po/LogicDev.java | 133 ++
.../java/com/njcn/quality/pojo/po/NetDev.java | 81 +
.../njcn/quality/pojo/vo/AirStrategyVO.java | 49 +
.../quality/pojo/vo/DataGroupTemplateVO.java | 22 +
.../com/njcn/quality/pojo/vo/DataHisVO.java | 20 +
.../njcn/quality/pojo/vo/EleIntegrityVO.java | 47 +
.../quality/pojo/vo/EleLoadSetTreeVO.java | 20 +
.../njcn/quality/pojo/vo/EleLoadSetVO.java | 25 +
.../com/njcn/quality/pojo/vo/EleMdVO.java | 20 +
.../com/njcn/quality/pojo/vo/EleRateVO.java | 28 +
.../quality/pojo/vo/EleStatisticalTreeVO.java | 21 +
.../quality/pojo/vo/EleStatisticalVO.java | 23 +
.../njcn/quality/pojo/vo/ElectCompareVO.java | 23 +
.../quality/pojo/vo/EnergyDeviceTreeVO.java | 30 +
.../quality/pojo/vo/EnergyTemplateVO.java | 42 +
.../njcn/quality/pojo/vo/LoadStatisticVO.java | 19 +
.../njcn/quality/pojo/vo/LoadTendencyVO.java | 17 +
.../pojo/vo/LogicDeviceLineInfoVO.java | 74 +
.../njcn/quality/pojo/vo/NetDevInfoVO.java | 161 ++
.../njcn/quality/pojo/vo/YunCaiDataVO.java | 20 +
.../njcn/quality/utils/EnergyEnumUtil.java | 49 +
.../src/test/java/com/njcn/AppTest.java | 20 +
pqs-quality/quality-boot/pom.xml | 130 ++
.../njcn/quality/QualityBootApplication.java | 25 +
.../controller/DataArrayController.java | 62 +
.../controller/DataGroupController.java | 73 +
.../quality/controller/DataSetController.java | 73 +
.../controller/DevModelController.java | 75 +
.../controller/DevVersionController.java | 62 +
.../controller/EleActrlController.java | 70 +
.../controller/EleAirStrategyController.java | 196 ++
.../quality/controller/EleAlmController.java | 70 +
.../quality/controller/EleBindController.java | 72 +
.../quality/controller/EleCtrlController.java | 69 +
.../quality/controller/EleDiController.java | 70 +
.../quality/controller/EleDictController.java | 124 ++
.../quality/controller/EleDoController.java | 69 +
.../controller/EleEpdPqdController.java | 87 +
.../quality/controller/EleEvtController.java | 68 +
.../controller/EleEvtParamController.java | 88 +
.../controller/EleIntegrityController.java | 82 +
.../quality/controller/EleLineController.java | 74 +
.../controller/EleLoadSetController.java | 68 +
.../quality/controller/EleLogsController.java | 25 +
.../quality/controller/EleMdController.java | 72 +
.../controller/EleOnlineRateController.java | 77 +
.../quality/controller/EleParmController.java | 69 +
.../controller/EleRateSetController.java | 58 +
.../EleStatisticalSetController.java | 68 +
.../quality/controller/EleStsController.java | 68 +
.../controller/EleTopicController.java | 87 +
.../controller/GroupArrayController.java | 64 +
.../controller/HardwareController.java | 71 +
.../controller/HighAnalyticController.java | 188 ++
.../njcn/quality/controller/LogicAccess.java | 29 +
.../controller/LogicDeviceLineController.java | 294 +++
.../quality/controller/ModelController.java | 70 +
.../quality/controller/NetDevController.java | 141 ++
.../quality/handler/MqttMessageHandler.java | 182 ++
.../listener/RedisKeyExpirationListener.java | 76 +
.../com/njcn/quality/mapper/AirSetMapper.java | 13 +
.../quality/mapper/AirStrategyMapper.java | 13 +
.../njcn/quality/mapper/DataArrayMapper.java | 17 +
.../njcn/quality/mapper/DataGroupMapper.java | 28 +
.../njcn/quality/mapper/DataMouldMapper.java | 17 +
.../njcn/quality/mapper/DataSetMapper.java | 17 +
.../njcn/quality/mapper/DevVersionMapper.java | 7 +
.../njcn/quality/mapper/EleActrlMapper.java | 7 +
.../com/njcn/quality/mapper/EleAlmMapper.java | 10 +
.../njcn/quality/mapper/EleBindMapper.java | 24 +
.../njcn/quality/mapper/EleCtrlMapper.java | 7 +
.../com/njcn/quality/mapper/EleDiMapper.java | 7 +
.../njcn/quality/mapper/EleDictMapper.java | 10 +
.../com/njcn/quality/mapper/EleDoMapper.java | 7 +
.../com/njcn/quality/mapper/EleEpdMapper.java | 24 +
.../com/njcn/quality/mapper/EleEvtMapper.java | 7 +
.../quality/mapper/EleEvtParamMapper.java | 15 +
.../quality/mapper/EleInformationMapper.java | 10 +
.../quality/mapper/EleIntegrityMapper.java | 17 +
.../njcn/quality/mapper/EleLineMapper.java | 19 +
.../njcn/quality/mapper/EleLoadSetMapper.java | 37 +
.../njcn/quality/mapper/EleLogsMapper.java | 7 +
.../com/njcn/quality/mapper/EleMdMapper.java | 23 +
.../njcn/quality/mapper/EleParmMapper.java | 7 +
.../quality/mapper/EleRateSetMappser.java | 32 +
.../mapper/EleStatisticalSetMapper.java | 24 +
.../com/njcn/quality/mapper/EleStsMapper.java | 7 +
.../njcn/quality/mapper/EleTopicMapper.java | 7 +
.../njcn/quality/mapper/GroupArrayMapper.java | 10 +
.../njcn/quality/mapper/HardwareMapper.java | 17 +
.../quality/mapper/LogicAccessMapper.java | 10 +
.../quality/mapper/LogicDeviceLineMapper.java | 124 ++
.../com/njcn/quality/mapper/NetDevMapper.java | 36 +
.../mapper/mapping/DataGroupMapper.xml | 17 +
.../quality/mapper/mapping/EleBindMapper.xml | 19 +
.../mapper/mapping/EleEpdPqdMapper.xml | 41 +
.../mapper/mapping/EleIntergrityMapper.xml | 29 +
.../quality/mapper/mapping/EleLineMapper.xml | 15 +
.../mapper/mapping/EleLoadSetMapper.xml | 35 +
.../quality/mapper/mapping/EleMdMapper.xml | 31 +
.../mapper/mapping/EleRateSetMapper.xml | 34 +
.../mapping/EleStatisticalSetMapper.xml | 17 +
.../mapper/mapping/LogicDeviceLineMapper.xml | 188 ++
.../quality/mapper/mapping/NetDevMapper.xml | 19 +
.../service/EleAirStrategyService.java | 67 +
.../quality/service/EleLoadSetService.java | 30 +
.../quality/service/EleRateSetService.java | 24 +
.../service/EleStatisticalSetService.java | 38 +
.../quality/service/HighAnalyticService.java | 87 +
.../quality/service/IDataArrayService.java | 34 +
.../quality/service/IDataGroupService.java | 51 +
.../njcn/quality/service/IDataSetService.java | 44 +
.../quality/service/IDevModelService.java | 43 +
.../quality/service/IDevVersionService.java | 29 +
.../quality/service/IEleActrlService.java | 39 +
.../njcn/quality/service/IEleAlmService.java | 46 +
.../njcn/quality/service/IEleBindService.java | 37 +
.../njcn/quality/service/IEleCtrlService.java | 40 +
.../njcn/quality/service/IEleDiService.java | 39 +
.../njcn/quality/service/IEleDictService.java | 78 +
.../njcn/quality/service/IEleDoService.java | 40 +
.../quality/service/IEleEpdPqdService.java | 50 +
.../quality/service/IEleEvtParamService.java | 55 +
.../njcn/quality/service/IEleEvtService.java | 40 +
.../service/IEleInformationService.java | 50 +
.../quality/service/IEleIntegrityService.java | 26 +
.../njcn/quality/service/IEleLineService.java | 60 +
.../njcn/quality/service/IEleLogsService.java | 23 +
.../njcn/quality/service/IEleMdService.java | 41 +
.../njcn/quality/service/IEleParmService.java | 46 +
.../njcn/quality/service/IEleSetService.java | 13 +
.../njcn/quality/service/IEleStsService.java | 41 +
.../quality/service/IEleTopicService.java | 41 +
.../quality/service/IGroupArrayService.java | 43 +
.../quality/service/IHardwareService.java | 35 +
.../quality/service/ILogicAccessService.java | 136 ++
.../service/ILogicDeviceLineService.java | 217 +++
.../njcn/quality/service/IModelService.java | 61 +
.../njcn/quality/service/INetDevService.java | 96 +
.../service/impl/DataArrayServiceImpl.java | 38 +
.../service/impl/DataGroupServiceImpl.java | 45 +
.../service/impl/DataSetServiceImpl.java | 43 +
.../service/impl/DevModelServiceImpl.java | 40 +
.../service/impl/DevVersionServiceImpl.java | 37 +
.../service/impl/ELeParmServiceImpl.java | 32 +
.../service/impl/EleActrlServiceImpl.java | 32 +
.../service/impl/EleAirSetServiceImpl.java | 19 +
.../impl/EleAirStrategyServiceImpl.java | 483 +++++
.../service/impl/EleAlmServiceImpl.java | 32 +
.../service/impl/EleBindServiceImpl.java | 97 +
.../service/impl/EleCtrlServiceImpl.java | 32 +
.../service/impl/EleDiServiceImpl.java | 32 +
.../service/impl/EleDictServiceImpl.java | 146 ++
.../service/impl/EleDoServiceImpl.java | 32 +
.../service/impl/EleEpdPqdServiceImpl.java | 42 +
.../service/impl/EleEvtParamServiceImpl.java | 43 +
.../service/impl/EleEvtServiceImpl.java | 34 +
.../impl/EleInformationServiceImpl.java | 282 +++
.../service/impl/EleIntegrityServiceImpl.java | 208 +++
.../service/impl/EleLineServiceImpl.java | 55 +
.../service/impl/EleLoadSetServiceImpl.java | 52 +
.../service/impl/EleLogsServiceImpl.java | 24 +
.../service/impl/EleMdServiceImpl.java | 32 +
.../service/impl/EleRateSetServiceImpl.java | 34 +
.../impl/EleStatisticalSetServiceImpl.java | 113 ++
.../service/impl/EleStsServiceImpl.java | 32 +
.../service/impl/EleTopicServiceImpl.java | 38 +
.../service/impl/GroupArrayServiceImpl.java | 45 +
.../service/impl/HardwareServiceImpl.java | 38 +
.../service/impl/HighAnalyticServiceImpl.java | 1645 +++++++++++++++++
.../service/impl/LogicAccessServiceImpl.java | 122 ++
.../impl/LogicDeviceLineServiceImpl.java | 682 +++++++
.../service/impl/ModelServiceImpl.java | 1227 ++++++++++++
.../service/impl/NetDevServiceImpl.java | 144 ++
.../src/main/resources/bootstrap.yml | 57 +
.../src/test/java/com/njcn/AppTest.java | 20 +
.../com/njcn/system/api/AreaFeignClient.java | 3 +
.../AreaFeignClientFallbackFactory.java | 6 +
.../system/controller/AreaController.java | 13 +
.../com/njcn/system/mapper/AreaMapper.java | 9 +-
.../njcn/system/mapper/mapping/AreaMapper.xml | 15 +
.../com/njcn/system/service/IAreaService.java | 2 +
.../system/service/impl/AreaServiceImpl.java | 7 +
.../com/njcn/user/UserBootApplication.java | 3 +-
323 files changed, 18518 insertions(+), 441 deletions(-)
create mode 100644 pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/TerminalParam.java
create mode 100644 pqs-quality/pom.xml
create mode 100644 pqs-quality/quality-api/pom.xml
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleAirStrategyFeignClient.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleIntegrityFeignClient.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleOnlineRateFeignClient.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleAirStrategyFallbackFactory.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleIntegrityFallbackFactory.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleOnlineRateFallbackFactory.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/EleStatisticalSetEnum.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/EnergyResponseEnum.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/LoadEnum.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/AirStrategyParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataArrayParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataGroupParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataHisParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataModelParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataSetParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevCfgParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevLineQueryParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevVersionParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DictParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/ElDataBindParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/EleParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/ElectComparaParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/EnergyBaseParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/GroupArrParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/HardwareParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/JobInfoParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/LineParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/LoadStatisticParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/param/NetDevParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/ApiParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/DataType.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/ModelState.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/TableName.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ACtrlDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AccessDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AccessParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AirStrategyDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AlmDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AskDataDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AskDataParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CpuInfoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CtrlDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CuDevDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CuIdDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataArrayDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataArrayListDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataSetDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevCfgDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevInfoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DeviceDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DeviceOperateDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DiDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DiskInfoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ElePublicDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EpdPqdDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EvtDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EvtParam.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/LineDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/MdDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/MemInfoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/NetAndDevByLineDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/NetDevDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/OnlineRateDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/PublicParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/RegisterDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/RegisterParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/SoftInfoDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/StsDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TemplateDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TemplateDataArrayDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ThreadDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TopicDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TopicParamDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TpListDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/UserCfgDTO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/AirSet.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/AirStrategy.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataArray.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataGroup.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataMould.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataSet.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DevVersion.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleALM.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleActrl.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleBind.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleCtrl.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDi.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDict.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDo.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEpdPqd.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEvt.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEvtParm.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleInformation.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleIntegrity.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleLine.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleLoadSet.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleLogs.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleMd.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleOnlineRate.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleParm.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleRateSet.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleStatisticalSet.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleSts.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleTopic.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/GroupArray.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/Hardware.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/LogicAccess.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/LogicDev.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/NetDev.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/AirStrategyVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/DataGroupTemplateVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/DataHisVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleIntegrityVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleLoadSetTreeVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleLoadSetVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleMdVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleRateVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleStatisticalTreeVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EleStatisticalVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/ElectCompareVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EnergyDeviceTreeVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/EnergyTemplateVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/LoadStatisticVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/LoadTendencyVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/LogicDeviceLineInfoVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/NetDevInfoVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/vo/YunCaiDataVO.java
create mode 100644 pqs-quality/quality-api/src/main/java/com/njcn/quality/utils/EnergyEnumUtil.java
create mode 100644 pqs-quality/quality-api/src/test/java/com/njcn/AppTest.java
create mode 100644 pqs-quality/quality-boot/pom.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/QualityBootApplication.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/DataArrayController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/DataGroupController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/DataSetController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/DevModelController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/DevVersionController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleActrlController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleAirStrategyController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleAlmController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleBindController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleCtrlController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleDiController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleDictController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleDoController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleEpdPqdController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleEvtController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleEvtParamController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleIntegrityController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleLineController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleLoadSetController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleLogsController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleMdController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleOnlineRateController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleParmController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleRateSetController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleStatisticalSetController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleStsController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/EleTopicController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/GroupArrayController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/HardwareController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/HighAnalyticController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/LogicAccess.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/LogicDeviceLineController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/ModelController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/controller/NetDevController.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/handler/MqttMessageHandler.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/listener/RedisKeyExpirationListener.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/AirSetMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/AirStrategyMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/DataArrayMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/DataGroupMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/DataMouldMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/DataSetMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/DevVersionMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleActrlMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleAlmMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleBindMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleCtrlMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleDiMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleDictMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleDoMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleEpdMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleEvtMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleEvtParamMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleInformationMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleIntegrityMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleLineMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleLoadSetMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleLogsMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleMdMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleParmMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleRateSetMappser.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleStatisticalSetMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleStsMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/EleTopicMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/GroupArrayMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/HardwareMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/LogicAccessMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/LogicDeviceLineMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/NetDevMapper.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/DataGroupMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleBindMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleEpdPqdMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleIntergrityMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleLineMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleLoadSetMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleMdMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleRateSetMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/EleStatisticalSetMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/LogicDeviceLineMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/mapper/mapping/NetDevMapper.xml
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/EleAirStrategyService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/EleLoadSetService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/EleRateSetService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/EleStatisticalSetService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/HighAnalyticService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IDataArrayService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IDataGroupService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IDataSetService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IDevModelService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IDevVersionService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleActrlService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleAlmService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleBindService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleCtrlService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleDiService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleDictService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleDoService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleEpdPqdService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleEvtParamService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleEvtService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleInformationService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleIntegrityService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleLineService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleLogsService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleMdService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleParmService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleSetService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleStsService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IEleTopicService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IGroupArrayService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IHardwareService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/ILogicAccessService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/ILogicDeviceLineService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/IModelService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/INetDevService.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/DataArrayServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/DataGroupServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/DataSetServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/DevModelServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/DevVersionServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/ELeParmServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleActrlServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleAirSetServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleAirStrategyServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleAlmServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleBindServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleCtrlServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleDiServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleDictServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleDoServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleEpdPqdServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleEvtParamServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleEvtServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleInformationServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleIntegrityServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleLineServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleLoadSetServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleLogsServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleMdServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleRateSetServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleStatisticalSetServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleStsServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/EleTopicServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/GroupArrayServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/HardwareServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/HighAnalyticServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/LogicAccessServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/LogicDeviceLineServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/ModelServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/java/com/njcn/quality/service/impl/NetDevServiceImpl.java
create mode 100644 pqs-quality/quality-boot/src/main/resources/bootstrap.yml
create mode 100644 pqs-quality/quality-boot/src/test/java/com/njcn/AppTest.java
diff --git a/pqs-common/common-core/src/main/java/com/njcn/common/pojo/constant/ServerInfo.java b/pqs-common/common-core/src/main/java/com/njcn/common/pojo/constant/ServerInfo.java
index b263ce89d..637fb140f 100644
--- a/pqs-common/common-core/src/main/java/com/njcn/common/pojo/constant/ServerInfo.java
+++ b/pqs-common/common-core/src/main/java/com/njcn/common/pojo/constant/ServerInfo.java
@@ -22,5 +22,6 @@ public interface ServerInfo {
String JOB_ADMIN = "job-admin";
String USER = "user-boot";
String JOB = "job-admin";
+ String QUALITY = "quality-boot";
}
diff --git a/pqs-common/common-core/src/main/java/com/njcn/common/pojo/enums/common/ServerEnum.java b/pqs-common/common-core/src/main/java/com/njcn/common/pojo/enums/common/ServerEnum.java
index 00abad528..1a8023b91 100644
--- a/pqs-common/common-core/src/main/java/com/njcn/common/pojo/enums/common/ServerEnum.java
+++ b/pqs-common/common-core/src/main/java/com/njcn/common/pojo/enums/common/ServerEnum.java
@@ -23,6 +23,8 @@ public enum ServerEnum {
SUPERVISE("pqs-supervise", "技术监督管理服务模块"),
SYSTEM("system-boot", "系统配置服务模块"),
USER("user-boot", "用户服务模块"),
+ ENERGY("energy-boot", "用能服务模块"),
+ QUALITY("quality-boot", "电能质量服务模块"),
COMMON("pqs-common", "通用服务模块");
private final String name;
diff --git a/pqs-common/common-core/src/main/java/com/njcn/common/utils/wave/AnalyWave.java b/pqs-common/common-core/src/main/java/com/njcn/common/utils/wave/AnalyWave.java
index ac5d8b01b..c6bf04913 100644
--- a/pqs-common/common-core/src/main/java/com/njcn/common/utils/wave/AnalyWave.java
+++ b/pqs-common/common-core/src/main/java/com/njcn/common/utils/wave/AnalyWave.java
@@ -1109,7 +1109,7 @@ public class AnalyWave {
********************************************************/
AnalyWave analyWave = new AnalyWave();
// 获取瞬时波形
- WaveDataDTO waveDataDTO = analyWave.getComtrade("E:\\Comtrade\\PQMonitor_PQM1_106_20220301_101522_338.CFG", 1);//获取原始波形值
+ WaveDataDTO waveDataDTO = analyWave.getComtrade("C:\\Users\\陈超\\Desktop\\Comtrade\\192.168.0.58\\222.CFG", 1);//获取原始波形值
// 获取RMS波形
WaveDataDTO waveDataDTO1 = analyWave.getValidData(waveDataDTO);
// 获取特征值
diff --git a/pqs-common/common-echarts/pom.xml b/pqs-common/common-echarts/pom.xml
index e74a73f6d..39bdeba13 100644
--- a/pqs-common/common-echarts/pom.xml
+++ b/pqs-common/common-echarts/pom.xml
@@ -41,6 +41,10 @@
com.google.code.gson
gson
+
+ org.projectlombok
+ lombok
+
\ No newline at end of file
diff --git a/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/utils/InfluxDbUtils.java b/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/utils/InfluxDbUtils.java
index 0d71cd2ec..dcb93c635 100644
--- a/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/utils/InfluxDbUtils.java
+++ b/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/utils/InfluxDbUtils.java
@@ -1,7 +1,6 @@
package com.njcn.influxdb.utils;
-import cn.hutool.core.util.StrUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.influxdb.InfluxDB;
@@ -170,7 +169,6 @@ public class InfluxDbUtils {
builder.tag(tags);
builder.fields(fields);
if (0 != time) {
- time = time + 28800000;
builder.time(time, timeUnit);
}
influxDB.write(dbName, retentionPolicy, builder.build());
diff --git a/pqs-common/common-influxdb/src/test/java/test.java b/pqs-common/common-influxdb/src/test/java/test.java
index f7ef836d5..290179aab 100644
--- a/pqs-common/common-influxdb/src/test/java/test.java
+++ b/pqs-common/common-influxdb/src/test/java/test.java
@@ -1,8 +1,11 @@
+import cn.hutool.core.date.DateUtil;
+import com.njcn.event.pojo.po.EventDetail;
import com.njcn.influxdb.utils.InfluxDbUtils;
import org.influxdb.InfluxDB.ConsistencyLevel;
import org.influxdb.dto.BatchPoints;
import org.influxdb.dto.Point;
import org.influxdb.dto.QueryResult;
+import org.influxdb.impl.InfluxDBResultMapper;
import java.util.*;
import java.util.concurrent.TimeUnit;
@@ -21,9 +24,17 @@ public class test {
//查询
public static QueryResult select(InfluxDbUtils influxDBUtil) {
long startTime = System.currentTimeMillis();
- QueryResult result = influxDBUtil.query("select * from data_V where phasic_type='A'");
+ //组装sql语句
+ StringBuilder stringBuilder = new StringBuilder();
+ stringBuilder.append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse("2022-05-06"))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse("2022-05-06"))).append("' and (");
+ //sql语句
+ stringBuilder.append("line_id ='").append("1e3b8531483b2a8cbee6747f1f641cf9").append("')");
+ //获取暂降事件
+ QueryResult result = influxDBUtil.query("select * from pqs_eventdetail where " + stringBuilder.toString());
+ InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
+ List eventDetailList = influxDBResultMapper.toPOJO(result, EventDetail.class);
long endTime = System.currentTimeMillis();
- System.out.println(endTime - startTime);
+ System.out.println(eventDetailList);
return result;
}
@@ -47,101 +58,152 @@ public class test {
}
}
- public static void main(String[] args) {
+ public static void main(String[] args) {
InfluxDbUtils influxDBUtil = new InfluxDbUtils("root", "123456789", "http://192.168.1.16:8086", "pqsbase", "");
insert(influxDBUtil);
+ //select(influxDBUtil);
+ }
+ public static void deleteDB(InfluxDbUtils influxDBUtil) {
+ influxDBUtil.deleteDB("LIMIT_RATE");
}
//单条数据插入
public static void insert(InfluxDbUtils influxDBUtil) {
+ // long time = Long.parseLong("1655135328135");
+ // Map tags = new HashMap<>();
+ // // tags.put("line_id", "127fad1dcb0077ac2979141b8473a5e4");
+ // tags.put("line_id", "1883a1fe6d9c3c5a03a4371bda024452");
+ // Map fields = new HashMap<>();
+ // fields.put("create_time", "2022-06-13 23:57:31");
+ // fields.put("update_time", "");
+ // fields.put("push_failed",0);
+ // fields.put("result",1);
+ // influxDBUtil.insert("pqs_event_push_logs", tags, fields, time, TimeUnit.MILLISECONDS);
+
+ long time = Long.parseLong("1646180719000");
Map tags = new HashMap<>();
- tags.put("lineid", "1e3b8531483b2a8cbee6747f1f641cf9");
- Map fields = new HashMap<>();
- fields.put("phasic_type","T");
- fields.put("value_type","MAX");
- fields.put("Freq_Dev", 48.6 );
- fields.put("Voltage_Dev", 8.3 );
- fields.put("UBalance", 7.6 );
- fields.put("Flicker", 4.6 );
- fields.put("UAberrance", 6.5 );
- fields.put("I_Neg", 5.6 );
- fields.put("UHarm_2", 6.8 );
- fields.put("UHarm_3", 5.5 );
- fields.put("UHarm_4", 5.4 );
- fields.put("UHarm_5", 7.8 );
- fields.put("UHarm_6", 6.2 );
- fields.put("UHarm_7", 2.5 );
- fields.put("UHarm_8", 8.3 );
- fields.put("UHarm_9", 6.2 );
- fields.put("UHarm_10", 12.8 );
- fields.put("UHarm_11", 2.8 );
- fields.put("UHarm_12", 8.4 );
- fields.put("UHarm_13", 5.6 );
- fields.put("UHarm_14", 5.2 );
- fields.put("UHarm_15", 9.5 );
- fields.put("UHarm_16", 8.3 );
- fields.put("UHarm_17", 7.8 );
- fields.put("UHarm_18", 6.2 );
- fields.put("UHarm_19", 2.5);
- fields.put("UHarm_20", 4.5 );
- fields.put("UHarm_21", 4.5 );
- fields.put("UHarm_22", 6.5 );
- fields.put("UHarm_23", 5.9 );
- fields.put("UHarm_24", 9.2 );
- fields.put("UHarm_25", 5.8 );
- fields.put("IHarm_2", 12.8 );
- fields.put("IHarm_3", 5.4 );
- fields.put("IHarm_4", 6.2 );
- fields.put("IHarm_5", 3.2 );
- fields.put("IHarm_6", 5.2 );
- fields.put("IHarm_7", 5.2 );
- fields.put("IHarm_8", 5.5 );
- fields.put("IHarm_9", 4.8 );
- fields.put("IHarm_10", 8.2 );
- fields.put("IHarm_11", 2.5 );
- fields.put("IHarm_12", 8.6 );
- fields.put("IHarm_13", 5.8 );
- fields.put("IHarm_14", 3.5 );
- fields.put("IHarm_15", 2.4 );
- fields.put("IHarm_16", 5.2 );
- fields.put("IHarm_17", 2.5 );
- fields.put("IHarm_18", 9.2 );
- fields.put("IHarm_19", 8.5);
- fields.put("IHarm_20", 8.5 );
- fields.put("IHarm_21", 6.2 );
- fields.put("IHarm_22", 5.2 );
- fields.put("IHarm_23", 8.5 );
- fields.put("IHarm_24", 5.2 );
- fields.put("IHarm_25", 8.4 );
- fields.put("InUHARM_1", 8.2 );
- fields.put("InUHARM_2", 5.2 );
- fields.put("InUHARM_3", 6.2 );
- fields.put("InUHARM_4", 4.2 );
- fields.put("InUHARM_5", 2.3 );
- fields.put("InUHARM_6", 6.2 );
- fields.put("InUHARM_7", 5.2 );
- fields.put("InUHARM_8", 10.2 );
- fields.put("InUHARM_9", 2.3 );
- fields.put("InUHARM_10", 4.2 );
- fields.put("InUHARM_11", 3.5 );
- fields.put("InUHARM_12", 3.6 );
- fields.put("InUHARM_13", 2.3 );
- fields.put("InUHARM_14", 7.2 );
- fields.put("InUHARM_15", 5.6 );
- fields.put("InUHARM_16", 5.6 );
- influxDBUtil.insert("PQS_AbnormalData", tags, fields, System.currentTimeMillis(), TimeUnit.MILLISECONDS);
+<<<<<<< .mine tags.put("LineID", "fd4ffb0dd33eafaaf403b07a3fc1afe5");
+======= tags.put("line_id", "89604adcaf7df6284fdaa352ccaba56b");
+>>>>>>> .theirs Map fields = new HashMap<>();
+ fields.put("VU_Dev1",5.706);
+ fields.put("VU_Dev2",5.706);
+ fields.put("VU_Dev3",5.706);
+ fields.put("VU_Dev4",5.706);
+ fields.put("VU_Dev5",5.706);
+ fields.put("Freq_Dev1",0.534);
+ fields.put("Freq_Dev2",0.534);
+ fields.put("Freq_Dev3",2.534);
+ fields.put("Freq_Dev4",0.534);
+ fields.put("Freq_Dev5",0.534);
+ fields.put("Data_PST1",0.604);
+ fields.put("Data_PST2",0.0);
+ fields.put("Data_PST3",0.691);
+ fields.put("Data_PST4",0.910);
+ fields.put("Data_PST5",0.691);
+ fields.put("V_Unbalance1",2.713);
+ fields.put("V_Unbalance2",2.713);
+ fields.put("V_Unbalance3",2.713);
+ fields.put("V_Unbalance4",2.713);
+ fields.put("V_Unbalance5",2.713);
+ fields.put("V_THD1",20.001);
+ fields.put("V_THD2",20.003);
+ fields.put("V_THD3",20.00);
+ fields.put("V_THD4",20.008);
+ fields.put("V_THD5",20.00);
+ fields.put("Event1",1.619);
+ fields.put("Event2",1.619);
+ fields.put("Event3",1.619);
+ fields.put("Event4",1.619);
+ fields.put("Event5",1.619);
+ influxDBUtil.insert("PQS_COMASSES", tags, fields, time, TimeUnit.MILLISECONDS);
+ // long time = Long.parseLong("1647473742000");
+ // tags.put("MYINDEX", "df1ff413949f6d1fc07ffdb5440b4907");
+ // Map fields = new HashMap<>();
+ // fields.put("Phasic_Type","T");
+ // fields.put("AllTime",1155);
+ // fields.put("Flicker_AllTime",550);
+ // fields.put("Flicker_OverTime",0);
+ // fields.put("Freq_Dev_OverTime",0);
+ // fields.put("Voltage_Dev_OverTime",0);
+ // fields.put("UBalance_OverTime",0);
+ // fields.put("UAberrance_OverTime",0);
+ // fields.put("I_Neg_OverTime",0);
+ // fields.put("UHarm_2_OverTime",0);
+ // fields.put("UHarm_3_OverTime",0);
+ // fields.put("UHarm_4_OverTime",0);
+ // fields.put("UHarm_5_OverTime",0);
+ // fields.put("UHarm_6_OverTime",0);
+ // fields.put("UHarm_7_OverTime",0);
+ // fields.put("UHarm_8_OverTime",0);
+ // fields.put("UHarm_9_OverTime",0);
+ // fields.put("UHarm_10_OverTime",0);
+ // fields.put("UHarm_11_OverTime",0);
+ // fields.put("UHarm_12_OverTime",0);
+ // fields.put("UHarm_13_OverTime",0);
+ // fields.put("UHarm_14_OverTime",0);
+ // fields.put("UHarm_15_OverTime",0);
+ // fields.put("UHarm_16_OverTime",0);
+ // fields.put("UHarm_17_OverTime",0);
+ // fields.put("UHarm_18_OverTime",0);
+ // fields.put("UHarm_19_OverTime",0);
+ // fields.put("UHarm_20_OverTime",0);
+ // fields.put("UHarm_21_OverTime",0);
+ // fields.put("UHarm_22_OverTime",0);
+ // fields.put("UHarm_23_OverTime",0);
+ // fields.put("UHarm_24_OverTime",0);
+ // fields.put("UHarm_25_OverTime",0);
+ // fields.put("IHarm_2_OverTime",0);
+ // fields.put("IHarm_3_OverTime",0);
+ // fields.put("IHarm_4_OverTime",0);
+ // fields.put("IHarm_5_OverTime",0);
+ // fields.put("IHarm_6_OverTime",0);
+ // fields.put("IHarm_7_OverTime",0);
+ // fields.put("IHarm_8_OverTime",0);
+ // fields.put("IHarm_9_OverTime",0);
+ // fields.put("IHarm_10_OverTime",0);
+ // fields.put("IHarm_11_OverTime",0);
+ // fields.put("IHarm_12_OverTime",0);
+ // fields.put("IHarm_13_OverTime",0);
+ // fields.put("IHarm_14_OverTime",0);
+ // fields.put("IHarm_15_OverTime",0);
+ // fields.put("IHarm_16_OverTime",0);
+ // fields.put("IHarm_17_OverTime",0);
+ // fields.put("IHarm_18_OverTime",0);
+ // fields.put("IHarm_19_OverTime",0);
+ // fields.put("IHarm_20_OverTime",0);
+ // fields.put("IHarm_21_OverTime",0);
+ // fields.put("IHarm_22_OverTime",0);
+ // fields.put("IHarm_23_OverTime",0);
+ // fields.put("IHarm_24_OverTime",0);
+ // fields.put("IHarm_25_OverTime",0);
+ // fields.put("InUHARM_1_OverTime",0);
+ // fields.put("InUHARM_2_OverTime",0);
+ // fields.put("InUHARM_3_OverTime",0);
+ // fields.put("InUHARM_4_OverTime",0);
+ // fields.put("InUHARM_5_OverTime",0);
+ // fields.put("InUHARM_6_OverTime",0);
+ // fields.put("InUHARM_7_OverTime",0);
+ // fields.put("InUHARM_8_OverTime",0);
+ // fields.put("InUHARM_9_OverTime",0);
+ // fields.put("InUHARM_10_OverTime",0);
+ // fields.put("InUHARM_11_OverTime",0);
+ // fields.put("InUHARM_12_OverTime",0);
+ // fields.put("InUHARM_13_OverTime",0);
+ // fields.put("InUHARM_14_OverTime",0);
+ // fields.put("InUHARM_15_OverTime",0);
+ // fields.put("InUHARM_16_OverTime",0);
+ // influxDBUtil.insert("LIMIT_RATE", tags, fields, time, TimeUnit.MILLISECONDS);
}
//循环写入数据库
public static void batchInsertOne(InfluxDbUtils influxDBUtil) {
Map tags1 = new HashMap<>();
- tags1.put("LineID", "8");
- tags1.put("Phasic_Type", "A");
+ tags1.put("line_id", "127fad1dcb0077ac2979141b8473a5e4");
Map fields1 = new HashMap<>();
- fields1.put("RMS", 2);
- fields1.put("RMS_AB", 2);
- fields1.put("RMS_BC", 2);
- fields1.put("RMS_CA", 2);
+ fields1.put("describe", "暂降事件1");
+ fields1.put("wave_type", 1);
+ fields1.put("persist_time", 1620);
+ fields1.put("event_value", 0.956);
Map tags2 = new HashMap<>();
tags2.put("LineID", "9");
tags2.put("Phasic_Type", "A");
diff --git a/pqs-common/common-poi/pom.xml b/pqs-common/common-poi/pom.xml
index 48c5c6b04..22deff41c 100644
--- a/pqs-common/common-poi/pom.xml
+++ b/pqs-common/common-poi/pom.xml
@@ -31,6 +31,10 @@
cn.afterturn
easypoi-spring-boot-starter
+
+ org.projectlombok
+ lombok
+
\ No newline at end of file
diff --git a/pqs-common/common-swagger/src/main/java/com/njcn/swagger/config/Knife4jSwaggerConfig.java b/pqs-common/common-swagger/src/main/java/com/njcn/swagger/config/Knife4jSwaggerConfig.java
index 475b9a52b..b8bbda1a4 100644
--- a/pqs-common/common-swagger/src/main/java/com/njcn/swagger/config/Knife4jSwaggerConfig.java
+++ b/pqs-common/common-swagger/src/main/java/com/njcn/swagger/config/Knife4jSwaggerConfig.java
@@ -58,7 +58,8 @@ public class Knife4jSwaggerConfig {
"com.njcn.system.controller",
"com.njcn.harmonic.controller",
"com.njcn.event.controller",
- "com.njcn.energy.controller")
+ "com.njcn.energy.controller",
+ "com.njcn.quality.controller")
.collect(Collectors.toList());
List grantTypes = new ArrayList<>();
String passwordTokenUrl = "http://" + gatewayUrl + "/pqs-auth/oauth/token";
diff --git a/pqs-common/common-web/src/main/java/com/njcn/web/utils/RequestUtil.java b/pqs-common/common-web/src/main/java/com/njcn/web/utils/RequestUtil.java
index 3ddc62a51..c57fa1fb0 100644
--- a/pqs-common/common-web/src/main/java/com/njcn/web/utils/RequestUtil.java
+++ b/pqs-common/common-web/src/main/java/com/njcn/web/utils/RequestUtil.java
@@ -40,7 +40,6 @@ public class RequestUtil {
/**
- * 获取登录认证的客户端ID
* 兼容两种方式获取OAuth2客户端信息(client_id、client_secret)
* 放在请求头(Request Headers)中的Authorization字段,且经过加密,例如 Basic Y2xpZW50OnNlY3JldA== 明文等于 client:secret
*/
@@ -49,7 +48,7 @@ public class RequestUtil {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
// 从请求路径中获取
String clientId = "";
- // 从请求头获取
+ // 从请求头获取 * 获取登录认证的客户端ID
String basic = request.getHeader(SecurityConstants.AUTHORIZATION_KEY);
if (StrUtil.isNotBlank(basic) && basic.startsWith(SecurityConstants.BASIC_PREFIX)) {
basic = basic.replace(SecurityConstants.BASIC_PREFIX, Strings.EMPTY);
diff --git a/pqs-common/pom.xml b/pqs-common/pom.xml
index a08f80471..628be90c3 100644
--- a/pqs-common/pom.xml
+++ b/pqs-common/pom.xml
@@ -20,8 +20,7 @@
common-web
common-autocode
common-influxdb
- common-poi
-
+
diff --git a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/TerminalParam.java b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/TerminalParam.java
new file mode 100644
index 000000000..5233ebc47
--- /dev/null
+++ b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/TerminalParam.java
@@ -0,0 +1,33 @@
+package com.njcn.device.pojo.param;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotEmpty;
+import java.util.List;
+
+/**
+ * pqs
+ *
+ * @author cdf
+ * @date 2022/6/14
+ */
+@Data
+@ApiModel
+@Valid
+public class TerminalParam {
+
+ @ApiModelProperty(name = "ids",value = "id集合",required = true)
+ @NotEmpty(message = "索引集合不可为空")
+ private List ids;
+ @ApiModelProperty(name = "runFlag",value = "终端运行状态")
+ private Integer runFlag;
+ @ApiModelProperty(name = "baseMealId",value = "基础套餐")
+ private String baseMealId;
+ @ApiModelProperty(name = "extendMealId",value = "扩展套餐")
+ private String extendMealId;
+ @ApiModelProperty(name = "flowStrategyId",value = "流量策略")
+ private String flowStrategyId;
+}
diff --git a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/LineDistributionVO.java b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/LineDistributionVO.java
index 785f4d93d..210080312 100644
--- a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/LineDistributionVO.java
+++ b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/LineDistributionVO.java
@@ -13,8 +13,17 @@ import java.io.Serializable;
@Data
public class LineDistributionVO implements Serializable {
@ApiModelProperty("区域名称")
- private String areaName;
+ private String name;
@ApiModelProperty("监测点个数")
- private Integer lineNum;
+ private Integer value;
+
+ public LineDistributionVO(String areaName, Integer lineNum) {
+ this.areaName = areaName;
+ this.lineNum = lineNum;
+ }
+
+ public LineDistributionVO() {
+
+ }
}
diff --git a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/TerminalMaintainVO.java b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/TerminalMaintainVO.java
index 6f7e7efd2..82c9fe989 100644
--- a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/TerminalMaintainVO.java
+++ b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/TerminalMaintainVO.java
@@ -43,6 +43,8 @@ public class TerminalMaintainVO {
private Float statisValue;
@ApiModelProperty(name = "流量策略")
private String flowStrategy;
+ @ApiModelProperty(name = "策略类型")
+ private Integer strategyFlag;
@ApiModelProperty(name = "子级")
List children;
}
diff --git a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/ProgramVersionController.java b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/ProgramVersionController.java
index 4067a56c5..e43ab9700 100644
--- a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/ProgramVersionController.java
+++ b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/ProgramVersionController.java
@@ -7,10 +7,12 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.pojo.vo.ShowVersionVO;
import com.njcn.device.pojo.vo.VersionVO;
import com.njcn.device.service.ProgramVersionService;
import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
@@ -66,6 +68,15 @@ public class ProgramVersionController extends BaseController {
}
}
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/getProgramVersionById")
+ @ApiOperation("修改版本回显")
+ @ApiImplicitParam(name = "id", value = "终端版本id", required = true)
+ public HttpResult getProgramVersionById(@RequestParam("id") String id) {
+ String methodDescribe = getMethodDescribe("getProgramVersionById");
+ ShowVersionVO result = programService.getProgramVersionById(id);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
+ }
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/updateProgramVersion")
diff --git a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalMaintainController.java b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalMaintainController.java
index 2314c8637..4c3de1d58 100644
--- a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalMaintainController.java
+++ b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalMaintainController.java
@@ -1,16 +1,21 @@
package com.njcn.device.controller;
+import cn.hutool.core.util.StrUtil;
import com.njcn.common.pojo.annotation.OperateInfo;
import com.njcn.common.pojo.constant.OperateType;
import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.enums.DeviceResponseEnum;
import com.njcn.device.pojo.param.TerminalMainQueryParam;
+import com.njcn.device.pojo.param.TerminalParam;
import com.njcn.device.pojo.vo.TerminalMaintainVO;
import com.njcn.device.service.TerminalMaintainService;
import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -21,6 +26,7 @@ import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
+import java.util.Objects;
/**
* pqs
@@ -109,13 +115,17 @@ public class TerminalMaintainController extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON, operateType = OperateType.UPDATE)
@PostMapping("/updateRunFlagManage")
@ApiOperation("批量修改终端状态")
- public HttpResult> updateRunFlagManage(@NotEmpty(message = "id不可为空") @RequestBody List ids, @NotNull(message = "指标id不可为空") @RequestParam("runFlag") Integer runFlag) {
+ @ApiImplicitParam(name = "terminalParam", value = "实体", required = true)
+ public HttpResult> updateRunFlagManage(@RequestBody TerminalParam terminalParam) {
String methodDescribe = getMethodDescribe("updateRunFlagManage");
- boolean res = terminalMaintainService.updateRunFlagManage(ids, runFlag);
+ if(Objects.isNull(terminalParam.getRunFlag())){
+ throw new BusinessException(CommonResponseEnum.ILLEGAL_ARGUMENT_EXCEPTION);
+ }
+ boolean res = terminalMaintainService.updateRunFlagManage(terminalParam);
if (res) {
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
} else {
- return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
}
}
@@ -129,13 +139,17 @@ public class TerminalMaintainController extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON, operateType = OperateType.UPDATE)
@PostMapping("/updateDevFlowMeal")
@ApiOperation("批量修改终端流量套餐")
- public HttpResult