增加状态点计算

cache/src/main/java/com/gyee/cache/init/CacheContext.java

@@ -336,28 +336,28 @@ public class CacheContext implements CommandLineRunner {
             redisService.set(i,s);
         });
 
-        logger.info("--------------------------redis五种状态");
-        Map<String,Map<String,List<Windturbinetestingpointdis>>> wzztMap = new HashMap<>();
-        List<Windturbinetestingpointdis> windturbinetestingpointdis = windturbinetestingpointdisService.list();
-        windturbinetestingpointdis.stream().forEach(w->{
-            if (wzztMap.containsKey(w.getWindturbineid())){
-                Map<String, List<Windturbinetestingpointdis>> stringListMap = wzztMap.get(w.getWindturbineid());
-                if (stringListMap.containsKey(w.getUniformcode())){
-                    stringListMap.get(w.getUniformcode()).add(w);
-                }else {
-                    List<Windturbinetestingpointdis> wdisList = new ArrayList<>();
-                    wdisList.add(w);
-                    stringListMap.put(w.getUniformcode(),wdisList);
-                }
-            }else {
-                Map<String,List<Windturbinetestingpointdis>> map = new HashMap<>();
-                List<Windturbinetestingpointdis> wdisList = new ArrayList<>();
-                wdisList.add(w);
-                map.put(w.getUniformcode(),wdisList);
-                wzztMap.put(w.getWindturbineid(),map);
-            }
-        });
-        redisService.set("WZZT",JSONObject.toJSONString(wzztMap));
+//        logger.info("--------------------------redis五种状态");
+//        Map<String,Map<String,List<Windturbinetestingpointdis>>> wzztMap = new HashMap<>();
+//        List<Windturbinetestingpointdis> windturbinetestingpointdis = windturbinetestingpointdisService.list();
+//        windturbinetestingpointdis.stream().forEach(w->{
+//            if (wzztMap.containsKey(w.getWindturbineid())){
+//                Map<String, List<Windturbinetestingpointdis>> stringListMap = wzztMap.get(w.getWindturbineid());
+//                if (stringListMap.containsKey(w.getUniformcode())){
+//                    stringListMap.get(w.getUniformcode()).add(w);
+//                }else {
+//                    List<Windturbinetestingpointdis> wdisList = new ArrayList<>();
+//                    wdisList.add(w);
+//                    stringListMap.put(w.getUniformcode(),wdisList);
+//                }
+//            }else {
+//                Map<String,List<Windturbinetestingpointdis>> map = new HashMap<>();
+//                List<Windturbinetestingpointdis> wdisList = new ArrayList<>();
+//                wdisList.add(w);
+//                map.put(w.getUniformcode(),wdisList);
+//                wzztMap.put(w.getWindturbineid(),map);
+//            }
+//        });
+//        redisService.set("WZZT",JSONObject.toJSONString(wzztMap));
 
         logger.info("--------------------------redis十三种状态");
         Map<String,Map<String,List<Windturbinestatusdi>>> sszztMap = new HashMap<>();
@@ -380,7 +380,7 @@ public class CacheContext implements CommandLineRunner {
                 sszztMap.put(w.getWindturbineid(),map);
             }
         });
-        redisService.set("SSZZT",JSONObject.toJSONString(wzztMap));
+        redisService.set("SSZZT",JSONObject.toJSONString(sszztMap));
 
     }
 }

common/src/main/java/com/gyee/common/contant/Contant.java

@@ -49,6 +49,21 @@ public class Contant {
     public static String AI022 = "AI022"; //风机实时风速
     public static String AI130 = "AI130"; //风机实时功率
     public static String AI064 = "AI064"; //风机发电量
+    //判断数据中断(风速，功率，绕组温度，电流，电压)
+    public static String INTERRUPTION ="AI022,AI130,AI045,AI058,AI061";
+    //判断状态
+    public static String MX000 = "MX000"; //待机
+    public static String MX002 = "MX002";//运行
+    public static String MX008 = "MX008";//维护
+    public static String MX006 = "MX006";//故障
+    //判断降出力
+    public static String AI134 = "AI134"; //叶轮转速给定
+//    public static String AI129 = "AI129"; //转矩给定
+    public static String AI178 = "AI178";//发电状态下的转速给定
+    public static String AI443 = "AI443";//scada有功设定值
+
+    public static String ZTMX = "ZTMX"; //状态明细
+    public static String FJ5T = "FJ5T"; //五种状态
 
 
 

realtime/generation-service/src/main/java/com/gyee/generation/controller/EquipmentmodelController.java

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

realtime/generation-service/src/main/java/com/gyee/generation/controller/WindturbinestatusdiController.java

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

realtime/generation-service/src/main/java/com/gyee/generation/init/CacheContext.java

@@ -37,6 +37,8 @@ public class CacheContext implements CommandLineRunner {
     @Resource
     private IMeterpointService meterpointService;
     @Resource
+    private IEquipmentmodelService equipmentmodelService;
+    @Resource
     private RedisService redisService;
     @Value("${runWindpowerstation}")
     private String runWindpowerstation;
@@ -54,6 +56,8 @@ public class CacheContext implements CommandLineRunner {
     public static Map<String,Map<String, Windpowerstationpointnew>> propointmap =new HashMap<>();
     public static Map<String,Map<String, Windpowerstationpointnew>> wppointmap =new HashMap<>();
     public static Map<String,Project> proMap = new HashMap<>();
+    public static Map<String,List<Windturbinestatusdi>> statusMap = new HashMap<>();
+    public static Map<String,Equipmentmodel> modelMap = new HashMap<>();
     @Override
     public void run(String... args) throws Exception {
         logger.info("缓存开始------------------------------------------------------------");
@@ -117,6 +121,16 @@ public class CacheContext implements CommandLineRunner {
             wppointmap.put(wp.getId(),stringMapMap);
         });
 
+        String sszzt = redisService.get("SSZZT");
+        Map<String,List<Windturbinestatusdi>> statusMap = JSONObject.parseObject(sszzt, new TypeReference<Map<String,List<Windturbinestatusdi>>>() {
+        });
+
+        List<Equipmentmodel> equipmentmodels = equipmentmodelService.list();
+        equipmentmodels.stream().forEach(e->{
+            modelMap.put(e.getId(),e);
+        });
+
+
 //        String wpString = redisService.get("PRODUCT-WP");
 //        wppointmap = JSONObject.parseObject(wpString, new TypeReference<Map<String, Map<String, Windpowerstationpointnew>>>() {
 //        });

realtime/generation-service/src/main/java/com/gyee/generation/mapper/auto/EquipmentmodelMapper.java

@@ -0,0 +1,16 @@
+package com.gyee.generation.mapper.auto;
+
+import com.gyee.generation.model.auto.Equipmentmodel;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+public interface EquipmentmodelMapper extends BaseMapper<Equipmentmodel> {
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/mapper/auto/WindturbinestatusdiMapper.java

@@ -0,0 +1,16 @@
+package com.gyee.generation.mapper.auto;
+
+import com.gyee.generation.model.auto.Windturbinestatusdi;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+public interface WindturbinestatusdiMapper extends BaseMapper<Windturbinestatusdi> {
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/model/auto/Equipmentmodel.java

@@ -0,0 +1,65 @@
+package com.gyee.generation.model.auto;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("EQUIPMENTMODEL")
+public class Equipmentmodel extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId("ID")
+    private String id;
+
+    @TableField("CODE")
+    private String code;
+
+    @TableField("NAME")
+    private String name;
+
+    @TableField("DESCRIPTION")
+    private String description;
+
+    @TableField("POWERPRODUCTION")
+    private Double powerproduction;
+
+    @TableField("CUTINWINDSPEED")
+    private Double cutinwindspeed;
+
+    @TableField("RATEDWINDSPEED")
+    private Double ratedwindspeed;
+
+    @TableField("CUTOUTWINDSPEED")
+    private String cutoutwindspeed;
+
+    @TableField("WINDTURBINEMANUFACTURERID")
+    private String windturbinemanufacturerid;
+
+    @TableField("PHOTO")
+    private String photo;
+
+    @TableField("UNIT")
+    private String unit;
+
+    @TableField("SWEPTAREA")
+    private Double sweptarea;
+
+    @TableField("EQUIPMENTCATEGORY")
+    private Double equipmentcategory;
+
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/model/auto/Windturbinestatusdi.java

@@ -0,0 +1,80 @@
+package com.gyee.generation.model.auto;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("WINDTURBINESTATUSDI")
+public class Windturbinestatusdi extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId("ID")
+    private String id;
+
+    @TableField("CODE")
+    private String code;
+
+    @TableField("NAME")
+    private String name;
+
+    @TableField("MODEL")
+    private String model;
+
+    @TableField("VALUEUNIT")
+    private String valueunit;
+
+    @TableField("ENGLISHNAME")
+    private String englishname;
+
+    @TableField("TYPEID")
+    private String typeid;
+
+    @TableField("MODELID")
+    private String modelid;
+
+    @TableField("MAXVAL")
+    private Double maxval;
+
+    @TableField("MINVAL")
+    private Double minval;
+
+    @TableField("REASONABLEMAXVAL")
+    private Double reasonablemaxval;
+
+    @TableField("REASONABLEMINVAL")
+    private Double reasonableminval;
+
+    @TableField("WINDTURBINEID")
+    private String windturbineid;
+
+    @TableField("UNIFORMCODE")
+    private String uniformcode;
+
+    @TableField("SHORTID")
+    private String shortid;
+
+    @TableField("LONGID")
+    private String longid;
+
+    @TableField("WINDPOWERSTATIONID")
+    private String windpowerstationid;
+
+    @TableField("REALTIMEID")
+    private String realtimeid;
+
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/service/StatusService.java

@@ -0,0 +1,162 @@
+package com.gyee.generation.service;
+
+import com.gyee.benchmarkinghistroy.util.realtimesource.IEdosUtil;
+import com.gyee.common.contant.Contant;
+import com.gyee.common.model.PointData;
+import com.gyee.common.model.StringUtils;
+import com.gyee.common.util.DateUtils;
+import com.gyee.generation.init.CacheContext;
+import com.gyee.generation.model.auto.*;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * @ClassName : StatusService
+ * @Author : xieshengjie
+ * @Date: 2022/3/28 14:22
+ * @Description : 状态计算
+ */
+@Service
+public class StatusService {
+
+    private Map<String, List<Windturbinestatusdi>> statusMap;
+    private List<Windturbine> wtls;
+    private Map<String, Map<String, Windturbinetestingpointnew>> wtpAimap;
+    private Date currentDate;
+    private List<Windpowerstation> wpls;
+    private Map<String, Equipmentmodel> modelMap;
+    @Resource
+    private IEdosUtil edosUtil;
+    @Value("${clauStatus.ai}")
+    private String clauStatusAi;
+    @Value("${clauStatus.di}")
+    private String clauStatusDi;
+    @Value("${second}")
+    private String second;
+    @Value("${AI134}")
+    private String AI134;
+    @Value("${AI178}")
+    private String AI178;
+
+
+    public void init(){
+        statusMap = CacheContext.statusMap;
+        wtls = CacheContext.wtls;
+        wpls = CacheContext.wpls;
+        wtpAimap = CacheContext.wtpAimap;
+        currentDate = DateUtils.getCurrentDate();
+        modelMap = CacheContext.modelMap;
+    }
+    public void calculateStatus() throws Exception {
+        init();
+        List<PointData> resultList = new ArrayList<>();
+        wpls.stream().forEach(wp->{
+            wtls.stream().filter(i->i.getWindpowerstationid().equals(wp.getId())).forEach(wt->{
+                Map<String, Windturbinetestingpointnew> stringWindturbinetestingpointnewMap = wtpAimap.get(wt.getId());
+                Windturbinetestingpointnew ztmxPoint = stringWindturbinetestingpointnewMap.get(Contant.ZTMX);
+                Windturbinetestingpointnew fj5tPoint = stringWindturbinetestingpointnewMap.get(Contant.FJ5T);
+                String[] interruption = Contant.INTERRUPTION.split(",");
+                List<String> interruptionList = new ArrayList<>();
+                Arrays.stream(interruption).forEach(i->{
+                    Windturbinetestingpointnew windturbinetestingpointnew = stringWindturbinetestingpointnewMap.get(i);
+                    if (!windturbinetestingpointnew.getCode().equals("INITIAL")){
+                        interruptionList.add(windturbinetestingpointnew.getCode());
+                    }
+                });
+                Integer status = 2;
+                Integer mxstatus = 2;
+                try {
+                    List<PointData> interruptionRealData = edosUtil.getRealData(interruptionList);
+                    List<PointData> collect = interruptionRealData.stream().filter(i -> Math.abs(currentDate.getTime() - i.getPointTime()) / 1000 < Integer.parseInt(second)).collect(Collectors.toList());
+                    if (StringUtils.isEmpty(collect)){
+                        Integer ztmx = Integer.parseInt(edosUtil.getRealData(ztmxPoint).getPointValue());
+                        if (ztmx == 7 || ztmx == 9 || ztmx == 10 || ztmx == 11 ){
+                            mxstatus = ztmx;
+                        }
+                        if (clauStatusAi.contains(wt.getWindpowerstationid())){
+                            //多状态根据一个点来判断
+
+                        }
+                        if (clauStatusDi.contains(wt.getWindpowerstationid())){
+                            //每个状态一个状态点
+                            List<Windturbinestatusdi> windturbinestatusdis = statusMap.get(wt.getId()).stream().filter(w -> w.getUniformcode().equals(Contant.MX000) || w.getUniformcode().equals(Contant.MX002) || w.getUniformcode().equals(Contant.MX006) || w.getUniformcode().equals(Contant.MX008)).collect(Collectors.toList());
+                            for(Windturbinestatusdi w : windturbinestatusdis){
+                                PointData realData = edosUtil.getRealData(w.getId());
+                                if (realData.getPointValueInDouble()==1){
+                                    mxstatus = Integer.parseInt(w.getTypeid());
+                                    break;
+                                }
+                            }
+                            if (mxstatus == 2){
+                                boolean isJcl = false;
+                                Windturbinetestingpointnew ai134point = stringWindturbinetestingpointnewMap.get(Contant.AI134);
+                                Windturbinetestingpointnew ai178point = stringWindturbinetestingpointnewMap.get(Contant.AI178);
+                                Windturbinetestingpointnew ai443point = stringWindturbinetestingpointnewMap.get(Contant.AI443);
+                                if (!ai134point.getCode().equals("INITIAL")){
+                                    Double realData = edosUtil.getRealData(ai134point).getPointValueInDouble();
+                                    if (realData<Double.parseDouble(AI134)){
+                                        isJcl = true;
+                                    }
+                                }
+                                if (!ai178point.getCode().equals("INITIAL")){
+                                    Double realData = edosUtil.getRealData(ai178point).getPointValueInDouble();
+                                    if (realData<Double.parseDouble(AI178)){
+                                        isJcl = true;
+                                    }
+                                }
+                                if (!ai443point.getCode().equals("INITIAL")){
+                                    Double realData = edosUtil.getRealData(ai443point).getPointValueInDouble();
+                                    if (realData<modelMap.get(wt.getModelid()).getPowerproduction()){
+                                        isJcl = true;
+                                    }
+                                }
+                                if (isJcl){
+                                    mxstatus = 3;
+                                }
+                            }
+                        }
+                    }else{
+                        //离线
+                        mxstatus = 12;
+                    }
+                    if (mxstatus == 0 || mxstatus == 1){
+                        status = 0;
+                    }else if(mxstatus == 2 || mxstatus == 3){
+                        status = 1;
+                    }else if(mxstatus == 4 || mxstatus == 5){
+                        status = 5;
+                    }else if(mxstatus == 6 || mxstatus == 7){
+                        status = 2;
+                    }else if(mxstatus == 8 || mxstatus == 9){
+                        status = 4;
+                    }else if(mxstatus == 10 || mxstatus == 11){
+                        status = 2;
+                    }else if(mxstatus == 12){
+                        status = 6;
+                    }
+                    PointData ztmx = createPointData(ztmxPoint, mxstatus);
+                    PointData fj5t = createPointData(fj5tPoint, status);
+                    resultList.add(ztmx);
+                    resultList.add(fj5t);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            });
+        });
+        edosUtil.sendMultiPoint(resultList);
+    }
+
+    private PointData createPointData(Windturbinetestingpointnew ztmxPoint, Integer mxstatus) {
+        PointData pointData = new PointData();
+        pointData.setEdnaId(ztmxPoint.getCode());
+        pointData.setPointName(ztmxPoint.getName());
+        pointData.setPointTime(currentDate.getTime());
+        pointData.setPointValue(String.valueOf(mxstatus));
+        pointData.setPointValueInDouble(mxstatus);
+        return pointData;
+    }
+}

realtime/generation-service/src/main/java/com/gyee/generation/service/auto/IEquipmentmodelService.java

@@ -0,0 +1,16 @@
+package com.gyee.generation.service.auto;
+
+import com.gyee.generation.model.auto.Equipmentmodel;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+public interface IEquipmentmodelService extends IService<Equipmentmodel> {
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/service/auto/IWindturbinestatusdiService.java

@@ -0,0 +1,16 @@
+package com.gyee.generation.service.auto;
+
+import com.gyee.generation.model.auto.Windturbinestatusdi;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+public interface IWindturbinestatusdiService extends IService<Windturbinestatusdi> {
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/service/auto/impl/EquipmentmodelServiceImpl.java

@@ -0,0 +1,20 @@
+package com.gyee.generation.service.auto.impl;
+
+import com.gyee.generation.model.auto.Equipmentmodel;
+import com.gyee.generation.mapper.auto.EquipmentmodelMapper;
+import com.gyee.generation.service.auto.IEquipmentmodelService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+@Service
+public class EquipmentmodelServiceImpl extends ServiceImpl<EquipmentmodelMapper, Equipmentmodel> implements IEquipmentmodelService {
+
+}

realtime/generation-service/src/main/java/com/gyee/generation/service/auto/impl/WindturbinestatusdiServiceImpl.java

@@ -0,0 +1,20 @@
+package com.gyee.generation.service.auto.impl;
+
+import com.gyee.generation.model.auto.Windturbinestatusdi;
+import com.gyee.generation.mapper.auto.WindturbinestatusdiMapper;
+import com.gyee.generation.service.auto.IWindturbinestatusdiService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 谢生杰
+ * @since 2022-03-28
+ */
+@Service
+public class WindturbinestatusdiServiceImpl extends ServiceImpl<WindturbinestatusdiMapper, Windturbinestatusdi> implements IWindturbinestatusdiService {
+
+}

realtime/generation-service/src/main/resources/application-td.yml

@@ -82,11 +82,23 @@ logging:
   level:
     root: info
     com.example: debug
-
+#db url
 db:
   url: http://10.83.68.159:8011/ts
-
+#参与计算的场站
 runWindpowerstation: CL_FDC,KB_FDC,DX_FDC,SY_FDC
+#计算状态用ai或者di
+clauStatus:
+  ai: CL_FDC,KB_FDC,DX_FDC,SY_FDC
+  di:
+
+#判断数据终端
+second: 90
+#判断降出力
+AI134: 17.4
+AI178: 17.4
+#AI443:容量
+