package ME.SM.OP.SM.AOP.MEC.SIQ.E;
import java.io.File;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArrayList;

import MS.OP.SM.AOP.MEC.SIQ.cache.DetaDBBufferCache_M;
import MSD.OP.SM.AOP.MEC.SIQ.SM.OSD.E.D_Rows_E;
import MSI.OP.SM.AOP.MEC.SIQ.SM.OSI.E.I_Tables_E;
import MSI.OP.SM.AOP.MEC.SIQ.SM.OSU.E.IU_Rows_E;
import MSQ.OP.SM.AOP.MEC.SIQ.SM.OSQ.E.Q_JoinRows_E;
import MSQ.OP.SM.AOP.MEC.SIQ.SM.OSQ.E.Q_Rows_E;
import MSU.OP.SM.AOP.MEC.SIQ.SM.update.E.U_JoinRows_E;
import MSU.OP.SM.AOP.MEC.SIQ.SM.update.E.U_Rows_E;
import OP.SM.AOP.MEC.SIQ.SM.reflection.Base;
import OP.SM.AOP.MEC.SIQ.SM.reflection.Table;
import PEU.P.cache.*;
import SVQ.stable.StableShellETL;
@SuppressWarnings("unchecked")
//作者,著作权人： 罗瑶光，浏阳
public class PLSQLCommand_E {
  public static void P_SetRoot(String[] acknowledge, Map<String, Object> output)
      throws Exception {
    String dbPath = acknowledge[1];
    for(int i=2; i<acknowledge.length; i++) {
      dbPath += ":" + acknowledge[i];
    }
    if(null != Cache_M.getCacheInfo("DBPath")) {
      File file = new File(dbPath);
      if(!file.exists()) {
        file.mkdirs();
        Cache c = new Cache();
        c.I_Value(dbPath);
        Cache_M.putCache("DBPath", c);
      }else if(file.isFile()) {
        throw new Exception();
      }else if(file.isDirectory()) {
        Cache c = new Cache();
        c.I_Value(dbPath);
        Cache_M.putCache("DBPath", c);
      }
    }
  }

  public static void P_BaseName(String[] acknowledge, Map<String, Object> object) {
    object.put(acknowledge[0], acknowledge[1]);
  }

  public static void P_TableName(String[] acknowledge, Map<String, Object> object) {
    object.put(acknowledge[0], acknowledge[1]);
    object.put("type", acknowledge[2]);
  }

  public static void P_ListNeedStart(String[] acknowledge, Map<String, Object> object) {
    object.put("start", "1");
    if(object.containsKey(acknowledge[0])) {
      List<String[]> relationValues = (List<String[]>) object.get(acknowledge[0]);
      relationValues.add(acknowledge);
      object.put(acknowledge[0], relationValues);
      return;
    }
    List<String[]> relationValues = new CopyOnWriteArrayList<>();
    relationValues.add(acknowledge);
    object.put(acknowledge[0], relationValues);
  }

  public static void P_Join(String[] acknowledge, Map<String, Object> object) {
    if(object.get("countJoins").toString().equals("1")) {
      object.put("countJoins", "n");
    }
    if(object.get("countJoins").toString().equals("0")) {
      object.put("countJoins", "1");
    }
    object.put(StableShellETL.SHELL_ETL_JOIN_BASE_NAME, acknowledge[1]);
    object.put("joinTableName", acknowledge[2]);
  }

  public static void P_E(String[] acknowledge, Map<String, Object> object
      , boolean mod) throws Exception {
    if(object.get("start").toString().equals("1")) {
      if(!acknowledge[0].equalsIgnoreCase(object.get("lastCommand").toString())
          &&(object.get("lastCommand").toString().contains("changeCulumnName")
              ||object.get("lastCommand").toString().contains("culumnValue")
              ||object.get("lastCommand").toString().contains(StableShellETL.SHELL_ETL_CONDITION)
              ||object.get("lastCommand").toString().contains("relation")
              ||object.get("lastCommand").toString().contains("aggregation")
              ||object.get("lastCommand").toString().contains("getCulumns")
              ||object.get("lastCommand").toString().contains(StableShellETL.SHELL_ETL_CULUMNNAME)
              ||object.get("lastCommand").toString().contains("relation"))) {
        P_E_Kernel(object, mod);
      }
    }
  }
//处理机中心, 别急, 准备验证 罗瑶光
  private static void P_E_Kernel(Map<String, Object> object, boolean mod) throws Exception{
    if(object.get("type").toString().equalsIgnoreCase("select") && 
        (object.get("countJoins").toString().equalsIgnoreCase("0") ||
            (object.get("countJoins").toString().equalsIgnoreCase("1") && object.get("newCommand").toString().equalsIgnoreCase("join")))){
      if(object.containsKey(StableShellETL.SHELL_ETL_CONDITION)) {
        object.put("obj", Q_Rows_E.selectRowsByAttributesOfCondition(object));
      }
      if(object.containsKey("aggregation")) {
        object.put("obj", Q_Rows_E.selectRowsByAttributesOfAggregation(object));
      }
      if(object.containsKey("getCulumns")) {
        object.put("obj", Q_Rows_E.selectRowsByAttributesOfGetCulumns(object));
      }
      object.remove("recordRows");
    }
    if(object.get("type").toString().equalsIgnoreCase("select") && 
        (object.get("countJoins").toString().equalsIgnoreCase("n") ||
            (object.get("countJoins").toString().equalsIgnoreCase("1")
                && !object.get("newCommand").toString().equalsIgnoreCase("join")))){
      if(object.containsKey(StableShellETL.SHELL_ETL_CONDITION)) {
        object.put("joinObj", Q_JoinRows_E.selectRowsByAttributesOfJoinCondition(object));
      }
      if(object.containsKey("relation")) {
        object.put("obj", Q_JoinRows_E.selectRowsByAttributesOfJoinRelation(object));
      }
      if(object.containsKey("aggregation")) {
        object.put("obj", Q_JoinRows_E.selectRowsByAttributesOfJoinAggregation(object));
      }
      if(object.containsKey("getCulumns")) {
        object.put("joinObj", Q_JoinRows_E.selectRowsByAttributesOfJoinGetCulumns(object));
      }
      object.remove("recordRows");
    }
    if(object.get("type").toString().equalsIgnoreCase("create")){
      if(object.containsKey(StableShellETL.SHELL_ETL_CULUMNNAME)) {
        I_Tables_E.I_Table(object, mod);
      }
      object.remove("recordRows");
    }
    //离散数学的conjuction变换  a^&&b^&&c * kernel[] = (a^&&b^)^^&&c * kernel[] = (a||b)^&&c * kernel[]
    if(object.get("type").toString().equalsIgnoreCase("update") && 
        (object.get("countJoins").toString().equalsIgnoreCase("0") ||
            (object.get("countJoins").toString().equalsIgnoreCase("1") 
                && object.get("newCommand").toString().equalsIgnoreCase("join")))){
      if(object.containsKey(StableShellETL.SHELL_ETL_CONDITION)) {
        object.put("updateObj", U_Rows_E.updateRowsByAttributesOfCondition(object, mod));
      }
      if(object.containsKey("aggregation")) {
        object.put("updateObj", U_Rows_E.updateRowsByAttributesOfAggregation(object, mod));
      }
      if(object.containsKey("culumnValue")) {
        U_Rows_E.updateRowsByRecordConditions(object, mod);
      }
      object.remove("recordRows");
    }
    if(object.get("type").toString().equalsIgnoreCase("update") && 
        (object.get("countJoins").toString().equalsIgnoreCase("n") ||
            (object.get("countJoins").toString().equalsIgnoreCase("1") 
                && !object.get("newCommand").toString().equalsIgnoreCase("join")))){
      if(object.containsKey(StableShellETL.SHELL_ETL_CONDITION)) {
        object.put("updateJoinObj"
            , U_JoinRows_E.updateRowsByAttributesOfJoinCondition(object, mod));
      }
      if(object.containsKey("relation")) {
        object.put("updateObj"
            , U_JoinRows_E.updateRowsByAttributesOfJoinRelation(object, mod));
      }
      if(object.containsKey("aggregation")) {
        object.put("updateObj"
            , U_JoinRows_E.updateRowsByAttributesOfJoinAggregation(object, mod));
      }
      if(object.containsKey("culumnValue")) {
        U_Rows_E.updateRowsByRecordConditions(object, mod);
      }
      object.remove("recordRows");
    }
    if(object.get("type").toString().equalsIgnoreCase("insert")) {
      if(object.containsKey("culumnValue")) {
        IU_Rows_E.IU_RowByAttributes(object, mod);
      }
    }
    if(object.get("type").toString().equalsIgnoreCase("delete")) {
      if(object.containsKey(StableShellETL.SHELL_ETL_CONDITION)) {
        D_Rows_E.D_RowByAttributesOfCondition(object, mod);
      }
    }
    object.remove(StableShellETL.SHELL_ETL_CONDITION);
    object.remove(StableShellETL.SHELL_ETL_CULUMNNAME);
    object.remove("changeCulumnName");
    object.remove("getCulumns");
    object.remove("relation");
    object.remove("aggregation");
    object.remove("getCulumns");
    object.put("start", "0");
  }
    
  //plsql函数执行指令 正在检查中 罗瑶光 20210405
  public static void P_Check(String acknowledge, Map<String, Object> object
      , boolean mod) throws Exception {
    if(object.get("start").toString().equals("1")) {
      P_E_Kernel(object, mod);
    }
    List<Map<String, Object>> obj = ((List<Map<String, Object>>)(object.get("obj")));
    int totalPages = 0;
    if(obj != null) {
      totalPages = obj.size();
    }
    int rowBeginIndex = object.containsKey("pageBegin")
        ? Integer.valueOf(object.get("pageBegin").toString()):0;
    int rowEndIndex = object.containsKey("pageEnd")
        ?Integer.valueOf(object.get("pageEnd").toString()):totalPages>15?15:totalPages;
    object.put("pageBegin", rowBeginIndex);
    object.put("pageEnd", rowEndIndex);

    String DBPath= Cache_M.getCacheInfo("DBPath").getValue().toString() 
        + "/" + object.get("baseName").toString();
    String DBTablePath = DBPath + "/" + object.get("tableName").toString();
    object.put("tablePath", DBTablePath);
    object.put("returnResult", "success");
    object.put("totalPages", totalPages);
    object.put("loginInfo", "success");
    List<Object> spec = new ArrayList<>();
    Iterator<String> iterator = new ArrayList<String>().iterator();
    if(obj== null || obj.size()< 1) {
      Base base= DetaDBBufferCache_M.db.getBase(object.get("baseName").toString());
      Table table= base.getTable(object.get("tableName").toString());
      if(null!= table) {
        iterator= table.getSpec().getCulumnTypes().keySet().iterator();
      }
    }else {//进行map 验证检测 罗瑶光 20210405
      Map<String, Object> map= obj.get(0);
      Map<String, Object> objectInMap
      = (Map<String, Object>)map.get(StableShellETL.SHELL_ETL_ROWVALUE);
      iterator = null== objectInMap? null:objectInMap.keySet().iterator();
    }
    if(iterator != null) {
      while(iterator.hasNext()) {
        spec.add(iterator.next());
      }
    }
    object.put("spec", spec);
  }
}