瀏覽代碼

iot数据解析优化

zhangqiankun 3 年之前
父節點
當前提交
6349e58cf1

+ 3 - 0
src/main/java/com/persagy/netty/collect/ReturnDifferentAlarm.java

@@ -136,6 +136,9 @@ public class ReturnDifferentAlarm {
 			JSONObject messageObj = JSONObject.parseObject(message);
 			String data = messageObj.getString("data");
 			String type = messageObj.getString("type");
+			if (StrUtil.isBlank(data)) {
+				return;
+			}
 			String[] split = data.split(";");
 			String dataTime = split[0];
 			String meter = split[1];

+ 4 - 0
src/main/java/com/persagy/service/impl/AlarmHandleServiceImpl.java

@@ -42,6 +42,7 @@ import com.persagy.utils.StringUtil;
 
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import lombok.extern.slf4j.Slf4j;
 
 /**
@@ -80,6 +81,9 @@ public class AlarmHandleServiceImpl implements AlarmHandleService {
     public void handleIOTData(String msg) throws SchedulerException, InterruptedException {
 		JSONObject parseObject = JSONObject.parseObject(msg);
 		msg = parseObject.getString("data");
+		if (StrUtil.isBlank(msg)) {
+			return;
+		}
         String[] split = msg.split(";");
         if (split.length % 4 != 0) {
             return;