go_dreamfactory/modules/user/api_create.go

package user

import (
	"go_dreamfactory/comm"
	"go_dreamfactory/lego/core"
	"go_dreamfactory/lego/sys/log"
	"go_dreamfactory/pb"
	cfg "go_dreamfactory/sys/configure/structs"
)

func (this *apiComp) CreateCheck(session comm.IUserSession, req *pb.UserCreateReq) (errdata *pb.ErrorData) {
	if req.Gender == 0 || req.Skin == "" {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_UserNickNameEmpty,
			Title: pb.ErrorCode_UserNickNameEmpty.ToString(),
		}
	}
	return
}

// 创角
func (this *apiComp) Create(session comm.IUserSession, req *pb.UserCreateReq) (errdata *pb.ErrorData) {
	var (
		user  *pb.DBUser
		res   []*cfg.Gameatn
		award []*pb.UserAtno
		tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
		err   error
	)

	if errdata = this.CreateCheck(session, req); errdata != nil {
		return
	}

	//获取用户
	user, err = this.module.modelUser.GetUser(session.GetUserId())
	if err != nil {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_UserNofound,
			Title:   pb.ErrorCode_UserNofound.ToString(),
			Message: err.Error(),
		}
		return
	}

	//已否已创角
	if user.Created {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_RoleCreated,
			Title: pb.ErrorCode_RoleCreated.ToString(),
		}
		return
	}

	//查询昵称是否重复
	if req.NickName != "" {
		if ok := this.module.modelUser.NickNameIsExist(req.NickName); !ok {
			errdata = &pb.ErrorData{
				Code:  pb.ErrorCode_UserNickNameExist,
				Title: pb.ErrorCode_UserNickNameExist.ToString(),
			}
			return
		}
	}

	update := map[string]interface{}{
		"name":    req.NickName, //设置昵称
		"created": true,         //创角标识
		"curSkin": req.Skin,     //设置形象
		"gender":  req.Gender,   //设置性别
		"ps":      0,            //设置初始体力 调整未0 由策划初始表发放
	}
	globalConf := this.module.globalConf
	if req.Gender == 1 {
		update["avatar"] = globalConf.BoyHeadPortrait
	} else if req.Gender == 2 {
		update["avatar"] = globalConf.GirlHeadPortrait
	}
	user.Gender = req.Gender
	user.Name = req.NickName
	user.CurSkin = req.Skin
	user.Gender = req.Gender
	session.SetMate(comm.Session_User, user)
	if err := this.module.modelUser.Change(session.GetUserId(), update); err != nil {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_DBError,
			Title: pb.ErrorCode_DBError.ToString(),
		}
		this.module.Error("创角",
			log.Field{Key: "uid", Value: session.GetUserId()},
			log.Field{Key: "params", Value: update},
			log.Field{Key: "err", Value: err.Error()},
		)
		return
	}
	//初始化创角资源
	if val, err := this.module.configure.GetGlobalInitConf(); err == nil {
		for _, v := range val.GetDataList() {
			res = append(res, v.Var...)
		}
		if errdata, _ = this.module.DispenseAtno(session, res, true); errdata != nil {
			this.module.Error("发放资源失败!", log.Field{Key: "uid", Value: session.GetUserId()}, log.Field{Key: "err", Value: errdata.String()})
			return
		}
	}
	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype72, 1))
	session.SendMsg(string(this.module.GetType()), UserSubTypeCreate, &pb.UserCreateResp{
		NickName: req.NickName,
		Skin:     req.Skin,
		Gender:   req.Gender,
		Award:    award,
	})

	//异步逻辑
	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
		baseInfo := &pb.BaseUserInfo{
			Uid:    user.Uid,
			Sid:    user.Sid,
			Name:   user.Name,
			Gender: user.Gender,
			Skin:   user.CurSkin,
			Aframe: user.Curaframe,
			Title:  user.Curtitle,
			Lv:     user.Lv,
		}
		for _, m := range this.module.notifyUserinfo {
			i, err := this.service.GetModule(core.M_Modules(m))
			if err != nil {
				this.module.Errorln(err)
				continue
			}
			if ic, ok := i.(comm.IUpdateUserBaseInfo); ok {
				ic.UpdateUserBaseInfo(session, baseInfo)
			}
		}
		this.mail.SendMailByCid(session, comm.Welcomemail, nil)
		if len(tasks) > 0 {
			this.module.ModuleBuried.TriggerBuried(session, tasks...)
		}
		this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "UserCreateReq", award)
		this.module.modelUser.ResAutoReplies(session, user.Resreplies)
		this.module.plunder.InitPlunderByUser(session)
		// 初始好友信息
		this.module.ModuleFriend.GetFriendList(session.GetUserId())
	})
	return
}