新增报警模块

web/consumer-hb/src/main/java/com/gyee/consumer/config/FeignConfiguration.java

@@ -11,6 +11,7 @@ import com.gyee.consumer.fallback.powercompare.PowerCompareServiceFallbackFactor
 import com.gyee.consumer.fallback.powersaturation.PowersaturationServiceFallbackFactory;
 import com.gyee.consumer.fallback.projectplan.ProjectPlanServiceFallbackFactory;
 import com.gyee.consumer.fallback.recommen.RecommenServiceFallbackFactory;
+import com.gyee.consumer.fallback.reliability.ReliabilityServiceFallbackFactory;
 import com.gyee.consumer.fallback.scatter.ScatterServiceFallbackFactory;
 import com.gyee.consumer.fallback.singleanalysis.SingleAnalysisServiceFallbackFactory;
 import com.gyee.consumer.fallback.warn.WarningServiceFallbackFactory;
@@ -123,5 +124,10 @@ public class FeignConfiguration {
         return new AlarmServiceFallbackFactory();
     }
 
+    @Bean
+    public ReliabilityServiceFallbackFactory reliabilityServiceFallbackFactory() {
+        return new ReliabilityServiceFallbackFactory();
+    }
+
 
 }

web/consumer-hb/src/main/java/com/gyee/consumer/controller/reliability/ReliabilityController.java

@@ -0,0 +1,61 @@
+package com.gyee.consumer.controller.reliability;
+
+
+import com.gyee.common.domain.AjaxResult;
+import com.gyee.consumer.service.reliability.ReliabilityService;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+
+@RestController
+@RequestMapping("/reliability")
+public class ReliabilityController {
+    @Autowired
+    private ReliabilityService reliabilityService;
+
+    /**
+     * 获得风场预警分类信息
+     * @param wpid
+     * @param date
+     * @return
+     */
+    @GetMapping("/earlyWarn")
+    @ResponseBody
+    @ApiOperation(value = "获得风场预警分类信息", notes = "获得风场预警分类信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "wpid", value = "风场编号", required = true, dataType = "string", paramType = "query"),
+            @ApiImplicitParam(name = "date", value = "日期", required = true, dataType = "string", paramType = "query")
+    })
+
+    public AjaxResult earlyWarn(@RequestParam("wpid") String wpid, @RequestParam("date") String date)  {
+
+        AjaxResult ajax=reliabilityService.earlyWarn( wpid,date);
+
+        return ajax;
+    }
+    /**
+     * 故障统计
+     * @param wpid
+     * @param date
+     * @return
+     */
+    @GetMapping("/failurestatistics")
+    @ResponseBody
+    @ApiOperation(value = "获得风场故障分类信息", notes = "获得风场故障分类信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "wpid", value = "风场编号", required = true, dataType = "string", paramType = "query"),
+            @ApiImplicitParam(name = "date", value = "日期", required = true, dataType = "string", paramType = "query")
+    })
+
+    public AjaxResult failurestatistics(@RequestParam("wpid") String wpid, @RequestParam("date") String date)  {
+
+        AjaxResult ajax=reliabilityService.failurestatistics( wpid,date);
+
+        return ajax;
+    }
+
+
+}

web/consumer-hb/src/main/java/com/gyee/consumer/fallback/reliability/ReliabilityServiceFallbackFactory.java

@@ -0,0 +1,30 @@
+package com.gyee.consumer.fallback.reliability;
+
+import com.gyee.common.domain.AjaxResult;
+import com.gyee.consumer.service.reliability.ReliabilityService;
+import feign.hystrix.FallbackFactory;
+import org.springframework.web.bind.annotation.RequestParam;
+
+public class ReliabilityServiceFallbackFactory implements FallbackFactory<ReliabilityService> {
+
+    @Override
+    public ReliabilityService create(Throwable throwable) {
+        return new ReliabilityService() {
+
+
+            @Override
+            public AjaxResult earlyWarn(@RequestParam("wpid") String wpid, @RequestParam("date") String date)
+            {
+                return  AjaxResult.error(throwable.getMessage());
+            }
+
+            @Override
+            public AjaxResult failurestatistics(@RequestParam("wpid") String wpid, @RequestParam("date") String date){
+                return  AjaxResult.error(throwable.getMessage());
+            }
+
+
+
+        };
+    }
+}

web/consumer-hb/src/main/java/com/gyee/consumer/service/reliability/ReliabilityService.java

@@ -0,0 +1,23 @@
+package com.gyee.consumer.service.reliability;
+
+
+import com.gyee.common.domain.AjaxResult;
+import com.gyee.consumer.config.FeignConfiguration;
+import com.gyee.consumer.fallback.reliability.ReliabilityServiceFallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(name = "reliability",url = "${provider.healthurl}",
+        fallbackFactory = ReliabilityServiceFallbackFactory.class,
+        configuration = FeignConfiguration.class)
+public interface ReliabilityService {
+
+
+    @GetMapping("/reliability/earlyWarn")
+    public AjaxResult earlyWarn(@RequestParam("wpid") String wpid, @RequestParam("date") String date) ;
+
+
+    @GetMapping("/reliability/failurestatistics")
+    public AjaxResult failurestatistics(@RequestParam("wpid") String wpid, @RequestParam("date") String date);
+ }