From d21646a619e656447b96fea22b085f871b1c35f2 Mon Sep 17 00:00:00 2001 From: Marek Isalski Date: Sat, 5 Sep 2020 09:58:42 +0100 Subject: [PATCH] bring in improvements from other developments --- fulcrm_membership.module | 298 ++++++++++++++++++++++++++++++++++++++- 1 file changed, 296 insertions(+), 2 deletions(-) diff --git a/fulcrm_membership.module b/fulcrm_membership.module index 423a549..5f0c260 100644 --- a/fulcrm_membership.module +++ b/fulcrm_membership.module @@ -2,6 +2,14 @@ function fulcrm_membership_menu() { $items = array(); + + $items[ 'admin/config/services/fulcrm/membership' ] = array( 'page callback' => 'fulcrm_membership_admin', + 'file' => 'fulcrm_membership.admin.inc', + 'title' => 'fulcrm Membership', + 'description' => 'Configure Membership integration with fulcrm.org.', + 'access callback' => 'user_access', + 'access arguments' => array('administer fulcrm membership'), + ); $items[ 'user/fulcrm/optin/%' ] = array( 'page callback' => 'fulcrm_membership_optin', 'page arguments' => array(3), 'title' => 'Subscription Opt-In', @@ -9,6 +17,12 @@ function fulcrm_membership_menu() { 'access callback' => 'user_access', 'access arguments' => array('access content'), ); + $items[ 'user/fulcrm/membership' ] = array( 'page callback' => 'fulcrm_membership_self_set', + 'title' => 'Choose Your Settings', + 'description' => 'Opt-In Membership Settings.', + 'access callback' => 'user_access', + 'access arguments' => array('access content'), + ); return $items; } @@ -18,11 +32,43 @@ function fulcrm_membership_optin_form_submit( $form, &$form_state ) { if ( $p2m_id ) { $api_data = fulcrm_apiv2_PATCH( 'person2membership/' . $p2m_id . '/', $data = array( 'archived' => NULL ), - $query = array( 'expand' => implode( ',', array( 'person', 'membership' ) ) ) ); + $query = array( 'expand' => implode( ',', array( 'person', 'membership', 'timescale' ) ) ) ); if ( $api_data[ 'success' ] ) { + $api1_data = fulcrm_apiv2_POST( 'n/', + $data = array( 'note' => 'Subscription added through opt-in via website.', + 'person' => $api_data[ 'data' ][ 'person' ][ 'url' ], + 'content_object' => $api_data[ 'data' ][ 'url' ], + ) ); + $now = new DateTime(); + $now->setTimestamp( time() ); + $now->setTimeZone( new DateTimeZone('GMT') ); + $now_str = $now->format('Y-m-d\TH:i:s\Z'); + + if ( $api_data[ 'data' ][ 'timescale' ] ) { + $api3_data = fulcrm_apiv2_PATCH( $api_data[ 'data' ][ 'timescale' ][ 'url' ], + $data = array( 'start' => $now_str ) ); + if ( $api3_data[ 'success' ] ) { + } else { + drupal_set_message( t('There was a problem confirming your subscription (update start date).'), 'error', FALSE ); + } + } else { + $api3_data = fulcrm_apiv2_POST( 'timescale/', + $data = array( 'start' => $now_str ) ); + if ( $api3_data[ 'success' ] ) { + $api4_data = fulcrm_apiv2_PATCH( 'person2membership/' . $p2m_id . '/', + $data = array( 'timescale' => $api3_data[ 'data' ][ 'url' ] ) ); + if ( $api4_data[ 'success' ] ) { + } else { + drupal_set_message( t('There was a problem confirming your subscription (associate start date).'), 'error', FALSE ); + } + } else { + drupal_set_message( t('There was a problem confirming your subscription (create start date).'), 'error', FALSE ); + } + } + if ( $api_data[ 'data' ][ 'person' ][ 'archived' ] ) { $api2_data = fulcrm_apiv2_PATCH( $api_data[ 'data' ][ 'person' ][ 'url' ], - $data = array( 'archived' => NULL ) ); + $data = array( 'archived' => NULL ) ); if ( $api2_data[ 'success' ] ) { drupal_set_message( t('Thank you! Your subscription to "%membership" has been confirmed.', array( '%membership' => $api_data[ 'data' ][ 'membership' ][ 'name' ] )), 'status', FALSE ); drupal_goto( '' ); @@ -82,3 +128,251 @@ function fulcrm_membership_optin( $passport ) { return drupal_get_form( 'fulcrm_membership_optin_form', $api_data[ 'data' ][ 'results' ] ); } } + + + +function fulcrm_membership_person2membership_is_current( $p2m ) { + if ( $p2m[ 'timescale' ] ) { + $tz = new DateTimeZone('UTC'); + $now = new DateTime(); + + $ts_start = $p2m[ 'timescale' ][ 'start' ]; + if ( $ts_start ) { + $start = DateTime::createFromFormat( 'Y-m-d\TH:i:s.u\Z', $ts_start, $timezone = $tz ); + $start = $start ? $start : DateTime::createFromFormat( 'Y-m-d\TH:i:s\Z', $ts_start, $timezone = $tz ); + } else { + $start = NULL; + } + + $ts_finish = $p2m[ 'timescale' ][ 'finish' ]; + if ( $ts_finish ) { + $finish = DateTime::createFromFormat( 'Y-m-d\TH:i:s.u\Z', $ts_finish, $timezone = $tz ); + $finish = $finish ? $finish : DateTime::createFromFormat( 'Y-m-d\TH:i:s\Z', $ts_finish, $timezone = $tz ); + } else { + $finish = NULL; + } + + return ( ( is_null( $start ) || ( $start <= $now ) ) && ( is_null( $finish ) || ( $finish > $now ) ) ); + } else { + return true; + } +} + +function fulcrm_membership_can_self_set_person2membership( $p2m ) { + if ( array_key_exists( 'membership', $p2m ) ) { + if ( is_array( $p2m[ 'membership' ] ) ) + $membership_id = $p2m[ 'membership' ][ 'id' ]; + else + $membership_id = fulcrm_apiv2_url_to_pk( $p2m[ 'membership' ] ); + + $self_set_membership_ids = variable_get( 'fulcrm_membership_self_set_membership_ids', array() ); + if ( array_key_exists( $membership_id, $self_set_membership_ids ) ) { + if ( $self_set_membership_ids[ $membership_id ] ) + return true; + } + } + return false; +} + +function fulcrm_membership_cease_person2membership( $p2m, $now = NULL ) { + if ( is_null( $now ) ) + $now = new DateTime(); + $tz = new DateTimeZone('UTC'); + $now->setTimeZone( $tz ); + $finish = $now->format( 'Y-m-d\TH:i:s.u\Z' ); + + if ( $p2m[ 'timescale' ] ) { + $api_data = fulcrm_apiv2_PATCH( $p2m[ 'timescale' ][ 'url' ], $data = array( 'finish' => $finish ) ); + if ( $api_data[ 'success' ] ) { + return true; + } else { + watchdog('fulcrm_membership', 'could not patch person2membership %id cease', array('%id'=>$p2m['id']), WATCHDOG_ERROR); + } + } else { + $timescale_data = fulcrm_apiv2_POST( 'timescale/', $data = array( 'finish' => $finish ) ); + if ( $timescale_data[ 'success' ] ) { + $api_data = fulcrm_apiv2_PATCH( $p2m[ 'url' ], $data = array( 'timescale' => $timescale_data[ 'data' ][ 'url' ] ) ); + if ( $api_data[ 'success' ] ) { + return true; + } else { + watchdog('fulcrm_membership', 'could not patch person2membership %id to add timescale %tid', array('%id'=>$p2m['id'],'%tid'=>$timescale_data['data']['id']), WATCHDOG_ERROR); + } + } else { + watchdog('fulcrm_membership', 'could not create timescale to cease membership %id', array('%id'=>$p2m['id']), WATCHDOG_ERROR); + } + } + return false; +} + +function fulcrm_membership_begin_person2membership( $person_id, $membership_id, $now = NULL ) { + if ( is_null( $now ) ) + $now = new DateTime(); + $tz = new DateTimeZone('UTC'); + $now->setTimeZone( $tz ); + $start = $now->format( 'Y-m-d\TH:i:s.u\Z' ); + + $timescale_data = fulcrm_apiv2_POST( 'timescale/', $data = array( 'start' => $start ) ); + if ( $timescale_data[ 'success' ] ) { + $api_data = fulcrm_apiv2_POST( 'person2membership/', $data = array( 'person' => '/api/v2/person/' . $person_id . '/', + 'membership' => '/api/v2/membership/' . $membership_id . '/', + 'timescale' => $timescale_data[ 'data' ][ 'url' ], + ) ); + if ( $api_data[ 'success' ] ) { + return true; + } else { + watchdog('fulcrm_membership', 'could not post person2membership to create membership %mid for %pid', array('%mid'=>$membership_id,'%pid'=>$person_id), WATCHDOG_ERROR); + } + } else { + watchdog('fulcrm_membership', 'could not post timescale to create membership %mid for %pid', array('%mid'=>$membership_id,'%pid'=>$person_id), WATCHDOG_ERROR); + } + +} + +function fulcrm_membership_self_set_form_submit( $form, &$form_state ) { + global $user; + $person_id = fulcrm_webhook_get_pk_for_entity_type( 'user', $user->uid, 'person' ); + if ( $person_id ) { + $person_data = fulcrm_apiv2_GET( 'person/' . $person_id . '/', + $query = array( 'expand' => implode( ',', array( 'person2memberships', + 'person2memberships.membership', + 'person2memberships.timescale' ) ) ) ); + if ( $person_data[ 'success' ] ) { + $membership_data = fulcrm_apiv2_GET( 'membership/', + $query = array( 'page_size' => 1000, + ) ); + + if ( $membership_data[ 'success' ] ) { + $membership_name = array(); + foreach ( $membership_data[ 'data' ][ 'results' ] as $membership ) + $membership_name[ $membership[ 'id' ] ] = $membership[ 'name' ]; + + $possible_ids = variable_get( 'fulcrm_membership_self_set_membership_ids', array() ); + + $current_map = array(); + $new_map = array(); + foreach ( $possible_ids as $membership_id => $is_possible ) { + if ( $is_possible ) { + $current_map[ $membership_id ] = false; + $new_map[ $membership_id ] = array_key_exists( $membership_id, $form_state[ 'values' ][ 'memberships' ] ) ? $form_state[ 'values' ][ 'memberships' ][ $membership_id ] : 0; + } + } + foreach ( $person_data[ 'data' ][ 'person2memberships' ] as $p2m ) { + $membership_id = $p2m[ 'membership' ][ 'id' ]; + if ( array_key_exists( $membership_id, $possible_ids ) && $possible_ids[ $membership_id ] ) { + if ( fulcrm_membership_person2membership_is_current( $p2m ) ) { + $current_map[ $membership_id ] = true; + } + } + } + + // figure out the differences + foreach ( $possible_ids as $membership_id => $is_possible ) { + if ( $is_possible ) { + if ( $current_map[ $membership_id ] && $new_map[ $membership_id ] ) { + // do nothing + } elseif ( !$current_map[ $membership_id ] && !$new_map[ $membership_id ] ) { + // do nothing + } elseif ( $current_map[ $membership_id ] && !$new_map[ $membership_id ] ) { + // REMOVE MEMBERSHIP $membership_id + foreach ( $person_data[ 'data' ][ 'person2memberships' ] as $p2m ) { + if ( $p2m[ 'membership' ][ 'id' ] == $membership_id ) { + if ( fulcrm_membership_person2membership_is_current( $p2m ) ) { + if ( fulcrm_membership_cease_person2membership( $p2m ) ) + drupal_set_message( t('Ceased your "' . $p2m[ 'membership' ][ 'name' ] . '" membership.'), 'status', FALSE ); + } + } + } + } elseif ( !$current_map[ $membership_id ] && $new_map[ $membership_id ] ) { + // ADD MEMBERSHIP $membership_id + if ( fulcrm_membership_begin_person2membership( $person_id, $membership_id ) ) { + drupal_set_message( t('You have begun your "' . $membership_name[ $membership_id ] . '" membership.'), 'status', FALSE ); + } + } + } + } + } else { + drupal_set_message( t('There was a problem fetching membership information.'), 'error', FALSE ); + } + } else { + drupal_set_message( t('There was a problem fetching your subscription information.'), 'error', FALSE ); + } + } +} + +function fulcrm_membership_self_set_form( $form, &$form_state ) { + global $user; + + $form[ 'title' ] = array( '#type' => 'item', + '#title' => 'Subscription Preferences', + '#description' => 'This page lets you choose which subscriptions you will receive. Simply tick or untick the boxes as required.', + ); + + $person_id = fulcrm_webhook_get_pk_for_entity_type( 'user', $user->uid, 'person' ); + if ( $person_id ) { + $person_data = fulcrm_apiv2_GET( 'person/' . $person_id . '/', + $query = array( 'expand' => implode( ',', array( 'person2memberships', + 'person2memberships.membership', + 'person2memberships.timescale' ) ) ) ); + + if ( $person_data[ 'success' ] ) { + $membership_data = fulcrm_apiv2_GET( 'membership/', + $query = array( 'page_size' => 1000, + ) ); + + if ( $membership_data[ 'success' ] ) { + $membership_name = array(); + foreach ( $membership_data[ 'data' ][ 'results' ] as $membership ) + $membership_name[ $membership[ 'id' ] ] = $membership[ 'name' ]; + + $possible_ids = variable_get( 'fulcrm_membership_self_set_membership_ids', array() ); + $membership_map = array(); + $options = array(); + + foreach ( $possible_ids as $membership_id => $is_possible ) { + if ( $is_possible ) { + $membership_map[ $membership_id ] = 0; + if ( array_key_exists( $membership_id, $membership_name ) ) + $options[ $membership_id ] = $membership_name[ $membership_id ]; + } + } + + foreach ( $person_data[ 'data' ][ 'person2memberships' ] as $p2m ) { + $membership_id = $p2m[ 'membership' ][ 'id' ]; + if ( array_key_exists( $membership_id, $possible_ids ) && $possible_ids[ $membership_id ] ) { + if ( fulcrm_membership_person2membership_is_current( $p2m ) ) { + $membership_map[ $membership_id ] = $membership_id; + } + } + } + + $form[ 'memberships' ] = array( '#type' => 'checkboxes', + '#title' => 'Your Current Subscriptions', + '#options' => $options, + '#default_value' => $membership_map, + ); + } else { + drupal_set_message( t('There was a problem fetching membership information.'), 'error', FALSE ); + } + } else { + drupal_set_message( t('There was a problem fetching your subscription information.'), 'error', FALSE ); + } + } + + $form[ 'actions' ] = array( '#type' => 'actions' ); + $form[ 'actions' ][ 'cancel' ] = array( '#markup' => l(t('Cancel'), 'user' ) ); + $form[ 'actions' ][ 'save' ] = array( '#type' => 'submit', + '#value' => t('Save'), + '#submit' => array( 'fulcrm_membership_self_set_form_submit' ), + ); + + + return $form; +} + +function fulcrm_membership_self_set() { + //if ( user_is_logged_in() ) { + return drupal_get_form( 'fulcrm_membership_self_set_form' ); + //} else { + //drupal_goto( 'user?destination=user/fulcrm/membership' ); + //} +}