package OrgtreeDAO

import (
	"dsSupport/MyModel/MySwagger"
	"dsSupport/Utils/CacheUtil"
	"dsSupport/Utils/DbUtil"
	"dsSupport/Utils/ErrorConst"
	"dsSupport/Utils/LogUtil"
	"dsSupport/models"
	"fmt"
)

//数据库
var db = DbUtil.Engine

func GetOrgtreeResults(query MySwagger.OrgtreeQuery) (bool, string, int, []map[string]interface{}, error) {
	sql := "SELECT * FROM t_dataex_orgtree WHERE 1 = 1" + query.Conditions + " ORDER BY create_time DESC, change_time DESC"
	//接收传入参数
	var limit = 10
	var offset = (query.Page - 1) * limit
	//条件查询语句
	conditionSql := fmt.Sprintf("%s", " limit ? offset ? ")
	//分页的语句
	pageSql := fmt.Sprintf("%s %s", sql, conditionSql)
	//数据条数
	count, _ := DbUtil.Engine.SQL(sql).Query().Count()
	//分页数据
	list, err := DbUtil.Engine.SQL(pageSql, limit, offset).Query().List()
	if list != nil {
		return true, "数据获取成功", count, list, err
	} else {
		return false, "数据获取失败，数据源不存在", count, nil, nil
	}
}

func CreateOrgtree(model *models.TDataexOrgtree) (bool, string, error) {
	_, err := db.Insert(model)
	if err != nil {
		fmt.Println("err=", err)
		LogUtil.Error(ErrorConst.SqlUpdateError, "接入系统authToken Update，数据库操作发生严重错误："+err.Error())
		return false, "数据库操作失败", err
	}
	return true, "创建成功!", nil
}

func UpdateOrgtree(id string, model *models.TDataexOrgtree) (bool, string, error) {
	//清除Redis缓存
	var ids = []string{id}
	var selector = CacheUtil.GetBean("t_dataex_orgtree")
	CacheUtil.DeleteCacheByIds(ids, selector)

	_, err := db.Where(" id = ?", id).Update(model)

	if err != nil {
		LogUtil.Error(ErrorConst.SqlUpdateError, "接入系统authToken Update，数据库操作发生严重错误："+err.Error())
		return false, "数据库操作失败", err
	}
	return true, "修改成功!", nil
}

func RemoveOrgtree(id string, model *models.TDataexOrgtree) (bool, string, error) {
	_, err := db.Where(" id = ?", id).Update(model)

	if err != nil {
		LogUtil.Error(ErrorConst.SqlUpdateError, "接入系统authToken Update，数据库操作发生严重错误："+err.Error())
		return false, "数据库操作失败", err
	}
	return true, "删除成功!", nil
}

func GetOrgtreeCountById(id string) int64 {
	business := new(models.TDataexOrgtree)
	total, err := db.Where("id =?", id).Count(business)
	if err != nil {
		LogUtil.Error(ErrorConst.SqlUpdateError, "接入系统authToken Update，数据库操作发生严重错误："+err.Error())
	}
	return total
}

func IsOrgtreeExistsById(id string) bool {
	if GetOrgtreeCountById(id) > 0 {
		return true
	}
	return false
}