Function getMonitorSummaryWithDay

src/server/model/monitor/index.ts:73–126

(
  monitorId: string,
  beforeDay: number = 30,
  timezone = 'utc'
)

}

export async function getMonitorSummaryWithDay(
  monitorId: string,
  beforeDay: number = 30,
  timezone = 'utc'
) {
  interface MonitorSummaryItem {
    day: string;
    total_count: number;
    up_count: number;
    up_rate: number;
  }

  const list = await prisma.$queryRaw<MonitorSummaryItem[]>`
    SELECT
      ${getDateQuery('"createdAt"', 'day', timezone)} AS day,
      COUNT(1) AS total_count,
      SUM(CASE WHEN "value" >= 0 THEN 1 ELSE 0 END) AS up_count,
      (SUM(CASE WHEN "value" >= 0 THEN 1 ELSE 0 END) * 100.0 / COUNT(1)) AS up_rate
    FROM
      "MonitorData"
    WHERE
      "monitorId" = ${monitorId} AND
      "createdAt" AT TIME ZONE ${timezone} >= CURRENT_DATE - INTERVAL '1 day' * ${beforeDay}
    GROUP BY
      1
    ORDER BY
      day;`;

  const map: Record<string, MonitorSummaryItem> = {};
  for (const item of list) {
    const date = dayjs(item.day).format('YYYY-MM-DD');
    map[date] = item;
  }

  return Array.from({ length: beforeDay }).map((_, i) => {
    const target = dayjs().subtract(i, 'days').format('YYYY-MM-DD');

    if (map[target]) {
      return {
        day: target,
        totalCount: Number(map[target].total_count),
        upCount: Number(map[target].up_count),
        upRate: Number(Number(map[target].up_rate).toFixed(1)),
      };
    } else {
      return {
        day: target,
        totalCount: 0,
        upCount: 0,
        upRate: 0,
      };
    }
  });
}

/**
 * create audit log which can query by log