package com.product.org.admin.service;

import com.product.admin.service.RolesService;
import com.product.common.lang.StringUtils;
import com.product.core.cache.DataPoolCacheImpl;
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.permission.PermissionLoad;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.org.admin.config.CmnConst;
import com.product.org.admin.config.SystemCode;
import com.product.org.admin.service.idel.ISystemDataPermissionService;
import com.product.util.BaseUtil;

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

import java.util.Map;

/**
 * Copyright © 2020 LX-BASE
 *
 * @Title: LX-BASE-SERVER
 * @Project: base-server-org-admin
 * @Date: 2020年6月11日
 * @Author: Mr.Xu
 * @Description:数据策略Service
 */
@Component
public class SystemDataPermissionService extends AbstractBaseService implements ISystemDataPermissionService {

    @Autowired
    public BaseDao dao;
    @Autowired
    public RolesService rolesService;
    /**
     * 数据权限初始
     */
    @Autowired
    public PermissionLoad permissionLoad = null;

    public PermissionLoad getPermissionLoad() {
        return permissionLoad;
    }

    public void setPermissionLoad(PermissionLoad permissionLoad) {
        this.permissionLoad = permissionLoad;
    }

    /**
     * 数据策略列表
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    public DataTableEntity listDataPermission(FieldSetEntity fse) throws BaseException {
        if (SpringMVCContextHolder.getCurrentUser() != null && SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid() != null) {
            StringBuilder sql = new StringBuilder();
            sql.append(" SELECT ");
            sql.append(" c.uuid org_level_uuid, ");
            sql.append(" c.org_level_name,c.org_level_all, ");
            sql.append(" GROUP_CONCAT( property_name ORDER BY property_name ) property_name ");
            sql.append(" FROM ");
            sql.append("product_sys_data_strategy_master a ");
            sql.append(" JOIN product_sys_data_strategy_properties b ON a.property_uuid = b.uuid ");
            sql.append(" join product_sys_org_levels c on a.org_level_uuid=c.uuid ");
            sql.append(" WHERE ");
            sql.append(" c.uuid = ? ");
            sql.append(" AND a.is_used = 1 ");
            sql.append(" GROUP BY ");
            sql.append(" c.uuid, ");
            sql.append(" c.org_level_name, ");
            sql.append(" c.org_level_all ");
            return dao.listTable(sql.toString(), new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)}, fse.getInteger(CmnConst.PAGESIZE), fse.getInteger(CmnConst.CPAGE));
        }
        return null;
    }

    /**
     * 数据策略详情
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    public FieldSetEntity findDataPermission(FieldSetEntity fse) throws BaseException {
        DataTableEntity dt = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid=?", new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)}, null, null, Integer.MAX_VALUE, 1, true);
        if (!BaseUtil.dataTableIsEmpty(dt)) {
            FieldSetEntity fs = new FieldSetEntity();
            fs.setTableName(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER);
            for (int i = 0; i < dt.getRows(); i++) {
                FieldSetEntity fss = dt.getFieldSetEntity(i);
                if(i==0){
                    fs.setValue(CmnConst.EFFECTIVE_START_DATE,fss.getObject(CmnConst.EFFECTIVE_START_DATE));
                    fs.setValue(CmnConst.EFFECTIVE_END_DATE,fss.getObject(CmnConst.EFFECTIVE_END_DATE));
                    fs.setValue(CmnConst.ORG_LEVEL_UUID,fss.getObject(CmnConst.ORG_LEVEL_UUID));
                }
                fs.setValue("master_uuid_" + fss.getString("property_uuid"), fss.getUUID());
                if (fss.getSubTableNames() != null && fss.getSubTableNames().length > 0) {
                    fs.setValue(fss.getSubTableNames()[0] + "_is_used", fss.getInteger(CmnConst.IS_USED));
                    fs.setValue(fss.getSubTableNames()[0] + "_properties", fss.getString(CmnConst.PROPERTY_UUID));
                }
                Map<String, DataTableEntity> subData = fss.getSubData();
                if (subData != null && subData.size() > 0) {
                    for (String ket_table : subData.keySet()) {
                        fs.addSubDataTable(subData.get(ket_table));
                    }
                }
            }
            return fs;
        }
        return null;
    }

    /**
     * 数据策略详情列表
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    public FieldSetEntity findDataPermissionList(FieldSetEntity fse) throws BaseException {
        DataTableEntity dt = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid=?", new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)}, null, null, Integer.MAX_VALUE, 1, true);
        if (!BaseUtil.dataTableIsEmpty(dt)) {
            if (BaseUtil.strIsNull(fse.getString("date"))) {
                return dt.getFieldSetEntity(0);
            }
            for (int i = 0, length = dt.getRows(); i < length; i++) {
                FieldSetEntity fs = dt.getFieldSetEntity(i);
                if (fs.getSubTableNames() != null && fs.getSubTableNames().length > 0 && fse.getString("date").equals(fs.getSubTableNames()[0])) {
                    fs.setValue(fs.getSubTableNames()[0] + "_is_used", fs.getString(CmnConst.IS_USED));
                    fs.setValue(fs.getSubTableNames()[0] + "_properties", fs.getString(CmnConst.PROPERTY_UUID));
                    return fs;
                }
            }
        }

        return null;
    }

    /**
     * 新增数据策略
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    public boolean addDataPermission(FieldSetEntity fse) throws BaseException {
        DataTableEntity listTable = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid=?", new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)});
        if (!BaseUtil.dataTableIsEmpty(listTable)) { //判断是否存在该公司策略
            throw new BaseException(SystemCode.SYSTEM_DATA_PERMISSION_ALREADY_EXIST_ADD_FAIL.getValue(), SystemCode.SYSTEM_DATA_PERMISSION_ALREADY_EXIST_ADD_FAIL.getText(), this.getClass(), "addDataPermission");
        }
        Map<String, DataTableEntity> subData = fse.getSubData();
        DataTableEntity masterDt = new DataTableEntity();
        if (fse.getSubData().size() != 0) {
            FieldMetaEntity f = new FieldMetaEntity();
            masterDt.setMeta(f);
            f.setTableName(new Object[]{CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER});
        }
        if (subData != null && subData.size() > 0) {
            for (String sub_table_name : subData.keySet()) {
                if (subData.get(sub_table_name) != null) {
                    FieldSetEntity fs = new FieldSetEntity();
                    fs.setMeta(fse.getMeta());
                    fs.setValue(CmnConst.IS_USED, fse.getString(sub_table_name + "_is_used"));
                    fs.setValue(CmnConst.PROPERTY_UUID, fse.getString(sub_table_name + "_properties"));
                    fs.setValue("org_level_uuid", fse.getString("org_level_uuid"));
                    fs.setValue(CmnConst.EFFECTIVE_START_DATE, fse.getString(CmnConst.EFFECTIVE_START_DATE));
                    fs.setValue(CmnConst.EFFECTIVE_END_DATE, fse.getString(CmnConst.EFFECTIVE_END_DATE));
                    fs = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fs);
                    DataTableEntity subDataTable = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), subData.get(sub_table_name));
                    fs.addSubDataTable(subDataTable);
                    masterDt.addFieldSetEntity(fs);
                }
            }
        }
        boolean re = dao.add(masterDt);
        //刷新单位的数据权限
        if (re) {
            DataPoolCacheImpl.getInstance().reFreshCacheDataByPermission(fse.getString(CmnConst.ORG_LEVEL_UUID));
        }
        return re;
    }

    /**
     * 新增数据策略
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    public boolean saveDataPermission(FieldSetEntity fse) throws BaseException {
        if (StringUtils.isEmpty(fse.getUUID())) {
            DataTableEntity listTable = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid=?", new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)});
            if (!BaseUtil.dataTableIsEmpty(listTable)) { //判断是否存在该公司策略
                throw new BaseException(SystemCode.SYSTEM_DATA_PERMISSION_ALREADY_EXIST_ADD_FAIL.getValue(), SystemCode.SYSTEM_DATA_PERMISSION_ALREADY_EXIST_ADD_FAIL.getText(), this.getClass(), "addDataPermission");
            }
        }
        Map<String, DataTableEntity> subData = fse.getSubData();
        DataTableEntity masterDt = new DataTableEntity();
        if (fse.getSubData().size() != 0) {
            FieldMetaEntity f = new FieldMetaEntity();
            masterDt.setMeta(f);
            f.setTableName(new Object[]{CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER});
        }
        if (subData != null && subData.size() > 0) {
            for (String sub_table_name : subData.keySet()) {
                if (subData.get(sub_table_name) != null) {
                    FieldSetEntity fs = new FieldSetEntity();
                    fs.setMeta(fse.getMeta());
                    fs.setValue(CmnConst.IS_USED, fse.getString(sub_table_name + "_is_used"));
                    fs.setValue(CmnConst.PROPERTY_UUID, fse.getString(sub_table_name + "_properties"));
                    fs.setValue("org_level_uuid", fse.getString("org_level_uuid"));
                    fs.setValue(CmnConst.EFFECTIVE_START_DATE, fse.getString(CmnConst.EFFECTIVE_START_DATE));
                    fs.setValue(CmnConst.EFFECTIVE_END_DATE, fse.getString(CmnConst.EFFECTIVE_END_DATE));
                    fs = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fs);
                    DataTableEntity subDataTable = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), subData.get(sub_table_name));
                    fs.addSubDataTable(subDataTable);
                    masterDt.addFieldSetEntity(fs);
                }
            }
        }
        boolean re = dao.add(masterDt);
        //刷新单位的数据权限
        if (re) {
            DataPoolCacheImpl.getInstance().reFreshCacheDataByPermission(fse.getString(CmnConst.ORG_LEVEL_UUID));
        }
        return re;
    }

    /**
     * 数据策略修改提交
     * cheng 2021年4月16日16:28:39
     * 批量修改数据策略
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    @Override
    public boolean updateDataPermission(FieldSetEntity fse) throws BaseException {
        if (fse != null ) {
            String effective_start_date = fse.getString(CmnConst.EFFECTIVE_START_DATE);
            String effective_end_date = fse.getString(CmnConst.EFFECTIVE_END_DATE);
            //罗鑫2021年3月1日 开始时间不能大于结束时间  cheng 2021年4月16日16:52:14 copy
            if (BaseUtil.strIsNull(effective_start_date)) {
                throw new BaseException(com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getValue(), com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getText(), this.getClass(), "public boolean updateDataPermissionBasics(FieldSetEntity fse)throws BaseException");
            }
            if (!BaseUtil.strIsNull(effective_end_date)) {
                if (BaseUtil.temporalComparison(effective_start_date, effective_end_date)) {
                    throw new BaseException(com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_FAIL.getValue(), com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_FAIL.getText(), this.getClass(), "public boolean updateDataPermissionBasics(FieldSetEntity fse)throws BaseException");
                }
            }
            DataTableEntity master_add = new DataTableEntity();
            DataTableEntity master_update = new DataTableEntity();
            Map<String, DataTableEntity> subData = fse.getSubData();
            if (subData != null && subData.size() > 0) {
                for (String sub_table_name : subData.keySet()) {
                    if (subData.get(sub_table_name) != null) {
                        String uuid = fse.getString("master_uuid_" + fse.getString(sub_table_name + "_properties"));
                        FieldSetEntity fs = new FieldSetEntity();
                        fs.setMeta(fse.getMeta());
                        fs.setValue(CmnConst.IS_USED, fse.getString(sub_table_name + "_is_used"));
                        fs.setValue(CmnConst.PROPERTY_UUID, fse.getString(sub_table_name + "_properties"));
                        fs.setValue(CmnConst.UUID, uuid);
                        fs.setValue("org_level_uuid", fse.getString("org_level_uuid"));
                        fs.setValue(CmnConst.EFFECTIVE_START_DATE, fse.getString(CmnConst.EFFECTIVE_START_DATE));
                        fs.setValue(CmnConst.EFFECTIVE_END_DATE, fse.getString(CmnConst.EFFECTIVE_END_DATE));
                        DataTableEntity subDataTable = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), subData.get(sub_table_name));
                        fs.addSubDataTable(subDataTable);
                        if(StringUtils.isEmpty(uuid)){
                            fs = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fs);
                            master_add.addFieldSetEntity(fs);
                        }else{
                            fs = BaseUtil.updatedRegeneratorAndUpdateTime(SpringMVCContextHolder.getCurrentUser(), fs);
                            master_update.addFieldSetEntity(fs);
                        }
                    }
                }
            }
            if(master_add.getRows()>0){
                dao.add(master_add);
            }
            if(master_update.getRows()>0){
                dao.add(master_update);
            }
            return true;
        }
        return false;
    }

    /**
     * 修改数据策略
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    public boolean updateDataPermissionBasics(FieldSetEntity fse) throws BaseException {
        BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fse);
        String effective_start_date = fse.getString(CmnConst.EFFECTIVE_START_DATE);
        String effective_end_date = fse.getString(CmnConst.EFFECTIVE_END_DATE);
        //罗鑫2021年3月1日 开始时间不能大于结束时间
        if (BaseUtil.strIsNull(effective_start_date)) {
            throw new BaseException(com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getValue(), com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getText(), this.getClass(), "public boolean updateDataPermissionBasics(FieldSetEntity fse)throws BaseException");
        }
        if (!BaseUtil.strIsNull(effective_end_date)) {
            if (BaseUtil.temporalComparison(effective_start_date, effective_end_date)) {
                throw new BaseException(com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_FAIL.getValue(), com.product.admin.config.SystemCode.SYSTEM_VALID_TIME_FAIL.getText(), this.getClass(), "public boolean updateDataPermissionBasics(FieldSetEntity fse)throws BaseException");
            }
        }
        DataTableEntity dataTableEntity = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid = ?", new String[]{fse.getString("org_level_uuid")});
        if (effective_end_date != null && effective_end_date.length() > 0) {
            for (int i = 0, length = dataTableEntity.getRows(); i < length; i++) {
                dataTableEntity.getFieldSetEntity(i).setValue(CmnConst.EFFECTIVE_START_DATE, fse.getString(CmnConst.EFFECTIVE_START_DATE));
                dataTableEntity.getFieldSetEntity(i).setValue(CmnConst.EFFECTIVE_END_DATE, effective_end_date);
            }
        } else {
            for (int i = 0, length = dataTableEntity.getRows(); i < length; i++) {
                dataTableEntity.getFieldSetEntity(i).setValue(CmnConst.EFFECTIVE_START_DATE, fse.getString(CmnConst.EFFECTIVE_START_DATE));
            }
        }

        boolean re = dao.update(dataTableEntity);
        //刷新单位的数据权限
        if (re) {
            DataPoolCacheImpl.getInstance().reFreshCacheDataByPermission(fse.getString(CmnConst.ORG_LEVEL_UUID));
        }
        return re;
    }

    /**
     * 删除数据策略
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    public boolean deleteDataPermission(FieldSetEntity fse) throws BaseException {

        DataTableEntity dt = dao.listTable(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER, "org_level_uuid=?", new Object[]{fse.getString(CmnConst.ORG_LEVEL_UUID)}, null, null, Integer.MAX_VALUE, 1, true);
        Object[] split = dt.getUuids();
        if (BaseUtil.dataTableIsEmpty(dt) || dt.getUuids() == null || split.length <= 0) {
            throw new BaseException(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText(), this.getClass(), "deleteDataPermission");
        }
        String placeholder = "";
        for (int i = 0; i < split.length; i++) {
            placeholder += ",?";
        }
        boolean re = dao.delete(fse.getTableName(), "uuid in (" + placeholder.substring(1) + ")", split);
        //刷新单位的数据权限
        if (re) {
            DataPoolCacheImpl.getInstance().reFreshCacheDataByPermission(fse.getString(CmnConst.ORG_LEVEL_UUID));
        }
        return re;
    }

    /**
     * @param fse
     * @return
     * @throws BaseException
     */
    public DataTableEntity listModulesAndFunctions(FieldSetEntity fse) throws BaseException {
        return rolesService.listFunctionRoleForClients(null, fse.getString("client_role_uuid"), false);
    }

    /**
     * 修改数据策略详情
     *
     * @param fse
     * @return
     * @throws BaseException
     */
    @Transactional
    public boolean updateDataPermissionDetails(FieldSetEntity fse) throws BaseException {
        int is_used = fse.getInteger(fse.getTableName() + "_is_used");
        String property_uuid = fse.getString(fse.getTableName() + "_properties");
        //针对哪家公司进行配置：关联组织架构UUID
        String org_level_uuid = fse.getString("org_level_uuid");
        FieldSetEntity master = new FieldSetEntity();
        master.setTableName(CmnConst.PRODUCT_SYS_DATA_STRATEGY_MASTER);
        master.setValue(CmnConst.IS_USED, is_used);
        master.setValue(CmnConst.PROPERTY_UUID, property_uuid);
        master.setValue("org_level_uuid", org_level_uuid);
        Map<String, DataTableEntity> details = fse.getSubData();
        DataTableEntity dt = details.get(fse.getSubTableNames()[0]);
        boolean status = false;
        String strategy_uuid;
        if (dt != null && dt.getRows() > 0) {
            if (dt.getFieldSetEntity(0).getString(CmnConst.STRATEGY_UUID) == null) {
                master = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), master);
                strategy_uuid = dao.add(master);
                status = true;
            } else {
                strategy_uuid = dt.getFieldSetEntity(0).getString(CmnConst.STRATEGY_UUID);
                master.setValue("uuid", strategy_uuid);
                master = BaseUtil.updatedRegeneratorAndUpdateTime(SpringMVCContextHolder.getCurrentUser(), master);
                status = dao.update(master);
            }
            for (int i = 0; i < dt.getRows(); i++) {
                FieldSetEntity fs = dt.getFieldSetEntity(i);
                fs.setTableName(fse.getTableName());
                if (StringUtils.isEmpty(fs.getString("uuid")) && !"del".equals(fs.getString("type"))) {
                    fs.setValue(CmnConst.STRATEGY_UUID, strategy_uuid);
                    fs = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fs);
                    dao.add(fs);
                } else if (!StringUtils.isEmpty(fs.getString("uuid")) && !"del".equals(fs.getString("type"))) {
                    fs.remove("created_utc_datetime");
                    fs.remove("updated_utc_datetime");
                    fs = BaseUtil.updatedRegeneratorAndUpdateTime(SpringMVCContextHolder.getCurrentUser(), fs);
                    dao.update(fs);
                } else {
                    dao.delete(fs.getTableName(), "uuid=?", new String[]{fs.getString("uuid")});
                }
            }
            //更新数据权限缓存
            //刷新单位的数据权限
            DataPoolCacheImpl.getInstance().reFreshCacheDataByPermission(fse.getString(CmnConst.ORG_LEVEL_UUID));
            return status;
        }
        return false;
    }
}