说明:本文基于nest.js,typescript语法,mongoose,moment
目录
前言:在网上找了很长时间,最终总结了如下两种方法,仅供参考
需要导的包:
import * as moment from 'moment';
import { DateTime } from 'ts-luxon';
import { InjectModel } from '@nestjs/mongoose';
第一种方法:正常循环
-
//近七天趋势分析
-
const water_rush_chart = [];
-
for (
let i =
0; i <
7; i++) {
-
const count =
await
this.
WaterRushModel.
aggregate([
-
{
-
$match: {
-
create_time: {
-
$gte:
DateTime.
local().
plus({
day: -i }).
startOf(
'day'),
//前i天的00:00
-
$lte:
DateTime.
local().
plus({
day: -i }).
endOf(
'day'),
//前i天的59:59秒
-
},
-
},
-
},
-
//分组
-
{
-
$group: {
-
_id:
null,
//根据什么分组
-
value: {
$sum:
'$flow' },
//求需要的字段值之和,$sum为求和,$flow为字段
-
dataDate: {
$push:
'$dataDate' },
-
},
-
},
-
]);
-
-
water_rush_chart.
unshift({
-
x:
DateTime.
local()
-
.
plus({
day: -(i +
1) })
-
.
toFormat(
'LL-dd'),
//转化为月-日
-
y: count[
0] ? count[
0].
value.
toFixed(
2) :
0,
-
s:
'数量',
-
});
-
}
第二种方法:通过分组将数据按照所需时间分组
-
//近24小时趋势图
-
const count1 =
await
this.
studentModel.
aggregate([
-
{
-
$match: {
-
created_at: {
-
$gte:
DateTime.
local().
plus({
hours: -
24 }).
startOf(
'hour'),
-
$lte:
DateTime.
local().
plus({
hours: -
1 }).
endOf(
'hour'),
-
},
-
},
-
},
-
//分组
-
{
-
$group: {
-
_id: {
-
$subtract: [
-
{
$subtract: [
'$created_at',
new
Date(
'1970-01-01')] },
-
{
-
$mod: [{
$subtract: [
'$created_at',
new
Date(
'1970-01-01')] },
1000 *
60 *
60
/*聚合时间段，24小时*/],
-
},
-
],
-
},
-
name: {
$push:
'$pump_room_name' },
-
score: {
$avg:
'$score' },
-
time: {
$push:
'$created_at' },
-
},
-
},
-
//排序
-
{
-
$sort: {
-
time:
1,
-
},
-
},
-
]);
-
-
//数据库查到的数据先存入数组
-
const student_arr = [];
-
count1.
filter(
(item) => {
-
//添加平均成绩
-
student_arr.
unshift({
-
x:
moment(item.
time[
0]).
format(
'HH:00'),
-
y: item.
score ||
0,
-
s:
'平均成绩',
-
});
-
});
-
-
//学生平均成绩趋势如(不包含当前小时)
-
const studnet_chart = [];
-
let num1 =
0;
-
for (
let i =
0; i <
24; i++) {
-
//获取当前时间
-
const time =
DateTime.
local()
-
.
plus({
hour: -(i +
1) })
-
.
startOf(
'hour')
-
.
toFormat(
'HH:00');
-
//判断所处时间是否有数据
-
if (num1 < student_arr.
length && student_arr[num1].
x === time) {
-
student_chart.
unshift(student_arr[num1]);
-
num1++;
-
}
else {
-
//为了防止数据库数据不全,数据库中没有的默认0
-
student_chart.
unshift({
-
x: time,
-
y:
0,
-
s:
'平均成绩',
-
});
-
}
-
}
两种方法各有优势,具体根据定时任务存储的时间而定.
语法方面也可进行优化,这里不做过多叙述.
如有更好的方法欢迎留言.
这里再分享几篇参考的文章以及感觉比较全面的MongoDB总结:
管道相关方法:
转载：https://blog.csdn.net/m0_46420244/article/details/128496643
查看评论