Организация семейства UNLIMIT тарифов на базе FreeBSD MPD

import bitel.billing.server.contract.bean.*;
 
cid = event.getContractID();
cm = new ContractManager( con );
 
contract = cm.getContractByID( cid );
 
if( contract == null )
{
	error( "Contract not found!" );
	return;
}
 
if( contract.getTitle().startsWith( "NK" ) )
{
	event.addAction( 1, "Активация UNLIM" );
}

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.util.*;
import java.sql.*;
import java.util.*;
 
MAX_FREEDOM_COUNT = 1;
PATTERN_ID = 16;
MID = 3;
 
cm = new ContractManager( con );
 
contract = cm.getContractByID( event.getContractID() );
if( contract == null )
{
	error( "Contract not found!" );
	return;
}
 
if( event.getActionId() == 1 )
{
	if( contract.isSub() )
	{ 
		event.addReport( "Это субдоговор!"		);
		return;
	}
 
	subList = contract.getSubList();
	count = 0;
 
	print( "count=" + count );
 
	// есть субдоговора
	if( Utils.notBlankString( subList ) )
	{ 
		String query = "SELECT COUNT(*) FROM contract WHERE id IN ("	+ subList + " ) AND title LIKE 'FREEDOM%'";
		ResultSet rs = con.createStatement().executeQuery( query );
 
		if( rs.next() )
		{
			count = rs.getInt( 1 );
 
			if( count >= MAX_FREEDOM_COUNT )
			{
				event.addReport( "Больше активировать договора Свобода нельзя" );
				return;
			}
		}
	}
 
    mainLoginPswd = "";
    mainLogin = "";
 
	// выбор пароля основного логина
    query = "SELECT login, pswd FROM user_login_" + MID + 
			" WHERE (date1 IS NULL OR date1<=CURDATE()) AND (date2 IS NULL OR date2>=CURDATE()) AND cid=" + contract.getID();
	rs = con.createStatement().executeQuery( query );
	if( rs.next() )
	{
		mainLogin = rs.getString( 1 );
		mainLoginPswd = rs.getString( 2 );
	}
	else
	{
		event.addReport( "Не найдено активных логинов в основном договоре!" );
		print( "no active login" );
		return;
	}
 
 
	// создаем новый договор и добавляем его субдоговором
	subContract = cm.createFromPattern( PATTERN_ID, "FREEDOM_" + count + "/" + contract.getTitle(), new GregorianCalendar(), "" );
	cm.addSub( contract.getID(), subContract.getID() );
 
	while (true) {
		print("Trying to create a login.");
		// выбор номера логина
	    login = 0;
	    query = "SELECT * FROM user_login_" + MID + " ORDER BY login";
	    ps = con.prepareStatement( query );
 
    	rs = ps.executeQuery();
	    while ( rs.next() )
    	{
	        if ( login != rs.getInt( "login" ) )
    	    {
        	   break;
	        }
    	    else
    		{
	           login++;
    	    }
	    }
 
		// создание логина
	    query = "INSERT INTO user_login_" + MID + " ( cid, login, date1, status, session, pswd, realm_group ) VALUES ( ?, ?, ?, ?, ?, ?, ? )";
	    ps = con.prepareStatement( query );
	    ps.setInt( 1, subContract.getID() );
	    ps.setInt( 2, login );
	    ps.setDate( 3, TimeUtils.convertCalendarToSqlDate( subContract.getDate1() ) );
	    ps.setInt( 4, 0 );
	    ps.setInt( 5, 1 );
		ps.setString( 6, mainLoginPswd );
        ps.setString( 7, "freedom" );
		try {
	    	ps.executeUpdate();
			break;
		} catch (e) {
			print("Couldn't set login " + login + " due to an exception " + e);
		}
	}
 
	event.addReport( "Активирован безлимитный договор " + subContract.getTitle() + 
					", Вы можете найти ссылку на него в верхней области окна.\n" );
	event.addReport( "Ваш безлимитный логин " + login + ", пароль совпадает с паролем на логин " + mainLogin + "\n\n" );
	event.addReport( "Вам необходимо перейти в статистику договорa " + subContract.getTitle() + "(ссылка в левой верхней области экрана) и выбрать тариф в меню 'Смена тарифных планов'\n" );
	event.addReport( "Добавьте задание на смену с текущей или любой другой даты. Проконтролировать смену тарифа Вы можете, выбрав повторно пункт 'Смена тарифных планов'.\n\n" );
	event.addReport( "ВНИМАНИЕ! После активации тарифа Вы можете воспользоваться 'безлимитным' логином только в том случае, если на счету основного договора достаточно средств\n" );
 
 
	print( "UNLIM activated! Login=" + login + ", pswd=" + mainLoginPswd );
}

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.tariff.bean.*;
import bitel.billing.server.script.event.*;
import bitel.billing.server.util.*;
import java.util.*;
 
VPN_MID = 3;
 
cid = event.getContractID();
dateList = new ArrayList();
event.setDateList( dateList );
 
// проверка отсутсвия открытых учетных периодов в период действия тарифа
query = "SELECT end FROM calculate_period_" + VPN_MID + " WHERE cid=? AND start<=? AND ?<=end";
ps = con.prepareStatement( query );
 
ps.setInt( 1, cid );
ps.setDate( 2, TimeUtils.convertDateToSqlDate( event.getDate() ) );
ps.setDate( 3, TimeUtils.convertDateToSqlDate( event.getDate() ) );
 
rs = ps.executeQuery();
 
// есть открытый период, можно менять тариф только после него
if( rs.next() )
{
	error( "Has an activated period.." );
 
	end = TimeUtils.convertDateToCalendar( rs.getDate( 1 ) );
	end.add( Calendar.DAY_OF_YEAR, 1 );
 
	dateList.add( end.getTime() );
}
//  нет открытого периода в настоящий момент, можно менять с текущей даты
else
{
	dateList.add( new Date() );
}

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.tariff.bean.*;
import bitel.billing.server.script.event.*;
import bitel.billing.server.util.*;
import java.util.*;
 
VPN_MID = 3;
 
cid = event.getContractID();
event.setProcessed( true );
 
ctm =  new ContractTariffManager(  con );
chm = new ChargeManager( con );
csm = new ContractServiceManager( con );
 
print( "Set new tariff: " + event.getToTariff().getID() );
 
// текущий тарифный план
currentTariff = event.getFromTariff();
if( currentTariff != null )
{
	tpid = currentTariff.getTariffPlanID();
	if( (tpid > 69) || (tpid < 53) )
	{
		 error("Wrong tariff: " + tpid );
		 return;
	}
 
	// проверка отсутсвия открытых учетных периодов в период действия тарифа
	query = "SELECT COUNT(*) FROM calculate_period_" + VPN_MID + " WHERE cid=? AND start<=? AND ?<=end";
	ps = con.prepareStatement( query );
 
	ps.setInt( 1, cid );
	ps.setDate( 2, TimeUtils.convertDateToSqlDate( event.getFromDate() ) );
	ps.setDate( 3, TimeUtils.convertDateToSqlDate( event.getFromDate() ) );
 
	rs = ps.executeQuery();
 
	if( rs.next() && rs.getInt(1) > 0 )
	{
		error( "Has an activated period.." );
		return;	
	}
 
	// закрываем старый тариф днем ранее
	endDate = new GregorianCalendar();
	endDate.setTime( event.getFromDate() );
 
	print( "endDate: " + TimeUtils.formatDate( endDate ) );
 
	endDate.add( Calendar.DAY_OF_MONTH, -1 );
 
	currentTariff.setDate2( endDate );
 
	if( TimeUtils.dateBefore( currentTariff.getDate2(), currentTariff.getDate1() ) )
	{
		ctm.deleteContractTariff( currentTariff.getID() );
	}
	else
	{
		// ctm.updateContractTariff( String.valueOf( currentTariff.getID() ), currentTariff  );
	      ctm.updateContractTariff( currentTariff  );
	}
}
 
// вносим новый тариф
newPlan = new  ContractTariff();
newPlan.setContractID( cid );
newPlan.setTariffPlanID( event.getToTariff().getID() );
newPlan.setDate1( TimeUtils.convertDateToCalendar( event.getFromDate() ) );
newPlan.setComment( "Смена тарифа через WEB" );
 
// ctm.updateContractTariff( "new", newPlan );
ctm.updateContractTariff( newPlan );

import bitel.billing.server.contract.bean.*;
import bitel.billing.server.util.*;
import java.util.*;
import java.math.*;
 
VPN_MID = 3;
CHARGE_TYPE = 21;
 
bu = new BalanceUtils( con ) ;
cm = new ContractManager( con );
chm = new ChargeManager( con );
ctm = new ContractTariffManager( con );
 
event.setProcessed( true );
 
if( event.getRequestDate() == null ) {
    error(  "event.requestDate() == null" );
    return;
}
 
cid = event.getContractID();
contract = cm.getContractByID( cid );
 
if( contract == null ) {
    error( "Contract with ID " + cid + " was not found!" );
    return;
}
 
date_clndr = (Calendar)event.getRequestDate();
date = date_clndr.getTime();
 
currentTariff = ctm.getContractTariff( cid, date_clndr );
if( currentTariff == null ) {
   error( "Current tariff was not found!" );
   return;
}
 
PAY = 0;
 
tpid = currentTariff.getTariffPlanID();
if(  tpid == 53 ) {
    PAY = 290;
}
else if ( tpid == 66 ) {
    PAY = 360;
}
else if ( tpid == 67 ) {
    PAY = 660;
}
else if ( tpid == 68 ) {
    PAY = 960;
}
else if ( tpid == 69 ) {
    PAY = 1660;
}
else {
    error( "Incorrect current tariff!" );
    return;
}
 
balance = bu.getBalance( date, cid );
 
if( balance.intValue() < PAY ) {
    error( "Not enough money to open a period!!" );
    return; 
}
 
charge = new Charge();
charge.setContractID( cid );
charge.setDate( date_clndr );
charge.setChargeTypeID( CHARGE_TYPE );
charge.setComment( "Активация периода UNLIM" );
charge.setSumma( PAY );
 
chm.updateCharge( "new", charge );
 
// обновляем баланс 
bu.updateBalance( date, cid );
 
date_start = new GregorianCalendar();
date_start.setTime( date );
date_end = (Calendar)date_start.clone();
date_end.add( Calendar.DAY_OF_YEAR, 30 );
event.setPeriodStart( date_start );
event.setPeriodEnd( date_end );
 
print( "PAY = " + PAY );