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

doc/风机无故障运行时间和待机时间.txt

@@ -6,4 +6,15 @@
 
 表 EARLYWARNINGANALYSISPUSH
 
+故障状态的统一编码
+NFDLZY_FXF
+
+风机状态的统一编码 "FJZT":
+ 0, "待机";1, "并网";2, "故障停机";3, "通讯中断";4, "维护停机";5, "非停机限电";6, "停机限电";
+
+
+连续无故障时间：
+    2MW: 故障-转->维护-->超过10分钟，就是故障 FJZT
+    1.5MW: 直接通过庚顿故障DI点，oracle统一编码NFDLZY_FXF
+
 

pom.xml

@@ -27,6 +27,11 @@
 	
 	<!-- https://mvnrepository.com/ 查找jar网站 -->
 	<dependencies>
+		<dependency>
+			<groupId>javax.xml</groupId>
+			<artifactId>jaxb-impl</artifactId>
+			<version>2.1</version>
+		</dependency>
 		<!-- SpringBoot Web容器 -->
 		<dependency>
 			<groupId>org.springframework.boot</groupId>

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

@@ -10,6 +10,7 @@ import feign.Param;
 import feign.RequestLine;
 
 import java.util.List;
+import java.util.Map;
 
 
 public interface IAdapterService {
@@ -37,7 +38,7 @@ public interface IAdapterService {
 
     @Headers({"Content-Type: application/json", "Accept: application/json"})
     @RequestLine("GET /ts/history/section?tagNames={tagNames}&ts={ts}")
-    List<TsPointData> getHistorySection(@Param(value = "tagNames") String tagNames, @Param(value = "ts") long ts);
+    Map<String,TsPointData> getHistorySection(@Param(value = "tagNames") String tagNames, @Param(value = "ts") long ts);
 
     @Headers({"Content-Type: application/json", "Accept: application/json"})
     @RequestLine("GET /alarm/count/query/new2?stationid={stationid}&startdate={startdate}&enddate={enddate}")

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/common/file/FileZip.java

@@ -0,0 +1,113 @@
+package com.gyee.frame.common.file;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.net.URLEncoder;
+import java.util.List;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
+
+public class FileZip {
+    /**
+     * 加载文件
+     *
+     * @param fileName
+     * @return
+     */
+    public static void download(String fileName, HttpServletResponse response) {
+        FileInputStream fis = null;
+        BufferedInputStream bis = null;
+        try {
+            // 获取文件
+            File file = new File(fileName);
+            // 清空缓冲区，状态码和响应头(headers)
+            response.reset();
+            // 设置ContentType，响应内容为二进制数据流，编码为utf-8，此处设定的编码是文件内容的编码
+            response.setContentType("application/octet-stream;charset=utf-8");
+            // 以（Content-Disposition: attachment; filename="filename.jpg"）格式设定默认文件名，设定utf编码，此处的编码是文件名的编码，使能正确显示中文文件名
+            response.setHeader("Content-Disposition", "attachment;fileName=" + file.getName() + ";filename*=utf-8''" + URLEncoder.encode(file.getName(), "utf-8"));
+
+            // 实现文件下载
+            byte[] buffer = new byte[1024];
+            fis = new FileInputStream(file);
+            bis = new BufferedInputStream(fis);
+            // 获取字节流
+            OutputStream os = response.getOutputStream();
+            int i = bis.read(buffer);
+            while (i != -1) {
+                os.write(buffer, 0, i);
+                i = bis.read(buffer);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (bis != null) {
+                try {
+                    bis.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (fis != null) {
+                try {
+                    fis.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+
+    /**
+     * @describe 压缩多个文件
+     * @author zfc
+     */
+    public static String zipFiles(List<File> srcFiles, File zipFile) {
+        // 判断压缩后的文件存在不，不存在则创建
+        //if (!zipFile.exists()) {
+            try {
+                zipFile.createNewFile();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+
+            // 创建 FileOutputStream 对象
+            FileOutputStream fileOutputStream = null;
+            // 创建 ZipOutputStream
+            ZipOutputStream zipOutputStream = null;
+            // 创建 FileInputStream 对象
+            FileInputStream fileInputStream = null;
+
+            try {
+                // 实例化 FileOutputStream 对象
+                fileOutputStream = new FileOutputStream(zipFile);
+                // 实例化 ZipOutputStream 对象
+                zipOutputStream = new ZipOutputStream(fileOutputStream);
+                // 创建 ZipEntry 对象
+                ZipEntry zipEntry = null;
+                // 遍历源文件数组
+                for (int i = 0; i < srcFiles.size(); i++) {
+                    // 将源文件数组中的当前文件读入 FileInputStream 流中
+                    fileInputStream = new FileInputStream(srcFiles.get(i));
+                    // 实例化 ZipEntry 对象，源文件数组中的当前文件
+                    zipEntry = new ZipEntry(srcFiles.get(i).getName());
+                    zipOutputStream.putNextEntry(zipEntry);
+                    // 该变量记录每次真正读的字节个数
+                    int len;
+                    // 定义每次读取的字节数组
+                    byte[] buffer = new byte[1024];
+                    while ((len = fileInputStream.read(buffer)) > 0) {
+                        zipOutputStream.write(buffer, 0, len);
+                    }
+                }
+                zipOutputStream.closeEntry();
+                zipOutputStream.close();
+                fileInputStream.close();
+                fileOutputStream.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        //}
+        return zipFile.getAbsolutePath();
+    }
+}

src/main/java/com/gyee/frame/controller/file/BoostStationController.java

@@ -0,0 +1,45 @@
+package com.gyee.frame.controller.file;
+
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+
+/**
+ * 组态升压站控制器
+ *
+ * @author xysn
+ */
+@CrossOrigin
+@RestController
+@RequestMapping("/api/boost_station")
+public class BoostStationController {
+    @Resource
+    private BoostStationSvc boostStationSvc;
+
+    /**
+     * 获取升压站信息
+     *
+     * @return 升压站信息
+     */
+    @GetMapping("/booststation")
+    public ShapeInfo getShapeInfos(@RequestParam(value = "id") String id) {
+        return boostStationSvc.getBoostStationInfo(id);
+    }
+
+    /**
+     * 获取svg文件
+     */
+    @GetMapping("/svg")
+    public String getSvgFile(@RequestParam(value = "id") String id) {
+        return boostStationSvc.getSvgFile(id);
+    }
+
+
+    /**
+     * 获取触发器和测点
+     */
+    @GetMapping("/svginfo")
+    public SvgInfo getSvgInfo(@RequestParam(value = "id") String id) {
+        return boostStationSvc.getSvgInfo(id);
+    }
+}

src/main/java/com/gyee/frame/controller/file/BoostStationSvc.java

@@ -0,0 +1,522 @@
+package com.gyee.frame.controller.file;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.google.common.collect.Maps;
+import org.springframework.stereotype.Component;
+
+import java.io.*;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 升压站服务
+ *
+ * @author xysn
+ */
+@Component
+public class BoostStationSvc {
+
+    /**
+     * 自定义控件路径
+     */
+    private final String CUSTOMIZE_PATH = "shapes\\customize_shapes.json";
+    /**
+     * 升压站信息
+     */
+    private final String BOOST_STATION_PATH = "shapes\\boost_station_infos.json";
+    /**
+     * 二次图信息
+     */
+    private final String SUB_STATION_PATH = "shapes\\sub_station_infos.json";
+    /**
+     * svg文件地址
+     */
+    private final String SVG_PATH = "shapes\\svg\\";
+
+    /**
+     * 自定义控件集合
+     */
+    private Map<String, ShapeInfo> customizeShapes;
+
+    /**
+     * 升压站
+     */
+    private Map<String, ShapeInfo> boostStationInfos;
+
+    /**
+     * 二次图
+     */
+    private Map<String, ShapeInfo> subShapeInfos;
+
+    /**
+     * 最大升压站序号
+     */
+    private int maxIndex;
+
+    public Map<String, ShapeInfo> getBoostStationInfos() {
+        if (boostStationInfos == null) {
+            initBoostStation();
+        }
+        return boostStationInfos;
+    }
+
+    public Map<String, ShapeInfo> getCustomizeShapesMap() {
+        if (customizeShapes == null) {
+            initCustomize();
+        }
+        return customizeShapes;
+    }
+
+    public Map<String, ShapeInfo> getSubShapeInfos() {
+        if (subShapeInfos == null) {
+            initSubStation();
+        }
+        return subShapeInfos;
+    }
+
+    /**
+     * 获取所有用户自定义控件
+     *
+     * @return 所有用户自定义控件
+     */
+    public Collection<ShapeInfo> getCustomizeShapes() {
+        final Map<String, ShapeInfo> infos = getCustomizeShapesMap();
+
+        return infos.values();
+    }
+
+    private void initCustomize() {
+        System.out.println("初始化自定义图形信息...");
+
+        ShapeInfo[] ls = getShapeInfosFromFile(CUSTOMIZE_PATH);
+        if (ls == null) {
+            customizeShapes = new HashMap<>();
+            return;
+        }
+        customizeShapes = Arrays.stream(ls).collect(Collectors.toMap(ShapeInfo::getId, ss -> ss));
+
+        System.out.println("自定义图形信息初始化结束");
+    }
+
+    /**
+     * 添加自定义图形
+     *
+     * @param info 图形信息
+     * @return
+     */
+    public boolean addCustomizeShape(ShapeInfo info) {
+        final Map<String, ShapeInfo> infos = getCustomizeShapesMap();
+
+        try {
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(CUSTOMIZE_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return false;
+            }
+            infos.put(info.getId(), info);
+            String str2 = JSON.toJSONString(infos.values());
+            return writToFile(CUSTOMIZE_PATH, str2);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
+
+    /**
+     * 移除自定义控件
+     *
+     * @param id 控件ID
+     * @return
+     */
+    public String removeCustomizeShape(String id) {
+        final Map<String, ShapeInfo> infos = getCustomizeShapesMap();
+        if (!infos.containsKey(id)) {
+            return "没有id为" + id + "的自定义控件";
+        }
+
+        try {
+            ShapeInfo osi = infos.get(id);
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(CUSTOMIZE_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return "控件移除失败：备份失败";
+            }
+            infos.remove(id);
+            String str2 = JSON.toJSONString(infos.values());
+            b = writToFile(CUSTOMIZE_PATH, str2);
+            if (!b) {
+                infos.put(id, osi);
+                return "保存失败";
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return "success";
+    }
+
+    /**
+     * 从文件获取图形信息
+     *
+     * @param path 路径
+     * @return 图形信息
+     */
+    private ShapeInfo[] getShapeInfosFromFile(String path) {
+        BufferedReader bufferedReader = null;
+        try {
+            File file = new File(path);
+            bufferedReader = new BufferedReader(new FileReader(file));
+            StringBuilder sb = new StringBuilder();
+            String s = null;
+            while ((s = bufferedReader.readLine()) != null) {
+                sb.append(s);
+            }
+            return JSONArray.parseObject(sb.toString(), ShapeInfo[].class);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                bufferedReader.close();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
+
+    /**
+     * 添加或更新升压站信息
+     *
+     * @param info 升压站信息
+     */
+    public boolean updateBoostStationInfos(ShapeInfo info) {
+        final Map<String, ShapeInfo> infos = getBoostStationInfos();
+
+        try {
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(BOOST_STATION_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return false;
+            }
+            if (infos.containsKey(info.getId())) {
+                info.setIndex(infos.get(info.getId()).getIndex());
+            } else {
+                info.setIndex(++maxIndex);
+            }
+            infos.put(info.getId(), info);
+            String str2 = JSON.toJSONString(infos.values());
+            return writToFile(BOOST_STATION_PATH, str2);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
+
+    /**
+     * 删除升压站
+     *
+     * @param id 升压站ID
+     * @return 是否成功
+     */
+    public boolean removeBoostStationInfos(String id) {
+        final Map<String, ShapeInfo> infos = getBoostStationInfos();
+
+        try {
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(BOOST_STATION_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return false;
+            }
+            if (infos.containsKey(id)) {
+                infos.remove(id);
+            }
+            String str2 = JSON.toJSONString(infos.values());
+            return writToFile(BOOST_STATION_PATH, str2);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
+
+
+    /**
+     * 获取升压站信息
+     *
+     * @return 升压站信息
+     */
+    public Collection<ShapeInfo> getShapeInfos() {
+        final Map<String, ShapeInfo> infos = getBoostStationInfos();
+        List<ShapeInfo> ls = new ArrayList<>(infos.values());
+        ls.sort(Comparator.comparingInt(ShapeInfo::getIndex));
+        return ls;
+    }
+
+
+    /**
+     * 根据id获取升压站信息
+     *
+     * @param id 场站id
+     */
+    public ShapeInfo getBoostStationInfo(String id) {
+        final Map<String, ShapeInfo> infos = getBoostStationInfos();
+        if (infos.containsKey(id)) {
+            return infos.get(id);
+        }
+        return null;
+    }
+
+    /**
+     * 初始化升压站信息
+     */
+    private void initBoostStation() {
+
+        System.out.println("初始化升压站图形信息...");
+
+        ShapeInfo[] ls = getShapeInfosFromFile(BOOST_STATION_PATH);
+        if (ls == null) {
+            boostStationInfos = Maps.newLinkedHashMap();
+            return;
+        }
+        final Optional<Integer> index = Arrays.stream(ls).max(Comparator.comparingInt(ShapeInfo::getIndex)).map(ShapeInfo::getIndex);
+        index.ifPresent(integer -> maxIndex = integer);
+        boostStationInfos = Arrays.stream(ls).collect(Collectors.toMap(ShapeInfo::getId, ss -> ss));
+
+        System.out.println("升压站图形信息初始化结束");
+    }
+
+    /**
+     * 获取二次图信息
+     *
+     * @param id 二次图ID
+     * @return 二次图信息
+     */
+    public ShapeInfo getSubShapeInfo(String id) {
+        final Map<String, ShapeInfo> infos = getSubShapeInfos();
+        if (infos.containsKey((id))) {
+            return infos.get(id);
+        }
+        return null;
+    }
+
+    /**
+     * 移除二次图
+     *
+     * @param id 二次图ID
+     * @return
+     */
+    public String removeSubStation(String id) {
+        final Map<String, ShapeInfo> infos = getSubShapeInfos();
+
+        if (!infos.containsKey(id)) {
+            return "没有名称为" + id + "的二次图";
+        }
+
+        try {
+            ShapeInfo osi = infos.get(id);
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(SUB_STATION_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return "二次图移除失败：备份失败";
+            }
+            infos.remove(id);
+            String str2 = JSON.toJSONString(infos.values());
+            b = writToFile(SUB_STATION_PATH, str2);
+            if (!b) {
+                infos.put(id, osi);
+                return "保存失败";
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return "success";
+    }
+
+    /**
+     * 初始化二次图
+     */
+    private void initSubStation() {
+        System.out.println("初始化升压站二次图信息...");
+
+        ShapeInfo[] ls = getShapeInfosFromFile(SUB_STATION_PATH);
+        if (ls == null) {
+            subShapeInfos = new HashMap<>();
+            return;
+        }
+        subShapeInfos = Arrays.stream(ls).collect(Collectors.toMap(ShapeInfo::getId, ss -> ss));
+
+        System.out.println("升压站二次图信息初始化结束");
+    }
+
+
+    /**
+     * 添加或更新二次图信息
+     *
+     * @param info 二次图信息
+     */
+    public boolean updateSubStationInfos(ShapeInfo info) {
+        final Map<String, ShapeInfo> infos = getSubShapeInfos();
+        try {
+            String str = JSON.toJSONString(infos.values());
+            boolean b = writToFile(SUB_STATION_PATH + System.currentTimeMillis(), str);
+            if (!b) {
+                return false;
+            }
+
+            infos.put(info.getId(), info);
+            String str2 = JSON.toJSONString(infos.values());
+            return writToFile(SUB_STATION_PATH, str2);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
+
+    /**
+     * 写入文件
+     */
+    private boolean writToFile(String path, String val) {
+        BufferedWriter bufferedWriter = null;
+        try {
+            File file = new File(path);
+            File pf = file.getParentFile();
+            if (!pf.exists()) {
+                boolean b = pf.mkdirs();
+            }
+            bufferedWriter = new BufferedWriter(new FileWriter(file));
+            bufferedWriter.write(val);
+            bufferedWriter.flush();
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                bufferedWriter.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 保存svg文件，如果存在则覆盖
+     */
+    public String addSvgFile(SvgFileInfo svg) {
+        String id = svg.getId();
+        if (id == null || "".equals(id)) {
+            return "svg文件id不能为空";
+        }
+        BufferedWriter bufferedWriter = null;
+        try {
+            File pf = new File(SVG_PATH);
+            if (!pf.exists()) {
+                boolean b = pf.mkdirs();
+            }
+            File f = new File(SVG_PATH + svg.getId() + ".svg");
+            bufferedWriter = new BufferedWriter(new FileWriter(f));
+            bufferedWriter.write(svg.getValue());
+            bufferedWriter.flush();
+        } catch (Exception e) {
+            e.printStackTrace();
+            return "保存文件出现错误：" + e.getMessage();
+        } finally {
+            try {
+                bufferedWriter.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return "success";
+    }
+
+    /**
+     * 获取svg文件
+     */
+    public String getSvgFile(String id) {
+        BufferedReader bufferedReader = null;
+        try {
+            File file = new File(SVG_PATH + id + ".svg");
+            System.out.println(file.getAbsolutePath());
+            if (!file.exists()) {
+                return "";
+            }
+            bufferedReader = new BufferedReader(new FileReader(file));
+            StringBuilder sb = new StringBuilder();
+            String s = null;
+            while ((s = bufferedReader.readLine()) != null) {
+                sb.append(s);
+            }
+            return sb.toString();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                bufferedReader.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return "";
+    }
+
+    /**
+     * 添加触发器和标签
+     */
+    public String addSvgInfo(SvgInfo info) {
+        String id = info.getId();
+        if (id == null || "".equals(id)) {
+            return "触发器和标签id不能为空";
+        }
+        BufferedWriter bufferedWriter = null;
+        try {
+            File pf = new File(SVG_PATH);
+            if (!pf.exists()) {
+                boolean b = pf.mkdirs();
+            }
+            File f = new File(SVG_PATH + info.getId() + ".info");
+            String val = JSON.toJSONString(info);
+            bufferedWriter = new BufferedWriter(new FileWriter(f));
+            bufferedWriter.write(val);
+            bufferedWriter.flush();
+        } catch (Exception e) {
+            e.printStackTrace();
+            return "保存文件出现错误：" + e.getMessage();
+        } finally {
+            try {
+                bufferedWriter.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return "success";
+    }
+
+    /**
+     * 获取svg测点和触发器
+     */
+    public SvgInfo getSvgInfo(String id) {
+        BufferedReader bufferedReader = null;
+        try {
+            File file = new File(SVG_PATH + id + ".info");
+            if (!file.exists()) {
+                return null;
+            }
+            bufferedReader = new BufferedReader(new FileReader(file));
+            StringBuilder sb = new StringBuilder();
+            String s = null;
+            while ((s = bufferedReader.readLine()) != null) {
+                sb.append(s);
+            }
+            return JSON.parseObject(sb.toString(), SvgInfo.class);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                bufferedReader.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
+}

src/main/java/com/gyee/frame/controller/file/LoadrateHourlyController.java

@@ -0,0 +1,62 @@
+package com.gyee.frame.controller.file;
+
+import com.gyee.frame.common.conf.AjaxStatus;
+import com.gyee.frame.common.domain.AjaxResult;
+import com.gyee.frame.common.file.FileZip;
+import com.gyee.frame.model.config.FilePathConfig;
+import com.gyee.frame.model.excel.LoadrateHourly;
+import com.gyee.frame.service.export.LoadrateHourlyService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import java.io.File;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/loadrate")
+public class LoadrateHourlyController {
+
+    @Resource
+    private LoadrateHourlyService loadrateHourlyService;
+
+    /**
+     * 光伏逆变器负荷率
+     */
+    @GetMapping("/info")
+    public AjaxResult getInfo(@RequestParam("stationid") String stationid,
+                              @RequestParam("date") String date,
+                              @RequestParam("time") String time){
+        List<LoadrateHourly> loadrateHourlies = loadrateHourlyService.readExcel(stationid, date, time);
+        if(loadrateHourlies==null){
+            return AjaxResult.error("文件不存在！");
+        }
+        return AjaxResult.successData(AjaxStatus.success.code,loadrateHourlies);
+    }
+    @GetMapping("/down")
+    public AjaxResult getDownInfo(HttpServletResponse response,
+                                  @RequestParam(value = "stationid",required = false) String stationid,
+                                  @RequestParam("date") String date,
+                                  @RequestParam(value = "time",required = false) String time){
+
+        if(time!=null){
+            File path = loadrateHourlyService.getPath(date, time);
+            if(!path.exists()) return AjaxResult.error("文件不存在！");
+            FileZip.download(path.getPath(),response);
+            return AjaxResult.success();
+        }else{
+            String s = FilePathConfig.getDataPath() + "\\光伏逆变器负荷率利用小时计算\\" + date.replaceAll("-", "") + ".zip";
+            File zipfile = new File(s);
+            List<File> values = loadrateHourlyService.getAllPath(date).entrySet().stream().map(kv -> kv.getValue()).collect(Collectors.toList());
+            if(values.size()<=0) return AjaxResult.error("文件不存在！");
+            String s1 = FileZip.zipFiles(values, zipfile);
+            FileZip.download(s1,response);
+            return AjaxResult.success();
+        }
+    }
+}

src/main/java/com/gyee/frame/controller/file/RectInfo.java

@@ -0,0 +1,57 @@
+package com.gyee.frame.controller.file;
+
+/**
+ * 图形矩阵信息
+ *
+ * @author xysn
+ */
+public class RectInfo {
+    /**
+     * x坐标
+     */
+    private double x;
+    /**
+     * y坐标
+     */
+    private double y;
+    /**
+     * 宽度
+     */
+    private double width;
+    /**
+     * 高度
+     */
+    private double height;
+
+    public double getX() {
+        return x;
+    }
+
+    public void setX(double x) {
+        this.x = x;
+    }
+
+    public double getY() {
+        return y;
+    }
+
+    public void setY(double y) {
+        this.y = y;
+    }
+
+    public double getWidth() {
+        return width;
+    }
+
+    public void setWidth(double width) {
+        this.width = width;
+    }
+
+    public double getHeight() {
+        return height;
+    }
+
+    public void setHeight(double height) {
+        this.height = height;
+    }
+}

src/main/java/com/gyee/frame/controller/file/ShapeInfo.java

@@ -0,0 +1,218 @@
+package com.gyee.frame.controller.file;
+
+import com.sun.xml.bind.v2.model.core.PropertyInfo;
+
+import javax.servlet.jsp.tagext.TagInfo;
+import java.util.List;
+
+/**
+ * 升压站图形信息
+ *
+ * @author xysn
+ */
+public class ShapeInfo {
+    /**
+     * 类型
+     */
+    private String type;
+    /**
+     * ID
+     */
+    private String id;
+    /**
+     * 序号
+     */
+    private int index;
+    /**
+     * 名称
+     */
+    private String name;
+    /**
+     * 矩形信息
+     */
+    private RectInfo rect;
+    /**
+     * 边框宽度
+     */
+    private double thickness;
+    /**
+     * 旋转角度
+     */
+    private float angle;
+    /**
+     * 填充颜色
+     */
+    private String fillColor;
+    /**
+     * 边框颜色
+     */
+    private String strokeColor;
+    /**
+     * 圆角半径
+     */
+    private float cornerRadius;
+    /**
+     * 是否显示
+     */
+    private boolean isVisible;
+    /**
+     * 事件
+     */
+    private String event;
+    /**
+     * 文字信息
+     */
+    private TextInfo textInfo;
+    /**
+     * 附加信息
+     */
+    private String tag;
+    /**
+     * 子图形
+     */
+    private List<ShapeInfo> subShapes;
+    /**
+     * 测点信息
+     */
+    private List<TagInfo> tagInfos;
+    /**
+     * 属性信息
+     */
+    private List<PropertyInfo> propertyInfos;
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public int getIndex() {
+        return index;
+    }
+
+    public void setIndex(int index) {
+        this.index = index;
+    }
+
+    public RectInfo getRect() {
+        return rect;
+    }
+
+    public void setRect(RectInfo rect) {
+        this.rect = rect;
+    }
+
+    public double getThickness() {
+        return thickness;
+    }
+
+    public void setThickness(double thickness) {
+        this.thickness = thickness;
+    }
+
+    public float getAngle() {
+        return angle;
+    }
+
+    public void setAngle(float angle) {
+        this.angle = angle;
+    }
+
+    public String getFillColor() {
+        return fillColor;
+    }
+
+    public void setFillColor(String fillColor) {
+        this.fillColor = fillColor;
+    }
+
+    public String getStrokeColor() {
+        return strokeColor;
+    }
+
+    public void setStrokeColor(String strokeColor) {
+        this.strokeColor = strokeColor;
+    }
+
+    public float getCornerRadius() {
+        return cornerRadius;
+    }
+
+    public void setCornerRadius(float cornerRadius) {
+        this.cornerRadius = cornerRadius;
+    }
+
+    public boolean getIsVisible() {
+        return isVisible;
+    }
+
+    public void setIsVisible(boolean visible) {
+        isVisible = visible;
+    }
+
+    public String getEvent() {
+        return event;
+    }
+
+    public void setEvent(String event) {
+        this.event = event;
+    }
+
+    public TextInfo getTextInfo() {
+        return textInfo;
+    }
+
+    public void setTextInfo(TextInfo textInfo) {
+        this.textInfo = textInfo;
+    }
+
+    public String getTag() {
+        return tag;
+    }
+
+    public void setTag(String tag) {
+        this.tag = tag;
+    }
+
+    public List<ShapeInfo> getSubShapes() {
+        return subShapes;
+    }
+
+    public void setSubShapes(List<ShapeInfo> subShapes) {
+        this.subShapes = subShapes;
+    }
+
+    public List<TagInfo> getTagInfos() {
+        return tagInfos;
+    }
+
+    public void setTagInfos(List<TagInfo> tagInfos) {
+        this.tagInfos = tagInfos;
+    }
+
+    public List<PropertyInfo> getPropertyInfos() {
+        return propertyInfos;
+    }
+
+    public void setPropertyInfos(List<PropertyInfo> propertyInfos) {
+        this.propertyInfos = propertyInfos;
+    }
+}

src/main/java/com/gyee/frame/controller/file/SvgCondition.java

@@ -0,0 +1,57 @@
+package com.gyee.frame.controller.file;
+
+/**
+ * svg 触发器
+ *
+ * @author xysn
+ */
+public class SvgCondition {
+    /**
+     * 属性
+     */
+    private String property;
+    /**
+     * 触发值
+     */
+    private double value;
+    /**
+     * 触发器属性
+     */
+    private String propertyValue;
+    /**
+     * 是否值绑定
+     */
+    private boolean isBinding;
+
+    public String getProperty() {
+        return property;
+    }
+
+    public void setProperty(String property) {
+        this.property = property;
+    }
+
+    public double getValue() {
+        return value;
+    }
+
+    public void setValue(double value) {
+        this.value = value;
+    }
+
+    public String getPropertyValue() {
+        return propertyValue;
+    }
+
+    public void setPropertyValue(String propertyValue) {
+        this.propertyValue = propertyValue;
+    }
+
+    public boolean getIsBinding() {
+        return this.isBinding;
+    }
+
+    public void setIsBinding(boolean isBinding) {
+        this.isBinding = isBinding;
+    }
+}

src/main/java/com/gyee/frame/controller/file/SvgFileInfo.java

@@ -0,0 +1,33 @@
+package com.gyee.frame.controller.file;
+
+/**
+ * SVG文件信息
+ *
+ * @author xysn
+ */
+public class SvgFileInfo {
+    /**
+     * ID
+     */
+    private String id;
+    /**
+     * 内容
+     */
+    private String value;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+}

src/main/java/com/gyee/frame/controller/file/SvgInfo.java

@@ -0,0 +1,54 @@
+package com.gyee.frame.controller.file;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * svg信息
+ *
+ * @author xysn
+ */
+public class SvgInfo {
+    /**
+     * ID
+     */
+    private String id;
+    /**
+     * 触发器
+     */
+    private Map<String, SvgCondition> conditions;
+    /**
+     * 测点
+     */
+    private Map<String, SvgTagInfo> tags;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Map<String, SvgCondition> getConditions() {
+        if (conditions == null) {
+            conditions = new HashMap<>();
+        }
+        return conditions;
+    }
+
+    public void setConditions(Map<String, SvgCondition> conditions) {
+        this.conditions = conditions;
+    }
+
+    public Map<String, SvgTagInfo> getTags() {
+        if (tags == null) {
+            tags = new HashMap<>();
+        }
+        return tags;
+    }
+
+    public void setTags(Map<String, SvgTagInfo> tags) {
+        this.tags = tags;
+    }
+}

src/main/java/com/gyee/frame/controller/file/SvgTagInfo.java

@@ -0,0 +1,33 @@
+package com.gyee.frame.controller.file;
+
+/**
+ * svg 标签信息
+ *
+ * @author xysn
+ */
+public class SvgTagInfo {
+    /**
+     * 测点名称
+     */
+    private String name;
+    /**
+     * 测点
+     */
+    private String tag;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getTag() {
+        return tag;
+    }
+
+    public void setTag(String tag) {
+        this.tag = tag;
+    }
+}

src/main/java/com/gyee/frame/controller/file/TextInfo.java

@@ -0,0 +1,45 @@
+package com.gyee.frame.controller.file;
+
+/**
+ * 图形文字信息
+ *
+ * @author xysn
+ */
+public class TextInfo {
+    /**
+     * 文字
+     */
+    private String text;
+    /**
+     * 字符大小
+     */
+    private float fontSize;
+    /**
+     * 字体
+     */
+    private String fontFamily;
+
+    public String getText() {
+        return text;
+    }
+
+    public void setText(String text) {
+        this.text = text;
+    }
+
+    public float getFontSize() {
+        return fontSize;
+    }
+
+    public void setFontSize(float fontSize) {
+        this.fontSize = fontSize;
+    }
+
+    public String getFontFamily() {
+        return fontFamily;
+    }
+
+    public void setFontFamily(String fontFamily) {
+        this.fontFamily = fontFamily;
+    }
+}

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/config/FilePathConfig.java

@@ -0,0 +1,29 @@
+package com.gyee.frame.model.config;
+
+import org.springframework.boot.system.ApplicationHome;
+
+import java.io.File;
+
+public class FilePathConfig {
+    private static String filePath;
+    private static String dataPath;
+
+    public static String getFilePath() {
+        if(filePath==null){
+            ApplicationHome home = new ApplicationHome(FilePathConfig.class);
+            filePath=home.getSource().getParentFile().getAbsolutePath();
+        }
+        return filePath;
+    }
+
+    public static String getDataPath() {
+        if(dataPath==null){
+            getFilePath();
+            //dataPath = filePath.substring(0, filePath.lastIndexOf("\\"));
+            dataPath = filePath+"\\data";
+            File file = new File(dataPath + "\\光伏逆变器负荷率利用小时计算");
+            if(!file.exists()) file.mkdirs();
+        }
+        return dataPath;
+    }
+}

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

@@ -0,0 +1,16 @@
+package com.gyee.frame.model.excel;
+
+import lombok.Data;
+
+@Data
+public class LoadrateHourly {
+    private String id;
+    private String branchcount;
+    private String platecount;
+    private String platecapacity;
+    private String time;
+    private String power;
+    private String loadfactor;
+    private String generatedenergy;
+    private String utilizationhour;
+}

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

@@ -0,0 +1,211 @@
+package com.gyee.frame.schdule.windturbinestatetime;
+
+import com.gyee.frame.common.feign.RemoteServiceBuilder;
+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.service.WindTurbineTestingPointAiService;
+import com.gyee.frame.service.export.LoadrateHourlyService;
+import com.gyee.frame.util.DateUtils;
+import org.apache.poi.ss.usermodel.FormulaEvaluator;
+import org.apache.poi.xssf.usermodel.*;
+import org.springframework.boot.system.ApplicationHome;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 光伏负荷率、利用小时计算
+ */
+@Component
+public class TaskLoadrateHourlyStatistics {
+
+    @Resource
+    private WindTurbineTestingPointAiService windTurbineTestingPointAiService;
+    @Resource
+    private RemoteServiceBuilder remoteServiceBuilder;
+    @Resource
+    private LoadrateHourlyService loadrateHourlyService;
+
+    private String powerTags;
+    private String electricityTags;
+    private List<WindTurbineTestingPointAi2> ai2ForPower;
+    private List<WindTurbineTestingPointAi2> ai2ForElectricity;
+    //场站、风机、标签点
+    Map<String, List<String>> powerCollect;
+    Map<String, List<String>> electricityCollect;
+
+    //利用小时计算
+    private void creatExcel(XSSFWorkbook sheets) {
+        getPowerTags();
+        getElectricityTags();
+        Calendar instance = Calendar.getInstance();
+        //Map<String,TsPointData> powerPoint = remoteServiceBuilder.ShardingService().getHistorySection(powerTags, instance.getTimeInMillis());
+        Map<String,TsPointData> electricityPoint = remoteServiceBuilder.ShardingService().getHistorySection(electricityTags, instance.getTimeInMillis());
+        //getPowerCollect();
+        getElectricityCollect();
+        Map<Integer, String> ptMap = loadrateHourlyService.getPtMap();
+        for (int i = 0; i <5; i++) {
+            XSSFSheet sheetAt = sheets.getSheetAt(i);
+            for (int i1 = 0; i1 < sheetAt.getLastRowNum()-1; i1++) {
+                sheetAt.getRow(i1+2).getCell(4).setCellValue(DateUtils.format(instance.getTime(),"yyyy-MM-dd HH:mm:ss"));
+                //sheetAt.getRow(i1+2).getCell(5).setCellValue(powerPoint.get(powerCollect.get(ptMap.get(i)).get(i1)).getDoubleValue());
+                sheetAt.getRow(i1+2).getCell(5).setCellValue(electricityPoint.get(electricityCollect.get(ptMap.get(i)).get(i1)).getDoubleValue());
+            }
+        }
+        FormulaEvaluator evaluator = new XSSFFormulaEvaluator(sheets);
+        evaluator.evaluateAll();
+        //通过输出流将workbook对象下载到磁盘
+        FileOutputStream out = null;
+        try {
+            out = new FileOutputStream(FilePathConfig.getDataPath()+"\\光伏逆变器负荷率利用小时计算\\"+DateUtils.format(new Date(),"yyyyMMdd")+"2200.xlsx");
+            sheets.write(out);
+            out.flush();
+            out.close();
+            //sheets.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+    //负荷率计算
+    private void creatExcel(String t) {
+        XSSFWorkbook sheets = readExceltemplate();
+        getPowerTags();
+        getElectricityTags();
+        Calendar instance = Calendar.getInstance();
+        Map<String,TsPointData> powerPoint = remoteServiceBuilder.ShardingService().getHistorySection(powerTags, instance.getTimeInMillis());
+        getPowerCollect();
+        Map<Integer, String> ptMap = loadrateHourlyService.getPtMap();
+        for (int i = 0; i <5; i++) {
+            XSSFSheet sheetAt = sheets.getSheetAt(i);
+            for (int i1 = 0; i1 < sheetAt.getLastRowNum()-1; i1++) {
+                sheetAt.getRow(i1+2).getCell(4).setCellValue(DateUtils.format(instance.getTime(),"yyyy-MM-dd HH:mm:ss"));
+                sheetAt.getRow(i1+2).getCell(5).setCellValue(powerPoint.get(powerCollect.get(ptMap.get(i)).get(i1)).getDoubleValue());
+            }
+        }
+        FormulaEvaluator evaluator = new XSSFFormulaEvaluator(sheets);
+        evaluator.evaluateAll();
+        //通过输出流将workbook对象下载到磁盘
+        FileOutputStream out = null;
+        try {
+            out = new FileOutputStream(FilePathConfig.getDataPath()+"\\光伏逆变器负荷率利用小时计算\\"+DateUtils.format(new Date(),"yyyyMMdd")+t+".xlsx");
+            sheets.write(out);
+            out.flush();
+            out.close();
+            //sheets.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 9点半
+     */
+    @Scheduled(cron = "0 30 9 * * ?")
+    public void getLoadrateHourly930(){
+        creatExcel("0930");
+    }
+
+    /**
+     * 12点半
+     */
+    @Scheduled(cron = "0 30 12 * * ?")
+    public void getLoadrateHourly1230(){
+        creatExcel("1230");
+    }
+
+    /**
+     * 18点半
+     */
+    @Scheduled(cron = "0 0 16 * * ?")
+    public void getLoadrateHourly1830(){
+        creatExcel("1830");
+    }
+
+    /**
+     * 22点
+     */
+    @Scheduled(cron = "0 0 20 * * ?")
+    public void getLoadrateHourly2200(){
+        String path = FilePathConfig.getFilePath()+"\\template\\公司光伏逆变器利用小时计算模板.xlsx";
+        XSSFWorkbook sheets = readExceltemplate(path);
+        creatExcel(sheets);
+    }
+
+    private XSSFWorkbook readExceltemplate(String path){
+        //在内存中创建一个Excel文件
+        XSSFWorkbook sheets = null;
+        try {
+            sheets = new XSSFWorkbook(path);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return sheets;
+    }
+
+    private XSSFWorkbook readExceltemplate(){
+        String path = FilePathConfig.getFilePath()+"\\template\\公司光伏逆变器负荷率计算模板.xlsx";
+        return readExceltemplate(path);
+    }
+
+    public String getPowerTags() {
+        if(powerTags==null){
+            getAi2ForPower();
+            powerTags = ai2ForPower.stream().map(wttpai2 -> wttpai2.getId()).collect(Collectors.joining(","));
+        }
+        return powerTags;
+    }
+
+    public String getElectricityTags() {
+        if(electricityTags==null){
+            getAi2ForElectricity();
+            electricityTags = ai2ForElectricity.stream().map(wttpai2 -> wttpai2.getId()).collect(Collectors.joining(","));
+        }
+        return electricityTags;
+    }
+
+    public List<WindTurbineTestingPointAi2> getAi2ForPower() {
+        if(ai2ForPower==null){
+            WindTurbineTestingPointAi2Example example = new WindTurbineTestingPointAi2Example();
+            example.createCriteria().andUniformcodeEqualTo("AI130").andWindpowerstationidLike("%GDC");
+            ai2ForPower = windTurbineTestingPointAiService.selectByExample(example);
+        }
+        return ai2ForPower;
+    }
+
+    public List<WindTurbineTestingPointAi2> getAi2ForElectricity() {
+        if(ai2ForElectricity==null){
+            WindTurbineTestingPointAi2Example example = new WindTurbineTestingPointAi2Example();
+            example.createCriteria().andUniformcodeEqualTo("RFDL").andWindpowerstationidLike("%GDC");
+            ai2ForElectricity = windTurbineTestingPointAiService.selectByExample(example);
+        }
+        return ai2ForElectricity;
+    }
+
+    public Map<String, List<String>> getPowerCollect() {
+        if(powerCollect==null){
+            powerCollect = ai2ForPower.stream().sorted((ai1,ai2)->{
+                return Integer.parseInt(ai1.getWindturbineid().substring(ai1.getWindturbineid().indexOf("_")+1))
+                        - Integer.parseInt(ai2.getWindturbineid().substring(ai2.getWindturbineid().indexOf("_")+1));
+            }).collect(Collectors.groupingBy(WindTurbineTestingPointAi2::getWindpowerstationid,Collectors.mapping(WindTurbineTestingPointAi2::getId,Collectors.toList())));
+        }
+        return powerCollect;
+    }
+
+    public Map<String, List<String>> getElectricityCollect() {
+        if(electricityCollect==null){
+            electricityCollect = ai2ForElectricity.stream().sorted((ai1,ai2)->{
+                return Integer.parseInt(ai1.getWindturbineid().substring(ai1.getWindturbineid().indexOf("_")+1))
+                        - Integer.parseInt(ai2.getWindturbineid().substring(ai2.getWindturbineid().indexOf("_")+1));
+            }).collect(Collectors.groupingBy(WindTurbineTestingPointAi2::getWindpowerstationid,Collectors.mapping(WindTurbineTestingPointAi2::getId,Collectors.toList())));
+        }
+        return electricityCollect;
+    }
+}

src/main/java/com/gyee/frame/service/AnalysissubtablebottomService.java

@@ -8,7 +8,6 @@ import com.gyee.frame.model.auto.AnalysissubtablebottomExample;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import javax.xml.ws.ServiceMode;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;

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

@@ -0,0 +1,184 @@
+package com.gyee.frame.service.export;
+
+import com.gyee.frame.model.config.FilePathConfig;
+import com.gyee.frame.model.excel.LoadrateHourly;
+import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.xssf.usermodel.XSSFRow;
+import org.apache.poi.xssf.usermodel.XSSFSheet;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.springframework.stereotype.Service;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class LoadrateHourlyService {
+
+    private Map<Integer, String> ptMap;
+    private Map<String, Integer> tpMap;
+
+    public Map<Integer, String> getPtMap() {
+        if (ptMap == null) {
+            ptMap = new HashMap<>(5);
+            ptMap.put(0, "PL_GDC");
+            ptMap.put(1, "DWK_GDC");
+            ptMap.put(2, "XH_GDC");
+            ptMap.put(3, "MCH_GDC");
+            ptMap.put(4, "HZJ_GDC");
+        }
+        return ptMap;
+    }
+
+    public Map<String, Integer> getTpMap() {
+        if (tpMap == null) {
+            tpMap = new HashMap<>(5);
+            tpMap.put("PL_GDC",0);
+            tpMap.put("DWK_GDC",1);
+            tpMap.put("XH_GDC",2);
+            tpMap.put("MCH_GDC",3);
+            tpMap.put("HZJ_GDC",4);
+        }
+        return tpMap;
+    }
+
+    public File getPath(String date, String time) {
+        String stime = date.replaceAll("-", "");
+        String path = FilePathConfig.getDataPath() + "\\光伏逆变器负荷率利用小时计算\\" + stime + time + ".xlsx";
+        return new File(path);
+    }
+
+    public Map<String, File> getAllPath(String time) {
+        Map<String, File> fileMap = new HashMap<>();
+        File file1 = getPath(time, "0930");
+        if (file1.exists()) fileMap.put("0930", file1);
+        File file2 = getPath(time, "1230");
+        if (file2.exists()) fileMap.put("1230", file2);
+        File file3 = getPath(time, "1830");
+        if (file3.exists()) fileMap.put("1830", file3);
+        File file4 = getPath(time, "2200");
+        if (file4.exists()) fileMap.put("2200", file4);
+        return fileMap;
+    }
+
+    private Map<String, List<LoadrateHourly>> sheets2LoadrateHourly(File file) {
+        XSSFWorkbook sheets = null;
+        try {
+            sheets = new XSSFWorkbook(file);
+        } catch (IOException | InvalidFormatException e) {
+            e.printStackTrace();
+        }
+
+        getPtMap();
+        Map<String, List<LoadrateHourly>> loadrateHourlysMap = new HashMap<>();
+        //表
+        for (int i = 0; i < 5; i++) {
+            XSSFSheet sheetAt = sheets.getSheetAt(i);
+            List<LoadrateHourly> loadrateHourlys = new ArrayList<>();
+            //行
+            for (int i1 = 0; i1 < sheetAt.getLastRowNum() - 1; i1++) {
+                XSSFRow row = sheetAt.getRow(i1 + 2);
+                LoadrateHourly lrh = new LoadrateHourly();
+                lrh.setId(getCellValue(row.getCell(0)));
+                lrh.setBranchcount(getCellValue(row.getCell(1)));
+                lrh.setPlatecount(getCellValue(row.getCell(2)));
+                lrh.setPlatecapacity(getCellValue(row.getCell(3)));
+                lrh.setTime(getCellValue(row.getCell(4)));
+                lrh.setPower(getCellValue(row.getCell(5)));
+                lrh.setLoadfactor(getCellValue(row.getCell(6)));
+                lrh.setGeneratedenergy(getCellValue(row.getCell(7)));
+                lrh.setUtilizationhour(getCellValue(row.getCell(8)));
+                loadrateHourlys.add(lrh);
+            }
+            loadrateHourlysMap.put(ptMap.get(i), loadrateHourlys);
+        }
+        return loadrateHourlysMap;
+    }
+
+    public String getCellValue(Cell cell) {
+        if (cell == null) return "";
+        String cellValue = "";
+        //判断数据的类型
+        switch (cell.getCellType()) {
+            case NUMERIC: //数字
+                cellValue = String.valueOf(cell.getNumericCellValue());
+                break;
+            case STRING: //字符串
+                cellValue = String.valueOf(cell.getStringCellValue());
+                break;
+            case BOOLEAN: //Boolean
+                cellValue = String.valueOf(cell.getBooleanCellValue());
+                break;
+            case FORMULA: //公式
+                cellValue = String.format("%.2f", cell.getNumericCellValue());
+                break;
+            default:
+                break;
+        }
+        return cellValue;
+    }
+
+    public Map<String, Map<String, List<LoadrateHourly>>> readExcel(String time) {
+        Map<String, Map<String, List<LoadrateHourly>>> lrhs = new HashMap<>();
+        Map<String, File> allPath = getAllPath(time);
+        for (Map.Entry<String, File> stringFileEntry : allPath.entrySet()) {
+            Map<String, List<LoadrateHourly>> stringListMap = sheets2LoadrateHourly(stringFileEntry.getValue());
+            lrhs.put(stringFileEntry.getKey(), stringListMap);
+        }
+        return lrhs;
+    }
+
+    public List<LoadrateHourly> readExcel(String stationid, String date, String time) {
+        File file = getPath(date, time);
+        List<LoadrateHourly> stringListMap = null;
+        if (file.exists()) {
+            stringListMap = sheets2LoadrateHourly(stationid, file,time);
+        }
+        return stringListMap;
+    }
+
+    private List<LoadrateHourly> sheets2LoadrateHourly(String stationid, File file, String time) {
+        XSSFWorkbook sheets = null;
+        try {
+            sheets = new XSSFWorkbook(file);
+        } catch (IOException | InvalidFormatException e) {
+            e.printStackTrace();
+        }
+        getPtMap();
+        getTpMap();
+        XSSFSheet sheetAt = sheets.getSheetAt(tpMap.get(stationid));
+        List<LoadrateHourly> loadrateHourlys = new ArrayList<>();
+        if(time.equals("2200")){
+            for (int i1 = 0; i1 < sheetAt.getLastRowNum() - 1; i1++) {
+                XSSFRow row = sheetAt.getRow(i1 + 2);
+                LoadrateHourly lrh = new LoadrateHourly();
+                lrh.setId(getCellValue(row.getCell(0)));
+                lrh.setBranchcount(getCellValue(row.getCell(1)));
+                lrh.setPlatecount(getCellValue(row.getCell(2)));
+                lrh.setPlatecapacity(getCellValue(row.getCell(3)));
+                lrh.setTime(getCellValue(row.getCell(4)));
+                lrh.setGeneratedenergy(getCellValue(row.getCell(5)));
+                lrh.setUtilizationhour(getCellValue(row.getCell(6)));
+                loadrateHourlys.add(lrh);
+            }
+        }else {
+            for (int i1 = 0; i1 < sheetAt.getLastRowNum() - 1; i1++) {
+                XSSFRow row = sheetAt.getRow(i1 + 2);
+                LoadrateHourly lrh = new LoadrateHourly();
+                lrh.setId(getCellValue(row.getCell(0)));
+                lrh.setBranchcount(getCellValue(row.getCell(1)));
+                lrh.setPlatecount(getCellValue(row.getCell(2)));
+                lrh.setPlatecapacity(getCellValue(row.getCell(3)));
+                lrh.setTime(getCellValue(row.getCell(4)));
+                lrh.setPower(getCellValue(row.getCell(5)));
+                lrh.setLoadfactor(getCellValue(row.getCell(6)));
+                loadrateHourlys.add(lrh);
+            }
+        }
+        return loadrateHourlys;
+    }
+}

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/main/java/com/gyee/frame/service/websocket/SandtableService.java

@@ -380,6 +380,7 @@ public class SandtableService {
                 }
                 if (mttrmaps.containsKey("mtbf")) {
                     tb_mtbf = (double) mttrmaps.get("mtbf");
+                    if(tb_mtbf!=0)
                     tb_mtbf = new BigDecimal(mtbf - tb_mtbf).divide(new BigDecimal(tb_mtbf), 4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue();
 
                 }
@@ -421,6 +422,7 @@ public class SandtableService {
                 }
                 if (mttrmaps.containsKey("mtbf")) {
                     bg_mtbf = (double) mttrmaps.get("mtbf");
+                    if(bg_mtbf!=0)
                     bg_mtbf = new BigDecimal(mtbf - bg_mtbf).divide(new BigDecimal(bg_mtbf), 4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue();
                     if(bg_mtbf<-100)
                     {

src/main/resources/application-dev.yml

@@ -25,7 +25,7 @@ spring:
      #两票数据源
      ticket:
        #url: jdbc:sqlserver://123.60.213.70:1433;DatabaseName=fdeam
-       url: jdbc:sqlserver://10.155.32.2:1433;DatabaseName=fdeam
+       url: jdbc:sqlserver://192.168.1.82:1433;DatabaseName=fdeam
        username: sa
        password: Gyee@321#!
        driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver

src/test/java/test/LosePowerTest.java

@@ -0,0 +1,506 @@
+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;
+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.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * 每个月各场站每台风机有多少次故障（故障时间持续超过2小时），停机时间。停机损失多少电量
+ */
+@SpringBootTest(classes = SpringbootStart.class)
+@RunWith(SpringRunner.class)
+public class LosePowerTest {
+
+    @Resource
+    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 {
+        getFaultCodes();
+        getLlfdlMap();
+        Date start = DateUtils.parseDate("2022-10-01", "yyyy-MM-dd");
+        Date end = DateUtils.parseDate("2022-10-31", "yyyy-MM-dd");
+        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) {
+        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).reversed()).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 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);
+            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("%_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;
+    }
+
+
+    @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;
+    }
+}