package com.megatim.fdxconsultation.core.impl.dataproductionworker;
|
|
import com.megatim.fdxcommons.core.impl.tools.CommonUtilities;
|
import com.megatim.fdxcommons.model.camel.CamelRouteConfiguration;
|
import com.megatim.fdxcommons.model.dataproduction.CommonDataProduction;
|
import com.megatim.fdxcommons.tools.context.AppContext;
|
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
|
import com.megatim.fdxconsultation.core.ifaces.dataproduction.metadata.ProductionMetaDataManager;
|
import com.megatim.fdxconsultation.core.ifaces.helper.TableInsert;
|
import com.megatim.fdxconsultation.core.ifaces.integration.ColumnDefinitionManager;
|
import com.megatim.fdxconsultation.core.impl.camel.helper.FileInsertionProcess;
|
import com.megatim.fdxconsultation.core.impl.sockets.DataProductionSessionHandler;
|
import com.megatim.fdxconsultation.model.dataproduction.DataProduction;
|
import com.megatim.fdxconsultation.model.mappers.MapStructMapper;
|
import java.io.File;
|
import java.io.IOException;
|
import java.nio.charset.Charset;
|
import java.sql.Connection;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import javax.sql.DataSource;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
class FileDataProductionTask implements DataProductionTask {
|
|
private final DataProduction dataProduction;
|
private final DataSource dataSource;
|
private final ColumnDefinitionManager columnDefinitionManager;
|
private final DataProductionSessionHandler dataProductionSessionHandler;
|
private final TableInsert tableInsert;
|
private final MapStructMapper mapper;
|
private final ProductionMetaDataManager metaDataManager;
|
|
public FileDataProductionTask(DataProduction dataProduction,
|
DataSource dataSource,
|
ColumnDefinitionManager columnDefinitionManager,
|
DataProductionSessionHandler dataProductionSessionHandler,
|
TableInsert tableInsert,
|
MapStructMapper mapper,
|
ProductionMetaDataManager metaDataManager) {
|
this.dataProduction = dataProduction;
|
this.dataSource = dataSource;
|
this.columnDefinitionManager = columnDefinitionManager;
|
this.dataProductionSessionHandler = dataProductionSessionHandler;
|
this.tableInsert = tableInsert;
|
this.mapper = mapper;
|
this.metaDataManager = metaDataManager;
|
}
|
|
@Override
|
public void processProduction() {
|
System.out.println("-------------------------before FileInsertionProcess-------------------");
|
CommonDataProduction cd = mapper.dataProductionToCommonDataProduction(dataProduction);
|
cd.setId(dataProduction.getId());
|
|
try {
|
File dataFile = dataFile(dataProduction);
|
|
if (dataFile.exists()) {
|
Charset charset = CommonUtilities.getCharset(dataFile);
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
connection.setAutoCommit(false);
|
new FileInsertionProcess(columnDefinitionManager,
|
cd,
|
connection,
|
dataFile,
|
charset,
|
tableInsert,
|
metaDataManager
|
).process();
|
connection.commit();
|
}
|
System.out.println("-------------------after FileInsertionProcess---------------------");
|
dataProductionSessionHandler.publishMessage(dataProduction);
|
dataFile.delete();
|
metaDataManager.deleteById(cd.getId());
|
}
|
} catch (Exception ex) {
|
Logger.getLogger(FileDataProductionTask.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
}
|
}
|
|
private File dataFile(CommonDataProduction dataProduction) throws IOException {
|
CamelRouteConfiguration camelRouteConfiguration = new CamelRouteConfiguration(AppContext.PROPERTY_FILE_PATH);
|
String dataDir = camelRouteConfiguration.getLocalConfiguration().consultationDestinationDir();
|
|
return new File(dataDir, dataProduction.getIntegrationFileName());
|
}
|
}
|
