common.js 7.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303
  1. /**
  2. * 通用公共函数
  3. */
  4. var common = {};
  5. /**
  6. * 日期格式化
  7. */
  8. common.timeFormat = function(time, fmt = 'yyyy-MM-dd hh:mm:ss', targetTimezone = 8) {
  9. try {
  10. if (!time) {
  11. return "";
  12. }
  13. if (typeof time === "string" && !isNaN(time)) time = Number(time);
  14. // 其他更多是格式化有如下:
  15. // yyyy-MM-dd hh:mm:ss|yyyy年MM月dd日 hh时MM分等,可自定义组合
  16. let date;
  17. if (typeof time === "number") {
  18. if (time.toString().length == 10) time *= 1000;
  19. date = new Date(time);
  20. } else {
  21. date = time;
  22. }
  23. const dif = date.getTimezoneOffset();
  24. const timeDif = dif * 60 * 1000 + (targetTimezone * 60 * 60 * 1000);
  25. const east8time = date.getTime() + timeDif;
  26. date = new Date(east8time);
  27. let opt = {
  28. "M+": date.getMonth() + 1, //月份
  29. "d+": date.getDate(), //日
  30. "h+": date.getHours(), //小时
  31. "m+": date.getMinutes(), //分
  32. "s+": date.getSeconds(), //秒
  33. "q+": Math.floor((date.getMonth() + 3) / 3), //季度
  34. "S": date.getMilliseconds() //毫秒
  35. };
  36. if (/(y+)/.test(fmt)) {
  37. fmt = fmt.replace(RegExp.$1, (date.getFullYear() + "").substr(4 - RegExp.$1.length));
  38. }
  39. for (let k in opt) {
  40. if (new RegExp("(" + k + ")").test(fmt)) {
  41. fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (opt[k]) : (("00" + opt[k]).substr(("" + opt[
  42. k]).length)));
  43. }
  44. }
  45. return fmt;
  46. } catch (err) {
  47. // 若格式错误,则原值显示
  48. return time;
  49. }
  50. };
  51. /**
  52. * 产生订单号,不依赖数据库,高并发时性能高(理论上会重复,但概率非常非常低)
  53. */
  54. common.createOrderNo = function(prefix = "", num = 25) {
  55. // 获取当前时间字符串格式如20200803093000123
  56. let timeStr = common.timeFormat(Date.now(), "yyyyMMddhhmmssS");
  57. timeStr = timeStr.substring(2);
  58. let randomNum = num - (prefix + timeStr).length;
  59. return prefix + timeStr + common.random(randomNum, "123456789");
  60. };
  61. /**
  62. * 产生随机数
  63. */
  64. common.random = function(length, list = "123456789") {
  65. let s = "";
  66. for (let i = 0; i < length; i++) {
  67. let code = list[Math.floor(Math.random() * list.length)];
  68. s += code;
  69. }
  70. return s;
  71. };
  72. /**
  73. * 休眠,等待(单位毫秒)
  74. * @param {Number} ms 毫秒
  75. * await common.sleep(1000);
  76. */
  77. common.sleep = ms => new Promise(resolve => setTimeout(resolve, ms));
  78. /**
  79. * 获取platform
  80. * let provider_pay_type = common.getPlatform(platform);
  81. */
  82. common.getPlatform = function(platform) {
  83. if (["h5", "web"].indexOf(platform) > -1) {
  84. platform = "web";
  85. } else if (["app", "app-plus"].indexOf(platform) > -1) {
  86. platform = "app";
  87. }
  88. return platform;
  89. };
  90. /**
  91. * 获取 provider_pay_type
  92. let provider_pay_type = common.getProviderPayType({
  93. platform,
  94. provider,
  95. ua,
  96. qr_code
  97. });
  98. */
  99. common.getProviderPayType = function(data) {
  100. let {
  101. platform,
  102. provider,
  103. ua,
  104. qr_code
  105. } = data;
  106. // 扫码支付
  107. if (qr_code) return "native";
  108. // 小程序支付
  109. if (platform.indexOf("mp") > -1) return "mp";
  110. // APP支付
  111. if (platform.indexOf("app") > -1) return "app";
  112. // 微信公众号支付
  113. if (platform === "web" && provider === "wxpay" && ua.toLowerCase().indexOf("micromessenger") > -1) return "jsapi";
  114. // 微信外部浏览器支付
  115. if (platform === "web" && provider === "wxpay" && ua.toLowerCase().indexOf("micromessenger") === -1) return "mweb";
  116. if (platform === "web" && provider === "alipay") return "native";
  117. throw new Error(`不支持的支付方式${provider}-${platform}`);
  118. };
  119. /**
  120. * 获取uniPay交易类型
  121. let tradeType = common.getTradeType({ provider, provider_pay_type });
  122. */
  123. common.getTradeType = function(data) {
  124. let { provider, provider_pay_type } = data;
  125. let pay_type = `${provider}_${provider_pay_type}`;
  126. let obj = {
  127. // 微信
  128. "wxpay_app": "APP", // 微信app支付
  129. "wxpay_mp": "JSAPI", // 微信小程序支付
  130. "wxpay_native": "NATIVE", // 微信扫码支付
  131. "wxpay_mweb": "MWEB", // 微信外部浏览器支付
  132. "wxpay_jsapi": "JSAPI", // 微信公众号支付
  133. // 支付宝
  134. "alipay_app": "APP", // 支付宝app支付
  135. "alipay_mp": "JSAPI", // 支付宝小程序支付
  136. "alipay_native": "NATIVE", // 支付宝扫码支付
  137. "alipay_mweb": "NATIVE", // 支付宝外部浏览器支付
  138. };
  139. return obj[pay_type];
  140. };
  141. /**
  142. * 给第三方服务器返回成功通知
  143. */
  144. common.returnNotifySUCCESS = function(data) {
  145. let { provider, provider_pay_type } = data;
  146. if (provider === "wxpay") {
  147. // 微信支付需返回 xml 格式的字符串
  148. return {
  149. mpserverlessComposedResponse: true,
  150. statusCode: 200,
  151. headers: {
  152. 'content-type': 'text/xml;charset=utf-8'
  153. },
  154. body: "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>"
  155. };
  156. } else if (provider === "alipay") {
  157. // 支付宝支付直接返回 success 字符串
  158. return {
  159. mpserverlessComposedResponse: true,
  160. statusCode: 200,
  161. headers: {
  162. 'content-type': 'text/plain'
  163. },
  164. body: "success"
  165. }
  166. } else if (provider === "wxpay-virtual") {
  167. // 微信虚拟支付返回对象形式 { ErrCode: 0, ErrMsg: "success" }
  168. return {
  169. "ErrCode": 0,
  170. "ErrMsg": "success"
  171. }
  172. }
  173. return "success";
  174. };
  175. // 获取异步通知的参数,并转成json对象
  176. common.getNotifyData = function(data) {
  177. let {
  178. provider,
  179. httpInfo
  180. } = data;
  181. let json = {};
  182. let body = httpInfo.body;
  183. if (httpInfo.isBase64Encoded) {
  184. body = Buffer.from(body, 'base64').toString('utf-8');
  185. }
  186. if (provider === "wxpay") {
  187. if (body.indexOf("<xml>") > -1) {
  188. // 微信支付v2
  189. json = common.parseXML(body);
  190. } else {
  191. // 微信支付v3
  192. json = typeof body === "string" ? JSON.parse(body) : body;
  193. }
  194. } else if (provider === "alipay") {
  195. // 支付宝支付
  196. json = common.urlStringToJson(body);
  197. } else if (provider === "wxpay-virtual") {
  198. // 微信小程序虚拟支付
  199. json = typeof body === "string" ? JSON.parse(body) : body;
  200. json.out_trade_no = json.OutTradeNo;
  201. }
  202. return json;
  203. };
  204. // 简易版XML转Object,只可在微信支付时使用,不支持嵌套
  205. common.parseXML = function(xml) {
  206. const xmlReg = /<(?:xml|root).*?>([\s|\S]*)<\/(?:xml|root)>/
  207. const str = xmlReg.exec(xml)[1]
  208. const obj = {}
  209. const nodeReg = /<(.*?)>(?:<!\[CDATA\[){0,1}(.*?)(?:\]\]>){0,1}<\/.*?>/g
  210. let matches = null
  211. // eslint-disable-next-line no-cond-assign
  212. while ((matches = nodeReg.exec(str))) {
  213. obj[matches[1]] = matches[2]
  214. }
  215. return obj
  216. };
  217. // url参数转json
  218. common.urlStringToJson = function(str) {
  219. let json = {};
  220. if (str != "" && str != undefined && str != null) {
  221. let arr = str.split("&");
  222. for (let i = 0; i < arr.length; i++) {
  223. let arrstr = arr[i].split("=");
  224. let k = arrstr[0];
  225. let v = arrstr[1];
  226. json[k] = v;
  227. }
  228. }
  229. return json;
  230. };
  231. const isSnakeCase = new RegExp('_(\\w)', 'g');
  232. const isCamelCase = new RegExp('[A-Z]', 'g');
  233. function parseObjectKeys(obj, type) {
  234. let parserReg;
  235. let parser;
  236. switch (type) {
  237. case 'snake2camel':
  238. parser = common.snake2camel
  239. parserReg = isSnakeCase
  240. break
  241. case 'camel2snake':
  242. parser = common.camel2snake
  243. parserReg = isCamelCase
  244. break
  245. }
  246. for (const key in obj) {
  247. if (Object.prototype.hasOwnProperty.call(obj, key)) {
  248. if (parserReg.test(key)) {
  249. const keyCopy = parser(key)
  250. obj[keyCopy] = obj[key]
  251. delete obj[key]
  252. if (Object.prototype.toString.call((obj[keyCopy])) === '[object Object]') {
  253. obj[keyCopy] = parseObjectKeys(obj[keyCopy], type)
  254. } else if (Array.isArray(obj[keyCopy])) {
  255. obj[keyCopy] = obj[keyCopy].map((item) => {
  256. return parseObjectKeys(item, type)
  257. })
  258. }
  259. }
  260. }
  261. }
  262. return obj
  263. }
  264. common.snake2camel = function(value) {
  265. return value.replace(isSnakeCase, (_, c) => (c ? c.toUpperCase() : ''))
  266. }
  267. common.camel2snake = function(value) {
  268. return value.replace(isCamelCase, str => '_' + str.toLowerCase())
  269. }
  270. // 转驼峰
  271. common.snake2camelJson = function(obj) {
  272. return parseObjectKeys(obj, 'snake2camel');
  273. };
  274. // 转蛇形
  275. common.camel2snakeJson = function(obj) {
  276. return parseObjectKeys(obj, 'camel2snake');
  277. };
  278. module.exports = common;