import java.io.*;
import java.net.*;
import java.util.*;
import java.sql.*;
public class Jututuba6{
  static Vector kasutajad=new Vector();
  public static void main(String argumendid[]) throws IOException{
    ServerSocket ss=new ServerSocket(3001);
    while(true){
      kasutajad.add(new Kasutaja(ss.accept()));      
    }
  }
  
  
 static class Kasutaja extends Thread{
  PrintWriter kirjutusvoog;
  Socket sc;
  String[] smiley={};
  String[] komments={};
  int i;
  int j;
  int n;
  boolean oigus=false;
  String kasutajanimi="nimetu";
  String sugu="puudub";
  String kirjeldus="";
  String nimi="nimetu";
  String nimi3="nimetu";
  String passwd="pole";
  String passwd1="pole1";
  String level="1";
  public Kasutaja(Socket uus_sc){
    sc=uus_sc;
    try{
      kirjutusvoog=new PrintWriter(sc.getOutputStream(), true);
    }catch(Exception e){e.printStackTrace();}
	loeFailist();
    start();
  }
  public void run(){
    try{
      BufferedReader sisse=new BufferedReader(
        new InputStreamReader(sc.getInputStream())
      );
      kirjutusvoog.println("*******    *********   **    **     *****     **    **  **     ****   ");
	  kirjutusvoog.println("**    **   *********   ***  ***    **   **    ***   **  **    **  **  ");
	  kirjutusvoog.println("**     **  ***         ********   **     **   ****  **  **   **    ** ");
	  kirjutusvoog.println("**     **  *****       ** ** **  **       **  ** ** **  **  **      **");
	  kirjutusvoog.println("**     **  ***         **    **  **       **  **  ****  **  **********");
	  kirjutusvoog.println("**    **   *********   **    **   **     **   **   ***  **  **      **");
	  kirjutusvoog.println("******     *********   **    **    *******    **    **  **  **      **");
	  kirjutusvoog.println("");
	  kirjutusvoog.println("Palun anna oma kasutajanimi: ");
      kasutajanimi=sisse.readLine();
	  kirjutusvoog.println("Palun anna oma password: ");
	  passwd=sisse.readLine();
	  level="1";
	  BufferedReader sisse1=new BufferedReader(new FileReader("kasutajad.txt"));
	  String oigeparol="";
	  boolean korras=false;
	  boolean valepass=false;
	  boolean leitudkasutaja=false;
	  String rida1=sisse1.readLine();
	  while (rida1!=null){
	  StringTokenizer stk=new StringTokenizer(rida1, "!");
	  String kasut=stk.nextToken();
	  String pass=stk.nextToken();
	  if (kasut.equals(kasutajanimi)){
	  if (pass.equals(passwd)){
	  korras=true;
	  }else{valepass=true;
	  oigeparol=pass;
	  }leitudkasutaja=true;
	  }
	  rida1=sisse1.readLine();
	  }
	  if (valepass==true){
	  kirjutusvoog.println("Sa tegid vea parooli sisestamisel.Palun anna uuesti oma password: ");
	  passwd=sisse.readLine();
	  if (oigeparol.equals(passwd)){
	  valepass=false;
	  }else{kirjutusvoog.println("Sa sisestasid ikka vale parooli, järelikult ei ole sa õige kasutaja!");
	  sc.close();
	  }
	  }
	  if(leitudkasutaja==false){
	  kirjutusvoog.println("Tere tulemast uus kasutaja!");
	  kirjutusvoog.println("Kas oled Naine/Mees/Muu?: ");
	  sugu=sisse.readLine();
	  kirjutusvoog.println("Palun anna oma kirjeldus: ");
	  kirjeldus=sisse.readLine();
      kirjutusvoog.println("Palun korda oma parooli igaks juhuks: "); 
      passwd1=sisse.readLine(); 
      if (passwd.equals(passwd1)){ 
      passwd=passwd1; 
      }else{ 
      kirjutusvoog.println("Tegid vea parooli teistkordsel sisestamisel!"); 
      kirjutusvoog.println("Palun korda oma parooli uuesti: "); 
      passwd1=sisse.readLine(); 
      if (passwd.equals(passwd1)){ 
      passwd=passwd1; 
      }else{ 
      sc.close(); 
      } 
      } 
	  PrintWriter valja=new PrintWriter(new FileWriter("kasutajad.txt", true));
	  valja.println(kasutajanimi+"!"+passwd);
      valja.close();
	  }
      andmbaas();
	  for(int i=0; i<kasutajad.size(); i++){
	  Kasutaja k=(Kasutaja)kasutajad.elementAt(i);	
	  k.kirjutusvoog.println("Jutukasse tuli "+kasutajanimi);
	  }
	  kirjutusvoog.println("Tere "+kasutajanimi);
	  if (kasutajanimi.equals("Maxman")){
	  oigus=true;
	  }else{
	  oigus=false;
	  }
	  kirjutusvoog.println("Praegu on jutukas:");
	  saadaInfo();
		kirjutusvoog.println("Kui sa ei tea  mis siin teha saab siis trüki lihtsalt .käsk");
      boolean veel=true;
      while(veel){
         String rida=sisse.readLine();
		 j=smiley.length+1;
         for(n=0;n<smiley.length;n++){
             System.out.println(smiley[n]+" "+komments[i]);
             if(rida.endsWith(smiley[n])){
              j=n;
			 }
			 }
         System.out.println(rida);
         if(rida.startsWith(".")){                   //käsklused
            if(rida.startsWith(".quit"))veel=false;
            if(rida.startsWith(".era"))saadaErateade(rida);
			if(rida.startsWith(".who"))saadaInfo();
			if(rida.startsWith(".emot"))naitaEmo();
			if(rida.startsWith(".käsk"))naitaKask();
			if(rida.startsWith(".kell"))kell();
            if(rida.startsWith(".level")){
			if (oigus==true){
			nimi=rida.substring(9, rida.length());
			level=rida.substring(7, 8);
			PrintWriter valja9=new PrintWriter(new FileWriter("levelid.txt", true));
            valja9.println(level+"!"+nimi);
            valja9.close();
			for(int i=0; i<kasutajad.size(); i++){
             Kasutaja k=(Kasutaja)kasutajad.elementAt(i);
			 if(k.kasutajanimi.equals(nimi)){
			 if(level.equals("1")){
			k.kirjutusvoog.println("...keegi loitsib midagi ja sa oled nyyd pisideemon");
			}
			if(level.equals("2")){
			k.kirjutusvoog.println("...keegi loitsib midagi ja sa oled nyyd deemon");
			}
			if(level.equals("3")){
			k.kirjutusvoog.println("...keegi loitsib midagi ja sa oled nyyd peadeemon");
			}
			kirjutusvoog.println("Ok");
			}
			}
			}else{
			kirjutusvoog.println("Sul ei ole õigust seda käsku kasutada!");
			}
			}
			if(rida.startsWith(".kill")){
			if (oigus==true){
			nimi3=rida.substring(6, rida.length());
			AdminKill();
			}else{
			kirjutusvoog.println("Sul ei ole õigust seda käsku kasutada!");
			}
			}
            } else {
            for(int i=0; i<kasutajad.size(); i++){
             Kasutaja k=(Kasutaja)kasutajad.elementAt(i);	 
			 System.out.println("j="+j);
			 if(j<komments.length){
              k.kirjutusvoog.println(kasutajanimi+" "+komments[j]+": "+rida);
			 } else {
			 k.kirjutusvoog.println(kasutajanimi+" ütleb: "+rida);		}
           }
        }
      }
	  for(int i=0; i<kasutajad.size(); i++){
	  Kasutaja k=(Kasutaja)kasutajad.elementAt(i);
	  k.kirjutusvoog.println(kasutajanimi+" läks ära");
	  }
      sc.close();
    } catch(Exception e){
      System.out.println("Probleem: "+e);
	  e.printStackTrace();
    }
    kasutajad.remove(this);
  }
  
  
  /**
  * Saadetakse teade vaid ühele kasutajale. Rida on eeldatavalt formaadis
  * .era kasutajanimi teade
  */
  void saadaErateade(String rida){
     int teinetyhik=rida.indexOf(" ", 5); //tühik pärast sümbolit nr 5
     if(teinetyhik==-1){
       kirjutusvoog.println("Vigane rida");
       return;
     }
     String saajaNimi=rida.substring(5, teinetyhik);
     String teade=rida.substring(teinetyhik+1);
     boolean saadetud=false;
     for(int i=0; i<kasutajad.size(); i++){
       Kasutaja k=(Kasutaja)kasutajad.elementAt(i);
       if(k.kasutajanimi.equals(saajaNimi)){
	   saadetud=true;
	   if(j<komments.length){
          k.kirjutusvoog.println(kasutajanimi+" "+komments[j]+" sulle: "+teade);
              kirjutusvoog.println("ütlesid "+saajaNimi+"'le: "+komments[j]+" "+teade);
			 } else {
			 k.kirjutusvoog.println(kasutajanimi+" ütleb sulle: "+teade);
              kirjutusvoog.println("ütlesid "+saajaNimi+"'le "+teade);			
		   }
         }
       }
	   if(!saadetud){
       kirjutusvoog.println("Tundmatu kasutaja: "+saajaNimi);
     }
     }
   void saadaInfo(){
   kirjutusvoog.println(" NIMI           LEVEL           KIRJELDUS");
   kirjutusvoog.println(" SalaDeemon     DEMONIA VALVUR  vaikib...");
   try{
	for(int a=0; a<kasutajad.size(); a++){
	BufferedReader blah=new BufferedReader(new FileReader("levelid.txt"));
	String inim=blah.readLine();
	Kasutaja k=(Kasutaja)kasutajad.elementAt(a);
	while(inim!=null){
	String blah2=inim.substring(0, 1);
	String blah1=inim.substring(2, inim.length());
	if (blah1.equals(k.kasutajanimi)){
	   String tyhikud="";
	   while(k.kasutajanimi.length()+tyhikud.length()<15){tyhikud=tyhikud+" ";}
	   if(blah2.equals("1")){
   		kirjutusvoog.println(" "+k.kasutajanimi+tyhikud+"pisideemon");
   		}
		if(blah2.equals("2")){
   		kirjutusvoog.println(" "+k.kasutajanimi+tyhikud+"deemon");
   		}
		if(blah2.equals("3")){
   		kirjutusvoog.println(" "+k.kasutajanimi+tyhikud+"peadeemon");
   		}
		}
	inim=blah.readLine();
	   }
	   }
	   }catch(Exception viga){System.out.println(viga);}
   	  }
   void naitaEmo(){
   try{
   BufferedReader sisse2=new BufferedReader(new FileReader("emotikud.txt"));
    String rida5=sisse2.readLine();
	System.out.println("Loeti "+rida5);
	while (rida5!=null){
	kirjutusvoog.println(rida5);
	rida5=sisse2.readLine();
   }
   sisse2.close();
   }catch(Exception e){e.printStackTrace();}
   }  
   void AdminKill(){
   String saajaNimi1=nimi3;
       for(int i=0; i<kasutajad.size(); i++){
       Kasutaja k=(Kasutaja)kasutajad.elementAt(i);
	   k.kirjutusvoog.println("SalaDeemon loitsib midagi ja "+nimi3+" kaob kiiremini kui välk!");
	   System.out.println(k.kasutajanimi);
       if(k.kasutajanimi.equals(saajaNimi1)){
	   k.kirjutusvoog.println("GET OUT!");
	   k.kirjutusvoog.close();
	   }
	   }
	  }
   void naitaKask(){
     kirjutusvoog.println("Käsud minu jutukas:");
      kirjutusvoog.println(".era    >>> saad saata privaat teksti");
      kirjutusvoog.println(".who    >>> info kasutajate kohta");
      kirjutusvoog.println(".quit   >>> lahku jutukast");
	  kirjutusvoog.println(".emot   >>> näitab emotikone ja kommentaare");
	  kirjutusvoog.println(".käsk   >>> näitab kõiki käske!");
	  kirjutusvoog.println(".kill   >>> viskab kasutaja jutukast välja (Admini õigus)");
	  kirjutusvoog.println(".kell   >>> näitab kellaega");
	  }
   void kell(){
   try{
    Socket sc=new Socket("madli.ut.ee", 13);
    BufferedReader sisse=new BufferedReader(
      new InputStreamReader(sc.getInputStream())
    );
    kirjutusvoog.println("SalaDeemon ütleb: Praegu on aeg "+sisse.readLine());
	}catch(Exception e){e.printStackTrace();}
   }
   void andmbaas(){
   try{
   //Class.forName("org.gjt.mm.mysql.Driver");
   Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
      Connection cn=DriverManager.getConnection("jdbc:odbc:mysql");
      Statement st=cn.createStatement();
      st.executeUpdate(
      "INSERT INTO kasutajad set kasutajanimi='+kasutajanimi+', parool='+passwd+', level=1, sugu='+sugu+', kirjeldus='+kirjeldus+';"
      );
      cn.close();
   }catch(Exception e){e.printStackTrace();}
   }
   void loeFailist(){
    try{
	  BufferedReader failist=new BufferedReader(new FileReader("emotikud.txt"));
	  int ridadearv=0;
	  for(String rida=failist.readLine(); rida!=null; rida=failist.readLine()){ridadearv++;}
	  failist.close();
	  smiley=new String[ridadearv];
	  komments=new String[ridadearv];
	  failist=new BufferedReader(new FileReader("emotikud.txt"));
	  int reanr=0;
	  for(String rida=failist.readLine(); rida!=null; rida=failist.readLine()){
	    StringTokenizer stk=new StringTokenizer(rida, "!");
		smiley[reanr]=stk.nextToken();
		komments[reanr]=stk.nextToken();
		reanr=reanr+1;
	  }
	  failist.close();
	}catch(Exception e){e.printStackTrace();}
 }
}
}