<?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\Db;
/**
* 商城数据处理指令
* Class AutoRun
* @package app\store\command
*/
class AutoRun extends \think\console\Command
{
protected function configure()
{
$this->setName('xclean:store')->setDescription('clean up invalid store records');
}
/**
* 业务指令执行
* @param \think\console\Input $input
* @param \think\console\Output $output
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
protected function execute(\think\console\Input $input, \think\console\Output $output)
{
// 自动取消30分钟未支付的订单
$this->autoCancelOrder();
// 清理一天前未支付的订单
$this->autoRemoveOrder();
// 订单自动退款处理
// $this->autoRefundOrder();
// 提现自动打款处理
// $this->autoTransfer();
}
/**
* 自动取消30分钟未支付的订单
* @throws \think\Exception
* @throws \think\exception\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 \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\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 \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\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 \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\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 \think\Exception
* @throws \think\exception\PDOException
*/
private function getDatetime($code)
{
$minutes = intval(sysconf($code) * 60);
return date('Y-m-d H:i:s', strtotime("-{$minutes} minutes"));
}
}