package OSI.AOP.MS.VPC.server;
import java.io.IOException;
import java.net.ServerSocket;

import javax.swing.JTextPane;

import ME.APM.VSQ.App;
import MS.OP.SM.AOP.MEC.SIQ.cache.DetaDBBufferCache_M;
import MS.VPC.PP.Time_P;
import MS.VPC.SH.Sleeper;
import MS.VPC.SH.Sleeper_H;
//import OM.config.Config;
import SVQ.stable.StableHTTP;
import SVQ.stable.StableWeb;
import OSI.AOP.MS.VPC.S.hall.DatabaseLog_H;
import VPC.VQS.DSU.utils.DetaUtil;
//作者,著作权人： 罗瑶光，浏阳
public class ServerInit_C {
  private static ServerSocket server;
  //private static Properties properties;
  private static int port;
  private static String dbConfigPath;
  //  private App app;
  //  static {
  //    //properties = new Properties();
  ////    try {
  ////      properties.load(new FileInputStream
  ////          (new File("src/main/resources/property.proterties")));
  ////      System.out.println("----德塔VPCS数据库服务器资源载入:成功！");
  ////    }catch (IOException e) {
  ////      e.printStackTrace();
  ////    }
  //  }

  public void IV_Service(JTextPane jTextPane, String 前端接口Txt) throws IOException {
    try {
      //port= Integer.parseInt(properties.getProperty(StableData.TCP_PORT));
      port= Integer.valueOf(前端接口Txt);
      //port= Config.detaVPCSDBPort;
      server= new ServerSocket(port);
      System.out.println("----德塔VPCS数据库服务器端口启动:" + port);
      if(jTextPane!= null) {
        String text= jTextPane.getText();
        text="\r\n"+ "----德塔VPCS数据库服务器端口启动:" + port+ text;
        text="\r\n"+ "..."+ text;
        jTextPane.setText(text);
      }
      if(null!= dbConfigPath && !dbConfigPath.isEmpty()) {
        dbConfigPath.replace("\\", "/"); //支持 linux reg 格式
        DetaUtil.IV_DB(dbConfigPath);
      }else {
        dbConfigPath= "C:/Users/yaogu/Desktop/project/开源门户/DBconfig.lyg";
        DetaUtil.IV_DB(dbConfigPath);
      }
      System.out.println("----德塔VPCS数据库服务器DMA确认:成功！");
      if(jTextPane!= null) {
        String text= jTextPane.getText();
        text="\r\n"+ "----德塔VPCS数据库服务器DMA确认:成功！"+ text;
        text="\r\n"+ "...";
        jTextPane.setText(text);
      }
      RequestFilter_C.IV_BlockList();
      System.out.println("----德塔VPCS数据库服务器IP过滤服务启动:成功！");
      if(jTextPane!= null) {
        String text= jTextPane.getText();
        text="\r\n"+ "----德塔VPCS数据库服务器IP过滤服务启动:成功！"+ text;
        text="\r\n"+ "...";
        jTextPane.setText(text);
      }
      DetaDBBufferCache_M.reflection();
      System.out.println("----德塔VPCS数据库服务器启动整库过程映射服务:成功！");
      if(jTextPane!= null) {
        String text= jTextPane.getText();
        text="\r\n"+ "----德塔VPCS数据库服务器启动整库过程映射服务:成功！"+ text;
        text="\r\n"+ "...";
        jTextPane.setText(text);
      }
      DatabaseLog_H.I_BinLog_H();
      System.out.println("----德塔VPCS数据库服务器启动整库过程映射服务:成功！");
      if(jTextPane!= null) {
        String text= jTextPane.getText();
        text="\r\n"+ "----德塔VPCS数据库服务器启动整库过程映射服务:成功！"+ text;;
        text="\r\n"+ "...";
        jTextPane.setText(text);
      }
      //      BootBackup.bootBackupByUsingGzip(Cache_M
      //.getCacheInfo("LogPath").getValue().toString()+"/zipCover");
      //      UnZip.unZipWithPath("C:/DetaLog/zipCover/zip_1549583065203.zip"
      //, "C:/DetaLog/zipCover/cover");
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  private void haoHiYooFaker(Sleeper_H sleeper_H) {
    sleeper_H.callSkivvy(); 
  }

  public void IV_Server(App app) throws IOException {
    dbConfigPath= app.dbConfigPath;
    System.out.println("----DETA VPCS--2.0");
    System.out.println("----Author: 罗瑶光");
    System.out.println("----浏阳德塔软件开发有限公司开源项目");
    if(app.appConfig.SectionJPanel.jTextPane!= null) {
      String text= app.appConfig.SectionJPanel.jTextPane.getText();
      text="\r\n"+ "载入德塔 PLSQL数据库 映射添加完毕！"+ text;
      text="\r\n"+ "----Author: 罗瑶光"+ text;
      text="\r\n"+ "----浏阳德塔软件开发有限公司开源项目"+ text;
      text="\r\n"+ "..."+ text;
      app.appConfig.SectionJPanel.jTextPane.setText(text);
    }
    Time_P time_P= new Time_P();
    time_P.begin();
    Sleeper_H sleeper_H = new Sleeper_H();
    IV_Service(app.appConfig.SectionJPanel.jTextPane, app.数据库接口Txt);
    time_P.end();
    if(app.appConfig.SectionJPanel.jTextPane!= null) {
      String text= app.appConfig.SectionJPanel.jTextPane.getText();
      text="\r\n"+ "----德塔VPCS数据库服务器启动一切正常-总耗时:" 
          + time_P.duration()+ "毫秒"+ text;
      text="\r\n"+ "..."+ text;
      app.appConfig.SectionJPanel.jTextPane.setText(text);
    }
    System.out.println("----德塔VPCS数据库服务器启动一切正常-总耗时:" 
        + time_P.duration()+ "毫秒");
    app.ready= true;
    while(true){
      if(sleeper_H.getThreadsCount()< StableWeb.SLEEPERS_RANGE){
        Sleeper sleeper= new Sleeper(app, StableHTTP.PORT_DATABASE);
        try {
          sleeper.hugPillow(sleeper_H, server.accept()
              , sleeper.hashCode());
          sleeper.start();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }else {
        haoHiYooFaker(sleeper_H);
      }
    }
  }
}