ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / letacommog / entrepro / wp-content / plugins / dokan-pro / includes / api

<?php

/**
* Announcement Controller class
*/
class Dokan_REST_Announcement_Controller extends Dokan_REST_Controller {

/**
     * Endpoint namespace.
     *
     * @var string
     */
    protected $namespace = 'dokan/v1';

/**
     * Route name
     *
     * @var string
     */
    protected $base = 'announcement';

/**
     * Post type.
     *
     * @var string
     */
    protected $post_type = 'dokan_announcement';

/**
     * Post type.
     *
     * @var string
     */
    protected $post_status = array( 'publish' );

/**
     * Register all announcement route
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function register_routes() {
        register_rest_route( $this->namespace, '/' . $this->base, array(
            array(
                'methods'             => WP_REST_Server::READABLE,
                'callback'            => array( $this, 'get_announcements' ),
                'args'                => array_merge( $this->get_collection_params(),  array(
                    'status' => array(
                        'type'        => 'string',
                        'description' => __( 'Announcement status', 'dokan' ),
                        'required'    => false,
                    ),
                ) ),
                'permission_callback' => array( $this, 'get_announcement_permissions_check' ),
            ),
            array(
                'methods'             => WP_REST_Server::CREATABLE,
                'callback'            => array( $this, 'create_announcement' ),
                'args'                => $this->get_endpoint_args_for_item_schema( WP_REST_Server::CREATABLE ),
                'permission_callback' => array( $this, 'create_announcement_permissions_check' ),
            ),
        ) );

register_rest_route( $this->namespace, '/' . $this->base . '/(?P<id>[\d]+)/', array(
            'args' => array(
                'id' => array(
                    'description' => __( 'Unique identifier for the object.', 'dokan-lite' ),
                    'type'        => 'integer',
                ),
            ),

array(
                'methods'             => WP_REST_Server::READABLE,
                'callback'            => array( $this, 'get_announcement' ),
                'permission_callback' => array( $this, 'get_announcement_permissions_check' ),
            ),

array(
                'methods'             => WP_REST_Server::EDITABLE,
                'callback'            => array( $this, 'update_announcement' ),
                'permission_callback' => array( $this, 'get_announcement_permissions_check' ),
            ),

array(
                'methods'             => WP_REST_Server::DELETABLE,
                'callback'            => array( $this, 'delete_announcement' ),
                'permission_callback' => array( $this, 'get_announcement_permissions_check' ),
            ),

) );

register_rest_route( $this->namespace, '/' . $this->base . '/(?P<id>[\d]+)/restore', array(
            'args' => array(
                'id' => array(
                    'description' => __( 'Unique identifier for the object.', 'dokan' ),
                    'type'        => 'integer',
                ),
            ),

array(
                'methods'             => WP_REST_Server::EDITABLE,
                'callback'            => array( $this, 'restore_announcement' ),
                'permission_callback' => array( $this, 'restore_announcement_permissions_check' ),
            ),
        ) );

register_rest_route( $this->namespace, '/' . $this->base . '/batch', array(
            array(
                'methods'             => WP_REST_Server::EDITABLE,
                'callback'            => array( $this, 'batch_items' ),
                'permission_callback' => array( $this, 'batch_items_permissions_check' ),
                'args'                => $this->get_endpoint_args_for_item_schema( WP_REST_Server::EDITABLE ),
            ),
        ) );
    }

/**
     * Get single object
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function get_object( $id ) {
        return get_post( $id );
    }

/**
     * Get all announcement
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function get_announcements( $request ) {
        $status = ( empty( $request['status'] ) || $request['status'] == 'all' ) ? array( 'publish', 'pending', 'draft' ) : $request['status'];

$limit = $request['per_page'];
        $offset = ( $request['page'] - 1 ) * $request['page'];

$args = array(
            'post_type'      => $this->post_type,
            'posts_per_page' => $limit,
            'paged'          => $offset,
            'post_status'    => $status
        );

$query = new WP_Query( $args );

$data = array();
        if ( $query->posts ) {
            foreach ( $query->posts as $key => $value ) {
                $resp   = $this->prepare_response_for_object( $value, $request );
                $data[] = $this->prepare_response_for_collection( $resp );
            }
        }

$response = rest_ensure_response( $data );
        $count = wp_count_posts( 'dokan_announcement' );

$response->header( 'X-Status-All', ( $count->pending + $count->publish + $count->draft ) );
        $response->header( 'X-Status-Pending', $count->pending );
        $response->header( 'X-Status-Publish', $count->publish );
        $response->header( 'X-Status-Draft', $count->draft );
        $response->header( 'X-Status-Trash', $count->trash );

$response = $this->format_collection_response( $response, $request, $query->found_posts );
        return $response;
    }

/**
     * Get single announcement object
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function get_announcement( $request ) {
        $announcement_id = $request['id'];

if ( empty( $announcement_id ) ) {
            return new WP_Error( 'no_announcement_found', __( 'No announcement found', 'dokan-lite' ), array( 'status' => 404 ) );
        }

$data     = $this->prepare_response_for_object( $this->get_object( $announcement_id ), $request );
        $response = rest_ensure_response( $data );

return $response;
    }

/**
     * Create announcement
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function create_announcement( $request ) {

if (  empty( trim( $request['title'] ) ) ) {
            return new WP_Error( 'no_title', __( 'Announcement title must be required', 'dokan-lite' ), array( 'status' => 404 ) );
        }

$status = !empty( $request['status'] ) ? $request['status'] : 'pending';

$data = array(
            'post_title'   => sanitize_text_field( $request['title'] ),
            'post_content' => $request['content'],
            'post_status'  => $status,
            'post_type'    => 'dokan_announcement',
            'post_author'  => get_current_user_id()
        );

$post_id = wp_insert_post( $data );

if (  is_wp_error( $post_id ) ) {
            return new WP_Error( $post_id->get_error_message() );
        }

update_post_meta( $post_id, '_announcement_type', $request['sender_type'] );
        update_post_meta( $post_id, '_announcement_selected_user', $request['sender_ids'] );

require_once DOKAN_PRO_ADMIN_DIR . '/announcement.php';
        $announcement = new Dokan_Announcement();

$assigned_sellers = !empty( $request['sender_ids'] ) ? $request['sender_ids'] : array();

if ( $request['sender_type'] == 'selected_seller' ) {
            $announcement->process_seller_announcement_data( $assigned_sellers, $post_id );
        } elseif ( $request['sender_type'] == 'all_seller' ) {
            $assigned_sellers = array();
            $users   = new WP_User_Query( array( 'role' => 'seller' ) );
            $sellers = $users->get_results();

if ( $sellers ) {
                foreach ( $sellers as $user ) {
                    $assigned_sellers[] = $user->ID;
                }
            }

$announcement->process_seller_announcement_data( $assigned_sellers, $post_id );
        }

$data = $this->prepare_response_for_object( $this->get_object( $post_id ), $request );
        do_action( 'dokan_after_announcement_saved', $assigned_sellers, $data );

return rest_ensure_response( $data );
    }

/**
     * Update announcement
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function update_announcement( $request ) {
        if ( empty( trim( $request['id'] ) ) ) {
            return new WP_Error( 'no_id', __( 'No announcement id found', 'dokan-lite' ), array( 'status' => 404 ) );
        }

if ( isset( $request['title'] ) && empty( trim( $request['title'] ) ) ) {
            return new WP_Error( 'no_title', __( 'Announcement title must be required', 'dokan-lite' ), array( 'status' => 404 ) );
        }

$status = ! empty( $request['status'] ) ? $request['status'] : '';

$data = array(
            'ID'           => $request['id'],
            'post_title'   => sanitize_text_field( $request['title'] ),
            'post_content' => sanitize_textarea_field( $request['content'] ),
        );

if ( $status ) {
            $data['post_status'] = $status;
        }

$post_id = wp_update_post( $data );

update_post_meta( $post_id, '_announcement_type', $request['sender_type'] );
        update_post_meta( $post_id, '_announcement_selected_user', $request['sender_ids'] );

require_once DOKAN_PRO_ADMIN_DIR . '/announcement.php';
        $announcement = new Dokan_Announcement();

$assigned_sellers = !empty( $request['sender_ids'] ) ? $request['sender_ids'] : array();

if ( $sellers ) {
                foreach ( $sellers as $user ) {
                    $assigned_sellers[] = $user->ID;
                }
            }

$announcement->process_seller_announcement_data( $assigned_sellers, $post_id );
        }

$data = $this->prepare_response_for_object( $this->get_object( $post_id ), $request );

do_action( 'dokan_after_announcement_saved', $assigned_sellers, $data );

return rest_ensure_response( $data );
    }

/**
     * Delete announcement
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function delete_announcement( $request ) {

$post = $this->get_object( $request['id'] );

if ( is_wp_error( $post ) ) {
            return $post;
        }

$id    = $post->ID;
        $force = (bool) $request['force'];

$supports_trash = ( EMPTY_TRASH_DAYS > 0 );

$supports_trash = apply_filters( "dokan_rest_{$this->post_type}_trashable", $supports_trash, $post );

// If we're forcing, then delete permanently.
        if ( $force ) {
            $previous = $this->prepare_response_for_object( $post, $request );
            $result = wp_delete_post( $id, true );
            $this->delete_announcement_data( $id );
            $response = new WP_REST_Response();
            $response->set_data( array( 'deleted' => true, 'previous' => $previous->get_data() ) );
        } else {
            // If we don't support trashing for this type, error out.
            if ( ! $supports_trash ) {
                /* translators: %s: force=true */
                return new WP_Error( 'rest_trash_not_supported', sprintf( __( "The post does not support trashing. Set '%s' to delete.", "dokan" ), 'force=true' ), array( 'status' => 501 ) );
            }

// Otherwise, only trash if we haven't already.
            if ( 'trash' === $post->post_status ) {
                return new WP_Error( 'rest_already_trashed', __( 'The post has already been deleted.', 'dokan' ), array( 'status' => 410 ) );
            }

// (Note that internally this falls through to `wp_delete_post` if
            // the trash is disabled.)
            $result = wp_trash_post( $id );
            $post = get_post( $id );
            $response = $this->prepare_response_for_object( $post, $request );
        }

if ( ! $result ) {
            return new WP_Error( 'dokan_rest_cannot_delete', __( 'The announcement cannot be deleted.', 'dokan' ), array( 'status' => 500 ) );
        }

return $response;
    }

/**
     * Restore announcement
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function restore_announcement( $request ) {
        $post = $this->get_object( $request['id'] );

if ( is_wp_error( $post ) ) {
            return $post;
        }

$post = wp_untrash_post( $post->ID );
        $response = $this->prepare_response_for_object( $post, $request );
        return $response;
    }

/**
     * trash, delete and restore bulk action
     *
     * JSON data format for sending to API
     *     {
     *         "trash" : [
     *             "1", "9", "7"
     *         ],
     *         "delete" : [
     *             "2"
     *         ],
     *         "restore" : [
     *             "4"
     *         ]
     *     }
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function batch_items( $request ) {
        global $wpdb;

$params = $request->get_params();

if ( empty( $params ) ) {
            return new WP_Error( 'no_item_found', __( 'No items found for bulk updating', 'dokan-lite' ), array( 'status' => 404 ) );
        }

$allowed_status = array( 'trash', 'delete', 'restore' );

foreach ( $params as $status => $value ) {
            if ( in_array( $status, $allowed_status ) ) {
                if ( 'delete' === $status ) {
                    foreach ( $value as $announcement_id ) {
                        $result = wp_delete_post( $announcement_id, true );
                        $this->delete_announcement_data( $announcement_id );
                    }
                } else if ( 'trash' === $status ) {
                    foreach ( $value as $announcement_id ) {
                        wp_trash_post( $announcement_id );
                    }
                } else if ( 'restore' === $status ) {
                    foreach ( $value as $announcement_id ) {
                        wp_untrash_post( $announcement_id );
                    }
                }
            }
        }

return true;
    }

/**
     * Delete announcement relational table data
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function delete_announcement_data( $post_id ) {
        global $wpdb;

$table_name = $wpdb->prefix.'dokan_announcement';
        $sql = "DELETE FROM {$table_name} WHERE `post_id` = $post_id";

$wpdb->query( $sql );
    }

/**
     * get_announcement_permissions_check
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function get_announcement_permissions_check() {
        return current_user_can( 'manage_options' );
    }

/**
     * get_announcement_permissions_check
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function restore_announcement_permissions_check() {
        return current_user_can( 'manage_options' );
    }

/**
     * create_announcement_permissions_check
     *
     * @since 2.8.2
     *
     * @return void
     */
    public function create_announcement_permissions_check() {
        return current_user_can( 'manage_options' );
    }

/**
     * Check permission for getting withdraw
     *
     * @since 2.8.0
     *
     * @return void
     */
    public function batch_items_permissions_check() {
        return current_user_can( 'manage_options' );
    }

/**
     * Prepare data for response
     *
     * @since 2.8.0
     *
     * @return data
     */
    public function prepare_response_for_object( $object, $request ) {
        $methods = dokan_withdraw_get_methods();
        $data = array(
            'id'           => $object->ID,
            'title'        => $object->post_title,
            'content'      => $object->post_content,
            'status'       => $object->post_status,
            'created_at'   => mysql_to_rfc3339( $object->post_date ),
            'sender_type'  => get_post_meta( $object->ID, '_announcement_type', true ),
            'sender_ids'   => array()
        );

$sender_ids = get_post_meta( $object->ID, '_announcement_selected_user', true );

if ( ! empty( $sender_ids ) ) {
            foreach ( $sender_ids as  $id ) {
                $vendor = dokan()->vendor->get( $id );
                $data['sender_ids'][] = array(
                    'id' => $id,
                    'name' => $vendor->get_shop_name() . '(' . $vendor->get_email() . ')'
                );
            }
        }

$response      = rest_ensure_response( $data );
        $response->add_links( $this->prepare_links( $object, $request ) );

return apply_filters( 'dokan_rest_prepare_announcement_object', $response, $object, $request );
    }

/**
     * Prepare links for the request.
     *
     * @param WC_Data         $object  Object data.
     * @param WP_REST_Request $request Request object.
     *
     * @return array                   Links for the given post.
     */
    protected function prepare_links( $object, $request ) {
        $links = array(
            'self' => array(
                'href' => rest_url( sprintf( '/%s/%s/%d', $this->namespace, $this->base, $object->ID ) ),
            ),
            'collection' => array(
                'href' => rest_url( sprintf( '/%s/%s', $this->namespace, $this->base ) ),
            ),
        );

return $links;
    }
}

[+] ..
[-] class-modules-controller.php [edit]
[-] class-coupon-controller.php [edit]
[-] class-announcement-controller.php [edit]
[-] class-product-variation-controller.php [edit]
[-] class-store-controller.php [edit]
[-] class-refund-controller.php [edit]
[-] class-reviews-controller.php [edit]
[-] class-reports-controller.php [edit]