//import { arrayBuffer } from "js-md5"
|
import {
|
Base64
|
} from 'js-base64';
|
import TaskInit from "@/common/extend.js"
|
|
const public_bucketname = "mobox3-public";
|
// 得到文件上传地址
|
export const getUploadUrl = (svrUrl, svrinfo, savepath, isPublic) => {
|
return new Promise((resolve, reject) => {
|
const savemode = 2
|
let bucketname = 'mobox3'
|
if (isPublic)
|
bucketname = public_bucketname
|
let apiUrl =
|
`${svrUrl}/oss/uldurl?method=post&svrinfo=${svrinfo}&savepath=${savepath}&savemode=${savemode}&bucketname=${bucketname}`
|
|
uni.request({
|
url: apiUrl + (isPublic ? "&bucketpolicy=public" : ""),
|
method: "GET",
|
success: (result) => {
|
|
if (result.statusCode != 200) {
|
return reject({
|
errMsg: "访问失败，状态码：" + result.statusCode
|
})
|
}
|
var ret = result.data
|
if (ret.code == 0) {
|
ret.data.bucketname = bucketname
|
return resolve(ret.data);
|
} else {
|
reject({
|
errMsg: ret.msg
|
});
|
}
|
},
|
fail: (err) => {
|
console.log("fail", err)
|
return reject(err);
|
}
|
})
|
})
|
}
|
|
|
// 得到文件下载地址
|
export const getDownloadUrl = (svrUrl, svrinfo, fileid, filename) => {
|
return new Promise((resolve, reject) => {
|
let apiUrl = `${svrUrl}/oss/dldurl?svrinfo=${svrinfo}&fileid=${fileid}&filename=${filename}`
|
uni.request({
|
url: apiUrl,
|
method: "GET",
|
success: (result) => {
|
if (result.statusCode != 200) {
|
return reject({
|
errMsg: "访问失败，状态码：" + result.statusCode
|
})
|
}
|
var ret = result.data
|
// console.log("getDownloadUrl", ret)
|
if (ret.code == 0) {
|
return resolve(ret.data);
|
} else {
|
reject({
|
errMsg: ret.msg
|
});
|
}
|
},
|
fail: (err) => {
|
console.log("fail", err)
|
return reject(err);
|
}
|
})
|
|
})
|
}
|
|
// 上传文件
|
|
export const putFile = (apiUrl, file) => {
|
console.log("putFile", apiUrl, file)
|
return new Promise((resolve, reject) => {
|
const app = getApp()
|
const fileSystemManager = uni.getFileSystemManager();
|
// 文件路径，这里以uniapp项目中的某个文件为例
|
const filePath = file.path
|
// 读取文件
|
// const task = uni.request({
|
// url: filePath,
|
// method: "GET",
|
// success: function(res) {
|
// console.log("readFile", res)
|
// const task = uni.request({
|
// url: apiUrl,
|
// method: "PUT",
|
// header: {
|
// 'content-type': 'application/octet-stream',
|
// 'Content-Length': data.byteLength
|
// },
|
// data: res,
|
// success: (result) => {
|
// console.log("result", result)
|
// resolve();
|
// },
|
// fail: (err) => {
|
// console.log("fail", err)
|
// reject(err);
|
// }
|
// })
|
|
// },
|
// fail: function(error) {
|
// console.log("fail", error)
|
// reject(error);
|
// }
|
// }
|
|
// )
|
console.log("readFile", filePath)
|
fileSystemManager.readFile({
|
filePath: filePath,
|
position: 0,
|
// encoding:"binary",
|
success: function(res) {
|
let data = res.data;
|
console.log("readFile res", res)
|
// const arrayBuffer = new Uint8Array(res.data)
|
// const string = String.fromCharCode.apply(null,arrayBuffer)
|
// const string = Base64.decode(data)
|
// console.log(string);
|
const task = uni.request({
|
url: apiUrl,
|
method: "PUT",
|
// header: {
|
// 'content-type': 'application/octet-stream',
|
// 'Content-Length': data.byteLength
|
// },
|
data: res.data,
|
success: (result) => {
|
console.log("result", result)
|
resolve();
|
},
|
fail: (err) => {
|
console.log("fail", err)
|
reject(err);
|
}
|
})
|
|
},
|
fail: function(error) {
|
console.log("fail", error)
|
reject(error);
|
}
|
});
|
|
})
|
}
|
|
export const uploadTask = (apiUrl, file, formData, cbSuccess, cbProgress, cbFail) => {
|
const app = getApp()
|
const path = file.path
|
let fileType = ""
|
//#ifdef MP-DINGTALK
|
fileType = "image"
|
if (TaskInit.fileUtils.isPictureType(file.name)) //文档
|
{
|
fileType = "image"
|
} else if (TaskInit.fileUtils.isVideoType(file.name)) //视频
|
{
|
fileType = "video"
|
} else if (TaskInit.fileUtils.isAudioType(file.name)) //音频
|
{
|
fileType = "audio"
|
} else if (TaskInit.fileUtils.isDocumentType(file.name)) //文档
|
{
|
fileType = "pdf"
|
}
|
//#endif
|
console.log("uploadTaskFileMinio ", path)
|
const task = uni.uploadFile({
|
url: apiUrl,
|
filePath: path,
|
name: "file",
|
fileType: fileType,
|
formData: formData,
|
success: (result) => {
|
console.log("uploadTaskFileMinio success", result)
|
if (result.statusCode == 204 || result.statusCode == 200) {
|
cbSuccess(result);
|
} else {
|
console.log("uploadTaskFileMinio fail", result)
|
var res = {}
|
res.errMsg = result.data ? result.data : '上传返回错误!';
|
res.path = file.path
|
cbFail(res);
|
}
|
},
|
fail: (result) => {
|
console.log("uploadTaskFileMinio fail", result)
|
var res = {}
|
res.errMsg = result.errMsg ? result.errMsg : '上传异常!';
|
res.path = file.path
|
cbFail(res);
|
}
|
})
|
task.onProgressUpdate((res) => {
|
console.log('上传进度' + res.progress);
|
// console.log('已经上传的数据长度' + res.totalBytesSent);
|
// console.log('预期需要上传的数据总长度' + res.totalBytesExpectedToSend);
|
res.path = file.path
|
cbProgress(res, task)
|
});
|
return task;
|
}
|
|
// 写数据库
|
export const callback = (
|
svrUrl,
|
savepath,
|
filesize,
|
filename,
|
md5,
|
userlogin,
|
username,
|
access,
|
secret
|
) => {
|
let apiUrl = `${svrUrl}/oss/uldcallback`
|
let bucket = 'mobox3'
|
let apptype = 'mobox3'
|
let isbase64 = 'N'
|
// console.log("callback apiUrl", apiUrl)
|
return new Promise((resolve, reject) => {
|
uni.request({
|
url: apiUrl,
|
method: "POST",
|
data: {
|
bucket,
|
savepath,
|
filesize,
|
filename,
|
apptype,
|
md5,
|
userlogin,
|
username,
|
isbase64,
|
access,
|
secret
|
},
|
success: (result) => {
|
if (result.statusCode != 200) {
|
return reject({
|
errMsg: "访问失败，状态码：" + result.statusCode
|
})
|
}
|
var ret = result.data
|
// console.log("callback", ret)
|
if (ret.code == 0) {
|
return resolve(ret.data);
|
} else {
|
reject({
|
errMsg: ret.msg
|
});
|
}
|
},
|
fail: (err) => {
|
console.log("fail", err)
|
return reject(err);
|
}
|
})
|
})
|
}
|
