From bdfd021068facbf2a34493dd90aa46a424f3fa12 Mon Sep 17 00:00:00 2001 From: rluisr Date: Sun, 18 Feb 2024 21:41:36 +0900 Subject: [PATCH] refactor: Remove unnecessary log and fmt imports --- pkg/external/cron.go | 16 +++++----------- pkg/usecase/tv_interactor.go | 4 +++- 2 files changed, 8 insertions(+), 12 deletions(-) diff --git a/pkg/external/cron.go b/pkg/external/cron.go index bf82290..24da791 100644 --- a/pkg/external/cron.go +++ b/pkg/external/cron.go @@ -21,8 +21,6 @@ package external import ( - "fmt" - "log" "os" "os/signal" "time" @@ -51,8 +49,11 @@ func Cron() { tvController.Interactor.TVRepository.Logging().Error("NewJob: FetchOrder", err.Error(), err) } - job, err := s.NewJob( - gocron.CronJob("* * * * *", false), + _, err = s.NewJob( + // KeepAlive を続けるために短い間隔で行う + gocron.DurationJob( + 3*time.Second, + ), gocron.NewTask(func() { icErr := tvController.InventoryCheck(5 * time.Minute) if icErr != nil { @@ -68,13 +69,6 @@ func Cron() { s.Start() - nextTime, err := job.NextRun() - if err != nil { - log.Println(err) - return - } - tvController.Interactor.TVRepository.Logging().Info(fmt.Sprintf("Next run: %s", nextTime)) - quit := make(chan os.Signal, 1) signal.Notify(quit, os.Interrupt) <-quit diff --git a/pkg/usecase/tv_interactor.go b/pkg/usecase/tv_interactor.go index 4913c1f..33ebde1 100644 --- a/pkg/usecase/tv_interactor.go +++ b/pkg/usecase/tv_interactor.go @@ -215,7 +215,9 @@ func (i *TVInteractor) InventoryCheck(cancelAfter time.Duration) error { } for _, order := range orders.Result.List { - if order.OrderStatus == bybit.OrderStatusUntriggered { + // New: 新規注文(ポジションは持ってない) + // Untriggered: TP/SL のみの注文(ポジション注文は通っているが、TP/SL 注文がある状態) + if order.OrderStatus == bybit.OrderStatusNew { createdAt, cErr := utils.TimestampMSToTime(order.CreatedTime) if cErr != nil { return cErr