修复队列名称

cmd/source/customer/customer.go

@@ -23,9 +23,9 @@ func Import(wg *sync.WaitGroup) {
 		wg.Done()
 	}()
 	Exchange = rabbitmq.QueueExchange{
-		"store_customer",
-		"store_customer",
-		"store",
+		"scm_store_customer",
+		"scm_store_customer",
+		"scm_store",
 		"direct",
 		configs.RABBITMQDSN,
 	}

cmd/source/goods/goods.go

@@ -16,9 +16,9 @@ var Exchange rabbitmq.QueueExchange
 //导入委托方的信息(excel导入)
 func Import(wg *sync.WaitGroup) {
 	Exchange = rabbitmq.QueueExchange{
-		"store_goods",
-		"store_goods",
-		"store",
+		"scm_store_goods",
+		"scm_store_goods",
+		"scm_store",
 		"direct",
 		configs.RABBITMQDSN,
 	}

cmd/source/supplier/supplier.go

@@ -25,9 +25,9 @@ func Import(wg *sync.WaitGroup) {
 		wg.Done()
 	}()
 	Exchange = rabbitmq.QueueExchange{
-		"store_supplier",
-		"store_supplier",
-		"store",
+		"scm_store_supplier",
+		"scm_store_supplier",
+		"scm_store",
 		"direct",
 		configs.RABBITMQDSN,
 	}