package com.arpa.hndahesudintocctmsdriver.oss; import android.content.ContentResolver; import android.database.Cursor; import android.graphics.Bitmap; import android.net.Uri; import android.os.Build; import android.provider.MediaStore; import android.util.Log; import android.widget.ImageView; import android.widget.ProgressBar; import androidx.appcompat.app.AppCompatActivity; import com.alibaba.sdk.android.oss.ClientConfiguration; import com.alibaba.sdk.android.oss.ClientException; import com.alibaba.sdk.android.oss.OSS; import com.alibaba.sdk.android.oss.OSSClient; import com.alibaba.sdk.android.oss.ServiceException; import com.alibaba.sdk.android.oss.callback.OSSCompletedCallback; import com.alibaba.sdk.android.oss.callback.OSSProgressCallback; import com.alibaba.sdk.android.oss.common.auth.OSSAuthCredentialsProvider; import com.alibaba.sdk.android.oss.common.auth.OSSCredentialProvider; import com.alibaba.sdk.android.oss.internal.OSSAsyncTask; import com.alibaba.sdk.android.oss.model.OSSRequest; import com.alibaba.sdk.android.oss.model.PutObjectRequest; import com.alibaba.sdk.android.oss.model.PutObjectResult; import com.arpa.hndahesudintocctmsdriver.BuildConfig; import com.arpa.hndahesudintocctmsdriver.base.App; import com.arpa.mylibrary.utils.LoadingUtils; import com.arpa.mylibrary.utils.TimeUtil; import com.lxj.xpopup.impl.LoadingPopupView; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.IOException; import java.net.URI; import java.util.ArrayList; import java.util.Calendar; import java.util.HashMap; import java.util.List; import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers; import io.reactivex.rxjava3.core.Observable; import io.reactivex.rxjava3.functions.Consumer; /** * @ClassName OssServiceUtil * @Author 用户 * @Date 2021/9/29 17:53 * @Description TODO */ public class OssServiceUtil { private static OSS oss; private static OSSCredentialProvider credentialProvider; private static ClientConfiguration conf; private String bucket; private picResultCallback callback;//回调接口 private String path = "tms/user-cert/"; private LoadingPopupView dialog; private OssServiceUtil() { } private static volatile OssServiceUtil ossUtils; public static OssServiceUtil getInstance() { if (ossUtils == null) { synchronized (OssServiceUtil.class) { if (ossUtils == null) { ossUtils = new OssServiceUtil(); } } } return ossUtils; } private void initDialog(AppCompatActivity activity) { dialog = LoadingUtils.Companion.getInstance().init(activity, "网络请求中......"); } //初始化使用参数 public void init() { bucket = OssConfigBean.bucket; // String stsServer = "http://platform.test.v2.dahehuoyun.com/devApi/file/aliyun/oss/getToken"; String stsServer = BuildConfig.BASE_URL+ "file/aliyun/oss/getToken"; credentialProvider = new OSSAuthCredentialsProvider(stsServer); conf = new ClientConfiguration(); conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒 conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒 conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个 conf.setMaxErrorRetry(2); // 失败后最大重试次数，默认2次 oss = new OSSClient(App.Companion.getApp(), OssConfigBean.endpoint, credentialProvider, conf); } public void setResultCallBack(picResultCallback callback) { this.callback = callback; } /** * 图片以路径的方式上传 *

* // * @param 图片的上传地址（更后台要） * // * @param 图片本地地址 * // * @param 进度条 */ public void asyncPutImage(final String localFile, final AppCompatActivity activity) { // if (object.equals("")) { // return; // } if (activity != null) { activity.runOnUiThread(new Runnable() { @Override public void run() { initDialog(activity); } }); } File file = new File(localFile); if (!file.exists()) { return; } Calendar instance = Calendar.getInstance(); String year = String.valueOf(instance.get(Calendar.YEAR)); String month = String.valueOf(instance.get(Calendar.MONTH) + 1); String day = String.valueOf(instance.get(Calendar.DAY_OF_MONTH)); String name = file.getName(); // 构造上传请求 // PutObjectRequest put = new PutObjectRequest(OssConfigBean.bucket, year + "/" + month + "/" + day + name, localFile); PutObjectRequest put = new PutObjectRequest(OssConfigBean.bucket, OssConfigBean.BUCKET_OBJECT + name, localFile); put.setCRC64(OSSRequest.CRC64Config.YES); String mCallbackAddress = OssConfigBean.OSS_CALLBACK_URL; // if (mCallbackAddress != null) { // // 传入对应的上传回调参数，这里默认使用OSS提供的公共测试回调服务器地址 // put.setCallbackParam(new HashMap() { // { // put("callbackUrl", mCallbackAddress); // //callbackBody可以自定义传入的信息 // put("callbackBody", "filename=${object}"); // } // }); // } //上传后回调通知 // 异步上传时可以设置进度回调 put.setProgressCallback(new OSSProgressCallback() { @Override public void onProgress(PutObjectRequest request, long currentSize, long totalSize) { // int progress = (int) (100 * currentSize / totalSize); // if (mProgress != null) { // mProgress.setProgress(progress); // } if (activity != null) { activity.runOnUiThread(() -> { if (dialog != null && !dialog.isShow()) { dialog.show(); } }); } } }); OSSAsyncTask task = oss.asyncPutObject(put, new OSSCompletedCallback() { @Override public void onSuccess(PutObjectRequest request, final PutObjectResult result) { if (activity != null) { activity.runOnUiThread(() -> { if (dialog != null) { dialog.dismiss(); } }); } String serverCallbackReturnBody = result.getServerCallbackReturnBody(); callback.getPicData(result, OssConfigBean.BUCKET_BASE_URL + OssConfigBean.BUCKET_OBJECT + name); } @Override public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) { if (activity != null) { activity.runOnUiThread(() -> { if (dialog != null) { dialog.dismiss(); } }); } String info = ""; // 请求异常 if (clientExcepion != null) { // 本地异常如网络异常等 clientExcepion.printStackTrace(); info = clientExcepion.toString(); } if (serviceException != null) { // 服务异常 Log.e("ErrorCode", serviceException.getErrorCode()); Log.e("RequestId", serviceException.getRequestId()); Log.e("HostId", serviceException.getHostId()); Log.e("RawMessage", serviceException.getRawMessage()); info = serviceException.toString(); } // task.cancel(); } }); } /** * 上传次数 */ int number; /** * 成功上传(本地文件名作为key,阿里云地址为value) */ List success = new ArrayList<>(); /** * 失败上传(返回失败文件的本地地址) */ List failure = new ArrayList<>(); /** * 批量上传图片 * * @param localFiles */ public void asyncPutImages(final List localFiles, final AppCompatActivity activity, PicsResultCallback callback) { if (activity != null) { activity.runOnUiThread(new Runnable() { @Override public void run() { initDialog(activity); if (dialog != null) { dialog.show(); } } }); } //初始化 number = 0; success.clear(); failure.clear(); for (int i = 0; i < localFiles.size(); i++) { File file = new File(localFiles.get(i)); if (!file.exists()) { return; } String name = file.getName(); // 构造上传请求 PutObjectRequest put = new PutObjectRequest(OssConfigBean.bucket, OssConfigBean.BUCKET_OBJECT + name, localFiles.get(i)); put.setCRC64(OSSRequest.CRC64Config.YES); oss.asyncPutObject(put, new OSSCompletedCallback() { @Override public void onSuccess(PutObjectRequest request, final PutObjectResult result) { number++; String aliPath = OssConfigBean.BUCKET_BASE_URL + OssConfigBean.BUCKET_OBJECT + name; success.add(aliPath); if (number == localFiles.size()) { if (activity != null) { activity.runOnUiThread(() -> { if (dialog != null) { dialog.dismiss(); } }); } //返回 上传路径,以及失败的路径 callback.onOssSuccess(success, failure); } } @Override public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) { number++; String aliPath = OssConfigBean.BUCKET_BASE_URL + OssConfigBean.BUCKET_OBJECT + name; failure.add(aliPath); if (number == localFiles.size()) { if (activity != null) { activity.runOnUiThread(() -> { if (dialog != null) { dialog.dismiss(); } }); } callback.onOssSuccess(success, failure); } } }); } } /** * 图片以bitmap的形式上传 * * @param object * @param localFile * @param mProgress * @param img * @param type */ public void asyncPutImage(String object, final Bitmap localFile, final ProgressBar mProgress, final ImageView img, String type) { if (object.equals("")) { Log.w("AsyncPutImage", "ObjectNull"); return; } if (localFile == null) { Log.w("AsyncPutImage", "bitmapNull"); return; } // 构造上传请求 PutObjectRequest put = new PutObjectRequest(bucket, object, getBitmapByte(localFile)); //上传后回调通知 // 客户端在上传Object时可以指定OSS服务端在处理完上传请求后，通知您的业务服务器，在该服务器确认接收了该回调后将回调的结果返回给客户端。 put.setCallbackParam(new HashMap() { { put("callbackUrl", path); put("callbackBody", //参数跟后台商议 "filename=${object}&size=${size}&action=${x:action}}"); } }); HashMap hashMap = new HashMap<>(); hashMap.put("x:action", type); put.setCallbackVars(hashMap); OSSAsyncTask task = oss.asyncPutObject(put, new OSSCompletedCallback() { @Override public void onSuccess(PutObjectRequest request, final PutObjectResult result) { Observable.just(result).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer() { @Override public void accept(PutObjectResult putObjectResult) throws Throwable { callback.getPicData(result, ""); } }); // Observable.just(result).observeOn(AndroidSchedulers.mainThread()).subscribe(putObjectResult -> callback.getPicData(result, "")); } @Override public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) { String info = ""; // 请求异常 if (clientExcepion != null) { // 本地异常如网络异常等 clientExcepion.printStackTrace(); info = clientExcepion.toString(); } if (serviceException != null) { // 服务异常 Log.e("ErrorCode", serviceException.getErrorCode()); Log.e("RequestId", serviceException.getRequestId()); Log.e("HostId", serviceException.getHostId()); Log.e("RawMessage", serviceException.getRawMessage()); info = serviceException.toString(); } } }); } public byte[] getBitmapByte(Bitmap bitmap) { ByteArrayOutputStream out = new ByteArrayOutputStream(); bitmap.compress(Bitmap.CompressFormat.JPEG, 100, out); try { out.flush(); out.close(); } catch (IOException e) { e.printStackTrace(); } return out.toByteArray(); } public interface picResultCallback { void getPicData(PutObjectResult data, String netPath); } public interface PicsResultCallback { void onOssSuccess(List success, List failure); } /** * Gets the corresponding path to a file from the given content:// URI * @param selectedVideoUri The content:// URI to find the file path from * @param contentResolver The content resolver to use to perform the query. * @return the file path as a string */ public String getFilePathFromContentUri(Uri selectedVideoUri, ContentResolver contentResolver) { String filePath; String[] filePathColumn = {MediaStore.MediaColumns.DATA}; Cursor cursor = contentResolver.query(selectedVideoUri, filePathColumn, null, null, null); // 也可用下面的方法拿到cursor // Cursor cursor = this.context.managedQuery(selectedVideoUri, filePathColumn, null, null, null); cursor.moveToFirst(); int columnIndex = cursor.getColumnIndex(filePathColumn[0]); filePath = cursor.getString(columnIndex); cursor.close(); return filePath; } }