Автоматизация подключений VPN-клиентов с использованием CRM плагина

import bitel.billing.server.contract.bean.*;
import ru.bitel.bgbilling.plugins.crm.server.bean.*;
import javax.text.*;
import bitel.billing.server.util.*;
import java.sql.*;
import java.util.*;
import ru.bitel.bgbilling.plugins.crm.server.dao.*;
import ru.bitel.bgbilling.plugins.crm.common.model.*;
 
payment = event.getPayment();
 
cid = payment.getContractID();
date = payment.getDate();
 
cm =  new ContractManager(  con );
chm = new ChargeManager( con );
bu = new BalanceUtils( con );
rtm =  new RegisterTaskManager( con );
pm = new PaymentManager( con );
cpu = new ContractParamUtils( con );
ctm =  new ContractTariffManager(  con );
 
DATE_ZAKL = 315;
 
DAYS_DELTA = 5;
 
SUMMA_LARGE = 960f;
SUMMA_SMALL = 768f;
SUMMA_STUDENT = 300f;
 
TARIFF_STUDENT = 213;
 
SMALL_PAY_TASK_TYPE = 8;
SMALL_PAY_TASK_GROUP = 11;
 
CONNECT_NK_TASK_TYPE = 5;
CONNECT_NK_DISP_TASK_TYPE = 63;
CONNECT_TASK_GROUP = 9;
 
ADDRESS_PARAM = 42;
CONNECT_CHARGE_TYPE = 43;
 
long NEOPL = 1<<4;
 
contract = cm.getContractByID( cid );
if( contract == null ) {
    error( "Contract not found!" );
    return;
}
 
long groups = contract.getGroups();
if( (groups & NEOPL) == 0 ) {
    error( "NEOPL group is not set!" );
    return; 
}
 
// дата заключения
dateZakl = cpu.getDateParam( cid, DATE_ZAKL );
 
if( dateZakl == null ) {
 error( "dateZakl == null" );
 return; 
}
 
if( TimeUtils.dateBefore( date, dateZakl ) ) {
 error( "Current date precedes the dateZakl." );
 return;     
}
 
// проверка существования в договоре задач типа "Подключение NK (диспетчер)"
filter = new RegisterTaskManager.TaskFilter();
filter.types =  CONNECT_NK_DISP_TASK_TYPE.toString();
filter.cid = cid;
filter.orders = new ArrayList();
filter.processed = -1;
 
taskCount = rtm.getTaskCount( filter );
 
// если такая задача уже есть, значит, ничего делать не нужно
if( taskCount > 0 ) {
    error( "The contract has been made via the 'NK Dispatcher' scheme." );
    return;
}
 
// проверка существования в договоре задач типа "Подключение NK"
filter.types =  CONNECT_NK_TASK_TYPE.toString();
 
taskCount = rtm.getTaskCount( filter );
 
// если такая задача уже есть, значит, ничего делать не нужно
if( taskCount > 0 ) {
    error(taskCount + " CONNECT_NK task(s) already exist." );
    return;
}
 
// сколько дней прошло с момента заключения договора до прихода платежа (текущего момента)
delta = 0;
dt = (Calendar)dateZakl.clone();
 
print( "dateZakl: " + TimeUtils.formatDate( dt ) + ";  date: " + TimeUtils.formatDate( date )  );
 
while( TimeUtils.dateBefore( dt, date ) ) {
    if( dt.get( Calendar.DAY_OF_WEEK ) != Calendar.SUNDAY &&
    dt.get( Calendar.DAY_OF_WEEK ) != Calendar.SATURDAY ) {
        print( "dt: " +  TimeUtils.formatDate( dt ) ); 
        delta++;
    }
    dt.add( Calendar.DAY_OF_YEAR, 1 );
}
 
print( "delta = " + delta  );
 
 
// текущий тарифный план договора
tpid = ctm.getContractTariff( cid, date ).getTariffPlanID();
 
// определение суммы
summa = SUMMA_LARGE;
 
if( delta <= DAYS_DELTA ) {
    summa = SUMMA_SMALL;
}
 
if( tpid == TARIFF_STUDENT ) {
    summa = SUMMA_STUDENT;
}
 
print( "summa = " + summa );
 
// не хватает денег
rest = bu.getBalance( event.getGenerateTime(), cid );
if( rest < summa ) {
    print( "Create call task" );
 
    task = new RegisterTask();
    task.setContractID( cid );
    task.setTypeID(  SMALL_PAY_TASK_TYPE );
    task.setGroupID( SMALL_PAY_TASK_GROUP );
    task.setOpenUserID( 0 ) ;
    task.setOpenTime( event.getGenerateTime() );
    task.setComment( "Недостаточный платеж за подключение" );
    task.setAddressParamID( ADDRESS_PARAM );
 
    rtm.updateTask( "new", task );
 
    return;
}
 
// снимаем группу "Неоплачен"
long groups = contract.getGroups();
if ( ( groups & NEOPL ) > 0L ) {
    groups = groups - NEOPL;
}
 
query = "UPDATE contract SET gr=? WHERE id=?";
ps = con.prepareStatement( query );
ps.setLong( 1, groups );
ps.setInt( 2, cid );
ps.executeUpdate();
 
// установка расхода
charge = new Charge();
charge.setContractID( cid );
charge.setDate( date );
charge.setChargeTypeID( CONNECT_CHARGE_TYPE );
charge.setComment( "Установлено скриптом" );
charge.setSumma( summa );
 
chm.updateCharge( "new", charge );
bu.updateBalance( date, cid );
 
// генерация задания на подключение
task = new RegisterTask();
task.setContractID( cid );
task.setTypeID(  CONNECT_NK_TASK_TYPE );
task.setGroupID( CONNECT_TASK_GROUP );
task.setOpenUserID( 0 ) ;
task.setOpenTime( event.getGenerateTime() );
task.setAddressParamID( ADDRESS_PARAM );
 
if( contract.getSubList().length() > 0 ) {
    task.setComment( "+свобода" );
}
 
rtm.updateTask( "new", task );

import bitel.billing.server.contract.bean.*;
import ru.bitel.bgbilling.plugins.crm.server.bean.*;
import java.util.regexp.*;
import javax.text.*;
import bitel.billing.server.util.*;
import java.sql.*;
import ru.bitel.bgbilling.plugins.crm.server.dao.*;
import ru.bitel.bgbilling.plugins.crm.common.model.*;
 
// Типы обрабатываемых задач
TASK_CONNECT_NK = 5;
 
task = event.getTask();
 
cid = event.getContractID();
date = task.getExecuteDate();
type = task.getTypeID();
 
report = event.getReport();
 
if( type != TASK_CONNECT_NK )
{
 print( "Can't process tasks of this type." );
 return;
}
 
ctm =  new ContractTariffManager(  con );
csm = new ContractServiceManager( con );
cu = new ContractUtils( con );
 
// проверка что абонплата уже стоит
isSetPay = false;
serviceList  = csm.getContractServiceList( cid, date );
for( Iterator it = serviceList.iterator(); it.hasNext(); ) {
 service = (ContractService)it.next();
 sid = service.getServiceID();
 
 if(  sid == 122 ) {    
      report.append( cu.getContractTitle( cid, true ) );
      report.append( " => абонплата уже установлена\n" );
 
      error( "Pay already set!" );
      return;
     }
 }
}
 
sid = 122;
 
// включение абонплаты
if( !isSetPay ) {
    newPay = new ContractService();
    newPay.setContractID( cid );
    newPay.setServiceID( sid );
    newPay.setComment( "Установлена скриптом" );
    newPay.setDate1( date );
 
    csm.updateContractService( "new", newPay );
}
 
task.setProcessed( true );