package com.product.data.sync.service;

import com.alibaba.fastjson.JSONObject;
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.PermissionService;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.service.support.QueryFilterService;
import com.product.core.transfer.Transactional;
import com.product.data.sync.config.SystemCode;
import com.product.data.sync.service.ide.IFunctionSynchrService;
import com.product.data.sync.util.DataManipulationUtils;
import com.product.util.BaseDaoServiceImpl;
import com.product.util.BaseUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;


/**
 * Copyright LX
 *
 * @Title: FunctionSynchrService
 * @Project: product-server
 * @date: 2021-08-30 14:19
 * @author: ZhouJie
 * @Description: 开发库功能同步
 */
@Service
public class FunctionSynchrService extends AbstractBaseService implements IFunctionSynchrService {

    @Autowired
    public BaseDao baseDao;
    @Autowired
    PermissionService permissionService;
    @Autowired
    QueryFilterService queryFilterService;

    /**
     * 获取JDBC连接
     *
     * @param fs
     * @return
     * @throws BaseException
     */
    public Connection getConnection(FieldSetEntity fs) throws BaseException, SQLException, ClassNotFoundException {
        String databaseType = fs.getString("type");//数据库类型
        String ipAddress = fs.getString("IP");//ip地址
        String databaseName = fs.getString("database_name");//数据库名称
        String portNumber = fs.getString("port");//端口号
        String userName = fs.getString("username");//用户名
        String userPassword = fs.getString("password");//密码
        String instantiation = fs.getString("");//实例名
        String url;
        String diver;
        if ("mysql".equals(databaseType)) {
            diver = "com.mysql.cj.jdbc.Driver";
            url = "jdbc:mysql://" + ipAddress + ":" + portNumber + "/" + databaseName + "?useSSL=false&serverTimezone=UTC";
        } else if ("oracle".equals(databaseType)) {
            diver = "oracle.jdbc.driver.OracleDriver";
            url = "jdbc:oracle:thin:@" + ipAddress + ":" + portNumber + ":orcl";
        } else if ("sqlserver".equals(databaseType)) {
            diver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
            url = "jdbc:sqlserver://" + ipAddress + ":" + portNumber + ";DataBaseName=" + databaseName;
        } else if ("informix".equals(databaseType)) {
            diver = "com.informix.jdbc.IfxDriver";
            url = "jdbc:informix-sqli://" + ipAddress + ":" + portNumber + "/" + databaseName + ":informixserver=" + instantiation;
        } else {
            throw new BaseException(SystemCode.SYSTEM_UNKNOWN_DATABASE_TYPE.getValue(), SystemCode.SYSTEM_UNKNOWN_DATABASE_TYPE.getText());
        }
        //获取jdbc连接
        return DataManipulationUtils.getConnection(diver, url, userName, userPassword);
    }

    /**
     * 开发库的模块功能树
     *
     * @return
     * @throws BaseException
     */
    public DataTableEntity getSyncTree(FieldSetEntity fse) throws BaseException, SQLException, ClassNotFoundException {
        StringBuilder str = new StringBuilder();
//        str.append(" SELECT uuid,product_name `name`,tricode,null tricode_parent,1 type,concat(tricode,'_',1) only_key FROM product_sys_products ");
//        str.append(" union all select a.uuid,`name`,b.tricode,b.tricode_parent,type,only_key from ( ");
//        str.append(" select  uuid,function_name `name`,2 type,concat(tricode,'_',2) only_key FROM product_sys_functions WHERE data_type=2 ");
//        str.append(" union all select uuid,function_name `name`,3 type,concat(tricode,'_',3) only_key FROM product_sys_functions where data_type=1) a join  ");
//        str.append(""product_sys_module_function_code b on (( a.type=2 and b.data_type=1 ) or (a.type=3 and b.data_type=2)) and a.uuid=b.data_uuid ");
//        str.append(" ORDER BY type ,tricode_parent asc,tricode,length(tricode) asc ");
        str.append(" SELECT uuid,product_name `name`,tricode,null tricode_parent,1 type,concat(tricode,'_',1) only_key FROM product_sys_products ");
        str.append(" union all select a.uuid,`name`,tricode,tricode_parent,type,only_key from ( ");
        str.append(" select  uuid,tricode,tricode_parent,function_name `name`,2 type,concat(tricode,'_',2) only_key FROM product_sys_functions WHERE data_type=2 ");
        str.append(" union all select uuid,tricode,tricode_parent,function_name `name`,3 type,concat(tricode,'_',3) only_key FROM product_sys_functions where data_type=1) a ");
        str.append(" ORDER BY type ,tricode_parent asc,tricode,length(tricode) asc ");
        Connection conn = getConnection(fse);
        DataTableEntity dt = null;
        try {
            dt = BaseDaoServiceImpl.getDataTable(conn, str.toString(), new Object[]{});
        } catch (Exception e) {
            DataManipulationUtils.close(null, null, conn);
            throw e;
        }
        return dt;
    }

    /**
     * 当前库的模块功能树
     *
     * @return
     * @throws BaseException
     */
    public DataTableEntity getNowTree(FieldSetEntity fse) throws BaseException, SQLException, ClassNotFoundException {
        StringBuilder str = new StringBuilder();
//        str.append(" SELECT uuid,product_name `name`,tricode,null tricode_parent,1 type,concat(tricode,'_',1) only_key FROM product_sys_products ");
//        str.append(" union all select a.uuid,`name`,b.tricode,b.tricode_parent,type,only_key from ( ");
//        str.append(" select  uuid,function_name `name`,2 type,concat(tricode,'_',2) only_key FROM product_sys_functions WHERE data_type=2 ");
//        str.append(" union all select uuid,function_name `name`,3 type,concat(tricode,'_',3) only_key FROM product_sys_functions where data_type=1 ) a join  ");
//        str.append(""product_sys_module_function_code b on (( a.type=2 and b.data_type=1 ) or (a.type=3 and b.data_type=2)) and a.uuid=b.data_uuid ");
//        str.append(" ORDER BY type ,tricode_parent asc,tricode,length(tricode) asc ");
        str.append(" SELECT uuid,product_name `name`,tricode,null tricode_parent,1 type,concat(tricode,'_',1) only_key FROM product_sys_products ");
        str.append(" union all select a.uuid,`name`,tricode,tricode_parent,type,only_key from ( ");
        str.append(" select  uuid,tricode,tricode_parent,function_name `name`,2 type,concat(tricode,'_',2) only_key FROM product_sys_functions WHERE data_type=2 ");
        str.append(" union all select uuid,tricode,tricode_parent,function_name `name`,3 type,concat(tricode,'_',3) only_key FROM product_sys_functions where data_type=1) a ");
        str.append(" ORDER BY type ,tricode_parent asc,tricode,length(tricode) asc ");
        DataTableEntity dt = baseDao.listTable(str.toString(), new Object[]{});
        return dt;
    }


    public boolean verificationCode() {
        String b = baseDao.getFieldSetEntityByFilter("product_sys_datamodel_field", "table_uuid='product_sys_functions' and field_name='tricode'", new String[]{}, false).getString("field_type");
        String c = baseDao.getFieldSetEntityByFilter("product_sys_datamodel_field", "table_uuid='product_sys_products' and field_name='tricode'", new String[]{}, false).getString("field_type");
        if ( b.equals("string") && c.equals("string")) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * 功能同步
     *
     * @return
     * @throws BaseException
     */
    @Transactional
    public FieldSetEntity syncFuntion(FieldSetEntity fse) throws BaseException, SQLException, ClassNotFoundException {
        DataTableEntity dt = fse.getSubDataTable("function_info");
        if (dt != null) {
            JSONObject products_uuid = new JSONObject();
            JSONObject modules_uuid = new JSONObject();
            JSONObject functions_uuid = new JSONObject();
            for (int i = 0; i < dt.getRows(); i++) {
                FieldSetEntity fsub = dt.getFieldSetEntity(i);
                if ("1".equals(fsub.getString("type"))) {
                    products_uuid.put(fsub.getString("tricode"), fsub.getString("upADD"));
                } else if ("2".equals(fsub.getString("type"))) {
                    modules_uuid.put(fsub.getString("tricode"), fsub.getString("upADD"));
                } else if ("3".equals(fsub.getString("type"))) {
                    functions_uuid.put(fsub.getString("tricode"), fsub.getString("upADD"));
                }
            }
            ArrayList<String> products_uuid_list = new ArrayList<>();
            ArrayList<String> modules_uuid_list = new ArrayList<>();
            ArrayList<String> functions_uuid_list = new ArrayList<>();
            for (String str : products_uuid.keySet()) {

                products_uuid_list.add(str);
            }
            for (String str : modules_uuid.keySet()) {
                modules_uuid_list.add(str);
            }
            for (String str : functions_uuid.keySet()) {
                functions_uuid_list.add(str);
            }
            Connection conn = getConnection(fse);
            DataTableEntity productsDt = null;
            if (products_uuid_list.size() > 0) {
                productsDt = BaseDaoServiceImpl.getDataTable(conn, "product_sys_products", BaseUtil.buildQuestionMarkFilter("tricode", products_uuid_list.size(), true), products_uuid_list.toArray());
            }
            DataTableEntity modulesDt = null;
            if (modules_uuid_list.size() > 0) {
                modulesDt = BaseDaoServiceImpl.getDataTable(conn, "product_sys_functions","data_type=2 and" +BaseUtil.buildQuestionMarkFilter("tricode", modules_uuid_list.size(), true), modules_uuid_list.toArray());
//                FieldMetaEntity f = new FieldMetaEntity();
//                f.setTableName(new Object[] { "product_sys_modules" });
//                modulesDt.setMeta(f);
            }
            DataTableEntity functionsDt = null;
            if (functions_uuid_list.size() > 0) {
                functionsDt = BaseDaoServiceImpl.getDataTable(conn, "product_sys_functions","data_type=1 and" + BaseUtil.buildQuestionMarkFilter("tricode", functions_uuid_list.size(), true), functions_uuid_list.toArray());
            }
            saveDataDT(productsDt, products_uuid);
            saveDataDT(modulesDt, modules_uuid);
            saveDataDT(functionsDt, functions_uuid);

        }
        return fse;
    }

    public void saveDataDT(DataTableEntity dt, JSONObject js) {
        if (dt != null) {
            for (int i = 0; i < dt.getRows(); i++) {
                FieldSetEntity fs = dt.getFieldSetEntity(i);
                if ("1".equals(js.getString(fs.getString("tricode")))) {
                    if ("行政办公".equals(fs.getString("module_name"))) {
                        System.out.println(111);
                    }
                    fs.setValue("uuid", null);
                    if ("product_sys_products".equals(fs.getTableName())) {
                        fs.setValue("product_id", null);
                        baseDao.add(fs);
                        continue;
                    } else if ("product_sys_functions".equals(fs.getTableName())) {
                        fs.setValue("function_id", null);
//                        String version_uuid = productsMap.getString(fs.getString("version_uuid"));
//                        if (null != version_uuid) {
//                            fs.setValue("product_uuid", version_uuid);
//                        }
                        baseDao.add(fs);
//                        modulesMap.put(fs.getString("tricode"), fs.getString("uuid"));
                        continue;
                    }
//                    else if ("product_sys_functions".equals(fs.getTableName())&&"1".equals(fs.getString("data_type"))) {
//                        fs.setValue("function_id", null);
//                        String tricode = fs.getString("tricode");
//                        String modules_uuid = modulesMap.getString(tricode.substring(0, tricode.length() - 4));
//                        if (null != modules_uuid) {
//                            fs.setValue("module_uuid", modules_uuid);
//                        }
//                        baseDao.add(fs);
//                        continue;
                    }
                }
//                baseDao.update(fs);
//            }
        }
    }

    public static void main(String[] args) {
        String code = "001-017-000";
        String substring = code.substring(0, code.length() - 4);
        System.out.println(substring);
    }
}