iranianpep/code-jetter

<?php

namespace CodeJetter\components\user\mappers;

use CodeJetter\core\database\BaseXrefMapper;
use CodeJetter\core\io\Input;
use CodeJetter\core\io\Output;
use CodeJetter\core\security\Validator;
use CodeJetter\core\security\ValidatorRule;

/**
 * Class GroupUserXrefMapper.
 */
abstract class GroupUserXrefMapper extends BaseXrefMapper
{
    /**
     * @param array $inputs
     *
     * @throws \Exception
     *
     * @return Output
     */
    public function add(array $inputs, array $fieldsValues = [], $extraDefinedInputs = [])
    {
        /**
         * Start validating.
         */
        $output = new Output();
        try {
            $requiredRule = new ValidatorRule('required');
            $idRule = new ValidatorRule('id');

            $groupIdInput = new Input('groupId', [$requiredRule, $idRule]);
            $memberIdInput = new Input('memberId', [$requiredRule, $idRule]);

            $validator = new Validator(
                [$groupIdInput, $memberIdInput],
                $inputs
            );

            $validatorOutput = $validator->validate();

            if ($validatorOutput->getSuccess() !== true) {
                $output->setSuccess(false);
                $output->setMessages($validatorOutput->getMessages());

                return $output;
            }
        } catch (\Exception $e) {
            (new \CodeJetter\core\ErrorHandler())->logError($e);
        }
        /**
         * Finish validating.
         */
        $fieldsValues = [
            [
                'column' => 'groupId',
                'value'  => $inputs['groupId'],
                'type'   => \PDO::PARAM_INT,
            ],
            [
                'column' => 'memberId',
                'value'  => $inputs['memberId'],
                'type'   => \PDO::PARAM_INT,
            ],
        ];

        $insertedId = $this->insertOne($fieldsValues);

        if (!empty($insertedId) && is_numeric($insertedId) && (int) $insertedId > 0) {
            $output->setSuccess(true);
            $output->setMessage('Group member xref added successfully');
            $output->setData($insertedId);
        } else {
            $output->setSuccess(false);
        }

        return $output;
    }

    /**
     * @param array $inputs
     *
     * @throws \Exception
     */
    public function batchAdd(array $inputs)
    {
        $fieldsValuesCollection = [];

        foreach ($inputs as $input) {
            $fieldsValuesCollection[] = [
                [
                    'column' => 'groupId',
                    'value'  => $input['groupId'],
                    'type'   => \PDO::PARAM_INT,
                ],
                [
                    'column' => 'memberId',
                    'value'  => $input['memberId'],
                    'type'   => \PDO::PARAM_INT,
                ],
            ];
        }

        $this->batchInsert($fieldsValuesCollection);
    }
}