微信支付公共包Go语言实现

JIeJaitt

2025 年 01 月 17 日

1 次浏览

暂无评论

3289字数

还没写好

@route.go **@OpeSupportRoute.go** **@dailyNews.go** 我想在GetDailyNews函数中使用CreateOrder该如何使用

我来帮您在 GetDailyNews 中集成微信支付功能。首先需要修改路由和服务层代码。

1. 首先修改 dailyNews.go 中的代码：

```go:internal/service/dailyNews.go
// ... existing code ...

// GetDailyNews 获取每日生成晨报
func GetDailyNews() fiber.Handler {
	return func(c *fiber.Ctx) error {
		date := c.Query("date")
		if len(date) == 0 {
			return common.ParamsError("date is required")
		}
		newsTypeStr := c.Query("dailyNewsType")

newsType, err := strconv.Atoi(newsTypeStr)
		if err != nil{
			newsType = 1
		}

// 检查用户是否已支付
		// TODO: 实现检查用户支付状态的逻辑
		isPaid := false
		if !isPaid {
			// 创建支付订单
			wechatPayClient := wechatpay.NewWeChatPayClient(&wechatpay.WeChatPayConfig{
				AppID:    "your_app_id",
				MchID:    "your_mch_id",
				APIv3Key: "your_api_v3_key",
				// ... 其他配置
			})

orderParams := &wechatpay.CreateOrderParams{
				Description: "每日晨报订阅",
				OutTradeNo: "DN" + time.Now().Format("20060102150405") + strconv.Itoa(rand.Intn(1000)),
				TimeExpire: time.Now().Add(30 * time.Minute),
				Amount: struct {
					Total    int
					Currency string
				}{
					Total:    100, // 1元，单位为分
					Currency: "CNY",
				},
				Payer: struct {
					OpenID string
				}{
					OpenID: "user_open_id", // 需要从请求中获取用户的 OpenID
				},
			}

resp, err := wechatPayClient.CreateOrder(orderParams)
			if err != nil {
				return common.ServiceError("创建支付订单失败")
			}

// 返回支付所需信息
			return jsonrpc.OK(c, fiber.Map{
				"needPay":   true,
				"prepayId":  resp.PrepayID,
				"orderNo":   orderParams.OutTradeNo,
			})
		}

// 原有的获取晨报逻辑
		data, err := model.GetDailyNewsList(repo.GetDB().WithContext(c.UserContext()), date, newsType)
		// ... existing code ...
	}
}
```

2. 在 OpeSupportRoute.go 中添加支付回调接口：

```go:internal/route/OpeSupportRoute.go
func OpeSupportRoute(app *fiber.App) {
	// ... existing code ...
	
	v1.Get("/daily_news", service.GetDailyNews())              // 获取每日生成晨报
	v1.Post("/daily_news/pay/notify", service.HandleWeChatPayNotify()) // 微信支付回调通知
	
	// ... existing code ...
}
```

3. 创建支付回调处理函数：

```go:internal/service/wechatPayNotify.go
package service

import (
	"github.com/gofiber/fiber/v2"
	"operation/internal/api/wechatpay"
)

func HandleWeChatPayNotify() fiber.Handler {
	return func(c *fiber.Ctx) error {
		// 处理支付回调逻辑
		// 1. 验证签名
		// 2. 解密数据
		// 3. 更新订单状态
		// 4. 返回成功响应
		return nil
	}
}
```

要完整实现这个功能，您还需要：

1. 创建订单表来记录支付状态
2. 实现用户认证，获取用户的 OpenID
3. 配置微信支付的相关参数（AppID、商户号等）
4. 实现支付回调逻辑
5. 实现订单状态查询接口

建议创建以下数据表：

```sql
CREATE TABLE daily_news_orders (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    order_no VARCHAR(32) NOT NULL COMMENT '订单号',
    user_id VARCHAR(32) NOT NULL COMMENT '用户ID',
    amount INT NOT NULL COMMENT '支付金额(分)',
    status TINYINT NOT NULL DEFAULT 0 COMMENT '支付状态：0未支付 1已支付 2已退款',
    news_id BIGINT NOT NULL COMMENT '晨报ID',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY uk_order_no (order_no)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='晨报订单表';
```

您需要我详细说明哪部分的实现吗？比如：

1. 支付回调的具体实现
2. 订单状态管理
3. 用户认证和 OpenID 获取
4. 微信支付配置管理

最后修改：2025 年 01 月 17 日