Changeset 8119


Ignore:
Timestamp:
29/02/12 09:45:43 (8 years ago)
Author:
mnagni
Message:

minimal formatting refactoring

Location:
mauRepo/revitalizationProject/branches/MEDIN/dpws/src/main/java/ndg/services/revitalization/ejb
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • mauRepo/revitalizationProject/branches/MEDIN/dpws/src/main/java/ndg/services/revitalization/ejb/HarvestThenIngestTimerService.java

    r8033 r8119  
    9191        public void handleTimeout(Timer timer) { 
    9292 
    93                 if (!TimerInfo.class.isAssignableFrom(timer.getInfo().getClass())) 
     93                if (!TimerInfo.class.isAssignableFrom(timer.getInfo().getClass())) { 
    9494                        return; 
     95                } 
     96                         
    9597 
    9698                final TimerInfo infoCache = (TimerInfo) timer.getInfo(); 
    9799                 
    98                 if (infoCache.getId() == null) 
     100                if (infoCache.getId() == null) { 
    99101                        return; 
     102                } 
     103                         
    100104                 
    101105                TimerInfo infoDB = getTimerInfo(infoCache.getId()); 
    102106                 
    103                 if (infoDB == null) 
     107                if (infoDB == null) { 
    104108                        return; 
     109                } 
     110                         
    105111                                 
    106112                //update the cached timer with the DB value 
     
    111117                        if (hiProcess != null && !hiProcess.getHiStatus().getId().equals("end_ingest")  
    112118                                        && !hiProcess.getHiStatus().getId().equals("failed_ingest") 
    113                                         && !hiProcess.getHiStatus().getId().equals("failed_harv")) 
     119                                        && !hiProcess.getHiStatus().getId().equals("failed_harv")) { 
    114120                                return; 
     121                        } 
     122                                 
    115123                } 
    116124         
     
    140148        @Override 
    141149        public Timer startTimer(TimerInfo info) throws TimerCreationException {          
    142                 if (info == null) 
     150                if (info == null) { 
    143151                        throw new TimerCreationException(); 
    144                  
    145                 if (Double.isNaN(info.getCommonId())) 
     152                } 
     153                         
     154                 
     155                if (Double.isNaN(info.getCommonId())) { 
    146156                        throw new TimerCreationException("The Provider ID cannot be null. "); 
    147                  
    148                 if (info.getStartDate() == null) 
     157                } 
     158                         
     159                 
     160                if (info.getStartDate() == null) { 
    149161                        throw new TimerCreationException("The StartDate cannot be null. "); 
    150                  
    151                 if (getTimerInfo(info.getCommonId()) != null) 
     162                } 
     163                         
     164                 
     165                if (getTimerInfo(info.getCommonId()) != null) { 
    152166                        throw new TimerCreationException("The given Provider ID already has an associated timer. "); 
     167                } 
     168                         
    153169                 
    154170                synchronized (timers) { 
     
    173189        public void cancelTimer(TimerInfo info) {                
    174190                //getTimer(info).cancel(); 
    175                 if (info.getLastReqId() == null) 
     191                if (info.getLastReqId() == null) { 
    176192                        return; 
     193                } 
     194                         
    177195                int index = monitors.indexOf(new HarvestProcessMonitoring(info.getLastReqId())); 
    178                 if (index < 0)  
    179                         return;          
     196                if (index < 0) { 
     197                        return; 
     198                }  
     199                                         
    180200                monitors.get(index).terminate(); 
    181201                monitors.remove(index); 
     
    228248        public TimerInfoLog deleteTimer(int timerID) { 
    229249                        TimerInfo oldTimer = getTimerInfo(timerID); 
    230                         if (oldTimer == null) 
     250                        if (oldTimer == null) { 
    231251                                return null; 
     252                        } 
     253                                 
    232254                         
    233255                        TimerInfoLog infoLog = new TimerInfoLog(oldTimer); 
     
    358380                @Override 
    359381                public boolean equals(Object obj) { 
    360                         if (this == obj) 
     382                        if (this == obj) { 
    361383                                return true; 
    362                         if (obj == null) 
     384                        } 
     385                                 
     386                        if (obj == null) { 
    363387                                return false; 
    364                         if (getClass() != obj.getClass()) 
     388                        } 
     389                                 
     390                        if (getClass() != obj.getClass()) { 
    365391                                return false; 
     392                        } 
     393                                 
    366394                        HarvestProcessMonitoring other = (HarvestProcessMonitoring) obj; 
    367                         if (!getOuterType().equals(other.getOuterType())) 
     395                        if (!getOuterType().equals(other.getOuterType())) { 
    368396                                return false; 
    369                         if (processID != other.processID) 
     397                        } 
     398                                 
     399                        if (processID != other.processID) { 
    370400                                return false; 
     401                        } 
     402                                 
    371403                        return true; 
    372404                } 
  • mauRepo/revitalizationProject/branches/MEDIN/dpws/src/main/java/ndg/services/revitalization/ejb/ModelManager.java

    r8033 r8119  
    192192                        Object[] resultElement = (Object[]) iter.next(); 
    193193                        tempLogs = new ProviderLogs<T>((Integer) resultElement[1]); 
    194                         if (tempLogs.getProviderID() == null) 
     194                        if (tempLogs.getProviderID() == null) { 
    195195                                continue; 
     196                        }                                
    196197                        int index = ret.indexOf(tempLogs); 
    197198                        if (index > -1) { 
     
    223224                        // set the process's status to run_harvest 
    224225                        hiProcess = processModel.advanceStatus(hiProcess); 
    225                         if (harvestLog == null) 
     226                        if (harvestLog == null) { 
    226227                                return hiProcess; 
     228                        }                                
    227229                         
    228230                        HarvestLog existingLog = em.find(HarvestLog.class, harvestLog.getReqId()); 
     
    444446                        ProviderCommon provider = null; 
    445447                        for (Integer id : commonIDs) { 
    446                                 if (id == null) 
     448                                if (id == null) { 
    447449                                        throw new NdgExecutionException("The parameter ProviderId is not a parsable number  "); 
    448                                         //throw new NdgExecutionException(new NdgMessage("string.not.number", new Object[]{"ProviderID"})); 
     450                                }                                        
    449451                                provider = getHarvesterConfiguration(id); 
    450                                 if (provider != null) 
     452                                if (provider != null) { 
    451453                                        ret.add(provider); 
     454                                }                                        
    452455                        } 
    453456                        return ret; 
     
    483486        public void deleteProvider(List<Integer> providerID) throws NdgExecutionException { 
    484487                for (Integer id : providerID){ 
    485                         if (id == null) 
     488                        if (id == null) { 
    486489                                throw new NdgExecutionException("The parameter ProviderId is not a parsable number  "); 
     490                        }                                
    487491                        ProviderCommon provider = getProviderCommon(id); 
    488492                        em.remove(provider);     
     
    507511 
    508512                String sqlString = GET_PROVIDER_STATISTIC; 
    509                 if (providerID == null || providerID.size() == 0) 
     513                if (providerID == null || providerID.size() == 0) { 
    510514                        sqlString = GET_ALL_PROVIDER_STATISTIC; 
    511                  
     515                } 
    512516                Query query = emDiscovery.createNativeQuery(sqlString); 
    513517 
  • mauRepo/revitalizationProject/branches/MEDIN/dpws/src/main/java/ndg/services/revitalization/ejb/discovery/CommonMethods.java

    r8118 r8119  
    4949                                        throw new AssembleQueryException(e); 
    5050                                } 
    51                                 if (listNamesItem == null) 
     51                                if (listNamesItem == null) { 
    5252                                        continue; 
     53                                } 
     54                                         
    5355 
    5456                                /* -- Append the field to the ORDER BY command -- */ 
     
    8991                        sb.append(", "); 
    9092                } else { 
    91                         if (sb.length() > 0) 
     93                        if (sb.length() > 0) { 
    9294                                sb.append(", "); 
     95                        }                                
    9396                } 
    9497        } 
     
    106109                        sb.append(" AND "); 
    107110                } else { 
    108                         if (sb.length() > 0) 
     111                        if (sb.length() > 0) { 
    109112                                sb.append(" AND "); 
     113                        }                                
    110114                } 
    111115        } 
     
    116120 
    117121                /* -- Append the WHERE clause to the FROM command -- */ 
    118                 if (whereSQL.length() > 0) 
     122                if (whereSQL.length() > 0) { 
    119123                        selectSQL.append(" WHERE "); 
     124                } 
     125                         
    120126                selectSQL.append(whereSQL); 
    121127 
     
    185191                        if (conn != null) 
    186192                                try { 
    187                                         if (!conn.isClosed()) 
     193                                        if (!conn.isClosed()) { 
    188194                                                conn.close(); 
     195                                        }                                                
    189196                                } catch (SQLException e) { 
    190197                                        logger.error("closeConnectionError: ", e); 
     
    195202        private void closeStatement(Statement stat, ResultSet rs) { 
    196203                try { 
    197                         if (rs != null) 
     204                        if (rs != null) { 
    198205                                rs.close(); 
     206                        }                                
    199207                } catch (Exception e) { 
    200208                        logger.error("closeResultsetError: ", e); 
    201209                } 
    202210                try { 
    203                         if (stat != null) 
    204                                 stat.close(); 
     211                        if (stat != null) { 
     212                                stat.close();    
     213                        } 
    205214                } catch (Exception e) { 
    206215                        logger.error("closeStatementError: ", e);                        
  • mauRepo/revitalizationProject/branches/MEDIN/dpws/src/main/java/ndg/services/revitalization/ejb/discovery/PresentHelper.java

    r8118 r8119  
    7777                        while (true) { 
    7878                                try { 
    79                                         if (!rs.next()) 
    80                                                 break; 
     79                                        if (!rs.next()) { 
     80                                                break;   
     81                                        }                                                
    8182                                } catch (SQLException e) { 
    8283                                        logHelper.logMessage(rs.toString(), Level.ERROR, e); 
     
    131132                        whereSQL.append(iter.next()); 
    132133                        whereSQL.append("'"); 
    133                         if (iter.hasNext()) 
     134                        if (iter.hasNext()) { 
    134135                                whereSQL.append(", "); 
     136                        }                                
    135137                } 
    136138                whereSQL.append(") "); 
     
    219221                                } 
    220222                } 
    221                 if (columnExist(rs, DiscoveryDictionaryDPWS.FULL_DOCUMENT)) 
     223                if (columnExist(rs, DiscoveryDictionaryDPWS.FULL_DOCUMENT)) { 
    222224                        od.setOriginalDocument(rs.getString(DiscoveryDictionaryDPWS.FULL_DOCUMENT)); 
     225                }                        
    223226                return od; 
    224227        } 
     
    232235        public List<OriginalDocument> doPresent(List<String> documentsId, RetrieveCriteriaType type) 
    233236                        throws NdgSQLException, AssembleQueryException, ResourceNotAvailable { 
    234                 if (documentsId == null || documentsId.size() == 0) 
     237                if (documentsId == null || documentsId.size() == 0) { 
    235238                        return new ArrayList<OriginalDocument>(); 
     239                }                        
    236240                this.documentsId = documentsId; 
    237241                String sqlQuery = assembleSearch(type); 
Note: See TracChangeset for help on using the changeset viewer.