<?php

namespace App\Http\Logic\Aside\Projects;

use App\Http\Logic\Aside\BaseLogic;
use App\Models\Inquiry\InquiryCount;
use App\Models\Inquiry\InquiryInfo;
use App\Models\Inquiry\InquiryIP;
use App\Models\Project\DeployBuild;
use App\Models\Project\Keywords;
use App\Models\Projects\InquiryUser;
use Illuminate\Support\Facades\DB;

/**
 * @remark :询盘中心
 * @class  :InquiryInfoLogic.php
 * @author :lyh
 * @time   :2023/7/11 15:20
 */
class InquiryInfoLogic extends BaseLogic
{

    public function __construct()
    {
        parent::__construct();
        $this->param = $this->requestAll;
        $this->model = new InquiryInfo();
        //TODO::测试数据
        $this->manager = [
            'id'=>1,
            'name'=>'cs'
        ];
    }

    /**
     * @remark :获取列表
     * @name   :getInquiryLists
     * @author :lyh
     * @method :post
     * @time   :2023/7/11 15:25
     */
    public function getInquiryLists($map,$page,$row,$order = 'id',$filed = ['*']){
        $lists = $this->model->lists($map,$page,$row,$order,$filed);
        return $this->success($lists);
    }


    /**
     * @remark :自定义添加特殊询盘信息
     * @name   :inquirySave
     * @author :lyh
     * @method :post
     * @time   :2023/7/12 9:22
     */
    public function inquirySave(){
        $this->param['created_at'] = date('Y-m-d H:i:s');
        $this->param['updated_at'] = date('Y-m-d H:i:s');
        $xp_id = $this->model->insertGetId($this->param);
//        @file_put_contents(storage_path('logs/lyh_error.log'), var_export($xp_id, true) . PHP_EOL, FILE_APPEND);
        if(!$xp_id){
            $this->fail('error');
        }
        //延时时间为0时，询盘转发
        if($this->param['delay'] == 0){
            $this->forwardTime($xp_id);
        }
        return $this->success();
    }


    /**
     * @remark :删除
     * @name   :inquiryInfoDel
     * @author :lyh
     * @method :post
     * @time   :2023/7/12 14:15
     */
    public function inquiryInfoDel(){
        DB::beginTransaction();
        try {
            $this->model->del(['id'=>$this->param['id']]);
            $inquiryUserModel = new InquiryUser();
            $inquiryUserModel->del(['xp_id'=>$this->param['id']]);
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            $this->fail('error');
        }
        return $this->success();
    }

    /**
     * @remark :转发详情
     * @name   :inquiryForwardInfo
     * @author :lyh
     * @method :post
     * @time   :2023/7/12 17:43
     */
    public function inquiryForwardInfo(){
        $info = $this->model->read(['id'=>$this->param['id']]);
        if($info === false){
            $this->fail('error');
        }
        return $this->success($info);
    }

    /**
     * @remark :导入保存数据
     * @name   :ImportInquiryInfoSave
     * @author :lyh
     * @method :post
     * @time   :2023/7/13 10:59
     */
    public function ImportInquiryInfoSave($row){
        $this->param = [
            'name'=>$row[0],
            'email'=>$row[1],
            'phone'=>$row[2],
            'ip'=>$row[3],
            'ip_area'=>$row[4],
            'message'=>$row[5],
            'type'=>$row[6],
            'forward_url'=>$row[7],
            'delay'=>$row[8],
        ];
        $this->inquirySave();
        return $this->success();
    }

    /**
     * @remark :根据国家获取随机ip
     * @name   :getSearchIp
     * @author :lyh
     * @method :post
     * @time   :2023/7/13 11:43
     */
    public function getSearchIp(){
        $inquiryIpModel = new InquiryIP();
        $info = $inquiryIpModel->where($this->param)->inRandomOrder()->first();
        return $this->success($info);
    }

    /**
     * @remark :根据时间转发
     * @name   :forwardTime
     * @author :lyh
     * @method :post
     * @time   :2023/7/13 17:39
     */
    public function forwardTime($xp_id){
        //获取数据详情
        $param = $this->model->read(['id'=>$xp_id]);
        if($param['delay'] == 0){
            $data = $param;
            $arr_url = explode(',',$param['forward_url']);
            foreach ($arr_url as $v){
                $data['url'] = $v;
                @file_put_contents(storage_path('logs/lyh_error.log'), var_export(json_encode($data).'debug---------------33333333333', true) . PHP_EOL, FILE_APPEND);
                $this->inquiryForward($data);
            }
            //更新数据库,修改状态为已转发
            $this->param['status'] = 3;
            $this->param['user_id'] = $this->manager['id'];
            $this->param['user_name'] = $this->manager['name'];
            $this->param['send_time'] = date('Y-m-d H:i:s',time() + $param['delay'] * 60 * 60) ;
            $rs = $this->model->edit($this->param,['id'=>$xp_id]);
            if($rs === false){
                $this->fail('error');
            }
        }
        return $this->success();
    }

    /**
     * @remark :询盘转发
     * @name   :inquiryForward
     * @author :lyh
     * @method :post
     * @time   :2023/7/13 14:39
     */
    public function inquiryForward($post_data){
        $url = 'https://form.globalso.com/api/external-interface/add/fa043f9cbec6b38f';
        $post_data_new = [];
        $post_data_new['refer'] = $post_data['url'];
        $post_data_new['name'] = $post_data['name'];
        $post_data_new['email'] = $post_data['email'];
        $post_data_new['phone'] = $post_data['phone'];
        $post_data_new['ip'] = $post_data['ip'];
        $post_data_new['message'] = $post_data['message'];
        $post_data_new['submit_time'] = date('Y-m-d H:i:s',time()+20);
        $token = md5($post_data_new['refer'].$post_data_new['name'].$post_data_new['ip'].date("Y-m-d",time()));
        $post_data_new['token'] = $token;
        $header = array(
            'CLIENT-IP: '.$post_data['ip'],
            'X-FORWARDED-FOR: '.$post_data['ip']
        );
        @file_put_contents(storage_path('logs/lyh_error.log'), var_export(json_encode($post_data_new).'debug', true) . PHP_EOL, FILE_APPEND);
        return http_post($url,$post_data_new,$header);
    }

    /**
     * @remark :更新询盘状态
     * @name   :inquiryEdit
     * @author :lyh
     * @method :post
     * @time   :2023/7/14 15:19
     */
    public function inquiryEdit(){
        $info = $this->model->read(['id'=>$this->param['id']]);
        if($info !== 0){
            $this->fail('当前状态下不允许修改状态');
        }
        $this->param['user_id'] = $this->manager['id'];
        $this->param['user_name'] = $this->manager['name'];
        $rs = $this->model->edit($this->param,['id'=>$this->param['id']]);
        if($rs === false){
            $this->fail('error');
        }
        return $this->success();
    }

    /**
     * @remark :获取30天统计
     * @name   :getNewThirtyCount
     * @author :lyh
     * @method :post
     * @time   :2023/7/14 16:00
     */
    public function getNewCount(){
        $inquiryCountModel = new InquiryCount();
        $lists = $inquiryCountModel->lists(['type'=>$this->param['type']],1,90);
        $data = $lists['list'];
        return $this->success($data);
    }

    /**
     * @remark :根据关键字获取域名
     * @name   :getKeywordUrl
     * @author :lyh
     * @method :post
     * @time   :2023/7/17 9:09
     */
    public function getKeywordUrl($map){
        $lists = [];
        $keywordModel = new Keywords();
        $list = $keywordModel->select('project_id')
            ->where(['type'=>1])->where('keyword','like','%'.$map['keyword'].'%')->groupBy('project_id')->get();
        if(!empty($list)){
            $data = [];
            $list = $list->toArray();
            foreach ($list as $v){
                $data[] = $v['project_id'];
            }
            //根据项目id获取域名
            $projectBuildModel = new DeployBuild();
            $lists = $projectBuildModel->select('test_domain ad domain')->whereIn('project_id', $data)->get()->toArray();
        }
        return $this->success($lists);
    }
}