Notify.php 84 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476
  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. //利润分配 end
  481. //商城订单
  482. //判断下,如果是组合支付中,现金+积分的形式支付情况下
  483. $array_fzone_paytype = json_decode( $store_order_data['fzone_paytype'],true);
  484. if($array_fzone_paytype['type']=='b2'){
  485. if(!empty($array_fzone_paytype['other']) && is_numeric($array_fzone_paytype['other']) == true){
  486. $vrpri = $user_data['score'] - $array_fzone_paytype['other'];
  487. // // //现金+积分
  488. if($vrpri >= 0 ){
  489. Db::name("user")->where("uid", $user_data['uid'])->update(['score'=>$vrpri]);
  490. }else{
  491. $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']];
  492. Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
  493. }
  494. }else{
  495. $note_arr = ["uid"=>$user_data['uid'],"msg"=>"数据异常","fzone_paytype"=>$store_order_data['fzone_paytype']];
  496. Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
  497. }
  498. }
  499. //end 现金+积分
  500. //如果注释了event事件,需要手动修改订单状态 1:代发货
  501. Db::name('store_order')->where('group_order_id', $group_order_id)->update(['status'=>0]);
  502. $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']]);
  503. Db::name('store_group_order')->where('group_order_id',$group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s')]);
  504. event('pay_success_order', ['order_sn' => $requestId[0],'pay_type'=>$pay_type]);
  505. break;
  506. case 'pay_channel':
  507. //渠道商
  508. try{
  509. $order_data=Db::name('channel_order') -> where('order_no',$requestId[0]) -> find();
  510. if($order_data['status']==1){
  511. return false;
  512. }
  513. $pay_type = $pay_type == 1 ? 'wx' : 'al';
  514. Db::name('channel_user')->where('uid',$order_data['uid'])->update(['status'=>1]);
  515. Db::name('channel_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'pay_type'=>$pay_type,'status'=>1]);
  516. }catch (\Exception $e) {
  517. Db::name('log')->insert(['data'=>'支付渠道商错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  518. }
  519. try{
  520. $access = new Access();
  521. //分佣
  522. $access->channel_fenyong($requestId[0]);
  523. // //给7个激活码
  524. // for($i=0;$i<=6;$i++){
  525. // Db::name('activation_code')->insertGetId([
  526. // 'uid'=>$order_data['uid'],
  527. // 'code'=>$this->randomFromDev(20),
  528. // 'ctime'=>time(),
  529. // 'status'=>1,
  530. // 'utime'=>time(),
  531. // 'use_uid'=>0,
  532. // 'type'=>2
  533. // ]);
  534. // }
  535. //赠送返本商户
  536. $mer = Db::name('user_mer') -> where('uid',$order_data['uid']) -> find();
  537. if(!$mer){
  538. Db::name('user_mer') -> insert(['uid'=>$order_data['uid'],'mer'=>10]);
  539. }else{
  540. Db::name('user_mer') -> where('uid',$order_data['uid'])->inc('mer', 10) ->update();;
  541. }
  542. //赠送商户
  543. $merchant=Db::name('merchant')->where('uid',$order_data['uid'])->find();
  544. if(!$merchant)
  545. Db::name('merchant_intention')->insert(['uid'=>$order_data['uid'],'status'=>3,'activation_code'=>rand('000000000','999999999')]);
  546. //赠送大仓会员资格
  547. $dacang_user = Db::name('da_cang_user')->where('uid', $order_data['uid'])->find();
  548. $time = date('Y-m-d', time());
  549. $time = strtotime($time);
  550. $end_time = $time + 31536000 - 1;
  551. $dc_id = 1;
  552. //如果不是金卡会员,赠送金卡会员一年
  553. if (!$dacang_user) {
  554. Db::name('da_cang_user')->insert(['uid' => $order_data['uid'], 'ctime' => time(), 'end_time' => $end_time, 'dc_id' => $dc_id,'status'=>1,'type'=>1]);
  555. }else{
  556. //如果是银卡会员,变成金卡,一年 || 是否已过期,如果已过期,赠送金卡会员一年
  557. if($dacang_user['type'] == 2 || $dacang_user['end_time'] < $time){
  558. Db::name('da_cang_user')->where('uid', $order_data['uid'])->where('dc_id', $dc_id)->update(['end_time' => $end_time,'status'=>1,'type'=>1]);
  559. }
  560. }
  561. }catch (\Exception $exception){
  562. Db::name('log')->insert(['data'=>'渠道商处理错误:'.$exception->getFile().':'.$exception->getLine().'【'.$exception->getMessage().'】']);
  563. }
  564. break;
  565. case 'pay_annual':
  566. //商户
  567. $annual_cost_order=Db::name('merchant_annual_cost_order')-> where('order_no',$requestId[0])->find();
  568. if($annual_cost_order['status'] == 0) {
  569. $pay_type = $pay_type == 1 ? 'wx' : 'al';
  570. Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->update(['rand' => $requestId[1],'pay_type'=>$pay_type,'status' => 1]);
  571. //如果有商户id就是续费
  572. $mer_id = Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->value('mer_id');
  573. if ($mer_id !== 0) {
  574. $expire_time = strtotime(date('Y-m-d')) + 86400 * 365 + 86400 - 1;
  575. Db::name('merchant')->where('mer_id', $mer_id)->update(['expire_time' => $expire_time, 'status' => 1]);
  576. }
  577. $mer = Db::name('user_mer') -> where('uid',$annual_cost_order['uid']) -> find();
  578. if(!$mer){
  579. Db::name('user_mer') -> insert(['uid'=>$annual_cost_order['uid'],'mer'=>2]);
  580. }else{
  581. Db::name('user_mer') -> where('uid',$annual_cost_order['uid'])->inc('mer', 2) ->update();;
  582. }
  583. $access = new Access();
  584. $access->nianfei_yj($annual_cost_order['id']);
  585. }
  586. break;
  587. case 'pay_activation':
  588. try{
  589. $order_data=Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> find();
  590. if($order_data['status']==1){
  591. return false;
  592. }
  593. $access = new Access();
  594. $id=Db::name('activation_code')->insertGetId([
  595. 'uid'=>$order_data['uid'],
  596. 'code'=>$access->randomFromDev(20),
  597. 'ctime'=>time(),
  598. 'status'=>1,
  599. 'utime'=>time(),
  600. 'use_uid'=>0,
  601. 'type'=>1
  602. ]);
  603. Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'status'=>1,'code_id'=>$id]);
  604. }catch (\Exception $e) {
  605. Db::name('log')->insert(['data'=>'支付激活码错误:'.$e->getFile().':'.$e->getLine().'【'.$e->getMessage().'】']);
  606. }
  607. //处理佣金
  608. $num=$access->activation_yj($requestId[0]);
  609. //分账
  610. $access->activation_spilet($requestId[0],$num);
  611. break;
  612. case 'notify_order':
  613. Db::name("log")->insert(array('data'=>'汇付退款回调'));//日志记录
  614. break;
  615. case 'marketing':
  616. $marketing_order=Db::name('marketing_order')-> where('order_no',$requestId[0])->find();
  617. if($marketing_order['status']==1){
  618. return app('json')->success(['result' => 'SUCCESS']);
  619. }
  620. // $pay_type = $pay_type == 1 ? 'wx' : 'ali';
  621. $checkUser = Db::name("MarketingUser") -> where('uid',$marketing_order['uid'])->find();
  622. $handle = $this -> marketing($marketing_order,$checkUser);
  623. if ($handle){
  624. //分账
  625. $this -> pay_user_annual($marketing_order['uid']);
  626. }
  627. break;
  628. case 'pay_user_annual':
  629. $user_pension_account_order=Db::name('user_pension_account_order')-> where('order_no',$requestId[0])->find();
  630. if($user_pension_account_order['status']==1){
  631. return app('json')->success(['result' => 'SUCCESS']);
  632. }
  633. $this -> pay_user_annual($user_pension_account_order['uid'],$requestId[0]);
  634. break;
  635. default:
  636. Db::name("log")->insert(array('data'=>$type));//日志记录
  637. }
  638. }
  639. return app('json')->success(['result' => 'SUCCESS']);
  640. }catch (\Exception $exception){
  641. Db::name("log")->insert(array('data'=>'汇付回调错误:'.$exception->getFile().':'.$exception->getLine().'【'.$exception->getMessage().'】'));//日志记录
  642. return app('json')->success(['result' => 'ERROR']);
  643. }
  644. }
  645. }
  646. /**
  647. * 会员升级
  648. */
  649. public function member_update($orderInfo,$goods_of_info,$user_id)
  650. {
  651. //code...
  652. $pay_gb = round($orderInfo['num'] * $orderInfo['gb_num'],2);
  653. //$pay_vr = round($orderInfo['num'] * $orderInfo['vr_num'],2);
  654. //付款按照700的VR付款 start
  655. $vr_num = 0;
  656. if ($orderInfo['price'] == 1180) {
  657. $vr_num = 700;
  658. } elseif ($orderInfo['price'] == 11800) {
  659. $vr_num = 7000;
  660. } elseif ($orderInfo['price'] == 11800) {
  661. $vr_num = 2100;
  662. }elseif($orderInfo['price'] == 10620){
  663. $vr_num = 6300;
  664. }
  665. $pay_gb1 = $vr_num;
  666. $pay_vr1 =$orderInfo['price'];//记录VR值
  667. // $result = Db::name("old_user_jbp")->where("id",$user_id)->dec("vr",$orderInfo['price'])->save();//1.0jbp旧表
  668. // Db::name("user")->where("uid",$user_id)->dec("vr",$orderInfo['price'])->save();//2.0新表
  669. $result = true;
  670. if($result) {
  671. $invite_id = $goods_of_info['spread_id'];
  672. $zs_ylj = 0; //养老金赋值
  673. if($goods_of_info['money'] == 1180){
  674. //修改订单到账状态
  675. $zs_ylj = round(700 * 0.05,2);//计算的养老金 金额
  676. }elseif($goods_of_info['money'] == 11800){
  677. $zs_ylj = round(7000 * 0.05,2);//计算的养老金 金额
  678. }elseif($goods_of_info['money'] == 3540){
  679. $zs_ylj = round(2100 * 0.05,2);//计算的养老金 金额
  680. }elseif($goods_of_info['money'] == 10620){
  681. $zs_ylj = round(6300 * 0.05,2);//计算的养老金 金额
  682. }elseif($goods_of_info['money'] == 9440){
  683. $zs_ylj = round(5600 * 0.05,2);//八单计算的养老金 金额
  684. }elseif($goods_of_info['money'] == 2360){
  685. $zs_ylj = round(1400 * 0.05,2);//两单计算的养老金 金额
  686. }
  687. $uid = $user_id;
  688. $new_user_id = $uid;
  689. if(empty($new_user_id)) {
  690. abort(0,"当前绑定会员查询错误");
  691. }
  692. $new_nums =Db::name("old_user_of_goods")->where("user_id", $uid)->sum("money");
  693. //增加过后权益对比 获取当前权益等级
  694. $old_level_id = Db::name("old_user_jbp")->where("id",$uid)->find();
  695. $old_level_info = Db::name("old_user_level")->where("id",$old_level_id['user_level_id'])->find();
  696. $level_info = [];
  697. $level_list = Db::name("old_user_level")->order("money desc")->select();
  698. //计算会员等级 升级
  699. foreach ($level_list as $key => $value) {
  700. # code...
  701. if($new_nums>=$value['money']) {
  702. $level_info = $value;
  703. break;
  704. }
  705. }
  706. $zs_gb = $orderInfo['price'] * 3;
  707. $zs_withdraw_quota = $orderInfo['price'];
  708. if($old_level_info['id'] == $level_info['id']) {
  709. //未到达升级权益 不改变用户等级
  710. $update_status = false;
  711. }else{
  712. $update_status = true;
  713. $user_level = $level_info['id'];
  714. //var_dump( $user_level);
  715. Db::name("old_user_jbp")->where("id",$new_user_id)->save(['user_level_id'=>$user_level]);//1.0jbp旧表
  716. Db::name("user")->where("uid",$new_user_id)->save(['user_level_id_old'=>$user_level]);//2.0新表
  717. // todo 同时改变他的权益
  718. }
  719. // Db::name("old_user_jbp")->where("id",$new_user_id)->inc("withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表
  720. // Db::name("user")->where("uid",$new_user_id)->save(['withdraw_quota_old'=>$zs_withdraw_quota]);//2.0新表
  721. // 下发邀请人赠送的GB
  722. // $zs_invite_gb = round($orderInfo['price']*0.3,2);
  723. // //todo
  724. // Db::name("old_user_jbp")->where("id",$invite_id)->inc("gb",$zs_invite_gb)->save();//1.0jbp旧表
  725. // Db::name("user")->where("uid",$invite_id)->inc("score",$zs_invite_gb)->save();//2.0新表
  726. //$old_have_pension = Db::name("old_user_jbp")->where("id",$invite_id)->value("have_pension");
  727. //检查是不是订单价格是1180或者11800,更改VR
  728. 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){
  729. //修改订单到账状态
  730. 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()]);
  731. }
  732. }
  733. if($result) {
  734. //更改订单状态
  735. Db::commit();
  736. $new_user_name = Db::name("old_user_jbp")->where("id",$new_user_id)->value("user_name");
  737. $new_user_name = empty($new_user_name) ? "" : $new_user_name;
  738. //记录日志信息
  739. if($user_id == $invite_id) {
  740. //报单中心=推荐人 GB记录日志有问题需要传入指定参数去计算
  741. //$money = Db::name("old_user_jbp")->where("id",$user_id)->value("gb");
  742. //$appoint_money = $money - $zs_invite_gb;
  743. 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){
  744. $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);
  745. }
  746. }else{
  747. 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){
  748. $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);
  749. }
  750. }
  751. // $this->change_user_log66($new_user_id,'gb',1,$zs_gb,"levle_update_zs","权益升级达标赠送");
  752. $this->change_user_log66($new_user_id,'withdraw_quota_old',1,$zs_withdraw_quota,"levle_update_zs","权益升级达标赠送");
  753. // $this->change_user_log66($invite_id,'gb',1,$zs_invite_gb,"levle_update_zs","邀请-".$new_user_name);
  754. // echo 123;return;
  755. //处理查看是否有待发放佣金
  756. // $zs_withdraw_quota
  757. Db::name("old_user_jbp")->where("id",$new_user_id)->inc("total_withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表
  758. Db::name("user")->where("uid",$new_user_id)->inc("total_withdraw_quota_old",$zs_withdraw_quota)->save();
  759. // $this->releaseTobeAmount($new_user_id,$zs_withdraw_quota);
  760. // $this->success("支付成功",['is_cash'=>0]);
  761. }
  762. Db::rollback();
  763. // $this->error("操作失败");
  764. }
  765. function change_user_log66($user_id,$type,$change_status,$money,$routine,$remark="",$is_admin=1,$appoint_money = 0)
  766. {
  767. $transition = [
  768. 'pv'=>1,
  769. "gb"=>2,
  770. "df"=>3,
  771. "vr"=>4,
  772. "bt"=>5,
  773. "withdraw_quota_old"=>6,
  774. "unsettled_pension"=>7,
  775. "amount_old"=>8
  776. ];
  777. $routineInfo = Db::name("old_routine_log_of_key")->where("key",$routine)->find();
  778. if(empty($routineInfo)) {
  779. return false;
  780. }
  781. $key_id = isset($routineInfo['id']) ? $routineInfo['id'] : 0;
  782. //再去查询变更前的 金额
  783. if($appoint_money > 0) {
  784. $alter_money = $appoint_money;
  785. }else{
  786. //再去查询变更前的 金额
  787. $alter_money = Db::name("user")->where('uid',$user_id)->value($type);
  788. }
  789. if($change_status == 1) {
  790. //新增前
  791. $alter_money = $alter_money-$money;
  792. }else if($change_status == 2){
  793. //减少前
  794. $alter_money = $alter_money + $money;
  795. }
  796. $inser_data = [];
  797. $inser_data['user_id'] = $user_id;
  798. $inser_data['type'] = $transition[$type];
  799. $inser_data['change_status'] = $change_status;
  800. $inser_data['money'] = $money;
  801. $inser_data['routine_log_of_key_id'] = $key_id;
  802. $inser_data['remark'] = $remark;
  803. $inser_data['is_admin'] = $is_admin;
  804. $inser_data['create_time'] = time();
  805. $inser_data['alter_money'] = isset($alter_money) ? $alter_money : 0;
  806. Db::name("old_user_log")->insert($inser_data);
  807. }
  808. public function pay_user_annual($uid,$order_no=''){
  809. Db::startTrans();
  810. try {
  811. if ($order_no != ''){
  812. Db::name('user_pension_account_order')-> where('order_no',$order_no) -> update(['status'=>1]);
  813. }
  814. $check = Db::name("user_pension_account") -> where("uid",$uid) -> find();
  815. $start_time = date('Y-m-d');
  816. $end_time = date("Y-m-d 23:59:59",strtotime("+1 year", strtotime($start_time)));
  817. $give = 0;
  818. //存在既续费
  819. if ($check){
  820. Db::name("user_pension_account") -> where("uid",$uid) -> update(['start_time'=>$start_time,'end_time'=>$end_time]);
  821. $give = $check['give'];
  822. }else{
  823. //新用户订单
  824. Db::name("user_pension_account") -> insert([
  825. "uid" => $uid,
  826. "start_time" => $start_time,
  827. "end_time" => $end_time,
  828. "status" => 1,
  829. ]);
  830. }
  831. if ($give == 0){
  832. Db::name("user_pension_account") -> where("uid",$uid) -> update(['give' => 1]);
  833. $mark = "开通养老金账户";
  834. $billData=[
  835. 'uid'=>$uid,
  836. 'pm'=>1,
  837. 'title'=>'养老金',
  838. 'category'=>'now_money',
  839. 'type'=>'commission',
  840. 'number'=>0.01,
  841. 'balance'=>0,
  842. 'mark'=>$mark,
  843. 'create_time'=>date("Y-m-d H:i:s",time()),
  844. 'status'=>1,
  845. 'order_sn'=>'',
  846. 'type_shop'=>0,
  847. 'commission_type'=>5,
  848. 'order_type'=>1,
  849. 'gzc'=>0
  850. ];
  851. Db::name('user_bill')->insert($billData);
  852. Db::name("user")->where("uid",$uid)->inc('annuity', 0.01) ->update();
  853. Db::name("user")->where("uid",$uid)->inc('annuity_num', 1) ->update();
  854. }
  855. // 提交事务
  856. Db::commit();
  857. return true;
  858. } catch (\Exception $e) {
  859. // 回滚事务
  860. Db::rollback();
  861. Log::error($e->getMessage());
  862. }
  863. }
  864. public function marketing($order,$marketingUser,$pay_type="wx"){
  865. Db::startTrans();
  866. try {
  867. Db::name('marketing_order') -> where('order_no',$order['order_no']) -> update(['pay_type'=>$pay_type,'status'=>1]);
  868. Db::name('marketing_user') -> where('uid',$order['uid']) -> update(['type'=>$order['type']]);
  869. //分红份数及资金
  870. $divvy_number = ceil(bcdiv($order['pay_price'],99));
  871. $divvy_money = $order['pay_price'];
  872. Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_number', $divvy_number) ->update();
  873. Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_money', $divvy_money) ->update();
  874. //上级
  875. $spread_uid = $marketingUser['spread_uid'];
  876. //养老金
  877. //本人给养老金10%
  878. $ylj=bcmul($order['pay_price'],'0.1',5);//10%的养老金
  879. $ylj=round($ylj,2);
  880. $title='养老金';
  881. if ($order['type'] == 1){
  882. $identity = "普通会员";
  883. }elseif ($order['type'] == 2){
  884. $identity = "创客";
  885. }elseif ($order['type'] == 3){
  886. $identity = "合伙人";
  887. }else{
  888. $identity = "";
  889. }
  890. $mark = "成为{$identity}获得{$ylj}养老金";
  891. $billData=[
  892. 'uid'=>$order['uid'],
  893. 'link_id'=>$order['id'],
  894. 'pm'=>1,
  895. 'title'=>$title,
  896. 'category'=>'now_money',
  897. 'type'=>'commission',
  898. 'number'=>$ylj,
  899. 'balance'=>0,
  900. 'mark'=>$mark,
  901. 'create_time'=>date("Y-m-d H:i:s",time()),
  902. 'status'=>1,
  903. 'order_sn'=>$order['order_no'],
  904. 'type_shop'=>0,
  905. 'commission_type'=>5,
  906. 'order_type'=>1,
  907. 'gzc'=>0
  908. ];
  909. Db::name('user_bill')->insert($billData);
  910. Db::name("user")->where("uid",$order['uid'])->inc('annuity', $ylj) ->update();
  911. Db::name("user")->where("uid",$order['uid'])->inc('annuity_num', 1) ->update();
  912. //上级佣金
  913. $checkSpread = Db::name("MarketingUser") -> where('uid',$spread_uid)->value("type");
  914. //检查上级身份 必须是会员或以上
  915. if ($checkSpread > 0){
  916. $commission=bcmul($order['pay_price'],'0.3',5);//30%的佣金
  917. $commission=round($commission,2);
  918. $spreadTitle='佣金';
  919. $spreadMark = "推广{$identity}获得{$commission}佣金";
  920. $spreadBillData=[
  921. 'uid'=>$spread_uid,
  922. 'link_id'=>$order['id'],
  923. 'pm'=>1,
  924. 'title'=>$spreadTitle,
  925. 'category'=>'now_money',
  926. 'type'=>'commission',
  927. 'number'=>$commission,
  928. 'balance'=>0,
  929. 'mark'=>$spreadMark,
  930. 'create_time'=>date("Y-m-d H:i:s",time()),
  931. 'status'=>1,
  932. 'order_sn'=>$order['order_no'],
  933. 'type_shop'=>0,
  934. 'commission_type'=>11,
  935. 'order_type'=>1
  936. ];
  937. Db::name('user_bill')->insert($spreadBillData);
  938. Db::name('user')->where('uid',$spread_uid)->inc('brokerage_price',$commission)->update();
  939. }
  940. $spread_list = $marketingUser['spread_list'];
  941. $spread_list = str_replace(['[', ']'], '', $spread_list);
  942. $spread_list = explode(',',$spread_list);
  943. //计算所有上级的累计销售业绩 赠送积分
  944. $achievement = $this -> achievement($spread_list,$order['uid'],$order['pay_price']);
  945. foreach($achievement as $key => $value){
  946. $spreadTitle='业务销售奖励积分';
  947. $achievementMark = "团队推广{$identity}获得{$value['commission']}积分";
  948. $integral = Db::name("marketing_user") -> where('uid',$spread_uid) -> value("integral");
  949. $achievementBillData=[
  950. 'uid'=>$key,
  951. 'pm'=>1,
  952. 'title'=>$spreadTitle,
  953. 'integral'=>$value['commission'],
  954. 'residual_integral' => $integral + $value['commission'],
  955. // 'mark'=>$achievementMark,
  956. 'order_sn'=>$order['order_no'],
  957. ];
  958. Db::name('marketing_integral')->insert($achievementBillData);
  959. Db::name('marketing_user')->where('uid',$spread_uid)->inc('integral',$value['commission'])->update();
  960. }
  961. if ($order['type'] == 2 || $order['type'] == 3) {
  962. //赠送商户
  963. $merchant=Db::name('merchant')->where('uid',$order['uid'])->find();
  964. if(!$merchant) {
  965. $access = new Access();
  966. $activation_code = $access->randomFromDev(20);
  967. // Db::name('activation_code')->insertGetId([
  968. // 'uid' => $order['uid'],
  969. // 'code' => $activation_code,
  970. // 'ctime' => time(),
  971. // 'status' => 1,
  972. // 'utime' => time(),
  973. // 'use_uid' => $order['uid'],
  974. // 'type' => 1
  975. // ]);
  976. Db::name('merchant_intention')->insert(['uid' => $order['uid'], 'status' => 3, 'activation_code' => $activation_code]);
  977. }
  978. }
  979. // 提交事务
  980. Db::commit();
  981. return true;
  982. } catch (\Exception $e) {
  983. // 回滚事务
  984. Db::rollback();
  985. Log::error($e->getMessage());
  986. return false;
  987. }
  988. }
  989. public function achievement($lists,$uid,$pay_price){
  990. $newList = [];
  991. $lastAchievement = 0;
  992. $lastCommission = 0;
  993. $total = 0;
  994. $list=array_reverse($lists);
  995. foreach($list as $value){
  996. $checkSpread = Db::name("MarketingUser") -> where('uid',$value)->value("type");
  997. //检查上级身份 必须是会员或以上
  998. if ($checkSpread <= 0) continue;
  999. $achievement = Db::name('marketing_order')
  1000. ->where('uid','in',function($query) use ($value,$uid){
  1001. $query->name('marketing_user')-> where("spread_list like '%[$value]%' or uid = $value","") -> where("uid","<>",$uid) -> field("uid");
  1002. })
  1003. -> where("status",1)
  1004. ->sum("pay_price");
  1005. if ($achievement >= 50000 && $achievement < 300000){
  1006. $c = round(bcmul($pay_price,'0.1',5),2);//10%
  1007. //如果业绩大于5万,小于30万。并且业绩等级等于1。奖励等于上个人的奖励减半
  1008. if ($lastAchievement == 1){
  1009. $c = round(bcmul($lastCommission,0.5,5),2);
  1010. }
  1011. $lastCommission = $c;
  1012. $lastAchievement = 1;
  1013. $total += $c;
  1014. $newList[$value] = [
  1015. "achievement" => $achievement,
  1016. "commission" => $c
  1017. ];
  1018. }elseif ($achievement >= 300000 && $achievement < 1000000){
  1019. $c = round(bcmul($pay_price,'0.15',5),2);//15%
  1020. //如果业绩大于5万,小于30万。并且业绩等级等于2。奖励等于上个人的奖励减半
  1021. if ($lastAchievement == 2){
  1022. $c = round(bcmul($lastCommission,0.5,5),2);
  1023. }else{
  1024. $c = $c - $total;
  1025. }
  1026. $lastAchievement = 2;
  1027. if ($c > 0){
  1028. $total += $c;
  1029. $lastCommission = $c;
  1030. $newList[$value] = [
  1031. "achievement" => $achievement,
  1032. "commission" => $c
  1033. ];
  1034. }else{
  1035. $lastCommission = 0;
  1036. }
  1037. }elseif ($achievement >= 1000000){
  1038. $c = round(bcmul($pay_price,'0.2',5),2);//20%
  1039. //如果业绩大于5万,小于30万。并且业绩等级等于3。奖励等于上个人的奖励减半
  1040. if ($lastAchievement == 3){
  1041. $c = round(bcmul($lastCommission,0.5,5),2);
  1042. }else{
  1043. $c = $c - $total;
  1044. }
  1045. $total += $c;
  1046. $lastAchievement = 3;
  1047. if ($c > 0){
  1048. $total += $c;
  1049. $lastCommission = $c;
  1050. $newList[$value] = [
  1051. "achievement" => $achievement,
  1052. "commission" => $c
  1053. ];
  1054. }else{
  1055. $lastCommission = 0;
  1056. }
  1057. }
  1058. }
  1059. return $newList;
  1060. }
  1061. //添加贡献值日志
  1062. public function con_log($uid,$num,$order_id,$order_type,$mark,$status = -1){
  1063. $con_data = Db::name('user')->where("uid",$uid)->find();
  1064. //如果状态是1那就是即刻入账,
  1065. if($status == 1){
  1066. $con_data_gongxian = Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]);
  1067. }
  1068. $con = [
  1069. 'uid'=>$uid,
  1070. 'number'=>$num,//赠送数量
  1071. 'status'=>$status,//红包状态
  1072. 'mark'=>$mark,//备注
  1073. 'desc'=>'',//描述
  1074. 'order_id'=>$order_id,//订单id
  1075. 'surplus'=> $con_data['contribute'],//剩余
  1076. 'order_type'=>$order_type,//订单类型
  1077. 'type'=>1,//1增加,2消耗
  1078. 'settlement_time'=>date('Y-m-d H:i:s'),
  1079. 'addtime'=>time()
  1080. ];
  1081. Db::name('user_sign_gongxian')->insert($con);
  1082. }
  1083. //添加积分日志
  1084. public function score_log($uid,$num,$order_id,$order_type,$mark,$status = -1){
  1085. $score_data = Db::name('user')->where("uid",$uid)->find();
  1086. //如果状态是1那就是即刻入账,
  1087. if($status == 1){
  1088. $con_data_score = Db::name('user')->where("uid",$uid)->update(['score'=>$score_data['score'] + $num]);
  1089. }
  1090. $score = [
  1091. 'uid'=>$uid,
  1092. 'continuity_day'=>0,//连续签到天数
  1093. 'reward_socre'=>$num,//积分数量
  1094. 'signin_time'=>0,//签到时间
  1095. 'source_uid'=>0,//赠送积分用户来源id
  1096. 'status'=>$status,//积分状态1:有效,0:失效,1:待确认
  1097. 'mark'=> $mark,//备注
  1098. 'order_id'=>$order_id,//订单id
  1099. 'pm'=>1,//1收入,2支出
  1100. 'surplus'=> $score_data['score'],//剩余
  1101. 'order_type'=>$order_type,//订单类型 ,10精彩生活区,11会员区,12复购区
  1102. 'source_type'=>3,//积分类型,1签到,2分享好友注册赠送,3自己下单赠送
  1103. 'settlement_time'=>date('Y-m-d H:i:s'),
  1104. 'addtime'=>time()
  1105. ];
  1106. Db::name('user_sign_score')->insert($score);
  1107. }
  1108. //添加推广佣金/养老金日志(养老金金额)
  1109. public function bill_user_log($uid,$num,$order_id,$comm_order_type,$order_sn,$mark,$merid,$ds=1){
  1110. $con_data = Db::name('user')->where("uid",$uid)->find();
  1111. //如果是会员专区就即刻到账
  1112. $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->find();
  1113. if($order_from_mer['mer_id'] == 496 && $comm_order_type==3){
  1114. // Db::name('user')->where("order_id",$order_id)->find();
  1115. Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]);
  1116. }
  1117. $name = '';
  1118. if($comm_order_type==3){
  1119. $name = '直推奖';
  1120. }else if($comm_order_type==5){
  1121. $name = '养老金';
  1122. }
  1123. $bill = [
  1124. 'uid'=>$uid,
  1125. 'link_id'=>$order_id,//关联订单id
  1126. 'pm'=>1,//0:支出,1:获得
  1127. 'title'=>$name,//账单标题
  1128. 'category'=>'now_money',//明细种类
  1129. 'type'=>'commission',//明细类型
  1130. 'number'=>$num,//明细数字
  1131. 'balance'=>0,//剩余
  1132. 'mark'=>$mark,//备注
  1133. 'create_time'=>date('Y-m-d H:i:s'),//添加时间
  1134. 'status'=>$ds,//0待确定,1有效,-1无效
  1135. 'commission_type'=>$comm_order_type,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
  1136. //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
  1137. //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
  1138. 'order_sn'=>$order_sn,//订单号
  1139. 'tripartite'=>0,//
  1140. 'type_shop'=>0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
  1141. 'mer_id'=>$merid,//商户id
  1142. 'source'=>0,//1线下 0线上
  1143. 'order_type'=>1,//1自营 2 第三方 订单类型
  1144. 'is_red_brokerage'=>0,//1红积分对冲佣金 0正常佣金
  1145. 'gzc'=>3,//养老金是否已进入公证处log表0:未进入。1:已进入
  1146. 'take_time'=>'',//结算时间
  1147. 'district_id'=>'',//
  1148. 'street_id'=>'',//
  1149. 'month'=>'',//月份
  1150. ];
  1151. Db::name('user_bill')->insert($bill);
  1152. }
  1153. //添加复购金
  1154. public function fugou_user_log($uid,$num,$order_id,$type_inc_des,$status=-1){
  1155. $fugou_data = Db::name('user')->where("uid",$uid)->find();
  1156. //如果状态是1那就是即刻入账,
  1157. if($status == 1){
  1158. $con_data_fugoujin = Db::name('user')->where("uid",$uid)->update(['fugou'=>$fugou_data['fugou'] + $num]);
  1159. }
  1160. $bill = [
  1161. 'uid'=>$uid,
  1162. 'number'=>$num,//数量
  1163. 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
  1164. 'mark'=>"复购金",//备注
  1165. 'desc'=>"抽取佣金的10%作为复购金",//描述
  1166. 'order_id'=>$order_id,//订单id
  1167. 'surplus'=>0,//剩余
  1168. 'order_type'=>11,//关联订单ID
  1169. 'type'=>$type_inc_des,//复购金类型 :1赠送,2消耗
  1170. 'settlement_time'=>date('Y-m-d H:i:s'),//添加时间,
  1171. 'addtime'=>time(),
  1172. ];
  1173. Db::name('user_sign_fugou')->insert($bill);
  1174. }
  1175. //订单数据补充
  1176. public function buchong(){
  1177. $list = Db::name('store_order')->where('fzone_paytype', 'not null')->select();
  1178. foreach($list as $k => $v){
  1179. $fzone_paytype = json_decode($v['fzone_paytype'], true);
  1180. if(isset($fzone_paytype['jingdou'])) $update_data['fzone_pay_jingdou'] = $fzone_paytype['jingdou'];
  1181. if(isset($fzone_paytype['vr'])) $update_data['fzone_pay_vr'] = $fzone_paytype['vr'];
  1182. if(isset($fzone_paytype['jifen'])) $update_data['fzone_pay_jifen'] = $fzone_paytype['jifen'];
  1183. if(isset($fzone_paytype['price'])) $update_data['fzone_pay_price'] = $fzone_paytype['price'];
  1184. if(isset($fzone_paytype['other'])) $update_data['fzone_pay_other'] = $fzone_paytype['other'];
  1185. if(isset($fzone_paytype['type'])) $update_data['fzone_pay_type'] = $fzone_paytype['type'];
  1186. if(isset($fzone_paytype['note'])) $update_data['fzone_pay_note'] = $fzone_paytype['note'];
  1187. Db::name('store_order')->where("order_id", $v['order_id'])->update($update_data);
  1188. }
  1189. return app('json')->success(['result' => 'ok']);
  1190. }
  1191. }