devbox
凡人多烦事01
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

微信电子发票--“自建平台模式”--小程序开票_${einvoice_url}

作者：凡人多烦事01 | 2024-03-23 22:07:41

赞

踩

${einvoice_url}

注：小程序开发票在官方文档（https://mp.weixin.qq.com/wiki?t=resource/res_main&id=21518166863ccFdP）的第四节


项目说明 

1.我有一个小程序，是交通行业的。用户买完票之后，可以在电子票页面申请开电子发票；

2. 小程序开发票用的是公众号的access_token，发送到用户卡包也是通过公众号发的，小程序要做的是申请电子发票和完成授权。
3. 虽然买完票就能申请发票，但是为了减少后续的冲红操作，在用户乘车之后才会去申请第三方平台开发票；
4. 代码用的是PHP。


项目大概逻辑

1. 商户获取获取access_token。（方法：getAccessToken()）
2. 提前获取开票平台标识s_pappid（方法：getInvoiceUrl()）
3. 设置商户联系方式（方法：setContact()）
4. 商户获取授权页（方法：getTicket()）；
5.  商户获取授权页url（方法：getAuthUrl()）；
6. 根据第5步的结果，在小程序开票按钮的点击事件上部署跳转到小程序授权页的逻辑；
7. 获取用户填写的抬头信息有两种办法：1）主动查询授权状态（方法：getAuthData()）、2）根据授权回调获取授权状态（方法：getAuthDataWxAccount()）；
8. 创建发票卡券模板（方法：getInvoiceCardId()）；
9. 在自建发票平台开具电子发票（意思是，自己去开发票，比如通过第三方开票平台，然后把开票返回的发票号码、发票代码、发票pdf文件等保存下来；最后再用这些信息调用微信的PDF上传接口和下发到用户卡包的接口）；
10. 上传发票PDF文件（方法：setPDF()）；
11. 将电子发票添加到用户微信卡包（方法：sendInvoice()）。

注：具体的使用方法请看“调用示例”


代码与说明

说明：域名空间下面引用的类，基本上都是数据库操作，大家可以不用看，主要是所取到的要用的字段含义。

AppIdModel用的表是zc2_ticket_appid，请求微信接口用到的字段基本都在这张表了：

  1. CREATE TABLE `zc2_ticket_appid` (
  2.   `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
  3.   `name` varchar(50) NOT NULL COMMENT '调用方名称',
  4.   `desc` varchar(100) NOT NULL COMMENT '调用方描述',
  5.   `appid` varchar(50) NOT NULL COMMENT '调用方APPID',
  6.   `appsecret` varchar(50) DEFAULT NULL COMMENT '调用方秘钥',
  7.   `wx_appid` varchar(50) NOT NULL DEFAULT '' COMMENT '微信APPID',
  8.   `wx_appsecret` varchar(125) NOT NULL DEFAULT '' COMMENT '微信APPSECRET',
  9.   `wx_mch_id` varchar(50) NOT NULL DEFAULT '' COMMENT '商户ID，多商户小程序在zc2_sale_address表配置',
  10.   `pay_acid` int(11) NOT NULL DEFAULT '0' COMMENT '支付商户ID，多商户小程序在zc2_sale_address表配置',
  11.   `access_token` varchar(1000) NOT NULL DEFAULT '' COMMENT '小程序access_token',
  12.   `status` tinyint(4) NOT NULL DEFAULT '1' COMMENT '1:有效 2：无效',
  13.   `createtime` int(10) DEFAULT '0',
  14.   `createuser` int(10) DEFAULT '0',
  15.   `updatetime` int(10) DEFAULT '0',
  16.   `updateuser` int(10) DEFAULT '0',
  17.   `bonus_insurance` tinyint(1) NOT NULL DEFAULT '2' COMMENT '赠送保险开关：1 开，2 关',
  18.   `type` tinyint(1) NOT NULL DEFAULT '1' COMMENT '渠道类别：1前端；2管理后台；3设备接口',
  19.   `auth_ticket` varchar(1000) NOT NULL DEFAULT '' COMMENT '授权页ticket凭证',
  20.   `invoice_url` varchar(512) NOT NULL DEFAULT '' COMMENT '开票平台链接',
  21.   `invoice_card_id` varchar(512) NOT NULL DEFAULT '' COMMENT '发票卡券模板',
  22.   `phone` varchar(20) NOT NULL DEFAULT '' COMMENT '商户联系手机',
  23.   `wx_account_appid` varchar(50) NOT NULL DEFAULT '' COMMENT '小程序关联的微信公众号APPID',
  24.   `wx_account_appsecret` varchar(125) NOT NULL DEFAULT '' COMMENT '小程序关联的微信公众号APPSECRET',
  25.   `wx_account_access_token` varchar(1000) NOT NULL DEFAULT '' COMMENT '小程序关联的微信公众号access_token',
  26.   PRIMARY KEY (`id`),
  27.   UNIQUE KEY `appid` (`appid`)
  28. ) ENGINE=MyISAM AUTO_INCREMENT=15 DEFAULT CHARSET=utf8 COMMENT='接口调用方appid表';
  29.  
  1. <?php
  2. /**
  3.  * 电子发票
  4.  */
  5. namespace Kgkx\Domain;
  6. use Focusspot\Model\AppId AS AppIDModel;
  7. use Focusspot\Common\Exception\LocalServiceException;
  8. use PhalApi\CUrl;
  9. use Focusspot\Common\Exception\RemoteServiceException;
  10. use Kgkx\Model\OrderTicket AS ModelOrderTickets;
  11. use Kgkx\Model\Invoice AS ModelInvoice;
  12. use Kgkx\Model\AppConfig AS ModelAppConfig;
  13.  
  14. class Invoice
  15. {
  16.  
  17.     public function __construct()
  18.     {
  19.  
  20.     }
  21.  
  22.     /**
  23.      * @Function: 获取AccessToken
  24.      * @param $appId
  25.      * @return mixed
  26.      * @throws LocalServiceException
  27.      * @throws RemoteServiceException
  28.      * 从数据库查询access_token 如果过期，则调用微信官方接口，获取新的
  29.      * access_token，并更新新的access_token和过期时间到数据库
  30.      */
  31.     public function getAccessToken($appId)
  32.     {
  33.         $appIdModel = new AppIDModel();
  34.         $row = $appIdModel->fetchByWxAppId($appId);
  35.         if($row)
  36.         {
  37.             //存在数据库的公众号access_token
  38.             $token = empty($row['wx_account_access_token']) ? null : json_decode($row['wx_account_access_token'], true);
  39.             if($token && $token['expire'] > time())
  40.             {
  41.                 return $token['access_token'];
  42.             }else
  43.             {
  44.                 $wxAccountAppid = $row['wx_account_appid'];//公众号appid
  45.                 $wxAccountAppSecret = $row['wx_account_appsecret'];//公众号appsecret
  46.                 $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$wxAccountAppid}&secret={$wxAccountAppSecret}";
  47.                 $curl = new CUrl(30);
  48.                 $ret = $curl->get($url);
  49.                 $ret = json_decode($ret, true);
  50.                 if(isset($ret['errcode']))
  51.                 {
  52.                     \PhalApi\DI()->logger->error('Function getAccessToken.$url : ' . $url);
  53.                     throw new RemoteServiceException("获取AccessToken失败:".$ret['errmsg'],98);
  54.                 }else
  55.                 {
  56.                     //保存到数据库
  57.                     $expire = time() + $ret['expires_in'] - 200; //过期时间
  58.                     $accessToken = $ret['access_token'];
  59.                     $updateData = array('wx_account_access_token' => json_encode(array('access_token' => $accessToken, 'expire' => $expire)));
  60.                     $params = array('wx_appid' => $appId);
  61.                     $appIdModel->updateData($updateData, $params);
  62.                     return $accessToken;
  63.                 }
  64.             }
  65.         }else
  66.         {
  67.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  68.         }
  69.     }
  70.  
  71.  
  72.     /**
  73.      * @function 验证access_token是否有效
  74.      * @param $access_token
  75.      * @return bool
  76.      */
  77.     public function checkAccessToken($access_token)
  78.     {
  79.         \PhalApi\DI()->logger->info('Function checkAccessToken.$access_token : ' . $access_token);
  80.         if(!empty($access_token))
  81.         {
  82.             $url = "https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token=".$access_token;
  83.             $curl = new CUrl(30);
  84.             $ret = $curl->get($url);
  85.             \PhalApi\DI()->logger->info('Function checkAccessToken.$ret : ' . $ret);
  86.  
  87.             $ret = json_decode($ret, true);
  88.             if(!isset($ret['errcode']))
  89.             {
  90.                 return true;
  91.             }
  92.         }
  93.  
  94.         return false;
  95.     }
  96.  
  97.  
  98.     /**
  99.      * @function 获取自身的开票平台识别码
  100.      * @param $appId
  101.      * @return bool|mixed
  102.      * @throws LocalServiceException
  103.      * @throws RemoteServiceException
  104.      * @desc 开票平台可以通过此接口获得本开票平台的预开票url，进而获取s_pappid。
  105.      *       开票平台将该s_pappid并透传给商户，商户可以通过该s_pappid参数在微信
  106.      *       电子发票方案中标识出为自身提供开票服务的开票平台。
  107.      */
  108.     public function getInvoiceUrl($appId)
  109.     {
  110.         $appIdModel = new AppIDModel();
  111.         $row = $appIdModel->fetchByWxAppId($appId);
  112.         if($row)
  113.         {
  114.             $invoiceUrl = empty($row['invoice_url']) ? null : $row['invoice_url'];
  115.             if($invoiceUrl)
  116.             {
  117.                 return $invoiceUrl;
  118.             }else
  119.             {
  120.                 $token = $this->getAccessToken($appId);
  121.                 $url = "https://api.weixin.qq.com/card/invoice/seturl?access_token={$token}";
  122.                 $curl = new CUrl(30);
  123.                 $curlRes = $curl->post($url,json_encode(array()));
  124.                 $ret = json_decode($curlRes, true);
  125.  
  126.                 \PhalApi\DI()->logger->error('$appId : ' . $appId);
  127.                 \PhalApi\DI()->logger->error('$url : ' . $url);
  128.                 \PhalApi\DI()->logger->error('$res : ' . json_encode($curlRes));
  129.  
  130.                 if($ret['errcode']==0 and $ret['errmsg']=='ok')
  131.                 {
  132.                     $invoiceUrl = $ret['invoice_url'];
  133.                     $updateData = array('invoice_url' => $invoiceUrl);
  134.                     $params = array('wx_appid' => $appId);
  135.                     $appIdModel->updateData($updateData, $params);
  136.                     return $invoiceUrl;
  137.                 }else
  138.                 {
  139.                     throw new RemoteServiceException("获取自身的开票平台识别码失败:".$ret['errcode'].$ret['errmsg'],98);
  140.                 }
  141.             }
  142.         }else
  143.         {
  144.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  145.         }
  146.     }
  147.  
  148.  
  149.     /**
  150.      * @function 设置商户联系方式
  151.      * @param $appId
  152.      * @param $time_out
  153.      * @return bool|mixed
  154.      * @throws LocalServiceException
  155.      * @throws RemoteServiceException
  156.      * @desc 商户获取授权链接之前，需要先设置商户的联系方式
  157.      */
  158.     public function setContact($appId,$time_out)
  159.     {
  160.         $appIdModel = new AppIDModel();
  161.         $row = $appIdModel->fetchByWxAppId($appId);
  162.         if($row and $row['phone'])
  163.         {
  164.             //1.获取AccessToken
  165.             $token = $this->getAccessToken($appId);
  166.  
  167.             //2.
  168.             $phone = $row['phone'];
  169.             $url = "https://api.weixin.qq.com/card/invoice/setbizattr?action=set_contact&access_token={$token}";
  170.             $params = json_encode(array('contact'=>array('phone'=>$phone,'time_out'=>$time_out)));
  171.             $curl = new CUrl(30);
  172.             $curlRes = $curl->post($url,$params);
  173.             $ret = json_decode($curlRes, true);
  174.  
  175.             \PhalApi\DI()->logger->error('$appId : ' . $appId);
  176.             \PhalApi\DI()->logger->error('$url : ' . $url);
  177.             \PhalApi\DI()->logger->error('$res : ' . json_encode($curlRes));
  178.  
  179.             if(!empty($ret['errcode'])) {
  180.                 throw new RemoteServiceException("设置商户联系方式失败:".$ret['errcode'].$ret['errmsg'],98);
  181.  
  182.             }else {
  183.                 return $ret;
  184.             }
  185.  
  186.         }else
  187.         {
  188.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  189.         }
  190.     }
  191.  
  192.  
  193.     /**
  194.      * @function 获取授权页ticket
  195.      * @param $appId
  196.      * @return bool|mixed
  197.      * @throws LocalServiceException
  198.      * @throws RemoteServiceException
  199.      * @desc 商户在调用授权页前需要先获取一个7200s过期的授权页ticket，在获取授权页接口中，
  200.      *       该ticket作为参数传入，加强安全性。
  201.      */
  202.     public function getTicket($appId)
  203.     {
  204.         $appIdModel = new AppIDModel();
  205.         $row = $appIdModel->fetchByWxAppId($appId);
  206.         if($row)
  207.         {
  208.             $authTicket = empty($row['auth_ticket']) ? null : json_decode($row['auth_ticket'], true);
  209.             if($authTicket && $authTicket['expire'] > time())
  210.             {
  211.                 return $authTicket['ticket'];
  212.             }else
  213.             {
  214.                 $token = $this->getAccessToken($appId);
  215.                 $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token={$token}&type=wx_card";
  216.                 $curl = new CUrl(30);
  217.                 $ret = $curl->get($url);
  218.                 $ret = json_decode($ret, true);
  219.  
  220.                 \PhalApi\DI()->logger->error('$appId : ' . $appId);
  221.                 \PhalApi\DI()->logger->error('$url : ' . $url);
  222.                 \PhalApi\DI()->logger->error('$ret : ' . json_encode($ret));
  223.  
  224.                 if(!empty($ret['errcode']))
  225.                 {
  226.                     throw new RemoteServiceException("获取网页授权ticket失败:".$ret['errcode'].$ret['errmsg'],98);
  227.                 }else
  228.                 {
  229.                     $expire = time() + $ret['expires_in'] - 200; //过期时间
  230.                     $ticket = $ret['ticket'];
  231.                     $updateData = array('auth_ticket' => json_encode(array('ticket' => $ticket, 'expire' => $expire)));
  232.                     $params = array('wx_appid' => $appId);
  233.                     $appIdModel->updateData($updateData, $params);
  234.                     return $ticket;
  235.                 }
  236.             }
  237.         }else
  238.         {
  239.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  240.         }
  241.     }
  242.  
  243.  
  244.     /**
  245.      * @function 获取授权页链接
  246.      * @param $appId
  247.      * @param $s_pappid string 开票平台在微信的标识号，商户需要找开票平台提供
  248.      * @param $order_id string 订单id，在商户内单笔开票请求的唯一识别号
  249.      * @param $money string 订单金额，以分为单位
  250.      * @param $timestamp int 时间戳
  251.      * @param $source string 开票来源，app：app开票，web：微信h5开票，wxa：小程序开发票，wap：普通网页开票
  252.      * @param $redirect_url string 授权成功后跳转页面。本字段只有在source为H5的时候需要填写，引导用户在微信中进行下一步流程。app开票因为从外部app拉起微信授权页，授权完成后自动回到原来的app，故无需填写。
  253.      * @param $ticket string 授权页ticket
  254.      * @param $type int 授权类型，0：开票授权，1：填写字段开票授权，2：领票授权
  255.      *
  256.      * @return bool|mixed
  257.      * @throws LocalServiceException
  258.      * @throws RemoteServiceException
  259.      */
  260.     public function getAuthUrl($appId,$s_pappid,$order_id,$money,$timestamp,$source,$redirect_url,$ticket,$type)
  261.     {
  262.         //1.获取AccessToken
  263.         $token = $this->getAccessToken($appId);
  264.  
  265.         //2.
  266.         $url = "https://api.weixin.qq.com/card/invoice/getauthurl?access_token={$token}";
  267.         $params = array(
  268.             's_pappid'=>$s_pappid,
  269.             'order_id'=>$order_id,
  270.             'money'=>$money,
  271.             'timestamp'=>$timestamp,
  272.             'source'=>$source,
  273.             'redirect_url'=>$redirect_url,
  274.             'ticket'=>$ticket,
  275.             'type'=>$type,
  276.         );
  277.         $curl = new CUrl(30);
  278.         $curlRes = $curl->post($url,json_encode($params));
  279.         $ret = json_decode($curlRes, true);
  280.  
  281.         \PhalApi\DI()->logger->error('$appId : ' . $appId);
  282.         \PhalApi\DI()->logger->error('$url : ' . $url);
  283.         \PhalApi\DI()->logger->error('$res : ' . json_encode($curlRes));
  284.  
  285.         if(!empty($ret['errcode'])) {
  286.             throw new RemoteServiceException("获取网页授权url失败:".$ret['errcode'].$ret['errmsg'],98);
  287.  
  288.         }else {
  289.             return $ret;
  290.         }
  291.     }
  292.  
  293.  
  294.     /**
  295.      * @function 创建发票卡券模板
  296.      * @param $appId
  297.      * @param $params
  298.     {
  299.     "invoice_info": {
  300.     "base_info": {
  301.     "logo_url": "http://mmbiz.qpic.cn/mmbiz/1.jpg", //发票商家 LOGO
  302.     "title": "xx公司",                              //收款方（显示在列表），上限为 9 个汉字，建议填入商户简称
  303.     "custom_url_name": "xyz",                       //开票平台自定义入口名称，与 custom_url 字段共同使用，长度限制在 5 个汉字内
  304.     "custom_url": "xyz",                            //开票平台自定义入口跳转外链的地址链接 , 发票外跳的链接会带有发票参数，用于标识是从哪张发票跳出的链接
  305.     "custom_url_sub_title": "xyz",                  //显示在入口右侧的 tips ，长度限制在 6 个汉字内
  306.     "promotion_url_name": "puname",                 //发营销场景的自定义入口
  307.     "promotion_url": "purl",                        //入口跳转外链的地址链接，发票外跳的链接会带有发票参数，用于标识是从那张发票跳出的链接
  308.     "promotion_url_sub_title": "ptitle",            //显示在入口右侧的 tips ，长度限制在 6 个汉字内
  309.     },
  310.     "type": " 广东省增值税普通发票 ",                    //发票类型
  311.     "payee": " 测试 - 收款方 ",                         //收款方（开票方）全称，显示在发票详情内。故建议一个收款方对应一个发票卡券模板
  312.     }
  313.     }
  314.      * @return bool|mixed
  315.      * @throws LocalServiceException
  316.      * @throws RemoteServiceException
  317.      */
  318.     public function getInvoiceCardId($appId,$params)
  319.     {
  320.         $appIdModel = new AppIDModel();
  321.         $row = $appIdModel->fetchByWxAppId($appId);
  322.         if($row)
  323.         {
  324.             $invoiceCardId = empty($row['invoice_card_id']) ? null : $row['invoice_card_id'];
  325.             if($invoiceCardId)
  326.             {
  327.                 return $invoiceCardId;
  328.             }else
  329.             {
  330.                 $token = $this->getAccessToken($appId);
  331.                 $url = "https://api.weixin.qq.com/card/invoice/platform/createcard?access_token={$token}";
  332.                 $curl = new CUrl(30);
  333.                 $curlRes = $curl->post($url,$params);
  334.                 $ret = json_decode($curlRes, true);
  335.  
  336.                 \PhalApi\DI()->logger->error('$appId : ' . $appId);
  337.                 \PhalApi\DI()->logger->error('$url : ' . $url);
  338.                 \PhalApi\DI()->logger->error('$params : ' . $params);
  339.                 \PhalApi\DI()->logger->error('$res : ' . json_encode($curlRes));
  340.  
  341.                 if(!empty($ret['errcode']))
  342.                 {
  343.                     throw new RemoteServiceException("创建发票卡券模板失败:".$ret['errcode'].$ret['errmsg'],98);
  344.                 }else
  345.                 {
  346.                     $invoiceCardId = $ret['card_id'];
  347.                     $updateData = array('invoice_card_id' => $invoiceCardId);
  348.                     $params = array('wx_appid' => $appId);
  349.                     $appIdModel->updateData($updateData, $params);
  350.                     return $invoiceCardId;
  351.                 }
  352.             }
  353.  
  354.         }else
  355.         {
  356.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  357.         }
  358.  
  359.     }
  360.  
  361.  
  362.     /**
  363.      * @param $appId
  364.      * @param $uid
  365.      * @param $order_no
  366.      * @param $ticket_no
  367.      * @return bool|mixed
  368.      * @throws LocalServiceException
  369.      * @throws RemoteServiceException
  370.      *
  371.      * @desc 小程序开具电子发票的步骤如下：
  372.             1 提前获取开票平台标识s_pappid，因为同一个开票平台的s_pappid都相同，所以获取s_pappid的操作只需要进行一次。不同接入模式获取s_pappid的方法略有不同：
  374.             如果商户接入模式为“自建平台模式”：s_pappid通过调用调用获取自身开票平台识别码接口获得
  376.             2 商户获取获取access_token。调用方法见获取access_token；
  377.             3 设置商户联系方式。调用方法见设置商户联系方式。注意，本步骤不能忽略，否则将造成下一步获取授权页报错；
  378.             4 商户获取授权页ticket。调用方法见获取授权页ticket；
  379.             5 商户获取授权页url，上一步获取的授权页ticket将作为参数传入。另外，本环节里面作为参数传入的order_id要注意保留，传递给开票平台作为向用户提供电子发票的依据。调用方法见获取授权页链接；
  380.             6 在小程序开票按钮的点击事件上部署跳转到小程序授权页的逻辑。上一步获得的auth_url和开票小程序appid要作为参数传入。调用方法见小程序打开授权页；
  381.             7 商户在后台等待接收用户的授权完成事件，获取授权事件方法见收取授权完成事件推送；
  382.             8 创建发票卡券模板。发票卡券模板应和背后的开票主体构成一一对应关系，便于后续若开票主体发生变化时，可以便捷修改。调用方法见创建发票卡券模板；
  383.             9 在自建发票平台开具电子发票；
  384.             10 上传发票PDF文件。此步骤获得的s_media_id起到关联PDF和发票卡券的作用，将作为参数在下一步的插卡接口中传入。调用方法见上传PDF；
  385.             11 将电子发票添加到用户微信卡包。调用方法见将电子发票卡券插入用户卡包。
  386.      */
  387.     public function getWxAuthUrl($appId,$uid,$order_no,$ticket_no)
  388.     {
  389.  
  390.         $orderTicketModel = new ModelOrderTickets();
  391.         $ticketRow = $orderTicketModel->getTicket($order_no,$ticket_no);
  392.         if(empty($ticketRow)){
  393.             throw new LocalServiceException("操作异常。订单号：{$order_no}票号：{$ticket_no}的票不存在。");
  394.         }
  395.         $order_id = $order_no.'_'.$ticket_no;
  396.         $money = $ticketRow['fee'];
  397.         $timestamp = time();
  398.         $source = 'wxa';
  399.         $redirect_url = '';
  400.         $type = '1';
  401.  
  402.         //1.解析InvoiceUrl中的s_pappid参数值
  403.         $s_pappid = '';
  404.         $invoiceUrl = $this->getInvoiceUrl($appId);
  405.         $invoiceUrlArr = parse_url($invoiceUrl);
  406.         parse_str($invoiceUrlArr['query']);
  407.         $invoiceUrlSpappid = $s_pappid;
  408.  
  409.         //3
  410.         $this->setContact($appId,30);
  411.  
  412.         //4
  413.         $authTicket = $this->getTicket($appId);
  414.  
  415.         return $this->getAuthUrl($appId,$invoiceUrlSpappid,$order_id,$money,$timestamp,$source,$redirect_url,$authTicket,$type);
  416.     }
  417.  
  418.  
  419.     /**
  420.      * @function 发送已经申请第三方成功的发票到用户微信卡包
  421.      * @param $appId
  422.      * @return array
  423.      * @throws LocalServiceException
  424.      * @throws RemoteServiceException
  425.      */
  426.     public function sendInvoice($appId)
  427.     {
  428.         $orderTicketsModel = new ModelOrderTickets();
  429.  
  430.         $appIdModel = new AppIDModel();
  431.         $appIdRow = $appIdModel->fetchByWxAppId($appId);
  432.         if(!$appIdRow) {
  433.             throw new LocalServiceException('系统异常：配置信息错误。');
  434.         }
  435.  
  436.         $cardParams = array(
  437.             'invoice_info'=>array(
  438.                 'type'=>'广东省增值税普通发票',
  439.                 'payee'=>' 测试 - 收款方',
  440.                 'base_info'=>array(
  441.                     'logo_url'=>'http://mmbiz.qpic.cn/mmbiz/iaL1LJM1mF9aRKPZJkmG8xXhiaHqkKSVMMWeN3hLut7X7hicFNjakmxibMLGWpXrEXB33367o7zHN0CwngnQY7zb7g/0',
  442.                     'title'=>'空港快线',
  443.                 )
  444.             )
  445.         );
  446.         $invoiceCardId = $this->getInvoiceCardId($appId,json_encode($cardParams,JSON_UNESCAPED_UNICODE));
  447.         $wxAccountAppId = $appIdRow['wx_account_appid'];
  448.  
  449.         //获取AppConfig配置信息
  450.         $appConfigModel = new ModelAppConfig();
  451.         $appConfigRes = $appConfigModel->getAppConfig();
  452.         if(empty($appConfigRes)){
  453.             throw new LocalServiceException("系统异常：AppConfig配置信息有误");
  454.         }
  455.         $appParams = json_decode($appConfigRes['app_params'],true);
  456.  
  457.  
  458.         $invoiceModel = new ModelInvoice();
  459.         $preSendInvoices = $invoiceModel->getPreSendInvoice();
  460.         $invoiceTotal = count($preSendInvoices);
  461.  
  462.         $successCount = 0;
  463.         $failCount = 0;
  464.         foreach ($preSendInvoices as $preSendInvoice)
  465.         {
  466.             $invoice_detail = json_decode($preSendInvoice['invoice_detail'],true);
  467.  
  468.             $info = array(
  469.                 array(
  470.                     'name'=>$invoice_detail['XMMC'],
  471.                     'num'=>$invoice_detail['XMSL'],
  472.                     'unit'=>$invoice_detail['DW'],
  473.                     'price'=>$invoice_detail['XMDJ']*100,
  474.                 )
  475.             );
  476.  
  477.             $invoice_user_data = array(
  478.                 'fee'=>$preSendInvoice['invoice_price'],
  479.                 'title'=>$preSendInvoice['receiver_name'],
  480.                 'billing_time'=>$preSendInvoice['invoice_time'],
  481.                 'billing_no'=>$preSendInvoice['invoice_code'],
  482.                 'billing_code'=>$preSendInvoice['invoice_no'],
  483.                 'fee_without_tax'=>$preSendInvoice['no_invoice_price'],
  484.                 'tax'=>$preSendInvoice['total_tax'],
  485.                 's_pdf_media_id'=>$preSendInvoice['pdf_media_id'],
  486.                 'check_code'=>$preSendInvoice['verify_code'],
  487.                 'buyer_number'=>$preSendInvoice['tax_number'],
  488.                 'buyer_address_and_phone'=>$preSendInvoice['address'].$preSendInvoice['telephone'],
  489.                 'buyer_bank_account'=>$preSendInvoice['bank_name'].$preSendInvoice['bank_account'],
  490.                 'seller_number'=>$appParams['KP_NSRSBH'],
  491.                 'seller_address_and_phone'=>$appParams['XHF_DZ'].$appParams['XHF_DH'],
  492.                 'seller_bank_account'=>$appParams['XHF_YHZH'],
  493.                 'cashier'=>$appParams['SKR'],
  494.                 'maker'=>$appParams['KPR'],
  495.                 'info'=>$info,
  496.             );
  497.  
  498.             $card_ext = array(
  499.                 'nonce_str'=> rand(1000000000,9999999999),
  500.                 'user_card'=>array('invoice_user_data'=>$invoice_user_data),
  501.             );
  502.  
  503.             $params = array(
  504.                 'order_id'=>$preSendInvoice['order_no'].'_'.$preSendInvoice['ticket_no'],
  505.                 'card_id'=>$invoiceCardId,
  506.                 'appid'=>$wxAccountAppId,
  507.                 'card_ext'=>$card_ext,
  508.             );
  509.  
  510.             $token = $this->getAccessToken($appId);
  511.             $url = "https://api.weixin.qq.com/card/invoice/insert?access_token={$token}";
  512.             $curl = new CUrl(30);
  513.             $curlRes = $curl->post($url,json_encode($params,JSON_UNESCAPED_UNICODE));
  514.             $ret = json_decode($curlRes, true);
  515.  
  516.             \PhalApi\DI()->logger->error('$appId : ' . $appId);
  517.             \PhalApi\DI()->logger->error('$url : ' . $url);
  518.             \PhalApi\DI()->logger->error('$params : ' . json_encode($params));
  519.             \PhalApi\DI()->logger->error('$res : ' . json_encode($curlRes));
  520.  
  521.             if(!empty($ret['errcode']))
  522.             {
  523.                 $failCount++;
  524.             }else
  525.             {
  526.                 $invUpdateData = array('state'=>7);
  527.                 $invUpdateParams = array('order_no'=>$preSendInvoice['order_no'],'ticket_no'=>$preSendInvoice['ticket_no']);
  528.                 $invoiceModel->updateInvoice($invUpdateParams,$invUpdateData);
  529.  
  530.                 //改变电子票列表的申请发票状态
  531.                 $ticUpdateData = array('invoice_state'=>7);
  532.                 $ticUpdateParams =  array('order_no'=>$preSendInvoice['order_no'],'ticket_no'=>$preSendInvoice['ticket_no']);
  533.                 $orderTicketsModel->updateTicket($ticUpdateParams,$ticUpdateData);
  534.                 $successCount++;
  535.             }
  536.  
  537.         }
  538.  
  539.         return array('invoiceTotal'=>$invoiceTotal,'successCount'=>$successCount,'failCount'=>$failCount);
  540.     }
  541.  
  542.  
  543.     /**
  544.      * @function 查询授权完成状态
  545.      *
  546.      * @desc
  547.      * 本接口的调用场景包括两个：
  548.      * 一、若商户在某次向用户展示授权页后经过较长时间仍未收到授权完成状态推送，可以使用本接口主动查询用户是否实际上已完成授权，只是由于网络等原因未收到授权完成事件
  549.      * 二、若商户向用户展示的授权页为type=1类型，商户在收到授权完成事件推送后需要进一步获取用户的开票信息，也可以调用本接口。
  550.      *
  551.      * @param $appId
  552.      * @return mixed
  553.      * @throws LocalServiceException
  554.      * @throws RemoteServiceException
  555.      */
  556.     public function getAuthData($appId)
  557.     {
  558.         //1.获取AccessToken
  559.         $token = $this->getAccessToken($appId);
  560.  
  561.         //2.解析InvoiceUrl中的s_pappid参数值
  562.         $s_pappid = '';
  563.         $invoiceUrl = $this->getInvoiceUrl($appId);
  564.         $invoiceUrlArr = parse_url($invoiceUrl);
  565.         parse_str($invoiceUrlArr['query']);
  566.         $invoiceUrlSpappid = $s_pappid;
  567.  
  568.         //3.获取已经申请航信的发票，上传PDF
  569.         $invoiceModel = new ModelInvoice();
  570.         $preSendInvoices = $invoiceModel->getAuthInvoice();
  571.         $invoiceTotal = count($preSendInvoices);
  572.  
  573.         $successCount = 0;
  574.         $failCount = 0;
  575.         foreach ($preSendInvoices as $preSendInvoice)
  576.         {
  577.             $order_id = $preSendInvoice['order_no'].'_'.$preSendInvoice['ticket_no'];
  578.             $url = "https://api.weixin.qq.com/card/invoice/getauthdata?access_token={$token}";
  579.             $params = json_encode(array('s_pappid' => $invoiceUrlSpappid, 'order_id' => $order_id));
  580.             $curl = new CUrl(30);
  581.             $curlRes = $curl->post($url, $params);
  582.             $ret = json_decode($curlRes, true);
  583.  
  584.             \PhalApi\DI()->logger->info('$url : ' . $url);
  585.             \PhalApi\DI()->logger->info('$params : ' . $params);
  586.             \PhalApi\DI()->logger->info('$ret : ' . json_encode($ret));
  587.  
  588.             if(!empty($ret['errcode']) and $ret['invoice_status']!= 'auth success'){
  589.                 $failCount++;
  590.                 continue;
  591.             }
  592.  
  593.             if(!empty($ret['user_auth_info']['user_field']))//个人发票
  594.             {
  595.                 $invoice_type = '2';
  596.                 $receiver_name = !empty($ret['user_auth_info']['user_field']['title'])?$ret['user_auth_info']['user_field']['title']:'';
  597.                 $telephone = !empty($ret['user_auth_info']['user_field']['phone'])?$ret['user_auth_info']['user_field']['phone']:'';
  598.                 $email = !empty($ret['user_auth_info']['user_field']['email'])?$ret['user_auth_info']['user_field']['email']:'';
  599.                 $updateData = array(
  600.                     'state'=>'2',
  601.                     'invoice_type'=>$invoice_type,
  602.                     'receiver_name'=>$receiver_name,
  603.                     'telephone'=>$telephone,
  604.                     'email'=>$email,
  605.                 );
  606.  
  607.             }elseif (!empty($ret['user_auth_info']['biz_field']))//企业发票
  608.             {
  609.                 $invoice_type = '1';
  610.                 $receiver_name = !empty($ret['user_auth_info']['biz_field']['title'])?$ret['user_auth_info']['biz_field']['title']:'';
  611.                 $tax_number = !empty($ret['user_auth_info']['biz_field']['tax_no'])?$ret['user_auth_info']['biz_field']['tax_no']:'';
  612.                 $address = !empty($ret['user_auth_info']['biz_field']['addr'])?$ret['user_auth_info']['biz_field']['addr']:'';
  613.                 $telephone = !empty($ret['user_auth_info']['biz_field']['phone'])?$ret['user_auth_info']['biz_field']['phone']:'';
  614.                 $bank_name = !empty($ret['user_auth_info']['biz_field']['bank_type'])?$ret['user_auth_info']['biz_field']['bank_type']:'';
  615.                 $bank_account = !empty($ret['user_auth_info']['biz_field']['bank_no'])?$ret['user_auth_info']['biz_field']['bank_no']:'';
  616.  
  617.                 $updateData = array(
  618.                     'state'=>'2',
  619.                     'invoice_type'=>$invoice_type,
  620.                     'receiver_name'=>$receiver_name,
  621.                     'tax_number'=>$tax_number,
  622.                     'address'=>$address,
  623.                     'telephone'=>$telephone,
  624.                     'bank_name'=>$bank_name,
  625.                     'bank_account'=>$bank_account,
  626.                 );
  627.  
  628.             }else{
  629.                 $updateData = array();
  630.             }
  631.  
  632.             $params = array('id' => $preSendInvoice['id']);
  633.             $invoiceModel->updateInvoice($params,$updateData);
  634.  
  635.             $orderTicketModel = new ModelOrderTickets();
  636.             $ticParams = array('order_no'=>$preSendInvoice['order_no'],'ticket_no'=>$preSendInvoice['ticket_no']);
  637.             $ticUpdateData = array('invoice_state'=>'2');
  638.             $orderTicketModel->updateTicket($ticParams,$ticUpdateData);
  639.  
  640.             $successCount++;
  641.         }
  642.  
  643.         return array('invoiceTotal'=>$invoiceTotal,'successCount'=>$successCount,'failCount'=>$failCount);
  644.     }
  645.  
  646.  
  647.     /**
  648.      * @function 上传PDF
  649.      * @desc
  650.      * 商户或开票平台可以通过该接口上传PDF。PDF上传成功后将获得发票文件的标识，后续可以通过插卡接口将PDF关联到用户的发票卡券上，一并插入到收票用户的卡包中。
  651.      * 注意：若上传成功的PDF在三天内没有被关联到发票卡券发送到用户卡包上，将会被清理。若商户或开票平台需要在三天后再关联发票卡券的话，需要重新上传。
  652.      *
  653.      * @param $appId
  654.      * @return array
  655.      * @throws LocalServiceException
  656.      * @throws RemoteServiceException
  657.      */
  658.     public function setPDF($appId)
  659.     {
  660.         $appIdModel = new AppIDModel();
  661.         $row = $appIdModel->fetchByWxAppId($appId);
  662.         if($row)
  663.         {
  664.             //1.获取AccessToken
  665.             $token = $this->getAccessToken($appId);
  666.  
  667.             //2.
  668.             $url = "https://api.weixin.qq.com/card/invoice/platform/setpdf?access_token={$token}";
  669.  
  670.             //3.获取已经申请航信的发票，上传PDF
  671.             $invoiceModel = new ModelInvoice();
  672.             $preSendInvoices = $invoiceModel->getPreSendInvoice();
  673.             $invoiceTotal = count($preSendInvoices);
  674.  
  675.             $successCount = 0;
  676.             $failCount = 0;
  677.             foreach ($preSendInvoices as $preSendInvoice)
  678.             {
  679.                 $fileName = $preSendInvoice['file_name'].'.pdf';
  680.                 $fileUrl = $preSendInvoice['file_url'];
  681.                 $fields = array(
  682.                     'type' => 'pdf',
  683.                     'filename' => $fileName,
  684.                     'filesize' => '',
  685.                     'offset' => 0,
  686.                     'filetype' => '.pdf',
  687.                     'originName' => $fileName,
  688.                     'upload'=>file_get_contents($fileUrl)
  689.                 );
  690.  
  691.                 $ret = $this->postPDF($url,$fields);
  692.                 \PhalApi\DI()->logger->error('$res : ' . json_encode($ret));
  693.  
  694.                 if($ret === false or !empty($ret['errcode'])){
  695.                     $failCount++;
  696.                     continue;
  697.                 }
  698.  
  699.                 $PDFMediaId = $ret['s_media_id'];
  700.                 $updateData = array('pdf_media_id' => $PDFMediaId);
  701.                 $params = array('id' => $preSendInvoice['id']);
  702.                 $invoiceModel->updateInvoice($params,$updateData);
  703.                 $successCount++;
  704.  
  705.             }
  706.             return array('invoiceTotal'=>$invoiceTotal,'successCount'=>$successCount,'failCount'=>$failCount);
  707.  
  708.         }else
  709.         {
  710.             throw new LocalServiceException("账户信息不存在或配置有误",99);
  711.         }
  712.     }
  713.  
  714.  
  715.     /**
  716.      * @function 发送pdf
  717.      * @param $url string
  718.      * @param $param array
  719.      * @return mixed
  720.      */
  721.     private static function postPDF($url,$param)
  722.     {
  723.         $delimiter = uniqid();
  724.         $data = '';
  725.         $eol = "\r\n";
  726.         $upload = $param['upload'];
  727.         unset($param['upload']);
  728.  
  729.         foreach ($param as $name => $content)
  730.         {
  731.             $data .= "--" . $delimiter . "\r\n"
  732.                 . 'Content-Disposition: form-data; name="' . $name . "\"\r\n\r\n"
  733.                 . $content . "\r\n";
  734.         }
  735.         // 拼接文件流
  736.         $data .= "--" . $delimiter . $eol
  737.             . 'Content-Disposition: form-data; name="pdf"; filename="' . $param['filename'] . '"' . "\r\n"
  738.             . 'Content-Type:application/octet-stream'."\r\n\r\n";
  739.  
  740.         $data .= $upload . "\r\n";
  741.         $data .= "--" . $delimiter . "--\r\n";
  742.  
  743.         $post_data = $data;
  744.         $curl = curl_init($url);
  745.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  746.         curl_setopt($curl, CURLOPT_POST, true);
  747.         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // stop verifying certificate
  748.         curl_setopt($curl, CURLOPT_POSTFIELDS, $post_data);
  749.         curl_setopt($curl, CURLOPT_HTTPHEADER, [
  750.             "Content-Type: multipart/form-data; boundary=" . $delimiter,
  751.             "Content-Length: " . strlen($post_data)
  752.         ]);
  753.         $response = curl_exec($curl);
  754.         curl_close($curl);
  755.         $info = json_decode($response, true);
  756.         return $info;
  757.     }
  758.  
  759.  
  760.  
  761.  
  762. }

调用示例

1.获取授权链接 

  1. $invoiceClass = new Invoice();
  2. $appId = \PhalApi\DI()->config->get('app.kgkx.wxAppId');//用于获取对应（zc2_ticket_appid）的配置信息
  3. $uid = $this->uid;//车票所属的用户openid
  4. $order_no = $this->orderNo;//车票所属的订单号
  5. $ticket_no = $this->ticketNo;//车票号
  6.  
  7. //getWxAuthUrl方法已经包含了“大概逻辑”里的前5步，最后只要将授权链接在小程序打开即可
  8. $invoiceClass ->getWxAuthUrl($appId,$uid,$order_no,$ticket_no);

返回结果

  1. {
  2.     "ret": 200,
  3.     "data": {
  4.         "errcode": 0,
  5.         "errmsg": "ok",
  6.         "auth_url": "pages/auth/auth?s_pappid=d3g1Y2Q4NTI3NWI4NDdlM2I2X7xcO5NPKJ9cUhYRLlygl8Dc2ZUl9PjYwiOwmLytYQwA&appid=wx5cd85275b847e3b6&num=1&o1=201904191345503490_0028657333&m1=15&t1=1557816628&source=wxa&type=1&signature=75dcbd921494457089d6c59534f9769624802b27",
  7.         "appid": "wx9db2c16d0633c2e7"
  8.     },
  9.     "msg": ""
  10. }

 

2. 小程序打开授权链接代码

  1. //发票授权
  2.   invoiceAuth: function () {
  3.     wx.navigateToMiniProgram({
  4.       appId: 'wx9db2c16d0633c2e7',
  5.       path: 'pages/auth/auth?s_pappid=d3g1Y2Q4NTI3NWI4NDdlM2I2X7xcO5NPKJ9cUhYRLlygl8Dc2ZUl9PjYwiOwmLytYQwA&appid=wx5cd85275b847e3b6&num=1&o1=201904191345503490_0028657333&m1=15&t1=1557816628&source=wxa&type=1&signature=75dcbd921494457089d6c59534f9769624802b27',
  6.       success(res) {
  7.         console.log('navigateToMiniProgram success:', res)
  8.       },
  9.       fail(error) {
  10.         console.log('navigateToMiniProgram fail:', error)
  11.       },
  12.       complete(res) {
  13.         console.log('navigateToMiniProgram complete:', res)
  14.       }
  15.     })
  16.   }

值得一提的是，这里的appId需要再app.json文件先配置好

  1. "navigateToMiniProgramAppIdList": [
  2.     "wx9db2c16d0633c2e7"
  3.   ]

 

3.主动查询授权状态

 说明：这里会用到定时任务的方式。查询到授权状态后，会将信息填到电子发票记录表，用来请求第三方开票平台

  1. $invoiceClass = new Invoice();
  2. $appId = \PhalApi\DI()->config->get('app.kgkx.wxAppId');//用于获取对应（zc2_ticket_appid）的配置信息
  3.  
  4. $invoiceClass ->getAuthData($appId);

 

4. 上传PDF

说明： 这里会用到定时任务的方式。请求第三方开票平台后，会返回一个发票PDF文件的地址，我们先用file_get_contents下载PDF文件，再通过数据格式使用multipart/form-data上传到微信。上传成功后，会返回一个s_media_id, 这个在发送发票到用户卡包的时候用到，需要对应发票记录来存。这里面的代码参考了：https://blog.51cto.com/suiwnet/2125883

  1. $invoiceClass = new Invoice();
  2. $appId = \PhalApi\DI()->config->get('app.kgkx.wxAppId');//用于获取对应（zc2_ticket_appid）的配置信息
  3.  
  4. $invoiceClass ->setPDF($appId);

 

5.发送发票到用户卡包

  1. $invoiceClass = new Invoice();
  2. $appId = \PhalApi\DI()->config->get('app.kgkx.wxAppId');//用于获取对应（zc2_ticket_appid）的配置信息
  3.  
  4. $invoiceClass ->sendInvoice($appId);


总结

1. 开发票的流程到这里已经完成。

2. 需要完善的是，发票冲红的问题。

3. 存在一个问题，access_token过了一段时间（这段时间小于返回的有效时间-200秒）之后就过期了，这里也需要继续完善。（2019-08-20）问题已经确认，是因为在多个地方用到了这个公众号的access_token，每用一次，上一个就可能过期，解决办法是，加一个验证checkAccessToken（$access_token）。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/凡人多烦事01/article/detail/297972
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号