xiaoshan/application/api/controller/Demo.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use app\utils\RedisUtil;
/**
 * 示例接口
 */
class Demo extends Api
{

    //如果$noNeedLogin为空表示所有接口都需要登录才能请求
    //如果$noNeedRight为空表示所有接口都需要验证权限才能请求
    //如果接口已经设置无需登录,那也就无需鉴权了
    //
    // 无需登录的接口,*表示全部
    protected $noNeedLogin = ['*'];
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['test2'];

    /**
     * 测试方法
     *
     * @ApiTitle    (测试名称)
     * @ApiSummary  (测试描述信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/demo/test/id/{id}/name/{name})
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="id", type="integer", required=true, description="会员ID")
     * @ApiParams   (name="name", type="string", required=true, description="用户名")
     * @ApiParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
     * @ApiReturn   ({
         'code':'1',
         'msg':'返回成功'
        })
     */
    public function test()
    {
        $total_amount = 1000;  //消费额
        $back_rate = 10;            //商家比例
        $user_id = 1;             //消费者id
        $shop_id = 1;            //门店id
        $this->task_bill($total_amount,$back_rate,$user_id,$shop_id,'hotel_order');
    }


    /*
     * 订单额，返利比例
     * $total_amount : 订单金额 ，需要计算的订单金额
     * $back_rate : 各店铺设置的返佣比例 3-20%
     * $user_id : 下单用户id
     * $shop_id : 店铺id
     * $table_name : hotel_order , hotel_canteen_order , university_event_apply , offline_shop_order
     * */
    public function task_bill($total_amount,$back_rate,$user_id,$shop_id,$table_name)
    {
        //3-20%
        $amount = bcdiv(bcmul($total_amount,$back_rate,2),100,2);

        //5倍
//        $back_double = config('site.back_double');
//        $amount = bcmul($amount,$back_double,2);

        //商务 + 锁客 + 网体 + 省代 + 市代 + 区代 = 40% （大约40%,具体看多少看各级配置）

        //商务 发给门店的上级  收益
        $shangwu_rate = config('site.back_shangwu');
        $shangwu_amount = bcdiv(bcmul($amount,$shangwu_rate,2),100,2);

        $shop_info = (new \app\common\business\PaymentBusiness)->getShopInfo($table_name,$shop_id);
        if($shop_info && $shop_info['invite_id'] && $shangwu_amount > 0){
            //发钱给 $shop_info['invite_id']

        }

        //锁客 发给消费者的上级 收益
        $suoke_rate   = config('site.back_suoke');
        $suoke_amount = bcdiv(bcmul($amount,$suoke_rate,2),100,2);

        $suoke_invite_id = Db::name('user')->where('id',$user_id)->value('invite_id');
        if($suoke_invite_id && $suoke_amount > 0){
            //发钱给 $suoke_invite_id
        }

        //网体 业务员逻辑 按月发 收益


        //省代,市代,区代 三个代理 都按月发 收益, 放到代理月辅助表
        $map_agent = [
            'month_date'  => date('Ym'),
            'province_id' => $shop_info['province_id'],
            'city_id'     => $shop_info['city_id'],
            'district_id' => $shop_info['district_id'],
        ];
        $agent_month = Db::name('agent_month')->where($map_agent)->order('id asc')->find();
        if(empty($agent_month)){
            $map_agent['back_amount'] = $amount;
            $map_agent['updatetime']  = time();
            $map_agent['status']      = 0;

            Db::name('agent_month')->insertGetId($map_agent);
        }else{
            Db::name('agent_month')->where('id',$agent_month['id'])->update([
                'updatetime'  => time(),
                'back_amount' => bcadd($agent_month['back_amount'],$amount,2)
            ]);
        }

    }

    //业务员奖
    public function yewuyuan(){
        $user_id = 1;
        $last_month = date('Ym',strtotime(date('Y-m-01')) - 86400);

        //我直推线下商家的总数量。
        $invite_count     = Db::name('offline_shop')->where('invite_id',$user_id)->count();

        //我上个月直推线下商家的总数量
        $invite_count_mon = Db::name('offline_shop')->where('invite_id',$user_id)->whereTime('create_time','last month')->count();

        //我的个人业绩。我所有直推线下商家的3-20%的让利总额
        $invite_amount = Db::name('bill')->where('shop_invite_id',$user_id)->where('table_name','offline_shop_order')->where('back_status','neq',0)
            ->whereTime('createtime','last month')->sum('back_amount');

        //我团队业绩
        $invite_uids = $this->get_all_down_uids($user_id);
        $invite_amount_tuandui = Db::name('bill')->where('shop_invite_id','IN',$invite_uids)->where('table_name','offline_shop_order')->where('back_status','neq',0)
            ->whereTime('createtime','last month')->sum('back_amount');

        //补贴/提成
        $butie = 0;        //补贴
        $yeji = 0;      //个人业绩提成
        $yingxiao_level = 0;//用户的营销等级

        //各级的条件
        $level_list = Db::name('yingxiao_level')->order('id asc')->select();
        foreach($level_list as $level){
            if($level['type'] == 1 || 1==1){
                //营销经理
                if($invite_amount_tuandui >= $level['invite_amount_tuandui'] && $invite_amount >= $level['invite_amount'] && $invite_count >= $level['invite_count']){
                    $butie     = $level['butie'];
                    $yeji_rate = $level['yeji_rate'];

                    $yeji = bcdiv(bcmul($invite_amount,$yeji_rate,2),100,2);

                    $yingxiao_level = $level['id'];

                    //公司分红(a%平分，b%业绩加权)
                    $redis_key_a = $last_month . '_yingxiao_a_' . $yingxiao_level;
                    RedisUtil::getInstance($redis_key_a)->lPush($user_id);

                    //redis左推入当前用户
                    $redis_key_b = $last_month . '_yingxiao_b_' . $yingxiao_level;
                    RedisUtil::getInstance($redis_key_b)->lPush([
                        'user_id' => $user_id,'invite_amount_tuandui' => $invite_amount_tuandui,
                    ]);

                    continue;
                }
            }else{
                //营销员
                if($invite_amount >= 60000 && $invite_count_mon >= 5){
                    $butie     = $level['butie'];
                    $yeji_rate = $level['yeji_rate'];

                    $yeji = bcdiv(bcmul($invite_amount,$yeji_rate,2),100,2);

                    $yingxiao_level = $level['id'];

                    continue;
                }
            }
        }

        if($yingxiao_level != 0){
            if($butie > 0){
                //给 $user_id 发 补贴
            }
            if($yeji > 0){
                //给 $user_id 发 个人业绩
            }
        }

    }

    private function get_all_down_uids($user_id){
         return $user_id;
    }

    //每月初执行，跑代理辅助表，把上个月的数据全部推送到 代理队列
    public function task_agent(){
        $last_month =  date('Ym',strtotime(date('Y-m-01')) - 86400); //上个月一号，202502

        $agent_month = Db::name('agent_month')->where('month_date',$last_month)->where('status',0)->column('id');

        //推送到代理job

        //修改状态
        Db::name('agent_month')->where('id','IN',$agent_month)->update([
            'status'     => 1,
            'updatetime' => time(),
        ]);
    }

    //代理job，跑完代理队列里的每一条
    public function job_agent($agent_month_id){

        $agent_month = Db::name('agent_month')->where('id',$agent_month_id)->find();
        if($agent_month['status'] != 1){
            //结束
            return;
        }

        $area = Db::name('shopro_data_area')
            ->where('id','IN',[$agent_month['province_id'],$agent_month['city_id'],$agent_month['district_id']])
            ->where('user_id','>',0)
            ->where('back_rate','>',0)
            ->select();

        if(empty($area)){
            //结束
            return;
        }

        //省市县执行三次
        foreach($area as $key => $agent){

            $agent_money = bcdiv(bcmul($agent_month['back_amount'],$agent['back_rate'],2),100,2);

            //发钱
            if($agent_money > 0){
                $agent['user_id'];
            }
        }

        //状态改为已发放
        Db::name('agent_month')->where('id',$agent_month_id)->update([
            'status' => '2',
            'exec_time' => time(),
        ]);


    }

    /**
     * 需要登录的接口
     *
     */
    public function test2()
    {
        echo 111;exit;
        $amount = 1000;
        $rate = 15;
        $data = [];

        for($i=1;$i<=40;$i++){


            $data[] = [
                'amount' => $amount,
            ];

            $amount = bcdiv(bcmul($amount,$rate,2),100,2);
        }

        dump($data);
//        Db::name('back_base')->insertAll($data);

    }

    /**
     * 需要登录且需要验证有相应组的权限
     *
     */
    public function test3()
    {
        //$this->success('返回成功', ['action' => 'test3']);
        $data = [
            'order_paidnum'      => ['inc',1],
            'order_total_amount' => ['inc',11.25],
            'goods_sales'        => ['inc',5],
        ];
        Db::name('live_room_log')->where('id',23)->update($data);
    }

}