42 lines
1.3 KiB
Go
42 lines
1.3 KiB
Go
|
// Package controller - Webhook控制器
|
|||
|
|
// 功能：接收平台（小红书、抖音）的webhook消息
|
|||
|
|
package controller
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"context"
|
|||
|
|
"customer-server/model/dto"
|
|||
|
|
"customer-server/service"
|
|||
|
|
|
|||
|
|
"github.com/gogf/gf/v2/frame/g"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
var Webhook = new(webhook)
|
|||
|
|
|
|||
|
|
type webhook struct{}
|
|||
|
|
|
|||
|
|
// Receive 接收Webhook消息
|
|||
|
|
// 参数: req - Webhook消息请求，包含平台、用户ID、内容等
|
|||
|
|
// 返回: res - 处理结果
|
|||
|
|
// 功能: 接收来自各平台的Webhook消息推送，统一处理后推送到Redis Stream
|
|||
|
|
func (c *webhook) Receive(ctx context.Context, req *dto.WebhookReceiveReq) (res *dto.WebhookReceiveRes, err error) {
|
|||
|
|
res, err = service.Webhook.Receive(ctx, req)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Verify 平台回调验证
|
|||
|
|
// 参数: req - 回调请求，包含echostr等
|
|||
|
|
// 返回: res - 处理结果
|
|||
|
|
// 功能: 验证平台回调请求，返回echostr
|
|||
|
|
func (c *webhook) Verify(ctx context.Context, req *dto.WebhookCallbackReq) (res *dto.WebhookCallbackRes, err error) {
|
|||
|
|
r := g.RequestFromCtx(ctx)
|
|||
|
|
// 直接返回 echostr（微信/抖音等平台验证方式）
|
|||
|
|
r.Response.Write(req.Echostr)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// History 查询对话记录
|
|||
|
|
func (c *webhook) History(ctx context.Context, req *dto.ConversationListReq) (res *dto.ConversationListRes, err error) {
|
|||
|
|
res, err = service.Webhook.GetHistory(ctx, req)
|
|||
|
|
return
|
|||
|
|
}
|