Context Navigation

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

Last change on this file since 815 was 809, checked in by gav, 14 years ago
Domain change, first draft of TaskProcedureRevisions.
File size: 41.7 KB

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

Note: See TracBrowser for help on using the repository browser.

Download in other formats: