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         firewall = Field(Boolean,default=False)
  20         plc_nodeid = Field(Int,default=1)
  21
  22         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  23
  24         @classmethod
  25         def by_hostname(cls, hostname):
  26                 return cls.query.filter_by(hostname=hostname).first()
  27
  28 class HistoryPCURecord(Entity):
  29         plc_pcuid = Field(Int,primary_key=True)
  30
  31         last_checked = Field(DateTime,default=datetime.now)
  32         last_changed = Field(DateTime,default=datetime.now)
  33         status = Field(String,default="unknown")
  34
  35         last_valid = Field(DateTime,default=None)
  36         valid  = Field(String,default="unknown")
  37
  38         acts_as_versioned(ignore=['last_changed', 'last_checked'])
  39
  40         @classmethod
  41         def by_pcuid(cls, pcuid):
  42                 return cls.query.filter_by(pcuid=pcuid).first()
  43
  44
  45 class HistorySiteRecord(Entity):
  46         loginbase = Field(String(250),primary_key=True)
  47         plc_siteid = Field(Int,default=1)
  48
  49         last_checked = Field(DateTime,default=datetime.now)
  50         last_changed = Field(DateTime,default=datetime.now)
  51
  52         nodes_total = Field(Int,default=0)
  53         nodes_up = Field(Int,default=0)
  54         slices_total = Field(Int,default=0)
  55         slices_used = Field(Int,default=0)
  56
  57         # all nodes offline and never-contact.
  58         new = Field(Boolean,default=False)
  59
  60         enabled = Field(Boolean,default=False)
  61
  62         status = Field(String,default="unknown")
  63
  64         message_id = Field(Int, default=0)
  65         message_status = Field(String, default=None)
  66         message_queue = Field(String, default=None)
  67         message_created = Field(DateTime, default=None)
  68
  69         penalty_level   = Field(Int, default=0)
  70         penalty_applied = Field(Boolean, default=False)
  71         acts_as_versioned(ignore=['last_changed', 'last_checked', 'message_status'])
  72
  73         @classmethod
  74         def by_loginbase(cls, loginbase):
  75                 return cls.query.filter_by(loginbase=loginbase).first()
  76