<?php
/**
 * Created by PhpStorm.
 * User: zhl
 * Date: 2024/01/04
 * Time: 16:08
 */
namespace App\Http\Controllers\Api;

use App\Models\Com\KeywordVideoTaskLog;
use App\Models\Domain\DomainInfo;
use App\Models\Domain\DomainRedirectTask;
use App\Models\Product\Keyword;
use App\Models\Project\Project;
use App\Models\Visit\SyncSubmitTask;
use App\Models\Visit\Visit;
use App\Models\Workchat\MessagePush;
use App\Services\ProjectServer;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Symfony\Component\Process\Process;

/**
 * Class NoticeController
 * @package App\Http\Controllers\Api
 */
class NoticeController extends BaseController
{
    /**
     * 网站引流
     * FIXME 当前接口给内部引流用， 使用简易接口， 后期需要添加完整校验机制以及多数据接口
     * @param Request $request
     * @return false|string
     */
    public function trafficVisit(Request $request)
    {
        $ip = $request->input('ip');
        $url = $request->input('url');
        $device_port = intval($request->input('device_port'));
        $referrer_url = $request->input('referrer_url');
        $user_agent = $request->input('user_agent');

        // 数据占时不入库， 些日志分析数据
        file_put_contents(storage_path('logs/trafficVisit.log'), var_export($request->all(), true) . PHP_EOL, FILE_APPEND);
//        return $this->success([]);

        if (empty($ip))
            return $this->error('IP不能为空');
        if (empty($url))
            return $this->error('访问链接不能为空');
        if (empty($user_agent))
            return $this->error('请求头信息user_agent不能为空');

        $url_array = parse_url($url);
        $array = [
            'ip' => $ip,
            'domain' => $url_array['host'] ?? '',
            'referer' => $referrer_url,
            'user_agent' => $user_agent,
            'data' => [
                'url' => $url,
                'domain' => empty($url_array['host']) ? '' : $url_array['scheme'] . '://' . $url_array['host'],
                'device_port' => in_array($device_port, array_keys(Visit::deviceMap())) ? $device_port : Visit::DEVICE_PC,
                'referrer_url' => $referrer_url
            ]
        ];
        SyncSubmitTask::createTask($array, SyncSubmitTask::TYPE_VISIT);
        return $this->success([]);
    }

    /**
     * 生成视频任务回调
     * @param Request $request
     * @return int
     */
    public function videoTaskCallback(Request $request)
    {
        // 获取参数
        $task_id = $request->input('task_id');
        $status = intval($request->input('status', 0));
        $thumb = $request->input('video_thumb');
        $video = $request->input('callback_resource');
        $embed_code = $request->input('embed_code');
        $all = $request->all();
        // 获取子任务
        $log = KeywordVideoTaskLog::where(['task_id' => $task_id])->first();
        if (empty($log)){
            return 200;
        }
        // 更新子任务状态 更新任务信息
        $log->status = KeywordVideoTaskLog::STATUS_FINISH;
        $log->result_status = $status;
        $log->result_info = json_encode($all);
        $log->save();
        if ($status != 200) {
            return 200;
        }
        // 更新关键词信息
        ProjectServer::useProject($log->project_id);
        $keyword = Keyword::where(['id' => $log->keyword_id])->first();
        // 关键词可能已被删除
        if (empty($keyword)){
            return 200;
        }
        $keyword->video = $video;
        $keyword->embed_code = $embed_code;
        $keyword->video_thumb = $thumb;
        $keyword->is_video_keyword = 1;
        $keyword->save();
        DB::disconnect('custom_mysql');
        return 200;
    }

    /**
     * 创建301跳转任务
     * @param Request $request
     * @return false|string
     * @author Akun
     * @date 2024/10/08 15:24
     */
    public function addRedirect(Request $request)
    {
        $origin_domain = $request->input('origin_domain', '');
        $other_domain = $request->input('other_domain', []);
        $target_domain = $request->input('target_domain', '');

        if ($other_domain && !is_array($other_domain)) {
            return $this->error('other_domain参数必须为数组');
        }

        if(strpos($origin_domain,'http') !== false){
            $origin_array = parse_url($origin_domain);
            $origin_domain = $origin_array['host'] ?? '';
        }
        if (empty($origin_domain)) {
            return $this->error('origin_domain参数填写有误');
        }

        if(strpos($target_domain,'http') !== false){
            $target_array = parse_url($target_domain);
            $target_domain = $target_array['host'] ?? '';
        }
        if (empty($target_domain)) {
            return $this->error('target_domain参数填写有误');
        }


        if(!check_domain_record($origin_domain,['domain'=>'','ip'=>DomainInfo::SERVER_IP_301])){
            return $this->error($origin_domain . ' 未解析至 ' . DomainInfo::SERVER_IP_301);
        }

        if($other_domain){
            foreach ($other_domain as &$ov) {
                if(strpos($ov,'http') !== false){
                    $ov_array = parse_url($ov);
                    $ov = $ov_array['host'] ?? '';
                }
                if(empty($ov)){
                    return $this->error('other_domain参数填写有误');
                }
                if (!check_domain_record($ov, ['domain'=>'','ip'=>DomainInfo::SERVER_IP_301])) {
                    return $this->error($ov . ' 未解析至 ' . DomainInfo::SERVER_IP_301);
                }
            }
        }

        //新增重定向任务
        $redirect_model = new DomainRedirectTask();
        $task_redirect_info = $redirect_model->read(['origin_domain'=>$origin_domain],['id','status']);
        if(!$task_redirect_info){
            $redirect_model->add([
                'origin_domain'=> $origin_domain,
                'other_domain' => json_encode($other_domain),
                'target_domain' => $target_domain
            ]);
        }else{
            if($task_redirect_info['status'] > DomainRedirectTask::STATUS_ING){
                $redirect_model->edit(['other_domain' => json_encode($other_domain), 'target_domain' => $target_domain, 'status'=>DomainRedirectTask::STATUS_UN, 'error_msg'=>null],['id'=>$task_redirect_info['id']]);
            }
        }

        return $this->success();
    }

    /**
     * 询盘通知企业微信群提示hook
     * 升级项目询盘hook
     * 通知发送群提醒
     * @param Request $request
     * @return false|string
     */
    public function inquiryNoticeHook(Request $request)
    {
        $domain = trim($request->input('domain'));
        $country = trim($request->input('country'));
        $name = trim($request->input('name'));
        $submit = trim($request->input('submit_at'));
        if (empty($domain) || empty($country) || empty($name) || empty($submit))
            return $this->error('参数不完整！');

        $project = Project::getProjectByDomain($domain);
        if (empty($project))
            return $this->success();

        MessagePush::addInquiryMessage(0, $project->id, $country, $name, $submit);
        return $this->success();
    }
}