1013 lines
42 KiB
Python
1013 lines
42 KiB
Python
# -*- coding: utf-8 -*-
|
|
#!/usr/bin/env python
|
|
|
|
import os
|
|
import sys
|
|
import csv
|
|
|
|
from datetime import datetime, time
|
|
from dateutil.relativedelta import relativedelta
|
|
|
|
import calebasse.settings
|
|
import django.core.management
|
|
|
|
django.core.management.setup_environ(calebasse.settings)
|
|
|
|
from django.contrib.auth.models import User
|
|
|
|
from calebasse.agenda.models import Event, EventType
|
|
from calebasse.dossiers.models import PatientRecord, Status, FileState, PatientAddress, PatientContact
|
|
from calebasse.ressources.models import Service
|
|
from calebasse.personnes.models import Worker, Holiday, ExternalWorker, ExternalTherapist
|
|
from calebasse.ressources.models import (WorkerType, ParentalAuthorityType, ParentalCustodyType,
|
|
FamilySituationType, TransportType, TransportCompany, Provenance, AnalyseMotive, FamilyMotive,
|
|
CodeCFTMEA, SocialisationDuration, School, SchoolLevel, OutMotive, OutTo, AdviceGiver,
|
|
MaritalStatusType, Job, PatientRelatedLink, HealthCenter)
|
|
|
|
# Configuration
|
|
db_path = "./scripts/20130104-213225"
|
|
|
|
#dbs = ["F_ST_ETIENNE_SESSAD_TED", "F_ST_ETIENNE_CMPP", "F_ST_ETIENNE_CAMSP", "F_ST_ETIENNE_SESSAD"]
|
|
dbs = ["F_ST_ETIENNE_SESSAD_TED"]
|
|
|
|
|
|
map_cs = {}
|
|
map_cs['CAMSP'] = {
|
|
'1': 'ACT_DOUBLE',
|
|
'2': 'ABS_NON_EXC',
|
|
'3': 'ABS_EXC',
|
|
'4': 'ABS_INTER',
|
|
'5': 'ACT_LOST',
|
|
'6': 'ANNUL_NOUS',
|
|
'7': 'ANNUL_FAMILLE',
|
|
'8': 'ENF_HOSP',
|
|
'9': 'ACT_LOST',
|
|
'10': 'ACT_LOST',
|
|
'11': 'ACT_LOST',
|
|
'12': 'REPORTE'
|
|
}
|
|
|
|
map_cs['CMPP'] = {
|
|
'1': 'ACT_DOUBLE',
|
|
'2': 'ABS_NON_EXC',
|
|
'3': 'ABS_EXC',
|
|
'4': 'ABS_INTER',
|
|
'5': 'ACT_LOST',
|
|
'6': 'ANNUL_NOUS',
|
|
'7': 'ANNUL_FAMILLE',
|
|
'8': 'ABS_ESS_PPS',
|
|
'9': 'ACT_LOST',
|
|
'10': 'ACT_LOST',
|
|
'11': 'ACT_LOST',
|
|
'12': 'REPORTE'
|
|
}
|
|
|
|
map_cs['SESSAD DYS'] = {
|
|
'1': 'ACT_DOUBLE',
|
|
'2': 'ABS_NON_EXC',
|
|
'3': 'ABS_EXC',
|
|
'4': 'ABS_INTER',
|
|
'5': 'ACT_LOST',
|
|
'6': 'ANNUL_NOUS',
|
|
'7': 'ANNUL_FAMILLE',
|
|
'8': 'ABS_ESS_PPS',
|
|
'9': 'ACT_LOST',
|
|
'10': 'ACT_LOST',
|
|
'11': 'REPORTE'
|
|
}
|
|
|
|
|
|
map_cs['SESSAD TED'] = {
|
|
'1': 'ACT_DOUBLE',
|
|
'2': 'ABS_NON_EXC',
|
|
'3': 'ABS_EXC',
|
|
'4': 'ACT_LOST',
|
|
'5': 'ABS_INTER',
|
|
'6': 'ANNUL_NOUS',
|
|
'7': 'ANNUL_FAMILLE',
|
|
'8': 'REPORTE'
|
|
}
|
|
|
|
def _exist(str):
|
|
if str and str != "" and str != '0':
|
|
return True
|
|
return False
|
|
|
|
def treat_name(name):
|
|
res = ''
|
|
for p in name.split():
|
|
res += p[0].upper()+p[1:].lower()
|
|
res += ' '
|
|
return res[:-1]
|
|
|
|
def _to_date(str_date):
|
|
if not str_date:
|
|
return None
|
|
return datetime.strptime(str_date[:-13], "%Y-%m-%d")
|
|
|
|
def _to_int(str_int):
|
|
if not str_int:
|
|
return None
|
|
return int(str_int)
|
|
|
|
def _get_dict(cols, line):
|
|
""""""
|
|
res = {}
|
|
for i, data in enumerate(line):
|
|
res[cols[i]] = data.decode('utf-8')
|
|
return res
|
|
|
|
tables_data = {}
|
|
|
|
map_rm_cmpp = [1, 3, 2, 8, 6, 4]
|
|
|
|
def get_rm(service, val):
|
|
old_id_rm = _to_int(val)
|
|
if old_id_rm < 1 or 'SESSAD' in service.name:
|
|
return None
|
|
if service.name == 'CMPP':
|
|
old_id_rm = map_rm_cmpp[old_id_rm - 1]
|
|
try:
|
|
return MaritalStatusType.objects.get(id=old_id_rm)
|
|
except:
|
|
return None
|
|
|
|
map_job_camsp = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 25, 21, 23, 20, 17, 15, 18, 16, 26, 27, 28]
|
|
|
|
# CMPP à 25 = Rien
|
|
def get_job(service, val):
|
|
old_id_job = _to_int(val)
|
|
if old_id_job < 1:
|
|
return None
|
|
if service.name == 'CAMSP' and old_id_job == 26:
|
|
return None
|
|
if service.name == 'CAMSP':
|
|
try:
|
|
old_id_job = map_job_camsp[old_id_job - 1]
|
|
except:
|
|
print 'Old id job out of range: %d' % old_id_job
|
|
try:
|
|
return Job.objects.get(id=old_id_job)
|
|
except:
|
|
return None
|
|
|
|
def extract_phone(val):
|
|
if not val or val == '' or val == '0':
|
|
return None
|
|
s = ''.join([c for c in val if c.isdigit()])
|
|
return s[:11]
|
|
|
|
def get_nir(nir, key, writer, line, service):
|
|
if not nir:
|
|
return None
|
|
if len(nir) != 13:
|
|
return -1
|
|
if key:
|
|
minus = 0
|
|
# Corsica dept 2A et 2B
|
|
if nir[6] in ('A', 'a'):
|
|
nir = [c for c in nir]
|
|
nir[6] = '0'
|
|
nir = ''.join(nir)
|
|
minus = 1000000
|
|
elif nir[6] in ('B', 'b'):
|
|
nir = [c for c in nir]
|
|
nir[6] = '0'
|
|
nir = ''.join(nir)
|
|
minus = 2000000
|
|
try:
|
|
nir = int(nir) - minus
|
|
good_key = 97 - (nir % 97)
|
|
key = int(key)
|
|
if key != good_key:
|
|
msg = 'Clé incorrect %s pour %s' % (str(key), str(nir))
|
|
writer.writerow(line + [service.name, msg])
|
|
except:
|
|
pass
|
|
return nir
|
|
|
|
|
|
def import_dossiers_phase_1():
|
|
""" """
|
|
print "====== Début à %s ======" % str(datetime.today())
|
|
|
|
f1 = open('./scripts/dossiers_ecoles_manuel.csv', 'wb')
|
|
writer1 = csv.writer(f1, delimiter=';', quotechar='|', quoting=csv.QUOTE_MINIMAL)
|
|
|
|
f2 = open('./scripts/dossiers_manuel.csv', 'wb')
|
|
writer2 = csv.writer(f2, delimiter=';', quotechar='|', quoting=csv.QUOTE_MINIMAL)
|
|
|
|
f3 = open('./scripts/contacts_manuel.csv', 'wb')
|
|
writer3 = csv.writer(f3, delimiter=';', quotechar='|', quoting=csv.QUOTE_MINIMAL)
|
|
|
|
f4 = open('./scripts/pc_manuel.csv', 'wb')
|
|
writer4 = csv.writer(f4, delimiter=';', quotechar='|', quoting=csv.QUOTE_MINIMAL)
|
|
|
|
status_accueil = Status.objects.filter(type="ACCUEIL")[0]
|
|
status_diagnostic = Status.objects.filter(type="DIAGNOSTIC")[0]
|
|
status_traitement = Status.objects.filter(type="TRAITEMENT")[0]
|
|
status_clos = Status.objects.filter(type="CLOS")[0]
|
|
status_bilan = Status.objects.filter(type="BILAN")[0]
|
|
status_suivi = Status.objects.filter(type="SUIVI")[0]
|
|
status_surveillance = Status.objects.filter(type="SURVEILLANCE")[0]
|
|
creator = User.objects.get(id=1)
|
|
|
|
for db in dbs:
|
|
if "F_ST_ETIENNE_CMPP" == db:
|
|
service = Service.objects.get(name="CMPP")
|
|
elif "F_ST_ETIENNE_CAMSP" == db:
|
|
service = Service.objects.get(name="CAMSP")
|
|
elif "F_ST_ETIENNE_SESSAD_TED" == db:
|
|
service = Service.objects.get(name="SESSAD TED")
|
|
elif "F_ST_ETIENNE_SESSAD" == db:
|
|
service = Service.objects.get(name="SESSAD DYS")
|
|
|
|
print "====== %s ======" % service.name
|
|
print datetime.today()
|
|
|
|
print "--> Lecture table des dossiers..."
|
|
csvfile = open(os.path.join(db_path, db, 'dossiers.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
d_cols = csvlines.next()
|
|
writer2.writerow(d_cols + ['service', 'creation', 'commentaire'])
|
|
tables_data['dossiers'] = []
|
|
for line in csvlines:
|
|
#Au moins nom et prénom
|
|
if _exist(line[1]) and _exist(line[2]):
|
|
data = _get_dict(d_cols, line)
|
|
tables_data['dossiers'].append(data)
|
|
else:
|
|
writer2.writerow(line + [service.name, 'Non', 'Ni Nom, ni prénom'])
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Lecture table des caisses..."
|
|
csvfile = open(os.path.join(db_path, db, 'caisses.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
caisses_cols = csvlines.next()
|
|
tables_data['caisses'] = {}
|
|
for line in csvlines:
|
|
data = _get_dict(caisses_cols, line)
|
|
tables_data['caisses'][data['id']] = data
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Chargement mises..."
|
|
mises = {}
|
|
csvfile = open(os.path.join(db_path, db, 'mises.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
cols = csvlines.next()
|
|
for line in csvlines:
|
|
mises[line[0]] = (line[1], line[2])
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Chargement quotations..."
|
|
mises_per_patient = {}
|
|
csvfile = open(os.path.join(db_path, db, 'dossiers_mises.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
cols = csvlines.next()
|
|
for line in csvlines:
|
|
code, axe = mises[line[2]]
|
|
quotation = CodeCFTMEA.objects.get(code=int(code), axe=int(axe))
|
|
if line[1] in mises_per_patient.keys():
|
|
mises_per_patient[line[1]].append(quotation)
|
|
else:
|
|
mises_per_patient[line[1]] = [quotation]
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Ajout périodes de socialisation..."
|
|
social_duration_per_patient = {}
|
|
csvfile = open(os.path.join(db_path, db, 'dossiers_ecoles.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
cols = csvlines.next()
|
|
writer1.writerow(cols + ['service'])
|
|
i = 0
|
|
for line in csvlines:
|
|
i += 1
|
|
print "Nombre à traiter : %d" % i
|
|
csvfile.close()
|
|
csvfile = open(os.path.join(db_path, db, 'dossiers_ecoles.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
csvlines.next()
|
|
for line in csvlines:
|
|
school = None
|
|
if _exist(line[2]):
|
|
school = School.objects.get(old_id=line[2], old_service=service.name)
|
|
level = None
|
|
try:
|
|
level = SchoolLevel.objects.get(old_id=line[4], old_service=service.name)
|
|
except:
|
|
pass
|
|
contact = line[3]
|
|
if contact != "":
|
|
contact += ' ' + line[7]
|
|
else:
|
|
contact = line[7]
|
|
start_date = _to_date(line[5])
|
|
social_duration = SocialisationDuration(school=school, level=level, start_date=start_date, contact=contact)
|
|
social_duration.save()
|
|
if line[1] in social_duration_per_patient.keys():
|
|
social_duration_per_patient[line[1]].append(social_duration)
|
|
else:
|
|
social_duration_per_patient[line[1]] = [social_duration]
|
|
#Produce file for manuel treatment:
|
|
for j in range(6, 16):
|
|
if j != 7 and _exist(line[j]):
|
|
writer1.writerow(line + [service.name])
|
|
i -= 1
|
|
if not (i % 10):
|
|
sys.stdout.write('%d' %i)
|
|
else:
|
|
sys.stdout.write('.')
|
|
sys.stdout.flush()
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Ajout des adresses..."
|
|
adresses_per_patient = {}
|
|
adresses_per_old_id = {}
|
|
csvfile = open(os.path.join(db_path, db, 'adresses.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
cols = csvlines.next()
|
|
i = 0
|
|
for line in csvlines:
|
|
i += 1
|
|
print "Nombre à traiter : %d" % i
|
|
csvfile.close()
|
|
csvfile = open(os.path.join(db_path, db, 'adresses.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
csvlines.next()
|
|
for line in csvlines:
|
|
phone = extract_phone(line[5])
|
|
comment = ''
|
|
if _exist(line[10]):
|
|
comment += line[10] + ' - '
|
|
if _exist(line[5]):
|
|
comment += "Numéro 1 : " + line[5] + ' - '
|
|
if _exist(line[8]):
|
|
comment += "Numéro 2 : " + line[8] + ' - '
|
|
fax = None
|
|
place_of_life = False
|
|
if _exist(line[9]) and line[9] == '-1':
|
|
place_of_life = True
|
|
number = None
|
|
street = line[11]
|
|
address_complement = line[12]
|
|
zip_code = None
|
|
if _exist(line[3]):
|
|
if len(line[3]) > 5:
|
|
zip_code = line[3][-5:]
|
|
else:
|
|
zip_code = line[3]
|
|
city = line[4]
|
|
|
|
address = PatientAddress(phone=phone, comment=comment,
|
|
fax=fax, place_of_life=place_of_life, number=number,
|
|
street=street, address_complement=address_complement,
|
|
zip_code=zip_code, city=city)
|
|
|
|
address.save()
|
|
if line[1] in adresses_per_patient.keys():
|
|
adresses_per_patient[line[1]].append(address)
|
|
else:
|
|
adresses_per_patient[line[1]] = [address]
|
|
adresses_per_old_id[line[0]] = (address, line[1])
|
|
i -= 1
|
|
if not (i % 10):
|
|
sys.stdout.write('%d' %i)
|
|
else:
|
|
sys.stdout.write('.')
|
|
sys.stdout.flush()
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Chargement des prise en charge..."
|
|
csvfile = open(os.path.join(db_path, db, 'pc.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
pc_cols = csvlines.next()
|
|
writer4.writerow(pc_cols + ['service', 'creation', 'commentaire'])
|
|
tables_data['pcs'] = {}
|
|
for line in csvlines:
|
|
data = _get_dict(pc_cols, line)
|
|
if line[1] in tables_data['pcs'].keys():
|
|
tables_data['pcs'][line[1]].append(data)
|
|
else:
|
|
tables_data['pcs'][line[1]] = [data]
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Ajout des contacts..."
|
|
contacts_per_patient = {}
|
|
csvfile = open(os.path.join(db_path, db, 'contacts.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
cols = csvlines.next()
|
|
writer3.writerow(cols + ['service', 'commentaire'])
|
|
i = 0
|
|
for line in csvlines:
|
|
i += 1
|
|
print "Nombre à traiter : %d" % i
|
|
csvfile.close()
|
|
csvfile = open(os.path.join(db_path, db, 'contacts.csv'), 'rb')
|
|
csvlines = csv.reader(csvfile, delimiter=';', quotechar='|')
|
|
csvlines.next()
|
|
for line in csvlines:
|
|
phone = extract_phone(line[13])
|
|
mobile = extract_phone(line[14])
|
|
contact_comment = ''
|
|
if _exist(line[13]):
|
|
contact_comment += "Travail : " + line[13] + ' - '
|
|
if _exist(line[14]):
|
|
contact_comment += "Mobile : " + line[14] + ' - '
|
|
if _exist(line[17]):
|
|
contact_comment += "Divers : " + line[17] + ' - '
|
|
last_name = treat_name(line[3])
|
|
first_name = treat_name(line[4])
|
|
gender = None
|
|
if line[2] == "1":
|
|
gender = 1
|
|
if line[2] == "2":
|
|
gender = 2
|
|
email = None
|
|
if _exist(line[15]):
|
|
email = line[15]
|
|
birthplace = None
|
|
if _exist(line[6]):
|
|
birthplace = line[6]
|
|
social_security_id = get_nir(line[7], line[8], writer3, line, service)
|
|
if social_security_id == -1:
|
|
msg = 'Numéro %s de longueur diff de 13.' % line[7]
|
|
writer3.writerow(line + [service.name, msg])
|
|
contact_comment += "Numéro NIR invalide : " + line[7] + ' - '
|
|
social_security_id = None
|
|
birthdate = _to_date(line[5])
|
|
job = get_job(service, line[9])
|
|
parente = None
|
|
try:
|
|
if service.name == 'CAMSP':
|
|
parente = PatientRelatedLink.objects.get(old_camsp_id=_to_int(line[11]))
|
|
elif service.name == 'CMPP':
|
|
parente = PatientRelatedLink.objects.get(old_cmpp_id=_to_int(line[11]))
|
|
elif service.name == 'SESSAD DYS':
|
|
parente = PatientRelatedLink.objects.get(old_sessad_dys_id=_to_int(line[11]))
|
|
elif service.name == 'SESSAD TED':
|
|
parente = PatientRelatedLink.objects.get(old_sessad_ted_id=_to_int(line[11]))
|
|
except:
|
|
pass
|
|
twinning_rank = None
|
|
thirdparty_payer = False
|
|
begin_rights = None
|
|
end_rights = None
|
|
health_center = None
|
|
old_contact_id = line[0]
|
|
|
|
contact = PatientContact(phone=phone, mobile= mobile,
|
|
contact_comment=contact_comment,
|
|
last_name = last_name, first_name = first_name,
|
|
gender = gender, email = email, parente = parente,
|
|
social_security_id = social_security_id,
|
|
birthdate = birthdate, job = job, birthplace=birthplace,
|
|
twinning_rank = twinning_rank,
|
|
thirdparty_payer = thirdparty_payer,
|
|
begin_rights = begin_rights,
|
|
end_rights = end_rights,
|
|
health_center = health_center,
|
|
old_contact_id=old_contact_id)
|
|
contact.save()
|
|
|
|
if not line[1] in adresses_per_old_id:
|
|
msg = 'Contact sans adresse'
|
|
writer3.writerow(line + [service.name, msg])
|
|
contact.delete()
|
|
else:
|
|
adresse, old_patient_id = adresses_per_old_id[line[1]]
|
|
contact.addresses.add(adresse)
|
|
# Ajouter l'adresse au contact
|
|
# Faire une liste des contacts par patient pour ajouter ensuite
|
|
if old_patient_id in contacts_per_patient.keys():
|
|
contacts_per_patient[old_patient_id].append(contact)
|
|
else:
|
|
contacts_per_patient[old_patient_id] = [contact]
|
|
i -= 1
|
|
if not (i % 10):
|
|
sys.stdout.write('%d' %i)
|
|
else:
|
|
sys.stdout.write('.')
|
|
sys.stdout.flush()
|
|
csvfile.close()
|
|
print "<-- Terminé"
|
|
|
|
print "--> Ajout dossiers..."
|
|
print "Nombre à traiter : %d" % len(tables_data['dossiers'])
|
|
i = len(tables_data['dossiers'])
|
|
for dossier in tables_data['dossiers']:
|
|
|
|
date_accueil = None
|
|
date_diagnostic = None
|
|
date_traitement = None
|
|
date_clos = None
|
|
date_bilan = None
|
|
date_suivi = None
|
|
date_surveillance = None
|
|
date_retour = None
|
|
fss = []
|
|
date_accueil = _to_date(dossier['con_date'])
|
|
date_traitement = _to_date(dossier['ins_date'])
|
|
date_clos = _to_date(dossier['sor_date'])
|
|
if not (date_accueil or date_traitement or date_clos):
|
|
# no state date, the record is inconsistent
|
|
writer2.writerow([dossier[c].encode('utf-8') for c in d_cols] + [service.name, 'Non', "Aucune date d'état existante"])
|
|
continue
|
|
# Manage states
|
|
if date_accueil and date_traitement and date_accueil >= date_traitement:
|
|
date_accueil = None
|
|
if date_traitement and date_clos and date_traitement >= date_clos:
|
|
date_traitement = None
|
|
if date_accueil and date_clos and date_accueil >= date_clos:
|
|
date_accueil = None
|
|
if "SESSAD" in service.name:
|
|
# Il n'y a jamais eu de retour au SESSADs
|
|
if date_accueil:
|
|
fss.append((status_accueil, date_accueil, None))
|
|
if date_traitement:
|
|
fss.append((status_traitement, date_traitement, None))
|
|
if date_clos:
|
|
fss.append((status_clos, date_clos, None))
|
|
# Jamais de motif et provenance au retour
|
|
elif service.name == 'CAMSP':
|
|
date_retour = _to_date(dossier['ret_date'])
|
|
if date_accueil:
|
|
fss.append((status_accueil, date_accueil, None))
|
|
if not date_retour:
|
|
if date_traitement:
|
|
s = status_bilan
|
|
if dossier['suivi'] == '3':
|
|
s = status_suivi
|
|
elif dossier['suivi'] == '4':
|
|
s = status_surveillance
|
|
# fss.append((s, date_traitement, "Il peut y avoir plusieurs états de suivi durant cette période de suivi mais ils ne peuvent être déterminés."))
|
|
fss.append((s, date_traitement, ""))
|
|
else:
|
|
# Le retour supprime la précédente de clôture, on choisit le retour à j-1
|
|
if date_traitement:
|
|
# c'est l'inscription
|
|
if date_traitement < date_retour:
|
|
fss.append((status_suivi, date_traitement, "Etat de traitement indéterminé (Suivi par défaut)."))
|
|
old_clos_date = date_retour + relativedelta(days=-1)
|
|
fss.append((status_clos, old_clos_date, "La date de clôture est indéterminée (par défaut positionnée à 1 jour avant le retour)."))
|
|
s = status_bilan
|
|
if dossier['suivi'] == '3':
|
|
s = status_suivi
|
|
elif dossier['suivi'] == '4':
|
|
s = status_surveillance
|
|
# fss.append((s, date_retour, "Il peut y avoir plusieurs états de suivi durant cette période de suivi mais ils ne peuvent être déterminés."))
|
|
fss.append((s, date_retour, ""))
|
|
if date_clos:
|
|
if date_retour and date_clos < date_retour:
|
|
print 'La date de clôture ne peut être antérieure à la date de retour!'
|
|
else:
|
|
fss.append((status_clos, date_clos, None))
|
|
else:
|
|
date_retour = _to_date(dossier['ret_date'])
|
|
if date_accueil:
|
|
fss.append((status_accueil, date_accueil, None))
|
|
if date_traitement:
|
|
fss.append((status_diagnostic, date_traitement, "Inscription en diag mais pourrait etre en trait. A préciser"))
|
|
if (date_retour and date_clos and date_retour > date_clos) or not date_clos:
|
|
if old_id in tables_data['pcs'].keys():
|
|
pcs = tables_data['pcs'][old_id]
|
|
last_pc = pcs[len(pcs)-1]
|
|
if last_pc['genre_pc'] == '2':
|
|
status, date, msg = fss[len(fss)-1]
|
|
last_date = date + relativedelta(days=1)
|
|
fss.append((status_traitement, last_date, "Date à préciser."))
|
|
else:
|
|
fss.append((status_clos, date_clos, None))
|
|
|
|
# Il faut l'historique des actes du patient
|
|
# Il faut pour chaque acte assigner à la pc
|
|
# on sait les derniers actes s'ils sont affecté ou non
|
|
# Il faudrait conserver avec les actes les num de facture ?
|
|
# rEvori el fonctionnement de l'assignation d'un acte a une pc
|
|
|
|
for col in ('mdph', 'code_archive', 'aeeh', 'mdph_departement', 'pps', 'pps_deb', 'pps_fin', 'mdph_Debut', 'mdph_Fin'):
|
|
if _exist(dossier[col]):
|
|
writer2.writerow([dossier[c].encode('utf-8') for c in d_cols] + [service.name, 'Oui', "Données présentes non traitées"])
|
|
break
|
|
|
|
#People
|
|
first_name = treat_name(dossier['prenom'])
|
|
last_name = treat_name(dossier['nom'])
|
|
display_name = None
|
|
gender = _to_int(dossier['nais_sexe'])
|
|
if not gender in (1,2):
|
|
gender = None
|
|
email = None
|
|
phone = None
|
|
|
|
#PatientContact
|
|
mobile = None
|
|
social_security_id = None
|
|
birthdate = _to_date(dossier['nais_date'])
|
|
twinning_rank = _to_int(dossier['nais_rang'])
|
|
# Pourra etre init à l'import des contacts après création du dossier
|
|
thirdparty_payer = False
|
|
begin_rights = None
|
|
end_rights = None
|
|
health_center = None
|
|
addresses = None
|
|
contact_comment = None
|
|
|
|
#PatientRecord
|
|
creator = creator
|
|
# Pourra etre init à l'import des contacts après création du dossier
|
|
nationality = None
|
|
paper_id = None
|
|
comment = dossier['infos']
|
|
pause = False
|
|
if _exist(dossier['blocage']):
|
|
pause = True
|
|
confidential = False
|
|
if _exist(dossier['non_communication_ecole']):
|
|
confidential = True
|
|
|
|
# Physiology and health data
|
|
size = _to_int(dossier['taille'])
|
|
weight = _to_int(dossier['poids'])
|
|
pregnancy_term = _to_int(dossier['terme'])
|
|
cranium_perimeter = None
|
|
chest_perimeter = None
|
|
apgar_score_one = _to_int(dossier['apgar_1'])
|
|
apgar_score_two = _to_int(dossier['apgar_5'])
|
|
|
|
|
|
# Inscription motive
|
|
# Up to now only used at the CAMSP
|
|
analysemotive = None
|
|
try:
|
|
analysemotive = AnalyseMotive.objects.get(id=_to_int(dossier['ins_motif']))
|
|
except:
|
|
pass
|
|
# Up to now only used at the CAMSP
|
|
familymotive = None
|
|
try:
|
|
familymotive = FamilyMotive.objects.get(id=_to_int(dossier['ins_motif_exprim']))
|
|
except:
|
|
pass
|
|
provenance = None
|
|
try:
|
|
provenance = Provenance.objects.get(old_id=_to_int(dossier['ins_provenance']), old_service=service.name)
|
|
except:
|
|
pass
|
|
# Up to now only used at the CAMSP
|
|
advicegiver = None
|
|
try:
|
|
advicegiver = AdviceGiver.objects.get(id=_to_int(dossier['con_qui']))
|
|
except:
|
|
pass
|
|
|
|
# Inscription motive
|
|
# Up to now only used at the CAMSP
|
|
outmotive = None
|
|
try:
|
|
outmotive = OutMotive.objects.get(id=_to_int(dossier['sor_motif']))
|
|
except:
|
|
pass
|
|
# Up to now only used at the CAMSP
|
|
outto = None
|
|
try:
|
|
outto = OutTo.objects.get(id=_to_int(dossier['sor_orientation']))
|
|
except:
|
|
pass
|
|
|
|
# Family
|
|
sibship_place = _to_int(dossier['nais_fratrie'])
|
|
nb_children_family = _to_int(dossier['nbr_enfants'])
|
|
parental_authority = None
|
|
try:
|
|
parental_authority = ParentalAuthorityType.objects.get(id=_to_int(dossier['autorite_parentale']))
|
|
except:
|
|
pass
|
|
# Up to now only used at the CAMSP
|
|
family_situation = None
|
|
try:
|
|
family_situation = FamilySituationType.objects.get(id=_to_int(dossier['situation_familiale']))
|
|
except:
|
|
pass
|
|
# Up to now only used at the CAMSP
|
|
child_custody = None
|
|
try:
|
|
child_custody = ParentalCustodyType.objects.get(id=_to_int(dossier['garde']))
|
|
except:
|
|
pass
|
|
|
|
rm_mother = get_rm(service, dossier['rm_mere'])
|
|
rm_father = get_rm(service, dossier['rm_pere'])
|
|
job_mother = get_job(service, dossier['prof_mere'])
|
|
job_father = get_job(service, dossier['prof_pere'])
|
|
family_comment = None
|
|
|
|
# Transport
|
|
transportcompany = None
|
|
try:
|
|
if service.name == 'CAMSP':
|
|
transportcompany = TransportCompany.objects.get(old_camsp_id=_to_int(dossier['transport']))
|
|
elif service.name == 'CMPP':
|
|
transportcompany = TransportCompany.objects.get(old_cmpp_id=_to_int(dossier['transport']))
|
|
elif service.name == 'SESSAD DYS':
|
|
transportcompany = TransportCompany.objects.get(old_sessad_dys_id=_to_int(dossier['transport']))
|
|
elif service.name == 'SESSAD TED':
|
|
transportcompany = TransportCompany.objects.get(old_sessad_ted_id=_to_int(dossier['transport']))
|
|
except:
|
|
pass
|
|
transporttype = None
|
|
try:
|
|
transporttype = TransportType.objects.get(id=_to_int(dossier['type_transport']))
|
|
except:
|
|
pass
|
|
|
|
# FollowUp
|
|
externaldoctor = None
|
|
try:
|
|
externaldoctor = ExternalTherapist.objects.get(old_id=_to_int(dossier['medecin_exterieur']), old_service=service.name)
|
|
except:
|
|
pass
|
|
externalintervener = None
|
|
try:
|
|
externalintervener = ExternalWorker.objects.get(old_id=_to_int(dossier['intervenant_exterieur']), old_service=service.name)
|
|
except:
|
|
pass
|
|
|
|
old_id = dossier['id']
|
|
old_old_id = dossier['ancien_numero']
|
|
|
|
|
|
patient, created = PatientRecord.objects.get_or_create(first_name = first_name,
|
|
last_name = last_name,
|
|
birthdate = birthdate,
|
|
twinning_rank = twinning_rank,
|
|
gender = gender,
|
|
display_name = display_name,
|
|
email = email,
|
|
phone = phone,
|
|
mobile = mobile,
|
|
contact_comment = contact_comment,
|
|
nationality = nationality,
|
|
paper_id = paper_id,
|
|
comment = comment,
|
|
pause = pause,
|
|
confidential = confidential,
|
|
size = size,
|
|
weight = weight,
|
|
pregnancy_term = pregnancy_term,
|
|
cranium_perimeter = cranium_perimeter,
|
|
chest_perimeter = chest_perimeter,
|
|
apgar_score_one = apgar_score_one,
|
|
apgar_score_two = apgar_score_two,
|
|
analysemotive = analysemotive,
|
|
familymotive = familymotive,
|
|
provenance = provenance,
|
|
advicegiver = advicegiver,
|
|
outmotive = outmotive,
|
|
outto = outto,
|
|
sibship_place = sibship_place,
|
|
nb_children_family = nb_children_family,
|
|
parental_authority = parental_authority,
|
|
family_situation = family_situation,
|
|
rm_mother = rm_mother,
|
|
rm_father = rm_father,
|
|
job_mother = job_mother,
|
|
job_father = job_father,
|
|
family_comment = family_comment,
|
|
child_custody = child_custody,
|
|
transportcompany = transportcompany,
|
|
transporttype = transporttype,
|
|
externaldoctor = externaldoctor,
|
|
externalintervener = externalintervener,
|
|
service=service,
|
|
creator=creator,
|
|
old_id = old_id,
|
|
old_old_id = old_old_id)
|
|
|
|
# if created:
|
|
# print 'Creation de%s' % patient
|
|
# else:
|
|
# print 'Patient %s existe' % patient
|
|
|
|
# Init states
|
|
if not fss:
|
|
print "Pas d'etat et le dossier patient %s (old_id) a ete cree!" % old_id
|
|
else:
|
|
fs = FileState(status=fss[0][0], author=creator, previous_state=None)
|
|
date_selected = fss[0][1]
|
|
fs.patient = patient
|
|
fs.date_selected = date_selected
|
|
fs.comment = fss[0][2]
|
|
fs.save()
|
|
patient.last_state = fs
|
|
patient.save()
|
|
if len(fss) > 1:
|
|
for status, date, comment in fss[1:]:
|
|
patient.set_state(status=status, author=creator, date_selected=date, comment=comment)
|
|
|
|
|
|
if old_id in mises_per_patient.keys():
|
|
for quotation in mises_per_patient[old_id]:
|
|
if quotation.axe == 1:
|
|
patient.mises_1.add(quotation)
|
|
elif quotation.axe == 2:
|
|
patient.mises_2.add(quotation)
|
|
elif quotation.axe == 3:
|
|
patient.mises_3.add(quotation)
|
|
else:
|
|
raise
|
|
|
|
if old_id in social_duration_per_patient.keys():
|
|
for social_duration in social_duration_per_patient[old_id]:
|
|
patient.socialisation_durations.add(social_duration)
|
|
|
|
for t_the in ('the_medecin', 'the_referent', 'the_therapeute'):
|
|
try:
|
|
therapist = None
|
|
if service.name == 'CAMSP':
|
|
therapist = Worker.objects.get(old_camsp_id=_to_int(dossier[t_the]))
|
|
elif service.name == 'CMPP':
|
|
therapist = Worker.objects.get(old_cmpp_id=_to_int(dossier[t_the]))
|
|
elif service.name == 'SESSAD DYS':
|
|
therapist = Worker.objects.get(old_sessad_dys_id=_to_int(dossier[t_the]))
|
|
elif service.name == 'SESSAD TED':
|
|
therapist = Worker.objects.get(old_sessad_ted_id=_to_int(dossier[t_the]))
|
|
patient.coordinators.add(therapist)
|
|
except:
|
|
pass
|
|
|
|
# Initialisation adresses et contacts
|
|
if old_id in adresses_per_patient.keys():
|
|
for adresse in adresses_per_patient[old_id]:
|
|
patient.addresses.add(adresse)
|
|
if old_id in contacts_per_patient.keys():
|
|
for contact in contacts_per_patient[old_id]:
|
|
if contact.last_name == patient.last_name \
|
|
and contact.first_name == patient.first_name:
|
|
# print "Le contact %s %s est le patient" % (contact.last_name, contact.first_name)
|
|
if not patient.birthdate:
|
|
patient.birthdate = contact.birthdate
|
|
patient.birthplace = contact.birthplace
|
|
patient.email = contact.email
|
|
patient.phone = contact.phone
|
|
patient.mobile = contact.mobile
|
|
patient.social_security_id = contact.social_security_id
|
|
patient.thirdparty_payer = contact.thirdparty_payer
|
|
patient.begin_rights = contact.begin_rights
|
|
patient.end_rights = contact.end_rights
|
|
patient.health_center = contact.health_center
|
|
patient.contact_comment = contact.contact_comment
|
|
patient.old_contact_id = contact.old_contact_id
|
|
patient.save()
|
|
contact.delete()
|
|
else:
|
|
patient.contacts.add(contact)
|
|
|
|
policyholder = None
|
|
health_center = None
|
|
other_health_center = None
|
|
if old_id in tables_data['pcs'].keys():
|
|
pcs = tables_data['pcs'][old_id]
|
|
j = len(pcs)-1
|
|
found = False
|
|
last_pc = None
|
|
while not found and j >= 0:
|
|
last_pc = pcs[j]
|
|
if 'contact_id' in last_pc.keys():
|
|
found = True
|
|
j -= 1
|
|
if not found:
|
|
writer2.writerow([dossier[c].encode('utf-8') for c in d_cols] + [service.name, 'Oui', "Pas de pc, le patient est l'assure sans caisse"])
|
|
# print "Pas de d'assure pour le patient %s" % old_id
|
|
# print "Le patient sera l'assure"
|
|
else:
|
|
try:
|
|
caisse = None
|
|
centre = None
|
|
lg = None
|
|
policyholder = patient.contacts.get(old_contact_id=_to_int(last_pc['contact_id']))
|
|
if last_pc['caisse_id'] in tables_data['caisses'].keys():
|
|
lg = tables_data['caisses'][last_pc['caisse_id']]['tp']
|
|
if len(lg) < 2:
|
|
lg = ['0', lg]
|
|
lg = ''.join(lg)
|
|
caisse = tables_data['caisses'][last_pc['caisse_id']]['caisse']
|
|
while len(caisse) < 3:
|
|
caisse = ['0', caisse]
|
|
caisse = ''.join(caisse)
|
|
centre = tables_data['caisses'][last_pc['caisse_id']]['centre']
|
|
while len(centre) < 4:
|
|
centre = ['0', centre]
|
|
centre = ''.join(centre)
|
|
if lg and caisse:
|
|
health_centers = HealthCenter.objects.filter(large_regime__code=lg, health_fund=caisse)
|
|
if health_centers and len(health_centers.all()) == 1:
|
|
health_center = health_centers[0]
|
|
if last_pc['centre']:
|
|
while len(last_pc['centre']) < 4:
|
|
last_pc['centre'] = ['0', last_pc['centre']]
|
|
last_pc['centre'] = ''.join(last_pc['centre'])
|
|
other_health_center = last_pc['centre']
|
|
elif health_centers and len(health_centers.all()) > 1:
|
|
health_centers = None
|
|
if last_pc['centre']:
|
|
while len(last_pc['centre']) < 4:
|
|
last_pc['centre'] = ['0', last_pc['centre']]
|
|
last_pc['centre'] = ''.join(last_pc['centre'])
|
|
# print "centre 1 %s" % last_pc['centre']
|
|
health_centers = HealthCenter.objects.filter(large_regime__code=lg, health_fund=caisse,
|
|
code = last_pc['centre'])
|
|
elif centre:
|
|
# print "centre 2 %s" % centre
|
|
health_centers = HealthCenter.objects.filter(large_regime__code=lg, health_fund=caisse,
|
|
code = centre)
|
|
if health_centers and len(health_centers.all()) == 1:
|
|
health_center = health_centers[0]
|
|
elif health_centers:
|
|
# print "Plusieurs caisses avec le meme centre, patient %s" % old_id
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', "Plusieurs caisses avec le meme centre, patient %s" % old_id])
|
|
else:
|
|
# print "Caisse non determinee par code centre, patient %s" % old_id
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', "Caisse non determinee par code centre, patient %s" % old_id])
|
|
else:
|
|
# print 'Caisse non trouvee avec ce numero de caisse et grand regime, patient %s' % old_id
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', 'Caisse non trouvee avec ce numero de caisse et grand regime, patient %s' % old_id])
|
|
else:
|
|
# print 'Infos manquantes dans fichiers des caisses, patient %s' % old_id
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', 'Infos manquantes dans fichiers des caisses, patient %s' % old_id])
|
|
else:
|
|
# print 'Pas de caisse dans le fichiers caisse avec l id %s, patient %s' % (last_pc['caisse_id'], old_id)
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', 'Pas de caisse dans le fichier caisse avec l id %s, patient %s' % (last_pc['caisse_id'], old_id)])
|
|
except:
|
|
# print "Pas de contact avec id %s, patient %s" % (last_pc['contact_id'], old_id)
|
|
writer4.writerow([last_pc[c].encode('utf-8') for c in pc_cols] + \
|
|
[service.name, '', "Pas d'assuré existant, le patient est choisi."])
|
|
|
|
else:
|
|
writer2.writerow([dossier[c].encode('utf-8') for c in d_cols] + \
|
|
[service.name, 'Oui', "Pas de pc, le patient est l'assure sans caisse"])
|
|
# print "Pas de pc pour le patient %s" % old_id
|
|
# print "Le patient sera l'assure"
|
|
if not policyholder:
|
|
policyholder = patient.patientcontact
|
|
policyholder.health_center = health_center
|
|
policyholder.other_health_center = other_health_center
|
|
policyholder.save()
|
|
patient.policyholder = policyholder
|
|
patient.save()
|
|
|
|
|
|
# On ne pass plus par le clean du contact form, du coup, pas moyen de modifier le health center!
|
|
|
|
# Faut-il gére un code de gestion ?
|
|
|
|
|
|
#Etat des dossiers
|
|
|
|
# patient.policyholder soit le contact, d'il n'y en a qu'un
|
|
# au cmmp, cf la pc
|
|
|
|
# Dossier en pause facturation! champs pause sur le dossier OK
|
|
# si aucun contact, ou aucun contact avec un Nir valide!
|
|
|
|
#Tiers-payant ? healthcenter ?
|
|
|
|
# Notifications au sessad, il n'y en a pas!
|
|
|
|
# i += 1
|
|
# print 'Fin de traitement pour le dossier %s' % patient
|
|
# if i >= 10:
|
|
# break
|
|
i -= 1
|
|
if not (i % 10):
|
|
sys.stdout.write('%d' %i)
|
|
else:
|
|
sys.stdout.write('.')
|
|
sys.stdout.flush()
|
|
|
|
print "<-- Terminé"
|
|
print "====== Fin à %s ======" % str(datetime.today())
|
|
|
|
#Travail manuel pour secreatires
|
|
# mdph_requests = models.ManyToManyField('ressources.MDPHRequest',
|
|
# mdph_responses = models.ManyToManyField('ressources.MDPHResponse',
|
|
|
|
|
|
# policyholder = None
|
|
# contacts = None
|
|
|
|
|
|
if __name__ == "__main__":
|
|
import_dossiers_phase_1()
|