package com.cloud.user.service.impl;


import com.alibaba.fastjson.JSONObject;
import com.cloud.common.constants.GlobalDict;
import com.cloud.common.model.FileInfos;
import com.cloud.common.utils.*;
import com.cloud.model.common.Page;
import com.cloud.model.sys.*;
import com.cloud.model.sys.constants.CredentialType;
import com.cloud.user.constants.EmpTypeConstant;
import com.cloud.user.dao.*;
import com.cloud.user.model.BbFace;
import com.cloud.user.service.BbEmployeeService;
import com.cloud.user.service.TokenService;
import com.cloud.user.utils.EnumStr;
import com.cloud.user.utils.FaceUtil;
import com.cloud.user.vo.BbEmployeeRelationVO;
import com.cloud.user.vo.BbEmployeeVO;
import lombok.extern.log4j.Log4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.*;
import java.util.List;

/**
 * 人员
 * 业务层
 */
@Log4j
@Service
public class BbEmployeeServiceImpl implements BbEmployeeService {
	
	@Autowired
	private BbEmployeeDao dao;
	@Autowired
	private SysOrganizationDao orgDao;
	@Autowired
	private BbFaceDao bbFaceDao;
//	@Autowired
//	private SysOrganizationService orgService;
	@Autowired
	private BbEmployeeRelationDao brDao;
	@Autowired
	private TokenService tokenService;
	@Autowired
	private RestTemplateUtil restTemplateUtil;
    @Autowired
    private UserRoleDao userRoleDao;
	@Autowired
	private EnumStr enumStr;
    @Autowired
	private AppUserDao userDao;
    @Autowired
    private UserCredentialsDao userCredentialsDao;
    @Autowired
    private FastDFSUtil fastDFSUtil;

	/**
	 * 根据主键查询
	 * @param orgId
	 */
	@Override
	public BbEmployee findById(String id, Long orgId) {
		Map<String, Object> params = new HashMap<String, Object>();
		params.put("id", id);
		if (orgId != null && !"".equals(orgId)) {
			params.put("orgId", orgId);
		}
		return dao.findById(params);
	}
	
	/**
	 * 根据主键删除
	 * @param params
	 */
	@Override
	public Map<String,Object> deleteById(Map<String, Object> params) {
		Map<String,Object> map = new HashMap<String,Object>();
		Integer status = dao.deleteById(params);
		if(status > 0){
			//同时逻辑删除人脸ID
			//bbFaceDao.deleteByUserId(params);
			//delete 删除人脸ID
			//bbFaceDao.deleteByUserId((String) params.get("id"));
			dao.deleteMergePerson((String) params.get("id"));
			map.put("code","0");
			map.put("message","删除成功！！！");
		}else{
			map.put("code","1");
			map.put("message","删除失败！！！");
		}
		return map;
	}

	@Override
	public Map<String, Object> deleteByIdFromTemp(String id) {
		Map<String,Object> map = new HashMap<String,Object>();
		Integer status = dao.deleteByIdFromTemp(id);
		if(status > 0){

			bbFaceDao.deleteByUserId(id);
			map.put("code","0");
			map.put("message","删除成功！！！");
		}else{
			map.put("code","1");
			map.put("message","删除失败！！！");
		}
		return map;
	}

	/**
	 * 添加, 没有业务
	 */
	@Override
	public Integer add(BbEmployee bean) {
//		bean.preInsert(tokenService.currentUser());
//		if (bean.getOrgNamesJson() == null || "".equals(bean.getOrgNamesJson())) {
//			bean.setOrgNamesJson("{}");
//		}
//		if (bean.getRevJson1() == null || "".equals(bean.getRevJson1())) {
//			bean.setRevJson1("{}");
//		}
		return 0;
	}

    @Override
    public Map isRepeatIdCard(Map<String,Object> param) {
        Map<String,Object> map = new HashMap<String,Object>();
        int count = dao.isRepeatIdCard(param);
        if(count==0){
            map.put("code","0");
            map.put("message","底库无此身份证号，可以使用！");
        }else{
            map.put("code","1");
            map.put("message","跟底库已有的身份证号重复！");
        }
        return map;
    }

    @Override
    public JSONObject clusterLocaltion(String clusterIds) {
        JSONObject paramMap = new JSONObject();
        paramMap.put("clusterIds",clusterIds);
        String post = restTemplateUtil.post(enumStr.getClusterLocaltion(), paramMap , MediaType.APPLICATION_JSON_UTF8, true);
        JSONObject jsonMap = JSONObject.parseObject(post);
        return jsonMap;
    }

    @Override
	public JSONObject singleEdit(MultipartFile file,String exPersonId) {
		FileInfos fileInfos = fastDFSUtil.upload(file);
		JSONObject paramMap = new JSONObject();
		paramMap.put("fileInfos",fileInfos);
		paramMap.put("exPersonId",exPersonId);
		Long time = System.currentTimeMillis();
		String post = restTemplateUtil.postImg(enumStr.getSingleEdit(), paramMap, MediaType.APPLICATION_JSON_UTF8,String.class, true );
		System.out.println("往返时间是"+(System.currentTimeMillis()-time)+"毫秒");
		JSONObject jsonMap = JSONObject.parseObject(post);
		System.out.println("返回的结果是"+JSONObject.parseObject(post) );
		return jsonMap;
	}

	/**
	 * 编辑， 没有业务
	 */
	@Override
	public BbEmployee update(BbEmployee bean) {
		bean.preUpdate(tokenService.currentUser());
		// 查找要编辑的数据库实体
		BbEmployee dbBean = findById(bean.getId(), bean.getOrgId());
		
		// 设置要修改的属性
		dbBean.setOfficeId(bean.getOfficeId());                     //部门Id
		dbBean.setCardId(bean.getCardId());                         //身份证号
		dbBean.setName(bean.getName());                             //姓名
		dbBean.setGender(bean.getGender());                         //性别
		dbBean.setNation(bean.getNation());                         //民族
		dbBean.setPhone(bean.getPhone());                           //电话
		dbBean.setType(bean.getType());                             //人员类型（学生、职工、校外）
		dbBean.setOrgNamesJson(bean.getOrgNamesJson());             //组织结构名称冗余
		dbBean.setPhotos(bean.getPhotos());                         //人员照片（格式
		dbBean.setFaceIds(bean.getFaceIds());                       //人脸Id(格式
		dbBean.setRemarks(bean.getRemarks());                       //备注信息
		dbBean.setRevJson1(bean.getRevJson1());                     //预留json格式字段1
		
		dao.update(dbBean);
		return dbBean;
	}

	
	/**
	 * 添加，包含业务
	 */
	@Transactional
	@Override
	public JSONObject addBbEmployee(MultipartFile[] files,Integer orgId,Integer officeId) {

		List<FileInfos> list = new ArrayList<>();
		//JSONArray jsonArray = new JSONArray();
		for (MultipartFile file : files) {
			FileInfos fileInfos = fastDFSUtil.upload(file);
			list.add(fileInfos);
		//	jsonArray.add(fileInfos);
		}

		JSONObject paramMap = new JSONObject();
		paramMap.put("list",list);     ///   wp  修改
		if(orgId == null || officeId == null ){
            LoginAppUser appUser = tokenService.currentUser();
            orgId = Integer.valueOf(appUser.getOrgId().toString());
            officeId = appUser.getOfficeId();
        }
		paramMap.put("orgId",orgId);
		paramMap.put("officeId",officeId);
		Long time = System.currentTimeMillis();
		String post = restTemplateUtil.postImg(enumStr.getUploadImgUrl(), paramMap, MediaType.APPLICATION_JSON_UTF8,String.class, true );
		System.out.println("往返时间是"+(System.currentTimeMillis()-time)+"毫秒");
		JSONObject jsonMap = JSONObject.parseObject(post);
		System.out.println("返回的结果是"+JSONObject.parseObject(post));
		return jsonMap;
	}

	/**
	 * 添加人员关系
	 * @return
	 */
	private Integer addEmpRelations(List<BbEmployeeRelationVO> list,BbEmployeeVO bbEmployeeVO){
		Integer state = 0;
		if(list.size() > 0){
			for(BbEmployeeRelationVO bbEmployeeRelationVO:list){
				bbEmployeeRelationVO.setOrgId(bbEmployeeVO.getOrgId());
				bbEmployeeRelationVO.setEmployeeId(bbEmployeeVO.getId());
				bbEmployeeRelationVO.preInsert(tokenService.currentUser());
				state = brDao.add(bbEmployeeRelationVO);
			}
		}
		return state;
	}

	/**
	 * 编辑，包含业务
	 */
	@Transactional
	@Override
	public void updateBbEmployee(BbEmployeeVO beanVO) {
		// 查找要编辑的数据库实体
		BbEmployee dbBean = findById(beanVO.getId(), beanVO.getOrgId());
		if(dbBean.getPhotos()!=null&&!dbBean.getPhotos().equals(beanVO.getPhotos())){
			Map<String,Object> params = new HashMap<>();
			params.put("id",beanVO.getId());
			params.put("orgId",beanVO.getOrgId());
			bbFaceDao.deleteByUserId((String) params.get("id"));
			//根据图片路径获得人脸ID
			try {
				byte[] bytesFaces = ReadUrlImg.getImgByte(imgHttpUrl+beanVO.getPhotos());
				//获取人脸特征
				String faces = FaceUtil.extractFeature(bytesFaces,null);
				//人脸特征不为空时
				if(faces!=null&&!faces.isEmpty()){
					Integer bbFaciId = bbFaceDao.findIdByFaces(faces);
					if(bbFaciId == null){
						BbFace bbFace = new BbFace();
						bbFace.setOrgId(beanVO.getOrgId());
						bbFace.setFeature(faces);
						bbFaceDao.save(bbFace);
						beanVO.setFaceIds(bbFace.getId().toString());
					}
				}else{
					beanVO.setFaceIds("");
				}
			}catch (IOException e){
				System.out.println(e.getMessage());
			}
		}

		beanVO.preUpdate(tokenService.currentUser());
		dao.updateBbEmpId(beanVO);
	}

    @Transactional
	@Override
	public void saveTemp(BbEmployee bean, String isMerge, String mergeFrom, String roleId) {
			//保存角色信息，如果有的话(每次都删除原有的再绑定新的角色)
			if(roleId!=null&&!"".equals(roleId)){
			    //判断用户名是否存在
                UserCredential userCredential = userCredentialsDao.findByUsername(bean.getUserName(),bean.getUserId());
                if (userCredential != null) {
                    throw new IllegalArgumentException("用户名已存在");
                }
				//删除旧的用户角色关联
				Map paramMap = new HashMap();
				paramMap.put("id",bean.getUserId());
				userRoleDao.deleteUserRole(paramMap);
                //创建一个新用户
                if(bean.getUserName()!=null){
                    Map bbperson = dao.anyThingToUpdate(bean.getId());
                    if(bbperson==null){
                        //证明在底库没有找到，去临时库找一下
                        bbperson = dao.tempToUpdate(bean.getId());
                    }

                    AppUser user = null;
                    if(bbperson.get("userId")!=null&&!bbperson.get("userId").equals("")){
                        Map map = new HashMap<>();
                        map.put("id",(int)bbperson.get("userId"));
                        user = userDao.findById(map);
                    }else{
                        user = new AppUser();
                    }
                    user.setUsername(bean.getUserName());
                    user.setPassword(MD5Util.encode("000000"));
                    user.setOrgId(bean.getOrgId());
                    user.setEnabled(Boolean.TRUE);
                    user.setOfficeId(bean.getOfficeId().intValue());
                    if(tokenService.currentUser()!=null){
                        user.preInsert(tokenService.currentUser());
                    }
                    userDao.save(user);
                    //添加用户凭证，不清楚添加的必要，但有用的地方
                    Long uid = user.getId();
                    userCredentialsDao.save(new UserCredential(user.getUsername(), CredentialType.USERNAME.name(), uid,user.getOrgId()));
                    bean.setUserId(user.getId());
                    log.info("新创建的用户id是"+user.getId());
                    //建立新的用户角色关联
                    String[] roleIds = roleId.split(",");
                    for (String id : roleIds) {
                        Map paramMap1 = new HashMap();
                        Map paramMap2 = new HashMap();
                        paramMap2.put("id",bean.getId());
                        paramMap1.put("userId",user.getId());
                        paramMap1.put("roleId",Integer.valueOf(id));
                        paramMap1.put("orgId",bean.getOrgId());
                        userRoleDao.saveUserRoles(paramMap1);
                    }
                }
			}else{
                Map bbperson = dao.anyThingToUpdate(bean.getId());
                if(bbperson==null){
                    //证明在底库没有找到，去临时库找一下
                    bbperson = dao.tempToUpdate(bean.getId());
                }

                if(bbperson.get("userId")!=null&&!bbperson.get("userId").equals("")){
                    Map paramMap = new HashMap();
                    paramMap.put("id",bean.getUserId());
                    userRoleDao.deleteUserRole(paramMap);
                }
            }
			//去人员添加模块保存人员信息
			JSONObject paramMap = new JSONObject();
			paramMap.put("bean",bean);
			paramMap.put("isMerge",isMerge);
			paramMap.put("mergeFrom",mergeFrom);
			String post = restTemplateUtil.post(enumStr.getEditToSave(), paramMap, MediaType.APPLICATION_JSON_UTF8, true);

	}

	@Override
	public void saveUpload(BbEmployee bean, String isMerge, String mergeFrom) {
//        if(roleId!=null&&!"".equals(roleId)){
//            //删除旧的用户角色关联
//            Map paramMap = new HashMap();
//            paramMap.put("id",bean.getUserId());
//            userRoleDao.deleteUserRole(paramMap);
//            //创建一个新用户
//            if(bean.getUserName()!=null){
//                AppUser user = new AppUser();
//                user.setUsername(bean.getUserName());
//                if(tokenService.currentUser()!=null){
//                    user.preInsert(tokenService.currentUser());
//                }
//                userDao.save(user);
//                bean.setUserId(user.getId());
//                log.info("新创建的用户id是"+user.getId());
//                //建立新的用户角色关联
//                String[] roleIds = roleId.split(",");
//                for (String id : roleIds) {
//                    Map paramMap1 = new HashMap();
//                    Map paramMap2 = new HashMap();
//                    paramMap2.put("id",bean.getId());
//                    paramMap1.put("userId",user.getId());
//                    paramMap1.put("roleId",Integer.valueOf(id));
//                    paramMap1.put("orgId",bean.getOrgId());
//                    userRoleDao.saveUserRoles(paramMap1);
//                }
//            }
//        }
		//去人员添加模块保存人员信息
		JSONObject paramMap = new JSONObject();

		paramMap.put("bean",bean);
		paramMap.put("isMerge",isMerge);
		paramMap.put("mergeFrom",mergeFrom);
		//String url="http://192.168.1.203:3697/addPerson/save";
		String post = restTemplateUtil.post(enumStr.getUploadToSave(), paramMap, MediaType.APPLICATION_JSON_UTF8, true);
	}
    @Transactional
    @Override
    public String anyThingToSave(BbEmployee bean, String roleId) {
		String isNewAppUser = null;  //   修改时初始人员 需要给定 密码
		Map bbperson = null;long userId = 0;
		if(bean.getId()!=null&&!"".equals(bean.getId())){
			 bbperson = dao.anyThingToUpdate(bean.getId());
			if(bbperson.get("userId")!=null){
				userId = Long.valueOf(""+bbperson.get("userId"));
			}
		}
                //判断用户名是否存在
		if(bean.getUserName()!=null){
                UserCredential userCredential = userCredentialsDao.findByUsername(bean.getUserName(),userId);
				if (userCredential != null) {
                    throw new IllegalArgumentException("用户名已存在.");
                }
		}
		try{
			if(bean.getId()!=null&&!"".equals(bean.getId())){
				log.info("保存用户信息");
				if(roleId!=null&&!"".equals(roleId)){
					//删除旧的用户角色关联
					Map paramMap = new HashMap();
					paramMap.put("id",bean.getUserId());
					userRoleDao.deleteUserRole(paramMap);
					//创建一个新用户
					if(bean.getUserName()!=null){
//                        Map bbperson = dao.anyThingToUpdate(bean.getId());
						AppUser user = new AppUser();
                            user.setOrgId(bean.getOrgId());
                            user.setEnabled(Boolean.TRUE);
                            user.setOfficeId(bean.getOfficeId().intValue());
                            if(tokenService.currentUser()!=null){
                                user.preUpdate(tokenService.currentUser());
                            }
						if(bbperson.get("userId")!=null&&!bbperson.get("userId").equals("")){
                            Map map = new HashMap<>();
                            map.put("id",(int)bbperson.get("userId"));
							 user = userDao.findById(map);
							user.setUsername(bean.getUserName());
							user.setOrgId(bean.getOrgId());
							user.setEnabled(Boolean.TRUE);
							user.setOfficeId(bean.getOfficeId().intValue());
							if(tokenService.currentUser()!=null){
								user.preUpdate(tokenService.currentUser());
							}
//                            user.setPassword(MD5Util.encode("000000"));   //  不能修改密码
                            userDao.update(user);
							userCredentialsDao.updateUserInfo(new UserCredential(user.getUsername(), CredentialType.USERNAME.name(), user.getId(),user.getOrgId()));
                            log.info("被修改的用户id是"+user.getId());
                        }else{
							user.setUsername(bean.getUserName());
                            user.setPassword(MD5Util.encode("000000"));
                            userDao.save(user);
                            //添加用户凭证，不清楚添加的必要，但有用的地方
                            Long uid = user.getId();
                            userCredentialsDao.save(new UserCredential(user.getUsername(), CredentialType.USERNAME.name(), uid,user.getOrgId()));
                            log.info("新创建的用户id是"+user.getId());
							isNewAppUser = "已经设置该用户初始密码为000000";
                        }
						bean.setUserId(user.getId());
						//建立新的用户角色关联
						String[] roleIds = roleId.split(",");
						for (String id : roleIds) {
							Map paramMap1 = new HashMap();
							Map paramMap2 = new HashMap();
							paramMap2.put("id",bean.getId());
							paramMap1.put("userId",user.getId());
                            paramMap1.put("roleId",Integer.valueOf(id));
							paramMap1.put("orgId",bean.getOrgId());
							userRoleDao.saveUserRoles(paramMap1);
						}
					}
				}else{
//                    Map bbperson = dao.anyThingToUpdate(bean.getId());
                    if(bbperson==null){
                        //证明在底库没有找到，去临时库找一下
                        bbperson = dao.tempToUpdate(bean.getId());
                    }
                    if(bbperson.get("userId")!=null&&!bbperson.get("userId").equals("")){
                        Map paramMap = new HashMap();
                        paramMap.put("id",bean.getUserId());
                        userRoleDao.deleteUserRole(paramMap);
                    }
                }
				JSONObject paramMap = new JSONObject();

				paramMap.put("bean",bean);
				String post = restTemplateUtil.post(enumStr.getAnyThingToSave(), paramMap, MediaType.APPLICATION_JSON_UTF8, true);
			}else{
				log.info("新增人员");
				if(roleId!=null&&!"".equals(roleId)){

					if(bean.getUserName()!=null){
						//创建系统用户
						AppUser user = new AppUser();
						user.setUsername(bean.getUserName());
						if(tokenService.currentUser()!=null){
							user.preInsert(tokenService.currentUser());
						}
						userDao.save(user);
						bean.setUserId(user.getId());
						log.info("新创建的用户id是"+user.getId());
						//建立新的用户角色关联
						String[] roleIds = roleId.split(",");
						for (String id : roleIds) {
							Map paramMap1 = new HashMap();
							Map paramMap2 = new HashMap();
							paramMap2.put("id",bean.getId());
							paramMap1.put("userId",user.getId());
                            paramMap1.put("roleId",Integer.valueOf(id));
							paramMap1.put("orgId",bean.getOrgId());
							userRoleDao.saveUserRoles(paramMap1);
						}
					}
				}
				JSONObject paramMap = new JSONObject();
				paramMap.put("bean",bean);
				String post = restTemplateUtil.post(enumStr.getAddSingle(), paramMap, MediaType.APPLICATION_JSON_UTF8, true);
				JSONObject jsonMap = JSONObject.parseObject(post);
				String personId =  jsonMap.getString("data");
			}
			return isNewAppUser;  //  神烦
		}catch (Exception e){
			e.printStackTrace();
		}
		return isNewAppUser;  //  神烦
    }

    @Override
    public Map anyThingToUpdate(BbEmployee bean) {
        Map<String,Object> map = new HashMap<>();
        Map bbperson = dao.anyThingToUpdate(bean.getId());
        List<Integer> roleIds = null;
        if(bbperson.get("userId")!=null&&!"".equals(bbperson.get("userId"))){
            roleIds = userRoleDao.findRolesIds(Long.valueOf(bbperson.get("userId").toString()));
        }

        String colonyIdStr = (String)bbperson.get("distributionIds");
        JSONObject paramMap = new JSONObject();
        paramMap.put("clusterIds",colonyIdStr);
        String post = restTemplateUtil.post(enumStr.getClusterLocaltion(), paramMap , MediaType.APPLICATION_JSON_UTF8, true);
        JSONObject jsonMap = JSONObject.parseObject(post);
        map.put("bbPerson",bbperson);
        map.put("roleIds",roleIds);
        map.put("colonys",jsonMap.get("data"));
        return map;
    }

	@Override
	public Map queryPersonSimpleInfoById(String perId,Boolean delFlag) {
		Map<String,Object> map = new HashMap<>();
		Map bbperson = dao.selectPersonDetailById(perId,delFlag);
		return bbperson;
	}

    /**
	 * 去编辑，包含业务
	 */
	@Override
	public Map<String,Object> toUpdateBbEmployee(BbEmployee bean) {
		// 查找要编辑的数据库实体
		BbEmployee dbBean = dao.findByIdFromTemp(bean.getId());
		JSONObject paramMap = new JSONObject();
		paramMap.put("feature",dbBean.getFeature());

		String post = restTemplateUtil.post(enumStr.getToUpdateUrl(), paramMap, MediaType.APPLICATION_JSON_UTF8, true);
        JSONObject jsonMap = JSONObject.parseObject(post);
//		List<BbEmployee> bbpersons = JSONObject.parseArray(post, BbEmployee.class);

//        JSONObject paramMap1 = new JSONObject();
//        paramMap.put("clusterIds",dbBean.getDistributionIds());
//        String post1 = restTemplateUtil.post(enumStr.getClusterLocaltion(), paramMap , MediaType.APPLICATION_JSON_UTF8, true);
//        JSONObject jsonMap1 = JSONObject.parseObject(post1);

        //把特征值过滤掉不往前台传;
        dbBean.setFeature(null);
        Map<String,Object> map = new HashMap<>();
		map.put("bbPerson",dbBean);
		map.put("likerPerson",jsonMap.get("data"));
       // map.put("colonys",jsonMap1.get("data"));
		return map;
	}

	/**
	 * 分页查询
	 */
	@Override
	public Page<BbEmployee> findBbEmployees(Map<String, Object> params) {

		//前台传参是否查全部
//		if(params.containsKey("isAll")){
//		    if(params.get("isAll").toString().equals("0")){
//                params.remove("orgId");
//            }
//		}

		//Long id = Long.parseLong(params.get("id").toString());
		//String parentIds = orgDao.findCurentParentIds(id,null);
		//Map<String,Object> param = new HashMap<>();
		//param.put("parentIds",parentIds);
		//List<Integer> orgs = orgService.findDownByOffIds(param);
		//params.put("orgIds",orgs);

		PageUtil.pageParamConver(params, true);
		List<BbEmployee> list = Collections.emptyList();
		Page<BbEmployee> data = new Page<>(0, list);
		if(params.get("id").toString().equals("001")){
			//查总库全部
			int total = dao.countBase(params);
			if(total>0){
				list = dao.findDataFromBase(params);
			}
			data = new Page<>(total, list);
		}else if(params.get("id").toString().equals("002")){
			//查临时库全部
			int total = dao.countTemp(params);
			if(total>0){
				list = dao.findDataFromTemp(params);
			}
			data = new Page<>(total, list);
		}else{
			//按组织ID去查
			int total = dao.count(params);
			if(total>0){
				list = dao.findData(params);
			}
			data = new Page<>(total, list);
		}


		return data;
	}

	@Override
	public Integer deleteByIds(Map<String, Object> params, Object object) {
		return dao.deleteByIds(params);
	}

    @Override
    public Page<BbEmployee> findOrgEmployeeByType(Map<String, Object> params) {
        //根据学校IDparentsId参数
        Long cruentId = Long.parseLong(params.get("id").toString());
        Long orgId = Long.parseLong(params.get("orgId").toString());
        String parentIds = orgDao.findCurentParentIds(cruentId,null);

        params.put("parentIds",parentIds);
        int total = dao.findOrgEmployeeByTypeCount(params);
        List<BbEmployee> list = Collections.emptyList();
        if (total > 0) {
            PageUtil.pageParamConver(params, true);

            list = dao.findOrgEmployeeByTypeData(params);
        }
        return new Page<BbEmployee>(total, list);
    }

	/**
	 * 通id查询个人及家人信息
	 */
	@Override
	public Map<String,Object> findInfoByEmployeeId(Map<String, Object> params){
		return dao.findInfoByEmployeeId(params);
	}

	@Override
	public List<Integer> findOrgEmpIds(Map<String, Object> params) {
		//根据学校IDparentsId参数
		Long cruentId = Long.parseLong(params.get("id").toString());
		//Long orgId = Long.parseLong(params.get("orgId").toString());
		String parentIds = orgDao.findCurentParentIds(cruentId,null);
		params.put("parentIds",parentIds);
		return dao.findOrgEmpIds(params);
	}

	/**
	 * 查找老师和学生
	 */
	@Override
	public Map<String, Object> findStudentAndTeachers(Map<String, Object> params) {
		Map<String, Object> result = new HashMap<String, Object>();
		Object type = params.get("type");
		if (type != null && !"".equals(type.toString().trim())) {
			String gradeId = (String)params.get("gradeId");
			if (gradeId == null || "".equals((gradeId+"").trim()) || "null".equals(gradeId+"")) {
				params.remove("gradeId");
			}
			if ("teachear".equals(params.get("type")) || "teacher".equals(params.get("type"))) {
				params.put("type","教师");
				params.remove("gradeId");
				params.remove("classId");
			} else {
				params.put("type","学生");
				String classId = (String)params.get("classId");
				if (classId != null && !"".equals(classId+"") && !"null".equals(classId+"")) {
					params.remove("gradeId");
				}
			}
		}
		List<BbEmployee> emps = dao.findStudentAndTeachers(params);
		result.put("emps", emps);
		return result;
	}

	@Override
	public List<Map<String, Object>> findOrgEmpMap(Map<String, Object> params) {
		//根据学校IDparentsId参数
		Long cruentId = null;
		if(params.get("id")==null||params.get("id").toString().equals("")){
			 cruentId = Long.parseLong(params.get("orgId").toString());
		}else{
			 cruentId = Long.parseLong(params.get("id").toString());
		}
		//Long orgId = Long.parseLong(params.get("orgId").toString());
		String parentIds = orgDao.findCurentParentIds(cruentId,null);
		params.put("parentIds",parentIds);
		return dao.findOrgEmpMap(params);
	}

	@Override
	public List<BbEmployee> findStuByEmpId(Map<String, Object> params) {

		List<BbEmployee> stuList = new ArrayList<>();
		stuList = dao.findStuByEmpId(params);
		if(stuList.size()==0){
			BbEmployee bbEmployee = new BbEmployee();
			bbEmployee.setRemarks("暂无任何数据！！！");
			stuList.add(bbEmployee);
		}
		return stuList;
	}

	@Override
	public List<BbEmployee> findBbEmployeeList(Map<String, Object> params){
		List<BbEmployee> list =dao.findData(params);
		return list;
	}
	@Value("${imgHttpUrl.URLSTR}")
	private String imgHttpUrl;
	@Override
	public Map<String,Object> addVisitor(BbEmployee bean) {

		BbEmployee isExistEmp = dao.isExistEmp(bean.getOrgId(),bean.getPhone());
		Map<String,Object> map = new HashMap<>();
		if(isExistEmp == null){
			bean.preInsert(tokenService.currentUser());
			if (bean.getOrgNamesJson() == null || "".equals(bean.getOrgNamesJson())) {
				bean.setOrgNamesJson("{}");
			}
			if (bean.getRevJson1() == null || "".equals(bean.getRevJson1())) {
				bean.setRevJson1("{}");
			}

			//提取姓名助记码
			bean.setMnemonicCode(new UpperByName().toUpperByName(bean.getName()));
			//设置人员类型
			bean.setType(EmpTypeConstant.EMP_VISITOR);
			//设置民族
			bean.setNation("汉族");
			//设置officeId 暂定直属学校
			bean.setOfficeId(bean.getOrgId());
			//设置组织机构沉余
			String parendIds = orgDao.findCurentParentIds(bean.getOrgId(),null);
			List<String> orgList = orgDao.finCurentOrgs(parendIds,bean.getOrgId());
			if(orgList.size()>0){
				String orgNams = orgList.get(0).toString();
				if(orgList.size()>1) {
					for (int i = 1; i < orgList.size(); i++) {
						orgNams += " " + orgList.get(i).toString();
					}
				}
				bean.setOrgNamesJson(orgNams);
			}
			if(bean.getPhotos()!=null&&!"".equals(bean.getPhotos())){
				//根据图片路径获得人脸ID
				try {
					byte[] bytesFaces = ReadUrlImg.getImgByte(imgHttpUrl+bean.getPhotos());
					//获取人脸特征
					String faces = FaceUtil.extractFeature(bytesFaces,null);
					//人脸特征不为空时
					if(faces!=null&&!faces.isEmpty()){
						Integer bbFaciId = bbFaceDao.findIdByFaces(faces);
						if(bbFaciId == null){
							BbFace bbFace = new BbFace();
							bbFace.setOrgId(bean.getOrgId());
							bbFace.setFeature(faces);
							bbFaceDao.save(bbFace);
							map.put("faceId",bbFace.getId());
							bean.setFaceIds(bbFace.getId().toString());
						}else{
							map.put("faceId",bbFaciId);
						}
					}
				}catch (IOException e){
					System.out.println(e.getMessage());
				}
			}else{
				map.put("faceId","");
			}
			try {
				//bean.setPhotos("group1/M00/00/00/i-Bpa1sPoIeANA_OAACFHEvYmp0557.jpg");//临时
				int isSuccess = dao.addVisitor(bean);
				if(isSuccess > 0){
					map.put("人员ID",bean.getId());
				}else {
					map.put("人员ID","添加数据失败！");
				}
			}catch (Exception e){
				System.out.println(e.getMessage());
				map.put("错误信息","检查数据格式是否错误。");
			}finally {
				return map;
			}
		}else{
			map.put("faceId",Integer.parseInt(isExistEmp.getFaceIds()));
			map.put("人员ID",isExistEmp.getId());
			return map;
		}
	}

	//教师模糊查询根据拼音
	@Override
	public Map<String, Object> findTeacherByPin(Map<String, Object> params) {
		Map<String, Object> map = new HashMap<>();
		List<BbEmployee> list = dao.findTeacherByPin(params);
		if(list.size()>0){
			map.put("total",list.size());
			map.put("data",list);
		}else{
			map.put("message","没有查到数据");
		}
		return map;
	}

	/**
	 * 根据人员id查询部门
	 */
	@Override
	public Map<String, Object> findOfficeNameById(Map<String, Object> params) {
		Map<String, Object> map = new HashMap<String,Object>();
		List<Map<String, Object>> list = dao.findOfficeNameById(params);
		if(list !=null& list.size()>0){
			map = list.get(0);
		}
		return map;
	}

	@Override
	public List<Map<String, Object>> findOrgTeaMap(Map<String, Object> params) {
		Long cruentId = Long.parseLong(params.get("orgId").toString());
		//Long orgId = Long.parseLong(params.get("orgId").toString());
		String parentIds = orgDao.findCurentParentIds(cruentId,null);
		params.put("parentIds",parentIds);
		return dao.findOrgTeaMap(params);
	}

	@Override
	public Map<String, Object> findEmpsByOrg(Map<String, Object> params) {
		Map<String,Object> map = new HashMap<>();

		//前台传参是否查全部
		if(params.containsKey("isAll")){
			if(params.get("isAll").toString().equals("0")){
				params.remove("orgId");
			}
		}
		//根据学校IDparentsId参数
		Long cruentId = null;
		if(params.get("id")==null||params.get("id").toString().equals("")){
			cruentId = Long.parseLong(params.get("orgId").toString());
		}else{
			cruentId = Long.parseLong(params.get("id").toString());
		}
		String parentIds = orgDao.findCurentParentIds(cruentId,null);
		params.put("parentIds",parentIds);
		Integer count = dao.findOrgEmpMapCount(params);
		List<Map<String,Object>> data = null;
		if(count > 0){
			data = dao.findOrgEmpMap(params);
			map.put("code",0);
			map.put("data",data);
			map.put("total",count);
			map.put("message","查询成功！");
		}else{
			map.put("code",1);
			map.put("message","查询失败！");
		}
		return map;
	}

	@Override
	@Transactional
	public void batchAddBbEmployee(List<BbEmployeeVO> addList) {
		for(BbEmployee bbEmployee:addList){
			bbEmployee.preInsert(tokenService.currentUser());
			dao.add(bbEmployee);
		}
	}

	@Override
	@Transactional
	public void batchUpdatePerson(List<BbEmployeeVO> updateList) {
		for(BbEmployee bbEmployee:updateList){

            if(bbEmployee.getId()!=null){
                //delete 删除人脸ID
                Map<String,Object> params = new HashMap<>();
                params.put("id",bbEmployee.getId());
                params.put("orgId",bbEmployee.getOrgId());
                bbFaceDao.deleteByUserId((String) params.get("id"));
            }
/*			bbEmployee.setUpdateBy(AppUserUtil.getLoginAppUser().getUsername());
			bbEmployee.setUpdateTime(new Date());*/
			bbEmployee.preUpdate(tokenService.currentUser());
			bbEmployee.setDelFlag("0");
			dao.updateByPhone(bbEmployee);
		}
	}

	@Override
	public BbEmployee findEmpById(Map<String, Object> params) {
		return dao.findEmpById(params);
	}

	@Override
	public Map findEmpAndLocationById(Map<String, Object> params) {
		Map map = new HashMap();
		BbEmployee bbEmployee = dao.findEmpById(params);
		map.put("bbEmployee",bbEmployee);
		//调设备接口得到localtionList
        JSONObject paramMap = new JSONObject();
        paramMap.put("clusterIds",bbEmployee.getDistributionIds());
        String post = restTemplateUtil.post(enumStr.getClusterLocaltion(), paramMap , MediaType.APPLICATION_JSON_UTF8, true);
        JSONObject jsonMap = JSONObject.parseObject(post);
		map.put("localtionList",jsonMap.get("data"));
		return map;
	}

	@Override
	public Page<BbEmployee> findOrgEmpInVisit(Map<String, Object> params) {

		params.put("type",EmpTypeConstant.EMP_VISITOR);

		int total = dao.findOrgEmpInVisitCount(params);
		List<BbEmployee> list = Collections.emptyList();
		if (total > 0) {
			PageUtil.pageParamConver(params, true);
			list = dao.findOrgEmpInVisitData(params);
		}
		return new Page<>(total, list);
	}

	//人员组织机构变更
	@Override
	public int updateOfficeId(Map<String, Object> params) {
		params.put("delFlag", GlobalDict.IS_NOT_DEL);
		if(params.get("updateOfficeId")==null || params.get("updateOfficeId").toString().equals("")){
			throw new IllegalArgumentException("组织机构不能为空");
		}
		Long updateOfficeId = Long.parseLong(params.get("updateOfficeId").toString());
        String parendIds = orgDao.findCurentParentIds(updateOfficeId,null);
        String orgNamesJson = orgDao.getParentNames(parendIds,null, " ");
		params.put("orgNamesJson",StringUtils.isEmpty(orgNamesJson)?"":orgNamesJson);
		return dao.updateOfficeId(params);
	}

}