This commit is contained in:
29
grpc/handler_cet.go
Normal file
29
grpc/handler_cet.go
Normal file
@@ -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)
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user