package com.product.admin.service;

import java.util.Date;

import org.apache.commons.lang3.RandomStringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.product.common.lang.DateUtils;
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.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.module.sys.service.UserService;
import com.product.common.lang.StringUtils;
import com.product.email.service.SendEmailService;
import com.product.admin.config.CmnConst;
import com.product.admin.service.idel.ISystemManagerSerivce;

@Component
public class SystemManagerService extends AbstractBaseService implements ISystemManagerSerivce {
    @Autowired
    UserService userService;
    @Autowired
    private SendEmailService sendEmailService;

    public UserService getUserService() {
        return userService;
    }

    public void setUserService(UserService userService) {
        this.userService = userService;
    }

    @Autowired
    public BaseDao baseDao;

    public DataTableEntity getManagerList(String user_uuid) throws BaseException {
        String sql = "SELECT user_uuid,GROUP_CONCAT(`org_level_uuid` SEPARATOR ',') org_level_uuid, role_uuids FROM product_sys_org_manager ";
        if (!StringUtils.isEmpty(user_uuid)) {
            sql += " where org_level_uuid in (SELECT uuid FROM product_sys_org_levels` where org_level_code_parent in (select org_level_uuid FROM product_sys_org_manager where user_uuid='"
                    + user_uuid + "' and manager_type=2) )";
        } else {
            sql += " where manager_type=2";
        }
        sql += " GROUP BY user_uuid,role_uuids";
        return baseDao.listTable(sql, new Object[]{});
    }

    @Transactional
    public String addManager(FieldSetEntity fse) throws BaseException {
        FieldSetEntity userFs = new FieldSetEntity();
        userFs.setTableName(CmnConst.PRODUCT_SYS_USERS);
        userFs.setValue(CmnConst.STATUS, fse.getString(CmnConst.STATUS));
        userFs.setValue(CmnConst.USER_ACCOUNT, fse.getString(CmnConst.USER_ACCOUNT));
        userFs.setValue(CmnConst.USER_NAME, fse.getString(CmnConst.USER_NAME));
        userFs.setValue(CmnConst.USER_PWD, fse.getString(CmnConst.USER_PWD));
        userFs.setValue(CmnConst.IS_MANAGER, 1);// 是否是管理员 0:否 1:是
        String datetime = DateUtils.getDateTime();
        userFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, datetime);
        FieldSetEntity sub = fse.getSubDataTable(CmnConst.PRODUCT_SYS_MANAGER).getData().get(0);
        String[] org_level_uuids = sub.getString("org_level_uuids").split(",");
        String user_uuid = baseDao.add(userFs);
        if (sub.getString("org_level_uuids") != null && org_level_uuids != null) {
            DataTableEntity newSubDataTable = new DataTableEntity();
            FieldMetaEntity f = new FieldMetaEntity();
            f.setTableName(new Object[]{CmnConst.PRODUCT_SYS_MANAGER});
            newSubDataTable.setMeta(f);
            FieldSetEntity newSubFs = null;
            for (int i = 0; i < org_level_uuids.length; i++) {
                newSubFs = new FieldSetEntity();
                newSubFs.setTableName(CmnConst.PRODUCT_SYS_MANAGER);
                newSubFs.setValue(CmnConst.MANAGER_TYPE, 2);// 管理员类型：1超级管理员 2.普通管理员
                newSubFs.setValue(CmnConst.USER_UUID, user_uuid);
                newSubFs.setValue(CmnConst.ORG_LEVEL_UUID, org_level_uuids[i]);// 管理员信息表拆分保存
                newSubFs.setValue(CmnConst.ROLE_UUIDS, "role_uuid_4");// 关联角色，默认普通管理员角色
                newSubFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
                newSubFs.setValue(CmnConst.UPDATED_UTC_DATETIME, datetime);
                newSubDataTable.addFieldSetEntity(newSubFs);
            }

            baseDao.add(newSubDataTable);
        }

        return user_uuid;
    }



    /**
     * 创建隐藏管理员，一个客户只创建一个，关联顶级公司，并且该客户下面创建子公司时，也要关联此管理员
     *
     * @param client 客户，必须包含公司
     * @return
     * @throws BaseException
     */
    @Transactional
    public void addHideManager(FieldSetEntity client) throws BaseException {
        // 用户表
        FieldSetEntity userFs = new FieldSetEntity();
        userFs.setTableName(CmnConst.PRODUCT_SYS_USERS);
        userFs.setValue(CmnConst.STATUS, "1");
        // 生成账户名
        String account = client.getString("client_short_code") + "_hidden_" + (int) ((Math.random() * 9 + 1) * 10000);
        userFs.setValue(CmnConst.USER_ACCOUNT, account);// 使用客户短编码+hidden+5位 随机数字
        // 随机生成8位密码
        String passWord = RandomStringUtils.randomAlphanumeric(8);
        userFs.setValue(CmnConst.USER_NAME, account);
        userFs.setValue(CmnConst.USER_PWD, userService.createPassWord(account, passWord));
        userFs.setValue(CmnConst.IS_MANAGER, 1);// 是否是管理员 0:否 1:是
        String datetime = DateUtils.getDateTime();
        userFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, datetime);
        String uuid = baseDao.add(userFs);
        FieldSetEntity uf = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, uuid, false);
        // 管理员表
        FieldSetEntity newSubFs = new FieldSetEntity();
        newSubFs.setTableName(CmnConst.PRODUCT_SYS_MANAGER);
        newSubFs.setValue(CmnConst.MANAGER_TYPE, 3);// 管理员类型：1超级管理员 2.普通管理员 3.隐藏管理员
        newSubFs.setValue(CmnConst.USER_ID, uf == null ? null : uf.getInteger(CmnConst.USER_ID));
        // 郑盟 2020年12月21日 下午14:05
        newSubFs.setValue(CmnConst.IS_USED, "1");
        newSubFs.setValue(CmnConst.ORG_LEVEL_UUID, client.getString(CmnConst.ORG_LEVEL_UUID));// 管理员关联公司
        newSubFs.setValue(CmnConst.ROLE_UUIDS, "a8e2a6ac-a507-47da-851b-9ac61541cd5a-notchange");// 关联角色，隐藏管理员角色
        newSubFs.setValue(CmnConst.CLIENTS_UUID, client.getString("uuid"));
        newSubFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        newSubFs.setValue(CmnConst.UPDATED_UTC_DATETIME, datetime);
        baseDao.add(newSubFs);

        // 新增隐藏管理员发送邮件
        // 邮件内容
        String user_id = client.getString(CmnConst.CREATED_BY);
        FieldSetEntity khfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, " user_id = ? ",
                new Object[]{user_id}, false);
        if (khfs != null) {
            String login_url = client.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, account);// 用户名
            nfs.setValue(CmnConst.PASS_WORD, passWord);
            nfs.setValue(CmnConst.USER_PRIMARY_EMAIL, khfs.getString(CmnConst.USER_PRIMARY_EMAIL));// 接受邮件邮箱地址
            // 发送邮件
            sendEmailService.parseMailTemplate(CmnConst.NEW_HIDDEN_ADMINISTRATOR_ACTIVATION, nfs);
        }
    }

    /**
     * 隐藏管理员绑定公司
     *
     * @param org_levels 公司
     */
    public void updateHideManagerBindingCompany(FieldSetEntity org_levels) throws BaseException {
        String client_uuid = org_levels.getString(CmnConst.CLIENT_UUID);
        FieldSetEntity manager = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER,
                "clients_uuid=? and manager_type=3", new Object[]{client_uuid}, false);
        if (manager != null) {
            String org_level_uuid = manager.getString(CmnConst.ORG_LEVEL_UUID);
            if (org_level_uuid == null || org_level_uuid.length() == 0) {
                org_level_uuid = org_levels.getString("uuid");
            } else if (!("," + org_level_uuid + ",").contains("," + org_levels.getString("uuid") + ",")) {
                org_level_uuid += "," + org_levels.getString("uuid");
            }
            manager.setValue(CmnConst.ORG_LEVEL_UUID, org_level_uuid);
            baseDao.update(manager);
        }
    }

    /**
     * 隐藏管理员解除绑定公司
     *
     * @param org_levels 公司
     */
    public void updateHideManagerClearCompany(FieldSetEntity org_levels) throws BaseException {
        String client_uuid = org_levels.getString(CmnConst.CLIENT_UUID);
        FieldSetEntity manager = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER,
                "clients_uuid=? and manager_type=3", new Object[]{client_uuid}, false);
        if (manager != null) {
            String org_level_uuid = manager.getString(CmnConst.ORG_LEVEL_UUID);
            if (org_level_uuid != null && org_level_uuid.length() > 0
                    && ("," + org_level_uuid + ",").contains("," + org_levels.getString("uuid") + ",")) {
                org_level_uuid = ("," + org_level_uuid + ",").replaceAll("," + org_levels.getString("uuid") + ",", "");
                org_level_uuid = org_level_uuid.substring(1, org_level_uuid.length() - 1);
            }
            manager.setValue(CmnConst.ORG_LEVEL_UUID, org_level_uuid);
            baseDao.update(manager);
        }
    }

    public boolean updateManager(FieldSetEntity fse) throws BaseException {
        return baseDao.update(fse);
    }

    /**
     * 修改/重置密码
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    public boolean updateManagerPwd(FieldSetEntity fse) throws BaseException {
        FieldSetEntity fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fse.getString(CmnConst.USER_UUID), false);
        String pwd = fse.getString(CmnConst.USER_PWD);
        fs.setValue(CmnConst.USER_PWD, pwd != null ? pwd : "");
        fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
        return baseDao.update(fs);
    }

    /**
     * 删除管理员
     */
    @Transactional
    public boolean deleteManager(FieldSetEntity fse) throws BaseException {
        String user_uuid = fse.getString(CmnConst.USER_UUID);
        boolean flag = false;
        if (!StringUtils.isEmpty(user_uuid)) {
            flag = baseDao.delete(CmnConst.PRODUCT_SYS_MANAGER, "user_uuid=?", new String[]{user_uuid});
            if (!flag)
                return flag;
            flag = baseDao.delete(CmnConst.PRODUCT_SYS_USERS, "uuid=?", new String[]{user_uuid});
        }
        return flag;
    }

    /**
     * 修改管理员状态
     */
    public boolean updateManagerStatus(FieldSetEntity fse) throws BaseException {
        FieldSetEntity fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fse.getString(CmnConst.USER_UUID), false);
        fs.setValue(CmnConst.STATUS, fse.getString(CmnConst.STATUS));// 状态 0：禁用 1：正常
        fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
        fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
        return baseDao.update(fs);
    }

    /**
     * 根据用户uuid 查询管理员
     *
     * @param user_uuid
     * @return
     * @throws BaseException
     */
    public FieldSetEntity findManagerTypeByUserUuid(String user_uuid) throws BaseException {
        return baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, "user_uuid=?", new String[]{user_uuid},
                false);
    }

    /**
     * 公司uuid 查询管理员
     *
     * @param org_level_uuid
     * @return
     * @throws BaseException
     */
    public FieldSetEntity findManagerType(String user_uuid, String org_level_uuid) throws BaseException {
        String filter = "  1=1";
        Object[] objects = new Object[]{};
        // 郑盟 2020年12月17日 下午16:05
        if (!StringUtils.isEmpty(user_uuid)) {
            filter += " and  user_uuid=?";
            objects = new Object[]{user_uuid};
        }
        // 郑盟 2020年12月17日 下午16:05
        if (!StringUtils.isEmpty(org_level_uuid)) {
            filter += " and  org_level_uuid=?";
            if (objects.length == 1) {
                objects = new Object[]{user_uuid, org_level_uuid};
            } else {
                objects = new Object[]{org_level_uuid};
            }
        }

        return baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, filter, objects, false);
    }

    // 随机字母
    public static String getRandStr(int num) {
        String strs = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
        StringBuilder buff = new StringBuilder();
        for (int i = 1; i <= num; i++) {
            char str = strs.charAt((int) (Math.random() * 52));
            buff.append(str);
        }
        return buff.toString();
    }

}