diff --git a/docs/CloudStrm.md b/docs/CloudStrm.md
index 1f43af0..b8c2b2d 100644
--- a/docs/CloudStrm.md
+++ b/docs/CloudStrm.md
@@ -2,6 +2,7 @@
 
 ### 更新记录
 
+- 3.4 交互命令
 - 3.3 fix bug
 - 3.2 fix bug
 - 3.1 注册交互命令、注册公共服务
diff --git a/package.json b/package.json
index 229d7a4..265ba9b 100644
--- a/package.json
+++ b/package.json
@@ -2,7 +2,7 @@
       "CloudStrm": {
         "name": "云盘Strm生成",
         "description": "监控文件创建，生成Strm文件。",
-        "version": "3.3",
+        "version": "3.4",
         "icon": "https://raw.githubusercontent.com/thsrite/MoviePilot-Plugins/main/icons/create.png",
         "author": "thsrite",
         "level": 1
diff --git a/plugins/cloudstrm/__init__.py b/plugins/cloudstrm/__init__.py
index 79b7dec..c3f8a82 100644
--- a/plugins/cloudstrm/__init__.py
+++ b/plugins/cloudstrm/__init__.py
@@ -8,6 +8,7 @@ from pathlib import Path
 import pytz
 from typing import Any, List, Dict, Tuple, Optional
 
+from app.core.event import eventmanager, Event
 from app.schemas.types import EventType
 from apscheduler.schedulers.background import BackgroundScheduler
 from apscheduler.triggers.cron import CronTrigger
@@ -25,7 +26,7 @@ class CloudStrm(_PluginBase):
     # 插件图标
     plugin_icon = "https://raw.githubusercontent.com/thsrite/MoviePilot-Plugins/main/icons/create.png"
     # 插件版本
-    plugin_version = "3.3"
+    plugin_version = "3.4"
     # 插件作者
     plugin_author = "thsrite"
     # 作者主页
@@ -147,7 +148,8 @@ class CloudStrm(_PluginBase):
                 self._scheduler.print_jobs()
                 self._scheduler.start()
 
-    def __scan(self):
+    @eventmanager.register(EventType.PluginAction)
+    def __scan(self, event: Event):
         """
         扫描
         """
@@ -158,6 +160,15 @@ class CloudStrm(_PluginBase):
             logger.error("未获取到可用目录监控配置，请检查")
             return
 
+        if event:
+            event_data = event.event_data
+            if not event_data or event_data.get("action") != "cloud_strm":
+                return
+            logger.info("收到命令，开始云盘strm生成 ...")
+            self.post_message(channel=event.event_data.get("channel"),
+                              title="开始云盘strm生成 ...",
+                              userid=event.event_data.get("user"))
+
         logger.info("云盘strm生成任务开始")
         # 首次扫描或者重建索引
         __init_flag = False
@@ -217,6 +228,10 @@ class CloudStrm(_PluginBase):
                 self.__sava_json()
 
         logger.info("云盘strm生成任务完成")
+        if event:
+            self.post_message(channel=event.event_data.get("channel"),
+                              title="云盘strm生成任务完成！",
+                              userid=event.event_data.get("user"))
 
     def __init_cloud_files_json(self):
         """