add target field

Author: tpfz

backend/api/handler/coze/loop/apis/eval_open_apiservice.go

@@ -2039,7 +2039,7 @@ func OpenAPIExperimentFiltersDTO2Domain(filters *openapiExperiment.Filters) (*do
 		return nil, nil
 	}
 	if filters.LogicOp != nil {
-		lo := strings.ToLower(strings.TrimSpace(string(*filters.LogicOp)))
+		lo := strings.ToLower(strings.TrimSpace(*filters.LogicOp))
 		if lo != "" && lo != "and" {
 			return nil, fmt.Errorf("only logic_op 'and' is supported for experiment result filters")
 		}
@@ -2126,7 +2126,7 @@ func ExperimentResultDomainFiltersNeedAccelerator(f *domainExpt.Filters) bool {
 }
 
 func openAPIExperimentFilterFieldTypeToDomain(ft openapiExperiment.FilterFieldType) (domainExpt.FieldType, error) {
-	s := strings.TrimSpace(string(ft))
+	s := strings.TrimSpace(ft)
 	if s == "" {
 		return 0, fmt.Errorf("empty field_type")
 	}
@@ -2210,7 +2210,7 @@ func openAPIExperimentFilterFieldTypeToDomain(ft openapiExperiment.FilterFieldTy
 }
 
 func openAPIExperimentFilterOperatorToDomain(op openapiExperiment.FilterOperatorType) (domainExpt.FilterOperatorType, error) {
-	s := strings.TrimSpace(string(op))
+	s := strings.TrimSpace(op)
 	if s == "" {
 		return 0, fmt.Errorf("empty operator")
 	}

backend/modules/evaluation/application/convertor/experiment/openapi.go

@@ -14,6 +14,7 @@ import (
 
 	domaincommon "github.com/coze-dev/coze-loop/backend/kitex_gen/coze/loop/evaluation/domain/common"
 	domain_expt "github.com/coze-dev/coze-loop/backend/kitex_gen/coze/loop/evaluation/domain/expt"
+	openapiCommon "github.com/coze-dev/coze-loop/backend/kitex_gen/coze/loop/evaluation/domain_openapi/common"
 	exptpb "github.com/coze-dev/coze-loop/backend/kitex_gen/coze/loop/evaluation/expt"
 	"github.com/coze-dev/coze-loop/backend/kitex_gen/coze/loop/evaluation/openapi"
 	"github.com/coze-dev/coze-loop/backend/modules/evaluation/application/convertor/common"
@@ -893,6 +894,81 @@ func (e *EvalOpenAPIApplication) ReportEvalTargetInvokeResult_(ctx context.Conte
 	return &openapi.ReportEvalTargetInvokeResultResponse{BaseResp: base.NewBaseResp()}, nil
 }
 
+func (e *EvalOpenAPIApplication) GetEvalTargetOutputFieldContentOApi(ctx context.Context, req *openapi.GetEvalTargetOutputFieldContentOApiRequest) (r *openapi.GetEvalTargetOutputFieldContentOApiResponse, err error) {
+	startTime := time.Now().UnixNano() / int64(time.Millisecond)
+	defer func() {
+		e.metric.EmitOpenAPIMetric(ctx, req.GetWorkspaceID(), 0, kitexutil.GetTOMethod(ctx), startTime, err)
+	}()
+	if req == nil {
+		return nil, errorx.NewByCode(errno.CommonInvalidParamCode, errorx.WithExtraMsg("req is nil"))
+	}
+	if req.GetWorkspaceID() == 0 {
+		return nil, errorx.NewByCode(errno.CommonInvalidParamCode, errorx.WithExtraMsg("workspace_id is required"))
+	}
+	if req.GetExperimentID() == 0 {
+		return nil, errorx.NewByCode(errno.CommonInvalidParamCode, errorx.WithExtraMsg("experiment_id is required"))
+	}
+	if req.GetItemID() == 0 {
+		return nil, errorx.NewByCode(errno.CommonInvalidParamCode, errorx.WithExtraMsg("item_id is required"))
+	}
+	if len(req.GetFieldKeys()) == 0 {
+		return nil, errorx.NewByCode(errno.CommonInvalidParamCode, errorx.WithExtraMsg("field_keys is required"))
+	}
+
+	err = e.auth.Authorization(ctx, &rpc.AuthorizationParam{
+		ObjectID:      strconv.FormatInt(req.GetExperimentID(), 10),
+		SpaceID:       req.GetWorkspaceID(),
+		ActionObjects: []*rpc.ActionObject{{Action: gptr.Of(consts.Read), EntityType: gptr.Of(rpc.AuthEntityType_EvaluationExperiment)}},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	turnResults, err := e.resultSvc.GetExptItemTurnResults(ctx, req.GetExperimentID(), req.GetItemID(), req.GetWorkspaceID(), nil)
+	if err != nil {
+		return nil, err
+	}
+	if len(turnResults) == 0 {
+		return nil, errorx.NewByCode(errno.ResourceNotFoundCode, errorx.WithExtraMsg("no turn result found for the given experiment_id and item_id"))
+	}
+
+	targetRecordID := turnResults[0].TargetResultID
+	if targetRecordID == 0 {
+		return nil, errorx.NewByCode(errno.ResourceNotFoundCode, errorx.WithExtraMsg("eval target record not found for the given experiment result"))
+	}
+
+	record, err := e.targetSvc.GetRecordByID(ctx, req.GetWorkspaceID(), targetRecordID)
+	if err != nil {
+		return nil, err
+	}
+	if record == nil {
+		return nil, errorx.NewByCode(errno.ResourceNotFoundCode, errorx.WithExtraMsg("eval target record not found"))
+	}
+
+	if err := e.targetSvc.LoadRecordOutputFields(ctx, record, req.GetFieldKeys()); err != nil {
+		return nil, err
+	}
+
+	fieldContents := make(map[string]*openapiCommon.Content)
+	if record.EvalTargetOutputData != nil && record.EvalTargetOutputData.OutputFields != nil {
+		keySet := make(map[string]struct{}, len(req.GetFieldKeys()))
+		for _, k := range req.GetFieldKeys() {
+			keySet[k] = struct{}{}
+		}
+		for k, c := range record.EvalTargetOutputData.OutputFields {
+			if _, ok := keySet[k]; ok {
+				fieldContents[k] = common.OpenAPIContentDO2DTO(c)
+			}
+		}
+	}
+
+	return &openapi.GetEvalTargetOutputFieldContentOApiResponse{
+		Data: &openapi.GetEvalTargetOutputFieldContentOpenAPIData{
+			FieldContents: fieldContents,
+		},
+	}, nil
+}
+
 func (e *EvalOpenAPIApplication) SubmitExperimentOApi(ctx context.Context, req *openapi.SubmitExperimentOApiRequest) (r *openapi.SubmitExperimentOApiResponse, err error) {
 	startTime := time.Now().UnixNano() / int64(time.Millisecond)
 	defer func() {