FranklinWH-Toolbox/service/repositories/api/plane_v2/plane_state.go

package plane_v2

import (
	"fmt"

	"go.uber.org/zap"
)

// ==================== State API ====================

// ListStates 列出状态
func ListStates(slug, projectID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/", slug, projectID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] ListStates 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ListStates 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("ListStates 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// CreateState 创建状态
// group: backlog / unstarted / started / completed / cancelled
func CreateState(slug, projectID, name, color, group string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/", slug, projectID)
	payload := map[string]interface{}{
		"name":  name,
		"color": color,
		"group": group,
	}

	resp, err := planeWebPost(url, payload)
	if err != nil {
		zap.L().Error("[PlaneWeb] CreateState 请求失败", zap.Error(err))
		return nil, err
	}

	if resp.StatusCode != 201 {
		zap.L().Error("[PlaneWeb] CreateState 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("CreateState 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// GetState 获取状态详情
func GetState(slug, projectID, stateID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/%s/", slug, projectID, stateID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] GetState 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] GetState 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("GetState 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// UpdateState 更新状态
func UpdateState(slug, projectID, stateID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/%s/", slug, projectID, stateID)

	resp, err := planeWebPatch(url, data)
	if err != nil {
		zap.L().Error("[PlaneWeb] UpdateState 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] UpdateState 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("UpdateState 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// DeleteState 删除状态
func DeleteState(slug, projectID, stateID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/%s/", slug, projectID, stateID)

	resp, err := planeWebDelete(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] DeleteState 请求失败", zap.Error(err))
		return err
	}

	if resp.StatusCode != 204 {
		zap.L().Error("[PlaneWeb] DeleteState 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("DeleteState 失败: %s", resp.Status)
	}

	return nil
}

// MarkStateDefault 设为默认状态
func MarkStateDefault(slug, projectID, stateID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/states/%s/mark-default/", slug, projectID, stateID)

	resp, err := planeWebPost(url, map[string]interface{}{})
	if err != nil {
		zap.L().Error("[PlaneWeb] MarkStateDefault 请求失败", zap.Error(err))
		return err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] MarkStateDefault 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("MarkStateDefault 失败: %s", resp.Status)
	}

	return nil
}

// ListCurrentStates 列出当前项目下的状态
func ListCurrentStates() ([]byte, error) {
	return ListStates(webWorkspaceSlug, webProjectId)
}