UserServiceImpl(
    const MockSmsClient::ptr& mock_sms_client,  // 短信服務(wù)（真實(shí)/模擬可替換）
    const std::shared_ptr<elasticlient::Client>& es_client,  // ES（用戶搜索用）
    const std::shared_ptr<odb::core::database>& mysql_client,  // MySQL（用戶數(shù)據(jù)存儲(chǔ)）
    const std::shared_ptr<sw::redis::Redis>& redis_client,  // Redis（會(huì)話/驗(yàn)證碼）
    const ServiceManager::ptr& channel_manager,  // 服務(wù)管理（調(diào)用文件服務(wù)等）
    const std::string& file_service_name  // 文件服務(wù)名稱（定位服務(wù)用）
) :
    _es_user(std::make_shared<ESUser>(es_client)),
    _mysql_user(std::make_shared<UserTable>(mysql_client)),
    _redis_session(std::make_shared<Session>(redis_client)),
    _redis_status(std::make_shared<Status>(redis_client)),
    _redis_codes(std::make_shared<Codes>(redis_client)),
    _file_service_name(file_service_name),
    _mm_channels(channel_manager),
    _dms_client(mock_sms_client)  // 注入短信服務(wù)，而非內(nèi)部new
{
    _es_user->createIndex();  // 初始化ES用戶索引
}

bool password_check(const std::string &password) {
    // 密碼規(guī)則：6-15位，只含字母、數(shù)字、_、-
    if (password.size() < 6 || password.size() > 15) {
        LOG_ERROR("密碼長(zhǎng)度不合法：{}-{}", password, password.size());
        return false;
    }
    for (int i = 0; i < password.size(); i++) {
        if (!((password[i] > 'a' && password[i] < 'z') ||
            (password[i] > 'A' && password[i] < 'Z') ||
            (password[i] > '0' && password[i] < '9') ||
            password[i] == '_' || password[i] == '-')) {
            LOG_ERROR("密碼字符不合法：{}", password);
            return false;
        }
    }
    return true;
}

void UserRegister(...) {
    // 1. 取請(qǐng)求參數(shù)
    std::string nickname = request->nickname();
    std::string password = request->password();
    
    // 2. 校驗(yàn)昵稱、密碼
    if (!nickname_check(nickname)) {
        return err_response("用戶名長(zhǎng)度不合法！");
    }
    if (!password_check(password)) {
        return err_response("密碼格式不合法！");
    }
    
    // 3. 查昵稱是否已存在（ODB ORM調(diào)用）
    auto user = _mysql_user->select_by_nickname(nickname);
    if (user) {
        return err_response("用戶名被占用!");
    }
    
    // 4. 生成用戶ID，存MySQL+ES
    std::string uid = uuid();  // 自定義工具函數(shù)，生成唯一ID
    user = std::make_shared<User>(uid, nickname, password);
    if (!_mysql_user->insert(user)) {
        return err_response("Mysql數(shù)據(jù)庫(kù)新增數(shù)據(jù)失敗!");
    }
    if (!_es_user->appendData(uid, "", nickname, "", "")) {
        return err_response("ES搜索引擎新增數(shù)據(jù)失敗！");
    }
    
    // 5. 返回成功
    response->set_success(true);
}

// mock_sms.hpp
class MockSmsClient {
public:
    using ptr = std::shared_ptr<MockSmsClient>;
    MockSmsClient(const Codes::ptr& codes_client) : _codes_client(codes_client) {}
    
    // 與真實(shí)DMSClient接口完全一致，方便替換
    bool send(const std::string& phone, const std::string& code) {
        // 不調(diào)用外部平臺(tái)，只打印日志（測(cè)試時(shí)能直接看到驗(yàn)證碼）
        LOG_INFO("【模擬短信】向{}發(fā)送驗(yàn)證碼：{}", phone, code);
        return true;
    }
private:
    Codes::ptr _codes_client;  // 用于后續(xù)擴(kuò)展，比如存驗(yàn)證碼
};

void GetPhoneVerifyCode(...) {
    // 1. 校驗(yàn)手機(jī)號(hào)格式（11位，以1開(kāi)頭，第二位3-9）
    std::string phone = request->phone_number();
    if (!phone_check(phone)) {
        return err_response("手機(jī)號(hào)碼格式錯(cuò)誤!");
    }
    
    // 2. 生成4位驗(yàn)證碼（自定義工具函數(shù)vcode()）
    std::string code_id = uuid();
    std::string code = vcode();  // 返回如"1234"
    
    // 3. 調(diào)用模擬短信服務(wù)（實(shí)際只打日志）
    if (!_dms_client->send(phone, code)) {
        return err_response("短信驗(yàn)證碼發(fā)送失敗!");
    }
    
    // 4. 存Redis（5分鐘過(guò)期）
    _redis_codes->append(code_id, code, std::chrono::minutes(5));
    
    // 5. 返回驗(yàn)證碼ID
    response->set_verify_code_id(code_id);
    response->set_success(true);
}

void UserLogin(...) {
    // 1. 校驗(yàn)用戶名密碼
    auto user = _mysql_user->select_by_nickname(nickname);
    if (!user || password != user->password()) {
        return err_response("用戶名或密碼錯(cuò)誤!");
    }
    
    // 2. 查是否已登錄（Redis查登錄狀態(tài)）
    if (_redis_status->exists(user->user_id())) {
        return err_response("用戶已在其他地方登錄!");
    }
    
    // 3. 生成ssid，存Redis（2小時(shí)過(guò)期）
    std::string ssid = uuid();
    _redis_session->append(ssid, user->user_id(), std::chrono::hours(2));
    
    // 4. 標(biāo)記登錄狀態(tài)（2小時(shí)過(guò)期，與會(huì)話同步）
    _redis_status->append(user->user_id(), std::chrono::hours(2));
    
    // 5. 返回ssid
    response->set_login_session_id(ssid);
    response->set_success(true);
}

void SetUserAvatar(...) {
    // 1. 取用戶ID和頭像數(shù)據(jù)
    std::string uid = request->user_id();
    std::string avatar_data = request->avatar();
    
    // 2. 查用戶是否存在
    auto user = _mysql_user->select_by_id(uid);
    if (!user) {
        return err_response("未找到用戶信息!");
    }
    
    // 3. 調(diào)用文件服務(wù)上傳頭像（通過(guò)ServiceManager找文件服務(wù)節(jié)點(diǎn)）
    auto channel = _mm_channels->choose(_file_service_name);
    FileService_Stub stub(channel.get());
    PutSingleFileReq file_req;
    PutSingleFileRsp file_rsp;
    file_req.mutable_file_data()->set_file_content(avatar_data);
    stub.PutSingleFile(&cntl, &file_req, &file_rsp, nullptr);
    if (cntl.Failed() || !file_rsp.success()) {
        return err_response("文件子服務(wù)調(diào)用失敗!");
    }
    
    // 4. 更新MySQL的avatar_id
    std::string avatar_id = file_rsp.file_info().file_id();
    user->avatar_id(avatar_id);
    if (!_mysql_user->update(user)) {
        return err_response("更新數(shù)據(jù)庫(kù)用戶頭像ID失敗!");
    }
    
    // 5. 同步ES信息
    if (!_es_user->appendData(user->user_id(), user->phone(), 
        user->nickname(), user->description(), avatar_id)) {
        return err_response("更新搜索引擎用戶頭像ID失敗!");
    }
    
    response->set_success(true);
}

add_executable(user_server
    source/user_server.cc
    source/user-odb.cxx  # 必須加，否則鏈接不到ORM實(shí)現(xiàn)
)

// UserServerBuilder
void make_redis_object(...) {
    _redis_client = RedisClientFactory::create(...);
    // 初始化Codes，賦值給成員變量
    _codes_client = std::make_shared<Codes>(_redis_client);
}

void make_mock_sms_object() {
    // 此時(shí)_codes_client已初始化，不會(huì)空指針
    _mock_sms_client = std::make_shared<MockSmsClient>(_codes_client);
}

# 查找依賴庫(kù)
find_package(swredis++ REQUIRED)
find_package(hiredis REQUIRED)

# 鏈接到目標(biāo)
target_link_libraries(user_server
    PRIVATE
    sw::redis++::swredis++
    hiredis::hiredis
    odb::mysql  # ODB MySQL庫(kù)
    elasticlient::elasticlient  # ES客戶端庫(kù)
    brpc  # RPC庫(kù)
    pthread  # 線程庫(kù)
)