сделал context.Background()

bin/templates/configs_/findmassby_functions_tink.json

@@ -4,6 +4,7 @@
 {"Table":"tinkoff_instrument","Columns":["instrument_type", "currency"]},
 {"Table":"tinkoff_instrument","Columns":["instrument_type", "trading_status_id", "for_qual_investor_flag"]},
 {"Table":"tinkoff_instrument","Columns":["instrument_type", "trading_status_id", "for_qual_investor_flag", "api_trade_available_flag"]},
+{"Table":"tinkoff_instrument","Columns":["instrument_type", "for_qual_investor_flag", "api_trade_available_flag"]},
 {"Table":"moex_securities_all","Columns":["group", "is_traded"]},
 {"Table":"my_bond","Columns":["account_id"]},
 {"Table":"my_bond_settings","Columns":["account_id"]},

bin/templates/pkg/db/crud/crud_table_cache.go_

@@ -9,6 +9,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"github.com/ManyakRus/starter/postgres_gorm"
 	"gorm.io/gorm"
+	"sync/atomic"
 )
 
 // cache - кэш с данными
@@ -30,7 +31,8 @@ func (crud Crud_DB) ReadFromCache(ID int64) (lawsuit_status_types.LawsuitStatusT
 	var Otvet lawsuit_status_types.LawsuitStatusType
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -46,6 +48,11 @@ func ReadFromCache_ctx(ctx context.Context, db *gorm.DB, ID int64) (lawsuit_stat
 	var Otvet lawsuit_status_types.LawsuitStatusType
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	// поищем сначала в кэше
 	Identifier := int64(ID)
 	Otvet, ok := cache.Get(Identifier)

bin/templates/pkg/db/crud/crud_table_update.go_

@@ -9,6 +9,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"gorm.io/gorm"
+	"sync/atomic"
 	"time"
 )
 
@@ -17,7 +18,8 @@ import (
 func (crud Crud_DB) UpdateManyFields(m *lawsuit_status_types.LawsuitStatusType, MassNeedUpdateFields []string) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -32,6 +34,12 @@ func (crud Crud_DB) UpdateManyFields(m *lawsuit_status_types.LawsuitStatusType,
 // MassNeedUpdateFields - список полей структуры golang для обновления
 func UpdateManyFields_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType, MassNeedUpdateFields []string) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err

bin/templates/pkg/db/crud/crud_table_update_func.go_

@@ -2,7 +2,8 @@
 func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -17,6 +18,11 @@ func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 func Read_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err

bin/templates/pkg/db/crud/crud_tables.go_

@@ -12,6 +12,7 @@ import (
 	"github.com/ManyakRus/starter/contextmain"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/crud_functions"
 	"gorm.io/gorm"
+	"sync/atomic"
 )
 
 // TableName - имя таблицы в БД Postgres
@@ -25,7 +26,8 @@ type Crud_DB struct {
 func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -39,6 +41,11 @@ func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 func Read_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -57,7 +64,8 @@ func Read_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitS
 
 // Save - записывает новый или существующий объект в базу данных
 func (crud Crud_DB) Save(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -70,6 +78,12 @@ func (crud Crud_DB) Save(m *lawsuit_status_types.LawsuitStatusType) error {
 // Save_ctx - записывает новый или существующий объект в базу данных
 func Save_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -81,7 +95,8 @@ func Save_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitS
 
 // Update - записывает существующий объект в базу данных
 func (crud Crud_DB) Update(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -94,6 +109,12 @@ func (crud Crud_DB) Update(m *lawsuit_status_types.LawsuitStatusType) error {
 // Update_ctx - записывает существующий объект в базу данных
 func Update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -112,7 +133,8 @@ func Update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.Lawsui
 
 // Create - записывает новый объект в базу данных
 func (crud Crud_DB) Create(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -125,6 +147,12 @@ func (crud Crud_DB) Create(m *lawsuit_status_types.LawsuitStatusType) error {
 // Create_ctx - записывает новый объект в базу данных
 func Create_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -145,7 +173,8 @@ func Create_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.Lawsui
 func (crud Crud_DB) create_update(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -159,6 +188,10 @@ func (crud Crud_DB) create_update(m *lawsuit_status_types.LawsuitStatusType) err
 func create_update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType, MassNeedUpdateFields []string) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
 	// log.Trace("start Save() ", TableName, " id: ", int64(m.ID))
 
 	if micro.ContextDone(ctx) == true {
@@ -216,7 +249,8 @@ func create_update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types
 func (crud Crud_DB) Restore(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -230,6 +264,11 @@ func (crud Crud_DB) Restore(m *lawsuit_status_types.LawsuitStatusType) error {
 func Restore_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -263,7 +302,8 @@ func (crud Crud_DB) Find_ByExtID(m *lawsuit_status_types.LawsuitStatusType) erro
 	}
 
 	//
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -278,6 +318,11 @@ func (crud Crud_DB) Find_ByExtID(m *lawsuit_status_types.LawsuitStatusType) erro
 func Find_ByExtID_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -305,7 +350,8 @@ func Find_ByExtID_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.
 func (crud Crud_DB) Delete(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -319,6 +365,11 @@ func (crud Crud_DB) Delete(m *lawsuit_status_types.LawsuitStatusType) error {
 func Delete_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err

bin/templates/pkg/db/crud/crud_tables_findby.go_

@@ -6,6 +6,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"gorm.io/gorm"
+	"sync/atomic"
 	"time"
 )
 

bin/templates/pkg/db/crud/crud_tables_findby_function.go_

@@ -2,7 +2,8 @@
 func (crud Crud_DB) FindBy_FieldNamesWithUnderline(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := context.Background()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -17,6 +18,11 @@ func (crud Crud_DB) FindBy_FieldNamesWithUnderline(m *lawsuit_status_types.Lawsu
 func FindBy_FieldNamesWithUnderline_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	tx := db.WithContext(ctx)
 
 	tx = tx.Where(`"ColumnName" = ?`, m.FieldName)

bin/templates/pkg/db/crud/crud_tables_findmassby.go_

@@ -6,6 +6,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"gorm.io/gorm"
+	"sync/atomic"
 	"time"
 )
 

bin/templates/pkg/db/crud/crud_tables_findmassby_function.go_

@@ -3,7 +3,8 @@ func (crud Crud_DB) FindMassBy_FieldNamesWithUnderline(m *lawsuit_status_types.L
 	Otvet := make([]lawsuit_status_types.LawsuitStatusType, 0)
 	var err error
 
-	ctxMain := context.Background()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -19,6 +20,11 @@ func FindMassBy_FieldNamesWithUnderline_ctx(ctx context.Context, db *gorm.DB, m
 	var err error
 	Otvet := make([]lawsuit_status_types.LawsuitStatusType, 0)
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	tx := db.WithContext(ctx)
 
 	tx = tx.Where(`"ColumnName" = ?`, m.FieldName)

bin/templates/pkg/db/crud/crud_tables_findmodelby.go_

@@ -6,6 +6,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"gorm.io/gorm"
+	"sync/atomic"
 	"time"
 )
 

bin/templates/pkg/db/crud/crud_tables_findmodelby_function.go_

@@ -2,7 +2,8 @@
 func (crud Crud_DB) FindModelBy_FieldNamesWithUnderline(m *lawsuit_status_types.LawsuitStatusType) (foreign_package.ForeignModel, error) {
 	var err error
 
-	ctxMain := context.Background()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -18,6 +19,11 @@ func FindModelBy_FieldNamesWithUnderline_ctx(ctx context.Context, db *gorm.DB, m
 	Otvet := foreign_package.ForeignModel{}
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	tx := db.WithContext(ctx)
 	
 	//находим запись в этой таблице

bin/templates/pkg/db/crud/crud_tables_rapira.go_

@@ -8,10 +8,11 @@ import (
 	"github.com/ManyakRus/starter/postgres_gorm"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
-	"time"
 	"github.com/ManyakRus/starter/contextmain"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/crud_functions"
 	"gorm.io/gorm"
+	"sync/atomic"
+	"time"
 )
 
 // TableName - имя таблицы в БД Postgres
@@ -25,7 +26,8 @@ type Crud_DB struct {
 func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -39,6 +41,11 @@ func (crud Crud_DB) Read(m *lawsuit_status_types.LawsuitStatusType) error {
 func Read_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -57,7 +64,8 @@ func Read_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitS
 
 // Save - записывает новый или существующий объект в базу данных
 func (crud Crud_DB) Save(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -70,6 +78,12 @@ func (crud Crud_DB) Save(m *lawsuit_status_types.LawsuitStatusType) error {
 // Save_ctx - записывает новый или существующий объект в базу данных
 func Save_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -81,7 +95,8 @@ func Save_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitS
 
 // Update - записывает существующий объект в базу данных
 func (crud Crud_DB) Update(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -94,6 +109,12 @@ func (crud Crud_DB) Update(m *lawsuit_status_types.LawsuitStatusType) error {
 // Update_ctx - записывает существующий объект в базу данных
 func Update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -112,7 +133,8 @@ func Update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.Lawsui
 
 // Create - записывает новый объект в базу данных
 func (crud Crud_DB) Create(m *lawsuit_status_types.LawsuitStatusType) error {
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -125,6 +147,12 @@ func (crud Crud_DB) Create(m *lawsuit_status_types.LawsuitStatusType) error {
 // Create_ctx - записывает новый объект в базу данных
 func Create_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
+
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -145,7 +173,8 @@ func Create_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.Lawsui
 func (crud Crud_DB) create_update(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -159,8 +188,11 @@ func (crud Crud_DB) create_update(m *lawsuit_status_types.LawsuitStatusType) err
 func create_update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType, MassNeedUpdateFields []string) error {
 	var err error
 
-	// log.Trace("start Save() ", TableName, " id: ", int64(m.ID))
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
 
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -216,7 +248,8 @@ func create_update_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types
 func (crud Crud_DB) Delete(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -230,6 +263,11 @@ func (crud Crud_DB) Delete(m *lawsuit_status_types.LawsuitStatusType) error {
 func Delete_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -257,7 +295,8 @@ func Delete_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.Lawsui
 func (crud Crud_DB) Restore(m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -271,6 +310,11 @@ func (crud Crud_DB) Restore(m *lawsuit_status_types.LawsuitStatusType) error {
 func Restore_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err
@@ -304,7 +348,8 @@ func (crud Crud_DB) Find_ByExtID(m *lawsuit_status_types.LawsuitStatusType) erro
 	}
 
 	//
-	ctxMain := contextmain.GetContext()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -319,6 +364,11 @@ func (crud Crud_DB) Find_ByExtID(m *lawsuit_status_types.LawsuitStatusType) erro
 func Find_ByExtID_ctx(ctx context.Context, db *gorm.DB, m *lawsuit_status_types.LawsuitStatusType) error {
 	var err error
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	if micro.ContextDone(ctx) == true {
 		err = context.Canceled
 		return err

bin/templates/pkg/db/crud/crud_tables_readall.go_

@@ -6,6 +6,7 @@ import (
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/db/db_constants"
 	"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
 	"gorm.io/gorm"
+	"sync/atomic"
 	"time"
 )
 

bin/templates/pkg/db/crud/crud_tables_readall_function.go_

@@ -3,7 +3,8 @@ func (crud Crud_DB) ReadAll() ([]lawsuit_status_types.LawsuitStatusType, error)
 	Otvet := make([]lawsuit_status_types.LawsuitStatusType, 0)
 	var err error
 
-	ctxMain := context.Background()
+	ctxMain := context.Background() //операцию надо выполнить, даже при отмене контекста
+	//ctxMain := contextmain.GetContext()
 	ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(db_constants.TIMEOUT_DB_SECONDS))
 	defer ctxCancelFunc()
 
@@ -19,6 +20,11 @@ func ReadAll_ctx(ctx context.Context, db *gorm.DB) ([]lawsuit_status_types.Lawsu
 	var err error
 	Otvet := make([]lawsuit_status_types.LawsuitStatusType, 0)
 
+	//количество невыполненных операций +1 -1
+	atomic.AddInt32(&stopapp.TotalMessagesSendingNow, 1)
+	defer atomic.AddInt32(&stopapp.TotalMessagesSendingNow, -1)
+
+	//
 	tx := db.WithContext(ctx)
 	
 	tx = tx.Where("is_deleted = ?", false)