perf: 离职移交部门

This commit is contained in:
kuaifan
2022-11-20 19:19:28 +08:00
parent 0e71efd714
commit 0cc1469589
4 changed files with 96 additions and 25 deletions

View File

@@ -766,30 +766,6 @@ class UsersController extends AbstractController
]);
$userTransfer->save();
$userTransfer->start();
// 离职移出群组
WebSocketDialog::select(['web_socket_dialogs.*'])
->join('web_socket_dialog_users as u', 'web_socket_dialogs.id', '=', 'u.dialog_id')
->where('web_socket_dialogs.type', 'group')
->where('u.userid', $userInfo->userid)
->orderByDesc('web_socket_dialogs.id')
->chunk(100, function($list) use ($transferUser, $userInfo) {
/** @var WebSocketDialog $dialog */
foreach ($list as $dialog) {
// 离职员工退出群
$dialog->exitGroup($userInfo->userid, 'remove', false, false);
if ($dialog->owner_id === $userInfo->userid) {
// 如果是群主则把交接人设为群主
$dialog->owner_id = $transferUser->userid;
if ($dialog->save()) {
$dialog->joinGroup($transferUser->userid, 0);
$dialog->pushMsg("groupUpdate", [
'id' => $dialog->id,
'owner_id' => $dialog->owner_id,
]);
}
}
}
});
} elseif ($type === 'cleardisable') {
// 取消离职重新加入全员群组
if (Base::settingFind('system', 'all_group_autoin', 'yes') === 'yes') {