Второй месяц наблюдается проблема с выполнением глобального скрипта планировщиком.
Скрипт выдергивает абонентов определенной группы и добавляет временный лимит.Скрипт выполняется перед снятием абонентской платы,он вытаскивает значение абонентской платы,текущий баланс и смотрит насколько изменится баланс после снятия абоненткой платы,если текущего лимита недостаточно,чтобы абонент продолжал работать,меняет значение лимита,точнее снижает его на время.
Вручную скрипт выполняется нормально,однако уже не первый месяц автоматически планировщиком он не отрабатывает и выдает следующую ошибку:
-----------------------------------------------------------------------------------------------------------
03-01/00:00:02 INFO [Thread-3] TaskExecuter - TaskExecuter => reloadTasks()
03-01/00:00:02 INFO [Thread-3] TaskExecuter - Task #1: bitel.billing.server.npay.Calculator
03-01/00:00:02 INFO [Thread-3] TaskExecuter - Task #2: bitel.billing.server.script.global.bean.GlobalScriptTimer
03-01/00:00:02 INFO [Thread-3] TaskExecuter - Task #3: bitel.billing.server.contract.LimitRestorer
03-01/01:20:02 INFO [Thread-3] TaskExecuter - Starting periodic task #2: bitel.billing.server.script.global.bean.GlobalScriptTimer
03-01/01:20:02 INFO [pool-2-thread-1] ChangeLimit - SELECT id FROM contract WHERE gr&(1<<6) > 0;
03-01/01:20:02 INFO [pool-2-thread-1] ChangeLimit - SELECT id FROM contract WHERE gr&(1<<6) > 0;
03-01/01:20:02 INFO [pool-2-thread-1] ChangeLimit - SELECT id FROM contract WHERE gr&(1<<6) > 0;147
03-01/01:20:02 INFO [pool-2-thread-1] ChangeLimit - abonCost=30.0
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - ru.bitel.bgbilling.common.BGException: java.sql.SQLException: Can't call commit when autocommit=true
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at bitel.billing.server.contract.bean.LimitManager.lowLimit(LimitManager.java:692)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at ChangeLimit.execute(ChangeLimit.java:70)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at ru.bitel.bgbilling.kernel.script.server.bean.GlobalScriptInvoker.invoke(GlobalScriptInvoker.jav
a:22)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at ru.bitel.bgbilling.kernel.script.server.GlobalScriptServiceImpl.executeGlobalScript(GlobalScrip
tServiceImpl.java:75)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at bitel.billing.server.script.global.bean.GlobalScriptTimer.executeJava(GlobalScriptTimer.java:81
)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at bitel.billing.server.script.global.bean.GlobalScriptTimer.executeTask(GlobalScriptTimer.java:48
)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at ru.bitel.bgbilling.kernel.task.server.TaskBase.run(TaskBase.java:74)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at java.lang.Thread.run(Thread.java:722)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - Caused by: java.sql.SQLException: Can't call commit when autocommit=true
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:934)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:931)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at com.mysql.jdbc.ConnectionImpl.commit(ConnectionImpl.java:1646)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at org.apache.commons.dbcp.DelegatingConnection.commit(DelegatingConnection.java:334)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at ru.bitel.bgbilling.server.util.PoolGuardConnectionWrapper.commit(PoolGuardConnectionWrapper.jav
a:73)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - at bitel.billing.server.contract.bean.LimitManager.lowLimit(LimitManager.java:688)
03-01/01:20:02 ERROR [pool-2-thread-1] LoggingPrintStream - ... 9 more
-------------------------------------------------------------------------------------------------------------------------------------
Вот собственно сам скрипт:
public class ChangeLimit
extends GlobalScriptBase
{
Logger logger = Logger.getLogger( ChangeLimit.class);
public Float getAbonPays(Integer cid,Connection con)
throws Exception {
String query = "SELECT n.data FROM contract c LEFT JOIN contract_tariff AS t ON c.id=t.cid LEFT JOIN tariff_plan AS p ON t.tpid=p.id LEFT JOIN module_tariff_tree as m ON m.tree_id=p.tree_id LEFT JOIN mtree_node as n ON n.mtree_id=m.id WHERE m.mid=2 and c.id = ? and n.type like '%cost%' and ( t.date2 is NULL or t.date2 > now());";
PreparedStatement getAbonPay = con.prepareStatement( query );
Float abonCost = 0.0f;
getAbonPay.setInt( 1,cid );
ResultSet abonPay = getAbonPay.executeQuery();
while ( abonPay.next() ) {
String abonPayCostData = abonPay.getString(1);
String[] abonPayCostDataArray = abonPayCostData.split("%");
abonCost = abonCost + Float.parseFloat(abonPayCostDataArray[1].split("&")[1]);
}
logger.info("abonCost=" + abonCost);
return abonCost;
}
@Override
public void execute( Setup setup, ConnectionSet connectionSet )
throws Exception
{
Connection con = connectionSet.getConnection();
ContractManager cmanager = new ContractManager(con);
BalanceUtils bmanager = new BalanceUtils(con);
LimitManager lmanager = new LimitManager(con);
Date curdate = new Date();
String sqlreq = "SELECT id FROM contract WHERE gr&(1<<6) > 0;";
logger.info(sqlreq);
try
{
PreparedStatement ps = con.prepareStatement(sqlreq);
ResultSet rs = ps.executeQuery();
logger.info(sqlreq);
while (rs.next()) {
Integer cid = rs.getInt("id");
logger.info(sqlreq + cid );
Contract contract = cmanager.getContractById(cid);
BigDecimal curLimit = contract.getBalanceLimit();
BigDecimal curBalance = bmanager.getBalance(curdate,cid);
BigDecimal stockval = new BigDecimal("-10.0");
String abonDebtSt = Float.toString(getAbonPays(cid,con));
BigDecimal abonDebt = new BigDecimal(abonDebtSt);
BigDecimal Debt = curBalance.subtract(abonDebt);
if ( curLimit.compareTo(Debt) > 0 ) {
lmanager.lowLimit(cid,curLimit.subtract(Debt.add(stockval)),19);
logger.info("Договор №" + cid + " " + contract.getComment() + "лимит временно изменен со значения:" + curLimit + " до значения:" + Debt.add(stockval) + " на " + curLimit.subtract(Debt.add(stockval)));
}
}
} catch (SQLException ex ) {
logger.info("Message: " + ex.getMessage());
}
}
}
|
