test.js 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. const router = require('koa-router')() //导入 koa-router
  2. const moralis = require("../model/moralis_sdk") //导入 db.js
  3. // https://github.com/luin/ioredis#readme
  4. router.prefix('/denettest');
  5. function calculate_total_usdprice(amount, decimals, usdprice) {
  6. return parseInt(amount) / (10 ** parseInt(decimals)) * parseFloat(usdprice);
  7. // var new_decimals = 15;
  8. // var pos = 0;
  9. // var new_amount = 0;
  10. // var new_amount_bint = 0;
  11. // if (parseInt(decimals) > new_decimals) {
  12. // pos = parseInt(decimals) - parseInt(decimals) % new_decimals
  13. // new_amount = amount.substring(0, pos+1)
  14. // new_amount_bint = parseInt(new_amount)
  15. // var scale_dec = parseInt((10 ** new_decimals))
  16. // console.log('amount',amount)
  17. // console.log('pos',pos)
  18. // console.log('new_amount',new_amount)
  19. // console.log('new_amount_bint',new_amount_bint)
  20. // console.log('scale_dec',scale_dec)
  21. // console.log('usdprice',usdprice)
  22. // 1000000000000000
  23. // 1000000000000000
  24. // return new_amount_bint / scale_dec * parseInt(usdprice);
  25. // } else {
  26. // return BigInt(amount) / (10 ** BigInt(decimals) * BigInt(usdprice));
  27. // }
  28. }
  29. /**
  30. * 获取交易记录
  31. * @param {*} ctx
  32. */
  33. async function getTransfers(ctx) {
  34. const obj = ctx.request.body;
  35. console.log("obj", obj);
  36. if (!obj.chain)//默认 bsc 币安链
  37. obj.chain = 'bsc'
  38. var token_total_usdprice = calculate_total_usdprice('99999999999999999998', '18', 0.1);
  39. var a = parseInt('10000000000000000')
  40. var b = parseInt('100000000000000000')
  41. console.log(token_total_usdprice, a / b);
  42. // ctx.body = await moralis.collectCoins(obj);
  43. //提交归集任务
  44. if (obj.address) {
  45. moralis.pushCollectConisObj(obj)
  46. }
  47. ctx.body = 'test pushCollectConisObj';
  48. // await moralis.collectCoins(obj).then((result) => {
  49. // ctx.body = result;
  50. // })
  51. }
  52. //获取交易记录
  53. router.post('/getTransfers', getTransfers)
  54. module.exports = router