// generated by xternalx at 10-11.06x2010
// visit http://xternalx.com
// or icq: 444 121 808

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.util.*;
import java.sql.*;
import java.util.*;
import java.lang.*;
import java.util.regex.*;
import java.util.regex.Pattern.*;
import bitel.billing.server.contract.bean.*;
import bitel.billing.server.phone.bean.*;
import bitel.billing.server.util.telnet.*;

public HashMap loadOptions(String opts)
{
    options = new HashMap();
   String[] lines = opts.replaceAll(",","").split("\n");
   for(i=0; i < lines.length; i++)
   {
      if(!lines[i].equals("") && !lines[i].equals(" "))
      if(!lines[i].substring(0,1).equals("#") || !lines[i].substring(0,1).equals(";"))
      {
         String[] kv = lines[i].split(" ");
         svc_type = new ArrayList();
         for(j=1; j < kv.length; j++)
         {
            svc_type.add(kv[j]);
            //print("   "+kv[j]);
         }
         options.put(kv[0], svc_type);
      }
   }
   return options;
}

public void performAction(actionCode)
{

}

public void onEvent( event, setup, con, conSlave )
{
   cid = event.getContractID();
   contract = new ContractManager(con).getContractByID(cid);
    clStatus = event.getStatus().getStatus();
   print("status changed for contract "+cid+" to state: "+clStatus );
//cintract,getStatus() == 3 - закрыт
//contract.getStatus() == 2 - отключен
//contract.getStatus() == 0 - подключен

   clItemManager = new ClientItemManager(con,1);
   clPointsInBill = clItemManager.getItemList(cid);

   for(i=0; i< clPointsInBill.size(); i++)
   {   
      pointItem      = clPointsInBill.get(i);
      portNumber      = 10001;
      scommHost      = "192.168.1.15";
      pointNumber      = pointItem.getClientNumbers().get(0);
      options         = loadOptions(clPointsInBill.get(i).getComment());
      haveVnums       = false;

      // если номер в федеральном формате
      // приводим его к обычному 7ми значному виду
        if(pointNumber.length()==11)
      {
         pointNumber = pointNumber.substring(4);
      }

      //print("  getting options for point: "+pointNumber);
      // у абонента виртуальный номер?
      if(options.containsKey("vnum"))
      {
         haveVnums = true;
         print(pointNumber+" is alias for some virtual numbers");
         //pointNumber = (String)options.get("vnum").get(0);
      }
      // на каком порту подключена АТС к SCOMM
      if(options.containsKey("port"))
      {
         print(pointNumber+" allocated to SCOMM port"+options.get("port").get(0));
         portNumber = Integer.parseInt(options.get("port").get(0));
      }
      t = new TelnetSession(scommHost, portNumber);
      t.connect();
      switch(clStatus)
      {
         case 0:
         {
            if(options.get("svc_stopped") != null)
            {
               if(!haveVnums)
               {
                  print(t.doCommand("settune "+pointNumber+" USE ON"));
               }
               else
               {
                  for(j=0; j< options.get("svc_stopped").size(); j++)
                  {
                     for(x=0; x<options.get("vnum").size();x++)
                     {
                        print("  take point "+options.get("vnum").get(x)+" online");
                        print(t.doCommand("settune "+options.get("vnum").get(x)+" "+(String)options.get("svc_stopped").get(j)+" ON"));
                     }
                  }
               }
            }
            else
            {
               print("no options defined for point: "+pointNumber);
            }
            break;
         }
         case 2:
         {
            print("  take point "+pointNumber+" offline");
            if(options.get("svc_stopped") != null)
            {
               if(!haveVnums)
               {
                  print(t.doCommand("settune "+pointNumber+" USE OFF"));
               }
               else
               {
                  for(j=0; j< options.get("svc_stopped").size(); j++)
                  {
                     for(x=0; x<options.get("vnum").size();x++)
                     {
                        print("  take point "+options.get("vnum").get(x)+" online");
                        print(t.doCommand("settune "+options.get("vnum").get(x)+" "+(String)options.get("svc_stopped").get(j)+" OFF"));
                     }
                  }
               }
            }
            else
            {
               print("no options defined for point: "+pointNumber);
            }
            break;
         }
             case 3:
         {
            print("  take point "+pointNumber+" down");
            if(options.get("svc_closed") != null)
            {
               if(!haveVnums)
               {
                  print(t.doCommand("settune "+pointNumber+" USE OFF"));
               }
               else
               {
                  for(j=0; j< options.get("svc_closed").size(); j++)
                  {
                     for(x=0; x<options.get("vnum").size();x++)
                     {
                        print("  take point "+options.get("vnum").get(x)+" online");
                        print(t.doCommand("settune "+options.get("vnum").get(x)+" "+(String)options.get("svc_closed").get(j)+" OFF"));
                     }
                  }
               }
            }
            else
            {
               print("no options defined for point: "+pointNumber);
            }
            break;
         }
      }
      t.disconnect();
   }
}

port 10001
vnum 304

svc_stopped CMN_8xxx, CMN_10xxx, CMN_82xxx
svc_closed USE