Автоматизация подключений VPN-клиентов с использованием CRM плагина
Материал из BiTel WiKi
Созданный договор "ожидает" поступления денег на счет.
При поступлении денег оценивается достаточность суммы. Сумма подключения равна 768 рублей, в случае если клиент оплатил в течении пяти рабочих дней от даты заключения договора, 300 рублей, если у договора стоит тариф с кодом 213 "Студент" и 960 рублей в прочих случаях.
Если баланс договора после поступления платежа не превысил стоимость подключния создается задача с типом 8 "Недостаточный платеж", по которой может быть произведен обзвон для уведомления клиента о недостаточности произведенной оплаты. Если баланс договора превысил стоимость подключения после чего создается задача типа 5 "Подключение NK", одновременно на договор заносится расход за подключение и снимается группа "Неоплачен".
Если в договоре не стоит группа "Неоплачен", либо на договор уже создана задача подключения скриптом либо диспетчером (типы 5 и 63), то повторно задача не создается.
В шаблоне договора должен быть прописан скрипт поведения. В скрипте опеределяется функция, обрабатывающая событие "Приход платежа".
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.server.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 );
После выполнения задачи, производится ее обработка. По событию "Обработка задачи" выполняется следующий скрипт. Скрипт открывает абонплату (услуга с кодом 122) датой подключения договора.
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.server.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 );