【微信公众号开发】基于golang的公众号开发——接入消息自动回复接口

package routers
import (
    "blog_server_v4/config"
    "crypto/sha1"
    "encoding/hex"
    "encoding/xml"
    "fmt"
    "github.com/gin-gonic/gin"
    "log"
    "net/http"
    "sort"
    "strings"
)
type ReqWxMessage struct {
    ToUserName   string `json:"ToUserName"`
    FromUserName string `json:"FromUserName"`
    CreateTime   int    `json:"CreateTime"`
    MsgType      string `json:"MsgType"` // text | image | voice | shortvideo | location
    Event        string `json:"Event"`
    EventKey     string `json:"EventKey"`
    Ticket       string `json:"Ticket"`
    // 文本消息
    Content   string `json:"Content"`
    MsgId     int64  `json:"MsgId"`
    MsgDataId int64  `json:"MsgDataId"`
    Idx       int    `json:"Idx"`
    // 图片消息
    PicUrl  string `json:"PicUrl"`
    MediaId string `json:"MediaId"`
    // 语音消息
    Format string `json:"Format"` // amr | speex
    // 视频消息
    ThumbMediaId string `json:"ThumbMediaId"`
    // 地理位置消息
    LocationX string `json:"Location_X"`
    LocationY string `json:"Location_Y"`
    Scale     string `json:"Scale"`
    Label     string `json:"Label"`
    // 链接消息
    Title       string `json:"Title"`
    Description string `json:"Description"`
    Url         string `json:"Url"`
}
type RespWxMessageText struct {
    ToUserName   string   `json:"ToUserName"`
    FromUserName string   `json:"FromUserName"`
    CreateTime   int      `json:"CreateTime"`
    MsgType      string   `json:"MsgType"`
    Content      string   `json:"Content"`
    XMLName      xml.Name `xml:"xml"`
}
func RouterPartner(router *gin.Engine) (interface{}, error) {
    routerPartner := router.Group("/xxx/xxxx")
    {
        routerPartner.POST("/xxx/xxxx/v1", func(c *gin.Context) {
            signature := c.Query("signature")
            timestamp := c.Query("timestamp")
            nonce := c.Query("nonce")
            openid := c.Query("openid")
            log.Println("signature:", signature, "timestamp:", timestamp, "nonce:", nonce, "openid:", openid)
            var wxMsg ReqWxMessage
            err := c.BindXML(&wxMsg)
            if err != nil {
                log.Println(err)
            }
            //log.Println("mxMsg:", wxMsg)
            //byteWxMsg, err := json.Marshal(wxMsg)
            //if err != nil {
            //  log.Println("err: ", err)
            //}
            //log.Println("wxMsgString: ", string(byteWxMsg))
            switch wxMsg.MsgType {
            case "text":
                if strings.ToLower(wxMsg.Content) == "pdf2023" {
                    respWxMessageText := RespWxMessageText{
                        ToUserName:   wxMsg.FromUserName,
                        FromUserName: wxMsg.ToUserName,
                        CreateTime:   wxMsg.CreateTime + 1,
                        MsgType:      "text",
                        Content: `链接：https://pan.baidu.com/s/1FYKllrdbZDNc5BxxLv9mcQ?pwd=pryf
                    提取码：pryf
                    --来自百度网盘超级会员V5的分享`,
                    }
                    byteResp, err := xml.Marshal(&respWxMessageText)
                    if err != nil {
                        log.Println(err)
                        break
                    }
                    c.String(http.StatusOK, string(byteResp))
                    //
                    //log.Println(string(byteResp))
                    return
                }
            }
            c.String(http.StatusOK, "success")
            return
        })
    }
    return routerPartner, nil
}