diff --git a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/client/excel/ExcelReadListener.java b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/client/excel/ExcelReadListener.java index 3ed953bb15..27b4a9cae7 100644 --- a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/client/excel/ExcelReadListener.java +++ b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/client/excel/ExcelReadListener.java @@ -18,23 +18,35 @@ package com.dtstack.chunjun.connector.ftp.client.excel; +import com.dtstack.chunjun.util.DateUtil; + import com.alibaba.excel.context.AnalysisContext; import com.alibaba.excel.read.listener.ReadListener; +import java.time.LocalDateTime; import java.util.Map; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; -public class ExcelReadListener implements ReadListener> { +public class ExcelReadListener implements ReadListener> { private final BlockingQueue queue = new LinkedBlockingQueue<>(4096); @Override - public void invoke(Map data, AnalysisContext context) { + public void invoke(Map data, AnalysisContext context) { String[] piece = new String[data.size()]; - for (Map.Entry entry : data.entrySet()) { - piece[entry.getKey()] = - entry.getValue() == null ? "" : String.valueOf(entry.getValue()); + for (Map.Entry entry : data.entrySet()) { + String value = ""; + if (entry.getValue() != null) { + if (entry.getValue() instanceof LocalDateTime) { + value = + DateUtil.timestampToString( + DateUtil.localDateTimetoDate((LocalDateTime) entry.getValue())); + } else { + value = String.valueOf(entry.getValue()); + } + } + piece[entry.getKey()] = value; } Row row = new Row(