import bitel.billing.server.contract.bean.*;
import bitel.billing.server.script.event.*;
import bitel.billing.server.tariff.bean.*;
import bitel.billing.server.ipn.bean.*;
import java.util.*;
import java.text.*;

//номер контракта
cid = event.getContractID();

//получение названия нужной таюлици с траффиком
evdate=event.getGenerateTime();
datefrm = new SimpleDateFormat("yyyyMM");
evyear=datefrm.format(evdate.getTime()).toString();

//получение траффика пользователя в данном отчетном периоде
ps = con.prepareStatement("SELECT SUM(amount) FROM ipn_contract_data_3_"+evyear+" WHERE cid=? AND sid=1");
ps.setInt( 1, cid);
rs = ps.executeQuery();
rs.first();
traffic = rs.getLong(1)/1073741824; //в гигабайтах

//получение текущего тарифа пользователя
//ctm =  new ContractTariffManager(  con );
//currentTariffID = ctm.getContractTariff( cid, evdate).getTariffPlanID();

ctm =  new ContractTariffManager(  con );

// текущий тарифный план
currentTarifList=ctm.getContractTariffList(cid, evdate);

//получение списка тарифов для для группы тарифов пользователя
ctgm=new ContractTariffGroupManager(con);
currentGroup=ctgm.getContractTariffGroup(cid, evdate);
if ( currentGroup == null ){
   error("no tarif group");
   return;
}
currentGroupID=currentGroup.getTariffGroupID();
tgm= new TariffGroupManager(con);
tariflist=tgm.getTariffGroupByID(currentGroupID).getPlanIdList();

for( Iterator it = currentTarifList.iterator(); it.hasNext();){
   currTarif = it.next();
   if (tariflist.contains(currTarif.getTariffPlanID().toString())) {
//      print("found_planID"+currTarif.getTariffPlanID());
      chTariff=currTarif;
      break;      
   }
//   print("check_plan"+currTarif.getTariffPlanID());
}


if( chTariff == null ){
 error( "Current tariff not found" );
 return;
}

currentTariffID=chTariff.getTariffPlanID();


//получение текущего типа шлюза пользователя
ugrm = new UserGateRuleManager( con, 3 );
rules = ugrm.getUserGateRules( cid );
for( Iterator it = rules.iterator(); it.hasNext(); ){
   currule = it.next();
   if (currule.getGateID() == 1){ //gate IPN
      ruletypeID=currule.getRuleTypeId();
      break;
   }
   print("gates="+currule.getGateID());
}


//расчет скорости пользователя в зависимости от тарифа
switch ( currentTariffID ){
   case 7:
      // план Нимбо-1 3мбит/c
      if (traffic < 50){
         newruleTypeID=4;
      }else{
         newruleTypeID=12;
      }
   break;

   case 8:
      // план Нимбо-2 5мбит/c
      if (traffic < 50){
         newruleTypeID=15;
      }else{
         newruleTypeID=12;
      }
   break;

   case 9:
      // план Нимбо-3 7мбит/c
      if (traffic < 100){
         newruleTypeID=16;
      }else{
         newruleTypeID=12;
      }
   break;

   case 10:
      // план Нимбо-4 10мбит/c
      if (traffic < 100){
         newruleTypeID=8;
      }else{
         newruleTypeID=11;
      }
   break;

   case 11:
      // план Нимбо-5 15мбит/c
      if (traffic < 100){
         newruleTypeID=17;
      }else{
         newruleTypeID=11;
      }
   break;

   case 12:
      // план Нимбо-6 20мбит/c
      if (traffic < 100){
         newruleTypeID=9;
      }else{
         newruleTypeID=11;
      }
   break;


   case 15:
      //бесплатный тариф 3Мбит/c
      if (traffic < 100){
         newruleTypeID=4;
      }else{
         newruleTypeID=12;
      }
   break;




   case 4:
      // план траффик 50мбит/c
      newruleTypeID=10;
   break;

   case 3:
      // план почтовый 50мбит/c
      newruleTypeID=10;
   break;

   case 5:
      // план Серфер 50мбит/c
      newruleTypeID=10;
   break;

   default:
      // 64 кбит/с
      newruleTypeID=14;
}



print("traffic="+traffic+" tarif="+currentTariffID+" rule="+ruletypeID+"newrule="+newruleTypeID);

//если новое правило отличается от существующего то обновляем
if (newruleTypeID != ruletypeID){
   currule.setRuleTypeId(newruleTypeID);
   ugrm.updateUserGateRule( String.valueOf( currule.getID() ), currule );

   // обновление правила на манаде
   csm = new IPNContractStatusManager( con, 3 );

   status =  csm.getContractStatus( cid );
   userID=1; //admin
   // открытие и закрытие шлюза (1-шлюз закрыт)
   csm.changeStatus( cid, 1, userID.intValue(), true );
   csm.changeStatus( cid, status, userID.intValue(), true );
}

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.script.event.*;
import bitel.billing.server.tariff.bean.*;
import bitel.billing.server.ipn.bean.*;
import java.util.*;
import java.text.*;


//номер контракта
cid = event.getContractID();

//получение названия нужной таблици с траффиком
evdate=event.getGenerateTime();
datefrm = new SimpleDateFormat("yyyyMM");
evyear=datefrm.format(evdate.getTime()).toString();

//получение траффика пользователя в данном отчетном периоде
ps = con.prepareStatement("SELECT SUM(amount) FROM ipn_contract_data_3_"+evyear+" WHERE cid=? AND sid=1");
ps.setInt( 1, cid);
rs = ps.executeQuery();
rs.first();
traffic = rs.getLong(1)/1073741824; //в гигабайтах

//получение текущего типа шлюза пользователя
ugrm = new UserGateRuleManager( con, 3 );
rules = ugrm.getUserGateRules( cid );
for( Iterator it = rules.iterator(); it.hasNext(); ){
   currule = it.next();
   if (currule.getGateID() == 1){ //gate IPN
      ruletypeID=currule.getRuleTypeId();
      break;
   }
   print("gates="+currule.getGateID());
}

currentTariffID=chTariff.getTariffPlanID(); // получение id тарифного плана, в которых описаны лимиты по наработке

csm = new IPNContractStatusManager( con, 3 );
status =  csm.getContractStatus( cid );
userID=1; //admin

switch ( currentTariffID ){

case 1:  // id=1 - тариф с наработкой 2 Гб до закрытия шлюза
      if ((traffic>2)&&(status=1)){
        csm.changeStatus( cid, 1, userID.intValue(), true ); //закрыт
    }else{
        If traffic<2{
   csm.changeStatus( cid, 2, userID.intValue(), true ); //открыт
   }else{
   csm.changeStatus( cid, 1, userID.intValue(), true ); //закрыт
   }
   }
    break;

case 2:  // id=2 - тариф с наработкой 2 Гб до закрытия шлюза
      if ((traffic>2)&&(status=2)){
        csm.changeStatus( cid, 1, userID.intValue(), true ); //закрыт
    }else{
        If traffic<2{
   csm.changeStatus( cid, 2, userID.intValue(), true ); //открыт
   }else{
   csm.changeStatus( cid, 1, userID.intValue(), true ); //закрыт
   }
   }
    break;
}