diff --git a/transfer_to_clickhouse/main.go b/transfer_to_clickhouse/main.go index e474e8f..85ea3f6 100644 --- a/transfer_to_clickhouse/main.go +++ b/transfer_to_clickhouse/main.go @@ -12,6 +12,9 @@ import ( "go.uber.org/zap" "go.uber.org/zap/zapcore" "log" + "os" + "os/signal" + "syscall" "time" "transfer_to_clickhouse/db" "transfer_to_clickhouse/models" @@ -19,18 +22,21 @@ import ( ) const pgCred = "host=10.8.0.5 port=5433 user=squiz password=Redalert2 dbname=squiz sslmode=disable" -const mongoURLCodeword = "mongodb://test:test@localhost:27020/?authSource=admin" -const mongoDatabaseNameCodeword = "admin" -const mongoURLCustomer = "mongodb://test:test@localhost:27020/?authSource=admin" -const mongoDatabaseNameCustomer = "admin" +const mongoURLCodeword = "mongodb://mongodb.pena:27017/" +const mongoDatabaseNameCodeword = "auth" +const mongoURLCustomer = "mongodb://mongodb.pena:27017/" +const mongoDatabaseNameCustomer = "customer" const trashLogHost1 = ":7113" const moduleLogger1 = "transfer" -const authServiceURL = "" +const authServiceURL = "http://10.7.0.4:59300/user" func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() + stopChan := make(chan os.Signal, 1) + signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM) + logger1, err := zap.NewProduction(zap.AddStacktrace(zap.DPanicLevel)) if err != nil { log.Fatalf("failed to init zap logger 1: %v", err) @@ -129,6 +135,7 @@ func main() { log.Fatalf("invalid set answerer events in quiz answerer: %v", err) } + <-stopChan } func newHlogger(ctx context.Context, logger *zap.Logger, trashLogHost, moduleLogger string) (hlog.Logger, error) { diff --git a/transfer_to_clickhouse/models/codeword.go b/transfer_to_clickhouse/models/codeword.go index 023a5e8..fa26da1 100644 --- a/transfer_to_clickhouse/models/codeword.go +++ b/transfer_to_clickhouse/models/codeword.go @@ -1,13 +1,12 @@ package models type InfoPromocodeCreated struct { - CtxID string //айдишник созданного промокода - CtxUserID string //айдишник юзера из токена - KeyType string //привилегия или скидка. или и то и другое, смотря что заполнено - CtxFactor float64 //множитель скидки - KeyTargetType string //privilege или service - CtxTarget string // айдишник привилегии или сервиса соответственно - CtxAmount int64 // если промик на привилегию + CtxID string //айдишник созданного промокода + CtxUserID string //айдишник юзера из токена + KeyType string //привилегия или скидка. или и то и другое, смотря что заполнено + KeyTargetType string //privilege или service + CtxTarget string // айдишник привилегии или сервиса соответственно + CtxAmount int64 // если промик на привилегию CtxCode string } diff --git a/transfer_to_clickhouse/transfer/codeword.go b/transfer_to_clickhouse/transfer/codeword.go index 350fe84..870f6a7 100644 --- a/transfer_to_clickhouse/transfer/codeword.go +++ b/transfer_to_clickhouse/transfer/codeword.go @@ -189,7 +189,6 @@ func (r *Codeword) EventCreate(ctx context.Context) error { for _, createdPromoCode := range promoCodes { var keyType string - var ctxFactor float64 var keyTargetType string var ctxTarget string var ctxAmount int64 @@ -199,7 +198,6 @@ func (r *Codeword) EventCreate(ctx context.Context) error { keyTargetType = "privilege,service" ctxTarget = fmt.Sprintf("%s,%s", createdPromoCode.Bonus.Privilege.PrivilegeID, createdPromoCode.Bonus.Discount.Target) ctxAmount = int64(createdPromoCode.Bonus.Privilege.Amount) - ctxFactor = createdPromoCode.Bonus.Discount.Factor } else if createdPromoCode.Bonus.Privilege.PrivilegeID != "" { keyType = "privilege" keyTargetType = "privilege" @@ -208,13 +206,11 @@ func (r *Codeword) EventCreate(ctx context.Context) error { } else if createdPromoCode.Bonus.Discount.Factor != 0 && createdPromoCode.Bonus.Discount.Factor != 1 { keyType = "discount" keyTargetType = "service" - ctxFactor = createdPromoCode.Bonus.Discount.Factor ctxTarget = createdPromoCode.Bonus.Discount.Target } r.logger.Emit(models.InfoPromocodeCreated{ CtxID: createdPromoCode.ID.String(), KeyType: keyType, - CtxFactor: ctxFactor, KeyTargetType: keyTargetType, CtxTarget: ctxTarget, CtxAmount: ctxAmount,