beauti-nof/application/common/model/MobileOrder.php

<?php

namespace app\common\model;

use app\admin\model\Mobile;
use app\admin\model\Admin;
use app\admin\model\MobileOrderAdmin;
use app\common\library\MobileConstant;
use app\common\service\ProduceOrderService;
use app\common\service\Refund;
use app\common\service\SmsSend;
use app\service\byte_dance\ByteDanceOrderPush;
use app\service\byte_dance\ByteDanceSettle;
use app\service\fast_hand\Settle;
use think\Db;
use think\db\Query;
use think\Model;


/**
 * 配置模型
 * @method static static filterSaled()
 * @method static static expired()
 * @method static static filterWillOver()
 * @method static static filterFlow()
 * @method $this filterShow($type)
 * @method $this waitPay()
 */
class MobileOrder extends Model
{
    protected $readonly=[
        'user_id',
    ];
    use TraitModel;
    const STATUS_WAIT_SEND=10;
    const STATUS_CAN_SEND=15;
    const STATUS_REFUND=30;
    const STATUS_REFUNDED=90;
    //供应商页面展示tab
    public static $GongYSStatus=[
        self::STATUS_CAN_SEND=>'待发货',
        17=>'有号码未发货',
        20=>'已发货待激活',
        25=>'已完成',
        60=>'无号码',
    ];
    public static $status=[
        0=>'待付款',
        self::STATUS_WAIT_SEND=>'已付款',
        self::STATUS_CAN_SEND=>'待发货',
        17=>'有号码未发货',
        20=>'已发货待激活',
        25=>'已完成',
        self::STATUS_REFUND=>'申请退款',
        50=>'已关闭',
        60=>'无号码',
        70=>'换卡',
        80=>'争议单',
        self::STATUS_REFUNDED=>'已退款',
    ];
    public static $refundAllowStatus=[
        self::STATUS_WAIT_SEND,
        15,
        17,
        20,
        60,
        70,
    ];
    public static $refundAllowStatusFlow=[
        10,
        15,
        20,
        23,
        110,
    ];
    public static $flowStatus=[
        0=>'待付款',//待付款
        10=>'已付款未处理',//已付款未处理
        15=>'待处理',//待处理
        20=>'已提交运营商',//已提交运营商
        23=>'已发货',//已发货
        25=>'已完结',//已激活/已完结
        self::STATUS_REFUND=>'申请退款',
        50=>'已关闭',//已激活/已完结
        self::STATUS_REFUNDED=>'已退款',
        110=>'审核失败',//审核失败
    ];
    public static $frontStatus=[
        0,
        self::STATUS_WAIT_SEND,
        self::STATUS_CAN_SEND,
        17,20,25,30,90,50,
    ];
    public static $payTypes=[
        1=>'微信',
        2=>'支付宝',
        3=>'京东',
        4=>'抖音',
        self::PT_KS=>'快手',
    ];
    const PT_DY=4;
    const PT_KS=5;
    protected $hidden=[
        'status_bak',
    ];
    protected $append=[
        'allow_refund',
    ];


    // 自动写入时间戳字段
    protected $autoWriteTimestamp = true;

    public function mobile(){
        return $this->belongsTo(Mobile::class)->setEagerlyType(0);
    }
    public function info(){
        return $this->hasOne(MobileOrderInfo::class);
    }
    public function mind(){
        return $this->hasOne(MobileOrderMind::class);
    }
    public function operation(){
        return $this->hasMany(MobileOrderOperation::class)->order('mobile_order_operation.id','desc');
    }
    public function admin(){
        return $this->hasMany(MobileOrderAdmin::class);
    }
    public function orderStatus(){
        return $this->hasMany(MobileOrderStatus::class);
    }
    public function refundLog(){
        return $this->hasMany(MobileOrderRefundLog::class);
    }
    public function rules(){
        return $this->hasMany(MobileOrderRules::class);
    }
    public function proxy(){
        $columns=Admin::getTableInfo()['fields'];
        unset($columns['password']);
        return $this->belongsTo(Admin::class)->field($columns);
    }

    public function getAddressAttr($a,$b){
        return Area::getNameString($b['city']).$a;
    }
    public function getAllowRefundAttr($_,$model){
        if(empty($model['type'])){
            return false;
        }
        if($model['type']==Mobile::FLOW){
            return in_array($model['status'],self::$refundAllowStatusFlow);
        }
        return in_array($model['status'],self::$refundAllowStatus);
    }
    public function setCityAttr($a){
        if(is_array($a)){
            return implode(',',$a);
        }
        return $a;
    }

    public function saveRules(){
        if($this['type']==1) {
            $mobile=$this['mobile'];
            $filters=MobileConstant::getFilters();
            $rules=[];
            foreach ($filters as $rule=>$filter){
                $fit=false;
                foreach ($filter as $column){
                    if($mobile[$column]){
                        $fit=true;
                        break;
                    }
                }
                if($fit){
                    $rules[]=[
                        'rule'=>$rule
                    ];
                }
            }
            $this->rules()->saveAll($rules);
        }
    }

    protected static function init()
    {
        self::beforeInsert(function (self $mobileOrder){
            $mobileOrder['order_no']=order_no();
            $mobileOrder['expire_time']=time()+86400;
            $mobileOrder['brand']=$mobileOrder['mobile']['brand'];
            #计算盈利
            $mobileOrder['amount_profit']=bcsub($mobileOrder['amount_base'],$mobileOrder['amount_di']);
            if($mobileOrder['amount_profit']<0){
                $mobileOrder['amount_profit']=0;
            }
        });
        self::afterInsert(function (self $mobileOrder){
            $mobileOrder->info()->save([
                'mobile'=>$mobileOrder['mobile'],
                'info'=>$mobileOrder['mobile']['info'],
            ]);
            #保存规律
            $mobileOrder->saveRules();
        });

        self::beforeUpdate(function (self $mobileOrder){
            $data=$mobileOrder->getChangedData();
            #记录status
            if(isset($data['status'])){
                $mobileOrder->orderStatus()->save([
                    'status'=>$mobileOrder->origin['status'],
                ]);
            }

            #物流信息
            if(!empty($data['trans_id'])){
                $mobileOrder['trans_name']=LogisticsCompany::getNameById($data['trans_id']);
            }
            if(isset($data['trans_id']) && !$data['trans_id']){
                $mobileOrder['trans_name']=null;
            }

            #主播

        });
        self::afterUpdate(function (self $mobileOrder){
            #同步订单
            /*if($mobileOrder['pay_type']==4){
                $push=new ByteDanceOrderPush();
                $push->setOrder($mobileOrder);
                $push->setPayment(null);
                $push->get();
            }*/
        });
    }

    public function sendNotifyToUser(){
        $mobileOrder=$this;
        if($mobileOrder['trans_name'] && $mobileOrder['trans_no']) {
            SmsSend::orderSend($mobileOrder['phone'], $mobileOrder['trans_name'], $mobileOrder['trans_no']);
        }
    }

    public function scopeExpired(Query $query){
        $query->where('status',0)->where('expire_time','<',time())->where('amount','>',0);
    }
    public function scopeFilterWillOver(Query $query){
        $query->whereIn('status',[20,23])->where('send_time','<=',strtotime('-3days'));
    }

    public function scopeFilterFlow(Query $query){
        $query->where('type',2);
    }

    public function cancel(){
        if($this['pay_time'] || $this['pay_time']!=0){
            return;
        }
        $this['status']=50;
        $this->save();
    }

    public function continuePay(){
        if($this['expire_time']<time()){
            throw_user('订单已过期');
        }
        if($this['status']!=0){
            throw_user('订单状态有误');
        }
        if($this['type']!=1){
            throw_user('该产品无需支付');
        }
        if(!$this['mobile']){
            throw_user('手机号不存在或已下架');
        }
        $this['mobile']->shouldBuy();
    }
    #wechat,alipay,dy
    public function paySuccessCallback($payment=null,$data=[],$type='wechat'){
        $mobileOrder=$this;
        if(!empty($mobileOrder['pay_time'])){
            throw_user("手机订单已支付");
        }
        if(Mobile::isTypeNo($mobileOrder['type'])) {
            $mobileOrder['status'] = MobileOrder::STATUS_CAN_SEND;
        }else{
            $mobileOrder['status'] = 10;
        }
        if($payment) {
            $payConfig=get_addon_config('epay');
            $mobileOrder['pay_time'] = $payment['pay_time'];
            if ($type == 'wechat') {
                $mobileOrder['pay_type'] = 1;
                $mobileOrder['pay_no'] = $data['transaction_id'];
                $mobileOrder['pay_mid_wechat']=$payConfig['wechat']['mch_id'];
            } elseif ($type == 'alipay') {
                $mobileOrder['pay_type'] = 2;
                $mobileOrder['pay_no'] = $data['trade_no'];
                $mobileOrder['pay_mid_alipay']=$payConfig['alipay']['app_id'];
            }elseif ($type=='dy'){
                $mobileOrder['pay_type'] = 4;
                $mobileOrder['pay_no'] = $data['channel_no'];
                $mobileOrder['pay_mid_dy']=$data['appid'];
            }elseif ($type=='ks'){
                $mobileOrder['pay_type'] = 5;
                $mobileOrder['pay_no'] = $data['ks_order_no'];
                $mobileOrder['pay_mid_ks']=$data['appid'];
            }
            $mobileOrder['payment_id'] = $payment['id'];
            SmsSend::orderPayed($mobileOrder['phone']);
            SmsSend::orderedSupplyNotice($mobileOrder);
        }else{
            $mobileOrder['pay_time']=time();
        }
        if (!$mobileOrder->save()) {
            throw_user("订单保存失败");
        }
        Mobile::whenOrderPayed($mobileOrder->mobile);
    }

    public function originData(){
        return $this->origin;
    }
    public function checkAllowRefund(){
        if($this['amount']<=0){
            throw_user('该订单未支付无法退款');
        }
        if(in_array($this['type'],[Mobile::BEAUTI,Mobile::API]) && !in_array($this['status'],self::$refundAllowStatus)){
            throw_user('当前状态不允许退款');
        }elseif($this['type']==Mobile::FLOW && !in_array($this['status'],self::$refundAllowStatusFlow)){
            throw_user('流量卡当前状态不允许退款');
        }
        if(empty($this->payment)){
            throw_user('该订单无支付信息无法退款');
        }
    }
    public function makeUserRefund($reason){
        $this['status_bak']=$this['status'];
        $this['status']=self::STATUS_REFUND;
        $this['refund_reason']=$reason;
        $this->save();
    }
    public static function flowStatus(){
        $s=self::$flowStatus;
        return $s;
    }
    public function frontStatus(){
        return self::$frontStatus;
    }
    public function scopeFilterShow(Query $query,$type){
        if ($type==1){
            $query->whereIn('mobile_order.status',$this->frontStatus());
        }else{
            $query->whereIn('mobile_order.status',array_keys(self::flowStatus()));
        }
    }

    public function makeRefund($from,$user,$data){
        $model=$this;
        $model['amount_refund'] = $data['amount'];
        $model['refund_no'] = session_create_id();
        $model['refund_audit_remark']=$data['refund_reason'];
        $statusBak=$model['status_bak'];
        if(is_null($model['status_bak'])) {
            $model['status_bak'] = $model['status'];
        }
        if ($data['pass']) {
            if ($data['amount'] > $model['amount']) {
                throw_user('退款金额不能大于付款金额');
            }
            Refund::setType($model)->refund();
            $model['status'] = self::STATUS_REFUNDED;
            SmsSend::orderRefund($model['phone']);
            #退款盈利哦
            $model['amount_profit']=bcsub($model['amount'],$model['amount_refund']);
        }else{
            $model['amount_refund']=0;
            if(!is_null($statusBak)){
                $model['status'] = $statusBak;
            }
        }
        $model->save();
        $model->refundLog()->save(MobileOrderRefundLog::withRefund($from,$user,$data));
    }
    public function makeOver($settle=true){
        $this['status']=25;
        $this->save();
        if($settle) {
            if ($this['payment_id']) {
                if ($this['pay_type'] == self::PT_DY) {
                    $this->dySettle();
                } elseif ($this['pay_type'] == self::PT_KS) {
                    $this->ksSettle();
                }
            }
        }
    }

    public function flowOrderSubmit(){
        $this['status']=0;
    }

    public function scopeWaitPay(Query $query){
        $query->where('status',0);
    }
    #销售金额
    public function scopeFilterSaled(Query $query){
        $query->whereNotIn('mobile_order.status',[0,50,90]);
    }
    #发货
    public function dealSend($trans_no,$trans_id){
        $this['trans_no']=$trans_no;
        $this['trans_id']=$trans_id;
        if($this['type']==1){
            $this['status']=20;
        }else{
            $this['status']=23;
        }
        $this['send_time']=time();
        $this->save();
        $this->sendNotifyToUser();
    }
    #30天内同一手机号不弄下单
    // public static function hasOrdered($phone,Mobile $mobile){
    public static function hasOrdered($phone,$mobile_brand){
        return
            self::whereNotIn('status',[0,50])
                ->where('create_time','>',strtotime('-30days'))
                ->where('phone',$phone)
                //->where('brand',$mobile['brand'])
                ->where('brand',$mobile_brand)
                ->value('id');
    }

    /**
     * 流量单限制
     */
    public static function orderLimit($id_no, $limit = 30, $mobileBrand = ''){
        $days = '-'.$limit.' days';
        if(!$id_no || !$mobileBrand) return true;
        // $brands = Mobile::$flowBrand;
        // $brand = $brands[$mobileBrand] ?? '';
        // if(!$brand) return false;
        return
            self::whereNotIn('status',[0,50])
                ->where('create_time','>',strtotime($days))
                ->where('id_no', $id_no)
                ->where('brand', $mobileBrand)
                // ->fetchSql()
                ->value('id');
    }

    public function payment(){
        return $this->belongsTo(Payment::class);
    }

    public function dySettle(){
        if($this['pay_type']!=self::PT_DY){
            throw_user('必须抖音支付才能结算');
        }

        $settle=new ByteDanceSettle();
        $settle->setMobileOrder($this);
        $settle->get();
    }
    public function ksSettle(){
        $settle=new Settle();
        $settle->setOrder($this);
        list($succ,$msg,$data)=$settle->get();
        if(!$succ){
            throw_user("快手结算失败:$msg");
        }
    }

    public function getOrderStatusText(){
        if(Mobile::isTypeNo($this['type'])){
            $status=self::$status;
        }else{
            $status=self::flowStatus();
        }
        return $status[$this['status']];
    }
    // // 和产品信息多对一的关系
    // public function produce()
    // {
    //     return $this->belongsTo(Produce::class, 'produce_id', 'id');
    // }

    /**
     * 和产品多态的关系
     *
     * @return void
     */
    public function produce()
    {
        $models = ProduceOrderService::PRODUCE_TYPE_MODEL;

        return $this->morphTo([
            'produce_type',
            'produce_id'
        ], $models);
    }
}