Notify.php 84 KB

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