fix(common): course adjust notice processing (#448)

Author: renbaoshuo

cmd/common/main.go

@@ -78,15 +78,33 @@ func loadNotice(db *db.Database) {
 		}
 		for _, row := range content {
 			ctx := context.Background()
+
+			ok, err := db.Notice.IsNoticeExists(ctx, row.Title, row.URL)
+			if err != nil {
+				logger.Warnf("syncer init: failed to check notice exists in page %d: %v", i, err)
+				continue
+			}
+			// 数据库已存在，无需处理
+			if ok {
+				continue
+			}
+
 			info := &model.Notice{
 				Title:       row.Title,
 				PublishedAt: row.Date,
 				URL:         row.URL,
 			}
-			err = db.Notice.CreateNotice(ctx, info)
-			if err != nil {
+			if err = db.Notice.CreateNotice(ctx, info); err != nil {
 				logger.Warnf("syncer init: failed to create notice in page %d: %v", i, err)
+				continue
 			}
+
+			go func(notice *jwch.NoticeInfo) {
+				ctx := context.Background()
+				if err := commonSvc.NewCommonService(ctx, clientSet, taskQueue).ProcessAutoAdjustCourseNotice(notice); err != nil {
+					logger.Errorf("syncer init: ProcessAutoAdjustCourseNotice failed, title=%s url=%s err=%v", notice.Title, notice.URL, err)
+				}
+			}(row)
 		}
 	}
 	logger.Infof("syncer init: notice syncer init success")
@@ -153,6 +171,8 @@ func syncNoticeTask() error {
 			continue
 		}
 
+		logger.Infof("syncNoticeTask: new notice found, title=%s url=%s", row.Title, row.URL)
+
 		info := &model.Notice{
 			Title:       row.Title,
 			URL:         row.URL,

internal/common/service/get_toolbox_config.go

@@ -18,9 +18,9 @@ package service
 
 import (
 	"context"
-	"fmt"
 
 	"github.com/west2-online/fzuhelper-server/pkg/db/model"
+	"github.com/west2-online/fzuhelper-server/pkg/logger"
 )
 
 const (
@@ -97,7 +97,7 @@ func (s *CommonService) GetToolboxConfig(ctx context.Context, studentID string,
 
 		// 跳过不匹配的配置
 		if matchScore < 0 {
-			fmt.Println("matchScore < 0", matchScore)
+			logger.Warnf("matchScore < 0: %d", matchScore)
 			continue
 		}
 		toolID := config.ToolID

internal/common/service/process_auto_adjust_course_notice.go

@@ -30,12 +30,14 @@ import (
 
 // 处理教务通知中的课程调整信息
 func (s *CommonService) ProcessAutoAdjustCourseNotice(info *jwch.NoticeInfo) error {
+	logger.Infof("ProcessAutoAdjustCourseNotice: processing notice, title=%s url=%s", info.Title, info.URL)
+
 	// 仅处理标题包含"课程调整"的通知，其余通知直接跳过
 	if !strings.Contains(info.Title, "课程调整") {
 		return nil
 	}
 
-	// 根据通知的树节点 ID 和新闻 ID 获取通知详情（含正文 HTML）
+	// 根据通知的 WbTreeId 和 WbNewsId 获取通知详情（含正文 HTML）
 	detail, err := jwch.NewStudent().GetNoticeDetail(&jwch.NoticeDetailReq{
 		WbTreeId: info.WbTreeId,
 		WbNewsId: info.WbNewsId,
@@ -44,17 +46,17 @@ func (s *CommonService) ProcessAutoAdjustCourseNotice(info *jwch.NoticeInfo) err
 		return fmt.Errorf("ProcessAutoAdjustCourseNotice: failed to get notice detail: %w", err)
 	}
 
-	content := detail.Content
-
-	// 调用 AI 从通知标题和正文中提取结构化的课程调整条目
+	// 调用 LLM 从通知标题和正文中提取结构化的课程调整条目
 	result, err := ai.AutoAdjustCourse(s.ctx, ai.AutoAdjustCourseInput{
 		Title:   info.Title,
-		Content: content,
+		Content: detail.Content,
 	})
 	if err != nil {
 		return fmt.Errorf("ProcessAutoAdjustCourseNotice: failed to auto adjust course: %w", err)
 	}
 
+	logger.Infof("ProcessAutoAdjustCourseNotice: AI extracted %+v", result.Items)
+
 	// 获取学期列表，用于后续将日期映射到具体学期
 	calendar, err := s.GetTermList()
 	if err != nil {