//初始化方法
function recordInit(scriptName){
//let ipInfoJson = getIP()
// let ip = ipInfoJson.cip
// let location = ipInfoJson.cname
let deviceIMEI = '',deviceBrand='',deviceModel='',AndroidVer='',deviceWH='',deviceBoard='',deviceMac='',AndroidId=''
try {
deviceBrand = device.brand;//制造廠商
deviceBoard = device.board;//主板
deviceMac = device.getMacAddress()//Mac地址
AndroidId = device.getAndroidId()//安卓ID
data={
"category":1,
"uuid":"55421",
"device_code":"086",
"configure":"5656E",
"owner":"1",
"model":device.model,
"release": device.release,
"memory":~~(device.getAvailMem()/1024/1024)+'MB',
"imei":device.getIMEI(),
"width":device.width,
"height":device.height,
"battery":device.getBattery()
}
var token=setting.storage.get('access_token')
var res = http.postJson(setting.api_domain+'device/?access-token='+token,data);
if(res.statusCode==200){
log('已添加')
return true
}
else if(res.statusCode==201){
log("已更新")
return true
}else{
log("添加設備失敗")
return false
}
} catch (error) {
log(error)
return false;
}
}
var ws = {
run:function(){
setting.ws_status =true;
console.log('使用軟件的過程中，請確保您的網絡流暢~')
console.log('Websocket連接中..')
setting.ws = web.newWebSocket(setting.websocket_domain, {
//eventThread: 'this'
});
//ws監聽
setting.ws.on("open", (res) => {
log("WebSocket連接成功！");
//心跳檢測
let hi={'type':'connect','uuid':'033246','device_code':'003'}
setting.ws.send(JSON.stringify(hi));
setting.heartbeat = threads.start(function(){
setInterval(function(){
console.log('發送心跳包');
}, 10000);
});
}).on("failure", (err, res) => {
// 關閉心跳包線程
setting.heartbeat.interrupt();
//console.error(err);
setting.ws_status =false;
// 斷線重連
if(setting.allow_ws_re){
console.error('與總控的連接已斷開，五秒后重連...');
sleep(5000)
this.run()
}
// 改變“連接總控”顏色
ui.run(function(){
ui.start.setBackgroundColor(colors.parseColor("#d6d7d7"))
ui.start.text("連接總控")
ui.start.setTextColor(colors.parseColor("#000000"))
});
//alert("提示","ws通道已斷開！");
//exit();
}).on("closing", (code, reason) => {
log("WebSocket關閉中");
}).on("text", (text) => {
log("收到消息")
try {
let data = JSON.parse(text);
switch(data.type){
case 'init':
console.log('等待總控響應...')
var ret=recordInit('init')
console.error("初始化返回："+ret )
if(ret){
toastLog('成功與總控建立連接')
console.info('大功告成，您可以在總控端控制該終端了~');
// 改變"連接總控"顏色
ui.run(function(){
// 如果在主界面
if(ui.start){
if(setting.sys_name == "閑魚助手"){
ui.start.setBackgroundColor(colors.parseColor("#009688"))
}else{
ui.start.setTextColor(colors.parseColor("#ffffff"))
ui.start.setBackgroundColor(colors.parseColor(setting.baozeng_colour))
}
ui.start.text("已連接")
}
});
device.vibrate(500);//震動700毫秒
}else{
setting.ws_status =false;
let err_msg = r['msg']
alert(err_msg);console.error(err_msg)
}
break;
case 'start':
log('接到任務:',json.task)
let sid = json.sid
stopEngine()
try {try {if(main_thread) main_thread.interrupt()} catch (error) { }} catch (error) { }
if(getScriptConfig(sid)){
send_Log('[開始運行]'+json.task,true)
main_thread = threads.start(function () {
doTask(sid)
});
}else{
send_Log('[啟動失敗]設備獲取腳本配置失敗!',true)
}
break;
case 'web_to_aj_command':
//執行web發來的命令
//console.warn(data.task_type + '('+data.task_id+')');
threads.start(function () {
eval(data.task_type + '('+data.task_id+')');
console.log('等待總控命令中....')
});
break;
case 'exec_command':
break;
case 'NO':
log(data.msg)
toast(data.msg)
setting.ws.closed();
break;
case 'web_to_aj_chat_message':
//web_to_aj_chat_message
console.log(data)
// console.log('web_to_aj_chat_message')
setting.message.push({name:data['name'],message:data['message']})
break;
default:
console.log('defautl')
console.log(data)
}
} catch (error) {
log("解析返回來的數據錯誤")
log(error)
}
}).on("closed", (code, reason) => {
//log("WebSocket已關閉: code = %d, reason = %s", code, reason);
setting.ws_status =false;
alert("提示","ws通道已斷開2");
console.error('ws通道已斷開2')
//exit();
});
}
}
// 函數導出
module.exports = ws;
