Method ForceImportSkill

api/service/skill_library_import.go:613–766

(ctx context.Context, eid, jobID int64)

}

func (s *SkillLibraryService) ForceImportSkill(ctx context.Context, eid, jobID int64) (*SkillImportResult, error) {
	if jobID <= 0 {
		return nil, ErrSkillImportRequestInvalid
	}

	job, err := model.GetSkillScanJobByIDAndEID(eid, jobID)
	if err != nil {
		return nil, err
	}
	if job == nil {
		return nil, gorm.ErrRecordNotFound
	}
	if job.Status != model.SkillScanJobStatusFailed {
		return nil, fmt.Errorf("任务状态不是失败，无法强制导入")
	}
	if job.RiskLevel != model.SkillRiskLevelHigh {
		return nil, fmt.Errorf("任务非高风险失败，无法强制导入")
	}
	if job.SkillLibraryID > 0 {
		return nil, fmt.Errorf("任务已关联技能，无法强制导入")
	}

	var payload SkillImportJobPayload
	if err := json.Unmarshal([]byte(job.ScanPayload), &payload); err != nil {
		return nil, fmt.Errorf("解析任务数据失败: %v", err)
	}
	if payload.OriginZipKey == "" {
		return nil, fmt.Errorf("任务缺少原始文件数据，无法强制导入")
	}

	zipContent, err := s.storage.Load(payload.OriginZipKey)
	if err != nil {
		return nil, fmt.Errorf("读取原始文件失败: %v", err)
	}

	req := &SkillImportRequest{
		Eid:        eid,
		SourceType: strings.TrimSpace(payload.SourceType),
		GithubURL:  strings.TrimSpace(payload.GithubURL),
		Ref:        strings.TrimSpace(payload.Ref),
		SkillPath:  strings.TrimSpace(payload.SkillPath),
	}
	if err := normalizeSkillImportRequest(req); err != nil {
		return nil, err
	}

	archiveSkillPath := ""
	if req.SourceType == model.SkillSourceTypeGithub {
		archiveSkillPath = parseGithubSourceSkillPath(payload.Ref)
	}

	stagingPath, err := createSkillExtractionStagingPath(s.buildSkillTenantRootPath(eid))
	if err != nil {
		return nil, err
	}
	defer os.RemoveAll(stagingPath)

	inspection, err := extractSkillArchiveToPath(zipContent, archiveSkillPath, stagingPath)