Method submitSkillImportJob

api/service/skill_library_service.go:237–274

(ctx context.Context, req *SkillImportRequest, permissionGroupIDs []int64)

}

func (s *SkillLibraryService) submitSkillImportJob(ctx context.Context, req *SkillImportRequest, permissionGroupIDs []int64) (*SkillImportResult, error) {
	if req == nil {
		return nil, ErrSkillImportRequestInvalid
	}

	payload := &SkillImportJobPayload{
		SourceType:         strings.TrimSpace(req.SourceType),
		UploadFileID:       strings.TrimSpace(req.UploadFileID),
		GithubURL:          strings.TrimSpace(req.GithubURL),
		Ref:                strings.TrimSpace(req.Ref),
		SkillPath:          strings.TrimSpace(req.SkillPath),
		PermissionGroupIDs: normalizePermissionGroupIDs(permissionGroupIDs),
	}
	payloadBytes, err := json.Marshal(payload)
	if err != nil {
		return nil, err
	}

	job := &model.SkillScanJob{
		Eid:          req.Eid,
		Status:       model.SkillScanJobStatusPending,
		ScanPayload:  string(payloadBytes),
		Message:      "导入任务已提交",
		RetryCount:   0,
		StartedTime:  0,
		FinishedTime: 0,
	}
	if err := model.DB.Create(job).Error; err != nil {
		return nil, err
	}

	s.RunAsyncImportJob(context.Background(), job.ID)

	return &SkillImportResult{
		ScanJobID:  job.ID,
		ScanStatus: job.Status,
	}, nil
}

func normalizeSkillImportRequest(req *SkillImportRequest) error {
	if req == nil {