From 1e4ae43008c6b036f25115cd684ba143fb54c401 Mon Sep 17 00:00:00 2001 From: duyu Date: Wed, 11 Sep 2024 11:51:03 +0800 Subject: [PATCH] test --- app/services/transfersys/transfersys_rdb.go | 2 +- build/sql/db.sql | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app/services/transfersys/transfersys_rdb.go b/app/services/transfersys/transfersys_rdb.go index 1568b76..0d6acde 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{10, 20, 50, 100, 1000} + var queue_nos = [...]int{-1, 10, 20, 50, 100, 1000} 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" { diff --git a/build/sql/db.sql b/build/sql/db.sql index b194b46..ea1dc4f 100644 --- a/build/sql/db.sql +++ b/build/sql/db.sql @@ -40,7 +40,7 @@ create table product ( status tinyint, -- 1.上架 2.下架 created_at timestamp default current_timestamp, -- v2 - type tinyint-- 1.拼多多 2.多多进宝 3. 拼多多+多多进宝 4. 直接返回成功商品 + type tinyint-- 1.拼多多 2.多多进宝 3. 拼多多+多多进宝 4. 直接返回成功商品 5. 淘宝单一规格商品 extend_parameter varchar(1024), );