05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream - java.lang.ClassNotFoundException: bitel.billing.server.mail.UserDispatchSender
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.security.AccessController.doPrivileged(Native Method)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.lang.Class.forName0(Native Method)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at java.lang.Class.forName(Class.java:171)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at ru.bitel.bgbilling.kernel.task.server.TaskData.initTask(TaskData.java:66)
05-27/18:50:03 ERROR [Thread-3] LoggingPrintStream -    at bitel.billing.server.TaskExecuter.run(TaskExecuter.java:209)
05-27/18:50:03  INFO [Thread-3] TaskExecuter - Starting periodic task #32: bitel.billing.server.mail.UserDispatchSender
05-27/18:50:03 ERROR [Thread-3] TaskExecuter -
java.lang.NullPointerException
   at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:649)
   at bitel.billing.server.TaskExecuter.run(TaskExecuter.java:213)
05-27/18:50:03  INFO [Thread-3] PaymentLoader - Loaded 1 file types.
05-27/18:50:03  INFO [Thread-3] TaskExecuter - Starting periodic task #11: bitel.billing.server.admin.integration.PaymentLoader
05-27/18:50:03  INFO [Thread-3] PaymentLoader - Loaded 1 file types.
05-27/18:50:03  INFO [Thread-3] TaskExecuter - Starting periodic task #24: bitel.billing.server.admin.integration.PaymentLoader
05-27/18:50:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/18:50:03  INFO [pool-2-thread-2] PaymentLoader - Task finished time=12 ms.
05-27/18:50:03  INFO [pool-2-thread-3] PaymentLoader - Task finished time=8 ms.
05-27/18:50:03 ERROR [pool-2-thread-4] MessageProcessor - Не удалось отправить сообщение пользовательского класса ru.reflexive.DispatchChargeMessage для подписки с id=10
java.lang.ArrayIndexOutOfBoundsException: -1
   at java.util.ArrayList.get(ArrayList.java:324)
   at ru.reflexive.DispatchChargeMessage.getMessageBody(DispatchChargeMessage.java:33)
   at ru.bitel.bgbilling.plugins.dispatch.server.bean.MessageProcessor.processMacro(MessageProcessor.java:156)
   at ru.bitel.bgbilling.plugins.dispatch.server.bean.MessageProcessor.send(MessageProcessor.java:232)
   at ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker.executeTask(DispatchWorker.java:101)
   at ru.bitel.bgbilling.kernel.task.server.TaskBase.run(TaskBase.java:74)
   at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
   at java.lang.Thread.run(Thread.java:662)
05-27/18:50:05  INFO [pool-2-thread-4] DispatchWorker - Task finished time=1331 ms.

05-27/19:29:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/19:29:03  INFO [pool-2-thread-2] DispatchWorker - Task finished time=20 ms.
05-27/19:30:03  INFO [Thread-3] PaymentLoader - Loaded 1 file types.
05-27/19:30:03  INFO [Thread-3] TaskExecuter - Starting periodic task #24: bitel.billing.server.admin.integration.PaymentLoader
05-27/19:30:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/19:30:03  INFO [pool-2-thread-3] PaymentLoader - Task finished time=4 ms.
05-27/19:30:03 ERROR [pool-2-thread-4] MessageProcessor - Не удалось отправить сообщение пользовательского класса ru.reflexive.DispatchChargeMessage для подписки с id=10
java.lang.ArrayIndexOutOfBoundsException: -1
   at java.util.ArrayList.get(ArrayList.java:324)
   at ru.reflexive.DispatchChargeMessage.getMessageBody(DispatchChargeMessage.java:33)
   at ru.bitel.bgbilling.plugins.dispatch.server.bean.MessageProcessor.processMacro(MessageProcessor.java:156)
   at ru.bitel.bgbilling.plugins.dispatch.server.bean.MessageProcessor.send(MessageProcessor.java:232)
   at ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker.executeTask(DispatchWorker.java:101)
   at ru.bitel.bgbilling.kernel.task.server.TaskBase.run(TaskBase.java:74)
   at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
   at java.lang.Thread.run(Thread.java:662)
05-27/19:30:05  INFO [pool-2-thread-4] DispatchWorker - Task finished time=1299 ms.
05-27/19:31:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/19:31:03  INFO [pool-2-thread-5] DispatchWorker - Task finished time=19 ms.
05-27/19:32:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/19:32:03  INFO [pool-2-thread-6] DispatchWorker - Task finished time=20 ms.
05-27/19:33:03  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
05-27/19:33:03  INFO [pool-2-thread-7] DispatchWorker - Task finished time=20 ms.

package ru.skyb.scripts.behavior;

import org.apache.log4j.Logger;

//import java.sql.Connection;
import java.util.List;

import ru.bitel.bgbilling.kernel.event.Event;
import ru.bitel.bgbilling.kernel.script.server.dev.EventScriptBase;
import ru.bitel.bgbilling.server.util.Setup;
import ru.bitel.common.sql.ConnectionSet;

import ru.bitel.bgbilling.plugins.dispatch.common.bean.Contact;
import ru.bitel.bgbilling.plugins.dispatch.server.dao.ContactDao;

import com.logica.smpp.Connection;
import com.logica.smpp.Data;
import com.logica.smpp.pdu.BindRequest;
import com.logica.smpp.pdu.Response;
import com.logica.smpp.pdu.SubmitSM;
import com.logica.smpp.TCPIPConnection;
import com.logica.smpp.Session;
import com.logica.smpp.pdu.BindTransmitter;
import com.logica.smpp.util.ByteBuffer;

import ru.bitel.bgbilling.kernel.contract.balance.server.event.PaymentEvent;

public class SmsGetPayment extends EventScriptBase<PaymentEvent>
{
   private static final Logger logger = Logger.getLogger( SmsGetPayment.class );
   
   @Override
   public void onEvent( PaymentEvent event1, Setup setup2, ConnectionSet connectionSet )
      throws Exception
   {
      java.sql.Connection con = connectionSet.getConnection();

      logger.info( "SMS_PAYMENT_ALERT:Начало" );

      int SmsPort = ;
      String SmsServer = "92.";
      String SmsUser = "";
      String SmsPass = "";
      String OperatorName = "OOOTELEKOM";

      String messPayments = "Поступил платеж на сумму(руб.): ";

      ru.bitel.bgbilling.kernel.contract.balance.common.bean.Payment payment = event1.getPayment();
      //Получаем id договора
      int cid = payment.getContractId();
      //Получаем сумму платежа
      messPayments += payment.getSumma().toString();
            
      logger.info( "SMS_PAYMENT_ALERT:" + messPayments  );      
      logger.info( "SMS_PAYMENT_ALERT:Контракт " + cid  );   
   
      ContactDao cd = new ContactDao(con);
      List<Contact> nymber = cd.getContactsForContract(cid, 1);
      for( Contact c : nymber ){

      //OperatorName = c.getValue();

      Connection conn = new TCPIPConnection( SmsServer , SmsPort );
      conn.setReceiveTimeout(1000 * 60);
      Session session = new Session(conn);
      BindRequest breq = new BindTransmitter();
      Response resp = null;
      try {
         breq.setSystemId(SmsUser);
         breq.setPassword(SmsPass);
         resp = session.bind(breq);
 
         if (resp.getCommandStatus() == Data.ESME_ROK) {
            String message = messPayments;
            
            SubmitSM msg = new SubmitSM();
            ByteBuffer byteMessage = new ByteBuffer();
            byteMessage.appendString(message, "UTF-16BE");
            msg.setDataCoding((byte) 8);
            msg.setSourceAddr((byte) 0, (byte) 5, OperatorName );
            msg.setDestAddr((byte) 1, (byte) 1, c.getValue());
            msg.assignSequenceNumber(true);
            msg.setRegisteredDelivery((byte) 1);
            msg.setMessagePayload(byteMessage);

            logger.info( "SMS_PAYMENT_ALERT:Контакт " + c.getValue()  );   
 
            resp = session.submit(msg);
            session.unbind();
 
            if (resp.getCommandStatus() == Data.ESME_ROK) {
               System.out.println("Message submitted. Status="
                     + resp.getCommandStatus());
            } else {
               System.out.println("Message submission failed. Status="
                     + resp.getCommandStatus());
            }
         } else {
            System.out.println("Couldn't bind. Status="
                  + resp.getCommandStatus());
         }
      } catch (Exception e) {
         e.printStackTrace();
      }


      }


   }

}

package ru.reflexive;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;
import java.util.List;

import ru.bitel.bgbilling.plugins.dispatch.server.bean.message.CustomDispatchMessage;
import ru.bitel.common.Utils;
import bitel.billing.server.contract.bean.BalanceUtils;
import bitel.billing.server.contract.bean.Payment;
import bitel.billing.server.contract.bean.PaymentManager;
import bitel.billing.server.contract.bean.Contract;


public class DispatchPaymentMessage extends CustomDispatchMessage
{
   @Override
   public String getMessageBody()
   {
      StringBuilder result = new StringBuilder( "Расход " );
      Contract contract = contractManager.getContractById( contractId );
      List<Payment> PaymentList = null;
      try
      {
         PaymentList = new PaymentManager( con ).getPaymentList( contractId );
      }
      catch( SQLException e )
      {
         e.printStackTrace();
      }
      Payment lastPayment = PaymentList.get( PaymentList.size() - 1 );
      result.append( Utils.formatBigDecimalSumm( lastPayment.getSumma() ) );
      result.append( " руб. с " + contract.getTitle() + " за " );
      try
      {
         String query = "select title from contract_Payment_types where id=" + lastPayment.getTypeId();
         PreparedStatement ps = con.prepareStatement( query );
         ResultSet rs = ps.executeQuery();
         if( rs.next() )
         {
            result.append( rs.getString( "title" ) );
         }
      }
      catch( SQLException e )
      {
         e.printStackTrace();
      }
      result.append( ", остаток на счете " + Utils.formatBigDecimalSumm( new BalanceUtils( con ).getBalance( new Date(), contract ) ) + " руб." );
      return result.toString();
   }
}

06-09/20:22:01  INFO [Thread-3] TaskExecuter - Starting periodic task #29: ru.bitel.bgbilling.plugins.dispatch.server.DispatchWorker
06-09/20:22:03  INFO [pool-2-thread-2] DispatchWorker - Task finished time=2248 ms.

import java.util.List;

import ru.bitel.bgbilling.kernel.container.managed.ServerContext;
import ru.bitel.bgbilling.kernel.event.Event;
import ru.bitel.bgbilling.kernel.module.common.bean.User;
import ru.bitel.bgbilling.kernel.script.server.dev.EventScriptBase;
import ru.bitel.bgbilling.plugins.dispatch.common.DispatchService;
import ru.bitel.bgbilling.plugins.dispatch.common.bean.Subscription;
import ru.bitel.bgbilling.plugins.dispatch.common.bean.condition.DispatchEventCondition;
import ru.bitel.bgbilling.server.util.Setup;
import ru.bitel.common.sql.ConnectionSet;

public class DispatchCharge
   extends EventScriptBase
{
   @Override
   public void onEvent( Event event1, Setup setup2, ConnectionSet connectionSet3 )
      throws Exception
   {
      int dispatchId = 5;
      int contractId = event1.getContractId();
      ServerContext context = new ServerContext( setup2, connectionSet3, -1, User.USER_SERVER );
      DispatchService service = context.newService( DispatchService.class, -1 );
      List<Subscription> subscriptions = service.getSubscriptions( dispatchId, contractId );
      for( Subscription subscription : subscriptions )
      {
         subscription.getPreferences().set( DispatchEventCondition.EVENT_OCCURED_FLAG, "1" );
         service.updateSubscriptions( subscription );
      }
   }

}

package ru.reflexive;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;
import java.util.List;

import ru.bitel.bgbilling.plugins.dispatch.server.bean.message.CustomDispatchMessage;
import ru.bitel.common.Utils;
import bitel.billing.server.contract.bean.BalanceUtils;
import bitel.billing.server.contract.bean.Payment;
import bitel.billing.server.contract.bean.PaymentManager;
import bitel.billing.server.contract.bean.Contract;


public class DispatchChargeMessage extends CustomDispatchMessage
{
   @Override
   public String getMessageBody()
   {
      StringBuilder result = new StringBuilder( "Приход " );
      Contract contract = contractManager.getContractById( contractId );
      List<Payment> PaymentList = null;
      try
      {
         PaymentList = new PaymentManager( con ).getPaymentList( contractId );
      }
      catch( SQLException e )
      {
         e.printStackTrace();
      }
      Payment lastPayment = PaymentList.get( PaymentList.size() - 1 );
      result.append( Utils.formatBigDecimalSumm( lastPayment.getSumma() ) );
      result.append( " руб. с " + contract.getTitle() + " за " );
      try
      {
         String query = "select title from contract_Payment_types where id=" + lastPayment.getTypeId();
         PreparedStatement ps = con.prepareStatement( query );
         ResultSet rs = ps.executeQuery();
         if( rs.next() )
         {
            result.append( rs.getString( "title" ) );
         }
      }
      catch( SQLException e )
      {
         e.printStackTrace();
      }
      result.append( ", остаток на счете " + Utils.formatBigDecimalSumm( new BalanceUtils( con ).getBalance( new Date(), contract ) ) + " руб." );
      return result.toString();
   }
}

GENERATE_TIME: 24.03.15 16:28:56
EXECUTION_STOP_TIME: 24.03.15 16:28:56
PROCESS_TIME: 12

OUT:


EXCEPTIONS:
Sourced file: Function [id:4; title:ru.reflexive.DispatchCharge] Token Parsing Error: Lexical error at line 18, column 10.  Encountered: "O" (79), after : "@": <at unknown location>

java.util.concurrent.ExecutionException: Sourced file: Function [id:4; title:ru.reflexive.DispatchCharge] Token Parsing Error: Lexical error at line 18, column 10.  Encountered: "O" (79), after : "@": <at unknown location>

   at java.util.concurrent.FutureTask.report(FutureTask.java:122)
   at java.util.concurrent.FutureTask.get(FutureTask.java:202)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener$ThreadedScriptEventListener.runScript(ScriptEventListener.java:466)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener.runScript(ScriptEventListener.java:310)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener.notify(ScriptEventListener.java:277)
   at ru.bitel.bgbilling.kernel.event.AbstractConsumer.notify(AbstractConsumer.java:345)
   at ru.bitel.bgbilling.kernel.event.Consumer.notify(Consumer.java:1)
   at ru.bitel.bgbilling.kernel.event.Consumer.onMessage0(Consumer.java:112)
   at ru.bitel.bgbilling.kernel.event.Consumer$EventListenerRunnable.runImpl(Consumer.java:51)
   at ru.bitel.common.worker.WorkerTask.run(WorkerTask.java:86)
   at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
   at java.lang.Thread.run(Thread.java:745)
   at ru.bitel.common.worker.WorkerThread.run(WorkerThread.java:46)
Caused by: Sourced file: Function [id:4; title:ru.reflexive.DispatchCharge] Token Parsing Error: Lexical error at line 18, column 10.  Encountered: "O" (79), after : "@": <at unknown location>

   at bsh.Interpreter.eval(Interpreter.java:707)
   at ru.bitel.bgbilling.kernel.script.server.bean.ScriptInstance.eval(ScriptInstance.java:323)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener$Worker.runScriptImpl(ScriptEventListener.java:99)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener.runScript(ScriptEventListener.java:353)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener$ThreadedScriptEventListener.access$0(ScriptEventListener.java:1)
   at ru.bitel.bgbilling.kernel.script.server.ScriptEventListener$ThreadedScriptEventListener$1.call(ScriptEventListener.java:454)
   at java.util.concurrent.FutureTask.run(FutureTask.java:262)
   ... 4 more