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

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

bug fixed

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