diff --git a/addons/auction/auction_wizard.xml b/addons/auction/auction_wizard.xml index 95c2ca16858..0a93799cc20 100644 --- a/addons/auction/auction_wizard.xml +++ b/addons/auction/auction_wizard.xml @@ -44,7 +44,7 @@ ). All Rights Reserved +# $Id$ +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see . +# +############################################################################## +import crm_lp +import wizard + + +# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: diff --git a/addons/crm_lp/__terp__.py b/addons/crm_lp/__terp__.py new file mode 100644 index 00000000000..2c016f00c3e --- /dev/null +++ b/addons/crm_lp/__terp__.py @@ -0,0 +1,45 @@ +# -*- encoding: utf-8 -*- +############################################################################## +# +# OpenERP, Open Source Management Solution +# Copyright (C) 2004-2009 Tiny SPRL (). All Rights Reserved +# $Id$ +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see . +# +############################################################################## + + +{ + 'name': 'Customer Relationship Management', + 'version': '1.0', + 'category': 'Generic Modules/CRM & SRM', + 'description': """ + This module provide synchronize between lp bugs with openobject cases + """, + 'author': 'Tiny', + 'website': 'http://www.openerp.com', + 'depends': [ 'crm','project'], + 'init_xml': [ + #'crm_lp_data.xml', + ], + 'update_xml': [ + 'crm_lp.xml', + 'crm_lp_wizard.xml'], + 'demo_xml': [], + 'installable': True, + 'active': False, + 'certificate': '', +} +# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: diff --git a/addons/crm_lp/crm_lp.py b/addons/crm_lp/crm_lp.py new file mode 100644 index 00000000000..161dde30bcb --- /dev/null +++ b/addons/crm_lp/crm_lp.py @@ -0,0 +1,462 @@ +# -*- encoding: utf-8 -*- +############################################################################## +# +# OpenERP, Open Source Management Solution +# Copyright (C) 2004-2009 Tiny SPRL (). All Rights Reserved +# $Id$ +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see . +# +############################################################################## + +import time +import tools +from osv import fields,osv,orm +import pooler + +import mx.DateTime +import base64 +from tools.translate import _ +from SimpleXMLRPCServer import SimpleXMLRPCServer +from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler +import os +import threading +import pickle +import time +import sys +import datetime + +try: + from launchpadlib.launchpad import Launchpad, EDGE_SERVICE_ROOT + from launchpadlib.credentials import Credentials +except: + raise osv.except_osv('Warning!','Please install launchpadlib direction package from https://help.launchpad.net/API/launchpadlib#Installation ') + +class lpServer(threading.Thread): + launchpad = False + + def __init__(self): + super(lpServer, self).__init__() + self.launchpad = self.get_lp() + + def get_lp(self): + launchpad = False + cachedir = os.path.expanduser('~/.launchpadlib/cache') + if not os.path.exists(cachedir): + os.makedirs(cachedir,0700) + credfile = os.path.expanduser('~/.launchpadlib/credentials') + try: + credentials = Credentials() + credentials.load(open(credfile)) + launchpad = Launchpad(credentials, EDGE_SERVICE_ROOT, cachedir) + except: + launchpad = Launchpad.get_token_and_login(sys.argv[0], EDGE_SERVICE_ROOT, cachedir) + return launchpad + + + def get_lp_bugs(self, projects): + launchpad = self.launchpad + res = {} + if not launchpad: + return res + if not isinstance(projects,list): + projects = [projects] + + bug_status=[] + for project in projects: + result = {} + r = {} + lp_project = self.launchpad.projects[str(project)] + result['non-series'] = lp_project.searchTasks(status=bug_status) + if 'series' in lp_project.lp_collections: + for series in lp_project.series: + result[series.name] = series.searchTasks() + bug_list=[] + for name, bugs in result.items(): + for bug in bugs: + bug_list.append(bug) + res[project]=bug_list + return res + + def getProject(self, project): + try: + project = self.launchpad.projects[project] + except: + return None + return project + + def getSeries(self, project): + lp_project = self.launchpad.projects[project] + if 'series' in lp_project.lp_collections: + return lp_project.series.entries + else: + return None + + def getMilestones(self, project, ml): + lp_project =self.launchpad.projects[project] + if 'all_milestones' in lp_project.lp_collections: + temp = lp_project.all_milestones.entries + res = [item for item in temp if item['series_target_link'] == ml] + return res + else: + return None + +class project_project(osv.osv): + _inherit = "project.project" + _columns = { + 'series_ids' : fields.one2many('project.series', 'project_id', 'LP Series'), + 'milestone_ids' : fields.one2many('project.milestone', 'project_id', 'LP Milestone'), + 'bugs_target': fields.char('Bugs Target', size=300), + 'flag':fields.boolean('Synchronize Lp'), + } + def write(self, cr, uid, ids, vals, context=None, check=True, update_check=True): + if vals.get('name' , False): + vals['bugs_target'] = "https://api.edge.launchpad.net/beta/" + vals['name'] + return super(osv.osv, self).write(cr, uid, ids, vals, context) + +project_project() + +class project_series(osv.osv): + _name="project.series" + _description="Project Series" + _columns={ + 'name':fields.char("Series Name",size=200, required=True, help="The name of the series"), + 'status': fields.char("Status", size=100), + 'summary': fields.char("Summary", size=1000, help="The summary should be a single short paragraph."), + 'project_id': fields.many2one('project.project', 'LP Project', ondelete='cascade'), + 'milestone_ids' : fields.one2many('project.milestone', 'series_id', 'LP Milestone'), + } +project_series() + +class project_milestone(osv.osv): + _name="project.milestone" + _description= "Project milestone" + _columns={ + 'name':fields.char('Version', size=100,required=True), + 'series_id':fields.many2one('project.series', 'Series', readonly=True,ondelete='cascade'), + 'project_id': fields.many2one('project.project', 'Project', readonly=True), + 'expect_date': fields.datetime('Expected Date', readonly=True), + } + +project_milestone() + +class crm_case(osv.osv): + _inherit = "crm.case" + + _columns = { + 'project_id': fields.many2one('project.project', 'Project'), + 'bug_id': fields.integer('Bug ID',readonly=True), + 'milestone_id': fields.many2one('project.milestone', 'Milestone'), + 'bug_owner_id': fields.many2one('res.users', 'Bug Owner'), + } + + def write(self, cr, uid, ids, vals, context=None, check=True, update_check=True): + attrs = ['stage_id', 'priority'] + for attr in attrs: + if attr in vals: + vals['date_action_last'] = time.strftime('%Y-%m-%d %H:%M:%S') + result = super(osv.osv, self).write(cr, uid, ids, vals, context) + return result + + def _check_bug(self, cr, uid, ids=False, context={}): + ''' + Function called by the scheduler to process cases for date actions + Only works on not done and cancelled cases + ''' + val={} + pool=pooler.get_pool(cr.dbname) + sec_obj = pool.get('crm.case.section') + section_id = sec_obj.search(cr, uid, [('code', '=', 'BugSup')]) + if section_id: + lp_server = lpServer() + self._create_bug(cr, uid, section_id,lp_server, context) + self._find_project_bug(cr,uid,section_id,lp_server) + return True + + def _create_bug(self, cr, uid, section_id,lp_server=None,context={}): + pool=pooler.get_pool(cr.dbname) + case_stage= pool.get('crm.case.stage') + + crm_case_obj = pool.get('crm.case') + for sec_id in section_id: + crm_ids=crm_case_obj.search(cr,uid,[('bug_id','=',False),('section_id','=',sec_id),('project_id','!=',False)]) + launchpad = lp_server.launchpad + if crm_ids: + for case in crm_case_obj.browse(cr,uid, crm_ids): + title = case.name + target = case.project_id.bugs_target + if not target: + target = "https://api.edge.launchpad.net/beta/" + case.project_id.name + description=case.description + b=launchpad.bugs.createBug(title=title, target=target, description=description) + if b: + bool = self.write(cr,uid,case.id,{'bug_id' : b.id},context=None) + status='New' + imp ='Undecided' + if case.stage_id.name == 'Future' and case.priority == '5': + imp = 'Wishlist' + elif case.priority == '1': + imp = 'High' + elif case.priority == '3': + imp = 'Medium' + if case.stage_id.name == 'Fixed': + status = 'Fix Released' + if case.stage_id.id == 'Invalid': + status = 'invalid' + t=b.bug_tasks[0] + t.status = status + t.importance = imp + t.lp_save() + return True + + + def _find_project_bug(self, cr, uid,section_id,lp_server=None,context={}): + + pool=pooler.get_pool(cr.dbname) + case_stage= pool.get('crm.case.stage') + for sec_id in section_id: + categ_fix_id=case_stage.search(cr, uid, [('section_id','=',sec_id),('name','=','Fixed')])[0] + categ_inv_id=case_stage.search(cr, uid, [('section_id','=',sec_id),('name','=','Invalid')])[0] + categ_future_id=case_stage.search(cr, uid, [('section_id','=',sec_id), ('name','=','Future')])[0] + categ_wfix_id=case_stage.search(cr, uid, [('section_id','=',sec_id),('name','=',"Won't fix")])[0] + val={} + res={} + series_ids=[] + prj = self.pool.get('project.project') + project_id=prj.search(cr,uid,[]) + for prj_id in prj.browse(cr,uid, project_id): + project_name=str(prj_id.name) + lp_project = lp_server.getProject(project_name) + if lp_project and prj_id.flag: + prjs=lp_server.get_lp_bugs(project_name) + self._get_project_series( cr, uid,lp_project,prj_id.id,lp_server) + for key, bugs in prjs.items(): + for bug in bugs: + b_id = self.search(cr,uid,[('bug_id','=',bug.bug.id)]) + val['project_id']=prj_id.id + val['description']=bug.bug.description + val['bug_id']=bug.bug.id + val['name']=bug.bug.title + val['section_id']=sec_id + owner = bug.owner + parnter_rec=self.pool.get('res.partner') + user_rec=self.pool.get('res.users') + partner_id = parnter_rec.search(cr,uid,[('name', '=',owner.display_name)]) + user_id = user_rec.search(cr,uid,[('login', '=',owner.name)]) + if not partner_id and not user_id : + res={} + res['name']=owner.display_name + res['login']=owner.name + res['password']=owner.name + res['lp_login']=owner.name + user_id = user_rec.create(cr,uid,res,context=context) + partner_id = parnter_rec.create(cr, uid, {'name': owner.display_name,'user_id':user_id}) + else: + partner_id= partner_id[0] + user_id=user_id[0] + if bug.assignee: + assing_id = user_rec.search(cr,uid,[('login', '=', bug.assignee.name)]) + if assing_id: + val['user_id']=assing_id[0] + else: + res={} + res['name']=bug.assignee.name + res['login']=bug.assignee.name + res['password']=bug.assignee.name + res['lp_login']=bug.assignee.name + assing_id = user_rec.create(cr,uid,res,context=context) + val['user_id']=assing_id + val['partner_id'] =partner_id + val['bug_owner_id']= user_id + if bug.importance == 'Wishlist': + val['stage_id']=categ_future_id + val['priority']='5' + elif bug.importance == 'Critical': + val['priority']='1' + val['state']='open' + elif bug.importance=='High': + val['priority']='2' + val['state']='open' + elif bug.importance=='Medium': + val['priority']='3' + val['state']='open' + if bug.status =='Fix Released': + val['stage_id']=categ_fix_id + val['state']='done' + if bug.status =='invaild': + val['stage_id']= val['stage_id']=categ_inv_id + val['state']='cancel' + if bug.status=='Confirmed': + val['state']='open' + if bug.milestone_link: + val['milestone_url']=bug.milestone_link + ml = bug.milestone_link.rsplit('/',1)[0] + ml_ids = self.pool.get('project.milestone').search(cr, uid, [('project_id','=',prj_id.id),('name','=', ml)]) + if not b_id: + bug_id=self.create(cr, uid, val,context=context) + self._check_state(cr, uid,[bug_id],val) + self._store_bug_history(cr, uid , bug_id,bug,val['bug_owner_id']) + if b_id: + crm_case = self.browse(cr,uid, b_id[0]) + lp_last_up_time = str(bug.bug.date_last_updated).split('.')[0] + lp_last_up_timestamp = time.mktime(time.strptime(lp_last_up_time,"%Y-%m-%dT%H:%M:%S"))+ time.timezone + if not crm_case.date_action_last: + local_last_up_time=0 + local_last_up_timestamp = 0 + local_last_up_timestamp1=0 + else: + local_last_up_time = str(crm_case.date_action_last).split('.')[0] + local_last_up_timestamp = time.mktime(time.strptime(local_last_up_time,"%Y-%m-%dT%H:%M:%S")) + time.timezone + local_last_up_timestamp1 = time.mktime(time.strptime(local_last_up_time,'%Y-%m-%dT%H:%M:%S')) + + args = (cr, uid, context, [sec_id], crm_case, bug, val) + if lp_last_up_timestamp >= local_last_up_timestamp: + self._update_local_record(*args) + elif lp_last_up_timestamp < local_last_up_timestamp: + self._update_lp_record(*args) + cr.commit() + return True + + def _get_project_series(self, cr, uid,lp_project,lp_project_id,lp_server=None,context={}): + pool=pooler.get_pool(cr.dbname) + all_series = lp_server.getSeries(lp_project) + if all_series: + prj_milestone_ids=[] + lp_series = pool.get('project.series') + for series in all_series: + res={} + ids = self.pool.get('project.series').search(cr, uid, [('project_id','=',lp_project_id),('name','=', series['name'])]) + if not ids: + res['name'] = series['name'] + res['status'] = series['status'] + res['summary'] = series['summary'] + res['project_id'] = lp_project_id + lp_series_id=lp_series.create(cr, uid, res,context=context) + ml = series['all_milestones_collection_link'].rsplit('/',1)[0] + cr.commit() + self._get_project_milestone(cr, uid, lp_series_id,ml,lp_project,lp_project_id, lp_server) + return True + + def _get_project_milestone(self, cr, uid,lp_series_id,milestone,lp_project,lp_project_id,lp_server=None,context={}): + pool=pooler.get_pool(cr.dbname) + res={} + all_milestones = lp_server.getMilestones(lp_project, milestone) + if all_milestones: + milestone_ids=[] + lp_milestones = pool.get('project.milestone') + for ms in all_milestones: + ids = self.pool.get('project.milestone').search(cr, uid, [('project_id','=',lp_project_id),('series_id','=',lp_series_id),('name','=', ms['name'])]) + if not ids: + res['name'] = ms['name'] + res['series_id'] = lp_series_id + res['project_id'] = lp_project_id + if ms['date_targeted']: + res['expect_date'] = ms['date_targeted'] + lp_milestones_id=lp_milestones.create(cr, uid, res,context=context) + cr.commit() + return True + + def _update_local_record(self, cr, uid, context, sec_id, crm_bug, lp_bug, val): + pool=pooler.get_pool(cr.dbname) + case= pool.get('crm.case') + b=case.write(cr,uid,crm_bug.id,val,context=context) + if b: + case._check_state(cr, uid,[crm_bug.id],val) + return True + + def _update_lp_record(self, cr, uid, context, sec_id, crm_bug, lp_bug, val): + pool=pooler.get_pool(cr.dbname) + case_stage= pool.get('crm.case.stage') + + status='New' + imp ='Undecided' + if crm_bug.stage_id.name == 'Future' and crm_bug.priority == '5': + imp = 'Wishlist' + elif crm_bug.priority == '1': + imp = 'Critical' + elif crm_bug.priority == '2': + imp = 'High' + elif crm_bug.priority == '3': + imp = 'Medium' + if crm_bug.stage_id.name == 'Fixed': + status = 'Fix Released' + if crm_bug.stage_id.name == 'Invalid': + status = 'Invalid' + t=lp_bug.bug.bug_tasks[0] + t.status = status + t.importance = imp + t.lp_save() + return True + + def _check_state(self, cr, uid,bug_id,vals={}): + partner = self.pool.get('res.users').browse(cr, uid, uid).address_id.partner_id.id + if not vals['partner_id']: + vals['partner_id']=partner + if vals['state']=='open': + self.case_open(cr,uid,bug_id) + if vals['state']=='cancel': + self.case_cancel(cr,uid,bug_id) + if vals['state']=='done': + self.case_close(cr,uid,bug_id) + return True + + def _store_bug_history(self, cr, uid,bug_id,bug,user_id,context={}): + obj = self.pool.get('crm.case.history') + for key in bug.bug.messages.entries: + if key['self_link'].rsplit('/',1)[1]!=0: + if bug.bug.attachments: + attachment = bug.bug.attachments[0] + attachment_data = attachment.data + attachment_fd = attachment_data.open() + attach_id=self.pool.get('ir.attachment').create(cr, uid, { + 'name': attachment_fd.filename.split('.')[0], + 'datas': base64.encodestring(attachment_fd.read()), + 'datas_fname':attachment_fd.filename, + 'res_model': 'crm.case', + 'res_id': bug_id, + }, context=context ) + + data = { + 'name': bug.status, + 'user_id': uid, + 'case_id': bug_id, + 'description':key['content'], + 'bug_owner_id':user_id, + 'filename':attach_id} + else: + data = { + 'name': bug.status, + 'user_id': uid, + 'case_id': bug_id, + 'description':key['content'], + 'bug_owner_id':user_id} + obj.create(cr, uid, data, context) + cr.commit() + return True +crm_case() + +class res_users(osv.osv): + _inherit = 'res.users' + _columns = { + 'lp_login': fields.char('Launchpad Login', size=100), + } +res_users() +class crm_case_history(osv.osv): + _inherit = 'crm.case.history' + _columns = { + 'bug_owner_id': fields.many2one('res.users', 'Bug Owner'), + 'filename':fields.many2one('ir.attachment','File'), + } +crm_case_history() +# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: diff --git a/addons/crm_lp/crm_lp.xml b/addons/crm_lp/crm_lp.xml new file mode 100644 index 00000000000..0b97099ba09 --- /dev/null +++ b/addons/crm_lp/crm_lp.xml @@ -0,0 +1,136 @@ + + + + project.milestone.form + project.milestone + form + +
+ + + + + + +
+ + project.milsetone.tree + project.milestone + tree + + + + + + + + + + + + LP Milestones + project.milestone + form + tree,form + + + + + lp.series + lp.series + form + +
+ + + + + + + + +
+ + + project.series + project.series + tree + + + + + + + + + + + + Project Series + project.series + form + tree,form + + + + + project.project.form + project.project + + form + + + + + + + + + + + + + crm.case + crm.case + + form + + + + + + + + + + + + res.users.lp.form + res.users + + form + + + + + + + + + crm.case.lp.history + crm.case.history + + form + + + + + + + + + + + + + diff --git a/addons/crm_lp/crm_lp_data.xml b/addons/crm_lp/crm_lp_data.xml new file mode 100644 index 00000000000..282e03fd613 --- /dev/null +++ b/addons/crm_lp/crm_lp_data.xml @@ -0,0 +1,16 @@ + + + + + Check Bug + 1 + hours + -1 + + + + + + + + diff --git a/addons/crm_lp/crm_lp_wizard.xml b/addons/crm_lp/crm_lp_wizard.xml new file mode 100644 index 00000000000..d622b778530 --- /dev/null +++ b/addons/crm_lp/crm_lp_wizard.xml @@ -0,0 +1,10 @@ + + + + + + diff --git a/addons/crm_lp/wizard/__init__.py b/addons/crm_lp/wizard/__init__.py new file mode 100644 index 00000000000..84c775dfe1a --- /dev/null +++ b/addons/crm_lp/wizard/__init__.py @@ -0,0 +1,23 @@ +# -*- encoding: utf-8 -*- +############################################################################## +# +# OpenERP, Open Source Management Solution +# Copyright (C) 2004-2009 Tiny SPRL (). All Rights Reserved +# $Id$ +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see . +# +############################################################################## +import wizard_crm_lp_sync +# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: diff --git a/addons/crm_lp/wizard/wizard_crm_lp_sync.py b/addons/crm_lp/wizard/wizard_crm_lp_sync.py new file mode 100644 index 00000000000..a8310557d2e --- /dev/null +++ b/addons/crm_lp/wizard/wizard_crm_lp_sync.py @@ -0,0 +1,57 @@ +############################################################################## +# +# OpenERP, Open Source Management Solution +# Copyright (C) 2004-2009 Tiny SPRL (). +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU Affero General Public License as +# published by the Free Software Foundation, either version 3 of the +# License, or (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU Affero General Public License for more details. +# +# You should have received a copy of the GNU Affero General Public License +# along with this program. If not, see . +# +############################################################################## + +import wizard +import pooler +from osv import osv +import time +import sys + +form = ''' +
+