package com.product.org.admin.service;


import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.alibaba.druid.util.StringUtils;
import com.product.admin.service.CodeService;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.core.permission.PermissionService;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.service.support.QueryFilterService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.org.admin.config.CmnCode;
import com.product.org.admin.config.CmnConst;
import com.product.org.admin.config.SystemCode;
import com.product.org.admin.service.idel.IDeptChangeService;
import com.product.util.BaseUtil;

/**
 * 
 * Copyright LX-BASE
 * 
 * @Title: LX-BASE-
 * @Project: DeptChangesService
 * @Date: 2020-06-04 20:07
 * @Author: 杜洪波
 * @Description: 部门变更
 */
@Component("deptChange")
public class DeptChangeService extends AbstractBaseService implements IDeptChangeService{

	@Autowired
	private BaseDao baseDao;
	
	@Autowired
	CodeService codeService;

	@Autowired
	PermissionService permissionService;
	
	@Autowired
	DeptChangeService deptChangeService;
	
	@Autowired
	public QueryFilterService queryFilterService;
	
	/**
	 * 部门变更列表
	 * 
	 * @param fse
	 * @return
	 * @throws BaseException
	 */
	public DataTableEntity listDeptChange(FieldSetEntity fse) throws BaseException {
		//郑盟   2020年12月22日   下午18:34
		String dataFilter=permissionService.getDataFilter("org_level_uuid,new_org_level_uuid") ;
		String queryFilter="";
		if (!BaseUtil.dataTableIsEmpty(fse.getSubDataTable("systemSeniorQueryString"))) {
			if (!StringUtils.isEmpty(dataFilter)) {
				queryFilter =" and"+queryFilterService.getQueryFilter(fse);
			}else {
				queryFilter =queryFilterService.getQueryFilter(fse);
			}
		} 
		return baseDao.listTable("product_sys_org_levels_change",dataFilter+queryFilter ,
				new Object[] {},new Object[] {}, null,fse.getInteger("pagesize"), fse.getInteger("cpage"));
	}

	/**
	 * 部门变更详情
	 * 
	 * @param uuid
	 * @return
	 * @throws BaseException
	 */
	public FieldSetEntity findDeptChange(String uuid) throws BaseException {
		return baseDao.getFieldSetEntity("product_sys_org_levels_change", uuid, false);
	}

	/**
	 * 部门变更新增验证
	 * 
	 * @param deptUUid
	 * @return
	 * @throws BaseException
	 */
	public String deptChangeAdd(FieldSetEntity fseChangeInfo) throws BaseException {
		DataTableEntity dtDeptChange = baseDao.listTable(CmnConst.PRODUCT_SYS_ORG_LEVELS_CHANGE, "origin_dept_uuid=? and (result_status is null or result_status=1)", new Object[] { fseChangeInfo.getString("origin_dept_uuid") });
		if (dtDeptChange != null && dtDeptChange.getRows() > 0) {
			throw new BaseException(SystemCode.SYSTEM_CURRENT_DEPT_CHANGE_EXIST.getValue(), SystemCode.SYSTEM_CURRENT_DEPT_CHANGE_EXIST.getText(), this.getClass(), "deptChangeAddValitation");
		}
		
		//设置创建人和创建时间
		fseChangeInfo.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		fseChangeInfo.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
		fseChangeInfo.setValue("result_status", 0);
		
		boolean isMatch=true;
		
		//获取部门变更类型
		String deptChangeType = fseChangeInfo.getString("change_status_uuid");
		
		IDeptChangeService service =(IDeptChangeService)getProxyInstance(deptChangeService);
		if ("2".equals(deptChangeType)) {	//合并部门
			isMatch = service.deptMerge(fseChangeInfo);
		} else if ("3".equals(deptChangeType)) {	//迁移部门
			isMatch = service.deptMove(fseChangeInfo);
		}
		
		if (isMatch) {
			//新增记录
			return baseDao.add(fseChangeInfo);
		}else {
			throw new BaseException(CmnCode.DEPT_CHANGE_ERROR.getValue(), CmnCode.DEPT_CHANGE_ERROR.getText());
		}
	}
	
	
	/**
	 * 	部门合并
	 *  1:变更后代部门全称  
	 *  2:变更后代部门组织机构编码  
	 *  3:变更原部门岗位至合并部门  
	 *  4:变更原部门员工至合并部门  
	 *  5:重新生成相关部门下员工的员工编码
	 * 	6.将原部门标记为被合并
	 * 	7.将变更标识为1
	 * @param fse
	 * @return
	 * @throws BaseException
	 */
	@Transactional
	public boolean deptMerge(FieldSetEntity fse) throws BaseException {
		
		boolean flag = true;
		
		String originOrgUuid = fse.getString(CmnConst.ORG_LEVEL_UUID);		//合并部门所属公司UUID
		String mergeOrgUuid = fse.getString("new_org_level_uuid");	//保留部门所属公司UUID
		String originDeptUuid = fse.getString(CmnConst.ORIGIN_DEPT_UUID);	//获取原部门UUID
		String mergeDeptUuid = fse.getString("new_dept_uuid");	//获取保留部门UUID
		
		//获取原部门信息
		FieldSetEntity fseOriginDept = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, originDeptUuid, false);
		//获取保留部门信息
		FieldSetEntity fseMergeDept = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, mergeDeptUuid, false);
		if (fseMergeDept == null || fseOriginDept==null) {
			throw new BaseException(SystemCode.SYSTEM_DEPT_MERGE_NO_EXIST.getValue(), SystemCode.SYSTEM_DEPT_MERGE_NO_EXIST.getText());
		}

		String originDeptCode = fseOriginDept.getString(CmnConst.ORG_LEVEL_CODE);	//获取原部门编码
		String mergeDeptCode = fseMergeDept.getString(CmnConst.ORG_LEVEL_CODE);		//获取保留部门编码
		
		//获取子一代部门信息
		DataTableEntity dtDepts=baseDao.listTable(CmnConst.PRODUCT_SYS_ORG_LEVELS, "org_level_code_parent =?", new Object[]{originDeptCode});
		
		//判断是否包含子一代部门变化
		if (!BaseUtil.dataTableIsEmpty(dtDepts)) {	
			Object[] uuids = dtDepts.getUuids();
			if (uuids != null) {
				
				//生成的第一个编码，后续编码需要根据该编码生成
				String finalCode="";
				
				//遍历子部门,变更上下级编码
				for (int i = 0; i < dtDepts.getRows(); i++) {
					FieldSetEntity fseSubDept=dtDepts.getFieldSetEntity(i);
					// 获取子部门合并前的编码
					String originDeptSubCode = fseSubDept.getString(CmnConst.ORG_LEVEL_CODE);
					// 创建子部门新编码
					String newDeptSubCode="";
					if(i==0) {	//生成code管理器编码
						newDeptSubCode = codeService.createCode(CmnConst.PRODUCT_SYS_ORG_LEVELS, CmnConst.ORG_LEVEL_CODE, mergeDeptCode);
						finalCode=newDeptSubCode;
					}else {	//自动生成后续编码
						newDeptSubCode = numCodeparse(finalCode,i);
					}
					
					fseSubDept.setValue(CmnConst.ORG_LEVEL_CODE, newDeptSubCode);
					fseSubDept.setValue(CmnConst.ORG_LEVEL_CODE_PARENT, mergeDeptCode);
					baseDao.update(fseSubDept);
					
					//变更该部门后代部门 编码与上级编码
					StringBuilder sqlSubDeptChangeCode=new StringBuilder();
					sqlSubDeptChangeCode.append(" update product_sys_org_levels ");
					sqlSubDeptChangeCode.append(" set org_level_code=concat(replace(substring(org_level_code,1,locate(?,org_level_code)+length(?)),?,?),substring(org_level_code,locate(?,org_level_code)+length(?)+1)), ");
					sqlSubDeptChangeCode.append(" org_level_code_parent=concat(replace(substring(org_level_code_parent,1,locate(?,org_level_code_parent)+length(?)),?,?),substring(org_level_code_parent,locate(?,org_level_code_parent)+length(?)+1)) ");
					sqlSubDeptChangeCode.append(" where org_level_code like ? ");
					baseDao.executeUpdate(sqlSubDeptChangeCode.toString(), new Object[] {originDeptSubCode,originDeptSubCode,originDeptSubCode,newDeptSubCode,originDeptSubCode,originDeptSubCode,
							originDeptSubCode,originDeptSubCode,originDeptSubCode,newDeptSubCode,originDeptSubCode,originDeptSubCode,originDeptSubCode+"-%"});
					
					//变更该部门及后代部门所有员工 编码与上级领导编码
					StringBuilder sqlStaffChangeCode=new StringBuilder();
					sqlStaffChangeCode.append(" update product_sys_staffs ");
					sqlStaffChangeCode.append(" set tricode=concat(replace(substring(tricode,1,locate(?,tricode)+length(?)),?,?),substring(tricode,locate(?,tricode)+length(?)+1)), ");
					sqlStaffChangeCode.append(" direct_leader_code=concat(replace(substring(direct_leader_code,1,locate(?,direct_leader_code)+length(?)),?,?),substring(direct_leader_code,locate(?,direct_leader_code)+length(?)+1)) ");
					sqlStaffChangeCode.append(" where tricode like ? ");
					
					flag=baseDao.executeUpdate(sqlStaffChangeCode.toString(), new Object[] {originDeptSubCode,originDeptSubCode,originDeptSubCode,newDeptSubCode,originDeptSubCode,originDeptSubCode,
							originDeptSubCode,originDeptSubCode,originDeptSubCode,newDeptSubCode,originDeptSubCode,originDeptSubCode,originDeptSubCode+"-%"});

				}
			}
			
		}
		
		
		//获取被合并部门的员工信息
		DataTableEntity dtStaffs=baseDao.listTable(CmnConst.PRODUCT_SYS_STAFFS, "dept_uuid = ?", new Object[]{originDeptUuid});
		if (!BaseUtil.dataTableIsEmpty(dtStaffs)) {
			
			//员工编码变更存储对象
			Map<String, String> changeStaffCode=new HashMap<>();
			
			//生成一个固定编码
			String finalCode="";
			
			//遍历变化的员工
			for (int i = 0; i < dtStaffs.getRows(); i++) {
				FieldSetEntity fseStaff=dtStaffs.getFieldSetEntity(i);
				fseStaff.remove("show_name");
				fseStaff.remove("family_name");
				fseStaff.remove("given_name");
				fseStaff.remove("preferred_name");
				
				String newStaffTricode="";
				if(i==0) {
					newStaffTricode = codeService.createCode(CmnConst.PRODUCT_SYS_STAFFS, CmnConst.TRICODE, mergeDeptCode);
					finalCode=newStaffTricode;
				}else {
					newStaffTricode = numCodeparse(finalCode,i);
				}
				
				String originStaffTricode=fseStaff.getString(CmnConst.TRICODE);
				
				fseStaff.setValue(CmnConst.TRICODE, newStaffTricode);
				
				changeStaffCode.put(originStaffTricode, newStaffTricode);
			}
			baseDao.update(dtStaffs);
			
			//修改影响到的其余下属员工
			for ( Map.Entry<String, String> entries : changeStaffCode.entrySet() ){
				String originStaffTriCode=entries.getKey();	//原部门编码
				String newStaffTriCode=entries.getValue();	//新部门编码
					
				StringBuilder sqlStaffChangeCode=new StringBuilder();
				sqlStaffChangeCode.append(" update product_sys_staffs set ");
				sqlStaffChangeCode.append(" direct_leader_code=concat(replace(substring(direct_leader_code,1,locate(?,direct_leader_code)+length(?)),?,?),substring(direct_leader_code,locate(?,direct_leader_code)+length(?)+1)) ");
				sqlStaffChangeCode.append(" where direct_leader_code like ? ");
					
				flag=baseDao.executeUpdate(sqlStaffChangeCode.toString(), new Object[] {originStaffTriCode,originStaffTriCode,originStaffTriCode,newStaffTriCode,originStaffTriCode,originStaffTriCode,originStaffTriCode+"%"});
			}
		}
		
		

		//变更合并部门的岗位所属部门至保留部门
		if (!originOrgUuid.equals(mergeOrgUuid)) {
			baseDao.executeUpdate("update product_sys_job_posts set org_level_uuid=?,dept_uuid=? where dept_uuid=?", new Object[] {mergeOrgUuid,mergeDeptUuid,originOrgUuid});
		}
		baseDao.executeUpdate("update product_sys_job_posts set dept_uuid=? where dept_uuid=?", new Object[] {mergeDeptUuid,originDeptUuid});
		
		//变更合并部门的人员所属部门至保留部门
		if (!originOrgUuid.equals(mergeOrgUuid)) {
			baseDao.executeUpdate("update product_sys_staffs set org_level_uuid=?,dept_uuid=? where dept_uuid=?", new Object[] {mergeOrgUuid,mergeDeptUuid,originOrgUuid});
		}
		baseDao.executeUpdate("update product_sys_staffs set dept_uuid=? where dept_uuid=?", new Object[] {mergeDeptUuid,originDeptUuid});
		
		//变更当前部门状态为被合并
		if (flag == true) {
			fseOriginDept.setValue("org_level_status", 2);
			flag = baseDao.update(fseOriginDept);
		}
		fse.setValue(CmnConst.RESULT_STATUS, 1);
		
		return flag;
	}
	
	/**
	 * 	手动处理编码  (循环产生编码拓展)
	 * @param finalCode
	 * @param i
	 * @return
	 */
	public String numCodeparse(String finalCode,int i) {
		
		//获取编码前缀和后缀
		String prefix=finalCode.substring(0, finalCode.lastIndexOf("-"));
		String suffix=finalCode.substring(finalCode.lastIndexOf("-")+1, finalCode.length());
		
		//通过后缀生成新编码
		int newSuffixNum=Integer.parseInt(suffix);
		newSuffixNum+=i;
		
		String newCode="";
		//生成新的编码
		if (newSuffixNum<10) {
			newCode=prefix+"-00"+newSuffixNum;
		}else if (newSuffixNum>9 && newSuffixNum<100) {
			newCode=prefix+"-0"+newSuffixNum;
		}else {
			newCode=prefix+"-"+newSuffixNum;
		}
		return newCode;
	}

	/**
	 * 	部门迁移
	 * 	1.变更原部门及后代部门国际化全称
	 * 	2.判断是否跨公司迁移(变更岗位和员工所属公司UUID)
	 * 	3.变更原部门及后代部门的组织机构编码及父编码
	 * 	4.变更原部门及后代部门下的员工编码
	 * 	5.将变更标识为1
	 * @param fse
	 * @param originDeptCode 原部门编码
	 * @param originDeptUuid 原部门uuid
	 * @return
	 * @throws BaseException
	 */
	@Transactional
	public boolean deptMove(FieldSetEntity fse) throws BaseException {
		boolean flag = true;
		
		String originDeptUuid=fse.getString(CmnConst.ORIGIN_DEPT_UUID);	//获取原部门UUID
		String moveDeptUuid = fse.getString("new_dept_uuid");		//获取迁入部门uuid
		String originOrgUuid=fse.getString(CmnConst.ORG_LEVEL_UUID);		//原部门所属公司
		String moveOrgUuid=fse.getString("new_org_level_uuid");	//迁入部门所属公司
		if (StringUtils.isEmpty(moveDeptUuid)) {	//杜洪波 updateTime 2020-12-17 09:48:00
			moveDeptUuid=moveOrgUuid;
		}
		
		//获取原部门国际化信息
		FieldSetEntity fseOriginDept=baseDao.listInternationDataTable(baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, originDeptUuid, false),null);
		
		//获取迁入部门国际化信息
		FieldSetEntity fseMoveDept = baseDao.listInternationDataTable(baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, moveDeptUuid, false),null);
		if (fseMoveDept == null || fseOriginDept==null) {
			return false;
		}

		String originDeptCode = fseOriginDept.getString(CmnConst.ORG_LEVEL_CODE);	//获取原部门编码
		String originDeptParentCode = fseOriginDept.getString(CmnConst.ORG_LEVEL_CODE_PARENT);	//获取原部门父级编码
		String moveDeptCode = fseMoveDept.getString(CmnConst.ORG_LEVEL_CODE);	//获取迁入部门编码
		
		//获取原部门上级国际化信息
		FieldSetEntity fseOriginDeptParent = baseDao.listInternationDataTable(baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ORG_LEVELS, "org_level_code=?", new Object[] {originDeptParentCode}, false),null);
		if (fseOriginDeptParent==null) {
			return false;
		}
		
				
		//获取所有后代部门信息
		DataTableEntity dtDepts=baseDao.listTable(CmnConst.PRODUCT_SYS_ORG_LEVELS, "org_level_code like'"+originDeptCode+"%'", new Object[]{});
		if (dtDepts!=null && dtDepts.getRows()>0) {
			Object[] uuids = dtDepts.getUuids();
			if (uuids != null) {
				
				//判断迁移前后公司是否修改,如已修改,则变更员工所属公司,岗位所属公司
				if (!originOrgUuid.equals(moveOrgUuid)) {
					baseDao.executeUpdate("update product_sys_staffs set org_level_uuid=? where " +  BaseUtil.buildQuestionMarkFilter(CmnConst.DATA_UUID, uuids.length, true), new Object[] {moveOrgUuid,Arrays.asList(uuids)});
					baseDao.executeUpdate("update product_sys_job_posts set org_level_uuid=? where " +  BaseUtil.buildQuestionMarkFilter(CmnConst.DATA_UUID, uuids.length, true), new Object[] {moveOrgUuid,Arrays.asList(uuids)});
				}
			}
		}
		
		//生成新部门编码
		String newMoveCode = codeService.createCode(CmnConst.PRODUCT_SYS_ORG_LEVELS, CmnConst.ORG_LEVEL_CODE, moveDeptCode);
		fseOriginDept.setValue(CmnConst.ORG_LEVEL_CODE, newMoveCode);
		fseOriginDept.setValue(CmnConst.ORG_LEVEL_CODE_PARENT, moveDeptCode);
		baseDao.update(fseOriginDept);
		
		//变更迁移部门及后代部门组织机构编码及父编码
		StringBuilder sqlSubDeptChangeCode=new StringBuilder();
		sqlSubDeptChangeCode.append(" update product_sys_org_levels ");
		sqlSubDeptChangeCode.append(" set org_level_code=concat(replace(substring(org_level_code,1,locate(?,org_level_code)+length(?)),?,?),substring(org_level_code,locate(?,org_level_code)+length(?)+1)), ");
		sqlSubDeptChangeCode.append(" org_level_code_parent=concat(replace(substring(org_level_code_parent,1,locate(?,org_level_code_parent)+length(?)),?,?),substring(org_level_code_parent,locate(?,org_level_code_parent)+length(?)+1)) ");
		sqlSubDeptChangeCode.append(" where org_level_code like ? ");
		
		baseDao.executeUpdate(sqlSubDeptChangeCode.toString(), new Object[] {originDeptCode,originDeptCode,originDeptCode,newMoveCode,originDeptCode,originDeptCode,
				originDeptCode,originDeptCode,originDeptCode,newMoveCode,originDeptCode,originDeptCode,originDeptCode+"-%"});
		
		//变更迁移部门及后代部门的员工编码和上级领导编码
		StringBuilder sqlStaffChangeCode=new StringBuilder();
		sqlStaffChangeCode.append(" update product_sys_staffs ");
		sqlStaffChangeCode.append(" set tricode=concat(replace(substring(tricode,1,locate(?,tricode)+length(?)),?,?),substring(tricode,locate(?,tricode)+length(?)+1)), ");
		sqlStaffChangeCode.append(" direct_leader_code=concat(replace(substring(direct_leader_code,1,locate(?,direct_leader_code)+length(?)),?,?),substring(direct_leader_code,locate(?,direct_leader_code)+length(?)+1)) ");
		sqlStaffChangeCode.append(" where tricode like ? ");
		
		flag=baseDao.executeUpdate(sqlStaffChangeCode.toString(), new Object[] {originDeptCode,originDeptCode,originDeptCode,newMoveCode,originDeptCode,originDeptCode,originDeptCode,originDeptCode,originDeptCode,newMoveCode,originDeptCode,originDeptCode,originDeptCode+"%"});
		
		if (flag) {
			fse.setValue(CmnConst.RESULT_STATUS, 1);
		}
		
		return baseDao.update(fse);
	}		
}