Merge branch 'meixiongfeng' of http://git.legu.cc/liwei_3d/go_dreamfactory into dev

modules/gm/module.go

@@ -65,6 +65,7 @@ func (this *GM) CreateCmd(session comm.IUserSession, cmd string) (code pb.ErrorC
 	keys := strings.Split(cmd, ":")
 	if len(keys) == 2 {
 		if keys[0] == "bingo" {
+			this.Debugf("create CMD	:%s", cmd) // 打印个日志方便查询
 			datas := strings.Split(keys[1], ",")
 			if len(datas) == 3 && (datas[0] == comm.AttrType || datas[0] == comm.ItemType ||
 				datas[0] == comm.HeroType || datas[0] == comm.EquipmentType) {

modules/hero/api_fusion.go

@@ -50,7 +50,7 @@ func (this *apiComp) Fusion(session comm.IUserSession, req *pb.HeroFusionReq) (c
 		_costMaphero[k] = _obj
 	}
 	for _, v := range conf.Pointhero {
-		if _, ok := mapHero[v]; !ok {
+		if _, ok := mapHero[v]; ok {
 			mapHero[v] -= 1
 		} else {
 			code = pb.ErrorCode_ReqParameterError

modules/hero/module.go

@@ -344,19 +344,33 @@ func (this *Hero) CreateMonster(heroCid string, star, lv int32) (hero *pb.DBHero
 
 // 只通过唯一id 查询英雄信息
 func (this *Hero) QueryCrossHeroinfo(oid string) (hero *pb.DBHero, err error) {
-	for _, tag := range db.GetServerTags() {
+
-		conn, err1 := db.ServerDBConn(tag) // 遍历连接对象
+	if this.modelHero.moduleHero.IsCross() {
-		if err1 != nil {
+		for _, tag := range db.GetServerTags() {
-			continue
+			conn, err1 := db.ServerDBConn(tag) // 遍历连接对象
+			if err1 != nil {
+				continue
+			}
+
+			sr := conn.Mgo.FindOne(comm.TableHero, bson.M{
+				"_id": oid,
+			})
+			hero = &pb.DBHero{}
+			if err = sr.Decode(hero); err != nil {
+				if err != mongo.ErrNoDocuments {
+					return
+				}
+			}
 		}
-		filter := bson.M{
+	} else { // 不是跨服就查本服
+		if res := this.modelHero.DB.FindOne(comm.TableHero, bson.M{
 			"_id": oid,
-		}
+		}); res == nil {
-		sr := conn.Mgo.FindOne(comm.TableHero, filter)
+			hero = &pb.DBHero{}
-		hero = &pb.DBHero{}
+			if err = res.Decode(hero); err != nil {
-		if err = sr.Decode(hero); err != nil {
+				if err != mongo.ErrNoDocuments {
-			if err != mongo.ErrNoDocuments {
+					return
-				return
+				}
 			}
 		}
 	}

modules/timer/season.go

@@ -0,0 +1,34 @@
+package timer
+
+import (
+	"go_dreamfactory/comm"
+	"go_dreamfactory/modules"
+
+	"go_dreamfactory/lego/core"
+	"go_dreamfactory/lego/sys/cron"
+)
+
+type SeasonPagoda struct {
+	modules.MCompModel
+	service core.IService
+	dbName  string
+}
+
+//组件初始化接口
+func (this *SeasonPagoda) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) {
+	this.TableName = comm.TableSeasonPagoda
+	this.MCompModel.Init(service, module, comp, options)
+	this.service = service
+	return
+}
+
+func (this *SeasonPagoda) Start() (err error) {
+	err = this.MCompModel.Start()
+	cron.AddFunc("0 0 23 L * ?", this.Timer) //每月最后一天23点执行一次
+	return
+}
+
+// 处理排行榜排序
+func (this *SeasonPagoda) Timer() {
+
+}