Basic CRM reporting.
[wolnelektury.git] / src / club / civicrm.py
1 from datetime import datetime
2 import json
3 from celery.task import task
4 from django.conf import settings
5 import requests
6 import yaml
7
8
9 class CiviCRM:
10     def __init__(self, base, key):
11         self.base = base
12         self.api_base = base + 'civicrm/ajax/api4/'
13         self.key = key
14         self.enabled = bool(self.base and self.key)
15
16     def request(self, resource, method, params):
17         if not self.enabled:
18             return
19
20         response = requests.post(
21             self.api_base + f'{resource}/{method}',
22             params={
23                 'params': json.dumps(params),
24                 'api_key': self.key
25             },
26         )
27         d = response.json()
28         return d
29
30     def create_or_update_contact(self, email, key):
31         contact_id = self.get_contact_id(email)
32         if contact_id is None:
33             contact_id = self.create_contact(email, key)
34         else:
35             self.update_contact(contact_id, key)
36         return contact_id
37
38     def get_contact_id(self, email):
39         result = self.request(
40             'Contact',
41             'get',
42             {
43                 "join": [["Email AS email", "LEFT"]],
44                 "where":[["email.email", "=", email]],
45                 "limit":1,
46                 "debug":True
47             }
48         )['values']
49         if result:
50             return result[0]['id']
51
52     def create_contact(self, email, key):
53         result = self.request(
54             'Contact',
55             'create',
56             {
57                 'values': {
58                     'WL.TPWL_key': key,
59                 },
60                 'chain': {
61                     'email': [
62                         'Email',
63                         'create',
64                         {
65                             'values': {
66                                 'email': email,
67                                 'contact_id': '$id'
68                             }
69                         }
70                     ]
71                 }
72             }
73         )
74         return result[0]['id']
75     
76     def update_contact(self, contact_id, key):
77         return self.request(
78             'Contact',
79             'update',
80             {
81                 'values': {
82                     'WL.TPWL_key': key,
83                 },
84                 'where': [
85                     ['id', '=', contact_id]
86                 ]
87             }
88         )
89                 
90
91     def report_activity(self, email, tpwl_key, key, name, datetime, details):
92         contact_id = self.create_or_update_contact(email, tpwl_key)
93
94         activity_id = self.get_activity_id(key)
95         if activity_id is None:
96             self.create_activity(
97                 contact_id,
98                 key,
99                 name,
100                 datetime,
101                 details
102             )
103         else:
104             self.update_activity(
105                 activity_id,
106                 contact_id,
107                 name,
108                 datetime,
109                 details
110             )
111
112     def get_activity_id(self, key):
113         result = self.request(
114             'Activity',
115             'get',
116             {
117                 'where': [
118                     ['subject', '=', key],
119                 ]
120             }
121         )['values']
122         if result:
123             return result[0]['id']
124     
125     def create_activity(self, contact_id, key, name, date_time, details):
126         detail_str = yaml.dump(details)
127         return self.request(
128             'Activity',
129             'create',
130             {
131                 'values': {
132                     'source_contact_id': contact_id,
133                     'activity_type_id:name': name,
134                     'status_id:name': 'Completed',
135                     'activity_date_time': date_time.isoformat() if date_time else '',
136                     'details' : detail_str,
137                     'subject': key,
138                 },
139                 'debug': True,
140             }
141         )
142
143     def update_activity(self, activity_id, contact_id, name, date_time, details):
144         detail_str = yaml.dump(details)
145
146         self.request(
147             'Activity',
148             'update',
149             {
150                 'values': {
151                     'source_contact_id': contact_id,
152                     'activity_type_id:name': name,
153                     'status_id:name': 'Completed',
154                     'activity_date_time': date_time.isoformat(),
155                     'details' : detail_str,
156                 },
157                 'where': [
158                     ['id', '=', activity_id]
159                 ]
160             }
161         )
162     
163     #do we create a civicontribution?
164
165
166 civicrm = CiviCRM(
167     settings.CIVICRM_BASE,
168     settings.CIVICRM_KEY,
169 )
170
171 @task(ignore_result=True)
172 def report_activity(*args, **kwargs):
173     civicrm.report_activity(*args, **kwargs)
174
175