Author: echatellier Date: 2014-09-18 16:39:45 +0200 (Thu, 18 Sep 2014) New Revision: 632 Url: http://forge.codelutin.com/projects/faxtomail/repository/revisions/632 Log: Add usefull log Modified: trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/ClientServiceImpl.java trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/EmailServiceImpl.java Modified: trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/ClientServiceImpl.java =================================================================== --- trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/ClientServiceImpl.java 2014-09-18 14:23:20 UTC (rev 631) +++ trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/ClientServiceImpl.java 2014-09-18 14:39:45 UTC (rev 632) @@ -133,6 +133,8 @@ @Override public void execute(Connection connection) throws SQLException { + int importedCount = 0; + // attention, le sql à pour cible postgresql, mssql, h2, il doit rester simple String query = String.format("SELECT %s, %s, %s, %s, %s, %s, %s, %s, %s, %s FROM %s", NewClient.PROPERTY_NAME, @@ -247,12 +249,18 @@ client.setFaxNumbers(faxNumbers); client = clientDao.update(client); } + + importedCount++; } // delete all rows stat = connection.createStatement(); stat.execute("DELETE FROM " + NewClient.class.getSimpleName()); + // usefull log info (do not remove) + if (importedCount > 0 && log.isInfoEnabled()) { + log.info(String.format("Imported %d new client rows", importedCount)); + } } }); Modified: trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/EmailServiceImpl.java =================================================================== --- trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/EmailServiceImpl.java 2014-09-18 14:23:20 UTC (rev 631) +++ trunk/faxtomail-service/src/main/java/com/franciaflex/faxtomail/services/service/EmailServiceImpl.java 2014-09-18 14:39:45 UTC (rev 632) @@ -1231,6 +1231,8 @@ @Override public void execute(Connection connection) throws SQLException { + int importedCount = 0; + // attention, le sql à pour cible postgresql, mssql, h2, il doit rester simple String query = String.format("SELECT %s, %s, %s FROM %s", EdiReturn.PROPERTY_RANGE_ROW_TOPIA_ID, @@ -1273,11 +1275,18 @@ email.setDemandStatus(DemandStatus.IN_PROGRESS); emailsToUpdate.add(email); + + importedCount++; } // delete all rows stat = connection.createStatement(); stat.execute("DELETE FROM " + EdiReturn.class.getSimpleName()); + + // usefull log info (do not remove) + if (importedCount > 0 && log.isInfoEnabled()) { + log.info(String.format("Imported %d ediReturn rows", importedCount)); + } } });