2票检修后正常运行时间

src/main/java/com/gyee/frame/mapper/graphicbilling/WorkticketMapper.java

@@ -0,0 +1,25 @@
+package com.gyee.frame.mapper.graphicbilling;
+
+import com.gyee.frame.model.excel.Workticket;
+import com.gyee.frame.model.excel.Woworktickeask;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author gfhd
+ * @since 2022-11-23
+ */
+public interface WorkticketMapper {
+    @Select("select a.id,a.wonum,a.wtickettype,a.finaltype,a.startdate,a.enddate,a.inceptdate,a.fiatdate,a.remark3,a.finaltime," +
+            "a.status,a.statusdate,a.eqnum,a.sitenum,a.corpnum,a.workdept,a.ticketnum,a.startworktime,a.equipment,a.sbms," +
+            "a.wtnum,a.gwnum,a.wspeed,b.address,b.location,b.description,b.description2,b.worktype " +
+            "from WORKTICKET a left join WOWORKTASK b on a.WONUM=b.WONUM " +
+            "where (b.DESCRIPTION2 like '%定检%' or  b.DESCRIPTION2 like '%半年%') and a.STARTDATE>#{startdate}")
+    List<Woworktickeask> selectByTime(Date startdate);
+}

src/main/java/com/gyee/frame/model/excel/Workticket.java

@@ -0,0 +1,401 @@
+package com.gyee.frame.model.excel;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author gfhd
+ * @since 2022-11-23
+ */
+@Data
+public class Workticket implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private BigDecimal id;
+
+    private String wonum;
+
+    private String station;
+
+    private String wtickettype;
+
+    private String principal;
+
+    private String deptgroup;
+
+    private String finaltype;
+
+    private Date startdate;
+
+    private Date enddate;
+
+    private String worktask;
+
+    private String workaddress;
+
+    private String stoplinename;
+
+    private String rundept;
+
+    private String consdept;
+
+    private String signatory;
+
+    private String tkchamber;
+
+    private String remark1;
+
+    private Date inceptdate;
+
+    private String inceptman;
+
+    private String yorn;
+
+    private String adjustoradd;
+
+    private String adjustuser;
+
+    private String preserving;
+
+    private String remark2;
+
+    private String fiatquomodo;
+
+    private Date fiatdate;
+
+    private String fiatuser1;
+
+    private String principal1;
+
+    private String remark3;
+
+    private String project;
+
+    private String principal2;
+
+    private String fiatuser2;
+
+    private String signatory1;
+
+    private Date changedate;
+
+    private String principal3;
+
+    private String newprincipal;
+
+    private String fiatuser3;
+
+    private Date newdate;
+
+    private String principal4;
+
+    private String inceptman1;
+
+    private Date finaltime;
+
+    private String principal5;
+
+    private String fiatuser4;
+
+    private String linenum;
+
+    private String status;
+
+    private Date statusdate;
+
+    private String eqnum;
+
+    private String location;
+
+    private String secyorn;
+
+    private String outyorn;
+
+    private String safeyorn;
+
+    private String sitenum;
+
+    private String corpnum;
+
+    private String eqnumdis;
+
+    private String locationdis;
+
+    private String workdept;
+
+    private Date signdate;
+
+    private String memberchange;
+
+    private String unlinename;
+
+    private String unlinecount;
+
+    private String switchcount;
+
+    private Long bafflecount;
+
+    private String fiatuser5;
+
+    private Date ticketfinaltime;
+
+    private String subnum;
+
+    private String subprincipal;
+
+    private String finaltype1;
+
+    private Date finaltime1;
+
+    private String principal6;
+
+    private String fiatuser6;
+
+    private Date fiatdate1;
+
+    private String fiatuser7;
+
+    private String safety;
+
+    private String principal7;
+
+    private String workline;
+
+    private String equi;
+
+    private String safenotice;
+
+    private Long sequence;
+
+    private String stantickettype;
+
+    private String stlitickettype;
+
+    private String initialuser;
+
+    private String initialuserdept;
+
+    private String workuser;
+
+    private String ticketnum;
+
+    private String addpeople;
+
+    private Date addtime;
+
+    private String awaypeople;
+
+    private Date awaytime;
+
+    private String worksteerpeople;
+
+    private String workaddpeople;
+
+    private String stopscope;
+
+    private Date countersigndate;
+
+    private String countersignperson;
+
+    private Date checkdate;
+
+    private String checkperson;
+
+    private String checkquestion;
+
+    private String remark4;
+
+    private String checkstate;
+
+    private Date startworktime;
+
+    private Date endworktime;
+
+    private String principal8;
+
+    private String bugnum;
+
+    private String workarea;
+
+    private String fireprincipal;
+
+    private String firelocation;
+
+    private String surveylocation;
+
+    private String contents;
+
+    private String instrument;
+
+    private String surveyperson;
+
+    private Date surveytime;
+
+    private Date applyfirestarttime;
+
+    private Date applyfireendtime;
+
+    private String leadership;
+
+    private String safeprincipal;
+
+    private String firefightingperson;
+
+    private String shiftforeman;
+
+    private String fireoperator;
+
+    private Date firepermittime;
+
+    private Date fireendtime;
+
+    private String deptgroup1;
+
+    private String fireworkcontent;
+
+    private String fiatuser8;
+
+    private String guardian;
+
+    private String guardian1;
+
+    private String guardian2;
+
+    private String fireoperator1;
+
+    private String shiftforeman1;
+
+    private String description;
+
+    private String equname;
+
+    private String barname;
+
+    private String barname1;
+
+    private Date lineadddate;
+
+    private Date lineenddate;
+
+    private String lineagreemode;
+
+    private String lineageepeople;
+
+    private String lineageepeople2;
+
+    private Date linebegindate;
+
+    private String linereportmode;
+
+    private String lineageepeople4;
+
+    private String lineageepeople3;
+
+    private String linerepoptmode;
+
+    private String equipment;
+
+    private String sbms;
+
+    private String eqname;
+
+    private String fiatuser;
+
+    private String inceptman2;
+
+    private String leadership1;
+
+    private String safeprincipal1;
+
+    private String firefightperson1;
+
+    private String wtnum;
+
+    private String workreport;
+
+    private String safemeasure;
+
+    private String addsafemeasure;
+
+    private Date principaldate;
+
+    private Date fiatuserdate;
+
+    private String gwnum;
+
+    private String isend;
+
+    private String wspeed;
+
+    private String completion;
+
+    private String relinecount;
+
+    private String unswitchcount;
+
+    private String reswitchcount;
+
+    private String firemode;
+
+    private String fireoperatornum;
+
+    private String signatorynum;
+
+    private String fiatuser1num;
+
+    private String principal2num;
+
+    private String shiftforemannum;
+
+    private String fiatusernum;
+
+    private String inceptman1num;
+
+    private String firefightingpernum;
+
+    private String safeprincipalnum;
+
+    private String fiatuser5num;
+
+    private String fiatuser8num;
+
+    private String principal1num;
+
+    private String guardiannum;
+
+    private String fireoperator1num;
+
+    private String principal5num;
+
+    private String fiatuser4num;
+
+    private String shiftforenum1num;
+
+    private String inceptmannum;
+
+    private String principal3num;
+
+    private String guardian1num;
+
+    private String fiatuser7num;
+
+    private String principal6num;
+
+    private String safeprincipal1num;
+
+    private String workorder;
+
+    private Date approvalstarttime;
+
+    private Date approvalendtime;
+
+    private String approvalperson;
+}

src/main/java/com/gyee/frame/model/excel/Woworktask.java

@@ -0,0 +1,42 @@
+package com.gyee.frame.model.excel;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author gfhd
+ * @since 2022-11-23
+ */
+@Data
+public class Woworktask implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private BigDecimal id;
+
+    private String wonum;
+
+    private String address;
+
+    private String location;
+
+    private String eqnum;
+
+    private String workcontent;
+
+    private String description;
+
+    private String description1;
+
+    private String description2;
+
+    private String worktype;
+
+    private String worktypecode;
+}

src/main/java/com/gyee/frame/model/excel/Woworktickeask.java

@@ -0,0 +1,77 @@
+package com.gyee.frame.model.excel;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author gfhd
+ * @since 2022-11-23
+ */
+@Data
+public class Woworktickeask implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private BigDecimal id;
+
+    private String wonum;
+
+    private String wtickettype;
+
+    private String finaltype;
+
+    private Date startdate;
+
+    private Date enddate;
+
+    private Date inceptdate;
+
+    private Date fiatdate;
+
+    private String remark3;
+
+    private Date finaltime;
+
+    private String status;
+
+    private Date statusdate;
+
+    private String eqnum;
+
+    private String sitenum;
+
+    private String corpnum;
+
+    private String workdept;
+
+    private String ticketnum;
+
+    private Date startworktime;
+
+    private String equipment;
+
+    private String sbms;
+
+    private String wtnum;
+
+    private String gwnum;
+
+    private String wspeed;
+
+    private String address;
+
+    private String location;
+
+    private String description;
+
+    private String description2;
+
+    private String worktype;
+}

src/main/java/com/gyee/frame/schdule/windturbinestatetime/TaskLoadrateHourlyStatistics.java

@@ -183,7 +183,7 @@ public class TaskLoadrateHourlyStatistics {
     public List<WindTurbineTestingPointAi2> getAi2ForElectricity() {
         if(ai2ForElectricity==null){
             WindTurbineTestingPointAi2Example example = new WindTurbineTestingPointAi2Example();
-            example.createCriteria().andUniformcodeEqualTo("RFDLREAD").andWindpowerstationidLike("%GDC");
+            example.createCriteria().andUniformcodeEqualTo("RFDL").andWindpowerstationidLike("%GDC");
             ai2ForElectricity = windTurbineTestingPointAiService.selectByExample(example);
         }
         return ai2ForElectricity;

src/main/java/com/gyee/frame/service/export/WorkticketService.java

@@ -0,0 +1,39 @@
+package com.gyee.frame.service.export;
+
+import com.gyee.frame.common.dataSources.DataSource;
+import com.gyee.frame.common.dataSources.DataSourceType;
+import com.gyee.frame.mapper.graphicbilling.WorkticketMapper;
+import com.gyee.frame.model.excel.Woworktickeask;
+import org.apache.commons.lang3.time.DateUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.text.ParseException;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author gfhd
+ * @since 2022-11-23
+ */
+@Service
+public class WorkticketService {
+
+    @Resource
+    private WorkticketMapper workticketMapper;
+
+    @DataSource(value = DataSourceType.TICKET)
+    public List<Woworktickeask> getsomething(String time){
+        Date date = new Date();
+        try {
+            date = DateUtils.parseDate(time, "yyyy-MM-dd HH:mm:ss");
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return workticketMapper.selectByTime(date);
+    }
+}

src/test/java/test/LosePowerTest.java

@@ -7,6 +7,8 @@ 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 com.gyee.frame.model.excel.Woworktickeask;
+import com.gyee.frame.service.export.WorkticketService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.time.DateFormatUtils;
 import org.apache.commons.lang3.time.DateUtils;
@@ -24,11 +26,12 @@ import java.io.FileOutputStream;
 import java.io.IOException;
 import java.text.ParseException;
 import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
 /**
- * 1、每个月各场站每台风机有多少次故障（故障时间持续超过2小时），停机时间。停机损失多少电量
- * 2、与两票系统关联统计风机定检之后可以正常运行时长
+ * 每个月各场站每台风机有多少次故障（故障时间持续超过2小时），停机时间。停机损失多少电量
  */
 @SpringBootTest(classes = SpringbootStart.class)
 @RunWith(SpringRunner.class)
@@ -41,6 +44,12 @@ public class LosePowerTest {
 
     private List<WindTurbineTestingPointAi2> faultCodes;
     private Map<String, String> llfdlMap;
+    private Map<String, String> fcMap;
+
+
+    @Resource
+    private WorkticketService workticketService;
+    private final String REGEX = "\\d+";
 
     @Test()
     public void test() throws ParseException {
@@ -48,9 +57,119 @@ public class LosePowerTest {
         getLlfdlMap();
         Date start = DateUtils.parseDate("2022-10-01", "yyyy-MM-dd");
         Date end = DateUtils.parseDate("2022-10-31", "yyyy-MM-dd");
-        calc(start, end);
+        calc3(start, end);
 
     }
+
+    private void calc3(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("故障时间(分钟)");
+        row0.createCell(7).setCellValue("损失电量(kWh)");
+        row0.createCell(8).setCellValue("机型");
+
+        int i = 1;
+        for (WindTurbineTestingPointAi2 wttpai2 : faultCodes) {
+
+            XSSFRow rowz = sheet.createRow(i);
+
+            List<TsPointData> historyRaw = remoteServiceBuilder.ShardingService().getHistoryRaw(wttpai2.getId(), start.getTime(), end.getTime());
+            //时间从小到大
+            historyRaw = historyRaw.stream().sorted(Comparator.comparing(TsPointData::getTs)).collect(Collectors.toList());
+
+            long duration = 0;//故障时间
+            long durationlj = 0;//停机时间
+            double ssdl = 0;//损失电量
+            long faultTime = historyRaw.get(0).getTs();
+            short gzcs = 0;//故障次数
+
+            short k = 0;//是否连续，如果点是连续的2，故障次数算1次
+
+            short 当前风机是否有故障 = 0;
+            //测点列表
+            for (TsPointData tsPointData : historyRaw) {
+                //点值
+                int doubleValue = (int) tsPointData.getDoubleValue();
+                if (doubleValue == 4) {
+                    k = 0;
+                    continue;
+                } else if (doubleValue == 2) {
+                    long ts = tsPointData.getTs();
+                    duration = faultTime - ts;
+                    //超过2小时,毫秒
+                    int 两小时 = 2 * 60 * 60 * 1000;
+                    int 一小时 = 1 * 60 * 60 * 1000;
+                    int 半小时 = 1 * 30 * 60 * 1000;
+                    if (duration > 一小时) {
+                        当前风机是否有故障 = 1;
+                        if (k == 0) gzcs++;
+                        k = 1;
+                        //一个故障一行excel
+                        XSSFRow row = sheet.createRow(i);
+                        i++;
+
+                        durationlj += duration;
+                        String s = llfdlMap.get(wttpai2.getWindturbineid());
+                        Map<String, TsPointData> h1 = remoteServiceBuilder.ShardingService().getHistorySection(s, ts);
+                        Map<String, TsPointData> h2 = remoteServiceBuilder.ShardingService().getHistorySection(s, faultTime);
+                        double doubleValue2 = h2.get(s).getDoubleValue();
+                        double doubleValue1 = h1.get(s).getDoubleValue();
+                        ssdl = doubleValue2 - doubleValue1;
+
+                        row.createCell(0).setCellValue(i - 1);
+                        row.createCell(1).setCellValue(wttpai2.getWindpowerstationid());
+                        row.createCell(2).setCellValue(wttpai2.getWindturbineid());
+                        row.createCell(3).setCellValue(DateFormatUtils.format(ts, "yyyy-MM-dd HH:mm:ss"));
+                        row.createCell(4).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM-dd HH:mm:ss"));
+                        row.createCell(5).setCellValue(1);
+                        row.createCell(6).setCellValue(duration / 60000);
+                        row.createCell(7).setCellValue(ssdl);
+                        row.createCell(8).setCellValue(wttpai2.getModelid());
+                    } else {
+                        k = 0;
+                    }
+                    faultTime = ts;
+                } else {
+                    faultTime = tsPointData.getTs();
+                    k = 0;
+                    continue;
+                }
+            }
+
+            if (当前风机是否有故障 == 0) {
+                rowz.createCell(0).setCellValue(i - 1);
+                rowz.createCell(1).setCellValue(wttpai2.getWindpowerstationid());
+                rowz.createCell(2).setCellValue(wttpai2.getWindturbineid());
+                rowz.createCell(3).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM"));
+                rowz.createCell(4).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM"));
+                rowz.createCell(5).setCellValue(gzcs);
+                rowz.createCell(6).setCellValue(durationlj / 60000);
+                rowz.createCell(7).setCellValue(ssdl);
+                rowz.createCell(8).setCellValue(wttpai2.getModelid());
+                i++;
+            }
+
+        }
+        //通过输出流将workbook对象下载到磁盘
+        FileOutputStream out = null;
+        try {
+            out = new FileOutputStream("D:\\计算\\麻黄山风电场202210-1小时.xlsx");
+            workbook.write(out);
+            out.flush();
+            out.close();
+            workbook.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
     //每行是一个故障
     private void calc2(Date start, Date end) {
         XSSFWorkbook workbook = new XSSFWorkbook();
@@ -60,11 +179,12 @@ public class LosePowerTest {
         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("机型");
+        row0.createCell(3).setCellValue("故障开始时间");
+        row0.createCell(4).setCellValue("故障结束时间");
+        row0.createCell(5).setCellValue("故障次数");
+        row0.createCell(6).setCellValue("故障时间(分钟)");
+        row0.createCell(7).setCellValue("损失电量(kWh)");
+        row0.createCell(8).setCellValue("机型");
 
         int i = 1;
         for (WindTurbineTestingPointAi2 wttpai2 : faultCodes) {
@@ -81,7 +201,7 @@ public class LosePowerTest {
             long faultTime = historyRaw.get(0).getTs();
             short gzcs = 0;//故障次数
 
-            short k = 0;//是否连续
+            short k = 0;//是否连续，如果点是连续的2，故障次数算1次
 
             short 当前风机是否有故障 = 0;
             //测点列表
@@ -92,7 +212,8 @@ public class LosePowerTest {
                     k = 0;
                     continue;
                 } else if (doubleValue == 2) {
-                    duration = faultTime - tsPointData.getTs();
+                    long ts = tsPointData.getTs();
+                    duration = faultTime - ts;
                     //超过2小时,毫秒
                     int 两小时 = 2 * 60 * 60 * 1000;
                     int 一小时 = 1 * 60 * 60 * 1000;
@@ -107,24 +228,25 @@ public class LosePowerTest {
 
                         durationlj += duration;
                         String s = llfdlMap.get(wttpai2.getWindturbineid());
-                        Map<String, TsPointData> h1 = remoteServiceBuilder.ShardingService().getHistorySection(s, tsPointData.getTs());
+                        Map<String, TsPointData> h1 = remoteServiceBuilder.ShardingService().getHistorySection(s, ts);
                         Map<String, TsPointData> h2 = remoteServiceBuilder.ShardingService().getHistorySection(s, faultTime);
                         double doubleValue2 = h2.get(s).getDoubleValue();
                         double doubleValue1 = h1.get(s).getDoubleValue();
                         ssdl = doubleValue2 - doubleValue1;
 
-                        row.createCell(0).setCellValue(i-1);
+                        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(1);
-                        row.createCell(5).setCellValue(duration / 60000);
-                        row.createCell(6).setCellValue(ssdl);
-                        row.createCell(7).setCellValue(wttpai2.getModelid());
-                    }else {
+                        row.createCell(3).setCellValue(DateFormatUtils.format(ts, "yyyy-MM-dd HH:mm:ss"));
+                        row.createCell(4).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM-dd HH:mm:ss"));
+                        row.createCell(5).setCellValue(1);
+                        row.createCell(6).setCellValue(duration / 60000);
+                        row.createCell(7).setCellValue(ssdl);
+                        row.createCell(8).setCellValue(wttpai2.getModelid());
+                    } else {
                         k = 0;
                     }
-                    faultTime = tsPointData.getTs();
+                    faultTime = ts;
                 } else {
                     faultTime = tsPointData.getTs();
                     k = 0;
@@ -132,15 +254,16 @@ public class LosePowerTest {
                 }
             }
 
-            if(当前风机是否有故障==0){
-                rowz.createCell(0).setCellValue(i-1);
+            if (当前风机是否有故障 == 0) {
+                rowz.createCell(0).setCellValue(i - 1);
                 rowz.createCell(1).setCellValue(wttpai2.getWindpowerstationid());
                 rowz.createCell(2).setCellValue(wttpai2.getWindturbineid());
                 rowz.createCell(3).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM"));
-                rowz.createCell(4).setCellValue(gzcs);
-                rowz.createCell(5).setCellValue(durationlj / 60000);
-                rowz.createCell(6).setCellValue(ssdl);
-                rowz.createCell(7).setCellValue(wttpai2.getModelid());
+                rowz.createCell(4).setCellValue(DateFormatUtils.format(faultTime, "yyyy-MM"));
+                rowz.createCell(5).setCellValue(gzcs);
+                rowz.createCell(6).setCellValue(durationlj / 60000);
+                rowz.createCell(7).setCellValue(ssdl);
+                rowz.createCell(8).setCellValue(wttpai2.getModelid());
                 i++;
             }
 
@@ -174,7 +297,7 @@ public class LosePowerTest {
 
         int i = 1;
         for (WindTurbineTestingPointAi2 wttpai2 : faultCodes) {
-            if(wttpai2.getWindturbineid().equals("MG01_01")){
+            if (wttpai2.getWindturbineid().equals("MG01_01")) {
                 System.out.println();
             }
             XSSFRow row = sheet.createRow(i);
@@ -215,7 +338,7 @@ public class LosePowerTest {
                         double doubleValue2 = h2.get(s).getDoubleValue();
                         double doubleValue1 = h1.get(s).getDoubleValue();
                         ssdl += doubleValue2 - doubleValue1;
-                    }else {
+                    } else {
                         k = 0;
                     }
                     faultTime = tsPointData.getTs();
@@ -225,7 +348,7 @@ public class LosePowerTest {
                     continue;
                 }
             }
-            row.createCell(0).setCellValue(i-1);
+            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"));
@@ -251,9 +374,9 @@ public class LosePowerTest {
     public List<WindTurbineTestingPointAi2> getFaultCodes() {
         if (faultCodes == null) {
             WindTurbineTestingPointAi2Example wtspAi2Example = new WindTurbineTestingPointAi2Example();
-            wtspAi2Example.createCriteria().andUniformcodeEqualTo("FJZT").andWindpowerstationidLike("%MHS_FDC");
+            wtspAi2Example.createCriteria().andUniformcodeEqualTo("FJZT").andWindpowerstationidLike("%_FDC");
             faultCodes = windTurbineTestingPointAi2Mapper.selectByExample(wtspAi2Example);
-            faultCodes=faultCodes.stream().sorted((t1,t2)->{
+            faultCodes = faultCodes.stream().sorted((t1, t2) -> {
                 return Integer.parseInt(t1.getWindturbineid().replaceFirst(".+_", "")) - Integer.parseInt(t2.getWindturbineid().replaceFirst(".+_", ""));
             }).collect(Collectors.toList());
         }
@@ -269,4 +392,123 @@ public class LosePowerTest {
         }
         return llfdlMap;
     }
+
+
+    @Test()
+    public void test2() {
+        List<Woworktickeask> getsomething = workticketService.getsomething("2022-08-01");
+
+        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("持续时长(天)");
+
+        int i = 1;
+        for (Woworktickeask wwtt : getsomething) {
+            //获取风机id
+            String windturbine = getFjMap(wwtt.getSitenum()) + getWindturbine(wwtt.getAddress());
+            if (windturbine == null) continue;
+
+            XSSFRow row = sheet.createRow(i);
+            row.createCell(0).setCellValue(i - 1);
+            i++;
+            row.createCell(1).setCellValue(wwtt.getSitenum());
+            row.createCell(2).setCellValue(windturbine);
+            row.createCell(3).setCellValue(DateFormatUtils.format(wwtt.getStartdate(), "yyyy-MM-dd HH:mm:ss"));
+            String duration = getDuration(windturbine, wwtt.getEnddate());
+            row.createCell(4).setCellValue(duration);
+        }
+    }
+
+    private String getDuration(String wt, Date enddate) {
+        getFaultCodes();
+
+        List<WindTurbineTestingPointAi2> collect = faultCodes.stream().filter(f -> f.getWindturbineid().equals(wt)).collect(Collectors.toList());
+
+        List<TsPointData> historyRaw = remoteServiceBuilder.ShardingService().getHistoryRaw(collect.get(0).getId(), enddate.getTime(), enddate.getTime() + 7 * 604800000);
+        //时间从小到大
+        historyRaw = historyRaw.stream().sorted(Comparator.comparing(TsPointData::getTs)).collect(Collectors.toList());
+
+        long duration = 0;//故障时间
+        long durationlj = 0;//停机时间
+        double ssdl = 0;//损失电量
+        long faultTime = historyRaw.get(0).getTs();
+        short gzcs = 0;//故障次数
+
+        //测点列表
+        for (TsPointData tsPointData : historyRaw) {
+            //点值
+            int doubleValue = (int) tsPointData.getDoubleValue();
+            if (doubleValue == 4) {
+                k = 0;
+                continue;
+            } else if (doubleValue == 2) {
+                long ts = tsPointData.getTs();
+                duration = faultTime - ts;
+                //超过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, ts);
+                    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 = ts;
+            } else {
+                faultTime = tsPointData.getTs();
+                k = 0;
+                continue;
+            }
+        }
+
+        return "";
+    }
+
+    private String getWindturbine(String address) {
+        Pattern pattern = Pattern.compile(REGEX);
+        Matcher matcher = pattern.matcher(address);
+        String group = null;
+        if (matcher.find()) {
+            group = matcher.group(0);
+            if (group.length() < 2) group = "0" + group;
+            if (group.length() > 3) return null;
+        } else {
+            return null;
+        }
+        //String s = address.replaceAll("[\\u4e00-\\u9fa5]{0,}", "");
+        return group;
+    }
+
+    public String getFjMap(String fccn) {
+        if (fccn.contains("麻黄山")) return "MG01_";
+        if (fccn.contains("牛首山")) return "NG01_";
+        if (fccn.contains("青山")) return "QG01_";
+        if (fccn.contains("石板泉")) return "SG01_";
+        if (fccn.contains("香山")) return "XG01_";
+        return null;
+    }
+
+    public static void main(String[] args) {
+        String a = null;
+        String b = null;
+        String c = "aa";
+        String d = a + b;
+        String e = a + c;
+    }
 }

src/test/java/test/RegularCheckTest.java

@@ -0,0 +1,92 @@
+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.custom.export.TsPointData;
+import com.gyee.frame.model.excel.Woworktickeask;
+import com.gyee.frame.service.export.WorkticketService;
+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.Comparator;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * 与两票系统关联统计风机定检之后可以正常运行时长
+ */
+@SpringBootTest(classes = SpringbootStart.class)
+@RunWith(SpringRunner.class)
+public class RegularCheckTest {
+
+    @Resource
+    private WorkticketService workticketService;
+    private final String REGEX = "\\d+";
+
+    @Test()
+    public void test() {
+        List<Woworktickeask> getsomething = workticketService.getsomething("2022-08-01");
+
+        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("持续时长(天)");
+
+        int i = 1;
+        for (Woworktickeask wwtt : getsomething) {
+            String windturbine = getWindturbine(wwtt.getAddress());
+            if(windturbine==null) continue;
+
+            XSSFRow row = sheet.createRow(i);
+            row.createCell(0).setCellValue(i-1);
+            i++;
+            row.createCell(1).setCellValue(wwtt.getSitenum());
+            row.createCell(2).setCellValue(windturbine);
+            row.createCell(3).setCellValue(DateFormatUtils.format(wwtt.getStartdate(),"yyyy-MM-dd HH:mm:ss"));
+            int duration = getDuration(wwtt.getEnddate());
+        }
+    }
+
+    private int getDuration(Date enddate) {
+
+        return 0;
+    }
+
+    private String getWindturbine(String address) {
+        /*Pattern pattern= Pattern.compile(REGEX);
+        Matcher matcher=pattern.matcher(address);
+        String group = null;
+        if(matcher.find()){
+            group = matcher.group(0);
+            if(group.length()<2) group = "0" + group;
+        }else {
+            return null;
+        }*/
+        String s = address.replaceAll("[\\u4e00-\\u9fa5]{0,}", "");
+        return s;
+    }
+}