package service

import (
	"github.com/go-xorm/xorm"
	"gitee.com/jonluo/baasmanager/apimanager/entity"
	"gitee.com/jonluo/baasmanager/apimanager/model"
	"fmt"
)

type DashboardService struct {
	DbEngine *xorm.Engine
}

func NewDashboardService(engine *xorm.Engine) *DashboardService {
	return &DashboardService{
		DbEngine: engine,
	}
}

func (d *DashboardService) Counts(userAccount string) (bool, *model.Dashboard) {

	dash := new(model.Dashboard)
	var err error

	values := make([]interface{}, 0)
	where := "1=1"
	if userAccount != "" {
		where += " and user_account = ? "
		values = append(values, userAccount)
	}

	dash.Users, err = d.DbEngine.Where(where, values...).Count(new(entity.User))
	if err != nil {
		logger.Error(err.Error())
	}

	dash.Chains, err = d.DbEngine.Where(where, values...).Count(new(entity.Chain))
	if err != nil {
		logger.Error(err.Error())
	}
	dash.Chaincodes, err = d.DbEngine.Where(where, values...).Count(new(entity.Chaincode))
	if err != nil {
		logger.Error(err.Error())
	}
	dash.Channels, err = d.DbEngine.Where(where, values...).Count(new(entity.Channel))
	if err != nil {
		logger.Error(err.Error())
	}

	return true, dash
}

func (d *DashboardService) SevenDays(userAccount string, start, end int) (bool, map[string][]map[string]string) {

	sevenMap := make(map[string][]map[string]string)

	where := " where 1=1 "
	if userAccount != "" {
		where += " and user_account =" + userAccount
	}

	if start != 0 {
		where += fmt.Sprintf(" and created >= %d", start)
	}

	if end != 0 {
		where += fmt.Sprintf(" and created <= %d", end)
	}

	sql := ` SELECT from_unixtime( created, "%Y-%m-%d" ) AS days, count( id ) AS counts FROM `
	group := " GROUP BY days "
	table := "chain"
	chains, err := d.DbEngine.QueryString(sql + table + where + group)
	if err != nil {
		logger.Error(err.Error())
	}
	sevenMap["chains"] = chains

	table = "channel"
	channels, err := d.DbEngine.QueryString(sql + table + where + group)
	if err != nil {
		logger.Error(err.Error())
	}
	sevenMap["channels"] = channels

	table = "chaincode"
	chaincodes, err := d.DbEngine.QueryString(sql + table + where + group)
	if err != nil {
		logger.Error(err.Error())
	}
	sevenMap["chaincodes"] = chaincodes

	table = "user"
	users, err := d.DbEngine.QueryString(sql + table + where + group)
	if err != nil {
		logger.Error(err.Error())
	}
	sevenMap["users"] = users

	return true, sevenMap
}