沉舟侧畔千帆进，病树前头万木春。这篇文章主要讲述OpenHarmony 通话应用源码剖析相关的知识，希望能为你提供帮助。
作者：赖尧
一、简介
?通话应用主要提供通话相关用户交互界面，根据电话服务子系统提供的通话数据和状态显示语音去电界面、语音来电界面、语音通话界面、语音多方通话界面、会议通话界面、会议管理界面；并根据用户界面上的操作完成接听、挂断、拒接、静音、保持、音频通道切换、DTMF键盘指令等下发电话服务子系统。
二、架构图

文章图片

三、代码结构

/applications_call ├── callui# 通话应用主Ability，提供拉起应用入口 │└── src │└── main │├── ets# ets代码目录 │├── default │├── assets# 图片资源 │├── common# 公共组件或方法配置目录 │├── components# 公共组件 │├── configs# 应用配置对象目录 │├── constant# 应用常量对象目录 │├── utils# 公共方法 │├── model# Model层代码目录 │├── pages# 通话页面目录 |├── app.ets# 全局ets逻辑和应用生命周期管理文件 │├── ServiceAbility# 服务ability │├── callManagerService.ets# ServiceAbility方法 │├── service.ts# ServiceAbility方法 │├── telephonyApi.ets# ServiceAbility方法 │├── resources# 资源配置文件存放目录 |├── base# 默认图片资源，字体大小，颜色资源存放目录 |├── zh_CN# 中文语言场景资源内容存放目录 │├── config.json# 全局配置文件 ├── figures# 架构图目录 │└── callui_en.png# 架构设计图 ├── signature# 签名证书文件目录 │└── com.ohos.callui.p7b# 签名文件 ├── LICENSE# 许可证

四、流程图

文章图片

五、时序图

文章图片

六、源码分析
1、启动通话常驻服务开机启动 通话应用常驻服务PA， 由元能力子系统拉起 代码路径/foundation/aafwk/standard/services/abilitymgr/src/ability_manager_service.cpp
```c++
void AbilityManagerService::StartingPhoneServiceAbility()

HILOG_DEBUG(" %publics" , func);
auto bms = GetBundleManager();
CHECK_POINTER_IS_NULLPTR(bms);

AppExecFwk::AbilityInfo phoneServiceInfo; Want phoneServiceWant; phoneServiceWant.SetElementName(AbilityConfig::PHONE_SERVICE_BUNDLE_NAME, AbilityConfig::PHONE_SERVICE_ABILITY_NAME); auto userId = GetUserId(); int attemptNums = 1; HILOG_DEBUG("%publics, QueryAbilityInfo, userId is %publicd", __func__, userId); IN_PROCESS_CALL_WITHOUT_RET( while (!(bms-> QueryAbilityInfo(phoneServiceWant, OHOS::AppExecFwk::AbilityInfoFlag::GET_ABILITY_INFO_DEFAULT, userId, phoneServiceInfo)) & & attemptNums < = MAX_NUMBER_OF_CONNECT_BMS) HILOG_INFO("Waiting query phone service ability info completed."); usleep(REPOLL_TIME_MICRO_SECONDS); attemptNums++; ); (void)StartAbility(phoneServiceWant, userId, DEFAULT_INVAL_VALUE);

##### 2、服务注册监听service ability 应用启动加载入口文件service.ts文件， 执行onStart钩子函数， 实例化CallManagerService类时添加注册监听， registerCallStateCallback 调用注册电话子系统接口function on(type: callDetailsChange, callback: Callback< CallAttributeOptions> ): void; 添加注册监听子系统上报的状态

/**

• add register listener
  */
  addRegisterListener()
  this.mTelephonyCall.registerCallStateCallback(this.getCallData.bind(this));
  
  public registerCallStateCallback(callBack)
  call.on(callDetailsChange, (data) =>
  if (!data)
  HiLog.i(TAG,prefixLog + call.on registerCallStateCallback + JSON.stringify(data))
  return;
  
  HiLog.i(TAG,prefixLog + call.on registerCallStateCallback callState:+ JSON.stringify(data.callState))
  callBack(data);
  );
  
  

根据上报通话当前状态校验是来电还是去电如果是就做拉起操作， 否则通话发布公共事件；

getCallData(callData)
this.callData = https://www.songbingjia.com/android/callData;
this.updateCallList();
const callState = this.callData;

/** * single call or dialing pull up the application */ if ((callState === CALL_STATUS_INCOMING & & this.callList.length === 1) || callState === CALL_STATUS_DIALING) this.startAbility(callData); else if (callState !== CALL_STATUS_DISCONNECTING) this.publishData(callData);

publishData(callData)
commonEvent.publish(callui.event.callDetailsChange,
bundleName: CALL_BUNDLE_NAME,
isOrdered: false,
data: JSON.stringify(callData)
, (res) =>
HiLog.i(TAG, " callUI service commonEvent.publish callback res : %s" )
);

##### 3、服务注册公共事件广播在启动注册监听后同时也注册添加公共事件广播， 其中callui.event.callEvent事件监听通话FA获取初始化数据， callui.event.click 事件监听systemui 通知栏操作按钮事件；

const events = [callui.event.callEvent, callui.event.click];
async addSubscriber()
subscriber = await new Promise((resolve) =>
commonEvent.createSubscriber(
events
, (err, data) =>
HiLog.i(TAG, " addSubscriber%s" )
resolve(data);
);
);

commonEvent.subscribe(subscriber, (err, res) => if (err.code === 0) if (res.event === events[0]) const obj = JSON.parse(res.data); if (obj & & obj.key === getInitCallData) this.publishData(this.callData); if (res.event === events[1]) const callId,btnType = res.parameters this.btnclickAgent(callId, btnType)else HiLog.i(TAG, "callui service commonEvent.subscribe failed err : %s" + JSON.stringify(err))subscriber.finishCommonEvent() .then(() => HiLog.i(TAG, "addSubscriber finishCommonEvent : %s") ) );

##### 4、拉起通话应用初始化数据在service中通过 PA.startAbility方法拉起 通话FA应用， 通话应用FA在启动入口页面index， 实例化CallManager类，调用initCallData方法， 获取初始通话数据， 调用update更新通话状态；

private initCallData()
featureAbility.getWant().then((want) =>
if (want & & want.parameters & & (callState in want.parameters))
this.update(want.parameters);
HiLog.i(TAG, " initCallData featureAbility.getWant :%s" )
else
this.mCallServiceProxy.publish(
key: getInitCallData,
params: []
);

)
.catch((error) =>
HiLog.i(TAG, " initCallData catch error :%s" + JSON.stringify(error))
);

##### 5、更新通话状态在CallManger类实例化时候， 添加公共事件广播监听callui.event.callDetailsChange, 应用中订阅到数据调用callDataManager中的update方法，更新callData和callList校验通话状态， 是单方通话或者是多方通话；

const events = [callui.event.callDetailsChange];
private async registerSubscriber()
subscriber = await new Promise((resolve) =>
commonEvent.createSubscriber(
events
,
(err, data) =>
resolve(data);

);
);

commonEvent.subscribe(subscriber, (err, res) => if (err.code === 0) const callData = https://www.songbingjia.com/android/JSON.parse(res.data); this.callData = callData HiLog.i(TAG,"commonEvent subscribe : %s") if (callData) this.update(callData); HiLog.i(TAG, "commonEvent subscribe : %s") else HiLog.i(TAG, "commonEvent.subscribe err: %s" + JSON.stringify(err)));

async update(callData)
if (globalThis.permissionFlag)
await this.contactManager.getContactInfo(callData)

this.mCallDataManager.update(callData);
call.formatPhoneNumber(callData.accountNumber, (err, data) =>
if (data =https://www.songbingjia.com/android/== undefined)
AppStorage.SetOrCreate(" AccountNumber" , callData.accountNumber)
else
AppStorage.SetOrCreate(" AccountNumber" , data)

);
HiLog.i(TAG, " update : " )

public update(callData)
constcallState, callId= callData;
const targetObj = this.callList.find((v) => v.callId === callId);
HiLog.i(TAG, " update : " )
if (targetObj)
Object.assign(targetObj,
...callData
);
else
this.addCallList(
...callData
);

if (callData.callState === CallStateConst.CALL_STATUS_ACTIVE) this.updateCallTimeList(callData); const singleCallState = callState === CallStateConst.CALL_STATUS_ACTIVE || callState === CallStateConst.CALL_STATUS_WAITING || this.callList.length === 1; const multiCallState = (callState === CallStateConst.CALL_STATUS_DIALING || callState === CallStateConst.CALL_STATUS_ALERTING) & & this.callList.length > 1; if (singleCallState || multiCallState) this.mCallStateManager.update(callData); this.callStateChange(callState); if (callState === CallStateConst.CALL_STATUS_DISCONNECTED) if (this.callList.length === 1) this.NotificationManager.cancelNotification(); AppStorage.Get< NotificationManager> (notificationManager).sendCapsuleNotification(callData, true); app.terminate(); else this.removeCallById(callId); const activeCallData = https://www.songbingjia.com/android/this.callList.find((v) => v.callState === CallStateConst.CALL_STATUS_ACTIVE); if (activeCallData) this.mCallStateManager.update(activeCallData); this.callStateChange(activeCallData); else if (this.callList[0]) this.mCallStateManager.update(this.callList[0]); this.callStateChange(this.callList[0].callState);

通话状态callState 包含的类型：

// calling
public static CALL_STATUS_ACTIVE: number = 0; // 通话中
// State keeping
public static CALL_STATUS_HOLDING: number = 1; // 保持
// Dialing
public static CALL_STATUS_DIALING: number = 2; // 正在拨号
// The other party is ringing
public static CALL_STATUS_ALERTING: number = 3; // 对方已振铃
// Call from the other party
public static CALL_STATUS_INCOMING: number = 4; // 来电
// Waiting for third-party calls
public static CALL_STATUS_WAITING: number = 5; // 三方来电等待
// Hung up
public static CALL_STATUS_DISCONNECTED: number = 6; // 已挂断
// Hanging up
public static CALL_STATUS_DISCONNECTING: number = 7; // 正在挂断

##### 6、发布通知在通话应用切换到后台， 会触发onPageHide钩子函数发送通知， 其中notificationManager.sendNotification方法发送按钮通知, notificationManager.sendCapsuleNotification方法发送的是胶囊通知；发布按钮通知， 配置actionButtons， 其中消息类型contentType 等于 notification.ContentType.NOTIFICATION_CONTENT_LONG_TEXT, 表示长消息类型， want下的 action配置为callui.event.click, 点击通知按钮会触发systemUI 中的WantAgent.trigger 系统会发布公共事件callui.event.click，在通话service中订阅公共事件callui.event.click响应的数据

onPageHide()
HiLog.i(TAG, " onPageHide :" )
this.appInactiveState = true;
const callState, accountNumber, contactName, callId = this.callData;
let fool = (callState !== CallStateConst.callStateObj.CALL_STATUS_DISCONNECTED & & callId)
if (callState !== CallStateConst.callStateObj.CALL_STATUS_DISCONNECTED & & callId)
let text = contactName ++ accountNumber +;
if (!contactName)
text = accountNumber +;

this.notificationManager.sendNotification(text, this.callData);
this.notificationManager.sendCapsuleNotification(this.callData, true);
HiLog.i(TAG, " onPageHide end :" )


// 发布通知
async sendNotification(text, callData)
const callState, callId = callData;
const actionBtnKeys = this.getMapObj(callState) || [];
const START_ABILITY, SEND_COMMON_EVENT = wantAgent.OperationType;
const wantAgentObj = await this.getWantAgent(callData, START_ABILITY);
notificationRequest.wantAgent = wantAgentObj;
notificationRequest.actionButtons = [];
if (actionBtnKeys.length)
for (const key of actionBtnKeys)
const data = https://www.songbingjia.com/android/
callId, btnType: key
;
const wantAgentObj = await this.getWantAgent(data, SEND_COMMON_EVENT);
resourceManager.getResourceManager((error, mgr) =>
if (error != null)
return;

mgr.getString(textMap[key].id, (error, value) =>
if (error != null)
else
notificationRequest.actionButtons.push(
title: value,
wantAgent: wantAgentObj
);
Object.assign(notificationRequest.content.longText,
title: text,
expandedTitle: text
);
notification.publish(notificationRequest);

);
);


HiLog.i(TAG, " sendNotification end : " )

// 发送胶囊通知
sendCapsuleNotification(callData, isBackground)
HiLog.i(TAG, " sendCapsuleNotification isBackground : %s" + JSON.stringify(isBackground))
callData.startTime = (callData.startTime)
HiLog.i(TAG, " sendCapsuleNotification callData.startTime: " )
const callState, startTime = callData;
commonEvent.publish(CAPSULE_EVENT_CALL_UI,
bundleName: com.ohos.callui,
isOrdered: false,
data: JSON.stringify(
callState,
startTime: startTime*1000,
isBackground,
wantBundleName: CALL_BUNDLE_NAME,
wantAbilityName: CALL_ABILITY_NAME
)
, (res) =>
HiLog.i(TAG, " callUI app commonEvent.publish CAPSULE_EVENT_CALL_UI callback res: %s" )
);

### 七、列举调用电话子系统接口1、来电接听， 拒接；通话中挂断， 保持， 取消保持接口调用；

// 接听
public acceptCall = function (callId)
call.answer(callId).then((res) =>
HiLog.i(TAG,prefixLog +" call.answer : %s" )
).catch((err) =>
HiLog.i(TAG, prefixLog + " call.answer catch : %s" + JSON.stringify(err))
);
;
// 拒接
public rejectCall = function (callId, isSendSms = false, msg = )
// 普通拒接和短信拒接
const rejectCallPromise = isSendSms ? call.reject(callId, messageContent: msg) : call.reject(callId);
rejectCallPromise.then((res) =>
HiLog.i(TAG,prefixLog +" then:rejectCall : %s" )
)
.catch((err) =>
HiLog.i(TAG, prefixLog + " catch:rejectCall : %s" + JSON.stringify(err))
);
;
// 挂断
public hangUpCall = (callId) => new Promise((resolve, reject) =>
call.hangup(callId).then((res) =>
resolve(res);
HiLog.i(TAG, prefixLog + " then:hangUpCall : %s" )
).catch((err) =>
reject(err);
HiLog.i(TAG, prefixLog + " catch:hangUpCall : %s" + JSON.stringify(err))
);
);
// 保持
public holdCall = (callId) => new Promise((resolve, reject) =>
call.holdCall(callId).then((res) =>
resolve(res);
HiLog.i(TAG,prefixLog +" then:holdCall : %s" )
)
.catch((err) =>
reject(err);
HiLog.i(TAG,prefixLog +" catch:holdCall : %s" + JSON.stringify(err))
);
);
// 取消保持
public unHoldCall = (callId) => new Promise((resolve, reject) =>
call.unHoldCall(callId).then((res) =>
resolve(res);
HiLog.i(TAG,prefixLog +" then:unHoldCall : %s" )
)
.catch((err) =>
reject(err);
HiLog.i(TAG,prefixLog +" catch:unHoldCall : %s" + JSON.stringify(err))
);
);

2、拨号盘拨号接口调用

【OpenHarmony 通话应用源码剖析】// 拨号
public dialCall(phoneNumber, accountId = 0, videoState = 0, dialScene = 0)
HiLog.i(TAG, " dialCall phoneNumber : " )
return call.dial(phoneNumber,
accountId,
videoState,
dialScene
);

## 更多原创内容请关注：[深开鸿技术团队](https://harmonyos.51cto.com/person/posts/15292440)入门到精通、技巧到案例，系统化分享HarmonyOS开发技术，欢迎投稿和订阅，让我们一起携手前行共建鸿蒙生态。[想了解更多关于开源的内容，请访问：](https://ost.51cto.com/#bkwz)[51CTO 开源基础软件社区](https://ost.51cto.com#bkwz)https://ost.51cto.com/#bkwz

推荐阅读

• 

  《时生》
• 

  中国为何不承认科索沃 北约轰炸南联盟
• 

  空调内外机通风口是什么
• 

  羊肉变质了煮熟还能吃吗
• 

  FGO贝奥武夫三技能强化简评 FGO圣诞六期贝奥武夫技能本
• 

  秦时明月世界测试福利有什么 秦时明月世界测试福利介绍
• 

  redis connect time out redis连接超时功能
• 

  穿衬衫要不要穿外套 穿衬衫里面还需要穿衣服吗
• 

  藜麦碳水化合物含量高吗
• 

  爱目者护眼贴关爱儿童眼部健康公益活动|爱目者护眼贴关爱儿童眼部健康公益活动 共筑美好未来
• 

  sp如何调玻璃材质 sp如何diy，sp如何diy更疼
• 

  鼻毛|鼻毛外露不美观，拔了完事？鼻毛好处很多，劝你手下留情
• 

  你们看过后觉得最好的小说是什么？有哪些“高干文”和“糙汉文”推荐？
• 

  美丽加
• 

  电商什么都卖好吗怎么说 电商什么都卖好吗，电商什么都卖好吗知乎
• 

  地不容价格 地不容
• 

  八月瓜种植技术及条件
• 

  笼养八哥怎么训练 怎样饲养和调教八哥
• 

  佳能A4000 IS价格是多少钱？佳能A4000 IS的佳能A4000 IS说明书
• 

  天天吃咸鸭蛋好吗会胖吗 天天吃咸鸭蛋好吗

• 领域驱动设计 - 战略设计 - 1/2限界上下文
• 知名网站的404页面都长啥样（最后一个绝了...）
• 进程管理二
• Java中Math.random()与Random类生成随机数及源码分析
• 40 岁失业高级码农自曝（阿里 P9，攒了 1.5亿...）
• Java设计模式—适配器模式（adapter pattern）
• 进程的优先级
• 有话说2020 年 12 月某一天 15 个程序员远程视频“真实”面试，面试记录过程
• 手动生成kubeadm token用于加入新的worker节点