package com.zhitan.handler;
|
|
import com.zhitan.model.entity.OpcData;
|
import com.zhitan.service.IDataService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
/**
|
* OPC UA数据处理器
|
*/
|
@Slf4j
|
@Component
|
public class OpcDataHandler {
|
private final IDataService dataService;
|
|
public OpcDataHandler(IDataService dataService) {
|
this.dataService = dataService;
|
}
|
|
/**
|
* 处理OPC UA数据
|
*
|
* @param dataList OPC UA数据列表
|
*/
|
public void handleOpcData(List<OpcData> dataList) {
|
if (dataList == null || dataList.isEmpty()) {
|
return;
|
}
|
|
for (OpcData data : dataList) {
|
if (data.getValue() != null) {
|
// 构建JSON格式数据
|
String jsonData = String.format("{\"%s\":%f}", data.getName(), data.getValue());
|
// 使用现有的数据服务写入时序数据
|
dataService.writeTimeSeriesData(jsonData);
|
log.debug("处理OPC UA数据: {} = {}", data.getName(), data.getValue());
|
} else if (data.getErrorMessage() != null) {
|
log.warn("OPC UA数据处理失败: {} - {}", data.getName(), data.getErrorMessage());
|
}
|
}
|
}
|
}
|
