project/app/cxinv/command/CheckInvoice.php

<?php
declare (strict_types = 1);

namespace app\cxinv\command;

use app\cxinv\model\Invoice;use app\cxinv\model\InvoiceInfo;use app\user\model\Business;use app\user\model\Supplier;use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;use think\facade\Cache;


class CheckInvoice extends Command
{
    protected $datetime;
    protected $InvoiceNum;
    protected $taxStatus = [
        'Y'=>'2','N'=>'1','H'=>'3'
    ];
    protected $output;
    protected function configure()
    {
        // 指令配置
        $this->setName('checkinvoice')
            ->setDescription('the checkinvoice command');
    }

    protected function execute(Input $input, Output $output)
    {
        $this->datetime = date('Y-m-d');
        $list = $this->getInvoice();
        $this->InvoiceNum =[
                    'special'=>'004',
                    'normal'=>'007',
                    'special_electronic'=>'028',
                    'blockchain_electronic'=>'016',
                    'electronic'=>'026',
                    'fully_digitalized_special_electronic'=>'021',
                    'fully_digitalized_normal_electronic'=>'022',
                ];
        $this->output=$output;
       // if(Cache::get('checkInvoiceP')==1)return;
        while ($list->valid()){
            Cache::set('checkInvoiceP',1,1800);
            $invoice = $list->current();
            $this->taxCheck($invoice);
            $this->output->writeln('['.date(DATE_W3C).']'.$invoice['hpNo'].'验票');
            $list->next();
        }
        Cache::set('checkInvoiceP',0);

    }

    protected  function getInvoice(){
        $list = Invoice::where([['status','=',0],['updatetime','<=',date('Y-m-d H:i:s')]])->cursor();
        foreach ($list as $item){
            yield $item;
        }
    }
    protected function taxCheck($invoice){
        $Tax =new \TaxInvoice(env('tax.appkey'),env('tax.appsecret'),env('tax.entcode'));

        $invNum= $this->InvoiceNum[$invoice['invoice_type']];
        $subtotal= $invoice['invoice_subtotal'];
        if(!in_array($invNum,['012','022','028']))$checkNum= substr($invoice['check_code'],-6);
        else $checkNum= $invoice['check_code'];
        if(in_array($invNum,['021','022'])) $subtotal= $invoice['invoice_total'];
       $result=$Tax->CheckInvoiceSingle($checkNum,$subtotal,$invoice['invoice_code'],$invoice['invoice_number'],$invoice['open_date'],$invNum);;
        $this->output->writeln('[' . date(DATE_W3C) . ']' . json_encode($result,JSON_UNESCAPED_UNICODE));
       Invoice::startTrans();
        try{
            if(isset($result['code']) && $result['code']=='0000' and count($result['data'])>0){
                if($result['data']['cyjg']=='0001'){
                    $data= $result['data'];
                     $this->changeFiled($data,$invoice);
                }elseif (in_array($result['data']['cyjg'],['0002','1014'])){
                    $this->lastUpdate($invoice['id']);
                }else $this->faild($invoice['id'],$result['data']['cyjgxx']);
            }else $this->faild($invoice['id']);
        }catch (\Exception $e){
           Invoice::rollback();
           echo $e->getMessage();
        }
       Invoice::commit();
    }

    protected function changeFiled($data,$invoice){
        $save = [
            'payNo'=>$invoice['InvCode'],
            'hpNo'=>'',
            'type'=>$invoice['invoice_type'],
            'title'=>'',
            'code'=>$data['fpdm'],
            'check_code'=>$data['jym'],
            'number'=>$data['fphm'],
            'issue_date'=>$data['kprq'],
            'encryption_block'=>'',
            'buyer_name'=>$data['gmfmc'],
            'buyer_id'=>$data['gmfsbh'],
            'buyer_address'=>$data['gmfdzdh'],
            'buyer_bank'=>$data['gmfyhzh'],
            'seller_name'=>$data['xhfmc'],
            'seller_id'=>$data['xhfsbh'],
            'seller_address'=>$data['xhfdzdh'],
            'seller_bank'=>$data['xhfyhzh'],
            'subtotal_amount'=>$data['fpje'],
            'subtotal_tax'=>$data['fpse'],
            'machine_number'=>$data['jqbh'],
            'status'=>$this->taxStatus[$data['zfbz']]??0,
            'total'=>$data['jshj'],
            'total_in_words'=>'',
            'receiver'=>$data['skr'],
            'issuer'=>$data['kpr'],
            'reviewer'=>$data['fhr'],
            'remarks'=>$data['bz'],
            'change_field'=>'',
            'item_list'=>$this->checkItem($data['detailList'])
        ];
        InvoiceInfo::create($save);
        $buyerinfo = Business::where(['inv_code'=>$invoice['buyer_id']])->findOrEmpty();
        $update=[];
        if(!$buyerinfo->isEmpty()){
            $update=["companyNo"=>$buyerinfo->companyNo,"companyName"=>$buyerinfo->company];
        }else $update=['companyNo'=>'','companyName'=>$save['buyer_name']];
        $saller= Supplier::where(['registercode'=>$invoice['seller_id']])->findOrEmpty();
        if (!$saller->isEmpty()){
            $update['supplierNo'] = $saller->code;
            $update['supplierName'] = $saller->name;
        }else $update['supplierName'] = $save['seller_name'];
        Invoice::where(['id'=>$invoice['id']])->update(array_merge($update,[
            'status'=>1,
            'inv_status'=>$this->taxStatus[$data['zfbz']]??0,
            'updatetime'=>date('Y-m-d H:i:s'),
            'remark'=>'验票成功'
        ]));
    }

    protected function checkItem($detail){
        if(!empty($detail)) return array_map(function ($item) {
             return [
              'name'=>$item['hwmc'],
              'specification'=>$item['jldw'],
              'unit'=>$item['ggxh'],
              'quantity'=>$item['spsl'],
              'unit_price'=>$item['bhsdj'],
              'amount'=>$item['je'],
              'tax'=>$item['se'],
              'tax_rate'=>$item['sl'],
              'license_plate_number'=>$item['ssflbm'],
          ];
        }, $detail);
        return [];
    }
    protected function faild($id,$msg=''){
       Invoice::where(['id'=>$id])->update(['status'=>5,'remark'=>$msg,'updatetime'=>date('Y-m-d H:i:s')]);
    }
    protected function lastUpdate($id){
        Invoice::where(['id'=>$id])->update(['status'=>0,'remark'=>'验证失败，等待第二天验证', 'updatetime'=> date('Y-m-d H:i:s',strtotime('+1 day'))]);
    }

}