/*
    * To change this template, choose Tools | Templates
    * and open the template in the editor.
    */
   package org.kuali.student.enrollment.class2.courseofferingset.service.impl;
   
   import org.apache.commons.lang.StringUtils;
   import org.apache.log4j.Logger;
   import org.kuali.student.enrollment.class2.courseofferingset.service.facade.RolloverAssist;
  import org.kuali.student.enrollment.courseoffering.dto.CourseOfferingInfo;
  import org.kuali.student.enrollment.courseoffering.service.CourseOfferingService;
  import org.kuali.student.enrollment.courseofferingset.dto.SocRolloverResultInfo;
  import org.kuali.student.enrollment.courseofferingset.dto.SocRolloverResultItemInfo;
  import org.kuali.student.enrollment.courseofferingset.service.CourseOfferingSetService;
  import org.kuali.student.r2.common.dto.AttributeInfo;
  import org.kuali.student.r2.common.dto.ContextInfo;
  import org.kuali.student.r2.common.dto.ValidationResultInfo;
  import org.kuali.student.r2.common.exceptions.AlreadyExistsException;
  import org.kuali.student.r2.common.exceptions.DataValidationErrorException;
  import org.kuali.student.r2.common.exceptions.InvalidParameterException;
  import org.kuali.student.r2.common.exceptions.OperationFailedException;
  import org.kuali.student.r2.common.util.RichTextHelper;
  import org.kuali.student.r2.common.util.constants.CourseOfferingSetServiceConstants;
  import org.kuali.student.r2.core.acal.service.AcademicCalendarService;
  import org.kuali.student.r2.lum.course.service.CourseService;
  
  import java.util.ArrayList;
  import java.util.Date;
  import java.util.List;
  
  /**
   *
   * @author nwright
   */
  public class CourseOfferingRolloverRunner implements Runnable {
  
      final static Logger logger = Logger.getLogger(CourseOfferingRolloverRunner.class);
      private CourseOfferingService coService;
      private CourseOfferingSetService socService;
      private CourseService courseService;
      private AcademicCalendarService acalService;
      private ContextInfo context;
      private SocRolloverResultInfo result;
      private RolloverAssist rolloverAssist;
  
      public RolloverAssist getRolloverAssist() {
          return rolloverAssist;
      }
  
      public void setRolloverAssist(RolloverAssist rolloverAssist) {
          this.rolloverAssist = rolloverAssist;
      }
  
      public CourseOfferingService getCoService() {
          return coService;
      }
  
      public void setCoService(CourseOfferingService coService) {
          this.coService = coService;
      }
  
      public CourseOfferingSetService getSocService() {
          return socService;
      }
  
      public void setSocService(CourseOfferingSetService socService) {
          this.socService = socService;
      }
  
      public CourseService getCourseService() {
          return courseService;
      }
  
      public void setCourseService(CourseService courseService) {
          this.courseService = courseService;
      }
  
      public AcademicCalendarService getAcalService() {
          return acalService;
      }
  
      public void setAcalService(AcademicCalendarService acalService) {
          this.acalService = acalService;
      }
  
      public ContextInfo getContext() {
          return context;
      }
  
      public void setContext(ContextInfo context) {
          this.context = context;
      }
  
      public SocRolloverResultInfo getResult() {
          return result;
      }
  
      public void setResult(SocRolloverResultInfo result) {
          this.result = result;
     }
 
     private void loadOptionKeys() {
         this.skipIfAlreadyExists = getBooleanOption(CourseOfferingSetServiceConstants.SKIP_IF_ALREADY_EXISTS_OPTION_KEY, false);
         this.logSuccesses = getBooleanOption(CourseOfferingSetServiceConstants.LOG_SUCCESSES_OPTION_KEY, false);
         this.progressFrequency = getIntOption(CourseOfferingSetServiceConstants.LOG_FREQUENCY_OPTION_KEY_PREFIX, 10);
         this.haltErrorsMax = getIntOption(CourseOfferingSetServiceConstants.HALT_ERRORS_MAX_OPTION_KEY_PREFIX, -1);
 
     }
     // TODO: implement these options
     private boolean skipIfAlreadyExists = false;
     private boolean logSuccesses = false;
     private int progressFrequency = 100;
     private int haltErrorsMax = -1;
 
     private boolean getBooleanOption(String key, boolean defValue) {
         for (String optionKey : this.result.getOptionKeys()) {
             if (optionKey.equals(key)) {
                 return true;
             }
         }
         // default
         return defValue;
     }
 
     private int getIntOption(String keyPrefix, int defValue) {
         for (String optionKey : this.result.getOptionKeys()) {
             if (optionKey.startsWith(keyPrefix)) {
                 return Integer.parseInt(optionKey);
             }
         }
         // default
         return defValue;
     }
 
     ////
     //// implement the run method
     ////  
     @Override
     public void run() {
         try {
             runInternal();
         } catch (Exception ex) {
             try {
                 this.result = socService.getSocRolloverResult(result.getId(), context);
                 this.result.setStateKey(CourseOfferingSetServiceConstants.ABORTED_RESULT_STATE_KEY);
                 this.result.setDateCompleted(new Date());
                 this.result.setMessage(new RichTextHelper().fromPlain("Got an unexpected exception running rollover:\n"
                         + ex.toString()));
                 this.socService.updateSocRolloverResult(result.getId(), result, context);
             } catch (Exception ex1) {
                 logger.fatal(result, ex);
                 throw new RuntimeException(ex1);
             }
         }
     }
 
     private String _computeDiffInSeconds(Date start, Date end) {
         long diffInMillis = end.getTime() - start.getTime();
         int seconds = (int)(diffInMillis / 1000);  // Convert to seconds
         int fraction = (int)(diffInMillis % 1000);
         String fractionStr = "" + fraction;
         while (fractionStr.length() < 3) {
             fractionStr = "0" + fractionStr;
         }
         return seconds + "." + fractionStr + "s";
     }
 
     private void _removeRolloverAssistIdFromContext(ContextInfo contextInfo) {
         int index = 0;
         for (AttributeInfo attr: contextInfo.getAttributes()) {
             if (attr.getKey().equals(CourseOfferingSetServiceConstants.ROLLOVER_ASSIST_ID_DYNATTR_KEY)) {
                 contextInfo.getAttributes().remove(index);
                 break; // Assume it only shows up once
             }
             index++;
         }
     }
     private void runInternal() throws Exception {
         if (this.context == null) {
             throw new NullPointerException("context not set");
         }
         loadOptionKeys();
         // mark running
         String resultId = result.getId();
         result = this.socService.getSocRolloverResult(resultId, context);
         result.setStateKey(CourseOfferingSetServiceConstants.RUNNING_RESULT_STATE_KEY);
         this.socService.updateSocRolloverResult(result.getId(), result, context);
         // Check if there are any course in the target soc
         if (!skipIfAlreadyExists) {
             List<String> targetCoIds = socService.getCourseOfferingIdsBySoc(this.result.getTargetSocId(), context);
             if (!targetCoIds.isEmpty()) {
                 throw new OperationFailedException(targetCoIds.size() + " course offerings already exist in the target soc");
             }
         }
         // mark the number expected
         List<String> sourceCoIds = socService.getCourseOfferingIdsBySoc(this.result.getSourceSocId(), context);
         result = this.socService.getSocRolloverResult(result.getId(), context);
         result.setItemsProcessed(0);
         result.setItemsExpected(sourceCoIds.size());
         this.socService.updateSocRolloverResult(result.getId(), result, context);
 
         // Start processing
         int sourceCoIdsHandled = 0;
         int aoRolledOver = 0;
         int errors = 0;
         List<SocRolloverResultItemInfo> items = new ArrayList<SocRolloverResultItemInfo>();
         int count = 1;
         Date origStart = new Date();
         //
         String rolloverAssistId = rolloverAssist.getRolloverId();
         AttributeInfo attr = new AttributeInfo();
         attr.setKey(CourseOfferingSetServiceConstants.ROLLOVER_ASSIST_ID_DYNATTR_KEY);
         attr.setValue(rolloverAssistId);
         context.getAttributes().add(attr);
         Date start = origStart;
         for (String sourceCoId : sourceCoIds) {
             // System.out.println("processing: " + sourceCoId);
             try {
                 SocRolloverResultItemInfo item = rolloverOneCourseOfferingReturningItem(sourceCoId);
                 Date end = new Date();
                 String timeInSeconds = _computeDiffInSeconds(start, end);
                 start = end; // Get ready for next one
                 logger.info("(" + count + ") Processing: " + sourceCoId + " (" + timeInSeconds + ")");
 
                 items.add(item);
                 reportProgressIfModulo(items, sourceCoIdsHandled);
                 if (!CourseOfferingSetServiceConstants.SUCCESSFUL_RESULT_ITEM_STATES.contains(item.getStateKey())) {
                     errors++;
                     if (this.haltErrorsMax != -1) {
                         if (errors > this.haltErrorsMax) {
                             throw new OperationFailedException("Too many errors, exceeded the halt threshold: " + errors
                                     + " out of " + sourceCoIdsHandled + " course offerings rolled over");
                         }
                     }
                 }
                 else {
                     String aoCountStr = item.getAttributeValue(CourseOfferingSetServiceConstants.ACTIVITY_OFFERINGS_CREATED_SOC_ITEM_DYNAMIC_ATTRIBUTE);
                     int aoCount = Integer.parseInt(aoCountStr);
                     aoRolledOver += aoCount;
                 }
             } catch (Exception ex) {
                 // log some conetxt for the exception
                 logger.fatal("failed while processing the " + sourceCoIdsHandled + "th course offering " + sourceCoId, ex);
                 throw ex;
             }
             sourceCoIdsHandled++;
             count++;
         }
         Date end = new Date();
         // Compute total rollover time in hours, minutes, and seconds
         String totalTime = _computeTotalTimeString(origStart, end);
 
         logger.info("======= Finished processing rollover ======= (" + totalTime + ")");
         _removeRolloverAssistIdFromContext(context); // KSENROLL-8062
         reportProgress(items, sourceCoIdsHandled - errors);      // Items Processed = Items - Errors
         // mark finished
         result = socService.getSocRolloverResult(result.getId(), context);
         result.setDateCompleted(new Date());
         result.setCourseOfferingsCreated(sourceCoIdsHandled - errors);
         result.setCourseOfferingsSkipped(errors);
         result.setActivityOfferingsCreated(aoRolledOver);
         result.setActivityOfferingsSkipped(0); // For now, we have no "failed" AOs that didn't rollover.
         result.setStateKey(CourseOfferingSetServiceConstants.FINISHED_RESULT_STATE_KEY);
         this.socService.updateSocRolloverResult(result.getId(), result, context);
     }
 
     private String _computeTotalTimeString(Date start, Date end) {
         long diffInMillis = end.getTime() - start.getTime();
         int seconds = (int)(diffInMillis / 1000);  // Convert to seconds
         int fraction = (int)(diffInMillis % 1000);
         String fractionStr = "" + fraction;
         while (fractionStr.length() < 3) {
             fractionStr = "0" + fractionStr;
         }
         int minutes = seconds / 60;
         seconds = seconds % 60;
         int hours = minutes / 60;
         minutes = hours % 60;
         StringBuilder result = new StringBuilder();
         if (hours > 0) {
             result.append(hours);
             result.append("h, ");
         }
         if (hours > 0 || minutes > 0) {
             result.append(minutes);
             result.append("m, ");
         }
         result.append(seconds);
         result.append(".");
         result.append(fractionStr);
         result.append("s");
         String str = result.toString();
         return str;
     }
 
     private void reportProgressIfModulo(List<SocRolloverResultItemInfo> items, int i) throws Exception {
         int modulo = i % progressFrequency;
         if (modulo != 0) {
             return;
         }
         this.reportProgress(items, i);
     }
 
     private void reportProgress(List<SocRolloverResultItemInfo> items, int i) throws Exception {
         this.socService.updateSocRolloverProgress(result.getId(), i, context);
         if (!this.logSuccesses) {
             stripSuccesses(items);
         }
         if (!items.isEmpty()) {
             Integer count = this.socService.createSocRolloverResultItems(result.getId(),
                     CourseOfferingSetServiceConstants.CREATE_RESULT_ITEM_TYPE_KEY,
                     items,
                     context);
         }
         items.clear();
     }
 
     private void stripSuccesses(List<SocRolloverResultItemInfo> items) {
         List<SocRolloverResultItemInfo> list = new ArrayList<SocRolloverResultItemInfo>();
         for (SocRolloverResultItemInfo item : items) {
             if (!CourseOfferingSetServiceConstants.SUCCESSFUL_RESULT_ITEM_STATES.contains(item.getStateKey())) {
                 list.add(item);
             }
         }
         if (items.size() != list.size()) {
             items.clear();
             items.addAll(list);
         }
     }
 
     private SocRolloverResultItemInfo rolloverOneCourseOfferingReturningItem(String sourceCoId) throws Exception {
         String error = null;
         try {
             SocRolloverResultItemInfo item = this.coService.rolloverCourseOffering(sourceCoId,
                     this.result.getTargetTermId(),
                     this.result.getOptionKeys(),
                     context);
             item.setSocRolloverResultId(result.getId());
             return item;
         } catch (AlreadyExistsException ex) {
             error = ex.getMessage();
         } catch (DataValidationErrorException ex) {
             boolean firstTime = true;
 
             // This provides a better error message for display in rollover results page= (KSENROLL-4582)
             //JIRA FIX : KSENROLL-8731 - Replaced StringBuffer with StringBuilder
             StringBuilder errorBuffer = new StringBuilder("Validation error(s): ");
             if (!StringUtils.isBlank(ex.getMessage())){
                 errorBuffer.append(ex.getMessage());
                 firstTime = false;
             }
             for (ValidationResultInfo info: ex.getValidationResults()) {
                 if (firstTime) {
                     firstTime = false;
                 } else {
                     errorBuffer.append(", ");
                 }
                 // Append on multiple error messages
                 errorBuffer.append(info.getElement() + " has bad data: " + info.getInvalidData());
             }
             error = errorBuffer.toString();
         } catch (InvalidParameterException ex) {
             error = ex.getMessage();
         } catch (Exception ex) {
             // This is a catchall for unknown exceptions, possibly due to bad data.  The previous exceptions are considered
             // expected exceptions.  By catching Exception, the rollover won't stop and will continue to process.
             error = "Unexpected error rolling over course";
             String mesg = ex.getMessage();
             if (mesg != null) {
                 error += ": (" + mesg + ")";
             }
             logger.warn("Unexpected error rolling over course", ex);
         }
         // got an error so process it
         SocRolloverResultItemInfo item = new SocRolloverResultItemInfo();
         item.setSocRolloverResultId(result.getId());
         item.setSourceCourseOfferingId(sourceCoId);
         item.setTypeKey(CourseOfferingSetServiceConstants.CREATE_RESULT_ITEM_TYPE_KEY);
         item.setStateKey(CourseOfferingSetServiceConstants.ERROR_RESULT_ITEM_STATE_KEY);
         item.setTargetCourseOfferingId(null);
         item.setMessage(new RichTextHelper().fromPlain(error));
         return item;
     }
 }