openbilibili/app/admin/main/growup/http/income.go

package http

import (
	"fmt"
	"net/http"
	"time"

	"go-common/library/log"
	bm "go-common/library/net/http/blademaster"
	"go-common/library/net/http/blademaster/render"
)

func upIncomeList(c *bm.Context) {
	v := new(struct {
		MIDs      []int64 `form:"mids,split"`
		Type      int     `form:"type"`
		GroupType int     `form:"group_type" default:"1"`
		FromTime  int64   `form:"from_time" validate:"required,min=1"`
		ToTime    int64   `form:"to_time" validate:"required,min=1"`
		MinIncome int64   `form:"min_income"`
		MaxIncome int64   `form:"max_income"`
		From      int     `form:"from" validate:"min=0" default:"0"`
		Limit     int     `form:"limit" validate:"min=1" default:"20"`
	})

	if err := c.Bind(v); err != nil {
		return
	}

	data, total, err := incomeSvr.UpIncomeList(c, v.MIDs, v.Type, v.GroupType, v.FromTime, v.ToTime, v.MinIncome, v.MaxIncome, v.From, v.Limit)
	if err != nil {
		log.Error("growup incomeSvr.UpIncomeList error(%v)", err)
		c.JSON(nil, err)
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"paging": map[string]int{
			"page_size": v.Limit,
			"total":     total,
		},
	}))
}

func upIncomeListExport(c *bm.Context) {
	v := new(struct {
		MIDs      []int64 `form:"mids,split"`
		Type      int     `form:"type"`
		GroupType int     `form:"group_type" default:"1"`
		FromTime  int64   `form:"from_time" validate:"min=1,required"`
		ToTime    int64   `form:"to_time" validate:"min=1,required"`
		MinIncome int64   `form:"min_income"`
		MaxIncome int64   `form:"max_income"`
		From      int     `form:"from" validate:"min=0" default:"0"`
		Limit     int     `form:"limit" validate:"min=1" default:"20"`
	})

	if err := c.Bind(v); err != nil {
		return
	}

	content, err := incomeSvr.UpIncomeListExport(c, v.MIDs, v.Type, v.GroupType, v.FromTime, v.ToTime, v.MinIncome, v.MaxIncome, v.From, v.Limit)
	if err != nil {
		log.Error("growup incomeSvr.UpIncomeListExport error(%v)", err)
		c.JSON(nil, err)
		return
	}

	c.Render(http.StatusOK, CSV{
		Content: content,
		Title:   fmt.Sprintf("%s-%s", time.Now().Format("2006-01-02"), "up_income"),
	})
}

func upIncomeStatis(c *bm.Context) {
	v := new(struct {
		MIDs      []int64 `form:"mids,split"`
		Type      int     `form:"type"`
		GroupType int     `form:"group_type" default:"1"`
		FromTime  int64   `form:"from_time" validate:"required,min=1"`
		ToTime    int64   `form:"to_time" validate:"required,min=1"`
	})

	if err := c.Bind(v); err != nil {
		return
	}

	data, err := incomeSvr.UpIncomeStatis(c, v.MIDs, v.Type, v.GroupType, v.FromTime, v.ToTime)
	if err != nil {
		log.Error("growup incomeSvr.UpIncomeStatis error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
	}))
}

func archiveStatis(c *bm.Context) {
	v := new(struct {
		CategoryID []int64 `form:"category_id,split"`
		Type       int     `form:"type"`
		GroupType  int     `form:"group_type" default:"1"`
		FromTime   int64   `form:"from_time" validate:"required,min=1"`
		ToTime     int64   `form:"to_time" validate:"required,min=1"`
	})
	if err := c.Bind(v); err != nil {
		return
	}
	data, err := incomeSvr.ArchiveStatis(c, v.CategoryID, v.Type, v.GroupType, v.FromTime, v.ToTime)
	if err != nil {
		log.Error("growup incomeSvr.ArchiveStatis error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
	}))
}

func archiveSection(c *bm.Context) {
	v := new(struct {
		CategoryID []int64 `form:"category_id,split"`
		Type       int     `form:"type"`
		GroupType  int     `form:"group_type" default:"1"`
		FromTime   int64   `form:"from_time" validate:"required,min=1"`
		ToTime     int64   `form:"to_time" validate:"required,min=1"`
	})
	if err := c.Bind(v); err != nil {
		return
	}
	data, err := incomeSvr.ArchiveSection(c, v.CategoryID, v.Type, v.GroupType, v.FromTime, v.ToTime)
	if err != nil {
		log.Error("growup incomeSvr.ArchiveSection error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
	}))
}

func archiveDetail(c *bm.Context) {
	v := new(struct {
		MID       int64 `form:"mid" validate:"required"`
		Type      int   `form:"type"`
		GroupType int   `form:"group_type" default:"1"`
		FromTime  int64 `form:"from_time" validate:"required,min=1"`
		ToTime    int64 `form:"to_time" validate:"required,min=1"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	data, err := incomeSvr.ArchiveDetail(c, v.MID, v.Type, v.GroupType, v.FromTime, v.ToTime)
	if err != nil {
		log.Error("growup incomeSvr.ArchiveDetail error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
	}))
}

func archiveTop(c *bm.Context) {
	v := new(struct {
		AIDs      []int64 `form:"aids,split"`
		Type      int     `form:"type"`
		GroupType int     `form:"group_type" default:"1"`
		FromTime  int64   `form:"from_time" validate:"required,min=1"`
		ToTime    int64   `form:"to_time" validate:"required,min=1"`
		From      int     `form:"from" validate:"min=0" default:"0"`
		Limit     int     `form:"limit" validate:"min=1" default:"20"`
	})

	if err := c.Bind(v); err != nil {
		return
	}

	data, total, err := incomeSvr.ArchiveTop(c, v.AIDs, v.Type, v.GroupType, v.FromTime, v.ToTime, v.From, v.Limit)
	if err != nil {
		log.Error("growup incomeSvr.ArchiveTop error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
		"paging": map[string]int{
			"page_size": v.Limit,
			"total":     total,
		},
	}))
}

func bgmDetail(c *bm.Context) {
	v := new(struct {
		SID      int64 `form:"sid"`
		FromTime int64 `form:"from_time" validate:"required,min=1"`
		ToTime   int64 `form:"to_time" validate:"required,min=1"`
		From     int   `form:"from" validate:"min=0" default:"0"`
		Limit    int   `form:"limit" validate:"min=1" default:"20"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	data, total, err := incomeSvr.BgmDetail(c, v.SID, v.FromTime, v.ToTime, v.From, v.Limit)
	if err != nil {
		log.Error("growup incomeSvr.BgmDetail error(%v)", err)
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":   err,
			"status": "fail",
		}))
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
		"paging": map[string]int{
			"page_size": v.Limit,
			"total":     total,
		},
	}))
}

func archiveBreach(c *bm.Context) {
	username, _, err := checkCookie(c)
	if err != nil {
		c.JSON(nil, err)
		return
	}
	v := new(struct {
		Type   int     `form:"type"`
		AIDs   []int64 `form:"aids,split" validate:"required"`
		MID    int64   `form:"mid" validate:"required"`
		Reason string  `form:"reason" validate:"required"`
	})
	if err = c.Bind(v); err != nil {
		return
	}

	err = incomeSvr.ArchiveBreach(c, v.Type, v.AIDs, v.MID, v.Reason, username)
	if err != nil {
		c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
			"code":    500,
			"message": err.Error(),
		}))
	} else {
		c.JSON(nil, nil)
	}
}

func archiveBlack(c *bm.Context) {
	v := new(struct {
		Type int     `form:"type"`
		AIDs []int64 `form:"aids,split" validate:"required"`
		MID  int64   `form:"mid" validate:"required"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	err := incomeSvr.ArchiveBlack(c, v.Type, v.AIDs, v.MID)
	if err != nil {
		log.Error("growup incomeSvr.ArchiveBlack error(%v)", err)
	}
	c.JSON(nil, err)
}

func breachList(c *bm.Context) {
	v := new(struct {
		MIDs     []int64 `form:"mids,split"`
		AIDs     []int64 `form:"aids,split"`
		Type     int     `form:"type"`
		FromTime int64   `form:"from_time" validate:"required,min=1"`
		ToTime   int64   `form:"to_time" validate:"required,min=1"`
		Reason   string  `form:"reason"`
		From     int     `form:"from" validate:"min=0" default:"0"`
		Limit    int     `form:"limit" validate:"min=1" default:"20"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	data, total, err := incomeSvr.BreachList(c, v.MIDs, v.AIDs, v.Type, v.FromTime, v.ToTime, v.Reason, v.From, v.Limit)
	if err != nil {
		log.Error("growup incomeSvr.BreachList error(%v)", err)
		c.JSON(nil, err)
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"paging": map[string]int{
			"page_size": v.Limit,
			"total":     total,
		},
	}))
}

func breachStatis(c *bm.Context) {
	v := new(struct {
		MIDs      []int64 `form:"mids,split"`
		AIDs      []int64 `form:"aids,split"`
		Type      int     `form:"type"`
		GroupType int     `form:"group_type"`
		FromTime  int64   `form:"from_time" validate:"required,min=1"`
		ToTime    int64   `form:"to_time" validate:"required,min=1"`
		Reason    string  `form:"reason"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	data, err := incomeSvr.BreachStatis(c, v.MIDs, v.AIDs, v.Type, v.GroupType, v.FromTime, v.ToTime, v.Reason)
	if err != nil {
		log.Error("growup incomeSvr.BreachStatis error(%v)", err)
		c.JSON(nil, err)
		return
	}
	c.Render(http.StatusOK, render.MapJSON(map[string]interface{}{
		"code":    0,
		"message": "0",
		"result":  data,
		"status":  "success",
	}))
}

func exportBreach(c *bm.Context) {
	v := new(struct {
		MIDs     []int64 `form:"mids,split"`
		AIDs     []int64 `form:"aids,split"`
		Type     int     `form:"type"`
		FromTime int64   `form:"from_time" validate:"required,min=1"`
		ToTime   int64   `form:"to_time" validate:"required,min=1"`
		Reason   string  `form:"reason"`
		From     int     `form:"from" validate:"min=0" default:"0"`
		Limit    int     `form:"limit" validate:"min=1" default:"20"`
	})
	if err := c.Bind(v); err != nil {
		return
	}

	content, err := incomeSvr.ExportBreach(c, v.MIDs, v.AIDs, v.Type, v.FromTime, v.ToTime, v.Reason, v.From, v.Limit)
	if err != nil {
		log.Error("growup svr.ExportBreach error(%v)", err)
		c.JSON(nil, err)
		return
	}
	c.Render(http.StatusOK, CSV{
		Content: content,
		Title:   fmt.Sprintf("%s-%s", time.Now().Format("2006-01-02"), "breach_record"),
	})
}