// +---------------------------------------------------------------------- namespace App\Services\Api; use App\Models\AccountLogModel; use App\Services\BaseService; use App\Services\RedisService; /** * 交易管理-服务类 * @author laravel开发员 * @since 2020/11/11 * Class AccountService */ class AccountService extends BaseService { public static $instance = null; /** * 构造函数 * @author laravel开发员 * @since 2020/11/11 * AccountService constructor. */ public function __construct() { $this->model = new AccountLogModel(); } /** * 静态入口 * @return static|null */ public static function make() { if (!self::$instance) { self::$instance = (new static()); } return self::$instance; } /** * @param $params * @param int $pageSize * @return array */ public function getDataList($params, $pageSize = 15) { $query = $this->getQuery($params); $list = $query->select(['a.*']) ->orderBy('a.create_time','desc') ->orderBy('a.id','desc') ->paginate($pageSize > 0 ? $pageSize : 9999999); $list = $list? $list->toArray() :[]; if($list){ $accountTypes = config('payment.accountTypes'); foreach($list['data'] as &$item){ $item['create_time'] = $item['create_time']? datetime($item['create_time'],'Y-m-d H:i:s') : ''; $item['time_text'] = $item['create_time']? datetime($item['create_time'],'Y年m月d日') : ''; $type = isset($item['type'])? intval($item['type']) : 0; $item['type_text'] = isset($item['remark'])? trim($item['remark']) : ''; if(empty($item['type_text'])){ $item['type_text'] = isset($accountTypes[$type])? $accountTypes[$type] : '收支明细'; } } } return [ 'pageSize'=> $pageSize, 'total'=>isset($list['total'])? $list['total'] : 0, 'list'=> isset($list['data'])? $list['data'] : [] ]; } public function getQuery($params) { $where = ['a.mark' => 1]; $type = isset($params['type'])? $params['type'] : 0; if($type>0){ $where['a.type'] = $type; } return $this->model->with(['member'])->from("account_logs as a") ->leftJoin('member as b','b.id','=','a.user_id') ->where($where) ->where(function ($query) use($params) { $keyword = isset($params['keyword']) ? $params['keyword'] : ''; $userId = isset($params['user_id'])? $params['user_id'] : 0; if($userId){ $query->where('a.user_id',$userId); } $status = isset($params['status'])? $params['status'] : 0; if($status){ $query->where('a.status',$status); }else{ $query->whereNotIn('a.status',[2]); } if ($keyword) { $query->where(function($query) use($keyword){ $query->where('b.nickname','like',"%{$keyword}%") ->orWhere('b.mobile','like',"%{$keyword}%") ->orWhere('b.realname','like',"%{$keyword}%"); }); } $orderNo = isset($params['order_no'])? trim($params['order_no']) : ''; if($orderNo){ $query->where(function($query) use($orderNo){ $query->where('a.source_order_no','like',"%{$orderNo}%"); }); } }) ->where(function ($query) use($params){ // 日期 $date = isset($params['date']) ? $params['date'] : []; $start = isset($date[0])? $date[0] : ''; $end = isset($date[1])? $date[1] : ''; $end = $start>=$end? '' : $end; if ($start) { $query->where('a.create_time','>=', strtotime($start)); } if($end){ $query->where('a.create_time','<=', strtotime($end)); } }); } /** * 今日金额统计数据 * @param $userId * @param int $type * @return array|mixed */ public function getTotalByDay($userId, $type=1) { $cacheKey = "caches:accounts:total_{$userId}_{$type}"; $data = RedisService::get($cacheKey); if($data){ return $data; } $data = $this->model->where(['user_id'=> $userId,'type'=>$type,'status'=>1,'mark'=>1]) ->where('create_time','>=', strtotime(date('Y-m-d'))) ->sum('money'); if($data){ RedisService::set($cacheKey, $data, rand(5,10)); } return $data; } }