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