zx/app/common/repositories/store/ExcelRepository.php

111 lines
3.3 KiB
PHP
Raw Permalink Normal View History

2024-07-02 15:32:59 +08:00
<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
namespace app\common\repositories\store;
use app\common\dao\store\ExcelDao;
use app\common\repositories\BaseRepository;
use app\common\repositories\system\admin\AdminRepository;
use app\common\repositories\system\merchant\MerchantAdminRepository;
use crmeb\services\ExcelService;
use think\facade\Db;
use think\facade\Queue;
use crmeb\jobs\SpreadsheetExcelJob;
class ExcelRepository extends BaseRepository
{
/**
* @var ExcelDao
*/
protected $dao;
/**
* StoreAttrTemplateRepository constructor.
* @param ExcelDao $dao
*/
public function __construct(ExcelDao $dao)
{
$this->dao = $dao;
}
/**
* TODO
* @param array $where
* @param int $admin_id
* @param string $type
* @author Qinii
* @day 2020-07-30
*/
public function create(array $where ,int $admin_id, string $type,int $merId)
{
$excel = $this->dao->create([
'mer_id' => $merId,
'admin_id' => $admin_id,
'type' => $type
]);
$data = ['where' => $where,'type' => $type,'excel_id' => $excel->excel_id];
Queue::push(SpreadsheetExcelJob::class,$data);
// app()->make(ExcelService::class)->$type($where,1);
}
/**
* TODO
* @param array $where
* @param int $page
* @param int $limit
* @return array
* @author Qinii
* @day 2020-07-30
*/
public function getList(array $where,int $page, int $limit)
{
$mer_make = app()->make(MerchantAdminRepository::class);
$sys_make = app()->make(AdminRepository::class);
$query = $this->dao->search($where);
$count = $query->count();
$list = $query->page($page,$limit)->select()
->each(function($item) use ($mer_make,$sys_make){
if (isset($item['admin_id']) && $item['admin_id']) {
if($item['mer_id']){
$admin = $mer_make->get($item['admin_id']);
}else{
$admin = $sys_make->get($item['admin_id']);
}
return $item['admin_id'] = $admin['real_name'] ??"";
}
});
return compact('count','list');
}
/**
* TODO 删除文件
* @param int $id
* @param string $path
* @author Qinii
* @day 2020-08-15
*/
public function del(int $id,?string $path)
{
Db::transaction(function()use($id,$path){
$this->dao->delete($id);
if(!is_null($path)){
$path = app()->getRootPath().'public'.$path;
if(file_exists($path))unlink($path);
}
});
}
}