Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增数据

Browse Source
This commit is contained in:
xy
2025-06-24 11:32:37 +08:00
parent 49642066f5
commit 7277299c66
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/CsAlarmServiceImpl.java
View File

@@ -49,16 +49,18 @@ public class CsAlarmServiceImpl extends ServiceImpl<CsEventMapper, CsEventPO> im
public void analysis(AppEventMessage appEventMessage) { public void analysis(AppEventMessage appEventMessage) {
List<CsEventPO> list1 = new ArrayList<>(); List<CsEventPO> list1 = new ArrayList<>();
LocalDateTime eventTime = null; LocalDateTime eventTime = null;
String tag = null; String tag = null, lineId = null;
String id = IdUtil.fastSimpleUUID(); String id = IdUtil.fastSimpleUUID();
//获取装置id //获取装置id
CsEquipmentDeliveryPO po = equipmentFeignClient.findDevByNDid(appEventMessage.getId()).getData(); CsEquipmentDeliveryPO po = equipmentFeignClient.findDevByNDid(appEventMessage.getId()).getData();
try { try {
lineId = appEventMessage.getId() + appEventMessage.getMsg().getClDid();
List<AppEventMessage.DataArray> dataArray = appEventMessage.getMsg().getDataArray(); List<AppEventMessage.DataArray> dataArray = appEventMessage.getMsg().getDataArray();
for (AppEventMessage.DataArray item : dataArray) { for (AppEventMessage.DataArray item : dataArray) {
eventTime = eventService.timeFormat(item.getDataTimeSec(),item.getDataTimeUSec()); eventTime = eventService.timeFormat(item.getDataTimeSec(),item.getDataTimeUSec());
//事件入库 //事件入库
CsEventPO csEvent = new CsEventPO(); CsEventPO csEvent = new CsEventPO();
csEvent.setLineId(lineId);
csEvent.setId(id); csEvent.setId(id);
csEvent.setDeviceId(po.getId()); csEvent.setDeviceId(po.getId());
csEvent.setProcess(po.getProcess()); csEvent.setProcess(po.getProcess());
@@ -91,6 +93,7 @@ public class CsAlarmServiceImpl extends ServiceImpl<CsEventMapper, CsEventPO> im
} }
} catch (Exception e) { } catch (Exception e) {
CsEventLogs csEventLogs = new CsEventLogs(); CsEventLogs csEventLogs = new CsEventLogs();
csEventLogs.setLineId(lineId);
csEventLogs.setDeviceId(po.getId()); csEventLogs.setDeviceId(po.getId());
csEventLogs.setStartTime(eventTime); csEventLogs.setStartTime(eventTime);
csEventLogs.setTag(tag); csEventLogs.setTag(tag);