test

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" {

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),
 );