update

dao/db.go

@@ -54,10 +54,16 @@ func (d *Dao) CreateTask(task *dbModel.Task) (err error) {
 }
 
 func (d *Dao) UpdateTaskStatus(taskId, txHash string, status int) (err error) {
-	return d.db.Model(&dbModel.Task{}).Where("task_id = ?", taskId).Updates(map[string]interface{}{
-		"tx_hash":   txHash,
+	if taskId != "" {
+		return d.db.Model(&dbModel.Task{}).Where("task_id = ?", taskId).Updates(map[string]interface{}{
+			"tx_hash":   txHash,
+			"tx_status": status,
+		}).Error
+	}
+	return d.db.Model(&dbModel.Task{}).Where("tx_hash = ?", txHash).Updates(map[string]interface{}{
 		"tx_status": status,
 	}).Error
+
 }
 
 func (d *Dao) GetTxHashesByStatus(status int) (txHashes []string, err error) {

executor/executer.go

@@ -83,7 +83,7 @@ func (e *Executor) ProcessReceipt(sync bool) {
 
 			log.WithFields(log.Fields{"txHash": txHash, "status": status}).Info("get tx receipt")
 
-			err = e.d.UpdateTaskStatus(txHash, txHash, status)
+			err = e.d.UpdateTaskStatus("", txHash, status)
 			if err != nil {
 				log.WithFields(log.Fields{
 					"txHash": txHash,

model/db/db.go

@@ -22,7 +22,7 @@ type Task struct {
 	ToAddress string `gorm:"type:varchar(255);not null;comment:目标地址"`
 	Value     string `gorm:"type:varchar(255);not null;comment:金额"`
 	Calldata  string `gorm:"type:varchar(2048);not null;comment:参数"`
-	TxHash    string `gorm:"type:varchar(255);not null;comment:交易hash"`
+	TxHash    string `gorm:"type:varchar(255);index;not null;comment:交易hash"`
 	TxStatus  int    `gorm:"type:int;not null;comment:交易状态"`
 	gorm.Model
 }