pg_lookup_product.c (7553B)
1 /* 2 This file is part of TALER 3 Copyright (C) 2022, 2025 Taler Systems SA 4 5 TALER is free software; you can redistribute it and/or modify it under the 6 terms of the GNU General Public License as published by the Free Software 7 Foundation; either version 3, or (at your option) any later version. 8 9 TALER is distributed in the hope that it will be useful, but WITHOUT ANY 10 WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 11 A PARTICULAR PURPOSE. See the GNU General Public License for more details. 12 13 You should have received a copy of the GNU General Public License along with 14 TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> 15 */ 16 /** 17 * @file backenddb/pg_lookup_product.c 18 * @brief Implementation of the lookup_product function for Postgres 19 * @author Iván Ávalos 20 */ 21 #include "taler/platform.h" 22 #include <taler/taler_error_codes.h> 23 #include <taler/taler_dbevents.h> 24 #include <taler/taler_pq_lib.h> 25 #include "pg_lookup_product.h" 26 #include "pg_helper.h" 27 28 29 enum GNUNET_DB_QueryStatus 30 TMH_PG_lookup_product (void *cls, 31 const char *instance_id, 32 const char *product_id, 33 struct TALER_MERCHANTDB_ProductDetails *pd, 34 size_t *num_categories, 35 uint64_t **categories) 36 { 37 struct PostgresClosure *pg = cls; 38 struct GNUNET_PQ_QueryParam params[] = { 39 GNUNET_PQ_query_param_string (instance_id), 40 GNUNET_PQ_query_param_string (product_id), 41 GNUNET_PQ_query_param_end 42 }; 43 44 PREPARE (pg, 45 "lookup_product", 46 "SELECT" 47 " mi.description" 48 ",mi.description_i18n::TEXT" 49 ",mi.product_name" 50 ",mi.unit" 51 ",mi.price_array" 52 ",mi.taxes::TEXT" 53 ",mi.total_stock" 54 ",mi.total_stock_frac" 55 ",mi.allow_fractional_quantity" 56 ",mi.fractional_precision_level" 57 ",mi.total_sold" 58 ",mi.total_sold_frac" 59 ",mi.total_lost" 60 ",mi.total_lost_frac" 61 ",mi.image" 62 ",mi.address::TEXT" 63 ",mi.next_restock" 64 ",mi.minimum_age" 65 ",mi.product_group_serial" 66 ",mi.money_pot_serial" 67 ",mi.price_is_net" 68 ",t.category_array AS categories" 69 " FROM merchant_inventory mi" 70 " JOIN merchant_instances inst" 71 " USING (merchant_serial)" 72 ",LATERAL (" 73 " SELECT ARRAY (" 74 " SELECT mpc.category_serial" 75 " FROM merchant_product_categories mpc" 76 " WHERE mpc.product_serial = mi.product_serial" 77 " ) AS category_array" 78 " ) t" 79 " WHERE inst.merchant_id=$1" 80 " AND mi.product_id=$2" 81 ); 82 if (NULL == pd) 83 { 84 struct GNUNET_PQ_ResultSpec rs_null[] = { 85 GNUNET_PQ_result_spec_end 86 }; 87 88 check_connection (pg); 89 return GNUNET_PQ_eval_prepared_singleton_select (pg->conn, 90 "lookup_product", 91 params, 92 rs_null); 93 } 94 else 95 { 96 char *my_name = NULL; 97 char *my_description = NULL; 98 json_t *my_description_i18n = NULL; 99 char *my_unit = NULL; 100 char *my_image = NULL; 101 json_t *my_address = NULL; 102 json_t *my_taxes = NULL; 103 uint64_t *my_categories = NULL; 104 struct TALER_Amount *my_price_array = NULL; 105 size_t my_price_array_length = 0; 106 struct GNUNET_PQ_ResultSpec rs[] = { 107 GNUNET_PQ_result_spec_string ("description", 108 &my_description), 109 TALER_PQ_result_spec_json ("description_i18n", 110 &my_description_i18n), 111 GNUNET_PQ_result_spec_string ("product_name", 112 &my_name), 113 GNUNET_PQ_result_spec_string ("unit", 114 &my_unit), 115 TALER_PQ_result_spec_array_amount_with_currency (pg->conn, 116 "price_array", 117 &my_price_array_length, 118 &my_price_array), 119 TALER_PQ_result_spec_json ("taxes", 120 &my_taxes), 121 GNUNET_PQ_result_spec_uint64 ("total_stock", 122 &pd->total_stock), 123 GNUNET_PQ_result_spec_uint32 ("total_stock_frac", 124 &pd->total_stock_frac), 125 GNUNET_PQ_result_spec_bool ("allow_fractional_quantity", 126 &pd->allow_fractional_quantity), 127 GNUNET_PQ_result_spec_uint32 ("fractional_precision_level", 128 &pd->fractional_precision_level), 129 GNUNET_PQ_result_spec_uint64 ("total_sold", 130 &pd->total_sold), 131 GNUNET_PQ_result_spec_uint32 ("total_sold_frac", 132 &pd->total_sold_frac), 133 GNUNET_PQ_result_spec_uint64 ("total_lost", 134 &pd->total_lost), 135 GNUNET_PQ_result_spec_uint32 ("total_lost_frac", 136 &pd->total_lost_frac), 137 GNUNET_PQ_result_spec_string ("image", 138 &my_image), 139 TALER_PQ_result_spec_json ("address", 140 &my_address), 141 GNUNET_PQ_result_spec_timestamp ("next_restock", 142 &pd->next_restock), 143 GNUNET_PQ_result_spec_uint32 ("minimum_age", 144 &pd->minimum_age), 145 GNUNET_PQ_result_spec_array_uint64 (pg->conn, 146 "categories", 147 num_categories, 148 &my_categories), 149 GNUNET_PQ_result_spec_allow_null ( 150 GNUNET_PQ_result_spec_uint64 ("product_group_serial", 151 &pd->product_group_id), 152 NULL), 153 GNUNET_PQ_result_spec_allow_null ( 154 GNUNET_PQ_result_spec_uint64 ("money_pot_serial", 155 &pd->money_pot_id), 156 NULL), 157 GNUNET_PQ_result_spec_bool ("price_is_net", 158 &pd->price_is_net), 159 GNUNET_PQ_result_spec_end 160 }; 161 enum GNUNET_DB_QueryStatus qs; 162 163 check_connection (pg); 164 pd->product_group_id = 0; 165 pd->money_pot_id = 0; 166 qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn, 167 "lookup_product", 168 params, 169 rs); 170 pd->product_name = my_name; 171 pd->description = my_description; 172 pd->description_i18n = my_description_i18n; 173 pd->unit = my_unit; 174 pd->taxes = my_taxes; 175 pd->image = my_image; 176 pd->image_hash = NULL; 177 pd->address = my_address; 178 pd->price_array = my_price_array; 179 pd->price_array_length = my_price_array_length; 180 *categories = my_categories; 181 /* Clear original pointers to that cleanup_result doesn't squash them */ 182 my_name = NULL; 183 my_description = NULL; 184 my_description_i18n = NULL; 185 my_unit = NULL; 186 my_taxes = NULL; 187 my_image = NULL; 188 my_address = NULL; 189 my_price_array = NULL; 190 my_price_array_length = 0; 191 my_categories = NULL; 192 GNUNET_PQ_cleanup_result (rs); 193 return qs; 194 } 195 }