schedule_converter/grpc/handler_grades.go

package grpc

import (
	"context"
	"encoding/json"
	"log/slog"

	pb "schedule_converter/proto/runner"

	apperr "schedule_converter/pkg/errors"
)

func (h *TaskHandler) getGrades(ctx context.Context, payload []byte) ([]byte, error) {
	var req pb.GetGradesPayload
	if err := unmarshalPayload(payload, &req); err != nil {
		return nil, err
	}

	log := slog.With("username", req.Username, "semester", req.Semester)
	log.Info("获取成绩任务")

	result, err := h.service.GetGrades(ctx, &req)
	if err != nil {
		return nil, apperr.New("get_grades", err, "获取成绩失败")
	}

	log.Info("成绩获取成功", "grade_count", len(result.Grades))
	return json.Marshal(result)
}