go/crud_generator
1
0
Fork 0
mirror of https://github.com/ManyakRus/crud_generator.git synced 2025-01-20 09:09:22 +02:00
Code Issues Releases Activity

сделал uuid

Browse Source
This commit is contained in:
Nikitin Aleksandr 2024-04-09 18:04:05 +03:00
parent 8e68074a03
commit 47e21aebf3
12 changed files with 108 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bin/notifier_service/pkg/crud_starter/crud_starter_manual.go
View File

@ -7,6 +7,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_attachament"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_channel"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_channel_prod"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_constructor_users"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_debt_list"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_debt_list2"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_delivery_error"
@ -34,6 +35,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_attachament"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_channel"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_channel_prod"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_constructor_users"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_debt_list"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_debt_list2"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_delivery_error"
@ -61,6 +63,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_attachament"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_channel"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_channel_prod"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_constructor_users"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_debt_list"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_debt_list2"
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_delivery_error"
@ -91,6 +94,7 @@ func initCrudTransport_manual_DB() {
crud_starter_attachament.SetCrudManualInterface(crud_attachament.Crud_DB{})
crud_starter_channel.SetCrudManualInterface(crud_channel.Crud_DB{})
crud_starter_channel_prod.SetCrudManualInterface(crud_channel_prod.Crud_DB{})
crud_starter_constructor_users.SetCrudManualInterface(crud_constructor_users.Crud_DB{})
crud_starter_debt_list.SetCrudManualInterface(crud_debt_list.Crud_DB{})
crud_starter_debt_list2.SetCrudManualInterface(crud_debt_list2.Crud_DB{})
crud_starter_delivery_error.SetCrudManualInterface(crud_delivery_error.Crud_DB{})
@ -121,6 +125,7 @@ func initCrudTransport_manual_GRPC() {
crud_starter_attachament.SetCrudManualInterface(grpc_attachament.Crud_GRPC{})
crud_starter_channel.SetCrudManualInterface(grpc_channel.Crud_GRPC{})
crud_starter_channel_prod.SetCrudManualInterface(grpc_channel_prod.Crud_GRPC{})
crud_starter_constructor_users.SetCrudManualInterface(grpc_constructor_users.Crud_GRPC{})
crud_starter_debt_list.SetCrudManualInterface(grpc_debt_list.Crud_GRPC{})
crud_starter_debt_list2.SetCrudManualInterface(grpc_debt_list2.Crud_GRPC{})
crud_starter_delivery_error.SetCrudManualInterface(grpc_delivery_error.Crud_GRPC{})
@ -151,6 +156,7 @@ func initCrudTransport_manual_NRPC() {
crud_starter_attachament.SetCrudManualInterface(grpc_attachament.Crud_GRPC{})
crud_starter_channel.SetCrudManualInterface(grpc_channel.Crud_GRPC{})
crud_starter_channel_prod.SetCrudManualInterface(grpc_channel_prod.Crud_GRPC{})
crud_starter_constructor_users.SetCrudManualInterface(grpc_constructor_users.Crud_GRPC{})
crud_starter_debt_list.SetCrudManualInterface(grpc_debt_list.Crud_GRPC{})
crud_starter_debt_list2.SetCrudManualInterface(grpc_debt_list2.Crud_GRPC{})
crud_starter_delivery_error.SetCrudManualInterface(grpc_delivery_error.Crud_GRPC{})

3
bin/notifier_service/pkg/object_model/entities/attachament/attachament.go
View File

@ -4,8 +4,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/tables/table_attachament"
)
// Attachament - модель для таблицы attachament: Вложения прикладываемые к сообщению
Целевая БД сервиса уведомлений
// Attachament - модель для таблицы attachament: Вложения прикладываемые к сообщениюЦелевая БД сервиса уведомлений
type Attachament struct {
table_attachament.Table_Attachament
}

3
bin/notifier_service/pkg/object_model/entities/incoming_event/incoming_event.go
View File

@ -4,8 +4,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/tables/table_incoming_event"
)
// IncomingEvent - модель для таблицы incoming_event: Входяшие события из шины или API, как есть.
Целевая БД сервиса уведомлений
// IncomingEvent - модель для таблицы incoming_event: Входяшие события из шины или API, как есть.Целевая БД сервиса уведомлений
type IncomingEvent struct {
table_incoming_event.Table_IncomingEvent
}

3
bin/notifier_service/pkg/object_model/entities/mailing/mailing.go
View File

@ -4,8 +4,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/tables/table_mailing"
)
// Mailing - модель для таблицы mailing: Рассылки
Целевая БД сервиса уведомлений
// Mailing - модель для таблицы mailing: РассылкиЦелевая БД сервиса уведомлений
type Mailing struct {
table_mailing.Table_Mailing
}

3
bin/notifier_service/pkg/object_model/entities/message/message.go
View File

@ -4,8 +4,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/tables/table_message"
)
// Message - модель для таблицы message: сообщения
Целевая БД сервиса уведомлений
// Message - модель для таблицы message: сообщенияЦелевая БД сервиса уведомлений
type Message struct {
table_message.Table_Message
}

3
bin/notifier_service/pkg/object_model/entities/template/template.go
View File

@ -4,8 +4,7 @@ import (
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/tables/table_template"
)
// Template - модель для таблицы template: Шаблоны уведомлений
Целевая БД сервиса уведомлений
// Template - модель для таблицы template: Шаблоны уведомленийЦелевая БД сервиса уведомлений
type Template struct {
table_template.Table_Template
}

86
internal/create_files/create_files.go
View File

@ -174,16 +174,71 @@ func FindPrimaryKeyNameType(Table1 *types.Table) (string, string) {
// return Otvet, Type
//}
// ReplacePrimaryKeyID - заменяет "ID" на название колонки PrimaryKey
func ReplacePrimaryKeyID(Text string, Table1 *types.Table) string {
// ReplacePrimaryKeyOtvetID - заменяет "Otvet.ID" на название колонки PrimaryKey
func ReplacePrimaryKeyOtvetID(Text string, Table1 *types.Table) string {
Otvet := Text
ColumnName, ColumnTypeGo := FindPrimaryKeyNameTypeGo(Table1)
//заменим ID-Alias на ID
TableName := Table1.Name
IDName, _ := FindPrimaryKeyNameType(Table1)
_, ok := types.MapConvertID[TableName+"."+IDName]
OtvetColumnName := "Otvet." + ColumnName
if ok == true {
OtvetColumnName = ColumnTypeGo + "(" + OtvetColumnName + ")"
}
//заменим int64(m.ID) на m.ID
if mini_func.IsNumberType(ColumnTypeGo) == true {
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", "Otvet."+ColumnName)
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", OtvetColumnName)
} else if ColumnTypeGo == "string" {
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID == 0", "Otvet."+ColumnName+" == \"\"")
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", "Otvet."+ColumnName)
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID == 0", OtvetColumnName+" == \"\"")
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID != 0", OtvetColumnName+" != \"\"")
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", OtvetColumnName)
} else if ColumnTypeGo == "uuid.UUID" || ColumnTypeGo == "uuid.NullUUID" {
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID == 0", OtvetColumnName+" == uuid.Nil")
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID != 0", OtvetColumnName+" != uuid.Nil")
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", OtvetColumnName)
} else if ColumnTypeGo == "time.Time" {
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) == 0", OtvetColumnName+".IsZero() == true")
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) != 0", OtvetColumnName+".IsZero() == false")
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID)", OtvetColumnName)
}
return Otvet
}
// ReplacePrimaryKeyM_ID - заменяет "m.ID" на название колонки PrimaryKey
func ReplacePrimaryKeyM_ID(Text string, Table1 *types.Table) string {
Otvet := Text
ColumnName, ColumnTypeGo := FindPrimaryKeyNameTypeGo(Table1)
//заменим ID-Alias на ID
TableName := Table1.Name
IDName, _ := FindPrimaryKeyNameType(Table1)
_, ok := types.MapConvertID[TableName+"."+IDName]
OtvetColumnName := "m." + ColumnName
if ok == true {
OtvetColumnName = ColumnTypeGo + "(" + OtvetColumnName + ")"
}
//заменим int64(m.ID) на m.ID
if mini_func.IsNumberType(ColumnTypeGo) == true {
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", OtvetColumnName)
} else if ColumnTypeGo == "string" {
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) == 0", OtvetColumnName+" == \"\"")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) != 0", OtvetColumnName+" != \"\"")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", OtvetColumnName)
} else if ColumnTypeGo == "uuid.UUID" || ColumnTypeGo == "uuid.NullUUID" {
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) == 0", OtvetColumnName+" == uuid.Nil")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) != 0", OtvetColumnName+" != uuid.Nil")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", OtvetColumnName)
} else if ColumnTypeGo == "time.Time" {
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) == 0", OtvetColumnName+".IsZero() == true")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID) != 0", OtvetColumnName+".IsZero() == false")
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", OtvetColumnName)
}
return Otvet
@ -709,7 +764,7 @@ func CheckAndAddImportTime_FromText(Text string) string {
func CheckAndAddImportUUID_FromText(Text string) string {
Otvet := Text
pos1 := strings.Index(Text, " uuid.")
pos1 := strings.Index(Text, "uuid.")
if pos1 < 0 {
return Otvet
}
@ -1484,3 +1539,22 @@ func Is_UUID_Type(TypeGo string) bool {
Otvet := TypeGo == "uuid.UUID" || TypeGo == "uuid.NullUUID"
return Otvet
}
//// ConvertID_toTypeID - заменяет int64(m.ID) на m.ID
//func ConvertID_toTypeID(Text string, Table1 *types.Table) string {
// Otvet := Text
//
// //заменим ID-Alias на ID
// TableName := Table1.Name
// IDName, _ := FindPrimaryKeyNameType(Table1)
// TextConvert, ok := types.MapConvertID[TableName+"."+IDName]
// if ok == true {
// Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", ""+TextConvert+"(m.ID)")
// return Otvet
// }
//
// //заменим int64(m.ID) на m.ID
// Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", "m.ID")
//
// return Otvet
//}

10
internal/create_files/crud_tables/crud_tables.go
View File

@ -155,6 +155,7 @@ func CreateFiles(Table1 *types.Table) error {
//создание текста
TextDB = strings.ReplaceAll(TextDB, config.Settings.TEXT_TEMPLATE_MODEL, ModelName)
TextDB = strings.ReplaceAll(TextDB, config.Settings.TEXT_TEMPLATE_TABLENAME, Table1.Name)
TextDB = create_files.ReplacePrimaryKeyM_ID(TextDB, Table1)
TextDB = config.Settings.TEXT_MODULE_GENERATED + TextDB
//TextDB = create_files.DeleteFuncFind_byExtID(TextDB, Table1)
@ -247,7 +248,7 @@ func CreateTestFiles(Table1 *types.Table) error {
TextDB = create_files.AddSkipNow(TextDB, Table1)
//замена ID на PrimaryKey
TextDB = create_files.ReplacePrimaryKeyID(TextDB, Table1)
TextDB = create_files.ReplacePrimaryKeyOtvetID(TextDB, Table1)
//замена импортов на новые URL
TextDB = create_files.ReplaceServiceURLImports(TextDB)
@ -832,6 +833,13 @@ func CreateFilesCache(Table1 *types.Table) error {
sCACHE_ELEMENTS_COUNT := micro.StringFromInt64(CACHE_ELEMENTS_COUNT)
TextCache = create_files.FillVariable(TextCache, constants.TEXT_CACHE_SIZE_1000, sCACHE_ELEMENTS_COUNT)
//тип ID кэша
_, ColumnTypeGo := create_files.FindPrimaryKeyNameTypeGo(Table1)
TextCache = strings.ReplaceAll(TextCache, ".LRU[int64", ".LRU["+ColumnTypeGo)
//uuid
TextCache = create_files.CheckAndAddImportUUID_FromText(TextCache)
//удаление пустого импорта
TextCache = create_files.DeleteEmptyImport(TextCache)

4
internal/create_files/grpc_client_tables/grpc_client_tables.go
View File

@ -226,7 +226,7 @@ func CreateTestFiles(Table1 *types.Table) error {
}
// замена ID на PrimaryKey
TextGRPCClient = create_files.ReplacePrimaryKeyID(TextGRPCClient, Table1)
TextGRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextGRPCClient, Table1)
//SkipNow()
TextGRPCClient = create_files.AddSkipNow(TextGRPCClient, Table1)
@ -798,7 +798,7 @@ func CreateFiles_GRPC_Client_Cache_Test(Table1 *types.Table) error {
TextGRPCClient = config.Settings.TEXT_MODULE_GENERATED + TextGRPCClient
// замена ID на PrimaryKey
TextGRPCClient = create_files.ReplacePrimaryKeyID(TextGRPCClient, Table1)
TextGRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextGRPCClient, Table1)
//SkipNow()
TextGRPCClient = create_files.AddSkipNow(TextGRPCClient, Table1)

2
internal/create_files/nrpc_client_tables/nrpc_client_tables.go
View File

@ -180,7 +180,7 @@ func CreateTestFiles(Table1 *types.Table) error {
}
// замена ID на PrimaryKey
TextNRPCClient = create_files.ReplacePrimaryKeyID(TextNRPCClient, Table1)
TextNRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextNRPCClient, Table1)
//SkipNow()
TextNRPCClient = create_files.AddSkipNow(TextNRPCClient, Table1)

2
internal/create_files/server_grpc_tables/server_grpc_tables.go
View File

@ -215,7 +215,7 @@ func CreateTestFiles(Table1 *types.Table) error {
}
// замена ID на PrimaryKey
TextGRPCServer = create_files.ReplacePrimaryKeyID(TextGRPCServer, Table1)
TextGRPCServer = create_files.ReplacePrimaryKeyOtvetID(TextGRPCServer, Table1)
//SkipNow()
TextGRPCServer = create_files.AddSkipNow(TextGRPCServer, Table1)

5
internal/postgres/postgres.go
View File

@ -256,10 +256,13 @@ order by
ModelName = create_files.FormatName(ModelName)
//
TableComment := v.TableComment
TableComment = strings.ReplaceAll(TableComment, "\n", "")
TableComment = strings.ReplaceAll(TableComment, "\r", "")
Table1 = CreateTable()
Table1.Name = TableName
Table1.OrderNumber = OrderNumberTable
Table1.Comment = v.TableComment
Table1.Comment = TableComment
Table1.NameGo = ModelName
}