Function SendAndReceive

cli/pkg/common/websocket.go:266–320

* * description: 发送数据到各端 * author: kenan * created on: 2021/4/8 11.03 * param key: business--表示发送给业务服务器，logic--表示逻辑服务器 * param Actioncode: 发送指令 * param ModID: 站点ID（3位前补零）+服务器模块类型（2位前补零），示例为1号站点服务器的数据服务 * param Token: 登录token * param Data: 发送的具体数据 * return return_1: */

(key, Actioncode, ModID, Token string, Data interface{})

* return return_1:
 */
func SendAndReceive(key, Actioncode, ModID, Token string, Data interface{}) (data baseMsg, code int) {
	if httpReqMsgReceiver.maxReceiver < len(httpReqMsgReceiver.receiver) {
		return data, 51002
	}

	cmd := httpReqMsgReceiver.getCmd()
	ch := make(chan []byte)
	pErr := httpReqMsgReceiver.pushMap(cmd, ch)

	defer func() {
		httpReqMsgReceiver.deleteMap(cmd)
		httpReqMsgReceiver.recoverCmd(cmd)
	}()

	if pErr != 200 {
		return data, 51004
	}

	msg := baseMsg{
		Company:    "SmartIDE",
		Actioncode: Actioncode,
		Data:       Data,
		ModID:      ModID,
		Token:      Token,
	}

	msgByte, _ := json.Marshal(msg)
	wsclient.mtx.Lock()
	if clientArr[key] != nil {
		sErr := clientArr[key].WriteMessage(websocket.BinaryMessage, msgByte)
		defer wsclient.mtx.Unlock()
		if sErr != nil {
			return data, 51004
		}

		select {
		case res := <-ch:
			var msg baseMsg
			err := json.Unmarshal([]byte(res), &msg)
			if err != nil {
				WSLog("数据解析失败")
				return data, 51004
			}
			SmartIDELog.ConsoleDebug(fmt.Sprintf("服务器推送数据：%+v\n", msg))
			return msg, msg.Result
		case <-time.After(httpReqMsgReceiver.receiveMsgTimeout):
			SmartIDELog.ConsoleDebug(fmt.Sprintf("接收发送数据：连接超时\n"))
			WSLog("连接超时")
			return data, 51005
		}
	}

	defer wsclient.mtx.Unlock()
	return data, 51006
}

/*
* description: ws接口日志记录器