commands/checksync.py

   1 #!/usr/bin/python
   2
   3 from monitor.database.info.model import *
   4 import sys
   5
   6
   7 if True:
   8     fbquery = HistorySiteRecord.query.all()
   9     loginbases = [ h.loginbase for h in fbquery ]
  10
  11     for lb in loginbases:
  12         h = HistorySiteRecord.query.filter_by(loginbase=lb).first()
  13         if len(h.versions) >= 2:
  14             if h.version != h.versions[-2].version + 1:
  15                 print h.loginbase, h.version, h.versions[-2].version
  16                 h.version = h.versions[-2].version + 1
  17                 h.flush()
  18
  19     session.flush()
  20
  21
  22
  23 if False:
  24     fbquery = HistoryNodeRecord.query.all()
  25     hostnames = [ n.hostname for n in fbquery ]
  26
  27     for hn in hostnames:
  28         fbrec = FindbadNodeRecord.query.filter_by(hostname=hn).order_by(FindbadNodeRecord.version.desc()).first()
  29         if len(fbrec.versions) >= 2:
  30             if fbrec.version != fbrec.versions[-2].version + 1:
  31                 print fbrec.hostname, fbrec.version, fbrec.versions[-2].version
  32                 fbrec.version = fbrec.versions[-2].version + 1
  33                 fbrec.flush()
  34
  35     session.flush()
  36
  37
  38 if False:
  39     fbquery = HistoryPCURecord.query.all()
  40     pcus = [ n.plc_pcuid for n in fbquery ]
  41
  42     for pcuid in pcus:
  43         fbrec = FindbadPCURecord.query.filter_by(plc_pcuid=pcuid).order_by(FindbadPCURecord.version.desc()).first()
  44         if len(fbrec.versions) >= 2:
  45             if fbrec.version != fbrec.versions[-2].version + 1:
  46                 print fbrec.plc_pcuid, fbrec.version, fbrec.versions[-2].version
  47                 fbrec.version = fbrec.versions[-2].version + 1
  48                 fbrec.flush()
  49
  50 session.flush()