Integry/IntegryManagementSystem
19
0
Fork 0
Code Actions Packages Projects Releases Activity

Merge remote-tracking branch 'origin/feature/RefactoringGestioneColli' into feature/RefactoringGestioneColli
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Valerio Castellana
2025-11-06 17:54:09 +01:00
parent b5cbbf7b0b db17e8c473
commit fa89398e40
45 changed files with 207 additions and 212 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ems-core/src/main/java/it/integry/ems/_context/EmsCoreDBLoader.java
View File

@@ -3,7 +3,7 @@ package it.integry.ems._context;
import it.integry.annotations.PostContextConstruct;
import it.integry.common.var.EmsDBConst;
import it.integry.ems.expansion.RunnableArgsThrowable;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.settings.SettingsController;
import it.integry.ems.sync.MultiDBTransaction.BasicConnectionPool;
@@ -83,9 +83,9 @@ public class EmsCoreDBLoader {
private void discoverAllConnections(MultiDBTransactionManager multiDBTransactionManager) throws Exception {
ArrayList<Callable<Void>> futureTasks = new ArrayList<>();
for (AvailableConnectionsModel model : settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true)) {
for (AvailableConnectionModel model : settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true)) {
AtomicReference<AvailableConnectionsModel> modelAtomicReference = new AtomicReference<>(model);
AtomicReference<AvailableConnectionModel> modelAtomicReference = new AtomicReference<>(model);
futureTasks.add(() -> {
try {

10
ems-core/src/main/java/it/integry/ems/datasource/DataSource.java
View File

@@ -1,6 +1,6 @@
package it.integry.ems.datasource;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems_model.config.EmsRestConstants;
@@ -13,13 +13,13 @@ import java.util.HashMap;
public class DataSource extends BasicDataSource {
private AvailableConnectionsModel connectionModel;
private AvailableConnectionModel connectionModel;
/**
* Instanzia un nuovo datasource.
*
* @deprecated Il datasource non deve essere istanziato direttamente ma bisogna utilizzare il metodo
* {@link it.integry.ems.sync.MultiDBTransaction.BasicConnectionPool#getConnection(AvailableConnectionsModel)} per ottenere una connessione.
* {@link it.integry.ems.sync.MultiDBTransaction.BasicConnectionPool#getConnection(AvailableConnectionModel)} per ottenere una connessione.
*/
@Deprecated
public DataSource() {
@@ -62,12 +62,12 @@ public class DataSource extends BasicDataSource {
}
public synchronized void initialize(String profileDB) throws Exception {
AvailableConnectionsModel connectionsModel = SettingsModel.getInstance().findConnectionModel(profileDB);
AvailableConnectionModel connectionsModel = SettingsModel.getInstance().findConnectionModel(profileDB);
initialize(connectionsModel);
}
public synchronized void initialize(AvailableConnectionsModel connectionModel) throws Exception {
public synchronized void initialize(AvailableConnectionModel connectionModel) throws Exception {
if (connectionModel == null) {
throw new Exception("Configurazione DB non trovata");
}

20
ems-core/src/main/java/it/integry/ems/dynamic_cache/DynamicCacheService.java
View File

@@ -3,7 +3,7 @@ package it.integry.ems.dynamic_cache;
import it.integry.ems.expansion.RunnableArgsWithReturn;
import it.integry.ems.expansion.RunnableWithReturn;
import it.integry.ems.looper.service.LooperService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -51,11 +51,11 @@ public class DynamicCacheService {
List<String> finalDbNames = dbNames.stream().map(String::toLowerCase).collect(Collectors.toList());
RunnableWithReturn<Object> internalRefreshAction = () -> {
Map<String, List<AvailableConnectionsModel>> databases = settingsModel.getAvailableConnections()
Map<String, List<AvailableConnectionModel>> databases = settingsModel.getAvailableConnections()
.stream()
.filter(AvailableConnectionsModel::getInternalDb)
.filter(AvailableConnectionModel::getInternalDb)
.filter(x -> finalDbNames.contains(x.getDbName().toLowerCase()))
.collect(Collectors.groupingBy(AvailableConnectionsModel::getDbName));
.collect(Collectors.groupingBy(AvailableConnectionModel::getDbName));
final HashMap<String, T> cachedDataByDB = new HashMap<>();
@@ -83,11 +83,11 @@ public class DynamicCacheService {
RunnableWithReturn<Object> refreshAction = () -> {
Map<String, List<AvailableConnectionsModel>> databases = settingsModel.getAvailableConnections()
Map<String, List<AvailableConnectionModel>> databases = settingsModel.getAvailableConnections()
.stream()
.filter(AvailableConnectionsModel::getInternalDb)
.filter(AvailableConnectionModel::getInternalDb)
.filter(x -> finalDbNames.contains(x.getDbName().toLowerCase()))
.collect(Collectors.groupingBy(AvailableConnectionsModel::getDbName));
.collect(Collectors.groupingBy(AvailableConnectionModel::getDbName));
final HashMap<String, List<? extends EntityBase>> cachedEntitiesByDB = new HashMap<>();
@@ -138,11 +138,11 @@ public class DynamicCacheService {
RunnableWithReturn<Object> refreshAction = () -> {
Map<String, List<AvailableConnectionsModel>> databases = settingsModel.getAvailableConnections()
Map<String, List<AvailableConnectionModel>> databases = settingsModel.getAvailableConnections()
.stream()
.filter(AvailableConnectionsModel::getInternalDb)
.filter(AvailableConnectionModel::getInternalDb)
.filter(x -> finalDbNames.contains(x.getDbName().toLowerCase()))
.collect(Collectors.groupingBy(AvailableConnectionsModel::getDbName));
.collect(Collectors.groupingBy(AvailableConnectionModel::getDbName));
final HashMap<String, List<?>> cacheQueryByDB = new HashMap<>();

10
ems-core/src/main/java/it/integry/ems/entity_logger/service/EntityLoggerComponent.java
View File

@@ -6,7 +6,7 @@ import it.integry.annotations.PostContextConstruct;
import it.integry.ems.entity_logger.db_schema_manager.component.SQLServerDBSchemaManager;
import it.integry.ems.entity_logger.db_schema_manager.dto.*;
import it.integry.ems.looper.service.LooperService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.settings.SettingsController;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -57,7 +57,7 @@ public class EntityLoggerComponent {
private void syncDBScheme() throws Exception {
AvailableConnectionsModel connectionsModel = settingsModel.getDefaultConnectionModel();
AvailableConnectionModel connectionsModel = settingsModel.getDefaultConnectionModel();
if (connectionsModel == null) {
throw new Exception("Impossibile ricavare la default connection");
@@ -107,7 +107,7 @@ public class EntityLoggerComponent {
}
if (settingsModel.getAvailableConnections().stream().noneMatch(x -> x.getDbName().equalsIgnoreCase(destDBName))) {
settingsModel.addAvailableConnection(new AvailableConnectionsModel()
settingsModel.addAvailableConnection(new AvailableConnectionModel()
.setInternalDb(false)
.setHost(dbHost)
.setUsername(dbUsername)
@@ -210,12 +210,12 @@ public class EntityLoggerComponent {
return;
try {
List<AvailableConnectionsModel> connectionsModels = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
List<AvailableConnectionModel> connectionsModels = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
String historyProfileDB = settingsController.getHistoryProfileDb();
try (MultiDBTransactionManager historyMultiDB = new MultiDBTransactionManager(historyProfileDB)) {
for (AvailableConnectionsModel sourceConnectionModel : connectionsModels) {
for (AvailableConnectionModel sourceConnectionModel : connectionsModels) {
String sql = "SELECT * FROM stb_log_entity_setup" +
" WHERE entity_name <> " + UtilityDB.valueToString(StbLogEntitySetup.ENTITY);

6
ems-core/src/main/java/it/integry/ems/license/LicenseComponent.java
View File

@@ -8,7 +8,7 @@ import it.integry.ems.json.ResponseJSONObjectMapper;
import it.integry.ems.response.EsitoType;
import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.service.HttpRestWrapper;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -60,11 +60,11 @@ public class LicenseComponent {
if (!canStart)
return;
List<AvailableConnectionsModel> availableConnectionsModels = settingsModel.getAvailableConnections(true);
List<AvailableConnectionModel> availableConnectionModels = settingsModel.getAvailableConnections(true);
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager()) {
for (AvailableConnectionsModel model : availableConnectionsModels) {
for (AvailableConnectionModel model : availableConnectionModels) {
multiDBTransactionManager.addConnection(model);
}

4
ems-core/src/main/java/it/integry/ems/migration/model/Migration_20210721093948.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.migration.model;
import it.integry.ems.migration._base.BaseMigration;
import it.integry.ems.migration._base.MigrationModelInterface;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems_model.utility.UtilityDB;
@@ -14,7 +14,7 @@ public class Migration_20210721093948 extends BaseMigration implements Migration
@Override
public void up() throws Exception {
AvailableConnectionsModel historyDBModel = settingsController.getHistoryDbConnectionModel();
AvailableConnectionModel historyDBModel = settingsController.getHistoryDbConnectionModel();
if (!settingsModel.getDefaultProfile().equalsIgnoreCase(connection.getProfileName()))
return;

4
ems-core/src/main/java/it/integry/ems/migration/model/Migration_20210924152555.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.migration.model;
import it.integry.ems.migration._base.BaseMigration;
import it.integry.ems.migration._base.MigrationModelInterface;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems_model.utility.UtilityDB;
@@ -14,7 +14,7 @@ public class Migration_20210924152555 extends BaseMigration implements Migration
@Override
public void up() throws Exception {
AvailableConnectionsModel historyDBModel = settingsController.getHistoryDbConnectionModel();
AvailableConnectionModel historyDBModel = settingsController.getHistoryDbConnectionModel();
if (!settingsModel.getDefaultProfile().equalsIgnoreCase(connection.getProfileName()))
return;

18
ems-core/src/main/java/it/integry/ems/migration/service/MigrationSetupService.java
View File

@@ -6,7 +6,7 @@ import it.integry.ems.migration._base.IntegryCustomerDB;
import it.integry.ems.migration.dto.MigrationStatusDTO;
import it.integry.ems.migration.dto.MigrationStatusEnum;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -46,14 +46,14 @@ public class MigrationSetupService {
final List<MigrationStatusDTO> migrationStatuses = new ArrayList<>();
final List<AvailableConnectionsModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel availableConnectionsModel : databases) {
if (IntegryCustomer.getFromDB(IntegryCustomerDB.parse(availableConnectionsModel.getDbName())) == IntegryCustomer.Integry &&
for (AvailableConnectionModel availableConnectionModel : databases) {
if (IntegryCustomer.getFromDB(IntegryCustomerDB.parse(availableConnectionModel.getDbName())) == IntegryCustomer.Integry &&
UtilityDebug.isDebugExecution())
continue;
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(availableConnectionsModel)) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(availableConnectionModel)) {
List<StbMigrationStatus> stbMigrationStatuses = retrieveStatuses(multiDBTransactionManager);
if (stbMigrationStatuses == null) {
@@ -88,7 +88,7 @@ public class MigrationSetupService {
migrationStatuses.add(new MigrationStatusDTO()
.setStatus(status)
.setMigrationCode(migrationCode)
.setProfileDb(availableConnectionsModel.getProfileName())
.setProfileDb(availableConnectionModel.getProfileName())
.setErrorMessage(errorMessage));
}
@@ -132,11 +132,11 @@ public class MigrationSetupService {
public void executeAll() throws Exception {
for (AvailableConnectionsModel availableConnectionsModel : settingsModel.getAvailableConnections(true)) {
for (AvailableConnectionModel availableConnectionModel : settingsModel.getAvailableConnections(true)) {
if (multiDBTransactionManager.getActiveConnections().stream()
.noneMatch(connection ->
connection.getDbName().equalsIgnoreCase(availableConnectionsModel.getDbName()))) {
multiDBTransactionManager.addConnection(availableConnectionsModel);
connection.getDbName().equalsIgnoreCase(availableConnectionModel.getDbName()))) {
multiDBTransactionManager.addConnection(availableConnectionModel);
}
}

4
ems-core/src/main/java/it/integry/ems/schedule/new_cron_job/service/AutomatedOperationService.java
View File

@@ -5,7 +5,7 @@ import it.integry.ems.schedule.new_cron_job.dto.AutomatedOperationTypeEnum;
import it.integry.ems.schedule.new_cron_job.dto.operations.OperationField;
import it.integry.ems.schedule.new_cron_job.dto.operations.OperationFieldDTO;
import it.integry.ems.schedule.new_cron_job.dto.operations.base_classes.BaseAutomatedOperationDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems_model.utility.UtilityString;
import org.springframework.beans.factory.annotation.Autowired;
@@ -46,7 +46,7 @@ public class AutomatedOperationService {
if (x.getName().equalsIgnoreCase("profiledb")) {
List<String> profiles = Stream.of(settingsModel.getAvailableConnections())
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.sorted()
.toList();

4
ems-core/src/main/java/it/integry/ems/schedule/new_cron_job/service/DefaultAutomatedOperationHandlerComponent.java
View File

@@ -7,7 +7,7 @@ import it.integry.ems._context.ApplicationContextProvider;
import it.integry.ems.schedule.new_cron_job.dto.AutomatedOperationTypeEnum;
import it.integry.ems.schedule.new_cron_job.dto.operations.ServiceCallAutomatedOperationDTO;
import it.integry.ems.schedule.new_cron_job.dto.operations.base_classes.BaseAutomatedOperationDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -272,7 +272,7 @@ public class DefaultAutomatedOperationHandlerComponent {
settingsModel.getAvailableConnections().stream()
.filter(x -> x.getInternalDb() && x.getProfileName().equalsIgnoreCase(x.getDbName()))
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.forEach(profileDb -> {
try {
final String operationName = "Remove FPX invio files (" + profileDb + ")";

6
ems-core/src/main/java/it/integry/ems/service/CleanDirectoryComponent.java
View File

@@ -1,6 +1,6 @@
package it.integry.ems.service;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -34,10 +34,10 @@ public class CleanDirectoryComponent {
public void cleanDirectory() throws Exception {
if (!UtilityDebug.isDebugExecution()) {
List<AvailableConnectionsModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
List<AvailableConnectionModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : databases) {
for (AvailableConnectionModel connectionModel : databases) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionModel, false)) {

4
ems-core/src/main/java/it/integry/ems/service/EntityLoggerNewService.java
View File

@@ -6,7 +6,7 @@ import it.integry.ems.dynamic_cache.DynamicCacheService;
import it.integry.ems.json.ResponseJSONObjectMapper;
import it.integry.ems.looper.service.LooperService;
import it.integry.ems.service.dto.EntityToLogDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.settings.SettingsController;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -66,7 +66,7 @@ public class EntityLoggerNewService {
private void initSetup() {
List<String> dbNames = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true)
.stream()
.map(AvailableConnectionsModel::getDbName)
.map(AvailableConnectionModel::getDbName)
.collect(Collectors.toList());;
dynamicCacheService.addEntity(DynamicCacheService.Keys.ENTITY_LOGGER_SETUP, 5, StbLogEntitySetup.class, dbNames);

6
ems-core/src/main/java/it/integry/ems/service/production/MrpConsumiHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.service.production;
import com.annimon.stream.Stream;
import it.integry.ems.service.dto.production.MRPDailyConsumiDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.service.SetupGest;
@@ -41,9 +41,9 @@ public class MrpConsumiHandlerService {
@Scheduled(fixedDelay = 1, timeUnit = TimeUnit.MINUTES, initialDelay = 60, zone = "Europe/Rome")
private void updateData() {
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = mrpSetupHandlerService.isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

10
ems-core/src/main/java/it/integry/ems/service/production/MrpSetupHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.service.production;
import it.integry.ems.service.dto.production.MRPDailySetupGruppiDTO;
import it.integry.ems.service.dto.production.MRPDailySetupSottogruppiDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -52,9 +52,9 @@ public class MrpSetupHandlerService {
"WHERE cod_opz = 'WG125'\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -78,9 +78,9 @@ public class MrpSetupHandlerService {
private void updateData() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

10
ems-core/src/main/java/it/integry/ems/service/production/ProductionOrderDataHandlerService.java
View File

@@ -4,7 +4,7 @@ import com.annimon.stream.Stream;
import it.integry.ems.service.dto.production.AvailableClassMercDTO;
import it.integry.ems.service.dto.production.OrdineInevasoGroupMercDTO;
import it.integry.ems.service.dto.production.OrdineLavorazioneDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -54,9 +54,9 @@ public class ProductionOrderDataHandlerService {
"WHERE cod_opz IN ('WG069', 'WG135')\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
executionPermission.remove(connectionsModel.getDbName());
@@ -75,9 +75,9 @@ public class ProductionOrderDataHandlerService {
public void updateInternalCache() throws Exception {
boolean onlyInevasi = true;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = executionPermission.getOrDefault(connectionModel.getDbName(), false);
if (!isEnabled) continue;

20
ems-core/src/main/java/it/integry/ems/settings/Model/AvailableConnectionsModel.java → ems-core/src/main/java/it/integry/ems/settings/Model/AvailableConnectionModel.java
View File

@@ -8,7 +8,7 @@ import it.integry.security.utility.CryptoUtils;
import java.io.IOException;
import java.util.Objects;
public class AvailableConnectionsModel {
public class AvailableConnectionModel {
private String profileName;
@@ -24,7 +24,7 @@ public class AvailableConnectionsModel {
return profileName;
}
public AvailableConnectionsModel setProfileName(String profileName) {
public AvailableConnectionModel setProfileName(String profileName) {
this.profileName = profileName;
return this;
}
@@ -33,7 +33,7 @@ public class AvailableConnectionsModel {
return connectionType;
}
public AvailableConnectionsModel setConnectionType(EmsRestConstants.DB_TYPE connectionType) {
public AvailableConnectionModel setConnectionType(EmsRestConstants.DB_TYPE connectionType) {
this.connectionType = connectionType;
return this;
}
@@ -42,7 +42,7 @@ public class AvailableConnectionsModel {
return dbName;
}
public AvailableConnectionsModel setDbName(String dbName) {
public AvailableConnectionModel setDbName(String dbName) {
this.dbName = dbName;
return this;
}
@@ -51,7 +51,7 @@ public class AvailableConnectionsModel {
return username;
}
public AvailableConnectionsModel setUsername(String username) {
public AvailableConnectionModel setUsername(String username) {
this.username = username;
return this;
}
@@ -60,7 +60,7 @@ public class AvailableConnectionsModel {
return password;
}
public AvailableConnectionsModel setPassword(String password) {
public AvailableConnectionModel setPassword(String password) {
this.password = password;
return this;
}
@@ -75,7 +75,7 @@ public class AvailableConnectionsModel {
return host;
}
public AvailableConnectionsModel setHost(String host) {
public AvailableConnectionModel setHost(String host) {
this.host = host;
return this;
}
@@ -84,7 +84,7 @@ public class AvailableConnectionsModel {
return encryptedDbPsw != null ? encryptedDbPsw : true;
}
public AvailableConnectionsModel setEncryptedDbPsw(Boolean encryptedDbPsw) {
public AvailableConnectionModel setEncryptedDbPsw(Boolean encryptedDbPsw) {
this.encryptedDbPsw = encryptedDbPsw;
return this;
}
@@ -93,7 +93,7 @@ public class AvailableConnectionsModel {
return isInternalDb;
}
public AvailableConnectionsModel setInternalDb(Boolean internalDb) {
public AvailableConnectionModel setInternalDb(Boolean internalDb) {
isInternalDb = internalDb;
return this;
}
@@ -149,7 +149,7 @@ public class AvailableConnectionsModel {
public boolean equals(Object o) {
//if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
AvailableConnectionsModel that = (AvailableConnectionsModel) o;
AvailableConnectionModel that = (AvailableConnectionModel) o;
return Objects.equals(getProfileName(), that.getProfileName()) &&
getConnectionType() == that.getConnectionType() &&
Objects.equals(getDbName(), that.getDbName()) &&

32
ems-core/src/main/java/it/integry/ems/settings/Model/SettingsModel.java
View File

@@ -41,7 +41,7 @@ public class SettingsModel implements InitializingBean {
private final ObservableField<String> systemPassword = new ObservableField<>("?MF!jbI+&OkA");
private final ObservableArrayList<AvailableConnectionsModel> availableConnections = new ObservableArrayList<>();
private final ObservableArrayList<AvailableConnectionModel> availableConnections = new ObservableArrayList<>();
private MailConfigurationModel defaultMailConfiguration = new MailConfigurationModel();
@@ -109,31 +109,31 @@ public class SettingsModel implements InitializingBean {
return this;
}
public List<AvailableConnectionsModel> getAvailableConnections() {
public List<AvailableConnectionModel> getAvailableConnections() {
return getAvailableConnections(false);
}
public List<AvailableConnectionsModel> getAvailableConnections(boolean onlyInternal) {
public List<AvailableConnectionModel> getAvailableConnections(boolean onlyInternal) {
return availableConnections.get().stream()
.filter(x -> !onlyInternal || x.getInternalDb())
.collect(Collectors.toList());
}
public List<AvailableConnectionsModel> getAvailableConnectionsWithoutDuplicatedProfiles(boolean onlyInternal) {
Map<String, List<AvailableConnectionsModel>> databases = getAvailableConnections(onlyInternal)
public List<AvailableConnectionModel> getAvailableConnectionsWithoutDuplicatedProfiles(boolean onlyInternal) {
Map<String, List<AvailableConnectionModel>> databases = getAvailableConnections(onlyInternal)
.stream()
.collect(Collectors.groupingBy(AvailableConnectionsModel::getDbName));
.collect(Collectors.groupingBy(AvailableConnectionModel::getDbName));
return databases.keySet().stream()
.map(key -> databases.get(key).get(0))
.collect(Collectors.toList());
}
public void addAvailableConnection(AvailableConnectionsModel availableConnectionsModel) {
availableConnections.add(availableConnectionsModel);
public void addAvailableConnection(AvailableConnectionModel availableConnectionModel) {
availableConnections.add(availableConnectionModel);
}
public void setAvailableConnections(ArrayList<AvailableConnectionsModel> availableConnections) {
public void setAvailableConnections(ArrayList<AvailableConnectionModel> availableConnections) {
this.availableConnections.set(availableConnections);
}
@@ -182,12 +182,12 @@ public class SettingsModel implements InitializingBean {
}
@JsonIgnore
public AvailableConnectionsModel getDefaultConnectionModel() {
public AvailableConnectionModel getDefaultConnectionModel() {
if (this.getAvailableConnections() == null || this.getAvailableConnections().isEmpty() || UtilityString.isNullOrEmpty(this.getDefaultProfile()))
return null;
Optional<AvailableConnectionsModel> optConn = this.getAvailableConnections().stream()
Optional<AvailableConnectionModel> optConn = this.getAvailableConnections().stream()
.filter(x -> x.getProfileName().equalsIgnoreCase(this.getDefaultProfile()))
.findFirst();
@@ -197,7 +197,7 @@ public class SettingsModel implements InitializingBean {
public String getProfileDbFromDbName(String dbName) {
String profileDb = this.getAvailableConnections().stream()
.filter(x -> x.getDbName().equalsIgnoreCase(dbName))
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.findFirst()
.orElse(null);
@@ -207,7 +207,7 @@ public class SettingsModel implements InitializingBean {
public String getDbNameFromProfileDb(String profileDb) {
String dbName = this.getAvailableConnections().stream()
.filter(x -> x.getProfileName().equalsIgnoreCase(profileDb))
.map(AvailableConnectionsModel::getDbName)
.map(AvailableConnectionModel::getDbName)
.findFirst()
.orElse(null);
@@ -215,7 +215,7 @@ public class SettingsModel implements InitializingBean {
}
public AvailableConnectionsModel findConnectionModel(String profileName) {
public AvailableConnectionModel findConnectionModel(String profileName) {
return getAvailableConnections().stream()
.filter(x -> x.getProfileName().equalsIgnoreCase(profileName))
.findFirst()
@@ -262,13 +262,13 @@ public class SettingsModel implements InitializingBean {
availableConnections.add(this.getDefaultProfile());
}
List<AvailableConnectionsModel> availableConnectionsModels = this.getAvailableConnections()
List<AvailableConnectionModel> availableConnectionModels = this.getAvailableConnections()
.stream()
.filter(availableConnectionsModel ->
availableConnections.stream().anyMatch(s -> s.equalsIgnoreCase(availableConnectionsModel.getProfileName())))
.collect(Collectors.toList());
this.setAvailableConnections(new ArrayList<>(availableConnectionsModels));
this.setAvailableConnections(new ArrayList<>(availableConnectionModels));
}
} catch (Exception ex) {

10
ems-core/src/main/java/it/integry/ems/settings/SettingsController.java
View File

@@ -4,7 +4,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import it.integry.ems.expansion.ObservableArrayList;
import it.integry.ems.expansion.ObservableField;
import it.integry.ems.properties.EmsProperties;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.utility.UtilityDebug;
import it.integry.ems.watching.FileWatcher;
@@ -152,7 +152,7 @@ public class SettingsController implements IFileWatcherEvents {
}
public String getHistoryProfileDb() throws Exception {
AvailableConnectionsModel connectionsModel = settingsModel.getDefaultConnectionModel();
AvailableConnectionModel connectionsModel = settingsModel.getDefaultConnectionModel();
if (connectionsModel == null) {
throw new Exception("Impossibile ricavare la default connection");
@@ -168,8 +168,8 @@ public class SettingsController implements IFileWatcherEvents {
}
public AvailableConnectionsModel getHistoryDbConnectionModel() {
AvailableConnectionsModel connectionsModel = settingsModel.getDefaultConnectionModel();
public AvailableConnectionModel getHistoryDbConnectionModel() {
AvailableConnectionModel connectionsModel = settingsModel.getDefaultConnectionModel();
if (connectionsModel == null) {
return null;
@@ -177,7 +177,7 @@ public class SettingsController implements IFileWatcherEvents {
String profileName = connectionsModel.getDbName() + "_history";
Optional<AvailableConnectionsModel> opt = settingsModel.getAvailableConnections().stream()
Optional<AvailableConnectionModel> opt = settingsModel.getAvailableConnections().stream()
.filter(x -> x.getProfileName().equalsIgnoreCase(profileName))
.findFirst();

12
ems-core/src/main/java/it/integry/ems/settings/SettingsConverter.java
View File

@@ -1,7 +1,7 @@
package it.integry.ems.settings;
import it.integry.ems.properties.EmsProperties;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.LoggerConfigurationModel;
import it.integry.ems.settings.Model.MailConfigurationModel;
import it.integry.ems_model.config.EmsRestConstants;
@@ -39,9 +39,9 @@ class SettingsConverter {
}
public ArrayList<AvailableConnectionsModel> getConvertedAvailableConnections() throws Exception {
public ArrayList<AvailableConnectionModel> getConvertedAvailableConnections() throws Exception {
ArrayList<AvailableConnectionsModel> connectionList = new ArrayList<AvailableConnectionsModel>();
ArrayList<AvailableConnectionModel> connectionList = new ArrayList<AvailableConnectionModel>();
File connectionFile = new File(emsProperties.getGlobalConnectionIniPath());
@@ -53,7 +53,7 @@ class SettingsConverter {
// Print the content on the console
if (strLine.startsWith("CONNECT_STRING")) {
AvailableConnectionsModel model = new AvailableConnectionsModel();
AvailableConnectionModel model = new AvailableConnectionModel();
String[] splittedLine = strLine.split("=");
@@ -82,7 +82,7 @@ class SettingsConverter {
String dbType = typeDBFullString.split("=")[1];
for (AvailableConnectionsModel model : connectionList) {
for (AvailableConnectionModel model : connectionList) {
if (model.getProfileName().equalsIgnoreCase(dbName)) {
model.setConnectionType(EmsRestConstants.DB_TYPE.fromString(dbType));
}
@@ -98,7 +98,7 @@ class SettingsConverter {
String dbEncryptedPsw = typeDBFullString.split("=")[1];
for (AvailableConnectionsModel model : connectionList) {
for (AvailableConnectionModel model : connectionList) {
if (model.getProfileName().equalsIgnoreCase(dbName)) {
model.setEncryptedDbPsw(dbEncryptedPsw.equalsIgnoreCase("S"));
}

12
ems-core/src/main/java/it/integry/ems/sync/AsyncManager.java
View File

@@ -3,7 +3,7 @@ package it.integry.ems.sync;
import com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement;
import it.integry.ems.json.ResponseJSONObjectMapper;
import it.integry.ems.looper.service.LooperService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.settings.SettingsController;
import it.integry.ems.sync.MultiDBTransaction.Connection;
@@ -63,11 +63,11 @@ public class AsyncManager {
}
String finalHistoryProfileDb = historyProfileDb;
List<AvailableConnectionsModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
List<AvailableConnectionModel> databases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
cachedSetup.clear();
for (AvailableConnectionsModel connectionModel : databases) {
for (AvailableConnectionModel connectionModel : databases) {
try {
cacheSetup(connectionModel);
} catch (Exception ex) {
@@ -76,7 +76,7 @@ public class AsyncManager {
}
}
private void cacheSetup(AvailableConnectionsModel connectionsModel) throws Exception {
private void cacheSetup(AvailableConnectionModel connectionsModel) throws Exception {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
String sql = "SELECT * FROM " + StbPublicationsDetail.ENTITY + " WHERE active = 1";
@@ -168,7 +168,7 @@ public class AsyncManager {
List<String> dbNamesToConnect = toBeSavedQueue.stream().map(Map.Entry::getKey).distinct().collect(Collectors.toList());
final List<AvailableConnectionsModel> databaseConnections = settingsModel.getAvailableConnections().stream()
final List<AvailableConnectionModel> databaseConnections = settingsModel.getAvailableConnections().stream()
.filter(x -> dbNamesToConnect.stream().anyMatch(y -> x.getDbName().equalsIgnoreCase(y)))
.collect(Collectors.toList());
@@ -180,7 +180,7 @@ public class AsyncManager {
final Map.Entry<String, StbTransactionLog> finalItemToSave = itemToSave;
final StbTransactionLog stbTransactionLog = finalItemToSave.getValue();
AvailableConnectionsModel connectionModel = databaseConnections.stream()
AvailableConnectionModel connectionModel = databaseConnections.stream()
.filter(x -> x.getDbName().equalsIgnoreCase(finalItemToSave.getKey()))
.findFirst()
.orElse(null);

12
ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/BasicConnectionPool.java
View File

@@ -1,7 +1,7 @@
package it.integry.ems.sync.MultiDBTransaction;
import it.integry.ems.datasource.DataSource;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@@ -62,10 +62,10 @@ public class BasicConnectionPool {
}
private void initializeConnections() {
final List<AvailableConnectionsModel> availableConnections =
final List<AvailableConnectionModel> availableConnections =
settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(false);
for (AvailableConnectionsModel model : availableConnections) {
for (AvailableConnectionModel model : availableConnections) {
try {
registerDataSourceIfNotExists(model);
@@ -75,13 +75,13 @@ public class BasicConnectionPool {
}
}
private DataSource createNewDataSource(AvailableConnectionsModel connectionModel) throws Exception {
private DataSource createNewDataSource(AvailableConnectionModel connectionModel) throws Exception {
DataSource ds = new DataSource();
ds.initialize(connectionModel);
return ds;
}
public Connection getConnection(AvailableConnectionsModel connectionsModel) throws SQLException {
public Connection getConnection(AvailableConnectionModel connectionsModel) throws SQLException {
if (connectionsModel == null) {
return null;
}
@@ -109,7 +109,7 @@ public class BasicConnectionPool {
}
private void registerDataSourceIfNotExists(AvailableConnectionsModel connectionModel) throws Exception {
private void registerDataSourceIfNotExists(AvailableConnectionModel connectionModel) throws Exception {
String dbName = connectionModel.getDbName();
if (!registeredDatasources.containsKey(dbName)) {
registeredDatasources.put(dbName, createNewDataSource(connectionModel));

18
ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java
View File

@@ -7,7 +7,7 @@ import it.integry.ems.exception.PrimaryDatabaseNotPresentException;
import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.migration._base.IntegryCustomerDB;
import it.integry.ems.properties.EmsProperties;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@@ -74,11 +74,11 @@ public class MultiDBTransactionManager implements AutoCloseable {
this.setPrimaryDB(profileDb);
}
public MultiDBTransactionManager(AvailableConnectionsModel connectionsModel) throws Exception {
public MultiDBTransactionManager(AvailableConnectionModel connectionsModel) throws Exception {
this(connectionsModel, true);
}
public MultiDBTransactionManager(AvailableConnectionsModel connectionsModel, boolean enableLog) throws Exception {
public MultiDBTransactionManager(AvailableConnectionModel connectionsModel, boolean enableLog) throws Exception {
this();
this.enableLog = enableLog;
this.setPrimaryDB(connectionsModel);
@@ -113,12 +113,12 @@ public class MultiDBTransactionManager implements AutoCloseable {
public void addConnection(String profileName) throws SQLException {
AvailableConnectionsModel availableConnectionsModel = settingsModel.findConnectionModel(profileName);
this.addConnection(availableConnectionsModel);
AvailableConnectionModel availableConnectionModel = settingsModel.findConnectionModel(profileName);
this.addConnection(availableConnectionModel);
}
public void addConnection(AvailableConnectionsModel availableConnectionsModel) throws SQLException {
Connection connection = connectionPool.getConnection(availableConnectionsModel);
public void addConnection(AvailableConnectionModel availableConnectionModel) throws SQLException {
Connection connection = connectionPool.getConnection(availableConnectionModel);
this.addConnection(connection);
}
@@ -285,11 +285,11 @@ public class MultiDBTransactionManager implements AutoCloseable {
throw new Exception(String.format("Configurazione DB non trovata o dati mancanti (%s)", profileDb));
}
AvailableConnectionsModel connectionModel = settingsModel.findConnectionModel(profileDb);
AvailableConnectionModel connectionModel = settingsModel.findConnectionModel(profileDb);
setPrimaryDB(connectionModel);
}
public void setPrimaryDB(AvailableConnectionsModel connectionModel) throws Exception {
public void setPrimaryDB(AvailableConnectionModel connectionModel) throws Exception {
this.close();
if (connectionModel == null) {

6
ems-core/src/main/java/it/integry/ems/sync/SyncManager.java
View File

@@ -6,7 +6,7 @@ import it.integry.ems.dynamic_cache.DynamicCacheService;
import it.integry.ems.exception.SyncException;
import it.integry.ems.json.ResponseJSONObjectMapper;
import it.integry.ems.service.MailService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -57,8 +57,8 @@ public class SyncManager {
@PostContextConstruct
public void init() {
List<String> dbNames = settingsModel.getAvailableConnections().stream()
.filter(AvailableConnectionsModel::getInternalDb)
.map(AvailableConnectionsModel::getDbName)
.filter(AvailableConnectionModel::getInternalDb)
.map(AvailableConnectionModel::getDbName)
.distinct()
.collect(Collectors.toList());

4
ems-core/src/main/java/it/integry/ems/system/SystemRequisiteCheckInterceptor.java
View File

@@ -7,7 +7,7 @@ import it.integry.common.var.EmsDBConst;
import it.integry.ems._context.EmsCoreContext;
import it.integry.ems.exception.SystemNotInitializedException;
import it.integry.ems.migration.MigrationComponent;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems_model.utility.UtilityHashMap;
import it.integry.ems_model.utility.UtilityString;
@@ -67,7 +67,7 @@ public class SystemRequisiteCheckInterceptor extends HandlerInterceptorAdapter {
String[] foundProfile = UtilityHashMap.getValueIfExists(request.getParameterMap(), CommonConstants.PROFILE_DB);
if (foundProfile != null && foundProfile.length > 0 && !UtilityString.isNullOrEmpty(foundProfile[0])) {
Optional<AvailableConnectionsModel> optConn = Stream.of(settingsModel.getAvailableConnections())
Optional<AvailableConnectionModel> optConn = Stream.of(settingsModel.getAvailableConnections())
.filter(x -> x.getProfileName().equalsIgnoreCase(foundProfile[0]))
.findFirst();

6
ems-core/src/main/java/it/integry/ems/user/service/UserCacheService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.user.service;
import it.integry.annotations.PostContextConstruct;
import it.integry.ems.model.IntegryApplicationEnum;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -54,11 +54,11 @@ public class UserCacheService {
private void internalCacheUpdate(boolean forceStart) {
if (!forceStart && !canStart) return;
List<AvailableConnectionsModel> availableConnectionsModels =
List<AvailableConnectionModel> availableConnectionModels =
settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager()) {
for (AvailableConnectionsModel model : availableConnectionsModels) {
for (AvailableConnectionModel model : availableConnectionModels) {
try {
multiDBTransactionManager.addConnection(model);
} catch (Exception ex) {

12
ems-core/src/main/java/it/integry/firebase/service/NotificationSenderComponent.java
View File

@@ -6,7 +6,7 @@ import it.integry.ems.json.ResponseJSONObjectMapper;
import it.integry.ems.response.EsitoType;
import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.service.HttpRestWrapper;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.entity.WtbNotification;
@@ -41,13 +41,13 @@ public class NotificationSenderComponent {
private void sendNotifications() {
MultiDBTransactionManager multiDBTransactionManager = null;
List<AvailableConnectionsModel> connectionsModels = settingsModel.getAvailableConnections();
List<AvailableConnectionModel> connectionsModels = settingsModel.getAvailableConnections();
connectionsModels = Stream.of(connectionsModels)
.filter(AvailableConnectionsModel::getInternalDb)
.filter(AvailableConnectionModel::getInternalDb)
.toList();
for (AvailableConnectionsModel availableConnectionsModel : connectionsModels) {
for (AvailableConnectionModel availableConnectionModel : connectionsModels) {
try {
Calendar calendar = Calendar.getInstance();
@@ -67,7 +67,7 @@ public class NotificationSenderComponent {
UtilityDate.formatDate(minsAfterNow, CommonConstants.DATETIME_FORMAT_YMD)
);
multiDBTransactionManager = new MultiDBTransactionManager(availableConnectionsModel.getProfileName());
multiDBTransactionManager = new MultiDBTransactionManager(availableConnectionModel.getProfileName());
List<HashMap<String, Object>> results = UtilityDB.executeSimpleQuery(multiDBTransactionManager.getPrimaryConnection(), sql);
multiDBTransactionManager.close();
@@ -78,7 +78,7 @@ public class NotificationSenderComponent {
StringBuilder jsonResponse = new StringBuilder();
int status = HttpRestWrapper.callGenericGet(
"http://localhost:" + UtilityServer.getLocalServerPort() + "/ems-api/notification/send/" + id + "?profileDb=" + availableConnectionsModel.getProfileName(),
"http://localhost:" + UtilityServer.getLocalServerPort() + "/ems-api/notification/send/" + id + "?profileDb=" + availableConnectionModel.getProfileName(),
null,
null,
jsonResponse,

6
ems-core/src/main/java/it/integry/security/cache/JwtTokenCacheComponent.java vendored
View File

@@ -2,7 +2,7 @@ package it.integry.security.cache;
import it.integry.annotations.PostContextAutowired;
import it.integry.annotations.PostContextConstruct;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -57,11 +57,11 @@ public class JwtTokenCacheComponent implements ApplicationListener {
private void updateCacheScheduled() {
if (!canStart || !settingsModel.isEnableTokenCaching()) return;
List<AvailableConnectionsModel> availableConnectionsModels = settingsModel.getAvailableConnections(true);
List<AvailableConnectionModel> availableConnectionModels = settingsModel.getAvailableConnections(true);
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager()) {
for (AvailableConnectionsModel model : availableConnectionsModels) {
for (AvailableConnectionModel model : availableConnectionModels) {
multiDBTransactionManager.addConnection(model);
}

6
ems-core/src/main/java/it/integry/security/service/DeviceInternalService.java
View File

@@ -1,6 +1,6 @@
package it.integry.security.service;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -32,9 +32,9 @@ public class DeviceInternalService {
"WHERE stb_auth_tokens.device_id IS NULL";
try {
List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for(AvailableConnectionsModel availableConnection : availableConnections) {
for (AvailableConnectionModel availableConnection : availableConnections) {
try (MultiDBTransactionManager mdb = new MultiDBTransactionManager(availableConnection)) {
UtilityDB.executeStatement(mdb.getPrimaryConnection(), cleanQuery);
}

4
ems-engine/src/main/java/it/integry/ems/activity/service/SteUPService.java
View File

@@ -19,7 +19,7 @@ import it.integry.ems.report.dto.PairsDTO;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.MailService;
import it.integry.ems.service.ReportProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.BasicConnectionPool;
import it.integry.ems.sync.MultiDBTransaction.Connection;
@@ -1291,7 +1291,7 @@ public class SteUPService {
public void allineamentoStrutturaDb(String profileDb) throws Exception {
AvailableConnectionsModel connectionsModel = settingsModel.getDefaultConnectionModel();
AvailableConnectionModel connectionsModel = settingsModel.getDefaultConnectionModel();
if (connectionsModel == null) {
throw new Exception("Impossibile ricavare la default connection");

6
ems-engine/src/main/java/it/integry/ems/contabil/service/AutofatturaService.java
View File

@@ -5,7 +5,7 @@ import it.integry.ems.contabil.dto.AutofatturaDTO;
import it.integry.ems.rules.businessLogic.AccountingBusinessLogic;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.MailService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -439,7 +439,7 @@ public class AutofatturaService {
}
public void chkAutofattura() throws Exception {
List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnections(true);
List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnections(true);
if (UtilityDebug.isIntegryServer()) {
availableConnections = availableConnections.stream().filter(x ->
@@ -447,7 +447,7 @@ public class AutofatturaService {
.collect(Collectors.toList());
}
for (AvailableConnectionsModel model : availableConnections) {
for (AvailableConnectionModel model : availableConnections) {
try (MultiDBTransactionManager mdb = new MultiDBTransactionManager(model)) {
Connection conn = mdb.getPrimaryConnection();

6
ems-engine/src/main/java/it/integry/ems/document/service/DocumentService.java
View File

@@ -26,7 +26,7 @@ import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.MailService;
import it.integry.ems.service.PrinterService;
import it.integry.ems.service.ReportProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -1225,7 +1225,7 @@ public class DocumentService {
}
public void chkInvioFE() throws Exception {
List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnections(true);
List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnections(true);
if (UtilityDebug.isIntegryServer()) {
availableConnections = availableConnections.stream().filter(x ->
@@ -1233,7 +1233,7 @@ public class DocumentService {
.collect(java.util.stream.Collectors.toList());
}
for (AvailableConnectionsModel model : availableConnections) {
for (AvailableConnectionModel model : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager1 = new MultiDBTransactionManager(model)) {
Connection conn = multiDBTransactionManager1.getPrimaryConnection();

6
ems-engine/src/main/java/it/integry/ems/logistic/missioni/magazzino_automatico/service/EuroforkDataSyncronizerService.java
View File

@@ -1,10 +1,8 @@
package it.integry.ems.logistic.missioni.magazzino_automatico.service;
import groovy.lang.Tuple3;
import it.integry.annotations.CustomerService;
import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.logistic.missioni.magazzino_automatico.dto.EuroforkLuPositionDTO;
import it.integry.ems.migration._base.IntegryCustomer;
import it.integry.ems.retail.wms.Utility.WMSUtility;
import it.integry.ems.retail.wms.generic.dto.MvwSitArtUdcDetInventarioDTO;
import it.integry.ems.retail.wms.generic.service.WMSGiacenzaULService;
@@ -30,7 +28,7 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
@CustomerService(IntegryCustomer.Biolevante)
//@CustomerService(IntegryCustomer.Biolevante)
public class EuroforkDataSyncronizerService {
private final Logger logger = LogManager.getLogger();
@@ -74,7 +72,7 @@ public class EuroforkDataSyncronizerService {
try (MultiDBTransactionManager mdbEurofork = new MultiDBTransactionManager("EUROFORK");
MultiDBTransactionManager mdbInternal = new MultiDBTransactionManager("BIOLEVANTE")) {
boolean resetAllPositions = false;
boolean resetAllPositions = true;
if (resetAllPositions) {
resetAllPositions(mdbInternal);
}

11
ems-engine/src/main/java/it/integry/ems/product/importaz/service/ImportApuliaPromoService.java
View File

@@ -6,7 +6,6 @@ import it.integry.ems.Import.dto.AnomalieDTO;
import it.integry.ems.Import.dto.ImportRequestDTO;
import it.integry.ems.file_formatter.csv.CsvMapper;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.base.EntityBase;
@@ -14,21 +13,19 @@ import it.integry.ems_model.config.EmsRestConstants;
import it.integry.ems_model.db.ResultSetMapper;
import it.integry.ems_model.entity.AtbListData;
import it.integry.ems_model.entity.MtbLisaData;
import it.integry.ems_model.entity.MtbLisvData;
import it.integry.ems_model.entity.VtbListData;
import it.integry.ems_model.service.SetupGest;
import it.integry.ems_model.types.OperationType;
import it.integry.ems_model.utility.*;
import it.integry.ems_model.utility.Query;
import it.integry.ems_model.utility.UtilityDB;
import it.integry.ems_model.utility.UtilityLocalDate;
import it.integry.ems_model.utility.UtilityString;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.util.*;
import java.util.stream.Collectors;

10
ems-engine/src/main/java/it/integry/ems/product/service/ContrattiDiAcquistoHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.product.service;
import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -53,9 +53,9 @@ public class ContrattiDiAcquistoHandlerService {
"WHERE cod_opz = 'WG098'\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -74,9 +74,9 @@ public class ContrattiDiAcquistoHandlerService {
private void updateProgContrattoA() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = executionPermission.getOrDefault(connectionModel.getDbName(), false);
if (!isEnabled) continue;

10
ems-engine/src/main/java/it/integry/ems/product/service/ContrattiDiVenditaHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.product.service;
import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -52,9 +52,9 @@ public class ContrattiDiVenditaHandlerService {
"WHERE cod_opz = 'WG097'\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -73,9 +73,9 @@ public class ContrattiDiVenditaHandlerService {
private void updateProgContrattoV() throws Exception {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = executionPermission.getOrDefault(connectionModel.getDbName(), false);
if (!isEnabled) continue;

8
ems-engine/src/main/java/it/integry/ems/retail/pvmRetail/service/PvmService.java
View File

@@ -32,7 +32,7 @@ import it.integry.ems.rules.businessLogic.LoadColliService;
import it.integry.ems.rules.completing.OrderRules;
import it.integry.ems.service.EmsServices;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -2447,9 +2447,9 @@ public class PvmService {
whereCond = Query.format("mtb_invent.cod_mdep = %s AND wtb_users.user_name = %s", userSession.getDefaultDepo().getCodMdep(), userSession.getCurrentUser().getUsername());
} else {
profiles = Stream.of(settingsModel.getAvailableConnections())
.filter(AvailableConnectionsModel::getInternalDb)
.distinctBy(AvailableConnectionsModel::getDbName)
.map(AvailableConnectionsModel::getProfileName)
.filter(AvailableConnectionModel::getInternalDb)
.distinctBy(AvailableConnectionModel::getDbName)
.map(AvailableConnectionModel::getProfileName)
.toList();
List<String> depositi = UtilityDB.executeSimpleQueryOnlyFirstColumn(multiDBTransactionManager.getPrimaryConnection(), Query.format("SELECT wtb_depo.cod_mdep\n" +
"FROM mtb_depo\n" +

10
ems-engine/src/main/java/it/integry/ems/retail/service/GrigliaAcquistoHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.retail.service;
import it.integry.common.var.CommonConstants;
import it.integry.ems.retail.dto.GrigliaAcquistoDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -54,9 +54,9 @@ public class GrigliaAcquistoHandlerService {
"WHERE cod_opz IN ('AG018', 'AG019')\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -103,9 +103,9 @@ public class GrigliaAcquistoHandlerService {
public void internalCache() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

10
ems-engine/src/main/java/it/integry/ems/retail/service/ListiniAcquistoHandlerService.java
View File

@@ -1,7 +1,7 @@
package it.integry.ems.retail.service;
import it.integry.ems.retail.dto.ListiniOrdiniAcquistoDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -47,9 +47,9 @@ public class ListiniAcquistoHandlerService {
"WHERE cod_opz = 'WG008'\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -72,9 +72,9 @@ public class ListiniAcquistoHandlerService {
public void updateData() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

10
ems-engine/src/main/java/it/integry/ems/retail/wms/ordini_acquisto/service/WMSBarcodeOrdiniAcquistoHandlerService.java
View File

@@ -1,7 +1,7 @@
package it.integry.ems.retail.wms.ordini_acquisto.service;
import it.integry.ems.retail.wms.ordini_acquisto.dto.BarcodeOrdiniAcquistoDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -47,9 +47,9 @@ public class WMSBarcodeOrdiniAcquistoHandlerService {
"WHERE cod_opz = 'WG008'\n" +
" AND flag_abil <> 'N'";
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
boolean isEnabled = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
@@ -72,10 +72,10 @@ public class WMSBarcodeOrdiniAcquistoHandlerService {
public void internalCache() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

10
ems-engine/src/main/java/it/integry/ems/retail/wms/ordini_acquisto/service/WMSMerceOrdiniAcquistoHandlerService.java
View File

@@ -2,7 +2,7 @@ package it.integry.ems.retail.wms.ordini_acquisto.service;
import com.annimon.stream.Stream;
import it.integry.ems.retail.wms.ordini_acquisto.dto.MerceOrdiniAcquistoDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
@@ -42,9 +42,9 @@ public class WMSMerceOrdiniAcquistoHandlerService {
if (!canBeExecuted) return;
try {
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionsModel : availableConnections) {
for (AvailableConnectionModel connectionsModel : availableConnections) {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(connectionsModel, false)) {
HashMap<String, String> setupSection = setupGest.getSetupSection(multiDBTransactionManager.getPrimaryConnection(), "PVM", "ORDINI_A");
@@ -68,9 +68,9 @@ public class WMSMerceOrdiniAcquistoHandlerService {
public void internalCache() {
if (!canBeExecuted) return;
final List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
for (AvailableConnectionsModel connectionModel : availableConnections) {
for (AvailableConnectionModel connectionModel : availableConnections) {
boolean isEnabled = isGestioneAbilitata(connectionModel.getDbName());
if (!isEnabled) continue;

6
ems-engine/src/main/java/it/integry/ems/system/context/EmsSystemContext.java
View File

@@ -9,7 +9,7 @@ import it.integry.ems.entity_logger.db_schema_manager.dto.DatabaseTableView;
import it.integry.ems.entity_logger.db_schema_manager.dto.DatabaseView;
import it.integry.ems.export.base.EntityExporterUtility;
import it.integry.ems.export.enums.EntityExportType;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.system.Import.AnagraficaImporter;
@@ -51,7 +51,7 @@ public class EmsSystemContext {
@Scheduled(cron = "0 0 0 * * *", zone = "Europe/Rome")
private void cleanTempTablesAndViews() throws Exception {
final List<AvailableConnectionsModel> availableDatabases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
final List<AvailableConnectionModel> availableDatabases = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
Pattern pattern1 = Pattern.compile("(t[0-9])\\w+", Pattern.CASE_INSENSITIVE);
Pattern pattern2 = Pattern.compile("(m[0-9])\\w+", Pattern.CASE_INSENSITIVE);
@@ -63,7 +63,7 @@ public class EmsSystemContext {
ArrayList<Callable<Void>> futureTasks = new ArrayList<>();
for (final AvailableConnectionsModel availableDatabase : availableDatabases) {
for (final AvailableConnectionModel availableDatabase : availableDatabases) {
futureTasks.add(() -> {
try (MultiDBTransactionManager multiDBTransactionManager = new MultiDBTransactionManager(availableDatabase)) {

6
ems-engine/src/main/java/it/integry/ems/system/controller/AziendaController.java
View File

@@ -4,7 +4,7 @@ import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.service.AziendaService;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.dto.UpdatePvmEndpointRequestDTO;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.entity.Azienda;
@@ -62,11 +62,11 @@ public class AziendaController {
throw new IllegalArgumentException("Endpoint cannot be null or empty");
}
List<AvailableConnectionsModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
List<AvailableConnectionModel> availableConnections = settingsModel.getAvailableConnectionsWithoutDuplicatedProfiles(true);
Exception firstException = null;
for (AvailableConnectionsModel availableConnection : availableConnections) {
for (AvailableConnectionModel availableConnection : availableConnections) {
StbGestSetup stbGestSetup = new StbGestSetup()
.setGestName("DATI_AZIENDA")
.setSection("URL")

14
ems-engine/src/main/java/it/integry/ems/system/controller/SystemController.java
View File

@@ -22,7 +22,7 @@ import it.integry.ems.service.*;
import it.integry.ems.service.dto.CustomEmailDTO;
import it.integry.ems.service.dto.TicketNotificationMailTemplateDataDTO;
import it.integry.ems.service.exception.EmptyReportException;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.status.ServiceChecker;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
@@ -483,16 +483,16 @@ public class SystemController {
ServiceRestResponse response;
try {
List<String> profiles = Stream.of(settingsModel.getAvailableConnections())
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.toList();
List<String> profilesWhereUserFound = new ArrayList<String>();
if (!UtilityString.isNullOrEmpty(username) && !UtilityString.isNullOrEmpty(password)) {
for (AvailableConnectionsModel availableConnectionsModel : settingsModel.getAvailableConnections()) {
if (availableConnectionsModel.getInternalDb()) {
HashMap<String, Object> tmpUserData = systemService.getUserdata(username, password, null, availableConnectionsModel);
if (tmpUserData != null) profilesWhereUserFound.add(availableConnectionsModel.getProfileName());
for (AvailableConnectionModel availableConnectionModel : settingsModel.getAvailableConnections()) {
if (availableConnectionModel.getInternalDb()) {
HashMap<String, Object> tmpUserData = systemService.getUserdata(username, password, null, availableConnectionModel);
if (tmpUserData != null) profilesWhereUserFound.add(availableConnectionModel.getProfileName());
}
}
} else {
@@ -1457,7 +1457,7 @@ public class SystemController {
try {
Optional<String> optProfile = Stream.of(settingsModel.getAvailableConnections())
.filter(x -> x.getDbName().equalsIgnoreCase(dbName))
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.findFirst();
if (optProfile.isPresent()) return ServiceRestResponse.createPositiveResponse(optProfile.get());

4
ems-engine/src/main/java/it/integry/ems/system/exchange/controller/ExchangeConfigController.java
View File

@@ -1,7 +1,7 @@
package it.integry.ems.system.exchange.controller;
import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.system.exchange.dto.ExchangeUpdateRowsOrderRequestDTO;
import it.integry.ems.system.exchange.service.structure.ExchangeConfigService;
@@ -33,7 +33,7 @@ public class ExchangeConfigController {
return ServiceRestResponse.createPositiveResponse(settingsModel.getAvailableConnections().stream()
.filter(x -> x.getInternalDb() || !onlyInternal)
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.collect(Collectors.toList()));
}

10
ems-engine/src/main/java/it/integry/ems/system/service/SystemService.java
View File

@@ -20,7 +20,7 @@ import it.integry.ems.response.FileItem;
import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.MailService;
import it.integry.ems.settings.Model.AvailableConnectionsModel;
import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.settings.SettingsController;
import it.integry.ems.sync.MultiDBTransaction.Connection;
@@ -171,7 +171,7 @@ public class SystemService {
return new ServiceRestResponse(EsitoType.OK, nodeList);
}
public HashMap<String, Object> getUserdata(String userName, String password, String md5User, AvailableConnectionsModel connectionModel) throws Exception {
public HashMap<String, Object> getUserdata(String userName, String password, String md5User, AvailableConnectionModel connectionModel) throws Exception {
String whereCond;
if (userName != null && !UtilityString.isNullOrEmpty(userName.trim())) {
String pswLower = password != null ? password.toLowerCase() : null;
@@ -321,14 +321,14 @@ public class SystemService {
// SELEZIONE CICLICA IN TUTTI I DB SPECIFICATI
profiles = Stream.of(settingsModel.getAvailableConnections(true))
.filter(x -> x.getProfileName().equalsIgnoreCase(x.getDbName()))
.map(AvailableConnectionsModel::getProfileName)
.map(AvailableConnectionModel::getProfileName)
.toList();
}
if (profiles.isEmpty()) {
profiles = Stream.of(settingsModel.getAvailableConnections(true))
.distinctBy(AvailableConnectionsModel::getDbName)
.map(AvailableConnectionsModel::getProfileName)
.distinctBy(AvailableConnectionModel::getDbName)
.map(AvailableConnectionModel::getProfileName)
.toList();
}