android AccessibilityService合法合规采集大众点评app商店商品详情(2024-09-02)
免责任声明:
任何可操作性的内容与本人无关,文章内容仅供参考学习，如有侵权损害贵公司利益，请联系作者，会立刻马上进行删除。
一、原理介绍
1、打开大众点评app商店
public void open_shop(Context context,String shop_id)
{
String url="dianping://gcshopshell?shopuuid="+shop_id;
scroll_count=0;
Uri uri = Uri.parse(url); //
Intent intent =new Intent(Intent.ACTION_VIEW,uri);;
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
context.startActivity(intent);
}2、采集如下字段：
public class Commodity{
public int id;
public String title; //商品标题
public String price; //售价
public String market_price; //市场价
public String sales; //年销量
public String shop_id; //商店id
public String shop_index;
public int count;
}3、 保存数据为Csv文件
Csv csv1=Csv.getInstance(context);
boolean bres=csv1.save_commodities(commodities);
if(bres==false){
fb.set_show("保存数据失败！请检查有没有数据存储权限！");
return;
}4、滚动屏幕
private void performScroll(AccessibilityNodeInfo rootNode){
if(mCurrentUI.startsWith("com.dianping.shopshell")){
AccessibilityNodeInfo scrollNode=AccessibilityHelper.findNodeInfosById(rootNode,"com.dianping.v1:id/pagecontainer_recyclerview",0);
if(scrollNode!=null) {
if (scroll_count < 10) {
AccessibilityHelper.performScrollForward(scrollNode);
AccessibilityNodeInfo firstNode=AccessibilityHelper.findNodeInfoByTextAllMatched(rootNode,"抢购");
if(firstNode==null)scroll_count=10;
}
else {
AccessibilityHelper.performScrollBackward(scrollNode);
AccessibilityNodeInfo firstNode=AccessibilityHelper.findNodeInfoByTextAllMatched(rootNode,"封面");
if(firstNode!=null)scroll_count=0;
}
scroll_count += 1;
if (scroll_count > 20) {
scroll_count = 0;
}
}
//AccessibilityNodeInfo no_moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"收起",0);
}5、采集数据
private Commodity get_commodity(AccessibilityNodeInfo buyNode){
try{
AccessibilityNodeInfo parent=buyNode.getParent();
if(parent==null)return null;
parent=parent.getParent();
if(parent==null)return null;
int price_count=0;
Commodity commodity=new Commodity();
for (int i = 0; i < parent.getChildCount(); i++) {
AccessibilityNodeInfo child=parent.getChild(i);
if(child!=null&&child.getText()!=null){
String text=child.getText().toString();
text=text.replaceAll(",","[comma]");
commodity.shop_id=shop_id;
commodity.shop_index=String.valueOf(csv.shop_index);
commodity.count=commodity_count;
if(i==0){
//if(isInCommodities(text))return null;
commodity.title=text;
}
if(text.startsWith("年售"))commodity.sales=text;
if(text.startsWith("全国爆卖"))commodity.sales=text;
if(text.startsWith("¥")){
if(price_count==0)
commodity.price=text;
else
if(price_count==1)
commodity.market_price=text;
price_count+=1;
}
}
}
if(isInCommodities(commodity))return null;
return commodity;
}catch (Exception e){
MyLog.e(e);
return null;
}
}
private boolean isInCommodities(String title){
for (Commodity commodity:commodities){
if(title.equals(commodity.title))return true;
}
return false;
}6、获取商品数量并点击更多，展开商品信息
private void performMoreClick(AccessibilityNodeInfo rootNode){
if(commodity_count>0)return;
AccessibilityNodeInfo moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"个团购",0);
if(moreNode!=null) {
String text=moreNode.getText().toString();
if(text.startsWith("更多")){
AccessibilityNodeInfo parent=moreNode.getParent();
if(parent==null)return;
if(parent.getClassName().toString().equals("android.widget.LinearLayout")){
MyLog.i("找到："+text);
int more=Funcs.getDigital(text);
if(more>0)commodity_count=more+5;
show_count();
AccessibilityHelper.performClick(moreNode);
}
}
return;
}
moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"个商品",0);
if(moreNode!=null) {
String text=moreNode.getText().toString();
if(text.indexOf("更多")>0){
String say="非美容院商店...跳过";
FloatWindowButton fb=FloatWindowButton.getInstance(context);
fb.set_show(say);
Csv csv1=Csv.getInstance(context);
boolean bres=csv1.save_no_shop_id(shop_id,String.valueOf(csv1.shop_index));
if(bres==false){
fb.set_show("保存数据失败！请检查有没有数据存储权限！");
return;
}
open_next_shop_prepare(Config.interval,false);
}
return;
}
}二、完整源代码
package accessibility.app;
import accessibility.AccessibilityFindByText;
import accessibility.AccessibilityHelper;
import accessibility.BaseAccessibilityJob;
import accessibility.AccService;
import floatwindow.FloatWindowButton;
import utils.Config;
import utils.Csv;
import utils.Funcs;
import utils.MyLog;
import android.content.Context;
import android.content.Intent;
import android.graphics.Point;
import android.net.Uri;
import android.os.Handler;
import android.util.Log;
import android.view.accessibility.AccessibilityEvent;
import android.view.accessibility.AccessibilityNodeInfo;
import android.widget.Toast;
import com.dp.jp.MainActivity;
import java.util.ArrayList;
import java.util.List;
public class ShopInfoJob extends BaseAccessibilityJob{
public static final int STAT_NONE=0;
public static final int STAT_WORKING=1;
public static final int STAT_WAITING=2;
public static int state=0;
private static ShopInfoJob current;
private utils.Csv csv;
private int scroll_count=0;
public String CurrentUI=null;
public String shop_id=null;
private boolean is_alarm=false;
//--------------------------------------------------------------------------
public List<Commodity> commodities=new ArrayList<Commodity>() ;
public boolean isBusy=false;
private int commodity_count=0;
private ShopInfoJob() {
//super(new String[]{Config.PKG_IM_TOKEN,Config.PKG_HUOBI,Config.PKG_BTD});
super(new String[]{"com.dianping.v1"});
//super(null);技术支持：metabycf or byc6352
csv= Csv.getInstance(context);
}
public static synchronized ShopInfoJob getInstance() {
if(current == null) {
current = new ShopInfoJob();
}
return current;
}
@Override
public void onCreateJob(AccService service) {
super.onCreateJob(service);
EventStart();
}
@Override
public void onStopJob() {
super.onStopJob();
}
/*
* (刷新处理流程)
* @see accessbility.AccessbilityJob#onWorking()
*/
@Override
public void onWorking(){
FloatWindowButton fb=FloatWindowButton.getInstance(context);
String say="正在执行任务...";
if(commodity_count>0&&commodities.size()>=commodity_count){
say="采集完成...";
fb.set_show(say);
Csv csv1=Csv.getInstance(context);
boolean bres=csv1.save_commodities(commodities);
if(bres==false){
fb.set_show("保存数据失败！请检查有没有数据存储权限！");
return;
}
AccessibilityHelper.performBack(service);
Funcs.sleep(2);
open_next_shop_prepare(Config.interval,false);
return;
}
AccessibilityNodeInfo rootNode = service.getRootInActiveWindow();
if (rootNode == null) return;
fb.set_show(say);
//com.dianping.shopshell.GCShopInfoActivity
if(rootNode.getPackageName().toString().equals("com.dianping.v1")){
if(mCurrentUI.startsWith("com.dianping.shopshell.")) {
performMoreClick(rootNode);
performScroll(rootNode);
}
}
}
@Override
public void onReceiveJob(AccessibilityEvent event) {
super.onReceiveJob(event);
if(!mIsEventWorking)return;
if(!mIsTargetPackageName)return;
CurrentUI=mCurrentUI;
if (event.getEventType() == AccessibilityEvent.TYPE_WINDOW_STATE_CHANGED)
{
MyLog.i("mCurrentUI="+mCurrentUI);
if(mCurrentUI.startsWith("com.dianping.shopshell.")){
if(state==STAT_WORKING) {
}
if(is_alarm)
Funcs.alarm(context,false);
}
if(mCurrentUI.startsWith("android.app.Dialog")){
if(Config.auto_close_verify){
AccessibilityNodeInfo rootNode=event.getSource();
if(rootNode==null)return;
//close_verify_btn(rootNode);
}else {
Funcs.alarm(context,true);
is_alarm=true;
}
}
if(mCurrentUI.startsWith("com.meituan.android.yoda.activity.YodaConfirmActivity")){
if(Config.auto_close_verify){
AccessibilityNodeInfo rootNode=event.getSource();
if(rootNode==null)return;
//close_verify_back(rootNode);
}else {
Funcs.alarm(context,true);
is_alarm=true;
}
}
}
if (event.getEventType() == AccessibilityEvent.TYPE_WINDOW_CONTENT_CHANGED)
{
if(commodity_count>0&&commodity_count==commodities.size())return;
if(mCurrentUI.startsWith("com.dianping.shopshell.")){
if(state==STAT_WORKING) {
AccessibilityNodeInfo rootNode=event.getSource();
if(rootNode==null)return;
pluck_from_shop(rootNode);
TimeStart();
performMoreClick(rootNode);
}
}
}
}
//---------------------------------------------------------------------
//"dianping://gcshopshell?shopuuid=H44paDfKZflcSGHd"
public void open_shop(Context context,String shop_id)
{
String url="dianping://gcshopshell?shopuuid="+shop_id;
scroll_count=0;
Uri uri = Uri.parse(url); //
Intent intent =new Intent(Intent.ACTION_VIEW,uri);;
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
context.startActivity(intent);
}
/*
1.浮动窗口：下一个
2.working.over
3.主窗口：继续
4.accservice open
*/
public void open_next_shop_prepare(int delay,boolean cur){
if(runnableStart!=null)return;
state=STAT_WAITING;
//et_cur_id.setText(String.valueOf(csv1.commodities_index));
runnableStart = new Runnable() {
@Override
public void run() {
try {
Csv csv1=Csv.getInstance(context);
if(cur)
shop_id=csv1.get_shop_id();
else
shop_id=csv1.get_next_shop_id();
FloatWindowButton fb=FloatWindowButton.getInstance(context);
fb.ShowFloatWindow();
if(csv1.shop_index>Config.end_id||csv1.shop_index>csv1.get_shop_total_count()||shop_id.equals("")){
String say="已完成任务";
fb.set_show(say);
runnableStart=null;
return;
}
state=STAT_WORKING;
String say="开始执行任务...";
fb.set_show(say);
fb.set_commodity_count_show(String.valueOf(csv1.shop_index));
open_shop(context,shop_id);
commodities.clear();
commodity_count=0;
runnableStart=null;
}catch (Exception e){
MyLog.e(e.getMessage().toString());
}
}
};
handler.postDelayed(runnableStart, delay);
}
//private boolean pluck_start=false;
//private int pluck_count=0;
//private Commodity commodity=null;
private void pluck_from_shop(AccessibilityNodeInfo rootNode){
try{
if(mCurrentUI.startsWith("com.dianping.shopshell.")){
if(isBusy)return;
isBusy=true;
try{
//com.dianping.v1:id/pagecontainer_recyclerview
//AccessibilityNodeInfo pagecontainerNode=AccessibilityHelper.findNodeInfosById(rootNode,"com.dianping.v1:id/pagecontainer_recyclerview",0);
//if(pagecontainerNode!=null){
List<AccessibilityNodeInfo> buyNodes=AccessibilityHelper.findNodeInfosByTextAllMatched(rootNode,"抢购");
if(buyNodes==null||buyNodes.size()==0)return;
for (AccessibilityNodeInfo buyNode:buyNodes){
Commodity commodity=get_commodity(buyNode) ;
if(commodity!=null)commodities.add(commodity);
}
show_count();
//}
}catch (Exception e){
MyLog.e(e.getMessage().toString());
return ;
}finally {
isBusy=false;
}
}
}catch (Exception e){
MyLog.e(e.getMessage().toString());
}
}
private void performScroll(AccessibilityNodeInfo rootNode){
if(mCurrentUI.startsWith("com.dianping.shopshell")){
AccessibilityNodeInfo scrollNode=AccessibilityHelper.findNodeInfosById(rootNode,"com.dianping.v1:id/pagecontainer_recyclerview",0);
if(scrollNode!=null) {
if (scroll_count < 10) {
AccessibilityHelper.performScrollForward(scrollNode);
AccessibilityNodeInfo firstNode=AccessibilityHelper.findNodeInfoByTextAllMatched(rootNode,"抢购");
if(firstNode==null)scroll_count=10;
}
else {
AccessibilityHelper.performScrollBackward(scrollNode);
AccessibilityNodeInfo firstNode=AccessibilityHelper.findNodeInfoByTextAllMatched(rootNode,"封面");
if(firstNode!=null)scroll_count=0;
}
scroll_count += 1;
if (scroll_count > 20) {
scroll_count = 0;
}
}
//AccessibilityNodeInfo no_moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"收起",0);
//if(no_moreNode!=null&&no_moreNode.getText()!=null&&no_moreNode.getText().toString().startsWith("收起")) scroll_count=10;
}
}
private Commodity get_commodity(AccessibilityNodeInfo buyNode){
try{
AccessibilityNodeInfo parent=buyNode.getParent();
if(parent==null)return null;
parent=parent.getParent();
if(parent==null)return null;
int price_count=0;
Commodity commodity=new Commodity();
for (int i = 0; i < parent.getChildCount(); i++) {
AccessibilityNodeInfo child=parent.getChild(i);
if(child!=null&&child.getText()!=null){
String text=child.getText().toString();
text=text.replaceAll(",","[comma]");
commodity.shop_id=shop_id;
commodity.shop_index=String.valueOf(csv.shop_index);
commodity.count=commodity_count;
if(i==0){
//if(isInCommodities(text))return null;
commodity.title=text;
}
if(text.startsWith("年售"))commodity.sales=text;
if(text.startsWith("全国爆卖"))commodity.sales=text;
if(text.startsWith("¥")){
if(price_count==0)
commodity.price=text;
else
if(price_count==1)
commodity.market_price=text;
price_count+=1;
}
}
}
if(isInCommodities(commodity))return null;
return commodity;
}catch (Exception e){
MyLog.e(e);
return null;
}
}
private boolean isInCommodities(String title){
for (Commodity commodity:commodities){
if(title.equals(commodity.title))return true;
}
return false;
}
private boolean isInCommodities(Commodity commodity_new){
try {
for (Commodity commodity:commodities){
if(Funcs.isEqua(commodity_new.title,commodity.title)&&Funcs.isEqua(commodity_new.price,commodity.price)&&Funcs.isEqua(commodity_new.sales,commodity.sales))return true;
}
return false;
}catch (Exception e){
MyLog.e(e);
return false;
}
}
private void performMoreClick(AccessibilityNodeInfo rootNode){
if(commodity_count>0)return;
AccessibilityNodeInfo moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"个团购",0);
if(moreNode!=null) {
String text=moreNode.getText().toString();
if(text.startsWith("更多")){
AccessibilityNodeInfo parent=moreNode.getParent();
if(parent==null)return;
if(parent.getClassName().toString().equals("android.widget.LinearLayout")){
MyLog.i("找到："+text);
int more=Funcs.getDigital(text);
if(more>0)commodity_count=more+5;
show_count();
AccessibilityHelper.performClick(moreNode);
}
}
return;
}
moreNode=AccessibilityHelper.findNodeInfosByText(rootNode,"个商品",0);
if(moreNode!=null) {
String text=moreNode.getText().toString();
if(text.indexOf("更多")>0){
String say="非美容院商店...跳过";
FloatWindowButton fb=FloatWindowButton.getInstance(context);
fb.set_show(say);
Csv csv1=Csv.getInstance(context);
boolean bres=csv1.save_no_shop_id(shop_id,String.valueOf(csv1.shop_index));
if(bres==false){
fb.set_show("保存数据失败！请检查有没有数据存储权限！");
return;
}
open_next_shop_prepare(Config.interval,false);
}
return;
}
}
private void show_count(){
String say="";
if(commodity_count==0)
say="当前商店编号："+String.valueOf(csv.shop_index)+"已找到商品数："+String.valueOf(commodities.size());
else
say="当前商店编号："+String.valueOf(csv.shop_index)+"共有商品数："+String.valueOf(commodity_count)+"已找到商品数："+String.valueOf(commodities.size());
FloatWindowButton.getInstance(context).set_commodity_count_show(say);
}
private Runnable runnableStart=null;
private Handler handler = new Handler();
public class Commodity{
public int id;
public String title;
public String price;
public String market_price;
public String sales;
public String shop_id;
public String shop_index;
public int count;
}
}
技术支持：
UVHvvJozOTg0ODg3MuW+ruS/oe+8mmJ5YzYzNTLmiJZtZXRhYnljZueUteaKpe+8mmJ5YzAx (base64解码)