import org.telegram.telegrambots.api.methods.send.SendDocument; //导入依赖的package包/类
private void download(String url, Handler<AsyncResult<Object>> handler) {
    vertx.executeBlocking(future -> {
        HttpGet httpGet = new HttpGet(rootOPDS + url);
        try {
            CloseableHttpResponse response = httpclient.execute(httpGet, context);
            if (response.getStatusLine().getStatusCode() == 200) {
                String fileName = fileNameParser.parse(url);
                HttpEntity ht = response.getEntity();
                BufferedHttpEntity buf = new BufferedHttpEntity(ht);
                File book = File.createTempFile("flibot_" + Long.toHexString(System.currentTimeMillis()), null);
                buf.writeTo(new FileOutputStream(book));
                final SendDocument sendDocument = new SendDocument();
                sendDocument.setNewDocument(fileName, new FileInputStream(book));
                sendDocument.setCaption("book");
                future.complete(sendDocument);
            }
        } catch (Exception e) {
            log.warn(e, e);
            future.fail(e);
        }
    }, res -> {
        handler.handle(res);
    });
}
 

import org.telegram.telegrambots.api.methods.send.SendDocument; //导入依赖的package包/类
private void downloadz(String url, Handler<AsyncResult<Object>> handler) {
    vertx.executeBlocking(future -> {
        HttpGet httpGet = new HttpGet(rootOPDS + url);
        try {
            CloseableHttpResponse response = httpclient.execute(httpGet, context);
            if (response.getStatusLine().getStatusCode() == 200) {
                HttpEntity ht = response.getEntity();
                ZipInputStream zip = new ZipInputStream(ht.getContent());
                ZipEntry entry = zip.getNextEntry();
                File book = File.createTempFile("flibot_" + Long.toHexString(System.currentTimeMillis()), null);

                byte[] buffer = new byte[2048];
                FileOutputStream fileOutputStream = new FileOutputStream(book);
                int len = 0;
                while ((len = zip.read(buffer)) > 0) {
                    fileOutputStream.write(buffer, 0, len);
                }
                fileOutputStream.close();
                zip.close();

                final SendDocument sendDocument = new SendDocument();
                sendDocument.setNewDocument(entry.getName(), new FileInputStream(book));
                sendDocument.setCaption("book");
                future.complete(sendDocument);
            }
        } catch (Exception e) {
            log.warn(e, e);
            future.fail(e);
        }
    }, res -> {
        handler.handle(res);
    });
}
 

import org.telegram.telegrambots.api.methods.send.SendDocument; //导入依赖的package包/类
private void onStartWithParameters(Message message, String language, String part) throws InvalidObjectException, TelegramApiException {
    if (DatabaseManager.getInstance().doesFileExists(part.trim())) {
        SendDocument sendDocumentRequest = new SendDocument();
        sendDocumentRequest.setDocument(part.trim());
        sendDocumentRequest.setChatId(message.getChatId());
        sendDocument(sendDocumentRequest);
    } else {
        SendMessage sendMessageRequest = new SendMessage();
        sendMessageRequest.setText(LocalisationService.getString("wrongFileId", language));
        sendMessageRequest.setChatId(message.getChatId());
        sendMessage(sendMessageRequest);
    }
}