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

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

status bar messaged added

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