UserServiceImpl(
    const MockSmsClient::ptr& mock_sms_client,  // 短信服務（真實/模擬可替換）
    const std::shared_ptr<elasticlient::Client>& es_client,  // ES（用戶搜索用）
    const std::shared_ptr<odb::core::database>& mysql_client,  // MySQL（用戶數(shù)據(jù)存儲）
    const std::shared_ptr<sw::redis::Redis>& redis_client,  // Redis（會話/驗證碼）
    const ServiceManager::ptr& channel_manager,  // 服務管理（調用文件服務等）
    const std::string& file_service_name  // 文件服務名稱（定位服務用）
) :
    _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)  // 注入短信服務，而非內部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("密碼長度不合法：{}-{}", 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. 取請求參數(shù)
    std::string nickname = request->nickname();
    std::string password = request->password();
    
    // 2. 校驗昵稱、密碼
    if (!nickname_check(nickname)) {
        return err_response("用戶名長度不合法！");
    }
    if (!password_check(password)) {
        return err_response("密碼格式不合法！");
    }
    
    // 3. 查昵稱是否已存在（ODB ORM調用）
    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ù)庫新增數(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) {}
    
    // 與真實DMSClient接口完全一致，方便替換
    bool send(const std::string& phone, const std::string& code) {
        // 不調用外部平臺，只打印日志（測試時能直接看到驗證碼）
        LOG_INFO("【模擬短信】向{}發(fā)送驗證碼：{}", phone, code);
        return true;
    }
private:
    Codes::ptr _codes_client;  // 用于后續(xù)擴展，比如存驗證碼
};

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

void UserLogin(...) {
    // 1. 校驗用戶名密碼
    auto user = _mysql_user->select_by_nickname(nickname);
    if (!user || password != user->password()) {
        return err_response("用戶名或密碼錯誤!");
    }
    
    // 2. 查是否已登錄（Redis查登錄狀態(tài)）
    if (_redis_status->exists(user->user_id())) {
        return err_response("用戶已在其他地方登錄!");
    }
    
    // 3. 生成ssid，存Redis（2小時過期）
    std::string ssid = uuid();
    _redis_session->append(ssid, user->user_id(), std::chrono::hours(2));
    
    // 4. 標記登錄狀態(tài)（2小時過期，與會話同步）
    _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. 調用文件服務上傳頭像（通過ServiceManager找文件服務節(jié)點）
    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("文件子服務調用失敗!");
    }
    
    // 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ù)庫用戶頭像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實現(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() {
    // 此時_codes_client已初始化，不會空指針
    _mock_sms_client = std::make_shared<MockSmsClient>(_codes_client);
}

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

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