utils.js 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264
  1. 'use strict'
  2. var CryptoJS = require("crypto-js");
  3. require('dotenv').config()
  4. const logger = require('./logger')
  5. const chinaTime = require('china-time');
  6. var { cryppt_config } = require('../config/config.js')
  7. const moment = require('moment-timezone');
  8. function toJson(code_, obj_, errMsg_) {
  9. var code = code_
  10. var data = obj_
  11. var errMsg = errMsg_
  12. let jopt = { code, data, errMsg };
  13. return JSON.stringify(jopt)
  14. }
  15. function decryptJson(message, key) {
  16. }
  17. /**
  18. *
  19. * @param {*} crypt_key 密文
  20. * @param {*} message 待解密的内容 U2FsdGVkX18zHfDE3lO2yVxk2lMCEiwjrzYo1ZbHqfriFapZWXqLhczs9J0cN9EnvQR64GLRzYDgzMuAr9U1C0LZjA5mV4cSAZeBOrY8KNY09+BhTDetb2/43bIwiFR6
  21. */
  22. function decryptPrivityKey(message) {
  23. // var encrypted = 'Zc4v3uJgPY+BVg/IrDLA4aIk9ko/UrgjAtBTLqymdMAvmqdp1GttRjkBgNNNTyxA+3ThbIGlM0INeeHGicYVbLea4ymkty8gd30rZXQ4yYQ='; //python is base64 ECB
  24. // var key = '0IPmaec1o9FQCqGN'//key used in Python
  25. // var iv = 'Zh4A7bOY2ksp9oIn'
  26. var encrypted = message; //python is base64 ECB
  27. var key = process.env.DENET_CRYPT_KEY
  28. var iv = process.env.DENET_CRYPT_IV
  29. if (!key || !iv) {
  30. logger.error('decryptPrivityKey key or iv is empty?');
  31. return null;
  32. }
  33. logger.log('encrypted=', encrypted);
  34. // logger.log('decryptPrivityKey key= iv=', key, iv);
  35. key = CryptoJS.enc.Utf8.parse(key);
  36. // var decrypted = CryptoJS.AES.decrypt(encrypted, key, {mode:CryptoJS.mode.ECB});
  37. iv = CryptoJS.enc.Utf8.parse(iv)
  38. var decrypted = CryptoJS.AES.decrypt(encrypted, key, { iv: iv, mode: CryptoJS.mode.CBC });
  39. var de_pk = decrypted.toString(CryptoJS.enc.Utf8);
  40. // logger.log('decrypted==', de_pk);
  41. return de_pk
  42. }
  43. // console.log('decryptPrivityKey 1',decryptPrivityKey('8C9oepm9euh9UwPfqVf0QaP5qUjZsghT/rRlM3I1NemLACM8N4yx0wHgHnH5sZGM/ai5yg1MJnJMbfmApss/y5Chq8Ys+mZjIVrru2IWl/I='))
  44. // console.log('decryptPrivityKey 2',decryptPrivityKey('4Uz4Jm7Xd1gH+1nFbR0B7hk1ITmsT8O3iAgS/hC0L9TkrqAZoklsQhXl4fA1X+uqpckF4HtnXnMpwng94GvvzsRfXYirfDfboneuzfc0o7s='))
  45. // console.log('decryptPrivityKey 3',decryptPrivityKey('mNSzG6qmijKGldl4EJ9qViv4L5nWjkxR66Xd6E31OS3wiYY55aCfL8w0eYM3GC8bkNTFpQf'))
  46. // 密钥
  47. const SECRET_KEY = CryptoJS.enc.Utf8.parse(cryppt_config.WITHDRAW_KEY);
  48. // 密钥偏移量
  49. const SECRET_IV = CryptoJS.enc.Utf8.parse("68F37CFC40C330D9FAAC0A16D49C8AD5");
  50. /**
  51. * 加密方法
  52. * @param data
  53. * @returns {string}
  54. */
  55. function encrypt(data) {
  56. if (typeof data === "object") {
  57. try {
  58. data = JSON.stringify(data);
  59. } catch (error) {
  60. console.log("encrypt error:", error);
  61. }
  62. }
  63. const dataHex = CryptoJS.enc.Utf8.parse(data);
  64. const encrypted = CryptoJS.AES.encrypt(dataHex, SECRET_KEY, {
  65. mode: CryptoJS.mode.ECB,
  66. padding: CryptoJS.pad.Pkcs7
  67. });
  68. return encrypted.ciphertext.toString();
  69. }
  70. /**
  71. * 解密方法
  72. * @param data
  73. * @returns {string}
  74. */
  75. function decrypt(data) {
  76. // const key = CryptoJS.enc.Hex.parse(SECRET_KEY);
  77. const decrypt = CryptoJS.AES.decrypt(data, SECRET_KEY, {
  78. mode: CryptoJS.mode.ECB,
  79. padding: CryptoJS.pad.Pkcs7
  80. });
  81. return CryptoJS.enc.Utf8.stringify(decrypt).toString();
  82. }
  83. const CHAIN_NAME = {
  84. eth: 'eth',
  85. bsc_testnet: 'bsc testnet',
  86. bsc_mainnet: 'bsc',
  87. czz: 'czz',
  88. kcc_testnet: 'kcc_testnet',
  89. kcc_mainnet: 'kcc_mainnet',
  90. okc_testnet: 'okc_testnet',
  91. okc_mainnet: 'okc_mainnet',
  92. }
  93. const CHAIN_ID = {
  94. eth: '0x1',
  95. bsc_testnet: '0x61',
  96. bsc_mainnet: '0x38',
  97. czz: '2019',
  98. kcc_testnet: '322',
  99. kcc_mainnet: '321',
  100. okc_testnet: '65',
  101. okc_mainnet: '66',
  102. }
  103. const CHAIN_ID_NAME = {
  104. 97: 'bsc_testnet',
  105. 56: 'bsc_mainnet',
  106. 2019: 'czz',
  107. 65: 'okc_testnet',
  108. 66: 'okc_mainnet',
  109. 321: 'kcc_mainnet',
  110. 322: 'kcc_testnet',
  111. }
  112. const USE_SDK = {
  113. MORALIS: 'moralis',
  114. DENET: 'denet',
  115. }
  116. function getRedisKeyFromChain(chain) {
  117. switch (chain) {
  118. case CHAIN_NAME.bsc_mainnet:
  119. case CHAIN_NAME.bsc_testnet:
  120. case 'bsc_testnet':
  121. case 'bsc_mainnet':
  122. case '97':
  123. case '56':
  124. return '_BSC'
  125. case CHAIN_NAME.czz:
  126. case CHAIN_ID.czz :
  127. return '_CZZ'
  128. case CHAIN_NAME.kcc_mainnet:
  129. case CHAIN_NAME.kcc_testnet:
  130. case CHAIN_ID.kcc_mainnet:
  131. case CHAIN_ID.kcc_testnet:
  132. return '_KCC'
  133. case CHAIN_NAME.okc_mainnet:
  134. case CHAIN_NAME.okc_testnet:
  135. case CHAIN_ID.okc_mainnet:
  136. case CHAIN_ID.okc_testnet:
  137. return '_OKC'
  138. default:
  139. return null
  140. }
  141. }
  142. function trim(str) {
  143. try {
  144. return str.replace(/(^\s*)|(\s*$)/g, "");
  145. } catch (error) {
  146. logger.error('trim error', error.toString())
  147. return str
  148. }
  149. }
  150. function getChainName(key) {
  151. return CHAIN_NAME[key];
  152. }
  153. function getChainIdToName(key) {
  154. return CHAIN_ID_NAME[key];
  155. }
  156. function getChainId(key) {
  157. return CHAIN_ID[key];
  158. }
  159. function sleep(time) {
  160. return new Promise((resolve) => setTimeout(resolve, time));
  161. }
  162. function getTimestamp() {
  163. return new Date().getTime()
  164. }
  165. function getCurrentDate() {
  166. return chinaTime('YYYY-MM-DD HH:mm:ss');
  167. }
  168. function getCurrentDateFormat(format) {
  169. return chinaTime(format);
  170. }
  171. function chinaTimeMs(format, ms) {
  172. return format
  173. ? moment(ms).tz('Asia/Shanghai').format(format)
  174. : new Date(moment(ms).tz('Asia/Shanghai').format('YYYY-MM-DD HH:mm'));
  175. }
  176. function getLastDay(format) {
  177. return moment().subtract(1, 'day').tz('Asia/Shanghai').format(format)
  178. }
  179. function getTimestampToDate(tm) {
  180. var now = new Date(tm),
  181. y = now.getFullYear(),
  182. m = now.getMonth() + 1,
  183. d = now.getDate();
  184. return y + '-' + (m < 10 ? '0' + m : m) + '-' + (d < 10 ? '0' + d : d) + 'T' + now.toTimeString().substr(0, 8) + '.000Z';
  185. }
  186. /**
  187. * @description 科学计数法转为string
  188. * @param {string, number} param
  189. */
  190. function scientificNotationToString(param) {
  191. try {
  192. let strParam = String(param)
  193. let flag = /e/.test(strParam)
  194. if (!flag) return param
  195. // 指数符号 true: 正,false: 负
  196. let sysbol = true
  197. if (/e-/.test(strParam)) {
  198. sysbol = false
  199. }
  200. // 指数
  201. let index = Number(strParam.match(/\d+$/)[0])
  202. // 基数
  203. let basis = strParam.match(/^[\d\.]+/)[0].replace(/\./, '')
  204. if (sysbol) {
  205. return basis.padEnd(index + 1, 0)
  206. } else {
  207. return basis.padStart(index + basis.length, 0).replace(/^0/, '0.')
  208. }
  209. } catch (error) {
  210. return param.toString()
  211. }
  212. }
  213. module.exports = {
  214. toJson,
  215. decryptPrivityKey,
  216. getChainName,
  217. getChainId,
  218. CHAIN_NAME,
  219. CHAIN_ID,
  220. USE_SDK,
  221. sleep,
  222. encrypt,
  223. decrypt,
  224. getTimestamp,
  225. getChainIdToName,
  226. getCurrentDate,
  227. getCurrentDateFormat,
  228. scientificNotationToString,
  229. getTimestampToDate,
  230. getRedisKeyFromChain,
  231. trim,
  232. getLastDay,
  233. }