java實現折線圖統計數據

           需求：可以分別按日，周，月進行統計交易總額。后台接收參數為type,string。其中type為查詢類型，string接收的為“yyyy-mm-dd”格式的字符串。按周統計的話是計算一周的交易總額，按月的話是計算一個月的交易總額；按周或者按月都是通過傳過來的字符串去解析周數或月份。默認查詢：日前推30天，周前推12周，月前推12個月。

           注意：1，周計數策略統一為iso標准策略計算；每周一為一周的第一天，第一個自然周最少要4天；

                           相關參考鏈接：

                                                    https://blog.csdn.net/wysnxzm/article/details/89095495

                                                    https://blog.csdn.net/sayWhat_sayHello/article/details/80589304  ；

                                                    https://blog.csdn.net/lifuxiangcaohui/article/details/50953018

                      2，數據的補全策略，通過事先運算出該時間范圍內的所有應展示的統計數據與實際mysql中查詢出來的數據進行對比，如果不存在響應map中則添加一條值為0的記錄。

           參考代碼：

public OpenAPiJsonResult shopTradeTrend(AppSession session, GetTradeTrendRequest request) throws Exception {
        WeekFields weekFields = WeekFields.of(DayOfWeek.MONDAY, 4);
        // 查詢條件
        String queryData = request.getQueryDate();
        Integer queryType = request.getType();

        List<String> responseDate = Lists.newArrayList();
        if (Objects.isNull(queryType) && StringUtils.isBlank(queryData)) {
            // 默認按日，展示當前日期前推30天的數據
            request.setType(0);
            request.setStartDate(LocalDate.now().minusDays(29).toString());
            request.setEndDate(LocalDate.now().plusDays(1).toString());
            responseDate = DateUtil.findDates(LocalDate.now().minusDays(30).toString(), LocalDate.now().toString());
        } else if (Objects.nonNull(queryType)) {
            if (queryType == 0) {
                // 按日，默認查30天
                if (StringUtils.isBlank(queryData)) {
                    request.setStartDate(LocalDate.now().minusDays(29).toString());
                    request.setEndDate(LocalDate.now().plusDays(1).toString());
                    responseDate = DateUtil.findDates(LocalDate.now().minusDays(30).toString(), LocalDate.now().toString());
                } else {
                    LocalDate queryDate = DateUtil.stringToLocalDate(queryData);
                    request.setStartDate(queryDate.minusDays(29).toString());
                    request.setEndDate(queryDate.plusDays(1).toString());
                    responseDate = DateUtil.findDates(queryDate.minusDays(30).toString(), queryDate.toString());
                }
            } else if (queryType == 1) {
                // 按周，默認查當前周前推12周的數據
                if (StringUtils.isBlank(queryData)) {
                    int nowWeekNo = LocalDate.now().get(weekFields.weekOfYear());
                    String weekStartDate = DateUtil.getWeekDays(LocalDate.now().getYear(), nowWeekNo, -11);
                    request.setStartDate(weekStartDate);
                    request.setEndDate(LocalDate.now().plusDays(1).toString());
                    responseDate = new ArrayList<>(Objects.requireNonNull(DateUtil.getWeekBetween(weekStartDate, LocalDate.now().toString())));
                } else {
                    LocalDate date = DateUtil.stringToLocalDate(queryData);
                    int nowWeekNo = date.get(weekFields.weekOfWeekBasedYear());
                    request.setStartDate(DateUtil.getWeekDays(date.get(weekFields.weekBasedYear()), nowWeekNo, -11));
                    request.setEndDate(DateUtil.getDateByYearAndWeekNo(date.get(weekFields.weekBasedYear()), nowWeekNo).plusDays(1).toString());
                    responseDate = new ArrayList<>(Objects.requireNonNull(DateUtil.getWeekBetween(DateUtil.getWeekDays(date.get(weekFields.weekBasedYear()), nowWeekNo, -11), DateUtil.getDateByYearAndWeekNo(date.get(weekFields.weekBasedYear()), nowWeekNo).toString())));
                }
            } else {
                // 按月，默認查12個月
                if (StringUtils.isBlank(queryData)) {
                    String startMonth = DateUtil.dateMinusMonth(LocalDate.now().getYear() + "" + LocalDate.now().getMonthValue(), -11);
                    request.setStartDate(startMonth.substring(0, 4) + "-" + startMonth.substring(4, 6) + "-01");
                    request.setEndDate(LocalDate.now().plusDays(1).toString());

                    responseDate = DateUtil.getMonthBetween(startMonth.substring(0, 4) + "-" + startMonth.substring(4, 6), LocalDate.now().getYear() + "-" + LocalDate.now().getMonthValue());
                } else {
                    LocalDate date = DateUtil.stringToLocalDate(queryData);
                    String startMonth = DateUtil.dateMinusMonth(date.getYear() + "" + date.getMonthValue(), -11);
                    request.setStartDate(startMonth.substring(0, 4) + "-" + startMonth.substring(4, 6) + "-01");
                    String endDate = DateUtil.getLastDay(date.getYear() + "-" + date.getMonthValue() + "-01");
                    request.setEndDate(DateUtil.stringToLocalDate(endDate).plusDays(1).toString());
                    responseDate = DateUtil.getMonthBetween(startMonth.substring(0, 4) + "-" + startMonth.substring(4, 6), date.getYear() + "-" + date.getMonthValue());
                }
            }
        }
        List<TradeTrendResponse> responseList = orderService.selectCountTradeTrend(session.getOrgId(), session.getStoreId(), request.getType(), request.getStartDate(), request.getEndDate());

        // 因為mysql month,week,day函數返回的數據在1-9內的都不帶0，需要拼裝成規范月，周，日數據
        List<String> convertData = Stream.of("1", "2", "3", "4", "5", "6", "7", "8", "9").collect(toList());
        if (Objects.isNull(request.getType()) || request.getType() == 0) {
            List<String> hasData = Lists.newArrayList();
            TreeMap<LocalDate, Double> responseMap = Maps.newTreeMap();
            // 按日
            responseList.forEach(x -> {
                if (convertData.contains(x.getMonthNo())) {
                    x.setMonthNo("0" + x.getMonthNo());
                }
                if (convertData.contains(x.getDayNo())) {
                    x.setDayNo("0" + x.getDayNo());
                }
                String str = x.getYearNo() + "-" + x.getMonthNo() + "-" + x.getDayNo();
                responseMap.put(DateUtil.stringToLocalDate(str), x.getAmount());
                hasData.add(str);
            });
            responseDate.removeAll(hasData);
            responseDate.forEach(noData -> {
                responseMap.put(DateUtil.stringToLocalDate(noData), 0.00);
            });
            return OpenAPiJsonResult.success(responseMap);
        } else if (request.getType() == 1) {
            // 按周
            List<String> hasData = Lists.newArrayList();
            TreeMap<String, Double> map = Maps.newTreeMap();
            responseList.forEach(x -> {
                map.put(x.getWeekNo().substring(0, 4) + "第" + x.getWeekNo().substring(4, 6) + "周", x.getAmount());
                hasData.add(x.getWeekNo());
            });
            responseDate.removeAll(hasData);
            responseDate.forEach(noData -> {
                map.put(noData.substring(0, 4) + "第" + noData.substring(4, 6) + "周", 0.00);
            });
            if (map.size() > 12) {
                map.remove(map.firstKey());
            }
            return OpenAPiJsonResult.success(map);
        } else {
            // 按月
            List<String> hasData = Lists.newArrayList();
            TreeMap<String, Double> map = Maps.newTreeMap();
            responseList.forEach(x -> {
                if (convertData.contains(x.getMonthNo())) {
                    x.setMonthNo("0" + x.getMonthNo());
                }
                String str = x.getYearNo() + "-" + x.getMonthNo();
                map.put(str + "月", x.getAmount());
                hasData.add(str);
            });
            responseDate.removeAll(hasData);
            responseDate.forEach(noData -> {
                map.put(noData + "月", 0.00);
            });
            return OpenAPiJsonResult.success(map);
        }
    }

  /**
     * 根據當前周號，計算n周前或后的周一日期
     *
     * @param year
     * @param week
     * @param targetNum
     * @return
     */
    public static String getWeekDays(int year, int week, int targetNum) {
        // 計算目標周數
        if (week + targetNum > 52) {
            year++;
        } else if (week + targetNum <= 0) {
            year--;
            week += targetNum + 52;
        } else {
            week += targetNum;
        }

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        Calendar cal = Calendar.getInstance();

        // 設置每周的開始日期
        cal.setFirstDayOfWeek(Calendar.MONDAY);

        cal.set(Calendar.YEAR, year);
        cal.set(Calendar.WEEK_OF_YEAR, week);
        cal.set(Calendar.DAY_OF_WEEK, cal.getFirstDayOfWeek());

        // 該周周一
        String beginDate = sdf.format(cal.getTime());

        cal.add(Calendar.DAY_OF_WEEK, 6);
        // 該周周日
        String endDate = sdf.format(cal.getTime());

        return beginDate;
    }

    /**
     * 根據年，周號，獲取該周周日
     *
     * @return
     */
    public static LocalDate getDateByYearAndWeekNo(int year, int week) {
        WeekFields weekFields2 = WeekFields.of(DayOfWeek.MONDAY, 4);
        LocalDate sunday = LocalDate.now()
                .withYear(year)
                .with(weekFields2.weekOfYear(), week)
                .with(weekFields2.dayOfWeek(), 7L);

        return sunday;
    }

    /**
     * 日期加、減幾月
     *
     * @param str
     * @param amount 正數加，負數減
     * @return
     * @throws Exception
     */
    public static String dateMinusMonth(String str, int amount) throws Exception {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMM");
        Date dt = sdf.parse(str);//將字符串生成Date
        Calendar rightNow = Calendar.getInstance();
        rightNow.setTime(dt);//使用給定的 Date 設置此 Calendar 的時間。
        rightNow.add(Calendar.MONTH, amount);// 日期減1個月
        Date dt1 = rightNow.getTime();//返回一個表示此 Calendar 時間值的 Date 對象。
        String reStr = sdf.format(dt1);//將給定的 Date 格式化為日期/時間字符串，並將結果添加到給定的 StringBuffer。
        return reStr;
    }

    /**
     * 獲取某個月最后一天
     *
     * @param datadate
     * @return
     * @throws Exception
     */
    public static String getLastDay(String datadate) throws Exception {
        Date date = null;
        String day_last = null;
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        date = format.parse(datadate);

//創建日歷
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        calendar.add(Calendar.MONTH, 1); //加一個月
        calendar.set(Calendar.DATE, 1);//設置為該月第一天
        calendar.add(Calendar.DATE, -1);//再減一天即為上個月最后一天
        day_last = format.format(calendar.getTime());
        return day_last;
    }

    /**
     * 獲取時間段內，所有天
     *
     * @param dBegin
     * @param dEnd
     * @return
     * @throws ParseException
     */
    public static List<String> findDates(String dBegin, String dEnd) throws ParseException {
        //日期工具類准備
        DateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        //設置開始時間
        Calendar calBegin = Calendar.getInstance();
        calBegin.setTime(format.parse(dBegin));
        //設置結束時間
        Calendar calEnd = Calendar.getInstance();
        calEnd.setTime(format.parse(dEnd));
        //裝返回的日期集合容器
        List<String> datelist = new ArrayList<String>();
        // 每次循環給calBegin日期加一天，直到calBegin.getTime()時間等於dEnd
        while (format.parse(dEnd).after(calBegin.getTime())) {
            // 根據日歷的規則，為給定的日歷字段添加或減去指定的時間量
            calBegin.add(Calendar.DAY_OF_MONTH, 1);
            datelist.add(format.format(calBegin.getTime()));
        }
        return datelist;
    }

    /**
     * 獲取一段時間內，所有月份
     *
     * @param minDate
     * @param maxDate
     * @return
     * @throws ParseException
     */
    public static List<String> getMonthBetween(String minDate, String maxDate) throws ParseException {
        ArrayList<String> result = new ArrayList<String>();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");//格式化為年月

        Calendar min = Calendar.getInstance();
        Calendar max = Calendar.getInstance();

        min.setTime(sdf.parse(minDate));
        min.set(min.get(Calendar.YEAR), min.get(Calendar.MONTH), 1);

        max.setTime(sdf.parse(maxDate));
        max.set(max.get(Calendar.YEAR), max.get(Calendar.MONTH), 2);

        Calendar curr = min;
        while (curr.before(max)) {
            result.add(sdf.format(curr.getTime()));
            curr.add(Calendar.MONTH, 1);
        }

        return result;
    }

    /**
     * 獲取時間段內所有的周，注意：需要指定周計數策略
     *
     * @param startStr
     * @param endStr
     * @return
     */
    @SuppressWarnings("all")
    public static Set<String> getWeekBetween(String startStr, String endStr) {
        WeekFields weekFields = WeekFields.of(DayOfWeek.MONDAY, 4);
        LocalDate start = DateUtil.stringToLocalDate(startStr);
        LocalDate end = DateUtil.stringToLocalDate(endStr);
        int startY = start.get(weekFields.weekBasedYear());
        int startW = start.get(weekFields.weekOfWeekBasedYear());
        int endY = end.get(weekFields.weekBasedYear());
        int endW = end.get(weekFields.weekOfWeekBasedYear());
        List<Integer> convertData = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9).collect(toList());
        Set<String> response = Sets.newTreeSet();
        if (endY - startY == 0) {// 同一年
            for (int i = startW; i <= endW; i++) {
                if (convertData.contains(i)) {
                    response.add(endY + "0" + i);
                } else {
                    response.add(endY + "" + i);
                }
            }
            return response;
        } else if (endY - startY == 1) { // 這里因業務只統計跨度為12周的數據，所以只考慮年差距在一年的情況
            String lastDay = startY + "-12-31";  // 獲取起始年最大周數
            int maxWeek = DateUtil.stringToLocalDate(lastDay).get(weekFields.weekOfYear());
            for (int i = startW; i <= maxWeek; i++) {
                if (convertData.contains(i)) {
                    response.add(startY + "0" + i);
                } else {
                    response.add(startY + "" + i);
                }
            }
            for (int j = 1; j <= endW; j++) {
                if (convertData.contains(j)) {
                    response.add(endY + "0" + j);
                } else {
                    response.add(endY + "" + j);
                }
            }
            return response;
        } else {// 暫不考慮
            return null;
        }
    }

  <select id="selectCountTradeTrend" resultMap="CountPayTrend">
        select
        <if test="queryType == 0">
            MONTH(pay_time) as month_no,
            DAY(pay_time) as day_no,
        </if>
        <if test="queryType == 1">
            yearweek(pay_time,3) as week_no,
        </if>
        <if test="queryType == 2">
            MONTH(pay_time) as month_no,
        </if>
        YEAR(pay_time) as year_no,
        SUM(practical_deal_price) as amount
        from
        <include refid="tableName"/>
        <where>
            org_id = #{orgId}
            and store_id = #{storeId}
            and is_del = 0
            <if test="startDate != null and startDate != ''">
                and pay_time &gt;= #{startDate}
            </if>
            <if test="endDate != null and endDate != ''">
                and pay_time &lt;= #{endDate}
            </if>
        </where>
        GROUP BY
        <if test="queryType == 0">
            DAY(pay_time)
        </if>
        <if test="queryType == 1">
            yearweek(pay_time,3)
        </if>
        <if test="queryType == 2">
            MONTH(pay_time)
        </if>
    </select>