package bo

import (
	"scd_check_tools/tools"
	"fmt"
	"strconv"
	"time"

	"github.com/astaxie/beego/orm"
)

//数据量统计
func AllRecordStat() (data []orm.Params, err error) {
	var sql = "select ifnull(count(1),0) rc from t_data_sf6 a "
	o := orm.NewOrm()
	var maps []orm.Params
	_, sqlerr := o.Raw(sql).Values(&maps)
	if sqlerr != nil {
		return nil, sqlerr
	}
	return maps, nil
}

func ClearData(dtype string, daybefore int) (result int, err error) {
	var sql = ""
	tname := "t_data_sf6"
	o := orm.NewOrm()
	if daybefore > 0 {
		d := time.Now()
		b, _ := time.ParseDuration(strconv.Itoa(daybefore*24*-1) + "h")
		d1 := d.Add(b)
		sql = "delete from " + tname + " where indate<'" + d1.Format("2006-01-02 15:04:05") + "'"
	} else {
		sql = "delete from " + tname
	}
	//fmt.Println(sql)
	_, er := o.Raw(sql).Exec()
	if er != nil {
		fmt.Println(tools.NowTime() + " sqlerror:" + er.Error() + " SQL:" + sql)
		return 0, er
	}
	return 1, nil
}