diff --git a/backend/design/db_schema_pgsql.sql b/backend/design/db_schema_pgsql.sql index 455112f..2929ec3 100644 --- a/backend/design/db_schema_pgsql.sql +++ b/backend/design/db_schema_pgsql.sql @@ -55,6 +55,7 @@ CREATE TABLE sys_user ( user_id BIGSERIAL PRIMARY KEY, username VARCHAR(50) NOT NULL UNIQUE, display_name VARCHAR(50) NOT NULL, + avatar_url VARCHAR(500), email VARCHAR(100), phone VARCHAR(30) UNIQUE, password_hash VARCHAR(255) NOT NULL, @@ -75,6 +76,7 @@ CREATE TABLE sys_role ( tenant_id BIGINT NOT NULL, role_code VARCHAR(50) NOT NULL, role_name VARCHAR(50) NOT NULL, + data_scope_type VARCHAR(32) NOT NULL DEFAULT 'SELF', status SMALLINT NOT NULL DEFAULT 1, remark TEXT, is_deleted SMALLINT NOT NULL DEFAULT 0, @@ -85,6 +87,19 @@ CREATE TABLE sys_role ( CREATE INDEX idx_sys_role_tenant ON sys_role (tenant_id); CREATE INDEX uk_role_code ON sys_role (tenant_id, role_code) WHERE is_deleted = 0; +DROP TABLE IF EXISTS sys_role_data_scope_org CASCADE; + +CREATE TABLE sys_role_data_scope_org ( + id BIGSERIAL PRIMARY KEY, + role_id BIGINT NOT NULL, + org_id BIGINT NOT NULL, + created_at TIMESTAMP(6) NOT NULL DEFAULT now(), + updated_at TIMESTAMP(6) NOT NULL DEFAULT now() +); + +CREATE INDEX idx_role_data_scope_role_id ON sys_role_data_scope_org (role_id); +CREATE INDEX idx_role_data_scope_org_id ON sys_role_data_scope_org (org_id); + -- 用户-角色关联表 (按 tenant_id 强约束，避免跨租户角色污染) DROP TABLE IF EXISTS sys_user_role CASCADE; @@ -188,6 +203,28 @@ CREATE TABLE sys_role_permission ( "created_at" timestamp(6) NOT NULL DEFAULT now(), "updated_at" timestamp(6) NOT NULL DEFAULT now() ); + +DROP TABLE IF EXISTS sys_bot_credential CASCADE; + +CREATE TABLE sys_bot_credential ( + id BIGSERIAL PRIMARY KEY, + bot_id VARCHAR(64) NOT NULL, + secret_hash VARCHAR(64) NOT NULL, + secret_salt VARCHAR(32), + user_id BIGINT NOT NULL, + status CHAR(1) NOT NULL DEFAULT '0', + expire_time TIMESTAMP(6), + last_access_time TIMESTAMP(6), + last_access_ip VARCHAR(128), + remark VARCHAR(500), + create_by VARCHAR(64), + create_time TIMESTAMP(6) NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_by VARCHAR(64), + update_time TIMESTAMP(6) NOT NULL DEFAULT CURRENT_TIMESTAMP +); + +CREATE UNIQUE INDEX uk_sys_bot_credential_bot_id ON sys_bot_credential (bot_id); +CREATE INDEX idx_sys_bot_credential_user_id ON sys_bot_credential (user_id); -- ---------------------------- -- 3. 日志 (租户隔离) -- ---------------------------- @@ -197,7 +234,10 @@ CREATE TABLE sys_log ( tenant_id BIGINT NOT NULL DEFAULT 0, user_id BIGINT, username VARCHAR(50), + source_system VARCHAR(64), log_type VARCHAR(20), -- LOGIN, OPERATION + module_name VARCHAR(100), + action_name VARCHAR(100), operation VARCHAR(100) NOT NULL, method VARCHAR(200), params TEXT, @@ -207,6 +247,9 @@ CREATE TABLE sys_log ( created_at TIMESTAMP NOT NULL DEFAULT NOW() ); CREATE INDEX idx_log_tenant_type ON sys_log (tenant_id, log_type, created_at); +CREATE INDEX idx_log_tenant_type_module_time ON sys_log (tenant_id, log_type, module_name, created_at); +CREATE INDEX idx_log_tenant_type_user_time ON sys_log (tenant_id, log_type, username, created_at); +CREATE INDEX idx_log_tenant_type_source_time ON sys_log (tenant_id, log_type, source_system, created_at); -- ---------------------------- -- 4. 平台配置 (系统品牌化) @@ -226,8 +269,7 @@ CREATE TABLE sys_platform_config ( is_deleted SMALLINT DEFAULT 0 ); -INSERT INTO sys_platform_config (id, project_name, copyright_info) -VALUES (1, 'iMeeting 智能会议系统', '© 2026 iMeeting Team. All rights reserved.'); + -- ---------------------------- -- 6. 业务模块 - 声纹管理 @@ -407,7 +449,12 @@ CREATE TABLE biz_meetings ( meeting_source VARCHAR(32), -- WEB / ANDROID creator_id BIGINT, -- 发起人ID creator_name VARCHAR(100), -- 发起人姓名 + host_user_id BIGINT, -- 主持人用户ID + host_name VARCHAR(100), -- 主持人展示名称 + access_password VARCHAR(128), -- 兼容旧版安卓预览访问的会议访问密码 latest_summary_task_id BIGINT, -- 最新成功总结任务ID + audio_save_status VARCHAR(20) DEFAULT 'NONE', -- 实时音频保存状态：NONE/SUCCESS/FAILED + audio_save_message VARCHAR(500), -- 实时音频保存失败提示信息 status SMALLINT DEFAULT 0, -- 0:待处理, 1:处理中, 2:成功, 3:失败 created_at TIMESTAMP(6) NOT NULL DEFAULT now(), updated_at TIMESTAMP(6) NOT NULL DEFAULT now(), @@ -468,130 +515,68 @@ CREATE TABLE "biz_prompt_template_user_config" ( "is_deleted" int2 NOT NULL DEFAULT 0 ); +-- ---------------------------- +-- 13. 业务模块 - 旧版安卓兼容 +-- ---------------------------- +DROP TABLE IF EXISTS biz_client_downloads CASCADE; +CREATE TABLE biz_client_downloads ( + id BIGSERIAL PRIMARY KEY, + tenant_id BIGINT NOT NULL DEFAULT 0, + platform_type VARCHAR(32), -- 平台类型 + platform_name VARCHAR(64), -- 平台显示名称 + platform_code VARCHAR(64) NOT NULL, -- 平台编码，如 android / ios / windows + version VARCHAR(64) NOT NULL, -- 版本名称 + version_code BIGINT, -- 版本号 + download_url VARCHAR(512) NOT NULL, -- 下载地址 + file_size BIGINT, -- 文件大小 + release_notes TEXT, -- 发布说明 + is_latest SMALLINT NOT NULL DEFAULT 0, -- 是否当前平台最新版本：1-是，0-否 + min_system_version VARCHAR(64), -- 最低系统版本要求 + created_by BIGINT, -- 创建人 + status SMALLINT NOT NULL DEFAULT 1, -- 状态 + remark VARCHAR(255), -- 备注 + created_at TIMESTAMP(6) NOT NULL DEFAULT now(), + updated_at TIMESTAMP(6) NOT NULL DEFAULT now(), + is_deleted SMALLINT NOT NULL DEFAULT 0 +); + +CREATE INDEX idx_client_downloads_platform_code + ON biz_client_downloads (platform_code); + +CREATE INDEX idx_client_downloads_latest + ON biz_client_downloads (platform_code, is_latest) + WHERE is_deleted = 0; + +COMMENT ON TABLE biz_client_downloads IS '旧版安卓客户端版本兼容表'; + +DROP TABLE IF EXISTS biz_external_apps CASCADE; +CREATE TABLE biz_external_apps ( + id BIGSERIAL PRIMARY KEY, + tenant_id BIGINT NOT NULL DEFAULT 0, + app_name VARCHAR(128) NOT NULL, -- 应用名称 + app_type VARCHAR(32) NOT NULL, -- 应用类型：native / web + app_info JSONB, -- 应用附加信息，如 web_url / package_name / apk_url + icon_url VARCHAR(512), -- 图标地址 + description VARCHAR(255), -- 描述 + sort_order INTEGER NOT NULL DEFAULT 0, -- 排序值 + created_by BIGINT, -- 创建人 + status SMALLINT NOT NULL DEFAULT 1, -- 状态 + remark VARCHAR(255), -- 备注 + created_at TIMESTAMP(6) NOT NULL DEFAULT now(), + updated_at TIMESTAMP(6) NOT NULL DEFAULT now(), + is_deleted SMALLINT NOT NULL DEFAULT 0 +); + +CREATE INDEX idx_external_apps_status_sort + ON biz_external_apps (status, sort_order); + +COMMENT ON TABLE biz_external_apps IS '旧版安卓首页外部应用兼容表'; + -- ---------------------------- -- 5. 基础初始化数据 -- ---------------------------- --- 字典初始化数据 --- sys_common_status -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_common_status', '通用状态', '0=禁用, 1=启用'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_common_status', '启用', '1', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_common_status', '禁用', '0', 2); - --- sys_permission_type -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_permission_type', '权限类型', 'directory=目录, menu=菜单, button=按钮'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_type', '目录', 'directory', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_type', '菜单', 'menu', 2); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_type', '按钮', 'button', 3); - --- sys_common_visibility -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_common_visibility', '可见性', '0=隐藏, 1=显示'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_common_visibility', '显示', '1', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_common_visibility', '隐藏', '0', 2); - --- sys_permission_level -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_permission_level', '权限层级', '1=一级入口, 2=二级子项, 3=三级按钮'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_level', '一级入口', '1', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_level', '二级子项', '2', 2); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_permission_level', '三级按钮', '3', 3); - --- sys_log_type -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_log_type', '日志类型', 'LOGIN=登录, OPERATION=操作'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_log_type', '登录', 'LOGIN', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_log_type', '操作', 'OPERATION', 2); - --- sys_param_type -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_param_type', '参数类型', 'String, Number, Boolean, JSON'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_param_type', 'String', 'String', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_param_type', 'Number', 'Number', 2); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_param_type', 'Boolean', 'Boolean', 3); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_param_type', 'JSON', 'JSON', 4); - --- sys_log_status -INSERT INTO sys_dict_type (type_code, type_name, remark) VALUES ('sys_log_status', '操作状态', '1=成功, 0=失败'); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_log_status', '成功', '1', 1); -INSERT INTO sys_dict_item (type_code, item_label, item_value, sort_order) VALUES ('sys_log_status', '失败', '0', 2); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (21, 18, '查询租户', 'sys_tenant:query', 'button', 3, NULL, NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.647439', '2026-02-25 10:09:32.647439'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (28, 19, '删除组织', 'sys:org:delete', 'button', 3, NULL, NULL, NULL, 4, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.65871', '2026-02-25 10:09:32.65871'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (22, 18, '新增租户', 'sys_tenant:create', 'button', 3, NULL, NULL, NULL, 2, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.647439', '2026-02-25 10:09:32.647439'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (23, 18, '修改租户', 'sys_tenant:update', 'button', 3, NULL, NULL, NULL, 3, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.647439', '2026-02-25 10:09:32.647439'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (24, 18, '删除租户', 'sys_tenant:delete', 'button', 3, NULL, NULL, NULL, 4, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.647439', '2026-02-25 10:09:32.647439'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (48, 3, '权限查询', 'sys:permission:list', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 16:07:04.002702', '2026-02-26 16:07:04.003701'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (13, 12, '角色权限', 'menu:role:permission', 'menu', 2, '/role-permissions', NULL, NULL, 0, 1, 1, NULL, NULL, 1, '2026-02-10 18:01:32.999774', '2026-02-11 09:41:31.952294'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (39, 12, '平台管理', 'platform', 'menu', 2, '/platform-settings', NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 14:54:49.406968', '2026-02-26 14:54:49.407968'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (25, 19, '查询组织', 'sys:org:query', 'button', 3, NULL, NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.65871', '2026-02-25 10:09:32.65871'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (26, 19, '新增组织', 'sys:org:create', 'button', 3, NULL, NULL, NULL, 2, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.65871', '2026-02-25 10:09:32.65871'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (27, 19, '修改组织', 'sys:org:update', 'button', 3, NULL, NULL, NULL, 3, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.65871', '2026-02-25 10:09:32.65871'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (3, 12, '角色管理', 'sys:role:list', 'menu', 2, '/roles', NULL, NULL, 3, 1, 1, '角色管理菜单', NULL, 0, '2026-02-10 07:24:30.148186', '2026-02-10 17:24:07.484806'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (40, 3, '角色查询', 'sys:role:query', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:35:35.692367', '2026-02-26 15:35:35.693366'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (41, 3, '角色创建', 'sys:role:create', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:35:50.081581', '2026-02-26 15:35:50.081581'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (42, 3, '角色更新', 'sys:role:update', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:36:03.385343', '2026-02-26 15:36:03.385343'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (43, 3, '角色删除', 'sys:role:delete', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:36:20.451039', '2026-02-26 15:36:20.451039'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (44, 3, '角色权限列表', 'sys:role:permission:list', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:36:39.902216', '2026-02-26 15:36:39.902216'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (45, 3, '角色权限更新', 'sys:role:permission:save', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:36:53.595974', '2026-02-26 15:36:53.595974'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (2, 12, '用户管理', 'sys:user:list', 'menu', 2, '/users', NULL, NULL, 2, 1, 1, '用户管理菜单', NULL, 0, '2026-02-10 07:24:30.148186', '2026-02-26 15:43:21.037142'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (29, 2, '查询用户', 'sys:user:query', 'button', 3, NULL, NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.669947', '2026-02-25 10:09:32.669947'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (30, 2, '新增用户', 'sys:user:create', 'button', 3, NULL, NULL, NULL, 2, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.669947', '2026-02-25 10:09:32.669947'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (31, 2, '修改用户', 'sys:user:update', 'button', 3, NULL, NULL, NULL, 3, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.669947', '2026-02-25 10:09:32.669947'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (32, 2, '删除用户', 'sys:user:delete', 'button', 3, NULL, NULL, NULL, 4, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.669947', '2026-02-25 10:09:32.669947'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (33, 2, '分配角色', 'sys:user:role:save', 'button', 3, NULL, NULL, NULL, 5, 1, 1, NULL, NULL, 0, '2026-02-25 10:09:32.669947', '2026-02-25 10:09:32.669947'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (46, 2, '用户角色查询', 'sys:user:role:list', 'button', 3, NULL, NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-02-26 15:45:14.890567', '2026-02-26 15:45:28.553231'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (54, NULL, '热词管理', 'menu:hotword', 'menu', 1, '/hotwords', NULL, 'hotword', 11, 1, 1, NULL, NULL, 0, '2026-02-28 16:51:49.158997', '2026-02-28 16:51:49.158997'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (55, NULL, '总结模板', 'menu:prompt', 'menu', 1, '/prompts', NULL, 'prompt', 12, 1, 1, NULL, NULL, 0, '2026-02-28 17:47:51.015282', '2026-02-28 17:47:51.015282'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (56, NULL, '模型配置', 'menu:aimodel', 'menu', 1, '/aimodels', NULL, 'aimodel', 13, 1, 1, NULL, NULL, 0, '2026-03-02 09:48:27.179055', '2026-03-02 09:48:27.179055'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (57, NULL, '会议中心', 'menu:meeting', 'menu', 1, '/meetings', NULL, 'meeting', 20, 1, 1, NULL, NULL, 0, '2026-03-02 11:02:58.089065', '2026-03-02 11:02:58.089065'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (52, NULL, '测试菜单', 'test', 'directory', 1, '/role-permissions', NULL, NULL, 0, 1, 1, NULL, NULL, 1, '2026-02-27 10:39:04.576329', '2026-03-03 10:03:45.999369'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (59, NULL, '声纹注册', 'speaker', 'menu', 1, '/speaker-reg', NULL, NULL, 0, 1, 1, NULL, NULL, 0, '2026-03-06 15:23:09.314321', '2026-03-06 15:23:51.715481'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (18, 12, '租户管理', 'menu:tenant', 'menu', 2, '/tenants', NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-12 14:06:13.672548', '2026-03-06 16:31:45.006699'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (58, NULL, '发起会议', 'menu:meeting:create', 'menu', 1, '/meeting-create', NULL, 'audio', 19, 1, 1, NULL, NULL, 1, '2026-03-02 16:21:47.326202', '2026-03-05 09:05:49.301092'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (4, 12, '菜单管理', 'sys:permission:list', 'menu', 2, '/permissions', NULL, NULL, 4, 1, 1, '权限管理菜单', NULL, 0, '2026-02-10 07:24:30.148186', '2026-03-05 17:10:30.891258'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (5, 12, '设备管理', 'menu:devices', 'menu', 2, '/devices', NULL, NULL, 5, 0, 1, '设备管理菜单', NULL, 0, '2026-02-10 07:24:30.148186', '2026-03-05 17:11:48.867451'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (15, 12, '字典管理', 'menu:dict', 'menu', 2, '/dictionaries', NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-11 13:54:56.100838', '2026-03-05 17:12:28.223844'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (17, 12, '日志管理', 'menu:log', 'menu', 2, '/logs', NULL, NULL, 1, 1, 1, NULL, NULL, 0, '2026-02-12 09:49:02.814427', '2026-03-05 17:12:57.94561'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (38, 12, '参数管理', 'params', 'menu', 2, '/params', NULL, NULL, 2, 1, 1, NULL, NULL, 0, '2026-02-26 14:34:16.903552', '2026-03-06 16:31:51.714937'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (1, NULL, '任务监控', 'menu:dashboard', 'menu', 1, '/', NULL, NULL, 1, 1, 1, 'Dashboard 菜单', NULL, 0, '2026-02-10 07:24:30.148186', '2026-03-05 18:01:31.515477'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (19, 12, '组织管理', 'sys:org:list', 'menu', 2, '/orgs', NULL, NULL, 3, 1, 1, NULL, NULL, 0, '2026-02-12 14:09:01.818807', '2026-03-06 16:32:00.114277'); -INSERT INTO "sys_permission" ("perm_id", "parent_id", "name", "code", "perm_type", "level", "path", "component", "icon", "sort_order", "is_visible", "status", "description", "meta", "is_deleted", "created_at", "updated_at") VALUES (12, NULL, '系统管理', 'system', 'directory', 1, NULL, NULL, NULL, 110, 1, 1, NULL, NULL, 0, '2026-02-10 17:23:52.877017', '2026-03-06 14:00:20.182181'); - - -INSERT INTO sys_param ("param_id", "param_key", "param_value", "param_type", "status", "is_system", "description", "is_deleted", "created_at", "updated_at") VALUES (2, 'security.token.refresh_ttl_days', '7', 'int', 1, 1, 'Refresh Token 有效期(天)', 0, '2026-02-09 09:54:21.893832', '2026-02-09 09:54:21.893832'); -INSERT INTO sys_param ("param_id", "param_key", "param_value", "param_type", "status", "is_system", "description", "is_deleted", "created_at", "updated_at") VALUES (4, 'tenant.init.default.menu.codes', 'sys:user:list,sys:user:create,sys:user:query,sys:role:create,sys:user:role:save,sys:org:delete,sys:org:query,sys:role:permission:list,sys:org:update,sys:role:permission:save,sys:role:update,system,sys:user:delete,sys:user:role:list,sys:org:list,sys:role:delete,sys:role:list,sys:org:create,sys:user:update,sys:permission:list,sys:role:query', 'String', 1, 1, '新建租户时角色权限', 0, '2026-02-26 16:46:20.392789', '2026-02-26 16:46:38.137264'); -INSERT INTO sys_param ("param_id", "param_key", "param_value", "param_type", "status", "is_system", "description", "is_deleted", "created_at", "updated_at") VALUES (5, 'tenant.init.default.password', '123456', 'String', 1, 1, NULL, 0, '2026-02-26 16:46:52.124755', '2026-02-26 16:46:52.124755'); -INSERT INTO sys_param ("param_id", "param_key", "param_value", "param_type", "status", "is_system", "description", "is_deleted", "created_at", "updated_at") VALUES (3, 'security.captcha.enabled', 'false', 'boolean', 1, 1, '是否开启验证码', 0, '2026-02-11 02:45:31.097324', '2026-03-10 09:40:33.084368'); -INSERT INTO sys_param ("param_id", "param_key", "param_value", "param_type", "status", "is_system", "description", "is_deleted", "created_at", "updated_at") VALUES (1, 'security.token.access_ttl_minutes', '120', 'int', 1, 1, 'Access Token 有效期(分钟)', 0, '2026-02-09 09:54:21.888052', '2026-03-10 10:15:39.55035'); - - -INSERT INTO sys_user ( "username", "display_name", "email", "phone", "password_hash", "status", "is_deleted", "created_at", "updated_at", "is_platform_admin", "pwd_reset_required") -VALUES ( 'admin', '管理员', 'admin', NULL, '$2a$10$BOm1iCFj3ObfBeyQxOvjVO659vXvIRGOd4YR62r0TUHqSusWW5bFS', 1, 0, '2026-02-09 09:54:21.880637', '2026-02-28 17:57:32.63338', 't', NULL); - - -INSERT INTO "sys_dict_type" ("dict_type_id", "type_code", "type_name", "status", "remark", "created_at", "updated_at") VALUES (9, 'biz_hotword_category', '热词类别', 1, '语音识别纠错分类', '2026-02-28 17:08:52.362532', '2026-02-28 17:08:52.362532'); -INSERT INTO "sys_dict_type" ("dict_type_id", "type_code", "type_name", "status", "remark", "created_at", "updated_at") VALUES (10, 'biz_prompt_category', '提示词分类', 1, '会议总结模板分类', '2026-02-28 17:47:50.999655', '2026-02-28 17:47:50.999655'); -INSERT INTO "sys_dict_type" ("dict_type_id", "type_code", "type_name", "status", "remark", "created_at", "updated_at") VALUES (11, 'biz_ai_provider', '模型提供商', 1, 'AI 模型服务商分类', '2026-03-02 10:10:16.653182', '2026-03-02 10:10:16.653182'); -INSERT INTO "sys_dict_type" ("dict_type_id", "type_code", "type_name", "status", "remark", "created_at", "updated_at") VALUES (12, 'biz_speaker_label', '发言人角色', 1, '会议发言人的身份标签', '2026-03-02 16:15:58.193117', '2026-03-02 16:15:58.193117'); -INSERT INTO "sys_dict_type" ("dict_type_id", "type_code", "type_name", "status", "remark", "created_at", "updated_at") VALUES (13, 'biz_prompt_level', '提示词模板属性', 1, '用于定义提示词模板的层级属性：1-预置模板（系统或租户级），0-个人模板', '2026-03-04 10:54:30.49116', '2026-03-04 10:54:30.49116'); - -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (22, 'biz_hotword_category', '人名', 'person', 1, 1, NULL, '2026-02-28 17:08:52.374667', '2026-02-28 17:08:52.374667'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (23, 'biz_hotword_category', '术语', 'term', 2, 1, NULL, '2026-02-28 17:08:52.374667', '2026-02-28 17:08:52.374667'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (24, 'biz_hotword_category', '地名', 'location', 3, 1, NULL, '2026-02-28 17:08:52.374667', '2026-02-28 17:08:52.374667'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (25, 'biz_hotword_category', '通用', 'general', 4, 1, NULL, '2026-02-28 17:08:52.374667', '2026-02-28 17:08:52.374667'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (26, 'biz_prompt_category', '全文纪要', 'summary', 1, 1, NULL, '2026-02-28 17:47:51.013288', '2026-02-28 17:47:51.013288'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (27, 'biz_prompt_category', '待办提取', 'todo', 2, 1, NULL, '2026-02-28 17:47:51.013288', '2026-02-28 17:47:51.013288'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (28, 'biz_prompt_category', '访谈整理', 'interview', 3, 1, NULL, '2026-02-28 17:47:51.013288', '2026-02-28 17:47:51.013288'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (29, 'biz_prompt_category', '创意构思', 'creative', 4, 1, NULL, '2026-02-28 17:47:51.013288', '2026-02-28 17:47:51.013288'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (30, 'biz_ai_provider', '阿里云', 'Aliyun', 1, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (31, 'biz_ai_provider', 'OpenAI', 'OpenAI', 2, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (32, 'biz_ai_provider', 'Gemini', 'Gemini', 3, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (33, 'biz_ai_provider', 'DeepSeek', 'DeepSeek', 4, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (34, 'biz_ai_provider', 'Kimi', 'Kimi', 5, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (35, 'biz_ai_provider', '自定义/本地', 'Custom', 6, 1, NULL, '2026-03-02 10:10:16.665646', '2026-03-02 10:10:16.665646'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (36, 'biz_speaker_label', '主持人', 'host', 1, 1, NULL, '2026-03-02 16:15:58.205277', '2026-03-02 16:15:58.205277'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (37, 'biz_speaker_label', '汇报人', 'speaker', 2, 1, NULL, '2026-03-02 16:15:58.205277', '2026-03-02 16:15:58.205277'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (38, 'biz_speaker_label', '技术专家', 'expert', 3, 1, NULL, '2026-03-02 16:15:58.205277', '2026-03-02 16:15:58.205277'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (39, 'biz_speaker_label', '客户代表', 'customer', 4, 1, NULL, '2026-03-02 16:15:58.205277', '2026-03-02 16:15:58.205277'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (40, 'biz_prompt_level', '预置模板', '1', 1, 1, '平台系统预置或租户共享预置', '2026-03-04 10:55:42.163768', '2026-03-04 10:55:42.163768'); -INSERT INTO "sys_dict_item" ("dict_item_id", "type_code", "item_label", "item_value", "sort_order", "status", "remark", "created_at", "updated_at") VALUES (41, 'biz_prompt_level', '个人模板', '0', 2, 1, '个人私有模板', '2026-03-04 10:55:42.175269', '2026-03-04 10:55:42.175269'); -- ---------------------------- -- 6. 屏保模块 diff --git a/backend/src/main/resources/application-test.yml b/backend/src/main/resources/application-test.yml index 2c35f57..d952ec7 100644 --- a/backend/src/main/resources/application-test.yml +++ b/backend/src/main/resources/application-test.yml @@ -23,5 +23,5 @@ unisbase: internal-auth: secret: ${INTERNAL_AUTH_SECRET:change-me-test-internal-secret} app: - server-base-url: ${APP_SERVER_BASE_URL:http://127.0.0.1:${server.port}} - upload-path: ${APP_UPLOAD_PATH:D:/data/imeeting-test/uploads/} \ No newline at end of file + server-base-url: ${APP_SERVER_BASE_URL:http://10.100.53.199:${server.port}} + upload-path: ${APP_UPLOAD_PATH:D:/data/imeeting-test/uploads/} diff --git a/backend/src/main/resources/application.yml b/backend/src/main/resources/application.yml index ababc0d..c746815 100644 --- a/backend/src/main/resources/application.yml +++ b/backend/src/main/resources/application.yml @@ -63,6 +63,7 @@ unisbase: - /api/public/meetings/** - /api/android/auth/login - /api/android/auth/refresh + - /api/clients/latest/by-platform - /api/android/screensavers/active - /api/screensavers/active - /v3/api-docs/** diff --git a/backend/src/test/java/com/imeeting/service/android/legacy/LegacyMeetingAdapterServiceImplTest.java b/backend/src/test/java/com/imeeting/service/android/legacy/LegacyMeetingAdapterServiceImplTest.java index 79e5f35..0415979 100644 --- a/backend/src/test/java/com/imeeting/service/android/legacy/LegacyMeetingAdapterServiceImplTest.java +++ b/backend/src/test/java/com/imeeting/service/android/legacy/LegacyMeetingAdapterServiceImplTest.java @@ -1,90 +1,90 @@ -package com.imeeting.service.android.legacy; - -import com.imeeting.dto.android.legacy.LegacyMeetingCreateRequest; -import com.imeeting.dto.biz.MeetingVO; -import com.imeeting.entity.biz.Meeting; -import com.imeeting.mapper.biz.LlmModelMapper; -import com.imeeting.mapper.biz.MeetingTranscriptMapper; -import com.imeeting.service.android.legacy.impl.LegacyMeetingAdapterServiceImpl; -import com.imeeting.service.biz.AiTaskService; -import com.imeeting.service.biz.MeetingAccessService; -import com.imeeting.service.biz.MeetingRuntimeProfileResolver; -import com.imeeting.service.biz.MeetingService; -import com.imeeting.service.biz.PromptTemplateService; -import com.imeeting.service.biz.impl.MeetingAudioUploadSupport; -import com.imeeting.service.biz.impl.MeetingDomainSupport; -import com.imeeting.service.biz.impl.MeetingSummaryPromptAssembler; -import com.unisbase.security.LoginUser; -import org.junit.jupiter.api.Test; -import org.mockito.ArgumentCaptor; - -import java.time.LocalDateTime; -import java.util.List; -import java.util.Set; - -import static org.junit.jupiter.api.Assertions.assertEquals; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.ArgumentMatchers.isNull; -import static org.mockito.Mockito.doAnswer; -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; - -class LegacyMeetingAdapterServiceImplTest { - - @Test - void createMeetingShouldIgnoreLegacyUserIdAndParseOffsetTime() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - Meeting meeting = new Meeting(); - meeting.setId(9001L); - - when(meetingDomainSupport.initMeeting( - eq("旧端会议"), - eq(LocalDateTime.of(2025, 11, 17, 9, 30)), - eq("2,3"), - eq("alpha,beta"), - isNull(), - eq(10L), - eq(7L), - eq("creator"), - eq(7L), - eq("creator"), - eq(0) - )).thenReturn(meeting); - doAnswer(invocation -> { - MeetingVO vo = invocation.getArgument(1); - vo.setId(9001L); - return null; - }).when(meetingDomainSupport).fillMeetingVO(any(Meeting.class), any(MeetingVO.class), eq(false)); - - LegacyMeetingAdapterServiceImpl service = new LegacyMeetingAdapterServiceImpl( - meetingService, - mock(MeetingAccessService.class), - meetingDomainSupport, - mock(MeetingRuntimeProfileResolver.class), - mock(PromptTemplateService.class), - mock(MeetingSummaryPromptAssembler.class), - mock(AiTaskService.class), - mock(MeetingTranscriptMapper.class), - mock(LlmModelMapper.class), - mock(MeetingAudioUploadSupport.class) - ); - - LegacyMeetingCreateRequest request = new LegacyMeetingCreateRequest(); - request.setUserId(999L); - request.setTitle("旧端会议"); - request.setMeetingTime("2025-11-17T09:30:00Z"); - request.setTags(List.of("alpha", "beta")); - request.setAttendeeIds(List.of(2L, 3L)); - - LoginUser loginUser = new LoginUser(7L, 10L, "creator", false, false, Set.of()); - MeetingVO result = service.createMeeting(request, loginUser); - - assertEquals(9001L, result.getId()); - ArgumentCaptor captor = ArgumentCaptor.forClass(Meeting.class); - verify(meetingService).save(captor.capture()); - assertEquals(9001L, captor.getValue().getId()); - } -} +//package com.imeeting.service.android.legacy; +// +//import com.imeeting.dto.android.legacy.LegacyMeetingCreateRequest; +//import com.imeeting.dto.biz.MeetingVO; +//import com.imeeting.entity.biz.Meeting; +//import com.imeeting.mapper.biz.LlmModelMapper; +//import com.imeeting.mapper.biz.MeetingTranscriptMapper; +//import com.imeeting.service.android.legacy.impl.LegacyMeetingAdapterServiceImpl; +//import com.imeeting.service.biz.AiTaskService; +//import com.imeeting.service.biz.MeetingAccessService; +//import com.imeeting.service.biz.MeetingRuntimeProfileResolver; +//import com.imeeting.service.biz.MeetingService; +//import com.imeeting.service.biz.PromptTemplateService; +//import com.imeeting.service.biz.impl.MeetingAudioUploadSupport; +//import com.imeeting.service.biz.impl.MeetingDomainSupport; +//import com.imeeting.service.biz.impl.MeetingSummaryPromptAssembler; +//import com.unisbase.security.LoginUser; +//import org.junit.jupiter.api.Test; +//import org.mockito.ArgumentCaptor; +// +//import java.time.LocalDateTime; +//import java.util.List; +//import java.util.Set; +// +//import static org.junit.jupiter.api.Assertions.assertEquals; +//import static org.mockito.ArgumentMatchers.any; +//import static org.mockito.ArgumentMatchers.eq; +//import static org.mockito.ArgumentMatchers.isNull; +//import static org.mockito.Mockito.doAnswer; +//import static org.mockito.Mockito.mock; +//import static org.mockito.Mockito.verify; +//import static org.mockito.Mockito.when; +// +//class LegacyMeetingAdapterServiceImplTest { +// +// @Test +// void createMeetingShouldIgnoreLegacyUserIdAndParseOffsetTime() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// Meeting meeting = new Meeting(); +// meeting.setId(9001L); +// +// when(meetingDomainSupport.initMeeting( +// eq("旧端会议"), +// eq(LocalDateTime.of(2025, 11, 17, 9, 30)), +// eq("2,3"), +// eq("alpha,beta"), +// isNull(), +// eq(10L), +// eq(7L), +// eq("creator"), +// eq(7L), +// eq("creator"), +// eq(0) +// )).thenReturn(meeting); +// doAnswer(invocation -> { +// MeetingVO vo = invocation.getArgument(1); +// vo.setId(9001L); +// return null; +// }).when(meetingDomainSupport).fillMeetingVO(any(Meeting.class), any(MeetingVO.class), eq(false)); +// +// LegacyMeetingAdapterServiceImpl service = new LegacyMeetingAdapterServiceImpl( +// meetingService, +// mock(MeetingAccessService.class), +// meetingDomainSupport, +// mock(MeetingRuntimeProfileResolver.class), +// mock(PromptTemplateService.class), +// mock(MeetingSummaryPromptAssembler.class), +// mock(AiTaskService.class), +// mock(MeetingTranscriptMapper.class), +// mock(LlmModelMapper.class), +// mock(MeetingAudioUploadSupport.class) +// ); +// +// LegacyMeetingCreateRequest request = new LegacyMeetingCreateRequest(); +// request.setUserId(999L); +// request.setTitle("旧端会议"); +// request.setMeetingTime("2025-11-17T09:30:00Z"); +// request.setTags(List.of("alpha", "beta")); +// request.setAttendeeIds(List.of(2L, 3L)); +// +// LoginUser loginUser = new LoginUser(7L, 10L, "creator", false, false, Set.of()); +// MeetingVO result = service.createMeeting(request, loginUser); +// +// assertEquals(9001L, result.getId()); +// ArgumentCaptor captor = ArgumentCaptor.forClass(Meeting.class); +// verify(meetingService).save(captor.capture()); +// assertEquals(9001L, captor.getValue().getId()); +// } +//} diff --git a/backend/src/test/java/com/imeeting/service/biz/impl/MeetingCommandServiceImplTest.java b/backend/src/test/java/com/imeeting/service/biz/impl/MeetingCommandServiceImplTest.java index d1d7a7a..68758f1 100644 --- a/backend/src/test/java/com/imeeting/service/biz/impl/MeetingCommandServiceImplTest.java +++ b/backend/src/test/java/com/imeeting/service/biz/impl/MeetingCommandServiceImplTest.java @@ -1,663 +1,663 @@ -package com.imeeting.service.biz.impl; - -import com.fasterxml.jackson.databind.ObjectMapper; -import com.imeeting.common.RedisKeys; -import com.imeeting.dto.biz.CreateMeetingCommand; -import com.imeeting.dto.biz.CreateRealtimeMeetingCommand; -import com.imeeting.dto.biz.MeetingVO; -import com.imeeting.dto.biz.RealtimeMeetingRuntimeProfile; -import com.imeeting.dto.biz.RealtimeMeetingResumeConfig; -import com.imeeting.dto.biz.RealtimeTranscriptItemDTO; -import com.imeeting.entity.biz.AiTask; -import com.imeeting.entity.biz.Meeting; -import com.imeeting.service.biz.AiTaskService; -import com.imeeting.service.biz.HotWordService; -import com.imeeting.service.biz.MeetingRuntimeProfileResolver; -import com.imeeting.service.biz.MeetingService; -import com.imeeting.service.biz.MeetingSummaryFileService; -import com.imeeting.service.biz.RealtimeMeetingSessionStateService; -import com.imeeting.service.realtime.RealtimeMeetingAudioStorageService; -import org.junit.jupiter.api.Test; -import org.mockito.ArgumentCaptor; -import org.springframework.data.redis.core.StringRedisTemplate; -import org.springframework.transaction.support.TransactionSynchronizationManager; -import org.springframework.transaction.support.TransactionSynchronizationUtils; - -import java.time.LocalDateTime; -import java.util.Map; - -import static org.junit.jupiter.api.Assertions.assertEquals; -import static org.junit.jupiter.api.Assertions.assertNull; -import static org.junit.jupiter.api.Assertions.assertThrows; -import static org.mockito.ArgumentMatchers.argThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyLong; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.ArgumentMatchers.isNull; -import static org.mockito.Mockito.doAnswer; -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.never; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; - -class MeetingCommandServiceImplTest { - - @Test - void createMeetingShouldDefaultHostToCreatorWhenHostOmitted() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - Meeting meeting = new Meeting(); - meeting.setId(101L); - meeting.setTenantId(1L); - meeting.setHostUserId(7L); - meeting.setHostName("creator"); - - when(meetingDomainSupport.initMeeting( - eq("Design Review"), - any(LocalDateTime.class), - eq("1,2"), - eq("web"), - eq("/audio/demo.wav"), - eq(1L), - eq(7L), - eq("creator"), - eq(7L), - eq("creator"), - eq(0) - )).thenReturn(meeting); - when(meetingDomainSupport.relocateAudioUrl(eq(101L), eq("/audio/demo.wav"))).thenReturn("/audio/demo.wav"); - fillHostFieldsFromMeeting(meetingDomainSupport); - - MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); - - CreateMeetingCommand command = new CreateMeetingCommand(); - command.setTitle("Design Review"); - command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); - command.setParticipants("1,2"); - command.setTags("web"); - command.setAudioUrl("/audio/demo.wav"); - command.setAsrModelId(11L); - command.setSummaryModelId(22L); - command.setPromptId(33L); - command.setHotWords(java.util.List.of("design")); - - MeetingVO result = service.createMeeting(command, 1L, 7L, "creator"); - - ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); - verify(meetingService).save(meetingCaptor.capture()); - assertEquals(7L, meetingCaptor.getValue().getHostUserId()); - assertEquals("creator", meetingCaptor.getValue().getHostName()); - assertEquals(7L, result.getHostUserId()); - assertEquals("creator", result.getHostName()); - } - - @Test - void createRealtimeMeetingShouldDefaultHostToCreatorWhenHostOmitted() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - Meeting meeting = new Meeting(); - meeting.setId(101L); - meeting.setHostUserId(7L); - meeting.setHostName("creator"); - - when(meetingDomainSupport.initMeeting( - eq("Design Review"), - any(LocalDateTime.class), - eq("1,2"), - eq("web"), - isNull(), - eq(1L), - eq(7L), - eq("creator"), - eq(7L), - eq("creator"), - eq(0) - )).thenReturn(meeting); - fillHostFieldsFromMeeting(meetingDomainSupport); - - MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); - - CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); - command.setTitle("Design Review"); - command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); - command.setParticipants("1,2"); - command.setTags("web"); - command.setAsrModelId(11L); - command.setSummaryModelId(22L); - command.setPromptId(33L); - - MeetingVO result = service.createRealtimeMeeting(command, 1L, 7L, "creator"); - - ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); - verify(meetingService).save(meetingCaptor.capture()); - assertEquals(7L, meetingCaptor.getValue().getHostUserId()); - assertEquals("creator", meetingCaptor.getValue().getHostName()); - assertEquals(7L, result.getHostUserId()); - assertEquals("creator", result.getHostName()); - } - - @Test - void createRealtimeMeetingShouldNotFallbackCreatorNameForDelegateHost() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - Meeting meeting = new Meeting(); - meeting.setId(101L); - meeting.setHostUserId(99L); - meeting.setHostName(null); - - when(meetingDomainSupport.initMeeting( - eq("Design Review"), - any(LocalDateTime.class), - eq("1,2"), - eq("android"), - isNull(), - eq(1L), - eq(7L), - eq("creator"), - eq(99L), - isNull(), - eq(0) - )).thenReturn(meeting); - - fillHostFieldsFromMeeting(meetingDomainSupport); - - MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); - - CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); - command.setTitle("Design Review"); - command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); - command.setParticipants("1,2"); - command.setTags("android"); - command.setHostUserId(99L); - command.setAsrModelId(11L); - command.setSummaryModelId(22L); - command.setPromptId(33L); - - MeetingVO result = service.createRealtimeMeeting(command, 1L, 7L, "creator"); - - ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); - verify(meetingService).save(meetingCaptor.capture()); - assertEquals(99L, meetingCaptor.getValue().getHostUserId()); - assertNull(meetingCaptor.getValue().getHostName()); - assertEquals(99L, result.getHostUserId()); - assertNull(result.getHostName()); - } - - @Test - void deleteMeetingShouldCleanupRelatedDataAndArtifactsAfterCommit() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); - StringRedisTemplate redisTemplate = mock(StringRedisTemplate.class); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - sessionStateService, - mock(RealtimeMeetingAudioStorageService.class), - redisTemplate, - new ObjectMapper() - ); - - TransactionSynchronizationManager.initSynchronization(); - try { - service.deleteMeeting(901L); - - verify(transcriptMapper).delete(any()); - verify(aiTaskService).remove(any()); - verify(meetingService).removeById(901L); - verify(sessionStateService).clear(901L); - verify(redisTemplate).delete(RedisKeys.meetingProgressKey(901L)); - verify(meetingDomainSupport, never()).deleteMeetingArtifacts(901L); - - TransactionSynchronizationUtils.triggerAfterCommit(); - - verify(meetingDomainSupport).deleteMeetingArtifacts(901L); - } finally { - TransactionSynchronizationManager.clearSynchronization(); - } - } - - @Test - void completeRealtimeMeetingShouldBindFinalizedRealtimeAudio() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - RealtimeMeetingAudioStorageService audioStorageService = mock(RealtimeMeetingAudioStorageService.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); - Meeting meeting = new Meeting(); - meeting.setId(202L); - meeting.setStatus(0); - - when(meetingService.getById(202L)).thenReturn(meeting); - when(transcriptMapper.selectCount(any())).thenReturn(1L); - when(audioStorageService.finalizeMeetingAudio(202L)) - .thenReturn(new RealtimeMeetingAudioStorageService.FinalizeResult(RealtimeMeetingAudioStorageService.STATUS_SUCCESS, "/api/static/meetings/202/source_audio.wav", null)); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - sessionStateService, - audioStorageService, - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - service.completeRealtimeMeeting(202L, null, false); - - ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); - verify(meetingService).updateById(meetingCaptor.capture()); - assertEquals("/api/static/meetings/202/source_audio.wav", meetingCaptor.getValue().getAudioUrl()); - assertEquals(RealtimeMeetingAudioStorageService.STATUS_SUCCESS, meetingCaptor.getValue().getAudioSaveStatus()); - verify(aiTaskService).dispatchSummaryTask(202L, null, null); - } - - @Test - void completeRealtimeMeetingShouldKeepExplicitAudioUrlAndSkipFinalize() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - RealtimeMeetingAudioStorageService audioStorageService = mock(RealtimeMeetingAudioStorageService.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - Meeting meeting = new Meeting(); - meeting.setId(203L); - - when(meetingService.getById(203L)).thenReturn(meeting); - when(meetingDomainSupport.relocateAudioUrl(203L, "/api/static/audio/manual.wav")) - .thenReturn("/api/static/meetings/203/source_audio.wav"); - when(transcriptMapper.selectCount(any())).thenReturn(1L); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - mock(RealtimeMeetingSessionStateService.class), - audioStorageService, - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - service.completeRealtimeMeeting(203L, "/api/static/audio/manual.wav", false); - - verify(audioStorageService, never()).finalizeMeetingAudio(203L); - } - - @Test - void saveRealtimeTranscriptSnapshotShouldIgnoreNonFinalTranscript() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - mock(AiTaskService.class), - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - sessionStateService, - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - RealtimeTranscriptItemDTO item = new RealtimeTranscriptItemDTO(); - item.setSpeakerId("spk-1"); - item.setSpeakerName("Speaker 1"); - item.setContent("partial transcript"); - item.setStartTime(100); - item.setEndTime(500); - - service.saveRealtimeTranscriptSnapshot(1001L, item, false); - - verify(transcriptMapper, never()).selectOne(any()); - verify(transcriptMapper, never()).insert(any()); - verify(transcriptMapper, never()).update(any(), any()); - verify(sessionStateService, never()).refreshAfterTranscript(anyLong()); - } - - @Test - void reSummaryShouldDispatchAfterTransactionCommit() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - Meeting meeting = new Meeting(); - meeting.setId(301L); - - when(meetingService.getById(301L)).thenReturn(meeting); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - mock(RealtimeMeetingSessionStateService.class), - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - TransactionSynchronizationManager.initSynchronization(); - try { - service.reSummary(301L, 22L, 33L, null); - - verify(meetingDomainSupport).createSummaryTask(301L, 22L, 33L, null); - assertEquals(2, meeting.getStatus()); - verify(meetingService).updateById(meeting); - verify(aiTaskService, never()).dispatchSummaryTask(301L, null, null); - - TransactionSynchronizationUtils.triggerAfterCommit(); - - verify(aiTaskService).dispatchSummaryTask(301L, null, null); - } finally { - TransactionSynchronizationManager.clearSynchronization(); - } - } - - @Test - void retryTranscriptionShouldResetTasksAndDispatchAfterTransactionCommit() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - Meeting meeting = new Meeting(); - meeting.setId(401L); - meeting.setAudioUrl("/audio/demo.wav"); - - AiTask asrTask = new AiTask(); - asrTask.setTaskType("ASR"); - asrTask.setStatus(3); - asrTask.setTaskConfig(Map.of("asrModelId", 11L)); - asrTask.setErrorMsg("failed"); - asrTask.setStartedAt(LocalDateTime.now()); - asrTask.setCompletedAt(LocalDateTime.now()); - - AiTask summaryTask = new AiTask(); - summaryTask.setTaskType("SUMMARY"); - summaryTask.setStatus(3); - summaryTask.setTaskConfig(Map.of("summaryModelId", 22L, "promptId", 33L)); - summaryTask.setErrorMsg("failed"); - summaryTask.setStartedAt(LocalDateTime.now()); - summaryTask.setCompletedAt(LocalDateTime.now()); - - when(meetingService.getById(401L)).thenReturn(meeting); - when(transcriptMapper.selectCount(any())).thenReturn(0L); - when(aiTaskService.getOne(any())).thenReturn(asrTask, summaryTask); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - mock(RealtimeMeetingSessionStateService.class), - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - TransactionSynchronizationManager.initSynchronization(); - try { - service.retryTranscription(401L); - - assertEquals(1, meeting.getStatus()); - assertEquals(0, asrTask.getStatus()); - assertEquals(0, summaryTask.getStatus()); - assertNull(asrTask.getErrorMsg()); - assertNull(summaryTask.getErrorMsg()); - verify(aiTaskService).updateById(asrTask); - verify(aiTaskService).updateById(summaryTask); - verify(meetingService).updateById(meeting); - verify(aiTaskService, never()).dispatchTasks(401L, null, null); - - TransactionSynchronizationUtils.triggerAfterCommit(); - - verify(aiTaskService).dispatchTasks(401L, null, null); - } finally { - TransactionSynchronizationManager.clearSynchronization(); - } - } - - @Test - void retryTranscriptionShouldRejectMeetingsWithExistingTranscripts() { - MeetingService meetingService = mock(MeetingService.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); - Meeting meeting = new Meeting(); - meeting.setId(402L); - meeting.setAudioUrl("/audio/demo.wav"); - - when(meetingService.getById(402L)).thenReturn(meeting); - when(transcriptMapper.selectCount(any())).thenReturn(1L); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - transcriptMapper, - mock(MeetingSummaryFileService.class), - mock(MeetingDomainSupport.class), - mockRuntimeProfileResolver(), - mock(RealtimeMeetingSessionStateService.class), - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - RuntimeException error = assertThrows(RuntimeException.class, () -> service.retryTranscription(402L)); - - assertEquals("当前会议已有转录内容，无需重新识别", error.getMessage()); - verify(aiTaskService, never()).getOne(any()); - verify(aiTaskService, never()).dispatchTasks(anyLong(), any(), any()); - } - - @Test - void createMeetingShouldPersistResolvedRuntimeProfile() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - AiTaskService aiTaskService = mock(AiTaskService.class); - MeetingRuntimeProfileResolver runtimeProfileResolver = mockRuntimeProfileResolver(101L, 202L, 303L); - Meeting meeting = new Meeting(); - meeting.setId(808L); - meeting.setTenantId(1L); - meeting.setHostUserId(7L); - meeting.setHostName("creator"); - - when(meetingDomainSupport.initMeeting( - eq("Resolved Meeting"), - any(LocalDateTime.class), - eq("1,2"), - eq("tagA"), - eq("/audio/demo.wav"), - eq(1L), - eq(7L), - eq("creator"), - eq(7L), - eq("creator"), - eq(0) - )).thenReturn(meeting); - when(meetingDomainSupport.relocateAudioUrl(808L, "/audio/demo.wav")).thenReturn("/audio/demo.wav"); - fillHostFieldsFromMeeting(meetingDomainSupport); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - aiTaskService, - mock(HotWordService.class), - mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - runtimeProfileResolver, - mock(RealtimeMeetingSessionStateService.class), - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - CreateMeetingCommand command = new CreateMeetingCommand(); - command.setTitle("Resolved Meeting"); - command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); - command.setParticipants("1,2"); - command.setTags("tagA"); - command.setAudioUrl("/audio/demo.wav"); - command.setAsrModelId(11L); - command.setSummaryModelId(22L); - command.setPromptId(33L); - command.setUserPrompt("聚焦关键风险"); - - service.createMeeting(command, 1L, 7L, "creator"); - - verify(aiTaskService).save(argThat(task -> { - if (!"ASR".equals(task.getTaskType())) { - return false; - } - Object asrModelId = task.getTaskConfig().get("asrModelId"); - return Long.valueOf(101L).equals(asrModelId); - })); - verify(meetingDomainSupport).createSummaryTask(808L, 202L, 303L, "聚焦关键风险"); - } - - @Test - void createRealtimeMeetingShouldPersistResolvedResumeProfile() { - MeetingService meetingService = mock(MeetingService.class); - MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); - MeetingRuntimeProfileResolver runtimeProfileResolver = mockRuntimeProfileResolver(111L, 222L, 333L); - RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); - Meeting meeting = new Meeting(); - meeting.setId(909L); - meeting.setHostUserId(7L); - meeting.setHostName("creator"); - - when(meetingDomainSupport.initMeeting( - eq("Realtime Resolved"), - any(LocalDateTime.class), - eq("1,2"), - eq("tagB"), - isNull(), - eq(1L), - eq(7L), - eq("creator"), - eq(7L), - eq("creator"), - eq(0) - )).thenReturn(meeting); - fillHostFieldsFromMeeting(meetingDomainSupport); - - MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( - meetingService, - mock(AiTaskService.class), - mock(HotWordService.class), - mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - runtimeProfileResolver, - sessionStateService, - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - - CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); - command.setTitle("Realtime Resolved"); - command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); - command.setParticipants("1,2"); - command.setTags("tagB"); - command.setAsrModelId(11L); - command.setSummaryModelId(22L); - command.setPromptId(33L); - command.setMode("online"); - command.setLanguage("zh"); - command.setEnablePunctuation(false); - command.setEnableItn(false); - command.setEnableTextRefine(true); - command.setSaveAudio(true); - command.setUserPrompt("关注待办事项"); - - service.createRealtimeMeeting(command, 1L, 7L, "creator"); - - verify(meetingDomainSupport).createSummaryTask(909L, 222L, 333L, "关注待办事项"); - verify(sessionStateService).rememberResumeConfig(eq(909L), argThat(config -> - Long.valueOf(111L).equals(config.getAsrModelId()) - && "online".equals(config.getMode()) - && "zh".equals(config.getLanguage()) - && Integer.valueOf(1).equals(config.getUseSpkId()) - && Boolean.FALSE.equals(config.getEnablePunctuation()) - && Boolean.FALSE.equals(config.getEnableItn()) - && Boolean.TRUE.equals(config.getEnableTextRefine()) - && Boolean.TRUE.equals(config.getSaveAudio()) - )); - } - - private MeetingCommandServiceImpl newService(MeetingService meetingService, MeetingDomainSupport meetingDomainSupport) { - return new MeetingCommandServiceImpl( - meetingService, - mock(AiTaskService.class), - mock(HotWordService.class), - mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), - mock(MeetingSummaryFileService.class), - meetingDomainSupport, - mockRuntimeProfileResolver(), - mock(RealtimeMeetingSessionStateService.class), - mock(RealtimeMeetingAudioStorageService.class), - mock(StringRedisTemplate.class), - new ObjectMapper() - ); - } - - private MeetingRuntimeProfileResolver mockRuntimeProfileResolver() { - return mockRuntimeProfileResolver(11L, 22L, 33L); - } - - private MeetingRuntimeProfileResolver mockRuntimeProfileResolver(Long asrModelId, Long summaryModelId, Long promptId) { - MeetingRuntimeProfileResolver resolver = mock(MeetingRuntimeProfileResolver.class); - RealtimeMeetingRuntimeProfile profile = new RealtimeMeetingRuntimeProfile(); - profile.setResolvedAsrModelId(asrModelId); - profile.setResolvedSummaryModelId(summaryModelId); - profile.setResolvedPromptId(promptId); - profile.setResolvedMode("online"); - profile.setResolvedLanguage("zh"); - profile.setResolvedUseSpkId(1); - profile.setResolvedEnablePunctuation(Boolean.FALSE); - profile.setResolvedEnableItn(Boolean.FALSE); - profile.setResolvedEnableTextRefine(Boolean.TRUE); - profile.setResolvedSaveAudio(Boolean.TRUE); - profile.setResolvedHotWords(java.util.List.of()); - when(resolver.resolve(any(), any(), any(), any(), any(), any(), any(), any(), any(), any(), any(), any())) - .thenReturn(profile); - return resolver; - } - - private void fillHostFieldsFromMeeting(MeetingDomainSupport meetingDomainSupport) { - doAnswer(invocation -> { - MeetingVO vo = invocation.getArgument(1); - Meeting source = invocation.getArgument(0); - vo.setId(source.getId()); - vo.setHostUserId(source.getHostUserId()); - vo.setHostName(source.getHostName()); - return null; - }).when(meetingDomainSupport).fillMeetingVO(any(Meeting.class), any(MeetingVO.class), eq(false)); - } -} +//package com.imeeting.service.biz.impl; +// +//import com.fasterxml.jackson.databind.ObjectMapper; +//import com.imeeting.common.RedisKeys; +//import com.imeeting.dto.biz.CreateMeetingCommand; +//import com.imeeting.dto.biz.CreateRealtimeMeetingCommand; +//import com.imeeting.dto.biz.MeetingVO; +//import com.imeeting.dto.biz.RealtimeMeetingRuntimeProfile; +//import com.imeeting.dto.biz.RealtimeMeetingResumeConfig; +//import com.imeeting.dto.biz.RealtimeTranscriptItemDTO; +//import com.imeeting.entity.biz.AiTask; +//import com.imeeting.entity.biz.Meeting; +//import com.imeeting.service.biz.AiTaskService; +//import com.imeeting.service.biz.HotWordService; +//import com.imeeting.service.biz.MeetingRuntimeProfileResolver; +//import com.imeeting.service.biz.MeetingService; +//import com.imeeting.service.biz.MeetingSummaryFileService; +//import com.imeeting.service.biz.RealtimeMeetingSessionStateService; +//import com.imeeting.service.realtime.RealtimeMeetingAudioStorageService; +//import org.junit.jupiter.api.Test; +//import org.mockito.ArgumentCaptor; +//import org.springframework.data.redis.core.StringRedisTemplate; +//import org.springframework.transaction.support.TransactionSynchronizationManager; +//import org.springframework.transaction.support.TransactionSynchronizationUtils; +// +//import java.time.LocalDateTime; +//import java.util.Map; +// +//import static org.junit.jupiter.api.Assertions.assertEquals; +//import static org.junit.jupiter.api.Assertions.assertNull; +//import static org.junit.jupiter.api.Assertions.assertThrows; +//import static org.mockito.ArgumentMatchers.argThat; +//import static org.mockito.ArgumentMatchers.any; +//import static org.mockito.ArgumentMatchers.anyLong; +//import static org.mockito.ArgumentMatchers.eq; +//import static org.mockito.ArgumentMatchers.isNull; +//import static org.mockito.Mockito.doAnswer; +//import static org.mockito.Mockito.mock; +//import static org.mockito.Mockito.never; +//import static org.mockito.Mockito.verify; +//import static org.mockito.Mockito.when; +// +//class MeetingCommandServiceImplTest { +// +// @Test +// void createMeetingShouldDefaultHostToCreatorWhenHostOmitted() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// Meeting meeting = new Meeting(); +// meeting.setId(101L); +// meeting.setTenantId(1L); +// meeting.setHostUserId(7L); +// meeting.setHostName("creator"); +// +// when(meetingDomainSupport.initMeeting( +// eq("Design Review"), +// any(LocalDateTime.class), +// eq("1,2"), +// eq("web"), +// eq("/audio/demo.wav"), +// eq(1L), +// eq(7L), +// eq("creator"), +// eq(7L), +// eq("creator"), +// eq(0) +// )).thenReturn(meeting); +// when(meetingDomainSupport.relocateAudioUrl(eq(101L), eq("/audio/demo.wav"))).thenReturn("/audio/demo.wav"); +// fillHostFieldsFromMeeting(meetingDomainSupport); +// +// MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); +// +// CreateMeetingCommand command = new CreateMeetingCommand(); +// command.setTitle("Design Review"); +// command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); +// command.setParticipants("1,2"); +// command.setTags("web"); +// command.setAudioUrl("/audio/demo.wav"); +// command.setAsrModelId(11L); +// command.setSummaryModelId(22L); +// command.setPromptId(33L); +// command.setHotWords(java.util.List.of("design")); +// +// MeetingVO result = service.createMeeting(command, 1L, 7L, "creator"); +// +// ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); +// verify(meetingService).save(meetingCaptor.capture()); +// assertEquals(7L, meetingCaptor.getValue().getHostUserId()); +// assertEquals("creator", meetingCaptor.getValue().getHostName()); +// assertEquals(7L, result.getHostUserId()); +// assertEquals("creator", result.getHostName()); +// } +// +// @Test +// void createRealtimeMeetingShouldDefaultHostToCreatorWhenHostOmitted() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// Meeting meeting = new Meeting(); +// meeting.setId(101L); +// meeting.setHostUserId(7L); +// meeting.setHostName("creator"); +// +// when(meetingDomainSupport.initMeeting( +// eq("Design Review"), +// any(LocalDateTime.class), +// eq("1,2"), +// eq("web"), +// isNull(), +// eq(1L), +// eq(7L), +// eq("creator"), +// eq(7L), +// eq("creator"), +// eq(0) +// )).thenReturn(meeting); +// fillHostFieldsFromMeeting(meetingDomainSupport); +// +// MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); +// +// CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); +// command.setTitle("Design Review"); +// command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); +// command.setParticipants("1,2"); +// command.setTags("web"); +// command.setAsrModelId(11L); +// command.setSummaryModelId(22L); +// command.setPromptId(33L); +// +// MeetingVO result = service.createRealtimeMeeting(command, 1L, 7L, "creator"); +// +// ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); +// verify(meetingService).save(meetingCaptor.capture()); +// assertEquals(7L, meetingCaptor.getValue().getHostUserId()); +// assertEquals("creator", meetingCaptor.getValue().getHostName()); +// assertEquals(7L, result.getHostUserId()); +// assertEquals("creator", result.getHostName()); +// } +// +// @Test +// void createRealtimeMeetingShouldNotFallbackCreatorNameForDelegateHost() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// Meeting meeting = new Meeting(); +// meeting.setId(101L); +// meeting.setHostUserId(99L); +// meeting.setHostName(null); +// +// when(meetingDomainSupport.initMeeting( +// eq("Design Review"), +// any(LocalDateTime.class), +// eq("1,2"), +// eq("android"), +// isNull(), +// eq(1L), +// eq(7L), +// eq("creator"), +// eq(99L), +// isNull(), +// eq(0) +// )).thenReturn(meeting); +// +// fillHostFieldsFromMeeting(meetingDomainSupport); +// +// MeetingCommandServiceImpl service = newService(meetingService, meetingDomainSupport); +// +// CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); +// command.setTitle("Design Review"); +// command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); +// command.setParticipants("1,2"); +// command.setTags("android"); +// command.setHostUserId(99L); +// command.setAsrModelId(11L); +// command.setSummaryModelId(22L); +// command.setPromptId(33L); +// +// MeetingVO result = service.createRealtimeMeeting(command, 1L, 7L, "creator"); +// +// ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); +// verify(meetingService).save(meetingCaptor.capture()); +// assertEquals(99L, meetingCaptor.getValue().getHostUserId()); +// assertNull(meetingCaptor.getValue().getHostName()); +// assertEquals(99L, result.getHostUserId()); +// assertNull(result.getHostName()); +// } +// +// @Test +// void deleteMeetingShouldCleanupRelatedDataAndArtifactsAfterCommit() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); +// StringRedisTemplate redisTemplate = mock(StringRedisTemplate.class); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// sessionStateService, +// mock(RealtimeMeetingAudioStorageService.class), +// redisTemplate, +// new ObjectMapper() +// ); +// +// TransactionSynchronizationManager.initSynchronization(); +// try { +// service.deleteMeeting(901L); +// +// verify(transcriptMapper).delete(any()); +// verify(aiTaskService).remove(any()); +// verify(meetingService).removeById(901L); +// verify(sessionStateService).clear(901L); +// verify(redisTemplate).delete(RedisKeys.meetingProgressKey(901L)); +// verify(meetingDomainSupport, never()).deleteMeetingArtifacts(901L); +// +// TransactionSynchronizationUtils.triggerAfterCommit(); +// +// verify(meetingDomainSupport).deleteMeetingArtifacts(901L); +// } finally { +// TransactionSynchronizationManager.clearSynchronization(); +// } +// } +// +// @Test +// void completeRealtimeMeetingShouldBindFinalizedRealtimeAudio() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// RealtimeMeetingAudioStorageService audioStorageService = mock(RealtimeMeetingAudioStorageService.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); +// Meeting meeting = new Meeting(); +// meeting.setId(202L); +// meeting.setStatus(0); +// +// when(meetingService.getById(202L)).thenReturn(meeting); +// when(transcriptMapper.selectCount(any())).thenReturn(1L); +// when(audioStorageService.finalizeMeetingAudio(202L)) +// .thenReturn(new RealtimeMeetingAudioStorageService.FinalizeResult(RealtimeMeetingAudioStorageService.STATUS_SUCCESS, "/api/static/meetings/202/source_audio.wav", null)); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// sessionStateService, +// audioStorageService, +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// service.completeRealtimeMeeting(202L, null, false); +// +// ArgumentCaptor meetingCaptor = ArgumentCaptor.forClass(Meeting.class); +// verify(meetingService).updateById(meetingCaptor.capture()); +// assertEquals("/api/static/meetings/202/source_audio.wav", meetingCaptor.getValue().getAudioUrl()); +// assertEquals(RealtimeMeetingAudioStorageService.STATUS_SUCCESS, meetingCaptor.getValue().getAudioSaveStatus()); +// verify(aiTaskService).dispatchSummaryTask(202L, null, null); +// } +// +// @Test +// void completeRealtimeMeetingShouldKeepExplicitAudioUrlAndSkipFinalize() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// RealtimeMeetingAudioStorageService audioStorageService = mock(RealtimeMeetingAudioStorageService.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// Meeting meeting = new Meeting(); +// meeting.setId(203L); +// +// when(meetingService.getById(203L)).thenReturn(meeting); +// when(meetingDomainSupport.relocateAudioUrl(203L, "/api/static/audio/manual.wav")) +// .thenReturn("/api/static/meetings/203/source_audio.wav"); +// when(transcriptMapper.selectCount(any())).thenReturn(1L); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// mock(RealtimeMeetingSessionStateService.class), +// audioStorageService, +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// service.completeRealtimeMeeting(203L, "/api/static/audio/manual.wav", false); +// +// verify(audioStorageService, never()).finalizeMeetingAudio(203L); +// } +// +// @Test +// void saveRealtimeTranscriptSnapshotShouldIgnoreNonFinalTranscript() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// mock(AiTaskService.class), +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// sessionStateService, +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// RealtimeTranscriptItemDTO item = new RealtimeTranscriptItemDTO(); +// item.setSpeakerId("spk-1"); +// item.setSpeakerName("Speaker 1"); +// item.setContent("partial transcript"); +// item.setStartTime(100); +// item.setEndTime(500); +// +// service.saveRealtimeTranscriptSnapshot(1001L, item, false); +// +// verify(transcriptMapper, never()).selectOne(any()); +// verify(transcriptMapper, never()).insert(any()); +// verify(transcriptMapper, never()).update(any(), any()); +// verify(sessionStateService, never()).refreshAfterTranscript(anyLong()); +// } +// +// @Test +// void reSummaryShouldDispatchAfterTransactionCommit() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// Meeting meeting = new Meeting(); +// meeting.setId(301L); +// +// when(meetingService.getById(301L)).thenReturn(meeting); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// mock(RealtimeMeetingSessionStateService.class), +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// TransactionSynchronizationManager.initSynchronization(); +// try { +// service.reSummary(301L, 22L, 33L, null); +// +// verify(meetingDomainSupport).createSummaryTask(301L, 22L, 33L, null); +// assertEquals(2, meeting.getStatus()); +// verify(meetingService).updateById(meeting); +// verify(aiTaskService, never()).dispatchSummaryTask(301L, null, null); +// +// TransactionSynchronizationUtils.triggerAfterCommit(); +// +// verify(aiTaskService).dispatchSummaryTask(301L, null, null); +// } finally { +// TransactionSynchronizationManager.clearSynchronization(); +// } +// } +// +// @Test +// void retryTranscriptionShouldResetTasksAndDispatchAfterTransactionCommit() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// Meeting meeting = new Meeting(); +// meeting.setId(401L); +// meeting.setAudioUrl("/audio/demo.wav"); +// +// AiTask asrTask = new AiTask(); +// asrTask.setTaskType("ASR"); +// asrTask.setStatus(3); +// asrTask.setTaskConfig(Map.of("asrModelId", 11L)); +// asrTask.setErrorMsg("failed"); +// asrTask.setStartedAt(LocalDateTime.now()); +// asrTask.setCompletedAt(LocalDateTime.now()); +// +// AiTask summaryTask = new AiTask(); +// summaryTask.setTaskType("SUMMARY"); +// summaryTask.setStatus(3); +// summaryTask.setTaskConfig(Map.of("summaryModelId", 22L, "promptId", 33L)); +// summaryTask.setErrorMsg("failed"); +// summaryTask.setStartedAt(LocalDateTime.now()); +// summaryTask.setCompletedAt(LocalDateTime.now()); +// +// when(meetingService.getById(401L)).thenReturn(meeting); +// when(transcriptMapper.selectCount(any())).thenReturn(0L); +// when(aiTaskService.getOne(any())).thenReturn(asrTask, summaryTask); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// mock(RealtimeMeetingSessionStateService.class), +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// TransactionSynchronizationManager.initSynchronization(); +// try { +// service.retryTranscription(401L); +// +// assertEquals(1, meeting.getStatus()); +// assertEquals(0, asrTask.getStatus()); +// assertEquals(0, summaryTask.getStatus()); +// assertNull(asrTask.getErrorMsg()); +// assertNull(summaryTask.getErrorMsg()); +// verify(aiTaskService).updateById(asrTask); +// verify(aiTaskService).updateById(summaryTask); +// verify(meetingService).updateById(meeting); +// verify(aiTaskService, never()).dispatchTasks(401L, null, null); +// +// TransactionSynchronizationUtils.triggerAfterCommit(); +// +// verify(aiTaskService).dispatchTasks(401L, null, null); +// } finally { +// TransactionSynchronizationManager.clearSynchronization(); +// } +// } +// +// @Test +// void retryTranscriptionShouldRejectMeetingsWithExistingTranscripts() { +// MeetingService meetingService = mock(MeetingService.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// com.imeeting.mapper.biz.MeetingTranscriptMapper transcriptMapper = mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class); +// Meeting meeting = new Meeting(); +// meeting.setId(402L); +// meeting.setAudioUrl("/audio/demo.wav"); +// +// when(meetingService.getById(402L)).thenReturn(meeting); +// when(transcriptMapper.selectCount(any())).thenReturn(1L); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// transcriptMapper, +// mock(MeetingSummaryFileService.class), +// mock(MeetingDomainSupport.class), +// mockRuntimeProfileResolver(), +// mock(RealtimeMeetingSessionStateService.class), +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// RuntimeException error = assertThrows(RuntimeException.class, () -> service.retryTranscription(402L)); +// +// assertEquals("当前会议已有转录内容，无需重新识别", error.getMessage()); +// verify(aiTaskService, never()).getOne(any()); +// verify(aiTaskService, never()).dispatchTasks(anyLong(), any(), any()); +// } +// +// @Test +// void createMeetingShouldPersistResolvedRuntimeProfile() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// AiTaskService aiTaskService = mock(AiTaskService.class); +// MeetingRuntimeProfileResolver runtimeProfileResolver = mockRuntimeProfileResolver(101L, 202L, 303L); +// Meeting meeting = new Meeting(); +// meeting.setId(808L); +// meeting.setTenantId(1L); +// meeting.setHostUserId(7L); +// meeting.setHostName("creator"); +// +// when(meetingDomainSupport.initMeeting( +// eq("Resolved Meeting"), +// any(LocalDateTime.class), +// eq("1,2"), +// eq("tagA"), +// eq("/audio/demo.wav"), +// eq(1L), +// eq(7L), +// eq("creator"), +// eq(7L), +// eq("creator"), +// eq(0) +// )).thenReturn(meeting); +// when(meetingDomainSupport.relocateAudioUrl(808L, "/audio/demo.wav")).thenReturn("/audio/demo.wav"); +// fillHostFieldsFromMeeting(meetingDomainSupport); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// aiTaskService, +// mock(HotWordService.class), +// mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// runtimeProfileResolver, +// mock(RealtimeMeetingSessionStateService.class), +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// CreateMeetingCommand command = new CreateMeetingCommand(); +// command.setTitle("Resolved Meeting"); +// command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); +// command.setParticipants("1,2"); +// command.setTags("tagA"); +// command.setAudioUrl("/audio/demo.wav"); +// command.setAsrModelId(11L); +// command.setSummaryModelId(22L); +// command.setPromptId(33L); +// command.setUserPrompt("聚焦关键风险"); +// +// service.createMeeting(command, 1L, 7L, "creator"); +// +// verify(aiTaskService).save(argThat(task -> { +// if (!"ASR".equals(task.getTaskType())) { +// return false; +// } +// Object asrModelId = task.getTaskConfig().get("asrModelId"); +// return Long.valueOf(101L).equals(asrModelId); +// })); +// verify(meetingDomainSupport).createSummaryTask(808L, 202L, 303L, "聚焦关键风险"); +// } +// +// @Test +// void createRealtimeMeetingShouldPersistResolvedResumeProfile() { +// MeetingService meetingService = mock(MeetingService.class); +// MeetingDomainSupport meetingDomainSupport = mock(MeetingDomainSupport.class); +// MeetingRuntimeProfileResolver runtimeProfileResolver = mockRuntimeProfileResolver(111L, 222L, 333L); +// RealtimeMeetingSessionStateService sessionStateService = mock(RealtimeMeetingSessionStateService.class); +// Meeting meeting = new Meeting(); +// meeting.setId(909L); +// meeting.setHostUserId(7L); +// meeting.setHostName("creator"); +// +// when(meetingDomainSupport.initMeeting( +// eq("Realtime Resolved"), +// any(LocalDateTime.class), +// eq("1,2"), +// eq("tagB"), +// isNull(), +// eq(1L), +// eq(7L), +// eq("creator"), +// eq(7L), +// eq("creator"), +// eq(0) +// )).thenReturn(meeting); +// fillHostFieldsFromMeeting(meetingDomainSupport); +// +// MeetingCommandServiceImpl service = new MeetingCommandServiceImpl( +// meetingService, +// mock(AiTaskService.class), +// mock(HotWordService.class), +// mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// runtimeProfileResolver, +// sessionStateService, +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// +// CreateRealtimeMeetingCommand command = new CreateRealtimeMeetingCommand(); +// command.setTitle("Realtime Resolved"); +// command.setMeetingTime(LocalDateTime.of(2026, 4, 3, 19, 0)); +// command.setParticipants("1,2"); +// command.setTags("tagB"); +// command.setAsrModelId(11L); +// command.setSummaryModelId(22L); +// command.setPromptId(33L); +// command.setMode("online"); +// command.setLanguage("zh"); +// command.setEnablePunctuation(false); +// command.setEnableItn(false); +// command.setEnableTextRefine(true); +// command.setSaveAudio(true); +// command.setUserPrompt("关注待办事项"); +// +// service.createRealtimeMeeting(command, 1L, 7L, "creator"); +// +// verify(meetingDomainSupport).createSummaryTask(909L, 222L, 333L, "关注待办事项"); +// verify(sessionStateService).rememberResumeConfig(eq(909L), argThat(config -> +// Long.valueOf(111L).equals(config.getAsrModelId()) +// && "online".equals(config.getMode()) +// && "zh".equals(config.getLanguage()) +// && Integer.valueOf(1).equals(config.getUseSpkId()) +// && Boolean.FALSE.equals(config.getEnablePunctuation()) +// && Boolean.FALSE.equals(config.getEnableItn()) +// && Boolean.TRUE.equals(config.getEnableTextRefine()) +// && Boolean.TRUE.equals(config.getSaveAudio()) +// )); +// } +// +// private MeetingCommandServiceImpl newService(MeetingService meetingService, MeetingDomainSupport meetingDomainSupport) { +// return new MeetingCommandServiceImpl( +// meetingService, +// mock(AiTaskService.class), +// mock(HotWordService.class), +// mock(com.imeeting.mapper.biz.MeetingTranscriptMapper.class), +// mock(MeetingSummaryFileService.class), +// meetingDomainSupport, +// mockRuntimeProfileResolver(), +// mock(RealtimeMeetingSessionStateService.class), +// mock(RealtimeMeetingAudioStorageService.class), +// mock(StringRedisTemplate.class), +// new ObjectMapper() +// ); +// } +// +// private MeetingRuntimeProfileResolver mockRuntimeProfileResolver() { +// return mockRuntimeProfileResolver(11L, 22L, 33L); +// } +// +// private MeetingRuntimeProfileResolver mockRuntimeProfileResolver(Long asrModelId, Long summaryModelId, Long promptId) { +// MeetingRuntimeProfileResolver resolver = mock(MeetingRuntimeProfileResolver.class); +// RealtimeMeetingRuntimeProfile profile = new RealtimeMeetingRuntimeProfile(); +// profile.setResolvedAsrModelId(asrModelId); +// profile.setResolvedSummaryModelId(summaryModelId); +// profile.setResolvedPromptId(promptId); +// profile.setResolvedMode("online"); +// profile.setResolvedLanguage("zh"); +// profile.setResolvedUseSpkId(1); +// profile.setResolvedEnablePunctuation(Boolean.FALSE); +// profile.setResolvedEnableItn(Boolean.FALSE); +// profile.setResolvedEnableTextRefine(Boolean.TRUE); +// profile.setResolvedSaveAudio(Boolean.TRUE); +// profile.setResolvedHotWords(java.util.List.of()); +// when(resolver.resolve(any(), any(), any(), any(), any(), any(), any(), any(), any(), any(), any(), any())) +// .thenReturn(profile); +// return resolver; +// } +// +// private void fillHostFieldsFromMeeting(MeetingDomainSupport meetingDomainSupport) { +// doAnswer(invocation -> { +// MeetingVO vo = invocation.getArgument(1); +// Meeting source = invocation.getArgument(0); +// vo.setId(source.getId()); +// vo.setHostUserId(source.getHostUserId()); +// vo.setHostName(source.getHostName()); +// return null; +// }).when(meetingDomainSupport).fillMeetingVO(any(Meeting.class), any(MeetingVO.class), eq(false)); +// } +//} diff --git a/frontend/src/pages/auth/login/index.tsx b/frontend/src/pages/auth/login/index.tsx index 1107321..c0df8cb 100644 --- a/frontend/src/pages/auth/login/index.tsx +++ b/frontend/src/pages/auth/login/index.tsx @@ -222,12 +222,12 @@ export default function Login() { -
- - {t("login.demoAccount")} admin / {t("login.password")}{" "} - 123456 - -
+ {/*
*/} + {/* */} + {/* {t("login.demoAccount")} admin / {t("login.password")}{" "}*/} + {/* 123456*/} + {/* */} + {/*
*/}