6155发送视频修改，方便随时切换切片大小
This commit is contained in:
liub
@ -877,7 +877,7 @@
|
||||
"clientid": clientid
|
||||
},
|
||||
formData: {
|
||||
code: 2
|
||||
code: 1
|
||||
},
|
||||
timeout: 600000,
|
||||
fail: (ex) => {
|
||||
@ -899,8 +899,10 @@
|
||||
|
||||
if (res.statusCode === 200) {
|
||||
if (res.data.code == 200) {
|
||||
console.log("上传完成,耗时:" + m + "分" + s + "秒");
|
||||
updateLoading(these,{text:"上传完成,耗时:" + m + "分" + s + "秒,正在切片。"})
|
||||
console.log("上传完成,耗时:" + m + "分" + s + "秒,获得数据:"+res.data.length);
|
||||
updateLoading(these, {
|
||||
text: "上传完成,耗时:" + m + "分" + s + "秒,正在切片。"
|
||||
})
|
||||
resolve(res.data);
|
||||
|
||||
return;
|
||||
@ -922,12 +924,14 @@
|
||||
|
||||
//视频切片
|
||||
let videoCutPacket = (array) => {
|
||||
console.log("开始切片:",array.length);
|
||||
return new Promise((resolve, reject) => {
|
||||
try {
|
||||
let index=0;
|
||||
let imgSize = 25600;
|
||||
let packetSize = 3200;
|
||||
let tdSize = 500;
|
||||
|
||||
let tdSize = 500; //只能是400/500
|
||||
let childPackLength = (tdSize === 400 ? 8 : 7);
|
||||
let results = [];
|
||||
for (let i = 0; i < 30; i++) { //先切出30张，每张25600字节
|
||||
let packet = array.slice(0, imgSize);
|
||||
@ -940,18 +944,24 @@
|
||||
packet.splice(0, packetSize);
|
||||
|
||||
let thirdLevel = [];
|
||||
for (let k = 0; k < 7; k++) { //每1个大包切出7个小包，前6包500字节，第7包200字节，共计56小包
|
||||
for (let k = 0; k < childPackLength; k++) {
|
||||
//如果每小包500字节的话，每1个大包切出7个小包，前6包500字节，第7包200字节，共计56小包
|
||||
//如果每小包400字节的话，每1个大包切出8个小包，每包400字节，共计64小包
|
||||
|
||||
let arr = childPacket.slice(0, tdSize);
|
||||
|
||||
childPacket.splice(0, tdSize)
|
||||
thirdLevel.push(arr);
|
||||
index++;
|
||||
console.log("第"+index+"包长度:"+arr.length);
|
||||
}
|
||||
secondLevel.push(thirdLevel);
|
||||
}
|
||||
results.push(secondLevel);
|
||||
}
|
||||
updateLoading(these,{text:'切片完成,正在发送'});
|
||||
updateLoading(these, {
|
||||
text: '切片完成,正在发送'
|
||||
});
|
||||
resolve(results);
|
||||
} catch (error) {
|
||||
updateLoading(these, {
|
||||
@ -965,7 +975,7 @@
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
//发送视频到设备
|
||||
let shotVideoClick = (array, type, ReSendNo) => {
|
||||
var sendImagePackets = () => {
|
||||
@ -974,9 +984,9 @@
|
||||
|
||||
|
||||
this.currentPacket = 0;
|
||||
|
||||
// 总数据包数
|
||||
var totalPackets = 1680;
|
||||
let smallPacketLen = array[0][0][0].length;
|
||||
// 总数据包数,每包400字节就是1920包，每包500字节时1680包
|
||||
var totalPackets = smallPacketLen === 400 ? 1920 : 1680;
|
||||
this.totalPackets = totalPackets;
|
||||
let currentPacket = 1;
|
||||
|
||||
@ -1000,27 +1010,35 @@
|
||||
}
|
||||
// console.log("111111")
|
||||
// 计算当前包的数据
|
||||
let packetSize = 500;
|
||||
let packetSize = smallPacketLen;
|
||||
|
||||
if ((currentPacket - 1) % 56 === 0) {
|
||||
|
||||
packetSize = 508;
|
||||
|
||||
if (smallPacketLen === 500) {
|
||||
if ((currentPacket - 1) % 56 === 0) {
|
||||
packetSize = 508;
|
||||
}
|
||||
|
||||
if (childPacketIndex === 6) {
|
||||
packetSize = 200;
|
||||
}
|
||||
|
||||
if ((currentPacket - 1) % 56 === 55) {
|
||||
packetSize = 201;
|
||||
}
|
||||
} else if (smallPacketLen === 400) {
|
||||
if ((currentPacket - 1) % 64 === 0) {
|
||||
packetSize = 408;
|
||||
}
|
||||
if ((currentPacket - 1) % 64 === 63) {
|
||||
packetSize = 401;
|
||||
}
|
||||
}
|
||||
|
||||
if (childPacketIndex === 6) {
|
||||
packetSize = 200;
|
||||
}
|
||||
|
||||
if ((currentPacket - 1) % 56 === 55) {
|
||||
packetSize = 201;
|
||||
}
|
||||
|
||||
console.log("imgIndex=" + imgIndex + ",imgPackIndex=" +
|
||||
imgPackIndex +
|
||||
",childPacketIndex=" + childPacketIndex)
|
||||
|
||||
|
||||
let packetData = array[imgIndex][imgPackIndex][childPacketIndex];
|
||||
console.log("imgIndex=" + imgIndex + ",imgPackIndex=" +imgPackIndex +",childPacketIndex=" + childPacketIndex+',packetData='+packetData.length);
|
||||
|
||||
let buffer = new ArrayBuffer(packetSize);
|
||||
let dataView = new DataView(buffer);
|
||||
@ -1028,7 +1046,8 @@
|
||||
let sortNo = currentPacket.toString(16).padStart(4, '0');
|
||||
// console.log("11111");
|
||||
let start = 0;
|
||||
if ((currentPacket - 1) % 56 === 0) {
|
||||
if (((currentPacket - 1) % 56 === 0 && smallPacketLen === 500)
|
||||
|| ((currentPacket - 1) % 64 ===0 && smallPacketLen === 400)) {
|
||||
// 填充头部
|
||||
dataView.setUint8(0, 0xFA); // 帧头
|
||||
dataView.setUint8(1, 0x09); // 帧类型：开机画面
|
||||
@ -1042,19 +1061,24 @@
|
||||
dataView.setUint8(7, imgPackIndex + 1);
|
||||
start = 8;
|
||||
}
|
||||
console.log("222222");
|
||||
|
||||
for (let i = 0; i < packetData.length; i++) {
|
||||
dataView.setUint8(start + i, '0x' + packetData[i]);
|
||||
}
|
||||
// console.log("333333333");
|
||||
if ((currentPacket - 1) % 56 === 55) {
|
||||
dataView.setUint8(200, 0xFF);
|
||||
if (smallPacketLen === 500) {
|
||||
if ((currentPacket - 1) % 56 === 55) {
|
||||
dataView.setUint8(200, 0xFF);
|
||||
}
|
||||
} else if (smallPacketLen === 400) {
|
||||
if ((currentPacket - 1) % 64 === 63) {
|
||||
dataView.setUint8(200, 0xFF);
|
||||
}
|
||||
}
|
||||
// console.log("444444");
|
||||
let inteval = parseInt(this.inteval ? this.inteval : 80);
|
||||
|
||||
ble.sendData(f.deviceId, buffer, f.writeServiceId, f
|
||||
.wirteCharactId, ).then(() => {
|
||||
.wirteCharactId,15).then(() => {
|
||||
if (ReSendNo) {
|
||||
|
||||
resolve();
|
||||
@ -1063,13 +1087,14 @@
|
||||
// 更新进度
|
||||
this.currentPacket = currentPacket;
|
||||
|
||||
updateLoading(these,{
|
||||
text:'正在发送:'+currentPacket+"/"+totalPackets
|
||||
updateLoading(these, {
|
||||
text: '正在发送:' + currentPacket + "/" +
|
||||
totalPackets
|
||||
});
|
||||
|
||||
|
||||
childPacketIndex++;
|
||||
if (childPacketIndex == 7) {
|
||||
if (childPacketIndex == (smallPacketLen === 500?7:8)) {
|
||||
imgPackIndex++;
|
||||
if (imgPackIndex == 8) {
|
||||
imgIndex++;
|
||||
@ -1092,7 +1117,9 @@
|
||||
}
|
||||
|
||||
console.error(err.errMsg + ",发送失败了" + currentPacket);
|
||||
updateLoading(these,{text:"发送失败,"+err.errMsg});
|
||||
updateLoading(these, {
|
||||
text: "发送失败," + err.errMsg
|
||||
});
|
||||
reject(err);
|
||||
});
|
||||
};
|
||||
@ -1106,15 +1133,16 @@
|
||||
}
|
||||
|
||||
return sendImagePackets();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
uni.chooseVideo({
|
||||
sourceType: ['album'],
|
||||
compressed:false,
|
||||
success: function(res) {
|
||||
console.log("res=",res);
|
||||
console.log("res=", res);
|
||||
let path = res.tempFilePath;
|
||||
let width = res.width;
|
||||
let height = res.height;
|
||||
@ -1124,9 +1152,9 @@
|
||||
err.push("视频时长至少2秒");
|
||||
}
|
||||
|
||||
if (width != 160 || height != 80) {
|
||||
err.push("视频宽高必须是160*80");
|
||||
}
|
||||
// if (width != 160 || height != 80) {
|
||||
// err.push("视频宽高必须是160*80");
|
||||
// }
|
||||
if (err.length > 0) {
|
||||
err = err.join(";");
|
||||
these.showPop({
|
||||
@ -1144,29 +1172,32 @@
|
||||
uplploadVideo(path).then(result => {
|
||||
|
||||
videoCutPacket(result.data).then(array => {
|
||||
|
||||
let start = new Date();
|
||||
console.log("开始发送");
|
||||
shotVideoClick(array).then(() => {
|
||||
console.log("发送完成");
|
||||
let end = new Date();
|
||||
var diff = (end.getTime() - start.getTime()) / 1000;
|
||||
let s =parseInt(diff % 60);
|
||||
let m =parseInt((diff - s) / 60);
|
||||
console.log("发送完成,耗时:" + m + "分" + s + "秒");
|
||||
updateLoading(these,{
|
||||
text: "发送完成,耗时:" + m + "分" + s + "秒",
|
||||
});
|
||||
|
||||
}).catch((ex1) => {
|
||||
console.log("出现了异常", ex1)
|
||||
}).finally(() => {
|
||||
timeDelayCloseLoading();
|
||||
});
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
let start = new Date();
|
||||
console.log("开始发送");
|
||||
shotVideoClick(array).then(() => {
|
||||
console.log("发送完成");
|
||||
let end = new Date();
|
||||
var diff = (end.getTime() - start
|
||||
.getTime()) / 1000;
|
||||
let s = parseInt(diff % 60);
|
||||
let m = parseInt((diff - s) / 60);
|
||||
console.log("发送完成,耗时:" + m + "分" +
|
||||
s + "秒");
|
||||
updateLoading(these, {
|
||||
text: "发送完成,耗时:" + m +
|
||||
"分" + s + "秒",
|
||||
});
|
||||
|
||||
}).catch((ex1) => {
|
||||
console.log("出现了异常", ex1)
|
||||
}).finally(() => {
|
||||
timeDelayCloseLoading();
|
||||
});
|
||||
|
||||
|
||||
|
||||
|
||||
}).catch(err => {
|
||||
timeDelayCloseLoading();
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user