commandfactory.java

关于 RFID 读写器的相关内容

				TagSelector[] tagSelectors = null;
				String[] passwords = null;
				
				if (params.length > 1) {
					passwords = params[1].getArray();
				}
				if (params.length > 2) {
					tagSelectors = toTagSelectorArray(params[2].getCollection());
				}
				
				return srcCommand.writeID(params[0].getString(), passwords, tagSelectors);
			}
			else if (command.equals("write")) {
				TagFieldValue[] tagFieldValues = null;
				TagSelector[] tagSelectors = null;
				String[] passwords = null;
				
				tagFieldValues = toTagFieldValueArray(params[0].getCollection());
				if (params.length > 1) {
					passwords = params[1].getArray();
				}
				if (params.length > 2) {
					tagSelectors = toTagSelectorArray(params[2].getCollection());
				}
				return srcCommand.write(tagFieldValues, passwords, tagSelectors);
			}
			else if (command.equals("kill")) {
				String[] passwords = null;
				TagSelector[] selectors = null;
				if (params.length > 0) {
					passwords = params[0].getArray();
				}
				if (params.length > 1) {
					selectors = toTagSelectorArray(params[1].getCollection());
				}
				return srcCommand.kill(passwords, selectors);
			}
			else if (command.equals("getReadCyclesPerTrigger")) {
				return srcCommand.getReadCyclesPerTrigger();
			}
			else if (command.equals("getMaxReadDutyCycle")) {
				return srcCommand.getMaxReadDutyCycles();
			}
			else if (command.equals("setReadCyclesPerTrigger")) {
				return srcCommand.setReadCyclesPerTrigger(params[0].getInt());
			}
			else if (command.equals("setMaxReadDutyCycle")) {
				return srcCommand.setMaxReadDutyCycles(params[0].getInt());
			}
			else if (command.equals("setReadTimeout")) {
				return srcCommand.setReadTimeout(params[0].getInt());
			}
			else if (command.equals("getReadTimeout")) {
				return srcCommand.getReadTimeout();
			}
			else if (command.equals("getSession")) {
				return srcCommand.getSession();
			}
			else if (command.equals("setSession")) {
				return srcCommand.setSession(params[0].getInt());
			}			
		}
		else if (object.equals("ReadPoint")) {
			ReadPointSerializer rpCommand = new ReadPointSerializerImpl(getNextId(), target);
			if (command.equals("getName")) {
				return rpCommand.getName();
			}
			
		}
		else if (object.equals("TagSelector")) {
			TagSelectorSerializer tsCommand = new TagSelectorSerializerImpl(getNextId(), target);
			if (command.equals("create")) {
				try {
					TagField tf = TagField.create(params[1].getString());
					return tsCommand.create(params[0].getString(), tf, params[2].getString(), params[3].getString(), params[4].getBoolean());
				} catch (Exception e) {}
			}
			else if (command.equals("getName")) {
				return tsCommand.getName();
			}
			else if (command.equals("getMaxNumberSupported")) {
				return tsCommand.getMaxNumberSupported();
			}
			else if (command.equals("getTagField")) {
				return tsCommand.getTagField();
			}
			else if (command.equals("getValue")) {
				return tsCommand.getValue();
			}
			else if (command.equals("getMask")) {
				return tsCommand.getMask();
			}
			else if (command.equals("getInclusiveFlag")) {
				return tsCommand.getInclusiveFlag();
			}
		}
		else if (object.equals("DataSelector")) {
			DataSelectorSerializer dsCommand = new DataSelectorSerializerImpl(getNextId(), target);
			if (command.equals("create")) {
				return dsCommand.create(params[0].getString());
			}
			else if (command.equals("getName")) {
				return dsCommand.getName();
			}
			else if (command.equals("addFieldNames")) {
				return dsCommand.addFieldNames(params[0].getArray());
			}
			else if (command.equals("removeFieldNames")) {
				return dsCommand.removeFieldNames(params[0].getArray());
			}
			else if (command.equals("removeAllFieldNames")) {
				return dsCommand.removeAllFieldNames();
			}
			else if (command.equals("getAllFieldNames")) {
				return dsCommand.getAllFieldNames();
			}
			else if (command.equals("addEventFilters")) {
				return dsCommand.addEventFilters(params[0].getArray());
			}
			else if (command.equals("removeEventFilters")) {
				return dsCommand.removeEventFilters(params[0].getArray());
			}
			else if (command.equals("removeAllEventFilters")) {
				return dsCommand.removeAllEventFilters();
			}
			else if (command.equals("getAllEventFilters")) {
				return dsCommand.getAllEventFilters();
			}
			else if (command.equals("addTagFieldNames")) {
				return dsCommand.addTagFieldNames(params[0].getArray());
			}
			else if (command.equals("removeTagFieldNames")) {
				return dsCommand.removeTagFieldNames(params[0].getArray());
			}
			else if (command.equals("removeAllTagFieldNames")) {
				return dsCommand.removeAllTagFieldNames();
			}
			else if (command.equals("getAllTagFieldNames")) {
				return dsCommand.getAllTagFieldNames();
			}
		}
		else if (object.equals("NotificationChannel")) {
			NotificationChannelSerializer ncCommand = new NotificationChannelSerializerImpl(getNextId(), target);
			if (command.equals("create")) {
				return ncCommand.create(params[0].getString(), params[1].getString());
			}
			else if (command.equals("getName")) {
				return ncCommand.getName();
			}
			else if (command.equals("getAddress")) {
				return ncCommand.getAddress();
			}
			else if (command.equals("getEffectiveAddress")) {
				return ncCommand.getEffectiveAddress();
			}
			else if (command.equals("setAddress")) {
				return ncCommand.setAddress(params[0].getString());
			}
			else if (command.equals("getDataSelector")) {
				return ncCommand.getDataSelector();
			}
			else if (command.equals("setDataSelector")) {
				try {
					DataSelector ds = DataSelector.create(params[0].getString());
					return ncCommand.setDataSelector(ds);
				} catch (Exception e) {}
			}
			else if (command.equals("addSources")) {
				Source[] srcs = toSourceArray(params[0].getCollection());
				return ncCommand.addSources(srcs);
			}
			else if (command.equals("removeSources")) {
				Source[] srcs = toSourceArray(params[0].getCollection());
				return ncCommand.removeSources(srcs);
			}
			else if (command.equals("getAllSources")) {
				return ncCommand.getAllSources();
			}
			else if (command.equals("addNotificationTriggers")) {
				Trigger[] trgs = toTriggerArray(params[0].getCollection());
				return ncCommand.addNotificationTriggers(trgs);
			}
			else if (command.equals("removeNotificationTriggers")) {
				Trigger[] trgs = toTriggerArray(params[0].getCollection());
				return ncCommand.removeNotificationTriggers(trgs);
			}
			else if (command.equals("removeAllNotificationTriggers")) {
				return ncCommand.removeAllNotificationTriggers();
			}
			else if (command.equals("getNotificationTrigger")) {
				return ncCommand.getNotificationTrigger(params[0].getString());
			}
			else if (command.equals("getAllNotificationTriggers")) {
				return ncCommand.getAllNotificationTriggers();
			}
			else if (command.equals("readQueuedData")) {
				NotificationChannelCommand.ReadQueuedData rq = cmdFactory.createNotificationChannelCommandReadQueuedData();
				if (params.length > 0) {
					return ncCommand.readQueuedData(params[0].getBoolean());
				} else {
					return ncCommand.readQueuedData();
				}
			}
		}
		else if (object.equals("Trigger")) {
			TriggerSerializer trgCommand = new TriggerSerializerImpl(getNextId(),target);
			if (command.equals("create")) {
				return trgCommand.create(params[0].getString(),params[1].getString(),params[2].getString());
			}
			else if (command.equals("getMaxNumberSupported")) {
				return trgCommand.getMaxNumberSupported();
			}
			else if (command.equals("getName")) {
				return trgCommand.getName();
			}
			else if (command.equals("getType")) {
				return trgCommand.getType();
			}
			else if (command.equals("getValue")) {
				return trgCommand.getValue();
			}
			else if (command.equals("fire")) {
				return trgCommand.fire();
			}
		
		}
		else if (object.equals("EventType")) {
			EventTypeSerializer evCommand = new EventTypeSerializerImpl(getNextId(), target);
			if (command.equals("getSupportedTypes")) {
				return evCommand.getSupportedTypes();
			}
		}
		else if (object.equals("TriggerType")) {
			TriggerTypeSerializer ttCommand = new TriggerTypeSerializerImpl(getNextId(), target);
			if (command.equals("getSupportedTypes")) {
				return ttCommand.getSupportedTypes();
			}
			
			
		}
		else if (object.equals("FieldName")) {
			FieldNameSerializer fnCommand = new FieldNameSerializerImpl(getNextId(), target);
			if (command.equals("getSupportedNames")) {
				return fnCommand.getSupportedNames();
			}
			
		}
		else if (object.equals("TagField")) {
			TagFieldSerializer tfCommand = new TagFieldSerializerImpl(getNextId(), target);
			if (command.equals("create")) {
				return tfCommand.create(params[0].getString());
			}
			else if (command.equals("getName")) {
				return tfCommand.getName();
			}
			else if (command.equals("getTagFieldName")) {
				return tfCommand.getTagFieldName();
			}
			else if (command.equals("setTagFieldName")) {
				return tfCommand.setTagFieldName(params[0].getString());
			}
			else if (command.equals("getMemoryBank")) {
				return tfCommand.getMemoryBank();
			}
			else if (command.equals("setMemoryBank")) {
				return tfCommand.setMemoryBank(params[0].getInt());
			}
			else if (command.equals("getOffset")) {
				return tfCommand.getOffset();
			}
			else if (command.equals("setOffset")) {
				return tfCommand.setOffset(params[0].getInt());
			}
			else if (command.equals("getLength")) {
				return tfCommand.getLength();
			}
			else if (command.equals("setLength")) {
				return tfCommand.setLength(params[0].getInt());
			}
			
		}
		else if (object.equals("IOPorts")) {
			
		}
		
		String xmlCommand = serializeCommand(cmd);
		return xmlCommand;
		
	}
	
	/**
	 * This method creates text commands
	 * 
	 * @param object the type of the object on which the method should be executed
	 * @param command which should be executed
	 * @param params parameters which belongs to the command
	 * @param target the name of the object on which the method should be executed
	 * @return the command in text format as string
	 * @throws ParameterTypeException if the parameters are illegal
	 */
	public static String getTextCommand(String object, String command, Parameter[] params, String target) throws ParameterTypeException {
		
		ObjectFactory cmdFactory = new ObjectFactory();
		Command cmd = cmdFactory.createCommand();
		cmd.setId(Integer.toString(getNextId()));
		if (!target.equals("")) {
			cmd.setTargetName(target);
		}
		if (object.equals("ReaderDevice")) {
			ReaderDeviceSerializer rdCommand = new org.fosstrak.reader.rp.proxy.msg.stubs.serializers.text.ReaderDeviceSerializerImpl(getNextId(), target);
			if (command.equals("getEPC")) {
				return rdCommand.getEPC();
			}
			else if (command.equals("getManufacturer")) {
				return rdCommand.getManufacturer();
			}
			else if (command.equals("getModel")) {
				return rdCommand.getModel();
			}
			else if (command.equals("getHandle")) {
				return rdCommand.getHandle();
			}
			else if (command.equals("setHandle")) {
				return rdCommand.setHandle(params[0].getInt());
			}
			
			else if (command.equals("getName")) {
				return rdCommand.getName();
			}
			else if (command.equals("setName")) {
				return rdCommand.setName(params[0].getString());
			}
			else if (command.equals("getRole")) {
				return rdCommand.getRole();
			}
			else if (command.equals("setRole")) {
				return rdCommand.setRole(params[0].getString());
			}
			else if (command.equals("getTimeTicks")) {
				return rdCommand.getTimeTicks();
			}
			else if (command.equals("getTimeUTC")) {
				return rdCommand.getTimeUTC();
			}
			else if (command.equals("setTimeUTC")) {
				return rdCommand.setTimeUTC(Calendar.getInstance().getTime()); 
			}
			else if (command.equals("getManufacturerDescription")) {
				return rdCommand.getManufacturerDescription();
			}
			else if (command.equals("getCurrentSource")) {
				return rdCommand.getCurrentSource();
			}
			else if (command.equals("setCurrentSource")) {
				Source src;
				try {
					src = Source.create(params[0].getString());
					return rdCommand.setCurrentSource(src);
				} catch (ReaderProtocolException e) {
					e.printStackTrace();
					return null;
				} 
				
			}
			else if (command.equals("getCurrentDataSelector")) {
				return rdCommand.getCurrentDataSelector();
			}
			else if (command.equals("setCurrentDataSelector")) {
				DataSelector ds;
				try {
					ds = DataSelector.create(params[0].getString());
					return rdCommand.setCurrentDataSelector(ds);
				} catch (ReaderProtocolException e) {
					e.printStackTrace();
					return null;
				}					
			}
			else if (command.equals("removeSources")) {
				Source[] sources = toSourceArray(params[0].getCollection());
				return rdCommand.removeSources(sources);
			}