Function handleCreateDailyReport

apps/daily-ai-trigger/src/handler.ts:53–117

(env: Env)

}

export async function handleCreateDailyReport(env: Env) {
	console.log('handleCreateDailyReport');

	const workspaceId = env.WORKSPACE_ID;
	const surveyId = env.SURVEY_ID;

	const startDate = dayjs().subtract(1, 'day').startOf('day');
	const endDate = dayjs().subtract(1, 'day').endOf('day');

	const { items } = await openApiClient.SurveyService.surveyResultList({
		workspaceId,
		surveyId,
		startAt: startDate.valueOf(),
		endAt: endDate.valueOf(),
		limit: 1000,
	});

	const resultList = items.filter((item) => Boolean(item.aiCategory));

	const title = `[${startDate.format('YYYY-MM-DD HH:mm:ss')} ~ ${endDate.format('HH:mm:ss')}] Survey Daily Report`;

	let content = '';

	const categoryCount: { [category: string]: number } = {};
	resultList.forEach((record) => {
		const category = record.aiCategory || 'Uncategorized';
		categoryCount[category] = (categoryCount[category] || 0) + 1;
	});

	const sortedCategories = Object.entries(categoryCount).sort((a, b) => b[1] - a[1]);

	content += `All Categories(${resultList.length}):\n`;
	sortedCategories.forEach(([category, count]) => {
		content += `- ${category}(${count})\n`;
	});

	// 3. Get top 3 categories with the most records
	const top3Categories = sortedCategories.slice(0, 3);

	content += `\n\nTop Issues:\n`;
	top3Categories.forEach(([category, count]) => {
		// Filter all records of the corresponding category
		const records = resultList.filter((record) => record.aiCategory === category);
		// Sample 3 records (or return all if less than 3)
		const sampledRecords = sampleItems(records, 3);

		content += `- ${category} (${count})\n`;
		sampledRecords.forEach((record) => {
			content += `  - ${record.aiTranslation}\n`;
		});
	});

	await Promise.all([
		notifyToFeishu(env, title, content),
		addFeishuBitableRecord(
			env,
			items.map((item) => ({
				id: item.id,