jy2024/jjt-biz/src/main/java/com/jjt/biz/controller/IndexController.java

package com.jjt.biz.controller;

import com.jjt.biz.domain.*;
import com.jjt.biz.service.*;
import com.jjt.biz.util.DataUtil;
import com.jjt.biz.vo.BizTypeVO;
import com.jjt.biz.vo.HlScoreVO;
import com.jjt.common.core.controller.BaseController;
import com.jjt.common.core.domain.AjaxResult;
import com.jjt.common.core.page.TableDataInfo;
import com.jjt.common.utils.DateUtils;
import com.jjt.hl.domain.HlScore;
import com.jjt.hl.service.IHlScoreService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 业务对象Controller
 *
 * @author jjt
 * @date 2024-08-09
 */
@Api(tags = "首页")
@RestController
@RequestMapping("/index")
public class IndexController extends BaseController {
    @Resource
    private IIndexMetricsService imService;
    @Resource
    private IBizObjMetricsService omService;
    @Resource
    private IHlScoreService scoreService;
    @Resource
    private IBizModelService bizModelService;
    @Resource
    private IBizObjMetricsDataService dataService;
    @Resource
    private IAlarmRecordService alarmRecordService;
    @Resource
    private JdbcTemplate jdbcTemplate;

    String[] MODEL_NAMES = {"市场服务", "市场出清", "信息发布", "市场合规", "市场结算"};

    @ApiOperation("巡检提示")
    @GetMapping("/hl/check")
    public AjaxResult hlCheck() {
        Map<String, Object> result = new HashMap<>(16);
        result.put("time", DateUtils.getTime());
        result.put("model", 5);
        result.put("metrics", new Random().nextInt(200));
        result.put("problem", new Random().nextInt(80));
        return AjaxResult.success(result);
    }

    @ApiOperation("当前健康度")
    @GetMapping("/hl/curr")
    public AjaxResult hlCurr() {
        List<HlScoreVO> list = scoreService.selectHlScoreListLast();
        list = list.stream().collect(Collectors.toList());
//        List<Map<String, Object>> result = new ArrayList<>();
//        for (int i = 0; i < MODEL_NAMES.length; i++) {
//            Map<String, Object> map = new HashMap<>(16);
//            map.put("name", MODEL_NAMES[i]);
//            Float score = Float.valueOf(new Random().nextInt(50) + 50);
//            map.put("score", score);
//            result.add(map);
//        }
        return AjaxResult.success(list);
    }

    @ApiOperation("应用健康趋势-按月")
    @GetMapping("/hl/month/{date}")
    public AjaxResult hlMonth(@ApiParam(value = "时间 yyyy-mm", required = true) @PathVariable("date") Date date) {
        List<Map<String, Object>> result = new ArrayList<>();
        HlScore search = new HlScore();
        search.setHlType("2");
        LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
        Map<String, Object> params = new HashMap<>(16);
        params.put("beginTime", localDate.with(TemporalAdjusters.firstDayOfMonth()) + " 00:00:00");
        params.put("endTime", localDate.with(TemporalAdjusters.lastDayOfMonth()) + " 23:59:59");
        search.setParams(params);
        List<HlScore> list = scoreService.selectHlScoreList(search);
        Map<Long, List<HlScore>> resultMap = list.stream().collect(Collectors.groupingBy(HlScore::getModelId));

        int len = 0;
        List<String> standTime = new ArrayList<>();
        for (Long modelId : resultMap.keySet()) {
            Map<String, Object> map = new HashMap<>(16);
            BizModel model = bizModelService.selectBizModelByModelId(modelId);
            map.put("name", model.getModelName());
            List<String> times = new ArrayList<>();
            List<Float> scores = new ArrayList<>();
            List<HlScore> scoreList = resultMap.get(modelId);
            scoreList = scoreList.stream().sorted(Comparator.comparing(HlScore::getHlDate)).collect(Collectors.toList());
            scoreList.forEach(hs -> {
                times.add(DateUtils.parseDateToStr("dd", hs.getHlDate()));
                if (hs.getHlScore() != null) {
                    scores.add(hs.getHlScore().floatValue());
                } else {
                    scores.add(100f);
                }
            });

            if (scoreList.size() > len) {
                len = scoreList.size();
                standTime = times;
            }

            map.put("time", times);
            map.put("score", scores);
            result.add(map);
        }
        DataUtil.standTimeMap(standTime, result);
        return success(result);
    }

    @ApiOperation("应用健康趋势-按年")
    @GetMapping("/hl/year/{date}")
    public AjaxResult hlYear(@ApiParam(value = "时间 yyyy", required = true) @PathVariable("date") String date) {
        List<Map<String, Object>> result = new ArrayList<>();
        String sql = "SELECT a.model_name,b.hy,b.hm,b.score from biz_model a,(SELECT model_id,year(hl_date) hy,month(hl_date) hm,AVG(ifnull(hl_score,100)) score" +
                " FROM hl_score t WHERE hl_type=2 AND year(hl_date)=? GROUP BY model_id,hy,hm) b WHERE a.model_id=b.model_id order by hm";
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql, date);
        Map<String, List<Map<String, Object>>> resultMap = list.stream().collect(Collectors.groupingBy(map -> (String) map.get("model_name")));
        int len = 0;
        List<String> standTime = new ArrayList<>();
        for (String name : resultMap.keySet()) {
            Map<String, Object> map = new HashMap<>(16);
            map.put("name", name);
            List<String> times = new ArrayList<>();
            List<Float> scores = new ArrayList<>();
            List<Map<String, Object>> detailList = resultMap.get(name);
            detailList.forEach(m -> {
                Integer hm = (Integer) m.get("hm");
                BigDecimal score = (BigDecimal) m.get("score");
                score = score.setScale(2, RoundingMode.HALF_UP);
                times.add(hm + "");
                scores.add(score.floatValue());
            });
            if (detailList.size() > len) {
                len = detailList.size();
                standTime = times;
            }
            map.put("time", times);
            map.put("score", scores);
            result.add(map);
        }
        DataUtil.standTimeMap(standTime, result);
        return success(result);
    }


    @ApiOperation("应用健康趋势-按天")
    @GetMapping("/hl/day/{date}")
    public AjaxResult hlDay(@ApiParam(value = "时间（yyyy-mm-dd", required = true) @PathVariable("date") Date date) {
        List<Map<String, Object>> result = new ArrayList<>();
        HlScore search = new HlScore();
        search.setHlType("1");
        Map<String, Object> params = new HashMap<>(16);
        params.put("beginTime", DateUtils.parseDateToStr("yyyy-MM-dd", date) + " 00:00:00");
        params.put("endTime", DateUtils.parseDateToStr("yyyy-MM-dd", date) + " 23:59:59");
        search.setParams(params);
        int len = 0;
        List<String> standTime = new ArrayList<>();
        List<HlScore> list = scoreService.selectHlScoreList(search);
        Map<Long, List<HlScore>> resultMap = list.stream().collect(Collectors.groupingBy(HlScore::getModelId));
        for (Long modelId : resultMap.keySet()) {
            Map<String, Object> map = new HashMap<>(16);
            BizModel model = bizModelService.selectBizModelByModelId(modelId);
            map.put("name", model.getModelName());
            List<String> times = new ArrayList<>();
            List<Float> scores = new ArrayList<>();
            List<HlScore> scoreList = resultMap.get(modelId);
            scoreList = scoreList.stream().sorted(Comparator.comparing(HlScore::getHlDate)).collect(Collectors.toList());

            scoreList.forEach(hs -> {
                times.add(DateUtils.parseDateToStr("HH:mm", hs.getHlDate()));
                if (hs.getHlScore() != null) {
                    scores.add(hs.getHlScore().floatValue());
                } else {
                    scores.add(100f);
                }
            });

            if (scoreList.size() > len) {
                len = scoreList.size();
                standTime = times;
            }

            map.put("time", times);
            map.put("score", scores);
            result.add(map);
        }

        DataUtil.standTimeMap(standTime, result);
        return success(result);
    }

    @ApiOperation("运行风险预测结果")
    @GetMapping("/risk")
    public AjaxResult risk() {
        String sql = "SELECT b.metrics_name metricsName,c.obj_name objName,'2' status" +
                " FROM (SELECT a.obj_id FROM risk_analysis a,risk_model b WHERE a.ANALYSE_TIME = (SELECT MAX(ANALYSE_TIME) FROM risk_analysis) AND a.risk_id=b.risk_id AND b.risk_type!='3' AND result LIKE '%恶化%') a," +
                "biz_obj_metrics b,biz_obj c" +
                " where a.obj_id = b.obj_metrics_id AND b.obj_id=c.obj_id";
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);

        Map<String, Object> result = new HashMap<>();
        result.put("num", list.size());
        result.put("data", list);
//        List<Map<String, Object>> resul = new ArrayList<>();
//        String[] objs = {"出清node1", "出清ecs", "业务应用3", "业务应用4", "业务应用5", "业务应用6", "业务应用7"};
//        String[] ms = {"cpu使用率", "慢访问次数", "GC次数", "空间交换", "打开文件数", "交换分区访问"};
//        Random random = new Random();
//        int x = objs.length * ms.length;
//        int xx = x / 2;
//        int max = random.nextInt(xx) + 12;
//        int num = 0;
//        for (int i = 0; i < max; i++) {
//            boolean flag = random.nextInt(888) % 2 == 0;
//            int mi = random.nextInt(ms.length - 1);
//            Map<String, Object> map = new HashMap<>(16);
//            String objName = objs[i % 6];
//            String metricsName = ms[mi];
//            map.put("objName", objName);
//            map.put("metricsName", metricsName);
//            String status = "1";
////            if (flag) {
//            //风险
//            num++;
//            status = "2";
////            }
//            map.put("status", status);
//            resul.add(map);
//        }
//
//        result.put("num", num);
//        result.put("data", resul);
        return success(result);
    }

    @ApiOperation("业务访问报错排名")
    @GetMapping("/biz/access")
    public AjaxResult access() {
        List<Map<String, Object>> result = new ArrayList<>();
        LocalDateTime endTime = LocalDateTime.now();
        LocalDateTime beginTime = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        String start = df.format(LocalDateTime.of(beginTime.toLocalDate(), LocalTime.MIN));
        String end = df.format(LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX));
        String sql = "SELECT bmdetail.model_id,subq.metrics_code,IFNULL(SUM(bmd.D_VALUE), 0) AS total_value " +
                "FROM biz_obj_metrics_data bmd " +
                "JOIN (" +
                "    SELECT bom.obj_metrics_id, bom.obj_id,md.metrics_code" +
                "    FROM biz_obj_metrics bom" +
                "    JOIN metrics_def md ON bom.metrics_id = md.metrics_id" +
                "    WHERE bom.metrics_name LIKE 'SPRING_BOOT/%' AND (md.metrics_code = 'pp.error' OR md.metrics_code='pp.tot')" +
                ") subq ON bmd.obj_metrics_id = subq.obj_metrics_id" +
                " JOIN biz_model_detail bmdetail ON subq.obj_id = bmdetail.obj_id" +
                " WHERE bmd.CREATE_TIME BETWEEN ? AND ?" +
                " GROUP BY bmdetail.model_id,subq.metrics_code";
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql, start, end);
        Map<Integer, List<Map<String, Object>>> resultMap = list.stream().collect(Collectors.groupingBy(mp -> (Integer) mp.get("model_id")));

        List<BizModel> modelList = bizModelService.selectBizModelList(new BizModel());
        for (BizModel model : modelList) {
            Map<String, Object> map = new HashMap<>(16);
            map.put("name", model.getModelName());
            List<Map<String, Object>> vList = resultMap.get(model.getModelId().intValue());
            if (vList != null) {
                for (Map<String, Object> objectMap : vList) {
                    String code = (String) objectMap.get("metrics_code");
                    BigDecimal value = (BigDecimal) objectMap.get("total_value");
                    if ("pp.error".equals(code)) {
                        map.put("error", value);
                    }
                    if ("pp.tot".equals(code)) {
                        map.put("total", value);
                    }
                }
            } else {
                map.put("error", 0);
                map.put("total", 0);
            }
            result.add(map);
        }
        return success(result);
    }

    @ApiOperation("组件告警数排名")
    @GetMapping("/obj/alarm")
    public AjaxResult alarm() {
        Map<String, Object> result = new HashMap<>();
        LocalDateTime endTime = LocalDateTime.now();
        LocalDateTime beginTime = endTime.minusDays(7);
        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        String start = df.format(LocalDateTime.of(beginTime.toLocalDate(), LocalTime.MIN));
        String end = df.format(LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX));
        List<BizTypeVO> list = alarmRecordService.listBizObj(null, start, end);
        list = list.stream().sorted(Comparator.comparing(BizTypeVO::getNum).reversed()).collect(Collectors.toList());
        AlarmRecord q = new AlarmRecord();
        q.setAlarmType("1");
        List<AlarmRecord> al = alarmRecordService.selectAlarmRecordList(q);
        result.put("curr", al.size());
        result.put("data", list);
        return success(result);
    }

    @ApiOperation("指标配置列表")
    @GetMapping("/ms/config/list")
    public AjaxResult configList() {
        List<IndexMetrics> list = imService.selectIndexMetricsList(new IndexMetrics());
        return AjaxResult.success(list);
    }

    @ApiOperation("重点指标运行趋势列表")
    @GetMapping("/ms/trend")
    public AjaxResult msList() {
        List<IndexMetrics> list = imService.selectIndexMetricsList(new IndexMetrics());
        list.forEach(im -> {
            Random r = new Random();
            DecimalFormat df = new DecimalFormat("#0.00");
            im.setValue(Float.parseFloat(df.format(r.nextFloat() * 100)));
        });
        return AjaxResult.success(list);
    }

    @ApiOperation("重点指标运行趋势图")
    @GetMapping("/ms/trend/{objMetricsId}")
    public AjaxResult msChat(@PathVariable("objMetricsId") Long objMetricsId) {
        List<Map<String, Object>> trendList = new ArrayList<>();

        LocalDateTime endTime = LocalDateTime.now();
        LocalDateTime beginTime = endTime.minusDays(7);
        Map<String, Object> params = new HashMap<>(16);
        params.put("beginTime", beginTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        params.put("endTime", endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        BizObjMetricsData q = new BizObjMetricsData();
        q.setObjMetricsId(objMetricsId);
        q.setParams(params);
        List<BizObjMetricsData> list = dataService.selectBizObjMetricsDataList(q);
        list.forEach(data -> {
            Map<String, Object> map = new HashMap<>(16);
            map.put("time", data.getCreateTime());
            map.put("value", data.getdValue().floatValue());
            trendList.add(map);
        });
//        LocalDateTime ed = LocalDateTime.now();
//        LocalDateTime st = ed.minusDays(8);
//        Random r = new Random();
//        DecimalFormat df = new DecimalFormat("#0.00");
//        do {
//            Map<String, Object> map = new HashMap<>(16);
//            long time = st.toEpochSecond(ZoneOffset.ofHours(8)) * 1000;
//            map.put("time", time);
//            float f = r.nextFloat() * 100;
//            map.put("value", Float.parseFloat(df.format(f)));
//            st = st.plusDays(1);
//            trendList.add(map);
//        } while (!st.isAfter(ed));
        return AjaxResult.success(trendList);
    }

    @ApiOperation("指标配置--选择指标列表")
    @GetMapping("/ms/config/select")
    public TableDataInfo list(BizObjMetrics bizObjMetrics) {
        startPage();
        List<BizObjMetrics> list = omService.selectBizObjMetricsList(bizObjMetrics);
        return getDataTable(list);
    }

    @ApiOperation("指标配置--添加指标")
    @GetMapping("/ms/config/add")
    public AjaxResult selectAdd(@ApiParam(value = "指标ID数组", required = true) Long[] ids) {
        for (int i = 0; i < ids.length; i++) {
            Long id = ids[i];
            IndexMetrics im = new IndexMetrics();
            im.setObjMetricsId(id);
            List list = imService.selectIndexMetricsList(im);
            if (list.size() == 0) {
                BizObjMetrics bom = omService.selectBizObjMetricsByObjMetricsId(id);
                im.setObjId(bom.getObjId());
                im.setObjName(bom.getObjName());
                im.setMetricsId(bom.getMetricsId());
                im.setMetricsName(bom.getMetricsName());
                imService.insertIndexMetrics(im);
            }
        }
        return AjaxResult.success();
    }

    @ApiOperation("指标配置--删除指标")
    @GetMapping("/ms/config/del/{imIds}")
    public AjaxResult configDel(@ApiParam(value = "指标imId", required = true) @PathVariable Long[] imIds) {
        return AjaxResult.success(imService.deleteIndexMetricsByImIds(imIds));
    }
}