Changeset 203 for trunk/grails-app/services/TaskRecurringScheduleService.groovy

Timestamp:

Nov 30, 2009, 10:28:58 PM (14 years ago)

Author:

gav

Message:

Move task recurring schedule creation to a service.

File:

• trunk/grails-app/services/TaskRecurringScheduleService.groovy (modified) (4 diffs)

trunk/grails-app/services/TaskRecurringScheduleService.groovy

@@ -6 +6 @@
     def taskService
 
+    /**
+    * Generate all enabled recurring tasks.
+    */
     def generateAll() {
 
-        /// @todo: disable recurringSchedule when moving a task to trash.
         def taskRecurringScheduleList = TaskRecurringSchedule.findAllByEnabled(true)
 
@@ -17 +19 @@
                     p.targetStartDate = it.nextTargetStartDate
                     p.targetCompletionDate = it.nextTargetCompletionDate
+                    if(it.task.taskProcedure) p.taskProcedure = it.task.taskProcedure
                     def result = taskService.createSubTask(it.task, p)
                     if( !result.error ) {
@@ -26 +29 @@
                     }
                     else {
-                        log.error result
+                        log.error "Sub task generation for recurring schedule ${it.id} failed."
+                        log.error result.taskInstance.errors
                     }
             }
@@ -33 +37 @@
     }
 
+    /**
+    * Creates a new recurring schedule for a task with the given params.
+    * @param params The params to use when creating the new recurring schedule.
+    * @returns A map containing result.error=true (if any error) and result.taskRecurringScheduleInstance and result.taskId.
+    */
+    def create(params) {
+        TaskRecurringSchedule.withTransaction { status ->
+            def result = [:]
+
+            def fail = { Object[] args ->
+                status.setRollbackOnly()
+                if(args.size() == 2) result.taskRecurringScheduleInstance.errors.rejectValue(args[0], args[1])
+                result.error = true
+                return result
+            }
+
+            result.taskRecurringScheduleInstance = new TaskRecurringSchedule(params)
+            result.taskId = result.taskRecurringScheduleInstance.task.id
+
+            if(!result.taskRecurringScheduleInstance.validate())
+                return fail()
+
+            def taskInstance = Task.lock(result.taskId)
+
+            if(!taskInstance)
+                return fail('task', "task.notFound")
+
+            if(taskInstance.taskRecurringSchedule)
+                return fail('task', "tast.taskRecurringSchedule.alreadyExists")
+
+            if(taskInstance.taskStatus.id == 3)
+                return fail('task', "task.operationNotPermittedOnCompleteTask")
+
+            if(taskInstance.trash)
+                return fail('task', "task.operationNotPermittedOnTaskInTrash")
+
+            if(result.taskRecurringScheduleInstance.nextTargetStartDate < dateUtilService.getToday())
+                return fail("nextTargetStartDate", "taskRecurring.nextTargetStartDate.NotInTheFuture")
+
+            taskInstance.taskRecurringSchedule = result.taskRecurringScheduleInstance
+
+            if(!result.taskRecurringScheduleInstance.save() || !taskInstance.save())
+                return fail()
+
+            // All went well if we get to here.
+            return result
+
+        } //end withTransaction
+    } // end create()
+
 } // end of class