From 8915fca8411a3a981da7ffefe8e78fd096995e7c Mon Sep 17 00:00:00 2001 From: WuYuuuub <625806558@qq.com> Date: Wed, 17 Jun 2026 22:41:34 +0800 Subject: [PATCH] =?UTF-8?q?cet=E6=88=90=E7=BB=A9=E6=9F=A5=E8=AF=A2handler?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- grpc/handler_cet.go | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 grpc/handler_cet.go diff --git a/grpc/handler_cet.go b/grpc/handler_cet.go new file mode 100644 index 0000000..29c9359 --- /dev/null +++ b/grpc/handler_cet.go @@ -0,0 +1,29 @@ +package grpc + +import ( + "context" + "encoding/json" + "log/slog" + + pb "schedule_converter/proto/runner" + + apperr "schedule_converter/pkg/errors" +) + +func (h *TaskHandler) getCET(ctx context.Context, payload []byte) ([]byte, error) { + var req pb.GetCetPayload + if err := unmarshalPayload(payload, &req); err != nil { + return nil, err + } + + log := slog.With("username", req.Username) + log.Info("获取四六级成绩任务") + + result, err := h.service.GetCET(ctx, &req) + if err != nil { + return nil, apperr.New("get_cet", err, "获取四六级成绩失败") + } + + log.Info("四六级成绩获取成功", "score_count", len(result.Scores)) + return json.Marshal(result) +}