setName('award_integral') ->setDescription('结算消费赠送积分'); } protected function execute(Input $input, Output $output) { try { $time = time(); $ableAuto = ConfigService::get('transaction', 'automatically_confirm_receipt'); $confirmTime = ConfigService::get('transaction', 'automatically_confirm_receipt_days') * 24 * 60 * 60; $orders = Order::where([ ['award_integral_event', '>', 0], ['award_integral', '>', 0], ['is_award_integral', '=', 0], ['pay_status', '=', 1], ['order_status', 'in', [1,2,3]] ])->select()->toArray(); foreach ($orders as $order) { if ($order['award_integral_event'] == OrderEnum::INTEGRAL_ORDER_DELIVERY && $order['order_status'] < OrderEnum::STATUS_WAIT_RECEIVE) { continue; } if ($order['award_integral_event'] == OrderEnum::INTEGRAL_ORDER_FINISH && $order['order_status'] != OrderEnum::STATUS_FINISH) { continue; } if ($order['award_integral_event'] == OrderEnum::INTEGRAL_ORDER_AFTER_SALE_OVER) { if ($ableAuto == YesNoEnum::YES && ($order['order_status'] != OrderEnum::STATUS_FINISH || ($confirmTime + (int) $order['confirm_take_time']) > $time)) { continue; } if ($ableAuto == YesNoEnum::NO && $order['order_status'] != OrderEnum::STATUS_FINISH) { continue; } } //增加用户积分 User::where('id',$order['user_id'])->inc('user_integral', $order['award_integral'])->update(); //修改订单信息 Order::update(['is_award_integral'=>1,'update_time'=>$time],['id'=>$order['id']]); //账户变动记录 AccountLogLogic::add($order['user_id'], AccountLogEnum::INTEGRAL_INC_AWARD, AccountLogEnum::INC, $order['award_integral'], $order['sn'], ''); } } catch (\Exception $e) { Log::write('结算消费赠送积分异常:'.$e->__toString(), 'award_integral_error'); } } }