format('Y-m-d H:i:s'); $books = DB::table('books') ->where('created_at', '>=', $datetime) ->select('id', 'cp_name', 'name') ->get(); $redisKey = 'contentManage.cp.newBook.alreadyAlert'; $str = ''; foreach ($books as $book) { if(Redis::sismember($redisKey, $book->id)) { continue; } $str .= sprintf('%s cp方的新书:%s
', $book->cp_name, $book->name); Redis::sadd($redisKey, $book->id); } if(!$str) { return ; } $str .= '已经进入植宇内容中台,请尽快查看'; NoticesService::addNotice([ 'title' => '有cp方新的书籍接入', 'notice_type_id' => 2, 'type' => 1, 'is_popup' => 1, 'content' => $str ]); } }