fix: force dynamic for meeting page

This commit is contained in:
李超14pro
2026-01-25 21:55:29 +08:00
commit e3e5e89df6
112 changed files with 19073 additions and 0 deletions

136
app/api/checkins/route.ts Normal file
View File

@@ -0,0 +1,136 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
import { determineKRStatus, determineProjectStatus } from '@/lib/kr-utils';
import type { KR, Checkin } from '@/types/database';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const krId = searchParams.get('kr_id');
const projectId = searchParams.get('project_id');
const userId = searchParams.get('user_id');
const limit = searchParams.get('limit');
let query = supabase
.from('checkins')
.select(`
*,
user:users(id, name, avatar_url),
kr:krs(id, title, metric_name, unit)
`)
.order('created_at', { ascending: false });
if (krId) query = query.eq('kr_id', krId);
if (projectId) query = query.eq('project_id', projectId);
if (userId) query = query.eq('user_id', userId);
if (limit) query = query.limit(parseInt(limit));
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { kr_id, project_id, user_id, date, current_value, confidence, reason_code, note } = body;
if (!kr_id || !project_id || current_value === undefined || confidence === undefined) {
return NextResponse.json(
{ error: 'KR ID、项目ID、当前值和信心度为必填项' },
{ status: 400 }
);
}
const { data: krData, error: krError } = await supabase
.from('krs')
.select('*')
.eq('id', kr_id)
.single();
if (krError || !krData) {
return NextResponse.json({ error: 'KR不存在' }, { status: 404 });
}
const kr = krData as KR;
const { data: recentCheckins } = await supabase
.from('checkins')
.select('*')
.eq('kr_id', kr_id)
.order('created_at', { ascending: false })
.limit(2);
const delta_value = current_value - kr.current_value;
const updatedKR: KR = {
...kr,
current_value,
confidence,
reason_code: reason_code || kr.reason_code,
note: note || kr.note,
};
const newStatus = determineKRStatus(updatedKR, (recentCheckins as Checkin[]) || []);
if ((newStatus === 'yellow' || newStatus === 'red') && !reason_code) {
return NextResponse.json(
{ error: '黄色或红色状态必须提供原因代码' },
{ status: 400 }
);
}
const checkinDate = date || new Date().toISOString().split('T')[0];
const { data: checkin, error: checkinError } = await supabase
.from('checkins')
.insert({
kr_id,
project_id,
user_id,
date: checkinDate,
current_value,
delta_value,
confidence,
status_snapshot: newStatus,
reason_code,
note,
})
.select()
.single();
if (checkinError) {
return NextResponse.json({ error: checkinError.message }, { status: 500 });
}
await supabase
.from('krs')
.update({
current_value,
confidence,
status: newStatus,
reason_code: reason_code || (newStatus === 'green' ? null : kr.reason_code),
note: note || kr.note,
updated_at: new Date().toISOString(),
})
.eq('id', kr_id);
const { data: projectKRs } = await supabase
.from('krs')
.select('status')
.eq('project_id', project_id);
if (projectKRs) {
const projectStatus = determineProjectStatus(projectKRs as KR[]);
await supabase
.from('projects')
.update({ status: projectStatus, updated_at: new Date().toISOString() })
.eq('id', project_id);
}
return NextResponse.json(checkin, { status: 201 });
}

109
app/api/krs/[id]/route.ts Normal file
View File

@@ -0,0 +1,109 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('krs')
.select(`
*,
owner:users!krs_owner_user_id_fkey(id, name, role, avatar_url),
project:projects(id, name, status),
objective:objectives(id, title, period_start, period_end)
`)
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: 'KR不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const {
title,
metric_name,
unit,
direction,
target_value,
current_value,
confidence,
status,
reason_code,
note,
need_owner_help,
period_start,
period_end,
period_type,
period_name,
objective_id,
} = body;
if ((status === 'yellow' || status === 'red') && !reason_code && !body.skipReasonCodeCheck) {
return NextResponse.json(
{ error: '黄色或红色状态必须提供原因代码' },
{ status: 400 }
);
}
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (title !== undefined) updateData.title = title;
if (metric_name !== undefined) updateData.metric_name = metric_name;
if (unit !== undefined) updateData.unit = unit;
if (direction !== undefined) updateData.direction = direction;
if (target_value !== undefined) updateData.target_value = target_value;
if (current_value !== undefined) updateData.current_value = current_value;
if (confidence !== undefined) updateData.confidence = confidence;
if (status !== undefined) updateData.status = status;
if (reason_code !== undefined) updateData.reason_code = reason_code;
if (note !== undefined) updateData.note = note;
if (need_owner_help !== undefined) updateData.need_owner_help = need_owner_help;
if (period_start !== undefined) updateData.period_start = period_start;
if (period_end !== undefined) updateData.period_end = period_end;
if (period_type !== undefined) updateData.period_type = period_type;
if (period_name !== undefined) updateData.period_name = period_name;
if (objective_id !== undefined) updateData.objective_id = objective_id;
const { data, error } = await supabase
.from('krs')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('krs')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

114
app/api/krs/route.ts Normal file
View File

@@ -0,0 +1,114 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const projectId = searchParams.get('project_id');
const objectiveId = searchParams.get('objective_id');
const ownerUserId = searchParams.get('owner_user_id');
const status = searchParams.get('status');
let query = supabase
.from('krs')
.select(`
*,
owner:users!krs_owner_user_id_fkey(id, name, role, avatar_url),
project:projects(id, name, status)
`)
.order('period_start', { ascending: false });
if (projectId) query = query.eq('project_id', projectId);
if (objectiveId) query = query.eq('objective_id', objectiveId);
if (ownerUserId) query = query.eq('owner_user_id', ownerUserId);
if (status) query = query.eq('status', status);
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const {
project_id,
objective_id,
period_type,
period_name,
period_start,
period_end,
title,
metric_name,
unit,
direction,
target_value,
owner_user_id,
confidence,
note,
} = body;
if (!project_id || !title || !metric_name || !unit || !target_value || !period_start || !period_end) {
return NextResponse.json(
{ error: '项目ID、标题、指标名称、单位、目标值、开始和结束日期为必填项' },
{ status: 400 }
);
}
if (target_value <= 0) {
return NextResponse.json({ error: '目标值必须大于0' }, { status: 400 });
}
if (new Date(period_end) < new Date(period_start)) {
return NextResponse.json({ error: '结束日期不能早于开始日期' }, { status: 400 });
}
if (owner_user_id) {
const { data: existingKRs } = await supabase
.from('krs')
.select('id')
.eq('owner_user_id', owner_user_id)
.eq('period_start', period_start)
.eq('period_end', period_end);
if (existingKRs && existingKRs.length >= 3) {
return NextResponse.json(
{ error: '该用户在此周期内已有3个KR,无法继续创建' },
{ status: 400 }
);
}
}
const { data, error } = await supabase
.from('krs')
.insert({
project_id,
objective_id,
period_type: period_type || 'custom',
period_name,
period_start,
period_end,
title,
metric_name,
unit,
direction: direction || 'increase',
target_value,
current_value: 0,
owner_user_id,
confidence: confidence || 80,
status: 'green',
note,
})
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}

View File

@@ -0,0 +1,70 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('meetings')
.select(`
*,
created_by_user:users!meetings_created_by_fkey(id, name, avatar_url),
project:projects(id, name)
`)
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '会议记录不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { summary, decisions, risks, next_period_commitments } = body;
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (summary !== undefined) updateData.summary = summary;
if (decisions !== undefined) updateData.decisions = decisions;
if (risks !== undefined) updateData.risks = risks;
if (next_period_commitments !== undefined) updateData.next_period_commitments = next_period_commitments;
const { data, error } = await supabase
.from('meetings')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('meetings')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

59
app/api/meetings/route.ts Normal file
View File

@@ -0,0 +1,59 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const projectId = searchParams.get('project_id');
let query = supabase
.from('meetings')
.select(`
*,
created_by_user:users!meetings_created_by_fkey(id, name, avatar_url),
project:projects(id, name)
`)
.order('created_at', { ascending: false });
if (projectId) query = query.eq('project_id', projectId);
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { project_id, period_start, period_end, summary, decisions, risks, next_period_commitments, created_by } = body;
if (!project_id || !period_start || !period_end || !summary) {
return NextResponse.json(
{ error: '项目ID、周期开始日期、周期结束日期和总结为必填项' },
{ status: 400 }
);
}
const { data, error } = await supabase
.from('meetings')
.insert({
project_id,
period_start,
period_end,
summary,
decisions,
risks,
next_period_commitments,
created_by,
})
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}

View File

@@ -0,0 +1,67 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('metrics')
.select('*')
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '指标不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { name, unit, direction, category, is_active } = body;
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (name !== undefined) updateData.name = name;
if (unit !== undefined) updateData.unit = unit;
if (direction !== undefined) updateData.direction = direction;
if (category !== undefined) updateData.category = category;
if (is_active !== undefined) updateData.is_active = is_active;
const { data, error } = await supabase
.from('metrics')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('metrics')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

48
app/api/metrics/route.ts Normal file
View File

@@ -0,0 +1,48 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const activeOnly = searchParams.get('active_only') === 'true';
const category = searchParams.get('category');
let query = supabase.from('metrics').select('*').order('name', { ascending: true });
if (activeOnly) query = query.eq('is_active', true);
if (category) query = query.eq('category', category);
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { name, unit, direction, category } = body;
if (!name || !unit) {
return NextResponse.json({ error: '名称和单位为必填项' }, { status: 400 });
}
const { data, error } = await supabase
.from('metrics')
.insert({
name,
unit,
direction: direction || 'increase',
category,
is_active: true,
})
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}

View File

@@ -0,0 +1,68 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('objectives')
.select('*')
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '目标不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { title, description, period_start, period_end } = body;
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (title !== undefined) updateData.title = title;
if (description !== undefined) updateData.description = description;
if (period_start !== undefined) updateData.period_start = period_start;
if (period_end !== undefined) updateData.period_end = period_end;
const { data, error } = await supabase
.from('objectives')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('objectives')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

View File

@@ -0,0 +1,48 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const projectId = searchParams.get('project_id');
let query = supabase.from('objectives').select('*').order('period_start', { ascending: false });
if (projectId) {
query = query.eq('project_id', projectId);
}
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { project_id, title, description, period_start, period_end, created_by } = body;
if (!project_id || !title || !period_start || !period_end) {
return NextResponse.json({ error: '项目ID、标题、开始日期和结束日期为必填项' }, { status: 400 });
}
if (new Date(period_end) < new Date(period_start)) {
return NextResponse.json({ error: '结束日期不能早于开始日期' }, { status: 400 });
}
const { data, error } = await supabase
.from('objectives')
.insert({ project_id, title, description, period_start, period_end, created_by })
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}

View File

@@ -0,0 +1,66 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('project_members')
.select('user_id, users(id, name, role, avatar_url)')
.eq('project_id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { user_id } = body;
if (!user_id) {
return NextResponse.json({ error: '用户ID为必填项' }, { status: 400 });
}
const { data, error } = await supabase
.from('project_members')
.insert({ project_id: params.id, user_id })
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { searchParams } = new URL(request.url);
const userId = searchParams.get('user_id');
if (!userId) {
return NextResponse.json({ error: '用户ID为必填项' }, { status: 400 });
}
const { error } = await supabase
.from('project_members')
.delete()
.eq('project_id', params.id)
.eq('user_id', userId);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

View File

@@ -0,0 +1,91 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('projects')
.select(`
*,
owner:users!projects_owner_id_fkey(id, name, role, avatar_url),
pm:users!projects_pm_id_fkey(id, name, role, avatar_url)
`)
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '项目不存在' }, { status: 404 });
}
const { data: members } = await supabase
.from('project_members')
.select('user_id, users(id, name, role, avatar_url)')
.eq('project_id', params.id);
return NextResponse.json({ ...data, members: members || [] });
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { name, description, owner_id, pm_id, project_type, status, member_ids } = body;
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (name !== undefined) updateData.name = name;
if (description !== undefined) updateData.description = description;
if (owner_id !== undefined) updateData.owner_id = owner_id;
if (pm_id !== undefined) updateData.pm_id = pm_id;
if (project_type !== undefined) updateData.project_type = project_type;
if (status !== undefined) updateData.status = status;
const { data, error } = await supabase
.from('projects')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (member_ids !== undefined) {
await supabase.from('project_members').delete().eq('project_id', params.id);
if (member_ids.length > 0) {
const memberRecords = member_ids.map((userId: string) => ({
project_id: params.id,
user_id: userId,
}));
await supabase.from('project_members').insert(memberRecords);
}
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('projects')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

58
app/api/projects/route.ts Normal file
View File

@@ -0,0 +1,58 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET() {
const { data, error } = await supabase
.from('projects')
.select(`
*,
owner:users!projects_owner_id_fkey(id, name, role, avatar_url),
pm:users!projects_pm_id_fkey(id, name, role, avatar_url)
`)
.order('created_at', { ascending: false });
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { name, description, owner_id, pm_id, project_type, member_ids } = body;
if (!name) {
return NextResponse.json({ error: '项目名称为必填项' }, { status: 400 });
}
const { data: project, error: projectError } = await supabase
.from('projects')
.insert({
name,
description,
owner_id,
pm_id,
project_type: project_type || 'general',
status: 'green',
})
.select()
.single();
if (projectError) {
return NextResponse.json({ error: projectError.message }, { status: 500 });
}
if (member_ids && member_ids.length > 0) {
const memberRecords = member_ids.map((userId: string) => ({
project_id: project.id,
user_id: userId,
}));
await supabase.from('project_members').insert(memberRecords);
}
return NextResponse.json(project, { status: 201 });
}

284
app/api/seed/route.ts Normal file
View File

@@ -0,0 +1,284 @@
export const dynamic = 'force-dynamic';
import { NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
function addDays(date: Date, days: number): string {
const result = new Date(date);
result.setDate(result.getDate() + days);
return result.toISOString().split('T')[0];
}
export async function POST() {
const today = new Date();
const todayStr = today.toISOString().split('T')[0];
const ownerUser = {
name: '老板',
role: 'owner' as const,
avatar_url: null,
};
const pmUser = {
name: '张项目经理',
role: 'pm' as const,
avatar_url: null,
};
const memberUser = {
name: '李工程师',
role: 'member' as const,
avatar_url: null,
};
const { data: users, error: usersError } = await supabase
.from('users')
.insert([ownerUser, pmUser, memberUser])
.select();
if (usersError || !users) {
return NextResponse.json({ error: usersError?.message || '创建用户失败' }, { status: 500 });
}
const [owner, pm, member] = users;
const project1 = {
name: '产品升级项目',
description: '核心产品功能升级与优化',
owner_id: owner.id,
pm_id: pm.id,
project_type: '产品研发',
status: 'green' as const,
};
const project2 = {
name: '市场拓展计划',
description: '新市场开拓与客户获取',
owner_id: owner.id,
pm_id: pm.id,
project_type: '市场营销',
status: 'yellow' as const,
};
const { data: projects, error: projectsError } = await supabase
.from('projects')
.insert([project1, project2])
.select();
if (projectsError || !projects) {
return NextResponse.json({ error: projectsError?.message || '创建项目失败' }, { status: 500 });
}
const [proj1, proj2] = projects;
await supabase.from('project_members').insert([
{ project_id: proj1.id, user_id: owner.id },
{ project_id: proj1.id, user_id: pm.id },
{ project_id: proj1.id, user_id: member.id },
{ project_id: proj2.id, user_id: owner.id },
{ project_id: proj2.id, user_id: pm.id },
]);
const objective1 = {
project_id: proj1.id,
title: '提升产品用户体验和性能',
description: '通过优化核心功能,提升用户满意度和系统性能',
period_start: addDays(today, -15),
period_end: addDays(today, 15),
created_by: owner.id,
};
const { data: objectives, error: objectivesError } = await supabase
.from('objectives')
.insert([objective1])
.select();
if (objectivesError || !objectives) {
return NextResponse.json({ error: objectivesError?.message || '创建目标失败' }, { status: 500 });
}
const [obj1] = objectives;
const krs = [
{
project_id: proj1.id,
objective_id: obj1.id,
period_type: '1w' as const,
period_name: '本周',
period_start: addDays(today, -3),
period_end: addDays(today, 4),
title: '完成首页加载速度优化',
metric_name: '页面加载时间',
unit: '秒',
direction: 'decrease' as const,
target_value: 2,
current_value: 2.8,
owner_user_id: member.id,
confidence: 85,
status: 'green' as const,
reason_code: null,
note: null,
need_owner_help: false,
},
{
project_id: proj1.id,
objective_id: obj1.id,
period_type: '3d' as const,
period_name: '紧急任务',
period_start: todayStr,
period_end: addDays(today, 3),
title: '修复关键Bug',
metric_name: 'Bug修复数',
unit: '个',
direction: 'increase' as const,
target_value: 5,
current_value: 2,
owner_user_id: member.id,
confidence: 70,
status: 'yellow' as const,
reason_code: 'RESOURCE' as const,
note: '需要更多测试资源',
},
{
project_id: proj1.id,
objective_id: obj1.id,
period_type: '2w' as const,
period_name: '双周迭代',
period_start: addDays(today, -7),
period_end: addDays(today, 7),
title: '提升用户满意度评分',
metric_name: 'NPS评分',
unit: '分',
direction: 'increase' as const,
target_value: 50,
current_value: 35,
owner_user_id: pm.id,
confidence: 60,
status: 'yellow' as const,
reason_code: 'DEPENDENCY' as const,
note: '依赖功能还未上线',
need_owner_help: false,
},
{
project_id: proj2.id,
objective_id: null,
period_type: 'monthly' as const,
period_name: '月度目标',
period_start: addDays(today, -10),
period_end: addDays(today, 20),
title: '新客户获取',
metric_name: '新签客户数',
unit: '家',
direction: 'increase' as const,
target_value: 10,
current_value: 3,
owner_user_id: pm.id,
confidence: 45,
status: 'red' as const,
reason_code: 'EXECUTION' as const,
note: '市场推广效果不及预期',
need_owner_help: true,
},
];
const { data: krsData, error: krsError } = await supabase
.from('krs')
.insert(krs)
.select();
if (krsError || !krsData) {
return NextResponse.json({ error: krsError?.message || '创建KR失败' }, { status: 500 });
}
const checkins = krsData.flatMap((kr) => {
const baseCheckins = [];
for (let i = 0; i < 20; i++) {
const checkinDate = addDays(today, -i - 1);
const progressMultiplier = (20 - i) / 21;
baseCheckins.push({
kr_id: kr.id,
project_id: kr.project_id,
user_id: kr.owner_user_id,
date: checkinDate,
current_value: kr.current_value * progressMultiplier,
delta_value: kr.current_value * 0.1,
confidence: kr.confidence + (i * 5),
status_snapshot: i === 0 ? kr.status : 'green',
reason_code: i === 0 ? kr.reason_code : null,
note: i === 0 ? `进度更新 - ${kr.title}` : null,
});
}
return baseCheckins;
});
await supabase.from('checkins').insert(checkins);
const meeting = {
project_id: proj1.id,
period_start: addDays(today, -7),
period_end: addDays(today, -1),
summary: `本周期完成情况总结:
- 页面加载优化进展顺利,预计可按时完成
- Bug修复进度略有滞后,需要协调测试资源
- 用户满意度提升依赖新功能上线
完成率:约65%`,
decisions: `1. 协调测试团队支援Bug修复
2. 推动依赖功能优先上线
3. 下周进行用户回访收集反馈`,
risks: `- 测试资源紧张可能影响交付质量
- 依赖功能延期风险`,
next_period_commitments: `- 完成所有关键Bug修复
- 页面加载时间降至2秒以内
- 收集至少20份用户反馈`,
created_by: pm.id,
};
await supabase.from('meetings').insert([meeting]);
const metrics = [
{ name: '页面加载时间', unit: '秒', direction: 'decrease' as const, category: '技术性能' },
{ name: 'Bug修复数', unit: '个', direction: 'increase' as const, category: '质量' },
{ name: 'NPS评分', unit: '分', direction: 'increase' as const, category: '用户体验' },
{ name: '新签客户数', unit: '家', direction: 'increase' as const, category: '业务' },
{ name: '活跃用户数', unit: '人', direction: 'increase' as const, category: '业务' },
{ name: '客户流失率', unit: '%', direction: 'decrease' as const, category: '业务' },
{ name: '代码覆盖率', unit: '%', direction: 'increase' as const, category: '质量' },
{ name: '响应时间', unit: 'ms', direction: 'decrease' as const, category: '技术性能' },
];
await supabase.from('metrics').insert(metrics);
const templates = [
{
name: '产品迭代模板',
description: '适用于产品功能迭代的KR模板',
project_type: '产品研发',
tags: ['产品', '迭代', '功能'],
items: [
{ title: '功能上线', metricName: '功能完成数', unit: '个', direction: 'increase', targetValue: 3 },
{ title: '性能优化', metricName: '响应时间', unit: 'ms', direction: 'decrease', targetValue: 200 },
{ title: '质量保障', metricName: 'Bug数', unit: '个', direction: 'decrease', targetValue: 5 },
],
},
{
name: '市场拓展模板',
description: '适用于市场营销项目的KR模板',
project_type: '市场营销',
tags: ['市场', '营销', '客户'],
items: [
{ title: '客户获取', metricName: '新客户数', unit: '家', direction: 'increase', targetValue: 10 },
{ title: '线索转化', metricName: '转化率', unit: '%', direction: 'increase', targetValue: 30 },
{ title: '客户留存', metricName: '续约率', unit: '%', direction: 'increase', targetValue: 85 },
],
},
];
await supabase.from('templates').insert(templates);
return NextResponse.json({
success: true,
ownerId: owner.id,
message: '演示数据已成功创建',
});
}

View File

@@ -0,0 +1,68 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('templates')
.select('*')
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '模板不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { name, description, project_type, tags, items, is_active } = body;
const updateData: Record<string, unknown> = { updated_at: new Date().toISOString() };
if (name !== undefined) updateData.name = name;
if (description !== undefined) updateData.description = description;
if (project_type !== undefined) updateData.project_type = project_type;
if (tags !== undefined) updateData.tags = tags;
if (items !== undefined) updateData.items = items;
if (is_active !== undefined) updateData.is_active = is_active;
const { data, error } = await supabase
.from('templates')
.update(updateData)
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('templates')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

View File

@@ -0,0 +1,49 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(request: NextRequest) {
const { searchParams } = new URL(request.url);
const activeOnly = searchParams.get('active_only') === 'true';
const projectType = searchParams.get('project_type');
let query = supabase.from('templates').select('*').order('name', { ascending: true });
if (activeOnly) query = query.eq('is_active', true);
if (projectType) query = query.eq('project_type', projectType);
const { data, error } = await query;
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { name, description, project_type, tags, items } = body;
if (!name || !items || items.length === 0) {
return NextResponse.json({ error: '名称和至少一个模板项为必填项' }, { status: 400 });
}
const { data, error } = await supabase
.from('templates')
.insert({
name,
description,
project_type,
tags: tags || [],
items,
is_active: true,
})
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}

View File

@@ -0,0 +1,60 @@
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { data, error } = await supabase
.from('users')
.select('*')
.eq('id', params.id)
.maybeSingle();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
if (!data) {
return NextResponse.json({ error: '用户不存在' }, { status: 404 });
}
return NextResponse.json(data);
}
export async function PATCH(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const body = await request.json();
const { name, role, avatar_url } = body;
const { data, error } = await supabase
.from('users')
.update({ name, role, avatar_url, updated_at: new Date().toISOString() })
.eq('id', params.id)
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { error } = await supabase
.from('users')
.delete()
.eq('id', params.id);
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json({ success: true });
}

38
app/api/users/route.ts Normal file
View File

@@ -0,0 +1,38 @@
export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from 'next/server';
import { supabase } from '@/lib/supabase';
export async function GET() {
const { data, error } = await supabase
.from('users')
.select('*')
.order('created_at', { ascending: true });
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data);
}
export async function POST(request: NextRequest) {
const body = await request.json();
const { name, role, avatar_url } = body;
if (!name || !role) {
return NextResponse.json({ error: '名称和角色为必填项' }, { status: 400 });
}
const { data, error } = await supabase
.from('users')
.insert({ name, role, avatar_url })
.select()
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(data, { status: 201 });
}