xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ASM #15468 Shefdecode failed to ingest RVF product at OUN

Browse source 
Change-Id: Ie345c88c4a3a0ff995c4d33772f90e863bed7ee5

Former-commit-id: 34465f09ce [formerly 400561ac9c] [formerly 34465f09ce [formerly 400561ac9c] [formerly 65677246c2 [formerly f78783d2ea194539414294abff46d4f2acda65d1]]]
Former-commit-id: 65677246c2
Former-commit-id: 475da269d8 [formerly 9285e0530f]
Former-commit-id: 60b7095e20
This commit is contained in:
Fay.Liang 2014-07-11 15:05:24 -04:00
parent dbed262c80
commit 3a4cff44cc
1 changed files with 4 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
edexOsgi/com.raytheon.edex.plugin.shef/src/com/raytheon/edex/plugin/shef/database/PostShef.java
View file

@ -123,6 +123,7 @@ import com.raytheon.uf.edex.decodertools.time.TimeTools;
* 05/28/2014 3222 mpduff Fix posting time to be processed time so db doesn't show all post times the same * 05/28/2014 3222 mpduff Fix posting time to be processed time so db doesn't show all post times the same
* 06/02/2014 mpduff Fix for caching of range checks. * 06/02/2014 mpduff Fix for caching of range checks.
* 06/26/2014 3321 mpduff Fix ingestSwitchMap checks * 06/26/2014 3321 mpduff Fix ingestSwitchMap checks
* 07/10/2014 3370 mpduff Fix update/insert issue for riverstatus
* </pre> * </pre>
* *
* @author mduff * @author mduff
@ -274,9 +275,6 @@ public class PostShef {
/** Basis time TimeStamp */ /** Basis time TimeStamp */
private java.sql.Timestamp basisTimeAnsi = new Timestamp(basisBeginTime); private java.sql.Timestamp basisTimeAnsi = new Timestamp(basisBeginTime);
/** River status update flag. update if true */
private boolean riverStatusUpdateFlag = true;
/** river status update query value */ /** river status update query value */
private boolean riverStatusUpdateValueFlag; private boolean riverStatusUpdateValueFlag;
@ -1105,7 +1103,6 @@ public class PostShef {
// Reset .E cache vars // Reset .E cache vars
tsList.clear(); tsList.clear();
useLatest = MISSING; useLatest = MISSING;
riverStatusUpdateFlag = true;
qualityCheckFlag = true; qualityCheckFlag = true;
useTs = null; useTs = null;
basisTimeValues = null; basisTimeValues = null;
@ -1446,15 +1443,7 @@ public class PostShef {
if ((shefList != null) && (shefList.size() > 0)) { if ((shefList != null) && (shefList.size() > 0)) {
ShefData maxShefDataValue = findMaxFcst(shefList); ShefData maxShefDataValue = findMaxFcst(shefList);
if (shefRecord.getShefType() == ShefType.E) { riverStatusUpdateValueFlag = updateRiverStatus(lid, pe, ts);
if (riverStatusUpdateFlag) {
riverStatusUpdateFlag = false;
riverStatusUpdateValueFlag = updateRiverStatus(lid, pe, ts);
}
} else {
riverStatusUpdateValueFlag = updateRiverStatus(lid, pe, ts);
}
postTables.postRiverStatus(shefRecord, maxShefDataValue, postTables.postRiverStatus(shefRecord, maxShefDataValue,
riverStatusUpdateValueFlag); riverStatusUpdateValueFlag);
} else { } else {
@ -2157,10 +2146,8 @@ public class PostShef {
try { try {
if (!ingestSwitchMap.containsKey(key)) { if (!ingestSwitchMap.containsKey(key)) {
errorMsg.append("Error getting connection to IHFS Database");
sql = "select lid, pe, dur, ts, extremum, ts_rank, ingest, ofs_input, stg2_input from IngestFilter where lid = '" sql = "select lid, pe, dur, ts, extremum, ts_rank, ingest, ofs_input, stg2_input from IngestFilter where lid = '"
+ locId + "'"; + locId + "'";
errorMsg.setLength(0);
errorMsg.append("Error requesting IngestFilter data: " + sql); errorMsg.append("Error requesting IngestFilter data: " + sql);
oa = dao.executeSQLQuery(sql); oa = dao.executeSQLQuery(sql);
if (oa.length > 0) { if (oa.length > 0) {
@ -2196,6 +2183,7 @@ public class PostShef {
ingestSwitchMap.put(key, ingestSwitch); ingestSwitchMap.put(key, ingestSwitch);
} }
matchFound = ingestSwitchMap.containsKey(key);
ingestSwitch = ingestSwitchMap.get(key); ingestSwitch = ingestSwitchMap.get(key);
/* /*
@ -2444,7 +2432,7 @@ public class PostShef {
if (!matchFound) { if (!matchFound) {
log.warn(locId + " - " + data.getPhysicalElement() + "(" log.warn(locId + " - " + data.getPhysicalElement() + "("
+ data.getDuration() + ")" + data.getTypeSource() + data.getDuration() + ")" + data.getTypeSource()
+ data.getExtremum() + " ingest " + "filter not defined"); + data.getExtremum() + " ingest filter not defined");
stats.incrementWarningMessages(); stats.incrementWarningMessages();
ingestSwitch = ShefConstants.IngestSwitch.POST_PE_OFF; ingestSwitch = ShefConstants.IngestSwitch.POST_PE_OFF;
} }