//-------------Конфигурация шлюза-------------------------------------------------------------------------
#имя пользователя
login=mrust
#пароль шлюза который задаётся для enable
cfg.pswd=DVfqSbl
#диапазон выделения vlan
range=1100-1900
#время ожидания ответа, по истечению которого, шлюз сбрасывает соединение и выдаёт ошибку
timeout=2000
#код Vlan параметра договора
vlanId=1
#код DHCP Relay параметра договора
relayId=2
//-------------Конфигурация шлюза-------------------------------------------------------------------------
//-------------Конфигурация типа шлюза---------------------------------------------------------
user_rule.editor.class=bitel.billing.module.services.ipn.editor.vlan.CiscoVlanContactRuleEditor
#gate_manager.class=bitel.billing.server.ipn.vlan.CiscoVlanGateWorker
#gate_manager.class=bitel.billing.server.ipn.DHCPGateWorker
gate_manager.class=bitel.billing.server.ipn.vlan.CiscoVlanParentGateWorker
use.script=1
#диапазон выделения vlan
range=1100-1900
//-------------Конфигурация типа шлюза---------------------------------------------------------
//-------------Команды-------------------------------------------------------------------------
[DEFAULT]
 
[REMOVE]
   <LOOP>         
         no ip route {A} 255.255.255.255 Vlan{VID}
   </LOOP>         
[/REMOVE]
 
[OPEN]
   <LOOP>         
           ip route {A} 255.255.255.255 Vlan{VID}
           ip route {DHCP_Relay} 255.255.255.255 Vlan{VID}
   </LOOP>         
[/OPEN]
 
[CLOSE]
   <LOOP>         
        no ip route {A} 255.255.255.255 Vlan{VID}
   </LOOP>         
[/CLOSE]
[/DEFAULT]
//-------------Команды-------------------------------------------------------------------------
//-------------Скрипт--------------------------------------------------------------------------
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.StringTokenizer;
import java.util.Map.Entry;
import java.sql.*;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

import org.apache.xml.serializer.ToXMLStream;
import org.xml.sax.SAXException;
 
import bitel.billing.common.module.ipn.IPNContractStatus;
import bitel.billing.server.ipn.GateWorker;
import bitel.billing.server.ipn.UserStatus;
import bitel.billing.server.ipn.bean.ManadUtils;
import bitel.billing.server.ipn.bean.VlanManager;
import bitel.billing.server.ipn.bean.GateType;
import bitel.billing.server.ipn.bean.RuleType;
import bitel.billing.server.ipn.bean.VlanManager;
import bitel.billing.server.ipn.bean.Gate;
import bitel.billing.server.util.DefaultServerSetup;
import bitel.billing.server.util.Utils;
import bitel.billing.server.util.telnet.TelnetSession;
import ru.bitel.bgbilling.common.DefaultSetup;
import bitel.billing.common.IPUtils;
import ru.bitel.bgbilling.common.DefaultSetup;
import bitel.billing.common.module.ipn.IPNContractStatus;
import bitel.billing.server.ipn.dlink.UserPortStatus;
import bitel.billing.server.ipn.dlink.UserPortStatus.UserPortStatusParser;

protected void doSync()
{
   try
   {
      log.info( "start of cisco........................................................");
      host = gate.getHost();
      port = gate.getPort();

      DefaultServerSetup gateSetup = new DefaultServerSetup( gate.getConfig(), "\r\n" );       

      pswdLogin = gate.getKeyword();
      login = gateSetup.getStringValue( "login");
      pswdCfg = gateSetup.getStringValue( "cfg.pswd");
       timeout = gateSetup.getIntValue( "timeout", 0 );
      vlanId = gateSetup.getIntValue( "vlanId",0);
      relayId = gateSetup.getIntValue( "relayId",0);
 
      result = new StringBuffer();
 
      if( log.isDebugEnabled() )
      {
          log.debug( gate.getId() + " gate: " + host + ":" + port  + " pswdLogin: " + pswdLogin + " pswdCfg: " +        pswdCfg );
      }
       session = new TelnetSession( host, port);
        session.setTimeout( timeout );
      session.setLoginPromptSequence( ":" );                  
      session.connect();
       result.append( session.doCommand( login ) );
       session.setLoginPromptSequence( ">" );
       result.append( session.doCommand( pswdLogin ) );
       result.append( session.doCommand( "terminal length 0" ) );
      result.append( session.doCommand( "terminal width 0" ) );
       session.setLoginPromptSequence( ":" );
      result.append( session.doCommand( "enable" ) );
       session.setLoginPromptSequence( "#" );
      result.append( session.doCommand( pswdCfg ) );
 
      result.append( session.doCommand( "configure terminal" ) );
 
//      log.debug( "execute commands" );
//      log.info( "------1------");
      log.info( "relayId = " + relayId);
      doCommands( session, result, vlanId, relayId);
 
      result.append( session.doCommand( "exit" ) );
        session.doCommandAsync( "exit" );
 
/*      log.info("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
      log.info( result );
      log.info("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");      
      log.debug( "ok" );
*/
   } catch (Exception e)
   {
      throw new RuntimeException ( e );
   }
 
   log.info( "end of cisco........................................................");
}
 
protected void add()
{
 
}
 
private void doCommands( TelnetSession session, StringBuffer result, vlanId, relayId) throws IOException
{      
   for( UserStatus status : statusList )
   {
      gateId  = gate.getId();
//      log.info("gateId=" + gateId);
//        log.info("vlanId=" + vlanId);
//        log.info("contractId=" + status.contractId);
      int vid = getVlan( status.contractId, vlanId );
      Relay = getRelay( status.contractId, relayId );
//      log.info("vid=" + vid);   
      //TODO - подумать что сделать справилами на добавление
      rules = null;
      if (status.status == IPNContractStatus.STATUS_OPEN)
      {
         rules = getOpenRules( status, vid, Relay);
      }          
//      else if (status.status == IPNContractStatus.STATUS_REMOVED)
//      {
//         rules = getRemoveRules( status, vid );   
//      }
      //if closed and etc
      else
      {
         rules = getCloseRules( status, vid, Relay );
      }
      if (vid > 0)
      {
         for ( String rule : rules )
         {               
//      log.info("rule=" + rule);   
            result.append(  session.doCommand( rule ) );            
         }
      }
   }      
}
 
getOpenRules( status, vid, Relay )
{
    return getRules( status, "\\[OPEN\\](.*)\\[/OPEN\\]", vid, Relay );
}
 
getCloseRules( status, vid, Relay )
{
    return getRules( status, "\\[CLOSE\\](.*)\\[/CLOSE\\]", vid, Relay );
}
 
getRemoveRules( UserStatus status, int vid, Relay )
{
    return getRules( status, "\\[REMOVE\\](.*)\\[/REMOVE\\]", vid, Relay );
}
 
getRules(  status, template, vid, Relay )
{
   // пользовательское правило, без типа - то все оставляем как есть
   rule = status.rule.getRuleText();
//   log.info("1rule=" + rule);
        //порты идут до #, а адреса идут после 
   String [] parts  = rule.split( "#" );
   portsStr = "";
   addresesStr = "";
   if ( parts.length > 0 )
   {
       portsStr = parts[0];
   }
   if ( parts.length > 1 )
   {
      addresesStr = parts[1];
   }
   //типизированное правило
   if( status.ruleType != null )
   {   
       rule = generateRule( addresesStr, status.gateType, status.ruleType, vid, Relay );
   }
//   log.info("2rule=" + rule);
   pattern = Pattern.compile( template, Pattern.DOTALL );
   m = pattern.matcher( rule );
   if (m.find())
   {
       rule = m.group( 1 );
   }      
   rule.replaceAll( "\r", "" );
   parts  = rule.split( "\n" );
   result = new ArrayList();
   for ( String part : parts )
   {
      if ( !Utils.isEmptyString( part ))
      {
         result.add( part );
      }
   }
 
   return result;
}      
 
generateRule( addresses, gateType, ruleType, vid, Relay )
{      
    ruleText = ManadUtils.getRule( gateType, ruleType );
    replacements =  new HashMap ();
    if (Relay != null || Relay.length()>0 )
    {
       replacements.put( "\\{DHCP_Relay\\}", Relay );
   }
    if ( vid > 0)
    {
        replacements.put( "\\{VID\\}", String.valueOf( vid ) );
    }
    return ManadUtils.generateRule( ruleText, addresses, replacements, ruleType );      
}

getVlan( cid , pid )
{
//   log.info("--------------2----------");
   int result = 1102;
   String query =  "select val from contract_parameter_type_1 where cid=" + cid + " and pid= " + pid;
//   log.info(query);
   PreparedStatement ps = con.prepareStatement( query );
   ResultSet rs = ps.executeQuery();
   rs.first();
//   log.info("Row = "+rs.getRow());
   if ( rs. isFirst() )
   {
//   log.info("---- First ------");
      result = rs.getInt(1);
   }
//   log.info("Vlan = "+result);

   return result;   
}

getRelay( cid , pid )
{
   log.info("pid = " + pid);
   result = "";
   String query =  "select val from contract_parameter_type_1 where cid=" + cid + " and pid= " + pid;
   log.info(query);
   PreparedStatement ps = con.prepareStatement( query );
   ResultSet rs = ps.executeQuery();
   rs.first();
   log.info("Row = "+rs.getRow());
   if ( rs. isFirst() )
   {
//   log.info("---- First ------");
      result = rs.getString(1);
   }
   log.info("Relay = "+result);

   return result;   
}
//-------------Скрипт--------------------------------------------------------------------------

void parentSync( child, childWorker)
{
       log.info( "test -  parentSync " );

      log.info( "gate.Host = " + gate.getHost() );
      log.info( "child.Host = " + child.getHost() );

      log.info( "test parentSync - ok" );
}

ManadUtils.getRule( gateType, ruleType );

ManadUtils.getRule( child.getGateType(), ruleType );