package com.cloud.user.service.impl;

import com.cloud.common.utils.DateUtil;
import com.cloud.common.utils.PageUtil;
import com.cloud.common.utils.UpperByName;
import com.cloud.model.common.Page;
import com.cloud.model.sys.SysPermission;
import com.cloud.model.sys.SysRole;
import com.cloud.user.dao.RolePermissionDao;
import com.cloud.user.dao.SysRoleDao;
import com.cloud.user.dao.SysRoleMenuDao;
import com.cloud.user.dao.UserRoleDao;
import com.cloud.user.service.AppUserService;
import com.cloud.user.service.SysRoleService;
import com.google.common.collect.Sets;
import lombok.extern.slf4j.Slf4j;
/*import org.springframework.amqp.core.AmqpTemplate;*/
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.util.*;
import java.util.stream.Collectors;



@Slf4j
@Service
public class SysRoleServiceImpl implements SysRoleService {

	@Autowired
	private SysRoleDao sysRoleDao;
	@Autowired
	private UserRoleDao userRoleDao;
	@Autowired
	private RolePermissionDao rolePermissionDao;
	@Autowired
    private SysRoleMenuDao sysRoleMenuDao;
	/*@Autowired
	private AmqpTemplate amqpTemplate;*/
	@Autowired
	private AppUserService appUserService;



	@Transactional
	@Override
	public void save(SysRole sysRole) {
		/*SysRole role = sysRoleDao.findByCode(sysRole.getCode());
		if (role != null) {
			throw new IllegalArgumentException("角色code已存在");
		}*/
		Map<String,Object> params = new HashMap<>();
		params.put("name",sysRole.getName());
		params.put("orgId",sysRole.getOrgId());
		SysRole role = sysRoleDao.findByName(params);
		if (role != null) {
			throw new IllegalArgumentException("角色已存在");
		}
		sysRole.setCreateTime(new Date());
		sysRole.setUpdateTime(sysRole.getCreateTime());
		sysRoleDao.save(sysRole);

		//Log l =new Log();
		//l.setModule("测试");
		//l.setFlag(true);
		//logClient.save2(l);
		log.info("保存角色：{}", sysRole);
	}

	@Transactional
	@Override
	public void update(SysRole sysRole) {
		sysRole.setUpdateTime(new Date());
		Map<String,Object> params = new HashMap<>();
		params.put("name",sysRole.getName());
		params.put("orgId",sysRole.getOrgId());
		SysRole role = sysRoleDao.findByName(params);
		if (role != null) {
			throw new IllegalArgumentException("角色已存在");
		}
		//sysRoleDao.update(sysRole);
		sysRoleDao.updateByPrimaryKeySelective(sysRole);
		log.info("修改角色：{}", sysRole);
	}

	@Transactional
	@Override
	public Map<String,Object> deleteRole(Map<String,Object> params) {
		Map<String,Object> map = new HashMap<>();
		Integer userRole = userRoleDao.findUserRoleCount(params);
		if (userRole == 0 ){
			SysRole sysRole = sysRoleDao.findByIdParams(params);
			//删除角色表
			sysRoleDao.delete(params);
			//删除对应角色拥有的权限
			//rolePermissionDao.deleteRolePermissionByParams(params)
			sysRoleMenuDao.deleteRolePermissionByParams(params);
			//删除角色用户表的数据
			userRoleDao.deleteUserRoleByParams(params);
			log.info("删除角色：{}", sysRole);
			map.put("code",0);
			map.put("msg","刪除成功！");
			map.put("success",true);
			map.put("data",null);
		}else {
			map.put("code",1);
			map.put("msg","该角色下有用户，不允许删除！");
			map.put("success",false);
			map.put("data",null);
		}
		// 发布role删除的消息
		//amqpTemplate.convertAndSend(UserCenterMq.MQ_EXCHANGE_USER, UserCenterMq.ROUTING_KEY_ROLE_DELETE, id);
		return map;
	}

	@Transactional
	@Override
	public void setPermissionToRole(Long roleId, Set<Long> permissionIds) {
		SysRole sysRole = sysRoleDao.findById(roleId);
		if (sysRole == null) {
			throw new IllegalArgumentException("角色不存在");
		}

		// 查出角色对应的old权限
		Set<Long> oldPermissionIds = rolePermissionDao.findPermissionsByRoleIds(Sets.newHashSet(roleId)).stream()
				.map(p -> p.getId()).collect(Collectors.toSet());

		// 需要添加的权限
		Collection<Long> addPermissionIds = org.apache.commons.collections4.CollectionUtils.subtract(permissionIds,
				oldPermissionIds);
		if (!CollectionUtils.isEmpty(addPermissionIds)) {
			addPermissionIds.forEach(permissionId -> {
				rolePermissionDao.saveRolePermission(roleId, permissionId);
			});
		}
		// 需要移除的权限
		Collection<Long> deletePermissionIds = org.apache.commons.collections4.CollectionUtils
				.subtract(oldPermissionIds, permissionIds);
		if (!CollectionUtils.isEmpty(deletePermissionIds)) {
			deletePermissionIds.forEach(permissionId -> {
				rolePermissionDao.deleteRolePermission(roleId, permissionId);
			});
		}

	}

	@Override
	public SysRole findById(Long id) {
		return sysRoleDao.findById(id);
	}

	@Override
	public Page<SysRole> findRoles(Map<String, Object> params) {
		int total = sysRoleDao.count(params);
		List<SysRole> list = Collections.emptyList();
		if (total > 0) {
			PageUtil.pageParamConver(params, false);

			list = sysRoleDao.findData(params);
		}
		return new Page<>(total, list);
	}

	@Override
	public Set<SysPermission> findPermissionsByRoleId(Long roleId) {
		return rolePermissionDao.findPermissionsByRoleIds(Sets.newHashSet(roleId));
	}

	@Override
	public List<Map<String, Object>> findRoleList(Map<String, Object> params) {
		return sysRoleDao.findRoleList(params);
	}

	@Override
	public int saveRoleMenus(Map<String, Object> params) {
		int status = 0;
		try{
			if(!params.get("menuIds").toString().equals("")){
				Set<Long> menuIds = new HashSet<>();
				String[] ids = params.get("menuIds").toString().split(",");
				for(int i=0;i<ids.length;i++){
					menuIds.add(Long.parseLong(ids[i]));
				}

				sysRoleDao.deleteRoleMenus(params);
				if (!CollectionUtils.isEmpty(menuIds)) {
					menuIds.forEach(menuId -> {
						params.put("menuId",menuId);
						sysRoleDao.saveRoleMenus(params);
					});
				}
			}else{
				sysRoleDao.deleteRoleMenus(params);
			}
			status = 1;
			return status;
		}catch (Exception e){
			e.printStackTrace();
			return status;
		}
	}

	@Override
	@Transactional
	public int saveUserRoleMens(Map<String, Object> params) {
		int status = 0;
		try {
			//添加角色
			SysRole sysRole = new SysRole();
			sysRole.setOrgId(Long.parseLong(params.get("orgId").toString()));
			//管理员后期字典取
			sysRole.setName("管理员");
			Map<String,Object> paramsRole = new HashMap<>();
			paramsRole.put("name",sysRole.getName());
			paramsRole.put("orgId",sysRole.getOrgId());
			SysRole role = sysRoleDao.findByName(paramsRole);
			if(role == null){
			sysRole.setIsSys(0);
			sysRole.setEnabled(false);
			sysRole.setDelFlag("0");
			sysRole.setCode(UUID.randomUUID().toString());
			sysRole.setCreateTime(DateUtil.getCurrentDate(DateUtil.TIME_PATTERN));
			sysRole.setUpdateTime(DateUtil.getCurrentDate(DateUtil.TIME_PATTERN));
			status = sysRoleDao.save(sysRole);

			//用户赋角色
			params.put("id",params.get("userId").toString());
			params.put("roleIds",sysRole.getId());
			appUserService.setRoleToUser(params);
			}else{
				sysRole.setId(role.getId());
			}
			//角色赋权限
				if(!params.get("menuIds").toString().equals("")){
					params.put("id",sysRole.getId());
					Set<Long> menuIds = new HashSet<>();
					String[] ids = params.get("menuIds").toString().split(",");
					for(int i=0;i<ids.length;i++){
						menuIds.add(Long.parseLong(ids[i]));
					}

					sysRoleDao.deleteRoleMenus(params);
					if (!CollectionUtils.isEmpty(menuIds)) {
						menuIds.forEach(menuId -> {
							params.put("menuId",menuId);
							sysRoleDao.saveRoleMenus(params);
						});
					}
				}else {
					params.put("id",sysRole.getId());
					sysRoleDao.deleteRoleMenus(params);
				}
				status = 1;
		}catch (Exception e){
			e.printStackTrace();
			return status;
		}
		return status;
	}
}