X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=pcacommand.cpp;h=2cb37bda8896f8f2cb1f64521f1a73232507f24b;hb=a9dbc22713bfc056a797361dd757b1a5c98e1c01;hp=e273e5fe7079ffab790ccf5498e69675a0fafeef;hpb=e150b0b0664caec517485ee6d69dcdade6dcae77;p=mothur.git diff --git a/pcacommand.cpp b/pcacommand.cpp index e273e5f..2cb37bd 100644 --- a/pcacommand.cpp +++ b/pcacommand.cpp @@ -48,6 +48,28 @@ string PCACommand::getHelpString(){ exit(1); } } +//********************************************************************************************************************** +string PCACommand::getOutputFileNameTag(string type, string inputName=""){ + try { + string outputFileName = ""; + map >::iterator it; + + //is this a type this command creates + it = outputTypes.find(type); + if (it == outputTypes.end()) { m->mothurOut("[ERROR]: this command doesn't create a " + type + " output file.\n"); } + else { + if (type == "pca") { outputFileName = "pca.axes"; } + else if (type == "loadings") { outputFileName = "pca.loadings"; } + else { m->mothurOut("[ERROR]: No definition for type " + type + " output file tag.\n"); m->control_pressed = true; } + } + return outputFileName; + } + catch(exception& e) { + m->errorOut(e, "PCACommand", "getOutputFileNameTag"); + exit(1); + } +} + //********************************************************************************************************************** PCACommand::PCACommand(){ try { @@ -117,12 +139,12 @@ PCACommand::PCACommand(string option) { sharedfile = validParameter.validFile(parameters, "shared", true); if (sharedfile == "not open") { sharedfile = ""; abort = true; } else if (sharedfile == "not found") { sharedfile = ""; } - else { mode = "sharedfile"; inputFile = sharedfile; } + else { mode = "sharedfile"; inputFile = sharedfile; m->setSharedFile(sharedfile); } relabundfile = validParameter.validFile(parameters, "relabund", true); if (relabundfile == "not open") { relabundfile = ""; abort = true; } else if (relabundfile == "not found") { relabundfile = ""; } - else { mode = "relabund"; inputFile = relabundfile; } + else { mode = "relabund"; inputFile = relabundfile; m->setRelAbundFile(relabundfile); } if ((sharedfile == "") && (relabundfile == "")) { @@ -157,7 +179,7 @@ PCACommand::PCACommand(string option) { groups = validParameter.validFile(parameters, "groups", false); if (groups == "not found") { groups = ""; } else { m->splitAtDash(groups, Groups); } - m->Groups = Groups; + m->setGroups(Groups); } @@ -203,7 +225,7 @@ int PCACommand::execute(){ //as long as you are not at the end of the file or done wih the lines you want while((lookupFloat[0] != NULL) && (userLabels.size() != 0)) { - if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { remove(outputNames[i].c_str()); } delete input; for (int i = 0; i < lookupFloat.size(); i++) { delete lookupFloat[i]; } lookupFloat.clear(); return 0; } + if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { m->mothurRemove(outputNames[i]); } delete input; for (int i = 0; i < lookupFloat.size(); i++) { delete lookupFloat[i]; } lookupFloat.clear(); return 0; } if(labels.count(lookupFloat[0]->getLabel()) == 1){ processedLabels.insert(lookupFloat[0]->getLabel()); @@ -236,7 +258,7 @@ int PCACommand::execute(){ } - if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { remove(outputNames[i].c_str()); } delete input; for (int i = 0; i < lookupFloat.size(); i++) { delete lookupFloat[i]; } lookupFloat.clear(); return 0; } + if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { m->mothurRemove(outputNames[i]); } delete input; for (int i = 0; i < lookupFloat.size(); i++) { delete lookupFloat[i]; } lookupFloat.clear(); return 0; } //output error messages about any remaining user labels set::iterator it; @@ -264,7 +286,7 @@ int PCACommand::execute(){ for (int i = 0; i < lookupFloat.size(); i++) { if (lookupFloat[i] != NULL) { delete lookupFloat[i]; } } lookupFloat.clear(); delete input; - if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { remove(outputNames[i].c_str()); } return 0; } + if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { m->mothurRemove(outputNames[i]); } return 0; } m->mothurOutEndLine(); m->mothurOut("Output File Names: "); m->mothurOutEndLine(); @@ -319,7 +341,6 @@ int PCACommand::process(vector& lookupFloat){ vector< vector > matrix(numSamples); vector colMeans(numOTUs); - //fill matrix with shared relative abundances, re-center for (int i = 0; i < lookupFloat.size(); i++) { matrix[i].resize(numOTUs, 0); @@ -366,7 +387,7 @@ int PCACommand::process(vector& lookupFloat){ string fbase = outputDir + m->getRootName(m->getSimpleName(inputFile)); string outputFileName = fbase + lookupFloat[0]->getLabel(); - output(outputFileName, m->Groups, X, d); + output(outputFileName, m->getGroups(), X, d); if (metric) { @@ -376,13 +397,13 @@ int PCACommand::process(vector& lookupFloat){ vector< vector > PCAEuclidDists = linearCalc.calculateEuclidianDistance(X, i); //G is the pca file - if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { remove(outputNames[i].c_str()); } return 0; } + if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { m->mothurRemove(outputNames[i]); } return 0; } double corr = linearCalc.calcPearson(PCAEuclidDists, observedEuclideanDistance); m->mothurOut("Rsq " + toString(i) + " axis: " + toString(corr * corr)); m->mothurOutEndLine(); - if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { remove(outputNames[i].c_str()); } return 0; } + if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) { m->mothurRemove(outputNames[i]); } return 0; } } } @@ -404,17 +425,19 @@ void PCACommand::output(string fnameRoot, vector name_list, vectoropenOutputFile((fnameRoot+"."+getOutputFileNameTag("pca")), pcaData); pcaData.setf(ios::fixed, ios::floatfield); pcaData.setf(ios::showpoint); - outputNames.push_back(fnameRoot+".pca.axes"); - outputTypes["pca"].push_back(fnameRoot+".pca.axes"); + outputNames.push_back(fnameRoot+"."+getOutputFileNameTag("pca")); + outputTypes["pca"].push_back(fnameRoot+"."+getOutputFileNameTag("pca")); - ofstream pcaLoadings((fnameRoot+".pca.loadings").c_str(), ios::trunc); + ofstream pcaLoadings; + m->openOutputFile((fnameRoot+"."+getOutputFileNameTag("loadings")), pcaLoadings); pcaLoadings.setf(ios::fixed, ios::floatfield); pcaLoadings.setf(ios::showpoint); - outputNames.push_back(fnameRoot+".pca.loadings"); - outputTypes["loadings"].push_back(fnameRoot+".pca.loadings"); + outputNames.push_back(fnameRoot+"."+getOutputFileNameTag("loadings")); + outputTypes["loadings"].push_back(fnameRoot+"."+getOutputFileNameTag("loadings")); pcaLoadings << "axis\tloading\n"; for(int i=0;i name_list, vector