/**
 *
 */
package com.product.admin.service;

import com.alibaba.druid.util.StringUtils;
import com.product.admin.config.CmnConst;
import com.product.admin.config.SystemCode;
import com.product.admin.service.idel.ISystemManagementUserService;
import com.product.core.config.CoreConst;
import com.product.core.config.Global;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldMetaEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
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.email.service.SendEmailService;
import com.product.module.sys.entity.SystemUser;
import com.product.module.sys.service.UserService;
import com.product.util.BaseUtil;
import org.apache.commons.lang3.RandomStringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.net.URLEncoder;
import java.util.Arrays;
import java.util.Date;
import java.util.Map;

/**
 * Copyright LX-BASE
 *
 * @Title: SystemManagementUserService
 * @Project: LX-BASE-SERVER
 * @Date: 2020年6月3日 下午4:40:01
 * @Author: 郑盟
 * @Description: 系统管理员设置
 */
@Component
public class SystemManagementUserService extends AbstractBaseService implements ISystemManagementUserService {
    @Autowired
    private BaseDao baseDao;
    @Autowired
    private UserService userService;
    @Autowired
    private RolesService rolesService;
    @Autowired
    private SendEmailService sendEmailService;
    @Autowired
    private UpdateLoginUserInfoService updateLoginUserInfoService;
    @Autowired
    private QueryFilterService queryFilterService;

    /**
     * 账号解冻
     * @param fse
     * @return
     * @throws BaseException
     */
    public boolean accountUnfreeze(FieldSetEntity fse) throws BaseException {
        if (!com.product.common.lang.StringUtils.isEmpty(fse.getUUID())) {
            //user 表 uuid
            return baseDao.executeUpdate("update product_sys_users set status=1 where uuid=?", new Object[]{fse.getUUID()});
        }
        return false;
    }

    /**
     * 新增管理员 manager_type 1超级管理员 2.普通管理员 3.隐藏管理员 4.系统管理员
     *
     * @throws BaseException
     */
    @Transactional
    public String addUser(FieldSetEntity fs, int manager_type) throws BaseException {
        String staffs_uuid = fs.getString("staffs_uuid");
        fs.setValue("login_url", URLEncoder.encode(Global.getSystemConfig("resetpwd.lxlogin_url", "")));//获取配置的管理员登录界面，保存fs中
        // 郑盟 2020年12月17日 下午16:05
        if (!StringUtils.isEmpty(staffs_uuid)) {
            return addStaffsManager(fs, manager_type);
        } else {
            return addManager(fs, manager_type);
        }
    }

    /**
     * 绑定人员的情况下创建管理员
     */
    public String addStaffsManager(FieldSetEntity fs, int manager_type) throws BaseException {
        // 对staffs进行修改
        String staffs_uuid = fs.getString(CmnConst.STAFFS_UUID);
        String pwd = fs.getString(CmnConst.USER_PWD);
        String user_account = fs.getString(CmnConst.USER_ACCOUNT);
        FieldSetEntity staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staffs_uuid, false);
        staffsFs.setValue("is_org_admin", 1);
        boolean updateStaffsFs = baseDao.executeUpdate("update product_sys_staffs set is_org_admin=1 where uuid=?",
                new String[]{staffsFs.getString(CmnConst.UUID)});
        // 对user进行修改
        if (!updateStaffsFs)
            return null;
        String user_id = staffsFs.getString(CmnConst.USER_ID);
        boolean updateUserFs = baseDao.executeUpdate("update product_sys_users set is_manager=1 where user_id=?",
                new String[]{user_id});
        if (!updateUserFs)
            return null;
        // 创建manager
        FieldSetEntity managerFs = new FieldSetEntity();
        managerFs.setTableName(CmnConst.PRODUCT_SYS_ORG_MANAGER);
        managerFs.setValue(CmnConst.USER_ID, user_id);
        managerFs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
        managerFs.setValue(CmnConst.MANAGER_TYPE, manager_type);
        managerFs.setValue(CmnConst.ROLE_UUIDS, fs.getString(CmnConst.ROLE_UUID));
        // 郑盟 2020年12月21日 下午14:05
        managerFs.setValue(CmnConst.IS_USED, "1");
        managerFs.setValue(CmnConst.CLIENTS_UUID, fs.getString(CmnConst.CLIENTS_UUID));
        managerFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        managerFs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
        String add = baseDao.add(managerFs);
        if (!StringUtils.isEmpty(add) && !StringUtils.isEmpty(user_id)) {
            // xupengcheng updateTime 2020年11月28日10:33:25 管理员绑定员工更新菜单、user对象信息
            updateLoginUserInfoService.updateUserInfoByManagerStaffBindClient(user_id, false);
        }
        // 新增单位管理员发送邮件
        // 邮件内容
        String login_url = fs.getString(CmnConst.LOGIN_URL);
        FieldSetEntity nfs = new FieldSetEntity();
        nfs.setTableName(CmnConst.STAFF_EMAIL_CONTENT);
        nfs.setValue(CmnConst.LOGIN_URL, login_url);// 登录页面
        nfs.setValue(CmnConst.USER_ACCOUNT, user_account);// 用户名
        nfs.setValue(CmnConst.PASS_WORD, pwd);// 密码
        String olu = fs.getString(CmnConst.ORG_LEVEL_UUID);
        if (olu.indexOf(",") != -1) {
            olu = olu.replace(",", "','");
        }
        String sql = "product_sys_org_levels where uuid in ('" + olu + "')";
        StringBuilder oln = new StringBuilder();
        DataTableEntity dtt = baseDao.listTable(sql);
        if (dtt.getRows() > 0) {
            for (int i = 0; i < dtt.getRows(); i++) {
                FieldSetEntity dfs = dtt.getFieldSetEntity(i);
                String na = dfs.getString(CmnConst.ORG_LEVEL_NAME);
                if (i < 1) {
                    oln.append(na);
                } else {
                    oln.append(",");
                    oln.append(na);
                }
            }
        }
//		nfs.setValue(CmnConst.ORG_LEVEL_NAME, oln);// 公司
//		nfs.setValue(CmnConst.USER_PRIMARY_EMAIL, fs.getString(CmnConst.USER_PRIMARY_EMAIL));// 邮箱地址
//		try {
//			String resultInfo = sendEmailService.parseMailTemplate(CmnConst.NEW_ACCOUNT_MANAGER_ACTIVATION, nfs);
//			if (SystemCode.SYSTEM_OPERATION_SUCCESS.getText().equals(resultInfo)) {
//				return add;
//			} else {
//				throw new BaseException(SystemCode.SYSTEM_MAIL_SEND_FAIL.getValue(),
//						SystemCode.SYSTEM_MAIL_SEND_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
//			}
//		} catch (Exception e) {
//			throw new BaseException(SystemCode.SYSTEM_MAIL_SEND_FAIL.getValue(),
//					SystemCode.SYSTEM_MAIL_SEND_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
//		}
        //返回信息
        return com.product.email.config.SystemCode.SYSTEM_OPERATION_SUCCESS.getText();
    }

    /**
     * 不绑定人员的情况下创建管理员
     */
    public String addManager(FieldSetEntity fs, int manager_type) throws BaseException {
        String user_account = fs.getString(CmnConst.USER_ACCOUNT);
        DataTableEntity listTable = baseDao.listTable(CmnConst.PRODUCT_SYS_USERS, "user_account='" + user_account + "'");
        if (listTable.getRows() > 0) {
            throw new BaseException(SystemCode.SYSTEM_REPEAT_USER_FAIL.getValue(),
                    SystemCode.SYSTEM_REPEAT_USER_FAIL.getText(), this.getClass(), "addUser");
        }
        String user_primary_email = fs.getString(CmnConst.USER_PRIMARY_EMAIL);
        DataTableEntity email = baseDao.listTable(CmnConst.PRODUCT_SYS_USERS,
                "user_primary_email='" + user_primary_email + "'");
        if (email.getRows() > 0) {
            throw new BaseException(SystemCode.SYSTEM_REPEAT_EMAIL_FAIL.getValue(),
                    SystemCode.SYSTEM_REPEAT_EMAIL_FAIL.getText(), this.getClass(), "addUser");
        }

        fs.setValue(CmnConst.IS_MANAGER, 1);
        fs.setValue(CmnConst.USER_PWD, userService.createPassWord(fs.getString(CmnConst.USER_ACCOUNT), fs.getString(CmnConst.USER_PWD)));
        fs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        fs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
        String add = baseDao.add(fs, false);

        // 处理manager公司uuid
        forManagerUuid(fs, add);

        FieldSetEntity rolefs = new FieldSetEntity();
        rolefs.setTableName(CmnConst.PRODUCT_SYS_ROLE);
        FieldMetaEntity ff = new FieldMetaEntity();
        ff.setTableName(new Object[]{CmnConst.PRODUCT_SYS_ROLE});
        rolefs.setMeta(ff);
        FieldSetEntity managerFs = new FieldSetEntity();
        FieldSetEntity userFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "uuid=? ", new String[]{add},
                false);
        FieldMetaEntity f = new FieldMetaEntity();
        f.setTableName(new Object[]{CmnConst.PRODUCT_SYS_ORG_MANAGER});
        managerFs.setMeta(f);
        managerFs.setValue(CmnConst.USER_ID, userFs.getString(CmnConst.USER_ID));
        // 郑盟 2020年12月17日 下午16:05
        if (!StringUtils.isEmpty(fs.getString(CmnConst.ORG_LEVEL_UUID))) {
            managerFs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
        }
        managerFs.setValue(CmnConst.MANAGER_TYPE, manager_type);
        // 郑盟 2020年12月17日 下午16:05
        if (!StringUtils.isEmpty(fs.getString(CmnConst.CLIENTS_UUID))) {
            managerFs.setValue(CmnConst.CLIENTS_UUID, fs.getString(CmnConst.CLIENTS_UUID));
        } else {
            managerFs.setValue(CmnConst.CLIENTS_UUID, null);
        }
        // 新增管理员 manager_type 1超级管理员 2.普通管理员 3.隐藏管理员 4.系统管理员
        choiceManagerType(manager_type, managerFs);

        // 郑盟 2020年12月21日 下午14:05
        managerFs.setValue(CmnConst.IS_USED, "1");
        managerFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        managerFs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());

        String addManager = baseDao.add(managerFs);
        if (addManager == null)
            return addManager;

        // 更新企业表
        uodateCompanyData(fs);
        // 新增单位管理员发送邮件
        // 邮件内容
//		FieldSetEntity nfs = new FieldSetEntity();
//		addManagerSendMail(fs, user_account, pwd, nfs);
//		return returnAdd(manager_type, nfs, add);
        //返回信息
        return com.product.email.config.SystemCode.SYSTEM_OPERATION_SUCCESS.getText();
    }

    private void forManagerUuid(FieldSetEntity fs, String add) {
        for (String client_uuid : fs.getString(CmnConst.ORG_LEVEL_UUID).split(",")) {
            DataTableEntity org_levels = baseDao.listTable(CmnConst.PRODUCT_SYS_ORG_LEVELS, " uuid=?",
                    new String[]{client_uuid});
            if (org_levels.getRows() > 0) {
                for (int i = 0; i < org_levels.getRows(); i++) {
                    FieldSetEntity org_level = org_levels.getFieldSetEntity(i);
                    String org_level_manager_uuid = null;
                    // 郑盟 2020年12月17日 下午16:05
                    if (org_level != null && (StringUtils.isEmpty(org_level.getString(CmnConst.ORG_LEVEL_MANAGER_UUID)))) {
                        org_level_manager_uuid = add;
                        org_level.setValue(CmnConst.ORG_LEVEL_MANAGER_UUID, org_level_manager_uuid);
                    } else if (org_level != null
                            && !StringUtils.isEmpty(org_level.getString(CmnConst.ORG_LEVEL_MANAGER_UUID))) {
                        org_level_manager_uuid = org_level.getString(CmnConst.ORG_LEVEL_MANAGER_UUID) + "," + add;
                        org_level.setValue(CmnConst.ORG_LEVEL_MANAGER_UUID, org_level_manager_uuid);
                    } else {
                        continue;
                    }
                    String sql = "update product_sys_org_levels set org_level_manager_uuid=? where uuid=?";
                    baseDao.executeUpdate(sql, new Object[]{org_level_manager_uuid, org_level.getUUID()});
                }
            }
        }
    }

    private void choiceManagerType(int manager_type, FieldSetEntity managerFs) {
        FieldSetEntity fss = null;
        if (manager_type == 2) {
            fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ROLE, "  uuid=?",
                    new String[]{CoreConst.ROLE_ADMIN_UUID_COMPANY}, false);
        }
        if (manager_type == 1) {
            fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ROLE, "   uuid=?",
                    new String[]{CoreConst.ROLE_ADMIN_UUID_ADMINISTRATOR}, false);
        }
        if (manager_type == 3) {
            fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ROLE, "    uuid=?",
                    new String[]{CoreConst.ROLE_ADMIN_UUID_HIDDEN}, false);
        }
        if (manager_type == 4) {
            fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ROLE, " uuid= ? ",
                    new String[]{CoreConst.ROLE_ADMIN_UUID_PLANTFORM}, false);
        }
        if (fss != null) {
            managerFs.setValue(CmnConst.ROLE_UUIDS, fss.getUUID());
        } else {
            throw new BaseException(SystemCode.SYSTEM_GET_ROLEUUID_FAIL.getValue(),
                    SystemCode.SYSTEM_GET_ROLEUUID_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
        }
    }

    private void uodateCompanyData(FieldSetEntity fs) {
        if (fs.getString(CmnConst.CLIENTS_UUID) != null) {
            String[] clients_uuid = fs.getString(CmnConst.CLIENTS_UUID).split(",");
            if (clients_uuid != null) {
                for (int i = 0; i < clients_uuid.length; i++) {
                    String client_uuid = clients_uuid[i];
                    DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_SYS_ORG_LEVELS, "client_uuid=?",
                            new String[]{client_uuid});
                    dt = baseDao.listInternationDataTable(dt, null);
                    forManagerDt(dt, fs);

                }
            }
        }
    }

    private void forManagerDt(DataTableEntity dt, FieldSetEntity fs) {
        if (dt.getRows() > 0) {
            for (int j = 0; j < dt.getRows(); j++) {
                FieldSetEntity fsd = dt.getFieldSetEntity(j);
                // 郑盟 2020年12月17日 下午16:05
                if (!StringUtils.isEmpty(fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID))) {
                    boolean ifuuidss = ifuuidss(fsd, fs);
                    if (!ifuuidss)
                        continue;
                } else {
                    fsd.setValue(CmnConst.ORG_LEVEL_MANAGER_UUID, fs.getString("uuid"));
                }
                String sql = "update product_sys_org_levels set org_level_manager_uuid='"
                        + fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID) + "' where uuid=?";
                baseDao.executeUpdate(sql, new String[]{fsd.getUUID()});
            }
        }
    }

    private boolean ifuuidss(FieldSetEntity fsd, FieldSetEntity fs) {
        String uuidss = fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID);
        String[] uuids = new String[100];
        if (uuidss != null && uuidss.contains(",")) {
            uuids = fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID).split(",");
        } else {
            uuids[0] = uuidss;
        }
        if (Arrays.asList(uuids).contains(fs.getUUID())) {
            return false;
        } else {
            fsd.setValue(CmnConst.ORG_LEVEL_MANAGER_UUID,
                    fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID) + "," + fs.getString("uuid"));
            return true;
        }
    }

    private void addManagerSendMail(FieldSetEntity fs, String user_account, String pwd, FieldSetEntity nfs) {
        String login_url = fs.getString(CmnConst.LOGIN_URL);
        nfs.setTableName(CmnConst.STAFF_EMAIL_CONTENT);
        nfs.setValue(CmnConst.LOGIN_URL, login_url);// 登录页面
        nfs.setValue(CmnConst.USER_ACCOUNT, user_account);// 用户名
        nfs.setValue(CmnConst.PASS_WORD, pwd);// 密码
        String olu = fs.getString(CmnConst.ORG_LEVEL_UUID);
        if (olu.indexOf(",") != -1) {
            olu = olu.replace(",", "','");
        }
        // 郑盟 2020年12月17日 下午16:05
        if (StringUtils.isEmpty(olu)) {
            throw new BaseException(SystemCode.SYSTEM_GET_COMPANY_FAIL.getValue(),
                    SystemCode.SYSTEM_GET_COMPANY_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
        }

        String sql = "product_sys_org_levels where  uuid in  ('" + olu + "') ";
        StringBuilder oln = new StringBuilder();
        DataTableEntity dtt = baseDao.listTable(sql);
        if (dtt.getRows() > 0) {
            for (int i = 0; i < dtt.getRows(); i++) {
                FieldSetEntity dfs = dtt.getFieldSetEntity(i);
                String na = dfs.getString(CmnConst.ORG_LEVEL_NAME);
                if (i < 1) {
                    oln.append(na);
                } else {
                    oln.append(",");
                    oln.append(na);
                }
            }
        }
        if (oln.length() == 0) {
            throw new BaseException(SystemCode.SYSTEM_GET_COMPANY_FAIL.getValue(),
                    SystemCode.SYSTEM_GET_COMPANY_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
        }
        nfs.setValue(CmnConst.ORG_LEVEL_NAME, oln);// 公司
        nfs.setValue(CmnConst.USER_PRIMARY_EMAIL, fs.getString(CmnConst.USER_PRIMARY_EMAIL));// 邮箱地址
    }

    private String returnAdd(int manager_type, FieldSetEntity nfs, String add) {
        String resultInfo = null;
        if (manager_type == 2) {
            resultInfo = sendEmailService.parseMailTemplate(CmnConst.NEW_ACCOUNT_MANAGER_ACTIVATION, nfs);
        } else if (manager_type == 3) {
            resultInfo = sendEmailService.parseMailTemplate(CmnConst.NEW_HIDDEN_ADMINISTRATOR_ACTIVATION, nfs);
        } else if (manager_type == 4) {
            resultInfo = sendEmailService.parseMailTemplate(CmnConst.NEW_PLATFORM_ADMINISTRATOR_ACTIVATION, nfs);
        }
        if (SystemCode.SYSTEM_OPERATION_SUCCESS.getText().equals(resultInfo)) {
            return add;
        } else {
            throw new BaseException(SystemCode.SYSTEM_MAIL_SEND_FAIL.getValue(),
                    SystemCode.SYSTEM_MAIL_SEND_FAIL.getText(), this.getClass(), CmnConst.SEND_PASSWORD_RESET_EMAIL);
        }
    }

    /**
     * 更新系统管理员
     *
     * @throws BaseException
     */
    @Transactional
    public boolean updateUser(FieldSetEntity fs) throws BaseException {

        DataTableEntity subDataTable = fs.getSubDataTable(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION);
        String user_uuid = fs.getString("uuid");
        // 郑盟 2020年12月17日 下午16:05
        if (StringUtils.isEmpty(user_uuid))
            return false;
        FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, user_uuid, false);

        FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ORG_MANAGER, "user_id= ?",
                new String[]{userFs.getString(CmnConst.USER_ID)}, false);
        managerFs.setValue(CmnConst.CLIENTS_UUID, fs.getString(CmnConst.CLIENTS_UUID));
        boolean update = baseDao.update(managerFs);
        if (!update)
            return update;
        forClientsUuid(fs);
        if (subDataTable != null) {
            for (int i = 0; i < subDataTable.getRows(); i++) {
                subDataTable.setFieldValue(i, CmnConst.ROLE_UUID, managerFs.getString(CmnConst.ROLE_UUIDS));
                subDataTable.setFieldValue(i, CmnConst.CREATED_BY,
                        SpringMVCContextHolder.getCurrentUser().getUser_id());
                subDataTable.setFieldValue(i, CmnConst.CREATED_UTC_DATETIME, new Date());
            }
            boolean updatePermission = rolesService.updatePermission(subDataTable);
            if (!updatePermission)
                return false;
        }
        Map<String, DataTableEntity> subData = fs.getSubData();
        if (fs.getSubDataTable(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION) != null) {
            subData.remove(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION);
        }
        fs.setSubData(subData);
        fs.setValue("is_manager", 1);
        fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
        if (!BaseUtil.strIsNull(fs.getString(CmnConst.USER_ID))) {
            // xupengcheng updateTime 2020年11月28日10:33:25 管理员绑定员工更新菜单、user对象信息
            updateLoginUserInfoService.updateUserInfoByManagerStaffBindClient(fs.getString(CmnConst.USER_ID), false);
        }
        if ("1".equals(fs.getString(CmnConst.STATUS)) && "0".equals(userFs.getString(CmnConst.STATUS))) {
            fs.setValue("login_fail_num", null);
            fs.setValue("locked_expire_time", null);
        }
        return baseDao.update(fs);
    }

    private void forClientsUuid(FieldSetEntity fs) {
        String[] clients_uuid = null;
        // 更新企业表
        if (!StringUtils.isEmpty(fs.getString(CmnConst.CLIENTS_UUID))) {
            clients_uuid = fs.getString(CmnConst.CLIENTS_UUID).split(",");
        }
        if (clients_uuid != null) {
            for (int i = 0; i < clients_uuid.length; i++) {
                String client_uuid = clients_uuid[i];
                DataTableEntity dt = baseDao.listTable("product_sys_org_levels", "client_uuid=?",
                        new String[]{client_uuid});
                forDt(dt, fs);

            }
        }
    }

    private void forDt(DataTableEntity dt, FieldSetEntity fs) {
        if (dt.getRows() > 0) {
            for (int j = 0; j < dt.getRows(); j++) {
                FieldSetEntity fsd = dt.getFieldSetEntity(j);
                String org_level_manager_uuid = null;
                // 郑盟 2020年12月17日 下午16:05
                if (!StringUtils.isEmpty(fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID))) {
                    String[] uuids = fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID).split(",");
                    if (Arrays.asList(uuids).contains(fs.getString("uuid"))) {
                        continue;
                    } else {
                        org_level_manager_uuid = fsd.getString(CmnConst.ORG_LEVEL_MANAGER_UUID) + "," + fs.getString("uuid");
                    }
                } else {
                    org_level_manager_uuid = fsd.getString("uuid");
                }
                baseDao.executeUpdate(" update product_sys_org_levels set org_level_manager_uuid=? where uuid=?",
                        new String[]{org_level_manager_uuid, fsd.getString("uuid")});
            }
        }
    }

    /**
     * 系统管理员列表
     *
     * @return
     */
    public DataTableEntity listUser(FieldSetEntity fse, String manager_type) throws BaseException {
        String queryFilters = "";
        if (!BaseUtil.dataTableIsEmpty(fse.getSubDataTable("systemSeniorQueryString"))) {
            queryFilters = " and " + queryFilterService.getQueryFilter(fse);
        }
        DataTableEntity dt = getUserType(queryFilters, manager_type, fse);
//        baseDao.loadPromptData(dt);
        return dt;
    }

    private DataTableEntity getUserType(String queryFilters, String manager_type, FieldSetEntity fse) {
        SystemUser user = SpringMVCContextHolder.getCurrentUser();
        if (user.getUserType() == 1) {
            return getUserTypeOne(queryFilters, "2,4", fse);
        } else if (3 == user.getUserType()) {
            return getUserTypeThree(queryFilters, fse, user);
        } else {
            return getUserTypeOther(queryFilters, manager_type, fse, user);
        }
    }

    public DataTableEntity getUserTypeOne(String queryFilters, String manager_type, FieldSetEntity fse) {
        StringBuilder sql = new StringBuilder(
                " SELECT a.*,b.uuid uuid1,b.clients_uuid,b.org_level_uuid,b.manager_type FROM product_sys_users a JOIN product_sys_org_manager b on a.user_id= b.user_id ");
        sql.append("WHERE 1=1  " + queryFilters + " and b.manager_type in(");
        sql.append(manager_type);
        sql.append(") ");
        sql.append(" ORDER BY b.clients_uuid,b.org_level_uuid,b.manager_type");
        DataTableEntity listTable = baseDao.listTable(sql.toString(), new Object[]{}, fse.getInteger(CmnConst.PAGESIZE),
                fse.getInteger(CmnConst.CPAGE));
        baseDao.loadPromptData(listTable);
        return listTable;

    }

    public DataTableEntity getUserTypeThree(String queryFilters, FieldSetEntity fse, SystemUser user) {
        // 隐藏管理员权限 2020年12月22日17:05:30 xupengcheng
        // 隐藏管理员所管理的客户uuid
        String manager_client_uuid = user.getClientUuid();
        StringBuilder sql = new StringBuilder();
        sql.append(" SELECT ");
        sql.append(" a.*, ");
        sql.append(" b.uuid uuid1, ");
        sql.append(" b.clients_uuid, ");
        sql.append(" b.org_level_uuid, ");
        sql.append(" b.manager_type ");
        sql.append(" FROM ");
        sql.append("product_sys_users a ");
        sql.append(" JOIN product_sys_org_manager b ON a.user_id = b.user_id ");
        sql.append(" AND b.clients_uuid = ? ");
        sql.append(" AND concat( ',', b.org_level_uuid, ',' ) LIKE concat( '%,',?, ',%' ) ");
        if (!StringUtils.isEmpty(queryFilters)) {
            sql.append(" AND ");
            sql.append(queryFilters);
        }
        return baseDao.listInternationDataTable(
                baseDao.listTable(sql.toString(), new Object[]{manager_client_uuid, user.getOrg_level_uuid()},
                        fse.getInteger(CmnConst.PAGESIZE), fse.getInteger(CmnConst.CPAGE)),
                null);
    }

    public DataTableEntity getUserTypeOther(String queryFilters, String manager_type, FieldSetEntity fse,
                                            SystemUser user) {
        if (user.getCurrentManager() != null
                && !StringUtils.isEmpty(user.getCurrentManager().getString(CmnConst.CLIENTS_UUID))
                && user.getUserType() == 4) {
            String[] levels = user.getCurrentManager().getString(CmnConst.CLIENTS_UUID).split(",");
            StringBuilder filter = new StringBuilder(" client_uuid=? ");
            if (levels.length > 1) {
                for (int i = 1; i < levels.length; i++) {
                    filter.append(" or client_uuid=? ");
                }
            }
            DataTableEntity org_levels = baseDao.listTable("product_sys_org_levels", filter.toString(), levels);
            StringBuilder sql = new StringBuilder();
            sql.append(
                    " SELECT a.*,b.uuid uuid1,b.clients_uuid,b.org_level_uuid,b.manager_type FROM product_sys_users a JOIN product_sys_org_manager b on a.user_id= b.user_id WHERE b.manager_type in ("
                            + manager_type + ") " + queryFilters + "");
            if (org_levels.getRows() > 0) {
                sql.append(" and (b.org_level_uuid like Concat('%','"
                        + org_levels.getFieldSetEntity(0).getString("uuid") + "','%')");
                for (int i = 1; i < org_levels.getRows(); i++) {
                    sql.append("or b.org_level_uuid like Concat('%','"
                            + org_levels.getFieldSetEntity(i).getString("uuid") + "','%')");
                }
                sql.append(") ORDER BY b.clients_uuid,b.org_level_uuid,b.manager_type");

            }
            return baseDao.listInternationDataTable(baseDao.listTable(sql.toString(), new Object[]{},
                    fse.getInteger(CmnConst.PAGESIZE), fse.getInteger(CmnConst.CPAGE)), null);
        } else if (user.getCurrentManager() != null
                && StringUtils.isEmpty(user.getCurrentManager().getString(CmnConst.CLIENTS_UUID))
                && user.getUserType() == 4) {
            return baseDao.listTable(
                    "SELECT a.*,b.uuid uuid1,b.clients_uuid,b.org_level_uuid,b.manager_type FROM product_sys_users a JOIN product_sys_org_manager b on a.user_id= b.user_id WHERE 1>2 "
                            + queryFilters + "",
                    new Object[]{});
        } else {
            String sql = " SELECT a.*,b.uuid uuid1,b.clients_uuid,b.org_level_uuid,b.manager_type FROM product_sys_users a JOIN product_sys_org_manager b on a.user_id= b.user_id WHERE b.manager_type in("
                    + manager_type + ") " + queryFilters + " ORDER BY b.clients_uuid,b.org_level_uuid,b.manager_type";
            return baseDao.listInternationDataTable(baseDao.listTable(sql, new Object[]{},
                    fse.getInteger(CmnConst.PAGESIZE), fse.getInteger(CmnConst.CPAGE)), null);
        }

    }

    /**
     * 系统管理员删除
     *
     * @return
     */
    @Transactional
    public boolean deleteUser(String uuid) throws BaseException {
        FieldSetEntity fs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "  uuid =?", new String[]{uuid},
                false);
        FieldSetEntity mfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ORG_MANAGER, " user_id =?",
                new String[]{fs.getString(CmnConst.USER_ID)}, false);
        if (mfs != null && !BaseUtil.strIsNull(mfs.getString(CmnConst.USER_ID))) {
            boolean delete = baseDao.delete(CmnConst.PRODUCT_SYS_ORG_MANAGER, " uuid  = ?", new String[]{mfs.getString("uuid")});
            if (delete) {
                // xupengcheng updateTime 2020年11月28日10:33:25 管理员绑定员工更新菜单、user对象信息
                updateLoginUserInfoService.updateUserInfoByManagerStaffBindClient(mfs.getString(CmnConst.USER_ID), false);
            }
        }
        FieldSetEntity staffs_fs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, " user_id= ?",
                new String[]{fs.getString(CmnConst.USER_ID)}, false);
        if (null == staffs_fs || null == staffs_fs.getUUID()) {
            return baseDao.delete(CmnConst.PRODUCT_SYS_USERS, "  uuid  =  ?", new String[]{uuid});
        } else {
            boolean updateStaffsFs = baseDao.executeUpdate("update product_sys_staffs set is_org_admin=0 where uuid=?",
                    new String[]{staffs_fs.getString("uuid")});
            if (!updateStaffsFs) {
                return updateStaffsFs;
            }
            return baseDao.executeUpdate("update product_sys_users set is_manager=0 where user_id=?",
                    new String[]{fs.getString(CmnConst.USER_ID)});
        }
    }

    /**
     * 系统管理员详情
     */
    public FieldSetEntity findUser(FieldSetEntity fs) throws BaseException {
        String user_uuid = fs.getString("uuid");
        if (StringUtils.isEmpty(user_uuid))
            return null;
        FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, user_uuid, false);

        FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_ORG_MANAGER, " user_id=?",
                new String[]{userFs.getString(CmnConst.USER_ID)}, false);
        FieldSetEntity staffsFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, " user_id=?",
                new String[]{userFs.getString(CmnConst.USER_ID)}, false);
        if (null != managerFs) {
            String role_uuid = managerFs.getString(CmnConst.ROLE_UUIDS);
            String sql = "select * FROM product_sys_function_permission where role_uuid in('"
                    + role_uuid.replace(",", "','") + "')";
            DataTableEntity listTable = baseDao.listTable(sql, new Object[]{});
            if (null != listTable && listTable.getRows() > 0) {
                userFs.addSubDataTable(listTable);
            }
            // 郑盟 2020年12月17日 下午16:05
            if (!StringUtils.isEmpty(managerFs.getString(CmnConst.CLIENTS_UUID))) {
                userFs.setValue(CmnConst.CLIENTS_UUID, managerFs.getString(CmnConst.CLIENTS_UUID));
            }
            userFs.setValue(CmnConst.MANAGER_TYPE, managerFs.getString(CmnConst.MANAGER_TYPE));
            userFs.setValue(CmnConst.ORG_LEVEL_UUID, managerFs.getString(CmnConst.ORG_LEVEL_UUID));
        }
        if (null != staffsFs) {
            userFs.setValue("staffs_uuid", staffsFs.getString("uuid"));
        }
        // 处理名字国际化
//		DataTableEntity user_name = baseDao.listTable(.PRODUCT_SYS_language_cont_values",
//				"data_uuid=? and field_name='user_name'", new String[] { user_uuid });
//		if (user_name.getRows() > 0) {
//			List<Map<String, String>> user_names = new ArrayList<>();
//			for (int i = 0; i < user_name.getRows(); i++) {
//				Map<String, String> map = new HashedMap();
//				map.put(user_name.getFieldSetEntity(i).getString("language_code"),
//						user_name.getFieldSetEntity(i).getString("field_value"));
//				map.put("uuid", user_name.getFieldSetEntity(i).getString("uuid"));
//				user_names.add(map);
//			}
//			userFs.setValue(CmnConst.USER_NAME, user_names);
//		}
        return userFs;
    }

    /**
     * 重置密码
     */
    public boolean resetPassword(FieldSetEntity fs) throws BaseException {
        String uuid = fs.getString("uuid");
        FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, uuid, false);
        if (null == userFs)
            return false;
        
        // 后端配置，重置密码模工=mail，则随机生成8位密码，发送到邮件，否则是默认初始密码
        String passWord =CmnConst.RESET_PWD_MODEL_MAIL.equals(Global.getSystemConfig(CmnConst.RESET_PWD_MODEL,CmnConst.RESET_PWD_MODEL_MAIL))? 
        		RandomStringUtils.randomAlphanumeric(8):Global.getSystemConfig(CmnConst.INITIAL_PWD, null);

        // 加密默认密码
        String pwd = userService.createPassWord(userFs.getString(CmnConst.USER_ACCOUNT), passWord);
        userFs.setValue(CmnConst.USER_PWD, pwd);
        if(CmnConst.RESET_PWD_MODEL_MAIL.equals(Global.getSystemConfig(CmnConst.RESET_PWD_MODEL,CmnConst.RESET_PWD_MODEL_MAIL))) {
	        // 密码重置成功发送邮件(无模板，暂未调用)
	        FieldSetEntity nfs = new FieldSetEntity();
	        nfs.setTableName(CmnConst.STAFF_EMAIL_CONTENT);
	        nfs.setValue(CmnConst.LOGIN_URL, fs.getString(CmnConst.LOGIN_URL));// 登录页面
	        nfs.setValue(CmnConst.USER_ACCOUNT, userFs.getString(CmnConst.USER_ACCOUNT));// 用户名
	        nfs.setValue(CmnConst.PASS_WORD, passWord);// 随机新密码
	        nfs.setValue(CmnConst.USER_PRIMARY_EMAIL, userFs.getString(CmnConst.USER_PRIMARY_EMAIL));// 接受邮件邮箱地址
	        sendEmailService.parseMailTemplate(CmnConst.PLATFORM_ADMINISTRATOR_RESET_PASSWORD_EMAIL, nfs);
        }
        return baseDao.update(userFs);
    }

    /**
     * 禁用账号
     */
    public boolean disableAccount(FieldSetEntity fs) throws BaseException {
        String uuid = fs.getString("uuid");
        FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, uuid, false);
        userFs.remove(CmnConst.USER_NAME);
        FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, "user_id=?",
                new String[]{userFs.getString(CmnConst.USER_ID)}, false);
        // 郑盟 2020年12月21日 下午14:05
        managerFs.setValue(CmnConst.IS_USED, fs.getString(CmnConst.STATUS));
        managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
        boolean managerUpdate = baseDao.update(managerFs);
        if (!managerUpdate)
            return managerUpdate;
        FieldSetEntity staffsFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, "user_id=?",
                new String[]{userFs.getString(CmnConst.USER_ID)}, false);
        if (staffsFs == null) {
            userFs.setValue(CmnConst.STATUS, fs.getString(CmnConst.STATUS));
            userFs.setValue(CmnConst.IS_MANAGER, fs.getString(CmnConst.STATUS));
            userFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
            userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
            return baseDao.update(userFs);
        } else {
            staffsFs.setValue("is_org_admin", fs.getString(CmnConst.STATUS));
            staffsFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
            staffsFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
            boolean update = baseDao.update(staffsFs);
            if (!update)
                return update;
            userFs.setValue(CmnConst.IS_MANAGER, fs.getString(CmnConst.STATUS));
            userFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
            userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
            return baseDao.update(userFs);

        }
    }
}