|
@@ -641,15 +641,15 @@ 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();
|
|
|
}
|