package user

import (
	"go_dreamfactory/comm"
	"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) {
	// name := strings.TrimSpace(req.NickName)
	// if name == "" || len(name) > 30 {
	// 	errdata = &pb.ErrorData{
	// 		Code:  pb.ErrorCode_UserNickNameEmpty,
	// 		Title: pb.ErrorCode_UserNickNameEmpty.ToString(),
	// 	}
	// 	return
	// }

	// if ok, _ := wordfilter.Validate(name); !ok {
	// 	errdata = &pb.ErrorData{
	// 		Code:  pb.ErrorCode_UserNickSensitive,
	// 		Title: pb.ErrorCode_UserNickSensitive.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,         //创角标识
		"figure":  req.Figure,   //设置形象
		"gender":  req.Gender,   //设置性别
		"ps":      0,            //设置初始体力 调整未0 由策划初始表发放
	}
	globalConf := this.module.globalConf
	if req.Gender == 0 {
		update["avatar"] = globalConf.BoyHeadPortrait
	} else if req.Gender == 1 {
		update["avatar"] = globalConf.GirlHeadPortrait
	}

	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, award = 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()})
		}
	}
	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype72, 1))
	session.SendMsg(string(this.module.GetType()), UserSubTypeCreate, &pb.UserCreateResp{
		NickName: req.NickName,
		Figure:   req.Figure,
		Gender:   req.Gender,
		Award:    award,
	})

	//异步逻辑
	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
		this.mail.SendMailByCid(session, comm.Welcomemail, nil)
		if len(tasks) > 0 {
			this.module.ModuleBuried.TriggerBuried(session, tasks...)
		}
		this.module.WriteUserLog(session.GetUserId(), comm.GMResAddType, "UserCreateReq", award)
	})
	return
}