零界绘 v1.0.2 - DownloadBookService.java 源代码

package com.junyue.novel.modules.bookshelf.service;

import android.app.Application;
import android.app.Notification;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.Intent;
import android.os.Build;
import android.os.IBinder;
import androidx.core.app.NotificationCompat;
import com.junyue.basic.app.App;
import com.junyue.novel.modules_bookshelf.R;
import com.junyue.novel.sharebean.BookDownload;
import com.junyue.novel.sharebean.reader.BookChapterBean;
import com.junyue.novel.sharebean.reader.CollBookBean;
import f.p.c.z.c1;
import f.p.c.z.u0;
import f.p.c.z.z0;
import f.p.f.a.c;
import i.b0.c.t;
import i.b0.c.u;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.ObservableEmitter;
import io.reactivex.rxjava3.core.ObservableOnSubscribe;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;
import io.reactivex.rxjava3.functions.Function;
import java.util.Iterator;
import java.util.List;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function2;

public final class DownloadBookService extends Service {
    public static final String p;
    public final i.d n = c1.b(f.n);
    public final f.p.g.g.a.c.a o = f.p.g.g.a.c.a.i;

    public static final class a<T> implements ObservableOnSubscribe<Boolean> {
        public static final a a = new a();

        @Override
        public final void subscribe(ObservableEmitter<Boolean> observableEmitter) {
            observableEmitter.onComplete();
        }
    }

    public static final class b<T, R> implements Function<String, Boolean> {
        public final BookDownload o;
        public final BookChapterBean p;

        public b(BookDownload bookDownload, BookChapterBean bookChapterBean) {
            this.o = bookDownload;
            this.p = bookChapterBean;
        }

        @Override
        public final Boolean apply(String str) {
            boolean z;
            t.e(str, "url");
            try {
                DownloadBookService downloadBookService = DownloadBookService.this;
                String c = this.o.c();
                t.d(c, "current.bookId");
                BookChapterBean bookChapterBean = this.p;
                List list = this.p.srcList;
                t.d(list, "chapter.srcList");
                f.p.g.g.a.d.a.b(downloadBookService, c, bookChapterBean, list);
                z = true;
            } catch (Throwable unused) {
                z = false;
            }
            return Boolean.valueOf(z);
        }
    }

    public static final class c extends u implements Function2<Observer<Boolean>, Disposable, i.t> {
        public c() {
            super(2);
        }

        public final void b(Observer<Boolean> observer, Disposable disposable) {
            t.e(observer, "$receiver");
            DownloadBookService.this.f().C(disposable);
        }

        public Object invoke(Object obj, Object obj2) {
            b((Observer) obj, (Disposable) obj2);
            return i.t.a;
        }
    }

    public static final class d extends u implements Function2<Observer<Boolean>, Boolean, i.t> {
        public final BookDownload o;
        public final BookChapterBean p;

        public d(BookDownload bookDownload, BookChapterBean bookChapterBean) {
            super(2);
            this.o = bookDownload;
            this.p = bookChapterBean;
        }

        public final void b(Observer<Boolean> observer, Boolean bool) {
            t.e(observer, "$receiver");
            this.o.p();
            for (c.b bVar : DownloadBookService.this.f().m()) {
                BookDownload bookDownload = this.o;
                bVar.j(bookDownload, this.p, bookDownload.g(), this.o.end, true);
            }
            DownloadBookService.this.i(this.o);
            if (DownloadBookService.this.f().o()) {
                return;
            }
            DownloadBookService.this.d();
        }

        public Object invoke(Object obj, Object obj2) {
            b((Observer) obj, (Boolean) obj2);
            return i.t.a;
        }
    }

    public static final class e extends u implements Function2<Observer<Boolean>, Throwable, i.t> {
        public final BookDownload o;
        public final BookChapterBean p;

        public e(BookDownload bookDownload, BookChapterBean bookChapterBean) {
            super(2);
            this.o = bookDownload;
            this.p = bookChapterBean;
        }

        public final void b(Observer<Boolean> observer, Throwable th) {
            t.e(observer, "$receiver");
            if (!f.p.c.s.b.j()) {
                f.p.g.g.a.c.a.i.t(this.o);
                Application application = DownloadBookService.this.getApplication();
                t.d(application, "application");
                u0.l(application, R.string.download_network_error_default_error_msg, 0, 2, null);
                DownloadBookService.this.stopSelf();
                return;
            }
            this.o.p();
            for (c.b bVar : DownloadBookService.this.f().m()) {
                BookDownload bookDownload = this.o;
                bVar.j(bookDownload, this.p, bookDownload.g(), this.o.d(), false);
            }
            DownloadBookService.this.i(this.o);
            if (DownloadBookService.this.f().o()) {
                return;
            }
            DownloadBookService.this.d();
        }

        public Object invoke(Object obj, Object obj2) {
            b((Observer) obj, (Throwable) obj2);
            return i.t.a;
        }
    }

    public static final class f extends u implements Function0<Class<?>> {
        public static final f n = new f();

        public f() {
            super(0);
        }

        public final Class<?> invoke() {
            return z0.a("/index/main");
        }
    }

    static {
        StringBuilder sb = new StringBuilder();
        e.a.b.c.c r = App.r();
        t.d(r, "App.getInstance()");
        sb.append(r.getPackageName());
        sb.append("$book_download");
        p = sb.toString();
    }

    public final Notification c(BookDownload bookDownload) {
        Object systemService = getSystemService("notification");
        if (systemService == null) {
            throw new NullPointerException("null cannot be cast to non-null type android.app.NotificationManager");
        }
        NotificationManager notificationManager = (NotificationManager) systemService;
        if (Build.VERSION.SDK_INT >= 26) {
            NotificationChannel notificationChannel = new NotificationChannel(p, getApplicationContext().getString(R.string.book_download_channel), 2);
            notificationChannel.setSound(null, null);
            notificationManager.createNotificationChannel(notificationChannel);
        }
        NotificationCompat.Builder contentTitle = new NotificationCompat.Builder(this, p).setContentTitle("漫画缓存");
        StringBuilder sb = new StringBuilder();
        sb.append("正在缓存:");
        CollBookBean b2 = bookDownload.b();
        t.d(b2, "download.bookBean");
        sb.append(b2.H());
        sb.append(" ");
        sb.append(bookDownload.i());
        Notification build = contentTitle.setContentText(sb.toString()).setSmallIcon(R.mipmap.ic_launcher).build();
        Intent intent = new Intent(this, g());
        intent.putExtra("nav_transform", "/bookshelf/book_download_manger");
        build.contentIntent = PendingIntent.getActivity(this, 0, intent, 134217728);
        t.d(build, "notification");
        return build;
    }

    public final void d() {
        if (this.o.o()) {
            this.o.A(false);
        }
        BookDownload p2 = this.o.p();
        if (p2 == null) {
            h();
            return;
        }
        i(p2);
        if (p2.g() >= p2.end - 1) {
            e(p2);
            return;
        }
        p2.t(p2.g() + 1);
        if (p2.g() >= p2.end) {
            e(p2);
            return;
        }
        BookChapterBean bookChapterBean = f.p.g.g.a.c.b.a(p2).get(p2.g());
        Observable observable = Observable.create(a.a).concatWith(Observable.just(f.p.c.f.a.a).map(new b(p2, bookChapterBean))).firstOrError().toObservable();
        t.d(observable, "Observable.create<Boolea…          .toObservable()");
        f.p.d.b.a.e(observable).subscribe(f.p.c.w.c.b(new c(), new d(p2, bookChapterBean), new e(p2, bookChapterBean), null, false, false, 56, null));
    }

    public final void e(BookDownload bookDownload) {
        bookDownload.t(bookDownload.end);
        bookDownload.p();
        f.p.g.g.a.c.a.i.f(bookDownload);
        for (c.b bVar : this.o.m()) {
            bVar.n(bookDownload);
        }
        this.o.D();
        i(bookDownload);
        this.o.B(null);
        for (c.b bVar2 : this.o.m()) {
            bVar2.E();
        }
        h();
    }

    public final f.p.g.g.a.c.a f() {
        return this.o;
    }

    public final Class<?> g() {
        return (Class) this.n.getValue();
    }

    public final void h() {
        if (this.o.p() != null) {
            return;
        }
        Iterator<BookDownload> it = this.o.r().iterator();
        BookDownload bookDownload = null;
        while (it.hasNext()) {
            BookDownload next = it.next();
            t.d(next, "d");
            if (!next.l() && !next.m()) {
                bookDownload = next;
            }
        }
        if (bookDownload == null) {
            this.o.B(null);
            stopSelf();
        } else {
            this.o.B(bookDownload);
            d();
            startForeground(R.id.notification_book_download, c(bookDownload));
            this.o.g();
        }
    }

    public final void i(BookDownload bookDownload) {
        if (bookDownload.h() != bookDownload.k()) {
            f.p.g.g.a.c.a.z(this.o, bookDownload, false, 2, null);
            startForeground(R.id.notification_book_download, c(bookDownload));
        }
    }

    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        stopForeground(true);
        Disposable q = this.o.q();
        if (q != null) {
            q.dispose();
        }
    }

    @Override
    public int onStartCommand(Intent intent, int i, int i2) {
        h();
        return super.onStartCommand(intent, i, i2);
    }
}