{content_preview}
" if content_preview else None, + email_action_path="/announcements", + ) + + return announcement + + +async def update_announcement( + db: AsyncSession, announcement: Announcement, data: AnnouncementUpdate +) -> Announcement: + for field, value in data.model_dump(exclude_unset=True).items(): + setattr(announcement, field, value) + await db.commit() + await db.refresh(announcement) + return announcement + + +async def delete_announcement(db: AsyncSession, announcement: Announcement): + await db.delete(announcement) + await db.commit() + + +async def get_announcement_by_id(db: AsyncSession, announcement_id: int) -> Announcement | None: + result = await db.execute( + select(Announcement) + .options(selectinload(Announcement.author)) + .where(Announcement.id == announcement_id) + ) + return result.scalar_one_or_none() + + +async def list_announcements( + db: AsyncSession, class_id: int, page: int = 1, page_size: int = 20 +) -> tuple[list[Announcement], int]: + total_result = await db.execute( + select(func.count(Announcement.id)).where(Announcement.class_id == class_id) + ) + total = total_result.scalar() or 0 + + result = await db.execute( + select(Announcement) + .options(selectinload(Announcement.author)) + .where(Announcement.class_id == class_id) + .order_by(Announcement.is_pinned.desc(), Announcement.created_at.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + announcements = list(result.scalars().all()) + return announcements, total diff --git a/backend/app/services/assignment_service.py b/backend/app/services/assignment_service.py new file mode 100644 index 0000000..a0807ae --- /dev/null +++ b/backend/app/services/assignment_service.py @@ -0,0 +1,179 @@ +from datetime import datetime + +from sqlalchemy import select, func +from sqlalchemy.ext.asyncio import AsyncSession +from sqlalchemy.orm import selectinload + +from app.db.models import Assignment, AssignmentSubmission, User +from app.schemas.assignment import AssignmentCreate, AssignmentUpdate, SubmissionCreate, SubmissionGrade +from app.services.notification_service import create_notifications_for_class + + +async def create_assignment( + db: AsyncSession, class_id: int, creator_id: int, data: AssignmentCreate +) -> Assignment: + assignment = Assignment( + class_id=class_id, + creator_id=creator_id, + title=data.title, + description=data.description, + deadline=data.deadline, + ) + db.add(assignment) + await db.commit() + await db.refresh(assignment) + + await create_notifications_for_class( + db, class_id, "assignment", f"新作业: {data.title}", + content=data.description, + related_id=assignment.id, + email_subject=f"HKU ICB - 新作业: {data.title}", + email_body=f"{data.description or data.title}
", + email_action_path="/assignments", + ) + + return assignment + + +async def update_assignment( + db: AsyncSession, assignment: Assignment, data: AssignmentUpdate +) -> Assignment: + for field, value in data.model_dump(exclude_unset=True).items(): + setattr(assignment, field, value) + await db.commit() + await db.refresh(assignment) + return assignment + + +async def delete_assignment(db: AsyncSession, assignment: Assignment): + await db.delete(assignment) + await db.commit() + + +async def get_assignment_by_id(db: AsyncSession, assignment_id: int) -> Assignment | None: + result = await db.execute( + select(Assignment) + .options( + selectinload(Assignment.creator), + selectinload(Assignment.submissions).selectinload(AssignmentSubmission.student), + ) + .where(Assignment.id == assignment_id) + ) + return result.scalar_one_or_none() + + +async def list_assignments( + db: AsyncSession, class_id: int, page: int = 1, page_size: int = 20 +) -> tuple[list[Assignment], int]: + total_result = await db.execute( + select(func.count(Assignment.id)).where(Assignment.class_id == class_id) + ) + total = total_result.scalar() or 0 + + result = await db.execute( + select(Assignment) + .options( + selectinload(Assignment.creator), + selectinload(Assignment.submissions), + ) + .where(Assignment.class_id == class_id) + .order_by(Assignment.created_at.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + return list(result.scalars().all()), total + + +async def add_attachments(db: AsyncSession, assignment: Assignment, urls: list[str]): + existing = assignment.get_attachment_urls_list() + existing.extend(urls) + assignment.set_attachment_urls_list(existing) + await db.commit() + await db.refresh(assignment) + + +async def create_submission( + db: AsyncSession, + assignment_id: int, + student_id: int, + notes: str | None, + file_url: str | None = None, + file_name: str | None = None, + file_type: str | None = None, + file_size: int | None = None, +) -> AssignmentSubmission: + # Check assignment exists and is open + a_result = await db.execute(select(Assignment).where(Assignment.id == assignment_id)) + assignment = a_result.scalar_one_or_none() + if assignment is None: + raise ValueError("作业不存在") + if assignment.status != "open": + raise ValueError("作业已关闭提交") + if assignment.deadline and datetime.now() > assignment.deadline: + raise ValueError("作业已过截止日期") + + # Check no existing submission + existing = await db.execute( + select(AssignmentSubmission).where( + AssignmentSubmission.assignment_id == assignment_id, + AssignmentSubmission.student_id == student_id, + ) + ) + if existing.scalar_one_or_none(): + raise ValueError("你已经提交过作业了") + + submission = AssignmentSubmission( + assignment_id=assignment_id, + student_id=student_id, + notes=notes, + file_url=file_url, + file_name=file_name, + file_type=file_type, + file_size=file_size, + ) + db.add(submission) + await db.commit() + await db.refresh(submission) + + # Reload with student relationship + result = await db.execute( + select(AssignmentSubmission) + .options(selectinload(AssignmentSubmission.student)) + .where(AssignmentSubmission.id == submission.id) + ) + return result.scalar_one() + + +async def get_submission_by_student( + db: AsyncSession, assignment_id: int, student_id: int +) -> AssignmentSubmission | None: + result = await db.execute( + select(AssignmentSubmission) + .options(selectinload(AssignmentSubmission.student)) + .where( + AssignmentSubmission.assignment_id == assignment_id, + AssignmentSubmission.student_id == student_id, + ) + ) + return result.scalar_one_or_none() + + +async def grade_submission( + db: AsyncSession, submission: AssignmentSubmission, data: SubmissionGrade +) -> AssignmentSubmission: + submission.grade = data.grade + submission.feedback = data.feedback + submission.graded_at = datetime.now() + await db.commit() + await db.refresh(submission) + return submission + + +async def list_submissions(db: AsyncSession, assignment_id: int) -> list[AssignmentSubmission]: + result = await db.execute( + select(AssignmentSubmission) + .options(selectinload(AssignmentSubmission.student)) + .where(AssignmentSubmission.assignment_id == assignment_id) + .order_by(AssignmentSubmission.created_at.desc()) + ) + return list(result.scalars().all()) diff --git a/backend/app/services/class_service.py b/backend/app/services/class_service.py new file mode 100644 index 0000000..003efd1 --- /dev/null +++ b/backend/app/services/class_service.py @@ -0,0 +1,79 @@ +from sqlalchemy import select, func +from sqlalchemy.ext.asyncio import AsyncSession + +from app.db.models import Class_, User +from app.schemas.class_ import ClassCreate, ClassUpdate + + +async def create_class(db: AsyncSession, data: ClassCreate) -> Class_: + class_ = Class_(**data.model_dump()) + db.add(class_) + await db.commit() + await db.refresh(class_) + return class_ + + +async def update_class(db: AsyncSession, class_: Class_, data: ClassUpdate) -> Class_: + for field, value in data.model_dump(exclude_unset=True).items(): + setattr(class_, field, value) + await db.commit() + await db.refresh(class_) + return class_ + + +async def delete_class(db: AsyncSession, class_: Class_): + await db.delete(class_) + await db.commit() + + +async def get_class_by_id(db: AsyncSession, class_id: int) -> Class_ | None: + result = await db.execute(select(Class_).where(Class_.id == class_id)) + return result.scalar_one_or_none() + + +async def list_classes( + db: AsyncSession, page: int = 1, page_size: int = 50 +) -> tuple[list[Class_], int]: + total_result = await db.execute(select(func.count(Class_.id))) + total = total_result.scalar() or 0 + + result = await db.execute( + select(Class_) + .order_by(Class_.cohort_year.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + classes = list(result.scalars().all()) + return classes, total + + +async def get_member_count(db: AsyncSession, class_id: int) -> int: + result = await db.execute( + select(func.count(User.id)).where( + User.class_id == class_id, User.status == "approved" + ) + ) + return result.scalar() or 0 + + +async def get_class_members( + db: AsyncSession, + class_id: int, + status: str | None = None, + page: int = 1, + page_size: int = 50, +) -> tuple[list[User], int]: + query = select(User).where(User.class_id == class_id) + count_query = select(func.count(User.id)).where(User.class_id == class_id) + + if status: + query = query.where(User.status == status) + count_query = count_query.where(User.status == status) + + total_result = await db.execute(count_query) + total = total_result.scalar() or 0 + + result = await db.execute( + query.order_by(User.name).offset((page - 1) * page_size).limit(page_size) + ) + return list(result.scalars().all()), total diff --git a/backend/app/services/cos_service.py b/backend/app/services/cos_service.py new file mode 100644 index 0000000..2fbd850 --- /dev/null +++ b/backend/app/services/cos_service.py @@ -0,0 +1,75 @@ +import uuid +from datetime import datetime +from io import BytesIO + +from qcloud_cos import CosConfig, CosS3Client + +from app.config import settings + +config = CosConfig( + Region=settings.cos_region, + SecretId=settings.cos_secret_id, + SecretKey=settings.cos_secret_key, +) +client = CosS3Client(config) + +ALLOWED_IMAGE_TYPES = { + "image/jpeg": ".jpg", + "image/png": ".png", + "image/gif": ".gif", + "image/webp": ".webp", +} + + +def upload_bytes(key: str, data: bytes, content_type: str) -> str: + """Upload raw bytes to COS, return the public URL.""" + client.put_object( + Bucket=settings.cos_bucket, + Key=key, + Body=BytesIO(data), + ContentType=content_type, + ) + return f"{settings.cos_base_url}/{key}" + + +def upload_image(prefix: str, filename: str, data: bytes, content_type: str) -> str: + """ + Upload an image to COS under the given prefix. + Returns the public URL. + """ + if content_type not in ALLOWED_IMAGE_TYPES: + raise ValueError(f"Unsupported image type: {content_type}") + + ext = ALLOWED_IMAGE_TYPES[content_type] + date_path = datetime.now().strftime("%Y/%m/%d") + unique_name = uuid.uuid4().hex[:12] + key = f"{prefix}/{date_path}/{unique_name}{ext}" + + return upload_bytes(key, data, content_type) + + +FILE_TYPE_EXTENSIONS = { + "application/pdf": ".pdf", + "application/msword": ".doc", + "application/vnd.openxmlformats-officedocument.wordprocessingml.document": ".docx", + "application/vnd.ms-excel": ".xls", + "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet": ".xlsx", + "application/vnd.ms-powerpoint": ".ppt", + "application/vnd.openxmlformats-officedocument.presentationml.presentation": ".pptx", + "application/zip": ".zip", + "text/plain": ".txt", + "image/jpeg": ".jpg", + "image/png": ".png", + "image/gif": ".gif", + "image/webp": ".webp", +} + + +def upload_file(prefix: str, filename: str, data: bytes, content_type: str) -> str: + """Upload any allowed file type to COS. Returns the public URL.""" + ext = FILE_TYPE_EXTENSIONS.get(content_type, "") + date_path = datetime.now().strftime("%Y/%m/%d") + unique_name = uuid.uuid4().hex[:12] + key = f"{prefix}/{date_path}/{unique_name}{ext}" + + return upload_bytes(key, data, content_type) diff --git a/backend/app/services/directory_service.py b/backend/app/services/directory_service.py new file mode 100644 index 0000000..72b56a5 --- /dev/null +++ b/backend/app/services/directory_service.py @@ -0,0 +1,77 @@ +import json +from sqlalchemy import select, or_, func +from sqlalchemy.ext.asyncio import AsyncSession + +from app.db.models import User +from app.schemas.user import UserPublic + + +async def search_directory( + db: AsyncSession, + class_id: int, + search: str | None = None, + industry: str | None = None, + company: str | None = None, + page: int = 1, + page_size: int = 20, +) -> tuple[list[User], int]: + """Search approved members in a class.""" + query = select(User).where( + User.class_id == class_id, User.status == "approved" + ) + count_query = select(func.count(User.id)).where( + User.class_id == class_id, User.status == "approved" + ) + + if search: + search_term = f"%{search}%" + query = query.where( + or_( + User.name.ilike(search_term), + User.company.ilike(search_term), + User.position.ilike(search_term), + ) + ) + count_query = count_query.where( + or_( + User.name.ilike(search_term), + User.company.ilike(search_term), + User.position.ilike(search_term), + ) + ) + + if industry: + query = query.where(User.industry == industry) + count_query = count_query.where(User.industry == industry) + + if company: + company_term = f"%{company}%" + query = query.where(User.company.ilike(company_term)) + count_query = count_query.where(User.company.ilike(company_term)) + + total_result = await db.execute(count_query) + total = total_result.scalar() or 0 + + result = await db.execute( + query.order_by(User.name) + .offset((page - 1) * page_size) + .limit(page_size) + ) + users = list(result.scalars().all()) + return users, total + + +def user_to_public(user: User, include_contact: bool = True) -> UserPublic: + """Convert User model to public profile, optionally hiding contact info.""" + return UserPublic( + id=user.id, + name=user.name, + student_id=user.student_id, + industry=user.industry, + company=user.company, + position=user.position, + wechat_id=user.wechat_id if include_contact else None, + phone=user.phone if include_contact else None, + avatar_url=user.avatar_url, + bio=user.bio, + ) diff --git a/backend/app/services/email_service.py b/backend/app/services/email_service.py new file mode 100644 index 0000000..28f0b20 --- /dev/null +++ b/backend/app/services/email_service.py @@ -0,0 +1,95 @@ +import logging +from email.mime.multipart import MIMEMultipart +from email.mime.text import MIMEText + +import aiosmtplib + +from app.config import settings + +logger = logging.getLogger(__name__) + + +async def send_email(to: str, subject: str, html_body: str) -> bool: + """Send HTML email via SMTP. Returns True on success.""" + if not settings.smtp_host: + logger.info(f"SMTP not configured, skipping email to {to}: {subject}") + return False + + msg = MIMEMultipart("alternative") + msg["From"] = f"{settings.smtp_from_name} <{settings.smtp_from_email}>" + msg["To"] = to + msg["Subject"] = subject + msg.attach(MIMEText(html_body, "html")) + + try: + await aiosmtplib.send( + msg, + hostname=settings.smtp_host, + port=settings.smtp_port, + username=settings.smtp_user, + password=settings.smtp_password, + use_tls=True, + ) + return True + except Exception as e: + logger.error(f"Failed to send email to {to}: {e}") + return False + + +async def send_registration_notification( + admin_email: str, student_name: str, class_name: str +): + html = f""" +{student_name} has registered for {class_name}.
+Please log in to HKU ICB to review and approve.
+ """ + await send_email(admin_email, "HKU ICB: New Registration", html) + + +async def send_approval_notification(student_email: str, approved: bool): + status_text = "approved" if approved else "rejected" + html = f""" +Your registration has been {status_text}.
+ {"You can now log in to HKU ICB.
" if approved else ""} + """ + await send_email( + student_email, f"HKU ICB: Registration {status_text.capitalize()}", html + ) + + +async def send_class_notification_email( + emails: list[str], + subject: str, + title: str, + body: str, + action_url: str | None = None, +): + """Send a styled notification email to class members.""" + action_html = "" + if action_url: + action_html = f""" +{data.title}
时间: {time_str}{location_info}
", + email_action_path="/schedule", + ) + + return item + + +async def update_schedule( + db: AsyncSession, item: Schedule, data: ScheduleUpdate +) -> Schedule: + for field, value in data.model_dump(exclude_unset=True).items(): + setattr(item, field, value) + await db.commit() + await db.refresh(item) + return item + + +async def delete_schedule(db: AsyncSession, item: Schedule): + await db.delete(item) + await db.commit() + + +async def get_schedule_by_id(db: AsyncSession, schedule_id: int) -> Schedule | None: + result = await db.execute(select(Schedule).where(Schedule.id == schedule_id)) + return result.scalar_one_or_none() + + +async def list_schedules( + db: AsyncSession, + class_id: int, + schedule_type: str | None = None, + page: int = 1, + page_size: int = 50, +) -> tuple[list[Schedule], int]: + query = select(Schedule).where(Schedule.class_id == class_id) + count_query = select(func.count(Schedule.id)).where(Schedule.class_id == class_id) + + if schedule_type: + query = query.where(Schedule.type == schedule_type) + count_query = count_query.where(Schedule.type == schedule_type) + + total_result = await db.execute(count_query) + total = total_result.scalar() or 0 + + result = await db.execute( + query.order_by(Schedule.start_time.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + items = list(result.scalars().all()) + return items, total + + +async def get_upcoming_schedules( + db: AsyncSession, class_id: int, limit: int = 10 +) -> list[Schedule]: + now = datetime.now(timezone.utc) + result = await db.execute( + select(Schedule) + .where(Schedule.class_id == class_id, Schedule.start_time >= now) + .order_by(Schedule.start_time.asc()) + .limit(limit) + ) + return list(result.scalars().all()) diff --git a/backend/app/services/timeline_service.py b/backend/app/services/timeline_service.py new file mode 100644 index 0000000..dc29b3a --- /dev/null +++ b/backend/app/services/timeline_service.py @@ -0,0 +1,177 @@ +import json +from datetime import datetime + +from sqlalchemy import select, func +from sqlalchemy.ext.asyncio import AsyncSession +from sqlalchemy.orm import selectinload + +from app.db.models import Timeline, TimelineLike, TimelineComment, User +from app.schemas.timeline import TimelineCreate, TimelineUpdate, TimelineCommentCreate +from app.services.notification_service import create_notifications_for_class + + +async def create_timeline( + db: AsyncSession, class_id: int, author_id: int, data: TimelineCreate +) -> Timeline: + post = Timeline( + class_id=class_id, + author_id=author_id, + title=data.title, + content=data.content, + ) + db.add(post) + await db.commit() + await db.refresh(post) + + content_preview = (data.content[:100] + "...") if data.content and len(data.content) > 100 else (data.content or "") + await create_notifications_for_class( + db, class_id, "timeline", f"新动态: {data.title}", + content=content_preview, + related_id=post.id, + email_subject=f"HKU ICB - 新动态: {data.title}", + email_body=f"{content_preview}
" if content_preview else None, + email_action_path="/timeline", + ) + + return post + + +async def update_timeline( + db: AsyncSession, post: Timeline, data: TimelineUpdate +) -> Timeline: + for field, value in data.model_dump(exclude_unset=True).items(): + setattr(post, field, value) + await db.commit() + await db.refresh(post) + return post + + +async def delete_timeline(db: AsyncSession, post: Timeline): + await db.delete(post) + await db.commit() + + +async def get_timeline_by_id(db: AsyncSession, post_id: int) -> Timeline | None: + result = await db.execute( + select(Timeline) + .options( + selectinload(Timeline.author), + selectinload(Timeline.likes), + selectinload(Timeline.comments).selectinload(TimelineComment.author), + ) + .where(Timeline.id == post_id) + ) + return result.scalar_one_or_none() + + +async def list_timelines( + db: AsyncSession, class_id: int, page: int = 1, page_size: int = 20 +) -> tuple[list[Timeline], int]: + total_result = await db.execute( + select(func.count(Timeline.id)).where(Timeline.class_id == class_id) + ) + total = total_result.scalar() or 0 + + result = await db.execute( + select(Timeline) + .options( + selectinload(Timeline.author), + selectinload(Timeline.likes), + selectinload(Timeline.comments), + ) + .where(Timeline.class_id == class_id) + .order_by(Timeline.created_at.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + posts = list(result.scalars().all()) + return posts, total + + +async def add_images_to_timeline(db: AsyncSession, post: Timeline, urls: list[str]): + existing = post.get_image_urls_list() + existing.extend(urls) + post.set_image_urls_list(existing) + await db.commit() + await db.refresh(post) + + +async def toggle_like(db: AsyncSession, post_id: int, user_id: int) -> dict: + result = await db.execute( + select(TimelineLike).where( + TimelineLike.post_id == post_id, + TimelineLike.user_id == user_id, + ) + ) + existing = result.scalar_one_or_none() + + if existing: + await db.delete(existing) + await db.commit() + # Count remaining likes + count_result = await db.execute( + select(func.count(TimelineLike.id)).where(TimelineLike.post_id == post_id) + ) + return {"liked": False, "like_count": count_result.scalar() or 0} + else: + like = TimelineLike(post_id=post_id, user_id=user_id) + db.add(like) + await db.commit() + count_result = await db.execute( + select(func.count(TimelineLike.id)).where(TimelineLike.post_id == post_id) + ) + return {"liked": True, "like_count": count_result.scalar() or 0} + + +async def create_comment( + db: AsyncSession, post_id: int, author_id: int, data: TimelineCommentCreate +) -> TimelineComment: + comment = TimelineComment( + post_id=post_id, + author_id=author_id, + content=data.content, + ) + db.add(comment) + await db.commit() + await db.refresh(comment) + + # Load author relationship for response + result = await db.execute( + select(TimelineComment) + .options(selectinload(TimelineComment.author)) + .where(TimelineComment.id == comment.id) + ) + return result.scalar_one() + + +async def delete_comment(db: AsyncSession, comment: TimelineComment): + await db.delete(comment) + await db.commit() + + +async def get_comment_by_id(db: AsyncSession, comment_id: int) -> TimelineComment | None: + result = await db.execute( + select(TimelineComment) + .options(selectinload(TimelineComment.author)) + .where(TimelineComment.id == comment_id) + ) + return result.scalar_one_or_none() + + +async def list_comments( + db: AsyncSession, post_id: int, page: int = 1, page_size: int = 50 +) -> tuple[list[TimelineComment], int]: + total_result = await db.execute( + select(func.count(TimelineComment.id)).where(TimelineComment.post_id == post_id) + ) + total = total_result.scalar() or 0 + + result = await db.execute( + select(TimelineComment) + .options(selectinload(TimelineComment.author)) + .where(TimelineComment.post_id == post_id) + .order_by(TimelineComment.created_at.asc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + return list(result.scalars().all()), total diff --git a/backend/app/services/user_service.py b/backend/app/services/user_service.py new file mode 100644 index 0000000..a951866 --- /dev/null +++ b/backend/app/services/user_service.py @@ -0,0 +1,80 @@ +from sqlalchemy import select, func +from sqlalchemy.ext.asyncio import AsyncSession + +from app.db.models import User +from app.schemas.user import UserOut, UserUpdate + + +async def get_user_by_email(db: AsyncSession, email: str) -> User | None: + result = await db.execute(select(User).where(User.email == email)) + return result.scalar_one_or_none() + + +async def get_user_by_id(db: AsyncSession, user_id: int) -> User | None: + result = await db.execute(select(User).where(User.id == user_id)) + return result.scalar_one_or_none() + + +async def update_profile(db: AsyncSession, user: User, data: UserUpdate) -> User: + update_data = data.model_dump(exclude_unset=True) + + # Handle email change with uniqueness check + if "email" in update_data and update_data["email"] != user.email: + existing = await db.execute( + select(User).where(User.email == update_data["email"]) + ) + if existing.scalar_one_or_none(): + raise ValueError("该邮箱已被使用") + user.email = update_data.pop("email") + + for field, value in update_data.items(): + setattr(user, field, value) + await db.commit() + await db.refresh(user) + return user + + +async def update_user_status( + db: AsyncSession, user_id: int, status: str, role: str | None = None +) -> User | None: + user = await get_user_by_id(db, user_id) + if user is None: + return None + user.status = status + if role is not None: + user.role = role + await db.commit() + await db.refresh(user) + return user + + +async def list_users( + db: AsyncSession, + page: int = 1, + page_size: int = 20, + class_id: int | None = None, + status: str | None = None, + role: str | None = None, +) -> tuple[list[User], int]: + query = select(User) + count_query = select(func.count(User.id)) + + if class_id is not None: + query = query.where(User.class_id == class_id) + count_query = count_query.where(User.class_id == class_id) + if status is not None: + query = query.where(User.status == status) + count_query = count_query.where(User.status == status) + if role is not None: + query = query.where(User.role == role) + count_query = count_query.where(User.role == role) + + total_result = await db.execute(count_query) + total = total_result.scalar() or 0 + + query = query.order_by(User.created_at.desc()) + query = query.offset((page - 1) * page_size).limit(page_size) + result = await db.execute(query) + users = list(result.scalars().all()) + + return users, total diff --git a/backend/app/services/vote_service.py b/backend/app/services/vote_service.py new file mode 100644 index 0000000..8173ebe --- /dev/null +++ b/backend/app/services/vote_service.py @@ -0,0 +1,141 @@ +from datetime import datetime + +from sqlalchemy import select, func +from sqlalchemy.ext.asyncio import AsyncSession +from sqlalchemy.orm import selectinload + +from app.db.models import Vote, VoteOption, VoteResponse, User +from app.schemas.vote import VoteCreate +from app.services.notification_service import create_notifications_for_class + + +async def create_vote( + db: AsyncSession, class_id: int, creator_id: int, data: VoteCreate +) -> Vote: + vote = Vote( + class_id=class_id, + creator_id=creator_id, + title=data.title, + description=data.description, + vote_type=data.vote_type, + is_anonymous=data.is_anonymous, + max_choices=data.max_choices, + deadline=data.deadline, + ) + db.add(vote) + await db.flush() + + for i, opt_text in enumerate(data.options): + option = VoteOption(vote_id=vote.id, content=opt_text, sort_order=i) + db.add(option) + + await db.commit() + await db.refresh(vote) + + # Load options for the returned object + result = await db.execute( + select(Vote) + .options(selectinload(Vote.options)) + .where(Vote.id == vote.id) + ) + vote = result.scalar_one() + + await create_notifications_for_class( + db, class_id, "vote", f"新投票: {data.title}", + content=data.description, + related_id=vote.id, + email_subject=f"HKU ICB - 新投票: {data.title}", + email_body=f"{data.description or data.title}
", + email_action_path="/votes", + ) + + return vote + + +async def get_vote_by_id(db: AsyncSession, vote_id: int) -> Vote | None: + result = await db.execute( + select(Vote) + .options( + selectinload(Vote.creator), + selectinload(Vote.options).selectinload(VoteOption.responses).selectinload(VoteResponse.voter), + ) + .where(Vote.id == vote_id) + ) + return result.scalar_one_or_none() + + +async def list_votes( + db: AsyncSession, class_id: int, page: int = 1, page_size: int = 20 +) -> tuple[list[Vote], int]: + total_result = await db.execute( + select(func.count(Vote.id)).where(Vote.class_id == class_id) + ) + total = total_result.scalar() or 0 + + result = await db.execute( + select(Vote) + .options( + selectinload(Vote.creator), + selectinload(Vote.options).selectinload(VoteOption.responses), + ) + .where(Vote.class_id == class_id) + .order_by(Vote.created_at.desc()) + .offset((page - 1) * page_size) + .limit(page_size) + ) + return list(result.scalars().all()), total + + +async def submit_vote( + db: AsyncSession, vote_id: int, voter_id: int, option_ids: list[int] +) -> None: + vote_result = await db.execute(select(Vote).where(Vote.id == vote_id)) + vote = vote_result.scalar_one_or_none() + if vote is None: + raise ValueError("投票不存在") + if vote.status != "open": + raise ValueError("投票已关闭") + if vote.deadline and datetime.now() > vote.deadline: + raise ValueError("投票已过截止日期") + + # Check if already voted + existing = await db.execute( + select(VoteResponse).where( + VoteResponse.vote_id == vote_id, + VoteResponse.voter_id == voter_id, + ) + ) + if existing.scalar_one_or_none(): + raise ValueError("你已经投过票了") + + # Validate option count + if vote.vote_type == "single" and len(option_ids) != 1: + raise ValueError("单选投票只能选择一个选项") + if vote.vote_type == "multiple" and len(option_ids) > vote.max_choices: + raise ValueError(f"最多选择 {vote.max_choices} 个选项") + + # Validate option_ids belong to this vote + for oid in option_ids: + opt_result = await db.execute( + select(VoteOption).where(VoteOption.id == oid, VoteOption.vote_id == vote_id) + ) + if opt_result.scalar_one_or_none() is None: + raise ValueError(f"选项 {oid} 不属于此投票") + + for oid in option_ids: + response = VoteResponse(vote_id=vote_id, option_id=oid, voter_id=voter_id) + db.add(response) + + await db.commit() + + +async def close_vote(db: AsyncSession, vote: Vote) -> Vote: + vote.status = "closed" + await db.commit() + await db.refresh(vote) + return vote + + +async def delete_vote(db: AsyncSession, vote: Vote): + await db.delete(vote) + await db.commit() diff --git a/backend/requirements.txt b/backend/requirements.txt new file mode 100644 index 0000000..b8033a9 --- /dev/null +++ b/backend/requirements.txt @@ -0,0 +1,13 @@ +fastapi==0.115.6 +uvicorn[standard]==0.34.0 +sqlalchemy[asyncio]==2.0.36 +aiosqlite==0.20.0 +pydantic[email]==2.10.3 +pydantic-settings==2.7.1 +python-jose[cryptography]==3.3.0 +passlib[bcrypt]==1.7.4 +alembic==1.14.0 +python-multipart==0.0.20 +aiosmtplib==3.0.2 +cos-python-sdk-v5==1.9.30 +httpx==0.28.1 diff --git a/docker-compose.yml b/docker-compose.yml new file mode 100644 index 0000000..901d45f --- /dev/null +++ b/docker-compose.yml @@ -0,0 +1,42 @@ +services: + backend: + build: ./backend + restart: unless-stopped + env_file: ./backend/.env + environment: + - CH_DATABASE_URL=sqlite+aiosqlite:///./data/classhub.db + - CH_FRONTEND_URL=http://localhost + volumes: + - classhub-data:/app/data + expose: + - "8000" + healthcheck: + test: ["CMD", "python", "-c", "import urllib.request; urllib.request.urlopen('http://localhost:8000/api/health')"] + interval: 30s + timeout: 5s + retries: 3 + + frontend: + build: + context: ./frontend + args: + - NEXT_PUBLIC_API_URL= + restart: unless-stopped + expose: + - "3000" + depends_on: + - backend + + nginx: + image: nginx:alpine + restart: unless-stopped + ports: + - "80:80" + volumes: + - ./nginx/nginx.conf:/etc/nginx/conf.d/default.conf:ro + depends_on: + - backend + - frontend + +volumes: + classhub-data: diff --git a/frontend/.dockerignore b/frontend/.dockerignore new file mode 100644 index 0000000..5522d9f --- /dev/null +++ b/frontend/.dockerignore @@ -0,0 +1,7 @@ +node_modules/ +.next/ +out/ +.env.local +.env*.local +*.tsbuildinfo +.git/ diff --git a/frontend/.gitignore b/frontend/.gitignore new file mode 100644 index 0000000..5ef6a52 --- /dev/null +++ b/frontend/.gitignore @@ -0,0 +1,41 @@ +# See https://help.github.com/articles/ignoring-files/ for more about ignoring files. + +# dependencies +/node_modules +/.pnp +.pnp.* +.yarn/* +!.yarn/patches +!.yarn/plugins +!.yarn/releases +!.yarn/versions + +# testing +/coverage + +# next.js +/.next/ +/out/ + +# production +/build + +# misc +.DS_Store +*.pem + +# debug +npm-debug.log* +yarn-debug.log* +yarn-error.log* +.pnpm-debug.log* + +# env files (can opt-in for committing if needed) +.env* + +# vercel +.vercel + +# typescript +*.tsbuildinfo +next-env.d.ts diff --git a/frontend/AGENTS.md b/frontend/AGENTS.md new file mode 100644 index 0000000..8bd0e39 --- /dev/null +++ b/frontend/AGENTS.md @@ -0,0 +1,5 @@ + +# This is NOT the Next.js you know + +This version has breaking changes — APIs, conventions, and file structure may all differ from your training data. Read the relevant guide in `node_modules/next/dist/docs/` before writing any code. Heed deprecation notices. + diff --git a/frontend/CLAUDE.md b/frontend/CLAUDE.md new file mode 100644 index 0000000..43c994c --- /dev/null +++ b/frontend/CLAUDE.md @@ -0,0 +1 @@ +@AGENTS.md diff --git a/frontend/Dockerfile b/frontend/Dockerfile new file mode 100644 index 0000000..af6d9b4 --- /dev/null +++ b/frontend/Dockerfile @@ -0,0 +1,34 @@ +FROM node:22-alpine AS deps +WORKDIR /app +COPY package.json package-lock.json* ./ +RUN npm ci --omit=dev + +FROM node:22-alpine AS builder +WORKDIR /app +COPY --from=deps /app/node_modules ./node_modules +COPY . . + +ARG NEXT_PUBLIC_API_URL="" +ENV NEXT_PUBLIC_API_URL=$NEXT_PUBLIC_API_URL + +RUN npm run build + +FROM node:22-alpine AS runner +WORKDIR /app + +ENV NODE_ENV=production + +RUN addgroup --system --gid 1001 nodejs && \ + adduser --system --uid 1001 nextjs + +COPY --from=builder /app/public ./public +COPY --from=builder --chown=nextjs:nodejs /app/.next/standalone ./ +COPY --from=builder --chown=nextjs:nodejs /app/.next/static ./.next/static + +USER nextjs + +EXPOSE 3000 +ENV PORT=3000 +ENV HOSTNAME="0.0.0.0" + +CMD ["node", "server.js"] diff --git a/frontend/README.md b/frontend/README.md new file mode 100644 index 0000000..e215bc4 --- /dev/null +++ b/frontend/README.md @@ -0,0 +1,36 @@ +This is a [Next.js](https://nextjs.org) project bootstrapped with [`create-next-app`](https://nextjs.org/docs/app/api-reference/cli/create-next-app). + +## Getting Started + +First, run the development server: + +```bash +npm run dev +# or +yarn dev +# or +pnpm dev +# or +bun dev +``` + +Open [http://localhost:3000](http://localhost:3000) with your browser to see the result. + +You can start editing the page by modifying `app/page.tsx`. The page auto-updates as you edit the file. + +This project uses [`next/font`](https://nextjs.org/docs/app/building-your-application/optimizing/fonts) to automatically optimize and load [Geist](https://vercel.com/font), a new font family for Vercel. + +## Learn More + +To learn more about Next.js, take a look at the following resources: + +- [Next.js Documentation](https://nextjs.org/docs) - learn about Next.js features and API. +- [Learn Next.js](https://nextjs.org/learn) - an interactive Next.js tutorial. + +You can check out [the Next.js GitHub repository](https://github.com/vercel/next.js) - your feedback and contributions are welcome! + +## Deploy on Vercel + +The easiest way to deploy your Next.js app is to use the [Vercel Platform](https://vercel.com/new?utm_medium=default-template&filter=next.js&utm_source=create-next-app&utm_campaign=create-next-app-readme) from the creators of Next.js. + +Check out our [Next.js deployment documentation](https://nextjs.org/docs/app/building-your-application/deploying) for more details. diff --git a/frontend/components.json b/frontend/components.json new file mode 100644 index 0000000..8d886db --- /dev/null +++ b/frontend/components.json @@ -0,0 +1,25 @@ +{ + "$schema": "https://ui.shadcn.com/schema.json", + "style": "base-nova", + "rsc": true, + "tsx": true, + "tailwind": { + "config": "", + "css": "src/app/globals.css", + "baseColor": "neutral", + "cssVariables": true, + "prefix": "" + }, + "iconLibrary": "lucide", + "rtl": false, + "aliases": { + "components": "@/components", + "utils": "@/lib/utils", + "ui": "@/components/ui", + "lib": "@/lib", + "hooks": "@/hooks" + }, + "menuColor": "default", + "menuAccent": "subtle", + "registries": {} +} diff --git a/frontend/eslint.config.mjs b/frontend/eslint.config.mjs new file mode 100644 index 0000000..05e726d --- /dev/null +++ b/frontend/eslint.config.mjs @@ -0,0 +1,18 @@ +import { defineConfig, globalIgnores } from "eslint/config"; +import nextVitals from "eslint-config-next/core-web-vitals"; +import nextTs from "eslint-config-next/typescript"; + +const eslintConfig = defineConfig([ + ...nextVitals, + ...nextTs, + // Override default ignores of eslint-config-next. + globalIgnores([ + // Default ignores of eslint-config-next: + ".next/**", + "out/**", + "build/**", + "next-env.d.ts", + ]), +]); + +export default eslintConfig; diff --git a/frontend/next.config.ts b/frontend/next.config.ts new file mode 100644 index 0000000..bf85763 --- /dev/null +++ b/frontend/next.config.ts @@ -0,0 +1,8 @@ +import type { NextConfig } from "next"; + +const nextConfig: NextConfig = { + output: "standalone", + allowedDevOrigins: ["192.168.31.172"], +}; + +export default nextConfig; diff --git a/frontend/package.json b/frontend/package.json new file mode 100644 index 0000000..e1336b1 --- /dev/null +++ b/frontend/package.json @@ -0,0 +1,35 @@ +{ + "name": "frontend", + "version": "0.1.0", + "private": true, + "scripts": { + "dev": "next dev", + "build": "next build", + "start": "next start", + "lint": "eslint" + }, + "dependencies": { + "@base-ui/react": "^1.3.0", + "class-variance-authority": "^0.7.1", + "clsx": "^2.1.1", + "lucide-react": "^1.8.0", + "next": "16.2.3", + "next-themes": "^0.4.6", + "react": "19.2.4", + "react-dom": "19.2.4", + "shadcn": "^4.2.0", + "sonner": "^2.0.7", + "tailwind-merge": "^3.5.0", + "tw-animate-css": "^1.4.0" + }, + "devDependencies": { + "@tailwindcss/postcss": "^4", + "@types/node": "^20", + "@types/react": "^19", + "@types/react-dom": "^19", + "eslint": "^9", + "eslint-config-next": "16.2.3", + "tailwindcss": "^4", + "typescript": "^5" + } +} diff --git a/frontend/postcss.config.mjs b/frontend/postcss.config.mjs new file mode 100644 index 0000000..61e3684 --- /dev/null +++ b/frontend/postcss.config.mjs @@ -0,0 +1,7 @@ +const config = { + plugins: { + "@tailwindcss/postcss": {}, + }, +}; + +export default config; diff --git a/frontend/public/file.svg b/frontend/public/file.svg new file mode 100644 index 0000000..004145c --- /dev/null +++ b/frontend/public/file.svg @@ -0,0 +1 @@ + \ No newline at end of file diff --git a/frontend/public/globe.svg b/frontend/public/globe.svg new file mode 100644 index 0000000..567f17b --- /dev/null +++ b/frontend/public/globe.svg @@ -0,0 +1 @@ + \ No newline at end of file diff --git a/frontend/public/next.svg b/frontend/public/next.svg new file mode 100644 index 0000000..5174b28 --- /dev/null +++ b/frontend/public/next.svg @@ -0,0 +1 @@ + \ No newline at end of file diff --git a/frontend/public/vercel.svg b/frontend/public/vercel.svg new file mode 100644 index 0000000..7705396 --- /dev/null +++ b/frontend/public/vercel.svg @@ -0,0 +1 @@ + \ No newline at end of file diff --git a/frontend/public/window.svg b/frontend/public/window.svg new file mode 100644 index 0000000..b2b2a44 --- /dev/null +++ b/frontend/public/window.svg @@ -0,0 +1 @@ + \ No newline at end of file diff --git a/frontend/src/app/(app)/admin/classes/page.tsx b/frontend/src/app/(app)/admin/classes/page.tsx new file mode 100644 index 0000000..df728cc --- /dev/null +++ b/frontend/src/app/(app)/admin/classes/page.tsx @@ -0,0 +1,218 @@ +"use client"; + +import { useEffect, useState } from "react"; +import { useAuth } from "@/hooks/use-auth"; +import { fetchAPI, postAPI, putAPI, deleteAPI } from "@/lib/api"; +import { Card, CardContent } from "@/components/ui/card"; +import { Button } from "@/components/ui/button"; +import { Input } from "@/components/ui/input"; +import { Label } from "@/components/ui/label"; +import { RoleGuard } from "@/components/role-guard"; +import { ConfirmDialog } from "@/components/confirm-dialog"; +import { ErrorState } from "@/components/error-state"; +import { toast } from "sonner"; +import type { ClassInfo } from "@/lib/types"; +import { + Dialog, + DialogContent, + DialogHeader, + DialogTitle, + DialogTrigger, +} from "@/components/ui/dialog"; + +export default function ClassesPage() { + const { user } = useAuth(); + const [classes, setClasses] = useState创建和管理班级
++ {cls.cohort_year}届 · {cls.member_count} 名成员 +
+管理班级花名册、邀请码和已注册成员
+班级邀请码
++ {inviteCode || "—"} +
++ 将此邀请码分享给学生，学生注册时输入邀请码+学号即可加入班级 +
+