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

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 ed2ea6a was ed2ea6a, checked in by Gervaise Alina <gervyh@…>, 15 years ago

print statement removed

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