BiTel

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.StringTokenizer;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
 
import bitel.billing.common.IPUtils;
import bitel.billing.common.module.ipn.IPNContractStatus;
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.dlink.UserPortStatus;
import bitel.billing.server.util.DefaultServerSetup;
import bitel.billing.server.util.Utils;
import bitel.billing.server.util.telnet.OperationTimedoutException;
import bitel.billing.server.util.telnet.TelnetSession;
 
protected void doSync()
{
   try
   {
      String host = gate.getHost();
      int port = gate.getPort();
 
 
      DefaultServerSetup gateSetup = new DefaultServerSetup( gate.getConfig(), "\r\n" );       
 
 
      String pswd = gate.getKeyword();
      String login = gateSetup.getStringValue( "login");
 
 
 
      StringBuffer result = new StringBuffer();
 
 
      if( log.isDebugEnabled() )
      {
          log.debug( gate.getId() + " gate: " + host + ":" + port  + " login: " + login + " pswd: " +       pswd );
      }
 
 
      TelnetSession session = new TelnetSession( host, port);
      session.setLoginPromptSequence( ":" );                  
 
      log.debug( "before connect" );
      session.connect();      
      log.debug( "after connect" );
 
      result.append( session.doCommand( login ) );
      log.debug( "after command" );
 
 
      session.setLoginPromptSequence( "#" );
      result.append( session.doCommand( pswd ) );
      log.debug( "before pswd" );
 
 
      log.debug( "execute commands" );
      doCommands( session, result, gateSetup);
 
 
 
      session.setLoginPromptSequence( "****" );
      result.append( session.doCommand( "logout" ) );
 
 
      log.info( "!!!!!!!!!!!!!!!!!!!!!!!!!!! Dlink!!!!!!!!!!!!!!!!!!!!!!!!!!!!" );
      log.info( result.toString() );
      log.info( "!!!!!!!!!!!!!!!!!!!!!!!!!!! Dlink!!!!!!!!!!!!!!!!!!!!!!!!!!!!" );
 
 
 
      log.debug( "ok" );
   } catch (Exception e)
   {
 
      throw new RuntimeException ( e );
   }
}
 
 
 
private void doCommands( TelnetSession session, StringBuffer result, DefaultServerSetup gateSetup)
throws IOException, OperationTimedoutException
{
 
   VlanManager manager = new VlanManager(mid, con);
 
    for( UserStatus status : statusList )
   {
 
      //берем vlan у родительской циски
      int vid = manager.getVlan( gate.getParentId(), status.contractId );
      if ( status.status == IPNContractStatus.STATUS_OPEN )
      {
         String[]  rules  = getOpenRules( status, vid );
         for ( String rule : rules )
         {
            result.append( session.doCommand( rule ) );   
         }
 
      }
      else
      {
         String[] rules = getCloseRules( status, vid );
         for ( String rule : rules )
         {
            result.append( session.doCommand( rule ) );   
         }
 
      }                              
   }     
 
 
}
 
 
 
private String[]  getOpenRules( UserStatus status, int vid )
{
   return getRules( status, "\\[OPEN\\]((.|\n)*)\\[/OPEN\\]", vid );
}
 
private String[]  getCloseRules( UserStatus status, int vid )
{
   return getRules( status, "\\[CLOSE\\]((.|\n)*)\\[/CLOSE\\]", vid );
}
 
 
 
getRules(  status, template, vid )
{
    // пользовательское правило, без типа - то все оставляем как есть
   rule = status.rule.getRuleText();
 
    //порты идут до #, а адреса идут после 
   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, portsStr, vid, status.gateType, status.ruleType );
   }
 
 
    pattern = Pattern.compile( template );
   m = pattern.matcher( rule );
   if (m.find())
   {
       rule = m.group( 1 );
   }      
 
   rule.replaceAll( "\r", "" );
   parts  = rule.split( "\n" );
 
   return parts;
}      
 
generateRule(  addreses, ports, vid, gateType, ruleType  )
{      
    ports_ = getPorts( ports );      

   ruleText = ManadUtils.getRule( gateType, ruleType );
 
   replacements =  new HashMap();
 
   if ( vid > 0)
   {
      replacements.put( "\\{VID\\}", String.valueOf( vid ) );            
   }   
 
   loops = ManadUtils.getAddresLoops( addreses );
 
   //адреса
   p = new LoopPattern();      
   p.setLoopPatern( "LOOP_PORT" );
   p.setReplace( "\\{PORT\\}" );
   p.setObjects( ports_ );      
   loops.add( p );

   return ManadUtils.generateRule( ruleText, replacements, ruleType, loops );      
}
 
getPorts( ports )
{
   portList = new ArrayList<String>();
   parts  = ports.split( ";" );
 
   for (String part : parts )
   {
      parts2  = part.split( ":" );
      if ( parts2.length <  2)
      {
         continue;
      }
      port = parts2 [1];
      portList.add( port );
   }
 
   ports_[] = new String [portList.size()];

   for (int i = 0; i < ports_.length; i++)
   {
      ports_[i] = portList.get( i );
   }

   return ports_;
}

http://10.3.0.1:8080/bgbilling/executer?id=875&module=ipn&action=GetContractRule&mid=1&BGBillingSecret=SU0b8zLGDgatPtl7yCjqEIFx&
[ length = 162 ] xml = <?xml version="1.0" encoding="windows-1251"?>
<data secret="9074DEB047D5530D99BF521836838ABD" status="ok"><rule rtid="2"><row text="10.99.1.2:1#;"/></rule></data>
http://10.3.0.1:8080/bgbilling/executer?module=ipn&gateId=9&action=GetVlan&mid=1&BGBillingSecret=fMZDtVolYbVrE00ubhM9410r&cid=609&
[ length = 129 ] xml = <?xml version="1.0" encoding="windows-1251"?>
<data secret="DA3244A302E084EA83692BE254484D3D" status="ok"><vlan vid="-1"/></data>
http://10.3.0.1:8080/bgbilling/executer?module=ipn&action=AddressContractInfo&mid=1&date=20.10.2009&BGBillingSecret=EaJLVR1CkuW01jm4Zk7hoE8A&cid=609&
[ length = 349 ] xml = <?xml version="1.0" encoding="windows-1251"?>
<data secret="259C882096EC4C8536FD3DB06218EE8E" status="ok"><table><data><row address_range="10.99.1.2 - 10.99.1.2" comment="" f0="443" f1="10.99.1.2 - 10.99.1.2" f2="[CORE: ANY; GW-NAT: ANY]" f3="07.10.2009-" f4="" id="443" ifaces="[CORE: ANY; GW-NAT: ANY]" period="07.10.2009-"/></data></table></data>
http://10.3.0.1:8080/bgbilling/executer?module=ipn&gid=9&address_list=%3B&action=CiscoVlanGenerateRule&mid=1&rtid=2&BGBillingSecret=USNyLQ2ZXLHtt5zyw4Co98CI&gtid=0&cid=609&
[ length = 144 ] xml = <?xml version="1.0" encoding="windows-1251"?>
<data secret="6B5AA3334C4D36EF2D50319F43935515" status="error">Ошибка в параметрах запроса!</data>
http://10.3.0.1:8080/bgbilling/executer?module=ipn&address_list=10.99.1.2%3A1%23%3B%0A&gid=6&action=CiscoSSHSwitchGenerateRule&mid=1&rtid=2&BGBillingSecret=KKoakl142enlPdnDrX5CDG1H&gtid=2&cid=609&
[ length = 534 ] xml = <?xml version="1.0" encoding="windows-1251"?>

public void main( setup, con, conSlave )
{

modset = new ModuleSetup(con, 1);
IPNContractStatusManager ipnstm= new IPNContractStatusManager(con, 1, modset);
print (ipnstm.getContractStatus(12));
print (new IPNContractStatusLogRecord.getDate()) ;

}