恋恋风辰的官方博客

聊天项目(13) 重置密码功能
Posted on 2024-04-26 18:10:11 by 恋恋风辰 | In C++ | 原文链接

重置密码label

当我们在登录忘记密码的时候可以支持重置密码，重置密码label也要实现浮动和点击效果，以及未点击效果。所以我们复用之前的ClickedLabel,
在登录界面中升级forget_label为ClickedLabel。

  1. LoginDialog::LoginDialog(QWidget *parent) :
  2.     QDialog(parent),
  3.     ui(new Ui::LoginDialog)
  4. {
  5.     ui->setupUi(this);
  6.     connect(ui->reg_btn, &QPushButton::clicked, this, &LoginDialog::switchRegister);
  7.     ui->forget_label->SetState("normal","hover","","selected","selected_hover","");
  8.     ui->forget_label->setCursor(Qt::PointingHandCursor);
  9.     connect(ui->forget_label, &ClickedLabel::clicked, this, &LoginDialog::slot_forget_pwd);
  10. }

点击忘记密码发送对应的信号

  1. void LoginDialog::slot_forget_pwd()
  2. {
  3.     qDebug()<<"slot forget pwd";
  4.     emit switchReset();
  5. }

我们在mainwindow中连接了重置密码的信号和槽

  1. //连接登录界面忘记密码信号
  2. connect(_login_dlg, &LoginDialog::switchReset, this, &MainWindow::SlotSwitchReset);

实现SlotSwitchReset

  1. void MainWindow::SlotSwitchReset()
  2. {
  3.     //创建一个CentralWidget, 并将其设置为MainWindow的中心部件
  4.     _reset_dlg = new ResetDialog(this);
  5.     _reset_dlg->setWindowFlags(Qt::CustomizeWindowHint|Qt::FramelessWindowHint);
  6.     setCentralWidget(_reset_dlg);
  8.    _login_dlg->hide();
  9.     _reset_dlg->show();
  10.     //注册返回登录信号和槽函数
  11.     connect(_reset_dlg, &ResetDialog::switchLogin, this, &MainWindow::SlotSwitchLogin2);
  12. }

ResetDialog是我们添加的界面类，新建ResetDialog界面类，界面布局如下

https://cdn.llfc.club/1712826184149.jpg

重置界面

  1. #include "resetdialog.h"
  2. #include "ui_resetdialog.h"
  3. #include <QDebug>
  4. #include <QRegularExpression>
  5. #include "global.h"
  6. #include "httpmgr.h"
  8. ResetDialog::ResetDialog(QWidget *parent) :
  9.     QDialog(parent),
  10.     ui(new Ui::ResetDialog)
  11. {
  12.     ui->setupUi(this);
  14.     connect(ui->user_edit,&QLineEdit::editingFinished,this,[this](){
  15.         checkUserValid();
  16.     });
  18.     connect(ui->email_edit, &QLineEdit::editingFinished, this, [this](){
  19.         checkEmailValid();
  20.     });
  22.     connect(ui->pwd_edit, &QLineEdit::editingFinished, this, [this](){
  23.         checkPassValid();
  24.     });
  27.     connect(ui->varify_edit, &QLineEdit::editingFinished, this, [this](){
  28.          checkVarifyValid();
  29.     });
  31.     //连接reset相关信号和注册处理回调
  32.     initHandlers();
  33.     connect(HttpMgr::GetInstance().get(), &HttpMgr::sig_reset_mod_finish, this,
  34.             &ResetDialog::slot_reset_mod_finish);
  36. }

下面是检测逻辑

  1. bool ResetDialog::checkUserValid()
  2. {
  3.     if(ui->user_edit->text() == ""){
  4.         AddTipErr(TipErr::TIP_USER_ERR, tr("用户名不能为空"));
  5.         return false;
  6.     }
  8.     DelTipErr(TipErr::TIP_USER_ERR);
  9.     return true;
  10. }
  13. bool ResetDialog::checkPassValid()
  14. {
  15.     auto pass = ui->pwd_edit->text();
  17.     if(pass.length() < 6 || pass.length()>15){
  18.         //提示长度不准确
  19.         AddTipErr(TipErr::TIP_PWD_ERR, tr("密码长度应为6~15"));
  20.         return false;
  21.     }
  23.     // 创建一个正则表达式对象，按照上述密码要求
  24.     // 这个正则表达式解释：
  25.     // ^[a-zA-Z0-9!@#$%^&*]{6,15}$ 密码长度至少6，可以是字母、数字和特定的特殊字符
  26.     QRegularExpression regExp("^[a-zA-Z0-9!@#$%^&*]{6,15}$");
  27.     bool match = regExp.match(pass).hasMatch();
  28.     if(!match){
  29.         //提示字符非法
  30.         AddTipErr(TipErr::TIP_PWD_ERR, tr("不能包含非法字符"));
  31.         return false;;
  32.     }
  34.     DelTipErr(TipErr::TIP_PWD_ERR);
  36.     return true;
  37. }
  39. bool ResetDialog::checkEmailValid()
  40. {
  41.     //验证邮箱的地址正则表达式
  42.     auto email = ui->email_edit->text();
  43.     // 邮箱地址的正则表达式
  44.     QRegularExpression regex(R"((\w+)(\.|_)?(\w*)@(\w+)(\.(\w+))+)");
  45.     bool match = regex.match(email).hasMatch(); // 执行正则表达式匹配
  46.     if(!match){
  47.         //提示邮箱不正确
  48.         AddTipErr(TipErr::TIP_EMAIL_ERR, tr("邮箱地址不正确"));
  49.         return false;
  50.     }
  52.     DelTipErr(TipErr::TIP_EMAIL_ERR);
  53.     return true;
  54. }
  56. bool ResetDialog::checkVarifyValid()
  57. {
  58.     auto pass = ui->varify_edit->text();
  59.     if(pass.isEmpty()){
  60.         AddTipErr(TipErr::TIP_VARIFY_ERR, tr("验证码不能为空"));
  61.         return false;
  62.     }
  64.     DelTipErr(TipErr::TIP_VARIFY_ERR);
  65.     return true;
  66. }
  68. void ResetDialog::AddTipErr(TipErr te, QString tips)
  69. {
  70.     _tip_errs[te] = tips;
  71.     showTip(tips, false);
  72. }
  74. void ResetDialog::DelTipErr(TipErr te)
  75. {
  76.     _tip_errs.remove(te);
  77.     if(_tip_errs.empty()){
  78.       ui->err_tip->clear();
  79.       return;
  80.     }
  82.     showTip(_tip_errs.first(), false);
  83. }

显示接口

  1. void ResetDialog::showTip(QString str, bool b_ok)
  2. {
  3.     if(b_ok){
  4.          ui->err_tip->setProperty("state","normal");
  5.     }else{
  6.         ui->err_tip->setProperty("state","err");
  7.     }
  9.     ui->err_tip->setText(str);
  11.     repolish(ui->err_tip);
  12. }

获取验证码

  1. void ResetDialog::on_varify_btn_clicked()
  2. {
  3.     qDebug()<<"receive varify btn clicked ";
  4.     auto email = ui->email_edit->text();
  5.     auto bcheck = checkEmailValid();
  6.     if(!bcheck){
  7.         return;
  8.     }
  10.     //发送http请求获取验证码
  11.     QJsonObject json_obj;
  12.     json_obj["email"] = email;
  13.     HttpMgr::GetInstance()->PostHttpReq(QUrl(gate_url_prefix+"/get_varifycode"),
  14.                                         json_obj, ReqId::ID_GET_VARIFY_CODE,Modules::RESETMOD);
  15. }

初始化回包处理逻辑

  1. void ResetDialog::initHandlers()
  2. {
  3.     //注册获取验证码回包逻辑
  4.     _handlers.insert(ReqId::ID_GET_VARIFY_CODE, [this](QJsonObject jsonObj){
  5.         int error = jsonObj["error"].toInt();
  6.         if(error != ErrorCodes::SUCCESS){
  7.             showTip(tr("参数错误"),false);
  8.             return;
  9.         }
  10.         auto email = jsonObj["email"].toString();
  11.         showTip(tr("验证码已发送到邮箱，注意查收"), true);
  12.         qDebug()<< "email is " << email ;
  13.     });
  15.     //注册注册用户回包逻辑
  16.     _handlers.insert(ReqId::ID_RESET_PWD, [this](QJsonObject jsonObj){
  17.         int error = jsonObj["error"].toInt();
  18.         if(error != ErrorCodes::SUCCESS){
  19.             showTip(tr("参数错误"),false);
  20.             return;
  21.         }
  22.         auto email = jsonObj["email"].toString();
  23.         showTip(tr("重置成功,点击返回登录"), true);
  24.         qDebug()<< "email is " << email ;
  25.         qDebug()<< "user uuid is " <<  jsonObj["uuid"].toString();
  26.     });
  27. }

根据返回的id调用不同的回报处理逻辑

  1. void ResetDialog::slot_reset_mod_finish(ReqId id, QString res, ErrorCodes err)
  2. {
  3.     if(err != ErrorCodes::SUCCESS){
  4.         showTip(tr("网络请求错误"),false);
  5.         return;
  6.     }
  8.     // 解析 JSON 字符串,res需转化为QByteArray
  9.     QJsonDocument jsonDoc = QJsonDocument::fromJson(res.toUtf8());
  10.     //json解析错误
  11.     if(jsonDoc.isNull()){
  12.         showTip(tr("json解析错误"),false);
  13.         return;
  14.     }
  16.     //json解析错误
  17.     if(!jsonDoc.isObject()){
  18.         showTip(tr("json解析错误"),false);
  19.         return;
  20.     }
  23.     //调用对应的逻辑,根据id回调。
  24.     _handlers[id](jsonDoc.object());
  26.     return;
  27. }

这里实现发送逻辑

  1. void ResetDialog::on_sure_btn_clicked()
  2. {
  3.     bool valid = checkUserValid();
  4.     if(!valid){
  5.         return;
  6.     }
  8.     valid = checkEmailValid();
  9.     if(!valid){
  10.         return;
  11.     }
  13.     valid = checkPassValid();
  14.     if(!valid){
  15.         return;
  16.     }
  18.     valid = checkVarifyValid();
  19.     if(!valid){
  20.         return;
  21.     }
  23.     //发送http重置用户请求
  24.     QJsonObject json_obj;
  25.     json_obj["user"] = ui->user_edit->text();
  26.     json_obj["email"] = ui->email_edit->text();
  27.     json_obj["passwd"] = xorString(ui->pwd_edit->text());
  28.     json_obj["varifycode"] = ui->varify_edit->text();
  29.     HttpMgr::GetInstance()->PostHttpReq(QUrl(gate_url_prefix+"/reset_pwd"),
  30.                  json_obj, ReqId::ID_RESET_PWD,Modules::RESETMOD);
  31. }

注册、重置、登录切换

我们要实现注册、重置、登录三个界面的替换，就需要在MainWindow中添加SlotSwitchLogin2的实现

  1. //从重置界面返回登录界面
  2. void MainWindow::SlotSwitchLogin2()
  3. {
  4.     //创建一个CentralWidget, 并将其设置为MainWindow的中心部件
  5.     _login_dlg = new LoginDialog(this);
  6.     _login_dlg->setWindowFlags(Qt::CustomizeWindowHint|Qt::FramelessWindowHint);
  7.     setCentralWidget(_login_dlg);
  9.    _reset_dlg->hide();
  10.     _login_dlg->show();
  11.     //连接登录界面忘记密码信号
  12.     connect(_login_dlg, &LoginDialog::switchReset, this, &MainWindow::SlotSwitchReset);
  13.     //连接登录界面注册信号
  14.     connect(_login_dlg, &LoginDialog::switchRegister, this, &MainWindow::SlotSwitchReg);
  15. }

服务端响应重置

在LogicSystem的构造函数中增加注册逻辑

  1. //重置回调逻辑
  2. RegPost("/reset_pwd", [](std::shared_ptr<HttpConnection> connection) {
  3.     auto body_str = boost::beast::buffers_to_string(connection->_request.body().data());
  4.     std::cout << "receive body is " << body_str << std::endl;
  5.     connection->_response.set(http::field::content_type, "text/json");
  6.     Json::Value root;
  7.     Json::Reader reader;
  8.     Json::Value src_root;
  9.     bool parse_success = reader.parse(body_str, src_root);
  10.     if (!parse_success) {
  11.         std::cout << "Failed to parse JSON data!" << std::endl;
  12.         root["error"] = ErrorCodes::Error_Json;
  13.         std::string jsonstr = root.toStyledString();
  14.         beast::ostream(connection->_response.body()) << jsonstr;
  15.         return true;
  16.     }
  18.     auto email = src_root["email"].asString();
  19.     auto name = src_root["user"].asString();
  20.     auto pwd = src_root["passwd"].asString();
  22.     //先查找redis中email对应的验证码是否合理
  23.     std::string  varify_code;
  24.     bool b_get_varify = RedisMgr::GetInstance()->Get(CODEPREFIX + src_root["email"].asString(), varify_code);
  25.     if (!b_get_varify) {
  26.         std::cout << " get varify code expired" << std::endl;
  27.         root["error"] = ErrorCodes::VarifyExpired;
  28.         std::string jsonstr = root.toStyledString();
  29.         beast::ostream(connection->_response.body()) << jsonstr;
  30.         return true;
  31.     }
  33.     if (varify_code != src_root["varifycode"].asString()) {
  34.         std::cout << " varify code error" << std::endl;
  35.         root["error"] = ErrorCodes::VarifyCodeErr;
  36.         std::string jsonstr = root.toStyledString();
  37.         beast::ostream(connection->_response.body()) << jsonstr;
  38.         return true;
  39.     }
  40.     //查询数据库判断用户名和邮箱是否匹配
  41.     bool email_valid = MysqlMgr::GetInstance()->CheckEmail(name, email);
  42.     if (!email_valid) {
  43.         std::cout << " user email not match" << std::endl;
  44.         root["error"] = ErrorCodes::EmailNotMatch;
  45.         std::string jsonstr = root.toStyledString();
  46.         beast::ostream(connection->_response.body()) << jsonstr;
  47.         return true;
  48.     }
  50.     //更新密码为最新密码
  51.     bool b_up = MysqlMgr::GetInstance()->UpdatePwd(name, pwd);
  52.     if (!b_up) {
  53.         std::cout << " update pwd failed" << std::endl;
  54.         root["error"] = ErrorCodes::PasswdUpFailed;
  55.         std::string jsonstr = root.toStyledString();
  56.         beast::ostream(connection->_response.body()) << jsonstr;
  57.         return true;
  58.     }
  60.     std::cout << "succeed to update password" << pwd << std::endl;
  61.     root["error"] = 0;
  62.     root["email"] = email;
  63.     root["user"] = name;
  64.     root["passwd"] = pwd;
  65.     root["varifycode"] = src_root["varifycode"].asString();
  66.     std::string jsonstr = root.toStyledString();
  67.     beast::ostream(connection->_response.body()) << jsonstr;
  68.     return true;
  69.     });

在Mysql中新增CheckEmail和UpdatePwd函数

  1. bool MysqlMgr::CheckEmail(const std::string& name, const std::string& email) {
  2.     return _dao.CheckEmail(name, email);
  3. }
  5. bool MysqlMgr::UpdatePwd(const std::string& name, const std::string& pwd) {
  6.     return _dao.UpdatePwd(name, pwd);
  7. }

DAO这一层写具体的逻辑, 检测邮箱是否合理

  1. bool MysqlDao::CheckEmail(const std::string& name, const std::string& email) {
  2.     auto con = pool_->getConnection();
  3.     try {
  4.         if (con == nullptr) {
  5.             pool_->returnConnection(std::move(con));
  6.             return false;
  7.         }
  9.         // 准备查询语句
  10.         std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("SELECT email FROM user WHERE name = ?"));
  12.         // 绑定参数
  13.         pstmt->setString(1, name);
  15.         // 执行查询
  16.         std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());
  18.         // 遍历结果集
  19.         while (res->next()) {
  20.             std::cout << "Check Email: " << res->getString("email") << std::endl;
  21.             if (email != res->getString("email")) {
  22.                 pool_->returnConnection(std::move(con));
  23.                 return false;
  24.             }
  25.             pool_->returnConnection(std::move(con));
  26.             return true;
  27.         }
  28.     }
  29.     catch (sql::SQLException& e) {
  30.         pool_->returnConnection(std::move(con));
  31.         std::cerr << "SQLException: " << e.what();
  32.         std::cerr << " (MySQL error code: " << e.getErrorCode();
  33.         std::cerr << ", SQLState: " << e.getSQLState() << " )" << std::endl;
  34.         return false;
  35.     }
  36. }

更新密码

  1. bool MysqlDao::UpdatePwd(const std::string& name, const std::string& newpwd) {
  2.     auto con = pool_->getConnection();
  3.     try {
  4.         if (con == nullptr) {
  5.             pool_->returnConnection(std::move(con));
  6.             return false;
  7.         }
  9.         // 准备查询语句
  10.         std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("UPDATE user SET pwd = ? WHERE name = ?"));
  12.         // 绑定参数
  13.         pstmt->setString(2, name);
  14.         pstmt->setString(1, newpwd);
  16.         // 执行更新
  17.         int updateCount = pstmt->executeUpdate();
  19.         std::cout << "Updated rows: " << updateCount << std::endl;
  20.         pool_->returnConnection(std::move(con));
  21.         return true;
  22.     }
  23.     catch (sql::SQLException& e) {
  24.         pool_->returnConnection(std::move(con));
  25.         std::cerr << "SQLException: " << e.what();
  26.         std::cerr << " (MySQL error code: " << e.getErrorCode();
  27.         std::cerr << ", SQLState: " << e.getSQLState() << " )" << std::endl;
  28.         return false;
  29.     }
  30. }
热门评论
  • T-summers
    2024-11-27 10:55:24

    有个问题，在检查邮箱号里，不应该是遍历结果集吗，但你的实现只能循环一次就会退出。

    下面是我改的实现。

        try
    {
        if (con == nullptr)
        {
            pool_->returnConnection(std::move(con));
            return false;
        }
        std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("SELECT email FROM user WHERE name = ?"));
        pstmt->setString(1, name);
        std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());
        while (res->next())
        {
            std::cout << "Check Email: " << res->getString("email") << std::endl;
            if (email == res->getString("email"))
            {
                pool_->returnConnection(std::move(con));
                return true;
            }
        }
        pool_->returnConnection(std::move(con));
        return false;
    }
点击查看更多评论 没有更多评论了,点击收起 展开评论

热门文章

  1. vscode搭建windows C++开发环境
    喜欢(596) 浏览(98933)

  2. 使用hexo搭建个人博客
    喜欢(533) 浏览(14046)

  3. Linux环境搭建和编码
    喜欢(594) 浏览(15685)

  4. MarkDown在线编辑器
    喜欢(514) 浏览(15966)

  5. 聊天项目(28) 分布式服务通知好友申请
    喜欢(507) 浏览(7228)

最新评论

  1. 无锁并发队列 TenThousandOne:_head  和 _tail  替换为原子变量。那里pop的逻辑，val = _data[h] 可以移到循环外面吗
  2. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理，无论工作也好生活也罢，最重要的是开心，即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃，所以我还是想去做喜欢的方向。
  3. 处理网络粘包问题 zyouth: //消息的长度小于头部规定的长度，说明数据未收全，则先将部分消息放到接收节点里 if (bytes_transferred < data_len) { memcpy(_recv_msg_node->_data + _recv_msg_node->_cur_len, _data + copy_len, bytes_transferred); _recv_msg_node->_cur_len += bytes_transferred; ::memset(_data, 0, MAX_LENGTH); _socket.async_read_some(boost::asio::buffer(_data, MAX_LENGTH), std::bind(&CSession::HandleRead, this, std::placeholders::_1, std::placeholders::_2, shared_self)); //头部处理完成 _b_head_parse = true; return; } 把_b_head_parse = true;放在_socket.async_read_some前面是不是更好
  4. C++ 线程池原理和实现 mzx2023:两种方法解决，一种是改排序算法，就是当线程耗尽的时候，使用普通递归，另一种是当在线程池commit的时候，判断线程是否耗尽，耗尽的话就直接当前线程执行task
  5. 利用指针和容器实现文本查询 越今朝:应该添加一个过滤功能以解决部分单词无法被查询的问题: eg: "I am a teacher."中的teacher无法被查询，因为在示例代码中teacher.被解释为一个单词从而忽略了teacher本身。

其他链接

  1. GitHub
  2. 个人博客
  3. 博客园
  4. CSDN

个人公众号

个人微信