mingxiang/application/index/controller/Plantask.php

<?php

namespace app\index\controller;
use think\Controller;
use think\Db;
use app\common\model\Wallet;

class Plantask extends Controller
{
    public function index()
    {
        exit;
    }




    //推荐奖励
    //订单支付回调之后的任务,每分钟运行
    //烧伤
    public function auto_order_paid(){

        $map = [
            'status' => 1,
            'have_paid' => ['gt',0],
            'paidtasktime' => 0,
        ];
        $order_list = Db::name('unishop_order')->where($map)->order('id asc')->limit(10)->select();
        if(empty($order_list)){
            echo '没有数据';
            exit;
        }

        Db::startTrans();
        $walletmodel = new Wallet();

        foreach($order_list as $key => $order){

            //直推代理商获益
            $intro_uid = Db::name('user')->where('id',$order['user_id'])->value('intro_uid');
            if($intro_uid){

                //直推的第一单金额，烧伤
                $map = [
                    'status' => 1,
                    'have_paid' => ['gt',0],
                    'user_id' => $intro_uid,
                ];
                $first_order = Db::name('unishop_order')->where($map)->order('have_paid asc')->value('order_price');
                $first_order = $first_order ?: 0;

                $jishu = $order['order_price'];
                $remark_shaoshang = '';
                if($first_order < $order['order_price']){
                    $jishu = $first_order;
                    $remark_shaoshang = '(烧伤)';
                }

                //奖励
                $bili = config('site.orderpaid_zhitui_bili') ?: 5;
                $score = bcdiv(bcmul($jishu,$bili,2),100,2);
                if($score > 0){
                    $rs_wallet = $walletmodel->lockChangeAccountRemain($intro_uid,'score',$score,3,'直推代理奖励'.$remark_shaoshang,'unishop_order',$order['id'],$order['user_id']);
                    if($rs_wallet['status'] === false){
                        echo $rs_wallet['msg'];
                        Db::rollback();
                        exit;
                    }
                }
            }

            //订单完成
            $rs_order = Db::name('unishop_order')->where('id',$order['id'])->update(['paidtasktime'=>time()]);
            if($rs_order === false){
                echo '更新失败';
                Db::rollback();
                exit;
            }

            //循环结束
        }

        Db::commit();
        echo '成功'.count($order_list);
    }

    //总代奖励
    //自动结算10日前订单,每分钟运行
    public function auto_jiesuan_order(){
        $nowtime = time();
        $toweek  = date('w',$nowtime);
        if($toweek == 0){
            //周日不结算（自动到下周一结算）
            echo '周日不结算';
            exit;
        }

        $tendays_ago = jiesuan_tendays_ago();
//        echo $tendays_ago;exit;
        //
        Db::startTrans();
        $order_map = [
            'status'      => 1,
            'have_paid'   => ['lt',$tendays_ago],
            'jiesuantime' => 0,
        ];
        $order = Db::name('unishop_order')->where($order_map)->where('have_paid','gt',0)->order('id asc')->lock(true)->find();
        if(empty($order)){
            echo '没有数据';
            Db::rollback();
            exit;
        }
//        dump($order);

        //买家得到收益
        if($order['order_shouyi'] > 0){
            $rs_wallet = model('wallet')->lockChangeAccountRemain($order['user_id'],'score',$order['order_shouyi'],5,'下单收益','unishop_order',$order['id'],$order['user_id']);
            if($rs_wallet['status'] === false){
                echo $rs_wallet['msg'];
                Db::rollback();
                exit;
            }
        }


        //为上级做贡献，找到上级
        $intro_uid = Db::name('user')->where('id',$order['user_id'])->value('intro_uid');
        if(empty($intro_uid)){
            echo '没有上级，结束';
            Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>time()]);
            Db::commit();
            exit;
        }


        //获取业绩
        $yeji = $this->jiesuan_yeji($intro_uid);
//        dump($yeji);

        //确定代理商等级，拿对应比例
        $rule = $this->jiesuan_daili_level($yeji);
        if($rule['bili'] == 0){
            echo '达不到第一级,结束';
            Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>time()]);
            Db::commit();
            exit;
        }
//        dump($rule);

        //给直推
        $score = bcdiv(bcmul($order['order_shouyi'],$rule['bili'],2),100,2);
//        dump($score);
        if($score > 0){
            $rs_wallet = model('wallet')->lockChangeAccountRemain($intro_uid,'score',$score,6,$rule['name'].'代理','unishop_order',$order['id'],$order['user_id']);
            if($rs_wallet['status'] === false){
                echo $rs_wallet['msg'];
                Db::rollback();
                exit;
            }
        }


        //标记为结算
        $jiesuan = Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>$nowtime]);
        if($jiesuan === false){
            echo '修改状态失败';
            Db::rollback();
            exit;
        }
        //批发的都卖出
        $pifa = Db::name('unishop_order_product')->where('order_id',$order['id'])->update(['pifa_status'=>1]);
        if($pifa === false){
            echo '修改状态失败2';
            Db::rollback();
            exit;
        }

        Db::commit();
        echo '完成'.$order['id'];
    }
    //获取业绩
    private function jiesuan_yeji($user_id){
        //找到所有下级
        //$user_ids = Db::name('user')->where('find_in_set(:intro_ids,intro_ids)', ['intro_ids' => $user_id])->column('id');
        $commonuser = new \app\common\model\User();
        $user_ids = $commonuser->my_down_all($user_id,[$user_id]);
//        dump($user_ids);

        if(empty($user_ids)){
            return 0;
        }

        $map = [
            'status' => 1,
            'have_paid' => ['gt',0],
            'user_id' => ['IN',$user_ids],
        ];
        $yeji = Db::name('unishop_order')->where($map)->sum('order_price');
        return $yeji;
    }



    //确认代理等级及规则
    private function jiesuan_daili_level($yeji){

        $data = Db::name('zongdai')->order('id asc')->select();
//        dump($data);

        $return = $data[0]; //默认第0个
        foreach($data as $key => $rule){
            if($yeji >= $rule['yeji']){
                $return = $rule;
            }
        }

        return $return;
    }


}