⁢性⁤抖⁡音​ v2.3.9 - 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 c1.f;
import c1.g;
import c1.h;
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 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 b = 0;
    ArrayList c;
    f1.a d;

    private void e(final String str) {
        this.d.b(f.e(new h() {
            @Override
            public final void a(g gVar) {
                UpdateChannelService.f(str, gVar);
            }
        }).q(s1.a.a()).i(e1.a.a()).n(new h1.c() {
            public final void accept(Object obj) {
                UpdateChannelService.h((String) obj);
            }
        }, new h1.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.a(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()) {
                    t.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.b + 1;
        this.b = i;
        if (i < this.c.size()) {
            e((String) this.c.get(this.b));
        } 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.d = new f1.a();
    }

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

    @Override
    public int onStartCommand(Intent intent, int i, int i2) {
        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.b = 0;
        if (this.c.size() > 0) {
            e((String) this.c.get(this.b));
        }
        return super.onStartCommand(intent, i, i2);
    }
}