screen/application/common/model/Orders.php

<?php

namespace app\common\model;

use app\admin\controller\City;
use app\admin\model\Address;
use app\admin\model\AdminMoneyLog;
use app\common\service\GyeUdun;
use app\common\service\UserSvc;
use Carbon\Carbon;
use think\Db;
use think\db\Query;
use think\Model;
use Yansongda\Supports\Arr;

/**
 * @property OrderInfo[] info
 * @property OrderAddress address
 * @property OrderLogistics logistics
 * @property User user
 * @property bool is_wait_pay
 * @property bool is_wait_send
 * @property bool is_payed
 * @property bool is_closed
 * @property Payment payment
 * @property int user_id
 * @property int id
 * @property int status
 * @property int admin_id
 * @property int coupon_id
 * @property int send_time
 * @property string order_no
 * @property float amount_cmn
 * @property float amount_pay
 * @property float amount_coupon
 * @method static static payed()
 * @method static static hasRefund()
 * @method static static statusPay()
 * @method Query hasGoods($goods_id)
 */
class Orders extends Model
{
    protected $type=[
        'tax'=>'json',
    ];

    #未支付过期时间
    const EXP_PAY=1800;
    #线下付款超时
    const EXP_PAY_OFFLINE=3*86400;
    #代付超时
    const EXP_PAY_DF=3*86400;
    #待收货过期时间
    const EXP_REC=30*86400;
    #已完成可售后时间
    const EXP_OVER=7*86400;

    const PT_QYWY=1;
    const PT_WX=2;
    const PT_ZFB=3;
    const PT_YL=4;
    const PT_DF=5;
    const PT_OFF=6;
    const PT_GYEU=7;
    const PT_GYEUZJ=8;
    public static $pay_types=[
        self::PT_QYWY=>'企业网银',
        self::PT_WX=>'微信',
        self::PT_ZFB=>'支付宝',
        self::PT_YL=>'银联',
        self::PT_DF=>'代付',
        self::PT_OFF=>'线下支付',
        self::PT_GYEU=>'工银U盾保留支付',
        self::PT_GYEUZJ=>'工银U盾直接支付',
    ];

    const S_WAIT_PAY=0;
    const S_WAIT_SEND=5;
    const S_WAIT_REC=10;
    const S_OVER=20;
    const S_CANCEL=30;
    const S_REFUND=40;
    public static $status=[
        self::S_WAIT_PAY=>'待支付',
        self::S_WAIT_SEND=>'待发货',
        self::S_WAIT_REC=>'待收货',
        self::S_OVER=>'已完成',
        self::S_CANCEL=>'已取消',
        //self::S_REFUND=>'退款退货',
    ];

    public static function getStatus()
    {
        return self::$status;
    }

    protected $autoWriteTimestamp=true;
    public function info(){
        return $this->hasMany(OrderInfo::class,'order_id');
    }
    public function user(){
        return $this->belongsTo(User::class);
    }
    public function payment(){
        return $this->belongsTo(Payment::class);
    }
    public function address(){
        return $this->hasOne(OrderAddress::class,'order_id');
    }
    public function logistics(){
        return $this->hasOne(OrderLogistics::class,'order_id');
    }
    public function voucher(){
        return $this->belongsTo(OrderVoucher::class,'order_voucher_id');
    }
    /*public function getGoodsAttr(){
        $info=$this->info()->with(['goodsBak'])->find();
        $goods=$info['goodsBak'];
        return [
            'goods'=>$goods['goods'],
            'sku'=>$goods['sku'],
        ];
    }*/
    public function getIsWaitPayAttr($_,$model){
        return $model['status']==self::S_WAIT_PAY;
    }
    public function getIsWaitSendAttr($_,$model){
        return $model['status']==self::S_WAIT_SEND;
    }
    public function getIsEvaledAttr($_,$model){
        $goodsIds=array_unique(OrderInfo::where('order_id',$model['id'])->column('goods_id'));
        $has=GoodsEval::where('order_id',$model['id'])->whereIn('goods_id',$goodsIds)->count();
        return $has==count($goodsIds);
    }
    public function getPayTypeTextAttr($_,$model){
        if(empty($model['pay_type'])){
            return null;
        }
        return self::getPayTypes()[$model['pay_type']];
    }

    /**
     * @return string[]
     */
    public static function getPayTypes(): array
    {
        return self::$pay_types;
    }

    public static function continue($status){
        $now=time();
        return self::where('status',$status)->limit(20)->where('continue_expire_time','<',$now);
    }

    #未支付过期
    public function makeCancel(){
        $this['status']=self::S_CANCEL;
        $this['cancel_time']=time();
        foreach ($this->info as $orderInfo){
            $stock=$orderInfo['is_kill']?'num_stock_kill':'num_stock';
            try {
                Goods::where('id',$orderInfo['goods_id'])->setDec('num_sell',$orderInfo['num']);
            }catch (\Exception $e){
                user_log('orders/cancel',"订单{$this['id']}减已售失败");
            }
            try {
                GoodsSku::where('id',$orderInfo['goods_sku_id'])->setDec('num_sell',$orderInfo['num']);
            }catch (\Exception $e){
                user_log('orders/cancel',"订单{$this['id']}减sku已售失败");
            }
            try {
                GoodsSku::where('id',$orderInfo['goods_sku_id'])->setInc($stock,$orderInfo['num']);
            }catch (\Exception $e){
                user_log('orders/cancel',"订单{$this['id']}增库存【{$stock}】失败");
            }
        }
        #返还优惠券
        $hasCoupon=$this->info()->where('coupon_id','>',0)->value('coupon_id');
        if($hasCoupon){
            UserCoupon::makeUse($hasCoupon,0);
        }
        UserCoupon::makeUse($this->coupon_id,0);

        $this->save();
    }
    #待收货过期
    public function makeRec(){
        $this->makeOverUdun();
        $this->makeOver();
    }
    #支付
    public function makePayInfo($pay_type){
        $user=$this->user;
        $this['pay_type']=$pay_type;
        if($pay_type==self::PT_OFF){
            $this['continue_expire_time']=Carbon::now()->startOfDay()->addSeconds(self::EXP_PAY_OFFLINE+86400-1)->timestamp;
            $this->save();
            return [
                'account_name'=>config('site.account_name'),
                'bank_no'=>config('site.account_bank_no'),
                'bank_name'=>config('site.accout_bank_name'),
            ];
        }elseif($pay_type==self::PT_DF){
            $this['continue_expire_time']=Carbon::now()->startOfDay()->addSeconds(self::EXP_PAY_DF+86400-1)->timestamp;
            $this->save();
            return [
                'expire'=>$this['continue_expire_time'],
            ];
        }else{
            $this['continue_expire_time']=Carbon::now()->addSeconds(self::EXP_PAY)->timestamp;
            $this->save();
        }
        return Payment::pay(
            $user,
            $pay_type,
            $this['amount_pay'],
            $this['id'],
            "订单【{$this['order_no']}】付款",
            $this->getTable()
        );
    }
    #支付后
    public static function makePayed(Payment $payment){
        $order=Orders::find($payment['payment_id']);
        if(!$order){
            return false;
        }
        if(!$order->isNotPay()){
            return false;
        }
        $order['payment_id']=$payment['id'];
        #代付
        if($order['user_id']!=$payment->user_id){

        }
        $order->save();
        $order->makePay($payment['pay_type']);
        return true;
    }
    public function makePay($payType=self::PT_OFF){
        $order=$this;
        $order['status']=self::S_WAIT_SEND;
        $order['pay_time']=time();
        $order['pay_type']=$payType;
        $order->save();
    }
    #发货
    public function makeSend($logistics,$data){
        $newData=Arr::only($data,['com_id','trans_no','remark','from_area','from_address','from_username','from_mobile']);
        if(!$logistics) {
            $this->logistics()->save($newData);
            $this['status']=self::S_WAIT_REC;
            $this['send_time']=time();
            $this->save();
        }else{
            $logistics->save($newData);
        }
    }
    public function makeSendSelf(Address $address,$remark,$com_id,$expType){
        $com = LogisticsCompany::where('id','=',$com_id)->find();
//        echo '<pre>';print_r($com);echo '</pre>';exit;
        $newData=[
            'com_id'=>$com_id,
            'remark'=>$remark,
            'from_area'=>$address->area,
            'from_address'=>$address->address,
            'from_username'=>$address['name'],
            'from_mobile'=>$address['mobile'],
            'expType'=>$com['name'].'-'.$expType,
            //'md_link'=>$label,
            //'trans_no'=>$data['kuaidinum'],
        ];
        $newData = array_filter($newData);
        $logistics=$this->logistics()->save($newData);
        if(!$logistics){
            throw_user('出现错误');
        }

        $names=[];
        foreach ($this->info as $info){
            $names[]=sprintf('%s:%s',$info->goods_name,$info->sku_name);
        }

//        print_r($logistics->from_username);
//        print_r($logistics->from_mobile);
//        print_r($logistics->fullArea());
//        print_r($this->address['name']);
//        print_r($this->address['mobile']);
//        print_r($this->address['address']);
//        print_r($this->info()->sum('num'));
//        print_r($this->order_no);
//        print_r($names);
//        print_r(implode('&',$names));
//        print_r($expType);
//        exit;

        list($res,$data)=logistics()
            ->setLogistics($com)
            ->setUserName($logistics->from_username)
            ->setPhone($logistics->from_mobile)
            ->setToArea($logistics->fullArea())
            ->setFromUsername($this->address['name'])
            ->setFromMobile($this->address['mobile'])
            ->setFromArea($this->address['address'])
            ->setCargo(implode('&',$names))
            ->setCount($this->info()->sum('num'))
            ->setOrderNo($this->order_no)
            ->setExpType($expType)
            ->setComName($com['code_kd100'])
            ->setPartnerId($com['partner_id'])
            ->labelOrder();
        if(!$res){
            throw_user($data);
        }
        $pubname='/uploads/ordermd/'.$this['id'];
        $dir=ROOT_PATH.'public'.$pubname;
        $filename=session_create_id().'.png';
        $saveName=$dir.'/'.$filename;
        if(!is_dir($dir)){
            @mkdir($dir,0755,true);
        }

        file_put_contents($saveName,file_get_contents($data['label']));
        $label=request()->domain().$pubname.'/'.$filename;

        $logistics->trans_no=$data['kuaidinum'];
        $logistics->md_link=$label;
        $logistics->save();

        $this['status']=self::S_WAIT_REC;
        $this['send_time']=time();
        $this->save();
    }
    #确认收货
    public function makeOver(){
        $this['status']=self::S_OVER;
        $this->save();
    }

    // 保留支付需要去银行确认
    public function makeOverUdun(){
        if ($this['pay_type'] == self::PT_GYEU) {
            //网银手动确认收货
            $payment = Payment::where('pay_type', self::PT_GYEU)->where('payment_id', $this['id'])->order('id', 'desc')->findOrFail();
            if (!$payment) {
                user_log('log/icbc', "未查询到支付记录" . json_encode($this));
            }

            GyeUdun::MybankPayCpayCppreservationpayV2Test($this['id'],$payment->order_no,moneyFormat($payment->amount,'f'));
        }
    }
    #发放提成
    public function makeSendCommission(){
        if($this->admin_id){
            AdminMoneyLog::money($this->admin_id,$this->amount_cmn,AdminMoneyLog::T_COMMISSION,$this['user_id'],$this['id']);
        }
    }



    /*
     * 是否未支付
     */
    public function isNotPay(){
        return $this['status']===self::S_WAIT_PAY;
    }
    /**
     * 是否已支付
     */
    public function getIsPayedAttr($_,$model){
        return in_array($model['status'],
            [
                self::S_WAIT_SEND,
                self::S_WAIT_REC,
                self::S_OVER,
            ]
        );
    }
    /**
     * 订单是否已关闭
     */
    public function getIsClosedAttr($_,$model){
        return in_array($model['status'],
            [
                self::S_CANCEL,
            ]
        );
    }
    /**
     * 是否允许退款
     */
    public function allowRefund(){
        if(in_array($this['status'],[
            self::S_WAIT_PAY,
            self::S_CANCEL,
        ])){
            throw_user('订单状态不允许售后');
        }
    }

    /**
     * 网银直接支付不允许退款
     */
    public function allowPayTypeRefund(){
        if(in_array($this['pay_type'],[
            self::PT_GYEUZJ,
        ])){
            throw_user('网银直接支付不允许退款');
        }
    }
    /**
     * 是否允许取消
     */
    public function allowCancel(){
        return in_array($this['status'],[
            self::S_WAIT_PAY,
        ]);
    }
    /**
     * 是否允许确认收货
     */
    public function allowOver(){
        return in_array($this['status'],[
            self::S_WAIT_REC,
        ]);
    }





    public function scopePayed(Query $query){
        $query->whereNotIn('status',[self::S_CANCEL,self::S_WAIT_PAY]);
    }
    public function scopeStatusPay(Query $query){
        $query->where('status',self::S_WAIT_SEND);
    }
    public function scopeHasGoods(Query $query,$goods_id){
        $query->whereExists(
            OrderInfo::whereRaw("orders.id=order_info.order_id and order_info.goods_id={$goods_id}")->buildSql()
        );
    }
    public function scopeHasRefund(Query $query){
        $query->whereExists(
            OrderInfo::where('refund_id','>',0)->where('order_info.order_id',Db::raw('orders.id'))->buildSql()
        );
    }


























    protected static function init()
    {
        self::beforeInsert(function (self $orders){
            #优惠总金额
            //$orders['amount_discount']=bcAddAll($orders['amount_coupon']??0,$orders['amount_coupon_kill']);
            #过期时间
            $orders['continue_expire_time']=time()+self::EXP_PAY;
            #去除无发票的
            if(empty($orders['tax']) || !in_array($orders['tax']['paper_type']??0,[1,2])){
                $orders['tax']=null;
            }
            #属于哪个销售员
            $orders['admin_id']=UserSvc::getSellerId($orders->user_id);
            #发货时间
            /*if(empty($orders['customer_send_time'])){
                $orders['customer_send_time']=Carbon::now()->addDays(config('site.send_delay_day')?:0);
            }*/
        });
        self::afterInsert(function (self $orders){
            #添加发票
            UserTax::fromOrder($orders);
            #合同链接
            $contract_link=request()->root(true)."/contract/view/show/{$orders['id']}";
            $orders->where('id',$orders['id'])->update([
                'contract_link'=>$contract_link,
            ]);
        });
        self::beforeUpdate(function (self $order){
            $data=$order->getChangedData();
            if(!empty($data['status'])){
                #待发货
                if($data['status']==self::S_WAIT_SEND){
                    $order['continue_expire_time']=null;
                }
                #待收货过期时间
                elseif ($data['status']==self::S_WAIT_REC){
                    $order['continue_expire_time']=time()+self::EXP_REC;
                }
                #已完成
               elseif($data['status']==self::S_OVER){
                    $order['rec_time']=time();
                   $order['continue_expire_time']=null;
                }

               $order['status_pre']=$order->origin['status'];
            }
            if(isset($order['amount_profit']) && $order['amount_profit']<0){
                $order['amount_profit']=0;
            }
            if(isset($order['amount_profit_per']) && $order['amount_profit_per']<0){
                $order['amount_profit_per']=0;
            }
            if(isset($order['amount_cmn']) && $order['amount_cmn']<0){
                $order['amount_cmn']=0;
            }
        });
        self::afterUpdate(function (self $orders){
            if(!empty($orders->status) && $orders->status==self::S_WAIT_SEND){
                Transaction::addTransaction($orders);
            }
            #如果已完成发放提成
            if(!empty($orders->status) && $orders->status==self::S_OVER){
                $orders->makeSendCommission();
            }
        });
    }
}