/**
|
* description 消息已读未读状态检测
|
*/
|
let packageName = 'com.ss.android.ugc.aweme';
|
let tenantId = "";
|
let scriptVersion = "";
|
//toast扩展参数
|
let toastExtra = {
|
"x":(device.getScreenWidth() - 800) / 2,
|
"y":(device.getScreenHeight() - 200) / 2,
|
"textColor":"#ffffff",
|
"duration":30000,
|
"width":800,
|
"height":200,
|
}
|
|
/**
|
* description 脚本入口
|
*/
|
run()
|
/**
|
* description 跳转消息页面
|
*/
|
toMessage();
|
|
/**
|
* description 唤醒设备
|
*/
|
function run() {
|
if (!isAccMode()) {
|
toast('非无障碍模式，无法执行脚本', toastExtra);
|
randomSleep("非无障碍模式，无法执行脚本", "", "", "", "", "");
|
exit();
|
}
|
//自动化服务是否正常
|
if (!autoServiceStart(2)) {
|
toast('自动化服务启动失败，无法执行脚本', toastExtra);
|
randomSleep("自动化服务启动失败，无法执行脚本", "", "", "", "", "");
|
exit();
|
}
|
//脚本停止监听
|
setStopCallback(function () {
|
device.cancelKeepingAwake(); //取消保持唤醒状态
|
logd("脚本停止");
|
deviceOperaLog("脚本停止", "脚本停止", 0, "", "", "", "", "")
|
home();
|
});
|
//脚本异常停止监听
|
setExceptionCallback(function (msg) {
|
device.cancelKeepingAwake(); //取消保持唤醒状态
|
logd("脚本异常停止");
|
deviceOperaLog("脚本异常停止", "脚本异常停止", 0, "", "", "", "", "")
|
home();
|
});
|
daemonEnv(true); //守护自动化环境
|
randomSleep("脚本开始运行", "脚本运行", "", "", "", "");
|
//保持设备唤醒
|
importClass(android.os.PowerManager);
|
device.keepAwake(PowerManager.SCREEN_DIM_WAKE_LOCK | PowerManager.ACQUIRE_CAUSES_WAKEUP);
|
//保持屏幕唤醒
|
device.keepScreenOn();
|
sleep(1000);
|
//息屏设备上滑解锁
|
let lock = id("com.android.systemui:id/notification_stack_scroller").getOneNodeInfo(5000);
|
if (lock) {
|
let screenWidth = device.getScreenWidth();
|
let screenHeight = device.getScreenHeight();
|
let startX = screenWidth / 2;
|
let startY = screenHeight - 200;
|
let endX = screenWidth / 2;
|
let endY = 50;
|
let duration = 2000;
|
swipeToPoint(startX, startY, endX, endY, duration);
|
}
|
getDevice()
|
launch(packageName, 5000, 2); //打开抖音
|
}
|
|
/**
|
* description 通过包名启动应用
|
* @param packageName {string} : 应用包名
|
* @param delay {number} : 启动后等待时长（毫秒）
|
* @param startNum {number} : 重试次数
|
* @return {boolean} : 返回是否成功
|
*/
|
function launch(packageName, delay, startNum) {
|
let result = false;
|
//判断应用的包名是否存在
|
if (utils.isAppExist(packageName)) {
|
//判断应用是否在前台
|
if (getRunningPkg() == null) {
|
toast('请开启辅助功能权限');
|
exit();
|
} else if (getRunningPkg() === packageName) {
|
logd('应用已经在前台');
|
result = true;
|
} else {
|
logd('启动应用...');
|
let alert_selectors = text("允许");
|
let num = 0;
|
//判断应用是否启动成功
|
while (num < startNum) {
|
if (getRunningPkg() === packageName) {
|
logd('启动成功');
|
randomSleep("脚本启动成功，版本：" + scriptVersion, "脚本启动", "", "", "", "");
|
result = true;
|
break;
|
} else if (has(alert_selectors)) {
|
//初次打开应用 可能会弹出是否允许打开的弹窗
|
let node = alert_selectors.getOneNodeInfo(1000);
|
if (node) {
|
node.click();
|
}
|
} else {
|
utils.openApp(packageName);
|
sleep(delay);
|
num++;
|
}
|
}
|
}
|
alert(); //应用启动后处理弹窗
|
operaLog(1);
|
} else {
|
toast('应用未安装');
|
exit();
|
}
|
return result;
|
}
|
|
/**
|
* description 跳转消息页面
|
*/
|
function toMessage() {
|
try {
|
//定位到首页
|
execSync(function () {
|
isHome();
|
}, 1000);
|
let message_icon = text("消息").getOneNodeInfo(randomSleep("准备点击消息按钮", "", "", "", "", ""));
|
//寻找消息图标并点击
|
if (message_icon.click()) {
|
operaLog(2);
|
randomSleep("点击消息按钮，进入消息页面", "", "", "", "", "")
|
// 获取已读 回复数量
|
let reply = ''
|
let message_icon = desc("消息，按钮").getOneNodeInfo(2000)
|
if (message_icon) {
|
let nodeInfo = message_icon.parent().parent();
|
let siblings = nodeInfo.siblings();
|
if (siblings) {
|
// 私信回复数量
|
reply = siblings[0].allChildren()[0].text;
|
}
|
}
|
let read = 0
|
while (true) {
|
let nodeInfo = text("已读 ·").getNodeInfo(2000);
|
let more = text("暂时没有更多了").getOneNodeInfo(2000);
|
if (nodeInfo) {
|
read = nodeInfo.length + read
|
}
|
if (more) {
|
break
|
}
|
sleep(3000);
|
swiper()
|
}
|
updateStatus(read, reply)
|
// 定位到首页
|
isHome();
|
randomSleep("脚本运行结束", "脚本运行结束", "", "", "", "");
|
}
|
} catch (e) {
|
logd(e)
|
randomSleep("脚本异常", "脚本异常", "", "", "", "");
|
isHome()
|
}
|
}
|
|
function swiper() {
|
let screenWidth = device.getScreenWidth();
|
let screenHeight = device.getScreenHeight();
|
|
let startX = screenWidth / 2;
|
let startY = screenHeight - 200;
|
let endX = screenWidth / 2;
|
let endY = 50;
|
let duration = 2000;
|
|
swipeToPoint(startX, startY, endX, endY, duration);
|
}
|
|
function updateStatus(read, reply) {
|
let deviceNo = ecloud.getDeviceNo();
|
let query = {
|
"pageNumber": 1,
|
"pageSize": 2,
|
"fields": "",
|
"query": "",
|
"tableNameEn": "device_user",
|
"search": {
|
"device_no": deviceNo
|
}
|
};
|
let queryr = ecloud.dynamicQuery(query)
|
queryr = JSON.parse(queryr)
|
let replyed = queryr.reply
|
if (replyed !== null && replyed !== '' && replyed !== undefined && replyed !== 'undefined') {
|
reply = parseInt(replyed, 10) + parseInt(reply, 10)
|
}
|
let update = {
|
"tableNameEn": "device_user",
|
"columns": {
|
"readed": read + "",
|
"reply": reply + ""
|
},
|
"query": "",
|
"search": {
|
"device_no": deviceNo
|
}
|
}
|
let updater = ecloud.dynamicUpdate(update)
|
logd("=== {}", updater);
|
}
|
|
/**
|
* 记录设备操作记录日志
|
*/
|
function deviceOperaLog(operateType, logDetail, intervals, tarPostName, tarUniqueNo, tarComment, tarNickname,time) {
|
let paltform = '';
|
let uniqueNo = '';
|
if ('com.ss.android.ugc.aweme'.equals(packageName)) {
|
// 斗音
|
paltform = 'DY'
|
uniqueNo = ecloud.getDeviceNo().substring(3)
|
} else if ('com.xingin.xhs'.equals(packageName)) {
|
// 小红书
|
paltform = 'XHS'
|
uniqueNo = ecloud.getDeviceNo().substring(4)
|
} else if ('com.smile.gifmaker'.equals(packageName)) {
|
// 快手
|
paltform = 'KS'
|
uniqueNo = ecloud.getDeviceNo().substring(3)
|
}
|
let add = {
|
"tableNameEn": "device_log",
|
"columns": {
|
"unique_no": uniqueNo,
|
"platform": paltform,
|
"device_no": ecloud.getDeviceNo(),
|
"task_name": ecloud.getTaskInfo().taskName,
|
"log_detail": logDetail,
|
"operate_type": operateType,
|
"intervals": intervals + "ms",
|
"operate_time": getDate(),
|
"tar_post_name": tarPostName,
|
"tar_unique_no": tarUniqueNo,
|
"tar_comment": tarComment,
|
"tar_nickname": tarNickname,
|
"task_id": ecloud.getTaskInfo().taskId,
|
"tenant_id": tenantId,
|
"serial_num": time
|
}
|
}
|
ecloud.dynamicAdd(add)
|
}
|
|
/**
|
* description 获取当前时间
|
* @return {string} : 返回时间
|
*/
|
function getDate() {
|
let date = new Date();
|
let sign2 = ":";
|
let year = date.getFullYear() // 年
|
let month = date.getMonth() + 1; // 月
|
let day = date.getDate(); // 日
|
let hour = date.getHours(); // 时
|
let minutes = date.getMinutes(); // 分
|
let seconds = date.getSeconds() //秒
|
let weekArr = ['星期一', '星期二', '星期三', '星期四', '星期五', '星期六', '星期天'];
|
let week = weekArr[date.getDay()];
|
// 给一位数的数据前面加 “0”
|
if (month >= 1 && month <= 9) {
|
month = "0" + month;
|
}
|
if (day >= 0 && day <= 9) {
|
day = "0" + day;
|
}
|
if (hour >= 0 && hour <= 9) {
|
hour = "0" + hour;
|
}
|
if (minutes >= 0 && minutes <= 9) {
|
minutes = "0" + minutes;
|
}
|
if (seconds >= 0 && seconds <= 9) {
|
seconds = "0" + seconds;
|
}
|
return year + "-" + month + "-" + day + " " + hour + sign2 + minutes + sign2 + seconds;
|
}
|
|
/**
|
* 记录埋点数据
|
*/
|
function operaLog(num) {
|
let paltform = '';
|
let operateType = '';
|
let uniqueNo = '';
|
if (num === 1) {
|
operateType = '应用启动'
|
} else if (num === 2) {
|
operateType = '点击消息'
|
} else if (num === 3) {
|
operateType = '点击互动消息'
|
} else if (num === 4) {
|
operateType = '脚本运行结束'
|
}
|
if ('com.ss.android.ugc.aweme'.equals(packageName)) {
|
// 斗音
|
paltform = 'DY'
|
uniqueNo = ecloud.getDeviceNo().substring(3)
|
} else if ('com.xingin.xhs'.equals(packageName)) {
|
// 小红书
|
paltform = 'XHS'
|
uniqueNo = ecloud.getDeviceNo().substring(4)
|
} else if ('com.smile.gifmaker'.equals(packageName)) {
|
// 快手
|
paltform = 'KS'
|
uniqueNo = ecloud.getDeviceNo().substring(3)
|
}
|
let add = {
|
"tableNameEn": "trace",
|
"columns": {
|
"device_no": ecloud.getDeviceNo(),
|
"platform": paltform,
|
"unique_no": uniqueNo,
|
"post_name": '',
|
"nickname": '',
|
"keyword": '',
|
"operate_type": operateType,
|
"operate_time": timeFormat("yyyy-MM-dd HH:mm:ss")+'',
|
"task_id": ecloud.getTaskInfo().taskId,
|
"task_name": ecloud.getTaskInfo().taskName,
|
"tenant_id": tenantId,
|
}
|
}
|
ecloud.dynamicAdd(add)
|
}
|
|
/**
|
* description 异步执行线程 处理弹窗
|
* @return {boolean} : 返回是否成功
|
*/
|
function alert() {
|
thread.execAsync(function () {
|
logd('启动线程，查找弹窗');
|
let btnText = ["下次再说",
|
"以后再说",
|
"关闭",
|
"允许",
|
"暂不",
|
"暂时不要",
|
"我知道了",
|
"知道了",
|
"取消"];
|
while (true) {
|
for (let i = 0; i < btnText.length; i++) {
|
let node = text(btnText[i]).getOneNodeInfo(1000);
|
if (node) {
|
node.click();
|
logd('弹窗已处理');
|
randomSleep("弹窗处理完毕", "", "", "", "", "")
|
}
|
}
|
}
|
});
|
return true;
|
}
|
|
/**
|
* description 定位到首页
|
* @return {boolean} : 返回是否成功
|
*/
|
function isHome() {
|
let result = false;
|
while (true) {
|
var home_selectors = text("首页").getOneNodeInfo(3000); //首页按钮
|
var message_selectors = text("消息").getOneNodeInfo(3000); //消息按钮
|
//判断是否在首页
|
if (home_selectors && message_selectors) {
|
var follow_selectors = text("关注"); //关注按钮
|
var recommend_selectors = text("推荐"); //推荐按钮
|
if (has(follow_selectors) && has(recommend_selectors)) {
|
toast('已定位首页');
|
randomSleep("定位到首页", "", "", "", "", "");
|
result = true;
|
break;
|
} else {
|
home_selectors.click();
|
sleep(3000);
|
}
|
} else {
|
toast('返回首页...');
|
//返回上一页
|
go_back(1);
|
}
|
}
|
return result;
|
}
|
|
/**
|
* description 自定义返回函数
|
* @param page {number} : 返回页数
|
*/
|
function go_back(page) {
|
let count = 0;
|
while (count < page) {
|
back();
|
count++;
|
randomSleep("返回上一页", "", "", "", "", "");
|
}
|
}
|
|
/**
|
* description 随机暂停时间
|
*/
|
function randomSleep(log, opeType, tarPostName, tarUniqueNo, tarComment, tarNickname) {
|
let min = Math.ceil(30);
|
let max = Math.floor(60);
|
let times = (Math.floor(Math.random() * (max - min + 1)) + min) * 100;
|
logd(log + "，停留" + times + "ms");
|
// 记录设备操作日志
|
if (opeType === "脚本启动" || opeType === "脚本运行结束") {
|
let serialNum = time()
|
deviceOperaLog(opeType, log + "，停留" + times + "ms", times, tarPostName, tarUniqueNo, tarComment, tarNickname, serialNum)
|
}else {
|
deviceOperaLog(opeType, log + "，停留" + times + "ms", times, tarPostName, tarUniqueNo, tarComment, tarNickname,null)
|
}
|
sleep(times);
|
return times;
|
}
|
|
/**
|
* 获取设备信息
|
*/
|
function getDevice() {
|
var d = ecloud.getTaskInfo()
|
let taskId = d.taskId
|
taskId = parseInt(taskId, 10)
|
scriptVersion = d.scriptVersion
|
var url = "http://47.120.7.97:8098/openapi/getTask";
|
var pa = {
|
"dataSecret": "test123"
|
};
|
var x = http.postJSON(url, pa, 10 * 1000);
|
x = JSON.parse(x)
|
for (let i = 0; i < x.length; i++) {
|
if (x[i].taskId === taskId) {
|
tenantId = x[i].tenantId
|
}
|
}
|
}
|
|
/**
|
* description 启动自动化
|
* @return {boolean} : 返回自动化服务结果
|
*/
|
function autoServiceStart(time) {
|
for (let i = 0; i < time; i++) {
|
if (isServiceOk()) {
|
return true;
|
}
|
let started = startEnv();
|
randomSleep("第' + (i + 1) + '次启动服务结果: " + started, "", "", "", "", "");
|
if (isServiceOk()) {
|
return true;
|
}
|
}
|
return isServiceOk();
|
}
|
