commie/im
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

13

Browse Source
This commit is contained in:
cansnow
2025-12-11 22:33:31 +08:00
parent 375917f06c
commit 5a086fa1fa
44 changed files with 1978 additions and 359 deletions
Download Patch File Download Diff File Expand all files Collapse all files
util/common.js
+235 -1
View File
@@ -241,6 +241,7 @@ export const formatChooseData = (data, key = "nickname") => {
};
export const getPurePath = (path) => {
if(!path)return "";
const prefix = "file://";
const relativeRrefix = "_doc/";
if (path.includes(prefix)) {
@@ -302,4 +303,237 @@ export const checkLoginError = (error) => {
default:
return "操作失败";
}
};
};
// 删除本地文件，适配 plus 环境
export const deleteLocalFile = (path) => {
return new Promise((resolve) => {
if (!path) return resolve();
if (typeof plus === 'undefined') return resolve();
// 尝试直接用 resolveLocalFileSystemURL，如果失败再尝试加 file:// 前缀
const tryRemove = (p) => {
plus.io.resolveLocalFileSystemURL(p, function(entry) {
entry.remove(function() {
resolve();
}, function(err) {
console.log('deleteLocalFile remove error:', err);
resolve();
});
}, function(err) {
resolve(err);
});
};
tryRemove(path);
});
};
export const getVideoCover = (videoPath, frameIndex, callback) => {
// 兼容性：如果传入 callback，则函数立即返回空串，并在回调中返回路径；
// 如果不传 callback，则返回 Promise<string>（兼容旧用法）。
// 简单字符串哈希，用于生成固定缩略图文件名
const _hash = (s) => {
let h = 2166136261;
for (let i = 0; i < s.length; i++) {
h ^= s.charCodeAt(i);
h = Math.imul(h, 16777619);
}
return (h >>> 0).toString(16);
};
const run = async () => {
if (!videoPath) return "";
// 生成固定的缩略图路径（基于 videoPath 哈希）
let coverRel = null;
try {
const key = _hash(String(videoPath));
coverRel = `_doc/video_cover_${key}.jpg`;
const coverAbs = typeof plus !== 'undefined' && plus.io ? plus.io.convertLocalFileSystemURL(coverRel) : null;
// 如果已存在，直接返回
if (typeof plus !== 'undefined' && plus.io) {
try {
const exists = await new Promise((res) => {
plus.io.resolveLocalFileSystemURL(coverRel, function(entry) { res(true); }, function() { res(false); });
});
if (exists) return coverAbs;
} catch (e) {
// ignore and continue
}
}
} catch (e) {
// ignore and continue
coverRel = null;
}
// 1. Native plus 方式尝试
if (typeof plus !== "undefined" && plus.io) {
try {
// 规范路径（若有可用转换函数）
if (typeof getUniversalVideoPath === 'function') {
try { videoPath = await getUniversalVideoPath(videoPath); } catch (e) {}
}
// 尝试 Android 原生 MediaMetadataRetriever 提取帧
if (plus.android) {
try {
var MediaMetadataRetriever = plus.android.importClass('android.media.MediaMetadataRetriever');
var retriever = new MediaMetadataRetriever();
var setDataSourcePath = videoPath;
if (typeof setDataSourcePath === 'string' && setDataSourcePath.indexOf('file://') === 0) {
setDataSourcePath = setDataSourcePath.replace('file://', '');
}
var _setOk = false;
try { retriever.setDataSource(setDataSourcePath); _setOk = true; } catch (sdErr) {
try {
var UriClass = plus.android.importClass('android.net.Uri');
var uriObj = UriClass.parse(videoPath);
var activity = plus.android.runtimeMainActivity();
retriever.setDataSource(activity, uriObj);
_setOk = true;
} catch (sd2Err) {}
}
var timeUs = (typeof frameIndex === 'number' && frameIndex >= 0) ? Math.floor(frameIndex * 1000000) : 0;
var bitmap = null;
try { bitmap = retriever.getFrameAtTime(timeUs); } catch (gfErr) {}
if (!bitmap) {
try { bitmap = retriever.getFrameAtTime(-1); } catch (e2) {}
}
if (!bitmap) {
try { bitmap = retriever.getFrameAtTime(1000000); } catch (e3) {}
}
if (bitmap) {
try {
var CompressFormat = plus.android.importClass('android.graphics.Bitmap$CompressFormat');
var ByteArrayOutputStream = plus.android.importClass('java.io.ByteArrayOutputStream');
var baos = new ByteArrayOutputStream();
plus.android.invoke(bitmap, 'compress', CompressFormat.JPEG, 80, baos);
var bytes = plus.android.invoke(baos, 'toByteArray');
// 写入到固定路径（如果 coverRel 可用）
var tempRel = coverRel || ('_doc/video_cover_' + Date.now() + '.jpg');
var tempAbs = plus.io.convertLocalFileSystemURL(tempRel);
var tempForJava = tempAbs;
if (typeof tempForJava === 'string' && tempForJava.indexOf('file://') === 0) tempForJava = tempForJava.replace('file://', '');
var FileOutputStream = plus.android.importClass('java.io.FileOutputStream');
var fos = new FileOutputStream(tempForJava);
plus.android.invoke(fos, 'write', bytes);
plus.android.invoke(fos, 'close');
try { retriever.release(); } catch (e) {}
return tempAbs;
} catch (writeErr) {
try { retriever.release(); } catch (e) {}
}
} else {
try { retriever.release(); } catch (e) {}
}
} catch (mmrErr) {}
}
// 兼容：尝试 plus.getVideoAttributes
if (typeof plus.getVideoAttributes === "function") {
try {
const attr = await new Promise((res, rej) => {
plus.getVideoAttributes(videoPath, function(info) { res(info && info.path ? info.path : info); }, function(err) { rej(err); });
});
if (attr) return attr;
} catch (e) {}
}
} catch (e) {}
}
// 3. H5 capture via video+canvas（在 native 的 WebView 中也可以运行）
if (typeof document !== "undefined") {
try {
const dataUrl = await new Promise((resolve) => {
const video = document.createElement('video');
video.crossOrigin = 'anonymous';
video.src = videoPath;
video.muted = true;
video.playsInline = true;
const onError = () => { cleanup(); resolve(''); };
const onLoaded = () => {
try {
const targetTime = (typeof frameIndex === 'number' && frameIndex >= 0) ? Math.min(video.duration, frameIndex) : Math.min(1, Math.max(0, video.duration / 2));
video.currentTime = targetTime;
} catch (err) {}
setTimeout(() => {
try {
const canvas = document.createElement('canvas');
canvas.width = video.videoWidth || 320;
canvas.height = video.videoHeight || 240;
const ctx = canvas.getContext('2d');
ctx.drawImage(video, 0, 0, canvas.width, canvas.height);
const data = canvas.toDataURL('image/jpeg', 0.8);
cleanup();
resolve(data || '');
} catch (err) { cleanup(); resolve(''); }
}, 400);
};
const cleanup = () => { video.removeEventListener('loadeddata', onLoaded); video.removeEventListener('error', onError); };
video.addEventListener('loadeddata', onLoaded);
video.addEventListener('error', onError);
});
if (!dataUrl) return '';
if (typeof plus !== 'undefined' && plus.io) {
try {
const base64Data = dataUrl.split(',')[1];
const bytes = atob(base64Data);
const buf = new ArrayBuffer(bytes.length);
const arr = new Uint8Array(buf);
for (let i = 0; i < bytes.length; i++) arr[i] = bytes.charCodeAt(i);
const tempRel = coverRel || ('_doc/video_cover_' + Date.now() + '.jpg');
const tempAbs = plus.io.convertLocalFileSystemURL(tempRel);
await new Promise((res, rej) => {
plus.io.resolveLocalFileSystemURL(tempRel, function(fentry) {
fentry.createWriter(function(writer) {
writer.onwrite = function() { res(tempAbs); };
writer.onerror = function(e) { rej(e); };
writer.write(arr.buffer);
}, function(e) { rej(e); });
}, function() {
plus.io.requestFileSystem(plus.io.PRIVATE_DOC, function(fs) {
fs.root.getFile(tempRel, {create: true}, function(fentry) {
fentry.createWriter(function(writer) { writer.onwrite = function() { res(tempAbs); }; writer.onerror = function(e) { rej(e); }; writer.write(arr.buffer); }, rej);
}, rej);
}, rej);
});
});
return tempAbs;
} catch (e) { return dataUrl; }
}
return dataUrl;
} catch (e) {}
}
return '';
};
if (typeof callback === 'function') {
run().then((p) => { try { callback(p); } catch (e) {} }).catch(() => { try { callback(''); } catch (e) {} });
return "";
}
return run();
};
export const getVideoInfo = async (src)=>{
return await new Promise((resolve,reject)=>{
uni.getVideoInfo({
src:src,
success(res){
resolve(res)
},fail(error){
reject(error)
}
})
});
}
util/imCommon.js
+45 -16
View File
@@ -119,12 +119,36 @@ export const parseMessageByType = (pmsg) => {
return pmsg.textElem.content;
case MessageType.PictureMessage:
return `[图片]`;
case MessageType.VoiceMessage:
return `[语音]`;
case MessageType.VideoMessage:
return `[视频]`;
case MessageType.FileMessage:
return `[文件]`;
case MessageType.MergeMessage:
return `[合并消息]`;
case MessageType.CardMessage:
return `[名片]`;
case MessageType.LocationMessage:
return `[位置]`;
case MessageType.CustomMessage:
return `[自定义消息]`;
case MessageType.TypingMessage:
return `[TypingMessage]`;
case MessageType.QuoteMessage:
return `[QuoteMessage]`;
case MessageType.FaceMessage:
return `[FaceMessage]`;
case MessageType.MarkdownMessage:
return `[MarkdownMessage]`;
case MessageType.FriendAdded:
return "你们已经是好友了，开始聊天吧~";
case MessageType.MemberEnter:
const enterDetails = JSON.parse(pmsg.notificationElem.detail);
const enterUser = enterDetails.entrantUser;
return `${getName(enterUser)}进入了群聊`;
case MessageType.OANotification:
return `[OANotification]`;
case MessageType.GroupCreated:
const groupCreatedDetail = JSON.parse(pmsg.notificationElem.detail);
const groupCreatedUser = groupCreatedDetail.opUser;
@@ -138,9 +162,7 @@ export const parseMessageByType = (pmsg) => {
(user, idx) => (inviteStr += getName(user) + "、") && idx > 3,
);
inviteStr = inviteStr.slice(0, -1);
return `${getName(inviteOpUser)}邀请了${inviteStr}${
invitedUserList.length > 3 ? "..." : ""
}进入群聊`;
return `${getName(inviteOpUser)}邀请了${inviteStr}${invitedUserList.length > 3 ? "..." : ""}进入群聊`;
case MessageType.MemberKicked:
const kickDetails = JSON.parse(pmsg.notificationElem.detail);
@@ -151,9 +173,13 @@ export const parseMessageByType = (pmsg) => {
(user, idx) => (kickStr += getName(user) + "、") && idx > 3,
);
kickStr = kickStr.slice(0, -1);
return `${getName(kickOpUser)}踢出了${kickStr}${
kickdUserList.length > 3 ? "..." : ""
}`;
return `${getName(kickOpUser)}踢出了${kickStr}${kickdUserList.length > 3 ? "..." : ""}`;
case MessageType.GroupMemberMuted:
return `[GroupMemberMuted]`;
case MessageType.GroupMemberCancelMuted:
return `[GroupMemberCancelMuted]`;
case MessageType.GroupMuted:
return `[GroupMuted]`;
case MessageType.MemberQuit:
const quitDetails = JSON.parse(pmsg.notificationElem.detail);
const quitUser = quitDetails.quitUser;
@@ -174,9 +200,17 @@ export const parseMessageByType = (pmsg) => {
case MessageType.GroupNameUpdated:
const groupNameUpdateDetail = JSON.parse(pmsg.notificationElem.detail);
const groupNameUpdateUser = groupNameUpdateDetail.opUser;
return `${getName(groupNameUpdateUser)}修改了群名称为${
groupNameUpdateDetail.group.groupName
}`;
return `${getName(groupNameUpdateUser)}修改了群名称为${groupNameUpdateDetail.group.groupName}`;
case MessageType.GroupCancelMuted:
return `[GroupCancelMuted]`;
case MessageType.GroupAnnouncementUpdated:
return `[GroupAnnouncementUpdated]`;
case MessageType.BurnMessageChange:
return `[BurnMessageChange]`;
case MessageType.RevokeMessage:
return `[RevokeMessage]`;
case MessageType.MsgPinned:
return `[MsgPinned]`;
default:
return "[暂未支持的消息类型]";
}
@@ -251,10 +285,7 @@ export const tipMessaggeFormat = (msg, currentUserID) => {
(user, idx) => (inviteStr += parseInfo(user) + "、") && idx > 3,
);
inviteStr = inviteStr.slice(0, -1);
return `${parseInfo(inviteOpUser)} 邀请了${inviteStr}${
invitedUserList.length > 3 ? "..." : ""
}加入群聊`;
case MessageType.MemberKicked:
return `${parseInfo(inviteOpUser)} 邀请了${inviteStr}${invitedUserList.length > 3 ? "..." : ""}加入群聊`; case MessageType.MemberKicked:
const kickDetails = JSON.parse(msg.notificationElem.detail);
const kickOpUser = kickDetails.opUser;
const kickdUserList = kickDetails.kickedUserList ?? [];
@@ -263,9 +294,7 @@ export const tipMessaggeFormat = (msg, currentUserID) => {
(user, idx) => (kickStr += parseInfo(user) + "、") && idx > 3,
);
kickStr = kickStr.slice(0, -1);
return `${parseInfo(kickOpUser)} 踢出了${kickStr}${
kickdUserList.length > 3 ? "..." : ""
}`;
return `${parseInfo(kickOpUser)} 踢出了${kickStr}${kickdUserList.length > 3 ? "..." : ""}`;
case MessageType.MemberEnter:
const enterDetails = JSON.parse(msg.notificationElem.detail);
const enterUser = enterDetails.entrantUser;
util/index.js
+71 -2
View File
@@ -2,6 +2,7 @@
//import i18n from '@/locales'
import base from '@/common/config';
//import store from "@/store";
import IMSDK from "openim-uniapp-polyfill";
const isString = (v)=> {
return typeof v === 'string' || v instanceof String;
},
@@ -222,5 +223,73 @@ export default{
v = parseFloat(v).toFixed(wei || 2);
return parseFloat(v);
},
}
imapi(method,data){
return IMSDK.asyncApi(method,IMSDK.uuid(),data);
},
async fileExsit(fn){
return await new Promise((resolve) => {
plus.io.resolveLocalFileSystemURL(fn, function(entry) { resolve(true); }, function() { resolve(false); });
})
},
downloadFile (url, savepath, successCb, errorCb, progressCb) {
if (!url) {
errorCb && errorCb(new Error('empty url'));
return;
}
const startDownload = () => {
try {
const task = plus.downloader.createDownload(url, { filename: savepath, timeout: 120000 }, function(d, status) {
if (status === 200) {
const local = d && d.filename ? d.filename : savepath;
successCb && successCb(local);
} else {
errorCb && errorCb(new Error('download status ' + status));
}
});
try {
if (task && typeof task.addEventListener === 'function') {
task.addEventListener('statechanged', function(t, status) {
if (t.state === 3) {
var downloaded = t.downloadedSize || t.downloaded || 0;
var total = t.totalSize || t.total || 0;
var prog = 0;
if (total > 0) prog = Math.min(100, Math.floor(downloaded / total * 100));
progressCb && progressCb(prog);
}
});
}
} catch (e) {
// ignore
}
task.start();
} catch (e) {
errorCb && errorCb(e);
}
};
// 确保父目录存在
try {
const parent = savepath.substring(0, savepath.lastIndexOf('/'));
plus.io.resolveLocalFileSystemURL(parent, function(entry) {
startDownload();
}, function() {
// 目录不存在，尝试创建（针对 _doc/<conversationID> 结构）
let rel = parent;
if (rel.indexOf('_doc/') === 0) rel = rel.replace(/^_doc\//, '');
plus.io.requestFileSystem(plus.io.PRIVATE_DOC, function(fs) {
fs.root.getDirectory(rel, { create: true }, function(entry) {
startDownload();
}, function(e) {
// 创建失败也尝试下载，可能运行时会自动创建
startDownload();
});
}, function(e) {
startDownload();
});
});
} catch (e) {
startDownload();
}
}
}