diff --git a/comm/const.go b/comm/const.go index 08f7e2c05..dcb3abff8 100644 --- a/comm/const.go +++ b/comm/const.go @@ -356,6 +356,8 @@ const ( //Rpc Rpc_ModuleBuriedTrigger core.Rpc_Key = "Rpc_ModuleBuriedTrigger" //埋点跨服触发通知 Rpc_OpendCond core.Rpc_Key = "Rpc_OpendCond" + + Rpc_ModuleWarorderSettlement core.Rpc_Key = "Rpc_ModuleWarorderSettlement" //战令结算 ) // 事件类型定义处 diff --git a/modules/sociaty/api_cross_activityreceive.go b/modules/sociaty/api_cross_activityreceive.go index c8f73b917..570b00973 100644 --- a/modules/sociaty/api_cross_activityreceive.go +++ b/modules/sociaty/api_cross_activityreceive.go @@ -53,8 +53,8 @@ func (this *apiComp) Activityreceive(session comm.IUserSession, req *pb.SociatyA conf, ok := this.module.sociatyActivityConf.GetDataMap()[req.Id] if !ok { errdata = &pb.ErrorData{ - Code: pb.ErrorCode_ConfigNoFound, - Title: pb.ErrorCode_ConfigNoFound.ToString(), + Code: pb.ErrorCode_ConfigNoFound, + Title: pb.ErrorCode_ConfigNoFound.ToString(), } return } @@ -68,7 +68,10 @@ func (this *apiComp) Activityreceive(session comm.IUserSession, req *pb.SociatyA } return } - + // 发放个人奖励 + if errdata = this.module.DispenseRes(session, conf.Reward, true); errdata != nil { + return + } // 活跃度领取 if err := this.module.modelSociatyTask.activityReceive(req.Id, sociaty.Id, uid); err != nil { this.module.Error("活跃度领取", log.Field{Key: "uid", Value: session.GetUserId()}, log.Field{Key: "params", Value: req.String()}) diff --git a/modules/sociaty/api_cross_receive.go b/modules/sociaty/api_cross_receive.go index fe9b0e48b..b9a92c224 100644 --- a/modules/sociaty/api_cross_receive.go +++ b/modules/sociaty/api_cross_receive.go @@ -1,6 +1,7 @@ package sociaty import ( + "fmt" "go_dreamfactory/comm" "go_dreamfactory/lego/sys/log" "go_dreamfactory/pb" @@ -53,7 +54,7 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.SociatyReceiveRe // 奖励领取 if err := this.module.modelSociatyTask.receive(req.TaskId, sociaty.Id, uid); err != nil { - + errdata = &pb.ErrorData{ Code: pb.ErrorCode_SociatyRewardReceived, Title: pb.ErrorCode_SociatyRewardReceived.ToString(), @@ -78,6 +79,13 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.SociatyReceiveRe log.Field{Key: "taskId", Value: req.TaskId}, ) } + } else { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ConfigNoFound, + Title: pb.ErrorCode_ConfigNoFound.ToString(), + Message: fmt.Sprintf("no found task conf:%d", req.TaskId), + } + return } // 更新公会经验和活跃度 diff --git a/modules/sociaty/model_sociatytask.go b/modules/sociaty/model_sociatytask.go index 815be10e9..431663f53 100644 --- a/modules/sociaty/model_sociatytask.go +++ b/modules/sociaty/model_sociatytask.go @@ -115,13 +115,14 @@ func (this *ModelSociatyTask) activityReceive(id int32, sociatyId, uid string) e break } } - if isUpdate { - update := map[string]interface{}{ - "activityList": sociatyTask.ActivityList, - } - return this.ChangeList(sociatyId, uid, update) + + if !isUpdate { + sociatyTask.ActivityList = append(sociatyTask.ActivityList, &pb.SociatyActivity{Id: id, Status: 1}) } - return nil + update := map[string]interface{}{ + "activityList": sociatyTask.ActivityList, + } + return this.ChangeList(sociatyId, uid, update) } // 更新任务列表