逻辑代码

接口

• 初始化角色信息

int32_t process_request_create_role(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);
int32_t process_response_create_role(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);

• 获取角色信息

int32_t process_request_get_role_info(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);
int32_t process_response_get_role_info(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);
int32_t process_notify_load_player_completed(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);

## 创建角色
1. 功能图

2. CPbMsgRequestCreateRole 结构体信息

//MSG_LOGIC_CREATE_ROLE 0x2020
message CPbMsgRequestCreateRole
{
required string m_szRoleName = 1;
required int32 m_iSirdarID = 2;
optional string m_szFBAccount = 3;
}

3. process_request_create_role接口实现
  MSG_LOGIC_CREATE_ROLE
  `int32_t CPlayer::process_request_create_role(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength)`
  1. 未创建角色状态判断 
  2. 定时器判断
    目的防止客户端还在创建过程中，没有返回给客户端，但是客户端又重新创建。
  3. 填充玩家信息
  4. 设置定时器
4. ProcessRequestCreateRole
  SS_MSG_CREATE_ROLE
  `int32_t CRoleProcessor::ProcessRequestCreateRole(int32_t iServerID, CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength)`

  1. 向数据库写入角色信息
      **注意:** 防止SQL非法字符注入，
    ```
char szEscapeName[max_role_name_length+max_role_name_length+1] = {0};
        MakeRealEscapeString(szEscapeName, stReqBody.m_stInfo.m_stRoleBrief.m_szRoleName, strlen(stReqBody.m_stInfo.m_stRoleBrief.m_szRoleName));
    ```
  2. 同步插入
    ```
    int32_t CProcessor::FormatAndExecuteSQLSync(const char* szFormat,...)
    {
        va_list vaList;
        va_start(vaList,szFormat);
        int32_t iRet = FormatSQLString(szFormat, vaList);
        va_end(vaList);
        
        if (success != iRet)
        {
          return fail;
        }
        
        return m_stMySql.execute(&m_szSQL[0]);
    }
    ```
    因为在玩家创建角色过程中，我们关注玩家的返回结果。创建玩家账号，和玩家角色信息。创建角色信息失败，自然也要删除之前创建的账号信息。之后可以给新玩家，赠送道具什么的。整个创建角色过程中，判断是否有超时。
  3. 响应

stRspBody.m_nResultID = result_id_success;
stRspBody.m_stInfo = stReqBody.m_stInfo;
return SendResponse(iServerID, rstMsgHead, stRspBody);

到此玩家创建角色结束。
5. process_response_create_role  
SS_MSG_CREATE_ROLE
解除定时器
6. process_request_get_role_info
获取之前生成一个FlagKey

m_lRoleFlagKey = now_msec();
CRequstGetRoleInfo stReqBody;
stReqBody.m_lRoleFlagKey = m_lRoleFlagKey;
send_request_to_gamedb(&stReqBody, SS_MSG_GET_ROLE_INFO, rstMsgHead.m_iMessageSequence);
return success;

7.process_response_get_role_info

7. 获取gamedb中创建角色信息
SS_MSG_GET_ROLE_INFO
`irtual void Excuting(int32_t iServerID, CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength);`

接口实现
  ```
 void CGetRoleCommand::Excuting(int32_t iServerID, CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength)
{
  CRequestGetRoleInfo stMsgBody;
  if (!stMsgBody.ParseFromArray(pszMsgBody, iBodyLength))
  {
      return;
  }
  CResponseGetRoleInfo stRspBody;
  stRspBody.m_nResultID = GetProcessor()->LoadPlayerDataFromDB(GetPlayer());

  if  (result_id_success == stRspBody.m_nResultID)
  {
      stRspBody.m_stInfo = GetPlayer()->m_stRole;
  }
  SendResponse(iServerID, rstMsgHead, stRspBody);
  
  if (result_id_success == stRspBody.m_nResultID)
  {
      GetProcessor()->SendPlaterDataToLogicServer(GetPlayer());
      GetProcessor()->NotifyMessageToPlayer(GetPlayer()->get_group(), GetPalyer()->get_uin(), SS_MSG_NOTIFY_LOAD_PLAYER_COMPLETED, &stMsgBody);
  }
}

7. process_notify_load_player_completed
   SS_MSG_NOTIFY_LOAD_PLAYER_COMPLETED
   检查状态是否同步，检查和更新玩家数据信息。

   int32_t CPlayer::process_notify_load_player_completed(CMessageHead& rstMsgHead, char* pszMsgBody, int32_t iBodyLength)
   {
     CNotifyLoadPlayerComplete stMsgBody;
     if (!stMsgBody.ParseFromArray(pszMsgBody, iBodyLength))
     {  
       return fail;
     }
     
     if (stMsgBody.m_lRoleFlagKey != m_lRoleFlagKey)
     {
         return fail;
     }
     .
     .
     .
     google::protobuf::MessageLite* pstBody = NULL;
     return send_notify_to_client(pstBody, MSG_LOGIC_NOTIFY_LOAD_PLAYER_COMPLETED);
   }