diff --git a/app/services/transfersys/transfersys_rdb.go b/app/services/transfersys/transfersys_rdb.go index 25b702e..b29783a 100644 --- a/app/services/transfersys/transfersys_rdb.go +++ b/app/services/transfersys/transfersys_rdb.go @@ -62,7 +62,7 @@ func WriteOrder() { return } // 创建价格分组 - var queue_nos = [...]int{-1, 10, 20, 50, 100, 1000, 102, 10210, 10220, 10250, 102100, 1021000} + var queue_nos = [...]int{-5, -4, -3, -2, -1, 10, 20, 50, 100, 1000, 102, 10210, 10220, 10250, 102100, 1021000} for _, value := range queue_nos { err = rdbmq.CreateStreamAndGroup(fmt.Sprintf("orders_%d", value), fmt.Sprintf("orders_%d", value)) if err != nil && err.Error() != "BUSYGROUP Consumer Group name already exists" {