cxinv/app/admin/listener/ComonQrd.php

<?php
declare (strict_types = 1);

namespace app\admin\listener;

use app\admin\model\Assoc;
use app\admin\model\InvoiceInfo;
use app\admin\model\InvoicePay;
use app\admin\model\InvoicePool;
use app\admin\model\InvoiceTicket;
use app\admin\model\Pay;
use app\admin\model\PayInfo;
use app\admin\model\PayInvoice;
use app\admin\model\QrdInfo;use app\admin\model\TagLog;
class ComonQrd
{
    /**
     * 事件监听处理
     * @return mixed
     */
    public function handle($event)
    {
        if($event['type']=='pay')$this->payComon($event);
		if($event['type']=='repay')$this->repayComon($event);
		if($event['type']=='inv'){
		    $this->invComon($event);
		    $this->InvToPay($event);
		}
		if($event['type']=='rinv'){
		    $this->returnInv($event);
		    $this->InvToPay($event,false);
		}
		if($event['type']=='check')$this->checkPay($event);
    }
    
    public function InvToPay($data,$bool=True){
                $invinfo =InvoicePool::where(['invNo'=>$data['invNo']])->findOrEmpty();
            	if($invinfo->isEmpty())return;
            	if($invinfo->inv_out =='GS2203161855277894')return;
            	if($bool){
            		if($invinfo->status!=4 ||$invinfo->is_comon!=1 )return;
            		$assoc_status=2;
            	}else{
            		$assoc_status=3;
            		if(in_array($invinfo->status,[5,6,7,8,9])||$invinfo->is_comon!=1 )return;
            	}

            	$assoc = Assoc::where(["viceCode"=>$data['invNo'],"status"=>$assoc_status,"is_del"=>0,"type"=>1])->select();
            	if($assoc->isEmpty()) return;
            	$orderArr = QrdInfo::whereIn("sequenceNo",array_column($assoc->toArray(),"orderCode"))->select();
            	if($orderArr->isEmpty())return;
            	$payArr=array_column($assoc->toArray(),"cancel_fee","orderCode");
            	$tag=[];
    	        $qrdSave=[];
            	foreach ($orderArr as $item){
            		if(!isset($payArr[$item->sequenceNo]))continue;
		           $tag_temp=[
		                'code'=>$item->sequenceNo,
		                'tag_id'=>11,
		                'creater'=>'system',
		                'createrid'=>0,
		                'tag_fee'=>0,
		                'tag_img'=>'',
		                "tag_code"=>$data['invNo'],
		                'status'=>$bool?1:0
		                ];
		            $qrd=[
		                'id'=>$item->id,
			            'wpay_fee'=>$item->wpay_fee,
			            'pay_status'=>$item->pay_status,
			            'pay_tag_fee'=>$item->pay_tag_fee,
			            'pay_tag' => 1
			            ];
		            if($bool){
		            	if($item->wpay_fee>$payArr[$item->sequenceNo]){
		            		$tag_temp['tag_fee']= $payArr[$item->sequenceNo];
		            		$qrd['pay_tag_fee'] =$item->pay_tag_fee+$payArr[$item->sequenceNo];
		            		$qrd['wpay_fee'] = $item->wpay_fee-$payArr[$item->sequenceNo];
		            		$qrd['pay_status'] = ($qrd['wpay_fee']==0 &&$item->pay_fee==0) ? 3:($qrd['apay_fee']==0?1:2);
		            	}else{
		            		$tag_temp['tag_fee'] =$item->wpay_fee;
		            		$qrd['pay_tag_fee'] =$item->pay_tag_fee+ $item->wpay_fee;
		            		$qrd['wpay_fee'] = 0;
		            		$qrd['pay_status'] = ($qrd['wpay_fee']==0 &&$item->pay_fee==0) ? 3:($qrd['apay_fee']==0?1:2);
		            	}
		            }else{

							$tag_temp['tag_fee']= $payArr[$item->sequenceNo];
							$tag_fee = ($item->pay_tag_fee>$payArr[$item->sequenceNo])?$payArr[$item->sequenceNo]:$item->pay_tag_fee;
				            $qrd['pay_tag_fee']=$item->pay_tag_fee-$tag_fee;
				            $qrd['wpay_fee'] = $item->wpay_fee+$tag_fee;
				            $qrd['pay_status'] = ($qrd['wpay_fee']==0  &&$item->pay_fee==0) ? 3:($qrd['apay_fee']==0?2:1);
		            }
		            $qrdSave[]=$qrd;
		            $tag[]=$tag_temp;
            	};
            	(new \app\admin\model\QrdInfo)->saveAll($qrdSave);
            	(new \app\admin\model\TagLog)->saveAll($tag);
    }
    
    public function payComon($data){
    	$payinfo = Pay::where("payNo",$data['payNo'])->findOrEmpty();
    	if($payinfo->isEmpty()) return;
    	if($payinfo->is_comon!=1)return;
    	if(!in_array($payinfo->status,[1,2]))return;
    	$qrdNo = PayInfo::alias("a")->leftJoin("ComonOrder b","a.cgdNo=b.cgdNo")->where(["payNo"=>$data['payNo'],"is_del"=>0,"a.status"=>1])->column("orderCode");
    	$qrdinfo = QrdInfo::where([["sequenceNo","in",$qrdNo],["wpay_fee",">",0]])->select();
    	if($qrdinfo->isEmpty())return;
    	$this->CheckComonOrder($payinfo);
    	$tag=[];
    	$qrdSave=[];
    	$payfee=$payinfo['apay_fee'];
    	foreach ($qrdinfo as $item){
    		$tag_temp=[
    			"code"=>$item->sequenceNo,
    			"tag_id"=>10,
    			"creater"=>"system",
    			"createrid"=>0,
    			"tag_fee"=>0,
    			"tag_img"=>"",
    			"status"=>1
    			];
    		$qrd=[
    			"id"=>$item->id,
	            "wpay_fee"=>$item->wpay_fee,
	            "apay_fee"=>$item->apay_fee,
	            "pay_status"=>$item->pay_status,
	            "pay_tag_fee"=>0,
	            "pay_tag" => 1
	            ];
    		if($item->wpay_fee>$payfee){
    			$tag_temp['tag_fee'] = $payfee;
    			$qrd['pay_tag_fee'] = $payfee;
    			$qrd['wpay_fee'] = $item->wpay_fee-$payfee;
    			$qrd['apay_fee'] = $item->apay_fee+$payfee;
    			$qrd['pay_status'] = ($qrd['wpay_fee']==0 &&$item->pay_fee==0) ? 3:($qrd['apay_fee']==0?1:2);
    			$payfee=0;
    		}else{
    			$payfee=$payfee-$item->wpay_fee;
    			$tag_temp['tag_fee'] =$item->wpay_fee;
    			$qrd['pay_tag_fee'] = $item->wpay_fee;
    			$qrd['wpay_fee'] = 0;
    			$qrd['apay_fee'] = $item->apay_fee+$item->wpay_fee;
    			$qrd['pay_status'] = ($qrd['wpay_fee']==0 &&$item->pay_fee==0) ? 3:($qrd['apay_fee']==0?1:2);
    		}
    		$qrdSave[]=$qrd;
    		$tag[]=$tag_temp;
    		if($data['pay_fee']==0) break;
    	}
    	(new \app\admin\model\QrdInfo)->saveAll($qrdSave);
    	(new \app\admin\model\TagLog)->saveAll($tag);
    }
    public function repayComon($data)
    {
        $payinfo = Pay::where('payNo', $data['payNo'])->findOrEmpty();
        if ($payinfo->isEmpty()) return;
        if ($payinfo->is_comon != 1) return;
        if (!in_array($payinfo->status, [1, 2])) return;
        $qrdNo   = PayInfo::alias('a')->leftJoin('ComonOrder b', 'a.cgdNo=b.cgdNo')->where(['payNo' => $data['payNo'], 'is_del' => 0, 'a.status' => 1])->column('orderCode');
        $qrdinfo = QrdInfo::where([['sequenceNo', 'in', $qrdNo], ['pay_tag_fee', '>', 0], ['pay_tag', '=', 1]])
            ->select();
        if ($qrdinfo->isEmpty()) return;
        $this->CheckComonOrder($payinfo);
        $qrdSave =$del= [];
        foreach ($qrdinfo as $item) {
            $qrd = [
                'id'          => $item->id,
                'wpay_fee'    => $item->wpay_fee,
                'apay_fee'    => $item->apay_fee,
                'pay_status'  => $item->pay_status,
                'pay_tag_fee' => 0,
                'pay_tag'     => 1
            ];
            if ($item->pay_tag_fee >= $item->apay_fee) {
                $qrd['pay_tag_fee']  = 0;
                $qrd['pay_tag']  =0;
                $qrd['wpay_fee']     = $item->wpay_fee + $item->pay_tag_fee;
                $qrd['apay_fee']     = 0 ;
                $qrd['pay_status']   = ($qrd['wpay_fee'] == 0 && $item->pay_fee == 0) ? 3 : ($qrd['apay_fee'] == 0 ? 1 : 2);
            } else {
                $qrd['pay_tag_fee']  = 0;
                $qrd['pay_tag']  = 0;
                $qrd['wpay_fee']     = $item->wpay_fee +  $item->pay_tag_fee;
                $qrd['apay_fee']     = $item->apay_fee-$item->pay_tag_fee ;
                $qrd['pay_status']   = ($qrd['wpay_fee'] == 0 && $item->pay_fee == 0) ? 3 : ($qrd['apay_fee'] == 0 ? 1 : 2);

            }
            $qrdSave[] = $qrd;
            $del[]=$item->sequenceNo;
        }
        (new \app\admin\model\QrdInfo)->saveAll($qrdSave);
        (new \app\admin\model\TagLog)->where('code','in',$del)->delete();
    }
    public function returnInv($data){
            $invinfo =InvoicePool::where(['invNo'=>$data['invNo'],"status"=>[5,6,7,8,9]])->findOrEmpty();
        	if($invinfo->isEmpty())return;
        	if($invinfo->is_comon!=1 )return;
        	$invpay =InvoicePay::where(['invNo'=>$data['invNo']])->findOrEmpty();
        	if($invpay->isEmpty())return;
        	if($invpay->status!=1 )return;
        	$payinfo = Pay::where('payNo',$invpay['payNo'])->findOrEmpty();
        	if($payinfo->isEmpty()) return;
        	if($payinfo->is_comon!=1)return;
        	$payinvoice = PayInvoice::where(["hpNo"=>$invpay->hpNo,"status"=>4])->findOrEmpty();
        	if($payinvoice->isEmpty())return;
        	$payinvoice->status=10;
        	$payinvoice->save();
        	 $payinfo->winv_fee = $payinfo->winv_fee+$payinvoice->inv_fee;
        	 $payinfo->ainv_fee = $payinfo->ainv_fee-$payinvoice->inv_fee;
        	 $payinfo->inv_status = ($payinfo->winv_fee==0 &&$payinfo->inv_fee==0)?3:($payinfo->ainv_fee==0?2:1);
        	 $this->CheckComonOrder($payinfo);
        	  $payinfo->save();
        	  $invpay->status =2;
        	  $invpay->save();
    }

     protected function checkPay($data){
    	$payinfo = Pay::where('payNo',$data['payNo'])->findOrEmpty();
    	if($payinfo->isEmpty()) return;
    	if($payinfo->is_comon!=1)return;
    	$this->CheckComonOrder($payinfo);

    }

    public function CheckComonOrder($payinfo){
    	if($payinfo->status==3||$payinfo->status==4 ){
	        PayInfo::alias('a')
	        ->leftJoin('ComonOrder b','a.cgdNo=b.cgdNo')
	            ->where(['payNo'=>$payinfo->payNo,'is_del'=>0,'a.status'=>0])
	            ->update(['b.status'=>0]);
    	}else{
    		if($payinfo->inv_status==3 &&$payinfo->pay_status==3){
	            PayInfo::alias('a')
	            ->leftJoin('ComonOrder b','a.cgdNo=b.cgdNo')
	            ->where(['payNo'=>$payinfo->payNo,'is_del'=>0,'a.status'=>1])
	            ->update(["b.status"=>2]);
		        }elseif($payinfo->inv_status!=3|| $payinfo->pay_status!=3){
		            PayInfo::alias('a')
		            ->leftJoin('ComonOrder b','a.cgdNo=b.cgdNo')
		            ->where(['payNo'=>$payinfo->payNo,'is_del'=>0,'a.status'=>1])
		            ->update(['b.status'=>1]);
		        }
    		}
    }
    
   //新开票完成 创建对应的标签；

    protected function invComon($data){
    	$invinfo =InvoicePool::where(['invNo'=>$data['invNo']])->findOrEmpty();
    	if($invinfo->isEmpty())return;
    	if($invinfo->status!=4 ||$invinfo->is_comon!=1 )return;
    	$invpay =InvoicePay::where(['invNo'=>$data['invNo']])->findOrEmpty();
    	if($invpay->isEmpty())return;
    	if($invpay->status!=0 )return;
    	$payinfo = Pay::where('payNo',$invpay['payNo'])->findOrEmpty();
    	if($payinfo->isEmpty()) return;
    	if($payinfo->is_comon!=1)return;
    	if(!in_array($payinfo->status,[1,2]))return;
    	$ticket =InvoiceTicket::where(["invNo"=>$data['invNo'],"type"=>0])->json(['item'])->findOrEmpty();
    	if($ticket->isEmpty())return;
    	$pay_fee=0;
    	    	if($payinfo->winv_fee >=$invinfo->inv_value){
    	    		$pay_fee = $invinfo->inv_value;
    	    	}else{
    	    		$pay_fee = $payinfo->winv_fee;
    	    	}
    	$payinvoice = [
    		"payNo"=>$invpay['payNo'],
    		"hpNo"=>makeNo("hp"),
    		"apply_id"=>0,
    		"apply_name"=>"system",
    		"invType"=>$invinfo->open_type==3?1:3,
    		"invoiceType"=>$invinfo->inv_type,
    		"inv_fee"=>$pay_fee,
    		"inv_subtotal_amount"=>$ticket->inv_subtotal,
    		"inv_amount"=>$ticket->inv_total,
    		"invStatus"=>1,
    		"status"=>4,
    		"check_time"=>date("Y-m-d H:i:s"),
    		"open_time"=>$ticket->open_date,
    		"invoiceNumber"=>$ticket->inv_number,
    		"seller_check"=>1,
    		"buyer_check"=>1,
    		"invoiceCode"=>$ticket->inv_code,
    		"checkNumber"=>$ticket->check_code,
    		"checkApi"=>$data['checkApi']??0
    		];
    	$payinfo->winv_fee = $payinfo->winv_fee-$pay_fee;
    	$payinfo->ainv_fee = $payinfo->ainv_fee+$pay_fee;
    	$payinfo->inv_status = ($payinfo->winv_fee==0 &&$payinfo->inv_fee==0)?3:($payinfo->ainv_fee==0?1:2);
    	$this->CheckComonOrder($payinfo);
    	$payinfo->save();
    	PayInvoice::create($payinvoice);
    	if(!empty($ticket->item)){
    	    		$itemArr=[];
    	    		foreach ($ticket->item as $item){
    	    		    $temp=[];
    	    		    $temp['name']=$item['XMMC'];
    	    		    $temp['unit']=$item['DW'];
    	    		    $temp['quantity']=$item['SPSL'];
    	    		    $temp['unit_price']=$item['DJ'];
    	    		    $temp['amount']=$item['JE'];
    	    		    $temp['tax']=$item['SE'];
    	    		    $temp['tax_rate']=strval($item['SL']*100)."%";
    				    $itemArr[]=$temp;
    			    }
    	}
    		    $info=[
    			    'payNo'          =>$invpay['payNo'] ,
    			    'hpNo'           =>$payinvoice['hpNo'] ,
    			    'type'           =>$invinfo['inv_type'] ,
    			    'number'         =>$ticket->inv_number ,
    			    'code'           =>$ticket->inv_code ,
    			    'check_code'     =>$ticket->check_code ,
    			    'issue_date'     =>date('Ymd' ,strtotime($ticket->open_date)) ,
    			    'buyer_name'     =>$ticket->buyer_title ,
    			    'buyer_id'       =>$ticket->buyer_id ,
    			    'buyer_address'  =>$ticket->buyer_addr . $ticket->buyer_mobile ,
    			    'buyer_bank'     =>$ticket->buyer_bank . $ticket->buyer_bankNo ,
    			    'seller_name'    =>$ticket->seller_title ,
    			    'seller_id'      =>$ticket->seller_id ,
    			    'seller_address' =>$ticket->seller_addr . $ticket->seller_mobile ,
    			    'seller_bank'    =>$ticket->seller_bank . $ticket->seller_bankNo ,
    			    'subtotal_amount'=>$ticket->inv_subtotal ,
    			    'subtotal_tax'   =>$ticket->tax_fee ,
    			    'total'          =>$ticket->inv_total ,
    			    'item_list'      =>json_encode($itemArr,JSON_UNESCAPED_UNICODE) ,
    			    'receiver'       =>$ticket->reciver ,
    			    'issuer'         =>$ticket->issuer ,
    			    'reviewer'       =>$ticket->reviewer ,
    			    'change_field'   =>'' ,
    		    ];
    		    InvoiceInfo::create($info);
    		    $invpay->hpNo = $payinvoice['hpNo'];
    		    $invpay->status =1;
    		    $invpay->save();
    }
}