From ac59397968c7190430ab68b4b2d862d6b85cb148 Mon Sep 17 00:00:00 2001
From: zj <tros-code@qq.com>
Date: Wed, 5 Aug 2026 15:45:42 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=96=87=E4=BB=B6=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1=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/ai_service.php                    |  2 -
 consumers/file_service.php                  | 56 +++++++++++++++++++++
 src/FileService/ExcelParseInterface.php     | 15 ++++++
 src/FileService/FileService.php             | 13 +++++
 src/FileService/FileServiceInterface.php    | 30 +++++++++++
 src/FileService/QuestionParseInterface.php  | 25 +++++++++
 src/FileService/QuestionQrCodeInterface.php | 19 +++++++
 7 files changed, 158 insertions(+), 2 deletions(-)
 create mode 100644 consumers/file_service.php
 create mode 100644 src/FileService/ExcelParseInterface.php
 create mode 100644 src/FileService/FileService.php
 create mode 100644 src/FileService/FileServiceInterface.php
 create mode 100644 src/FileService/QuestionParseInterface.php
 create mode 100644 src/FileService/QuestionQrCodeInterface.php

diff --git a/consumers/ai_service.php b/consumers/ai_service.php
index 31fab6d..94dce44 100644
--- a/consumers/ai_service.php
+++ b/consumers/ai_service.php
@@ -11,8 +11,6 @@ declare(strict_types=1);
  */
 use Dhd\Micro\Interface\AIService\AIService;
 
-// use function Hyperf\Support\env;
-
 return [
     // 对应消费者类的 $serviceName
     'name' => 'AIService',
diff --git a/consumers/file_service.php b/consumers/file_service.php
new file mode 100644
index 0000000..259d93c
--- /dev/null
+++ b/consumers/file_service.php
@@ -0,0 +1,56 @@
+<?php
+
+/**
+ * 文件服务
+ */
+
+return  [
+    // 对应消费者类的 $serviceName
+    'name' => 'FileService',
+    // 服务接口名，可选，默认值等于 name 配置的值，如果 name 直接定义为接口类则可忽略此行配置，如 name 为字符串则需要配置 service 对应到接口类
+    'service' => \Dhd\Micro\Interface\FileService\FileServiceInterface::class,
+    // 对应容器对象 ID，可选，默认值等于 service 配置的值，用来定义依赖注入的 key
+    // 'id' => \Dhd\Micro\Interface\FileService\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/FileService/ExcelParseInterface.php b/src/FileService/ExcelParseInterface.php
new file mode 100644
index 0000000..c8168bb
--- /dev/null
+++ b/src/FileService/ExcelParseInterface.php
@@ -0,0 +1,15 @@
+<?php
+
+/**
+ * JsonRpc服务接口
+ */
+
+namespace Dhd\Micro\Interface\FileService;
+
+interface ExcelParseInterface
+{
+    /**
+     * 解析文件
+     */
+    public function excelParse(array $header, string $highestColumn, int $fileId, int $page = 1, int $limit = 1000): array;
+}
diff --git a/src/FileService/FileService.php b/src/FileService/FileService.php
new file mode 100644
index 0000000..badd99e
--- /dev/null
+++ b/src/FileService/FileService.php
@@ -0,0 +1,13 @@
+<?php
+
+/**
+ * 文件服务
+ */
+
+namespace Dhd\Micro\Interface\FileService;
+
+interface FileService extends
+    FileServiceInterface,
+    QuestionParseInterface,
+    QuestionQrCodeInterface,
+    ExcelParseInterface {}
diff --git a/src/FileService/FileServiceInterface.php b/src/FileService/FileServiceInterface.php
new file mode 100644
index 0000000..70fc25d
--- /dev/null
+++ b/src/FileService/FileServiceInterface.php
@@ -0,0 +1,30 @@
+<?php
+
+/**
+ * JsonRpc服务接口
+ */
+
+namespace Dhd\Micro\Interface\FileService;
+
+interface FileServiceInterface
+{
+    /**
+     * 获取文件分组列表
+     */
+    public function getFileGroupList(): array;
+
+    /**
+     * 添加/编辑文件分组
+     */
+    public function editFileGroup(int $groupId, int $pid, string $groupName): array;
+
+    /**
+     * 删除文件分组
+     */
+    public function deleteFileGroup(int $groupId): array;
+
+    /**
+     * 获取文件列表
+     */
+    public function getFileList(array $params): array;
+}
diff --git a/src/FileService/QuestionParseInterface.php b/src/FileService/QuestionParseInterface.php
new file mode 100644
index 0000000..689ee0a
--- /dev/null
+++ b/src/FileService/QuestionParseInterface.php
@@ -0,0 +1,25 @@
+<?php
+
+/**
+ * JsonRpc服务接口
+ */
+
+namespace Dhd\Micro\Interface\FileService;
+
+interface QuestionParseInterface
+{
+    /**
+     * 解析文件
+     */
+    public function questionWordParse(int $fileId): array;
+
+    /**
+     * 根据code确认导入题目，设置submit_save为1，且移动图片到$this->imageDir目录，变更图片路径
+     */
+    public function submitSaveByCode(string $code): array;
+
+    /**
+     * 读取解析暂存数据，不确认导入且不移动图片。
+     */
+    public function getQuestionParseByCode(string $code): array;
+}
diff --git a/src/FileService/QuestionQrCodeInterface.php b/src/FileService/QuestionQrCodeInterface.php
new file mode 100644
index 0000000..da3b1c0
--- /dev/null
+++ b/src/FileService/QuestionQrCodeInterface.php
@@ -0,0 +1,19 @@
+<?php
+
+/**
+ * JsonRpc服务接口
+ */
+
+namespace Dhd\Micro\Interface\FileService;
+
+interface QuestionQrCodeInterface
+{
+    /**
+     * 生成题目、试卷二维码
+     * @param int $type 二维码类型
+     * @param int $id 记录ID
+     * @param array $data 额外参数
+     * @return array
+     */
+    public function createQuestionQr(int $type, int $id, array $data): array;
+}