/*-
 * ================================================================================
 * ECOMP Portal
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property
 * ================================================================================
 * Licensed under the Apache 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.apache.org/licenses/LICENSE-2.0
 * 
 * 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.openecomp.portalapp.portal.service;

import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.hibernate.SessionFactory;
import org.openecomp.portalapp.portal.domain.EPUser;
import org.openecomp.portalapp.portal.domain.EPUserNotification;
import org.openecomp.portalapp.portal.domain.EcompAppRole;
import org.openecomp.portalapp.portal.logging.aop.EPMetricsLog;
import org.openecomp.portalapp.portal.transport.EpNotificationItem;
import org.openecomp.portalapp.portal.transport.EpNotificationItemVO;
import org.openecomp.portalapp.portal.transport.EpRoleNotificationItem;
import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.openecomp.portalsdk.core.service.DataAccessService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.stereotype.Service;

@Service("userNotificationService")
@org.springframework.context.annotation.Configuration
@EnableAspectJAutoProxy
@EPMetricsLog
public class UserNotificationServiceImpl implements UserNotificationService {
	EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(FunctionalMenuServiceImpl.class);

	@Autowired
	private DataAccessService dataAccessService;
	@Autowired
	private SessionFactory sessionFactory;

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#getNotifications(java.lang.Long)
	 */
	@Override
	public List<EpNotificationItem> getNotifications(Long userId) {
		Map<String, String> params = new HashMap<String, String>();
		params.put("user_id", userId.toString());
		@SuppressWarnings("unchecked")
		List<EpNotificationItem> notificationList = dataAccessService.executeNamedQuery("getNotifications", params,
				null);
		// set the roles to null for pure retrieval of all notifications
		for (EpNotificationItem item : notificationList) {
			item.setRoles(null);
		}
		return notificationList;
	}

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#getNotificationHistoryVO(java.lang.Long)
	 */
	@Override
	public List<EpNotificationItemVO> getNotificationHistoryVO(Long userId) {
		Map<String, String> params = new HashMap<String, String>();
		params.put("user_id", userId.toString());
		@SuppressWarnings("unchecked")
		List<EpNotificationItemVO> notificationList = dataAccessService.executeNamedQuery("getNotificationHistoryVO",
				params, null);
		return notificationList;
	}

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#getAdminNotificationVOS()
	 */
	@Override
	public List<EpNotificationItemVO> getAdminNotificationVOS() {
		Map<String, String> params = new HashMap<String, String>();
		@SuppressWarnings("unchecked")
		List<EpNotificationItemVO> notificationList = dataAccessService
				.executeNamedQuery("getAdminNotificationHistoryVO", params, null);
		return notificationList;
	}

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#getNotificationRoles(java.lang.Long)
	 */
	@Override
	public List<EpRoleNotificationItem> getNotificationRoles(Long notificationId) {
		Map<String, String> params = new HashMap<String, String>();
		params.put("notificationId", Long.toString(notificationId));
		@SuppressWarnings("unchecked")
		List<EpRoleNotificationItem> roleNotifList = dataAccessService.executeNamedQuery("getNotificationRoles", params,
				null);
		return roleNotifList;
	}

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#getAppRoleList()
	 */
	@SuppressWarnings("unchecked")
	@Override
	public List<EcompAppRole> getAppRoleList() {
		List<EcompAppRole> appRoleList = (List<EcompAppRole>) dataAccessService.executeNamedQuery("getEpNotificationAppRoles", null, null);		
		return appRoleList;		
	}	
	
	/*
	 * (non-Javadoc)
	 * 
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#
	 * setNotificationsRead(java.lang.Long, int)
	 */
	@Override
	public void setNotificationRead(Long notificationId, int userId) {
		EPUserNotification userNotification = new EPUserNotification();
		userNotification.setNotificationId(notificationId);
		userNotification.setUpdateTime(new Date());
		userNotification.setViewed("Y");
		userNotification.setUserId((long) userId);
		getDataAccessService().saveDomainObject(userNotification, null);
	}

	/*
	 * (non-Javadoc)
	 * @see org.openecomp.portalapp.portal.service.UserNotificationService#saveNotification(org.openecomp.portalapp.portal.transport.EpNotificationItem)
	 */
	@Override
	public String saveNotification(EpNotificationItem notificationItem) throws Exception {

		// gather the roles
		if (notificationItem.getRoleIds() != null && !notificationItem.getIsForAllRoles().equals("Y")) {
			if (notificationItem.getRoles() == null) {
				Set<EpRoleNotificationItem> roleSet = new HashSet<EpRoleNotificationItem>();
				notificationItem.setRoles(roleSet);
			}
			for (Long roleId : notificationItem.getRoleIds()) {
				EpRoleNotificationItem roleItem = new EpRoleNotificationItem();
				roleItem.setNotificationId(notificationItem.getNotificationId());
				roleItem.setRoleId(roleId.intValue());
				notificationItem.getRoles().add(roleItem);
			}
		}

		
			// for updates fetch roles and then save
			if (notificationItem.getNotificationId() != null) {
				EpNotificationItem updateNotificationItem = (EpNotificationItem) getDataAccessService()
						.getDomainObject(EpNotificationItem.class, notificationItem.getNotificationId(), null);
				notificationItem.setRoles(updateNotificationItem.getRoles());
			}
			 if(notificationItem.msgSource == null)
	            {
	                notificationItem.setMsgSource("EP");
	            }
			getDataAccessService().saveDomainObject(notificationItem, null);
			 return "" ;

		} 
	  @Override
	    public List<EPUser> getUsersByOrgIds(List<String> OrgIds) {
	        Map<String, Object> params = new HashMap<String, Object>();
	        params.put("OrgIds", OrgIds);
	        @SuppressWarnings("unchecked")
	        List<EPUser> userList = dataAccessService.executeNamedQuery("getUsersByOrgIdsNotifications", params,    null);
	        return userList;
	    }
	  
	  @Override
			public List<String> getMessageRecipients(Long notificationId) {
				Map<String, String> params = new HashMap<>();
				params.put("notificationId", Long.toString(notificationId));
				@SuppressWarnings("unchecked")
				List<String> activeUsers = dataAccessService.executeNamedQuery("messageRecipients", params, null);
				return activeUsers;
			}

	public DataAccessService getDataAccessService() {
		return dataAccessService;
	}

	public void setDataAccessService(DataAccessService dataAccessService) {
		this.dataAccessService = dataAccessService;
	}

	public SessionFactory getSessionFactory() {
		return sessionFactory;
	}

	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}

}