А что такого в скрипте что он вызвал вот такое будучи запущенным через дин.код?
Код:
package ru.ellcom.test;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.List;
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.Utils;
import ru.bitel.common.sql.ConnectionSet;
import bitel.billing.server.contract.bean.Contract;
import bitel.billing.server.contract.bean.ContractManager;
import bitel.billing.server.contract.bean.ContractParameterManager;
import ru.bitel.bgbilling.kernel.contract.param.common.bean.*;
import com.Ostermiller.util.ExcelCSVParser;
import com.mysql.jdbc.PreparedStatement;
public class loadManagers
extends GlobalScriptBase
{
int paramId = 27;
int userId = 13;
@Override
public void execute( Setup setup, ConnectionSet connectionSet )
throws Exception
{
print("Start");
Connection con = connectionSet.getConnection();
ContractParameterManager cpm = new ContractParameterManager( con );
long timeStart = System.currentTimeMillis();
// удаление всех установленных менеджеров
String query = "SELECT cid FROM contract_parameter_type_7 WHERE pid = ?";
java.sql.PreparedStatement ps = con.prepareStatement( query );
ps.setInt( 1, paramId );
ResultSet rs = ps.executeQuery();
int count = 0;
while ( rs.next() )
{
cpm.deleteListParam(rs.getInt( 1 ), paramId, User.USER_SERVER);
++count;
}
ps.close();
print( "Removed " + count + " values" );
// загружаем файлы
loadFile( "/opt/BG/manager_new.csv", setup, con, cpm );
long timeEnd = System.currentTimeMillis();
print( "Process time: " + (timeEnd - timeStart)/1000 + " s." );
}
private void loadFile( String filename, Setup setup, Connection con, ContractParameterManager cpm )
throws Exception
{
ContractManager cm = new ContractManager( con );
String[][] data = ExcelCSVParser.parse( new InputStreamReader( new FileInputStream( filename ), "CP1251" ) , ';' );
if( data != null && data.length > 0 )
{
final int rowCount = data.length;
for( int rowNum = 1; rowNum < rowCount; rowNum++ )
{
String[] fields = data[rowNum];
String contractTitle;
String manager;
contractTitle = fields[0];
manager = fields[1];
Contract contract = null;
int cid = 0;
try
{
contract = cm.getContractByTitle(contractTitle);
cid = contract.getId();
try
{
ListParamValue listValue = new ListParamValue();
listValue.setId(Utils.parseInt(manager));
listValue.setCustomValue("");
cpm.updateListParam(cid, paramId, listValue, User.USER_SERVER);
if(contract.isSuper() == true)
{
List<Contract> subContracts = cm.getSubContracts(cid);
for( Contract c : subContracts )
{
try
{
cpm.updateListParam(c.getId(), paramId, listValue, User.USER_SERVER);
}
catch (Exception e)
{
error( "Error in sub: cid = " + c.getId() + " format: " + e.toString());
}
}
}
}
catch (Exception e)
{
error( "Error: contract = " + contractTitle + " format: " + e.toString());
}
}
catch (Exception e)
{
error( "Not found contract " + contractTitle + " format: " + e.toString());
}
}
}
}
}
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.List;
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.Utils;
import ru.bitel.common.sql.ConnectionSet;
import bitel.billing.server.contract.bean.Contract;
import bitel.billing.server.contract.bean.ContractManager;
import bitel.billing.server.contract.bean.ContractParameterManager;
import ru.bitel.bgbilling.kernel.contract.param.common.bean.*;
import com.Ostermiller.util.ExcelCSVParser;
import com.mysql.jdbc.PreparedStatement;
public class loadManagers
extends GlobalScriptBase
{
int paramId = 27;
int userId = 13;
@Override
public void execute( Setup setup, ConnectionSet connectionSet )
throws Exception
{
print("Start");
Connection con = connectionSet.getConnection();
ContractParameterManager cpm = new ContractParameterManager( con );
long timeStart = System.currentTimeMillis();
// удаление всех установленных менеджеров
String query = "SELECT cid FROM contract_parameter_type_7 WHERE pid = ?";
java.sql.PreparedStatement ps = con.prepareStatement( query );
ps.setInt( 1, paramId );
ResultSet rs = ps.executeQuery();
int count = 0;
while ( rs.next() )
{
cpm.deleteListParam(rs.getInt( 1 ), paramId, User.USER_SERVER);
++count;
}
ps.close();
print( "Removed " + count + " values" );
// загружаем файлы
loadFile( "/opt/BG/manager_new.csv", setup, con, cpm );
long timeEnd = System.currentTimeMillis();
print( "Process time: " + (timeEnd - timeStart)/1000 + " s." );
}
private void loadFile( String filename, Setup setup, Connection con, ContractParameterManager cpm )
throws Exception
{
ContractManager cm = new ContractManager( con );
String[][] data = ExcelCSVParser.parse( new InputStreamReader( new FileInputStream( filename ), "CP1251" ) , ';' );
if( data != null && data.length > 0 )
{
final int rowCount = data.length;
for( int rowNum = 1; rowNum < rowCount; rowNum++ )
{
String[] fields = data[rowNum];
String contractTitle;
String manager;
contractTitle = fields[0];
manager = fields[1];
Contract contract = null;
int cid = 0;
try
{
contract = cm.getContractByTitle(contractTitle);
cid = contract.getId();
try
{
ListParamValue listValue = new ListParamValue();
listValue.setId(Utils.parseInt(manager));
listValue.setCustomValue("");
cpm.updateListParam(cid, paramId, listValue, User.USER_SERVER);
if(contract.isSuper() == true)
{
List<Contract> subContracts = cm.getSubContracts(cid);
for( Contract c : subContracts )
{
try
{
cpm.updateListParam(c.getId(), paramId, listValue, User.USER_SERVER);
}
catch (Exception e)
{
error( "Error in sub: cid = " + c.getId() + " format: " + e.toString());
}
}
}
}
catch (Exception e)
{
error( "Error: contract = " + contractTitle + " format: " + e.toString());
}
}
catch (Exception e)
{
error( "Not found contract " + contractTitle + " format: " + e.toString());
}
}
}
}
}
