import java.io.*;
import java.net.*;
import java.util.*;
public class Randserv{
  static Vector kasutajad=new Vector();
  static Date algaeg=new Date();
  public static void main(String argumendid[]) throws IOException{
    ServerSocket ss=new ServerSocket(3001);

    while(true){
      kasutajad.add(new Loim(ss.accept()));
//      String IP = Socket.getRemoteSocketAddress().toString();

    }
  }

  public synchronized static void kirjutalog(int teade){
    try{
        PrintWriter faili=new PrintWriter(new FileWriter("minulog.txt",true));
        faili.println(new Date()+ " "+teade);
        faili.close();
    }catch(Exception ex){ex.printStackTrace();}
  }

 /*public synchronized static void trykilog(PrintWriter sihtkoht){
    try{
        BufferedReader failist= new BufferedReader(new FileReader("minulog.txt"));
        for(String rida=failist.readLine(); rida!=null;rida=failist.readLine()){
          sihtkoht.println(rida);
        }
        failist.close();
    }catch(Exception ex){ex.printStackTrace();}
  }*/
 public synchronized static void analyze(PrintWriter sihtkoht){
    try{
        BufferedReader failist= new BufferedReader(new FileReader("minulog.txt"));
        int loendur=0;
        String rida=failist.readLine();
        while(rida!=null){
          loendur++;
          rida=failist.readLine();
        }
        //System.out.println(loendur);
        sihtkoht.println(loendur);
        failist.close();
    }catch(Exception ex){
        ex.printStackTrace();
    }
  }
 static class Loim extends Thread{
  protected Socket sc;
  PrintWriter valja;
  String kasutajanimi="";
  String IP;
  public Loim(Socket uus_sc){
   try{
    sc=uus_sc;
    valja=new PrintWriter(sc.getOutputStream(), true);
    IP=sc.getRemoteSocketAddress().toString();

    start();
   }catch(Exception e){e.printStackTrace();}
  }
  public void run(){
    try{
      BufferedReader sisse=new BufferedReader(
        new InputStreamReader(sc.getInputStream())
      );
      valja.println("Tere tulemast RandServ juhuarvude serverisse!");
      /*valja.println("Sisesta kasutajanimi:");
      //kasutajanimi=sisse.readLine();
      String uusnimi=sisse.readLine();
      boolean olemas=false;
      for(int i=0;i<kasutajad.size();i++){
        if(((Loim)kasutajad.elementAt(i)).kasutajanimi.equals(uusnimi)){
          olemas=true;
        }
      }
      if(olemas){
        valja.println(uusnimi+" juba olemas.");
        sc.close();
        kirjutalog(uusnimi+ " leidub juba.");
        throw new Exception(uusnimi+ " leidub juba");
      }
      kasutajanimi=uusnimi; */
      System.out.println("Saabus uus kasutaja");
//      String IP = Socket.getRemoteSocketAddress().toString();
//      System.out.println(IP);
      valja.println("Juhuarvu saamiseks tryki .rnd");
      valja.println("Serverist v2ljumiseks .e");
      valja.println("Statisitka teenuse kohta .stat");
      boolean veel=true;
      while(veel){
         String rida=sisse.readLine();
         //System.out.println(kasutajanimi+": "+rida);
         System.out.println(rida);
         if(rida.startsWith(".")){
            if(rida.startsWith(".e")){veel=false;}
            if(rida.startsWith(".rnd")){
              /*valja.println("Millises vahemikus sa oma juhuarvu soovid?");
              valja.println("Juhuarvud genereeritakse täisarvudena nullist kuni");
              valja.println("sinu poolt sisestatud numbrini. ");
              rida=sisse.readLine();
              int nu=parseInt("34");*/
              int suva=(int)Math.floor(100*Math.random());
              valja.println(suva);
              //System.out.println(kasutajanimi+": sai "+suva);
              //kirjutalog(kasutajanimi+": sai "+suva);
              kirjutalog(suva);
            }
            /*if (rida.startsWith(".p")){
              int tyhikukoht=rida.indexOf(" ",3);
              String saajanimi=rida.substring(3, tyhikukoht);
              for(int i=0; i<kasutajad.size(); i++){
                Loim kasutaja=(Loim)kasutajad.elementAt(i);
                if(saajanimi.equals(kasutaja.kasutajanimi)){
                  kasutaja.valja.println(kasutajanimi+ " teatas: "+rida.substring(tyhikukoht));
                }
              }
            }*/
            /*if (rida.startsWith(".log")){
              trykilog(valja);
            } */
            if (rida.startsWith(".stat")){
              valja.println("Hetkel kasutajaid selles serveris: "+kasutajad.size());
              valja.print("Genereeritud numbreid: ");
              analyze(valja);
              Date loppaeg=new Date();
              double aeg = (loppaeg.getTime() - algaeg.getTime()) * 0.001;
              int sek=(int)aeg%60;
              int min= (int)aeg/60;
              valja.println("Server on t88tanud: " + min+" minutit "+sek+" sekundit");
              valja.println("Sinu IP aadress: "+IP.substring(1,13));
              //veel panna system uptime ja kliendi IP
            }
         }else{
        /* for(int i=0; i<kasutajad.size(); i++){
           if (veel==true)((Loim)kasutajad.elementAt(i)).valja.println(kasutajanimi+" ytles: "+rida);
         }
         kirjutalog(kasutajanimi+": "+rida);*/
      }}

      valja.println("Head aega. Kylastage meid j2lle.");
      Thread.sleep(1000);
    }catch(Exception e){
      System.out.println("Probleem: "+e);
    }
     try{sc.close();System.out.println("Lahkus kasutaja");}catch(Exception e){}
    kasutajad.remove(this);
  }
 }
}