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

Merge branch 'develop' into feature/JDK11
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
jenkins
2025-01-16 15:23:40 +01:00
parent 44ce2a7b71 fcd9cbe153
commit 9fc43d1f4d
8 changed files with 122 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250116150858.java Normal file
View File

@@ -0,0 +1,33 @@
package it.integry.ems.migration.model;
import it.integry.ems.migration._base.BaseMigration;
import it.integry.ems.migration._base.IntegryCustomer;
import it.integry.ems.migration._base.MigrationModelInterface;
public class Migration_20250116150858 extends BaseMigration implements MigrationModelInterface {
@Override
public void up() throws Exception {
if (isHistoryDB())
return;
if (!isCustomer(IntegryCustomer.Carelli)) return;
createOrUpdateView("gvw_part_iva_infragroup", "ALTER VIEW [dbo].[gvw_part_iva_infragroup] AS\n" +
" SELECT part_iva\n" +
" FROM gestfood.dbo.azienda\n" +
" UNION\n" +
" SELECT part_iva\n" +
" FROM panimal.dbo.azienda\n" +
" UNION\n" +
" SELECT part_iva\n" +
" FROM carelli.dbo.azienda\n" +
" UNION\n" +
" SELECT part_iva\n" +
" FROM format.dbo.azienda");
}
@Override
public void down() throws Exception {
}
}

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

@@ -80,7 +80,7 @@ public class BasicConnectionPool {
public synchronized boolean releaseConnection(String profileName, DataSource ds) throws UnexpectedConnectionSwitchException, SQLException, IOException {
String currentCatalog = ds.getConnection().getCatalog();
final AvailableConnectionsModel availableConnectionsModel = settingsModel.getAvailableConnections().stream()
.filter(x -> x.getProfileName().equals(profileName))
.filter(x -> x.getProfileName().equalsIgnoreCase(profileName))
.findFirst()
.orElse(null);

2
ems-engine/src/main/java/it/integry/ems/document/export/DocumentiExporter.java
View File

@@ -71,7 +71,7 @@ public class DocumentiExporter extends BaseEntityExporter implements IEntityExpo
break;
case SICILIANI_ORGCONS:
SicilianiDMSExportService orgCons = context.getBean(SicilianiDMSExportService.class);
entityExportResponse = orgCons.syncOrgCons(jsonBody.get("whereCond").asText(), jsonBody.get("queryPercPesoOrdViaggio").asText(), jsonBody.get("dataCons").asText());
entityExportResponse = orgCons.syncOrgCons(jsonBody.get("whereCond").asText(), jsonBody.get("queryPercPesoOrdViaggio").asText(), jsonBody.get("dataCons").asText(), username);
break;
case SICILIANI_TAGLIACUCI:
SicilianiDMSExportService tagliaCuci = context.getBean(SicilianiDMSExportService.class);

8
ems-engine/src/main/java/it/integry/ems/document/export/service/SicilianiDMSExportService.java
View File

@@ -180,7 +180,7 @@ public class SicilianiDMSExportService {
return response;
}
public EntityExportResponse syncOrgCons(String whereCond, String queryDettPesoViaggio, String dataCons) throws Exception {
public EntityExportResponse syncOrgCons(String whereCond, String queryDettPesoViaggio, String dataCons, String userNAme) throws Exception {
EntityExportResponse<List<File>> response = new EntityExportResponse<List<File>>();
response.setResponse(new ArrayList<File>());
String profileDBAlyante = setupGest.getSetup("DMS", "PROFILE", "ALYANTE");
@@ -195,7 +195,7 @@ public class SicilianiDMSExportService {
try {
String codiceDitta = setupGest.getSetup("DMS", "SETUP", "CODICE_DITTA");
String serverObject = setupGest.getSetup("DMS", "PROFILE", "DB_INTERSCAMBIO");
String userUnlockIDViaggio = setupGest.getSetupUser(conn, "W_VORGCONS_DISP", "SETUP","ABILITA_SBLOCCO_ID_VIAGGIO", userNAme);
String columnPercPesoOrdine = "";
String tableCostoViaggi = "";
@@ -324,7 +324,7 @@ public class SicilianiDMSExportService {
((String) UtilityHashMap.getValueIfExists(x, "lockIdViaggio")).equalsIgnoreCase("S")).findFirst();
if (!lockIdViaggio.isPresent()) {
if (!lockIdViaggio.isPresent() || userUnlockIDViaggio.equalsIgnoreCase("S")) {
if (flagExistOrd.compareTo("N") == 0) {
sql = "INSERT INTO dtb_infoviaggi " +
"( ditta, " +
@@ -453,7 +453,7 @@ public class SicilianiDMSExportService {
((Integer) UtilityHashMap.getValueIfExists(x, "id_viaggio")).equals(idViaggio) &&
((String) UtilityHashMap.getValueIfExists(x, "lockIdViaggio")).equalsIgnoreCase("S")).findFirst();
if (!lockIdViaggio.isPresent()) {
if (!lockIdViaggio.isPresent() || userUnlockIDViaggio.equalsIgnoreCase("S")) {
sql = "delete from dtb_infoviaggi " +
" from dtb_infoviaggi " +
" where chiave_traxal = " + UtilityDB.valueToString(keyOrd);

41
ems-engine/src/main/java/it/integry/ems/logistic/service/DistribuzioneColliService.java
View File

@@ -246,9 +246,9 @@ public class DistribuzioneColliService {
List<DtbOrdr> orderRows = UtilityDB.executeSimpleQueryDTO(multiDBTransactionManager.getPrimaryConnection(), dtbOrdrSql, DtbOrdr.class, 30);
if (orderRows == null) orderRows = new ArrayList<>();
orderTestate = Stream.of(orderTestate)
orderTestate = orderTestate.stream()
.distinct()
.toList();
.collect(Collectors.toList());
List<MtbColr> mtbColrsToSave = new ArrayList<>();
@@ -313,9 +313,10 @@ public class DistribuzioneColliService {
MtbColr sourceMtbColr = groupedMtbColrs.get(i);
final MtbColr finalSourceMtbColr = sourceMtbColr;
MtbAart currentMtbAart = Stream.of(mtbAarts)
MtbAart currentMtbAart = mtbAarts.stream()
.filter(mtbAart -> finalSourceMtbColr.getCodMart().equalsIgnoreCase(mtbAart.getCodMart()))
.single();
.findFirst()
.orElse(null);
//Mi calcolo una qta_cnf media
if ("S".equalsIgnoreCase(currentMtbAart.getFlagQtaCnfFissa())) {
@@ -336,20 +337,20 @@ public class DistribuzioneColliService {
//solo se la partita non è NULL sull'ordine ed è uguale su collo e ordine
List<DtbOrdr> artOrderRowsWithPart = null;
if (flagRaggXQtaCnf.equalsIgnoreCase("S") && "N".equalsIgnoreCase(currentMtbAart.getFlagQtaCnfFissa())) {
artOrderRowsWithPart = Stream.of(orderRows)
artOrderRowsWithPart = orderRows.stream()
.filter(dtbOrdr -> UtilityString.equalsIgnoreCase(dtbOrdr.getCodMart(), finalSourceMtbColr.getCodMart()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getPartitaMag(), finalSourceMtbColr.getPartitaMag()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodTagl(), finalSourceMtbColr.getCodTagl()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodCol(), finalSourceMtbColr.getCodCol()) &&
Objects.equals(dtbOrdr.getQtaCnf().setScale(5, RoundingMode.HALF_UP), finalSourceMtbColr.getQtaCnf().setScale(5, RoundingMode.HALF_UP)))
.toList();
.collect(Collectors.toList());
} else {
artOrderRowsWithPart = Stream.of(orderRows)
artOrderRowsWithPart = orderRows.stream()
.filter(dtbOrdr -> UtilityString.equalsIgnoreCase(dtbOrdr.getCodMart(), finalSourceMtbColr.getCodMart()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getPartitaMag(), finalSourceMtbColr.getPartitaMag()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodTagl(), finalSourceMtbColr.getCodTagl()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodCol(), finalSourceMtbColr.getCodCol()))
.toList();
.collect(Collectors.toList());
}
for (int j = 0; j < artOrderRowsWithPart.size() && sourceMtbColr.getQtaCol().compareTo(BigDecimal.ZERO) > 0; j++) {
@@ -403,20 +404,20 @@ public class DistribuzioneColliService {
//solo se la partita è NULL sull'ordine
List<DtbOrdr> artOrderRowsNoPart = null;
if (flagRaggXQtaCnf.equalsIgnoreCase("S") && "N".equalsIgnoreCase(currentMtbAart.getFlagQtaCnfFissa())) {
artOrderRowsNoPart = Stream.of(orderRows)
artOrderRowsNoPart = orderRows.stream()
.filter(dtbOrdr -> UtilityString.equalsIgnoreCase(dtbOrdr.getCodMart(), finalSourceMtbColr.getCodMart()) &&
(dtbOrdr.getPartitaMag() == null) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodTagl(), finalSourceMtbColr.getCodTagl()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodCol(), finalSourceMtbColr.getCodCol()) &&
Objects.equals(dtbOrdr.getQtaCnf().setScale(5, RoundingMode.HALF_UP), finalSourceMtbColr.getQtaCnf().setScale(5, RoundingMode.HALF_UP)))
.toList();
.collect(Collectors.toList());
} else {
artOrderRowsNoPart = Stream.of(orderRows)
artOrderRowsNoPart = orderRows.stream()
.filter(dtbOrdr -> UtilityString.equalsIgnoreCase(dtbOrdr.getCodMart(), finalSourceMtbColr.getCodMart()) &&
(dtbOrdr.getPartitaMag() == null) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodTagl(), finalSourceMtbColr.getCodTagl()) &&
UtilityString.equalsIgnoreCase(dtbOrdr.getCodCol(), finalSourceMtbColr.getCodCol()))
.toList();
.collect(Collectors.toList());
}
for (int j = 0; j < artOrderRowsNoPart.size() && sourceMtbColr.getQtaCol().compareTo(BigDecimal.ZERO) > 0; j++) {
@@ -496,7 +497,7 @@ public class DistribuzioneColliService {
if (dtbOrdrToUpdate != null && !dtbOrdrToUpdate.isEmpty()) {
//Creo le testate per ogni ordine trovato nelle righe
List<DtbOrdt> dtbOrdtToUpdate = Stream.of(dtbOrdrToUpdate)
List<DtbOrdt> dtbOrdtToUpdate = dtbOrdrToUpdate.stream()
.map(dtbOrdr -> {
DtbOrdt dtbOrdt = new DtbOrdt();
dtbOrdt.setGestione(dtbOrdr.getGestione());
@@ -507,7 +508,7 @@ public class DistribuzioneColliService {
return dtbOrdt;
})
.distinct()
.toList();
.collect(Collectors.toList());
if (dtbOrdtToUpdate != null && !dtbOrdtToUpdate.isEmpty()) {
@@ -544,13 +545,13 @@ public class DistribuzioneColliService {
mtbColrToSave.setQueryTimeoutSeconds(30);
//Carico tutte le righe che combaciano con qta > 0
List<MtbColr> found = Stream.of(sourceMtbColrs)
List<MtbColr> found = sourceMtbColrs.stream()
.filter(mtbColr -> UtilityString.equalsIgnoreCase(mtbColr.getPartitaMag(), mtbColrToSave.getPartitaMag()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodMart(), mtbColrToSave.getCodMart()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodTagl(), mtbColrToSave.getCodTagl()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodCol(), mtbColrToSave.getCodCol()) &&
mtbColr.getQtaCol().compareTo(BigDecimal.ZERO) > 0)
.toList();
.collect(Collectors.toList());
BigDecimal qtaTotToSubstract = mtbColrToSave.getQtaCol();
@@ -662,13 +663,13 @@ public class DistribuzioneColliService {
groupedMtbColr.setOperation(OperationType.INSERT_OR_UPDATE);
groupedMtbColr.setNumCnf(null);
List<MtbColr> match = Stream.of(mtbColrsToSave)
List<MtbColr> match = mtbColrsToSave.stream()
.filter(mtbColr -> UtilityString.equalsIgnoreCase(mtbColr.getCodMart(), groupedMtbColr.getCodMart()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodCol(), groupedMtbColr.getCodCol()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodTagl(), groupedMtbColr.getCodTagl()) &&
UtilityString.equalsIgnoreCase(mtbColr.getPartitaMag(), groupedMtbColr.getPartitaMag()) &&
UtilityString.equalsIgnoreCase(mtbColr.getCodJcom(), groupedMtbColr.getCodJcom()))
.toList();
.collect(Collectors.toList());
if (match != null && !match.isEmpty()) {
groupedMtbColr.setNumOrd(match.get(0).getNumOrd());
@@ -689,7 +690,7 @@ public class DistribuzioneColliService {
sourceMtbColt.setDataDistribuzione(new Date());
sourceMtbColt.setQueryTimeoutSeconds(30);
boolean anyRowInSourceMtbColt = Stream.of(sourceMtbColt.getMtbColr())
boolean anyRowInSourceMtbColt = sourceMtbColt.getMtbColr().stream()
.anyMatch(x -> x.getOperation() != OperationType.DELETE &&
UtilityBigDecimal.greaterThan(x.getQtaCol(), BigDecimal.ZERO) ||
UtilityBigDecimal.greaterThan(x.getNumCnf(), BigDecimal.ZERO) ||
@@ -732,7 +733,7 @@ public class DistribuzioneColliService {
private void checkInDistribution(MtbColt sourceMtbColt) throws Exception {
if (Stream.of(this.mCurrentlyDistributingMtbColt)
if (this.mCurrentlyDistributingMtbColt.stream()
.anyMatch(x -> x.getGestione().equalsIgnoreCase(sourceMtbColt.getGestione()) &&
x.getNumCollo().equals(sourceMtbColt.getNumCollo()) &&
x.getSerCollo().equalsIgnoreCase(sourceMtbColt.getSerCollo()) &&

10
ems-engine/src/main/java/it/integry/ems/product/importaz/dto/AggiornaLisvDTO.java
View File

@@ -20,6 +20,7 @@ public class AggiornaLisvDTO {
private String whereCondLisv;
private BigDecimal ricaricoTestataLisv;
private BigDecimal percMaggPrezzo;
private BigDecimal percMaggPrezzoAcquisto;
private Boolean aggArtCommerciali;
private List<MtbLisvData> mtbLisvData;
@@ -140,6 +141,15 @@ public class AggiornaLisvDTO {
return this;
}
public BigDecimal getPercMaggPrezzoAcquisto() {
return percMaggPrezzoAcquisto;
}
public AggiornaLisvDTO setPercMaggPrezzoAcquisto(BigDecimal percMaggPrezzoAcquisto) {
this.percMaggPrezzoAcquisto = percMaggPrezzoAcquisto;
return this;
}
public Boolean getAggArtCommerciali() {
return aggArtCommerciali;
}

73
ems-engine/src/main/java/it/integry/ems/product/importaz/service/ImportListiniVenditaService.java
View File

@@ -210,32 +210,53 @@ public class ImportListiniVenditaService {
whereCond = " AND lisv.cod_mart is not null";
}
String queryLisa =
"SELECT atb_list_data.cod_promo, "
+ " atb_list_data.note as descr_promo, "
+ " atb_list_data.data_iniz_sell_out, "
+ " atb_list_data.data_fine_sell_out, " + " mtb_lisa.cod_mart, "
+ " round(IsNull(mtb_lisa_data.prz_acq, mtb_lisa.prz_acq)/ mtb_lisa.rap_conv, 5) as prz_acq, "
+ " round(dbo.f_calcPrzNettoAcq( atb_list.cod_alis, atb_list.expression_costo, Isnull(mtb_lisa_data.perc_1,mtb_lisa.perc_1), Isnull(mtb_lisa_data.perc_2, mtb_lisa.perc_2), Isnull(mtb_lisa_data.perc_3, mtb_lisa.perc_3), Isnull(mtb_lisa_data.perc_4, mtb_lisa.perc_4), IsNull(mtb_lisa_promo.perc_promo_1, 0), IsNull(mtb_lisa_promo.perc_promo_2, 0), IsNull(mtb_lisa_promo.perc_promo_3, 0), IsNull(mtb_lisa_promo.perc_promo_4, 0), Isnull(mtb_lisa_data.perc_promo, mtb_lisa.perc_promo), Isnull(mtb_lisa_data.val_promo, mtb_lisa.val_promo), Isnull(mtb_lisa_data.perc_oneri, mtb_lisa.perc_oneri), Isnull(mtb_lisa_data.val_oneri, mtb_lisa.val_oneri), Isnull(mtb_lisa_data.prz_acq, mtb_lisa.prz_acq)) / mtb_lisa.rap_conv, 5) as prz_acq_netto, "
+ " IsNull(mtb_lisa_data.prz_ven_sug, mtb_lisa.prz_ven_sug ) as prz_vend_sugg, "
+ " atb_list_data.cod_alis, "
+ " atb_list_data.versione "
+ " FROM mtb_lisa "
+ " INNER JOIN atb_list ON atb_list.cod_alis = mtb_lisa.cod_alis "
+ " INNER JOIN mtb_aart ON mtb_lisa.cod_mart = mtb_aart.cod_mart "
+ " INNER JOIN mtb_lisa_data ON mtb_lisa.cod_alis = mtb_lisa_data.cod_alis AND "
+ " mtb_lisa.cod_art_for = mtb_lisa_data.cod_art_for AND "
+ " mtb_lisa_data.versione = " + UtilityDB.valueToString(aggiornaLisvDTO.getVersione())
+ " LEFT OUTER JOIN mtb_lisa_promo ON mtb_lisa_data.cod_alis = mtb_lisa_promo.cod_alis AND "
+ " mtb_lisa_data.versione = mtb_lisa_promo.versione AND "
+ " mtb_lisa_data.cod_art_for = mtb_lisa_promo.cod_art_for "
+ " LEFT OUTER JOIN atb_list_data ON mtb_lisa_data.cod_alis = atb_list_data.cod_alis AND "
+ " mtb_lisa_data.versione = atb_list_data.versione "
+ " WHERE ( mtb_lisa_data.tipo_variazione is null or mtb_lisa_data.tipo_variazione <> 'D' ) AND "
+ " mtb_lisa.cod_alis = " + UtilityDB.valueToString(aggiornaLisvDTO.getCodAlis()) + " AND "
+ " ((" + UtilityDB.valueToString(aggiornaLisvDTO.getVersione()) + " <> 0 and mtb_lisa_data.versione is not null) or (" + UtilityDB.valueToString(aggiornaLisvDTO.getVersione()) + " = 0)) and "
+ " mtb_lisa.flag_attivo = 'S' ";
String maggiorazionePrzAcq = "";
if ( !UtilityBigDecimal.isNullOrZero(aggiornaLisvDTO.getPercMaggPrezzoAcquisto()) ){
maggiorazionePrzAcq = " * ( 1 + CAST(" + aggiornaLisvDTO.getPercMaggPrezzoAcquisto() + " as numeric(20,5))/100) ";
}
String queryLisa =
"SELECT atb_list_data.cod_promo,\n" +
" atb_list_data.note AS descr_promo,\n" +
" atb_list_data.data_iniz_sell_out,\n" +
" atb_list_data.data_fine_sell_out,\n" +
" mtb_lisa.cod_mart,\n" +
" ROUND(ISNULL(mtb_lisa_data.prz_acq, mtb_lisa.prz_acq) / mtb_lisa.rap_conv [MAGG_PRZ_ACQ], 5) AS prz_acq,\n" +
" ROUND(dbo.f_calcprznettoacq(atb_list.cod_alis, atb_list.expression_costo,\n" +
" ISNULL(mtb_lisa_data.perc_1, mtb_lisa.perc_1),\n" +
" ISNULL(mtb_lisa_data.perc_2, mtb_lisa.perc_2),\n" +
" ISNULL(mtb_lisa_data.perc_3, mtb_lisa.perc_3),\n" +
" ISNULL(mtb_lisa_data.perc_4, mtb_lisa.perc_4),\n" +
" ISNULL(mtb_lisa_promo.perc_promo_1, 0), ISNULL(mtb_lisa_promo.perc_promo_2, 0),\n" +
" ISNULL(mtb_lisa_promo.perc_promo_3, 0), ISNULL(mtb_lisa_promo.perc_promo_4, 0),\n" +
" ISNULL(mtb_lisa_data.perc_promo, mtb_lisa.perc_promo),\n" +
" ISNULL(mtb_lisa_data.val_promo, mtb_lisa.val_promo),\n" +
" ISNULL(mtb_lisa_data.perc_oneri, mtb_lisa.perc_oneri),\n" +
" ISNULL(mtb_lisa_data.val_oneri, mtb_lisa.val_oneri),\n" +
" ISNULL(mtb_lisa_data.prz_acq, mtb_lisa.prz_acq)) / mtb_lisa.rap_conv [MAGG_PRZ_ACQ], 5) AS prz_acq_netto,\n" +
" ISNULL(mtb_lisa_data.prz_ven_sug, mtb_lisa.prz_ven_sug) AS prz_vend_sugg,\n" +
" atb_list_data.cod_alis,\n" +
" atb_list_data.versione\n" +
"FROM mtb_lisa\n" +
" INNER JOIN atb_list ON atb_list.cod_alis = mtb_lisa.cod_alis\n" +
" INNER JOIN mtb_aart ON mtb_lisa.cod_mart = mtb_aart.cod_mart\n" +
" INNER JOIN mtb_lisa_data ON mtb_lisa.cod_alis = mtb_lisa_data.cod_alis AND\n" +
" mtb_lisa.cod_art_for = mtb_lisa_data.cod_art_for AND " +
" mtb_lisa_data.versione = [VERSIONE]\n" +
" LEFT OUTER JOIN mtb_lisa_promo ON mtb_lisa_data.cod_alis = mtb_lisa_promo.cod_alis AND\n" +
" mtb_lisa_data.versione = mtb_lisa_promo.versione AND\n" +
" mtb_lisa_data.cod_art_for = mtb_lisa_promo.cod_art_for\n" +
" LEFT OUTER JOIN atb_list_data ON mtb_lisa_data.cod_alis = atb_list_data.cod_alis AND\n" +
" mtb_lisa_data.versione = atb_list_data.versione\n" +
"WHERE (mtb_lisa_data.tipo_variazione IS NULL OR mtb_lisa_data.tipo_variazione <> 'D')\n" +
" AND mtb_lisa.cod_alis = [COD_ALIS]\n" +
" AND (([VERSIONE] <> 0 AND mtb_lisa_data.versione IS NOT NULL) OR ([VERSIONE] = 0))\n" +
" AND mtb_lisa.flag_attivo = 'S' ";
queryLisa = queryLisa
.replace("[COD_ALIS]", UtilityDB.valueToString(aggiornaLisvDTO.getCodAlis()))
.replace("[VERSIONE]", UtilityDB.valueToString(aggiornaLisvDTO.getVersione()))
.replace("[MAGG_PRZ_ACQ]", maggiorazionePrzAcq);
String queryLisv =
"SELECT vtb_list.cod_vlis, "
@@ -284,7 +305,7 @@ public class ImportListiniVenditaService {
+ " lisa.cod_mart, "
+ " IsNull(lisv.unt_mis_ven, mtb_aart.unt_mis) as unt_mis_ven, "
+ " IsNull(lisv.rap_conv, 1) as rap_conv, "
+ " lisa.prz_acq_netto * IsNull(lisv.rap_conv, 1) as prz_base, "
+ " lisa.prz_acq_netto * IsNull(lisv.rap_conv, 1) as prz_base, " //TO-DO Mina
+ " case when lisv.cod_mart is null THEN "
+ "CASE " + UtilityDB.valueToString(setup.get("RICARICO_ART_NUOVI"))
+ " WHEN 'T' THEN testata_lisv.ricarico_testata "

8
ems-engine/src/main/java/it/integry/ems/production/service/FLProductionService.java
View File

@@ -398,8 +398,10 @@ public class FLProductionService {
if ("S".compareTo(isDBcentrale) == 0) {
passaporto = getNextNumPassaporto(connDBCentrale, codCentroAziDBCentrale, flAggListinoProdDTO.getDataProd());
passaportoDBCentrale = passaporto;
/* passaporto = getNextNumPassaporto(connDBCentrale, codCentroAziDBCentrale, flAggListinoProdDTO.getDataProd());
passaportoDBCentrale = passaporto;*/
passaporto = flAggListinoProdDTO.getPassaporto();
}
if (!UtilityString.isNullOrEmpty(flAggListinoProdDTO.getCodAlis())) {
@@ -438,7 +440,7 @@ public class FLProductionService {
String erroreMessage = mtbListData.getException().getMessage();
throw new Exception(erroreMessage);
} else {
if ("N".compareTo(contoLavoro) == 0) {
if ("N".compareTo(contoLavoro) == 0 && isDBcentrale.compareTo("N") == 0) {
/*******************************************************
* AGGIORNAMENTO LISTINO FORNITORE DATABASE CENTRALE
* ******************************************************/