PHPsxg/app/models/auction/AuctionOrder.php

<?php

/**
 *
 * @author: xaboy<365615158@qq.com>
 * @day: 2017/11/02
 */

namespace app\models\auction;

use app\admin\model\user\User;
use app\admin\model\user\UserBill;
use crmeb\services\product\Product;
use crmeb\traits\ModelTrait;
use crmeb\basic\BaseModel;

/**
 * 预约 Model
 * Class WechatNews
 * @package app\admin\model\wechat
 */
class AuctionOrder extends BaseModel
{

    use ModelTrait;

    protected $pk = 'id';

    protected $name = 'auction_order';
    protected $autoWriteTimestamp = true;


    /**
     * 用户订单
     * @param $data
     * @param $uid
     * @return \think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function userOrder($data,$uid)
    {
        if ($data['order_id']){
            $list = self::alias('a')
                ->field('a.*,u.nickname,u.avatar,u.uid as user_id')
                ->leftJoin('user u', 'a.collection_id = u.uid')
                ->where('a.order_id', $data['order_id'])->find(); //详细订单
        }else{
            if ($data['type'] == 1){
                $list = self::where([['uid', '=', $uid], ['status', '=', 1]])->order('id DESC')->page($data['page'], $data['limit'])->select(); //待支付

            }else if($data['type'] == 2){
                $list = self::where([['uid', '=', $uid],['status', '=', 2]])->order('id DESC')->page($data['page'], $data['limit'])->select(); //完成订单

            }else if($data['type'] == 3){
                $list = AuctionProduct::alias('a')
                    ->field('a.*, au.name as au_name')
                    ->leftJoin('auction au', 'au.id = a.auction_id')
                    ->order('a.id DESC')
                    ->where('a.uid', $uid)
                    ->where('a.is_show', 0)
                    ->select();

            }else{
                $list = self::where([['uid', '=', $uid], ['status', '<', 1]])->order('id DESC')->page($data['page'], $data['limit'])->select(); //过期订单
            }
        }
        $list = !empty($list)? $list->toArray(): [];
        return $list;
    }

    /**
     * 卖家订单
     * @param $data
     * @param $uid
     * @return \think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function seller_list($data,$uid)
    {
        if ($data['order_id']){
            $list = self::alias('a')
                ->field('a.*,u.nickname,u.avatar,u.uid as user_id')
                ->leftJoin('user u', 'a.uid = u.uid')
                ->where('a.order_id', $data['order_id'])->find(); //详细订单
        }else{
            if ($data['type'] == 3){
                $list = AuctionProduct::alias('a')
                    ->field('a.*, au.name as au_name')
                    ->leftJoin('auction au', 'au.id = a.auction_id')
                    ->order('a.id DESC')
                    ->where('a.uid', $uid)
                    ->where('a.is_show', 1)
                    ->select();
            }else{
                if ($data['type'] ==  1){
                    $status = 1;
                }elseif ($data['type'] == 2){
                    $status = 2;
                }else{
                    $status = 0;
                }
                $list = self::alias('a')
                    ->field('a.*,u.nickname,u.avatar,u.uid as user_id')
                    ->leftJoin('user u', 'a.uid = u.uid')
                    ->order('a.id DESC')
                    ->where([['a.collection_id', '=', $uid], ['a.status', '=', $status]])
                    ->page($data['page'], $data['limit'])
                    ->select(); //待支付订单
            }

        }
        $list = !empty($list)? $list->toArray(): [];

        return $list;
    }

    /**
     * 订单过期
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function deduction()
    {
        $hour = strtotime(date('Y-m-d H:i:s', strtotime('-30 minute'))); // 30分钟以前

        $order = AuctionOrder::where('create_time', '<', $hour)->where('status', '=', 1)->select(); // 查询不在当前30分钟前的订单
        if ($order){
            foreach ($order as $K => $v){
                $product = AuctionProduct::where('id', $v['product_id'])->find();

                $auction = Auction::where('id', $product['auction_id'])->find();

                $booking = AuctionBooking::where([['uid', '=', $v['uid']], ['status', '=', 1], ['auction_id', '=', $auction['id']]])->where('status', '=', 1)->find(); // 找到预约订单
                if ($booking){
                    AuctionBooking::where('id', $booking['id'])->update(['status' => 2]); // 修改预约订单状态 为扣除
                }
                AuctionOrder::where('create_time', '<', $hour)->where('status', '=', 1)->update(['status' => 0]); // 修改为已过期订单
            }

        }
    }

    /**
     * 退回广告值
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function th()
    {
        $auction = Auction::select();
        if ($auction){
            foreach ($auction as $k => $v){
                if (strtotime($v['rend_time'])+1800 < time()){
                    // 结束后半个小时退回广告值
                    $booking = AuctionBooking::where([['auction_id', '=', $v['id']], ['status','=' , 1], ['frequency', '=', $v['frequency']]])->select();
                    if ($booking){
                        foreach ($booking as $key => $value){
                            $product = AuctionProduct::where('auction_id', $value['auction_id'])->column('id');
                            $order = AuctionOrder::where([['product_id', 'in', $product], ['frequency', '=', $value['frequency']], ['uid', '=', $value['uid']]])->find();
                            if (!$order){
                                $date = date("Y-m-d");
                                $firstday = date('Y-m-01 00:00:00', strtotime($date));  //本月第一天
                                $lastday = date('Y-m-d 23:59:59', strtotime("$firstday +1 month -1 day")); //本月最后一天
                                $userBok = AuctionBooking::where('uid', '=',$value['uid'])->where('th', '=', 1)->whereBetweenTime('create_time', $firstday, $lastday)->count(); //预约未购买退回的次数
                                if ($userBok >= 3){
                                    $userBok++;
                                    if ($userBok == 4) $bf = 0.1;
                                    if ($userBok == 5) $bf = 0.2;
                                    if ($userBok >= 6) $bf = 0.5;
                                }else{
                                    $bf = 0;
                                }
                                $find = AuctionBooking::find($value['id']);
                                $find['status'] = 0;
                                $find['th'] = 1;
                                $find['deduct_advert'] = $value['advert']*$bf; // 扣除广告书
                                $user = User::where('uid', $value['uid'])->find();
                                $user['aid_val'] += ($value['advert']-$find['deduct_advert']); // 增加用户广告值
                                $user->save();
                                $find->save();
                                UserBill::income('未购买解冻但扣除'. $find['deduct_advert'].'广告值',$user['uid'], 'aid_val', 'add_aid_val',$value['advert'] - ($value['advert'] * $bf), 0, $user['aid_val'], '未购买解冻但扣除'. $find['deduct_advert'].'广告值');
                            }
                        }
                    }
                }
            }
        }
    }

    /**
     * 支付订单
     * @param $order
     * @param $uid
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function pay($order, $uid)
    {
        $user = User::where('uid', $uid)->find();


        $user['now_money'] -= $order['actual_price']; // 扣除用户余额
        AuctionProduct::where('id', $order['product_id'])->update(['uid' => $uid, 'is_show' => 0]); // 修改商品拥有人,商品下架等待挂售
        $user->save();
        if ($order['collection_id'] > 0){
            self::m_user($order['collection_id'], $order['actual_price']);
        }
        AuctionOrder::where('id', $order['id'])->update(['status' => 2]); // 修改订单状态
        UserBill::expend('购买商品支付', $uid, 'now_money', 'sub_money', $order['actual_price'], $user['spread_uid'], $user['now_money'], '购买商品支付订单');
    }

    /**
     * 卖家增加余额
     * @param $uid
     * @param $price
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function m_user($uid, $price)
    {
        $user = User::where('uid', $uid)->find();
        $user['now_money'] += $price; // 卖家增加余额

        $user->save();
        UserBill::income('卖出商品', $uid, 'now_money', 'add_money', $price, $user['spread_uid'], $user['now_money'], '商品卖出');

    }





}