138 lines
4.0 KiB
PHP
138 lines
4.0 KiB
PHP
<?php
|
||
|
||
namespace app\task\behavior\sharing;
|
||
|
||
use think\Cache;
|
||
use app\task\model\sharing\Order as OrderModel;
|
||
use app\task\model\sharing\Active as ActiveModel;
|
||
use app\task\model\sharing\Setting as SettingModel;
|
||
use app\common\service\Message as MessageService;
|
||
use app\common\enum\sharing\ActiveStatus as ActiveStatusEnum;
|
||
|
||
/**
|
||
* 拼团订单行为管理
|
||
* Class Active
|
||
* @package app\task\behavior
|
||
*/
|
||
class Active
|
||
{
|
||
/* @var ActiveModel $model */
|
||
private $model;
|
||
|
||
/**
|
||
* 执行函数
|
||
* @param $model
|
||
* @return bool
|
||
*/
|
||
public function run($model)
|
||
{
|
||
if (!$model instanceof ActiveModel) {
|
||
return new ActiveModel and false;
|
||
}
|
||
$this->model = $model;
|
||
if (!$model::$wxapp_id) {
|
||
return false;
|
||
}
|
||
if (!Cache::has('__task_space__sharing_active__' . $model::$wxapp_id)) {
|
||
try {
|
||
// 拼团设置
|
||
$config = SettingModel::getItem('basic');
|
||
// 已过期的拼单更新状态(拼单失败)
|
||
$this->onUpdateActiveEnd();
|
||
// 更新拼团失败的订单并退款
|
||
if ($config['auto_refund'] == true) {
|
||
$this->onOrderRefund();
|
||
}
|
||
} catch (\Exception $e) {
|
||
}
|
||
Cache::set('__task_space__sharing_active__' . $model::$wxapp_id, time(), 10);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 已过期的拼单更新状态
|
||
* @return false|int
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
private function onUpdateActiveEnd()
|
||
{
|
||
// 获取已过期的拼单列表
|
||
$list = $this->model->getEndedList();
|
||
// 拼单ID集
|
||
$activeIds = [];
|
||
foreach ($list as $item) {
|
||
$activeIds[] = $item['active_id'];
|
||
}
|
||
// 记录日志
|
||
$this->dologs('onSetActiveEnd', [
|
||
'activeIds' => json_encode($activeIds),
|
||
]);
|
||
// 发送拼团失败订阅消息
|
||
foreach ($list as $item) {
|
||
MessageService::send('sharing.active_status', [
|
||
'active' => $item,
|
||
'status' => ActiveStatusEnum::ACTIVE_STATE_FAIL
|
||
]);
|
||
}
|
||
// 更新已过期状态
|
||
return $this->model->updateEndedStatus($activeIds);
|
||
}
|
||
|
||
/**
|
||
* 更新拼团失败的订单并退款
|
||
* @return bool
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
private function onOrderRefund()
|
||
{
|
||
// 实例化拼单订单模型
|
||
$model = new OrderModel;
|
||
// 每次最多处理的个数，防止运行太久
|
||
// 及微信申请退款API请求频率限制：150qps
|
||
$maxLimit = 100;
|
||
// 获取拼团失败的订单集
|
||
$orderList = $model->getFailedOrderList($maxLimit);
|
||
// 整理拼团订单id
|
||
$orderIds = [];
|
||
foreach ($orderList as $order) {
|
||
$orderIds[] = $order['order_id'];
|
||
}
|
||
// 记录日志
|
||
$this->dologs('onOrderRefund', [
|
||
'orderIds' => json_encode($orderIds),
|
||
]);
|
||
if (empty($orderIds)) {
|
||
return false;
|
||
}
|
||
// 更新拼团失败的订单并退款
|
||
if ($model->updateFailedStatus($orderList)) {
|
||
return true;
|
||
}
|
||
// 存在退款出错的订单记录日志
|
||
$this->dologs('onOrderRefund', [
|
||
'error: ' => $model->getError()
|
||
]);
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 记录日志
|
||
* @param $method
|
||
* @param array $params
|
||
* @return bool|int
|
||
*/
|
||
private function dologs($method, $params = [])
|
||
{
|
||
$value = 'behavior sharing Active --' . $method;
|
||
foreach ($params as $key => $val)
|
||
$value .= ' --' . $key . ' ' . $val;
|
||
return log_write($value);
|
||
}
|
||
|
||
}
|