package http
import (
"net/http"
"go-common/app/interface/main/account/conf"
"go-common/app/interface/main/account/service/card"
"go-common/app/interface/main/account/service/coupon"
"go-common/app/interface/main/account/service/geetest"
"go-common/app/interface/main/account/service/member"
"go-common/app/interface/main/account/service/passport"
"go-common/app/interface/main/account/service/point"
"go-common/app/interface/main/account/service/realname"
rls "go-common/app/interface/main/account/service/relation"
us "go-common/app/interface/main/account/service/usersuit"
"go-common/app/interface/main/account/service/vip"
vipverify "go-common/app/service/main/vip/verify"
"go-common/library/log"
bm "go-common/library/net/http/blademaster"
"go-common/library/net/http/blademaster/middleware/antispam"
"go-common/library/net/http/blademaster/middleware/auth"
"go-common/library/net/http/blademaster/middleware/supervisor"
v "go-common/library/net/http/blademaster/middleware/verify"
)
var (
relationSvc *rls.Service
memberSvc *member.Service
passSvc *passport.Service
vipSvc *vip.Service
realnameSvc *realname.Service
usSvc *us.Service
couponSvc *coupon.Service
pointSvc *point.Service
cardSvc *card.Service
geetestSvr *geetest.Service
// api middleware
authn *auth.Auth
verify *v.Verify
anti *antispam.Antispam
batchRelAnti *antispam.Antispam
smsAnti *antispam.Antispam
faceAnti *antispam.Antispam
vipAnti *antispam.Antispam
spv *supervisor.Supervisor
// vip third verify
vipThirdVerify *vipverify.Verify
)
// Init init http sever instance.
func Init(c *conf.Config) {
// service
initService(c)
vipThirdVerify = vipverify.NewThirdVerify(c.VipThirdVerifyConfig)
// init outer router
// innerEngine := bm.DefaultServer(c.BM.Inner)
innerEngine := bm.NewServer(c.BM.Inner)
innerEngine.Use(bm.Recovery(), bm.Trace(), bm.Logger(), bm.Mobile())
setupInnerEngine(innerEngine)
if err := innerEngine.Start(); err != nil {
log.Error("innerEngine.Start() error(%v)", err)
panic(err)
}
}
func setupInnerEngine(e *bm.Engine) {
e.Ping(ping)
e.Register(register)
// member
mr := e.Group("/x/member", bm.CSRF())
mr.GET("/notice", authn.User, notice)
mr.POST("/notice/close", authn.User, closeNotice)
sec := mr.Group("/security", authn.User)
sec.GET("/status", status)
sec.POST("/feedback", feedback)
sec.POST("/close", closeNotify)
app := mr.Group("/app", authn.UserMobile)
app.GET("/nickfree", nickFree)
app.POST("/uname/update", spv.ServeHTTP, updateUname)
app.POST("/sign/update", spv.ServeHTTP, updateSign)
app.POST("/sex/update", updateSex)
app.POST("/birthday/update", updateBirthday)
app.POST("/face/update", spv.ServeHTTP, faceAnti.ServeHTTP, updateFace)
app.POST("/pendant/equip", pendantEquip)
app.GET("/point/flag", pointFlagMobile)
web := mr.Group("/web", authn.User)
web.POST("/update", spv.ServeHTTP, update)
web.POST("/face/update", spv.ServeHTTP, faceAnti.ServeHTTP, updateFace)
web.POST("/sign/update", spv.ServeHTTP, updateSign)
web.POST("/uname/update", spv.ServeHTTP, updateUname)
web.GET("/account", account)
web.GET("/reply/list", replyHistoryList)
web.GET("/coin/log", logCoin)
web.GET("/moral/log", logMoral)
web.GET("/exp/log", logExp)
web.GET("/exp/reward", reward)
web.GET("/login/log", logLogin)
web.GET("/coin", coin)
web.POST("/birthday/update", updateBirthday)
web.POST("/pendant/equip", pendantEquip)
web.GET("/point/flag", pointFlag)
sudo := mr.Group("/sudo", sudo)
sudo.POST("/notify-purge-cache", notityPurgeCache)
// captcha 验证码
cap := mr.Group("/captcha", authn.UserWeb)
cap.GET("/geetest", getChallenge) //获取极验图形验证
cap.POST("/geetest/check", geetestValidate) //校验极验验证码
// vip
vip := e.Group("/x/vip", bm.CSRF())
vip.GET("/code/verify", authn.User, codeVerify)
vip.POST("/code/open", authn.User, codeOpen)
vip.GET("/tips", authn.User, tips)
vip.GET("/price/panel", authn.User, vipAnti.ServeHTTP, vipPanel)
vip.GET("/coupon/list", authn.User, vipAnti.ServeHTTP, couponList)
vip.GET("/coupon/usable", authn.User, vipAnti.ServeHTTP, couponUsable)
vip.POST("/coupon/unlock", authn.User, vipAnti.ServeHTTP, couponUnlock)
vip.GET("/privilege/bysid", vipAnti.ServeHTTP, privilegeBySid)
vip.GET("/privilege/bytype", vipAnti.ServeHTTP, privilegeByType)
vip.GET("/manager", authn.User, vipAnti.ServeHTTP, vipManagerInfo)
vip.POST("/unfreeze", authn.UserWeb, vipAnti.ServeHTTP, unfrozen)
vip.GET("/frozenTime", authn.UserWeb, vipAnti.ServeHTTP, frozenTime)
vip.GET("/code/openeds", vipAnti.ServeHTTP, codeOpeneds)
vip.GET("/public/panel", authn.Guest, vipAnti.ServeHTTP, publicPriceList)
vip.POST("/batch/use", vipAnti.ServeHTTP, useBatch)
vip.GET("/order/status", authn.UserWeb, orderStatus)
vip.GET("/price/panel/v8", authn.Guest, vipAnti.ServeHTTP, vipPanelV8)
vip.GET("/prize/cards", authn.UserWeb, vipAnti.ServeHTTP, prizeCards)
vip.POST("/prize/draw", authn.UserWeb, vipAnti.ServeHTTP, prizeDraw)
vip.GET("/resource/banner", authn.UserMobile, vipAnti.ServeHTTP, resourceBanner) // 大会员落地页
vip.GET("/resource/buy", authn.UserMobile, vipAnti.ServeHTTP, resourceBuy) // 大会员购买页
vip.GET("/coupon/usable/v2", authn.Guest, vipAnti.ServeHTTP, couponBySuitIDV2)
vip.GET("/price/panel/v9", authn.Guest, vipAnti.ServeHTTP, vipPanelV9)
// associate
vip.GET("/associate/info", authn.User, bindInfoByMid)
vip.GET("/associate/panel", authn.User, actlimit, associatePanel)
vip.POST("/associate/create/order", authn.User, actlimit, createAssociateOrder)
vip.GET("/associate/ele/oauth", authn.User, actlimit, eleOAuthURL)
vip.GET("/associate/ele/redpackets", redpackets)
vip.GET("/associate/ele/specailfoods", specailfoods)
//vip welfare
vip.GET("/welfare/list", authn.Guest, welfareList)
vip.GET("/welfare/type", authn.Guest, welfareTypeList)
vip.GET("/welfare/info", authn.Guest, welfareInfo)
vip.POST("/welfare", authn.User, vipAnti.ServeHTTP, receiveWelfare)
vip.GET("/welfare/my", authn.User, myWelfare)
// vip third verify.
// ele oauth callback.
e.GET("/x/oauth2/v1/callback", authn.User, actlimit, openAuthCallBack)
// bilibili third.
oauth2 := e.Group("/x/oauth2/v1", iplimit, vipThirdVerify.Verify, bm.CSRF())
oauth2.POST("/access_token", openIDByOAuth2Code)
// bilibili third vip.
vipThird := oauth2.Group("/vip", iplimit, openlimit)
vipThird.POST("/bind", openBindByOutOpenID)
vipThird.GET("/account", userInfoByOpenID)
vipThird.POST("/delivery", bilibiliVipGrant)
vipThird.POST("/prize/grant", bilibiliPrizeGrant)
// vip app api
vip.GET("/v1/order/status", authn.UserMobile, orderStatus)
vip.GET("/v1/frozenTime", authn.UserMobile, vipAnti.ServeHTTP, frozenTime)
vip.POST("/v1/unfrozen", authn.UserMobile, vipAnti.ServeHTTP, unfrozen)
vip.GET("/v2/tips", authn.User, tipsv2)
vip.GET("/v2/price/panel", authn.Guest, vipAnti.ServeHTTP, vipPanelV2)
invite := mr.Group("/invite", authn.UserWeb)
invite.GET("/stat", inviteStat)
invite.POST("/buy", buy)
invite.POST("/apply", apply)
// medal 勋章
medal := mr.Group("/medal")
// medal.GET("/user/info", authn.User, medalHomeInfo)
medal.GET("/user/info", authn.User, medalUserInfo)
medal.POST("/install", authn.User, medalInstall)
medal.GET("/popup", authn.User, medalPopup)
medal.GET("/my/info", authn.User, medalMyInfo)
medal.GET("/all/info", authn.User, medalAllInfo)
official := mr.Group("/official", bm.CSRF(), authn.User)
official.POST("/submit", submitOffical)
official.GET("/doc", officialDoc)
official.GET("/conditions", officialConditions)
official.POST("/upload/image", uploadImage)
official.POST("/mobile/verify", smsAnti.ServeHTTP, mobileVerify)
official.GET("/permission", officialPermission)
official.GET("/auto/fill/doc", officialAutoFillDoc)
official.GET("/monthly/times", monthlyOfficialSubmittedTimes)
identifyG := mr.Group("/identify", authn.UserWeb)
identifyG.GET("/info", identifyInfo)
// realname
realnameG := mr.Group("/realname", authn.User)
realnameG.GET("/channel", realnameChannel)
realnameG.GET("/status", realnameStatus)
realnameG.GET("/apply/status", realnameApplyStatus)
realnameG.POST("/apply", realnameApply)
realnameG.POST("/upload", realnameUpload)
realnameG.GET("/preview", realnamePreview)
realnameG.GET("/countrylist", realnameCountryList)
realnameG.GET("/card/types", realnameCardTypes)
realnameG.GET("/v2/card/types", realnameCardTypesV2)
realnameG.POST("/tel/capture", realnameTelCapture)
realnameG.GET("/tel/info", realnameTelInfo)
realnameG.GET("/captcha", realnameCaptcha)
realnameG.GET("/captcha/refresh", realnameCaptchaRefresh)
realnameG.GET("/captcha/confirm", realnameCaptchaConfirm)
realnameG.POST("/alipay/apply", realnameAlipayApply)
realnameG.GET("/alipay/confirm", realnameAlipayConfirm)
// passport
passportR := mr.Group("/passport", authn.User)
passportR.GET("/testUserName", testUserName)
// member v2
memberV2 := e.Group("x/member/v2", bm.CSRF())
memberV2.GET("/notice", authn.UserMobile, noticeV2)
memberV2.POST("/notice/close", authn.UserMobile, closeNoticeV2)
// relation
relationG := e.Group("/x/relation", bm.CSRF())
relationG.GET("", authn.User, relation)
relationG.GET("/relations", authn.User, relations)
relationG.GET("/blacks", authn.User, blacks)
relationG.GET("/whispers", authn.User, whispers)
relationG.GET("/friends", authn.User, friends)
relationG.POST("/modify", authn.User, anti.ServeHTTP, modify)
relationG.POST("/batch/modify", authn.User, batchRelAnti.ServeHTTP, batchModify)
relationG.GET("/followings", authn.Guest, followings)
relationG.GET("/same/followings", authn.User, sameFollowings)
relationG.GET("/followers", authn.Guest, followers)
relationG.GET("/stat", authn.Guest, stat)
relationG.GET("/stats", authn.Guest, stats)
relationG.GET("/recommend", authn.User, recommend)
relationG.GET("/recommend/followlist_empty", authn.User, bm.Mobile(), recommendFollowlistEmpty)
relationG.GET("/recommend/answer_ok", authn.User, bm.Mobile(), recommendAnswerOK)
relationG.GET("/recommend/tag_suggest", authn.User, bm.Mobile(), recommendTagSuggest)
relationG.GET("/recommend/tag_suggest/detail", authn.User, bm.Mobile(), recommendTagSuggestDetail)
// relation tag
relationG.GET("/tag", authn.User, tag)
relationG.GET("/tags", authn.User, tags)
relationG.POST("/tag/special/add", authn.User, addSpecial)
relationG.POST("/tag/special/del", authn.User, delSpecial)
relationG.GET("/tag/special", authn.User, special)
relationG.GET("/tag/user", authn.User, tagUser)
relationG.POST("/tag/create", authn.User, tagCreate)
relationG.POST("/tag/update", authn.User, tagUpdate)
relationG.POST("/tag/del", authn.User, tagDel)
relationG.POST("/tags/addUsers", authn.User, tagsAddUsers)
relationG.POST("/tags/copyUsers", authn.User, tagsCopyUsers)
relationG.POST("/tags/moveUsers", authn.User, tagsMoveUsers)
// for mobile.
relationG.GET("/tag/m/tags", authn.User, mobileTags)
// 提示用户关注该up主
relationG.POST("/prompt", authn.User, prompt)
relationG.POST("/prompt/close", authn.User, closePrompt)
// 粉丝提醒功能
relationG.GET("/followers/unread", authn.User, unread)
relationG.POST("/followers/unread/reset", authn.User, unreadReset)
relationG.GET("/followers/unread/count", authn.User, unreadCount)
relationG.POST("/followers/unread/count/reset", authn.User, unreadCountReset)
relationG.GET("/followers/notify", authn.User, followerNotifySetting)
relationG.POST("/followers/notify/enable", authn.User, enableFollowerNotify)
relationG.POST("/followers/notify/disable", authn.User, disableFollowerNotify)
// achieve
relationG.POST("/achieve/award/get", authn.User, achieveGet)
relationG.GET("/achieve/award", authn.Guest, achieve)
// pendant group
pendant := e.Group("/x/pendant", bm.CSRF())
// pendant with web
pendant.GET("/current", authn.UserWeb, pendantCurrent)
pendant.GET("/all", authn.UserWeb, pendantAll)
pendant.GET("/my", authn.UserWeb, pendantMy)
pendant.GET("/myHistory", authn.UserWeb, pendantMyHistory)
pendant.GET("/bigEntry", authn.UserWeb, pendantEntry)
pendant.GET("/vipRecommend", authn.UserWeb, pendantVIP)
pendant.POST("/checkOrder", authn.UserWeb, pendantCheckOrder)
pendant.POST("/vipGet", authn.UserWeb, pendantVIPGet)
pendant.POST("/order", authn.UserWeb, pendantOrder)
// pendant with app
pendant.GET("/pointEntry", authn.UserMobile, pendantEntry)
// pendent with vri
pendant.GET("/single", verify.Verify, pendantSingle)
coupon := e.Group("/x/coupon", bm.CSRF(), authn.User)
coupon.GET("/allowance/list", allowanceList)
coupon.GET("/list", couponPage)
coupon.GET("/code/verify", captchaToken)
coupon.POST("/code/exchange", useCouponCode)
point := e.Group("/x/point", bm.CSRF(), authn.User)
point.GET("/info", pointInfo)
point.GET("/history", pointPage)
card := e.Group("/x/card", bm.CSRF())
card.GET("/bymid", authn.User, userCard)
card.GET("/info", cardInfo)
card.GET("/hots", cardHots)
card.GET("/groups", authn.Guest, cardGroups)
card.GET("/bytype", cardsByGid)
card.POST("/equip", authn.User, equip)
card.POST("/demount", authn.User, demount)
}
// ping check server ok.
func ping(c *bm.Context) {
var err error
if err = memberSvc.Ping(c); err != nil {
c.JSON(nil, err)
log.Error("service ping error(%v)", err)
c.Writer.WriteHeader(http.StatusServiceUnavailable)
}
}
func register(ctx *bm.Context) {
ctx.JSON(nil, nil)
}
func initService(c *conf.Config) {
relationSvc = rls.New(c)
memberSvc = member.New(c)
realnameSvc = realname.New(c, conf.RsaPub(), conf.RsaPriv(), conf.AlipayPub(), conf.AlipayBiliPriv())
passSvc = passport.New(c)
cardSvc = card.New(c)
vipSvc = vip.New(c)
usSvc = us.New(c)
geetestSvr = geetest.New(c)
// api middleware
authn = auth.New(c.AuthN)
verify = v.New(c.Verify)
anti = antispam.New(c.Antispam)
batchRelAnti = antispam.New(c.BatchRelAntispam)
smsAnti = antispam.New(c.SMSAntispam)
faceAnti = antispam.New(c.FaceAntispam)
vipAnti = antispam.New(c.VIPAntispam)
spv = supervisor.New(c.Supervisor)
couponSvc = coupon.New(c)
pointSvc = point.New(c)
}