Commit 3e2a6206 authored by chenweijian's avatar chenweijian

开斋节活动

parent fbd791a1
...@@ -554,7 +554,7 @@ func OnMic() { ...@@ -554,7 +554,7 @@ func OnMic() {
model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", event.UserId) model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", event.UserId)
} }
// 处理活动数据 // 处理活动数据
go rpc.AddActPoint(model, event.UserId, 1) go rpc.AddActPoint(model, event.UserId, 1, 0)
return nil return nil
}) })
} }
...@@ -118,7 +118,7 @@ func (s *GroupService) LeaveGroupMember(model *domain.Model, groupId string, use ...@@ -118,7 +118,7 @@ func (s *GroupService) LeaveGroupMember(model *domain.Model, groupId string, use
} }
//进入房间, 返回channelId, err //进入房间, 返回channelId, err
func (s *GroupService) GroupIn(userId uint64, externalId string, groupUuid string, password, imei, ip string, provider group_e.GroupProvider) (string, string, error) { func (s *GroupService) GroupIn(userId uint64, externalId string, groupUuid string, password, imei, ip string, provider group_e.GroupProvider, roomId int64) (string, string, error) {
var channelId string var channelId string
var token string var token string
var rideId uint64 var rideId uint64
...@@ -279,7 +279,7 @@ func (s *GroupService) GroupIn(userId uint64, externalId string, groupUuid strin ...@@ -279,7 +279,7 @@ func (s *GroupService) GroupIn(userId uint64, externalId string, groupUuid strin
if err != nil { if err != nil {
return "", "", err return "", "", err
} else { } else {
go dealActDataAfterEnterRoom(s.svc.MyContext, userId, rideId) go dealActDataAfterEnterRoom(s.svc.MyContext, userId, rideId, roomId)
return channelId, token, nil return channelId, token, nil
} }
} }
...@@ -458,10 +458,10 @@ func (s *GroupService) GroupClearScreenByMgr(groupId string, userId uint64) erro ...@@ -458,10 +458,10 @@ func (s *GroupService) GroupClearScreenByMgr(groupId string, userId uint64) erro
return nil return nil
} }
func dealActDataAfterEnterRoom(myContext *mycontext.MyContext, userId, rideId uint64) { func dealActDataAfterEnterRoom(myContext *mycontext.MyContext, userId, rideId uint64, roomId int64) {
defer utils.CheckGoPanic() defer utils.CheckGoPanic()
if rideId == 1241 { if rideId == 1241 {
// 处理活动数据 // 处理活动数据
go rpc.AddActPoint(domain.CreateModelContext(myContext), userId, 5) go rpc.AddActPoint(domain.CreateModelContext(myContext), userId, 5, roomId)
} }
} }
...@@ -1777,7 +1777,7 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) { ...@@ -1777,7 +1777,7 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) {
} }
} }
if channelId, token, err := group_s.NewGroupService(myContext).GroupIn(userId, externalId, groupId, password, imei, ip, provider); err != nil { if channelId, token, err := group_s.NewGroupService(myContext).GroupIn(userId, externalId, groupId, password, imei, ip, provider, gi.Id); err != nil {
return myContext, err return myContext, err
} else { } else {
// 加入房间缓存 // 加入房间缓存
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment