|
|
@ -111,18 +111,22 @@ public class TeambitionClientService { |
|
|
|
LOGGER.info("文件预处理成功,开始上传。文件名:{},上传URL数量:{}", path, uploadUrl.size()); |
|
|
|
LOGGER.info("文件预处理成功,开始上传。文件名:{},上传URL数量:{}", path, uploadUrl.size()); |
|
|
|
|
|
|
|
|
|
|
|
byte[] buffer = new byte[chunkSize]; |
|
|
|
byte[] buffer = new byte[chunkSize]; |
|
|
|
for (String oneUploadUrl : uploadUrl) { |
|
|
|
for (int i = 0; i < uploadUrl.size(); i++) { |
|
|
|
|
|
|
|
String oneUploadUrl = uploadUrl.get(i); |
|
|
|
try { |
|
|
|
try { |
|
|
|
int read = IOUtils.read(inputStream, buffer, 0, buffer.length); |
|
|
|
int read = IOUtils.read(inputStream, buffer, 0, buffer.length); |
|
|
|
if (read == -1) { |
|
|
|
if (read == -1) { |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
client.upload(oneUploadUrl, buffer, 0, read); |
|
|
|
client.upload(oneUploadUrl, buffer, 0, read); |
|
|
|
|
|
|
|
LOGGER.info("文件正在上传上传。文件名:{},当前进度:{}/{}", path, (i+1), uploadUrl.size()); |
|
|
|
|
|
|
|
|
|
|
|
} catch (IOException e) { |
|
|
|
} catch (IOException e) { |
|
|
|
throw new RuntimeException(e); |
|
|
|
throw new RuntimeException(e); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
UploadFinalRequest uploadFinalRequest = new UploadFinalRequest(); |
|
|
|
UploadFinalRequest uploadFinalRequest = new UploadFinalRequest(); |
|
|
|
uploadFinalRequest.setCcpFileId(uploadPreResult.getCcpFileId()); |
|
|
|
uploadFinalRequest.setCcpFileId(uploadPreResult.getCcpFileId()); |
|
|
|
uploadFinalRequest.setDriveId(client.getDriveId()); |
|
|
|
uploadFinalRequest.setDriveId(client.getDriveId()); |
|
|
|