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 '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); Db::name('log')->insert(['data'=>'汇付支付撤销返回结果:'.json_encode($hf_refund_res)]); break; } $post_data_str['expend']['open_id'] = $post_data_str['expend']['open_id'] ?? ''; Db::name('store_order')->where('group_order_id', $group_order_id)->update(['pay_open_id' => $post_data_str['expend']['open_id']]); 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; 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 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; } }