package cn.flightfeather.thirdappmodule.activity;

import android.content.DialogInterface;
import android.os.Bundle;
import android.os.Environment;
import android.support.v7.app.AlertDialog;
import android.support.v7.app.AppCompatActivity;
import android.support.v7.widget.CardView;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.util.Log;
import android.view.View;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.ping.greendao.gen.MediafileDao;

import java.io.File;
import java.util.ArrayList;
import java.util.List;

import cn.flightfeather.thirdappmodule.CommonApplication;
import cn.flightfeather.thirdappmodule.R;
import cn.flightfeather.thirdappmodule.adapter.MediaFileListAdapter;
import cn.flightfeather.thirdappmodule.bean.entity.Mediafile;
import cn.flightfeather.thirdappmodule.task.CompressPhotoTask;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.http.Multipart;
import retrofit2.http.POST;
import retrofit2.http.Part;

public class UploadMediaFilesActivity extends AppCompatActivity implements View.OnClickListener {
    private RecyclerView rv_main;
    private TextView tv_uploada;
    private MediafileDao mediafileDao;
    private CommonApplication application;
    private List<Mediafile> mediaFileListCurrent;
    private List<File> fileListCurrent;
    private MediaFileListAdapter adapter;
    private CardView cv_wait;
    private TextView tv_waitText;
    private AlertDialog.Builder uploadingDialog;
    private int photoTotal = 0;
    private int photoUploaded =0;
    private ProgressBar pb_uploading;
    private TextView tv_status;
    private UploadService uploadService;
    private List<File> outputFileList;
    private AlertDialog uploadingDialog2;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_upload_media_files);
        application = (CommonApplication) getApplication();
        uploadService = application.getRetrofit().create(UploadService.class);
        initUI();
        initDataBase();
        initData();
        initUploadingDialog();
    }

    //初始化界面
    private void initUI() {
        getSupportActionBar().setTitle("文件上传");
        rv_main = (RecyclerView) findViewById(R.id.rv_main);
        tv_uploada = (TextView) findViewById(R.id.tv_upload);
        cv_wait = (CardView) findViewById(R.id.cv_wait);
        tv_waitText = (TextView) findViewById(R.id.tv_wait_text);
        cv_wait.setVisibility(View.GONE);

        LinearLayoutManager manager = new LinearLayoutManager(this);
        rv_main.setLayoutManager(manager);
        mediaFileListCurrent = new ArrayList<>();
        adapter = new MediaFileListAdapter(this,mediaFileListCurrent);
        rv_main.setAdapter(adapter);

        tv_uploada.setOnClickListener(this);
    }

    //初始化数据库
    private void initDataBase() {
        mediafileDao = application.getDaoSession().getMediafileDao();
    }
    //初始化数据
    private void initData() {
        List<Mediafile> mediaFileList = mediafileDao.queryBuilder().where(MediafileDao.Properties.Remark.eq("未上传")).list();
        if (mediaFileList!=null&&mediaFileList.size()>0){
            mediaFileListCurrent.clear();
            mediaFileListCurrent.addAll(mediaFileList);
            //检查一下mediafile对应的图片是否存在，没有则删掉mediafile
            for (int i = 0;i<mediaFileListCurrent.size();i++){
                Mediafile  mediaFile = mediaFileListCurrent.get(i);
                File file = new File(Environment.getExternalStorageDirectory(),(mediaFile.getPath()+mediaFile.getDescription()));
                if (!file.exists()){
                    Log.i(i+":","no Photo");
                    mediafileDao.delete(mediaFile);
                }
            }
            List<Mediafile> mediaFileList2 = mediafileDao.queryBuilder().where(MediafileDao.Properties.Remark.eq("未上传")).list();
            mediaFileListCurrent.clear();
            mediaFileListCurrent.addAll(mediaFileList2);
            photoTotal = mediaFileListCurrent.size();
            photoUploaded = 0;
            adapter.notifyDataSetChanged();
        }
    }
    //上传前压缩图片
    private void preUpload(){
        CompressPhotoTask task = new CompressPhotoTask(mediaFileListCurrent,this);
        task.execute();
        pb_uploading.setMax(photoTotal);
        pb_uploading.setProgress(photoUploaded);
        tv_status.setText("压缩中...");
        if (uploadingDialog2 != null && !uploadingDialog2.isShowing()) {
            uploadingDialog2.show();
        } else {
            uploadingDialog2 = uploadingDialog.show();
        }
    }
    //开始上传
    public void startUplaod(List<File> outputFileList){

        this.outputFileList = outputFileList;
        updateUploadingStatus();
        uploadSinglePhoto(outputFileList.get(0));

    }

    private void showErrorDialog(){
        uploadingDialog2.dismiss();
        AlertDialog.Builder dialog = new AlertDialog.Builder(this);
        dialog.setTitle("上传失败");
        dialog.setMessage("请重试");
        dialog.setPositiveButton("确定",null);
        initData();
        dialog.show();

    }
    //一次上传全部的图片
    private void uploadAllPhoto(List<File> outputFileList){
        List<MultipartBody.Part> photoList = new ArrayList<>();
        //准备图片部分
        for (File file:outputFileList){
            // 创建 RequestBody，用于封装构建RequestBody
            RequestBody requestFile = RequestBody.create(MediaType.parse("multipart/form-data"), file);
            // MultipartBody.Part  和后端约定好Key，这里的partName是用image
            MultipartBody.Part body = MultipartBody.Part.createFormData("Photos", file.getName(), requestFile);
            photoList.add(body);
        }
        //将mediafile的备注设置为已上传，如果上传成功就将这个列表写入数据库
        for (int i = 0;i<mediaFileListCurrent.size();i++){
            Mediafile mediaFile = mediaFileListCurrent.get(i);
            mediaFile.setRemark("已上传");
            mediaFileListCurrent.set(i,mediaFile);
        }
        //准备mediafile的json
        Gson gson = new GsonBuilder()
                .setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ")
                .create();
        String a =gson.toJson(mediaFileListCurrent);
        final RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), a);
        MultipartBody.Part part = MultipartBody.Part.createFormData("mediafileVoList", null, requestBody);
        photoList.add(part);


        Call<ResponseBody> uploadPhotos =uploadService.uploadPhotos(photoList);
        uploadPhotos.enqueue(new Callback<ResponseBody>() {
            @Override
            public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                if (response.body()!=null){
                    mediafileDao.updateInTx(mediaFileListCurrent);
                    hideWait();
                    Toast.makeText(application, "上传成功", Toast.LENGTH_SHORT).show();
                    finish();

                }else if (response.errorBody()!=null){
                    hideWait();
                    System.out.println("uploadPhotos:"+response.errorBody().toString());
                    Toast.makeText(application, "上传错误，请重试", Toast.LENGTH_SHORT).show();
                }
            }

            @Override
            public void onFailure(Call<ResponseBody> call, Throwable t) {
                hideWait();
                System.out.println("uploadPhotos:"+t.toString());
                Toast.makeText(application, "网络连接失败", Toast.LENGTH_SHORT).show();
            }
        });
    }

    //显示确认上传的dialog
    public void showConfirmUploadDialog(){
        if (mediaFileListCurrent!=null&&mediaFileListCurrent.size()>0){
            AlertDialog.Builder dialog = new AlertDialog.Builder(this);
            dialog.setTitle("开始上传吗？");
            dialog.setMessage("推荐在wifi连接下上传,避免过多的流量消耗");
            dialog.setPositiveButton("确定", new DialogInterface.OnClickListener() {
                @Override
                public void onClick(DialogInterface dialogInterface, int i) {
                    preUpload();
                }
            });
            dialog.setNegativeButton("取消",null);
            dialog.show();
        }else {
            Toast.makeText(application, "没有要上传的图片", Toast.LENGTH_SHORT).show();
        }

    }
    private void initUploadingDialog(){
        uploadingDialog = new AlertDialog.Builder(this);
        uploadingDialog.setTitle("正在上传");
        View view =View.inflate(UploadMediaFilesActivity.this,R.layout.dialog_uploading,null);
        pb_uploading = (ProgressBar) view.findViewById(R.id.pb_uploading);
        tv_status = (TextView) view.findViewById(R.id.tv_status);
        uploadingDialog.setView(view);
        uploadingDialog.setCancelable(false);


    }

    private void uploadSinglePhoto(File file){
        List<MultipartBody.Part> photoList = new ArrayList<>();
        //准备图片部分

            // 创建 RequestBody，用于封装构建RequestBody
            RequestBody requestFile = RequestBody.create(MediaType.parse("multipart/form-data"), file);
            // MultipartBody.Part  和后端约定好Key，这里的partName是用image
            MultipartBody.Part body = MultipartBody.Part.createFormData("Photos", file.getName(), requestFile);
            photoList.add(body);

        List<Mediafile> mediafiles = new ArrayList<>();
        final Mediafile mediaFile = mediaFileListCurrent.get(photoUploaded);
        mediaFile.setRemark("已上传");
        mediafiles.add(mediaFile);

        //准备mediafile的json
        Gson gson = new GsonBuilder()
                .setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ")
                .create();
        String a =gson.toJson(mediafiles);

        final RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), a);
        MultipartBody.Part part = MultipartBody.Part.createFormData("mediafileVoList", null, requestBody);
        photoList.add(part);

        Call<ResponseBody> uploadPhotos =uploadService.uploadPhotos(photoList);
        uploadPhotos.enqueue(new Callback<ResponseBody>() {
            @Override
            public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                if (response.body()!=null){
                    mediafileDao.update(mediaFile);
                    photoUploaded++;
                    updateUploadingStatus();
                    if (photoUploaded<photoTotal){
                        uploadSinglePhoto(outputFileList.get(photoUploaded));
                    }else {
                        Toast.makeText(application, "上传成功", Toast.LENGTH_SHORT).show();
                        clearTemp(outputFileList);
                        finish();
                    }

                }else if (response.errorBody()!=null){
                    hideWait();
                    System.out.println("uploadSinglePhotos:"+response.errorBody().toString());
                    Toast.makeText(application, "上传错误，请重试", Toast.LENGTH_SHORT).show();
                    showErrorDialog();

                }
            }

            @Override
            public void onFailure(Call<ResponseBody> call, Throwable t) {
                hideWait();
                System.out.println("uploadSinglePhotos:"+t.toString());
                Toast.makeText(application, "网络连接失败", Toast.LENGTH_SHORT).show();
                showErrorDialog();
            }
        });


    }
    //更新上传的显示状态
    private void updateUploadingStatus(){
        pb_uploading.setProgress(photoUploaded);
        tv_status.setText(photoUploaded+"/"+photoTotal);
    }
    //清理缓存
    private void clearTemp(List<File> outputFileList){
        if (outputFileList!=null&&outputFileList.size()>0){
            for (File file:outputFileList){
                if (file.exists()){
                    file.delete();
                }
            }
        }

    }

    private void showCompressWait(){
        tv_waitText.setText("压缩中");
        cv_wait.setVisibility(View.VISIBLE);
    }
    private void showUploadWait(){
        tv_waitText.setText("上传中");
        cv_wait.setVisibility(View.VISIBLE);
    }
    private void hideWait(){
        cv_wait.setVisibility(View.GONE);
    }

    @Override
    public void onClick(View view) {
        if (view.getId() == R.id.tv_upload) {
            showConfirmUploadDialog();
        }
    }
    interface UploadService{
        @Multipart
        @POST("mediafile/add/")
        Call<ResponseBody> uploadPhotos(@Part List<MultipartBody.Part> partList);
    }

    @Override
    protected void onStop() {
        super.onStop();

    }
}