导航菜单
登录 注册

页面标题

页面副标题

TruCred v1.1.3 - UploadFileIntentService.java 源代码

正在查看： TruCred v1.1.3 应用的 UploadFileIntentService.java JAVA 源代码文件

本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。 


package com.veloz.app.service;

import android.app.IntentService;
import android.content.Context;
import android.content.Intent;
import android.graphics.Bitmap;
import android.os.Parcelable;
import com.amazonaws.auth.BasicSessionCredentials;
import com.amazonaws.mobileconnectors.s3.transferutility.TransferListener;
import com.amazonaws.mobileconnectors.s3.transferutility.TransferState;
import com.amazonaws.mobileconnectors.s3.transferutility.TransferUtility;
import com.amazonaws.services.s3.AmazonS3Client;
import com.blankj.utilcode.util.FileUtils;
import com.blankj.utilcode.util.ImageUtils;
import com.blankj.utilcode.util.LogUtils;
import com.jeremyliao.liveeventbus.LiveEventBus;
import com.veloz.app.entity.LiveIdentifyInfo;
import com.veloz.app.entity.LiveIdentifyNotifyInfo;
import com.veloz.app.entity.ResultGotInfo;
import com.veloz.app.entity.UploadCompleteEntity;
import com.veloz.app.entity.UserStorageTempToken;
import com.veloz.app.http.Callback;
import com.veloz.app.http.Repository;
import com.veloz.app.service.UploadFileIntentService;
import com.veloz.app.utils.FileUtil;
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.ObservableEmitter;
import io.reactivex.rxjava3.core.ObservableOnSubscribe;
import io.reactivex.rxjava3.core.ObservableSource;
import io.reactivex.rxjava3.functions.Consumer;
import io.reactivex.rxjava3.functions.Function;
import io.reactivex.rxjava3.schedulers.Schedulers;
import java.io.File;

public class UploadFileIntentService extends IntentService {
    public UploadCompleteEntity a;
    public AmazonS3Client b;
    public AmazonS3Client c;

    public UploadFileIntentService() {
        super("UploadFileIntentService");
    }

    public static void s(UploadCompleteEntity uploadCompleteEntity) {
        LiveEventBus.get("UploadCompleteEntity").post(uploadCompleteEntity);
        LogUtils.e(new Object[]{"uploadImages completed: " + uploadCompleteEntity.toString()});
    }

    public static void startUploadIDImage(Context context, String str) {
        Intent intent = new Intent(context, (Class<?>) UploadFileIntentService.class);
        intent.setAction("com.veloz.app.service.action.uploadIDImg");
        intent.putExtra("com.veloz.app.service.extra.id_data", str);
        context.startService(intent);
    }

    public static void startUploadLiveImage(Context context, Parcelable parcelable) {
        Intent intent = new Intent(context, (Class<?>) UploadFileIntentService.class);
        intent.setAction("com.veloz.app.service.action.uploadLiveImg");
        intent.putExtra("com.veloz.app.service.extra.live_data", parcelable);
        context.startService(intent);
    }

    public static void t(Throwable th) {
        LiveEventBus.get("UploadCompleteEntity").post(null);
        LogUtils.e(new Object[]{"uploadImages error:" + th.getMessage()});
    }

    public static void w(LiveIdentifyNotifyInfo liveIdentifyNotifyInfo) {
        LiveEventBus.get("LiveIdentifyNotifyInfo").post(liveIdentifyNotifyInfo);
        LogUtils.e(new Object[]{"LiveIdentifyNotifyInfo completed: " + liveIdentifyNotifyInfo.toString()});
    }

    public static void x(Throwable th) {
        LiveEventBus.get("LiveIdentifyNotifyInfo").post(null);
        LogUtils.e(new Object[]{"LiveIdentifyNotifyInfo error" + th.getMessage()});
    }

    public final void A(String str, UserStorageTempToken userStorageTempToken, final ObservableEmitter observableEmitter) {
        try {
            File file = new File(str);
            UserStorageTempToken.UploadImageCompressionMate uploadImageCompressionMate = userStorageTempToken.imageCompression;
            if (uploadImageCompressionMate != null) {
                LogUtils.e(new Object[]{"A：" + FileUtils.getLength(file)});
                if (uploadImageCompressionMate.convertSize < FileUtils.getLength(file)) {
                    ImageUtils.save(FileUtil.a(ImageUtils.getBitmap(file), uploadImageCompressionMate.width, uploadImageCompressionMate.height, uploadImageCompressionMate.convertSize, uploadImageCompressionMate.quality), str, Bitmap.CompressFormat.JPEG);
                    file = new File(str);
                    LogUtils.e(new Object[]{"A：" + FileUtils.getLength(file)});
                }
            }
            UploadCompleteEntity uploadCompleteEntity = new UploadCompleteEntity();
            this.a = uploadCompleteEntity;
            uploadCompleteEntity.fileName = userStorageTempToken.privateFilePathWithExt;
            uploadCompleteEntity.fileSize = FileUtils.getLength(file);
            UploadCompleteEntity uploadCompleteEntity2 = this.a;
            uploadCompleteEntity2.tempUrl = userStorageTempToken.tempUrl;
            uploadCompleteEntity2.tempUrlBase64 = userStorageTempToken.tempUrlBase64;
            String str2 = userStorageTempToken.privateFilePathWithoutExt + "." + FileUtils.getFileExtension(str);
            AmazonS3Client amazonS3Client = new AmazonS3Client(new BasicSessionCredentials(userStorageTempToken.accessKeyId, userStorageTempToken.accessKeySecret, userStorageTempToken.securityToken));
            this.b = amazonS3Client;
            amazonS3Client.setEndpoint(userStorageTempToken.endpoint);
            new TransferUtility(this.b, getApplicationContext()).upload(userStorageTempToken.bucketName, str2, file).setTransferListener(new TransferListener() {
                public void onError(int i, Exception exc) {
                    LogUtils.e(new Object[]{"id=" + i});
                }

                public void onProgressChanged(int i, long j2, long j3) {
                    LogUtils.e(new Object[]{"id=" + i});
                }

                public void onStateChanged(int i, TransferState transferState) {
                    LogUtils.e(new Object[]{"onStateChanged"});
                    if (transferState == TransferState.COMPLETED) {
                        UploadFileIntentService.this.a.status = 1;
                        observableEmitter.onNext(UploadFileIntentService.this.a);
                        observableEmitter.onComplete();
                    } else if (transferState == TransferState.FAILED) {
                        UploadFileIntentService.this.a.status = 0;
                        observableEmitter.onNext(UploadFileIntentService.this.a);
                        observableEmitter.onComplete();
                    }
                }
            });
        } catch (Exception unused) {
        }
    }

    public final void B(String str, UserStorageTempToken userStorageTempToken, final ObservableEmitter observableEmitter) {
        try {
            File file = new File(str);
            UserStorageTempToken.UploadImageCompressionMate uploadImageCompressionMate = userStorageTempToken.imageCompression;
            if (uploadImageCompressionMate != null) {
                LogUtils.e(new Object[]{"A：" + FileUtils.getLength(file)});
                if (uploadImageCompressionMate.convertSize < FileUtils.getLength(file)) {
                    ImageUtils.save(FileUtil.a(ImageUtils.getBitmap(file), uploadImageCompressionMate.width, uploadImageCompressionMate.height, uploadImageCompressionMate.convertSize, uploadImageCompressionMate.quality), str, Bitmap.CompressFormat.JPEG);
                    file = new File(str);
                    LogUtils.e(new Object[]{"A：" + FileUtils.getLength(file)});
                }
            }
            UploadCompleteEntity uploadCompleteEntity = new UploadCompleteEntity();
            this.a = uploadCompleteEntity;
            uploadCompleteEntity.fileName = userStorageTempToken.privateFilePathWithExt;
            uploadCompleteEntity.fileSize = FileUtils.getLength(file);
            this.a.fileBusinessType = 9030;
            String str2 = userStorageTempToken.privateFilePathWithoutExt + "." + FileUtils.getFileExtension(str);
            AmazonS3Client amazonS3Client = new AmazonS3Client(new BasicSessionCredentials(userStorageTempToken.accessKeyId, userStorageTempToken.accessKeySecret, userStorageTempToken.securityToken));
            this.c = amazonS3Client;
            amazonS3Client.setEndpoint(userStorageTempToken.endpoint);
            new TransferUtility(this.c, getApplicationContext()).upload(userStorageTempToken.bucketName, str2, file).setTransferListener(new TransferListener() {
                public void onError(int i, Exception exc) {
                    observableEmitter.onError(exc);
                }

                public void onProgressChanged(int i, long j2, long j3) {
                    LogUtils.e(new Object[]{"id=" + i});
                }

                public void onStateChanged(int i, TransferState transferState) {
                    LogUtils.e(new Object[]{"onStateChanged"});
                    if (transferState == TransferState.COMPLETED) {
                        observableEmitter.onNext(UploadFileIntentService.this.a);
                        observableEmitter.onComplete();
                    }
                }
            });
        } catch (Exception unused) {
        }
    }

    public final Observable C(final UploadCompleteEntity uploadCompleteEntity, final LiveIdentifyInfo liveIdentifyInfo) {
        return Observable.create(new ObservableOnSubscribe() {
            @Override
            public final void subscribe(ObservableEmitter observableEmitter) {
                UploadFileIntentService.this.y(uploadCompleteEntity, liveIdentifyInfo, observableEmitter);
            }
        });
    }

    public final Observable D(final UploadCompleteEntity uploadCompleteEntity, final LiveIdentifyInfo liveIdentifyInfo) {
        return Observable.create(new ObservableOnSubscribe() {
            @Override
            public final void subscribe(ObservableEmitter observableEmitter) {
                UploadFileIntentService.this.z(uploadCompleteEntity, liveIdentifyInfo, observableEmitter);
            }
        });
    }

    public final Observable r(final UserStorageTempToken userStorageTempToken, final String str) {
        return Observable.create(new ObservableOnSubscribe() {
            @Override
            public final void subscribe(ObservableEmitter observableEmitter) {
                UploadFileIntentService.this.A(str, userStorageTempToken, observableEmitter);
            }
        });
    }

    public final Observable F(final UserStorageTempToken userStorageTempToken, final String str) {
        return Observable.create(new ObservableOnSubscribe() {
            @Override
            public final void subscribe(ObservableEmitter observableEmitter) {
                UploadFileIntentService.this.B(str, userStorageTempToken, observableEmitter);
            }
        });
    }

    public final Observable n(final String str) {
        return Observable.create(new ObservableOnSubscribe() {
            @Override
            public final void subscribe(ObservableEmitter observableEmitter) {
                UploadFileIntentService.this.q(str, observableEmitter);
            }
        });
    }

    public final void o(final String str) {
        n("jpg").flatMap(new Function() {
            @Override
            public final Object apply(Object obj) {
                ObservableSource r2;
                r2 = UploadFileIntentService.this.r(str, (UserStorageTempToken) obj);
                return r2;
            }
        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer() {
            @Override
            public final void accept(Object obj) {
                UploadFileIntentService.s((UploadCompleteEntity) obj);
            }
        }, new Consumer() {
            @Override
            public final void accept(Object obj) {
                UploadFileIntentService.t((Throwable) obj);
            }
        });
    }

    @Override
    public void onHandleIntent(Intent intent) {
        if (intent != null) {
            String action = intent.getAction();
            if ("com.veloz.app.service.action.uploadLiveImg".equals(action)) {
                p((LiveIdentifyInfo) intent.getParcelableExtra("com.veloz.app.service.extra.live_data"));
            } else if ("com.veloz.app.service.action.uploadIDImg".equals(action)) {
                o(intent.getStringExtra("com.veloz.app.service.extra.id_data"));
            }
        }
    }

    public final void p(final LiveIdentifyInfo liveIdentifyInfo) {
        n("jpg").flatMap(new Function() {
            @Override
            public final Object apply(Object obj) {
                ObservableSource u2;
                u2 = UploadFileIntentService.this.u(liveIdentifyInfo, (UserStorageTempToken) obj);
                return u2;
            }
        }).flatMap(new Function() {
            @Override
            public final Object apply(Object obj) {
                ObservableSource v2;
                v2 = UploadFileIntentService.this.v(liveIdentifyInfo, (UploadCompleteEntity) obj);
                return v2;
            }
        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer() {
            @Override
            public final void accept(Object obj) {
                UploadFileIntentService.w((LiveIdentifyNotifyInfo) obj);
            }
        }, new Consumer() {
            @Override
            public final void accept(Object obj) {
                UploadFileIntentService.x((Throwable) obj);
            }
        });
    }

    public final void q(String str, final ObservableEmitter observableEmitter) {
        Repository.getInstance().getUserStorageTempToken(str, new Callback<UserStorageTempToken>() {
            @Override
            public void onSuccess(UserStorageTempToken userStorageTempToken) {
                observableEmitter.onNext(userStorageTempToken);
                observableEmitter.onComplete();
            }

            @Override
            public void onError(String str2, ResultGotInfo resultGotInfo) {
                super.onError(str2, resultGotInfo);
            }
        });
    }

    public final ObservableSource u(LiveIdentifyInfo liveIdentifyInfo, UserStorageTempToken userStorageTempToken) {
        return F(userStorageTempToken, liveIdentifyInfo.getFilePath());
    }

    public final ObservableSource v(LiveIdentifyInfo liveIdentifyInfo, UploadCompleteEntity uploadCompleteEntity) {
        return liveIdentifyInfo.getLiveType() == 0 ? D(uploadCompleteEntity, liveIdentifyInfo) : C(uploadCompleteEntity, liveIdentifyInfo);
    }

    public final void y(UploadCompleteEntity uploadCompleteEntity, LiveIdentifyInfo liveIdentifyInfo, final ObservableEmitter observableEmitter) {
        try {
            Repository.getInstance().checkLiveIdentifyNotify(uploadCompleteEntity.fileBusinessType, uploadCompleteEntity.fileName, uploadCompleteEntity.fileSize, liveIdentifyInfo.getLivingIdentifyReqNo(), liveIdentifyInfo.getSupplierNo(), liveIdentifyInfo.getTimeCost(), new Callback<LiveIdentifyNotifyInfo>() {
                @Override
                public void onSuccess(LiveIdentifyNotifyInfo liveIdentifyNotifyInfo) {
                    observableEmitter.onNext(liveIdentifyNotifyInfo);
                    observableEmitter.onComplete();
                }

                @Override
                public void onError(String str, ResultGotInfo resultGotInfo) {
                }
            });
        } catch (Exception unused) {
        }
    }

    public final void z(UploadCompleteEntity uploadCompleteEntity, LiveIdentifyInfo liveIdentifyInfo, final ObservableEmitter observableEmitter) {
        try {
            Repository.getInstance().liveIdentifyNotify(uploadCompleteEntity.fileBusinessType, uploadCompleteEntity.fileName, uploadCompleteEntity.fileSize, uploadCompleteEntity.liveJson, liveIdentifyInfo.getLivingIdentifyReqNo(), liveIdentifyInfo.getLivingRecognitionType(), liveIdentifyInfo.getSupplierNo(), liveIdentifyInfo.getTimeCost(), new Callback<LiveIdentifyNotifyInfo>() {
                @Override
                public void onSuccess(LiveIdentifyNotifyInfo liveIdentifyNotifyInfo) {
                    observableEmitter.onNext(liveIdentifyNotifyInfo);
                    observableEmitter.onComplete();
                }

                @Override
                public void onError(String str, ResultGotInfo resultGotInfo) {
                }
            });
        } catch (Exception unused) {
        }
    }
}