Skip to content

Commit

Permalink
add parent signer
Browse files Browse the repository at this point in the history
  • Loading branch information
Musiczombie committed Dec 9, 2019
1 parent b23a119 commit 7f31284
Showing 1 changed file with 26 additions and 24 deletions.
50 changes: 26 additions & 24 deletions db/action.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,42 +12,44 @@ import (
)

type MysqlAction struct {
TxHash string
ActionHash string
ActionIndex int
Nonce uint64
Height uint64
Created uint64
GasAssetId uint64
TransferAssetId uint64
ActionType uint64
From string
To string
Amount *big.Int
GasLimit uint64
GasUsed uint64
State uint64
ErrorMsg string
Remark []byte
Payload []byte
PayloadSize int
InternalCount int
Payer string
PayerGasPrice *big.Int
TxHash string
ActionHash string
ActionIndex int
Nonce uint64
Height uint64
Created uint64
GasAssetId uint64
TransferAssetId uint64
ActionType uint64
From string
To string
Amount *big.Int
GasLimit uint64
GasUsed uint64
State uint64
ErrorMsg string
Remark []byte
Payload []byte
PayloadSize int
InternalCount int
Payer string
PayerGasPrice *big.Int
ParentSigner string
PayerParentSigner string
}

func InsertAction(data *MysqlAction, dbTx *sql.Tx) error {
tName := GetTableNameHash("actions_hash", data.TxHash)
insertSql := fmt.Sprintf("insert into %s (tx_hash, action_hash, action_index,nonce,height,created,gas_asset_id,transfer_asset_id,"+
"action_type,from_account,to_account,amount,gas_limit,gas_used,state,error_msg,remark,payload,payload_size,internal_action_count, payer, payer_gas_price) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", tName)
"action_type,from_account,to_account,amount,gas_limit,gas_used,state,error_msg,remark,payload,payload_size,internal_action_count, payer, payer_gas_price, parent_signer, payer_parent_signer) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", tName)
stmt, err := dbTx.Prepare(insertSql)
defer stmt.Close()
if err != nil {
ZapLog.Panic("InsertAction error", zap.Error(err), zap.String("txHash", data.TxHash), zap.String("sql", insertSql))
}
state := strconv.FormatUint(data.State, 10)
_, err = stmt.Exec(data.TxHash, data.ActionHash, data.ActionIndex, data.Nonce, data.Height, data.Created, data.GasAssetId, data.TransferAssetId,
data.ActionType, data.From, data.To, data.Amount.String(), data.GasLimit, data.GasUsed, state, data.ErrorMsg, data.Remark, data.Payload, data.PayloadSize, data.InternalCount, data.Payer, data.PayerGasPrice.String())
data.ActionType, data.From, data.To, data.Amount.String(), data.GasLimit, data.GasUsed, state, data.ErrorMsg, data.Remark, data.Payload, data.PayloadSize, data.InternalCount, data.Payer, data.PayerGasPrice.String(), data.ParentSigner, data.PayerParentSigner)
if err != nil {
ZapLog.Panic("InsertAction error", zap.Error(err), zap.String("txHash", data.TxHash))
}
Expand Down

0 comments on commit 7f31284

Please sign in to comment.