EntryFormAbility.ets 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891
  1. import { formBindingData, FormExtensionAbility, formProvider } from '@kit.FormKit';
  2. import { Want } from '@kit.AbilityKit';
  3. import { hilog } from '@kit.PerformanceAnalysisKit';
  4. import { fileIo } from '@kit.CoreFileKit';
  5. import { http } from '@kit.NetworkKit';
  6. import { WidgetDataManager } from '../common/widget/WidgetDataManager';
  7. import { PlayerControlService } from '../common/widget/PlayerControlService';
  8. import { AvSessionWidgetListener } from '../common/widget/AvSessionWidgetListener';
  9. import { WidgetData, WidgetSize, FormattedWidgetData } from '../common/widget/WidgetTypes';
  10. import { FormLayoutManager } from '../common/widget/FormLayoutManager';
  11. import { GlobalWidgetManager } from '../common/widget/GlobalWidgetManager';
  12. import { WidgetSizeAdapter, SizeChangeListener } from '../common/widget/WidgetSizeAdapter';
  13. import { PreferencesUtil } from '../common/utils/PreferencesUtil';
  14. const TAG = 'Heanup EntryFormAbility';
  15. /**
  16. * 扩展的卡片数据接口,支持图片传递
  17. */
  18. interface ExtendedWidgetData extends FormattedWidgetData {
  19. formImages?: Record<string, number>;
  20. }
  21. /**
  22. * 自定义对象复制函数,替代Object.assign
  23. */
  24. function copyWidgetData(target: ExtendedWidgetData, overrides: Partial<ExtendedWidgetData>): ExtendedWidgetData {
  25. return {
  26. isPlaying: overrides.isPlaying !== undefined ? overrides.isPlaying : target.isPlaying,
  27. isPaused: overrides.isPaused !== undefined ? overrides.isPaused : target.isPaused,
  28. isLoading: overrides.isLoading !== undefined ? overrides.isLoading : target.isLoading,
  29. songTitle: overrides.songTitle !== undefined ? overrides.songTitle : target.songTitle,
  30. songArtist: overrides.songArtist !== undefined ? overrides.songArtist : target.songArtist,
  31. songAlbum: overrides.songAlbum !== undefined ? overrides.songAlbum : target.songAlbum,
  32. coverImage: overrides.coverImage !== undefined ? overrides.coverImage : target.coverImage,
  33. currentTime: overrides.currentTime !== undefined ? overrides.currentTime : target.currentTime,
  34. totalTime: overrides.totalTime !== undefined ? overrides.totalTime : target.totalTime,
  35. progressPercentage: overrides.progressPercentage !== undefined ? overrides.progressPercentage :
  36. target.progressPercentage,
  37. hasNext: overrides.hasNext !== undefined ? overrides.hasNext : target.hasNext,
  38. hasPrevious: overrides.hasPrevious !== undefined ? overrides.hasPrevious : target.hasPrevious,
  39. showProgress: overrides.showProgress !== undefined ? overrides.showProgress : target.showProgress,
  40. showCover: overrides.showCover !== undefined ? overrides.showCover : target.showCover,
  41. widgetSize: overrides.widgetSize !== undefined ? overrides.widgetSize : target.widgetSize,
  42. timestamp: overrides.timestamp !== undefined ? overrides.timestamp : target.timestamp,
  43. imgName: overrides.imgName !== undefined ? overrides.imgName : target.imgName,
  44. formImages: overrides.formImages !== undefined ? overrides.formImages : target.formImages
  45. };
  46. }
  47. /**
  48. * 桌面播放器卡片扩展能力
  49. * 负责处理卡片的生命周期管理和用户交互事件
  50. * 支持多尺寸适配和UI重构
  51. */
  52. export default class EntryFormAbility extends FormExtensionAbility
  53. implements SizeChangeListener {
  54. private widgetDataManager: WidgetDataManager | null = null;
  55. private playerControlService: PlayerControlService = new PlayerControlService();
  56. private layoutManager: FormLayoutManager = FormLayoutManager.getInstance();
  57. private sizeAdapter: WidgetSizeAdapter = WidgetSizeAdapter.getInstance();
  58. private globalWidgetManager: GlobalWidgetManager = GlobalWidgetManager.getInstance();
  59. // 使用实例变量而不是静态变量,确保每个进程都能正确设置监听器
  60. private globalListenerSetup: boolean = false;
  61. // 防抖机制:避免短时间内重复更新
  62. private lastUpdateTime: number = 0;
  63. private updateDebounceDelay: number = 100;
  64. // 100ms防抖延迟
  65. // 进程启动时间,用于检测进程重启
  66. private processStartTime: number = Date.now();
  67. // 图片下载缓存
  68. private downloadingImages: Map<string, Promise<string | null>> = new Map();
  69. private imageCache: Map<string, string> = new Map();
  70. // url -> fileName映射
  71. /**
  72. * 卡片创建时调用
  73. */
  74. onAddForm(want: Want): formBindingData.FormBindingData {
  75. // 检查参数有效性
  76. if (!want || !want.parameters) {
  77. hilog.error(0x0000, TAG, 'FormAbility onAddForm want or want.parameters is undefined');
  78. return formBindingData.createFormBindingData('');
  79. }
  80. // 初始化服务
  81. try {
  82. this.initializeServices();
  83. } catch (error) {
  84. hilog.error(0x0000, TAG, `Heanup EntryFormAbility failed to initialize services: ${error}`);
  85. }
  86. const formId = want.parameters?.['ohos.extra.param.key.form_identity'] as string;
  87. const formName = want.parameters?.['ohos.extra.param.key.form_name'] as string;
  88. const formDimension = want.parameters?.['ohos.extra.param.key.form_dimension'] as string;
  89. const tempFlag = want.parameters?.['ohos.extra.param.key.form_temporary'] as boolean;
  90. // 持久化保存 Form ID(异步执行,不阻塞返回)
  91. this.saveFormIdToPersistence(formId).then(() => {
  92. })
  93. // 检测卡片尺寸并注册到全局管理器
  94. const widgetSize = this.sizeAdapter.detectSizeFromWant(want);
  95. try {
  96. this.globalWidgetManager.registerWidget(formId, widgetSize);
  97. } catch (error) {
  98. hilog.error(0x0000, TAG, `Failed to register widget: ${error}`);
  99. }
  100. // 注册各种监听器
  101. this.sizeAdapter.registerSizeChangeListener(formId, this);
  102. // 初始化卡片数据
  103. this.initializeWidget(formId, widgetSize);
  104. // 验证监听器设置状态
  105. setTimeout(() => {
  106. const avSessionListener = AvSessionWidgetListener.getInstance();
  107. const listenerCount = avSessionListener.getListenerCount();
  108. if (listenerCount === 0) {
  109. hilog.warn(0x0000, TAG, `⚠️ No listeners found! Form process may not receive data updates!`);
  110. } else {
  111. }
  112. }, 2000);
  113. // 获取当前播放状态而不是初始数据
  114. this.playerControlService.getCurrentPlayState().then((currentState: WidgetData) => {
  115. const adaptedData = this.layoutManager.adaptDataForSize(currentState, widgetSize);
  116. const formData = formBindingData.createFormBindingData(adaptedData);
  117. // 立即更新卡片以显示当前状态
  118. formProvider.updateForm(formId, formData);
  119. });
  120. // 返回初始数据作为临时显示
  121. const initialData = this.widgetDataManager?.getInitialWidgetData() || this.getDefaultWidgetData();
  122. const adaptedData = this.layoutManager.adaptDataForSize(initialData, widgetSize);
  123. return formBindingData.createFormBindingData(adaptedData);
  124. }
  125. /**
  126. * 卡片更新时调用
  127. */
  128. onUpdateForm(formId: string): void {
  129. // 确保服务已初始化
  130. if (!this.globalListenerSetup) {
  131. this.initializeServices();
  132. }
  133. // 确保widget已注册到GlobalWidgetManager
  134. if (!this.globalWidgetManager.hasWidget(formId)) {
  135. this.globalWidgetManager.registerWidget(formId, 'medium' as WidgetSize);
  136. }
  137. // 只更新指定的卡片,避免重复更新
  138. this.updateWidgetData(formId);
  139. }
  140. /**
  141. * 卡片删除时调用
  142. */
  143. onRemoveForm(formId: string): void {
  144. // 从持久化存储中移除 Form ID(异步执行)
  145. this.removeFormIdFromPersistence(formId).then(() => {
  146. });
  147. // 注销各种监听器
  148. this.sizeAdapter.unregisterSizeChangeListener(formId);
  149. // 从全局管理器中注销卡片
  150. this.globalWidgetManager.unregisterWidget(formId);
  151. // 清理卡片相关数据和配置
  152. this.widgetDataManager?.removeWidgetData(formId);
  153. }
  154. /**
  155. * 卡片可见性变化时调用
  156. */
  157. onVisibilityChange(newStatus: Record<string, number>): void {
  158. const formIds = Object.keys(newStatus);
  159. for (let i = 0; i < formIds.length; i++) {
  160. const formId = formIds[i];
  161. const isVisible = newStatus[formId] === 1;
  162. if (isVisible) {
  163. // 卡片变为可见时,更新数据
  164. this.updateWidgetData(formId);
  165. }
  166. }
  167. }
  168. /**
  169. * 卡片配置更新时调用
  170. */
  171. onConfigurationUpdate(newConfig: Object): void {
  172. // 更新所有卡片以适应新配置
  173. this.widgetDataManager?.updateAllWidgets();
  174. }
  175. /**
  176. * 实现SizeChangeListener接口
  177. * 处理卡片尺寸变化事件
  178. */
  179. onSizeChanged(formId: string, oldSize: WidgetSize, newSize: WidgetSize): void {
  180. // 更新全局管理器中的尺寸记录
  181. this.globalWidgetManager.updateWidgetSize(formId, newSize);
  182. // 立即更新卡片数据以适应新尺寸
  183. this.updateWidgetData(formId);
  184. }
  185. /**
  186. * 处理卡片尺寸变化(系统调用)
  187. * @param newStatus 新的尺寸状态
  188. */
  189. onAcquireFormState(want: Want): number {
  190. const formId = want.parameters?.['ohos.extra.param.key.form_identity'] as string;
  191. if (formId) {
  192. // 检测新的尺寸
  193. const newSize = this.sizeAdapter.detectSizeFromWant(want);
  194. const oldSize = this.globalWidgetManager.getWidgetSize(formId);
  195. if (oldSize && this.sizeAdapter.validateSizeChange(oldSize, newSize)) {
  196. // 处理尺寸变化
  197. this.handleFormSizeChange(formId, oldSize, newSize);
  198. }
  199. }
  200. // 返回卡片状态 - 使用数字常量代替枚举
  201. return 1; // READY状态
  202. }
  203. /**
  204. * 初始化服务
  205. */
  206. private initializeServices(): void {
  207. if (!this.widgetDataManager) {
  208. this.widgetDataManager = new WidgetDataManager();
  209. }
  210. // 设置全局状态监听器(每个进程实例设置一次)
  211. if (!this.globalListenerSetup) {
  212. this.setupGlobalStateListener();
  213. this.globalListenerSetup = true;
  214. }
  215. }
  216. /**
  217. * 设置全局状态监听器
  218. */
  219. private setupGlobalStateListener(): void {
  220. try {
  221. const avSessionListener = AvSessionWidgetListener.getInstance();
  222. avSessionListener.addStateListener((data: WidgetData) => {
  223. this.updateAllWidgetsWithData(data);
  224. });
  225. } catch (error) {
  226. hilog.error(0x0000, TAG,
  227. `Heanup EntryFormAbility [Process:${this.processStartTime}] failed to setup global listener: ${error}`);
  228. }
  229. }
  230. /**
  231. * 使用指定数据更新所有卡片
  232. */
  233. private updateAllWidgetsWithData(data: WidgetData): void {
  234. // 防抖机制:避免短时间内重复更新
  235. const now = Date.now();
  236. if (now - this.lastUpdateTime < this.updateDebounceDelay) {
  237. return;
  238. }
  239. this.lastUpdateTime = now;
  240. const activeWidgets = this.globalWidgetManager.getActiveWidgets();
  241. if (activeWidgets.size === 0) {
  242. hilog.warn(0x0000, TAG, 'Heanup EntryFormAbility no widgets to update in this process, skipping');
  243. return;
  244. }
  245. activeWidgets.forEach((size: WidgetSize, formId: string) => {
  246. this.updateSingleWidget(formId, size, data);
  247. });
  248. }
  249. /**
  250. * 更新单个卡片,带重试机制和网络图片支持
  251. */
  252. private updateSingleWidget(formId: string, size: WidgetSize, data: WidgetData, retryCount: number = 0): void {
  253. try {
  254. // 根据卡片尺寸适配数据
  255. const formattedData = this.layoutManager.adaptDataForSize(data, size);
  256. // 转换为ExtendedWidgetData
  257. const adaptedData: ExtendedWidgetData = {
  258. isPlaying: formattedData.isPlaying,
  259. isPaused: formattedData.isPaused,
  260. isLoading: formattedData.isLoading,
  261. songTitle: formattedData.songTitle,
  262. songArtist: formattedData.songArtist,
  263. songAlbum: formattedData.songAlbum,
  264. coverImage: formattedData.coverImage,
  265. currentTime: formattedData.currentTime,
  266. totalTime: formattedData.totalTime,
  267. progressPercentage: formattedData.progressPercentage,
  268. hasNext: formattedData.hasNext,
  269. hasPrevious: formattedData.hasPrevious,
  270. showProgress: formattedData.showProgress,
  271. showCover: formattedData.showCover,
  272. widgetSize: formattedData.widgetSize,
  273. timestamp: formattedData.timestamp,
  274. imgName: formattedData.imgName,
  275. formImages: formattedData.formImages
  276. };
  277. // 使用统一的图片处理方法
  278. this.updateWidgetWithImage(formId, adaptedData, retryCount);
  279. } catch (error) {
  280. hilog.error(0x0000, TAG, `Heanup widget ${formId} process error: ${error}`);
  281. // 如果是处理错误,也尝试重试
  282. if (retryCount < 2) {
  283. setTimeout(() => {
  284. this.updateSingleWidget(formId, size, data, retryCount + 1);
  285. }, 1000 * (retryCount + 1));
  286. }
  287. }
  288. }
  289. /**
  290. * 直接更新卡片(无网络图片)
  291. */
  292. private updateWidgetDirectly(formId: string, adaptedData: ExtendedWidgetData, retryCount: number = 0): void {
  293. const formData = formBindingData.createFormBindingData(adaptedData);
  294. formProvider.updateForm(formId, formData).then(() => {
  295. }).catch(() => {
  296. hilog.error(0x0000, TAG, `Heanup widget ${formId} update failed, retry count: ${retryCount}`);
  297. // 重试机制:最多重试2次
  298. if (retryCount < 2) {
  299. setTimeout(() => {
  300. this.updateWidgetDirectly(formId, adaptedData, retryCount + 1);
  301. }, 1000 * (retryCount + 1)); // 递增延迟
  302. }
  303. });
  304. }
  305. /**
  306. * 统一处理图片更新
  307. */
  308. private async updateWidgetWithImage(formId: string, adaptedData: ExtendedWidgetData,
  309. retryCount: number = 0): Promise<void> {
  310. try {
  311. if (!adaptedData.coverImage || adaptedData.coverImage.trim() === '') {
  312. // 没有封面图片,直接更新
  313. this.updateWidgetDirectly(formId, adaptedData, retryCount);
  314. return;
  315. }
  316. if (this.isNetworkUrl(adaptedData.coverImage)) {
  317. // 处理网络图片
  318. await this.updateWidgetWithNetworkImage(formId, adaptedData, retryCount);
  319. } else if (this.isLocalFileUri(adaptedData.coverImage)) {
  320. // 处理本地文件URI
  321. await this.updateWidgetWithLocalImage(formId, adaptedData, retryCount);
  322. } else {
  323. // 其他情况,可能是相对路径或其他格式,直接使用
  324. this.updateWidgetDirectly(formId, adaptedData, retryCount);
  325. }
  326. } catch (error) {
  327. hilog.error(0x0000, TAG, `Heanup widget ${formId} image update error: ${error}`);
  328. // 失败时使用默认数据
  329. const dataWithoutImage: ExtendedWidgetData = copyWidgetData(adaptedData, { coverImage: '' });
  330. this.updateWidgetDirectly(formId, dataWithoutImage, retryCount);
  331. }
  332. }
  333. /**
  334. * 处理本地文件URI图片
  335. */
  336. private async updateWidgetWithLocalImage(formId: string, adaptedData: ExtendedWidgetData,
  337. retryCount: number = 0): Promise<void> {
  338. try {
  339. const localFileUri: string = adaptedData.coverImage;
  340. // 先用无图片的数据快速更新一次,确保界面响应性
  341. const dataWithoutImage: ExtendedWidgetData = copyWidgetData(adaptedData, {
  342. coverImage: '',
  343. imgName: '',
  344. formImages: undefined
  345. });
  346. this.updateWidgetDirectly(formId, dataWithoutImage, 0);
  347. // 处理本地图片文件
  348. const fileName = await this.processLocalImageFile(localFileUri);
  349. if (fileName) {
  350. try {
  351. // 按照官方文档要求,准备 formImages 和文件描述符
  352. const imageMap: Record<string, number> = {};
  353. const fileDescriptor = await this.getImageFileDescriptor(fileName);
  354. imageMap[fileName] = fileDescriptor;
  355. // 按照官方文档要求,imgName 必须与 formImages 中的 key 相同
  356. const dataWithImage: ExtendedWidgetData = copyWidgetData(adaptedData, {
  357. coverImage: '', // 清空原路径
  358. imgName: fileName, // 设置图片名称用于 memory:// 协议
  359. formImages: imageMap // 必填字段,不可缺省
  360. });
  361. const formDataWithImage = formBindingData.createFormBindingData(dataWithImage);
  362. await formProvider.updateForm(formId, formDataWithImage);
  363. } catch (fdError) {
  364. hilog.error(0x0000, TAG, `Heanup widget ${formId} failed to get file descriptor: ${fdError}`);
  365. // 文件描述符获取失败,使用默认图片
  366. this.updateWidgetDirectly(formId, dataWithoutImage, 0);
  367. }
  368. } else {
  369. hilog.warn(0x0000, TAG, `Heanup widget ${formId} failed to process local image, using default`);
  370. // 图片处理失败,使用默认图片
  371. this.updateWidgetDirectly(formId, dataWithoutImage, 0);
  372. }
  373. } catch (error) {
  374. hilog.error(0x0000, TAG, `Heanup widget ${formId} local image update error: ${error}`);
  375. // 失败后回退到无图片模式
  376. const dataWithoutImage: ExtendedWidgetData = copyWidgetData(adaptedData, {
  377. coverImage: '',
  378. imgName: '',
  379. formImages: undefined
  380. });
  381. this.updateWidgetDirectly(formId, dataWithoutImage, retryCount);
  382. }
  383. }
  384. /**
  385. * 使用网络图片更新卡片
  386. */
  387. private async updateWidgetWithNetworkImage(formId: string, adaptedData: ExtendedWidgetData,
  388. retryCount: number = 0): Promise<void> {
  389. try {
  390. const imageUrl: string = adaptedData.coverImage;
  391. // 先用无图片的数据快速更新一次
  392. const dataWithoutImage: ExtendedWidgetData = copyWidgetData(adaptedData, { coverImage: '' });
  393. this.updateWidgetDirectly(formId, dataWithoutImage, 0);
  394. // 下载图片
  395. const fileName = await this.downloadNetworkImage(imageUrl);
  396. if (fileName) {
  397. // 准备包含图片的数据
  398. const imageMap: Record<string, number> = {};
  399. imageMap[fileName] = await this.getImageFileDescriptor(fileName);
  400. const dataWithImage: ExtendedWidgetData = copyWidgetData(adaptedData, {
  401. coverImage: '', // 清空URL
  402. imgName: fileName, // 设置图片名称用于memory://协议
  403. formImages: imageMap
  404. });
  405. const formDataWithImage = formBindingData.createFormBindingData(dataWithImage);
  406. await formProvider.updateForm(formId, formDataWithImage);
  407. } else {
  408. hilog.warn(0x0000, TAG, `Heanup widget ${formId} failed to download image, using default`);
  409. // 图片下载失败,使用默认图片
  410. this.updateWidgetDirectly(formId, dataWithoutImage, 0);
  411. }
  412. } catch (error) {
  413. hilog.error(0x0000, TAG, `Heanup widget ${formId} network image update error: ${error}`);
  414. // 失败后回退到无图片模式
  415. const dataWithoutImage: ExtendedWidgetData = copyWidgetData(adaptedData, { coverImage: '' });
  416. this.updateWidgetDirectly(formId, dataWithoutImage, retryCount);
  417. }
  418. }
  419. /**
  420. * 检查是否为网络URL
  421. */
  422. private isNetworkUrl(url: string): boolean {
  423. return url.startsWith('http://') || url.startsWith('https://');
  424. }
  425. /**
  426. * 检查是否为本地文件URI
  427. */
  428. private isLocalFileUri(url: string): boolean {
  429. return url.startsWith('file://');
  430. }
  431. /**
  432. * 处理本地图片文件,将其复制到卡片可访问的临时目录
  433. */
  434. private async processLocalImageFile(fileUri: string): Promise<string | null> {
  435. try {
  436. // 检查缓存
  437. if (this.imageCache.has(fileUri)) {
  438. const fileName = this.imageCache.get(fileUri)!;
  439. // 验证缓存文件是否仍然存在 - 使用 FormExtensionAbility 的 tempDir
  440. const formTempDir = this.context.getApplicationContext().tempDir;
  441. const tempFilePath = `${formTempDir}/${fileName}`;
  442. if (fileIo.accessSync(tempFilePath)) {
  443. return fileName;
  444. } else {
  445. // 缓存文件已不存在,清除缓存记录
  446. this.imageCache.delete(fileUri);
  447. hilog.warn(0x0000, TAG, `Cached file no longer exists, will reprocess: ${fileName}`);
  448. }
  449. }
  450. // 检查是否正在处理
  451. if (this.downloadingImages.has(fileUri)) {
  452. const existingPromise = this.downloadingImages.get(fileUri);
  453. if (existingPromise) {
  454. return await existingPromise;
  455. }
  456. }
  457. // 开始处理本地文件
  458. const processPromise = this.performLocalImageCopy(fileUri);
  459. this.downloadingImages.set(fileUri, processPromise);
  460. const fileName = await processPromise;
  461. // 清理处理状态
  462. this.downloadingImages.delete(fileUri);
  463. if (fileName) {
  464. this.imageCache.set(fileUri, fileName);
  465. }
  466. return fileName;
  467. } catch (error) {
  468. hilog.error(0x0000, TAG, `Failed to process local image ${fileUri}: ${error}`);
  469. this.downloadingImages.delete(fileUri);
  470. return null;
  471. }
  472. }
  473. /**
  474. * 执行本地图片文件复制
  475. */
  476. private async performLocalImageCopy(fileUri: string): Promise<string | null> {
  477. try {
  478. // 转换 file:// URI 为实际文件路径
  479. const realPath = fileUri.replace('file://', '');
  480. // 检查源文件是否存在
  481. if (!fileIo.accessSync(realPath)) {
  482. hilog.error(0x0000, TAG, `Source image file does not exist: ${realPath}`);
  483. return null;
  484. }
  485. // 生成目标文件名(包含时间戳和随机数,确保每次都不同)
  486. const fileExtension = this.getFileExtension(realPath) || 'jpg';
  487. const fileName = `widget_local_${Date.now()}_${Math.random().toString(36).substr(2, 9)}.${fileExtension}`;
  488. // 使用 FormExtensionAbility 的 tempDir(官方文档要求)
  489. const formTempDir = this.context.getApplicationContext().tempDir;
  490. const tempFilePath = `${formTempDir}/${fileName}`;
  491. // 复制文件到临时目录
  492. fileIo.copyFileSync(realPath, tempFilePath);
  493. return fileName;
  494. } catch (error) {
  495. hilog.error(0x0000, TAG, `Failed to copy local image: ${error}`);
  496. return null;
  497. }
  498. }
  499. /**
  500. * 获取文件扩展名
  501. */
  502. private getFileExtension(filePath: string): string | null {
  503. const lastDotIndex = filePath.lastIndexOf('.');
  504. if (lastDotIndex === -1 || lastDotIndex === filePath.length - 1) {
  505. return null;
  506. }
  507. return filePath.substring(lastDotIndex + 1).toLowerCase();
  508. }
  509. /**
  510. * 下载网络图片
  511. */
  512. private async downloadNetworkImage(imageUrl: string): Promise<string | null> {
  513. try {
  514. // 检查缓存
  515. if (this.imageCache.has(imageUrl)) {
  516. const fileName = this.imageCache.get(imageUrl)!;
  517. return fileName;
  518. }
  519. // 检查是否正在下载
  520. if (this.downloadingImages.has(imageUrl)) {
  521. const existingPromise = this.downloadingImages.get(imageUrl);
  522. if (existingPromise) {
  523. return await existingPromise;
  524. }
  525. }
  526. // 开始下载
  527. const downloadPromise = this.performImageDownload(imageUrl);
  528. this.downloadingImages.set(imageUrl, downloadPromise);
  529. const fileName = await downloadPromise;
  530. // 清理下载状态
  531. this.downloadingImages.delete(imageUrl);
  532. if (fileName) {
  533. this.imageCache.set(imageUrl, fileName);
  534. }
  535. return fileName;
  536. } catch (error) {
  537. hilog.error(0x0000, TAG, `Failed to download image ${imageUrl}: ${error}`);
  538. this.downloadingImages.delete(imageUrl);
  539. return null;
  540. }
  541. }
  542. /**
  543. * 执行图片下载
  544. */
  545. private async performImageDownload(imageUrl: string): Promise<string | null> {
  546. try {
  547. // 创建HTTP请求
  548. const httpRequest = http.createHttp();
  549. // 设置超时时间为3秒,适合卡片的快速响应需求
  550. const response = await httpRequest.request(imageUrl, {
  551. method: http.RequestMethod.GET,
  552. expectDataType: http.HttpDataType.ARRAY_BUFFER,
  553. connectTimeout: 3000,
  554. readTimeout: 3000
  555. });
  556. if (response.responseCode === http.ResponseCode.OK && response.result) {
  557. // 生成文件名(确保每次都不同,符合官方文档要求)
  558. const fileName = `widget_cover_${Date.now()}_${Math.random().toString(36).substr(2, 9)}.jpg`;
  559. // 使用 FormExtensionAbility 的 tempDir(官方文档要求)
  560. const formTempDir = this.context.getApplicationContext().tempDir;
  561. const filePath = `${formTempDir}/${fileName}`;
  562. // 保存文件
  563. const file = fileIo.openSync(filePath, fileIo.OpenMode.READ_WRITE | fileIo.OpenMode.CREATE);
  564. await fileIo.write(file.fd, response.result as ArrayBuffer);
  565. fileIo.closeSync(file);
  566. httpRequest.destroy();
  567. return fileName;
  568. } else {
  569. hilog.error(0x0000, TAG, `HTTP request failed: ${response.responseCode}`);
  570. httpRequest.destroy();
  571. return null;
  572. }
  573. } catch (error) {
  574. hilog.error(0x0000, TAG, `Download error: ${error}`);
  575. return null;
  576. }
  577. }
  578. /**
  579. * 获取图片文件描述符
  580. */
  581. private async getImageFileDescriptor(fileName: string): Promise<number> {
  582. try {
  583. // 使用 FormExtensionAbility 的 tempDir(官方文档要求)
  584. const formTempDir = this.context.getApplicationContext().tempDir;
  585. const filePath = `${formTempDir}/${fileName}`;
  586. const file = fileIo.openSync(filePath, fileIo.OpenMode.READ_ONLY);
  587. // 注意:文件描述符会被系统自动管理,不需要手动关闭
  588. // 系统会在卡片更新完成后自动关闭文件描述符
  589. return file.fd;
  590. } catch (error) {
  591. hilog.error(0x0000, TAG, `Failed to get file descriptor for ${fileName}: ${error}`);
  592. throw new Error(`Failed to get file descriptor for ${fileName}: ${error}`);
  593. }
  594. }
  595. /**
  596. * 获取默认卡片数据
  597. */
  598. private getDefaultWidgetData(): WidgetData {
  599. return {
  600. playState: {
  601. isPlaying: false,
  602. isPaused: true,
  603. isLoading: false
  604. },
  605. currentSong: {
  606. id: '',
  607. title: '暂无播放',
  608. artist: '未知艺术家',
  609. album: '未知专辑',
  610. coverImagePath: '',
  611. duration: 0
  612. },
  613. progress: {
  614. currentPosition: 0,
  615. duration: 0,
  616. percentage: 0,
  617. currentTimeText: '00:00',
  618. totalTimeText: '00:00'
  619. },
  620. playlist: {
  621. hasNext: false,
  622. hasPrevious: false,
  623. currentIndex: 0,
  624. totalCount: 0
  625. },
  626. config: {
  627. size: 'medium' as WidgetSize,
  628. theme: 'auto' as string,
  629. showProgress: true,
  630. showCover: true
  631. }
  632. };
  633. }
  634. /**
  635. * 初始化卡片
  636. */
  637. private async initializeWidget(formId: string, widgetSize: WidgetSize): Promise<void> {
  638. try {
  639. // 获取当前播放状态
  640. const currentState = await this.playerControlService.getCurrentPlayState();
  641. // 适配数据到指定尺寸
  642. const adaptedData = this.layoutManager.adaptDataForSize(currentState, widgetSize);
  643. await this.widgetDataManager?.saveWidgetData(formId, adaptedData);
  644. // 立即更新一次卡片数据
  645. await this.updateWidgetData(formId);
  646. } catch (error) {
  647. hilog.error(0x0000, TAG, `Failed to initialize widget ${formId}: ${error}`);
  648. }
  649. }
  650. /**
  651. * 更新卡片数据(简化版本)
  652. */
  653. private async updateWidgetData(formId: string): Promise<void> {
  654. try {
  655. const currentState = await this.playerControlService.getCurrentPlayState();
  656. // 获取卡片当前尺寸
  657. const currentSize = this.globalWidgetManager.getWidgetSize(formId) || WidgetSize.MEDIUM;
  658. // 适配数据到当前尺寸并直接更新
  659. const adaptedData = this.layoutManager.adaptDataForSize(currentState, currentSize);
  660. const formData = formBindingData.createFormBindingData(adaptedData);
  661. await formProvider.updateForm(formId, formData);
  662. } catch (error) {
  663. hilog.error(0x0000, TAG, `Failed to update widget ${formId}: ${error}`);
  664. }
  665. }
  666. /**
  667. * 处理表单尺寸变化
  668. */
  669. private async handleFormSizeChange(formId: string, oldSize: WidgetSize, newSize: WidgetSize): Promise<void> {
  670. try {
  671. // 获取当前播放状态
  672. const currentState = await this.playerControlService.getCurrentPlayState();
  673. // 使用适配器处理尺寸变化
  674. const adaptedData = this.sizeAdapter.handleSizeChange(formId, oldSize, newSize, currentState);
  675. // 更新卡片数据
  676. await this.widgetDataManager?.updateWidget(formId, adaptedData);
  677. } catch (error) {
  678. hilog.error(0x0000, TAG, `Failed to handle form size change: ${error}`);
  679. }
  680. }
  681. /**
  682. * 保存 Form ID 到持久化存储
  683. */
  684. private async saveFormIdToPersistence(formId: string): Promise<void> {
  685. try {
  686. const preferencesUtil = PreferencesUtil.getInstance();
  687. const prefs = await preferencesUtil.getPreferences(this.context);
  688. await preferencesUtil.addFormId(prefs, formId);
  689. } catch (error) {
  690. hilog.error(0x0000, TAG, `❌ Failed to save Form ID: ${error}`);
  691. }
  692. }
  693. /**
  694. * 从持久化存储中移除 Form ID
  695. */
  696. private async removeFormIdFromPersistence(formId: string): Promise<void> {
  697. try {
  698. const preferencesUtil = PreferencesUtil.getInstance();
  699. const prefs = await preferencesUtil.getPreferences(this.context);
  700. await preferencesUtil.removeFormId(prefs, formId);
  701. } catch (error) {
  702. hilog.error(0x0000, TAG, `❌ Failed to remove Form ID: ${error}`);
  703. }
  704. }
  705. }