diff --git a/server/light_backtask/task/vester.go b/server/light_backtask/task/vester.go
index 29de3b0d..3d228a5e 100644
--- a/server/light_backtask/task/vester.go
+++ b/server/light_backtask/task/vester.go
@@ -112,7 +112,7 @@ func (this* vester) saveToDb(ds *f5.DataSet) bool {
 		p := new(jccommon.VesterDepositPo)
 		if q5.DecodeJson(returnValues, p) == nil {
 			decodeJsonOk = true
-			f5.GetGoStyleDb().NewUpsert(
+			err, _, _ := f5.GetGoStyleDb().NewUpsert(
 				constant.BCEVENT_DB,
 				"t_vester_deposit_withdraw",
 				whereKv,
@@ -121,12 +121,15 @@ func (this* vester) saveToDb(ds *f5.DataSet) bool {
 					{"account_address", p.Account},
 					{"deposit_amount", p.Amount},
 				}))
+			if err != nil {
+				return false
+			}
 		}
 	} else if eventName == VESTER_WITHDRAW_EVENT_NAME {
 		p := new(jccommon.VesterWithdrawPo)
 		if q5.DecodeJson(returnValues, p) == nil {
 			decodeJsonOk = true
-			f5.GetGoStyleDb().NewUpsert(
+			err, _, _ := f5.GetGoStyleDb().NewUpsert(
 				constant.BCEVENT_DB,
 				"t_vester_deposit_withdraw",
 				whereKv,
@@ -136,6 +139,9 @@ func (this* vester) saveToDb(ds *f5.DataSet) bool {
 					{"withdraw_clamied_amount", p.ClaimedAmount},
 					{"withdraw_balance", p.Balance},
 				}))
+			if err != nil {
+				return false
+			}
 		}
 	} else {
 		panic(fmt.Sprintf("vester unknow event_name %s", eventName))