liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传竞技场匹配机制

Browse Source
This commit is contained in:
liwei1dao 2022-10-27 18:46:19 +08:00
parent 953bc69f10
commit c472ead14b
2 changed files with 52 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
modules/arena/modelarena.go
View File

@ -243,7 +243,11 @@ func (this *modelArena) matchePlayer(uid string, dan, num int32) (results []*pb.
cursor *mongo.Cursor cursor *mongo.Cursor
) )
results = make([]*pb.ArenaPlayer, 0) results = make([]*pb.ArenaPlayer, 0)
if cursor, err = this.DBModel.DB.Find(comm.TableArena, bson.M{"uid": bson.M{"$ne": uid}, "dan": dan, "loc": bson.M{"$near": []int32{dan * 1000, rand.Int31n(100)}, "$maxDistance": 100}}, options.Find().SetSkip(0).SetLimit(int64(num))); err != nil { if cursor, err = this.DBModel.DB.Find(comm.TableArena, bson.M{
"uid": bson.M{"$ne": uid},
"dan": dan,
"loc": bson.M{"$geoWithin": bson.M{"$center": bson.A{[]int32{dan * 1000, rand.Int31n(100)}, 100}}},
}, options.Find().SetSkip(0).SetLimit(int64(num))); err != nil {
this.module.Errorln(err) this.module.Errorln(err)
return return
} else { } else {

47
sys/db/init_test.go
View File

@ -1,11 +1,18 @@
package db package db
import ( import (
"context"
"fmt" "fmt"
"go_dreamfactory/comm"
"go_dreamfactory/lego/sys/mgo"
"go_dreamfactory/pb"
"math/rand"
"sync" "sync"
"testing" "testing"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo/options"
) )
func Test_Id(t *testing.T) { func Test_Id(t *testing.T) {
@ -22,3 +29,43 @@ func Test_Id(t *testing.T) {
} }
wg.Wait() wg.Wait()
} }
func Test_2D(t *testing.T) {
if sys, err := mgo.NewSys(
mgo.SetMongodbUrl("mongodb://10.0.0.9:10013"),
mgo.SetMongodbDatabase("dreamfactory4"),
); err != nil {
fmt.Printf("err:%v", err)
return
} else {
port := []int32{2 * 1000, rand.Int31n(100)}
fmt.Printf("port:%v \n", port)
if cursor, err := sys.Find(comm.TableArena, bson.M{
"dan": 2,
"loc": bson.M{
"$geoWithin": bson.M{
"$center": bson.A{port, 30},
},
},
// bson.A{[]int32{2 * 1000, rand.Int31n(100)}, 100}
// "loc": bson.M{
// "$near": bson.M{
// "$geometry": bson.M{"type": "Point", "coordinates": []int32{dan * 1000, rand.Int31n(100)}},
// "$maxDistance": 100,
// },
// },
}, options.Find().SetSkip(0).SetLimit(int64(5))); err != nil {
fmt.Printf("err:%v", err)
return
} else {
for cursor.Next(context.Background()) {
temp := &pb.DBArenaUser{}
if err = cursor.Decode(temp); err != nil {
fmt.Printf("err:%v", err)
return
}
fmt.Printf("temp:%v\n", temp.Uid)
}
}
}
}