iramuteq.org Git - iramuteq/blob - analyse_merge.py

   1 # -*- coding: utf-8 -*-
   2 #Author: Pierre Ratinaud
   3 #Copyright (c) 2015 Pierre Ratinaud
   4 #License: GNU/GPL
   5
   6 import os
   7 from chemins import PathOut
   8 from functions import exec_rcode, check_Rresult
   9 from dialog import MergeDialog
  10 import wx
  11 from time import sleep
  12 from PrintRScript import MergeGraphes
  13
  14 def merge_graphes(lgraphes):
  15     script = MergeGraphes({'lgraphes':lgraphes, 'grapheout' : '/tmp/graphe.graphml'})
  16     script.make_script()
  17     script.write()
  18     return script
  19
  20 class AnalyseMerge :
  21     def __init__(self, ira, parametres, dlg = None):
  22         self.ira = ira
  23         self.dlg = dlg
  24         self.parametres = parametres
  25         if 'pathout' not in self.parametres :
  26             self.parametres['pathout'] = PathOut(self.parametres['fileout'], analyse_type = self.parametres['type'], dirout = os.path.dirname(self.parametres['fileout'])).mkdirout()
  27             self.pathout = PathOut(analyse_type = self.parametres['type'], dirout = self.parametres['pathout'])
  28         else :
  29             self.pathout = PathOut(dirout = self.parametres['pathout'], analyse_type = self.parametres['type'])
  30         if self.doparametres(dlg=dlg) is not None :
  31             script = merge_graphes(self.parametres['graphs'])
  32             self.doR(script.scriptout, dlg=False)
  33             print 'fini'
  34
  35
  36     def doparametres(self, dlg=None):
  37         if dlg is not None :
  38             dial = MergeDialog(self.ira)
  39             res = dial.ShowModal()
  40             if res == wx.ID_OK :
  41                 self.parametres['graphs'] = [graph.GetPath() for graph in dial.graphs if graph.GetPath() != '']
  42                 return True
  43         return True
  44
  45     def doR(self, Rscript, wait = False, dlg = None, message = '') :
  46         #log.info('R code...')
  47         pid = exec_rcode(self.ira.RPath, Rscript, wait = wait)
  48         while pid.poll() is None :
  49             if dlg :
  50                 self.dlg.Pulse(message)
  51                 sleep(0.2)
  52             else :
  53                 sleep(0.2)
  54         return check_Rresult(self.ira, pid)