package main

import (
	"bufio"
	"dsTools/Utils/ConfigUtil"
	"dsTools/Utils/DbUtil"
	"dsTools/Utils/FileUtil"
	"fmt"
	"io"
	"os"
	"strings"
)

func main() {
	//1、定义参加同步的表有哪些
	var syncTables []string
	//读取
	f, err := os.Open("./Config/syncDataTables.txt")
	if err != nil {
		fmt.Println("没有找到数据同步的定义表文件syncDataTables.txt！")
		return
	}
	buf := bufio.NewReader(f)
	var shouldBreak = false
	for {
		line, err := buf.ReadString('\n')
		if err != nil || io.EOF == err {
			shouldBreak = true
		}
		line = strings.TrimSpace(line)
		if strings.Index(line, "#") < 0 && len(line) > 0 {
			syncTables = append(syncTables, line)
		}
		if shouldBreak {
			break
		}
	}
	//遍历每一个表
	for i := 0; i < len(syncTables); i++ {
		tableName:=syncTables[i]
		//到mysql中查询
		sql := "desc " + tableName
		list, err := DbUtil.Engine.QueryInterface(sql)
		if err != nil {
			fmt.Println(err)
		}
		var pinSql = "select "
		for j := 0; j < len(list); j++ {
			c := list[j]
			field := string(c["Field"].([]byte))
			Type := string(c["Type"].([]byte))
			Key := string(c["Key"].([]byte))
			if Key == "PRI" {
				var pk = "concat('" + ConfigUtil.InstallAreaCode + "','_'," + field + ")"
				pinSql += pk + " as id,"
				pinSql += field + " as pk,"
			} else if Type == "datetime" || Type == "timestamp" { //带时间的日期格式
				pinSql += "date_format(" + field + ", '%Y-%m-%d %H:%i:%s') as " + field + ","
			} else if Type == "date" { //不带时间的日期格式
				pinSql += "date_format(" + field + ", '%Y-%m-%d') as " + field + ","
			} else { //普通格式
				pinSql += field + ","
			}
		}
		pinSql += "'" + tableName + "' as table_name "
		pinSql += " from " +tableName + " where last_updated_time>:sql_last_value"
		//输出
		p:="SyncSql/"
		FileUtil.WriteToFile(p+tableName+".sql", pinSql)
		fmt.Println("正在生成"+tableName+"...")
	}
	fmt.Println("恭喜，所有配置文件成功生成！")
}