|
@@ -1,139 +0,0 @@
|
|
|
-package public
|
|
|
-
|
|
|
-import (
|
|
|
- "encoding/json"
|
|
|
- "log"
|
|
|
- "net/rpc"
|
|
|
-
|
|
|
- util "app.yhyue.com/moapp/jybase/common"
|
|
|
- qrpc "app.yhyue.com/moapp/jybase/rpc"
|
|
|
-)
|
|
|
-
|
|
|
-var rpcserver string
|
|
|
-var followPushRpcServer string
|
|
|
-
|
|
|
-func InitRpcCall(Sysconfig map[string]interface{}) {
|
|
|
- rpcserver, _ = Sysconfig["weixinrpc"].(string)
|
|
|
- followPushRpcServer, _ = Sysconfig["followPushRpc"].(string)
|
|
|
-}
|
|
|
-
|
|
|
-//发送管理员模板消息
|
|
|
-func SendBidOpenMsg(p *qrpc.NotifyMsg) bool {
|
|
|
- ok, _ := qrpc.WxPush(rpcserver, "WeiXinRpc.SendBidOpenMsg", p)
|
|
|
- return ok
|
|
|
-}
|
|
|
-
|
|
|
-//发送数据报告模板消息
|
|
|
-func SendDataReportMsg(p *qrpc.NotifyMsg) bool {
|
|
|
- ok, _ := qrpc.WxPush(rpcserver, "WeiXinRpc.SendDataReportMsg", p)
|
|
|
- return ok
|
|
|
-}
|
|
|
-
|
|
|
-//发送保函申请消息
|
|
|
-func SendLOGApplyMsg(p *qrpc.NotifyMsg) bool {
|
|
|
- ok, _ := qrpc.WxPush(rpcserver, "WeiXinRpc.SendLOGApplyMsg", p)
|
|
|
- return ok
|
|
|
-}
|
|
|
-
|
|
|
-//发送年终活动消息
|
|
|
-func SendACTIVEApplyMsg(p *qrpc.NotifyMsg) bool {
|
|
|
- ok, _ := qrpc.WxPush(rpcserver, "WeiXinRpc.SendACTIVEApplyMsg", p)
|
|
|
- return ok
|
|
|
-}
|
|
|
-
|
|
|
-//项目更新推送
|
|
|
-func FollowPush(p *qrpc.FollowPush) (repls []*map[string]interface{}, err error) {
|
|
|
- util.Try(func() {
|
|
|
- client, e := rpc.DialHTTP("tcp", followPushRpcServer)
|
|
|
- defer client.Close()
|
|
|
- if e != nil {
|
|
|
- err = e
|
|
|
- log.Println(err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- var repl []byte
|
|
|
- err = client.Call("FollowPushRpc.FollowPush", p, &repl)
|
|
|
- if err == nil && repl != nil && len(repl) > 0 {
|
|
|
- var mp []*map[string]interface{}
|
|
|
- json.Unmarshal(repl, &mp)
|
|
|
- repls = mp
|
|
|
- }
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- }
|
|
|
- }, func(e interface{}) {})
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-//返回项目更新
|
|
|
-func FollowPushBack(p *qrpc.FollowPush) (err error) {
|
|
|
- util.Try(func() {
|
|
|
- client, e := rpc.DialHTTP("tcp", followPushRpcServer)
|
|
|
- defer client.Close()
|
|
|
- if e != nil {
|
|
|
- err = e
|
|
|
- log.Println(err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- var repl []byte
|
|
|
- err = client.Call("FollowPushRpc.FollowPush", p, &repl)
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- }
|
|
|
- }, func(e interface{}) {})
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-//分享二维码图片
|
|
|
-func GetShareQR(url uint32) string {
|
|
|
- var ret string
|
|
|
- util.Try(func() {
|
|
|
- client, err := rpc.DialHTTP("tcp", rpcserver)
|
|
|
- defer client.Close()
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- err = client.Call("WeiXinRpc.GetShareQR", url, &ret)
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- }
|
|
|
- }, func(e interface{}) {})
|
|
|
- return ret
|
|
|
-}
|
|
|
-
|
|
|
-//分享二维码图片
|
|
|
-func GetShareQRStr(url string) string {
|
|
|
- var ret string
|
|
|
- util.Try(func() {
|
|
|
- client, err := rpc.DialHTTP("tcp", rpcserver)
|
|
|
- defer client.Close()
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- err = client.Call("WeiXinRpc.GetShareQRStr", url, &ret)
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- }
|
|
|
- }, func(e interface{}) {})
|
|
|
- return ret
|
|
|
-}
|
|
|
-
|
|
|
-//获取未关注用户unionid
|
|
|
-func GetUnionid(openid string) string {
|
|
|
- var unionid string
|
|
|
- util.Try(func() {
|
|
|
- client, err := rpc.DialHTTP("tcp", rpcserver)
|
|
|
- defer client.Close()
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- err = client.Call("WeiXinRpc.GetUnionid", openid, &unionid)
|
|
|
- if err != nil {
|
|
|
- log.Println(err.Error())
|
|
|
- }
|
|
|
- }, func(e interface{}) {})
|
|
|
- return unionid
|
|
|
-}
|