write large Excel file support divided Sheets

Author: robinhood-jim

common/src/main/java/com/robin/core/fileaccess/iterator/XlsxFileIterator.java

@@ -225,6 +225,9 @@ protected void pullNext() throws Exception {
                 streamReader.close();
                 readStreams=sheetStreams.next();
                 streamReader=factory.createXMLStreamReader(readStreams,colmeta.getEncode());
+                if(hasHeader) {
+                    readNext();
+                }
             }
             readNext();
         }

common/src/main/java/com/robin/core/fileaccess/writer/XlsxFileWriter.java

@@ -40,13 +40,12 @@
  * Xlsx StaX writer,Support divided Sheet write,MAX_LINE max sheet lines
  */
 public class XlsxFileWriter extends TextBasedFileWriter{
-    private XMLOutputFactory factory;
     private XMLStreamWriter streamWriter;
     private XSSFWorkbook workbook;
     private OPCPackage opcPackage;
 
     private static final char CHARA = 'A';
-    private Map<String,CellStyle> cellStyleMap=new HashMap<>();
+    private final Map<String,CellStyle> cellStyleMap=new HashMap<>();
     private int rowPos=2;
     private int currentSheetPos=0;
     private ExcelSheetProp sheetProp;
@@ -85,7 +84,7 @@ public XlsxFileWriter(DataCollectionMeta colmeta, AbstractFileSystemAccessor acc
     public void beginWrite() throws IOException {
         super.beginWrite();
         try {
-            factory=XMLOutputFactory.newFactory();
+            XMLOutputFactory factory=XMLOutputFactory.newFactory();
             workbook = new XSSFWorkbook();
             Field field = workbook.getClass().getSuperclass().getDeclaredField("pkg");
             field.setAccessible(true);

core/src/main/java/com/robin/core/base/dao/IjdbcDao.java

@@ -200,7 +200,7 @@ public interface IjdbcDao {
      * @return
      * @throws DAOException
      */
-    <T extends BaseObject>T getEntity(Class<T> clazz, Serializable value) throws DAOException;
+    <T extends BaseObject,P extends Serializable>T getEntity(Class<T> clazz, P value) throws DAOException;
 
     /**
      * Execute Sql with Config query

core/src/main/java/com/robin/core/base/dao/JdbcDao.java

@@ -796,7 +796,7 @@ public <T extends BaseObject, P extends Serializable> int deleteByCondition(Clas
 
 
     @Override
-    public <T extends BaseObject> T getEntity(Class<T> clazz, Serializable id) throws DAOException {
+    public <T extends BaseObject,P extends Serializable> T getEntity(Class<T> clazz, P id) throws DAOException {
         try {
             T obj = clazz.getDeclaredConstructor().newInstance();
             EntityMappingUtil.SelectSegment segment = EntityMappingUtil.getSelectPkSegment(clazz, id, sqlGen, this);