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

package plane_v2_api

import (
	"fmt"

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

// ListModules 列出项目模块
func ListModules(c *plane.PlaneClient, slug, projectID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/", slug, projectID)

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

// CreateModule 创建模块
func CreateModule(c *plane.PlaneClient, slug, projectID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/", slug, projectID)

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

// GetModule 获取模块详情
func GetModule(c *plane.PlaneClient, slug, projectID, moduleID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

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

// UpdateModule 更新模块
func UpdateModule(c *plane.PlaneClient, slug, projectID, moduleID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

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

// DeleteModule 删除模块
func DeleteModule(c *plane.PlaneClient, slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

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

// ListModuleIssues 列出模块工作项
func ListModuleIssues(c *plane.PlaneClient, slug, projectID, moduleID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-issues/", slug, projectID, moduleID)

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

// AddIssuesToModule 添加工作项到模块
func AddIssuesToModule(c *plane.PlaneClient, slug, projectID, moduleID string, issueIDs []string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-issues/", slug, projectID, moduleID)
	payload := map[string]interface{}{
		"issues": issueIDs,
	}

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

// RemoveIssueFromModule 从模块移除工作项
func RemoveIssueFromModule(c *plane.PlaneClient, slug, projectID, moduleID, issueID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-issues/%s/", slug, projectID, moduleID, issueID)

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

// ArchiveModule 归档模块
func ArchiveModule(c *plane.PlaneClient, slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/archive/", slug, projectID, moduleID)

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

// UnarchiveModule 取消归档模块
func UnarchiveModule(c *plane.PlaneClient, slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/archive/", slug, projectID, moduleID)

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