# gdpr-framework/trunk/src/Components/Consent/UserConsentModel.php

The GDPR Framework By Data443, version trunk. 433 lines.

- Page: https://pluginprobe.com/plugins/gdpr-framework/trunk/code/src/Components/Consent/UserConsentModel.php
- Raw: https://pluginprobe.com/plugins/gdpr-framework/trunk/raw/src/Components/Consent/UserConsentModel.php
- Modified: 2022-04-19T18:55:24+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/gdpr-framework/trunk/code/src/Components/Consent/UserConsentModel.php#L10-L20`.

```php
<?php

namespace Codelight\GDPR\Components\Consent;

use DateTime;

/**
 * Class UserConsentModel
 *
 * @package Codelight\GDPR\Components\Consent
 */
class UserConsentModel
{
	/* @var string */
	public $tableName;

	/* @var string */
	public $logtableName;

	/* @var string */
	public $version =  GDPR_FRAMEWORK_VERSION;

	/* @var string */
	public $primaryKey = 'id';

	/**
	 * UserConsentModel constructor.
	 */
	public function __construct()
	{ 
		$this->setTableName();
		$this->setUserLogTableName();
	}

	/**
	 * Set the table name with wpdb-s prefix
	 */
	protected function setTableName()
	{
		global $wpdb;
		$this->tableName = $wpdb->prefix . 'gdpr_consent';
	}

	/**
	 * Set the table name with wpdb-s prefix
	 */
	protected function setUserLogTableName()
	{
		global $wpdb;
		$this->logtableName = $wpdb->prefix . 'gdpr_userlogs';
	}

	/**
	 * Check if a user has given a consent
	 *
	 * @param $email
	 * @param $consent
	 * @return int
	 */
	public function given($email, $consent)
	{
		global $wpdb;

		// FRAM-140 fix invalid access: should be '$consent' not '$consent->consent'
		return count( $wpdb->get_results( $wpdb->prepare(
			"SELECT * FROM {$this->tableName} WHERE email = %s AND consent = %s AND status = 1;",
			$email,
			$consent
		) ) );
		
	}

	/**
	 * Check if a user has withdrawn a consent
	 *
	 * @param $email
	 * @param $consent
	 * @return int
	 */
	public function withdrawn($email, $consent)
	{
		global $wpdb;

		return count($wpdb->get_results($wpdb->prepare(
			"SELECT * FROM {$this->tableName} WHERE email = %s AND consent = %s AND status = 0;",
			$email,
			$consent
		)));
	}

	/**
	 * Check if a consent exists in the database
	 *
	 * @param $email
	 * @param $consent
	 * @return array|null|object
	 */
	public function exists($email, $consent)
	{
		global $wpdb;

		return count($wpdb->get_results($wpdb->prepare(
			"SELECT * FROM {$this->tableName} WHERE email = %s AND consent = %s;",
			$email,
			$consent
		)));
	}

	/**
	 * Set a consent to 'given'
	 *
	 * @param $email
	 * @param $consent
	 * @param $status
	 * @return false|int
	 */
	public function give($email, $consent, $valid_until)
	{
		$this->set($email, $consent, 1, $valid_until);
	}

	/**
	 * Set a consent to 'withdrawn'
	 *
	 * @param $email
	 * @param $consent
	 * @param $status
	 * @return false|int
	 */
	public function withdraw($email, $consent)
	{
		$this->set($email, $consent, 0, null);
	}

	/**
	 * Set a consent to 'given' or 'withdrawn'
	 *
	 * @param $email
	 * @param $consent
	 * @param $status
	 * @return false|int
	 */
	protected function set($email, $consent, $status, $valid_until, $version = 1)
	{
		global $wpdb;

		if( $valid_until !== null && $valid_until !== '' ) {
			$future_date = new DateTime( current_time( 'mysql' ) );
			date_add( $future_date, date_interval_create_from_date_string( $valid_until . 'months' ) );
			$future_date = date_format($future_date, 'Y-m-d H:i:s');
		}else{
			$future_date = '9999-12-31 23:59:59';
		}

		if ($this->exists($email, $consent)) {
			return $wpdb->update(
				$this->tableName,
				[
					'version'     => $version,
					'status'      => $status,
					'updated_at'  => current_time( 'mysql' ),
					'ip'          => $_SERVER['REMOTE_ADDR'],
					'valid_until' => $future_date,
				],
				[
					'email'   => $email,
					'consent' => $consent,
				]
			);
		} else {
			return $wpdb->insert(
				$this->tableName,
				[
					'email'       => $email,
					'version'     => $version,
					'consent'     => $consent,
					'status'      => $status,
					'updated_at'  => current_time( 'mysql' ),
					'ip'          => $_SERVER['REMOTE_ADDR'],
					'valid_until' => $future_date,
				]
			);
		}
	}

	/**
	 * Set a userlog
	 *
	 * @param $email
	 * @param $userlog
	 */
	public function savelog($email, $userlog)
	{
		
		$this->savelog_gdpr($email, $userlog);
	}

	/**
	 * Set a userlog to show previous data
	 *
	 * @param $userid
	 * @param $userlog
	 */
	protected function savelog_gdpr($user_id,$userlog)
	{
		global $wpdb;
		if (!empty($user_id) && !empty($userlog)) {
			$sa= $wpdb->insert(
				$this->logtableName,
				[
					'user_id'    => $user_id,
					'userlog'    => $userlog,
					'updated_at' => current_time( 'mysql' ),
					'ip'         => $_SERVER['REMOTE_ADDR'],
				]
			);
		}
	}

	/**
	 * Get all consent given by data subject
	 *
	 * @param $email
	 */
	public function getAll($email)
	{
		global $wpdb;

		/**
		 * Workaround to an issue with array_column in PHP5.6 - thanks @paulnewson
		 */
		if (version_compare(PHP_VERSION, '7') >= 0) {
			return $wpdb->get_results( $wpdb->prepare(
				"SELECT * FROM {$this->tableName} WHERE email = %s and status = 1;",
				$email
			));
		} else {
			return json_decode( json_encode( $wpdb->get_results($wpdb->prepare(
				"SELECT * FROM {$this->tableName} WHERE email = %s and status = 1;",
				$email
			))), true);
		}
	}

	
	/**
	 * Get all consent given by data subject with data
	 *
	 * @param $email
	 */
	public function getAllwithdetails($email)
	{
		global $wpdb;

		/**
		 * Workaround to an issue with array_column in PHP5.6 - thanks @paulnewson
		 */
		if (version_compare(PHP_VERSION, '7') >= 0) {
			return $wpdb->get_results($wpdb->prepare(
				"SELECT * FROM {$this->tableName} WHERE email = %s and status = 1;",
				$email
			));
		} else {
			return json_decode(json_encode($wpdb->get_results($wpdb->prepare(
				"SELECT * FROM {$this->tableName} WHERE email = %s and status = 1;",
				$email
			))), true);
		}
	}

	/**
	 * Get all consent given by data subject
	 *
	 * @param $email
	 */
	public function getuserlogs($userid)
	{
		global $wpdb;
		/**
		 * Workaround to an issue with array_column in PHP5.6 - thanks @paulnewson
		 */
		if (version_compare(PHP_VERSION, '7') >= 0) {
			return $wpdb->get_results($wpdb->prepare(
				"SELECT * FROM {$this->logtableName} WHERE user_id = %s;",
				$userid
			));
		} else {
			return json_decode(json_encode($wpdb->get_results($wpdb->prepare(
				"SELECT * FROM {$this->logtableName} WHERE user_id = %s;",
				$userid
			))), true);
		}
	}

	/**
	 * Remove a log row from the database
	 *
	 * @param $id
	 */
	public function deletelog($id)
	{
		global $wpdb;

		return $wpdb->delete(
			$this->logtableName,
			[
				'user_id'   => $id,
			]
		);
	}

	/**
	 * Remove a consent row from the database
	 *
	 * @param $email
	 * @param $consent
	 * @return false|int
	 */
	public function delete($email, $consent)
	{
		global $wpdb;

		return $wpdb->delete(
			$this->tableName,
			[
				'email'   => $email,
				'consent' => $consent,
			]
		);
	}

	/**
	 * Withdraw consent and anonymize data subject's email
	 *
	 * @param $email
	 * @param $consent
	 * @param $anonymizedId
	 * @return false|int
	 */
	public function anonymize($email, $consent, $anonymizedId)
	{
		global $wpdb;

		if ($this->exists($email, $consent)) {
			return $wpdb->update(
				$this->tableName,
				[
					'email'      => $anonymizedId,
					'status'     => 0,
					'updated_at' => current_time( 'mysql' ),
					'ip'         => $_SERVER['REMOTE_ADDR'],
				],
				[
					'email'   => $email,
					'consent' => $consent,
				]
			);
		}
	}

	/**
	 * Get columns and formats
	 */
	public function getColumns()
	{
		return [
			'id'         => '%d',
			'version'    => '%d',
			'email'      => '%s',
			'consent'    => '%s',
			'status'     => '%d',
			'updated_at' => '%s',
			'ip'         => '%s',
			'valid_until'   => '%s',
		];
	}

	/**
	 * Get default column values
	 */
	public function getColumnDefaults()
	{
		return [
			'id'         => '',
			'version'    => 1,
			'email'      => '',
			'consent'    => '',
			'status'     => '',
			'updated_at' => '',
			'ip'         => '',
			'valid_until'   => '',
		];
	}

	/**
	 * Create the table
	 */
	public function createTable()
	{
		
		require_once(ABSPATH . 'wp-admin/includes/upgrade.php');
		$sql = "CREATE TABLE " . $this->tableName . " (
			id bigint(20) NOT NULL AUTO_INCREMENT,
			version int NOT NULL,
			email varchar(64) NOT NULL,
			consent varchar(128) NOT NULL,
			status tinyint NOT NULL,
			updated_at TIMESTAMP NULL,
			ip varchar(64) NOT NULL,
			valid_until DATETIME NOT NULL,
			PRIMARY KEY  (id)
			) CHARACTER SET utf8 COLLATE utf8_general_ci;";
		dbDelta($sql);
		update_option($this->tableName . '_db_version', $this->version);
	}
	/**
	 * create table to user logs
	 */
	public function createUserTable()
	{
		require_once(ABSPATH . 'wp-admin/includes/upgrade.php');
		$sql = "CREATE TABLE " . $this->logtableName . " (
			id bigint(20) NOT NULL AUTO_INCREMENT,
			user_id int NOT NULL,
			userlog varchar(4000) NOT NULL,
			updated_at TIMESTAMP NULL,
			ip varchar(64) NOT NULL,
			PRIMARY KEY  (id)
			) CHARACTER SET utf8 COLLATE utf8_general_ci;";
		dbDelta($sql);
		update_option($this->logtableName . '_db_version', $this->version);
	}
}
```