import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Main logic for parsing the groups from the JSON file. Also does validation of the groups attributes.
 * @param groups JSONArray object that contains the groups parsed from the JSON file.
 * @param groupType the type of the groups in the JSONArray Object.
 * @return An ArrayList of Group Objects that contain the parsed information.
 * @throws JSONException
 * @throws AdeUsageException
 */
private List<Group> parseGroups(JSONArray groups, String groupType) throws JSONException, AdeUsageException{
    if (groups.length() == 0) throw new AdeUsageException("No groups specified for group of type " + groupType);
    List<Group> currentGroups = new ArrayList<Group>();
    for (int i = 0; i < groups.length(); i++){
        JSONObject group = groups.getJSONObject(i);
        String name = group.getString("name");
        String dataType = group.getString("dataType");
        short evalOrder = group.getShort("evaluationOrder");
        String ruleName = group.getString("ruleName");
     
        if (!verifyStringParam(name, 200, "[a-zA-Z0-9_ ]*") || name.equalsIgnoreCase("unassigned")
                || !validateDataType(dataType) || evalOrder < 1 || !verifyStringParam(ruleName, 200, "[a-zA-Z0-9_ ]*")){
            throw new AdeUsageException("Invalid parameters for a group of type " + groupType + " was specified");
        }
        currentGroups.add(new Group(name, GroupType.valueOf(groupType), DataType.valueOf(dataType.toUpperCase()), evalOrder, ruleName));
    }
    
    validateEvaluationOrderAndName(currentGroups);
    
    return currentGroups;        
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Main logic for parsing the rules from the JSON file. Also does validation of the rules attributes.
 * @param groups JSONArray object that contains the groups parsed from the JSON file.
 * @param rules JSONArray object that contains the rules parsed from the JSON file.
 * @return An ArrayList of Rule Objects that contain the parsed information.
 * @throws AdeUsageException
 * @throws JSONException
 */
private List<Rule> parseRules(JSONArray rules) throws AdeUsageException, JSONException{
    if (rules.length() == 0) throw new AdeUsageException("No rules specified");
    List<Rule> currentRules = new ArrayList<Rule>();
    for (int i = 0; i < rules.length(); i++){
        JSONObject rule = rules.getJSONObject(i);
        String name = rule.getString("name");
        String description = rule.getString("description");
        String membershipRule = rule.getString("membershipRule");
        
        if (!verifyStringParam(name, 200, "[a-zA-Z0-9_ ]*") || (description != null && description.length() > 1000)
                || name.equalsIgnoreCase("unassigned_rule") || !verifyStringParam(membershipRule,256,"[a-zA-Z0-9.:?/*-]*")){
            throw new AdeUsageException("Invalid parameters for rules was specified");
        }
        
        currentRules.add(new Rule(name, membershipRule, description));
        
        validateRuleNames(currentRules);
    }
    return currentRules;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
private LocalizationInput toResetLocalizationInput(JSONObject source) throws JSONException {
	String uuid = source.getString("uuid");
	LocalizationInput locInput = new LocalizationInput();
	locInput.setUuid(uuid).setUpdateMode(UpdateMode.reset);
	try{
		if(!source.isNull("xtrue") && !source.isNull("ytrue") && !source.isNull("ztrue")){
			double xtrue = source.getDouble("xtrue");
			double ytrue = source.getDouble("ytrue");
			double ztrue = source.getDouble("ztrue");
			locInput.setInitialLocation(xtrue, ytrue, ztrue);
		}
		if(!source.isNull("theta")){
			double theta = source.getDouble("theta");
			locInput.setInitialOrientation(theta);
		}
	} catch(JSONException e){
		e.printStackTrace();
	}
	return locInput;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public static int[] parseJsonObjectIDList(JSONObject spec, String[] colnames, String group) 
	throws JSONException
{
	int[] colList = new int[0];
	boolean ids = spec.containsKey("ids") && spec.getBoolean("ids");
	
	if( spec.containsKey(group) && spec.get(group) instanceof JSONArray )
	{
		JSONArray colspecs = (JSONArray)spec.get(group);
		colList = new int[colspecs.size()];
		for(int j=0; j<colspecs.size(); j++) {
			JSONObject colspec = (JSONObject) colspecs.get(j);
			colList[j] = ids ? colspec.getInt("id") : 
				(ArrayUtils.indexOf(colnames, colspec.get("name")) + 1);
			if( colList[j] <= 0 ) {
				throw new RuntimeException("Specified column '" +
					colspec.get(ids?"id":"name")+"' does not exist.");
			}
		}
		
		//ensure ascending order of column IDs
		Arrays.sort(colList);
	}
	
	return colList;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Converts an input stream of a string frame in csv or textcell format
 * into a frame block. The meta data string is the SystemML generated
 * .mtd file including the number of rows and columns.
 * 
 * @param input InputStream to a string frame in csv or textcell format
 * @param meta string representing SystemML frame metadata in JSON format
 * @return frame as a frame block
 * @throws IOException if IOException occurs
 */
public FrameBlock convertToFrame(InputStream input, String meta) 
	throws IOException
{
	try {
		//parse json meta data 
		JSONObject jmtd = new JSONObject(meta);
		int rows = jmtd.getInt(DataExpression.READROWPARAM);
		int cols = jmtd.getInt(DataExpression.READCOLPARAM);
		String format = jmtd.getString(DataExpression.FORMAT_TYPE);
		
		//parse the input frame
		return convertToFrame(input, rows, cols, format);
	}
	catch(Exception ex) {
		throw new IOException(ex);
	}
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
static public MapData loadMapData(String projectPath, JSONObject formatJSON){
	MapData mapData = null;
	JSONObject mapFormatJSON = null;
	try {
		mapFormatJSON = formatJSON.getJSONObject("map");
	} catch (JSONException e) {
		e.printStackTrace();
	}
	for(MapDataReader mapReader: mapReaderLoader){
		if(mapReader.hasReadMethod(mapFormatJSON)){
			System.out.println("MapDataReader="+mapReader);
			mapData = mapReader.read(projectPath, mapFormatJSON);
			return mapData;
		}
	}
	throw new RuntimeException("MapDataReader was not found. MapFormatJSON = "+mapFormatJSON);
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public TestData loadTestData(String projectPath, JSONObject formatJSON, MapData mapData, String group){
	String testDataDir = projectPath + TestDataReaderBase.TEST_PATH;
	List<String> resNames = resReader.getResourceNames(testDataDir);
	String readMethod = toReadMethod(formatJSON);
	TestData testData = new TestData();
	if(DataUtils.hasReadMethod(readMethod)){
		for(String str: resNames){
			if(str.endsWith(CSV_EXT)){
				InputStream is = resReader.getInputStream(str);
				String[] strs = str.split("/");
				String fileName = strs[strs.length-1];
				List<Sample> samples = DataUtils.readCSVWalkingSamples(is, group);
				DataUnit data = new DataUnit(fileName, samples);
				testData.add(data);
				System.out.println(fileName + " is read by " + readMethod);
			}
		}
	}
	return testData;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public TestData movingAverageTestData(TestData testData, JSONObject formatJSON) {
	try {
		if (formatJSON.getJSONObject("test").has("movingAverageWindow")) {
			int mawindow = formatJSON.getJSONObject("test").getInt("movingAverageWindow");
			int nTest = testData.getSize();
			System.out.println("Test data moving averaged (window" + mawindow + ")");
			for (int i = 0; i < nTest; i++) {
				DataUnit tst = testData.get(i);
				List<Sample> smps = Sample.movingAverage(tst.getSamples(), mawindow);
				tst.setSamples(smps);
			}
		}
	} catch (JSONException e) {
		e.printStackTrace();
	}
	return testData;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public static JSONObject BLEBeaconToJSONObject(BLEBeacon BLEBeacon){

		JSONObject jobj = new JSONObject();
		try{
			jobj.put("type","beacon");

			jobj.put("x", BLEBeacon.getX());
			jobj.put("y", BLEBeacon.getY());
			jobj.put("f", BLEBeacon.getZ());

			jobj.put("id", BLEBeacon.getMinor());
			jobj.put("major", BLEBeacon.getMajor());
			jobj.put("minor", BLEBeacon.getMinor());
			jobj.put("msdPower", BLEBeacon.getMsdPower());
			jobj.put("outPower", BLEBeacon.getOutputPower());
		}catch(JSONException e){
			e.printStackTrace();
		}
		return jobj;
	}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Reads an input frame in arbitrary format from HDFS into a dense string array.
 * NOTE: this call currently only supports default configurations for CSV.
 * 
 * @param fname the filename of the input frame
 * @return frame as a two-dimensional string array
 * @throws IOException if IOException occurs
 */
public String[][] readStringFrame(String fname) 
	throws IOException
{
	try {
		//read json meta data 
		String fnamemtd = DataExpression.getMTDFileName(fname);
		JSONObject jmtd = new DataExpression().readMetadataFile(fnamemtd, false);
		
		//parse json meta data 
		long rows = jmtd.getLong(DataExpression.READROWPARAM);
		long cols = jmtd.getLong(DataExpression.READCOLPARAM);
		String format = jmtd.getString(DataExpression.FORMAT_TYPE);
		InputInfo iinfo = InputInfo.stringExternalToInputInfo(format);
	
		//read frame file
		return readStringFrame(fname, iinfo, rows, cols);
	}
	catch(Exception ex) {
		throw new IOException(ex);
	}
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public JSONObject toJSON(){
	JSONObject json = new JSONObject();

	JSONObject LDPLJSON = new JSONObject();
	JSONObject GPJSON = new JSONObject();
	JSONObject optJSON = new JSONObject();

	try {
		double[] params = getParams();
		LDPLJSON.put("n", params[0]).put("A", params[1]).put("fa", params[2]).put("fb", params[3]).put(HDIFF, hDiff);

		GPJSON.put("lengthes", new Double[]{lengthes[0], lengthes[1], lengthes[2]});
		GPJSON.put("sigmaP", stdev).put("sigmaN", sigmaN).put("useMask", gpLDPL.getUseMask()?1:0).put("constVar", gpLDPL.getOptConstVar());

		optJSON.put("optimizeHyperParameters", doHyperParameterOptimize?1:0);

		json.put(LDPLParameters, LDPLJSON);
		json.put(GPParameters, GPJSON);
		json.put(OPTIONS, optJSON);

	} catch (JSONException e) {
		e.printStackTrace();
	}

	return json;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public DataManagerImpl(JSONObject settings) {
	this.settings = settings;
	if (this.settings == null) {
		return;
	}
	try {
		JSONArray array = settings.getJSONArray("configurations");
		if (array == null) {
			return;
		}
		for (int i = 0; i < array.length(); i++) {
			JSONObject config = array.getJSONObject(i);
			uuidSiteMap.put(config.getString("uuid"), config.getString("site_id"));
		}
	} catch (JSONException e) {
		e.printStackTrace();
	}
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public static ObservationModel buildObservationModel(JSONObject json, ProjectData projData){
	ObservationModel model=null;
	try {
		String name = json.getString("name");
		System.out.println("Building an observation model : "+name);

		for(ObservationModelFactory obsProv: obsLoader){
			System.out.println("ObservationModelProvider="+obsProv.getClass().getSimpleName());
			if(obsProv.hasModel(json)){
				System.out.println("ObservationModelProvider="+obsProv.getClass().getSimpleName() +" is creating an observation model.");
				model = obsProv.create(json, projData);
			}
		}

		if(model==null){
			System.err.println("Unknown observation model name: "+name);
			throw new RuntimeException();
		}
	} catch (JSONException e) {
		e.printStackTrace();
	}
	return model;
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public static List<Integer> parseBinningColIDs(JSONObject jSpec, String[] colnames) 
	throws IOException 
{
	try {
		if( jSpec.containsKey(TfUtils.TXMETHOD_BIN) && jSpec.get(TfUtils.TXMETHOD_BIN) instanceof JSONArray ) {
			return Arrays.asList(ArrayUtils.toObject(
					TfMetaUtils.parseJsonObjectIDList(jSpec, colnames, TfUtils.TXMETHOD_BIN)));	
		}
		else { //internally generates
			return Arrays.asList(ArrayUtils.toObject(
					TfMetaUtils.parseJsonIDList(jSpec, colnames, TfUtils.TXMETHOD_BIN)));	
		}
	}
	catch(JSONException ex) {
		throw new IOException(ex);
	}
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
public static  SyntheticDataGenerator create(JSONObject json){

		SyntheticDataGenerator gen = new SyntheticDataGenerator();

		try{
			JSONObject beaconJSON = json.getJSONObject("Beacon");
			JSONObject motionJSON = json.getJSONObject("Motion");

			gen.beaconGen = new SyntheticBeaconDataGenerator(beaconJSON);
			gen.motionGen = new SyntheticMotionDataGenerator(motionJSON);

			JSONObject randomJSON = json.getJSONObject("Random");
			int seed =  randomJSON==null ? 1234 : randomJSON.getInt("seed");
			gen.beaconGen.setRandom(new Random(seed));
			gen.motionGen.setRandom(new Random(seed));

		}catch(JSONException e){
			e.printStackTrace();
		}
		return gen;
	}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Preliminary initialization. Creates the skeleton of the JSON file.
 * @throws JSONException
 * @throws IOException
 */
@Before
public void initialize() throws JSONException, IOException{
    jsonGroupParser = new JSONGroupParser();
    jsonGroupObject = new JSONObject();
    initializeJSON();
    jsonFile = new File(JSON_FILE_PATH);
    fileWriter = new FileWriter(jsonFile);
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
private void initializeJSON() throws JSONException{
    rulesArray = new JSONArray();
    jsonGroupObject.put("rules", rulesArray);
    JSONObject modelInfo = new JSONObject();
    modelArray = new JSONArray();
    modelInfo.put("modelgroups", modelArray);
    jsonGroupObject.put("groups", modelInfo);
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Makes sure a AdeUsageException is thrown when the evaluation order is incorrect. The evaluation
 * order must be in increasing consecutive order starting with 1.
 * @throws JSONException
 * @throws IOException
 * @throws AdeException
 */
@Test(expected=AdeUsageException.class)
public void testEvaluationOrder() throws JSONException, IOException, AdeException{
    JSONObject modelGroup1 = GroupsAndRulesJSONUtil.createGroup("ModelGName1", "syslog", 2, "modelRule1");
    JSONObject modelGroup2 = GroupsAndRulesJSONUtil.createGroup("ModelGName2", "syslog", 3, "modelRule2");
    modelArray.put(modelGroup1);
    modelArray.put(modelGroup2);
    writeToFileAndParseJSON();
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Makes sure a AdeUsageException is thrown when we do not have a 1-1 mapping for groups to rules.
 * @throws JSONException
 * @throws IOException
 * @throws AdeException
 */
@Test(expected=AdeUsageException.class)
public void testvalidate1to1GroupRules() throws JSONException, IOException, AdeException {
    JSONObject modelGroup1 = GroupsAndRulesJSONUtil.createGroup("ModelGName1", "syslog", 1, "modelRule1");
    JSONObject modelGroup2 = GroupsAndRulesJSONUtil.createGroup("ModelGName2", "syslog", 2, "modelRule2");
    JSONObject rule1 = GroupsAndRulesJSONUtil.createRule("modelRule1", "Description for model rule 1", "ModelGName1");
    modelArray.put(modelGroup1);
    modelArray.put(modelGroup2);
    rulesArray.put(rule1);
    writeToFileAndParseJSON();
}
 

import org.apache.wink.json4j.JSONObject; //导入依赖的package包/类
/**
 * Checks to make sure that every rule name in a group is referenced by a rule otherwise, a 
 * AdeUsageException is thrown.
 * @throws JSONException
 * @throws IOException
 * @throws AdeException
 */
@Test(expected=AdeUsageException.class)
public void testvalidateGroupRulesNames() throws JSONException, IOException, AdeException {
    JSONObject modelGroup1 = GroupsAndRulesJSONUtil.createGroup("ModelGName1", "syslog", 1, "modelRule1");
    JSONObject modelGroup2 = GroupsAndRulesJSONUtil.createGroup("ModelGName2", "syslog", 2, "modelRule2");
    JSONObject rule1 = GroupsAndRulesJSONUtil.createRule("modelRule1", "Description for model rule 1", "ModelGName1");
    JSONObject rule2 = GroupsAndRulesJSONUtil.createRule("modelRule3", "Description for model rule 2", "ModelGName2");
    modelArray.put(modelGroup1);
    modelArray.put(modelGroup2);
    rulesArray.put(rule1);
    rulesArray.put(rule2);
    writeToFileAndParseJSON();
}