service

type Block struct {
	Id              int64    `json:"id" gorm:"column:id"`
	BlockHash       string   `json:"hash" gorm:"column:hash"`
	BlockTime       string   `json:"timestamp" gorm:"column:block_time"`
	BlockStatus     string   `json:"blockStatus" gorm:"column:block_status"`
	BlockNumber     string   `json:"number" gorm:"column:block_number"`
	ParentHash      string   `json:"parentHash" gorm:"column:parent_hash"`
	BlockReward     string   `json:"blockReward" gorm:"column:block_reward"`
	FeeRecipient    string   `json:"feeRecipient" gorm:"column:fee_recipient"`
	TotalDifficulty string   `json:"totalDifficulty" gorm:"column:total_difficulty"`
	BlockSize       string   `json:"size" gorm:"column:block_size"`
	GasLimit        string   `json:"gasLimit" gorm:"column:gas_limit"`
	GasUsed         string   `json:"gasUsed" gorm:"column:gas_used"`
	BaseFee         string   `json:"baseFeePerGas" gorm:"column:base_fee_per_gas"`
	ExtraData       string   `json:"extraData" gorm:"column:extra_data"`
	Root            string   `json:"stateRoot" gorm:"column:state_root"`
	Transactions    []string `json:"transactions" gorm:"column:transactions"`
	TxRoot          string   `json:"transactionsRoot" gorm:"column:transactions_root"`
	ReceiptRoot     string   `json:"receiptsRoot" gorm:"column:receipts_root"`
	Coinbase        string   `json:"miner" gorm:"column:miner"`
	Nonce           string   `json:"nonce" gorm:"column:nonce"`
}

type BlockChainInterface interface {
	GetTx(txHash string, task *config.TxTask, log *logrus.Entry) *Tx
	GetReceipt(txHash string, task *config.ReceiptTask, log *logrus.Entry) *Receipt
	GetReceiptByBlock(blockHash, number string, task *config.ReceiptTask, log *logrus.Entry) []*Receipt
	GetBlockByNumber(blockNumber string, task *config.BlockTask, log *logrus.Entry) (*Block, []*Tx)

	GetBlockByHash(blockHash string, cfg *config.BlockTask, log *logrus.Entry) (*Block, []*Tx)

	BalanceCluster(key string, clusterList []*config.FromCluster) (*config.FromCluster, error)
	Monitor()
}

type Common interface {
	Start()
	Stop()
}

type KafkaInterface interface {
	//ProductMessage 生产消息到指定kafka.topic
	ProductMessage(msg *kafka.Message)
}

type Logs []struct {
	BlockHash        string   `json:"blockHash" gorm:"column:block_hash"`
	Address          string   `json:"address" gorm:"column:address"`
	LogIndex         string   `json:"logIndex" gorm:"column:log_index"`
	Data             string   `json:"data" gorm:"column:data"`
	Removed          bool     `json:"removed" gorm:"column:removed"`
	Topics           []string `json:"topics" gorm:"column:topics"`
	BlockNumber      string   `json:"blockNumber" gorm:"column:block_number"`
	TransactionIndex string   `json:"transactionIndex" gorm:"column:transaction_index"`
	TransactionHash  string   `json:"transactionHash" gorm:"column:transaction_hash"`
}

type NodeInfo struct {
	Ip         string    `json:"ip"`
	Host       string    `json:"host"`
	Info       string    `json:"info"`   //json 对象
	NodeId     string    `json:"nodeId"` //node 唯一标识
	CreateTime time.Time `json:"createTime" gorm:"column:create_time"`
}

type NodeInterface interface {
	//PushNodeInfo  定时的上传node info (20s)
	PushNodeInfo(node *NodeInfo)
}

type NodeSource struct {
	Id          int64     `json:"id" gorm:"column:id"`
	BlockChain  int       `json:"blockChain" gorm:"column:block_chain"` // 公链code
	TxHash      string    `json:"txHash" gorm:"column:tx_hash"`
	BlockHash   string    `json:"blockHash" gorm:"column:block_hash"`
	BlockNumber string    `json:"blockNumber" gorm:"column:block_number"`
	SourceType  int       `json:"sourceType" gorm:"column:source_type"` // 任务类型 1: 交易 2:区块 3.收据
	CreateTime  time.Time `json:"createTime" gorm:"column:create_time"`
}

type NodeTask struct {
	Id          int64  `json:"id"  gorm:"column:id"`
	NodeId      string `json:"nodeId" gorm:"column:node_id"`
	BlockNumber string `json:"blockNumber" gorm:"column:block_number"`
	BlockHash   string `json:"blockHash" gorm:"column:block_hash"`
	TxHash      string `json:"txHash" gorm:"column:tx_hash"`
	TaskType    int8   `json:"taskType" gorm:"column:task_type"` // 0:保留 1:同步Tx. 2:同步Block 3:同步Receipt
	BlockChain  int    `json:"blockChain" gorm:"column:block_chain"`
	TaskStatus  int    `json:"taskStatus" gorm:"column:task_status"` //0: 初始 1: 成功. 2: 失败.  3: 执行中 其他：重试次数
}

type Receipt struct {
	Id                int64  `json:"id"`
	BlockHash         string `json:"blockHash" gorm:"column:block_hash"`
	LogsBloom         string `json:"logsBloom" gorm:"column:logs_bloom"`
	ContractAddress   string `json:"contractAddress" gorm:"column:contract_address"`
	TransactionIndex  string `json:"transactionIndex" gorm:"column:transaction_index"`
	Type              string `json:"type" gorm:"column:tx_type"`
	TransactionHash   string `json:"transactionHash" gorm:"column:transaction_hash"`
	GasUsed           string `json:"gasUsed" gorm:"column:gas_used"`
	BlockNumber       string `json:"blockNumber" gorm:"column:block_number"`
	CumulativeGasUsed string `json:"cumulativeGasUsed" gorm:"column:cumulative_gas_used"`
	From              string `json:"from" gorm:"column:from_addr"`
	To                string `json:"to" gorm:"column:to_addr"`
	EffectiveGasPrice string `json:"effectiveGasPrice" gorm:"column:effective_gas_price"`
	Logs              *Logs  `json:"logs" gorm:"column:logs"`
	CreateTime        string `json:"createTime" gorm:"column:create_time"` // 2006-01-02
	Status            string `json:"status" gorm:"column:status"`
}

type TaskInterface interface {
	GetTaskWithTx(blockChain int, nodeId string) ([]*NodeTask, error)
	GetTaskWithReceipt(blockChain int, nodeId string) ([]*NodeTask, error)
	GetTaskWithBlock(blockChain int, nodeId string) ([]*NodeTask, error)
	UpdateTaskStatus(id int64, status int) error
	AddTaskSource(source *NodeSource) error
	AddNodeTask(list []*NodeTask) error
	UpdateNodeTaskStatusWithTx(task *NodeTask) error
	UpdateNodeTaskListStatusWithTx(txHashList []string, taskType int, blockChain int, taskStatus int) error
}

type Tx struct {
	Id          int64  `json:"id" gorm:"column:id"`
	TxHash      string `json:"hash" gorm:"column:hash"`
	TxTime      string `json:"txTime" gorm:"column:tx_time"`
	TxStatus    string `json:"txStatus" gorm:"column:tx_status"`
	BlockNumber string `json:"blockNumber" gorm:"column:block_number"`
	FromAddr    string `json:"from" gorm:"column:from_addr"`
	ToAddr      string `json:"to" gorm:"column:to_addr"`
	Value       string `json:"value" gorm:"column:value"`
	Fee         string `json:"fee" gorm:"column:fee"`
	GasPrice    string `json:"gasPrice" gorm:"column:gas_price"`
	MaxPrice    string `json:"maxFeePerGas" gorm:"column:max_fee_per_gas"`
	GasLimit    string `json:"gas" gorm:"column:gas"`
	GasUsed     string `json:"gasUsed" gorm:"column:gas_used"`
	BaseFee     string `json:"baseFeePerGas" gorm:"column:base_fee_per_gas"`
	PriorityFee string `json:"maxPriorityFeePerGas" gorm:"column:max_priority_fee_per_gas"`
	InputData   string `json:"input" gorm:"column:input_data"`
	BlockHash   string `json:"blockHash" gorm:"column:block_hash"`

	TransactionIndex string `json:"transactionIndex" gorm:"column:transaction_index"`
	Type             string `json:"type" gorm:"column:tx_type"`
}