问题描述

1. 列表中的任务,是要用户分享到微信群或者朋友圈,当分享成功收到回调之后,把改任务设置成"已完成"
2. 连续若干次分享,前面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次,问题就出在了这里.

• 所以 问题的关键是: 如何保证没有分享成功的任务,不执行成功的回调方法

问题解决

为了达到目的,我目前有两个想法:

1. 在分享成功的广播发送后,分别进入到n+1个回调操作,然后通过某种条件判断当前的任务是否成功
2. 在分享失败的广播发送后,把对任务成功的订阅事件销毁掉

经过一番思索,发现想法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