/*
 * <<
 *  Davinci
 *  ==
 *  Copyright (C) 2016 - 2019 EDP
 *  ==
 *  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 edp.davinci.service.impl;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import edp.core.consts.Consts;
import edp.core.exception.ServerException;
import edp.core.exception.UnAuthorizedException;
import edp.core.utils.BaseLock;
import edp.core.utils.LockFactory;
import edp.davinci.core.enums.CheckEntityEnum;
import edp.davinci.core.enums.LockType;
import edp.davinci.core.enums.UserPermissionEnum;
import edp.davinci.dto.projectDto.ProjectPermission;
import edp.davinci.model.User;
import edp.davinci.service.ProjectService;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Component
public abstract class BaseEntityService {

	@Autowired
	ProjectService projectService;

	protected BaseLock getLock(CheckEntityEnum entity, String name, Long domainId) {

		return LockFactory.getLock(
				entity.getSource().toUpperCase() + Consts.AT_SYMBOL + name + Consts.AT_SYMBOL + domainId, 5,
				LockType.REDIS);
	}

	protected void releaseLock(BaseLock lock) {
		// workaround for very high concurrency
		// do nothing, wait for the service layer transaction to commit
	}

	protected void alertNameTaken(CheckEntityEnum entity, String name) throws ServerException {
		log.warn("The {} name({}) is already taken", entity.getSource(), name);
//		throw new ServerException("The " + entity.getSource() + " name is already taken");
		throw new ServerException("名称:[ " + name + " ] 已经存在！");
	}

	protected void alertUnAuthorized(CheckEntityEnum entity, User user, String operation) throws ServerException {
		log.warn("User({}) don't have permission to {} this {}", user.getId(), operation, entity.getSource());
		throw new UnAuthorizedException("当前用户没有权限： " + operation + " 此资源: " + entity.getSource());
	}

	protected ProjectPermission getProjectPermission(Long projectId, User user) {
		try {
			return projectService.getProjectPermission(projectService.getProjectDetail(projectId, user, false), user);
		} catch (Exception e) {
			return null;
		}
	}

	private short getEntityPermission(CheckEntityEnum entity, ProjectPermission projectPermission) {

		short permission = (short) -1;

		switch (entity) {
			case SOURCE:
				permission = projectPermission.getSourcePermission();
				break;
			case CRONJOB:
				permission = projectPermission.getSchedulePermission();
				break;
			case DISPLAY:
			case DISPLAYSLIDE:
			case DASHBOARDPORTAL:
			case DASHBOARD:
				permission = projectPermission.getVizPermission();
				break;
			case VIEW:
				permission = projectPermission.getViewPermission();
				break;
			case WIDGET:
				permission = projectPermission.getWidgetPermission();
				break;
			default:
				break;
		}

		return permission;
	}
	
	protected void checkDeletePermission(CheckEntityEnum entity, Long projectId, User user)
			throws UnAuthorizedException {

		ProjectPermission projectPermission = getProjectPermission(projectId, user);

		if (projectPermission == null) {
			alertUnAuthorized(entity, user, "delete");
		}

		if (getEntityPermission(entity, projectPermission) < UserPermissionEnum.DELETE.getPermission()) {
			alertUnAuthorized(entity, user, "delete");
		}
	}

	protected void checkWritePermission(CheckEntityEnum entity, Long projectId, User user, String operation)
			throws UnAuthorizedException {

		ProjectPermission projectPermission = getProjectPermission(projectId, user);

		if (projectPermission == null) {
			alertUnAuthorized(entity, user, operation);
		}

		if (getEntityPermission(entity, projectPermission) < UserPermissionEnum.WRITE.getPermission()) {
			alertUnAuthorized(entity, user, operation);
		}
	}
	
	protected void checkSharePermission(CheckEntityEnum entity, Long projectId, User user)
			throws UnAuthorizedException {

		ProjectPermission projectPermission = getProjectPermission(projectId, user);

		if (projectPermission == null) {
			alertUnAuthorized(entity, user, "share");
		}

		if (!projectPermission.getSharePermission()) {
			alertUnAuthorized(entity, user, "share");
		}
	}
	
	public boolean checkReadPermission(CheckEntityEnum entity, Long projectId, User user) {

		ProjectPermission projectPermission = getProjectPermission(projectId, user);

		if (projectPermission == null) {
			return false;
		}

		if (getEntityPermission(entity, projectPermission) < UserPermissionEnum.READ.getPermission()) {
			return false;
		}

		return true;
	}
}