package MetadataDAO

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

//数据库
var db = DbUtil.Engine

func GetMetadataRow(where string) (bool, string, map[string]interface{}, error) {
	sql := "SELECT id FROM t_dataex_metadata WHERE " + where
	fmt.Println("sql = ", sql)

	//通过SQL获取带缓存的数据
	list, count, _ := CacheUtil.Page(sql, 1, 0)

	if count > 0 {
		return true, "数据获取成功", list[0],nil
	}else {
		return false, "数据获取失败，systemID对应的数据源类型不存在", nil,nil
	}
}

func GetMetadataResults (query MySwagger.MetadataQuery) (bool, string, int32, []map[string]interface{}, error) {
	sql := "SELECT id FROM t_dataex_metadata WHERE 1 = 1" + query.Conditions
	fmt.Println("sql = ", sql)

	//通过SQL获取带缓存的数据
	list, count, _ := CacheUtil.Page(sql, 100, query.Page)

	if count >0 {
		return true, "数据获取成功", count, list, nil
	}else {
		return false, "数据获取失败，systemID对应的数据源类型不存在", count, nil, nil
	}
}


func CreateMetadata (model *models.TDataexMetadata) (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 CreateMetadataBatch (model []models.TDataexMetadata) (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 UpdateMetadata (id string, model *models.TDataexMetadata) (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 RemoveMetadata (id string, model *models.TDataexMetadata) (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 GetMetadataCountByDatasourceId(datasourceId string) int64  {
	business := new(models.TDataexMetadata)
	total, err := db.Where("datasource_id =?", datasourceId).Count(business)
	if err != nil {
		LogUtil.Error(ErrorConst.SqlQueryError, "数据库操作发生严重错误："+err.Error())
	}
	return total
}

func IsMetadataExistsByDatasourceId(datasourceId string) bool {
	if GetMetadataCountByDatasourceId(datasourceId) > 0 {
		return true
	}
	return false
}

func DeleteMetadataByDatasourceId (datasourceId string) (bool, string, error) {
	_, err := db.Exec("DELETE FROM t_dataex_metadata WHERE datasource_id = ?", datasourceId)
	if err != nil {
		LogUtil.Error(ErrorConst.SqlQueryError, "数据库操作发生严重错误："+err.Error())
		return false, "数据库操作失败", err
	}
	return true, "删除成功!", nil
}