path: root/ecomp-sdk/epsdk-core/src/main/java/org/onap/portalsdk/core/service/BroadcastServiceImpl.java

/*
 * ============LICENSE_START==========================================
 * ONAP Portal SDK
 * ===================================================================
 * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
 * ===================================================================
 *
 * Unless otherwise specified, all software contained herein is licensed
 * under the Apache License, Version 2.0 (the "License");
 * you may not use this software 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.
 *
 * Unless otherwise specified, all documentation contained herein is licensed
 * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
 * you may not use this documentation except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *             https://creativecommons.org/licenses/by/4.0/
 *
 * Unless required by applicable law or agreed to in writing, documentation
 * 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.
 *
 * ============LICENSE_END============================================
 *
 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
 */
package org.onap.portalsdk.core.service;

import java.util.Calendar;
import java.util.Collections;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeSet;

import javax.servlet.http.HttpServletRequest;

import org.onap.portalsdk.core.domain.BroadcastMessage;
import org.onap.portalsdk.core.domain.Lookup;
import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.onap.portalsdk.core.service.support.FusionService;
import org.onap.portalsdk.core.util.SystemProperties;
import org.onap.portalsdk.core.web.support.AppUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.ServletRequestBindingException;
import org.springframework.web.bind.ServletRequestUtils;

@SuppressWarnings("rawtypes")
@Service("broadcastService")
@Transactional
public class BroadcastServiceImpl extends FusionService implements BroadcastService {

	private static final EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(BroadcastServiceImpl.class);

	@Autowired
	private DataAccessService dataAccessService;

	private static Hashtable broadcastMessages = new Hashtable();

	public BroadcastServiceImpl() {
		super();
	}

	@Override
	@SuppressWarnings("unchecked")
	public void loadMessages() {
		List messageLocations = AppUtils.getLookupListNoCache("fn_lu_message_location", "message_location_id",
				"message_location_descr", "", "message_location_id");

		for (int i = 0; i < messageLocations.size(); i++) {
			Lookup location = (Lookup) messageLocations.get(i);
			String locationId = location.getValue();

			broadcastMessages.put(locationId, getPersistedBroadcastMessages(locationId));
		}
	}

	@Override
	@SuppressWarnings("unchecked")
	public Map getBcModel(HttpServletRequest request) {
		HashMap bcModel = new HashMap();

		int messageId = ServletRequestUtils.getIntParameter(request, "message_id", 0);
		String task = ServletRequestUtils.getStringParameter(request, "task", "get");

		// delete or toggle activation on the selected record (if applicable)
		if (messageId != 0 && ("delete".equals(task) || "toggleActive".equals(task))) {
			BroadcastMessage message = (BroadcastMessage) getDataAccessService().getDomainObject(BroadcastMessage.class,
					new Long(messageId), null);

			if ("delete".equals(task)) {
				getDataAccessService().deleteDomainObject(message, null);
			} else if ("toggleActive".equals(task)) {
				HashMap additionalParams = new HashMap();
				additionalParams.put(Parameters.PARAM_HTTP_REQUEST, request);

				message.setActive(new Boolean(!message.getActive().booleanValue()));
				getDataAccessService().saveDomainObject(message, additionalParams);
			}
			loadMessages();
		}

		List items = getDataAccessService().getList(BroadcastMessage.class, null);
		Collections.sort(items);
		bcModel.put("messagesList", packageMessages(items));

		List locations = AppUtils.getLookupList("fn_lu_message_location", "message_location_id",
				"message_location_descr", "", "message_location_id");
		bcModel.put("messageLocations", locations);

		if ("true".equals(SystemProperties.getProperty(SystemProperties.CLUSTERED))) {
			List sites = AppUtils.getLookupList("fn_lu_broadcast_site", "broadcast_site_cd", "broadcast_site_descr", "",
					"broadcast_site_descr");
			bcModel.put("broadcastSites", sites);
		}

		return bcModel;
	}

	@SuppressWarnings("unchecked")
	private HashMap packageMessages(List messages) {
		HashMap messagesList = new HashMap();
		Set locationMessages = null;

		Integer previousLocationId = null;

		for (int i = 0; i < messages.size(); i++) {
			BroadcastMessage message = (BroadcastMessage) messages.get(i);

			if (!message.getLocationId().equals(previousLocationId)) {
				if (previousLocationId != null) {
					messagesList.put(previousLocationId.toString(), locationMessages);
				}

				locationMessages = new TreeSet();
				previousLocationId = message.getLocationId();
			}

			locationMessages.add(message);
		}

		if (previousLocationId != null) {
			messagesList.put(previousLocationId.toString(), locationMessages);
		}

		return messagesList;
	}

	@SuppressWarnings("unchecked")
	private List getPersistedBroadcastMessages(String locationId) {
		HashMap params = new HashMap();

		params.put("location_id", new Integer(locationId));

		Calendar calInstanceToday = Calendar.getInstance();
		calInstanceToday.set(Calendar.HOUR, 0);
		calInstanceToday.set(Calendar.MINUTE, 0);
		calInstanceToday.set(Calendar.SECOND, 0);
		params.put("today_date", calInstanceToday.getTime());

		return getDataAccessService().executeNamedQuery("broadcastMessages", params, null);
	}

	@Override
	public Map getBroadcastMessages() {
		return broadcastMessages;
	}

	public static List getBroadcastMessages(String locationId) {
		return (List) broadcastMessages.get(locationId);
	}

	public static String displayMessages(String locationId) {
		return displayServerMessages(locationId, null);
	}

	public static String displayServerMessages(String locationId, String siteCd) {
		StringBuilder html = new StringBuilder();
		List messages = getBroadcastMessages(locationId);
		for (int i = 0; i < messages.size(); i++) {
			BroadcastMessage message = (BroadcastMessage) messages.get(i);
			if ((message.getSiteCd() == null)
					|| ((message.getSiteCd() != null) && message.getSiteCd().equals(siteCd))) {
				html.append("<li class=\"broadcastMessage\">").append(message.getMessageText());
			}
		}
		if (html.length() > 0) {
			html.insert(0, "<ul class=\"broadcastMessageList\">");
			html.append("</ul>");
		}
		return html.toString();
	}

	public static boolean hasMessages(String locationId) {
		return hasServerMessages(locationId, null);
	}

	public static boolean hasServerMessages(String locationId, String siteCd) {
		List messages = getBroadcastMessages(locationId);
		boolean messagesExist = !((messages == null) || messages.isEmpty());
		if (!messagesExist)
			return false;

		if (siteCd == null) {
			return messagesExist;
		} else {
			if(messages!=null){
				for (int i = 0; i < messages.size(); i++) {
					BroadcastMessage message = (BroadcastMessage) messages.get(i);

					if ((message.getSiteCd() == null) || message.getSiteCd().equals(siteCd)) {
						return true;
					}
				}
			}
			return false;
		}
	}

	@Override
	public BroadcastMessage getBroadcastMessage(HttpServletRequest request) {
		long messageId = ServletRequestUtils.getLongParameter(request, "message_id", 0);

		BroadcastMessage message = new BroadcastMessage();
		if (messageId != 0)
			message = (BroadcastMessage) getDataAccessService().getDomainObject(BroadcastMessage.class,
					new Long(messageId), null);

		if (message.getLocationId() == null) {
			try {
				message.setLocationId(
						new Integer(ServletRequestUtils.getStringParameter(request, "message_location_id")));
			} catch (NumberFormatException | ServletRequestBindingException e) {
				logger.error(EELFLoggerDelegate.errorLogger, "getBroadcastMessage failed", e);
			}
			message.setActive(Boolean.TRUE);
		}

		return message;
	}

	public DataAccessService getDataAccessService() {
		return dataAccessService;
	}

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

	@Override
	public void saveBroadcastMessage(BroadcastMessage broadcastMessage) {
		dataAccessService.saveDomainObject(broadcastMessage, null);
	}

	@Override
	public void removeBroadcastMessage(BroadcastMessage broadcastMessage) {
		dataAccessService.deleteDomainObject(broadcastMessage, null);
	}

}