diff --git a/server/backtask/task/webhook.go b/server/backtask/task/webhook.go index 22f91848..03043fce 100644 --- a/server/backtask/task/webhook.go +++ b/server/backtask/task/webhook.go @@ -120,6 +120,7 @@ func (this* webHook) orderUpdatedCb(ds *f5.DataSet) bool { ds.GetByName("event_id"), err) return false } + var resultErr error var itemId int32 var heroQuality int32 this.getItemIdHeroQuality(netId, p.Data.Sell[0].ContractAddress, p.Data.Sell[0].TokenId, @@ -160,6 +161,7 @@ func (this* webHook) orderUpdatedCb(ds *f5.DataSet) bool { updateFields, insertFields, func (err error, lastInsertId int64, rowsAffected int64) { + resultErr = err if err != nil { return } @@ -167,7 +169,7 @@ func (this* webHook) orderUpdatedCb(ds *f5.DataSet) bool { func (ds *f5.DataSet) bool { return p.EventId > ds.GetByName("event_id") }) - return true + return resultErr == nil } func (this* webHook) activitySaleCb(ds *f5.DataSet) bool { @@ -182,6 +184,7 @@ func (this* webHook) activitySaleCb(ds *f5.DataSet) bool { ds.GetByName("event_id"), err) return false } + var resultErr error var itemId int32 var heroQuality int32 this.getItemIdHeroQuality(netId, @@ -216,6 +219,7 @@ func (this* webHook) activitySaleCb(ds *f5.DataSet) bool { updateFields, insertFields, func (err error, lastInsertId int64, rowsAffected int64) { + resultErr = err if err != nil { return } @@ -223,7 +227,7 @@ func (this* webHook) activitySaleCb(ds *f5.DataSet) bool { func (ds *f5.DataSet) bool { return p.EventId > ds.GetByName("event_id") }) - return true + return resultErr == nil } func (this* webHook) getItemIdHeroQuality(netId int32, contractAddress string, tokenId string,