数据点位过滤修复，使用了计算规则的点位存储_n的。

yangys

2024-11-03 d187cd0fa46d01ec293e2aba1a1e54fdfab2ec80

 collect/src/main/java/com/qianwen/mdc/collect/vo/WorkstationDatapointsVO.java

@@ -10,7 +10,6 @@
import com.alibaba.fastjson.JSONObject;

import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONUtil;
import io.swagger.annotations.ApiModelProperty;


@@ -42,6 +41,8 @@
    
    //private List<DataPoint> points = null;
    private List<String> points = new ArrayList<>();
    
    private List<DataPoint> dpList = new ArrayList<>();

   public WorkstationDatapointsVO(long workstationId, String appId,String dpConfig) {
      super();
@@ -60,13 +61,18 @@
      
      points = new ArrayList<>();
      JSONObject ptObj;
      String dpName;
      for(int i=0;i<ptArr.size();i++) {
         ptObj = ptArr.getJSONObject(i);
         
         //DataPoint dp = new DataPoint();
         //dp.setDpName(ptObj.getString("dpName"));
         dpName = ptObj.getString("dpName");
         points.add(dpName);
         
         points.add(ptObj.getString("dpName"));
         DataPoint dp = new DataPoint();
         dp.setDpName(dpName);
         dp.setRuleContent(ptObj.getString("ruleContent"));
         dpList.add(dp);
			
      }
   }

@@ -108,28 +114,51 @@
    * @param dpName
    * @return
    */
   public boolean containsDataPoint(String dpName) {
   public boolean containsDataPointOld(String dpName) {
      if(ObjectUtil.isEmpty(points)) {
         return false;
      }
      
      return points.contains(dpName);
      /*
      for(String dpn : points) {
         if(StringUtils.equals(dpn, dpName)) {
            return true;
		
   }

   public boolean containsDataPoint(String receiveDpName) {
      if(ObjectUtil.isEmpty(dpList)) {
         return false;
      }
      if(receiveDpName.startsWith("DeviceStatus")) {
         System.out.println("recname="+receiveDpName);
      }
      for(DataPoint dp : dpList) {
         //无计算规则，直接数据点名称匹配
         if(!dp.hasRuleContent()){
            if(StringUtils.equals(dp.getDpName(), receiveDpName)){
               return true;
            }
				
         }else {
            //有计算规则，用数据点名称_n匹配
            if(StringUtils.equals(dp.getDpName()+"_n", receiveDpName)) {
               return true;
            }
         }
      }
      return false;
      */
		
   }

    
}
/*
class DataPoint{
   private String dpName;

class DataPoint implements Serializable{
   private String dpName;
   private String ruleContent;
	
   /**
    * 数据点是否包含计算规则
    */
   public boolean hasRuleContent() {
      return StringUtils.isNotBlank(StringUtils.trim(ruleContent));
   }
   public String getDpName() {
      return dpName;
   }
@@ -137,7 +166,19 @@
   public void setDpName(String dpName) {
      this.dpName = dpName;
   }

   public String getRuleContent() {
      return ruleContent;
   }

   public void setRuleContent(String ruleContent) {
      this.ruleContent = ruleContent;
   }
   @Override
   public String toString() {
      return "DataPoint [dpName=" + dpName + ", ruleContent=" + ruleContent + "]";
   }
   
   
}
*/