微信公众号消息推送接入指南

func (h *OAHandler) RegisterRoutes(server *gin.Engine) {
	// 微信公众平台 (Official Account) 消息推送网关
	g := server.Group("/api/v1/oa")
	{
		// portal 门户：入口站点需对微信服务器免登录放行
		g.GET("/portal", h.VerifyEcho)
	}
}

func (h *OAHandler) VerifyEcho(ctx *gin.Context) {
	appId := h.getAppId(ctx)
	if appId == "" {
		h.l.Warn("微信公众平台验证请求缺失 appId 参数")
		response.Fail(ctx, ecode.InvalidParams.WithDetails("缺失 appId 参数"))
		return
	}

	// 定义微信验证请求参数
	type EchoReq struct {
		Signature string `form:"signature" binding:"required"`
		Timestamp string `form:"timestamp" binding:"required"`
		Nonce     string `form:"nonce" binding:"required"`
		Echostr   string `form:"echostr" binding:"required"`
	}

	var req EchoReq
	if valid, errs := validator.BindAndValid(ctx, &req); !valid {
		h.l.Warn("接收到非法微信公众平台验证请求，参数缺失或格式不符", zap.Any("errs", errs))
		response.Fail(ctx, ecode.InvalidParams.WithDetails(errs))
		return
	}

	// 验证签名
	if h.svc.CheckSignature(ctx, appId, req.Signature, req.Timestamp, req.Nonce) {
		h.l.Info("微信公众平台服务器验证成功", zap.String("echostr", req.Echostr), zap.String("appId", appId))
		// 验证成功，原样返回 echostr 字符串
		ctx.String(http.StatusOK, req.Echostr)
		return
	}

	h.l.Warn("微信公众平台服务器签名验证失败",
		zap.String("appId", appId),
		zap.String("signature", req.Signature),
		zap.String("timestamp", req.Timestamp),
		zap.String("nonce", req.Nonce))
	ctx.String(http.StatusForbidden, "Signature Verification Failed")
}

func (s *oaService) CheckSignature(ctx context.Context, appId, signature, timestamp, nonce string) bool {
	// 获取公众号配置中的 Token
	oaConfig, err := s.oaConfigRepo.GetByAppId(ctx, appId)
	if err != nil || oaConfig == nil || oaConfig.Token == "" {
		s.l.Warn("OA Token 未配置或拉取失败", zap.String("appId", appId), zap.Error(err))
		return false
	}
	token := oaConfig.Token

	// 1. 将 token、timestamp、nonce 三个参数进行字典序排序
	params := []string{token, timestamp, nonce}
	sort.Strings(params)

	// 2. 将排序后的参数拼接成一个字符串
	var raw string
	for _, p := range params {
		raw += p
	}

	// 3. 对拼接后的字符串进行 SHA1 加密
	h := sha1.New()
	h.Write([]byte(raw))
	hashStr := hex.EncodeToString(h.Sum(nil))

	// 4. 将加密后的字符串与微信传来的 signature 对比
	return hashStr == signature
}

cpolar http 8080