您的当前位置:首页正文

HarmonyOS开发实例:【自定义Emitter】

2024-11-25 来源:个人技术集锦

介绍

本示例使用[Emitter]实现事件的订阅和发布,使用[自定义弹窗]设置广告信息。

效果预览

使用说明

代码解析

HarmonyOS&OpenHarmony文档紫料添加v
mau123789直接拿取

entry/src/main/ets/
|---components
|   |---BottomNavigation.ets                    // 底部按钮导航栏
|   |---Choice.ets                              // 商品规格选择
|   |---EventsDialog.ets                        // 广告弹窗
|   |---Information.ets                         // 详细信息页面
|   |---Valueation.ets                          // 价格页面
|---mock
|   |---DetailData.ets                          // 商品详情数据
|   |---ProductsData.ets                        // 产品列表数据
|---model
|   |---DetailMode.ets                          // 商品详情数据结构
|   |---GoodsModel.ets                          // 商品数据结构
|---pages
|   |---Detail.ets                              // 商品详情
|   |---Index.ets                               // 首页
|   |---ShopCart.ets                            // 购物车
|---shoppingCart
|   |---Cart.ets                                // 购物车
|   |---FavorGoodlist.ets                       // 推荐列表
|---util
|   |---Logger.ets                              // 日志工具
feature/emitter/src/main/ets/
|---common
|   |---EmitterConst.ts                         // 事件通知常量
|---components
|   |---feature
|   |   |---CustomEmitter.ets                   // 封装事件通知类

具体实现

  • 订阅事件通知在CustomEmitter中实现,源码参考[CustomEmitter.ets]
/*

 * Copyright (c) 2022 Huawei Device Co., Ltd.

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *     http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */



import emitter from '@ohos.events.emitter';

import { EmitterConst } from '../../common/EmitterConst';

import Base from '@ohos.base';



class GoodsListInner {

  id: number = 0

}



class GoodsList {

  data: GoodsListInner = {

    id: 0

  }

}



export class CustomEmitter {

  shoppingCartGoodsList: GoodsList[] = [];



  // 单次订阅回调

  public showEventsDialog(callback: Base.Callback<emitter.EventData>) {

    let dialogShowEventsId: emitter.InnerEvent = {

      eventId: EmitterConst.DIALOG_EVENT_ID

    };

    let dialogShowEventsData: emitter.EventData = {

      data: {

        id: EmitterConst.DIALOG_EVENT_ID,

      }

    };

    // 单次订阅事件--广告

    emitter.once(dialogShowEventsId, callback);

    // 事件发布

    emitter.emit(dialogShowEventsId, dialogShowEventsData);

  }



  // 单次订阅回调(eventId为string类型)

  public closeEventsDialog(callback: Base.Callback<emitter.EventData>) {

    let dialogCloseEventsData: emitter.EventData = {

      data: {

        id: EmitterConst.CLOSE_DIALOG_EVENT_ID

      }

    };

    // 单次订阅事件--关闭广告

    emitter.once(EmitterConst.CLOSE_DIALOG_EVENT_ID, callback);

    // 事件发布

    emitter.emit(EmitterConst.CLOSE_DIALOG_EVENT_ID, dialogCloseEventsData);

  }



  // 持久化订阅的事件回调

  public setShoppingCartGoodsList(callback: (eventData: emitter.EventData) => void) {

    let addGoodDataId: emitter.InnerEvent = {

      eventId: EmitterConst.ADD_EVENT_ID

    };

    // 以持久化方式订阅购物车添加事件并接收事件回调

    emitter.off(EmitterConst.ADD_EVENT_ID);



    emitter.on(addGoodDataId, (eventData: emitter.EventData) => {

      callback(eventData);

    });

  }



  // 持久化订阅的事件回调(eventId为string类型)

  public deleteShoppingCartGoodsList(callback: (eventData: emitter.EventData) => void) {

    // 以持久化方式订阅购物车删除事件并接收事件回调

    emitter.off(EmitterConst.DELETE_EVENT_ID);

    emitter.on(EmitterConst.DELETE_EVENT_ID, (eventData: emitter.EventData) => {

      callback(eventData);

    });

  }



  public addGoods(goodId: number) {

    let addToShoppingCartId: emitter.InnerEvent = {

      eventId: EmitterConst.ADD_EVENT_ID

    };

    let shoppingCartData: emitter.EventData = {

      data: {

        id: goodId

      }

    };

    // 持续订阅发布事件

    emitter.emit(addToShoppingCartId, shoppingCartData);

  }



  public deleteGoods(listItemId: number) {

    console.info("setShoppingCartGoodsList goodId" + JSON.stringify(listItemId))

    let shoppingCartData: emitter.EventData = {

      data: {

        id: listItemId,

      }

    };

    // 持续订阅发布事件

    emitter.emit(EmitterConst.DELETE_EVENT_ID, shoppingCartData);

  }



  // 以持久化方式订阅购物车购买事件

  public listenerEvents() {

    emitter.on(EmitterConst.BUY_EVENT_ID, (eventData: emitter.EventData) => {

    });

  }



  // 获取购买事件订阅者数量并将结果返回

  public getListenerCounts(callback: (counts: number) => void) {

    callback(emitter.getListenerCount(EmitterConst.BUY_EVENT_ID));

  }



  // 取消订阅购买事件后将购买事件订阅者数量结果返回

  public clearListenerCounts(callback: (counts: number) => void) {

    emitter.off(EmitterConst.BUY_EVENT_ID);

    callback(emitter.getListenerCount(EmitterConst.BUY_EVENT_ID));

  }

}
  • 广告弹窗:使用Emitter的事件单次订阅emitter.once(eventId,call),eventId为number类型,单次订阅CustomDialogController弹窗事件,弹窗触发后自动取消订阅。
  • 关闭广告弹窗:使用Emitter的事件单次订阅emitter.once(eventId,call),eventId为string类型,单次订阅CustomDialogController弹窗事件,弹窗关闭后自动取消订阅。
  • 购物车添加商品:使用Emitter.on持续订阅商品添加事件,eventId为number类型,添加商品时更新购物车商品列表。
  • 购物车删除商品:使用Emitter.on持续订阅商品删除事件,eventId为string类型,删除商品时更新购物车商品列表。
  • 购物数量:使用Emitter.getListenerCount获取购买事件订阅者数量,进入购物车页面显示数量结果,清空时取消订阅,结果为0。
显示全文