init

order/sendPurchaseEmail/main.go

@@ -69,19 +69,19 @@ func main() {
 		util.Configs.Rabbitmq_ichunt.Dns,
 		util.Configs.Rabbitmq_ichunt.Dns,
 	}
 	}
 
 
-	for i:=0;i<= 100;i++{
-		logger.Debug("Debug记录日志555555555555555555555555555555")
-		logger.Trace("Trace记录日志555555555555555555555555555555")
-		logger.Info("Info记录日志555555555555555555555555555555")
-		logger.Warn("Warn记录日志555555555555555555555555555555")
-		logger.Error("Error记录日志555555555555555555555555555555")
-		logger.Fatal("Fatal记录日志555555555555555555555555555555")
-	}
+	//for i:=0;i<= 100;i++{
+	//	logger.Debug("Debug记录日志555555555555555555555555555555")
+	//	logger.Trace("Trace记录日志555555555555555555555555555555")
+	//	logger.Info("Info记录日志555555555555555555555555555555")
+	//	logger.Warn("Warn记录日志555555555555555555555555555555")
+	//	logger.Error("Error记录日志555555555555555555555555555555")
+	//	logger.Fatal("Fatal记录日志555555555555555555555555555555")
+	//}
 
 
 	for{
 	for{
 		var wg sync.WaitGroup
 		var wg sync.WaitGroup
 		fmt.Println("开始执行任务....")
 		fmt.Println("开始执行任务....")
-		for i := 0;i<1;i++{
+		for i := 0;i<2;i++{
 			wg.Add(1)
 			wg.Add(1)
 			go func(wg *sync.WaitGroup){
 			go func(wg *sync.WaitGroup){
 				mq := rabbitmq.New(queueExchange)
 				mq := rabbitmq.New(queueExchange)