Omaha #2536 moved com.raytheon.edex.plugin.text to com.raytheon.uf.edex.plugin.text
minor clode cleanup Former-commit-id: f68b6921c08b8bccf355fa9c991c232f2ffa2076
This commit is contained in:
parent
4d1b6ddc00
commit
994f7d820d
41 changed files with 104 additions and 111 deletions
|
@ -33,6 +33,7 @@ Jul 09, 2008 1222 jelkins Split command line loader from class
|
||||||
Jul 24, 2012 #944 dgilling Refactored to support separate
|
Jul 24, 2012 #944 dgilling Refactored to support separate
|
||||||
generation of products and utilities.
|
generation of products and utilities.
|
||||||
Sep 07, 2012 #1150 dgilling Ensure all necessary dirs get created.
|
Sep 07, 2012 #1150 dgilling Ensure all necessary dirs get created.
|
||||||
|
May 12, 2014 2536 bclement renamed text plugin to include uf in name
|
||||||
|
|
||||||
@author: jelkins
|
@author: jelkins
|
||||||
"""
|
"""
|
||||||
|
@ -392,7 +393,7 @@ class Generator():
|
||||||
siteD = SITE_INFO[siteid]
|
siteD = SITE_INFO[siteid]
|
||||||
stationID4 = siteD['fullStationID']
|
stationID4 = siteD['fullStationID']
|
||||||
|
|
||||||
from com.raytheon.edex.plugin.text.dao import AfosToAwipsDao
|
from com.raytheon.uf.edex.plugin.text.dao import AfosToAwipsDao
|
||||||
|
|
||||||
dao = AfosToAwipsDao()
|
dao = AfosToAwipsDao()
|
||||||
response = dao.lookupAfosId(stationID4, None, None)
|
response = dao.lookupAfosId(stationID4, None, None)
|
||||||
|
|
|
@ -20,7 +20,7 @@ Import-Package: com.raytheon.edex.exception,
|
||||||
com.raytheon.uf.edex.database.purge,
|
com.raytheon.uf.edex.database.purge,
|
||||||
org.apache.camel
|
org.apache.camel
|
||||||
Require-Bundle: org.jep;bundle-version="1.0.0",
|
Require-Bundle: org.jep;bundle-version="1.0.0",
|
||||||
com.raytheon.edex.plugin.text,
|
com.raytheon.uf.edex.plugin.text,
|
||||||
com.raytheon.uf.common.site;bundle-version="1.12.1174",
|
com.raytheon.uf.common.site;bundle-version="1.12.1174",
|
||||||
org.springframework;bundle-version="2.5.6",
|
org.springframework;bundle-version="2.5.6",
|
||||||
com.raytheon.uf.edex.database,
|
com.raytheon.uf.edex.database,
|
||||||
|
|
|
@ -23,13 +23,13 @@ import java.text.SimpleDateFormat;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
||||||
import com.raytheon.uf.common.dissemination.OUPRequest;
|
import com.raytheon.uf.common.dissemination.OUPRequest;
|
||||||
import com.raytheon.uf.common.dissemination.OfficialUserProduct;
|
import com.raytheon.uf.common.dissemination.OfficialUserProduct;
|
||||||
import com.raytheon.uf.edex.database.DataAccessLayerException;
|
import com.raytheon.uf.edex.database.DataAccessLayerException;
|
||||||
import com.raytheon.uf.edex.dissemination.transmitted.TransProdHeader;
|
import com.raytheon.uf.edex.dissemination.transmitted.TransProdHeader;
|
||||||
import com.raytheon.uf.edex.dissemination.transmitted.TransmittedProductList;
|
import com.raytheon.uf.edex.dissemination.transmitted.TransmittedProductList;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Utilities for generating a wmo header or tracking headers
|
* Utilities for generating a wmo header or tracking headers
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<projectDescription>
|
<projectDescription>
|
||||||
<name>com.raytheon.edex.plugin.text</name>
|
<name>com.raytheon.uf.edex.plugin.text</name>
|
||||||
<comment></comment>
|
<comment></comment>
|
||||||
<projects>
|
<projects>
|
||||||
</projects>
|
</projects>
|
|
@ -1,8 +1,8 @@
|
||||||
Manifest-Version: 1.0
|
Manifest-Version: 1.0
|
||||||
Bundle-ManifestVersion: 2
|
Bundle-ManifestVersion: 2
|
||||||
Bundle-Name: Text Plug-in
|
Bundle-Name: Text Plug-in
|
||||||
Bundle-SymbolicName: com.raytheon.edex.plugin.text
|
Bundle-SymbolicName: com.raytheon.uf.edex.plugin.text
|
||||||
Bundle-Version: 1.12.1174.qualifier
|
Bundle-Version: 1.14.0.qualifier
|
||||||
Eclipse-RegisterBuddy: com.raytheon.edex.common, com.raytheon.uf.common.serialization
|
Eclipse-RegisterBuddy: com.raytheon.edex.common, com.raytheon.uf.common.serialization
|
||||||
Bundle-Vendor: RAYTHEON
|
Bundle-Vendor: RAYTHEON
|
||||||
Require-Bundle: com.raytheon.edex.textdb,
|
Require-Bundle: com.raytheon.edex.textdb,
|
||||||
|
@ -16,8 +16,8 @@ Require-Bundle: com.raytheon.edex.textdb,
|
||||||
com.raytheon.uf.edex.archive,
|
com.raytheon.uf.edex.archive,
|
||||||
com.raytheon.uf.edex.ndm;bundle-version="1.0.0",
|
com.raytheon.uf.edex.ndm;bundle-version="1.0.0",
|
||||||
com.raytheon.uf.common.localization;bundle-version="1.14.0"
|
com.raytheon.uf.common.localization;bundle-version="1.14.0"
|
||||||
Export-Package: com.raytheon.edex.plugin.text,
|
Export-Package: com.raytheon.uf.edex.plugin.text,
|
||||||
com.raytheon.edex.plugin.text.dao
|
com.raytheon.uf.edex.plugin.text.dao
|
||||||
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
|
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
|
||||||
Import-Package: com.raytheon.uf.common.dataplugin.text,
|
Import-Package: com.raytheon.uf.common.dataplugin.text,
|
||||||
com.raytheon.uf.common.dataplugin.text.db,
|
com.raytheon.uf.common.dataplugin.text.db,
|
|
@ -6,9 +6,9 @@
|
||||||
<bean id="textProperties" class="com.raytheon.uf.common.dataplugin.PluginProperties">
|
<bean id="textProperties" class="com.raytheon.uf.common.dataplugin.PluginProperties">
|
||||||
<property name="pluginName" value="text" />
|
<property name="pluginName" value="text" />
|
||||||
<property name="pluginFQN" value="com.raytheon.uf.common.dataplugin.text" />
|
<property name="pluginFQN" value="com.raytheon.uf.common.dataplugin.text" />
|
||||||
<property name="dao" value="com.raytheon.edex.plugin.text.dao.TextDao" />
|
<property name="dao" value="com.raytheon.uf.edex.plugin.text.dao.TextDao" />
|
||||||
<property name="database" value="fxa"/>
|
<property name="database" value="fxa"/>
|
||||||
<property name="record" value="com.raytheon.edex.plugin.text.TextRecord"/>
|
<property name="record" value="com.raytheon.uf.edex.plugin.text.TextRecord"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="textRegistered" factory-bean="pluginRegistry" factory-method="register"
|
<bean id="textRegistered" factory-bean="pluginRegistry" factory-method="register"
|
|
@ -7,7 +7,7 @@
|
||||||
<constructor-arg value="Ingest.Text.*" />
|
<constructor-arg value="Ingest.Text.*" />
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="textDecoder" class="com.raytheon.edex.plugin.text.TextDecoder">
|
<bean id="textDecoder" class="com.raytheon.uf.edex.plugin.text.TextDecoder">
|
||||||
<property name="pluginName" value="text" />
|
<property name="pluginName" value="text" />
|
||||||
<property name="decoderMode" value="STD" />
|
<property name="decoderMode" value="STD" />
|
||||||
</bean>
|
</bean>
|
||||||
|
@ -25,15 +25,15 @@
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<!-- define the bean that handles automatic faxing of products. -->
|
<!-- define the bean that handles automatic faxing of products. -->
|
||||||
<bean id="autoFaxManager" class="com.raytheon.edex.plugin.text.subscription.AutoFaxManager">
|
<bean id="autoFaxManager" class="com.raytheon.uf.edex.plugin.text.subscription.AutoFaxManager">
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<!-- verify text product info for site, spawns in separate thread to not delay start up -->
|
<!-- verify text product info for site, spawns in separate thread to not delay start up -->
|
||||||
<bean id="textVersionPurge" class="com.raytheon.edex.plugin.text.TextVersionPurge" depends-on="textRegistered"/>
|
<bean id="textVersionPurge" class="com.raytheon.uf.edex.plugin.text.TextVersionPurge" depends-on="textRegistered"/>
|
||||||
|
|
||||||
<!-- Special handler for text plugin archives that bases filenames off
|
<!-- Special handler for text plugin archives that bases filenames off
|
||||||
creation time-->
|
creation time-->
|
||||||
<bean id="textArchiveNamer" class="com.raytheon.edex.plugin.text.maintenance.archiver.TextArchiveFileNameFormatter" />
|
<bean id="textArchiveNamer" class="com.raytheon.uf.edex.plugin.text.maintenance.archiver.TextArchiveFileNameFormatter" />
|
||||||
<bean factory-bean="databaseArchiver" factory-method="registerPluginArchiveFormatter" depends-on="databaseArchiver">
|
<bean factory-bean="databaseArchiver" factory-method="registerPluginArchiveFormatter" depends-on="databaseArchiver">
|
||||||
<constructor-arg value="text" />
|
<constructor-arg value="text" />
|
||||||
<constructor-arg ref="textArchiveNamer" />
|
<constructor-arg ref="textArchiveNamer" />
|
||||||
|
@ -44,8 +44,8 @@
|
||||||
<constructor-arg value="1000" type="java.lang.Integer"/>
|
<constructor-arg value="1000" type="java.lang.Integer"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="afosToAwipsListener" class="com.raytheon.edex.plugin.text.ingest.AfosToAwipsListener" />
|
<bean id="afosToAwipsListener" class="com.raytheon.uf.edex.plugin.text.ingest.AfosToAwipsListener" />
|
||||||
<bean id="afosBrowserListener" class="com.raytheon.edex.plugin.text.ingest.AfosBrowserModelSubscriber" />
|
<bean id="afosBrowserListener" class="com.raytheon.uf.edex.plugin.text.ingest.AfosBrowserModelSubscriber" />
|
||||||
|
|
||||||
<bean factory-bean="ndmProc" factory-method="registerListener">
|
<bean factory-bean="ndmProc" factory-method="registerListener">
|
||||||
<constructor-arg value="afos2awips.txt" />
|
<constructor-arg value="afos2awips.txt" />
|
|
@ -2,32 +2,32 @@
|
||||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||||
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
|
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
|
||||||
|
|
||||||
<bean id="getAfosIdHandler" class="com.raytheon.edex.plugin.text.handler.GetAfosIdHandler" />
|
<bean id="getAfosIdHandler" class="com.raytheon.uf.edex.plugin.text.handler.GetAfosIdHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetAfosIdRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetAfosIdRequest"/>
|
||||||
<constructor-arg ref="getAfosIdHandler"/>
|
<constructor-arg ref="getAfosIdHandler"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="getPartialAfosIdHandler" class="com.raytheon.edex.plugin.text.handler.GetPartialAfosIdHandler" />
|
<bean id="getPartialAfosIdHandler" class="com.raytheon.uf.edex.plugin.text.handler.GetPartialAfosIdHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetPartialAfosIdRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetPartialAfosIdRequest"/>
|
||||||
<constructor-arg ref="getPartialAfosIdHandler"/>
|
<constructor-arg ref="getPartialAfosIdHandler"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="getWmoIdHandler" class="com.raytheon.edex.plugin.text.handler.GetWmoIdHandler" />
|
<bean id="getWmoIdHandler" class="com.raytheon.uf.edex.plugin.text.handler.GetWmoIdHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetWmoIdRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetWmoIdRequest"/>
|
||||||
<constructor-arg ref="getWmoIdHandler"/>
|
<constructor-arg ref="getWmoIdHandler"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="insertStdTextProduct" class="com.raytheon.edex.plugin.text.handler.InsertStdTextProductHandler"/>
|
<bean id="insertStdTextProduct" class="com.raytheon.uf.edex.plugin.text.handler.InsertStdTextProductHandler"/>
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.InsertStdTextProductRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.InsertStdTextProductRequest"/>
|
||||||
<constructor-arg ref="insertStdTextProduct"/>
|
<constructor-arg ref="insertStdTextProduct"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<!-- Instantiate the handler class for StdTextProductRequestHandler -->
|
<!-- Instantiate the handler class for StdTextProductRequestHandler -->
|
||||||
<bean id="stdTextProduct" class="com.raytheon.edex.plugin.text.handler.StdTextProductRequestHandler"/>
|
<bean id="stdTextProduct" class="com.raytheon.uf.edex.plugin.text.handler.StdTextProductRequestHandler"/>
|
||||||
<!-- Register the handler class with the StdTextProductServerHandlerRegister. -->
|
<!-- Register the handler class with the StdTextProductServerHandlerRegister. -->
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.StdTextProductServerRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.StdTextProductServerRequest"/>
|
||||||
|
@ -35,25 +35,25 @@
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<!-- Instantiate the handler class for TextProductInfoRequestHandler -->
|
<!-- Instantiate the handler class for TextProductInfoRequestHandler -->
|
||||||
<bean id="textProductInfo" class="com.raytheon.edex.plugin.text.handler.TextProductInfoCreateHandler"/>
|
<bean id="textProductInfo" class="com.raytheon.uf.edex.plugin.text.handler.TextProductInfoCreateHandler"/>
|
||||||
<!-- Register the handler class with the TextProductInfoHandlerRegister. -->
|
<!-- Register the handler class with the TextProductInfoHandlerRegister. -->
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.TextProductInfoCreateRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.TextProductInfoCreateRequest"/>
|
||||||
<constructor-arg ref="textProductInfo"/>
|
<constructor-arg ref="textProductInfo"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="sendFaxRequestHandler" class="com.raytheon.edex.plugin.text.handler.SendFaxRequestHandler" />
|
<bean id="sendFaxRequestHandler" class="com.raytheon.uf.edex.plugin.text.handler.SendFaxRequestHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.SendFaxRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.SendFaxRequest"/>
|
||||||
<constructor-arg ref="sendFaxRequestHandler"/>
|
<constructor-arg ref="sendFaxRequestHandler"/>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<bean id="autoFaxRequestHandler" class="com.raytheon.edex.plugin.text.handler.AutoFaxRequestHandler" />
|
<bean id="autoFaxRequestHandler" class="com.raytheon.uf.edex.plugin.text.handler.AutoFaxRequestHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.AutoFaxRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.AutoFaxRequest"/>
|
||||||
<constructor-arg ref="autoFaxRequestHandler"/>
|
<constructor-arg ref="autoFaxRequestHandler"/>
|
||||||
</bean>
|
</bean>
|
||||||
<bean id="getAutoFaxRecordsRequestHandler" class="com.raytheon.edex.plugin.text.handler.GetAutoFaxRecordsRequestHandler" />
|
<bean id="getAutoFaxRecordsRequestHandler" class="com.raytheon.uf.edex.plugin.text.handler.GetAutoFaxRecordsRequestHandler" />
|
||||||
<bean factory-bean="handlerRegistry" factory-method="register">
|
<bean factory-bean="handlerRegistry" factory-method="register">
|
||||||
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetAutoFaxRecordsRequest"/>
|
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.GetAutoFaxRecordsRequest"/>
|
||||||
<constructor-arg ref="getAutoFaxRecordsRequestHandler"/>
|
<constructor-arg ref="getAutoFaxRecordsRequestHandler"/>
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text;
|
package com.raytheon.uf.edex.plugin.text;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
||||||
|
@ -36,7 +36,7 @@ package com.raytheon.edex.plugin.text;
|
||||||
*/
|
*/
|
||||||
|
|
||||||
public class TextConstants {
|
public class TextConstants {
|
||||||
public static final String PLUGIN_NAME = "com.raytheon.edex.plugin.text";
|
public static final String PLUGIN_NAME = "com.raytheon.uf.edex.plugin.text";
|
||||||
|
|
||||||
public static final String CATEGORY = "TextPlugin";
|
public static final String CATEGORY = "TextPlugin";
|
||||||
}
|
}
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text;
|
package com.raytheon.uf.edex.plugin.text;
|
||||||
|
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
import java.io.FileInputStream;
|
import java.io.FileInputStream;
|
||||||
|
@ -27,6 +27,7 @@ import java.io.InputStream;
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
import java.util.Date;
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
@ -42,20 +43,18 @@ import org.apache.commons.logging.LogFactory;
|
||||||
import com.raytheon.edex.esb.Headers;
|
import com.raytheon.edex.esb.Headers;
|
||||||
import com.raytheon.edex.exception.DecoderException;
|
import com.raytheon.edex.exception.DecoderException;
|
||||||
import com.raytheon.edex.plugin.AbstractDecoder;
|
import com.raytheon.edex.plugin.AbstractDecoder;
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.TextSeparatorFactory;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.WMOMessageSeparator;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
||||||
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
||||||
import com.raytheon.uf.common.dataplugin.PluginException;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
|
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
|
||||||
import com.raytheon.uf.common.time.DataTime;
|
import com.raytheon.uf.common.time.DataTime;
|
||||||
import com.raytheon.uf.edex.core.props.PropertiesFactory;
|
import com.raytheon.uf.edex.core.props.PropertiesFactory;
|
||||||
import com.raytheon.uf.edex.database.DataAccessLayerException;
|
import com.raytheon.uf.edex.database.DataAccessLayerException;
|
||||||
import com.raytheon.uf.edex.decodertools.time.TimeTools;
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.WMOMessageSeparator;
|
||||||
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
||||||
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
|
|
||||||
|
@ -80,6 +79,7 @@ import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
* Jul 16, 2013 16323 D. Friedman Use concurrent map
|
* Jul 16, 2013 16323 D. Friedman Use concurrent map
|
||||||
* Aug 30, 2013 2298 rjpeter Make getPluginName abstract
|
* Aug 30, 2013 2298 rjpeter Make getPluginName abstract
|
||||||
* Mar 14, 2014 2652 skorolev Changed logging for skipped headers.
|
* Mar 14, 2014 2652 skorolev Changed logging for skipped headers.
|
||||||
|
* May 12, 2014 2536 bclement added createTextRecord(), removed deprecated code
|
||||||
* </pre>
|
* </pre>
|
||||||
*
|
*
|
||||||
* @author
|
* @author
|
||||||
|
@ -128,7 +128,7 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
*
|
*
|
||||||
* @see com.raytheon.edex.plugin.IMessageDecoder#decode()
|
* @see com.raytheon.edex.uf.plugin.IMessageDecoder#decode()
|
||||||
*/
|
*/
|
||||||
public PluginDataObject[] writeTextProduct(StdTextProduct textProduct)
|
public PluginDataObject[] writeTextProduct(StdTextProduct textProduct)
|
||||||
throws DecoderException {
|
throws DecoderException {
|
||||||
|
@ -143,12 +143,9 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
boolean success = textdb.writeProduct(textProduct);
|
boolean success = textdb.writeProduct(textProduct);
|
||||||
|
|
||||||
if (success) {
|
if (success) {
|
||||||
pdo = new TextRecord();
|
String productId = textProduct.getCccid()
|
||||||
pdo.setProductId(textProduct.getCccid()
|
+ textProduct.getNnnid() + textProduct.getXxxid();
|
||||||
+ textProduct.getNnnid() + textProduct.getXxxid());
|
pdo = createTextRecord(productId, textProduct.getRefTime());
|
||||||
DataTime dt = new DataTime(
|
|
||||||
TimeTools.newCalendar(textProduct.getRefTime()));
|
|
||||||
pdo.setDataTime(dt);
|
|
||||||
} else {
|
} else {
|
||||||
// throw new Exception("product already exists");
|
// throw new Exception("product already exists");
|
||||||
}
|
}
|
||||||
|
@ -160,11 +157,6 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
|
|
||||||
if (pdo != null) {
|
if (pdo != null) {
|
||||||
pdo.setTraceId(traceId);
|
pdo.setTraceId(traceId);
|
||||||
try {
|
|
||||||
pdo.constructDataURI();
|
|
||||||
} catch (PluginException e) {
|
|
||||||
logger.error("Unable to construct dataURI", e);
|
|
||||||
}
|
|
||||||
logger.debug(traceId + " - " + pdo);
|
logger.debug(traceId + " - " + pdo);
|
||||||
|
|
||||||
returnObjects = new TextRecord[1];
|
returnObjects = new TextRecord[1];
|
||||||
|
@ -176,6 +168,21 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
return returnObjects;
|
return returnObjects;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Construct a new text record with the given product ID and refTime
|
||||||
|
*
|
||||||
|
* @param productId
|
||||||
|
* @param refTime
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
private static TextRecord createTextRecord(String productId, long refTime) {
|
||||||
|
TextRecord pdo = new TextRecord();
|
||||||
|
pdo.setProductId(productId);
|
||||||
|
DataTime dt = new DataTime(new Date(refTime));
|
||||||
|
pdo.setDataTime(dt);
|
||||||
|
return pdo;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
*
|
*
|
||||||
|
@ -299,12 +306,9 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
operationalMode, headers);
|
operationalMode, headers);
|
||||||
|
|
||||||
if (writeTime != Long.MIN_VALUE) {
|
if (writeTime != Long.MIN_VALUE) {
|
||||||
pdo = new TextRecord();
|
String productId = rptData.getAfosProdId()
|
||||||
pdo.setProductId(rptData.getAfosProdId()
|
.toString();
|
||||||
.toString());
|
pdo = createTextRecord(productId, writeTime);
|
||||||
DataTime dt = new DataTime(
|
|
||||||
TimeTools.newCalendar(writeTime));
|
|
||||||
pdo.setDataTime(dt);
|
|
||||||
stored++;
|
stored++;
|
||||||
} else {
|
} else {
|
||||||
// throw new
|
// throw new
|
||||||
|
@ -320,12 +324,6 @@ public class TextDecoder extends AbstractDecoder {
|
||||||
|
|
||||||
if (pdo != null) {
|
if (pdo != null) {
|
||||||
pdo.setTraceId(traceId);
|
pdo.setTraceId(traceId);
|
||||||
try {
|
|
||||||
pdo.constructDataURI();
|
|
||||||
} catch (PluginException e) {
|
|
||||||
logger.error("Unable to construct dataURI", e);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
logger.debug(traceId + " - " + pdo);
|
logger.debug(traceId + " - " + pdo);
|
||||||
reports.add(pdo);
|
reports.add(pdo);
|
||||||
}
|
}
|
|
@ -17,14 +17,13 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text;
|
package com.raytheon.uf.edex.plugin.text;
|
||||||
|
|
||||||
import javax.persistence.Access;
|
import javax.persistence.Access;
|
||||||
import javax.persistence.AccessType;
|
import javax.persistence.AccessType;
|
||||||
import javax.persistence.Column;
|
import javax.persistence.Column;
|
||||||
import javax.xml.bind.annotation.XmlElement;
|
import javax.xml.bind.annotation.XmlElement;
|
||||||
|
|
||||||
import com.raytheon.uf.common.dataplugin.IDecoderGettable;
|
|
||||||
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
||||||
import com.raytheon.uf.common.dataplugin.annotations.DataURI;
|
import com.raytheon.uf.common.dataplugin.annotations.DataURI;
|
||||||
import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
|
import com.raytheon.uf.common.serialization.annotations.DynamicSerialize;
|
||||||
|
@ -42,6 +41,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
|
||||||
* May 07, 2013 1869 bsteffen Remove dataURI column from
|
* May 07, 2013 1869 bsteffen Remove dataURI column from
|
||||||
* PluginDataObject.
|
* PluginDataObject.
|
||||||
* Aug 30, 2013 2298 rjpeter Make getPluginName abstract
|
* Aug 30, 2013 2298 rjpeter Make getPluginName abstract
|
||||||
|
* May 12, 2014 2536 bclement removed IDecoderGettable
|
||||||
*
|
*
|
||||||
* </pre>
|
* </pre>
|
||||||
*
|
*
|
||||||
|
@ -94,14 +94,6 @@ public class TextRecord extends PluginDataObject {
|
||||||
this.productId = productId;
|
this.productId = productId;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public IDecoderGettable getDecoderGettable() {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Column
|
@Column
|
||||||
@Access(AccessType.PROPERTY)
|
@Access(AccessType.PROPERTY)
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text;
|
package com.raytheon.uf.edex.plugin.text;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
|
@ -18,7 +18,7 @@
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
|
|
||||||
package com.raytheon.edex.plugin.text.dao;
|
package com.raytheon.uf.edex.plugin.text.dao;
|
||||||
|
|
||||||
import java.sql.Connection;
|
import java.sql.Connection;
|
||||||
import java.sql.PreparedStatement;
|
import java.sql.PreparedStatement;
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.dao;
|
package com.raytheon.uf.edex.plugin.text.dao;
|
||||||
|
|
||||||
import java.util.Calendar;
|
import java.util.Calendar;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
|
@ -17,15 +17,15 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.request.GetAfosIdRequest;
|
import com.raytheon.uf.common.dataplugin.text.request.GetAfosIdRequest;
|
||||||
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
|
@ -17,15 +17,15 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.request.GetPartialAfosIdRequest;
|
import com.raytheon.uf.common.dataplugin.text.request.GetPartialAfosIdRequest;
|
||||||
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -17,15 +17,15 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.request.GetWmoIdRequest;
|
import com.raytheon.uf.common.dataplugin.text.request.GetWmoIdRequest;
|
||||||
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -17,11 +17,10 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.TextConstants;
|
|
||||||
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
|
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
||||||
import com.raytheon.uf.common.dataplugin.text.request.InsertStdTextProductRequest;
|
import com.raytheon.uf.common.dataplugin.text.request.InsertStdTextProductRequest;
|
||||||
|
@ -33,7 +32,8 @@ import com.raytheon.uf.edex.core.EDEXUtil;
|
||||||
import com.raytheon.uf.edex.core.EdexException;
|
import com.raytheon.uf.edex.core.EdexException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* Handles InsertStdTextProductRequests by placing them onto the LDAD queue and
|
||||||
|
* sending product alarm alerts as specified by the request
|
||||||
*
|
*
|
||||||
* <pre>
|
* <pre>
|
||||||
*
|
*
|
||||||
|
@ -43,6 +43,7 @@ import com.raytheon.uf.edex.core.EdexException;
|
||||||
* Nov 12, 2009 mschenke Initial creation
|
* Nov 12, 2009 mschenke Initial creation
|
||||||
* 01Jun2010 cjeanbap Added operational mode functionality.
|
* 01Jun2010 cjeanbap Added operational mode functionality.
|
||||||
* 08Jul2010 2187 cjeanbap Added operational mode functionality.
|
* 08Jul2010 2187 cjeanbap Added operational mode functionality.
|
||||||
|
* May 12, 2014 2536 bclement removed unused import
|
||||||
* </pre>
|
* </pre>
|
||||||
*
|
*
|
||||||
* @author mschenke
|
* @author mschenke
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import com.raytheon.edex.textdb.fax.FaxSender;
|
import com.raytheon.edex.textdb.fax.FaxSender;
|
||||||
import com.raytheon.uf.common.dataplugin.text.request.SendFaxRequest;
|
import com.raytheon.uf.common.dataplugin.text.request.SendFaxRequest;
|
|
@ -18,11 +18,10 @@
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
|
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.TextConstants;
|
|
||||||
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
|
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.OperationalStdTextProduct;
|
import com.raytheon.uf.common.dataplugin.text.db.OperationalStdTextProduct;
|
||||||
|
@ -37,7 +36,8 @@ import com.raytheon.uf.edex.core.EDEXUtil;
|
||||||
import com.raytheon.uf.edex.core.EdexException;
|
import com.raytheon.uf.edex.core.EdexException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* Handles StdTextProductServerRequest by placing them onto the LDAD queue and
|
||||||
|
* sending product alarm alerts as specified by the request
|
||||||
*
|
*
|
||||||
* <pre>
|
* <pre>
|
||||||
*
|
*
|
||||||
|
@ -49,6 +49,7 @@ import com.raytheon.uf.edex.core.EdexException;
|
||||||
* 07Jul2010 2187 cjeanbap Submit AfosId to AlarmAlertUtil.
|
* 07Jul2010 2187 cjeanbap Submit AfosId to AlarmAlertUtil.
|
||||||
* 02Aug2010 2187 cjeanbap Move AlarmAlertUtil.sendProductAlarmAlert()
|
* 02Aug2010 2187 cjeanbap Move AlarmAlertUtil.sendProductAlarmAlert()
|
||||||
* outside of if-statement.
|
* outside of if-statement.
|
||||||
|
* May 12, 2014 2536 bclement removed unused import
|
||||||
*
|
*
|
||||||
* </pre>
|
* </pre>
|
||||||
*
|
*
|
|
@ -1,4 +1,4 @@
|
||||||
package com.raytheon.edex.plugin.text.handler;
|
package com.raytheon.uf.edex.plugin.text.handler;
|
||||||
|
|
||||||
import com.raytheon.edex.textdb.dao.TextProductInfoDao;
|
import com.raytheon.edex.textdb.dao.TextProductInfoDao;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.TextProductInfo;
|
import com.raytheon.uf.common.dataplugin.text.db.TextProductInfo;
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl;
|
package com.raytheon.uf.edex.plugin.text.impl;
|
||||||
|
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
|
||||||
|
@ -25,14 +25,14 @@ import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.esb.Headers;
|
import com.raytheon.edex.esb.Headers;
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.StdCollectiveSeparator;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.StdTextSeparator;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.TextDecoderMode;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.UACollectiveSeparator;
|
|
||||||
import com.raytheon.edex.plugin.text.impl.separator.WMOMessageSeparator;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
||||||
import com.raytheon.uf.edex.core.props.PropertiesFactory;
|
import com.raytheon.uf.edex.core.props.PropertiesFactory;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.StdCollectiveSeparator;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.StdTextSeparator;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.TextDecoderMode;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.UACollectiveSeparator;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.separator.WMOMessageSeparator;
|
||||||
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
|
|
||||||
/**
|
/**
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl;
|
package com.raytheon.uf.edex.plugin.text.impl;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl.separator;
|
package com.raytheon.uf.edex.plugin.text.impl.separator;
|
||||||
|
|
||||||
import java.util.regex.Matcher;
|
import java.util.regex.Matcher;
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
@ -26,10 +26,10 @@ import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.esb.Headers;
|
import com.raytheon.edex.esb.Headers;
|
||||||
import com.raytheon.edex.plugin.text.impl.TextSeparatorFactory;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
||||||
import com.raytheon.uf.common.site.SiteMap;
|
import com.raytheon.uf.common.site.SiteMap;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
|
||||||
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
||||||
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
|
|
||||||
|
@ -87,7 +87,7 @@ public class StdCollectiveSeparator extends WMOMessageSeparator {
|
||||||
/*
|
/*
|
||||||
* (non-Javadoc)
|
* (non-Javadoc)
|
||||||
*
|
*
|
||||||
* @see com.raytheon.edex.plugin.text.impl.separator.WMOMessageSeparator#
|
* @see com.raytheon.uf.edex.plugin.text.impl.separator.WMOMessageSeparator#
|
||||||
* createProductId()
|
* createProductId()
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
|
@ -117,7 +117,7 @@ public class StdCollectiveSeparator extends WMOMessageSeparator {
|
||||||
/*
|
/*
|
||||||
* (non-Javadoc)
|
* (non-Javadoc)
|
||||||
*
|
*
|
||||||
* @see com.raytheon.edex.plugin.text.impl.separator.WMOMessageSeparator#
|
* @see com.raytheon.uf.edex.plugin.text.impl.separator.WMOMessageSeparator#
|
||||||
* identifyReports(byte[], com.raytheon.edex.esb.Headers)
|
* identifyReports(byte[], com.raytheon.edex.esb.Headers)
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
|
@ -17,16 +17,16 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl.separator;
|
package com.raytheon.uf.edex.plugin.text.impl.separator;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.esb.Headers;
|
import com.raytheon.edex.esb.Headers;
|
||||||
import com.raytheon.edex.plugin.text.impl.TextSeparatorFactory;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
||||||
import com.raytheon.uf.common.site.SiteMap;
|
import com.raytheon.uf.common.site.SiteMap;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
|
||||||
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
||||||
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
|
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl.separator;
|
package com.raytheon.uf.edex.plugin.text.impl.separator;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl.separator;
|
package com.raytheon.uf.edex.plugin.text.impl.separator;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
@ -28,9 +28,9 @@ import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.esb.Headers;
|
import com.raytheon.edex.esb.Headers;
|
||||||
import com.raytheon.edex.plugin.text.impl.TextSeparatorFactory;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
|
||||||
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
import com.raytheon.uf.edex.wmo.message.AFOSProductId;
|
||||||
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
import com.raytheon.uf.edex.wmo.message.WMOHeader;
|
||||||
|
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.impl.separator;
|
package com.raytheon.uf.edex.plugin.text.impl.separator;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.ingest;
|
package com.raytheon.uf.edex.plugin.text.ingest;
|
||||||
|
|
||||||
import java.io.BufferedReader;
|
import java.io.BufferedReader;
|
||||||
import java.io.BufferedWriter;
|
import java.io.BufferedWriter;
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.ingest;
|
package com.raytheon.uf.edex.plugin.text.ingest;
|
||||||
|
|
||||||
import java.io.BufferedReader;
|
import java.io.BufferedReader;
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
|
@ -30,7 +30,6 @@ import java.util.List;
|
||||||
|
|
||||||
import org.apache.commons.lang.StringUtils;
|
import org.apache.commons.lang.StringUtils;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.dao.AfosToAwipsDao;
|
|
||||||
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwipsId;
|
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwipsId;
|
||||||
|
@ -38,6 +37,7 @@ import com.raytheon.uf.common.status.IUFStatusHandler;
|
||||||
import com.raytheon.uf.common.status.UFStatus;
|
import com.raytheon.uf.common.status.UFStatus;
|
||||||
import com.raytheon.uf.common.status.UFStatus.Priority;
|
import com.raytheon.uf.common.status.UFStatus.Priority;
|
||||||
import com.raytheon.uf.edex.ndm.ingest.INationalDatasetSubscriber;
|
import com.raytheon.uf.edex.ndm.ingest.INationalDatasetSubscriber;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Updates the afos_to_awips table in the database based on the supplied
|
* Updates the afos_to_awips table in the database based on the supplied
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.maintenance.archiver;
|
package com.raytheon.uf.edex.plugin.text.maintenance.archiver;
|
||||||
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
|
|
@ -17,7 +17,7 @@
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
* further licensing information.
|
* further licensing information.
|
||||||
**/
|
**/
|
||||||
package com.raytheon.edex.plugin.text.subscription;
|
package com.raytheon.uf.edex.plugin.text.subscription;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
@ -26,7 +26,6 @@ import java.util.List;
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|
||||||
import com.raytheon.edex.plugin.text.TextRecord;
|
|
||||||
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
|
||||||
import com.raytheon.edex.textdb.fax.AutoFaxDao;
|
import com.raytheon.edex.textdb.fax.AutoFaxDao;
|
||||||
import com.raytheon.edex.textdb.fax.FaxSender;
|
import com.raytheon.edex.textdb.fax.FaxSender;
|
||||||
|
@ -36,6 +35,7 @@ import com.raytheon.uf.common.dataplugin.text.AutoFaxContainer;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.AutoFaxRecord;
|
import com.raytheon.uf.common.dataplugin.text.db.AutoFaxRecord;
|
||||||
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
|
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
|
||||||
import com.raytheon.uf.edex.core.EdexException;
|
import com.raytheon.uf.edex.core.EdexException;
|
||||||
|
import com.raytheon.uf.edex.plugin.text.TextRecord;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TODO Add Description
|
* TODO Add Description
|
|
@ -44,7 +44,7 @@
|
||||||
unpack="false"/>
|
unpack="false"/>
|
||||||
|
|
||||||
<plugin
|
<plugin
|
||||||
id="com.raytheon.edex.plugin.text"
|
id="com.raytheon.uf.edex.plugin.text"
|
||||||
download-size="0"
|
download-size="0"
|
||||||
install-size="0"
|
install-size="0"
|
||||||
version="0.0.0"
|
version="0.0.0"
|
||||||
|
|
Loading…
Add table
Reference in a new issue