fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

同步

Browse Source
This commit is contained in:
wong
2026-01-05 11:04:08 +08:00
parent 8beb2cb6fe
commit f096e07ec8
19 changed files with 4352 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

130
Moncter/app/controller/IndexController.php
View File

@@ -21,4 +21,134 @@ class IndexController
return json(['code' => 0, 'msg' => 'ok']);
}
/**
* 测试 MongoDB 数据库连接
* GET /api/test/db
*/
public function testDb(Request $request)
{
$result = [
'code' => 0,
'msg' => 'ok',
'data' => [
'config' => [],
'connection' => [],
'test_query' => [],
],
];
try {
// 读取数据库配置
$dbConfig = config('database', []);
$mongoConfig = $dbConfig['connections']['mongodb'] ?? null;
if (!$mongoConfig) {
throw new \Exception('MongoDB 配置不存在');
}
$result['data']['config'] = [
'driver' => $mongoConfig['driver'] ?? 'unknown',
'database' => $mongoConfig['database'] ?? 'unknown',
'dsn' => $mongoConfig['dsn'] ?? 'unknown',
'has_username' => !empty($mongoConfig['username']),
'has_password' => !empty($mongoConfig['password']),
];
// 尝试使用 MongoDB 客户端直接连接
try {
// 构建包含认证信息的 DSN（如果配置了用户名和密码）
$dsn = $mongoConfig['dsn'];
if (!empty($mongoConfig['username']) && !empty($mongoConfig['password'])) {
// 如果 DSN 中不包含认证信息，则添加
if (strpos($dsn, '@') === false) {
// 从 mongodb://host:port 格式转换为 mongodb://username:password@host:port/database
$dsn = str_replace(
'mongodb://',
'mongodb://' . urlencode($mongoConfig['username']) . ':' . urlencode($mongoConfig['password']) . '@',
$dsn
);
// 添加数据库名和认证源
$dsn .= '/' . $mongoConfig['database'];
if (!empty($mongoConfig['options']['authSource'])) {
$dsn .= '?authSource=' . urlencode($mongoConfig['options']['authSource']);
}
}
}
// 过滤掉空字符串的选项（MongoDB 客户端不允许空字符串）
$options = array_filter($mongoConfig['options'] ?? [], function ($value) {
return $value !== '';
});
$client = new \MongoDB\Client(
$dsn,
$options
);
// 尝试执行 ping 命令
$adminDb = $client->selectDatabase('admin');
$pingResult = $adminDb->command(['ping' => 1])->toArray();
$result['data']['connection'] = [
'status' => 'connected',
'ping' => 'ok',
'server_info' => $client->getManager()->getServers(),
];
// 尝试选择目标数据库并列出集合
$targetDb = $client->selectDatabase($mongoConfig['database']);
$collections = $targetDb->listCollections();
$collectionNames = [];
foreach ($collections as $collection) {
$collectionNames[] = $collection->getName();
}
$result['data']['test_query'] = [
'database' => $mongoConfig['database'],
'collections_count' => count($collectionNames),
'collections' => $collectionNames,
];
} catch (\MongoDB\Driver\Exception\Exception $e) {
$result['data']['connection'] = [
'status' => 'failed',
'error' => $e->getMessage(),
'code' => $e->getCode(),
];
$result['code'] = 500;
$result['msg'] = 'MongoDB 连接失败';
}
// 尝试使用 Repository 查询（如果连接成功）
if ($result['data']['connection']['status'] === 'connected') {
try {
$userRepo = new \app\repository\UserProfileRepository();
$count = $userRepo->newQuery()->count();
$result['data']['repository_test'] = [
'status' => 'ok',
'user_profile_count' => $count,
];
} catch (\Throwable $e) {
$result['data']['repository_test'] = [
'status' => 'failed',
'error' => $e->getMessage(),
];
}
}
} catch (\Throwable $e) {
$result = [
'code' => 500,
'msg' => '测试失败: ' . $e->getMessage(),
'data' => [
'error' => $e->getMessage(),
'file' => $e->getFile(),
'line' => $e->getLine(),
],
];
}
return json($result);
}
}

555
Moncter/app/controller/UserController.php
View File

@@ -1,16 +1,557 @@
<?php
namespace app\controller;
use app\repository\UserProfileRepository;
use app\service\UserService;
use app\utils\ApiResponseHelper;
use app\utils\DataMaskingHelper;
use app\utils\LoggerHelper;
use support\Request;
use support\Response;
class UserController
{
public function hello(Request $request)
/**
* 创建用户
*
* POST /api/users
*
* 请求体示例：
* {
* "id_card": "110101199001011234",
* "id_card_type": "身份证",
* "name": "张三",
* "phone": "13800138000",
* "email": "zhangsan@example.com",
* "gender": 1,
* "birthday": "1990-01-01",
* "address": "北京市朝阳区"
* }
*/
public function store(Request $request): Response
{
$default_name = 'webman';
// 从get请求里获得name参数，如果没有传递name参数则返回$default_name
$name = $request->get('name', $default_name);
// 向浏览器返回字符串
return response('hello ' . $name);
try {
LoggerHelper::logRequest('POST', '/api/users');
$rawBody = $request->rawBody();
// 调试：记录原始请求体
if (empty($rawBody)) {
return ApiResponseHelper::error('请求体为空，请确保 Content-Type 为 application/json 并发送有效的 JSON 数据', 400);
}
$body = json_decode($rawBody, true);
if (json_last_error() !== JSON_ERROR_NONE) {
$errorMsg = '请求体必须是有效的 JSON 格式';
$jsonError = json_last_error_msg();
if ($jsonError) {
$errorMsg .= ': ' . $jsonError;
}
// 开发环境输出更多调试信息
if (getenv('APP_DEBUG') === 'true') {
$errorMsg .= ' (原始请求体: ' . substr($rawBody, 0, 200) . ')';
}
return ApiResponseHelper::error($errorMsg, 400);
}
$userService = new UserService(new UserProfileRepository());
$result = $userService->createUser($body);
return ApiResponseHelper::success($result, '用户创建成功');
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
}
/**
* 查询用户信息
*
* GET /api/users/{user_id}?decrypt_id_card=1
*
* @param Request $request
* @return Response
*/
public function show(Request $request): Response
{
try {
// 从请求路径中解析 user_id
$path = $request->path();
if (preg_match('#/api/users/([^/]+)#', $path, $matches)) {
$userId = $matches[1];
} else {
$userId = $request->get('user_id');
if (!$userId) {
throw new \InvalidArgumentException('缺少 user_id 参数');
}
}
LoggerHelper::logRequest('GET', $path, ['user_id' => $userId]);
// 检查是否需要解密身份证（需要权限控制，这里简单用参数控制）
$decryptIdCard = (bool)$request->get('decrypt_id_card', false);
$userService = new UserService(new UserProfileRepository());
$user = $userService->getUserById($userId, $decryptIdCard);
if (!$user) {
return ApiResponseHelper::error('用户不存在', 404, 404);
}
// 如果不需要解密身份证，对敏感字段进行脱敏
if (!$decryptIdCard) {
$user = DataMaskingHelper::maskArray($user, ['phone', 'email']);
}
LoggerHelper::logBusiness('get_user_info', [
'user_id' => $userId,
'decrypt_id_card' => $decryptIdCard,
]);
return ApiResponseHelper::success($user);
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
/**
* 更新用户信息
*
* PUT /api/users/{user_id}
*
* 请求体示例：
* {
* "name": "张三",
* "phone": "13800138000",
* "email": "zhangsan@example.com",
* "gender": 1,
* "birthday": "1990-01-01",
* "address": "北京市朝阳区",
* "status": 0
* }
*/
public function update(Request $request): Response
{
try {
// 从请求路径中解析 user_id
$path = $request->path();
if (preg_match('#/api/users/([^/]+)#', $path, $matches)) {
$userId = $matches[1];
} else {
$userId = $request->get('user_id');
if (!$userId) {
throw new \InvalidArgumentException('缺少 user_id 参数');
}
}
LoggerHelper::logRequest('PUT', $path, ['user_id' => $userId]);
$rawBody = $request->rawBody();
// 调试：记录原始请求体
if (empty($rawBody)) {
return ApiResponseHelper::error('请求体为空，请确保 Content-Type 为 application/json 并发送有效的 JSON 数据', 400);
}
$body = json_decode($rawBody, true);
if (json_last_error() !== JSON_ERROR_NONE) {
$errorMsg = '请求体必须是有效的 JSON 格式';
$jsonError = json_last_error_msg();
if ($jsonError) {
$errorMsg .= ': ' . $jsonError;
}
// 开发环境输出更多调试信息
if (getenv('APP_DEBUG') === 'true') {
$errorMsg .= ' (原始请求体: ' . substr($rawBody, 0, 200) . ')';
}
return ApiResponseHelper::error($errorMsg, 400);
}
if (empty($body)) {
return ApiResponseHelper::error('请求体不能为空', 400);
}
$userService = new UserService(new UserProfileRepository());
$result = $userService->updateUser($userId, $body);
// 脱敏处理
$result = DataMaskingHelper::maskArray($result, ['phone', 'email']);
return ApiResponseHelper::success($result, '用户更新成功');
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
/**
* 解密身份证号
*
* GET /api/users/{user_id}/decrypt-id-card
*/
public function decryptIdCard(Request $request): Response
{
try {
// 从请求路径中解析 user_id
$path = $request->path();
if (preg_match('#/api/users/([^/]+)/decrypt-id-card#', $path, $matches)) {
$userId = $matches[1];
} else {
$userId = $request->get('user_id');
if (!$userId) {
throw new \InvalidArgumentException('缺少 user_id 参数');
}
}
LoggerHelper::logRequest('GET', $path, ['user_id' => $userId]);
$userService = new UserService(new UserProfileRepository());
$user = $userService->getUserById($userId, true); // 强制解密
if (!$user) {
return ApiResponseHelper::error('用户不存在', 404, 404);
}
LoggerHelper::logBusiness('decrypt_id_card', [
'user_id' => $userId,
]);
return ApiResponseHelper::success([
'user_id' => $user['user_id'],
'id_card' => $user['id_card'] ?? ''
]);
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
/**
* 删除用户（软删除）
*
* DELETE /api/users/{user_id}
*/
public function destroy(Request $request): Response
{
try {
// 从请求路径中解析 user_id
$path = $request->path();
if (preg_match('#/api/users/([^/]+)#', $path, $matches)) {
$userId = $matches[1];
} else {
$userId = $request->get('user_id');
if (!$userId) {
throw new \InvalidArgumentException('缺少 user_id 参数');
}
}
LoggerHelper::logRequest('DELETE', $path, ['user_id' => $userId]);
$userService = new UserService(new UserProfileRepository());
$userService->deleteUser($userId);
return ApiResponseHelper::success(null, '用户删除成功');
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
/**
* 搜索用户（支持多种搜索条件组合）
*
* POST /api/users/search
*
* 支持以下搜索方式：
* 1. 基础字段搜索：姓名、手机号、邮箱、身份证号等
* 2. 标签筛选：根据用户标签筛选
* 3. 组合搜索：基础字段 + 标签筛选
*
* 请求体示例1（姓名模糊搜索）：
* {
* "name": "张三",
* "page": 1,
* "page_size": 20
* }
*
* 请求体示例2（组合搜索：姓名 + 手机号）：
* {
* "name": "张",
* "phone": "138",
* "page": 1,
* "page_size": 20
* }
*
* 请求体示例3（根据标签筛选）：
* {
* "tag_conditions": [
* {
* "tag_code": "high_consumer",
* "operator": "=",
* "value": "high"
* }
* ],
* "logic": "AND",
* "page": 1,
* "page_size": 20
* }
*
* 请求体示例4（组合搜索：基础字段 + 标签）：
* {
* "name": "张",
* "min_total_amount": 1000,
* "tag_conditions": [
* {
* "tag_code": "active_user",
* "operator": "=",
* "value": "active"
* }
* ],
* "page": 1,
* "page_size": 20
* }
*/
public function search(Request $request): Response
{
try {
LoggerHelper::logRequest('POST', '/api/users/search');
$rawBody = $request->rawBody();
// 调试：记录原始请求体
if (empty($rawBody)) {
return ApiResponseHelper::error('请求体为空，请确保 Content-Type 为 application/json 并发送有效的 JSON 数据', 400);
}
$body = json_decode($rawBody, true);
if (json_last_error() !== JSON_ERROR_NONE) {
$errorMsg = '请求体必须是有效的 JSON 格式';
$jsonError = json_last_error_msg();
if ($jsonError) {
$errorMsg .= ': ' . $jsonError;
}
// 开发环境输出更多调试信息
if (getenv('APP_DEBUG') === 'true') {
$errorMsg .= ' (原始请求体: ' . substr($rawBody, 0, 200) . ')';
}
return ApiResponseHelper::error($errorMsg, 400);
}
$page = (int)($body['page'] ?? 1);
$pageSize = (int)($body['page_size'] ?? 20);
if ($page < 1) {
$page = 1;
}
if ($pageSize < 1 || $pageSize > 100) {
$pageSize = 20;
}
$userService = new UserService(new UserProfileRepository());
// 情况1：仅根据身份证号查找（返回单个用户，不分页）
if (!empty($body['id_card']) && empty($body['tag_conditions']) && empty($body['name']) && empty($body['phone']) && empty($body['email'])) {
$user = $userService->findUserByIdCard($body['id_card']);
if (!$user) {
return ApiResponseHelper::error('未找到该身份证号对应的用户', 404, 404);
}
// 脱敏处理
$user = DataMaskingHelper::maskArray($user, ['phone', 'email']);
LoggerHelper::logBusiness('search_user_by_id_card', [
'found' => true,
]);
return ApiResponseHelper::success($user);
}
// 情况2：根据标签筛选用户（可能结合基础字段搜索）
if (!empty($body['tag_conditions'])) {
$tagService = new \app\service\TagService(
new \app\repository\TagDefinitionRepository(),
new UserProfileRepository(),
new \app\repository\UserTagRepository(),
new \app\repository\TagHistoryRepository(),
new \app\service\TagRuleEngine\SimpleRuleEngine()
);
$conditions = $body['tag_conditions'];
$logic = $body['logic'] ?? 'AND';
$includeUserInfo = true; // 标签筛选需要用户信息
// 验证条件格式
foreach ($conditions as $condition) {
if (!isset($condition['tag_code']) || !isset($condition['operator']) || !isset($condition['value'])) {
throw new \InvalidArgumentException('每个条件必须包含 tag_code、operator 和 value 字段');
}
}
// 先根据标签筛选用户
$tagResult = $tagService->filterUsersByTags(
$conditions,
$logic,
1, // 先获取所有符合条件的用户ID
10000, // 临时设置大值，获取所有用户ID
true
);
$userIds = array_column($tagResult['users'], 'user_id');
if (empty($userIds)) {
return ApiResponseHelper::success([
'users' => [],
'total' => 0,
'page' => $page,
'page_size' => $pageSize,
'total_pages' => 0,
]);
}
// 如果有基础字段搜索条件，进一步筛选
$baseConditions = [];
if (!empty($body['name'])) {
$baseConditions['name'] = $body['name'];
}
if (!empty($body['phone'])) {
$baseConditions['phone'] = $body['phone'];
$baseConditions['phone_exact'] = $body['phone_exact'] ?? false;
}
if (!empty($body['email'])) {
$baseConditions['email'] = $body['email'];
$baseConditions['email_exact'] = $body['email_exact'] ?? false;
}
if (isset($body['gender']) && $body['gender'] !== '') {
$baseConditions['gender'] = $body['gender'];
}
if (isset($body['status']) && $body['status'] !== '') {
$baseConditions['status'] = $body['status'];
}
if (isset($body['min_total_amount'])) {
$baseConditions['min_total_amount'] = $body['min_total_amount'];
}
if (isset($body['max_total_amount'])) {
$baseConditions['max_total_amount'] = $body['max_total_amount'];
}
if (isset($body['min_total_count'])) {
$baseConditions['min_total_count'] = $body['min_total_count'];
}
if (isset($body['max_total_count'])) {
$baseConditions['max_total_count'] = $body['max_total_count'];
}
// 如果有基础字段条件，需要进一步筛选
if (!empty($baseConditions)) {
$baseConditions['user_ids'] = $userIds; // 限制在标签筛选的用户范围内
$result = $userService->searchUsers($baseConditions, $page, $pageSize);
} else {
// 没有基础字段条件，直接使用标签筛选结果并分页
$total = count($userIds);
$offset = ($page - 1) * $pageSize;
$pagedUserIds = array_slice($userIds, $offset, $pageSize);
// 获取用户详细信息
$users = [];
foreach ($pagedUserIds as $userId) {
$user = $userService->getUserById($userId, false);
if ($user) {
$users[] = $user;
}
}
$result = [
'users' => $users,
'total' => $total,
'page' => $page,
'page_size' => $pageSize,
'total_pages' => (int)ceil($total / $pageSize),
];
}
// 对返回的用户信息进行脱敏处理
if (isset($result['users']) && is_array($result['users'])) {
foreach ($result['users'] as &$user) {
$user = DataMaskingHelper::maskArray($user, ['phone', 'email']);
}
unset($user);
}
LoggerHelper::logBusiness('search_users_by_tags', [
'conditions_count' => count($conditions),
'base_conditions' => !empty($baseConditions),
'result_count' => $result['total'] ?? 0,
]);
return ApiResponseHelper::success($result);
}
// 情况3：仅基础字段搜索（无标签条件）
$baseConditions = [];
if (!empty($body['name'])) {
$baseConditions['name'] = $body['name'];
}
if (!empty($body['phone'])) {
$baseConditions['phone'] = $body['phone'];
$baseConditions['phone_exact'] = $body['phone_exact'] ?? false;
}
if (!empty($body['email'])) {
$baseConditions['email'] = $body['email'];
$baseConditions['email_exact'] = $body['email_exact'] ?? false;
}
if (!empty($body['id_card'])) {
$baseConditions['id_card'] = $body['id_card'];
}
if (isset($body['gender']) && $body['gender'] !== '') {
$baseConditions['gender'] = $body['gender'];
}
if (isset($body['status']) && $body['status'] !== '') {
$baseConditions['status'] = $body['status'];
}
if (isset($body['min_total_amount'])) {
$baseConditions['min_total_amount'] = $body['min_total_amount'];
}
if (isset($body['max_total_amount'])) {
$baseConditions['max_total_amount'] = $body['max_total_amount'];
}
if (isset($body['min_total_count'])) {
$baseConditions['min_total_count'] = $body['min_total_count'];
}
if (isset($body['max_total_count'])) {
$baseConditions['max_total_count'] = $body['max_total_count'];
}
if (empty($baseConditions)) {
return ApiResponseHelper::error('请提供至少一个搜索条件', 400);
}
$result = $userService->searchUsers($baseConditions, $page, $pageSize);
// 对返回的用户信息进行脱敏处理
if (isset($result['users']) && is_array($result['users'])) {
foreach ($result['users'] as &$user) {
$user = DataMaskingHelper::maskArray($user, ['phone', 'email']);
}
unset($user);
}
LoggerHelper::logBusiness('search_users_by_base_fields', [
'conditions' => array_keys($baseConditions),
'result_count' => $result['total'] ?? 0,
]);
return ApiResponseHelper::success($result);
} catch (\InvalidArgumentException $e) {
return ApiResponseHelper::error($e->getMessage(), 400);
} catch (\Throwable $e) {
return ApiResponseHelper::exception($e);
}
}
}