ad

app/admin/command/QueryInvalidInvoice.php

@@ -0,0 +1,94 @@
+<?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\Config;
+use TaxInvoice;
+use think\facade\Db;
+class QueryInvalidInvoice extends Command
+{
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('queryinvalidinvoice')
+            ->setDescription('the queryinvalidinvoice command');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+//    	$this->ChickInvoice('91110113MA004JNJ28',"1100223130","35084031");
+    	$date=date("Y-m-d H:i:s");
+    	Db::startTrans();
+    	try{
+    	$data =Db::name("invoice_return")->where(["status"=>1,"red_inv"=>"","is_del"=>0])->where("updatetime","<=",date("Y-m-d H:i:s"))->findOrEmpty();
+    	if(empty($data))return;
+    	$invoiceInfo = Db::name("invoice_ticket")->where(["invNo"=>$data['invNo'],"is_del"=>0,"status"=>1])
+    	->findOrEmpty();
+    	if(empty($invoiceInfo))throw new \Exception("未找到开票数据");
+		$check=$this->ChickInvoice($invoiceInfo['seller_id'],$invoiceInfo['inv_code'],$invoiceInfo['inv_number']);
+		if(isset($check['ZTDM']) && $check['ZTDM']=='001000') {
+			$reups=Db::name("invoice_return")->where($data)->update(["status"=>1,"remark"=>$data['remark']."({$check['ZTXX']})","updatetime"=>date("Y-m-d H:i:s",time()+120)]);
+			if($reups==false)throw new \Exception("退票数据更新失败");
+			throw new \Exception("发票作废中");
+		}
+		if(isset($check['ZTDM']) && $check['ZTDM']=='000000'){
+			$reup=Db::name("invoice_return")->where($data)->update(["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
+			if($reup==false)throw new \Exception("退票数据更新失败");
+			  $qrdArr=Db::name("assoc")->where(["viceCode"=>$data['invNo'],"is_del"=>0,"status"=>2])->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){
+                                throw  new \Exception("确认单信息未找到");
+                              }
+                              if($qrdinfo['ainv_fee']<$value['cancel_fee']){
+                                   throw  new \Exception("确认单信息开票金额不足");
+                              }
+                              $update =[
+                                  "winv_fee"=>$qrdinfo['winv_fee']+$value['cancel_fee'],
+                                  "ainv_fee"=>$qrdinfo['ainv_fee']-$value['cancel_fee'],
+                                  "inv_status"=>$qrdinfo['inv_fee']==0 &&$qrdinfo['ainv_fee']-$value['cancel_fee']==0 ? 1 : 2,
+                                  "status"=>$qrdinfo['ainv_fee']==0 &&$qrdinfo['inv_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){
+                                  throw  new \Exception("确认单信息更新失败");
+                              }
+                              $assoc=["status"=>3,"updatetime"=>date("Y-m-d H:i:s")];
+                              $assocup =Db::name("assoc")->where($value)->update($assoc);
+                              if($assocup==false){
+                                  throw  new \Exception("确认单关联信息更新失败");
+                              }
+                          }
+                     }else{
+                     	throw  new \Exception("未找到关联订单数据信息");
+                     }
+		}else{
+			$reup=Db::name("invoice_return")->where($data)->update(["status"=>4,"remark"=>$data['remark']."({$check['ZTXX']})","updatetime"=>date("Y-m-d H:i:s")]);
+			if($reup==false)throw new \Exception("退票数据更新失败");
+		}
+		Db::commit();
+		$output->writeln("[$date] {$data['invNo']}数据处理完成");
+    	}catch (\Exception $e){
+    		Db::rollback();
+    		$output->writeln("[$date] ".$e->getMessage());
+    	}
+
+
+    }
+
+
+    private function ChickInvoice($sellid,$invoice_code,$invoice_num){
+    	$invoice=Config::get("invoice");
+    	$tax =new TaxInvoice($invoice['appKey'],$invoice['appSecret'],$invoice['entCode']);
+    	$reuslt = $tax->QueryInvalidInvoice($sellid,$invoice_code,$invoice_num);
+    	return $reuslt;
+    }
+}

config/console.php

@@ -7,6 +7,7 @@ return [
     'commands' => [
     	"generrateinvoice"=>app\admin\command\GenerrateInvoice::class,
 		"getorderinfoandinvoiceinfo"=>app\admin\command\GetOrderInfoAndInvoiceInfo::class,
+		"queryvalidinvoice"=>app\admin\command\QueryInvalidInvoice::class,
 
 		'copyCxData'=>app\command\copyCxData::class,//复制采销数据到中间表
         'handleCxData'=>app\command\handleCxData::class,//处理中间表的采销数据

extend/TaxInvoice.php

@@ -499,7 +499,7 @@ class TaxInvoice {
 * @param string $invoiceCode
  * @return array|bool|float|int|mixed|\stdClass|string|null
 */public function QueryInvalidInvoice(string $seller_id='',string $invoiceNumber='',string $invoiceCode=''){
-    	$url=$this->domain."/api/order-api/order-api/v5/DeprecateInvoices?access_token=".$this->GetToken();
+    	$url=$this->domain."/api/order-api/order-api/v5/QueryInvalidInvoice?access_token=".$this->GetToken();
 		$param=[
 			"XHFSBH"=>$seller_id,
 			"FPDM"=>$invoiceCode,