@ -64,6 +64,7 @@ import com.liferay.portal.kernel.cache.CacheRegistryUtil;
import com.liferay.portal.kernel.cache.MultiVMPoolUtil ;
import com.liferay.portal.kernel.cache.SingleVMPoolUtil ;
import com.liferay.portal.kernel.dao.jdbc.DataAccess ;
import com.liferay.portal.kernel.dao.orm.QueryUtil ;
import com.liferay.portal.kernel.exception.PortalException ;
import com.liferay.portal.kernel.exception.SystemException ;
import com.liferay.portal.kernel.log.Log ;
@ -164,6 +165,9 @@ public class ManutenzioneDatabase {
ZoneSismicheUtil zone = new ZoneSismicheUtil ( serviceContext ) ;
esitoLog ( esito , zone . aggiornaComuni ( companyId ) ) ;
}
if ( mode . contains ( "!Riduzione!" ) ) {
esitoLog ( esito , riduzione ( companyId , mode . substring ( 11 ) ) ) ;
}
if ( mode . contains ( "!Pulisci!" ) ) {
if ( mode . contains ( "!DocumentLibrary!" ) ) {
esitoLog ( esito , puliziaDocumentLibrary ( companyId ) ) ;
@ -180,9 +184,9 @@ public class ManutenzioneDatabase {
esitoLog ( esito , svuotaIntPraticaDettPratica ( ) ) ;
}
if ( mode . contains ( "!User!" ) ) {
esitoLog ( esito , svuotaUser ( companyId ) ) ;
esito . addAll ( svuotaUser ( companyId ) ) ;
}
esitoLog ( esito , svuotaDatabase ( companyId ) ) ;
esito . addAll ( svuotaDatabase ( companyId ) ) ;
if ( mode . contains ( "!Reset!" ) ) {
ConfigurazioneLocalServiceUtil . storeConfig ( Constants . NUMERO_PROGETTO_KEY_DB , "1" , serviceContext ) ;
}
@ -195,7 +199,30 @@ public class ManutenzioneDatabase {
return esito ;
}
private static List < String > riduzione ( long companyId , String rimaste ) throws SystemException , PortalException {
// !Riduzione!107043,107023,106983,106793,104938,77853
List < String > esito = new ArrayList < > ( ) ;
try {
Connection connection = DataAccess . getUpgradeOptimizedConnection ( ) ;
Statement s = connection . createStatement ( ) ;
String condizione = "numeroprogetto IN ('" + StringUtil . merge ( StringUtil . split ( rimaste , ',' ) , "','" ) + "')" ;
String sql = "DELETE FROM portos_bo_intpratica WHERE NOT " + condizione ;
int i = s . executeUpdate ( sql ) ;
esitoLog ( esito , "Cancellate " + i + " IntPratica" ) ;
sql = "DELETE FROM portos_bo_dettpratica WHERE intpraticaid NOT IN ("
+ "SELECT intpraticaid FROM portos_bo_intpratica WHERE " + condizione + ')' ;
i = s . executeUpdate ( sql ) ;
esitoLog ( esito , "Cancellate " + i + " DettPratica" ) ;
} catch ( SQLException e ) {
e . printStackTrace ( ) ;
}
esito . addAll ( svuotaDatabase ( companyId ) ) ;
return esito ;
}
private static void clearCache ( ) {
try {
SingleVMPoolUtil . clear ( ) ;
MultiVMPoolUtil . clear ( ) ;
@ -209,7 +236,7 @@ public class ManutenzioneDatabase {
List < String > esito = new ArrayList < > ( ) ;
esitoLog ( esito , svuotaDettPratica ( ) ) ;
esitoLog ( esito , svuotaAllegatoManuale ( ) ) ;
esitoLog ( esito , svuotaAssetEntry ( companyId ) ) ;
// esitoLog(esito, svuotaAssetEntry(companyId));
esitoLog ( esito , svuotaAsseverazione ( ) ) ;
esitoLog ( esito , svuotaAvviso ( companyId ) ) ;
esitoLog ( esito , svuotaCollaudo ( ) ) ;
@ -223,28 +250,29 @@ public class ManutenzioneDatabase {
esitoLog ( esito , svuotaFineLavori ( ) ) ;
esitoLog ( esito , svuotaGroup ( companyId ) ) ;
esitoLog ( esito , svuotaHistoryWorkflowAction ( ) ) ;
esitoLog ( esito , svuotaMBDiscussion ( companyId ) ) ;
esitoLog ( esito , svuotaMBMessage ( companyId ) ) ;
esitoLog ( esito , svuotaMBThread ( ) ) ;
// esitoLog(esito, svuotaMBDiscussion(companyId));
// esitoLog(esito, svuotaMBMessage(companyId));
// esitoLog(esito, svuotaMBThread());
esitoLog ( esito , svuotaPagamento ( companyId ) ) ;
esitoLog ( esito , svuotaParereGeologo ( ) ) ;
esitoLog ( esito , svuotaRatingsEntry ( ) ) ;
esitoLog ( esito , svuotaRatingsStats ( companyId ) ) ;
esitoLog ( esito , svuotaResourcePermission ( companyId ) ) ;
// esitoLog(esito, svuotaResourcePermission(companyId));
esitoLog ( esito , svuotaSoggetto ( ) ) ;
esitoLog ( esito , svuotaSorteggio ( ) ) ;
esitoLog ( esito , svuotaStoricoSoggettoPratica ( ) ) ;
esitoLog ( esito , svuotaSyncDLObject ( ) ) ;
esitoLog ( esito , svuotaSystemEvent ( companyId ) ) ;
esitoLog ( esito , svuotaTempistica ( ) ) ;
esito . addAll ( svuotaUser ( companyId ) ) ;
esitoLog ( esito , svuotaWorkflowInstance ( ) ) ;
return esito ;
}
private static List < String > puliziaDocumentLibrary ( long companyId ) {
List < String > esito = new ArrayList < > ( ) ;
Set < String > parentFolderNames = new HashSet < > ( ) ;
try {
long allegatiFolderId = ConfigurazioneLocalServiceUtil . findByC_ChiaveLong ( companyId ,
ConfigurazioneConstants . ATTACHMENT_FOLDER_ID ) ;
@ -254,7 +282,6 @@ public class ManutenzioneDatabase {
List < DLFolder > folders ;
do {
folders = DLFolderLocalServiceUtil . getDLFolders ( start , start + SLICE ) ;
int rimossi = 0 ;
totali + = folders . size ( ) ;
for ( DLFolder folder : folders ) {
DLFolder parent = folder . getParentFolder ( ) ;
@ -279,7 +306,6 @@ public class ManutenzioneDatabase {
_log . info ( "Cancello la cartella " + folder . getName ( ) ) ;
DLAppLocalServiceUtil . deleteFolder ( folder . getFolderId ( ) ) ;
cancellati + + ;
rimossi + + ;
}
} else {
_log . info ( "Mantengo la cartella " + folder . getName ( ) ) ;
@ -294,14 +320,13 @@ public class ManutenzioneDatabase {
_log . info ( "Cancello la cartella " + folder . getName ( ) ) ;
DLAppLocalServiceUtil . deleteFolder ( folder . getFolderId ( ) ) ;
cancellati + + ;
rimossi + + ;
}
} else {
_log . info ( "Non allegato " + folder . getName ( ) + " in " + parent . getName ( ) ) ;
}
}
}
start + = folders . size ( ) - rimossi ;
start + = folders . size ( ) ;
} while ( folders . size ( ) > 0 ) ;
esitoLog ( esito , "Analizzate " + totali + " cartelle, cancellate " + cancellati ) ;
} catch ( PortalException | SystemException e ) {
@ -314,6 +339,7 @@ public class ManutenzioneDatabase {
}
private static List < Long > avvisiFileEntries ( ) throws SystemException {
List < Long > result = new ArrayList < > ( ) ;
int start = 0 ;
List < Avviso > avvisi = null ;
@ -330,13 +356,13 @@ public class ManutenzioneDatabase {
}
private static String puliziaAllegati ( long companyId , long folderId ) throws SystemException , PortalException {
List < Long > avvisiFileEntries = avvisiFileEntries ( ) ;
long repositoryId = DLAppLocalServiceUtil . getFolder ( folderId ) . getRepositoryId ( ) ;
int start = 0 ;
int cancellati = 0 ;
List < FileEntry > fileEntries = null ;
do {
int rimossi = 0 ;
fileEntries = DLAppServiceUtil . getFileEntries ( repositoryId , folderId , start , start + SLICE ) ;
for ( FileEntry fileEntry : fileEntries ) {
String [ ] parti = StringUtil . split ( fileEntry . getTitle ( ) . replaceAll ( "\\.p7m$" , StringPool . BLANK ) , '_' ) ;
@ -366,7 +392,6 @@ public class ManutenzioneDatabase {
if ( ! esiste ( DETTPRATICA_CLASS_NAME , id1 ) ) {
DLAppLocalServiceUtil . deleteFileEntry ( fileEntry . getFileEntryId ( ) ) ;
cancellati + + ;
rimossi + + ;
}
break ;
case "AI_B" :
@ -377,7 +402,6 @@ public class ManutenzioneDatabase {
if ( ! avvisiFileEntries . contains ( fileEntry . getFileEntryId ( ) ) ) {
DLAppLocalServiceUtil . deleteFileEntry ( fileEntry . getFileEntryId ( ) ) ;
cancellati + + ;
rimossi + + ;
}
break ;
default :
@ -389,17 +413,17 @@ public class ManutenzioneDatabase {
_log . info ( "Nome sconosciuto " + fileEntry . getTitle ( ) ) ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( fileEntries . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " File orfani" ;
}
private static String svuotaAllegatoManuale ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < AllegatoManuale > allegatiManuali = null ;
do {
int rimossi = 0 ;
allegatiManuali = AllegatoManualeLocalServiceUtil . getAllegatoManuales ( start , start + SLICE ) ;
for ( AllegatoManuale allegatoManuale : allegatiManuali ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , allegatoManuale . getIntPraticaId ( ) )
@ -408,20 +432,19 @@ public class ManutenzioneDatabase {
deleteFileEntry ( allegatoManuale . getFileEntryId ( ) ) ;
AllegatoManualeLocalServiceUtil . deleteAllegatoManuale ( allegatoManuale ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( allegatiManuali . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " AllegatoManuale" ;
}
private static String svuotaAssetEntry ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < AssetEntry > assetEntries = null ;
do {
int rimossi = 0 ;
assetEntries = AssetEntryLocalServiceUtil . getAssetEntries ( start , start + SLICE ) ;
for ( AssetEntry assetEntry : assetEntries ) {
String className = assetEntry . getClassName ( ) ;
@ -431,20 +454,19 @@ public class ManutenzioneDatabase {
if ( ! esiste ( className , assetEntry . getClassPK ( ) , companyId ) ) {
AssetEntryLocalServiceUtil . deleteAssetEntry ( assetEntry ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( assetEntries . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " AssetEntry" ;
}
private static String svuotaAsseverazione ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < Asseverazione > asseverazioni = null ;
do {
int rimossi = 0 ;
asseverazioni = AsseverazioneLocalServiceUtil . getAsseveraziones ( start , start + SLICE ) ;
for ( Asseverazione asseverazione : asseverazioni ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , asseverazione . getIntPraticaId ( ) )
@ -452,20 +474,19 @@ public class ManutenzioneDatabase {
deleteFileEntry ( asseverazione . getFileEntryId ( ) ) ;
AsseverazioneLocalServiceUtil . deleteAsseverazione ( asseverazione ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( asseverazioni . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Asseverazione" ;
}
private static String svuotaAvviso ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < Avviso > avvisi = null ;
do {
int rimossi = 0 ;
avvisi = AvvisoLocalServiceUtil . getAvvisos ( start , start + SLICE ) ;
for ( Avviso avviso : avvisi ) {
if ( ! esiste ( avviso . getClassName ( ) , avviso . getClassPk ( ) , companyId )
@ -475,117 +496,111 @@ public class ManutenzioneDatabase {
deleteFileEntry ( avviso . getFileEntryIdProtocollo ( ) ) ;
AvvisoLocalServiceUtil . deleteAvviso ( avviso ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( avvisi . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Avviso" ;
}
private static String svuotaCollaudo ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Collaudo > collaudi = null ;
do {
int rimossi = 0 ;
collaudi = CollaudoLocalServiceUtil . getCollaudos ( start , start + SLICE ) ;
for ( Collaudo collaudo : collaudi ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , collaudo . getIntPraticaId ( ) ) ) {
CollaudoLocalServiceUtil . deleteCollaudo ( collaudo ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( collaudi . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Collaudo" ;
}
private static String svuotaContact ( long companyId ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Contact > contacts = null ;
do {
int rimossi = 0 ;
contacts = ContactLocalServiceUtil . getContacts ( start , start + SLICE ) ;
for ( Contact contact : contacts ) {
if ( ! esiste ( contact . getClassName ( ) , contact . getClassPK ( ) , companyId ) ) {
ContactLocalServiceUtil . deleteContact ( contact ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( contacts . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Contact" ;
}
private static String svuotaControlloPratica ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < ControlloPratica > controlliPratiche = null ;
do {
int rimossi = 0 ;
controlliPratiche = ControlloPraticaLocalServiceUtil . getControlloPraticas ( start , start + SLICE ) ;
for ( ControlloPratica controlloPratica : controlliPratiche ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , controlloPratica . getIntPraticaId ( ) )
| | ! esiste ( DETTPRATICA_CLASS_NAME , controlloPratica . getDettPraticaId ( ) ) ) {
ControlloPraticaLocalServiceUtil . deleteControlloPratica ( controlloPratica ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( controlliPratiche . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " ControlloPratica" ;
}
private static String svuotaDelega ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Delega > deleghe = null ;
do {
int rimossi = 0 ;
deleghe = DelegaLocalServiceUtil . getDelegas ( start , start + SLICE ) ;
for ( Delega delega : deleghe ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , delega . getIntPraticaId ( ) )
| | ! esiste ( DETTPRATICA_CLASS_NAME , delega . getDettPraticaId ( ) ) ) {
DelegaLocalServiceUtil . deleteDelega ( delega ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( deleghe . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Delega" ;
}
private static String svuotaDettPratica ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < DettPratica > dettPratiche = null ;
do {
int rimossi = 0 ;
dettPratiche = DettPraticaLocalServiceUtil . getDettPraticas ( start , start + SLICE ) ;
for ( DettPratica dettPratica : dettPratiche ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , dettPratica . getIntPraticaId ( ) ) ) {
DettPraticaLocalServiceUtil . deleteDettPratica ( dettPratica ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( dettPratiche . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " DettPratica" ;
}
private static String svuotaDocAggiuntiva ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < DocAggiuntiva > docAggiuntive = null ;
do {
int rimossi = 0 ;
docAggiuntive = DocAggiuntivaLocalServiceUtil . getDocAggiuntivas ( start , start + SLICE ) ;
for ( DocAggiuntiva docAggiuntiva : docAggiuntive ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , docAggiuntiva . getIntPraticaId ( ) )
@ -593,20 +608,19 @@ public class ManutenzioneDatabase {
deleteFileEntry ( docAggiuntiva . getFileEntryId ( ) ) ;
DocAggiuntivaLocalServiceUtil . deleteDocAggiuntiva ( docAggiuntiva ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( docAggiuntive . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " DocAggiuntiva" ;
}
private static String svuotaDocPratica ( long companyId ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < DocPratica > docPratiche = null ;
do {
int rimossi = 0 ;
docPratiche = DocPraticaLocalServiceUtil . getDocPraticas ( start , start + SLICE ) ;
for ( DocPratica docPratica : docPratiche ) {
if ( ! esiste ( docPratica . getClassName ( ) , docPratica . getClassPk ( ) , companyId )
@ -614,74 +628,71 @@ public class ManutenzioneDatabase {
deleteFileEntry ( docPratica . getDlFileEntryId ( ) ) ;
DocPraticaLocalServiceUtil . deleteDocPratica ( docPratica ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( docPratiche . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " DocPratica" ;
}
private static String svuotaEmail ( long companyId ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Email > emails = null ;
do {
int rimossi = 0 ;
emails = EmailLocalServiceUtil . getEmails ( start , start + SLICE ) ;
for ( Email email : emails ) {
if ( ! esiste ( email . getClassName ( ) , email . getClassPK ( ) , companyId ) ) {
EmailLocalServiceUtil . deleteEmail ( email ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( emails . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Email" ;
}
private static String svuotaEmailAttachment ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < EmailAttachment > emailAttachments = null ;
do {
int rimossi = 0 ;
emailAttachments = EmailAttachmentLocalServiceUtil . getEmailAttachments ( start , start + SLICE ) ;
for ( EmailAttachment emailAttachment : emailAttachments ) {
if ( ! esiste ( EMAIL_CLASS_NAME , emailAttachment . getEmailId ( ) ) ) {
deleteFileEntry ( emailAttachment . getFileEntryId ( ) ) ;
EmailAttachmentLocalServiceUtil . deleteEmailAttachment ( emailAttachment ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( emailAttachments . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " EmailAttachment" ;
}
private static String svuotaFineLavori ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < FineLavori > finiLavori = null ;
do {
int rimossi = 0 ;
finiLavori = FineLavoriLocalServiceUtil . getFineLavoris ( start , start + SLICE ) ;
for ( FineLavori fineLavori : finiLavori ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , fineLavori . getIntPraticaId ( ) ) ) {
FineLavoriLocalServiceUtil . deleteFineLavori ( fineLavori ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( finiLavori . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " FineLavori" ;
}
// Troncare le tabelle è l'unico modo possibile
private static String svuotaIntPraticaDettPratica ( ) {
int i = 0 ;
int d = 0 ;
try {
@ -689,56 +700,56 @@ public class ManutenzioneDatabase {
Statement s = connection . createStatement ( ) ;
i = s . executeUpdate ( "DELETE FROM portos_bo_intpratica" ) ;
d = s . executeUpdate ( "DELETE FROM portos_bo_dettpratica" ) ;
} catch ( SQLException e ) { }
} catch ( SQLException e ) {
e . printStackTrace ( ) ;
}
clearCache ( ) ;
return "Cancellati " + i + " IntPratica, " + d + " DettPratica" ;
}
private static String svuotaGroup ( long companyId ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Group > groups = null ;
do {
int rimossi = 0 ;
groups = GroupLocalServiceUtil . getGroups ( start , start + SLICE ) ;
for ( Group group : groups ) {
if ( ! esiste ( group . getClassName ( ) , group . getClassPK ( ) , companyId ) ) {
GroupLocalServiceUtil . deleteGroup ( group ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( groups . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Group" ;
}
private static String svuotaHistoryWorkflowAction ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < HistoryWorkflowAction > actions = null ;
do {
int rimossi = 0 ;
actions = HistoryWorkflowActionLocalServiceUtil . getHistoryWorkflowActions ( start , start + SLICE ) ;
for ( HistoryWorkflowAction action : actions ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , action . getIntPraticaId ( ) )
| | ! esiste ( DETTPRATICA_CLASS_NAME , action . getDettPraticaId ( ) ) ) {
HistoryWorkflowActionLocalServiceUtil . deleteHistoryWorkflowAction ( action ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( actions . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " HistoryWorkflowAction" ;
}
private static String svuotaMBDiscussion ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < MBDiscussion > mbDiscussions = null ;
do {
int rimossi = 0 ;
mbDiscussions = MBDiscussionLocalServiceUtil . getMBDiscussions ( start , start + SLICE ) ;
for ( MBDiscussion mbDiscussion : mbDiscussions ) {
if ( ! esiste ( mbDiscussion . getClassName ( ) , mbDiscussion . getClassPK ( ) , companyId )
@ -746,20 +757,19 @@ public class ManutenzioneDatabase {
| | ! esiste ( GROUP_CLASS_NAME , mbDiscussion . getGroupId ( ) ) ) {
MBDiscussionLocalServiceUtil . deleteMBDiscussion ( mbDiscussion ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( mbDiscussions . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " MBDiscussion" ;
}
private static String svuotaMBMessage ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < MBMessage > mbMessages = null ;
do {
int rimossi = 0 ;
mbMessages = MBMessageLocalServiceUtil . getMBMessages ( start , start + SLICE ) ;
for ( MBMessage mbMessage : mbMessages ) {
if ( ! esiste ( mbMessage . getClassName ( ) , mbMessage . getClassPK ( ) , companyId )
@ -767,40 +777,38 @@ public class ManutenzioneDatabase {
| | ! esiste ( GROUP_CLASS_NAME , mbMessage . getGroupId ( ) ) ) {
MBMessageLocalServiceUtil . deleteMBMessage ( mbMessage ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( mbMessages . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " MBMessage" ;
}
private static String svuotaMBThread ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < MBThread > mbThreads = null ;
do {
int rimossi = 0 ;
mbThreads = MBThreadLocalServiceUtil . getMBThreads ( start , start + SLICE ) ;
for ( MBThread mbThread : mbThreads ) {
if ( ! esiste ( MBMESSAGE_CLASS_NAME , mbThread . getRootMessageId ( ) )
| | ! esiste ( GROUP_CLASS_NAME , mbThread . getGroupId ( ) ) ) {
MBThreadLocalServiceUtil . deleteMBThread ( mbThread ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( mbThreads . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " MBThread" ;
}
private static String svuotaPagamento ( long companyId ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Pagamento > pagamenti = null ;
do {
int rimossi = 0 ;
pagamenti = PagamentoLocalServiceUtil . getPagamentos ( start , start + SLICE ) ;
for ( Pagamento pagamento : pagamenti ) {
if ( ! esiste ( pagamento . getClassName ( ) , pagamento . getClassPk ( ) , companyId )
@ -808,20 +816,19 @@ public class ManutenzioneDatabase {
deleteFileEntry ( pagamento . getFileEntryId ( ) ) ;
PagamentoLocalServiceUtil . deletePagamento ( pagamento ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( pagamenti . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Pagamento" ;
}
private static String svuotaParereGeologo ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < ParereGeologo > pareriGeologo = null ;
do {
int rimossi = 0 ;
pareriGeologo = ParereGeologoLocalServiceUtil . getParereGeologos ( start , start + SLICE ) ;
for ( ParereGeologo parereGeologo : pareriGeologo ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , parereGeologo . getIntPraticaId ( ) )
@ -829,58 +836,55 @@ public class ManutenzioneDatabase {
deleteFileEntry ( parereGeologo . getFileEntryId ( ) ) ;
ParereGeologoLocalServiceUtil . deleteParereGeologo ( parereGeologo ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( pareriGeologo . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " ParereGeologo" ;
}
private static String svuotaRatingsEntry ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < RatingsEntry > entries = null ;
do {
int rimossi = 0 ;
entries = RatingsEntryLocalServiceUtil . getRatingsEntries ( start , start + SLICE ) ;
for ( RatingsEntry entry : entries ) {
if ( ! esiste ( entry . getClassName ( ) , entry . getClassPK ( ) ) ) {
RatingsEntryLocalServiceUtil . deleteRatingsEntry ( entry ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( entries . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " RatingsEntry" ;
}
private static String svuotaRatingsStats ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < RatingsStats > ratingsStatses = null ;
do {
int rimossi = 0 ;
ratingsStatses = RatingsStatsLocalServiceUtil . getRatingsStatses ( start , start + SLICE ) ;
for ( RatingsStats ratingsStats : ratingsStatses ) {
if ( ! esiste ( ratingsStats . getClassName ( ) , ratingsStats . getClassPK ( ) , companyId ) ) {
RatingsStatsLocalServiceUtil . deleteRatingsStats ( ratingsStats ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( ratingsStatses . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " RatingsStats" ;
}
private static String svuotaResourcePermission ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < ResourcePermission > resourcePermissions = null ;
do {
int rimossi = 0 ;
resourcePermissions = ResourcePermissionLocalServiceUtil . getResourcePermissions ( start , start + SLICE ) ;
for ( ResourcePermission resourcePermission : resourcePermissions ) {
long classPK = 0 ;
@ -896,24 +900,23 @@ public class ManutenzioneDatabase {
if ( ! esiste ( resourcePermission . getName ( ) , classPK ) ) {
ResourcePermissionLocalServiceUtil . deleteResourcePermission ( resourcePermission ) ;
cancellati + + ;
rimossi + + ;
}
break ;
}
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( resourcePermissions . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " ResourcePermission" ;
}
private static String svuotaSoggetto ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
int docPraticaCancellati = 0 ;
List < Soggetto > soggetti = null ;
do {
int rimossi = 0 ;
soggetti = SoggettoLocalServiceUtil . getSoggettos ( start , start + SLICE ) ;
for ( Soggetto soggetto : soggetti ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , soggetto . getIntPraticaId ( ) )
@ -929,79 +932,75 @@ public class ManutenzioneDatabase {
}
SoggettoLocalServiceUtil . deleteSoggetto ( soggetto ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( soggetti . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Soggetto, " + docPraticaCancellati + " DocPratica" ;
}
private static String svuotaSorteggio ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < Sorteggio > sorteggi = null ;
do {
int rimossi = 0 ;
sorteggi = SorteggioLocalServiceUtil . getSorteggios ( start , start + SLICE ) ;
for ( Sorteggio sorteggio : sorteggi ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , sorteggio . getIntPraticaId ( ) )
| | ! esiste ( DETTPRATICA_CLASS_NAME , sorteggio . getDettPraticaId ( ) ) ) {
SorteggioLocalServiceUtil . deleteSorteggio ( sorteggio ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( sorteggi . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Sorteggio" ;
}
private static String svuotaStoricoSoggettoPratica ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < StoricoSoggettoPratica > storicoSoggettiPratiche = null ;
do {
int rimossi = 0 ;
storicoSoggettiPratiche = StoricoSoggettoPraticaLocalServiceUtil . getStoricoSoggettoPraticas ( start , start
+ SLICE ) ;
for ( StoricoSoggettoPratica storicoSoggettoPratica : storicoSoggettiPratiche ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , storicoSoggettoPratica . getIntPraticaId ( ) ) ) {
StoricoSoggettoPraticaLocalServiceUtil . deleteStoricoSoggettoPratica ( storicoSoggettoPratica ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( storicoSoggettiPratiche . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " StoricoSoggettoPratica" ;
}
private static String svuotaSystemEvent ( long companyId ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < SystemEvent > systemEvents = null ;
do {
int rimossi = 0 ;
systemEvents = SystemEventLocalServiceUtil . getSystemEvents ( start , start + SLICE ) ;
for ( SystemEvent systemEvent : systemEvents ) {
if ( ! esiste ( systemEvent . getClassName ( ) , systemEvent . getClassPK ( ) , companyId ) ) {
SystemEventLocalServiceUtil . deleteSystemEvent ( systemEvent ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( systemEvents . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " SystemEvent" ;
}
private static String svuotaSyncDLObject ( ) throws SystemException {
int start = 0 ;
int cancellati = 0 ;
List < SyncDLObject > syncDLObjects = null ;
do {
int rimossi = 0 ;
syncDLObjects = SyncDLObjectLocalServiceUtil . getSyncDLObjects ( start , start + SLICE ) ;
for ( SyncDLObject syncDLObject : syncDLObjects ) {
String className = null ;
@ -1016,58 +1015,72 @@ public class ManutenzioneDatabase {
if ( ! esiste ( className , syncDLObject . getTypePK ( ) ) ) {
SyncDLObjectLocalServiceUtil . deleteSyncDLObject ( syncDLObject ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( syncDLObjects . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " SyncDLObject" ;
}
private static String svuotaTempistica ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < Tempistica > tempistiche = null ;
do {
int rimossi = 0 ;
tempistiche = TempisticaLocalServiceUtil . getTempisticas ( start , start + SLICE ) ;
for ( Tempistica tempistica : tempistiche ) {
if ( ! esiste ( INTPRATICA_CLASS_NAME , tempistica . getIntPraticaId ( ) )
| | ! esiste ( DETTPRATICA_CLASS_NAME , tempistica . getDettPraticaId ( ) ) ) {
TempisticaLocalServiceUtil . deleteTempistica ( tempistica ) ;
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( tempistiche . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " Tempistica" ;
}
private static String svuotaUser ( long companyId ) throws SystemException , PortalException {
private static List < String > svuotaUser ( long companyId ) throws SystemException , PortalException {
List < String > esito = new ArrayList < > ( ) ;
int start = 0 ;
int cancellati = 0 ;
List < User > users = null ;
Role adminRole = RoleLocalServiceUtil . getRole ( companyId , RoleConstants . ADMINISTRATOR ) ;
Set < String > soggetti = new HashSet < > ( ) ;
for ( Soggetto soggetto : SoggettoLocalServiceUtil . getSoggettos ( QueryUtil . ALL_POS , QueryUtil . ALL_POS ) ) {
soggetti . add ( soggetto . getCodiceFiscaleDelegato ( ) . toLowerCase ( ) ) ;
soggetti . add ( soggetto . getCodiceFiscale ( ) . toLowerCase ( ) ) ;
}
for ( IntPratica pratica : IntPraticaLocalServiceUtil . getIntPraticas ( QueryUtil . ALL_POS , QueryUtil . ALL_POS ) ) {
soggetti . add ( pratica . getUserName ( ) . toLowerCase ( ) ) ;
}
do {
int rimossi = 0 ;
users = UserLocalServiceUtil . getUsers ( start , start + SLICE ) ;
for ( User user : users ) {
if ( user . getRoles ( ) . contains ( adminRole ) ) {
_log . info ( "Non cancello utente " + user . getFullName ( ) ) ;
if ( soggetti . contains ( user . getScreenName ( ) . toLowerCase ( ) ) | | user . getRoles ( ) . contains ( adminRole )
| | ( user . getOrganizationIds ( ) . length > 0 ) | | user . getDefaultUser ( ) ) { } else {
try {
UserLocalServiceUtil . deleteUser ( user ) ;
} catch ( Exception e ) {
esitoLog ( esito , "Errore utente " + user . getFullName ( ) + ": " + e . getMessage ( ) ) ;
}
cancellati + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( users . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " User" ;
esitoLog ( esito , "Cancellati " + cancellati + " User" ) ;
return esito ;
}
private static String svuotaWorkflowInstance ( ) throws SystemException , PortalException {
int start = 0 ;
int cancellati = 0 ;
List < WorkflowInstanceLink > links = null ;
do {
int rimossi = 0 ;
links = WorkflowInstanceLinkLocalServiceUtil . getWorkflowInstanceLinks ( start , start + SLICE ) ;
for ( WorkflowInstanceLink link : links ) {
if ( ! esiste ( link . getClassName ( ) , link . getClassPK ( ) ) ) {
@ -1084,19 +1097,20 @@ public class ManutenzioneDatabase {
instance . getWorkflowInstanceId ( ) ) ;
}
cancellati + + ;
rimossi + + ;
}
}
start + = SLICE - rimossi ;
start + = SLICE ;
} while ( links . size ( ) > 0 ) ;
return "Cancellati " + cancellati + " WorkflowInstance" ;
}
private static boolean esiste ( String className , long classPK ) throws SystemException {
return esiste ( className , classPK , 0 ) ;
}
private static boolean esiste ( String className , long classPK , long companyId ) throws SystemException {
if ( 0 ! = classPK & & Validator . isNotNull ( className ) ) {
try {
if ( ALLEGATOMANUALE_CLASS_NAME . equals ( className ) ) {
@ -1193,7 +1207,7 @@ public class ManutenzioneDatabase {
WorkflowInstanceManagerUtil . getWorkflowInstance ( companyId , classPK ) ;
}
} else {
if ( className . contains ( "." ) ) {
if ( className . contains ( StringPool . PERIOD ) ) {
switch ( className ) {
case "com.liferay.portlet.blogs" :
case "com.liferay.portlet.documentlibrary" :
@ -1216,6 +1230,7 @@ public class ManutenzioneDatabase {
}
private static void deleteFileEntry ( long fileEntryId ) throws SystemException {
try {
DLAppLocalServiceUtil . deleteFileEntry ( fileEntryId ) ;
} catch ( PortalException e ) { }
@ -1229,6 +1244,7 @@ public class ManutenzioneDatabase {
}
private static void esitoLog ( List < String > esito , String msg ) {
_log . info ( msg ) ;
esito . add ( msg ) ;
}
Salvatore La Manna