|
@@ -628,6 +628,7 @@ async function execCollectCoinsTask() {
|
|
|
isExecCollect = true;
|
|
|
while (collectCoinsArrays.length > 0) {
|
|
|
var obj = collectCoinsArrays.pop();
|
|
|
+ lastCollectCoinsAddress = obj.address;
|
|
|
//开始收集用户地址里面的币到归集地址
|
|
|
var ret = await collectCoins(obj);
|
|
|
// await utils.sleep(3000)
|
|
@@ -640,18 +641,17 @@ async function execCollectCoinsTask() {
|
|
|
|
|
|
function pushCollectConisObj(obj) {
|
|
|
logger.debug('collectCoinsArrays length=', collectCoinsArrays.length, lastCollectCoinsAddress)
|
|
|
- if (collectCoinsArrays.length > 0) {
|
|
|
- var findItem = collectCoinsArrays.find(element => {
|
|
|
- return (obj.address == element.address) || (!lastCollectCoinsAddress && lastCollectCoinsAddress == element.address)
|
|
|
- })
|
|
|
- if (findItem) {
|
|
|
- logger.log('当前任务正在处理中...', obj.address)
|
|
|
- return;
|
|
|
- }
|
|
|
- }
|
|
|
+ // if (collectCoinsArrays.length > 0) {
|
|
|
+ // var findItem = collectCoinsArrays.find(element => {
|
|
|
+ // return (obj.address == element.address) || (!lastCollectCoinsAddress && lastCollectCoinsAddress == element.address)
|
|
|
+ // })
|
|
|
+ // if (findItem) {
|
|
|
+ // logger.log('当前任务正在处理中...', obj.address)
|
|
|
+ // return;
|
|
|
+ // }
|
|
|
+ // }
|
|
|
collectCoinsArrays.push(obj)
|
|
|
execCollectCoinsTask();
|
|
|
- lastCollectCoinsAddress = obj.address;
|
|
|
}
|
|
|
|
|
|
|