blackteay/ThinkAdmin
1
0
Fork 0
mirror of https://gitee.com/zoujingli/ThinkAdmin.git synced 2025-04-24 18:36:15 +08:00
Code Issues Projects Releases Wiki Activity

Update UserTransfer.php

Browse Source
This commit is contained in:
邹景立 2021-03-18 18:39:42 +08:00
parent f6010d56fc
commit 7cb50999de
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
app/data/command/UserTransfer.php
View File

@ -61,7 +61,6 @@ class UserTransfer extends Command
} else { } else {
$this->queryTransferWallet($vo); $this->queryTransferWallet($vo);
} }
continue;
} }
} catch (\Exception $exception) { } catch (\Exception $exception) {
$this->output->writeln("订单 {$vo['code']} 提现失败，{$exception->getMessage()}"); $this->output->writeln("订单 {$vo['code']} 提现失败，{$exception->getMessage()}");
@ -85,8 +84,7 @@ class UserTransfer extends Command
*/ */
private function createTransferBank(array $item): array private function createTransferBank(array $item): array
{ {
$wechat = TransfersBank::instance($this->getConfig()); return TransfersBank::instance($this->getConfig())->create([
return $wechat->create([
'partner_trade_no' => $item['code'], 'partner_trade_no' => $item['code'],
'enc_bank_no' => $item['bank_code'], 'enc_bank_no' => $item['bank_code'],
'enc_true_name' => $item['bank_user'], 'enc_true_name' => $item['bank_user'],
@ -135,13 +133,10 @@ class UserTransfer extends Command
*/ */
private function queryTransferWallet(array $item) private function queryTransferWallet(array $item)
{ {
$config = $this->getConfig(); $result = Transfers::instance($this->getConfig())->query($item['partner_trade_no']);
$wechat = Transfers::instance($config);
$result = $wechat->query($item['partner_trade_no']);
if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') { if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
$this->app->db->name('DataUserTransfer')->where(['code' => $item['code']])->update([ $this->app->db->name('DataUserTransfer')->where(['code' => $item['code']])->update([
'status' => 5, 'status' => 5,
'trade_no' => $result['partner_trade_no'],
'trade_time' => $result['payment_time'], 'trade_time' => $result['payment_time'],
'change_time' => date('Y-m-d H:i:s'), 'change_time' => date('Y-m-d H:i:s'),
'change_desc' => '微信提现打款成功', 'change_desc' => '微信提现打款成功',
@ -161,9 +156,7 @@ class UserTransfer extends Command
*/ */
private function queryTransferBank(array $item) private function queryTransferBank(array $item)
{ {
$config = $this->getConfig(); $result = TransfersBank::instance($this->getConfig())->query($item['partner_trade_no']);
$wechat = TransfersBank::instance($config);
$result = $wechat->query($item['partner_trade_no']);
if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') { if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
if ($result['status'] === 'SUCCESS') { if ($result['status'] === 'SUCCESS') {
$this->app->db->name('DataUserTransfer')->where(['code' => $item['code']])->update([ $this->app->db->name('DataUserTransfer')->where(['code' => $item['code']])->update([