dootask/app/Http/Controllers/Api/PublicController.php

<?php

namespace App\Http\Controllers\Api;

use App\Models\User;
use App\Models\UserCheckinMac;
use App\Models\UserCheckinRecord;
use App\Models\WebSocketDialog;
use App\Models\WebSocketDialogMsg;
use App\Module\Base;
use Cache;
use Carbon\Carbon;
use Request;

/**
 * @apiDefine public
 *
 * 公开
 */
class PublicController extends AbstractController
{
    /**
     * 签到 - 路由器（openwrt）功能安装脚本
     *
     * @apiParam {String}   key
     *
     * @return string
     */
    public function checkin__install()
    {
        $key = trim(Request::input('key'));
        //
        $setting = Base::setting('checkinSetting');
        if ($setting['open'] !== 'open') {
            return <<<EOF
                #!/bin/sh
                echo "function off"
                EOF;
        }
        if ($key != $setting['key']) {
            return <<<EOF
                #!/bin/sh
                echo "key error"
                EOF;
        }
        //
        $reportUrl = Base::fillUrl("api/public/checkin/report");
        return <<<EOE
            #!/bin/sh
            echo 'installing...'

            cat > /etc/init.d/dootask-checkin-report <<EOF
            #!/bin/sh
            mac=\\\$(awk 'NR!=1&&\\\$3=="0x2" {print \\\$4}' /proc/net/arp | tr "\\n" ",")
            tmp='{"key":"{$setting['key']}","mac":"'\\\${mac}'","time":"'\\\$(date +%s)'"}'
            curl -4 -X POST "{$reportUrl}" -H "Content-Type: application/json" -d \\\${tmp}
            EOF

            chmod +x /etc/init.d/dootask-checkin-report
            crontab -l >/tmp/cronbak
            sed -i '/\/etc\/init.d\/dootask-checkin-report/d' /tmp/cronbak
            sed -i '/^$/d' /tmp/cronbak
            echo "* * * * * sh /etc/init.d/dootask-checkin-report" >>/tmp/cronbak
            crontab /tmp/cronbak
            rm -f /tmp/cronbak
            /etc/init.d/cron enable
            /etc/init.d/cron restart

            echo 'installed'
            EOE;
    }

    /**
     * {post} 签到 - 路由器（openwrt）上报
     *
     * @apiParam {String}   key
     * @apiParam {String}   mac     使用逗号分割多个
     * @apiParam {String}   time
     *
     * @return string
     */
    public function checkin__report()
    {
        $key = trim(Request::input('key'));
        $mac = trim(Request::input('mac'));
        $time = intval(Request::input('time'));
        //
        $setting = Base::setting('checkinSetting');
        if ($setting['open'] !== 'open') {
            return 'function off';
        }
        if ($key != $setting['key']) {
            return 'key error';
        }
        $times = $setting['time'] ? Base::json2array($setting['time']) : ['00:00', '23:59'];
        $advance = (intval($setting['advance']) ?: 120) * 60;
        $delay = (intval($setting['delay']) ?: 120) * 60;
        //
        $nowDate = date("Y-m-d");
        $nowTime = date("H:i:s");
        //
        $timeStart = strtotime("{$nowDate} {$times[0]}");
        $timeEnd = strtotime("{$nowDate} {$times[1]}");
        $timeAdvance = max($timeStart - $advance, strtotime($nowDate));
        $timeDelay = min($timeEnd + $delay, strtotime("{$nowDate} 23:59:59"));
        if (Base::time() < $timeAdvance || $timeDelay < Base::time()) {
            return "not in valid time, valid time is " . date("H:i", $timeAdvance) . "-" . date("H:i", $timeDelay);
        }
        //
        $macs = explode(",", $mac);
        $checkins = [];
        foreach ($macs as $mac) {
            $mac = strtoupper($mac);
            if (Base::isMac($mac) &&  $UserCheckinMac = UserCheckinMac::whereMac($mac)->first()) {
                $checkins[] = $UserCheckinMac;
                $array = [
                    'userid' => $UserCheckinMac->userid,
                    'mac' => $UserCheckinMac->mac,
                    'date' => $nowDate,
                ];
                $record = UserCheckinRecord::where($array)->first();
                if (empty($record)) {
                    $record = UserCheckinRecord::createInstance($array);
                }
                $record->times = Base::array2json(array_merge($record->times, [$nowTime]));
                $record->report_time = $time;
                $record->save();
            }
        }
        //
        if ($checkins && $botUser = User::botGetOrCreate('check-in')) {
            $sendMsg = function($type, UserCheckinMac $checkin) use ($botUser, $nowDate) {
                $cacheKey = "Checkin::sendMsg-{$nowDate}-{$type}:" . $checkin->userid;
                if (Cache::get($cacheKey) === "yes") {
                    return;
                }
                Cache::put($cacheKey, "yes", Carbon::now()->addDay());
                //
                $dialog = WebSocketDialog::checkUserDialog($botUser->userid, $checkin->userid);
                if ($dialog) {
                    $hi = date("H:i");
                    $pre = $type == "up" ? "上班" : "下班";
                    $remark = $checkin->remark ?: $checkin->mac;
                    $text = "{$pre}签到成功，签到时间: {$hi} ({$remark})";
                    WebSocketDialogMsg::sendMsg(null, $dialog->id, 'text', ['text' => $text], $botUser->userid);
                }
            };
            if ($timeAdvance <= Base::time() && Base::time() <= $timeStart + 3600) {
                // 上班签到（迟到1小时内仍提醒）
                foreach ($checkins as $checkin) {
                    $sendMsg('up', $checkin);
                }
            }
            if ($timeEnd <= Base::time() && Base::time() <= $timeDelay) {
                // 下班签到
                foreach ($checkins as $checkin) {
                    $sendMsg('down', $checkin);
                }
            }
        }
        return 'success';
    }
}