diff --git a/src/main/java/org/well/well/manager/PressureManager.java b/src/main/java/org/well/well/manager/PressureManager.java index ad7a8ca..1b19c8c 100644 --- a/src/main/java/org/well/well/manager/PressureManager.java +++ b/src/main/java/org/well/well/manager/PressureManager.java @@ -68,11 +68,12 @@ String cell = jsonObject.getString("cell"); JSONArray jsonArray = jsonObject.getJSONArray("datas"); BusWell busWell = busWellManager.getWellByDevCode(devCode); + System.out.println(jsonObject.toString()); for (int i = 0; i < jsonArray.size(); i++) { try { String dataValue = ((JSONObject) jsonArray.get(i)).getString("dataValue"); String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); - dataValue = String.format("%.2f", Double.valueOf(dataValue)); + dataValue = String.format("%.4f", Double.valueOf(dataValue)); //1.存数据 saveData(devCode, busWell == null ? "" : busWell.getWellCode(), dataValue, cell, upTime);//存储采集数据 //2.有无超限处理流程(判断最后一条数据) diff --git a/src/main/java/org/well/well/manager/PressureManager.java b/src/main/java/org/well/well/manager/PressureManager.java index ad7a8ca..1b19c8c 100644 --- a/src/main/java/org/well/well/manager/PressureManager.java +++ b/src/main/java/org/well/well/manager/PressureManager.java @@ -68,11 +68,12 @@ String cell = jsonObject.getString("cell"); JSONArray jsonArray = jsonObject.getJSONArray("datas"); BusWell busWell = busWellManager.getWellByDevCode(devCode); + System.out.println(jsonObject.toString()); for (int i = 0; i < jsonArray.size(); i++) { try { String dataValue = ((JSONObject) jsonArray.get(i)).getString("dataValue"); String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); - dataValue = String.format("%.2f", Double.valueOf(dataValue)); + dataValue = String.format("%.4f", Double.valueOf(dataValue)); //1.存数据 saveData(devCode, busWell == null ? "" : busWell.getWellCode(), dataValue, cell, upTime);//存储采集数据 //2.有无超限处理流程(判断最后一条数据) diff --git a/target/classes/wellSensor/application.properties b/target/classes/wellSensor/application.properties index 24f5b11..6acc0e8 100644 --- a/target/classes/wellSensor/application.properties +++ b/target/classes/wellSensor/application.properties @@ -172,7 +172,7 @@ bootstrap.servers = 111.198.10.15:12502 kafka.topic = pressure -bootstrap.groupid = 2 +bootstrap.groupid = 0 # ============================================================================ # 告警、工单推送地址