You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
129 lines
3.7 KiB
129 lines
3.7 KiB
package http |
|
|
|
import ( |
|
"net/http" |
|
|
|
"go-common/app/job/main/growup/conf" |
|
"go-common/app/job/main/growup/service" |
|
"go-common/app/job/main/growup/service/charge" |
|
"go-common/app/job/main/growup/service/ctrl" |
|
"go-common/app/job/main/growup/service/income" |
|
"go-common/app/job/main/growup/service/tag" |
|
|
|
"go-common/library/log" |
|
bm "go-common/library/net/http/blademaster" |
|
) |
|
|
|
var ( |
|
executor *ctrl.UnboundedExecutor |
|
svr *service.Service |
|
tagSvr *tag.Service |
|
incomeSrv *income.Service |
|
chargeSrv *charge.Service |
|
) |
|
|
|
// Init init |
|
func Init(c *conf.Config) { |
|
// service |
|
executor = ctrl.NewUnboundedExecutor() |
|
svr = service.New(c, executor) |
|
tagSvr = tag.New(c, executor) |
|
incomeSrv = income.New(c, executor) |
|
chargeSrv = charge.New(c, executor) |
|
|
|
// bm |
|
engine := bm.DefaultServer(c.BM) |
|
initRouter(engine) |
|
if err := engine.Start(); err != nil { |
|
log.Error("engine.Start error(%v)", err) |
|
panic(err) |
|
} |
|
} |
|
|
|
// Close close service |
|
func Close() { |
|
svr.Close() |
|
tagSvr.Close() |
|
} |
|
|
|
func initRouter(e *bm.Engine) { |
|
e.Ping(ping) |
|
mr := e.Group("/x/internal/job/growup") |
|
tag := mr.Group("tag") |
|
{ |
|
tag.POST("/income", tagIncome) |
|
tag.POST("/archive/ratio", tagRatio) |
|
tag.POST("/ups", tagUps) |
|
tag.POST("/extra", tagExtraIncome) |
|
} |
|
mr.GET("/email/combine", combineMails) |
|
mr.GET("/email/tagincome", sendTagIncome) |
|
|
|
mr.POST("/blacklist/init/mid", initBlacklistMID) |
|
mr.POST("/blacklist/update", updateBlacklist) |
|
|
|
mr.POST("/data/update/withdraw", updateWithdraw) |
|
mr.GET("/data/up/income/statis", getUpIncomeStatis) |
|
mr.GET("/data/av/income/statis", getAvIncomeStatis) |
|
mr.GET("/cheat", updateCheat) |
|
mr.POST("/data/fix/tag", updateTagIncome) |
|
mr.POST("/data/fix/upincome", fixUpIncome) |
|
mr.POST("/data/fix/up/av/statis", fixUpAvStatis) |
|
mr.POST("/data/fix/tag/adjust", fixTagAdjust) |
|
mr.POST("/data/fix/income", fixIncome) |
|
mr.POST("/data/fix/account/type", fixAccountType) |
|
mr.POST("/data/fix/upaccount", fixUpAccount) |
|
mr.POST("/data/fix/baseincome", fixBaseIncome) |
|
mr.POST("/data/fix/av/breach", fixAvBreach) |
|
mr.POST("/data/fix/up/totalincome", fixUpTotalIncome) |
|
mr.POST("/data/fix/up/business", updateBusinessIncome) |
|
mr.POST("/data/up/sync/pgc", syncUpPGC) |
|
mr.POST("/data/up/sync/avbaseincome", syncAvBaseIncome) |
|
mr.POST("/data/column/tag", updateColumnTag) |
|
mr.POST("/data/del", delDataLimit) |
|
creative := mr.Group("/creative") |
|
{ |
|
creative.POST("/income", creativeIncome) |
|
creative.POST("/charge", creativeCharge) |
|
creative.POST("/statis", creativeStatis) |
|
creative.POST("/bill", creativeBill) |
|
creative.POST("/budget", creativeBudget) |
|
creative.POST("/activity", creativeActivity) |
|
} |
|
mr.POST("/up/info/update", updateUpInfoVideo) |
|
mr.POST("/credit/sync", syncCreditScore) |
|
mr.POST("/bgm/sync", syncBGM) |
|
mr.POST("/bgm/statis", calBgmStatis) |
|
mr.POST("/bgm/base", calBgmBaseIncome) |
|
mr.POST("/sync/account", syncUpAccount) |
|
auto := mr.Group("/auto") |
|
{ |
|
auto.POST("/archive/breach", autoBreach) |
|
auto.POST("/up/punish", autoPunish) |
|
auto.POST("/up/examination", autoExamination) |
|
} |
|
|
|
taskStatus := mr.Group("/task") |
|
{ |
|
taskStatus.POST("/status", updateTaskStatus) |
|
taskStatus.POST("/column", checkTaskColumn) |
|
} |
|
|
|
incomeAdjust := mr.Group("/income_bubble") |
|
{ |
|
incomeAdjust.POST("/meta/sync", syncBubbleMeta) |
|
incomeAdjust.POST("/task/meta", syncBubbleMetaTask) |
|
incomeAdjust.POST("/task/snapshot", snapshotBubbleTask) |
|
} |
|
// delete |
|
mr.GET("/avratio", execAvRatio) |
|
mr.GET("/income", execIncome) |
|
} |
|
|
|
// ping check server ok. |
|
func ping(c *bm.Context) { |
|
if err := svr.Ping(c); err != nil { |
|
log.Error("service ping error(%v)", err) |
|
c.AbortWithStatus(http.StatusServiceUnavailable) |
|
} |
|
}
|
|
|