package weixinrpc import ( "git.tetele.net/tgo/conf" ) const DES_KEY = "wxserrpc" type WxApiRes struct { Errcode int Errmsg string } type Req struct { SiteId string Dbname string } type AccessTokenReq struct { Req Appid string Secret string } type AccessTokenRes struct { AccessToken string } type UniformMessageReq struct { Req Appid string Secret string Touser string MpAppid string TemplateId string Url string MiniProgram interface{} Data interface{} } type SubscribeMessageReq struct { Req Appid string Secret string Touser string TemplateId string Page string MiniprogramState string Lang string Data interface{} } /** * 获取小程序openid请求参数 */ type MiniAppOpenidReq struct { Appid string Secret string JsCode string } /** * 获取小程序openid返回参数 */ type MiniAppOpenidRes struct { Openid string SessionKey interface{} Unionid interface{} NickName string AvatarUrl string WxApiRes } /** * 获取公众号openid返回参数 */ type MpOpenidRes struct { AccessToken string ExpiresIn string RefreshToken string Openid string Scope string } /** * 获取公众号用户信息请求参数 */ type MpUserInfoReq struct { AccessToken string Openid string } /** * 根据用户access_token换取用户信息返回参数 */ type MpUserInfoRes struct { Openid string Nickname string Sex string Province string City string Country string Headimgurl string Privilege string Unionid string } func rpc_server_conn(url ...string) (*WeixinRpcServiceClient, error) { var wx_rpc_url string if len(url) > 0 && url[0] != "" { wx_rpc_url = url[0] } else { wx_rpc_url = "127.0.0.1:" + conf.WEIXIN_RPC_PORT } conn, _, err := DialWeixinRpcService("tcp", wx_rpc_url) if err != nil { return nil, err } return conn, nil }