问题描述
- 列表中的任务,是要用户分享到微信群或者朋友圈,当分享成功收到回调之后,把改任务设置成"已完成"
- 连续若干次分享,前面n次都没有分享成功,第n+1次分享成功后,前面的所有任务都变成了"已完成"
问题排查
在相关页面中,有个shareToWechat
的方法
当用户点击了"分享"按钮,就调用这个方法,方法中添加了一个微信分享回调通知监听
监听回调方法中,把该任务id加入到已完成列表,代码如下:
// 分享到微信
private func shareToWechat(model: GWXShareModel, task: GOwnMissionMetaTask){
// 调用分享
if wxShareSendMultiMessage(model: model) == false {
SVProgressHUD.showError(withStatus: "分享失败")
return
}
SVProgressHUD.dismiss()
NotificationCenter.default.rx
.notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Success()))
.subscribe({ (noti) in
print("~~~~分享成功!!")
SVProgressHUD.dismiss()
// 把当前任务加到完成列表里,用户可以领取奖励
self.viewModel.addTaskToDoneList(id: task.id)
// 刷新列表
self.viewModel.missionList.value = self.viewModel.missionList.value
}).disposed(by: self.disposeBag)
}
问题分析
通过断点调试,发现当第n+1次分享成功后,发射了一次成功回调的广播
而成功的回调被注册了n+1次,于是回调方法调用了n+1次,问题就出在了这里.
所以
问题的关键是: 如何保证没有分享成功的任务,不执行成功的回调方法
问题解决
为了达到目的,我目前有两个想法:
- 在分享成功的广播发送后,分别进入到n+1个回调操作,然后通过某种条件判断当前的任务是否成功
- 在分享失败的广播发送后,把对任务成功的订阅事件销毁掉
经过一番思索,发现想法1不可行,想法2很容易做到,最终的代码如下:
// 分享到微信
private func shareWX(model: GWXShareModel, task: GOwnMissionMetaTask){
// 调用分享
if wxShareSendMultiMessage(model: model) == false {
SVProgressHUD.showError(withStatus: "分享失败")
return
}
// 分享成功的监听
let notificationSubscription = NotificationCenter.default.rx
.notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Success()))
.subscribe({ (noti) in
print("~~~~分享成功!!")
SVProgressHUD.dismiss()
// 把当前任务加到完成列表里,用户可以领取奖励
self.viewModel.addTaskToDoneList(id: task.id)
// 刷新列表
self.viewModel.missionList.value = self.viewModel.missionList.value
})
// 分享失败的监听
NotificationCenter.default.rx
.notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Fail()))
.subscribe { (noti) in
// 微信分享失败后,把对分享成功的rx监听对象销毁
notificationSubscription.dispose()
}.disposed(by: disposeBag)
}
总结
对于监听通知,要留意是否注册了多余的订阅者,如果不及时清除很可能会有bug