package cn.iocoder.yudao.module.bi.service.dashboard;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.module.bi.dal.dataobject.BiChartConfigDO;
|
import cn.iocoder.yudao.module.bi.dal.dataobject.BiDashboardDO;
|
import cn.iocoder.yudao.module.bi.dal.mysql.BiChartConfigMapper;
|
import cn.iocoder.yudao.module.bi.dal.mysql.BiDashboardMapper;
|
import cn.iocoder.yudao.module.bi.enums.ErrorCodeConstants;
|
import com.alibaba.fastjson.JSON;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
/**
|
* 仪表盘 Service 实现
|
*
|
* @author 超级管理员
|
*/
|
@Slf4j
|
@Service
|
public class DashboardServiceImpl implements DashboardService {
|
|
@Resource
|
private BiDashboardMapper dashboardMapper;
|
|
@Resource
|
private BiChartConfigMapper chartConfigMapper;
|
|
@Resource
|
private JdbcTemplate jdbcTemplate;
|
|
@Override
|
public List<BiDashboardDO> getDashboardList() {
|
return dashboardMapper.selectEnabledList();
|
}
|
|
@Override
|
public List<Map<String, Object>> getDashboardData(String dashboardCode, Map<String, Object> params) {
|
BiDashboardDO dashboard = dashboardMapper.selectByCode(dashboardCode);
|
if (dashboard == null) {
|
throw exception(ErrorCodeConstants.BI_DASHBOARD_NOT_EXISTS);
|
}
|
if (dashboard.getStatus() != null && dashboard.getStatus() == 0) {
|
throw exception(ErrorCodeConstants.BI_DASHBOARD_IS_DISABLE);
|
}
|
|
List<BiChartConfigDO> charts = chartConfigMapper.selectListByDashboardId(dashboard.getId());
|
List<Map<String, Object>> result = new ArrayList<>();
|
|
for (BiChartConfigDO chart : charts) {
|
Map<String, Object> chartData = new LinkedHashMap<>();
|
chartData.put("id", chart.getId());
|
chartData.put("name", chart.getName());
|
chartData.put("chartType", chart.getChartType());
|
chartData.put("refreshInterval", chart.getRefreshInterval());
|
|
// 解析布局位置
|
if (StrUtil.isNotBlank(chart.getPosition())) {
|
chartData.put("position", JSON.parse(chart.getPosition()));
|
}
|
|
// 解析 ECharts 配置项
|
if (StrUtil.isNotBlank(chart.getChartOptions())) {
|
chartData.put("chartOptions", JSON.parse(chart.getChartOptions()));
|
}
|
|
// 执行查询SQL
|
if (StrUtil.isNotBlank(chart.getQuerySql())) {
|
try {
|
String sql = buildSql(chart.getQuerySql(), params);
|
List<Map<String, Object>> queryResult = jdbcTemplate.queryForList(sql);
|
chartData.put("data", queryResult);
|
} catch (Exception e) {
|
log.error("[BI][图表: {}] 查询SQL执行失败", chart.getName(), e);
|
chartData.put("data", Collections.emptyList());
|
chartData.put("error", "查询失败: " + e.getMessage());
|
}
|
} else {
|
chartData.put("data", Collections.emptyList());
|
}
|
|
result.add(chartData);
|
}
|
|
return result;
|
}
|
|
/**
|
* 构建SQL，替换参数占位符
|
*/
|
private String buildSql(String querySql, Map<String, Object> params) {
|
if (params == null || params.isEmpty()) {
|
return querySql;
|
}
|
String sql = querySql;
|
for (Map.Entry<String, Object> entry : params.entrySet()) {
|
String placeholder = "{{" + entry.getKey() + "}}";
|
Object value = entry.getValue();
|
if (value instanceof String) {
|
sql = sql.replace(placeholder, "'" + value.toString().replace("'", "''") + "'");
|
} else if (value instanceof Number) {
|
sql = sql.replace(placeholder, value.toString());
|
}
|
}
|
return sql;
|
}
|
|
}
|
