微商客 v2.1.2 - WxGroupToSaveActivity.java 源代码

package com.jianzhen.wsk.v1.activity;

import android.content.Context;
import android.os.Bundle;
import android.view.View;
import android.view.accessibility.AccessibilityNodeInfo;
import android.widget.Toast;
import com.auxiliary.library.core.NodeExecutor;
import com.auxiliary.library.node.SelectNode;
import com.auxiliary.library.node.WhileNode;
import com.auxiliary.library.node.base.INode;
import com.auxiliary.library.service.AuxiliaryService;
import com.auxiliary.library.service.IAccessibility;
import com.auxiliary.library.widget.ExecutorWindow;
import com.jianzhen.wsk.R;
import com.jianzhen.wsk.databinding.ActivityWxGroupToSaveBinding;
import com.jianzhen.wsk.dialog.InteractTimeDialog;
import com.jianzhen.wsk.utils.ScriptLoadUtil;
import com.jianzhen.wsk.utils.Utils;
import com.jianzhen.wsk.v1.VBaseActivity;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;

public class WxGroupToSaveActivity extends VBaseActivity<ActivityWxGroupToSaveBinding> implements View.OnClickListener, InteractTimeDialog.OnCompleteListener {
    private InteractTimeDialog mDialog;
    private ExecutorWindow mExecutorWindow;
    private WxDeleteGroupIm mParam = new WxDeleteGroupIm();
    private final String funcId = "10082";
    private String myWxName = "";
    private List<String> bookGroupList = new ArrayList();

    public static class WxDeleteGroupIm {
        public String interactTime = "[1000,3000]";
        public String wx_name;
    }

    @Override
    public void initView(ActivityWxGroupToSaveBinding activityWxGroupToSaveBinding, Bundle bundle) {
        this.mDialog = new InteractTimeDialog(this, this);
        activityWxGroupToSaveBinding.tvTitle.setText(R.string.group_save_book);
    }

    @Override
    public void initListener(ActivityWxGroupToSaveBinding activityWxGroupToSaveBinding, Bundle bundle) {
        activityWxGroupToSaveBinding.tvStart.setOnClickListener(this);
        activityWxGroupToSaveBinding.tvInteractTime.setOnClickListener(this);
    }

    @Override
    public void onTimeComplete(String str, String str2) {
        this.mParam.interactTime = str;
        ((ActivityWxGroupToSaveBinding) this.mViewBinding).tvInteractTime.setText(str2);
    }

    @Override
    public void onClick(View view) {
        InteractTimeDialog interactTimeDialog;
        if (view == ((ActivityWxGroupToSaveBinding) this.mViewBinding).tvInteractTime && (interactTimeDialog = this.mDialog) != null) {
            interactTimeDialog.show(this.mParam.interactTime);
        } else if (view == ((ActivityWxGroupToSaveBinding) this.mViewBinding).tvStart) {
            getFuncLimit("10082");
        }
    }

    @Override
    public void lambda$setNotYearVipTip$7() {
        super.lambda$setNotYearVipTip$7();
        try {
            this.bookGroupList = new ArrayList();
            IAccessibility accessibility = AuxiliaryService.getAccessibility();
            ExecutorWindow executorWindow = this.mExecutorWindow;
            if (executorWindow != null) {
                executorWindow.hideFloatWindow();
            }
            Utils.openWx(this);
            ExecutorWindow loadWx = ScriptLoadUtil.loadWx(accessibility, "10082", "wx_group_save_book");
            this.mExecutorWindow = loadWx;
            loadWx.setArgs(this.mParam);
            this.mExecutorWindow.showFloatWindow();
            this.mExecutorWindow.setISelect(new NodeExecutor.ISelectMap() {
                public final void onNodeSelect(SelectNode selectNode, List list, Object obj, NodeExecutor nodeExecutor) {
                    WxGroupToSaveActivity.this.lambda$SendWxStart$3(selectNode, list, obj, nodeExecutor);
                }
            });
            this.mExecutorWindow.setIFilter(new NodeExecutor.IFilter() {
                public final List onFilter(NodeExecutor nodeExecutor, INode iNode, List list, Object obj) {
                    List lambda$SendWxStart$4;
                    lambda$SendWxStart$4 = WxGroupToSaveActivity.this.lambda$SendWxStart$4(nodeExecutor, iNode, list, obj);
                    return lambda$SendWxStart$4;
                }
            });
            this.mExecutorWindow.addStatusCallback(new NodeExecutor.DefaultStatusCallback() {
                public void onFinish(NodeExecutor nodeExecutor, boolean z) {
                    WxGroupToSaveActivity.this.mExecutorWindow.setMessage("保存完成！", true);
                    WxGroupToSaveActivity.this.addFuncLimitCount("10082");
                    super.onFinish(nodeExecutor, z);
                }
            });
        } catch (Exception unused) {
            Toast.makeText((Context) this, (CharSequence) "请先启动辅助服务", 0).show();
        }
    }

    public void lambda$SendWxStart$3(SelectNode selectNode, List list, Object obj, NodeExecutor nodeExecutor) {
        List list2 = (List) list.stream().filter(new Predicate() {
            @Override
            public final boolean test(Object obj2) {
                return WxGroupToSaveActivity.lambda$SendWxStart$0((NodeExecutor.NodeParam) obj2);
            }
        }).map(new Function() {
            @Override
            public final Object apply(Object obj2) {
                String str;
                str = ((NodeExecutor.NodeParam) obj2).text;
                return str;
            }
        }).filter(new Predicate() {
            @Override
            public final boolean test(Object obj2) {
                return WxGroupToSaveActivity.lambda$SendWxStart$2((String) obj2);
            }
        }).collect(Collectors.toList());
        if (selectNode.getPageName().equals("我的页面获取我的昵称")) {
            if (this.myWxName.isEmpty() && !list2.isEmpty()) {
                this.myWxName = (String) list2.get(0);
            }
            this.mParam.wx_name = this.myWxName;
            return;
        }
        if (selectNode.getPageName().equals("保存的群聊页面")) {
            this.bookGroupList.addAll((List) list2.stream().distinct().collect(Collectors.toList()));
        }
    }

    static boolean lambda$SendWxStart$0(NodeExecutor.NodeParam nodeParam) {
        return nodeParam.text != null;
    }

    static boolean lambda$SendWxStart$2(String str) {
        return ("微信团队".equals(str) || "文件传输助手".equals(str) || "未设置标签的朋友".equals(str)) ? false : true;
    }

    public List lambda$SendWxStart$4(NodeExecutor nodeExecutor, INode iNode, List list, Object obj) {
        ArrayList arrayList = new ArrayList(list);
        if (!"while_node".equals(iNode.getNodeType()) || !"saveGroupList".equals(((WhileNode) iNode).getTag())) {
            return list;
        }
        Iterator it = list.iterator();
        while (it.hasNext()) {
            AccessibilityNodeInfo accessibilityNodeInfo = (AccessibilityNodeInfo) it.next();
            if (accessibilityNodeInfo != null && accessibilityNodeInfo.getText() != null) {
                String obj2 = accessibilityNodeInfo.getText().toString();
                int lastIndexOf = obj2.lastIndexOf(40);
                int lastIndexOf2 = obj2.lastIndexOf(41);
                if (lastIndexOf != -1) {
                    obj2 = Utils.removeCharacters(obj2, lastIndexOf, lastIndexOf2);
                }
                if (this.bookGroupList.contains(obj2)) {
                    arrayList.remove(accessibilityNodeInfo);
                }
            }
        }
        return arrayList;
    }

    protected void onResume() {
        super.onResume();
        ExecutorWindow executorWindow = this.mExecutorWindow;
        if (executorWindow != null) {
            executorWindow.hideFloatWindow();
            this.mExecutorWindow.stop();
        }
    }
}