github/dootask
1
0
Fork 0
mirror of https://github.com/kuaifan/dootask.git synced 2025-12-12 19:35:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
kuaifan 2025-05-15 00:39:25 +08:00
parent 5b811df8ee
commit 0a14219112
3 changed files with 27 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
app/Observers/AbstractObserver.php Normal file
View File

@ -0,0 +1,19 @@
<?php
namespace App\Observers;
use Hhxsv5\LaravelS\Swoole\Task\Task;
class AbstractObserver
{
/**
* @param $task
* @return void
*/
public static function taskDeliver($task)
{
if (app()->bound('swoole')) {
Task::deliver($task);
}
}
}

9
app/Observers/WebSocketDialogMsgObserver.php
View File

@ -4,9 +4,8 @@ namespace App\Observers;
use App\Models\WebSocketDialogMsg; use App\Models\WebSocketDialogMsg;
use App\Tasks\ZincSearchSyncTask; use App\Tasks\ZincSearchSyncTask;
use Hhxsv5\LaravelS\Swoole\Task\Task;
class WebSocketDialogMsgObserver class WebSocketDialogMsgObserver extends AbstractObserver
{ {
/** /**
* Handle the WebSocketDialogMsg "created" event. * Handle the WebSocketDialogMsg "created" event.
@ -16,7 +15,7 @@ class WebSocketDialogMsgObserver
*/ */
public function created(WebSocketDialogMsg $webSocketDialogMsg) public function created(WebSocketDialogMsg $webSocketDialogMsg)
{ {
Task::deliver(new ZincSearchSyncTask('sync', $webSocketDialogMsg->toArray())); self::taskDeliver(new ZincSearchSyncTask('sync', $webSocketDialogMsg->toArray()));
} }
/** /**
@ -27,7 +26,7 @@ class WebSocketDialogMsgObserver
*/ */
public function updated(WebSocketDialogMsg $webSocketDialogMsg) public function updated(WebSocketDialogMsg $webSocketDialogMsg)
{ {
Task::deliver(new ZincSearchSyncTask('sync', $webSocketDialogMsg->toArray())); self::taskDeliver(new ZincSearchSyncTask('sync', $webSocketDialogMsg->toArray()));
} }
/** /**
@ -38,7 +37,7 @@ class WebSocketDialogMsgObserver
*/ */
public function deleted(WebSocketDialogMsg $webSocketDialogMsg) public function deleted(WebSocketDialogMsg $webSocketDialogMsg)
{ {
Task::deliver(new ZincSearchSyncTask('delete', $webSocketDialogMsg->toArray())); self::taskDeliver(new ZincSearchSyncTask('delete', $webSocketDialogMsg->toArray()));
} }
/** /**

9
app/Observers/WebSocketDialogUserObserver.php
View File

@ -6,9 +6,8 @@ use App\Models\Deleted;
use App\Models\WebSocketDialogUser; use App\Models\WebSocketDialogUser;
use App\Tasks\ZincSearchSyncTask; use App\Tasks\ZincSearchSyncTask;
use Carbon\Carbon; use Carbon\Carbon;
use Hhxsv5\LaravelS\Swoole\Task\Task;
class WebSocketDialogUserObserver class WebSocketDialogUserObserver extends AbstractObserver
{ {
/** /**
* Handle the WebSocketDialogUser "created" event. * Handle the WebSocketDialogUser "created" event.
@ -31,7 +30,7 @@ class WebSocketDialogUserObserver
} }
} }
Deleted::forget('dialog', $webSocketDialogUser->dialog_id, $webSocketDialogUser->userid); Deleted::forget('dialog', $webSocketDialogUser->dialog_id, $webSocketDialogUser->userid);
Task::deliver(new ZincSearchSyncTask('userSync', $webSocketDialogUser->toArray())); self::taskDeliver(new ZincSearchSyncTask('userSync', $webSocketDialogUser->toArray()));
} }
/** /**
@ -42,7 +41,7 @@ class WebSocketDialogUserObserver
*/ */
public function updated(WebSocketDialogUser $webSocketDialogUser) public function updated(WebSocketDialogUser $webSocketDialogUser)
{ {
Task::deliver(new ZincSearchSyncTask('userSync', $webSocketDialogUser->toArray())); self::taskDeliver(new ZincSearchSyncTask('userSync', $webSocketDialogUser->toArray()));
} }
/** /**
@ -54,7 +53,7 @@ class WebSocketDialogUserObserver
public function deleted(WebSocketDialogUser $webSocketDialogUser) public function deleted(WebSocketDialogUser $webSocketDialogUser)
{ {
Deleted::record('dialog', $webSocketDialogUser->dialog_id, $webSocketDialogUser->userid); Deleted::record('dialog', $webSocketDialogUser->dialog_id, $webSocketDialogUser->userid);
Task::deliver(new ZincSearchSyncTask('deleteUser', $webSocketDialogUser->toArray())); self::taskDeliver(new ZincSearchSyncTask('deleteUser', $webSocketDialogUser->toArray()));
} }
/** /**