diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..374fc0b --- /dev/null +++ b/.gitignore @@ -0,0 +1,49 @@ +# Compiled class file +*.class +*.iml +*.idea +target/ +logs/ + +# Log file +*.log + +# BlueJ files +*.ctxt + +# Mobile Tools for Java (J2ME) +.mtj.tmp/ + +# Package Files # +*.jar +*.war +*.ear +*.tar.gz +*.rar + +# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml +hs_err_pid* + +*velocity.log* + +# Eclipse # +.classpath +.project +.settings/ + +.DS_Store + +_dockerCerts/ + +.factorypath + +node_modules/ +package-lock.json +yarn.lock + +rebel.xml + +!DmJdbcDriver18.jar +!kingbase8-8.6.0.jar +/govern.ipr +/govern.iws diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/enums/AlgorithmResponseEnum.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/enums/AlgorithmResponseEnum.java index 73df459..b096b75 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/enums/AlgorithmResponseEnum.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/enums/AlgorithmResponseEnum.java @@ -20,6 +20,7 @@ public enum AlgorithmResponseEnum { NDID_ERROR("A00502","存在相同的ndid"), DATA_ERROR("A00503","存在相同的数据"), LINE_DATA_ERROR ("A00504","设备下监测点数据缺失"), + LINE_DATA_MISS ("A00504","设备下监测点数据缺失"), POSITION_ERROR ("A00504","监测点位置数据缺失"), ENGINEERING_DATA_ERROR ("A00505","工程数据数据缺失"), ELEEPDPQD_DATA_ERROR ("A00506","统计指标据数据缺失"), diff --git a/cs-harmonic/cs-harmonic-boot/pom.xml b/cs-harmonic/cs-harmonic-boot/pom.xml index e64cf10..91d1fd5 100644 --- a/cs-harmonic/cs-harmonic-boot/pom.xml +++ b/cs-harmonic/cs-harmonic-boot/pom.xml @@ -80,6 +80,18 @@ 1.0.0 compile + + com.njcn + common-event + 1.0.0 + compile + + + com.njcn + common-oss + 1.0.0 + compile + com.njcn user-api diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/controller/EventController.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/controller/EventController.java index 7012381..8931afc 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/controller/EventController.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/controller/EventController.java @@ -8,6 +8,9 @@ import com.njcn.common.utils.HttpResultUtil; import com.njcn.csharmonic.param.CsEventUserQueryParam; import com.njcn.csharmonic.pojo.vo.EventDetailVO; import com.njcn.csharmonic.service.CsEventPOService; +import com.njcn.event.file.pojo.dto.WaveDataDTO; +import com.njcn.influx.pojo.dto.EventQueryDTO; +import com.njcn.influx.pojo.po.cs.EntData; import com.njcn.web.controller.BaseController; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -31,7 +34,7 @@ import java.util.List; @Api(tags = "暂降事件") @AllArgsConstructor public class EventController extends BaseController { - private final CsEventPOService eventService; + private final CsEventPOService csEventPOService; @OperateInfo(info = LogEnum.BUSINESS_COMMON) @@ -40,10 +43,20 @@ public class EventController extends BaseController { @ApiImplicitParam(name = "csEventUserQueryParam", value = "暂降事件查询参数", required = true) public HttpResult> queryEventList(@RequestBody CsEventUserQueryParam csEventUserQueryParam) { String methodDescribe = getMethodDescribe("queryEventList"); - List list = eventService.queryEventList(csEventUserQueryParam); + List list = csEventPOService.queryEventList(csEventUserQueryParam); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @GetMapping("/analyseWave") + @ApiOperation("暂态事件波形分析") + @ApiImplicitParam(name = "eventId", value = "暂态事件索引", required = true) + public HttpResult analyseWave(String eventId) { + String methodDescribe = getMethodDescribe("analyseWave"); + WaveDataDTO wave = csEventPOService.analyseWave(eventId); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, wave, methodDescribe); + } + diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/CsEventPOService.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/CsEventPOService.java index 628abb2..efa7cf3 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/CsEventPOService.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/CsEventPOService.java @@ -9,6 +9,9 @@ import java.util.List; /** * +import com.njcn.event.file.pojo.dto.WaveDataDTO; + +/** * Description: * Date: 2023/9/4 15:15【需求编号】 * @@ -17,5 +20,12 @@ import java.util.List; */ public interface CsEventPOService extends IService{ + /*** + * 根据事件ID解析该事件波形文件 + * @author hongawen + * @date 2023/9/20 14:23 + * @return WaveDataDTO + */ + WaveDataDTO analyseWave(String eventId); List queryEventList(CsEventUserQueryParam csEventUserQueryParam); } diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java index cc2aec8..981bf82 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java @@ -1,19 +1,20 @@ package com.njcn.csharmonic.service.impl; -import com.njcn.csdevice.api.CsLedgerFeignClient; +import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.util.StrUtil; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.utils.PubUtils; import com.njcn.csdevice.api.CsLineFeignClient; -import com.njcn.csdevice.pojo.dto.DevDetailDTO; -import com.njcn.csharmonic.param.CsEventUserQueryParam; -import com.njcn.csharmonic.pojo.vo.EventDetailVO; -import com.njcn.csharmonic.service.CsEventUserPOService; -import com.njcn.influx.pojo.dto.EventDataSetDTO; -import com.njcn.influx.service.EvtDataService; -import com.njcn.system.api.EleEvtFeignClient; -import com.njcn.system.api.EpdFeignClient; -import com.njcn.system.pojo.po.EleEpdPqd; -import com.njcn.system.pojo.po.EleEvtParm; +import com.njcn.csdevice.enums.AlgorithmResponseEnum; +import com.njcn.csdevice.pojo.po.CsLinePO; +import com.njcn.event.file.component.WaveFileComponent; +import com.njcn.event.file.pojo.dto.WaveDataDTO; +import com.njcn.event.file.pojo.enums.WaveFileResponseEnum; +import com.njcn.oss.constant.GeneralConstant; +import com.njcn.oss.constant.OssPath; +import com.njcn.oss.utils.FileStorageUtil; import lombok.RequiredArgsConstructor; -import org.springframework.beans.BeanUtils; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.njcn.csharmonic.mapper.CsEventPOMapper; @@ -24,6 +25,14 @@ import java.util.ArrayList; import java.util.List; import java.util.Optional; + +import java.io.File; +import java.io.InputStream; +import java.util.List; +import java.util.Objects; +import java.util.stream.Collectors; +import java.util.stream.Stream; + /** * * Description: @@ -32,6 +41,7 @@ import java.util.Optional; * @author clam * @version V1.0.0 */ +@Slf4j @Service @RequiredArgsConstructor public class CsEventPOServiceImpl extends ServiceImpl implements CsEventPOService{ @@ -76,4 +86,42 @@ public class CsEventPOServiceImpl extends ServiceImpl csLinePOList = csLineFeignClient.queryLineById(Stream.of(eventDetail.getLineId()).collect(Collectors.toList())).getData(); + if(CollectionUtil.isEmpty(csLinePOList)){ + throw new BusinessException(AlgorithmResponseEnum.LINE_DATA_MISS); + } + waveDataDTO.setPtType(csLinePOList.get(0).getConType()); + waveDataDTO.setPt(csLinePOList.get(0).getPtRatio()); + waveDataDTO.setCt(csLinePOList.get(0).getCtRatio() ); + return waveDataDTO; + } } diff --git a/pom.xml b/pom.xml index 5481984..9d4043b 100644 --- a/pom.xml +++ b/pom.xml @@ -24,13 +24,13 @@ 192.168.1.13 127.0.0.1 - 192.168.1.13 ${middle.server.url}:18848 + + fd74182b-1fce-4dba-afa7-2623b0376205 - 415a1c87-33aa-47bd-8e25-13cc456c87ed ${middle.server.url}:8080