package com.ibeetl.admin.core.service;

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

import com.ibeetl.admin.core.dao.CityPartnerDao;
import com.ibeetl.admin.core.entity.XzxCityPartner;
import com.ibeetl.admin.core.util.ExceptionEnum;
import com.ibeetl.admin.core.util.MiException;
import org.beetl.sql.core.SQLManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.ibeetl.admin.core.conf.PasswordConfig.PasswordEncryptService;
import com.ibeetl.admin.core.dao.CoreOrgDao;
import com.ibeetl.admin.core.dao.CoreUserDao;
import com.ibeetl.admin.core.entity.CoreOrg;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.rbac.UserLoginInfo;
import com.ibeetl.admin.core.util.PlatformException;
import com.ibeetl.admin.core.util.enums.DelFlagEnum;
import com.ibeetl.admin.core.util.enums.GeneralStateEnum;

@Service
@Transactional
public class CoreUserService {
	@Autowired
	CoreUserDao userDao ;
	@Autowired
	CityPartnerDao partnerDao ;
	
	@Autowired
	CoreOrgDao orgDao;
	
	@Autowired
	PasswordEncryptService passwordEncryptService;
	
	@Autowired SQLManager sqlManager;
	
	public UserLoginInfo login(String userName,String password){
		CoreUser query = new CoreUser();
		query.setCode(userName);
		query.setPassword(passwordEncryptService.password(password));
		query.setState(GeneralStateEnum.ENABLE.getValue());
		CoreUser user =userDao.createLambdaQuery().andEq(CoreUser::getCode,userName).
		    andEq(CoreUser::getPassword, passwordEncryptService.password(password)).single();
		if(user==null) {
		    throw new PlatformException("用户"+"不存在或者密码错误");
		}
		if(!user.getState().equals(GeneralStateEnum.ENABLE.getValue())){
		    throw new PlatformException("用户"+"已经失效");
		}
		if(user.getDelFlag()==DelFlagEnum.DELETED.getValue()) {
		    throw new PlatformException("用户"+"已经删除");
		}
		
		
		List<CoreOrg>  orgs = getUserOrg(user.getId(),user.getOrgId());
		UserLoginInfo loginInfo = new UserLoginInfo();
		loginInfo.setOrgs(orgs);
		loginInfo.setUser(user);
		return loginInfo;
		
	}

	public Map<String,Object> loginApi(String userName, String password,String userType){
		Map<String,Object> map = new HashMap<>();
		String msg = "";
		CoreUser query = new CoreUser();
		query.setCode(userName);
		query.setPassword(passwordEncryptService.password(password));
		query.setState(GeneralStateEnum.ENABLE.getValue());
		CoreUser user =userDao.createLambdaQuery().andEq(CoreUser::getCode,userName).andEq(CoreUser::getDelFlag,0).
				andEq(CoreUser::getPassword, passwordEncryptService.password(password)).single();
		if(user==null) {
			XzxCityPartner query1 = new XzxCityPartner();
			query1.setAccountNo(userName);
			query1.setPassword(passwordEncryptService.password(password));
			query1.setProhibit(1);
			XzxCityPartner partner =partnerDao.createLambdaQuery().andEq(XzxCityPartner::getAccountNo,userName).andEq(XzxCityPartner::getDelFlag,0).
					andEq(XzxCityPartner::getPassword, passwordEncryptService.password(password)).single();
			if(partner==null){
				msg = "用户"+"不存在或者密码错误";
			}else{
				user = new CoreUser();
				user.setName(partner.getPartnerName());
				user.setState(partner.getState());
				user.setPassword(partner.getPassword());
				user.setCode(partner.getAccountNo());
				user.setDelFlag(partner.getDelFlag());
				user.setAttachmentId(partner.getAttachmentId());
				user.setJobType0(partner.getJobType0());
				user.setJobType1(partner.getJobType1());
				user.setOrgId(partner.getOrgId());
                user.setId(partner.getId());

				userType="2";
			}

		}else{
			if(!user.getState().equals(GeneralStateEnum.ENABLE.getValue())){
				msg ="用户"+"已经失效";
			}
			if(user.getDelFlag()==DelFlagEnum.DELETED.getValue()) {
				msg ="用户"+"已经删除";
			}
		}
		UserLoginInfo loginInfo = new UserLoginInfo();

        if(!"".equals(msg)){
			map.put("msg",msg);
			map.put("userLoginInfo",loginInfo);
		}else{
			List<CoreOrg> orgs = new ArrayList<>();
        	if(null!=user.getOrgId()){
				  orgs = getUserOrg(user.getId(),user.getOrgId());
			}else{
				orgs = getUserOrg(user.getId(),1);
			}
			loginInfo.setOrgs(orgs);
			loginInfo.setUser(user);
			map.put("userLoginInfo",loginInfo);
			map.put("userType",userType);
		}

		return map;

	}
	
	public  List<CoreOrg> getUserOrg(long userId,long orgId){
		List<CoreOrg> orgs =  orgDao.queryOrgByUser(userId);
		if(orgs.isEmpty()){
			//没有赋值任何角色，默认给一个所在部门
			//排除打包站
			if(orgId==16){
				System.out.println(ExceptionEnum.MONITOR_EXCEPTION);
				throw new MiException(ExceptionEnum.MONITOR_EXCEPTION);
			}
			CoreOrg userOrg = orgDao.unique(orgId);
			orgs.add(userOrg);
		}
		return orgs;
	}
	
	
	
	public List<CoreUser> getAllUsersByRole(String role){
		return userDao.getUserByRole(role);
	}
	
	public CoreUser getUserByCode(String userName){
		CoreUser user = new CoreUser();
		user.setCode(userName);
		return userDao.templateOne(user);
	}
	
	public void update(CoreUser user){
		userDao.updateById(user);
	}
	
	public CoreOrg getOrgById(Long orgId){
		return orgDao.unique(orgId);
	}
	
	public CoreUser getUserById(Long userId){
		return userDao.unique(userId);
	}
	
	public List<String> getOrgCode(List<Long> orgIds){
		return orgDao.queryAllOrgCode(orgIds);
	}
}