//初始化方法

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;