monitor/database/info/history.py

   1 from elixir import Entity, Field, OneToMany, ManyToOne, ManyToMany
   2 from elixir import options_defaults, using_options, setup_all
   3 from elixir import String, Integer as Int, DateTime, Boolean
   4 from elixir.ext.versioned import *
   5
   6 from datetime import datetime,timedelta
   7
   8 from monitor.database.dborm import mon_metadata, mon_session
   9 __metadata__ = mon_metadata
  10 __session__  = mon_session
  11
  12 # your data model
  13 class HistoryNodeRecord(Entity):
  14         hostname = Field(String(250),primary_key=True)
  15         last_checked = Field(DateTime,default=datetime.now)
  16         last_changed = Field(DateTime,default=datetime.now)
  17         status = Field(String,default="unknown")
  18         haspcu = Field(Boolean,default=False)
  19         plc_nodeid = Field(Int,default=1)
  20
  21         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  22
  23         @classmethod
  24         def by_hostname(cls, hostname):
  25                 return cls.query.filter_by(hostname=hostname).first()
  26
  27 class HistoryPCURecord(Entity):
  28         plc_pcuid = Field(Int,primary_key=True)
  29
  30         last_checked = Field(DateTime,default=datetime.now)
  31         last_changed = Field(DateTime,default=datetime.now)
  32         status = Field(String,default="unknown")
  33
  34         last_valid = Field(DateTime,default=None)
  35         valid  = Field(String,default="unknown")
  36
  37         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  38
  39         @classmethod
  40         def by_pcuid(cls, pcuid):
  41                 return cls.query.filter_by(pcuid=pcuid).first()
  42
  43
  44 class HistorySiteRecord(Entity):
  45         loginbase = Field(String(250),primary_key=True)
  46         plc_siteid = Field(Int,default=1)
  47
  48         last_checked = Field(DateTime,default=datetime.now)
  49         last_changed = Field(DateTime,default=datetime.now)
  50
  51         nodes_total = Field(Int,default=0)
  52         nodes_up = Field(Int,default=0)
  53         slices_total = Field(Int,default=0)
  54         slices_used = Field(Int,default=0)
  55
  56         # all nodes offline and never-contact.
  57         new = Field(Boolean,default=False)
  58
  59         enabled = Field(Boolean,default=False)
  60
  61         status = Field(String,default="unknown")
  62
  63         message_id = Field(Int, default=0)
  64         message_status = Field(String, default=None)
  65         message_queue = Field(String, default=None)
  66         message_created = Field(DateTime, default=None)
  67
  68         penalty_level   = Field(Int, default=0)
  69         penalty_applied = Field(Boolean, default=False)
  70         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  71
  72         @classmethod
  73         def by_loginbase(cls, loginbase):
  74                 return cls.query.filter_by(loginbase=loginbase).first()
  75