Merge branch 'master' of http://124.70.43.205:3000/GYEE_R.D/Gyee_Frame_NX

src/main/java/com/gyee/frame/common/feign/RemoteServiceBuilder.java

@@ -35,7 +35,7 @@ public class RemoteServiceBuilder {
                 .decoder(new JacksonDecoder())
                 .options(new Request.Options(5000, 600000))
                 .retryer(new Retryer.Default(10000, 10000, 3))
-                .target(IAdapterService.class, "http://192.168.1.18:8075");
+                .target(IAdapterService.class, "http://192.168.10.18:8075");
     }
 
 }

src/main/java/com/gyee/frame/mapper/auto/AlarmsnapMapper.java

@@ -2,13 +2,24 @@ package com.gyee.frame.mapper.auto;
 
 import com.gyee.frame.model.auto.Alarmsnap;
 import com.gyee.frame.model.auto.AlarmsnapExample;
+import com.gyee.frame.model.auto.FaultInfo;
 import com.gyee.frame.model.custom.TotalNumVo;
 import com.gyee.frame.model.custom.TotalNumsVo;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 
+import java.util.Date;
 import java.util.List;
 
 public interface AlarmsnapMapper {
+    @Select("SELECT h.id,h.faultTime,h.messageType,h.snapID,s.stationId,s.projectId,s.lineId,s.windturbineId,s.alertValue,s.rank," +
+            "s.category1,s.category2,s.category3,s.isOpened,s.stationName,s.windturbineName,s.alertText,s.modelId" +
+            "FROM faulthistory h left join faultsnap s on h.snapid = s.id" +
+            "WHERE h.messageType = 1 and s.WINDTURBINEID=#{windturbineid}" +
+            "  AND h.faultTime > #{starttime} AND h.faultTime < #{endtime} AND ROWNUM<#{row}" +
+            "order by h.faultTime desc")
+    List<FaultInfo>  getRecentFault(@Param("windturbineid") String wt,@Param("starttime") Date st,@Param("endtime") Date et,@Param("row") int r);
+
     /**
      * This method was generated by MyBatis Generator.
      * This method corresponds to the database table ALARMSNAP

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/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

@@ -1,12 +1,20 @@
 package test;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.gyee.SpringbootStart;
+import com.gyee.frame.common.domain.AjaxResult;
 import com.gyee.frame.common.feign.RemoteServiceBuilder;
+import com.gyee.frame.mapper.auto.AlarmsnapMapper;
 import com.gyee.frame.mapper.auto.WindTurbineTestingPointAi2Mapper;
+import com.gyee.frame.model.auto.FaultInfo;
 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,23 +32,31 @@ 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)
 public class LosePowerTest {
 
     @Resource
-    private WindTurbineTestingPointAi2Mapper windTurbineTestingPointAi2Mapper;
+    private WindTurbineTestingPointAi2Mapper windTurbineTestingPointAi2Mapper;@Resource
+    private AlarmsnapMapper alarmsnapMapper;
     @Resource
     private RemoteServiceBuilder remoteServiceBuilder;
 
     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,8 +64,133 @@ 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("机型");
+        row0.createCell(9).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) {
+                    continue;
+                } else if (doubleValue == 2) {
+                    if(k==0){
+                        faultTime = tsPointData.getTs();
+                        k = 1;
+                    }else {
+                        continue;
+                    }
+                } else {
+                    if(k==1){
+                        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;
+                            gzcs++;
+                            //一个故障一行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());
 
+                            List<FaultInfo> recentFault = alarmsnapMapper.getRecentFault(wttpai2.getWindturbineid(), new Date(ts-1*60*60*1000), new Date(ts), 4);
+                            if(recentFault.size()==0){
+                                recentFault = alarmsnapMapper.getRecentFault(wttpai2.getWindturbineid(), new Date(ts-8*60*60*1000), new Date(ts), 2);
+                            }
+                            String dsgz = "";
+                            for (FaultInfo faultInfo : recentFault) {
+                                dsgz = dsgz + DateFormatUtils.format(faultInfo.getFaultTime(), "yyyy-MM-dd HH:mm:ss") + ":" + faultInfo.getAlertText() + "\n";
+                            }
+                            row.createCell(9).setCellValue(dsgz);
+                        }
+                        k = 0;
+                    }else {
+                        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) {
@@ -60,11 +201,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 +223,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 +234,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 +250,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 +276,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 +319,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 +360,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 +370,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 +396,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 +414,93 @@ 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();
+
+        }
+
+        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;
+    }
+}