BiTel

nt = new RegisterTask();
rtm = new registertaskManager();
nt.setExecutors(some_executors_list);
rtm.updateTask(nt);
rtm.updateExecutorsList(nt,"");

rtm.updateExecutorsList(nt.getID(),"");

import java.sql.*;
import java.util.*;
import bitel.billing.server.contract.bean.*;
import bitel.billing.server.util.*;
import bitel.billing.server.model.*;
import ru.bitel.bgbilling.plugins.crm.server.bean.*;
import ru.bitel.bgbilling.plugins.crm.server.dao.*;
import ru.bitel.bgbilling.plugins.crm.common.model.*;

int DATE_ZAKL_DOG = 25;
int ADDR = 7;
int FIO = 9;
int TYPE_ID = 5;
rtm = new RegisterTaskManager(con);

payment = event.getPayment();
cid = event.getContractID();
CM = new ContractManager ( con );
cpu = new ContractParamUtils ( con );
cont = cpu.getDateParam (cid , DATE_ZAKL_DOG );
contr = CM.getContractByID( cid );
capv = cpu.getAddressParam(cid,ADDR);
print ("CID: " + cid);
filter = new RegisterTaskManager.TaskFilter();
filter.cid = cid;
filter.orders = new ArrayList();

if ( cont == null ) {
   cpu.setDateParam ( cid, DATE_ZAKL_DOG, payment.getDate().getTime() );
   contr.setComment ( cpu.getStringParam ( cid, FIO ));
      query = "UPDATE contract SET comment=? WHERE id=?";
      psUpdate = con.prepareStatement( query );
      psUpdate.setString( 1, cpu.getStringParam ( cid, FIO ));
      psUpdate.setInt( 2, cid );
      psUpdate.executeUpdate();
      print ("Contract comment: " + contr.getComment());
      print ("Contract FIO: " + cpu.getStringParam(cid, FIO));
//         if ( rtm.getTaskCount(filter) > 0 ) {
//            prt = rtm.getTaskList(filter, new Page (0,0));
//            prts = prt.size();
//            print ("prt.size();" + prt.size()+"rtm.getTaskCount(filter)"+rtm.getTaskCount(filter));
//            for (int i=0; i<prts;i++) {
//            obj = prt.get(i);
//            task = obj.getTask();
//            print ( "Contract : "+obj.getContract() );
//            print ( "comment :" + task.getComment() + " Status :" + task.getStatus());
//            }
            
//         } else {
            print (" no task count, making new task" );
            curtime = payment.getDate().getTime();
            nt = new RegisterTask();
            rtm.loadExecutorList(nt);
            lst = nt.getExecutors();
            lst.clear();
            query = "SELECT * FROM register_executor";
            re = con.prepareStatement(query);
            ResultSet re = re.executeQuery();
//            re.first();
            while (re.next()) {
            if (capv.getAddress().indexOf(re.getString(2)) != -1) {
            print (re.getString(2) +" | "+ capv.getAddress() +" | "+ re.getInt(1));
            print(capv.getAddress().indexOf(re.getString(2)));
            lst.add(re.getInt(1));
            if (lst.isEmpty()) {
            print ("Empty");
            }else {
            for (int i=0; i<lst.size(); i++) {
            if ( i>0 ) {
            execlst = ","+lst.get(i);
            } else {
            execlst = lst.get(i);
            }
            }}
            nt.setExecutors(lst);
            break;
            }
            }
            ttt = nt.getExecutors();
            for (int i=0; i<ttt.size(); i++) {
            print ("tttttttt : "+ttt.get(i));
            }            
            nt.setAddressObjectId(7);
            nt.setAddressParamID(7);
            nt.setAcceptUserID(payment.getUserID());
            nt.setCloseUserID(payment.getUserID());
            nt.setCreateUserID(payment.getUserID());
            nt.setLastmodTime(curtime);
            nt.setLastmodUserID(payment.getUserID());
            nt.setOpenTime(curtime);
            nt.setOpenUserID(payment.getUserID());
            nt.setProcessed(true);
            nt.setResolution("Новое подключение. Задача сгенерирована скриптом");
            nt.setTargetDate(curtime);
            nt.setAcceptTime(curtime);
            nt.setCloseTime(curtime);
            nt.setComment("Сделано скриптом");
            nt.setCreateTime(curtime);
            nt.setExecuteDate(curtime);
            nt.setStatus(2);
            nt.setContractID(cid);
            nt.setTypeID(TYPE_ID);
            rtm.updateTask("new", nt);
            rtm.updateExecutorList (nt, "");
//               }
} else {
      print ("this task can not be processed! date of contract confirmation is already set");
return;
      }

task.setGroupID(int)

   public void updateTask( String id, RegisterTask task )
   {
      try
      {
         String query = null;
         PreparedStatement ps = null;

         if( id.equals( "new" ) )
         {
            query = "INSERT INTO register_task " +
                  "(cid, type, open_dt, open_uid, accept_dt, accept_uid, " +
                  "close_dt, close_uid, status, target_dt, comment, gr, resolution, prid, execute_dt, apid, processed," +
                  "lm_dt, lm_uid, aobject_id ) " +
                  "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
            ps = con.prepareStatement( query );
         }
         else
         {
            query = "UPDATE register_task SET cid=?, type=?, open_dt=?, open_uid=?, accept_dt=?, accept_uid=?, " +
                  "close_dt=?, close_uid=?, status=?, target_dt=?, comment=?, gr=?, resolution=?, prid=?, execute_dt=?, apid=?, processed=?, lm_dt=?, lm_uid=?, aobject_id=? WHERE id=?";
            ps = con.prepareStatement( query );

            ps.setInt( 21, CommonUtils.parseIntString( id, 0 ) );
         }

         ps.setInt( 1, task.getContractID() );
         ps.setInt( 2, task.getTypeID() );
         ps.setTimestamp( 3, TimeUtils.convertDateToTimestamp( task.getOpenTime() ) );
         ps.setInt( 4, task.getOpenUserID() );
         ps.setTimestamp( 5, TimeUtils.convertDateToTimestamp( task.getAcceptTime() ) );
         ps.setInt( 6, task.getAcceptUserID() );
         ps.setTimestamp( 7, TimeUtils.convertDateToTimestamp( task.getCloseTime() ) );
         ps.setInt( 8, task.getCloseUserID() );
         ps.setInt( 9, task.getStatus() );
         ps.setDate( 10, TimeUtils.convertDateToSqlDate( task.getTargetDate() ) );
         ps.setString( 11, task.getComment() );
         ps.setInt( 12, task.getGroupID() );
         ps.setString( 13, task.getResolution() );
         ps.setInt( 14, task.getProblemID() );
         ps.setDate( 15, TimeUtils.convertDateToSqlDate( task.getExecuteDate() ) );
         ps.setInt( 16, task.getAddressParamID() );
         ps.setBoolean( 17, task.isProcessed() );
            ps.setTimestamp( 18, TimeUtils.convertDateToTimestamp( task.getLastmodTime() ) );
            ps.setInt( 19, task.getLastmodUserID() );
            ps.setInt( 20, task.getAddressObjectId() );

         ps.executeUpdate();

         if( id.equals( "new" ) )
         {
            task.setID( Utils.lastInsertId( ps ) );
         }
         else
         {
            task.setID( CommonUtils.parseIntString( id, 0 ) );
         }
         ps.close();
      }
      catch ( Exception ex )
      {
         ex.printStackTrace();
      }
   }

   public void updateExecutorList( RegisterTask task, String groupExecutors )
   {
      String query = null;
      PreparedStatement ps = null;

      try
      {
         if ( CommonUtils.notEmptyString( groupExecutors ) )
         {
            // удаляем только исполнителей из текущей группы
            query = "DELETE FROM register_task_executor WHERE tid=? ";
            query += " AND eid IN ( " + groupExecutors + ")";

            ps = con.prepareStatement( query );
            ps.setInt( 1, task.getID() );
            ps.executeUpdate();
            ps.close();
         }

         query = "INSERT INTO register_task_executor (tid, eid) VALUES (?, ?)";
         ps = con.prepareStatement( query );
         ps.setInt( 1, task.getID() );
         for( Integer executor : task.getExecutors() )
         {
            ps.setInt( 2, executor );
            ps.executeUpdate();
         }
         ps.close();
      }
      catch ( Exception ex )
      {
         ex.printStackTrace();
      }
   }

query="SELECT * FROM register_task_executor WHERE tid=?";
ps.PrepareStatement(query);
ps.setString(1,some-task-object.getId());

   public void loadExecutorList( RegisterTask task )
   {
      try
      {
         List<Integer> executors = new ArrayList<Integer>();
         String query = "SELECT eid FROM register_task_executor WHERE tid=?";
         PreparedStatement ps = con.prepareStatement( query );
         ps.setInt( 1, task.getID() );
         ResultSet rs = ps.executeQuery();
         while( rs.next() )
         {
            executors.add( new Integer( rs.getInt( 1 ) ) );
         }
         ps.close();
         task.setExecutors( executors );
      }
      catch ( Exception ex )
      {
         ex.printStackTrace();
      }
   }

register_task_executor

public class ActionGetRegisterTask
    extends ActionBase
{
    @Override
    public void doAction()
        throws SQLException
    {
        int id = getIntParameter( "id", -1 );
        if ( id < 0 )
        {
            setParamsError();
            return;
        }
        Element taskEl = createElement( rootNode, "task" );
        RegisterTaskManager taskManager = new RegisterTaskManager( con );
        RegisterTask task = taskManager.getTaskByID( id );
        if ( task != null )
        {
            taskEl.setAttribute( "type", String.valueOf( task.getTypeID() ) );
            taskEl.setAttribute( "apid", String.valueOf( task.getAddressParamID() ) );
            taskEl.setAttribute( "aObjectId", String.valueOf( task.getAddressObjectId() ) );
            taskEl.setAttribute( "target_date", TimeUtils.formatDate( task.getTargetDate() ) );
            taskEl.setAttribute( "execute_date", TimeUtils.formatDate( task.getExecuteDate() ) );
            taskEl.setAttribute( "group", String.valueOf( task.getGroupID() ) );
            taskEl.setAttribute( "executors", CommonUtils.listToString( task.getExecutors() ) );
            taskEl.setAttribute( "status", String.valueOf( task.getStatus() ) );
            taskEl.setAttribute( "open", buildRef( task.getOpenUserID(), task.getOpenTime() ) );
            taskEl.setAttribute( "accept", buildRef( task.getAcceptUserID(), task.getAcceptTime() ) );
            taskEl.setAttribute( "close", buildRef( task.getCloseUserID(), task.getCloseTime() ) );
            taskEl.setAttribute( "lastmod", buildRef( task.getLastmodUserID(),
                                                      task.getLastmodTime() ) );
            Element commentEl = createElement( taskEl, "comment" );
            stringToLines( commentEl, task.getComment() );
            Element resolutionEl = createElement( taskEl, "resolution" );
            stringToLines( resolutionEl, task.getResolution() );
            if ( task.getContractID() > 0 )
            {
                ContractManager cm = new ContractManager( con );
                Contract contract = cm.getContractByID( task.getContractID() );
                taskEl.setAttribute( "contract", contract.getTitle() );
                taskEl.setAttribute( "contract_id", String.valueOf( contract.getID() ) );
            }
        }
    }
}

   public RegisterTask getTaskByID( int id )
   {
      RegisterTask result = null;

      try
      {
         String query = "SELECT * FROM register_task WHERE id=?";
         PreparedStatement ps = con.prepareStatement( query );
         ps.setInt( 1, id );
         ResultSet rs = ps.executeQuery();
         if ( rs.next() )
         {
            result = new RegisterTask();
            loadTaskFromRS( "", rs, result );
            loadExecutorList( result );
         }
         ps.close();
      }
      catch ( Exception ex )
      {
         ex.printStackTrace();
      }

      return result;
   }

query = "SELECT hid FROM contract_parameter_type_2 where address =?";
pa = con.prepareStatement(query);
pa.setString(1,capv.getAddress());
pa = pa.executeQuery(); pa.next();            

nt.setAddressObjectId(pa.getInt(1));
nt.setAddressParamID(pa.getInt(1));

nt.setAddressObjectId( 0 );
nt.setAddressParamID(pa.getInt(1));

            nt.setAddressObjectId(0);
            nt.setAddressParamID(pa.getInt(1));

            nt.setAddressObjectId(pa.getInt(1));
            nt.setAddressParamID(0);

      query.append( "SELECT task.*, address.hid, address.flat, address.room, objecta.flat, objecta.room, contract.title, " );
        query.append(  "phone.val, " );
   query.append( "house.*, quarter.title, street.title, city.title" );
        query.append( " FROM register_task AS task  " );
        query.append( " LEFT JOIN object ON task.aobject_id=object.id" );
        query.append( " LEFT JOIN object_param_value_address as objecta " );
        query.append( " ON object.id=objecta.object_id AND task.apid=param_id" ); 
        query.append( " LEFT JOIN contract_parameter_type_2 AS address " );
      query.append( " ON task.cid=address.cid AND address.pid=task.apid AND task.aobject_id=0" );      
        // дом
      query.append( " LEFT JOIN address_house AS house" );
      query.append( " ON house.id=IF (address.hid IS NULL, objecta.hid, address.hid ) " );
      // квартал
      query.append( " LEFT JOIN address_quarter AS quarter" );
      query.append( " ON house.quarterid=quarter.id " );
      // название улицы
      query.append( " LEFT JOIN address_street AS street" );
      query.append( " ON house.streetid=street.id" );
      // город
      query.append( " LEFT JOIN address_city AS city" );
      query.append( " ON house.cityid=city.id" );