tk query

application/command.php

@@ -22,4 +22,5 @@ return [
     \app\common\command\OrderExpiredCommand::class,
     \app\common\command\UserExpiredCommand::class,
     \app\common\command\LoginCommand::class,
+    \app\common\command\TakeCashQueryCommand::class,
 ];

application/common/command/TakeCashQueryCommand.php

@@ -0,0 +1,41 @@
+<?php
+namespace app\common\command;
+
+use app\common\model\TakeCash;
+use app\common\model\User;
+use app\service\WechatTransferSvc;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\Db;
+use think\Log;
+
+class TakeCashQueryCommand extends Command{
+    protected function configure()
+    {
+        $this->setName('tk:query')->setDescription('提现确认');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        $cashes=TakeCash::where('check_status',0)
+            ->where('status',TakeCash::STATUS_PASS)
+            ->limit(10)
+            ->select();
+        $class=new WechatTransferSvc();
+        foreach ($cashes as $cash){
+            Db::startTrans();
+            try {
+                list($succ,$data)=$class->checkDetail($cash['order_no'],$cash['detail_no']);
+                if(in_array($data['detail_status'],['SUCCESS','PROCESSING'])){
+                    $cash['check_status']=$data['detail_status']=='SUCCESS'?1:2;
+                    $cash['check_data']=$data['fail_reason']??json_encode($data,256);
+                    $cash->save();
+                }
+                Db::commit();
+            }catch (\Exception $e){
+                Db::rollback();
+            }
+        }
+    }
+}