source: sasview/src/sans/perspectives/fitting/fitting.py @ 949aa2c

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 949aa2c was bf5e985, checked in by pkienzle, 10 years ago

restore simultaneous fitting for bumps

  • Property mode set to 100644
File size: 91.0 KB
Line 
1"""
2    Fitting perspective
3"""
4################################################################################
5#This software was developed by the University of Tennessee as part of the
6#Distributed Data Analysis of Neutron Scattering Experiments (DANSE)
7#project funded by the US National Science Foundation.
8#
9#See the license text in license.txt
10#
11#copyright 2009, University of Tennessee
12################################################################################
13import re
14import sys
15import os
16import wx
17import logging
18import numpy
19import time
20from copy import deepcopy
21import models
22
23from sans.dataloader.loader import Loader
24from sans.guiframe.dataFitting import Data2D
25from sans.guiframe.dataFitting import Data1D
26from sans.guiframe.dataFitting import check_data_validity
27from sans.guiframe.events import NewPlotEvent
28from sans.guiframe.events import StatusEvent 
29from sans.guiframe.events import EVT_SLICER_PANEL
30from sans.guiframe.events import EVT_SLICER_PARS_UPDATE
31from sans.guiframe.gui_style import GUIFRAME_ID
32from sans.guiframe.plugin_base import PluginBase
33from sans.guiframe.data_processor import BatchCell
34from sans.fit.Fitting import Fit
35from .console import ConsoleUpdate
36from .fitproblem import FitProblemDictionary
37from .fitpanel import FitPanel
38from .resultpanel import ResultPanel, PlotResultEvent
39
40from .fit_thread import FitThread
41from .pagestate import Reader
42from .fitpage import Chi2UpdateEvent
43from sans.perspectives.calculator.model_editor import TextDialog
44from sans.perspectives.calculator.model_editor import EditorWindow
45from sans.guiframe.gui_manager import MDIFrame
46
47# TODO: remove globals from interface to bumps options!
48# Default bumps to use the levenberg-marquardt optimizer
49import bumps.fitters
50bumps.fitters.FIT_DEFAULT = 'lm'
51
52MAX_NBR_DATA = 4
53SANS_F_TOL = 5e-05
54
55(PageInfoEvent, EVT_PAGE_INFO) = wx.lib.newevent.NewEvent()
56
57
58if sys.platform == "win32":
59    ON_MAC = False
60else:
61    ON_MAC = True
62
63
64
65class Plugin(PluginBase):
66    """
67    Fitting plugin is used to perform fit
68    """
69    def __init__(self, standalone=False):
70        PluginBase.__init__(self, name="Fitting", standalone=standalone)
71       
72        #list of panel to send to guiframe
73        self.mypanels = []
74        # reference to the current running thread
75        self.calc_2D = None
76        self.calc_1D = None
77       
78        self.color_dict = {}
79       
80        self.fit_thread_list = {}
81        self.residuals = None
82        self.weight = None
83        self.fit_panel = None
84        self.plot_panel = None
85        # Start with a good default
86        self.elapsed = 0.022
87        self.fit_panel = None
88        #Flag to let the plug-in know that it is running stand alone
89        self.standalone = True
90        ## dictionary of page closed and id
91        self.closed_page_dict = {}
92        ## Fit engine
93        self._fit_engine = 'bumps'
94        self._gui_engine = None
95        ## Relative error desired in the sum of squares (float); scipy only
96        self.ftol = SANS_F_TOL
97        self.batch_reset_flag = True
98        #List of selected data
99        self.selected_data_list = []
100        ## list of slicer panel created to display slicer parameters and results
101        self.slicer_panels = []
102        # model 2D view
103        self.model2D_id = None
104        #keep reference of the simultaneous fit page
105        self.sim_page = None
106        self.sim_menu = None
107        self.batch_page = None
108        self.batch_menu = None
109        self.index_model = 0
110        self.test_model_color = None
111        #Create a reader for fit page's state
112        self.state_reader = None
113        self._extensions = '.fitv'
114        self.scipy_id = wx.NewId()
115        self.park_id = wx.NewId()
116        self.bumps_id = wx.NewId()
117        self.menu1 = None
118        self.new_model_frame = None
119       
120        self.temp_state = []
121        self.state_index = 0
122        self.sfile_ext = None
123        # take care of saving  data, model and page associated with each other
124        self.page_finder = {}
125        # Log startup
126        logging.info("Fitting plug-in started")
127        self.batch_capable = self.get_batch_capable()
128   
129    def get_batch_capable(self):
130        """
131        Check if the plugin has a batch capability
132        """
133        return True
134   
135    def create_fit_problem(self, page_id):
136        """
137        Given an ID create a fitproblem container
138        """
139        self.page_finder[page_id] = FitProblemDictionary()
140       
141    def delete_fit_problem(self, page_id):
142        """
143        Given an ID create a fitproblem container
144        """
145        if page_id in self.page_finder.iterkeys():
146            del self.page_finder[page_id]
147       
148    def add_color(self, color, id):
149        """
150        adds a color as a key with a plot id as its value to a dictionary
151        """
152        self.color_dict[id] = color
153       
154    def on_batch_selection(self, flag):
155        """
156        switch the the notebook of batch mode or not
157        """
158        self.batch_on = flag
159        if self.fit_panel is not None:
160            self.fit_panel.batch_on = self.batch_on
161       
162    def populate_menu(self, owner):
163        """
164        Create a menu for the Fitting plug-in
165       
166        :param id: id to create a menu
167        :param owner: owner of menu
168       
169        :return: list of information to populate the main menu
170       
171        """
172        #Menu for fitting
173        self.menu1 = wx.Menu()
174        id1 = wx.NewId()
175        simul_help = "Add new fit panel"
176        self.menu1.Append(id1, '&New Fit Page', simul_help)
177        wx.EVT_MENU(owner, id1, self.on_add_new_page)
178        self.menu1.AppendSeparator()
179        self.id_simfit = wx.NewId()
180        simul_help = "Constrained or Simultaneous Fit"
181        self.menu1.Append(self.id_simfit, '&Constrained or Simultaneous Fit', simul_help)
182        wx.EVT_MENU(owner, self.id_simfit, self.on_add_sim_page)
183        self.sim_menu = self.menu1.FindItemById(self.id_simfit)
184        self.sim_menu.Enable(False)
185        #combined Batch
186        self.id_batchfit = wx.NewId()
187        batch_help = "Combined Batch"
188        self.menu1.Append(self.id_batchfit, '&Combine Batch Fit', batch_help)
189        wx.EVT_MENU(owner, self.id_batchfit, self.on_add_sim_page)
190        self.batch_menu = self.menu1.FindItemById(self.id_batchfit)
191        self.batch_menu.Enable(False)
192        self.menu1.AppendSeparator()
193        #Set park engine
194        scipy_help = "Scipy Engine: Perform Simple fit. More in Help window...."
195        self.menu1.AppendCheckItem(self.scipy_id, "Simple FitEngine [LeastSq]",
196                                   scipy_help)
197        wx.EVT_MENU(owner, self.scipy_id, self._onset_engine_scipy)
198       
199        park_help = "Park Engine: Perform Complex fit. More in Help window...."
200        self.menu1.AppendCheckItem(self.park_id, "Complex FitEngine [ParkMC]",
201                                   park_help)
202        wx.EVT_MENU(owner, self.park_id, self._onset_engine_park)
203       
204        bumps_help = "Bumps: fitting and uncertainty analysis. More in Help window...."
205        self.menu1.AppendCheckItem(self.bumps_id, "Bumps fit",
206                                   bumps_help)
207        wx.EVT_MENU(owner, self.bumps_id, self._onset_engine_bumps)
208       
209        self.menu1.FindItemById(self.scipy_id).Check(self._fit_engine=="scipy")
210        self.menu1.FindItemById(self.park_id).Check(self._fit_engine=="park")
211        self.menu1.FindItemById(self.bumps_id).Check(self._fit_engine=="bumps")
212        self.menu1.AppendSeparator()
213        self.id_tol = wx.NewId()
214        ftol_help = "Change the current FTolerance (=%s) " % str(self.ftol)
215        ftol_help += "of Simple FitEngine..."
216        self.menu1.Append(self.id_tol, "Change FTolerance",
217                                   ftol_help)
218        wx.EVT_MENU(owner, self.id_tol, self.show_ftol_dialog)
219
220        self.id_bumps_options = wx.NewId()
221        bopts_help = "Bumps fitting options"
222        self.menu1.Append(self.id_bumps_options, 'Bumps &Options', bopts_help)
223        wx.EVT_MENU(owner, self.id_bumps_options, self.on_bumps_options)
224        self.bumps_options_menu = self.menu1.FindItemById(self.id_bumps_options)
225        self.bumps_options_menu.Enable(True)
226
227        self.id_result_panel = wx.NewId()
228        self.menu1.Append(self.id_result_panel, "Fit Results", "Show fit results panel")
229        wx.EVT_MENU(owner, self.id_result_panel, lambda ev: self.result_frame.Show())
230        self.menu1.AppendSeparator()
231       
232        self.id_reset_flag = wx.NewId()
233        resetf_help = "BatchFit: If checked, the initial param values will be "
234        resetf_help += "propagated from the previous results. "
235        resetf_help += "Otherwise, the same initial param values will be used "
236        resetf_help += "for all fittings."
237        self.menu1.AppendCheckItem(self.id_reset_flag,
238                                   "Chain Fitting [BatchFit Only]",
239                                   resetf_help)
240        wx.EVT_MENU(owner, self.id_reset_flag, self.on_reset_batch_flag)
241        chain_menu = self.menu1.FindItemById(self.id_reset_flag)
242        chain_menu.Check(not self.batch_reset_flag)
243        chain_menu.Enable(self.batch_on)
244       
245        self.menu1.AppendSeparator()
246        self.edit_model_menu = wx.Menu()
247        # Find and put files name in menu
248        try:
249            self.set_edit_menu(owner=owner)
250        except:
251            raise
252       
253        self.id_edit = wx.NewId()
254        editmodel_help = "Edit customized model sample file"
255        self.menu1.AppendMenu(self.id_edit, "Edit Custom Model",
256                              self.edit_model_menu, editmodel_help)
257        #create  menubar items
258        return [(self.menu1, self.sub_menu)]
259   
260    def edit_custom_model(self, event):
261        """
262        Get the python editor panel
263        """
264        id = event.GetId()
265        label = self.edit_menu.GetLabel(id)
266        from sans.perspectives.calculator.pyconsole import PyConsole
267        filename = os.path.join(models.find_plugins_dir(), label)
268        frame = PyConsole(parent=self.parent, manager=self,
269                          panel=self.fit_panel,
270                          title='Advanced Custom Model Editor',
271                          filename=filename)
272        self.put_icon(frame)
273        frame.Show(True)
274   
275    def delete_custom_model(self, event):
276        """
277        Delete custom model file
278        """
279        id = event.GetId()
280        label = self.delete_menu.GetLabel(id)
281        toks = os.path.splitext(label)
282        path = os.path.join(models.find_plugins_dir(), toks[0])
283        try:
284            for ext in ['.py', '.pyc']:
285                p_path = path + ext
286                os.remove(p_path)
287            self.update_custom_combo()
288            if os.path.isfile(p_path):
289                msg = "Sorry! Could not be able to delete the default "
290                msg += "custom model... \n"
291                msg += "Please manually remove the files (.py, .pyc) "
292                msg += "in the 'plugin_models' folder \n"
293                msg += "inside of the SansView application, "
294                msg += "and try it again."
295                wx.MessageBox(msg, 'Info')
296                #wx.PostEvent(self.parent, StatusEvent(status=msg, type='stop',
297                #                                      info='warning'))
298            else:
299                self.delete_menu.Delete(id)
300                for item in self.edit_menu.GetMenuItems():
301                    if item.GetLabel() == label:
302                        self.edit_menu.DeleteItem(item)
303                        msg = "The custom model, %s, has been deleted."% label
304                        wx.PostEvent(self.parent, StatusEvent(status=msg, 
305                                                type='stop', info='info'))
306                        break
307        except:
308            msg ='Delete Error: \nCould not delete the file; Check if in use.'
309            wx.MessageBox(msg, 'Error')
310   
311    def make_sum_model(self, event):
312        """
313        Edit summodel template and make one
314        """
315        id = event.GetId()
316        model_manager = models.ModelManager()
317        model_list = model_manager.get_model_name_list()
318        plug_dir = models.find_plugins_dir()
319        textdial = TextDialog(None, self, -1, 'Easy Sum/Multi(p1, p2) Editor', 
320                              model_list, plug_dir)
321        self.put_icon(textdial)
322        textdial.ShowModal()
323        textdial.Destroy()
324   
325    def make_new_model(self, event):
326        """
327        Make new model
328        """
329        if self.new_model_frame != None:
330            self.new_model_frame.Show(False)
331            self.new_model_frame.Show(True)
332        else:
333            id = event.GetId()
334            dir_path = models.find_plugins_dir()
335            title = "New Custom Model Function"
336            self.new_model_frame = EditorWindow(parent=self, base=self,
337                                                path=dir_path, title=title)
338            self.put_icon(self.new_model_frame)
339        self.new_model_frame.Show(True)
340
341    def update_custom_combo(self):
342        """
343        Update custom model list in the fitpage combo box
344        """
345        custom_model = 'Customized Models'
346        try:
347            # Update edit menus
348            self.set_edit_menu_helper(self.parent, self.edit_custom_model)
349            self.set_edit_menu_helper(self.parent, self.delete_custom_model)
350            temp = self.fit_panel.reset_pmodel_list()
351            if temp:
352                # Set the new custom model list for all fit pages
353                for uid, page in self.fit_panel.opened_pages.iteritems():
354                    if hasattr(page, "formfactorbox"):
355                        page.model_list_box = temp
356                        current_val = page.formfactorbox.GetLabel()
357                        #if page.plugin_rbutton.GetValue():
358                        mod_cat = page.categorybox.GetStringSelection()
359                        if mod_cat == custom_model:
360                            #pos = page.formfactorbox.GetSelection()
361                            page._show_combox_helper()
362                            new_val = page.formfactorbox.GetLabel()
363                            if current_val != new_val and new_val != '':
364                                page.formfactorbox.SetLabel(new_val)
365                            else:
366                                page.formfactorbox.SetLabel(current_val)
367        except:
368            pass
369       
370       
371    def set_edit_menu(self, owner):
372        """
373        Set list of the edit model menu labels
374        """
375        id = wx.NewId()
376        #new_model_menu = wx.Menu()
377        self.edit_model_menu.Append(id, 'New',
378                                   'Add a new model function')
379        wx.EVT_MENU(owner, id, self.make_new_model)
380        id = wx.NewId()
381        self.edit_model_menu.Append(id, 'Sum|Multi(p1, p2)',
382                                    'Sum of two model functions')
383        wx.EVT_MENU(owner, id, self.make_sum_model)
384        e_id = wx.NewId()
385        self.edit_menu = wx.Menu()
386        self.edit_model_menu.AppendMenu(e_id, 
387                                    'Advanced', self.edit_menu) 
388        self.set_edit_menu_helper(owner, self.edit_custom_model)
389
390        d_id = wx.NewId()
391        self.delete_menu = wx.Menu()
392        self.edit_model_menu.AppendMenu(d_id,
393                                        'Delete', self.delete_menu)
394        self.set_edit_menu_helper(owner, self.delete_custom_model)
395   
396    def set_edit_menu_helper(self, owner=None, menu=None):
397        """
398        help for setting list of the edit model menu labels
399        """
400        if menu == None:
401            menu = self.edit_custom_model
402        list_fnames = os.listdir(models.find_plugins_dir())
403        list_fnames.sort()
404        for f_item in list_fnames:
405            name = os.path.basename(f_item)
406            toks = os.path.splitext(name)
407            if toks[-1] == '.py' and not toks[0] == '__init__':
408                if menu == self.edit_custom_model:
409                    if toks[0] == 'easy_sum_of_p1_p2':
410                        continue
411                    submenu = self.edit_menu
412                else:
413                    submenu = self.delete_menu
414                has_file = False
415                for item in submenu.GetMenuItems():
416                    if name == submenu.GetLabel(item.GetId()):
417                        has_file = True
418                if not has_file:
419                    id = wx.NewId()
420                    submenu.Append(id, name)
421                    wx.EVT_MENU(owner, id, menu)
422                    has_file = False
423
424    def put_icon(self, frame):
425        """
426        Put icon in the frame title bar
427        """
428        if hasattr(frame, "IsIconized"):
429            if not frame.IsIconized():
430                try:
431                    icon = self.parent.GetIcon()
432                    frame.SetIcon(icon)
433                except:
434                    pass
435
436    def on_add_sim_page(self, event):
437        """
438        Create a page to access simultaneous fit option
439        """
440        id = event.GetId()
441        caption = "Const & Simul Fit"
442        page = self.sim_page
443        if id == self.id_batchfit:
444            caption = "Combined Batch"
445            page = self.batch_page
446           
447        def set_focus_page(page):
448            page.Show(True)
449            page.Refresh()
450            page.SetFocus()
451            #self.parent._mgr.Update()
452            msg = "%s already opened\n" % str(page.window_caption)
453            wx.PostEvent(self.parent, StatusEvent(status=msg))
454           
455        if page != None:
456            return set_focus_page(page)
457        if caption == "Const & Simul Fit":
458            self.sim_page = self.fit_panel.add_sim_page(caption=caption)
459        else:
460            self.batch_page = self.fit_panel.add_sim_page(caption=caption)
461       
462    def help(self, evt):
463        """
464        Show a general help dialog.
465        """
466        from help_panel import  HelpWindow
467        frame = HelpWindow(None, -1, 'HelpWindow')
468        if hasattr(frame, "IsIconized"):
469            if not frame.IsIconized():
470                try:
471                    icon = self.parent.GetIcon()
472                    frame.SetIcon(icon)
473                except:
474                    pass
475        frame.Show(True)
476       
477    def get_context_menu(self, plotpanel=None):
478        """
479        Get the context menu items available for P(r).them allow fitting option
480        for Data2D and Data1D only.
481       
482        :param graph: the Graph object to which we attach the context menu
483       
484        :return: a list of menu items with call-back function
485       
486        :note: if Data1D was generated from Theory1D
487                the fitting option is not allowed
488               
489        """
490        self.plot_panel = plotpanel
491        graph = plotpanel.graph
492        fit_option = "Select data for fitting"
493        fit_hint =  "Dialog with fitting parameters "
494       
495        if graph.selected_plottable not in plotpanel.plots:
496            return []
497        item = plotpanel.plots[graph.selected_plottable]
498        if item.__class__.__name__ is "Data2D":
499            if hasattr(item, "is_data"):
500                if item.is_data:
501                    return [[fit_option, fit_hint, self._onSelect]]
502                else:
503                    return [] 
504            return [[fit_option, fit_hint, self._onSelect]]
505        else:
506           
507            # if is_data is true , this in an actual data loaded
508            #else it is a data created from a theory model
509            if hasattr(item, "is_data"):
510                if item.is_data:
511                    return [[fit_option, fit_hint, self._onSelect]]
512                else:
513                    return []
514            return [[fit_option, fit_hint, self._onSelect]]
515        return []
516
517    def get_panels(self, parent):
518        """
519        Create and return a list of panel objects
520        """
521        self.parent = parent
522        #self.parent.Bind(EVT_FITSTATE_UPDATE, self.on_set_state_helper)
523        # Creation of the fit panel
524        self.frame = MDIFrame(self.parent, None, 'None', (100, 200))
525        self.fit_panel = FitPanel(parent=self.frame, manager=self)
526        self.frame.set_panel(self.fit_panel)
527        self._frame_set_helper()
528        self.on_add_new_page(event=None)
529        #Set the manager for the main panel
530        self.fit_panel.set_manager(self)
531        # List of windows used for the perspective
532        self.perspective = []
533        self.perspective.append(self.fit_panel.window_name)
534
535        self.result_frame = MDIFrame(self.parent, None, ResultPanel.window_caption, (220, 200))
536        self.result_panel = ResultPanel(parent=self.result_frame, manager=self)
537        self.perspective.append(self.result_panel.window_name)
538       
539        #index number to create random model name
540        self.index_model = 0
541        self.index_theory = 0
542        self.parent.Bind(EVT_SLICER_PANEL, self._on_slicer_event)
543        self.parent.Bind(EVT_SLICER_PARS_UPDATE, self._onEVT_SLICER_PANEL)
544        #self.parent._mgr.Bind(wx.aui.EVT_AUI_PANE_CLOSE,self._onclearslicer)
545        #Create reader when fitting panel are created
546        self.state_reader = Reader(self.set_state)
547        #append that reader to list of available reader
548        loader = Loader()
549        loader.associate_file_reader(".fitv", self.state_reader)
550        #Send the fitting panel to guiframe
551        self.mypanels.append(self.fit_panel)
552        self.mypanels.append(self.result_panel)
553        return self.mypanels
554   
555    def clear_panel(self):
556        """
557        """
558        self.fit_panel.clear_panel()
559       
560    def set_default_perspective(self):
561        """
562        Call back method that True to notify the parent that the current plug-in
563        can be set as default perspective.
564        when returning False, the plug-in is not candidate for an automatic
565        default perspective setting
566        """
567        return True
568   
569    def delete_data(self, data):
570        """
571        delete  the given data from panel
572        """
573        self.fit_panel.delete_data(data)
574       
575    def set_data(self, data_list=None):
576        """
577        receive a list of data to fit
578        """
579        if data_list is None:
580            data_list = []
581        selected_data_list = []
582        if self.batch_on:
583            page = self.add_fit_page(data=data_list)
584        else:
585            if len(data_list) > MAX_NBR_DATA:
586                from fitting_widgets import DataDialog
587                dlg = DataDialog(data_list=data_list, nb_data=MAX_NBR_DATA)
588                if dlg.ShowModal() == wx.ID_OK:
589                    selected_data_list = dlg.get_data()
590                dlg.Destroy()
591               
592            else:
593                selected_data_list = data_list
594            try:
595                group_id = wx.NewId()
596                for data in selected_data_list:
597                    if data is not None:
598                        # 2D has no same group_id
599                        if data.__class__.__name__ == 'Data2D':
600                            group_id = wx.NewId()
601                        data.group_id = group_id
602                        if group_id not in data.list_group_id:
603                            data.list_group_id.append(group_id)
604                        page = self.add_fit_page(data=[data])
605            except:
606                msg = "Fitting Set_data: " + str(sys.exc_value)
607                wx.PostEvent(self.parent, StatusEvent(status=msg, info="error"))
608   
609    def set_theory(self, theory_list=None):
610        """
611        """
612        #set the model state for a given theory_state:
613        for item in theory_list:
614            try:
615                _, theory_state = item
616                self.fit_panel.set_model_state(theory_state)
617            except:
618                msg = "Fitting: cannot deal with the theory received"
619                logging.error("set_theory " + msg + "\n" + str(sys.exc_value))
620                wx.PostEvent(self.parent,
621                             StatusEvent(status=msg, info="error"))
622           
623    def set_state(self, state=None, datainfo=None, format=None):
624        """
625        Call-back method for the fit page state reader.
626        This method is called when a .fitv/.svs file is loaded.
627       
628        : param state: PageState object
629        : param datainfo: data
630        """
631        #state = self.state_reader.get_state()
632        if state != None:
633            state = state.clone()
634            # store fitting state in temp_state
635            self.temp_state.append(state)
636        else:
637            self.temp_state = []
638        # index to start with for a new set_state
639        self.state_index = 0
640        # state file format
641        self.sfile_ext = format
642       
643        self.on_set_state_helper(event=None)
644
645    def  on_set_state_helper(self, event=None):
646        """
647        Set_state_helper. This actually sets state
648        after plotting data from state file.
649       
650        : event: FitStateUpdateEvent called
651            by dataloader.plot_data from guiframe
652        """
653        if len(self.temp_state) == 0:
654            if self.state_index == 0 and len(self.mypanels) <= 0 \
655            and self.sfile_ext == '.svs':
656                self.temp_state = []
657                self.state_index = 0
658            return
659       
660        try:
661            # Load fitting state
662            state = self.temp_state[self.state_index]
663            #panel state should have model selection to set_state
664            if state.formfactorcombobox != None:
665                #set state
666                data = self.parent.create_gui_data(state.data)
667                data.group_id = state.data.group_id
668                self.parent.add_data(data_list={data.id: data})
669                wx.PostEvent(self.parent, NewPlotEvent(plot=data,
670                                        title=data.title))
671                #need to be fix later make sure we are sendind guiframe.data
672                #to panel
673                state.data = data
674                page = self.fit_panel.set_state(state)
675            else:
676                #just set data because set_state won't work
677                data = self.parent.create_gui_data(state.data)
678                data.group_id = state.data.group_id
679                self.parent.add_data(data_list={data.id: data})
680                wx.PostEvent(self.parent, NewPlotEvent(plot=data,
681                                        title=data.title))
682                page = self.add_fit_page([data])
683                caption = page.window_caption
684                self.store_data(uid=page.uid, data_list=page.get_data_list(),
685                        caption=caption)
686                self.mypanels.append(page)
687               
688            # get ready for the next set_state
689            self.state_index += 1
690
691            #reset state variables to default when all set_state is finished.
692            if len(self.temp_state) == self.state_index:
693               
694                self.temp_state = []
695                #self.state_index = 0
696                # Make sure the user sees the fitting panel after loading
697                #self.parent.set_perspective(self.perspective)
698                self.on_perspective(event=None)
699        except:
700            self.state_index = 0
701            self.temp_state = []
702            raise
703       
704    def set_param2fit(self, uid, param2fit):
705        """
706        Set the list of param names to fit for fitprobelm
707        """
708        self.page_finder[uid].set_param2fit(param2fit)
709       
710    def set_graph_id(self, uid, graph_id):
711        """
712        Set graph_id for fitprobelm
713        """
714        self.page_finder[uid].set_graph_id(graph_id)
715       
716    def get_graph_id(self, uid):
717        """
718        Set graph_id for fitprobelm
719        """
720        return self.page_finder[uid].get_graph_id()
721                         
722    def save_fit_state(self, filepath, fitstate):
723        """
724        save fit page state into file
725        """
726        self.state_reader.write(filename=filepath, fitstate=fitstate)
727
728    def set_fit_weight(self, uid, flag, is2d=False, fid=None):
729        """
730        Set the fit weights of a given page for all
731        its data by default. If fid is provide then set the range
732        only for the data with fid as id
733        :param uid: id corresponding to a fit page
734        :param fid: id corresponding to a fit problem (data, model)
735        :param weight: current dy data
736        """
737        if uid in self.page_finder.keys():
738            self.page_finder[uid].set_weight(flag=flag, is2d=is2d)
739                   
740    def set_fit_range(self, uid, qmin, qmax, fid=None):
741        """
742        Set the fitting range of a given page for all
743        its data by default. If fid is provide then set the range
744        only for the data with fid as id
745        :param uid: id corresponding to a fit page
746        :param fid: id corresponding to a fit problem (data, model)
747        :param qmin: minimum  value of the fit range
748        :param qmax: maximum  value of the fit range
749        """
750        if uid in self.page_finder.keys():
751            self.page_finder[uid].set_range(qmin=qmin, qmax=qmax, fid=fid)
752     
753    def schedule_for_fit(self, value=0, uid=None):
754        """
755        Set the fit problem field to 0 or 1 to schedule that problem to fit.
756        Schedule the specified fitproblem or get the fit problem related to
757        the current page and set value.
758        :param value: integer 0 or 1
759        :param uid: the id related to a page contaning fitting information
760        """
761        if uid in self.page_finder.keys():
762            self.page_finder[uid].schedule_tofit(value)
763         
764    def get_page_finder(self):
765        """
766        return self.page_finder used also by simfitpage.py
767        """
768        return self.page_finder
769   
770    def set_page_finder(self, modelname, names, values):
771        """
772        Used by simfitpage.py to reset a parameter given the string constrainst.
773         
774        :param modelname: the name ot the model for with the parameter
775                            has to reset
776        :param value: can be a string in this case.
777        :param names: the paramter name
778         
779        :note: expecting park used for fit.
780         
781        """
782        sim_page_id = self.sim_page.uid
783        for uid, value in self.page_finder.iteritems():
784            if uid != sim_page_id and uid != self.batch_page.uid:
785                list = value.get_model()
786                model = list[0]
787                if model.name == modelname:
788                    value.set_model_param(names, values)
789                    break
790         
791    def split_string(self, item):
792        """
793        receive a word containing dot and split it. used to split parameterset
794        name into model name and parameter name example: ::
795       
796            paramaterset (item) = M1.A
797            Will return model_name = M1 , parameter name = A
798           
799        """
800        if item.find(".") >= 0:
801            param_names = re.split("\.", item)
802            model_name = param_names[0]
803            ##Assume max len is 3; eg., M0.radius.width
804            if len(param_names) == 3:
805                param_name = param_names[1] + "." + param_names[2]
806            else:
807                param_name = param_names[1]
808            return model_name, param_name
809   
810    def set_ftol(self, ftol=None):
811        """
812        Set ftol: Relative error desired in the sum of chi squares.
813        """
814        # check if it is flaot
815        try:
816            f_tol = float(ftol)
817        except:
818            # default
819            f_tol = SANS_F_TOL
820           
821        self.ftol = f_tol
822        # update ftol menu help strings
823        ftol_help = "Change the current FTolerance (=%s) " % str(self.ftol)
824        ftol_help += "of Simple FitEngine..."
825        if self.menu1 != None:
826            self.menu1.SetHelpString(self.id_tol, ftol_help)
827       
828    def show_ftol_dialog(self, event=None):
829        """
830        Dialog to select ftol for Scipy
831        """
832        from ftol_dialog import ChangeFtol
833        dialog = ChangeFtol(self.parent, self)
834        result = dialog.ShowModal()
835        if result == wx.ID_OK:
836            value = dialog.get_ftol()
837            if value is not None:
838                self.set_ftol(value)
839                msg = "The ftol (LeastSq) is set to %s." % value
840            else:
841                msg = "Error in the selection... No change in ftol."
842            # post event for info
843            wx.PostEvent(self.parent,
844                         StatusEvent(status=msg, info='warning'))
845        dialog.Destroy()
846
847    def on_bumps_options(self, event=None):
848        from bumps.gui.fit_dialog import OpenFitOptions
849        OpenFitOptions()
850
851    def stop_fit(self, uid):
852        """
853        Stop the fit engine
854        """
855        if uid in self.fit_thread_list.keys():
856            calc_fit = self.fit_thread_list[uid]
857            if calc_fit is not  None and calc_fit.isrunning():
858                calc_fit.stop()
859                msg = "Fit stop!"
860                wx.PostEvent(self.parent, StatusEvent(status=msg, type="stop"))
861            del self.fit_thread_list[uid]
862        #set the fit button label of page when fit stop is trigger from
863        #simultaneous fit pane
864        sim_flag = self.sim_page is not None and uid == self.sim_page.uid
865        batch_flag = self.batch_page is not None and uid == self.batch_page.uid
866        if sim_flag or batch_flag:
867            for uid, value in self.page_finder.iteritems():
868                if value.get_scheduled() == 1:
869                    if uid in self.fit_panel.opened_pages.keys():
870                        panel = self.fit_panel.opened_pages[uid]
871                        panel._on_fit_complete()
872 
873    def set_smearer(self, uid, smearer, fid, qmin=None, qmax=None, draw=True,
874                    enable_smearer=False):
875        """
876        Get a smear object and store it to a fit problem of fid as id. If proper
877        flag is enable , will plot the theory with smearing information.
878       
879        :param smearer: smear object to allow smearing data of id fid
880        :param enable_smearer: Define whether or not all (data, model) contained
881            in the structure of id uid will be smeared before fitting.
882        :param qmin: the maximum value of the theory plotting range
883        :param qmax: the maximum value of the theory plotting range
884        :param draw: Determine if the theory needs to be plot
885        """
886        if uid not in self.page_finder.keys():
887            return
888        self.page_finder[uid].enable_smearing(flag=enable_smearer)
889        self.page_finder[uid].set_smearer(smearer, fid=fid)
890        if draw:
891            ## draw model 1D with smeared data
892            data = self.page_finder[uid].get_fit_data(fid=fid)
893            if data is None:
894                msg = "set_mearer requires at least data.\n"
895                msg += "Got data = %s .\n" % str(data)
896                return
897                #raise ValueError, msg
898            model = self.page_finder[uid].get_model(fid=fid)
899            if model is None:
900                return
901            enable1D = issubclass(data.__class__, Data1D)
902            enable2D = issubclass(data.__class__, Data2D)
903            ## if user has already selected a model to plot
904            ## redraw the model with data smeared
905            smear = self.page_finder[uid].get_smearer(fid=fid)
906
907            # compute weight for the current data
908            weight = self.page_finder[uid].get_weight(fid=fid)
909
910            self.draw_model(model=model, data=data, page_id=uid, smearer=smear,
911                enable1D=enable1D, enable2D=enable2D,
912                qmin=qmin, qmax=qmax, weight=weight)
913            self._mac_sleep(0.2)
914           
915    def _mac_sleep(self, sec=0.2):
916        """
917        Give sleep to MAC
918        """
919        if ON_MAC:
920            time.sleep(sec)
921       
922    def draw_model(self, model, page_id, data=None, smearer=None,
923                   enable1D=True, enable2D=False,
924                   state=None,
925                   fid=None,
926                   toggle_mode_on=False,
927                   qmin=None, qmax=None,
928                   update_chisqr=True, weight=None, source='model'):
929        """
930        Draw model.
931       
932        :param model: the model to draw
933        :param name: the name of the model to draw
934        :param data: the data on which the model is based to be drawn
935        :param description: model's description
936        :param enable1D: if true enable drawing model 1D
937        :param enable2D: if true enable drawing model 2D
938        :param qmin:  Range's minimum value to draw model
939        :param qmax:  Range's maximum value to draw model
940        :param qstep: number of step to divide the x and y-axis
941        :param update_chisqr: update chisqr [bool]
942             
943        """
944        #self.weight = weight
945        if issubclass(data.__class__, Data1D) or not enable2D:
946            ## draw model 1D with no loaded data
947            self._draw_model1D(model=model,
948                               data=data,
949                               page_id=page_id,
950                               enable1D=enable1D,
951                               smearer=smearer,
952                               qmin=qmin,
953                               qmax=qmax,
954                               fid=fid,
955                               weight=weight,
956                               toggle_mode_on=toggle_mode_on,
957                               state=state,
958                               update_chisqr=update_chisqr,
959                               source=source)
960        else:
961            ## draw model 2D with no initial data
962            self._draw_model2D(model=model,
963                                page_id=page_id,
964                                data=data,
965                                enable2D=enable2D,
966                                smearer=smearer,
967                                qmin=qmin,
968                                qmax=qmax,
969                                fid=fid,
970                                weight=weight,
971                                state=state,
972                                toggle_mode_on=toggle_mode_on,
973                                update_chisqr=update_chisqr,
974                                source=source)
975           
976    def onFit(self, uid):
977        """
978        Get series of data, model, associates parameters and range and send then
979        to  series of fit engines. Fit data and model, display result to
980        corresponding panels.
981        :param uid: id related to the panel currently calling this fit function.
982        """
983        if uid is None: raise RuntimeError("no page to fit") # Should never happen
984
985        # Remember the user selected fit engine before the fit.  Simultaneous
986        # fitting may change the selected engine, so it needs to be restored
987        # when the fit is complete.
988        self._gui_engine = self._fit_engine
989
990        sim_page_uid = getattr(self.sim_page, 'uid', None)
991        batch_page_uid = getattr(self.batch_page, 'uid', None)
992
993        if uid == sim_page_uid:
994            fit_type = 'simultaneous'
995        elif uid == batch_page_uid:
996            fit_type = 'combined_batch'
997        else:
998            fit_type = 'single'
999
1000        # if constrained fit, don't use scipy leastsq directly
1001        if fit_type == 'simultaneous':
1002            if self._fit_engine not in ("park","bumps"):
1003                self._on_change_engine(engine='bumps')
1004
1005
1006        fitter_list = []
1007        sim_fitter = None
1008        if fit_type == 'simultaneous':
1009            #simulatanous fit only one engine need to be created
1010            sim_fitter = Fit(self._fit_engine)
1011            sim_fitter.fitter_id = self.sim_page.uid
1012            fitter_list.append(sim_fitter)
1013
1014        self.current_pg = None
1015        list_page_id = []
1016        fit_id = 0
1017        for page_id, page_info in self.page_finder.iteritems():
1018            # For simulfit (uid give with None), do for-loop
1019            # if uid is specified (singlefit), do it only on the page.
1020            if page_id in (sim_page_uid, batch_page_uid): continue
1021            if fit_type == "single" and page_id != uid: continue
1022
1023            try:
1024                if page_info.get_scheduled() == 1:
1025                    page_info.nbr_residuals_computed = 0
1026                    page = self.fit_panel.get_page_by_id(page_id)
1027                    self.set_fit_weight(uid=page.uid,
1028                                     flag=page.get_weight_flag(),
1029                                     is2d=page._is_2D())
1030                    if not page.param_toFit:
1031                        msg = "No fitting parameters for %s"%page.window_caption
1032                        wx.PostEvent(page.parent.parent,
1033                                     StatusEvent(status=msg, info="error",
1034                                                 type="stop"))
1035                        return False
1036                    if not page._update_paramv_on_fit():
1037                        msg = "Fitting range or parameter values are"
1038                        msg += " invalid in %s" % \
1039                                    page.window_caption
1040                        wx.PostEvent(page.parent.parent,
1041                                     StatusEvent(status=msg, info="error",
1042                                     type="stop"))
1043                        return False
1044
1045                    pars = [str(element[1]) for element in page.param_toFit]
1046                    fitproblem_list = page_info.values()
1047                    for fitproblem in  fitproblem_list:
1048                        if sim_fitter is None:
1049                            fitter = Fit(self._fit_engine)
1050                            fitter.fitter_id = page_id
1051                            fitter_list.append(fitter)
1052                        else:
1053                            fitter = sim_fitter
1054                        self._add_problem_to_fit(fitproblem=fitproblem,
1055                                             pars=pars,
1056                                             fitter=fitter,
1057                                             fit_id=fit_id)
1058                        fit_id += 1
1059                    list_page_id.append(page_id)
1060                    page_info.clear_model_param()
1061            except KeyboardInterrupt:
1062                msg = "Fitting terminated"
1063                wx.PostEvent(self.parent, StatusEvent(status=msg, info="info",
1064                                                      type="stop"))
1065                return True
1066            except:
1067                msg = "Fitting error: %s" % str(sys.exc_value)
1068                wx.PostEvent(self.parent, StatusEvent(status=msg, info="error",
1069                                                      type="stop"))
1070                return False
1071        ## If a thread is already started, stop it
1072        #if self.calc_fit!= None and self.calc_fit.isrunning():
1073        #    self.calc_fit.stop()
1074        msg = "Fitting is in progress..."
1075        wx.PostEvent(self.parent, StatusEvent(status=msg, type="progress"))
1076       
1077        #Handler used for park engine displayed message
1078        handler = ConsoleUpdate(parent=self.parent,
1079                                manager=self,
1080                                improvement_delta=0.1)
1081        self._mac_sleep(0.2)
1082
1083        # batch fit
1084        batch_inputs = {}
1085        batch_outputs = {}
1086        if fit_type == "simultaneous":
1087            page = self.sim_page
1088        elif fit_type == "combined_batch":
1089            page = self.batch_page
1090        else:
1091            page = self.fit_panel.get_page_by_id(uid)
1092        if page.batch_on:
1093            calc_fit = FitThread(handler=handler,
1094                                 fn=fitter_list,
1095                                 pars=pars,
1096                                 batch_inputs=batch_inputs,
1097                                 batch_outputs=batch_outputs,
1098                                 page_id=list_page_id,
1099                                 completefn=self._batch_fit_complete,
1100                                 ftol=self.ftol,
1101                                 reset_flag=self.batch_reset_flag)
1102        else:
1103            ## Perform more than 1 fit at the time
1104            calc_fit = FitThread(handler=handler,
1105                                    fn=fitter_list,
1106                                    batch_inputs=batch_inputs,
1107                                    batch_outputs=batch_outputs,
1108                                    page_id=list_page_id,
1109                                    updatefn=handler.update_fit,
1110                                    completefn=self._fit_completed,
1111                                    ftol=self.ftol)
1112        #self.fit_thread_list[current_page_id] = calc_fit
1113        self.fit_thread_list[uid] = calc_fit
1114        calc_fit.queue()
1115        calc_fit.ready(2.5)
1116        msg = "Fitting is in progress..."
1117        wx.PostEvent(self.parent, StatusEvent(status=msg, type="progress"))
1118       
1119        return True
1120
1121    def remove_plot(self, uid, fid=None, theory=False):
1122        """
1123        remove model plot when a fit page is closed
1124        :param uid: the id related to the fitpage to close
1125        :param fid: the id of the fitproblem(data, model, range,etc)
1126        """
1127        if uid not in self.page_finder.keys():
1128            return
1129        fitproblemList = self.page_finder[uid].get_fit_problem(fid)
1130        for fitproblem in fitproblemList:
1131            data = fitproblem.get_fit_data()
1132            model = fitproblem.get_model()
1133            plot_id = None
1134            if model is not None:
1135                plot_id = data.id + model.name
1136            if theory:
1137                plot_id = data.id + model.name
1138            group_id = data.group_id
1139            wx.PostEvent(self.parent, NewPlotEvent(id=plot_id,
1140                                                   group_id=group_id,
1141                                                   action='remove'))
1142           
1143    def store_data(self, uid, data_list=None, caption=None):
1144        """
1145        Recieve a list of data and store them ans well as a caption of
1146        the fit page where they come from.
1147        :param uid: if related to a fit page
1148        :param data_list: list of data to fit
1149        :param caption: caption of the window related to these data
1150        """
1151        if data_list is None:
1152            data_list = []
1153       
1154        self.page_finder[uid].set_fit_data(data=data_list)
1155        if caption is not None:
1156            self.page_finder[uid].set_fit_tab_caption(caption=caption)
1157           
1158    def on_add_new_page(self, event=None):
1159        """
1160        ask fit panel to create a new empty page
1161        """
1162        try:
1163            page = self.fit_panel.add_empty_page()
1164            # add data associated to the page created
1165            if page != None:
1166                wx.PostEvent(self.parent, StatusEvent(status="Page Created",
1167                                               info="info"))
1168            else:
1169                msg = "Page was already Created"
1170                wx.PostEvent(self.parent, StatusEvent(status=msg,
1171                                                       info="warning"))
1172        except:
1173            msg = "Creating Fit page: %s"%sys.exc_value
1174            wx.PostEvent(self.parent, StatusEvent(status=msg, info="error"))
1175       
1176    def add_fit_page(self, data):
1177        """
1178        given a data, ask to the fitting panel to create a new fitting page,
1179        get this page and store it into the page_finder of this plug-in
1180        :param data: is a list of data
1181        """
1182        page = self.fit_panel.set_data(data)
1183        # page could be None when loading state files
1184        if page == None:
1185            return page
1186        #append Data1D to the panel containing its theory
1187        #if theory already plotted
1188        if page.uid in self.page_finder:
1189            data = page.get_data()
1190            theory_data = self.page_finder[page.uid].get_theory_data(data.id)
1191            if issubclass(data.__class__, Data2D):
1192                data.group_id = wx.NewId()
1193                if theory_data is not None:
1194                    group_id = str(page.uid) + " Model1D"
1195                    wx.PostEvent(self.parent,
1196                             NewPlotEvent(group_id=group_id,
1197                                               action="delete"))
1198                    self.parent.update_data(prev_data=theory_data,
1199                                             new_data=data)
1200            else:
1201                if theory_data is not None:
1202                    group_id = str(page.uid) + " Model2D"
1203                    data.group_id = theory_data.group_id
1204                    wx.PostEvent(self.parent, 
1205                             NewPlotEvent(group_id=group_id,
1206                                               action="delete"))
1207                    self.parent.update_data(prev_data=theory_data,
1208                                             new_data=data)
1209        self.store_data(uid=page.uid, data_list=page.get_data_list(),
1210                        caption=page.window_caption)
1211        if self.sim_page is not None and not self.batch_on:
1212            self.sim_page.draw_page()
1213        if self.batch_page is not None and self.batch_on:
1214            self.batch_page.draw_page()
1215           
1216        return page
1217           
1218    def _onEVT_SLICER_PANEL(self, event):
1219        """
1220        receive and event telling to update a panel with a name starting with
1221        event.panel_name. this method update slicer panel
1222        for a given interactor.
1223       
1224        :param event: contains type of slicer , paramaters for updating
1225            the panel and panel_name to find the slicer 's panel concerned.
1226        """
1227        event.panel_name
1228        for item in self.parent.panels:
1229            name = event.panel_name
1230            if self.parent.panels[item].window_caption.startswith(name):
1231                self.parent.panels[item].set_slicer(event.type, event.params)
1232               
1233        #self.parent._mgr.Update()
1234   
1235    def _closed_fitpage(self, event):
1236        """
1237        request fitpanel to close a given page when its unique data is removed
1238        from the plot. close fitpage only when the a loaded data is removed
1239        """
1240        if event is None or event.data is None:
1241            return
1242        if hasattr(event.data, "is_data"):
1243            if not event.data.is_data or \
1244                event.data.__class__.__name__ == "Data1D":
1245                self.fit_panel.close_page_with_data(event.data)
1246 
1247    def _reset_schedule_problem(self, value=0, uid=None):
1248        """
1249        unschedule or schedule all fitproblem to be fit
1250        """
1251        # case that uid is not specified
1252        if uid == None:
1253            for page_id in self.page_finder.keys():
1254                self.page_finder[page_id].schedule_tofit(value)
1255        # when uid is given
1256        else:
1257            if uid in self.page_finder.keys():
1258                self.page_finder[uid].schedule_tofit(value)
1259               
1260    def _add_problem_to_fit(self, fitproblem, pars, fitter, fit_id):
1261        """
1262        Create and set fit engine with series of data and model
1263        :param pars: list of fittable parameters
1264        :param fitter_list: list of fit engine
1265        :param value:  structure storing data mapped to their model, range etc.
1266        """
1267        data = fitproblem.get_fit_data()
1268        model = fitproblem.get_model()
1269        smearer = fitproblem.get_smearer()
1270        qmin, qmax = fitproblem.get_range()
1271
1272        #Extra list of parameters and their constraints
1273        listOfConstraint = []
1274        param = fitproblem.get_model_param()
1275        if len(param) > 0:
1276            for item in param:
1277                ## check if constraint
1278                if item[0] != None and item[1] != None:
1279                    listOfConstraint.append((item[0], item[1]))
1280        new_model = model
1281        fitter.set_model(new_model, fit_id, pars, data=data,
1282                         constraints=listOfConstraint)
1283        fitter.set_data(data=data, id=fit_id, smearer=smearer, qmin=qmin,
1284                        qmax=qmax)
1285        fitter.select_problem_for_fit(id=fit_id, value=1)
1286       
1287    def _onSelect(self, event):
1288        """
1289        when Select data to fit a new page is created .Its reference is
1290        added to self.page_finder
1291        """
1292        panel = self.plot_panel
1293        if panel == None:
1294            raise ValueError, "Fitting:_onSelect: NonType panel"
1295        Plugin.on_perspective(self, event=event)
1296        self.select_data(panel)
1297       
1298    def select_data(self, panel):
1299        """
1300        """
1301        for plottable in panel.graph.plottables:
1302            if plottable.__class__.__name__ in ["Data1D", "Theory1D"]:
1303                data_id = panel.graph.selected_plottable
1304                if plottable == panel.plots[data_id]:
1305                    data = plottable
1306                    self.add_fit_page(data=[data])
1307                    return
1308            else:
1309                data = plottable
1310                self.add_fit_page(data=[data])
1311           
1312    def update_fit(self, result=None, msg=""):
1313        """
1314        """
1315        print "update_fit result", result
1316       
1317    def _batch_fit_complete(self, result, pars, page_id,
1318                            batch_outputs, batch_inputs, elapsed=None):
1319        """
1320        Display fit result in batch
1321        :param result: list of objects received fromt fit engines
1322        :param pars: list of  fitted parameters names
1323        :param page_id: list of page ids which called fit function
1324        :param elapsed: time spent at the fitting level
1325        """
1326        self._mac_sleep(0.2)
1327        uid = page_id[0]
1328        if uid in self.fit_thread_list.keys():
1329            del self.fit_thread_list[uid]
1330         
1331        self._update_fit_button(page_id)
1332        t1 = time.time()
1333        str_time = time.strftime("%a, %d %b %Y %H:%M:%S ", time.localtime(t1))
1334        msg = "Fit completed on %s \n" % str_time
1335        msg += "Duration time: %s s.\n" % str(elapsed)
1336        wx.PostEvent(self.parent, StatusEvent(status=msg, info="info",
1337                                              type="stop"))
1338       
1339        if batch_outputs is None:
1340            batch_outputs = {}
1341       
1342        # format batch_outputs
1343        batch_outputs["Chi2"] = []
1344        #Don't like these loops
1345        # Need to create dictionary of all fitted parameters
1346        # since the number of parameters can differ between each fit result
1347        for list_res in result:
1348            for res in list_res:
1349                model, data = res.inputs[0]
1350                if model is not None and hasattr(model, "model"):
1351                    model = model.model
1352                #get all fittable parameters of the current model
1353                for param in  model.getParamList():
1354                    if param  not in batch_outputs.keys():
1355                        batch_outputs[param] = []
1356                for param in model.getDispParamList():
1357                    if not model.is_fittable(param) and \
1358                        param in batch_outputs.keys():
1359                        del batch_outputs[param]
1360                # Add fitted parameters and their error
1361                for param in res.param_list:
1362                    if param not in batch_outputs.keys():
1363                        batch_outputs[param] = []
1364                    err_param = "error on %s" % str(param)
1365                    if err_param not in batch_inputs.keys():
1366                        batch_inputs[err_param] = []
1367        msg = ""
1368        for list_res in result:
1369            for res in list_res:
1370                pid = res.fitter_id
1371                model, data = res.inputs[0]
1372                correct_result = False
1373                if model is not None and hasattr(model, "model"):
1374                    model = model.model
1375                if data is not None and hasattr(data, "sans_data"):
1376                    data = data.sans_data
1377               
1378                is_data2d = issubclass(data.__class__, Data2D)
1379                #check consistency of arrays
1380                if not is_data2d:
1381                    if len(res.theory) == len(res.index[res.index]) and \
1382                        len(res.index) == len(data.y):
1383                        correct_result = True
1384                else:
1385                    copy_data = deepcopy(data)
1386                    new_theory = copy_data.data
1387                    new_theory[res.index] = res.theory
1388                    new_theory[res.index == False] = numpy.nan
1389                    correct_result = True
1390                #get all fittable parameters of the current model
1391                param_list = model.getParamList()
1392                for param in model.getDispParamList():
1393                    if not model.is_fittable(param) and \
1394                        param in param_list:
1395                        param_list.remove(param)
1396                if not correct_result or res.fitness is None or \
1397                    not numpy.isfinite(res.fitness) or \
1398                    numpy.any(res.pvec == None) or not \
1399                    numpy.all(numpy.isfinite(res.pvec)):
1400                    data_name = str(None)
1401                    if data is not None:
1402                        data_name = str(data.name)
1403                    model_name = str(None)
1404                    if model is not None:
1405                        model_name = str(model.name)
1406                    msg += "Data %s and Model %s did not fit.\n" % (data_name,
1407                                                                    model_name)
1408                    ERROR = numpy.NAN
1409                    cell = BatchCell()
1410                    cell.label = res.fitness
1411                    cell.value = res.fitness
1412                    batch_outputs["Chi2"].append(ERROR)
1413                    for param in param_list:
1414                        # save value of  fixed parameters
1415                        if param not in res.param_list:
1416                            batch_outputs[str(param)].append(ERROR)
1417                        else:
1418                            #save only fitted values
1419                            batch_outputs[param].append(ERROR)
1420                            batch_inputs["error on %s" % str(param)].append(ERROR)
1421                else:
1422                    # ToDo: Why sometimes res.pvec comes with numpy.float64?
1423                    # Need to fix it within ScipyEngine
1424                    if res.pvec.__class__ == numpy.float64:
1425                        res.pvec = [res.pvec]
1426                       
1427                    cell = BatchCell()
1428                    cell.label = res.fitness
1429                    cell.value = res.fitness
1430                    batch_outputs["Chi2"].append(cell)
1431                    # add parameters to batch_results
1432                    for param in param_list:
1433                        # save value of  fixed parameters
1434                        if param not in res.param_list:
1435                            batch_outputs[str(param)].append(model.getParam(param))
1436                        else:
1437                            index = res.param_list.index(param)
1438                            #save only fitted values
1439                            batch_outputs[param].append(res.pvec[index])
1440                            if res.stderr is not None and \
1441                                len(res.stderr) == len(res.param_list):
1442                                item = res.stderr[index]
1443                                batch_inputs["error on %s" % param].append(item)
1444                            else:
1445                                batch_inputs["error on %s" % param].append('-')
1446                            model.setParam(param, res.pvec[index])
1447                #fill the batch result with emtpy value if not in the current
1448                #model
1449                EMPTY = "-"
1450                for key in batch_outputs.keys():
1451                    if key not in param_list and key not in ["Chi2", "Data"]:
1452                        batch_outputs[key].append(EMPTY)
1453                               
1454                self.page_finder[pid].set_batch_result(batch_inputs=batch_inputs,
1455                                                       batch_outputs=batch_outputs)
1456               
1457                cpage = self.fit_panel.get_page_by_id(pid)
1458                cpage._on_fit_complete()
1459                self.page_finder[pid][data.id].set_result(res)
1460                fitproblem = self.page_finder[pid][data.id]
1461                qmin, qmax = fitproblem.get_range()
1462                plot_result = False
1463                if correct_result:
1464                    if not is_data2d:
1465                        self._complete1D(x=data.x[res.index], y=res.theory, page_id=pid,
1466                                         elapsed=None,
1467                                         index=res.index, model=model,
1468                                         weight=None, fid=data.id,
1469                                         toggle_mode_on=False, state=None,
1470                                         data=data, update_chisqr=False,
1471                                         source='fit', plot_result=plot_result)
1472                    else:
1473                        self._complete2D(image=new_theory, data=data,
1474                                         model=model,
1475                                         page_id=pid, elapsed=None,
1476                                         index=res.index,
1477                                         qmin=qmin,
1478                                         qmax=qmax, fid=data.id, weight=None,
1479                                         toggle_mode_on=False, state=None,
1480                                         update_chisqr=False,
1481                                         source='fit', plot_result=plot_result)
1482                self.on_set_batch_result(page_id=pid,
1483                                         fid=data.id,
1484                                         batch_outputs=batch_outputs,
1485                                         batch_inputs=batch_inputs)
1486       
1487        wx.PostEvent(self.parent, StatusEvent(status=msg, error="info",
1488                                              type="stop"))
1489        # Remove parameters that are not shown
1490        cpage = self.fit_panel.get_page_by_id(uid)
1491        tbatch_outputs = {}
1492        shownkeystr = cpage.get_copy_params()
1493        for key in batch_outputs.keys():
1494            if key in ["Chi2", "Data"] or shownkeystr.count(key) > 0:
1495                tbatch_outputs[key] = batch_outputs[key]
1496               
1497        wx.CallAfter(self.parent.on_set_batch_result, tbatch_outputs,
1498                     batch_inputs, self.sub_menu)
1499       
1500    def on_set_batch_result(self, page_id, fid, batch_outputs, batch_inputs):
1501        """
1502        """
1503        pid = page_id
1504        if fid not in self.page_finder[pid]:
1505            return
1506        fitproblem = self.page_finder[pid][fid]
1507        index = self.page_finder[pid].nbr_residuals_computed - 1
1508        residuals = fitproblem.get_residuals()
1509        theory_data = fitproblem.get_theory_data()
1510        data = fitproblem.get_fit_data()
1511        model = fitproblem.get_model()
1512        #fill batch result information
1513        if "Data" not in batch_outputs.keys():
1514            batch_outputs["Data"] = []
1515        from sans.guiframe.data_processor import BatchCell
1516        cell = BatchCell()
1517        cell.label = data.name
1518        cell.value = index
1519       
1520        if theory_data != None:
1521            #Suucessful fit
1522            theory_data.id = wx.NewId()
1523            theory_data.name = model.name + "[%s]" % str(data.name)
1524            if issubclass(theory_data.__class__, Data2D):
1525                group_id = wx.NewId()
1526                theory_data.group_id = group_id
1527                if group_id not in theory_data.list_group_id:
1528                    theory_data.list_group_id.append(group_id)
1529               
1530            try:
1531                # associate residuals plot
1532                if issubclass(residuals.__class__, Data2D):
1533                    group_id = wx.NewId()
1534                    residuals.group_id = group_id
1535                    if group_id not in residuals.list_group_id:
1536                        residuals.list_group_id.append(group_id)
1537                batch_outputs["Chi2"][index].object = [residuals]
1538            except:
1539                pass
1540
1541        cell.object = [data, theory_data]
1542        batch_outputs["Data"].append(cell)
1543        for key, value in data.meta_data.iteritems():
1544            if key not in batch_inputs.keys():
1545                batch_inputs[key] = []
1546            #if key.lower().strip() != "loader":
1547            batch_inputs[key].append(value)
1548        param = "temperature"
1549        if hasattr(data.sample, param):
1550            if param not in  batch_inputs.keys():
1551                batch_inputs[param] = []
1552            batch_inputs[param].append(data.sample.temperature)
1553       
1554    def _fit_completed(self, result, page_id, batch_outputs,
1555                       batch_inputs=None, pars=None, elapsed=None):
1556        """
1557        Display result of the fit on related panel(s).
1558        :param result: list of object generated when fit ends
1559        :param pars: list of names of parameters fitted
1560        :param page_id: list of page ids which called fit function
1561        :param elapsed: time spent at the fitting level
1562        """
1563        t1 = time.time()
1564        str_time = time.strftime("%a, %d %b %Y %H:%M:%S ", time.localtime(t1))
1565        msg = "Fit completed on %s \n" % str_time
1566        msg += "Duration time: %s s.\n" % str(elapsed)
1567        wx.PostEvent(self.parent, StatusEvent(status=msg, info="info",
1568                                                      type="stop"))
1569        wx.PostEvent(self.result_panel, PlotResultEvent(result=result))
1570        # reset fit_engine if changed by simul_fit
1571        if self._fit_engine != self._gui_engine:
1572            self._on_change_engine(self._gui_engine)
1573        self._update_fit_button(page_id)
1574        result = result[0]
1575        self.fit_thread_list = {}
1576        if page_id is None:
1577            page_id = []
1578        ## fit more than 1 model at the same time
1579        self._mac_sleep(0.2)
1580        try:
1581            index = 0
1582            for uid in page_id:
1583                res = result[index]
1584                if res.fitness is None or \
1585                    not numpy.isfinite(res.fitness) or \
1586                    numpy.any(res.pvec == None) or \
1587                    not numpy.all(numpy.isfinite(res.pvec)):
1588                    msg = "Fitting did not converge!!!"
1589                    wx.PostEvent(self.parent,
1590                             StatusEvent(status=msg,
1591                                         info="warning",
1592                                         type="stop"))
1593                    self._update_fit_button(page_id)
1594                else:
1595                    #set the panel when fit result are float not list
1596                    if res.pvec.__class__ == numpy.float64:
1597                        pvec = [res.pvec]
1598                    else:
1599                        pvec = res.pvec
1600                    if res.stderr.__class__ == numpy.float64:
1601                        stderr = [res.stderr]
1602                    else:
1603                        stderr = res.stderr
1604                    cpage = self.fit_panel.get_page_by_id(uid)
1605                    # Make sure we got all results
1606                    #(CallAfter is important to MAC)
1607                    try:
1608                        #if res != None:
1609                        wx.CallAfter(cpage.onsetValues, res.fitness,
1610                                     res.param_list,
1611                                     pvec, stderr)
1612                        index += 1
1613                        wx.CallAfter(cpage._on_fit_complete)
1614                    except KeyboardInterrupt:
1615                        msg = "Singular point: Fitting Stoped."
1616                        wx.PostEvent(self.parent, StatusEvent(status=msg,
1617                                                              info="info",
1618                                                              type="stop"))
1619                    except:
1620                        msg = "Singular point: Fitting Error occurred."
1621                        wx.PostEvent(self.parent, StatusEvent(status=msg,
1622                                                              info="error",
1623                                                              type="stop"))
1624                   
1625        except:
1626            msg = "Fit completed but Following"
1627            msg += " warning occurred: %s" % sys.exc_value
1628            wx.PostEvent(self.parent, StatusEvent(status=msg, info="warning",
1629                                                  type="stop"))
1630           
1631    def _update_fit_button(self, page_id):
1632        """
1633        Update Fit button when fit stopped
1634       
1635        : parameter page_id: fitpage where the button is
1636        """
1637        if page_id.__class__.__name__ != 'list':
1638            page_id = [page_id]
1639        for uid in page_id:
1640            page = self.fit_panel.get_page_by_id(uid)
1641            page._on_fit_complete()
1642       
1643    def _on_show_panel(self, event):
1644        """
1645        """
1646        pass
1647   
1648    def on_reset_batch_flag(self, event):
1649        """
1650        Set batch_reset_flag
1651        """
1652        event.Skip()
1653        if self.menu1 == None:
1654            return
1655        menu_item = self.menu1.FindItemById(self.id_reset_flag)
1656        flag = menu_item.IsChecked()
1657        if not flag:
1658            menu_item.Check(False)
1659            self.batch_reset_flag = True
1660        else:
1661            menu_item.Check(True)
1662            self.batch_reset_flag = False
1663       
1664        ## post a message to status bar
1665        msg = "Set Chain Fitting: %s" % str(not self.batch_reset_flag)
1666        wx.PostEvent(self.parent,
1667                     StatusEvent(status=msg))
1668
1669    def _onset_engine_park(self, event):
1670        """
1671        set engine to park
1672        """
1673        self._on_change_engine('park')
1674       
1675    def _onset_engine_scipy(self, event):
1676        """
1677        set engine to scipy
1678        """
1679        self._on_change_engine('scipy')
1680       
1681    def _onset_engine_bumps(self, event):
1682        """
1683        set engine to bumps
1684        """
1685        self._on_change_engine('bumps')
1686       
1687    def _on_slicer_event(self, event):
1688        """
1689        Receive a panel as event and send it to guiframe
1690       
1691        :param event: event containing a panel
1692       
1693        """
1694        if event.panel is not None:
1695            new_panel = event.panel
1696            self.slicer_panels.append(event.panel)
1697            # Set group ID if available
1698            event_id = self.parent.popup_panel(event.panel)
1699            event.panel.uid = event_id
1700            self.mypanels.append(event.panel)
1701       
1702    def _onclearslicer(self, event):
1703        """
1704        Clear the boxslicer when close the panel associate with this slicer
1705        """
1706        name = event.GetEventObject().frame.GetTitle()
1707        print "name", name
1708        for panel in self.slicer_panels:
1709            if panel.window_caption == name:
1710               
1711                for item in self.parent.panels:
1712                    if hasattr(self.parent.panels[item], "uid"):
1713                        if self.parent.panels[item].uid == panel.base.uid:
1714                            self.parent.panels[item].onClearSlicer(event)
1715                            #self.parent._mgr.Update()
1716                            break
1717                break
1718   
1719    def _on_change_engine(self, engine='park'):
1720        """
1721        Allow to select the type of engine to perform fit
1722       
1723        :param engine: the key work of the engine
1724       
1725        """
1726        ## saving fit engine name
1727        self._fit_engine = engine
1728        ## change menu item state
1729        if engine == "park":
1730            self.menu1.FindItemById(self.park_id).Check(True)
1731            self.menu1.FindItemById(self.scipy_id).Check(False)
1732            self.menu1.FindItemById(self.bumps_id).Check(False)
1733        elif engine == "scipy":
1734            self.menu1.FindItemById(self.park_id).Check(False)
1735            self.menu1.FindItemById(self.scipy_id).Check(True)
1736            self.menu1.FindItemById(self.bumps_id).Check(False)
1737        else:
1738            self.menu1.FindItemById(self.park_id).Check(False)
1739            self.menu1.FindItemById(self.scipy_id).Check(False)
1740            self.menu1.FindItemById(self.bumps_id).Check(True)
1741        ## post a message to status bar
1742        msg = "Engine set to: %s" % self._fit_engine
1743        wx.PostEvent(self.parent,
1744                     StatusEvent(status=msg))
1745        ## send the current engine type to fitpanel
1746        self.fit_panel._on_engine_change(name=self._fit_engine)
1747
1748    def _on_model_panel(self, evt):
1749        """
1750        react to model selection on any combo box or model menu.plot the model 
1751       
1752        :param evt: wx.combobox event
1753       
1754        """
1755        model = evt.model
1756        uid = evt.uid
1757        qmin = evt.qmin
1758        qmax = evt.qmax
1759        caption = evt.caption
1760        enable_smearer = evt.enable_smearer
1761        if model == None:
1762            return
1763        if uid not in self.page_finder.keys():
1764            return
1765        # save the name containing the data name with the appropriate model
1766        self.page_finder[uid].set_model(model)
1767        self.page_finder[uid].enable_smearing(enable_smearer)
1768        self.page_finder[uid].set_range(qmin=qmin, qmax=qmax)
1769        self.page_finder[uid].set_fit_tab_caption(caption=caption)
1770        if self.sim_page is not None and not self.batch_on:
1771            self.sim_page.draw_page()
1772        if self.batch_page is not None and self.batch_on:
1773            self.batch_page.draw_page()
1774       
1775    def _update1D(self, x, output):
1776        """
1777        Update the output of plotting model 1D
1778        """
1779        msg = "Plot updating ... "
1780        wx.PostEvent(self.parent, StatusEvent(status=msg, type="update"))
1781       
1782    def _complete1D(self, x, y, page_id, elapsed, index, model,
1783                    weight=None, fid=None,
1784                    toggle_mode_on=False, state=None,
1785                    data=None, update_chisqr=True,
1786                    source='model', plot_result=True):
1787        """
1788        Complete plotting 1D data
1789        """
1790        try:
1791            numpy.nan_to_num(y)
1792           
1793            new_plot = Data1D(x=x, y=y)
1794            new_plot.is_data = False
1795            new_plot.dy = numpy.zeros(len(y))
1796            new_plot.symbol = GUIFRAME_ID.CURVE_SYMBOL_NUM
1797            _yaxis, _yunit = data.get_yaxis()
1798            _xaxis, _xunit = data.get_xaxis()
1799            new_plot.title = data.name
1800
1801            new_plot.group_id = data.group_id
1802            if new_plot.group_id == None:
1803                new_plot.group_id = data.group_id
1804            new_plot.id = str(page_id) + " " + data.name
1805            #if new_plot.id in self.color_dict:
1806            #    new_plot.custom_color = self.color_dict[new_plot.id]
1807            #find if this theory was already plotted and replace that plot given
1808            #the same id
1809            theory_data = self.page_finder[page_id].get_theory_data(fid=data.id)
1810           
1811            if data.is_data:
1812                data_name = str(data.name)
1813            else:
1814                data_name = str(model.__class__.__name__)
1815           
1816            new_plot.name = model.name + " [" + data_name +"]"
1817            new_plot.xaxis(_xaxis, _xunit)
1818            new_plot.yaxis(_yaxis, _yunit)
1819            self.page_finder[page_id].set_theory_data(data=new_plot,
1820                                                      fid=data.id)
1821            self.parent.update_theory(data_id=data.id, theory=new_plot,
1822                                       state=state)
1823            current_pg = self.fit_panel.get_page_by_id(page_id)
1824            title = new_plot.title
1825            batch_on = self.fit_panel.get_page_by_id(page_id).batch_on
1826            if not batch_on:
1827                wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot,
1828                                            title=str(title)))
1829            elif plot_result:
1830                top_data_id = self.fit_panel.get_page_by_id(page_id).data.id
1831                if data.id == top_data_id:
1832                    wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot,
1833                                            title=str(title)))
1834            caption = current_pg.window_caption
1835            self.page_finder[page_id].set_fit_tab_caption(caption=caption)
1836           
1837            self.page_finder[page_id].set_theory_data(data=new_plot,
1838                                                      fid=data.id)
1839            if toggle_mode_on:
1840                wx.PostEvent(self.parent,
1841                             NewPlotEvent(group_id=str(page_id) + " Model2D",
1842                                          action="Hide"))
1843            else:
1844                if update_chisqr:
1845                    wx.PostEvent(current_pg,
1846                                 Chi2UpdateEvent(output=self._cal_chisqr(
1847                                                                data=data,
1848                                                                fid=fid,
1849                                                                weight=weight,
1850                                                            page_id=page_id,
1851                                                            index=index)))
1852                else:
1853                    self._plot_residuals(page_id=page_id, data=data, fid=fid,
1854                                         index=index, weight=weight)
1855
1856            msg = "Computation  completed!"
1857            wx.PostEvent(self.parent, StatusEvent(status=msg, type="stop"))
1858        except:
1859            raise
1860   
1861    def _update2D(self, output, time=None):
1862        """
1863        Update the output of plotting model
1864        """
1865        wx.PostEvent(self.parent, StatusEvent(status="Plot \
1866        #updating ... ", type="update"))
1867        #self.ready_fit()
1868 
1869    def _complete2D(self, image, data, model, page_id, elapsed, index, qmin,
1870                qmax, fid=None, weight=None, toggle_mode_on=False, state=None,
1871                     update_chisqr=True, source='model', plot_result=True):
1872        """
1873        Complete get the result of modelthread and create model 2D
1874        that can be plot.
1875        """
1876        numpy.nan_to_num(image)
1877        new_plot = Data2D(image=image, err_image=data.err_data)
1878        new_plot.name = model.name + '2d'
1879        new_plot.title = "Analytical model 2D "
1880        new_plot.id = str(page_id) + " " + data.name
1881        new_plot.group_id = str(page_id) + " Model2D"
1882        new_plot.detector = data.detector
1883        new_plot.source = data.source
1884        new_plot.is_data = False
1885        new_plot.qx_data = data.qx_data
1886        new_plot.qy_data = data.qy_data
1887        new_plot.q_data = data.q_data
1888        new_plot.mask = data.mask
1889        ## plot boundaries
1890        new_plot.ymin = data.ymin
1891        new_plot.ymax = data.ymax
1892        new_plot.xmin = data.xmin
1893        new_plot.xmax = data.xmax
1894        title = data.title
1895       
1896        new_plot.is_data = False
1897        if data.is_data:
1898            data_name = str(data.name)
1899        else:
1900            data_name = str(model.__class__.__name__) + '2d'
1901
1902        if len(title) > 1:
1903            new_plot.title = "Model2D for %s "% model.name + data_name
1904        new_plot.name = model.name + " [" + \
1905                                    data_name + "]"
1906        theory_data = deepcopy(new_plot)
1907       
1908        self.page_finder[page_id].set_theory_data(data=theory_data,
1909                                                  fid=data.id)
1910        self.parent.update_theory(data_id=data.id,
1911                                       theory=new_plot,
1912                                       state=state)
1913        current_pg = self.fit_panel.get_page_by_id(page_id)
1914        title = new_plot.title
1915        if not source == 'fit' and plot_result:
1916            wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot,
1917                                               title=title))
1918        if toggle_mode_on:
1919            wx.PostEvent(self.parent,
1920                             NewPlotEvent(group_id=str(page_id) + " Model1D",
1921                                               action="Hide"))
1922        else:
1923            # Chisqr in fitpage
1924            if update_chisqr:
1925                wx.PostEvent(current_pg,
1926                             Chi2UpdateEvent(output=self._cal_chisqr(data=data,
1927                                                                    weight=weight,
1928                                                                    fid=fid,
1929                                                         page_id=page_id,
1930                                                         index=index)))
1931            else:
1932                self._plot_residuals(page_id=page_id, data=data, fid=fid,
1933                                      index=index, weight=weight)
1934        msg = "Computation  completed!"
1935        wx.PostEvent(self.parent, StatusEvent(status=msg, type="stop"))
1936   
1937    def _draw_model2D(self, model, page_id, qmin,
1938                      qmax,
1939                      data=None, smearer=None,
1940                      description=None, enable2D=False,
1941                      state=None,
1942                      fid=None,
1943                      weight=None,
1944                      toggle_mode_on=False,
1945                       update_chisqr=True, source='model'):
1946        """
1947        draw model in 2D
1948       
1949        :param model: instance of the model to draw
1950        :param description: the description of the model
1951        :param enable2D: when True allows to draw model 2D
1952        :param qmin: the minimum value to  draw model 2D
1953        :param qmax: the maximum value to draw model 2D
1954        :param qstep: the number of division of Qx and Qy of the model to draw
1955           
1956        """
1957        if not enable2D:
1958            return None
1959        try:
1960            from model_thread import Calc2D
1961            ## If a thread is already started, stop it
1962            if (self.calc_2D is not None) and self.calc_2D.isrunning():
1963                self.calc_2D.stop()
1964            self.calc_2D = Calc2D(model=model,
1965                                    data=data,
1966                                    page_id=page_id,
1967                                    smearer=smearer,
1968                                    qmin=qmin,
1969                                    qmax=qmax,
1970                                    weight=weight, 
1971                                    fid=fid,
1972                                    toggle_mode_on=toggle_mode_on,
1973                                    state=state,
1974                                    completefn=self._complete2D,
1975                                    update_chisqr=update_chisqr, source=source)
1976            self.calc_2D.queue()
1977        except:
1978            raise
1979
1980    def _draw_model1D(self, model, page_id, data,
1981                      qmin, qmax, smearer=None,
1982                state=None,
1983                weight=None,
1984                fid=None,
1985                toggle_mode_on=False, update_chisqr=True, source='model',
1986                enable1D=True):
1987        """
1988        Draw model 1D from loaded data1D
1989       
1990        :param data: loaded data
1991        :param model: the model to plot
1992       
1993        """
1994        if not enable1D:
1995            return
1996        try:
1997            from model_thread import Calc1D
1998            ## If a thread is already started, stop it
1999            if (self.calc_1D is not None) and self.calc_1D.isrunning():
2000                self.calc_1D.stop()
2001            self.calc_1D = Calc1D(data=data,
2002                                  model=model,
2003                                  page_id=page_id, 
2004                                  qmin=qmin,
2005                                  qmax=qmax,
2006                                  smearer=smearer,
2007                                  state=state,
2008                                  weight=weight,
2009                                  fid=fid,
2010                                  toggle_mode_on=toggle_mode_on,
2011                                  completefn=self._complete1D,
2012                                  #updatefn = self._update1D,
2013                                  update_chisqr=update_chisqr,
2014                                  source=source)
2015            self.calc_1D.queue()
2016        except:
2017            msg = " Error occurred when drawing %s Model 1D: " % model.name
2018            msg += " %s" % sys.exc_value
2019            wx.PostEvent(self.parent, StatusEvent(status=msg))
2020   
2021    def _cal_chisqr(self, page_id, data, weight, fid=None, index=None):
2022        """
2023        Get handy Chisqr using the output from draw1D and 2D,
2024        instead of calling expansive CalcChisqr in guithread
2025        """
2026        try:
2027            data_copy = deepcopy(data)
2028        except:
2029            return
2030        # default chisqr
2031        chisqr = None
2032        #to compute chisq make sure data has valid data
2033        # return None if data == None
2034        if not check_data_validity(data_copy) or data_copy == None:
2035            return chisqr
2036
2037        # Get data: data I, theory I, and data dI in order
2038        if data_copy.__class__.__name__ == "Data2D":
2039            if index == None:
2040                index = numpy.ones(len(data_copy.data), dtype=bool)
2041            if weight != None:
2042                data_copy.err_data = weight
2043            # get rid of zero error points
2044            index = index & (data_copy.err_data != 0)
2045            index = index & (numpy.isfinite(data_copy.data))
2046            fn = data_copy.data[index]
2047            theory_data = self.page_finder[page_id].get_theory_data(fid=data_copy.id)
2048            if theory_data == None:
2049                return chisqr
2050            gn = theory_data.data[index]
2051            en = data_copy.err_data[index]
2052        else:
2053            # 1 d theory from model_thread is only in the range of index
2054            if index == None: 
2055                index = numpy.ones(len(data_copy.y), dtype=bool)
2056            if weight != None:
2057                data_copy.dy = weight
2058            if data_copy.dy == None or data_copy.dy == []:
2059                dy = numpy.ones(len(data_copy.y))
2060            else:
2061                ## Set consitently w/AbstractFitengine:
2062                # But this should be corrected later.
2063                dy = deepcopy(data_copy.dy)
2064                dy[dy == 0] = 1
2065            fn = data_copy.y[index]
2066           
2067            theory_data = self.page_finder[page_id].get_theory_data(fid=data_copy.id)
2068            if theory_data == None:
2069                return chisqr
2070            gn = theory_data.y
2071            en = dy[index]
2072       
2073        # residual
2074        try:
2075            res = (fn - gn) / en
2076        except ValueError:
2077            print "Unmatch lengths %s, %s, %s"% (len(fn), len(gn), len(en))
2078            return
2079       
2080        residuals = res[numpy.isfinite(res)]
2081        # get chisqr only w/finite
2082        chisqr = numpy.average(residuals * residuals)
2083       
2084        self._plot_residuals(page_id=page_id, data=data_copy,
2085                             fid=fid,
2086                             weight=weight, index=index)
2087       
2088        return chisqr
2089   
2090    def _plot_residuals(self, page_id, weight, fid=None,
2091                        data=None, index=None):
2092        """
2093        Plot the residuals
2094       
2095        :param data: data
2096        :param index: index array (bool)
2097        : Note: this is different from the residuals in cal_chisqr()
2098        """
2099        data_copy = deepcopy(data)
2100        # Get data: data I, theory I, and data dI in order
2101        if data_copy.__class__.__name__ == "Data2D":
2102            # build residuals
2103            residuals = Data2D()
2104            #residuals.copy_from_datainfo(data)
2105            # Not for trunk the line below, instead use the line above
2106            data_copy.clone_without_data(len(data_copy.data), residuals)
2107            residuals.data = None
2108            fn = data_copy.data
2109            theory_data = self.page_finder[page_id].get_theory_data(fid=data_copy.id)
2110            gn = theory_data.data
2111            if weight == None:
2112                en = data_copy.err_data
2113            else:
2114                en = weight
2115            residuals.data = (fn - gn) / en
2116            residuals.qx_data = data_copy.qx_data
2117            residuals.qy_data = data_copy.qy_data
2118            residuals.q_data = data_copy.q_data
2119            residuals.err_data = numpy.ones(len(residuals.data))
2120            residuals.xmin = min(residuals.qx_data)
2121            residuals.xmax = max(residuals.qx_data)
2122            residuals.ymin = min(residuals.qy_data)
2123            residuals.ymax = max(residuals.qy_data)
2124            residuals.q_data = data_copy.q_data
2125            residuals.mask = data_copy.mask
2126            residuals.scale = 'linear'
2127            # check the lengths
2128            if len(residuals.data) != len(residuals.q_data):
2129                return
2130        else:
2131            # 1 d theory from model_thread is only in the range of index
2132            if data_copy.dy == None or data_copy.dy == []:
2133                dy = numpy.ones(len(data_copy.y))
2134            else:
2135                if weight == None:
2136                    dy = numpy.ones(len(data_copy.y))
2137                ## Set consitently w/AbstractFitengine:
2138                ## But this should be corrected later.
2139                else:
2140                    dy = weight
2141                dy[dy == 0] = 1
2142            fn = data_copy.y[index]
2143            theory_data = self.page_finder[page_id].get_theory_data(fid=data_copy.id)
2144            gn = theory_data.y
2145            en = dy[index]
2146            # build residuals
2147            residuals = Data1D()
2148            try:
2149                residuals.y = (fn - gn) / en
2150            except:
2151                msg = "ResidualPlot Error: different # of data points in theory"
2152                wx.PostEvent(self.parent, StatusEvent(status=msg, info="error"))
2153                residuals.y = (fn - gn[index]) / en
2154            residuals.x = data_copy.x[index]
2155            residuals.dy = numpy.ones(len(residuals.y))
2156            residuals.dx = None
2157            residuals.dxl = None
2158            residuals.dxw = None
2159            residuals.ytransform = 'y'
2160            # For latter scale changes
2161            residuals.xaxis('\\rm{Q} ', 'A^{-1}')
2162            residuals.yaxis('\\rm{Residuals} ', 'normalized')
2163        theory_name = str(theory_data.name.split()[0])
2164        new_plot = residuals
2165        new_plot.name = "Residuals for " + str(theory_name) + "[" +\
2166                        str(data.name) +"]"
2167        ## allow to highlight data when plotted
2168        new_plot.interactive = True
2169        ## when 2 data have the same id override the 1 st plotted
2170        new_plot.id = "res" + str(data_copy.id) + str(theory_name)
2171        ##group_id specify on which panel to plot this data
2172        group_id = self.page_finder[page_id].get_graph_id()
2173        if group_id == None:
2174            group_id = data.group_id
2175        new_plot.group_id = "res" + str(group_id)
2176        #new_plot.is_data = True
2177        ##post data to plot
2178        title = new_plot.name
2179        self.page_finder[page_id].set_residuals(residuals=new_plot,
2180                                                fid=data.id)
2181        self.parent.update_theory(data_id=data.id, theory=new_plot)
2182        batch_on = self.fit_panel.get_page_by_id(page_id).batch_on
2183        if not batch_on:
2184            wx.PostEvent(self.parent, NewPlotEvent(plot=new_plot, title=title))
Note: See TracBrowser for help on using the repository browser.