public function consume($data): void
{
try {
$register = Db::table('activity_registration')->where("id", $data['id'])->first();
if ($register) {
// var_dump($register);
$isTradeManaged = $this->easyWeChatService->isTradeManaged($register->team_id);
// var_dump($isTradeManaged);
if ($isTradeManaged) {
//發(fā)貨
$shipping_list = [
['item_desc' => '活動報名虛擬發(fā)貨通知']
];
$user = Db::table('user')->where("id", $register->user_id)->first();
$this->easyWeChatService->shippingMiniProgramEntry($register->team_id,$register->transaction_id,3,$shipping_list,$user->openid);
}
}
} catch (Throwable $exception) {
throw new BusinessException($exception->getMessage());
}
}
上面是redis隊(duì)列的代碼,這邊測試會出現(xiàn)一個問題,用的laravel的數(shù)據(jù)庫,當(dāng)超過8小時沒有redis隊(duì)列沒有操作的時候,在redis里面進(jìn)行數(shù)據(jù)庫操作就會出現(xiàn)這個問題。然后這個問題只在隊(duì)列里面出現(xiàn)了,在http進(jìn)程里面是沒有出現(xiàn)過這個問題的