/*

  * Copyright 2007-2009 The Kuali Foundation

  *

  * Licensed under the Educational Community License, Version 2.0 (the "License");

  * you may not use this file except in compliance with the License.

  * You may obtain a copy of the License at

  *

  * http://www.opensource.org/licenses/ecl2.php

  *

  * Unless required by applicable law or agreed to in writing, software

  * distributed under the License is distributed on an "AS IS" BASIS,

  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

  * See the License for the specific language governing permissions and

  * limitations under the License.

  */

 package org.kuali.rice.kim.impl.responsibility;

 import org.kuali.rice.kew.api.WorkflowRuntimeException;

 import org.kuali.rice.kew.messaging.MessageServiceNames;

 import org.kuali.rice.kew.responsibility.ResponsibilityChangeProcessor;

 import org.kuali.rice.kew.util.KEWConstants;

 import org.kuali.rice.kim.api.responsibility.Responsibility;

 import org.kuali.rice.kim.api.responsibility.ResponsibilityService;

 import org.kuali.rice.kim.api.role.RoleResponsibility;

 import org.kuali.rice.kim.impl.role.RoleMemberBo;

 import org.kuali.rice.kim.impl.role.RoleResponsibilityBo;

 import org.kuali.rice.kim.util.KimConstants;

 import org.kuali.rice.krad.service.BusinessObjectService;

 import org.kuali.rice.krad.service.KRADServiceLocator;

 import org.kuali.rice.ksb.api.KsbApiServiceLocator;

 import org.kuali.rice.ksb.messaging.service.KSBXMLService;

 import javax.xml.namespace.QName;

 import java.util.ArrayList;

 import java.util.Collections;

 import java.util.HashSet;

 import java.util.List;

 import java.util.Map;

 import java.util.Set;

 public class ResponsibilityInternalServiceImpl implements ResponsibilityInternalService {

         private BusinessObjectService businessObjectService;

     private ResponsibilityService responsibilityService;

         public void saveRoleMember(RoleMemberBo roleMember){

                 //need to find what responsibilities changed so we can notify interested clients.  Like workflow.

             List<RoleResponsibility> oldRoleResp = getRoleResponsibilities(roleMember.getRoleId());

             // add row to member table

             getBusinessObjectService().save( roleMember );

             //need to find what responsibilities changed so we can notify interested clients.  Like workflow.

             // the new member has been added

             List<RoleResponsibility> newRoleResp = getRoleResponsibilities(roleMember.getRoleId());

             updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(oldRoleResp, newRoleResp));

         }

         public void removeRoleMember(RoleMemberBo roleMember){

                 //need to find what responsibilities changed so we can notify interested clients.  Like workflow.

             List<RoleResponsibility> oldRoleResp = getRoleResponsibilities(roleMember.getRoleId());

             // add row to member table

             getBusinessObjectService().delete( roleMember );

             //need to find what responsibilities changed so we can notify interested clients.  Like workflow.

             // the new member has been added

             List<RoleResponsibility> newRoleResp = getRoleResponsibilities(roleMember.getRoleId());

             updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(oldRoleResp, newRoleResp));

         }

         @SuppressWarnings("unchecked")

         public void updateActionRequestsForRoleChange(String roleId) {

             List<RoleResponsibility> newRoleResp = getRoleResponsibilities(roleId);

             updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(Collections.EMPTY_LIST, newRoleResp));

         }

         /**

          * This overridden method ...

          *

          * @see ResponsibilityInternalService#updateActionRequestsForResponsibilityChange(java.util.Set)

          */

         public void updateActionRequestsForResponsibilityChange(Set<String> responsibilityIds) {

                 KSBXMLService responsibilityChangeProcessor = (KSBXMLService) KsbApiServiceLocator.getMessageHelper()

         .getServiceAsynchronously(new QName(KEWConstants.KEW_MODULE_NAMESPACE, MessageServiceNames.RESPONSIBILITY_CHANGE_SERVICE));

         try {

                 responsibilityChangeProcessor.invoke(ResponsibilityChangeProcessor.getResponsibilityChangeContents(responsibilityIds));

         } catch (Exception e) {

             throw new WorkflowRuntimeException(e);

         }

         }

         @SuppressWarnings("unchecked")

         public List<RoleResponsibility> getRoleResponsibilities(String roleId){

                 List<RoleResponsibilityBo> rrBoList =

                                 (List<RoleResponsibilityBo>)getBusinessObjectService()

                                 .findMatching(RoleResponsibilityBo.class, Collections.singletonMap(KimConstants.PrimaryKeyConstants.ROLE_ID, roleId));

                 List<RoleResponsibility> result = new ArrayList<RoleResponsibility>( rrBoList.size() );

                 for ( RoleResponsibilityBo bo : rrBoList ) {

                         result.add( RoleResponsibilityBo.to(bo) );

                 }

                 return result;

     }

          /**

     *

     * This method compares the two lists of responsibilitiy IDs and does a union.  returns a unique list of responsibility ids.

     *

     * @param oldRespList

     * @param newRespList

     * @return

     */

    protected Set<String> getChangedRoleResponsibilityIds(

                         List<RoleResponsibility> oldRespList,

                         List<RoleResponsibility> newRespList) {

                 Set<String> lRet = new HashSet<String>();

                 for (RoleResponsibility resp : oldRespList) {

                         lRet.add(resp.getResponsibilityId());

                 }

                 for (RoleResponsibility resp : newRespList) {

                         lRet.add(resp.getResponsibilityId());

                 }

                 return lRet;

         }

         protected BusinessObjectService getBusinessObjectService() {

                 if ( businessObjectService == null ) {

                         businessObjectService = KRADServiceLocator.getBusinessObjectService();

                 }

                 return businessObjectService;

         }

     public boolean areActionsAtAssignmentLevel(Responsibility responsibility ) {

             Map<String, String> details = responsibility.getAttributes();

             if ( details == null ) {

                     return false;

             }

             String actionDetailsAtRoleMemberLevel = details.get( KimConstants.AttributeConstants.ACTION_DETAILS_AT_ROLE_MEMBER_LEVEL );

             return Boolean.valueOf(actionDetailsAtRoleMemberLevel);

     }

     public boolean areActionsAtAssignmentLevelById( String responsibilityId ) {

             Responsibility responsibility = responsibilityService.getResponsibility(responsibilityId);

             if ( responsibility == null ) {

                     return false;

             }

             return areActionsAtAssignmentLevel(responsibility);

     }

 }