|
|
@@ -238,19 +238,197 @@ public class StatusService {
|
|
|
*/
|
|
|
private boolean isJcl(Date currentDate, Map<String, ProBasicEquipmentPoint> stringWindturbinetestingpointnewMap) throws Exception {
|
|
|
boolean isJcl = false;
|
|
|
- ProBasicEquipmentPoint zsgdPoint = stringWindturbinetestingpointnewMap.get(ContantXk.CJ_YLZSGD);
|
|
|
- if (zsgdPoint != null){
|
|
|
- if (!zsgdPoint.getNemCode().equals("INITIAL")){
|
|
|
- Double realData = edosUtil.getSectionData(zsgdPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
- if (realData<Double.parseDouble(AI110)){
|
|
|
- isJcl = true;
|
|
|
+
|
|
|
+ if(stringWindturbinetestingpointnewMap.containsKey(ContantXk.CJ_YLZSGD))
|
|
|
+ {
|
|
|
+ ProBasicEquipmentPoint zsgdPoint = stringWindturbinetestingpointnewMap.get(ContantXk.CJ_YLZSGD);
|
|
|
+ if (zsgdPoint != null){
|
|
|
+ if (!zsgdPoint.getNemCode().equals("INITIAL")){
|
|
|
+ Double realData = edosUtil.getSectionData(zsgdPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
+ if (realData<Double.parseDouble(AI110)){
|
|
|
+ isJcl = true;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+
|
|
|
return isJcl;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 计算风机中间状态(0 正常，1离线，2降出力，3限电)
|
|
|
+ */
|
|
|
+ public void middleStatusReal() throws Exception {
|
|
|
+
|
|
|
+ Map<String, Map<String, ProBasicEquipmentPoint>> wtpAimap = CacheContext.wtpAimap;
|
|
|
+ List<ProBasicEquipment> wtls = CacheContext.wtls;
|
|
|
+ Map<String, List<ProBasicStatusPoint>> statusMap = CacheContext.statusMap;
|
|
|
+ Map<String, ProEconEquipmentmodel> modelMap = CacheContext.modelMap;
|
|
|
+ Map<String, Map<Integer, Integer>> aistateMap = CacheContext.aistateMap;
|
|
|
+ Date currentDate = DateUtils.getCurrentDate();
|
|
|
+
|
|
|
+ List<PointData> resultList = new ArrayList<>();
|
|
|
+
|
|
|
+
|
|
|
+ for(ProBasicEquipment wt:wtls) {
|
|
|
+
|
|
|
+ //获得设备测点
|
|
|
+ Map<String, ProBasicEquipmentPoint> equipmentPointMap = wtpAimap.get(wt.getId());
|
|
|
+
|
|
|
+ //中间状态点
|
|
|
+ ProBasicEquipmentPoint zjztPoint = equipmentPointMap.get(ContantXk.ZJZT);
|
|
|
+ //遍历中断判定点
|
|
|
+ String[] interruption = null;
|
|
|
+ if (wt.getEquipmentCategory() == -1) {
|
|
|
+ interruption = ContantXk.INTERRUPTION.split(",");
|
|
|
+ } else if (wt.getEquipmentCategory() == -2) {
|
|
|
+
|
|
|
+ interruption = ContantXk.INTERRUPTIONGF.split(",");
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> interruptionList = new ArrayList<>();
|
|
|
+ Arrays.stream(interruption).forEach(i -> {
|
|
|
+ ProBasicEquipmentPoint equipmentPoint = equipmentPointMap.get(i);
|
|
|
+ if (!equipmentPoint.getNemCode().equals("INITIAL")) {
|
|
|
+ interruptionList.add(equipmentPoint.getNemCode());
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ //初始化状态
|
|
|
+ Double status = 0.0;
|
|
|
+
|
|
|
+ try {
|
|
|
+ //如果没有配置中断诊断点，判定为中断状态
|
|
|
+ if (StringUtils.isEmpty(interruptionList)) {
|
|
|
+ status = 1.0;
|
|
|
+ } else {
|
|
|
+ //读取中断测点数据
|
|
|
+ List<PointData> interruptionRealData = edosUtil.getRealData(interruptionList);
|
|
|
+ Calendar c = Calendar.getInstance();
|
|
|
+ c.setTime(currentDate);
|
|
|
+
|
|
|
+ int state = 0;
|
|
|
+ for (int i = 0; i < interruptionList.size(); i++) {
|
|
|
+ String str = interruptionList.get(i);
|
|
|
+ c.add(Calendar.MINUTE, -10);
|
|
|
+ long oldtime = c.getTime().getTime() / 1000;
|
|
|
+
|
|
|
+// List<PointData> ls= edosUtil.getHistoryDatasSnap(str,c.getTime().getTime()/1000,currentDate.getTime()/1000,null,60l);
|
|
|
+//
|
|
|
+// for(PointData po:ls)
|
|
|
+// {
|
|
|
+// if (po.getPointValueInDouble() != interruptionRealData.get(i).getPointValueInDouble()) {
|
|
|
+// state++;
|
|
|
+// }
|
|
|
+// }
|
|
|
+ //读取三分钟前的切面值进行对比，如果数据一致判定通信中断
|
|
|
+ PointData oldValue = edosUtil.getHistMatrix(str, oldtime);
|
|
|
+ if (oldValue.getPointValueInDouble() == interruptionRealData.get(i).getPointValueInDouble()) {
|
|
|
+ state++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //判定是否所有中断盘点点的取值时间，距离当前时间相差大于指定值，就统计到新的集合里，如果结果集数量等于中断点数量，说明设备通信中断
|
|
|
+ List<PointData> collect = interruptionRealData.stream().filter(i -> (currentDate.getTime() - i.getPointTime()) / 1000 > Integer.parseInt(second)).collect(Collectors.toList());
|
|
|
+
|
|
|
+ if (state == 3 || collect.size() == interruptionRealData.size()) {
|
|
|
+ //离线
|
|
|
+ status = 1.0;
|
|
|
+ }else
|
|
|
+ {
|
|
|
+ //进行其它状态判断
|
|
|
+ status = getStatus(modelMap, aistateMap, statusMap, wt);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ //统计所有记录，准备同时批量写入数据
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate, status, zjztPoint.getNemCode(), zjztPoint.getName()));
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+// });
|
|
|
+ }
|
|
|
+ edosUtil.sendMultiPoint(resultList);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断中间状态
|
|
|
+ * @param modelMap 型号集合
|
|
|
+ * @param aistateMap ai测点集合
|
|
|
+ * @param statusMap di测点集合
|
|
|
+ * @param wt 设备对象
|
|
|
+ * @return
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ private double getStatus(Map<String, ProEconEquipmentmodel> modelMap,Map<String, Map<Integer, Integer>> aistateMap,Map<String, List<ProBasicStatusPoint>> statusMap,ProBasicEquipment wt) throws Exception {
|
|
|
+
|
|
|
+ double status = 0;
|
|
|
+
|
|
|
+ String aiordi = modelMap.get(wt.getModelId()).getDescription();
|
|
|
+ if (aiordi.equals("AI")) {
|
|
|
+ Map<Integer, Integer> stateMap = aistateMap.get(wt.getModelId());
|
|
|
+ Optional<ProBasicStatusPoint> first = statusMap.get(wt.getId()).stream().filter(w -> w.getUniformCode().equals(Contant.AI422)).findFirst();
|
|
|
+ if (first.isPresent()) {
|
|
|
+ ProBasicStatusPoint windturbinestatusdi = first.get();
|
|
|
+ int pointValueInDouble = (int) edosUtil.getRealData(windturbinestatusdi.getNemCode()).getPointValueInDouble();
|
|
|
+
|
|
|
+ if (stateMap.containsKey(pointValueInDouble)) {
|
|
|
+ status = (double) stateMap.get(pointValueInDouble);
|
|
|
+
|
|
|
+ if(status==3)
|
|
|
+ {
|
|
|
+ status=2;
|
|
|
+ }else if(status==8 || status==9)
|
|
|
+ {
|
|
|
+ status=3;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //每个状态一个状态点
|
|
|
+ Map<String, String> stateMap = new HashMap<>();
|
|
|
+ List<ProBasicStatusPoint> windturbinestatusdis = statusMap.get(wt.getId()).stream().filter(w -> w.getUniformCode().equals(Contant.MX000) || w.getUniformCode().equals(Contant.MX002) || w.getUniformCode().equals(Contant.MX003) || w.getUniformCode().equals(Contant.MX006) || w.getUniformCode().equals(Contant.MX008)).collect(Collectors.toList());
|
|
|
+
|
|
|
+ List<String> pointls=new ArrayList<>();
|
|
|
+ for (ProBasicStatusPoint w : windturbinestatusdis) {
|
|
|
+ pointls.add(w.getNemCode());
|
|
|
+ }
|
|
|
+ List<PointData> values= edosUtil.getRealData(pointls);
|
|
|
+
|
|
|
+ if(values.size()==windturbinestatusdis.size())
|
|
|
+ {
|
|
|
+ for (int i=0;i< windturbinestatusdis.size();i++) {
|
|
|
+ ProBasicStatusPoint w=windturbinestatusdis.get(i);
|
|
|
+ if (values.get(i).getPointValueInDouble() == 1) {
|
|
|
+ stateMap.put(w.getUniformCode(), w.getTypeId());
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ {
|
|
|
+ for (ProBasicStatusPoint w : windturbinestatusdis) {
|
|
|
+ PointData realData = edosUtil.getRealData(w.getNemCode());
|
|
|
+ if (realData.getPointValueInDouble() == 1) {
|
|
|
+ stateMap.put(w.getUniformCode(), w.getTypeId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (stateMap.containsKey("MX002") && stateMap.containsKey("MX003")) {
|
|
|
+ status = 2;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (stateMap.containsKey("MX005")) {
|
|
|
+ status = 3;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return status;
|
|
|
+ }
|
|
|
/**
|
|
|
* 计算风机状态
|
|
|
*/
|
|
|
@@ -264,14 +442,17 @@ public class StatusService {
|
|
|
|
|
|
List<PointData> resultList = new ArrayList<>();
|
|
|
|
|
|
- wtls.stream().forEach(wt->{
|
|
|
+ int times=0;
|
|
|
+
|
|
|
+ List<String> pointls=new ArrayList<>();
|
|
|
+
|
|
|
+ List<PointData> pointDatals = new ArrayList<>();
|
|
|
+ for(ProBasicEquipment wt:wtls) {
|
|
|
Map<String, ProBasicEquipmentPoint> equipmentPointMap = wtpAimap.get(wt.getId());
|
|
|
- //限电状态点
|
|
|
- ProBasicEquipmentPoint xdztPoint = equipmentPointMap.get(ContantXk.XDZT);
|
|
|
+ //中间状态点
|
|
|
+ ProBasicEquipmentPoint zjztPoint = equipmentPointMap.get(ContantXk.ZJZT);
|
|
|
//挂牌状态点
|
|
|
ProBasicEquipmentPoint gpztPoint = equipmentPointMap.get(ContantXk.GPZT);
|
|
|
- //设备状态点
|
|
|
- ProBasicEquipmentPoint sbztPoint = equipmentPointMap.get(ContantXk.SBZT);
|
|
|
//明细状态点
|
|
|
ProBasicEquipmentPoint mxztPoint = equipmentPointMap.get(ContantXk.MXZT);
|
|
|
//实时功率点
|
|
|
@@ -279,26 +460,63 @@ public class StatusService {
|
|
|
//状态持续时间，以秒计算
|
|
|
ProBasicEquipmentPoint ztcxsjPoint = equipmentPointMap.get(ContantXk.ZTCXSJ);
|
|
|
|
|
|
+ pointls.add(zjztPoint.getNemCode());
|
|
|
+ pointls.add(gpztPoint.getNemCode());
|
|
|
+
|
|
|
+ pointls.add(mxztPoint.getNemCode());
|
|
|
+ pointls.add(ssglPoint.getNemCode());
|
|
|
+ pointls.add(ztcxsjPoint.getNemCode());
|
|
|
+
|
|
|
+ times++;
|
|
|
+ if(times==1000)
|
|
|
+ {
|
|
|
+ List<PointData> templs=edosUtil.getRealData(pointls);
|
|
|
+ pointDatals.addAll(templs);
|
|
|
+ pointls=new ArrayList<>();
|
|
|
+ times=0;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(!pointls.isEmpty())
|
|
|
+ {
|
|
|
+ List<PointData> templs=edosUtil.getRealData(pointls);
|
|
|
+ pointDatals.addAll(templs);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ for(int x=0;x<wtls.size();x++) {
|
|
|
+ ProBasicEquipment wt=wtls.get(x);
|
|
|
+ Map<String, ProBasicEquipmentPoint> equipmentPointMap = wtpAimap.get(wt.getId());
|
|
|
+
|
|
|
+ //设备状态点
|
|
|
+ ProBasicEquipmentPoint sbztPoint = equipmentPointMap.get(ContantXk.SBZT);
|
|
|
+ //明细状态点
|
|
|
+ ProBasicEquipmentPoint mxztPoint = equipmentPointMap.get(ContantXk.MXZT);
|
|
|
+ //状态持续时间，以秒计算
|
|
|
+ ProBasicEquipmentPoint ztcxsjPoint = equipmentPointMap.get(ContantXk.ZTCXSJ);
|
|
|
+
|
|
|
String[] interruption = null;
|
|
|
- if (wt.getEquipmentCategory()==-1){
|
|
|
+ if (wt.getEquipmentCategory() == -1) {
|
|
|
interruption = ContantXk.INTERRUPTION.split(",");
|
|
|
- }else if (wt.getEquipmentCategory()==-2){
|
|
|
+ } else if (wt.getEquipmentCategory() == -2) {
|
|
|
|
|
|
interruption = ContantXk.INTERRUPTIONGF.split(",");
|
|
|
}
|
|
|
|
|
|
List<String> interruptionList = new ArrayList<>();
|
|
|
- Arrays.stream(interruption).forEach(i->{
|
|
|
+ Arrays.stream(interruption).forEach(i -> {
|
|
|
ProBasicEquipmentPoint equipmentPoint = equipmentPointMap.get(i);
|
|
|
- if (!equipmentPoint.getNemCode().equals("INITIAL")){
|
|
|
+ if (!equipmentPoint.getNemCode().equals("INITIAL")) {
|
|
|
interruptionList.add(equipmentPoint.getNemCode());
|
|
|
}
|
|
|
});
|
|
|
double mxzt = 0;
|
|
|
double ztcxsj = 0;
|
|
|
try {
|
|
|
- mxzt = edosUtil.getSectionData(mxztPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
- ztcxsj = edosUtil.getSectionData(ztcxsjPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
+ mxzt = pointDatals.get(x*5+2).getPointValueInDouble();
|
|
|
+ ztcxsj =pointDatals.get(x*5+4).getPointValueInDouble();
|
|
|
+
|
|
|
+// mxzt = edosUtil.getSectionData(mxztPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
+// ztcxsj = edosUtil.getSectionData(ztcxsjPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
@@ -306,120 +524,66 @@ public class StatusService {
|
|
|
Double status = 0.0;
|
|
|
Double mxstatus = 2.0;
|
|
|
try {
|
|
|
- if (StringUtils.isEmpty(interruptionList)){
|
|
|
+ if (StringUtils.isEmpty(interruptionList)) {
|
|
|
mxstatus = 12.0;
|
|
|
status = 6.0;
|
|
|
- }
|
|
|
- else {
|
|
|
+ } else {
|
|
|
|
|
|
|
|
|
- List<PointData> interruptionRealData = edosUtil.getRealData(interruptionList);
|
|
|
- Calendar c=Calendar.getInstance();
|
|
|
+ Calendar c = Calendar.getInstance();
|
|
|
c.setTime(currentDate);
|
|
|
- c.add(Calendar.MINUTE,-3);
|
|
|
- long oldtime =c.getTime().getTime()/1000 ;
|
|
|
- if(wt.getId().equals("SXJ_KGDL_HSM_F_WT_0047_EQ"))
|
|
|
- {
|
|
|
- System.out.println("");
|
|
|
- }
|
|
|
- int state=0;
|
|
|
- for(int i=0;i<interruptionList.size();i++)
|
|
|
- {
|
|
|
- String str=interruptionList.get(i);
|
|
|
- List<PointData> oldValueLs = edosUtil.getHistoryDatasSnap(str,c.getTime().getTime()/1000,currentDate.getTime()/1000,null,30l);
|
|
|
- if(!oldValueLs.isEmpty())
|
|
|
- {
|
|
|
- for(PointData oldValue:oldValueLs)
|
|
|
- {
|
|
|
- if(oldValue.getPointValueInDouble()!=interruptionRealData.get(i).getPointValueInDouble())
|
|
|
- {
|
|
|
- state++;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
- List<PointData> collect = interruptionRealData.stream().filter(i -> (currentDate.getTime() - i.getPointTime()) / 1000 > Integer.parseInt(second)).collect(Collectors.toList());
|
|
|
+//
|
|
|
+// if (wt.getId().equals("SXJ_KGDL_BHB_F_WT_0032_EQ")) {
|
|
|
+// System.out.println("");
|
|
|
+// }
|
|
|
|
|
|
|
|
|
- double ssgl = edosUtil.getSectionData(ssglPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
- double gpzt = edosUtil.getSectionData(gpztPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
- double xdzt = edosUtil.getSectionData(xdztPoint,currentDate.getTime()).getPointValueInDouble();
|
|
|
+ double ssgl = pointDatals.get(x*5+3).getPointValueInDouble();
|
|
|
+ double gpzt = pointDatals.get(x*5+1).getPointValueInDouble();
|
|
|
+ double zjzt = pointDatals.get(x*5).getPointValueInDouble();
|
|
|
+// double ssgl = edosUtil.getSectionData(ssglPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
+// double gpzt = edosUtil.getSectionData(gpztPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
+// double xdzt = edosUtil.getSectionData(xdztPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
|
|
|
- if(state==0 || collect.size()==interruptionRealData.size())
|
|
|
- {
|
|
|
- //离线
|
|
|
+ if (zjzt == 1) {
|
|
|
mxstatus = 12.0;
|
|
|
- }else {
|
|
|
- if (xdzt == 1){
|
|
|
- mxstatus = getGpzt(1,ssgl);
|
|
|
- }else {
|
|
|
- mxstatus = getMxzt(modelMap,aistateMap,statusMap,wt);
|
|
|
- }
|
|
|
- if (mxstatus == 2){
|
|
|
- boolean isJcl = isJcl(currentDate, equipmentPointMap);
|
|
|
- if (ssgl<=0){
|
|
|
- mxstatus=0.0;
|
|
|
- }else if (isJcl){
|
|
|
- mxstatus = 3.0;
|
|
|
- }
|
|
|
- }
|
|
|
+ }else if (zjzt == 3) {
|
|
|
+ mxstatus = getGpzt(gpzt, ssgl);
|
|
|
+ } else {
|
|
|
+ mxstatus = getMxzt(zjzt,modelMap, aistateMap, statusMap, wt);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
- if (collect.size()==interruptionRealData.size()){
|
|
|
-
|
|
|
- // 0, "正常状态";1, "限电";2, "场内受累检修";3, "场内受累故障";4, "场外受累电网";5, "场外受累天气";6, "发电限负荷";
|
|
|
- if(gpzt != 0){
|
|
|
- //获取挂牌状态给明细状态赋值
|
|
|
- mxstatus = getGpzt(gpzt,ssgl);
|
|
|
- }
|
|
|
-// else if (xdzt == 1){
|
|
|
-// mxstatus = getGpzt(1,ssgl);
|
|
|
-// }else {
|
|
|
-// mxstatus = getMxzt(modelMap,aistateMap,statusMap,wt);
|
|
|
-// }
|
|
|
-// if (mxstatus == 2){
|
|
|
-// boolean isJcl = isJcl(currentDate, equipmentPointMap);
|
|
|
-// if (ssgl<=0){
|
|
|
-// mxstatus=0.0;
|
|
|
-// }else if (isJcl){
|
|
|
-// mxstatus = 3.0;
|
|
|
-// }
|
|
|
-// }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- if (mxstatus == 0 || mxstatus == 1){
|
|
|
+ if (mxstatus == 0 || mxstatus == 1) {
|
|
|
status = 0.0;
|
|
|
- }else if(mxstatus == 2 || mxstatus == 3){
|
|
|
+ } else if (mxstatus == 2 || mxstatus == 3) {
|
|
|
status = 1.0;
|
|
|
- }else if(mxstatus == 4 || mxstatus == 5){
|
|
|
+ } else if (mxstatus == 4 || mxstatus == 5) {
|
|
|
status = 2.0;
|
|
|
- }else if(mxstatus == 6 || mxstatus == 7){
|
|
|
+ } else if (mxstatus == 6 || mxstatus == 7) {
|
|
|
status = 3.0;
|
|
|
- }else if(mxstatus == 8 || mxstatus == 9){
|
|
|
+ } else if (mxstatus == 8 || mxstatus == 9) {
|
|
|
status = 4.0;
|
|
|
- }else if(mxstatus == 10 || mxstatus == 11){
|
|
|
+ } else if (mxstatus == 10 || mxstatus == 11) {
|
|
|
status = 5.0;
|
|
|
- }else if(mxstatus == 12 || mxstatus == 13){
|
|
|
+ } else if (mxstatus == 12 || mxstatus == 13) {
|
|
|
status = 6.0;
|
|
|
}
|
|
|
}
|
|
|
- if (mxstatus == mxzt){
|
|
|
- ztcxsj ++;
|
|
|
- }else {
|
|
|
+ if (mxstatus == mxzt) {
|
|
|
+ ztcxsj++;
|
|
|
+ } else {
|
|
|
ztcxsj = 0;
|
|
|
}
|
|
|
- resultList.add(PointUtil.createPointData(currentDate,mxstatus,mxztPoint.getNemCode(),mxztPoint.getName()));
|
|
|
- resultList.add(PointUtil.createPointData(currentDate,status,sbztPoint.getNemCode(),sbztPoint.getName()));
|
|
|
- resultList.add(PointUtil.createPointData(currentDate,ztcxsj,ztcxsjPoint.getNemCode(),ztcxsjPoint.getName()));
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate, mxstatus, mxztPoint.getNemCode(), mxztPoint.getName()));
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate, status, sbztPoint.getNemCode(), sbztPoint.getName()));
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate, ztcxsj, ztcxsjPoint.getNemCode(), ztcxsjPoint.getName()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
|
|
|
- });
|
|
|
+// });
|
|
|
+ }
|
|
|
edosUtil.sendMultiPoint(resultList);
|
|
|
}
|
|
|
|
|
|
@@ -895,7 +1059,7 @@ public class StatusService {
|
|
|
edosUtil.sendMultiPoint(resultList);
|
|
|
}
|
|
|
|
|
|
- private double getMxzt(Map<String, ProEconEquipmentmodel> modelMap,Map<String, Map<Integer, Integer>> aistateMap,Map<String, List<ProBasicStatusPoint>> statusMap,ProBasicEquipment wt) throws Exception {
|
|
|
+ private double getMxzt(double zjzt,Map<String, ProEconEquipmentmodel> modelMap,Map<String, Map<Integer, Integer>> aistateMap,Map<String, List<ProBasicStatusPoint>> statusMap,ProBasicEquipment wt) throws Exception {
|
|
|
|
|
|
double mxstatus = 2;
|
|
|
|
|
|
@@ -917,19 +1081,50 @@ public class StatusService {
|
|
|
//每个状态一个状态点
|
|
|
Map<String,String> stateMap = new HashMap<>();
|
|
|
List<ProBasicStatusPoint> windturbinestatusdis = statusMap.get(wt.getId()).stream().filter(w -> w.getUniformCode().equals(Contant.MX000) || w.getUniformCode().equals(Contant.MX002) || w.getUniformCode().equals(Contant.MX003) || w.getUniformCode().equals(Contant.MX006) || w.getUniformCode().equals(Contant.MX008)).collect(Collectors.toList());
|
|
|
- for(ProBasicStatusPoint w : windturbinestatusdis){
|
|
|
- PointData realData = edosUtil.getRealData(w.getNemCode());
|
|
|
- if (realData.getPointValueInDouble()==1){
|
|
|
- stateMap.put(w.getUniformCode(),w.getTypeId());
|
|
|
- mxstatus = Double.parseDouble(w.getTypeId());
|
|
|
+
|
|
|
+
|
|
|
+ List<String> pointls=new ArrayList<>();
|
|
|
+ for (ProBasicStatusPoint w : windturbinestatusdis) {
|
|
|
+ pointls.add(w.getNemCode());
|
|
|
+ }
|
|
|
+ List<PointData> values= edosUtil.getRealData(pointls);
|
|
|
+
|
|
|
+
|
|
|
+ if(values.size()==windturbinestatusdis.size())
|
|
|
+ {
|
|
|
+ for (int i=0;i< windturbinestatusdis.size();i++) {
|
|
|
+ ProBasicStatusPoint w=windturbinestatusdis.get(i);
|
|
|
+ if (values.get(i).getPointValueInDouble() == 1) {
|
|
|
+ stateMap.put(w.getUniformCode(), w.getTypeId());
|
|
|
+ mxstatus = Double.parseDouble(w.getTypeId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ {
|
|
|
+ for (ProBasicStatusPoint w : windturbinestatusdis) {
|
|
|
+ PointData realData = edosUtil.getRealData(w.getNemCode());
|
|
|
+ if (realData.getPointValueInDouble() == 1) {
|
|
|
+ stateMap.put(w.getUniformCode(), w.getTypeId());
|
|
|
+ mxstatus = Double.parseDouble(w.getTypeId());
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
if (stateMap.containsKey("MX006") && stateMap.containsKey("MX008")){
|
|
|
mxstatus = Double.parseDouble(stateMap.get("MX008"));
|
|
|
}
|
|
|
+
|
|
|
if (stateMap.containsKey("MX002") && stateMap.containsKey("MX003")){
|
|
|
mxstatus = Double.parseDouble(stateMap.get("MX003"));
|
|
|
}
|
|
|
+ if (zjzt==3){
|
|
|
+ if ( stateMap.containsKey("MX006")){
|
|
|
+ mxstatus = 9;
|
|
|
+ }else
|
|
|
+ {
|
|
|
+ mxstatus = 8;
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -1280,5 +1475,78 @@ public class StatusService {
|
|
|
}
|
|
|
|
|
|
|
|
|
+ public void startStatusReal() throws Exception {
|
|
|
+
|
|
|
+ System.out.println("状态判定调度程序执行开始!。。。。。。");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+// Calendar c = Calendar.getInstance();
|
|
|
+// Date begin=c.getTime();
|
|
|
+// Date end=null;
|
|
|
+// System.out.println("状态判定调度程序执行开始!。。。。。。");
|
|
|
+ statusReal();
|
|
|
+
|
|
|
+// end=new Date();
|
|
|
+// System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
|
|
|
+// System.out.println("状态判定调度程序执行结束!。。。。。。");
|
|
|
+// System.out.println("完成!。。。。。。");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ public void startMiddleStatusReal() throws Exception {
|
|
|
+
|
|
|
+ System.out.println("中间状态判定调度程序执行开始!。。。。。。");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+// Calendar c = Calendar.getInstance();
|
|
|
+// Date begin=c.getTime();
|
|
|
+// Date end=null;
|
|
|
+// System.out.println("中间状态判定调度程序执行开始!。。。。。。");
|
|
|
+
|
|
|
+ middleStatusReal();
|
|
|
+// end=new Date();
|
|
|
+// System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
|
|
|
+// System.out.println("中间状态判定调度程序执行结束!。。。。。。");
|
|
|
+// System.out.println("完成!。。。。。。");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public void startPowerRationing() throws Exception {
|
|
|
+
|
|
|
+ System.out.println("场站状态判定调度程序执行开始!。。。。。。");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+// Calendar c = Calendar.getInstance();
|
|
|
+// Date begin=c.getTime();
|
|
|
+// Date end=null;
|
|
|
+// System.out.println("场站状态判定调度程序执行开始!。。。。。。");
|
|
|
+ powerRationing();
|
|
|
+
|
|
|
+//
|
|
|
+// end=new Date();
|
|
|
+// System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
|
|
|
+// System.out.println("场站状态判定调度程序执行结束!。。。。。。");
|
|
|
+// System.out.println("完成!。。。。。。");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public void startStatusNumber() throws Exception {
|
|
|
+
|
|
|
+ System.out.println("状态数量判定调度程序执行开始!。。。。。。");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+// Calendar c = Calendar.getInstance();
|
|
|
+// Date begin=c.getTime();
|
|
|
+// Date end=null;
|
|
|
+// System.out.println("状态数量判定调度程序执行开始!。。。。。。");
|
|
|
+ calculateStatusNumber();
|
|
|
+
|
|
|
+
|
|
|
+// end=new Date();
|
|
|
+// System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
|
|
|
+// System.out.println("场站状态数量判定调度程序执行结束!。。。。。。");
|
|
|
+// System.out.println("完成!。。。。。。");
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
}
|
