<?php
namespace app\api\logic\order;

use think\Db;
use app\common\logic\Basic as BasicLogic;
use app\common\model\order\PddOrder as ModelPddOrder;
use app\api\logic\commission\Pdd as LogicPddCommission;

class PddOrder extends BasicLogic
{
    protected $model;

    protected static $userRate = 0; //用户反佣比例


    public function __construct(){
        $this->model = new ModelPddOrder();
    }


    /**
     * 订单入库和更新
     *
     * @return void
     */
    public function fanliOrder($order)
    {
        $order_sn = isset($order['order_sn']) ? $order['order_sn'] : '';
        if(empty($order_sn)) return ['status'=>false,'info'=>'订单号为空'];
        Db::startTrans();
        $find_order = $this->model->where(['order_sn'=>$order_sn])->find();
        $custom_parameters = isset($order['custom_parameters']) ? $order['custom_parameters'] : "";
        $uid_arr = json_decode($custom_parameters,true);
        $uid = !$uid_arr ? "" : $uid_arr['uid'];
        $save_order = [
            'auth_duo_id' => isset($order['auth_duo_id']) ? $order['auth_duo_id'] : '',
            'order_id' => isset($order['order_id']) ? $order['order_id'] : (!empty($find_order) ? $find_order['order_id'] : ''),
            'batch_no' => isset($order['batch_no']) ? $order['batch_no'] : '',
            'cpa_new' => isset($order['cpa_new']) ? $order['cpa_new'] : '',
            'custom_parameters' => isset($order['custom_parameters']) ? $order['custom_parameters'] : '',
            'fail_reason' => isset($order['fail_reason']) ? $order['fail_reason'] : '',
            'goods_id' => isset($order['goods_id']) ? $order['goods_id'] : '',
            'goods_name' => isset($order['goods_name']) ? $order['goods_name'] : '',
            'goods_price' => isset($order['goods_price']) ? $order['goods_price'] : '',
            'goods_quantity' => isset($order['goods_quantity']) ? $order['goods_quantity'] : '',
            'goods_thumbnail_url' => isset($order['goods_thumbnail_url']) ? $order['goods_thumbnail_url'] : '',
            'group_id' => isset($order['group_id']) ? $order['group_id'] : '',
            'order_amount' => isset($order['order_amount']) ? $order['order_amount'] : '',
            'order_create_time' => isset($order['order_create_time']) ? $order['order_create_time'] : '',
            'order_group_success_time' => isset($order['order_group_success_time']) ? $order['order_group_success_time'] : '',
            'order_modify_at' => isset($order['order_modify_at']) ? $order['order_modify_at'] : '',
            'order_pay_time' => isset($order['order_pay_time']) ? $order['order_pay_time'] : '',
            'order_receive_time' => isset($order['order_receive_time']) ? $order['order_receive_time'] : '',
            'order_settle_time' => isset($order['order_settle_time']) ? $order['order_settle_time'] : '',
            'order_sn' => isset($order['order_sn']) ? $order['order_sn'] : '',
            'order_status' => isset($order['order_status']) ? $order['order_status'] : '',
            'order_status_desc' => isset($order['order_status_desc']) ? $order['order_status_desc'] : '',
            'order_verify_time' => isset($order['order_verify_time']) ? $order['order_verify_time'] : (!empty($find_order) ? $find_order['order_verify_time'] : ''),
            'promotion_amount' => isset($order['promotion_amount']) ? $order['promotion_amount'] : '',
            'promotion_rate' => isset($order['promotion_rate']) ? $order['promotion_rate'] : '',
            'p_id' => isset($order['p_id']) ? $order['p_id'] : '',
            'type' => isset($order['type']) ? $order['type'] : '',
            'zs_duo_id' => isset($order['zs_duo_id']) ? $order['zs_duo_id'] : '',
            'cat_ids' => isset($order['cat_ids']) ? (is_array($order['cat_ids']) ? implode(',', $order['cat_ids']) : $order['cat_ids']) : '',
            'is_direct' => isset($order['is_direct']) ? $order['is_direct'] : '',
            'sep_duo_id' => isset($order['sep_duo_id']) ? $order['sep_duo_id'] : '',
            'sep_market_fee' => isset($order['sep_market_fee']) ? $order['sep_market_fee'] : '',
            'sep_pid' => isset($order['sep_pid']) ? $order['sep_pid'] : '',
            'sep_rate' => isset($order['sep_rate']) ? $order['sep_rate'] : '',
            'sep_parameters' => isset($order['sep_parameters']) ? $order['sep_parameters'] : '',   
            'price_compare_status' => isset($order['price_compare_status']) ? $order['price_compare_status'] : '',
            'uid' => $uid,
            'pid' => isset($order['pid']) ? $order['pid'] : ''
        ];
        if(empty($find_order)){
            $save_order['tk_z_status'] = 1;
            $save_order['is_distribution'] = (empty($save_order['uid']) || $save_order['uid'] == 0) ? 2 : 0; //如果没有渠道关系ID则该订单无须反佣
            $save_order['create_time'] = time();
            $res = $this->model->insert($save_order);
            if(!$res){
                Db::rollback();
                return ['status'=>false,'info'=>'订单添加失败，订单order_sn：'.$order_sn];
            }
        }else{
            if($find_order['order_status'] != $save_order['order_status']){ //订单发生改变，更新订单
                $save_order['update_time'] = time();
                $save_order['tk_z_status'] = 2;
                $res_update = $this->model->where(['order_sn'=> $order_sn])->update($save_order);
                if(!$res_update){
                    Db::rollback();
                    return ['status'=>false,'info'=>'订单更新失败，订单order_sn：'.$order_sn];
                }
            }   
        }
        Db::commit();
        return ['status'=>true,'info'=>'订单逻辑处理完成'];
    }


    /**
     * 拆分订单
     *
     * @return void
     */
    public function chaifenOrder()
    {
        $list = $this->model->where(['is_distribution'=>0,'uid'=>['neq',''],'uid'=>['neq',0]])->whereOr("is_distribution = 1 And tk_z_status = 2 And uid !=''")->limit(20)->order('id desc')->select();
        if(!empty($list)){
            $LogicPddCommission = new LogicPddCommission();
            foreach($list as $order){
                $result = $LogicPddCommission->fanliCommission($order);
                if(!$result){
                    mylog('订单拆分错误',$result['info'],"errorInfo");
                }
            }
        }
        return ['status'=>true,'info'=>'拆分逻辑执行完成'];
    }

}