From 29e742394bf404c9cf0a2c59bb361c27b0029cd1 Mon Sep 17 00:00:00 2001 From: Marek Isalski Date: Mon, 4 Mar 2019 00:29:27 +0100 Subject: [PATCH] can now begin a membership; but cease needs a fix --- fulcrm_membership.module | 127 ++++++++++++++++++++++++++++++++++++++- 1 file changed, 125 insertions(+), 2 deletions(-) diff --git a/fulcrm_membership.module b/fulcrm_membership.module index e6c1628..9d55dc4 100644 --- a/fulcrm_membership.module +++ b/fulcrm_membership.module @@ -132,8 +132,129 @@ function fulcrm_membership_optin( $passport ) { } } +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[ '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 ) { @@ -141,7 +262,7 @@ function fulcrm_membership_self_set_form( $form, &$form_state ) { $form[ 'title' ] = array( '#type' => 'item', '#title' => 'Subscription Preferences', - '#description' => '', + '#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' ); @@ -183,7 +304,7 @@ function fulcrm_membership_self_set_form( $form, &$form_state ) { } $form[ 'memberships' ] = array( '#type' => 'checkboxes', - '#title' => 'Subscriptions', + '#title' => 'Your Current Subscriptions', '#options' => $options, '#default_value' => $membership_map, ); @@ -196,11 +317,13 @@ function fulcrm_membership_self_set_form( $form, &$form_state ) { } $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; }