This commit is contained in:
meixiongfeng 2022-06-28 15:24:40 +08:00
parent 9d47098166
commit fedb567675

View File

@ -138,17 +138,15 @@ func (this *DB_Comp) Model_UpdateDBByLog(uid string) (err error) {
}
_tableName := data.D[0].(string) //表名
Where := data.D[1].(bson.M)
Query := data.D[2].(bson.M)
Where := bson.M{} //data.D[1].(bson.M)
Query := bson.M{} //data.D[2].(bson.M)
// for key, v := range data.D[1].(bson.M) {
// //Where[v.Key] = v.Value
// Where = v
// }
// for _, v := range data.D[2].(bson.M) {
// Query[v.Key] = v.Value
// }
for _, v := range data.D[1].(bson.D) {
Where[v.Key] = v.Value
}
for _, v := range data.D[2].(bson.D) {
Query[v.Key] = v.Value
}
_, err = this.DB.UpdateMany(core.SqlTable(_tableName), Where, bson.M{"$set": Query})
if err != nil {
log.Errorf("Update %s db err:%v", core.SqlTable(_tableName), err)