java牛晓法APP.zip

package com.niuxiaofa.newlaw.videoupload.impl; import android.app.Activity; import android.content.Context; import android.content.SharedPreferences; import android.net.Uri; import android.os.Bundle; import android.os.Handler; import android.text.TextUtils; import android.util.Log; import com.niuxiaofa.newlaw.videoupload.TXUGCPublishTypeDef; import com.niuxiaofa.newlaw.videoupload.impl.compute.TXHttpTaskMetrics; import com.niuxiaofa.newlaw.videoupload.impl.compute.TXOnGetHttpTaskMetrics; import com.tencent.cos.xml.CosXmlService; import com.tencent.cos.xml.CosXmlServiceConfig; import com.tencent.cos.xml.exception.CosXmlClientException; import com.tencent.cos.xml.exception.CosXmlServiceException; import com.tencent.cos.xml.listener.CosXmlProgressListener; import com.tencent.cos.xml.listener.CosXmlResultListener; import com.tencent.cos.xml.model.CosXmlRequest; import com.tencent.cos.xml.model.CosXmlResult; import com.tencent.cos.xml.model.object.InitMultipartUploadRequest; import com.tencent.cos.xml.model.object.InitMultipartUploadResult; import com.tencent.cos.xml.model.object.PutObjectRequest; import com.tencent.cos.xml.transfer.COSXMLUploadTask; import com.tencent.cos.xml.transfer.TransferConfig; import com.tencent.cos.xml.transfer.TransferManager; import com.tencent.cos.xml.transfer.TransferState; import com.tencent.cos.xml.transfer.TransferStateListener; import org.json.JSONException; import org.json.JSONObject; import java.io.File; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.InetAddress; import java.util.List; import java.util.Map; import java.util.Timer; import java.util.TimerTask; import okhttp3.Call; import okhttp3.Callback; import okhttp3.Response; /** * 视频上传客户端 */ public class TVCClient { private final static String TAG = "TVC-Client"; private Context context; private Handler mainHandler; private boolean busyFlag = false; private boolean cancleFlag = false; private TVCUploadInfo uploadInfo; private UGCClient ugcClient; private TVCUploadListener tvcListener; private int cosAppId; //点播上传用到的COS appid private int userAppId; //客户自己的appid，数据上报需要 private String uploadRegion = ""; private String cosBucket; private String cosTmpSecretId = ""; private String cosTmpSecretKey = ""; private String cosToken = ""; private long cosExpiredTime; private long localTimeAdvance = 0; //本地时间相对unix时间戳提前间隔 private String cosVideoPath; private String videoFileId; private String cosCoverPath; private boolean isOpenCosAcc = false; //是否使用cos动态加速 private String cosAccDomain = ""; //动态加速域名 private String cosHost = ""; private String domain; private String cosIP = ""; private String vodSessionKey = null; private long reqTime = 0; //各阶段开始请求时间 private long initReqTime = 0; //上传请求时间，用于拼接reqKey。串联请求 private String customKey = ""; //用于数据上报 private CosXmlService mCosXmlService; private COSXMLUploadTask mCOSXMLUploadTask; private TransferConfig mTransferConfig; private TransferManager mTransferManager; // 断点重传session本地缓存 // 以文件路径作为key值得，存储的内容是<session, uploadId, fileLastModify, expiredTime> private static final String LOCALFILENAME = "TVCSession"; private SharedPreferences mSharedPreferences; private SharedPreferences.Editor mShareEditor; private String uploadId = null; private long fileLastModTime = 0; //视频文件最后修改时间 private long coverFileLastModTime = 0; //封面文件最后修改时间 private boolean enableResume = true; private boolean enableHttps = false; private UGCReport.ReportInfo reportInfo; private static final int VIRTUAL_TOTAL_PERCENT = 10; //前后的虚拟进度占的百分比 private TimerTask virtualProgress = null; //虚拟进度任务 private Timer mTimer; //定时器 private int virtualPercent = 0; //虚拟进度 private boolean realProgressFired = false; private int vodCmdRequestCount = 0; //vod信令重试次数 /** * 初始化上传实例 * * @param signature 签名 * @param iTimeOut 超时时间 */ public TVCClient(Context context, String customKey, String signature, boolean enableResume, boolean enableHttps, int iTimeOut) { TXUGCPublishOptCenter.getInstance().prepareUpload(signature); this.context = context.getApplicationContext(); ugcClient = UGCClient.getInstance(signature, iTimeOut); mainHandler = new Handler(context.getMainLooper()); mSharedPreferences = context.getSharedPreferences(LOCALFILENAME, Activity.MODE_PRIVATE); mShareEditor = mSharedPreferences.edit(); this.enableResume = enableResume; this.enableHttps = enableHttps; this.customKey = customKey; reportInfo = new UGCReport.ReportInfo(); clearLocalCache(); } /** * 初始化上传实例 * * @param ugcSignature 签名 */ public TVCClient(Context context, String customKey, String ugcSignature, boolean resumeUpload, boolean enableHttps) { this(context, customKey, ugcSignature, resumeUpload, enableHttps, 8); } // 清理一下本地缓存，过期的删掉 private void clearLocalCache() { if (mSharedPreferences != null) { try { Map<String, ?> allContent = mSharedPreferences.getAll(); //注意遍历map的方法 for(Map.Entry<String, ?> entry : allContent.entrySet()){ JSONObject json = new JSONObject((String) entry.getValue()); long expiredTime = json.optLong("expiredTime", 0); // 过期了清空key if (expiredTime < System.currentTimeMillis() / 1000) { mShareEditor.remove(entry.getKey()); mShareEditor.commit(); } } } catch (Exception e) { e.printStackTrace(); } } } private void startTimer() { if (mTimer != null) { mTimer.cancel(); mTimer = null; } if (virtualProgress != null) { virtualProgress = null; } if (virtualProgress == null) { virtualProgress = new TimerTask() { @Override public void run() { postVirtualProgress(); } }; } mTimer = new Timer(); mTimer.schedule(virtualProgress, 2000/VIRTUAL_TOTAL_PERCENT, 2000/VIRTUAL_TOTAL_PERCENT); //前后的虚拟进度大概持续2s } private void stopTimer() { if (mTimer != null) { mTimer.cancel(); mTimer = null; } if (virtualProgress != null) { virtualProgress = null; } } private void postVirtualProgress() { if (uploadInfo != null) { long total = uploadInfo.getFileSize() + (uploadInfo.isNeedCover()? uploadInfo.getCoverFileSize(): 0); if ((virtualPercent >= 0 && virtualPercent < 10) || (virtualPercent >=90 && virtualPercent <100)) { ++virtualPercent; notifyUploadProgress(virtualPercent * total / 100, total); } } } // 通知上层上传成功 private void notifyUploadSuccess(final String fileId, final String playUrl, final String coverUrl) { TXUGCPublishOptCenter.getInstance().delPublishing(uploadInfo.getFilePath()); final long total = uploadInfo.getFileSize() + (uploadInfo.isNeedCover()? uploadInfo.getCoverFileSize(