Notify.php 85 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486
  1. <?php
  2. namespace app\controller\api;
  3. use AdaPaySdk\AdapayTools;
  4. use app\common\repositories\store\order\StoreRefundOrderRepository;
  5. use app\controller\api\merchant\sxy\Access;
  6. use app\controller\api\store\service\Huafei;
  7. use think\facade\Db;
  8. use think\facade\Log;
  9. use think\facade\Request;
  10. class Notify
  11. {
  12. public function notify($type){
  13. // Db::name('log')->insert(['data'=>'汇付支付回调---'.json_encode($type)]);
  14. set_time_limit(0);
  15. $post = Request::param();
  16. Db::name("log")->insert(array('data'=>'【汇付异步接受到的参数】'.json_encode($post),));//日志记录
  17. $post_data_str = isset($post['data']) ? $post['data']: '';
  18. $post_sign_str = isset($post['sign']) ? $post['sign']: '';
  19. # 先校验签名和返回的数据的签名的数据是否一致
  20. $adapay_tools=new AdapayTools();
  21. if ($post['app_id'] == 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0'){
  22. 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');
  23. }else{
  24. AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
  25. }
  26. // AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
  27. // $adapay_tools->SetParams();
  28. $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
  29. $post_data_str=json_decode($post_data_str,true);
  30. if ($sign_flag){
  31. try {
  32. if(empty($post_data_str['error_msg'])){
  33. Db::name("log")->insert(array('data'=>'【验签通过-支付】:时间:'.date('Y-m-d H:i:s',time()),));//日志记录
  34. $requestId = [];
  35. if(strpos($post_data_str['order_no'],'_') !== false){
  36. $requestId = explode("_",$post_data_str['order_no']);
  37. }
  38. $pay_type = $post_data_str['pay_channel'];
  39. $pay_type = $pay_type == 'wx_lite' ? 1 : 4;
  40. switch ($type){
  41. case 'huafei':
  42. //话费充值支付成功推送
  43. try{
  44. $order_data = Db::name('order_huafei_hf') -> where('order_no', $requestId[0])->find();
  45. if($order_data['status']==1) return false;
  46. Db::name('order_huafei_hf')->where('order_no',$requestId[0])->update([
  47. 'rand'=>$requestId[1],
  48. 'pay_type'=>$pay_type,
  49. 'pay_wx'=>systemConfig('pay_wx'),
  50. 'payment_id'=>$post_data_str['id'],
  51. 'reverse_amt'=>$post_data_str['pay_amt'],
  52. 'status'=>1
  53. ]);
  54. }catch (\Exception $e) {
  55. Db::name('log')->insert(['data'=>'话费充值支付回调错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  56. }
  57. //话费充值支付成功推送
  58. try{
  59. $push = app()->make(Huafei::class)->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price'], $order_data['order_id']);
  60. if($push['code'] != '0000'){
  61. $pay_wx = systemConfig('pay_wx');
  62. //推送失败 给新支付的这一笔退款
  63. Db::name('log')->insert(['data' => '给新话费充值支付的这一笔退款']);
  64. if ($pay_wx == 3){
  65. $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
  66. }else{
  67. $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
  68. }
  69. $refund_traits = [
  70. 'payment_id' => $post_data_str['id'],
  71. 'app_id' => $post['app_id'],
  72. 'order_no' => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(),
  73. 'reverse_amt' => $post_data_str['pay_amt'],
  74. 'notify_url' => env('APP_URL') . "/api/hf_notify/reverse_order",
  75. ];
  76. $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type == '1' ? 2 : 1, $pay_wx, $key);
  77. Db::name('log')->insert(['data'=>'话费充值汇付支付撤销返回结果:'.json_encode($hf_refund_res)]);
  78. //把赠送出去的养老金 积分 贡献值 复购金 改为已失效
  79. Db::name('user_bill')->where('order_sn', $order_data['order_no'])->update(['status'=> -1]);
  80. Db::name('user_sign_score')->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
  81. Db::name('user_sign_gongxian')->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
  82. Db::name('user_sign_fugou')->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
  83. }
  84. }catch (\Exception $e) {
  85. Db::name('log')->insert(['data'=>'话费充值支付回调推送订单错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  86. }
  87. break;
  88. case 'pay':
  89. //商城集合订单
  90. Db::name('store_group_order') -> where('group_order_sn',$requestId[0]) -> update(['rand'=>$requestId[1]]);
  91. // 判断代付是否支付过
  92. $group_order = Db::name('store_group_order')->where('group_order_sn', $requestId[0])->find();
  93. $group_order_id = $group_order['group_order_id']??'';
  94. $old_pay_open_id = Db::name('store_order')->where('group_order_id', $group_order_id)->value('pay_open_id');
  95. if ($old_pay_open_id && $old_pay_open_id != $post_data_str['expend']['open_id']) {
  96. // 给新支付的这一笔退款
  97. Db::name('log')->insert(['data' => '给新支付的这一笔退款']);
  98. if ($group_order['pay_wx'] == 3){
  99. $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
  100. }else{
  101. $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
  102. }
  103. $refund_traits = [
  104. 'payment_id' => $post_data_str['id'],
  105. 'app_id' => $post['app_id'],
  106. 'order_no' => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(),
  107. 'reverse_amt' => $post_data_str['pay_amt'],
  108. 'notify_url' => env('APP_URL') . "/api/hf_notify/reverse_order",
  109. ];
  110. $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type['pay_type'] == '1' ? 2 : 1, $group_order['pay_wx'], $key);
  111. Db::name('log')->insert(['data'=>'汇付支付撤销返回结果:'.json_encode($hf_refund_res)]);
  112. break;
  113. }
  114. $post_data_str['expend']['open_id'] = $post_data_str['expend']['open_id'] ?? '';
  115. //start
  116. //分配逻辑
  117. // $store_order_data = Db::name('store_order')->where('group_order_id', $group_order_id)->find();
  118. //精彩生活
  119. // if($store_order_data['mer_id'] == 439){
  120. // if(!empty($store_order_data)){}
  121. // }
  122. //$group_order = Db::name('store_group_order')->where('group_order_sn',$group_order_id)->find();
  123. //var_dump($group_order['group_order_id']);return;
  124. //分配逻辑
  125. $store_order_data = Db::name('store_order')->where('group_order_id',$group_order_id)->find();
  126. //找到对应的商品id(product_id)
  127. $store_order_product_data = Db::name('store_order_product')->where('order_id',$store_order_data['order_id'])->find();
  128. //找到对应的商品让利金额或比例
  129. $store_product_data = Db::name('store_product')->where('product_id',$store_order_product_data['product_id'])->find();
  130. //下单用户
  131. $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find();
  132. // $concession_pri = $store_product_data['concession_pri'];//商家让利金额
  133. $concession_pri = $store_order_data['con_pri'];
  134. $spread_uid = 0;//下单用户上级uid
  135. $fgj_pri=0;//推广者的佣金抽10%到个人复购金
  136. $pv = 0; //待分配的PV
  137. //var_dump($store_product_data['concession_pri']);return;
  138. //精彩生活
  139. if($store_order_data['mer_id'] == 439){
  140. //分配参数
  141. $job_par = [];
  142. if(!empty($store_order_data)){
  143. $job_par = json_decode($store_order_data['fzone_paytype'], true);
  144. //if($job_par['note'] == "现金"){
  145. //普通消费者
  146. $ylj_pri = round($concession_pri * 0.3,2);
  147. $pv = round($concession_pri * 0.35,2);
  148. //分配养老金给消费者
  149. $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
  150. //分配积分和贡献值给消费者
  151. $con = $user_data['contribute'] + $pv;
  152. $score = $user_data['score'] + $pv;
  153. //Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,"contribute"=>$con,"score"=>$score]);
  154. $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);
  155. $this->con_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送贡献值");
  156. $this->score_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送积分");
  157. //给推广者分配养老金
  158. //给推广者分配佣金
  159. if($user_data['spread_uid'] != 0){
  160. //查询下单用户上级身份
  161. $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
  162. //业务员或以上的推荐人等级
  163. //user_group=1是消费者 3%,2:业务员 5%,3:业务经理7%,4:初级合伙人9%,5:中级合伙人11%,6:高级合伙人13%,7:董事15%
  164. if($spread_data['user_group'] > 1){
  165. // //给推广者分配佣金
  166. $yj_amount = 0;
  167. $ylj_amount = $spread_data['annuity'] + round($pv * 0.05,2);
  168. $ssf = 0;//变量
  169. $yj_amount_90 = 0;//90%的佣金
  170. if($spread_data['user_group'] == 2){
  171. $ssf =round($pv * 0.07,2);
  172. $con = $spread_data['contribute'] + round($pv * 0.07,2);
  173. $score = $spread_data['score'] + round($pv * 0.07,2);
  174. $yj_amount_90 = round($pv * 0.07,2) * 0.9;
  175. $fgj_amount_10 = round($pv * 0.07,2) * 0.1;//推广者的佣金抽10%到个人复购金
  176. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  177. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  178. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  179. // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  180. }else if($spread_data['user_group'] == 3){
  181. $ssf =round($pv * 0.09,2);
  182. $con = $spread_data['contribute'] + round($pv * 0.09,2);
  183. $score = $spread_data['score'] + round($pv * 0.09,2);
  184. $yj_amount_90 = round($pv * 0.09,2) * 0.9;
  185. $fgj_amount_10 = round($pv * 0.09,2) * 0.1;//推广者的佣金抽10%到个人复购金
  186. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  187. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  188. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  189. // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  190. }else if($spread_data['user_group'] == 4){
  191. $ssf =round($pv * 0.11,2);
  192. $con = $spread_data['contribute'] + round($pv * 0.11,2);
  193. $score = $spread_data['score'] + round($pv * 0.11,2);
  194. $yj_amount_90 = round($pv * 0.11,2) * 0.9;
  195. $fgj_amount_10 = round($pv * 0.11,2) * 0.1;//推广者的佣金抽10%到个人复购金
  196. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  197. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  198. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  199. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  200. }else if($spread_data['user_group'] == 5){
  201. $ssf =round($pv * 0.13,2);
  202. $con = $spread_data['contribute'] + round($pv * 0.13,2);
  203. $score = $spread_data['score'] + round($pv * 0.13,2);
  204. // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.13,2);
  205. $yj_amount_90 = round($pv * 0.13,2) * 0.9;
  206. $fgj_amount_10 = round($pv * 0.13,2) * 0.1;//推广者的佣金抽10%到个人复购金
  207. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  208. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  209. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  210. // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  211. }else if($spread_data['user_group'] == 6){
  212. $ssf =round($pv * 0.15,2);
  213. $con = $spread_data['contribute'] + round($pv * 0.15,2);
  214. $score = $spread_data['score'] + round($pv * 0.15,2);
  215. // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.15,2);
  216. $yj_amount_90 = round($pv * 0.15,2) * 0.9;
  217. $fgj_amount_10 = round($pv * 0.15,2) * 0.1;//推广者的佣金抽10%到个人复购金
  218. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  219. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  220. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  221. // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  222. }else if($spread_data['user_group'] == 7){
  223. $ssf =round($pv * 0.17,2);
  224. $con = $spread_data['contribute'] + round($pv * 0.17,2);
  225. $score = $spread_data['score'] + round($pv * 0.17,2);
  226. // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.17,2);
  227. $yj_amount_90 = round($pv * 0.17,2) * 0.9;
  228. $fgj_amount_10 = round($pv * 0.17,2) * 0.1;//推广者的佣金抽10%到个人复购金
  229. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  230. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  231. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  232. // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
  233. }
  234. //贡献值
  235. $this->con_log($spread_data['uid'],$pv,$store_order_data['order_id'],11,"精彩生活区商品赠送贡献值");
  236. //积分
  237. $this->score_log($spread_data['uid'],$ssf,$store_order_data['order_id'],11,"精彩生活区商品赠送积分");
  238. // //推广佣金
  239. $this->bill_user_log($spread_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);
  240. //养老金
  241. $this->bill_user_log($spread_data['uid'],round($pv * 0.05,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'推广获得养老金'.round($pv * 0.05,2),$store_order_data['mer_id'],0);
  242. }
  243. //普通用户推广人
  244. if($spread_data['user_group'] == 1){
  245. //给推广者分配佣金
  246. // $ylj_amount = $spread_data['annuity'] + round($pv * 0.3,2);
  247. $yj_amount_90 = round($pv * 0.21,2) * 0.9;
  248. $fgj_amount_10 = round($pv * 0.21,2) * 0.1;//推广者的佣金抽10%到个人复购金
  249. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  250. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  251. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  252. //Db::name('user')->where('uid',$spread_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
  253. $con = $spread_data['contribute'] + round($pv * 0.21,2);
  254. $score = $spread_data['score'] + round($pv * 0.21,2);
  255. //贡献值和积分
  256. //Db::name('user')->where('uid',$spread_data['uid'])->update(["contribute"=>$con,"score"=>$score]);
  257. //推广养老金
  258. //推广佣金
  259. $this->bill_user_log($spread_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);
  260. $this->con_log($spread_data['uid'],round($pv * 0.21,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
  261. $this->score_log($spread_data['uid'],round($pv * 0.21,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");
  262. }
  263. }
  264. //锁客收益
  265. if($user_data['mer_id'] != 0){
  266. $merchant_data = Db::name('merchant')->where('mer_id',$user_data['mer_id'])->find();
  267. $merchant_user_data = Db::name('user')->where('uid',$merchant_data['uid'])->find();
  268. if(!empty($merchant_user_data)){
  269. //$merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.05,2);
  270. //给推广者分配佣金
  271. $yj_amount_90 = round($pv * 0.05,2) * 0.9;
  272. $fgj_amount_10 = round($pv * 0.05,2) * 0.1;//推广者的佣金抽10%到个人复购金
  273. $yj_amount = $merchant_user_data['brokerage_price'] + $yj_amount_90;
  274. $fgj_amount = $merchant_user_data['fugou'] + $fgj_amount_10;
  275. $this->fugou_user_log($merchant_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
  276. //Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
  277. //推广佣金
  278. $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);
  279. }
  280. }
  281. //}
  282. //var_dump($ylj_amount);
  283. }
  284. //VIP专区
  285. }else if($store_order_data['mer_id'] == 496){
  286. //业务员和以上推广的等级获得推广佣金
  287. $le_yw_amount = 0;
  288. //获赠的贡献值和积分
  289. $gx_jf = 0;
  290. $yj1 = 0;
  291. if($store_product_data['price'] == 1180){
  292. $pv = 1000;
  293. $gx_jf = 700;
  294. $yj1 = 100;
  295. $le_yw_amount = 300;
  296. }else if($store_product_data['price'] == 10620){
  297. $pv = 9000;
  298. $gx_jf = 6300;
  299. $yj1 = 900;
  300. $le_yw_amount = 2700;
  301. }else if($store_product_data['price'] == 11800){
  302. $pv = 10000;
  303. $gx_jf = 7000;
  304. $yj1 = 1000;
  305. $le_yw_amount = 3000;
  306. }else if($store_product_data['price'] == 9440){
  307. $pv = 8000;
  308. $gx_jf = 5600;
  309. $yj1 = 800;
  310. $le_yw_amount = 2400;
  311. }else if($store_product_data['price'] == 2360){
  312. $pv = 2000;
  313. $gx_jf = 1400;
  314. $yj1 = 200;
  315. $le_yw_amount = 600;
  316. }
  317. $ylj_pri = round($pv * 0.035,2);
  318. //$pv = round($pv * 0.35,2);
  319. //分配养老金给消费者
  320. //普通用户获取贡献值和pv3.5%养老金和积分
  321. $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
  322. $gxz_amount_mine = $user_data['contribute'] + $gx_jf;
  323. $jf_amount_mine = $user_data['score'] + $gx_jf;
  324. //Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,'contribute'=> $gxz_amount_mine,'score'=> $jf_amount_mine]);
  325. $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
  326. //$this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1);
  327. $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送积分",1);
  328. //查询下单用户上级身份(2.0新表用户)
  329. $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
  330. //查询下单用户上级身份(1.0表用户,会员升级)
  331. $spread_data_old = 0;
  332. if($user_data['spread_old'] != 0){
  333. $sf = Db::name('old_user_jbp')->where('id',$user_data['spread_old'])->find();
  334. if(!empty($sf)){
  335. $spread_data_old = $sf;
  336. }
  337. }
  338. //给推广者分配养老金
  339. //给推广者分配佣金(2.0系统中)
  340. if($user_data['spread_uid'] != 0){
  341. $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
  342. //user_group=1是消费者,2:业务,3:业务经理,4:初级合伙人,5:中级合伙人,6:高级合伙人,7:董事
  343. //业务或以上等级推广人
  344. //获得养老金、佣金、贡献值和积分
  345. if($spread_data['user_group'] > 1){
  346. $con =0;//贡献值
  347. $score = 0;//积分
  348. //养老金
  349. $uer_bill = $spread_data['annuity'] + round($pv * 0.035,2);
  350. $yj_amount_90 = $le_yw_amount * 0.9;
  351. $fgj_amount_10 = $le_yw_amount * 0.1;//推广者的佣金抽10%到个人复购金
  352. $yongjin = $spread_data['brokerage_price'] + $yj_amount_90;
  353. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  354. if($spread_data['user_group'] == 2){
  355. $con = $spread_data['contribute'] + round($pv * 0.07,2);
  356. $score = $spread_data['brokerage_price'] + round($pv * 0.07,2);
  357. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  358. //贡献值
  359. // $this->con_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  360. //积分
  361. $this->score_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  362. }else if($spread_data['user_group'] == 3){
  363. $con = $spread_data['contribute'] + round($pv * 0.09,2);
  364. $score = $spread_data['brokerage_price'] + round($pv * 0.09,2);
  365. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  366. //贡献值
  367. // $this->con_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  368. //积分
  369. $this->score_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  370. }else if($spread_data['user_group'] == 4){
  371. $con = $spread_data['contribute'] + round($pv * 0.11,2);
  372. $score = $spread_data['brokerage_price'] + round($pv * 0.11,2);
  373. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  374. //贡献值
  375. // $this->con_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  376. //积分
  377. $this->score_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  378. }else if($spread_data['user_group'] == 5){
  379. $con = $spread_data['contribute'] + round($pv * 0.13,2);
  380. $score = $spread_data['brokerage_price'] + round($pv * 0.13,2);
  381. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  382. //贡献值
  383. // $this->con_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  384. //积分
  385. $this->score_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  386. }else if($spread_data['user_group'] == 6){
  387. $con = $spread_data['contribute'] + round($pv * 0.15,2);
  388. $score = $spread_data['brokerage_price'] + round($pv * 0.15,2);
  389. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  390. //贡献值
  391. //$this->con_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  392. //积分
  393. $this->score_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  394. }else if($spread_data['user_group'] == 7){
  395. $con = $spread_data['contribute'] + round($pv * 0.17,2);
  396. $score = $spread_data['brokerage_price'] + round($pv * 0.17,2);
  397. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);
  398. //贡献值
  399. //$this->con_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  400. //积分
  401. $this->score_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  402. }
  403. $this->con_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  404. //养老金
  405. $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
  406. //佣金
  407. $this->bill_user_log($spread_data['uid'], $yj_amount_90,$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'. $yj_amount_90,$store_order_data['mer_id']);
  408. //复购金
  409. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1);
  410. }
  411. //普通的用户推广人
  412. if($spread_data['user_group'] == 1){
  413. // $yj_amount = $spread_data['annuity'] + round($pv * 0.01,2);
  414. // Db::name('user')->where('uid',$user_data['spread_uid'])->update(['annuity'=>$ylj_amount,'brokerage_price'=>$yj_amount]);
  415. // //推广养老金
  416. // $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']);
  417. // //推广佣金
  418. // $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']);
  419. //获取贡献值和积分和佣金
  420. $gx_jf = $spread_data['contribute'] + round($pv * 0.21,2);
  421. //$yj111 = $spread_data['brokerage_price'] + $yj1;
  422. $yj_amount_90 = round($yj1 * 0.9,2);
  423. $fgj_amount_10 = round($yj1 * 0.1,2);//推广者的佣金抽10%到个人复购金
  424. $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
  425. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  426. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1);
  427. //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $gx_jf,'score'=> $gx_jf,'brokerage_price'=> $yj_amount,'fugou'=>$fgj_amount]);
  428. $this->con_log($spread_data['uid'],round($pv * 0.21,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值",1);
  429. $this->score_log($spread_data['uid'],round($pv * 0.21,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);
  430. //推广佣金
  431. $this->bill_user_log($spread_data['uid'],$yj_amount_90,$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.$yj_amount_90,$store_order_data['mer_id']);
  432. }
  433. }else if(!empty($spread_data_old)){
  434. //1.0jbp系统中,如果有用户升级会员,给推荐人贡献值(90%)和养老金(10%)
  435. $spread_data = Db::name('user')->where('uid',$spread_data_old['id'])->find();
  436. // $spread_data = Db::name('user')->where('uid',473)->find();
  437. //养老金
  438. $uer_bill = $spread_data['annuity'] + round($pv * 0.035,2);
  439. $yj_amount_90 = $le_yw_amount * 0.9;
  440. $fgj_amount_10 = $le_yw_amount * 0.1;//推广者的佣金抽10%到个人复购金
  441. $yongjin = $spread_data['brokerage_price'] + $yj_amount_90;
  442. $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
  443. //养老金
  444. $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
  445. //佣金
  446. $this->bill_user_log($spread_data['uid'], $yj_amount_90,$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'. $yj_amount_90,$store_order_data['mer_id']);
  447. //复购金
  448. $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1);
  449. $orderInfo=[
  450. 'num'=>1,
  451. 'gb_num'=>1,
  452. 'price'=>$store_product_data['price']
  453. ];
  454. $goods_of_info1 = Db::name("old_user_of_goods")->where("id", $store_order_data['user_of_goods_id'])->find();//用户的订单价格表
  455. if(!empty($goods_of_info1)){
  456. $this->member_update($orderInfo,$goods_of_info1,$user_data['uid']);
  457. }
  458. }
  459. //锁客收益
  460. if($user_data['mer_id'] != 0){
  461. $merchant_data = Db::name('merchant')->where('mer_id',$user_data['mer_id'])->find();
  462. $merchant_user_data = Db::name('user')->where('uid',$merchant_data['uid'])->find();
  463. if(!empty($merchant_user_data)){
  464. $yj_amount_90 = round($pv * 0.035,2) * 0.9;
  465. $fgj_amount_10 = round($pv * 0.035,2) * 0.1;//推广者的佣金抽10%到个人复购金
  466. $yj_amount = $merchant_data['brokerage_price'] + $yj_amount_90;
  467. $fgj_amount = $merchant_data['fugou'] + $fgj_amount_10;
  468. $this->fugou_user_log($merchant_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1);
  469. //Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
  470. //推广佣金
  471. $this->bill_user_log($merchant_data['uid'],round($pv * 0.35,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.35,2),$store_order_data['mer_id']);
  472. }
  473. }
  474. }
  475. //判断是否是精彩生活区的商品
  476. if($store_order_data['mer_id'] == 439){
  477. //供应链的状态
  478. Db::name('store_order')->where('group_order_id', $group_order_id)->update(['douhuomall'=>1,'douhuomall_status'=>9]);
  479. }
  480. //判断是否是自营商品,如果是自营商品需要更改这个值
  481. if($store_order_data['mer_id'] == 496){
  482. //自营商品
  483. Db::name('store_order')->where('group_order_id', $group_order_id)->update(['distribution_mode'=>1]);
  484. }
  485. //利润分配 end
  486. //商城订单
  487. //判断下,如果是组合支付中,现金+积分的形式支付情况下
  488. $array_fzone_paytype = json_decode( $store_order_data['fzone_paytype'],true);
  489. if($array_fzone_paytype['type']=='b2'){
  490. if(!empty($array_fzone_paytype['other']) && is_numeric($array_fzone_paytype['other']) == true){
  491. $vrpri = $user_data['score'] - $array_fzone_paytype['other'];
  492. // // //现金+积分
  493. if($vrpri >= 0 ){
  494. Db::name("user")->where("uid", $user_data['uid'])->update(['score'=>$vrpri]);
  495. }else{
  496. $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']];
  497. Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
  498. }
  499. }else{
  500. $note_arr = ["uid"=>$user_data['uid'],"msg"=>"数据异常","fzone_paytype"=>$store_order_data['fzone_paytype']];
  501. Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
  502. }
  503. }
  504. //end 现金+积分
  505. //如果注释了event事件,需要手动修改订单状态 1:代发货
  506. Db::name('store_order')->where('group_order_id', $group_order_id)->update(['status'=>0]);
  507. $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']]);
  508. Db::name('store_group_order')->where('group_order_id',$group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s')]);
  509. event('pay_success_order', ['order_sn' => $requestId[0],'pay_type'=>$pay_type]);
  510. break;
  511. case 'pay_channel':
  512. //渠道商
  513. try{
  514. $order_data=Db::name('channel_order') -> where('order_no',$requestId[0]) -> find();
  515. if($order_data['status']==1){
  516. return false;
  517. }
  518. $pay_type = $pay_type == 1 ? 'wx' : 'al';
  519. Db::name('channel_user')->where('uid',$order_data['uid'])->update(['status'=>1]);
  520. Db::name('channel_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'pay_type'=>$pay_type,'status'=>1]);
  521. }catch (\Exception $e) {
  522. Db::name('log')->insert(['data'=>'支付渠道商错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  523. }
  524. try{
  525. $access = new Access();
  526. //分佣
  527. $access->channel_fenyong($requestId[0]);
  528. // //给7个激活码
  529. // for($i=0;$i<=6;$i++){
  530. // Db::name('activation_code')->insertGetId([
  531. // 'uid'=>$order_data['uid'],
  532. // 'code'=>$this->randomFromDev(20),
  533. // 'ctime'=>time(),
  534. // 'status'=>1,
  535. // 'utime'=>time(),
  536. // 'use_uid'=>0,
  537. // 'type'=>2
  538. // ]);
  539. // }
  540. //赠送返本商户
  541. $mer = Db::name('user_mer') -> where('uid',$order_data['uid']) -> find();
  542. if(!$mer){
  543. Db::name('user_mer') -> insert(['uid'=>$order_data['uid'],'mer'=>10]);
  544. }else{
  545. Db::name('user_mer') -> where('uid',$order_data['uid'])->inc('mer', 10) ->update();;
  546. }
  547. //赠送商户
  548. $merchant=Db::name('merchant')->where('uid',$order_data['uid'])->find();
  549. if(!$merchant)
  550. Db::name('merchant_intention')->insert(['uid'=>$order_data['uid'],'status'=>3,'activation_code'=>rand('000000000','999999999')]);
  551. //赠送大仓会员资格
  552. $dacang_user = Db::name('da_cang_user')->where('uid', $order_data['uid'])->find();
  553. $time = date('Y-m-d', time());
  554. $time = strtotime($time);
  555. $end_time = $time + 31536000 - 1;
  556. $dc_id = 1;
  557. //如果不是金卡会员,赠送金卡会员一年
  558. if (!$dacang_user) {
  559. Db::name('da_cang_user')->insert(['uid' => $order_data['uid'], 'ctime' => time(), 'end_time' => $end_time, 'dc_id' => $dc_id,'status'=>1,'type'=>1]);
  560. }else{
  561. //如果是银卡会员,变成金卡,一年 || 是否已过期,如果已过期,赠送金卡会员一年
  562. if($dacang_user['type'] == 2 || $dacang_user['end_time'] < $time){
  563. Db::name('da_cang_user')->where('uid', $order_data['uid'])->where('dc_id', $dc_id)->update(['end_time' => $end_time,'status'=>1,'type'=>1]);
  564. }
  565. }
  566. }catch (\Exception $exception){
  567. Db::name('log')->insert(['data'=>'渠道商处理错误:'.$exception->getFile().':'.$exception->getLine().'【'.$exception->getMessage().'】']);
  568. }
  569. break;
  570. case 'pay_annual':
  571. //商户
  572. $annual_cost_order=Db::name('merchant_annual_cost_order')-> where('order_no',$requestId[0])->find();
  573. if($annual_cost_order['status'] == 0) {
  574. $pay_type = $pay_type == 1 ? 'wx' : 'al';
  575. Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->update(['rand' => $requestId[1],'pay_type'=>$pay_type,'status' => 1]);
  576. //如果有商户id就是续费
  577. $mer_id = Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->value('mer_id');
  578. if ($mer_id !== 0) {
  579. $expire_time = strtotime(date('Y-m-d')) + 86400 * 365 + 86400 - 1;
  580. Db::name('merchant')->where('mer_id', $mer_id)->update(['expire_time' => $expire_time, 'status' => 1]);
  581. }
  582. $mer = Db::name('user_mer') -> where('uid',$annual_cost_order['uid']) -> find();
  583. if(!$mer){
  584. Db::name('user_mer') -> insert(['uid'=>$annual_cost_order['uid'],'mer'=>2]);
  585. }else{
  586. Db::name('user_mer') -> where('uid',$annual_cost_order['uid'])->inc('mer', 2) ->update();;
  587. }
  588. $access = new Access();
  589. $access->nianfei_yj($annual_cost_order['id']);
  590. }
  591. break;
  592. case 'pay_activation':
  593. try{
  594. $order_data=Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> find();
  595. if($order_data['status']==1){
  596. return false;
  597. }
  598. $access = new Access();
  599. $id=Db::name('activation_code')->insertGetId([
  600. 'uid'=>$order_data['uid'],
  601. 'code'=>$access->randomFromDev(20),
  602. 'ctime'=>time(),
  603. 'status'=>1,
  604. 'utime'=>time(),
  605. 'use_uid'=>0,
  606. 'type'=>1
  607. ]);
  608. Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'status'=>1,'code_id'=>$id]);
  609. }catch (\Exception $e) {
  610. Db::name('log')->insert(['data'=>'支付激活码错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  611. }
  612. //处理佣金
  613. $num=$access->activation_yj($requestId[0]);
  614. //分账
  615. $access->activation_spilet($requestId[0],$num);
  616. break;
  617. case 'notify_order':
  618. Db::name("log")->insert(array('data'=>'汇付退款回调'));//日志记录
  619. break;
  620. case 'marketing':
  621. $marketing_order=Db::name('marketing_order')-> where('order_no',$requestId[0])->find();
  622. if($marketing_order['status']==1){
  623. return app('json')->success(['result' => 'SUCCESS']);
  624. }
  625. // $pay_type = $pay_type == 1 ? 'wx' : 'ali';
  626. $checkUser = Db::name("MarketingUser") -> where('uid',$marketing_order['uid'])->find();
  627. $handle = $this -> marketing($marketing_order,$checkUser);
  628. if ($handle){
  629. //分账
  630. $this -> pay_user_annual($marketing_order['uid']);
  631. }
  632. break;
  633. case 'pay_user_annual':
  634. $user_pension_account_order=Db::name('user_pension_account_order')-> where('order_no',$requestId[0])->find();
  635. if($user_pension_account_order['status']==1){
  636. return app('json')->success(['result' => 'SUCCESS']);
  637. }
  638. $this -> pay_user_annual($user_pension_account_order['uid'],$requestId[0]);
  639. break;
  640. default:
  641. Db::name("log")->insert(array('data'=>$type));//日志记录
  642. }
  643. }
  644. return app('json')->success(['result' => 'SUCCESS']);
  645. }catch (\Exception $exception){
  646. Db::name("log")->insert(array('data'=>'汇付回调错误:'.$exception->getFile().':'.$exception->getLine().'【'.$exception->getMessage().'】'));//日志记录
  647. return app('json')->success(['result' => 'ERROR']);
  648. }
  649. }
  650. }
  651. /**
  652. * 会员升级
  653. */
  654. public function member_update($orderInfo,$goods_of_info,$user_id)
  655. {
  656. //code...
  657. $pay_gb = round($orderInfo['num'] * $orderInfo['gb_num'],2);
  658. //$pay_vr = round($orderInfo['num'] * $orderInfo['vr_num'],2);
  659. //付款按照700的VR付款 start
  660. $vr_num = 0;
  661. if ($orderInfo['price'] == 1180) {
  662. $vr_num = 700;
  663. } elseif ($orderInfo['price'] == 11800) {
  664. $vr_num = 7000;
  665. } elseif ($orderInfo['price'] == 11800) {
  666. $vr_num = 2100;
  667. }elseif($orderInfo['price'] == 10620){
  668. $vr_num = 6300;
  669. }
  670. $pay_gb1 = $vr_num;
  671. $pay_vr1 =$orderInfo['price'];//记录VR值
  672. // $result = Db::name("old_user_jbp")->where("id",$user_id)->dec("vr",$orderInfo['price'])->save();//1.0jbp旧表
  673. // Db::name("user")->where("uid",$user_id)->dec("vr",$orderInfo['price'])->save();//2.0新表
  674. $result = true;
  675. if($result) {
  676. $invite_id = $goods_of_info['spread_id'];
  677. $zs_ylj = 0; //养老金赋值
  678. if($goods_of_info['money'] == 1180){
  679. //修改订单到账状态
  680. $zs_ylj = round(700 * 0.05,2);//计算的养老金 金额
  681. }elseif($goods_of_info['money'] == 11800){
  682. $zs_ylj = round(7000 * 0.05,2);//计算的养老金 金额
  683. }elseif($goods_of_info['money'] == 3540){
  684. $zs_ylj = round(2100 * 0.05,2);//计算的养老金 金额
  685. }elseif($goods_of_info['money'] == 10620){
  686. $zs_ylj = round(6300 * 0.05,2);//计算的养老金 金额
  687. }elseif($goods_of_info['money'] == 9440){
  688. $zs_ylj = round(5600 * 0.05,2);//八单计算的养老金 金额
  689. }elseif($goods_of_info['money'] == 2360){
  690. $zs_ylj = round(1400 * 0.05,2);//两单计算的养老金 金额
  691. }
  692. $uid = $user_id;
  693. $new_user_id = $uid;
  694. if(empty($new_user_id)) {
  695. abort(0,"当前绑定会员查询错误");
  696. }
  697. $new_nums =Db::name("old_user_of_goods")->where("user_id", $uid)->sum("money");
  698. //增加过后权益对比 获取当前权益等级
  699. $old_level_id = Db::name("old_user_jbp")->where("id",$uid)->find();
  700. $old_level_info = Db::name("old_user_level")->where("id",$old_level_id['user_level_id'])->find();
  701. $level_info = [];
  702. $level_list = Db::name("old_user_level")->order("money desc")->select();
  703. //计算会员等级 升级
  704. foreach ($level_list as $key => $value) {
  705. # code...
  706. if($new_nums>=$value['money']) {
  707. $level_info = $value;
  708. break;
  709. }
  710. }
  711. $zs_gb = $orderInfo['price'] * 3;
  712. $zs_withdraw_quota = $orderInfo['price'];
  713. if($old_level_info['id'] == $level_info['id']) {
  714. //未到达升级权益 不改变用户等级
  715. $update_status = false;
  716. }else{
  717. $update_status = true;
  718. $user_level = $level_info['id'];
  719. //var_dump( $user_level);
  720. Db::name("old_user_jbp")->where("id",$new_user_id)->save(['user_level_id'=>$user_level]);//1.0jbp旧表
  721. Db::name("user")->where("uid",$new_user_id)->save(['user_level_id_old'=>$user_level]);//2.0新表
  722. // todo 同时改变他的权益
  723. }
  724. // Db::name("old_user_jbp")->where("id",$new_user_id)->inc("withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表
  725. // Db::name("user")->where("uid",$new_user_id)->save(['withdraw_quota_old'=>$zs_withdraw_quota]);//2.0新表
  726. // 下发邀请人赠送的GB
  727. // $zs_invite_gb = round($orderInfo['price']*0.3,2);
  728. // //todo
  729. // Db::name("old_user_jbp")->where("id",$invite_id)->inc("gb",$zs_invite_gb)->save();//1.0jbp旧表
  730. // Db::name("user")->where("uid",$invite_id)->inc("score",$zs_invite_gb)->save();//2.0新表
  731. //$old_have_pension = Db::name("old_user_jbp")->where("id",$invite_id)->value("have_pension");
  732. //检查是不是订单价格是1180或者11800,更改VR
  733. 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){
  734. //修改订单到账状态
  735. Db::name("old_user_of_goods")->where("id",$goods_of_info['id'])->save(['status'=>1,'money'=>$goods_of_info['money'],'pay_gb'=>0,'pay_vr'=>$pay_vr1,'pay_bt'=>0,'create_time'=>time()]);
  736. }
  737. }
  738. if($result) {
  739. //更改订单状态
  740. Db::commit();
  741. $new_user_name = Db::name("old_user_jbp")->where("id",$new_user_id)->value("user_name");
  742. $new_user_name = empty($new_user_name) ? "" : $new_user_name;
  743. //记录日志信息
  744. if($user_id == $invite_id) {
  745. //报单中心=推荐人 GB记录日志有问题需要传入指定参数去计算
  746. //$money = Db::name("old_user_jbp")->where("id",$user_id)->value("gb");
  747. //$appoint_money = $money - $zs_invite_gb;
  748. 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){
  749. $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);
  750. }
  751. }else{
  752. 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){
  753. $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);
  754. }
  755. }
  756. // $this->change_user_log66($new_user_id,'gb',1,$zs_gb,"levle_update_zs","权益升级达标赠送");
  757. $this->change_user_log66($new_user_id,'withdraw_quota_old',1,$zs_withdraw_quota,"levle_update_zs","权益升级达标赠送");
  758. // $this->change_user_log66($invite_id,'gb',1,$zs_invite_gb,"levle_update_zs","邀请-".$new_user_name);
  759. // echo 123;return;
  760. //处理查看是否有待发放佣金
  761. // $zs_withdraw_quota
  762. Db::name("old_user_jbp")->where("id",$new_user_id)->inc("total_withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表
  763. Db::name("user")->where("uid",$new_user_id)->inc("total_withdraw_quota_old",$zs_withdraw_quota)->save();
  764. // $this->releaseTobeAmount($new_user_id,$zs_withdraw_quota);
  765. // $this->success("支付成功",['is_cash'=>0]);
  766. }
  767. Db::rollback();
  768. // $this->error("操作失败");
  769. }
  770. function change_user_log66($user_id,$type,$change_status,$money,$routine,$remark="",$is_admin=1,$appoint_money = 0)
  771. {
  772. $transition = [
  773. 'pv'=>1,
  774. "gb"=>2,
  775. "df"=>3,
  776. "vr"=>4,
  777. "bt"=>5,
  778. "withdraw_quota_old"=>6,
  779. "unsettled_pension"=>7,
  780. "amount_old"=>8
  781. ];
  782. $routineInfo = Db::name("old_routine_log_of_key")->where("key",$routine)->find();
  783. if(empty($routineInfo)) {
  784. return false;
  785. }
  786. $key_id = isset($routineInfo['id']) ? $routineInfo['id'] : 0;
  787. //再去查询变更前的 金额
  788. if($appoint_money > 0) {
  789. $alter_money = $appoint_money;
  790. }else{
  791. //再去查询变更前的 金额
  792. $alter_money = Db::name("user")->where('uid',$user_id)->value($type);
  793. }
  794. if($change_status == 1) {
  795. //新增前
  796. $alter_money = $alter_money-$money;
  797. }else if($change_status == 2){
  798. //减少前
  799. $alter_money = $alter_money + $money;
  800. }
  801. $inser_data = [];
  802. $inser_data['user_id'] = $user_id;
  803. $inser_data['type'] = $transition[$type];
  804. $inser_data['change_status'] = $change_status;
  805. $inser_data['money'] = $money;
  806. $inser_data['routine_log_of_key_id'] = $key_id;
  807. $inser_data['remark'] = $remark;
  808. $inser_data['is_admin'] = $is_admin;
  809. $inser_data['create_time'] = time();
  810. $inser_data['alter_money'] = isset($alter_money) ? $alter_money : 0;
  811. Db::name("old_user_log")->insert($inser_data);
  812. }
  813. public function pay_user_annual($uid,$order_no=''){
  814. Db::startTrans();
  815. try {
  816. if ($order_no != ''){
  817. Db::name('user_pension_account_order')-> where('order_no',$order_no) -> update(['status'=>1]);
  818. }
  819. $check = Db::name("user_pension_account") -> where("uid",$uid) -> find();
  820. $start_time = date('Y-m-d');
  821. $end_time = date("Y-m-d 23:59:59",strtotime("+1 year", strtotime($start_time)));
  822. $give = 0;
  823. //存在既续费
  824. if ($check){
  825. Db::name("user_pension_account") -> where("uid",$uid) -> update(['start_time'=>$start_time,'end_time'=>$end_time]);
  826. $give = $check['give'];
  827. }else{
  828. //新用户订单
  829. Db::name("user_pension_account") -> insert([
  830. "uid" => $uid,
  831. "start_time" => $start_time,
  832. "end_time" => $end_time,
  833. "status" => 1,
  834. ]);
  835. }
  836. if ($give == 0){
  837. Db::name("user_pension_account") -> where("uid",$uid) -> update(['give' => 1]);
  838. $mark = "开通养老金账户";
  839. $billData=[
  840. 'uid'=>$uid,
  841. 'pm'=>1,
  842. 'title'=>'养老金',
  843. 'category'=>'now_money',
  844. 'type'=>'commission',
  845. 'number'=>0.01,
  846. 'balance'=>0,
  847. 'mark'=>$mark,
  848. 'create_time'=>date("Y-m-d H:i:s",time()),
  849. 'status'=>1,
  850. 'order_sn'=>'',
  851. 'type_shop'=>0,
  852. 'commission_type'=>5,
  853. 'order_type'=>1,
  854. 'gzc'=>0
  855. ];
  856. Db::name('user_bill')->insert($billData);
  857. Db::name("user")->where("uid",$uid)->inc('annuity', 0.01) ->update();
  858. Db::name("user")->where("uid",$uid)->inc('annuity_num', 1) ->update();
  859. }
  860. // 提交事务
  861. Db::commit();
  862. return true;
  863. } catch (\Exception $e) {
  864. // 回滚事务
  865. Db::rollback();
  866. Log::error($e->getMessage());
  867. }
  868. }
  869. public function marketing($order,$marketingUser,$pay_type="wx"){
  870. Db::startTrans();
  871. try {
  872. Db::name('marketing_order') -> where('order_no',$order['order_no']) -> update(['pay_type'=>$pay_type,'status'=>1]);
  873. Db::name('marketing_user') -> where('uid',$order['uid']) -> update(['type'=>$order['type']]);
  874. //分红份数及资金
  875. $divvy_number = ceil(bcdiv($order['pay_price'],99));
  876. $divvy_money = $order['pay_price'];
  877. Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_number', $divvy_number) ->update();
  878. Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_money', $divvy_money) ->update();
  879. //上级
  880. $spread_uid = $marketingUser['spread_uid'];
  881. //养老金
  882. //本人给养老金10%
  883. $ylj=bcmul($order['pay_price'],'0.1',5);//10%的养老金
  884. $ylj=round($ylj,2);
  885. $title='养老金';
  886. if ($order['type'] == 1){
  887. $identity = "普通会员";
  888. }elseif ($order['type'] == 2){
  889. $identity = "创客";
  890. }elseif ($order['type'] == 3){
  891. $identity = "合伙人";
  892. }else{
  893. $identity = "";
  894. }
  895. $mark = "成为{$identity}获得{$ylj}养老金";
  896. $billData=[
  897. 'uid'=>$order['uid'],
  898. 'link_id'=>$order['id'],
  899. 'pm'=>1,
  900. 'title'=>$title,
  901. 'category'=>'now_money',
  902. 'type'=>'commission',
  903. 'number'=>$ylj,
  904. 'balance'=>0,
  905. 'mark'=>$mark,
  906. 'create_time'=>date("Y-m-d H:i:s",time()),
  907. 'status'=>1,
  908. 'order_sn'=>$order['order_no'],
  909. 'type_shop'=>0,
  910. 'commission_type'=>5,
  911. 'order_type'=>1,
  912. 'gzc'=>0
  913. ];
  914. Db::name('user_bill')->insert($billData);
  915. Db::name("user")->where("uid",$order['uid'])->inc('annuity', $ylj) ->update();
  916. Db::name("user")->where("uid",$order['uid'])->inc('annuity_num', 1) ->update();
  917. //上级佣金
  918. $checkSpread = Db::name("MarketingUser") -> where('uid',$spread_uid)->value("type");
  919. //检查上级身份 必须是会员或以上
  920. if ($checkSpread > 0){
  921. $commission=bcmul($order['pay_price'],'0.3',5);//30%的佣金
  922. $commission=round($commission,2);
  923. $spreadTitle='佣金';
  924. $spreadMark = "推广{$identity}获得{$commission}佣金";
  925. $spreadBillData=[
  926. 'uid'=>$spread_uid,
  927. 'link_id'=>$order['id'],
  928. 'pm'=>1,
  929. 'title'=>$spreadTitle,
  930. 'category'=>'now_money',
  931. 'type'=>'commission',
  932. 'number'=>$commission,
  933. 'balance'=>0,
  934. 'mark'=>$spreadMark,
  935. 'create_time'=>date("Y-m-d H:i:s",time()),
  936. 'status'=>1,
  937. 'order_sn'=>$order['order_no'],
  938. 'type_shop'=>0,
  939. 'commission_type'=>11,
  940. 'order_type'=>1
  941. ];
  942. Db::name('user_bill')->insert($spreadBillData);
  943. Db::name('user')->where('uid',$spread_uid)->inc('brokerage_price',$commission)->update();
  944. }
  945. $spread_list = $marketingUser['spread_list'];
  946. $spread_list = str_replace(['[', ']'], '', $spread_list);
  947. $spread_list = explode(',',$spread_list);
  948. //计算所有上级的累计销售业绩 赠送积分
  949. $achievement = $this -> achievement($spread_list,$order['uid'],$order['pay_price']);
  950. foreach($achievement as $key => $value){
  951. $spreadTitle='业务销售奖励积分';
  952. $achievementMark = "团队推广{$identity}获得{$value['commission']}积分";
  953. $integral = Db::name("marketing_user") -> where('uid',$spread_uid) -> value("integral");
  954. $achievementBillData=[
  955. 'uid'=>$key,
  956. 'pm'=>1,
  957. 'title'=>$spreadTitle,
  958. 'integral'=>$value['commission'],
  959. 'residual_integral' => $integral + $value['commission'],
  960. // 'mark'=>$achievementMark,
  961. 'order_sn'=>$order['order_no'],
  962. ];
  963. Db::name('marketing_integral')->insert($achievementBillData);
  964. Db::name('marketing_user')->where('uid',$spread_uid)->inc('integral',$value['commission'])->update();
  965. }
  966. if ($order['type'] == 2 || $order['type'] == 3) {
  967. //赠送商户
  968. $merchant=Db::name('merchant')->where('uid',$order['uid'])->find();
  969. if(!$merchant) {
  970. $access = new Access();
  971. $activation_code = $access->randomFromDev(20);
  972. // Db::name('activation_code')->insertGetId([
  973. // 'uid' => $order['uid'],
  974. // 'code' => $activation_code,
  975. // 'ctime' => time(),
  976. // 'status' => 1,
  977. // 'utime' => time(),
  978. // 'use_uid' => $order['uid'],
  979. // 'type' => 1
  980. // ]);
  981. Db::name('merchant_intention')->insert(['uid' => $order['uid'], 'status' => 3, 'activation_code' => $activation_code]);
  982. }
  983. }
  984. // 提交事务
  985. Db::commit();
  986. return true;
  987. } catch (\Exception $e) {
  988. // 回滚事务
  989. Db::rollback();
  990. Log::error($e->getMessage());
  991. return false;
  992. }
  993. }
  994. public function achievement($lists,$uid,$pay_price){
  995. $newList = [];
  996. $lastAchievement = 0;
  997. $lastCommission = 0;
  998. $total = 0;
  999. $list=array_reverse($lists);
  1000. foreach($list as $value){
  1001. $checkSpread = Db::name("MarketingUser") -> where('uid',$value)->value("type");
  1002. //检查上级身份 必须是会员或以上
  1003. if ($checkSpread <= 0) continue;
  1004. $achievement = Db::name('marketing_order')
  1005. ->where('uid','in',function($query) use ($value,$uid){
  1006. $query->name('marketing_user')-> where("spread_list like '%[$value]%' or uid = $value","") -> where("uid","<>",$uid) -> field("uid");
  1007. })
  1008. -> where("status",1)
  1009. ->sum("pay_price");
  1010. if ($achievement >= 50000 && $achievement < 300000){
  1011. $c = round(bcmul($pay_price,'0.1',5),2);//10%
  1012. //如果业绩大于5万,小于30万。并且业绩等级等于1。奖励等于上个人的奖励减半
  1013. if ($lastAchievement == 1){
  1014. $c = round(bcmul($lastCommission,0.5,5),2);
  1015. }
  1016. $lastCommission = $c;
  1017. $lastAchievement = 1;
  1018. $total += $c;
  1019. $newList[$value] = [
  1020. "achievement" => $achievement,
  1021. "commission" => $c
  1022. ];
  1023. }elseif ($achievement >= 300000 && $achievement < 1000000){
  1024. $c = round(bcmul($pay_price,'0.15',5),2);//15%
  1025. //如果业绩大于5万,小于30万。并且业绩等级等于2。奖励等于上个人的奖励减半
  1026. if ($lastAchievement == 2){
  1027. $c = round(bcmul($lastCommission,0.5,5),2);
  1028. }else{
  1029. $c = $c - $total;
  1030. }
  1031. $lastAchievement = 2;
  1032. if ($c > 0){
  1033. $total += $c;
  1034. $lastCommission = $c;
  1035. $newList[$value] = [
  1036. "achievement" => $achievement,
  1037. "commission" => $c
  1038. ];
  1039. }else{
  1040. $lastCommission = 0;
  1041. }
  1042. }elseif ($achievement >= 1000000){
  1043. $c = round(bcmul($pay_price,'0.2',5),2);//20%
  1044. //如果业绩大于5万,小于30万。并且业绩等级等于3。奖励等于上个人的奖励减半
  1045. if ($lastAchievement == 3){
  1046. $c = round(bcmul($lastCommission,0.5,5),2);
  1047. }else{
  1048. $c = $c - $total;
  1049. }
  1050. $total += $c;
  1051. $lastAchievement = 3;
  1052. if ($c > 0){
  1053. $total += $c;
  1054. $lastCommission = $c;
  1055. $newList[$value] = [
  1056. "achievement" => $achievement,
  1057. "commission" => $c
  1058. ];
  1059. }else{
  1060. $lastCommission = 0;
  1061. }
  1062. }
  1063. }
  1064. return $newList;
  1065. }
  1066. //添加贡献值日志
  1067. public function con_log($uid,$num,$order_id,$order_type,$mark,$status = -1){
  1068. $con_data = Db::name('user')->where("uid",$uid)->find();
  1069. //如果状态是1那就是即刻入账,
  1070. if($status == 1){
  1071. $con_data_gongxian = Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]);
  1072. }
  1073. $con = [
  1074. 'uid'=>$uid,
  1075. 'number'=>$num,//赠送数量
  1076. 'status'=>$status,//红包状态
  1077. 'mark'=>$mark,//备注
  1078. 'desc'=>'',//描述
  1079. 'order_id'=>$order_id,//订单id
  1080. 'surplus'=> $con_data['contribute'],//剩余
  1081. 'order_type'=>$order_type,//订单类型
  1082. 'type'=>1,//1增加,2消耗
  1083. 'settlement_time'=>date('Y-m-d H:i:s'),
  1084. 'addtime'=>time()
  1085. ];
  1086. Db::name('user_sign_gongxian')->insert($con);
  1087. }
  1088. //添加积分日志
  1089. public function score_log($uid,$num,$order_id,$order_type,$mark,$status = -1){
  1090. $score_data = Db::name('user')->where("uid",$uid)->find();
  1091. //如果状态是1那就是即刻入账,
  1092. if($status == 1){
  1093. $con_data_score = Db::name('user')->where("uid",$uid)->update(['score'=>$score_data['score'] + $num]);
  1094. }
  1095. $score = [
  1096. 'uid'=>$uid,
  1097. 'continuity_day'=>0,//连续签到天数
  1098. 'reward_socre'=>$num,//积分数量
  1099. 'signin_time'=>0,//签到时间
  1100. 'source_uid'=>0,//赠送积分用户来源id
  1101. 'status'=>$status,//积分状态1:有效,0:失效,1:待确认
  1102. 'mark'=> $mark,//备注
  1103. 'order_id'=>$order_id,//订单id
  1104. 'pm'=>1,//1收入,2支出
  1105. 'surplus'=> $score_data['score'],//剩余
  1106. 'order_type'=>$order_type,//订单类型 ,10精彩生活区,11会员区,12复购区
  1107. 'source_type'=>3,//积分类型,1签到,2分享好友注册赠送,3自己下单赠送
  1108. 'settlement_time'=>date('Y-m-d H:i:s'),
  1109. 'addtime'=>time()
  1110. ];
  1111. Db::name('user_sign_score')->insert($score);
  1112. }
  1113. //添加推广佣金/养老金日志(养老金金额)
  1114. public function bill_user_log($uid,$num,$order_id,$comm_order_type,$order_sn,$mark,$merid,$ds=1){
  1115. $con_data = Db::name('user')->where("uid",$uid)->find();
  1116. //如果是会员专区就即刻到账
  1117. $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->find();
  1118. if($order_from_mer['mer_id'] == 496 && $comm_order_type==3){
  1119. // Db::name('user')->where("order_id",$order_id)->find();
  1120. Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]);
  1121. }
  1122. $name = '';
  1123. if($comm_order_type==3){
  1124. $name = '直推奖';
  1125. }else if($comm_order_type==5){
  1126. $name = '养老金';
  1127. }
  1128. $bill = [
  1129. 'uid'=>$uid,
  1130. 'link_id'=>$order_id,//关联订单id
  1131. 'pm'=>1,//0:支出,1:获得
  1132. 'title'=>$name,//账单标题
  1133. 'category'=>'now_money',//明细种类
  1134. 'type'=>'commission',//明细类型
  1135. 'number'=>$num,//明细数字
  1136. 'balance'=>0,//剩余
  1137. 'mark'=>$mark,//备注
  1138. 'create_time'=>date('Y-m-d H:i:s'),//添加时间
  1139. 'status'=>$ds,//0待确定,1有效,-1无效
  1140. 'commission_type'=>$comm_order_type,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
  1141. //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
  1142. //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
  1143. 'order_sn'=>$order_sn,//订单号
  1144. 'tripartite'=>0,//
  1145. 'type_shop'=>0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
  1146. 'mer_id'=>$merid,//商户id
  1147. 'source'=>0,//1线下 0线上
  1148. 'order_type'=>1,//1自营 2 第三方 订单类型
  1149. 'is_red_brokerage'=>0,//1红积分对冲佣金 0正常佣金
  1150. 'gzc'=>3,//养老金是否已进入公证处log表0:未进入。1:已进入
  1151. 'take_time'=>'',//结算时间
  1152. 'district_id'=>'',//
  1153. 'street_id'=>'',//
  1154. 'month'=>'',//月份
  1155. ];
  1156. Db::name('user_bill')->insert($bill);
  1157. }
  1158. //添加复购金
  1159. public function fugou_user_log($uid,$num,$order_id,$type_inc_des,$status=-1){
  1160. $fugou_data = Db::name('user')->where("uid",$uid)->find();
  1161. //如果状态是1那就是即刻入账,
  1162. if($status == 1){
  1163. $con_data_fugoujin = Db::name('user')->where("uid",$uid)->update(['fugou'=>$fugou_data['fugou'] + $num]);
  1164. }
  1165. $bill = [
  1166. 'uid'=>$uid,
  1167. 'number'=>$num,//数量
  1168. 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
  1169. 'mark'=>"复购金",//备注
  1170. 'desc'=>"抽取佣金的10%作为复购金",//描述
  1171. 'order_id'=>$order_id,//订单id
  1172. 'surplus'=>0,//剩余
  1173. 'order_type'=>11,//关联订单ID
  1174. 'type'=>$type_inc_des,//复购金类型 :1赠送,2消耗
  1175. 'settlement_time'=>date('Y-m-d H:i:s'),//添加时间,
  1176. 'addtime'=>time(),
  1177. ];
  1178. Db::name('user_sign_fugou')->insert($bill);
  1179. }
  1180. //订单数据补充
  1181. public function buchong(){
  1182. $list = Db::name('store_order')->where('fzone_paytype', 'not null')->select();
  1183. foreach($list as $k => $v){
  1184. $fzone_paytype = json_decode($v['fzone_paytype'], true);
  1185. if(isset($fzone_paytype['jingdou'])) $update_data['fzone_pay_jingdou'] = $fzone_paytype['jingdou'];
  1186. if(isset($fzone_paytype['vr'])) $update_data['fzone_pay_vr'] = $fzone_paytype['vr'];
  1187. if(isset($fzone_paytype['jifen'])) $update_data['fzone_pay_jifen'] = $fzone_paytype['jifen'];
  1188. if(isset($fzone_paytype['price'])) $update_data['fzone_pay_price'] = $fzone_paytype['price'];
  1189. if(isset($fzone_paytype['other'])) $update_data['fzone_pay_other'] = $fzone_paytype['other'];
  1190. if(isset($fzone_paytype['type'])) $update_data['fzone_pay_type'] = $fzone_paytype['type'];
  1191. if(isset($fzone_paytype['note'])) $update_data['fzone_pay_note'] = $fzone_paytype['note'];
  1192. Db::name('store_order')->where("order_id", $v['order_id'])->update($update_data);
  1193. }
  1194. return app('json')->success(['result' => 'ok']);
  1195. }
  1196. }