sdnr/wireless-transport/code-Carbon-SR1/apps/devicemanager/impl/src/main/java/org/opendaylight/mwtn/devicemanager/impl/database/types/EsFaultCurrent.java

   1 package org.opendaylight.mwtn.devicemanager.impl.database.types;
   2
   3 import org.elasticsearch.index.query.BoolQueryBuilder;
   4 import org.elasticsearch.index.query.QueryBuilder;
   5 import org.elasticsearch.index.query.QueryBuilders;
   6 import org.opendaylight.mwtn.base.database.EsObject;
   7 import org.opendaylight.mwtn.devicemanager.impl.xml.ProblemNotificationXml;
   8
   9 /**
  10  * Event from Network to be recorded in the database
  11  *
  12  */
  13
  14 public class EsFaultCurrent extends EsObject {
  15
  16     public static final String ESDATATYPENAME = "faultcurrent";
  17     //private static final String NOALARM = "NonAlarmed";
  18
  19     private ProblemNotificationXml faultCurrent;
  20
  21     public ProblemNotificationXml getProblem() {
  22         return faultCurrent;
  23     }
  24
  25     public void setProblem(ProblemNotificationXml fault) {
  26         this.faultCurrent = fault;
  27         setEsId(fault.genSpecificEsId());
  28     }
  29
  30     public boolean isNoAlarmIndication() {
  31         return faultCurrent.getSeverity().isNoAlarmIndication();
  32     }
  33
  34     public static QueryBuilder getQueryForOneNode( String nodeName) {
  35         return QueryBuilders.termQuery("faultCurrent.nodeName", nodeName);
  36     }
  37
  38     public static QueryBuilder getQueryForOneNodeAndObjectId( String nodeName, String objectId) {
  39         BoolQueryBuilder bq = QueryBuilders.boolQuery();
  40         bq.must(QueryBuilders.termQuery("faultCurrent.nodeName", nodeName));
  41         bq.must(QueryBuilders.termQuery("faultCurrent.objectId", objectId));
  42         return bq;
  43         //return QueryBuilders.termQuery("faultCurrent.objectId", objectId);
  44
  45     }
  46
  47     public static String getEsdatatypename() {
  48         return ESDATATYPENAME;
  49     }
  50
  51  }