source: trunk/grails-app/services/TaskService.groovy @ 613

Last change on this file since 613 was 601, checked in by gav, 14 years ago

Add default.please.select.text and default.none.select.text messages.
Update Task views and service to use new messages.
File size: 36.3 KB
Line 
1import grails.util.Environment
2
3/**
4* Provides a service class for the Task domain class.
5*
6*/
7class TaskService {
8
9    boolean transactional = false
10
11    def authService
12    def dateUtilService
13    def assignedGroupService
14    def assignedPersonService
15
16    /**
17    * Determines and returns a possible parent list for a task.
18    * @todo Create and use another method that limits the results to say the latest 20 or 100 tasks?
19    * @param taskInstance The task to use when determining the possible parent list.
20    * @returns A list of the possible parents.
21    */
22    def possibleParentList(taskInstance) {
23        def criteria = taskInstance.createCriteria()
24        def possibleParentList = criteria {
25            and {
26                notEqual('trash', true)
27                notEqual('id', taskInstance.id)
28                taskInstance.subTasks.each() { notEqual('id', it.id) }
29                }
30        }
31    }
32
33    /**
34    * Determines and returns a list of possible task types for scheduled tasks.
35    * @returns A list of the possible task types.
36    */
37    def getScheduledTaskTypes() {
38        def criteria = TaskType.createCriteria()
39        def scheduledTaskTypes = criteria {
40            and {
41                eq('isActive', true)
42                gt('id', 2L)
43                }
44        }
45    }
46
47    /**
48    * Determines and returns a list of possible task priorites for Scheduled tasks.
49    * @returns A list of the possible task priorites.
50    */
51    def getScheduledTaskPriorities() {
52        def criteria = TaskPriority.createCriteria()
53        def scheduledTaskPriorities = [:]
54        scheduledTaskPriorities.list = criteria {
55            and {
56                eq('isActive', true)
57                gt('id', 1L)
58                }
59        }
60        scheduledTaskPriorities.default = scheduledTaskPriorities.list.find { it.id == 4L } //  1-Normal.
61        return scheduledTaskPriorities
62    }
63
64    /**
65    * Determines and returns a list of possible task priorites for Unscheduled tasks.
66    * @returns A map containing a list of the possible task priorites and the default priority.
67    */
68    def getUnscheduledTaskPriorities() {
69        def criteria = TaskPriority.createCriteria()
70        def unscheduledTaskPriorities = [:]
71        unscheduledTaskPriorities.list = criteria {
72            and {
73                eq('isActive', true)
74                lt('id', 5L)
75                ne('id', 1L)
76            }
77        }
78        unscheduledTaskPriorities.default = unscheduledTaskPriorities.list.find { it.id == 3L } // 2-High.
79        return unscheduledTaskPriorities
80    }
81
82    /**
83    * Creates a new task with the given params.
84    * @param params The params to use when creating the new task.
85    * @returns A map containing result.error (if any error) and result.taskInstance.
86    */
87    def save(params) {
88        Task.withTransaction { status ->
89            def result = [:]
90
91            def fail = { Map m ->
92                status.setRollbackOnly()
93                if(result.taskInstance && m.field)
94                    result.taskInstance.errors.rejectValue(m.field, m.code)
95                result.error = [ code: m.code, args: ["Task", params.id] ]
96                return result
97            }
98
99            def taskInstance = new Task(params)
100            result.taskInstance = taskInstance
101
102            // Set taskStatus if not supplied.
103            if(!params.taskStatus)
104                taskInstance.taskStatus = TaskStatus.read(1) // Not Started
105
106            // Set budgetStatus if not supplied.
107            if(!params.taskBudgetStatus) {
108                if(taskInstance.taskType?.id == 1 || taskInstance.taskType?.id == 2) // Immediate Callout or Unsheduled Breakin.
109                    taskInstance.taskBudgetStatus = TaskBudgetStatus.read(1) // Unplanned.
110                else
111                    taskInstance.taskBudgetStatus = TaskBudgetStatus.read(2) // Planned.
112            }
113
114            if(result.taskInstance.parentTask?.trash)
115                return fail(field:"parentTask", code:"task.operationNotPermittedOnTaskInTrash")
116
117            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
118                return fail(code:"default.create.failure")
119
120            def taskModification = new TaskModification(person: authService.currentUser,
121                                                taskModificationType: TaskModificationType.get(1),
122                                                task: taskInstance)
123
124            if(taskModification.hasErrors() || !taskModification.save())
125                return fail(field:"taskModifications", code:"task.modifications.failedToSave")
126
127            //Add the assignedGroups, provided by a new ArrayList(task.assignedGroups)
128            if(params.assignedGroups) {
129                def assignedGroupsResult
130                def assignedGroupParams = [:]
131                params.assignedGroups.each() {
132
133                    assignedGroupParams = [personGroup: it.personGroup,
134                                                                task: taskInstance,
135                                                                estimatedHour: it.estimatedHour,
136                                                                estimatedMinute: it.estimatedMinute]
137
138                    assignedGroupsResult = assignedGroupService.save(assignedGroupParams)
139
140                    if(assignedGroupsResult.error)
141                        return fail(field:"assignedGroups", code:"task.assignedGroups.failedToSave")
142
143                }
144            }
145
146            //Add the assignedPersons, provided by a new ArrayList(task.assignedPersons)
147            if(params.assignedPersons) {
148                def assignedPersonsResult
149                def assignedPersonsParams = [:]
150                params.assignedPersons.each() {
151
152                    assignedPersonsParams = [person: it.person,
153                                                                task: taskInstance,
154                                                                estimatedHour: it.estimatedHour,
155                                                                estimatedMinute: it.estimatedMinute]
156
157                    assignedPersonsResult = assignedPersonService.save(assignedPersonsParams)
158
159                    if(assignedPersonsResult.error)
160                        return fail(field:"assignedPersons", code:"task.assignedPersons.failedToSave")
161
162                }
163            }
164
165            // Success.
166            return result
167
168        } //end withTransaction
169    } // end save()
170
171    /**
172    * Creates a subTask copying sane attributes from the parentTask unless otherwise specified in params.
173    * The targetStartDate and targetCompletionDate default to today since that is the sane thing to do.
174    * The taskProcedure is only assigned to the sub task if supplied in params.
175    * The assignedPersons and assignedGroups are only added to the sub task if supplied in params.
176    * The positiveFault property is never set on the subTask.
177    * Collections in params must be supplied as new ArrayList's.
178    * This method is not intended to be a copyTask method.
179    * There should be no reason to copy tasks, recurrence can be used to create similar tasks.
180    * @param parentTask The parent task to get attributes from, also set as the parent.
181    * @param params Overrides the parent task values if specified.
182    * @returns A map containing result.error=true (if any error) and result.taskInstance.
183    */
184    def createSubTask(parentTask, params = [:]) {
185
186        def result = [:]
187
188        //Make our new Task a subTask and set the required properties.
189        def p = [:]
190        p.parentTask = parentTask
191        p.description = params.description ?: parentTask.description
192        p.comment = params.comment ?: parentTask.comment
193        p.targetStartDate = params.targetStartDate ?: dateUtilService.today
194        p.targetCompletionDate = params.targetCompletionDate ?: dateUtilService.today
195
196        p.safetyRequirement = params.safetyRequirement ?: parentTask.safetyRequirement
197        p.mandatoryRegulatory = params.mandatoryRegulatory ?: parentTask.mandatoryRegulatory
198
199        p.taskGroup = params.taskGroup ?: parentTask.taskGroup
200        p.taskStatus = TaskStatus.get(1) // A new subTask must always be "Not Started".
201        p.taskPriority = parentTask.taskPriority
202        p.taskType = params.taskType ?: parentTask.taskType
203        p.leadPerson = params.leadPerson ?: parentTask.leadPerson
204        p.primaryAsset = params.primaryAsset ?: parentTask.primaryAsset
205        p.associatedAssets = params.associatedAssets ?: new ArrayList(parentTask.associatedAssets) // Collection.
206
207        // Supplied by recurring tasks.
208        if(params.taskProcedure) p.taskProcedure = params.taskProcedure
209        if(params.assignedGroups) p.assignedGroups = params.assignedGroups // Collection.
210        if(params.assignedPersons) p.assignedPersons = params.assignedPersons // Collection.
211
212        // trash: A new subTask must always have trash=false, which is already the domain class default.
213
214        // These would be considered copying, hence not done.
215        // taskRecurringSchedule, entries, taskModifications, subTasks, inventoryMovements.
216
217        // Create the sub task and return the result.
218        result = save(p)
219
220        // Approve.
221        if(!result.error && parentTask.approved) {
222            p = [:]
223            p.id = result.taskInstance.id
224            approve(p)
225        }
226
227        // Success.
228        return result
229
230    } // end createSubTask()
231
232    /**
233    * In production tasks are NEVER deleted, only the trash flag is set!
234    * However during testing it may be required to delete a task and that
235    * is why this method exists.
236    */
237    def delete(params) {
238        Task.withTransaction { status ->
239            def result = [:]
240
241            def fail = { Map m ->
242                status.setRollbackOnly()
243                if(result.taskInstance && m.field)
244                    result.taskInstance.errors.rejectValue(m.field, m.code)
245                result.error = [ code: m.code, args: ["Task", params.id] ]
246                return result
247            }
248
249            if(Environment.current == Environment.PRODUCTION)
250                return fail(code:"task.delete.failure.production")
251
252            result.taskInstance = Task.get(params.id)
253
254            if(!result.taskInstance)
255                return fail(code:"default.not.found")
256
257            // Handle taskModifications.
258            def taskModifications = TaskModification.findAllByTask(result.taskInstance)
259            taskModifications.each() {
260                result.taskInstance.removeFromTaskModifications(it)
261                it.delete()
262            }
263
264            // Handle assignedPersons.
265            def taskAssignedPersons = AssignedPerson.findAllByTask(result.taskInstance)
266            taskAssignedPersons.each() {
267                result.taskInstance.removeFromAssignedPersons(it)
268                it.delete()
269            }
270
271            // Handle assignedGroups.
272            def taskAssignedGroups = AssignedGroup.findAllByTask(result.taskInstance)
273            taskAssignedGroups.each() {
274                result.taskInstance.removeFromAssignedGroups(it)
275                it.delete()
276            }
277
278            if(result.error)
279                return result
280
281            try {
282                result.taskInstance.delete(flush:true)
283                return result //Success.
284            }
285            catch(org.springframework.dao.DataIntegrityViolationException e) {
286                return fail(code:"default.delete.failure")
287            }
288
289        } // end withTransaction
290    } // delete()
291
292    /**
293    * Creates a new task entry.
294    * @param params The params to use when creating the new entry.
295    * @returns A map containing result.error=true (if any error), result.entryInstance and result.taskId.
296    */
297    def saveEntry(params) {
298        Task.withTransaction { status ->
299            def result = [:]
300
301            def fail = { Map m ->
302                status.setRollbackOnly()
303                if(result.taskInstance && m.field)
304                    result.taskInstance.errors.rejectValue(m.field, m.code)
305                result.error = [ code: m.code, args: ["Entry", params.id] ]
306                return result
307            }
308
309            result.entryInstance = new Entry(params)
310            result.entryInstance.enteredBy = authService.currentUser
311
312            def taskInstance
313            if(result.entryInstance.task?.id) {
314                result.taskId = result.entryInstance.task.id
315                taskInstance = Task.lock(result.entryInstance.task.id)
316            }
317
318            if(!taskInstance)
319                return fail(field:"task", code:"task.notFound")
320
321            if(result.entryInstance.hasErrors() || !result.entryInstance.save())
322                return fail(code:"default.create.failure")
323
324            if(taskInstance.taskStatus.id == 3)
325                return fail(field:"task", code:"task.operationNotPermittedOnCompleteTask")
326
327            // If task status is "Not Started" and entry type is "Work Done" and time has been booked.
328            // Then we create the started modification and set task status.
329            if(taskInstance.taskStatus.id == 1 && result.entryInstance.entryType.id == 3
330                && (result.entryInstance.durationHour + result.entryInstance.durationMinute > 0)) {
331
332                // Create the "Started" task modification, this provides the "Actual Started Date".
333                def taskModification = new TaskModification(person: authService.currentUser,
334                                                        taskModificationType: TaskModificationType.read(2),
335                                                        task: taskInstance)
336
337                if(taskModification.hasErrors() || !taskModification.save())
338                    return fail(field:"task", code:"task.modifications.failedToSave")
339
340                // Set task status to "In Progress".
341                taskInstance.taskStatus = TaskStatus.read(2)
342
343                if(taskInstance.hasErrors() || !taskInstance.save())
344                    return fail(field:"task", code:"task.failedToSave")
345            }
346
347            // Success.
348            return result
349
350        } // end withTransaction
351    } // end saveEntry()
352
353    /**
354    * Updates an existing task.
355    * @param params The params to update for task with id of params.id.
356    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
357    */
358    def update(params) {
359        Task.withTransaction { status ->
360            def result = [:]
361
362            def fail = { Map m ->
363                status.setRollbackOnly()
364                if(result.taskInstance && m.field)
365                    result.taskInstance.errors.rejectValue(m.field, m.code)
366                result.error = [ code: m.code, args: ["Task", params.id] ]
367                return result
368            }
369
370            result.taskInstance = Task.get(params.id)
371
372            if(!result.taskInstance)
373                return fail('id', "task.notFound")
374
375            // Optimistic locking check.
376            if(params.version) {
377                if(result.taskInstance.version > params.version.toLong())
378                    return fail(field:"version", code:"default.optimistic.locking.failure")
379            }
380
381            result.taskInstance.properties = params
382
383            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
384                return fail(code:"default.update.failure")
385
386            def taskModification = new TaskModification(person:authService.currentUser,
387                                                    taskModificationType: TaskModificationType.get(3),
388                                                    task: result.taskInstance)
389
390            if(taskModification.hasErrors() || !taskModification.save())
391                return fail(code:"task.modifications.failedToSave")
392
393            // Success.
394            return result
395
396        } //end withTransaction
397    }  // end update()
398
399    /**
400    * Completes an existing task.
401    * @param params The params for task with id of params.id.
402    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
403    */
404    def complete(params) {
405        Task.withTransaction { status ->
406            def result = [:]
407
408            def fail = { Map m ->
409                status.setRollbackOnly()
410                if(result.taskInstance && m.field)
411                    result.taskInstance.errors.rejectValue(m.field, m.code)
412                result.error = [ code: m.code, args: ["Task", params.id] ]
413                return result
414            }
415
416            result.taskInstance = Task.get(params.id)
417
418            if(!result.taskInstance)
419                return fail(code:"default.not.found")
420
421            // Optimistic locking check.
422            if(params.version) {
423                if(result.taskInstance.version > params.version.toLong())
424                    return fail(field:"version", code:"default.optimistic.locking.failure")
425            }
426
427            result.taskInstance.taskStatus = TaskStatus.get(3)
428            result.taskInstance.attentionFlag = false
429            result.taskInstance.taskRecurringSchedule?.enabled = false
430
431            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
432                return fail(code:"default.update.failure")
433
434            def taskModification = new TaskModification(person:authService.currentUser,
435                                                    taskModificationType: TaskModificationType.get(4),
436                                                    task: result.taskInstance)
437
438
439            if(taskModification.hasErrors() || !taskModification.save())
440                return fail(code:"task.modifications.failedToSave")
441
442            // Success.
443            return result
444
445        } //end withTransaction
446    }  // end complete()
447
448    /**
449    * Sets the attentionFlag on an existing task.
450    * @param params The params for task with id of params.id.
451    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
452    */
453    def setAttentionFlag(params) {
454        Task.withTransaction { status ->
455            def result = [:]
456
457            def fail = { Map m ->
458                status.setRollbackOnly()
459                if(result.taskInstance && m.field)
460                    result.taskInstance.errors.rejectValue(m.field, m.code)
461                result.error = [ code: m.code, args: ["Task", params.id] ]
462                return result
463            }
464
465            result.taskInstance = Task.get(params.id)
466
467            if(!result.taskInstance)
468                return fail(code:"default.not.found")
469
470            // Optimistic locking check.
471            if(params.version) {
472                if(result.taskInstance.version > params.version.toLong())
473                    return fail(field:"version", code:"default.optimistic.locking.failure")
474            }
475
476            result.taskInstance.attentionFlag = true
477
478            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
479                return fail(code:"default.update.failure")
480
481            def taskModification = new TaskModification(person:authService.currentUser,
482                                                    taskModificationType: TaskModificationType.get(12),
483                                                    task: result.taskInstance)
484
485            if(taskModification.hasErrors() || !taskModification.save())
486                return fail(code:"task.modifications.failedToSave")
487
488            // Success.
489            return result
490
491        } //end withTransaction
492    }  // end flag()
493
494    /**
495    * Clears the attentionFlag on an existing task.
496    * @param params The params for task with id of params.id.
497    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
498    */
499    def clearAttentionFlag(params) {
500        Task.withTransaction { status ->
501            def result = [:]
502
503            def fail = { Map m ->
504                status.setRollbackOnly()
505                if(result.taskInstance && m.field)
506                    result.taskInstance.errors.rejectValue(m.field, m.code)
507                result.error = [ code: m.code, args: ["Task", params.id] ]
508                return result
509            }
510
511            result.taskInstance = Task.get(params.id)
512
513            if(!result.taskInstance)
514                return fail(code:"default.not.found")
515
516            // Optimistic locking check.
517            if(params.version) {
518                if(result.taskInstance.version > params.version.toLong())
519                    return fail(field:"version", code:"default.optimistic.locking.failure")
520            }
521
522            result.taskInstance.attentionFlag = false
523
524            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
525                return fail(code:"default.update.failure")
526
527            def taskModification = new TaskModification(person:authService.currentUser,
528                                                    taskModificationType: TaskModificationType.get(13),
529                                                    task: result.taskInstance)
530
531            if(taskModification.hasErrors() || !taskModification.save())
532                return fail(code:"task.modifications.failedToSave")
533
534            // Success.
535            return result
536
537        } //end withTransaction
538    }  // end clearFlag()
539
540    /**
541    * Reopens an existing task.
542    * @param params The params for task with id of params.id.
543    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
544    */
545    def reopen(params) {
546        Task.withTransaction { status ->
547            def result = [:]
548
549            def fail = { Map m ->
550                status.setRollbackOnly()
551                if(result.taskInstance && m.field)
552                    result.taskInstance.errors.rejectValue(m.field, m.code)
553                result.error = [ code: m.code, args: ["Task", params.id] ]
554                return result
555            }
556
557            result.taskInstance = Task.get(params.id)
558
559            if(!result.taskInstance)
560                return fail(code:"default.not.found")
561
562            // Optimistic locking check.
563            if(params.version) {
564                if(result.taskInstance.version > params.version.toLong())
565                    return fail(field:"version", code:"default.optimistic.locking.failure")
566            }
567
568            def isInProgress = false
569            result.taskInstance.entries.each() {
570                if(it.entryType.id == 3 && (it.durationHour + it.durationMinute > 0) )
571                    isInProgress = true
572            }
573
574            if(isInProgress)
575                result.taskInstance.taskStatus = TaskStatus.read(2) // In Progress
576            else
577                result.taskInstance.taskStatus = TaskStatus.read(1) // Not Started
578
579            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
580                return fail(code:"default.update.failure")
581
582            def taskModification = new TaskModification(person:authService.currentUser,
583                                                    taskModificationType: TaskModificationType.get(5),
584                                                    task: result.taskInstance)
585
586            if(taskModification.hasErrors() || !taskModification.save())
587                return fail(code:"task.modifications.failedToSave")
588
589            // Success.
590            return result
591
592        } //end withTransaction
593    }  // end reopen()
594
595    /**
596    * Move a task to the trash.
597    * @param params The params for task with id of params.id.
598    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
599    */
600    def trash(params) {
601        Task.withTransaction { status ->
602            def result = [:]
603
604            def fail = { Map m ->
605                status.setRollbackOnly()
606                if(result.taskInstance && m.field)
607                    result.taskInstance.errors.rejectValue(m.field, m.code)
608                result.error = [ code: m.code, args: ["Task", params.id] ]
609                return result
610            }
611
612            result.taskInstance = Task.get(params.id)
613
614            if(!result.taskInstance)
615                return fail(code:"default.not.found")
616
617            // Optimistic locking check.
618            if(params.version) {
619                if(result.taskInstance.version > params.version.toLong())
620                    return fail(field:"version", code:"default.optimistic.locking.failure")
621            }
622
623            result.taskInstance.trash = true
624            result.taskInstance.attentionFlag = false
625            result.taskInstance.taskRecurringSchedule?.enabled = false
626
627            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
628                return fail(code:"default.update.failure")
629
630            def taskModification = new TaskModification(person:authService.currentUser,
631                                                    taskModificationType: TaskModificationType.get(6),
632                                                    task: result.taskInstance)
633
634            if(taskModification.hasErrors() || !taskModification.save())
635                return fail(code:"task.modifications.failedToSave")
636
637            // Success.
638            return result
639
640        } //end withTransaction
641    }  // end trash()
642
643    /**
644    * Restore a task from the trash.
645    * @param params The params for task with id of params.id.
646    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
647    */
648    def restore(params) {
649        Task.withTransaction { status ->
650            def result = [:]
651
652            def fail = { Map m ->
653                status.setRollbackOnly()
654                if(result.taskInstance && m.field)
655                    result.taskInstance.errors.rejectValue(m.field, m.code)
656                result.error = [ code: m.code, args: ["Task", params.id] ]
657                return result
658            }
659
660            result.taskInstance = Task.get(params.id)
661
662            if(!result.taskInstance)
663                return fail(code:"default.not.found")
664
665            // Optimistic locking check.
666            if(params.version) {
667                if(result.taskInstance.version > params.version.toLong())
668                    return fail(field:"version", code:"default.optimistic.locking.failure")
669            }
670
671            result.taskInstance.trash = false
672
673            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
674                return fail(code:"default.update.failure")
675
676            def taskModification = new TaskModification(person:authService.currentUser,
677                                                    taskModificationType: TaskModificationType.get(7),
678                                                    task: result.taskInstance)
679
680            if(taskModification.hasErrors() || !taskModification.save())
681                return fail(code:"task.modifications.failedToSave")
682
683            // Success.
684            return result
685
686        } //end withTransaction
687    }  // end restore()
688
689    /**
690    * Approve a task.
691    * @param params The params for task with id of params.id.
692    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
693    */
694    def approve(params) {
695        Task.withTransaction { status ->
696            def result = [:]
697
698            def fail = { Map m ->
699                status.setRollbackOnly()
700                if(result.taskInstance && m.field)
701                    result.taskInstance.errors.rejectValue(m.field, m.code)
702                result.error = [ code: m.code, args: ["Task", params.id] ]
703                return result
704            }
705
706            result.taskInstance = Task.get(params.id)
707
708            if(!result.taskInstance)
709                return fail(code:"default.not.found")
710
711            // Optimistic locking check.
712            if(params.version) {
713                if(result.taskInstance.version > params.version.toLong())
714                    return fail(field:"version", code:"default.optimistic.locking.failure")
715            }
716
717            result.taskInstance.approved = true
718
719            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
720                return fail(code:"default.update.failure")
721
722            def taskModification = new TaskModification(person:authService.currentUser,
723                                                    taskModificationType: TaskModificationType.get(8),
724                                                    task: result.taskInstance)
725
726            if(taskModification.hasErrors() || !taskModification.save())
727                return fail(code:"task.modifications.failedToSave")
728
729            // Success.
730            return result
731
732        } //end withTransaction
733    }  // end approve()
734
735    /**
736    * Remove a previously given approval from a task.
737    * @param params The params for task with id of params.id.
738    * @returns A map containing result.error (if any error) and result.taskInstance (if available).
739    */
740    def renegeApproval(params) {
741        Task.withTransaction { status ->
742            def result = [:]
743
744            def fail = { Map m ->
745                status.setRollbackOnly()
746                if(result.taskInstance && m.field)
747                    result.taskInstance.errors.rejectValue(m.field, m.code)
748                result.error = [ code: m.code, args: ["Task", params.id] ]
749                return result
750            }
751
752            result.taskInstance = Task.get(params.id)
753
754            if(!result.taskInstance)
755                return fail(code:"default.not.found")
756
757            // Optimistic locking check.
758            if(params.version) {
759                if(result.taskInstance.version > params.version.toLong())
760                    return fail(field:"version", code:"default.optimistic.locking.failure")
761            }
762
763            result.taskInstance.approved = false
764
765            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
766                return fail(code:"default.update.failure")
767
768            def taskModification = new TaskModification(person:authService.currentUser,
769                                                    taskModificationType: TaskModificationType.get(9),
770                                                    task: result.taskInstance)
771
772            if(taskModification.hasErrors() || !taskModification.save())
773                return fail(code:"task.modifications.failedToSave")
774
775            // Success.
776            return result
777
778        } //end withTransaction
779    }  // end renegeApproval()
780
781    /**
782    * Creates a new unscheduled breakin task with the given params.
783    * @param params The params to use when creating the new task.
784    * @returns A map containing result.error (if any error) and result.taskInstance.
785    */
786    def saveUnscheduled(params) {
787        Task.withTransaction { status ->
788            def result = [:]
789
790            def fail = { Map m ->
791                status.setRollbackOnly()
792                if(result.taskInstance && m.field)
793                    result.taskInstance.errors.rejectValue(m.field, m.code)
794                result.error = [ code: m.code, args: ["Task", params.id] ]
795                return result
796            }
797
798            // If not supplied.
799            if(!params.taskStatus)
800                params.taskStatus = TaskStatus.get(1) // Not Started.
801
802            result.taskInstance = new Task(params)
803
804            // Always for an unscheduled breakin..
805            result.taskInstance.taskType = TaskType.get(2) // Unscheduled Breakin.
806            result.taskInstance.taskBudgetStatus = TaskBudgetStatus.get(1) // Unplanned.
807
808            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
809                fail(code:"default.create.failure")
810
811            if(!result.error) {
812                def taskModification = new TaskModification(person: authService.currentUser,
813                                                                taskModificationType: TaskModificationType.get(1), // Created.
814                                                                task: result.taskInstance)
815
816                if(taskModification.hasErrors() || !taskModification.save())
817                    fail(field:"taskModifications", code:"task.modifications.failedToSave")
818            }
819
820            // Success.
821            return result
822
823        } //end withTransaction
824    } // end saveUnscheduled()
825
826    /**
827    * Creates a new immediate callout task with the given params.
828    * @param params The params to use when creating the new task.
829    * @returns A map containing result.error (if any error) and result.taskInstance.
830    */
831    def saveImmediateCallout(params) {
832        Task.withTransaction { status ->
833            def result = [:]
834
835            def fail = { Map m ->
836                status.setRollbackOnly()
837                if(result.taskInstance && m.field)
838                    result.taskInstance.errors.rejectValue(m.field, m.code)
839                result.error = [ code: m.code, args: ["Task", params.id] ]
840                return result
841            }
842
843            // If not supplied.
844            if(!params.taskStatus)
845                params.taskStatus = TaskStatus.get(1) // Not Started.
846
847            result.taskInstance = new Task(params)
848
849            // Always for an immediate callout.
850            result.taskInstance.taskType = TaskType.get(1) // Immediate Callout.
851            result.taskInstance.taskBudgetStatus = TaskBudgetStatus.get(1) // Unplanned.
852            result.taskInstance.taskPriority = TaskPriority.get(1) // Immediate.
853            result.taskInstance.taskGroup = TaskGroup.get(1) // Engineering Activites.
854            result.taskInstance.approved = true
855            result.taskInstance.leadPerson = authService.currentUser
856            result.taskInstance.targetCompletionDate = result.taskInstance.targetStartDate
857
858            if(result.taskInstance.hasErrors() || !result.taskInstance.save())
859                fail(code:"default.create.failure")
860
861            if(!result.error) {
862                def taskModification = new TaskModification(person: authService.currentUser,
863                                                                taskModificationType: TaskModificationType.get(1), // Created.
864                                                                task: result.taskInstance)
865
866                if(taskModification.hasErrors() || !taskModification.save())
867                    fail(field:"taskModifications", code:"task.modifications.failedToSave")
868            }
869
870            def productionReference
871            if(params.entryFault.productionReference.id.isLong())
872                productionReference = ProductionReference.get(params.entryFault.productionReference.id.toLong())
873
874            def faultParams = [task: result.taskInstance,
875                                            entryType: EntryType.get(1),
876                                            comment: params.entryFault.comment,
877                                            dateDone: result.taskInstance.targetStartDate,
878                                            productionReference: productionReference,
879                                            durationHour: params.entryFault.durationHour,
880                                            durationMinute: params.entryFault.durationMinute]
881            def faultResult = saveEntry(faultParams)
882            result.entryFaultInstance = faultResult.entryInstance
883
884            def causeParams = [task: result.taskInstance,
885                                            entryType: EntryType.get(2),
886                                            dateDone: result.taskInstance.targetStartDate,
887                                            comment: params.entryCause.comment]
888            def causeResult = saveEntry(causeParams)
889            result.entryCauseInstance = causeResult.entryInstance
890
891            def workDoneParams = [task: result.taskInstance,
892                                                    entryType: EntryType.get(3),
893                                                    comment: params.entryWorkDone.comment,
894                                            dateDone: result.taskInstance.targetStartDate,
895                                                    durationHour: params.entryWorkDone.durationHour,
896                                                    durationMinute: params.entryWorkDone.durationMinute]
897            def workDoneResult = saveEntry(workDoneParams)
898            result.entryWorkDoneInstance = workDoneResult.entryInstance
899
900            if(result.error)
901                return result
902
903            if(causeResult.error)
904                return fail(code: "default.create.failure")
905
906            if(faultResult.error)
907                return fail(code: "default.create.failure")
908
909            if(workDoneResult.error)
910                return fail(code: "default.create.failure")
911
912            // Success.
913            return result
914
915        } //end withTransaction
916    } // end saveImmediateCallout()
917
918} // end TaskService
Note: See TracBrowser for help on using the repository browser.