1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
# ############################################################################
# # #
# # Description: Ensemble de méthodes pour étendre dbmain afin #
# # d'effectuer des recherches dans la bdd #
# # #
# ############################################################################
# Infos pour les "join":
# https:#www.freecodecamp.org/news/sql-joins-tutorial/
# Import de dbmain
from src.database import dbmain
from datetime import datetime
# Extension de cette classe avec dbmain
class DbMission(dbmain.DbMain):
# ****************************************************************************
# ENREGISTREMENT ET VALIDATION DES MISSIONS
# ****************************************************************************
# Enregistrement d'une mission
def register_mission(self, subject, clientId, proId, jobId):
# Préparation de la requète pour enregistrement de la mission
reqAddMission = """
INSERT INTO """ + self.TABLEMISSION + """
(date, subject, clientId, proId, jobCategoryId)
VALUES
(?, ?, ?, ?, ?)"""
# Exécution de la requète
self.exec_cmd(reqAddMission,
[datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
subject,
clientId,
proId,
jobId
]
)
return 1
# Enregistrement d'une mission
def accept_mission_by_missionid(self, missionId):
# Préparation de la requète pour enregistrement de la mission
reqAddMission = """
UPDATE
""" + self.TABLEMISSION + """
SET
acceptedByPro = ?
WHERE
missionId = ?"""
# Exécution de la requète
self.exec_cmd(reqAddMission, [datetime.now().strftime("%Y-%m-%d %H:%M:%S"), missionId])
return 1
def validate_mission_pro_by_missionid(self, missionId):
# Préparation de la requète pour enregistrement de la mission
reqAddMission = """
UPDATE
""" + self.TABLEMISSION + """
SET
validatedByPro = ?
WHERE
missionId = ?"""
# Exécution de la requète
self.exec_cmd(reqAddMission, [datetime.now().strftime("%Y-%m-%d %H:%M:%S"), missionId])
return 1
def validate_mission_client_by_missionid(self, missionId):
# Préparation de la requète pour enregistrement de la mission
reqAddMission = """
UPDATE
""" + self.TABLEMISSION + """
SET
validatedByClient = ?
WHERE
missionId = ?"""
# Exécution de la requète
self.exec_cmd(reqAddMission, [datetime.now().strftime("%Y-%m-%d %H:%M:%S"), missionId])
return 1
def review_mission(self, missionId, review, note):
# Préparation de la requète pour enregistrement de la mission
reqAddMission = """
UPDATE
""" + self.TABLEMISSION + """
SET
review = ?, note = ?
WHERE
missionId = ?"""
# Exécution de la requète
self.exec_cmd(reqAddMission, [review, note, missionId])
return 1
# ****************************************************************************
# RECUPERATION DES INFORMATIONS RELATIVES AUX MISSIONS
# ****************************************************************************
# Récupérations des missions d'un pro par son id
def get_mission_by_proid(self, proId):
reqGetMissionsProId = """
SELECT
missionId, date, subject, note, review,
acceptedByPro, validatedByClient,
validatedByPro, jobCategoryId, proId, lastname
FROM
""" + self.TABLEMISSION + """
LEFT JOIN
""" + self.TABLEUSERINFO + """
ON
""" + self.TABLEMISSION + """.proId = """ + self.TABLEUSERINFO + """.userId
WHERE
proId = ?"""
self.exec_cmd(reqGetMissionsProId, [proId])
result = self.cur.fetchall()
return result
# Récupérations des missions d'un client par son id
def get_mission_by_clientid(self, clientId):
reqGetMissionsClientId = """
SELECT
missionId, date, subject, note, review,
acceptedByPro, validatedByClient,
validatedByPro, jobCategoryId, proId, lastname
FROM
""" + self.TABLEMISSION + """
LEFT JOIN
""" + self.TABLEUSERINFO + """
ON
""" + self.TABLEMISSION + """.proId = """ + self.TABLEUSERINFO + """.userId
WHERE
clientId = ?"""
self.exec_cmd(reqGetMissionsClientId, [clientId])
result = self.cur.fetchall()
return result
# Récupérations des missions d'un client par son id
def get_all_missions(self):
reqGetAllMission = """
SELECT
*
FROM
""" + self.TABLEMISSION
self.exec_cmd(reqGetAllMission)
result = self.cur.fetchall()
return result
# Compte le nombre de mission d'un consultant par son nom
def count_pro_missions_by_proid(self, proId):
reqCountMission = """
SELECT COUNT(*) FROM
""" + self.TABLEMISSION + """
INNER JOIN
""" + self.TABLEUSERINFO + """
ON
""" + self.TABLEMISSION + """.proId = """ + self.TABLEUSERINFO + """.userId
WHERE
proId = ?"""
self.exec_cmd(reqCountMission, [proId])
result = self.cur.fetchall()
return result
|
