sscc.java

一个开源的rfid middleware 资料

package com.refactored_networks.epc.epcnetwork;
/**
 * Copyright 2005 Refactored Networks, LLC

   Licensed 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.

 */
import java.util.BitSet;
import java.util.Properties;
import java.util.StringTokenizer;

public class SSCC extends EPC {
	protected String sManagerId;
	protected String sSerialReference;
	protected BitSet bits;
	protected String sFilter;
	
	private ParseUtils utils = new ParseUtils();
	
	public SSCC(BitSet inEPC, Properties iConfig) throws EPCParseException {
		super(inEPC, iConfig);
		if(inEPC.length() == 64) {
			parse64bit(ParseUtils.BitsToBytes(inEPC));
		} else if(inEPC.length() == 96) {
			parse96bit(ParseUtils.BitsToBytes(inEPC));
		}
	}
	
	
	/**
	 * @param inEPC
	 * @param flags
	 * @param iConfig
	 * @throws EPCParseException
	 */
	public SSCC(String inEPC, int flags, Properties iConfig) throws EPCParseException {
		super(inEPC, flags, iConfig);
		if((flags & EPC.CANONICAL) != 0) {
			parseCanonical(inEPC);
		} else if((flags & EPC.NINETYSIXBIT) != 0) {
			if((flags & EPC.BINARY) != 0) {
				parse96bit(utils.BinaryStringToByteArray(inEPC));
			} else if((flags & EPC.DECIMAL) !=0 ) {
				parse96bit(utils.DecimalStringToByteArray(inEPC));
			} else if((flags & EPC.HEX) != 0) {
				parse96bit(utils.HexStringToByteArray(inEPC));
			} else throw new EPCParseException("Unable to interpret flags in a meaningful way:" + flags);
		} else if((flags & EPC.SIXTYFOURBIT) != 0) {
			if((flags & EPC.BINARY) != 0) {
				parse64bit(utils.BinaryStringToByteArray(inEPC));
			} else if((flags & EPC.DECIMAL) !=0 ) {
				parse64bit(utils.DecimalStringToByteArray(inEPC));
			} else if((flags & EPC.HEX) != 0) {
				parse64bit(utils.HexStringToByteArray(inEPC));
			} else throw new EPCParseException("Unable to interpret flags in a meaningful way:" + flags);
		}
	}

	
	public SSCC(byte[] inEPC,Properties config) throws EPCParseException {
		super(inEPC,config);

		switch((inEPC[0] & 0xFF)) {
                        case 8: parse64bit(inEPC);
                                 break;
                        case 49: parse96bit(inEPC);
                                 break;
                        default:
                                throw new EPCParseException("Binary EPC's header does not correspond to an SSCC");
                }
	}

	private void parse64bit(byte[] inEPC) throws EPCParseException {
		bits = new BitSet(((inEPC.length)*8)+1);
		bits.set(0);
		int j=0;
        	for (int i=((inEPC.length)*8)-1;i>=0; i--) {
			if(((inEPC[(inEPC.length-1) - (j/8)])&(1<<(j%8))) > 0) {
				bits.set(i+1);
			} else {
				bits.set(i+1,false);
			}
			j++;
        	}

		long lHeader = ParseUtils.BitsToInt(bits.get(1,9),8);
		long lFilter = ParseUtils.BitsToInt(bits.get(9,12),3);
		long lIndex = ParseUtils.BitsToInt(bits.get(12,26),14);
		try {
			CompanyPrefixIndexDB indexDB = new CompanyPrefixIndexDB(config);
			sManagerId = indexDB.Lookup(Long.toString(lIndex));
		} catch(NoSuchIndexException noindex) {
			throw new EPCParseException("The index value was not found in " + config.getProperty("method"));
		} catch(Exception e) {
			throw new EPCParseException(e.getMessage());
		}
		sSerialReference = utils.ZeroPad(Long.toString(ParseUtils.BitsToInt(bits.get(26,65),39)),17-sManagerId.length());

	}


	private void parse96bit(byte[] inEPC) throws EPCParseException {
		bits = new BitSet(((inEPC.length)*8)+1);
		bits.set(0);
		int j=0;
        	for (int i=((inEPC.length)*8)-1;i>=0; i--) {
			if(((inEPC[(inEPC.length-1) - (j/8)])&(1<<(j%8))) > 0) {
				bits.set(i+1);
			} else {
				bits.set(i+1,false);
			}
			j++;
        	}

		long lHeader = ParseUtils.BitsToInt(bits.get(1,9),8);
		long lFilter = ParseUtils.BitsToInt(bits.get(9,12),3);
		sFilter = Long.toString(lFilter);
		long lPartition = ParseUtils.BitsToInt(bits.get(12,15),3);

		switch((int) lPartition) {
			case 0:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,55),40)),12);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(55,73),17)),5);
				break;
			case 1:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,52),37)),11);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(52,73),20)),6);
				break;
			case 2:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,49),34)),10);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(49,73),24)),7);
				break;
			case 3:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,45),30)),9);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(45,73),27)),8);
				break;
			case 4:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,42),27)),8);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(42,73),30)),9);
				break;
			case 5:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,39),24)), 7);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(39,73),34)),10);
				break;
			case 6:
				sManagerId = utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(15,35),20)),6);
				sSerialReference =utils.ZeroPad(
				   Long.toString(ParseUtils.BitsToInt(bits.get(35,73),37)),11);
				break;
		       default: 
				throw new EPCParseException("partition value invalid (" + lPartition + ")");
		}
	}

	

	public void parseCanonical(String inEPC) throws EPCParseException {
		// The parser
		StringTokenizer st = new StringTokenizer(inEPC, ":.");

		// Is there anything to parse?
		if(!st.hasMoreTokens()) {
			throw new EPCParseException("Parse error. Not enough parse tokens.");
		}
		// If this isn't a URN, then throw an exception
		String sURN = st.nextToken();
		if(!sURN.equalsIgnoreCase("urn")) {
			throw new EPCParseException("Not a URN. Scheme is " + sURN);
		}

		// Are there more tokens?
		if(!st.hasMoreTokens()) {
			throw new EPCParseException("Parse error. Not enough parse tokens.");
		}

		// Is this an EPC? If not, then throw an exception
		String sNID = st.nextToken();
		if(!sNID.equalsIgnoreCase("epc")) {
			throw new EPCParseException("Not an EPC. NID is " + sNID);
		}

		// Anything left?
		if(!st.hasMoreTokens()) {
			throw new EPCParseException("Parse error. Not enough parse tokens.");
		}

		// Is this an 'id' type of an EPC? If not, throw an exception
		// We'll add the other types later....
		String sEPCType = st.nextToken();
		if(!sEPCType.equalsIgnoreCase("id")) {
			throw new EPCParseException("Not a pure identify form of an EPC. Type is " + sEPCType);
		}

		// Anything left?
		if(!st.hasMoreTokens()) {
			throw new EPCParseException("Parse error. Not enough parse tokens.");
		}

		// Finally! Is this a valid EPC type? If so, then save
		// that and end since any further parsing is handled by
		// the subclass.
		String sIdType = st.nextToken();
		if(!sIdType.equalsIgnoreCase("sscc")) {
			throw new EPCParseException("Not an SSCC. Type is " + sIdType);
		}
		sManagerId = st.nextToken();
		if(sManagerId == null) {
			throw new EPCParseException("No manager id found");
		}
		sSerialReference = st.nextToken();
		if(sSerialReference == null) {
			throw new EPCParseException("No product id found");
		}
	}

	public String getSubNamespaceName() {
		return("sscc");
	}

	public String getCanonicalEncoding() {
		return("urn:epc:id:sscc:" + sManagerId + "." + sSerialReference);
	}
	public String getONSEncoding() {
		return(sSerialReference + "." + sManagerId + ".sscc.id.");
	}

	public BitSet getBinaryEncodingBitSet(int flags) throws EPCParseException {
		if((flags & EPC.NINETYSIXBIT) != 0) {
			return(build96bit());
		} else if((flags & EPC.SIXTYFOURBIT) != 0 ) {
			return(build64bit());
		}
		return(null);
	}
	
	private BitSet build64bit() throws EPCParseException {
		BitSet mybits = new BitSet(64);
		String sIndex;
		mybits.set(0);
		mybits.set(1);
		
		String bsFilter = utils.ZeroPad(Integer.toString(Integer.parseInt(sFilter),2),3);
		for(int i=0;i<bsFilter.length();i++) 
			if(bsFilter.charAt(i) == '1') {
				mybits.set(i+3);
			} else {
				mybits.set(i+3,false);
			}
		try {
			CompanyPrefixIndexDB indexDB = new CompanyPrefixIndexDB(config);
			sIndex = indexDB.ReverseLookup(sManagerId);
		} catch(NoSuchIndexException noindex) {
			throw new EPCParseException("The index value was not found in " + config.getProperty("method"));
		} catch(Exception e) {
			throw new EPCParseException(e.getMessage());
		}
		
		String bsIndex = utils.ZeroPad(Integer.toString(Integer.parseInt(sIndex),2),14);
		for(int i=0;i<bsIndex.length();i++) 
			if(bsIndex.charAt(i) == '1') 
				mybits.set(i+6);
			else 
				mybits.set(i+6,false);
		String bsSerialReference = utils.ZeroPad(Integer.toString(Integer.parseInt(sSerialReference),2),20);
		for(int i=0;i<bsSerialReference.length();i++) 
			if(bsSerialReference.charAt(i) == '1') 
				mybits.set(i+6);
			else 
				mybits.set(i+6,false);
		return(mybits);
	}


	private BitSet build96bit() throws EPCParseException {
		BitSet mybits = new BitSet(64);
		mybits.set(0);
		mybits.set(3);
		mybits.set(4);
		mybits.set(8);
		String bsFilter = utils.ZeroPad(Integer.toString(Integer.parseInt(sFilter),2),3);
		for(int i=0;i<bsFilter.length();i++) 
			if(bsFilter.charAt(i) == '1') {
				mybits.set(i+9);
			} else {
				mybits.set(i+9,false);
			}
		
		String bsPartition;
		String bsManagerId;
		String bsSerialReference;
		String bsSerialNum;
		
		switch(sManagerId.length()) {
		case 6:
			bsPartition = utils.ZeroPad(Integer.toString(6,2),3);
			for(int i=0;i<bsPartition.length();i++) 
				if(bsPartition.charAt(i) == '1') {
					mybits.set(i+12);
				} else {
					mybits.set(i+12,false);
				}
			bsManagerId = utils.ZeroPad(Integer.toString(Integer.parseInt(sManagerId),2),20);
			for(int i=0;i<bsManagerId.length();i++) {
				if(bsManagerId.charAt(i) == '1') 
					mybits.set(15+i);
				else 
					mybits.set(15+i,false);
			}
			 bsSerialReference = utils.ZeroPad(Integer.toString(Integer.parseInt(sSerialReference),2),38);
			for(int i=0;i<bsSerialReference.length();i++) {
				if(bsSerialReference.charAt(i) == '1') 
					mybits.set(35+i);
				else 
					mybits.set(35+i,false);
			}
			 
			break;
		case 7:
			bsPartition = utils.ZeroPad(Integer.toString(5,2),3);
			for(int i=0;i<bsPartition.length();i++) 
				if(bsPartition.charAt(i) == '1') {
					mybits.set(i+12);
				} else {
					mybits.set(i+12,false);
				}
			 bsManagerId = utils.ZeroPad(Integer.toString(Integer.parseInt(sManagerId),2),24);
			for(int i=0;i<bsManagerId.length();i++) {
				if(bsManagerId.charAt(i) == '1') 
					mybits.set(15+i);
				else 
					mybits.set(15+i,false);
			}
			 bsSerialReference = utils.ZeroPad(Integer.toString(Integer.parseInt(sSerialReference),2),34);
			for(int i=0;i<bsSerialReference.length();i++) {
				if(bsSerialReference.charAt(i) == '1') 
					mybits.set(39+i);
				else 
					mybits.set(39+i,false);
			}
			break;
		case 8:
			bsPartition = utils.ZeroPad(Integer.toString(6,2),3);
			for(int i=0;i<bsPartition.length();i++) 
				if(bsPartition.charAt(i) == '1') {
					mybits.set(i+12);
				} else {
					mybits.set(i+12,false);
				}
			 bsManagerId = utils.ZeroPad(Integer.toString(Integer.parseInt(sManagerId),2),27);
			for(int i=0;i<bsManagerId.length();i++) {
				if(bsManagerId.charAt(i) == '1')