helper.js 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417
  1. 'use strict';
  2. /**
  3. * 辅助方法扩展
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/9/28
  7. * @version
  8. */
  9. const zeroRange = 0.0000000001;
  10. const fs = require('fs');
  11. const streamToArray = require('stream-to-array');
  12. const _ = require('lodash');
  13. module.exports = {
  14. /**
  15. * 生成随机字符串
  16. *
  17. * @param {Number} length - 需要生成字符串的长度
  18. * @param {Number} type - 1为数字和字符 2为纯数字 3为纯字母
  19. * @return {String} - 返回生成结果
  20. */
  21. generateRandomString(length, type = 1) {
  22. length = parseInt(length);
  23. length = isNaN(length) ? 1 : length;
  24. let randSeed = [];
  25. let numberSeed = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
  26. let stringSeed = ['A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S',
  27. 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o',
  28. 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z'];
  29. switch (type) {
  30. case 1:
  31. randSeed = stringSeed.concat(numberSeed);
  32. stringSeed = numberSeed = null;
  33. break;
  34. case 2:
  35. randSeed = numberSeed;
  36. break;
  37. case 3:
  38. randSeed = stringSeed;
  39. break;
  40. default:
  41. break;
  42. }
  43. const seedLength = randSeed.length - 1;
  44. let result = '';
  45. for (let i = 0; i < length; i++) {
  46. const index = Math.ceil(Math.random() * seedLength);
  47. result += randSeed[index];
  48. }
  49. return result;
  50. },
  51. /**
  52. * 显示排序符号
  53. *
  54. * @param {String} field - 字段名称
  55. * @return {String} - 返回字段排序的符号
  56. */
  57. showSortFlag(field) {
  58. const sort = this.ctx.sort;
  59. if (!(sort instanceof Array) || sort.length !== 2) {
  60. return '';
  61. }
  62. sort[1] = sort[1].toUpperCase();
  63. return (sort[0] === field && sort[1] === 'DESC') ? '' : '-';
  64. },
  65. /**
  66. * 判断是否为ajax请求
  67. *
  68. * @param {Object} request - 请求数据
  69. * @return {boolean} 判断结果
  70. */
  71. isAjax(request) {
  72. let headerInfo = request.headers['x-requested-with'] === undefined ? '' : request.headers['x-requested-with'];
  73. headerInfo = headerInfo.toLowerCase();
  74. return headerInfo === 'xmlhttprequest';
  75. },
  76. /**
  77. * 模拟发送请求
  78. *
  79. * @param {String} url - 请求地址
  80. * @param {Object} data - 请求数据
  81. * @param {String} type - 请求类型(POST) POST | GET
  82. * @param {String} dataType - 数据类型 json|text
  83. * @return {Object} - 请求结果
  84. */
  85. async sendRequest(url, data, type = 'POST', dataType = 'json') {
  86. // 发起请求
  87. const response = await this.ctx.curl(url, {
  88. method: type,
  89. data,
  90. dataType,
  91. });
  92. if (response.status !== 200) {
  93. throw '请求失败';
  94. }
  95. return response.data;
  96. },
  97. /**
  98. * 深度验证数据
  99. *
  100. * @param {Object} rule - 数据规则
  101. * @return {void}
  102. */
  103. validate(rule) {
  104. // 先用内置的验证器验证数据
  105. this.ctx.validate(rule);
  106. // 然后再验证是否有多余的数据
  107. const postData = this.ctx.request.body;
  108. delete postData._csrf;
  109. const postDataKey = Object.keys(postData);
  110. const ruleKey = Object.keys(rule);
  111. // 自动增加字段则填充上,以防判断出错
  112. if (postData.create_time !== undefined) {
  113. ruleKey.push('create_time');
  114. }
  115. for (const tmp of postDataKey) {
  116. // 规则里面没有定义则抛出异常
  117. if (ruleKey.indexOf(tmp) < 0) {
  118. throw '参数不正确';
  119. }
  120. }
  121. },
  122. /**
  123. * 拆分path
  124. *
  125. * @param {String|Array} paths - 拆分字符
  126. * @param {String} symbol - 拆分符号
  127. * @return {Array} - 拆分结果
  128. */
  129. explodePath(paths, symbol = '.') {
  130. const result = [];
  131. paths = paths instanceof Array ? paths : [paths];
  132. for (const path of paths) {
  133. // 拆分数据
  134. const pathArray = path.split(symbol);
  135. // 用户缓存循环的数据
  136. const tmpArray = [];
  137. for (const tmp of pathArray) {
  138. // 每次循环都追加一个数据进去
  139. tmpArray.push(tmp);
  140. const tmpPathString = tmpArray.join(symbol);
  141. // 判断是否已经存在有对应数据
  142. if (result.indexOf(tmpPathString) >= 0) {
  143. continue;
  144. }
  145. result.push(tmpPathString);
  146. }
  147. }
  148. return result;
  149. },
  150. /**
  151. * 基于obj, 拷贝sObj中的内容
  152. * obj = {a: 1, b: 2}, sObj = {a: 0, c: 3}, 返回{a: 0, b: 2, c: 3}
  153. * @param obj
  154. * @param sObj
  155. * @returns {any}
  156. */
  157. updateObj(obj, sObj) {
  158. if (!obj) {
  159. return JSON.parse(JSON.stringify(sObj));
  160. }
  161. const result = JSON.parse(JSON.stringify(obj));
  162. if (sObj) {
  163. for (const prop in sObj) {
  164. result[prop] = sObj[prop];
  165. }
  166. }
  167. return result;
  168. },
  169. /**
  170. * 在数组中查找
  171. * @param {Array} arr
  172. * @param name -
  173. * @param value
  174. * @returns {*}
  175. */
  176. findData(arr, name, value) {
  177. if (!arr instanceof Array) {
  178. throw '该方法仅用于数组查找';
  179. }
  180. if (arr.length === 0) { return undefined; }
  181. for (const data of arr) {
  182. if (data[name] == value) {
  183. return data;
  184. }
  185. }
  186. return undefined;
  187. },
  188. /**
  189. * 检查数字是否为0
  190. * @param {Number} value
  191. * @return {boolean}
  192. */
  193. checkZero(value) {
  194. return value && Math.abs(value) > zeroRange;
  195. },
  196. /**
  197. * 检查数字是否相等
  198. * @param {Number} value1
  199. * @param {Number} value2
  200. * @returns {boolean}
  201. */
  202. checkNumberEqual(value1, value2) {
  203. if (value1 && value2) {
  204. return Math.abs(value2 - value1) > zeroRange;
  205. } else {
  206. return (!value1 && !value2)
  207. }
  208. },
  209. /**
  210. * 比较编码
  211. * @param str1
  212. * @param str2
  213. * @param symbol
  214. * @returns {number}
  215. */
  216. compareCode(str1, str2, symbol = '-') {
  217. if (!str1) {
  218. return -1;
  219. } else if (!str2) {
  220. return 1;
  221. }
  222. const path1 = str1.split(symbol);
  223. const path2 = str2.split(symbol);
  224. for (let i = 0, iLen = Math.min(path1.length, path2.length); i < iLen; i++) {
  225. if (path1 < path2) {
  226. return -1;
  227. } else if (path1 > path2) {
  228. return 1;
  229. }
  230. }
  231. return path1.length - path2.length;
  232. },
  233. /**
  234. * 树结构节点排序,要求最顶层节点须在同一父节点下
  235. * @param treeNodes
  236. * @param idField
  237. * @param pidField
  238. */
  239. sortTreeNodes (treeNodes, idField, pidField) {
  240. const result = [];
  241. const getFirstLevel = function (nodes) {
  242. let result;
  243. for (const node of nodes) {
  244. if (!result || result > node.level) {
  245. result = node.level;
  246. }
  247. }
  248. return result;
  249. }
  250. const getLevelNodes = function (nodes, level) {
  251. const children = nodes.filter(function (a) {
  252. return a.level = level;
  253. });
  254. children.sort(function (a, b) {
  255. return a.order - b.order;
  256. })
  257. return children;
  258. }
  259. const getChildren = function (nodes, node) {
  260. const children = nodes.filter(function (a) {
  261. return a[pidField] = node[idField];
  262. });
  263. children.sort(function (a, b) {
  264. return a.order - b.order;
  265. })
  266. return children;
  267. }
  268. const addSortNodes = function (nodes) {
  269. for (let i = 0; i< nodes.length; i++) {
  270. result.push(nodes[i]);
  271. addSortNodes(getChildren(nodes[i]));
  272. }
  273. }
  274. const firstLevel = getFirstLevel(treeNodes);
  275. addSortNodes(getLevelNodes(treeNodes, firstLevel));
  276. },
  277. /**
  278. * 判断当前用户是否有指定权限
  279. *
  280. * @param {Number|Array} permission - 权限id
  281. * @return {Boolean} - 返回判断结果
  282. */
  283. hasPermission(permission) {
  284. let result = false;
  285. try {
  286. const sessionUser = this.ctx.session.sessionUser;
  287. if (sessionUser.permission === undefined) {
  288. throw '不存在权限数据';
  289. }
  290. let currentPermission = sessionUser.permission;
  291. if (currentPermission === '') {
  292. throw '权限数据为空';
  293. }
  294. // 管理员则直接返回结果
  295. if (currentPermission === 'all') {
  296. return true;
  297. }
  298. currentPermission = currentPermission.split(',');
  299. permission = permission instanceof Array ? permission : [permission];
  300. let counter = 0;
  301. for (const tmp of permission) {
  302. if (currentPermission[tmp] !== undefined) {
  303. counter++;
  304. }
  305. }
  306. result = counter === permission.length;
  307. } catch (error) {
  308. result = false;
  309. }
  310. return result;
  311. },
  312. /**
  313. * 将文件流的数据保存至本地文件
  314. * @param stream
  315. * @param fileName
  316. * @returns {Promise<void>}
  317. */
  318. async saveStreamFile(stream, fileName) {
  319. // 读取字节流
  320. const parts = await streamToArray(stream);
  321. // 转化为buffer
  322. const buffer = Buffer.concat(parts);
  323. // 写入文件
  324. await fs.writeFileSync(fileName, buffer);
  325. },
  326. /**
  327. * 检查code是否是指标模板数据
  328. * @param {String} code
  329. * @returns {boolean}
  330. */
  331. validBillsCode(code) {
  332. const reg1 = /(^[0-9]+)([a-z0-9\-]*)/i;
  333. const reg2 = /([a-z0-9]+$)/i;
  334. return reg1.test(code) && reg2.test(code);
  335. },
  336. getNumberFormatter(decimal) {
  337. if (decimal <= 0) {
  338. return "0";
  339. }
  340. let pre = "0.";
  341. for (let i = 0; i < decimal; i++) {
  342. pre += "#"
  343. }
  344. return pre;
  345. },
  346. /**
  347. * 根据单位查找对应的清单精度
  348. * @param {tenderInfo.precision} list - 清单精度列表
  349. * @param {String} unit - 单位
  350. * @returns {number}
  351. */
  352. findPrecision(list, unit) {
  353. if (unit) {
  354. for (const p in list) {
  355. if (list[p].unit && list[p].unit === unit) {
  356. return list[p];
  357. }
  358. }
  359. }
  360. return list.other;
  361. },
  362. /**
  363. * 检查数据中的精度
  364. * @param {Object} Obj - 检查的数据
  365. * @param {Array} fields - 检查的属性
  366. * @param {Number} precision - 精度
  367. * @constructor
  368. */
  369. checkFieldPrecision(Obj, fields, precision) {
  370. if (Obj) {
  371. for (const field of fields) {
  372. if (Obj[field]) {
  373. Obj[field] = this.round(Obj[field], precision);
  374. }
  375. }
  376. }
  377. },
  378. /**
  379. * 四舍五入(统一,方便以后万一需要置换)
  380. * @param {Number} value - 舍入的数字
  381. * @param {Number} decimal - 要保留的小数位数
  382. * @returns {*}
  383. */
  384. round(value, decimal) {
  385. return _.round(value, decimal);
  386. },
  387. };