package com.ylb.home.viewmodel;
import android.app.Application;
import android.view.View;
import androidx.annotation.NonNull;
import androidx.databinding.ObservableArrayList;
import androidx.databinding.ObservableField;
import androidx.lifecycle.AndroidViewModel;
import androidx.lifecycle.MutableLiveData;
import com.alibaba.android.arouter.launcher.ARouter;
import com.alipay.sdk.widget.j;
import com.xliang.shengxin.base.BaseConst;
import com.xliang.shengxin.base.account.AccountManager;
import com.xliang.shengxin.base.dialog.AlertBottomDialog;
import com.xliang.shengxin.base.interfaces.DataResponseListener;
import com.xliang.shengxin.base.network.RetrofitManager;
import com.xliang.shengxin.base.observer.ResponseObserver;
import com.xliang.shengxin.base.router.RouterPath;
import com.xliang.shengxin.base.utils.RouterUtils;
import com.xliang.shengxin.base.utils.RxUtils;
import com.xliang.shengxin.base.utils.TimeUtil;
import com.xliang.shengxin.base.utils.ToastUtil;
import com.ylb.home.BR;
import com.ylb.home.R;
import com.ylb.home.api.HomeApi;
import com.ylb.home.constants.LoadingStatus;
import com.ylb.home.domain.SuCaiPkgDetail;
import com.ylb.module.common.api.CommonApi;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Predicate;
import io.reactivex.schedulers.Schedulers;
import java.util.HashMap;
import java.util.concurrent.TimeUnit;
import me.tatarka.bindingcollectionadapter2.ItemBinding;
import tv.danmaku.ijk.media.player.IjkMediaPlayer;
public class SuCaiPkgViewModel extends AndroidViewModel {
public ObservableField<String> btnValue = new ObservableField<>();
public ObservableField<String> countdownDisplayTime = new ObservableField<>();
public ObservableField<Long> countdownTime = new ObservableField<>();
private Disposable disposable;
public ItemBinding<SuCaiPkgDetail.RecommendSuCai> itemBinding = ItemBinding.of(BR.recommend_item, R.layout.home_sucai_recommend_item);
public int leftPack;
private MutableLiveData<Integer> loadingStatus = new MutableLiveData<>();
public ObservableArrayList<SuCaiPkgDetail.RecommendSuCai> recommendList = new ObservableArrayList<>();
public ItemBinding<String> snapshotItemBinding = ItemBinding.of(BR.snapshotUrl, R.layout.sucai_pkg_detail_snapshot_layout);
public ObservableField<SuCaiPkgDetail> sucaiDetail = new ObservableField<>();
public SuCaiPkgViewModel(@NonNull Application application) {
super(application);
}
public void requestSuCaiDetail(int i) {
this.loadingStatus.setValue(0);
((HomeApi) RetrofitManager.create(HomeApi.class)).getSuCaiPkgDetail(i).compose(RxUtils.schedulersTransformer()).compose(RxUtils.responseTransformer()).subscribe(new ResponseObserver<SuCaiPkgDetail>() {
/* class com.ylb.home.viewmodel.SuCaiPkgViewModel.AnonymousClass1 */
public void onSuccess(SuCaiPkgDetail suCaiPkgDetail) {
boolean z;
if (suCaiPkgDetail != null) {
SuCaiPkgViewModel suCaiPkgViewModel = SuCaiPkgViewModel.this;
int i = suCaiPkgDetail.leftPack;
suCaiPkgViewModel.leftPack = i;
if (i == -1 || (((z = AccountManager.isVip) && i > 0) || suCaiPkgDetail.isBuy == 1)) {
suCaiPkgViewModel.btnValue.set("立即领取");
} else if (!z || i != 0) {
suCaiPkgViewModel.btnValue.set("会员免费领");
} else {
suCaiPkgViewModel.btnValue.set("永久会员免费领");
}
SuCaiPkgViewModel.this.sucaiDetail.set(suCaiPkgDetail);
SuCaiPkgViewModel.this.recommendList.addAll(suCaiPkgDetail.sugList);
SuCaiPkgViewModel.this.countdownTime.set(Long.valueOf(suCaiPkgDetail.countdownSeconds));
SuCaiPkgViewModel suCaiPkgViewModel2 = SuCaiPkgViewModel.this;
suCaiPkgViewModel2.disposable = SuCaiPkgViewModel.startCountDown(suCaiPkgViewModel2.countdownTime, suCaiPkgViewModel2.countdownDisplayTime);
SuCaiPkgViewModel.this.setLoadingStatus(2);
return;
}
SuCaiPkgViewModel.this.setLoadingStatus(1);
}
@Override // com.xliang.shengxin.base.observer.ResponseObserver, io.reactivex.Observer
public void onError(Throwable th) {
super.onError(th);
SuCaiPkgViewModel.this.setLoadingStatus(1);
}
});
}
public void requestPackNum(int i) {
((HomeApi) RetrofitManager.create(HomeApi.class)).getSuCaiPkgDetail(i).compose(RxUtils.schedulersTransformer()).compose(RxUtils.responseTransformer()).subscribe(new ResponseObserver<SuCaiPkgDetail>() {
/* class com.ylb.home.viewmodel.SuCaiPkgViewModel.AnonymousClass2 */
public void onSuccess(SuCaiPkgDetail suCaiPkgDetail) {
if (suCaiPkgDetail != null) {
SuCaiPkgViewModel.this.leftPack = suCaiPkgDetail.leftPack;
}
}
@Override // com.xliang.shengxin.base.observer.ResponseObserver, io.reactivex.Observer
public void onError(Throwable th) {
super.onError(th);
}
});
}
public static Disposable startCountDown(ObservableField<Long> observableField, ObservableField<String> observableField2) {
return Observable.interval(1, TimeUnit.SECONDS).takeUntil(new Predicate() {
/* class com.ylb.home.viewmodel.$$Lambda$SuCaiPkgViewModel$iCCJRlKdMcshcnfblrQEglxTTK0 */
@Override // io.reactivex.functions.Predicate
public final boolean test(Object obj) {
return SuCaiPkgViewModel.lambda$startCountDown$0(ObservableField.this, (Long) obj);
}
}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer(observableField2) {
/* class com.ylb.home.viewmodel.$$Lambda$SuCaiPkgViewModel$LFmjOlB0k9YjxMA91K0dQYQ9QU */
public final /* synthetic */ ObservableField f$1;
{
this.f$1 = r2;
}
@Override // io.reactivex.functions.Consumer
public final void accept(Object obj) {
SuCaiPkgViewModel.lambda$startCountDown$1(ObservableField.this, this.f$1, (Long) obj);
}
});
}
static /* synthetic */ boolean lambda$startCountDown$0(ObservableField observableField, Long l) throws Exception {
return ((Long) observableField.get()).longValue() <= 1;
}
static /* synthetic */ void lambda$startCountDown$1(ObservableField observableField, ObservableField observableField2, Long l) throws Exception {
long longValue = ((Long) observableField.get()).longValue() - 1;
observableField.set(Long.valueOf(longValue));
observableField2.set(TimeUtil.getCountDownTime(longValue * 1000));
}
public MutableLiveData<Integer> getLoadingStatus() {
return this.loadingStatus;
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void setLoadingStatus(@LoadingStatus int i) {
this.loadingStatus.setValue(Integer.valueOf(i));
}
public void foreverVipGetSuCaiPkg(View view, int i) {
if (this.sucaiDetail.get().isBuy == 1) {
gotoSuCaiPkgDownloadInfo(i);
} else if (AccountManager.isForeverVip()) {
createOrder(i);
} else if (BaseConst.CHANNEL_SUB.equals(AccountManager.channel) && AccountManager.isVip && this.leftPack > 0) {
showDialog(view, i);
} else if (!BaseConst.CHANNEL_SUB.equals(AccountManager.channel) || !AccountManager.isVip || this.leftPack != 0) {
RouterUtils.toVipView();
} else {
showDialog2(view);
}
}
private void showDialog2(View view) {
String str;
if (!AccountManager.isVip || AccountManager.vipType != 2) {
str = (!AccountManager.isVip || AccountManager.vipType != 7) ? "提示" : "您当前是季会员";
} else {
str = "您当前是年会员";
}
AlertBottomDialog alertBottomDialog = new AlertBottomDialog(view.getContext());
alertBottomDialog.setTitle(str);
alertBottomDialog.setMsgContent("素材包领取已上限，开通永久会员无限制领取");
alertBottomDialog.showIvClose();
alertBottomDialog.setBtnOkContent("立即升级永久会员");
alertBottomDialog.setListener($$Lambda$SuCaiPkgViewModel$7Fo5N99XgJwc76T7yg3K4WTZFMo.INSTANCE);
alertBottomDialog.show();
}
private void showDialog(View view, int i) {
String str;
if (!AccountManager.isVip || AccountManager.vipType != 2) {
str = (!AccountManager.isVip || AccountManager.vipType != 7) ? "提示" : "您当前是季会员";
} else {
str = "您当前是年会员";
}
AlertBottomDialog alertBottomDialog = new AlertBottomDialog(view.getContext());
alertBottomDialog.setTitle(str);
alertBottomDialog.showIvClose();
alertBottomDialog.setMsgContent("还可领取" + this.leftPack + "个,共" + AccountManager.totalPack + "个素材包可领取");
alertBottomDialog.setBtnOkContent("确定领取素材包");
alertBottomDialog.setBtnOk2Content("立即升级永久会员");
alertBottomDialog.setListener(new DataResponseListener(i) {
/* class com.ylb.home.viewmodel.$$Lambda$SuCaiPkgViewModel$hme4K5LhNbbldu5Qug7_kXjKG0 */
public final /* synthetic */ int f$1;
{
this.f$1 = r2;
}
@Override // com.xliang.shengxin.base.interfaces.DataResponseListener
public final void onResponse(Object obj) {
SuCaiPkgViewModel.this.lambda$showDialog$3$SuCaiPkgViewModel(this.f$1, (Boolean) obj);
}
});
alertBottomDialog.setListener2($$Lambda$SuCaiPkgViewModel$KAC1ak58p1udUmy51lWb9LYSnM.INSTANCE);
alertBottomDialog.show();
}
/* access modifiers changed from: private */
/* renamed from: lambda$showDialog$3 */
public /* synthetic */ void lambda$showDialog$3$SuCaiPkgViewModel(int i, Boolean bool) {
createOrder(i);
}
private void createOrder(final int i) {
if (this.loadingStatus.getValue().intValue() != 0) {
setLoadingStatus(0);
if (BaseConst.CHANNEL_SUB.equals(AccountManager.channel)) {
((CommonApi) RetrofitManager.create(CommonApi.class)).createOrder2(i).compose(RxUtils.schedulersTransformer()).compose(RxUtils.responseTransformer()).subscribe(new ResponseObserver<String>() {
/* class com.ylb.home.viewmodel.SuCaiPkgViewModel.AnonymousClass3 */
public void onSuccess(String str) {
SuCaiPkgViewModel.this.setLoadingStatus(3);
SuCaiPkgViewModel.this.commitOrder(str, i);
}
@Override // com.xliang.shengxin.base.observer.ResponseObserver, io.reactivex.Observer
public void onError(Throwable th) {
super.onError(th);
SuCaiPkgViewModel.this.setLoadingStatus(3);
ToastUtil.Short("获取失败，请稍后再试");
}
});
} else {
((CommonApi) RetrofitManager.create(CommonApi.class)).createOrder(i).compose(RxUtils.schedulersTransformer()).compose(RxUtils.responseTransformer()).subscribe(new ResponseObserver<String>() {
/* class com.ylb.home.viewmodel.SuCaiPkgViewModel.AnonymousClass4 */
public void onSuccess(String str) {
SuCaiPkgViewModel.this.setLoadingStatus(3);
SuCaiPkgViewModel.this.commitOrder(str, i);
}
@Override // com.xliang.shengxin.base.observer.ResponseObserver, io.reactivex.Observer
public void onError(Throwable th) {
super.onError(th);
SuCaiPkgViewModel.this.setLoadingStatus(3);
ToastUtil.Short("获取失败，请稍后再试");
}
});
}
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void commitOrder(String str, final int i) {
setLoadingStatus(0);
HashMap hashMap = new HashMap();
hashMap.put("orderNo", str);
hashMap.put("paymentType", 21);
((CommonApi) RetrofitManager.create(CommonApi.class)).commitOrder(hashMap).compose(RxUtils.schedulersTransformer()).compose(RxUtils.responseTransformer()).subscribe(new ResponseObserver<String>() {
/* class com.ylb.home.viewmodel.SuCaiPkgViewModel.AnonymousClass5 */
public void onSuccess(String str) {
SuCaiPkgViewModel.this.setLoadingStatus(3);
if (SuCaiPkgViewModel.this.leftPack <= 0 || "ok".equals(str)) {
SuCaiPkgViewModel.this.sucaiDetail.get().isBuy = 1;
SuCaiPkgViewModel.gotoSuCaiPkgDownloadInfo(i);
int i = SuCaiPkgViewModel.this.leftPack;
if (i != -1 && i != 0) {
if (BaseConst.CHANNEL_SUB.equals(AccountManager.channel)) {
SuCaiPkgViewModel suCaiPkgViewModel = SuCaiPkgViewModel.this;
int i2 = suCaiPkgViewModel.leftPack - 1;
suCaiPkgViewModel.leftPack = i2;
if (i2 > 0) {
AccountManager.leftPack--;
ToastUtil.Long("还剩" + SuCaiPkgViewModel.this.leftPack + "个素材包可领取");
return;
}
}
if (BaseConst.CHANNEL_SUB.equals(AccountManager.channel)) {
ToastUtil.Long("您的素材包已领取完");
return;
}
return;
}
return;
}
ToastUtil.Short("购买失败");
}
@Override // com.xliang.shengxin.base.observer.ResponseObserver
public void onError(String str, String str2) {
super.onError(str, str2);
SuCaiPkgViewModel.this.setLoadingStatus(3);
ToastUtil.Short("获取失败，请稍后再试");
}
});
}
public static void gotoSuCaiPkgDownloadInfo(int i) {
ARouter.getInstance().build(RouterPath.Common.ROUTE_WEB_VIEW).withString(IjkMediaPlayer.OnNativeInvokeListener.ARG_URL, "https://www.xlgogo.com/pages/sucaisx/downloadDetail?id=" + i + "&token=" + AccountManager.getToken()).withString(j.k, "百度网盘").navigation();
}
/* access modifiers changed from: protected */
@Override // androidx.lifecycle.ViewModel
public void onCleared() {
super.onCleared();
Disposable disposable2 = this.disposable;
if (disposable2 != null && !disposable2.isDisposed()) {
this.disposable.dispose();
}
}
}