停机损失多少电量test

src/test/java/test/LosePowerTest.java

@@ -0,0 +1,165 @@
+package test;
+
+import com.gyee.SpringbootStart;
+import com.gyee.frame.common.feign.RemoteServiceBuilder;
+import com.gyee.frame.mapper.auto.WindTurbineTestingPointAi2Mapper;
+import com.gyee.frame.model.auto.WindTurbineTestingPointAi2;
+import com.gyee.frame.model.auto.WindTurbineTestingPointAi2Example;
+import com.gyee.frame.model.config.FilePathConfig;
+import com.gyee.frame.model.custom.export.TsPointData;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.time.DateFormatUtils;
+import org.apache.commons.lang3.time.DateUtils;
+import org.apache.poi.xssf.usermodel.XSSFRow;
+import org.apache.poi.xssf.usermodel.XSSFSheet;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import javax.annotation.Resource;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.text.ParseException;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 1、每个月各场站每台风机有多少次故障（故障时间持续超过2小时），停机时间。停机损失多少电量
+ * 2、与两票系统关联统计风机定检之后可以正常运行时长
+ */
+@SpringBootTest(classes = SpringbootStart.class)
+@RunWith(SpringRunner.class)
+public class LosePowerTest {
+
+    @Autowired
+    private WindTurbineTestingPointAi2Mapper windTurbineTestingPointAi2Mapper;
+    @Resource
+    private RemoteServiceBuilder remoteServiceBuilder;
+
+    private List<WindTurbineTestingPointAi2> faultCodes;
+    private Map<String, String> llfdlMap;
+
+    @Test()
+    public void test() throws ParseException {
+        getFaultCodes();
+        getLlfdlMap();
+        Date start = DateUtils.parseDate("2022-10-01", "yyyy-MM-dd");
+        Date end = DateUtils.parseDate("2022-10-31", "yyyy-MM-dd");
+        calc(start, end);
+
+    }
+
+    private void calc(Date start, Date end) {
+        XSSFWorkbook workbook = new XSSFWorkbook();
+        XSSFSheet sheet = workbook.createSheet();
+
+        XSSFRow row0 = sheet.createRow(0);
+        row0.createCell(0).setCellValue("序号");
+        row0.createCell(1).setCellValue("场站");
+        row0.createCell(2).setCellValue("风机");
+        row0.createCell(3).setCellValue("月份");
+        row0.createCell(4).setCellValue("故障次数");
+        row0.createCell(5).setCellValue("故障时间(分钟)");
+        row0.createCell(6).setCellValue("损失电量(kWh)");
+        row0.createCell(7).setCellValue("机型");
+
+        int i = 1;
+        for (WindTurbineTestingPointAi2 wttpai2 : faultCodes) {
+            if(wttpai2.getWindturbineid().equals("MG01_01")){
+                System.out.println();
+            }
+            XSSFRow row = sheet.createRow(i);
+            i++;
+            List<TsPointData> historyRaw = remoteServiceBuilder.ShardingService().getHistoryRaw(wttpai2.getId(), start.getTime(), end.getTime());
+            historyRaw = historyRaw.stream().sorted(Comparator.comparing(TsPointData::getTs).reversed()).collect(Collectors.toList());
+
+            long duration = 0;//故障时间
+            long durationlj = 0;//停机时间
+            int ssdl = 0;//损失电量
+            long faultTime = historyRaw.get(0).getTs();
+            short gzcs = 0;//故障次数
+
+            short k = 0;//是否连续
+
+            //测点列表
+            for (TsPointData tsPointData : historyRaw) {
+                //点值
+                int doubleValue = (int) tsPointData.getDoubleValue();
+                if (doubleValue == 4) {
+                    k = 0;
+                    continue;
+                } else if (doubleValue == 2) {
+                    duration = faultTime - tsPointData.getTs();
+                    //超过2小时,毫秒
+                    int 两小时 = 2 * 60 * 60 * 1000;
+                    int 一小时 = 1 * 60 * 60 * 1000;
+                    int 半小时 = 1 * 30 * 60 * 1000;
+                    if (duration > 半小时) {
+                        if (k == 0) gzcs++;
+                        k = 1;
+
+                        durationlj += duration;
+                        String s = llfdlMap.get(wttpai2.getWindturbineid());
+                        Map<String, TsPointData> h1 = remoteServiceBuilder.ShardingService().getHistorySection(s, tsPointData.getTs());
+                        Map<String, TsPointData> h2 = remoteServiceBuilder.ShardingService().getHistorySection(s, faultTime);
+                        double doubleValue2 = h2.get(s).getDoubleValue();
+                        double doubleValue1 = h1.get(s).getDoubleValue();
+                        ssdl += doubleValue2 - doubleValue1;
+                    }else {
+                        k = 0;
+                    }
+                    faultTime = tsPointData.getTs();
+                } else {
+                    faultTime = tsPointData.getTs();
+                    k = 0;
+                    continue;
+                }
+            }
+            row.createCell(0).setCellValue(i-1);
+            row.createCell(1).setCellValue(wttpai2.getWindpowerstationid());
+            row.createCell(2).setCellValue(wttpai2.getWindturbineid());
+            row.createCell(3).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM"));
+            row.createCell(4).setCellValue(gzcs);
+            row.createCell(5).setCellValue(durationlj / 60000);
+            row.createCell(6).setCellValue(ssdl / 1000.0);
+            row.createCell(7).setCellValue(wttpai2.getModelid());
+
+        }
+        //通过输出流将workbook对象下载到磁盘
+        FileOutputStream out = null;
+        try {
+            out = new FileOutputStream("C:\\dell\\UpdatePackage\\麻黄山风电场202210-半小时.xlsx");
+            workbook.write(out);
+            out.flush();
+            out.close();
+            workbook.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public List<WindTurbineTestingPointAi2> getFaultCodes() {
+        if (faultCodes == null) {
+            WindTurbineTestingPointAi2Example wtspAi2Example = new WindTurbineTestingPointAi2Example();
+            wtspAi2Example.createCriteria().andUniformcodeEqualTo("FJZT").andWindpowerstationidLike("%MHS_FDC");
+            faultCodes = windTurbineTestingPointAi2Mapper.selectByExample(wtspAi2Example);
+            faultCodes=faultCodes.stream().sorted((t1,t2)->{
+                return Integer.parseInt(t1.getWindturbineid().replaceFirst(".+_", "")) - Integer.parseInt(t2.getWindturbineid().replaceFirst(".+_", ""));
+            }).collect(Collectors.toList());
+        }
+        return faultCodes;
+    }
+
+    public Map<String, String> getLlfdlMap() {
+        if (llfdlMap == null) {
+            WindTurbineTestingPointAi2Example wtspAi2Example = new WindTurbineTestingPointAi2Example();
+            wtspAi2Example.createCriteria().andUniformcodeEqualTo("YFDLLL").andWindpowerstationidLike("%_FDC");
+            List<WindTurbineTestingPointAi2> ai2s = windTurbineTestingPointAi2Mapper.selectByExample(wtspAi2Example);
+            llfdlMap = ai2s.stream().collect(Collectors.toMap(WindTurbineTestingPointAi2::getWindturbineid, WindTurbineTestingPointAi2::getId));
+        }
+        return llfdlMap;
+    }
+}