1

pool/publicApi.go

@@ -224,6 +224,7 @@ func (c *Client) Send(msg *SendMsg) error {
 		return errors.New("连接ID：" + c.Id + "ws连接己经断开，无法发送消息")
 	default:
 		msg.ToClientId = c.Id
+		fmt.Println(msg)
 		c.send(msg)
 	}
 	return nil
@@ -240,7 +241,7 @@ func (c *Client) Close() {
 // 在此方法中sendMsg.Channel指定的值不会处理
 func Send(msg *SendMsg) error {
 	//log.Info("发送指令：",msg.Cmd,msg.ToClientId)
-	fmt.Println(msg)
+
 	if msg.ToClientId == "" {
 		return errors.New("发送消息的消息体中未指定ToClient目标！")
 	}
@@ -391,11 +392,11 @@ func SaveMsg(msg *SendMsg) {
 		mqData.EndTime = msg.SendTime
 
 		if user.CustomerType == "1" {
-			mqData.Finish = "3"
+			mqData.Finish = "1"
 		}
 
 		if user.CustomerType == "2" {
-			mqData.Finish = "1"
+			mqData.Finish = "2"
 		}
 	}