<?php

namespace App\Jobs;

use App\Models\App\Team;
use App\Models\Message;
use App\Models\User;
use App\Models\UserInfo;
use App\Models\Wechat;
use App\Utils\Messenger as Messengers;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;

class GroupChatUnreadNotice implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    /**
     * 群聊id
     * @var
     */
    protected $team_id;

    /**
     * 用户id
     * @var
     */
    protected $user_id;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($team_id,$user_id)
    {
        $this->team_id = $team_id;
        $this->user_id = $user_id;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $user = User::find($this->user_id);

        //消息提醒开关
        $user_info = UserInfo::firstOrCreate(['user_id'=>$user->id]);
        if($user_info->message_notice == 0){
            return;
        }

        $mobile = $user->mobile;
        $official_openid = Wechat::where('user_id', $this->user_id)->value('official_openid');
        $team = Team::find($this->team_id);
        $is_subscribe = \WechatService::officialIsSubscribed($official_openid);
        //未关注公众号 发短信通知
        if(!$is_subscribe && $mobile){
            $url = \CommonUtilsService::getWecharLink("/pages/tabBar/news");
            $short_url_data = \CommonUtilsService::shortUrl(env('APP_URL') . '/h5/#/jump_url?url=' . $url);
            $url = $short_url_data['url'] ?? '';
            $content = "收到一条群通知，请点击{$url} 查看信息，敬请微信关注“福恋智能”公众号，以便接收通知!";
            Message::create([
                'phone' => $mobile,
                'message' => $content,
                'confirmed' => 1,
                'ip' => request() ? request()->ip() : '127.0.0.1',
            ]);
            Messengers::sendSMS($mobile, $content);
            return;
        }
        if (!$official_openid) {
            return;
        }
        //模板消息通知
        $data['touser'] = $official_openid;
        $data['template_id'] = config('wechat.tpls.start_message_notice');
        $data['url'] = '';
        $data['miniprogram'] = [
            'appid'=> config('wechat.mini_program.app_id'),
            'pagepath'=>'/pages/tabBar/news'
        ];
        $data['data'] = [
            'first' => "{$user->nickname}，您有群聊《{$team->tname}》消息未读",
            'keyword1' => date('Y-m-d H:i:s'),
            'keyword2' => "{$user->nickname}，您有群聊《{$team->tname}》消息未读",
            'remark' => '本通知可在福恋小程序 我的-设置 中关闭。',
        ];
        SendTemplateMsg::dispatch($data)->onQueue('start_message');
    }
}