This commit is contained in:
meixiongfeng 2022-06-17 15:52:07 +08:00
parent def537a01a
commit b007be914d

View File

@ -155,12 +155,12 @@ func (this *DB_Comp) Model_UpdateDBByLog(uid string) (err error) {
_delID = append(_delID, data.ID) // 都操作都成功了记录要删除的key
}
// if len(_delID) > 0 {
// _, err = this.DB.DeleteMany(DB_ModelTable, bson.M{"_id": bson.M{"$in": _delID}}, options.Delete()) // 批量删除已处理的数据
// if err != nil {
// log.Errorf("del err %v", err)
// }
// }
if len(_delID) > 0 {
_, err = this.DB.DeleteMany(DB_ModelTable, bson.M{"_id": bson.M{"$in": _delID}}, options.Delete()) // 批量删除已处理的数据
if err != nil {
log.Errorf("del err %v", err)
}
}
return
}