test1($order_amount,$rate,$user_id,$shop_id); } /* * 订单额,返利比例 * $table : offline_shop , * */ public function test1($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),2); $shangwu_invite_id = Db::name($table_name)->where('id',$shop_id)->value('invite_id'); //发钱给 $shangwu_invite_id if($shangwu_invite_id && $shangwu_amount > 0){ } //锁客 发给消费者的上级 收益 $suoke_rate = config('site.back_suoke'); $suoke_amount = bcdiv(bcmul($amount,$suoke_rate,2),2); $suoke_invite_id = Db::name('user')->where('id',$user_id)->value('invite_id'); //发钱给 $suoke_invite_id if($suoke_invite_id && $suoke_amount > 0){ } //网体 业务员逻辑 按月发 收益 //省代,市代,区代 三个代理 都按月发 收益 } //每月初执行,跑代理辅助表,把上个月的数据全部推送到 代理队列 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); } }