| 1 | |
package org.kuali.student.lum.service.assembler; |
| 2 | |
|
| 3 | |
import java.util.List; |
| 4 | |
|
| 5 | |
import org.apache.log4j.Logger; |
| 6 | |
import org.kuali.student.common.assembly.BaseDTOAssemblyNode; |
| 7 | |
import org.kuali.student.common.assembly.BaseDTOAssemblyNode.NodeOperation; |
| 8 | |
import org.kuali.student.common.assembly.BusinessServiceMethodInvoker; |
| 9 | |
import org.kuali.student.common.assembly.data.AssemblyException; |
| 10 | |
import org.kuali.student.common.exceptions.AlreadyExistsException; |
| 11 | |
import org.kuali.student.common.exceptions.CircularReferenceException; |
| 12 | |
import org.kuali.student.common.exceptions.CircularRelationshipException; |
| 13 | |
import org.kuali.student.common.exceptions.DataValidationErrorException; |
| 14 | |
import org.kuali.student.common.exceptions.DependentObjectsExistException; |
| 15 | |
import org.kuali.student.common.exceptions.DoesNotExistException; |
| 16 | |
import org.kuali.student.common.exceptions.InvalidParameterException; |
| 17 | |
import org.kuali.student.common.exceptions.MissingParameterException; |
| 18 | |
import org.kuali.student.common.exceptions.OperationFailedException; |
| 19 | |
import org.kuali.student.common.exceptions.PermissionDeniedException; |
| 20 | |
import org.kuali.student.common.exceptions.UnsupportedActionException; |
| 21 | |
import org.kuali.student.common.exceptions.VersionMismatchException; |
| 22 | |
import org.kuali.student.core.atp.service.AtpService; |
| 23 | |
import org.kuali.student.core.statement.dto.RefStatementRelationInfo; |
| 24 | |
import org.kuali.student.core.statement.dto.ReqComponentInfo; |
| 25 | |
import org.kuali.student.core.statement.dto.StatementInfo; |
| 26 | |
import org.kuali.student.core.statement.dto.StatementTreeViewInfo; |
| 27 | |
import org.kuali.student.core.statement.service.StatementService; |
| 28 | |
import org.kuali.student.lum.course.service.assembler.LoCategoryRelationInfo; |
| 29 | |
import org.kuali.student.lum.lo.dto.LoInfo; |
| 30 | |
import org.kuali.student.lum.lo.dto.LoLoRelationInfo; |
| 31 | |
import org.kuali.student.lum.lo.service.LearningObjectiveService; |
| 32 | |
import org.kuali.student.lum.lrc.dto.ResultComponentInfo; |
| 33 | |
import org.kuali.student.lum.lrc.service.LrcService; |
| 34 | |
import org.kuali.student.lum.lu.dto.CluCluRelationInfo; |
| 35 | |
import org.kuali.student.lum.lu.dto.CluInfo; |
| 36 | |
import org.kuali.student.lum.lu.dto.CluLoRelationInfo; |
| 37 | |
import org.kuali.student.lum.lu.dto.CluPublicationInfo; |
| 38 | |
import org.kuali.student.lum.lu.dto.CluResultInfo; |
| 39 | |
import org.kuali.student.lum.lu.service.LuService; |
| 40 | |
|
| 41 | 2 | public class LumServiceMethodInvoker implements BusinessServiceMethodInvoker { |
| 42 | 2 | final Logger LOG = Logger.getLogger(LumServiceMethodInvoker.class); |
| 43 | |
private LuService luService; |
| 44 | |
private StatementService statementService; |
| 45 | |
private LearningObjectiveService loService; |
| 46 | |
private AtpService atpService; |
| 47 | |
private LrcService lrcService; |
| 48 | |
|
| 49 | |
@SuppressWarnings("unchecked") |
| 50 | |
public final void invokeServiceCalls(BaseDTOAssemblyNode results) |
| 51 | |
throws AlreadyExistsException, DataValidationErrorException, |
| 52 | |
DoesNotExistException, InvalidParameterException, |
| 53 | |
MissingParameterException, OperationFailedException, |
| 54 | |
PermissionDeniedException, VersionMismatchException, |
| 55 | |
DependentObjectsExistException, CircularRelationshipException, |
| 56 | |
AssemblyException, UnsupportedActionException, UnsupportedOperationException, CircularReferenceException { |
| 57 | |
|
| 58 | |
|
| 59 | 3352 | if(NodeOperation.DELETE == results.getOperation()) { |
| 60 | 130 | for(BaseDTOAssemblyNode childNode: (List<BaseDTOAssemblyNode>) results.getChildNodes()){ |
| 61 | 112 | invokeServiceCalls(childNode); |
| 62 | |
} |
| 63 | |
} |
| 64 | |
|
| 65 | 3352 | invokeServiceCallOnResult(results); |
| 66 | |
|
| 67 | |
|
| 68 | 3351 | if(NodeOperation.DELETE != results.getOperation()) { |
| 69 | 3221 | for(BaseDTOAssemblyNode childNode: (List<BaseDTOAssemblyNode>) results.getChildNodes()){ |
| 70 | 3187 | invokeServiceCalls(childNode); |
| 71 | |
} |
| 72 | |
} |
| 73 | 3351 | } |
| 74 | |
|
| 75 | |
|
| 76 | |
|
| 77 | |
|
| 78 | |
|
| 79 | |
|
| 80 | |
|
| 81 | |
|
| 82 | |
|
| 83 | |
|
| 84 | |
|
| 85 | |
|
| 86 | |
|
| 87 | |
|
| 88 | |
|
| 89 | |
|
| 90 | |
|
| 91 | |
|
| 92 | |
protected void invokeServiceCallOnResult(BaseDTOAssemblyNode results) |
| 93 | |
throws AlreadyExistsException, DataValidationErrorException, |
| 94 | |
DoesNotExistException, InvalidParameterException, |
| 95 | |
MissingParameterException, OperationFailedException, |
| 96 | |
PermissionDeniedException, AssemblyException, |
| 97 | |
VersionMismatchException, DependentObjectsExistException, |
| 98 | |
CircularRelationshipException, UnsupportedActionException, |
| 99 | |
UnsupportedOperationException, CircularReferenceException { |
| 100 | 3352 | Object nodeData = results.getNodeData(); |
| 101 | 3352 | if (nodeData == null) { |
| 102 | 9 | return; |
| 103 | |
} |
| 104 | |
|
| 105 | 3343 | if (LOG.isDebugEnabled()) { |
| 106 | 0 | LOG.debug(results.getOperation() + ": " + nodeData); |
| 107 | |
} |
| 108 | |
|
| 109 | 3343 | if(nodeData instanceof CluInfo){ |
| 110 | 230 | CluInfo clu = (CluInfo) nodeData; |
| 111 | 230 | switch(results.getOperation()){ |
| 112 | |
case CREATE: |
| 113 | 169 | CluInfo newClu = luService.createClu(clu.getType(), clu); |
| 114 | 169 | if(results.getAssembler() != null) { |
| 115 | 169 | results.getAssembler().assemble(newClu, results.getBusinessDTORef(), true); |
| 116 | |
} |
| 117 | |
break; |
| 118 | |
case UPDATE: |
| 119 | 48 | CluInfo updatedClu = luService.updateClu(clu.getId(), clu); |
| 120 | 47 | if(results.getAssembler() != null) { |
| 121 | 47 | results.getAssembler().assemble(updatedClu, results.getBusinessDTORef(), true); |
| 122 | |
} |
| 123 | |
break; |
| 124 | |
case DELETE: |
| 125 | 13 | luService.deleteClu(clu.getId()); |
| 126 | |
break; |
| 127 | |
} |
| 128 | 229 | }else if(nodeData instanceof CluCluRelationInfo){ |
| 129 | 197 | CluCluRelationInfo relation = (CluCluRelationInfo) nodeData; |
| 130 | 197 | switch(results.getOperation()){ |
| 131 | |
case CREATE: |
| 132 | 177 | CluCluRelationInfo newCluRel = luService.createCluCluRelation(relation.getCluId(), relation.getRelatedCluId(), relation.getType(), relation); |
| 133 | |
|
| 134 | 177 | if(null != results.getBusinessDTORef()) { |
| 135 | 0 | results.getAssembler().assemble(newCluRel, results.getBusinessDTORef(), true); |
| 136 | |
} |
| 137 | |
break; |
| 138 | |
case UPDATE: |
| 139 | 1 | CluCluRelationInfo updatedCluRel = luService.updateCluCluRelation(relation.getId(), relation); |
| 140 | |
|
| 141 | 1 | if(null != results.getBusinessDTORef()) { |
| 142 | 0 | results.getAssembler().assemble(updatedCluRel, results.getBusinessDTORef(), true); |
| 143 | |
} |
| 144 | |
break; |
| 145 | |
case DELETE: |
| 146 | 19 | luService.deleteCluCluRelation(relation.getId()); |
| 147 | |
break; |
| 148 | |
} |
| 149 | 197 | }else if(nodeData instanceof CluResultInfo){ |
| 150 | 109 | CluResultInfo cluResult = (CluResultInfo) nodeData; |
| 151 | 109 | switch(results.getOperation()){ |
| 152 | |
case CREATE: |
| 153 | 86 | luService.createCluResult(cluResult.getCluId(), cluResult.getType(), cluResult); |
| 154 | 86 | break; |
| 155 | |
case UPDATE: |
| 156 | 19 | luService.updateCluResult(cluResult.getId(), cluResult); |
| 157 | 19 | break; |
| 158 | |
case DELETE: |
| 159 | 4 | luService.deleteCluResult(cluResult.getId()); |
| 160 | |
break; |
| 161 | |
} |
| 162 | 109 | }else if(nodeData instanceof LoCategoryRelationInfo){ |
| 163 | 1331 | LoCategoryRelationInfo loCategoryRelation = (LoCategoryRelationInfo) nodeData; |
| 164 | 1331 | switch(results.getOperation()){ |
| 165 | |
case CREATE: |
| 166 | 1289 | loService.addLoCategoryToLo(loCategoryRelation.getCategoryId(), loCategoryRelation.getLoId()); |
| 167 | 1289 | break; |
| 168 | |
case UPDATE: |
| 169 | 0 | throw new UnsupportedOperationException("Can't call update on lo category relations, just add and remove"); |
| 170 | |
case DELETE: |
| 171 | 42 | loService.removeLoCategoryFromLo(loCategoryRelation.getCategoryId(), loCategoryRelation.getLoId()); |
| 172 | |
break; |
| 173 | |
} |
| 174 | 1331 | }else if(nodeData instanceof LoInfo){ |
| 175 | 695 | LoInfo lo = (LoInfo) nodeData; |
| 176 | 695 | switch(results.getOperation()){ |
| 177 | |
case CREATE: |
| 178 | 651 | LoInfo createdLo = loService.createLo(lo.getLoRepositoryKey(), lo.getType(), lo); |
| 179 | 651 | if(null != results.getBusinessDTORef()) { |
| 180 | 651 | results.getAssembler().assemble(createdLo, results.getBusinessDTORef(), true); |
| 181 | |
} |
| 182 | |
break; |
| 183 | |
case UPDATE: |
| 184 | 21 | LoInfo updatedLo = loService.updateLo(lo.getId(), lo); |
| 185 | 21 | if(null != results.getBusinessDTORef()) { |
| 186 | 21 | results.getAssembler().assemble(updatedLo, results.getBusinessDTORef(), true); |
| 187 | |
} |
| 188 | |
break; |
| 189 | |
case DELETE: |
| 190 | 23 | loService.deleteLo(lo.getId()); |
| 191 | |
break; |
| 192 | |
} |
| 193 | 695 | }else if(nodeData instanceof LoLoRelationInfo){ |
| 194 | 570 | LoLoRelationInfo loRelation = (LoLoRelationInfo) nodeData; |
| 195 | 570 | switch(results.getOperation()){ |
| 196 | |
case CREATE: |
| 197 | 552 | loService.createLoLoRelation(loRelation.getLoId(), loRelation.getRelatedLoId(), loRelation.getType(), loRelation); |
| 198 | 552 | break; |
| 199 | |
case UPDATE: |
| 200 | 0 | loService.updateLoLoRelation(loRelation.getId(), loRelation); |
| 201 | 0 | break; |
| 202 | |
case DELETE: |
| 203 | 18 | loService.deleteLoLoRelation(loRelation.getId()); |
| 204 | |
break; |
| 205 | |
} |
| 206 | 570 | }else if(nodeData instanceof CluLoRelationInfo){ |
| 207 | 104 | CluLoRelationInfo cluLoRelation = (CluLoRelationInfo) nodeData; |
| 208 | 104 | switch(results.getOperation()){ |
| 209 | |
case CREATE: |
| 210 | 99 | luService.createCluLoRelation(cluLoRelation.getCluId(), cluLoRelation.getLoId(), cluLoRelation.getType(), cluLoRelation); |
| 211 | 99 | break; |
| 212 | |
case UPDATE: |
| 213 | 0 | luService.updateCluLoRelation(cluLoRelation.getLoId(), cluLoRelation); |
| 214 | 0 | break; |
| 215 | |
case DELETE: |
| 216 | 5 | luService.deleteCluLoRelation(cluLoRelation.getId()); |
| 217 | |
break; |
| 218 | |
} |
| 219 | 104 | }else if(nodeData instanceof ResultComponentInfo){ |
| 220 | 4 | ResultComponentInfo resultComponent = (ResultComponentInfo) nodeData; |
| 221 | 4 | switch(results.getOperation()){ |
| 222 | |
case CREATE: |
| 223 | 4 | ResultComponentInfo createdResultComponent = lrcService.createResultComponent(resultComponent.getType(), resultComponent); |
| 224 | |
|
| 225 | 4 | if(results.getBusinessDTORef()!=null&& results.getBusinessDTORef() instanceof ResultComponentInfo){ |
| 226 | 4 | ResultComponentInfo resultComponentToUpdate = (ResultComponentInfo) results.getBusinessDTORef(); |
| 227 | 4 | resultComponentToUpdate.setId(createdResultComponent.getId()); |
| 228 | 4 | resultComponentToUpdate.setType(createdResultComponent.getType()); |
| 229 | 4 | resultComponentToUpdate.setDesc(createdResultComponent.getDesc()); |
| 230 | 4 | resultComponentToUpdate.setEffectiveDate(createdResultComponent.getEffectiveDate()); |
| 231 | 4 | resultComponentToUpdate.setExpirationDate(createdResultComponent.getExpirationDate()); |
| 232 | 4 | resultComponentToUpdate.setMetaInfo(createdResultComponent.getMetaInfo()); |
| 233 | 4 | resultComponentToUpdate.setName(createdResultComponent.getName()); |
| 234 | 4 | resultComponentToUpdate.setResultValues(createdResultComponent.getResultValues()); |
| 235 | 4 | resultComponentToUpdate.setState(createdResultComponent.getState()); |
| 236 | 4 | } |
| 237 | |
break; |
| 238 | |
case UPDATE: |
| 239 | 0 | lrcService.updateResultComponent(resultComponent.getId(), resultComponent); |
| 240 | 0 | break; |
| 241 | |
case DELETE: |
| 242 | 0 | lrcService.deleteResultComponent(resultComponent.getId()); |
| 243 | |
break; |
| 244 | |
} |
| 245 | 4 | } else if(nodeData instanceof RefStatementRelationInfo){ |
| 246 | 9 | RefStatementRelationInfo relation = (RefStatementRelationInfo) nodeData; |
| 247 | 9 | switch(results.getOperation()){ |
| 248 | |
case CREATE: |
| 249 | 6 | RefStatementRelationInfo created = statementService.createRefStatementRelation(relation); |
| 250 | 6 | relation.setMetaInfo(created.getMetaInfo()); |
| 251 | 6 | break; |
| 252 | |
case UPDATE: |
| 253 | 1 | RefStatementRelationInfo updated = statementService.updateRefStatementRelation(relation.getId(), relation); |
| 254 | 1 | relation.setMetaInfo(updated.getMetaInfo()); |
| 255 | 1 | break; |
| 256 | |
case DELETE: |
| 257 | 2 | statementService.deleteRefStatementRelation(relation.getId()); |
| 258 | |
break; |
| 259 | |
} |
| 260 | 9 | } else if(nodeData instanceof StatementInfo){ |
| 261 | 0 | StatementInfo statement = (StatementInfo) nodeData; |
| 262 | 0 | switch(results.getOperation()){ |
| 263 | |
case CREATE: |
| 264 | 0 | StatementInfo created = statementService.createStatement(statement.getType(), statement); |
| 265 | 0 | if(results.getAssembler() != null && results.getBusinessDTORef() != null) { |
| 266 | 0 | results.getAssembler().assemble(created, results.getBusinessDTORef(), true); |
| 267 | |
} |
| 268 | |
break; |
| 269 | |
case UPDATE: |
| 270 | 0 | StatementInfo updated = statementService.updateStatement(statement.getId(), statement); |
| 271 | 0 | if(results.getAssembler() != null && results.getBusinessDTORef() != null) { |
| 272 | 0 | results.getAssembler().assemble(updated, results.getBusinessDTORef(), true); |
| 273 | |
} |
| 274 | |
break; |
| 275 | |
case DELETE: |
| 276 | 0 | statementService.deleteStatement(statement.getId()); |
| 277 | |
break; |
| 278 | |
} |
| 279 | 0 | } else if(nodeData instanceof ReqComponentInfo){ |
| 280 | 0 | ReqComponentInfo reqComp = (ReqComponentInfo) nodeData; |
| 281 | 0 | switch(results.getOperation()){ |
| 282 | |
case CREATE: |
| 283 | 0 | ReqComponentInfo created = statementService.createReqComponent(reqComp.getType(), reqComp); |
| 284 | 0 | reqComp.setMetaInfo(created.getMetaInfo()); |
| 285 | 0 | break; |
| 286 | |
case UPDATE: |
| 287 | 0 | ReqComponentInfo updated = statementService.updateReqComponent(reqComp.getId(), reqComp); |
| 288 | 0 | reqComp.setMetaInfo(updated.getMetaInfo()); |
| 289 | 0 | break; |
| 290 | |
case DELETE: |
| 291 | 0 | statementService.deleteReqComponent(reqComp.getId()); |
| 292 | |
break; |
| 293 | |
} |
| 294 | 0 | }else if(nodeData instanceof StatementTreeViewInfo){ |
| 295 | 9 | StatementTreeViewInfo treeView = (StatementTreeViewInfo) nodeData; |
| 296 | 9 | switch(results.getOperation()){ |
| 297 | |
case CREATE: |
| 298 | 6 | StatementTreeViewInfo created = statementService.createStatementTreeView(treeView); |
| 299 | 6 | if(results.getAssembler() != null && results.getBusinessDTORef() != null) { |
| 300 | 6 | results.getAssembler().assemble(created, results.getBusinessDTORef(), true); |
| 301 | |
} |
| 302 | |
break; |
| 303 | |
case UPDATE: |
| 304 | 1 | StatementTreeViewInfo updated = statementService.updateStatementTreeView(treeView.getId(), treeView); |
| 305 | 1 | if(results.getAssembler() != null && results.getBusinessDTORef() != null) { |
| 306 | 1 | results.getAssembler().assemble(updated, results.getBusinessDTORef(), true); |
| 307 | |
} |
| 308 | |
break; |
| 309 | |
case DELETE: |
| 310 | 2 | statementService.deleteStatementTreeView(treeView.getId()); |
| 311 | |
break; |
| 312 | |
} |
| 313 | 9 | }else if(nodeData instanceof CluPublicationInfo){ |
| 314 | 85 | CluPublicationInfo cluPublication = (CluPublicationInfo) nodeData; |
| 315 | 85 | switch(results.getOperation()){ |
| 316 | |
case CREATE: |
| 317 | 55 | luService.createCluPublication(cluPublication.getCluId(), cluPublication.getType(), cluPublication); |
| 318 | 55 | break; |
| 319 | |
case UPDATE: |
| 320 | 30 | luService.updateCluPublication(cluPublication.getId(), cluPublication); |
| 321 | 30 | break; |
| 322 | |
case DELETE: |
| 323 | 0 | luService.deleteCluPublication(cluPublication.getId()); |
| 324 | |
break; |
| 325 | |
} |
| 326 | 85 | }else{ |
| 327 | 0 | throw new UnsupportedActionException("This service invoker does not know how to handle nodeData for "+nodeData.getClass().getName()); |
| 328 | |
} |
| 329 | |
|
| 330 | 3342 | } |
| 331 | |
|
| 332 | |
public LuService getLuService() { |
| 333 | 0 | return luService; |
| 334 | |
} |
| 335 | |
|
| 336 | |
public void setLuService(LuService luService) { |
| 337 | 2 | this.luService = luService; |
| 338 | 2 | } |
| 339 | |
|
| 340 | |
public StatementService getStatementService() { |
| 341 | 0 | return statementService; |
| 342 | |
} |
| 343 | |
|
| 344 | |
public void setStatementService(StatementService statementService) { |
| 345 | 2 | this.statementService = statementService; |
| 346 | 2 | } |
| 347 | |
|
| 348 | |
public LearningObjectiveService getLoService() { |
| 349 | 0 | return loService; |
| 350 | |
} |
| 351 | |
|
| 352 | |
public void setLoService(LearningObjectiveService loService) { |
| 353 | 2 | this.loService = loService; |
| 354 | 2 | } |
| 355 | |
|
| 356 | |
public AtpService getAtpService() { |
| 357 | 0 | return atpService; |
| 358 | |
} |
| 359 | |
|
| 360 | |
public void setAtpService(AtpService atpService) { |
| 361 | 1 | this.atpService = atpService; |
| 362 | 1 | } |
| 363 | |
|
| 364 | |
public void setLrcService(LrcService lrcService) { |
| 365 | 1 | this.lrcService = lrcService; |
| 366 | 1 | } |
| 367 | |
|
| 368 | |
} |