From fca5c28c79b061f4db3658f6d9e043024f326962 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 14 十一月 2025 21:58:02 +0800
Subject: [PATCH] 离线默认配置改为300秒
---
collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java | 52 +++++++++++++++++++++++++++++++++-------------------
1 files changed, 33 insertions(+), 19 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java b/collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java
index 4fe5297..de40a7b 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java
@@ -1,12 +1,16 @@
package com.qianwen.mdc.collect.handler;
+import java.util.ArrayList;
import java.util.Arrays;
+import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import com.qianwen.mdc.collect.dto.PackedTelemetryData;
import com.qianwen.mdc.collect.entity.iotdb.Alarm;
import com.qianwen.mdc.collect.service.AlarmService;
@@ -20,28 +24,38 @@
@Override
public void handleData(PackedTelemetryData data) {
- Alarm alarm = new Alarm();//Objects.requireNonNull(BeanUtil.copy(data, Alarm.class));
- alarm.setTime(data.getTime());
- alarm.setWorkstationId(data.getWorkstationId());
- alarm.setCalendarCode(data.getCalendarCode());
- alarm.setFactoryDate(data.getFactoryDate());
- alarm.setFactoryMonth(data.getFactoryMonth());
- alarm.setFactoryWeek(data.getFactoryWeek());
- alarm.setFactoryYear(data.getFactoryYear());
- alarm.setShiftIndex(data.getShiftIndex());
- alarm.setShiftTimeType(data.getShiftTimeType());
-
- alarmService.saveAlarms(Arrays.asList(alarm));
+ alarmService.saveAlarms(parseAlarm(data));
- log.info("鎶ヨ鏁版嵁澶勭悊瀹屾垚:鍛婅鏁版嵁{} ",alarm);
+ log.info("鎶ヨ鏁版嵁澶勭悊瀹屾垚:鍛婅鏁版嵁{} ",data);
}
- /**
- * 濉厖鍛婅鐨勮缁嗕俊鎭紝绾у埆锛屼俊鎭紝浠ｇ爜
- * @param alarm
- */
- void fileAlarmDetail(Alarm alarm,PackedTelemetryData data){
- alarm.setMessage(data.getValue());
+ List<Alarm> parseAlarm(PackedTelemetryData data){
+ List<Alarm> alarmList = new ArrayList<>();
+ //828d json鏁扮粍鏍煎紡[{"alarmNo":"8084"}]
+ JSONArray alarmArr = JSONArray.parseArray(data.getValue());
+
+ for(int i=0;i<alarmArr.size();i++) {
+ Alarm alarm = new Alarm();
+ alarm.setTime(data.getTime());
+ alarm.setWorkstationId(data.getWorkstationId());
+ alarm.setCalendarCode(data.getCalendarCode());
+ alarm.setFactoryDate(data.getFactoryDate());
+ alarm.setFactoryMonth(data.getFactoryMonth());
+ alarm.setFactoryWeek(data.getFactoryWeek());
+ alarm.setFactoryYear(data.getFactoryYear());
+ alarm.setShiftIndex(data.getShiftIndex());
+ alarm.setShiftTimeType(data.getShiftTimeType());
+
+ JSONObject alarmJson = alarmArr.getJSONObject(i);
+ alarm.setCode(alarmJson.getString("alarmNo"));
+
+ alarm.setMessage("");//鏆傛椂娌℃湁锛岄渶瑕佸弽鏌�
+
+ alarmList.add(alarm);
+ }
+ return alarmList;
}
+
+
}
--
Gitblit v1.9.3