/* ====================================================================
|
Licensed to the Apache Software Foundation (ASF) Under one or more
|
contributor license agreements. See the NOTICE file distributed with
|
this work for Additional information regarding copyright ownership.
|
The ASF licenses this file to You Under the Apache License, Version 2.0
|
(the "License"); you may not use this file except in compliance with
|
the License. You may obtain a copy of the License at
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
Unless required by applicable law or agreed to in writing, software
|
distributed Under the License is distributed on an "AS Is" BASIS,
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
See the License for the specific language governing permissions and
|
limitations Under the License.
|
==================================================================== */
|
|
namespace HH.WMS.Utils.NPOI.HSSF.EventModel
|
{
|
using System;
|
using System.IO;
|
using System.Collections;
|
using HH.WMS.Utils.NPOI.HSSF.Record;
|
using System.Reflection;
|
using System.Text;
|
|
|
/**
|
* Event-based record factory. As opposed to RecordFactory
|
* this refactored version throws record events as it comes
|
* accross the records. I throws the "lazily" one record behind
|
* to ensure that ContinueRecords are Processed first.
|
*
|
* @author Andrew C. Oliver (acoliver@apache.org) - probably to blame for the bugs (so yank his chain on the list)
|
* @author Marc Johnson (mjohnson at apache dot org) - methods taken from RecordFactory
|
* @author Glen Stampoultzis (glens at apache.org) - methods taken from RecordFactory
|
* @author Csaba Nagy (ncsaba at yahoo dot com)
|
*/
|
public class EventRecordFactory
|
{
|
|
private ERFListener _listener;
|
private ArrayList _sids;
|
|
/**
|
* Create an EventRecordFactory
|
* @param abortable specifies whether the return from the listener
|
* handler functions are obeyed. False means they are ignored. True
|
* means the event loop exits on error.
|
*/
|
public EventRecordFactory(ERFListener listener, ArrayList sids)
|
{
|
_listener = listener;
|
_sids = sids;
|
|
if (_sids == null)
|
{
|
_sids = null;
|
}
|
else
|
{
|
if (_sids == null)
|
_sids = new ArrayList();
|
_sids.Sort(); // for faster binary search
|
}
|
}
|
private bool IsSidIncluded(int sid)
|
{
|
if (_sids == null)
|
{
|
return true;
|
}
|
return _sids.BinarySearch((short)sid) >= 0;
|
}
|
/**
|
* sends the record event to all registered listeners.
|
* @param record the record to be thrown.
|
* @return <c>false</c> to abort. This aborts
|
* out of the event loop should the listener return false
|
*/
|
private bool ProcessRecord(Record record)
|
{
|
if (!IsSidIncluded(record.Sid))
|
{
|
return true;
|
}
|
return _listener.ProcessRecord(record);
|
}
|
/**
|
* Create an array of records from an input stream
|
*
|
* @param in the InputStream from which the records will be
|
* obtained
|
*
|
* @exception RecordFormatException on error Processing the
|
* InputStream
|
*/
|
public void ProcessRecords(Stream in1)
|
{
|
Record last_record = null;
|
|
RecordInputStream recStream = new RecordInputStream(in1);
|
|
while (recStream.HasNextRecord) {
|
recStream.NextRecord();
|
Record[] recs = RecordFactory.CreateRecord(recStream); // handle MulRK records
|
if (recs.Length > 1) {
|
for (int k = 0; k < recs.Length; k++) {
|
if ( last_record != null ) {
|
if (!ProcessRecord(last_record)) {
|
return;
|
}
|
}
|
last_record = recs[ k ]; // do to keep the algorithm homogeneous...you can't
|
} // actually continue a number record anyhow.
|
} else {
|
Record record = recs[ 0 ];
|
|
if (record != null) {
|
if (last_record != null) {
|
if (!ProcessRecord(last_record)) {
|
return;
|
}
|
}
|
last_record = record;
|
}
|
}
|
}
|
|
if (last_record != null) {
|
ProcessRecord(last_record);
|
}
|
}
|
}
|
}
|
