NN2022112805/app/Services/Common/OrderService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Common;

use App\Models\AccountModel;
use App\Models\GoodsModel;
use App\Models\MemberModel;
use App\Models\OrderModel;
use App\Models\ScoreGoodsModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use Illuminate\Support\Facades\DB;

/**
 * 积分商城订单管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * Class OrderService
 * @package App\Services\Common
 */
class OrderService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     * OrderService constructor.
     */
    public function __construct()
    {
        $this->model = new OrderModel();
    }

    /**
     * 静态入口
     * @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)
    {
        $where = ['a.mark' => 1];
        $status = isset($params['status']) ? $params['status'] : 0;
        $userId = isset($params['user_id']) ? $params['user_id'] : 0;
        $shopId = isset($params['shop_id']) ? $params['shop_id'] : 0;
        $parentId = isset($params['parent_id']) ? $params['parent_id'] : 0;
        if ($shopId > 0) {
            $where['a.shop_id'] = $shopId;
        }
        if ($parentId > 0) {
            $where['b.parent_id'] = $parentId;
        }

        if ($status > 0) {
            $where['a.status'] = $status;
        }

        $list = $this->model->from('orders as a')
            ->leftJoin('member as b', 'a.user_id', '=', 'b.id')
            ->leftJoin('score_goods as g', 'g.id', '=', 'a.goods_id')
            ->leftJoin('score_goods_cate as c', 'c.id', '=', 'g.cate_id')
            ->where($where)
            ->where(function ($query) use ($params) {
                $keyword = isset($params['keyword']) ? $params['keyword'] : '';
                if ($keyword) {
                    $query->where('b.nickname', 'like', "%{$keyword}%")->orWhere('b.mobile', 'like', "%{$keyword}%")->orWhere('g.goods_name', 'like', "%{$keyword}%");
                }
            })
            ->where(function ($query) use ($userId) {
                if($userId){
                    $query->where('a.user_id', '=', $userId);
                }
            })
            ->select(['a.*', 'b.nickname', 'b.mobile as buy_mobile', 'c.name as cate_name', 'g.goods_name', 'g.code', 'g.thumb'])
            ->orderBy('a.pay_time', 'desc')
            ->orderBy('a.id', 'desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list ? $list->toArray() : [];
        if ($list) {
            foreach ($list['data'] as &$item) {
                $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
                $item['pay_time'] = $item['pay_time'] ? datetime($item['pay_time'], 'Y-m-d H:i:s') : '';
                $item['thumb'] = isset($item['thumb']) && $item['thumb'] ? get_image_url($item['thumb']) : '';
            }
        }

        return [
            'pageSize' => $pageSize,
            'total' => isset($list['total']) ? $list['total'] : 0,
            'counts' => [
                ''
            ],
            'list' => isset($list['data']) ? $list['data'] : []
        ];
    }

    /**
     * 添加或编辑
     * @return array
     * @since 2020/11/11
     * @author laravel开发员
     */
    public function edit()
    {
        $data = request()->all();
        return parent::edit($data); // TODO: Change the autogenerated stub
    }

    /**
     * 抢拍交易订单数
     * @param $userId 用户ID
     * @param int $status 状态
     * @return mixed
     */
    public function getNewTradeCount($userId, $status=0)
    {
        $where = ['user_id'=>$userId,'mark'=>1,'is_read'=>0];
        return $this->model->where($where)
            ->where(function($query) use($status){
                $query->whereIn('status',is_array($status)? $status:[$status]);
            })
            ->count('id');
    }

    /**
     * 详情
     * @param $id
     * @return mixed
     */
    public function getInfo($id)
    {
        $info = $this->model->from('orders as a')
            ->leftJoin('member as b', 'a.user_id', '=', 'b.id')
            ->leftJoin('score_goods as g', 'g.id', '=', 'a.goods_id')
            ->where(['a.id'=>$id,'a.mark'=>1])
            ->select(['a.*', 'b.nickname', 'b.mobile as buy_mobile', 'g.goods_name','g.source_price', 'g.code', 'g.thumb'])
            ->first();
        if($info){
            $info['create_time_text'] = $info['create_time'] ? datetime($info['create_time'], 'Y-m-d H:i:s') : '';
            $info['pay_time'] = $info['pay_time'] ? datetime($info['pay_time'], 'Y-m-d H:i:s') : '';
            $info['thumb'] = isset($info['thumb']) && $info['thumb'] ? get_image_url($info['thumb']) : '';
            $info['pay_img'] = isset($info['pay_img']) && $info['pay_img'] ? get_image_url($info['pay_img']) : '';

            $address = MemberAddressService::make()->getBindInfo($info['user_id']);
            $info['address'] = $address? $address : [];

            // 积分
            $scoreRate = MemberModel::where(['id'=> $info['user_id']])->value('score_rate');
            $scoreRate = $scoreRate>0 && $scoreRate<=1? $scoreRate : 1;
            $info['score'] = round($info['total']/$scoreRate, 0);

            $bankInfo = ConfigService::make()->getConfigByGroupValue('8');
            $info['bank_info'] = $bankInfo? $bankInfo : ['realname'=>'','bank_name'=>'','bank_num'=>''];
        }

        return $info;
    }

    /**
     * 兑换
     * @param $userId
     */
    public function exchange($userId, $shopId)
    {
        $params = request()->all();
        $goodsId = isset($params['id'])? $params['id'] : 0;
        $info = ScoreGoodsModel::where(['id'=> $goodsId,'mark'=>1,'status'=>1])->first();
        if(empty($info)){
            $this->error = 2061;
            return false;
        }

        $memberInfo = MemberModel::where(['id'=> $userId,'mark'=>1,'status'=>1])->select(['id','member_level','nickname'])->first();
        $memberLevel = isset($memberInfo['member_level'])? $memberInfo['member_level'] : 0;
        if(empty($memberInfo)){
            $this->error = 2019;
            return false;
        }

        $total = $memberLevel? $info['price'] : $info['source_price'];
        $order = [
            'user_id'=> $userId,
            'shop_id'=> $shopId,
            'goods_id'=> $goodsId,
            'order_sn'=> get_order_num('S'),
            'price'=> $info['price'],
            'num'=> 1,
            'total'=> $total,
            'pay_money'=> $total,
            'status'=>1,
            'create_time'=> time(),
            'update_time'=> time(),
            'mark'=>1
        ];

        return $this->model->insertGetId($order);
    }

    /**
     * 支付兑换
     * @param $userId
     * @return bool
     */
    public function pay($userId)
    {
        $params = request()->all();
        $id = isset($params['id'])? $params['id'] : 0;
        $info = $this->model->where(['id'=> $id,'mark'=>1,'status'=>1])->first();
        $total = isset($info['total'])? $info['total'] : 0;
        if(!$id || empty($info)){
            $this->error = 2073;
            return false;
        }

        $payScore = isset($params['score'])? intval($params['score']) : 0;
        $addressInfo = isset($params['address'])? $params['address'] : [];
        $payImg = isset($params['pay_img'])? $params['pay_img'] : '';
        if(empty($addressInfo)){
            $this->error = 2075;
            return false;
        }

        if($payScore<=0 && empty($payImg)){
            $this->error = 2074;
            return false;
        }

        $memberInfo = MemberModel::where(['id'=> $userId,'mark'=>1,'status'=>1])->first();
        $score = isset($memberInfo['score'])? $memberInfo['score'] : 0;
        $scoreRate = isset($memberInfo['score_rate'])? $memberInfo['score_rate'] : 0;
        $scoreRate = $scoreRate>0 && $scoreRate<=1? $scoreRate : 1;
        if(empty($memberInfo)){
            $this->error = 2019;
            return false;
        }

        if($payScore > $score){
            $this->error = 2077;
            return false;
        }

        // 所需积分
        $needScore = round($total/$scoreRate, 0);
        if($payScore<$needScore && empty($payImg)){
            $this->error = 2076;
            return false;
        }

        $scorePayMoney = intval($payScore*$scoreRate, 0);
        $payMoney = round($total - $scorePayMoney, 0);

        $address = [];
        $address[] = isset($addressInfo['province'])? $addressInfo['province'] : '';
        $address[] = isset($addressInfo['city'])? $addressInfo['city'] : '';
        $address[] = isset($addressInfo['district'])? $addressInfo['district'] : '';
        $address[] = isset($addressInfo['address'])? $addressInfo['address'] : '';
        $address = array_filter($address);
        $data = [
            'pay_img'=> $payImg,
            'pay_time'=> time(),
            'user_address'=> $address? implode(' ', $address) : '',
            'realname'=> isset($addressInfo['realname'])? $addressInfo['realname'] : '',
            'user_mobile'=> isset($addressInfo['mobile'])? $addressInfo['mobile'] : '',
            'pay_score'=> $payScore,
            'pay_money'=> $payMoney,
            'status'=> 2,
            'update_time'=>time()
        ];

        DB::beginTransaction();
        if(!$this->model->where(['id'=> $id])->update($data)){
            $this->error = 2079;
            Db::rollBack();
            return true;
        }

        if($payScore>0){
            if(!MemberModel::where(['id'=>$userId,'mark'=>1])->update(['score'=> max(0, $score - $payScore),'update_time'=>time()])){
                $this->error = 2079;
                DB::rollBack();
                return true;
            }

            $data = [
                'user_id'=> $userId,
                'shop_id'=>$info['shop_id'],
                'source_order_sn'=> $info['order_sn'],
                'type'=> 1,
                'coin_type'=> 3,
                'money'=> -$payScore,
                'balance'=> $score,
                'create_time'=> time(),
                'update_time'=> time(),
                'remark'=> '积分兑换商品',
                'status'=>1,
                'mark'=>1,
            ];
            if(!AccountModel::insertGetId($data)){
                $this->error = 2079;
                DB::rollBack();
                return true;
            }
        }


        Db::commit();
        $this->error = 2078;
        return false;
    }

    /**
     * 已收款
     * @return bool
     */
    public function received()
    {
        $params = request()->all();
        $id = isset($params['id'])? $params['id'] : 0;
        $info = $this->model->where(['id'=> $id,'mark'=>1])->first();
        $status = isset($info['status'])? $info['status'] : 0;
        if(!$id || empty($info)){
            $this->error = 2081;
            return false;
        }

        if($status != 2){
            $this->error = 2090;
            return false;
        }

        if($this->model->where(['id'=> $id])->update(['status'=> 3, 'update_time'=> time()])){
            $this->error = 2092;
            return true;
        }else{
            $this->error = 2093;
            return false;
        }
    }

    /**
     * 已发货
     * @return bool
     */
    public function deliver()
    {
        $params = request()->all();
        $id = isset($params['id'])? $params['id'] : 0;
        $express = isset($params['express'])? $params['express'] : '';
        $expressNo = isset($params['express_no'])? $params['express_no'] : '';
        $info = $this->model->where(['id'=> $id,'mark'=>1])->first();
        $status = isset($info['status'])? $info['status'] : 0;
        if(!$id || empty($info)){
            $this->error = 2081;
            return false;
        }

        if(!in_array($status, [2,3])){
            $this->error = 2090;
            return false;
        }

        if($this->model->where(['id'=> $id])->update(['status'=> 4,'express'=> $express,'express_no'=> $expressNo, 'update_time'=> time()])){
            $this->error = 2094;
            return true;
        }else{
            $this->error = 2095;
            return false;
        }
    }

    /**
     * 已收货
     * @return bool
     */
    public function receive()
    {
        $params = request()->all();
        $id = isset($params['id'])? $params['id'] : 0;
        $info = $this->model->where(['id'=> $id,'mark'=>1])->first();
        $status = isset($info['status'])? $info['status'] : 0;
        if(!$id || empty($info)){
            $this->error = 2081;
            return false;
        }

        if(!in_array($status, [3,4,5])){
            $this->error = 2082;
            return false;
        }

        if($this->model->where(['id'=> $id])->update(['status'=> 5, 'update_time'=> time()])){
            $this->error = 2083;
            return true;
        }else{
            $this->error = 2084;
            return false;
        }
    }
}