ddsc/application/store/command/AutoRun.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\store\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\Db;
use think\db\exception\DataNotFoundException;
use think\db\exception\ModelNotFoundException;
use think\Exception;
use think\exception\DbException;
use think\exception\PDOException;
use We;

/**
 * 商城数据处理指令
 * Class AutoRun
 * @package app\store\command
 */
class AutoRun extends Command
{

    /**
     * 配置指令信息
     */
    protected function configure()
    {
        $this->setName('xclean:store')->setDescription('[清理]检查并处理商城任务');
    }

    /**
     * 业务指令执行
     * @param Input $input
     * @param Output $output
     * @throws Exception
     * @throws DataNotFoundException
     * @throws ModelNotFoundException
     * @throws DbException
     * @throws PDOException
     */
    protected function execute(Input $input, Output $output)
    {
        // 自动取消30分钟未支付的订单
        $this->autoCancelOrder();
        // 清理一天前未支付的订单
        $this->autoRemoveOrder();
        // 订单自动退款处理
        // $this->autoRefundOrder();
        // 提现自动打款处理
        // $this->autoTransfer();
    }

    /**
     * 自动取消30分钟未支付的订单
     * @throws Exception
     * @throws PDOException
     */
    private function autoCancelOrder()
    {
        $datetime = $this->getDatetime('store_order_wait_time');
        $where = [['status', 'in', ['1', '2']], ['pay_state', 'eq', '0'], ['create_at', '<', $datetime]];
        $count = Db::name('StoreOrder')->where($where)->update([
            'status'       => '0',
            'cancel_state' => '1',
            'cancel_at'    => date('Y-m-d H:i:s'),
            'cancel_desc'  => '30分钟未完成支付自动取消订单',
        ]);
        if ($count > 0) {
            $this->output->info("共计自动取消了30分钟未支付的{$count}笔订单！");
        } else {
            $this->output->comment('没有需要自动取消30分钟未支付的订单记录！');
        }
    }

    /**
     * 清理一天前未支付的订单
     * @throws Exception
     * @throws DataNotFoundException
     * @throws ModelNotFoundException
     * @throws DbException
     * @throws PDOException
     */
    private function autoRemoveOrder()
    {
        $datetime = $this->getDatetime('store_order_clear_time');
        $where = [['status', 'eq', '0'], ['pay_state', 'eq', '0'], ['create_at', '<', $datetime]];
        $list = Db::name('StoreOrder')->where($where)->limit(20)->select();
        if (count($orderNos = array_unique(array_column($list, 'order_no'))) > 0) {
            $this->output->info("自动删除前一天已经取消的订单：" . PHP_EOL . join(',' . PHP_EOL, $orderNos));
            Db::name('StoreOrder')->whereIn('order_no', $orderNos)->delete();
            Db::name('StoreOrderList')->whereIn('order_no', $orderNos)->delete();
        } else {
            $this->output->comment('没有需要自动删除前一天已经取消的订单！');
        }
    }

    /**
     * 订单自动退款操作
     * @throws Exception
     * @throws DataNotFoundException
     * @throws ModelNotFoundException
     * @throws DbException
     * @throws PDOException
     */
    private function autoRefundOrder()
    {
        // 未完成退款的订单，执行微信退款操作
        foreach (Db::name('StoreOrder')->where(['refund_state' => '1'])->select() as $order) try {
            $this->output->writeln("正在为 {$order['order_no']} 执行退款操作...");
            $result = We::WePayRefund(config('wechat.wxpay'))->create([
                'transaction_id' => $order['pay_no'],
                'out_refund_no'  => $order['refund_no'],
                'total_fee'      => $order['price_total'] * 100,
                'refund_fee'     => $order['pay_price'] * 100,
                'refund_account' => 'REFUND_SOURCE_UNSETTLED_FUNDS',
            ]);
            if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
                Db::name('StoreOrder')->where(['order_no' => $order['order_no']])->update([
                    'refund_state' => '2', 'refund_desc' => '自动退款成功！',
                ]);
            } else {
                Db::name('StoreOrder')->where(['order_no' => $order['order_no']])->update([
                    'refund_desc' => isset($result['err_code_des']) ? $result['err_code_des'] : '自动退款失败',
                ]);
            }
        } catch (\Exception $e) {
            $this->output->writeln("订单 {$order['order_no']} 执行退款失败，{$e->getMessage()}！");
            Db::name('StoreOrder')->where(['order_no' => $order['order_no']])->update(['refund_desc' => $e->getMessage()]);
        }
        $this->output->writeln('自动检测退款订单执行完成！');
    }

    /**
     * 自动企业打款操作
     * @throws Exception
     * @throws DataNotFoundException
     * @throws ModelNotFoundException
     * @throws DbException
     * @throws PDOException
     */
    private function autoTransfer()
    {
        # 批量企业打款
        foreach (Db::name('StoreProfitUsed')->where(['status' => '1'])->select() as $vo) try {
            $wechat = We::WePayTransfers(config('wechat.wxpay'));
            $result = $wechat->create([
                'partner_trade_no' => $vo['trs_no'],
                'openid'           => $vo['openid'],
                'check_name'       => 'NO_CHECK',
                'amount'           => $vo['pay_price'] * 100,
                'desc'             => '营销活动拥金提现',
                'spbill_create_ip' => '127.0.0.1',
            ]);
            if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
                Db::name('StoreProfitUsed')->where(['trs_no' => $vo['trs_no']])->update([
                    'status' => '2', 'pay_desc' => '拥金提现成功！', 'pay_no' => $result['payment_no'], 'pay_at' => date('Y-m-d H:i:s'),
                ]);
            } else {
                Db::name('StoreProfitUsed')->where(['trs_no' => $vo['trs_no']])->update([
                    'pay_desc' => isset($result['err_code_des']) ? $result['err_code_des'] : '自动打款失败', 'last_at' => date('Y-m-d H:i:s'),
                ]);
            }
        } catch (\Exception $e) {
            $this->output->writeln("订单 {$vo['trs_no']} 执行提现失败，{$e->getMessage()}！");
            Db::name('StoreProfitUsed')->where(['trs_no' => $vo['trs_no']])->update(['pay_desc' => $e->getMessage()]);
        }
    }

    /**
     * 获取配置时间
     * @param string $code
     * @return string
     * @throws Exception
     * @throws PDOException
     */
    private function getDatetime($code)
    {
        $minutes = intval(sysconf($code) * 60);
        return date('Y-m-d H:i:s', strtotime("-{$minutes} minutes"));
    }

}