fix(mall): 修复Tokenview Webhook服务交易验证逻辑

Administrator

6 days ago 492ec5b26be12ccc18bfc2006b2c9ff16d2e4bef

fix(mall): 修复Tokenview Webhook服务交易验证逻辑

- 添加对多种地址字段的支持(address/toAddress/to)
- 新增时间戳和币种字段提取功能
- 添加交易币种匹配验证，仅处理USDT交易
- 修复合约地址验证时变量名错误问题
- 修改充值匹配逻辑使用tokenValue而非原始value
- 移除金额计算中的除法操作以避免精度损失

 src/main/java/cc/mrbird/febs/mall/controller/dependentStation/TokenviewWebhookService.java

@@ -68,15 +68,23 @@
        }

        // 从 payload 提取关键字段（兼容多种 key 命名）
        String toAddress = getField(payload, "address", "toAddress","to");
        String txid = getField(payload, "txid", "hash", "transactionHash");
        String toAddress = getField(payload, "to", "toAddress");
        String time = getField(payload, "time");
        String value = getField(payload, "value", "amount");
        String tokenAddr = getField(payload, "token", "tokenAddr", "contractAddress");
        String symbol = getField(payload, "symbol", "tokenSymbol");
        String coin = getField(payload, "coin");
        String tokenAddr = getField(payload, "token", "tokenAddr", "contractAddress","tokenAddress");
        String tokenSymbol = getField(payload, "tokenSymbol");
        String tokenValue = getField(payload, "tokenValue");

        if (StrUtil.isBlank(txid)) {
            log.warn("webhook 推送数据缺少交易哈希 txid: {}", payload);
            return "缺少 txid，跳过处理";
        }

        if (StrUtil.isNotBlank(tokenSymbol) && !"USDT".equalsIgnoreCase(tokenSymbol)) {
            log.info("交易币种不匹配，期望: {}, 实际: {}, txid: {}", "USDT", tokenSymbol, txid);
            return "收款地址不匹配，跳过处理";
        }

        // 验证收款地址是否匹配
@@ -87,12 +95,12 @@

        // 验证 token 合约地址（USDT: TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t）
        if (StrUtil.isNotBlank(tokenAddr) && !"TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t".equalsIgnoreCase(tokenAddr)) {
            log.info("非 USDT 代币交易，跳过处理: token={}, symbol={}, txid={}", tokenAddr, symbol, txid);
            log.info("非 USDT 代币交易，跳过处理: token={}, symbol={}, txid={}", tokenAddr, tokenSymbol, txid);
            return "非 USDT 交易，跳过处理";
        }

        // 执行充值匹配
        return matchAndUpdateOrder(txid, value, receiveAddress);
        return matchAndUpdateOrder(txid, tokenValue, receiveAddress);
    }

    /**
@@ -133,8 +141,9 @@
        }
        BigDecimal amount;
        try {
            amount = new BigDecimal(rawValue)
                    .divide(new BigDecimal("1000000"), 2, RoundingMode.DOWN);
//            amount = new BigDecimal(rawValue)
//                    .divide(new BigDecimal("1000000"), 2, RoundingMode.DOWN);
            amount = new BigDecimal(rawValue);
        } catch (NumberFormatException e) {
            log.error("金额解析失败: txid={}, value={}", txid, rawValue, e);
            return "金额解析失败: " + txid;