get( ' INSERT INTO public.basket ( user_id, letter, last_mod ) VALUES ( :user_id, :letter, CURRENT_TIMESTAMP ) RETURNING user_id ', [ 'user_id' => $data['user_id'], 'letter' => $data['letter'] ], -1 ); foreach ($data['items'] as $item) { $this->get( ' INSERT INTO public.basket_items ( user_id, item_id, count ) VALUES ( :user_id, :item_id, :count ) RETURNING id ', [ 'user_id' => $data['user_id'], 'item_id' => $item['item_id'], 'count' => $item['count_items'] ], -1 ); } return 'User #'.$query_basket[0]['user_id'].' added'; } public function checkExist($user_id) { $query = $this->get( ' SELECT * FROM public.basket WHERE user_id = :user_id LIMIT 1 ', [ 'user_id' => $user_id ], -1 ); if (!empty($query[0]['id'])) { return true; } else { return false; } } // public function updateData($data) { // $query_basket = $this->exec( // ' // UPDATE // public.basket // SET // letter = :letter, // last_mod = CURRENT_TIMESTAMP // WHERE // user_id = :user_id // RETURNING user_id // ', // [ // 'user_id' => $data['user_id'], // 'letter' => $data['letter'] // ], // -1 // ); // // foreach ($data['items'] as $item) { // $query_basket_items = $this->get( // ' // INSERT INTO // public.basket_items // ( // user_id, // item_id, // count // ) // VALUES // ( // :user_id, // :item_id, // :count // ) // RETURNING id // ', // [ // 'user_id' => $data['user_id'], // 'item_id' => $item['item_id'], // 'count' => $item['count_items'] // ], // -1 // ); // } // return 'User #'.$query_basket[0]['user_id'].' updated'; // } }