mirror of
https://github.com/ManyakRus/crud_generator.git
synced 2024-11-24 08:22:42 +02:00
сделал uuid
This commit is contained in:
Nikitin Aleksandr
parent
133b94310f
commit
f7686109d7
@ -5,179 +5,23 @@ package crud_starter
|
||||
|
||||
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"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_delivery_status"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_filial"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_incoming_event"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_link_type"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_mailing"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_mailing_stats"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_message"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_meter_list"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_pdf_data"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_redirect_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_short_links"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_statistic"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_telegram_users"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_telegram_users_info"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_template"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_template_decoration"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_u_link_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_w_log"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_w_log_message_del"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/crud_starter/crud_starter_w_options"
|
||||
|
||||
"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"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_delivery_status"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_filial"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_incoming_event"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_link_type"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_mailing"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_mailing_stats"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_message"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_meter_list"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_pdf_data"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_redirect_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_short_links"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_statistic"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_telegram_users"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_telegram_users_info"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_template"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_template_decoration"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_u_link_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_w_log"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_w_log_message_del"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/db/crud/crud_w_options"
|
||||
|
||||
"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"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_delivery_status"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_filial"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_incoming_event"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_link_type"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_mailing"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_mailing_stats"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_message"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_meter_list"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_pdf_data"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_redirect_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_short_links"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_statistic"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_telegram_users"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_telegram_users_info"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_template"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_template_decoration"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_u_link_store"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_w_log"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_w_log_message_del"
|
||||
"gitlab.aescorp.ru/dsp_dev/claim/notifier_service/pkg/network/grpc/grpc_client/grpc_w_options"
|
||||
)
|
||||
|
||||
// initCrudTransport_manual_DB - заполняет объекты crud для работы с БД напрямую
|
||||
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{})
|
||||
crud_starter_delivery_status.SetCrudManualInterface(crud_delivery_status.Crud_DB{})
|
||||
crud_starter_filial.SetCrudManualInterface(crud_filial.Crud_DB{})
|
||||
crud_starter_incoming_event.SetCrudManualInterface(crud_incoming_event.Crud_DB{})
|
||||
crud_starter_link_type.SetCrudManualInterface(crud_link_type.Crud_DB{})
|
||||
crud_starter_mailing.SetCrudManualInterface(crud_mailing.Crud_DB{})
|
||||
crud_starter_mailing_stats.SetCrudManualInterface(crud_mailing_stats.Crud_DB{})
|
||||
crud_starter_message.SetCrudManualInterface(crud_message.Crud_DB{})
|
||||
crud_starter_meter_list.SetCrudManualInterface(crud_meter_list.Crud_DB{})
|
||||
crud_starter_pdf_data.SetCrudManualInterface(crud_pdf_data.Crud_DB{})
|
||||
crud_starter_redirect_store.SetCrudManualInterface(crud_redirect_store.Crud_DB{})
|
||||
crud_starter_short_links.SetCrudManualInterface(crud_short_links.Crud_DB{})
|
||||
crud_starter_statistic.SetCrudManualInterface(crud_statistic.Crud_DB{})
|
||||
crud_starter_telegram_users.SetCrudManualInterface(crud_telegram_users.Crud_DB{})
|
||||
crud_starter_telegram_users_info.SetCrudManualInterface(crud_telegram_users_info.Crud_DB{})
|
||||
crud_starter_template.SetCrudManualInterface(crud_template.Crud_DB{})
|
||||
crud_starter_template_decoration.SetCrudManualInterface(crud_template_decoration.Crud_DB{})
|
||||
crud_starter_u_link_store.SetCrudManualInterface(crud_u_link_store.Crud_DB{})
|
||||
crud_starter_w_log.SetCrudManualInterface(crud_w_log.Crud_DB{})
|
||||
crud_starter_w_log_message_del.SetCrudManualInterface(crud_w_log_message_del.Crud_DB{})
|
||||
crud_starter_w_options.SetCrudManualInterface(crud_w_options.Crud_DB{})
|
||||
}
|
||||
|
||||
// initCrudTransport_manual_GRPC - заполняет объекты crud для работы с БД через протокол GRPC
|
||||
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{})
|
||||
crud_starter_delivery_status.SetCrudManualInterface(grpc_delivery_status.Crud_GRPC{})
|
||||
crud_starter_filial.SetCrudManualInterface(grpc_filial.Crud_GRPC{})
|
||||
crud_starter_incoming_event.SetCrudManualInterface(grpc_incoming_event.Crud_GRPC{})
|
||||
crud_starter_link_type.SetCrudManualInterface(grpc_link_type.Crud_GRPC{})
|
||||
crud_starter_mailing.SetCrudManualInterface(grpc_mailing.Crud_GRPC{})
|
||||
crud_starter_mailing_stats.SetCrudManualInterface(grpc_mailing_stats.Crud_GRPC{})
|
||||
crud_starter_message.SetCrudManualInterface(grpc_message.Crud_GRPC{})
|
||||
crud_starter_meter_list.SetCrudManualInterface(grpc_meter_list.Crud_GRPC{})
|
||||
crud_starter_pdf_data.SetCrudManualInterface(grpc_pdf_data.Crud_GRPC{})
|
||||
crud_starter_redirect_store.SetCrudManualInterface(grpc_redirect_store.Crud_GRPC{})
|
||||
crud_starter_short_links.SetCrudManualInterface(grpc_short_links.Crud_GRPC{})
|
||||
crud_starter_statistic.SetCrudManualInterface(grpc_statistic.Crud_GRPC{})
|
||||
crud_starter_telegram_users.SetCrudManualInterface(grpc_telegram_users.Crud_GRPC{})
|
||||
crud_starter_telegram_users_info.SetCrudManualInterface(grpc_telegram_users_info.Crud_GRPC{})
|
||||
crud_starter_template.SetCrudManualInterface(grpc_template.Crud_GRPC{})
|
||||
crud_starter_template_decoration.SetCrudManualInterface(grpc_template_decoration.Crud_GRPC{})
|
||||
crud_starter_u_link_store.SetCrudManualInterface(grpc_u_link_store.Crud_GRPC{})
|
||||
crud_starter_w_log.SetCrudManualInterface(grpc_w_log.Crud_GRPC{})
|
||||
crud_starter_w_log_message_del.SetCrudManualInterface(grpc_w_log_message_del.Crud_GRPC{})
|
||||
crud_starter_w_options.SetCrudManualInterface(grpc_w_options.Crud_GRPC{})
|
||||
}
|
||||
|
||||
// initCrudTransport_manual_NRPC - заполняет объекты crud для работы с БД через протокол NRPC
|
||||
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{})
|
||||
crud_starter_delivery_status.SetCrudManualInterface(grpc_delivery_status.Crud_GRPC{})
|
||||
crud_starter_filial.SetCrudManualInterface(grpc_filial.Crud_GRPC{})
|
||||
crud_starter_incoming_event.SetCrudManualInterface(grpc_incoming_event.Crud_GRPC{})
|
||||
crud_starter_link_type.SetCrudManualInterface(grpc_link_type.Crud_GRPC{})
|
||||
crud_starter_mailing.SetCrudManualInterface(grpc_mailing.Crud_GRPC{})
|
||||
crud_starter_mailing_stats.SetCrudManualInterface(grpc_mailing_stats.Crud_GRPC{})
|
||||
crud_starter_message.SetCrudManualInterface(grpc_message.Crud_GRPC{})
|
||||
crud_starter_meter_list.SetCrudManualInterface(grpc_meter_list.Crud_GRPC{})
|
||||
crud_starter_pdf_data.SetCrudManualInterface(grpc_pdf_data.Crud_GRPC{})
|
||||
crud_starter_redirect_store.SetCrudManualInterface(grpc_redirect_store.Crud_GRPC{})
|
||||
crud_starter_short_links.SetCrudManualInterface(grpc_short_links.Crud_GRPC{})
|
||||
crud_starter_statistic.SetCrudManualInterface(grpc_statistic.Crud_GRPC{})
|
||||
crud_starter_telegram_users.SetCrudManualInterface(grpc_telegram_users.Crud_GRPC{})
|
||||
crud_starter_telegram_users_info.SetCrudManualInterface(grpc_telegram_users_info.Crud_GRPC{})
|
||||
crud_starter_template.SetCrudManualInterface(grpc_template.Crud_GRPC{})
|
||||
crud_starter_template_decoration.SetCrudManualInterface(grpc_template_decoration.Crud_GRPC{})
|
||||
crud_starter_u_link_store.SetCrudManualInterface(grpc_u_link_store.Crud_GRPC{})
|
||||
crud_starter_w_log.SetCrudManualInterface(grpc_w_log.Crud_GRPC{})
|
||||
crud_starter_w_log_message_del.SetCrudManualInterface(grpc_w_log_message_del.Crud_GRPC{})
|
||||
crud_starter_w_options.SetCrudManualInterface(grpc_w_options.Crud_GRPC{})
|
||||
}
|
||||
}
|
||||
|
||||
@ -15,6 +15,7 @@ import "google/protobuf/timestamp.proto";
|
||||
service Sync_service {
|
||||
}
|
||||
|
||||
|
||||
// -------------------------- Request ----------------------------------------------
|
||||
|
||||
// RequestId - параметры запроса на сервер
|
||||
@ -26,17 +27,17 @@ message RequestId {
|
||||
// RequestString - параметры запроса на сервер
|
||||
message RequestString {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string StringFind = 2; // строка поиска
|
||||
string String_1 = 2; // строка поиска
|
||||
}
|
||||
|
||||
// RequestString3 - параметры запроса на сервер
|
||||
message RequestString3 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string StringFind1 = 2; // строка поиска
|
||||
string StringFind2 = 3; // строка поиска
|
||||
string StringFind3 = 4; // строка поиска
|
||||
string String_1 = 2; // строка поиска
|
||||
string String_2 = 3; // строка поиска
|
||||
string String_3 = 4; // строка поиска
|
||||
}
|
||||
// RequestId - параметры запроса на сервер
|
||||
// RequestExtID - параметры запроса на сервер
|
||||
message RequestExtID {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 ExtID = 2; // ext_id записи в БД
|
||||
@ -59,16 +60,16 @@ message RequestInnKpp {
|
||||
// RequestIdId - параметры запроса на сервер
|
||||
message RequestIdId {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD1 = 2; // id записи в БД
|
||||
int64 iD2 = 3; // id записи в БД
|
||||
int64 ID1 = 2; // id записи в БД
|
||||
int64 ID2 = 3; // id записи в БД
|
||||
}
|
||||
|
||||
// RequestIdIdId - параметры запроса на сервер
|
||||
message RequestIdIdId {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD1 = 2; // id записи в БД
|
||||
int64 iD2 = 3; // id записи в БД
|
||||
int64 iD3 = 4; // id записи в БД
|
||||
int64 ID1 = 2; // id записи в БД
|
||||
int64 ID2 = 3; // id записи в БД
|
||||
int64 ID3 = 4; // id записи в БД
|
||||
}
|
||||
|
||||
// RequestDate - параметры запроса на сервер, передаётся Дата time.Time
|
||||
@ -101,56 +102,161 @@ message RequestBool {
|
||||
bool Bool = 2; // строка поиска
|
||||
}
|
||||
|
||||
//----------------------------- Request_ID -------------------------------------------
|
||||
|
||||
// Request_ID_Date - параметры запроса на сервер, передаётся ID + Дата time.Time
|
||||
message Request_ID_Date {
|
||||
// RequestId_Date - параметры запроса на сервер, передаётся ID + Дата time.Time
|
||||
message RequestId_Date {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
google.protobuf.Timestamp Date = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_Float64 - параметры запроса на сервер, передаётся ID + float64
|
||||
message Request_ID_Float64 {
|
||||
// RequestId_Float64 - параметры запроса на сервер, передаётся ID + float64
|
||||
message RequestId_Float64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
double Float64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_Float32 - параметры запроса на сервер, передаётся ID + float32
|
||||
message Request_ID_Float32 {
|
||||
// RequestId_Float32 - параметры запроса на сервер, передаётся ID + float32
|
||||
message RequestId_Float32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
float Float32 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_Int32 - параметры запроса на сервер, передаётся ID + int32
|
||||
message Request_ID_Int32 {
|
||||
// RequestId_Int32 - параметры запроса на сервер, передаётся ID + int32
|
||||
message RequestId_Int32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
int32 Int32 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_Int64 - параметры запроса на сервер, передаётся ID + int64
|
||||
message Request_ID_Int64 {
|
||||
// RequestId_Int64 - параметры запроса на сервер, передаётся ID + int64
|
||||
message RequestId_Int64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
int64 Int64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_Bool - параметры запроса на сервер, передаётся ID + bool
|
||||
message Request_ID_Bool {
|
||||
// RequestId_Bool - параметры запроса на сервер, передаётся ID + bool
|
||||
message RequestId_Bool {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
int64 ID = 2; // id записи в БД
|
||||
bool Bool = 3; // значение поиска
|
||||
}
|
||||
|
||||
// Request_ID_String - параметры запроса на сервер, передаётся ID + string
|
||||
message Request_ID_String {
|
||||
// RequestId_String - параметры запроса на сервер, передаётся ID + string
|
||||
message RequestId_String {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int64 iD = 2; // id записи в БД
|
||||
string StringFind = 3; // строка поиска
|
||||
int64 ID = 2; // id записи в БД
|
||||
string String_1 = 3; // строка поиска
|
||||
}
|
||||
|
||||
//----------------------------- Request_Int32 -------------------------------------------
|
||||
|
||||
// RequestInt32_Date - параметры запроса на сервер, передаётся int32 + Дата time.Time
|
||||
message RequestInt32_Date {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
google.protobuf.Timestamp Date = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_Float64 - параметры запроса на сервер, передаётся int32 + float64
|
||||
message RequestInt32_Float64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
double Float64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_Float32 - параметры запроса на сервер, передаётся int32 + float32
|
||||
message RequestInt32_Float32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
float Float32 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_Int32 - параметры запроса на сервер, передаётся int32 + int32
|
||||
message RequestInt32_Int32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
int32 Int32_2 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_Int64 - параметры запроса на сервер, передаётся int32 + int64
|
||||
message RequestInt32_Int64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
int64 Int64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_Bool - параметры запроса на сервер, передаётся int32 + bool
|
||||
message RequestInt32_Bool {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
bool Bool = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestInt32_String - параметры запроса на сервер, передаётся int32 + string
|
||||
message RequestInt32_String {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
int32 Int32 = 2; // id записи в БД
|
||||
string String_1 = 3; // строка поиска
|
||||
}
|
||||
|
||||
//----------------------------- Request_String -------------------------------------------
|
||||
|
||||
// RequestString_Date - параметры запроса на сервер, передаётся string + Дата time.Time
|
||||
message RequestString_Date {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // ID записи в БД
|
||||
google.protobuf.Timestamp Date = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_Float64 - параметры запроса на сервер, передаётся string + float64
|
||||
message RequestString_Float64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
double Float64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_Float32 - параметры запроса на сервер, передаётся string + float32
|
||||
message RequestString_Float32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
float Float32 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_Int32 - параметры запроса на сервер, передаётся string + int32
|
||||
message RequestString_Int32 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
int32 Int32 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_Int64 - параметры запроса на сервер, передаётся string + int64
|
||||
message RequestString_Int64 {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
int64 Int64 = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_Bool - параметры запроса на сервер, передаётся string + bool
|
||||
message RequestString_Bool {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
bool Bool = 3; // значение поиска
|
||||
}
|
||||
|
||||
// RequestString_String - параметры запроса на сервер, передаётся string + string
|
||||
message RequestString_String {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
string String_1 = 2; // id записи в БД
|
||||
string String_2 = 3; // строка поиска
|
||||
}
|
||||
|
||||
//-------------------------------------------------------------------------------------
|
||||
|
||||
// Request_Model_MassString - модель и массив строк
|
||||
message Request_Model_MassString {
|
||||
uint32 VersionModel= 1; //версия структуры модели
|
||||
@ -158,7 +264,6 @@ message Request_Model_MassString {
|
||||
repeated string MassNames = 3; //массив строк
|
||||
}
|
||||
|
||||
|
||||
// -------------------------- Response ----------------------------------------------
|
||||
|
||||
// Response - возвращает строка json Модель
|
||||
|
||||
@ -25,7 +25,7 @@ func (crud Crud_GRPC) ReadFromCache(ID int64) (lawsuit_status_types.LawsuitStatu
|
||||
var versionModel = crud.GetVersionModel()
|
||||
|
||||
Request := &grpc_proto.RequestId{}
|
||||
Request.ID = ID
|
||||
Request.ID = int64(ID)
|
||||
Request.VersionModel = versionModel
|
||||
|
||||
ctxMain := context.Background()
|
||||
|
||||
@ -20,7 +20,7 @@ func TestReadFromCache(t *testing.T) {
|
||||
t.Error("ReadFromCache() error: ", err)
|
||||
}
|
||||
|
||||
if Otvet.ID == 0 {
|
||||
if int64(Otvet.ID) == 0 {
|
||||
t.Error("ReadFromCache() error: ID =0")
|
||||
}
|
||||
}
|
||||
|
||||
@ -43,18 +43,18 @@ func TestCreate(t *testing.T) {
|
||||
grpc_client.Connect()
|
||||
defer grpc_client.CloseConnection()
|
||||
|
||||
Model := lawsuit_status_types.LawsuitStatusType{}
|
||||
Model.ID = -1
|
||||
Otvet := lawsuit_status_types.LawsuitStatusType{}
|
||||
Otvet.ID = -1
|
||||
|
||||
crud := Crud_GRPC{}
|
||||
err := crud.Create(&Model)
|
||||
err := crud.Create(&Otvet)
|
||||
|
||||
if err == nil {
|
||||
t.Error("TestCreate() error: ", err)
|
||||
}
|
||||
|
||||
if Model.ID > 0 {
|
||||
t.Error("TestCreate() error: ID >0")
|
||||
if int64(Otvet.ID) != 0 {
|
||||
t.Error("TestCreate() error: ID !=0")
|
||||
}
|
||||
}
|
||||
|
||||
@ -63,17 +63,17 @@ func TestUpdate(t *testing.T) {
|
||||
grpc_client.Connect()
|
||||
defer grpc_client.CloseConnection()
|
||||
|
||||
Model := lawsuit_status_types.LawsuitStatusType{}
|
||||
Model.ID = 0
|
||||
Otvet := lawsuit_status_types.LawsuitStatusType{}
|
||||
Otvet.ID = -1
|
||||
|
||||
crud := Crud_GRPC{}
|
||||
err := crud.Update(&Model)
|
||||
err := crud.Update(&Otvet)
|
||||
|
||||
if err == nil {
|
||||
t.Error("TestUpdate() error: ", err)
|
||||
}
|
||||
|
||||
if Model.ID != 0 {
|
||||
if int64(Otvet.ID) != 0 {
|
||||
t.Error("TestUpdate() error: ID =0")
|
||||
}
|
||||
}
|
||||
|
||||
@ -9,7 +9,7 @@ func (crud Crud_GRPC) Update(m *lawsuit_status_types.LawsuitStatusType) error {
|
||||
var versionModel = crud.GetVersionModel()
|
||||
|
||||
Request := &grpc_proto.RequestId{}
|
||||
Request.ID = m.ID
|
||||
Request.ID = int64(m.ID)
|
||||
Request.FieldName = m.ColumnName
|
||||
Request.VersionModel = versionModel
|
||||
|
||||
|
||||
@ -7,9 +7,9 @@ func TestCrud_GRPC_Update(t *testing.T) {
|
||||
crud := Crud_GRPC{}
|
||||
|
||||
//прочитаем из БД
|
||||
Model := lawsuit_status_types.LawsuitStatusType{}
|
||||
Model.ID = Postgres_ID_Test
|
||||
err := crud.Read(&Model)
|
||||
m := lawsuit_status_types.LawsuitStatusType{}
|
||||
m.ID = Postgres_ID_Test
|
||||
err := crud.Read(&m)
|
||||
|
||||
if err != nil {
|
||||
t.Error("TestCrud_GRPC_Update() Read() error: ", err)
|
||||
@ -17,8 +17,8 @@ func TestCrud_GRPC_Update(t *testing.T) {
|
||||
|
||||
//запишем в БД это же значение
|
||||
Otvet := lawsuit_status_types.LawsuitStatusType{}
|
||||
Otvet.ID = Model.ID
|
||||
Otvet.ColumnName = Model.ColumnName
|
||||
Otvet.ID = m.ID
|
||||
Otvet.ColumnName = m.ColumnName
|
||||
err = crud.Update_ColumnName(&Otvet)
|
||||
if err != nil {
|
||||
t.Error("TestCrud_GRPC_Update() Update() error: ", err)
|
||||
|
||||
@ -29,7 +29,7 @@ func TestCrud_GRPC_UpdateManyFields(t *testing.T) {
|
||||
t.Error("TestCrud_GRPC_UpdateManyFields() error: ", err)
|
||||
}
|
||||
|
||||
if Otvet.ID == 0 {
|
||||
if int64(Otvet.ID) == 0 {
|
||||
t.Error("TestCrud_GRPC_UpdateManyFields() error: ID =0")
|
||||
}
|
||||
}
|
||||
|
||||
@ -202,17 +202,17 @@ func ReplacePrimaryKeyOtvetID(Text string, Table1 *types.Table) string {
|
||||
OtvetColumnName = ColumnTypeGo + "(" + OtvetColumnName + ")"
|
||||
}
|
||||
|
||||
//заменим int64(m.ID) на m.ID
|
||||
//заменим int64(Otvet.ID) на Otvet.ID
|
||||
if mini_func.IsNumberType(ColumnTypeGo) == true {
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID)", OtvetColumnName)
|
||||
} else if ColumnTypeGo == "string" {
|
||||
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID == 0", OtvetColumnName+" == \"\"")
|
||||
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID != 0", OtvetColumnName+" != \"\"")
|
||||
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID", OtvetColumnName)
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) == 0", OtvetColumnName+" == \"\"")
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) != 0", OtvetColumnName+" != \"\"")
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(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)
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) == 0", OtvetColumnName+" == uuid.Nil")
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(Otvet.ID) != 0", OtvetColumnName+" != uuid.Nil")
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(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")
|
||||
@ -247,7 +247,7 @@ func ReplacePrimaryKeyM_ID(Text string, Table1 *types.Table) string {
|
||||
} 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)
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", OtvetColumnName+".String()")
|
||||
} 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")
|
||||
@ -1175,51 +1175,117 @@ func AddInterfaceFunction(s, TextAdd string) string {
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// FindTextProtobufRequest - возвращает имя message из .proto, в зависимости от типа, а также название поля
|
||||
func FindTextProtobufRequest(TypeGo string) (string, string) {
|
||||
Otvet := "RequestID"
|
||||
// FindTextProtobufRequest - возвращает "RequestID" и "ID" - имя message из .proto, в зависимости от типа, а также название поля
|
||||
func FindTextProtobufRequest(Table1 *types.Table, TypeGo string) (string, string) {
|
||||
Otvet := "RequestId"
|
||||
TextRequestFieldName := "ID"
|
||||
TextRequest := "Request"
|
||||
|
||||
PrimaryKeyColumn := FindPrimaryKeyColumn(Table1)
|
||||
PrimaryKeyTypeGo := PrimaryKeyColumn.TypeGo
|
||||
switch PrimaryKeyTypeGo {
|
||||
case "string", "uuid.UUID":
|
||||
TextRequest = "RequestString_"
|
||||
}
|
||||
|
||||
switch TypeGo {
|
||||
case "int", "int64":
|
||||
{
|
||||
Otvet = "RequestId"
|
||||
if PrimaryKeyTypeGo == "int64" {
|
||||
Otvet = TextRequest + "Id"
|
||||
TextRequestFieldName = "ID"
|
||||
} else {
|
||||
Otvet = TextRequest + "Int64"
|
||||
TextRequestFieldName = "Int64"
|
||||
}
|
||||
}
|
||||
|
||||
case "int32":
|
||||
{
|
||||
Otvet = TextRequest + "Int32"
|
||||
TextRequestFieldName = "Int32"
|
||||
}
|
||||
case "string":
|
||||
{
|
||||
Otvet = TextRequest + "String"
|
||||
TextRequestFieldName = "String_1"
|
||||
}
|
||||
case "uuid.UUID":
|
||||
{
|
||||
Otvet = TextRequest + "String"
|
||||
TextRequestFieldName = "String_1"
|
||||
}
|
||||
case "time.Time":
|
||||
{
|
||||
Otvet = TextRequest + "Date"
|
||||
TextRequestFieldName = "Date"
|
||||
}
|
||||
case "float32":
|
||||
{
|
||||
Otvet = TextRequest + "Float32"
|
||||
TextRequestFieldName = "Float32"
|
||||
}
|
||||
case "float64":
|
||||
{
|
||||
Otvet = TextRequest + "Float64"
|
||||
TextRequestFieldName = "Float64"
|
||||
}
|
||||
case "bool":
|
||||
{
|
||||
Otvet = TextRequest + "Bool"
|
||||
TextRequestFieldName = "Bool"
|
||||
}
|
||||
}
|
||||
|
||||
return Otvet, TextRequestFieldName
|
||||
}
|
||||
|
||||
// FindTextProtobufRequestPrimaryKey - возвращает "RequestID" и "ID" - имя message из .proto, в зависимости от типа, а также название поля
|
||||
func FindTextProtobufRequestPrimaryKey(Table1 *types.Table, TypeGo string) (string, string) {
|
||||
Otvet := "RequestId"
|
||||
TextRequestFieldName := "ID"
|
||||
TextRequest := "Request"
|
||||
|
||||
switch TypeGo {
|
||||
case "int", "int64":
|
||||
{
|
||||
Otvet = TextRequest + "Id"
|
||||
TextRequestFieldName = "ID"
|
||||
}
|
||||
|
||||
case "int32":
|
||||
{
|
||||
Otvet = "RequestInt32"
|
||||
Otvet = TextRequest + "Int32"
|
||||
TextRequestFieldName = "Int32"
|
||||
}
|
||||
case "string":
|
||||
{
|
||||
Otvet = "RequestString"
|
||||
TextRequestFieldName = "StringFind"
|
||||
Otvet = TextRequest + "String"
|
||||
TextRequestFieldName = "String_1"
|
||||
}
|
||||
case "uuid.UUID":
|
||||
{
|
||||
Otvet = "RequestString"
|
||||
TextRequestFieldName = "StringFind"
|
||||
Otvet = TextRequest + "String"
|
||||
TextRequestFieldName = "String_1"
|
||||
}
|
||||
case "time.Time":
|
||||
{
|
||||
Otvet = "RequestDate"
|
||||
Otvet = TextRequest + "Date"
|
||||
TextRequestFieldName = "Date"
|
||||
}
|
||||
case "float32":
|
||||
{
|
||||
Otvet = "RequestFloat32"
|
||||
Otvet = TextRequest + "Float32"
|
||||
TextRequestFieldName = "Float32"
|
||||
}
|
||||
case "float64":
|
||||
{
|
||||
Otvet = "RequestFloat64"
|
||||
Otvet = TextRequest + "Float64"
|
||||
TextRequestFieldName = "Float64"
|
||||
}
|
||||
case "bool":
|
||||
{
|
||||
Otvet = "RequestBool"
|
||||
Otvet = TextRequest + "Bool"
|
||||
TextRequestFieldName = "Bool"
|
||||
}
|
||||
}
|
||||
@ -1234,7 +1300,7 @@ func FindTextProtobufRequest(TypeGo string) (string, string) {
|
||||
// TextRequestFieldGolang - название поля в Request с преобразованием в тип гоу
|
||||
// TextGolangLine - замена всей строки в го
|
||||
func FindTextProtobufRequest_ID_Type(Table1 *types.Table, Column1 *types.Column, VariableName string) (string, string, string, string) {
|
||||
Otvet := "RequestID"
|
||||
Otvet := "RequestId"
|
||||
TextRequestFieldName := "ID"
|
||||
TextRequestFieldGolang := "ID"
|
||||
TextGolangLine := ""
|
||||
@ -1243,33 +1309,51 @@ func FindTextProtobufRequest_ID_Type(Table1 *types.Table, Column1 *types.Column,
|
||||
TableName := Table1.Name
|
||||
ColumnName := Column1.Name
|
||||
|
||||
//найдём тип колонки PrimaryKey
|
||||
PrimaryKey_Column := FindPrimaryKeyColumn(Table1)
|
||||
PrimaryKey_TypeGo := PrimaryKey_Column.TypeGo
|
||||
//Text_Request_ID := "Request_ID"
|
||||
Otvet, _ = FindTextProtobufRequest(Table1, PrimaryKey_TypeGo)
|
||||
//Text_Request_ID = "Request_" + TextID
|
||||
|
||||
//найдём строку по типу колонки
|
||||
switch TypeGo {
|
||||
case "int", "int64":
|
||||
{
|
||||
Otvet = "Request_ID_Int64"
|
||||
//Otvet = Text_Request_ID + "_Int64"
|
||||
TextRequestFieldName = "Int64"
|
||||
TextRequestFieldGolang = VariableName + "Int64"
|
||||
}
|
||||
|
||||
case "int32":
|
||||
{
|
||||
Otvet = "Request_ID_Int32"
|
||||
//Otvet = Text_Request_ID + "_Int32"
|
||||
TextRequestFieldName = "Int32"
|
||||
TextRequestFieldGolang = VariableName + "Int32"
|
||||
}
|
||||
case "string":
|
||||
{
|
||||
Otvet = "Request_ID_String"
|
||||
TextRequestFieldName = "StringFind"
|
||||
TextRequestFieldGolang = VariableName + "StringFind"
|
||||
//Otvet = Text_Request_ID + "_String"
|
||||
if Column1 != PrimaryKey_Column {
|
||||
TextRequestFieldName = "String_2"
|
||||
TextRequestFieldGolang = VariableName + "String_2"
|
||||
} else {
|
||||
TextRequestFieldName = "String_1"
|
||||
TextRequestFieldGolang = VariableName + "String_1"
|
||||
}
|
||||
}
|
||||
case "uuid.UUID":
|
||||
{
|
||||
Otvet = "Request_ID_String"
|
||||
TextRequestFieldName = "StringFind"
|
||||
TextRequestFieldGolang = VariableName + "StringFind"
|
||||
//Otvet = Text_Request_ID + "_String"
|
||||
if Column1 != PrimaryKey_Column {
|
||||
TextRequestFieldName = "String_2"
|
||||
TextRequestFieldGolang = VariableName + "String_2"
|
||||
} else {
|
||||
TextRequestFieldName = "String_1"
|
||||
TextRequestFieldGolang = VariableName + "String_1"
|
||||
}
|
||||
TextGolangLine = "value, err := uuid.Parse(" + VariableName + "" + TextRequestFieldName + ")" + `
|
||||
if Request.StringFind == "" {
|
||||
if Request.String_2 == "" {
|
||||
value = uuid.Nil
|
||||
err = nil
|
||||
}
|
||||
@ -1280,25 +1364,25 @@ func FindTextProtobufRequest_ID_Type(Table1 *types.Table, Column1 *types.Column,
|
||||
}
|
||||
case "time.Time":
|
||||
{
|
||||
Otvet = "Request_ID_Date"
|
||||
//Otvet = Text_Request_ID + "_Date"
|
||||
TextRequestFieldName = "Date"
|
||||
TextRequestFieldGolang = VariableName + "Date.AsTime()"
|
||||
}
|
||||
case "float32":
|
||||
{
|
||||
Otvet = "Request_ID_Float32"
|
||||
//Otvet = Text_Request_ID + "_Float32"
|
||||
TextRequestFieldName = "Float32"
|
||||
TextRequestFieldGolang = VariableName + "Float32"
|
||||
}
|
||||
case "float64":
|
||||
{
|
||||
Otvet = "Request_ID_Float64"
|
||||
//Otvet = Text_Request_ID + "_Float64"
|
||||
TextRequestFieldName = "Float64"
|
||||
TextRequestFieldGolang = VariableName + "Float64"
|
||||
}
|
||||
case "bool":
|
||||
{
|
||||
Otvet = "Request_ID_Bool"
|
||||
//Otvet = Text_Request_ID + "_Bool"
|
||||
TextRequestFieldName = "Bool"
|
||||
TextRequestFieldGolang = VariableName + "Bool"
|
||||
}
|
||||
@ -1571,3 +1655,90 @@ func Is_UUID_Type(TypeGo string) bool {
|
||||
//
|
||||
// return Otvet
|
||||
//}
|
||||
|
||||
// Replace_Postgres_ID_Test - заменяет текст "const Postgres_ID_Test = 0" на нужный ИД
|
||||
func Replace_Postgres_ID_Test(Text string, Table1 *types.Table) string {
|
||||
Otvet := Text
|
||||
|
||||
TextFind := "const Postgres_ID_Test = 0"
|
||||
ColumnPrimary := FindPrimaryKeyColumn(Table1)
|
||||
IDMinimum := Table1.IDMinimum
|
||||
|
||||
if ColumnPrimary.TypeGo == "uuid.UUID" {
|
||||
if Table1.IDMinimum == "" {
|
||||
IDMinimum = FindTextDefaultValue(ColumnPrimary.TypeGo)
|
||||
Otvet = strings.ReplaceAll(Otvet, TextFind, `var Postgres_ID_Test = `+IDMinimum+``)
|
||||
} else {
|
||||
Otvet = strings.ReplaceAll(Otvet, TextFind, `var Postgres_ID_Test, _ = uuid.Parse("`+IDMinimum+`")`)
|
||||
}
|
||||
} else {
|
||||
Otvet = strings.ReplaceAll(Otvet, TextFind, TextFind+IDMinimum)
|
||||
}
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// ReplaceTextRequestID - заменяет RequestId{} на RequestString{}
|
||||
func ReplaceTextRequestID(Text string, Table1 *types.Table) string {
|
||||
Otvet := Text
|
||||
|
||||
PrimaryKeyColumn := FindPrimaryKeyColumn(Table1)
|
||||
TypeGo := PrimaryKeyColumn.TypeGo
|
||||
|
||||
TextRequestID, TextID := FindTextProtobufRequest(Table1, TypeGo)
|
||||
Otvet = strings.ReplaceAll(Otvet, "RequestId{}", TextRequestID+"{}")
|
||||
Otvet = strings.ReplaceAll(Otvet, "Request.ID", "Request."+TextID)
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// ReplaceTextRequestID_PrimaryKey - заменяет RequestId{} на RequestString{}
|
||||
func ReplaceTextRequestID_PrimaryKey(Text string, Table1 *types.Table) string {
|
||||
Otvet := Text
|
||||
|
||||
PrimaryKeyColumn := FindPrimaryKeyColumn(Table1)
|
||||
TypeGo := PrimaryKeyColumn.TypeGo
|
||||
|
||||
TextRequestID, TextID := FindTextProtobufRequestPrimaryKey(Table1, TypeGo)
|
||||
Otvet = strings.ReplaceAll(Otvet, "RequestId{}", TextRequestID+"{}")
|
||||
Otvet = strings.ReplaceAll(Otvet, "Request.ID", "Request."+TextID)
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// ReplaceIDtoID - заменяет int64(ID) на ID
|
||||
func ReplaceIDtoID(Text string, Table1 *types.Table) string {
|
||||
Otvet := Text
|
||||
|
||||
PrimaryKeyColumn := FindPrimaryKeyColumn(Table1)
|
||||
OtvetColumnName := FindTextConvertGolangTypeToProtobufType(Table1, PrimaryKeyColumn, "")
|
||||
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(ID)", OtvetColumnName)
|
||||
Otvet = strings.ReplaceAll(Otvet, "(ID int64", "(ID "+PrimaryKeyColumn.TypeGo)
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// ReplaceOtvetIDEqual1 - заменяет Otvet.ID = -1
|
||||
func ReplaceOtvetIDEqual1(Text string, Table1 *types.Table) string {
|
||||
Otvet := Text
|
||||
|
||||
PrimaryKeyColumn := FindPrimaryKeyColumn(Table1)
|
||||
Value := FindNegativeValue(PrimaryKeyColumn.TypeGo)
|
||||
|
||||
Otvet = strings.ReplaceAll(Otvet, "Otvet.ID = -1", "Otvet.ID = "+Value)
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// FindNegativeValue - возвращает -1 для числовых типов
|
||||
func FindNegativeValue(TypeGo string) string {
|
||||
Otvet := ""
|
||||
|
||||
Otvet = FindTextDefaultValue(TypeGo)
|
||||
if mini_func.IsNumberType(TypeGo) == true {
|
||||
Otvet = "-1"
|
||||
}
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
@ -227,6 +227,16 @@ func CreateFilesTest(Table1 *types.Table) error {
|
||||
TextDB = create_files.DeleteFuncTestDelete(TextDB, Table1)
|
||||
TextDB = create_files.DeleteFuncTestRestore(TextDB, Table1)
|
||||
TextDB = create_files.DeleteFuncTestFind_byExtID(TextDB, Table1)
|
||||
|
||||
//Postgres_ID_Test = ID Minimum
|
||||
TextDB = create_files.Replace_Postgres_ID_Test(TextDB, Table1)
|
||||
|
||||
//замена ID на PrimaryKey
|
||||
TextDB = create_files.ReplacePrimaryKeyOtvetID(TextDB, Table1)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextDB = create_files.CheckAndAddImportUUID_FromText(TextDB)
|
||||
|
||||
}
|
||||
|
||||
//создание текста
|
||||
@ -241,23 +251,9 @@ func CreateFilesTest(Table1 *types.Table) error {
|
||||
}
|
||||
TextDB = create_files.DeleteFuncTestFind_byExtID(TextDB, Table1)
|
||||
|
||||
//Postgres_ID_Test = ID Minimum
|
||||
if Table1.IDMinimum != "" {
|
||||
TextFind := "const Postgres_ID_Test = "
|
||||
ColumnPrimary := create_files.FindPrimaryKeyColumn(Table1)
|
||||
if ColumnPrimary.TypeGo == "uuid.UUID" {
|
||||
TextDB = strings.ReplaceAll(TextDB, TextFind+"0", TextFind+`var Postgres_ID_Test, _ = uuid.Parse("`+TextFind+Table1.IDMinimum+`")`)
|
||||
} else {
|
||||
TextDB = strings.ReplaceAll(TextDB, TextFind+"0", TextFind+Table1.IDMinimum)
|
||||
}
|
||||
}
|
||||
|
||||
//SkipNow() если нет строк в БД
|
||||
TextDB = create_files.AddSkipNow(TextDB, Table1)
|
||||
|
||||
//замена ID на PrimaryKey
|
||||
TextDB = create_files.ReplacePrimaryKeyOtvetID(TextDB, Table1)
|
||||
|
||||
//замена импортов на новые URL
|
||||
TextDB = create_files.ReplaceServiceURLImports(TextDB)
|
||||
|
||||
@ -562,6 +558,7 @@ func CreateFilesUpdateEveryColumn(Table1 *types.Table) error {
|
||||
ModelTableURL := create_files.FindModelTableURL(TableName)
|
||||
TextCrud = create_files.AddImport(TextCrud, ModelTableURL)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextCrud = create_files.CheckAndAddImportUUID_FromText(TextCrud)
|
||||
//TextCrud = create_files.ConvertRequestIdToAlias(TextCrud, Table1)
|
||||
}
|
||||
@ -628,7 +625,7 @@ func FindTextUpdateEveryColumn1(TextCrudUpdateFunc string, Table1 *types.Table,
|
||||
ModelName := Table1.NameGo
|
||||
ColumnName := Column1.NameGo
|
||||
FuncName := "Update_" + ColumnName
|
||||
TextRequest, TextRequestFieldName := create_files.FindTextProtobufRequest(Column1.TypeGo)
|
||||
TextRequest, TextRequestFieldName := create_files.FindTextProtobufRequest(Table1, Column1.TypeGo)
|
||||
|
||||
//заменяем Read_ctx()
|
||||
Otvet = strings.ReplaceAll(Otvet, " Read_ctx ", " "+FuncName+"_ctx ")
|
||||
@ -771,7 +768,7 @@ func FindTextUpdateEveryColumnTest1(TextCrudUpdateFunc string, Table1 *types.Tab
|
||||
ModelName := Table1.NameGo
|
||||
ColumnName := Column1.NameGo
|
||||
FuncName := "Update_" + ColumnName
|
||||
TextRequest, TextRequestFieldName := create_files.FindTextProtobufRequest(Column1.TypeGo)
|
||||
TextRequest, TextRequestFieldName := create_files.FindTextProtobufRequest(Table1, Column1.TypeGo)
|
||||
DefaultValue := create_files.FindTextDefaultValue(Column1.TypeGo)
|
||||
|
||||
Otvet = strings.ReplaceAll(Otvet, config.Settings.TEXT_TEMPLATE_TABLENAME, Table1.Name)
|
||||
|
||||
@ -89,6 +89,9 @@ func CreateGRPCClient() error {
|
||||
TextGRPCClient = strings.ReplaceAll(TextGRPCClient, ServiceNameTemplate, ServiceName)
|
||||
TextGRPCClient = strings.ReplaceAll(TextGRPCClient, strings.ToUpper(ServiceNameTemplate), strings.ToUpper(ServiceName))
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPCClient = create_files.CheckAndAddImportUUID_FromText(TextGRPCClient)
|
||||
|
||||
}
|
||||
|
||||
//заменим имя сервиса на новое
|
||||
|
||||
@ -51,9 +51,9 @@ func CreateAllFiles(MapAll map[string]*types.Table) error {
|
||||
}
|
||||
|
||||
//тестовые файлы grpc_client update
|
||||
err = CreateTestFilesUpdateEveryColumn(Table1)
|
||||
err = CreateFilesUpdateEveryColumnTest(Table1)
|
||||
if err != nil {
|
||||
log.Error("CreateTestFilesUpdateEveryColumn() table: ", Table1.Name, " error: ", err)
|
||||
log.Error("CreateFilesUpdateEveryColumnTest() table: ", Table1.Name, " error: ", err)
|
||||
return err
|
||||
}
|
||||
|
||||
@ -149,6 +149,16 @@ func CreateFiles(Table1 *types.Table) error {
|
||||
//grpc_nrpc
|
||||
GRPC_NRPC_URL := create_files.Find_GRPC_NRPC_URL()
|
||||
TextGRPCClient = create_files.AddImport(TextGRPCClient, GRPC_NRPC_URL)
|
||||
|
||||
//замена ID на PrimaryKey
|
||||
TextGRPCClient = create_files.ReplacePrimaryKeyM_ID(TextGRPCClient, Table1)
|
||||
|
||||
//замена RequestId{}
|
||||
TextGRPCClient = create_files.ReplaceTextRequestID_PrimaryKey(TextGRPCClient, Table1)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPCClient = create_files.CheckAndAddImportUUID_FromText(TextGRPCClient)
|
||||
|
||||
}
|
||||
|
||||
//удалим лишние функции
|
||||
@ -205,6 +215,19 @@ func CreateFilesTest(Table1 *types.Table) error {
|
||||
|
||||
ModelTableName := create_files.FindModelTableURL(TableName)
|
||||
TextGRPCClient = create_files.AddImport(TextGRPCClient, ModelTableName)
|
||||
|
||||
//Postgres_ID_Test = ID Minimum
|
||||
TextGRPCClient = create_files.Replace_Postgres_ID_Test(TextGRPCClient, Table1)
|
||||
|
||||
//замена ID на PrimaryKey
|
||||
TextGRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextGRPCClient, Table1)
|
||||
|
||||
//замена Otvet.ID = -1
|
||||
TextGRPCClient = create_files.ReplaceOtvetIDEqual1(TextGRPCClient, Table1)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPCClient = create_files.CheckAndAddImportUUID_FromText(TextGRPCClient)
|
||||
|
||||
}
|
||||
|
||||
//создание текста
|
||||
@ -448,6 +471,10 @@ func CreateFilesUpdateEveryColumn(Table1 *types.Table) error {
|
||||
TextGRPC_Client = create_files.CheckAndAddImportTime_FromText(TextGRPC_Client)
|
||||
TextGRPC_Client = create_files.CheckAndAddImportTimestamp_FromText(TextGRPC_Client)
|
||||
TextGRPC_Client = create_files.CheckAndAddImportAlias(TextGRPC_Client)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPC_Client = create_files.CheckAndAddImportUUID_FromText(TextGRPC_Client)
|
||||
|
||||
}
|
||||
|
||||
//удаление пустых строк
|
||||
@ -497,6 +524,16 @@ func FindTextUpdateEveryColumn1(TextGRPC_ClientUpdateFunc string, Table1 *types.
|
||||
FuncName := "Update_" + ColumnName
|
||||
TextRequest, TextRequestFieldName, _, _ := create_files.FindTextProtobufRequest_ID_Type(Table1, Column1, "Request.")
|
||||
|
||||
//замена RequestId{}
|
||||
Otvet = create_files.ReplaceTextRequestID(Otvet, Table1)
|
||||
|
||||
//
|
||||
Otvet = create_files.ReplacePrimaryKeyM_ID(Otvet, Table1)
|
||||
|
||||
//замена ID на PrimaryKey
|
||||
Otvet = create_files.ReplacePrimaryKeyM_ID(Otvet, Table1)
|
||||
|
||||
//
|
||||
ColumnNameGolang := create_files.FindTextConvertGolangTypeToProtobufType(Table1, Column1, "m.")
|
||||
|
||||
_, IDTypeGo := create_files.FindPrimaryKeyNameTypeGo(Table1)
|
||||
@ -508,15 +545,15 @@ func FindTextUpdateEveryColumn1(TextGRPC_ClientUpdateFunc string, Table1 *types.
|
||||
Otvet = strings.ReplaceAll(Otvet, config.Settings.TEXT_TEMPLATE_TABLENAME, Table1.Name)
|
||||
Otvet = strings.ReplaceAll(Otvet, "grpc_proto.RequestId", "grpc_proto."+TextRequest)
|
||||
Otvet = strings.ReplaceAll(Otvet, "m.ColumnName", ColumnNameGolang)
|
||||
Otvet = strings.ReplaceAll(Otvet, " m.ID", " "+IDTypeGo+"(m.ID)")
|
||||
Otvet = strings.ReplaceAll(Otvet, "int64(m.ID)", " "+IDTypeGo+"(m.ID)")
|
||||
Otvet = strings.ReplaceAll(Otvet, "ColumnName", ColumnName)
|
||||
Otvet = strings.ReplaceAll(Otvet, "Request.FieldName", "Request."+TextRequestFieldName)
|
||||
|
||||
return Otvet
|
||||
}
|
||||
|
||||
// CreateTestFilesUpdateEveryColumn - создаёт 1 файл в папке grpc_client
|
||||
func CreateTestFilesUpdateEveryColumn(Table1 *types.Table) error {
|
||||
// CreateFilesUpdateEveryColumnTest - создаёт 1 файл в папке grpc_client
|
||||
func CreateFilesUpdateEveryColumnTest(Table1 *types.Table) error {
|
||||
var err error
|
||||
|
||||
TableName := strings.ToLower(Table1.Name)
|
||||
@ -575,6 +612,9 @@ func CreateTestFilesUpdateEveryColumn(Table1 *types.Table) error {
|
||||
TextGRPC_Client = create_files.AddImport(TextGRPC_Client, ModelTableURL)
|
||||
|
||||
//TextGRPC_Client = create_files.ConvertRequestIdToAlias(TextGRPC_Client, Table1)
|
||||
|
||||
TextGRPC_Client = create_files.ReplacePrimaryKeyOtvetID(TextGRPC_Client, Table1)
|
||||
|
||||
}
|
||||
|
||||
//создание текста
|
||||
@ -588,8 +628,14 @@ func CreateTestFilesUpdateEveryColumn(Table1 *types.Table) error {
|
||||
//TextGRPC_Client = strings.ReplaceAll(TextGRPC_Client, config.Settings.TEXT_TEMPLATE_TABLENAME, Table1.Name)
|
||||
TextGRPC_Client = TextGRPC_Client + TextUpdateEveryColumn
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPC_Client = create_files.CheckAndAddImportUUID_FromText(TextGRPC_Client)
|
||||
|
||||
//
|
||||
TextGRPC_Client = config.Settings.TEXT_MODULE_GENERATED + TextGRPC_Client
|
||||
|
||||
//TextGRPC_Client = create_files.ReplaceTextRequestID(TextGRPC_Client, Table1)
|
||||
|
||||
//SkipNow() если нет строк в БД
|
||||
TextGRPC_Client = create_files.AddSkipNow(TextGRPC_Client, Table1)
|
||||
|
||||
@ -638,6 +684,10 @@ func FindTextUpdateEveryColumnTest(TextGRPC_ClientUpdateFunc string, Table1 *typ
|
||||
func FindTextUpdateEveryColumnTest1(TextGRPC_ClientUpdateFunc string, Table1 *types.Table, Column1 *types.Column) string {
|
||||
Otvet := TextGRPC_ClientUpdateFunc
|
||||
|
||||
Otvet = create_files.ReplaceTextRequestID(Otvet, Table1)
|
||||
Otvet = create_files.ReplacePrimaryKeyM_ID(Otvet, Table1)
|
||||
Otvet = create_files.ReplacePrimaryKeyOtvetID(Otvet, Table1)
|
||||
|
||||
ModelName := Table1.NameGo
|
||||
ColumnName := Column1.NameGo
|
||||
FuncName := "Update_" + ColumnName
|
||||
@ -722,6 +772,16 @@ func CreateFiles_GRPC_Client_Cache(Table1 *types.Table) error {
|
||||
//grpc_nrpc
|
||||
GRPC_NRPC_URL := create_files.Find_GRPC_NRPC_URL()
|
||||
TextGRPCClient = create_files.AddImport(TextGRPCClient, GRPC_NRPC_URL)
|
||||
|
||||
//замена RequestId{}
|
||||
TextGRPCClient = create_files.ReplaceTextRequestID_PrimaryKey(TextGRPCClient, Table1)
|
||||
|
||||
//замена int64(ID) на ID
|
||||
TextGRPCClient = create_files.ReplaceIDtoID(TextGRPCClient, Table1)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPCClient = create_files.CheckAndAddImportUUID_FromText(TextGRPCClient)
|
||||
|
||||
}
|
||||
|
||||
//удаление пустого импорта
|
||||
@ -789,6 +849,12 @@ func CreateFiles_GRPC_Client_Cache_Test(Table1 *types.Table) error {
|
||||
////constants GRPC
|
||||
//RepositoryGRPCConstantsURL := create_files.FindGRPCConstantsURL()
|
||||
//TextGRPCClient = create_files.AddImport(TextGRPCClient, RepositoryGRPCConstantsURL)
|
||||
|
||||
// замена ID на PrimaryKey
|
||||
TextGRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextGRPCClient, Table1)
|
||||
|
||||
//добавим импорт uuid
|
||||
TextGRPCClient = create_files.CheckAndAddImportUUID_FromText(TextGRPCClient)
|
||||
}
|
||||
|
||||
//создание текста
|
||||
@ -797,9 +863,6 @@ func CreateFiles_GRPC_Client_Cache_Test(Table1 *types.Table) error {
|
||||
TextGRPCClient = strings.ReplaceAll(TextGRPCClient, config.Settings.TEXT_TEMPLATE_TABLENAME, Table1.Name)
|
||||
TextGRPCClient = config.Settings.TEXT_MODULE_GENERATED + TextGRPCClient
|
||||
|
||||
// замена ID на PrimaryKey
|
||||
TextGRPCClient = create_files.ReplacePrimaryKeyOtvetID(TextGRPCClient, Table1)
|
||||
|
||||
//SkipNow()
|
||||
TextGRPCClient = create_files.AddSkipNow(TextGRPCClient, Table1)
|
||||
|
||||
|
||||
@ -135,7 +135,7 @@ func FindTextProtoTable1(TextProto string, Table1 *types.Table) string {
|
||||
Otvet := "\n" //"\n\t//\n"
|
||||
|
||||
ModelName := Table1.NameGo
|
||||
Otvet = Otvet + FindTextRead(TextProto, ModelName)
|
||||
Otvet = Otvet + FindTextRead(TextProto, Table1)
|
||||
Otvet = Otvet + FindTextCreate(TextProto, ModelName)
|
||||
Otvet = Otvet + FindTextUpdate(TextProto, ModelName)
|
||||
Otvet = Otvet + FindTextSave(TextProto, ModelName)
|
||||
@ -155,9 +155,9 @@ func FindTextProtoTable1(TextProto string, Table1 *types.Table) string {
|
||||
}
|
||||
|
||||
// FindTextRead - возвращает текст .proto
|
||||
func FindTextRead(TextProto string, ModelName string) string {
|
||||
func FindTextRead(TextProto string, Table1 *types.Table) string {
|
||||
Otvet := ""
|
||||
Otvet2 := TextRead(ModelName)
|
||||
Otvet2 := TextRead(Table1)
|
||||
|
||||
//проверка такой текст уже есть
|
||||
pos1 := strings.Index(TextProto, Otvet2)
|
||||
@ -267,8 +267,13 @@ func FindTextFindByExtId(TextProto string, ModelName string) string {
|
||||
}
|
||||
|
||||
// TextRead - возвращает текст .proto
|
||||
func TextRead(ModelName string) string {
|
||||
Otvet := "rpc " + ModelName + "_Read(RequestId) returns (Response) {}"
|
||||
func TextRead(Table1 *types.Table) string {
|
||||
ModelName := Table1.NameGo
|
||||
PrimaryKeyColumn := create_files.FindPrimaryKeyColumn(Table1)
|
||||
TypeGo := PrimaryKeyColumn.TypeGo
|
||||
TextRequest := "RequestId"
|
||||
TextRequest, _ = create_files.FindTextProtobufRequest(Table1, TypeGo)
|
||||
Otvet := "rpc " + ModelName + "_Read(" + TextRequest + ") returns (Response) {}"
|
||||
|
||||
return Otvet
|
||||
}
|
||||
@ -413,7 +418,7 @@ func FindTextReadFromCache(TextProto string, Table1 *types.Table) string {
|
||||
// TextReadFromCache - возвращает текст .proto
|
||||
func TextReadFromCache(Table1 *types.Table) string {
|
||||
Column1 := create_files.FindPrimaryKeyColumn(Table1)
|
||||
TextRequestId, _ := create_files.FindTextProtobufRequest(Column1.TypeGo)
|
||||
TextRequestId, _ := create_files.FindTextProtobufRequest(Table1, Column1.TypeGo)
|
||||
ModelName := Table1.NameGo
|
||||
Otvet := "rpc " + ModelName + "_ReadFromCache(" + TextRequestId + ") returns (Response) {}"
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user