rx-util

rxliuli 在浏览器上使用的 js 工具集

目前为 2020-07-02 提交的版本。查看 最新版本

此脚本不应直接安装,它是一个供其他脚本使用的外部库。如果您需要使用该库,请在脚本元属性加入:// @require https://update.cn-greasyfork.org/scripts/382120/822650/rx-util.js

  1. (function (global, factory) {
  2. typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) :
  3. typeof define === 'function' && define.amd ? define(['exports'], factory) :
  4. (global = global || self, factory(global.rx = {}));
  5. }(this, (function (exports) { 'use strict';
  6.  
  7. /**
  8. * 在浏览器上下载二进制资源
  9. * @param blob 要下载的二进制资源
  10. * @param filename 文件名
  11. */
  12. function download(blob, filename = 'unknown') {
  13. // 创建隐藏的可下载链接
  14. const eleLink = document.createElement('a');
  15. eleLink.download = filename;
  16. eleLink.style.display = 'none';
  17. // 为 link 赋值
  18. eleLink.href = URL.createObjectURL(blob);
  19. // 触发点击
  20. document.body.appendChild(eleLink);
  21. eleLink.click();
  22. // 然后移除
  23. document.body.removeChild(eleLink);
  24. }
  25.  
  26. /*! *****************************************************************************
  27. Copyright (c) Microsoft Corporation. All rights reserved.
  28. Licensed under the Apache License, Version 2.0 (the "License"); you may not use
  29. this file except in compliance with the License. You may obtain a copy of the
  30. License at http://www.apache.org/licenses/LICENSE-2.0
  31.  
  32. THIS CODE IS PROVIDED ON AN *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  33. KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY IMPLIED
  34. WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE,
  35. MERCHANTABLITY OR NON-INFRINGEMENT.
  36.  
  37. See the Apache Version 2.0 License for specific language governing permissions
  38. and limitations under the License.
  39. ***************************************************************************** */
  40.  
  41. function __awaiter(thisArg, _arguments, P, generator) {
  42. return new (P || (P = Promise))(function (resolve, reject) {
  43. function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
  44. function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
  45. function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
  46. step((generator = generator.apply(thisArg, _arguments || [])).next());
  47. });
  48. }
  49.  
  50. /**
  51. * 将字符串转化为 Blob 类型
  52. * @param str 字符串
  53. * @returns Blob 数据
  54. */
  55. function strToBlob(str) {
  56. return new Blob([str], {
  57. type: 'text/plain',
  58. });
  59. }
  60.  
  61. /**
  62. * 在浏览器上下载文本内容
  63. * @param str 字符串内容
  64. * @param filename 下载文件名,没有则默认为链接中的文件名
  65. */
  66. function downloadString(str, filename = 'unknown.txt') {
  67. return __awaiter(this, void 0, void 0, function* () {
  68. download(strToBlob(str), filename);
  69. });
  70. }
  71.  
  72. /**
  73. * 根据 url 下载二进制资源
  74. * @param url 下载请求信息
  75. * @param filename 下载文件名,没有则默认为链接中的文件名
  76. */
  77. function downloadUrl(url, filename = url.substr(url.lastIndexOf('/'))) {
  78. return __awaiter(this, void 0, void 0, function* () {
  79. // 创建隐藏的可下载链接
  80. const eleLink = document.createElement('a');
  81. eleLink.download = filename;
  82. eleLink.style.display = 'none';
  83. // 为 link 赋值
  84. eleLink.href = url;
  85. // 触发点击
  86. document.body.appendChild(eleLink);
  87. eleLink.click();
  88. // 然后移除
  89. document.body.removeChild(eleLink);
  90. });
  91. }
  92.  
  93. /**
  94. * 获取 cookie 键值映射 Map
  95. * @returns cookie 键值映射 Map
  96. */
  97. function getCookies() {
  98. return document.cookie.split(';').reduce((res, str) => {
  99. const [k, v] = str.split('=');
  100. res.set(k, v);
  101. return res;
  102. }, new Map());
  103. }
  104.  
  105. /**
  106. * 将 url 中的内容加载到元素上
  107. * 注:domSelector 必须有 src 属性用以将加载完成的资源赋值给其,加载默认是异步的
  108. * @param url url 资源
  109. * @param dom dom 元素
  110. * @param init 初始化参数, 实为 fetch() 的参数以及一些自定义的参数,默认 {}
  111. * 关于 fetch 具体可以参考 <https://developer.mozilla.org/zh-CN/docs/Web/API/Fetch_API/Using_Fetch>
  112. */
  113. function loadResource(url, dom, init = {}) {
  114. return __awaiter(this, void 0, void 0, function* () {
  115. const res = yield fetch(url, init);
  116. const blob = yield res.blob();
  117. // 生成一个本地的 url 并赋值给 src 属性
  118. dom.src = window.URL.createObjectURL(blob);
  119. });
  120. }
  121.  
  122. /**
  123. * 协议与默认端口映射表
  124. */
  125. const protocolPortMap = new Map()
  126. .set('http', 80)
  127. .set('https', 443)
  128. .set('ssh', 22)
  129. .set('ftp', 21);
  130. /**
  131. * 解析 url 字符串
  132. * @param url url 字符串,不能为空
  133. * @returns url 对象
  134. * @deprecated 请使用原生 API URL 类,可以通过 new URL(url) 将 URL 字符串转换为 URL 对象,并获取指定的信息
  135. */
  136. function parseUrl(url) {
  137. if (!url) {
  138. throw new Error('Url cannot be empty');
  139. }
  140. const regexp = new RegExp('^((\\w+)://([\\w\\.]*)(:(\\d+))?)(.*)');
  141. const temps = regexp.exec(url);
  142. if (temps === null) {
  143. return null;
  144. }
  145. const website = temps[1];
  146. const protocol = temps[2];
  147. const domain = temps[3];
  148. const portStr = temps[5];
  149. const href = temps[6];
  150. // 截取域名之后的内容
  151. const temp = url.substr(website.length);
  152. const markIndex = temp.indexOf('?');
  153. // 如果没有携带参数则直接返回
  154. if (markIndex === -1) {
  155. const accessPath = temp;
  156. return {
  157. url,
  158. website,
  159. protocol,
  160. domain,
  161. // tslint:disable-next-line:radix
  162. port: parseInt(portStr),
  163. href,
  164. accessPath,
  165. params: new Map(),
  166. };
  167. }
  168. let accessPath = temp.substr(0, markIndex);
  169. if (accessPath.endsWith('/')) {
  170. accessPath = accessPath.substring(0, accessPath.length - 1);
  171. }
  172. const port = portStr || protocolPortMap.get(protocol) || 0;
  173. // 解析参数列表
  174. const params = temp
  175. .substr(markIndex + 1)
  176. .split('&')
  177. .map(str => str.split('='))
  178. .filter(arr => arr[0] !== '')
  179. .reduce((params, arr) => {
  180. const k = decodeURIComponent(arr[0]);
  181. const v = decodeURIComponent(arr.length === 1 ? '' : arr[1]);
  182. // 如果已经存在了就认为是数组参数
  183. const vs = params.get(k);
  184. if (vs === undefined) {
  185. params.set(k, v);
  186. }
  187. else {
  188. if (!Array.isArray(vs)) {
  189. params.set(k, [vs]);
  190. }
  191. if (params.get(k).length !== undefined) {
  192. params.get(k).push(v);
  193. }
  194. }
  195. return params;
  196. }, new Map());
  197. return {
  198. url,
  199. website,
  200. protocol,
  201. domain,
  202. port,
  203. href,
  204. accessPath,
  205. params,
  206. };
  207. }
  208.  
  209. /**
  210. * 读取文件类型
  211. */
  212. var ReadType;
  213. (function (ReadType) {
  214. /**
  215. * 以 data url 读取
  216. */
  217. ReadType["DataURL"] = "readAsDataURL";
  218. /**
  219. * 以文本读取
  220. */
  221. ReadType["Text"] = "readAsText";
  222. /**
  223. * 以二进制文件读取
  224. */
  225. ReadType["BinaryString"] = "readAsBinaryString";
  226. /**
  227. * 以 ArrayBuffer 读取
  228. */
  229. ReadType["ArrayBuffer"] = "readAsArrayBuffer";
  230. })(ReadType || (ReadType = {}));
  231. /**
  232. * 读取本地浏览器选择的文件
  233. * @param file 选择的文件
  234. * @param options 读取的选项
  235. * @returns 返回了读取到的内容(异步)
  236. */
  237. function _readLocal(file, options = {}) {
  238. const { type, encoding } = Object.assign({
  239. type: ReadType.DataURL,
  240. encoding: 'UTF-8',
  241. }, options);
  242. return new Promise((resolve, reject) => {
  243. if (!file) {
  244. reject(new Error('file not exists'));
  245. }
  246. const fr = new FileReader();
  247. fr.onload = () => {
  248. resolve(fr.result);
  249. };
  250. fr.onerror = error => {
  251. reject(error);
  252. };
  253. switch (type) {
  254. case ReadType.DataURL:
  255. fr.readAsDataURL(file);
  256. break;
  257. case ReadType.Text:
  258. fr.readAsText(file, encoding);
  259. break;
  260. case ReadType.BinaryString:
  261. fr.readAsBinaryString(file);
  262. break;
  263. case ReadType.ArrayBuffer:
  264. fr.readAsArrayBuffer(file);
  265. break;
  266. }
  267. });
  268. }
  269. const readLocal = Object.assign(_readLocal, {
  270. ReadType,
  271. /**
  272. * 以 data url 读取
  273. * @deprecated 已废弃,请使用枚举类 ReadType
  274. */
  275. DataURL: ReadType.DataURL,
  276. /**
  277. * 以文本读取
  278. * @deprecated 已废弃,请使用枚举类 ReadType
  279. */
  280. Text: ReadType.Text,
  281. /**
  282. * 以二进制文件读取
  283. * @deprecated 已废弃,请使用枚举类 ReadType
  284. */
  285. BinaryString: ReadType.BinaryString,
  286. /**
  287. * 以 ArrayBuffer 读取
  288. * @deprecated 已废弃,请使用枚举类 ReadType
  289. */
  290. ArrayBuffer: ReadType.ArrayBuffer,
  291. });
  292.  
  293. /**
  294. * 为 js 中的 Date 对象原型添加 format 格式化方法
  295. * @param date 要进行格式化的日期
  296. * @param fmt 日期的格式,格式 {@code '[Y+|y+][M+][D+|d+][H+|h+][m+][s+][S+][q+]'}
  297. * @returns 格式化得到的结果
  298. */
  299. function dateFormat(date, fmt) {
  300. const timeFormatDefaults = {
  301. 'Y+|y+': date.getFullYear(),
  302. 'M+': date.getMonth() + 1,
  303. 'D+|d+': date.getDate(),
  304. 'H+|h+': date.getHours(),
  305. 'm+': date.getMinutes(),
  306. 's+': date.getSeconds(),
  307. 'q+': Math.floor((date.getMonth() + 3) / 3),
  308. 'S+': date.getMilliseconds(),
  309. };
  310. for (const k in timeFormatDefaults) {
  311. if (!new RegExp('(' + k + ')').test(fmt)) {
  312. continue;
  313. }
  314. if (k === 'Y+|y+') {
  315. fmt = fmt.replace(RegExp.$1, ('' + timeFormatDefaults[k]).substr(4 - RegExp.$1.length));
  316. }
  317. else if (k === 'S+') {
  318. let lens = RegExp.$1.length;
  319. lens = lens === 1 ? 3 : lens;
  320. fmt = fmt.replace(RegExp.$1, ('00' + timeFormatDefaults[k]).substr(('' + timeFormatDefaults[k]).length - 1, lens));
  321. }
  322. else {
  323. const v = Reflect.get(timeFormatDefaults, k);
  324. fmt = fmt.replace(RegExp.$1, RegExp.$1.length === 1 ? v : ('00' + v).substr(('' + v).length));
  325. }
  326. }
  327. return fmt;
  328. }
  329.  
  330. /**
  331. * 默认的日期格式
  332. * 不加 Z 为本地日期时间,避免出现时区的问题
  333. */
  334. const dateFormatter = 'yyyy-MM-ddThh:mm:ss.SSS';
  335. /**
  336. * 将参数 key 与 value 进行 url 编码
  337. * @param k 参数的名字
  338. * @param v 参数的值
  339. * @returns 编码后的字符串
  340. */
  341. const encode = (k, v) => encodeURIComponent(k) + '=' + encodeURIComponent(v);
  342. /**
  343. * 拼接参数字符串
  344. * @param params 参数对象
  345. * @returns 拼接后的字符串
  346. */
  347. function spliceParams(params = {}) {
  348. return Array.from(Object.entries(params)).reduce((res, [k, v]) => {
  349. if (v === undefined || v === null) {
  350. return res;
  351. }
  352. else if (v instanceof Date) {
  353. res += encode(k, dateFormat(v, dateFormatter));
  354. }
  355. else if (v instanceof Array) {
  356. res += v
  357. .map(item => encode(k, item instanceof Date ? dateFormat(item, dateFormatter) : item))
  358. .join('&');
  359. }
  360. else {
  361. res += encode(k, v);
  362. }
  363. return (res += '&');
  364. }, '');
  365. }
  366.  
  367. /**
  368. * 等待指定的时间/等待指定表达式成立
  369. * 如果未指定等待条件则立刻执行
  370. * 注: 此实现在 nodejs 10- 会存在宏任务与微任务的问题,切记 async-await 本质上还是 Promise 的语法糖,实际上并非真正的同步函数!!!即便在浏览器,也不要依赖于这种特性。
  371. * @param param 等待时间/等待条件
  372. * @returns Promise 对象
  373. */
  374. function wait(param) {
  375. return new Promise(resolve => {
  376. if (typeof param === 'number') {
  377. setTimeout(resolve, param);
  378. }
  379. else if (typeof param === 'function') {
  380. const timer = setInterval(() => {
  381. if (param()) {
  382. clearInterval(timer);
  383. resolve();
  384. }
  385. }, 100);
  386. }
  387. else {
  388. resolve();
  389. }
  390. });
  391. }
  392.  
  393. /**
  394. * 为 fetch 请求添加超时选项
  395. * 注:超时选项并非真正意义上的超时即取消请求,请求依旧正常执行完成,但会提前返回 reject 结果
  396. * @param fetchPromise fetch 请求的 Promise
  397. * @param timeout 超时时间
  398. * @returns 如果超时就提前返回 reject, 否则正常返回 fetch 结果
  399. */
  400. function fetchTimeout(fetchPromise, timeout) {
  401. return Promise.race([
  402. fetchPromise,
  403. wait(timeout).then(() => {
  404. throw new Error('timeout');
  405. }),
  406. ]);
  407. }
  408.  
  409. /**
  410. * 将字符串转为字符流
  411. * @param str 字符串
  412. * @returns 字符流对象
  413. */
  414. function strToArrayBuffer(str) {
  415. const buf = new ArrayBuffer(str.length);
  416. const view = new Uint8Array(buf);
  417. for (let i = 0; i < str.length; ++i) {
  418. view[i] = str.charCodeAt(i) & 0xff;
  419. }
  420. return buf;
  421. }
  422.  
  423. /**
  424. * 限制并发请求数量的 fetch 封装
  425. * @class FetchLimiting
  426. * @example
  427. * const fetchLimiting = new FetchLimiting()
  428. * fetchLimiting._fetch('/')
  429. * .then(res => res.json())
  430. * .then(json => console.log(json))
  431. * @deprecated 已废弃,请使用 {@link asyncLimiting} 函数
  432. */
  433. class FetchLimiting {
  434. /**
  435. * 构造函数
  436. * @param option 可选配置项
  437. * @param option.timeout 超时毫秒数
  438. * @param option.limit 最大并发数限制
  439. */
  440. constructor({ timeout = 10000, limit = 10, } = {}) {
  441. /**
  442. * @field timeout 超时毫秒数
  443. */
  444. this.timeout = timeout;
  445. /**
  446. * @field limit 最大并发数限制
  447. */
  448. this.limit = limit;
  449. /**
  450. * @field execCount 当前正在执行异步的数量
  451. */
  452. this.execCount = 0;
  453. /**
  454. * @field waitArr 等待的队列
  455. * @type {Array.<IArguments>}
  456. */
  457. this.waitArr = [];
  458. }
  459. /**
  460. * 执行一个请求
  461. * 如果到达最大并发限制时就进行等待
  462. * @param url 请求 url 信息
  463. * @param init 请求的其他可选项,默认为 undefined
  464. * @returns 如果超时就提前返回 reject, 否则正常返回 fetch 结果
  465. */
  466. fetch(input, init) {
  467. return __awaiter(this, void 0, void 0, function* () {
  468. const _innerFetch = () => __awaiter(this, void 0, void 0, function* () {
  469. this.execCount++;
  470. const args = this.waitArr.shift();
  471. try {
  472. // 这里的 args 实际上就是 arguments 对象,即上面的 url 和 init
  473. return yield fetchTimeout(fetch(args[0], args[1]), this.timeout);
  474. }
  475. finally {
  476. this.execCount--;
  477. }
  478. });
  479. this.waitArr.push([input, init]);
  480. yield wait(() => this.execCount < this.limit);
  481. // 尝试启动等待队列
  482. return _innerFetch();
  483. });
  484. }
  485. }
  486.  
  487. /**
  488. * 将一个 Iterator 迭代器转换为一个 Array
  489. * @param iterator Iterator 迭代器
  490. * @return Iterator 中每一项元素转换而得到的 Array
  491. * @deprecated 已废弃,请使用 ES6 原生函数 {@see Array.from} 替代
  492. */
  493. function asIterator(iterator) {
  494. const arr = [];
  495. while (true) {
  496. const next = iterator.next();
  497. if (next.done) {
  498. break;
  499. }
  500. arr.push(next.value);
  501. }
  502. return arr;
  503. }
  504.  
  505. /**
  506. * 判断一个对象是否是无效的
  507. * 无效的值仅包含 null/undefined
  508. * @param object 任何一个对象
  509. * @returns 是否无效的值
  510. */
  511. function isNullOrUndefined(object) {
  512. return object === undefined || object === null;
  513. }
  514.  
  515. /**
  516. * 返回第一个参数的函数
  517. * 注: 一般可以当作返回参数自身的函数,如果你只关注第一个参数的话
  518. * @param obj 任何对象
  519. * @typeparam T 传入参数的类型
  520. * @typeparam R 返回结果的类型,默认为 T,只是为了兼容该函数当参数被传递时可能出现需要类型不一致的问题
  521. * @returns 传入的第一个参数
  522. */
  523. function returnItself(obj) {
  524. return obj;
  525. }
  526.  
  527. /**
  528. * 兼容异步函数的返回值
  529. * @param res 返回值
  530. * @param callback 同步/异步结果的回调函数
  531. * @typeparam T 处理参数的类型,如果是 Promise 类型,则取出其泛型类型
  532. * @typeparam Param 处理参数具体的类型,如果是 Promise 类型,则指定为原类型
  533. * @typeparam R 返回值具体的类型,如果是 Promise 类型,则指定为 Promise 类型,否则为原类型
  534. * @returns 处理后的结果,如果是同步的,则返回结果是同步的,否则为异步的
  535. */
  536. function compatibleAsync(res, callback) {
  537. return (res instanceof Promise
  538. ? res.then(callback)
  539. : callback(res));
  540. }
  541.  
  542. /**
  543. * 内部使用的函数
  544. * 注: 如果谓词中包含任意一个异步(返回 Promise)函数,则整个返回结果将变成异步的,否则默认为同步操作.
  545. * @param fns 谓词数组
  546. * @param args 谓词应用的参数列表
  547. * @param condition 临界条件
  548. * @returns 返回结果
  549. */
  550. function _inner(fns, args, condition) {
  551. const fn = fns[0];
  552. const res = fn(...args);
  553. function _call(res) {
  554. if (condition(res)) {
  555. return res;
  556. }
  557. const others = fns.slice(1);
  558. if (others.length === 0) {
  559. return res;
  560. }
  561. return _inner(others, args, condition);
  562. }
  563. return compatibleAsync(res, _call);
  564. }
  565. /**
  566. * 连接谓词函数
  567. */
  568. class CombinedPredicate {
  569. /**
  570. * 使用 && 进行连接
  571. * @param fns 连接任意多个谓词
  572. * @returns 连接后的新谓词
  573. */
  574. static and(...fns) {
  575. return function (...args) {
  576. return _inner(fns, args, res => !res);
  577. };
  578. }
  579. /**
  580. * 使用 || 进行连接
  581. * @param fns 连接任意多个谓词
  582. * @returns 连接后的新谓词
  583. */
  584. static or(...fns) {
  585. return function (...args) {
  586. return _inner(fns, args, res => res);
  587. };
  588. }
  589. /**
  590. * 对谓词进行取反
  591. * @param fn 谓词
  592. * @returns 取反后的谓词
  593. */
  594. static not(fn) {
  595. return new Proxy(fn, {
  596. apply(_, _this, args) {
  597. return compatibleAsync(Reflect.apply(_, this, args), res => !res);
  598. },
  599. });
  600. }
  601. }
  602. const and = CombinedPredicate.and;
  603. const or = CombinedPredicate.or;
  604. const not = CombinedPredicate.not;
  605.  
  606. /**
  607. * 操作类型
  608. */
  609. var ActionType;
  610. (function (ActionType) {
  611. ActionType["forEach"] = "forEach";
  612. ActionType["filter"] = "filter";
  613. ActionType["map"] = "map";
  614. ActionType["flatMap"] = "flatMap";
  615. ActionType["sort"] = "sort";
  616. ActionType["reduce"] = "reduce";
  617. ActionType["reduceRight"] = "reduceRight";
  618. ActionType["findIndex"] = "findIndex";
  619. ActionType["find"] = "find";
  620. ActionType["every"] = "every";
  621. ActionType["some"] = "some";
  622. ActionType["parallel"] = "parallel";
  623. ActionType["serial"] = "serial";
  624. })(ActionType || (ActionType = {}));
  625. /**
  626. * 保存高阶函数传入的异步操作
  627. * @field 异步操作的类型
  628. * @field 异步操作
  629. */
  630. class Action {
  631. constructor(type, args) {
  632. this.type = type;
  633. this.args = args;
  634. this.type = type;
  635. this.args = args;
  636. }
  637. }
  638. Action.Type = ActionType;
  639. /**
  640. * 抽象异步数组,实现了一些公共的函数
  641. */
  642. class InnerBaseAsyncArray {
  643. /**
  644. * 构造函数
  645. * @param args 数组初始元素
  646. */
  647. constructor(args = []) {
  648. this._arr = args;
  649. }
  650. /**
  651. * 将整个数组排序
  652. * @param fn 比较函数
  653. * @returns 排序后的数组
  654. */
  655. sort(fn) {
  656. return __awaiter(this, void 0, void 0, function* () {
  657. if (fn === undefined) {
  658. return new InnerAsyncArray(this._arr.sort());
  659. }
  660. // TODO 此处为了让 type-doc 能生成文档而不得不加上类型
  661. const arr = this._arr.map((v, i) => [v, i]);
  662. function _sort(arr, fn) {
  663. return __awaiter(this, void 0, void 0, function* () {
  664. // 边界条件,如果传入数组的值
  665. if (arr.length <= 1) {
  666. return arr;
  667. }
  668. // 根据中间值对数组分治为两个数组
  669. const medianIndex = Math.floor(arr.length / 2);
  670. const medianValue = arr[medianIndex];
  671. const left = [];
  672. const right = [];
  673. for (let i = 0, len = arr.length; i < len; i++) {
  674. if (i === medianIndex) {
  675. continue;
  676. }
  677. const v = arr[i];
  678. if ((yield fn(v, medianValue)) <= 0) {
  679. left.push(v);
  680. }
  681. else {
  682. right.push(v);
  683. }
  684. }
  685. return (yield _sort(left, fn))
  686. .concat([medianValue])
  687. .concat(yield _sort(right, fn));
  688. });
  689. }
  690. return new InnerAsyncArray(yield (yield _sort(arr, ([t1], [t2]) => fn(t1, t2))).map(([_v, i]) => this._arr[i]));
  691. });
  692. }
  693. /**
  694. * 异步的 find
  695. * @param fn 异步查询函数
  696. * @returns 查询到的第一个值
  697. */
  698. find(fn) {
  699. return __awaiter(this, void 0, void 0, function* () {
  700. const i = yield this.findIndex(fn);
  701. return i === -1 ? null : this._arr[i];
  702. });
  703. }
  704. /**
  705. * 异步的 every
  706. * @param fn 异步匹配函数
  707. * @returns 是否全部匹配
  708. */
  709. every(fn) {
  710. return __awaiter(this, void 0, void 0, function* () {
  711. return (yield this.findIndex(CombinedPredicate.not(fn))) === -1;
  712. });
  713. }
  714. /**
  715. * 异步的 some
  716. * @param fn 异步匹配函数
  717. * @returns 是否有任意一个匹配
  718. */
  719. some(fn) {
  720. return __awaiter(this, void 0, void 0, function* () {
  721. return (yield this.findIndex(fn)) !== -1;
  722. });
  723. }
  724. /**
  725. * 转换为并发异步数组
  726. */
  727. parallel() {
  728. return new InnerAsyncArrayParallel(this._arr);
  729. }
  730. /**
  731. * 转换为顺序异步数组
  732. */
  733. serial() {
  734. return new InnerAsyncArray(this._arr);
  735. }
  736. /**
  737. * 获取内部数组的值,将返回一个浅复制的数组
  738. */
  739. value() {
  740. return this._arr.slice();
  741. }
  742. }
  743. /**
  744. * 串行的异步数组
  745. */
  746. class InnerAsyncArray extends InnerBaseAsyncArray {
  747. constructor(args) {
  748. super(args);
  749. }
  750. forEach(fn) {
  751. return __awaiter(this, void 0, void 0, function* () {
  752. for (let i = 0, len = this._arr.length; i < len; i++) {
  753. yield fn.call(this, this._arr[i], i, this);
  754. }
  755. });
  756. }
  757. filter(fn) {
  758. return __awaiter(this, void 0, void 0, function* () {
  759. const res = new InnerAsyncArray();
  760. for (let i = 0, len = this._arr.length; i < len; i++) {
  761. if (yield fn.call(this, this._arr[i], i, this)) {
  762. res._arr.push(this._arr[i]);
  763. }
  764. }
  765. return res;
  766. });
  767. }
  768. map(fn) {
  769. return __awaiter(this, void 0, void 0, function* () {
  770. const res = new InnerAsyncArray();
  771. for (let i = 0, len = this._arr.length; i < len; i++) {
  772. res._arr.push(yield fn.call(this, this._arr[i], i, this));
  773. }
  774. return res;
  775. });
  776. }
  777. flatMap(fn) {
  778. return __awaiter(this, void 0, void 0, function* () {
  779. const res = new InnerAsyncArray();
  780. for (let i = 0, len = this._arr.length; i < len; i++) {
  781. res._arr.push(...(yield fn.call(this, this._arr[i], i, this)));
  782. }
  783. return res;
  784. });
  785. }
  786. reduce(fn, res) {
  787. return __awaiter(this, void 0, void 0, function* () {
  788. for (let i = 0, len = this._arr.length; i < len; i++) {
  789. if (res) {
  790. res = yield fn.call(this, res, this._arr[i], i, this);
  791. }
  792. else {
  793. res = this._arr[i];
  794. }
  795. }
  796. return res;
  797. });
  798. }
  799. reduceRight(fn, res) {
  800. return __awaiter(this, void 0, void 0, function* () {
  801. for (let i = this._arr.length - 1; i >= 0; i--) {
  802. if (res) {
  803. res = yield fn.apply(this, [res, this._arr[i], i, this]);
  804. }
  805. else {
  806. res = this._arr[i];
  807. }
  808. }
  809. return res;
  810. });
  811. }
  812. findIndex(fn) {
  813. return __awaiter(this, void 0, void 0, function* () {
  814. for (let i = 0, len = this._arr.length; i < len; i++) {
  815. const res = yield fn.call(this, this._arr[i], i, this);
  816. if (res) {
  817. return i;
  818. }
  819. }
  820. return -1;
  821. });
  822. }
  823. }
  824. /**
  825. * 并发的异步数组
  826. */
  827. class InnerAsyncArrayParallel extends InnerBaseAsyncArray {
  828. constructor(args) {
  829. super(args);
  830. }
  831. forEach(fn) {
  832. return __awaiter(this, void 0, void 0, function* () {
  833. yield this._all(fn);
  834. });
  835. }
  836. filter(fn) {
  837. return __awaiter(this, void 0, void 0, function* () {
  838. const res = yield this._all(fn);
  839. const result = new InnerAsyncArrayParallel();
  840. for (let i = 0, len = res.length; i < len; i++) {
  841. if (res[i]) {
  842. result._arr.push(this._arr[i]);
  843. }
  844. }
  845. return result;
  846. });
  847. }
  848. map(fn) {
  849. return __awaiter(this, void 0, void 0, function* () {
  850. return new InnerAsyncArrayParallel(yield this._all(fn));
  851. });
  852. }
  853. flatMap(fn) {
  854. return __awaiter(this, void 0, void 0, function* () {
  855. const res = yield this._all(fn);
  856. return new InnerAsyncArrayParallel(res.flat());
  857. });
  858. }
  859. sort(fn) {
  860. throw new Error('Method not implemented.');
  861. }
  862. reduce(fn, res) {
  863. return __awaiter(this, void 0, void 0, function* () {
  864. for (let i = 0, len = this._arr.length; i < len; i++) {
  865. if (res) {
  866. res = yield fn.call(this, res, this._arr[i], i, this);
  867. }
  868. else {
  869. res = this._arr[i];
  870. }
  871. }
  872. return res;
  873. });
  874. }
  875. reduceRight(fn, res) {
  876. return __awaiter(this, void 0, void 0, function* () {
  877. for (let i = this._arr.length - 1; i >= 0; i--) {
  878. if (res) {
  879. res = yield fn.apply(this, [res, this._arr[i], i, this]);
  880. }
  881. else {
  882. res = this._arr[i];
  883. }
  884. }
  885. return res;
  886. });
  887. }
  888. findIndex(fn) {
  889. return __awaiter(this, void 0, void 0, function* () {
  890. return (yield this._all(fn)).findIndex(returnItself);
  891. });
  892. }
  893. _all(fn) {
  894. return __awaiter(this, void 0, void 0, function* () {
  895. return yield Promise.all(this._arr.map((v, i) => fn.apply(this, [v, i, this])));
  896. });
  897. }
  898. }
  899. /**
  900. * 异步数组
  901. */
  902. class AsyncArray {
  903. /**
  904. * 构造函数
  905. * @param args 任意个参数
  906. */
  907. constructor(...args) {
  908. /**
  909. * 内部数组的长度,用于让 {@link AsyncArray} 的实例能作为 {@link Array.from} 的参数
  910. */
  911. this.length = 0;
  912. this._arr = Array.from(args);
  913. /**
  914. * @field 保存异步任务
  915. * @type {Action[]}
  916. */
  917. this._tasks = [];
  918. }
  919. /**
  920. * 为内置数组赋值
  921. * 此处自动重新计算 length 属性
  922. */
  923. set _arr(arr) {
  924. this.__arr = arr;
  925. this.length = this.__arr.length;
  926. }
  927. get _arr() {
  928. return this.__arr;
  929. }
  930. /**
  931. * 提供一个函数方便根据已有的数组或类数组(Set/Map)创建 {@link AsyncArray}
  932. * @param arr 一个可迭代元素
  933. * @returns 创建一个新的异步数组包装
  934. */
  935. static from(arr) {
  936. const result = new AsyncArray();
  937. if (isNullOrUndefined(arr)) {
  938. return result;
  939. }
  940. result._arr = Array.from(arr);
  941. return result;
  942. }
  943. filter(fn) {
  944. return this._addTask(new Action(Action.Type.filter, [fn]));
  945. }
  946. map(fn) {
  947. return this._addTask(new Action(Action.Type.map, [fn]));
  948. }
  949. flatMap(fn) {
  950. return this._addTask(new Action(Action.Type.flatMap, [fn]));
  951. }
  952. sort(fn) {
  953. return this._addTask(new Action(Action.Type.sort, [fn]));
  954. }
  955. parallel() {
  956. return this._addTask(new Action(Action.Type.parallel, []));
  957. }
  958. serial() {
  959. return this._addTask(new Action(Action.Type.serial, []));
  960. }
  961. forEach(fn) {
  962. return this._addTask(new Action(Action.Type.forEach, [fn])).then();
  963. }
  964. some(fn) {
  965. return this._addTask(new Action(Action.Type.some, [fn])).then();
  966. }
  967. every(fn) {
  968. return this._addTask(new Action(Action.Type.every, [fn])).then();
  969. }
  970. find(fn) {
  971. return this._addTask(new Action(Action.Type.find, [fn])).then();
  972. }
  973. findIndex(fn) {
  974. return this._addTask(new Action(Action.Type.findIndex, [fn])).then();
  975. }
  976. reduce(fn, res) {
  977. return this._addTask(new Action(Action.Type.reduce, [fn, res])).then();
  978. }
  979. reduceRight(fn, res) {
  980. return this._addTask(new Action(Action.Type.reduceRight, [fn, res])).then();
  981. }
  982. /**
  983. * 终结整个链式操作并返回结果,可以使用 await 等待当前实例开始计算
  984. */
  985. then(onfulfilled, onrejected) {
  986. return __awaiter(this, void 0, void 0, function* () {
  987. try {
  988. let asyncArray = new InnerAsyncArray(this._arr);
  989. let result = this._arr;
  990. for (const task of this._tasks) {
  991. asyncArray = yield Reflect.apply(Reflect.get(asyncArray, task.type), asyncArray, task.args);
  992. if (asyncArray instanceof InnerBaseAsyncArray) {
  993. result = asyncArray.value();
  994. }
  995. else {
  996. if (!isNullOrUndefined(onfulfilled)) {
  997. onfulfilled(result);
  998. }
  999. return asyncArray;
  1000. }
  1001. }
  1002. if (!isNullOrUndefined(onfulfilled)) {
  1003. onfulfilled(result);
  1004. }
  1005. return result;
  1006. }
  1007. catch (err) {
  1008. if (!isNullOrUndefined(onrejected)) {
  1009. onrejected(err);
  1010. }
  1011. }
  1012. });
  1013. }
  1014. /**
  1015. * @deprecated 已废弃,请直接使用 await 进行等待获取结果值即可
  1016. */
  1017. value() {
  1018. return this.then();
  1019. }
  1020. /**
  1021. * 允许使用 for-of 遍历内部的 _arr
  1022. */
  1023. *[Symbol.iterator]() {
  1024. for (const kv of this._arr) {
  1025. yield kv;
  1026. }
  1027. }
  1028. _addTask(task) {
  1029. const result = new AsyncArray(...this._arr);
  1030. result._tasks = [...this._tasks, task];
  1031. return result;
  1032. }
  1033. }
  1034.  
  1035. function asyncFlatMap(arr, fn) {
  1036. return __awaiter(this, void 0, void 0, function* () {
  1037. return new AsyncArray(...arr).flatMap(fn);
  1038. });
  1039. }
  1040.  
  1041. /**
  1042. * 判断数字是否在指定区间之中
  1043. * @param num 指定数字
  1044. * @param min 最小值
  1045. * @param max 最大值(不包含)
  1046. */
  1047. function isRange(num, min, max) {
  1048. return num >= min && num < max;
  1049. }
  1050.  
  1051. /**
  1052. * 判断是否为小数的正则表达式
  1053. */
  1054. const FloatRule = /^(-?\d+)(.\d+)?$/;
  1055. /**
  1056. * 判断是否为整数的正则表达式
  1057. */
  1058. const IntegerRule = /^-?\d+$/;
  1059. /**
  1060. * 判断是否为邮箱的正则表达式
  1061. */
  1062. const EmailRule = /^\w+((-\w+)|(\.\w+))*@[A-Za-z0-9]+((\.|-)[A-Za-z0-9]+)*\.[A-Za-z]+$/;
  1063. /**
  1064. * 判断是否为 ipv4 地址的正则表达式
  1065. */
  1066. const Ipv4Rule = /^((25[0-5]|2[0-4]\d|1?\d?\d)\.){3}(25[0-5]|2[0-4]\d|1?\d?\d)$/;
  1067. /**
  1068. * 判断是否为固定电话的正则表达式
  1069. */
  1070. const TelephoneRule = /^0[1-9][0-9]{1,2}-[2-8][0-9]{6,7}$/;
  1071. /**
  1072. * 判断是否为移动电话的正则表达式
  1073. * 注:不在判断二三位的数字,具体参考:http://caibaojian.com/phone-regexp.html
  1074. */
  1075. const MobileRule = /^1\d{10}$/;
  1076. /**
  1077. * 判断是否为域名的正则表达式
  1078. */
  1079. const DomainRule = /^(?=^.{3,255}$)[a-zA-Z0-9][-a-zA-Z0-9]{0,62}(\.[a-zA-Z0-9][-a-zA-Z0-9]{0,62})+$/;
  1080. /**
  1081. * 判断是否为邮政编码的正则表达式
  1082. */
  1083. const PostcodeRule = /^\d{6}$/;
  1084. /**
  1085. * 字符串校验
  1086. * @suppress 之后将会对类型定义进行不兼容修改,避免一直出现的两难问题
  1087. */
  1088. class StringValidator {
  1089. /**
  1090. * 判断一个字符串是否为空字符串
  1091. * @param str 字符串
  1092. * @returns 是否为空字符串
  1093. */
  1094. static isEmpty(str) {
  1095. return isNullOrUndefined(str) || str === '';
  1096. }
  1097. /**
  1098. * 判断一个字符串是否为空白的字符串
  1099. * @param str 字符串
  1100. * @returns 是否为空字符串
  1101. */
  1102. static isBlank(str) {
  1103. return StringValidator.isEmpty(str) || str.trim() === '';
  1104. }
  1105. /**
  1106. * 判断字符串是否位小数
  1107. * @param str 需要进行判断的字符串
  1108. * @returns 是否为小数
  1109. */
  1110. static isFloat(str) {
  1111. if (isNullOrUndefined(str)) {
  1112. return false;
  1113. }
  1114. return FloatRule.test(str);
  1115. }
  1116. /**
  1117. * 判断字符串是否位整数
  1118. * @param str 需要进行判断的字符串
  1119. * @returns 是否为小数
  1120. */
  1121. static isInteger(str) {
  1122. return !isNullOrUndefined(str) && IntegerRule.test(str);
  1123. }
  1124. /**
  1125. * 判断邮箱的格式是否正确
  1126. * @param str 邮箱字符串
  1127. * @returns 是否是邮箱
  1128. */
  1129. static isEmail(str) {
  1130. return !isNullOrUndefined(str) && EmailRule.test(str);
  1131. }
  1132. /**
  1133. * 判断 ipv4 地址的格式是否正确
  1134. * @param str ipv4 字符串
  1135. * @returns 是否是 ipv4 地址
  1136. */
  1137. static isIpv4(str) {
  1138. return !isNullOrUndefined(str) && Ipv4Rule.test(str);
  1139. }
  1140. /**
  1141. * 判断字符串是否为正确的端口号
  1142. * 正确的端口号是 1-65535
  1143. * @param str 字符串
  1144. * @returns 是否为端口号
  1145. */
  1146. static isPort(str) {
  1147. // tslint:disable-next-line:radix
  1148. return StringValidator.isInteger(str) && isRange(parseInt(str), 1, 65535);
  1149. }
  1150. /**
  1151. * 判断是否为固定电话
  1152. * @param str 字符串
  1153. * @returns 是否为固定电话
  1154. */
  1155. static isTelephone(str) {
  1156. return !isNullOrUndefined(str) && TelephoneRule.test(str);
  1157. }
  1158. /**
  1159. * 判断是否为移动电话
  1160. * @param str 字符串
  1161. * @returns 是否为移动电话
  1162. */
  1163. static isMobile(str) {
  1164. return !isNullOrUndefined(str) && MobileRule.test(str);
  1165. }
  1166. /**
  1167. * 判断是否为域名
  1168. * @param str 字符串
  1169. * @returns 是否为域名
  1170. */
  1171. static isDomain(str) {
  1172. return !isNullOrUndefined(str) && DomainRule.test(str);
  1173. }
  1174. /**
  1175. * 判断是否为邮政编码
  1176. * @param str 字符串
  1177. * @returns 是否为邮政编码
  1178. */
  1179. static isPostcode(str) {
  1180. return !isNullOrUndefined(str) && PostcodeRule.test(str);
  1181. }
  1182. }
  1183. /**
  1184. * 导出一个字符串校验的对象
  1185. * @deprecated 已废弃,请直接使用类的静态函数
  1186. */
  1187. const stringValidator = StringValidator;
  1188.  
  1189. /**
  1190. * 可能的类型
  1191. */
  1192. var Type;
  1193. (function (Type) {
  1194. Type[Type["String"] = 0] = "String";
  1195. Type[Type["Number"] = 1] = "Number";
  1196. Type[Type["Boolean"] = 2] = "Boolean";
  1197. Type[Type["Undefined"] = 3] = "Undefined";
  1198. Type[Type["Null"] = 4] = "Null";
  1199. Type[Type["Symbol"] = 5] = "Symbol";
  1200. Type[Type["PropertyKey"] = 6] = "PropertyKey";
  1201. Type[Type["Object"] = 7] = "Object";
  1202. Type[Type["Array"] = 8] = "Array";
  1203. Type[Type["Function"] = 9] = "Function";
  1204. Type[Type["Date"] = 10] = "Date";
  1205. Type[Type["File"] = 11] = "File";
  1206. Type[Type["Blob"] = 12] = "Blob";
  1207. Type[Type["Stream"] = 13] = "Stream";
  1208. Type[Type["ArrayBuffer"] = 14] = "ArrayBuffer";
  1209. Type[Type["ArrayBufferView"] = 15] = "ArrayBufferView";
  1210. Type[Type["URLSearchParams"] = 16] = "URLSearchParams";
  1211. Type[Type["FormData"] = 17] = "FormData";
  1212. })(Type || (Type = {}));
  1213. /**
  1214. * 校验变量的类型
  1215. */
  1216. class TypeValidator {
  1217. /**
  1218. * 获取变量的类型
  1219. * @param val 变量
  1220. * @returns 类型
  1221. * 注: 此函数依赖于 ts 的编译枚举原理与约定 {@link TypeValidator} 中所有判断函数都是以 `is` 开头并于 {@link Type} 中的保持一致
  1222. */
  1223. static getType(val) {
  1224. for (const k of Object.keys(Type)) {
  1225. if (StringValidator.isInteger(k)) {
  1226. const type = Type[k];
  1227. if (TypeValidator['is' + type](val)) {
  1228. return Type[type];
  1229. }
  1230. }
  1231. }
  1232. throw new Error('无法识别的类型');
  1233. }
  1234. /**
  1235. * 判断是否为指定类型
  1236. * @param val 需要判断的值
  1237. * @param types 需要判断的类型
  1238. */
  1239. static isType(val, ...types) {
  1240. return types.includes(TypeValidator.getType(val));
  1241. }
  1242. /**
  1243. * 判断是否为字符串
  1244. * @param val 需要判断的值
  1245. * @returns 是否为字符串
  1246. */
  1247. static isString(val) {
  1248. return typeof val === 'string';
  1249. }
  1250. /**
  1251. * 判断是否为数字
  1252. * @param val 需要判断的值
  1253. * @returns 是否为数字
  1254. */
  1255. static isNumber(val) {
  1256. return typeof val === 'number';
  1257. }
  1258. /**
  1259. * 判断是否为布尔值
  1260. * @param val 需要判断的值
  1261. * @returns 是否为布尔值
  1262. */
  1263. static isBoolean(val) {
  1264. return typeof val === 'boolean';
  1265. }
  1266. /**
  1267. * 判断是否为 Symbol
  1268. * @param val 需要判断的值
  1269. * @returns 是否为 Symbol
  1270. */
  1271. static isSymbol(val) {
  1272. return typeof val === 'symbol';
  1273. }
  1274. /**
  1275. * 判断是否为 undefined
  1276. * @param val 需要判断的值
  1277. * @returns 是否为 undefined
  1278. */
  1279. static isUndefined(val) {
  1280. return val === undefined;
  1281. }
  1282. /**
  1283. * 判断是否为 null
  1284. * @param val 需要判断的值
  1285. * @returns 是否为 null
  1286. */
  1287. static isNull(val) {
  1288. return val === null;
  1289. }
  1290. /**
  1291. * 判断是否可以作为对象的属性
  1292. * @param val 需要判断的值
  1293. * @returns 是否为对象属性
  1294. */
  1295. static isPropertyKey(val) {
  1296. return (TypeValidator.isString(val) ||
  1297. TypeValidator.isNumber(val) ||
  1298. TypeValidator.isSymbol(val));
  1299. }
  1300. /**
  1301. * 判断是否为对象
  1302. * 注: 函数(包括 ES6 箭头函数)将不被视为对象
  1303. * @param val 需要判断的值
  1304. * @returns 是否为对象
  1305. */
  1306. static isObject(val) {
  1307. return (!TypeValidator.isNull(val) &&
  1308. !TypeValidator.isUndefined(val) &&
  1309. typeof val === 'object');
  1310. }
  1311. /**
  1312. * 判断是否为数组
  1313. * @param val 需要判断的值
  1314. * @returns 是否为数组
  1315. */
  1316. static isArray(val) {
  1317. return Array.isArray(val);
  1318. }
  1319. /**
  1320. * 判断是否为数组
  1321. * @param val 需要判断的值
  1322. * @returns 是否为数组
  1323. */
  1324. static isFunction(val) {
  1325. return toString.call(val) === '[object Function]';
  1326. }
  1327. /**
  1328. * 判断是否为日期
  1329. * @param val 需要判断的值
  1330. * @returns 是否为日期
  1331. */
  1332. static isDate(val) {
  1333. return toString.call(val) === '[object Date]';
  1334. }
  1335. /**
  1336. * 判断是否为浏览器文件类型
  1337. * @param val 需要判断的值
  1338. * @returns 是否为浏览器文件类型
  1339. */
  1340. static isFile(val) {
  1341. return toString.call(val) === '[object File]';
  1342. }
  1343. /**
  1344. * 判断是否为浏览器二进制类型
  1345. * @param val 需要判断的值
  1346. * @returns 是否为浏览器二进制类型
  1347. */
  1348. static isBlob(val) {
  1349. return toString.call(val) === '[object Blob]';
  1350. }
  1351. /**
  1352. * 判断是否为浏览器流类型
  1353. * @param val 需要判断的值
  1354. * @returns 是否为浏览器流类型
  1355. */
  1356. static isStream(val) {
  1357. return TypeValidator.isObject(val) && TypeValidator.isFunction(val.pipe);
  1358. }
  1359. /**
  1360. * 判断是否为浏览器 ArrayBuffer 类型
  1361. * @param val 需要判断的值
  1362. * @returns 是否为浏览器 ArrayBuffer 类型
  1363. */
  1364. static isArrayBuffer(val) {
  1365. return toString.call(val) === '[object ArrayBuffer]';
  1366. }
  1367. /**
  1368. * 判断是否为浏览器 ArrayBufferView 类型
  1369. * @param val 需要判断的值
  1370. * @returns 是否为浏览器 ArrayBufferView 类型
  1371. */
  1372. static isArrayBufferView(val) {
  1373. return typeof ArrayBuffer !== 'undefined' && ArrayBuffer.isView
  1374. ? ArrayBuffer.isView(val)
  1375. : val && val.buffer && val.buffer instanceof ArrayBuffer;
  1376. }
  1377. /**
  1378. * 判断是否为浏览器 URLSearchParams 类型
  1379. * @param val 需要判断的值
  1380. * @returns 是否为浏览器 URLSearchParams 类型
  1381. */
  1382. static isURLSearchParams(val) {
  1383. return !TypeValidator.isUndefined(val) && val instanceof URLSearchParams;
  1384. }
  1385. /**
  1386. * 判断是否为浏览器 FormData 类型
  1387. * @param val 需要判断的值
  1388. * @returns 是否为浏览器 FormData 类型
  1389. */
  1390. static isFormData(val) {
  1391. return !TypeValidator.isUndefined(val) && val instanceof FormData;
  1392. }
  1393. }
  1394. /**
  1395. * 类型枚举类对象
  1396. */
  1397. TypeValidator.Type = Type;
  1398.  
  1399. /**
  1400. * 安全执行某个函数
  1401. * 支持异步函数
  1402. * @param fn 需要执行的函数
  1403. * @param defaultVal 发生异常后的默认返回值,默认为 null
  1404. * @param args 可选的函数参数
  1405. * @returns 函数执行的结果,或者其默认值
  1406. */
  1407. function safeExec(fn, defaultVal, ...args) {
  1408. const defRes = (defaultVal === undefined ? null : defaultVal);
  1409. try {
  1410. const res = fn(...args);
  1411. return res instanceof Promise ? res.catch(() => defRes) : res;
  1412. }
  1413. catch (err) {
  1414. return defRes;
  1415. }
  1416. }
  1417.  
  1418. /**
  1419. * 提取对象中的字段并封装为函数
  1420. * @param k 提取的字段,深度获取使用 . 分割不同的字段
  1421. * @returns 获取对象中指定字段的函数
  1422. */
  1423. function extractField(k) {
  1424. const fields = TypeValidator.isString(k) ? k.split('.') : [k];
  1425. return fields.reduceRight((fn, field) => {
  1426. return function (obj) {
  1427. return safeExec(() => fn(Reflect.get(obj, field)));
  1428. };
  1429. }, returnItself);
  1430. }
  1431.  
  1432. /**
  1433. * 获取提取对象属性的函数
  1434. * @param k 提取对象属性的函数或者是属性名(允许使用 . 进行分割)
  1435. * @returns 提取对象属性的函数
  1436. */
  1437. function getKFn(k) {
  1438. return k instanceof Function ? k : extractField(k);
  1439. }
  1440.  
  1441. /**
  1442. * 自行实现 flatMap,将数组压平一层
  1443. * @param arr 数组
  1444. * @param k 映射方法,将一个元素映射为一个数组
  1445. * @returns 压平一层的数组
  1446. */
  1447. function flatMap(arr, k = (v) => Array.from(v)) {
  1448. const fn = getKFn(k);
  1449. return arr.reduce((res, v, i, arr) => {
  1450. res.push(...fn(v, i, arr));
  1451. return res;
  1452. }, new Array());
  1453. }
  1454.  
  1455. function groupBy(arr, k,
  1456. /**
  1457. * 默认的值处理函数
  1458. * @param res 最终 V 集合
  1459. * @param item 当前迭代的元素
  1460. * @returns 将当前元素合并后的最终 V 集合
  1461. */
  1462. vFn = ((res, item) => {
  1463. res.push(item);
  1464. return res;
  1465. }), init = () => []) {
  1466. const kFn = getKFn(k);
  1467. // 将元素按照分组条件进行分组得到一个 条件 -> 数组 的对象
  1468. return arr.reduce((res, item, index, arr) => {
  1469. const k = kFn(item, index, arr);
  1470. // 如果已经有这个键了就直接追加, 否则先将之初始化再追加元素
  1471. if (!res.has(k)) {
  1472. res.set(k, init());
  1473. }
  1474. res.set(k, vFn(res.get(k), item, index, arr));
  1475. return res;
  1476. }, new Map());
  1477. }
  1478.  
  1479. /**
  1480. * 创建一个等差数列数组
  1481. * @param start 开始(包含)
  1482. * @param end 结束(不包含)
  1483. * @param sep 步长,默认为 1
  1484. * @returns 等差数列数组
  1485. */
  1486. function range(start, end, sep = 1) {
  1487. const arr = [];
  1488. for (let i = start; i < end; i += sep) {
  1489. arr.push(i);
  1490. }
  1491. return arr;
  1492. }
  1493.  
  1494. /**
  1495. * 将数组转化为一个 Object 对象
  1496. * @deprecated 已废弃,请使用更好的 {@link arrayToMap} 替代
  1497. * @param arr 需要进行转换的数组
  1498. * @param k 生成对象属性名的函数
  1499. * @param v 生成对象属性值的函数,默认为数组中的迭代元素
  1500. * @returns 转化得到的对象
  1501. */
  1502. function toObject(arr, k, v = returnItself) {
  1503. const kFn = getKFn(k);
  1504. const vFn = getKFn(v);
  1505. return arr.reduce((res, item, i, arr) => {
  1506. const k = kFn(item, i, arr);
  1507. if (!Reflect.has(res, k)) {
  1508. Reflect.set(res, k, vFn(item, i, arr));
  1509. }
  1510. return res;
  1511. }, {});
  1512. }
  1513.  
  1514. /**
  1515. * js 的数组去重方法
  1516. * @param arr 要进行去重的数组
  1517. * @param k 唯一标识元素的方法,默认使用 {@link returnItself}
  1518. * @returns 进行去重操作之后得到的新的数组 (原数组并未改变)
  1519. */
  1520. function uniqueBy(arr, k = returnItself) {
  1521. const kFn = getKFn(k);
  1522. const set = new Set();
  1523. return arr.filter((v, ...args) => {
  1524. const k = kFn(v, ...args);
  1525. if (set.has(k)) {
  1526. return false;
  1527. }
  1528. set.add(k);
  1529. return true;
  1530. });
  1531. }
  1532.  
  1533. /**
  1534. * 将数组映射为 Map
  1535. * @param arr 数组
  1536. * @param k 产生 Map 元素唯一标识的函数,或者对象元素中的一个属性名
  1537. * @param v 产生 Map 值的函数,默认为返回数组的元素,或者对象元素中的一个属性名
  1538. * @returns 映射产生的 map 集合
  1539. */
  1540. function arrayToMap(arr, k, v = returnItself) {
  1541. const kFn = getKFn(k);
  1542. const vFn = getKFn(v);
  1543. return arr.reduce((res, item, index, arr) => res.set(kFn(item, index, arr), vFn(item, index, arr)), new Map());
  1544. }
  1545.  
  1546. /**
  1547. * 日期格式化类
  1548. */
  1549. class DateFormat {
  1550. /**
  1551. * 构造函数
  1552. * @param name 日期格式的名称
  1553. * @param format 日期的格式值
  1554. * @param value 格式化得到的值
  1555. * @param index 需要替换位置的索引
  1556. */
  1557. constructor(name, format, value, index) {
  1558. this.name = name;
  1559. this.format = format;
  1560. this.value = value;
  1561. this.index = index;
  1562. }
  1563. }
  1564. /**
  1565. * 日期时间的正则表达式
  1566. */
  1567. const dateFormats = new Map()
  1568. .set('year', 'Y{4}|Y{2}|y{4}|y{2}')
  1569. .set('month', 'M{1,2}')
  1570. .set('day', 'D{1,2}|d{1,2}')
  1571. .set('hour', 'h{1,2}')
  1572. .set('minute', 'm{1,2}')
  1573. .set('second', 's{1,2}')
  1574. .set('millieSecond', 'S{1,3}');
  1575. /**
  1576. * 如果没有格式化某项的话则设置为默认时间
  1577. */
  1578. const defaultDateValues = new Map()
  1579. .set('month', '01')
  1580. .set('day', '01')
  1581. .set('hour', '00')
  1582. .set('minute', '00')
  1583. .set('second', '00')
  1584. .set('millieSecond', '000');
  1585. /**
  1586. * 月份日期校验
  1587. */
  1588. const monthDayValidate = {
  1589. 1: 31,
  1590. 3: 31,
  1591. 5: 31,
  1592. 7: 31,
  1593. 8: 31,
  1594. 10: 31,
  1595. 12: 31,
  1596. 4: 30,
  1597. 6: 30,
  1598. 9: 30,
  1599. 11: 30,
  1600. 2: 28,
  1601. };
  1602. /**
  1603. * 解析字符串为 Date 对象
  1604. * @param str 日期字符串
  1605. * @param fmt 日期字符串的格式,目前仅支持使用 y(年),M(月),d(日),h(时),m(分),s(秒),S(毫秒)
  1606. * @returns 解析得到的 Date 对象
  1607. */
  1608. function dateParse(str, fmt) {
  1609. const now = new Date();
  1610. defaultDateValues.set('year', now.getFullYear().toString());
  1611. // 保存对传入的日期字符串进行格式化的全部信息数组列表
  1612. const dateUnits = [];
  1613. for (const [fmtName, regex] of dateFormats) {
  1614. const regExp = new RegExp(regex);
  1615. if (regExp.test(fmt)) {
  1616. const matchStr = regExp.exec(fmt)[0];
  1617. const regexStr = '`'.repeat(matchStr.length);
  1618. const index = fmt.indexOf(matchStr);
  1619. fmt = fmt.replace(matchStr, regexStr);
  1620. dateUnits.push(new DateFormat(fmtName, '\\d'.repeat(matchStr.length), null, index));
  1621. }
  1622. else {
  1623. dateUnits.push(new DateFormat(fmtName, null, defaultDateValues.get(fmtName), -1));
  1624. }
  1625. }
  1626. // 进行验证是否真的是符合传入格式的字符串
  1627. fmt = fmt.replace(new RegExp('`', 'g'), '\\d');
  1628. if (!new RegExp(`^${fmt}$`).test(str)) {
  1629. return null;
  1630. }
  1631. // 进行一次排序, 依次对字符串进行截取
  1632. dateUnits
  1633. // 过滤掉没有得到格式化的对象
  1634. .filter(({ format }) => format)
  1635. // 按照字符串中日期片段的索引进行排序
  1636. .sort(function (a, b) {
  1637. return a.index - b.index;
  1638. })
  1639. // 获取到匹配的日期片段的值
  1640. .map(format => {
  1641. const matchDateUnit = new RegExp(format.format).exec(str);
  1642. if (matchDateUnit !== null && matchDateUnit.length > 0) {
  1643. str = str.replace(matchDateUnit[0], '');
  1644. format.value = matchDateUnit[0];
  1645. }
  1646. return format;
  1647. })
  1648. // 覆写到 dateStr 上面
  1649. .forEach(({ format }, i) => {
  1650. const matchDateUnit = new RegExp(format).exec(str);
  1651. if (matchDateUnit !== null && matchDateUnit.length > 0) {
  1652. str = str.replace(matchDateUnit[0], '');
  1653. dateUnits[i].value = matchDateUnit[0];
  1654. }
  1655. });
  1656. // 将截取完成的信息封装成对象并格式化标准的日期字符串
  1657. const map = arrayToMap(dateUnits, item => item.name, item => item.value);
  1658. if (map.get('year').length === 2) {
  1659. map.set('year', defaultDateValues
  1660. .get('year')
  1661. .substr(0, 2)
  1662. .concat(map.get('year')));
  1663. }
  1664. // 注意:此处使用的是本地时间而非 UTC 时间
  1665. const get = (unit) => parseInt(map.get(unit));
  1666. const year = get('year');
  1667. const month = get('month');
  1668. const day = get('day');
  1669. const hour = get('hour');
  1670. const minute = get('minute');
  1671. const second = get('second');
  1672. const millieSecond = get('millieSecond');
  1673. if (!isRange(month, 1, 12 + 1)) {
  1674. return null;
  1675. }
  1676. if (!isRange(day, 1, Reflect.get(monthDayValidate, month) +
  1677. (month === 2 && year % 4 === 0 ? 1 : 0) +
  1678. 1)) {
  1679. return null;
  1680. }
  1681. if (!isRange(hour, 0, 24 + 1) ||
  1682. !isRange(minute, 0, 60 + 1) ||
  1683. !isRange(second, 0, 60 + 1) ||
  1684. !isRange(millieSecond, 0, 999 + 1)) {
  1685. return null;
  1686. }
  1687. return new Date(year, month - 1, day, hour, minute, second, millieSecond);
  1688. }
  1689.  
  1690. /**
  1691. * 解析字符串为 Date 对象
  1692. * @deprecated 已弃用,请使用可读性更好的 {@link dateParse} 代替
  1693. * @param dateStr 日期字符串
  1694. * @param fmt 日期字符串的格式
  1695. * 目前仅支持使用 y(年),M(月),d(日),h(时),m(分),s(秒),S(毫秒)
  1696. * @returns 解析得到的 Date 对象
  1697. */
  1698. function strToDate(dateStr, fmt) {
  1699. return dateParse(dateStr, fmt);
  1700. }
  1701.  
  1702. /**
  1703. * 复制一段文本内容
  1704. * @param text 要进行复制的文本
  1705. * @returns 是否复制成功
  1706. */
  1707. function copyText(text) {
  1708. const $el = document.createElement('textarea');
  1709. $el.style.position = 'fixed';
  1710. $el.style.top = '-1000px';
  1711. document.body.appendChild($el);
  1712. $el.value = text;
  1713. $el.select();
  1714. const res = document.execCommand('copy');
  1715. document.body.removeChild($el);
  1716. return res;
  1717. }
  1718.  
  1719. /**
  1720. * 根据 html 字符串创建 Element 元素
  1721. * @param str html 字符串
  1722. * @returns 创建的 Element 元素
  1723. */
  1724. function createElByString(str) {
  1725. const root = document.createElement('div');
  1726. root.innerHTML = str;
  1727. return root.querySelector('*');
  1728. }
  1729.  
  1730. /**
  1731. * 获取输入框中光标所在位置
  1732. * @param {HTMLFormElement} el 需要获取的输入框元素
  1733. * @returns 光标所在位置的下标
  1734. */
  1735. function getCursorPosition(el) {
  1736. return el.selectionStart;
  1737. }
  1738.  
  1739. /**
  1740. * 获取输入框中光标所在位置
  1741. * @param {HTMLFormElement} el 需要获取的输入框元素
  1742. * @returns 光标所在位置的下标
  1743. * @deprecated 已废弃,请使用正确更名后的 {@link getCursorPosition} 函数
  1744. */
  1745. function getCusorPostion(el) {
  1746. return getCursorPosition(el);
  1747. }
  1748.  
  1749. /**
  1750. * 设置输入框中选中的文本/光标所在位置
  1751. * @param el 需要设置的输入框元素
  1752. * @param start 光标所在位置的下标
  1753. * @param end 结束位置,默认为输入框结束
  1754. */
  1755. function setCursorPosition(el, start, end = start) {
  1756. el.focus();
  1757. el.setSelectionRange(start, end);
  1758. }
  1759.  
  1760. /**
  1761. * 在指定位置后插入文本
  1762. * @param el 需要设置的输入框元素
  1763. * @param text 要插入的值
  1764. * @param start 开始位置,默认为当前光标处
  1765. */
  1766. function insertText(el, text, start = getCursorPosition(el)) {
  1767. const value = el.value;
  1768. el.value = value.substr(0, start) + text + value.substr(start);
  1769. setCursorPosition(el, start + text.length);
  1770. }
  1771.  
  1772. /**
  1773. * 字符串安全的转换为小写
  1774. * @param str 字符串
  1775. * @returns 转换后得到的全小写字符串
  1776. */
  1777. function toLowerCase(str) {
  1778. if (isNullOrUndefined(str) || typeof str !== 'string') {
  1779. return str;
  1780. }
  1781. return str.toLowerCase();
  1782. }
  1783.  
  1784. /**
  1785. * 判断指定元素是否是可编辑元素
  1786. * 注:可编辑元素并不一定能够进行编辑,例如只读的 input 元素
  1787. * @param el 需要进行判断的元素
  1788. * @returns 是否为可编辑元素
  1789. */
  1790. function isEditable(el) {
  1791. const inputEls = ['input', 'date', 'datetime', 'select', 'textarea'];
  1792. return (
  1793. // 此处需要判断是否存在属性 isContentEditable
  1794. // @ts-ignore
  1795. el && (el.isContentEditable || inputEls.includes(toLowerCase(el.tagName))));
  1796. }
  1797.  
  1798. let lastFocusEl;
  1799. /**
  1800. * 获取到最后一个获得焦点的元素
  1801. * @returns 最后一个获取到焦点的元素
  1802. */
  1803. function _lastFocus() {
  1804. return lastFocusEl;
  1805. }
  1806. const lastFocus = Object.assign(_lastFocus, {
  1807. init() {
  1808. document.addEventListener('focus', event => {
  1809. lastFocusEl = event.target;
  1810. }, true);
  1811. document.addEventListener('blur', () => {
  1812. lastFocusEl = null;
  1813. }, true);
  1814. },
  1815. });
  1816.  
  1817. /**
  1818. * 直接删除指定元素
  1819. * @param el 需要删除的元素
  1820. * @returns 返回被删除的元素
  1821. */
  1822. function removeEl(el) {
  1823. const parent = el.parentElement;
  1824. if (parent == null) {
  1825. return null;
  1826. }
  1827. return parent.removeChild(el);
  1828. }
  1829.  
  1830. /**
  1831. * 在指定范围内删除文本
  1832. * @param el 需要设置的输入框元素
  1833. * @param start 开始位置,默认为当前选中开始位置
  1834. * @param end 结束位置,默认为当前选中结束位置
  1835. */
  1836. function removeText(el, start = el.selectionStart, end = el.selectionEnd) {
  1837. // 删除之前必须要 [记住] 当前光标的位置
  1838. const index = getCursorPosition(el);
  1839. const value = el.value;
  1840. el.value = value.substr(0, start) + value.substr(end, value.length);
  1841. setCursorPosition(el, index);
  1842. }
  1843.  
  1844. /**
  1845. * 设置输入框中选中的文本/光标所在位置
  1846. * @param el 需要设置的输入框元素
  1847. * @param start 光标所在位置的下标
  1848. * @param end 结束位置,默认为输入框结束
  1849. * @deprecated 已废弃,请使用正确更名后的 {@link setCursorPosition} 函数
  1850. */
  1851. function setCusorPostion(el, start, end = start) {
  1852. return setCursorPosition(el, start, end);
  1853. }
  1854.  
  1855. /**
  1856. * 监听 event 的添加/删除,使 DOM 事件是可撤销的
  1857. * 注:必须及早运行,否则无法监听之前添加的事件
  1858. * @deprecated 实际上 {@link EventUtil} 已经更好的实现了这个功能,如果需要则直接修改原型即可,无需使用该函数
  1859. */
  1860. function watchEventListener() {
  1861. /**
  1862. * 用来保存监听到的事件信息
  1863. */
  1864. class Event {
  1865. constructor(el, type, listener, useCapture) {
  1866. this.el = el;
  1867. this.type = type;
  1868. this.listener = listener;
  1869. this.useCapture = useCapture;
  1870. }
  1871. }
  1872. /**
  1873. * 监听所有的 addEventListener, removeEventListener 事件
  1874. */
  1875. const documentAddEventListener = document.addEventListener;
  1876. const eventTargetAddEventListener = EventTarget.prototype.addEventListener;
  1877. const documentRemoveEventListener = document.removeEventListener;
  1878. const eventTargetRemoveEventListener = EventTarget.prototype.removeEventListener;
  1879. const events = [];
  1880. /**
  1881. * 自定义的添加事件监听函数
  1882. * @param type 事件类型
  1883. * @param listener 事件监听函数
  1884. * @param [useCapture] 是否需要捕获事件冒泡,默认为 false
  1885. */
  1886. function addEventListener(type, listener, useCapture = false) {
  1887. const $addEventListener =
  1888. // @ts-ignore
  1889. this === document ? documentAddEventListener : eventTargetAddEventListener;
  1890. // @ts-ignore
  1891. events.push(new Event(this, type, listener, useCapture));
  1892. // @ts-ignore
  1893. $addEventListener.apply(this, arguments);
  1894. }
  1895. /**
  1896. * 自定义的根据类型删除事件函数
  1897. * 该方法会删除这个类型下面全部的监听函数,不管数量
  1898. * @param type 事件类型
  1899. */
  1900. function removeEventListenerByType(type) {
  1901. const $removeEventListener =
  1902. // @ts-ignore
  1903. this === document
  1904. ? documentRemoveEventListener
  1905. : eventTargetRemoveEventListener;
  1906. const removeIndexList = events
  1907. // @ts-ignore
  1908. .map((e, i) => (e.el === this || e.type === arguments[0] ? i : -1))
  1909. .filter(i => i !== -1);
  1910. removeIndexList.forEach(i => {
  1911. const e = events[i];
  1912. $removeEventListener.apply(e.el, [e.type, e.listener, e.useCapture]);
  1913. });
  1914. removeIndexList.sort((a, b) => b - a).forEach(i => events.splice(i, 1));
  1915. }
  1916. document.addEventListener = EventTarget.prototype.addEventListener = addEventListener;
  1917. // @ts-ignore
  1918. document.removeEventListenerByType = EventTarget.prototype.removeEventListenerByType = removeEventListenerByType;
  1919. }
  1920.  
  1921. /**
  1922. * 将任意对象转换为 String
  1923. * 主要避免原生 Object toString 遇到某些空值的时候抛异常的问题
  1924. * @param object 任意对象
  1925. * @returns 字符串
  1926. */
  1927. function toString$1(object) {
  1928. if (isNullOrUndefined(object)) {
  1929. return '';
  1930. }
  1931. if (object instanceof Date) {
  1932. return object.toISOString();
  1933. }
  1934. return object.toString();
  1935. }
  1936.  
  1937. /**
  1938. * FormData 批量添加方法
  1939. * 注:该方法不会覆盖掉原本的属性
  1940. * @param fd FormData 对象
  1941. * @param obj 键值对对象
  1942. * @returns 添加完成后的 FormData 对象
  1943. */
  1944. function appends(fd, obj) {
  1945. for (const k in obj) {
  1946. const v = obj[k];
  1947. fd.append(k, toString$1(v));
  1948. }
  1949. return fd;
  1950. }
  1951.  
  1952. /**
  1953. * FormData 批量删除方法
  1954. * @param fd FormData 对象
  1955. * @param keys 删除的 key 列表
  1956. * @returns 返回删除后的 FormData 对象
  1957. */
  1958. function deletes(fd, keys) {
  1959. keys.forEach(key => fd.delete(key));
  1960. return fd;
  1961. }
  1962.  
  1963. /**
  1964. * FormData 批量设置方法
  1965. * 注:该方法会覆盖掉原本的属性
  1966. * @param fd 表单对象
  1967. * @param obj 键值对对象
  1968. * @returns 设置完成后的 FormData 对象
  1969. */
  1970. function sets(fd, obj) {
  1971. for (const k in obj) {
  1972. fd.set(k, obj[k]);
  1973. }
  1974. return fd;
  1975. }
  1976.  
  1977. /**
  1978. * FormData 转换为包含所有键值数组的二维数组函数
  1979. *
  1980. * @param fd 需要转换的 FormData 对象
  1981. * @returns 转换后的数组
  1982. * @deprecated 已被原生函数 Array.from 取代
  1983. */
  1984. function formDataToArray(fd) {
  1985. // @ts-ignore
  1986. return Array.from(fd);
  1987. }
  1988.  
  1989. /**
  1990. * 将参数对象转换为 FormData,只转换一层
  1991. * @param data 参数对象
  1992. * @return {FormData} 转换后的表单对象
  1993. */
  1994. function objToFormData(data) {
  1995. return Object.entries(data).reduce((res, [k, v]) => {
  1996. if (v instanceof Blob) {
  1997. res.append(k, v);
  1998. }
  1999. else {
  2000. res.append(k, v && v.toString());
  2001. }
  2002. return res;
  2003. }, new FormData());
  2004. }
  2005.  
  2006. /**
  2007. * 函数去抖
  2008. * 去抖 (debounce) 去抖就是对于一定时间段的连续的函数调用,只让其执行一次
  2009. * 注: 包装后的函数如果两次操作间隔小于 delay 则不会被执行, 如果一直在操作就会一直不执行, 直到操作停止的时间大于 delay 最小间隔时间才会执行一次, 不管任何时间调用都需要停止操作等待最小延迟时间
  2010. * 应用场景主要在那些连续的操作, 例如页面滚动监听, 包装后的函数只会执行最后一次
  2011. * 注: 该函数第一次调用一定不会执行,第一次一定拿不到缓存值,后面的连续调用都会拿到上一次的缓存值。如果需要在第一次调用获取到的缓存值,则需要传入第三个参数 {@param init},默认为 {@code undefined} 的可选参数
  2012. * 注: 返回函数结果的高阶函数需要使用 {@see Proxy} 实现,以避免原函数原型链上的信息丢失
  2013. *
  2014. * @param delay 最小延迟时间,单位为 ms
  2015. * @param action 真正需要执行的操作
  2016. * @param init 初始的缓存值,不填默认为 {@see undefined}
  2017. * @return 包装后有去抖功能的函数。该函数是异步的,与需要包装的函数 {@see action} 是否异步没有太大关联
  2018. */
  2019. function debounce(delay, action, init = null) {
  2020. let flag;
  2021. let result = init;
  2022. return new Proxy(action, {
  2023. apply(_, _this, args) {
  2024. return new Promise(resolve => {
  2025. if (flag)
  2026. clearTimeout(flag);
  2027. flag = setTimeout(() => resolve((result = Reflect.apply(_, _this, args))), delay);
  2028. setTimeout(() => resolve(result), delay);
  2029. });
  2030. },
  2031. });
  2032. }
  2033.  
  2034. /**
  2035. * 使用 Proxy 实现通用的单例模式
  2036. * @param clazz 需要包装为单例的类型
  2037. * @returns 包装后的单例模式类,使用 {@code new} 创建将只在第一次有效
  2038. */
  2039. function singleModel(clazz) {
  2040. let instance;
  2041. return new Proxy(clazz, {
  2042. construct(target, args, newTarget) {
  2043. if (instance === undefined) {
  2044. instance = Reflect.construct(target, args, newTarget);
  2045. }
  2046. return instance;
  2047. },
  2048. });
  2049. }
  2050.  
  2051. /**
  2052. * 状态机
  2053. * 用于避免使用 if-else 的一种方式
  2054. * @typeparam K 状态的类型,默认为 any
  2055. * @typeparam V 构造函数返回值的类型,一般为实现子类的基类,默认为 any
  2056. * @deprecated 该类将在下个大版本进行重构,使用函数而非类作为基本单元
  2057. */
  2058. class StateMachine {
  2059. constructor() {
  2060. this.classMap = new Map();
  2061. }
  2062. /**
  2063. * 获取到一个状态工厂
  2064. * @deprecated 已废弃,请直接创建一个 StateMachine 实例
  2065. */
  2066. static getFactory() {
  2067. /**
  2068. * 状态注册器
  2069. * 更好的有限状态机,分离子类与构建的关系,无论子类如何增删该都不影响基类及工厂类
  2070. */
  2071. return new StateMachine();
  2072. }
  2073. /**
  2074. * 注册一个 class,创建子类时调用,用于记录每一个 [状态 => 子类] 对应
  2075. * 注: 此处不再默认使用单例模式,如果需要,请自行对 class 进行包装
  2076. * @param state 作为键的状态
  2077. * @param clazz 对应的子类型
  2078. * @returns 返回 clazz 本身
  2079. */
  2080. register(state, clazz) {
  2081. this.classMap.set(state, clazz);
  2082. return clazz;
  2083. }
  2084. /**
  2085. * 获取一个标签子类对象
  2086. * @param state 状态索引
  2087. * @param args 构造函数的参数
  2088. * @returns 子类对象
  2089. */
  2090. getInstance(state, ...args) {
  2091. const Class = this.classMap.get(state);
  2092. if (!Class) {
  2093. return null;
  2094. }
  2095. // 构造函数的参数
  2096. return new Class(...args);
  2097. }
  2098. /**
  2099. * 允许使用 for-of 遍历整个状态机
  2100. */
  2101. *[Symbol.iterator]() {
  2102. for (const kv of this.classMap.entries()) {
  2103. yield kv;
  2104. }
  2105. }
  2106. }
  2107.  
  2108. /**
  2109. * 函数节流
  2110. * 节流 (throttle) 让一个函数不要执行的太频繁,减少执行过快的调用,叫节流
  2111. * 类似于上面而又不同于上面的函数去抖, 包装后函数在上一次操作执行过去了最小间隔时间后会直接执行, 否则会忽略该次操作
  2112. * 与上面函数去抖的明显区别在连续操作时会按照最小间隔时间循环执行操作, 而非仅执行最后一次操作
  2113. * 注: 该函数第一次调用一定会执行,不需要担心第一次拿不到缓存值,后面的连续调用都会拿到上一次的缓存值
  2114. * 注: 返回函数结果的高阶函数需要使用 {@see Proxy} 实现,以避免原函数原型链上的信息丢失
  2115. *
  2116. * @param delay 最小间隔时间,单位为 ms
  2117. * @param action 真正需要执行的操作
  2118. * @return {Function} 包装后有节流功能的函数。该函数是异步的,与需要包装的函数 {@link action} 是否异步没有太大关联
  2119. */
  2120. function throttle(delay, action) {
  2121. let last = 0;
  2122. let result;
  2123. return new Proxy(action, {
  2124. apply(target, thisArg, args) {
  2125. return new Promise(resolve => {
  2126. const curr = Date.now();
  2127. if (curr - last > delay) {
  2128. result = Reflect.apply(target, thisArg, args);
  2129. last = curr;
  2130. resolve(result);
  2131. return;
  2132. }
  2133. resolve(result);
  2134. });
  2135. },
  2136. });
  2137. }
  2138.  
  2139. /**
  2140. * 测试函数的执行时间
  2141. * 注:如果函数返回 Promise,则该函数也会返回 Promise,否则直接返回执行时间
  2142. * @param fn 需要测试的函数
  2143. * @returns 执行的毫秒数
  2144. */
  2145. function timing(fn) {
  2146. const begin = performance.now();
  2147. const res = fn();
  2148. return compatibleAsync(res, () => performance.now() - begin);
  2149. }
  2150.  
  2151. /**
  2152. * 轮询等待指定资源加载完毕再执行操作
  2153. * 使用 Promises 实现,可以使用 ES7 的 {@see async} 和 {@see await} 调用
  2154. * @param fn 判断必须的资源是否存在的方法
  2155. * @param option 可配置项
  2156. * @returns Promise 对象
  2157. */
  2158. function waitResource(fn, { interval = 100, max = 10 } = {}) {
  2159. let current = 0;
  2160. return new Promise((resolve, reject) => {
  2161. const timer = setInterval(() => {
  2162. if (fn()) {
  2163. clearInterval(timer);
  2164. resolve();
  2165. }
  2166. current++;
  2167. if (current >= max) {
  2168. clearInterval(timer);
  2169. reject(new Error('waitResource call timeout'));
  2170. }
  2171. }, interval);
  2172. });
  2173. }
  2174.  
  2175. /**
  2176. * 监视指定函数返回值的变化
  2177. * @param fn 需要监视的函数
  2178. * @param callback 回调函数
  2179. * @param interval 每次检查的间隔时间,默认为 100ms
  2180. * @returns 关闭这个监视函数
  2181. */
  2182. function watch(fn, callback, interval = 100) {
  2183. let oldVal = fn();
  2184. const timer = setInterval(() => {
  2185. const newVal = fn();
  2186. if (oldVal !== newVal) {
  2187. callback(newVal, oldVal);
  2188. oldVal = newVal;
  2189. }
  2190. }, interval);
  2191. return () => clearInterval(timer);
  2192. }
  2193.  
  2194. /**
  2195. * 深度监听指定对象属性的变化
  2196. * 注:指定对象不能是原始类型,即不可变类型,而且对象本身的引用不能改变,最好使用 const 进行声明
  2197. * @param object 需要监视的对象
  2198. * @param callback 当代理对象发生改变时的回调函数,回调函数有三个参数,分别是对象,修改的 key,修改的 v
  2199. * @returns 返回源对象的一个代理
  2200. */
  2201. function watchObject(object, callback) {
  2202. const handler = {
  2203. get(target, k) {
  2204. try {
  2205. // 注意: 这里很关键,它为对象的字段也添加了代理
  2206. return new Proxy(Reflect.get(target, k), handler);
  2207. }
  2208. catch (err) {
  2209. return Reflect.get(target, k);
  2210. }
  2211. },
  2212. set(target, k, v) {
  2213. callback(target, k, v);
  2214. return Reflect.set(target, k, v);
  2215. },
  2216. };
  2217. return new Proxy(object, handler);
  2218. }
  2219.  
  2220. /**
  2221. * 填充字符串到指定长度
  2222. * @param item 填充的字符串
  2223. * @param len 填充的长度
  2224. * @returns 填充完成的字符串
  2225. * @deprecated 已废弃,请使用 ES6 {@link String.prototype.repeat} 函数
  2226. * 具体请参考 MDN {@url(https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/Global_Objects/String/repeat)}
  2227. */
  2228. function fill(item, len) {
  2229. if (len <= 0) {
  2230. return '';
  2231. }
  2232. return item + fill(item, len - 1);
  2233. }
  2234.  
  2235. /**
  2236. * 字符串格式化
  2237. *
  2238. * @param str 要进行格式化的值
  2239. * @param args 格式化参数值,替换字符串中的 {} 的值
  2240. * @returns 替换完成的字符串
  2241. * @deprecated 已废弃,请使用 ES6 模板字符串 {@url(https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/template_strings)}
  2242. */
  2243. function format(str, args) {
  2244. return Object.keys(args).reduce((res, k) => res.replace(new RegExp(`{${k}}`, 'g'), toString$1(args[k])), str);
  2245. }
  2246.  
  2247. /**
  2248. * 判断字符串是否位小数
  2249. * @param str 需要进行判断的字符串
  2250. * @returns 是否为小数
  2251. * @deprecated 已废弃,请使用 {@link stringValidator#isFloat}
  2252. */
  2253. function isFloat(str) {
  2254. return stringValidator.isFloat(str);
  2255. }
  2256.  
  2257. /**
  2258. * 判断字符串是否位整数
  2259. * @param str 需要进行判断的字符串
  2260. * @returns 是否为小数
  2261. * @deprecated 已废弃,请使用 {@link stringValidator#isInteger}
  2262. */
  2263. function isNumber(str) {
  2264. return stringValidator.isInteger(str);
  2265. }
  2266.  
  2267. /**
  2268. * 字符串安全的转换为大写
  2269. * @param str 字符串
  2270. * @returns 转换后得到的全大写字符串
  2271. */
  2272. function toUpperCase(str) {
  2273. if (isNullOrUndefined(str) || typeof str !== 'string') {
  2274. return str;
  2275. }
  2276. return str.toUpperCase();
  2277. }
  2278.  
  2279. /**
  2280. * 将空白字符串转换为 null
  2281. *
  2282. * @param str 将空字符串转换为 {@code null}
  2283. * @returns 可能为 {@code null}
  2284. */
  2285. function blankToNull(str) {
  2286. return StringValidator.isBlank(str) ? null : str;
  2287. }
  2288.  
  2289. /**
  2290. * 置空对象所有空白的属性
  2291. * @param obj 对象
  2292. * @returns 将所有的空白属性全部转换为 null 的新对象
  2293. */
  2294. function blankToNullField(obj) {
  2295. return Object.keys(obj).reduce((res, k) => {
  2296. const v = Reflect.get(obj, k);
  2297. Reflect.set(res, k, typeof v === 'string' ? blankToNull(v) : v);
  2298. return res;
  2299. }, {});
  2300. }
  2301.  
  2302. /**
  2303. * 将对象的所有属性置空
  2304. * @param obj 需要置空属性的对象
  2305. * @returns 返回一个新的对象
  2306. */
  2307. function emptyAllField(obj) {
  2308. return Object.keys(obj).reduce((res, k) => {
  2309. Reflect.set(res, k, null);
  2310. return res;
  2311. }, {});
  2312. }
  2313.  
  2314. /**
  2315. * 排除对象中的指定字段
  2316. * 注: 此处将获得一个浅拷贝对象
  2317. * @param obj 排除对象
  2318. * @param fields 要排除的多个字段
  2319. * @returns 排除完指定字段得到的新的对象
  2320. */
  2321. function excludeFields(obj, ...fields) {
  2322. const set = new Set(fields);
  2323. return Object.keys(obj).reduce((res, k) => {
  2324. if (!set.has(k)) {
  2325. Reflect.set(res, k, Reflect.get(obj, k));
  2326. }
  2327. return res;
  2328. }, {});
  2329. }
  2330.  
  2331. /**
  2332. * 将 Map 转换为 Object 对象
  2333. * @param map Map 键值表
  2334. * @returns 转换得到的 Object 对象
  2335. */
  2336. function mapToObject(map) {
  2337. const res = {};
  2338. for (const [k, v] of map) {
  2339. Reflect.set(res, k, v);
  2340. }
  2341. return res;
  2342. }
  2343.  
  2344. function randomInt(num1, num2) {
  2345. const min = num2 ? num1 : 0;
  2346. const max = num2 ? num2 : num1;
  2347. if (max <= 0) {
  2348. throw new Error('最大值不能为 0');
  2349. }
  2350. return min + Math.floor(Math.random() * (max - min));
  2351. }
  2352.  
  2353. /**
  2354. * 计算月有多少天
  2355. * @param date 日期
  2356. * @returns 月的总天数
  2357. */
  2358. function calcMonEndDay(date) {
  2359. const monthToDay = [
  2360. [new Set([1, 3, 5, 7, 8, 10, 12]), 30],
  2361. [new Set([4, 6, 9, 11]), 30],
  2362. [new Set([2]), 28],
  2363. ];
  2364. const year = date.getFullYear();
  2365. const month = date.getMonth() + 1;
  2366. const days = monthToDay.find(([monthSet]) => monthSet.has(month))[1];
  2367. return days + (month === 2 && year % 4 === 0 ? 1 : 0);
  2368. }
  2369. /**
  2370. * 日期固定时间点
  2371. */
  2372. class DateConstants {
  2373. /**
  2374. * 获取指定日期一天的开始时间
  2375. * @param date 指定的时间,默认为当前日期
  2376. * @returns 一天的开始时间
  2377. */
  2378. static dayStart(date = new Date()) {
  2379. return new Date(`${dateFormat(date, 'yyyy-MM-dd')}T00:00:00.000`);
  2380. }
  2381. /**
  2382. * 获取指定日期一天的结束时间
  2383. * @param date 指定的时间,默认为当前日期
  2384. * @returns 一天的结束时间
  2385. */
  2386. static dayEnd(date = new Date()) {
  2387. return new Date(`${dateFormat(date, 'yyyy-MM-dd')}T23:59:59.999`);
  2388. }
  2389. /**
  2390. * 获取指定日期所在月的开始时间
  2391. * @param date 指定的时间,默认为当前日期
  2392. * @returns 月的开始时间
  2393. */
  2394. static monthStart(date = new Date()) {
  2395. return new Date(`${dateFormat(date, 'yyyy-MM')}-01T00:00:00.000`);
  2396. }
  2397. /**
  2398. * 获取指定日期所在月的结束时间
  2399. * @param date 指定的时间,默认为当前日期
  2400. * @returns 月的结束时间
  2401. */
  2402. static monthEnd(date = new Date()) {
  2403. return new Date(`${dateFormat(date, 'yyyy-MM')}-${calcMonEndDay(date)}T23:59:59.999`);
  2404. }
  2405. /**
  2406. * 获取指定日期所在年份的新年开始时间
  2407. * @param date 指定的时间,默认为当前日期
  2408. * @returns 新年开始时间
  2409. */
  2410. static yearStart(date = new Date()) {
  2411. return new Date(`${date.getFullYear()}-01-01T00:00:00.000`);
  2412. }
  2413. /**
  2414. * 获取指定日期所在年份的旧年结束时间
  2415. * @param date 指定的时间,默认为当前日期
  2416. * @returns 旧年结束时间
  2417. */
  2418. static yearEnd(date = new Date()) {
  2419. return new Date(`${date.getFullYear()}-12-31T23:59:59.999`);
  2420. }
  2421. }
  2422. /**
  2423. * 导出一个日期固定时间点的对象
  2424. * @deprecated 已废弃,请直接使用类的静态函数
  2425. */
  2426. const dateConstants = DateConstants;
  2427.  
  2428. /**
  2429. * 一天标准的毫秒数
  2430. */
  2431. const DAY_UNIT_TIME = 1000 * 60 * 60 * 24;
  2432. /**
  2433. * 日期增强
  2434. */
  2435. class DateEnhance {
  2436. /**
  2437. * 构造函数
  2438. * @param date 要增强的日期
  2439. */
  2440. constructor(date) {
  2441. this.date = date;
  2442. }
  2443. /**
  2444. * 获取到年份
  2445. * @returns
  2446. */
  2447. year() {
  2448. return this.date.getFullYear();
  2449. }
  2450. /**
  2451. * 获取月份
  2452. * @returns
  2453. * @deprecated 已废弃,请使用 {@link this#monthOfYear} 函数
  2454. */
  2455. month() {
  2456. return this.date.getMonth();
  2457. }
  2458. /**
  2459. * 获取今年的第几个月份
  2460. * 和 {@link this#month} 不同的是不再从 0 计算月份
  2461. */
  2462. monthOfYear() {
  2463. return this.date.getMonth() + 1;
  2464. }
  2465. /**
  2466. * 获取一年内的第多少天
  2467. * 注: 这个天数指定的在第几天而非过去了多少天,例如 2018-01-10 的结果会是 10
  2468. * @returns
  2469. */
  2470. dayOfYear() {
  2471. return Math.ceil((this.date.getTime() - dateConstants.yearStart(this.date).getTime()) /
  2472. DAY_UNIT_TIME);
  2473. }
  2474. /**
  2475. * 获取一个月内的第多少天
  2476. * 注: 这个天数指的是在第几天而非过去了多少天,例如 2018-01-10 的结果会是 10
  2477. * @returns
  2478. */
  2479. dayOfMonth() {
  2480. return this.date.getDate();
  2481. }
  2482. /**
  2483. * 获取一个星期内的第多少天
  2484. * @returns
  2485. */
  2486. dayOfWeek() {
  2487. return this.date.getDay();
  2488. }
  2489. /**
  2490. * 获取一年内的第多少星期
  2491. * 注: 这个星期指定的在第几天而非过去了多少天,例如 2018-01-10 的结果会是 10
  2492. * @returns
  2493. */
  2494. weekOfYear() {
  2495. return Math.ceil(this.dayOfYear() / 7);
  2496. }
  2497. /**
  2498. * 获取一个月内的第多少星期
  2499. * @returns
  2500. */
  2501. weekOfMonth() {
  2502. return Math.ceil(this.dayOfMonth() / 7);
  2503. }
  2504. /**
  2505. * 获取季度
  2506. * @returns
  2507. */
  2508. quarter() {
  2509. const month = this.month();
  2510. if (isRange(month, 0, 3)) {
  2511. return 1;
  2512. }
  2513. else if (isRange(month, 3, 6)) {
  2514. return 2;
  2515. }
  2516. else if (isRange(month, 6, 9)) {
  2517. return 3;
  2518. }
  2519. else {
  2520. return 4;
  2521. }
  2522. }
  2523. /**
  2524. * 获取小时
  2525. * @returns
  2526. */
  2527. hour() {
  2528. return this.date.getHours();
  2529. }
  2530. /**
  2531. * 获取分钟
  2532. * @returns
  2533. */
  2534. minute() {
  2535. return this.date.getMinutes();
  2536. }
  2537. /**
  2538. * 获取秒
  2539. * @returns
  2540. */
  2541. second() {
  2542. return this.date.getSeconds();
  2543. }
  2544. /**
  2545. * 获取毫秒
  2546. * @returns
  2547. */
  2548. milliSecond() {
  2549. return this.date.getMilliseconds();
  2550. }
  2551. }
  2552. /**
  2553. * 获取一个增强的日期
  2554. * @param date 要增强的日期
  2555. * @returns 增强日期
  2556. */
  2557. function dateEnhance(date) {
  2558. return new DateEnhance(date);
  2559. }
  2560.  
  2561. /**
  2562. * 获取一年内的第多少星期
  2563. * @param date 日期
  2564. * @returns 这个日期第多少个星期
  2565. * @deprecated 不推荐使用,请使用 {@see dateEnhance} 代替
  2566. */
  2567. function getYearWeek(date) {
  2568. return dateEnhance(date).weekOfYear();
  2569. }
  2570.  
  2571. /**
  2572. * 时间日期间隔
  2573. */
  2574. class DateBetween {
  2575. /**
  2576. * 构造函数
  2577. * @param start 开始时间
  2578. * @param end 结束时间
  2579. */
  2580. constructor(start, end) {
  2581. this.start = start;
  2582. this.end = end;
  2583. }
  2584. /**
  2585. * 获取毫秒差值
  2586. * @returns 毫秒差值
  2587. */
  2588. milliSecond() {
  2589. return this.end.getTime() - this.start.getTime();
  2590. }
  2591. /**
  2592. * 获取秒差值
  2593. * @returns 秒差值
  2594. */
  2595. second() {
  2596. return Math.floor(this.milliSecond() / 1000);
  2597. }
  2598. /**
  2599. * 获取分钟差值
  2600. * @returns 分钟差值
  2601. */
  2602. minute() {
  2603. return Math.floor(this.second() / 60);
  2604. }
  2605. /**
  2606. * 获取小时差值
  2607. * @returns 小时差值
  2608. */
  2609. hour() {
  2610. return Math.floor(this.minute() / 60);
  2611. }
  2612. /**
  2613. * 获取天数差值
  2614. * @returns 天数差值
  2615. */
  2616. day() {
  2617. return Math.floor(this.hour() / 24);
  2618. }
  2619. /**
  2620. * 获取月份差值
  2621. * 注: 此处获取的差值是按月计算的,即 2018-12-31 => 2019-01-01 也被认为相差一个月
  2622. * @returns 月份差值
  2623. */
  2624. month() {
  2625. const year = this.year();
  2626. const month = this.end.getMonth() - this.start.getMonth();
  2627. return year * 12 + month;
  2628. }
  2629. /**
  2630. * 获取年份差值
  2631. * 注: 此处获取的差值是按年计算的,即 2018-12-31 => 2019-01-01 也被认为相差一年
  2632. * @returns 年份差值
  2633. */
  2634. year() {
  2635. return this.end.getFullYear() - this.start.getFullYear();
  2636. }
  2637. }
  2638. /**
  2639. * 获取两个时间的差值
  2640. * @param start 开始时间
  2641. * @param end 结束时间
  2642. * @returns 差值对象
  2643. */
  2644. function dateBetween(start, end) {
  2645. return new DateBetween(start, end);
  2646. }
  2647.  
  2648. /**
  2649. * 返回合理参数本身的函数
  2650. * 1. 如果没有参数则返回 undefined
  2651. * 2. 如果只有一个参数则返回参数本身
  2652. * 3. 如果有两个以上的参数则返回参数列表
  2653. * @param args 任何对象
  2654. * @returns 传入的参数
  2655. * @deprecated 已废弃,貌似没有太多的使用场景
  2656. */
  2657. function returnReasonableItself(...args) {
  2658. const len = args.length;
  2659. if (len === 0) {
  2660. return null;
  2661. }
  2662. if (len === 1) {
  2663. return args[0];
  2664. }
  2665. return args;
  2666. }
  2667.  
  2668. /**
  2669. * 从数组中移除指定的元素
  2670. * 注: 时间复杂度为 1~3On
  2671. * @param arr 需要被过滤的数组
  2672. * @param deleteItems 要过滤的元素数组
  2673. * @param k 每个元素的唯一键函数
  2674. */
  2675. function filterItems(arr, deleteItems, k = returnItself) {
  2676. const kFn = getKFn(k);
  2677. const kSet = new Set(deleteItems.map(kFn));
  2678. return arr.filter((v, i, arr) => !kSet.has(kFn(v, i, arr)));
  2679. }
  2680.  
  2681. /**
  2682. * 比较两个数组的差异
  2683. * @param left 第一个数组
  2684. * @param right 第二个数组
  2685. * @param k 每个元素的唯一标识产生函数
  2686. * @returns 比较的差异结果
  2687. */
  2688. function diffBy(left, right, k = returnItself) {
  2689. const kFn = getKFn(k);
  2690. // 首先得到两个 kSet 集合用于过滤
  2691. const kThanSet = new Set(left.map(kFn));
  2692. const kThatSet = new Set(right.map(kFn));
  2693. const leftUnique = left.filter((v, ...args) => !kThatSet.has(kFn(v, ...args)));
  2694. const rightUnique = right.filter((v, ...args) => !kThanSet.has(kFn(v, ...args)));
  2695. const kLeftSet = new Set(leftUnique.map(kFn));
  2696. const common = left.filter((v, ...args) => !kLeftSet.has(kFn(v, ...args)));
  2697. return { left: leftUnique, right: rightUnique, common };
  2698. }
  2699.  
  2700. /**
  2701. * 比较两个数组的差异
  2702. * @deprecated 已废弃,请使用更简洁的 {@link diffBy}
  2703. */
  2704. const arrayDiffBy = diffBy;
  2705.  
  2706. /**
  2707. * 使用 Generator 实现一个从 0 开始的无限自增序列
  2708. */
  2709. function* autoIncrementGenerator() {
  2710. for (let i = 0;; i++) {
  2711. /**
  2712. * @returns 每次获取都返回循环中的当前迭代变量,然后暂停于此处
  2713. */
  2714. yield i;
  2715. }
  2716. }
  2717. /**
  2718. * 生成器对象
  2719. */
  2720. const generator = autoIncrementGenerator();
  2721. /**
  2722. * 获取自增长序列的最新值
  2723. * @returns 最新值
  2724. */
  2725. function autoIncrement() {
  2726. return generator.next().value;
  2727. }
  2728.  
  2729. /**
  2730. * 转换接口
  2731. * @interface
  2732. */
  2733. class IConverter {
  2734. /**
  2735. * 将字符串解析为字符串列表
  2736. *
  2737. * @param str 字符串
  2738. * @return {Array.<String>} 字符串列表
  2739. * @abstract
  2740. */
  2741. from(str) {
  2742. throw new Error('子类必须重写 from 函数');
  2743. }
  2744. /**
  2745. * 将字符串列表构造为字符串
  2746. *
  2747. * @param list 字符串列表
  2748. * @return {String} 字符串
  2749. * @abstract
  2750. */
  2751. to(list) {
  2752. throw new Error('子类必须重写 to 函数');
  2753. }
  2754. }
  2755.  
  2756. /**
  2757. * 驼峰风格解析
  2758. */
  2759. class CamelOrPascalFrom extends IConverter {
  2760. /**
  2761. * 将字符串解析为字符串列表
  2762. *
  2763. * @param str 字符串
  2764. * @return {Array.<String>} 字符串列表
  2765. * @override
  2766. */
  2767. from(str) {
  2768. const result = [];
  2769. const len = str.length;
  2770. let old = 0;
  2771. for (let i = 0; i < len; i++) {
  2772. const c = str.charAt(i);
  2773. if (c >= 'A' && c <= 'Z') {
  2774. if (i !== 0) {
  2775. result.push(str.substring(old, i));
  2776. }
  2777. old = i;
  2778. }
  2779. }
  2780. if (old !== str.length) {
  2781. result.push(str.substring(old, str.length));
  2782. }
  2783. return result;
  2784. }
  2785. }
  2786.  
  2787. /**
  2788. * 小写开头的驼峰转换器
  2789. *
  2790. */
  2791. class CamelConverter extends CamelOrPascalFrom {
  2792. /**
  2793. * 将字符串列表构造为字符串
  2794. *
  2795. * @param list 字符串列表
  2796. * @return {String} 字符串
  2797. * @override
  2798. */
  2799. to(list) {
  2800. return list.reduce((res, s, i) => {
  2801. const str = toLowerCase(s);
  2802. return (res +=
  2803. (i === 0 ? toLowerCase : toUpperCase)(str.substring(0, 1)) +
  2804. str.substring(1));
  2805. }, '');
  2806. }
  2807. }
  2808.  
  2809. /**
  2810. * 大写开头的驼峰转换器
  2811. */
  2812. class PascalConverter extends CamelOrPascalFrom {
  2813. /**
  2814. * 将字符串列表构造为字符串
  2815. *
  2816. * @param list 字符串列表
  2817. * @return {String} 字符串
  2818. * @override
  2819. */
  2820. to(list) {
  2821. return list.reduce((res, s) => {
  2822. const str = toLowerCase(s);
  2823. return (res += toUpperCase(str.substring(0, 1)) + str.substring(1));
  2824. }, '');
  2825. }
  2826. }
  2827.  
  2828. /**
  2829. * 下划线风格解析
  2830. */
  2831. class SnakeOrScreamingSnakeFrom extends IConverter {
  2832. /**
  2833. * 将字符串解析为字符串列表
  2834. *
  2835. * @param str 字符串
  2836. * @return {Array.<String>} 字符串列表
  2837. * @override
  2838. */
  2839. from(str) {
  2840. return str.split('_');
  2841. }
  2842. }
  2843.  
  2844. /**
  2845. * 小写下划线的转换器
  2846. */
  2847. class SnakeConverter extends SnakeOrScreamingSnakeFrom {
  2848. /**
  2849. * 将字符串列表构造为字符串
  2850. *
  2851. * @param list 字符串列表
  2852. * @return {String} 字符串
  2853. * @override
  2854. */
  2855. to(list) {
  2856. return list.map(toLowerCase).join('_');
  2857. }
  2858. }
  2859.  
  2860. /**
  2861. * 大写下划线的转换器
  2862. */
  2863. class ScreamingSnakeConverter extends SnakeOrScreamingSnakeFrom {
  2864. /**
  2865. * 将字符串列表构造为字符串
  2866. *
  2867. * @param list 字符串列表
  2868. * @return {String} 字符串
  2869. * @override
  2870. */
  2871. to(list) {
  2872. return list.map(toUpperCase).join('_');
  2873. }
  2874. }
  2875.  
  2876. /**
  2877. * @enum {Symbol} 字符串风格常量对象
  2878. */
  2879. (function (StringStyleType) {
  2880. /**
  2881. * 小写驼峰
  2882. */
  2883. StringStyleType[StringStyleType["Camel"] = 1] = "Camel";
  2884. /**
  2885. * 大写驼峰
  2886. */
  2887. StringStyleType[StringStyleType["Pascal"] = 2] = "Pascal";
  2888. /**
  2889. * 小写下划线
  2890. */
  2891. StringStyleType[StringStyleType["Snake"] = 3] = "Snake";
  2892. /**
  2893. * 大写下划线
  2894. */
  2895. StringStyleType[StringStyleType["ScreamingSnake"] = 4] = "ScreamingSnake";
  2896. })(exports.StringStyleType || (exports.StringStyleType = {}));
  2897.  
  2898. /**
  2899. * 转换器工厂
  2900. */
  2901. class ConverterFactory {
  2902. /**
  2903. * 获取一个转换器实例
  2904. *
  2905. * @param styleType 转换风格,使用了 {@link stringStyleType} 定义的常量对象
  2906. * @return {IConverter} 转换器对象
  2907. * @throws 如果获取未定义过的转换器,则会抛出异常
  2908. */
  2909. static getInstance(styleType) {
  2910. switch (styleType) {
  2911. case exports.StringStyleType.Camel:
  2912. return new CamelConverter();
  2913. case exports.StringStyleType.Pascal:
  2914. return new PascalConverter();
  2915. case exports.StringStyleType.Snake:
  2916. return new SnakeConverter();
  2917. case exports.StringStyleType.ScreamingSnake:
  2918. return new ScreamingSnakeConverter();
  2919. default:
  2920. throw new Error('No corresponding converter found');
  2921. }
  2922. }
  2923. }
  2924.  
  2925. /**
  2926. * 字符串风格转换器
  2927. * 请不要直接使用构造函数创建,而是用 {@link StringStyleUtil.getConverter} 来获得一个转换器
  2928. * @private
  2929. */
  2930. class StringStyleConverter {
  2931. /**
  2932. * 构造一个字符串任意风格转换器
  2933. * @param from 转换字符串的风格
  2934. * @param to 需要转换的风格
  2935. * @private
  2936. */
  2937. constructor(from, to) {
  2938. /**
  2939. * @field 解析字符串风格的转换器
  2940. * @type {IConverter}
  2941. * @private
  2942. */
  2943. this.fromConverter = ConverterFactory.getInstance(from);
  2944. /**
  2945. * @field 构造字符串风格的转换器
  2946. * @type {IConverter}
  2947. * @private
  2948. */
  2949. this.toConverter = ConverterFactory.getInstance(to);
  2950. }
  2951. /**
  2952. * 转换字符串的风格
  2953. *
  2954. * @param str 要转换的字符串
  2955. * @return {String} 转换得到的字符串
  2956. */
  2957. convert(str) {
  2958. if (stringValidator.isEmpty(str)) {
  2959. return str;
  2960. }
  2961. return this.toConverter.to(this.fromConverter.from(str));
  2962. }
  2963. }
  2964.  
  2965. /**
  2966. * 包装一个函数为指定参数只执行一次的函数
  2967. * @param fn 需要包装的函数
  2968. * @param identity 参数转换的函数,参数为需要包装函数的参数
  2969. * @returns 需要被包装的函数
  2970. */
  2971. function onceOfSameParam(fn, identity = (args) => `onceOfSameParam-${fn.toString()}-${JSON.stringify(args)}`) {
  2972. const cacheMap = new Map();
  2973. const res = new Proxy(fn, {
  2974. apply(_, _this, args) {
  2975. const key = identity(args);
  2976. const old = cacheMap.get(key);
  2977. if (old !== undefined) {
  2978. return old;
  2979. }
  2980. const res = Reflect.apply(_, _this, args);
  2981. return compatibleAsync(res, res => {
  2982. cacheMap.set(key, res);
  2983. return res;
  2984. });
  2985. },
  2986. });
  2987. return Object.assign(res, {
  2988. origin: fn,
  2989. clear(...keys) {
  2990. if (keys.length) {
  2991. cacheMap.clear();
  2992. }
  2993. else {
  2994. keys.forEach(key => cacheMap.delete(key));
  2995. }
  2996. },
  2997. });
  2998. }
  2999.  
  3000. /**
  3001. * 包装获取字符串风格转换器
  3002. * 此处采用了单例模式,每种转换器只会有一个
  3003. *
  3004. * @param from 解析风格
  3005. * @param to 转换风格
  3006. * @return {StringStyleConverter} 转换器的实例
  3007. */
  3008. const _getConverter = onceOfSameParam(
  3009. /**
  3010. * @param from 解析风格
  3011. * @param to 转换风格
  3012. * @return {StringStyleConverter} 转换器的实例
  3013. */
  3014. (from, to) => new StringStyleConverter(from, to));
  3015. /**
  3016. * 字符串风格转换工具类
  3017. */
  3018. class StringStyleUtil {
  3019. /**
  3020. * 获取一个转换器的实例
  3021. * 该函数获取的转换器可以任意复用,请优先使用函数
  3022. * @param from 解析风格
  3023. * @param to 转换风格
  3024. * @return {StringStyleConverter} 转换器的实例
  3025. */
  3026. static getConverter(from, to) {
  3027. return _getConverter(from, to);
  3028. }
  3029. /**
  3030. * 直接转换字符串的风格
  3031. * 请优先使用可以复用的 {@link StringStyleUtil.getConverter} 函数
  3032. * @param from 解析风格
  3033. * @param to 转换风格
  3034. * @param str 要转换的字符串
  3035. * @return {String} 转换得到的字符串
  3036. */
  3037. static convert(from, to, str) {
  3038. return StringStyleUtil.getConverter(from, to).convert(str);
  3039. }
  3040. }
  3041.  
  3042. /**
  3043. * 递归使对象不可变
  3044. * @param obj 任何非空对象
  3045. * @returns 新的不可变对象
  3046. */
  3047. function deepFreeze(obj) {
  3048. const freeze = (v) => {
  3049. if (TypeValidator.isObject(v)) {
  3050. deepFreeze(v);
  3051. }
  3052. };
  3053. // 数组和对象分别处理
  3054. if (TypeValidator.isArray(obj)) {
  3055. obj.forEach(freeze);
  3056. }
  3057. else if (TypeValidator.isObject(obj)) {
  3058. Object.keys(obj)
  3059. .map(k => Reflect.get(obj, k))
  3060. .forEach(freeze);
  3061. }
  3062. return Object.freeze(obj);
  3063. }
  3064.  
  3065. // noinspection JSPrimitiveTypeWrapperUsage
  3066. /**
  3067. * 包装对象,使其成为可以任意深度调用而不会出现 undefined 调用的问题
  3068. * 注意: 该函数不能进行递归调用({@link JSON.stringfy}),一定会造成堆栈溢出的问题(RangeError: Maximum call stack size exceeded)
  3069. * @param obj 任意一个 Object 对象
  3070. * @param [defaultValue] 默认值,默认为 {}
  3071. * @returns 包装后的对象
  3072. */
  3073. function deepProxy(obj = {}, defaultValue = new String()) {
  3074. const handler = {
  3075. get(target, k) {
  3076. let v = Reflect.get(target, k);
  3077. if (isNullOrUndefined(v)) {
  3078. v = defaultValue;
  3079. }
  3080. if (TypeValidator.isFunction(v)) {
  3081. return v.bind(target);
  3082. }
  3083. if (!TypeValidator.isObject(v)) {
  3084. return v;
  3085. }
  3086. return new Proxy(v, handler);
  3087. },
  3088. };
  3089. return new Proxy(obj, handler);
  3090. }
  3091.  
  3092. /**
  3093. * 将函数包装为柯里化函数
  3094. * 注: 该函数模仿了 Lodash 的 curry 函数
  3095. * @param fn 需要包装的函数
  3096. * @param {...any} args 应用的部分参数
  3097. * @returns 包装后的函数
  3098. * @deprecated 由于之前的理解错误,该函数在下个大版本将会被废弃,请使用命名更合适的 {@link partial}
  3099. */
  3100. function curry(fn, ...args) {
  3101. const realArgs = args.filter(arg => arg !== curry._);
  3102. // 如果函数参数足够则调用传入的函数
  3103. if (realArgs.length >= fn.length) {
  3104. return fn(...realArgs);
  3105. }
  3106. /**
  3107. * 最终返回的函数
  3108. * @param otherArgs 接受任意参数
  3109. * @returns 返回一个函数,或者函数调用完成返回结果
  3110. */
  3111. function innerFn(...otherArgs) {
  3112. // 记录需要移除补到前面的参数
  3113. const removeIndexSet = new Set();
  3114. let i = 0;
  3115. const newArgs = args.map(arg => {
  3116. if (arg !== curry._ ||
  3117. otherArgs[i] === undefined ||
  3118. otherArgs[i] === curry._) {
  3119. return arg;
  3120. }
  3121. removeIndexSet.add(i);
  3122. // 每次补偿前面的 curry._ 参数计数器 +1
  3123. return otherArgs[i++];
  3124. });
  3125. const newOtherArgs = otherArgs.filter((_v, i) => !removeIndexSet.has(i));
  3126. return curry(fn, ...newArgs, ...newOtherArgs);
  3127. }
  3128. // 定义柯里化函数的剩余参数长度,便于在其他地方进行部分参数应用
  3129. // 注: 不使用 length 属性的原因是 length 属性
  3130. innerFn._length = fn.length - args.filter(arg => arg !== curry._).length;
  3131. // 自定义 toString 函数便于调试
  3132. innerFn.toString = () => `name: ${fn.name}, args: [${args.map(o => o.toString()).join(', ')}]`;
  3133. innerFn._curry = true;
  3134. return innerFn;
  3135. }
  3136. /**
  3137. * 柯里化的占位符,需要应用后面的参数时使用
  3138. * 例如 {@link curry(fn)(curry._, 1)} 意味着函数 fn 的第二个参数将被确定为 1
  3139. */
  3140. curry._ = Symbol('_');
  3141.  
  3142. /**
  3143. * 快速根据指定函数对数组进行排序
  3144. * 注: 使用递归实现,对于超大数组(其实前端的数组不可能特别大吧?#笑)可能造成堆栈溢出
  3145. * @param arr 需要排序的数组
  3146. * @param k 对数组中每个元素都产生可比较的值的函数,默认返回自身进行比较
  3147. * @returns 排序后的新数组
  3148. */
  3149. function sortBy(arr, k = returnItself) {
  3150. const kFn = getKFn(k);
  3151. // 此处为了让 typedoc 能生成文档而不得不加上类型
  3152. const newArr = arr.map((v, i) => [v, i]);
  3153. function _sort(arr, fn) {
  3154. // 边界条件,如果传入数组的值
  3155. if (arr.length <= 1) {
  3156. return arr;
  3157. }
  3158. // 根据中间值对数组分治为两个数组
  3159. const medianIndex = Math.floor(arr.length / 2);
  3160. const medianValue = arr[medianIndex];
  3161. const left = [];
  3162. const right = [];
  3163. for (let i = 0, len = arr.length; i < len; i++) {
  3164. if (i === medianIndex) {
  3165. continue;
  3166. }
  3167. const v = arr[i];
  3168. if (fn(v, medianValue) <= 0) {
  3169. left.push(v);
  3170. }
  3171. else {
  3172. right.push(v);
  3173. }
  3174. }
  3175. return _sort(left, fn)
  3176. .concat([medianValue])
  3177. .concat(_sort(right, fn));
  3178. }
  3179. return _sort(newArr, ([t1, i1], [t2, i2]) => {
  3180. const k1 = kFn(t1, i1, arr);
  3181. const k2 = kFn(t2, i2, arr);
  3182. if (k1 === k2) {
  3183. return 0;
  3184. }
  3185. else if (k1 < k2) {
  3186. return -1;
  3187. }
  3188. else {
  3189. return 1;
  3190. }
  3191. }).map(([_v, i]) => arr[i]);
  3192. }
  3193.  
  3194. /**
  3195. * 日期格式化器
  3196. * 包含格式化为字符串和解析字符串为日期的函数
  3197. */
  3198. class DateFormatter {
  3199. /**
  3200. * 构造函数
  3201. * @param fmt 日期时间格式
  3202. */
  3203. constructor(fmt) {
  3204. this.fmt = fmt;
  3205. }
  3206. /**
  3207. * 格式化
  3208. * @param date 需要格式化的日期
  3209. * @returns 格式化的字符串
  3210. */
  3211. format(date) {
  3212. if (isNullOrUndefined(date)) {
  3213. return '';
  3214. }
  3215. return dateFormat(date, this.fmt);
  3216. }
  3217. /**
  3218. * 解析字符串为日期对象
  3219. * @param str 字符串
  3220. * @returns 解析得到的日期
  3221. */
  3222. parse(str) {
  3223. if (stringValidator.isEmpty(str)) {
  3224. return null;
  3225. }
  3226. return dateParse(str, this.fmt);
  3227. }
  3228. /**
  3229. * 将日期时间字符串转换为前端指定格式的字符串
  3230. * 主要适用场景是前端接收到后端的日期时间一般是一个字符串,然而需要自定义格式的时候还必须先创建 {@link Date} 对象才能格式化,略微繁琐,故使用该函数
  3231. * @param str 字符串
  3232. * @param parseFmt 解析的日期时间格式。默认直接使用 {@link new Date()} 创建
  3233. * @returns 转换后得到的字符串
  3234. */
  3235. strFormat(str, parseFmt) {
  3236. if (stringValidator.isEmpty(str)) {
  3237. return '';
  3238. }
  3239. const date = parseFmt ? dateParse(str, parseFmt) : new Date(str);
  3240. return dateFormat(date, this.fmt);
  3241. }
  3242. }
  3243. /**
  3244. * 日期格式化器
  3245. */
  3246. DateFormatter.dateFormatter = new DateFormatter('yyyy-MM-dd');
  3247. /**
  3248. * 时间格式化器
  3249. */
  3250. DateFormatter.timeFormatter = new DateFormatter('hh:mm:ss');
  3251. /**
  3252. * 日期时间格式化器
  3253. */
  3254. DateFormatter.dateTimeFormatter = new DateFormatter('yyyy-MM-dd hh:mm:ss');
  3255.  
  3256. /**
  3257. * 查询符合条件的元素的下标
  3258. * @param arr 查询的数组
  3259. * @param fn 谓词
  3260. * @param num 查询的第几个符合条件的元素,默认为 1,和默认的 findIndex 行为保持一致
  3261. * @returns 符合条件的元素的下标,如果没有则返回 -1
  3262. */
  3263. function findIndex(arr, fn, num = 1) {
  3264. let k = 0;
  3265. for (let i = 0, len = arr.length; i < len; i++) {
  3266. if (fn.call(arr, arr[i], i, arr) && ++k >= num) {
  3267. return i;
  3268. }
  3269. }
  3270. return -1;
  3271. }
  3272.  
  3273. /**
  3274. * 连接两个函数并自动柯里化
  3275. * 注: 该函数依赖于 length,所以不支持默认参数以及不定参数
  3276. * @param fn1 第一个函数
  3277. * @param fn2 第二个函数
  3278. * @returns 连接后的函数
  3279. */
  3280. const _compose = (fn1, fn2) => {
  3281. return function (...args) {
  3282. const i = findIndex(args, v => v !== curry._, fn1._length || fn1.length);
  3283. const res = curry(fn1, ...args);
  3284. // 如果这个函数的参数不足,则返回它
  3285. if (i === -1) {
  3286. return _compose(res, fn2);
  3287. }
  3288. // 否则将结果以及多余的参数应用到下一个函数上
  3289. return curry(fn2, res, ...args.slice(i + 1));
  3290. };
  3291. };
  3292. /**
  3293. * 将多个函数组合起来
  3294. * 前面函数的返回值将变成后面函数的第一个参数,如果到了最后一个函数执行完成,则直接返回
  3295. * 注: 该函数是自动柯里化,将对所有传入的函数进行柯里化处理
  3296. * 注: 该函数支持一次调用传入全部函数的参数
  3297. * @param fns 多个需要连接函数
  3298. * @returns 连接后的柯里化函数
  3299. * TODO 这里需要进行类型优化
  3300. */
  3301. function compose(...fns) {
  3302. return fns.reduceRight((fn1, fn2) => _compose(fn2, fn1));
  3303. }
  3304.  
  3305. /**
  3306. * 递归排除对象中的指定字段
  3307. * @param obj 需要排除的对象
  3308. * @param {...obj} fields 需要排除的字段
  3309. */
  3310. function deepExcludeFields(obj, ...fields) {
  3311. if (TypeValidator.isArray(obj)) {
  3312. return obj.map(o => deepExcludeFields(o, ...fields));
  3313. }
  3314. else if (TypeValidator.isDate(obj)) {
  3315. return obj;
  3316. }
  3317. else if (TypeValidator.isObject(obj)) {
  3318. const temp = excludeFields(obj, ...fields);
  3319. return Object.keys(temp).reduce((res, k) => {
  3320. const v = Reflect.get(res, k);
  3321. Reflect.set(res, k, deepExcludeFields(v, ...fields));
  3322. return res;
  3323. }, temp);
  3324. }
  3325. else {
  3326. return obj;
  3327. }
  3328. }
  3329.  
  3330. /**
  3331. * 递归排除对象中的指定字段
  3332. * @param obj 需要排除的对象
  3333. * @param {...obj} fields 需要排除的字段
  3334. * @deprecated 已废弃,请使用统一使用 `deep` 开头的 {@link deepExcludeFields} 函数
  3335. */
  3336. function excludeFieldsDeep(obj, ...fields) {
  3337. return deepExcludeFields(obj, ...fields);
  3338. }
  3339.  
  3340. /**
  3341. * 缓存的值
  3342. */
  3343. class CacheVal {
  3344. /**
  3345. * 构造函数
  3346. * @param options 缓存值对象
  3347. * @param options.key 缓存的键原始值
  3348. * @param options.val 缓存的值
  3349. * @param options.cacheOption 缓存的选项
  3350. */
  3351. constructor(options = {}) {
  3352. Object.assign(this, options);
  3353. }
  3354. }
  3355.  
  3356. /**
  3357. * 无限的超时时间
  3358. * TODO 此处暂时使用字符串作为一种折衷方法,因为 Symbol 无法被序列化为 JSON,反向序列化也是不可能的
  3359. */
  3360. const TimeoutInfinite = 'TimeoutInfinite';
  3361.  
  3362. /**
  3363. * 使用 LocalStorage 实现的缓存
  3364. * 1. get: 根据 key 获取
  3365. * 2. set: 根据 key value 设置,会覆盖
  3366. * 3. touch: 获取并刷新超时时间
  3367. * 4. add: 根据 key value 添加,不会覆盖
  3368. * 5. del: 根据 key 删除
  3369. * 6. clearExpired: 清除所有过期的缓存
  3370. */
  3371. class LocalStorageCache {
  3372. /**
  3373. * 构造函数
  3374. * @param cacheOption 全局缓存选项
  3375. */
  3376. constructor({ timeout = TimeoutInfinite, serialize = JSON.stringify, deserialize = JSON.parse, } = {}) {
  3377. // 这里必须强制转换,因为 timeStart 在全局选项中是不可能存在的
  3378. this.cacheOption = {
  3379. timeout,
  3380. serialize,
  3381. deserialize,
  3382. };
  3383. /**
  3384. * 缓存对象,默认使用 localStorage
  3385. */
  3386. this.localStorage = window.localStorage;
  3387. // 创建后将异步清空所有过期的缓存
  3388. this.clearExpired();
  3389. }
  3390. /**
  3391. * 清空所有过期的 key
  3392. * 注: 该函数是异步执行的
  3393. */
  3394. clearExpired() {
  3395. return __awaiter(this, void 0, void 0, function* () {
  3396. const local = this.localStorage;
  3397. const getKeys = () => {
  3398. const len = local.length;
  3399. const res = [];
  3400. for (let i = 0; i < len; i++) {
  3401. res.push(local.key(i));
  3402. }
  3403. return res;
  3404. };
  3405. getKeys()
  3406. .filter(not(isNullOrUndefined))
  3407. .map(key => safeExec(() => JSON.parse(local.getItem(key))))
  3408. .filter(cacheVal => !isNullOrUndefined(cacheVal) &&
  3409. isNullOrUndefined(cacheVal.cacheOption))
  3410. // TODO 这里暂时加个补丁,过滤掉 timeStart,timeout 为 undefined 的缓存
  3411. .filter(({ cacheOption = {} }) => {
  3412. const { timeStart, timeout } = cacheOption;
  3413. if (isNullOrUndefined(timeStart) || isNullOrUndefined(timeout)) {
  3414. return false;
  3415. }
  3416. return timeout !== TimeoutInfinite && Date.now() - timeStart > timeout;
  3417. })
  3418. .forEach(({ key }) => local.removeItem(key));
  3419. });
  3420. }
  3421. /**
  3422. * 根据 key + value 添加
  3423. * 如果不存在则添加,否则忽略
  3424. * @param key 缓存的 key
  3425. * @param val 缓存的 value
  3426. * @param cacheOption 缓存的选项,默认为无限时间
  3427. * @override
  3428. */
  3429. add(key, val, timeout) {
  3430. const result = this.get(key);
  3431. if (result !== null) {
  3432. return;
  3433. }
  3434. this.set(key, val, timeout);
  3435. }
  3436. /**
  3437. * 根据指定的 key 删除
  3438. * 如果存在则删除,否则忽略
  3439. * @param key 删除的 key
  3440. * @override
  3441. */
  3442. del(key) {
  3443. this.localStorage.removeItem(key);
  3444. }
  3445. /**
  3446. * 根据指定的 key 修改
  3447. * 不管是否存在都会设置
  3448. * @param key 修改的 key
  3449. * @param val 修改的 value
  3450. * @param timeout 修改的选项
  3451. * @override
  3452. */
  3453. set(key, val, timeout) {
  3454. this.localStorage.setItem(key, JSON.stringify(new CacheVal({
  3455. key,
  3456. val: this.cacheOption.serialize(val),
  3457. // 我们不需要缓存序列化/反序列化策略(实际上也无法缓存)
  3458. cacheOption: {
  3459. timeStart: Date.now(),
  3460. timeout: timeout || this.cacheOption.timeout,
  3461. },
  3462. })));
  3463. }
  3464. /**
  3465. * 根据 key 获取
  3466. * 如果存在则获取,否则忽略
  3467. * @param key 指定的 key
  3468. * @param timeout 获取的选项
  3469. * @returns 获取到的缓存值
  3470. * @override
  3471. */
  3472. get(key) {
  3473. const str = this.localStorage.getItem(key);
  3474. const cacheVal = safeExec(() => JSON.parse(str));
  3475. if (isNullOrUndefined(cacheVal) ||
  3476. isNullOrUndefined(cacheVal.cacheOption)) {
  3477. return null;
  3478. }
  3479. const [timeStart, timeout, deserialize] = [
  3480. cacheVal.cacheOption.timeStart,
  3481. cacheVal.cacheOption.timeout,
  3482. this.cacheOption.deserialize,
  3483. ];
  3484. // 如果超时则删除并返回 null
  3485. if (timeout !== TimeoutInfinite && Date.now() - timeStart > timeout) {
  3486. this.del(key);
  3487. return null;
  3488. }
  3489. try {
  3490. return deserialize(cacheVal.val);
  3491. }
  3492. catch (e) {
  3493. this.del(key);
  3494. return null;
  3495. }
  3496. }
  3497. /**
  3498. * 根据 key 获取并刷新超时时间
  3499. * @param key 指定的 key
  3500. * @param cacheOption 获取的选项
  3501. * @returns 获取到的缓存值
  3502. * @override
  3503. */
  3504. touch(key) {
  3505. const str = this.localStorage.getItem(key);
  3506. /**
  3507. * @type {CacheVal}
  3508. */
  3509. const cacheVal = safeExec(() => JSON.parse(str));
  3510. if (isNullOrUndefined(cacheVal) ||
  3511. isNullOrUndefined(cacheVal.cacheOption)) {
  3512. return null;
  3513. }
  3514. const [timeStart, timeout, deserialize] = [
  3515. cacheVal.cacheOption.timeStart,
  3516. cacheVal.cacheOption.timeout,
  3517. this.cacheOption.deserialize,
  3518. ];
  3519. // 如果超时则删除并返回 null
  3520. if (timeout !== TimeoutInfinite && Date.now() - timeStart > timeout) {
  3521. this.del(key);
  3522. return null;
  3523. }
  3524. try {
  3525. const result = deserialize(cacheVal.val);
  3526. this.set(key, result, { timeStart: Date.now(), timeout });
  3527. return result;
  3528. }
  3529. catch (e) {
  3530. this.del(key);
  3531. return null;
  3532. }
  3533. }
  3534. }
  3535.  
  3536. /**
  3537. * 默认使用的 {@link ICache} 接口的缓存实现
  3538. */
  3539. const cache = new LocalStorageCache();
  3540. /**
  3541. * 缓存工具类
  3542. * 主要实现缓存高阶函数的封装
  3543. */
  3544. class CacheUtil {
  3545. /**
  3546. * 将指定函数包装为只调用一次为缓存函数
  3547. * @param fn 需要包装的函数
  3548. * @param options 缓存选项对象。可选项
  3549. * @param options.identity 缓存标识。默认为函数 {@link toString},但有时候不太可行(继承自基类的函数)
  3550. * @param options.timeout 缓存时间。默认为无限
  3551. * @returns 包装后的函数
  3552. */
  3553. static once(fn, { identity = fn.toString(), timeout } = {}) {
  3554. const generateKey = () => `CacheUtil.onceOfSameParam-${identity}`;
  3555. const innerFn = new Proxy(fn, {
  3556. apply(_, _this, args) {
  3557. const key = generateKey();
  3558. const val = cache.get(key);
  3559. if (val !== null) {
  3560. return val;
  3561. }
  3562. return compatibleAsync(Reflect.apply(_, _this, args), res => {
  3563. cache.set(key, res, timeout);
  3564. return res;
  3565. });
  3566. },
  3567. });
  3568. return Object.assign(innerFn, {
  3569. origin: fn,
  3570. clear() {
  3571. cache.del(generateKey());
  3572. },
  3573. });
  3574. }
  3575. /**
  3576. * 包裹函数为缓存函数
  3577. * @param fn 一个接受一些参数并返回结果的函数
  3578. * @param options 缓存选项对象。可选项
  3579. * @param options.identity 缓存标识。默认为函数 {@link toString},但有时候不太可行(继承自基类的函数)
  3580. * @param options.timeout 缓存时间。默认为无限
  3581. * @returns 带有缓存功能的函数
  3582. */
  3583. static onceOfSameParam(fn, { identity = fn.toString(), timeout } = {}) {
  3584. const generateKey = (args) => `CacheUtil.onceOfSameParam-${identity}-${JSON.stringify(args)}`;
  3585. const innerFn = new Proxy(fn, {
  3586. apply(_, _this, args) {
  3587. const key = generateKey(args);
  3588. const val = cache.get(key);
  3589. if (val !== null) {
  3590. return val;
  3591. }
  3592. return compatibleAsync(Reflect.apply(_, _this, args), res => {
  3593. cache.set(key, res, timeout);
  3594. return res;
  3595. });
  3596. },
  3597. });
  3598. return Object.assign(innerFn, {
  3599. origin: fn,
  3600. clear(...args) {
  3601. cache.del(generateKey(args));
  3602. },
  3603. });
  3604. }
  3605. }
  3606. /**
  3607. * 导出一个默认的缓存工具对象
  3608. * @deprecated 已废弃,请直接使用类的静态函数
  3609. */
  3610. const cacheUtil = CacheUtil;
  3611.  
  3612. /**
  3613. * 一个空的函数
  3614. * @param args 接受任何参数
  3615. */
  3616. function emptyFunc(...args) { }
  3617.  
  3618. /**
  3619. * 禁止他人调试网站相关方法的集合对象
  3620. */
  3621. class AntiDebug {
  3622. /**
  3623. * 不停循环 debugger 防止有人调试代码
  3624. * @returns 取消函数
  3625. */
  3626. static cyclingDebugger() {
  3627. const res = setInterval(() => {
  3628. debugger;
  3629. }, 100);
  3630. return () => clearInterval(res);
  3631. }
  3632. /**
  3633. * 检查是否正在 debugger 并调用回调函数
  3634. * @param fn 回调函数,默认为重载页面
  3635. * @returns 取消函数
  3636. */
  3637. static checkDebug(fn = () => window.location.reload()) {
  3638. const res = setInterval(() => {
  3639. const diff = timing(() => {
  3640. debugger;
  3641. });
  3642. if (diff > 500) {
  3643. console.log(diff);
  3644. fn();
  3645. }
  3646. }, 1000);
  3647. return () => clearInterval(res);
  3648. }
  3649. /**
  3650. * 禁用控制台调试输出
  3651. * @returns 取消函数
  3652. */
  3653. static disableConsoleOutput() {
  3654. if (!window.console) {
  3655. return emptyFunc;
  3656. }
  3657. const map = arrayToMap(Object.keys(console), returnItself, k => {
  3658. // @ts-ignore
  3659. const temp = console[k];
  3660. // @ts-ignore
  3661. console[k] = emptyFunc;
  3662. return temp;
  3663. });
  3664. return () => {
  3665. for (const [k, v] of map) {
  3666. // @ts-ignore
  3667. console[k] = v;
  3668. }
  3669. };
  3670. }
  3671. }
  3672. /**
  3673. * 禁止他人调试网站相关方法的集合对象
  3674. * @deprecated 已废弃,请直接使用类的静态函数
  3675. */
  3676. const antiDebug = AntiDebug;
  3677.  
  3678. /**
  3679. * 判断一个字符串是否为空白的字符串
  3680. * @param str 字符串
  3681. * @returns 是否为空字符串
  3682. * @deprecated 已废弃,请使用 {@link stringValidator#isBlank}
  3683. */
  3684. function isBlank(str) {
  3685. return stringValidator.isBlank(str);
  3686. }
  3687.  
  3688. /**
  3689. * 判断一个字符串是否为空字符串
  3690. * @param str 字符串
  3691. * @returns 是否为空字符串
  3692. * @deprecated 已废弃,请使用 {@link stringValidator#isEmpty}
  3693. */
  3694. function isEmpty(str) {
  3695. return stringValidator.isEmpty(str);
  3696. }
  3697.  
  3698. /**
  3699. * 加载一个远程脚本文件
  3700. * @param src 远程脚本路径
  3701. * @returns 等待异步加载脚本完成
  3702. */
  3703. function loadScript(src) {
  3704. return new Promise((resolve, reject) => {
  3705. const script = document.createElement('script');
  3706. script.async = false;
  3707. script.src = src;
  3708. script.addEventListener('load', () => resolve());
  3709. script.addEventListener('error', reject);
  3710. document.body.appendChild(script);
  3711. });
  3712. }
  3713.  
  3714. /**
  3715. * 将一个谓词函数取反
  3716. * 如果是同步函数,则返回的函数也是同步的,否则返回的是取反后的异步函数
  3717. * @param fn 要取反的函数
  3718. * @returns 取反得到的函数
  3719. * @deprecated 已废弃,请使用 {@link CombinedPredicate.not} 进行为此取反
  3720. */
  3721. function deny(fn) {
  3722. return CombinedPredicate.not(fn);
  3723. }
  3724.  
  3725. /**
  3726. * 数组校验器
  3727. */
  3728. class ArrayValidator {
  3729. /**
  3730. * 是否为空数组
  3731. * @param array 空数组
  3732. * @returns 是否为空数组
  3733. */
  3734. static isEmpty(array) {
  3735. return (isNullOrUndefined(array) ||
  3736. !(array instanceof Array) ||
  3737. array.length === 0);
  3738. }
  3739. }
  3740. /**
  3741. * 导出一个默认的数组校验对象
  3742. * @deprecated 已废弃,请直接使用类的静态函数
  3743. */
  3744. const arrayValidator = ArrayValidator;
  3745.  
  3746. /**
  3747. * 路径工具
  3748. */
  3749. class PathUtil {
  3750. /**
  3751. * 拼接多个路径
  3752. *
  3753. * @param paths 路径数组
  3754. * @return {String} 拼接完成的路径
  3755. */
  3756. static join(...paths) {
  3757. return paths.reduce(PathUtil._join);
  3758. }
  3759. /**
  3760. * 拼接两个路径
  3761. *
  3762. * @param pathStart 开始路径
  3763. * @param pathEnd 结束路径
  3764. * @return {String} 拼接完成的两个路径
  3765. */
  3766. static _join(pathStart, pathEnd) {
  3767. if (pathStart.endsWith(PathUtil.Separator)) {
  3768. return (pathStart + pathEnd).replace(PathUtil.Separator + PathUtil.Separator, PathUtil.Separator);
  3769. }
  3770. if (pathEnd.startsWith(PathUtil.Separator)) {
  3771. return pathStart + pathEnd;
  3772. }
  3773. return pathStart + PathUtil.Separator + pathEnd;
  3774. }
  3775. }
  3776. /**
  3777. * 路径分隔符
  3778. */
  3779. PathUtil.Separator = '/';
  3780. /**
  3781. * 导出一个路径工具类
  3782. * @deprecated 已废弃,请直接使用类的静态函数
  3783. */
  3784. const pathUtil = PathUtil;
  3785.  
  3786. var LoggerLevelEnum;
  3787. (function (LoggerLevelEnum) {
  3788. LoggerLevelEnum[LoggerLevelEnum["Debug"] = 0] = "Debug";
  3789. LoggerLevelEnum[LoggerLevelEnum["Log"] = 1] = "Log";
  3790. LoggerLevelEnum[LoggerLevelEnum["Info"] = 2] = "Info";
  3791. LoggerLevelEnum[LoggerLevelEnum["Warn"] = 3] = "Warn";
  3792. LoggerLevelEnum[LoggerLevelEnum["Error"] = 4] = "Error";
  3793. })(LoggerLevelEnum || (LoggerLevelEnum = {}));
  3794. const enumMap = {
  3795. debug: LoggerLevelEnum.Debug,
  3796. log: LoggerLevelEnum.Log,
  3797. info: LoggerLevelEnum.Info,
  3798. warn: LoggerLevelEnum.Warn,
  3799. error: LoggerLevelEnum.Error,
  3800. };
  3801. /**
  3802. * 自定义的日志类
  3803. * 主要便于在开发环境下正常显示调试信息,在生产环境则默认关闭它
  3804. */
  3805. class Logger {
  3806. /**
  3807. * 构造函数
  3808. * @param options 可选项
  3809. * @param options.enable 是否开启日志
  3810. */
  3811. constructor({ enable = true, level = LoggerLevelEnum.Log, } = {}) {
  3812. /**
  3813. * 开发日志:业务强相关调试日志,希望其他人开发时默认隐藏起来的日志(例如第三方服务的回调日志很多,但对于服务接入层的使用者并不关心)
  3814. */
  3815. this.debug = console.debug;
  3816. /**
  3817. * 开发日志:业务相关调试日志,希望其他开发时也能看到的日志
  3818. */
  3819. this.log = console.log;
  3820. /**
  3821. * 生产日志:开发环境也会打印的日志,希望在生产环境打印并且方便调试的日志
  3822. */
  3823. this.info = console.info;
  3824. /**
  3825. * 警告日志:一些危险的操作可以在这里打印出来,同时会显示在生产环境(例如警告用户不要在控制台输入不了解的代码以避免账号安全)
  3826. */
  3827. this.warn = console.warn;
  3828. /**
  3829. * 错误日志:发生错误时使用的日志,发生影响到用户的错误时必须使用该日志
  3830. */
  3831. this.error = console.error;
  3832. this.dir = console.dir;
  3833. this.dirxml = console.dirxml;
  3834. this.table = console.table;
  3835. this.trace = console.trace;
  3836. this.group = console.group;
  3837. this.groupCollapsed = console.groupCollapsed;
  3838. this.groupEnd = console.groupEnd;
  3839. this.clear = console.clear;
  3840. this.count = console.count;
  3841. this.assert = console.assert;
  3842. this.profile = console.profile;
  3843. this.profileEnd = console.profileEnd;
  3844. this.time = console.time;
  3845. this.timeEnd = console.timeEnd;
  3846. this.timeStamp = console.timeStamp;
  3847. this.enable = enable;
  3848. this.level = level;
  3849. }
  3850. /**
  3851. * 设置 enable 的 setter 属性,在改变时合并对应的子类对象实现
  3852. * @param enable 是否开启
  3853. */
  3854. set enable(enable) {
  3855. Object.keys(console).forEach(k => Reflect.set(this, k, enable ? console[k] : emptyFunc));
  3856. }
  3857. /**
  3858. * 设置日志的级别
  3859. * @param level
  3860. */
  3861. set level(level) {
  3862. Object.keys(console)
  3863. .filter(k => Reflect.has(enumMap, k))
  3864. .forEach(k => Reflect.set(this, k, Reflect.get(enumMap, k) >= level ? console[k] : emptyFunc));
  3865. }
  3866. }
  3867. Logger.Level = LoggerLevelEnum;
  3868. /**
  3869. * 导出一个全局可用的 Logger 对象
  3870. * 使用 enable 属性控制是否开启日志输出,默认为 true
  3871. */
  3872. const logger = new Logger();
  3873.  
  3874. /**
  3875. * 将 Object 对象 转换为 Map
  3876. * @param obj Object 对象
  3877. * @returns 转换得到的 Map 键值表
  3878. */
  3879. function objectToMap(obj) {
  3880. return Object.keys(obj).reduce((map, k) => map.set(k, Reflect.get(obj, k)), new Map());
  3881. }
  3882.  
  3883. /**
  3884. * 将列表转换为树节点
  3885. * 注: 该函数默认树的根节点只有一个,如果有多个,则返回一个数组
  3886. * @param list 树节点列表
  3887. * @param options 其他选项
  3888. * @returns 树节点,或是树节点列表
  3889. */
  3890. function listToTree(list, { bridge = returnItself, isRoot = node => !node.parentId, } = {}) {
  3891. const arr = [];
  3892. const res = list.reduce((root, _sub) => {
  3893. const sub = bridge(_sub);
  3894. if (isRoot(sub)) {
  3895. root.push(sub);
  3896. return root;
  3897. }
  3898. for (const _parent of list) {
  3899. const parent = bridge(_parent);
  3900. if (sub.parentId === parent.id) {
  3901. parent.child = parent.child || [];
  3902. parent.child.push(sub);
  3903. return root;
  3904. }
  3905. }
  3906. return root;
  3907. }, arr);
  3908. // 根据顶级节点的数量决定如何返回
  3909. const len = res.length;
  3910. if (len === 0)
  3911. return {};
  3912. if (len === 1)
  3913. return res[0];
  3914. return res;
  3915. }
  3916.  
  3917. /**
  3918. * 桥接对象不存在的字段
  3919. * @param map 代理的字段映射 Map
  3920. * @returns 转换一个对象为代理对象
  3921. * @typeparam 类型解释:1. -readonly 是将使用者的 as const 修改为可变的字段,2. [P in keyof M] 从映射对象中取出所有的 key 作为字段,3. T[M[P] extends keyof T ? M[P] : never] 本质上只是 T[M[P]]],只是 ts 不认为 M[P] 是 T 的字段,所以只能绕一下才能使用
  3922. */
  3923. function bridge(map) {
  3924. /**
  3925. * 为对象添加代理的函数
  3926. * @param obj 任何对象
  3927. * @returns 代理后的对象
  3928. */
  3929. return function (obj) {
  3930. return new Proxy(obj, {
  3931. get(_, k) {
  3932. if (Reflect.has(map, k)) {
  3933. return Reflect.get(_, Reflect.get(map, k));
  3934. }
  3935. return Reflect.get(_, k);
  3936. },
  3937. set(_, k, v) {
  3938. if (Reflect.has(map, k)) {
  3939. Reflect.set(_, Reflect.get(map, k), v);
  3940. return true;
  3941. }
  3942. Reflect.set(_, k, v);
  3943. return true;
  3944. },
  3945. });
  3946. };
  3947. }
  3948.  
  3949. /**
  3950. * 遍历并映射一棵树的每个节点
  3951. * @param root 树节点
  3952. * @param options 其他选项
  3953. * @returns 递归遍历后的树节点
  3954. */
  3955. function treeMapping(root, { before = returnItself, after = returnItself, paramFn = (node, ...args) => [], } = {}) {
  3956. /**
  3957. * 遍历一颗完整的树
  3958. * @param node 要遍历的树节点
  3959. * @param args 每次递归遍历时的参数
  3960. */
  3961. function _treeMapping(node, ...args) {
  3962. // 之前的操作
  3963. const _node = before(node, ...args);
  3964. const _child = _node.child;
  3965. if (!arrayValidator.isEmpty(_child)) {
  3966. _node.child = _child.map(v =>
  3967. // 产生一个参数
  3968. _treeMapping(v, ...paramFn(_node, ...args)));
  3969. }
  3970. // 之后的操作
  3971. return after(_node, ...args);
  3972. }
  3973. return _treeMapping(root);
  3974. }
  3975.  
  3976. /**
  3977. * 将树节点转为树节点列表
  3978. * 这里使用了循环进行遍历,而非传统的递归方式
  3979. * @param root 树节点
  3980. * @param options 其他选项
  3981. * @returns 树节点列表
  3982. */
  3983. function treeToList(root, { calcPath = false, bridge = returnItself, } = {}) {
  3984. const res = [];
  3985. const temp = bridge(root);
  3986. if (calcPath) {
  3987. temp.path = temp.id + '';
  3988. }
  3989. // 利用队列缓存所有未处理的节点
  3990. const queue = [temp];
  3991. // 使用 Set 防止可能的重复引用
  3992. const filterSet = new Set();
  3993. // 使用 lastIdMap 避免重复添加
  3994. const lastIdMap = new Map();
  3995. for (let value; queue.length > 0;) {
  3996. const first = queue.shift();
  3997. value = bridge(first);
  3998. // 判断重复
  3999. if (value === undefined || filterSet.has(first)) {
  4000. continue;
  4001. }
  4002. filterSet.add(first);
  4003. res.push(value);
  4004. const child = value.child;
  4005. if (ArrayValidator.isEmpty(child)) {
  4006. continue;
  4007. }
  4008. const childNonIllegal = child.filter(v => !isNullOrUndefined(v) || filterSet.has(v));
  4009. // TODO 这里和上面的代码明显重复,待优化。。。
  4010. queue.push(...(calcPath
  4011. ? childNonIllegal.map(v => {
  4012. const _v = bridge(v);
  4013. // 如果最后一个的 id 等于自身,说明已经被添加过了
  4014. if (lastIdMap.get(_v.id) === _v.id) {
  4015. return _v;
  4016. }
  4017. // 使用父节点绝对路径 + 当前 id
  4018. _v.path = value.path + ',' + _v.id;
  4019. lastIdMap.set(_v.id, _v.id);
  4020. return _v;
  4021. })
  4022. : childNonIllegal));
  4023. }
  4024. return res;
  4025. }
  4026.  
  4027. /**
  4028. * 树节点桥接工具类
  4029. * 主要实现了桥接 {@field bridge} {@field bridgeTree} 和 {@field bridgeList} 三个函数,事实上桥接之后再转换相当于做了两遍,但就目前而言暂且只能如此了
  4030. */
  4031. class NodeBridgeUtil {
  4032. /**
  4033. * 桥接对象为标准的树结构
  4034. * @param nodeBridge 桥接对象
  4035. * @returns 代理函数
  4036. */
  4037. static bridge({ id = 'id', parentId = 'parentId', child = 'child', path = 'path', } = {}) {
  4038. return bridge({
  4039. id,
  4040. parentId,
  4041. child,
  4042. path,
  4043. });
  4044. }
  4045. /**
  4046. * 桥接一棵完整的树
  4047. * @param tree 树节点
  4048. * @param nodeBridge 桥接对象
  4049. * @returns 代理后的树对象
  4050. */
  4051. static bridgeTree(tree, nodeBridge) {
  4052. return treeMapping(tree, {
  4053. before: this.bridge(nodeBridge),
  4054. });
  4055. }
  4056. /**
  4057. * 桥接一个树节点列表
  4058. * @param list 树节点列表
  4059. * @param nodeBridge 桥接对象
  4060. * @returns 代理后的树节点列表
  4061. */
  4062. static bridgeList(list, nodeBridge) {
  4063. return list.map(this.bridge(nodeBridge));
  4064. }
  4065. }
  4066. /**
  4067. * 导出一个 NodeBridgeUtil 的实例
  4068. * @deprecated 已废弃,请直接使用类的静态函数
  4069. */
  4070. const nodeBridgeUtil = NodeBridgeUtil;
  4071.  
  4072. /**
  4073. * 获取对象中所有的属性及对应的值,包括 ES6 新增的 Symbol 类型的属性
  4074. * @param obj 任何对象
  4075. * @returns 属性及其对应值的二维数组
  4076. * @deprecated 该函数将要被废弃,实质上应用场景很窄
  4077. */
  4078. function getObjectEntries(obj) {
  4079. const mFn = k => [
  4080. k,
  4081. Reflect.get(obj, k),
  4082. ];
  4083. return Reflect.ownKeys(obj).map(mFn);
  4084. }
  4085.  
  4086. /**
  4087. * 获取对象中所有的属性,包括 ES6 新增的 Symbol 类型的属性
  4088. * @param obj 任何对象
  4089. * @returns 属性数组
  4090. * @deprecated 已废弃,请使用 ES6 {@see Reflect.ownKeys} 代替
  4091. * 具体参考 {@url(https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/Global_Objects/Reflect/ownKeys)}
  4092. */
  4093. function getObjectKeys(obj) {
  4094. if (isNullOrUndefined(obj)) {
  4095. return [];
  4096. }
  4097. return Reflect.ownKeys(obj);
  4098. }
  4099.  
  4100. /**
  4101. * 比较两个浮点数是否相等
  4102. * 具体实现采用差值取绝对值并与 {@link Number.EPSILON} 比较的方式,如果小于浮点数最小差值,则认为它们是 [相等] 的
  4103. * @param num1 第一个浮点数
  4104. * @param num2 第二个浮点数
  4105. * @returns 两数是否相等
  4106. */
  4107. function floatEquals(num1, num2) {
  4108. return Math.abs(num1 - num2) < Number.EPSILON;
  4109. }
  4110.  
  4111. //TODO 暂时绕过类型错误,之后有时间再修
  4112. // export function assign<T, A>(target: T, a: A): T & A
  4113. // export function assign<T, A, B>(target: T, a: A, b: B): T & A & B
  4114. // export function assign<T, A, B, C>(target: T, a: A, b: B, c: C): T & A & B & C
  4115. // export function assign<T, A, B, C, D>(
  4116. // target: T,
  4117. // a: A,
  4118. // b: B,
  4119. // c: C,
  4120. // d: D,
  4121. // ): T & A & B & C & D
  4122. /**
  4123. * 合并多个对象的属性
  4124. * 1. 该合并的方式为浅层合并,只会合并一层的对象
  4125. * 2. 默认忽略值为 undefined/null 的属性
  4126. * @param target 覆盖的对象上
  4127. * @param {...Object} sources 任意数量的对象
  4128. * @returns 合并后的对象
  4129. */
  4130. function assign(target, ...sources) {
  4131. return [target, ...sources].reduce((res, source) => {
  4132. if (isNullOrUndefined(source)) {
  4133. return res;
  4134. }
  4135. return Object.keys(source).reduce((res, k) => {
  4136. const v = Reflect.get(source, k);
  4137. if (isNullOrUndefined(v)) {
  4138. return res;
  4139. }
  4140. Reflect.set(res, k, v);
  4141. return res;
  4142. }, res);
  4143. }, {});
  4144. }
  4145.  
  4146. /**
  4147. * 根据不同的源对象获取不同的正则匹配,代表不需要拷贝的属性
  4148. * @param source 源对象
  4149. * @returns 匹配内部属性的正则表达式
  4150. */
  4151. function getInnerFieldRule(source) {
  4152. if (source instanceof Function) {
  4153. return /^(?:constructor|prototype|arguments|caller|name|bind|call|apply|toString|length)$/;
  4154. }
  4155. else {
  4156. return /^(?:toString|length)$/;
  4157. }
  4158. }
  4159. /**
  4160. * 拷贝对象的属性到目标对象上
  4161. * @param target 目标对象
  4162. * @param source 源对象
  4163. * @returns 返回 {@param target} 目标对象
  4164. */
  4165. function _copyProps(target, source) {
  4166. const innerField = getInnerFieldRule(source);
  4167. Reflect.ownKeys(source).forEach(prop => {
  4168. if (typeof prop === 'string' && innerField.test(prop)) {
  4169. return;
  4170. }
  4171. Reflect.set(target, prop, Reflect.get(source, prop));
  4172. });
  4173. return target;
  4174. }
  4175. /**
  4176. * 混合多个类
  4177. * @param {...Class} mixins 需要混合的多个类及其构造函数参数映射函数的 Map 集合
  4178. * @returns 返回一个混合后的类,构造函数将的参数
  4179. */
  4180. function aggregation(mixins) {
  4181. const arr = Array.from(mixins);
  4182. class Aggregate {
  4183. /**
  4184. * @param args 任意数量的参数
  4185. */
  4186. constructor(...args) {
  4187. arr.forEach(([Mixin, fn = returnItself]) => _copyProps(this, new Mixin(...fn(args))));
  4188. }
  4189. }
  4190. arr.forEach(([Mixin]) => {
  4191. _copyProps(Aggregate.prototype, Mixin.prototype);
  4192. _copyProps(Aggregate, Mixin);
  4193. });
  4194. return Aggregate;
  4195. }
  4196.  
  4197. /**
  4198. * 包装一个异步函数为有限制并发功能的函数
  4199. * @param fn 异步函数
  4200. * @param options 可选参数
  4201. * @param options.limit 并发限制数量,默认为 1
  4202. * @returns 返回被包装后的限制并发功能的函数
  4203. */
  4204. function asyncLimiting(fn, { limit = 1 } = {}) {
  4205. // 当前正在执行异步的数量
  4206. let execCount = 0;
  4207. // waitArr 等待的队列
  4208. const takeQueue = [];
  4209. // 是否增加了 execCount 的标记
  4210. let flag = false;
  4211. return new Proxy(fn, {
  4212. apply(_, _this, args) {
  4213. return __awaiter(this, void 0, void 0, function* () {
  4214. const _takeRun = () => __awaiter(this, void 0, void 0, function* () {
  4215. if (!flag) {
  4216. execCount++;
  4217. flag = false;
  4218. }
  4219. const tempArgs = takeQueue.shift();
  4220. try {
  4221. return yield Reflect.apply(_, _this, tempArgs);
  4222. }
  4223. finally {
  4224. execCount--;
  4225. }
  4226. });
  4227. takeQueue.push(args);
  4228. yield wait(() => {
  4229. const result = execCount < limit;
  4230. // 如果等待结束则必须立刻增加 execCount,避免微任务与宏任务调度可能产生错误
  4231. if (result) {
  4232. flag = true;
  4233. execCount++;
  4234. }
  4235. return result;
  4236. });
  4237. return _takeRun();
  4238. });
  4239. },
  4240. });
  4241. }
  4242.  
  4243. /**
  4244. * 默认的超时时间,可以认为是无限
  4245. */
  4246. const TimeoutInfinity = () => false;
  4247. /**
  4248. * 创建一个 Lock 对象,用于锁住当前的当前的异步流程
  4249. */
  4250. class Locker {
  4251. /**
  4252. * @param options 可选项
  4253. * @param options.limit 限制并发数量,默认为 1
  4254. * @param options.timeout 超时时间,默认为无限
  4255. */
  4256. constructor({ limit = 1, timeout } = {}) {
  4257. this.limit = limit;
  4258. this.timeout = timeout || TimeoutInfinity;
  4259. }
  4260. /**
  4261. * 当前是否锁住了
  4262. * @returns 是否锁住了
  4263. */
  4264. isLocked() {
  4265. return this.limit <= 0;
  4266. }
  4267. /**
  4268. * 添加异步锁
  4269. * @param timeout 超时时间,默认为全局 timeout
  4270. * @returns 进行等待
  4271. */
  4272. lock(timeout = this.timeout) {
  4273. return __awaiter(this, void 0, void 0, function* () {
  4274. if (this.isLocked()) {
  4275. /**
  4276. * @type {Number|Function}
  4277. */
  4278. yield Promise.race([
  4279. wait(() => {
  4280. const result = !this.isLocked();
  4281. if (result) {
  4282. this.limit--;
  4283. }
  4284. return result;
  4285. }),
  4286. wait(timeout),
  4287. ]);
  4288. }
  4289. else {
  4290. this.limit--;
  4291. }
  4292. });
  4293. }
  4294. /**
  4295. * 删除异步锁
  4296. */
  4297. unlock() {
  4298. this.limit++;
  4299. }
  4300. }
  4301.  
  4302. /**
  4303. * 包装一个函数为有错误重试功能的函数
  4304. * 注: 如果发生错误,最终将抛出最后一次调用的异常
  4305. * @param fn 需要被包装的函数
  4306. * @param num 调用的次数。默认为 1
  4307. * @param errorCheck 检查返回结果是否需要重试的函数。默认只要 resolve() 就返回 true
  4308. * @returns 包装后的有错误重试功能的函数
  4309. */
  4310. function trySometime(fn, num = 1, errorCheck = res => true) {
  4311. return new Proxy(fn, {
  4312. apply(target, thisArg, args) {
  4313. return __awaiter(this, void 0, void 0, function* () {
  4314. let err;
  4315. for (let i = 0; i < num; i++) {
  4316. try {
  4317. // 等待结果出来
  4318. const res = yield Reflect.apply(target, thisArg, args);
  4319. // 如果没问题就直接返回了
  4320. if (errorCheck(res)) {
  4321. return res;
  4322. }
  4323. // 否则抛出异常以进行下一次重试
  4324. throw res;
  4325. }
  4326. catch (error) {
  4327. err = error;
  4328. }
  4329. }
  4330. throw err;
  4331. });
  4332. },
  4333. });
  4334. }
  4335.  
  4336. /**
  4337. * 包装一个函数为有错误重试功能的函数
  4338. * 注意: 该函数是并行运行,所以一旦调用,就会同时调用 n 次,不管之前有没有失败。。。此函数不适合包装有副作用的操作,例如修改用户信息,请使用 {@link trySometime} 替代
  4339. * @param fn 需要被包装的函数
  4340. * @param num 调用的次数。默认为 1
  4341. * @param errorCheck 检查返回结果是否需要重试的函数。默认只要 resolve() 就返回 true
  4342. * @returns 包装后的有错误重试功能的函数
  4343. */
  4344. function trySometimeParallel(fn, num = 1, errorCheck = res => true) {
  4345. return new Proxy(fn, {
  4346. apply(target, thisArg, args) {
  4347. return __awaiter(this, void 0, void 0, function* () {
  4348. return new Promise((resolve, reject) => __awaiter(this, void 0, void 0, function* () {
  4349. let err;
  4350. try {
  4351. yield Promise.all(range(0, num).map(() => __awaiter(this, void 0, void 0, function* () {
  4352. try {
  4353. const res = yield Reflect.apply(target, thisArg, args);
  4354. if (errorCheck(res) === true) {
  4355. resolve(res);
  4356. }
  4357. throw res;
  4358. }
  4359. catch (error) {
  4360. err = error;
  4361. }
  4362. })));
  4363. }
  4364. catch (error) {
  4365. console.log(error);
  4366. }
  4367. reject(err);
  4368. }));
  4369. });
  4370. },
  4371. });
  4372. }
  4373.  
  4374. /**
  4375. * 深度比较两个对象是否相等
  4376. * @param x 任何对象
  4377. * @param y 任何对象
  4378. * @returns 是否相等
  4379. */
  4380. function compare(x, y) {
  4381. if ((typeof x === 'number' || x instanceof Number) &&
  4382. (typeof y === 'number' || y instanceof Number)) {
  4383. const _x = +x;
  4384. const _y = +y;
  4385. // 如果都是 NaN 则直接返回 true
  4386. if (isNaN(_x) && isNaN(_y)) {
  4387. return true;
  4388. }
  4389. // 如果是 -0/+0 则返回 false
  4390. if (_x === _y) {
  4391. return 1 / _x === 1 / _y;
  4392. }
  4393. // 如果均为数字且两数之差的绝对值小于浮点数的最小精度(此举主要是为了避免浮点数的精度丢失)
  4394. if (Math.abs(_x - _y) < Number.EPSILON) {
  4395. return true;
  4396. }
  4397. }
  4398. // 如果恒等表达式成立则直接返回 true
  4399. if (x === y) {
  4400. return true;
  4401. }
  4402. // 比较正则和字符串
  4403. if ((x instanceof RegExp && y instanceof RegExp) ||
  4404. ((typeof x === 'string' || x instanceof String) &&
  4405. (typeof y === 'string' || y instanceof String))) {
  4406. return x.toString() === y.toString();
  4407. }
  4408. // 如果都是时间则比较它们的时间戳
  4409. if (x instanceof Date && y instanceof Date) {
  4410. return x.getTime() === y.getTime();
  4411. }
  4412. // 如果两者有一个不是 Object 类型的话则直接返回 false
  4413. // 注: 此处直接返回 false 是因为特殊原生类型的都在上面处理过了
  4414. // 注: Array 可以按照 Object 的逻辑进行处理
  4415. if (!(x instanceof Object && y instanceof Object)) {
  4416. return false;
  4417. }
  4418. // 比较它们的原型
  4419. if (x.prototype !== y.prototype) {
  4420. return false;
  4421. }
  4422. // 比较构造函数
  4423. if (x.constructor !== y.constructor) {
  4424. return false;
  4425. }
  4426. // 比较 y 中的属性是否全部都在 x 中
  4427. for (const p of Object.keys(y)) {
  4428. if (!Reflect.has(x, p)) {
  4429. return false;
  4430. }
  4431. }
  4432. // 比较 x 中的属性是否全部都在 y 中
  4433. for (const p of Object.keys(x)) {
  4434. if (!Reflect.has(y, p)) {
  4435. return false;
  4436. }
  4437. // 比较每个元素的类型,如果不同则直接返回 false
  4438. if (typeof y[p] !== typeof x[p]) {
  4439. return false;
  4440. }
  4441. // 递归比较每个元素
  4442. if (!compare(x[p], y[p])) {
  4443. return false;
  4444. }
  4445. }
  4446. // 全部比较完成仍然没有结果就返回 true
  4447. return true;
  4448. }
  4449.  
  4450. /**
  4451. * 阻塞主线程指定时间
  4452. * 注: 和 {@see wait} 不同,该函数会真的阻塞住主线程,即这段时间内其他的代码都无法执行,例如用户的点击事件!
  4453. * @param time 阻塞毫秒数
  4454. */
  4455. function sleep(time) {
  4456. const end = performance.now() + time;
  4457. while (performance.now() <= end) { }
  4458. }
  4459.  
  4460. /**
  4461. * 包装一个函数为异步函数
  4462. * 如果是一个异步函数,则直接返回,否则返回一部函数
  4463. * @param fn 任意一个函数
  4464. * @returns 返回的异步结果 Promise 对象
  4465. * @typeparam R 原函数函数返回值类型
  4466. */
  4467. function async(fn) {
  4468. return new Proxy(fn, {
  4469. apply(_, _this, args) {
  4470. return __awaiter(this, void 0, void 0, function* () {
  4471. return yield Reflect.apply(_, _this, args);
  4472. });
  4473. },
  4474. });
  4475. }
  4476.  
  4477. /**
  4478. * 将一个异步函数包装为具有时序的异步函数
  4479. * 注: 该函数会按照调用顺序依次返回结果,后面的调用的结果需要等待前面的,所以如果不关心过时的结果,请使用 {@link switchMap} 函数
  4480. * @param fn 一个普通的异步函数
  4481. * @returns 包装后的函数
  4482. */
  4483. function mergeMap(fn) {
  4484. // 当前执行的异步操作 id
  4485. let id = 0;
  4486. // 所执行的异步操作 id 列表
  4487. const ids = new Set();
  4488. return new Proxy(fn, {
  4489. apply(_, _this, args) {
  4490. return __awaiter(this, void 0, void 0, function* () {
  4491. const prom = Reflect.apply(_, _this, args);
  4492. const temp = id;
  4493. ids.add(temp);
  4494. id++;
  4495. yield wait(() => !ids.has(temp - 1));
  4496. ids.delete(temp);
  4497. return yield prom;
  4498. });
  4499. },
  4500. });
  4501. }
  4502.  
  4503. /**
  4504. * 将一个异步函数包装为具有时序的异步函数
  4505. * 注: 该函数会丢弃过期的异步操作结果,这样的话性能会稍稍提高(主要是响应比较快的结果会立刻生效而不必等待前面的响应结果)
  4506. * @param fn 一个普通的异步函数
  4507. * @returns 包装后的函数
  4508. */
  4509. function switchMap(fn) {
  4510. // 当前执行的异步操作 id
  4511. let id = 0;
  4512. // 最后一次异步操作的 id,小于这个的操作结果会被丢弃
  4513. let last = 0;
  4514. // 缓存最后一次异步操作的结果
  4515. let cache;
  4516. return new Proxy(fn, {
  4517. apply(_, _this, args) {
  4518. return __awaiter(this, void 0, void 0, function* () {
  4519. const temp = id;
  4520. id++;
  4521. const res = yield Reflect.apply(_, _this, args);
  4522. if (temp < last) {
  4523. return cache;
  4524. }
  4525. cache = res;
  4526. last = temp;
  4527. return res;
  4528. });
  4529. },
  4530. });
  4531. }
  4532.  
  4533. /**
  4534. * 将指定函数包装为只调用一次,其他的调用返回旧值
  4535. * 主要适用场景是只允许调用一次的地方,例如 Tab 的初始化
  4536. * * 示意图:
  4537. * a => b => c => d => e =>
  4538. * a ==|====|====|====|====>
  4539. * |b |c |d |e (die)
  4540. *
  4541. * @param fn 需要包装的函数
  4542. * @returns 包装后的函数
  4543. */
  4544. function once(fn) {
  4545. let flag = true;
  4546. let cache;
  4547. const res = new Proxy(fn, {
  4548. apply(target, thisArg, args) {
  4549. if (!flag) {
  4550. return cache;
  4551. }
  4552. flag = false;
  4553. // 如果是异步函数则返回异步的结果
  4554. return compatibleAsync(Reflect.apply(target, thisArg, args), res => {
  4555. cache = res;
  4556. return cache;
  4557. });
  4558. },
  4559. });
  4560. return Object.assign(res, {
  4561. origin: fn,
  4562. clear() {
  4563. cache = null;
  4564. },
  4565. });
  4566. }
  4567.  
  4568. /**
  4569. * 将一个异步函数包装为具有时序的异步函数
  4570. * 注: 该函数会按照调用顺序依次返回结果,后面的执行的调用(不是调用结果)需要等待前面的,此函数适用于异步函数的内里执行也必须保证顺序时使用,否则请使用 {@link mergeMap} 函数
  4571. * 注: 该函数其实相当于调用 {@code asyncLimiting(fn, {limit: 1})} 函数
  4572. * 例如即时保存文档到服务器,当然要等待上一次的请求结束才能请求下一次,不然数据库保存的数据就存在谬误了
  4573. * @param fn 一个普通的异步函数
  4574. * @returns 包装后的函数
  4575. */
  4576. function concatMap(fn) {
  4577. // 当前执行的异步操作 id
  4578. let id = 0;
  4579. // 所执行的异步操作 id 列表
  4580. const ids = new Set();
  4581. return new Proxy(fn, {
  4582. apply(_, _this, args) {
  4583. return __awaiter(this, void 0, void 0, function* () {
  4584. const temp = id;
  4585. ids.add(temp);
  4586. id++;
  4587. yield wait(() => !ids.has(temp - 1));
  4588. const res = yield Reflect.apply(_, _this, args);
  4589. ids.delete(temp);
  4590. return res;
  4591. });
  4592. },
  4593. });
  4594. }
  4595.  
  4596. /**
  4597. * 重复执行指定的函数
  4598. * @param num 重复的次数
  4599. * @param fn 执行的函数,如果是异步函数,则返回 Array.<Promise>
  4600. * @param {...Object} args 参数
  4601. * @returns 执行返回结果
  4602. */
  4603. function repeatedCall(num, fn, ...args) {
  4604. return range(0, num).map(() => fn(...args));
  4605. }
  4606.  
  4607. /**
  4608. * 发布订阅模式
  4609. * @typeparam T 订阅主题的类型,虽然可以为 any,但这里是刻意进行限制以避免 “全局” 的发布订阅中心对象
  4610. * @deprecated 已废弃,请使用语义更好、类型安全且 API 更强大的 {@see EventEmitter} 进行事件总线处理
  4611. */
  4612. class PubSubMachine {
  4613. constructor() {
  4614. /**
  4615. * 订阅者集合
  4616. */
  4617. this.subMap = new Map();
  4618. }
  4619. /**
  4620. * 发布一个主题
  4621. * @param topic 发布的主题
  4622. * @param [args] 主题订阅所需要的参数
  4623. */
  4624. pub(topic, ...args) {
  4625. const fns = this.subMap.get(topic);
  4626. if (fns === undefined) {
  4627. return;
  4628. }
  4629. fns.forEach(fn => fn(...args));
  4630. }
  4631. /**
  4632. * 订阅一个主题
  4633. * @param topic 订阅的主题
  4634. * @param fn 回调的函数
  4635. */
  4636. sub(topic, fn) {
  4637. if (!this.subMap.has(topic)) {
  4638. this.subMap.set(topic, []);
  4639. }
  4640. this.subMap.get(topic).push(fn);
  4641. }
  4642. /**
  4643. * 取消订阅
  4644. * @param topic 订阅的主题
  4645. * @param fn 订阅的函数,没有则删除这个主题下所有的函数
  4646. */
  4647. unsub(topic, fn) {
  4648. if (fn === undefined) {
  4649. this.subMap.delete(topic);
  4650. return;
  4651. }
  4652. if (!this.subMap.has(topic)) {
  4653. return;
  4654. }
  4655. const fns = this.subMap.get(topic);
  4656. fns.splice(fns.indexOf(fn), 1);
  4657. }
  4658. }
  4659.  
  4660. /**
  4661. * 提取对象数组为 Map
  4662. * @param arr 对象数组
  4663. * @param fields 提取的字段
  4664. * @returns 提取字段名对应其字段值数组的 Map
  4665. * @typeparam T 数组元素的类型,必须为可提取字段的对象
  4666. */
  4667. function extractFieldMap(arr, fields) {
  4668. return arr.reduce((res, v) => {
  4669. for (const [k, _arr] of res) {
  4670. _arr.push(Reflect.get(v, k));
  4671. }
  4672. return res;
  4673. }, arrayToMap(fields, k => k, () => new Array()));
  4674. }
  4675.  
  4676. /**
  4677. * 数组按照指定长度进行分段为二维数组
  4678. * 注: num 必须要大于 1
  4679. * @param arr 要进行分段的数组
  4680. * @param num 每段的长度
  4681. * @returns 分段后的二维数组
  4682. */
  4683. function segmentation(arr, num) {
  4684. return arr.reduce((res, v, i) => {
  4685. const index = (i + 1) % num;
  4686. if (index === 1) {
  4687. res.push([]);
  4688. }
  4689. res[res.length - 1].push(v);
  4690. return res;
  4691. }, new Array());
  4692. }
  4693.  
  4694. /**
  4695. * 切换 DOM 元素的 class
  4696. * @param {Element} el DOM 元素
  4697. * @param {Object} obj 切换的状态/class 键值对象
  4698. * @return 根据状态切换 class 的函数
  4699. */
  4700. function toggleClass(el, obj) {
  4701. const arr = Array.from(Object.values(obj));
  4702. /**
  4703. * 返回切换 class 的函数
  4704. * @param state 切换的状态
  4705. */
  4706. return function toggle(state) {
  4707. arr.forEach(v => el.classList.remove(v));
  4708. el.classList.add(obj[state]);
  4709. };
  4710. }
  4711.  
  4712. /**
  4713. * 将函数包装为偏函数
  4714. * 注: 该函数模仿了 underscore 的 partial 函数
  4715. * @param fn 需要包装的函数
  4716. * @param {...any} args 应用的部分参数
  4717. * @returns 包装后的函数
  4718. */
  4719. function partial(fn, ...args) {
  4720. const realArgs = args.filter(arg => arg !== partial._);
  4721. // 如果函数参数足够则调用传入的函数
  4722. if (realArgs.length >= fn.length) {
  4723. return fn(...realArgs);
  4724. }
  4725. /**
  4726. * 最终返回的函数
  4727. * @param otherArgs 接受任意参数
  4728. * @returns 返回一个函数,或者函数调用完成返回结果
  4729. */
  4730. function innerFn(...otherArgs) {
  4731. // 记录需要移除补到前面的参数
  4732. const removeIndexSet = new Set();
  4733. let i = 0;
  4734. const newArgs = args.map(arg => {
  4735. if (arg !== partial._ ||
  4736. otherArgs[i] === undefined ||
  4737. otherArgs[i] === partial._) {
  4738. return arg;
  4739. }
  4740. removeIndexSet.add(i);
  4741. // 每次补偿前面的 partial._ 参数计数器 +1
  4742. return otherArgs[i++];
  4743. });
  4744. const newOtherArgs = otherArgs.filter((_v, i) => !removeIndexSet.has(i));
  4745. return partial(fn, ...newArgs, ...newOtherArgs);
  4746. }
  4747. // 定义偏函数的剩余参数长度,便于在其他地方进行部分参数应用
  4748. // 注: 不使用 length 属性的原因是 length 属性
  4749. innerFn._length = fn.length - args.filter(arg => arg !== partial._).length;
  4750. // 自定义 toString 函数便于调试
  4751. innerFn.toString = () => `name: ${fn.name}, args: [${args.map(o => o.toString()).join(', ')}]`;
  4752. innerFn._partial = true;
  4753. return innerFn;
  4754. }
  4755. /**
  4756. * 偏的占位符,需要应用后面的参数时使用
  4757. * 例如 {@link partial(fn)(partial._, 1)} 意味着函数 fn 的第二个参数将被确定为 1
  4758. */
  4759. partial._ = Symbol('_');
  4760.  
  4761. /**
  4762. * 事件工具类
  4763. */
  4764. class EventUtil {
  4765. static add(dom, type, listener, options) {
  4766. if (!EventUtil.listenerMap.has(dom)) {
  4767. EventUtil.listenerMap.set(dom, []);
  4768. }
  4769. EventUtil.listenerMap.get(dom).push({
  4770. type,
  4771. listener,
  4772. options,
  4773. });
  4774. dom.addEventListener(type, listener, options);
  4775. }
  4776. static remove(dom, type, listener, options) {
  4777. dom.removeEventListener(type, listener, options);
  4778. EventUtil.listenerMap.set(dom, (EventUtil.listenerMap.get(dom) || []).filter(cacheListener => cacheListener.type !== type ||
  4779. cacheListener.listener !== listener ||
  4780. cacheListener.options !== options));
  4781. }
  4782. static removeByType(dom, type, options) {
  4783. const listenerList = EventUtil.listenerMap.get(dom);
  4784. if (listenerList === undefined) {
  4785. return [];
  4786. }
  4787. const map = groupBy(listenerList, cacheListener => type === cacheListener.type && options === cacheListener.options);
  4788. const removeCacheListenerList = map.get(true) || [];
  4789. const retainCacheListenerList = map.get(true) || [];
  4790. EventUtil.listenerMap.set(dom, retainCacheListenerList);
  4791. return removeCacheListenerList.map(cacheListener => {
  4792. dom.removeEventListener(cacheListener.type, cacheListener.listener, cacheListener.options);
  4793. return cacheListener;
  4794. });
  4795. }
  4796. }
  4797. /**
  4798. * 缓存的事件监听对象映射表
  4799. */
  4800. EventUtil.listenerMap = new Map();
  4801.  
  4802. /**
  4803. * 加载一个远程样式文件
  4804. * @param href 远程 CSS 样式路径
  4805. * @returns 等待异步加载样式完成
  4806. */
  4807. function loadStyle(href) {
  4808. return new Promise((resolve, reject) => {
  4809. const link = document.createElement('link');
  4810. link.rel = 'stylesheet';
  4811. link.href = href;
  4812. link.addEventListener('load', () => resolve());
  4813. link.addEventListener('error', reject);
  4814. document.body.appendChild(link);
  4815. });
  4816. }
  4817.  
  4818. /**
  4819. * 补 0 函数
  4820. * @param time 为时分秒补首位 0
  4821. * @returns 补零得到的字符串
  4822. */
  4823. function zeroPadding(time) {
  4824. return (time >= 10 ? '' : '0') + time;
  4825. }
  4826. /**
  4827. * 秒表
  4828. * 标准格式 `HH:mm:ss`
  4829. * 主要适用场景是格式化/解析时间差值
  4830. */
  4831. class Stopwatch {
  4832. /**
  4833. * 格式化一个以秒为单位的绝对时间为标准时间格式的字符串
  4834. * @param time 时间/s
  4835. * @returns 格式化后的字符串
  4836. */
  4837. static format(time) {
  4838. const seconds = time % 60;
  4839. const minutes = Math.floor(time / 60) % 60;
  4840. const hours = Math.floor(time / 60 / 60);
  4841. return `${zeroPadding(hours)}:${zeroPadding(minutes)}:${zeroPadding(seconds)}`;
  4842. }
  4843. /**
  4844. * 解析一个标准的时间字符串为秒为单位的绝对时间
  4845. * @param str 时间字符串
  4846. * @returns 解析得到的时间/s
  4847. */
  4848. static parse(str) {
  4849. const [, hours, minutes, seconds] = /(\d+):(\d+):(\d+)/.exec(str);
  4850. return (parseInt(hours) * 60 * 60 + parseInt(minutes) * 60 + parseInt(seconds));
  4851. }
  4852. }
  4853.  
  4854. /**
  4855. * 提醒用户当前页面有正在执行的操作,暂时不能离开
  4856. * 注:用户实际上可以不管该提醒
  4857. * @param fn 谓词,是否要提醒不要关闭
  4858. * @returns 返回删除这个事件监听的函数
  4859. */
  4860. function remindLeavePage(fn = () => false) {
  4861. const listener = (e) => {
  4862. if (fn()) {
  4863. return false;
  4864. }
  4865. const confirmationMessage = '请不要关闭页面';
  4866. e.returnValue = confirmationMessage; //Gecko + IE
  4867. return confirmationMessage; //Webkit, Safari, Chrome etc.
  4868. };
  4869. window.addEventListener('beforeunload', listener);
  4870. return () => window.removeEventListener('beforeunload', listener);
  4871. }
  4872.  
  4873. /**
  4874. * 事件总线
  4875. * 实际上就是发布订阅模式的一种简单实现
  4876. * 类型定义受到 {@link https://github.com/andywer/typed-emitter/blob/master/index.d.ts} 的启发,不过只需要声明参数就好了,而不需要返回值(应该是 {@code void})
  4877. */
  4878. class EventEmitter {
  4879. constructor() {
  4880. this.events = new Map();
  4881. }
  4882. /**
  4883. * 添加一个事件监听程序
  4884. * @param type 监听类型
  4885. * @param callback 处理回调
  4886. * @returns {@code this}
  4887. */
  4888. add(type, callback) {
  4889. const callbacks = this.events.get(type) || [];
  4890. callbacks.push(callback);
  4891. this.events.set(type, callbacks);
  4892. return this;
  4893. }
  4894. /**
  4895. * 移除一个事件监听程序
  4896. * @param type 监听类型
  4897. * @param callback 处理回调
  4898. * @returns {@code this}
  4899. */
  4900. remove(type, callback) {
  4901. const callbacks = this.events.get(type) || [];
  4902. this.events.set(type, callbacks.filter((fn) => fn !== callback));
  4903. return this;
  4904. }
  4905. /**
  4906. * 移除一类事件监听程序
  4907. * @param type 监听类型
  4908. * @returns {@code this}
  4909. */
  4910. removeByType(type) {
  4911. this.events.delete(type);
  4912. return this;
  4913. }
  4914. /**
  4915. * 触发一类事件监听程序
  4916. * @param type 监听类型
  4917. * @param args 处理回调需要的参数
  4918. * @returns {@code this}
  4919. */
  4920. emit(type, ...args) {
  4921. const callbacks = this.events.get(type) || [];
  4922. callbacks.forEach(fn => {
  4923. fn(...args);
  4924. });
  4925. return this;
  4926. }
  4927. /**
  4928. * 获取一类事件监听程序
  4929. * @param type 监听类型
  4930. * @returns 一个只读的数组,如果找不到,则返回空数组 {@code []}
  4931. */
  4932. listeners(type) {
  4933. return Object.freeze(this.events.get(type) || []);
  4934. }
  4935. }
  4936.  
  4937. /**
  4938. * 一个简单的微任务队列辅助类,使用(宏)命令模式实现
  4939. * 注:该 class 是为了解决问题 https://segmentfault.com/q/1010000019115775
  4940. */
  4941. class MicrotaskQueue {
  4942. constructor() {
  4943. // task 列表
  4944. this.tasks = [];
  4945. // 当前是否存在正在执行的 task
  4946. this.lock = false;
  4947. }
  4948. add(func) {
  4949. this.tasks.push(func);
  4950. this.execute();
  4951. return this;
  4952. }
  4953. execute() {
  4954. if (this.lock) {
  4955. return;
  4956. }
  4957. this.lock = true;
  4958. const goNext = () => {
  4959. if (this.tasks.length) {
  4960. const task = this.tasks.shift();
  4961. compatibleAsync(task(), () => goNext());
  4962. }
  4963. else {
  4964. this.lock = false;
  4965. }
  4966. };
  4967. Promise.resolve().then(goNext);
  4968. }
  4969. }
  4970.  
  4971. /**
  4972. * 取值的字符串
  4973. */
  4974. const rangeStr = '0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz';
  4975. const rangeLen = rangeStr.length;
  4976. /**
  4977. * 生成一个随机字符串
  4978. * @param len
  4979. */
  4980. function randomStr(len) {
  4981. let res = '';
  4982. for (let i = 0; i < len; i++) {
  4983. res += rangeStr.charAt(Math.floor(Math.random() * rangeLen));
  4984. }
  4985. return res;
  4986. }
  4987.  
  4988. /**
  4989. * 解析字段字符串为数组
  4990. * @param str 字段字符串
  4991. * @returns 字符串数组,数组的 `[]` 取法会被解析为数组的一个元素
  4992. */
  4993. function parseFieldStr(str) {
  4994. return str
  4995. .split(/[\.\[]/)
  4996. .map(k => (/\]$/.test(k) ? k.slice(0, k.length - 1) : k));
  4997. }
  4998.  
  4999. /**
  5000. * 安全的深度获取对象的字段
  5001. * TODO 该函数尚处于早期测试阶段
  5002. * 注: 只要获取字段的值为 {@type null|undefined},就会直接返回 {@param defVal}
  5003. * 类似于 ES2019 的可选调用链特性: https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/Operators/%E5%8F%AF%E9%80%89%E9%93%BE
  5004. * @param obj 获取的对象
  5005. * @param fields 字段字符串或数组
  5006. * @param [defVal] 取不到值时的默认值,默认为 null
  5007. */
  5008. function get(obj, fields, defVal = null) {
  5009. if (TypeValidator.isString(fields)) {
  5010. fields = parseFieldStr(fields);
  5011. }
  5012. let res = obj;
  5013. for (const field of fields) {
  5014. try {
  5015. res = Reflect.get(res, field);
  5016. if (isNullOrUndefined(res)) {
  5017. return defVal;
  5018. }
  5019. }
  5020. catch (e) {
  5021. return defVal;
  5022. }
  5023. }
  5024. return res;
  5025. }
  5026.  
  5027. /**
  5028. * 安全的深度设置对象的字段
  5029. * TODO 该函数尚处于早期测试阶段
  5030. * 注: 只要设置字段的值为 {@type null|undefined},就会直接返回 {@param defVal}
  5031. * 类似于 ES2019 的可选调用链特性: https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/Operators/%E5%8F%AF%E9%80%89%E9%93%BE
  5032. * @param obj 设置的对象
  5033. * @param fields 字段字符串或数组
  5034. * @param [val] 设置字段的值
  5035. */
  5036. function set(obj, fields, val) {
  5037. if (TypeValidator.isString(fields)) {
  5038. fields = parseFieldStr(fields);
  5039. }
  5040. let res = obj;
  5041. for (let i = 0, len = fields.length; i < len; i++) {
  5042. const field = fields[i];
  5043. if (i === len - 1) {
  5044. res[field] = val;
  5045. return true;
  5046. }
  5047. res = res[field];
  5048. if (!TypeValidator.isObject(res)) {
  5049. return false;
  5050. }
  5051. }
  5052. return false;
  5053. }
  5054.  
  5055. /**
  5056. * 获取当前选中的文本
  5057. * @returns 当前选中的文本
  5058. */
  5059. function getSelectText() {
  5060. return getSelection().toString();
  5061. }
  5062.  
  5063. /**
  5064. * 获取图片的尺寸
  5065. * @param url
  5066. */
  5067. function imageSize(url) {
  5068. return new Promise((resolve, reject) => {
  5069. const image = new Image();
  5070. image.addEventListener('load', function () {
  5071. resolve({
  5072. width: this.width,
  5073. height: this.height,
  5074. });
  5075. });
  5076. image.addEventListener('error', ev => {
  5077. reject(ev.error);
  5078. });
  5079. image.src = url;
  5080. });
  5081. }
  5082.  
  5083. /**
  5084. * 获取鼠标的位置
  5085. * @param e 触发的鼠标事件对象
  5086. * @returns 鼠标的坐标
  5087. */
  5088. function getMousePos(e) {
  5089. const scrollX = document.documentElement.scrollLeft || document.body.scrollLeft;
  5090. const scrollY = document.documentElement.scrollTop || document.body.scrollTop;
  5091. const x = e.pageX || e.clientX + scrollX;
  5092. const y = e.pageY || e.clientY + scrollY;
  5093. return { x, y };
  5094. }
  5095.  
  5096. /**
  5097. * 将多个并发异步调用合并为一次批处理
  5098. * @param handle 批处理的函数
  5099. * @param ms 等待的时长(时间越长则可能合并的调用越多,否则将使用微任务只合并一次同步执行的所有调用)
  5100. */
  5101. function batch(handle, ms = 0) {
  5102. //参数 => 结果 映射
  5103. const resultMap = new Map();
  5104. //参数列表
  5105. const paramSet = new Set();
  5106. //当前是否被锁定
  5107. let lock = false;
  5108. return function (...argArray) {
  5109. return __awaiter(this, void 0, void 0, function* () {
  5110. paramSet.add(argArray);
  5111. yield Promise.all([wait(() => resultMap.has(argArray) || !lock), wait(ms)]);
  5112. if (!resultMap.has(argArray)) {
  5113. try {
  5114. lock = true;
  5115. Array.from(yield handle(Array.from(paramSet))).forEach(([k, v]) => {
  5116. resultMap.set(k, v);
  5117. });
  5118. }
  5119. finally {
  5120. lock = false;
  5121. }
  5122. }
  5123. const value = resultMap.get(argArray);
  5124. paramSet.delete(argArray);
  5125. resultMap.delete(argArray);
  5126. // noinspection SuspiciousTypeOfGuard
  5127. if (value instanceof Error) {
  5128. throw value;
  5129. }
  5130. return value;
  5131. });
  5132. };
  5133. }
  5134.  
  5135. exports.AntiDebug = AntiDebug;
  5136. exports.ArrayValidator = ArrayValidator;
  5137. exports.AsyncArray = AsyncArray;
  5138. exports.CacheUtil = CacheUtil;
  5139. exports.CombinedPredicate = CombinedPredicate;
  5140. exports.DateConstants = DateConstants;
  5141. exports.DateFormatter = DateFormatter;
  5142. exports.EventEmitter = EventEmitter;
  5143. exports.EventUtil = EventUtil;
  5144. exports.FetchLimiting = FetchLimiting;
  5145. exports.LocalStorageCache = LocalStorageCache;
  5146. exports.Locker = Locker;
  5147. exports.Logger = Logger;
  5148. exports.MicrotaskQueue = MicrotaskQueue;
  5149. exports.NodeBridgeUtil = NodeBridgeUtil;
  5150. exports.PathUtil = PathUtil;
  5151. exports.PubSubMachine = PubSubMachine;
  5152. exports.StateMachine = StateMachine;
  5153. exports.Stopwatch = Stopwatch;
  5154. exports.StringStyleUtil = StringStyleUtil;
  5155. exports.StringValidator = StringValidator;
  5156. exports.TypeValidator = TypeValidator;
  5157. exports.aggregation = aggregation;
  5158. exports.and = and;
  5159. exports.antiDebug = antiDebug;
  5160. exports.appends = appends;
  5161. exports.arrayDiffBy = arrayDiffBy;
  5162. exports.arrayToMap = arrayToMap;
  5163. exports.arrayValidator = arrayValidator;
  5164. exports.asIterator = asIterator;
  5165. exports.assign = assign;
  5166. exports.async = async;
  5167. exports.asyncFlatMap = asyncFlatMap;
  5168. exports.asyncLimiting = asyncLimiting;
  5169. exports.autoIncrement = autoIncrement;
  5170. exports.batch = batch;
  5171. exports.blankToNull = blankToNull;
  5172. exports.blankToNullField = blankToNullField;
  5173. exports.bridge = bridge;
  5174. exports.cacheUtil = cacheUtil;
  5175. exports.compare = compare;
  5176. exports.compatibleAsync = compatibleAsync;
  5177. exports.compose = compose;
  5178. exports.concatMap = concatMap;
  5179. exports.copyText = copyText;
  5180. exports.createElByString = createElByString;
  5181. exports.curry = curry;
  5182. exports.dateBetween = dateBetween;
  5183. exports.dateConstants = dateConstants;
  5184. exports.dateEnhance = dateEnhance;
  5185. exports.dateFormat = dateFormat;
  5186. exports.dateParse = dateParse;
  5187. exports.debounce = debounce;
  5188. exports.deepExcludeFields = deepExcludeFields;
  5189. exports.deepFreeze = deepFreeze;
  5190. exports.deepProxy = deepProxy;
  5191. exports.deletes = deletes;
  5192. exports.deny = deny;
  5193. exports.diffBy = diffBy;
  5194. exports.download = download;
  5195. exports.downloadString = downloadString;
  5196. exports.downloadUrl = downloadUrl;
  5197. exports.emptyAllField = emptyAllField;
  5198. exports.emptyFunc = emptyFunc;
  5199. exports.excludeFields = excludeFields;
  5200. exports.excludeFieldsDeep = excludeFieldsDeep;
  5201. exports.extractFieldMap = extractFieldMap;
  5202. exports.fetchTimeout = fetchTimeout;
  5203. exports.fill = fill;
  5204. exports.filterItems = filterItems;
  5205. exports.findIndex = findIndex;
  5206. exports.flatMap = flatMap;
  5207. exports.floatEquals = floatEquals;
  5208. exports.formDataToArray = formDataToArray;
  5209. exports.format = format;
  5210. exports.get = get;
  5211. exports.getCookies = getCookies;
  5212. exports.getCursorPosition = getCursorPosition;
  5213. exports.getCusorPostion = getCusorPostion;
  5214. exports.getKFn = getKFn;
  5215. exports.getMousePos = getMousePos;
  5216. exports.getObjectEntries = getObjectEntries;
  5217. exports.getObjectKeys = getObjectKeys;
  5218. exports.getSelectText = getSelectText;
  5219. exports.getYearWeek = getYearWeek;
  5220. exports.groupBy = groupBy;
  5221. exports.imageSize = imageSize;
  5222. exports.insertText = insertText;
  5223. exports.isBlank = isBlank;
  5224. exports.isEditable = isEditable;
  5225. exports.isEmpty = isEmpty;
  5226. exports.isFloat = isFloat;
  5227. exports.isNullOrUndefined = isNullOrUndefined;
  5228. exports.isNumber = isNumber;
  5229. exports.isRange = isRange;
  5230. exports.lastFocus = lastFocus;
  5231. exports.listToTree = listToTree;
  5232. exports.loadResource = loadResource;
  5233. exports.loadScript = loadScript;
  5234. exports.loadStyle = loadStyle;
  5235. exports.logger = logger;
  5236. exports.mapToObject = mapToObject;
  5237. exports.mergeMap = mergeMap;
  5238. exports.nodeBridgeUtil = nodeBridgeUtil;
  5239. exports.not = not;
  5240. exports.objToFormData = objToFormData;
  5241. exports.objectToMap = objectToMap;
  5242. exports.once = once;
  5243. exports.onceOfSameParam = onceOfSameParam;
  5244. exports.or = or;
  5245. exports.parseUrl = parseUrl;
  5246. exports.partial = partial;
  5247. exports.pathUtil = pathUtil;
  5248. exports.randomInt = randomInt;
  5249. exports.randomStr = randomStr;
  5250. exports.range = range;
  5251. exports.readLocal = readLocal;
  5252. exports.remindLeavePage = remindLeavePage;
  5253. exports.removeEl = removeEl;
  5254. exports.removeText = removeText;
  5255. exports.repeatedCall = repeatedCall;
  5256. exports.returnItself = returnItself;
  5257. exports.returnReasonableItself = returnReasonableItself;
  5258. exports.safeExec = safeExec;
  5259. exports.segmentation = segmentation;
  5260. exports.set = set;
  5261. exports.setCursorPosition = setCursorPosition;
  5262. exports.setCusorPostion = setCusorPostion;
  5263. exports.sets = sets;
  5264. exports.singleModel = singleModel;
  5265. exports.sleep = sleep;
  5266. exports.sortBy = sortBy;
  5267. exports.spliceParams = spliceParams;
  5268. exports.strToArrayBuffer = strToArrayBuffer;
  5269. exports.strToDate = strToDate;
  5270. exports.stringValidator = stringValidator;
  5271. exports.switchMap = switchMap;
  5272. exports.throttle = throttle;
  5273. exports.timing = timing;
  5274. exports.toLowerCase = toLowerCase;
  5275. exports.toObject = toObject;
  5276. exports.toString = toString$1;
  5277. exports.toUpperCase = toUpperCase;
  5278. exports.toggleClass = toggleClass;
  5279. exports.treeMapping = treeMapping;
  5280. exports.treeToList = treeToList;
  5281. exports.trySometime = trySometime;
  5282. exports.trySometimeParallel = trySometimeParallel;
  5283. exports.uniqueBy = uniqueBy;
  5284. exports.wait = wait;
  5285. exports.waitResource = waitResource;
  5286. exports.watch = watch;
  5287. exports.watchEventListener = watchEventListener;
  5288. exports.watchObject = watchObject;
  5289.  
  5290. Object.defineProperty(exports, '__esModule', { value: true });
  5291.  
  5292. })));
  5293. //# sourceMappingURL=rx-util.js.map