Merge branch 'master' of https://code.fnuoos.com/zhimeng/ad_platform

app/hdl/hdl_finance_index.go

@@ -0,0 +1,73 @@
+package hdl
+
+import (
+	"applet/app/e"
+	"applet/app/lib/validate"
+	"applet/app/md"
+	"applet/app/svc"
+	"github.com/gin-gonic/gin"
+)
+
+// FinanceIndexTotal
+// @Summary    	 统计数据
+// @Tags         首页------嘉俊
+// @Description  首页-统计数据
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Success      200   {string}	      "具体看返回内容 这是data里面的数据"
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/total [GET]
+func FinanceIndexTotal(c *gin.Context) {
+	svc.FinanceIndexTotal(c)
+}
+
+// FinanceIndexAppList
+// @Summary    	 应用数据
+// @Tags         首页------嘉俊
+// @Description  首页-应用数据
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Param        args 	body      md.IndexAppListReq   true   "请求参数"
+// @Success      200   {object}	  md.IndexAppListRes     "具体看返回内容 这是data里面的数据"
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/app/list [POST]
+func FinanceIndexAppList(c *gin.Context) {
+	var req md.IndexAppListReq
+	err := c.ShouldBindJSON(&req)
+	if err != nil {
+		err = validate.HandleValidateErr(err)
+		err1 := err.(e.E)
+		e.OutErr(c, err1.Code, err1.Error())
+		return
+	}
+	res := svc.FinanceIndexAppList(c, req)
+	e.OutSuc(c, res, nil)
+	return
+}
+
+// FinanceIndexAppListTable
+// @Summary    	 应用数据-每个应用的折线图
+// @Tags         首页------嘉俊
+// @Description  首页-应用数据-每个应用的折线图
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Param        args 	body      md.IndexAppListTableReq   true   "请求参数"
+// @Success      200   {string}	      "具体看返回内容 "
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/app/list/table [POST]
+func FinanceIndexAppListTable(c *gin.Context) {
+	var req md.IndexAppListTableReq
+	err := c.ShouldBindJSON(&req)
+	if err != nil {
+		err = validate.HandleValidateErr(err)
+		err1 := err.(e.E)
+		e.OutErr(c, err1.Code, err1.Error())
+		return
+	}
+	res := svc.FinanceBeforeSevenPoint(c, req)
+	e.OutSuc(c, res, nil)
+	return
+}

app/hdl/hdl_operator_index.go

@@ -0,0 +1,73 @@
+package hdl
+
+import (
+	"applet/app/e"
+	"applet/app/lib/validate"
+	"applet/app/md"
+	"applet/app/svc"
+	"github.com/gin-gonic/gin"
+)
+
+// OperatorIndexTotal
+// @Summary    	 统计数据
+// @Tags         首页------嘉俊
+// @Description  首页-统计数据
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Success      200   {string}	      "具体看返回内容 这是data里面的数据"
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/total [GET]
+func OperatorIndexTotal(c *gin.Context) {
+	svc.OperatorIndexTotal(c)
+}
+
+// OperatorIndexAppList
+// @Summary    	 应用数据
+// @Tags         首页------嘉俊
+// @Description  首页-应用数据
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Param        args 	body      md.IndexAppListReq   true   "请求参数"
+// @Success      200   {object}	  md.IndexAppListRes     "具体看返回内容 这是data里面的数据"
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/app/list [POST]
+func OperatorIndexAppList(c *gin.Context) {
+	var req md.IndexAppListReq
+	err := c.ShouldBindJSON(&req)
+	if err != nil {
+		err = validate.HandleValidateErr(err)
+		err1 := err.(e.E)
+		e.OutErr(c, err1.Code, err1.Error())
+		return
+	}
+	res := svc.OperatorIndexAppList(c, req)
+	e.OutSuc(c, res, nil)
+	return
+}
+
+// OperatorIndexAppListTable
+// @Summary    	 应用数据-每个应用的折线图
+// @Tags         首页------嘉俊
+// @Description  首页-应用数据-每个应用的折线图
+// @param Authorization header string true "验证参数Bearer和token空格拼接"
+// @Accept       json
+// @Produce      json
+// @Param        args 	body      md.IndexAppListTableReq   true   "请求参数"
+// @Success      200   {string}	      "具体看返回内容 "
+// @Failure      400   {object}   md.Response              "具体错误"
+// @Router       /api/index/app/list/table [POST]
+func OperatorIndexAppListTable(c *gin.Context) {
+	var req md.IndexAppListTableReq
+	err := c.ShouldBindJSON(&req)
+	if err != nil {
+		err = validate.HandleValidateErr(err)
+		err1 := err.(e.E)
+		e.OutErr(c, err1.Code, err1.Error())
+		return
+	}
+	res := svc.OperatorBeforeSevenPoint(c, req)
+	e.OutSuc(c, res, nil)
+	return
+}

app/router/router.go

@@ -81,7 +81,9 @@ func route(r *gin.RouterGroup) {
 	rDataCenter(r.Group("/dataCenter"))                   // 数据中心
 	rSettleCenter(r.Group("/settleCenter"))               // 结算中心
 	rFinanceCenter(r.Group("/financeCenter"))             // 财务中心
-	rIndex(r.Group("/index"))                             // 首页
+	rIndex(r.Group("/index"))                             // 默认首页 超管看
+	rOperatorIndex(r.Group("/operatorIndex"))             // 运营首页
+	rFinanceIndex(r.Group("/financeIndex"))               // 财务首页
 	rFinancialDynamics(r.Group("/financialDynamics"))     // 资产动态
 }
 
@@ -95,7 +97,16 @@ func rIndex(r *gin.RouterGroup) {
 	r.POST("/app/list", hdl.IndexAppList)            // 首页-应用数据
 	r.POST("/app/list/table", hdl.IndexAppListTable) // 首页-应用数据-每个应用的折线图
 }
-
+func rOperatorIndex(r *gin.RouterGroup) {
+	r.GET("/total", hdl.OperatorIndexTotal)                  // 首页-统计数据
+	r.POST("/app/list", hdl.OperatorIndexAppList)            // 首页-应用数据
+	r.POST("/app/list/table", hdl.OperatorIndexAppListTable) // 首页-应用数据-每个应用的折线图
+}
+func rFinanceIndex(r *gin.RouterGroup) {
+	r.GET("/total", hdl.FinanceIndexTotal)                  // 首页-统计数据
+	r.POST("/app/list", hdl.FinanceIndexAppList)            // 首页-应用数据
+	r.POST("/app/list/table", hdl.FinanceIndexAppListTable) // 首页-应用数据-每个应用的折线图
+}
 func rRole(r *gin.RouterGroup) {
 	r.GET("/roleList", hdl.RoleList)                                // 角色列表
 	r.POST("/addRole", hdl.AddRole)                                 // 角色添加

app/svc/svc_finance_index.go

@@ -0,0 +1,278 @@
+package svc
+
+import (
+	"applet/app/e"
+	"applet/app/md"
+	"applet/app/utils"
+	db "code.fnuoos.com/zhimeng/model.git/src"
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"strings"
+	"time"
+)
+
+func FinanceIndexTotal(c *gin.Context) {
+	//昨天
+	yesterday := utils.GetTimeRange("yesterday")
+	yesterdayTotal := commFinanceTotal(c, time.Unix(yesterday["start"], 0).Format("2006-01-02"), time.Unix(yesterday["end"]-3600, 0).Format("2006-01-02"))
+	yesterdayTotalAgent := commFinanceTotalAgent(c, time.Unix(yesterday["start"], 0).Format("2006-01-02"), time.Unix(yesterday["end"]-3600, 0).Format("2006-01-02"))
+
+	//前天
+	beforeYesterDayTotal := commFinanceTotal(c, time.Unix(yesterday["start"]-86400, 0).Format("2006-01-02"), time.Unix(yesterday["start"]-3600, 0).Format("2006-01-02"))
+	beforeYesterDayTotalAgent := commFinanceTotalAgent(c, time.Unix(yesterday["start"]-86400, 0).Format("2006-01-02"), time.Unix(yesterday["start"]-3600, 0).Format("2006-01-02"))
+
+	//7天
+	withinSevenDays := utils.GetTimeRange("new_within_seven_days")
+	withinSevenDaysTotal := commFinanceTotal(c, time.Unix(withinSevenDays["start"], 0).Format("2006-01-02"), time.Unix(withinSevenDays["end"]-3600, 0).Format("2006-01-02"))
+	withinSevenDaysTotalAgent := commFinanceTotalAgent(c, time.Unix(withinSevenDays["start"], 0).Format("2006-01-02"), time.Unix(withinSevenDays["end"]-3600, 0).Format("2006-01-02"))
+
+	//7天前的 7天
+	beforeWithinSevenDaysTotal := commFinanceTotal(c, time.Unix(withinSevenDays["start"]-3600-7*86400, 0).Format("2006-01-02"), time.Unix(withinSevenDays["start"]-3600, 0).Format("2006-01-02"))
+	beforeWithinSevenDaysTotalAgent := commFinanceTotalAgent(c, time.Unix(withinSevenDays["start"]-3600-7*86400, 0).Format("2006-01-02"), time.Unix(withinSevenDays["start"]-3600, 0).Format("2006-01-02"))
+
+	//本月
+	currentMonth := utils.GetTimeRange("current_month")
+	currentMonthTotal := commFinanceTotal(c, time.Unix(currentMonth["start"], 0).Format("2006-01-02"), time.Unix(currentMonth["end"]-3600, 0).Format("2006-01-02"))
+	currentMonthTotalAgent := commFinanceTotalAgent(c, time.Unix(currentMonth["start"], 0).Format("2006-01-02"), time.Unix(currentMonth["end"]-3600, 0).Format("2006-01-02"))
+
+	//上月
+	lastMonth := utils.GetTimeRange("last_month")
+	lastMonthTotal := commFinanceTotal(c, time.Unix(lastMonth["start"], 0).Format("2006-01-02"), time.Unix(lastMonth["end"]-3600, 0).Format("2006-01-02"))
+	lastMonthTotalAgent := commFinanceTotalAgent(c, time.Unix(lastMonth["start"], 0).Format("2006-01-02"), time.Unix(lastMonth["end"]-3600, 0).Format("2006-01-02"))
+
+	//上上月
+	beforeLastMonth := time.Unix(lastMonth["start"]-86400, 0)
+	beforeLastMonthStr := time.Date(beforeLastMonth.Year(), beforeLastMonth.Month(), 1, 0, 0, 0, 0, beforeLastMonth.Location())
+	beforeLastMonthTotal := commFinanceTotal(c, beforeLastMonthStr.Format("2006-01-02"), time.Unix(lastMonth["start"]-3600, 0).Format("2006-01-02"))
+	beforeLastMonthTotalAgent := commFinanceTotalAgent(c, beforeLastMonthStr.Format("2006-01-02"), time.Unix(lastMonth["start"]-3600, 0).Format("2006-01-02"))
+
+	res := []md.IndexAppListDataList{
+		{Name: "昨日收益(媒体)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(yesterdayTotal[0]["media_revenue"]) / 100)},
+		{Name: "七日收益(媒体)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotal[0]["media_revenue"]) / 100)},
+		{Name: "本月收益(媒体)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotal[0]["media_revenue"]) / 100)},
+		{Name: "上月收益(媒体)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotal[0]["media_revenue"]) / 100)},
+		{Name: "昨日收益(渠道)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotalAgent, yesterdayTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(yesterdayTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "七日收益(渠道)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotalAgent, withinSevenDaysTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "本月收益(渠道)", Type: "current_month", Bili: commBili(c, lastMonthTotalAgent, currentMonthTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "上月收益(渠道)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotalAgent, lastMonthTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "昨日收益(平台收益)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "platform_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(yesterdayTotal[0]["platform_revenue"]) / 100)},
+		{Name: "七日收益(平台收益)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "platform_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotal[0]["platform_revenue"]) / 100)},
+		{Name: "本月收益(平台收益)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "platform_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotal[0]["platform_revenue"]) / 100)},
+		{Name: "上月收益(平台收益)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "platform_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotal[0]["platform_revenue"]) / 100)},
+	}
+	e.OutSuc(c, res, nil)
+	return
+}
+func commFinanceTotalAgent(c *gin.Context, startDate, endDate string) []map[string]string {
+	sql := `
+		SELECT 
+			SUM(agent_revenue+extra_revenue) as media_revenue
+		FROM generate_wx_ad_data_with_agent_flow
+		where %s 
+`
+	where := "uuid=" + c.GetString("mid")
+	if startDate != "" {
+		where += " and date>='" + startDate + "'"
+	}
+	if endDate != "" {
+		where += " and date<='" + endDate + "'"
+	}
+	sql = fmt.Sprintf(sql, where)
+	nativeString, _ := db.QueryNativeString(db.Db, sql)
+	if len(nativeString) == 0 {
+		nativeString = []map[string]string{
+			{
+				"media_revenue": "0",
+			},
+		}
+	}
+	return nativeString
+}
+
+func FinanceBeforeSevenPoint(c *gin.Context, req md.IndexAppListTableReq) map[string][]string {
+
+	start := utils.TimeStdParseUnix(req.StartDate + " 00:00:00")
+	day := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00")-start)/86400 + 1
+	first := start - day*86400*6
+	dayAll := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00")-first)/86400 + 1
+
+	firstTime := time.Unix(first, 0).Format("2006-01-02")
+	appData := make(map[string][]string)
+	for _, v := range req.AppId {
+		appData[v] = make([]string, dayAll/day+1, dayAll/day+1)
+	}
+	dateList := make(map[int]string)
+	j := 1
+	for i := 0; i < int(dayAll); i++ {
+		if i >= (j-1)*int(day) && i < j*int(day) {
+			dateList[j-1] += "," + time.Unix(first+int64(i)*86400, 0).Format("2006-01-02")
+			continue
+		}
+		j++
+		dateList[j-1] += "," + time.Unix(first+int64(i)*86400, 0).Format("2006-01-02")
+	}
+	if len(req.AppId) > 0 {
+		date := commFinanceTotalByDate(c, firstTime, req.EndDate, req.AppId)
+		for _, v := range date {
+			for k1, v1 := range dateList {
+				if strings.Contains(v1, v["date"]) {
+					appData[v["app_id"]][k1] = utils.Float64ToStr(utils.StrToFloat64(appData[v["app_id"]][k1]) + utils.StrToFloat64(v["media_revenue"]))
+				}
+			}
+		}
+	}
+	for k, v := range appData {
+		for k1, v1 := range v {
+			if v1 == "" {
+				appData[k][k1] = "0"
+			}
+		}
+	}
+	return appData
+}
+
+func FinanceIndexAppList(c *gin.Context, req md.IndexAppListReq) md.IndexAppListRes {
+	appId := make([]string, 0)
+	data := commFinanceTotalByApp(c, req, appId)
+	for _, v := range data {
+		appId = append(appId, v["app_id"])
+	}
+	start := utils.TimeStdParseUnix(req.StartDate + " 00:00:00")
+	day := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00") - start) / 86400
+	req.EndDate = time.Unix(start-1, 0).Format("2006-01-02")
+	req.StartDate = time.Unix(start-1-day*86400, 0).Format("2006-01-02")
+	dataLast := commFinanceTotalByApp(c, req, appId)
+	dataLastMap := make(map[string][]map[string]string)
+	for _, v := range dataLast {
+		dataLastMap[v["app_id"]] = make([]map[string]string, 0)
+		dataLastMap[v["app_id"]] = append(dataLastMap[v["app_id"]], v)
+	}
+	list := make([]md.IndexAppListData, 0)
+	for _, v := range data {
+		_, ok := dataLastMap[v["app_id"]]
+		if ok == false {
+			dataLastMap[v["app_id"]] = []map[string]string{
+				{"media_revenue": "0", "ecpm": "0", "exposure_count": "0", "click_count": "0", "click_rate": "0"},
+			}
+		}
+		tmpList := []map[string]string{
+			v,
+		}
+		dataList := []md.IndexAppListDataList{
+			{Name: "广告预估收益", Type: "media_revenue", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(v["media_revenue"]) / 100)},
+			{Name: "ECPM", Type: "ecpm", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "ecpm"), Value: utils.Float64ToStr(utils.StrToFloat64(v["ecpm"]) / float64(day))},
+			{Name: "曝光量", Type: "exposure_count", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "exposure_count"), Value: v["exposure_count"]},
+			{Name: "点击量", Type: "click_count", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "click_count"), Value: v["click_count"]},
+			{Name: "点击率", Type: "click_rate", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "click_rate"), Value: utils.GetPrec(v["click_rate"], "2") + "%"},
+		}
+		applet := GetAppletInfo(c, v["app_id"])
+		tmp := md.IndexAppListData{
+			Name:      applet["name"],
+			Logo:      applet["logo"],
+			List:      dataList,
+			TableList: []string{},
+		}
+		list = append(list, tmp)
+	}
+	res := md.IndexAppListRes{
+		List:  list,
+		AppId: appId,
+		Sort: []md.SelectData{
+			{Name: "按收益最高", Value: "media_revenue desc"},
+			{Name: "按ECPM最高", Value: "ecpm desc"},
+			{Name: "按曝光量最高", Value: "exposure_count desc"},
+		},
+	}
+	return res
+}
+func commFinanceTotal(c *gin.Context, startDate, endDate string) []map[string]string {
+	sql := `
+		SELECT 
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_rate) as click_rate,
+			SUM(platform_retention+commission_retention+price_adjustment_retention) as platform_revenue,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s 
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if startDate != "" {
+		where += " and date>='" + startDate + "'"
+	}
+	if endDate != "" {
+		where += " and date<='" + endDate + "'"
+	}
+	sql = fmt.Sprintf(sql, where)
+	nativeString, _ := db.QueryNativeString(db.Db, sql)
+	if len(nativeString) == 0 {
+		nativeString = []map[string]string{
+			{
+				"media_revenue": "0",
+			},
+		}
+	}
+	return nativeString
+}
+func commFinanceTotalByApp(c *gin.Context, req md.IndexAppListReq, appId []string) []map[string]string {
+	sql := `
+		SELECT 
+			app_id as app_id,
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_count)/SUM(exposure_count)*100 as click_rate,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s group by app_id order by %s,id asc limit 50
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if req.StartDate != "" {
+		where += " and date>='" + req.StartDate + "'"
+	}
+	if req.EndDate != "" {
+		where += " and date<='" + req.EndDate + "'"
+	}
+	if req.Name != "" {
+		mediumId := GetMediumId(c, req.Name)
+		where += " and medium_id in(" + mediumId + ")"
+	}
+	if len(appId) > 0 {
+		where += " and app_id in(‘" + strings.Join(appId, ",") + "’)"
+	}
+	if req.Sort == "" {
+		req.Sort = "media_revenue desc"
+	}
+	sql = fmt.Sprintf(sql, where, req.Sort)
+	nativeString, _ := db.QueryNativeString(db.Db, sql)
+	return nativeString
+}
+func commFinanceTotalByDate(c *gin.Context, startDate, endDate string, appId []string) []map[string]string {
+	sql := `
+		SELECT 
+			app_id as app_id,
+			date as date,
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_count)/SUM(exposure_count)*100 as click_rate,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s group by date,app_id
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if startDate != "" {
+		where += " and date>='" + startDate + "'"
+	}
+	if endDate != "" {
+		where += " and date<='" + endDate + "'"
+	}
+	if len(appId) > 0 {
+		where += " and app_id in('" + strings.Join(appId, ",") + "')"
+	}
+	sql = fmt.Sprintf(sql, where)
+	nativeString, err := db.QueryNativeString(db.Db, sql)
+	fmt.Println(err)
+	return nativeString
+}

app/svc/svc_index.go

@@ -51,14 +51,14 @@ func IndexTotal(c *gin.Context) {
 		{Name: "七日收益(媒体)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotal[0]["media_revenue"]) / 100)},
 		{Name: "本月收益(媒体)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotal[0]["media_revenue"]) / 100)},
 		{Name: "上月收益(媒体)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotal[0]["media_revenue"]) / 100)},
-		{Name: "昨日收益(曝光量)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "exposure_count"), Value: yesterdayTotal[0]["exposure_count"]},
-		{Name: "七日收益(曝光量)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "exposure_count"), Value: withinSevenDaysTotal[0]["exposure_count"]},
-		{Name: "本月收益(曝光量)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "exposure_count"), Value: currentMonthTotal[0]["exposure_count"]},
-		{Name: "上月收益(曝光量)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "exposure_count"), Value: lastMonthTotal[0]["exposure_count"]},
-		{Name: "昨日收益(渠道)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotalAgent, yesterdayTotalAgent, "media_revenue"), Value: yesterdayTotalAgent[0]["media_revenue"]},
-		{Name: "七日收益(渠道)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotalAgent, withinSevenDaysTotalAgent, "media_revenue"), Value: withinSevenDaysTotalAgent[0]["media_revenue"]},
-		{Name: "本月收益(渠道)", Type: "current_month", Bili: commBili(c, lastMonthTotalAgent, currentMonthTotalAgent, "media_revenue"), Value: currentMonthTotalAgent[0]["media_revenue"]},
-		{Name: "上月收益(渠道)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotalAgent, lastMonthTotalAgent, "media_revenue"), Value: lastMonthTotalAgent[0]["media_revenue"]},
+		{Name: "昨日曝光量(媒体)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "exposure_count"), Value: yesterdayTotal[0]["exposure_count"]},
+		{Name: "七日曝光量(媒体)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "exposure_count"), Value: withinSevenDaysTotal[0]["exposure_count"]},
+		{Name: "本月曝光量(媒体)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "exposure_count"), Value: currentMonthTotal[0]["exposure_count"]},
+		{Name: "上月曝光量(媒体)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "exposure_count"), Value: lastMonthTotal[0]["exposure_count"]},
+		{Name: "昨日收益(渠道)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotalAgent, yesterdayTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(yesterdayTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "七日收益(渠道)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotalAgent, withinSevenDaysTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "本月收益(渠道)", Type: "current_month", Bili: commBili(c, lastMonthTotalAgent, currentMonthTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotalAgent[0]["media_revenue"]) / 100)},
+		{Name: "上月收益(渠道)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotalAgent, lastMonthTotalAgent, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotalAgent[0]["media_revenue"]) / 100)},
 	}
 	e.OutSuc(c, res, nil)
 	return

app/svc/svc_operator_index.go

@@ -0,0 +1,240 @@
+package svc
+
+import (
+	"applet/app/e"
+	"applet/app/md"
+	"applet/app/utils"
+	db "code.fnuoos.com/zhimeng/model.git/src"
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"strings"
+	"time"
+)
+
+func OperatorIndexTotal(c *gin.Context) {
+	//昨天
+	yesterday := utils.GetTimeRange("yesterday")
+	yesterdayTotal := commOperatorTotal(c, time.Unix(yesterday["start"], 0).Format("2006-01-02"), time.Unix(yesterday["end"]-3600, 0).Format("2006-01-02"))
+
+	//前天
+	beforeYesterDayTotal := commOperatorTotal(c, time.Unix(yesterday["start"]-86400, 0).Format("2006-01-02"), time.Unix(yesterday["start"]-3600, 0).Format("2006-01-02"))
+
+	//7天
+	withinSevenDays := utils.GetTimeRange("new_within_seven_days")
+	withinSevenDaysTotal := commOperatorTotal(c, time.Unix(withinSevenDays["start"], 0).Format("2006-01-02"), time.Unix(withinSevenDays["end"]-3600, 0).Format("2006-01-02"))
+
+	//7天前的 7天
+	beforeWithinSevenDaysTotal := commOperatorTotal(c, time.Unix(withinSevenDays["start"]-3600-7*86400, 0).Format("2006-01-02"), time.Unix(withinSevenDays["start"]-3600, 0).Format("2006-01-02"))
+
+	//本月
+	currentMonth := utils.GetTimeRange("current_month")
+	currentMonthTotal := commOperatorTotal(c, time.Unix(currentMonth["start"], 0).Format("2006-01-02"), time.Unix(currentMonth["end"]-3600, 0).Format("2006-01-02"))
+
+	//上月
+	lastMonth := utils.GetTimeRange("last_month")
+	lastMonthTotal := commOperatorTotal(c, time.Unix(lastMonth["start"], 0).Format("2006-01-02"), time.Unix(lastMonth["end"]-3600, 0).Format("2006-01-02"))
+
+	//上上月
+	beforeLastMonth := time.Unix(lastMonth["start"]-86400, 0)
+	beforeLastMonthStr := time.Date(beforeLastMonth.Year(), beforeLastMonth.Month(), 1, 0, 0, 0, 0, beforeLastMonth.Location())
+	beforeLastMonthTotal := commOperatorTotal(c, beforeLastMonthStr.Format("2006-01-02"), time.Unix(lastMonth["start"]-3600, 0).Format("2006-01-02"))
+
+	res := []md.IndexAppListDataList{
+		{Name: "昨日收益(媒体)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(yesterdayTotal[0]["media_revenue"]) / 100)},
+		{Name: "七日收益(媒体)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(withinSevenDaysTotal[0]["media_revenue"]) / 100)},
+		{Name: "本月收益(媒体)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(currentMonthTotal[0]["media_revenue"]) / 100)},
+		{Name: "上月收益(媒体)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(lastMonthTotal[0]["media_revenue"]) / 100)},
+		{Name: "昨日曝光量(媒体)", Type: "yesterday", Bili: commBili(c, beforeYesterDayTotal, yesterdayTotal, "exposure_count"), Value: yesterdayTotal[0]["exposure_count"]},
+		{Name: "七日曝光量(媒体)", Type: "within_seven_days", Bili: commBili(c, beforeWithinSevenDaysTotal, withinSevenDaysTotal, "exposure_count"), Value: withinSevenDaysTotal[0]["exposure_count"]},
+		{Name: "本月曝光量(媒体)", Type: "current_month", Bili: commBili(c, lastMonthTotal, currentMonthTotal, "exposure_count"), Value: currentMonthTotal[0]["exposure_count"]},
+		{Name: "上月曝光量(媒体)", Type: "last_month", Bili: commBili(c, beforeLastMonthTotal, lastMonthTotal, "exposure_count"), Value: lastMonthTotal[0]["exposure_count"]},
+	}
+	e.OutSuc(c, res, nil)
+	return
+}
+
+func OperatorBeforeSevenPoint(c *gin.Context, req md.IndexAppListTableReq) map[string][]string {
+	start := utils.TimeStdParseUnix(req.StartDate + " 00:00:00")
+	day := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00")-start)/86400 + 1
+	first := start - day*86400*6
+	dayAll := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00")-first)/86400 + 1
+
+	firstTime := time.Unix(first, 0).Format("2006-01-02")
+	appData := make(map[string][]string)
+	for _, v := range req.AppId {
+		appData[v] = make([]string, dayAll/day+1, dayAll/day+1)
+	}
+	dateList := make(map[int]string)
+	j := 1
+	for i := 0; i < int(dayAll); i++ {
+		if i >= (j-1)*int(day) && i < j*int(day) {
+			dateList[j-1] += "," + time.Unix(first+int64(i)*86400, 0).Format("2006-01-02")
+			continue
+		}
+		j++
+		dateList[j-1] += "," + time.Unix(first+int64(i)*86400, 0).Format("2006-01-02")
+	}
+	if len(req.AppId) > 0 {
+		date := commOperatorTotalByDate(c, firstTime, req.EndDate, req.AppId)
+		for _, v := range date {
+			for k1, v1 := range dateList {
+				if strings.Contains(v1, v["date"]) {
+					appData[v["app_id"]][k1] = utils.Float64ToStr(utils.StrToFloat64(appData[v["app_id"]][k1]) + utils.StrToFloat64(v["media_revenue"]))
+				}
+			}
+		}
+	}
+	for k, v := range appData {
+		for k1, v1 := range v {
+			if v1 == "" {
+				appData[k][k1] = "0"
+			}
+		}
+	}
+	return appData
+}
+
+func OperatorIndexAppList(c *gin.Context, req md.IndexAppListReq) md.IndexAppListRes {
+	appId := make([]string, 0)
+	data := commOperatorTotalByApp(c, req, appId)
+	for _, v := range data {
+		appId = append(appId, v["app_id"])
+	}
+	start := utils.TimeStdParseUnix(req.StartDate + " 00:00:00")
+	day := (utils.TimeStdParseUnix(req.EndDate+" 00:00:00") - start) / 86400
+	req.EndDate = time.Unix(start-1, 0).Format("2006-01-02")
+	req.StartDate = time.Unix(start-1-day*86400, 0).Format("2006-01-02")
+	dataLast := commOperatorTotalByApp(c, req, appId)
+	dataLastMap := make(map[string][]map[string]string)
+	for _, v := range dataLast {
+		dataLastMap[v["app_id"]] = make([]map[string]string, 0)
+		dataLastMap[v["app_id"]] = append(dataLastMap[v["app_id"]], v)
+	}
+	list := make([]md.IndexAppListData, 0)
+	for _, v := range data {
+		_, ok := dataLastMap[v["app_id"]]
+		if ok == false {
+			dataLastMap[v["app_id"]] = []map[string]string{
+				{"media_revenue": "0", "ecpm": "0", "exposure_count": "0", "click_count": "0", "click_rate": "0"},
+			}
+		}
+		tmpList := []map[string]string{
+			v,
+		}
+		dataList := []md.IndexAppListDataList{
+			{Name: "广告预估收益", Type: "media_revenue", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "media_revenue"), Value: utils.Float64ToStr(utils.StrToFloat64(v["media_revenue"]) / 100)},
+			{Name: "ECPM", Type: "ecpm", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "ecpm"), Value: utils.Float64ToStr(utils.StrToFloat64(v["ecpm"]) / float64(day))},
+			{Name: "曝光量", Type: "exposure_count", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "exposure_count"), Value: v["exposure_count"]},
+			{Name: "点击量", Type: "click_count", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "click_count"), Value: v["click_count"]},
+			{Name: "点击率", Type: "click_rate", Bili: commBili(c, dataLastMap[v["app_id"]], tmpList, "click_rate"), Value: utils.GetPrec(v["click_rate"], "2") + "%"},
+		}
+		applet := GetAppletInfo(c, v["app_id"])
+		tmp := md.IndexAppListData{
+			Name:      applet["name"],
+			Logo:      applet["logo"],
+			List:      dataList,
+			TableList: []string{},
+		}
+		list = append(list, tmp)
+	}
+	res := md.IndexAppListRes{
+		List:  list,
+		AppId: appId,
+		Sort: []md.SelectData{
+			{Name: "按收益最高", Value: "media_revenue desc"},
+			{Name: "按ECPM最高", Value: "ecpm desc"},
+			{Name: "按曝光量最高", Value: "exposure_count desc"},
+		},
+	}
+	return res
+}
+func commOperatorTotal(c *gin.Context, startDate, endDate string) []map[string]string {
+	sql := `
+		SELECT 
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_rate) as click_rate,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s 
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if startDate != "" {
+		where += " and date>='" + startDate + "'"
+	}
+	if endDate != "" {
+		where += " and date<='" + endDate + "'"
+	}
+	sql = fmt.Sprintf(sql, where)
+	nativeString, _ := db.QueryNativeString(db.Db, sql)
+	if len(nativeString) == 0 {
+		nativeString = []map[string]string{
+			{
+				"media_revenue": "0",
+			},
+		}
+	}
+	return nativeString
+}
+func commOperatorTotalByApp(c *gin.Context, req md.IndexAppListReq, appId []string) []map[string]string {
+	sql := `
+		SELECT 
+			app_id as app_id,
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_count)/SUM(exposure_count)*100 as click_rate,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s group by app_id order by %s,id asc limit 50
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if req.StartDate != "" {
+		where += " and date>='" + req.StartDate + "'"
+	}
+	if req.EndDate != "" {
+		where += " and date<='" + req.EndDate + "'"
+	}
+	if req.Name != "" {
+		mediumId := GetMediumId(c, req.Name)
+		where += " and medium_id in(" + mediumId + ")"
+	}
+	if len(appId) > 0 {
+		where += " and app_id in(‘" + strings.Join(appId, ",") + "’)"
+	}
+	if req.Sort == "" {
+		req.Sort = "media_revenue desc"
+	}
+	sql = fmt.Sprintf(sql, where, req.Sort)
+	nativeString, _ := db.QueryNativeString(db.Db, sql)
+	return nativeString
+}
+func commOperatorTotalByDate(c *gin.Context, startDate, endDate string, appId []string) []map[string]string {
+	sql := `
+		SELECT 
+			app_id as app_id,
+			date as date,
+			SUM(exposure_count) as exposure_count,
+			SUM(click_count) as click_count,
+			SUM(click_count)/SUM(exposure_count)*100 as click_rate,
+			SUM(ecpm) as ecpm,
+			SUM(media_revenue) as media_revenue
+		FROM generate_wx_ad_data
+		where %s group by date,app_id
+`
+	where := "is_generate_report=1 and uuid=" + c.GetString("mid")
+	if startDate != "" {
+		where += " and date>='" + startDate + "'"
+	}
+	if endDate != "" {
+		where += " and date<='" + endDate + "'"
+	}
+	if len(appId) > 0 {
+		where += " and app_id in('" + strings.Join(appId, ",") + "')"
+	}
+	sql = fmt.Sprintf(sql, where)
+	nativeString, err := db.QueryNativeString(db.Db, sql)
+	fmt.Println(err)
+	return nativeString
+}