MqttDemo/common/httpClient.js

import {
	requestEncode,
	responseDecode
} from "./protoMap"
//import util from '../common/util'


const URL = 'https://test.ohplay.radio1964.net/Ohplay/Web/HttpToTcp';



function post(request) {
	let requestBuffer = requestEncode(request)
	return uni.request({
		url: URL,
		header: {
			"X-Requested-With": "XMLHttpRequest",
			"Content-Type": "application/x-protobuf",
			'Token': 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VyaWQiOjY1MDYzMywibmFtZSI6IjE4MTI2NDQ3MDE1IiwiZXhwIjoxNjIyODg0NTA1fQ.f7jIm0856-VnynA99MBoA2Dl1pePxI0HT_ECsUp5QHA'
		},
		method: 'POST',
		timeout: 15000,
		dataType: 'protobuf',
		responseType: 'text',
		data: requestBuffer
	}).then((res) => {
		for (let response of res) {
			if (response !== null && response !== undefined && response.statusCode === 200) {
				try {
					console.log(response);
					let resJson = JSON.parse(response.data) //转化成json对象
					console.log(resJson);
					if(resJson.code === 0){
						let base64Str = resJson.data;
						//let base64Str = 'DQMAAAAVAQAAAB0CAAAAJeoDAABKlgEKBBICb2sSjQFleUpoYkdjaU9pSklVekkxTmlJc0luUjVjQ0k2SWtwWFZDSjkuZXlKVmMyVnlhV1FpT2pZNE5EQXhNQ3dpYm1GdFpTSTZJalFpTENKbGVIQWlPakUyTWpNME9EWTRNamg5LlNzRlgzdWJ5UFp4NWRCLXJzZHNDd3NGcjlpLUpJczFXeWJBS2pBS3pwdzQ='
						let buffer = Buffer.from(base64Str,'base64')
						let data = responseDecode(buffer)
						console.log(data);
						let code = 0
						let msg = "success"
						if (typeof data.errInfo !== 'undefined') {
							code = data.errInfo.errorCode
							if (typeof data.errInfo.errorMessage === 'string') {
								msg = data.errInfo.errorMessage
							} else {
								msg = Buffer.from(data.errInfo.errorMessage).toString()
							}
						}
						return {
							code: code,
							msg: msg,
							data: data
						}
					}else{
						return {
							code: resJson.code,
							msg: resJson.info
						}
					}
					
				} catch (e) {
					return {
						code: -1,
						msg: e.toString()
					}
				}
			}
		}
	})

}

module.exports = post