Update UserTransfer.php

app/data/command/UserTransfer.php

@@ -9,6 +9,7 @@ use think\admin\storage\LocalStorage;
 use think\console\Input;
 use think\console\Output;
 use WePay\Transfers;
+use WePay\TransfersBank;
 
 /**
  * 用户提现处理
@@ -24,6 +25,7 @@ class UserTransfer extends Command
     }
 
     /**
+     * 执行微信提现操作
      * @param Input $input
      * @param Output $output
      * @return void
@@ -31,24 +33,20 @@ class UserTransfer extends Command
      */
     protected function execute(Input $input, Output $output)
     {
-        $map = ['type' => 1, 'status' => 3];
+        $map = [['type', 'in', ['wechat_banks', 'wechat_wallet']], ['status', '=', 3]];
         foreach ($this->app->db->name('DataUserTransfer')->where($map)->cursor() as $vo) try {
-            $wechat = Transfers::instance($this->getPayment());
+            if ($vo['type'] === 'wechat_banks') {
-            $result = $wechat->create([
+                $result = $this->transferBank($vo);
-                'openid'           => $vo['openid'],
+            } else {
-                'amount'           => $vo['amount'] * 100,
+                $result = $this->transferWallet($vo);
-                'partner_trade_no' => $vo['code'],
+            }
-                'spbill_create_ip' => '127.0.0.1',
-                'check_name'       => 'NO_CHECK',
-                'desc'             => '微信余额提现',
-            ]);
             if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
                 $this->app->db->name('DataUserTransfer')->where(['code' => $vo['code']])->update([
                     'status'      => 4,
                     'trade_no'    => $result['partner_trade_no'],
                     'trade_time'  => $result['payment_time'],
                     'change_time' => date('Y-m-d H:i:s'),
-                    'change_desc' => '线上提现成功',
+                    'change_desc' => '线上微信提现成功',
                 ]);
             } else {
                 $this->app->db->name('DataUserTransfer')->where(['code' => $vo['code']])->update([
@@ -63,6 +61,81 @@ class UserTransfer extends Command
         }
     }
 
+    /**
+     * 尝试提现转账到银行卡
+     * @param array $item
+     * @return array
+     * @throws Exception
+     * @throws \WeChat\Exceptions\InvalidDecryptException
+     * @throws \WeChat\Exceptions\InvalidResponseException
+     * @throws \WeChat\Exceptions\LocalCacheException
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function transferBank(array $item): array
+    {
+        $wechat = TransfersBank::instance($this->getPayment());
+        return $wechat->create([
+            'partner_trade_no' => $item['code'],
+            'enc_bank_no'      => $item['bank_code'],
+            'enc_true_name'    => $item['bank_user'],
+            'bank_code'        => '1002',
+            'amount'           => $item['amount'] * 100,
+            'desc'             => '微信银行卡提现',
+        ]);
+    }
+
+    /**
+     * 尝试提现转账到微信钱包
+     * @param array $item
+     * @return array
+     * @throws Exception
+     * @throws \WeChat\Exceptions\InvalidResponseException
+     * @throws \WeChat\Exceptions\LocalCacheException
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function transferWallet(array $item): array
+    {
+        $wechat = Transfers::instance($config = $this->getPayment());
+        return $wechat->create([
+            'openid'           => $this->getUserOpenid($item['uid'], $config),
+            'amount'           => $item['amount'] * 100,
+            'partner_trade_no' => $item['code'],
+            'spbill_create_ip' => '127.0.0.1',
+            'check_name'       => 'NO_CHECK',
+            'desc'             => '微信余额提现',
+        ]);
+    }
+
+    /**
+     * 根据配置获取用户OPENID
+     * @param int $uid
+     * @param array $config
+     * @return mixed|null
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function getUserOpenid(int $uid, array $config)
+    {
+        $user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
+        if (empty($user)) return null;
+        if ($config['type'] === 'normal') {
+            if (!empty($user['openid1'])) return $user['openid1'];
+            if (!empty($user['openid2'])) return $user['openid2'];
+        }
+        if ($config['type'] === 'wxapp' && $user['openid1']) {
+            return $user['openid1'];
+        }
+        if ($config['type'] === 'wechat' && !empty($user['openid2'])) {
+            return $user['openid2'];
+        }
+        return null;
+    }
+
     /**
      * 获取微信提现参数
      * @return array
@@ -78,6 +151,7 @@ class UserTransfer extends Command
         $key1 = LocalStorage::instance()->set("{$data['wechat_mch_id']}_key.pem", $data['wechat_mch_key_text'], true);
         $key2 = LocalStorage::instance()->set("{$data['wechat_mch_id']}_cert.pem", $data['wechat_mch_cert_text'], true);
         return [
+            'type'       => $data['wechat_type'],
             'appid'      => $data['wechat_appid'],
             'mch_id'     => $data['wechat_mch_id'],
             'mch_key'    => $data['wechat_mch_key'],