devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

uniapp微信小程序实现大文件上传 分片上传 进度条_miniprogram-file-uploader

作者：盐析白兔 | 2024-02-07 17:59:05

赞

踩

miniprogram-file-uploader

一、安装  

npm i miniprogram-file-uploader

二、页面引入

    import Uploader from 'miniprogram-file-uploader'

 三、实现功能（重要）

        1.获取图片的路径

        2.设置分片的大小

        3.将数据放入

  1. 	let obj = this.uploadItem //图片路径或者视频路径 可以通过chooseMedia的api进行获取
  2. 				var tempFilePath = obj.tempFilePath
  3. 				var file = {//重点，分片要的参数 
  4. 					ext_file_name: '',
  5. 					index: 0,
  6. 					chunkSize: 1024 * 1024 * 0.5 //分片0.5M 根据自己的分片需求设置一片多大
  7. 				}
  8. 				file.ext_file_name = obj.tempFilePath
  9. 				file.index = Math.ceil(obj.size / file.chunkSize) //获取索引
  10. 				var opt = {
  11. 					fileName: file.ext_file_name,
  12. 					totalSize: obj.size,
  13. 					chunkSize: file.chunkSize,
  14. 					query: { //后端需要的参数
  15. 						activity_id: this.activity_id,
  16. 						file_type: this.file_type,
  17. 						total_size: obj.size,
  18. 						ext_file_name: file.ext_file_name
  19. 					},
  20. 					timeout: 180000, //请求超时时间，默认 10000 ms
  21. 					verifyUrl: 'https://xxxxxxx/upload/b2b3.0/digital_activity/?act=verify',//后端提供接口路径
  22. 					uploadUrl: 'https://xxxxxxx/upload/b2b3.0/digital_activity/?act=upload',//后端提供接口路径
  23. 					mergeUrl: `https://xxxxxxx/upload/b2b3.0/digital_activity/?act=merge&activity_id=${this.activity_id}&file_type=${this.file_type}&ext_file_name=${file.ext_file_name}`, //合并分块   //后端提供接口路径 参数自己传
  24. 					tempFilePath: tempFilePath //图片路径
  25. 				}
  26. 				const uploader = new Uploader(opt)//在这里扭一下

四、实现上传进度条

  1. <view class="prompt_box" >
  2. 	<view class="prompt_top">
  3. 		<view class="prompt_title two_ti">正在提交</view>
  4. 		<view class="prompt_tow">
  5. 			<view class="">
  6. 				<progress :percent="upload.progress" stroke-width="4px" class="progress"
  7. 									:activeColor='theme_config.theme_color' show-info="true" font-size="15px"
  8. 									border-radius="4px"></progress>
  9. 			</view>
  10. 			<view class="">正在上传，请耐心等待</view>
  11. 		</view>
  12. 	</view>
  13. 	<view class="prompt_but two" @click="CancelSubmission">
  14. 		<view>取消提交</view>
  15. 		</view>
  16. </view>
  1. data(){
  2. return{
  3. 	upload: { //上传进度
  4. 					// eq: -1,
  5. 					size: 0,
  6. 					progress: 0,
  7. 					uploadedSize: 0,
  8. 					averageSpeed: 0,
  9. 					timeRemaining: 0
  10. 				},
  11. }
  12.  
  13. }
  14.  
  15.  
  16.  
  17.  
  18.  
  19. //js------
  20.  
  21.                 const uploader = new Uploader(opt)//在这里扭一下
  22. 				uploader.on('complete', (res) => {})
  23.  
  24. 				uploader.on('retry', (res) => {})
  25. 				uploader.on('success', (res) => {
  26. 					if (res.result.status_info.status_code == 100) {
  27. 						this.PostSubmitWork(res.result.build_info)
  28. 					}
  29. 				})
  30. 				uploader.on('fail', (res) => {
  31. 					this.isupload = false
  32. 				})
  33.  
  34. 				uploader.on('progress', (res) => { //上传进度这里是进度条提供
  35. 					var tmp = {
  36. 						size: obj.size / 1024,
  37. 						progress: res.progress,
  38. 						uploadedSize: parseInt(res.uploadedSize / 1024),
  39. 						averageSpeed: parseInt(res.averageSpeed / 1024),
  40. 						timeRemaining: res.timeRemaining / 1000
  41. 					}
  42. 					this.upload = tmp//进度的所有数据
  43. 				})

全部函数js

  1. 	// 上传逻辑
  2. 			uploadOne() {
  3. 				let obj = this.uploadItem //图片路径或者视频路径 可以通过chooseMedia的api进行获取
  4. 				var tempFilePath = obj.tempFilePath
  5. 				var file = {//重点，分片要的参数 
  6. 					ext_file_name: '',
  7. 					index: 0,
  8. 					chunkSize: 1024 * 1024 * 0.5 //分片0.5M 根据自己的分片需求设置一片多大
  9. 				}
  10. 				file.ext_file_name = obj.tempFilePath
  11. 				file.index = Math.ceil(obj.size / file.chunkSize) //获取索引
  12. 				var opt = {
  13. 					fileName: file.ext_file_name,
  14. 					totalSize: obj.size,
  15. 					chunkSize: file.chunkSize,
  16. 					query: { //后端需要的参数
  17. 						activity_id: this.activity_id,
  18. 						file_type: this.file_type,
  19. 						total_size: obj.size,
  20. 						ext_file_name: file.ext_file_name
  21. 					},
  22. 					timeout: 180000, //请求超时时间，默认 10000 ms
  23. 					verifyUrl: 'https://xxxxxxx/upload/b2b3.0/digital_activity/?act=verify',//后端提供接口路径
  24. 					uploadUrl: 'https://xxxxxxx/upload/b2b3.0/digital_activity/?act=upload',//后端提供接口路径
  25. 					mergeUrl: `https://xxxxxxx/upload/b2b3.0/digital_activity/?act=merge&activity_id=${this.activity_id}&file_type=${this.file_type}&ext_file_name=${file.ext_file_name}`, //合并分块   //后端提供接口路径 参数自己传
  26. 					tempFilePath: tempFilePath //图片路径
  27. 				}
  28. 				const uploader = new Uploader(opt)//在这里扭一下
  29.  
  30. 				// 成功或失败都会触发
  31. 				uploader.on('complete', (res) => {})
  32.  
  33. 				uploader.on('retry', (res) => {})
  34. 				uploader.on('success', (res) => {
  35. 					if (res.result.status_info.status_code == 100) {
  36. 						this.PostSubmitWork(res.result.build_info)
  37. 					}
  38. 				})
  39. 				uploader.on('fail', (res) => {
  40. 					this.isupload = false
  41. 				})
  42.  
  43. 				uploader.on('progress', (res) => { //上传进度这里是进度条提供
  44. 					var tmp = {
  45. 						size: obj.size / 1024,
  46. 						progress: res.progress,
  47. 						uploadedSize: parseInt(res.uploadedSize / 1024),
  48. 						averageSpeed: parseInt(res.averageSpeed / 1024),
  49. 						timeRemaining: res.timeRemaining / 1000
  50. 					}
  51. 					this.upload = tmp
  52. 				})
  53. 				uploader.upload()
  54. 				this.uploader = uploader
  55. 			},

五、修改npm的源码，处理请求源码中请求所携带的参数问题，以及报错处理（重要）

修改npm后的源码。可直接用（需修改请求参数）
 

  1. /**
  2.  * miniprogram-uploader 1.0.0
  3.  * description: A JavaScript library supports miniprogram to upload large file.
  4.  * author: sanfordsun
  5.  * Released under the MIT License.
  6.  */
  7. import md5 from 'js-md5'
  8. var commonjsGlobal = typeof globalThis !== 'undefined' ? globalThis : typeof window !== 'undefined' ? window :
  9.   typeof global !== 'undefined' ? global : typeof self !== 'undefined' ? self : {};
  10.  
  11. function createCommonjsModule(fn, basedir, module) {
  12.   return module = {
  13.     path: basedir,
  14.     exports: {},
  15.     require: function(path, base) {
  16.       return commonjsRequire(path, (base === undefined || base === null) ? module.path : base);
  17.     }
  18.   }, fn(module, module.exports), module.exports;
  19. }
  20.  
  21. function commonjsRequire() {
  22.   throw new Error('Dynamic requires are not currently supported by @rollup/plugin-commonjs');
  23. }
  24.  
  25. var logger = createCommonjsModule(function(module) {
  26.   /*!
  27.    * js-logger - http://github.com/jonnyreeves/js-logger
  28.    * Jonny Reeves, http://jonnyreeves.co.uk/
  29.    * js-logger may be freely distributed under the MIT license.
  30.    */
  31.   (function(global) {
  32.  
  33.     // Top level module for the global, static logger instance.
  34.     var Logger = {};
  35.  
  36.     // For those that are at home that are keeping score.
  37.     Logger.VERSION = "1.6.0";
  38.  
  39.     // Function which handles all incoming log messages.
  40.     var logHandler;
  41.  
  42.     // Map of ContextualLogger instances by name; used by Logger.get() to return the same named instance.
  43.     var contextualLoggersByNameMap = {};
  44.  
  45.     // Polyfill for ES5's Function.bind.
  46.     var bind = function(scope, func) {
  47.       return function() {
  48.         return func.apply(scope, arguments);
  49.       };
  50.     };
  51.  
  52.     // Super exciting object merger-matron 9000 adding another 100 bytes to your download.
  53.     var merge = function() {
  54.       var args = arguments,
  55.         target = args[0],
  56.         key, i;
  57.       for (i = 1; i < args.length; i++) {
  58.         for (key in args[i]) {
  59.           if (!(key in target) && args[i].hasOwnProperty(key)) {
  60.             target[key] = args[i][key];
  61.           }
  62.         }
  63.       }
  64.       return target;
  65.     };
  66.  
  67.     // Helper to define a logging level object; helps with optimisation.
  68.     var defineLogLevel = function(value, name) {
  69.       return {
  70.         value: value,
  71.         name: name
  72.       };
  73.     };
  74.  
  75.     // Predefined logging levels.
  76.     Logger.TRACE = defineLogLevel(1, 'TRACE');
  77.     Logger.DEBUG = defineLogLevel(2, 'DEBUG');
  78.     Logger.INFO = defineLogLevel(3, 'INFO');
  79.     Logger.TIME = defineLogLevel(4, 'TIME');
  80.     Logger.WARN = defineLogLevel(5, 'WARN');
  81.     Logger.ERROR = defineLogLevel(8, 'ERROR');
  82.     Logger.OFF = defineLogLevel(99, 'OFF');
  83.  
  84.     // Inner class which performs the bulk of the work; ContextualLogger instances can be configured independently
  85.     // of each other.
  86.     var ContextualLogger = function(defaultContext) {
  87.       this.context = defaultContext;
  88.       this.setLevel(defaultContext.filterLevel);
  89.       this.log = this.info; // Convenience alias.
  90.     };
  91.  
  92.     ContextualLogger.prototype = {
  93.       // Changes the current logging level for the logging instance.
  94.       setLevel: function(newLevel) {
  95.         // Ensure the supplied Level object looks valid.
  96.         if (newLevel && "value" in newLevel) {
  97.           this.context.filterLevel = newLevel;
  98.         }
  99.       },
  100.  
  101.       // Gets the current logging level for the logging instance
  102.       getLevel: function() {
  103.         return this.context.filterLevel;
  104.       },
  105.  
  106.       // Is the logger configured to output messages at the supplied level?
  107.       enabledFor: function(lvl) {
  108.         var filterLevel = this.context.filterLevel;
  109.         return lvl.value >= filterLevel.value;
  110.       },
  111.  
  112.       trace: function() {
  113.         this.invoke(Logger.TRACE, arguments);
  114.       },
  115.  
  116.       debug: function() {
  117.         this.invoke(Logger.DEBUG, arguments);
  118.       },
  119.  
  120.       info: function() {
  121.         this.invoke(Logger.INFO, arguments);
  122.       },
  123.  
  124.       warn: function() {
  125.         this.invoke(Logger.WARN, arguments);
  126.       },
  127.  
  128.       error: function() {
  129.         this.invoke(Logger.ERROR, arguments);
  130.       },
  131.  
  132.       time: function(label) {
  133.         if (typeof label === 'string' && label.length > 0) {
  134.           this.invoke(Logger.TIME, [label, 'start']);
  135.         }
  136.       },
  137.  
  138.       timeEnd: function(label) {
  139.         if (typeof label === 'string' && label.length > 0) {
  140.           this.invoke(Logger.TIME, [label, 'end']);
  141.         }
  142.       },
  143.  
  144.       // Invokes the logger callback if it's not being filtered.
  145.       invoke: function(level, msgArgs) {
  146.         if (logHandler && this.enabledFor(level)) {
  147.           logHandler(msgArgs, merge({
  148.             level: level
  149.           }, this.context));
  150.         }
  151.       }
  152.     };
  153.  
  154.     // Protected instance which all calls to the to level `Logger` module will be routed through.
  155.     var globalLogger = new ContextualLogger({
  156.       filterLevel: Logger.OFF
  157.     });
  158.  
  159.     // Configure the global Logger instance.
  160.     (function() {
  161.       // Shortcut for optimisers.
  162.       var L = Logger;
  163.  
  164.       L.enabledFor = bind(globalLogger, globalLogger.enabledFor);
  165.       L.trace = bind(globalLogger, globalLogger.trace);
  166.       L.debug = bind(globalLogger, globalLogger.debug);
  167.       L.time = bind(globalLogger, globalLogger.time);
  168.       L.timeEnd = bind(globalLogger, globalLogger.timeEnd);
  169.       L.info = bind(globalLogger, globalLogger.info);
  170.       L.warn = bind(globalLogger, globalLogger.warn);
  171.       L.error = bind(globalLogger, globalLogger.error);
  172.  
  173.       // Don't forget the convenience alias!
  174.       L.log = L.info;
  175.     }());
  176.  
  177.     // Set the global logging handler.  The supplied function should expect two arguments, the first being an arguments
  178.     // object with the supplied log messages and the second being a context object which contains a hash of stateful
  179.     // parameters which the logging function can consume.
  180.     Logger.setHandler = function(func) {
  181.       logHandler = func;
  182.     };
  183.  
  184.     // Sets the global logging filter level which applies to *all* previously registered, and future Logger instances.
  185.     // (note that named loggers (retrieved via `Logger.get`) can be configured independently if required).
  186.     Logger.setLevel = function(level) {
  187.       // Set the globalLogger's level.
  188.       globalLogger.setLevel(level);
  189.  
  190.       // Apply this level to all registered contextual loggers.
  191.       for (var key in contextualLoggersByNameMap) {
  192.         if (contextualLoggersByNameMap.hasOwnProperty(key)) {
  193.           contextualLoggersByNameMap[key].setLevel(level);
  194.         }
  195.       }
  196.     };
  197.  
  198.     // Gets the global logging filter level
  199.     Logger.getLevel = function() {
  200.       return globalLogger.getLevel();
  201.     };
  202.  
  203.     // Retrieve a ContextualLogger instance.  Note that named loggers automatically inherit the global logger's level,
  204.     // default context and log handler.
  205.     Logger.get = function(name) {
  206.       // All logger instances are cached so they can be configured ahead of use.
  207.       return contextualLoggersByNameMap[name] ||
  208.         (contextualLoggersByNameMap[name] = new ContextualLogger(merge({
  209.           name: name
  210.         }, globalLogger.context)));
  211.     };
  212.  
  213.     // CreateDefaultHandler returns a handler function which can be passed to `Logger.setHandler()` which will
  214.     // write to the window's console object (if present); the optional options object can be used to customise the
  215.     // formatter used to format each log message.
  216.     Logger.createDefaultHandler = function(options) {
  217.       options = options || {};
  218.  
  219.       options.formatter = options.formatter || function defaultMessageFormatter(messages, context) {
  220.         // Prepend the logger's name to the log message for easy identification.
  221.         if (context.name) {
  222.           messages.unshift("[" + context.name + "]");
  223.         }
  224.       };
  225.  
  226.       // Map of timestamps by timer labels used to track `#time` and `#timeEnd()` invocations in environments
  227.       // that don't offer a native console method.
  228.       var timerStartTimeByLabelMap = {};
  229.  
  230.       // Support for IE8+ (and other, slightly more sane environments)
  231.       var invokeConsoleMethod = function(hdlr, messages) {
  232.         Function.prototype.apply.call(hdlr, console, messages);
  233.       };
  234.  
  235.       // Check for the presence of a logger.
  236.       if (typeof console === "undefined") {
  237.         return function() {
  238.           /* no console */
  239.         };
  240.       }
  241.  
  242.       return function(messages, context) {
  243.         // Convert arguments object to Array.
  244.         messages = Array.prototype.slice.call(messages);
  245.  
  246.         var hdlr = console.log;
  247.         var timerLabel;
  248.  
  249.         if (context.level === Logger.TIME) {
  250.           timerLabel = (context.name ? '[' + context.name + '] ' : '') + messages[0];
  251.  
  252.           if (messages[1] === 'start') {
  253.             if (console.time) {
  254.               console.time(timerLabel);
  255.             } else {
  256.               timerStartTimeByLabelMap[timerLabel] = new Date().getTime();
  257.             }
  258.           } else {
  259.             if (console.timeEnd) {
  260.               console.timeEnd(timerLabel);
  261.             } else {
  262.               invokeConsoleMethod(hdlr, [timerLabel + ': ' +
  263.                 (new Date().getTime() - timerStartTimeByLabelMap[timerLabel]) + 'ms'
  264.               ]);
  265.             }
  266.           }
  267.         } else {
  268.           // Delegate through to custom warn/error loggers if present on the console.
  269.           if (context.level === Logger.WARN && console.warn) {
  270.             hdlr = console.warn;
  271.           } else if (context.level === Logger.ERROR && console.error) {
  272.             hdlr = console.error;
  273.           } else if (context.level === Logger.INFO && console.info) {
  274.             hdlr = console.info;
  275.           } else if (context.level === Logger.DEBUG && console.debug) {
  276.             hdlr = console.debug;
  277.           } else if (context.level === Logger.TRACE && console.trace) {
  278.             hdlr = console.trace;
  279.           }
  280.  
  281.           options.formatter(messages, context);
  282.           invokeConsoleMethod(hdlr, messages);
  283.         }
  284.       };
  285.     };
  286.  
  287.     // Configure and example a Default implementation which writes to the `window.console` (if present).  The
  288.     // `options` hash can be used to configure the default logLevel and provide a custom message formatter.
  289.     Logger.useDefaults = function(options) {
  290.       Logger.setLevel(options && options.defaultLevel || Logger.DEBUG);
  291.       Logger.setHandler(Logger.createDefaultHandler(options));
  292.     };
  293.  
  294.     // Export to popular environments boilerplate.
  295.     if (module.exports) {
  296.       module.exports = Logger;
  297.     } else {
  298.       Logger._prevLogger = global.Logger;
  299.  
  300.       Logger.noConflict = function() {
  301.         global.Logger = Logger._prevLogger;
  302.         return Logger;
  303.       };
  304.  
  305.       global.Logger = Logger;
  306.     }
  307.   }(commonjsGlobal));
  308. });
  309.  
  310. var sparkMd5 = createCommonjsModule(function(module, exports) {
  311.   (function(factory) {
  312.     {
  313.       // Node/CommonJS
  314.       module.exports = factory();
  315.     }
  316.   }(function(undefined$1) {
  317.  
  318.     /*
  319.      * Fastest md5 implementation around (JKM md5).
  320.      * Credits: Joseph Myers
  321.      *
  322.      * @see http://www.myersdaily.org/joseph/javascript/md5-text.html
  323.      * @see http://jsperf.com/md5-shootout/7
  324.      */
  325.  
  326.     /* this function is much faster,
  327.       so if possible we use it. Some IEs
  328.       are the only ones I know of that
  329.       need the idiotic second function,
  330.       generated by an if clause.  */
  331.     var hex_chr = ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'];
  332.  
  333.     function md5cycle(x, k) {
  334.       var a = x[0],
  335.         b = x[1],
  336.         c = x[2],
  337.         d = x[3];
  338.  
  339.       a += (b & c | ~b & d) + k[0] - 680876936 | 0;
  340.       a = (a << 7 | a >>> 25) + b | 0;
  341.       d += (a & b | ~a & c) + k[1] - 389564586 | 0;
  342.       d = (d << 12 | d >>> 20) + a | 0;
  343.       c += (d & a | ~d & b) + k[2] + 606105819 | 0;
  344.       c = (c << 17 | c >>> 15) + d | 0;
  345.       b += (c & d | ~c & a) + k[3] - 1044525330 | 0;
  346.       b = (b << 22 | b >>> 10) + c | 0;
  347.       a += (b & c | ~b & d) + k[4] - 176418897 | 0;
  348.       a = (a << 7 | a >>> 25) + b | 0;
  349.       d += (a & b | ~a & c) + k[5] + 1200080426 | 0;
  350.       d = (d << 12 | d >>> 20) + a | 0;
  351.       c += (d & a | ~d & b) + k[6] - 1473231341 | 0;
  352.       c = (c << 17 | c >>> 15) + d | 0;
  353.       b += (c & d | ~c & a) + k[7] - 45705983 | 0;
  354.       b = (b << 22 | b >>> 10) + c | 0;
  355.       a += (b & c | ~b & d) + k[8] + 1770035416 | 0;
  356.       a = (a << 7 | a >>> 25) + b | 0;
  357.       d += (a & b | ~a & c) + k[9] - 1958414417 | 0;
  358.       d = (d << 12 | d >>> 20) + a | 0;
  359.       c += (d & a | ~d & b) + k[10] - 42063 | 0;
  360.       c = (c << 17 | c >>> 15) + d | 0;
  361.       b += (c & d | ~c & a) + k[11] - 1990404162 | 0;
  362.       b = (b << 22 | b >>> 10) + c | 0;
  363.       a += (b & c | ~b & d) + k[12] + 1804603682 | 0;
  364.       a = (a << 7 | a >>> 25) + b | 0;
  365.       d += (a & b | ~a & c) + k[13] - 40341101 | 0;
  366.       d = (d << 12 | d >>> 20) + a | 0;
  367.       c += (d & a | ~d & b) + k[14] - 1502002290 | 0;
  368.       c = (c << 17 | c >>> 15) + d | 0;
  369.       b += (c & d | ~c & a) + k[15] + 1236535329 | 0;
  370.       b = (b << 22 | b >>> 10) + c | 0;
  371.  
  372.       a += (b & d | c & ~d) + k[1] - 165796510 | 0;
  373.       a = (a << 5 | a >>> 27) + b | 0;
  374.       d += (a & c | b & ~c) + k[6] - 1069501632 | 0;
  375.       d = (d << 9 | d >>> 23) + a | 0;
  376.       c += (d & b | a & ~b) + k[11] + 643717713 | 0;
  377.       c = (c << 14 | c >>> 18) + d | 0;
  378.       b += (c & a | d & ~a) + k[0] - 373897302 | 0;
  379.       b = (b << 20 | b >>> 12) + c | 0;
  380.       a += (b & d | c & ~d) + k[5] - 701558691 | 0;
  381.       a = (a << 5 | a >>> 27) + b | 0;
  382.       d += (a & c | b & ~c) + k[10] + 38016083 | 0;
  383.       d = (d << 9 | d >>> 23) + a | 0;
  384.       c += (d & b | a & ~b) + k[15] - 660478335 | 0;
  385.       c = (c << 14 | c >>> 18) + d | 0;
  386.       b += (c & a | d & ~a) + k[4] - 405537848 | 0;
  387.       b = (b << 20 | b >>> 12) + c | 0;
  388.       a += (b & d | c & ~d) + k[9] + 568446438 | 0;
  389.       a = (a << 5 | a >>> 27) + b | 0;
  390.       d += (a & c | b & ~c) + k[14] - 1019803690 | 0;
  391.       d = (d << 9 | d >>> 23) + a | 0;
  392.       c += (d & b | a & ~b) + k[3] - 187363961 | 0;
  393.       c = (c << 14 | c >>> 18) + d | 0;
  394.       b += (c & a | d & ~a) + k[8] + 1163531501 | 0;
  395.       b = (b << 20 | b >>> 12) + c | 0;
  396.       a += (b & d | c & ~d) + k[13] - 1444681467 | 0;
  397.       a = (a << 5 | a >>> 27) + b | 0;
  398.       d += (a & c | b & ~c) + k[2] - 51403784 | 0;
  399.       d = (d << 9 | d >>> 23) + a | 0;
  400.       c += (d & b | a & ~b) + k[7] + 1735328473 | 0;
  401.       c = (c << 14 | c >>> 18) + d | 0;
  402.       b += (c & a | d & ~a) + k[12] - 1926607734 | 0;
  403.       b = (b << 20 | b >>> 12) + c | 0;
  404.  
  405.       a += (b ^ c ^ d) + k[5] - 378558 | 0;
  406.       a = (a << 4 | a >>> 28) + b | 0;
  407.       d += (a ^ b ^ c) + k[8] - 2022574463 | 0;
  408.       d = (d << 11 | d >>> 21) + a | 0;
  409.       c += (d ^ a ^ b) + k[11] + 1839030562 | 0;
  410.       c = (c << 16 | c >>> 16) + d | 0;
  411.       b += (c ^ d ^ a) + k[14] - 35309556 | 0;
  412.       b = (b << 23 | b >>> 9) + c | 0;
  413.       a += (b ^ c ^ d) + k[1] - 1530992060 | 0;
  414.       a = (a << 4 | a >>> 28) + b | 0;
  415.       d += (a ^ b ^ c) + k[4] + 1272893353 | 0;
  416.       d = (d << 11 | d >>> 21) + a | 0;
  417.       c += (d ^ a ^ b) + k[7] - 155497632 | 0;
  418.       c = (c << 16 | c >>> 16) + d | 0;
  419.       b += (c ^ d ^ a) + k[10] - 1094730640 | 0;
  420.       b = (b << 23 | b >>> 9) + c | 0;
  421.       a += (b ^ c ^ d) + k[13] + 681279174 | 0;
  422.       a = (a << 4 | a >>> 28) + b | 0;
  423.       d += (a ^ b ^ c) + k[0] - 358537222 | 0;
  424.       d = (d << 11 | d >>> 21) + a | 0;
  425.       c += (d ^ a ^ b) + k[3] - 722521979 | 0;
  426.       c = (c << 16 | c >>> 16) + d | 0;
  427.       b += (c ^ d ^ a) + k[6] + 76029189 | 0;
  428.       b = (b << 23 | b >>> 9) + c | 0;
  429.       a += (b ^ c ^ d) + k[9] - 640364487 | 0;
  430.       a = (a << 4 | a >>> 28) + b | 0;
  431.       d += (a ^ b ^ c) + k[12] - 421815835 | 0;
  432.       d = (d << 11 | d >>> 21) + a | 0;
  433.       c += (d ^ a ^ b) + k[15] + 530742520 | 0;
  434.       c = (c << 16 | c >>> 16) + d | 0;
  435.       b += (c ^ d ^ a) + k[2] - 995338651 | 0;
  436.       b = (b << 23 | b >>> 9) + c | 0;
  437.  
  438.       a += (c ^ (b | ~d)) + k[0] - 198630844 | 0;
  439.       a = (a << 6 | a >>> 26) + b | 0;
  440.       d += (b ^ (a | ~c)) + k[7] + 1126891415 | 0;
  441.       d = (d << 10 | d >>> 22) + a | 0;
  442.       c += (a ^ (d | ~b)) + k[14] - 1416354905 | 0;
  443.       c = (c << 15 | c >>> 17) + d | 0;
  444.       b += (d ^ (c | ~a)) + k[5] - 57434055 | 0;
  445.       b = (b << 21 | b >>> 11) + c | 0;
  446.       a += (c ^ (b | ~d)) + k[12] + 1700485571 | 0;
  447.       a = (a << 6 | a >>> 26) + b | 0;
  448.       d += (b ^ (a | ~c)) + k[3] - 1894986606 | 0;
  449.       d = (d << 10 | d >>> 22) + a | 0;
  450.       c += (a ^ (d | ~b)) + k[10] - 1051523 | 0;
  451.       c = (c << 15 | c >>> 17) + d | 0;
  452.       b += (d ^ (c | ~a)) + k[1] - 2054922799 | 0;
  453.       b = (b << 21 | b >>> 11) + c | 0;
  454.       a += (c ^ (b | ~d)) + k[8] + 1873313359 | 0;
  455.       a = (a << 6 | a >>> 26) + b | 0;
  456.       d += (b ^ (a | ~c)) + k[15] - 30611744 | 0;
  457.       d = (d << 10 | d >>> 22) + a | 0;
  458.       c += (a ^ (d | ~b)) + k[6] - 1560198380 | 0;
  459.       c = (c << 15 | c >>> 17) + d | 0;
  460.       b += (d ^ (c | ~a)) + k[13] + 1309151649 | 0;
  461.       b = (b << 21 | b >>> 11) + c | 0;
  462.       a += (c ^ (b | ~d)) + k[4] - 145523070 | 0;
  463.       a = (a << 6 | a >>> 26) + b | 0;
  464.       d += (b ^ (a | ~c)) + k[11] - 1120210379 | 0;
  465.       d = (d << 10 | d >>> 22) + a | 0;
  466.       c += (a ^ (d | ~b)) + k[2] + 718787259 | 0;
  467.       c = (c << 15 | c >>> 17) + d | 0;
  468.       b += (d ^ (c | ~a)) + k[9] - 343485551 | 0;
  469.       b = (b << 21 | b >>> 11) + c | 0;
  470.  
  471.       x[0] = a + x[0] | 0;
  472.       x[1] = b + x[1] | 0;
  473.       x[2] = c + x[2] | 0;
  474.       x[3] = d + x[3] | 0;
  475.     }
  476.  
  477.     function md5blk(s) {
  478.       var md5blks = [],
  479.         i; /* Andy King said do it this way. */
  480.  
  481.       for (i = 0; i < 64; i += 4) {
  482.         md5blks[i >> 2] = s.charCodeAt(i) + (s.charCodeAt(i + 1) << 8) + (s.charCodeAt(i + 2) << 16) + (s
  483.           .charCodeAt(i + 3) << 24);
  484.       }
  485.       return md5blks;
  486.     }
  487.  
  488.     function md5blk_array(a) {
  489.       var md5blks = [],
  490.         i; /* Andy King said do it this way. */
  491.  
  492.       for (i = 0; i < 64; i += 4) {
  493.         md5blks[i >> 2] = a[i] + (a[i + 1] << 8) + (a[i + 2] << 16) + (a[i + 3] << 24);
  494.       }
  495.       return md5blks;
  496.     }
  497.  
  498.     function md51(s) {
  499.       var n = s.length,
  500.         state = [1732584193, -271733879, -1732584194, 271733878],
  501.         i,
  502.         length,
  503.         tail,
  504.         tmp,
  505.         lo,
  506.         hi;
  507.  
  508.       for (i = 64; i <= n; i += 64) {
  509.         md5cycle(state, md5blk(s.substring(i - 64, i)));
  510.       }
  511.       s = s.substring(i - 64);
  512.       length = s.length;
  513.       tail = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0];
  514.       for (i = 0; i < length; i += 1) {
  515.         tail[i >> 2] |= s.charCodeAt(i) << ((i % 4) << 3);
  516.       }
  517.       tail[i >> 2] |= 0x80 << ((i % 4) << 3);
  518.       if (i > 55) {
  519.         md5cycle(state, tail);
  520.         for (i = 0; i < 16; i += 1) {
  521.           tail[i] = 0;
  522.         }
  523.       }
  524.  
  525.       // Beware that the final length might not fit in 32 bits so we take care of that
  526.       tmp = n * 8;
  527.       tmp = tmp.toString(16).match(/(.*?)(.{0,8})$/);
  528.       lo = parseInt(tmp[2], 16);
  529.       hi = parseInt(tmp[1], 16) || 0;
  530.  
  531.       tail[14] = lo;
  532.       tail[15] = hi;
  533.  
  534.       md5cycle(state, tail);
  535.       return state;
  536.     }
  537.  
  538.     function md51_array(a) {
  539.       var n = a.length,
  540.         state = [1732584193, -271733879, -1732584194, 271733878],
  541.         i,
  542.         length,
  543.         tail,
  544.         tmp,
  545.         lo,
  546.         hi;
  547.  
  548.       for (i = 64; i <= n; i += 64) {
  549.         md5cycle(state, md5blk_array(a.subarray(i - 64, i)));
  550.       }
  551.  
  552.       // Not sure if it is a bug, however IE10 will always produce a sub array of length 1
  553.       // containing the last element of the parent array if the sub array specified starts
  554.       // beyond the length of the parent array - weird.
  555.       // https://connect.microsoft.com/IE/feedback/details/771452/typed-array-subarray-issue
  556.       a = (i - 64) < n ? a.subarray(i - 64) : new Uint8Array(0);
  557.  
  558.       length = a.length;
  559.       tail = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0];
  560.       for (i = 0; i < length; i += 1) {
  561.         tail[i >> 2] |= a[i] << ((i % 4) << 3);
  562.       }
  563.  
  564.       tail[i >> 2] |= 0x80 << ((i % 4) << 3);
  565.       if (i > 55) {
  566.         md5cycle(state, tail);
  567.         for (i = 0; i < 16; i += 1) {
  568.           tail[i] = 0;
  569.         }
  570.       }
  571.  
  572.       // Beware that the final length might not fit in 32 bits so we take care of that
  573.       tmp = n * 8;
  574.       tmp = tmp.toString(16).match(/(.*?)(.{0,8})$/);
  575.       lo = parseInt(tmp[2], 16);
  576.       hi = parseInt(tmp[1], 16) || 0;
  577.  
  578.       tail[14] = lo;
  579.       tail[15] = hi;
  580.  
  581.       md5cycle(state, tail);
  582.  
  583.       return state;
  584.     }
  585.  
  586.     function rhex(n) {
  587.       var s = '',
  588.         j;
  589.       for (j = 0; j < 4; j += 1) {
  590.         s += hex_chr[(n >> (j * 8 + 4)) & 0x0F] + hex_chr[(n >> (j * 8)) & 0x0F];
  591.       }
  592.       return s;
  593.     }
  594.  
  595.     function hex(x) {
  596.       var i;
  597.       for (i = 0; i < x.length; i += 1) {
  598.         x[i] = rhex(x[i]);
  599.       }
  600.       return x.join('');
  601.     }
  602.  
  603.     // In some cases the fast add32 function cannot be used..
  604.     if (hex(md51('hello')) !== '5d41402abc4b2a76b9719d911017c592');
  605.  
  606.     // ---------------------------------------------------
  607.  
  608.     /**
  609.      * ArrayBuffer slice polyfill.
  610.      *
  611.      * @see https://github.com/ttaubert/node-arraybuffer-slice
  612.      */
  613.  
  614.     if (typeof ArrayBuffer !== 'undefined' && !ArrayBuffer.prototype.slice) {
  615.       (function() {
  616.         function clamp(val, length) {
  617.           val = (val | 0) || 0;
  618.  
  619.           if (val < 0) {
  620.             return Math.max(val + length, 0);
  621.           }
  622.  
  623.           return Math.min(val, length);
  624.         }
  625.  
  626.         ArrayBuffer.prototype.slice = function(from, to) {
  627.           var length = this.byteLength,
  628.             begin = clamp(from, length),
  629.             end = length,
  630.             num,
  631.             target,
  632.             targetArray,
  633.             sourceArray;
  634.  
  635.           if (to !== undefined$1) {
  636.             end = clamp(to, length);
  637.           }
  638.  
  639.           if (begin > end) {
  640.             return new ArrayBuffer(0);
  641.           }
  642.  
  643.           num = end - begin;
  644.           target = new ArrayBuffer(num);
  645.           targetArray = new Uint8Array(target);
  646.  
  647.           sourceArray = new Uint8Array(this, begin, num);
  648.           targetArray.set(sourceArray);
  649.  
  650.           return target;
  651.         };
  652.       })();
  653.     }
  654.  
  655.     // ---------------------------------------------------
  656.  
  657.     /**
  658.      * Helpers.
  659.      */
  660.  
  661.     function toUtf8(str) {
  662.       if (/[\u0080-\uFFFF]/.test(str)) {
  663.         str = unescape(encodeURIComponent(str));
  664.       }
  665.  
  666.       return str;
  667.     }
  668.  
  669.     function utf8Str2ArrayBuffer(str, returnUInt8Array) {
  670.       var length = str.length,
  671.         buff = new ArrayBuffer(length),
  672.         arr = new Uint8Array(buff),
  673.         i;
  674.  
  675.       for (i = 0; i < length; i += 1) {
  676.         arr[i] = str.charCodeAt(i);
  677.       }
  678.  
  679.       return returnUInt8Array ? arr : buff;
  680.     }
  681.  
  682.     function arrayBuffer2Utf8Str(buff) {
  683.       return String.fromCharCode.apply(null, new Uint8Array(buff));
  684.     }
  685.  
  686.     function concatenateArrayBuffers(first, second, returnUInt8Array) {
  687.       var result = new Uint8Array(first.byteLength + second.byteLength);
  688.  
  689.       result.set(new Uint8Array(first));
  690.       result.set(new Uint8Array(second), first.byteLength);
  691.  
  692.       return returnUInt8Array ? result : result.buffer;
  693.     }
  694.  
  695.     function hexToBinaryString(hex) {
  696.       var bytes = [],
  697.         length = hex.length,
  698.         x;
  699.  
  700.       for (x = 0; x < length - 1; x += 2) {
  701.         bytes.push(parseInt(hex.substr(x, 2), 16));
  702.       }
  703.  
  704.       return String.fromCharCode.apply(String, bytes);
  705.     }
  706.  
  707.     // ---------------------------------------------------
  708.  
  709.     /**
  710.      * SparkMD5 OOP implementation.
  711.      *
  712.      * Use this class to perform an incremental md5, otherwise use the
  713.      * static methods instead.
  714.      */
  715.  
  716.     function SparkMD5() {
  717.       // call reset to init the instance
  718.       this.reset();
  719.     }
  720.  
  721.     /**
  722.      * Appends a string.
  723.      * A conversion will be applied if an utf8 string is detected.
  724.      *
  725.      * @param {String} str The string to be appended
  726.      *
  727.      * @return {SparkMD5} The instance itself
  728.      */
  729.     SparkMD5.prototype.append = function(str) {
  730.       // Converts the string to utf8 bytes if necessary
  731.       // Then append as binary
  732.       this.appendBinary(toUtf8(str));
  733.  
  734.       return this;
  735.     };
  736.  
  737.     /**
  738.      * Appends a binary string.
  739.      *
  740.      * @param {String} contents The binary string to be appended
  741.      *
  742.      * @return {SparkMD5} The instance itself
  743.      */
  744.     SparkMD5.prototype.appendBinary = function(contents) {
  745.       this._buff += contents;
  746.       this._length += contents.length;
  747.  
  748.       var length = this._buff.length,
  749.         i;
  750.  
  751.       for (i = 64; i <= length; i += 64) {
  752.         md5cycle(this._hash, md5blk(this._buff.substring(i - 64, i)));
  753.       }
  754.  
  755.       this._buff = this._buff.substring(i - 64);
  756.  
  757.       return this;
  758.     };
  759.  
  760.     /**
  761.      * Finishes the incremental computation, reseting the internal state and
  762.      * returning the result.
  763.      *
  764.      * @param {Boolean} raw True to get the raw string, false to get the hex string
  765.      *
  766.      * @return {String} The result
  767.      */
  768.     SparkMD5.prototype.end = function(raw) {
  769.       var buff = this._buff,
  770.         length = buff.length,
  771.         i,
  772.         tail = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
  773.         ret;
  774.  
  775.       for (i = 0; i < length; i += 1) {
  776.         tail[i >> 2] |= buff.charCodeAt(i) << ((i % 4) << 3);
  777.       }
  778.  
  779.       this._finish(tail, length);
  780.       ret = hex(this._hash);
  781.  
  782.       if (raw) {
  783.         ret = hexToBinaryString(ret);
  784.       }
  785.  
  786.       this.reset();
  787.  
  788.       return ret;
  789.     };
  790.  
  791.     /**
  792.      * Resets the internal state of the computation.
  793.      *
  794.      * @return {SparkMD5} The instance itself
  795.      */
  796.     SparkMD5.prototype.reset = function() {
  797.       this._buff = '';
  798.       this._length = 0;
  799.       this._hash = [1732584193, -271733879, -1732584194, 271733878];
  800.  
  801.       return this;
  802.     };
  803.  
  804.     /**
  805.      * Gets the internal state of the computation.
  806.      *
  807.      * @return {Object} The state
  808.      */
  809.     SparkMD5.prototype.getState = function() {
  810.       return {
  811.         buff: this._buff,
  812.         length: this._length,
  813.         hash: this._hash.slice()
  814.       };
  815.     };
  816.  
  817.     /**
  818.      * Gets the internal state of the computation.
  819.      *
  820.      * @param {Object} state The state
  821.      *
  822.      * @return {SparkMD5} The instance itself
  823.      */
  824.     SparkMD5.prototype.setState = function(state) {
  825.       this._buff = state.buff;
  826.       this._length = state.length;
  827.       this._hash = state.hash;
  828.  
  829.       return this;
  830.     };
  831.  
  832.     /**
  833.      * Releases memory used by the incremental buffer and other additional
  834.      * resources. If you plan to use the instance again, use reset instead.
  835.      */
  836.     SparkMD5.prototype.destroy = function() {
  837.       delete this._hash;
  838.       delete this._buff;
  839.       delete this._length;
  840.     };
  841.  
  842.     /**
  843.      * Finish the final calculation based on the tail.
  844.      *
  845.      * @param {Array}  tail   The tail (will be modified)
  846.      * @param {Number} length The length of the remaining buffer
  847.      */
  848.     SparkMD5.prototype._finish = function(tail, length) {
  849.       var i = length,
  850.         tmp,
  851.         lo,
  852.         hi;
  853.  
  854.       tail[i >> 2] |= 0x80 << ((i % 4) << 3);
  855.       if (i > 55) {
  856.         md5cycle(this._hash, tail);
  857.         for (i = 0; i < 16; i += 1) {
  858.           tail[i] = 0;
  859.         }
  860.       }
  861.  
  862.       // Do the final computation based on the tail and length
  863.       // Beware that the final length may not fit in 32 bits so we take care of that
  864.       tmp = this._length * 8;
  865.       tmp = tmp.toString(16).match(/(.*?)(.{0,8})$/);
  866.       lo = parseInt(tmp[2], 16);
  867.       hi = parseInt(tmp[1], 16) || 0;
  868.  
  869.       tail[14] = lo;
  870.       tail[15] = hi;
  871.       md5cycle(this._hash, tail);
  872.     };
  873.  
  874.     /**
  875.      * Performs the md5 hash on a string.
  876.      * A conversion will be applied if utf8 string is detected.
  877.      *
  878.      * @param {String}  str The string
  879.      * @param {Boolean} [raw] True to get the raw string, false to get the hex string
  880.      *
  881.      * @return {String} The result
  882.      */
  883.     SparkMD5.hash = function(str, raw) {
  884.       // Converts the string to utf8 bytes if necessary
  885.       // Then compute it using the binary function
  886.       return SparkMD5.hashBinary(toUtf8(str), raw);
  887.     };
  888.  
  889.     /**
  890.      * Performs the md5 hash on a binary string.
  891.      *
  892.      * @param {String}  content The binary string
  893.      * @param {Boolean} [raw]     True to get the raw string, false to get the hex string
  894.      *
  895.      * @return {String} The result
  896.      */
  897.     SparkMD5.hashBinary = function(content, raw) {
  898.       var hash = md51(content),
  899.         ret = hex(hash);
  900.  
  901.       return raw ? hexToBinaryString(ret) : ret;
  902.     };
  903.  
  904.     // ---------------------------------------------------
  905.  
  906.     /**
  907.      * SparkMD5 OOP implementation for array buffers.
  908.      *
  909.      * Use this class to perform an incremental md5 ONLY for array buffers.
  910.      */
  911.     SparkMD5.ArrayBuffer = function() {
  912.       // call reset to init the instance
  913.       this.reset();
  914.     };
  915.  
  916.     /**
  917.      * Appends an array buffer.
  918.      *
  919.      * @param {ArrayBuffer} arr The array to be appended
  920.      *
  921.      * @return {SparkMD5.ArrayBuffer} The instance itself
  922.      */
  923.     SparkMD5.ArrayBuffer.prototype.append = function(arr) {
  924.       var buff = concatenateArrayBuffers(this._buff.buffer, arr, true),
  925.         length = buff.length,
  926.         i;
  927.  
  928.       this._length += arr.byteLength;
  929.  
  930.       for (i = 64; i <= length; i += 64) {
  931.         md5cycle(this._hash, md5blk_array(buff.subarray(i - 64, i)));
  932.       }
  933.  
  934.       this._buff = (i - 64) < length ? new Uint8Array(buff.buffer.slice(i - 64)) : new Uint8Array(0);
  935.  
  936.       return this;
  937.     };
  938.  
  939.     /**
  940.      * Finishes the incremental computation, reseting the internal state and
  941.      * returning the result.
  942.      *
  943.      * @param {Boolean} raw True to get the raw string, false to get the hex string
  944.      *
  945.      * @return {String} The result
  946.      */
  947.     SparkMD5.ArrayBuffer.prototype.end = function(raw) {
  948.       var buff = this._buff,
  949.         length = buff.length,
  950.         tail = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
  951.         i,
  952.         ret;
  953.  
  954.       for (i = 0; i < length; i += 1) {
  955.         tail[i >> 2] |= buff[i] << ((i % 4) << 3);
  956.       }
  957.  
  958.       this._finish(tail, length);
  959.       ret = hex(this._hash);
  960.  
  961.       if (raw) {
  962.         ret = hexToBinaryString(ret);
  963.       }
  964.  
  965.       this.reset();
  966.  
  967.       return ret;
  968.     };
  969.  
  970.     /**
  971.      * Resets the internal state of the computation.
  972.      *
  973.      * @return {SparkMD5.ArrayBuffer} The instance itself
  974.      */
  975.     SparkMD5.ArrayBuffer.prototype.reset = function() {
  976.       this._buff = new Uint8Array(0);
  977.       this._length = 0;
  978.       this._hash = [1732584193, -271733879, -1732584194, 271733878];
  979.  
  980.       return this;
  981.     };
  982.  
  983.     /**
  984.      * Gets the internal state of the computation.
  985.      *
  986.      * @return {Object} The state
  987.      */
  988.     SparkMD5.ArrayBuffer.prototype.getState = function() {
  989.       var state = SparkMD5.prototype.getState.call(this);
  990.  
  991.       // Convert buffer to a string
  992.       state.buff = arrayBuffer2Utf8Str(state.buff);
  993.  
  994.       return state;
  995.     };
  996.  
  997.     /**
  998.      * Gets the internal state of the computation.
  999.      *
  1000.      * @param {Object} state The state
  1001.      *
  1002.      * @return {SparkMD5.ArrayBuffer} The instance itself
  1003.      */
  1004.     SparkMD5.ArrayBuffer.prototype.setState = function(state) {
  1005.       // Convert string to buffer
  1006.       state.buff = utf8Str2ArrayBuffer(state.buff, true);
  1007.  
  1008.       return SparkMD5.prototype.setState.call(this, state);
  1009.     };
  1010.  
  1011.     SparkMD5.ArrayBuffer.prototype.destroy = SparkMD5.prototype.destroy;
  1012.  
  1013.     SparkMD5.ArrayBuffer.prototype._finish = SparkMD5.prototype._finish;
  1014.  
  1015.     /**
  1016.      * Performs the md5 hash on an array buffer.
  1017.      *
  1018.      * @param {ArrayBuffer} arr The array buffer
  1019.      * @param {Boolean}     [raw] True to get the raw string, false to get the hex one
  1020.      *
  1021.      * @return {String} The result
  1022.      */
  1023.     SparkMD5.ArrayBuffer.hash = function(arr, raw) {
  1024.       var hash = md51_array(new Uint8Array(arr)),
  1025.         ret = hex(hash);
  1026.  
  1027.       return raw ? hexToBinaryString(ret) : ret;
  1028.     };
  1029.  
  1030.     return SparkMD5;
  1031.   }));
  1032. });
  1033.  
  1034. var config = {
  1035.   tempFilePath: '',
  1036.   totalSize: 0,
  1037.   fileName: '',
  1038.   verifyUrl: '',
  1039.   uploadUrl: '',
  1040.   mergeUrl: '',
  1041.   maxConcurrency: 5,
  1042.   generateIdentifier: null,
  1043.   chunkSize: 5 * 1024 * 1024,
  1044.   maxMemory: 100 * 1024 * 1024,
  1045.   query: '',
  1046.   header: {},
  1047.   testChunks: false,
  1048.   chunkRetryInterval: 0,
  1049.   maxChunkRetries: 0,
  1050.   timeout: 10000,
  1051.   successStatus: [200, 201, 202],
  1052.   failStatus: [404, 415, 500, 501],
  1053.   verbose: false
  1054. };
  1055.  
  1056. class EventEmitter {
  1057.   constructor() {
  1058.     this.events = {};
  1059.   }
  1060.  
  1061.   on(event, listener) {
  1062.     if (typeof this.events[event] !== 'object') {
  1063.       this.events[event] = [];
  1064.     }
  1065.     this.events[event].push(listener);
  1066.     return () => this.off(event, listener)
  1067.   }
  1068.  
  1069.   off(event, listener) {
  1070.     if (typeof this.events[event] === 'object') {
  1071.       const idx = this.events[event].indexOf(listener);
  1072.       if (idx > -1) {
  1073.         this.events[event].splice(idx, 1);
  1074.       }
  1075.     }
  1076.   }
  1077.  
  1078.   emit(event, ...args) {
  1079.     if (typeof this.events[event] === 'object') {
  1080.       this.events[event].forEach(listener => listener.apply(this, args));
  1081.     }
  1082.   }
  1083.  
  1084.   once(event, listener) {
  1085.     const remove = this.on(event, (...args) => {
  1086.       remove();
  1087.       listener.apply(this, args);
  1088.     });
  1089.   }
  1090. }
  1091.  
  1092. const isFunction = x => typeof x === 'function';
  1093.  
  1094. function promisify(func) {
  1095.   if (!isFunction(func)) return func
  1096.   return (args = {}) => new Promise((resolve, reject) => {
  1097.     func(
  1098.       Object.assign(args, {
  1099.         success: resolve,
  1100.         fail: reject
  1101.       })
  1102.     );
  1103.   })
  1104. }
  1105.  
  1106. function addParams(url = '', params = {}) {
  1107.   const parts = url.split('&');
  1108.   const query = Object.keys(params).map(key => `${key}=${params[key]}`).join('&');
  1109.   return query ? `${parts[0]}&${query}` : parts[0]
  1110. }
  1111.  
  1112. const awaitWrap = (promise) => promise
  1113.   .then(data => [null, data])
  1114.   .catch(err => [err, null]);
  1115.  
  1116. const compareVersion = (v1, v2) => {
  1117.   v1 = v1.split('.');
  1118.   v2 = v2.split('.');
  1119.   const len = Math.max(v1.length, v2.length);
  1120.  
  1121.   while (v1.length < len) {
  1122.     v1.push('0');
  1123.   }
  1124.   while (v2.length < len) {
  1125.     v2.push('0');
  1126.   }
  1127.  
  1128.   for (let i = 0; i < len; i++) {
  1129.     const num1 = parseInt(v1[i], 10);
  1130.     const num2 = parseInt(v2[i], 10);
  1131.  
  1132.     if (num1 > num2) {
  1133.       return 1
  1134.     } else if (num1 < num2) {
  1135.       return -1
  1136.     }
  1137.   }
  1138.  
  1139.   return 0
  1140. };
  1141.  
  1142. logger.useDefaults({
  1143.   defaultLevel: logger.OFF,
  1144.   formatter(messages) {
  1145.     const now = new Date();
  1146.     const time = `${now.getHours()}:${now.getMinutes()}:${now.getSeconds()}`;
  1147.     messages.unshift(time);
  1148.     messages.unshift('[Uploader]');
  1149.   }
  1150. });
  1151.  
  1152. const fileManager = wx.getFileSystemManager();
  1153. const readFileAsync = promisify(fileManager.readFile);
  1154. const miniProgram = wx.getAccountInfoSync();
  1155. const systemInfo = wx.getSystemInfoSync();
  1156. const appId = miniProgram.appId;
  1157. const MB = 1024 * 1024;
  1158.  
  1159.  
  1160.  
  1161.  
  1162. // -----------------下面是请求的数据，可以删掉
  1163. let app_key = 'xxx';
  1164. let key = 'xxx';
  1165.  
  1166. // 随机32位数
  1167. function nonce() {
  1168.   let arr = ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f', 'A', 'B',
  1169.     'C', 'D', 'E'
  1170.   ];
  1171.   let res = '';
  1172.   for (let i = 0; i < 32; i++) {
  1173.     let pos = Math.round(Math.random() * (arr.length - 1));
  1174.     res += arr[pos]
  1175.   }
  1176.   return res;
  1177. }
  1178.  
  1179. function signfn(action, postParam) {
  1180.   // 时间戳
  1181.   let ts = new Date().getTime().toString();
  1182.   let randomNum = nonce();
  1183.  
  1184.   let act = app_key; //请求带的url
  1185.   function getSign(params, app_key, key) {
  1186.  
  1187.     if (typeof params == "string") {
  1188.       return paramsStrSort(params);
  1189.     } else if (typeof params == "object") {
  1190.       let arr = [];
  1191.       for (let i in params) {
  1192.         arr.push((i + "=" + params[i]));
  1193.       }
  1194.       return paramsStrSort(arr.join(("&")))
  1195.     }
  1196.   }
  1197.  
  1198.   function paramsStrSort(paramsStr) {
  1199.     let url = paramsStr;
  1200.     let arr = [];
  1201.     let p = url.split("&");
  1202.     for (let i in p) {
  1203.       let temp_arr = p[i].split("=");
  1204.       arr.push((temp_arr[0].toLowerCase() + "=" + temp_arr[1]));
  1205.     }
  1206.     let urlStr = arr.sort().join("&");
  1207.     let newUrl = urlStr + '&key=' + key;
  1208.     return md5(newUrl);
  1209.   }
  1210.  
  1211.   var params = {
  1212.     act,
  1213.     'ts': ts,
  1214.     'nonce': randomNum,
  1215.     app_key
  1216.   };
  1217.   // 转成字符串
  1218.   let signstr = JSON.stringify(params);
  1219.   let sign = getSign(params, app_key, key);
  1220.  
  1221.  
  1222.   return {
  1223.     sign,
  1224.     ts,
  1225.     randomNum,
  1226.     app_key
  1227.   };
  1228.  
  1229. }
  1230. // -----------------上面是请求的数据，可以删掉  结束
  1231.  
  1232.  
  1233.  
  1234.  
  1235. class Uploader {
  1236.   constructor(option = {}) {
  1237.     if (option.verbose) logger.setLevel(logger.INFO);
  1238.     logger.debug('construct option ', option);
  1239.     this.config = Object.assign(config, option);
  1240.     this.emitter = new EventEmitter();
  1241.     this.totalSize = this.config.totalSize;
  1242.     this.chunkSize = this.config.chunkSize;
  1243.     this.tempFilePath = this.config.tempFilePath;
  1244.     this.totalChunks = Math.ceil(this.totalSize / this.chunkSize);
  1245.     this.maxLoadChunks = Math.floor(this.config.maxMemory / this.chunkSize);
  1246.     this._event();
  1247.   }
  1248.  
  1249.   static isSupport() {
  1250.     const version = systemInfo.SDKVersion;
  1251.     return compareVersion(version, '2.10.0') >= 0
  1252.   }
  1253.  
  1254.   async upload() {
  1255.     this._reset();
  1256.  
  1257.     logger.info('start generateIdentifier');
  1258.     // step1: 计算 identifier
  1259.     try {
  1260.       logger.time('[Uploader] generateIdentifier');
  1261.       if (this.config.testChunks) {
  1262.         this.identifier = await this.computeMD5();
  1263.       } else {
  1264.         this.identifier = this.generateIdentifier();
  1265.       }
  1266.       logger.timeEnd('[Uploader] generateIdentifier');
  1267.       logger.debug('generateIdentifier ', this.identifier);
  1268.     } catch (error) {
  1269.       this.handleFail({
  1270.         errCode: 10002,
  1271.         errMsg: error.message
  1272.       });
  1273.       return
  1274.     }
  1275.     logger.info('generateIdentifier end');
  1276.     // step2: 获取已上传分片
  1277.  
  1278.     if (this.config.testChunks && this.config.verifyUrl) {
  1279.       logger.info('start verify uploaded chunks');
  1280.       logger.time('[Uploader] verifyRequest');
  1281.       const [verifyErr, verifyResp] = await awaitWrap(this.verifyRequest());
  1282.       logger.timeEnd('[Uploader] verifyRequest');
  1283.       logger.debug('verifyRequest', verifyErr, verifyResp);
  1284.       if (verifyErr) {
  1285.         this.handleFail({
  1286.           errCode: 20001,
  1287.           errMsg: verifyErr.errMsg
  1288.         });
  1289.         return
  1290.       }
  1291.       const {
  1292.         needUpload,
  1293.         uploadedChunks,
  1294.       } = verifyResp.data;
  1295.       logger.info('verify uploaded chunks end');
  1296.       // 秒传逻辑
  1297.       // 找不到合成的文件
  1298.       if (!needUpload) {
  1299.         this.progress = 100;
  1300.         this.timeRemaining = 0;
  1301.         this.dispatchProgress();
  1302.         this.emit('success', {
  1303.           errCode: 0,
  1304.           ...verifyResp.data
  1305.         });
  1306.         this.emit('complete', {
  1307.           errCode: 0,
  1308.           ...verifyResp.data
  1309.         });
  1310.         return
  1311.         // 分片齐全，但没有合并
  1312.       } else if (uploadedChunks.length === this.totalChunks) {
  1313.         this.progress = 100;
  1314.         this.timeRemaining = 0;
  1315.         this.dispatchProgress();
  1316.         this.emit('uploadDone');
  1317.         return
  1318.       } else {
  1319.         this.chunksIndexNeedRead = this.chunksIndexNeedRead.filter(v => !uploadedChunks.includes(v));
  1320.         this.chunksIndexNeedSend = this.chunksIndexNeedSend.filter(v => !uploadedChunks.includes(v));
  1321.         this.uploadedChunks = uploadedChunks.sort();
  1322.       }
  1323.     }
  1324.  
  1325.     this.chunksNeedSend = this.chunksIndexNeedSend.length;
  1326.     this.sizeNeedSend = this.chunksNeedSend * this.chunkSize;
  1327.     if (this.chunksIndexNeedSend.includes(this.totalChunks - 1)) {
  1328.       this.sizeNeedSend -= (this.totalChunks * this.chunkSize - this.totalSize);
  1329.     }
  1330.     logger.debug(`
  1331.       start upload
  1332.         uploadedChunks: ${this.uploadedChunks},
  1333.         chunksQueue: ${this.chunksQueue},
  1334.         chunksIndexNeedRead: ${this.chunksIndexNeedRead},
  1335.         chunksNeedSend: ${this.chunksIndexNeedSend},
  1336.         sizeNeedSend: ${this.sizeNeedSend}
  1337.     `);
  1338.  
  1339.     logger.info('start upload chunks');
  1340.     logger.time('[Uploader] uploadChunks');
  1341.     // step3: 开始上传
  1342.     this.isUploading = true;
  1343.     this._upload();
  1344.   }
  1345.  
  1346.   _requestAsync(args = {}, callback) {
  1347.     const {
  1348.       chunkRetryInterval,
  1349.       maxChunkRetries,
  1350.       successStatus,
  1351.       failStatus
  1352.     } = this.config;
  1353.  
  1354.     let retries = maxChunkRetries;
  1355.  
  1356.     // args.url||
  1357.     const signInfo = signfn(args.url)
  1358.     return new Promise((resolve, reject) => {
  1359.       let ts = new Date().getTime().toString();
  1360.       const doRequest = () => {
  1361.         const task = wx.request({
  1362.           ...args,
  1363.           header: {
  1364.             "Content-Type": "multipart/form-data",
  1365.             "auth-ts": signInfo.ts, //时间戳
  1366.             "auth-access-token": uni.getStorageSync('user_info').access_token || '',
  1367.             "auth-nonce": signInfo.randomNum, //随机字符串(32位)
  1368.             "auth-sign": signInfo.sign, //签名
  1369.             "auth-key": signInfo.app_key, //应用的APP_KEY
  1370.             "auth-platform": '1', //请求平台ID 1:web端 2:安卓 3:苹果
  1371.             "auth-appid": uni.getStorageSync('user_info').app_id || 0, //通过二维码进入携带的appid
  1372.             "auth-orgname": uni.getStorageSync('user_info').org_info.orgname || orgname || '', //用户机构
  1373.           },
  1374.           timeout: this.config.timeout,
  1375.           success: (res) => {
  1376.             let pages = getCurrentPages();
  1377.             if (res.data.result.status_info.status_code != 100) {
  1378.               let pagesitem = pages[2] || pages[1] || pages[0]
  1379.               if (pagesitem.route == "PackageA/pages/vote_work/video_upload") {
  1380.                 pagesitem.$vm.$refs.sbp.close()
  1381.                 pagesitem.$vm.isupload = false
  1382.                 pagesitem.$vm.showMsk = false
  1383.               }
  1384.               uni.showToast({
  1385.                 title: res.data.result.status_info.status_message,
  1386.                 duration: 2000,
  1387.                 icon: 'none'
  1388.               })
  1389.               this.cancel();
  1390.               return
  1391.             }
  1392.             const statusCode = res.statusCode;
  1393.  
  1394.             // 标示成功的返回码
  1395.             if (successStatus.includes(statusCode)) {
  1396.               resolve(res);
  1397.               // 标示失败的返回码
  1398.             } else if (failStatus.includes(statusCode)) {
  1399.               reject(res);
  1400.             } else if (retries > 0) {
  1401.               setTimeout(() => {
  1402.                 this.emit('retry', {
  1403.                   statusCode,
  1404.                   url: args.url
  1405.                 });
  1406.                 --retries;
  1407.                 doRequest();
  1408.               }, chunkRetryInterval);
  1409.             } else {
  1410.               reject(res);
  1411.             }
  1412.           },
  1413.           fail: (res) => {
  1414.             reject(res);
  1415.              let pageS = getCurrentPages();
  1416.             let pagesitem = pageS[2] || pageS[1] || pageS[0]
  1417.             if (pagesitem.route == "PackageA/pages/vote_work/video_upload") {
  1418.               console.log(pagesitem, 'pagesitem----');
  1419.               pagesitem.$vm.$refs.sbp.close()
  1420.               // pagesitem.$vm.imgvido_arr = []
  1421.               pagesitem.$vm.isupload = false
  1422.               pagesitem.$vm.showMsk = false
  1423.             }
  1424.             uni.showToast({
  1425.               title: res.data.result.status_info.status_message,
  1426.               duration: 2000,
  1427.               icon: 'none'
  1428.             })
  1429.             console.log(res, '请求失败');
  1430.             return
  1431.           }
  1432.         });
  1433.         if (isFunction(callback)) {
  1434.  
  1435.           callback(task);
  1436.         }
  1437.       };
  1438.  
  1439.       doRequest();
  1440.     })
  1441.   }
  1442.  
  1443.   handleFail(e) {
  1444.     if (this.isFail) return
  1445.     logger.error('upload file fail: ', e);
  1446.     this.isFail = true;
  1447.     this.cancel();
  1448.     this.emit('fail', e);
  1449.     this.emit('complete', e);
  1450.   }
  1451.  
  1452.   _event() { // step4: 发送合并请求
  1453.     // step4: 发送合并请求
  1454.     this.on('uploadDone', async () => {
  1455.       logger.timeEnd('[Uploader] uploadChunks');
  1456.       logger.info('upload chunks end');
  1457.       this.isUploading = false;
  1458.       logger.info('start merge reqeust');
  1459.       logger.time('[Uploader] mergeRequest');
  1460.       const [mergeErr, mergeResp] = await awaitWrap(this.mergeRequest());
  1461.       logger.timeEnd('[Uploader] mergeRequest');
  1462.       logger.info('merge reqeust end');
  1463.       logger.debug('mergeRequest', mergeErr, mergeResp);
  1464.       if (mergeErr) {
  1465.         this.handleFail({
  1466.           errCode: 20003,
  1467.           errrMsg: mergeErr.errMsg
  1468.         });
  1469.         return
  1470.       }
  1471.       logger.info('upload file success');
  1472.       this.emit('success', {
  1473.         errCode: 0,
  1474.         ...mergeResp.data
  1475.       });
  1476.       this.emit('complete', {
  1477.         errCode: 0,
  1478.         ...mergeResp.data
  1479.       });
  1480.     });
  1481.   }
  1482.  
  1483.   _upload() {
  1484.     this.startUploadTime = Date.now();
  1485.     this._uploadedSize = 0;
  1486.  
  1487.     if (this.chunksQueue.length) {
  1488.       const maxConcurrency = this.config.maxConcurrency;
  1489.       for (let i = 0; i < maxConcurrency; i++) {
  1490.         this.uploadChunk();
  1491.       }
  1492.     } else {
  1493.       this.readFileChunk();
  1494.     }
  1495.   }
  1496.  
  1497.   updateUploadSize(currUploadSize) {
  1498.     this.uploadedSize += currUploadSize; // 总体上传大小，暂停后累计
  1499.     this._uploadedSize += currUploadSize; // 上传大小，暂停后清空
  1500.     const time = Date.now() - this.startUploadTime; // 当前耗时
  1501.     const averageSpeed = this._uploadedSize / time; // B/ms
  1502.     const sizeWaitSend = this.sizeNeedSend - this.uploadedSize; // 剩余需要发送的大小
  1503.     this.timeRemaining = parseInt(sizeWaitSend / averageSpeed, 10); // 剩余时间
  1504.     this.averageSpeed = parseInt(averageSpeed, 10) * 1000; // 平均速度 B/s
  1505.     this.progress = parseInt(((this.uploadedSize * 100) / this.sizeNeedSend), 10);
  1506.     this.dispatchProgress();
  1507.   }
  1508.  
  1509.   dispatchProgress() {
  1510.     this.emit('progress', {
  1511.       totalSize: this.totalSize,
  1512.       progress: this.progress,
  1513.       uploadedSize: this.uploadedSize,
  1514.       averageSpeed: this.averageSpeed,
  1515.       timeRemaining: this.timeRemaining
  1516.     });
  1517.   }
  1518.  
  1519.   pause() {
  1520.     logger.info('** pause **');
  1521.     this.isUploading = false;
  1522.     const abortIndex = Object.keys(this.uploadTasks).map(v => v * 1);
  1523.     abortIndex.forEach(index => {
  1524.       this.chunksIndexNeedRead.push(index);
  1525.       this.uploadTasks[index].abort();
  1526.     });
  1527.     this.uploadTasks = {};
  1528.   }
  1529.  
  1530.   resume() {
  1531.     logger.info('** resume **');
  1532.     this.isUploading = true;
  1533.     this._upload();
  1534.   }
  1535.  
  1536.   cancel() {
  1537.     logger.info('** cancel **');
  1538.     this.pause();
  1539.     this._reset();
  1540.   }
  1541.  
  1542.   _reset() {
  1543.     this.chunksIndexNeedRead = Array.from(Array(this.totalChunks).keys());
  1544.     this.chunksIndexNeedSend = Array.from(Array(this.totalChunks).keys());
  1545.     this.chunksNeedSend = this.totalChunks;
  1546.     this.sizeNeedSend = this.totalSize;
  1547.     this.identifier = '';
  1548.     this.chunksSend = 0;
  1549.     this.chunksQueue = [];
  1550.     this.uploadTasks = {};
  1551.     this.pUploadList = [];
  1552.     this.uploadedChunks = [];
  1553.     this.isUploading = false;
  1554.     this.isFail = false;
  1555.     this.progress = 0;
  1556.     this.uploadedSize = 0;
  1557.     this.averageSpeed = 0;
  1558.     this.timeRemaining = Number.POSITIVE_INFINITY;
  1559.     this.dispatchProgress();
  1560.   }
  1561.  
  1562.   readFileChunk() {
  1563.     const {
  1564.       tempFilePath,
  1565.       chunkSize,
  1566.       maxLoadChunks,
  1567.       chunksQueue,
  1568.       chunksIndexNeedRead,
  1569.       totalSize
  1570.     } = this;
  1571.     const chunks = Math.min(chunksIndexNeedRead.length, maxLoadChunks - chunksQueue.length);
  1572.     // 异步读取
  1573.     logger.debug(`readFileChunk chunks: ${chunks}, chunksIndexNeedRead`, this.chunksIndexNeedRead);
  1574.     for (let i = 0; i < chunks; i++) {
  1575.       const index = chunksIndexNeedRead.shift();
  1576.       const position = index * chunkSize;
  1577.       const length = Math.min(totalSize - position, chunkSize);
  1578.       if (this.isFail) break
  1579.  
  1580.       readFileAsync({
  1581.         filePath: tempFilePath,
  1582.         position,
  1583.         length
  1584.       }).then(res => {
  1585.         const chunk = res.data;
  1586.         this.chunksQueue.push({
  1587.           chunk,
  1588.           length,
  1589.           index
  1590.         });
  1591.         this.uploadChunk();
  1592.         return null
  1593.       }).catch(e => {
  1594.         this.handleFail({
  1595.           errCode: 10001,
  1596.           errMsg: e.errMsg
  1597.         });
  1598.       });
  1599.     }
  1600.   }
  1601.  
  1602.   uploadChunk() { //暂停 / 继续 /取消
  1603.     // 暂停中
  1604.     if (!this.isUploading || this.isFail) return
  1605.     // 没有更多数据了
  1606.     if (!this.chunksQueue.length) return
  1607.     // 达到最大并发度
  1608.     if (Object.keys(this.uploadTasks).length === this.config.maxConcurrency) return
  1609.  
  1610.     const {
  1611.       chunk,
  1612.       index,
  1613.       length
  1614.     } = this.chunksQueue.shift();
  1615.  
  1616.     // 跳过已发送的分块
  1617.     if (this.uploadedChunks.includes(index)) {
  1618.       this.uploadChunk();
  1619.       return
  1620.     }
  1621.     const {
  1622.       uploadUrl,
  1623.       query,
  1624.       header
  1625.     } = this.config;
  1626.     const identifier = this.identifier;
  1627.     const url = addParams(uploadUrl, {
  1628.       ...query,
  1629.       identifier,
  1630.       index,
  1631.       chunkSize: length,
  1632.       fileName: this.config.fileName,
  1633.       totalChunks: this.totalChunks,
  1634.       totalSize: this.totalSize
  1635.     });
  1636.     logger.debug(`uploadChunk index: ${index}, lenght ${length}`);
  1637.     logger.time(`[Uploader] uploadChunk index-${index}`);
  1638.     this._requestAsync({
  1639.       url,
  1640.       data: chunk,
  1641.       header: {
  1642.         ...header,
  1643.         'content-type': 'application/octet-stream'
  1644.       },
  1645.       method: 'POST',
  1646.     }, (task) => {
  1647.       this.uploadTasks[index] = task;
  1648.     }).then((res) => {
  1649.       if (res.data.result.status_info.status_code != 100) {
  1650.         this.cancel();
  1651.         return
  1652.       }
  1653.       this.chunksSend++;
  1654.       delete this.uploadTasks[index];
  1655.       this.updateUploadSize(length);
  1656.       logger.debug(`uploadChunk success chunksSend: ${this.chunksSend}`);
  1657.       logger.timeEnd(`[Uploader] uploadChunk index-${index}`);
  1658.       // 尝试继续加载文件
  1659.       this.readFileChunk();
  1660.       // 尝试继续发送下一条
  1661.       this.uploadChunk();
  1662.       // 所有分片发送完毕
  1663.       if (this.chunksSend === this.chunksNeedSend) {
  1664.         this.emit('uploadDone');
  1665.       }
  1666.       return null
  1667.     }).catch(res => {
  1668.       if (res.errMsg.includes('request:fail abort')) {
  1669.         logger.info(`chunk index-${index} will be aborted`);
  1670.       } else {
  1671.         this.handleFail({
  1672.           errCode: 20002,
  1673.           errMsg: res.errMsg
  1674.         });
  1675.       }
  1676.     });
  1677.   }
  1678.  
  1679.   emit(event, data) {
  1680.     this.emitter.emit(event, data);
  1681.   }
  1682.  
  1683.   on(event, listenr) {
  1684.     this.emitter.on(event, listenr);
  1685.   }
  1686.  
  1687.   off(event, listenr) {
  1688.     this.emitter.off(event, listenr);
  1689.   }
  1690.  
  1691.   generateIdentifier() {
  1692.     let identifier = '';
  1693.     const generator = this.config.generateIdentifier;
  1694.     if (isFunction(generator)) {
  1695.       identifier = generator();
  1696.     } else {
  1697.       const uuid = `${appId}-${Date.now()}-${Math.random()}`;
  1698.       identifier = sparkMd5.hash(uuid);
  1699.     }
  1700.     return identifier
  1701.   }
  1702.  
  1703.   async computeMD5() {
  1704.     const {
  1705.       tempFilePath,
  1706.       totalSize,
  1707.       chunkSize
  1708.     } = this;
  1709.  
  1710.     // 文件比内存限制小时，保存分片
  1711.     const isltMaxMemory = totalSize < this.config.maxMemory;
  1712.     const sliceSize = isltMaxMemory ? chunkSize : 10 * MB;
  1713.     const sliceNum = Math.ceil(totalSize / sliceSize);
  1714.     const spark = new sparkMd5.ArrayBuffer();
  1715.     for (let i = 0; i < sliceNum; i++) {
  1716.       const position = i * sliceSize;
  1717.       const length = Math.min(totalSize - position, sliceSize);
  1718.       // eslint-disable-next-line no-await-in-loop
  1719.       const [readFileErr, readFileResp] = await awaitWrap(readFileAsync({
  1720.         filePath: tempFilePath,
  1721.         position,
  1722.         length
  1723.       }));
  1724.  
  1725.       if (readFileErr) {
  1726.         spark.destroy();
  1727.         throw (new Error(readFileErr.errMsg))
  1728.       }
  1729.  
  1730.       const chunk = readFileResp.data;
  1731.       if (isltMaxMemory) {
  1732.         this.chunksQueue.push({
  1733.           chunk,
  1734.           length,
  1735.           index: i
  1736.         });
  1737.       }
  1738.       spark.append(chunk);
  1739.     }
  1740.     this.chunksIndexNeedRead = [];
  1741.     const identifier = spark.end();
  1742.     spark.destroy();
  1743.     return identifier
  1744.   }
  1745.  
  1746.   async verifyRequest() {
  1747.     const {
  1748.       verifyUrl,
  1749.       fileName
  1750.     } = this.config;
  1751.     const verifyResp = await this._requestAsync({
  1752.       url: verifyUrl,
  1753.       data: {
  1754.         fileName,
  1755.         identifier: this.identifier
  1756.       }
  1757.     });
  1758.     return verifyResp
  1759.   }
  1760.  
  1761.   async mergeRequest() {
  1762.     const {
  1763.       mergeUrl,
  1764.       fileName
  1765.     } = this.config;
  1766.     const mergeResp = await this._requestAsync({
  1767.       url: mergeUrl,
  1768.       data: {
  1769.         fileName,
  1770.         identifier: this.identifier
  1771.       }
  1772.     });
  1773.     return mergeResp
  1774.   }
  1775. }
  1776.  
  1777. export default Uploader;
  1778. //# sourceMappingURL=uploader.js.map

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/66671
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号