cxinv/app/admin/command/GetOrderInfoAndInvoiceInfo.php

<?php
declare (strict_types = 1);

namespace app\admin\command;

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;
use think\facade\Config;
use think\facade\Db;

class GetOrderInfoAndInvoiceInfo extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('getorderinfoandinvoiceinfo')
            ->setDescription('the getorderinfoandinvoiceinfo command');
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令输出
       $GetOrderInfoAndInvoiceInfo= Cache::store("redis")->get("GetOrderInfoAndInvoiceInfo");
       if($GetOrderInfoAndInvoiceInfo==1) return '';
       	Cache::store("redis")->set("GetOrderInfoAndInvoiceInfo",1,180);
	    Db::startTrans();
		try{
			$data = $this->GetData();
			if(empty($data)) {
				Db::rollback();
				return '';
			}
			$date=date("Y-m-d H:i:s");
			foreach ($data as $value){
				if($value['status']==1){
					$this->GetOrderInfo($value);
				}
				if($value['status']==2){
					
					if($value['KPLX']==1){
							$red=Db::name("invoice_red")->where(["invRed"=>$value['invNo'],"is_del"=>0])->find();
							if($red){
								$invNo=$red['invNo'];
								Db::name("invoice_return")->where(["returnCode"=>$red['returnCode']])->update(["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
								Db::name("invoice_red")->where($red)->update(["status"=>4,"remark"=>"开票成功","updatetime"=>date("Y-m-d H:i:s")]);
								Db::name("invoice_pool")->where(["invNo"=>$red['invNo'],"is_del"=>0])->update(["status"=>6,"updatetime"=>date("Y-m-d H:i:s")]);
							}
							$this->insertTicket($value['result'],$invNo);
					}else{
							$invNo = $value['invNo'];
							Db::name("invoice_pool")->where(["invNo"=>$value['invNo'],"is_del"=>0])->update(["status"=>4,"seller_check"=>1,"buyer_check"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
							$this->insertTicket($value['result'],$invNo);
					}
					if(isset($invNo)&&$invNo!=''){
						$is_comon= Db::name('invoice_pool')->where(['invNo'=>$invNo,'is_del'=>0])
																					->value('is_comon');
						if ($is_comon == 1) {
							event('comonOrder' ,['invNo'=>$invNo ,'type' =>$value['KPLX']==0?'inv':'rinv']);
							$output->writeln( "【 $date 】通用订单验票完成".$invNo.$value['KPLX']==0?'开票':'退票');
						}
					}
					Db::name("invoice_interface")->where($value)->update(["is_check"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
					
				}
				if($value['status']==3 || $value['status']==4){
					if($value['KPLX']==1){
						$red=Db::name('invoice_red')->where(['invRed'=>$value['invNo'],'is_del'=>0])->find();
						Db::name("invoice_red")->where(["invRed"=>$value['invNo'],"is_del"=>0])->update(["status"=>6,"remark"=>"红冲开票失败","updatetime"=>date("Y-m-d H:i:s")]);
						Db::name("invoice_return")->where(["returnCode"=>$red['returnCode'],"status"=>1])->update(["status"=>4,"remark"=>"红冲开票失败","updatetime"=>date("Y-m-d H:i:s")]);
					}else{
						Db::name("invoice_pool")->where(["invNo"=>$value['invNo'],"is_del"=>0])->update(["status"=>5,"check_remark"=>$value['remark'],"updatetime"=>date("Y-m-d H:i:s")]);

					}
					Db::name("invoice_interface")->where($value)->update(["is_check"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
				}
			}
			$output->writeln( "【 $date 】验票完成".$value['invNo']);
			Db::commit();
			Cache::store("redis")->set("GetOrderInfoAndInvoiceInfo",0);
		}catch (\Exception $exception){
			Cache::store("redis")->set("generrateinvoice",0);
			Db::rollback();
			$output->writeln( "【 $date 】开票申请失败".$exception->getMessage().$exception->getLine().$exception->getFile());
		}

		 Cache::store("redis")->set("GetOrderInfoAndInvoiceInfo",0);

    }

    protected function GetData(){
    	$list=Db::name("invoice_interface")->where([["status",">=",1],["is_check","=",0],["updatetime","<=",date("Y-m-d 
    	H:i:s")]])->limit(20)->lock(true)->select()->toArray();
        return $list;
    }

    protected function GetOrderInfo($order){
    	$invoiceConf=Config::get('invoice');
    	if(!isset($invoiceConf[$order['XHFSBH']])){
    		Db::name('invoice_interface')->where($order)->update(['status'=>4,'remark'=>"金税配置不存在",'updatetime'=>date('Y-m-d H:i:s')]);
			echo '['.date('Y-m-d H:i:s').']';
			echo "金税配置不存在\r\n";
			return '';
    	}
    	$invoice = $invoiceConf[$order['XHFSBH']];
    	$tax =new \TaxInvoice($invoice['appKey'],$invoice['appSecret'],$invoice['entCode']);
		$result=$tax->GetOrderInfoAndInvoiceInfo($order['XHFSBH'],$order['DDQQLSH']);
		if(isset($result['ZTDM'])&& $result['ZTDM']=='000000'){
			foreach ($result['DDFPZXX'] as $value){
				$zt=$value['DDFPXX']['DDZT'];
				$ztxx=$value['DDFPXX']['DDZTXX'];
				if($zt=='030000'){
					$data= $value['DDFPXX'];
					$data['itemlist'] = $value['DDMXXX'];
					if($data['KPLX']==0)$this->updateGood($value['DDMXXX'],$order['invNo'],4);
					else $this->updateGood($value['DDMXXX'],$order['invNo'],6);
					$exit= json_encode($data,JSON_UNESCAPED_UNICODE);
					Db::name("invoice_interface")->where(["DDQQLSH"=>$value['DDFPXX']['DDQQLSH']])->update(["status"=>2,"result"=>$exit,"remark"=>$ztxx,"updatetime"=>date("Y-m-d H:i:s")]);
				}
				if($zt=='031999' ||$zt=='032997'||$zt=='032999'||$zt=='032998' ){
					Db::name("invoice_interface")->where(["DDQQLSH"=>$value['DDFPXX']['DDQQLSH']])->update(["status"=>4,"remark"=>$ztxx,"updatetime"=>date("Y-m-d H:i:s")]);
				}
				if($zt=='031000' ||$zt=='032000'){
					Db::name("invoice_interface")->where(["DDQQLSH"=>$value['DDFPXX']['DDQQLSH']])->update(["status"=>4,"remark"=>$ztxx,"updatetime"=>date("Y-m-d H:i:s")]);
				}
			}
		}else{
			Db::name("invoice_interface")->where($order)->update(["status"=>4,"remark"=>$result['message']?? $result['ZTXX'],"updatetime"=>date("Y-m-d H:i:s")]);
			echo "[".date("Y-m-d H:i:s")."]";
			echo $result['message']?? $result['ZTXX'] ."\r\n";
		}
    }

    protected function insertTicket($data,$invNo=''){
	    $json= json_decode($data,true);
		if(is_array($json)&&!empty($json)){
			$invinfo =Db::name("invoice_ticket")->where(["invNo"=>$invNo,'type'=>$json['KPLX'],'is_del'=>0])->findOrEmpty();
			if(empty($invinfo)){
				$invinfo["invNo"]=$invNo;
				$invinfo["status"]=1;
				$invinfo["addtime"]=date("Y-m-d H:i:s");
			}
			$invinfo["inv_type"]=$json['FPLXDM'];
			$invinfo["type"]=$json['KPLX'];
			$invinfo["inv_code"]=$json['FPDM'];
			$invinfo["inv_number"]=$json['FPHM'];
			$invinfo["inv_total"]=$json['JSHJ'];
			$invinfo["inv_subtotal"]=$json['HJJE'];
			$invinfo["open_date"]=$json['KPRQ'];
			$invinfo["seller_id"]=$json['XHFSBH'];
			$invinfo["seller_title"]=$json['XHFMC'];
			$invinfo["seller_addr"]=$json['XHFDZ'];
			$invinfo["seller_mobile"]=$json['XHFDH'];
			$invinfo["seller_bank"]=$json['XHFYH'];
			$invinfo["seller_bankNo"]=$json['XHFZH'];
			$invinfo["buyer_id"]=$json['GMFSBH'];
			$invinfo["buyer_title"]=$json['GMFMC'];
			$invinfo["buyer_addr"]=$json['GMFDZ'];
			$invinfo["buyer_mobile"]=$json['GMFDH'];
			$invinfo["buyer_bank"]=$json['GMFYH'];
			$invinfo["buyer_bankNo"]=$json['GMFZH'];
			$invinfo["tax_fee"]=$json['HJSE'];
			$invinfo["remark"]=$json['BZ']??$json['CHBZ'];
			$invinfo["issuer"]=$json['KPR'];
			$invinfo["reciver"]=$json['SKR'];
			$invinfo["reviewer"]=$json['FHR'];
			$invinfo["check_code"]=$json['JYM'];
			$invinfo["pdfstream"]=$json['PDFZJL']??"";
			$invinfo["item"]=json_encode($json['itemlist'],JSON_UNESCAPED_UNICODE);
			Db::name("invoice_ticket")->save($invinfo);
		}

    }
    private function updateGood($data,$invNo,$status=4){
			if(empty($data))return;
			if($status==6){
				$invinfo =Db::name('invoice_red')->where(['invRed'=>$invNo,'is_del'=>0])->findOrEmpty();
				$invNo = $invinfo['invNo']??'';
				if(!key_exists('ZXBM' , $data[0])){
					$data  =Db::name('invoice_good')
            		->where(['invNo'=>$invNo,'is_del'=>0])
            		->field("0 as FPHXZ,
									catNo  as SPBM,
									id as ZXBM,
									is_discount as YHZCBS,
									if(inv_tag=0,'',inv_tag) as  LSLBS,
									addTax	as ZZSTSGL,
									goodName as XMMC,
									'' as DW,
									'' as SPSL,
									'' as DJ,
									(-totalPrice) as JE,
									0 HSBZ,
									tax as SL,
									-taxPrice as SE")->select()->toArray();
				}
			}
			foreach ($data as $value){
				if($value['ZXBM']!=''){
					$invinfo =Db::name("invoice_good")->where(["invNo"=>$invNo,"id"=>$value['ZXBM'],'is_del'=>0])->findOrEmpty();
					if(empty($invinfo)) continue;
					if($status==4){
						$invinfo['goodPrice'] = $value['DJ'];
						$invinfo['totalPrice'] = $value['JE'];
						$invinfo['taxPrice'] = $value['SE'];
					}else{
						$invinfo['goodNum'] =0;
					}
					$invinfo['updatetime'] = date("Y-m-d H:i:s");
					Db::name("invoice_good")->save($invinfo);
				}
			}
			$this->updateQRd($invNo,$status);
		}


		private  function updateQRd($invNo,$status){
            	$qrdArr=Db::name("assoc")->where(["viceCode"=>$invNo,"is_del"=>0])->column("id,orderCode,cancel_fee");
                 if(!empty($qrdArr)){
                      foreach ($qrdArr as $value){
                          $qrdinfo =Db::name("qrd_info")->where(["sequenceNo"=>$value['orderCode']])->find();
                          if($qrdinfo==false){
                              echo  "$invNo 确认单信息未找到\r\n";break;
                          }
                          if($status==4){
	                            if($qrdinfo['inv_fee']<$value['cancel_fee']){
	                              echo  "$invNo 确认单信息开票金额不足 \r\n";
	                              break;
	                          }
	                          $update =[
	                              "ainv_fee"=>$qrdinfo['ainv_fee']+$value['cancel_fee'],
	                              "inv_fee"=>$qrdinfo['inv_fee']-$value['cancel_fee'],
	                              "invtime"=>date("Y-m-d H:i:s"),
	                              "inv_status"=>$qrdinfo['winv_fee']==0 &&($qrdinfo['inv_fee']-$value['cancel_fee'])==0 ? 3 : 2,
	                              "updatetime"=>date("Y-m-d H:i:s"),
	                          ];
                          }
                           if($status==6){
	                             if($qrdinfo['ainv_fee']<$value['cancel_fee']){
	                              echo "$invNo 确认单信息开票金额不足 \r\n";break;
	                          }
	                          $update =[
	                              "ainv_fee"=>$qrdinfo['ainv_fee']-$value['cancel_fee'],
	                              "winv_fee"=>$qrdinfo['winv_fee']+$value['cancel_fee'],
	                              "invtime"=>'',
	                              "inv_status"=>$qrdinfo['inv_fee']==0 &&($qrdinfo['ainv_fee']-$value['cancel_fee'])==0 ? 1 : 2,
	                              "status"=>$qrdinfo['inv_fee']==0 &&($qrdinfo['ainv_fee']-$value['cancel_fee'])==0&& $qrdinfo['pay_status']==1 ? 0 : 1,
	                              "updatetime"=>date("Y-m-d H:i:s"),
	                          ];
                          }
                          $qrdup = Db::name("qrd_info")->where($qrdinfo)->update($update);
                          if($qrdup==false){
                              echo "$invNo 确认单信息更新失败 \r\n";break;
                          }
                          $assoc=["status"=>$status==4?2:3,"assoc_time"=>date("Y-m-d H:i:s"),"updatetime"=>date("Y-m-d H:i:s")];
                          $assocup =Db::name("assoc")->where($value)->update($assoc);
                          if($assocup==false){
                               echo "$invNo 确认单关联信息更新失败 \r\n";break;
                          }
                      }
                 }
		}
}