package service

import (
	"dashoo.cn/micro/app/dao"
	"dashoo.cn/micro/app/model"
	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/grpool"
	"github.com/gogf/gf/util/gconv"
)

type sysLoginLog struct {
	Pool *grpool.Pool
}

var (
	SysLoginLog = &sysLoginLog{
		Pool: grpool.New(100),
	}
)

func (s *sysLoginLog) Invoke(data *model.LoginLogParams) {
	s.Pool.Add(func() {
		//写入日志数据
		//SysUser.LoginLog(data)
	})
}

func (s *sysLoginLog) LoginLogListByPage(req *model.SysLoginLogSearchReq) (total, page int, list []*model.SysLogin, err error) {
	db := dao.SysLogin.M
	order := "info_id DESC"
	if req.LoginName != "" {
		db = db.Where("login_name like ?", "%"+req.LoginName+"%")
	}
	if req.Status != "" {
		db = db.Where("status", gconv.Int(req.Status))
	}
	if req.Ipaddr != "" {
		db = db.Where("ipaddr like ?", "%"+req.Ipaddr+"%")
	}
	if req.LoginLocation != "" {
		db = db.Where("login_location like ?", "%"+req.LoginLocation+"%")
	}
	if req.BeginTime != "" {
		db = db.Where("login_time >=", req.BeginTime)
	}
	if req.EndTime != "" {
		db = db.Where("login_time <=", req.EndTime)
	}
	if req.SortName != "" {
		if req.SortOrder != "" {
			order = req.SortName + " " + req.SortOrder
		} else {
			order = req.SortName + " DESC"
		}
	}

	total, err = db.Count()
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取总行数失败")
		return
	}
	err = db.Page(req.GetPage()).Order(order).Scan(&list)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取数据失败")
	}
	return
}

func (s *sysLoginLog) DeleteLoginLogByIds(ids []int) (err error) {
	if len(ids) == 0 {
		err = gerror.New("参数错误")
		return
	}
	_, err = dao.SysLogin.Delete("info_id in (?)", ids)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("删除失败")
	}
	return
}

func (s *sysLoginLog) ClearLoginLog() (err error) {
	_, err = g.DB().Exec("truncate " + dao.SysLogin.Table)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("清除失败")
	}
	return
}