diff --git a/modules/caravan/module.go b/modules/caravan/module.go index 1e5904a05..66b5bed16 100644 --- a/modules/caravan/module.go +++ b/modules/caravan/module.go @@ -416,7 +416,7 @@ func (this *Caravan) Rpc_ModuleCaravanSettlement(ctx context.Context, args *pb.E } Query := bson.M{} Query["merchantmoney"] = 0 - _, err := this.modelCaravan.DB.UpdateMany(core.SqlTable(comm.TableUser), bson.M{}, bson.M{"$set": Query}, options.MergeUpdateOptions().SetUpsert(true)) //, new(options.UpdateOptions).SetUpsert(true) + _, err := this.modelCaravan.DB.UpdateMany(core.SqlTable(comm.TableUser), bson.M{"merchantmoney": bson.M{"$gt": 0}}, bson.M{"$set": Query}, options.MergeUpdateOptions().SetUpsert(true)) //, new(options.UpdateOptions).SetUpsert(true) if err != nil { this.Errorf("UpdateMany error: %v", err) }