@@ -113,7 +125,7 @@
data.data.payments.map(p =>
'
| ' + new Date(p.Timestamp).toLocaleString() + ' | ' +
'' + p.Address.substring(0, 10) + '... | ' +
- '' + (p.Amount / 1000000).toFixed(6) + ' USDT | ' +
+ '' + p.Amount.toFixed(6) + ' USDT | ' +
'' + p.From.substring(0, 10) + '... | ' +
'' + p.Confirmations + ' | ' +
'' +
@@ -125,6 +137,52 @@
}
}
+ async function queryTransactions() {
+ const address = document.getElementById('queryAddress').value.trim();
+ if (!address) {
+ alert('请输入地址');
+ return;
+ }
+
+ const startTime = document.getElementById('startTime').value;
+ const endTime = document.getElementById('endTime').value;
+ const minAmount = document.getElementById('minAmount').value;
+ const minConfirmations = document.getElementById('minConfirmations').value;
+ const limit = document.getElementById('queryLimit').value;
+
+ const body = {
+ address: address,
+ startTime: startTime ? new Date(startTime).getTime() : 0,
+ endTime: endTime ? new Date(endTime).getTime() : 0,
+ minAmount: minAmount ? (parseFloat(minAmount) * 1000000).toString() : '',
+ minConfirmations: parseInt(minConfirmations) || 0,
+ limit: parseInt(limit) || 50,
+ };
+
+ const res = await fetch('/query', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify(body)
+ });
+
+ const data = await res.json();
+ if (data.success && data.data.payments && data.data.payments.length > 0) {
+ const html = ' 找到 ' + data.data.count + ' 条记录 ' +
+ '| 时间 | 金额 | 来源 | 确认数 | TxID |
|---|
' +
+ data.data.payments.map(p =>
+ '| ' + new Date(p.Timestamp).toLocaleString() + ' | ' +
+ '' + p.Amount.toFixed(6) + ' USDT | ' +
+ '' + p.From.substring(0, 10) + '... | ' +
+ '' + p.Confirmations + ' | ' +
+ '' +
+ p.TxID.substring(0, 10) + '... | '
+ ).join('') + '
';
+ document.getElementById('queryResults').innerHTML = html;
+ } else {
+ document.getElementById('queryResults').innerHTML = '' + (data.message || '未找到记录') + ' ';
+ }
+ }
+
listAddresses();
getPayments();
diff --git a/log/blocks.json b/log/blocks.json
new file mode 100644
index 0000000..717e4ad
--- /dev/null
+++ b/log/blocks.json
@@ -0,0 +1,27 @@
+{
+ "id": "2bf9c73deb56166ad38906e732a898646cfc3db15e0daab0e33a6c4e3bf0509e",
+ "blockNumber": 79809798,
+ "blockTimeStamp": 1770093843000,
+ "contractResult": [
+ "0000000000000000000000000000000000000000000000000000000000000000"
+ ],
+ "contract_address": "41a614f803b6fd780986a42c78ec9c7f77e6ded13c",
+ "receipt": {
+ "energy_usage": 130285,
+ "energy_usage_total": 130285,
+ "net_usage": 345,
+ "result": "SUCCESS",
+ "energy_penalty_total": 100635
+ },
+ "log": [
+ {
+ "address": "a614f803b6fd780986a42c78ec9c7f77e6ded13c",
+ "topics": [
+ "ddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef",
+ "0000000000000000000000006158fe96b950111b8f1f31249fedda484e941312",
+ "000000000000000000000000e5fcae42ed4ecf7e23e4a561aded72c69aeeabc0"
+ ],
+ "data": "0000000000000000000000000000000000000000000000000000000000ca54e0"
+ }
+ ]
+}
\ No newline at end of file
diff --git a/log/transactions.json b/log/transactions.json
new file mode 100644
index 0000000..ed5c66c
--- /dev/null
+++ b/log/transactions.json
@@ -0,0 +1,23 @@
+{
+ "data": [
+ {
+ "transaction_id": "2bf9c73deb56166ad38906e732a898646cfc3db15e0daab0e33a6c4e3bf0509e",
+ "token_info": {
+ "symbol": "USDT",
+ "address": "TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t",
+ "decimals": 6,
+ "name": "Tether USD"
+ },
+ "block_timestamp": 1770093843000,
+ "from": "TJqwA7SoZnERE4zW5uDEiPkbz4B66h9TFj",
+ "to": "TWwGSYwpSzT6GTBr4AQw9QF6m4VVui3UGc",
+ "type": "Transfer",
+ "value": "13260000"
+ }
+ ],
+ "success": true,
+ "meta": {
+ "at": 1770094054104,
+ "page_size": 1
+ }
+}
\ No newline at end of file
diff --git a/tron_usdt_monitor.go b/tron_usdt_monitor.go
index 58dcc2f..ae79708 100644
--- a/tron_usdt_monitor.go
+++ b/tron_usdt_monitor.go
@@ -41,6 +41,16 @@ type USDTMan struct {
httpClient *http.Client // HTTP 客户端
}
+// QueryFilter 查询过滤条件
+type QueryFilter struct {
+ Address string // 地址（必填）
+ StartTime int64 // 开始时间戳（毫秒），0 表示不限制
+ EndTime int64 // 结束时间戳（毫秒），0 表示不限制
+ MinAmount *big.Int // 最小金额（micro USDT），nil 表示不限制
+ MinConfirmations int64 // 最小确认数，0 表示不限制
+ Limit int // 查询数量限制，0 使用默认值
+}
+
// USDTPayment USDT 收款信息
type USDTPayment struct {
Address string
@@ -351,6 +361,43 @@ func (m *USDTMan) getUSDTTransactions(address string) ([]TronGridTransaction, er
return result.Data, nil
}
+// getUSDTTransactionsWithLimit 获取指定数量的交易
+func (m *USDTMan) getUSDTTransactionsWithLimit(address string, limit int) ([]TronGridTransaction, error) {
+ url := fmt.Sprintf("%s/v1/accounts/%s/transactions/trc20?limit=%d&contract_address=%s&only_to=true",
+ TronGridAPI, address, limit, USDTContractAddress)
+
+ req, err := http.NewRequest("GET", url, nil)
+ if err != nil {
+ return nil, err
+ }
+
+ if m.apiKey != "" {
+ req.Header.Set("TRON-PRO-API-KEY", m.apiKey)
+ }
+
+ resp, err := m.httpClient.Do(req)
+ if err != nil {
+ return nil, err
+ }
+ defer resp.Body.Close()
+
+ body, err := io.ReadAll(resp.Body)
+ if err != nil {
+ return nil, err
+ }
+
+ if resp.StatusCode != 200 {
+ return nil, fmt.Errorf("TronGrid API error: %d %s", resp.StatusCode, string(body))
+ }
+
+ var result TronGridAccountTransactions
+ if err := json.Unmarshal(body, &result); err != nil {
+ return nil, err
+ }
+
+ return result.Data, nil
+}
+
// getTransactionBlock 获取交易的区块号
func (m *USDTMan) getTransactionBlock(txID string) (int64, error) {
url := fmt.Sprintf("%s/wallet/gettransactioninfobyid?value=%s", TronGridAPI, txID)
@@ -466,3 +513,85 @@ func (m *USDTMan) RemoveAddress(address string) {
}
}
}
+
+// QueryTransactions 主动查询交易记录（带过滤条件）
+func (m *USDTMan) QueryTransactions(filter QueryFilter) ([]*USDTPayment, error) {
+ if filter.Address == "" {
+ return nil, fmt.Errorf("address is required")
+ }
+
+ // 设置默认 limit
+ limit := filter.Limit
+ if limit == 0 {
+ limit = m.maxHistoryTxns
+ }
+
+ // 获取交易列表
+ transactions, err := m.getUSDTTransactionsWithLimit(filter.Address, limit)
+ if err != nil {
+ return nil, err
+ }
+
+ // 获取当前区块（用于计算确认数）
+ currentBlock, err := m.getCurrentBlock()
+ if err != nil {
+ return nil, err
+ }
+
+ var results []*USDTPayment
+
+ for _, txn := range transactions {
+ // 时间过滤
+ if filter.StartTime > 0 && txn.BlockTimestamp < filter.StartTime {
+ continue
+ }
+ if filter.EndTime > 0 && txn.BlockTimestamp > filter.EndTime {
+ continue
+ }
+
+ // 只处理转入该地址的交易
+ if !strings.EqualFold(txn.To, filter.Address) {
+ continue
+ }
+
+ // 解析金额
+ amount := new(big.Int)
+ amount, ok := amount.SetString(txn.Value, 10)
+ if !ok || amount.Sign() <= 0 {
+ continue
+ }
+
+ // 金额过滤
+ if filter.MinAmount != nil && amount.Cmp(filter.MinAmount) < 0 {
+ continue
+ }
+
+ // 获取区块号
+ blockNumber, err := m.getTransactionBlock(txn.TransactionID)
+ if err != nil {
+ continue
+ }
+
+ // 计算确认数
+ confirmations := currentBlock - blockNumber
+
+ // 确认数过滤
+ if filter.MinConfirmations > 0 && confirmations < filter.MinConfirmations {
+ continue
+ }
+
+ payment := &USDTPayment{
+ Address: filter.Address,
+ Amount: amount,
+ TxID: txn.TransactionID,
+ BlockNumber: blockNumber,
+ Timestamp: txn.BlockTimestamp,
+ From: txn.From,
+ Confirmations: confirmations,
+ }
+
+ results = append(results, payment)
+ }
+
+ return results, nil
+}
|