add save message to mysql switch

internal/msg_transfer/logic/init.go

@@ -2,8 +2,8 @@ package logic
 
 import (
 	"Open_IM/pkg/common/config"
-
 	"Open_IM/pkg/common/kafka"
+	"fmt"
 )
 
 var (
@@ -20,6 +20,10 @@ func Init() {
 }
 func Run() {
 	//register mysqlConsumerHandler to
-	go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH)
+	if config.Config.ChatPersistenceMysql {
+		go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH)
+	} else {
+		fmt.Println("not start mysql consumer")
+	}
 	go historyCH.historyConsumerGroup.RegisterHandleAndConsumer(&historyCH)
 }

internal/msg_transfer/logic/persistent_msg_handler.go

@@ -56,14 +56,10 @@ func (pc *PersistentConsumerHandler) handleChatWs2Mysql(msg []byte, msgKey strin
 			}
 		}
 		if tag {
-			if config.Config.ChatPersistenceMysql == true {
-				log.NewInfo(msgFromMQ.OperationID, "msg_transfer msg persisting", string(msg))
-				if err = im_mysql_msg_model.InsertMessageToChatLog(msgFromMQ); err != nil {
-					log.NewError(msgFromMQ.OperationID, "Message insert failed", "err", err.Error(), "msg", msgFromMQ.String())
-					return
-				}
-			} else {
-				log.Debug(msgFromMQ.OperationID, "don't insert to db", string(msg))
+			log.NewInfo(msgFromMQ.OperationID, "msg_transfer msg persisting", string(msg))
+			if err = im_mysql_msg_model.InsertMessageToChatLog(msgFromMQ); err != nil {
+				log.NewError(msgFromMQ.OperationID, "Message insert failed", "err", err.Error(), "msg", msgFromMQ.String())
+				return
 			}
 		}