Package org.bgerp.plugin.inventory.sync1c.service

Class ExportService

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.inventory.sync1c.service.ExportService

public class ExportService
extends CommonDAO

Service for managing the export queue and sending write-offs to 1C.

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, 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
ExportService(Connection con)

Method Summary

Modifier and Type	Method	Description
void	createWriteoffMovements(int processId)	Creates writeoff movements in ERP for all active reserves of the process.
void	enqueue(int processId)	Enqueues a write-off export for the given process.
String	sendExportQueue(ExportQueue q)	Sends a queued write-off export to 1C.

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

ExportService

public ExportService(Connection con)

Method Details

enqueue

public void enqueue(int processId)
             throws SQLException

Enqueues a write-off export for the given process. For each reserve movement in the process, looks up the engineer warehouse by store_id and adds an entry to the export queue. Duplicate (process_id, instance_id) entries are silently ignored. Does NOT commit — caller is responsible.

Throws:

SQLException

sendExportQueue

public String sendExportQueue(ExportQueue q)
                       throws SQLException

Sends a queued write-off export to 1C.

Parameters:

q - the queue entry to process

Returns:

null on success, error message on failure

Throws:

SQLException

createWriteoffMovements

public void createWriteoffMovements(int processId)
                             throws SQLException

Creates writeoff movements in ERP for all active reserves of the process. Called after successful export to 1C so the ERP balance reflects the physical write-off. Updates both quantity and reserved via the "writeoff" balance rule. Does NOT commit — caller is responsible.

Parameters:

processId - the process whose reserves were written off

Throws:

SQLException