|
@@ -40,8 +40,12 @@ public class HBaseUtil {
|
|
|
wrapperObject.put("Database", db);
|
|
|
wrapperObject.put("Datatable", tb);
|
|
|
wrapperObject.put("Criteria", Criteria);
|
|
|
-
|
|
|
- LogUtil.info("Reload Project:" + project + " dy_pointlist Begin...");
|
|
|
+ LogUtil.info("Clear Project Point List:" + project + " Begin...");
|
|
|
+ Constant.ps_PhysicalList = new HashMap<String, List<String>>();
|
|
|
+ Constant.ps_ProjectList = new HashMap<String, List<String>>();
|
|
|
+ Constant.ps_MeterList = new HashMap<String, List<String>>();
|
|
|
+ LogUtil.info("Clear Project Point List:" + project + " End...");
|
|
|
+ LogUtil.info("Reload Project Point List:" + project + " dy_pointlist Begin...");
|
|
|
JSONObject queryResult = agent.Query(wrapperObject);
|
|
|
JSONArray resultContent = (JSONArray) queryResult.get("Content");
|
|
|
for (int i = 0; i < resultContent.size(); i++) {
|
|
@@ -94,8 +98,8 @@ public class HBaseUtil {
|
|
|
Constant.ps_ProjectList.get(project).add(value);
|
|
|
checkStatus(project, meter, funcid, address_1, address_2, address_3, address_4);
|
|
|
}
|
|
|
+ LogUtil.info("Reload Project Point List:" + project + " dy_pointlist End...");
|
|
|
|
|
|
- LogUtil.info("Reload Project:" + project + " dy_pointlist End...");
|
|
|
}
|
|
|
|
|
|
private static void checkStatus(String project, String meter, long funcid, String address_1, String address_2,
|