package main

import (
	"fmt"
	"github.com/jinzhu/gorm"
	"github.com/micro/go-micro/v2"
	"github.com/micro/go-micro/v2/logger"
	"github.com/micro/go-micro/v2/registry"
	"github.com/micro/go-micro/v2/registry/etcd"
	"gitee.com/ichub/go-factroy2024/common/base"
	handler2 "gitee.com/ichub/go-factroy2024/framework/grpc/test/service/handler"

	"gitee.com/ichub/go-factroy2024/factroy/dbfactroy"
	cmsColumnProto "gitee.com/ichub/go-factroy2024/framework/grpc/proto/cmsColumn"
	helloProto "gitee.com/ichub/go-factroy2024/framework/grpc/proto/hello"
	hubLevelsProto "gitee.com/ichub/go-factroy2024/framework/grpc/proto/hubLevels"
	tablenameProto "gitee.com/ichub/go-factroy2024/framework/grpc/proto/tableName"
)

func roachDBUrlConnPG() string {
	//	return "postgresql://code@192.168.14.235:26257/" + base.MODULE_MAP[base.APP].DbName + "?sslmode=require"
	return "postgresql://root@192.168.14.153:26257/" + base.MODULE_MAP[base.APP].DbName + "?sslmode=disable"
}

type RpcClientInfo struct {
	Hostip, ServerName, ClientName string
	Nats_URL                       string //  "nats://192.168.4.119:4222"

}

func main() {
	rpcClientInfo := RpcClientInfo{
		//"192.168.13.154:2379,192.168.13.155:2379,192.168.13.156:2379",
		"192.168.14.153:2379",
		"common.service",
		"hubgo.client",
		"nats://192.168.4.119:4222",
	}
	tabletool := &dbfactroy.DbFactroy{
		Dbtype_mysql: false,
		DbName:       base.MODULE_MAP[base.APP].DbName,
		Table:        "employee",
		Author:       "leijianming",
		ModuleDefine: base.MODULE_MAP[base.APP], //MODULE_NAME,
	}

	dBUrl := roachDBUrlConnPG()
	// dBUrl := fmt.Sprintf("attend:123456@tcp(attend.akunlong.top:3306)/%s?charset=utf8&mb4&parseTime=True&loc=Local", tabletool.DbName)
	var dbinst *gorm.DB = tabletool.IniDb(dBUrl) //  dbcontent.InitDB_pg(pgDBUrlConn())
	defer dbinst.Close()

	reg := etcd.NewRegistry(func(options *registry.Options) {
		options.Addrs = []string{
			rpcClientInfo.Hostip,
		}
	})

	// New Service
	opts := []micro.Option{
		micro.Registry(reg),
		micro.Name(rpcClientInfo.ServerName),
		micro.Version("latest"),
	}
	opts = append(opts, micro.Address("0.0.0.0:10080"))
	service := micro.NewService(opts...)
	fmt.Println(opts)
	service.Init()

	// Register Handler
	tablenameProto.RegisterTableNameHandler(service.Server(), new(handler2.TableNameRpc))
	cmsColumnProto.RegisterCmsColumnHandler(service.Server(), new(handler2.CmsColumnRpc))
	helloProto.RegisterHelloYeahHandler(service.Server(), new(handler2.HelloRpc))
	hubLevelsProto.RegisterHubLevelsHandler(service.Server(), new(handler2.HubLevelsRpc))

	// Run service
	if err := service.Run(); err != nil {
		logger.Fatal(err)
	}

}