package com.slcf.service.impl;

import java.io.IOException;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.poi.hssf.usermodel.HSSFCell;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.ss.util.CellRangeAddress;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import com.slcf.dao.UserDao;
import com.slcf.pojo.UserBean;
import com.slcf.service.UserService;

@Service
public class UserServiceImpl implements UserService{

	@Resource
	UserDao userDao;
	
	/**
	 * 分页查询所以user信息
	 * @param spage
	 * @param epage
	 * @return
	 */
	public Map<String,Object> getUserList(int pageNumber, int pageSize) {
		Map<String,Object>map=new HashMap<String, Object>();
		try {
			int count = userDao.getUserCount();
			// List<UserBean>ulist=userDao.getUserList((pageNumber-1)*pageSize,
			// pageNumber*pageSize);
			List<UserBean> ulist = userDao.getUserList((pageNumber - 1) * pageSize, pageSize);
			map.put("total", count);
			map.put("rows", ulist);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}

	/**
	 * 修改用户密码
	 */
	public int upPass(int uid, String pass,HttpServletRequest request) {
		int i=0;
		try {
			i = userDao.upPass(uid, pass);
			// String name=(String)request.getSession().getAttribute("NAME");
			// if(i>0){
			// j=userDao.insertUserOpt(uid, "修改", name);
			// }
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return i;
	}

	/**
	 * 验证用户登录账号是否唯一
	 */
	public boolean validUserAccount(String account, int uid) {
		boolean flag=true;
		try {
			List<UserBean> ulist = userDao.getUserByAccount(account);
			if (uid != 0) {// 修改
				if (ulist.size() == 1 && ulist.get(0).getUser_id() == uid) {
					flag = true;
				} else if (ulist.size() == 0) {
					flag = true;
				} else {
					flag = false;
				}
			} else {// 添加
				if (ulist.size() > 0) {
					flag = false;
				}
			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return flag;
	}

	/**
	 * 添加用户信息
	 */
	public int saveUser(UserBean user,HttpServletRequest request) {		
		int i=0;
		try {
			i = userDao.saveUser(user);
//			String name = (String) request.getSession().getAttribute("NAME");
			if (i > 0) {
				List<UserBean> list = userDao.getUserByAccount(user.getUser_account());
				int x = userDao.saveUserRole(list.get(0).getUser_id(), 1);// 默认是普通员工
				// j=userDao.insertUserOpt(list.get(0).getUser_id(), "添加", name);
				if (x == 1) {
					i = 1;
				} else {
					i = 0;
				}
			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return i;
	}

	/**
	 * 删除用户
	 */
	public int delUser(int uid) {
		int i = 0;
		try {
			i = userDao.delUser(uid);
			userDao.delUserRoleByUid(uid);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return i;
	}

	/**
	 * 根据用户id查询用户信息
	 * @param id
	 * @return
	 */
	public UserBean queryUserById(int id) {
		UserBean user=new UserBean();
		try {
			user = userDao.queryUserById(id);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return user;
	}

	/**
	 * 修改用户
	 * @param user
	 * @return
	 */
	public int upUser(UserBean user,HttpServletRequest request) {
//		String name=(String)request.getSession().getAttribute("NAME");
//		int j=0;
		int i = 0; 
		try {
			i = userDao.upUser(user);
//			if (i > 0) {
//				j = userDao.insertUserOpt(user.getUser_id(), "修改", name);
//			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return i;
	}

	/**
	 * 批量删除用户
	 */
	public int delUsers(int[] ids) {
		int sum=0;
		int y=0;
		try {
			for (int i = 0; i < ids.length; i++) {
				// int j=userDao.delUserOpt(ids[i]);
				// if(j>0){
				int x = userDao.delUser(ids[i]);
				userDao.delUserRoleByUid(ids[i]);
				sum += x;
				// }
			}
			if (sum == ids.length) {
				y = 1;
			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return y;
	}

	public List<Integer> getUserRole(int uid) {
		try {
			List<Integer> list=userDao.getUserRole(uid);
			return list;
		}catch (Exception e) {
			System.out.println(e.getMessage());
			return null;
		}		
	}

	
	public boolean saveUserRole(int uid, String ridStr) {
		boolean flag=false;
		try {
			int sum = 0, x = 0;
			int count = userDao.getCount(uid);
			if (count >= 1) {
				x = userDao.delUserRoleByUid(uid);
			}
			if (count >= 1 && x > 0 || count == 0) {
				if (ridStr.contains(",")) {
					String idStrs[] = ridStr.split(",");
					int ids[] = new int[idStrs.length];
					for (int i = 0; i < idStrs.length; i++) {
						ids[i] = Integer.parseInt(idStrs[i]);
					}
					for (Integer s : ids) {
						int j = userDao.saveUserRole(uid, s);
						sum += j;
					}
					if (sum == ids.length) {
						flag = true;
					}
				} else {
					int y = userDao.saveUserRole(uid, Integer.parseInt(ridStr));
					if (y > 0) {
						flag = true;
					}
				}
			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return flag;
	}

	public void ExportUserList(HttpServletResponse response) {
		//输出Excel文件  
	    try {
			//HSSFWorkbook对象(excel的文档对象)  
			HSSFWorkbook workBook=new HSSFWorkbook();
			
			//sheet对象（excel的表单）
			HSSFSheet sheet=workBook.createSheet("用户表信息");
			
			//行数，参数为行索引(excel的行)
			HSSFRow rowHead=sheet.createRow(0);//第一行  可以是0～65535之间的任何一个
			
			//创建excel的单元格，参数为列索引，可以是0～255之间的任何一个 
			HSSFCell cellOne=rowHead.createCell(0);
			cellOne.setCellValue("用户信息");//表头
			
			//合并单元格CellRangeAddress构造参数依次表示起始行，截至行，起始列， 截至列  
			sheet.addMergedRegion(new CellRangeAddress(0,0,0,9));
			
			HSSFRow rows=sheet.createRow(1);//第二行
			//创建单元格并设置单元格内容
			rows.createCell(0).setCellValue("用户编号");
			rows.createCell(1).setCellValue("登陆账号");
			rows.createCell(2).setCellValue("用户姓名");
			rows.createCell(3).setCellValue("用户年龄");
			rows.createCell(4).setCellValue("用户性别");
			rows.createCell(5).setCellValue("用户地址");
			rows.createCell(6).setCellValue("出生日期");
			rows.createCell(7).setCellValue("Email");
			rows.createCell(8).setCellValue("联系电话");
			rows.createCell(9).setCellValue("所属部门");
		
			List<UserBean>userList=userDao.queryUserList();
			for(int i=0;i<userList.size();i++){
				HSSFRow row=sheet.createRow(i+2);//从第三行开始
				//创建单元格并设置单元格内容
				row.createCell(0).setCellValue(userList.get(i).getUser_id());
				row.createCell(1).setCellValue(userList.get(i).getUser_account());
				row.createCell(2).setCellValue(userList.get(i).getUser_name());
				row.createCell(3).setCellValue(userList.get(i).getUser_age());
				row.createCell(4).setCellValue(userList.get(i).getUser_sex());
				row.createCell(5).setCellValue(userList.get(i).getUser_address());
				row.createCell(6).setCellValue(userList.get(i).getUser_birth());
				row.createCell(7).setCellValue(userList.get(i).getEmail());
				row.createCell(8).setCellValue(userList.get(i).getUser_phone());
				row.createCell(9).setCellValue(userList.get(i).getDept_name());
			}
//		//输出Excel文件  
//	    try {
			OutputStream output=response.getOutputStream();
			response.reset();  
		    response.setHeader("Content-disposition", "attachment; filename=userinfo.xls");  
		    response.setContentType("application/msexcel");          
		    workBook.write(output);  
		    output.close();
		} catch (IOException e) {
			e.printStackTrace();
		}  
	     
	}

	public Map<String,Object> importExcel(MultipartFile file) {
		List<UserBean>userList=new ArrayList<UserBean>();
		Map<String,Object>map=new HashMap<String, Object>();
		int x=0,y=0,sum=0;
		boolean flag=false;
		if(file!=null){
			//根据指定的文件输入流导入Excel从而产生Workbook对象  
			try {
				Workbook workBook=new HSSFWorkbook(file.getInputStream());
				//获取Excel文档中的第一个表单
				Sheet sheet=workBook.getSheetAt(0);
				//对Sheet中的每一行进行迭代  
	    		for (Row r : sheet) {  
	    		//如果当前行的行号（从0开始）未达到2（第三行）则从新循环  
	    		if(r.getRowNum()<2){  
	    		      continue;  
	    		     } 
	    		
	    		UserBean user=new UserBean();
	    		user.setUser_account(r.getCell(0).getStringCellValue());
	    		user.setUser_name(r.getCell(1).getStringCellValue());
	    		user.setUser_password(r.getCell(2).getStringCellValue());
	    		user.setUser_address(r.getCell(3).getStringCellValue());
	    		user.setUser_phone(r.getCell(4).getStringCellValue());
	    		userList.add(user);
	    		}
			} catch (IOException e) {
				e.printStackTrace();
			}
			
			
			y=userList.size();
			for(UserBean u:userList){
				List<UserBean> user=userDao.getUserByAccount(u.getUser_account());
				if(user!=null&&user.size()>0){
					x++;
				}else{
					int i=userDao.saveUser(u);
					sum+=i;
				}
			}
			if(sum==(y-x)){
				flag=true;
			}
		}
		map.put("msg", "共有"+y+"条数据,成功导入"+sum+"条数据,登陆账号重名的数据有"+x+"条");
		map.put("flag", flag);
		return map;
	}

	public Map<String, Object> getUserListByCon(int spage, int epage, int userId, String userName, int deptId) {
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			List<UserBean> userList = userDao.getUserListByCon(spage, epage, userId, userName, deptId);
			int count = userDao.getContByCon(userId, userName, deptId);
			map.put("rows", userList);
			map.put("total", count);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}

	public Map<String, Object> getHightsInfo() {
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			List<UserBean> nanlist = userDao.getUserCharNan();
			List<UserBean> nvList = userDao.getUserCharNv();
			int naninfo[] = new int[12];
			int nvinfo[] = new int[12];
			// 男
			for (UserBean u : nanlist) {// 数据库月份信息
				String str[] = u.getMon().split("-");
				int j = Integer.parseInt(str[1]);
				for (int i = 1; i <= 12; i++) {
					if (j == i) {
						naninfo[i - 1] = u.getNum();
					}
				}
			}

			for (UserBean u : nvList) {// 数据库月份信息
				String str[] = u.getMon().split("-");
				int j = Integer.parseInt(str[1]);
				for (int i = 1; i <= 12; i++) {
					if (j == i) {
						nvinfo[i - 1] = u.getNum();
					}
				}
			}
			map.put("naninfo", naninfo);
			map.put("nvinfo", nvinfo);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
}