package service

import (
	"errors"
	"time"
	"vamicro/compTable-service/models"
)

type DbTableService struct {

}

func InitDbTableEnableStatus(){
	time.Sleep(1 * time.Second)

	var dt models.Dbtables
	allTables, err := dt.FindAllDbTables()
	if err ==nil {
		if allTables !=nil && len(allTables)>0 {
			currentTime := time.Now()
			for _, t := range allTables {
				startTime := t.StartTime
				endTime := t.EndTime
				st, _ := time.ParseInLocation("2006-01-02 15:04:05", startTime, time.Local)
				if endTime !=""{
					et, _ := time.ParseInLocation("2006-01-02 15:04:05", endTime, time.Local)
					if et.After(currentTime) {
						if st.Before(currentTime) && st.Month() == currentTime.Month() && st.Day() == currentTime.Day() {//当天开启
							dt.UpdateEnableStatus(t.Id,1)
						}
					} else {
						//已过期
						dt.UpdateEnableStatus(t.Id,0)
					}
				} else {
					if st.Before(currentTime) { //
						if t.Enable == 0 { //当前是关闭状态，判断是否需要开启
							if st.Month() == currentTime.Month() && st.Day() == currentTime.Day() {
								dt.UpdateEnableStatus(t.Id,1)
							}
						} else { //当前是开启状态

						}
					} else {
						dt.UpdateEnableStatus(t.Id,0)
					}
				}
			}
		}
	}
}

func (sv DbTableService) Add(dt models.Dbtables) (bool,error) {
	existList, err := dt.FindByName(dt.TableName)
	if err ==nil && len(existList) == 0 {
		return dt.Add()
	}
	return false,errors.New("dbt exist")
}

func (sv DbTableService) Update(dt models.Dbtables) (bool,error) {
	return dt.Update()
}

func (sv DbTableService)UpdateDbTableStatus(id string,enable int) (bool,error) {
	var dt models.Dbtables
	return dt.UpdateEnableStatus(id,enable)
}

func (sv DbTableService) DeleteById(id string) (bool,error) {
	var dt models.Dbtables
	return dt.DeleteById(id)
}

func (sv DbTableService) SelectById(id string) (dt models.Dbtables,err error) {
	var dtE models.Dbtables
	rows, err := dtE.SelectById(id)
	if rows > 0 && err ==nil {
		return dtE,nil
	}
	return dt,errors.New("dbtable not found")
}

func (sv DbTableService) FindByIsSync(tableName string,isSync string) (arr []models.Dbtables,err error) {
	var dt models.Dbtables
	return dt.FindByIsSync(tableName, isSync)
}

func (sv DbTableService) FindByDbtIds(ids []string) (arr []models.Dbtables,err error) {
	var dt models.Dbtables
	return dt.FindByDbtIds(ids)
}

//-1:包含已删除底库,1：查已删除,0:查未删除
func (sv DbTableService) FindAllDbTablesByCurServer(isDelete int,typ string) (arr []models.Dbtables,err error) {
	var dt models.Dbtables
	return dt.FindAllDbTablesByCurServer(isDelete, typ)
}

func (sv DbTableService) FindAllDbTables() (arr []models.Dbtables,err error) {
	var dt models.Dbtables
	return dt.FindAllDbTables()
}

func (sv DbTableService) FindAllLocalDbTables(isDelete string) (arr []models.Dbtables,err error) {
	var dt models.Dbtables
	return dt.FindAllLocalDbTables(isDelete)
}