|
|
- package weixinrpc
-
- import (
- "encoding/json"
- "strconv"
- "time"
-
- "git.tetele.net/tgo/crypter"
-
- "github.com/golang/protobuf/proto"
- )
-
- /**
- * 发送小程序统一服务消息,默认发送公众号消息
- * appid,secret 小程序ID 密钥
- * touser 小程序openid
- * mp_appid 关联公众号appid,要求与小程序有绑定且同主体
- * temp_id 公众号模板id
- * redirect_url 跳转的url
- * mini_program 公众号模板消息所要跳转的小程序,小程序的必须与公众号具有绑定关系
- * data 公众号模板消息的数据
- */
-
- func SendUniformMessage(dbname, site_id string, appid, secret, touser, mp_appid, temp_id, redirect_url, mini_program string, data interface{}, url ...string) (*WxApiRes, error) {
-
- conn, err := rpc_server_conn(url...)
-
- uniform_message_data := UniformMessageReq{}
- uniform_message_data.SiteId = site_id
- uniform_message_data.Dbname = dbname
- uniform_message_data.Appid = appid
- uniform_message_data.Secret = secret
- uniform_message_data.Touser = touser
- uniform_message_data.MpAppid = mp_appid
- uniform_message_data.TemplateId = temp_id
- uniform_message_data.Url = redirect_url
- uniform_message_data.MiniProgram = mini_program
- uniform_message_data.Data = data
-
- data_json, err := json.Marshal(uniform_message_data)
- if err != nil {
- return nil, err
- }
-
- encryData := crypter.DesEn(string(data_json), DES_KEY)
-
- now_int64 := time.Now().Unix()
-
- now := strconv.FormatInt(now_int64, 10)
-
- sign := Sign(encryData, now)
-
- req := &Request{
- proto.String(encryData),
- proto.String(now),
- proto.String(sign),
- nil}
-
- res := &Response{}
-
- err = conn.SendUniformMessage(req, res)
-
- if err != nil {
- return nil, err
- }
-
- return HandleRes(res)
-
- }
|