jypkg/public/rpccall.go

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
}