|
|
@@ -26,362 +26,362 @@ var result_arr = []; |
|
|
|
var errMsg_arr = []; |
|
|
|
var current_device = null; |
|
|
|
export function scanDevice(nameFlag, timeOut, callBack) { |
|
|
|
timeId = setTimeout(res => { |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "扫描超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}) |
|
|
|
}, timeOut); |
|
|
|
ble.scan_StartScanBleDevice(nameFlag, res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
timeId = setTimeout(res => { |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "扫描超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}) |
|
|
|
}, timeOut); |
|
|
|
ble.scan_StartScanBleDevice(nameFlag, res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function stopScanDevice(callBack) { |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function connect(device, callBack) { |
|
|
|
console.log("==========connectDevice_Start==========:" + JSON.stringify(device)); |
|
|
|
receive_data = ""; |
|
|
|
if (current_device != null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: 10004, |
|
|
|
msg: "已连接其他蓝牙设备", |
|
|
|
data: current_device |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
if (device == null || device == "undefined") { |
|
|
|
callBack.call(this, { |
|
|
|
code: 10003, |
|
|
|
msg: "参数错误", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
timeId = setTimeout(res => { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "连接超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, connectTimeOut); |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
console.log(JSON.stringify(res)+"******************************************ldd"); |
|
|
|
if (res.code == config.successCode()) { |
|
|
|
ble.connectDevice(device, res => { |
|
|
|
console.log(JSON.stringify(res)+"******************************************ldd"); |
|
|
|
if (res.code == config.successCode()) { |
|
|
|
ble.findDeviceServices(res.data, res => { |
|
|
|
console.info(JSON.stringify(res)); |
|
|
|
ble.setParams(res.data.id); |
|
|
|
if (res.code != config.successCode()) { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode(), |
|
|
|
msg: "连接失败", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
}, res1 => { |
|
|
|
dealReceiveData(res1.data.value, res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
ICCReset_Protocol(res => { |
|
|
|
if (res.code == 0) { |
|
|
|
current_device = device; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleSuccessCode(), |
|
|
|
msg: "连接成功", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} else { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode(), |
|
|
|
msg: "连接失败,卡复位失败", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
}) |
|
|
|
}) |
|
|
|
}) |
|
|
|
} else { |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
} else { |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
console.log("==========connectDevice_Start==========:" + JSON.stringify(device)); |
|
|
|
receive_data = ""; |
|
|
|
if (current_device != null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: 10004, |
|
|
|
msg: "已连接其他蓝牙设备", |
|
|
|
data: current_device |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
if (device == null || device == "undefined") { |
|
|
|
callBack.call(this, { |
|
|
|
code: 10003, |
|
|
|
msg: "参数错误", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
timeId = setTimeout(res => { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "连接超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, connectTimeOut); |
|
|
|
ble.scan_stopScanBleDevice(res => { |
|
|
|
console.log(JSON.stringify(res) + "******************************************ldd"); |
|
|
|
if (res.code == config.successCode()) { |
|
|
|
ble.connectDevice(device, res => { |
|
|
|
console.log(JSON.stringify(res) + "******************************************ldd"); |
|
|
|
if (res.code == config.successCode()) { |
|
|
|
ble.findDeviceServices(res.data, res => { |
|
|
|
console.info(JSON.stringify(res)); |
|
|
|
ble.setParams(res.data.id); |
|
|
|
if (res.code != config.successCode()) { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode(), |
|
|
|
msg: "连接失败", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
}, res1 => { |
|
|
|
dealReceiveData(res1.data.value, res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
ICCReset_Protocol(res => { |
|
|
|
if (res.code == 0) { |
|
|
|
current_device = device; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleSuccessCode(), |
|
|
|
msg: "连接成功", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} else { |
|
|
|
disConnectDevice(res => {}); |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode(), |
|
|
|
msg: "连接失败,卡复位失败", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
}) |
|
|
|
}) |
|
|
|
}) |
|
|
|
} else { |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
} else { |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function onDisconnet(callBack) { |
|
|
|
ble.onDeviceConnectStateChange(res => { |
|
|
|
isConnect = false; |
|
|
|
dataArray = []; |
|
|
|
frame_count = 0; |
|
|
|
frame_total = 0; |
|
|
|
onfire.clear(); |
|
|
|
receive_data = ""; |
|
|
|
clearTimeout(timeId); |
|
|
|
current_device = null; |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
ble.onDeviceConnectStateChange(res => { |
|
|
|
isConnect = false; |
|
|
|
dataArray = []; |
|
|
|
frame_count = 0; |
|
|
|
frame_total = 0; |
|
|
|
onfire.clear(); |
|
|
|
receive_data = ""; |
|
|
|
clearTimeout(timeId); |
|
|
|
current_device = null; |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function disConnectDevice(callBack) { |
|
|
|
receive_data = ""; |
|
|
|
ble.disConnectDevice(res => { |
|
|
|
isConnect = false; |
|
|
|
dataArray = []; |
|
|
|
frame_count = 0; |
|
|
|
frame_total = 0; |
|
|
|
onfire.clear(); |
|
|
|
clearTimeout(timeId); |
|
|
|
current_device = null; |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
receive_data = ""; |
|
|
|
ble.disConnectDevice(res => { |
|
|
|
isConnect = false; |
|
|
|
dataArray = []; |
|
|
|
frame_count = 0; |
|
|
|
frame_total = 0; |
|
|
|
onfire.clear(); |
|
|
|
clearTimeout(timeId); |
|
|
|
current_device = null; |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function ESAMReset_Protocol(callBack) { |
|
|
|
console.log("==========ESAMReset_Protocol_Start=========="); |
|
|
|
receive_data = ""; |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
errMsg_arr = []; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ICC复位超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
var cmd_arr = request33.ESAMResetReq(); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ResetFlag(); |
|
|
|
recive33.receiveReset(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
console.log("==========ESAMReset_Protocol_Start=========="); |
|
|
|
receive_data = ""; |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
errMsg_arr = []; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ICC复位超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
var cmd_arr = request33.ESAMResetReq(); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ResetFlag(); |
|
|
|
recive33.receiveReset(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function ESAMChannel_CmdArray(cmdArray, callBack) { |
|
|
|
if (current_device == null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.errorCode(), |
|
|
|
msg: "未连接设备", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
cmd_count = cmdArray.length; |
|
|
|
all_cmdArray = cmdArray; |
|
|
|
ESAMTransfro(callBack) |
|
|
|
if (current_device == null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.errorCode(), |
|
|
|
msg: "未连接设备", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
cmd_count = cmdArray.length; |
|
|
|
all_cmdArray = cmdArray; |
|
|
|
ESAMTransfro(callBack) |
|
|
|
}; |
|
|
|
export function ICCReset_Protocol(callBack) { |
|
|
|
console.log("==========ICCReset_Protocol_Start=========="); |
|
|
|
receive_data = ""; |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ICC复位超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
var cmd_arr = request33.ICCResetReq(); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ResetFlag(); |
|
|
|
recive33.receiveReset(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
console.log("==========ICCReset_Protocol_Start=========="); |
|
|
|
receive_data = ""; |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ICC复位超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
var cmd_arr = request33.ICCResetReq(); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ResetFlag(); |
|
|
|
recive33.receiveReset(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
}; |
|
|
|
export function ICCChannel_CmdArray(cmdArray, callBack) { |
|
|
|
if (current_device == null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.errorCode(), |
|
|
|
msg: "未连接设备", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
cmd_count = cmdArray.length; |
|
|
|
all_cmdArray = cmdArray; |
|
|
|
ICCTransfro(callBack) |
|
|
|
if (current_device == null) { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.errorCode(), |
|
|
|
msg: "未连接设备", |
|
|
|
data: null |
|
|
|
}); |
|
|
|
return |
|
|
|
} |
|
|
|
cmd_count = cmdArray.length; |
|
|
|
all_cmdArray = cmdArray; |
|
|
|
ICCTransfro(callBack) |
|
|
|
}; |
|
|
|
|
|
|
|
function ESAMChannel_Protocol(cmd, callBack) { |
|
|
|
console.log("==========ESAMChannel_Protocol_Start==========:" + cmd); |
|
|
|
var cmd_arr = request33.ESAMChannelTransmission("00", [cmd]); |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
errMsg_arr = []; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ESAM透传超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ChannelFlag(); |
|
|
|
recive33.receiveChannel(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
console.log("==========ESAMChannel_Protocol_Start==========:" + cmd); |
|
|
|
var cmd_arr = request33.ESAMChannelTransmission("00", [cmd]); |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
errMsg_arr = []; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ESAM透传超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ChannelFlag(); |
|
|
|
recive33.receiveChannel(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
} |
|
|
|
|
|
|
|
function ESAMTransfro(callBack) { |
|
|
|
var cmd = all_cmdArray[flag]; |
|
|
|
var that = this; |
|
|
|
ESAMChannel_Protocol(cmd, res => { |
|
|
|
if (res.code == 0) { |
|
|
|
flag++; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
result_arr.push(res.data) |
|
|
|
} |
|
|
|
if (flag < cmd_count) { |
|
|
|
ESAMTransfro(callBack) |
|
|
|
} else { |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
res.data = result_arr |
|
|
|
} |
|
|
|
result_arr = []; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
} else { |
|
|
|
if (errMsg_arr.length > 0) { |
|
|
|
res.msg = errMsg_arr[flag] |
|
|
|
} |
|
|
|
errMsg_arr = []; |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
var cmd = all_cmdArray[flag]; |
|
|
|
var that = this; |
|
|
|
ESAMChannel_Protocol(cmd, res => { |
|
|
|
if (res.code == 0) { |
|
|
|
flag++; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
result_arr.push(res.data) |
|
|
|
} |
|
|
|
if (flag < cmd_count) { |
|
|
|
ESAMTransfro(callBack) |
|
|
|
} else { |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
res.data = result_arr |
|
|
|
} |
|
|
|
result_arr = []; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
} else { |
|
|
|
if (errMsg_arr.length > 0) { |
|
|
|
res.msg = errMsg_arr[flag] |
|
|
|
} |
|
|
|
errMsg_arr = []; |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
} |
|
|
|
|
|
|
|
function ICCChannel_Protocol(cmd, callBack) { |
|
|
|
console.log("==========ICCChannel_Protocol_Start==========:" + cmd); |
|
|
|
var cmd_arr = request33.ICCChannelTransmission("00", [cmd]); |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "ICC透传超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ChannelFlag(); |
|
|
|
recive33.receiveChannel(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
console.log("==========ICCChannel_Protocol_Start==========:" + cmd); |
|
|
|
var cmd_arr = request33.ICCChannelTransmission("00", [cmd]); |
|
|
|
timeId = setTimeout(res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.timeOutCode(), |
|
|
|
msg: "连接设备蓝牙超时", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}, sendTimeOut); |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
fireFlag = config.ChannelFlag(); |
|
|
|
recive33.receiveChannel(res => { |
|
|
|
clearTimeout(timeId); |
|
|
|
console.log("返回上层数据:" + JSON.stringify(res)); |
|
|
|
callBack.call(this, res) |
|
|
|
}) |
|
|
|
}) |
|
|
|
} |
|
|
|
|
|
|
|
function ICCTransfro(callBack) { |
|
|
|
var cmd = all_cmdArray[flag]; |
|
|
|
var that = this; |
|
|
|
ICCChannel_Protocol(cmd, res => { |
|
|
|
if (res.code == 0) { |
|
|
|
flag++; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
result_arr.push(res.data) |
|
|
|
} |
|
|
|
if (flag < cmd_count) { |
|
|
|
ICCTransfro(callBack) |
|
|
|
} else { |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
res.data = result_arr |
|
|
|
} |
|
|
|
result_arr = []; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
} else { |
|
|
|
if (errMsg_arr.length > 0) { |
|
|
|
res.msg = errMsg_arr[flag] |
|
|
|
} |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
result_arr = []; |
|
|
|
flag = 0; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
var cmd = all_cmdArray[flag]; |
|
|
|
var that = this; |
|
|
|
ICCChannel_Protocol(cmd, res => { |
|
|
|
if (res.code == 0) { |
|
|
|
flag++; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
result_arr.push(res.data) |
|
|
|
} |
|
|
|
if (flag < cmd_count) { |
|
|
|
ICCTransfro(callBack) |
|
|
|
} else { |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
flag = 0; |
|
|
|
if (errMsg_arr.length == 0) { |
|
|
|
res.data = result_arr |
|
|
|
} |
|
|
|
result_arr = []; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
} else { |
|
|
|
if (errMsg_arr.length > 0) { |
|
|
|
res.msg = errMsg_arr[flag] |
|
|
|
} |
|
|
|
cmd_count = 0; |
|
|
|
all_cmdArray = []; |
|
|
|
result_arr = []; |
|
|
|
flag = 0; |
|
|
|
callBack.call(this, res) |
|
|
|
} |
|
|
|
}) |
|
|
|
} |
|
|
|
|
|
|
|
function dealReceiveData(data, callBack) { |
|
|
|
if (receive_data.length > 0) { |
|
|
|
if (receive_data.indexOf("FE01") == -1) { |
|
|
|
receive_data = "" |
|
|
|
} |
|
|
|
} |
|
|
|
receive_data += data; |
|
|
|
var blg = parseInt(receive_data.substring(4, 8), 16) * 2 == receive_data.length ? true : false; |
|
|
|
if (blg) { |
|
|
|
var flag_protocol = receive_data.substr(24, 2); |
|
|
|
var flag_wechat = receive_data.substr(8, 4); |
|
|
|
if (flag_protocol == "33") { |
|
|
|
console.log(TAG + "----fireFlag:" + fireFlag); |
|
|
|
var pack_count = receive_data.substr(28, 2); |
|
|
|
wechat_arr.push(receive_data); |
|
|
|
receive_data = ""; |
|
|
|
if (pack_count == "80" || pack_count == "00") { |
|
|
|
onfire.fire(fireFlag, wechat_arr); |
|
|
|
wechat_arr = [] |
|
|
|
} |
|
|
|
} else if (flag_wechat == "2711" || flag_wechat == "2713") { |
|
|
|
if (flag_wechat == "2711") { |
|
|
|
var mac = receive_data.substring(40, 44); |
|
|
|
var cmd_arr = request33.wechatInit1(mac); |
|
|
|
receive_data = ""; |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => {}) |
|
|
|
} else if (flag_wechat == "2713") { |
|
|
|
var cmd_arr = request33.wechatInit2(mac); |
|
|
|
receive_data = ""; |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleSuccessCode(), |
|
|
|
msg: "连接成功", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}) |
|
|
|
} else { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode, |
|
|
|
msg: "非法连接", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
} else { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode, |
|
|
|
msg: "非法连接", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
} |
|
|
|
if (receive_data.length > 0) { |
|
|
|
if (receive_data.indexOf("FE01") == -1) { |
|
|
|
receive_data = "" |
|
|
|
} |
|
|
|
} |
|
|
|
receive_data += data; |
|
|
|
var blg = parseInt(receive_data.substring(4, 8), 16) * 2 == receive_data.length ? true : false; |
|
|
|
if (blg) { |
|
|
|
var flag_protocol = receive_data.substr(24, 2); |
|
|
|
var flag_wechat = receive_data.substr(8, 4); |
|
|
|
if (flag_protocol == "33") { |
|
|
|
console.log(TAG + "----fireFlag:" + fireFlag); |
|
|
|
var pack_count = receive_data.substr(28, 2); |
|
|
|
wechat_arr.push(receive_data); |
|
|
|
receive_data = ""; |
|
|
|
if (pack_count == "80" || pack_count == "00") { |
|
|
|
onfire.fire(fireFlag, wechat_arr); |
|
|
|
wechat_arr = [] |
|
|
|
} |
|
|
|
} else if (flag_wechat == "2711" || flag_wechat == "2713") { |
|
|
|
if (flag_wechat == "2711") { |
|
|
|
var mac = receive_data.substring(40, 44); |
|
|
|
var cmd_arr = request33.wechatInit1(mac); |
|
|
|
receive_data = ""; |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => {}) |
|
|
|
} else if (flag_wechat == "2713") { |
|
|
|
var cmd_arr = request33.wechatInit2(mac); |
|
|
|
receive_data = ""; |
|
|
|
ble.sendMessageToDevice(cmd_arr, res => { |
|
|
|
receive_data = ""; |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleSuccessCode(), |
|
|
|
msg: "连接成功", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
}) |
|
|
|
} else { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode, |
|
|
|
msg: "非法连接", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
} else { |
|
|
|
callBack.call(this, { |
|
|
|
code: config.bleErrorCode, |
|
|
|
msg: "非法连接", |
|
|
|
data: null |
|
|
|
}) |
|
|
|
} |
|
|
|
} |
|
|
|
} |