<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Models\{PatientRecord, UserSocialite};
use Overtrue\LaravelWeChat\EasyWeChat;
use Slowlyo\OwlAdmin\Models\AdminUser;
use App\Enums\SocialiteType;

class PatientRecordNotify extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'patient-record:notify';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '病历记录: 通知';

    /**
     * Execute the console command.
     */
    public function handle()
    {
        $now = now();
        $list = PatientRecord::where('is_notified', 0)
            ->whereNotNull('notify_user_id')
            ->whereBetween('notify_at', [$now->copy()->startOfDay(), $now->copy()->endOfDay()])
            ->get();
        $app = EasyWeChat::officialAccount();
        $app->setAccessToken(new \App\Services\WechatOfficialAccessToken(
            appId: $app->getAccount()->getAppId(),
            secret: $app->getAccount()->getSecret(),
            cache: $app->getCache(),
            httpClient: $app->getHttpClient(),
            stable: $app->getConfig()->get('use_stable_access_token', false),
        ));
        $api = $app->getClient();
        // 微信公众号关联账户
        $users = UserSocialite::where('user_type', (new AdminUser)->getMorphClass())->where('type', SocialiteType::WxOfficial)->whereIn('user_id', $list->pluck('notify_user_id'))->get();
        foreach ($list as $item) {
            $user = $users->firstWhere('user_id', $item->notify_user_id);
            if ($user) {
                $response = $api->postJson('/cgi-bin/message/template/send', [
                    'touser' => $user->openid,
                    'template_id' => '',
                    'url' => url('/h5/pages/record/detail?id=' . $item->id),
                    'data' => []
                ]);
                if ($response->isFailed()) {
                    logger('病历记录: 通知, 模板消息发送, 失败', $response->toArray(false));
                    continue;
                }
                $item->update(['is_notified' => 1]);
            }
        }
    }
}