公证处入账

app/common/repositories/merchant/order/OrderGzcRepository.php

@@ -178,6 +178,7 @@ class OrderGzcRepository extends BaseRepository
         }
     }
 
+
     public function register($mobile)
     {
         $thirdKey = "xingfubao";
@@ -219,9 +220,62 @@ class OrderGzcRepository extends BaseRepository
         curl_close($curl);
 
         $response = json_decode($response, true);
-        return $response['data']['uid'];
+        return $response;
     }
 
+
+
+
+    public function certification($uid, $mobile, $user_name, $user_card, $card_positive, $card_reverse)
+    {
+        $thirdKey = "xingfubao";
+        $thirdsignKey = "xfb@86868.";
+        $time = time();
+
+        $data = [
+            'uid'  => $uid,
+            'mobile' => $mobile,
+            'user_name' => $user_name,
+            'user_card' => $user_card,
+            'card_positive'=> $card_positive,
+            'card_reverse'=> $card_reverse,
+        ];
+
+        ksort($data);
+        $params = '';
+        foreach ($data as $key => $value) {
+            $params .= '&' . $key . '=' . $value;
+        }
+        $params = ltrim($params, '&');
+        $sign = strtoupper(md5($params . '&key=' . $thirdKey . '&signKey=' . $thirdsignKey . '&timestamp=' . $time));
+        $curl = curl_init();
+
+        curl_setopt_array($curl, [
+            CURLOPT_URL            => "http://pcpc.bjtdba.com/api/third/certification",
+            CURLOPT_RETURNTRANSFER => true,
+            CURLOPT_ENCODING       => "",
+            CURLOPT_MAXREDIRS      => 10,
+            CURLOPT_TIMEOUT        => 30,
+            CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
+            CURLOPT_CUSTOMREQUEST  => "POST",
+            CURLOPT_POSTFIELDS     => $data,
+            CURLOPT_HTTPHEADER     => [
+                "key: $thirdKey",
+                "sign: $sign",
+                "timestamp: $time"
+            ],
+        ]);
+
+        $response = curl_exec($curl);
+
+        curl_close($curl);
+
+        $response = json_decode($response, true);
+        return $response;
+    }
+
+
+
     public function gzc($uid, $pension)
     {
         $thirdKey = "xingfubao";
@@ -264,6 +318,6 @@ class OrderGzcRepository extends BaseRepository
         curl_close($curl);
 
         $response = json_decode($response, true);
-        return $response['code'];
+        return $response;
     }
 }

app/controller/admin/system/merchant/GzcLogs.php

@@ -69,38 +69,131 @@ class GzcLogs extends BaseController
      * created: 2021/3/24 13:56
      */
     public function inGzc()
-    {
-        return app('json')->fail('不可执行');
-        $params = $this->request->params(['account_type', 'bank_name', 'branch_name', 'bank_account', 'bank_no', 'alipay_account','alipay_no','wxpay_account','wxpay_no','deposit_dt']);
-        Db::table('rrx_gzc_logs')
-            ->where('gzc', 0)
-            ->where('pension', '>', 0)
-            ->update($params);
+    { 
+        $id = intval($this->request->param('id'));
         $cursor = Db::table('rrx_gzc_logs')
+            ->where('id', $id)
             ->where('gzc', 0)
+            ->where('success', 0)
             ->where('pension', '>', 0)
             ->cursor();
+            
         foreach($cursor as $log){
             if (!$log){
                 return app('json')->fail('暂无记录');
             }
-            $phone= Db::table('rrx_user')->where('uid',$log['uid'])->value('phone');
-            $OrderGzcRepository      = app()->make(OrderGzcRepository::class);
-            $uid = $OrderGzcRepository->register($phone);
-            $OrderGzcRepository->gzc($uid,$log['pension']);
+            $mobile= $log['mobile'];
+            $user_name =  Db::name('user_certification')->where('uid',$log['uid'])->value('user_name');
+            $user_card =  Db::name('user_certification')->where('uid',$log['uid'])->value('user_card');
+            $card_positive = Db::name('user_certification')->where('uid',$log['uid'])->value('card_positive');
+            $card_reverse = Db::name('user_certification')->where('uid',$log['uid'])->value('card_reverse');
+            if(!$mobile || !$user_name || !$user_card || !$card_positive || !$card_reverse){
+                return app('json')->fail('暂无记录');
+            }
+
+            //发起入账gzc
+            $OrderGzcRepository = app()->make(OrderGzcRepository::class);
+            $register = $OrderGzcRepository->register($mobile);
+            if($register['status'] != 200) return app('json')->fail('入账失败:'.$register['message']);
+            $uid = $register['data']['uid'] ?? 0;
+            if(!$uid) return app('json')->fail('创建或获取用户失败');
+            $certification = $OrderGzcRepository->certification($uid, $mobile, $user_name, $user_card, $card_positive, $card_reverse);
+            if($certification['status'] != 200) return app('json')->fail('实名认证失败:'.$certification['message']);
+            $gzc = $OrderGzcRepository->gzc($uid,$log['pension']);
+            if($gzc['status'] != 200) return app('json')->fail('入账失败:'.$gzc['message']);
+            $gzc_deposit_no = $gzc['data'];
+            $gzc_confirm_result = $gzc['message'];
         }
         $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
         $orderId = $OrderMerchantRepository->getNewOrderId('IN10');
         Db::table('rrx_gzc_logs')
+        ->where('id', $id)
+        ->where('gzc', 0)
+        ->where('success', 0)
+        ->where('pension', '>', 0)
+        ->update([
+            'gzc' => 1,
+            'platform_no' => $orderId,
+            'gzc_deposit_no' => $gzc_deposit_no,
+            'gzc_confirm_result' => $gzc_confirm_result,
+            'success' => 1,
+            'update_time' => date('Y-m-d H:i:s')
+        ]);
+        return app('json')->success('发起成功');
+    }
+
+
+
+
+    /**
+     * 发起入账
+     * author: php迷途小书童
+     * created: 2021/3/24 13:56
+     */
+    public function inGzcAll()
+    { 
+        $ids = intval($this->request->param('ids'));
+        if(!$ids) return app('json')->fail('请选择需要入账的记录');
+        $ids = explode(",", $ids);
+        if(!count($ids)){
+            return app('json')->fail('暂无记录');
+        }
+
+        $cursor = Db::table('rrx_gzc_logs')
+            ->whereIn('id', $ids)
             ->where('gzc', 0)
+            ->where('success', 0)
+            ->where('pension', '>', 0)
+            ->cursor();
+        foreach($cursor as $log){
+            if (!$log){
+                return app('json')->fail('暂无记录');
+            }
+            $mobile= $log['mobile'];
+            $user_name =  Db::name('user_certification')->where('uid',$log['uid'])->value('user_name');
+            $user_card =  Db::name('user_certification')->where('uid',$log['uid'])->value('user_card');
+            $card_positive = Db::name('user_certification')->where('uid',$log['uid'])->value('card_positive');
+            $card_reverse = Db::name('user_certification')->where('uid',$log['uid'])->value('card_reverse');
+            if(!$mobile || !$user_name || !$user_card || !$card_positive || !$card_reverse){
+                return app('json')->fail('暂无记录');
+            }
+
+            //发起入账gzc
+            $OrderGzcRepository = app()->make(OrderGzcRepository::class);
+            $register = $OrderGzcRepository->register($mobile);
+            if($register['status'] != 200) return app('json')->fail('入账失败:'.$register['message']);
+            $uid = $register['data']['uid'] ?? 0;
+            if(!$uid) return app('json')->fail('创建或获取用户失败');
+            $certification = $OrderGzcRepository->certification($uid, $mobile, $user_name, $user_card, $card_positive, $card_reverse);
+            if($certification['status'] != 200) return app('json')->fail('实名认证失败:'.$certification['message']);
+            $gzc = $OrderGzcRepository->gzc($uid,$log['pension']);
+            if($gzc['status'] != 200) return app('json')->fail('入账失败:'.$gzc['message']);
+            $gzc_deposit_no = $gzc['data'];
+            $gzc_confirm_result = $gzc['message'];
+
+            $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
+            $orderId = $OrderMerchantRepository->getNewOrderId('IN10');
+            Db::table('rrx_gzc_logs')
+            ->where('id', $log['id'])
+            ->where('gzc', 0)
+            ->where('success', 0)
             ->where('pension', '>', 0)
             ->update([
                 'gzc' => 1,
                 'platform_no' => $orderId,
+                'gzc_deposit_no' => $gzc_deposit_no,
+                'gzc_confirm_result' => $gzc_confirm_result,
+                'success' => 1,
                 'update_time' => date('Y-m-d H:i:s')
             ]);
+        }
         return app('json')->success('发起成功');
     }
+
+
+
+
+
     /**
      * TODO 导出文件
      * @author Qinii

route/admin.php

@@ -191,6 +191,7 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
             Route::get('lst', '/lst')->name('systemMerchantGzcLogsLst');
             Route::get('inForm', '/inForm')->name('systemMerchantGzcInForm');
             Route::post('inGzc', '/inGzc')->name('systemMerchantGzcIn');
+            Route::post('inGzcAll', '/inGzcAll')->name('systemMerchantGzcInAll');
             Route::get('editForm/:id/form', '/editForm')->name('systemMerchantGzcEditForm');
             Route::post('editForm', '/editFormPost')->name('systemMerchantGzcEditFormPost');
             Route::post('checkAmount', '/checkAmount')->name('systemMerchantGzcEditFormPost');