diff --git a/app/Models/UmengAlias.php b/app/Models/UmengAlias.php index 8f5204f2f..503e2e16d 100644 --- a/app/Models/UmengAlias.php +++ b/app/Models/UmengAlias.php @@ -158,11 +158,15 @@ class UmengAlias extends AbstractModel } $builder ->orderByDesc('id') - ->chunkById(100, function ($rows) use ($array) { - $lists = $rows->groupBy('platform'); - foreach ($lists as $platform => $list) { - $alias = $list->pluck('alias')->implode(','); - self::pushMsgToAlias($alias, $platform, $array); + ->chunkById(100, function ($datas) use ($array) { + $uids = $datas->groupBy('userid'); + foreach ($uids as $uid => $rows) { + $array['badge'] = WebSocketDialogMsgRead::whereUserid($uid)->whereReadAt(null)->count(); + $lists = $rows->groupBy('platform'); + foreach ($lists as $platform => $list) { + $alias = $list->pluck('alias')->implode(','); + self::pushMsgToAlias($alias, $platform, $array); + } } }); }