2

app/Module/AppMessage/README.md

@@ -1,144 +0,0 @@
-# APP站内信模块文档
-
-## 模块说明
-APP消息模块是一个APP内部消息通知系统，支持系统消息、用户消息、业务消息等类型。
-
-## 目录结构
-```
-app/Module/AppMessage/
-├── Controllers/          # 控制器目录
-├── Models/              # 模型目录
-├── Repositorys/         # 仓库目录
-├── Services/            # 服务目录
-├── Validators/          # 验证器目录
-├── Validations/         # 验证规则目录
-├── Queues/              # 队列目录
-├── Enums/               # 枚举目录
-└── Commands/            # 命令目录
-```
-
-## 数据表设计
-
-### 消息表 (app_messages)
-| 字段名 | 类型 | 说明 |
-|--------|------|------|
-| id | bigint | 主键ID |
-| type | varchar(20) | 消息类型 |
-| title | varchar(255) | 消息标题 |
-| content | text | 消息内容 |
-| data | json | 消息数据 |
-| sender_id | bigint | 发送者ID |
-| sender_type | varchar(20) | 发送者类型 |
-| status | tinyint | 状态：0禁用 1启用 |
-| created_at | timestamp | 创建时间 |
-| updated_at | timestamp | 更新时间 |
-
-### 消息接收表 (app_message_recipients)
-| 字段名 | 类型 | 说明 |
-|--------|------|------|
-| id | bigint | 主键ID |
-| message_id | bigint | 消息ID |
-| user_id | bigint | 用户ID |
-| is_read | tinyint | 是否已读：0未读 1已读 |
-| read_at | timestamp | 阅读时间 |
-| created_at | timestamp | 创建时间 |
-| updated_at | timestamp | 更新时间 |
-
-### 消息模板表 (app_message_templates)
-| 字段名 | 类型 | 说明 |
-|--------|------|------|
-| id | bigint | 主键ID |
-| name | varchar(100) | 模板名称 |
-| code | varchar(50) | 模板代码 |
-| type | varchar(20) | 消息类型 |
-| title | varchar(255) | 消息标题 |
-| content | text | 消息内容 |
-| variables | json | 变量定义 |
-| status | tinyint | 状态：0禁用 1启用 |
-| created_at | timestamp | 创建时间 |
-| updated_at | timestamp | 更新时间 |
-
-## 枚举定义
-
-### 消息类型 (AppMessageType)
-- SYSTEM: 系统消息
-- USER: 用户消息
-- BUSINESS: 业务消息
-- SECURITY: 安全消息
-
-### 发送者类型 (AppSenderType)
-- SYSTEM: 系统
-- USER: 用户
-- ADMIN: 管理员
-
-### 消息状态 (AppMessageStatus)
-- DRAFT: 草稿
-- PUBLISHED: 已发布
-- ARCHIVED: 已归档
-
-## 核心服务
-
-### AppMessageService
-消息核心服务，负责消息的发送、模板管理等功能。
-
-主要方法：
-- send(array $data): 发送消息
-- sendBatch(array $data): 批量发送消息
-- getTemplate(int $id): 获取模板
-- createTemplate(array $data): 创建模板
-- updateTemplate(int $id, array $data): 更新模板
-- deleteTemplate(int $id): 删除模板
-- markAsRead(int $messageId, int $userId): 标记消息为已读
-- getUnreadCount(int $userId): 获取未读消息数量
-
-## 队列处理
-
-### SendAppMessageQueue
-消息发送队列，处理异步发送任务。
-
-## 使用示例
-
-```php
-// 发送消息
-$messageService = new AppMessageService();
-$messageService->send([
-    'template_id' => 1,
-    'user_ids' => [1, 2, 3],
-    'data' => [
-        'order_id' => '123456',
-        'amount' => 100
-    ]
-]);
-
-// 批量发送消息
-$messageService->sendBatch([
-    [
-        'template_id' => 1,
-        'user_ids' => [1, 2],
-        'data' => ['order_id' => '123456']
-    ],
-    [
-        'template_id' => 2,
-        'user_ids' => [3, 4],
-        'data' => ['order_id' => '654321']
-    ]
-]);
-
-// 标记消息为已读
-$messageService->markAsRead(1, 1);
-
-// 获取未读消息数量
-$unreadCount = $messageService->getUnreadCount(1);
-```
-
-## 注意事项
-1. 消息发送采用队列异步处理
-2. 支持消息模板
-3. 支持变量替换
-4. 支持消息类型
-5. 支持消息状态
-6. 支持消息归档
-7. 支持消息统计
-8. 支持消息撤回
-9. 支持消息定时发送
-10. 支持消息优先级 

app/Module/AppMessage/Services/AppMessageService.php

@@ -1,316 +0,0 @@
-<?php
-
-namespace App\Module\AppMessage\Services;
-
-use App\Module\AppMessage\Enums\AppMessageStatus;
-use App\Module\AppMessage\Enums\AppMessageType;
-use App\Module\AppMessage\Enums\AppSenderType;
-use App\Module\AppMessage\Models\AppMessage;
-use App\Module\AppMessage\Models\AppMessageRecipient;
-use App\Module\AppMessage\Models\AppMessageTemplate;
-use App\Module\AppMessage\Queues\SendAppMessageQueue;
-use Illuminate\Support\Facades\DB;
-use Illuminate\Support\Facades\Log;
-use Illuminate\Support\Collection;
-use Carbon\Carbon;
-
-/**
- * 应用消息服务类
- *
- * 该服务类提供了消息的发送、模板管理、消息状态管理等功能
- */
-class AppMessageService
-{
-    /**
-     * 发送消息
-     *
-     * @param array $data [
-     *     'template_id' => int|null,        // 模板ID
-     *     'template_code' => string|null,   // 模板代码
-     *     'title' => string,                // 消息标题
-     *     'content' => string,              // 消息内容
-     *     'content_type' => string,         // 内容类型：text,html,markdown,json
-     *     'data' => array|null,            // 附加数据
-     *     'variables_data' => array|null,   // 模板变量数据
-     *     'sender_id' => int,              // 发送者ID
-     *     'sender_type' => string,         // 发送者类型：system,user
-     *     'receiver_id' => int|null,       // 接收者ID，为空表示群发
-     *     'receivers' => array|null,       // 群发接收者ID数组
-     *     'allow_reply' => bool,           // 是否允许回复
-     *     'parent_id' => int|null,         // 父消息ID（回复时使用）
-     * ]
-     * @return AppMessage
-     */
-    public function send(array $data): AppMessage
-    {
-        try {
-            DB::beginTransaction();
-
-            // 如果提供了模板ID或代码，则获取模板
-            if (!empty($data['template_id']) || !empty($data['template_code'])) {
-                $template = $this->getTemplate($data['template_id'] ?? null, $data['template_code'] ?? null);
-                if ($template) {
-                    $data = $this->applyTemplate($template, $data);
-                }
-            }
-
-            // 创建消息
-            $message = new AppMessage();
-            $message->type = $data['type'] ?? 'user';
-            $message->template_id = $data['template_id'] ?? null;
-            $message->template_code = $data['template_code'] ?? null;
-            $message->title = $data['title'];
-            $message->content = $data['content'];
-            $message->content_type = $data['content_type'] ?? 'text';
-            $message->data = $data['data'] ?? null;
-            $message->variables_data = $data['variables_data'] ?? null;
-            $message->sender_id = $data['sender_id'];
-            $message->sender_type = $data['sender_type'];
-            $message->receiver_id = $data['receiver_id'] ?? null;
-            $message->parent_id = $data['parent_id'] ?? null;
-            $message->allow_reply = $data['allow_reply'] ?? true;
-            $message->save();
-
-            // 处理群发
-            if (empty($message->receiver_id) && !empty($data['receivers'])) {
-                $this->sendToRecipients($message, $data['receivers']);
-            }
-
-            DB::commit();
-            return $message;
-        } catch (\Exception $e) {
-            DB::rollBack();
-            throw $e;
-        }
-    }
-
-    /**
-     * 批量发送消息
-     *
-     * @param array $messages 消息数组
-     * @return Collection
-     */
-    public function sendBatch(array $messages): Collection
-    {
-        $results = collect();
-        foreach ($messages as $data) {
-            $results->push($this->send($data));
-        }
-        return $results;
-    }
-
-    /**
-     * 获取模板
-     *
-     * @param int|null $id 模板ID
-     * @param string|null $code 模板代码
-     * @return AppMessageTemplate|null
-     */
-    public function getTemplate(?int $id = null, ?string $code = null): ?AppMessageTemplate
-    {
-        if ($id) {
-            return AppMessageTemplate::find($id);
-        }
-        if ($code) {
-            return AppMessageTemplate::where('code', $code)->first();
-        }
-        return null;
-    }
-
-    /**
-     * 应用模板
-     *
-     * @param AppMessageTemplate $template 模板
-     * @param array $data 数据
-     * @return array
-     */
-    protected function applyTemplate(AppMessageTemplate $template, array $data): array
-    {
-        $variables = $data['variables_data'] ?? [];
-        $content = $template->content;
-
-        // 替换模板变量
-        if (!empty($variables) && !empty($template->variables)) {
-            foreach ($template->variables as $key => $info) {
-                $value = $variables[$key] ?? '';
-                $content = str_replace('{{'.$key.'}}', $value, $content);
-            }
-        }
-
-        return array_merge($data, [
-            'type' => $template->type,
-            'title' => $template->title,
-            'content' => $content,
-            'content_type' => $template->content_type,
-            'allow_reply' => $template->allow_reply,
-        ]);
-    }
-
-    /**
-     * 发送给多个接收者
-     *
-     * @param AppMessage $message 消息
-     * @param array $receiverIds 接收者ID数组
-     * @return void
-     */
-    protected function sendToRecipients(AppMessage $message, array $receiverIds): void
-    {
-        $now = Carbon::now();
-        $recipients = array_map(function ($userId) use ($message, $now) {
-            return [
-                'message_id' => $message->id,
-                'user_id' => $userId,
-                'created_at' => $now,
-                'updated_at' => $now,
-            ];
-        }, array_unique($receiverIds));
-
-        AppMessageRecipient::insert($recipients);
-    }
-
-    /**
-     * 标记消息为已读
-     *
-     * @param int $messageId 消息ID
-     * @param int $userId 用户ID
-     * @return bool
-     */
-    public function markAsRead(int $messageId, int $userId): bool
-    {
-        $now = Carbon::now();
-
-        // 更新直接接收的消息
-        $message = AppMessage::where('id', $messageId)
-            ->where('receiver_id', $userId)
-            ->first();
-
-        if ($message) {
-            $message->update([
-                'is_read' => true,
-                'read_at' => $now
-            ]);
-            return true;
-        }
-
-        // 更新群发消息接收记录
-        $recipient = AppMessageRecipient::where('message_id', $messageId)
-            ->where('user_id', $userId)
-            ->first();
-
-        if ($recipient) {
-            $recipient->update([
-                'is_read' => true,
-                'read_at' => $now
-            ]);
-            return true;
-        }
-
-        return false;
-    }
-
-    /**
-     * 获取用户未读消息数量
-     *
-     * @param int $userId 用户ID
-     * @return int
-     */
-    public function getUnreadCount(int $userId): int
-    {
-        // 直接接收的未读消息
-        $directCount = AppMessage::where('receiver_id', $userId)
-            ->where('is_read', false)
-            ->where('status', 1)
-            ->count();
-
-        // 群发消息的未读数量
-        $recipientCount = AppMessageRecipient::where('user_id', $userId)
-            ->where('is_read', false)
-            ->where('status', 1)
-            ->count();
-
-        return $directCount + $recipientCount;
-    }
-
-    /**
-     * 获取用户的消息列表
-     *
-     * @param int $userId 用户ID
-     * @param array $filters 过滤条件
-     * @param int $perPage 每页数量
-     * @return \Illuminate\Pagination\LengthAwarePaginator
-     */
-    public function getUserMessages(int $userId, array $filters = [], int $perPage = 15)
-    {
-        $query = AppMessage::where(function ($query) use ($userId) {
-            $query->where('receiver_id', $userId)
-                ->orWhereExists(function ($query) use ($userId) {
-                    $query->from('app_message_recipients')
-                        ->whereColumn('app_message_recipients.message_id', 'app_messages.id')
-                        ->where('app_message_recipients.user_id', $userId)
-                        ->where('app_message_recipients.status', 1);
-                });
-        })->where('status', 1);
-
-        // 应用过滤条件
-        if (!empty($filters['type'])) {
-            $query->where('type', $filters['type']);
-        }
-        if (!empty($filters['content_type'])) {
-            $query->where('content_type', $filters['content_type']);
-        }
-        if (isset($filters['is_read'])) {
-            $query->where('is_read', $filters['is_read']);
-        }
-
-        return $query->orderBy('created_at', 'desc')->paginate($perPage);
-    }
-
-    /**
-     * 创建消息模板
-     *
-     * @param array $data 模板数据，包含以下字段：
-     *                    - name: string 模板名称
-     *                    - code: string 模板代码
-     *                    - type: string 模板类型
-     *                    - title: string 消息标题
-     *                    - content: string 消息内容
-     *                    - variables: array 模板变量
-     *                    - status: bool 模板状态
-     * @return AppMessageTemplate 返回创建的模板实例
-     */
-    public function createTemplate(array $data): AppMessageTemplate
-    {
-        return AppMessageTemplate::create($data);
-    }
-
-    /**
-     * 更新消息模板
-     *
-     * @param int $id 模板ID
-     * @param array $data 更新的模板数据，字段同createTemplate方法
-     * @return bool 更新成功返回true，失败返回false
-     */
-    public function updateTemplate(int $id, array $data): bool
-    {
-        $template = $this->getTemplate($id);
-        if (!$template) {
-            return false;
-        }
-        return $template->update($data);
-    }
-
-    /**
-     * 删除消息模板
-     *
-     * @param int $id 模板ID
-     * @return bool 删除成功返回true，失败返回false
-     */
-    public function deleteTemplate(int $id): bool
-    {
-        $template = $this->getTemplate($id);
-        if (!$template) {
-            return false;
-        }
-        return $template->delete();
-    }
-}