FranklinWH-Toolbox/service/repositories/api/plane_v2/plane_v2_api/intake.go

package plane_v2_api

import (
	"encoding/json"
	"fmt"

	plane "fwh-toolbox-server/repositories/api/plane_v2"

	"go.uber.org/zap"
)

// ListIntakeIssues 列出收件箱工作项
func ListIntakeIssues(c *plane.PlaneClient, slug, projectID, status string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/intake-issues/", slug, projectID)
	if status != "" {
		url += "?status=" + status
	}

	resp, err := c.Get(url)
	if err != nil {
		zap.L().Error("[PlaneAPI] ListIntakeIssues 请求失败", zap.Error(err))
		return nil, err
	}
	if !plane.IsSuccess(resp.StatusCode) {
		return nil, fmt.Errorf("ListIntakeIssues 失败: %s", resp.Status)
	}
	return resp.Body, nil
}

// CreateIntakeIssue 创建收件箱工作项
func CreateIntakeIssue(c *plane.PlaneClient, slug, projectID string, issue plane.IntakeIssueRequest) (*plane.IntakeIssueResponse, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/intake-issues/", slug, projectID)
	payload := map[string]any{
		"source": "IN_APP",
		"issue":  issue,
	}

	resp, err := c.Post(url, payload)
	if err != nil {
		zap.L().Error("[PlaneAPI] CreateIntakeIssue 请求失败", zap.Error(err))
		return nil, err
	}
	if !plane.IsSuccess(resp.StatusCode) {
		return nil, fmt.Errorf("CreateIntakeIssue 失败: %s, body=%s", resp.Status, string(resp.Body))
	}

	var result plane.IntakeIssueResponse
	if err := json.Unmarshal(resp.Body, &result); err != nil {
		return nil, fmt.Errorf("响应解析失败: %w", err)
	}
	return &result, nil
}

// GetIntakeIssue 获取收件箱工作项详情
func GetIntakeIssue(c *plane.PlaneClient, slug, projectID, issueID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/intake-issues/%s/?expand=issue_inbox", slug, projectID, issueID)

	resp, err := c.Get(url)
	if err != nil {
		return nil, err
	}
	if !plane.IsSuccess(resp.StatusCode) {
		return nil, fmt.Errorf("GetIntakeIssue 失败: %s", resp.Status)
	}
	return resp.Body, nil
}

// UpdateIntakeIssue 更新收件箱工作项
func UpdateIntakeIssue(c *plane.PlaneClient, slug, projectID, issueID string, data map[string]any) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/intake-issues/%s/", slug, projectID, issueID)

	resp, err := c.Patch(url, data)
	if err != nil {
		return nil, err
	}
	if !plane.IsSuccess(resp.StatusCode) {
		return nil, fmt.Errorf("UpdateIntakeIssue 失败: %s", resp.Status)
	}
	return resp.Body, nil
}

// AcceptIntakeIssue 接受收件箱工作项
func AcceptIntakeIssue(c *plane.PlaneClient, slug, projectID, issueID string) ([]byte, error) {
	return UpdateIntakeIssue(c, slug, projectID, issueID, map[string]any{"status": 1})
}

// RejectIntakeIssue 拒绝收件箱工作项
func RejectIntakeIssue(c *plane.PlaneClient, slug, projectID, issueID string) ([]byte, error) {
	return UpdateIntakeIssue(c, slug, projectID, issueID, map[string]any{"status": -1})
}

// DeleteIntakeIssue 删除收件箱工作项
func DeleteIntakeIssue(c *plane.PlaneClient, slug, projectID, issueID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/intake-issues/%s/", slug, projectID, issueID)

	resp, err := c.Delete(url)
	if err != nil {
		return err
	}
	if resp.StatusCode != 204 {
		return fmt.Errorf("DeleteIntakeIssue 失败: %s", resp.Status)
	}
	return nil
}