MessageDetailView.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#ifdef __WINNT__
#include <windows.h>
#endif
 
#include <dcl/Files.h>
#include <dcl/FileInputStream.h>
#include <dcl/URI.h>
 
#include <dcl/DateTime.h>
 
#include "ServletMain.h"
#include "HtmlPage.h"
#include "MessageTree.h"
#include "LinkUtility.h"
 
#include "MessageView.h"
 
#if __DCL_HAVE_THIS_FILE__
#undef __THIS_FILE__
static const char_t __THIS_FILE__[] = __T("fastpage/MessageDetailView.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
inline String __GetLocalFileName(
    const String& strAttachDir,
    const String& strDsID,
    const String& strMessageID,
    const String& strAttachNo
)
{
    return strAttachDir
        + strDsID + L"/"
        + strMessageID + L"-"
        + strAttachNo + L".dat";
}
 
/*
    QUERY_STRING
        ?p=N&m=N,...[&l=N[,G]]
        ?p=N&v=N&m=N&c={good|bad|del}[&l=N[,G]]
        ?p=N&v=N&m=N&a=N[&l=N[,G]]
 
*/
 
IMPLEMENT_CLASSINFO_EX(MessageDetailView, MessageView)
 
MessageDetailView::MessageDetailView(HtmlPage* pPage)
    : MessageView(pPage)
{
    __nParts = 5;
    __nRows = 20;
 
    __nFilter = 0;
    __nSubject = 0;
}
 
void MessageDetailView::init(SQLFields& fields)
    __DCL_THROWS1(Exception*)
{
    MessageView::init(fields);
 
    __mapParams.lookup(L"WRITE", __strWritePage);
    __mapParams.lookup(L"LIST", __strListPage);
    __mapParams.lookup(L"ATTACH_TITLE", __strAttachTitle);
 
    String rValue;
    if (__mapParams.lookup(L"PARTS", rValue) && !rValue.isEmpty()) {
        __nParts = Integer::parse(rValue, 10, __nParts);
        if (__nParts < 5 || __nParts > 20)
            __nParts = 5;
    }
 
    if (__mapParams.lookup(L"ROWS", rValue) && !rValue.isEmpty()) {
        __nRows = Integer::parse(rValue, 10, __nRows);
        if (__nRows <= 0)
            __nRows = 20;
    }
 
    if (__mapParams.lookup(L"FILTER", rValue) && !rValue.isEmpty()) {
        StringArray list;
        rValue.split(L',', list);
        StringArray::Iterator itList = list.begin();
        for(; itList != list.end(); itList++) {
            (*itList).trim();
            if (!(*itList).isEmpty()) {
                if (!(*itList).compareNoCase(L"SELF"))
                    __nFilter |= FILTER_SELF;
                else if (!(*itList).compareNoCase(L"CHILDREN"))
                    __nFilter |= FILTER_CHILDREN;
                else {
                    // invalid value
                    __DCL_TRACE1(L"Warning! Invalid Params: FILTER=%ls\n", rValue.data());
                }
            }
        }
    }
 
    if (__mapParams.lookup(L"MSG", rValue) && !rValue.isEmpty()) {
        __strMsg = rValue.trim(L" ,");
    }
 
    if (__mapParams.lookup(L"SORT", rValue) && !rValue.isEmpty()) {
        if (!rValue.compareNoCase(L"ASC") || !rValue.compareNoCase(L"DESC"))
            __strSort = rValue;
        else {
            __DCL_TRACE1(L"Warning! Invalid Params: SORT=%ls\n", rValue.data());
        }
    }
    else {
        if (__nSequence)
            __strSort = L"DESC";
        else
            __strSort = L"ASC";
    }
 
    if (__mapParams.lookup(L"SUBJECT", rValue) && !rValue.isEmpty()) {
        StringArray list;
        rValue.split(L',', list);
        StringArray::Iterator itList = list.begin();
        for(; itList != list.end(); itList++) {
            (*itList).trim();
            if (!(*itList).isEmpty()) {
                if (!(*itList).compareNoCase(L"PARENT"))
                    __nSubject |= SUBJECT_PARENT;
                else if (!(*itList).compareNoCase(L"PREV"))
                    __nSubject |= SUBJECT_PREV;
                else if (!(*itList).compareNoCase(L"NEXT"))
                    __nSubject |= SUBJECT_NEXT;
                else {
                    // invalid value
                    __DCL_TRACE1(L"Warning! Invalid Params: SUBJECT=%ls\n", rValue.data());
                }
            }
        }
    }
}
 
void MessageDetailView::onPrint(Session& session)
    __DCL_THROWS1(Exception*)
{
#ifdef __DCL_DEBUG
//  showNullMacro(true, true);
#endif
    ListedStringToStringArrayMap& mapQuery = session.__ctx.__queryMap;
    SQLQuery& q = session.__query;
 
    String strTableID = String::valueOf(__nTableID);
    String strDsID = String::valueOf(__nDsID);
    String strUserID = String::valueOf(session.__nUserID);
 
    int nCurrentPart = Integer::parse(getDefault(mapQuery, L"part"), 10, 1);
    int nRows = __nRows;
 
    /*
    strListPage         n[&msg][&...], L"list=" of QUERY_STRING
    strListPageEnc      URLEncode(strListPage)
    strThisPage         n[&msg=n][&rows=n][&...]    part 제외
    strThisEx       strThisPage + [&part=n][&list=strListPageEnc] 
    strThisEnc      URLEncode(strThisPage)
    */
    String strListPage = getDefault(mapQuery, L"list");
    String strListPageEnc;
    String strWritePage = __strWritePage;
    String strDetailPage = __pPage->__strPageID;
    StringBuilder strThisPage = __pPage->__strPageID;
    String strMsg;
    bool bAddParentToList = false;
 
    if (strListPage.isEmpty()) {
        bAddParentToList = __strListPage.contains(L"&msg");
        strListPage = __strListPage;
    }
 
    strListPageEnc = URLEncoder::encode(strListPage);
 
    if (!__strMsg.isEmpty())
        strMsg = __strMsg;
    else
        strMsg = String::join(mapQuery[L"msg"], L',', false);
 
    TextTemplate* pNOTICE = &(*this)[L"NOTICE"];
    TextTemplate* pSTART = &(*this)[L"START"];
    TextTemplate* pREPLY = &(*this)[L"REPLY"];
    TextTemplate& EMPTY = (*this)[L"EMPTY"];
 
    assign(L"IS_GUEST", session.isSysGuest() ? L"true" : L"false");
    assign(L"WRITE", strWritePage);
    assign(L"LIST", strListPage);
    EMPTY.assign(L"LIST", strListPage);
 
    if (strMsg.isEmpty()) {
        assign(L"EMPTY", EMPTY);
        return;
    }
    strThisPage += L"&msg=" + strMsg;
 
    String strWhereEx;
    switch(__nFilter) {
        default :
        case FILTER_SELF :
            strWhereEx = L" AND M.MESSAGE_ID IN (" + strMsg + L")";
            break;
        case FILTER_CHILDREN :
            strWhereEx = L" AND M.PARENT_ID IN (" + strMsg + L")";
            break;
        case FILTER_SELF | FILTER_CHILDREN :
            strWhereEx = L" AND (M.MESSAGE_ID IN (" + strMsg + L") OR M.PARENT_ID IN (L" + strMsg + L"))";
        break;
    }
 
    __DCL_ASSERT(nRows > 0);
 
    TextTemplate* pPART_LINK = atP(L"PART_LINK");
    int nUsingRecord = nRows;
    int nTotalRecord = nUsingRecord;
    int nTotalPart = 1;
    if (nCurrentPart != 1 || pPART_LINK) {
        q.execute(L""
            "SELECT COUNT(*) "
            "\n FROM DCL_MESSAGE_" + strTableID + L" AS M"
            "\n WHERE M.DS_ID = " + strDsID + strWhereEx
        );
        q.fetch();
        nTotalRecord = q.fields()[0].asInteger();
 
        if (nTotalRecord == 0) {
            assign(L"EMPTY", EMPTY);
 
            MessageView::onPrint(session);
            return;
        }
 
        nTotalPart = nTotalRecord / nUsingRecord;
        if (nTotalRecord % nUsingRecord)
            nTotalPart++;
    }
 
    if (nCurrentPart <= 0 || nCurrentPart > nTotalPart)
        nCurrentPart = nTotalPart;
 
    StringBuilder strThisEx = strThisPage;
    if (nCurrentPart > 1)
        strThisEx += L"&part=" + String::valueOf(nCurrentPart);
 
    if (!strListPageEnc.isEmpty())
        strThisEx += L"&list=" + strListPageEnc;
 
    String strThisEnc = URLEncoder::encode(strThisPage);
 
    assign(L"_LIST", strListPageEnc);
    assign(L"_THIS", strThisEnc);
 
    StringBuilder strFieldEx;
    StringBuilder strJoinEx;
 
    if (__nSubject & SUBJECT_PARENT) {
        strJoinEx += L"\n  LEFT OUTER JOIN DCL_MESSAGE_" + strTableID + L""
            " AS P\n    ON (M.DS_ID = P.DS_ID AND M.PARENT_ID = P.MESSAGE_ID)";
 
        strFieldEx += L", P.SUBJECT AS P_SUBJECT";
    }
    if (__nSubject & SUBJECT_PREV) {
 
    }
    if (__nSubject & SUBJECT_NEXT) {
 
    }
 
    int nOffset = (nCurrentPart - 1) * nUsingRecord;
 
    String strSQL = L""
        "SELECT M.MESSAGE_ID, M.PREV_ID, M.NEXT_ID, M.PARENT_ID, M.REPLY_ID,"
        "\n  M.NCHILD, M.TYPE AS BODY_TYPE,"
        "\n  M.USER_ID, M.SUBJECT, M.BODY_HTML, M.UPDATE_TIME,"
        "\n  M.NREAD, M.NAGREE, M.NDISAGREE, (M.NAGREE + M.NDISAGREE) AS NVOTE,"
        "\n  (M.NAGREE - M.NDISAGREE) AS NDECISION, M.VOTE_END,"
        "\n  U.USER_NAME AS WRITER, R.USER_ID AS R_USER_ID"
            + strFieldEx.toString() + L""
        "\n FROM DCL_MESSAGE_" + strTableID + L" AS M"
        "\n  INNER JOIN DCLWC_USER U ON (M.USER_ID = U.USER_ID)"
        "\n  LEFT OUTER JOIN DCL_MESSAGE_R_" + strTableID + L" AS R"
        "\n   ON (M.DS_ID = R.DS_ID AND M.MESSAGE_ID = R.MESSAGE_ID"
                " AND R.USER_ID = " + strUserID + L")"
            + strJoinEx.toString() + L""
        "\n WHERE M.DS_ID = " + strDsID + strWhereEx + L""
        "\n ORDER BY M.START_ID " + __strSort + L", M.REPLY_ID ASC"
        "\n LIMIT " + String::valueOf(nUsingRecord) + L""
        "\n  OFFSET " + String::valueOf(nOffset);
 
    __DCL_TRACE1(L"\n%ls\n", strSQL.data());
 
    q.execute(strSQL);
    q.fetch();
    if (q.eof()) {
        assign(L"EMPTY", EMPTY);
    }
    else {
        UpdateLink ul(atP(L"UPDATE_LINK"), strDetailPage, strWritePage, strThisEnc, strListPageEnc);
        SiblingLink sl(atP(L"SIBLING_LINK"), strDetailPage, strListPageEnc);
 
        MessageTree mt(__nReplyDepth);
        SQLQuery qAttach(q.connection());
        SQLQuery qInsert(q.connection());
        SQLQuery qUpdate(q.connection());
        qAttach.prepare(L""
            "SELECT NO, NDOWNLOAD, FILENAME, TYPE, ICON, CEILING(SIZE / 1024) AS KSIZE"
            "\n FROM DCL_MESSAGE_A_" + strTableID + L""
            "\n WHERE DS_ID = " + strDsID + L""
            "\n  AND MESSAGE_ID = :MESSAGE_ID"
            "\n ORDER BY NO ASC"
        );
        qInsert.prepare(L""
            "INSERT INTO DCL_MESSAGE_R_" + strTableID + L""
            "\n  (DS_ID, MESSAGE_ID, USER_ID, NVOTE, UPDATE_TIME)"
            "\n VALUES (L" + strDsID + L", :MESSAGE_ID, L" + strUserID
                + L", 0, CURRENT_TIMESTAMP)"
        );
        qUpdate.prepare(L""
            "UPDATE DCL_MESSAGE_" + strTableID + L""
            "\n SET NREAD = NREAD + 1"
            "\n WHERE DS_ID = " + strDsID + L""
            "\n  AND MESSAGE_ID = :MESSAGE_ID"
        );
 
        SQLFields& fields = q.fields();
        TextTemplate* pDest = NULL;
        while(!q.eof()) {
            int nMessageID = fields.byName(L"MESSAGE_ID").asInteger();
            int64_t nReplyID = fields.byName(L"REPLY_ID").asInt64();
            int nUserID = fields.byName(L"USER_ID").asInteger();
            String strMessageID = String::valueOf(nMessageID);
 
            MessageTree::Position rPos;
            mt.getPosition(nReplyID, rPos);
 
            if (pDest)
                pDest->reset();
 
            if (rPos.nDepthIndex == 0) {
                if (IS_NOTICE_ID(nMessageID))
                    pDest = pNOTICE;
                else
                    pDest = pSTART;
            }
            else
                pDest = pREPLY;
 
            pDest->assign(L"VNO", VNO());
            if (bAddParentToList) {
                StringBuilder str = strListPage + L"=";
                str += fields.byName(L"PARENT_ID").asString();
                strListPageEnc = URLEncoder::encode(str);
 
                pDest->assign(L"LIST", str);
                sl.assign(pDest, fields, strListPageEnc);
            }
            else {
                pDest->assign(L"LIST", strListPage);
                sl.assign(pDest, fields);
            }
            ul.assign(pDest, fields, session, strMessageID, strListPage, mt, rPos);
 
            // U.WRITER, SUBJECT, BODY_HTML, UPDATE_TIME, NREAD, NVOTE
            pDest->assign(fields, L"&nbsp");
            pDest->assign(L"UPDATE_DATE", fields.byName(L"UPDATE_TIME").asDate().toString());
 
            if (__nSubject & SUBJECT_PARENT) {
                String str;
                SQLField& field = fields.byName(L"P_SUBJECT");
                if (!field.isNull())
                    str = field.asString();
                if (str.isEmpty())
                    str = L"제목없음";
                append(L"P_SUBJECT", str);
            }
 
            int nBodyType = fields.byName(L"BODY_TYPE").asInteger();
            if (nBodyType < 0) {
                StringBuilder strBodyHtml = L"<span style=\"color:red\">(L";
                if (nBodyType == -1)
                    strBodyHtml += L"글쓴이가 글을 삭제했습니다";
                else
                    strBodyHtml += L"관리자에 의해 삭제되었습니다.";
                strBodyHtml += L")</span>";
 
                pDest->assign(L"SUBJECT", L"삭제됨");
                pDest->assign(L"BODY_HTML", strBodyHtml);
            }
            else {
                if (fields.byName(L"SUBJECT").asString().isEmpty())
                    pDest->assign(L"SUBJECT", L"제목없음");
            }
 
            TextTemplate* pATTACH = pDest->atP(L"ATTACH");
            TextTemplate* pIMAGE = pDest->atP(L"IMAGE");
            if (pATTACH || pIMAGE) {
                pDest->assign(L"ATTACH_TITLE", __strAttachTitle);
 
                qAttach.params()[0].setValue(nMessageID);
                qAttach.execute();
                qAttach.fetch();
                bool bFirst = true;
                while (!qAttach.eof()) {
                    String strType = qAttach.fields().byName(L"TYPE").asString();
                    if (pATTACH) {
                        pATTACH->assign(L"SELF", SELF());
                        pATTACH->assign(L"MESSAGE_ID", strMessageID);
                        pATTACH->assign(qAttach.fields(), String());
                        if (bFirst)
                            pDest->assign(L"ATTACH", *pATTACH);
                        else
                            pDest->append(L"ATTACH", *pATTACH);
                    }
                    if (pIMAGE && strType.compareNoCase(L"image", 5) == 0) {
                        pIMAGE->assign(L"SELF", SELF());
                        pIMAGE->assign(L"MESSAGE_ID", strMessageID);
                        pIMAGE->assign(qAttach.fields(), String());
                        if (bFirst)
                            pDest->assign(L"IMAGE", *pIMAGE);
                        else
                            pDest->append(L"IMAGE", *pIMAGE);
                    }
                    bFirst = false;
                    qAttach.fetch();
                }
            }
 
            if (!session.isSysGuest() && session.__nUserID != nUserID
                && fields.byName(L"R_USER_ID").isNull()
            ) {
                qInsert.params()[0].setValue(nMessageID);
                qInsert.execute();
                qUpdate.params()[0].setValue(nMessageID);
                qUpdate.execute();
 
                pDest->assign(
                    L"NREAD",
                    String::valueOf(fields.byName(L"NREAD").asInteger() + 1)
                );
            }
            append(L"EMPTY", *pDest);
            q.fetch();
        } // while(!q.eof())
    }
 
    if (pPART_LINK && nTotalPart > 1) {
        PartLink pl(pPART_LINK, strThisPage, strListPageEnc);
        pl.assign(this, nTotalPart, nCurrentPart, __nParts);
    }
 
    MessageView::onPrint(session);
}
 
void MessageDetailView::onGet(Session& session)
    __DCL_THROWS1(Exception*)
{
    HttpServletContextEx& ctx = session.__ctx;
    SQLQuery& q = session.__query;
 
    ListedStringToStringArrayMap& mapQuery = ctx.__queryMap;
    ListedStringToStringArrayMap::ConstIterator itM = mapQuery.find(L"msg");
    if (itM == mapQuery.end() || (*itM).value.isEmpty()) {
        session.__ctx.setStatusCode(HTTP_STATUS_NOT_FOUND);
        return;
    }
 
    String strMessageID = (*itM).value[0];
    String strTableID = String::valueOf(__nTableID);
    String strDsID = String::valueOf(__nDsID);
 
    ListedStringToStringArrayMap::ConstIterator itA = mapQuery.find(L"attach");
    if (itA != mapQuery.end() && (*itA).value.size() > 0) {
        // attachment
        q.execute(L""
            "SELECT FILENAME, TYPE"
            "\n FROM DCL_MESSAGE_A_" + strTableID + L""
            "\n WHERE DS_ID = " + strDsID + L""
            "\n  AND MESSAGE_ID = " + strMessageID + L""
            "\n  AND NO = " + (*itA).value[0]
        );
        q.fetch();
        if (!q.eof()) {
            String strFileName = __pPage->site()->strAttachmentDir
                + String::valueOf(__nDsID) + L"/"
                + (*itM).value[0] + L"-"
                + (*itA).value[0] + L".dat";
 
            if (Files::exists(strFileName)) {
                size_t nLen = (size_t) Files::size(strFileName);
                String strName = q.fields()[0].asString();
                String strType = q.fields()[1].asString();
 
                FileInputStream in(strFileName);
 
                ctx.setContentType(strType);
                ctx.addHeader(
                    HttpHeader(L"Content-Length", String::valueOf(nLen))
                    );
                ctx.addHeader(
                    HttpHeader(
                        L"Content-Disposition",
                        L"inline; filename=\"" + strName + L"\""
                    )
                );
 
                char aBuf[4096];
                size_t n;
                while((n = in.read(aBuf, 4096)) > 0) {
                    ctx.write(aBuf, n);
                }
 
                return;
            }
        }
    }
    else
    {
        if (!session.isSysGuest())
        {
#undef      CM_UNKNOWN
#undef      CM_GOOD
#undef      CM_BAD
#undef      CM_ERASE
 
#define     CM_UNKNOWN      0
#define     CM_GOOD         1
#define     CM_BAD          -1
#define     CM_ERASE        2
 
            int nCM = CM_UNKNOWN;
            ListedStringToStringArrayMap::ConstIterator itC = mapQuery.find(L"c");
            if (itC != mapQuery.end() && (*itC).value.size() > 0) {
                String strCM = (*itC).value[0];
                if (strCM == L"good")
                    nCM = CM_GOOD;
                else if (strCM == L"bad")
                    nCM = CM_BAD;
                else if (strCM == L"erase")
                    nCM = CM_ERASE;
            }
 
            if (nCM == CM_GOOD || nCM == CM_BAD) {
                String strUserID = String::valueOf(session.__nUserID);
                q.execute(L""
                    "SELECT NVOTE FROM DCL_MESSAGE_R_" + strTableID + L""
                    "\n WHERE DS_ID = " + strDsID + L""
                    "\n  AND MESSAGE_ID = " + strMessageID + L""
                    "\n  AND USER_ID = " + strUserID
                );
                q.fetch();
                if (!q.eof()) {
                    if (q.fields()[0].asInteger() == 0) {
                        q.execute(L""
                            "UPDATE DCL_MESSAGE_R_" + strTableID + L""
                            "\n SET VOTE = " + String::valueOf(nCM) + L""
                            "\n WHERE DS_ID = " + strDsID + L""
                            "\n  AND MESSAGE_ID = " + strMessageID + L""
                            "\n  AND USER_ID = " + strUserID
                        );
 
                        if (nCM == CM_GOOD)
                            q.execute(L""
                                "UPDATE DCL_MESSAGE_" + strTableID + L""
                                "\n SET NVOTE = NVOTE + 1 "
                                "\n WHERE DS_ID = " + strDsID + L""
                                "\n  AND MESSAGE_ID = " + strMessageID
                            );
                        else
                            q.execute(L""
                                "UPDATE DCL_MESSAGE_" + strTableID + L""
                                "\n SET NBAD = NBAD + 1 "
                                "\n WHERE DS_ID = " + strDsID + L""
                                "\n  AND MESSAGE_ID = " + strMessageID
                            );
                    }
                }
            }
            else if (nCM == CM_ERASE) {
                q.execute(L""
                    "SELECT M.USER_ID, A.NO"
                    "\n FROM DCL_MESSAGE_" + strTableID + L" AS M"
                    "\n  LEFT OUTER JOIN DCL_MESSAGE_A_" + strTableID + L" AS A"
                    "\n   ON (M.DS_ID = A.DS_ID AND M.MESSAGE_ID = A.MESSAGE_ID)"
                    "\n WHERE M.DS_ID = " + strDsID + L""
                    "\n  AND M.MESSAGE_ID = " + strMessageID + L""
                    "\n  AND M.SUBJECT IS NOT NULL"
                    "\n ORDER BY A.NO"
                );
                q.fetch();
                if (!q.eof()) {
                    int nUserID = q.fields()[0].asInteger();
                    if (session.isSysAdmin() || session.__nUserID == nUserID) {
                        if (!q.fields()[1].isNull()) {
                            // 첨부파일이 있다.
                            do {
                                String strFileName = __GetLocalFileName(
                                    __pPage->site()->strAttachmentDir,
                                    strDsID,
                                    strMessageID,
                                    q.fields()[1].asString()
                                );
                                if (Files::exists(strFileName))
                                    Files::unlink(strFileName);
 
                                q.fetch();
                            } while (!q.eof());
 
                            q.execute(L""
                                "DELETE FROM DCL_MESSAGE_A_" + strTableID + L""
                                "\n WHERE DS_ID = " + strDsID + L""
                                "\n  AND MESSAGE_ID = " + strMessageID
                            );
                        }
 
                        String strBodyType;
                        if (session.__nUserID == nUserID)
                            strBodyType = L"-1";
                        else
                            strBodyType = L"-2";
 
                        q.execute(L""
                            "UPDATE DCL_MESSAGE_" + strTableID + L""
                            "\n SET TYPE = " + strBodyType + L""
                            "\n  ,SUBJECT = NULL, BODY_ORG = NULL, BODY_PLAIN = NULL"
                            "\n  ,BODY_HTML = :BODY_HTML, UPDATE_TIME = CURRENT_TIMESTAMP"
                            "\n WHERE DS_ID = " + strDsID + L""
                            "\n  AND MESSAGE_ID = " + strMessageID
                        );
                    }
 
                    String strListPage = getDefault(mapQuery, L"l");
                    if (strListPage.isEmpty())
                        strListPage = __strListPage;
                    String strRefresh = L"?p=" + strListPage;
                    __pPage->refresh(session, strRefresh);
                    return;
                }
            }
        } // if (!session.isSysGuest())
 
        __pPage->print(session);
        return;
    }
 
    session.__ctx.setStatusCode(HTTP_STATUS_NOT_FOUND);
}
 
__DCL_END_NAMESPACE