insert(['data'=>'汇付支付回调---'.json_encode($type)]); set_time_limit(0); $post = Request::param(); Db::name("log")->insert(array('data'=>'【汇付异步接受到的参数】'.json_encode($post),));//日志记录 $post_data_str = isset($post['data']) ? $post['data']: ''; $post_sign_str = isset($post['sign']) ? $post['sign']: ''; # 先校验签名和返回的数据的签名的数据是否一致 $adapay_tools=new AdapayTools(); if ($post['app_id'] == 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0'){ AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAKvkKGN19wxH9Uusx8gXnt89oYbgvIRkzO2pD0nzSF/MS65m2j5DgKMG5lryL6bfco2p9syoxKI7IE9pLFtFTyI477cNoUsvWiIYikx5uKz0CDdBcR8AAapfrs5XKgJMcogulqDm4/7QUDuQJoATdvEpA6yfiaW2EqSnMpvZKsdFAgMBAAECgYAgmVOjkUK6HIeDw4/b/cbOlbSljMeT4D4RMIfKwY3PRUJxH+Zx+oFR6cQUKWwqHKRwA3Tf2X35OndlOBAGez2Hc1M08brGSlCB/Ze654mOP5H+bImKfmWQxJiVbbY4ef6msgNAp+FicWLvo6WDuymmP7gvoQbC5E90tRKDCvyawQJBANy/GaYU209Dikbd6E2rWKaS9dgx9f/wZOqmUMUzsDicMO4nK1qojyEm8inkoSRyzv0vLXqD/j/buhE4FjO/YbECQQDHV66K4NKNvuKAbI0NNXothxe2PS6lJrBU5QWgt4Q6CsQ8v+WyFq9AUjEahN11Evm2DCnEBddZKmSctZTgry/VAkAgCEMKjKA+Ykige/cHvkOA+HZgRu+xkgqy2iuCUjvSGygmhtyNrUQHxYUCe0C+70IGD2CEFL9COPpJIWBnZfAhAkATbV0qVbzPaaIDaBDbD7Ini7no3c+U8s9Ohr9kqV3uliwHy5/kGkfcGeaFMhuvFDlX35mWbAdPvkzt5NhsiUY9AkBNdE3yUz+f7A92oZr4bHX7r5gyUTumRiBYyiJ8dgMl6lT8OpQZpBxdswyWg2nkmPoCjoASZx8LoCBhsK4SBcfz'); }else{ AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX'); } // AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX'); // $adapay_tools->SetParams(); $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str); $post_data_str=json_decode($post_data_str,true); if ($sign_flag){ try { if(empty($post_data_str['error_msg'])){ Db::name("log")->insert(array('data'=>'【验签通过-支付】:时间：'.date('Y-m-d H:i:s',time()),));//日志记录 $requestId = []; if(strpos($post_data_str['order_no'],'_') !== false){ $requestId = explode("_",$post_data_str['order_no']); } $pay_type = $post_data_str['pay_channel']; $pay_type = $pay_type == 'wx_lite' ? 1 : 4; switch ($type){ case 'huafei': //话费充值支付成功推送 try{ $order_data = Db::name('order_huafei_hf') -> where('order_no', $requestId[0])->find(); if($order_data['status']==1) return false; Db::name('order_huafei_hf')->where('order_no',$requestId[0])->update([ 'rand'=>$requestId[1], 'pay_type'=>$pay_type, 'pay_wx'=>systemConfig('pay_wx'), 'app_id'=>$post['app_id'], 'payment_id'=>$post_data_str['id'], 'reverse_amt'=>$post_data_str['pay_amt'], 'status'=>1 ]); }catch (\Exception $e) { Db::name('log')->insert(['data'=>'话费充值支付回调错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']); } //话费充值支付成功推送 try{ $push = app()->make(Huafei::class)->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price'], $order_data['order_id']); if($push['code'] != '0000'){ $pay_wx = systemConfig('pay_wx'); //推送失败 给新支付的这一笔退款 Db::name('log')->insert(['data' => '给新话费充值支付的这一笔退款']); if ($pay_wx == 3){ $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871'; }else{ $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f'; } $refund_traits = [ 'payment_id' => $post_data_str['id'], 'app_id' => $post['app_id'], 'order_no' => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(), 'reverse_amt' => $post_data_str['pay_amt'], 'notify_url' => env('APP_URL') . "/api/hf_notify/reverse_order", ]; $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type == '1' ? 2 : 1, $pay_wx, $key); Db::name('log')->insert(['data'=>'话费充值汇付支付撤销返回结果：'.json_encode($hf_refund_res)]); //把赠送出去的养老金 积分 贡献值 复购金 改为已失效 Db::name('user_bill')->where('order_sn', $order_data['order_no'])->update(['status'=> -1]); Db::name('user_sign_score')->where('order_id', $order_data['order_no'])->update(['status'=> 0]); Db::name('user_sign_gongxian')->where('order_id', $order_data['order_no'])->update(['status'=> 0]); Db::name('user_sign_fugou')->where('order_id', $order_data['order_no'])->update(['status'=> 0]); Db::name('user_sign_hongbao')->where('order_id', $order_data['order_no'])->update(['status'=> 0]); } }catch (\Exception $e) { Db::name('log')->insert(['data'=>'话费充值支付回调推送订单错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']); } break; case 'pay': //商城集合订单 Db::name('store_group_order') -> where('group_order_sn',$requestId[0]) -> update(['rand'=>$requestId[1]]); // 判断代付是否支付过 $group_order = Db::name('store_group_order')->where('group_order_sn', $requestId[0])->find(); $group_order_id = $group_order['group_order_id']??''; $old_pay_open_id = Db::name('store_order')->where('group_order_id', $group_order_id)->value('pay_open_id'); if ($old_pay_open_id && $old_pay_open_id != $post_data_str['expend']['open_id']) { // 给新支付的这一笔退款 Db::name('log')->insert(['data' => '给新支付的这一笔退款']); if ($group_order['pay_wx'] == 3){ $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871'; }else{ $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f'; } $refund_traits = [ 'payment_id' => $post_data_str['id'], 'app_id' => $post['app_id'], 'order_no' => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(), 'reverse_amt' => $post_data_str['pay_amt'], 'notify_url' => env('APP_URL') . "/api/hf_notify/reverse_order", ]; // $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type['pay_type'] == '1' ? 2 : 1, $group_order['pay_wx'], $key); $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type == '1' ? 2 : 1, $group_order['pay_wx'], $key); Db::name('log')->insert(['data'=>'汇付支付撤销返回结果：'.json_encode($hf_refund_res)]); break; } $post_data_str['expend']['open_id'] = $post_data_str['expend']['open_id'] ?? ''; //start //分配逻辑 // $store_order_data = Db::name('store_order')->where('group_order_id', $group_order_id)->find(); //精彩生活 // if($store_order_data['mer_id'] == 439){ // if(!empty($store_order_data)){} // } //$group_order = Db::name('store_group_order')->where('group_order_sn',$group_order_id)->find(); //var_dump($group_order['group_order_id']);return; //分配逻辑 $store_order_data = Db::name('store_order')->where('group_order_id',$group_order_id)->find(); //找到对应的商品id(product_id) $store_order_product_data = Db::name('store_order_product')->where('order_id',$store_order_data['order_id'])->find(); //找到对应的商品让利金额或比例 $store_product_data = Db::name('store_product')->where('product_id',$store_order_product_data['product_id'])->find(); //找到对应的商品id的规格 $store_product_attr_value = Db::name('store_product_attr_value')->where('product_id', $store_order_product_data['product_id'])->find(); //下单用户 $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find(); // $concession_pri = $store_product_data['concession_pri'];//商家让利金额 $concession_pri = $store_order_data['con_pri']; $spread_uid = 0;//下单用户上级uid $fgj_pri=0;//推广者的佣金抽10%到个人复购金 $pv = 0; //待分配的PV $wenan = ''; //var_dump($store_product_data['concession_pri']);return; //精彩生活 if($store_order_data['mer_id'] == 439){ $wenan = '精彩生活'; //分配参数 $job_par = []; if(!empty($store_order_data)){ $job_par = json_decode($store_order_data['fzone_paytype'], true); //if($job_par['note'] == "现金"){ //普通消费者 $ylj_pri = bcmul($concession_pri, 0.3,2); $pv = bcmul($concession_pri, 0.35,2); //分配养老金给消费者 $ylj_amount_mine = $user_data['annuity'] + $ylj_pri; //分配积分和贡献值给消费者 $con = $user_data['contribute'] + $pv; $score = $user_data['score'] + $pv; //Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,"contribute"=>$con,"score"=>$score]); $this->bill_user_log($user_data['uid'],$ylj_pri,$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.$ylj_pri,$store_order_data['mer_id'],0); $this->con_log_pv($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送pv"); $this->con_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送贡献值"); $this->score_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送积分"); if (!empty($user_data['is_old'])) { // 红包 $this->giveHongBao($user_data['uid'], $pv, $store_order_data['order_id'], '购买精彩生活商品赠送红包'); } //给推广者分配养老金 //给推广者分配佣金 // if ($user_data['spread_uid'] != 0) { //查询下单用户上级身份 $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find(); $StoreOrderRepository = app()->make(StoreOrderRepository::class); $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']); if ($spread_data['user_group'] == 1) { $yj_amount_90 = bcmul($pv * 0.9, $rate, 2); $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金 $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1); //推广养老金 //推广佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0); // 贡献值 $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 11, "推广精彩生活商品赠送贡献值"); //积分 $this->score_log($spread_data['uid'], bcmul($pv, $rate, 2), $store_order_data['order_id'], 11, "推广精彩生活商品赠送积分"); } else if ($spread_data['user_group'] > 1) { $ssf = bcmul($pv, $rate, 2); $yj_amount_90 = bcmul($pv * 0.9, $rate, 2); $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金 $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1); //贡献值 $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 11, "推广精彩生活区商品赠送贡献值"); //积分 $this->score_log($spread_data['uid'], $ssf, $store_order_data['order_id'], 11, "推广精彩生活区商品赠送积分"); // //推广佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0); //养老金 $this->bill_user_log($spread_data['uid'], bcmul($pv, 0.05, 2), $store_order_data['order_id'], 5, $store_order_data['order_sn'], '推广获得养老金' . bcmul($pv, 0.05, 2), $store_order_data['mer_id'], 0); } //锁客收益 if($user_data['mer_id'] != 0){ $merchant_data = Db::name('merchant')->where('mer_id',$user_data['mer_id'])->find(); $merchant_user_data = Db::name('user')->where('uid',$merchant_data['uid'])->find(); if(!empty($merchant_user_data)){ //$merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.05,2); //给推广者分配佣金 $yj_amount_90 = bcmul($pv, 0.05,2) * 0.9; $fgj_amount_10 = bcmul($pv, 0.05,2) * 0.1;//推广者的佣金抽10%到个人复购金 $yj_amount = $merchant_user_data['brokerage_price'] + $yj_amount_90; $fgj_amount = $merchant_user_data['fugou'] + $fgj_amount_10; $this->fugou_user_log($merchant_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1); //Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]); //推广佣金 $this->bill_user_log($merchant_data['uid'], $yj_amount_90,$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金'. $yj_amount_90,$store_order_data['mer_id'],0); } } //} //var_dump($ylj_amount); } //VIP专区 }else if($store_order_data['mer_id'] == 496){ $wenan = '会员专区'; //业务员和以上推广的等级获得推广佣金 $le_yw_amount = 0; //获赠的贡献值和积分 $gx_jf = 0; $yj1 = 0; if($store_product_data['price'] == 1180){ $pv = 1000; $gx_jf = 700; $yj1 = 100; $le_yw_amount = 300; }else if($store_product_data['price'] == 10620){ $pv = 9000; $gx_jf = 6300; $yj1 = 900; $le_yw_amount = 2700; }else if($store_product_data['price'] == 11800){ $pv = 10000; $gx_jf = 7000; $yj1 = 1000; $le_yw_amount = 3000; }else if($store_product_data['price'] == 9440){ $pv = 8000; $gx_jf = 5600; $yj1 = 800; $le_yw_amount = 2400; }else if($store_product_data['price'] == 2360){ $pv = 2000; $gx_jf = 1400; $yj1 = 200; $le_yw_amount = 600; } $ylj_pri = bcmul($pv, 0.035,2); //$pv = round($pv * 0.35,2); //分配养老金给消费者 //普通用户获取贡献值和pv3.5%养老金和积分 $ylj_amount_mine = $user_data['annuity'] + $ylj_pri; $gxz_amount_mine = $user_data['contribute'] + $gx_jf; $jf_amount_mine = $user_data['score'] + $gx_jf; //Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,'contribute'=> $gxz_amount_mine,'score'=> $jf_amount_mine]); $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']); $this->con_log_pv($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送pv",1); // $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1); $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1); $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送积分",1); //查询下单用户上级身份（2.0新表用户） $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find(); //查询下单用户上级身份（1.0表用户，会员升级） $spread_data_old = 0; if($user_data['spread_old'] != 0){ $sf = Db::name('old_user_jbp')->where('id',$user_data['invite_id_od'])->find(); if(!empty($sf)){ $spread_data_old = $sf; } } //给推广者分配养老金 //给推广者分配佣金(2.0系统中) // if ($user_data['spread_uid'] != 0) { if ($user_data['uid'] > 611) { $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find(); //user_group=1是消费者，2:业务，3:业务经理，4:初级合伙人，5:中级合伙人,6:高级合伙人，7：董事 //业务或以上等级推广人 //获得养老金、佣金、贡献值和积分 if($spread_data['user_group'] > 1){ $con =0;//贡献值 $score = 0;//积分 //养老金 $uer_bill = $spread_data['annuity'] + bcmul($pv, 0.035,2); $yj_amount_90 = $le_yw_amount * 0.9; $fgj_amount_10 = $le_yw_amount * 0.1;//推广者的佣金抽10%到个人复购金 $yongjin = $spread_data['brokerage_price'] + $yj_amount_90; $fgj_amount = $spread_data['fugou'] + $fgj_amount_10; if($spread_data['user_group'] == 2){ $con = $spread_data['contribute'] + bcmul($pv, 0.07,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.07,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 // $this->con_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 //$this->score_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); }else if($spread_data['user_group'] == 3){ $con = $spread_data['contribute'] + bcmul($pv, 0.09,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.09,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 // $this->con_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 //$this->score_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); }else if($spread_data['user_group'] == 4){ $con = $spread_data['contribute'] + bcmul($pv, 0.11,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.11,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 // $this->con_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 // $this->score_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); }else if($spread_data['user_group'] == 5){ $con = $spread_data['contribute'] + bcmul($pv, 0.13,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.13,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 // $this->con_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 // $this->score_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); }else if($spread_data['user_group'] == 6){ $con = $spread_data['contribute'] + bcmul($pv, 0.15,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.15,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 //$this->con_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 // $this->score_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); }else if($spread_data['user_group'] == 7){ $con = $spread_data['contribute'] + bcmul($pv, 0.17,2); $score = $spread_data['brokerage_price'] + bcmul($pv, 0.17,2); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]); //贡献值 //$this->con_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //积分 //$this->score_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); } $this->score_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); $this->con_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //养老金 $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']); //佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90,$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金'. $yj_amount_90,$store_order_data['mer_id']); //复购金 $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1); } //普通的用户推广人 if($spread_data['user_group'] == 1){ // $yj_amount = $spread_data['annuity'] + round($pv * 0.01,2); // Db::name('user')->where('uid',$user_data['spread_uid'])->update(['annuity'=>$ylj_amount,'brokerage_price'=>$yj_amount]); // //推广养老金 // $this->bill_user_log($user_data['spread_uid'],round($pv * 0.01,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'推广获得养老金'.round($pv * 0.01,2),$store_order_data['mer_id']); // //推广佣金 // $this->bill_user_log($user_data['spread_uid'],round($pv * 0.01,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得佣金'.round($pv * 0.01,2),$store_order_data['mer_id']); //获取贡献值和积分和佣金 $gx_jf = $spread_data['contribute'] + bcmul($pv, 0.3,2); //$yj111 = $spread_data['brokerage_price'] + $yj1; $yj_amount_90 = bcmul($yj1, 0.9,2); $fgj_amount_10 = bcmul($yj1, 0.1,2);//推广者的佣金抽10%到个人复购金 $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90; $fgj_amount = $spread_data['fugou'] + $fgj_amount_10; $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1); //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $gx_jf,'score'=> $gx_jf,'brokerage_price'=> $yj_amount,'fugou'=>$fgj_amount]); $this->con_log($spread_data['uid'],round($pv * 0.3,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); $this->score_log($spread_data['uid'],round($pv * 0.3,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1); //推广佣金 $this->bill_user_log($spread_data['uid'],$yj_amount_90,$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金'.$yj_amount_90,$store_order_data['mer_id']); } }else if($spread_data_old != 0){ //1.0jbp系统中，如果有用户升级会员，给推荐人贡献值(90%)和养老金(10%) $spread_data = Db::name('user')->where('uid',$spread_data_old['id'])->find(); // $spread_data = Db::name('user')->where('uid',473)->find(); //养老金 $uer_bill = $spread_data['annuity'] + bcmul($pv, 0.035,2); $yj_amount_90 = bcmul($le_yw_amount,0.9,2); $fgj_amount_10 = bcmul($le_yw_amount,0.1,2);//推广者的佣金抽10%到个人复购金 $yongjin = $spread_data['brokerage_price'] + $yj_amount_90; $fgj_amount = $spread_data['fugou'] + $fgj_amount_10; $this->con_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1); //养老金 $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']); //佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90,$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金'. $yj_amount_90,$store_order_data['mer_id']); //复购金 $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1); $orderInfo=[ 'num'=>1, 'gb_num'=>1, 'price'=>$store_product_data['price'] ]; $goods_of_info1 = Db::name("old_user_of_goods")->where("id", $store_order_data['user_of_goods_id'])->find();//用户的订单价格表 if(!empty($goods_of_info1)){ // $spread_data = Db::name('test_log')->insert(['note'=>"goodsofinf22222o:".json_encode($goods_of_info1)]); $this->member_update($orderInfo,$goods_of_info1,$user_data['uid']); } } //锁客收益 if($user_data['mer_id'] != 0){ $merchant_data = Db::name('merchant')->where('mer_id',$user_data['mer_id'])->find(); $merchant_user_data = Db::name('user')->where('uid',$merchant_data['uid'])->find(); if(!empty($merchant_user_data)){ $yj_amount_90 = bcmul($pv * 0.9, 0.035,2); $fgj_amount_10 = bcmul($pv * 0.1, 0.035,2);//推广者的佣金抽10%到个人复购金 $yj_amount = $merchant_data['brokerage_price'] + $yj_amount_90; $fgj_amount = $merchant_data['fugou'] + $fgj_amount_10; $this->fugou_user_log($merchant_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1); //Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]); //推广佣金 $this->bill_user_log($merchant_data['uid'],round($pv * 0.35,2),$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金'.round($pv * 0.35,2),$store_order_data['mer_id']); } } $fzone_paytype = json_decode($store_order_data['fzone_paytype'],true); $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find(); //会员专区的现金+VR支付 if($fzone_paytype['type'] == 'a3'){ $dev_vr = $user_data['vr'] - $fzone_paytype['other']; if($dev_vr >= 0){ $user_data_dev_vr = Db::name('user')->where('uid',$store_order_data['uid'])->update(["vr"=>$dev_vr]); if($user_data_dev_vr){ //支出账号存到log日志 $log_data = [ 'uid'=>$user_data['uid'], 'number'=>$fzone_paytype['other'], 'mark'=>"购买会员专区商品消费VR:" . $fzone_paytype['other'], 'desc'=>"VR", 'order_id'=>0, 'surplus'=>$dev_vr, 'order_type'=>0, 'type'=>2, 'addtime'=>time() ]; $user_res_log = Db::name("user_sign_vr")->insert( $log_data); } }else{ $log_data = [ 'note'=>"uid:" . $store_order_data['uid'] . " 购买会员专区商品消费VR:" .$fzone_paytype['other'] . " 用户消费前的VR余额:" . $user_data['vr'] . "描述:" ."未扣成功!" . "备注:" . json_encode($fzone_paytype), 'create_time'=>date("Y-m-d H:i:s",time()) ]; Db::name("test_log")->insert( $log_data); } } //会员专区，给用户升级判断 $orderList = Db::name("store_order")->where("uid", $store_order_data['uid'])->where("mer_id", 496)->where("status", "in", [0, 1, 2, 3])->select(); // 初始化总和变量 $totalPayPrice = 0; // 遍历查询结果 foreach ($orderList as $order) { // 累加 pay_price $totalPayPrice += $order['pay_price']; } $userdata = Db::name("user")->where("uid", $store_order_data['uid'])->find(); if ($totalPayPrice >= 1180 && $totalPayPrice < 11800) { if ($userdata['user_group'] <= 1) { Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 2]); } } else if ($totalPayPrice >= 11800) { if ($userdata['user_group'] <= 2) { Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 3]); } } } else { $wenan = '商贸区'; // 商贸区 /** @var \app\common\repositories\merchant\MerchantRepository $merchant */ $merchant = app()->make(MerchantRepository::class); $merchantInfo = $merchant->get($store_order_data['mer_id']); // 1企业2个体3个人 if ($merchantInfo && !empty($store_order_data) && in_array($merchantInfo['type'], [2, 3])) { //商家让利部分的拆分 $ylj_pri = bcmul($concession_pri, 0.3, 2); // 让利部分30%给消费者做养老金 $pv = bcmul($concession_pri, 0.35, 2); // 35%做业绩PV分配 // 让利部分30%给消费者做养老金{$ylj_pri} $this->bill_user_log($user_data['uid'], $ylj_pri, $store_order_data['order_id'], 5, $group_order['group_order_sn'], '购买商贸区商品获得养老金' . $ylj_pri, $store_order_data['mer_id'], 0); // 购买商贸区赠送贡献值 $this->con_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送贡献值"); // 购买商贸区赠送PV值 $this->con_log_pv($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区赠送PV值"); // 积分 $this->score_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送积分"); if (!empty($user_data['is_old'])) { // 红包 $this->giveHongBao($user_data['uid'], $pv, $store_order_data['order_id'], '购买商贸区商品赠送红包'); } $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find(); if($spread_data) { $StoreOrderRepository = app()->make(StoreOrderRepository::class); $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']); if ($spread_data['user_group'] == 1) { $yj_amount_90 = bcmul($pv * 0.9, $rate, 2); $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金 $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1); //推广养老金 //推广佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0); // 贡献值 $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 11, "推广商贸区商品赠送贡献值"); //积分 $this->score_log($spread_data['uid'], bcmul($pv, $rate, 2), $store_order_data['order_id'], 11, "推广商贸区商品赠送积分"); } else if ($spread_data['user_group'] > 1) { $ssf = bcmul($pv, $rate, 2); $yj_amount_90 = bcmul($pv * 0.9, $rate, 2); $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金 $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1); //贡献值 $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 11, "推广商贸区商品赠送贡献值"); //积分 $this->score_log($spread_data['uid'], $ssf, $store_order_data['order_id'], 11, "推广商贸区商品赠送积分"); // //推广佣金 $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0); //养老金 $this->bill_user_log($spread_data['uid'], bcmul($pv, 0.05, 2), $store_order_data['order_id'], 5, $store_order_data['order_sn'], '推广获得养老金' . bcmul($pv, 0.05, 2), $store_order_data['mer_id'], 0); } } //锁客收益 if ($store_order_data['mer_id'] > 0) { $merchant_data = Db::name('merchant')->where('mer_id', $store_order_data['mer_id'])->find(); $merchant_user_data = Db::name('user')->where('uid', $merchant_data['uid'])->find(); if (!empty($merchant_user_data)) { //给推广者分配佣金 $yj_amount_90 = bcmul($pv * 0.9, 0.05, 2); $fgj_amount_10 = bcmul($pv * 0.1, 0.05, 2);//推广者的佣金抽10%到个人复购金 $this->fugou_user_log($merchant_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1); //推广佣金 $this->bill_user_log($merchant_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $group_order['group_order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0); } /** @var OrderMerchantRepository $orderMerchantRepository */ $orderMerchantRepository = app()->make(OrderMerchantRepository::class); $jdAndGonxianConfig = $orderMerchantRepository->getMerchantContribution($store_product_attr_value['extension_one']); //商户获得贡献值 ---- 3月29日 商户不再获得贡献值 改为获得分润值 // if ($concession_pri >= 0.01) { // $gonxian = bcmul($concession_pri, $jdAndGonxianConfig['gonxian'], 2); // $gongxian_data = [ // "uid" => $merchant_data["uid"], // "mer_id" => $user_data['mer_id'], // "pv" => $pv, // "number" => $gonxian, // "addtime" => time(), // "status" => -1, // "order_type" => 2, // "order_id" => $store_order_data['order_id'], // "mark" => "锁客商家获得贡献值", // "desc" => '', // "surplus" => $gonxian, // "type" => 1 // ]; // Db::name("user_sign_gongxian")->insert($gongxian_data);//添加记录 // } else { // Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，贡献值低于0.01无法入库 特此记录！']); // } //商户获得京豆 $jd = bcmul($concession_pri, $jdAndGonxianConfig['jd'], 2); if ($jd >= 0.01) { $jd_data = [ "uid" => $merchant_data["uid"], "mer_id" => $store_order_data['mer_id'], "number" => $jd, "addtime" => time(), "status" => -1, "order_type" => 2, "order_id" => $store_order_data['order_id'], "mark" => "线上用户消费商家获得京豆", "desc" => '', "surplus" => $jd, "type" => 1 ]; Db::name("user_sign_jingdou")->insert($jd_data);//添加记录 } else { Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，京豆低于0.01无法入库 特此记录！']); } } } } //判断是否是精彩生活区的商品 if($store_order_data['mer_id'] == 439){ //供应链的状态 Db::name('store_order')->where('group_order_id', $group_order_id)->update(['douhuomall'=>1,'douhuomall_status'=>9]); } //判断是否是自营商品，如果是自营商品需要更改这个值 if($store_order_data['mer_id'] == 496){ //自营商品 Db::name('store_order')->where('group_order_id', $group_order_id)->update(['distribution_mode'=>1]); } //利润分配 end //商城订单 //判断下，如果是组合支付中，现金+积分的形式支付情况下 $array_fzone_paytype = json_decode( $store_order_data['fzone_paytype'],true); if($array_fzone_paytype['type']=='b2'){ if(!empty($array_fzone_paytype['other']) && is_numeric($array_fzone_paytype['other']) == true){ $vrpri = $user_data['score'] - $array_fzone_paytype['other']; // // //现金+积分 if($vrpri >= 0 ){ Db::name("user")->where("uid", $user_data['uid'])->update(['score'=>$vrpri]); //消费积分日志 $log_data = [ "uid" => $user_data['uid'], "reward_socre" => $array_fzone_paytype['other'], "addtime" => time(), "status" => 1, "order_id" => $store_order_data['order_id'], "mark" => "购买" . $wenan . "商品消费积分", "surplus" => $vrpri, "pm" => 2, "source_type" => 5 ]; Db::name("user_sign_score")->insert($log_data); }else{ $note_arr = ["uid"=>$user_data['uid'],"dec_score"=>$array_fzone_paytype['other'],"rem_score"=>$user_data['score'],"msg"=>"积分不足","fzone_paytype"=>$store_order_data['fzone_paytype']]; Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]); } }else{ $note_arr = ["uid"=>$user_data['uid'],"msg"=>"数据异常","fzone_paytype"=>$store_order_data['fzone_paytype']]; Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]); } } //end 现金+积分 //如果注释了event事件，需要手动修改订单状态 1：代发货 Db::name('store_order')->where('group_order_id', $group_order_id)->update(['status'=>0]); $orderss = Db::name('store_order')->where('group_order_id', $group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s'),'pay_open_id' => $post_data_str['expend']['open_id']]); Db::name('store_group_order')->where('group_order_id',$group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s')]); event('pay_success_order', ['order_sn' => $requestId[0],'pay_type'=>$pay_type]); break; case 'pay_channel': //渠道商 try{ $order_data=Db::name('channel_order') -> where('order_no',$requestId[0]) -> find(); if($order_data['status']==1){ return false; } $pay_type = $pay_type == 1 ? 'wx' : 'al'; Db::name('channel_user')->where('uid',$order_data['uid'])->update(['status'=>1]); Db::name('channel_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'pay_type'=>$pay_type,'status'=>1]); }catch (\Exception $e) { Db::name('log')->insert(['data'=>'支付渠道商错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']); } try{ $access = new Access(); //分佣 $access->channel_fenyong($requestId[0]); // //给7个激活码 // for($i=0;$i<=6;$i++){ // Db::name('activation_code')->insertGetId([ // 'uid'=>$order_data['uid'], // 'code'=>$this->randomFromDev(20), // 'ctime'=>time(), // 'status'=>1, // 'utime'=>time(), // 'use_uid'=>0, // 'type'=>2 // ]); // } //赠送返本商户 $mer = Db::name('user_mer') -> where('uid',$order_data['uid']) -> find(); if(!$mer){ Db::name('user_mer') -> insert(['uid'=>$order_data['uid'],'mer'=>10]); }else{ Db::name('user_mer') -> where('uid',$order_data['uid'])->inc('mer', 10) ->update();; } //赠送商户 $merchant=Db::name('merchant')->where('uid',$order_data['uid'])->find(); if(!$merchant) Db::name('merchant_intention')->insert(['uid'=>$order_data['uid'],'status'=>3,'activation_code'=>rand('000000000','999999999')]); //赠送大仓会员资格 $dacang_user = Db::name('da_cang_user')->where('uid', $order_data['uid'])->find(); $time = date('Y-m-d', time()); $time = strtotime($time); $end_time = $time + 31536000 - 1; $dc_id = 1; //如果不是金卡会员,赠送金卡会员一年 if (!$dacang_user) { Db::name('da_cang_user')->insert(['uid' => $order_data['uid'], 'ctime' => time(), 'end_time' => $end_time, 'dc_id' => $dc_id,'status'=>1,'type'=>1]); }else{ //如果是银卡会员,变成金卡，一年 || 是否已过期,如果已过期,赠送金卡会员一年 if($dacang_user['type'] == 2 || $dacang_user['end_time'] < $time){ Db::name('da_cang_user')->where('uid', $order_data['uid'])->where('dc_id', $dc_id)->update(['end_time' => $end_time,'status'=>1,'type'=>1]); } } }catch (\Exception $exception){ Db::name('log')->insert(['data'=>'渠道商处理错误：'.$exception->getFile().'：'.$exception->getLine().'【'.$exception->getMessage().'】']); } break; case 'pay_annual': //商户 $annual_cost_order=Db::name('merchant_annual_cost_order')-> where('order_no',$requestId[0])->find(); if($annual_cost_order['status'] == 0) { $pay_type = $pay_type == 1 ? 'wx' : 'al'; Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->update(['rand' => $requestId[1],'pay_type'=>$pay_type,'status' => 1]); //如果有商户id就是续费 $mer_id = Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->value('mer_id'); if ($mer_id !== 0) { $expire_time = strtotime(date('Y-m-d')) + 86400 * 365 + 86400 - 1; Db::name('merchant')->where('mer_id', $mer_id)->update(['expire_time' => $expire_time, 'status' => 1]); } $mer = Db::name('user_mer') -> where('uid',$annual_cost_order['uid']) -> find(); if(!$mer){ Db::name('user_mer') -> insert(['uid'=>$annual_cost_order['uid'],'mer'=>2]); }else{ Db::name('user_mer') -> where('uid',$annual_cost_order['uid'])->inc('mer', 2) ->update();; } $access = new Access(); $access->nianfei_yj($annual_cost_order['id']); } break; case 'pay_activation': try{ $order_data=Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> find(); if($order_data['status']==1){ return false; } $access = new Access(); $id=Db::name('activation_code')->insertGetId([ 'uid'=>$order_data['uid'], 'code'=>$access->randomFromDev(20), 'ctime'=>time(), 'status'=>1, 'utime'=>time(), 'use_uid'=>0, 'type'=>1 ]); Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'status'=>1,'code_id'=>$id]); }catch (\Exception $e) { Db::name('log')->insert(['data'=>'支付激活码错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']); } //处理佣金 $num=$access->activation_yj($requestId[0]); //分账 $access->activation_spilet($requestId[0],$num); break; case 'notify_order': Db::name("log")->insert(array('data'=>'汇付退款回调'));//日志记录 break; case 'marketing': $marketing_order=Db::name('marketing_order')-> where('order_no',$requestId[0])->find(); if($marketing_order['status']==1){ return app('json')->success(['result' => 'SUCCESS']); } // $pay_type = $pay_type == 1 ? 'wx' : 'ali'; $checkUser = Db::name("MarketingUser") -> where('uid',$marketing_order['uid'])->find(); $handle = $this -> marketing($marketing_order,$checkUser); if ($handle){ //分账 $this -> pay_user_annual($marketing_order['uid']); } break; case 'pay_user_annual': $user_pension_account_order=Db::name('user_pension_account_order')-> where('order_no',$requestId[0])->find(); if($user_pension_account_order['status']==1){ return app('json')->success(['result' => 'SUCCESS']); } $this -> pay_user_annual($user_pension_account_order['uid'],$requestId[0]); break; case 'movie': // 电影订单支付回调 /** @var MovieRepository $movieRepository */ $movieRepository = app()->make(MovieRepository::class); $movieRepository->updateMovieOrderAndcalculationCommissionDividendAward($pay_type, $requestId[0], $post_data_str); break; default: Db::name("log")->insert(array('data'=>$type));//日志记录 } } return app('json')->success(['result' => 'SUCCESS']); }catch (\Exception $exception){ Db::name("log")->insert(array('data'=>'汇付回调错误：'.$exception->getFile().'：'.$exception->getLine().'【'.$exception->getMessage().'】'));//日志记录 return app('json')->success(['result' => 'ERROR']); } } } /** * 会员升级 */ public function member_update($orderInfo,$goods_of_info,$user_id) { //code... $pay_gb = bcmul($orderInfo['num'], $orderInfo['gb_num'],2); //$pay_vr = round($orderInfo['num'] * $orderInfo['vr_num'],2); //付款按照700的VR付款 start $vr_num = 0; if ($orderInfo['price'] == 1180) { $vr_num = 700; } elseif ($orderInfo['price'] == 11800) { $vr_num = 7000; } elseif ($orderInfo['price'] == 11800) { $vr_num = 2100; }elseif($orderInfo['price'] == 10620){ $vr_num = 6300; } $pay_gb1 = $vr_num; $pay_vr1 =$orderInfo['price'];//记录VR值 // $result = Db::name("old_user_jbp")->where("id",$user_id)->dec("vr",$orderInfo['price'])->save();//1.0jbp旧表 // Db::name("user")->where("uid",$user_id)->dec("vr",$orderInfo['price'])->save();//2.0新表 $result = true; if($result) { $invite_id = $goods_of_info['spread_id']; $zs_ylj = 0; //养老金赋值 if($orderInfo['price'] == 1180){ //修改订单到账状态 $zs_ylj = bcmul(700, 0.05,2);//计算的养老金 金额 }elseif($orderInfo['price'] == 11800){ $zs_ylj = bcmul(7000, 0.05,2);//计算的养老金 金额 }elseif($orderInfo['price'] == 3540){ $zs_ylj = bcmul(2100, 0.05,2);//计算的养老金 金额 }elseif($orderInfo['price'] == 10620){ $zs_ylj = bcmul(6300, 0.05,2);//计算的养老金 金额 }elseif($orderInfo['price'] == 9440){ $zs_ylj = bcmul(5600, 0.05,2);//八单计算的养老金 金额 }elseif($orderInfo['price'] == 2360){ $zs_ylj = bcmul(1400, 0.05,2);//两单计算的养老金 金额 } // $spread_data = Db::name('test_log')->insert(['note'=>"price1:" . $orderInfo['price'] ." pri2:" . $zs_ylj]); $uid = $user_id; $new_user_id = $uid; if(empty($new_user_id)) { abort(0,"当前绑定会员查询错误"); } $new_nums =Db::name("old_user_of_goods")->where("user_id", $uid)->sum("money"); //增加过后权益对比 获取当前权益等级 $old_level_id = Db::name("old_user_jbp")->where("id",$uid)->find(); $old_level_info = Db::name("old_user_level")->where("id",$old_level_id['user_level_id'])->find(); $level_info = []; $level_list = Db::name("old_user_level")->order("money desc")->select(); //计算会员等级 升级 foreach ($level_list as $key => $value) { # code... if($new_nums>=$value['money']) { $level_info = $value; break; } } $zs_gb = $orderInfo['price'] * 3; $zs_withdraw_quota = $orderInfo['price']; if($old_level_info['id'] == $level_info['id']) { //未到达升级权益 不改变用户等级 $update_status = false; }else{ $update_status = true; $user_level = $level_info['id']; //var_dump( $user_level); Db::name("old_user_jbp")->where("id",$new_user_id)->save(['user_level_id'=>$user_level]);//1.0jbp旧表 Db::name("user")->where("uid",$new_user_id)->save(['user_level_id_old'=>$user_level]);//2.0新表 // todo 同时改变他的权益 } //检查是不是订单价格是1180或者11800，更改VR //if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440 || $goods_of_info['money'] == 2360){ //修改订单到账状态 // $spread_data = Db::name('test_log')->insert(['note'=>"goodid:" . $goods_of_info['id'] .' money:'.$goods_of_info['money'].' pay_vr:'.$pay_vr1]); Db::name("old_user_of_goods")->where("id",$goods_of_info['id'])->save(['status'=>1,'money'=>$orderInfo['price'],'pay_gb'=>0,'pay_vr'=>$pay_vr1,'pay_bt'=>0,'create_time'=>time()]); // $spread_data = Db::name('test_log')->insert(['note'=>"money:" . $goods_of_info['money'] ." pay_vr:" . $pay_vr1]); // } } if($result) { //更改订单状态 Db::commit(); $new_user_name = Db::name("old_user_jbp")->where("id",$new_user_id)->value("user_name"); $new_user_name = empty($new_user_name) ? "" : $new_user_name; //记录日志信息 if($user_id == $invite_id) { //报单中心=推荐人 GB记录日志有问题需要传入指定参数去计算 //$money = Db::name("old_user_jbp")->where("id",$user_id)->value("gb"); //$appoint_money = $money - $zs_invite_gb; //if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440 || $goods_of_info['money'] == 2360){ $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name); // } }else{ // if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440 || $goods_of_info['money'] == 2360){ $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name); //} } // $this->change_user_log66($new_user_id,'gb',1,$zs_gb,"levle_update_zs","权益升级达标赠送"); $this->change_user_log66($new_user_id,'withdraw_quota_old',1,$zs_withdraw_quota,"levle_update_zs","权益升级达标赠送"); // $this->change_user_log66($invite_id,'gb',1,$zs_invite_gb,"levle_update_zs","邀请-".$new_user_name); // echo 123;return; //处理查看是否有待发放佣金 // $zs_withdraw_quota Db::name("old_user_jbp")->where("id",$new_user_id)->inc("total_withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表 Db::name("user")->where("uid",$new_user_id)->inc("total_withdraw_quota_old",$zs_withdraw_quota)->save(); // $this->releaseTobeAmount($new_user_id,$zs_withdraw_quota); // $this->success("支付成功",['is_cash'=>0]); } Db::rollback(); // $this->error("操作失败"); } function change_user_log66($user_id,$type,$change_status,$money,$routine,$remark="",$is_admin=1,$appoint_money = 0) { $transition = [ 'pv'=>1, "gb"=>2, "df"=>3, "vr"=>4, "bt"=>5, "withdraw_quota_old"=>6, "unsettled_pension"=>7, "amount_old"=>8 ]; $routineInfo = Db::name("old_routine_log_of_key")->where("key",$routine)->find(); if(empty($routineInfo)) { return false; } $key_id = isset($routineInfo['id']) ? $routineInfo['id'] : 0; //再去查询变更前的 金额 if($appoint_money > 0) { $alter_money = $appoint_money; }else{ //再去查询变更前的 金额 $alter_money = Db::name("user")->where('uid',$user_id)->value($type); } if($change_status == 1) { //新增前 $alter_money = $alter_money-$money; }else if($change_status == 2){ //减少前 $alter_money = $alter_money + $money; } $inser_data = []; $inser_data['user_id'] = $user_id; $inser_data['type'] = $transition[$type]; $inser_data['change_status'] = $change_status; $inser_data['money'] = $money; $inser_data['routine_log_of_key_id'] = $key_id; $inser_data['remark'] = $remark; $inser_data['is_admin'] = $is_admin; $inser_data['create_time'] = time(); $inser_data['alter_money'] = isset($alter_money) ? $alter_money : 0; Db::name("old_user_log")->insert($inser_data); } public function pay_user_annual($uid,$order_no=''){ Db::startTrans(); try { if ($order_no != ''){ Db::name('user_pension_account_order')-> where('order_no',$order_no) -> update(['status'=>1]); } $check = Db::name("user_pension_account") -> where("uid",$uid) -> find(); $start_time = date('Y-m-d'); $end_time = date("Y-m-d 23:59:59",strtotime("+1 year", strtotime($start_time))); $give = 0; //存在既续费 if ($check){ Db::name("user_pension_account") -> where("uid",$uid) -> update(['start_time'=>$start_time,'end_time'=>$end_time]); $give = $check['give']; }else{ //新用户订单 Db::name("user_pension_account") -> insert([ "uid" => $uid, "start_time" => $start_time, "end_time" => $end_time, "status" => 1, ]); } if ($give == 0){ Db::name("user_pension_account") -> where("uid",$uid) -> update(['give' => 1]); $mark = "开通养老金账户"; $billData=[ 'uid'=>$uid, 'pm'=>1, 'title'=>'养老金', 'category'=>'now_money', 'type'=>'commission', 'number'=>0.01, 'balance'=>0, 'mark'=>$mark, 'create_time'=>date("Y-m-d H:i:s",time()), 'status'=>1, 'order_sn'=>'', 'type_shop'=>0, 'commission_type'=>5, 'order_type'=>1, 'gzc'=>0 ]; Db::name('user_bill')->insert($billData); Db::name("user")->where("uid",$uid)->inc('annuity', 0.01) ->update(); Db::name("user")->where("uid",$uid)->inc('annuity_num', 1) ->update(); } // 提交事务 Db::commit(); return true; } catch (\Exception $e) { // 回滚事务 Db::rollback(); Log::error($e->getMessage()); } } public function marketing($order,$marketingUser,$pay_type="wx"){ Db::startTrans(); try { Db::name('marketing_order') -> where('order_no',$order['order_no']) -> update(['pay_type'=>$pay_type,'status'=>1]); Db::name('marketing_user') -> where('uid',$order['uid']) -> update(['type'=>$order['type']]); //分红份数及资金 $divvy_number = ceil(bcdiv($order['pay_price'],99)); $divvy_money = $order['pay_price']; Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_number', $divvy_number) ->update(); Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_money', $divvy_money) ->update(); //上级 $spread_uid = $marketingUser['spread_uid']; //养老金 //本人给养老金10% $ylj=bcmul($order['pay_price'],'0.1',5);//10%的养老金 $ylj=round($ylj,2); $title='养老金'; if ($order['type'] == 1){ $identity = "普通会员"; }elseif ($order['type'] == 2){ $identity = "创客"; }elseif ($order['type'] == 3){ $identity = "合伙人"; }else{ $identity = ""; } $mark = "成为{$identity}获得{$ylj}养老金"; $billData=[ 'uid'=>$order['uid'], 'link_id'=>$order['id'], 'pm'=>1, 'title'=>$title, 'category'=>'now_money', 'type'=>'commission', 'number'=>$ylj, 'balance'=>0, 'mark'=>$mark, 'create_time'=>date("Y-m-d H:i:s",time()), 'status'=>1, 'order_sn'=>$order['order_no'], 'type_shop'=>0, 'commission_type'=>5, 'order_type'=>1, 'gzc'=>0 ]; Db::name('user_bill')->insert($billData); Db::name("user")->where("uid",$order['uid'])->inc('annuity', $ylj) ->update(); Db::name("user")->where("uid",$order['uid'])->inc('annuity_num', 1) ->update(); //上级佣金 $checkSpread = Db::name("MarketingUser") -> where('uid',$spread_uid)->value("type"); //检查上级身份 必须是会员或以上 if ($checkSpread > 0){ $commission=bcmul($order['pay_price'],'0.3',5);//30%的佣金 $commission=round($commission,2); $spreadTitle='佣金'; $spreadMark = "推广{$identity}获得{$commission}佣金"; $spreadBillData=[ 'uid'=>$spread_uid, 'link_id'=>$order['id'], 'pm'=>1, 'title'=>$spreadTitle, 'category'=>'now_money', 'type'=>'commission', 'number'=>$commission, 'balance'=>0, 'mark'=>$spreadMark, 'create_time'=>date("Y-m-d H:i:s",time()), 'status'=>1, 'order_sn'=>$order['order_no'], 'type_shop'=>0, 'commission_type'=>11, 'order_type'=>1 ]; Db::name('user_bill')->insert($spreadBillData); Db::name('user')->where('uid',$spread_uid)->inc('brokerage_price',$commission)->update(); } $spread_list = $marketingUser['spread_list']; $spread_list = str_replace(['[', ']'], '', $spread_list); $spread_list = explode(',',$spread_list); //计算所有上级的累计销售业绩 赠送积分 $achievement = $this -> achievement($spread_list,$order['uid'],$order['pay_price']); foreach($achievement as $key => $value){ $spreadTitle='业务销售奖励积分'; $achievementMark = "团队推广{$identity}获得{$value['commission']}积分"; $integral = Db::name("marketing_user") -> where('uid',$spread_uid) -> value("integral"); $achievementBillData=[ 'uid'=>$key, 'pm'=>1, 'title'=>$spreadTitle, 'integral'=>$value['commission'], 'residual_integral' => $integral + $value['commission'], // 'mark'=>$achievementMark, 'order_sn'=>$order['order_no'], ]; Db::name('marketing_integral')->insert($achievementBillData); Db::name('marketing_user')->where('uid',$spread_uid)->inc('integral',$value['commission'])->update(); } if ($order['type'] == 2 || $order['type'] == 3) { //赠送商户 $merchant=Db::name('merchant')->where('uid',$order['uid'])->find(); if(!$merchant) { $access = new Access(); $activation_code = $access->randomFromDev(20); // Db::name('activation_code')->insertGetId([ // 'uid' => $order['uid'], // 'code' => $activation_code, // 'ctime' => time(), // 'status' => 1, // 'utime' => time(), // 'use_uid' => $order['uid'], // 'type' => 1 // ]); Db::name('merchant_intention')->insert(['uid' => $order['uid'], 'status' => 3, 'activation_code' => $activation_code]); } } // 提交事务 Db::commit(); return true; } catch (\Exception $e) { // 回滚事务 Db::rollback(); Log::error($e->getMessage()); return false; } } public function achievement($lists,$uid,$pay_price){ $newList = []; $lastAchievement = 0; $lastCommission = 0; $total = 0; $list=array_reverse($lists); foreach($list as $value){ $checkSpread = Db::name("MarketingUser") -> where('uid',$value)->value("type"); //检查上级身份 必须是会员或以上 if ($checkSpread <= 0) continue; $achievement = Db::name('marketing_order') ->where('uid','in',function($query) use ($value,$uid){ $query->name('marketing_user')-> where("spread_list like '%[$value]%' or uid = $value","") -> where("uid","<>",$uid) -> field("uid"); }) -> where("status",1) ->sum("pay_price"); if ($achievement >= 50000 && $achievement < 300000){ $c = round(bcmul($pay_price,'0.1',5),2);//10% //如果业绩大于5万，小于30万。并且业绩等级等于1。奖励等于上个人的奖励减半 if ($lastAchievement == 1){ $c = round(bcmul($lastCommission,0.5,5),2); } $lastCommission = $c; $lastAchievement = 1; $total += $c; $newList[$value] = [ "achievement" => $achievement, "commission" => $c ]; }elseif ($achievement >= 300000 && $achievement < 1000000){ $c = round(bcmul($pay_price,'0.15',5),2);//15% //如果业绩大于5万，小于30万。并且业绩等级等于2。奖励等于上个人的奖励减半 if ($lastAchievement == 2){ $c = round(bcmul($lastCommission,0.5,5),2); }else{ $c = $c - $total; } $lastAchievement = 2; if ($c > 0){ $total += $c; $lastCommission = $c; $newList[$value] = [ "achievement" => $achievement, "commission" => $c ]; }else{ $lastCommission = 0; } }elseif ($achievement >= 1000000){ $c = round(bcmul($pay_price,'0.2',5),2);//20% //如果业绩大于5万，小于30万。并且业绩等级等于3。奖励等于上个人的奖励减半 if ($lastAchievement == 3){ $c = round(bcmul($lastCommission,0.5,5),2); }else{ $c = $c - $total; } $total += $c; $lastAchievement = 3; if ($c > 0){ $total += $c; $lastCommission = $c; $newList[$value] = [ "achievement" => $achievement, "commission" => $c ]; }else{ $lastCommission = 0; } } } return $newList; } public function giveHongBao($uid, $pv, $order_id, $mark, $status = -1) { //添加红包 $hongbao = bcmul($pv, 0.45, 2); $hongbao_data = [ "uid" => $uid, "number" => $hongbao, "addtime" => time(), "status" => $status, "order_type" => 1, "order_id" => $order_id, "mark" => $mark, "desc" => '', "surplus" => $hongbao, "type" => 1, //1消费赠送 'settlement_time' => date('Y-m-d H:i:s') ]; Db::name("user_sign_hongbao")->insert($hongbao_data);//添加记录 } public function con_log_pv($uid, $pv, $order_id, $order_type, $mark, $status = -1) { // 添加pv记录 $pv_data = [ "uid" => $uid, "pv" => $pv, "addtime" => time(), "status" => $status, "order_type" => $order_type, "order_id" => $order_id, "mark" => $mark, ]; // 当状态为1时是实时结算 if($status == 1) { // Db::name('user')->where('uid', $uid)->inc('pv', (float)$pv)->update(); $con_data = Db::name('user')->where("uid", $uid)->find(); Db::name('user')->where("uid", $uid)->update(['pv' => ($con_data['pv']?:0) + $pv]); $pv_data['settlement_time'] = date('Y-m-d H:i:s'); } Db::name("user_pv_log")->insert($pv_data);//添加pv记录 } //添加贡献值日志 public function con_log($uid,$num,$order_id,$order_type,$mark,$status = -1){ $con_data = Db::name('user')->where("uid",$uid)->find(); //如果状态是1那就是即刻入账， if($status == 1){ // //如果当前用户是业务经理之前的等级，那么需要将当前用户的直推用户贡献值加到自己贡献值中去 // if( $con_data['user_group'] <= 2 ){ $spread_data = Db::name('user')->where("spread_uid",$uid)->select(); if (strpos($mark, "购买") !== false) { Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]); /** @var UserRepository $userRepository */ $userRepository = app()->make(UserRepository::class); $userRepository->setUserIdentity($uid); } if (strpos($mark, "推广") !== false) { Db::name('user')->where("uid",$uid)->update(['per_contribute'=>$con_data['per_contribute'] + $num]); } //if(count($spread_data) > 0){ // $all_ids = []; // foreach($spread_data as $k=>$v){ // $all_ids[] = $v['uid']; // } // // 查询当前用户及其子级的所有订单 // $orders = Db::name("store_order") // ->whereIn('status', [0, 1, 2, 3]) // ->whereIn("uid", $all_ids) // ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440]) // ->select(); // // 计算总业绩 // $totalPv = 0; // foreach ($orders as $order) { // switch ($order['total_price']) { // case 1180: // $totalPv += 700; // break; // case 11800: // $totalPv += 7000; // break; // case 10620: // $totalPv += 6300; // break; // case 2360: // $totalPv += 1400; // break; // case 9440: // $totalPv += 5600; // break; // } // } // } // }else{ // // 检查是否包含“推广” // // if (strpos($mark, "推广") !== false) { // // echo "字符串1包含'推广'\n"; // // } // 检查是否包含“购买” if (strpos($mark, "购买") !== false) { Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]); /** @var UserRepository $userRepository */ $userRepository = app()->make(UserRepository::class); $userRepository->setUserIdentity($uid); } // } } $con = [ 'uid'=>$uid, 'number'=>$num,//赠送数量 'status'=>$status,//红包状态 'mark'=>$mark,//备注 'desc'=>'',//描述 'order_id'=>$order_id,//订单id 'surplus'=> $con_data['contribute'],//剩余 'order_type'=>$order_type,//订单类型 'type'=>1,//1增加，2消耗 'settlement_time'=>date('Y-m-d H:i:s'), 'addtime'=>time() ]; Db::name('user_sign_gongxian')->insert($con); } //添加积分日志 public function score_log($uid,$num,$order_id,$order_type,$mark,$status = -1){ $score_data = Db::name('user')->where("uid",$uid)->find(); //如果状态是1那就是即刻入账， if($status == 1){ $con_data_score = Db::name('user')->where("uid",$uid)->update(['score'=>$score_data['score'] + $num]); } $score = [ 'uid'=>$uid, 'continuity_day'=>0,//连续签到天数 'reward_socre'=>$num,//积分数量 'signin_time'=>0,//签到时间 'source_uid'=>0,//赠送积分用户来源id 'status'=>$status,//积分状态1:有效，0:失效,1:待确认 'mark'=> $mark,//备注 'order_id'=>$order_id,//订单id 'pm'=>1,//1收入，2支出 'surplus'=> $score_data['score'],//剩余 'order_type'=>$order_type,//订单类型 ,10精彩生活区，11会员区，12复购区 'source_type'=>3,//积分类型，1签到，2分享好友注册赠送，3自己下单赠送 'settlement_time'=>date('Y-m-d H:i:s'), 'addtime'=>time() ]; Db::name('user_sign_score')->insert($score); } //添加推广佣金/养老金日志(养老金金额) public function bill_user_log($uid,$num,$order_id,$comm_order_type,$order_sn,$mark,$merid,$ds=0){ $con_data = Db::name('user')->where("uid",$uid)->find(); //如果是会员专区就即刻到账 $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->find(); //查询支付方式 $array_fzone_paytype = json_decode($order_from_mer['fzone_paytype'],true); $pay_type = 3;//默认是微信 if($array_fzone_paytype['note'] != "现金"){ $pay_type = 4; } $sm_status = 0;//储存当前用户是否有实名的状态 if($order_from_mer['mer_id'] == 496){ //如果是会员区的直推就即刻到账 if($comm_order_type == 3){ Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]); } //如果是会员区的养老金，查看是否有实名，如果实名就改变订单状态和user-bill的状态 if($comm_order_type == 5){ //当前用户是否有实名，然后改变user_bill和order_store的gzc状态 $get_cer_datas = Db::name('user_certification')->where("uid", $uid)->find(); if (!empty($get_cer_datas)) { if (!empty($get_cer_datas['user_card'])) { $sm_status = 1; $ds = 1; Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 1]); //添加养老金到公证处日志 $ylj_data_log = [ 'user_name' => $get_cer_datas['user_name'], "mobile" => $get_cer_datas['mobile'], "user_card" => $get_cer_datas['user_card'],//身份证 "pension" => $num,//养老金额度 "out_trade_no" => $order_from_mer['order_sn'],//订单号 "account_type" => $pay_type,//支付方式(3:微信,4:组合) "order_type" => 2,//订单类型(2:) "pay_time" => date('Y-m-d H:i:s'), "create_time" => date('Y-m-d H:i:s'), "update_time" => date('Y-m-d H:i:s'), "uid" => $uid, ]; Db::name('gzc_logs')->insert($ylj_data_log); } }else { Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 0]); //添加养老金到公证处日志 $ylj_data_log = [ //'user_name' => $get_cer_datas['user_name'], //"mobile" => $get_cer_datas['mobile'], //"user_card" => $get_cer_datas['user_card'],//身份证 "pension" => $num,//养老金额度 "out_trade_no" => $order_from_mer['order_sn'],//订单号 "account_type" => $pay_type,//支付方式(3:微信,4:组合) "order_type" => 2,//订单类型(2:) "pay_time" => date('Y-m-d H:i:s'), "create_time" => date('Y-m-d H:i:s'), "update_time" => date('Y-m-d H:i:s'), "uid" => $uid, ]; Db::name('gzc_logs')->insert($ylj_data_log); } $ds = 1; } } $name = ''; if($comm_order_type==3){ $name = '直推奖'; }else if($comm_order_type==5){ $name = '养老金'; //$user_bill_status = Db::name('store_order')->where("order_id",$order_id)->update(['gzc'=>1]); } $bill = [ 'uid'=>$uid, 'link_id'=>$order_id,//关联订单id 'pm'=>1,//0：支出，1：获得 'title'=>$name,//账单标题 'category'=>'now_money',//明细种类 'type'=>'commission',//明细类型 'number'=>$num,//明细数字 'balance'=>0,//剩余 'mark'=>$mark,//备注 'create_time'=>date('Y-m-d H:i:s'),//添加时间 'status'=> $ds,//0待确定，1有效，-1无效 'commission_type'=>$comm_order_type,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费 //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金 //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’ 'order_sn'=>$order_sn,//订单号 'tripartite'=>0,// 'type_shop'=>0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上 'mer_id'=>$merid,//商户id 'source'=>0,//1线下 0线上 'order_type'=>1,//1自营 2 第三方 订单类型 'is_red_brokerage'=>0,//1红积分对冲佣金 0正常佣金 'gzc'=> $sm_status,//养老金是否已进入公证处log表0：未进入。1：已进入 'take_time'=>'',//结算时间 'district_id'=>'',// 'street_id'=>'',// 'month'=>'',//月份 ]; Db::name('user_bill')->insert($bill); } //添加复购金 public function fugou_user_log($uid,$num,$order_id,$type_inc_des,$status=-1){ $fugou_data = Db::name('user')->where("uid",$uid)->find(); //如果状态是1那就是即刻入账， if($status == 1){ $con_data_fugoujin = Db::name('user')->where("uid",$uid)->update(['fugou'=>$fugou_data['fugou'] + $num]); } $bill = [ 'uid'=>$uid, 'number'=>$num,//数量 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认 'mark'=>"复购金",//备注 'desc'=>"抽取佣金的10%作为复购金",//描述 'order_id'=>$order_id,//订单id 'surplus'=>0,//剩余 'order_type'=>11,//关联订单ID 'type'=>$type_inc_des,//复购金类型 :1赠送，2消耗 'settlement_time'=>date('Y-m-d H:i:s'),//添加时间, 'addtime'=>time(), ]; Db::name('user_sign_fugou')->insert($bill); } //订单数据补充 public function buchong(){ $list = Db::name('user_sign_fugou')->where('order_id', 2147483647)->where('mark', '购买话费商品赠送复购金')->where('status', -1)->select(); foreach($list as $k => $v){ $score = Db::name('user_sign_score')->where('uid', $v['uid'])->where('addtime', $v['addtime'])->where('mark', '购买话费商品赠送积分')->find(); if($score){ $update_data['status'] = $score['status']; $update_data['order_id'] = $score['order_id']; Db::name('user_sign_fugou')->where("id", $v['id'])->update($update_data); } } // foreach($list as $k => $v){ // $fzone_paytype = json_decode($v['fzone_paytype'], true); // if(isset($fzone_paytype['jingdou'])) $update_data['fzone_pay_jingdou'] = $fzone_paytype['jingdou']; // if(isset($fzone_paytype['vr'])) $update_data['fzone_pay_vr'] = $fzone_paytype['vr']; // if(isset($fzone_paytype['jifen'])) $update_data['fzone_pay_jifen'] = $fzone_paytype['jifen']; // if(isset($fzone_paytype['price'])) $update_data['fzone_pay_price'] = $fzone_paytype['price']; // if(isset($fzone_paytype['other'])) $update_data['fzone_pay_other'] = $fzone_paytype['other']; // if(isset($fzone_paytype['type'])) $update_data['fzone_pay_type'] = $fzone_paytype['type']; // if(isset($fzone_paytype['note'])) $update_data['fzone_pay_note'] = $fzone_paytype['note']; // Db::name('store_order')->where("order_id", $v['order_id'])->update($update_data); // } return app('json')->success(['result' => 'ok']); } }