/*
 * Copyright [2020] [MaxKey of copyright http://www.maxkey.top]
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *     http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 

package org.maxkey.web.contorller;

import java.beans.PropertyEditorSupport;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.TreeSet;
import java.util.stream.Collectors;

import javax.validation.Valid;

import org.apache.mybatis.jpa.persistence.JpaPageResults;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.maxkey.constants.ConstantsOperateMessage;
import org.maxkey.constants.ConstantsPasswordSetType;
import org.maxkey.crypto.ReciprocalUtils;
import org.maxkey.entity.ExcelImport;
import org.maxkey.entity.UserInfo;
import org.maxkey.persistence.service.UserInfoService;
import org.maxkey.util.DateUtils;
import org.maxkey.util.ExcelUtils;
import org.maxkey.util.JsonUtils;
import org.maxkey.util.StringUtils;
import org.maxkey.web.WebContext;
import org.maxkey.web.message.Message;
import org.maxkey.web.message.MessageScope;
import org.maxkey.web.message.MessageType;
import org.maxkey.web.message.OperateType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.propertyeditors.CustomDateEditor;
import org.springframework.stereotype.Controller;
import org.springframework.util.CollectionUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.WebDataBinder;
import org.springframework.web.bind.annotation.InitBinder;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import com.google.common.collect.Lists;

/**
 * @author Crystal.Sea
 *
 */
@Controller
@RequestMapping(value = { "/userinfo" })
public class UserInfoController {
	final static Logger _logger = LoggerFactory.getLogger(UserInfoController.class);
	
	@Autowired
	@Qualifier("userInfoService")
	private UserInfoService userInfoService;

	
	/**
	 * 查询用户列表
	 * @param user
	 * @return
	 */
	@RequestMapping(value={"/grid"})
	@ResponseBody
	public JpaPageResults<UserInfo> forwardUsersList(@ModelAttribute("userInfo") UserInfo userInfo){
		return userInfoService.queryPageResults(userInfo);
		
	}
	
	@RequestMapping(value={"/forwardAdd"})
	public ModelAndView forwardSelectUserType(){
		ModelAndView modelAndView=new ModelAndView("/userinfo/userAdd");
		//List<UserType> userTypeList=userTypeService.query(null);
		//modelAndView.addObject("userTypeList", userTypeList);
		return modelAndView;
	}
	
	@RequestMapping(value={"/list"})
	public ModelAndView usersList(){
		return new ModelAndView("/userinfo/usersList");
	}
	
	@RequestMapping(value={"/select"})
	public ModelAndView usersSelect(){
		ModelAndView modelAndView= new ModelAndView("/userinfo/userinfoSelect");
		return modelAndView;
	}
	
	/**
	 * 新增
	 * @param userInfo
	 * @param result
	 * @return
	 */
	@RequestMapping(value="/add") 
	public ModelAndView addUsers(@Valid  @ModelAttribute("userInfo")UserInfo userInfo,BindingResult result) {
		_logger.debug(userInfo.toString());
		if(result.hasErrors()){
			// new Message(WebContext.getValidErrorText(),result);
		}
		
		userInfo.setId(WebContext.genId());
		//userInfo.setNameZHShortSpell(StringUtils.hanYu2Pinyin(userInfo.getDisplayName(), true));
		//userInfo.setNameZHSpell(StringUtils.hanYu2Pinyin(userInfo.getDisplayName(), false));
		if( userInfoService.insert(userInfo)) {
			  new Message(WebContext.getI18nValue(ConstantsOperateMessage.INSERT_SUCCESS),userInfo,MessageType.success,OperateType.add,MessageScope.DB);
		}
		
		 new Message(WebContext.getI18nValue(ConstantsOperateMessage.INSERT_ERROR),MessageType.error);
		return   WebContext.forward("forwardUpdate/"+userInfo.getId());
	}
	
	@RequestMapping(value={"/forwardUpdate/{id}"})
	public ModelAndView forwardUpdateUsers(@PathVariable("id")String id){
		ModelAndView modelAndView=new ModelAndView("/userinfo/userUpdate");
		UserInfo userInfo=userInfoService.get(id);
		if(userInfo.getPicture()!=null){
			WebContext.getSession().setAttribute(userInfo.getId(), userInfo.getPicture());
		}
		
		modelAndView.addObject("model", userInfo);
		return modelAndView;
	}

	/**
	 * 查询用户，根据id
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value="/getUsers/{id}") 
	public UserInfo getUserInfo(@PathVariable("id")String id) {
		_logger.debug(id);
		UserInfo userInfo = userInfoService.get(id);
		if(userInfo!=null&&userInfo.getDecipherable()!=null){
			try{
				userInfo.setPassword(ReciprocalUtils.decoder(userInfo.getDecipherable()));
			}catch (Exception e) {
			}
			userInfo.setDecipherable(userInfo.getPassword());
		}
		return userInfo;
	}
	
	
    @ResponseBody
    @RequestMapping(value = "/randomPassword")
    public String randomPassword() {
        return userInfoService.randomPassword();
    }
	   
	/**
	 * 修改用户
	 * @param userInfo
	 * @param result
	 * @return
	 */

	@RequestMapping(value="/update") 
	public ModelAndView updateUsers(@Valid  @ModelAttribute("userInfo")UserInfo userInfo,BindingResult result) {
		_logger.debug(userInfo.toString());
		if(result.hasErrors()){
			// new Message(WebContext.getValidErrorText(),result);
		}
		_logger.info(userInfo.getExtraAttributeName());
		_logger.info(userInfo.getExtraAttributeValue());
		//userInfo.setNameZHShortSpell(StringUtils.hanYu2Pinyin(userInfo.getDisplayName(), true));
		//userInfo.setNameZHSpell(StringUtils.hanYu2Pinyin(userInfo.getDisplayName(), false));
		convertExtraAttribute(userInfo) ;
		_logger.info(userInfo.getExtraAttribute());
		if(userInfoService.update(userInfo)) {
			new Message(WebContext.getI18nValue(ConstantsOperateMessage.UPDATE_SUCCESS),userInfo,MessageType.success,OperateType.add,MessageScope.DB);
			
		}
	    new Message(WebContext.getI18nValue(ConstantsOperateMessage.UPDATE_ERROR),MessageType.error);
		return   WebContext.forward("forwardUpdate/"+userInfo.getId());
	}
	
	
	/**
	 * 批量删除用户
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value="/batchDelete")  
	public Message batchDeleteUsers(@RequestParam("id")String id) {
		_logger.debug(id);
		if(userInfoService.batchDelete(StringUtils.string2List(id, ","))) {
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.DELETE_SUCCESS),MessageType.success);
			
		} else {
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.DELETE_ERROR),MessageType.error);
		}
	}
	
	/**
	 * 根据用户id删除用户
	 * 
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value="/delete")  
	public Message deleteUsersById(@RequestParam("id") String id) {
		_logger.debug(id);
		if(userInfoService.batchDelete(id)) {
			//provisioningPrepare.prepare(userInfo, OPERATEACTION.DELETE_ACTION);
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.DELETE_SUCCESS),MessageType.success);
		} else {
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.DELETE_ERROR),MessageType.error);
		}
	}
	
	protected void convertExtraAttribute(UserInfo userInfo) {
		if(userInfo.getExtraAttributeValue()!=null){
			String []extraAttributeLabel=userInfo.getExtraAttributeName().split(",");
			String []extraAttributeValue=userInfo.getExtraAttributeValue().split(",");
			Map<String,String> extraAttributeMap=new HashMap<String,String> ();
			for(int i=0;i<extraAttributeLabel.length;i++){
				extraAttributeMap.put(extraAttributeLabel[i], extraAttributeValue[i]);
			}
			String extraAttribute=JsonUtils.object2Json(extraAttributeMap);
			userInfo.setExtraAttribute(extraAttribute);
		}
	}
	
	@RequestMapping(value={"/forwardChangePassword/{id}"})
	public ModelAndView forwardChangePassword(@PathVariable("id")String id){
		ModelAndView modelAndView=new ModelAndView("/userinfo/changePassword");
		UserInfo userInfo=userInfoService.get(id);
		
		modelAndView.addObject("model", userInfo);
		return modelAndView;
	}
	
	@RequestMapping(value={"/forwardChangeUserinfoStatus/{id}"})
	public ModelAndView forwardChangeUserinfoStatus(@PathVariable("id")String id){
		ModelAndView modelAndView=new ModelAndView("/userinfo/changeUserinfoStatus");
		UserInfo userInfo=userInfoService.get(id);
		
		modelAndView.addObject("model", userInfo);
		return modelAndView;
	}
	
	@ResponseBody
	@RequestMapping(value="/changePassword")  
	public Message changePassword( @ModelAttribute("userInfo")UserInfo userInfo) {
		_logger.debug(userInfo.getId());
		userInfo.setPasswordSetType(ConstantsPasswordSetType.PASSWORD_NORMAL);
		if(userInfoService.changePassword(userInfo,true)) {
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.UPDATE_SUCCESS),MessageType.success);
			
		} else {
			return  new Message(WebContext.getI18nValue(ConstantsOperateMessage.UPDATE_ERROR),MessageType.error);
		}
	}
	
    @RequestMapping(value = "/import")
    public ModelAndView importing(@ModelAttribute("excelImportFile")ExcelImport excelImportFile)  {
        if (excelImportFile.isExcelNotEmpty() ) {
            try {
                int columnSize = 46;
                List<UserInfo> userInfoList = Lists.newArrayList();
                Workbook workbook = excelImportFile.biuldWorkbook();
                int recordCount = 0;
                int sheetSize = workbook.getNumberOfSheets();
                //遍历sheet页
                for (int i = 0; i < sheetSize; i++) {
                    Sheet sheet = workbook.getSheetAt(i);
                    int rowSize = sheet.getLastRowNum() + 1;
                    for (int j = 1; j < rowSize; j++) {//遍历行
                        Row row = sheet.getRow(j);
                        if (row == null || j <3 ) {//略过空行和前3行
                            continue;
                        } else {//其他行是数据行
                            UserInfo userInfo = new UserInfo();
                            userInfo.setCreatedDate(DateUtils.formatDateTime(new Date()));
                            
                            for (int k = 0; k < columnSize; k++) {
                            	Cell cell = row.getCell(k);
                                if (k == 0) {// 登录账号
                                    userInfo.setUsername(ExcelUtils.getValue(cell));
                                } else if (k == 1) {// 密码
                                    userInfo.setPassword(ExcelUtils.getValue(cell));
                                } else if (k == 2) {// 用户显示
                                    userInfo.setDisplayName(ExcelUtils.getValue(cell));
                                } else if (k == 3) {// 姓
                                    userInfo.setFamilyName(ExcelUtils.getValue(cell));
                                } else if (k == 4) {// 名
                                    userInfo.setGivenName(ExcelUtils.getValue(cell));
                                } else if (k == 5) {// 中间名
                                    userInfo.setMiddleName(ExcelUtils.getValue(cell));
                                } else if (k == 6) {// 昵称
                                    userInfo.setNickName(ExcelUtils.getValue(cell));
                                } else if (k == 7) {// 性别
                                    String gender = ExcelUtils.getValue(cell);
                                    userInfo.setGender(gender.equals("")? 1 : Integer.valueOf(ExcelUtils.getValue(cell)));
                                } else if (k == 8) {// 语言偏好
                                    userInfo.setPreferredLanguage(ExcelUtils.getValue(cell));
                                } else if (k == 9) {// 时区
                                    userInfo.setTimeZone(ExcelUtils.getValue(cell));
                                } else if (k == 10) {// 用户类型
                                    userInfo.setUserType(ExcelUtils.getValue(cell));
                                } else if (k == 11) {// 员工编码
                                    userInfo.setEmployeeNumber(ExcelUtils.getValue(cell));
                                } else if (k == 12) {// AD域账号
                                    userInfo.setWindowsAccount(ExcelUtils.getValue(cell));
                                }else if (k == 13) {// 所属机构
                                    userInfo.setOrganization(ExcelUtils.getValue(cell));
                                }else if (k == 14) {// 分支机构
                                    userInfo.setDivision(ExcelUtils.getValue(cell));
                                }else if (k == 15) {// 部门编号
                                    userInfo.setDepartmentId(ExcelUtils.getValue(cell));
                                }else if (k == 16) {// 部门名称
                                    userInfo.setDepartment(ExcelUtils.getValue(cell));
                                }else if (k == 17) {// 成本中心
                                    userInfo.setCostCenter(ExcelUtils.getValue(cell));
                                }else if (k == 18) {// 职位
                                    userInfo.setJobTitle(ExcelUtils.getValue(cell));
                                }else if (k == 19) { // 级别
                                    userInfo.setJobLevel(ExcelUtils.getValue(cell));
                                }else if (k == 20) {// 上级经理
                                    userInfo.setManager(ExcelUtils.getValue(cell));
                                }else if (k == 21) {// 助理
                                    userInfo.setAssistant(ExcelUtils.getValue(cell));
                                }else if (k == 22) {// 入职时间
                                    userInfo.setEntryDate(ExcelUtils.getValue(cell));
                                }else if (k == 23) {
                                    // 离职时间
                                    userInfo.setQuitDate(ExcelUtils.getValue(cell));
                                }else if (k == 24) {// 工作-国家
                                    userInfo.setWorkCountry(ExcelUtils.getValue(cell));
                                }else if (k == 25) {// 工作-省
                                    userInfo.setWorkRegion(ExcelUtils.getValue(cell));
                                }else if (k == 26) {// 工作-城市
                                    userInfo.setTimeZone(ExcelUtils.getValue(cell));
                                }else if (k == 27) {// 工作-地址
                                    userInfo.setWorkLocality(ExcelUtils.getValue(cell));
                                }else if (k == 28) {// 邮编
                                    userInfo.setWorkPostalCode(ExcelUtils.getValue(cell));
                                }else if (k == 29) {// 传真
                                    userInfo.setWorkFax(ExcelUtils.getValue(cell));
                                }else if (k == 30) {// 工作电话
                                    userInfo.setWorkPhoneNumber(ExcelUtils.getValue(cell));
                                }else if (k == 31) {// 工作邮件
                                    userInfo.setWorkEmail(ExcelUtils.getValue(cell));
                                }else if (k == 32) {// 证件类型 todo 现在数据库中存储的是tinyint
//                                    userInfo.setIdType(ExcelUtils.getValue(cell));
                                }else if (k == 33) {// 证件号码
                                    userInfo.setIdCardNo(ExcelUtils.getValue(cell));
                                } else if (k == 34) {
                                    // 出生日期
                                    userInfo.setBirthDate(ExcelUtils.getValue(cell));
                                }else if (k == 35) {// 婚姻状态 todo 现在数据字段类型是 tinyint
//                                    userInfo.setMarried(ExcelUtils.getValue(cell));
                                }else if (k == 36) {// 开始工作时间
                                    userInfo.setStartWorkDate(ExcelUtils.getValue(cell));
                                }else if (k == 37) {// 个人主页
                                    userInfo.setWebSite(ExcelUtils.getValue(cell));
                                }else if (k == 38) {// 即时通讯
                                    userInfo.setDefineIm(ExcelUtils.getValue(cell));
                                }else if (k == 39) {// 国家
                                    userInfo.setHomeCountry(ExcelUtils.getValue(cell));
                                }else if (k == 40) {// 省
                                    userInfo.setHomeRegion(ExcelUtils.getValue(cell));
                                }else if (k == 41) {// 城市
                                    userInfo.setHomeLocality(ExcelUtils.getValue(cell));
                                }else if (k == 42) {// 家庭地址
                                    userInfo.setHomeStreetAddress(ExcelUtils.getValue(cell));
                                }else if (k == 43) {// 家庭邮编
                                    userInfo.setHomePostalCode(ExcelUtils.getValue(cell));
                                }else if (k == 44) {// 家庭传真
                                    userInfo.setHomeFax(ExcelUtils.getValue(cell));
                                }else if (k == 45) {// 家庭电话
                                    userInfo.setHomePhoneNumber(ExcelUtils.getValue(cell));
                                }else if (k == 46) {// 家庭邮箱
                                    userInfo.setHomeEmail(ExcelUtils.getValue(cell));
                                }
                            }
                            userInfo.setStatus(1);
                            userInfoList.add(userInfoService.passwordEncoder(userInfo));
                            recordCount ++;
                            _logger.debug("record {} user {} account {}",recordCount,userInfo.getDisplayName(),userInfo.getUsername());
                        }
                    }
                }
                // 数据去重
                if(!CollectionUtils.isEmpty(userInfoList)){
                    userInfoList = userInfoList.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(o -> o.getUsername()))), ArrayList::new));
                    if( userInfoService.batchInsert(userInfoList)) {
                    	new Message(WebContext.getI18nValue(ConstantsOperateMessage.INSERT_SUCCESS), null, MessageType.success, OperateType.add, MessageScope.DB);
                    }else {
                    	new Message(WebContext.getI18nValue(ConstantsOperateMessage.INSERT_ERROR), MessageType.error);
                    }
                }
            } catch (IOException e) {
                e.printStackTrace();
            }finally {
            	excelImportFile.closeWorkbook();
            }
        }else {
        	new Message(WebContext.getI18nValue(ConstantsOperateMessage.INSERT_ERROR), MessageType.error);
        }
        
        return new ModelAndView("/userinfo/usersImport");
    }
    
	@InitBinder
	public void binder(WebDataBinder binder) {
		binder.registerCustomEditor(String.class, new PropertyEditorSupport() {
		    @Override
			public void setAsText(String value) {
		        	if(StringUtils.isEmpty(value)){
		        		setValue(null);
		        	}else{
		        		setValue(value);
		        	}
		    }

		    
		});
		 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
	        dateFormat.setLenient(false);  
	        binder.registerCustomEditor(Date.class, new CustomDateEditor(dateFormat, true));
	}
	

}