115 lines
5.2 KiB
Go
115 lines
5.2 KiB
Go
package api
|
|
|
|
import (
|
|
"time"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/autonavi"
|
|
"git.rosy.net.cn/baseapi/platformapi/dadaapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/elmapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/jdapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/mtpsapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/showapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/weimobapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/weixinapi"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils/cache"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils/cache/redis"
|
|
|
|
"github.com/astaxie/beego"
|
|
"github.com/qiniu/api.v7/auth/qbox"
|
|
)
|
|
|
|
var (
|
|
JdAPI *jdapi.API
|
|
ElmAPI *elmapi.API
|
|
EbaiAPI *ebaiapi.API
|
|
MtpsAPI *mtpsapi.API
|
|
DadaAPI *dadaapi.API
|
|
MtwmAPI *mtwmapi.API
|
|
WeixinAPI *weixinapi.API
|
|
WeixinMiniAPI *weixinapi.API
|
|
WeixinPageAPI *weixinapi.API
|
|
|
|
AutonaviAPI *autonavi.API
|
|
QiniuAPI *qbox.Mac
|
|
ShowAPI *showapi.API
|
|
WeimobAPI *weimobapi.API
|
|
DingDingAPI *dingdingapi.API
|
|
DingDingQRCodeAPI *dingdingapi.API
|
|
|
|
Cacher cache.ICacher
|
|
)
|
|
|
|
func Init() {
|
|
if !beego.AppConfig.DefaultBool("disableJd", false) {
|
|
JdAPI = jdapi.New(beego.AppConfig.String("jdToken"), beego.AppConfig.String("jdAppKey"), beego.AppConfig.String("jdSecret"))
|
|
JdAPI.SetStoreCookie(beego.AppConfig.DefaultString("jdStorePageCookie", ""))
|
|
}
|
|
if !beego.AppConfig.DefaultBool("disableElm", false) {
|
|
initElm()
|
|
}
|
|
if !beego.AppConfig.DefaultBool("disableMtps", false) {
|
|
MtpsAPI = mtpsapi.New(beego.AppConfig.String("mtpsAppKey"), beego.AppConfig.String("mtpsSecret"))
|
|
}
|
|
MtwmAPI = mtwmapi.New(beego.AppConfig.String("mtwmAppID"), beego.AppConfig.String("mtwmSecret"), beego.AppConfig.String("mtwmCallbackURL"))
|
|
if !beego.AppConfig.DefaultBool("disableDada", false) {
|
|
DadaAPI = dadaapi.New(beego.AppConfig.String("dadaAppKey"), beego.AppConfig.String("dadaAppSecret"), beego.AppConfig.String("dadaSourceID"), beego.AppConfig.String("dadaCallbackURL"), beego.AppConfig.DefaultBool("dadaIsProd", false))
|
|
}
|
|
if !beego.AppConfig.DefaultBool("disableWeixin", false) {
|
|
WeixinAPI = weixinapi.New(beego.AppConfig.String("weixinAppID"), beego.AppConfig.String("weixinSecret"))
|
|
// 这个主要是用于调试阶段使用，生产环境中用的是自动刷新那套
|
|
if weixinToken := beego.AppConfig.DefaultString("weixinToken", ""); weixinToken != "" {
|
|
WeixinAPI.CBSetToken(weixinToken)
|
|
}
|
|
if weixinMsgToken := beego.AppConfig.DefaultString("weixinMsgToken", ""); weixinMsgToken != "" {
|
|
WeixinAPI.SetMsgTokenAndKey(weixinMsgToken, beego.AppConfig.DefaultString("weixinMsgKey", ""))
|
|
}
|
|
}
|
|
WeixinMiniAPI = weixinapi.New(beego.AppConfig.String("weixinMiniAppID"), beego.AppConfig.String("weixinMiniSecret"))
|
|
WeixinPageAPI = weixinapi.New(beego.AppConfig.String("weixinPageAppID"), beego.AppConfig.String("weixinPageSecret"))
|
|
|
|
AutonaviAPI = autonavi.New(beego.AppConfig.String("autonaviKey"))
|
|
QiniuAPI = qbox.NewMac(beego.AppConfig.String("qiniuAK"), beego.AppConfig.String("qiniuSK"))
|
|
if !beego.AppConfig.DefaultBool("disableEbai", false) {
|
|
EbaiAPI = ebaiapi.New(beego.AppConfig.String("ebaiSource"), beego.AppConfig.String("ebaiSecret"))
|
|
ebaiStorePageCookieWMUSS := beego.AppConfig.DefaultString("ebaiStorePageCookieWMUSS", "")
|
|
ebaiStorePageCookieWMSTOKEN := beego.AppConfig.DefaultString("ebaiStorePageCookieWMSTOKEN", "")
|
|
if ebaiStorePageCookieWMUSS != "" && ebaiStorePageCookieWMSTOKEN != "" {
|
|
EbaiAPI.SetStoreCookie("WMUSS", ebaiStorePageCookieWMUSS)
|
|
EbaiAPI.SetStoreCookie("WMSTOKEN", ebaiStorePageCookieWMSTOKEN)
|
|
}
|
|
}
|
|
ShowAPI = showapi.New(beego.AppConfig.DefaultInt("showAppID", 0), beego.AppConfig.DefaultString("showAppSecret", ""))
|
|
Cacher = redis.New(beego.AppConfig.DefaultString("redisHost", "localhost"), beego.AppConfig.DefaultInt("redisPort", 0), beego.AppConfig.DefaultString("redisPassword", ""))
|
|
|
|
//微盟上传大图片耗时较长
|
|
weimobAPIConfig := platformapi.DefAPIConfig
|
|
weimobAPIConfig.ClientTimeout = 120 * time.Second
|
|
WeimobAPI = weimobapi.New(nil, beego.AppConfig.DefaultString("weimobAppID", ""), beego.AppConfig.DefaultString("weimobAppSecret", ""), &weimobAPIConfig)
|
|
|
|
DingDingAPI = dingdingapi.New(beego.AppConfig.DefaultString("dingdingAppKey", ""), beego.AppConfig.DefaultString("dingdingSecret", ""))
|
|
DingDingQRCodeAPI = dingdingapi.New(beego.AppConfig.DefaultString("dingdingQRCodeAppKey", ""), beego.AppConfig.DefaultString("dingdingQRCodeSecret", ""))
|
|
}
|
|
|
|
func initElm() {
|
|
token := beego.AppConfig.DefaultString("elmToken", "")
|
|
// if token == "" {
|
|
// db := orm.NewOrm()
|
|
// var tokenInfo []orm.Params
|
|
// num, err := db.Raw("SELECT * FROM config WHERE thirdparty='eleme'").Values(&tokenInfo)
|
|
// if err != nil || num != 1 {
|
|
// panic(err.Error())
|
|
// }
|
|
|
|
// var tokenInfo2 map[string]interface{}
|
|
// if err := utils.UnmarshalUseNumber([]byte(tokenInfo[0]["token"].(string)), &tokenInfo2); err != nil {
|
|
// panic(err.Error())
|
|
// }
|
|
// token = tokenInfo2["accessToken"].(string)
|
|
// }
|
|
ElmAPI = elmapi.New(token, beego.AppConfig.String("elmAppKey"), beego.AppConfig.String("elmSecret"), beego.AppConfig.DefaultBool("elmIsProd", false))
|
|
}
|