diff --git a/pqs-advance/advance-api/src/main/java/com/njcn/advance/pojo/dto/waveAnalysis/BackData.java b/pqs-advance/advance-api/src/main/java/com/njcn/advance/pojo/dto/waveAnalysis/BackData.java index 10fae9583..bb0a2cc8e 100644 --- a/pqs-advance/advance-api/src/main/java/com/njcn/advance/pojo/dto/waveAnalysis/BackData.java +++ b/pqs-advance/advance-api/src/main/java/com/njcn/advance/pojo/dto/waveAnalysis/BackData.java @@ -47,7 +47,7 @@ import java.util.List; * angle_diff_cn C相相位负跳变 * bph_max_value 不平衡度（单位%） */ -@JsonIgnoreProperties(ignoreUnknown = true) +@JsonIgnoreProperties(ignoreUnknown = true,value = {"pointer"}) public class BackData extends Structure { public int qvvr_cata_cause[] = new int[256]; public int qvvr_phasetype[] = new int[256]; diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/AreaLineInfoVO.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/AreaLineInfoVO.java index 13cea0870..11ee201f0 100644 --- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/AreaLineInfoVO.java +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/AreaLineInfoVO.java @@ -63,6 +63,9 @@ public class AreaLineInfoVO implements Serializable { @ApiModelProperty(name = "pt2",value = "pt2") private Integer pt2; + @ApiModelProperty(name = "ptType",value = "接线类型(0:星型接法;1:三角型接法;2:开口三角型接法)") + private Integer ptType; + @ApiModelProperty(name = "objName",value = "对象名称") private String objName; diff --git a/pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/LineMapper.xml b/pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/LineMapper.xml index 9a29458b4..cd6947ebc 100644 --- a/pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/LineMapper.xml +++ b/pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/LineMapper.xml @@ -557,6 +557,7 @@ detail.ct2, detail.pt1, detail.pt2, + detail.PT_Type as ptType, detail.obj_name, detail.Dev_Capacity deviceCapacity, detail.Short_Capacity, diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/ReportController.java b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/ReportController.java index 5f27441b5..e9d9f2c9e 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/ReportController.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/ReportController.java @@ -234,4 +234,10 @@ public class ReportController extends BaseController { reportService.getPmsAreaReport(areaReportParam, response); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/createEventReport") + @ApiOperation("暂态事件报告导出") + public void createEventReport(@RequestBody @Validated List index, HttpServletResponse response) throws IOException, InvalidFormatException { + commMonitorEventReportService.createEventReport(index,response); + } } diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/mapper/RmpEventDetailMapper.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/mapper/RmpEventDetailMapper.java index 1fdce8565..84bb018c8 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/mapper/RmpEventDetailMapper.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/mapper/RmpEventDetailMapper.java @@ -1,10 +1,8 @@ package com.njcn.event.common.mapper; -import cn.hutool.core.date.DateTime; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.njcn.event.pojo.dto.EventCount; import com.njcn.event.pojo.po.RmpEventDetailPO; -import com.njcn.event.pojo.vo.RmpEventDetailVO; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/pojo/dto/EventInfoDetailVO.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/pojo/dto/EventInfoDetailVO.java new file mode 100644 index 000000000..e5577ca10 --- /dev/null +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/pojo/dto/EventInfoDetailVO.java @@ -0,0 +1,63 @@ +package com.njcn.event.common.pojo.dto; + +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * @Description: + * @Author: wr + * @Date: 2023/11/1 13:17 + */ +@Data +public class EventInfoDetailVO implements Serializable { + + @ApiModelProperty("监测点名称") + private String lineName; + + @ApiModelProperty("供电公司名称") + private String gdName; + + @ApiModelProperty("变电站名称") + private String bdzName; + + @ApiModelProperty("终端名称") + private String devName; + + @ApiModelProperty("电压等级") + private String scale; + + @ApiModelProperty("ip") + private String ip; + + @ApiModelProperty("暂降事件id") + private String eventDetailIndex; + + @ApiModelProperty("触发时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS") + private LocalDateTime timeID; + + @ApiModelProperty("持续时间") + private Double persistTime; + + @ApiModelProperty("处理结果第一条事件发生时间毫秒") + private Double ms; + + @ApiModelProperty("特征幅值") + private Double eventValue; + + @ApiModelProperty("报告状态") + private int report; + + @ApiModelProperty("评价") + private int evaluate; + + @ApiModelProperty("报告路径") + private String reportPath; + + + +} \ No newline at end of file diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/CommMonitorEventReportService.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/CommMonitorEventReportService.java index 6bb850fdd..467dcdba0 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/CommMonitorEventReportService.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/CommMonitorEventReportService.java @@ -2,8 +2,11 @@ package com.njcn.event.common.service; import com.njcn.event.common.pojo.dto.LineDetailDataCommDTO; import com.njcn.event.pojo.param.ExportParam; +import org.apache.poi.openxml4j.exceptions.InvalidFormatException; import javax.servlet.http.HttpServletResponse; +import java.io.IOException; +import java.util.List; /** * pqs @@ -16,6 +19,9 @@ public interface CommMonitorEventReportService { void getLineExport(ExportParam exportParam, LineDetailDataCommDTO lineDetailDataCommDTO, HttpServletResponse response); - - + /** + * 暂态事件报告 + * @param index + */ + void createEventReport(List index, HttpServletResponse response) throws IOException, InvalidFormatException; } diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/WaveService.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/WaveService.java index 50622d209..79033944a 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/WaveService.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/WaveService.java @@ -1,6 +1,12 @@ package com.njcn.event.common.service; -import com.njcn.advance.pojo.dto.waveAnalysis.WaveData; +import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; +import com.njcn.event.common.pojo.dto.EventEigDetail; +import com.njcn.event.file.pojo.dto.WaveDataDTO; +import com.njcn.event.pojo.po.RmpEventDetailPO; + +import java.util.List; + /** * @Author: cdf @@ -9,6 +15,14 @@ import com.njcn.advance.pojo.dto.waveAnalysis.WaveData; */ public interface WaveService { - //通过优化后的方式获取波形数据 - WaveData getWavedata(String eventIndex, int flag); + /** + * 通过优化后的方式获取波形数据 + * @param + * @param + * @return + */ + WaveDataDTO getWavedata(RmpEventDetailPO eventDetail, AreaLineInfoVO line); + + + List eventDetailEigenvalue(String eventDetailIndex,Integer ptType); } diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/CommMonitorEventReportServiceImpl.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/CommMonitorEventReportServiceImpl.java index f524d8175..e49d7b1e8 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/CommMonitorEventReportServiceImpl.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/CommMonitorEventReportServiceImpl.java @@ -1,14 +1,15 @@ package com.njcn.event.common.service.impl; import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.ObjUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.njcn.advance.pojo.dto.waveAnalysis.WaveData; import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.exception.BusinessException; -import com.njcn.device.pms.api.MonitorClient; import com.njcn.device.pq.api.LineFeignClient; +import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; import com.njcn.echarts.pojo.constant.PicCommonData; import com.njcn.echarts.util.DrawPicUtil; import com.njcn.event.common.mapper.RmpEventDetailMapper; @@ -18,36 +19,34 @@ import com.njcn.event.common.service.CommMonitorEventReportService; import com.njcn.event.common.service.EventAnalysisService; import com.njcn.event.common.service.EventReportService; import com.njcn.event.common.service.WaveService; +import com.njcn.event.common.pojo.dto.EventInfoDetailVO; import com.njcn.event.common.utils.WordUtil; import com.njcn.event.common.utils.WordUtils; +import com.njcn.event.file.component.WavePicComponent; import com.njcn.event.file.pojo.bo.WaveDataDetail; +import com.njcn.event.file.pojo.dto.WaveDataDTO; +import com.njcn.event.file.utils.WaveUtil; import com.njcn.event.pojo.param.ExportParam; import com.njcn.event.pojo.param.StatisticsParam; import com.njcn.event.pojo.po.EventDetail; import com.njcn.event.pojo.po.RmpEventDetailPO; import com.njcn.event.pojo.vo.*; +import com.njcn.oss.utils.FileStorageUtil; import com.njcn.system.api.DicDataFeignClient; import com.njcn.system.enums.DicDataEnum; import com.njcn.system.enums.DicDataTypeEnum; import com.njcn.system.pojo.po.DictData; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.apache.poi.hssf.usermodel.HSSFCell; -import org.apache.poi.hssf.usermodel.HSSFCellStyle; import org.apache.poi.openxml4j.exceptions.InvalidFormatException; import org.apache.poi.util.Units; import org.apache.poi.xwpf.usermodel.*; import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTTblWidth; import org.openxmlformats.schemas.wordprocessingml.x2006.main.STTblWidth; import org.springframework.stereotype.Service; -import org.springframework.util.CollectionUtils; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; import javax.servlet.ServletOutputStream; import javax.servlet.http.HttpServletResponse; -import javax.servlet.http.HttpSession; import java.io.*; import java.math.BigDecimal; import java.math.BigInteger; @@ -57,6 +56,7 @@ import java.text.SimpleDateFormat; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.stream.Collectors; +import java.util.stream.Stream; /** @@ -72,16 +72,15 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport private final DicDataFeignClient dicDataFeignClient; - private final EventReportService eventReportService; - //调用暂降密度接口 private final EventAnalysisService eventAnalysisService; - private final RmpEventDetailMapper rmpEventDetailMapper; - - //private final WaveService waveService; - + private final WaveService waveService; private final DrawPicUtil drawPicUtil; + private final WavePicComponent wavePicComponent; + private final FileStorageUtil fileStorageUtil; + private final LineFeignClient lineFeignClient; + /** * 监测点导出word @@ -226,7 +225,7 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport EventDetail eventDetail = plot.get(j); String s = eventDetail.getStartTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")); - insertRow(doc, table, centerParagraph, false, j + 1 + "", s, BigDecimal.valueOf(eventDetail.getFeatureAmplitude() * 100).setScale(2, RoundingMode.HALF_UP).toString(), eventDetail.getDuration() + "", Objects.isNull(eventDetail.getAdvanceType())?"/":eventDetail.getAdvanceType(), Objects.isNull(eventDetail.getAdvanceReason())?"/":eventDetail.getAdvanceReason(), Objects.isNull(eventDetail.getSeverity())?"/":eventDetail.getSeverity() + ""); + insertRow(doc, table, centerParagraph, false, j + 1 + "", s, BigDecimal.valueOf(eventDetail.getFeatureAmplitude() * 100).setScale(2, RoundingMode.HALF_UP).toString(), eventDetail.getDuration() + "", Objects.isNull(eventDetail.getAdvanceType()) ? "/" : eventDetail.getAdvanceType(), Objects.isNull(eventDetail.getAdvanceReason()) ? "/" : eventDetail.getAdvanceReason(), Objects.isNull(eventDetail.getSeverity()) ? "/" : eventDetail.getSeverity() + ""); } i++; } @@ -369,7 +368,7 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport } else { for (int j = 0; j < reasonTypeTime.size(); j++) { TimeVO timeVO = reasonTypeTime.get(j); - insertRow(doc, table1, centerParagraph, false,timeVO.getFulltime(), timeVO.getTimes()); + insertRow(doc, table1, centerParagraph, false, timeVO.getFulltime(), timeVO.getTimes()); } } two++; @@ -384,7 +383,7 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport if (fly) { List tempDictType = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.EVENT_STATIS.getCode()).getData(); List typeIds = tempDictType.stream().filter(x -> DicDataEnum.VOLTAGE_DIP.getCode().equals(x.getCode()) || DicDataEnum.SHORT_INTERRUPTIONS.getCode().equals(x.getCode())) - .map(DictData::getId).collect(Collectors.toList()); + .map(DictData::getId).collect(Collectors.toList()); List tempInfo = info.stream().filter(temp -> typeIds.contains(temp.getEventType())).collect(Collectors.toList()); StatisticVO statistic = eventReportService.getStatistic(tempInfo, reasonData, typeData); if (exportParam.isYybg() || exportParam.isYytx()) { @@ -468,8 +467,8 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport response.setContentType("application/octet-stream;charset=UTF-8"); doc.write(outputStream); outputStream.close(); - }catch (Exception e){ - throw new BusinessException(CommonResponseEnum.FAIL,"导出监测点暂降报告异常"); + } catch (Exception e) { + throw new BusinessException(CommonResponseEnum.FAIL, "导出监测点暂降报告异常"); } } @@ -528,14 +527,8 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport } - public void setCellStyle(HSSFCell cellname, String value, HSSFCellStyle style) { - cellname.setCellValue(value); - cellname.setCellStyle(style); - } /** - * - * * @param document 文档 * @param image 图片base64 * @param name 图片名 @@ -544,16 +537,16 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport */ public void createPic(XWPFDocument document, String image, String name) { try { - XWPFParagraph picParagraph = WordUtils.getCenterParagraph(document); - XWPFRun createRun = picParagraph.createRun(); - if (image.contains(PicCommonData.PNG_PREFIX)) { - image = image.replace(PicCommonData.PNG_PREFIX, ""); - } - byte[] bytes = Base64.getDecoder().decode(image); - InputStream in = new ByteArrayInputStream(bytes); - createRun.addPicture(in, 5, name, Units.toEMU(410), Units.toEMU(170)); - }catch (Exception e){ - log.error("在word中创建图片异常:",e); + XWPFParagraph picParagraph = WordUtils.getCenterParagraph(document); + XWPFRun createRun = picParagraph.createRun(); + if (image.contains(PicCommonData.PNG_PREFIX)) { + image = image.replace(PicCommonData.PNG_PREFIX, ""); + } + byte[] bytes = Base64.getDecoder().decode(image); + InputStream in = new ByteArrayInputStream(bytes); + createRun.addPicture(in, 5, name, Units.toEMU(410), Units.toEMU(170)); + } catch (Exception e) { + log.error("在word中创建图片异常:", e); } } @@ -589,10 +582,10 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport // .map(DictData::getId).collect(Collectors.toList()); //数据暂降查询 List info = rmpEventDetailMapper.selectList(new LambdaQueryWrapper() - .eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex()) + .eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex()) // .in(RmpEventDetailPO::getEventType, typeIds) - .ge(StrUtil.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime, DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime()))) - .le(StrUtil.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime()))) + .ge(StrUtil.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime, DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime()))) + .le(StrUtil.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime()))) .orderByDesc(RmpEventDetailPO::getStartTime) ); @@ -600,92 +593,61 @@ public class CommMonitorEventReportServiceImpl implements CommMonitorEventReport } - - /* *//** + /** * 生成暂降事件报告 - *//* - public void createEventReport(List index) { - try { - WordUtil wordUtil = new WordUtil(); - for (int i = 0; i < index.size(); i++) { - WaveData waveData = waveService.getWavedata(index.get(i), 1); - //数据筛选,如果是双路电压的话，会存在2个波形数据 - List waveDataDetails = waveService.filteWaveData(waveData); - if (waveData.getSunData().isEmpty()) { - throw new BusinessException(CommonResponseEnum.FAIL,"没有波形数据"); - } else { - String time = waveData.getTime(); - time = time.replace(" ", "%20"); - String title = "监测点名称：" + waveData.getLineName() + "%20发生时刻：" + time + "%20特征幅值：" + waveData.getEventValue() + "%25%20持续时间：" + waveData.getPersistTime() + "s"; + */ + public void createEventReport(List eventIndex, HttpServletResponse response) throws IOException, InvalidFormatException { + WordUtil wordUtil = new WordUtil(); + for (String index : eventIndex) { + RmpEventDetailPO detail = rmpEventDetailMapper.selectById(index); + List lineDetail = lineFeignClient.getBaseLineAreaInfo(Stream.of(detail.getLineId()).collect(Collectors.toList())).getData(); + AreaLineInfoVO line = lineDetail.get(0); + WaveDataDTO waveData = waveService.getWavedata(detail, line); + //数据筛选,如果是双路电压的话，会存在2个波形数据 + List waveDataDetails = WaveUtil.filterWaveData(waveData); + if (ObjUtil.isNull(waveData)) { + throw new BusinessException(CommonResponseEnum.FAIL, "没有波形数据"); + } else { + //获取瞬时波形 + String instantPath = wavePicComponent.generateImageShun(waveData, waveDataDetails); + InputStream instantStream = fileStorageUtil.getFileStream(instantPath); + String imageShun64 = cn.hutool.core.codec.Base64.encode(instantStream); - List shun = new ArrayList<>(); - List rms = new ArrayList<>(); - if (waveDataDetails.size() == 1) { - shun.add(waveService.createShunTitle(title, waveDataDetails.get(0))); - rms.add(waveService.createRMSTitle(title, waveDataDetails.get(0))); - } else { - shun.add(waveService.createShunTitle(title, waveDataDetails.get(0))); - rms.add(waveService.createRMSTitle(title, waveDataDetails.get(0))); - for (int n = 1; n < waveDataDetails.size(); n++) { - shun.add(waveService.createShun(waveDataDetails.get(n))); - rms.add(waveService.createRMS(waveDataDetails.get(n))); - } - } - wordUtil.translateShun(i, shun); - wordUtil.translateRms(i, rms); - List eventDetailEigenvalue = eventDetailService.eventDetailEigenvalue(index.get(i)); - wordUtil.setEventDetailEigenvalue(i, eventDetailEigenvalue); - EventInfoDetail eventInfoList = .eventDetailBaseInfoByIndex(index.get(i)); - wordUtil.setEventInfoList(i, eventInfoList); - } - } - wordUtil.createReport(index.size()); + wordUtil.translateShun(index, imageShun64); + //获取rms波形 + String rmsPath = wavePicComponent.generateImageRms(waveData, waveDataDetails); + InputStream rmsStream = fileStorageUtil.getFileStream(rmsPath); + String rmsShun64 = cn.hutool.core.codec.Base64.encode(rmsStream); + wordUtil.translateRms(index, rmsShun64); + + EventInfoDetailVO eventInfoList = new EventInfoDetailVO(); + eventInfoList.setLineName(line.getLineName()); + eventInfoList.setGdName(line.getGdName()); + eventInfoList.setBdzName(line.getSubName()); + eventInfoList.setDevName(line.getDeviceName()); + eventInfoList.setScale(line.getVoltageScale()); + eventInfoList.setIp(line.getIp()); + eventInfoList.setEventDetailIndex(detail.getEventId()); + eventInfoList.setTimeID(detail.getStartTime()); + eventInfoList.setPersistTime(detail.getDuration()); + eventInfoList.setMs(detail.getFirstMs()); + eventInfoList.setEventValue(detail.getFeatureAmplitude()); + wordUtil.setEventInfoList(index, eventInfoList); + List eventDetailEigenvalue = waveService.eventDetailEigenvalue(index,line.getPtType()); + wordUtil.setEventDetailEigenvalue(index, eventDetailEigenvalue); - SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmm");// 报告时分秒格式 - String fileName = "暂降事件报告_" + formatter.format(new Date()) + ".docx"; - //读取配置文件 - Properties pros = PubUtils.readProperties(getClass().getClassLoader(), "java.properties"); - String tmpPath = pros.get("TMP_PATH").toString() + File.separator + "eventreoprt"; - tmpPath = ClearPathUtil.cleanString(tmpPath); - OutputStream os = null; - File tmpfile = new File(tmpPath); - if (!tmpfile.exists()) { - tmpfile.mkdir(); } - tmpPath = tmpPath + File.separator + fileName; - tmpPath = ClearPathUtil.cleanString(tmpPath); - File tmp = new File(tmpPath); - if (tmp.exists()) { - tmp.delete(); - } - PubUtils.createFile(tmpPath); - try { - os = new FileOutputStream(tmpPath); - if (null != wordUtil.getDocument()) { - wordUtil.getDocument().write(os); - session.setAttribute("eventFilePath", tmpPath); - session.setAttribute("eventFileName", fileName); - } - } catch (Exception e) { - session.setAttribute("eventFilePath", ""); - session.setAttribute("eventFileName", ""); - logger.error("输出暂态事件报告异常，原因为：" + e.toString()); - } finally { - try { - if (os != null) { - os.close(); - } - } catch (Exception e) { - logger.error("关闭流异常，原因为：" + e.toString()); - } - } - } catch (Exception e) { - e.printStackTrace(); - logger.error("生成事件报告失败，方法名为：getEventReport，异常为：" + e.toString()); - result = PubUtils.assignmentResult(null, 500, "生成事件报告出错，请联系管理员"); } - - return result; - }*/ - + wordUtil.createReport(eventIndex); + try { + ServletOutputStream outputStream = response.getOutputStream(); + String fileName = URLEncoder.encode("暂降事件报告_" + DateUtil.format(new Date(),DatePattern.NORM_DATE_PATTERN)+ ".docx", "UTF-8"); + response.setHeader("Content-Disposition", "attachment; filename=\"" + fileName + "\""); + response.setContentType("application/octet-stream;charset=UTF-8"); + wordUtil.getDocument().write(outputStream); + outputStream.close(); + } catch (Exception e) { + throw new BusinessException(CommonResponseEnum.FAIL, "导出暂降事件报告异常"); + } + } } diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java index 14ff45118..e17204c04 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java @@ -1,213 +1,125 @@ -//package com.njcn.event.common.service.impl; -// -//import cn.hutool.core.util.StrUtil; -//import com.njcn.advance.pojo.dto.waveAnalysis.AnalyWave; -//import com.njcn.advance.pojo.dto.waveAnalysis.WaveData; -//import com.njcn.common.config.GeneralInfo; -//import com.njcn.common.pojo.exception.BusinessException; -//import com.njcn.device.pq.api.LineFeignClient; -//import com.njcn.device.pq.pojo.po.line.LineInfoVO; -//import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; -//import com.njcn.event.common.mapper.RmpEventDetailMapper; -//import com.njcn.event.common.service.WaveService; -//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.event.file.utils.WaveUtil; -//import com.njcn.event.pojo.po.RmpEventDetailPO; -//import com.njcn.oss.constant.GeneralConstant; -//import com.njcn.oss.constant.OssPath; -//import com.njcn.oss.utils.FileStorageUtil; -//import lombok.RequiredArgsConstructor; -//import lombok.extern.slf4j.Slf4j; -//import org.apache.commons.lang3.StringUtils; -//import org.springframework.stereotype.Service; -// -//import java.io.File; -//import java.io.InputStream; -//import java.math.BigDecimal; -//import java.math.RoundingMode; -//import java.text.SimpleDateFormat; -//import java.util.List; -//import java.util.Objects; -//import java.util.stream.Collectors; -//import java.util.stream.Stream; -// -///** -// * @Author: cdf -// * @CreateTime: 2026-02-26 -// * @Description: -// */ -//@Service -//@RequiredArgsConstructor -//@Slf4j -//public class WaveServiceImpl implements WaveService { -// -// private final RmpEventDetailMapper rmpEventDetailMapper; -// -// private final WaveFileComponent waveFileComponent; -// -// private final GeneralInfo generalInfo; -// -// private final FileStorageUtil fileStorageUtil; -// private final LineFeignClient lineFeignClient; -// -// -// /** -// * 根据暂降事件索引获取波形数据 -// * 注：当前只考虑本地的波形文件 -// * -// * @param eventIndex 事件索引 -// * @param flag 抽点方式 -// */ -// @Override -// public WaveData getWavedata(String eventIndex, int flag) { -// WaveData waveData = new WaveData(); -// RmpEventDetailPO eventDetail = rmpEventDetailMapper.selectById(eventIndex); -// if (Objects.nonNull(eventDetail)) { -// //获取PT变比 -// List lineInfoVOList = lineFeignClient.getBaseLineAreaInfo(Stream.of(eventDetail.getLineId()).collect(Collectors.toList())).getData(); -// AreaLineInfoVO line = lineInfoVOList.get(0); -// waveData.setLineName(line.getLineName()); -// /*********** Modify by xuyang 添加变电站名称---Start **************/ -// waveData.setSubName(line.getSubName()); -// /*********** Modify by xuyang ---End **************/ -// waveData.setEventValue(BigDecimal.valueOf(eventDetail.getFeatureAmplitude()*100).setScale(2, RoundingMode.HALF_UP).floatValue()); -// waveData.setPersistTime(BigDecimal.valueOf(eventDetail.getDuration()*100).setScale(3, RoundingMode.HALF_UP).floatValue()); -// waveData.setTrigeTime(AnalyWave.getTimeWave()); -// if (Objects.nonNull(line)) { -// float pt1 = line.getPt1(); -// float pt2 = line.getPt2(); -// float pt = (pt1) / (pt2); -// waveData.setPt(pt); -// float ct1 = line.getCt1(); -// float ct2 = line.getCt2(); -// float ct = (ct1) / (ct2); -// waveData.setCt(ct); -// //获取接线方式 -// if (line.getVHarmonicValue() != 0) { -// //赋值abc三相名称 -// if (lineDetail.getPtType() == 2) { -// waveData.setOpen(true); -// } -// } -// } -// //严重度 -// Float yzd = eventDetail.getSeverity(); -// if (null == yzd || yzd == 0.0) { -// // 前去计算严重度 -// yzd = Float.parseFloat(getYzd(eventDetail.getPersistTime(), eventDetail.getEventValue())); -// eventDetail.setSeverity(yzd); -// //回填严重度到数据库中 -// updateEventDeatilYzd(eventDetail); -// } -// waveData.setYzd(yzd); -// //暂降发生时间 -// String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(eventDetail.getTimeId()) + "." + PubUtils.getMs(eventDetail.getMs()); -// waveData.setTime(time); -// //暂降类型 -// // 获取暂降类型的数据字典 暂降类型 -// List voltageType = redisCacheUtil.getVoltageType(); -// for (DicData dicData : voltageType) { -// if (dicData.getDicIndex().equals(eventDetail.getEventType())) { -// waveData.setWaveType(dicData.getDicName()); -// break; -// } -// } -// if (Integer.parseInt(eventDetail.getFileFlag()) == 1) { -// //根据暂降事件，返回波形文件名 -// LineInfoVO ip = lineFeignClient.getLineInfoVO(eventIndex); -// if (StringUtils.isBlank(ip)) { -// return waveData; -// } -// String path = appConfig.getWavePath(); -// path = path + File.separator + ip; -// String waveName = getWaveName(eventDetail, path); -// String pathTemp = path + File.separator + waveName; -// File file = new File(pathTemp); -// // 判断文件是否存在 -// if (file.isFile() && file.exists()) { -// System.out.println(pathTemp + "路径下，文件找到了"); -// //CFG文件路径 pathTemp -// //获取波形的瞬时值、RMS值数据 -// AnalyWave analyWave = new AnalyWave(); -// WaveDataDTO tagDataValue = waveRead(eventDetail.getWavePath(),ip); -// List> shunWave = tagDataValue.getListWaveData();//获取瞬时波形值 -// List> rmsWave = tagDataValue.getListRmsData();//RMS值波形 -// waveData.setnOneWaveNum(analyWave.getnOneWaveNum()); -// waveData.setSunData(shunWave); -// waveData.setTmpWaveTitle(tagDataValue.getWaveTitle()); -// waveData.setFirstMs(analyWave.getFirstMs()); -// waveData.setFirstTime(analyWave.getFirstTime()); -// waveData.setRmsData(rmsWave); -// waveData.setRatesCfg(analyWave.getRatesCfg()); -// /*********** Modify by yexibao ---Start **************/ -// waveData.setiPhasic(tagDataValue.getIPhasic()); -// /*********** Modify by yexibao ---End **************/ -// List tmpWaveTitle = tagDataValue.getWaveTitle(); -// /*********** Modify by yexibao ---Start **************/ -// for (int i = 0; i < tagDataValue.getIPhasic(); i++) { -// if (tmpWaveTitle.get(i + 1).substring(1).indexOf("A") > -1) -// waveData.setA(tmpWaveTitle.get(i + 1).substring(1)); -// if (tmpWaveTitle.get(i + 1).substring(1).indexOf("B") > -1) -// waveData.setB(tmpWaveTitle.get(i + 1).substring(1)); -// if (tmpWaveTitle.get(i + 1).substring(1).indexOf("C") > -1) -// waveData.setC(tmpWaveTitle.get(i + 1).substring(1)); -// } -// /*********** Modify by yexibao ---End **************/ -// -// } else { -// System.out.println(pathTemp + "路径下，文件找不到了"); -// } -// } -// } -// return waveData; -// } -// -// -// -// public WaveDataDTO waveRead(String waveName,String ip){ -// WaveDataDTO waveDataDTO; -// String cfgPath, datPath, cfgPath2, datPath2; -// if (generalInfo.getBusinessWaveFileStorage() == GeneralConstant.LOCAL_DISK) { -// cfgPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.CFG; -// datPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.DAT; -// log.info("本地磁盘波形文件路径----" + cfgPath); -// InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath); -// InputStream datStream = waveFileComponent.getFileInputStreamByFilePath(datPath); -// if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { -// throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); -// } -// waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1); -// } else { -// cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG; -// datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT; -// //适配文件后缀小写 -// cfgPath2 = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG.toLowerCase(); -// datPath2 = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT.toLowerCase(); -// log.info("文件服务器波形文件路径----" + cfgPath); -// try ( -// InputStream cfgStream = fileStorageUtil.getFileStream(cfgPath); -// InputStream datStream = fileStorageUtil.getFileStream(datPath) -// ) { -// if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { -// throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); -// } -// waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 0); -// } catch (Exception e) { -// try { -// InputStream cfgStream = fileStorageUtil.getFileStream(cfgPath2); -// InputStream datStream = fileStorageUtil.getFileStream(datPath2); -// if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { -// throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); -// } -// waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 0); -// } catch (Exception e1) { -// throw new BusinessException(WaveFileResponseEnum.WAVE_DATA_INVALID); -// } -// -// } -// } -// return waveDataDTO; -// } -//} +package com.njcn.event.common.service.impl; + +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; +import com.njcn.advance.api.EventWaveAnalysisFeignClient; +import com.njcn.advance.pojo.dto.waveAnalysis.EntityAdvancedData; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.utils.PubUtils; +import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; +import com.njcn.event.common.pojo.dto.EventEigDetail; +import com.njcn.event.common.service.WaveService; +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.event.pojo.po.RmpEventDetailPO; +import com.njcn.oss.constant.GeneralConstant; +import com.njcn.oss.constant.OssPath; +import com.njcn.oss.utils.FileStorageUtil; +import com.njcn.system.api.DicDataFeignClient; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.io.InputStream; +import java.util.*; + + +/** + * @Author: cdf + * @CreateTime: 2026-02-26 + * @Description: + */ +@Service +@RequiredArgsConstructor +@Slf4j +public class WaveServiceImpl implements WaveService { + + private final WaveFileComponent waveFileComponent; + private final FileStorageUtil fileStorageUtil; + private final EventWaveAnalysisFeignClient eventWaveAnalysisFeignClient; + + /** + * 根据暂降事件索引获取波形数据 + * 注：当前只考虑本地的波形文件 + * + * @param eventDetail 暂态事件 + * @param line 监测点 + */ + @Override + public WaveDataDTO getWavedata(RmpEventDetailPO eventDetail, AreaLineInfoVO line) { + WaveDataDTO waveDataDTO = null; + if (ObjectUtil.isNotEmpty(line)) { + String waveName = eventDetail.getWavePath(); + if (StrUtil.isBlank(waveName)) { + throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); + } + String wavePath = OssPath.WAVE_DIR + line.getIp() + StrUtil.SLASH + waveName; + try ( + InputStream cfgStream = fileStorageUtil.getFileStream(wavePath + GeneralConstant.CFG); + InputStream datStream = fileStorageUtil.getFileStream(wavePath + GeneralConstant.DAT) + ) { + if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { + throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); + } + waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1); + } catch (Exception e) { + try { + InputStream cfgStreamLower = fileStorageUtil.getFileStream(wavePath + GeneralConstant.CFG_LOWER); + InputStream datStreamLower = fileStorageUtil.getFileStream(wavePath + GeneralConstant.DAT_LOWER); + if (Objects.isNull(cfgStreamLower) || Objects.isNull(datStreamLower)) { + throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); + } + waveDataDTO = waveFileComponent.getComtrade(cfgStreamLower, datStreamLower, 1); + } catch (Exception e1) { + throw new BusinessException(WaveFileResponseEnum.WAVE_DATA_INVALID); + } + } + waveDataDTO = waveFileComponent.getValidData(waveDataDTO); + waveDataDTO.setPtType(line.getPtType()); + waveDataDTO.setPt(line.getPt1() * 1.0 / line.getPt2()); + waveDataDTO.setCt(line.getCt1() * 1.0 / line.getCt2()); + waveDataDTO.setMonitorName(line.getLineName()); + } + return waveDataDTO; + } + + @Override + public List eventDetailEigenvalue(String eventDetailIndex,Integer ptType) { + List eventInfoDetails = new ArrayList<>(); + EntityAdvancedData entityAdvancedData = eventWaveAnalysisFeignClient.analysis(eventDetailIndex).getData() ; + if (entityAdvancedData.backNumber != -1) { + for (int i = 0; i < entityAdvancedData.backNumber; i++) { + EventEigDetail eventEigDetail = new EventEigDetail(); + eventEigDetail.setHold_time_dq(entityAdvancedData.evt_buf[i].hold_time_dq * 1000); + eventEigDetail.setPow_a(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].POW_a)); + eventEigDetail.setPow_b(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].POW_b)); + eventEigDetail.setPow_c(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].POW_c)); + + eventEigDetail.setVoltagechange_Va(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].Voltagechange_Va / 1000)); + eventEigDetail.setVoltagechange_Vb(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].Voltagechange_Vb / 1000)); + eventEigDetail.setVoltagechange_Vc(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].Voltagechange_Vc / 1000)); + + + eventEigDetail.setUa_min(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].ua_min[0])); + eventEigDetail.setUb_min(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].ub_min[0])); + eventEigDetail.setUc_min(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].ua_min[0])); + + eventEigDetail.setAngle_diff_ap(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].angle_diff_ap[0])); + eventEigDetail.setAngle_diff_bp(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].angle_diff_bp[0])); + eventEigDetail.setAngle_diff_cp(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].angle_diff_cp[0])); + + eventEigDetail.setBph_max_value(PubUtils.floatRound(2, entityAdvancedData.evt_buf[i].bph_max_value[0])); + eventEigDetail.setSagReason(entityAdvancedData.sagReason[0]);//暂降原因，暂降原因都一样 + eventEigDetail.setSagType(entityAdvancedData.sagType[i]);//暂降类型 + eventInfoDetails.add(eventEigDetail); + eventEigDetail.setPttype(ptType); + } + } else { + eventInfoDetails = null; + } + return eventInfoDetails; + } + + +} diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/utils/WordUtil.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/utils/WordUtil.java index e5ba08c93..c549005a7 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/utils/WordUtil.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/utils/WordUtil.java @@ -1,684 +1,342 @@ -//package com.njcn.event.common.utils; -// -// -//import com.njcn.event.common.pojo.dto.EventEigDetail; -//import com.njcn.event.pojo.po.RmpEventDetailPO; -//import net.sf.json.JSONArray; -//import org.apache.poi.openxml4j.exceptions.InvalidFormatException; -//import org.apache.poi.util.Units; -//import org.apache.poi.xwpf.usermodel.*; -//import org.openxmlformats.schemas.wordprocessingml.x2006.main.*; -//import sun.misc.BASE64Decoder; -// -//import java.io.ByteArrayInputStream; -//import java.io.IOException; -//import java.io.InputStream; -//import java.math.BigInteger; -//import java.text.SimpleDateFormat; -//import java.util.*; -// -//public class WordUtil { -// private Map> listShunPic = new HashMap<>(); -// private Map> listRmsPic = new HashMap<>(); -// private XWPFDocument document; -// private Map> eventDetailEigenvalue = new HashMap<>(); -// private Map eventInfoList = new HashMap<>(); -// -// public void setEventInfoList(Integer index, RmpEventDetailPO eventInfoList) { -// RmpEventDetailPO tmp = eventInfoList == null ? new RmpEventDetailPO() : eventInfoList; -// this.eventInfoList.put(index, tmp); -// } -// -// public void setEventDetailEigenvalue(Integer index, List eventDetailEigenvalue) { -// List tmp = eventDetailEigenvalue == null ? new ArrayList<>() : eventDetailEigenvalue; -// this.eventDetailEigenvalue.put(index, tmp); -// } -// -// public XWPFDocument getDocument() { -// return document; -// } -// -// public WordUtil() { -// this.document = new XWPFDocument(); -// } -// -// public void translateShun(Integer index, List strPic) { -// BASE64Decoder decoder = new BASE64Decoder(); -// List tmp = new ArrayList<>(); -// -// for (int i = 0; i < strPic.size(); i++) { -// try { -// byte[] buffer = decoder.decodeBuffer(strPic.get(i)); -// tmp.add(buffer); -// } catch (Exception e) { -// } -// } -// listShunPic.put(index, tmp); -// } -// -// public void translateRms(Integer index, List strPic) { -// BASE64Decoder decoder = new BASE64Decoder(); -// List tmp = new ArrayList<>(); -// -// for (int i = 0; i < strPic.size(); i++) { -// try { -// byte[] buffer = decoder.decodeBuffer(strPic.get(i)); -// tmp.add(buffer); -// } catch (Exception e) { -// } -// } -// listRmsPic.put(index, tmp); -// } -// -// public void createReport(Integer length) throws IOException, InvalidFormatException { -// setHeadingStyle(this.document); -// -// // 添加标题 -// XWPFParagraph titleParagraph = getCenterParagraph(this.document); -// addLine(titleParagraph, 11); -// // 设置段落居中 -// XWPFRun titleParagraphBigRun = titleParagraph.createRun(); -// addParagraph(titleParagraphBigRun, "宋体", 28, "000000", "暂降事件报告", true); -// addLine(titleParagraph, 17); -// XWPFRun titleParagraphDateRun = titleParagraph.createRun(); -// addParagraph(titleParagraphDateRun, "宋体", 16, "000000", "南京灿能电力自动化股份有限公司", false); -// addLine(titleParagraph, 1); -// titleParagraphDateRun = titleParagraph.createRun(); -// addParagraph(titleParagraphDateRun, "宋体", 14, "000000", "生成时间：" + getRightNow(), false); -// addLine(titleParagraph, 8); -// titleParagraph = getLeftParagraph(this.document); -// titleParagraphDateRun = titleParagraph.createRun(); -// addParagraph(titleParagraphDateRun, "宋体", 10, "000000", "【申明】本公司保留对报告的修改权，恕不另行通知，敬请关注最新版本。", false); -// for (int m = 0; m < length; m++) { -// List eventDetailEigenvaluetmp = this.eventDetailEigenvalue.get(m); -// -// SimpleDateFormat sdfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); -// String time = sdfs.format(eventInfoList.get(m).getStartTime()); -// createTitle(document, String.valueOf(m+1) + ". " +time, "标题 1", 0, 20); -// createTitle(document, String.valueOf(m+1) + "." +"1. 基本信息", "标题 2", 0, 15); -// XWPFParagraph introductionContentParagraph = getLeftParagraph(document); -// introductionContentParagraph.setIndentationFirstLine(200); -// XWPFRun introductionContentRun = introductionContentParagraph.createRun(); -// addParagraph(introductionContentRun, "宋体", 11, "000000", -// eventInfoList.get(m).getGdName() + "，" + eventInfoList.get(m).getBdzName() + "，网络参数：" + eventInfoList.get(m).getIp() -// + "，" + eventInfoList.get(m).getLineName() + "于" + time + "发生暂降事件，特征幅值：" -// + String.valueOf(eventInfoList.get(m).getEventValue()) + "%，持续时间：" + eventInfoList.get(m).getPersistTime() -// + "s。", -// false); -// createTitle(document, String.valueOf(m+1) + "." +"2. 波形图", "标题 2", 0, 15); -// createTitle(document, String.valueOf(m+1) + "." +"2.1 瞬时波形图", "标题 3", 200, 11); -// for(int shun = 0;shun< listShunPic.get(m).size();shun++){ -// createPic(document, "瞬时波形"+String.valueOf(shun), listShunPic.get(m).get(shun)); -// } -// createTitle(document, String.valueOf(m+1) + "." +"2.2 RMS波形图", "标题 3", 200, 11); -// for(int rms = 0;rms< listRmsPic.get(m).size();rms++){ -// createPic(document, "RMS波形"+String.valueOf(rms), listRmsPic.get(m).get(rms)); -// } -// createTitle(document, String.valueOf(m+1) + "." +"3. 多特征值", "标题 2", 0, 15); -// -// XWPFParagraph value = getLeftParagraph(document); -// XWPFRun valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", "事件总分段数：" + eventDetailEigenvaluetmp.size(), false); -// addLine(value, 1); -// -// if (eventDetailEigenvaluetmp.size() == 0) { -// continue; -// } -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", "暂降原因：" + eventDetailEigenvaluetmp.get(0).getSagReason(), false); -// addLine(value, 1); -// -// for (int i = 0; i < eventDetailEigenvaluetmp.size(); i++) { -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", "分段" + (i + 1) + "多特征值", true); -// addLine(value, 1); -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", -// "波形起始点相位(°)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" -// + eventDetailEigenvaluetmp.get(i).getPow_a() + " " -// + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" -// + eventDetailEigenvaluetmp.get(i).getPow_b() + " " -// + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" -// : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" -// + eventDetailEigenvaluetmp.get(i).getPow_c())), -// false); -// addLine(value, 1); -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", -// "跳变段电压变化率(V/ms)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" -// + eventDetailEigenvaluetmp.get(i).getVoltagechange_Va() + " " -// + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" -// + eventDetailEigenvaluetmp.get(i).getVoltagechange_Vb() + " " -// + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" -// : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" -// + eventDetailEigenvaluetmp.get(i).getVoltagechange_Vc())), -// false); -// addLine(value, 1); -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", -// "相位跳变(°)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" -// + eventDetailEigenvaluetmp.get(i).getAngle_diff_ap() + " " -// + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" -// + eventDetailEigenvaluetmp.get(i).getAngle_diff_bp() + " " -// + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" -// : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" -// + eventDetailEigenvaluetmp.get(i).getAngle_diff_cp())), -// false); -// /* -// * addLine(value, 1); valuex = value.createRun(); -// * addParagraph(valuex, "宋体", 11, "000000", "特征幅值(V)：A相" + -// * this.eventDetailEigenvalue.get(i).getUa_min() + " B相" + -// * this.eventDetailEigenvalue.get(i).getUb_min() + " C相" + -// * this.eventDetailEigenvalue.get(i).getUc_min(), false); -// */ -// /* -// * addLine(value, 1); valuex = value.createRun(); -// * addParagraph(valuex, "宋体", 11, "000000", "持续时间(ms)：" + -// * this.eventDetailEigenvalue.get(i).getHold_time_dq(), false); -// */ -// addLine(value, 1); -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", -// "不平衡度(%)：" + eventDetailEigenvaluetmp.get(i).getBph_max_value(), false); -// addLine(value, 1); -// valuex = value.createRun(); -// addParagraph(valuex, "宋体", 11, "000000", "暂降类型：" + eventDetailEigenvaluetmp.get(i).getSagType(), -// false); -// addLine(value, 1); -// } -// } -// } -// -// public void createPic(XWPFDocument document, String name, byte[] base64Info) -// throws IOException, InvalidFormatException { -// XWPFParagraph picParagraph = getCenterParagraph(document); -// XWPFRun createRun = picParagraph.createRun(); -// InputStream in = new ByteArrayInputStream(base64Info); -// createRun.addPicture(in, 5, name, Units.toEMU(410), Units.toEMU(170)); -// } -// -// public void createTitle(XWPFDocument document, String message, String style, int line, int fontSize) { -// XWPFParagraph summaeTableParagraph = getLeftParagraph(document); -// summaeTableParagraph.setStyle(style); -// summaeTableParagraph.setIndentationFirstLine(line); -// XWPFRun summaeTableRun = summaeTableParagraph.createRun(); -// addParagraph(summaeTableRun, "宋体", fontSize, "000000", message, false); -// } -// -// public void setParagraphStyle(XWPFParagraph paragraph) { -// paragraph.setSpacingBefore(100); -// paragraph.setSpacingAfter(100); -// } -// -// /** -// * 返回指定格式的段落 居中型 -// * -// * @param document -// * 文档对象 -// */ -// public XWPFParagraph getCenterParagraph(XWPFDocument document) { -// XWPFParagraph paragraph = document.createParagraph(); -// setParagraphStyle(paragraph); -// paragraph.setAlignment(ParagraphAlignment.CENTER); -// paragraph.setVerticalAlignment(TextAlignment.CENTER); -// return paragraph; -// } -// -// /** -// * 返回指定格式的段落 居左型 -// * -// * @param document -// * 文档对象 -// */ -// public XWPFParagraph getLeftParagraph(XWPFDocument document) { -// XWPFParagraph paragraph = document.createParagraph(); -// setParagraphStyle(paragraph); -// paragraph.setAlignment(ParagraphAlignment.LEFT); -// return paragraph; -// } -// -// /** -// * 添加换行符 -// * -// * @param paragraph -// * 指定段落 -// * @param amount -// * 行数 -// */ -// public void addLine(XWPFParagraph paragraph, Integer amount) { -// XWPFRun run = paragraph.createRun(); -// run.setFontSize(11); -// for (int i = 0; i < amount; i++) { -// run.addCarriageReturn(); -// } -// } -// -// /** -// * 添加段落文本 -// * -// * @param run -// * 文本执行对象 -// * @param fontFamily -// * 字体类型 -// * @param fontSize -// * 字体大小 -// * @param backgroundColor -// * 字体颜色 -// * @param bold -// * 是否加粗 -// */ -// public void addParagraph(XWPFRun run, String fontFamily, Integer fontSize, String backgroundColor, String message, -// boolean bold) { -// run.setText(message); -// run.setColor(backgroundColor); -// run.setFontSize(fontSize); -// run.setFontFamily(fontFamily); -// run.setBold(bold); -// } -// -// /** -// * 增加自定义标题样式。这里用的是stackoverflow的源码 -// * -// * @param docxDocument -// * 目标文档 -// * @param strStyleId -// * 样式名称 -// * @param headingLevel -// * 样式级别 -// */ -// public void addCustomHeadingStyle(XWPFDocument docxDocument, String strStyleId, int headingLevel) { -// -// CTStyle ctStyle = CTStyle.Factory.newInstance(); -// ctStyle.setStyleId(strStyleId); -// -// CTString styleName = CTString.Factory.newInstance(); -// styleName.setVal(strStyleId); -// ctStyle.setName(styleName); -// -// CTDecimalNumber indentNumber = CTDecimalNumber.Factory.newInstance(); -// indentNumber.setVal(BigInteger.valueOf(headingLevel)); -// -// // lower number > style is more prominent in the formats bar -// ctStyle.setUiPriority(indentNumber); -// -// CTOnOff onoffnull = CTOnOff.Factory.newInstance(); -// ctStyle.setUnhideWhenUsed(onoffnull); -// -// // style shows up in the formats bar -// ctStyle.setQFormat(onoffnull); -// -// // style defines a heading of the given level -// CTPPr ppr = CTPPr.Factory.newInstance(); -// ppr.setOutlineLvl(indentNumber); -// ctStyle.setPPr(ppr); -// -// XWPFStyle style = new XWPFStyle(ctStyle); -// -// // is a null op if already defined -// XWPFStyles styles = docxDocument.createStyles(); -// -// style.setType(STStyleType.PARAGRAPH); -// styles.addStyle(style); -// -// } -// -// /** -// * 设置文档中标题格式 -// */ -// public void setHeadingStyle(XWPFDocument document) { -// addCustomHeadingStyle(document, "标题 1", 1); -// addCustomHeadingStyle(document, "标题 2", 2); -// addCustomHeadingStyle(document, "标题 3", 3); -// addCustomHeadingStyle(document, "标题 4", 4); -// addCustomHeadingStyle(document, "标题 5", 5); -// addCustomHeadingStyle(document, "标题 6", 6); -// addCustomHeadingStyle(document, "标题 7", 7); -// } -// -// /** -// * 给表格添加一行数据 -// * -// * @param paragraph -// * 段落对象 -// * @param row -// * 行对象 -// * @param data -// * 不定长度的数据 -// */ -// public void setExcelContent(XWPFParagraph paragraph, XWPFTableRow row, String... data) { -// for (int i = 0; i < data.length; i++) { -// XWPFRun run = paragraph.createRun(); -// run.setFontFamily("宋体"); -// run.setText(data[i]); -// row.getCell(i).setParagraph(paragraph); -// paragraph.removeRun(0); -// } -// } -// -// /** -// * 添加表头标题一行数据 -// * -// * @param paragraph -// * 段落对象 -// * @param row -// * 行对象 -// * @param data -// * 不定长度的数据 -// */ -// public void setExcelHeadContent(XWPFParagraph paragraph, XWPFTableRow row, String... data) { -// XWPFRun run = paragraph.createRun(); -// run.setFontFamily("宋体"); -// run.setBold(true); -// run.setText(data[0]); -// row.getCell(0).setParagraph(paragraph); -// paragraph.removeRun(0); -// for (int i = 1; i < data.length; i++) { -// XWPFRun run1 = paragraph.createRun(); -// run1.setFontFamily("宋体"); -// run1.setBold(true); -// run1.setText(data[i]); -// row.addNewTableCell().setParagraph(paragraph); -// paragraph.removeRun(0); -// } -// } -// -// /** -// * 获取当前的日期 -// * -// * @return -// */ -// public String getRightNow() { -// Calendar rightNow = Calendar.getInstance(); -// Integer year = rightNow.get(Calendar.YEAR); -// Integer month = rightNow.get(Calendar.MONTH) + 1; -// Integer day = rightNow.get(rightNow.DAY_OF_MONTH); -// return year + "年" + month + "月" + day + "日"; -// } -// -// public String createWave(WaveData waveData) throws Exception { -// HashMap datas = new HashMap<>(); -// List> sunData = waveData.getSunData(); -// int iphasic =waveData.getiPhasic(); -// float pt = waveData.getPt() / 1000; -// float ifmax = 0f, ifmin = 0f; -// List> adata = new ArrayList<>(); -// List> bdata = new ArrayList<>(); -// List> cdata = new ArrayList<>(); -// -// if (sunData.size() > 0) { -// ifmax = sunData.get(0).get(1) * pt; -// ifmin = sunData.get(0).get(1) * pt; -// } -// List colors =new ArrayList<>(); -// -// for (int i = 0; i < sunData.size(); i++) { -// float x = sunData.get(i).get(0); -// if(iphasic==1){ -// float shunFirstA = sunData.get(i).get(1) * pt; -// List a = new ArrayList() { -// { -// add(x); -// add(shunFirstA); -// } -// }; -// adata.add(a); -// ifmax = ifmax > shunFirstA ? ifmax : shunFirstA; -// ifmin = ifmin < shunFirstA ? ifmin : shunFirstA; -// colors.add("#DAA520"); -// colors.add("#fff"); -// colors.add("#fff"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", ""); -// datas.put("c", ""); -// }else if(iphasic==2){ -// float shunFirstA = sunData.get(i).get(1) * pt; -// float shunFirstB = sunData.get(i).get(2) * pt; -// List a = new ArrayList() { -// { -// add(x); -// add(shunFirstA); -// } -// }; -// adata.add(a); -// -// List b = new ArrayList() { -// { -// add(x); -// add(shunFirstB); -// } -// }; -// bdata.add(b); -// -// ifmax = getMaxTwo(ifmax, shunFirstA, shunFirstB); -// ifmin = getMinTwo(ifmin, shunFirstA, shunFirstB); -// -// colors.add("#DAA520"); -// colors.add("#2E8B57"); -// colors.add("#fff"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", waveData.getB()); -// datas.put("c", ""); -// -// }else if(iphasic==3){ -// float shunFirstA = sunData.get(i).get(1) * pt; -// float shunFirstB = sunData.get(i).get(2) * pt; -// float shunFirstC = sunData.get(i).get(3) * pt; -// List a = new ArrayList() { -// { -// add(x); -// add(shunFirstA); -// } -// }; -// adata.add(a); -// -// List b = new ArrayList() { -// { -// add(x); -// add(shunFirstB); -// } -// }; -// bdata.add(b); -// -// List c = new ArrayList() { -// { -// add(x); -// add(shunFirstC); -// } -// }; -// cdata.add(c); -// ifmax = getMax(ifmax, shunFirstA, shunFirstB, shunFirstC); -// ifmin = getMin(ifmin, shunFirstA, shunFirstB, shunFirstC); -// -// colors.add("#DAA520"); -// colors.add("#2E8B57"); -// colors.add("#A52a2a"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", waveData.getB()); -// datas.put("c", waveData.getC()); -// } -// -// -// } -// -// String time = waveData.getTime(); -// time = time.replace(" ", "%20"); -// float severity = waveData.getYzd(); -// String strSeverity = String.valueOf(severity); -// String type = waveData.getWaveType(); -// -// if (severity < 0) { -// strSeverity = "/"; -// type = "/"; -// } -// -// String title = "监测点名称：" + waveData.getLineName() + "%20发生时刻：" + time + "%20特征幅值：" + waveData.getEventValue() -// + "%25%20持续时间：" + waveData.getPersistTime() + "s"; -// -// -// datas.put("title", title); -// datas.put("adata", JSONArray.fromObject(adata).toString()); -// datas.put("bdata", JSONArray.fromObject(bdata).toString()); -// datas.put("cdata", JSONArray.fromObject(cdata).toString()); -// datas.put("unit", "kV"); -// datas.put("max", String.valueOf(ifmax)); -// datas.put("min", String.valueOf(ifmin)); -// datas.put("colors", JSONArray.fromObject(colors).toString()); -// datas.put("cshow", Boolean.toString(!waveData.getOpenTri())); -// -// -// String option = FreemarkerUtil.generateString("wave.ftl", "com/pqs9200/template", datas); -// return EchartsUtil.generateEchartsBase64(option, "3003"); -// } -// -// public String createRms(WaveData waveData) throws IOException, TemplateException { -// List> rmsData = waveData.getRmsData(); -// HashMap datas = new HashMap<>(); -// int iphasic =waveData.getiPhasic(); -// float pt = waveData.getPt() / 1000; -// List> adata = new ArrayList<>(); -// List> bdata = new ArrayList<>(); -// List> cdata = new ArrayList<>(); -// -// List colors =new ArrayList<>(); -// for (int i = 0; i < rmsData.size(); i++) { -// float x = rmsData.get(i).get(0); -// if(iphasic==1){ -// float rmsFirstA = rmsData.get(i).get(1) * pt; -// List a = new ArrayList() { -// { -// add(x); -// add(rmsFirstA); -// } -// }; -// adata.add(a); -// -// colors.add("#DAA520"); -// colors.add("#fff"); -// colors.add("#fff"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", ""); -// datas.put("c", ""); -// }else if(iphasic==2){ -// float rmsFirstA = rmsData.get(i).get(1) * pt; -// float rmsFirstB = rmsData.get(i).get(2) * pt; -// List a = new ArrayList() { -// { -// add(x); -// add(rmsFirstA); -// } -// }; -// adata.add(a); -// -// List b = new ArrayList() { -// { -// add(x); -// add(rmsFirstB); -// } -// }; -// bdata.add(b); -// -// colors.add("#DAA520"); -// colors.add("#2E8B57"); -// colors.add("#fff"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", waveData.getB()); -// datas.put("c", ""); -// }else if(iphasic==3){ -// float rmsFirstA = rmsData.get(i).get(1) * pt; -// float rmsFirstB = rmsData.get(i).get(2) * pt; -// float rmsFirstC = rmsData.get(i).get(3) * pt; -// -// List a = new ArrayList() { -// { -// add(x); -// add(rmsFirstA); -// } -// }; -// adata.add(a); -// -// List b = new ArrayList() { -// { -// add(x); -// add(rmsFirstB); -// } -// }; -// bdata.add(b); -// -// List c = new ArrayList() { -// { -// add(x); -// add(rmsFirstC); -// } -// }; -// cdata.add(c); -// -// colors.add("#DAA520"); -// colors.add("#2E8B57"); -// colors.add("#A52a2a"); -// -// datas.put("a", waveData.getA()); -// datas.put("b", waveData.getB()); -// datas.put("c", waveData.getC()); -// } -// -// -// } -// -// String time = waveData.getTime(); -// time = time.replace(" ", "%20"); // 时分秒 -// float severity = waveData.getYzd(); -// String strSeverity = String.valueOf(severity); -// String type = waveData.getWaveType(); -// -// if (severity < 0) { -// strSeverity = "/"; -// type = "/"; -// } -// -// String title = "监测点名称：" + waveData.getLineName() + "%20发生时刻：" + time + "%20特征幅值：" + waveData.getEventValue() -// + "%25%20持续时间：" + waveData.getPersistTime() + "s"; -// -// -// datas.put("title", title); -// datas.put("adata", JSONArray.fromObject(adata).toString()); -// datas.put("bdata", JSONArray.fromObject(bdata).toString()); -// datas.put("cdata", JSONArray.fromObject(cdata).toString()); -// datas.put("unit", "kV"); -// datas.put("colors", JSONArray.fromObject(colors).toString()); -// datas.put("cshow", Boolean.toString(!waveData.getOpenTri())); -// -// String option = FreemarkerUtil.generateString("rms.ftl", "com/pqs9200/template", datas); -// return EchartsUtil.generateEchartsBase64(option, "3003"); -// } -// -// private float getMin(float temp, float tempA, float tempB, float tempC) { -// temp = temp < tempA ? temp : tempA; -// temp = temp < tempB ? temp : tempB; -// temp = temp < tempC ? temp : tempC; -// return temp; -// } -// -// private float getMinTwo(float temp, float tempA, float tempB) { -// temp = temp < tempA ? temp : tempA; -// temp = temp < tempB ? temp : tempB; -// return temp; -// } -// -// private float getMax(float temp, float tempA, float tempB, float tempC) { -// temp = temp > tempA ? temp : tempA; -// temp = temp > tempB ? temp : tempB; -// temp = temp > tempC ? temp : tempC; -// return temp; -// } -// -// private float getMaxTwo(float temp, float tempA, float tempB) { -// temp = temp > tempA ? temp : tempA; -// temp = temp > tempB ? temp : tempB; -// return temp; -// } -//} +package com.njcn.event.common.utils; + + +import com.njcn.event.common.pojo.dto.EventEigDetail; +import com.njcn.event.common.pojo.dto.EventInfoDetailVO; +import org.apache.poi.openxml4j.exceptions.InvalidFormatException; +import org.apache.poi.util.Units; +import org.apache.poi.xwpf.usermodel.*; +import org.openxmlformats.schemas.wordprocessingml.x2006.main.*; +import sun.misc.BASE64Decoder; + +import java.io.ByteArrayInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.math.BigInteger; +import java.time.format.DateTimeFormatter; +import java.util.*; + +public class WordUtil { + private Map> listShunPic = new HashMap<>(); + private Map> listRmsPic = new HashMap<>(); + private XWPFDocument document; + private Map> eventDetailEigenvalue = new HashMap<>(); + private Map eventInfoList = new HashMap<>(); + + public void setEventInfoList(String index, EventInfoDetailVO eventInfoList) { + EventInfoDetailVO tmp = eventInfoList == null ? new EventInfoDetailVO() : eventInfoList; + this.eventInfoList.put(index, tmp); + } + + public void setEventDetailEigenvalue(String index, List eventDetailEigenvalue) { + List tmp = eventDetailEigenvalue == null ? new ArrayList<>() : eventDetailEigenvalue; + this.eventDetailEigenvalue.put(index, tmp); + } + + public XWPFDocument getDocument() { + return document; + } + + public WordUtil() { + this.document = new XWPFDocument(); + } + + public void translateShun(String index, String strShunPic) { + BASE64Decoder decoder = new BASE64Decoder(); + List tmp = new ArrayList<>(); + try { + byte[] buffer = decoder.decodeBuffer(strShunPic); + tmp.add(buffer); + } catch (Exception e) { + } + listShunPic.put(index, tmp); + } + + public void translateRms(String index, String strRmsPic) { + BASE64Decoder decoder = new BASE64Decoder(); + List tmp = new ArrayList<>(); + try { + byte[] buffer = decoder.decodeBuffer(strRmsPic); + tmp.add(buffer); + } catch (Exception e) { + } + listRmsPic.put(index, tmp); + } + + public void createReport(List eventIndex) throws IOException, InvalidFormatException { + setHeadingStyle(this.document); + + // 添加标题 + XWPFParagraph titleParagraph = getCenterParagraph(this.document); + addLine(titleParagraph, 11); + // 设置段落居中 + XWPFRun titleParagraphBigRun = titleParagraph.createRun(); + addParagraph(titleParagraphBigRun, "宋体", 28, "000000", "暂降事件报告", true); + addLine(titleParagraph, 17); + XWPFRun titleParagraphDateRun = titleParagraph.createRun(); + addParagraph(titleParagraphDateRun, "宋体", 16, "000000", "南京灿能电力自动化股份有限公司", false); + addLine(titleParagraph, 1); + titleParagraphDateRun = titleParagraph.createRun(); + addParagraph(titleParagraphDateRun, "宋体", 14, "000000", "生成时间：" + getRightNow(), false); + addLine(titleParagraph, 8); + titleParagraph = getLeftParagraph(this.document); + titleParagraphDateRun = titleParagraph.createRun(); + addParagraph(titleParagraphDateRun, "宋体", 10, "000000", "【申明】本公司保留对报告的修改权，恕不另行通知，敬请关注最新版本。", false); + for (int m = 0; m < eventIndex.size(); m++) { + String eventId = eventIndex.get(m); + List eventDetailEigenvaluetmp = this.eventDetailEigenvalue.get(eventId); + String time = eventInfoList.get(eventId).getTimeID().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")); + createTitle(document, (m + 1) + ". " + time, "标题 1", 0, 20); + createTitle(document, (m + 1) + "." + "1. 基本信息", "标题 2", 0, 15); + XWPFParagraph introductionContentParagraph = getLeftParagraph(document); + introductionContentParagraph.setIndentationFirstLine(200); + XWPFRun introductionContentRun = introductionContentParagraph.createRun(); + addParagraph(introductionContentRun, "宋体", 11, "000000", eventInfoList.get(eventId).getGdName() + "，" + eventInfoList.get(eventId).getBdzName() + "，网络参数：" + eventInfoList.get(eventId).getIp() + "，" + eventInfoList.get(eventId).getLineName() + "于" + time + "发生暂降事件，特征幅值：" + (eventInfoList.get(eventId).getEventValue()) + "%，持续时间：" + eventInfoList.get(eventId).getPersistTime() + "s。", false); + createTitle(document, (m + 1) + "." + "2. 波形图", "标题 2", 0, 15); + createTitle(document, (m + 1) + "." + "2.1 瞬时波形图", "标题 3", 200, 11); + for (int shun = 0; shun < listShunPic.get(eventId).size(); shun++) { + createPic(document, "瞬时波形" + (shun), listShunPic.get(eventId).get(shun)); + } + createTitle(document, (m + 1) + "." + "2.2 RMS波形图", "标题 3", 200, 11); + for (int rms = 0; rms < listRmsPic.get(eventId).size(); rms++) { + createPic(document, "RMS波形" + (eventId), listRmsPic.get(eventId).get(rms)); + } + createTitle(document, (m + 1) + "." + "3. 多特征值", "标题 2", 0, 15); + + XWPFParagraph value = getLeftParagraph(document); + XWPFRun valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "事件总分段数：" + eventDetailEigenvaluetmp.size(), false); + addLine(value, 1); + + if (eventDetailEigenvaluetmp.size() == 0) { + continue; + } + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "暂降原因：" + eventDetailEigenvaluetmp.get(0).getSagReason(), false); + addLine(value, 1); + + for (int i = 0; i < eventDetailEigenvaluetmp.size(); i++) { + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "分段" + (i + 1) + "多特征值", true); + addLine(value, 1); + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "波形起始点相位(°)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" + eventDetailEigenvaluetmp.get(i).getPow_a() + " " + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" + eventDetailEigenvaluetmp.get(i).getPow_b() + " " + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" + eventDetailEigenvaluetmp.get(i).getPow_c())), false); + addLine(value, 1); + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "跳变段电压变化率(V/ms)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" + eventDetailEigenvaluetmp.get(i).getVoltagechange_Va() + " " + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" + eventDetailEigenvaluetmp.get(i).getVoltagechange_Vb() + " " + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" + eventDetailEigenvaluetmp.get(i).getVoltagechange_Vc())), false); + addLine(value, 1); + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "相位跳变(°)：" + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "A" : "AB") + "相" + eventDetailEigenvaluetmp.get(i).getAngle_diff_ap() + " " + (eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "B" : "BC") + "相" + eventDetailEigenvaluetmp.get(i).getAngle_diff_bp() + " " + ((eventDetailEigenvaluetmp.get(0).getPttype() == 2) ? "" : ((eventDetailEigenvaluetmp.get(0).getPttype() == 0 ? "C" : "CA") + "相" + eventDetailEigenvaluetmp.get(i).getAngle_diff_cp())), false); + /* + * addLine(value, 1); valuex = value.createRun(); + * addParagraph(valuex, "宋体", 11, "000000", "特征幅值(V)：A相" + + * this.eventDetailEigenvalue.get(i).getUa_min() + " B相" + + * this.eventDetailEigenvalue.get(i).getUb_min() + " C相" + + * this.eventDetailEigenvalue.get(i).getUc_min(), false); + */ + /* + * addLine(value, 1); valuex = value.createRun(); + * addParagraph(valuex, "宋体", 11, "000000", "持续时间(ms)：" + + * this.eventDetailEigenvalue.get(i).getHold_time_dq(), false); + */ + addLine(value, 1); + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "不平衡度(%)：" + eventDetailEigenvaluetmp.get(i).getBph_max_value(), false); + addLine(value, 1); + valuex = value.createRun(); + addParagraph(valuex, "宋体", 11, "000000", "暂降类型：" + eventDetailEigenvaluetmp.get(i).getSagType(), false); + addLine(value, 1); + } + addLine(value, 1); + } + System.out.println("11"); + } + + public void createPic(XWPFDocument document, String name, byte[] base64Info) throws IOException, InvalidFormatException { + XWPFParagraph picParagraph = getCenterParagraph(document); + XWPFRun createRun = picParagraph.createRun(); + InputStream in = new ByteArrayInputStream(base64Info); + createRun.addPicture(in, 5, name, Units.toEMU(410), Units.toEMU(170)); + } + + public void createTitle(XWPFDocument document, String message, String style, int line, int fontSize) { + XWPFParagraph summaeTableParagraph = getLeftParagraph(document); + summaeTableParagraph.setStyle(style); + summaeTableParagraph.setIndentationFirstLine(line); + XWPFRun summaeTableRun = summaeTableParagraph.createRun(); + addParagraph(summaeTableRun, "宋体", fontSize, "000000", message, false); + } + + public void setParagraphStyle(XWPFParagraph paragraph) { + paragraph.setSpacingBefore(100); + paragraph.setSpacingAfter(100); + } + + /** + * 返回指定格式的段落 居中型 + * + * @param document 文档对象 + */ + public XWPFParagraph getCenterParagraph(XWPFDocument document) { + XWPFParagraph paragraph = document.createParagraph(); + setParagraphStyle(paragraph); + paragraph.setAlignment(ParagraphAlignment.CENTER); + paragraph.setVerticalAlignment(TextAlignment.CENTER); + return paragraph; + } + + /** + * 返回指定格式的段落 居左型 + * + * @param document 文档对象 + */ + public XWPFParagraph getLeftParagraph(XWPFDocument document) { + XWPFParagraph paragraph = document.createParagraph(); + setParagraphStyle(paragraph); + paragraph.setAlignment(ParagraphAlignment.LEFT); + return paragraph; + } + + /** + * 添加换行符 + * + * @param paragraph 指定段落 + * @param amount 行数 + */ + public void addLine(XWPFParagraph paragraph, Integer amount) { + XWPFRun run = paragraph.createRun(); + run.setFontSize(11); + for (int i = 0; i < amount; i++) { + run.addCarriageReturn(); + } + } + + /** + * 添加段落文本 + * + * @param run 文本执行对象 + * @param fontFamily 字体类型 + * @param fontSize 字体大小 + * @param backgroundColor 字体颜色 + * @param bold 是否加粗 + */ + public void addParagraph(XWPFRun run, String fontFamily, Integer fontSize, String backgroundColor, String message, boolean bold) { + run.setText(message); + run.setColor(backgroundColor); + run.setFontSize(fontSize); + run.setFontFamily(fontFamily); + run.setBold(bold); + } + + /** + * 增加自定义标题样式。这里用的是stackoverflow的源码 + * + * @param docxDocument 目标文档 + * @param strStyleId 样式名称 + * @param headingLevel 样式级别 + */ + public void addCustomHeadingStyle(XWPFDocument docxDocument, String strStyleId, int headingLevel) { + + CTStyle ctStyle = CTStyle.Factory.newInstance(); + ctStyle.setStyleId(strStyleId); + + CTString styleName = CTString.Factory.newInstance(); + styleName.setVal(strStyleId); + ctStyle.setName(styleName); + + CTDecimalNumber indentNumber = CTDecimalNumber.Factory.newInstance(); + indentNumber.setVal(BigInteger.valueOf(headingLevel)); + + // lower number > style is more prominent in the formats bar + ctStyle.setUiPriority(indentNumber); + + CTOnOff onoffnull = CTOnOff.Factory.newInstance(); + ctStyle.setUnhideWhenUsed(onoffnull); + + // style shows up in the formats bar + ctStyle.setQFormat(onoffnull); + + // style defines a heading of the given level + CTPPr ppr = CTPPr.Factory.newInstance(); + ppr.setOutlineLvl(indentNumber); + ctStyle.setPPr(ppr); + + XWPFStyle style = new XWPFStyle(ctStyle); + + // is a null op if already defined + XWPFStyles styles = docxDocument.createStyles(); + + style.setType(STStyleType.PARAGRAPH); + styles.addStyle(style); + + } + + /** + * 设置文档中标题格式 + */ + public void setHeadingStyle(XWPFDocument document) { + addCustomHeadingStyle(document, "标题 1", 1); + addCustomHeadingStyle(document, "标题 2", 2); + addCustomHeadingStyle(document, "标题 3", 3); + addCustomHeadingStyle(document, "标题 4", 4); + addCustomHeadingStyle(document, "标题 5", 5); + addCustomHeadingStyle(document, "标题 6", 6); + addCustomHeadingStyle(document, "标题 7", 7); + } + + /** + * 给表格添加一行数据 + * + * @param paragraph 段落对象 + * @param row 行对象 + * @param data 不定长度的数据 + */ + public void setExcelContent(XWPFParagraph paragraph, XWPFTableRow row, String... data) { + for (int i = 0; i < data.length; i++) { + XWPFRun run = paragraph.createRun(); + run.setFontFamily("宋体"); + run.setText(data[i]); + row.getCell(i).setParagraph(paragraph); + paragraph.removeRun(0); + } + } + + /** + * 添加表头标题一行数据 + * + * @param paragraph 段落对象 + * @param row 行对象 + * @param data 不定长度的数据 + */ + public void setExcelHeadContent(XWPFParagraph paragraph, XWPFTableRow row, String... data) { + XWPFRun run = paragraph.createRun(); + run.setFontFamily("宋体"); + run.setBold(true); + run.setText(data[0]); + row.getCell(0).setParagraph(paragraph); + paragraph.removeRun(0); + for (int i = 1; i < data.length; i++) { + XWPFRun run1 = paragraph.createRun(); + run1.setFontFamily("宋体"); + run1.setBold(true); + run1.setText(data[i]); + row.addNewTableCell().setParagraph(paragraph); + paragraph.removeRun(0); + } + } + + /** + * 获取当前的日期 + * + * @return + */ + public String getRightNow() { + Calendar rightNow = Calendar.getInstance(); + Integer year = rightNow.get(Calendar.YEAR); + Integer month = rightNow.get(Calendar.MONTH) + 1; + Integer day = rightNow.get(rightNow.DAY_OF_MONTH); + return year + "年" + month + "月" + day + "日"; + } + + +}