增加fohow首页 first接口

go/gopath/src/fohow-statement-api/controllers/fohow_home_page_stat_controller/left_top_data_of_home_page.go

@@ -0,0 +1,40 @@
+package fohow_home_page_stat_controller
+
+import (
+	"fohow-statement-api/models"
+	"github.com/astaxie/beego"
+)
+
+type FohowLeftTopDataOfHomePageController struct {
+	beego.Controller
+}
+
+// @Title Get
+// @Description 首页左上角的数据集合。
+// @Param	Authorization	header 	string	true	"格式: Token XXXXXX"
+// @Success 200 {object} int64
+// @router / [get]
+func (self *FohowLeftTopDataOfHomePageController) Get() {
+	//platform_type := self.GetString("platform_type")
+	//
+	//if strings.TrimSpace(platform_type) == "" {
+	//	platform_type = models.PLATFORM_TYPE_FANS_FOHOW
+	//}
+	type Ret struct {
+		TotalFans   int64 `json:"platform_total_fans"`
+		TotalRank1s int64 `json:"total_load1"`  //总店长
+		TotalRank2s int64 `json:"total_load2"`  //总群主
+		TotalInvest int64 `json:"total_invest"` //充值总额
+		TotalOrder  int64 `json:"total_order"`  //订单总额
+	}
+
+	//totalFans := models.GetFansTotalCountByType(platform_type)
+	totalFans := models.GetFohowFansTotalCountByWxUserTable(true)
+	total := models.GetRank1UsersTotalCount()
+	totalRank2 := models.GetRank2UsersTotalCount()
+	totalInvest := models.GetFohowAllRechargeTotal() / int64(100)
+	totalProject := models.GetFohowTotalOrderCount() / int64(100)
+	self.Data["json"] = &Ret{TotalFans: totalFans, TotalRank1s: total, TotalRank2s: totalRank2, TotalInvest: totalInvest, TotalOrder: totalProject}
+
+	self.ServeJSON()
+}

go/gopath/src/fohow-statement-api/main.go

@@ -22,6 +22,7 @@ func main() {
 	orm.RegisterDataBase("data_source", "mysql", beego.AppConfig.String("MysqlDataSource"))
 	orm.RegisterDataBase("rabbit_data_source", "mysql", beego.AppConfig.String("MysqlRabbitDataSource"))
 	orm.RegisterDataBase("cow_data_source", "mysql", beego.AppConfig.String("MysqlCowDataSource"))
+	orm.RegisterDataBase("fohow_data_source", "mysql", beego.AppConfig.String("MysqlFohowDataSource"))
 
 	orm.SetMaxIdleConns("default", 10)
 	orm.SetMaxOpenConns("default", 20)
@@ -31,6 +32,8 @@ func main() {
 	orm.SetMaxOpenConns("rabbit_data_source", 50)
 	orm.SetMaxIdleConns("cow_data_source", 25)
 	orm.SetMaxOpenConns("cow_data_source", 50)
+	orm.SetMaxIdleConns("fohow_data_source", 25)
+	orm.SetMaxOpenConns("fohow_data_source", 50)
 	// 跨域filter要放在最前面
 	beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
 		AllowAllOrigins: true,

go/gopath/src/fohow-statement-api/models/d5c_bonus.go

@@ -14,6 +14,29 @@ const (
 	projects_table = "d5c_projects"
 )
 
+//fohow 订单总金额
+func GetFohowTotalOrderCount() int64 {
+
+	o := orm.NewOrm()
+	o.Using("fohow_data_source")
+
+	type Ret struct {
+		Total int64 `json:"total"`
+	}
+
+	var ret Ret
+
+	sql := fmt.Sprintf("select sum(total_price) as total from orders where  state not in ('processing','complete','dispatch')")
+
+	err := o.Raw(sql).QueryRow(&ret)
+
+	if err != nil {
+		beego.BeeLogger.Warn("models.GetFohowTotalOrderCount err[%s]", err)
+		return 0
+	}
+	return ret.Total
+}
+
 //项目总额：(类型：股权、收益权)(状态：除了审核中和准备中)项目的投资总额
 func GetD5cTotalProjectInvestment() int64 {
 
@@ -38,6 +61,36 @@ func GetD5cTotalProjectInvestment() int64 {
 
 }
 
+//获取fohow充值总金额
+func GetFohowAllRechargeTotal() int64 {
+	o := orm.NewOrm()
+	o.Using("fohow_data_source")
+
+	type Ret struct {
+		Total int64 `json:"total"`
+	}
+
+	var ret Ret
+
+	sql := `
+		SELECT
+			sum(paied_price) AS total
+		FROM
+			balance_orders
+		Where
+			status=true
+			;
+	`
+
+	err := o.Raw(sql).QueryRow(&ret)
+
+	if err != nil {
+		beego.BeeLogger.Warn("models.GetFohowAllRechargeTotal err[%s]", err)
+		return 0
+	}
+	return ret.Total
+}
+
 //众筹总额：(类型：股权、收益权)(状态：除了审核中和准备中)项目，所有有效投资记录的总金额
 func GetD5cTotalProjectJoinInvestment() int64 {
 	o := orm.NewOrm()

go/gopath/src/fohow-statement-api/models/d5c_user.go

@@ -8,7 +8,8 @@ import (
 )
 
 const (
-	users_table = "d5c_users"
+	users_table         = "d5c_users"
+	fohow_wx_user_table = "wx_users"
 )
 
 type MonthItem struct {

go/gopath/src/fohow-statement-api/routers/router.go

@@ -32,6 +32,7 @@ import (
 	"fohow-statement-api/controllers/d5c_train_controller"
 	"fohow-statement-api/controllers/d5c_user_controller"
 	"fohow-statement-api/controllers/d5c_zt_invest_controller"
+	"fohow-statement-api/controllers/fohow_home_page_stat_controller"
 	"fohow-statement-api/controllers/rabbit_balance_consume_controller"
 	"fohow-statement-api/controllers/rabbit_exchange_platform_controller"
 	"fohow-statement-api/controllers/rabbit_merchant_controller"
@@ -428,6 +429,13 @@ func init() {
 				&cow_punch.CowPunchController{},
 			),
 		),
+
+		//----------- fohow相关 -----------
+		beego.NSNamespace("/home_left_top_data",
+			beego.NSInclude(
+				&fohow_home_page_stat_controller.FohowLeftTopDataOfHomePageController{},
+			),
+		),
 	)
 	beego.AddNamespace(ns)
 }