ViewShoppingBasket.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#if __DCL_WINDOWS
#include <windows.h>
#endif
 
#include <dcl/Files.h>
 
#include "EShopServlet.h"
 
__DCL_BEGIN_NAMESPACE
 
#ifdef __DCL_DEBUG
#undef __THIS_FILE__
static const wchar_t __THIS_FILE__[] = L"eshop/ShoppingBasket.cpp";
#endif
 
void EShopServlet::onViewShoppingBasket(
            HttpServletContextEx& ctx,
            const EShopSession& session
            )
{
    Writer& out = ctx.writer();
 
    ListedStringToStringArrayMap& params = ctx.__formMap;
    StringArray& vPID = params[PRODUCT_STR];
    StringArray& vQty = params[L"qty"];
 
    SQLQuery q(session.SQLConn());
    if (!vPID.isEmpty())
    {
        if (vPID.size() == 1 && vQty.isEmpty())
        {
            // 상품목록에서 "장바구니 추가"를 클릭했다.
            int nProductID = 0;
            try
            {
                nProductID = Int32::parse(vPID[0]);
            }
            catch(Exception* e)
            {
                e->destroy();
            }
            q.prepare(L""
                "SELECT PRODUCT_ID "
                "   FROM ES_SHOPPING_BASKET "
                "   WHERE SESSION_ID = :SESSION_ID "
                "       AND PRODUCT_ID = :PRODUCT_ID"
                );
            q.params()[0].setValue(session.sessionID());
            q.params()[1].setValue(nProductID);
            q.execute();
 
            q.fetch();
            if (q.eof())
            {
                q.prepare(L""
                    "INSERT INTO ES_SHOPPING_BASKET "
                    "   VALUES(:SESSION_ID, :PRODUCT_ID, 1)"
                    );
                q.params()[0].setValue(session.sessionID());
                q.params()[1].setValue(nProductID);
                q.execute();
 
//              __DCL_TRACE1(L"insert : %d\n", q.affectedRows());
            }
        }
        else
        {
            // 장바구니 보기에서 "다시계산"을 클릭했다.
            __DCL_ASSERT(vPID.size() == vQty.size());
            q.prepare(L""
                "UPDATE ES_SHOPPING_BASKET "
                "   SET QUANTITY = :QUANTITY "
                "   WHERE SESSION_ID = :SESSION_ID"
                "       AND PRODUCT_ID = :PRODUCT_ID"
                );
            for(int i = 0; i < vPID.size(); i++)
            {
                int nProductID = 0;
                int nQuantity = 0;
                
                try
                {
                    nProductID = Int32::parse(vPID[i]);
                }
                catch(Exception* e)
                {
                    e->destroy();
                }
                try
                {
                    nQuantity = Int32::parse(vQty[i]);
                }
                catch(Exception* e)
                {
                    e->destroy();
                }
                q.params()[0].setValue(nQuantity);
                q.params()[1].setValue(session.sessionID());
                q.params()[2].setValue(nProductID);
 
                q.execute();
            }
 
            q.execute(L""
                "DELETE FROM ES_SHOPPING_BASKET "
                "   WHERE SESSION_ID = \'" + session.sessionID()
                + L"\'       AND QUANTITY = 0 "
                );
        }
    }
 
    TextTemplate tpl = *m_pViewShoppingBasket;
    TextTemplate& row = tpl[L"ROW"];
 
    String strActionHREF = String::format(L"?%ls=%d",
            COMMAND_STR, CM_VIEW_SHOPPING_BASKET);
    tpl.assign(L"ACTION_HREF", strActionHREF);
    tpl.assign(L"PRODUCT_STR", PRODUCT_STR);
 
    String sql = L""
        "SELECT S.PRODUCT_ID, S.QUANTITY, P.PRODUCT_NAME, P.QUALITY, P.PRICE,"
        "       S.QUANTITY, P.PRICE * S.QUANTITY AS AMOUNT, P.IMAGE_FILE_NAME "
        "   FROM ES_SHOPPING_BASKET S \n"
        "       INNER JOIN ES_PRODUCT P "
        "           ON S.PRODUCT_ID = P.PRODUCT_ID \n"
        "   WHERE S.SESSION_ID = \'"
        + session.sessionID() + L'\'';
    __DCL_TRACE1(L"[%ls]\n", sql.data());
    q.execute(sql);
 
    q.fetch();
    if (q.eof())
    {
        tpl.erase(L"ROW");
        tpl.assign(L"TOTAL", L"0");
    }
    else
    {
        int64_t nTotal = 0;
        while(!q.eof())
        {
            int64_t nAmount;
            q.fields().byName(L"AMOUNT").getValue(nAmount);
            nTotal += nAmount;
 
            String strImage = Files::dirname(ctx.path()) + L"image/"
                    + q.fields().byName(L"IMAGE_FILE_NAME").asString();
 
            row.assign(L"PRODUCT_STR", PRODUCT_STR);
            row.assign(q.fields(), L"&nbsp;");
            row.assign(L"IMAGE", strImage);
            tpl.append(L"ROW", row);
            q.fetch();
        }
        tpl.assign(L"TOTAL", String::valueOf(nTotal));
    }
 
    if (session.isGuest())
    {
        tpl.erase(L"ORDER");
        TextTemplate& tplNotLogin = tpl[L"NOT_LOGIN"];
        tpl.assign(L"NOT_LOGIN", tplNotLogin);
    }
    else
    {
        tpl.erase(L"NOT_LOGIN");
        TextTemplate& tplOrder = tpl[L"ORDER"];
        tplOrder.assign(L"USER_NAME", session.userName());
 
        strActionHREF = String::format(L"?%ls=%d",
            COMMAND_STR, CM_ORDER);
        tplOrder.assign(L"ACTION_HREF", strActionHREF);
 
        tpl.assign(L"ORDER", tplOrder);
    }
    out << tpl;
}
 
__DCL_END_NAMESPACE