Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public int runAggregation(List<String> terminals) throws SQLException {
- long t0 = System.currentTimeMillis();
- int i = runSubPeriodAggregation(terminals);
- Session session = SessionFactoryController.getInstance().getSessionFactory().openSession();
- ScrollableResults scroll = getTerminals(session, terminals);
- try {
- while (scroll.next()) {
- long t1 = System.currentTimeMillis();
- OBPOSApplications terminal = (OBPOSApplications) scroll.get(0);
- checkLastDayPeriodAggregated(terminal);
- Date selectedPeriod = periodStart;
- Date firstPeriod = getFirstPeriodWithoutAggregation(terminal);
- for (Date period = firstPeriod; period
- .compareTo(selectedPeriod) <= 0; period = periodNext) {
- long t2 = System.currentTimeMillis();
- initPeriod(period);
- aggregatePeriod(terminal);
- OBDal.getInstance().getConnection(false).commit();
- OBDal.getInstance().getSession().clear();
- i++;
- log.debug("Aggregation for period {} took: {} ms.", period,
- System.currentTimeMillis() - t2);
- }
- log.debug("Aggregation for terminal {} took: {} ms.", terminal.getName(),
- System.currentTimeMillis() - t1);
- }
- log.debug("Aggregation took: {} ms.", System.currentTimeMillis() - t0);
- } finally {
- scroll.close();
- if (session.isOpen()) {
- session.close();
- }
- }
- return i;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement