⁣逼‌多​多⁣ v3.6.2 - UpdateChannelService.java 源代码

package com.juneRain.jy.commonlib.channel;

import android.app.Service;
import android.content.BroadcastReceiver;
import android.content.Intent;
import android.os.IBinder;
import android.text.TextUtils;
import com.google.gson.reflect.TypeToken;
import com.juneRain.jy.baselib.utils.GsonUtil;
import com.juneRain.jy.baselib.utils.k;
import com.juneRain.jy.baselib.utils.n;
import com.juneRain.jy.commonlib.channel.ChannelManager;
import h1.f;
import h1.g;
import h1.h;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;

public class UpdateChannelService extends Service {
    private static final String e = "UpdateChannelService";
    public static boolean f;
    private BroadcastReceiver a;

    private int f35b = 0;
    ArrayList c;

    k1.a f36d;

    private void e(final String str) {
        this.f36d.b(f.d(new h() {
            public final void a(g gVar) {
                UpdateChannelService.f(str, gVar);
            }
        }).p(x1.a.a()).h(j1.a.a()).m(new m1.c() {
            public final void accept(Object obj) {
                UpdateChannelService.h((String) obj);
            }
        }, new m1.c() {
            public final void accept(Object obj) {
                UpdateChannelService.this.i((Throwable) obj);
            }
        }));
    }

    public static void f(String str, g gVar) {
        URL url = new URL(str);
        k.e(e, "url = " + str + "  ,  start getchannelList = ");
        HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
        httpURLConnection.setConnectTimeout(60000);
        httpURLConnection.setReadTimeout(60000);
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(httpURLConnection.getInputStream()));
        StringBuilder sb = new StringBuilder();
        while (true) {
            String readLine = bufferedReader.readLine();
            if (readLine == null) {
                break;
            } else {
                sb.append(readLine);
            }
        }
        bufferedReader.close();
        httpURLConnection.disconnect();
        String sb2 = sb.toString();
        k.e(e, "url = " + str + "  ,  channelList = " + sb2);
        if (sb.length() <= 0 || httpURLConnection.getResponseCode() != 200) {
            gVar.onError(new Exception());
        } else {
            n.d("channel_list", sb2);
            gVar.onNext(sb2);
        }
    }

    public static void g() {
    }

    public static void h(String str) {
        ArrayList arrayList = new ArrayList(Arrays.asList(str.split("\\|")));
        synchronized (UpdateChannelService.class) {
            try {
                if (ChannelManager.e()) {
                    x.b.a("update_channel_list", str);
                } else {
                    ChannelManager.i(arrayList, new ChannelManager.b() {
                        @Override
                        public final void a() {
                            UpdateChannelService.g();
                        }
                    });
                }
                f = false;
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public void i(Throwable th) {
        int i = this.f35b + 1;
        this.f35b = i;
        if (i < this.c.size()) {
            e((String) this.c.get(this.f35b));
        } else {
            f = false;
        }
    }

    private void j() {
        BroadcastReceiver broadcastReceiver = this.a;
        if (broadcastReceiver != null) {
            unregisterReceiver(broadcastReceiver);
            this.a = null;
        }
    }

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

    @Override
    public void onCreate() {
        super.onCreate();
        this.f36d = new k1.a();
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        j();
        this.f36d.dispose();
        k.b(e, "下载任务服务销毁");
    }

    @Override
    public int onStartCommand(Intent intent, int i, int i3) {
        f = true;
        this.c = new ArrayList();
        String string = n.a("home").getString("update_channel_address", "");
        if (!TextUtils.isEmpty(string)) {
            this.c.addAll((Collection) GsonUtil.b(string, new TypeToken<List<String>>() {
            }.getType()));
        }
        this.f35b = 0;
        if (this.c.size() > 0) {
            e((String) this.c.get(this.f35b));
        }
        return super.onStartCommand(intent, i, i3);
    }
}