红果免费短剧 v6.2.3.32版本的 MD5 值为：a6b05492607eab2c8a25f26d2f238ae0

以下内容为反编译后的 b.java 源代码，内容仅作参考

package com.dragon.read.app.privacy;

import android.content.Intent;
import android.content.SharedPreferences;
import android.util.Log;
import com.dragon.read.app.App;
import com.dragon.read.app.i;
import com.dragon.read.app.privacy.api.AdRecommendApi;
import com.dragon.read.app.privacy.api.center.PrivacyCenter;
import com.dragon.read.app.privacy.api.center.d;
import com.dragon.read.base.util.LogHelper;
import com.dragon.read.component.interfaces.an;
import com.dragon.read.local.KvCacheMgr;
import com.ss.android.common.util.ToolUtils;
import io.reactivex.Completable;
import io.reactivex.CompletableSource;
import io.reactivex.Single;
import io.reactivex.SingleSource;
import io.reactivex.functions.Action;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;
import java.util.HashMap;
import java.util.concurrent.Callable;
import java.util.concurrent.atomic.AtomicInteger;

public final class b implements an {

    public static final LogHelper f41005a = new LogHelper("PrivacyRecommendMgr");

    private final AtomicInteger f41006b;

    private static final class a {

        public static final b f41019a = new b();

        private a() {
        }
    }

    public static b a() {
        return a.f41019a;
    }

    private b() {
        this.f41006b = new AtomicInteger(-1);
    }

    private boolean l() {
        return ToolUtils.isMainProcess(App.context());
    }

    public Completable e() {
        return Completable.defer(new Callable() {
            @Override
            public final Object call() {
                CompletableSource m;
                m = b.this.m();
                return m;
            }
        }).onErrorComplete();
    }

    public Single<Boolean> f() {
        return Single.defer(new Callable<SingleSource<? extends Boolean>>() {
            @Override
            public SingleSource<? extends Boolean> call() {
                boolean z;
                int i = b.this.i().getInt("recommend_ad", -1);
                if (i == -1) {
                    return b.this.g();
                }
                if (i == 200) {
                    z = true;
                } else {
                    z = false;
                }
                return Single.just(Boolean.valueOf(z));
            }
        });
    }

    public Single<Boolean> h() {
        return Single.defer(new Callable<SingleSource<? extends Boolean>>() {
            @Override
            public SingleSource<? extends Boolean> call() {
                return Single.just(Boolean.valueOf(b.this.c()));
            }
        });
    }

    public SharedPreferences i() {
        return KvCacheMgr.getPrivate(App.context(), "compliance_0");
    }

    private int j() {
        int i = this.f41006b.get();
        if (i != -1) {
            return i;
        }
        int i2 = i().getInt("recommend_novel", -1);
        this.f41006b.set(i2);
        return i2;
    }

    public CompletableSource m() throws Exception {
        if (j() == -1) {
            return k().ignoreElement();
        }
        return Completable.complete();
    }

    private Single<Boolean> k() {
        if (!l()) {
            return Single.error(new RuntimeException("not main process, fetching is forbidden"));
        }
        return PrivacyCenter.a().flatMap(new Function() {
            @Override
            public final Object apply(Object obj) {
                SingleSource a2;
                a2 = b.this.a((d) obj);
                return a2;
            }
        }).doOnError(new Consumer() {
            @Override
            public final void accept(Object obj) {
                b.this.b((Throwable) obj);
            }
        }).doOnSuccess(new Consumer() {
            @Override
            public final void accept(Object obj) {
                b.this.a((Boolean) obj);
            }
        });
    }

    @Override
    public boolean c() {
        if (j() != 403 && !i.f40671a.b()) {
            return true;
        }
        return false;
    }

    public Single<Boolean> g() {
        if (!l()) {
            return Single.error(new RuntimeException("not main process, fetching is forbidden"));
        }
        return ((AdRecommendApi) com.dragon.read.base.http.c.a("https://ad.zijieapi.com/", AdRecommendApi.class)).getConfig(true).map(new Function<com.dragon.read.app.privacy.api.b, Boolean>() {
            @Override
            public Boolean apply(com.dragon.read.app.privacy.api.b bVar) throws Exception {
                b.f41005a.i("广告- get ad recommend result = %s", bVar);
                if (bVar.a()) {
                    return Boolean.valueOf(bVar.c());
                }
                throw bVar.b();
            }
        }).doOnError(new Consumer<Throwable>() {
            @Override
            public void accept(Throwable th) {
                b.f41005a.e("广告- get ad recommend has error = %s", Log.getStackTraceString(th));
            }
        }).doOnSuccess(a("recommend_ad"));
    }

    @Override
    public boolean b() {
        int i = i().getInt("recommend_ad", -1);
        if (i == -1 || i == 200) {
            return true;
        }
        return false;
    }

    public void d() {
        f41005a.i("当前隐私合规推荐信息配置如下：ad=%s, novel=%s", Integer.valueOf(i().getInt("recommend_ad", -1)), Integer.valueOf(i().getInt("recommend_novel", -1)));
        k().subscribeOn(Schedulers.single()).onErrorReturnItem(false).subscribe();
    }

    private Consumer<Boolean> a(final String str) {
        return new Consumer<Boolean>() {
            @Override
            public void accept(Boolean bool) {
                int i;
                SharedPreferences.Editor edit = b.this.i().edit();
                String str2 = str;
                if (bool.booleanValue()) {
                    i = 200;
                } else {
                    i = 403;
                }
                edit.putInt(str2, i);
            }
        };
    }

    public void d(boolean z) throws Exception {
        c(z);
        App.sendLocalBroadcast(new Intent("action_novel_recommend_mode_changed"));
    }

    public void a(Boolean bool) throws Exception {
        this.f41006b.compareAndSet(-1, 200);
    }

    public void b(Throwable th) throws Exception {
        f41005a.e("隐私- get novel recommend has error = %s", Log.getStackTraceString(th));
        this.f41006b.compareAndSet(-1, 200);
    }

    private void c(boolean z) throws Exception {
        int i;
        if (z) {
            i = 200;
        } else {
            i = 403;
        }
        a("recommend_novel", z).run();
        this.f41006b.set(i);
    }

    public static void a(Throwable th) throws Exception {
        f41005a.e("隐私- update novel recommend has error = %s", Log.getStackTraceString(th));
    }

    public Completable b(final boolean z) {
        return PrivacyCenter.a(z).doOnError(new Consumer() {
            @Override
            public final void accept(Object obj) {
                b.a((Throwable) obj);
            }
        }).doOnComplete(new Action() {
            @Override
            public final void run() {
                b.this.d(z);
            }
        });
    }

    public SingleSource a(d dVar) throws Exception {
        boolean z;
        LogHelper logHelper = f41005a;
        logHelper.i("隐私- get novel recommend result = %s", dVar);
        if (dVar.b()) {
            int j = j();
            if (j != 403) {
                z = true;
            } else {
                z = false;
            }
            logHelper.i("隐私 - update privacy setting. local = %d, setting = %s", Integer.valueOf(j), dVar);
            if (dVar.d()) {
                return PrivacyCenter.a(z).toSingleDefault(true);
            }
            c(dVar.a());
        }
        return Single.just(true);
    }

    public Completable a(final boolean z) {
        HashMap hashMap = new HashMap();
        hashMap.put("disable", Integer.valueOf(!z ? 1 : 0));
        return ((AdRecommendApi) com.dragon.read.base.http.c.a("https://ad.zijieapi.com/", AdRecommendApi.class)).updateConfig(hashMap, true).flatMapCompletable(new Function<com.dragon.read.app.privacy.api.c, CompletableSource>() {
            @Override
            public CompletableSource apply(com.dragon.read.app.privacy.api.c cVar) {
                b.f41005a.i("广告- update ad recommend request[enable] = %s, result = %s", Boolean.valueOf(z), cVar);
                if (cVar.a()) {
                    return Completable.complete();
                }
                return Completable.error(cVar.b());
            }
        }).doOnError(new Consumer<Throwable>() {
            @Override
            public void accept(Throwable th) {
                b.f41005a.e("广告- update ad recommend has error = %s", Log.getStackTraceString(th));
            }
        }).doOnComplete(a("recommend_ad", z));
    }

    private Action a(final String str, final boolean z) {
        return new Action() {
            @Override
            public void run() {
                int i;
                SharedPreferences.Editor edit = b.this.i().edit();
                String str2 = str;
                if (z) {
                    i = 200;
                } else {
                    i = 403;
                }
                edit.putInt(str2, i);
            }
        };
    }
}