dootask/app/Tasks/UnclaimedTaskRemindTask.php

<?php

namespace App\Tasks;

use App\Models\User;
use App\Module\Base;
use App\Models\Project;
use App\Models\ProjectTask;
use App\Models\ProjectUser;
use Carbon\Carbon;
use App\Models\WebSocketDialogMsg;
use Illuminate\Support\Facades\Cache;

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

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

    public function start()
    {
        //
        $setting = Base::setting('system');
        if ($setting['unclaimed_task_reminder'] !== 'open') {
            return;
        }
        if (!$setting['unclaimed_task_reminder_time']) {
            return;
        }
        //
        $times = explode(':',date('H:i'));
        $reminderTimes = explode(':',$setting['unclaimed_task_reminder_time']);
        if( !isset($times[1]) || !isset($reminderTimes[1]) || $times[0] != $reminderTimes[0]){
            return;
        }
        // 执行一次
        if (Cache::get("UnclaimedTaskRemindTask:His",0)) {
            return;
        }
        if( $times[1] >= $reminderTimes[1] - 1 && $times[1] <= $reminderTimes[1] + 1){
            //
            Cache::put("UnclaimedTaskRemindTask:His", date('H:i:s'), Carbon::now()->addMinutes(5));
            //
            Project::whereNull('deleted_at')->whereNull('archived_at')->chunk(100,function($projects) {
                foreach ($projects as $project) {
                    //
                    $projectTasks = ProjectTask::select('project_tasks.id','project_tasks.name')
                        ->leftJoin('project_task_users', function ($query) {
                            $query->on('project_tasks.id', '=', 'project_task_users.task_id');
                        })
                        ->where('project_tasks.project_id',$project->id)
                        ->whereNull('project_tasks.deleted_at')
                        ->whereNull('project_tasks.archived_at')
                        ->whereNull('project_task_users.id')
                        ->limit(10)
                        ->get();
                    //
                    if( !$projectTasks->isEmpty() ){
                        $botUser = User::botGetOrCreate('task-alert');
                        if (empty($botUser)) {
                            return;
                        }
                        if (!ProjectUser::whereUserid($botUser->userid)->whereProjectId($project->id)->exists()) {
                            $project->joinProject($botUser->userid);
                            $project->syncDialogUser();
                        }
                        //
                        $taskHtml = '<span style="line-height: 26px;">任务待领取</span> <br/>';
                        foreach($projectTasks as $projectTask){
                            $taskHtml .=  "<span class=\"mention task\" style=\"line-height: 26px;\" data-id=\"{$projectTask->id}\">#{$projectTask->name}</span> <br/>";
                        }
                        WebSocketDialogMsg::sendMsg(null, $project->dialog_id , 'text', [
                            'text' => $taskHtml
                        ], $botUser->userid);
                    }
                }
            });
        }
    }

    public function end()
    {

    }

}