|
@@ -2350,7 +2350,7 @@ public class HBaseUtil {
|
|
public static void BatchInsert(String DB, List<Record> dataList) throws Exception {
|
|
public static void BatchInsert(String DB, List<Record> dataList) throws Exception {
|
|
JSONArray InsertObjects = new JSONArray();
|
|
JSONArray InsertObjects = new JSONArray();
|
|
JSONArray InsertPresentObjects = new JSONArray();
|
|
JSONArray InsertPresentObjects = new JSONArray();
|
|
- JSONArray InsertLogObjects = new JSONArray();
|
|
|
|
|
|
+ // JSONArray InsertLogObjects = new JSONArray();
|
|
|
|
|
|
try {
|
|
try {
|
|
if (DB == null) {
|
|
if (DB == null) {
|
|
@@ -2382,7 +2382,7 @@ public class HBaseUtil {
|
|
InsertPresentObjects.add(InsertPresentObject);
|
|
InsertPresentObjects.add(InsertPresentObject);
|
|
}
|
|
}
|
|
|
|
|
|
- JSONObject InsertLogObject = new JSONObject();
|
|
|
|
|
|
+ /*JSONObject InsertLogObject = new JSONObject();
|
|
InsertLogObject.put("building", data.buildingSign);
|
|
InsertLogObject.put("building", data.buildingSign);
|
|
InsertLogObject.put("meter", data.meterSign);
|
|
InsertLogObject.put("meter", data.meterSign);
|
|
InsertLogObject.put("funcid", (long) data.funcID);
|
|
InsertLogObject.put("funcid", (long) data.funcID);
|
|
@@ -2390,7 +2390,7 @@ public class HBaseUtil {
|
|
InsertLogObject.put("receivetime", Constant.format(data.receivetime));
|
|
InsertLogObject.put("receivetime", Constant.format(data.receivetime));
|
|
InsertLogObject.put("logtime", Constant.format(new Date()));
|
|
InsertLogObject.put("logtime", Constant.format(new Date()));
|
|
InsertLogObject.put("data", data.data);
|
|
InsertLogObject.put("data", data.data);
|
|
- InsertLogObjects.add(InsertLogObject);
|
|
|
|
|
|
+ InsertLogObjects.add(InsertLogObject);*/
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@@ -2406,12 +2406,12 @@ public class HBaseUtil {
|
|
wrapperObject.put("InsertObjects", InsertObjects);
|
|
wrapperObject.put("InsertObjects", InsertObjects);
|
|
query(Constant.agent, wrapperObject);
|
|
query(Constant.agent, wrapperObject);
|
|
|
|
|
|
- wrapperObject = new JSONObject();
|
|
|
|
|
|
+ /* wrapperObject = new JSONObject();
|
|
wrapperObject.put("QueryType", "batch_put");
|
|
wrapperObject.put("QueryType", "batch_put");
|
|
wrapperObject.put("Database", DB);
|
|
wrapperObject.put("Database", DB);
|
|
wrapperObject.put("Datatable", "original_detail");
|
|
wrapperObject.put("Datatable", "original_detail");
|
|
wrapperObject.put("InsertObjects", InsertLogObjects);
|
|
wrapperObject.put("InsertObjects", InsertLogObjects);
|
|
- query(Constant.agent, wrapperObject);
|
|
|
|
|
|
+ query(Constant.agent, wrapperObject);*/
|
|
|
|
|
|
// for (String upload : Constant.uploadList) {
|
|
// for (String upload : Constant.uploadList) {
|
|
// wrapperObject = new JSONObject();
|
|
// wrapperObject = new JSONObject();
|
|
@@ -2442,7 +2442,7 @@ public class HBaseUtil {
|
|
} finally {
|
|
} finally {
|
|
InsertObjects = null;
|
|
InsertObjects = null;
|
|
InsertPresentObjects = null;
|
|
InsertPresentObjects = null;
|
|
- InsertLogObjects = null;
|
|
|
|
|
|
+ //InsertLogObjects = null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|