<?php
/*
** Job Arranger Manager
** Copyright (C) 2023 Daiwa Institute of Research Ltd. All Rights Reserved.
**
** Licensed to the Apache Software Foundation (ASF) under one or more
** contributor license agreements. See the NOTICE file distributed with
** this work for additional information regarding copyright ownership.
** The ASF licenses this file to you under the Apache License, Version 2.0
** (the "License"); you may not use this file except in compliance with
** the License. You may obtain a copy of the License at
**
** http://www.apache.org/licenses/LICENSE-2.0
**
** Unless required by applicable law or agreed to in writing, software
** distributed under the License is distributed on an "AS IS" BASIS,
** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
** See the License for the specific language governing permissions and
** limitations under the License.
**
**/

namespace App\Services;

use App\Utils\Service;
use App\Utils\Core;
use App\Utils\Constants;
use App\Services\ObjectDetailService;
use App\Models\ObjectLockModel;
use App\Models\CalendarModel;
use App\Models\FilterModel;
use App\Models\JobnetModel;
use App\Models\ScheduleModel;
use App\Models\UserModel;
use App\Utils\Util;
use Datetime, DateInterval;
use PDOException;

/**
 * This service is used to manage the object lock services.
 *
 * @version    6.1.0
 * @since      Class available since version 6.1.0
 */
class ObjectLockService extends Service
{


    /**
     * @var \App\Services\ObjectDetailService
     */
    private $objectDetailService;
    /**
     * @var ObjectLockModel
     */
    private $objectLockModel;
    /**
     * @var CalendarModel
     */
    private $calendarModel;
    /**
     * @var FilterModel
     */
    private $filterModel;
    /**
     * @var ScheduleModel
     */
    private $scheduleModel;
    /**
     * @var JobnetModel
     */
    private $jobnetModel;
    /**
     * @var UserModel
     */
    private $userModel;
    protected $logger;

    public function __construct()
    {
        parent::__construct();
        $this->logger = Core::logger();
        $this->objectDetailService = new ObjectDetailService();
        $this->objectLockModel = new ObjectLockModel();
        $this->calendarModel = new CalendarModel();
        $this->filterModel = new FilterModel();
        $this->scheduleModel = new ScheduleModel();
        $this->jobnetModel = new JobnetModel();
        $this->userModel = new UserModel();
        $this->util = new Util();
    }

    public function getClientIpAddress()
    {
        if (!empty($_SERVER["HTTP_CLIENT_IP"])) {
            $ip = $_SERVER["HTTP_CLIENT_IP"];
        } elseif (!empty($_SERVER["HTTP_X_FORWARDED_FOR"])) {
            $ip = $_SERVER["HTTP_X_FORWARDED_FOR"];
        } else {
            $ip = $_SERVER["REMOTE_ADDR"];
        }
        return $ip;
    }
    /**
     * It checks whether or not current login user got permission for the object
     *
     * @param   object $detail   detail information of object.
     * @param   string $action   type of the action. "VALID" or "DEL"
     * @param   int    $type     type of object
     * @throws  PDOException
     * @return  bool 
     * @since   Method available since version 6.1.0
     */
    public function isValid($detail, $action, $type = null)
    {
        $this->logger->info('Check editable service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
        try {
            $this->logger->info('#3805 => start working [isValid method of objectLockService]');
            $this->logger->info('#3805 => details in [isValid method of objectLockService] : '. print_r($detail, true));
            $this->logger->info('#3805 => action in [isValid method of objectLockService] : '. print_r($action, true));
            $this->logger->info('#3805 => type in [isValid method of objectLockService] : '. print_r($type, true));
            if (Constants::OBJECT_TYPE_SCHEDULE == $type) {
                $username = $detail['userName'];
            } else {
                $username = $detail->user_name;
            }
            $this->logger->info('#3805 => user name in [isValid method of objectLockService] : '. print_r($user_name, true));
            $objectUserGroupList = $this->userModel->getGroupIDListByAlias($username);
            $this->logger->info('#3805 => object User Group List in [isValid method of objectLockService]/ user owned object/ : '. print_r($objectUserGroupList, true));
            $userGroupList = $_SESSION['userInfo']['groupList'];
            $this->logger->info('#3805 => user Group List in [isValid method of objectLockService]/ session user/ : '. print_r($userGroupList, true));
            $objectOwnType = Constants::OBJECT_USER_TYPE_OTHER;
            if ($this->userModel->isExistGroupId($userGroupList, $objectUserGroupList)) {
                $objectOwnType = Constants::OBJECT_USER_TYPE_OWN;
            }
            $this->logger->info('#3805 => object own type in [isValid method of objectLockService] : '. print_r($objectOwnType, true));
            $valid = true;
            $this->logger->info('#3805 => user Info in [isValid method of objectLockService] : '. print_r($_ESSSION['userInfo'], true));
            $this->logger->info('#3805 => user Type in [isValid method of objectLockService] : '. print_r($_SESSION['userInfo']['userType'], true));
            if ($_SESSION['userInfo']['userType'] == Constants::USER_TYPE_GENERAL) {
                $this->logger->info('#3805 => this is first condition in [isValid method of objectLockService].');
                $valid = false;
            } else if ($_SESSION['userInfo']['userType'] != Constants::USER_TYPE_SUPER && $objectOwnType == Constants::OBJECT_USER_TYPE_OTHER && $action == Constants::OBJ_VALID_PROC) {
                $this->logger->info('#3805 => this is first condition in [isValid method of objectLockService].');
                $valid = false;
            } else if ($_SESSION['userInfo']['userType'] != Constants::USER_TYPE_ADMIN && $_SESSION['userInfo']['userType'] != Constants::USER_TYPE_SUPER && $objectOwnType == Constants::OBJECT_USER_TYPE_OTHER && $action == Constants::OBJ_DELETE_PROC) {
                $this->logger->info('#3805 => user Type is user role in [isValid method of objectLockService].');
                $valid = false;
            }
            return $valid;
        } catch (PDOException $e) {
            $this->logger->info('#3805 => PDOException in [isValid method of ObjectLockService]: ' . $e->getMessage());
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
    }

    /**
     * It checks object is editable or not.
     *
     * @param   object $detail  detail information of object.
     * @param   int    $type    type of object
     * @param   bool   $version
     * @throws  PDOException
     * @return  string $editable
     * @since   Method available since version 6.1.0
     */
    public function isEditable($detail, $type, $version = false): String
    {
        $this->logger->debug('Check editable service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
        try {
            if (Constants::OBJECT_TYPE_SCHEDULE == $type) {
                $detail = $detail[0];
                $validFlag = $detail['validFlag'];
                $objectUserGroupList = $this->userModel->getGroupIDListByAlias($detail['userName']);
            } else {
                $validFlag = $detail->valid_flag;
                $objectUserGroupList = $this->userModel->getGroupIDListByAlias($detail->user_name);
            }

            $userGroupList = $_SESSION['userInfo']['groupList'];
            $editable =  Constants::SERVICE_MESSAGE_UNEDITABLE;

            $objectOwnType = Constants::OBJECT_USER_TYPE_OTHER;
            if ($this->userModel->isExistGroupId($userGroupList, $objectUserGroupList)) {
                $objectOwnType = Constants::OBJECT_USER_TYPE_OWN;
            }
            if ($_SESSION['userInfo']['userType'] == Constants::USER_TYPE_SUPER || ($objectOwnType == Constants::OBJECT_USER_TYPE_OWN && $_SESSION['userInfo']['userType'] == Constants::USER_TYPE_ADMIN)) {
                if ($version) {
                    $editable = Constants::SERVICE_MESSAGE_EDITABLE;
                } else {
                    if ($validFlag == 0) {
                        $editable = Constants::SERVICE_MESSAGE_EDITABLE;
                    }
                }
            }
            return $editable;
        } catch (PDOException $e) {
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
    }

    /**
     * It checks object is editable or not for editing.
     *
     * @param   object $data  object info.
     * @param   string $type  
     * @throws  PDOException
     * @return  string|array  could be array if editable, could be string if uneditable
     * @since   Method available since version 6.1.0
     */
    public function process($data, $type, $version = false): String
    {
        $this->logger->debug($type . ' service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
        $detail = $this->objectDetailService->getSingleObject($data->objectId, $data->objectType, null);
        if ($detail == Constants::SERVICE_MESSAGE_ITEM_NOT_FOUND) {
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
        $isEditable = $this->isEditable($detail, $data->objectType, $version);
        if ($isEditable != Constants::SERVICE_MESSAGE_EDITABLE) {
            $this->logger->debug('Object is not editable.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
            return $isEditable;
        }

        $this->logger->debug('Object is editable.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);

        try {

            $checkWhere = "object_id = '$data->objectId' AND object_type = $data->objectType";
            $checkResult = $this->objectLockModel->checkObjectLock($checkWhere);
            if ($checkResult) {
                if ($checkResult->username == $_SESSION['userInfo']['userName'] && $checkResult->attempt_ip == $data->attemptIp) {
                    //Lock user is same
                    $this->logger->info(Constants::SERVICE_MESSAGE_OBJ_LOCK_USER_SAME, ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
                    return Constants::SERVICE_MESSAGE_OBJ_LOCK_USER_SAME;
                }
                $this->logger->info(Constants::SERVICE_MESSAGE_OBJ_LOCK_BY_OTHERS, ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
                return Constants::SERVICE_MESSAGE_OBJ_LOCK_BY_OTHERS;

            } else {
                //Object is not locked.
                if ($type == Constants::SERVICE_TYPE_LOCK) {
                    return $this->lockObject($data);
                } else {
                    $this->logger->info(Constants::SERVICE_MESSAGE_OBJ_NOT_LOCK, ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
                    return Constants::SERVICE_MESSAGE_OBJ_NOT_LOCK;
                }
            }
        } catch (PDOException $e) {
            $this->logger->info(Constants::SERVICE_INTERNAL_SERVER_ERROR, ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
    }


    /**
     * It locks for editing object.
     *
     * @param   object $data   data of object to lock.
     * @throws  PDOException
     * @return  string fail or success message for lock process
     * @since   Method available since version 6.1.0
     */
    public function lockObject($data): String
    {
        $this->logger->debug('Lock object service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
        $createdDate = time();
        $objectData = [
            'object_id' => $data->objectId,
            'object_type' =>  $data->objectType,
            'username' => $_SESSION['userInfo']['userName'],
            'attempt_ip' => $data->attemptIp,
            'created_date' => $createdDate,
            'last_active_time' => $createdDate,
        ];

        try {
            if ($this->objectLockModel->insertObjectLock($objectData)) {
                return Constants::SERVICE_MESSAGE_SUCCESS;
            } else {
                return Constants::SERVICE_MESSAGE_FAIL;
            }
        } catch (PDOException $e) {
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
    }

    /**
     * It retrieves locked object lists.
     *
     * @throws  PDOException
     * @return  array|string could be array if success, could be string if fail
     * @since   Method available since version 6.1.0
     */
    // public function init()
    // {
    //     $this->logger->debug('Init service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
    //     try {
    //         $data = $this->objectLockModel->getData();
    //         if ($data) {
    //             return $data;
    //         } else {
    //             $this->logger->error('Object init data is not found.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
    //             return Constants::SERVICE_MESSAGE_FAIL;
    //         }
    //     } catch (PDOException $e) {
    //         return Constants::SERVICE_INTERNAL_SERVER_ERROR;
    //     }
    // }

    /**
     * It retrieves all locked object lists on search data.
     *
     * @param   array $para
     * @throws  PDOException
     * @return  array|string could be array if success, could be string if fail
     * @since   Method available since version 6.1.0
     */
    // public function lazySearch($para)
    // {
    //     $this->logger->debug('Object lock lazy search service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
    //     $sort = $para['sort'];
    //     $limit = $para['limit'];
    //     $searchArr = $para['whereArr'];

    //     $search = "";
    //     if ($searchArr[0] !== "") {
    //         $search = $search . "username LIKE '%" . $searchArr[0] . "%'" . " and";
    //     }
    //     if ($searchArr[1] !== "") {
    //         $search = $search  . " object_id LIKE '%" . $searchArr[1] . "%'" . " and";
    //     }
    //     if ($searchArr[2] !== "") {
    //         $search = $search . " object_type LIKE " . $searchArr[2] . " and";
    //     }

    //     try {
    //         return $this->objectLockModel->searchLockData($sort, $limit, $search);
    //     } catch (PDOException $e) {
    //         return Constants::SERVICE_INTERNAL_SERVER_ERROR;
    //     }
    // }

    /**
     * It deletes locked object.
     *
     * @param   object $data   data of locked object.
     * @throws  PDOException
     * @return  string fail or success message for unlock process
     * @since   Method available since version 6.1.0
     */
    public function deleteLockObject($data): String
    {
        $this->logger->debug('Delete lock service is started.', ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
        try {
            $deleteWhere = "object_id = '$data->objectId' AND object_type = $data->objectType";
            if ($this->objectLockModel->deleteObjectLock($deleteWhere)) {
                return Constants::SERVICE_MESSAGE_SUCCESS;
            } else {
                return Constants::SERVICE_MESSAGE_FAIL;
                $this->logger->debug('Object lock delete failed. id:' . $data->objectId, ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
            }
        } catch (PDOException $e) {
            $this->logger->error($e->getMessage(), ['controller' => __METHOD__, 'user' => $_SESSION['userInfo']['userName']]);
            return Constants::SERVICE_INTERNAL_SERVER_ERROR;
        }
    }
}