mall_functions_consumption.c

Go to the documentation of this file.

#include "../header.h"
#include "../mall_agent_header.h"
#include "../library_header.h"


/*
 * \fn: int mall_consumption_shopping()
 * \brief:
 */
int mall_consumption_shopping()
{
    /* Allocate local buyer queues and seller lists. */
    seller_array sellers_list;
    buyer_array buyers_list;
    /* Initialize arrays. */
    init_seller_array(&sellers_list);
    init_buyer_array(&buyers_list);
    
    /* Collect supply */
    int firm_id, inventory;;
    double price, inv_price;
    double denominator = 0;
    double min_price = 5;
    double max_price = 0;
    
    START_SELL_MESSAGE_LOOP
    firm_id = sell_message->id;
    price = sell_message->price;
    if (price < min_price) {
        min_price = price;
    }
    if (price > max_price) {
        max_price = price;
    }
    inventory = sell_message->inventory;
    if (price > 0 && inventory > 0) {
        /* Add to the shelve */
        inv_price = 1/price;
        denominator += inv_price;
        add_seller(&sellers_list, firm_id, price, inventory, inv_price);
    }
    else if (inventory <= 0){
        if (WARNING_MODE) {
            printf("Warning @mall_consumption_shopping(): An invalid inventory = %d is received from Firm ID = %d\n", inventory, firm_id);
        }
    }
    else{
        if (WARNING_MODE) {
            printf("Warning @mall_consumption_shopping(): An invalid price = %f is received from Firm ID = %d\n", price, firm_id);
        }
    }
    
    FINISH_SELL_MESSAGE_LOOP
    
    //printf("IT_NO = %d, Mall max = %f , min = %f\n", IT_NO, max_price, min_price);
    
    
    /* Queue the households */
    int hh_id;
    double budget;
    START_BUY_MESSAGE_LOOP
    hh_id = buy_message->id;
    budget = buy_message->budget;
    if (budget > 0) {
        /* Add household to the queue */
        add_buyer(&buyers_list, hh_id, budget);
    }
    else{
        if (WARNING_MODE) {
            printf("Warning @mall_consumption_shopping(): An invalid budget = %f is received from Household ID = %d\n", budget, hh_id);
        }
    }
    FINISH_BUY_MESSAGE_LOOP
    
    /* Do the matching *
     * Input assumptions:
     * sellers are sorted ascendingly by price.
     * buyers are randomly queued
     * this is done at message filtering stage.
     */
    double select_prob;
    double inv_price_cum;
    double denominator_temp;
    int ind,i;
    int transaction_size;
    double transaction_volume;
    
    /* Identifiers below are used to hold weekly transaction summary.
     */
    int total_sold = 0;
    double total_volume = 0;
    int transaction_occured;
    do {
        
        if (sellers_list.size == 0 || buyers_list.size == 0) {break;}
        
        hh_id = buyers_list.array[0].id;
        budget = buyers_list.array[0].budget;
        price = sellers_list.array[0].price;
        
        /* The household in the turn does not have enough money to buy even
         the cheapest available good.
         */
        if (budget < price) {
            remove_buyer(&buyers_list,0);
            continue;
        }
        
        /* Determining the probability of picking a random seller. */
        select_prob = (double) random_int(0, 99) / 100;
        inv_price_cum = 0;
        transaction_size = 0;
        transaction_volume = 0;
        transaction_occured = 0;
        for (ind = 0; ind < sellers_list.size; ind++) {
            inventory = sellers_list.array[ind].inventory;
            firm_id = sellers_list.array[ind].id;
            if (inventory <= 0) {
                remove_seller(&sellers_list, ind);
                if (WARNING_MODE) {
                    printf("Warning @mall_consumption_shopping(): An invalid inventory = %d is detected while processing Firm ID = %d\n", inventory, firm_id);
                }
                break;
            }
            inv_price_cum += sellers_list.array[ind].inv_price;
            price = sellers_list.array[ind].price;
            
            /* Household with current budget does not afford to buy further goods in the list.
             The household buys from the ones he/she affords to buy.
             */
            if (budget <= price) {
                denominator_temp = inv_price_cum;
                if (denominator_temp <= 0) {
                    if (WARNING_MODE) {
                        printf("Warning @mall_consumption_shopping(): An invalid state is detected while processing Household ID = %d\n", hh_id);
                    }
                    remove_buyer(&buyers_list, 0);
                    break;
                }
                inv_price_cum = 0;
                for (i = 0; i <= ind; i++) {
                    inventory = sellers_list.array[i].inventory;
                    inv_price_cum += sellers_list.array[i].inv_price;
                    if ((inv_price_cum / denominator_temp - select_prob) >= 0) {
                        transaction_size = (int) floor(budget / price);
                        if (transaction_size > inventory){
                            transaction_size = inventory;
                        }
                        /* Update household budget and send out message.*/
                        transaction_volume = transaction_size * price;
                        budget -= transaction_volume;
                        buyers_list.array[0].budget = budget;
                        add_bought_message(hh_id, transaction_volume, transaction_size);
                        /* Send out sales info. */
                        add_sold_message(firm_id, transaction_size);
                        total_sold += transaction_size;
                        total_volume += transaction_volume;
                        /* Update sellers inventory to go */
                        inventory -= transaction_size;
                        if (inventory == 0) {
                            denominator -= sellers_list.array[i].inv_price;
                            remove_seller(&sellers_list, i);
                        }
                        else{
                            sellers_list.array[i].inventory = inventory;
                        }
                        transaction_occured = 1;
                        break;
                    }
                }
                break;
            }
            
            /* Household decides to buy from the current shelf he/she is examining.
             */
            if ((inv_price_cum / denominator - select_prob) >= 0) {
                transaction_size = (int) floor(budget / price);
                if (transaction_size > inventory){
                    transaction_size = inventory;
                }
                /* Update household budget and send out message.*/
                transaction_volume = transaction_size * price;
                budget -= transaction_volume;
                buyers_list.array[0].budget = budget;
                add_bought_message(hh_id, transaction_volume, transaction_size);
                /* Send out sales info. */
                add_sold_message(firm_id, transaction_size);
                total_sold += transaction_size;
                total_volume += transaction_volume;
                /* Update sellers inventory to go */
                inventory -= transaction_size;
                if (inventory == 0) {
                    denominator -= sellers_list.array[ind].inv_price;
                    remove_seller(&sellers_list, ind);
                }
                else{
                    sellers_list.array[ind].inventory = inventory;
                }
                transaction_occured = 1;
            }
            /* Household is eager to buy from a more expensive shelf.
             */
            
        }/* Sellers Loop End */
        if (transaction_occured == 0) {
            if (WARNING_MODE) {
                printf("Warning @mall_consumption_shopping(): Transaction did not take place while processing Household ID = %d\n", hh_id);
                remove_buyer(&buyers_list, 0);
            }
        }
    } while (1);
    
    /* Finish */
    GOODS_TRANSACTIONS.quantity = total_sold;
    if (total_sold > 0) {
        GOODS_TRANSACTIONS.avg_price = total_volume / total_sold;
    }
    
    /* Free seller list */
    free_seller_array(&sellers_list);
    /* Free buyer queues */
    free_buyer_array(&buyers_list);
    return 0; /* Returning zero means the agent is not removed */
}

// * \fn: int mall_consumption_shopping()
// * \brief:
// */
//int mall_consumption_shopping_old()
//{
//    /* Initialize **
//     */
//    
//    int firm_id, hh_id;
//    double price, budget;
//    int quantity, total_sold;
//
//    double denominator;
//    
//    double min_price;
//    int min_price_index;
//    int min_price_is_picked;
//    
//    /* identifiers used to hold weekly transaction summary
//     */
//    
//    int transaction_quantity = 0;
//    double transaction_volume = 0;
//    
//    /* Allocate local buyer queues and seller lists.
//     */
//    seller_array sellers_list;
//    buyer_array buyers_list;
//    
//    /* Initialize */
//    init_seller_array(&sellers_list);
//    init_buyer_array(&buyers_list);
//    
//    denominator = 0;
//    min_price_is_picked = 0;
//    /* Collect supply */
//    START_SELL_MESSAGE_LOOP
//    firm_id = sell_message->id;
//    price = sell_message->price;
//    
//    if ( min_price_is_picked == 0){
//        min_price = price;
//        min_price_is_picked = 1;
//        min_price_index = 0;
//    }
//    
//    denominator += 1 / price;
//    quantity = sell_message->inventory;
//    /* Add to the shelve */
//    add_seller(&sellers_list, firm_id, price, quantity);
//  FINISH_SELL_MESSAGE_LOOP
//    
//    /* Queue the households */
//    START_BUY_MESSAGE_LOOP
//    hh_id = buy_message->id;
//    budget = buy_message->budget;
//    /* Add household to the queue */
//    add_buyer(&buyers_list, hh_id, budget, 0);
//  FINISH_BUY_MESSAGE_LOOP
//    
//    
//    if (sellers_list.size == 0 || buyers_list.size == 0) {
//        /* Free seller list */
//        free_seller_array(&sellers_list);
//        /* Free buyer queues */
//        free_buyer_array(&buyers_list);
//        return 0;
//    }
//    
//    
//    /* Do the matching *
//     * Input assumptions:
//     * sellers are sorted ascendingly by price.
//     * buyers are randomly queued
//     * this is done at message filtering stage.
//     */
//    double select_prob;
//    double firm_select_prob, firm_select_prob_cum;
//    int tmp,i,j;
//    int sold_out = 0;
//    for (i = 0; i < buyers_list.size; i++) {
//        
//        if (sold_out == sellers_list.size) { break; }
//        
//        budget = buyers_list.array[i].budget;
//        if (budget < min_price || budget < 0 || min_price < 0){ continue; }
//        /* Filtering out households with initially insufficient budgets.
//         */
//        
//        
//        select_prob = (double) random_int(0, sellers_list.size) / sellers_list.size;
//        firm_select_prob_cum = 0;
//        j = min_price_index;
//        do {
//            /* Filtering out households those who have spent their budget down below min price. */
//            if (budget < min_price) { break; }
//
//            /* No goods left to buy more. */
//            if (sold_out == sellers_list.size) { break; }
//            
//            quantity = sellers_list.array[j].inventory;
//        
//            if (quantity <= 0) {
//            /* This is the case when goods right after min price goods have already been sold out. */
//                if (j == min_price_index) {
//                    min_price_index = j+1;
//                }
//                j++;
//                continue;
//            }
//            
//            price = sellers_list.array[j].price;
//            if (budget < price) {
//                /* Houshold (select_prob) desires something she/he cannot afford (any more).
//                 Try finding a cheaper product by starting over.
//                 Make sure that an affordable good is targeted.
//                 */
//                tmp = (int)firm_select_prob_cum * 100;
//                select_prob = (double)random_int(0, tmp) / (tmp + 1);
//                firm_select_prob_cum = 0;
//                j = min_price_index;
//                continue;
//            }
//            
//            firm_select_prob = (1 / price) / denominator;
//            firm_select_prob_cum += firm_select_prob;
//            if ((firm_select_prob_cum - select_prob) >= 0){
//                quantity = (int) floor(budget / price);
//                
//                if (quantity >= sellers_list.array[j].inventory) {
//                    quantity = sellers_list.array[j].inventory;
//                    sold_out++;
//                    denominator -= 1/price;
//                    if (j == min_price_index){
//                        min_price_index = j+1;
//                        min_price = sellers_list.array[j+1].price;
//                    }
//                }
//                
//                if (quantity < 0) {
//                    if (WARNING_MODE) {
//                        printf("Warning @mall_consumption_shopping(): Seller = %d, Buyer = %d, Vars: quantity = %d, budget = %f, price = %f, inventory = %d\n", sellers_list.array[j].id,buyers_list.array[i].id, quantity, budget, price, sellers_list.array[j].inventory);
//                    }
//                    quantity = 0;
//                }
//                
//                buyers_list.array[i].recieved_quantity += quantity;
//                sellers_list.array[j].inventory -= quantity;
//                buyers_list.array[i].budget -= quantity * price;
//                budget = buyers_list.array[i].budget;
//                
//                transaction_quantity += quantity;
//                transaction_volume += quantity * price;
//                
//                j = min_price_index;
//                select_prob = (double)random_int(0, sellers_list.size) / sellers_list.size;
//                continue;
//            }
//            j++;
//        } while (1);
//    }
//    
//
//    /* Indeed keeps unsold quantities. */
//    total_sold = 0;
//    quantity = 0;
//    /* Send out revenue information. */
//    for (i =0; i < sellers_list.size; i++) {
//        firm_id = sellers_list.array[i].id;
//        quantity = sellers_list.array[i].inventory;
//        add_sold_message(firm_id, quantity);
//        total_sold += quantity;
//    }
//    quantity = 0;
//    /* Send out goods information. */
//    for (i =0; i < buyers_list.size; i++) {
//        hh_id = buyers_list.array[i].id;
//        budget = buyers_list.array[i].budget;
//        quantity = buyers_list.array[i].recieved_quantity;
//        add_bought_message(hh_id, budget, quantity);
//    }
//    
//    /* Finish */
//    GOODS_TRANSACTIONS.quantity = transaction_quantity;
//    if (transaction_quantity > 0) {
//        GOODS_TRANSACTIONS.avg_price = transaction_volume / transaction_quantity;
//    }
//    
//    /* Free seller list */
//    free_seller_array(&sellers_list);
//    /* Free buyer queues */
//    free_buyer_array(&buyers_list);
//  return 0; /* Returning zero means the agent is not removed */
//}

/*
 * \fn: int mall_consumption_summary()
 * \brief:
 */
int mall_consumption_summary()
{
    double price;
    int quantity;
    
    price = GOODS_TRANSACTIONS.avg_price;
    quantity = GOODS_TRANSACTIONS.quantity;
    
    if (DATA_COLLECTION_MODE) {
        char * filename;
        FILE * file1;
        filename = malloc(100*sizeof(char));
        filename[0]=0;
        strcpy(filename, "./outputs/data/Mall_snapshot.txt");
        
        file1 = fopen(filename,"a");
        fprintf(file1,"%d %d %f\n",IT_NO, quantity, price);
        fclose(file1);
        free(filename);
    }
    
    add_goods_transactions_summary_message(quantity, price);
    
    if (PRINT_DEBUG_MODE) {
        printf("Mall posts weekly transaction summaries. \n");
    }

    
    return 0; /* Returning zero means the agent is not removed */
}