не нужно по голове
В общем сил уже нет, вынесли все из цикла что увидели. мб Java гуру не вооружённым глазом определят где происходит утечка. Код прилагаю. Заранее спасибо.
Код:
import bitel.billing.server.admin.bean.*;
import bitel.billing.server.util.*;
import com.Ostermiller.util.*;
import java.util.*;
import bitel.billing.common.*;
import java.io.*;
import java.sql.*;
import bitel.billing.server.contract.bean.*;
import bitel.billing.server.contract.*;
import ru.bitel.common.*;
import java.math.*;
import java.util.regex.*;
import java.text.*;
int LOADED_GROUP = 7;
int PATTERN_ID = 7;
int PAYMENT_TYPE_ID = 1;
int CHARGE_TYPE_ID = 7;
int CITY_ID = 1;
int ADDRESS_PARAM_ID = 13;
int PHONE_PARAM_ID = 4;
int DATAZAKLUCH_PARAM_ID = 6;
int DATAPODKLUCH_PARAM_ID = 20;
int FIO_PARAM_ID = 2;
int DOC_PARAM_ID = 17;
int LGOTA_PARAM_ID = 19;
int PRIMECHANIE_PARAM_ID = 18;
int KREDIT_PARAM_ID = 25;
java.util.Date curdate = new java.util.Date();
java.util.Date beginmonth = new java.util.Date(curdate.getYear(),curdate.getMonth(),1);
Calendar now = new GregorianCalendar();
DecimalFormat format5 = new DecimalFormat( "00000" );
Map streetMap;
Map houseMap;
public void main( setup, con, conSlave )
{
long timeStart = System.currentTimeMillis();
loadFile( "C:/3.csv", setup, con, 11 );
long timeEnd = System.currentTimeMillis();
print( "Process time: " + (timeEnd - timeStart)/1000 + " s." );
}
private void loadFile( file, setup, con, patternId )
{
int rowNum = 0;
print( "Loading " + file );
String query;
ContractManager cm = new ContractManager( con );
ContractTariffManager ctm = new ContractTariffManager( con );
ContractParameterManager cpm = new ContractParameterManager( con );
PaymentManager paymentManager = new PaymentManager( con );
ChargeManager chargeManager = new ChargeManager( con );
BalanceUtils bu = new BalanceUtils( con );
query = "INSERT INTO contract_balance(yy, mm, cid, summa1) VALUES(?,?,?,?)";
PreparedStatement psInsertBalance = con.prepareStatement( query );
psInsertBalance.setInt( 1, now.get( Calendar.YEAR ) );
psInsertBalance.setInt( 2, now.get( Calendar.MONTH ) + 1 );
String[][] data = ExcelCSVParser.parse( new InputStreamReader( new FileInputStream( file ), "windows-1251" ) , ';' );
if( data != null && data.length > 0 )
{
final int rowCount = data.length;
if( streetMap == null )
{
streetMap = new HashMap();
query = "SELECT id, title FROM address_street WHERE cityid=1";
PreparedStatement ps = con.prepareStatement( query );
ResultSet rs = ps.executeQuery();
while( rs.next() )
{
streetMap.put( rs.getString( 2 ), rs.getInt( 1 ) );
//print( "Loaded street: " + rs.getString( 2 ) + " => " + rs.getString( 1 ) );
}
ps.close();
}
if( houseMap == null )
{
houseMap = new HashMap();
query = "SELECT streetid, house, frac, id FROM address_house";
PreparedStatement ps = con.prepareStatement( query );
ResultSet rs = ps.executeQuery();
while( rs.next() )
{
String key = rs.getString( 1 ) + "-" + rs.getString( 2 ) + rs.getString( 3 );
houseMap.put( key, rs.getInt( 4 ) );
//print( "Loaded house: " + key + " => " + id );
}
ps.close();
}
String licSchet;
String datazakluch;
String datapodkl;
String addressstreet;
String addresshome;
String addresskorp;
String addressroom;
String fio;
String dokument;
String phone;
String stoimostpodkl;
String lgota;
String tariff;
String primechanie;
String ostatokkredit;
BigDecimal saldo = BigDecimal.ZERO;
BigDecimal pay = BigDecimal.ZERO;
BigDecimal charge = BigDecimal.ZERO;
String pswd;
String title;
Integer streetId;
String houseKey;
Integer houseId;
Contract contract;
String[] fields;
//запускает цикл импортирования договоров
for( rowNum = 1; rowNum < rowCount; rowNum++ )
{
fields = new String[40];
fields = data[rowNum];
//print ("rowNum" + data[rowNum]);
if( fields.length < 9 ){error( "Incorrect line " + rowNum ); continue;}
if( rowNum % 100 == 0 ){System.out.println( "Count => " + rowNum );}
licSchet = fields[0];
datazakluch = fields[1];
datapodkl = fields[2];
addressstreet = fields[3];
addresshome = fields[4];
addresskorp = fields[5];
addressroom = fields[6];
fio = fields[7];
dokument = fields[10];
phone = fields[11];
stoimostpodkl = fields[12];
lgota = fields[13];
tariff = fields[14];
primechanie = fields[15];
ostatokkredit = fields[16];
saldo = BigDecimal.ZERO;
//print (addressstreet + addresshome + addresskorp + addressroom);
try
{
saldo = new BigDecimal( fields[17].replaceAll( " ", "0" ) );
//pay = new BigDecimal( fields[0].replaceAll( " ", "0" ) );
//charge = new BigDecimal( fields[0].replaceAll( " ", "0" ) );
}
catch( Exception ex )
{
error( "Error load summ file: " + file + "; line: " + rowNum + "; fio: " + fio );
}
//print( "FIO:" + fio + "; licChet: " + licSchet + "; tariff:" + tariff );
pswd = PswdGen.generatePassword( 5, "0123456789" );
title = "СКПТ-" + format5.format( Utils.parseLong( licSchet ) );
// создание договора
contract = cm.createFromPattern( patternId, title, TimeUtils.convertDateToCalendar( beginmonth ), pswd );
//Выбираем руппу
contract.setGroups( contract.getGroups() | (1L<<7) );
contract.setComment( fio );
cm.updateContract( contract );
streetId = streetMap.get( addressstreet );
if( streetId == null )
{
query = "INSERT INTO address_street(cityid, title) VALUES(?, ?)";
PreparedStatement ps = con.prepareStatement( query, PreparedStatement.RETURN_GENERATED_KEYS );
ps.setInt( 1, CITY_ID );
ps.setString( 2, addressstreet );
ps.executeUpdate();
streetId = ServerUtils.lastInsertId( ps );
streetMap.put( addressstreet, streetId );
ps.close();
}
houseKey = streetId + "-" + addresshome + addresskorp;
houseId = houseMap.get( houseKey );
if( houseId == null )
{
query = "INSERT INTO address_house(streetid, house, frac) VALUES(?,?,?)";
PreparedStatement ps = con.prepareStatement( query, PreparedStatement.RETURN_GENERATED_KEYS );
ps.setInt( 1, streetId );
ps.setString( 2, addresshome );
ps.setString( 3, addresskorp );
ps.executeUpdate();
houseId = ServerUtils.lastInsertId( ps );
houseMap.put( houseKey, houseId );
ps.close();
}
ContractAddressParamValue addressParam = new ContractAddressParamValue();
addressParam.setHouseId( houseId );
addressParam.setFlat( addressroom );
addressParam.setRoom( "" );
addressParam.setFloor( -1 );
addressParam.setPod( -1 );
addressParam.setAddress("ул. " + addressstreet + ", д. " + addresshome + ", кв. " + addressroom );
addressParam.setComment( "" );
cpm.setAddressParam( contract.getId(), ADDRESS_PARAM_ID, addressParam, User.USER_SERVER );
if( Utils.notBlankString( phone ) ){cpm.setStringParam( contract.getId(), PHONE_PARAM_ID, phone, User.USER_SERVER );}
if( Utils.notBlankString( dokument ) ){cpm.setStringParam( contract.getId(), DOC_PARAM_ID, dokument, User.USER_SERVER );}
if( Utils.notBlankString( lgota ) ){cpm.setStringParam( contract.getId(), LGOTA_PARAM_ID, lgota, User.USER_SERVER );}
// if( Utils.notBlankString( datazakluch ) ){cpm.setStringParam( contract.getId(), DATAZAKLUCH_PARAM_ID, datazakluch, User.USER_SERVER );}
if( Utils.notBlankString( datapodkl ) ){cpm.setStringParam( contract.getId(), DATAPODKLUCH_PARAM_ID, datapodkl, User.USER_SERVER );}
if( Utils.notBlankString( primechanie ) ){cpm.setStringParam( contract.getId(), PRIMECHANIE_PARAM_ID, primechanie, User.USER_SERVER );}
if( Utils.notBlankString( stoimostpodkl ) ){cpm.setStringParam( contract.getId(), KREDIT_PARAM_ID, " Стоимость подкл.:" + stoimostpodkl + "р." + " Остаток за кредит:" + ostatokkredit + "р.", User.USER_SERVER );}
// баланс
if( saldo.compareTo( BigDecimal.ZERO ) != 0 )
{
psInsertBalance.setInt( 3, contract.getId() );
psInsertBalance.setBigDecimal( 4, saldo );
psInsertBalance.executeUpdate();
}
cpm.setStringParam( contract.getId(), FIO_PARAM_ID, fio, User.USER_SERVER );
bu.updateBalance( curdate, contract.getId() );
// установка тарифа
ContractTariff contractTariff = new ContractTariff();
contractTariff.setContractID( contract.getID() );
switch(tariff)
{
case "200": contractTariff.setTariffPlanID( 168 ); break;
case "165": contractTariff.setTariffPlanID( 170 ); break;
case "250": contractTariff.setTariffPlanID( 171 ); break;
case "260": contractTariff.setTariffPlanID( 172 ); break;
case "45": contractTariff.setTariffPlanID( 173 ); break;
case "330": contractTariff.setTariffPlanID( 174 ); break;
case "84": contractTariff.setTariffPlanID( 175 ); break;
}
contractTariff.setComment( "" );
contractTariff.setDate1( TimeUtils.convertDateToCalendar( curdate ) );
ctm.updateContractTariff( contractTariff );
}
}
}
Вход
Регистрация
FAQ
Поиск
), писало
