<?php

namespace App\Console\Commands\Project;

use App\Helper\Arr;
use App\Helper\Common;
use App\Helper\OaGlobalsoApi;
use App\Models\Channel\Channel;
use App\Models\Com\NoticeLog;
use App\Models\Com\UpdateLog;
use App\Models\Com\UpdateVisit;
use App\Models\Manage\Mobile;
use App\Models\Project\After;
use App\Models\Project\DeployBuild;
use App\Models\Project\DeployOptimize;
use App\Models\Project\Payment;
use App\Models\Project\Project;
use App\Models\Project\ProjectRenew;
use App\Models\User\User as UserModel;
use App\Services\ProjectServer;
use App\Utils\LogUtils;
use Hashids\Hashids;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Http;

/**
 * 同步项目信息
 * Class ChannelInfo
 * @package App\Console\Commands
 * @author zbj
 * @date 2023/6/27
 */
class SyncProject extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'sync_project';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '同步项目信息';

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

    /**
     * @return bool
     */
    public function handle()
    {
        while (true){
            $list = NoticeLog::where('type', NoticeLog::TYPE_PROJECT)->where('status', NoticeLog::STATUS_PENDING)->get();
            foreach ($list as $item){
                echo date('Y-m-d') . ' start:' . $item['id'] . PHP_EOL;
                try {
                    $is_update = $item['data']['is_update']??0;//是否是4.0或5.0更新到6.0
                    $order_id = $item['data']['order_id'];
                    if($is_update == 1){
                        $data = http_get('https://quanqiusou.cn/extend_api/v6/update.php?postid='.$order_id, ['charset' => 'UTF-8']);
                    }else{
                        $api = new OaGlobalsoApi();
                        $data = $api->order_info($order_id);
                    }
                    if(!$data || empty($data['data'])){
                        LogUtils::error('OaGlobalsoApi order_info error', $data);
                        $this->retry($item, '未获取到订单信息');
                        continue;
                    }
                    if($data['data']['order_type'] == '首次'){
                        $this->sync($data['data'],$is_update);
                        //同步aicc
                        if($data['data']['exclusive_aicc']){
                            $this->toAicc($data['data']);
                        }
                        //同步hagro
                        if($data['data']['exclusive_hagro']){
                            $this->toHagro($data['data']);
                        }
                    }
                    if($data['data']['order_type'] == '续费'){
                        $this->renewSync($data['data']);
                    }
                    $item->status = NoticeLog::STATUS_SUCCESS;
                    $item->save();
                    echo 'success:' . $item['id'] . PHP_EOL;
                }catch (\Exception $e){
                    echo 'error:' . $item['id'] . $e->getMessage() .' line ' . $e->getLine() . PHP_EOL;
                    errorLog('项目同步失败', $item, $e);
                    $this->retry($item, $e->getMessage());
                }
            }
            sleep(2);
        }

    }

    /**
     * @param NoticeLog $log
     */
    public function retry($log, $remark){
        if($log->retry >= 3){
            $log->status = NoticeLog::STATUS_FAIL;
            $log->remark = mb_substr($remark, 0, 250);
        }else{
            $log->retry = $log->retry + 1;
        }
        $log->save();
    }

    /**
     * @remark :同步续费记录单
     * @name   :renewSync
     * @author :lyh
     * @method :post
     * @time   :2023/8/11 15:33
     */
    public function renewSync($param){
        $title = date('Ymd') . '-' . $param['company_name'];;
        $data = [
            'title' => '【续费单】'.$title,
            'company' => $param['company_name'],
            'lead_name' => $param['principal_name'],
            'mobile' => $param['principal_mobile'],
            'qq' => $param['customer_qq'],
            'channel' => json_encode(Channel::getProjectChannel($param['company_id'], $param['username_sales'])),
            'requirement' => $param['remark'],
            'cooperate_date' => date('Y-m-d', $param['create_time']),
            'service_duration' => $param['years'],
            'plan' => $this->versionData($param['plan_marketing']),
//            'api_no' => $param['id'],  //改手动填
            'amount' => $param['plan_price'],
            'contract' => json_encode($param['files']),
            'bill' => json_encode($param['images']),
        ];
        $renewModel = new ProjectRenew();
        $rs = $renewModel->add($data);
        if($rs === false){
            errorLog('项目续费单同步失败');
        }
        return true;
    }

    /**
     * @remark :获取版本
     * @name   :versionData
     * @author :lyh
     * @method :post
     * @time   :2023/8/9 14:46
     */
    public function versionData($param){
        $data = Project::planMap();
        $data = array_flip($data);
        if(isset($data[$param])){
            return $data[$param];
        }else{
            return 1;
        }
    }

    /**
     * @remark :导入数据
     * @name   :sync
     * @author :lyh
     * @method :post
     * @time   :2023/8/9 15:04
     */
    public function sync($param,$is_update = 0){
        $title = date('Ymd') . '-' . $param['company_name'];
        $data = [
            'project'=>[
                'title' => $title,
                'company' => $param['company_name'],
                'lead_name' => $param['principal_name'],
                'mobile' => $param['principal_mobile'],
                'mysql_id'=>Project::MYSQL_ID,
                'qq' => $param['customer_qq'],
                'channel' => Channel::getProjectChannel($param['company_id'], $param['username_sales']),
                'requirement' => $param['remark'],
                'cooperate_date' => date('Y-m-d', $param['create_time']),
                'from_order_id' => $param['from_order_id'],
                'aicc' => $param['exclusive_aicc'],
                "exclusive_aicc_day" => $param['exclusive_aicc_day'],
                'hagro' => $param['exclusive_hagro'],
                "exclusive_hagro_day" => $param['exclusive_hagro_day'],
                'notice_order_id' => $param['id'],
                'type' => $is_update,
                'is_upgrade'=>$is_update,
            ],
            'deploy_build' => [
                'service_duration' => $param['years'] ?? 0,
                'plan' => $this->versionData($param['plan_marketing']),
                'login_mobile'=>$param['principal_mobile']
            ],
            'deploy_optimize' => [
                'api_no' => 0
            ],
            'project_after' => [],
            'payment' => [
                'amount' => $param['plan_price'],
                'contract'=>$param['files'],
                'bill'=>$param['images']
            ],
        ];
        DB::beginTransaction();
        try {
            $id = $this->saveProject($data['project']);
            $this->setPostId($data['deploy_build']['plan'],$id);
            $this->savePayment($data['payment'],$id);
            $this->saveDeployBuild($data['deploy_build'],$id);
            $this->saveDeployOptimize($data['deploy_optimize'],$id);
            $this->saveAfter($data['project_after'],$id);

            if($is_update == 1){
                //4.0或5.0更新到6.0
                //初始化数据库
                $this->initializationMysql($id);
                //初始账号
                $this->createUser($data['project']['mobile'],$id,$data['project']['lead_name']);
                //新增数据抓取任务
                $task_list = [];
                if(!in_array('category_news',$param['api_type'])){
                    array_push($param['api_type'],'category_news');
                }
                foreach ($param['api_type'] as $v_type){
                    if($v_type == 'category' || $v_type == 'category_news' || $v_type == 'tag'){
                        UpdateLog::createLog($id,$v_type,$param['get_data_url']);
                    }else{
                        $task_list[] = $v_type;
                    }
                }
                foreach ($task_list as $task){
                    UpdateLog::createLog($id,$task,$param['get_data_url']);
                }
                UpdateVisit::createLog($id,$param['get_data_url']);
            }
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            throw new \Exception($e->getMessage());
        }
    }

    /**
     * @remark :设置post_id
     * @name   :setPostId
     * @author :lyh
     * @method :post
     * @time   :2023/8/9 14:47
     */
    public function setPostId($plan,$id){
        $length = strlen((string)$id); // 获取变量的位数
        $paddingLength = Project::TYPE_FIVE - $length; // 计算填充前面的 0 的位数
        $zeros = str_repeat("0", $paddingLength);
        $number = Project::TYPE_SIX.$plan.$zeros.$id;
        $projectModel = new Project();
        $projectModel->edit(['post_id'=>$number],['id'=>$id]);
        return true;
    }

    /**
     * @remark :保存项目
     * @name   :saveProject
     * @author :lyh
     * @method :post
     * @time   :2023/8/30 15:53
     */
    public function saveProject($param){
        if(isset($param['channel']) && !empty($param['channel'])){
            $param['channel'] = Arr::a2s($param['channel']);
        }else{
            $param['channel'] = Arr::a2s(["user_id"=>"", "zone_id"=>"", "channel_id"=>""]);
        }
        $projectModel = new Project();
        $info = $projectModel->read(['from_order_id'=>$param['from_order_id'],'delete_status'=>0]);
        if($info !== false){
            unset($param['type']); //更新的 不更新状态了
            $projectModel->edit($param, ['id' => $info['id']]);
            return $info['id'];
        }else{
            return $projectModel->addReturnId($param);
        }
    }

    /**
     * 保存优化部署
     * @author zbj
     * @date 2023/4/26
     */
    protected function saveAfter($param,$id){
        $param['project_id'] = $id;
        //查询数据是否存在
        $afterModel = new After();
        $info = $afterModel->read(['project_id'=>$id]);
        if($info !== false){
            $afterModel->edit($param,['id'=>$info['id']]);
        }else{
            $afterModel->add($param);
        }
    }

    /**
     * @remark :保存付款续费
     * @name   :savePayment
     * @author :lyh
     * @method :post
     * @time   :2023/8/29 16:19
     */
    protected function savePayment($param,$id){
        $param['project_id'] = $id;
        $paymentModel= new Payment();
        $param['contract'] = Arr::a2s($param['contract']);
        $param['bill'] = Arr::a2s($param['bill']);
        if(!isset($param['renewal_record'])){
            $param['renewal_record'] = Arr::a2s([["amount"=> null, "remark"=> null, "expire_at"=> null]]);
        }
        $info = $paymentModel->read(['project_id'=>$id]);
        if($info !== false){
            $paymentModel->edit($param,['id'=>$info['id']]);
        }else{
            $paymentModel->add($param);
        }
    }

    /**
     * @remark :保存建站部署
     * @name   :saveDeployBuild
     * @author :lyh
     * @method :post
     * @time   :2023/8/29 16:19
     */
    protected function saveDeployBuild($param,$id){
        $param['project_id'] = $id;
        $hashids = new Hashids('test_domain', 5, 'abcdefghjkmnpqrstuvwxyz1234567890');
        $code = $hashids->encode($id);
        $param['test_domain'] = 'https://v6-' . $code . '.globalso.site/';
        $deployBuildModel = new DeployBuild();
        $info = $deployBuildModel->read(['project_id'=>$id]);
        if($info !== false){
            $deployBuildModel->edit($param,['id'=>$info['id']]);
        }else{
            $deployBuildModel->add($param);
        }
    }

    /**
     * @remark :保存优化信息
     * @name   :saveDeployOptimize
     * @author :lyh
     * @method :post
     * @time   :2023/8/30 16:11
     */
    protected function saveDeployOptimize($param,$id){
        $param['project_id'] = $id;
        $deployOptimizeModel = new DeployOptimize();
        $info = $deployOptimizeModel->read(['project_id'=>$id]);
        if($info !== false){
            $deployOptimizeModel->edit($param,['id'=>$info['id']]);
        }else{
            $deployOptimizeModel->add($param);
        }
    }

    /**
     * 同步到AICC
     * @param $data
     * @author zbj
     * @date 2023/9/1
     */
    protected function toAicc($data){
        $url = 'https://biz.ai.cc/api/sync_company_for_order';
        $param = [
            'company_name' => $data['company_name'],
            'company_address' => '',
            'company_tel' => $data['principal_mobile'],
            'company_email' => '',
            'remark' => $data['remark'],
            'level_id' => 6,
            'level_day' => $data['exclusive_aicc_day'] ?: 1,
            'from_order_id' => $data['from_order_id'],
            'nickname' => $data['username_sales'] ?? $data['principal_mobile'],
        ];

        //sign
        ksort($param);
        $tem = [];
        foreach ($param as $key => $val) {
            $tem[] = $key . '=' . urlencode($val);
        }
        $string = implode('&', $tem);
        $key = md5('quanqiusou.com');
        $param['sign'] = md5($string . $key);
        $res = Http::withoutVerifying()->post($url, $param)->json();
        if(empty($res['status']) || $res['status'] != 200){
            LogUtils::error('ProjectToAicc error', $res);
        }
    }

    /**
     * 同步到Hagro
     * @param $data
     * @author zbj
     * @date 2023/9/1
     */
    protected function toHagro($data){
        $url = 'https://admin.hagro.cn/globalso/create_project';
        $param = [
            'company' => $data['company_name'],
            'phone' => $data['principal_mobile'],
            'planday' => $data['exclusive_hagro_day'] ?: 1,
            'from_order_id' => $data['from_order_id'],
            'agent_phone' => Channel::where('source_id', $data['company_id'])->value('contact_mobile') ?: '',
            'nickname' => $data['username_sales'] ?? $data['principal_mobile'],
        ];
        $common = new Common();
        $token = $common->encrypt($param);
        $res = Http::withoutVerifying()->get($url, ['token' => $token])->json();
        if(empty($res['code']) || $res['code'] != 200){
            LogUtils::error('ProjectToHagro error', $res);
        }
    }

    /**
     * 初始化数据库
     * @param $project_id
     * @author Akun
     * @date 2023/09/19 15:12
     */
    public function initializationMysql($project_id){
        //切换数据库配置
        $project = ProjectServer::useProject($project_id);
        //创建数据库
        ProjectServer::createDatabase($project);
        //创建表
        ProjectServer::initTable();
        //初始数据
        ProjectServer::saveInitParam($project_id);
    }

    /**
     * 创建用户
     * @param $mobile
     * @param $project_id
     * @param $lead_name
     * @author Akun
     * @date 2023/09/19 15:12
     */
    public function createUser($mobile,$project_id,$lead_name){
        $userModel = new UserModel();
        //查看当前项目是否存在号码库中
        $mobileModel = new Mobile();
        $mobileInfo = $mobileModel->read(['mobile'=>$mobile]);
        if($mobileInfo === false){
            //查看当前用户是否存在
            $info = $userModel->read(['mobile'=>$mobile,'project_id'=>$project_id]);
            if($info === false){
                $data = [
                    'mobile'=>$mobile,
                    'password'=>base64_encode(md5('123456')),
                    'project_id'=>$project_id,
                    'name'=>$lead_name,
                    'type'=>UserModel::TYPE_ONE
                ];
                $userModel->add($data);
            }
        }
        return true;
    }
}