package com.dev.service.internal;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.app.base.data.ApiResponseResult;
import com.app.base.data.DataGrid;
import com.dev.service.ApiCodeService;
import com.system.permission.dao.SysPermissionDao;
import com.system.permission.entity.SysPermission;
import com.system.role.dao.RolePermissionMapDao;
import com.system.role.dao.SysRoleDao;
import com.system.role.entity.RolePermissionMap;
import com.system.role.entity.SysRole;
import com.system.user.dao.UserRoleMapDao;
import com.system.user.entity.SysUser;
import com.utils.BaseService;
import com.utils.SearchFilter;
import com.utils.UserUtil;
import com.utils.enumeration.BasicStateEnum;

/**
 * 角色
 *
 */
@Service(value = "apiCodeService")
@Transactional(propagation = Propagation.REQUIRED)
public class ApiCodeImpl implements ApiCodeService {

    @Autowired
    private SysRoleDao sysRoleDao;
    @Autowired
    private RolePermissionMapDao rolePermissionMapDao;
    @Autowired
    private UserRoleMapDao userRoleMapDao;
    @Autowired
    private SysPermissionDao sysPermissionDao;

    /**
     * 新增角色
     * @param sysRole
     * @return
     * @author fyx
     * @serialData 2018-11-21
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult add(SysRole sysRole) throws Exception{
        if(sysRole == null){
            return ApiResponseResult.failure("角色不能为空！");
        }
        if(StringUtils.isEmpty(sysRole.getBsCode())){
            return ApiResponseResult.failure("角色编号不能为空！");
        }
        if(StringUtils.isEmpty(sysRole.getBsName())){
            return ApiResponseResult.failure("角色名称不能为空！");
        }
        int count = sysRoleDao.countByIsDelAndBsCode(0, sysRole.getBsCode());
        if(count > 0){
            return ApiResponseResult.failure("该角色已存在，请填写其他角色编号！");
        }

        sysRole.setCreatedTime(new Date());
        sysRoleDao.save(sysRole);

        return ApiResponseResult.success("角色添加成功！").data(sysRole);
    }

	@Override
    @Transactional
    public ApiResponseResult edit(SysRole sysRole) throws Exception {
        if(sysRole == null){
            return ApiResponseResult.failure("角色不能为空！");
        }
        if(sysRole.getId() == null){
            return ApiResponseResult.failure("角色ID不能为空！");
        }
        if(StringUtils.isEmpty(sysRole.getBsCode())){
            return ApiResponseResult.failure("角色编号不能为空！");
        }
        if(StringUtils.isEmpty(sysRole.getBsName())){
            return ApiResponseResult.failure("角色名称不能为空！");
        }
        SysRole o = sysRoleDao.findById((long) sysRole.getId());
        if(o == null){
            return ApiResponseResult.failure("该角色不存在！");
        }

        //判断角色编号是否有变化，有则修改；没有则不修改
        String originalCode = o.getBsCode();
        if(o.getBsCode().equals(sysRole.getBsCode())){
        }else{
            int count = sysRoleDao.countByIsDelAndBsCode(0, sysRole.getBsCode());
            if(count > 0){
                return ApiResponseResult.failure("角色编号已存在，请填写其他角色编号！");
            }
            o.setBsCode(sysRole.getBsCode().trim());
        }
        o.setModifiedTime(new Date());
        o.setBsName(sysRole.getBsName());
        o.setDescpt(sysRole.getDescpt());
        sysRoleDao.save(o);

        return ApiResponseResult.success("编辑成功！");
	}

    @Override
    @Transactional
    public ApiResponseResult delete(Long id) throws Exception{
        if(id == null){
            return ApiResponseResult.failure("角色ID不能为空！");
        }
        SysRole o  = sysRoleDao.findById((long) id);
        if(o == null){
            return ApiResponseResult.failure("该角色不存在！");
        }

        o.setModifiedTime(new Date());
        o.setIsDel(1);
        sysRoleDao.save(o);

        return ApiResponseResult.success("删除成功！");
    }

	@Override
    @Transactional
	public ApiResponseResult getList(String keyword, String bsCode,String bsName, Date createdTimeStart, Date createdTimeEnd, PageRequest pageRequest) throws Exception {
        //查询条件1
        List<SearchFilter> filters =new ArrayList<>();
        filters.add(new SearchFilter("isDel", SearchFilter.Operator.EQ, BasicStateEnum.FALSE.intValue()));
        if(StringUtils.isNotEmpty(bsCode)){
            filters.add(new SearchFilter("bsCode", SearchFilter.Operator.LIKE, bsCode));
        }
        if(StringUtils.isNotEmpty(bsName)){
            filters.add(new SearchFilter("bsName", SearchFilter.Operator.LIKE, bsName));
        }
        if(createdTimeStart != null){
            filters.add(new SearchFilter("createdTime", SearchFilter.Operator.GTE, createdTimeStart));
        }
        if(createdTimeEnd != null){
            filters.add(new SearchFilter("createdTime", SearchFilter.Operator.LTE, createdTimeEnd));
        }
        //查询2
        List<SearchFilter> filters1 =new ArrayList<>();
        if(StringUtils.isNotEmpty(keyword)){
            filters1.add(new SearchFilter("bsCode", SearchFilter.Operator.LIKE, keyword));
            filters1.add(new SearchFilter("bsName", SearchFilter.Operator.LIKE, keyword));
        }
        Specification<SysRole> spec = Specification.where(BaseService.and(filters, SysRole.class));
        Specification<SysRole> spec1 =  spec.and(BaseService.or(filters1, SysRole.class));
        Page<SysRole> page = sysRoleDao.findAll(spec1, pageRequest);

        return ApiResponseResult.success().data(DataGrid.create(page.getContent(), (int) page.getTotalElements(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize()));
	}

	@Override
	public ApiResponseResult getCheckedRoles(long userId) throws Exception {
		Map map = new HashMap();
		return ApiResponseResult.success().data(map);
	}
	@Override
    @Transactional
	public ApiResponseResult saveUserRoles(long userId,String roles) throws Exception {
		return ApiResponseResult.success("修改成功！");
	}

	@Override
	public ApiResponseResult addRouter(String rolecode, String roles) throws Exception {
		return ApiResponseResult.success();
	}

	@Override
	public ApiResponseResult getRouter(String rolecode) throws Exception {
		return null;
	}

    /**
     * 获取当前角色的操作权限
     * @return
     * @throws Exception
     */
    @Override
    @Transactional(readOnly = true)
    public ApiResponseResult getPermission() throws Exception{
        SysUser currUser = UserUtil.getCurrUser();  //获取当前用户
//        if(currUser == null || currUser.getId() == null){
//            return ApiResponseResult.failure("当前用户不存在！");
//        }
        if(currUser == null || currUser.getFid() == null){
            return ApiResponseResult.failure("当前用户不存在！");
        }

        //1.初始化
        int isSuper = 0;
        String perm = "";

        //2.判断是否为管理员用户，是则无需获取操作权限；否则获取操作权限
//        if(currUser.getUserIsSuper() == 1){
//            //2.1
//            isSuper = 1;
//        }else{
//            //2.2获取当前用户所属角色
//            List<UserRolesMap> mapList = userRolesMapDao.findByIsDelAndUserId(0, currUser.getId());
//            if(mapList != null && mapList.size() > 0){
//                for(UserRolesMap map : mapList){
//                    if(map != null && map.getUserId() != null){
//                        //获取角色
//                        ApiCode role = sysRoleDao.findById((long) map.getRoleId());
//                        if(role != null && StringUtils.isNotEmpty(role.getBsPermission())){
//                            perm = StringUtils.isNotEmpty(perm) ? (perm+","+role.getBsPermission()) : role.getBsPermission();
//                        }
//                    }
//                }
//            }
//        }

        //3.封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("isSuper", isSuper);
        map.put("perm", perm);

        return ApiResponseResult.success().data(map);
    }

    /**
     * 根据ID获取角色
     * @param id
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getRole(Long id) throws Exception{
        if(id == null){
            return ApiResponseResult.failure("角色ID不能为空！");
        }
        SysRole o = sysRoleDao.findById((long) id);
        if(o == null){
            return ApiResponseResult.failure("该角色不存在！");
        }
        return ApiResponseResult.success().data(o);
    }

    /**
     * 获取所有角色
     * @return
     * @throws Exception
     */
    @Override
    @Transactional(readOnly = true)
    public ApiResponseResult getRoles() throws Exception{
        List<SearchFilter> filters = new ArrayList<>();
        Specification<SysRole> spec = Specification.where(BaseService.and(filters, SysRole.class));
        List<SysRole> list = sysRoleDao.findAll(spec);
        return ApiResponseResult.success().data(list);
    }

    /**
     * 根据角色ID获取权限信息
     * @param id
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getRolePerm(Long id) throws Exception{
        if(id == null){
            return ApiResponseResult.failure("角色ID不能为空！");
        }
        SysRole o = sysRoleDao.findById((long) id);
        if(o == null){
            return ApiResponseResult.failure("该角色不存在！");
        }

        //获取当前角色下角色权限关联信息
        List<RolePermissionMap> list = rolePermissionMapDao.findByIsDelAndAndRoleId(0, id);

        //获取所有权限信息
        List<SysPermission> list2 = sysPermissionDao.findByIsDel(0);

        List<Map<String, Object>> mapList = new ArrayList<>();
        for(SysPermission permItem : list2) {
            Map<String, Object> map = new HashMap<>();
            map.put("id", permItem.getId()!=null ? permItem.getId().toString() : "");
            map.put("code", permItem.getBsCode()!=null ? permItem.getBsCode().toString() : "");
            map.put("name", permItem.getBsName()!=null ? permItem.getBsName().toString() : "");
            map.put("pId", permItem.getParentId()!=null ? permItem.getParentId().toString() : "");
            map.put("zindex", permItem.getZindex()!=null ? permItem.getZindex().toString() : "");
            map.put("istype", permItem.getIstype()!=null ? permItem.getIstype().toString() : "");
            map.put("descpt", permItem.getDescpt()!=null ? permItem.getDescpt().toString() : "");
            map.put("icon", permItem.getBsIcon()!=null ? permItem.getBsIcon().toString() : "");
            map.put("page", permItem.getPageUrl()!=null ? permItem.getPageUrl().toString() : "");
            map.put("checked", false);
            map.put("open", true);
            //判断是否有权限
            for(RolePermissionMap rolePermItem : list){
                if(rolePermItem.getPermitId()!=null && rolePermItem.getPermitId().equals(permItem.getId())){
                    map.put("checked", true);
                }
            }
            mapList.add(map);
        }

        return ApiResponseResult.success().data(mapList);
    }

    /**
     * 设置权限
     * @param roleId
     * @param permIds
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult doRolePerm(Long roleId, String permIds) throws Exception{
        if(roleId == null){
            return ApiResponseResult.failure("角色ID不能为空！");
        }
        //转换
        String[] permIdArray = permIds.split(",");
        List<Long> permIdList = new ArrayList<Long>();
        for(int i = 0; i < permIdArray.length; i++){
            if(StringUtils.isNotEmpty(permIdArray[i])) {
                permIdList.add(Long.parseLong(permIdArray[i]));
            }
        }

        //1.删除角色原权限信息
        List<RolePermissionMap> listOld = rolePermissionMapDao.findByIsDelAndAndRoleId(0, roleId);
        if(listOld.size() > 0){
            for(RolePermissionMap item : listOld){
                item.setModifiedTime(new Date());
                item.setIsDel(1);
            }
            rolePermissionMapDao.saveAll(listOld);
        }

        //2.添加角色新权限信息
        List<RolePermissionMap> listNew = new ArrayList<>();
        if(permIdList.size() > 0){
            for(Long permId : permIdList){
                RolePermissionMap item = new RolePermissionMap();
                item.setCreatedTime(new Date());
                item.setRoleId(roleId);
                item.setPermitId(permId);
                listNew.add(item);
            }
            rolePermissionMapDao.saveAll(listNew);
        }

        return ApiResponseResult.success("设置权限成功！");
    }
}