293 lines
10 KiB
Python
293 lines
10 KiB
Python
##
|
|
# This software was developed and / or modified by Raytheon Company,
|
|
# pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
#
|
|
# U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
# This software product contains export-restricted data whose
|
|
# export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
# to non-U.S. persons whether in the United States or abroad requires
|
|
# an export license or other authorization.
|
|
#
|
|
# Contractor Name: Raytheon Company
|
|
# Contractor Address: 6825 Pine Street, Suite 340
|
|
# Mail Stop B8
|
|
# Omaha, NE 68106
|
|
# 402.291.0100
|
|
#
|
|
# See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
# further licensing information.
|
|
##
|
|
# Utility classes for the VTEC active table
|
|
|
|
import time, copy, types
|
|
import LogStream
|
|
import JUtil
|
|
|
|
|
|
class VTECTableUtil:
|
|
|
|
def __init__(self, activeTableFileName = None):
|
|
self._activeTableFilename = activeTableFileName
|
|
self._activeTableLockFD = None
|
|
if activeTableFileName is not None:
|
|
self._activeTableLockFilename = self._activeTableFilename + "lock"
|
|
else:
|
|
self._activeTableLockFilename = None
|
|
|
|
#------------------------------------------------------------------
|
|
# Consolidate Utilities
|
|
#------------------------------------------------------------------
|
|
|
|
#given the table, will consolidate like records and return a table
|
|
#with identical hazards, but with multiple id entries
|
|
def consolidateByID(self, ptable, compare=None):
|
|
if compare is None:
|
|
compare = ['etn','vtecstr','ufn','areaPoints','valuePoints','hdln',
|
|
'phensig','previousStart','previousEnd','purgeTime','issueTime',
|
|
'downgradeFrom','upgradeFrom','startTime','endTime','act','pil','phen',
|
|
'sig','officeid','seg','state']
|
|
ctable = []
|
|
for a in ptable:
|
|
found = 0
|
|
for c in ctable:
|
|
if self.hazardCompare(a, c, compare):
|
|
found = 1
|
|
if type(a['id']) == types.ListType:
|
|
zones = a['id']
|
|
else:
|
|
zones = [a['id']]
|
|
|
|
allzones = c['id']
|
|
for z in zones:
|
|
allzones.append(z)
|
|
c['id'] = allzones
|
|
break
|
|
if found == 0:
|
|
newc = copy.deepcopy(a)
|
|
if newc['id'] is not list:
|
|
newc['id'] = [newc['id']]
|
|
ctable.append(newc)
|
|
|
|
return ctable
|
|
|
|
#------------------------------------------------------------------
|
|
# Printing Utilities
|
|
#------------------------------------------------------------------
|
|
|
|
#Pretty-prints the given table or table entry, returns the string
|
|
def printActiveTable(self, table, combine=False, idType='zone'):
|
|
if table is None:
|
|
s = "Table is None"
|
|
return s
|
|
elif hasattr(table,"jclassname"):
|
|
table = JUtil.javaObjToPyVal(table)
|
|
print type(table)
|
|
|
|
#dictionary, single record
|
|
if type(table) is dict:
|
|
ptable = []
|
|
ptable.append(table)
|
|
#list of dictionaries
|
|
else:
|
|
ptable = table
|
|
|
|
s = '\n' #Return value
|
|
|
|
# Use the zone or city printEntry method
|
|
if idType == 'zone':
|
|
printEntry = self.printEntry
|
|
compare = None
|
|
elif idType == 'city':
|
|
printEntry = self.printCityEntry
|
|
compare = ['start', 'end', 'phen', 'sig', 'seg']
|
|
|
|
|
|
#combine mode, attempt to combine records
|
|
if combine:
|
|
ctable = self.consolidateByID(ptable, compare=compare)
|
|
for c in ctable:
|
|
s = s + printEntry(c)
|
|
#non-combine mode
|
|
else:
|
|
for p in ptable:
|
|
s = s + printEntry(p)
|
|
|
|
return s
|
|
|
|
|
|
#Pretty-prints an entry in the table
|
|
def printEntry(self, entry):
|
|
#formatting for the etn
|
|
if type(entry['etn']) is int:
|
|
etn = "%04i" % entry['etn']
|
|
else:
|
|
etn = entry['etn']
|
|
|
|
#formatting for the vstr
|
|
if entry.has_key('vtecstr'):
|
|
vstr = entry['vtecstr']
|
|
else:
|
|
vstr = "????"
|
|
|
|
#formatting for the id depending upon the type of table
|
|
zones = ''
|
|
if type(entry['id']) == types.ListType:
|
|
zones = entry['id']
|
|
zones.sort()
|
|
zones = `zones`
|
|
else:
|
|
zones = entry['id']
|
|
|
|
#until further notice
|
|
ufn = entry.get('ufn', 0)
|
|
|
|
#formatting for areaPoints, valuePoints if available
|
|
apvp = ''
|
|
if entry.has_key('areaPoints') and entry.has_key('valuePoints'):
|
|
ratio = (entry['valuePoints'] / float(entry['areaPoints'])) * 100.0
|
|
apvp = 'AreaPoints: ' + '%6i' % entry['areaPoints'] +\
|
|
' ValuePoints: ' + '%6i' % entry['valuePoints'] + \
|
|
' % Area: ' + '%6.1f' % ratio + '%\n'
|
|
|
|
#formatting for hdln
|
|
if entry.has_key('hdln'):
|
|
hdln = entry['hdln']
|
|
else:
|
|
hdln = "????"
|
|
|
|
#formatting for key
|
|
if entry.has_key('phensig'):
|
|
key = entry['phensig']
|
|
else:
|
|
key = "????"
|
|
|
|
#formatting for previousStart/End
|
|
if entry.has_key('previousStart') and entry.has_key('previousEnd'):
|
|
prev = '\nPrevStart: ' + \
|
|
time.asctime(time.gmtime(entry['previousStart'])) + \
|
|
' ' + `entry['previousStart']` + '\nPrevEnd: ' + \
|
|
time.asctime(time.gmtime(entry['previousEnd'])) + \
|
|
' ' + `entry['previousEnd']`
|
|
else:
|
|
prev = ''
|
|
|
|
#formatting for purgeTime
|
|
if entry.has_key('purgeTime'):
|
|
expireT = '\nPurge: ' + \
|
|
time.asctime(time.gmtime(entry['purgeTime'])) + \
|
|
' ' + `entry['purgeTime']`
|
|
else:
|
|
expireT = ''
|
|
|
|
#formatting for issueTime
|
|
if entry.has_key('issueTime'):
|
|
issueT = '\nIssue: ' + \
|
|
time.asctime(time.gmtime(entry['issueTime'])) + \
|
|
' ' + `entry['issueTime']`
|
|
else:
|
|
issueT = ''
|
|
|
|
#formatting for recState
|
|
if entry.has_key('state'):
|
|
recState = " RecState: " + entry['state']
|
|
else:
|
|
recState = ''
|
|
|
|
#formatting for upgrades/downgrades special records
|
|
if entry.has_key('downgradeFrom'):
|
|
related = entry['downgradeFrom']
|
|
duType = "DowngradeFrom: "
|
|
elif entry.has_key('upgradeFrom'):
|
|
related = entry['upgradeFrom']
|
|
duType = "UpgradeFrom: "
|
|
else:
|
|
related = None
|
|
if related is not None:
|
|
if related.has_key('phensig'):
|
|
rkey = related['phensig']
|
|
else:
|
|
rkey = "????"
|
|
if type(related['etn']) is int:
|
|
retn = "%04i" % related['etn']
|
|
else:
|
|
retn = related['etn']
|
|
relatedText = duType + "Action: " + related['act'] + \
|
|
' Phen: ' + related['phen'] + ' Sig: ' + related['sig'] + \
|
|
' Key: ' + rkey + ' Etn:' + retn + '\n' +\
|
|
duType + 'Start: ' +\
|
|
time.asctime(time.gmtime(related['startTime'])) +\
|
|
' ' + `related['startTime']` + '\n' + \
|
|
duType + 'End: ' + \
|
|
time.asctime(time.gmtime(related['endTime'])) + ' ' +\
|
|
`related['endTime']` + '\n'
|
|
else:
|
|
relatedText = ""
|
|
|
|
t = 'Vtec: ' + vstr + '\nHdln: ' + hdln + \
|
|
'\nStart: ' + time.asctime(time.gmtime(entry['startTime'])) +\
|
|
' ' + `entry['startTime']` + ' Action: ' + entry['act'] + \
|
|
' Pil: ' + entry['pil'] + '\nEnd: ' + \
|
|
time.asctime(time.gmtime(entry['endTime'])) + ' ' + `entry['endTime']` + \
|
|
' UFN: ' + `ufn` + recState + expireT + issueT + prev + '\n' +\
|
|
'Phen: ' + entry['phen'] + ' Sig: ' + entry['sig'] + ' Office: ' +\
|
|
entry['officeid'] + ' Etn: ' + etn + ' Seg: ' + `entry['seg']` + \
|
|
' Key: ' + key + '\n' + apvp + 'Zone: ' + zones + '\n' +\
|
|
relatedText + '\n'
|
|
return t
|
|
|
|
#Pretty-prints an entry in the table
|
|
def printCityEntry(self, entry):
|
|
#formatting for the id depending upon the type of table
|
|
zones = ''
|
|
if type(entry['id']) == types.ListType:
|
|
zones = entry['id']
|
|
zones.sort()
|
|
zones = `zones`
|
|
else:
|
|
zones = entry['id']
|
|
|
|
#formatting for key
|
|
if entry.has_key('key'):
|
|
key = entry['key']
|
|
else:
|
|
key = "????"
|
|
|
|
#until further notice
|
|
ufn = entry.get('ufn', 0)
|
|
|
|
start = entry['startTime']
|
|
end = entry['endTime']
|
|
t = 'Phen: ' + entry['phen'] + ' Sig: ' + entry['sig'] + \
|
|
' Seg: ' + `entry['seg']` + ' Key: ' + key + \
|
|
' UFN: ' + `ufn` + \
|
|
'\nStart: ' + time.asctime(time.gmtime(start)) + ' ' + `start` +\
|
|
'\nEnd: ' + time.asctime(time.gmtime(end)) + ' ' + `end` +\
|
|
'\nCities: ' + zones + '\n\n'
|
|
return t
|
|
|
|
|
|
# Comparison routine for two hazard entries. Returns 1 if the
|
|
# two records are equal. The fields to compare are provided.
|
|
def hazardCompare(self, rec1, rec2, fields):
|
|
for f in fields:
|
|
if rec1.has_key(f) and rec2.has_key(f):
|
|
if rec1[f] != rec2[f]:
|
|
return 0
|
|
elif rec1.has_key(f) or rec2.has_key(f):
|
|
return 0 #one record has the field, set it not equal
|
|
else:
|
|
continue #neither record has this field, that is ok
|
|
return 1
|
|
|
|
def _get4ID(self, id):
|
|
if id in ['SJU']:
|
|
return "TJSJ"
|
|
elif id in ['AFG', 'AJK', 'HFO', 'GUM']:
|
|
return "P" + id
|
|
elif id in ['AER', 'ALU']:
|
|
return "PAFC"
|
|
else:
|
|
return "K" + id
|
|
|
|
|
|
|