one_after 3 月之前
父節點
當前提交
de6230539f
共有 3 個文件被更改,包括 70 次插入43 次删除
  1. 43 43
      app/business/GoodsBusiness.php
  2. 21 0
      app/controller/UserController.php
  3. 6 0
      app/functions.php

+ 43 - 43
app/business/GoodsBusiness.php

@@ -21,53 +21,53 @@ class GoodsBusiness
 
             $payorder = Db::table('wa_payorder')->where('id', $payorderId)->first();
 
-//          if ($payorder->pay_type == 2) {
-//                $data = PayTwoBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
-//                Log::channel('payment')->info('桥头', $data);
-//                if (Arr::get($data, 'data.retCode') != 'SUCCESS') {
-//                    throw new \Exception('通道未开通!');
-//                }
-//                $arr = [
-//                    'type'       => 2,
-//                    'url'        => Arr::get($data, 'data.payParams.payUrl'),
-//                    'payOrderId' => ''
-//                ];
-//            }elseif ($payorder->pay_type == 3) {
-//                $data = PayThreeBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
-//                Log::channel('payment')->info('林北', $data);
-//                if (Arr::get($data, 'data.code') != 1000) {
-//                    throw new \Exception('通道未开通!');
-//                }
-//                $arr = [
-//                    'type'       => 2,
-//                    'url'        => Arr::get($data, 'data.data.message.url'),
-//                    'payOrderId' => ''
-//                ];
-//            }elseif ($payorder->pay_type == 5) {
-//                $data = PayFiveBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
-//                Log::channel('payment')->info('鸿运', $data);
-//                if (Arr::get($data, 'data.retCode') != 'SUCCESS') {
-//                    throw new \Exception('通道未开通!');
-//                }
-//                $arr = [
-//                    'type'       => 2,
-//                    'url'        => Arr::get($data, 'data.payParams.payUrl'),
-//                    'payOrderId' => ''
-//                ];
-//            } else {
-//                $arr = [
-//                    'type'       => 1,
-//                    'url'        => '',
-//                    'payOrderId' => ''
-//                ];
-//            }
-
+          if ($payorder->pay_type == 2) {
+                $data = PayTwoBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
+                Log::channel('payment')->info('桥头', $data);
+                if (Arr::get($data, 'data.retCode') != 'SUCCESS') {
+                    throw new \Exception('通道未开通!');
+                }
                 $arr = [
                     'type'       => 2,
-                    'url'        => Arr::get($param, 'url', ''),
+                    'url'        => Arr::get($data, 'data.payParams.payUrl'),
                     'payOrderId' => ''
                 ];
-                PayorderBusiness::payorderSave(collect($payorder)->toArray());
+            }elseif ($payorder->pay_type == 3) {
+                $data = PayThreeBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
+                Log::channel('payment')->info('林北', $data);
+                if (Arr::get($data, 'data.code') != 1000) {
+                    throw new \Exception('通道未开通!');
+                }
+                $arr = [
+                    'type'       => 2,
+                    'url'        => Arr::get($data, 'data.data.message.url'),
+                    'payOrderId' => ''
+                ];
+            }elseif ($payorder->pay_type == 5) {
+                $data = PayFiveBusiness::payment($payorder->order_no, $payorder->pay_characteristic, $payorder->money, Arr::get($param, 'url', ''));
+                Log::channel('payment')->info('鸿运', $data);
+                if (Arr::get($data, 'data.retCode') != 'SUCCESS') {
+                    throw new \Exception('通道未开通!');
+                }
+                $arr = [
+                    'type'       => 2,
+                    'url'        => Arr::get($data, 'data.payParams.payUrl'),
+                    'payOrderId' => ''
+                ];
+            } else {
+                $arr = [
+                    'type'       => 1,
+                    'url'        => '',
+                    'payOrderId' => ''
+                ];
+            }
+
+//                $arr = [
+//                    'type'       => 2,
+//                    'url'        => Arr::get($param, 'url', ''),
+//                    'payOrderId' => ''
+//                ];
+//                PayorderBusiness::payorderSave(collect($payorder)->toArray());
 
         } catch (\Throwable $exception) {
             throw new \Exception($exception->getMessage());

+ 21 - 0
app/controller/UserController.php

@@ -145,6 +145,27 @@ class UserController
             StreamBusiness::addStream($request->user_data['id'], 10000, streamType34, moldType10, moldTypefild10);
         }
 
+        $has       = Db::table('wa_stream')
+            ->where('user_id', $request->user_data['id'])
+            ->where('type', streamType35)
+            ->exists();
+        $orderlist = Db::table('wa_stream')
+            ->where('user_id', $request->user_data['id'])
+            ->where('type', 3)
+            ->where('is_pay', 2)
+            ->where('created_at', '>=', '2025-12-02 00:00:00')
+            ->where('created_at', '<=', '2025-12-02 23:59:59')
+            ->exists();
+        if (empty($has) && !empty($orderlist)) {
+            StreamBusiness::addStream($request->user_data['id'], 20, streamType35, moldType7, moldTypefild7);
+        }
+        $rs_refresh = Db::table('wa_users')->where('id',$request->user_data['id'])->value('is_refresh');
+        if($rs_refresh==0){
+            $ranking = mt_rand(880000, 900000);
+            Db::table('wa_user_social_cark')->where('user_id',$request->user_data['id'])->update(['ranking'=>$ranking]);
+            Db::table('wa_users')->where('id',$request->user_data['id'])->update(['is_refresh'=>1]);
+        }
+
         return success($arr);
     }
 

+ 6 - 0
app/functions.php

@@ -292,6 +292,8 @@
     define('streamType33', 33);
     /** 平台赠送 */
     define('streamType34', 34);
+    /** 平台赠送 */
+    define('streamType35', 35);
     function streamType($value = '')
     {
         $arr = [
@@ -430,6 +432,10 @@
             [
                 'value' => 34,
                 'name'  => '平台赠送',
+            ],
+            [
+                'value' => 35,
+                'name'  => '平台赠送',
             ]
         ];
         if ($value) {