fix

initalize/rabbitmq.go

@@ -6,11 +6,12 @@ import (
 	"errors"
 	"fusenapi/constants"
 	"fusenapi/utils/mq_consumer_factory"
-	"github.com/streadway/amqp"
-	"github.com/zeromicro/go-zero/core/logx"
 	"log"
 	"strings"
 	"sync"
+
+	"github.com/streadway/amqp"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 type RabbitMqHandle struct {

model/gmodel/fs_user_logic.go

@@ -143,7 +143,7 @@ func (u *FsUserModel) RegisterByFusen(ctx context.Context, token *auth.RegisterT
 
 	logcontent := ""
 	defer func() {
-		logx.Info("aaaa:", logcontent, err)
+		logx.Info("aaaa:", logcontent, " ", err.Error())
 	}()
 
 	err = u.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {

server/websocket/etc/websocket.yaml

@@ -10,7 +10,7 @@ Auth:
     AccessSecret: fusen2023
     AccessExpire: 2592000
     RefreshAfter: 1592000
-SourceRabbitMq:   #amqp://rabbit001:rabbit001129@110.41.19.98:5672
+SourceRabbitMq: "amqp://rabbit001:rabbit001129@110.41.19.98:5672"
 AWS:
     S3:
         Credentials: