Merge branch 'release/v1.1.4发布'

zhaojs

2023-07-20 8c00bd0245ca4756ca04483a4980ad202714e43e

 application/api/logic/commission/Jd.php

@@ -61,6 +61,67 @@
    }


     /**
     * 返利入库和更新（新），加上首单逻辑
     *
     * @return void
     */
    public function fanliCommissionNew($order)
    {
        $trade_id = isset($order['order_row_id']) ? $order['order_row_id'] : '';
        if(empty($trade_id)) return ['status'=>false,'info'=>'订单号为空'];
        //判断是实付金额是否大于4元，大于4元直接普通返利
        if(floatval($order['estimate_cos_price'])>5){
            $res=self::fanliCommission($order);
            return $res;
        }
        //根据淘宝绑定渠道id查询用户信息
        $ModelUser = new ModelUser();
        $user = $ModelUser->where(['common_relation_id'=>$order['position_id']])->find();
        if(!empty($user))
        {
            $browse=DB::name('user_first_free_browse')->where(['user_id'=>$user['id'],'is_order'=>1])->find();
            if(!empty($browse)){
                //查询是否是首单商品
            $first_browse=DB::name('user_first_free_browse')->where(['user_id'=>$user['id'],'tid'=>$order['order_row_id']])->find();
            if(!empty('first_browse')){
                //计算首单返利
                $res=self::fanliCommissionForFree($order);
                return $res;
            }
            else{
                $res=self::fanliCommission($order);
                return $res;
            }

            }
            else{
                $itemid=$order['sku_id'];
                $first_good=DB::name('user_first_free_browse')->where(['user_id'=>$user['id'],'is_order'=>0,'new_goodsId'=>$itemid])->find();
                if(empty($first_good)){
                    $res=self::fanliCommission($order);
                    return $res;
                }
                else{
                    //计算首单返利
                    $res=self::fanliCommissionForFree($order);
                    return $res;

                }
            }
        
        }
        else{
            //标记订单为无需分销
            $ModelOrder = new ModelTaobaoOrder();
            $ModelOrder->where(['id'=>$order['id']])->update(['is_distribution'=>2,'update_time'=>time()]);
            Db::commit();
            return ['status'=>true,'info'=>'无需分销'];
        }
        
    }



    /**
     * 返利入库和更新
@@ -249,5 +310,98 @@
        return ['status'=>true,'info'=>'拆分成功'];
    }

    /**
     * 首单返利入库和更新
     *
     * @return void
     */
    public function fanliCommissionForFree($order)
    {
        $trade_id = isset($order['order_row_id']) ? $order['order_row_id'] : '';
        if(empty($trade_id)) return ['status'=>false,'info'=>'订单号为空'];
        Db::startTrans();
        $ModelUser = new ModelUser();
        $user = $ModelUser->where(['common_relation_id'=>$order['position_id']])->find();
        $ModelOrder = new ModelJdOrder();
        if(empty($user)){
            //标记订单为无需分销
            $ModelOrder->where(['id'=>$order['id']])->update(['is_distribution'=>2,'update_time'=>time()]);
            Db::commit();
            return ['status'=>true,'info'=>'无需分销'];
        }
        $userLevelInfo = $this->getLevelInfo($user['level']); //用户等级信息
        $find_commission = $this->model->where(['trade_id'=>$trade_id])->select();
        $push_data = [];
        if(empty($find_commission)){ //开始反佣入库
            //自购反佣
            $tmp_1 = [
                'trade_parent_id' => $order['order_id'],
                'trade_id' => $trade_id,
                'member_id' => $user['id'],
                'buy_member_id' => $user['id'],
                'is_own' => 1,
                'alipay_total_price' => $order['estimate_cos_price'],
                'pub_share_pre_fee' => $order['estimate_cos_price'],
                'pub_share_fee' => $order['valid_code'] == 17 ? $order['estimate_cos_price']: "",
                'refund_tag' => 0,
                'item_img' => $order['image_url'],
                'item_title' => $order['sku_name'],
                'tk_status' => $order['valid_code'],
                'item_id' => $order['sku_id'],
                'member_commission_rate' => 100,
                'is_settle' => 0,
                'tb_paid_time' => $order['order_time'],
                'pay_price' => $order['actual_cos_price'],
                'tk_earning_time' =>!empty($order['finish_time']) ? strtotime($order['finish_time']) : 0, 
                'pay_month' => $order['pay_month'],
                'create_time' => time()
            ]; 
            $save_data[] = $tmp_1;
            $result = $this->model->saveAll($save_data);
            if(!$result){
                Db::rollback();
                return ['status'=>false,'info'=>'反佣入库失败'];
            }
            if($order['is_distribution'] == 0){
                $res_order = $ModelOrder->where(['id'=>$order['id']])->update(['is_distribution'=>1,'update_time'=>time()]);
                if(!$res_order){
                    Db::rollback();
                    return ['status'=>false,'info'=>'订单状态修改失败'];
                }
            }
            // if(!empty($push_data)){
            //     $this->userPush($push_data);
            // }
        }else{ //已经拆分订单，进行更新
            foreach($find_commission as $item){
                $item_data = [
                    'alipay_total_price' => $order['estimate_cos_price'],
                    'pub_share_pre_fee' => $order['estimate_cos_price'],
                    'pub_share_fee' => $order['valid_code'] == 17 ? $order['estimate_cos_price']: $item['pub_share_fee'],
                    'refund_tag' => 0,
                    'tk_status' => $order['valid_code'],
                    'pay_price' => $order['actual_cos_price'],
                    'tk_earning_time' =>!empty($order['finish_time']) ? strtotime($order['finish_time']) : 0, 
                    'pay_month' => $order['pay_month'],
                    'update_time' => time()
                ];
                $update_commission = $this->model->where(['id'=>$item['id']])->update($item_data);
                if(!$update_commission){
                    Db::rollback();
                    return ['status'=>false,'info'=>'更新拆分记录错误,ID为:'.$item['id']];
                }
            }
            //更新订单
            $update_order = $ModelOrder->where(['id'=>$order['id']])->update(['tk_z_status'=>1,'update_time'=>time()]);
            if(!$update_order){
                Db::rollback();
                return ['status'=>false,'info'=>'更新订单tk_z_status错误,订单ID为:'.$order['id']];
            }
        }
        Db::name('user_first_free_browse')->where(['user_id'=>$user['id'],'new_goodsId'=>$order['sku_id']])->update(['tid'=>$trade_id,'is_order'=>1]);
        Db::commit();
        return ['status'=>true,'info'=>'拆分成功'];
    }


}