RecordService.java 文件源码

public ChartVo getAsProgress(HttpSession session) {
    String sql = "SELECT " +
            "sum(CASE R.success WHEN 0 THEN 1 ELSE 0 END) failure, " +
            "sum(CASE R.success WHEN 1 THEN 1 ELSE 0 END) success, " +
            "sum(CASE R.success WHEN 2 THEN 1 ELSE 0 END) killed, " +
            "sum(CASE R.jobType WHEN 0 THEN 1 ELSE 0 END) singleton, " +
            "sum(CASE R.jobType WHEN 1 THEN 1 ELSE 0 END) flow, " +
            "sum(CASE J.cronType WHEN 0 THEN 1 ELSE 0 END) crontab, " +
            "sum(CASE J.cronType WHEN 1 THEN 1 ELSE 0 END) quartz, " +
            "sum(CASE R.execType WHEN 0 THEN 1 ELSE 0 END) auto, " +
            "sum(CASE R.execType WHEN 1 THEN 1 ELSE 0 END) operator, " +
            "sum(CASE R.redoCount>0 WHEN 1 THEN 1 ELSE 0 END) rerun " +
            "FROM T_RECORD R LEFT JOIN T_JOB J ON R.jobid=J.jobid WHERE 1=1 ";

    if (!OpencronTools.isPermission(session)) {
        User user = OpencronTools.getUser(session);
        sql += " AND R.userId = " + user.getUserId() + " AND R.agentId in (" + user.getAgentIds() + ")";
    }
    return queryDao.sqlUniqueQuery(ChartVo.class, sql);
}