<?php
/**
 * Created by PhpStorm.
 * User: zhl
 * Date: 2025/2/13
 * Time: 16:45
 */

namespace App\Console\Commands\Inquiry;

use App\Helper\Translate;
use App\Models\Inquiry\InquiryInfo;
use App\Services\InquiryRelayService;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

class SyncInquiryRelay extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'sync_inquiry_relay';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '同步询盘信息：站群询盘，';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }


    public function handle()
    {
        $this->getInquiryForm();
        $this->getInquirySzcm();
    }

    /**
     * 获取表单系统中询盘信息
     * message_sign唯一值：md5(name+email+phone+ip+time)
     */
    public function getInquiryForm()
    {
        $service = new InquiryRelayService();
        $result = $service->getInquiryRelay();
        if (isset($result['status']) && $result['status'] == 200) {
            $data = $result['data'] ?? [];
            foreach ($data as $item) {
                $this->saveDate($item, $item['source_type']);
            }
        }
    }

    /**
     * 获取秋哥asp采集询盘信息
     * type固定4
     * message_sign唯一值：md5(name+email+phone+ip+time)
     * 先查数据库最大origin_key，再获取数据
     */
    public function getInquirySzcm()
    {
        $max_origin_key = InquiryInfo::where('type', 4)->orderBy('origin_key', 'desc')->value('origin_key');
        if ($max_origin_key) {
            $start_id = $max_origin_key + 1;
        } else {
            $start_id = 65029;
        }

        $service = new InquiryRelayService();
        while ($start_id > 0) {
            $result = $service->getInquirySzcm($start_id);
            if ($result) {
                $this->saveDate($result, 4);
                $start_id += 1;
            } else {
                $start_id = 0;
            }
        }
    }

    public function saveDate($data, $type)
    {
        $model = new InquiryInfo();
        $message_sign = md5($data['name'] . $data['email'] . $data['phone'] . $data['ip'] . $data['time']);
        $inquiry_info = $model->where('message_sign', $message_sign)->first();
        if (!$inquiry_info) {
            //没有IP，根据submit_country获取
            if (empty($data['ip']) && isset($data['submit_country']) && $data['submit_country']) {
                $chinese_name = DB::table('gl_world_country_city')->where('pid', 0)->where('iso2', $data['submit_country'])->value('chinese_name');
                $data['ip'] = $this->getIpData($chinese_name);
            }

            //获取country
            $country = '';
            if ($data['ip']) {
                $country = file_get_contents("http://ip.globalso.com?ip=" . $data['ip']);
            }

            //翻译message
            $message_cn = '';
            $re_message_trans = Translate::translate($data['message'], 'zh');
            if (isset($re_message_trans[0]['code']) && $re_message_trans[0]['code'] == 200) {
                $message_cn = $re_message_trans[0]['texts'];
            }

            //获取页面上title和keywords
            $html = curl_c($data['refer'], false);

            if (empty($data['title'])) {
                preg_match_all('/<title>([\w\W]*?)<\/title>/', $html, $matches);
                if (!empty($matches[1])) {
                    $data['title'] = substr($matches[1][0], 0, 255);
                }
            }

            $keywords = '';
            preg_match_all('/<meta\s+[^>]*?name=[\'|\"]keywords[\'|\"]\s+[^>]*?content=[\'|\"]([\w\W]*?)[\'|\"]/', $html, $matches);
            if (!empty($matches[1])) {
                $keywords = substr($matches[1][0], 0, 255);
            }

            if (empty($data['origin_key'])) {
                $data['origin_key'] = 0;
            }

            if (empty($data['image'])) {
                $data['image'] = '';
            }

            $model->createInquiry($data['name'], $data['phone'], $data['email'], $data['ip'], $country, $data['message'], $message_cn, $type, $data['time'], $data['refer'], $data['title'], $keywords, $message_sign, $data['origin_key'], $data['image']);
        }
    }

    /**
     * 获取国家随机ip
     * @param $country_name
     * @return mixed|string
     * @author Akun
     * @date 2025/02/14 14:19
     */
    public function getIpData($country_name)
    {
        // 有国家 通过国家查询， 如果没有获取到就随机获取
        $where = [];
        $country_name && $where['ip_area'] = $country_name;
        $ip = DB::table('gl_xunpan_ipdata')->where($where)->inRandomOrder()->value('ip');
        if (empty($ip_data)) {
            $ip = DB::table('gl_xunpan_ipdata')->inRandomOrder()->value('ip');
        }
        return $ip;
    }
}