diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250630165427.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250630165427.java new file mode 100644 index 0000000000..8bdc0fcc90 --- /dev/null +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250630165427.java @@ -0,0 +1,137 @@ +package it.integry.ems.migration.model; + +import it.integry.ems.migration._base.BaseMigration; +import it.integry.ems.migration._base.MigrationModelInterface; + +public class Migration_20250630165427 extends BaseMigration implements MigrationModelInterface { + + @Override + public void up() throws Exception { + if (isHistoryDB()) + return; + + + createOrUpdateView("pvw_clienti_prospect", "CREATE VIEW [dbo].[pvw_clienti_prospect] AS \n" + + "SELECT\n" + + " 'P' AS tipologia,\n" + + " ptb_pros.cod_ppro,\n" + + " ptb_pros.rag_soc,\n" + + " ptb_pros.indirizzo,\n" + + " ptb_pros.cap,\n" + + " ptb_pros.citta,\n" + + " ptb_pros.prov,\n" + + " ptb_pros.nazione,\n" + + " ptb_pros.telefono,\n" + + " ptb_pros.fax,\n" + + " ptb_pros.part_iva,\n" + + " ptb_pros.cod_fisc,\n" + + " ptb_pros.note,\n" + + " ptb_pros.e_mail,\n" + + " ptb_pros.e_mail_pec,\n" + + " ptb_pros.cuu_pa,\n" + + " ptb_pros.cod_ppro AS cod_ppro_anag,\n" + + " ptb_pros.cod_vage,\n" + + " vtb_agen.cod_visp AS cod_visp,\n" + + " ptb_pros.fonte,\n" + + " ptb_pros.cod_vzon,\n" + + " CONVERT(numeric(5, 2), 0) AS perc_provv,\n" + + " case when ptb_pros.flag_stato_pros = 1 then 'A' else 'I' end AS flag_stato,\n" + + " ptb_pros.cod_anag,\n" + + " ptb_pros.gg_chiusura,\n" + + " ptb_pros.data_ins,\n" + + " ptb_pros.cod_vtip AS cod_canale,\n" + + " ptb_pros.cod_paga,\n" + + " ptb_pros.rag_soc2,\n" + + " ptb_pros.flag_informativa,\n" + + " ptb_pros.flag_consenso,\n" + + " ptb_pros.persona_rif,\n" + + " ptb_pros.telefono as num_cell \n" + + "FROM\n" + + " ptb_pros LEFT OUTER JOIN vtb_agen ON ptb_pros.cod_vage = vtb_agen.cod_vage \n" + + "UNION ALL\n" + + "SELECT\n" + + " 'C',\n" + + " gtb_anag.cod_anag,\n" + + " gtb_anag.rag_soc,\n" + + " gtb_anag.indirizzo,\n" + + " gtb_anag.cap,\n" + + " gtb_anag.citta,\n" + + " gtb_anag.prov,\n" + + " gtb_anag.nazione,\n" + + " gtb_anag.telefono,\n" + + " gtb_anag.fax,\n" + + " gtb_anag.part_iva,\n" + + " gtb_anag.cod_fisc,\n" + + " gtb_anag.note,\n" + + " gtb_anag.e_mail,\n" + + " gtb_anag.e_mail_pec,\n" + + " gtb_anag.cuu_pa,\n" + + " gtb_anag.cod_anag AS cod_ppro_anag,\n" + + " vtb_clie.cod_vage,\n" + + " vtb_agen.cod_visp,\n" + + " CONVERT(varchar(40), NULL),\n" + + " vtb_clie.cod_vzon,\n" + + " vtb_clie.perc_prov,\n" + + " vtb_clie.flag_stato,\n" + + " CONVERT(varchar(5), NULL),\n" + + " vtb_clie.gg_chiusura,\n" + + " gtb_anag.data_ins,\n" + + " vtb_clie.cod_vtip,\n" + + " vtb_clie.cod_paga,\n" + + " gtb_anag.rag_soc2,\n" + + " gtb_anag.flag_informativa,\n" + + " gtb_anag.flag_consenso,\n" + + " gtb_anag.persona_rif,\n" + + " gtb_anag.num_cell \n" + + "FROM\n" + + " gtb_anag \n" + + " INNER JOIN vtb_clie ON gtb_anag.cod_anag = vtb_clie.cod_anag \n" + + " LEFT OUTER JOIN vtb_agen ON vtb_clie.cod_vage = vtb_agen.cod_vage \n" + + "UNION ALL\n" + + "SELECT\n" + + " 'F' AS tipologia,\n" + + " gtb_anag.cod_anag,\n" + + " gtb_anag.rag_soc,\n" + + " gtb_anag.indirizzo,\n" + + " gtb_anag.cap,\n" + + " gtb_anag.citta,\n" + + " gtb_anag.prov,\n" + + " gtb_anag.nazione,\n" + + " gtb_anag.telefono,\n" + + " gtb_anag.fax,\n" + + " gtb_anag.part_iva,\n" + + " gtb_anag.cod_fisc,\n" + + " gtb_anag.note,\n" + + " gtb_anag.e_mail,\n" + + " gtb_anag.e_mail_pec,\n" + + " gtb_anag.cuu_pa,\n" + + " gtb_anag.cod_anag,\n" + + " CONVERT(varchar(5), NULL),\n" + + " CONVERT(varchar(5), NULL),\n" + + " CONVERT(varchar(40), NULL),\n" + + " CONVERT(varchar(5), NULL),\n" + + " CONVERT(numeric(5, 2), 0),\n" + + " atb_forn.flag_stato,\n" + + " CONVERT(varchar(5), NULL),\n" + + " CONVERT(varchar(40), NULL),\n" + + " gtb_anag.data_ins,\n" + + " atb_forn.cod_atip AS cod_canale,\n" + + " atb_forn.cod_paga,\n" + + " gtb_anag.rag_soc2,\n" + + " gtb_anag.flag_informativa,\n" + + " gtb_anag.flag_consenso,\n" + + " gtb_anag.persona_rif,\n" + + " gtb_anag.num_cell \n" + + "FROM\n" + + " gtb_anag,\n" + + " atb_forn \n" + + "WHERE\n" + + " gtb_anag.cod_anag = atb_forn.cod_anag"); + } + + @Override + public void down() throws Exception { + + } + +}