add log

Author: skiffer-git

open_im_sdk/conversation_msg.go

@@ -3,7 +3,6 @@ package open_im_sdk
 import (
 	"database/sql"
 	"encoding/json"
-	"fmt"
 	"strings"
 )
 
@@ -201,7 +200,7 @@ func (u *UserRelated) doMsgNew(c2v cmd2Value) {
 	u.newMessage(newMessages)
 	u.doUpdateConversation(cmd2Value{Value: updateConNode{"", ConChange, ""}})
 	u.doUpdateConversation(cmd2Value{Value: updateConNode{"", TotalUnreadMessageChanged, ""}})
-	fmt.Println("length msgListenerList", u.MsgListenerList, "length message", len(newMessages), "msgListenerLen", len(u.MsgListenerList))
+	sdkLog("length msgListenerList", u.MsgListenerList, "length message", len(newMessages), "msgListenerLen", len(u.MsgListenerList))
 
 }
 

open_im_sdk/data_model.go

@@ -461,7 +461,7 @@ func (u *UserRelated) judgeConversationIfExists(conversationID string) bool {
 	var count int
 	rows, err := u.Query("select count(*) from conversation where  conversation_id=?", conversationID)
 	if err != nil {
-		fmt.Println("judge err")
+		sdkLog("judge err")
 		sdkLog(err.Error())
 		return false
 	}
@@ -635,7 +635,7 @@ func (u *UserRelated) getMultipleConversationModel(conversationIDList []string)
 	u.mRWMutex.RLock()
 	defer u.mRWMutex.RUnlock()
 	rows, err := u.Query("SELECT * FROM conversation where conversation_id in (" + sqlStringHandle(conversationIDList) + ")")
-	fmt.Println("SELECT * FROM conversation where conversation_id in (" + sqlStringHandle(conversationIDList) + ")")
+	sdkLog("SELECT * FROM conversation where conversation_id in (" + sqlStringHandle(conversationIDList) + ")")
 	for rows.Next() {
 		temp := new(ConversationStruct)
 		err = rows.Scan(&temp.ConversationID, &temp.ConversationType, &temp.UserID, &temp.GroupID, &temp.ShowName,
@@ -748,7 +748,6 @@ func (u *UserRelated) updateBlackList(info userInfo) error {
 	}
 	_, err = stmt.Exec(info.Uid, info.Name, info.Icon, info.Gender, info.Mobile, info.Birth, info.Email, info.Ex)
 	if err != nil {
-		fmt.Println(err)
 		sdkLog(err.Error())
 		return err
 	}
@@ -760,13 +759,11 @@ func (u *UserRelated) delTheUserFromBlackList(uid string) error {
 	defer u.mRWMutex.Unlock()
 	stmt, err := u.Prepare("delete from black_list where uid=?")
 	if err != nil {
-		fmt.Println(err)
 		sdkLog(err.Error())
 		return err
 	}
 	_, err = stmt.Exec(uid)
 	if err != nil {
-		fmt.Println(err)
 		sdkLog(err.Error())
 		return err
 	}
@@ -810,12 +807,12 @@ func (u *UserRelated) updateApplicationList(info applyUserInfo) error {
 	defer u.mRWMutex.Unlock()
 	stmt, err := u.Prepare("replace into friend_request(uid,name,icon,gender,mobile,birth,email,ex,flag,req_message,create_time) values (?,?,?,?,?,?,?,?,?,?,?)")
 	if err != nil {
-		fmt.Println(err.Error())
+		sdkLog(err.Error())
 		return err
 	}
 	_, err = stmt.Exec(info.Uid, info.Name, info.Icon, info.Gender, info.Mobile, info.Birth, info.Email, info.Ex, info.Flag, info.ReqMessage, info.ApplyTime)
 	if err != nil {
-		fmt.Println(err.Error())
+		sdkLog(err.Error())
 		return err
 	}
 	return nil

open_im_sdk/group.go

@@ -3,7 +3,6 @@ package open_im_sdk
 import (
 	"encoding/json"
 	"errors"
-	"fmt"
 	"strings"
 )
 
@@ -548,14 +547,14 @@ func (u *UserRelated) getJoinedGroupListFromSvr() ([]groupInfo, error) {
 	sdkLog("getJoinedGroupListRouter ", getJoinedGroupListRouter, req, u.token)
 	resp, err := post2Api(getJoinedGroupListRouter, req, u.token)
 	if err != nil {
-		fmt.Println("post api:", err)
+		sdkLog("post api:", err)
 		return nil, err
 	}
 
 	var stcResp getJoinedGroupListResp
 	err = json.Unmarshal(resp, &stcResp)
 	if err != nil {
-		fmt.Println("unmarshal, ", err)
+		sdkLog("unmarshal, ", err)
 		return nil, err
 	}
 

open_im_sdk/init_login.go

@@ -542,7 +542,7 @@ func (u *UserRelated) heartbeat() {
 						}
 						LogBegin("syncMsg2ServerMaxSeq", wsSeqResp.MaxSeq, wsSeqResp.MinSeq, wsReq.OperationID)
 						u.syncMsg2ServerMaxSeq(wsSeqResp.MaxSeq)
-						LogEnd("syncMsg2ServerMaxSeq")
+						LogEnd("syncMsg2ServerMaxSeq", wsSeqResp.MaxSeq, wsSeqResp.MinSeq, wsReq.OperationID)
 					}
 				}
 				breakFlag = 1

open_im_sdk/open_im_sdk_conversation_msg.go

@@ -4,7 +4,6 @@ import (
 	//"bytes"
 	//"encoding/gob"
 	"encoding/json"
-	"fmt"
 	"github.com/golang/protobuf/proto"
 	"github.com/gorilla/websocket"
 	"net/http"
@@ -877,7 +876,6 @@ func (u *UserRelated) SendMessage(callback SendMsgCallBack, message, receiver, g
 			soundURL, uuid, err := u.uploadSound(sourcePath, callback)
 			if err != nil {
 				callback.OnError(301, err.Error())
-				fmt.Println("oss Sound upload err", 111)
 				sdkLog("uploadSound err:", err.Error())
 				u.sendMessageFailedHandle(&s, &c, conversationID)
 				return
@@ -1136,7 +1134,7 @@ func (u *UserRelated) SendMessage(callback SendMsgCallBack, message, receiver, g
 
 func (u *UserRelated) GetHistoryMessageList(callback Base, getMessageOptions string) {
 	go func() {
-		fmt.Println("GetHistoryMessageList", getMessageOptions)
+		sdkLog("GetHistoryMessageList", getMessageOptions)
 		var sourceID string
 		var conversationID string
 		var startTime int64
@@ -1168,7 +1166,7 @@ func (u *UserRelated) GetHistoryMessageList(callback Base, getMessageOptions str
 			} else {
 				err := json.Unmarshal([]byte(m), &latestMsg)
 				if err != nil {
-					fmt.Println("get history err :", err)
+					sdkLog("get history err :", err)
 					callback.OnError(200, err.Error())
 					return
 				}
@@ -1178,7 +1176,7 @@ func (u *UserRelated) GetHistoryMessageList(callback Base, getMessageOptions str
 		} else {
 			startTime = p.StartMsg.SendTime
 		}
-		fmt.Println("sourceID:", sourceID, "startTime:", startTime, "count:", p.Count)
+		sdkLog("sourceID:", sourceID, "startTime:", startTime, "count:", p.Count)
 		err, list := u.getHistoryMessage(sourceID, startTime, p.Count, sessionType)
 		sort.Sort(list)
 		if err != nil {
@@ -1324,7 +1322,7 @@ func (u *UserRelated) DeleteMessageFromLocalStorage(callback Base, message strin
 		if m != "" {
 			err := json.Unmarshal([]byte(m), &latestMsg)
 			if err != nil {
-				fmt.Println("DeleteMessage err :", err)
+				sdkLog("DeleteMessage err :", err)
 				callback.OnError(200, err.Error())
 				return
 			}