<?php

namespace App\Http\Logic\Aside\Optimize;

use App\Helper\Common;
use App\Helper\Gpt;
use App\Helper\Translate;
use App\Http\Logic\Aside\BaseLogic;
use App\Models\Ai\AiCommand;
use App\Models\Inquiry\InquiryInfo;
use App\Models\Inquiry\InquiryProject;
use App\Models\Inquiry\InquiryProjectRoute;
use App\Models\Inquiry\InquiryRelayDetail;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Str;

/**
 * @remark :询盘中心
 * @class  :InquiryForwardLogic.php
 * @author :akun
 * @time   :2025/2/21 11:17
 */
class InquiryForwardLogic extends BaseLogic
{

    public function __construct()
    {
        parent::__construct();
        $this->param = $this->requestAll;
        $this->model = new InquiryInfo();
    }

    /**
     * 获取类型
     * @return array
     * @author Akun
     * @date 2025/02/21 11:19
     */
    public function getType()
    {
        return $this->success($this->model->typeMap());
    }

    /**
     * 获取列表
     * @param $map
     * @param $page
     * @param $row
     * @param string $order
     * @param string[] $filed
     * @return array
     * @author Akun
     * @date 2025/02/21 11:19
     */
    public function getInquiryLists($map, $page, $row, $order = 'id', $filed = ['*'])
    {
        $lists = $this->model->lists($map, $page, $row, $order, $filed);
        return $this->success($lists);
    }

    /**
     * 转发询盘
     * @return array
     * @throws \App\Exceptions\AsideGlobalException
     * @throws \App\Exceptions\BsideGlobalException
     * @author Akun
     * @date 2025/02/21 14:54
     */
    public function inquiryForward()
    {
        $info = $this->model->read(['id' => $this->param['id']]);
        if ($info === false) {
            $this->fail('获取询盘详情失败');
        }
        if ($info['status'] != InquiryInfo::STATUS_INIT) {
            $this->fail('当前询盘状态无法转发');
        }

        DB::beginTransaction();
        try {
            $num = 0;
            $now = date('Y-m-d H:i:s');
            foreach ($this->param['forward_url'] as $url) {
                $domain_array = parse_url($url);
                $website = $domain_array['host'] ?? '';
                if (!$website) {
                    continue;
                }

                //获取站点对应项目版本
                $project_version = InquiryProject::select(['version'])->where('domain', 'like', '%' . $website . '%')->first();
                if (!$project_version) {
                    continue;
                }
                $is_v6 = $project_version->version == 6 ? 1 : 0;


                //计算发送时间
                if ($this->param['inquiry_diff'] > 0) {
                    $start_at = date('Y-m-d H:i:s', strtotime($this->param['inquiry_date'] . ' -' . $this->param['inquiry_diff'] . ' hours'));
                } elseif ($this->param['inquiry_diff'] < 0) {
                    $start_at = date('Y-m-d H:i:s', strtotime($this->param['inquiry_date'] . ' +' . abs($this->param['inquiry_diff']) . ' hours'));
                } else {
                    $start_at = $this->param['inquiry_date'];
                }
                if ($start_at < $now) {
                    $start_at = $now;
                }

                InquiryRelayDetail::createInquiry($info['id'], $website, $info['country'], $this->param['ip'], $this->param['name'], $this->param['email'], $this->param['phone'], $this->param['message'], $is_v6, json_encode([$url]), $start_at);

                $num += 1;
            }

            //更改询盘状态及转发数量
            $this->model->edit(['status' => 1, 'num' => $num], ['id' => $this->param['id']]);

            DB::commit();
        } catch (\Exception $e) {
            DB::rollback();

            Log::error('inquiry_forward error:' . $e->getMessage());
            $this->fail('转发询盘失败');
        }

        return $this->success();
    }

    /**
     * 获取随机ip
     * @return array
     * @throws \App\Exceptions\AsideGlobalException
     * @throws \App\Exceptions\BsideGlobalException
     * @author Akun
     * @date 2025/02/26 15:50
     */
    public function getIp()
    {
        $ip = DB::table('gl_xunpan_ipdata')->where('ip_area', $this->param['country'])->inRandomOrder()->value('ip');
        if (!$ip) {
            $this->fail('当前国家无法获取随机ip');
        }

        return $this->success(['ip' => $ip]);
    }

    /**
     * 关键词查询项目着陆页
     * @return int|mixed
     * @author Akun
     * @date 2025/02/26 17:13
     */
    public function searchKeywords()
    {
        $num = $this->param['num'] ?? 3;

        $model = new InquiryProjectRoute();
        if ($this->param['type'] == 1) {
            //使用全文索引搜索
            $routeQuery = $model->select(['project_id', 'route'])->whereRaw("MATCH(title) AGAINST(? IN BOOLEAN MODE)", [$this->param['keywords']]);
        } else {
            //使用like查询
            $routeQuery = $model->select(['project_id', 'route'])->where('title', 'like', '%' . $this->param['keywords'] . '%');
        }

        $re_route = $routeQuery->inRandomOrder()->take(100)->get()->toArray();

        $lists = [];
        if (count($re_route) > 0) {
            //根据项目id查询项目，并根据询盘量排序
            $project_ids = array_column($re_route, 'project_id');
            $re_project = InquiryProject::select(['id', 'project', 'channel', 'domain'])->whereIn('id', $project_ids)->orderBy('recent_inquiry', 'asc')->get();

            if ($re_project->count() > 0) {
                //根据代理商去重
                $channel = [];
                foreach ($re_project as $vp) {
                    $vp_channel = explode(',', $vp->channel);
                    $has_channel = 0;
                    foreach ($vp_channel as $vpc) {
                        if (in_array($vpc, $channel)) {
                            $has_channel = 1;
                        }
                    }

                    if ($has_channel == 0) {
                        $channel = array_merge($channel, $vp_channel);

                        $route = '';
                        foreach ($re_route as $vr) {
                            if ($vr['project_id'] == $vp->id) {
                                $route = $vr['route'];
                                break;
                            }
                        }
                        if (substr($route, -5) != '.html') {
                            $route = $route . '/';
                        }

                        $lists[] = [
                            'id' => $vp->id,
                            'project' => $vp->project,
                            'route' => $vp->domain . $route
                        ];
                    }
                }
            }
        }

        return $this->success(array_slice($lists, 0, $num, true));
    }

    /**
     * AI重写询盘文案
     * @return array
     * @throws \App\Exceptions\AsideGlobalException
     * @throws \App\Exceptions\BsideGlobalException
     * @author Akun
     * @date 2025/02/27 10:40
     */
    public function aiRewrite()
    {
        $ai_command = AiCommand::where('key', 'inquiry_text_rewrite')->value('ai');
        if (!$ai_command) {
            $this->fail('AI重写指令未配置');
        }

        $in_content = $this->param['message'];
        $translateSl = Translate::translateSl($in_content);
        $lang = $translateSl['texts']['sl'] ?? 'en';
        if ($lang == 'en' || $lang == 'ja' || $lang == 'ko' || Str::contains($lang, 'zh')) {
            $lang = 'en';
        }

        $ai_command = str_replace('{incontent}', Arr::random(explode("\r\n", $in_content)), $ai_command);

        $text = Gpt::instance()->openai_chat_qqs($ai_command);
        if ($lang != 'en' && !Str::contains($lang, 'zh')) {
            $text = Translate::tran($text, $lang);
        }

        return $this->success(['ai_message' => Common::deal_str($text)]);
    }
}