blackteay/ThinkAdmin
1
0
Fork 0
mirror of https://gitee.com/zoujingli/ThinkAdmin.git synced 2025-05-22 06:49:15 +08:00
Code Issues Projects Releases Wiki Activity

Update UserTransfer.php

Browse Source
This commit is contained in:
邹景立 2021-03-19 15:47:40 +08:00
parent 4e91d298fd
commit a45d2f0774
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,13 +29,17 @@ class UserTransfer extends Command
* @param Input $input * @param Input $input
* @param Output $output * @param Output $output
* @return void * @return void
* @throws Exception
* @throws \think\db\exception\DbException * @throws \think\db\exception\DbException
*/ */
protected function execute(Input $input, Output $output) protected function execute(Input $input, Output $output)
{ {
$map = [['type', 'in', ['wechat_banks', 'wechat_wallet']], ['status', 'in', [3, 4]]]; $map = [['type', 'in', ['wechat_banks', 'wechat_wallet']], ['status', 'in', [3, 4]]];
[$total, $count, $error] = [$this->app->db->name('DataUserTransfer')->where($map)->count(), 0, 0];
foreach ($this->app->db->name('DataUserTransfer')->where($map)->cursor() as $vo) try { foreach ($this->app->db->name('DataUserTransfer')->where($map)->cursor() as $vo) try {
$this->queue->message($total, ++$count, "开始处理订单 {$vo['code']} 提现");
if ($vo['status'] === 3) { if ($vo['status'] === 3) {
$this->queue->message($total, $count, "尝试处理订单 {$vo['code']} 打款", 1);
if ($vo['type'] === 'wechat_banks') { if ($vo['type'] === 'wechat_banks') {
$result = $this->createTransferBank($vo); $result = $this->createTransferBank($vo);
} else { } else {
@ -55,6 +59,7 @@ class UserTransfer extends Command
]); ]);
} }
} elseif ($vo['status'] === 4) { } elseif ($vo['status'] === 4) {
$this->queue->message($total, $count, "刷新提现订单 {$vo['code']} 状态", 1);
if ($vo['type'] === 'wechat_banks') { if ($vo['type'] === 'wechat_banks') {
$this->queryTransferBank($vo); $this->queryTransferBank($vo);
} else { } else {
@ -62,11 +67,13 @@ class UserTransfer extends Command
} }
} }
} catch (\Exception $exception) { } catch (\Exception $exception) {
$this->output->writeln("提现 {$vo['code']} 失败，{$exception->getMessage()}"); $error++;
$this->queue->message($total, $count, "处理提现订单 {$vo['code']} 失败，{$exception->getMessage()}");
$this->app->db->name('DataUserTransfer')->where(['code' => $vo['code']])->update([ $this->app->db->name('DataUserTransfer')->where(['code' => $vo['code']])->update([
'change_time' => date('Y-m-d H:i:s'), 'change_desc' => $exception->getMessage(), 'change_time' => date('Y-m-d H:i:s'), 'change_desc' => $exception->getMessage(),
]); ]);
} }
$this->setQueueSuccess("此次共处理 {$total} 笔提现操作，处理失败 {$error} 笔。");
} }
/** /**