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 | 50 ++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 44 insertions(+), 6 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 99c5984..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,23 +1,61 @@
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;
@Component
public class AlarmDataHandler implements TelemetryDataHandler {
private static final Logger log = LoggerFactory.getLogger(AlarmDataHandler.class);
+ @Autowired
+ private AlarmService alarmService;
@Override
public void handleData(PackedTelemetryData data) {
- /*
- WorkstationOutput workstationOutput = TelemetryOutputWrapper.build().entityVO(data);
- IOutputAggregateService outputAggregateService = (IOutputAggregateService) SpringUtil.getBean(IOutputAggregateService.class);
- outputAggregateService.outputRealTimeAggregate(workstationOutput);
- */
- log.info("鎶ヨtdengine 瀹炴椂鑱氬悎瀹屾垚:鏁版嵁{} ");
+ alarmService.saveAlarms(parseAlarm(data));
+
+ log.info("鎶ヨ鏁版嵁澶勭悊瀹屾垚:鍛婅鏁版嵁{} ",data);
+
}
+
+ 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