Changeset 775 for branches/features/taskProcedureRework/grails-app/services

Timestamp:

Feb 3, 2011, 5:12:40 AM (14 years ago)

Author:

gav

Message:

Add optimistic locking checks and transactional save for TaskProcedure.

File:

• branches/features/taskProcedureRework/grails-app/services/TaskProcedureService.groovy (modified) (3 diffs)

branches/features/taskProcedureRework/grails-app/services/TaskProcedureService.groovy

@@ -22 +22 @@
                     result.taskProcedureInstance.errors.rejectValue(m.field, m.code)
                 result.error = [ code: m.code, args: ["TaskProcedure", params.id] ]
+                // Fetch to prevent lazy initialization error.
+                result.taskProcedureInstance?.linkedTask.primaryAsset
+                result.taskProcedureInstance?.createdBy
                 return result
             }
@@ -63 +66 @@
                 // Populate maintenanceAction errors for display.
                 result.taskProcedureInstance.maintenanceActions.each { it.validate() }
-                // Fetch to prevent lazy initialization error.
-                result.taskProcedureInstance.linkedTask.primaryAsset
-                result.taskProcedureInstance.createdBy
                 return fail(code:"default.update.failure")
             }
@@ -75 +75 @@
     }  // end update()
 
+    /**
+    * Creates a new taskProcedure with the given params.
+    * @param params The params to use when creating the new taskProcedure.
+    * @returns A map containing result.error (if any error) and result.taskProcedure.
+    */
+    def save(params) {
+        def result = [:]
+        TaskProcedure.withTransaction { status ->
+            def fail = { Map m ->
+                status.setRollbackOnly()
+                if(result.taskProcedureInstance && m.field) 
+                    result.taskProcedureInstance.errors.rejectValue(m.field, m.code)
+                result.error = [ code: m.code, args: ["TaskProcedure", params.id] ]
+                // Fetch to prevent lazy initialization error.
+                result.taskProcedureInstance.linkedTask.primaryAsset
+                return result
+            }
+
+            result.taskProcedureInstance = new TaskProcedure(params)
+
+            // Optimistic locking check on linkedTask.
+            if(result.taskProcedureInstance.linkedTask.taskProcedure)
+                    return fail(field:"version", code:"default.optimistic.locking.failure")
+
+            result.taskProcedureInstance.createdBy = authService.currentUser
+            result.taskProcedureInstance.lastUpdatedBy = authService.currentUser
+
+            // Gaps in the html index's can be created by adding 2 items and removing the first one.
+            // This creates a gap at the missing index where LazyList will return a null.
+            def nullMaintenanceActions = result.taskProcedureInstance.maintenanceActions.findAll {!it}
+            if (nullMaintenanceActions) {
+                result.taskProcedureInstance.maintenanceActions.removeAll(nullMaintenanceActions)
+            }
+
+            // Also sets: taskInstance.taskProcedure = taskProcedureInstance
+            result.taskProcedureInstance.addToTasks(result.taskProcedureInstance.linkedTask)
+
+            if(result.taskProcedureInstance.hasErrors() || !result.taskProcedureInstance.save()) {
+                // Populate maintenanceAction errors for display.
+                result.taskProcedureInstance.maintenanceActions.each { it.validate() }
+                return fail(code:"default.create.failure")
+            }
+
+        } //end withTransaction
+
+        result.taskProcedureInstance.lastUpdated = new Date() // Required to trigger version increment to 1.
+
+        // success
+        return result
+    }  // end save()
+
 } // end class