package ru.ellcom.test;

import bitel.billing.server.contract.bean.Contract;
import bitel.billing.server.contract.bean.ContractManager;
import bitel.billing.server.contract.bean.LimitChangeTask;
import bitel.billing.server.contract.bean.LimitManager;
import ru.bitel.bgbilling.kernel.module.common.bean.User;
import ru.bitel.bgbilling.kernel.script.server.dev.GlobalScriptBase;
import ru.bitel.bgbilling.server.util.Setup;
import ru.bitel.common.sql.ConnectionSet;

import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.List;

public class LimitVip
   extends GlobalScriptBase
{
   @Override
   public void execute( Setup setup, ConnectionSet connectionSet )
      throws Exception
   {
      int groupId = 1;
      int count = 0;

      print("Start");
      Connection con  = connectionSet.getConnection();
      ContractManager cm = new ContractManager(con);
      LimitManager lm = new LimitManager(con);
            
      long timeStart = System.currentTimeMillis();
      String query =    " SELECT c.id FROM contract AS c WHERE c.gr&(1<<"+ groupId +") > 0";
      java.sql.PreparedStatement ps = con.prepareStatement( query );
      ResultSet rs = ps.executeQuery();

      while ( rs.next() )
      {
         int cid = rs.getInt("c.id");
         List<LimitChangeTask> taskList = lm.getContractMoveTasks(cid);
         for (LimitChangeTask task : taskList) {
            lm.deleteMoveTaskAndLog(task.getId(), task.getContractId(), task.getUserId());
         }
         BigDecimal limit = new BigDecimal(-10000000);
         lm.updateContractLimit(User.USER_SERVER, limit, cid, "Лимит выставленный VIP абонентам", "");
         count++;
      }
      rs.close();
      ps.close();
      long timeEnd = System.currentTimeMillis();
      print( "Count = " + count);
      print( "Process time: " + (timeEnd - timeStart)/1000 + " s." );
            
   }
}

SELECT c.id, c.title, c.comment, s.title, s.status
FROM contract AS c
LEFT JOIN inet_serv_12 AS s ON s.contractId = c.id
WHERE s.contractId IS NOT NULL
AND s.status <> 0

lm.updateContractLimit(User.USER_SERVER, limit, cid, "Лимит выставленный VIP абонентам", "");

              Payment fakePayment = new Payment();//гененрируем событие изменения лимита:
              fakePayment.setContractID(cid);
              fakePayment.setPaymentTypeID(-1);
              fakePayment.setDate(new Date());
              fakePayment.setUserID(-1);
              EventProcessor.getInstance().publish( new PaymentEvent(0, fakePayment));

SELECT c.id, c.title, c.comment, c.status, s.title, s.status
FROM contract AS c
LEFT JOIN inet_serv_12 AS s ON s.contractId = c.id
WHERE s.contractId IS NOT NULL
AND c.status <> 0