Issue #3923 Fix thin client grid updates.

Former-commit-id: fa11934170 [formerly 147b6c3733] [formerly 67701a2480] [formerly fa11934170 [formerly 147b6c3733] [formerly 67701a2480] [formerly dcea13e602 [formerly 67701a2480 [formerly 537534fb920a8ea109d9bc655f16579cdb357dda]]]]
Former-commit-id: dcea13e602
Former-commit-id: e9f61f6b13 [formerly 918bdad0f4] [formerly 25cbde3b79d123c25e9ccf8664cc1d78cd7d29da [formerly b9dfe6a44e]]
Former-commit-id: b89e7c6a47927a440344448e662a9a69f501c069 [formerly 97a7386f66]
Former-commit-id: deff57c9f8
This commit is contained in:
Ben Steffensmeier 2014-12-15 12:57:55 -06:00
parent 8e028cca9b
commit b5ab1f8eac

View file

@ -28,12 +28,12 @@ import java.util.Map;
import java.util.Set;
import java.util.TimeZone;
import com.raytheon.uf.common.inventory.exception.DataCubeException;
import com.raytheon.uf.common.dataplugin.PluginDataObject;
import com.raytheon.uf.common.dataquery.requests.DbQueryRequest;
import com.raytheon.uf.common.dataquery.requests.RequestConstraint;
import com.raytheon.uf.common.dataquery.requests.RequestConstraint.ConstraintType;
import com.raytheon.uf.common.dataquery.responses.DbQueryResponse;
import com.raytheon.uf.common.inventory.exception.DataCubeException;
import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.common.status.UFStatus.Priority;
@ -62,6 +62,7 @@ import com.raytheon.viz.grid.util.RadarAdapter;
* Dec 13, 2011 bsteffen Initial creation
* Feb 21, 2014 DR 16744 D. Friedman Add radar/grid updates
* Apr 1, 2014 DR 17220 D. Friedman Handle uninitialized grid inventory
* Dec 15, 2014 3923 bsteffen Retrieve pdo for grid instead of dataURI.
*
* </pre>
*
@ -179,14 +180,14 @@ public class ThinClientDataUpdateTree extends DataUpdateTree {
newQuery.put("insertTime", new RequestConstraint(time,
ConstraintType.GREATER_THAN));
dbRequest.setConstraints(newQuery);
dbRequest.addRequestField("dataURI");
DbQueryResponse response = null;
try {
response = (DbQueryResponse) ThriftClient.sendRequest(dbRequest);
for (String dataURI : response.getFieldObjects("dataURI",
String.class)) {
for (PluginDataObject pdo : response
.getEntityObjects(PluginDataObject.class)) {
AlertMessage am = new AlertMessage();
am.dataURI = dataURI;
am.dataURI = pdo.getDataURI();
am.decodedAlert = RecordFactory.getInstance().loadMapFromUri(
am.dataURI);
messages.add(am);