diff --git a/pom.xml b/pom.xml
index e93fa24..714abf2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2,12 +2,12 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- com.integrated_yjb_dataDocking
- integrated_yjb_dataDocking
+ com.sx_yjb_dataDocking
+ sx_yjb_dataDocking
1.0
- jar
+ war
- integrated_yjb_dataDocking
+ sx_yjb_dataDocking
http://maven.apache.org
diff --git a/src/main/java/com/netsdk/utils/ProvincialPlatformDataPushScheduled.java b/src/main/java/com/netsdk/utils/ProvincialPlatformDataPushScheduled.java
index 1a78fcf..314b52e 100644
--- a/src/main/java/com/netsdk/utils/ProvincialPlatformDataPushScheduled.java
+++ b/src/main/java/com/netsdk/utils/ProvincialPlatformDataPushScheduled.java
@@ -84,8 +84,20 @@ public class ProvincialPlatformDataPushScheduled {
if (dataPd.containsKey("REPORT_ID") && !Tools.isEmpty(dataPd.getString("REPORT_ID"))) {
HashMap data = new HashMap<>();
data.put("quotaId", dataPd.get("REPORT_ID")); // 传感编码
- data.put("value", dataPd.get("CURRENT_VALUE")); // 指标当前采集值
- data.put("datas", true); // 质量戳
+ // 确保 CURRENT_VALUE 转换为 Float 类型
+ Object currentValue = dataPd.get("CURRENT_VALUE");
+ if (currentValue != null) {
+ if (currentValue instanceof String) {
+ data.put("value", Float.parseFloat((String) currentValue));
+ } else if (currentValue instanceof Number) {
+ data.put("value", ((Number) currentValue).floatValue());
+ } else {
+ data.put("value", currentValue);
+ }
+ } else {
+ data.put("value", null);
+ }
+ data.put("isValid", true); // 质量戳
dataList.add(data);
}
}
@@ -187,7 +199,7 @@ public class ProvincialPlatformDataPushScheduled {
if (response.getStatusCode().is2xxSuccessful()) {
System.out.println("数据推送成功,响应内容:" + response.getBody());
} else {
- System.err.println("数据推送失败,状态码:" + response.getStatusCodeValue() +
+ System.out.println("数据推送失败,状态码:" + response.getStatusCodeValue() +
",响应内容:" + response.getBody());
}
} catch (Exception e) {