live_product_api/app/model/system/Attachment.php

<?php
namespace app\model\system;

use library\traits\ModelTrait;
use library\basic\BaseModel;

/**
 * 文件检验model
 * Class SystemFile
 * @package app\models\system
 */
class Attachment extends BaseModel
{

    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'att_id';

    /**
     * 模型名称
     * @var string
     */
    protected $name = 'attachment';

    use ModelTrait;

    /**
     * TODO 添加附件记录
     * @param $name
     * @param $att_size
     * @param $att_type
     * @param $att_dir
     * @param string $satt_dir
     * @param int $pid
     * @param int $imageType
     * @param int $time
     * @return Attachment
     */
    public static function attachmentAdd($name, $att_size, $att_type, $att_dir, $satt_dir = '', $pid = 0, $imageType = 1, $time = 0, $module_type = 1, $mer_id = '')
    {
        $data['name'] = $name;
        $data['att_dir'] = $att_dir;
        $data['satt_dir'] = $satt_dir;
        $data['att_size'] = $att_size;
        $data['att_type'] = $att_type;
        $data['image_type'] = $imageType;
        $data['module_type'] = $module_type;
        $data['time'] = $time ? $time : time();
        $data['pid'] = $pid;
        $data['mer_id'] = $mer_id;
        return self::create($data);
    }

    /**
     * TODO 获取分类图
     * @param $id
     * @return array
     */
    public static function getAll($id)
    {
        $model = new self;
        $where['pid'] = $id;
        $where['module_type'] = 1;
        $model->where($where)->order('att_id desc');
        return $model->page($model, $where, '', 24);
    }

    /** 获取图片列表
     * @param $where
     * @return array
     */
    public static function getImageList($where)
    {
        $model = new self;
        $model = $model->where('module_type', 1);
        if (isset($where['pid']) && $where['pid']) $model = $model->where('pid', $where['pid']);
        if (isset($where['mer_id']) && $where['mer_id'] != '') $model = $model->where('mer_id', $where['mer_id']);
        $model = $model->page((int)$where['page'], (int)$where['limit']);
        $model = $model->order('att_id desc,time desc');
        $list = $model->select();
        $list = count($list) ? $list->toArray() : [];
        $site_url = config('app')['API_URL'];
        foreach ($list as &$item) {
            if ($site_url) {
                $item['satt_dir'] = (strpos($item['satt_dir'], $site_url) !== false || strstr($item['satt_dir'], 'http') !== false) ? $item['satt_dir'] : $site_url . $item['satt_dir'];
                $item['att_dir'] = (strpos($item['att_dir'], $site_url) !== false || strstr($item['att_dir'], 'http') !== false) ? $item['satt_dir'] : $site_url . $item['att_dir'];
            }
        }
        if (isset($where['pid']) && $where['pid']) $map[] = ['pid', '=', $where['pid']];
        $map[] = ['module_type', '=', 1];
        if (isset($where['mer_id']) && $where['mer_id']) $map[] = ['mer_id', '=', $where['mer_id']];
        $count = self::where($map)->count();
        return compact('count', 'list');
    }

    /**
     * TODO 获取单条信息
     * @param $value
     * @param string $field
     * @return array
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getInfo($value, $field = 'att_id')
    {
        $where[$field] = $value;
        $count = self::where($where)->count();
        if (!$count) return false;
        return self::where($where)->find()->toArray();
    }

    /**
     * 清除昨日海报
     * @return bool
     * @throws \Exception
     */
    public static function emptyYesterdayAttachment()
    {
        self::beginTrans();
        try {
            $list = self::whereTime('time', 'yesterday')->where(['module_type' => 2])->column('att_dir', 'att_id');
            foreach ($list as $att_id => $att_dir) {
                if ($att_dir && strstr($att_dir, 'uploads') !== false) {
                    if (strstr($att_dir, 'http') === false)
                        @unlink(substr($att_dir, 1));
                    else {
                        $filedir = substr($att_dir, strpos($att_dir, 'uploads'));
                        @unlink($filedir);
                    }
                }
                self::del($att_id);
            }
            self::commitTrans();
        } catch (\Exception $e) {
            self::rollbackTrans();
        }
    }
}