// +---------------------------------------------------------------------- namespace app\jobs\order; use app\services\order\StoreOrderStatusServices; use crmeb\basic\BaseJobs; use crmeb\traits\QueueTrait; /** * Class OrderStatusJob * @package app\jobs\order */ class OrderStatusJob extends BaseJobs { use QueueTrait; public function doJob($orderId, $group, $totalPrice, $payPrice) { /** @var StoreOrderStatusServices $statusService */ $statusService = app()->make(StoreOrderStatusServices::class); $statusService->save([ 'oid' => $orderId, 'change_type' => 'cache_key_create_order', 'change_message' => '订单生成', 'change_time' => time() ]); if (isset($group['changePrice']) && $group['changePrice'] > 0) { $totalPrice = $group['priceData']['pay_price'] ?? $totalPrice; $statusService->save([ 'oid' => $orderId, 'change_type' => 'order_edit', 'change_time' => time(), 'change_message' => '商品总价为:' . $totalPrice . ' 修改实际支付金额为:' . $payPrice ]); } return true; } /** * 保存支付成功 * @param $oid * @return bool */ public function savePayStatus($oid) { if (!$oid) { return true; } /** @var StoreOrderStatusServices $statusService */ $statusService = app()->make(StoreOrderStatusServices::class); $statusService->save([ 'oid' => $oid, 'change_type' => 'pay_success', 'change_message' => '用户付款成功', 'change_time' => time() ]); return true; } }