<?php

namespace App\Console\Commands;

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

/**
 * 同步项目信息
 * 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'] == '首次'){
                    $data['data']['type'] = 1; //建站进程中
                    ProjectLogic::instance()->sync($data['data']);
                }
                if($data['data']['order_type'] == '续费'){
                    $data['data']['type'] = 4; //续费记录单
                    $this->renewSync($data['data']);
                }
//                @file_put_contents(storage_path('logs/lyh_error.log'), var_export($data['data'], true) . PHP_EOL, FILE_APPEND);
                $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){
        //查询续费项目
        $projectModel = new Project();
        $info = $projectModel->read(['app_id'=>$param['id']]);
        $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' => 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' => $param['files'],
            'bill' => $param['images'],
            'post_id'=>$info['post_id']
        ];
        $renewModel = new ProjectRenew();
        $rs = $renewModel->add($data);
        if($rs === false){
            errorLog('项目续费单同步失败');
        }
        //同步更改项目版本

    }

    /**
     * @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   :savePayment
     * @author :lyh
     * @method :post
     * @time   :2023/8/11 16:08
     */
    protected function savePayment($param,$project_id){
        //查询数据详情
        $paymentModel = new Payment();
        $paymentModel->read(['project_id'=>$project_id]);

        $data = [
            'amount'=>$param['amount'],
            'contract'=>$param['contract'],
            'bill'=>$param['bill'],
            'renewal_record'
        ];
        $paymentModel->edit($data,['project_id'=>$project_id]);
    }
}