add
This commit is contained in:
@@ -134,14 +134,14 @@ func CreateHandler(c *gin.Context) {
|
|||||||
// 插入交易记录
|
// 插入交易记录
|
||||||
var recordID string
|
var recordID string
|
||||||
err = tx.QueryRow(
|
err = tx.QueryRow(
|
||||||
`INSERT INTO trading_records (event_type, payload)
|
`INSERT INTO cn_futures_trading_records (event_type, payload)
|
||||||
VALUES ('交易中', $1)
|
VALUES ('交易中', $1)
|
||||||
RETURNING id`,
|
RETURNING id`,
|
||||||
payloadBytes, // 只剩一个占位符
|
payloadBytes, // 只剩一个占位符
|
||||||
).Scan(&recordID)
|
).Scan(&recordID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
tx.Rollback()
|
tx.Rollback()
|
||||||
zap.L().Error("❌ trading_records 插入失败",
|
zap.L().Error("❌ cn_futures_trading_records 插入失败",
|
||||||
zap.String("req_id", reqID),
|
zap.String("req_id", reqID),
|
||||||
zap.Error(err),
|
zap.Error(err),
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user