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

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

improve message on gauge of the status bar

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