<?php

namespace App\Console\Commands;

use App\Helper\OaGlobalsoApi;
use App\Http\Logic\Aside\Project\ProjectLogic;
use App\Models\Channel\Channel;
use App\Models\NoticeLog;
use App\Models\Project\Project;
use App\Models\Project\ProjectRenew;
use App\Utils\LogUtils;
use Illuminate\Console\Command;

/**
 * 同步项目信息
 * 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()
    {
        $list = NoticeLog::where('type', NoticeLog::TYPE_PROJECT)->where('status', NoticeLog::STATUS_PENDING)->get();
        foreach ($list as $item){
            try {
                $api = new OaGlobalsoApi();
                $data = $api->order_info($item['data']['order_id']);
                if(!$data || empty($data['data'])){
                    LogUtils::error('OaGlobalsoApi order_info error', $data);
                    $this->retry($item);
                }
                if($data['data']['order_type'] == '首次'){
                    ProjectLogic::instance()->sync($data['data']);
                }
                if($data['data']['order_type'] == '续费'){
                    $this->renewSync($data['data']);
                }
                $item->status = NoticeLog::STATUS_SUCCESS;
                $item->save();
            }catch (\Exception $e){
                errorLog('项目同步失败', $item, $e);
                $this->retry($item);
            }
        }
    }

    /**
     * @param NoticeLog $log
     */
    public function retry($log){
        if($log->retry >= 3){
            $log->status = NoticeLog::STATUS_FAIL;
        }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']),
        ];
//        @file_put_contents(storage_path('logs/lyh_error.log'), var_export($data, true) . PHP_EOL, FILE_APPEND);
        $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;
        }
    }
}