From b8da879cae43333925f9985160ec2baa9160f39b Mon Sep 17 00:00:00 2001
From: zj <tros-code@qq.com>
Date: Thu, 6 Aug 2026 16:18:01 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=AF=BE=E7=A8=8B?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consumers/course_service.php                  |  56 ++++++++++
 src/CourseService/CourseService.php           |  13 +++
 .../JsonRpcInterface/CourseFileInterface.php  |  42 ++++++++
 .../CourseServiceInterface.php                | 102 ++++++++++++++++++
 .../JsonRpcInterface/CourseUnitInterface.php  |  34 ++++++
 .../JsonRpcInterface/CourseVideoInterface.php |  68 ++++++++++++
 src/FileService/FileService.php               |   8 +-
 .../ExcelParseInterface.php                   |   2 +-
 .../FileServiceInterface.php                  |   2 +-
 .../QuestionParseInterface.php                |   2 +-
 .../QuestionQrCodeInterface.php               |   2 +-
 11 files changed, 323 insertions(+), 8 deletions(-)
 create mode 100644 consumers/course_service.php
 create mode 100755 src/CourseService/CourseService.php
 create mode 100644 src/CourseService/JsonRpcInterface/CourseFileInterface.php
 create mode 100755 src/CourseService/JsonRpcInterface/CourseServiceInterface.php
 create mode 100644 src/CourseService/JsonRpcInterface/CourseUnitInterface.php
 create mode 100644 src/CourseService/JsonRpcInterface/CourseVideoInterface.php
 rename src/FileService/{ => JsonRpcInterface}/ExcelParseInterface.php (79%)
 rename src/FileService/{ => JsonRpcInterface}/FileServiceInterface.php (89%)
 rename src/FileService/{ => JsonRpcInterface}/QuestionParseInterface.php (89%)
 rename src/FileService/{ => JsonRpcInterface}/QuestionQrCodeInterface.php (85%)

diff --git a/consumers/course_service.php b/consumers/course_service.php
new file mode 100644
index 0000000..962f446
--- /dev/null
+++ b/consumers/course_service.php
@@ -0,0 +1,56 @@
+<?php
+
+/**
+ * 文件服务
+ */
+
+return  [
+    // 对应消费者类的 $serviceName
+    'name' => 'CourseService',
+    // 服务接口名，可选，默认值等于 name 配置的值，如果 name 直接定义为接口类则可忽略此行配置，如 name 为字符串则需要配置 service 对应到接口类
+    'service' => \Dhd\Micro\CourseService\CourseService::class,
+    // 对应容器对象 ID，可选，默认值等于 service 配置的值，用来定义依赖注入的 key
+    // 'id' => \App\JsonRpc\File\FileServiceInterface::class,
+    // 服务提供者的服务协议，可选，默认值为 jsonrpc-http
+    // 可选 jsonrpc-http jsonrpc jsonrpc-tcp-length-check
+    'protocol' => 'jsonrpc-http',
+    // 负载均衡算法，可选，默认值为 random
+    'load_balancer' => 'random',
+    // 这个消费者要从哪个服务中心获取节点信息，如不配置则不会从服务中心获取节点信息
+    'registry' => [
+        'protocol' => env("CONSUMERS_PROTOCOL", "consul"),
+        'address' => env("CONSUMERS_ADDRESS", "http://127.0.0.1:8500"),
+    ],
+    // 'nodes' => [
+    //     ['host' => '172.18.0.2', 'port' => 9501],
+    // ],
+    // 配置项，会影响到 Packer 和 Transporter
+    'options' => [
+        'connect_timeout' => 5.0,
+        'recv_timeout' => 5.0,
+        'settings' => [
+            // 根据协议不同，区分配置
+            'open_eof_split' => true,
+            'package_eof' => "\r\n",
+            // 'open_length_check' => true,
+            // 'package_length_type' => 'N',
+            // 'package_length_offset' => 0,
+            // 'package_body_offset' => 4,
+        ],
+        // 重试次数，默认值为 2，收包超时不进行重试。暂只支持 JsonRpcPoolTransporter
+        'retry_count' => 2,
+        // 重试间隔，毫秒
+        'retry_interval' => 100,
+        // 使用多路复用 RPC 时的心跳间隔，null 为不触发心跳
+        'heartbeat' => 30,
+        // 当使用 JsonRpcPoolTransporter 时会用到以下配置
+        'pool' => [
+            'min_connections' => 1,
+            'max_connections' => 32,
+            'connect_timeout' => 10.0,
+            'wait_timeout' => 3.0,
+            'heartbeat' => -1,
+            'max_idle_time' => 60.0,
+        ],
+    ],
+];
diff --git a/src/CourseService/CourseService.php b/src/CourseService/CourseService.php
new file mode 100755
index 0000000..0745a8b
--- /dev/null
+++ b/src/CourseService/CourseService.php
@@ -0,0 +1,13 @@
+<?php
+
+/**
+ * 课程服务
+ */
+
+namespace Dhd\Micro\CourseService;
+
+interface CourseService extends
+    \Dhd\Micro\Interface\CourseService\JsonRpcInterface\CourseServiceInterface,
+    \Dhd\Micro\Interface\CourseService\JsonRpcInterface\CourseFileInterface,
+    \Dhd\Micro\Interface\CourseService\JsonRpcInterface\CourseUnitInterface,
+    \Dhd\Micro\Interface\CourseService\JsonRpcInterface\CourseVideoInterface {}
diff --git a/src/CourseService/JsonRpcInterface/CourseFileInterface.php b/src/CourseService/JsonRpcInterface/CourseFileInterface.php
new file mode 100644
index 0000000..0f018a3
--- /dev/null
+++ b/src/CourseService/JsonRpcInterface/CourseFileInterface.php
@@ -0,0 +1,42 @@
+<?php
+
+/**
+ * 课程讲义服务接口
+ */
+
+namespace Dhd\Micro\Interface\CourseService\JsonRpcInterface;
+
+interface CourseFileInterface
+{
+    /**
+     * 获取课程讲义列表
+     * @param int $courseId 课程ID
+     * @param bool $onlyShow 是否只显示显示状态的讲义
+     */
+    public function getCourseFileList(int $courseId, bool $onlyShow = false): array;
+
+    /**
+     * 新增、编辑课程讲义
+     */
+    public function editCourseFile(array $data);
+
+    /**
+     * 删除课程讲义
+     * @param int $id 课程讲义ID
+     */
+    public function deleteCourseFile(int $id);
+
+    /**
+     * 修改课程讲义显示状态
+     * @param int $id 课程讲义ID
+     * @param int $isShow 显示状态 0-不显示 1-显示
+     */
+    public function editCourseFileShow(int $id, int $isShow);
+
+    /**
+     * 修改课程讲义排序
+     * @param int $id 课程讲义ID
+     * @param int $sort 排序
+     */
+    public function editCourseFileSort(int $id, int $sort);
+}
diff --git a/src/CourseService/JsonRpcInterface/CourseServiceInterface.php b/src/CourseService/JsonRpcInterface/CourseServiceInterface.php
new file mode 100755
index 0000000..3ba18e1
--- /dev/null
+++ b/src/CourseService/JsonRpcInterface/CourseServiceInterface.php
@@ -0,0 +1,102 @@
+<?php
+
+/**
+ * 课程服务接口
+ */
+
+namespace Dhd\Micro\Interface\CourseService\JsonRpcInterface;
+
+interface CourseServiceInterface
+{
+    /**
+     * 获取课程分类列表
+     */
+    public function getCourseCategoryList(): array;
+
+    /**
+     * 编辑/创建课程分类
+     */
+    public function editCourseCategory(array $data);
+
+    /**
+     * 删除课程分类
+     * @param int $id 课程分类ID
+     */
+    public function deleteCourseCategory(int $id);
+
+    /**
+     * 后台管理获取课程列表
+     * @param array $params 查询参数
+     */
+    public function adminGetCourseList(array $params): array;
+
+    /**
+     * APP获取课程列表
+     * @param array $params 获取参数
+     */
+    public function appGetCourseList(array $params): array;
+
+    /**
+     * 获取课程详情
+     * @param int $id 课程ID
+     * @param string $platform 平台 admin-后台 app-APP
+     * @param int $userId 用户ID
+     */
+    public function getCourseDetail(int $id, string $platform = 'admin', int $userId = 0): array;
+
+    /**
+     * 新增、编辑课程
+     */
+    public function editCourse(array $data);
+
+    /**
+     * 修改课程显示状态
+     * @param int $id 课程ID
+     * @param int $isShow 显示状态 0-不显示 1-显示
+     */
+    public function editCourseShow(int $id, int $isShow);
+
+    /**
+     * 修改课程排序
+     * @param int $id 课程ID
+     * @param int $sort 排序
+     */
+    public function editCourseSort(int $id, int $sort);
+
+    /**
+     * 删除课程
+     * @param int $id 课程ID
+     */
+    public function deleteCourse(int $id);
+
+    /**
+     * 用户添加课程学习
+     * @param int $courseId 课程ID
+     * @param int $userId 用户ID
+     */
+    public function addLearnCourse(int $courseId, int $userId);
+
+    /**
+     * 验证领取码
+     * @param int $courseId 课程ID
+     * @param int $userId 用户ID
+     * @param string $inviteCode 领取码
+     * @return void
+     */
+    public function virfyInviteCode(int $courseId, int $userId, string $inviteCode);
+
+    /**
+     * 搜索课程
+     * @param string $keyword 搜索关键词
+     * @param array $params 搜索参数
+     * @return array
+     */
+    public function searchCourses(string $keyword, array $params = []): array;
+
+    /**
+     * 根据教师ID获取课程列表
+     * @param int $teacherId 教师ID
+     * @param string $platform 平台 admin-后台 app-APP
+     */
+    public function getCoursesByTeacherId(int $teacherId, string $platform = 'app'): array;
+}
diff --git a/src/CourseService/JsonRpcInterface/CourseUnitInterface.php b/src/CourseService/JsonRpcInterface/CourseUnitInterface.php
new file mode 100644
index 0000000..59da122
--- /dev/null
+++ b/src/CourseService/JsonRpcInterface/CourseUnitInterface.php
@@ -0,0 +1,34 @@
+<?php
+
+/**
+ * 课程单元、章节接口
+ */
+
+namespace Dhd\Micro\Interface\CourseService\JsonRpcInterface;
+
+interface CourseUnitInterface
+{
+
+    /**
+     * 获取课程单、章节元列表
+     * @param int $courseId 课程ID
+     */
+    public function getCourseUnitList(int $courseId): array;
+
+     /**
+     * 获取课程单、章节元详情
+     * @param int $id 课程单、章节元ID
+     */
+    public function getCourseUnitDetail(int $id): array;
+
+    /**
+     * 新增、编辑课程单、章节元
+     */
+    public function editCourseUnit(array $data);
+
+    /**
+     * 删除课程单、章节元
+     * @param int $id 课程单、章节元ID
+     */
+    public function deleteCourseUnit(int $id);
+}
diff --git a/src/CourseService/JsonRpcInterface/CourseVideoInterface.php b/src/CourseService/JsonRpcInterface/CourseVideoInterface.php
new file mode 100644
index 0000000..92a2856
--- /dev/null
+++ b/src/CourseService/JsonRpcInterface/CourseVideoInterface.php
@@ -0,0 +1,68 @@
+<?php
+
+/**
+ * 课程视频接口
+ */
+
+namespace Dhd\Micro\Interface\CourseService\JsonRpcInterface;
+
+interface CourseVideoInterface
+{
+    /**
+     * 获取课程视频列表
+     * @param int $courseId 课程ID
+     * @param string $platform 平台 admin-后台 app-APP
+     */
+    public function getVideoLists(int $courseId, string $platform = 'admin'): array;
+
+    /**
+     * 获取课程视频详情
+     * @param int $id 课程视频ID
+     * @param string $platform 平台 admin-后台 app-APP
+     */
+    public function getVideoDetail(int $id, string $platform = 'admin'): array;
+
+    /**
+     * 新增、编辑课程视频
+     * 'id',
+     * 'course_id',
+     * 'unit_id',
+     * 'cover_image',
+     * 'sort',
+     * 'title',
+     * 'video_url',
+     * 'video_size',
+     * 'video_time',
+     * 'format',
+     * 'is_show',
+     * 'main_teacher',
+     */
+    public function editVideo(array $data);
+
+    /**
+     * 删除课程视频
+     * @param int $id 课程视频ID
+     */
+    public function deleteVideo(int $id);
+
+    /**
+     * 修改课程视频排序
+     * @param int $id 课程视频ID
+     * @param int $sort 排序
+     */
+    public function editVideoSort(int $id, int $sort);
+
+    /**
+     * 课程视频显示状态
+     * @param int $id 课程视频ID
+     * @param int $isShow 显示状态 0-不显示 1-显示
+     */
+    public function editVideoShow(int $id, int $isShow);
+
+    /**
+     * 课程视频浏览量+1
+     * @param int $id 课程视频ID
+     * @param int $userId 用户ID
+     */
+    public function addVideoBrowse(int $id, int $userId);
+}
diff --git a/src/FileService/FileService.php b/src/FileService/FileService.php
index 5396cf2..95edf75 100644
--- a/src/FileService/FileService.php
+++ b/src/FileService/FileService.php
@@ -7,7 +7,7 @@
 namespace Dhd\Micro\Interface\FileService;
 
 interface FileService extends
-    \Dhd\Micro\Interface\FileService\FileServiceInterface,
-    \Dhd\Micro\Interface\FileService\QuestionParseInterface,
-    \Dhd\Micro\Interface\FileService\QuestionQrCodeInterface,
-    \Dhd\Micro\Interface\FileService\ExcelParseInterface {}
+    \Dhd\Micro\Interface\FileService\JsonRpcInterface\FileServiceInterface,
+    \Dhd\Micro\Interface\FileService\JsonRpcInterface\QuestionParseInterface,
+    \Dhd\Micro\Interface\FileService\JsonRpcInterface\QuestionQrCodeInterface,
+    \Dhd\Micro\Interface\FileService\JsonRpcInterface\ExcelParseInterface {}
diff --git a/src/FileService/ExcelParseInterface.php b/src/FileService/JsonRpcInterface/ExcelParseInterface.php
similarity index 79%
rename from src/FileService/ExcelParseInterface.php
rename to src/FileService/JsonRpcInterface/ExcelParseInterface.php
index c8168bb..45c5e58 100644
--- a/src/FileService/ExcelParseInterface.php
+++ b/src/FileService/JsonRpcInterface/ExcelParseInterface.php
@@ -4,7 +4,7 @@
  * JsonRpc服务接口
  */
 
-namespace Dhd\Micro\Interface\FileService;
+namespace Dhd\Micro\Interface\FileService\JsonRpcInterface;
 
 interface ExcelParseInterface
 {
diff --git a/src/FileService/FileServiceInterface.php b/src/FileService/JsonRpcInterface/FileServiceInterface.php
similarity index 89%
rename from src/FileService/FileServiceInterface.php
rename to src/FileService/JsonRpcInterface/FileServiceInterface.php
index 70fc25d..a83c4ed 100644
--- a/src/FileService/FileServiceInterface.php
+++ b/src/FileService/JsonRpcInterface/FileServiceInterface.php
@@ -4,7 +4,7 @@
  * JsonRpc服务接口
  */
 
-namespace Dhd\Micro\Interface\FileService;
+namespace Dhd\Micro\Interface\FileService\JsonRpcInterface;
 
 interface FileServiceInterface
 {
diff --git a/src/FileService/QuestionParseInterface.php b/src/FileService/JsonRpcInterface/QuestionParseInterface.php
similarity index 89%
rename from src/FileService/QuestionParseInterface.php
rename to src/FileService/JsonRpcInterface/QuestionParseInterface.php
index 689ee0a..ecbb519 100644
--- a/src/FileService/QuestionParseInterface.php
+++ b/src/FileService/JsonRpcInterface/QuestionParseInterface.php
@@ -4,7 +4,7 @@
  * JsonRpc服务接口
  */
 
-namespace Dhd\Micro\Interface\FileService;
+namespace Dhd\Micro\Interface\FileService\JsonRpcInterface;
 
 interface QuestionParseInterface
 {
diff --git a/src/FileService/QuestionQrCodeInterface.php b/src/FileService/JsonRpcInterface/QuestionQrCodeInterface.php
similarity index 85%
rename from src/FileService/QuestionQrCodeInterface.php
rename to src/FileService/JsonRpcInterface/QuestionQrCodeInterface.php
index da3b1c0..2e9d6a3 100644
--- a/src/FileService/QuestionQrCodeInterface.php
+++ b/src/FileService/JsonRpcInterface/QuestionQrCodeInterface.php
@@ -4,7 +4,7 @@
  * JsonRpc服务接口
  */
 
-namespace Dhd\Micro\Interface\FileService;
+namespace Dhd\Micro\Interface\FileService\JsonRpcInterface;
 
 interface QuestionQrCodeInterface
 {

From 1b3dc61f502f46f3a0481fa529673b5ae84bc5bb Mon Sep 17 00:00:00 2001
From: zj <tros-code@qq.com>
Date: Thu, 6 Aug 2026 17:10:13 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=AF=BE=E7=A8=8B?=
 =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/CourseService/CourseService.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/CourseService/CourseService.php b/src/CourseService/CourseService.php
index 0745a8b..c19f92c 100755
--- a/src/CourseService/CourseService.php
+++ b/src/CourseService/CourseService.php
@@ -4,7 +4,7 @@
  * 课程服务
  */
 
-namespace Dhd\Micro\CourseService;
+namespace Dhd\Micro\Interface\CourseService;
 
 interface CourseService extends
     \Dhd\Micro\Interface\CourseService\JsonRpcInterface\CourseServiceInterface,