demo/message.go

package demo

import (
	"encoding/json"
	"fmt"
	"github.com/labstack/echo/v4"
	"github.com/zsmhub/xhs-sdk/message"
	"net/http"
)

// &#25509;&#25910;&#23567;&#32418;&#20070;&#24320;&#25918;&#24179;&#21488;&#28040;&#24687;&#25512;&#36865;&#31034;&#20363;
func CallbackMain() {
	e := echo.New()

	e.GET("/message/auth", func(c echo.Context) error {
		// &#25171;&#21360;&#28040;&#24687;&#25512;&#36865;&#35831;&#27714;&#20307;&#65292;&#20415;&#20110;&#35843;&#35797;
		// requestBody, _ := ioutil.ReadAll(c.Request().Body)
		// fmt.Printf("xhs auth : uri=%s, req=%s\n", c.Request().RequestURI, string(requestBody))

		code := c.Param("code")
		state := c.Param("state")
		fmt.Printf("code=%s, state=%s\n", code, state)

		return c.JSON(http.StatusOK, message.MessageResp{
			Success:   true,
			ErrorCode: 0,
			ErrorMsg:  "",
		})
	}).Name = "&#24212;&#29992;&#25480;&#26435;&#22238;&#35843;&#22320;&#22336;"

	e.POST("/message/push", func(c echo.Context) error {
		// &#25171;&#21360;&#28040;&#24687;&#25512;&#36865;&#35831;&#27714;&#20307;&#65292;&#20415;&#20110;&#35843;&#35797;
		// requestBody, _ := ioutil.ReadAll(c.Request().Body)
		// fmt.Printf("xhs push : uri=%s, req=%s\n", c.Request().RequestURI, string(requestBody))

		var req []message.Message
		_ = c.Bind(&req)
		for _, v := range req {
			vJson, _ := json.Marshal(v)
			fmt.Printf("msg=%s\n", vJson)

			// &#28040;&#24687;data&#35299;&#26512;&#31034;&#20363;
			if v.MsgTag == (message.MsgFulfillmentStatusChange{}.MsgTag()) {
				// &#26041;&#26696;&#19968;
				//var resp message.MsgFulfillmentStatusChange
				//if err := v.DecodeData(&resp); err != nil {
				//    fmt.Println(err)
				//    continue
				//} else {
				//    fmt.Printf("resp=%+v\n", resp)
				//}

				// &#26041;&#26696;&#20108;
				resp, err := message.MsgFulfillmentStatusChange{}.DecodeData(v.Data)
				if err != nil {
					fmt.Println(err)
					continue
				} else {
					fmt.Printf("resp=%+v\n", resp)
				}
			}
		}

		return c.JSON(http.StatusOK, message.MessageResp{
			Success:   true,
			ErrorCode: 0,
			ErrorMsg:  "",
		})
	}).Name = "&#24212;&#29992;&#25512;&#36865;&#22238;&#35843;&#22320;&#22336;"

	e.Logger.Fatal(e.Start(":1323"))
	select {}
}