Class OltOnuDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.bgb.getolt.dao.OltOnuDAO

public class OltOnuDAO
extends CommonDAO

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	OltOnuDAO.OnuMacEntry	ONU entry with MAC addresses and billing data presence flag.

Nested classes/interfaces inherited from class CommonDAO

CommonDAO.ObjectExtractor<T>, CommonDAO.RecordUpdater<T>

Field Summary

Fields inherited from class CommonDAO

con, log, SQL_AND, SQL_DELETE, SQL_DELETE_FROM, SQL_DESC, SQL_DISTINCT, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT_IGNORE_INTO, SQL_INSERT_INTO, SQL_LEFT_JOIN, SQL_LIMIT, SQL_ON_DUP_KEY_UPDATE, SQL_ORDER_BY, SQL_REPLACE, SQL_SELECT, SQL_SELECT_ALL_FROM, SQL_SELECT_COUNT_ROWS, SQL_SET, SQL_UNION_ALL, SQL_UPDATE, SQL_VALUES, SQL_VALUES_1, SQL_VALUES_2, SQL_VALUES_3, SQL_VALUES_4, SQL_VALUES_5, SQL_WHERE

Constructor Summary

Constructors

Constructor	Description
OltOnuDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
int	batchUpdateBillingData(Map<Integer,Object[]> updates)	Batch update billing data for matched ONUs.
int	countActiveByOltId(int oltId)
int	countByOltId(int oltId)
void	deleteByOltId(int oltId)
void	deleteByOltPortId(int oltPortId)
void	deleteStale(int oltId, int oltPortId, List<Integer> activeOnuNums)
List<OltOnuDAO.OnuMacEntry>	getAllMacEntries()	Get all ONU MAC entries for billing mapping.
List<OltOnu>	getByContract(String operator, int contractId, String numDogovor)
OltOnu	getByMac(String mac)
List<OltOnu>	getByOltId(int oltId)
List<OltOnu>	getByPortId(int oltPortId)
void	insertOrUpdate(OltOnu onu)
Set<Integer>	searchOltIds(String query)	Search ONU by mac, num_dogovor, abon_fio, abon_addr.

Methods inherited from class CommonDAO

deleteById, foundRows, getById, getGroupedIds, getGroupedIds, getIds, getIds, getPageLimit, getPeriodSql, lastInsertId, setPeriodParamValue, setRecordCount, update, updateColumn, updateIds, updateIds, updateOrInsert

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OltOnuDAO

public OltOnuDAO(Connection con)

Method Details

getByPortId

public List<OltOnu> getByPortId(int oltPortId)
                         throws SQLException

Throws:

SQLException

countByOltId

public int countByOltId(int oltId)
                 throws SQLException

Throws:

SQLException

countActiveByOltId

public int countActiveByOltId(int oltId)
                       throws SQLException

Throws:

SQLException

getByOltId

public List<OltOnu> getByOltId(int oltId)
                        throws SQLException

Throws:

SQLException

getByContract

public List<OltOnu> getByContract(String operator,
 int contractId,
 String numDogovor)
                           throws SQLException

Parameters:

operator - оператор ONU; пустой или null — искать по всем операторам (режим getolt:api.operator.filter=0)

contractId - id договора в биллинге, <= 0 — искать только по номеру

numDogovor - номер договора

Returns:

найденные ONU, свежие первыми

Throws:

SQLException

searchOltIds

public Set<Integer> searchOltIds(String query)
                          throws SQLException

Search ONU by mac, num_dogovor, abon_fio, abon_addr. Returns distinct OLT IDs containing matching ONUs.

Throws:

SQLException

getByMac

public OltOnu getByMac(String mac)
                throws SQLException

Throws:

SQLException

insertOrUpdate

public void insertOrUpdate(OltOnu onu)
                    throws SQLException

Throws:

SQLException

deleteByOltId

public void deleteByOltId(int oltId)
                   throws SQLException

Throws:

SQLException

deleteByOltPortId

public void deleteByOltPortId(int oltPortId)
                       throws SQLException

Throws:

SQLException

deleteStale

public void deleteStale(int oltId,
 int oltPortId,
 List<Integer> activeOnuNums)
                 throws SQLException

Throws:

SQLException

getAllMacEntries

public List<OltOnuDAO.OnuMacEntry> getAllMacEntries()
                                             throws SQLException

Get all ONU MAC entries for billing mapping. Returns id, mac, macTo, and whether billing data is already present.

Throws:

SQLException

batchUpdateBillingData

public int batchUpdateBillingData(Map<Integer,Object[]> updates)
                           throws SQLException

Batch update billing data for matched ONUs. Uses PreparedStatement.addBatch() for efficiency.

Parameters:

updates - map of ONU id → billing data array [operator, serviceId, contractId, numDogovor, login, abonFio, abonAddr]

Returns:

number of updated rows

Throws:

SQLException