Omaha #2536 merged edex.textdb into text plugins

Former-commit-id: 5a3e156e6c3307e5e631fd54c86bd1ae337c2f7c
This commit is contained in:
Brian Clements 2014-05-19 15:12:53 -05:00
parent eff69410eb
commit da7d5888b0
85 changed files with 355 additions and 376 deletions

View file

@ -45,13 +45,6 @@
version="0.0.0"
unpack="false"/>
<plugin
id="com.raytheon.edex.textdb"
download-size="0"
install-size="0"
version="0.0.0"
unpack="false"/>
<plugin
id="com.raytheon.viz.texteditor"
download-size="0"

View file

@ -6,9 +6,7 @@ Bundle-Version: 1.14.0.qualifier
Eclipse-RegisterBuddy: com.raytheon.edex.common, com.raytheon.uf.common.serialization
Bundle-Activator: com.raytheon.viz.texteditor.Activator
Bundle-Vendor: Raytheon
Require-Bundle: com.raytheon.edex.common,
com.raytheon.edex.textdb,
com.raytheon.uf.common.activetable,
Require-Bundle: com.raytheon.uf.common.activetable,
com.raytheon.uf.common.auth;bundle-version="1.12.1174",
com.raytheon.uf.common.dataplugin.radar;bundle-version="1.0.0",
com.raytheon.uf.common.dataplugin.text;bundle-version="1.11.30",

View file

@ -35,8 +35,6 @@ import java.util.Set;
import java.util.SortedSet;
import java.util.TreeSet;
import com.raytheon.edex.textdb.dbapi.impl.AFOS_CLASS;
import com.raytheon.edex.textdb.dbapi.impl.AFOS_ORIGIN;
import com.raytheon.uf.common.dataplugin.radar.util.RadarTextProductUtil;
import com.raytheon.uf.common.dataplugin.radar.util.RadarsInUseUtil;
import com.raytheon.uf.common.localization.IPathManager;
@ -49,6 +47,8 @@ import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
import com.raytheon.uf.viz.core.localization.LocalizationManager;
import com.raytheon.viz.texteditor.util.AFOS_CLASS;
import com.raytheon.viz.texteditor.util.AFOS_ORIGIN;
/**
* Singleton class that contains information related to querying for or updating

View file

@ -22,11 +22,11 @@ package com.raytheon.viz.texteditor.command;
import java.util.ArrayList;
import java.util.List;
import com.raytheon.edex.textdb.dbapi.impl.AFOSParser;
import com.raytheon.uf.common.dataplugin.text.StdTextProductContainer;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.common.dataplugin.text.dbsrv.IQueryTransport;
import com.raytheon.uf.common.dataplugin.text.request.ExecuteAfosCmdRequest;
import com.raytheon.uf.common.dataplugin.text.util.AFOSParser;
import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;

View file

@ -19,7 +19,7 @@
**/
package com.raytheon.viz.texteditor.command;
import com.raytheon.edex.textdb.dbapi.impl.AFOSParser;
import com.raytheon.uf.common.dataplugin.text.util.AFOSParser;
import com.raytheon.uf.viz.core.localization.LocalizationManager;
import com.raytheon.viz.texteditor.util.TextEditorUtil;

View file

@ -59,8 +59,6 @@ import org.eclipse.swt.widgets.Menu;
import org.eclipse.swt.widgets.ScrollBar;
import org.eclipse.swt.widgets.Shell;
import com.raytheon.edex.textdb.dbapi.impl.AFOS_CLASS;
import com.raytheon.edex.textdb.dbapi.impl.AFOS_ORIGIN;
import com.raytheon.uf.common.dataplugin.text.dbsrv.IQueryTransport;
import com.raytheon.uf.common.dataplugin.text.dbsrv.TextDBQuery;
import com.raytheon.uf.common.message.Message;
@ -77,6 +75,8 @@ import com.raytheon.viz.texteditor.TextDisplayModel;
import com.raytheon.viz.texteditor.command.CommandFactory;
import com.raytheon.viz.texteditor.msgs.IAfosBrowserCallback;
import com.raytheon.viz.texteditor.msgs.ITextWorkstationCallback;
import com.raytheon.viz.texteditor.util.AFOS_CLASS;
import com.raytheon.viz.texteditor.util.AFOS_ORIGIN;
import com.raytheon.viz.texteditor.util.TextEditorUtil;
import com.raytheon.viz.ui.dialogs.CaveSWTDialog;

View file

@ -111,7 +111,6 @@ import org.eclipse.swt.widgets.Text;
import org.eclipse.ui.PlatformUI;
import org.eclipse.ui.menus.IMenuService;
import com.raytheon.edex.textdb.dbapi.impl.AFOSParser;
import com.raytheon.uf.common.activetable.SendPracticeProductRequest;
import com.raytheon.uf.common.dataplugin.text.RemoteRetrievalResponse;
import com.raytheon.uf.common.dataplugin.text.alarms.AlarmAlertProduct;
@ -121,6 +120,7 @@ import com.raytheon.uf.common.dataplugin.text.dbsrv.IQueryTransport;
import com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest;
import com.raytheon.uf.common.dataplugin.text.request.StdTextProductServerRequest;
import com.raytheon.uf.common.dataplugin.text.request.TextProductInfoCreateRequest;
import com.raytheon.uf.common.dataplugin.text.util.AFOSParser;
import com.raytheon.uf.common.dissemination.OUPRequest;
import com.raytheon.uf.common.dissemination.OUPResponse;
import com.raytheon.uf.common.dissemination.OUPTestRequest;

View file

@ -17,18 +17,20 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.viz.texteditor.util;
import java.util.HashMap;
/**
* TODO Add Description
* Automation of Field Operations and Services classification enum
*
* <pre>
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Nov 13, 2008 jkorman Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to viz.texteditor
*
* </pre>
*
* @author jkorman

View file

@ -17,18 +17,20 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.viz.texteditor.util;
import java.util.HashMap;
/**
* TODO Add Description
* Automation of Field Operations and Services origin enum
*
* <pre>
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Nov 13, 2008 jkorman Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to viz.texteditor
*
* </pre>
*
* @author jkorman

View file

@ -223,11 +223,6 @@
<appender-ref ref="purge"/>
</logger>
<logger name="com.raytheon.edex.textdb.dao.StdTextProductDao.PurgeLogger" additivity="false">
<level value="INFO"/>
<appender-ref ref="purge"/>
</logger>
<logger name="RouteFailedLog" additivity="false">
<level value="WARN"/>
<appender-ref ref="RouteFailedLog"/>

View file

@ -23,7 +23,6 @@ Bundle-RequiredExecutionEnvironment: JavaSE-1.6
Import-Package: com.raytheon.edex.plugin.obs,
com.raytheon.edex.plugin.obs.metar,
com.raytheon.edex.plugin.obs.metar.util,
com.raytheon.edex.textdb.dbapi.impl,
com.raytheon.uf.common.dataplugin.obs.metar,
com.raytheon.uf.common.dataplugin.obs.metar.util,
com.raytheon.uf.common.dataplugin.sfcobs,

View file

@ -1,7 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"/>
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
<classpathentry kind="src" path="src"/>
<classpathentry kind="output" path="bin"/>
</classpath>

View file

@ -1,11 +0,0 @@
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
org.eclipse.jdt.core.compiler.compliance=1.7
org.eclipse.jdt.core.compiler.debug.lineNumber=generate
org.eclipse.jdt.core.compiler.debug.localVariable=generate
org.eclipse.jdt.core.compiler.debug.sourceFile=generate
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
org.eclipse.jdt.core.compiler.source=1.7

View file

@ -1,25 +0,0 @@
Manifest-Version: 1.0
Bundle-ManifestVersion: 2
Bundle-Name: Textdb Plug-in
Bundle-SymbolicName: com.raytheon.edex.textdb
Bundle-Version: 1.12.1174.qualifier
Eclipse-RegisterBuddy: com.raytheon.edex.common, com.raytheon.uf.common.serialization
Bundle-Vendor: RAYTHEON
Require-Bundle: com.raytheon.edex.common,
com.raytheon.uf.common.localization,
org.apache.commons.lang,
com.raytheon.uf.edex.decodertools;bundle-version="1.0.0",
javax.persistence,
com.raytheon.uf.common.dataplugin.text,
com.raytheon.uf.common.status;bundle-version="1.12.1122",
com.raytheon.uf.common.site;bundle-version="1.0.0",
com.raytheon.uf.edex.ndm;bundle-version="1.0.0"
Export-Package: com.raytheon.edex.textdb.alarms,
com.raytheon.edex.textdb.dao,
com.raytheon.edex.textdb.dbapi.impl,
com.raytheon.edex.textdb.fax
Bundle-RequiredExecutionEnvironment: JavaSE-1.7
Import-Package: com.raytheon.uf.common.message,
com.raytheon.uf.common.serialization.comm,
com.raytheon.uf.common.wmo,
org.apache.commons.logging

View file

@ -1,5 +0,0 @@
source.. = src/
output.. = bin/
bin.includes = META-INF/,\
.,\
res/

View file

@ -1,52 +0,0 @@
<beans xmlns="http://www.springframework.org/schema/beans"
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
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="textDBStaticDataListener" class="com.raytheon.edex.textdb.ingest.TextDBStaticDataSubscriber">
<constructor-arg value="jms-generic:topic:textDBFilesChanged"/>
</bean>
<bean id="siteMapListener" class="com.raytheon.edex.textdb.ingest.SiteMapNationalDatasetSubscriber" />
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="bit_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="collective_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="exclusionProductList.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="ispan_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="station_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="upair_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="afos_lookup_table.dat" />
<constructor-arg ref="siteMapListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="national_category_table.template" />
<constructor-arg ref="siteMapListener" />
</bean>
<camelContext id="textDbContext"
xmlns="http://camel.apache.org/schema/spring"
errorHandlerRef="errorHandler">
<route id="textDBStaticSetDirty">
<from uri="jms-generic:topic:textDBFilesChanged"/>
<bean ref="textDBStaticDataListener" method="setDirty"/>
</route>
</camelContext>
</beans>

View file

@ -1,78 +0,0 @@
<beans xmlns="http://www.springframework.org/schema/beans"
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
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="executeAfosCmdHandler" class="com.raytheon.edex.textdb.handler.ExecuteAfosCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteAfosCmdRequest"/>
<constructor-arg ref="executeAfosCmdHandler"/>
</bean>
<bean id="executeAwipsCmdHandler" class="com.raytheon.edex.textdb.handler.ExecuteAwipsCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteAwipsCmdRequest"/>
<constructor-arg ref="executeAwipsCmdHandler"/>
</bean>
<bean id="executeWmoCmdHandler" class="com.raytheon.edex.textdb.handler.ExecuteWmoCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteWmoCmdRequest"/>
<constructor-arg ref="executeWmoCmdHandler"/>
</bean>
<bean id="writeProductHandler" class="com.raytheon.edex.textdb.handler.WriteProductHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.WriteProductRequest"/>
<constructor-arg ref="writeProductHandler"/>
</bean>
<bean id="remoteRetrievalHandler" class="com.raytheon.edex.textdb.handler.RemoteRetrievalHandler">
<property name="rrManager" ref="remoteRetrievalManager" />
</bean>
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest"/>
<constructor-arg ref="remoteRetrievalHandler"/>
</bean>
<bean id="remoteRetrievalManager" class="com.raytheon.edex.textdb.handler.RemoteRetrievalManager">
<!-- <property name="remoteRetrievalExternalURI" value="direct-vm:remoteRetrievalExternalRoute" /> -->
<property name="rrDelegate" ref="textdbRemoteRetrievalTarget" />
</bean>
<!-- JmsPooled* do not work... -->
<bean id="jms-mhs" class="org.apache.camel.component.jms.JmsComponent">
<constructor-arg ref="jmsMhsConfig" />
<property name="taskExecutor" ref="mhsThreadPool" />
</bean>
<bean id="mhsThreadPool"
class="com.raytheon.uf.edex.esb.camel.spring.JmsThreadPoolTaskExecutor">
<property name="corePoolSize" value="1" />
<property name="maxPoolSize" value="1" />
</bean>
<bean id="jmsMhsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="recoveryInterval" value="1000"/>
<property name="connectionFactory" ref="amqConnectionFactory" />
<property name="destinationResolver" ref="qpidNoDurableResolver"/>
</bean>
<camelContext id="textdb-remote-retrieval" xmlns="http://camel.apache.org/schema/spring"
errorHandlerRef="errorHandler">
<proxy id="textdbRemoteRetrievalTarget"
serviceInterface="com.raytheon.edex.textdb.handler.RemoteRetrievalManager$IRRDelegate"
serviceUrl="direct-vm:remoteRetrievalExternalRoute" />
<route id="remoteRetrievalExternal">
<from uri="direct-vm:remoteRetrievalExternalRoute" />
<!-- Convert from BeanInvocation if needed. -->
<convertBodyTo type="com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest" />
<bean ref="serializationUtil" method="transformToThrift" />
<to uri="jms-mhs:queue:fxa.mhs.request?requestTimeout=122000" pattern="InOut" />
<bean ref="serializationUtil" method="transformFromThrift" />
</route>
</camelContext>
</beans>

View file

@ -1,42 +0,0 @@
/**
* 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.
**/
package com.raytheon.edex.textdb;
/**
* TODO Add Description
*
* <pre>
*
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Jul 6, 2010 4687 cjeanbap Initial creation
*
* </pre>
*
* @author mschenke
* @version 1.0
*/
public class TextConstants {
public static final String PLUGIN_NAME = "com.raytheon.edex.textdb";
public static final String CATEGORY = "TextDBPlugin";
}

View file

@ -1,33 +0,0 @@
package com.raytheon.edex.textdb.handler;
import com.raytheon.edex.textdb.handler.RemoteRetrievalManager.RRJob;
import com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
public class RemoteRetrievalHandler implements
IRequestHandler<RemoteRetrievalRequest> {
private RemoteRetrievalManager rrManager;
@Override
public Object handleRequest(RemoteRetrievalRequest request)
throws Exception {
RRJob job = rrManager.submitRequest(request);
return job.waitResponse();
}
/**
* @return the rrManager
*/
public RemoteRetrievalManager getRrManager() {
return rrManager;
}
/**
* @param rrManager the rrManager to set
*/
public void setRrManager(RemoteRetrievalManager rrManager) {
this.rrManager = rrManager;
}
}

View file

@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"/>
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
<classpathentry kind="src" path="src"/>
<classpathentry kind="output" path="bin"/>

View file

@ -1,7 +1,11 @@
#Tue Feb 02 15:27:55 CST 2010
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
org.eclipse.jdt.core.compiler.compliance=1.6
org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
org.eclipse.jdt.core.compiler.compliance=1.7
org.eclipse.jdt.core.compiler.debug.lineNumber=generate
org.eclipse.jdt.core.compiler.debug.localVariable=generate
org.eclipse.jdt.core.compiler.debug.sourceFile=generate
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
org.eclipse.jdt.core.compiler.source=1.6
org.eclipse.jdt.core.compiler.source=1.7

View file

@ -4,7 +4,7 @@ Bundle-Name: Textdb Plug-in
Bundle-SymbolicName: com.raytheon.uf.common.dataplugin.text
Bundle-Version: 1.14.0.qualifier
Bundle-Vendor: RAYTHEON
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
Bundle-RequiredExecutionEnvironment: JavaSE-1.7
Eclipse-RegisterBuddy: com.raytheon.uf.common.serialization
Require-Bundle: com.raytheon.uf.common.serialization,
org.hibernate,
@ -14,6 +14,9 @@ Import-Package: com.raytheon.uf.common.dataplugin.persist,
com.raytheon.uf.common.serialization,
com.raytheon.uf.common.serialization.annotations,
com.raytheon.uf.common.serialization.comm,
com.raytheon.uf.common.site,
com.raytheon.uf.common.status,
com.raytheon.uf.common.util,
com.raytheon.uf.common.wmo,
javax.persistence,
org.apache.commons.lang.builder
@ -21,5 +24,6 @@ Export-Package: com.raytheon.uf.common.dataplugin.text;uses:="com.raytheon.uf.co
com.raytheon.uf.common.dataplugin.text.alarms,
com.raytheon.uf.common.dataplugin.text.db;uses:="com.raytheon.uf.common.dataplugin.persist,com.raytheon.uf.common.wmo,com.raytheon.uf.common.serialization",
com.raytheon.uf.common.dataplugin.text.dbsrv,
com.raytheon.uf.common.dataplugin.text.request;uses:="com.raytheon.uf.common.serialization.comm"
com.raytheon.uf.common.dataplugin.text.request;uses:="com.raytheon.uf.common.serialization.comm",
com.raytheon.uf.common.dataplugin.text.util

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.uf.common.dataplugin.text.util;
import com.raytheon.uf.common.site.SiteMap;
@ -93,6 +93,8 @@ import com.raytheon.uf.common.site.SiteMap;
* Jul 29, 2011 10237 R. Ferrel parseCommand now properly validates
* commands with large index.
* Jan 29, 2014 DR14595 mgamazaychikov Added handling of M: command
* May 20, 2014 2536 bclement moved from edex.textdb to common.dataplugin.text
*
* </pre>
*
* @author jkorman

View file

@ -18,6 +18,7 @@ Import-Package: com.raytheon.edex.util,
com.raytheon.uf.edex.database,
com.raytheon.uf.edex.database.dao,
com.raytheon.uf.edex.database.plugin,
com.raytheon.uf.edex.plugin.text.db,
org.quartz
Export-Package: com.raytheon.uf.edex.ohd,
com.raytheon.uf.edex.ohd.reportalarm,
@ -32,5 +33,4 @@ Require-Bundle: com.raytheon.edex.common,
com.raytheon.uf.common.units;bundle-version="1.0.0",
com.raytheon.uf.common.dataplugin.shef,
com.raytheon.uf.common.dataplugin.text,
com.raytheon.edex.textdb,
com.raytheon.uf.edex.decodertools

View file

@ -24,12 +24,12 @@ import java.io.IOException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.ohd.AppsDefaults;
import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.time.util.TimeUtil;
import com.raytheon.uf.common.util.FileUtil;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* Provides SHEF with the ability to generate alert/alarms report products and

View file

@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"/>
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
<classpathentry kind="src" path="src"/>
<classpathentry kind="output" path="bin"/>

View file

@ -1,7 +1,11 @@
#Thu Mar 26 10:26:04 CDT 2009
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
org.eclipse.jdt.core.compiler.compliance=1.6
org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
org.eclipse.jdt.core.compiler.compliance=1.7
org.eclipse.jdt.core.compiler.debug.lineNumber=generate
org.eclipse.jdt.core.compiler.debug.localVariable=generate
org.eclipse.jdt.core.compiler.debug.sourceFile=generate
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
org.eclipse.jdt.core.compiler.source=1.6
org.eclipse.jdt.core.compiler.source=1.7

View file

@ -5,8 +5,7 @@ Bundle-SymbolicName: com.raytheon.uf.edex.plugin.text
Bundle-Version: 1.14.0.qualifier
Eclipse-RegisterBuddy: com.raytheon.edex.common, com.raytheon.uf.common.serialization
Bundle-Vendor: RAYTHEON
Require-Bundle: com.raytheon.edex.textdb,
org.apache.commons.lang,
Require-Bundle: org.apache.commons.lang,
com.raytheon.edex.common,
javax.persistence,
com.raytheon.uf.common.serialization.comm,
@ -18,12 +17,15 @@ Require-Bundle: com.raytheon.edex.textdb,
com.raytheon.uf.common.localization;bundle-version="1.14.0"
Export-Package: com.raytheon.uf.edex.plugin.text,
com.raytheon.uf.edex.plugin.text.dao,
com.raytheon.uf.edex.plugin.text.db,
com.raytheon.uf.edex.plugin.text.dbsrv
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
Bundle-RequiredExecutionEnvironment: JavaSE-1.7
Import-Package: com.raytheon.uf.common.dataplugin.text,
com.raytheon.uf.common.dataplugin.text.alarms,
com.raytheon.uf.common.dataplugin.text.db,
com.raytheon.uf.common.dataplugin.text.dbsrv,
com.raytheon.uf.common.dataplugin.text.request,
com.raytheon.uf.common.dataplugin.text.util,
com.raytheon.uf.common.message,
com.raytheon.uf.common.wmo,
org.apache.commons.logging

View file

@ -38,7 +38,7 @@
<property name="sessionFactory" ref="fxaSessionFactory" />
</bean>
<bean id="autoFaxDao" class="com.raytheon.edex.textdb.fax.AutoFaxDao">
<bean id="autoFaxDao" class="com.raytheon.uf.edex.plugin.text.fax.AutoFaxDao">
<property name="autoFaxNotifyURI" value="jms-generic:topic:autofax.notify"/>
</bean>

View file

@ -73,6 +73,45 @@
<constructor-arg ref="afosBrowserListener" />
</bean>
<!-- textdb -->
<bean id="textDBStaticDataListener" class="com.raytheon.uf.edex.plugin.text.ingest.TextDBStaticDataSubscriber">
<constructor-arg value="jms-generic:topic:textDBFilesChanged"/>
</bean>
<bean id="siteMapListener" class="com.raytheon.uf.edex.plugin.text.ingest.SiteMapNationalDatasetSubscriber" />
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="bit_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="collective_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="exclusionProductList.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="ispan_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="station_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="upair_table.dat" />
<constructor-arg ref="textDBStaticDataListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="afos_lookup_table.dat" />
<constructor-arg ref="siteMapListener" />
</bean>
<bean factory-bean="ndmProc" factory-method="registerListener">
<constructor-arg value="national_category_table.template" />
<constructor-arg ref="siteMapListener" />
</bean>
<camelContext id="text-camel"
xmlns="http://camel.apache.org/schema/spring"
errorHandlerRef="errorHandler">
@ -209,6 +248,11 @@
</doCatch>
</doTry>
</route>
<route id="textDBStaticSetDirty">
<from uri="jms-generic:topic:textDBFilesChanged"/>
<bean ref="textDBStaticDataListener" method="setDirty"/>
</route>
</camelContext>
<camelContext id="clustered-text-camel"

View file

@ -1,6 +1,7 @@
<beans xmlns="http://www.springframework.org/schema/beans"
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
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="getAfosIdHandler" class="com.raytheon.uf.edex.plugin.text.handler.GetAfosIdHandler" />
@ -66,8 +67,67 @@
<property name="byteLimitInMB" value="${textdbsrv.byteLimitInMB}"/>
</bean>
<bean id="executeAfosCmdHandler" class="com.raytheon.uf.edex.plugin.text.handler.ExecuteAfosCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteAfosCmdRequest"/>
<constructor-arg ref="executeAfosCmdHandler"/>
</bean>
<bean id="executeAwipsCmdHandler" class="com.raytheon.uf.edex.plugin.text.handler.ExecuteAwipsCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteAwipsCmdRequest"/>
<constructor-arg ref="executeAwipsCmdHandler"/>
</bean>
<bean id="executeWmoCmdHandler" class="com.raytheon.uf.edex.plugin.text.handler.ExecuteWmoCmdHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.ExecuteWmoCmdRequest"/>
<constructor-arg ref="executeWmoCmdHandler"/>
</bean>
<bean id="writeProductHandler" class="com.raytheon.uf.edex.plugin.text.handler.WriteProductHandler" />
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.WriteProductRequest"/>
<constructor-arg ref="writeProductHandler"/>
</bean>
<bean id="remoteRetrievalHandler" class="com.raytheon.uf.edex.plugin.text.handler.RemoteRetrievalHandler">
<property name="rrManager" ref="remoteRetrievalManager" />
</bean>
<bean factory-bean="handlerRegistry" factory-method="register">
<constructor-arg value="com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest"/>
<constructor-arg ref="remoteRetrievalHandler"/>
</bean>
<bean id="remoteRetrievalManager" class="com.raytheon.uf.edex.plugin.text.handler.RemoteRetrievalManager">
<!-- <property name="remoteRetrievalExternalURI" value="direct-vm:remoteRetrievalExternalRoute" /> -->
<property name="rrDelegate" ref="textdbRemoteRetrievalTarget" />
</bean>
<!-- JmsPooled* do not work... -->
<bean id="jms-mhs" class="org.apache.camel.component.jms.JmsComponent">
<constructor-arg ref="jmsMhsConfig" />
<property name="taskExecutor" ref="mhsThreadPool" />
</bean>
<bean id="mhsThreadPool"
class="com.raytheon.uf.edex.esb.camel.spring.JmsThreadPoolTaskExecutor">
<property name="corePoolSize" value="1" />
<property name="maxPoolSize" value="1" />
</bean>
<bean id="jmsMhsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="recoveryInterval" value="1000"/>
<property name="connectionFactory" ref="amqConnectionFactory" />
<property name="destinationResolver" ref="qpidNoDurableResolver"/>
</bean>
<camelContext id="textdbsrv-request-camel" xmlns="http://camel.apache.org/schema/spring" errorHandlerRef="errorHandler">
<proxy id="textdbRemoteRetrievalTarget"
serviceInterface="com.raytheon.uf.edex.plugin.text.handler.RemoteRetrievalManager$IRRDelegate"
serviceUrl="direct-vm:remoteRetrievalExternalRoute" />
<endpoint id="textdbsrvXml_from"
uri="jetty:http://0.0.0.0:${HTTP_PORT}/services/textdbsrv?disableStreamCache=true" />
@ -75,5 +135,14 @@
<from uri="ref:textdbsrvXml_from" />
<bean ref="textDbSrvWrapper" method="executeTextDBMessage" />
</route>
<route id="remoteRetrievalExternal">
<from uri="direct-vm:remoteRetrievalExternalRoute" />
<!-- Convert from BeanInvocation if needed. -->
<convertBodyTo type="com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest" />
<bean ref="serializationUtil" method="transformToThrift" />
<to uri="jms-mhs:queue:fxa.mhs.request?requestTimeout=122000" pattern="InOut" />
<bean ref="serializationUtil" method="transformFromThrift" />
</route>
</camelContext>
</beans>

View file

@ -43,8 +43,6 @@ import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.exception.DecoderException;
import com.raytheon.edex.plugin.AbstractDecoder;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
import com.raytheon.uf.common.dataplugin.PluginDataObject;
import com.raytheon.uf.common.dataplugin.text.AfosWmoIdDataContainer;
import com.raytheon.uf.common.dataplugin.text.db.AfosToAwips;
@ -55,7 +53,9 @@ import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.core.props.PropertiesFactory;
import com.raytheon.uf.edex.database.DataAccessLayerException;
import com.raytheon.uf.edex.plugin.text.dao.AfosToAwipsDao;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
import com.raytheon.uf.edex.plugin.text.impl.separator.WMOMessageSeparator;
/**

View file

@ -24,8 +24,8 @@ import java.util.HashSet;
import java.util.List;
import java.util.Set;
import com.raytheon.edex.textdb.dao.StdTextProductDao;
import com.raytheon.uf.edex.database.purge.PurgeLogger;
import com.raytheon.uf.edex.plugin.text.dao.StdTextProductDao;
/**
* TODO Add Description

View file

@ -18,7 +18,7 @@
* further licensing information.
**/
package com.raytheon.edex.textdb.dao;
package com.raytheon.uf.edex.plugin.text.dao;
import java.util.ArrayList;
import java.util.List;
@ -42,6 +42,7 @@ import com.raytheon.uf.edex.database.dao.DaoConfig;
* 09/04/07 400 garmendariz Initial Check in
* Oct 1, 2008 1538 jkorman Added additional functionality.
* 08/31/10 2103 cjeanbap Updated criteria field of primary key.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -18,7 +18,7 @@
* further licensing information.
**/
package com.raytheon.edex.textdb.dao;
package com.raytheon.uf.edex.plugin.text.dao;
import java.math.BigInteger;
import java.sql.Connection;
@ -88,6 +88,7 @@ import com.raytheon.uf.edex.decodertools.time.TimeTools;
* 23May2012 14952 rferrel Added cccnnnxxxByRefTime.
* 03Oct2012 15244 mgamazaychikov Added the fix to query the appropriate table
* (operational or practice)
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author garmendariz

View file

@ -25,8 +25,6 @@ import java.util.List;
import java.util.Map;
import com.raytheon.edex.db.dao.DefaultPluginDao;
import com.raytheon.edex.textdb.dao.StdTextProductDao;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.PluginException;
import com.raytheon.uf.common.dataquery.db.QueryParam.QueryOperand;
import com.raytheon.uf.common.time.util.TimeUtil;
@ -34,6 +32,7 @@ import com.raytheon.uf.edex.database.DataAccessLayerException;
import com.raytheon.uf.edex.database.processor.IDatabaseProcessor;
import com.raytheon.uf.edex.database.purge.PurgeLogger;
import com.raytheon.uf.edex.database.query.DatabaseQuery;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* DAO for text products

View file

@ -18,7 +18,7 @@
* further licensing information.
**/
package com.raytheon.edex.textdb.dao;
package com.raytheon.uf.edex.plugin.text.dao;
import java.util.List;
@ -44,6 +44,7 @@ import com.raytheon.uf.edex.database.dao.DaoConfig;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* 09/04/07 400 garmendariz Initial Check in
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -18,7 +18,7 @@
* further licensing information.
**/
package com.raytheon.edex.textdb.dao;
package com.raytheon.uf.edex.plugin.text.dao;
import java.util.ArrayList;
import java.util.List;
@ -43,6 +43,7 @@ import com.raytheon.uf.edex.database.dao.DaoConfig;
* 09/04/07 400 garmendariz Initial Check in
* Oct 1, 2008 1538 jkorman Added additional functionality.
* Aug 9, 2010 3944 cjeanbap Added method, queryAllWatchWarn.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author garmendariz

View file

@ -17,15 +17,16 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.uf.edex.plugin.text.db;
/**
*
* <pre>
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Jul 10, 2009 2191 rjpeter Initial implementation.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*
* @author rjpeter

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.uf.edex.plugin.text.db;
import java.util.ArrayList;
import java.util.Calendar;
@ -28,21 +28,23 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.textdb.dao.StateMatchDao;
import com.raytheon.edex.textdb.dao.StdTextProductDao;
import com.raytheon.edex.textdb.dao.TextProductInfoDao;
import com.raytheon.edex.textdb.dao.WatchWarnDao;
import com.raytheon.uf.common.dataplugin.text.db.OperationalStdTextProduct;
import com.raytheon.uf.common.dataplugin.text.db.PracticeStdTextProduct;
import com.raytheon.uf.common.dataplugin.text.db.StateMatch;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.common.dataplugin.text.db.TextProductInfo;
import com.raytheon.uf.common.dataplugin.text.db.WatchWarn;
import com.raytheon.uf.common.dataplugin.text.util.AFOSParser;
import com.raytheon.uf.common.site.SiteMap;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.common.wmo.WMOTimeParser;
import com.raytheon.uf.edex.core.props.PropertiesFactory;
import com.raytheon.uf.edex.plugin.text.dao.StateMatchDao;
import com.raytheon.uf.edex.plugin.text.dao.StdTextProductDao;
import com.raytheon.uf.edex.plugin.text.dao.TextProductInfoDao;
import com.raytheon.uf.edex.plugin.text.dao.WatchWarnDao;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
/**
* Text Database.
@ -71,6 +73,7 @@ import com.raytheon.uf.edex.core.props.PropertiesFactory;
* Feb 18, 2014 2652 skorolev Corrected writeProduct for WMO header if archive is allowed. Deleted unused code.
* May 14, 2014 2536 bclement moved WMO Header to common, removed TimeTools usage
* May 15, 2014 2536 bclement moved asciiToHex() hexToAscii() and getProperty() to PropConverter
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author jkorman

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.alarms;
package com.raytheon.uf.edex.plugin.text.dbsrv.impl;
import java.text.DateFormat;
import java.text.ParseException;
@ -45,6 +45,7 @@ import com.raytheon.uf.edex.core.EdexException;
* 15Feb2010 4426 MW Fegan Added over-ride of sendProductAlarmAlert(...)
* 08Jul2010 2187 cjeanbap Added Operational mode functionality.
* 23May2012 14952 rferrel Added reference time.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -22,7 +22,6 @@ package com.raytheon.uf.edex.plugin.text.dbsrv.impl;
import java.util.List;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.db.StateMatch;
import com.raytheon.uf.common.dataplugin.text.dbsrv.ICommandExecutor;
import com.raytheon.uf.common.dataplugin.text.dbsrv.PropConverter;
@ -31,6 +30,7 @@ import com.raytheon.uf.common.dataplugin.text.dbsrv.TextDBSrvCommandTags;
import com.raytheon.uf.common.message.Header;
import com.raytheon.uf.common.message.Message;
import com.raytheon.uf.common.message.Property;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
*

View file

@ -33,8 +33,6 @@ import javax.xml.bind.JAXBException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.common.dataplugin.text.dbsrv.ICommandExecutor;
import com.raytheon.uf.common.dataplugin.text.dbsrv.PropConverter;
@ -51,6 +49,7 @@ import com.raytheon.uf.common.site.SiteMap;
import com.raytheon.uf.common.time.util.TimeUtil;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* Handles database interactions with the Text DB's standard text products

View file

@ -20,7 +20,6 @@
package com.raytheon.uf.edex.plugin.text.dbsrv.impl;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.dbsrv.ICommandExecutor;
import com.raytheon.uf.common.dataplugin.text.dbsrv.PropConverter;
import com.raytheon.uf.common.dataplugin.text.dbsrv.TextDBSrvCommandTags;
@ -29,6 +28,7 @@ import com.raytheon.uf.common.message.Header;
import com.raytheon.uf.common.message.Message;
import com.raytheon.uf.common.message.Property;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* Manipulates version headers on textdbsrv messages

View file

@ -26,7 +26,6 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.db.WatchWarn;
import com.raytheon.uf.common.dataplugin.text.dbsrv.ICommandExecutor;
import com.raytheon.uf.common.dataplugin.text.dbsrv.PropConverter;
@ -37,6 +36,7 @@ import com.raytheon.uf.common.message.Message;
import com.raytheon.uf.common.message.Property;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* Processes warning textdbsrv command messages

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.fax;
package com.raytheon.uf.edex.plugin.text.fax;
import java.util.ArrayList;
import java.util.HashMap;
@ -38,7 +38,7 @@ import com.raytheon.uf.common.status.UFStatus.Priority;
import com.raytheon.uf.edex.core.EDEXUtil;
/**
* TODO Add Description
* Data access object for storing and retrieving AutoFaxRecords
*
* <pre>
*
@ -47,6 +47,7 @@ import com.raytheon.uf.edex.core.EDEXUtil;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Nov 2, 2010 bfarmer Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.fax;
package com.raytheon.uf.edex.plugin.text.fax;
import java.io.BufferedWriter;
import java.io.File;
@ -27,7 +27,7 @@ import java.io.IOException;
import com.raytheon.uf.common.util.RunProcess;
/**
* TODO Add Description
* Sends FAX to number using LDAD system
*
* <pre>
*
@ -38,6 +38,7 @@ import com.raytheon.uf.common.util.RunProcess;
* Oct 28, 2010 bfarmer Initial creation
* Sep 19, 2011 10955 rferrel Use RunProcess
* Jan 10, 2012 4550 mgamazaychikov Fixed the sshCommand
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -22,11 +22,11 @@ package com.raytheon.uf.edex.plugin.text.handler;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.textdb.fax.AutoFaxDao;
import com.raytheon.uf.common.dataplugin.PluginException;
import com.raytheon.uf.common.dataplugin.text.db.AutoFaxRecord;
import com.raytheon.uf.common.dataplugin.text.request.AutoFaxRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.fax.AutoFaxDao;
/**
* TODO Add Description

View file

@ -17,15 +17,15 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.handler;
package com.raytheon.uf.edex.plugin.text.handler;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.StdTextProductContainer;
import com.raytheon.uf.common.dataplugin.text.request.ExecuteAfosCmdRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* TODO Add Description
* Request handler for ExecuteAfosCmdRequests. Forwards request to textdb.
*
* <pre>
*
@ -35,6 +35,7 @@ import com.raytheon.uf.common.serialization.comm.IRequestHandler;
* Feb 2, 2010 njensen Initial creation
* Apri 14, 2010 4734 mhuang Returned StdTextProductContainer object
* May 23, 2012 14952 rferrel Added refTime.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author njensen

View file

@ -17,17 +17,17 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.handler;
package com.raytheon.uf.edex.plugin.text.handler;
import java.util.List;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.common.dataplugin.text.request.ExecuteAwipsCmdRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* TODO Add Description
* Request handler for ExecuteAwipsCmdRequests. Forwards request to textdb.
*
* <pre>
*
@ -36,6 +36,7 @@ import com.raytheon.uf.common.serialization.comm.IRequestHandler;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Aug 4, 2011 rferrel Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -17,17 +17,17 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.handler;
package com.raytheon.uf.edex.plugin.text.handler;
import java.util.List;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.common.dataplugin.text.request.ExecuteAwipsCmdRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
/**
* TODO Add Description
* Request handler for ExecuteAwipsCmdRequests. Forwards request to textdb.
*
* <pre>
*
@ -36,6 +36,7 @@ import com.raytheon.uf.common.serialization.comm.IRequestHandler;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Aug 5, 2011 rferrel Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -22,11 +22,11 @@ package com.raytheon.uf.edex.plugin.text.handler;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.textdb.fax.AutoFaxDao;
import com.raytheon.uf.common.dataplugin.PluginException;
import com.raytheon.uf.common.dataplugin.text.AutoFaxContainer;
import com.raytheon.uf.common.dataplugin.text.request.GetAutoFaxRecordsRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.fax.AutoFaxDao;
/**
* TODO Add Description

View file

@ -21,8 +21,6 @@ package com.raytheon.uf.edex.plugin.text.handler;
import java.util.Date;
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.request.InsertStdTextProductRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.common.status.IUFStatusHandler;
@ -30,6 +28,8 @@ import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
import com.raytheon.uf.edex.plugin.text.dbsrv.impl.AlarmAlertUtil;
/**
* Handles InsertStdTextProductRequests by placing them onto the LDAD queue and

View file

@ -0,0 +1,69 @@
/**
* 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.
**/
package com.raytheon.uf.edex.plugin.text.handler;
import com.raytheon.uf.common.dataplugin.text.request.RemoteRetrievalRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.handler.RemoteRetrievalManager.RRJob;
/**
* Request handler for RemoteRetrievalRequests. Forwards request to
* RemoteRetrievalManager for delegation.
*
* <pre>
*
* SOFTWARE HISTORY
*
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* ??? Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*
* @version 1.0
*/
public class RemoteRetrievalHandler implements
IRequestHandler<RemoteRetrievalRequest> {
private RemoteRetrievalManager rrManager;
@Override
public Object handleRequest(RemoteRetrievalRequest request)
throws Exception {
RRJob job = rrManager.submitRequest(request);
return job.waitResponse();
}
/**
* @return the rrManager
*/
public RemoteRetrievalManager getRrManager() {
return rrManager;
}
/**
* @param rrManager the rrManager to set
*/
public void setRrManager(RemoteRetrievalManager rrManager) {
this.rrManager = rrManager;
}
}

View file

@ -1,4 +1,23 @@
package com.raytheon.edex.textdb.handler;
/**
* 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.
**/
package com.raytheon.uf.edex.plugin.text.handler;
import java.util.HashMap;
@ -8,6 +27,22 @@ import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
/**
* Manages remote retrieval job delegation.
*
* <pre>
*
* SOFTWARE HISTORY
*
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* ??? Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*
* @version 1.0
*/
public class RemoteRetrievalManager {
public interface IRRDelegate {
RemoteRetrievalResponse retrieve(RemoteRetrievalRequest req) throws Exception;

View file

@ -19,12 +19,13 @@
**/
package com.raytheon.uf.edex.plugin.text.handler;
import com.raytheon.edex.textdb.fax.FaxSender;
import com.raytheon.uf.common.dataplugin.text.request.SendFaxRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.fax.FaxSender;
/**
* TODO Add Description
* Request handler for SendFaxRequests. Sends FAX message using
* {@link FaxSender}
*
* <pre>
*
@ -33,6 +34,7 @@ import com.raytheon.uf.common.serialization.comm.IRequestHandler;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Oct 21, 2010 bfarmer Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -22,8 +22,6 @@ package com.raytheon.uf.edex.plugin.text.handler;
import java.util.Date;
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
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.PracticeStdTextProduct;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
@ -34,6 +32,8 @@ import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
import com.raytheon.uf.edex.plugin.text.dbsrv.impl.AlarmAlertUtil;
/**
* Handles StdTextProductServerRequest by placing them onto the LDAD queue and

View file

@ -1,9 +1,9 @@
package com.raytheon.uf.edex.plugin.text.handler;
import com.raytheon.edex.textdb.dao.TextProductInfoDao;
import com.raytheon.uf.common.dataplugin.text.db.TextProductInfo;
import com.raytheon.uf.common.dataplugin.text.request.TextProductInfoCreateRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.edex.plugin.text.dao.TextProductInfoDao;
/**
* TODO Add Description Register request and handler beans in text-request.xml.

View file

@ -17,13 +17,11 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.handler;
package com.raytheon.uf.edex.plugin.text.handler;
import java.util.Date;
import java.util.logging.Logger;
import com.raytheon.edex.textdb.alarms.AlarmAlertUtil;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.uf.common.dataplugin.text.request.WriteProductRequest;
import com.raytheon.uf.common.serialization.comm.IRequestHandler;
import com.raytheon.uf.common.status.IUFStatusHandler;
@ -31,9 +29,11 @@ import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
import com.raytheon.uf.edex.plugin.text.dbsrv.impl.AlarmAlertUtil;
/**
* TODO Add Description
* Request handler for WriteProductRequests. Forwards request to textdb.
*
* <pre>
*
@ -45,6 +45,7 @@ import com.raytheon.uf.edex.core.EdexException;
* Jul 02, 2010 4687 cjeanbap Added watch warn queue.
* May 23, 2012 14952 rferrel Alarm Alerts date now set to the
* products reference/create time.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.uf.edex.plugin.text.impl;
import java.io.BufferedReader;
import java.io.File;
@ -58,6 +58,7 @@ import com.raytheon.uf.common.util.StringUtil;
* Mar 17, 2014 DR 16449 D. Friedman Fix reload/populate.
* Apr 01, 2014 2915 dgilling Major re-factor, all methods are now
* static.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author jkorman

View file

@ -25,10 +25,9 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.core.props.PropertiesFactory;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
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;

View file

@ -17,19 +17,21 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.dbapi.impl;
package com.raytheon.uf.edex.plugin.text.impl;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
/**
* TODO Add Description
* Data object containing the WMO headers, AFOS product ID and report data as a
* string
*
* <pre>
* SOFTWARE HISTORY
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Oct 1, 2008 1538 jkorman Initial creation
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
* </pre>
*
* @author jkorman

View file

@ -26,12 +26,12 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
import com.raytheon.uf.common.site.SiteMap;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.plugin.text.impl.TextDBStaticData;
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
/**
* Standard Message Collective Separator.

View file

@ -23,12 +23,12 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
import com.raytheon.uf.common.site.SiteMap;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.plugin.text.impl.TextDBStaticData;
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
/**
*

View file

@ -28,11 +28,11 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.plugin.text.impl.TextDBStaticData;
import com.raytheon.uf.edex.plugin.text.impl.TextSeparatorFactory;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
/**
* Upper Air Collective text Separator.

View file

@ -30,9 +30,9 @@ import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.esb.Headers;
import com.raytheon.edex.plugin.AbstractRecordSeparator;
import com.raytheon.edex.textdb.dbapi.impl.WMOReportData;
import com.raytheon.uf.common.wmo.AFOSProductId;
import com.raytheon.uf.common.wmo.WMOHeader;
import com.raytheon.uf.edex.plugin.text.impl.WMOReportData;
/**
* Decoder implementation for text products

View file

@ -17,7 +17,7 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.ingest;
package com.raytheon.uf.edex.plugin.text.ingest;
import java.io.BufferedReader;
import java.io.BufferedWriter;
@ -51,6 +51,7 @@ import com.raytheon.uf.edex.ndm.ingest.INationalDatasetSubscriber;
* ------------ ---------- ----------- --------------------------
* Jan 06, 2011 bfarmer Initial creation
* Mar 06, 2014 2876 mpduff New NDM plugin.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -17,12 +17,11 @@
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
* further licensing information.
**/
package com.raytheon.edex.textdb.ingest;
package com.raytheon.uf.edex.plugin.text.ingest;
import java.io.File;
import java.io.IOException;
import com.raytheon.edex.textdb.dbapi.impl.TextDBStaticData;
import com.raytheon.uf.common.localization.IPathManager;
import com.raytheon.uf.common.localization.LocalizationContext;
import com.raytheon.uf.common.localization.LocalizationContext.LocalizationLevel;
@ -34,6 +33,7 @@ import com.raytheon.uf.common.util.FileUtil;
import com.raytheon.uf.edex.core.EDEXUtil;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.ndm.ingest.INationalDatasetSubscriber;
import com.raytheon.uf.edex.plugin.text.impl.TextDBStaticData;
/**
* Text DB static data subscriber.
@ -49,6 +49,7 @@ import com.raytheon.uf.edex.ndm.ingest.INationalDatasetSubscriber;
* Mar 06, 2014 2876 mpduff New NDM plugin.
* Mar 17, 2014 DR 16449 D. Friedman Send 'setDirty' notification to all nodes.
* Mar 20, 2014 2915 dgilling Code cleanup.
* May 20, 2014 2536 bclement moved from edex.textdb to edex.plugin.text
*
* </pre>
*

View file

@ -26,9 +26,6 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.raytheon.edex.textdb.dbapi.impl.TextDB;
import com.raytheon.edex.textdb.fax.AutoFaxDao;
import com.raytheon.edex.textdb.fax.FaxSender;
import com.raytheon.uf.common.dataplugin.PluginDataObject;
import com.raytheon.uf.common.dataplugin.PluginException;
import com.raytheon.uf.common.dataplugin.text.AutoFaxContainer;
@ -36,6 +33,9 @@ import com.raytheon.uf.common.dataplugin.text.db.AutoFaxRecord;
import com.raytheon.uf.common.dataplugin.text.db.StdTextProduct;
import com.raytheon.uf.edex.core.EdexException;
import com.raytheon.uf.edex.plugin.text.TextRecord;
import com.raytheon.uf.edex.plugin.text.db.TextDB;
import com.raytheon.uf.edex.plugin.text.fax.AutoFaxDao;
import com.raytheon.uf.edex.plugin.text.fax.FaxSender;
/**
* TODO Add Description

View file

@ -22,13 +22,6 @@
<import feature="com.raytheon.uf.edex.archive.feature" version="1.0.0.qualifier"/>
</requires>
<plugin
id="com.raytheon.edex.textdb"
download-size="0"
install-size="0"
version="0.0.0"
unpack="false"/>
<plugin
id="com.raytheon.uf.edex.dissemination"
download-size="0"

View file

@ -23,10 +23,8 @@
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.sfcobs"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.shef"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.taf"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.text"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.textlightning"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.plugin.warning"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.edex.textdb"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.uf.common.dataaccess"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.uf.common.dataplugin"/>
<classpathentry combineaccessrules="false" kind="src" path="/com.raytheon.uf.common.dataplugin.acars"/>