108 lines
2.9 KiB
Go
108 lines
2.9 KiB
Go
package sociaty
|
|
|
|
import (
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/lego/sys/log"
|
|
"go_dreamfactory/pb"
|
|
"go_dreamfactory/sys/configure"
|
|
"go_dreamfactory/utils"
|
|
)
|
|
|
|
// 我的公会
|
|
|
|
func (this *apiComp) MineCheck(session comm.IUserSession, req *pb.SociatyMineReq) (errdata *pb.ErrorData) {
|
|
return
|
|
}
|
|
|
|
func (this *apiComp) Mine(session comm.IUserSession, req *pb.SociatyMineReq) (errdata *pb.ErrorData) {
|
|
|
|
uid := session.GetUserId()
|
|
userEx, err := this.module.ModuleUser.GetUserExpand(uid)
|
|
if err != nil {
|
|
this.module.Error("GetRemoteUserExpand",
|
|
log.Field{Key: "uid", Value: uid},
|
|
log.Field{Key: "err", Value: err.Error()},
|
|
)
|
|
return
|
|
}
|
|
|
|
rsp := &pb.SociatyMineResp{}
|
|
|
|
// 未加入公会
|
|
if userEx.SociatyId == "" {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_SociatyNoAdded,
|
|
Title: pb.ErrorCode_SociatyNoAdded.ToString(),
|
|
}
|
|
return
|
|
}
|
|
|
|
// 获取公会
|
|
sociaty := this.module.modelSociaty.getUserSociaty(uid)
|
|
if sociaty == nil {
|
|
this.module.Error("当前玩家所在的公会未找到", log.Field{Key: "uid", Value: uid})
|
|
return
|
|
}
|
|
|
|
//判断公会是否解散（公会解散非立即执行）
|
|
if this.module.modelSociaty.isDismiss(sociaty) {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_SociatyDismissed,
|
|
Title: pb.ErrorCode_SociatyDismissed.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
|
|
// 初始玩家公会任务
|
|
sociatyTask, _ := this.module.modelSociatyTask.getUserTask(uid, sociaty.Id)
|
|
if sociatyTask.SociatyId != "" {
|
|
// 今日首次进入公会
|
|
if utils.IsFirstTody(sociatyTask.LastUpdateTime) {
|
|
//更新昨日签到数
|
|
this.module.modelSociaty.clearSigned(sociaty)
|
|
// 删除任务
|
|
if err := this.module.modelSociatyTask.deleTask(sociaty.Id, uid); err == nil {
|
|
// 初始新的公会任务
|
|
if err = this.module.modelSociatyTask.initSociatyTask(uid, sociaty.Id); err != nil {
|
|
this.module.Error("初始化玩家公会任务",
|
|
log.Field{Key: "uid", Value: uid},
|
|
log.Field{Key: "sociatyId", Value: sociaty.Id},
|
|
log.Field{Key: "err", Value: err.Error()},
|
|
)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if sociaty.AccuseTime > 0 {
|
|
// 获取会长
|
|
master := this.module.modelSociaty.getMasterInfo(sociaty)
|
|
if master != nil {
|
|
if master.Uid == session.GetUserId() { //自己是会长
|
|
sociaty.AccuseTime = 0
|
|
update := map[string]interface{}{
|
|
"accuseTime": 0,
|
|
}
|
|
this.module.modelSociaty.updateSociaty(sociaty.Id, update)
|
|
} else {
|
|
now := configure.Now().Unix()
|
|
if now > sociaty.AccuseTime { // 重新选择会长
|
|
if err := this.module.modelSociaty.extendJob(master.Uid, sociaty); err != nil {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_DBError,
|
|
Title: pb.ErrorCode_DBError.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
rsp.Master = master
|
|
}
|
|
}
|
|
}
|
|
}
|
|
rsp.Sociaty = sociaty
|
|
session.SendMsg(string(this.module.GetType()), SociatySubTypeMine, rsp)
|
|
return
|
|
}
|