|
@@ -84,6 +84,7 @@ async function getAllTokenWithdrawInfoLists(ctx) {
|
|
|
}
|
|
|
|
|
|
async function collect_conis_task() {
|
|
|
+ logger.log("collect_conis_task start")
|
|
|
while (true) {
|
|
|
var exec_obj = await redis.redis_pop(reids_token_config.COLLECT_CONIS_QUEUE_KEY)
|
|
|
if (!exec_obj) {
|
|
@@ -95,7 +96,7 @@ async function collect_conis_task() {
|
|
|
try {
|
|
|
exec_obj = JSON.parse(exec_obj)
|
|
|
} catch (error) {
|
|
|
- logger.error('item parse error', error);
|
|
|
+ logger.error('item parse error', error.toString());
|
|
|
break
|
|
|
}
|
|
|
logger.log('collect_conis_task exec item>>>>', exec_obj);
|
|
@@ -103,10 +104,12 @@ async function collect_conis_task() {
|
|
|
var ret = await moralis.collectCoins(exec_obj)
|
|
|
logger.log('collect_conis_task ret =', exec_obj, ret)
|
|
|
}
|
|
|
+ logger.log("collect_conis_task end")
|
|
|
}
|
|
|
|
|
|
|
|
|
async function withdraw_task() {
|
|
|
+ logger.log("withdraw_task start")
|
|
|
let last_time = 0
|
|
|
let last_hash = ''
|
|
|
|
|
@@ -200,6 +203,8 @@ async function withdraw_task() {
|
|
|
logger.error('withdraw_task error=', error.toString())
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ logger.log("withdraw_task end")
|
|
|
}
|
|
|
|
|
|
/**
|