Merge pull request #11232 from dataease/pr@dev-v2@fixDS

Pr@dev v2@fix ds
This commit is contained in:
taojinlong 2024-07-29 17:33:55 +08:00 committed by GitHub
commit e700067500
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 81 additions and 70 deletions

View File

@ -89,14 +89,10 @@ public class ChartDataServer implements ChartDataApi {
public void innerExportDetails(ChartExcelRequest request, HttpServletResponse response) throws Exception { public void innerExportDetails(ChartExcelRequest request, HttpServletResponse response) throws Exception {
HttpServletRequest httpServletRequest = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest httpServletRequest = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String linkToken = httpServletRequest.getHeader(AuthConstant.LINK_TOKEN_KEY); String linkToken = httpServletRequest.getHeader(AuthConstant.LINK_TOKEN_KEY);
if (StringUtils.isEmpty(linkToken) || !request.isDataEaseBi()) { if ((StringUtils.isNotEmpty(linkToken) && !request.isDataEaseBi()) || (request.isDataEaseBi() && StringUtils.isEmpty(linkToken))) {
exportCenterManage.addTask(request.getViewId(), "chart", request);
return;
}
OutputStream outputStream = response.getOutputStream(); OutputStream outputStream = response.getOutputStream();
try { try {
findExcelData(request); findExcelData(request);
Workbook wb = new SXSSFWorkbook(); Workbook wb = new SXSSFWorkbook();
//给单元格设置样式 //给单元格设置样式
@ -151,6 +147,10 @@ public class ChartDataServer implements ChartDataApi {
} catch (Exception e) { } catch (Exception e) {
DEException.throwException(e); DEException.throwException(e);
} }
}else {
exportCenterManage.addTask(request.getViewId(), "chart", request);
return;
}
} }

View File

@ -1,5 +1,5 @@
<script lang="ts" setup> <script lang="ts" setup>
import { ref, h, onUnmounted } from 'vue' import { ref, h, onUnmounted, computed } from 'vue'
import { EmptyBackground } from '@/components/empty-background' import { EmptyBackground } from '@/components/empty-background'
import { ElButton, ElMessage, ElMessageBox, ElTabPane, ElTabs } from 'element-plus-secondary' import { ElButton, ElMessage, ElMessageBox, ElTabPane, ElTabs } from 'element-plus-secondary'
import { RefreshLeft } from '@element-plus/icons-vue' import { RefreshLeft } from '@element-plus/icons-vue'
@ -15,6 +15,8 @@ import { useI18n } from '@/hooks/web/useI18n'
import { useEmitt } from '@/hooks/web/useEmitt' import { useEmitt } from '@/hooks/web/useEmitt'
import Icon from '@/components/icon-custom/src/Icon.vue' import Icon from '@/components/icon-custom/src/Icon.vue'
import { useCache } from '@/hooks/web/useCache' import { useCache } from '@/hooks/web/useCache'
import { useLinkStoreWithOut } from '@/store/modules/link'
import { useAppStoreWithOut } from '@/store/modules/app'
const { t } = useI18n() const { t } = useI18n()
const tableData = ref([]) const tableData = ref([])
@ -150,8 +152,12 @@ const init = params => {
} }
}, 5000) }, 5000)
} }
const linkStore = useLinkStoreWithOut()
const appStore = useAppStoreWithOut()
const isDataEaseBi = computed(() => appStore.getIsDataEaseBi)
const taskExportTopicCall = task => { const taskExportTopicCall = task => {
if (!linkStore.getLinkToken && !isDataEaseBi.value && !appStore.getIsIframe) {
if (JSON.parse(task).exportStatus === 'SUCCESS') { if (JSON.parse(task).exportStatus === 'SUCCESS') {
openMessageLoading( openMessageLoading(
JSON.parse(task).exportFromName + ' 导出成功,前往', JSON.parse(task).exportFromName + ' 导出成功,前往',
@ -167,6 +173,7 @@ const taskExportTopicCall = task => {
callbackExportError callbackExportError
) )
} }
}
} }
const openMessageLoading = (text, type = 'success', cb) => { const openMessageLoading = (text, type = 'success', cb) => {

View File

@ -276,7 +276,11 @@ public abstract class Provider {
session.setPassword(configuration.getSshPassword()); session.setPassword(configuration.getSshPassword());
} }
session.setConfig("StrictHostKeyChecking", "no"); session.setConfig("StrictHostKeyChecking", "no");
session.connect(); try {
session.connect(1000 * 5);
} catch (Exception e) {
DEException.throwException("SSH 连接失败:" + e.getMessage());
}
session.setPortForwardingL(configuration.getLPort(), configuration.getHost(), configuration.getPort()); session.setPortForwardingL(configuration.getLPort(), configuration.getHost(), configuration.getPort());
return session; return session;