source: sasview/sansview/perspectives/fitting/fitting.py @ ddfcd90

ESS_GUIESS_GUI_DocsESS_GUI_batch_fittingESS_GUI_bumps_abstractionESS_GUI_iss1116ESS_GUI_iss879ESS_GUI_iss959ESS_GUI_openclESS_GUI_orderingESS_GUI_sync_sascalccostrafo411magnetic_scattrelease-4.1.1release-4.1.2release-4.2.2release_4.0.1ticket-1009ticket-1094-headlessticket-1242-2d-resolutionticket-1243ticket-1249ticket885unittest-saveload
Last change on this file since ddfcd90 was 0f5fe6b, checked in by Gervaise Alina <gervyh@…>, 15 years ago

working on close and reopen fit page

  • Property mode set to 100644
File size: 40.6 KB
Line 
1import  re
2import sys, wx, logging
3import string, numpy, math
4
5#import copy,deepcopy
6from danse.common.plottools.plottables import Data1D, Theory1D,Data2D
7from danse.common.plottools.PlotPanel import PlotPanel
8from sans.guicomm.events import NewPlotEvent, StatusEvent 
9from sans.guicomm.events import EVT_SLICER_PANEL,ERR_DATA
10
11from sans.fit.AbstractFitEngine import Model,FitData1D,FitData2D#,Data,
12from fitproblem import FitProblem
13from fitpanel import FitPanel
14from fit_thread import FitThread
15import models
16import fitpage
17
18DEFAULT_BEAM = 0.005
19DEFAULT_QMIN = 0.0
20DEFAULT_QMAX = 0.1
21DEFAULT_NPTS = 50
22import time
23import thread
24
25
26(PageInfoEvent, EVT_PAGE_INFO)   = wx.lib.newevent.NewEvent()
27class PlotInfo:
28    """
29        store some plotting field
30    """
31    _xunit = 'A^{-1}'
32    _xaxis= "\\rm{Q}"
33    _yunit = "cm^{-1}"
34    _yaxis= "\\rm{Intensity} "
35    id = "Model"
36    group_id = "Model"
37    title= None
38    info= None
39   
40   
41class Plugin:
42    """
43        Fitting plugin is used to perform fit
44    """
45    def __init__(self):
46        ## Plug-in name
47        self.sub_menu = "Fitting"
48       
49        ## Reference to the parent window
50        self.parent = None
51        #Provide list of models existing in the application
52        self.menu_mng = models.ModelManager()
53        ## List of panels for the simulation perspective (names)
54        self.perspective = []
55        #list of panel to send to guiframe
56        self.mypanels=[]
57        # reference to the current running thread
58        self.calc_2D= None
59        self.calc_1D= None
60        self.calc_fit= None
61       
62        # Start with a good default
63        self.elapsed = 0.022
64        # the type of optimizer selected, park or scipy
65        self.fitter  = None
66        #Flag to let the plug-in know that it is running stand alone
67        self.standalone=True
68        ## dictionary of page closed and id
69        self.closed_page_dict ={}
70        ## Fit engine
71        self._fit_engine = 'scipy'
72        #List of selected data
73        self.selected_data_list=[]
74        # Log startup
75        logging.info("Fitting plug-in started")   
76        # model 2D view
77        self.model2D_id=None
78        #keep reference of the simultaneous fit page
79        self.sim_page=None
80        #dictionary containing data name and error on dy of that data
81        self.err_dy={}
82       
83   
84       
85    def populate_menu(self, id, owner):
86        """
87            Create a menu for the Fitting plug-in
88            @param id: id to create a menu
89            @param owner: owner of menu
90            @ return : list of information to populate the main menu
91        """
92        #Menu for fitting
93        self.menu1 = wx.Menu()
94       
95        #Set park engine
96        id3 = wx.NewId()
97        scipy_help= "Scipy Engine: Perform Simple fit. More in Help window...."
98        #self.menu1.Append(id3, "Scipy",scipy_help)
99        self.menu1.AppendCheckItem(id3, "Simple Fit  [Scipy]",scipy_help) 
100        wx.EVT_MENU(owner, id3,  self._onset_engine_scipy)
101       
102        id3 = wx.NewId()
103        park_help = "Park Engine: Perform Complex fit. More in Help window...."
104        self.menu1.AppendCheckItem(id3, "Complex Fit  [Park]",park_help) 
105        wx.EVT_MENU(owner, id3,  self._onset_engine_park)
106        self.menu1.AppendSeparator()
107       
108        id1 = wx.NewId()
109        simul_help = "Allow to edit fit engine with multiple model and data"
110        self.menu1.Append(id1, '&Simultaneous Page',simul_help)
111        wx.EVT_MENU(owner, id1, self.on_add_sim_page)
112   
113        #menu for model
114        menu2 = wx.Menu()
115   
116        self.menu_mng.populate_menu(menu2, owner)
117        id2 = wx.NewId()
118        owner.Bind(models.EVT_MODEL,self._on_model_menu)
119     
120        self.fit_panel.set_owner(owner)
121        self.fit_panel.set_model_list(self.menu_mng.get_model_list())
122        owner.Bind(fitpage.EVT_MODEL_BOX,self._on_model_panel)
123       
124        self.menu3= wx.Menu()
125        id4 = wx.NewId()
126       
127        #create  menubar items
128        return [(id, self.menu1, "Fitting"),
129                (id4,self.menu3,"Averagers"),
130                (id2, menu2, "Model")]
131   
132    def on_add_sim_page(self, event):
133        """
134            Create a page to access simultaneous fit option
135        """
136        if self.sim_page !=None:
137            msg= "Simultaneous Fit page already opened"
138            wx.PostEvent(self.parent, StatusEvent(status= msg))
139            return 
140       
141        self.sim_page= self.fit_panel.add_sim_page()
142       
143       
144       
145    def help(self, evt):
146        """
147            Show a general help dialog.
148            TODO: replace the text with a nice image
149        """
150        from helpPanel import  HelpWindow
151        frame = HelpWindow(None, -1, 'HelpWindow')   
152        frame.Show(True)
153       
154       
155    def get_context_menu(self, graph=None):
156        """
157            Get the context menu items available for P(r)
158            @param graph: the Graph object to which we attach the context menu
159            @return: a list of menu items with call-back function
160        """
161        self.graph=graph
162        for item in graph.plottables:
163            if item.__class__.__name__ is "Data2D":
164                return [["Select data  for Fitting",\
165                          "Dialog with fitting parameters ", self._onSelect]] 
166            else:
167               
168                if item.name==graph.selected_plottable :
169                    if not hasattr(item, "group_id"):
170                        return []
171                    return [["Select data  for Fitting", \
172                             "Dialog with fitting parameters ", self._onSelect]] 
173        return []   
174
175
176    def get_panels(self, parent):
177        """
178            Create and return a list of panel objects
179        """
180        self.parent = parent
181        # Creation of the fit panel
182        self.fit_panel = FitPanel(self.parent, -1)
183        #Set the manager for the main panel
184        self.fit_panel.set_manager(self)
185        # List of windows used for the perspective
186        self.perspective = []
187        self.perspective.append(self.fit_panel.window_name)
188        # take care of saving  data, model and page associated with each other
189        self.page_finder = {}
190        #index number to create random model name
191        self.index_model = 0
192        self.index_theory= 0
193        self.parent.Bind(EVT_SLICER_PANEL, self._on_slicer_event)
194        self.parent.Bind( ERR_DATA, self._on_data_error)
195       
196        #Send the fitting panel to guiframe
197        self.mypanels.append(self.fit_panel)
198        return self.mypanels
199
200       
201     
202    def get_perspective(self):
203        """
204            Get the list of panel names for this perspective
205        """
206        return self.perspective
207   
208   
209    def on_perspective(self, event):
210        """
211            Call back function for the perspective menu item.
212            We notify the parent window that the perspective
213            has changed.
214        """
215        self.parent.set_perspective(self.perspective)
216   
217   
218    def post_init(self):
219        """
220            Post initialization call back to close the loose ends
221            [Somehow openGL needs this call]
222        """
223        self.parent.set_perspective(self.perspective)
224
225
226    def copy_data(self, item, dy):
227        """
228            receive a data 1D and the list of errors on dy
229            and create a new data1D data
230            @param return
231        """
232        detector=None
233        source=None
234        dxl=None
235        dxw=None
236        if hasattr(item, "dxl"):
237            dxl = item.dxl
238        if hasattr(item, "dxw"):
239            dxw = item.dxw
240        if hasattr(item, "detector"):
241            detector =item.detector
242        if hasattr(item, "source"):
243            source =item.source
244        from sans.guiframe import dataFitting
245        data= dataFitting.Data1D(x=item.x, y=item.y, dy=dy, dxl=dxl, dxw=dxw)
246        data.name=item.name
247        data.detector=detector
248        data.source= source
249        return data
250
251    def set_fit_range(self, page, qmin, qmax):
252        """
253            Set the fitting range of a given page
254        """
255        if page in self.page_finder.iterkeys():
256            fitproblem= self.page_finder[page]
257            fitproblem.set_range(qmin= qmin, qmax= qmax)
258                   
259    def schedule_for_fit(self,value=0,page=None,fitproblem =None): 
260        """
261            Set the fit problem field to 0 or 1 to schedule that problem to fit.
262            Schedule the specified fitproblem or get the fit problem related to
263            the current page and set value.
264            @param value : integer 0 or 1
265            @param fitproblem: fitproblem to schedule or not to fit
266        """   
267        if fitproblem !=None:
268            fitproblem.schedule_tofit(value)
269        else:
270            if page in self.page_finder.iterkeys():
271                fitproblem= self.page_finder[page]
272                fitproblem.schedule_tofit(value)
273         
274                     
275                   
276    def get_page_finder(self):
277        """ @return self.page_finder used also by simfitpage.py""" 
278        return self.page_finder
279   
280   
281    def set_page_finder(self,modelname,names,values):
282        """
283             Used by simfitpage.py to reset a parameter given the string constrainst.
284             @param modelname: the name ot the model for with the parameter has to reset
285             @param value: can be a string in this case.
286             @param names: the paramter name
287             @note: expecting park used for fit.
288        """ 
289        sim_page= self.sim_page
290        for page, value in self.page_finder.iteritems():
291            if page != sim_page:
292                list=value.get_model()
293                model = list[0]
294                if model.name== modelname:
295                    value.set_model_param(names,values)
296                    break
297
298   
299                           
300    def split_string(self,item): 
301        """
302            receive a word containing dot and split it. used to split parameterset
303            name into model name and parameter name example:
304            paramaterset (item) = M1.A
305            @return model_name =M1 , parameter name =A
306        """
307        if string.find(item,".")!=-1:
308            param_names= re.split("\.",item)
309            model_name=param_names[0]
310            param_name=param_names[1] 
311            return model_name,param_name
312       
313   
314    def stop_fit(self):
315        """
316            Stop the fit engine
317        """
318        if self.calc_fit!= None and self.calc_thread.isrunning():
319            self.calc_thread.stop()
320            wx.PostEvent(self.parent, StatusEvent(status="Fitting  \
321                is cancelled" , type="stop"))
322           
323   
324     
325    def set_smearer(self,smearer, qmin=None, qmax=None):
326        """
327            Get a smear object and store it to a fit problem
328            @param smearer: smear object to allow smearing data
329        """   
330        current_pg=self.fit_panel.get_current_page()
331        self.page_finder[current_pg].set_smearer(smearer)
332        ## draw model 1D with smeared data
333        data =  self.page_finder[current_pg].get_plotted_data()
334        model = self.page_finder[current_pg].get_model()
335        ## if user has already selected a model to plot
336        ## redraw the model with data smeared
337       
338        smearer =self.page_finder[current_pg].get_smearer()
339        if smearer != None:
340            self.draw_model( model=model, data= data, smearer= smearer,
341                qmin= qmin, qmax= qmax)
342
343   
344   
345    def draw_model(self, model, data= None,smearer= None,
346                   enable1D= True, enable2D= False,
347                   qmin= DEFAULT_QMIN, qmax= DEFAULT_QMAX, qstep= DEFAULT_NPTS):
348        """
349             Draw model.
350             @param model: the model to draw
351             @param name: the name of the model to draw
352             @param data: the data on which the model is based to be drawn
353             @param description: model's description
354             @param enable1D: if true enable drawing model 1D
355             @param enable2D: if true enable drawing model 2D
356             @param qmin:  Range's minimum value to draw model
357             @param qmax:  Range's maximum value to draw model
358             @param qstep: number of step to divide the x and y-axis
359             
360        """
361        ## draw model 1D with no loaded data
362        self._draw_model1D( model= model, data= data,enable1D=enable1D, smearer= smearer,
363                           qmin= qmin, qmax= qmax, qstep= qstep )
364        ## draw model 2D with no initial data
365        self._draw_model2D(model=model,
366                           data = data,
367                           enable2D= enable2D,
368                           qmin=qmin,
369                           qmax=qmax,
370                           qstep=qstep)
371       
372 
373                       
374    def onFit(self):
375        """
376            perform fit
377        """
378        ##  count the number of fitproblem schedule to fit
379        fitproblem_count= 0
380        for value in self.page_finder.itervalues():
381            if value.get_scheduled()==1:
382                fitproblem_count += 1
383               
384        ## if simultaneous fit change automatically the engine to park
385        if fitproblem_count >1:
386            self.menu1.FindItemByPosition(1).Check(True)
387            self.menu1.FindItemByPosition(0).Check(False)
388            self._on_change_engine(engine='park')
389           
390        from sans.fit.Fitting import Fit
391        self.fitter= Fit(self._fit_engine)
392       
393        if self._fit_engine=="park":
394            engineType="Simultaneous Fit"
395        else:
396            engineType="Single Fit"
397           
398        fproblemId = 0
399        current_pg=None
400        for page, value in self.page_finder.iteritems():
401            try:
402                if value.get_scheduled()==1:
403                    #Get list of parameters name to fit
404                    pars = []
405                    templist = []
406                    templist = page.get_param_list()
407                    for element in templist:
408                        name = str(element[0].GetLabelText())
409                        pars.append(name)
410                    #Set Engine  (model , data) related to the page on
411                    self._fit_helper( current_pg=page, value=value,pars=pars,
412                                      id=fproblemId, title= engineType ) 
413                    fproblemId += 1 
414                    current_pg= page
415            except:
416                msg= "%s error: %s" % (engineType,sys.exc_value)
417                wx.PostEvent(self.parent, StatusEvent(status= msg ))
418                return 
419        #Do the simultaneous fit
420        try:
421            ## If a thread is already started, stop it
422            if self.calc_fit!= None and self.calc_fit.isrunning():
423                self.calc_fit.stop()
424            ## perform single fit
425            if self._fit_engine=="scipy":
426                qmin, qmax= current_pg.get_range()
427                self.calc_fit=FitThread(parent =self.parent,
428                                        fn= self.fitter,
429                                       cpage=current_pg,
430                                       pars= pars,
431                                       completefn= self._single_fit_completed,
432                                       updatefn=None)
433                     
434            else:
435                ## Perform more than 1 fit at the time
436                self.calc_fit=FitThread(parent =self.parent,
437                                        fn= self.fitter,
438                                       completefn= self._simul_fit_completed,
439                                       updatefn=None)
440            self.calc_fit.queue()
441            self.calc_fit.ready(2.5)
442           
443        except:
444            msg= "%s error: %s" % (engineType,sys.exc_value)
445            wx.PostEvent(self.parent, StatusEvent(status= msg ))
446            return 
447             
448             
449    def _add_page_onmenu(self, name, page_info,fitproblem=None):
450        """
451            Add name of a closed page of fitpanel in a menu
452        """
453        list = self.menu1.GetMenuItems()
454        for item in list:
455            if name == item.GetItemLabel():
456                self.closed_page_dict[name][1:] = page_info, fitproblem
457               
458        if not name in self.closed_page_dict.keys():   
459            # Post paramters
460            event_id = wx.NewId()
461            self.menu1.Append(event_id, name, "Show %s fit panel" % name)
462            self.closed_page_dict[name]= [event_id,page_info, fitproblem]
463            wx.EVT_MENU(self.parent,event_id,  self._open_closed_page)
464       
465       
466    def _open_closed_page(self, event):   
467        """
468            reopen a closed page
469        """
470        for value in self.closed_page_dict.values():
471            if event.GetId() in value:
472                id, page_info,fitproblem = value
473       
474                if page_info.page_name !="Model Page":
475                    page = self.fit_panel.add_fit_page(data= page_info.data,
476                                                        page_info=page_info)
477                    if fitproblem != None:
478                        self.page_finder[page]=fitproblem
479                else:
480                    model= page_info.model
481                    self.fit_panel.add_model_page(model,model.name,topmenu=False,
482                                                  page_info=page_info)
483                    break
484       
485       
486    def _reset_schedule_problem(self, value=0):
487        """
488             unschedule or schedule all fitproblem to be fit
489        """
490        for page, fitproblem in self.page_finder.iteritems():
491            fitproblem.schedule_tofit(value)
492           
493    def _fit_helper(self,current_pg,pars,value, id, title="Single Fit " ):
494        """
495            helper for fitting
496        """
497        metadata = value.get_fit_data()
498        model = value.get_model()
499        smearer = value.get_smearer()
500        qmin , qmax = value.get_range()
501        self.fit_id =id
502        #Create list of parameters for fitting used
503        templist=[]
504        pars=pars
505        try:
506            ## create a park model and reset parameter value if constraint
507            ## is given
508            new_model = Model(model)
509            param = value.get_model_param()
510            if len(param)>0:
511                for item in param:
512                    param_value = item[1]
513                    param_name = item[0]
514                    ## check if constraint
515                    if param_value !=None and param_name != None:
516                        new_model.parameterset[ param_name].set( param_value )
517           
518           
519            #Do the single fit
520            self.fitter.set_model(new_model, self.fit_id, pars)
521            dy=[]
522            x=[]
523            y=[]
524            ## checking the validity of error
525            if metadata.__class__ in  ["Data1D","Theory1D"]:
526                for i in range(len(metadata.dy)):
527                    if metadata.dy[i] !=0:
528                        dy.append(metadata.dy[i])
529                        x.append(metadata.x[i])
530                        y.append(metadata.y[i])
531                if len(dy)>0:       
532                    metadata.dy=numpy.zeros(len(dy))
533                    metadata.dy=dy
534                    metadata.y=numpy.zeros(len(y))
535                    metadata.y=y
536                    metadata.x=numpy.zeros(len(x))
537                    metadata.x=x
538           
539            self.fitter.set_data(data=metadata,Uid=self.fit_id,
540                                 smearer=smearer,qmin= qmin,qmax=qmax )
541           
542            self.fitter.select_problem_for_fit(Uid= self.fit_id,
543                                               value= value.get_scheduled())
544           
545        except:
546            msg= title +" error: %s" % sys.exc_value
547            wx.PostEvent(self.parent, StatusEvent(status= msg ))
548            return
549       
550    def _onSelect(self,event):
551        """
552            when Select data to fit a new page is created .Its reference is
553            added to self.page_finder
554        """
555        self.panel = event.GetEventObject()
556        for item in self.panel.graph.plottables:
557            if item.name == self.panel.graph.selected_plottable:
558                ## put the errors values back to the model if the errors were hiden
559                ## before sending them to the fit engine
560                if len(self.err_dy)>0:
561                    if item.name in  self.err_dy.iterkeys():
562                        dy= self.err_dy[item.name]
563                        data= self.copy_data(item, dy)
564                    else:
565                        data= item
566                else:
567                    if item.dy==None:
568                        dy= numpy.zeros(len(item.y))
569                        dy[dy==0]=1
570                        data= self.copy_data(item, dy)
571                    else:
572                        data= item
573            else:
574                data= item
575            ## create anew page                   
576            if item.name == self.panel.graph.selected_plottable or\
577                 item.__class__.__name__ is "Data2D":
578                try:
579                    page = self.fit_panel.add_fit_page(data)
580                    # add data associated to the page created
581                    if page !=None:   
582                        #create a fitproblem storing all link to data,model,page creation
583                        self.page_finder[page]= FitProblem()
584                        ## item is almost the same as data but contains
585                        ## axis info for plotting
586                        self.page_finder[page].add_plotted_data(item)
587                        self.page_finder[page].add_fit_data(data)
588                       
589                        wx.PostEvent(self.parent, StatusEvent(status="Page Created"))
590                    else:
591                        wx.PostEvent(self.parent, StatusEvent(status="Page was already Created"))
592                except:
593                    wx.PostEvent(self.parent, StatusEvent(status="Creating Fit page: %s"\
594                    %sys.exc_value))
595                    return
596   
597    def _single_fit_completed(self,result,pars,cpage, elapsed=None):
598        """
599            Display fit result on one page of the notebook.
600            @param result: result of fit
601            @param pars: list of names of parameters fitted
602            @param current_pg: the page where information will be displayed
603            @param qmin: the minimum value of x to replot the model
604            @param qmax: the maximum value of x to replot model
605         
606        """
607        #wx.PostEvent(self.parent, StatusEvent(status="Single fit \
608        #complete! " , type="stop"))
609        try:
610            for page, value in self.page_finder.iteritems():
611                if page==cpage :
612                    model= value.get_model()
613                    break
614            i = 0
615            for name in pars:
616                if result.pvec.__class__==numpy.float64:
617                    model.setParam(name,result.pvec)
618                else:
619                    model.setParam(name,result.pvec[i])
620                    i += 1
621            ## Reset values of the current page to fit result
622            cpage.onsetValues(result.fitness, result.pvec,result.stderr)
623            ## plot the current model with new param
624            metadata =  self.page_finder[cpage].get_fit_data()
625            model = self.page_finder[cpage].get_model()
626            qmin, qmax= self.page_finder[cpage].get_range()
627            #Replot models
628            msg= "Single Fit completed. plotting... %s:"%model.name
629            wx.PostEvent(self.parent, StatusEvent(status="%s " % msg))
630            self.draw_model( model=model, data= metadata,qmin= qmin, qmax= qmax)
631           
632        except:
633            msg= "Single Fit completed but Following error occurred:"
634            wx.PostEvent(self.parent, StatusEvent(status="%s %s" % (msg, sys.exc_value)))
635            return
636       
637       
638    def _simul_fit_completed(self,result,pars=None,cpage=None, elapsed=None):
639        """
640            Parameter estimation completed,
641            display the results to the user
642            @param alpha: estimated best alpha
643            @param elapsed: computation time
644        """
645        wx.PostEvent(self.parent, StatusEvent(status="Simultaneous fit \
646        complete ", type="stop"))
647       
648        ## fit more than 1 model at the same time
649        try:
650            for page, value in self.page_finder.iteritems():
651                if value.get_scheduled()==1:
652                    model = value.get_model()
653                    metadata =  value.get_plotted_data()
654                    small_out = []
655                    small_cov = []
656                    i = 0
657                    #Separate result in to data corresponding to each page
658                    for p in result.parameters:
659                        model_name,param_name = self.split_string(p.name) 
660                        if model.name == model_name:
661                            p_name= model.name+"."+param_name
662                            if p.name == p_name:
663                                small_out.append(p.value )
664                                model.setParam(param_name,p.value) 
665                                if p.stderr==None:
666                                    p.stderr=numpy.nan
667                                    small_cov.append(p.stderr)
668                                   
669                                else:
670                                    small_cov.append(p.stderr)
671                            else:
672                                value= model.getParam(param_name)
673                                small_out.append(value )
674                                small_cov.append(numpy.nan)
675                    # Display result on each page
676                    page.onsetValues(result.fitness, small_out,small_cov)
677                    #Replot models
678                    msg= "Simultaneous Fit completed. plotting... %s:"%model.name
679                    wx.PostEvent(self.parent, StatusEvent(status="%s " % msg))
680                    qmin, qmax= page.get_range()
681                    self.draw_model( model=model, data= metadata,qmin= qmin, qmax= qmax)
682                   
683        except:
684             msg= "Simultaneous Fit completed but Following error occurred: "
685             wx.PostEvent(self.parent, StatusEvent(status="%s%s" %(msg,sys.exc_value)))
686             return 
687             
688                           
689       
690    def _on_show_panel(self, event):
691        print "_on_show_panel: fitting"
692     
693     
694    def _onset_engine_park(self,event):
695        """
696            set engine to park
697        """
698        if event.IsChecked():
699            self.menu1.FindItemByPosition(0).Check(False)
700        self._on_change_engine('park')
701       
702       
703    def _onset_engine_scipy(self,event):
704        """
705            set engine to scipy
706        """
707        if event.IsChecked():
708            self.menu1.FindItemByPosition(1).Check(False)
709        self._on_change_engine('scipy')
710       
711    def _on_slicer_event(self, event):
712        """
713            Receive a panel as event and send it to guiframe
714            @param event: event containing a panel
715        """
716        if event.panel!=None:
717            new_panel = event.panel
718            # Set group ID if available
719            event_id = self.parent.popup_panel(new_panel)
720            self.menu3.Append(event_id, new_panel.window_caption, 
721                             "Show %s plot panel" % new_panel.window_caption)
722            # Set UID to allow us to reference the panel later
723            new_panel.uid = event_id
724            new_panel
725            self.mypanels.append(new_panel) 
726        return   
727   
728    def _on_change_engine(self, engine='park'):
729        """
730            Allow to select the type of engine to perform fit
731            @param engine: the key work of the engine
732        """
733        ## saving fit engine name
734        self._fit_engine = engine
735        ## post a message to status bar
736        wx.PostEvent(self.parent, StatusEvent(status="Engine set to: %s" % self._fit_engine))
737   
738        ## Bind every open fit page with a newevent to know the current fitting engine
739        import fitpage
740        event= fitpage.FitterTypeEvent()
741        event.type = self._fit_engine
742        for key in self.page_finder.keys():
743            wx.PostEvent(key, event)
744       
745   
746    def _on_model_panel(self, evt):
747        """
748            react to model selection on any combo box or model menu.plot the model 
749            @param evt: wx.combobox event
750        """
751        model = evt.model
752       
753        if model ==None:
754            return
755       
756        current_pg = self.fit_panel.get_current_page() 
757        ## make sure nothing is done on self.sim_page
758        ## example trying to call set_panel on self.sim_page
759        if current_pg != self.sim_page :
760           
761            if self.page_finder[current_pg].get_model()== None :
762               
763                model.name="M"+str(self.index_model)
764                self.index_model += 1 
765            else:
766                model.name= self.page_finder[current_pg].get_model().name
767               
768            metadata = self.page_finder[current_pg].get_plotted_data()
769           
770            # save the name containing the data name with the appropriate model
771            self.page_finder[current_pg].set_model(model)
772            qmin, qmax= current_pg.get_range()
773            self.page_finder[current_pg].set_range(qmin=qmin, qmax=qmax)
774           
775            # save model name
776            self.draw_model( model=model, data= metadata, qmin=qmin, qmax=qmax)
777           
778            if self.sim_page!=None:
779                self.sim_page.draw_page()
780       
781       
782 
783    def _on_model_menu(self, evt):
784        """
785            Plot a theory from a model selected from the menu
786            @param evt: wx.menu event
787        """
788        name = evt.model.__class__.__name__
789        if hasattr(evt.model, "name"):
790            name = evt.model.name
791        model = evt.model
792     
793        # Create a model page. If a new page is created, the model
794        # will be plotted automatically. If a page already exists,
795        # the content will be updated and the plot refreshed
796        self.fit_panel.add_model_page(model,name,topmenu=True)
797   
798   
799   
800   
801    def _update1D(self,x, output):
802        """
803            Update the output of plotting model 1D
804        """
805        self.calc_thread.ready(1)
806   
807    def _fill_default_model2D(self, theory, qmax,qstep, qmin=None):
808        """
809            fill Data2D with default value
810            @param theory: Data2D to fill
811        """
812        from DataLoader.data_info import Detector, Source
813       
814        detector = Detector()
815        theory.detector.append(detector) 
816           
817        theory.detector[0].distance=1e+32
818        theory.source= Source()
819        theory.source.wavelength=2*math.pi/1e+32
820     
821        ## Create detector for Model 2D
822        xmax=2*theory.detector[0].distance*math.atan(\
823                            qmax/(4*math.pi/theory.source.wavelength))
824       
825        theory.detector[0].pixel_size.x= xmax/(qstep/2-0.5)
826        theory.detector[0].pixel_size.y= xmax/(qstep/2-0.5)
827        theory.detector[0].beam_center.x= qmax
828        theory.detector[0].beam_center.y= qmax
829        ## create x_bins and y_bins of the model 2D
830        distance   = theory.detector[0].distance
831        pixel      = qstep/2-1
832        theta      = pixel / distance / qstep#100.0
833        wavelength = theory.source.wavelength
834        pixel_width_x = theory.detector[0].pixel_size.x
835        pixel_width_y = theory.detector[0].pixel_size.y
836        center_x      = theory.detector[0].beam_center.x/pixel_width_x
837        center_y      = theory.detector[0].beam_center.y/pixel_width_y
838       
839       
840        size_x, size_y= numpy.shape(theory.data)
841        for i_x in range(size_x):
842            theta = (i_x-center_x)*pixel_width_x / distance
843            qx = 4.0*math.pi/wavelength * math.tan(theta/2.0)
844            theory.x_bins.append(qx)   
845        for i_y in range(size_y):
846            theta = (i_y-center_y)*pixel_width_y / distance
847            qy =4.0*math.pi/wavelength * math.tan(theta/2.0)
848            theory.y_bins.append(qy)
849           
850        theory.group_id ="Model"
851        theory.id ="Model"
852        ## determine plot boundaries
853        theory.xmin= -qmax
854        theory.xmax= qmax
855        theory.ymin= -qmax
856        theory.ymax= qmax
857       
858       
859    def _get_plotting_info(self, data=None):
860        """
861            get plotting info from data if data !=None
862            else use some default
863        """
864        my_info = PlotInfo()
865        if data !=None:
866            if hasattr(data,"info"):
867                x_name, x_units = data.get_xaxis() 
868                y_name, y_units = data.get_yaxis() 
869               
870                my_info._xunit = x_units
871                my_info._xaxis = x_name
872                my_info._yunit = y_units
873                my_info._yaxis = y_name
874               
875            my_info.title= data.name
876            if hasattr(data, "info"):
877                my_info.info= data.info
878            if hasattr(data, "group_id"):
879                my_info.group_id= data.group_id
880           
881        return my_info
882               
883    def _complete1D(self, x,y, elapsed,model,data=None):
884        """
885            Complete plotting 1D data
886        """ 
887        try:
888            new_plot = Theory1D(x=x, y=y)
889            my_info = self._get_plotting_info( data)
890            new_plot.name = model.name
891            new_plot.id = my_info.id
892            new_plot.group_id = my_info.group_id
893           
894            new_plot.xaxis( my_info._xaxis,  my_info._xunit)
895            new_plot.yaxis( my_info._yaxis, my_info._yunit)
896           
897            # Pass the reset flag to let the plotting event handler
898            # know that we are replacing the whole plot
899            title= my_info.title
900            if title== None:
901                title="Analytical model 1D "
902                wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot,
903                             title= str(title), reset=True ))
904            else:
905                wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot,
906                             title= str(title)))
907           
908        except:
909            msg= " Error occurred when drawing %s Model 1D: "%new_plot.name
910            msg+= " %s"%sys.exc_value
911            wx.PostEvent( self.parent, StatusEvent(status= msg ))
912            return 
913       
914                 
915   
916       
917    def _update2D(self, output,time=None):
918        """
919            Update the output of plotting model
920        """
921        wx.PostEvent(self.parent, StatusEvent(status="Plot \
922        #updating ... ",type="update"))
923        self.calc_thread.ready(0.01)
924       
925       
926    def _complete2D(self, image,data, model,  elapsed,qmin, qmax,qstep=DEFAULT_NPTS):
927        """
928            Complete get the result of modelthread and create model 2D
929            that can be plot.
930        """
931        msg = "Calc complete !"
932        wx.PostEvent( self.parent, StatusEvent( status= msg , type="stop" ))
933   
934        err_image = numpy.zeros(numpy.shape(image))
935        err_image[err_image==0]= 1
936        theory= Data2D(image= image , err_image= err_image)
937        theory.name= model.name
938       
939        if data ==None:
940            self._fill_default_model2D(theory= theory, qmax=qmax,qstep=qstep, qmin= qmin)
941       
942        else:
943            theory.id= "Model"
944            theory.group_id= "Model"+data.name
945            theory.x_bins= data.x_bins
946            theory.y_bins= data.y_bins
947            theory.detector= data.detector
948            theory.source= data.source
949           
950            ## plot boundaries
951            theory.ymin= data.ymin
952            theory.ymax= data.ymax
953            theory.xmin= data.xmin
954            theory.xmax= data.xmax
955       
956        ## plot
957        wx.PostEvent(self.parent, NewPlotEvent(plot=theory,
958                         title="Analytical model 2D ", reset=True ))
959         
960    def _on_data_error(self, event):
961        """
962            receives and event from plotting plu-gins to store the data name and
963            their errors of y coordinates for 1Data hide and show error
964        """
965        self.err_dy= event.err_dy
966         
967    def _draw_model2D(self,model,data=None,description=None, enable2D=False,
968                      qmin=DEFAULT_QMIN, qmax=DEFAULT_QMAX, qstep=DEFAULT_NPTS):
969        """
970            draw model in 2D
971            @param model: instance of the model to draw
972            @param description: the description of the model
973            @param enable2D: when True allows to draw model 2D
974            @param qmin: the minimum value to  draw model 2D
975            @param qmax: the maximum value to draw model 2D
976            @param qstep: the number of division of Qx and Qy of the model to draw
977           
978        """
979       
980        x=  numpy.linspace(start= -1*qmax,
981                               stop= qmax,
982                               num= qstep,
983                               endpoint=True ) 
984        y = numpy.linspace(start= -1*qmax,
985                               stop= qmax,
986                               num= qstep,
987                               endpoint=True )
988        ## use data info instead
989        if data !=None:
990            ## check if data2D to plot
991            if hasattr(data, "x_bins"):
992                enable2D = True
993                x= data.x_bins
994                y= data.y_bins
995           
996        if not enable2D:
997            return
998        try:
999            from model_thread import Calc2D
1000            ## If a thread is already started, stop it
1001            if self.calc_2D != None and self.calc_2D.isrunning():
1002                self.calc_2D.stop()
1003            self.calc_2D = Calc2D(  x= x,
1004                                    y= y,
1005                                    model= model, 
1006                                    data = data,
1007                                    qmin= qmin,
1008                                    qmax= qmax,
1009                                    qstep= qstep,
1010                                    completefn= self._complete2D,
1011                                    updatefn= self._update2D )
1012            self.calc_2D.queue()
1013           
1014        except:
1015            msg= " Error occurred when drawing %s Model 2D: "%model.name
1016            msg+= " %s"%sys.exc_value
1017            wx.PostEvent( self.parent, StatusEvent(status= msg ))
1018            return 
1019   
1020    def _draw_model1D(self, model, data=None, smearer= None,
1021                qmin=DEFAULT_QMIN, qmax=DEFAULT_QMAX, qstep= DEFAULT_NPTS,enable1D= True):
1022        """
1023            Draw model 1D from loaded data1D
1024            @param data: loaded data
1025            @param model: the model to plot
1026        """
1027         
1028        x=  numpy.linspace(start= qmin,
1029                           stop= qmax,
1030                           num= qstep,
1031                           endpoint=True
1032                           )
1033        if data!=None:
1034            ## check for data2D
1035            if hasattr(data,"x_bins"):
1036                return
1037            x = data.x
1038            if qmin == DEFAULT_QMIN :
1039                qmin = min(data.x)
1040            if qmax == DEFAULT_QMAX:
1041                qmax = max(data.x)
1042       
1043        if not enable1D:
1044            return
1045   
1046        try:
1047            from model_thread import Calc1D
1048            ## If a thread is already started, stop it
1049            if self.calc_1D!= None and self.calc_1D.isrunning():
1050                self.calc_1D.stop()
1051            self.calc_1D= Calc1D( x= x,
1052                                  data = data,
1053                                  model= model, 
1054                                  qmin = qmin,
1055                                  qmax = qmax,
1056                                  smearer = smearer,
1057                                  completefn = self._complete1D,
1058                                  updatefn = self._update1D  )
1059            self.calc_1D.queue()
1060           
1061        except:
1062            msg= " Error occurred when drawing %s Model 1D: "%model.name
1063            msg+= " %s"%sys.exc_value
1064            wx.PostEvent( self.parent, StatusEvent(status= msg ))
1065            return 
1066           
1067   
1068
1069
1070   
1071if __name__ == "__main__":
1072    i = Plugin()
1073   
1074   
1075   
1076   
Note: See TracBrowser for help on using the repository browser.