feat: 快手结算

mini/manifest.json

@@ -76,8 +76,8 @@
     "mp-toutiao" : {
         "usingComponents" : true,
         "appid" : "tta9e8df5536d6b48b01",
-        "setting": {
-          "urlCheck": false
+        "setting" : {
+            "urlCheck" : false
         }
     },
     "uniStatistics" : {

server/app/Helper/Kuaishou.php

@@ -71,6 +71,60 @@ class Kuaishou extends BaseUniPlatform
         ];
     }
 
+    public function settle($orderNo, $amount)
+    {
+        $url = $this->API::SETTLE.'?'.http_build_query([
+                'app_id' => $this->appId,
+                'access_token' =>  $this->accessToken,
+            ]);
+        $data = [
+            'app_id'        => $this->appId,
+            'out_order_no'  => $orderNo,
+            'out_settle_no' => $orderNo,
+            'reason'        => '主动结算',
+            'notify_url'    => env('APP_URL') . '/api/pay/kuaishou/settle',
+            'settle_amount' => $amount
+        ];
+        $data['sign'] = $this->getSign($data);
+
+        return $this->post(
+            $url,
+            $data,
+            'json'
+        );
+    }
+
+    public function pushOrder($openid, $orderId): array
+    {
+        $data = [
+            'app_id'               => $this->appId,
+            'out_order_no'         => $orderId,
+            'out_biz_order_no'     => $orderId,
+            'open_id'              => $openid,
+            'order_create_time'    => (int)Carbon::now()->subDays(7)->getPreciseTimestamp(3),
+            'order_status'         => 2, // 支付成功
+            'order_path'           => 'pages/my/consume',
+            'product_cover_img_id' => '5acfa29b90c8234ff41ede600cad6a9b715f38871eaf5973',
+        ];
+        $url = $this->API::ORDER_PUSH.'?'.http_build_query([
+                'app_id' => $this->appId,
+                'access_token' =>  $this->accessToken,
+            ]);
+        return $this->post($url, $data,'json');
+    }
+
+    public function upload()
+    {
+        $url = 'https://open.kuaishou.com/openapi/mp/developer/file/img/uploadWithUrl'.'?'.http_build_query([
+                'app_id' => $this->appId,
+                'access_token' =>  $this->accessToken,
+                'url' => 'http://fourtiao.oss-cn-beijing.aliyuncs.com/zhangsiye/images/664b34c5afb8cb56d4a3cec398e64948.png'
+            ]);
+        return $this->post(
+            $url,
+        );
+    }
+
 
     /**
      * @param array  $data

server/app/Helper/UniPlatform/Kuaishou/KuaishouAPI.php

@@ -31,4 +31,16 @@ final class KuaishouAPI extends BaseAPI
      * @url https://developer.open-douyin.com/docs/resource/zh-CN/mini-app/develop/server/qr-code/create-qr-code
      */
     const CREATE_QRCODE =  '';
+
+    /**
+     * 同步订单
+     * @url https://mp.kuaishou.com/docs/develop/server/order/push.html
+     */
+    const ORDER_PUSH = PAY_URL.'/order/v1/report';
+
+    /**
+     * 结算
+     * @url https://mp.kuaishou.com/docs/develop/server/epay/interfaceDefinition.html#_3%E3%80%81%E6%94%AF%E4%BB%98%E7%BB%93%E7%AE%97
+     */
+    const SETTLE = PAY_URL.'/epay/settle';
 }

server/app/Http/Controllers/V1/PayNoticeController.php

@@ -65,8 +65,9 @@ class PayNoticeController extends Controller
 
     public function kuaishou(): JsonResponse
     {
-        $app = new KuaishouPayment($this->getUniFactory(2));
-        return $app->payNotify(function ($data, $fail) {
+        $factory = $this->getUniFactory(2);
+        $app = new KuaishouPayment($factory);
+        return $app->payNotify(function ($data, $fail) use($factory) {
             //处理支付订单
             try {
                 \DB::beginTransaction();
@@ -89,9 +90,15 @@ class PayNoticeController extends Controller
                 $pay->save();
                 // 处理
                 if ($pay->source == Pay::SOURCE_RECHARGE) {
-                    $this->recharge($payId);
+                    $goods = $this->recharge($payId);
                 } else if ($pay->source == Pay::SOURCE_BUY_VIP) {
-                    $this->buyVip($payId);
+                    $goods = $this->buyVip($payId);
+                }
+
+                if(isset($goods)){
+                    /* @var Pay $payInfo*/
+                    $payInfo = Pay::with(['user'])->where('pay_id', $payId)->first();
+                    $factory->pushOrder($payInfo->user->open_id, $payId);
                 }
 
                 \DB::commit();
@@ -106,6 +113,14 @@ class PayNoticeController extends Controller
         });
     }
 
+    public function kuaishouSettle()
+    {
+        $app = new KuaishouPayment($this->getUniFactory(2));
+        return $app->payNotify(function ($data, $fail) {
+            return true;
+        });
+    }
+
     /**
      * @return Response
      * @throws \EasyWeChat\Kernel\Exceptions\Exception

server/app/Jobs/KuaishouSettlementJob.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Helper\ByteDance;
+use App\Helper\Kuaishou;
+use App\Helper\UniPlatform\Bytedance\ByteDanceAPI;
+use App\Helper\UniPlatform\Kuaishou\KuaishouAPI;
+use App\Models\Pay;
+use App\Models\PayConfig;
+use Carbon\Carbon;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Psy\Util\Json;
+
+class KuaishouSettlementJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $app = $this->getKuishouFactory();
+
+        $orders = Pay::with(['user.info'])->whereHas('user.info', function ($query){
+            $query->where('platform', 2);
+        })->where('status', 1)
+            ->where('created_at', '<=',Carbon::now()->subDays(7)->toDateString().' 00:00:00')
+            ->where('is_settle', 0)
+            ->get()
+            ->chunk(30);
+        foreach ($orders as $arr){
+            /* @var Pay $order*/
+            foreach ($arr as $order){
+                try {
+                    $res = $app->settle($order->pay_id, $order->order_fee * 100);
+                    $order->is_settle = 1;
+                    $order->settle_no = $res['settle_no'];
+                    $order->save();
+                    \Log::info("快手结算--> 支付订单号：{$order->pay_id}\t结算单号：{$res['settle_no']}");
+                }catch (\Exception $e) {
+                    \Log::info("快手结算错误--> 支付订单号：{$order->pay_id}\n错误信息：{$e->getMessage()}");
+                }
+            }
+            // 30QPS
+            sleep(1);
+        }
+
+    }
+
+    protected function getKuishouFactory(): Kuaishou
+    {
+        $setting = PayConfig::first();
+        return (new Kuaishou(app(KuaishouAPI::class)))->factory([
+            'app_id'     => $setting->kuaishou_app_id,
+            'app_secret' => $setting->kuaishou_app_secret,
+        ]);
+    }
+}