From 0809fce7c43a94c40f0b355e359221477facc51b Mon Sep 17 00:00:00 2001
From: chensiAb <chenchenco03@163.com>
Date: Thu, 16 May 2024 11:01:32 +0800
Subject: [PATCH] fix:'格式化大写PX变小写'

---
 common/Bridge.js |  184 ++++++++++++++++++++++++++++++++++++---------
 1 files changed, 147 insertions(+), 37 deletions(-)

diff --git a/common/Bridge.js b/common/Bridge.js
index cf2b376..90b8891 100644
--- a/common/Bridge.js
+++ b/common/Bridge.js
@@ -1,8 +1,19 @@
 /**
  * 跨端双向通讯桥
  * @author Tevin
+ * @version 1.3.0
  * @tutorial
- *  网页对 App 发起通讯
+ *  通讯策略
+ *      1. App 对网页一般为单向通知,无资源管理要求
+ *      2. 网页对 App 发起单向通知时,也无资源管理要求
+ *      3. 网页对 App 发起单次通讯时,如诺 App 未执行回调,前端将在5分钟后字段释放资源
+ *      4. 网页对 App 发起持续性通讯时,应转换为 App 对网页发起通知,通知无资源管理要求(而不是使用轮询或监听,需要手动停止释放资源)
+ *      5. 网页对 App 发起通讯,两端具体处理方式如下:
+ *          - 如果 callback 有值,App 端在各种情况下,都尽量执行回调,以便于前端更快释放资源
+ *          - 如果 callback 无值,即为单向通知,此时 App 无需处理回调(消息提示由 App 端执行)
+ *          - 如果 App 出现报错或异常,执行 callback 回调时不传任何内容(不能传空对象或空字符串,直接为空)(错误提醒由 App 执行)
+ *          - 如果通讯正常,但是业务为支线流程,例如取消操作,则返回标识表明取消操作(消息提示由网页端执行)
+ *  网页对 App 发起通讯操作步骤
  *      1. 【App端】App 注册接收器,用于接收网页通知
  *          在页面打开之前,App 注入方法 linking = function(paramStr) { <Native Code> }
  *      2. 网页业务中 js 发起通讯
@@ -11,7 +22,7 @@
  *          window.linking('{method:\'methodName\', param:{key1:\'value1\'}, callback:\'bridge.cb111at1541994536008\'}');
  *      4. 【App端】App 处理完后直接调用网页上的全局回调,并传递结果完成通讯
  *          bridge.cb101at1541994536008('{key2:\'value2\'}');
- *  App 对网页发起通讯
+ *  App 对网页发起通讯操作步骤
  *      1. 网页注册接收器,用于接收 App 通知
  *          window.telling = function(dataStr) { someJs };
  *      2. 网页业务中注册接收通讯
@@ -31,6 +42,8 @@
     constructor() {
         this._data = {
             count: 100,
+            fileSaved: {},  // 已保存图片名称列表 { 'blob:***' : 'bridge:***' }
+            fileLoaded: {},  // 已读取图片名称列表 { 'bridge:***' : 'blob:***' }
         };
         this._receives = {};
         this._earlyInvok = [];
@@ -81,9 +94,9 @@
 
     /**
      * 发起一次发送
-     * @param {string} method
-     * @param {object} param
-     * @param {function} callback - 来自网页业务逻辑的回调
+     * @param {String} method
+     * @param {Object} [param]
+     * @param {Function} [callback] - 来自网页业务逻辑的回调
      * @private
      */
     _sendLinking(method, param, callback) {
@@ -94,11 +107,24 @@
         }
         // 转换发送参数键名为下划线
         param = this.transKeyName('underline', param);
+        // 如果无回调,视为单向通知,不全局挂载
         // 如果有回调,转存回调
-        const name = 'cb' + this._data.count++ + 'at' + Date.now();
-        this[name] = (res) => {
-            if (callback && Tools.isFunction(callback)) {
-                if (res) {
+        let cbName = '';
+        if (callback && Tools.isFunction(callback)) {
+            cbName = 'cb' + this._data.count++ + 'at' + Date.now();
+            // 5分钟后超时,自动清除资源
+            const timer = setTimeout(() => {
+                // 释放资源
+                callback = null;
+                this[cbName] = () => {
+                    delete this[cbName];
+                    Tools.toast('跨端通讯超时,请关掉页面重试!');
+                };
+            }, 5 * 60 * 1000);
+            // 挂载到全局
+            this[cbName] = (res) => {
+                // res有值,正常通讯
+                if (typeof res !== 'undefined') {
                     let data;
                     try {
                         // 转对象
@@ -109,30 +135,40 @@
                         Tools.toast('跨端通讯异常:解析数据失败!');
                         return;
                     }
+                    // 回传业务层,忽略来自业务层的报错
                     callback(data);
-                } else {
-                    callback();
                 }
-            }
-            delete this[name];
-        };
+                // res 无值,视为 java 层异常,由 java 层进行异常提醒
+                else {
+                    // do nothing
+                }
+                // 执行一次后释放资源
+                callback = null;
+                delete this[cbName];
+                clearTimeout(timer);
+            };
+        }
         // 发送
         window.aisim.linking(JSON.stringify({
             method,
             param,
-            callback: 'bridge.' + name,
+            callback: cbName ? ('bridge.' + cbName) : '',
         }));
     }
 
     /**
      * 向 app 发起通讯
-     * @param {string} method
-     * @param {object|function} [param]
-     * @param {function} [callback]
+     * @param {String} method
+     * @param {Object|Function} [param]
+     * @param {Function} [callback]
      */
     invoking(method, param = {}, callback) {
+        // param 无值时
+        if (!param) {
+            param = {};
+        }
         // param 为函数时
-        if (param && Tools.isFunction(param)) {
+        else if (param && Tools.isFunction(param)) {
             callback = param;
             param = {};
         }
@@ -225,11 +261,16 @@
      * 保存文件到 java 端,并返回文件名
      * @param objUrl
      * @param callback
+     * @param onError
      */
-    fileSave(objUrl = '', callback) {
+    fileSave(objUrl = '', callback, onError) {
         // 非 ObjectURL 跳过
         if (objUrl.indexOf('blob:') < 0) {
             callback(objUrl);
+            return;
+        }
+        if (this._data.fileSaved[objUrl]) {
+            callback(this._data.fileSaved[objUrl]);
             return;
         }
         // 分段存储
@@ -242,7 +283,18 @@
             };
             this.invoking('img_write', writeData, res => {
                 if (res.result === false) {
-                    Tools.toast(res.msg);
+                    Tools.toast('离线图片存储:' + res.msg);
+                    onError({
+                        method: 'img_write',
+                        request: {
+                            fileName: writeData.fileName,
+                            currentIdx: writeData.currentIdx,
+                            totalIdx: writeData.total,
+                            data: (writeData.data || '').substr(0, 10)
+                                + '...(共' + (writeData.data || '').length + '个base64字符)',
+                        },
+                        response: res,
+                    });
                     return;
                 }
                 // 按分段递归保存
@@ -258,22 +310,28 @@
             });
         };
         $fileTrans.transObjUrlToBaseData(objUrl, baseData => {
+            this._data.fileSaved[objUrl] = 'bridge:' + baseData.fileName;
             saveFileChunk(baseData, 0);
         });
     }
 
     /**
      * 从 java 读取文件 base64
-     * @param fileName
+     * @param bridgeName
      * @param callback
+     * @param onError
      */
-    fileLoad(fileName = '', callback) {
+    fileLoad(bridgeName = '', callback, onError) {
         // 非存储地址,跳过
-        if (fileName.indexOf('bridge:') < 0) {
-            callback(fileName);
+        if (bridgeName.indexOf('bridge:') < 0) {
+            callback(bridgeName);
             return;
         }
-        fileName = fileName.split(':')[1];
+        if (this._data.fileLoaded[bridgeName]) {
+            callback(this._data.fileLoaded[bridgeName]);
+            return;
+        }
+        const fileName = bridgeName.split(':')[1];
         const chunkSize = $fileTrans.getChunkSize();
         const baseArr = [];
         let totalSize = 0;
@@ -286,7 +344,21 @@
             };
             this.invoking('img_read', loadData, res => {
                 if (res.result === false) {
-                    Tools.toast(res.msg);
+                    Tools.toast('离线图片读取:' + res.msg);
+                    onError({
+                        method: 'img_read',
+                        request: {
+                            ...loadData,
+                            totalCount,
+                        },
+                        response: {
+                            result: res.result,
+                            msg: res.msg,
+                            'total_size': res.totalSize,
+                            data: (res.data || '').substr(0, 10)
+                                + '...(共' + (res.data || '').length + '个base64字符)',
+                        },
+                    });
                     return;
                 }
                 if (totalSize === 0) {
@@ -304,9 +376,30 @@
                         baseArr,
                         fileName,
                     };
-                    $fileTrans.transBaseDataToObjUrl(baseData, objUrl => {
-                        callback && callback(objUrl);
-                    });
+                    try {
+                        $fileTrans.transBaseDataToObjUrl(baseData, objUrl => {
+                            this._data.fileLoaded[bridgeName] = objUrl;
+                            callback && callback(objUrl);
+                        });
+                    } catch (e) {
+                        onError({
+                            method: 'img_read@merge_after_base64_loaded',
+                            request: {
+                                ...loadData,
+                                totalCount,
+                            },
+                            response: {
+                                result: res.result,
+                                msg: res.msg,
+                                'total_size': res.totalSize,
+                                data: (res.data || '').substr(0, 10)
+                                    + '...(共' + (res.data || '').length + '个base64字符)',
+                            },
+                            base64Arr: baseData.baseArr.map(baseItem => (baseItem || []).substr(0, 10)
+                                + '...(共' + (res.data || '').length + '个base64字符)'),
+                            message: 'Base64合并解析异常!',
+                        });
+                    }
                 }
             });
         };
@@ -315,14 +408,20 @@
 
     /**
      * 从 java 端移除文件
-     * @param fileName
+     * @param bridgeName
      */
-    fileRemove(fileName = '') {
-        if (fileName.indexOf('bridge:') < 0) {
+    fileRemove(bridgeName = '') {
+        if (bridgeName.indexOf('bridge:') < 0) {
             return;
         }
-        fileName = fileName.split(':')[1];
+        const fileName = bridgeName.split(':')[1];
         this.invoking('img_del', { fileName });
+        // 移除
+        Object.keys(this._data.fileSaved).forEach(objUrl => {
+            if (bridgeName === this._data.fileSaved[objUrl]) {
+                delete this._data.fileSaved[objUrl];
+            }
+        });
     }
 
     /**
@@ -331,13 +430,20 @@
      * @param names
      * @param callback
      */
-    fileStorehouse(type, names = [], callback) {
+    fileStore(type, names = [], callback) {
+        if (!names || names.length === 0) {
+            callback && callback([]);
+            return;
+        }
+        if (typeof names === 'string') {
+            names = names.split(',');
+        }
         // 保存
         if (type === 'save') {
             const list = [];
             const save = index => {
-                this.fileSave(names[index], fileName => {
-                    list.push(fileName);
+                this.fileSave(names[index], bridgeName => {
+                    list.push(bridgeName);
                     // 递归下一个
                     if (index < names.length - 1) {
                         setTimeout(() => {
@@ -348,6 +454,8 @@
                     else {
                         callback && callback(list);
                     }
+                }, err => {
+                    callback && callback(null, err);
                 });
             };
             save(0);
@@ -368,6 +476,8 @@
                     else {
                         callback && callback(list);
                     }
+                }, err => {
+                    callback && callback(null, err);
                 });
             };
             load(0);

--
Gitblit v1.9.1