--- /dev/null
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# OpenERP, Open Source Management Solution
+# Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>). 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 <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+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:
--- /dev/null
+<openerp>
+<data>
+ <record model="ir.ui.view" id="lp_project_milestone_form">
+ <field name="name">project.milestone.form</field>
+ <field name="model">project.milestone</field>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <form string="Milestone">
+ <field name="name"/>
+ <field name="series_id" />
+ <field name="project_id" />
+ <field name="expect_date" />
+ </form>
+ </field>
+ </record>
+ <record model="ir.ui.view" id="lp_project_milestone_tree">
+ <field name="name">project.milsetone.tree</field>
+ <field name="model">project.milestone</field>
+ <field name="type">tree</field>
+ <field name="arch" type="xml">
+ <tree string="Milestone">
+ <field name="name"/>
+ <field name="series_id" />
+ <field name="project_id" />
+ <field name="expect_date" />
+ </tree>
+ </field>
+ </record>
+
+ <record model="ir.actions.act_window" id="action_lp_milestone">
+ <field name="name">LP Milestones</field>
+ <field name="res_model">project.milestone</field>
+ <field name="view_type">form</field>
+ <field name="view_mode">tree,form</field>
+ <field name="view_id" ref="lp_project_milestone_tree"/>
+ </record>
+
+ <record model="ir.ui.view" id="form_lp_series">
+ <field name="name">lp.series</field>
+ <field name="model">lp.series</field>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <form string="Project Series ">
+ <field name="name"/>
+ <field name="status"/>
+ <field name="summary"/>
+ <field name="project_id"/>
+ <separator string="Milestone Information" colspan="4" />
+ <field name="milestone_ids" colspan="4" nolabel="1" />
+ </form>
+ </field>
+ </record>
+
+ <record model="ir.ui.view" id="tree_lp_series">
+ <field name="name">project.series</field>
+ <field name="model">project.series</field>
+ <field name="type">tree</field>
+ <field name="arch" type="xml">
+ <tree string="Project Series ">
+ <field name="name"/>
+ <field name="status"/>
+ <field name="project_id"/>
+ </tree>
+ </field>
+ </record>
+
+
+ <record model="ir.actions.act_window" id="action_lp_series">
+ <field name="name">Project Series</field>
+ <field name="res_model">project.series</field>
+ <field name="view_type">form</field>
+ <field name="view_mode">tree,form</field>
+ <field name="view_id" ref="tree_lp_series"/>
+ </record>
+
+ <record model="ir.ui.view" id="view_lp_project_form">
+ <field name="name">project.project.form</field>
+ <field name="model">project.project</field>
+ <field name="inherit_id" ref="project.edit_project"/>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <notebook position="inside">
+ <page string="LP Project Information">
+ <field name="flag"/>
+ <field name="bugs_target" colspan="4" />
+ <field name="series_ids" colspan="4" nolabel="1" />
+ </page>
+ </notebook>
+ </field>
+ </record>
+
+ <record model="ir.ui.view" id="view_crm_lp_form">
+ <field name="name">crm.case</field>
+ <field name="model">crm.case</field>
+ <field name="inherit_id" ref="crm.crm_case-view"/>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <field name="id" position="after">
+ <field name="project_id"/>
+ <field name="bug_id"/>
+ <field name="milestone_id"/>
+ <field name="bug_owner_id"/>
+ </field>
+ </field>
+ </record>
+
+ <record model="ir.ui.view" id="view_crm_lp_users_form">
+ <field name="name">res.users.lp.form</field>
+ <field name="model">res.users</field>
+ <field name="inherit_id" ref="base.view_users_form"/>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <field name="password" position="after">
+ <field name="lp_login"/>
+ </field>
+ </field>
+ </record>
+
+ <record model="ir.ui.view" id="view_crm_bug_history_form">
+ <field name="name">crm.case.lp.history</field>
+ <field name="model">crm.case.history</field>
+ <field name="inherit_id" ref="crm.crm_case_history-view"/>
+ <field name="type">form</field>
+ <field name="arch" type="xml">
+ <field name="user_id" position="after">
+ <field name="bug_owner_id"/>
+ <field name="filename"/>
+ </field>
+ </field>
+ </record>
+<menuitem id="base.menu_pm_planning" name="Planning" parent="project.menu_main" sequence="3"/>
+<!--<menuitem name="Project Series" id="menu_lp_series" parent="base.menu_pm_planning" action="action_lp_series"/>-->
+<menuitem name="Project Milestones" id="menu_lp_milestones" parent="base.menu_pm_planning" action="action_lp_milestone" sequence="1"/>
+</data>
+
+</openerp>
projects / odoo / odoo.git / commitdiff