diff --git a/engine/storage_sql.go b/engine/storage_sql.go index f2928c54d..3f22c7bda 100644 --- a/engine/storage_sql.go +++ b/engine/storage_sql.go @@ -409,14 +409,14 @@ func (self *SQLStorage) SetTPDerivedChargers(sgs []*utils.TPDerivedChargers) err dcKey := dCharger.GetDerivedChargersKey() if found, _ := m[dcKey]; !found { m[dcKey] = true - if err := tx.Delete(TpDerivedCharger{ + if err := tx.Where(TpDerivedCharger{ Tpid: dCharger.TPid, Direction: dCharger.Direction, Tenant: dCharger.Tenant, Category: dCharger.Category, Account: dCharger.Account, Subject: dCharger.Subject, - }).Error; err != nil { + }).Delete(TpDerivedCharger{}).Error; err != nil { tx.Rollback() return err }