addons/anonymization/anonymization.py

   1 # -*- encoding: utf-8 -*-
   2 ##############################################################################
   3 #
   4 #    OpenERP, Open Source Management Solution
   5 #    Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>). All Rights Reserved
   6 #    $Id$
   7 #
   8 #    This program is free software: you can redistribute it and/or modify
   9 #    it under the terms of the GNU General Public License as published by
  10 #    the Free Software Foundation, either version 3 of the License, or
  11 #    (at your option) any later version.
  12 #
  13 #    This program is distributed in the hope that it will be useful,
  14 #    but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 #    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 #    GNU General Public License for more details.
  17 #
  18 #    You should have received a copy of the GNU General Public License
  19 #    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  20 #
  21 ##############################################################################
  22
  23 from lxml import etree
  24 import os
  25 import base64
  26 try:
  27     import cPickle as pickle
  28 except ImportError:
  29     import pickle
  30 import random
  31 import datetime
  32 from osv import fields, osv
  33 from tools.translate import _
  34
  35
  36 FIELD_STATES = [('clear', 'Clear'), ('anonymized', 'Anonymized'), ('not_existing', 'Not Existing')]
  37 ANONYMIZATION_STATES = FIELD_STATES + [('unstable', 'Unstable')]
  38 ANONYMIZATION_HISTORY_STATE = [('started', 'Started'), ('done', 'Done'), ('in_exception', 'Exception occured')]
  39 ANONYMIZATION_DIRECTION = [('clear -> anonymized', 'clear -> anonymized'), ('anonymized -> clear', 'anonymized -> clear')]
  40
  41
  42 class ir_model_fields_anonymization(osv.osv):
  43     _name = 'ir.model.fields.anonymization'
  44     _rec_name = 'field_id'
  45
  46     _columns = {
  47         'model_name': fields.char('Object Name', size=128, required=True),
  48         'model_id': fields.many2one('ir.model', 'Object', ondelete='set null'),
  49         'field_name': fields.char('Field Name', size=128, required=True),
  50         'field_id': fields.many2one('ir.model.fields', 'Field', ondelete='set null'),
  51         'state': fields.selection(selection=FIELD_STATES, String='State', required=True, readonly=True),
  52     }
  53
  54     _sql_constraints = [
  55         ('model_id_field_id_uniq', 'unique (model_name, field_name)', _("You cannot have two records having the same model and the same field")),
  56     ]
  57
  58     def _get_global_state(self, cr, uid, context=None):
  59         ids = self.search(cr, uid, [('state', '<>', 'not_existing')], context=context)
  60         fields = self.browse(cr, uid, ids, context=context)
  61         if not len(fields) or len(fields) == len([f for f in fields if f.state == 'clear']):
  62             state = 'clear' # all fields are clear
  63         elif len(fields) == len([f for f in fields if f.state == 'anonymized']):
  64             state = 'anonymized' # all fields are anonymized
  65         else:
  66             state = 'unstable' # fields are mixed: this should be fixed
  67         return state
  68
  69     def _check_write(self, cr, uid, context=None):
  70         # check that the field is created from the menu and not from an database update
  71         # otherwise the database update can crash:
  72         if context.get('manual'):
  73             global_state = self._get_global_state(cr, uid, context=context)
  74             if global_state == 'anonymized':
  75                 raise osv.except_osv('Error !', "The database is currently anonymized, you cannot create, modify or delete fields.")
  76             elif global_state == 'unstable':
  77                 msg = "The database anonymization is currently in an unstable state. Some fields are anonymized," + \
  78                       " while some fields are not anonymized. You should try to solve this problem before trying to create, write or delete fields."
  79                 raise osv.except_osv('Error !', msg)
  80
  81         return True
  82
  83     def _get_model_and_field_ids(self, cr, uid, vals, context=None):
  84         model_and_field_ids = (False, False)
  85
  86         if 'field_name' in vals and vals['field_name'] and 'model_name' in vals and vals['model_name']:
  87             ir_model_fields_obj = self.pool.get('ir.model.fields')
  88             ir_model_obj = self.pool.get('ir.model')
  89
  90             model_ids = ir_model_obj.search(cr, uid, [('model', '=', vals['model_name'])], context=context)
  91             if model_ids:
  92                 field_ids = ir_model_fields_obj.search(cr, uid, [('name', '=', vals['field_name']), ('model_id', '=', model_ids[0])], context=context)
  93                 if field_ids:
  94                     field_id = field_ids[0]
  95                     model_and_field_ids = (model_ids[0], field_id)
  96
  97         return model_and_field_ids
  98
  99     def create(self, cr, uid, vals, context=None):
 100         # check field state: all should be clear before we can add a new field to anonymize:
 101         self._check_write(cr, uid, context=context)
 102
 103         if 'field_name' in vals and vals['field_name'] and 'model_name' in vals and vals['model_name']:
 104             vals['model_id'], vals['field_id'] = self._get_model_and_field_ids(cr, uid, vals, context=context)
 105
 106         # check not existing fields:
 107         if not vals.get('field_id'):
 108             vals['state'] = 'not_existing'
 109
 110         res = super(ir_model_fields_anonymization, self).create(cr, uid, vals, context=context)
 111
 112         return res
 113
 114     def write(self, cr, uid, ids, vals, context=None):
 115         # check field state: all should be clear before we can modify a field:
 116         if not (len(vals.keys()) == 1 and vals.get('state') == 'clear'):
 117             self._check_write(cr, uid, context=context)
 118
 119         if 'field_name' in vals and vals['field_name'] and 'model_name' in vals and vals['model_name']:
 120             vals['model_id'], vals['field_id'] = self._get_model_and_field_ids(cr, uid, vals, context=context)
 121
 122         # check not existing fields:
 123         if 'field_id' in vals:
 124             if not vals.get('field_id'):
 125                 vals['state'] = 'not_existing'
 126             else:
 127                 global_state = self._get_global_state(cr, uid, context)
 128                 if global_state != 'unstable':
 129                     vals['state'] = global_state
 130
 131         res = super(ir_model_fields_anonymization, self).write(cr, uid, ids, vals, context=context)
 132
 133         return res
 134
 135     def unlink(self, cr, uid, ids, context=None):
 136         # check field state: all should be clear before we can unlink a field:
 137         self._check_write(cr, uid, context=context)
 138
 139         res = super(ir_model_fields_anonymization, self).unlink(cr, uid, ids, context=context)
 140         return res
 141
 142     def onchange_model_id(self, cr, uid, ids, model_id, context=None):
 143         res = {'value': {
 144                     'field_name': False,
 145                     'field_id': False,
 146                     'model_name': False,
 147               }}
 148
 149         if model_id:
 150             ir_model_obj = self.pool.get('ir.model')
 151             model_ids = ir_model_obj.search(cr, uid, [('id', '=', model_id)])
 152             model_id = model_ids and model_ids[0] or None
 153             model_name = model_id and ir_model_obj.browse(cr, uid, model_id).model or False
 154             res['value']['model_name'] = model_name
 155
 156         return res
 157
 158     def onchange_model_name(self, cr, uid, ids, model_name, context=None):
 159         res = {'value': {
 160                     'field_name': False,
 161                     'field_id': False,
 162                     'model_id': False,
 163               }}
 164
 165         if model_name:
 166             ir_model_obj = self.pool.get('ir.model')
 167             model_ids = ir_model_obj.search(cr, uid, [('model', '=', model_name)])
 168             model_id = model_ids and model_ids[0] or False
 169             res['value']['model_id'] = model_id
 170
 171         return res
 172
 173     def onchange_field_name(self, cr, uid, ids, field_name, model_name):
 174         res = {'value': {
 175                 'field_id': False,
 176             }}
 177
 178         if field_name and model_name:
 179             ir_model_fields_obj = self.pool.get('ir.model.fields')
 180             field_ids = ir_model_fields_obj.search(cr, uid, [('name', '=', field_name), ('model', '=', model_name)])
 181             field_id = field_ids and field_ids[0] or False
 182             res['value']['field_id'] = field_id
 183
 184         return res
 185
 186     def onchange_field_id(self, cr, uid, ids, field_id, model_name):
 187         res = {'value': {
 188                     'field_name': False,
 189               }}
 190
 191         if field_id:
 192             ir_model_fields_obj = self.pool.get('ir.model.fields')
 193             field = ir_model_fields_obj.browse(cr, uid, field_id)
 194             res['value']['field_name'] = field.name
 195
 196         return res
 197
 198     _defaults = {
 199         'state': lambda *a: 'clear',
 200     }
 201
 202 ir_model_fields_anonymization()
 203
 204
 205 class ir_model_fields_anonymization_history(osv.osv):
 206     _name = 'ir.model.fields.anonymization.history'
 207     _order = "date desc"
 208
 209     _columns = {
 210         'date': fields.datetime('Date', required=True, readonly=True),
 211         'field_ids': fields.many2many('ir.model.fields.anonymization', 'anonymized_field_to_history_rel', 'field_id', 'history_id', 'Fields', readonly=True),
 212         'state': fields.selection(selection=ANONYMIZATION_HISTORY_STATE, string='State', required=True, readonly=True),
 213         'direction': fields.selection(selection=ANONYMIZATION_DIRECTION, string='Direction', required=True, readonly=True),
 214         'msg': fields.text('Message', readonly=True),
 215         'filepath': fields.char(string='File path', size=256, readonly=True),
 216     }
 217
 218 ir_model_fields_anonymization_history()
 219
 220
 221 class ir_model_fields_anonymize_wizard(osv.osv_memory):
 222     _name = 'ir.model.fields.anonymize.wizard'
 223
 224     def _get_state(self, cr, uid, ids, name, arg, context=None):
 225         res = {}
 226
 227         state = self._get_state_value(cr, uid, context=None)
 228         for id in ids:
 229             res[id] = state
 230
 231         return res
 232
 233     def _get_summary(self, cr, uid, ids, name, arg, context=None):
 234         res = {}
 235         summary = self._get_summary_value(cr, uid, context)
 236         for id in ids:
 237             res[id] = summary
 238
 239         return res
 240
 241     _columns = {
 242         'name': fields.char(size='64', string='File Name'),
 243         'summary': fields.function(_get_summary, method=True, type='text', string='Summary'),
 244         'file_export': fields.binary(string='Export'),
 245         'file_import': fields.binary(string='Import'),
 246         'state': fields.function(_get_state, method=True, string='State', type='selection', selection=ANONYMIZATION_STATES, readonly=False),
 247         'msg': fields.text(string='Message'),
 248     }
 249
 250     def _get_state_value(self, cr, uid, context=None):
 251         state = self.pool.get('ir.model.fields.anonymization')._get_global_state(cr, uid, context=context)
 252         return state
 253
 254     def _get_summary_value(self, cr, uid, context=None):
 255         summary = u''
 256         anon_field_obj = self.pool.get('ir.model.fields.anonymization')
 257         ir_model_fields_obj = self.pool.get('ir.model.fields')
 258
 259         anon_field_ids = anon_field_obj.search(cr, uid, [('state', '<>', 'not_existing')], context=context)
 260         anon_fields = anon_field_obj.browse(cr, uid, anon_field_ids, context=context)
 261
 262         field_ids = [anon_field.field_id.id for anon_field in anon_fields if anon_field.field_id]
 263         fields = ir_model_fields_obj.browse(cr, uid, field_ids, context=context)
 264
 265         fields_by_id = dict([(f.id, f) for f in fields])
 266
 267         for anon_field in anon_fields:
 268             field = fields_by_id.get(anon_field.field_id.id)
 269
 270             values = {
 271                 'model_name': field.model_id.name,
 272                 'model_code': field.model_id.model,
 273                 'field_code': field.name,
 274                 'field_name': field.field_description,
 275                 'state': anon_field.state,
 276             }
 277             summary += u" * %(model_name)s (%(model_code)s) -> %(field_name)s (%(field_code)s): state: (%(state)s)\n" % values
 278
 279         return summary
 280
 281     def default_get(self, cr, uid, fields_list, context=None):
 282         res = {}
 283         res['name'] = '.pickle'
 284         res['summary'] = self._get_summary_value(cr, uid, context)
 285         res['state'] = self._get_state_value(cr, uid, context)
 286         res['msg'] = """Before executing the anonymization process, you should make a backup of your database."""
 287
 288         return res
 289
 290     def fields_view_get(self, cr, uid, view_id=None, view_type='form', context=None, *args, **kwargs):
 291         state = self.pool.get('ir.model.fields.anonymization')._get_global_state(cr, uid, context=context)
 292         step = context.get('step', 'new_window')
 293
 294         res = super(ir_model_fields_anonymize_wizard, self).fields_view_get(cr, uid, view_id, view_type, context, *args, **kwargs)
 295
 296         eview = etree.fromstring(res['arch'])
 297         placeholder = eview.xpath("group[@name='placeholder1']")
 298         if len(placeholder):
 299             placeholder = placeholder[0]
 300             if step == 'new_window' and state == 'clear':
 301                 # clicked in the menu and the fields are not anonymized: warn the admin that backuping the db is very important
 302                 placeholder.addnext(etree.Element('field', {'name': 'msg', 'colspan': '4', 'nolabel': '1'}))
 303                 placeholder.addnext(etree.Element('newline'))
 304                 placeholder.addnext(etree.Element('label', {'string': 'Warning'}))
 305                 eview.remove(placeholder)
 306             elif step == 'new_window' and state == 'anonymized':
 307                 # clicked in the menu and the fields are already anonymized
 308                 placeholder.addnext(etree.Element('newline'))
 309                 placeholder.addnext(etree.Element('field', {'name': 'file_import', 'required': "1"}))
 310                 eview.remove(placeholder)
 311             elif step == 'just_anonymized':
 312                 # we just ran the anonymization process, we need the file export field
 313                 placeholder.addnext(etree.Element('newline'))
 314                 placeholder.addnext(etree.Element('field', {'name': 'file_export'}))
 315                 # we need to remove the button:
 316                 buttons = eview.xpath("button")
 317                 for button in buttons:
 318                     eview.remove(button)
 319                 # and add a message:
 320                 placeholder.addnext(etree.Element('field', {'name': 'msg', 'colspan': '4', 'nolabel': '1'}))
 321                 placeholder.addnext(etree.Element('newline'))
 322                 placeholder.addnext(etree.Element('label', {'string': 'Result'}))
 323                 # remove the placeholer:
 324                 eview.remove(placeholder)
 325             elif step == 'just_desanonymized':
 326                 # we just reversed the anonymization process, we don't need any field
 327                 # we need to remove the button
 328                 buttons = eview.xpath("button")
 329                 for button in buttons:
 330                     eview.remove(button)
 331                 # and add a message
 332                 # and add a message:
 333                 placeholder.addnext(etree.Element('field', {'name': 'msg', 'colspan': '4', 'nolabel': '1'}))
 334                 placeholder.addnext(etree.Element('newline'))
 335                 placeholder.addnext(etree.Element('label', {'string': 'Result'}))
 336                 # remove the placeholer:
 337                 eview.remove(placeholder)
 338             else:
 339                 # unstable ?
 340                 raise
 341
 342             res['arch'] = etree.tostring(eview)
 343
 344         return res
 345
 346     def _raise_after_history_update(self, cr, uid, history_id, error_type, error_msg):
 347         self.pool.get('ir.model.fields.anonymization.history').write(cr, uid, history_id, {
 348             'state': 'in_exception',
 349             'msg': error_msg,
 350         })
 351         raise osv.except_osv(error_type, error_msg)
 352
 353     def anonymize_database(self,cr, uid, ids, context=None):
 354         """Sets the 'anonymized' state to defined fields"""
 355
 356         # create a new history record:
 357         anonymization_history_model = self.pool.get('ir.model.fields.anonymization.history')
 358
 359         vals = {
 360             'date': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
 361             'state': 'started',
 362             'direction': 'clear -> anonymized',
 363         }
 364         history_id = anonymization_history_model.create(cr, uid, vals)
 365
 366         # check that all the defined fields are in the 'clear' state
 367         state = self.pool.get('ir.model.fields.anonymization')._get_global_state(cr, uid, context=context)
 368         if state == 'anonymized':
 369             self._raise_after_history_update(cr, uid, history_id, 'Error !', "The database is currently anonymized, you cannot anonymize it again.")
 370         elif state == 'unstable':
 371             msg = "The database anonymization is currently in an unstable state. Some fields are anonymized," + \
 372                   " while some fields are not anonymized. You should try to solve this problem before trying to do anything."
 373             self._raise_after_history_update(cr, uid, history_id, 'Error !', msg)
 374
 375         # do the anonymization:
 376         dirpath = os.environ.get('HOME') or os.getcwd()
 377         rel_filepath = 'field_anonymization_%s_%s.pickle' % (cr.dbname, history_id)
 378         abs_filepath = os.path.abspath(os.path.join(dirpath, rel_filepath))
 379
 380         ir_model_fields_anonymization_model = self.pool.get('ir.model.fields.anonymization')
 381         field_ids = ir_model_fields_anonymization_model.search(cr, uid, [('state', '<>', 'not_existing')], context=context)
 382         fields = ir_model_fields_anonymization_model.browse(cr, uid, field_ids, context=context)
 383
 384         if not fields:
 385             msg = "No fields are going to be anonymized."
 386             self._raise_after_history_update(cr, uid, history_id, 'Error !', msg)
 387
 388         data = []
 389
 390         for field in fields:
 391             model_name = field.model_id.model
 392             field_name = field.field_id.name
 393             field_type = field.field_id.ttype
 394             table_name = self.pool.get(model_name)._table
 395
 396             # get the current value
 397             sql = "select id, %s from %s" % (field_name, table_name)
 398             cr.execute(sql)
 399             records = cr.dictfetchall()
 400             for record in records:
 401                 data.append({"model_id": model_name, "field_id": field_name, "id": record['id'], "value": record[field_name]})
 402
 403                 # anonymize the value:
 404                 anonymized_value = None
 405
 406                 sid = str(record['id'])
 407                 if field_type == 'char':
 408                     anonymized_value = 'xxx'+sid
 409                 elif field_type == 'selection':
 410                     anonymized_value = 'xxx'+sid
 411                 elif field_type == 'text':
 412                     anonymized_value = 'xxx'+sid
 413                 elif field_type == 'boolean':
 414                     anonymized_value = random.choice([True, False])
 415                 elif field_type == 'date':
 416                     anonymized_value = '2011-11-11'
 417                 elif field_type == 'datetime':
 418                     anonymized_value = '2011-11-11 11:11:11'
 419                 elif field_type == 'float':
 420                     anonymized_value = 0.0
 421                 elif field_type == 'integer':
 422                     anonymized_value = 0
 423                 elif field_type in ['binary', 'many2many', 'many2one', 'one2many', 'reference']: # cannot anonymize these kind of fields
 424                     msg = "Cannot anonymize fields of these types: binary, many2many, many2one, one2many, reference"
 425                     self._raise_after_history_update(cr, uid, history_id, 'Error !', msg)
 426
 427                 if anonymized_value is None:
 428                     self._raise_after_history_update(cr, uid, history_id, 'Error !', "Anonymized value is None. This cannot happens.")
 429
 430                 sql = "update %(table)s set %(field)s = %%(anonymized_value)s where id = %%(id)s" % {
 431                     'table': table_name,
 432                     'field': field_name,
 433                 }
 434                 cr.execute(sql, {
 435                     'anonymized_value': anonymized_value,
 436                     'id': record['id']
 437                 })
 438
 439         # save pickle:
 440         fn = open(abs_filepath, 'w')
 441         pickle.dump(data, fn, pickle.HIGHEST_PROTOCOL)
 442
 443         # update the anonymization fields:
 444         values = {
 445             'state': 'anonymized',
 446         }
 447         ir_model_fields_anonymization_model.write(cr, uid, field_ids, values, context=context)
 448
 449         # add a result message in the wizard:
 450         msgs = ["Anonymization successful.",
 451                "",
 452                "Don't forget to save the resulting file to a safe place because you will not be able to revert the anonymization without this file.",
 453                "",
 454                "This file is also stored in the %s directory. The absolute file path is: %s",
 455               ]
 456         msg = '\n'.join(msgs) % (dirpath, abs_filepath)
 457
 458         fn = open(abs_filepath, 'r')
 459
 460         self.write(cr, uid, ids, {
 461             'msg': msg,
 462             'file_export': base64.encodestring(fn.read()),
 463         })
 464         fn.close()
 465
 466         # update the history record:
 467         anonymization_history_model.write(cr, uid, history_id, {
 468             'field_ids': [[6, 0, field_ids]],
 469             'msg': msg,
 470             'filepath': abs_filepath,
 471             'state': 'done',
 472         })
 473
 474         # handle the view:
 475         view_id = self._id_get(cr, uid, 'ir.ui.view', 'view_ir_model_fields_anonymize_wizard_form', 'anonymization')
 476
 477         return {
 478                 'res_id': ids[0],
 479                 'view_id': [view_id],
 480                 'view_type': 'form',
 481                 "view_mode": 'form',
 482                 'res_model': 'ir.model.fields.anonymize.wizard',
 483                 'type': 'ir.actions.act_window',
 484                 'context': {'step': 'just_anonymized'},
 485                 'target':'new',
 486         }
 487
 488     def reverse_anonymize_database(self,cr, uid, ids, context=None):
 489         """Set the 'clear' state to defined fields"""
 490
 491         ir_model_fields_anonymization_model = self.pool.get('ir.model.fields.anonymization')
 492         anonymization_history_model = self.pool.get('ir.model.fields.anonymization.history')
 493
 494         # create a new history record:
 495         vals = {
 496             'date': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
 497             'state': 'started',
 498             'direction': 'anonymized -> clear',
 499         }
 500         history_id = anonymization_history_model.create(cr, uid, vals)
 501
 502         # check that all the defined fields are in the 'anonymized' state
 503         state = ir_model_fields_anonymization_model._get_global_state(cr, uid, context=context)
 504         if state == 'clear':
 505             raise osv.except_osv('Error !', "The database is not currently anonymized, you cannot reverse the anonymization.")
 506         elif state == 'unstable':
 507             msg = "The database anonymization is currently in an unstable state. Some fields are anonymized," + \
 508                   " while some fields are not anonymized. You should try to solve this problem before trying to do anything."
 509             raise osv.except_osv('Error !', msg)
 510
 511         wizards = self.browse(cr, uid, ids, context=context)
 512         for wizard in wizards:
 513             if not wizard.file_import:
 514                 msg = "The anonymization export file was not supplied. It is not possible to reverse the anonymization process without this file."
 515                 self._raise_after_history_update(cr, uid, history_id, 'Error !', msg)
 516
 517             # reverse the anonymization:
 518             # load the pickle file content into a data structure:
 519             data = pickle.loads(base64.decodestring(wizard.file_import))
 520
 521             for line in data:
 522                 table_name = self.pool.get(line['model_id'])._table
 523                 sql = "update %(table)s set %(field)s = %%(value)s where id = %%(id)s" % {
 524                     'table': table_name,
 525                     'field': line['field_id'],
 526                 }
 527                 cr.execute(sql, {
 528                     'value': line['value'],
 529                     'id': line['id']
 530                 })
 531
 532             # update the anonymization fields:
 533             ir_model_fields_anonymization_model = self.pool.get('ir.model.fields.anonymization')
 534             field_ids = ir_model_fields_anonymization_model.search(cr, uid, [('state', '<>', 'not_existing')], context=context)
 535             values = {
 536                 'state': 'clear',
 537             }
 538             ir_model_fields_anonymization_model.write(cr, uid, field_ids, values, context=context)
 539
 540             # add a result message in the wizard:
 541             msg = '\n'.join(["Successfully reversed the anonymization.",
 542                              "",
 543                             ])
 544
 545             self.write(cr, uid, ids, {'msg': msg})
 546
 547             # update the history record:
 548             anonymization_history_model.write(cr, uid, history_id, {
 549                 'field_ids': [[6, 0, field_ids]],
 550                 'msg': msg,
 551                 'filepath': False,
 552                 'state': 'done',
 553             })
 554
 555             # handle the view:
 556             view_id = self._id_get(cr, uid, 'ir.ui.view', 'view_ir_model_fields_anonymize_wizard_form', 'anonymization')
 557
 558             return {
 559                     'res_id': ids[0],
 560                     'view_id': [view_id],
 561                     'view_type': 'form',
 562                     "view_mode": 'form',
 563                     'res_model': 'ir.model.fields.anonymize.wizard',
 564                     'type': 'ir.actions.act_window',
 565                     'context': {'step': 'just_desanonymized'},
 566                     'target':'new',
 567             }
 568
 569     def _id_get(self, cr, uid, model, id_str, mod):
 570         if '.' in id_str:
 571             mod, id_str = id_str.split('.')
 572         try:
 573             idn = self.pool.get('ir.model.data')._get_id(cr, uid, mod, id_str)
 574             res = int(self.pool.get('ir.model.data').read(cr, uid, [idn], ['res_id'])[0]['res_id'])
 575         except:
 576             res = None
 577         return res
 578
 579 ir_model_fields_anonymize_wizard()
 580