mirror of
https://github.com/Unidata/python-awips.git
synced 2025-02-23 14:57:56 -05:00
rm activetable, ActiveTableModeAdapter, LockTableAdapter
This commit is contained in:
parent
b645a646e5
commit
d40f3d9586
28 changed files with 0 additions and 1168 deletions
|
@ -1,30 +0,0 @@
|
|||
#
|
||||
# Adapter for com.raytheon.uf.common.activetable.ActiveTableMode
|
||||
#
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# 09/29/10 wldougher Initial Creation.
|
||||
#
|
||||
|
||||
from thrift.Thrift import TType
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.activetable import ActiveTableMode
|
||||
|
||||
ClassAdapter = 'com.raytheon.uf.common.activetable.ActiveTableMode'
|
||||
|
||||
|
||||
def serialize(context, mode):
|
||||
context.protocol.writeFieldBegin('__enumValue__', TType.STRING, 0)
|
||||
context.writeString(mode.value)
|
||||
|
||||
|
||||
def deserialize(context):
|
||||
result = ActiveTableMode()
|
||||
# Read the TType.STRING, "__enumValue__", and id.
|
||||
# We're not interested in any of those, so just discard them.
|
||||
context.protocol.readFieldBegin()
|
||||
# now get the actual enum value
|
||||
result.value = context.readString()
|
||||
return result
|
|
@ -1,70 +0,0 @@
|
|||
#
|
||||
# Adapter for com.raytheon.uf.common.dataplugin.gfe.server.lock.LockTable
|
||||
#
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------- -------- --------- ---------------------------------------------
|
||||
# Apr 22, 2013 rjpeter Initial Creation.
|
||||
# Jun 12, 2013 2099 dgilling Use new Lock constructor.
|
||||
# Feb 06, 2017 5959 randerso Removed Java .toString() calls
|
||||
#
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataplugin.gfe.server.lock import LockTable
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataplugin.gfe.server.lock import Lock
|
||||
|
||||
ClassAdapter = 'com.raytheon.uf.common.dataplugin.gfe.server.lock.LockTable'
|
||||
|
||||
|
||||
def serialize(context, lockTable):
|
||||
index=0
|
||||
wsIds = {str(lockTable.getWsId()) : index}
|
||||
index += 1
|
||||
locks = lockTable.getLocks()
|
||||
lockWsIdIndex = []
|
||||
for lock in locks:
|
||||
wsIdString = str(lock.getWsId())
|
||||
|
||||
if wsIdString in wsIds:
|
||||
lockWsIdIndex.append(wsIds[wsIdString])
|
||||
else:
|
||||
lockWsIdIndex.append(index)
|
||||
wsIds[wsIdString] = index
|
||||
index += 1
|
||||
|
||||
context.writeObject(lockTable.getParmId())
|
||||
|
||||
context.writeI32(index)
|
||||
for wsId in sorted(wsIds, key=wsIds.get):
|
||||
context.writeObject(wsId)
|
||||
|
||||
context.writeI32(len(locks))
|
||||
for lock, wsIndex in zip(locks, lockWsIdIndex):
|
||||
serializer.writeI64(lock.getStartTime())
|
||||
serializer.writeI64(lock.getEndTime())
|
||||
serializer.writeI32(wsIndex)
|
||||
|
||||
|
||||
def deserialize(context):
|
||||
parmId = context.readObject()
|
||||
numWsIds = context.readI32()
|
||||
wsIds = []
|
||||
for x in range(numWsIds):
|
||||
wsIds.append(context.readObject())
|
||||
|
||||
numLocks = context.readI32()
|
||||
locks = []
|
||||
for x in range(numLocks):
|
||||
startTime = context.readI64()
|
||||
endTime = context.readI64()
|
||||
wsId = wsIds[context.readI32()]
|
||||
lock = Lock(parmId, wsId, startTime, endTime)
|
||||
locks.append(lock)
|
||||
|
||||
lockTable = LockTable()
|
||||
lockTable.setParmId(parmId)
|
||||
lockTable.setWsId(wsIds[0])
|
||||
lockTable.setLocks(locks)
|
||||
|
||||
return lockTable
|
|
@ -35,7 +35,6 @@ __all__ = [
|
|||
'WsIdAdapter',
|
||||
'CalendarAdapter',
|
||||
'GregorianCalendarAdapter',
|
||||
'ActiveTableModeAdapter',
|
||||
'DateAdapter',
|
||||
'FormattedDateAdapter',
|
||||
'LocalizationLevelSerializationAdapter',
|
||||
|
@ -51,7 +50,6 @@ __all__ = [
|
|||
'FloatBufferAdapter',
|
||||
'ByteBufferAdapter',
|
||||
'TimeConstraintsAdapter',
|
||||
'LockTableAdapter',
|
||||
'JTSEnvelopeAdapter'
|
||||
]
|
||||
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
|
||||
__all__ = [
|
||||
'activetable',
|
||||
'alertviz',
|
||||
'auth',
|
||||
'dataaccess',
|
||||
|
|
|
@ -1,63 +0,0 @@
|
|||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# 05/22/2015 4522 randerso Initial creation
|
||||
# 03/17/2016 5426 randerso Add issueYear to primary key
|
||||
# 08/03/2016 19213 ryu Add pil to primary key
|
||||
#
|
||||
|
||||
|
||||
class ActiveTableKey(object):
|
||||
|
||||
def __init__(self):
|
||||
self.officeid = None
|
||||
self.phen = None
|
||||
self.sig = None
|
||||
self.etn = None
|
||||
self.ugcZone = None
|
||||
self.issueYear = None
|
||||
self.pil = None
|
||||
|
||||
def getOfficeid(self):
|
||||
return self.officeid
|
||||
|
||||
def setOfficeid(self, officeid):
|
||||
self.officeid = officeid
|
||||
|
||||
def getPhen(self):
|
||||
return self.phen
|
||||
|
||||
def setPhen(self, phen):
|
||||
self.phen = phen
|
||||
|
||||
def getSig(self):
|
||||
return self.sig
|
||||
|
||||
def setSig(self, sig):
|
||||
self.sig = sig
|
||||
|
||||
def getEtn(self):
|
||||
return self.etn
|
||||
|
||||
def setEtn(self, etn):
|
||||
self.etn = etn
|
||||
|
||||
def getUgcZone(self):
|
||||
return self.ugcZone
|
||||
|
||||
def setUgcZone(self, ugcZone):
|
||||
self.ugcZone = ugcZone
|
||||
|
||||
def getIssueYear(self):
|
||||
return self.issueYear
|
||||
|
||||
def setIssueYear(self, issueYear):
|
||||
self.issueYear = issueYear
|
||||
|
||||
def getPil(self):
|
||||
return self.pil
|
||||
|
||||
def setPil(self, pil):
|
||||
self.pil = pil
|
|
@ -1,9 +0,0 @@
|
|||
# Jul 27, 2016 #5769 randerso Fixed __str__ method
|
||||
|
||||
|
||||
class ActiveTableMode(object):
|
||||
def __init__(self):
|
||||
self.value = None
|
||||
|
||||
def __str__(self):
|
||||
return str(self.value)
|
|
@ -1,269 +0,0 @@
|
|||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# 05/22/2015 4522 randerso Initial creation (hand generated)
|
||||
# 03/17/2016 5426 randerso Add issueYear to primary key
|
||||
# 06/27/2016 5707 nabowle Remove geometry
|
||||
#
|
||||
|
||||
import abc
|
||||
from six import with_metaclass
|
||||
from . import ActiveTableKey
|
||||
|
||||
|
||||
class ActiveTableRecord(with_metaclass(abc.ABCMeta, object)):
|
||||
@abc.abstractmethod
|
||||
def __init__(self):
|
||||
self.key = ActiveTableKey.ActiveTableKey()
|
||||
self.wmoid = None
|
||||
self.pil = None
|
||||
self.xxxid = None
|
||||
self.countyheader = None
|
||||
self.vtecstr = None
|
||||
self.productClass = None
|
||||
self.act = None
|
||||
self.startTime = None
|
||||
self.endTime = None
|
||||
self.issueTime = None
|
||||
self.purgeTime = None
|
||||
self.ufn = None
|
||||
self.forecaster = None
|
||||
self.motdir = None
|
||||
self.motspd = None
|
||||
self.loc = None
|
||||
self.rawmessage = None
|
||||
self.seg = None
|
||||
self.phensig = None
|
||||
self.region = None
|
||||
self.overviewText = None
|
||||
self.segText = None
|
||||
self.locationID = None
|
||||
self.floodSeverity = None
|
||||
self.immediateCause = None
|
||||
self.floodRecordStatus = None
|
||||
self.floodBegin = None
|
||||
self.floodCrest = None
|
||||
self.floodEnd = None
|
||||
self.identifier = None
|
||||
|
||||
def getKey(self):
|
||||
return self.key
|
||||
|
||||
def setKey(self, key):
|
||||
self.key = key
|
||||
|
||||
def getWmoid(self):
|
||||
return self.wmoid
|
||||
|
||||
def setWmoid(self, wmoid):
|
||||
self.wmoid = wmoid
|
||||
|
||||
def getPil(self):
|
||||
return self.pil
|
||||
|
||||
def setPil(self, pil):
|
||||
self.pil = pil
|
||||
|
||||
def getXxxid(self):
|
||||
return self.xxxid
|
||||
|
||||
def setXxxid(self, xxxid):
|
||||
self.xxxid = xxxid
|
||||
|
||||
def getCountyheader(self):
|
||||
return self.countyheader
|
||||
|
||||
def setCountyheader(self, countyheader):
|
||||
self.countyheader = countyheader
|
||||
|
||||
def getUgcZone(self):
|
||||
return self.key.getUgcZone()
|
||||
|
||||
def setUgcZone(self, ugcZone):
|
||||
self.key.setUgcZone(ugcZone)
|
||||
|
||||
def getVtecstr(self):
|
||||
return self.vtecstr
|
||||
|
||||
def setVtecstr(self, vtecstr):
|
||||
self.vtecstr = vtecstr
|
||||
|
||||
def getProductClass(self):
|
||||
return self.productClass
|
||||
|
||||
def setProductClass(self, productClass):
|
||||
self.productClass = productClass
|
||||
|
||||
def getAct(self):
|
||||
return self.act
|
||||
|
||||
def setAct(self, act):
|
||||
self.act = act
|
||||
|
||||
def getOfficeid(self):
|
||||
return self.key.getOfficeid()
|
||||
|
||||
def setOfficeid(self, officeid):
|
||||
self.key.setOfficeid(officeid)
|
||||
|
||||
def getPhen(self):
|
||||
return self.key.getPhen()
|
||||
|
||||
def setPhen(self, phen):
|
||||
self.key.setPhen(phen)
|
||||
|
||||
def getSig(self):
|
||||
return self.key.getSig()
|
||||
|
||||
def setSig(self, sig):
|
||||
self.key.setSig(sig)
|
||||
|
||||
def getEtn(self):
|
||||
return self.key.getEtn()
|
||||
|
||||
def setEtn(self, etn):
|
||||
self.key.setEtn(etn)
|
||||
|
||||
def getStartTime(self):
|
||||
return self.startTime
|
||||
|
||||
def setStartTime(self, startTime):
|
||||
self.startTime = startTime
|
||||
|
||||
def getEndTime(self):
|
||||
return self.endTime
|
||||
|
||||
def setEndTime(self, endTime):
|
||||
self.endTime = endTime
|
||||
|
||||
def getIssueTime(self):
|
||||
return self.issueTime
|
||||
|
||||
def setIssueTime(self, issueTime):
|
||||
from datetime import datetime
|
||||
date = datetime.utcfromtimestamp(issueTime.getTime()/1000)
|
||||
self.key.setIssueYear(date.year)
|
||||
self.issueTime = issueTime
|
||||
|
||||
def getPurgeTime(self):
|
||||
return self.purgeTime
|
||||
|
||||
def setPurgeTime(self, purgeTime):
|
||||
self.purgeTime = purgeTime
|
||||
|
||||
def isUfn(self):
|
||||
return self.ufn
|
||||
|
||||
def setUfn(self, ufn):
|
||||
self.ufn = ufn
|
||||
|
||||
def getForecaster(self):
|
||||
return self.forecaster
|
||||
|
||||
def setForecaster(self, forecaster):
|
||||
self.forecaster = forecaster
|
||||
|
||||
def getMotdir(self):
|
||||
return self.motdir
|
||||
|
||||
def setMotdir(self, motdir):
|
||||
self.motdir = motdir
|
||||
|
||||
def getMotspd(self):
|
||||
return self.motspd
|
||||
|
||||
def setMotspd(self, motspd):
|
||||
self.motspd = motspd
|
||||
|
||||
def getLoc(self):
|
||||
return self.loc
|
||||
|
||||
def setLoc(self, loc):
|
||||
self.loc = loc
|
||||
|
||||
def getRawmessage(self):
|
||||
return self.rawmessage
|
||||
|
||||
def setRawmessage(self, rawmessage):
|
||||
self.rawmessage = rawmessage
|
||||
|
||||
def getSeg(self):
|
||||
return self.seg
|
||||
|
||||
def setSeg(self, seg):
|
||||
self.seg = seg
|
||||
|
||||
def getPhensig(self):
|
||||
return self.phensig
|
||||
|
||||
def setPhensig(self, phensig):
|
||||
self.phensig = phensig
|
||||
|
||||
def getRegion(self):
|
||||
return self.region
|
||||
|
||||
def setRegion(self, region):
|
||||
self.region = region
|
||||
|
||||
def getOverviewText(self):
|
||||
return self.overviewText
|
||||
|
||||
def setOverviewText(self, overviewText):
|
||||
self.overviewText = overviewText
|
||||
|
||||
def getSegText(self):
|
||||
return self.segText
|
||||
|
||||
def setSegText(self, segText):
|
||||
self.segText = segText
|
||||
|
||||
def getLocationID(self):
|
||||
return self.locationID
|
||||
|
||||
def setLocationID(self, locationID):
|
||||
self.locationID = locationID
|
||||
|
||||
def getFloodSeverity(self):
|
||||
return self.floodSeverity
|
||||
|
||||
def setFloodSeverity(self, floodSeverity):
|
||||
self.floodSeverity = floodSeverity
|
||||
|
||||
def getImmediateCause(self):
|
||||
return self.immediateCause
|
||||
|
||||
def setImmediateCause(self, immediateCause):
|
||||
self.immediateCause = immediateCause
|
||||
|
||||
def getFloodRecordStatus(self):
|
||||
return self.floodRecordStatus
|
||||
|
||||
def setFloodRecordStatus(self, floodRecordStatus):
|
||||
self.floodRecordStatus = floodRecordStatus
|
||||
|
||||
def getFloodBegin(self):
|
||||
return self.floodBegin
|
||||
|
||||
def setFloodBegin(self, floodBegin):
|
||||
self.floodBegin = floodBegin
|
||||
|
||||
def getFloodCrest(self):
|
||||
return self.floodCrest
|
||||
|
||||
def setFloodCrest(self, floodCrest):
|
||||
self.floodCrest = floodCrest
|
||||
|
||||
def getFloodEnd(self):
|
||||
return self.floodEnd
|
||||
|
||||
def setFloodEnd(self, floodEnd):
|
||||
self.floodEnd = floodEnd
|
||||
|
||||
def getIdentifier(self):
|
||||
return self.identifier
|
||||
|
||||
def setIdentifier(self, identifier):
|
||||
self.identifier = identifier
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
|
||||
|
||||
class DumpActiveTableRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.actions = None
|
||||
self.etns = None
|
||||
self.fileContent = None
|
||||
self.fileName = None
|
||||
self.fromSite = None
|
||||
self.ids = None
|
||||
self.mode = None
|
||||
self.phens = None
|
||||
self.pils = None
|
||||
self.sigs = None
|
||||
self.sites = None
|
||||
|
||||
def getActions(self):
|
||||
return self.actions
|
||||
|
||||
def setActions(self, actions):
|
||||
self.actions = actions
|
||||
|
||||
def getEtns(self):
|
||||
return self.etns
|
||||
|
||||
def setEtns(self, etns):
|
||||
self.etns = etns
|
||||
|
||||
def getFileContent(self):
|
||||
return self.fileContent
|
||||
|
||||
def setFileContent(self, fileContent):
|
||||
self.fileContent = fileContent
|
||||
|
||||
def getFileName(self):
|
||||
return self.fileName
|
||||
|
||||
def setFileName(self, fileName):
|
||||
self.fileName = fileName
|
||||
|
||||
def getFromSite(self):
|
||||
return self.fromSite
|
||||
|
||||
def setFromSite(self, fromSite):
|
||||
self.fromSite = fromSite
|
||||
|
||||
def getIds(self):
|
||||
return self.ids
|
||||
|
||||
def setIds(self, ids):
|
||||
self.ids = ids
|
||||
|
||||
def getMode(self):
|
||||
return self.mode
|
||||
|
||||
def setMode(self, mode):
|
||||
self.mode = mode
|
||||
|
||||
def getPhens(self):
|
||||
return self.phens
|
||||
|
||||
def setPhens(self, phens):
|
||||
self.phens = phens
|
||||
|
||||
def getPils(self):
|
||||
return self.pils
|
||||
|
||||
def setPils(self, pils):
|
||||
self.pils = pils
|
||||
|
||||
def getSigs(self):
|
||||
return self.sigs
|
||||
|
||||
def setSigs(self, sigs):
|
||||
self.sigs = sigs
|
||||
|
||||
def getSites(self):
|
||||
return self.sites
|
||||
|
||||
def setSites(self, sites):
|
||||
self.sites = sites
|
||||
|
|
@ -1,32 +0,0 @@
|
|||
|
||||
|
||||
class DumpActiveTableResponse(object):
|
||||
def __init__(self):
|
||||
self.dump = None
|
||||
self.unfilteredCount = 0
|
||||
self.filteredCount = 0
|
||||
self.message = None
|
||||
|
||||
def getUnfilteredCount(self):
|
||||
return self.unfilteredCount
|
||||
|
||||
def getFilteredCount(self):
|
||||
return self.filteredCount
|
||||
|
||||
def getDump(self):
|
||||
return self.dump
|
||||
|
||||
def getMessage(self):
|
||||
return self.message
|
||||
|
||||
def setUnfilteredCount(self, unfilteredCount):
|
||||
self.unfilteredCount = unfilteredCount
|
||||
|
||||
def setFilteredCount(self, filteredCount):
|
||||
self.filteredCount = filteredCount
|
||||
|
||||
def setDump(self, dump):
|
||||
self.dump = dump
|
||||
|
||||
def setMessage(self, message):
|
||||
self.message = message
|
|
@ -1,26 +0,0 @@
|
|||
|
||||
|
||||
class GetActiveTableDictRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.requestedSiteId = None
|
||||
self.mode = None
|
||||
self.wfos = None
|
||||
|
||||
def getRequestedSiteId(self):
|
||||
return self.requestedSiteId
|
||||
|
||||
def setRequestedSiteId(self, requestedSiteId):
|
||||
self.requestedSiteId = requestedSiteId
|
||||
|
||||
def getMode(self):
|
||||
return self.mode
|
||||
|
||||
def setMode(self, mode):
|
||||
self.mode = mode
|
||||
|
||||
def getWfos(self):
|
||||
return self.wfos
|
||||
|
||||
def setWfos(self, wfos):
|
||||
self.wfos = wfos;
|
|
@ -1,20 +0,0 @@
|
|||
|
||||
|
||||
class GetActiveTableDictResponse(object):
|
||||
|
||||
def __init__(self):
|
||||
self.activeTable = None
|
||||
self.mode = None
|
||||
|
||||
def getActiveTable(self):
|
||||
return self.activeTable
|
||||
|
||||
def setActiveTable(self, activeTable):
|
||||
self.activeTable = activeTable
|
||||
|
||||
def getMode(self):
|
||||
return self.mode
|
||||
|
||||
def setMode(self, mode):
|
||||
self.mode = mode
|
||||
|
|
@ -1,12 +0,0 @@
|
|||
|
||||
|
||||
class GetFourCharSitesRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.sites = None
|
||||
|
||||
def getSites(self):
|
||||
return self.sites
|
||||
|
||||
def setSites(self, sites):
|
||||
self.sites = sites
|
|
@ -1,12 +0,0 @@
|
|||
|
||||
|
||||
class GetFourCharSitesResponse(object):
|
||||
|
||||
def __init__(self):
|
||||
self.sites = None
|
||||
|
||||
def getSites(self):
|
||||
return self.sites
|
||||
|
||||
def setSites(self, sites):
|
||||
self.sites = sites
|
|
@ -1,26 +0,0 @@
|
|||
|
||||
|
||||
class GetVtecAttributeRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.siteId = None
|
||||
self.attribute = None
|
||||
self.defaultValue = None
|
||||
|
||||
def getSiteId(self):
|
||||
return self.siteId
|
||||
|
||||
def setSiteId(self, site):
|
||||
self.siteId = site
|
||||
|
||||
def getAttribute(self):
|
||||
return self.attribute
|
||||
|
||||
def setAttribute(self, attribute):
|
||||
self.attribute = attribute
|
||||
|
||||
def getDefaultValue(self):
|
||||
return self.defaultValue
|
||||
|
||||
def setDefaultValue(self, default):
|
||||
self.defaultValue = default
|
|
@ -1,12 +0,0 @@
|
|||
|
||||
|
||||
class GetVtecAttributeResponse(object):
|
||||
|
||||
def __init__(self):
|
||||
self.value = None
|
||||
|
||||
def getValue(self):
|
||||
return self.value
|
||||
|
||||
def setValue(self, value):
|
||||
self.value = value
|
|
@ -1,15 +0,0 @@
|
|||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# 05/22/2015 4522 randerso Changed to inherit from ActiveTableRecord
|
||||
#
|
||||
|
||||
from . import ActiveTableRecord
|
||||
|
||||
|
||||
class OperationalActiveTableRecord(ActiveTableRecord):
|
||||
|
||||
def __init__(self):
|
||||
super(OperationalActiveTableRecord, self).__init__()
|
|
@ -1,15 +0,0 @@
|
|||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# 05/22/2015 4522 randerso Changed to inherit from ActiveTableRecord
|
||||
#
|
||||
|
||||
from . import ActiveTableRecord
|
||||
|
||||
|
||||
class PracticeActiveTableRecord(ActiveTableRecord):
|
||||
|
||||
def __init__(self):
|
||||
super(PracticeActiveTableRecord, self).__init__()
|
|
@ -1,27 +0,0 @@
|
|||
|
||||
|
||||
class SendPracticeProductRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.drtString = None
|
||||
self.notifyGFE = None
|
||||
self.productText = None
|
||||
|
||||
def getDrtString(self):
|
||||
return self.drtString
|
||||
|
||||
def setDrtString(self, drtString):
|
||||
self.drtString = drtString
|
||||
|
||||
def getNotifyGFE(self):
|
||||
return self.notifyGFE
|
||||
|
||||
def setNotifyGFE(self, notifyGFE):
|
||||
self.notifyGFE = notifyGFE
|
||||
|
||||
def getProductText(self):
|
||||
return self.productText
|
||||
|
||||
def setProductText(self, productText):
|
||||
self.productText = productText
|
||||
|
|
@ -1,34 +0,0 @@
|
|||
# 03/25/14 #2884 randerso Added xxxid to VTECChange
|
||||
|
||||
|
||||
class VTECChange(object):
|
||||
|
||||
def __init__(self):
|
||||
self.site = None
|
||||
self.pil = None
|
||||
self.phensig = None
|
||||
self.xxxid = None
|
||||
|
||||
def getSite(self):
|
||||
return self.site
|
||||
|
||||
def setSite(self, site):
|
||||
self.site = site
|
||||
|
||||
def getPil(self):
|
||||
return self.pil
|
||||
|
||||
def setPil(self, pil):
|
||||
self.pil = pil
|
||||
|
||||
def getPhensig(self):
|
||||
return self.phensig
|
||||
|
||||
def setPhensig(self, phensig):
|
||||
self.phensig = phensig
|
||||
|
||||
def getXxxid(self):
|
||||
return self.xxxid
|
||||
|
||||
def setXxxid(self, xxxid):
|
||||
self.xxxid = xxxid
|
|
@ -1,39 +0,0 @@
|
|||
|
||||
|
||||
class VTECTableChangeNotification(object):
|
||||
|
||||
def __init__(self):
|
||||
self.mode = None
|
||||
self.modTime = None
|
||||
self.modSource = None
|
||||
self.changes = None
|
||||
|
||||
def getMode(self):
|
||||
return self.mode
|
||||
|
||||
def setMode(self, mode):
|
||||
self.mode = mode
|
||||
|
||||
def getModTime(self):
|
||||
return self.modTime
|
||||
|
||||
def setModTime(self, modTime):
|
||||
self.modTime = modTime
|
||||
|
||||
def getModSource(self):
|
||||
return self.modSource
|
||||
|
||||
def setModSource(self, modSource):
|
||||
self.modSource = modSource
|
||||
|
||||
def getChanges(self):
|
||||
return self.changes
|
||||
|
||||
def setChanges(self, changes):
|
||||
self.changes = changes
|
||||
|
||||
def __repr__(self):
|
||||
msg = 'Table Name: ' + str(self.mode) + '\n'
|
||||
msg += 'ModTime: ' + str(self.modTime) + '\n'
|
||||
msg += 'ModSource: ' + str(self.modSource)
|
||||
return msg
|
|
@ -1,39 +0,0 @@
|
|||
|
||||
__all__ = [
|
||||
'request',
|
||||
'response',
|
||||
'ActiveTableKey',
|
||||
'ActiveTableMode',
|
||||
'ActiveTableRecord',
|
||||
'DumpActiveTableRequest',
|
||||
'DumpActiveTableResponse',
|
||||
'GetActiveTableDictRequest',
|
||||
'GetActiveTableDictResponse',
|
||||
'GetFourCharSitesRequest',
|
||||
'GetFourCharSitesResponse',
|
||||
'GetVtecAttributeRequest',
|
||||
'GetVtecAttributeResponse',
|
||||
'OperationalActiveTableRecord',
|
||||
'PracticeActiveTableRecord',
|
||||
'SendPracticeProductRequest',
|
||||
'VTECChange',
|
||||
'VTECTableChangeNotification'
|
||||
]
|
||||
|
||||
from .ActiveTableKey import ActiveTableKey
|
||||
from .ActiveTableRecord import ActiveTableRecord
|
||||
from .ActiveTableMode import ActiveTableMode
|
||||
from .DumpActiveTableRequest import DumpActiveTableRequest
|
||||
from .DumpActiveTableResponse import DumpActiveTableResponse
|
||||
from .GetActiveTableDictRequest import GetActiveTableDictRequest
|
||||
from .GetActiveTableDictResponse import GetActiveTableDictResponse
|
||||
from .GetFourCharSitesRequest import GetFourCharSitesRequest
|
||||
from .GetFourCharSitesResponse import GetFourCharSitesResponse
|
||||
from .GetVtecAttributeRequest import GetVtecAttributeRequest
|
||||
from .GetVtecAttributeResponse import GetVtecAttributeResponse
|
||||
from .OperationalActiveTableRecord import OperationalActiveTableRecord
|
||||
from .PracticeActiveTableRecord import PracticeActiveTableRecord
|
||||
from .SendPracticeProductRequest import SendPracticeProductRequest
|
||||
from .VTECChange import VTECChange
|
||||
from .VTECTableChangeNotification import VTECTableChangeNotification
|
||||
|
|
@ -1,19 +0,0 @@
|
|||
|
||||
|
||||
class ClearPracticeVTECTableRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.siteID = None
|
||||
self.workstationID = None
|
||||
|
||||
def getSiteID(self):
|
||||
return self.siteID
|
||||
|
||||
def setSiteID(self, siteID):
|
||||
self.siteID = siteID
|
||||
|
||||
def getWorkstationID(self):
|
||||
return self.workstationID
|
||||
|
||||
def setWorkstationID(self, workstationID):
|
||||
self.workstationID = workstationID
|
|
@ -1,74 +0,0 @@
|
|||
|
||||
|
||||
class MergeActiveTableRequest(object):
|
||||
|
||||
def __init__(self, incomingRecords=[], tableName='PRACTICE', site=None,
|
||||
timeOffset=0.0, xmlSource=None, fromIngestAT=False,
|
||||
makeBackups=True):
|
||||
self.incomingRecords = incomingRecords
|
||||
self.site = site
|
||||
self.tableName = tableName.upper() if tableName.upper() in ['OPERATIONAL', 'PRACTICE'] else 'PRACTICE'
|
||||
self.timeOffset = float(timeOffset)
|
||||
self.xmlSource = xmlSource
|
||||
self.fromIngestAT = bool(fromIngestAT)
|
||||
self.makeBackups = bool(makeBackups)
|
||||
|
||||
def __repr__(self):
|
||||
retVal = "MergeActiveTableRequest("
|
||||
retVal += repr(self.incomingRecords) + ", "
|
||||
retVal += repr(self.tableName) + ", "
|
||||
retVal += repr(self.site) + ", "
|
||||
retVal += repr(self.timeOffset) + ", "
|
||||
retVal += repr(self.xmlSource) + ", "
|
||||
retVal += repr(self.fromIngestAT) + ", "
|
||||
retVal += repr(self.makeBackups) + ")"
|
||||
return retVal
|
||||
|
||||
def __str__(self):
|
||||
return self.__repr__()
|
||||
|
||||
def getIncomingRecords(self):
|
||||
return self.incomingRecords
|
||||
|
||||
def setIncomingRecords(self, incomingRecords):
|
||||
self.incomingRecords = incomingRecords
|
||||
|
||||
def getTableName(self):
|
||||
return self.tableName
|
||||
|
||||
def setTableName(self, tableName):
|
||||
value = tableName.upper()
|
||||
if value not in ['OPERATIONAL', 'PRACTICE']:
|
||||
raise ValueError("Invalid value " + tableName + " specified for ActiveTableMode.")
|
||||
self.tableName = value
|
||||
|
||||
def getSite(self):
|
||||
return self.site
|
||||
|
||||
def setSite(self, site):
|
||||
self.site = site
|
||||
|
||||
def getTimeOffset(self):
|
||||
return self.timeOffset
|
||||
|
||||
def setTimeOffset(self, timeOffset):
|
||||
self.timeOffset = float(timeOffset)
|
||||
|
||||
def getXmlSource(self):
|
||||
return self.xmlSource
|
||||
|
||||
def setXmlSource(self, xmlSource):
|
||||
self.xmlSource = xmlSource
|
||||
|
||||
def getFromIngestAT(self):
|
||||
return self.fromIngestAT
|
||||
|
||||
def setFromIngestAT(self, fromIngestAT):
|
||||
self.fromIngestAT = bool(fromIngestAT)
|
||||
|
||||
def getMakeBackups(self):
|
||||
return self.makeBackups
|
||||
|
||||
def setMakeBackups(self, makeBackups):
|
||||
self.makeBackups = bool(makeBackups)
|
||||
|
|
@ -1,79 +0,0 @@
|
|||
|
||||
|
||||
class RetrieveRemoteActiveTableRequest(object):
|
||||
|
||||
def __init__(self, serverHost=None, serverPort=0, serverProtocol=None,
|
||||
mhsId=None, siteId=None, ancfAddress=None, bncfAddress=None,
|
||||
transmitScript=None):
|
||||
self.serverHost = serverHost
|
||||
self.serverPort = int(serverPort)
|
||||
self.serverProtocol = serverProtocol
|
||||
self.mhsId = mhsId
|
||||
self.siteId = siteId
|
||||
self.ancfAddress = ancfAddress
|
||||
self.bncfAddress = bncfAddress
|
||||
self.transmitScript = transmitScript
|
||||
|
||||
def __repr__(self):
|
||||
retVal = "RetrieveRemoteActiveTableRequest("
|
||||
retVal += repr(self.serverHost) + ", "
|
||||
retVal += repr(self.serverPort) + ", "
|
||||
retVal += repr(self.serverProtocol) + ", "
|
||||
retVal += repr(self.mhsId) + ", "
|
||||
retVal += repr(self.siteId) + ", "
|
||||
retVal += repr(self.ancfAddress) + ", "
|
||||
retVal += repr(self.bncfAddress) + ", "
|
||||
retVal += repr(self.transmitScript) + ")"
|
||||
return retVal
|
||||
|
||||
def __str__(self):
|
||||
return self.__repr__()
|
||||
|
||||
def getServerHost(self):
|
||||
return self.serverHost
|
||||
|
||||
def setServerHost(self, serverHost):
|
||||
self.serverHost = serverHost
|
||||
|
||||
def getServerPort(self):
|
||||
return self.serverPort
|
||||
|
||||
def setServerPort(self, serverPort):
|
||||
self.serverPort = int(serverPort)
|
||||
|
||||
def getServerProtocol(self):
|
||||
return self.serverProtocol
|
||||
|
||||
def setServerProtocol(self, serverProtocol):
|
||||
self.serverProtocol = serverProtocol
|
||||
|
||||
def getMhsId(self):
|
||||
return self.mhsId
|
||||
|
||||
def setMhsId(self, mhsId):
|
||||
self.mhsId = mhsId
|
||||
|
||||
def getSiteId(self):
|
||||
return self.siteId
|
||||
|
||||
def setSiteId(self, siteId):
|
||||
self.siteId = siteId
|
||||
|
||||
def getAncfAddress(self):
|
||||
return self.ancfAddress
|
||||
|
||||
def setAncfAddress(self, ancfAddress):
|
||||
self.ancfAddress = ancfAddress
|
||||
|
||||
def getBncfAddress(self):
|
||||
return self.bncfAddress
|
||||
|
||||
def setBncfAddress(self, bncfAddress):
|
||||
self.bncfAddress = bncfAddress
|
||||
|
||||
def getTransmitScript(self):
|
||||
return self.transmitScript
|
||||
|
||||
def setTransmitScript(self, transmitScript):
|
||||
self.transmitScript = transmitScript
|
||||
|
|
@ -1,120 +0,0 @@
|
|||
|
||||
|
||||
class SendActiveTableRequest(object):
|
||||
|
||||
def __init__(self, serverHost=None, serverPort=None, serverProtocol=None,
|
||||
serverSite=None, mhsId=None, sites=None, filterSites=None,
|
||||
mhsSites=None, issueTime=None, countDict=None, fileName=None,
|
||||
xmlIncoming=None, transmitScript=None):
|
||||
self.serverHost = serverHost
|
||||
self.serverPort = None if serverPort is None else int(serverPort)
|
||||
self.serverProtocol = serverProtocol
|
||||
self.serverSite = serverSite
|
||||
self.mhsId = mhsId
|
||||
self.sites = sites if sites is not None else []
|
||||
self.filterSites = filterSites if filterSites is not None else []
|
||||
self.mhsSites = mhsSites if mhsSites is not None else []
|
||||
self.issueTime = None if issueTime is None else float(issueTime)
|
||||
self.countDict = countDict if countDict is not None else {}
|
||||
self.fileName = fileName
|
||||
self.xmlIncoming = xmlIncoming
|
||||
self.transmitScript = transmitScript
|
||||
|
||||
def __repr__(self):
|
||||
retVal = "SendActiveTableRequest("
|
||||
retVal += repr(self.serverHost) + ", "
|
||||
retVal += repr(self.serverPort) + ", "
|
||||
retVal += repr(self.serverProtocol) + ", "
|
||||
retVal += repr(self.serverSite) + ", "
|
||||
retVal += repr(self.mhsId) + ", "
|
||||
retVal += repr(self.sites) + ", "
|
||||
retVal += repr(self.filterSites) + ", "
|
||||
retVal += repr(self.mhsSites) + ", "
|
||||
retVal += repr(self.issueTime) + ", "
|
||||
retVal += repr(self.countDict) + ", "
|
||||
retVal += repr(self.fileName) + ", "
|
||||
retVal += repr(self.xmlIncoming) + ", "
|
||||
retVal += repr(self.transmitScript) + ")"
|
||||
return retVal
|
||||
|
||||
def __str__(self):
|
||||
return self.__repr__()
|
||||
|
||||
def getServerHost(self):
|
||||
return self.serverHost
|
||||
|
||||
def setServerHost(self, serverHost):
|
||||
self.serverHost = serverHost
|
||||
|
||||
def getServerPort(self):
|
||||
return self.serverPort
|
||||
|
||||
def setServerPort(self, serverPort):
|
||||
self.serverPort = serverPort
|
||||
|
||||
def getServerProtocol(self):
|
||||
return self.serverProtocol
|
||||
|
||||
def setServerProtocol(self, serverProtocol):
|
||||
self.serverProtocol = serverProtocol
|
||||
|
||||
def getServerSite(self):
|
||||
return self.serverSite
|
||||
|
||||
def setServerSite(self, serverSite):
|
||||
self.serverSite = serverSite
|
||||
|
||||
def getMhsId(self):
|
||||
return self.mhsId
|
||||
|
||||
def setMhsId(self, mhsId):
|
||||
self.mhsId = mhsId
|
||||
|
||||
def getSites(self):
|
||||
return self.sites
|
||||
|
||||
def setSites(self, sites):
|
||||
self.sites = sites
|
||||
|
||||
def getFilterSites(self):
|
||||
return self.filterSites
|
||||
|
||||
def setFilterSites(self, filterSites):
|
||||
self.filterSites = filterSites
|
||||
|
||||
def getMhsSites(self):
|
||||
return self.mhsSites
|
||||
|
||||
def setMhsSites(self, mhsSites):
|
||||
self.mhsSites = mhsSites
|
||||
|
||||
def getIssueTime(self):
|
||||
return self.issueTime
|
||||
|
||||
def setIssueTime(self, issueTime):
|
||||
self.issueTime = issueTime
|
||||
|
||||
def getCountDict(self):
|
||||
return self.countDict
|
||||
|
||||
def setCountDict(self, countDict):
|
||||
self.countDict = countDict
|
||||
|
||||
def getFileName(self):
|
||||
return self.fileName
|
||||
|
||||
def setFileName(self, fileName):
|
||||
self.fileName = fileName
|
||||
|
||||
def getXmlIncoming(self):
|
||||
return self.xmlIncoming
|
||||
|
||||
def setXmlIncoming(self, xmlIncoming):
|
||||
self.xmlIncoming = xmlIncoming
|
||||
|
||||
def getTransmitScript(self):
|
||||
return self.transmitScript
|
||||
|
||||
def setTransmitScript(self, transmitScript):
|
||||
self.transmitScript = transmitScript
|
||||
|
|
@ -1,13 +0,0 @@
|
|||
|
||||
__all__ = [
|
||||
'ClearPracticeVTECTableRequest',
|
||||
'MergeActiveTableRequest',
|
||||
'RetrieveRemoteActiveTableRequest',
|
||||
'SendActiveTableRequest'
|
||||
]
|
||||
|
||||
from .ClearPracticeVTECTableRequest import ClearPracticeVTECTableRequest
|
||||
from .MergeActiveTableRequest import MergeActiveTableRequest
|
||||
from .RetrieveRemoteActiveTableRequest import RetrieveRemoteActiveTableRequest
|
||||
from .SendActiveTableRequest import SendActiveTableRequest
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
|
||||
|
||||
class ActiveTableSharingResponse(object):
|
||||
|
||||
def __init__(self):
|
||||
self.taskSuccess = None
|
||||
self.errorMessage = None
|
||||
|
||||
def getTaskSuccess(self):
|
||||
return self.taskSuccess
|
||||
|
||||
def setTaskSuccess(self, taskSuccess):
|
||||
self.taskSuccess = bool(taskSuccess)
|
||||
|
||||
def getErrorMessage(self):
|
||||
return self.errorMessage
|
||||
|
||||
def setErrorMessage(self, errorMessage):
|
||||
self.errorMessage = errorMessage
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
|
||||
__all__ = [
|
||||
'ActiveTableSharingResponse'
|
||||
]
|
||||
|
||||
from .ActiveTableSharingResponse import ActiveTableSharingResponse
|
||||
|
Loading…
Add table
Reference in a new issue