使用Golang实现YNAB API接口调用的插件库

YNAB (You Need A Budget) 是一个流行的个人财务管理工具，它提供了丰富的API接口。下面我将介绍如何使用Golang实现YNAB API的调用，并提供一个完整的插件库示例。

1. 准备工作

首先，你需要获取YNAB API的访问令牌：

1. 登录YNAB账户
2. 进入"开发者设置"
3. 创建新的访问令牌

2. 基础库实现

以下是实现YNAB API调用的基础库代码：

package ynab

import (
	"bytes"
	"encoding/json"
	"errors"
	"fmt"
	"io"
	"net/http"
	"time"
)

const (
	baseURL = "https://api.ynab.com/v1"
)

// Client 是YNAB API客户端
type Client struct {
	apiKey     string
	httpClient *http.Client
}

// NewClient 创建新的YNAB客户端
func NewClient(apiKey string) *Client {
	return &Client{
		apiKey: apiKey,
		httpClient: &http.Client{
			Timeout: time.Second * 30,
		},
	}
}

// doRequest 执行API请求
func (c *Client) doRequest(method, endpoint string, body interface{}) ([]byte, error) {
	var reqBody io.Reader
	if body != nil {
		jsonBody, err := json.Marshal(body)
		if err != nil {
			return nil, err
		}
		reqBody = bytes.NewBuffer(jsonBody)
	}

	req, err := http.NewRequest(method, baseURL+endpoint, reqBody)
	if err != nil {
		return nil, err
	}

	req.Header.Set("Authorization", "Bearer "+c.apiKey)
	req.Header.Set("Content-Type", "application/json")

	resp, err := c.httpClient.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	respBody, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}

	if resp.StatusCode >= 400 {
		return nil, errors.New(string(respBody))
	}

	return respBody, nil
}

3. 预算相关功能实现

// Budget 表示YNAB预算
type Budget struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

// GetBudgets 获取所有预算
func (c *Client) GetBudgets() ([]Budget, error) {
	resp, err := c.doRequest("GET", "/budgets", nil)
	if err != nil {
		return nil, err
	}

	var response struct {
		Data struct {
			Budgets []Budget `json:"budgets"`
		} `json:"data"`
	}

	if err := json.Unmarshal(resp, &response); err != nil {
		return nil, err
	}

	return response.Data.Budgets, nil
}

// GetBudgetById 通过ID获取预算
func (c *Client) GetBudgetById(budgetId string) (*Budget, error) {
	resp, err := c.doRequest("GET", fmt.Sprintf("/budgets/%s", budgetId), nil)
	if err != nil {
		return nil, err
	}

	var response struct {
		Data struct {
			Budget Budget `json:"budget"`
		} `json:"data"`
	}

	if err := json.Unmarshal(resp, &response); err != nil {
		return nil, err
	}

	return &response.Data.Budget, nil
}

4. 交易相关功能实现

// Transaction 表示YNAB交易
type Transaction struct {
	ID          string  `json:"id"`
	Date        string  `json:"date"`
	Amount      float64 `json:"amount"`
	PayeeName   string  `json:"payee_name"`
	Category    string  `json:"category_name"`
	Description string  `json:"memo"`
}

// GetTransactions 获取预算的交易
func (c *Client) GetTransactions(budgetId string) ([]Transaction, error) {
	resp, err := c.doRequest("GET", fmt.Sprintf("/budgets/%s/transactions", budgetId), nil)
	if err != nil {
		return nil, err
	}

	var response struct {
		Data struct {
			Transactions []Transaction `json:"transactions"`
		} `json:"data"`
	}

	if err := json.Unmarshal(resp, &response); err != nil {
		return nil, err
	}

	return response.Data.Transactions, nil
}

// CreateTransaction 创建新交易
func (c *Client) CreateTransaction(budgetId string, transaction Transaction) (*Transaction, error) {
	reqBody := struct {
		Transaction Transaction `json:"transaction"`
	}{
		Transaction: transaction,
	}

	resp, err := c.doRequest("POST", fmt.Sprintf("/budgets/%s/transactions", budgetId), reqBody)
	if err != nil {
		return nil, err
	}

	var response struct {
		Data struct {
			Transaction Transaction `json:"transaction"`
		} `json:"data"`
	}

	if err := json.Unmarshal(resp, &response); err != nil {
		return nil, err
	}

	return &response.Data.Transaction, nil
}

5. 使用示例

package main

import (
	"fmt"
	"log"
	"ynab" // 假设上面的代码在ynab包中
)

func main() {
	// 替换为你的YNAB API密钥
	apiKey := "your_ynab_api_key_here"
	client := ynab.NewClient(apiKey)

	// 获取所有预算
	budgets, err := client.GetBudgets()
	if err != nil {
		log.Fatalf("获取预算失败: %v", err)
	}

	fmt.Println("可用预算:")
	for _, budget := range budgets {
		fmt.Printf("- %s (ID: %s)\n", budget.Name, budget.ID)
	}

	// 假设我们使用第一个预算
	if len(budgets) == 0 {
		log.Fatal("没有找到预算")
	}
	budgetId := budgets[0].ID

	// 获取交易
	transactions, err := client.GetTransactions(budgetId)
	if err != nil {
		log.Fatalf("获取交易失败: %v", err)
	}

	fmt.Println("\n最近的交易:")
	for i, t := range transactions {
		if i >= 5 { // 只显示前5笔交易
			break
		}
		fmt.Printf("- %s: %.2f (%s)\n", t.Date, t.Amount, t.PayeeName)
	}

	// 创建新交易示例
	newTransaction := ynab.Transaction{
		Date:        "2023-11-01",
		Amount:      50.00,
		PayeeName:   "超市",
		Category:    "食品杂货",
		Description: "每周购物",
	}

	createdTx, err := client.CreateTransaction(budgetId, newTransaction)
	if err != nil {
		log.Fatalf("创建交易失败: %v", err)
	}

	fmt.Printf("\n创建的交易ID: %s\n", createdTx.ID)
}

6. 高级功能扩展

你可以进一步扩展这个库，添加以下功能：

1. 账户管理：获取、创建和更新账户
2. 类别操作：管理预算类别和类别组
3. 批量操作：批量导入交易
4. 错误处理：更详细的错误分类和处理
5. 分页支持：处理大量数据的API响应
6. 缓存：减少重复API调用

7. 注意事项

1. API有速率限制(200请求/小时)，需要适当处理
2. 敏感数据(如API密钥)应该安全存储
3. 考虑添加重试机制处理临时网络问题
4. 可以使用context包支持请求取消

这个实现提供了YNAB API的基本功能，你可以根据需要进一步扩展和完善它。