需求
公司因自有订单业务规模不断扩大，产生了线上电子发票开具的需求，对接的是诺诺开发平台。
申请诺诺资质：申请成为诺诺平台资质，提交资料，一次性费用2w+，每年一定维护费用。
创建应用类型
诺诺开放平台支持如下两种应用类型，企业可根据业务需求选择。
-
自用型：接入诺诺开放平台业务能力，为自己公司开发应用。自助接入建议使用自用型应用
自用型流程图 -
第三方应用：第三方接入（帮助其他企业开发）建议使用第三方应用。系统服务商可创建第三方应用，开发应用服务于商户，可代商户发起调用。进行第三方调用前，需在应用中添加对应功能并获得商户授权。
第三方应用流程图
自用型对接
自用型可以理解为公司给客户开票
应用列表
- 创建自用型应用获取到APPKey和APPSecret
- 获取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();
}
第三方应用对接
第三方应用对接可以理解为公司的客户给它的客户开票
- 公司的客户也需要提交资料到诺诺平台，获取资质；
- 注册诺诺平台账号；
- 授权成为创建应用下的商户；
利用回调地址可以接受商户授权成功后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
第三方应用类型在流程上稍微绕一些，商户获取资质有一定的费用。
对接过程中也遇到了不少问题，需要与诺诺人员沟通。
需要注意的点：
- 调用开票等接口前，需要插入税盘，安装诺诺的软件，启动助手。
对接没有使用沙盒环境（用不了，喊用正式环境），使用的正式环境开的测试票，最后红冲了。
调用平台C回调地址设置
诺诺平台-A，开票中间平台-B，调用平台-C
如果做的是开票中间平台B，假如C调用B接口后，B调用A，A回调B，B回调C，所以需要B在调用接口前需要提供回调地址给B。我们做法是，公司信息注册在B平台时需要提供回调地址存储在数据库，开票成功后回调C使用。
