reorganize portfolio folder
This commit is contained in:
362
caotek_mesavoirs/views/portfolio.py
Normal file
362
caotek_mesavoirs/views/portfolio.py
Normal file
@@ -0,0 +1,362 @@
|
||||
# -*- coding: utf8 -*-
|
||||
from pyramid.response import Response
|
||||
from pyramid.renderers import render, get_renderer
|
||||
from pyramid.view import (
|
||||
view_config,
|
||||
forbidden_view_config,
|
||||
)
|
||||
from pyramid.httpexceptions import (
|
||||
HTTPFound,
|
||||
HTTPNotFound,
|
||||
HTTPForbidden,
|
||||
)
|
||||
from pyramid_mailer import get_mailer
|
||||
from pyramid_mailer.message import Message, Attachment
|
||||
from datetime import *
|
||||
import hashlib
|
||||
|
||||
from sqlalchemy.exc import DBAPIError
|
||||
from ..security import groupfinder
|
||||
|
||||
from ..models.default import *
|
||||
from ..models.portfolio import *
|
||||
from ..models.members import (
|
||||
get_member_by_email,
|
||||
)
|
||||
from ..views.default import (
|
||||
to_euro,
|
||||
to_usd,
|
||||
to_decimal,
|
||||
)
|
||||
|
||||
import json
|
||||
import time
|
||||
import yfinance as yf
|
||||
import html
|
||||
|
||||
@view_config(route_name='portfolio', renderer='../templates/portfolio/portfolio.pt', permission='view')
|
||||
def portfolio(request):
|
||||
logged_in = request.authenticated_userid
|
||||
member = get_member_by_email(request, logged_in)
|
||||
url = request.route_url('portfolio')
|
||||
|
||||
message = ''
|
||||
|
||||
# lire les categories
|
||||
items = get_allocation(request, '0')
|
||||
# construire la liste pour donut
|
||||
donut_cible=[]
|
||||
donut_cible.append(('Allocation cible', 'Pourcent'))
|
||||
donut_actuel=[]
|
||||
donut_actuel.append(('Allocation actuelle', 'Pourcent'))
|
||||
|
||||
# calculer % total
|
||||
total = 0
|
||||
for item in items:
|
||||
# construire la liste pour donut cible
|
||||
d = (item.classe, item.pc_cible)
|
||||
donut_cible.append(d)
|
||||
# construire la liste pour donut actuel
|
||||
d = (item.classe, int(item.pc_atteint * 10))
|
||||
donut_actuel.append(d)
|
||||
# totaliser les pourcentages
|
||||
total += item.pc_cible
|
||||
|
||||
if total != 100:
|
||||
message = 'Attention, le total de votre répartition cible est incorrect : %s.' % total
|
||||
|
||||
# lire les actifs
|
||||
actifs = get_actifs(request, '0')
|
||||
|
||||
# MAJ du prtefeuille
|
||||
if 'form.submitted' in request.params:
|
||||
# lire le cours de EURUSD
|
||||
ticker = yf.Ticker('EUR=X')
|
||||
# maj des parités des devises
|
||||
update_actif_devise(request, 'USD', ticker.info.get('regularMarketPrice'))
|
||||
|
||||
for item in actifs:
|
||||
if item.type == 'ACTION':
|
||||
# lire le cours de l'action
|
||||
ticker = yf.Ticker(item.symbole)
|
||||
# caluler son rendement
|
||||
dividends = get_dividends(ticker)
|
||||
update_actif_valeur(request, item.symbole, ticker.info.get('regularMarketPrice'), dividends)
|
||||
time.sleep(1) # attendre 2 secondes
|
||||
|
||||
# update du portefeuille
|
||||
update_portefeuille(request, logged_in)
|
||||
# relire les actifs
|
||||
actifs = get_actifs(request, '0')
|
||||
message = 'Le portefeuille est mis à jour avec succès.'
|
||||
|
||||
total_valeur = 0
|
||||
total_pv = 0
|
||||
total_rdt = 0
|
||||
for item in actifs:
|
||||
total_valeur += item.valeur
|
||||
total_pv += item.plus_value
|
||||
total_pc_value = total_pv / total_valeur * 100
|
||||
total_rdt += item.rendement
|
||||
|
||||
# lire l'historique
|
||||
histos = get_histo(request,'0')
|
||||
courbe_evoln=[]
|
||||
courbe_evoln.append(('Date', 'Valeur part PF', 'Valeur part CARINVT:FP'))
|
||||
|
||||
for item in histos:
|
||||
# construire la liste pour donut cible
|
||||
d = (item.date.strftime('%d/%m/%Y'), int(item.val_part * 1000), int(item.val_part_ref * 1000))
|
||||
courbe_evoln.append(d)
|
||||
|
||||
return {
|
||||
'page_title': "Portefeuille",
|
||||
'message': message,
|
||||
'url': url,
|
||||
'items': items,
|
||||
'member': member,
|
||||
'donut_cible': json.dumps(donut_cible),
|
||||
'donut_actuel': json.dumps(donut_actuel),
|
||||
'courbe_evoln': json.dumps(courbe_evoln),
|
||||
'actifs': actifs,
|
||||
'total_valeur': total_valeur,
|
||||
'total_pv': total_pv,
|
||||
'total_pc_value': total_pc_value,
|
||||
'total_rdt': total_rdt
|
||||
}
|
||||
|
||||
@view_config(route_name='actif_edit', renderer='../templates/portfolio/actif_edit.pt', permission='view')
|
||||
def actif_edit(request):
|
||||
no_id = request.matchdict['no_id']
|
||||
url = request.route_url('actif_edit', no_id=no_id)
|
||||
message = ''
|
||||
allocation_list = get_allocation_bytype(request,'ACTION')
|
||||
|
||||
if no_id == '0':
|
||||
# nouveau
|
||||
actif = {}
|
||||
actif['no_id'] = '0'
|
||||
actif['symbole'] = ''
|
||||
actif['libelle'] = ''
|
||||
actif['classe'] = ''
|
||||
actif['devise'] = 'EUR'
|
||||
actif['nombre'] = '0'
|
||||
actif['pru'] = '0'
|
||||
actif['ter'] = '0'
|
||||
actif['pc_rdt'] = '0'
|
||||
actif['website'] = ''
|
||||
actif['modif_le'] = None
|
||||
page_title= 'Nouvel actif ACTION'
|
||||
else:
|
||||
# lire la fiche du actif
|
||||
actif = get_actifs(request, no_id)
|
||||
if not actif:
|
||||
request.session.flash(u"Actif non trouvé : %s" % no_id, 'warning')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
page_title= "Actif ACTION : %s" % (actif.libelle)
|
||||
|
||||
if 'form.submitted' in request.params:
|
||||
new_values = {}
|
||||
for param, db_value in actif.items():
|
||||
if param in request.params and request.params[param] != db_value:
|
||||
new_values[param] = request.params[param]
|
||||
|
||||
if new_values:
|
||||
if 'symbole' in request.params:
|
||||
symbole = request.params['symbole']
|
||||
else:
|
||||
symbole = actif.symbole
|
||||
|
||||
# récupérer le cours du symbole de Yahoo finance
|
||||
ticker = yf.Ticker(symbole)
|
||||
new_values['cours'] = ticker.info.get('regularMarketPrice')
|
||||
new_values['devise'] = ticker.info.get('currency')
|
||||
new_values['libelle'] = html.unescape(ticker.info.get('shortName'))
|
||||
update_actif(request, no_id, new_values)
|
||||
request.session.flash(u"La fiche a été mise à jour avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
if 'form.deleted' in request.params:
|
||||
delete_actif(request, no_id)
|
||||
request.session.flash(u"La fiche a été supprimée avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
return {
|
||||
'page_title': page_title,
|
||||
'url': url,
|
||||
'actif': actif,
|
||||
'allocation_list': allocation_list,
|
||||
'message': message,
|
||||
}
|
||||
|
||||
@view_config(route_name='actif2_edit', renderer='../templates/portfolio/actif2_edit.pt', permission='view')
|
||||
def actif2_edit(request):
|
||||
no_id = request.matchdict['no_id']
|
||||
url = request.route_url('actif2_edit', no_id=no_id)
|
||||
message = ''
|
||||
allocation_list = get_allocation_bytype(request,'AUTRE')
|
||||
|
||||
if no_id == '0':
|
||||
# nouveau
|
||||
actif = {}
|
||||
actif['no_id'] = '0'
|
||||
actif['symbole'] = ''
|
||||
actif['classe'] = ''
|
||||
actif['libelle'] = ''
|
||||
actif['pru'] = '0'
|
||||
actif['cours'] = '0'
|
||||
actif['ter'] = '0'
|
||||
actif['pc_rdt'] = '0'
|
||||
actif['modif_le'] = None
|
||||
page_title= 'Nouvel actif'
|
||||
else:
|
||||
# lire la fiche du actif
|
||||
actif = get_actifs(request, no_id)
|
||||
if not actif:
|
||||
request.session.flash(u"Actif non trouvé : %s" % no_id, 'warning')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
page_title= "Actif : %s" % (actif.symbole)
|
||||
|
||||
if 'form.submitted' in request.params:
|
||||
new_values = {}
|
||||
for param, db_value in actif.items():
|
||||
if param in request.params and request.params[param] != db_value:
|
||||
new_values[param] = request.params[param]
|
||||
if new_values:
|
||||
new_values['nombre'] = 1000
|
||||
new_values['devise'] = 'EUR'
|
||||
update_actif(request, no_id, new_values)
|
||||
request.session.flash(u"La fiche a été mise à jour avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
if 'form.deleted' in request.params:
|
||||
delete_actif(request, no_id)
|
||||
request.session.flash(u"La fiche a été supprimée avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
return {
|
||||
'page_title': page_title,
|
||||
'url': url,
|
||||
'actif': actif,
|
||||
'allocation_list': allocation_list,
|
||||
'message': message,
|
||||
}
|
||||
|
||||
|
||||
@view_config(route_name='allocation_edit', renderer='../templates/portfolio/allocation_edit.pt', permission='view')
|
||||
def allocation_edit(request):
|
||||
no_cat = request.matchdict['no_cat']
|
||||
url = request.route_url('allocation_edit', no_cat=no_cat)
|
||||
message = ''
|
||||
# lire les classes
|
||||
classes_list = get_classes(request, '0')
|
||||
|
||||
if no_cat == '0':
|
||||
# nouveau
|
||||
allocation = {}
|
||||
allocation['no_cat'] = '0'
|
||||
allocation['classe'] = ''
|
||||
allocation['type'] = 'ACTION'
|
||||
allocation['pc_cible'] = '0'
|
||||
page_title= 'Nouvelle classe'
|
||||
else:
|
||||
# lire la fiche de la categorie
|
||||
allocation = get_allocation(request, no_cat)
|
||||
if not allocation:
|
||||
request.session.flash(u"Classe non trouvé : %s" % no_cat, 'warning')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
page_title= "Classe : %s" % (allocation.classe)
|
||||
|
||||
if 'form.submitted' in request.params:
|
||||
new_values = {}
|
||||
for param, db_value in allocation.items():
|
||||
if param in request.params and request.params[param] != db_value:
|
||||
new_values[param] = request.params[param]
|
||||
|
||||
if new_values:
|
||||
update_allocation(request, no_cat, new_values)
|
||||
request.session.flash(u"La fiche a été mise à jour avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
if 'form.deleted' in request.params:
|
||||
delete_allocation(request, no_cat)
|
||||
request.session.flash(u"La fiche a été supprimée avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('portfolio'))
|
||||
|
||||
return {
|
||||
'page_title': page_title,
|
||||
'url': url,
|
||||
'allocation': allocation,
|
||||
'classes_list': classes_list,
|
||||
'message': message,
|
||||
}
|
||||
|
||||
@view_config(route_name='histo_list', renderer='../templates/portfolio/histo_list.pt', permission='manage')
|
||||
def histo_list(request):
|
||||
# lire l historique
|
||||
items = get_histo(request, '0')
|
||||
|
||||
liste=[]
|
||||
for item in items:
|
||||
# construire la liste pour datatable
|
||||
d = (item.date.strftime('%d/%m/%Y'), to_euro(item.mvt_cash), to_euro(item.valeur_pf), str(item.nb_part),
|
||||
to_euro(item.val_part), to_euro(item.cours_ref), to_euro(item.val_part_ref), str(item.no_id).zfill(4))
|
||||
liste.append(d)
|
||||
|
||||
return {
|
||||
'page_title': 'Historique',
|
||||
'dt_data': json.dumps(liste),
|
||||
}
|
||||
|
||||
@view_config(route_name='histo_edit', renderer='../templates/portfolio/histo_edit.pt', permission='view')
|
||||
def histo_edit(request):
|
||||
no_id = request.matchdict['no_id']
|
||||
url = request.route_url('histo_edit', no_id=no_id)
|
||||
message = ''
|
||||
today = datetime.today()
|
||||
|
||||
if no_id == '0':
|
||||
# nouveau
|
||||
item = {}
|
||||
item['no_id'] = 0
|
||||
item['date'] = today
|
||||
item['mvt_cash'] = 0.0
|
||||
item['nb_part'] = 0.0
|
||||
page_title= 'Nouvelle valeur part'
|
||||
else:
|
||||
# lire la fiche de la categorie
|
||||
item = get_histo(request, no_id)
|
||||
if not item:
|
||||
request.session.flash(u"Histo non trouvé : %s" % no_id, 'warning')
|
||||
return HTTPFound(location=request.route_url('histo_list'))
|
||||
page_title= "Valeur part au %s" % (item.date.strftime('%d/%m/%Y'))
|
||||
|
||||
if 'form.submitted' in request.params:
|
||||
new_values = {}
|
||||
for param, db_value in item.items():
|
||||
if param in request.params and request.params[param] != db_value:
|
||||
new_values[param] = request.params[param]
|
||||
|
||||
if new_values:
|
||||
# lire le cours de l'indice de réfence : Carmignac Investissement A EUR Acc
|
||||
ticker = yf.Ticker('0P00000FB2.F')
|
||||
new_values['cours_ref'] = ticker.info.get('regularMarketPrice')
|
||||
|
||||
update_histo(request, no_id, new_values)
|
||||
request.session.flash(u"La fiche a été mise à jour avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('histo_list'))
|
||||
|
||||
|
||||
if 'form.deleted' in request.params:
|
||||
delete_histo(request, no_id)
|
||||
request.session.flash(u"La fiche a été supprimée avec succès.", 'success')
|
||||
return HTTPFound(location=request.route_url('histo_list'))
|
||||
|
||||
return {
|
||||
'page_title': page_title,
|
||||
'url': url,
|
||||
'item': item,
|
||||
'today': today,
|
||||
'message': message,
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user