baokan/app/Models/FilesManager.php

<?php

namespace App\Models;

use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model;
use PhpOffice\PhpSpreadsheet\IOFactory;

/**
 * 文件上传记录
 * 
 */
class FilesManager extends Model
{
    use HasFactory;

    // 与模型关联的表名
    protected $table = 'files_manager';
    // 是否主动维护时间戳
    public $timestamps = false;
    // 定义时间戳字段名
    // const CREATED_AT = 'insert_time';
    // const UPDATED_AT = 'update_time';

    /**
     * 添加数据
     * 
     */
    public function add($data)
    {
        // 时间
        $data['insert_time']                = time();
        $data['update_time']                = time();
        // 写入数据表
        $id                                    = $this->query()->insertGetId($data);
        // 返回结果
        return                              $id;
    }

    /**
     * 添加数据
     * 
     */
    public function edit($id, $data)
    {
        // 更新时间
        $data['update_time']                = time();
        // 写入数据表
        $result                                = $this->query()->where(['id' => $id])->update($data);
        // 返回结果
        return                              $result;
    }

    /**
     * 文件上传到cos
     * 
     * @param	\Illuminate\Http\UploadedFile  $file		文件对象
     * 
     * @return  Array		$result			返回结果
     * 			string 		$file_path		文件路径
     * 			int 		$file_size		文件大小
     * 			string 		$file_name	    文件名称
     *          string 		$file_md5	    文件Md5
     */
    public function fileStore($file, $path = 'company/license/')
    {
        // 请指定路径
        if (!$path)                         return ['error' => '请指定存储路径'];
        // 组装
        $path                               = trim($path, '/') . '/';
        // 判断文件是否有问题
        if (!is_object($file))              return ['error' => '文件上传失败，请重试'];
        // md5
        $fileMd5                            = md5_file($file->getPathName());
        // 通过文件MD5查询是否已经存在
        $data                               = $this->getOneByMd5($fileMd5);
        // 如果存在,直接返回
        if ($data)                          return $data;
        // 文件名
        $filename                           = html_entity_decode(ltrim($file->getClientOriginalName(), '/'), ENT_QUOTES, 'UTF-8');
        // // 文件名仅支持字母数字中文-_组合
        // if (!preg_match('/^[\x{4e00}-\x{9fa5}A-Za-z0-9_\-\+\.\(\)(\x20)]+$/u', $filename)) return ['error' => $filename . '文件名仅支持字母数字中文空格-_组合'];
        // 文件大小
        $ext                                = pathinfo($file->getClientOriginalName(),PATHINFO_EXTENSION);
        // 文件名
        $filename                           = md5($filename).'.'.$ext;
        // 文件大小
        $size                               = $file->getSize();
        // 保存文件
        $objectPath                         = $file->move(public_path('uploads/' . $path), $filename);
        // 如果有错误
        if (!$objectPath)                   return ['error' => $file->getError()];
        // 保存路径
        $data                               = ['file_path' => $path . $filename, 'file_size' => $size, 'file_name' => $filename, 'file_md5' => $fileMd5];
        // 写入数据库
        $data['file_id']                    = $this->add($data);
        // 移动失败
        if (!$data['file_id'])              return ['error' => '存储失败'];
        // 返回结果
        return                              $data;
    }

    /**
     * 通过md5值获取文件信息
     * 
     * @param     String   $fileMd5     文件Md5值
     * @param     String   $$field      指定获取字段名称
     * 
     */
    public function getOneByMd5($fileMd5, $field = '')
    {
        // 获取数据
        $data                              = $this->where([['file_md5', '=', $fileMd5]])->first(['id as file_id', 'file_name', 'file_path', 'file_md5', 'file_size']);
        // 如果
        $data                              = $data ? $data->toArray() : [];
        // 是否获取字段
        return                             empty($field) ? $data : (isset($data[$field]) ? $data[$field] : null);
    }

    /**
     * 从Excel获取产品/客户等编码
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * @param       Model   $Model          数据模型，订单/用户模型
     * 
     */
    public function excelToCode($file, Model $Model)
    {
        // 获取文件后缀名
        $ext                                = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                             = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheet                              = $reader->getActiveSheet()->toArray();
        // 临时数据
        $list                               = [];
        // 循环处理每行
        foreach ($sheet as $row) {
            // 循环获取每行的每列
            foreach ($row as $col) {
                // code转id
                $col                        = $Model->codeToId($col);
                // 如果数据存在
                if ($col)                  $list[] = $col;
            }
        }
        // 返回结果
        return                              $list;
    }


    /**
     * 从Excel获取订单数据
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function excelToOrder($file)
    {
        // 获取文件后缀名
        $ext                        = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                     = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheetList                  = $reader->getActiveSheet()->toArray('');
        // 表格列标题
        $column                     = array_shift($sheetList);
        // 列标题换字段
        $column                     = $this->columnToField($column);
        // 字段值
        if( !$column )              return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)    {
            // 获取对应的数据
            $order                              = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)      {
                // 根据字段索引获取对应的值，转存到订单
                if( isset($column[$kk]) )         $order[$column[$kk]] = $vv;
            }
            // 第一条，没有订单id不可以
            if( $row == 0 )                     {
                // 验证必须数据
                if( !$order['weizan_orderid'] ) return ['error' => ($row + 1).' 没有识别到订单ID'];
                if( !$order['contact_phone'] )  return ['error' => ($row + 1).' 没有识别到手机号'];
                if( !$order['status'] )         return ['error' => ($row + 1).' 没有识别到订单状态'];
                if( strtotime($order['insert_time']) === false )    return ['error' => ($row + 1).' 没有识别到下单时间'];
            }
            // 产品名称每行必填
            if( !$order['product_name'] )       return ['error' => ($row + 1).' 行未识别到商品名称'];
            if( !$order['buy_num'] )            return ['error' => ($row + 1).' 行未识别到商品数量'];
            if( !$order['pay_total'] )            return ['error' => ($row + 1).' 行未识别到商品金额'];
            // 替换一下产品名称中的数据，避免数据超长
            $order['product_name']              = str_ireplace(['（）','()','（','('],'',str_ireplace($order['sku_attr_names'],'',$order['product_name']));
            $order['insert_time']               = $order['insert_time'] ? intval(strtotime($order['insert_time'])) : '';
            // 如果不是第一条
            if( $row >= 1 )                     {
                // 如果没有订单ID 使用上一条的信息(兼容合并单元格)
                if( !$order['weizan_orderid'] )     $order['weizan_orderid']    = $sheetList[$row-1]['weizan_orderid'];
                if( !$order['insert_time'] )        $order['insert_time']       = $sheetList[$row-1]['insert_time'];
                if( !$order['buyer_nick'] )         $order['buyer_nick']        = $sheetList[$row-1]['buyer_nick'];
                if( !$order['status'] )             $order['status']            = $sheetList[$row-1]['status'];
                if( !$order['contact_phone'] )      $order['contact_phone']     = $sheetList[$row-1]['contact_phone'];
                if( !$order['contact_name'] )       $order['contact_name']      = $sheetList[$row-1]['contact_name'];
                if( !$order['contact_province'] )   $order['contact_province']  = $sheetList[$row-1]['contact_province'];
                if( !$order['contact_city'] )       $order['contact_city']      = $sheetList[$row-1]['contact_city'];
                if( !$order['contact_area'] )       $order['contact_area']      = $sheetList[$row-1]['contact_area'];
                if( !$order['contact_addr'] )       $order['contact_addr']      = $sheetList[$row-1]['contact_addr'];
                if( !$order['product_name'] )       $order['product_name']      = $sheetList[$row-1]['product_name'];
            }
            // 追加到订单列表
            $sheetList[$row]                    = $order;
        }
        // 返回结果
        return                                  $sheetList;
    }


    /**
     * 从Excel获取订单数据
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function excelToProduct($file)
    {
        // 获取文件后缀名
        $ext                        = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                     = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheetList                  = $reader->getActiveSheet()->toArray('');
        // 表格列标题
        $column                     = array_shift($sheetList);
        // 列标题换字段
        $column                     = $this->columnToProduct($column);
        // 字段值
        if( !$column )              return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)    {
            // 获取对应的数据
            $order                  = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)      {
                // 根据字段索引获取对应的值，转存到订单
                if( isset($column[$kk]) )         $order[$column[$kk]] = $vv;
            }
            // 如果存在的话
            if( $order['grade'] )    {
                // 转数组
                $order['grade']      = explode(',',$order['grade']);
                // 适读
                $order['grade']      = empty($order['grade']) ? '' : '【适读'. $order['grade'][0].'-'.$order['grade'][count($order['grade'])-1].'年级】';
            }
            // 时间转换
            $order['insert_time']    = $order['insert_time'] ? strtotime($order['insert_time']) : 0;
            $order['update_time']    = $order['update_time'] ? strtotime($order['update_time']) : 0;
            // 库存默认
            $order['stock']          = 99999;
            // 适读
            $order['name']           = $order['name'].$order['grade'];
            // 描述
            $order['description']    = str_ireplace('http://img.duibaoduikan.com/','https://edu.dfwy.tech/',$order['description']);
            // 删除数据
            unset($order['grade']);
            // 追加到订单列表
            $sheetList[$row]         = $order;
        }
        // 返回结果
        return                       $sheetList;
    }

    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function columnToProduct($column)
    {
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {

            if( $value == 'goods_name')    $field[$key] = 'name';
            if( $value == 'category_id')   $field[$key] = 'type_id';
            if( $value == 'goods_main_img')$field[$key] = 'thumb';
            if( $value == 'goods_specs')   $field[$key] = 'spec';
            if( $value == 'goods_price')   $field[$key] = 'price';
            if( $value == 'fit_grade' )    $field[$key] = 'grade';
            if( $value == 'magazine_info') $field[$key] = 'description';
            if( $value == 'goods_sort')    $field[$key] = 'sort';
            if( $value == 'status')        $field[$key] = 'status';
            if( $value == 'create_time')   $field[$key] = 'insert_time';
            if( $value == 'update_time')   $field[$key] = 'update_time';
        }
        // 返回字段值
        return                          $field;
    }

    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function columnToField($column)
    {
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {

            if( $value == '订单ID')         $field[$key] = 'weizan_orderid';
            if( $value == '下单时间')       $field[$key] = 'insert_time';
            if( $value == '订单状态')       $field[$key] = 'status';
            
            if( $value == '收货人')         $field[$key] = 'contact_name';
            if( $value == '收货人手机号' )   $field[$key] = 'contact_phone';
            if( $value == '省')             $field[$key] = 'contact_province';
            if( $value == '市')             $field[$key] = 'contact_city';
            if( $value == '区')             $field[$key] = 'contact_area';
            if( $value == '收货地址')       $field[$key] = 'contact_addr';

            if( $value == '商品名称')       $field[$key] = 'product_name';
            if( $value == '商品规格')       $field[$key] = 'sku_attr_names';
            if( $value == '商品数量')       $field[$key] = 'buy_num';
            if( $value == '商品金额')       $field[$key] = 'pay_total';
            
            if( $value == '买家昵称')       $field[$key] = 'buyer_nick';

        }
        // 返回字段值
        return                          $field;
    }


    /**
     * 从Excel获取订单数据
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function excelToOrderStatus($file)
    {
        // 获取文件后缀名
        $ext                                            = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                                         = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 最大行数
        $reader                                         = $reader->getActiveSheet();
        $maxRow                                         = $reader->getHighestRow();
        // 验证文件格式
        if ( $maxRow > 500 )                            return ['error' => '每次批量仅可处理500条'];
        // 提取数据
        $sheetList                                      = $reader->toArray('');
        // 表格列标题
        $column                                         = array_shift($sheetList);
        // 列标题换字段
        $column                                         = $this->columnToFieldOrderStatus($column);
        // 字段值
        if( !$column )                                  return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)            {
            // 获取对应的数据
            $order                                      = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)              {
                // 根据字段索引获取对应的值，转存到订单
                if( isset($column[$kk]) )               $order[$column[$kk]] = $vv;
            }
            // 验证必须数据
            if( !$order['order_code'] )                 return ['error' => ($row + 1).' 没有识别到订单ID'];
            if( !$order['status'] )                     return ['error' => ($row + 1).' 没有识别到订单状态'];
            // 如果没有订单ID 使用上一条的信息(兼容合并单元格)
            if( !$order['order_code'] )                 $order['order_code']        = $sheetList[$row-1]['order_code'];
            if( !$order['status'] )                     $order['status']            = $sheetList[$row-1]['status'];
            // 追加到订单列表
            $sheetList[$row]                            = $order;
        }
        // 返回结果
        return                                          $sheetList;
    }

    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function columnToFieldOrderStatus($column)
    {
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {
            if( $value == '订单编号')       $field[$key] = 'order_code';
            if( $value == '订单状态')       $field[$key] = 'status';
        }
        // 返回字段值
        return                          $field;
    }

    /**
     * 从Excel获取客户信息
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function excelToCustom($file)
    {
        // 获取文件后缀名
        $ext                        = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                     = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheetList                  = $reader->getActiveSheet()->toArray('');
        // 表格列标题
        $column                     = array_shift($sheetList);
        // 列标题换字段
        $column                     = $this->customToField($column);
        // 字段值
        if( !$column )              return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)    {
            // 获取对应的数据
            $custom                             = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)      {
                // 根据字段索引获取对应的值，转存到客户信息
                if( isset($column[$kk]) )       $custom[$column[$kk]] = $vv;
            }
            // 验证必须数据
            if( empty($custom['external_userid']) )      return ['error' => ($row + 1).' 没有识别到企微ID'];
            if( empty($custom['username']) )          return ['error' => ($row + 1).' 没有识别到用户昵称'];
            if( empty($custom['phone']) )             return ['error' => ($row + 1).' 没有识别到用户手机号'];
            // 没有详细地址，则默认为空
            if( empty($custom['contact_name']) )      $custom['contact_name'] = '';
            if( empty($custom['contact_phone']) )     $custom['contact_phone'] = '';
            if( empty($custom['contact_shop']) )      $custom['contact_shop'] = '';
            if( empty($custom['contact_province']) )  $custom['contact_province'] = '';
            if( empty($custom['contact_city']) )      $custom['contact_city'] = '';
            if( empty($custom['contact_area']) )      $custom['contact_area'] = '';
            if( empty($custom['contact_addr']) )      $custom['contact_addr'] = '';
            // 追加到订单列表
            $sheetList[$row]                    = $custom;
        }
        // 返回结果
        return                                  $sheetList;
    }


    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function customToField($column)
    {
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {
            if( $value == '企微ID')         $field[$key] = 'external_userid';
            if( $value == '用户昵称')        $field[$key] = 'username';
            if( $value == '用户手机号' )     $field[$key] = 'phone';
            if( $value == '收货人')          $field[$key] = 'contact_name';
            if( $value == '店铺信息')        $field[$key] = 'contact_shop';
            if( $value == '收货人手机号' )   $field[$key] = 'contact_phone';
            if( $value == '省')             $field[$key] = 'contact_province';
            if( $value == '市')             $field[$key] = 'contact_city';
            if( $value == '区')             $field[$key] = 'contact_area';
            if( $value == '收货地址')        $field[$key] = 'contact_addr';
        }
        // 返回字段值
        return                          $field;
    }


    /**
     * 从Excel获取积分操作
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function excelToScore($file)
    {
        // 获取文件后缀名
        $ext                        = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                     = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheetList                  = $reader->getActiveSheet()->toArray('');
        // 表格列标题
        $column                     = array_shift($sheetList);
        // 列标题换字段
        $column                     = $this->scoreToField($column);
        // 字段值
        if( !$column )              return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)    {
            // 获取对应的数据
            $custom                             = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)      {
                // 根据字段索引获取对应的值，转存到客户信息
                if( isset($column[$kk]) )       $custom[$column[$kk]] = $vv;
            }
            // 验证必须数据
            if( empty($custom['custom_uid']) )  return ['error' => ($row + 1).' 没有识别到客户ID'];
            if( empty($custom['score']) )       return ['error' => ($row + 1).' 没有识别到积分数量'];
            if( empty($custom['description']) ) $custom['description'] = '';
            // 积分转整数
            $custom['score']                    = intval($custom['score']);
            // 追加到订单列表
            $sheetList[$row]                    = $custom;
        }
        // 返回结果
        return                                  $sheetList;
    }

    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function scoreToField($column)
    {
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {
            if( $value == '客户ID')         $field[$key] = 'custom_uid';
            if( $value == '积分数量')        $field[$key] = 'score';
            if( $value == '备注' )          $field[$key] = 'description';
        }
        // 返回字段值
        return                          $field;
    }

    /**
     * 从Excel获取积分操作
     * 
     * @param     \Illuminate\Http\UploadedFile   $file     传入的文件
     * 
     */
    public function weibanToScore($file)
    {
        // 获取文件后缀名
        $ext                        = pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
        // 验证文件格式
        if (!in_array($ext, ['csv', 'xlsx', 'xls']))    return ['error' => '请上传Excel'];
        // 读取文件
        $reader                     = IOFactory::createReader(ucwords($ext))->load($file->getPathname());
        // 提取数据
        $sheetList                  = $reader->getActiveSheet()->toArray('');
        // 表格列标题
        $column                     = array_shift($sheetList);
        // 列标题换字段
        $column                     = $this->weibanToField($column);
        // 字段值
        if( !$column )              return ['error' => '请检查内容表头格式'];
        // 循环表格数据
        foreach ($sheetList as $row=>$value)    {
            // 获取对应的数据
            $custom                             = [];
            // 循环每个字段，获取值
            foreach ($value as $kk => $vv)      {
                // 根据字段索引获取对应的值，转存到客户信息
                if( isset($column[$kk]) )       $custom[$column[$kk]] = $vv;
            }
            // 验证必须数据
            if( empty($custom['external_userid']) )    return ['error' => ($row + 1).' 没有识别到企微ID'];
            // if( empty($custom['phone']) )           return ['error' => ($row + 1).' 没有识别到联系方式'];
            if( empty($custom['score']) )           return ['error' => ($row + 1).' 没有识别到积分数量'];
            if( empty($custom['description']) )     $custom['description'] = '';
            // 积分转整数
            $custom['score']                    = intval($custom['score']);
            // 追加到订单列表
            $sheetList[$row]                    = $custom;
        }
        // 返回结果
        return                                  $sheetList;
    }

    /**
     * 获取列对应的数据库字段名
     * 
     */
    private function weibanToField($column){
        // 字段值
        $field                              = [];
        // 循环列标题
        foreach ($column as $key => $value) {
            if( $value == '企微ID')         $field[$key]  = 'external_userid';
            // if( $value == '联系方式')        $field[$key]  = 'phone';
            if( $value == '积分数量')        $field[$key] = 'score';
            if( $value == '备注' )          $field[$key] = 'description';
        }
        // 返回字段值
        return                          $field;
    }

}