## # 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. ## ## # This is a base file that is not intended to be overridden. ## ## # uengine is deprecated and will be removed from the system soon. Migrate your # apps to using the Data Access Framework (DAF). ## # # GempakMosaicImgLinkRequest # # This code has been developed by the SIB for use in the AWIPS2 system. # Performs a BaseRequest for a Mosaic image from GEMPAK, and stores # the image data in the uEngineProducts directory for later transfer. # # Usage: # import GempakSatHdrRequest # dataRequest = GempakSatHdrRequest.GempakSatHdrRequest() # dataRequest.setPhysicalElement("...") # dataRequest.setSectorID("...") # dataRequest.setTime("090519/1100") # return dataRequest.execute() # # SOFTWARE HISTORY # # Date Ticket# Engineer Description # ------------ ---------- ----------- -------------------------- # 12/22/09 173_partB mgamazaychikov Initial Creation # 05/20/14 2913 bsteffen Remove unused imports # import BaseRequest from com.raytheon.uf.common.message.response import ResponseMessageGeneric from java.util import ArrayList from gov.noaa.nws.ncep.edex.uengine.utility import GempakConvert class GempakMosaicImgLinkRequest(BaseRequest.BaseRequest): def __init__(self): BaseRequest.BaseRequest.__init__(self, "mosaic") self.format = "db2g" # # Converts time form GEMPAK format to database format # and sets the dataTime parameter for the query # def setTime(self, aDattim): convert = GempakConvert() name = "dataTime" operand = "between" aw2Time = convert.dattimToDbtime(aDattim) timeRange = convert.setTimeRange(aw2Time) self.query.addParameter(name, timeRange, operand) # # Sets the Product Code parameter for the query # def setProduct(self, aProduct): name = "prodName" self.query.addParameter(name, aProduct) # # Sets the Gate Resolution parameter for the query # def setResolution(self, aResolution): name = "resolution" theResolution = "%s" % int ( float(aResolution) * 1000 ) self.query.addParameter(name, theResolution) # # Execute the BaseRequest and calls the appropriate response function # def execute(self): self.query.setCount(1) self.queryResults = self.query.execute() if self.queryResults is None or self.queryResults.size() == 0: self.makeNullResponse() else: return self.__makeResponse() # # Builds the return string content and adds it to the response ArrayList # def __makeResponse(self): from com.raytheon.edex.uengine.tasks.decode import FileIn from com.raytheon.edex.uengine.tasks.output import FileOut from gov.noaa.nws.ncep.edex.plugin.mosaic.uengine import DecodeMosaicImage response = ArrayList() size = self.queryResults.size() for i in range(size): currentQuery = self.queryResults.get(i) # # Call FileIn constructor # fileIn = FileIn(self.plugin, currentQuery) records = fileIn.retrieveGroup() radarImage = DecodeMosaicImage(currentQuery, records, "GEMPAK") # # Call the execute method, getting back the data record # record = radarImage.execute() fileOut = FileOut(record, self.format) # # Execute method of FileOut class stores the data # in a file in uEngineProducts directory with the extension # contained in the string self.format # writeFile = fileOut.execute() # # Separate the file name from the complete path and store in content # content = ("%s" % writeFile).split("/")[len(("%s" % writeFile).split("/") ) - 1] # # Return content wrapped in a generic XML message # response.add(ResponseMessageGeneric(content)) return response # # Returns a string with null response # def makeNullResponse(self): response = ArrayList() response.add(ResponseMessageGeneric("Database Query returned no results")) return response