package com.ld.igds.sys;

import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.math.RandomUtils;
import org.hibernate.Session;
import org.springframework.security.authentication.encoding.PasswordEncoder;
import org.springframework.stereotype.Component;

import com.bstek.bdf2.core.CoreHibernateDao;
import com.bstek.bdf2.core.business.IUser;
import com.bstek.bdf2.core.context.ContextHolder;
import com.bstek.bdf2.core.exception.NoneLoginException;
import com.bstek.bdf2.core.model.DefaultUser;
import com.bstek.bdf2.core.model.UserDept;
import com.bstek.bdf2.core.model.UserPosition;
import com.bstek.bdf2.core.service.IRoleService;
import com.bstek.bdf2.core.service.IUserService;
import com.bstek.bdf2.core.service.MemberType;
import com.bstek.dorado.annotation.DataProvider;
import com.bstek.dorado.annotation.DataResolver;
import com.bstek.dorado.annotation.Expose;
import com.bstek.dorado.data.entity.EntityState;
import com.bstek.dorado.data.entity.EntityUtils;
import com.bstek.dorado.data.provider.Page;



/**
 * 用户管理
 * @author Andy
 *
 */
@Component("core.userMaintain")
@SuppressWarnings("deprecation")
public class UserMaintain extends CoreHibernateDao {
	private PasswordEncoder passwordEncoder;

	private IUserService userService;
	private IRoleService roleService;

	/**
	 * 分页获取用户信息
	 * 
	 * @param page
	 * @param criteria
	 * @throws Exception
	 */
	@DataProvider
	public void loadUsers(Page<DefaultUser> page) throws Exception {
		DefaultUser user = (DefaultUser) ContextHolder.getLoginUser();
		if (user == null) {
			throw new NoneLoginException("Please login first");
		}

		String hql = " from " + DefaultUser.class.getName()
				+ " where companyId=:companyId";
		Map<String, Object> args = new HashMap<>();
		args.put("companyId", user.getCompanyId());

		String countHql = "select count(*) " + hql;

		this.pagingQuery(page, hql, countHql, args);
	}

	@DataResolver
	public void saveUsers(Collection<DefaultUser> users) throws Exception {
		IUser loginuser = ContextHolder.getLoginUser();
		if (loginuser == null) {
			throw new NoneLoginException("Please login first!");
		}
		String companyId = loginuser.getCompanyId();
		if (StringUtils.isNotEmpty(getFixedCompanyId())) {
			companyId = getFixedCompanyId();
		}
		Session session = this.getSessionFactory().openSession();
		try {
			for (DefaultUser user : users) {
				EntityState state = EntityUtils.getState(user);
				if (state.equals(EntityState.NEW)) {
					String salt = String.valueOf(RandomUtils.nextInt(100));
					String password = passwordEncoder.encodePassword(
							user.getPassword(), salt);
					user.setPassword(password);
					user.setSalt(salt);
					user.setCompanyId(companyId);
					session.save(user);
				} else if (state.equals(EntityState.MODIFIED)) {
					session.update(user);
				} else if (state.equals(EntityState.DELETED)) {
					roleService.deleteRoleMemeber(user.getUsername(),
							MemberType.User);
					session.delete(user);
				}
			}
		} finally {
			session.flush();
			session.close();
		}
	}

	/**
	 * 这个方法用来判断在添加新用户时用户名是否已经存在
	 * 
	 * @param username
	 *            用户输入的用户名
	 */
	@Expose
	public String userIsExists(String username) {
		String hql = "select count(*) from " + DefaultUser.class.getName()
				+ " u where u.username = :username";
		Map<String, Object> parameterMap = new HashMap<String, Object>();
		parameterMap.put("username", username);
		int count = this.queryForInt(hql, parameterMap);

		String returnStr = null;
		if (count > 0) {
			returnStr = "此用户已存在！";
		}
		return returnStr;
	}

	/**
	 * 重置指定用户密码
	 * 
	 * @param username
	 * @return
	 */
	@Expose
	public String resetPassword(String username) {
		Integer newPassword = (int) (Math.random() * 900000 + 100000);
		userService.changePassword(username, newPassword.toString());
		return newPassword.toString();
	}

	/**
	 * 设置指定用户为业务管理员
	 * 
	 * @param username
	 * @return
	 */
	@Expose
	public String saveUserAdmin(String username) {
		DefaultUser user = (DefaultUser) userService
				.loadUserByUsername(username);
		if (user == null)
			return "为查询到用户，请联系管理员！！";
		Session session = this.getSessionFactory().openSession();
		session.update(user);
		session.flush();
		session.close();
		return null;
	}

	@Expose
	public void insertUserPosition(String username, String ids) {
		Session session = this.getSessionFactory().openSession();
		try {
			session.createQuery(
					"delete " + UserPosition.class.getName()
							+ " u where u.username = :username")
					.setString("username", username).executeUpdate();

			if (StringUtils.isNotEmpty(ids)) {
				UserPosition userPosition;
				for (String id : ids.split(",")) {
					userPosition = new UserPosition();
					userPosition.setId(UUID.randomUUID().toString());
					userPosition.setPositionId(id);
					userPosition.setUsername(username);
					session.save(userPosition);
				}
			}
		} finally {
			session.flush();
			session.close();
		}
	}

	@Expose
	public void insertUserDept(String username, String ids) {
		Session session = this.getSessionFactory().openSession();
		try {
			session.createQuery(
					"delete " + UserDept.class.getName()
							+ " u where u.username = :username")
					.setString("username", username).executeUpdate();

			if (StringUtils.isNotEmpty(ids)) {
				UserDept userDept;
				for (String id : ids.split(",")) {
					userDept = new UserDept();
					userDept.setId(UUID.randomUUID().toString());
					userDept.setDeptId(id);
					userDept.setUsername(username);
					session.save(userDept);
				}
			}
		} finally {
			session.flush();
			session.close();
		}
	}

}