public void handleInvoice(SubmitInvoiceRpcReq req) throws Exception {

        boolean isAccess = false;

        String invoiceKey = String.format(ApiRedisKey.AGENT_WITHDRAW_INVOICE, req.getBaseUserId());

        try {

            isAccess = redisTemplate.setIfAbsent(invoiceKey, "1", 60);

            JlpayAssert.isTrue(isAccess, "正在处理，稍后再试");

            //批处理ID(时间戳+用户ID)

            String batchNo = System.currentTimeMillis() + String.format("%010d", req.getBaseUserId());

            InvoiceVo invoiceVo = new InvoiceVo();

            invoiceVo.setBatchNo(batchNo);

            invoiceVo.setLicenseNo(getLicenseNo(req.getBaseUserId()));

            HashMap<String, String> channelMap = getChannelMap();

            invoiceService.saveSubmitInvoice(req, channelMap, invoiceVo);

            FixedThreadPoolUtil.INSTANCE.execute(() -> {

                log.info("提现开票异步任务--开始");

                List<WithdrawInvoice> withdrawInvoiceList = invoiceService.getWithdrawInvoiceList(batchNo);

                if (CollectionUtils.isEmpty(withdrawInvoiceList)) {

                    return;

                }

                invoiceService.handleSubmitInvoice(withdrawInvoiceList);

                withdrawInvoiceList.stream().forEach(withdrawInvoice -> {

                    InvoiceVo vo = makeupInvoiceVo(withdrawInvoice);

                    sendInvoiceEmail(vo, withdrawInvoice);

                });

                log.info("提现开票异步任务--结束");

            });

        } finally {

            if (isAccess) {

                redisTemplate.delete(invoiceKey);

            }

        }

    }