dootask/app/Tasks/CheckinRemindTask.php

<?php

namespace App\Tasks;

use App\Models\ApproveProcInstHistory;
use App\Models\User;
use App\Models\UserCheckinRecord;
use App\Models\WebSocketDialog;
use App\Models\WebSocketDialogMsg;
use App\Module\Base;
use App\Module\Extranet;
use App\Module\Timer;
use Cache;
use Carbon\Carbon;

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

    public function start()
    {
        $setting = Base::setting('checkinSetting');
        if ($setting['open'] !== 'open') {
            return;
        }
        // 判断非工作日
        if (Extranet::isHoliday(date("Ymd")) > 0) {
            return;
        }
        //
        $times = $setting['time'] ? Base::json2array($setting['time']) : ['09:00', '18:00'];
        $remindin = (intval($setting['remindin']) ?: 5) * 60;
        $remindexceed = (intval($setting['remindexceed']) ?: 10) * 60;
        //
        $nowDate = date("Y-m-d");
        $timeStart = strtotime("{$nowDate} {$times[0]}");
        //
        if ($remindin > 0) {
            $timeRemindin = $timeStart - $remindin;
            if ($timeRemindin <= Timer::time() && Timer::time() <= $timeStart) {
                // 签到打卡提醒
                $this->remind('in');
            }
        }
        if ($remindexceed > 0) {
            $timeRemindexceed = $timeStart + $remindexceed;
            if ($timeRemindexceed <= Timer::time() && Timer::time() <= $timeRemindexceed + 300) {
                // 签到缺卡提醒
                $this->remind('exceed');
            }
        }
    }

    public function end()
    {

    }

    private function remind($type)
    {
        if (Cache::get("CheckinRemindTask:remind-" . $type) == date("Ymd")) {
            return;
        }
        Cache::put("CheckinRemindTask:remind-" . $type, date("Ymd"), Carbon::now()->addDay());
        //
        $botUser = User::botGetOrCreate('check-in');
        if (!$botUser) {
            return;
        }
        // 提醒对象：3天内有签到的成员（在职）
        User::whereBot(0)->whereNull('disable_at')->chunk(100, function ($users) use ($type, $botUser) {
            /** @var User $user */
            foreach ($users as $user) {
                if (UserCheckinRecord::whereUserid($user->userid)->where('date', date("Y-m-d"))->exists()) {
                    continue;   // 已打卡
                }
                if (!UserCheckinRecord::whereUserid($user->userid)->where('created_at', '>', Carbon::now()->subDays(3))->exists()) {
                    continue;   // 3天内没有打卡
                }
                if (ApproveProcInstHistory::userIsLeave($user->userid)) {
                    continue;   // 请假、外出
                }
                $dialog = WebSocketDialog::checkUserDialog($botUser, $user->userid);
                if ($dialog) {
                    if ($type === 'exceed') {
                        $title = '缺卡提醒';
                        $style = 'color:#f55;';
                        $content = '上班时间到了，你还没有打卡哦~';
                    } else {
                        $title = '打卡提醒';
                        $style = '';
                        $content = '快到上班时间了，别忘了打卡哦~';
                    }
                    WebSocketDialogMsg::sendMsg(null, $dialog->id, 'template', [
                        'type' => 'content',
                        'title' => $title,
                        'content' => [
                            [
                                'content' => $title,
                                'style' => $style . 'font-weight:bold',
                            ],
                            [
                                'content' => $content,
                                'style' => 'padding-top:4px;opacity:0.6',
                            ],
                        ],
                    ], $botUser->userid);
                }
            }
        });
    }
}