source: sasview/sansview/perspectives/fitting/fitting.py @ 54905de

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 54905de was 54905de, checked in by Jae Cho <jhjcho@…>, 15 years ago

reversed the last change causing another problem

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