山西大同功能实现

web/gdsx-ghost/src/main/java/com/gyee/ghost/controller/StoptypeController.java

@@ -0,0 +1,20 @@
+package com.gyee.ghost.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-08-06
+ */
+@RestController
+@RequestMapping("//stoptype")
+public class StoptypeController {
+
+}

web/gdsx-ghost/src/main/java/com/gyee/ghost/controller/ghost/GhostController.java

@@ -8,6 +8,7 @@ import com.gyee.common.model.StringUtils;
 import com.gyee.ghost.init.CacheContext;
 import com.gyee.ghost.model.auto.Fanoperation;
 import com.gyee.ghost.model.auto.Nature;
+import com.gyee.ghost.model.auto.Shutdownevent;
 import com.gyee.ghost.model.auto.Windpowerstation;
 import com.gyee.ghost.service.auto.GhostService;
 import org.springframework.web.bind.annotation.*;
@@ -63,4 +64,20 @@ public class GhostController {
             return R.error().message("访问失败");
         }
     }
+
+
+    @GetMapping("/shutdownevent")
+    @ResponseBody
+    @CrossOrigin(origins = "*", maxAge = 3600)
+    public R shutdownevent(
+            @RequestParam(value = "wpid",required = true)String wpid,
+            @RequestParam(value = "beginDate",required = true)String beginDate,
+            @RequestParam(value = "endDate",required = true)String endDate){
+        List<Shutdownevent> resultList = ghostService.shutdownevent(wpid,beginDate,endDate);
+        if (StringUtils.isNotNull(resultList)) {
+            return R.ok((long) resultList.size()).data(resultList);
+        }else{
+            return R.error().message("访问失败");
+        }
+    }
 }

web/gdsx-ghost/src/main/java/com/gyee/ghost/init/CacheContext.java

@@ -2,9 +2,11 @@ package com.gyee.ghost.init;
 
 
 
+import com.gyee.ghost.model.auto.Stoptype;
 import com.gyee.ghost.model.auto.Windpowerstation;
 import com.gyee.ghost.model.auto.Windturbine;
 import com.gyee.ghost.service.auto.GhostService;
+import com.gyee.ghost.service.auto.IStoptypeService;
 import com.gyee.ghost.service.auto.IWindpowerstationService;
 import com.gyee.ghost.service.auto.IWindturbineService;
 import org.slf4j.Logger;
@@ -35,11 +37,14 @@ public class CacheContext implements CommandLineRunner {
     private IWindturbineService windturbineService;
     @Resource
     private IWindpowerstationService windpowerstationService;
+    @Resource
+    private IStoptypeService stoptypeService;
 
     public static List<Windturbine> wtls = new ArrayList<>();
     public static Map<String,Windturbine> wtmap = new HashMap<>();
 
     public static List<Windpowerstation> wpls = new ArrayList<>();
+    public static Map<String,String> stopmap = new HashMap<>();
 
 
     @Override
@@ -51,6 +56,12 @@ public class CacheContext implements CommandLineRunner {
 
         wpls = windpowerstationService.list();
 
+        List<Stoptype> stoptypes = stoptypeService.list();
+        stoptypes.forEach(stoptype -> {
+            stopmap.put(stoptype.getId(),stoptype.getName());
+        });
+
+        ghostService.saveNature("2022-08-01","2022-08-05");
 
 
     }

web/gdsx-ghost/src/main/java/com/gyee/ghost/mapper/auto/StoptypeMapper.java

@@ -0,0 +1,16 @@
+package com.gyee.ghost.mapper.auto;
+
+import com.gyee.ghost.model.auto.Stoptype;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-08-06
+ */
+public interface StoptypeMapper extends BaseMapper<Stoptype> {
+
+}

web/gdsx-ghost/src/main/java/com/gyee/ghost/model/auto/Stoptype.java

@@ -0,0 +1,32 @@
+package com.gyee.ghost.model.auto;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-08-06
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class Stoptype extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    private String id;
+
+    private String name;
+
+    private Integer isplan;
+
+    private String parentid;
+
+    private String nwys;
+
+
+}

web/gdsx-ghost/src/main/java/com/gyee/ghost/service/auto/GhostService.java

@@ -16,10 +16,7 @@ import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
 import java.sql.Timestamp;
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Optional;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Service
@@ -201,6 +198,7 @@ public class GhostService {
             Fanoperation fanoperation = hjlist.get(0);
             fanoperation.setWindturbineid("合计");
             fanoperation.setWindturbinename("合计");
+            fanoperation.setAvailability(DoubleUtils.keepPrecision(fanoperation.getAvailability(),2));
             resultList.add(fanoperation);
         }
         return resultList;
@@ -223,7 +221,7 @@ public class GhostService {
         SortUtils.sort(resultList,"windturbineid",SortUtils.ASC);
 
         qw.clear();
-        qw.select("windturbineid,windturbinename,sum(generatingcapacity) generatingcapacity,min(inputsmall) inputsmall,max(inputsmallspeed) inputsmallspeed,max(edinputsmallspeed) edinputsmallspeed,max(edinputsavgspeed) edinputsavgspeed,max(edinputbigpower) edinputbigpower,max(edinputavgpower) edinputavgpower,avg(availability) availability,sum(faultcount) faultcount,sum(faulttime) faulttime");
+        qw.select("sum(generatingcapacity) generatingcapacity,min(inputsmall) inputsmall,max(inputsmallspeed) inputsmallspeed,max(edinputsmallspeed) edinputsmallspeed,max(edinputsavgspeed) edinputsavgspeed,max(edinputbigpower) edinputbigpower,max(edinputavgpower) edinputavgpower,avg(availability) availability,sum(faultcount) faultcount,sum(faulttime) faulttime");
         qw.ge("recorddate",begin).le("recorddate",end);
         if (StringUtils.isNotEmpty(wpid)){
             qw.eq("windpowerstationid",wpid);
@@ -233,8 +231,29 @@ public class GhostService {
             Nature nature = hjlist.get(0);
             nature.setWindturbineid("合计");
             nature.setWindturbinename("合计");
+            nature.setAvailability(DoubleUtils.keepPrecision(nature.getAvailability(),2));
             resultList.add(nature);
         }
         return resultList;
     }
+
+    public List<Shutdownevent> shutdownevent(String wpid, String beginDate, String endDate) {
+        List<Shutdownevent> resultList = new ArrayList<>();
+        Map<String, String> stopmap = CacheContext.stopmap;
+        Date begin = DateUtils.parseDate(beginDate);
+        Date end = DateUtils.parseDate(endDate);
+        QueryWrapper<Shutdownevent> qw = new QueryWrapper<>();
+        qw.ge("stoptime",begin).le("stoptime",end);
+        if (StringUtils.isNotEmpty(wpid)){
+            qw.eq("windpowerstationid",wpid);
+        }
+        List<Shutdownevent> shutdowneventList = shutdowneventService.list(qw);
+        shutdowneventList.stream().forEach(shutdownevent->{
+            String stoptypeid = shutdownevent.getStoptypeid();
+            shutdownevent.setStoptypeid(stopmap.get(stoptypeid));
+            resultList.add(shutdownevent);
+        });
+
+        return resultList;
+    }
 }

web/gdsx-ghost/src/main/java/com/gyee/ghost/service/auto/IStoptypeService.java

@@ -0,0 +1,16 @@
+package com.gyee.ghost.service.auto;
+
+import com.gyee.ghost.model.auto.Stoptype;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-08-06
+ */
+public interface IStoptypeService extends IService<Stoptype> {
+
+}

web/gdsx-ghost/src/main/java/com/gyee/ghost/service/auto/impl/StoptypeServiceImpl.java

@@ -0,0 +1,20 @@
+package com.gyee.ghost.service.auto.impl;
+
+import com.gyee.ghost.model.auto.Stoptype;
+import com.gyee.ghost.mapper.auto.StoptypeMapper;
+import com.gyee.ghost.service.auto.IStoptypeService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-08-06
+ */
+@Service
+public class StoptypeServiceImpl extends ServiceImpl<StoptypeMapper, Stoptype> implements IStoptypeService {
+
+}

web/gdsx-ghost/src/main/resources/application.yml

@@ -46,9 +46,9 @@ spring:
     type: com.alibaba.druid.pool.DruidDataSource
     driver-class-name: oracle.jdbc.OracleDriver
     #外网
-    url: jdbc:oracle:thin:@123.60.213.70:1521:gdnxfd
-    username: nxfdprod
-    password: gdnxfd123
+    url: jdbc:oracle:thin:@11.0.118.57:1521:gdsj
+    username: gdprod
+    password: gd123
     oracle-schema=:
 
     #    url: jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&serverTimezone=UTC