美文网首页
诺诺开放平台电子发票对接

诺诺开放平台电子发票对接

作者: 一只浩子 | 来源:发表于2022-07-17 14:37 被阅读0次
    需求

    公司因自有订单业务规模不断扩大,产生了线上电子发票开具的需求,对接的是诺诺开发平台。

    诺诺开放平台首页
    开发指南

    申请诺诺资质:申请成为诺诺平台资质,提交资料,一次性费用2w+,每年一定维护费用。

    创建应用类型

    诺诺开放平台支持如下两种应用类型,企业可根据业务需求选择。

    1. 自用型:接入诺诺开放平台业务能力,为自己公司开发应用。自助接入建议使用自用型应用


      自用型流程图
    2. 第三方应用:第三方接入(帮助其他企业开发)建议使用第三方应用。系统服务商可创建第三方应用,开发应用服务于商户,可代商户发起调用。进行第三方调用前,需在应用中添加对应功能并获得商户授权。


      第三方应用流程图
    自用型对接

    自用型可以理解为公司给客户开票


    应用列表
    1. 创建自用型应用获取到APPKey和APPSecret
    2. 获取access_token
      access_token是开发者调用开放平台接口的调用凭据,开发者通过应用参数向诺诺开放平台调用令牌接口地址获取access_token。令牌有效期默认24h(也可在创建应用时设置token永不过期,我们创建的是默认24h),且令牌30天内的调用上限为50次 ,请开发者做好令牌的管理。
        private String getNNToken(String redisKey) {
            // 获取token
            Object token = redisUtil.get(redisKey);
            if (ObjectUtils.isNotEmpty(token)) {
                return (String) token;
            }
            String result = NNOpenSDK.getIntance().getMerchantToken(nnAppkey, nnAppSecret, nn_accessToken_url);
            HashMap tokenMap = JSON.parseObject(result, HashMap.class);
            token = tokenMap.get("access_token”);
            if (ObjectUtils.isEmpty(token)) {
                String msg = "获取token出错:" + tokenMap.get("error") + " " + tokenMap.get("error_description”);
                throw new MsgException(msg);
            }
            // 缓存token 比诺诺先过期
            long expires_in = (Integer) tokenMap.get("expires_in") - 60 * 60;
            redisUtil.set(redisKey, token, expires_in);
            return (String) token;
        }
    

    获取到的access_token,存入到redis,就可以使用access_token,调用开票、重开、查询、发送email等接口

    @Override
        public AjaxResponse<Object> ybInvoice(InvoiceOrderDTO orderDTO) throws Exception {
            // 校验order信息
            String content = generateOrder(orderDTO);
            
            NNOpenSDK sdk = NNOpenSDK.getIntance();
            String method = InvoiceMethodEnum.INVOICE_METHOD_NEW.getKey();
            String senId = IdUtils.simpleUUID();
            // 获取token
            String token = getNNToken(yuanben_redisKey);
            
            //调用诺诺接口的时间
            long reqApiTimes = System.currentTimeMillis();
            String result = sdk.sendPostSyncRequest(nnUrl, senId, nnAppkey, nnAppSecret, token, StaticValue.SHUNDIAN_TAXNUM, method, content);
            log.info("ybInvoice result = " + result);
            AjaxResponse<Object> ajaxResponse = generateAjaxResponse(result, reqApiTimes);
            return ajaxResponse;
        }
    
        @Override
        public AjaxResponse<Object> ybReInvoice(String serialNo) {
            if (StringUtils.isBlank(serialNo)) {
                throw new MsgException("发票流水号不能空!”);
            }
            NNOpenSDK sdk = NNOpenSDK.getIntance();
            String method = InvoiceMethodEnum.INVOICE_METHOD_REINVOICE.getKey();
            String senId = IdUtils.simpleUUID();
            // 获取token
            String token = getNNToken(yuanben_redisKey);
            Map<String, Object> contentMap = new HashMap<>();
            contentMap.put("fpqqlsh", serialNo);
            String content = JSON.toJSONString(contentMap);
            //调用诺诺接口的时间
            long reqApiTimes = System.currentTimeMillis();
            String result = sdk.sendPostSyncRequest(nnUrl, senId, nnAppkey, nnAppSecret, token, StaticValue.SHUNDIAN_TAXNUM, method, content);
            log.info("result = " + result);
    
            AjaxResponse<Object> ajaxResponse = generateAjaxResponse(result, reqApiTimes);
            if (ajaxResponse.isState()) {
                saveInvoiceRecord(StaticValue.SHUNDIAN_TAXNUM, serialNo, System.currentTimeMillis(), 0);
            }
            return ajaxResponse;
        }
    
        @Override
        public AjaxResponse<Object> ybQueryInvoiceResult(String serialNos, String orderNos, String isOfferInvoiceDetail) {
    
            if (StringUtils.isBlank(serialNos) && StringUtils.isBlank(orderNos)) {
                throw new MsgException("发票流水号或订单编号,两字段二选一”);
            }
            if (StringUtils.isBlank(isOfferInvoiceDetail)) {
                isOfferInvoiceDetail = “0”;
            }
            String[] serialNosArray = null;
            String[] orderNosArray = null;
            if (StringUtils.isNotBlank(serialNos)) {
                serialNosArray = serialNos.split(",”);
            }
            if (StringUtils.isNotBlank(orderNos)) {
                orderNosArray = orderNos.split(",”);
            }
    
            NNOpenSDK sdk = NNOpenSDK.getIntance();
            String method = InvoiceMethodEnum.INVOICE_METHOD_RESULT.getKey();
            String senId = IdUtils.simpleUUID();
            String token = getNNToken(yuanben_redisKey);
    
            Map<String, Object> contentMap = new HashMap<>();
            if (StringUtils.isNotBlank(serialNos)) {
                contentMap.put("serialNos", serialNosArray);
            } else {
                contentMap.put("orderNos", orderNosArray);
            }
            contentMap.put("isOfferInvoiceDetail", isOfferInvoiceDetail);
            String content = JSON.toJSONString(contentMap);
            //调用诺诺接口的时间
            long reqApiTimes = System.currentTimeMillis();
            String result = sdk.sendPostSyncRequest(nnUrl, senId, nnAppkey, nnAppSecret, token, StaticValue.SHUNDIAN_TAXNUM, method, content);
            log.info("result = " + result);
            
            return generateAjaxResponse(result, reqApiTimes);
        }
    
        @Override
        public AjaxResponse<Object> ybDeliveryInvoice(String invoiceCode, String invoiceNum, String phone, String mail) {
            NNOpenSDK sdk = NNOpenSDK.getIntance();
            String method = InvoiceMethodEnum.INVOICE_METHOD_DELIVERY.getKey();
            String senId = IdUtils.simpleUUID();
            String token = getNNToken(yuanben_redisKey);
    
            AssertUtil.notBlank(invoiceCode, "发票代码不能为空”);
            AssertUtil.notBlank(invoiceNum, "发票号码不能为空”);
    
            if (StringUtils.isBlank(phone) && StringUtils.isBlank(mail)) {
                throw new MsgException("交付手机号,和交付邮箱至少有一个不为空”);
            }
    
            Map<String, Object> contentMap = new HashMap<>();
            if (StringUtils.isNotBlank(phone)) {
                contentMap.put("phone", phone);
            } else {
                contentMap.put("mail", mail);
            }
            contentMap.put("taxnum", StaticValue.SHUNDIAN_TAXNUM);
            contentMap.put("invoiceCode", invoiceCode);
            contentMap.put("invoiceNum", invoiceNum);
            String content = JSON.toJSONString(contentMap);
            //调用诺诺接口的时间
            long reqApiTimes = System.currentTimeMillis();
            String result = sdk.sendPostSyncRequest(nnUrl, senId, nnAppkey, nnAppSecret, token, StaticValue.SHUNDIAN_TAXNUM, method, content);
            log.info("result = " + result);
    
            return generateAjaxResponse(result, reqApiTimes);
        }
    
        @Override
        public AjaxResponse<Object> ybCancelInvoice(String invoiceId, String invoiceCode, String invoiceNo) {
            NNOpenSDK sdk = NNOpenSDK.getIntance();
            String method = InvoiceMethodEnum.INVOICE_METHOD_CANCEL.getKey();
            String senId = IdUtils.simpleUUID();
            String token = getNNToken(yuanben_redisKey);
    
            AssertUtil.notBlank(invoiceId, "发票流水号不能为空”);
            AssertUtil.notBlank(invoiceCode, "发票代码不能为空”);
            AssertUtil.notBlank(invoiceNo, "发票号码不能为空”);
    
            Map<String, Object> contentMap = new HashMap<>();
            contentMap.put("invoiceId", invoiceId);
            contentMap.put("invoiceCode", invoiceCode);
            contentMap.put("invoiceNo", invoiceNo);
            String content = JSON.toJSONString(contentMap);
            //调用诺诺接口的时间
            long reqApiTimes = System.currentTimeMillis();
            String result = sdk.sendPostSyncRequest(nnUrl, senId, nnAppkey, nnAppSecret, token, StaticValue.SHUNDIAN_TAXNUM, method, content);
            log.info("result = " + result);
    
            return generateAjaxResponse(result, reqApiTimes);
        }
    

    校验订单必传参数(客户税务信息,订单信息)后,组装订单默认参数,商户信息从数据库查询。

    /**
         * 组装订单必填信息
         * @Params: 
         * @DateTime: 2022/7/15 下午4:22
         * @Author: zenghao
         */
        private String generateOrder(InvoiceOrderDTO orderDTO) throws Exception {
            ClientCacheModel clientCacheModel = ThreadLocalClientCache.get();
            // 查询商户信息
            TinSalerPO salerPO = salerDAO.findByPrimaryKey(clientCacheModel.getGuid());
            // 生成订单号、默认蓝票、默认发邮件
            orderDTO.setOrderNo(getOrderNo());
            orderDTO.setInvoiceDate(DateTime.getCurrentDate_YYYYMMDDHHMMSS());
            orderDTO.setInvoiceType(InvoiceTypeEnum.BLUE_TICKET.getKey());
            // 0 代表开票成功后发送电子票到指定邮件
            orderDTO.setPushMode("0”);
            orderDTO.setBuyerPhone(orderDTO.getBuyerTel());
            // 商户信息
            orderDTO.setSalerAccount(salerPO.getAccountBank());
            orderDTO.setSalerAddress(salerPO.getAddress());
            orderDTO.setSalerTel(salerPO.getTel());
            orderDTO.setSalerTaxNum(salerPO.getTaxNum());
            // 设置回调地址,开票成功后,回调接口处理后续业务
            orderDTO.setCallBackUrl(callBackUrl);
            
            Map<String, Object> map = new HashMap<>();
            map.put("order", orderDTO);
            String content = JSON.toJSONString(map);
            log.info(orderDTO.toString());
            return content;
        }
    

    重点提一点,提交成功后,返回是开票提交成功,会立即返回开票流水号,这里电子票的状态不是最终状态,如果使用流水号查询开票信息,有可能是开票中状态。
    这里我们需要利用比较关键的参数,callBackUrl,写入订单成功后的回调地址,利用回调接口,读取返回的订单流水号和订单json信息,然后进行一些数据存储的业务处理。

    @RequestMapping("/callback”)
        @ResponseBody
        public AjaxResponse invoiceCallback(HttpServletRequest request) throws Exception {
            //返回的内容
            String content = request.getParameter("content”);
            Map map = JSON.parseObject(content, Map.class);
            //发票流水号
            String serialNum = (String) map.get("c_fpqqlsh”);
            //商户税号
            String saleTaxNum = (String) map.get("c_saletaxnum”);
            invoiceRecordService.invoiceCallback(serialNum, saleTaxNum);
            return AjaxResponse.ok();
        }
    
    第三方应用对接

    第三方应用对接可以理解为公司的客户给它的客户开票

    1. 公司的客户也需要提交资料到诺诺平台,获取资质;
    2. 注册诺诺平台账号;
    3. 授权成为创建应用下的商户;

    链接:https://open.nuonuo.com/authorization.html?appKey=35012739&response_type=code&redirect_uri=https://einv.ybveg.com/openApi/invoice/tpa/merchant/code&state=yuanben

    利用回调地址可以接受商户授权成功后code,利用code调用生成access_token接口,有了这个access_token,就可以进行开票等接口的正常调用了。创建应用时选择的是access_token永久有效,商户的access_token存入数据库已备用。

    private String getNNToken(String code, String taxNum) {
            Object token = null;
            String result = NNOpenSDK.getIntance().getISVToken(tpa_nnAppkey, tpa_nnAppSecret, code, taxNum, auth_redirect_uri, nn_accessToken_url);
            HashMap tokenMap = JSON.parseObject(result, HashMap.class);
            token = tokenMap.get("access_token");
            if (ObjectUtils.isEmpty(token)) {
                String msg = "获取token出错:" + tokenMap.get("error") + " " + tokenMap.get("error_description");
                throw new MsgException(msg);
            }
            log.info("taxNum = " + taxNum + "access_token = " + tokenMap.toString());
            return (String) token;
        }
    

    创建第三方应用时,设置的授权回调地址设置很重要。

        @GetMapping("/tpa/merchant/code")
        @ResponseBody
        public AjaxResponse tpAppMerchant(@RequestParam String code, @RequestParam String taxnum) throws Exception {
            invoiceService.tpAppGetMerchantToken(code, taxnum);
            return AjaxResponse.ok();
        }
    

    授权后可以再商户管理查看商户授权信息


    截屏2022-07-17 下午1.58.40.png

    第三方应用类型在流程上稍微绕一些,商户获取资质有一定的费用。

    对接过程中也遇到了不少问题,需要与诺诺人员沟通。

    需要注意的点:
    1. 调用开票等接口前,需要插入税盘,安装诺诺的软件,启动助手。
    2. 对接没有使用沙盒环境(用不了,喊用正式环境),使用的正式环境开的测试票,最后红冲了。

    相关文章

      网友评论

          本文标题:诺诺开放平台电子发票对接

          本文链接:https://www.haomeiwen.com/subject/txhlirtx.html