dootask/app/Tasks/AppPushTask.php

<?php

namespace App\Tasks;

use App\Models\ProjectTask;
use App\Models\ProjectTaskPushLog;
use App\Models\User;
use App\Models\WebSocketDialog;
use App\Models\WebSocketDialogMsg;
use App\Module\Base;
use Carbon\Carbon;

@error_reporting(E_ALL & ~E_NOTICE & ~E_WARNING);

class AppPushTask extends AbstractTask
{
    public function __construct()
    {
        parent::__construct();
    }

    public function start()
    {
        $setting = Base::setting('appPushSetting');
        $pushTask = $setting['push'] === 'open' && $setting['push_task'] !== 'close';
        if (!$pushTask) {
            return;
        }
        $start = intval($setting['task_start_minute']);
        $hours = floatval($setting['task_remind_hours']);
        $hours2 = floatval($setting['task_remind_hours2']);
        if ($start > -1) {
            ProjectTask::whereNull("complete_at")
                ->whereNull("archived_at")
                ->whereBetween("start_at", [
                    Carbon::now()->subMinutes($start + 10),
                    Carbon::now()->subMinutes($start)
                ])->chunkById(100, function ($tasks) {
                    /** @var ProjectTask $task */
                    foreach ($tasks as $task) {
                        $this->taskPush($task, 0);
                    }
                });
        }
        if ($hours > -1) {
            ProjectTask::whereNull("complete_at")
                ->whereNull("archived_at")
                ->whereBetween("end_at", [
                    Carbon::now()->addMinutes($hours * 60),
                    Carbon::now()->addMinutes($hours * 60 + 10)
                ])->chunkById(100, function ($tasks) {
                    /** @var ProjectTask $task */
                    foreach ($tasks as $task) {
                        $this->taskPush($task, 1);
                    }
                });
        }
        if ($hours2 > -1) {
            ProjectTask::whereNull("complete_at")
                ->whereNull("archived_at")
                ->whereBetween("end_at", [
                    Carbon::now()->subMinutes($hours2 * 60 + 10),
                    Carbon::now()->subMinutes($hours2 * 60)
                ])->chunkById(100, function ($tasks) {
                    /** @var ProjectTask $task */
                    foreach ($tasks as $task) {
                        $this->taskPush($task, 2);
                    }
                });
        }
    }

    public function end()
    {

    }

    /**
     * 任务过期前、超期后提醒
     * @param ProjectTask $task
     * @param int $type
     * @return void
     */
    private function taskPush(ProjectTask $task, int $type)
    {
        $userids = $task->taskUser->where('owner', 1)->pluck('userid')->toArray();
        if (empty($userids)) {
            return;
        }
        $users = User::whereIn('userid', $userids)->whereNull('disable_at')->get();
        if (empty($users)) {
            return;
        }

        $botUser = User::botGetOrCreate('task-alert');
        if (empty($botUser)) {
            return;
        }

        $setting = Base::setting('appPushSetting');
        $text = view('push.task', [
            'type' => str_replace([0, 1, 2], ['start', 'before', 'after'], $type),
            'task' => $task,
            'setting' => $setting,
        ])->render();

        /** @var User $user */
        foreach ($users as $user) {
            $data = [
                'type' => $type,
                'userid' => $user->userid,
                'task_id' => $task->id,
            ];
            $pushLog = ProjectTaskPushLog::where($data)->exists();
            if ($pushLog) {
                continue;
            }
            //
            $dialog = WebSocketDialog::checkUserDialog($botUser->userid, $data['userid']);
            if ($dialog) {
                ProjectTaskPushLog::createInstance($data)->save();
                WebSocketDialogMsg::sendMsg(null, $dialog->id, 'text', ['text' => $text], $botUser->userid);    // todo 未能在任务end事件来发送任务
            }
        }
    }
}