lib.php

<?php
/**
 * @package    enrol_idpay
 * @copyright  IDPay
 * @author     Mohammad Nabipour
 * @license    https://idpay.ir/
 */

defined('MOODLE_INTERNAL') || die();

class enrol_idpay_plugin extends enrol_plugin
{
    public const PAYMENT_CREATED = 'created';
    public const PAYMENT_FAILED = 'failed';
    public const PAYMENT_PENDING = 'pending';
    public const PAYMENT_SUCCESS = 'success';
    public const Mail_TO_STUDENT = 'STUDENT';
    public const Mail_TO_ADMIN = 'ADMIN';
    public const Mail_TO_TEACHER = 'TEACHER';

    private function doCheckout(stdClass $instance)
    {
        global $CFG, $USER, $OUTPUT, $PAGE, $DB;
        ob_start();

        $startDateCondition = $instance->enrolstartdate != 0 && $instance->enrolstartdate > time();
        $endDateCondition = $instance->enrolenddate != 0 && $instance->enrolenddate < time();
        $beforePaid = $DB->record_exists('user_enrolments', ['userid' => $USER->id, 'enrolid' => $instance->id]);

        if ($startDateCondition || $endDateCondition || $beforePaid) {
            return ob_get_clean();
        }

        $courseId = $instance->courseid;
        $course = $DB->get_record('course', ['id' => $courseId]);
        $context = context_course::instance($course->id);
        $cost = (int)$instance->cost <= 0 ? (int)$this->get_config('cost') : (int)$instance->cost;

        if ($cost >= 10000) {

            if (!isguestuser()) {
                $courseFullName = format_string($course->fullname, true, array('context' => $context));
                $courseShortName = format_string($course->shortname, true, array('context' => $context));
                $userFullName = fullname($USER);
                $userFirstName = $USER->firstname;
                $userLastName = $USER->lastname;
                $userAddress = $USER->address;
                $userCity = $USER->city;
                $instanceName = $this->get_instance_name($instance);

                $pluginInstance = new enrol_idpay_plugin();
                $currency = $pluginInstance->get_config('currency');
                $paymentUrl = "{$CFG->wwwroot}/enrol/idpay/request.php";
                $cancelUrl = "$CFG->wwwroot";

                $paymentRequiredTitle = get_string("paymentrequired");
                $paymentInstantTitle = get_string("paymentinstant");
                $costTitle = get_string("cost");
                $userTitle = get_string('user');
                $continueToCourseTitle = get_string('continuetocourse');
                $submitTitle = get_string("sendpaymentbutton", "enrol_idpay");

                echo "<div style='text-align: center'>";
                echo "<p>{$paymentRequiredTitle}</p>";
                echo "<p><b>{$instanceName}</b></p>";
                echo "<p><b>{$costTitle} : {$currency} {$cost}</b></p>";
                echo "<p>{$paymentInstantTitle}</p>";
                echo "<form action='{$paymentUrl}' method='post'>";
                echo "<input type='hidden' name='item_name' value='{$courseFullName}' />";
                echo "<input type='hidden' name='item_number' value='{$courseShortName}' />";
                echo "<input type='hidden' name='quantity' value='1' />";
                echo "<input type='hidden' name='on0' value='{$userTitle}' />";
                echo "<input type='hidden' name='os0' value='{$userFullName}' />";
                echo "<input type='hidden' name='course_id' value='{$course->id}' />";
                echo "<input type='hidden' name='instance_id' value='{$instance->id}' />";
                echo "<input type='hidden' name='amount' value='{$cost}' />";
                echo "<input type='hidden' name='cancel_return' value='{$cancelUrl}' />";
                echo "<input type='hidden' name='rm' value='2' />";
                echo "<input type='hidden' name='cbt' value='{$continueToCourseTitle}' />";
                echo "<input type='hidden' name='first_name' value='{$userFirstName}' />";
                echo "<input type='hidden' name='last_name' value='{$userLastName}' />";
                echo "<input type='hidden' name='address' value='{$userAddress}' />";
                echo "<input type='hidden' name='city' value='{$userCity}' />";
                echo "<input type='hidden' name='email' value='{$USER->email}' />";
                echo "<input type='hidden' name='country' value='{$USER->country}' />";
                echo "<input type='submit' value='{$submitTitle}' />";
                echo "</form>";
                echo "</div>";

            } else {
                $wwwroot = empty($CFG->loginhttps) ? $wwwroot = $CFG->wwwroot : str_replace("http://", "https://", $CFG->wwwroot);
                $text1 = get_string('paymentrequired');
                $text2 = get_string('cost');
                $text3 = get_string('loginsite');
                $urlLogin = "{$wwwroot}/login/";

                echo "<div class='mdl-align'><p>{$text1}</p>";
                echo "<p><b>{$text2} : {$instance->currency} {$cost}</b></p>";
                echo "<p><a href='{$urlLogin}'>{$text3}</a></p>";
                echo "</div>";
            }
        } else {
            $notSupportTitle = get_string('nocost', 'enrol_idpay');
            echo "<p>{$notSupportTitle}</p>";
        }
        return $OUTPUT->box(ob_get_clean());
    }

    public function doPayment(array $request)
    {
        global $_SESSION, $USER, $DB, $OUTPUT, $CFG;

        $_SESSION['courseid'] = $_POST['course_id'];
        $_SESSION['instanceid'] = $_POST['instance_id'];
        $_SESSION['totalcost'] = $_POST['amount'];
        $_SESSION['userid'] = $USER->id;

        $course_id = (int)$_POST['course_id'];
        $instance_id = $_POST['instance_id'];
        $api_key = $this->get_config('api_key');
        $sandbox = $this->get_config('sandbox');
        $amount = (int)$_POST['amount'];
        $mail = $USER->email;
        $callback = "{$CFG->wwwroot}/enrol/idpay/verify.php?course_id={$course_id}";
        $description = "Payment For Course : {$_POST['item_name']}";
        $phone = $USER->phone1;
        $user_name = "{$USER->firstname} {$USER->lastname}";
        $item_name = $_POST['item_name'];

        $data = new stdClass();
        $data->receiver_email = $mail;
        $data->receiver_id = $USER->id;
        $data->item_name = $item_name;
        $data->courseid = $course_id;
        $data->userid = $USER->id;
        $data->username = $user_name;
        $data->instanceid = $instance_id;
        $data->memo = "پرداخت امن با آیدی پی";
        $data->tax = "0";
        $data->payment_status = self::PAYMENT_CREATED;
        $data->pending_reason = 'Waiting For Token';
        $data->payment_type = 'IRR';
        $data->amount = $amount;
        $data->refnumber = '-';
        $data->idpay_id = '-';
        $data->log = "در انتظار دریافت توکن";

        $order_id = $DB->insert_record("enrol_idpay", $data);

        $params = array(
            'order_id' => $order_id,
            'amount' => $amount,
            'name' => $user_name,
            'phone' => $phone,
            'mail' => $mail,
            'desc' => $description,
            'callback' => $callback,
        );

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, 'https://api.idpay.ir/v1.1/payment');
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
            'Content-Type: application/json',
            'X-API-KEY:' . $api_key,
            'X-SANDBOX:' . $sandbox
        ));

        $result = curl_exec($ch);
        $result = json_decode($result);
        $http_status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($http_status != 201 || empty($result) || empty($result->id) || empty($result->link)) {
            $msg = sprintf('خطا هنگام ایجاد تراکنش. وضعیت خطا: %s - کد خطا: %s - پیام خطا: %s', $http_status, $result->error_code, $result->error_message);
            $url = $CFG->wwwroot . '/enrol/index.php?id=' . $_POST['course_id'];

            $this->orderUpdate($order_id, 'Can Not Create Transaction', self::PAYMENT_FAILED, $msg);

            echo $OUTPUT->header();
            echo '<h3 dir="rtl" style="text-align:center; color: red;">' . $msg . '</h3>';
            echo '<div class="single_button" style="text-align:center;">';
            echo "<a href='{$url}'>";
            echo '<button> بازگشت به صفحه قبلی  </button></a></div>';
            echo $OUTPUT->footer();
            exit;

        } else {

            $this->orderUpdate($order_id, 'Redirected To IPG', self::PAYMENT_PENDING, 'انتقال به درگاه', $result->id);
            Header("Location: $result->link");
            exit;
        }

    }

    /**
     * @throws dml_exception
     * @throws coding_exception
     */
    public function doCallback(array $request)
    {
        global $CFG, $_SESSION, $DB;

        $status = $request['status'];
        $orderId = $request['order_id'];
        $transId = $request['id'];
        $trackId = $request['track_id'];

        $order = $DB->get_record('enrol_idpay', ['id' => $orderId]);

        $validation = [
            $status,
            $orderId,
            $transId,
            $trackId,
            $order,
        ];

        if ($this->isOnceEmpty($validation)) {
            $msg = $this->getTranslateMessage();
            $this->orderUpdate($orderId, "Empty Data", self::PAYMENT_FAILED, $msg, $transId);
            return '<div style="color:red;direction:rtl; text-align:right">' . $msg . '<br/></div>';
        } elseif ($status != '10') {
            $msg = $this->getTranslateMessage($status);
            $this->orderUpdate($orderId, "Incorrect Status Success : {$status}", self::PAYMENT_FAILED, $msg, $transId);
            return '<div style="color:red;direction:rtl; text-align:right">' . $msg . '<br/></div>';
        } elseif ($this->isNotDoubleSpending($order, $transId) || $order->payment_status != self::PAYMENT_PENDING) {
            $msg = $this->getTranslateMessage('0');
            $this->orderUpdate($orderId, "DoubleSpending", self::PAYMENT_FAILED, $msg, $transId);
            return '<div style="color:red;direction:rtl; text-align:right">' . $msg . '<br/></div>';
        }

        $api_key = $this->get_config('api_key');
        $sandbox = $this->get_config('sandbox');
        $params = [
            'id' => $transId,
            'order_id' => $orderId
        ];

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, 'https://api.idpay.ir/v1.1/payment/verify');
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
            'Content-Type: application/json',
            'X-API-KEY:' . $api_key,
            'X-SANDBOX: ' . $sandbox,
        ));
        $result = curl_exec($ch);
        $result = json_decode($result);
        $http_status = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if ($http_status != 200) {
            $msg = sprintf('خطا هنگام ایجاد تراکنش. وضعیت خطا: %s - کد خطا: %s - پیام خطا: %s', $http_status, $result->error_code, $result->error_message);
            $this->orderUpdate($orderId, "Cant Create Verify Transaction", self::PAYMENT_FAILED, $msg, $transId);
            return '<div style="color:red; direction:rtl; text-align:right">' . $msg . '<br/></div>';

        } else {

            $verify_status = empty($result->status) ? NULL : $result->status;
            $verify_track_id = empty($result->track_id) ? NULL : $result->track_id;
            $verify_order_id = empty($result->order_id) ? NULL : $result->order_id;
            $verify_amount = empty($result->amount) ? NULL : $result->amount;

            $user = $DB->get_record("user", ["id" => $order->userid]);
            $course = $DB->get_record("course", ["id" => $order->courseid]);
            $courseContext = context_course::instance($course->id, IGNORE_MISSING);
            $enrol = $DB->get_record("enrol", ["id" => $order->instanceid, "status" => 0]);

            if ($verify_status < 100 || empty($verify_status) || empty($verify_track_id) || empty($verify_amount) || empty($verify_order_id)) {
                $msg = $this->getTranslateMessage();
                $this->orderUpdate($orderId, "Empty Verify Transaction", self::PAYMENT_FAILED, $msg, $transId);
                return '<div style="color:red; direction:rtl; text-align:right">' . $msg . '<br/></div>';
            } elseif (empty($user) || empty($course) || empty($courseContext) || empty($enrol)) {
                $msg = $this->getTranslateMessage();
                $this->orderUpdate($orderId, "Incorrect Or Not Exist User Or Course Or Enrol", self::PAYMENT_FAILED, $msg, $transId);
                return '<div style="color:red; direction:rtl; text-align:right">' . $msg . '<br/></div>';
            } else {
                $msg = $this->getTranslateMessage($verify_status);
                $this->orderUpdate($orderId, "Complete Transaction", self::PAYMENT_SUCCESS, $msg, $transId);

                $startDate = 0;
                $endDate = 0;
                if (!empty($this->get_config('enrolperiod'))) {
                    $startDate = time();
                    $endDate = $startDate + $this->get_config('enrolperiod');
                }

                $this->enrol_user($enrol, $user->id, $enrol->roleid, $startDate, $endDate);

                if ($users = get_users_by_capability($courseContext, 'moodle/course:update', 'u.*', 'u.id ASC', '', '', '', '', false, true)) {
                    $users = sort_by_roleassignment_authority($users, $courseContext);
                    $teacher = array_shift($users);
                } else {
                    $teacher = false;
                }

                $mailStudents = !empty($this->get_config('mailstudents')) ? (array) $this->get_config('mailstudents') : [];
                $userFromStudents = empty($teacher) ? core_user::get_noreply_user() : $teacher ;
                $userToStudents = $user ;
                $this->sendMail($mailStudents, self::Mail_TO_STUDENT,$course,$userFromStudents,$userToStudents);

                $mailAdmins = !empty($this->get_config('mailadmins')) ? get_admins() : [];
                $userFromAdmins = $user;
                $userToAdmins = $user ;
                $this->sendMail($mailAdmins, self::Mail_TO_ADMIN,$course,$userFromAdmins,$userToAdmins);

                $mailTeachers = !empty($this->get_config('mailteachers')) ? $this->get_config('mailteachers') : [];
                $userFromTeachers = $user;
                $userToTeachers = $teacher ;
                $this->sendMail($mailTeachers, self::Mail_TO_TEACHER,$course,$userFromTeachers,$userToTeachers);

                $result ='<div>';
                $result .= '<h3 style="text-align:center; color: green;">با تشکر از شما، پرداخت شما با موفقیت انجام شد و به  درس انتخاب شده افزوده شدید.</h3>';
                $result .= "<h3 style='text-align:center; color: green;'>کد پیگیری :  $verify_track_id  </h3>";
                $result .= '<div class="single_button" style="text-align:center;">';
                $result .='<a href="' . $CFG->wwwroot . '/course/view.php?id=' . $course->id . '"><button>ورود به درس خریداری شده</button></a>';
                $result .='</div>';
                return $result;
            }

        }
    }

    public function sendMail($members, $type, $course, $userFrom,$userToStudents)
    {
        if (empty($members)) return null;
        $courseContext = context_course::instance($course->id, IGNORE_MISSING);
        $shortname = format_string($course->shortname, true, array('context' => $courseContext));

        foreach ($members as $member) {
            $eventdata = new \core\message\message();
            $eventdata->courseid = $course->id;
            $eventdata->modulename = 'moodle';
            $eventdata->component = 'enrol_idpay';
            $eventdata->name = 'idpay_enrolment';
            $eventdata->subject = get_string("enrolmentnew", 'enrol', $shortname);
            $eventdata->fullmessageformat = FORMAT_PLAIN;
            $eventdata->fullmessagehtml = '';
            $eventdata->smallmessage = '';
            $eventdata->userfrom = $userFrom;
            $eventdata->userto = $type == self::Mail_TO_ADMIN ?  $member:  $userToStudents;
            message_send($eventdata);

        }
    }

    public function orderUpdate($orderId, $reason, $status, $log, $transactionId = null, $refNumber = null)
    {
        global $DB;
        $data = $DB->get_record('enrol_idpay', ['id' => $orderId]);
        $data->idpay_id = $transactionId ?? '-';
        $data->refnumber = $refNumber ?? '-';
        $data->pending_reason = $reason;
        $data->payment_status = $status;
        $data->log = $log;
        $data->timeupdated = time();
        $DB->update_record('enrol_idpay', $data);
    }

    public function isOnceEmpty(array $variables): bool
    {
        foreach ($variables as $variable) {
            if (empty($variable)) {
                return true;
            }
        }

        return false;
    }

    public function isNotDoubleSpending($order, $callbackTransaction)
    {
        return $order->idpay_id != $callbackTransaction;
    }

    public function getTranslateMessage($msgNumber = null)
    {
        switch ($msgNumber) {
            case "1":
                $msg = "پرداخت انجام نشده است";
                break;
            case "2":
                $msg = "پرداخت ناموفق بوده است";
                break;
            case "3":
                $msg = "خطا رخ داده است";
                break;
            case "4":
                $msg = "بلوکه شده";
                break;
            case "5":
                $msg = "برگشت به پرداخت کننده";
                break;
            case "6":
                $msg = "برگشت خورده سیستمی";
                break;
            case "7":
                $msg = "انصراف از پرداخت";
                break;
            case "8":
                $msg = "به درگاه پرداخت منتقل شد";
                break;
            case "10":
                $msg = "در انتظار تایید پرداخت";
                break;
            case "100":
                $msg = "پرداخت تایید شده است";
                break;
            case "101":
                $msg = "پرداخت قبلا تایید شده است";
                break;
            case "200":
                $msg = "به دریافت کننده واریز شد";
                break;
            case "0":
                $msg = "سواستفاده از تراکنش قبلی";
                break;
            case "404":
                $msg = "واحد پول انتخاب شده پشتیبانی نمی شود.";
                $msgNumber = '404';
                break;
            case "405":
                $msg = "کاربر از انجام تراکنش منصرف شده است.";
                $msgNumber = '404';
                break;
            case "1000":
                $msg = "خطا دور از انتظار";
                $msgNumber = '404';
                break;
            case null:
                $msg = "خطا دور از انتظار";
                $msgNumber = '1000';
                break;
        }

        return $msg . ' -وضعیت: ' . "$msgNumber";

    }

    private function getThumbnailImage(array $instances): array
    {
        $found = false;
        foreach ($instances as $instance) {
            $startDateCondition = $instance->enrolstartdate != 0 && $instance->enrolstartdate > time();
            $endDateCondition = $instance->enrolenddate != 0 && $instance->enrolenddate < time();
            if ($startDateCondition || $endDateCondition) {
                continue;
            }
            $found = true;
            break;
        }
        if ($found) {
            $title = get_string('pluginname', 'enrol_idpay');
            $pixIcon = new pix_icon('icon', $title, 'enrol_idpay', ['class' => 'iconsize-big']);
            return [$pixIcon];
        }
        return [];
    }


    /* ------------------------------- Built In Func----------------------------------- */
    public function get_info_icons(array $instances)
    {
        return $this->getThumbnailImage($instances);
    }

    public function enrol_page_hook(stdClass $instance)
    {
        return $this->doCheckout($instance);
    }

    public function allow_manage(stdClass $instance)
    {
        return true;
    }

    public function allow_unenrol(stdClass $instance)
    {
        return true;
    }

    public function roles_protected()
    {
        return false;
    }

    public function show_enrolme_link(stdClass $instance)
    {
        return ($instance->status == ENROL_INSTANCE_ENABLED);
    }

    public function can_delete_instance($instance)
    {
        $context = context_course::instance($instance->courseid);
        return has_capability('enrol/idpay:config', $context);
    }

    public function can_hide_show_instance($instance)
    {
        $context = context_course::instance($instance->courseid);
        return has_capability('enrol/idpay:config', $context);
    }

    public function get_newinstance_link($courseid)
    {
        $context = context_course::instance($courseid, MUST_EXIST);
        if (!has_capability('moodle/course:enrolconfig', $context) or !has_capability('enrol/idpay:config', $context)) {
            return NULL;
        }
        return new moodle_url('/enrol/idpay/edit.php', array('courseid' => $courseid));
    }

    public function add_course_navigation($instancesnode, stdClass $instance)
    {
        if ($instance->enrol !== 'idpay') {
            throw new coding_exception('Invalid enrol instance type!');
        }

        $context = context_course::instance($instance->courseid);
        if (has_capability('enrol/idpay:config', $context)) {
            $managelink = new moodle_url('/enrol/idpay/edit.php', ['courseid' => $instance->courseid, 'id' => $instance->id]);
            $instancesnode->add($this->get_instance_name($instance), $managelink, navigation_node::TYPE_SETTING);
        }
    }

    public function get_action_icons(stdClass $instance)
    {
        global $OUTPUT;

        if ($instance->enrol !== 'idpay') {
            throw new coding_exception('invalid enrol instance!');
        }
        $context = context_course::instance($instance->courseid);

        $icons = array();

        if (has_capability('enrol/idpay:config', $context)) {
            $editlink = new moodle_url("/enrol/idpay/edit.php", array('courseid' => $instance->courseid, 'id' => $instance->id));
            $icons[] = $OUTPUT->action_icon($editlink, new pix_icon('t/edit', get_string('edit'), 'core',
                array('class' => 'iconsmall')));
        }

        return $icons;
    }

    /* ---------------------------------------- Not Refactor ----------------------------------------------------- */

    public function restore_instance(restore_enrolments_structure_step $step, stdClass $data, $course, $oldid)
    {
        global $DB;
        if ($step->get_task()->get_target() == backup::TARGET_NEW_COURSE) {
            $merge = false;
        } else {
            $merge = array(
                'courseid' => $data->courseid,
                'enrol' => $this->get_name(),
                'roleid' => $data->roleid,
                'cost' => $data->cost,
                'currency' => $data->currency,
            );
        }
        if ($merge and $instances = $DB->get_records('enrol', $merge, 'id')) {
            $instance = reset($instances);
            $instanceid = $instance->id;
        } else {
            $instanceid = $this->add_instance($course, (array)$data);
        }
        $step->set_mapping('enrol', $oldid, $instanceid);
    }

    public function restore_user_enrolment(restore_enrolments_structure_step $step, $data, $instance, $userid, $oldinstancestatus)
    {
        $this->enrol_user($instance, $userid, null, $data->timestart, $data->timeend, $data->status);
    }

    public function get_user_enrolment_actions(course_enrolment_manager $manager, $ue)
    {
        $actions = array();
        $context = $manager->get_context();
        $instance = $ue->enrolmentinstance;
        $params = $manager->get_moodlepage()->url->params();
        $params['ue'] = $ue->id;
        if ($this->allow_unenrol($instance) && has_capability("enrol/idpay:unenrol", $context)) {
            $url = new moodle_url('/enrol/unenroluser.php', $params);
            $actions[] = new user_enrolment_action(new pix_icon('t/delete', ''), get_string('unenrol', 'enrol'), $url, array('class' => 'unenrollink', 'rel' => $ue->id));
        }
        if ($this->allow_manage($instance) && has_capability("enrol/idpay:manage", $context)) {
            $url = new moodle_url('/enrol/editenrolment.php', $params);
            $actions[] = new user_enrolment_action(new pix_icon('t/edit', ''), get_string('edit'), $url, array('class' => 'editenrollink', 'rel' => $ue->id));
        }
        return $actions;
    }

    public function cron()
    {
        $trace = new text_progress_trace();
        $this->process_expirations($trace);
    }

    public function sync(progress_trace $trace): int
    {
        $this->process_expirations($trace);
        return 0;
    }

}