|
@@ -73,7 +73,7 @@ public class RedisDataService {
|
|
|
}
|
|
|
|
|
|
if (keys == null || points == null || keys.isEmpty() ||
|
|
|
- keys.size() != points.size() ) {
|
|
|
+ keys.size() != points.size() ) {
|
|
|
log.error("地址错误! publicaddr = " + addr);
|
|
|
return false;
|
|
|
}
|
|
@@ -91,7 +91,10 @@ public class RedisDataService {
|
|
|
continue;
|
|
|
|
|
|
long time = Long.valueOf(mp.get("timestamp")).longValue() * 1000;
|
|
|
- double value = Double.valueOf(mp.get("value")).doubleValue();
|
|
|
+ double value = 0.0;
|
|
|
+ try{
|
|
|
+ value = Double.valueOf(mp.get("value")).doubleValue();
|
|
|
+ }catch (Exception e){}
|
|
|
|
|
|
if (point.getValue() != value) {
|
|
|
point.setConsumed(false);
|
|
@@ -107,5 +110,4 @@ public class RedisDataService {
|
|
|
|
|
|
return true;
|
|
|
}
|
|
|
-
|
|
|
}
|