package pg

import (
	"fmt"
	"github.com/go-pg/pg/v10"
	"github.com/go-pg/pg/v10/orm"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/constant"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg/models"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/log"

	"github.com/linmadan/egglib-go/persistent/pg/comment"
	"github.com/linmadan/egglib-go/persistent/pg/hooks"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg/models"
)

var DB *pg.DB

func init() {
	DB = pg.Connect(&pg.Options{
		User:     constant.POSTGRESQL_USER,
		Password: constant.POSTGRESQL_PASSWORD,
		Database: constant.POSTGRESQL_DB_NAME,
		Addr:     fmt.Sprintf("%s:%s", constant.POSTGRESQL_HOST, constant.POSTGRESQL_PORT),
	})
	if !constant.DISABLE_SQL_GENERATE_PRINT {
		DB.AddQueryHook(hooks.SqlGeneratePrintHook{Logger: log.Logger})
	}
	if !constant.DISABLE_CREATE_TABLE {
		for _, model := range []interface{}{
			&models.ContractUndertakerFeedback{},
			&models.CooperationApplication{},
			&models.CooperationContract{},
			&models.CooperationMode{},
			&models.CooperationProject{},
			&models.DividendsEstimate{},
			&models.DividendsIncentivesRule{},
			&models.MoneyIncentivesRule{},
		} {
			err := DB.Model(model).CreateTable(&orm.CreateTableOptions{
				Temp:          false,
				IfNotExists:   true,
				FKConstraints: true,
			})
			if err != nil {
				panic(err)
			}
			comment.AddComments(DB, model)
		}
	}
}