no message
This commit is contained in:
parent
1979637197
commit
404017c33e
|
@ -777,6 +777,7 @@ func NewPlayerData(acc string, name string, id int32, channel, platform string,
|
|||
UnMaxPower: 10, //初始化炮倍最小倍数
|
||||
WeekCardTime: make(map[int32]int64),
|
||||
WeekCardAward: make(map[int32]bool),
|
||||
WelfData: NewWelfareData(),
|
||||
}
|
||||
|
||||
if tel != "" {
|
||||
|
|
|
@ -15,9 +15,10 @@ import (
|
|||
"time"
|
||||
|
||||
"google.golang.org/protobuf/proto"
|
||||
"mongo.games.com/goserver/core/logger"
|
||||
)
|
||||
|
||||
const DEFAULT_TIMEOUT = time.Duration(time.Second * 30)
|
||||
const DEFAULT_TIMEOUT = time.Second * 30
|
||||
|
||||
var WebApiStats = new(sync.Map)
|
||||
|
||||
|
@ -81,7 +82,7 @@ func getRequest(appId, action string, params map[string]string, body proto.Messa
|
|||
}
|
||||
|
||||
callUrl := MakeURL(appId, action, params, data)
|
||||
//println("callurl=", callUrl)
|
||||
logger.Logger.Tracef("getRequest url: %v params: %v request body: %v", callUrl, params, body)
|
||||
req, err := http.NewRequest("GET", callUrl, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
@ -129,7 +130,7 @@ func getRequest(appId, action string, params map[string]string, body proto.Messa
|
|||
}
|
||||
return body, err
|
||||
}
|
||||
println("callurl=", callUrl, "code=", resp.StatusCode)
|
||||
logger.Logger.Errorf("getRequest url:%v params:%v request body:%v code:%v", callUrl, params, body, resp.StatusCode)
|
||||
return nil, fmt.Errorf("StatusCode:%d", resp.StatusCode)
|
||||
}
|
||||
|
||||
|
@ -152,7 +153,7 @@ func postRequest(appId, action string, params map[string]string, body proto.Mess
|
|||
}
|
||||
|
||||
callUrl := MakeURL(appId, action, params, data)
|
||||
//println("callurl=", callUrl)
|
||||
logger.Logger.Tracef("postRequest url: %v request body: %v", callUrl, body)
|
||||
req, err := http.NewRequest("POST", callUrl, bytes.NewBuffer(data))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
@ -200,7 +201,7 @@ func postRequest(appId, action string, params map[string]string, body proto.Mess
|
|||
}
|
||||
return body, err
|
||||
}
|
||||
println("callurl=", callUrl, "code=", resp.StatusCode)
|
||||
logger.Logger.Errorf("postRequest url:%v request body: %v code: %v", callUrl, body, resp.StatusCode)
|
||||
return nil, fmt.Errorf("StatusCode:%d", resp.StatusCode)
|
||||
}
|
||||
|
||||
|
|
|
@ -357,7 +357,7 @@ func CSBindInvite(s *netlib.Session, packetid int, data interface{}, sid int64)
|
|||
return nil
|
||||
}), task.CompleteNotifyWrapper(func(i interface{}, t task.Task) {
|
||||
if err != nil || inviteSnId == 0 {
|
||||
logger.Logger.Errorf("GetSnIdByCode err %v %v", err, inviteSnId)
|
||||
logger.Logger.Tracef("GetSnIdByCode not found %v %v", err, msg.GetCode())
|
||||
ret.OpRetCode = welfare.OpResultCode_OPRC_NotExist
|
||||
send()
|
||||
return
|
||||
|
|
|
@ -2,9 +2,8 @@ package main
|
|||
|
||||
import (
|
||||
"encoding/gob"
|
||||
"mongo.games.com/game/common"
|
||||
"mongo.games.com/game/model"
|
||||
"mongo.games.com/game/webapi"
|
||||
"time"
|
||||
|
||||
"mongo.games.com/goserver/core"
|
||||
"mongo.games.com/goserver/core/basic"
|
||||
"mongo.games.com/goserver/core/module"
|
||||
|
@ -14,7 +13,10 @@ import (
|
|||
"mongo.games.com/goserver/core/task"
|
||||
"mongo.games.com/goserver/core/transact"
|
||||
"mongo.games.com/goserver/core/utils"
|
||||
"time"
|
||||
|
||||
"mongo.games.com/game/common"
|
||||
"mongo.games.com/game/model"
|
||||
"mongo.games.com/game/webapi"
|
||||
)
|
||||
|
||||
var MonitorMgrSington = &MonitorMgr{}
|
||||
|
@ -164,5 +166,4 @@ func init() {
|
|||
//gob registe
|
||||
|
||||
module.RegisteModule(MonitorMgrSington, time.Minute*5, 0)
|
||||
|
||||
}
|
||||
|
|
|
@ -1,8 +1,11 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"mongo.games.com/goserver/core/module"
|
||||
"time"
|
||||
|
||||
"mongo.games.com/goserver/core/module"
|
||||
|
||||
"mongo.games.com/game/model"
|
||||
)
|
||||
|
||||
var PlayerOnlineSington = &PlayerOnlineEvent{
|
||||
|
@ -55,7 +58,7 @@ func (p *PlayerOnlineEvent) Update() {
|
|||
|
||||
here:
|
||||
p.OnlineCh = onlineCh
|
||||
//LogChannelSingleton.WriteMQData(model.GenerateOnline(p.OnlineCh))
|
||||
LogChannelSingleton.WriteMQData(model.GenerateOnline(p.OnlineCh))
|
||||
}
|
||||
|
||||
func (p *PlayerOnlineEvent) Shutdown() {
|
||||
|
|
Loading…
Reference in New Issue