Package org.bgerp.plugin.inventory.dao

Class MovementDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.inventory.dao.MovementDAO

public class MovementDAO
extends CommonDAO

DAO for stock Movement records and inventory_balance. Movements are append-only — never updated or deleted. Balance is maintained via INSERT ... ON DUPLICATE KEY UPDATE.

Nested Class Summary

Nested classes/interfaces inherited from class ru.bgcrm.dao.CommonDAO

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

Field Summary

Fields inherited from class ru.bgcrm.dao.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
MovementDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
void	append(Movement m)	Appends a movement record and updates the balance accordingly.
static Movement	fromRs(ResultSet rs)
List<Map<String,Object>>	getBalanceItems(Collection<Integer> storeIds)	Returns balance data for given store IDs as a flat list of maps.
List<Map<String,Object>>	getBalanceList(int storeId)	Returns balance for a store as list of maps with keys: itemTitle, quantity, reserved.
Movement	getById(long id)
List<Movement>	getListByProcess(int processId)
List<Movement>	getListByStore(int storeId, int limit)

Methods inherited from class ru.bgcrm.dao.CommonDAO

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

Methods inherited from class java.lang.Object

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

Constructor Details

MovementDAO

public MovementDAO(Connection con)

Method Details

getById

public Movement getById(long id)
                 throws SQLException

Throws:

SQLException

getListByStore

public List<Movement> getListByStore(int storeId,
 int limit)
                              throws SQLException

Throws:

SQLException

getListByProcess

public List<Movement> getListByProcess(int processId)
                                throws SQLException

Throws:

SQLException

append

public void append(Movement m)
            throws SQLException

Appends a movement record and updates the balance accordingly. For "reserve" adds to reserved; for "unreserve"/"writeoff"/"return" adjusts reserved/quantity.

Parameters:

m - movement to record

Throws:

IllegalStateException - if the operation would make balance negative

SQLException

getBalanceItems

public List<Map<String,Object>> getBalanceItems(Collection<Integer> storeIds)
                                         throws SQLException

Returns balance data for given store IDs as a flat list of maps. Each map has keys: storeId, itemId, quantity, reserved. Used for JS-driven balance hints in the process materials tab.

Throws:

SQLException

getBalanceList

public List<Map<String,Object>> getBalanceList(int storeId)
                                        throws SQLException

Returns balance for a store as list of maps with keys: itemTitle, quantity, reserved. Ordered by item title. Only rows with quantity > 0 or reserved > 0.

Throws:

SQLException

fromRs

public static Movement fromRs(ResultSet rs)
                       throws SQLException

Throws:

SQLException