Commit 7c7eaf47 authored by 李伟@五瓣科技's avatar 李伟@五瓣科技

fix from addr

parent f43a3562
...@@ -725,16 +725,22 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string, ...@@ -725,16 +725,22 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string,
count++ count++
first = false first = false
valueStream <- TxWithFrom{
From: common.HexToAddress(systemFromAddr).Bytes(),
Tx: tx,
}
} else { } else {
tx, _ = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(toAddrs[count%addrsL]), amount, big.NewInt(256), nil) tx, _ = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(toAddrs[count%addrsL]), amount, big.NewInt(256), nil)
valueStream <- TxWithFrom{
From: common.HexToAddress(fromAddr).Bytes(),
Tx: tx,
}
} }
originalTxParam.Nonce++ originalTxParam.Nonce++
valueStream <- TxWithFrom{
From: common.HexToAddress(systemFromAddr).Bytes(),
Tx: tx,
}
count-- count--
if count == 0 { if count == 0 {
close(valueStream) close(valueStream)
...@@ -850,7 +856,6 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string, ...@@ -850,7 +856,6 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string,
} }
} }
} }
return nil return nil
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment