SimpleCMS\DynamicUnit\Packages\DynamicQuery

Complexity

Total Complexity

39

Size/Duplication

Total Lines	164
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	7	2
A	addItems()	0	5	5
A	create()	0	10	2
A	pullFile()	0	6	4
A	createOrUpdateAttribute()	0	6	3
A	removeUnderId()	0	6	3
A	updateItems()	0	6	5
A	convertModel()	0	3	2
A	update()	0	15	4
A	getFileSql()	0	10	2
A	convertUnitSql()	0	8	1
A	convertSql()	0	16	5
A	convertAttributeSql()	0	9	1

<?php
namespace SimpleCMS\DynamicUnit\Packages;

use Illuminate\Http\UploadedFile;
use Illuminate\Support\Collection;
use SimpleCMS\DynamicUnit\Models\DynamicAttribute;
use SimpleCMS\DynamicUnit\Models\DynamicUnit as DynamicUnitModel;

/**
 * 操作类
 *
 * @author Dennis Lui <hackout@vip.qq.com>
 */
class DynamicQuery
{

    /**
     * 删除动作
     *
     * @author Dennis Lui <hackout@vip.qq.com>
     * @param  int $id
     * @param  string $type
     * @return bool
     */
    public static function delete(int $id, string $type): bool
    {
        $model = self::convertModel($type);
        if (!$item = $model::find($id)) {
            return false;
        }
        return $item->delete();
    }

    /**
     * 添加动作
     *
     * @author Dennis Lui <hackout@vip.qq.com>
     * @param  array $data
     * @return bool
     */
    public static function create(array $data, string $type): bool
    {
        $model = self::convertModel($type);
        list($sql, $file) = self::getFileSql($data, $type);
        $item = $model::create($sql);
        if ($file) {
            $item->addMedia($file)->toMediaCollection($model::MEDIA_FILE);
        }
        self::addItems($data, $type, $item);
        return !empty($item);
    }

    private static function addItems(array $data, string $type = 'attribute', DynamicUnitModel $dynamicUnit): void
    {
        if ($type == 'unit' && array_key_exists('items', $data) && $data['items']) {
            foreach ($data['items'] as $rs) {
                self::create(array_merge(['dynamic_unit_id' => $dynamicUnit->id], $rs), 'attribute');
            }
        }
    }

    private static function updateItems(array $data, string $type = 'attribute', DynamicUnitModel $dynamicUnit): void
    {
        if ($type == 'unit' && array_key_exists('items', $data) && $data['items']) {
            self::removeUnderId($dynamicUnit, $data['items']);
            foreach ($data['items'] as $rs) {
                self::createOrUpdateAttribute($rs, $dynamicUnit);
            }
        }
    }

    private static function createOrUpdateAttribute(array $data, DynamicUnitModel $dynamicUnitModel)
    {
        if (array_key_exists('id', $data) && $data['id']) {
            self::update((int) $data['id'], array_merge(['dynamic_unit_id' => $dynamicUnitModel->id], $data), 'attribute');
        } else {
            self::create(array_merge(['dynamic_unit_id' => $dynamicUnitModel->id], $data), 'attribute');
        }
    }

    private static function getFileSql(array $data, string $type = 'attribute'): array
    {
        $file = null;
        if ($type == 'attribute') {
            $sql = self::convertAttributeSql($data);
            $file = self::pullFile($data);
        } else {
            $sql = self::convertUnitSql($data);
        }
        return [$sql, $file];
    }

    /**
     * 修改动作
     *
     * @author Dennis Lui <hackout@vip.qq.com>
     * @param  int $id
     * @param  array $data
     * @return bool
     */
    public static function update(int $id, array $data, string $type): bool
    {
        $model = self::convertModel($type);
        if (!$item = $model::find($id)) {
            return false;
        }
        list($sql, $file) = self::getFileSql($data, $type);
        $item->fill($sql);
        $result = $item->save();
        if ($file) {
            $item->media && $item->media->each(fn($media) => $media->delete());
            $item->addMedia($file)->toMediaCollection($model::MEDIA_FILE);
        }
        self::addItems($data, $type, $item);
        return $result;
    }

    private static function removeUnderId(DynamicUnitModel $item, array $array): void
    {
        $collection = new Collection($array);
        $idList = $collection->filter(fn($n) => isset ($n['id']) && !empty ($n['id']))->values()->pluck('id')->toArray();
        if ($idList) {
            $item->items()->whereNotIn('id', $idList)->delete();
        }
    }

    private static function convertModel(string $type)
    {
        return $type == 'attribute' ? DynamicAttribute::class : DynamicUnitModel::class;
    }


    private static function convertSql(array $data): array|bool
    {
        $sql = [];
        $map = array_merge([
            'file' => null,
            'id' => null,
            'name' => null,
            'code' => null
        ], $data);
        if (!$map['name'] && !$map['code'])
            return false;
        if ($map['name'])
            $sql['name'] = $map['name'];
        if ($map['code'])
            $sql['code'] = $map['code'];
        return [$sql, $map['file'], $map['id']];
    }

    private static function pullFile(array $data): null|UploadedFile
    {
        if (array_key_exists('file', $data) && $data['file']) {
            return $data['file'] instanceof UploadedFile ? $data['file'] : null;
        }
        return null;
    }

    private static function convertAttributeSql(array $data): array
    {
        $sql = array_merge([
            'dynamic_unit_id' => 0,
            'name' => null,
            'code' => null
        ], $data);
        $collection = new Collection($sql);
        return $collection->only(['dynamic_unit_id', 'name', 'code'])->toArray();
    }

    private static function convertUnitSql(array $data): array
    {
        $sql = array_merge([
            'name' => null,
            'code' => null
        ], $data);
        $collection = new Collection($sql);
        return $collection->only(['name', 'code'])->toArray();
    }
}