|
@@ -553,19 +553,18 @@ async function execCollectCoinsTask() {
|
|
isExecCollect = true;
|
|
isExecCollect = true;
|
|
while (collectCoinsArrays.length > 0) {
|
|
while (collectCoinsArrays.length > 0) {
|
|
var obj = collectCoinsArrays.pop();
|
|
var obj = collectCoinsArrays.pop();
|
|
- lastCollectCoinsAddress = obj.address;
|
|
|
|
//开始收集用户地址里面的币到归集地址
|
|
//开始收集用户地址里面的币到归集地址
|
|
var ret = await collectCoins(obj);
|
|
var ret = await collectCoins(obj);
|
|
// await utils.sleep(3000)
|
|
// await utils.sleep(3000)
|
|
logger.log('execCollectCoinsTask=', collectCoinsArrays.length, ret)
|
|
logger.log('execCollectCoinsTask=', collectCoinsArrays.length, ret)
|
|
- lastCollectCoinsAddress = ''
|
|
|
|
}
|
|
}
|
|
isExecCollect = false;
|
|
isExecCollect = false;
|
|
|
|
+ lastCollectCoinsAddress = ''
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
function pushCollectConisObj(obj) {
|
|
function pushCollectConisObj(obj) {
|
|
- logger.debug('collectCoinsArrays length=', collectCoinsArrays.length)
|
|
|
|
|
|
+ logger.debug('collectCoinsArrays length=', collectCoinsArrays.length,lastCollectCoinsAddress)
|
|
if (collectCoinsArrays.length > 0) {
|
|
if (collectCoinsArrays.length > 0) {
|
|
var findItem = collectCoinsArrays.find(element => {
|
|
var findItem = collectCoinsArrays.find(element => {
|
|
return (obj.address == element.address) || (!lastCollectCoinsAddress && lastCollectCoinsAddress == element.address)
|
|
return (obj.address == element.address) || (!lastCollectCoinsAddress && lastCollectCoinsAddress == element.address)
|
|
@@ -577,6 +576,7 @@ function pushCollectConisObj(obj) {
|
|
}
|
|
}
|
|
collectCoinsArrays.push(obj)
|
|
collectCoinsArrays.push(obj)
|
|
execCollectCoinsTask();
|
|
execCollectCoinsTask();
|
|
|
|
+ lastCollectCoinsAddress = obj.address;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|