wechat/examples/beego/beego.go

package main

import (
	"fmt"

	"github.com/astaxie/beego"
	"github.com/astaxie/beego/context"
	"github.com/silenceper/wechat"
	"github.com/silenceper/wechat/message"
)

func hello(ctx *context.Context) {
	//配置微信参数
	config := &wechat.Config{
		AppID:          "wxbb8d22a4653455e7",
		AppSecret:      "044ac985f5066c0a23716f403bc7b5cc",
		Token:          "youjia",
		EncodingAESKey: "nHlUl7WWD0driO5HMez3R63T0mrj2uRSQ64pi3tqHLo",
	}
	fmt.Println("-----==++-----333")
	wc := wechat.NewWechat(config)
	// 传入request和responseWriter
	server := wc.GetServer(ctx.Request, ctx.ResponseWriter)
	//设置接收消息的处理方法
	server.SetMessageHandler(func(msg message.MixMessage) *message.Reply {
		//回复消息：演示回复用户发送的消息
		text := message.NewText(msg.Content)
		return &message.Reply{MsgType: message.MsgTypeText, MsgData: text}
	})

	//处理消息接收以及回复
	err := server.Serve()
	if err != nil {
		fmt.Println(err)
		return
	}

	//发送回复的消息
	server.Send()
}

func main() {
	beego.Any("/", hello)
	beego.Run(":7050")
}