OrderServiceModel.php

<?php
namespace App\Model;

use Illuminate\Database\Eloquent\Model;
use Request;
use App\Model\UserMainModel;
use App\Model\OrderServiceItemsModel;
use App\Model\OrderServiceLogModel;
use App\Http\Controllers\PermController;

class OrderServiceModel extends Model
{
	protected $connection = 'order';
	protected $table      = 'lie_order_service';
	protected $primaryKey = 'id';
	protected $guarded    = ['id'];
	public $timestamps    = true;
	const CREATED_AT      = 'create_time';
	const UPDATED_AT      = 'update_time';

    /** * @param \DateTime|int $value * @return false|int * @author dividez */ 
    public function fromDateTime($value)
    { 
        return strtotime(parent::fromDateTime($value)); 
    }

    // 获取列表
    public function lists($request, $export='')
    {
        $page  = $request->input('page', 1);
        $limit = $request->input('limit', 10);

		$map['service_sn']     = $request->input('service_sn', ''); // 售后单号
		$map['order_sn']       = $request->input('order_sn', ''); // 订单号
		$map['apply_id']       = $request->input('apply_id', ''); // 申请人
		$map['service_status'] = $request->input('service_status', ''); // 售后状态
		$map['refund_status']  = $request->input('refund_status', ''); // 退款状态
		$map['return_status']  = $request->input('return_status', ''); // 退货状态
		$map['begin_time']     = $request->input('begin_time', '') ? strtotime($request->input('begin_time')) : '';
		$map['end_time']       = $request->input('end_time', '') ? strtotime($request->input('end_time')) + 86399 : '';

		$perm = new PermController;
        $role = $perm->getUserRole($request); // 用户角色

        $list = $this->where(function($query) use ($map, $request, $role) {
                    // 售后单号
                    if ($map['service_sn']) {
                        $query->where('service_sn', '=', $map['service_sn']);
                    }
                
                    // 订单号
                    if ($map['order_sn']) {
                        $query->where('order_sn', '=', $map['order_sn']);
                    }
                
                    // 申请人
                    if ($map['apply_id']) {
                        $query->where('apply_id', '=', $map['apply_id']);
                    }
                
                    // 售后状态
                    if ($map['service_status']) {
                        $query->where('service_status', '=', $map['service_status']);
                    }
                
                    // 退款状态
                    if ($map['refund_status']) {
                        $query->where('refund_status', '=', $map['refund_status']);
                    }
                
                    // 退货状态
                    if ($map['return_status']) {
                        $query->where('return_status', '=', $map['return_status']);
                    }
                
                    // 创建时间
                    if(!empty($map['begin_time']) && !empty($map['end_time'])) {  
                        $query->whereBetween('create_time', [$map['begin_time'], $map['end_time']]);
                    }
                    else if(!empty($map['begin_time'])) {
                        $query->where('create_time', '>=', $map['begin_time']);
                    }
                    else if(!empty($map['end_time'])) {
                        $query->where('create_time', '<=', $map['end_time']);
                    }

                    switch ($role) {
                        case 2: // 查看下级
                            $sub_sale_ids = $perm->getSubSaleId($request->user->userId);
                            $query->whereIn('apply_id', $sub_sale_ids);
                            break;
                        case 3:
                        case 5: // 查看自己
                            $query->where('apply_id', $request->user->userId);
                            break;
                    }
                })
                ->orderBy('id', 'desc');
// $tmp = str_replace('?', '"'.'%s'.'"', $list->toSql());
// $tmp = vsprintf($tmp, $list->getBindings());
// echo $tmp;exit;
        if ($export) {
            $list = $list->get()->toArray();
            $list = $this->handle($list);

            if (empty($list)) {
                echo '<script>alert("导出数据为空");history.go(-1);</script>';die;
            }

            return $list;
        } else {
            $list = $list->paginate($limit, ['*'], 'page', $page)->toArray();
            $data = $this->handle($list['data']);

            return [0, '获取成功', $data, $list['total']];
        }
    }

    // 处理数据
    public function handle($data)
    {
        if (!$data) return false;

        $UserMainModel = new UserMainModel;
        $OrderServiceItemsModel = new OrderServiceItemsModel;

        foreach ($data as &$v) {
        	$user = $UserMainModel->getUserAccount($v['user_id']);

			$v['user_account']       = $user->mobile ? $user->mobile : $user->email;
			$v['service_status_val'] = array_get(Config('order_service.service_status'), $v['service_status'], ''); 
			$v['refund_status_val']  = array_get(Config('order_service.refund_status'), $v['refund_status'], ''); 
			$v['return_status_val']  = array_get(Config('order_service.return_status'), $v['return_status'], ''); 
			$v['auditor_time']       = $v['auditor_time'] ? date('Y-m-d H:i:s', $v['auditor_time']) : '';

            if ($v['service_status'] == 1) {
                $v['items'] = $OrderServiceItemsModel->where('service_id', $v['id'])->get()->toArray();
            }
        }

        return $data;
    }

    // 操作
    public function action($request)
    {
    	$id = $request->input('id', 0);

    	if (!$id) return [-1, '参数缺失'];

        $data = []; 
		$data['service_status'] = $request->input('service_status', 1);   
		$data['update_time']    = time(); 

		switch ($data['service_status']) {
            case -1: $event = '取消售后申请'; break;
            case 2: $event = '提交售后申请'; break;
            case 3: $event = '审核通过售后申请'; break;
        }

        if ($data['service_status'] == 3) { // 审核通过
            $service_type = $request->input('service_type', 1);

			$data['auditor_id']   = $request->user->userId;
			$data['auditor_name'] = $request->user->name;
			$data['auditor_time'] = time(); 

			// 生成退款单
			$post = [];
			$post['id']          = $id;
			$post['k1']          = time();
			$post['k2']          = md5(md5($post['k1']).'fh6y5t4rr351d2c3bryi');
			$post['operator_id'] = $request->user->userId;

            $url = Config('website.api_domain').'refund/apply';

            $res = json_decode(curlApi($url, $post, 'POST'), true);

            if (!$res || $res['err_code'] != 0) return [-2, '审核通过失败，原因：'.$res['err_msg']]; 

            if ( $service_type == 1) {
                $event .= '，生成退款单，退款单号：'.$res['data'];
            } else {
                $event .= '，生成退货单，退货单号：'.$res['data'];
            }      
        }

        $this->where('id', $id)->update($data);
        OrderServiceLogModel::addLog($id, $request->user->userId, $event);

        return [0, '成功'];
    }

    // 编辑
    public function edit($request)
    {
        $id = $request->input('id');
        $event = '编辑售后单';

        $info = $this->find($id);
        $event .= '，修改前---售后类型：'.array_get(Config('order_service.service_type'), $info['service_type'], '').'，退款方式：'.array_get(Config('order_service.refund_type'), $info['refund_type'], '');

        $order_service['service_type'] = $request->input('service_type');
        $order_service['refund_type']  = $request->input('refund_type');

        if ($order_service['refund_type'] == 2) { // 支付宝
            $order_service['customer_name']  = $request->input('ali_customer_name');
            $order_service['refund_account'] = $request->input('ali_refund_account');
        } else if ($order_service['refund_type'] == 3) { // 银行
            $order_service['customer_name']  = $request->input('bank_customer_name');
            $order_service['refund_account'] = $request->input('bank_refund_account');
            $order_service['bank_name']      = $request->input('bank_name');
            $order_service['bank_sub_name']  = $request->input('bank_sub_name');
        }

        $res = $this->where('id', $id)->update($order_service);

        if ($res === false) return [-1, '更新订单售后表失败'];

        $service_items = $request->input('service_item');

        $OrderServiceItemsModel = new OrderServiceItemsModel;

        $event .= '，售后明细：';
        foreach ($service_items as $k=>$v) {
            $item = $OrderServiceItemsModel->find($k);
            $event .= '['.$item['goods_name'].' | '.$item['adjust_number'].' | '.$item['adjust_price'].' | '.'申请原因：'.array_get(Config('order_service.apply_reason'), $item['apply_reason'], '').' | '.'备注：'.$item['remark'].'] ';

            $v['update_time'] = time();

            $res = $OrderServiceItemsModel->where('id', $k)->update($v);

            if ($res === false) return [-1, '更新订单售后明细表失败'];
        }

        OrderServiceLogModel::addLog($id, $request->user->userId, $event);
        
        return [0, '成功'];
    }

    // 获取已售后数量
    public function getServicedNum($request)
    {
        $order_id = $request->input('order_id', 0);

        $data = $this->from('lie_order_service as s')
                ->leftJoin('lie_order_service_items as i', 's.id', '=', 'i.service_id')
                ->where('s.service_status', '>', 1)
                ->where('i.order_id', $order_id)
                ->select('goods_id', 'adjust_number')
                ->get()
                ->toArray();

        if (empty($data)) return [0, '', $data];

        $goods = [];
        foreach ($data as $v) {
            if (isset($goods[$v['goods_id']] )) {
                $goods[$v['goods_id']] += $v['adjust_number'];
            } else {
                $goods[$v['goods_id']] = $v['adjust_number'];
            }       
        }

       return [0, '', $goods];     
    }

}