package com.example.smart.oss;


import static com.example.smart.oss.OssConfig.BUCKET_NAME;
import static com.example.smart.oss.OssConfig.OSS_DAILY_SIGN;
import static com.example.smart.oss.OssConfig.OSS_STS_API;

import android.app.Application;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.net.Uri;
import android.util.Log;

import androidx.annotation.NonNull;

import com.alibaba.sdk.android.oss.ClientConfiguration;
import com.alibaba.sdk.android.oss.ClientException;
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.common.auth.OSSFederationCredentialProvider;
import com.alibaba.sdk.android.oss.common.auth.OSSFederationToken;
import com.alibaba.sdk.android.oss.common.auth.OSSStsTokenCredentialProvider;
import com.alibaba.sdk.android.oss.internal.OSSAsyncTask;
import com.alibaba.sdk.android.oss.model.GetObjectRequest;
import com.alibaba.sdk.android.oss.model.GetObjectResult;
import com.alibaba.sdk.android.oss.model.OSSRequest;
import com.alibaba.sdk.android.oss.model.OSSResult;
import com.alibaba.sdk.android.oss.model.PutObjectRequest;
import com.alibaba.sdk.android.oss.model.PutObjectResult;
import com.example.basecore.util.DateUtils;
import com.example.smart.util.StatusProvider;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;

public class OssService {

    public static OSSClient oss;

    public static void create(Application application) {
        String endpoint = OssConfig.OSS_ENDPOINT;

        OSSCredentialProvider credentialProvider = new OSSAuthCredentialsProvider(OSS_STS_API);
        ClientConfiguration 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(application, endpoint, credentialProvider, conf);
    }


    public static void create(String id, String key, String token, Application application) {
        String endpoint = OssConfig.OSS_ENDPOINT;

        OSSCredentialProvider credentialProvider = new OSSStsTokenCredentialProvider(id, key, token);

        ClientConfiguration 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(application, endpoint, credentialProvider, conf);
    }


    private static String generateDailyPath() {
        String date = DateUtils.getCurDate();
        return OSS_DAILY_SIGN + date + "/";
    }

//
//    public static void asyncPutImage(String localFile, IOssCallBack callBack) {
//        if (oss == null) {
//            return;
//        }
//        File file = new File(localFile);
//        if (!file.exists()) {
//            Log.w("AsyncPutImage", "FileNotExist");
//            Log.w("LocalFile", localFile);
//            return;
//        }
//
//        String name = StatusProvider.INSTANCE.getUid() + "_" + System.currentTimeMillis() + "_" + file.getName();
//        String objectName = generateDailyPath() + name;
//        Log.w("objectName", objectName);
//
//        // 构造上传请求
//        PutObjectRequest put = new PutObjectRequest(BUCKET_NAME, objectName, localFile);
//        put.setCRC64(OSSRequest.CRC64Config.YES);
//
//
//        // 异步上传时可以设置进度回调
//        put.setProgressCallback(new OSSProgressCallback<PutObjectRequest>() {
//            @Override
//            public void onProgress(PutObjectRequest request, long currentSize, long totalSize) {
////                int progress = (int) (100 * currentSize / totalSize);
////                 Log.d("put", "progress = " + progress);
//            }
//        });
//
//        OSSAsyncTask task = oss.asyncPutObject(put, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
//            @Override
//            public void onSuccess(PutObjectRequest request, PutObjectResult result) {
//                Log.d("PutObject", "UploadSuccess");
//
//                Log.d("ETag", result.getETag());
//                Log.d("RequestId", result.getRequestId());
//
//                callBack.onSuccess(objectName);
//
//            }
//
//            @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();
//                }
//                callBack.onFailed();
//            }
//        });
//    }
//
//
//    public static void asyncPutImage(String localFile, String objectName, IOssCallBack callBack) {
//        if (oss == null) {
//            return;
//        }
//        File file = new File(localFile);
//        if (!file.exists()) {
//            Log.w("AsyncPutImage", "FileNotExist");
//            Log.w("LocalFile", localFile);
//            return;
//        }
//
//        String name = StatusProvider.INSTANCE.getUid() + "_" + System.currentTimeMillis() + "_" + file.getName();
//        objectName += name;
//        Log.w("objectName", objectName);
//
//        // 构造上传请求
//        PutObjectRequest put = new PutObjectRequest(BUCKET_NAME, objectName, localFile);
//        put.setCRC64(OSSRequest.CRC64Config.YES);
//
//
//        String finalObjectName = objectName;
//
//        OSSAsyncTask<PutObjectResult> task = oss.asyncPutObject(put, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
//            @Override
//            public void onSuccess(PutObjectRequest request, PutObjectResult result) {
//                callBack.onSuccess(finalObjectName);
//            }
//
//            @Override
//            public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) {
//                // 请求异常
//                if (clientExcepion != null) {
//                    // 本地异常如网络异常等
//                    clientExcepion.printStackTrace();
//                }
//                if (serviceException != null) {
//                    // 服务异常
//                    Log.e("ErrorCode", serviceException.getErrorCode());
//                    Log.e("RequestId", serviceException.getRequestId());
//                    Log.e("HostId", serviceException.getHostId());
//                    Log.e("RawMessage", serviceException.getRawMessage());
//                }
//
//                callBack.onFailed();
//            }
//        });
//    }
//
//
//    /**
//     * 多文件上传
//     */
//    public static void asyncPutImageList(List<String> list, String objectName, IOssCallBack callBack) {
//        if (oss == null) {
//            return;
//        }
//        List<String> ossResultList = Collections.synchronizedList(new ArrayList<>());
//
//        for (String str : list) {
//            asyncPutImage(str, objectName, new IOssCallBack() {
//                @Override
//                public void onSuccess(@NonNull String ossPath) {
//                    ossResultList.add(ossPath);
//                    callBack.onSuccess(ossPath);
//                    if (ossResultList.size() == list.size()) {
//                        callBack.onAllListSuccess(ossResultList);
//                    }
//                }
//
//                @Override
//                public void onFailed() {
//                    callBack.onFailed();
//                    ossResultList.add("");
//                    if (ossResultList.size() == list.size()) {
//                        callBack.onAllListSuccess(ossResultList);
//                    }
//                }
//            });
//        }
//    }
//
//
//    public static void asyncPutImageByUri(Uri uri, String objectName, IOssCallBack callBack) {
//        if (oss == null) {
//            return;
//        }
//
//        String name = StatusProvider.INSTANCE.getUid() + "_" + System.currentTimeMillis() + "_" + "img.jpg";
//        objectName += name;
//
//        // 构造上传请求
//        PutObjectRequest put = new PutObjectRequest(BUCKET_NAME, objectName, uri);
//        put.setCRC64(OSSRequest.CRC64Config.YES);
//
//        String finalObjectName = objectName;
//        oss.asyncPutObject(put, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
//            @Override
//            public void onSuccess(PutObjectRequest request, PutObjectResult result) {
//                callBack.onSuccess(finalObjectName);
//            }
//
//            @Override
//            public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) {
//                // 请求异常
//                if (clientExcepion != null) {
//                    // 本地异常如网络异常等
//                    clientExcepion.printStackTrace();
//                }
//                if (serviceException != null) {
//                    // 服务异常
//                    Log.e("ErrorCode", serviceException.getErrorCode());
//                    Log.e("RequestId", serviceException.getRequestId());
//                    Log.e("HostId", serviceException.getHostId());
//                    Log.e("RawMessage", serviceException.getRawMessage());
//                }
//
//                callBack.onFailed();
//            }
//        });
//    }
//
//    public static void getFile(String objectName, IOssGetCallback callBack) {
//        if (oss == null) {
//            return;
//        }
//        //"sign/daily/2023-09-20/_1695181081925_IMG_20230829_181457.jpg"
//        GetObjectRequest request = new GetObjectRequest(OssConfig.BUCKET_NAME, objectName);
//
//        oss.asyncGetObject(request, new OSSCompletedCallback<GetObjectRequest, GetObjectResult>() {
//            @Override
//            public void onSuccess(GetObjectRequest request, GetObjectResult result) {
//
//                InputStream inputStream = result.getObjectContent();
//                Bitmap bm = BitmapFactory.decodeStream(inputStream);
//                callBack.onSuccess(bm);
//
//            }
//
//            @Override
//            public void onFailure(GetObjectRequest request, ClientException clientException, ServiceException serviceException) {
//                callBack.onFailed();
//            }
//        });
//
//    }
//

}