MessageListView.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#ifdef __WINNT__
#include <windows.h>
#endif
 
#include <dcl/Numeric.h>
#include <dcl/Files.h>
//#include <dcl/Collection.h>
#include <dcl/URI.h>
 
#include <dcl/DateTime.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/MessageListView.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
IMPLEMENT_CLASSINFO_EX(MessageListView, MessageView)
 
MessageListView::MessageListView(HtmlPage* pPage)
    : MessageView(pPage)
{
    __bOverride = false;
    __bNoAsc = false;
    __nParts = 5;
    __nRows = 20;
    __nCols = 4;
    __nGroup = 1;
    __nSubjectShort = 0;
    __nBodyLength = -1;
    __nRecentHour = 24;
    __nThumbnail = TN_NONE;
    __nFilter = 0;
    __nType = TYPE_LIST;
}
 
void MessageListView::init(SQLFields& fields)
    __DCL_THROWS1(Exception*)
{
    MessageView::init(fields);
 
    __mapParams.lookup(L"DETAIL", __strDetailPage);
    __mapParams.lookup(L"WRITE", __strWritePage);
    __mapParams.lookup(L"LIST", __strListPage);
 
    String rValue;
    if (__mapParams.lookup(L"OVERRIDE", rValue) && 
        !rValue.compareNoCase(L"YES"))
            __bOverride = true;
 
    if (__mapParams.lookup(L"NO", rValue) && !rValue.isEmpty()) {
        if (!rValue.compareNoCase(L"ASC"))
            __bNoAsc = true;
    }
 
    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"COLS", rValue) && !rValue.isEmpty()) {
        __nCols = Integer::parse(rValue, 10, __nCols);
        if (!(2 <= __nCols && __nCols <= 10)) {
            __DCL_TRACE1(L"Warning! Invalid Params: COLS=%ls\n", rValue.data());
            __nCols = 4;
        }
    }
 
    if (__mapParams.lookup(L"GROUP", rValue) && !rValue.isEmpty()) {
        __nGroup = Integer::parse(rValue, 10, __nGroup);
        if (!(1 <= __nGroup && __nGroup <= 10)) {
            __DCL_TRACE1(L"Warning! Invalid Params: GROUP=%ls\n", rValue.data());
            __nGroup = 1;
        }
    }
 
    if (__mapParams.lookup(L"SUBJECT_SHORT", rValue) && !rValue.isEmpty()) {
        __nSubjectShort = Integer::parse(rValue, 10, 0);
        if (__nSubjectShort < 0) {
            __DCL_TRACE1(L"Warning! Invalid Params: SUBJECT_SHORT=%ls\n", rValue.data());
            __nSubjectShort = 0;
        }
    }
 
    if (__mapParams.lookup(L"BODY_LENGTH", rValue) && !rValue.isEmpty()) {
        __nBodyLength = Integer::parse(rValue, 10, 0);
    }
 
    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"NOTICE"))
                    __nFilter |= FILTER_NOTICE;
                else if (!(*itList).compareNoCase(L"START"))
                    __nFilter |= FILTER_START;
                else if (!(*itList).compareNoCase(L"REPLY"))
                    __nFilter |= FILTER_REPLY;
                else if (!(*itList).compareNoCase(L"SELF"))
                    __nFilter |= FILTER_SELF;
                else if (!(*itList).compareNoCase(L"CHILDREN"))
                    __nFilter |= FILTER_CHILDREN;
                else if (!(*itList).compareNoCase(L"DEPTH_1"))
                    __nFilter |= FILTER_DEPTH_1;
                else {
                    // invalid value
                    __DCL_TRACE1(L"Warning! Invalid Params: FILTER=%ls\n", rValue.data());
                }
            }
        }
        if ((__nFilter & 0x000f) && (__nFilter & 0x00f0) && (__nFilter & 0x0f00)) {
            // NOTICE, START, REPLY 와 SELF, CHILDREN은 함께 사용할 수 없다.
            __DCL_TRACE1(L"Warning! Invalid Params: FILTER=%ls\n", rValue.data());
            __nFilter &= 0x000f;
        }
    }
 
    if (__nFilter & (FILTER_SELF | FILTER_CHILDREN)
        && __mapParams.lookup(L"MSG", rValue) && !rValue.isEmpty()
    ) {
        __strMsg = rValue.trim(L", ");;
    }
 
    if (__mapParams.lookup(L"RECENT", rValue)) {
        rValue = rValue.trim();
        if (!rValue.isEmpty()) {
            int nHour = Integer::parse(rValue, 10, 0);
            if (0 < nHour && nHour < 100)
                __nRecentHour = nHour;
            else {
                __DCL_TRACE1(L"Warning! Invalid Params: RECENT=%ls\n", rValue.data());
            }
        }
    }
 
    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"TYPE", rValue) && !rValue.isEmpty()) {
        if (!rValue.compareNoCase(L"GRID"))
            __nType = TYPE_GRID;
        else if (!rValue.compareNoCase(L"LIST"))
            __nType = TYPE_LIST;
        else if (!rValue.compareNoCase(L"ATTACH"))
            __nType = TYPE_ATTACH;
        else {
            __DCL_TRACE1(L"Warning! Invalid Params: TYPE=%ls\n", rValue.data());
        }
    }
 
    if (__mapParams.lookup(L"THUMBNAIL", rValue) && !rValue.isEmpty()) {
        if (!rValue.compareNoCase(L"CHILD"))
            __nThumbnail = TN_CHILD;
        else if (!rValue.compareNoCase(L"SELF"))
            __nThumbnail = TN_SELF;
        else {
            __DCL_TRACE1(L"Warning! Invalid Params: THUMBNAIL=%ls\n", rValue.data());
        }
    }
}
 
void MessageListView::onPrint(Session& session)
    __DCL_THROWS1(Exception*)
{
    DateTime dtStartA = DateTime::getCurrentLocalTime();
#ifdef __DCL_DEBUG
//  showNullMacro(true, true);
#endif
    SQLQuery& q = session.__query;
    ListedStringToStringArrayMap& mapQuery = session.__ctx.__queryMap;
 
    String strTableID = String::valueOf(__nTableID);
    String strDsID = String::valueOf(__nDsID);
 
    int nCurrentPart = Integer::parse(getDefault(mapQuery, L"part"), 10, 1);
    int nRows = __nRows;
    int nCols = __nCols;
    int nFilter = __nFilter;
 
    /*
    strListPage     n[&msg][&...], L"list=" of QUERY_STRING
    strListPageEnc  URLEncode(strListPage)
    strThisPage     n[&msg=n][&rows=n][&cols=n][&...] part 제외
    strThisPageEx       strThisPage + [&part=n][&list=strListPageEnc]
    strThisPageEnc  URLEncode(strThisPageEx)
    */
    String strDetailPage = __strDetailPage;
    String strWritePage = __strWritePage;
    String strListPage = getDefault(mapQuery, L"list");
    String strListPageEnc;
    StringBuilder strThisPage = __pPage->__strPageID;
    String strThisPageEnc;
    String strMsg = getDefault(mapQuery, L"msg");
 
    if (strListPage.isEmpty())
        strListPage = __strListPage;
 
    strListPageEnc = URLEncoder::encode(strListPage);
 
    if (!strMsg.isEmpty()) {
        assign(L"MSG", strMsg);
        strThisPage += L"&msg=" + strMsg;
    }
 
    if (!__strMsg.isEmpty())
        strMsg = __strMsg;
 
    if (!strMsg.isEmpty()) {
        strMsg = strMsg.trim().trim(L",");
 
        StringArray list;
        if (strMsg.split(L',', list) > 0) {
            if (*(list.begin()) == L"-1") {
                nFilter = FILTER_DEPTH_1;
                strMsg.clear();
            }
        }
    }
 
    if (__bOverride) {
        String str = getDefault(mapQuery, L"rows");
        if (!str.isEmpty()) {
            nRows = Integer::parse(str, 10, nRows);
            if (nRows <= 0)
                nRows = __nRows;
 
            strThisPage += L"&rows=" + String::valueOf(nRows);
        }
 
        if (__nType == TYPE_GRID) {
            str = getDefault(mapQuery, L"cols");
            if (!str.isEmpty()) {
                nCols = Integer::parse(str, 10, nCols);
                if (!(2 <= __nCols && __nCols <= 10))
                    nCols = __nCols;
 
                strThisPage += L"&cols=" + String::valueOf(nCols);
            }
        }
    }
 
    TextTemplate* pROW = NULL;
    TextTemplate* pNOTICE = NULL;
    TextTemplate* pSTART = NULL;
    TextTemplate* pREPLY = NULL;
    TextTemplate* pEMPTY = NULL;
    TextTemplate* pPADDING = NULL;
 
    // 레코드를 위한 매크로 이름
    // 서브템플릿 EMPTY, PADDING은 반드시 포함되어 있어야 한다. 
    String strRecName;
    String strRowName = L"EMPTY";
 
    pEMPTY = &((*this)[L"EMPTY"]);
    if (__nType == TYPE_GRID) {
        pROW = &((*this)[L"ROW"]);
        pNOTICE = &((*pROW)[L"NOTICE"]);
        pSTART = &((*pROW)[L"START"]);
        pREPLY = &((*pROW)[L"REPLY"]);
        pPADDING = &((*pROW)[L"PADDING"]);
 
        strRecName = L"PADDING";
        pROW->erase(L"NOTICE");
        pROW->erase(L"START");
        pROW->erase(L"REPLY");
        erase(L"ROW");
    }
    else {
        pNOTICE = &((*this)[L"NOTICE"]);
        pSTART = &((*this)[L"START"]);
        pREPLY = &((*this)[L"REPLY"]);
 
        strRecName = L"EMPTY";
        erase(L"NOTICE");
        erase(L"START");
        erase(L"REPLY");
    }
 
    assign(L"IS_GUEST", session.isSysGuest() ? L"true" : L"false");
    assign(L"DETAIL", strDetailPage);
    assign(L"WRITE", strWritePage);
    assign(L"LIST", strListPage);
    assign(L"_THIS", URLEncoder::encode(strThisPage));
 
    if (nFilter & (FILTER_SELF | FILTER_CHILDREN)) {
        // FILTER가 SELF, CHILDREN이면 "msg"를 사용한다.
        if (strMsg.isEmpty()) {
            assign(strRowName, *pEMPTY);
            MessageView::onPrint(session);
            return;
        }
    }
 
    String strWhereEx;
    switch(nFilter) {
        default :
        case FILTER_NOTICE | FILTER_START | FILTER_REPLY :
            break;
        case FILTER_NOTICE :
            strWhereEx = L" AND M.MESSAGE_ID = M.START_ID AND M.MESSAGE_ID > 2000000000";
            break;
        case FILTER_START :
            strWhereEx = L" AND M.MESSAGE_ID = M.START_ID AND M.MESSAGE_ID <= 2000000000";
            break;
        case FILTER_NOTICE | FILTER_START :
            strWhereEx = L" AND M.MESSAGE_ID = M.START_ID";
            break;
        case FILTER_START | FILTER_REPLY :
            strWhereEx = L" AND M.MESSAGE_ID <= 2000000000";
            break;
        case FILTER_SELF :
            strWhereEx = L" AND M.MESSAGE_ID IN (L" + strMsg + L")";
            break;
        case FILTER_CHILDREN :
            strWhereEx = L" AND M.PARENT_ID IN (L" + strMsg + L")";
            break;
        case FILTER_SELF | FILTER_CHILDREN :
            strWhereEx = L" AND ((M.MESSAGE_ID IN (L" + strMsg + L") OR M.PARENT_ID IN (L" + strMsg + L")))";
            break;
        case FILTER_DEPTH_1 :
            strWhereEx = L" AND (M.PARENT_ID = M.START_ID)";
            break;
    }
 
    __DCL_ASSERT(nRows > 0 && nCols > 0);
 
    TextTemplate* pPART_LINK = atP(L"PART_LINK");
    int nUsingRecord = nRows;
    if (__nType == TYPE_GRID)
        nUsingRecord *= nCols;
 
    int nTotalRecord = nUsingRecord;
    int nTotalPart = 1;
 
    // nNo를 표시하기 위해서 조건에 만족하는 전체레코드의 개수가 항상 필요하다.
    // 2006.06.26
//  if (nCurrentPart != 1 || pPART_LINK)
//  {
        q.execute(L""
            "SELECT COUNT(*) "
            "   FROM DCL_MESSAGE_" + strTableID + L" AS M"
            "   WHERE M.DS_ID = " + strDsID + strWhereEx
        );
        q.fetch();
        nTotalRecord = q.fields()[0].asInteger();
 
        if (nTotalRecord == 0) {
            assign(strRowName, *pEMPTY);
 
            MessageView::onPrint(session);
            return;
        }
 
        nTotalPart = nTotalRecord / nUsingRecord;
        if (nTotalRecord % nUsingRecord)
            nTotalPart++;
//  }
    if (nCurrentPart <= 0 || nCurrentPart > nTotalPart)
        nCurrentPart = nTotalPart;
 
    StringBuilder strThisPageEx = strThisPage;
    if (nCurrentPart > 1)
        strThisPageEx += L"&part=" + String::valueOf(nCurrentPart);
 
    if (!strListPageEnc.isEmpty())
        strThisPageEx += L"&list=" + strListPageEnc;
 
    strThisPageEnc = URLEncoder::encode(strThisPageEx);
 
    assign(L"_LIST", strListPageEnc);
    assign(L"_THIS", strThisPageEnc);
    if (!session.isSysGuest()) {
        TextTemplate& _ADD = (*this)[L"_ADD"];
        _ADD.assign(L"WRITE", strWritePage);
        _ADD.assign(L"PARENT_ID", L"0");
        _ADD.assign(L"_LIST", strListPageEnc);
        _ADD.assign(L"_THIS", strThisPageEnc);
        assign(L"_ADD", _ADD);
    }
 
    StringBuilder strFieldEx;
    switch(__nThumbnail) {
        case TN_NONE :
            break;
        case TN_CHILD :
            strFieldEx = L", M.CHILD_ID AS TN_ID";
            break;
        case TN_SELF :
            strFieldEx = L", M.MESSAGE_ID AS TN_ID";
            break;
        default :
            __DCL_ASSERT(false);
    }
 
    if (__nBodyLength >= 0)
        strFieldEx += L", M.BODY_PLAIN";
 
    String strFrom;
    StringBuilder strOrderBy;
    if (nFilter == FILTER_DEPTH_1)
        strOrderBy = L"M.MESSAGE_ID DESC";  //"M.UPDATE_TIME DESC";
    else
        strOrderBy = L"M.START_ID " + __strSort + L", M.REPLY_ID ASC";
 
    if (__nType == TYPE_ATTACH) {
        strFrom = L"DCL_MESSAGE_A_" + strTableID + L" AS A"
            "\n  INNER JOIN DCL_MESSAGE_" + strTableID + L" AS M"
            " ON (A.DS_ID = M.DS_ID AND A.MESSAGE_ID = M.MESSAGE_ID)";
        strFieldEx += L", A.NO, A.FILENAME, A.NDOWNLOAD, A.ICON, CEILING(A.SIZE / 1024) AS KSIZE";
        strOrderBy += L", A.NO ASC";
    }
    else {
        strFrom = L"DCL_MESSAGE_" + strTableID + L" AS M";
    }
 
    int nOffset = (nCurrentPart - 1) * nUsingRecord;
 
    String strSQL = L""
        "SELECT M.DS_ID, M.MESSAGE_ID, M.REPLY_ID, M.NCHILD,"
        "\n  M.NREAD, M.NAGREE, M.NDISAGREE, (M.NAGREE + M.NDISAGREE) AS NVOTE,"
        "\n  (M.NAGREE - M.NDISAGREE) AS NDECISION, M.VOTE_END, M.TYPE AS BODY_TYPE,"
        "\n  M.SUBJECT, M.UPDATE_TIME, M.USER_ID, U.USER_NAME AS WRITER"
            + strFieldEx.toString() + L""
        "\n FROM " + strFrom.toString() + L""
        "\n  INNER JOIN DCLWC_USER AS U ON (M.USER_ID = U.USER_ID)" + L""
        "\n WHERE M.DS_ID = " + strDsID + strWhereEx + L""
        "\n ORDER BY " + strOrderBy.toString() + L""
        "\n LIMIT " + String::valueOf(nUsingRecord) + L""
        "\n  OFFSET " + String::valueOf(nOffset);
 
    __DCL_TRACE1(L"\n%ls\n", strSQL.data());
    DateTime dtStartQ = DateTime::getCurrentLocalTime();
 
    q.execute(strSQL);
    __DCL_TRACE1(L"LIST_SQL: %ls\n", (DateTime::getCurrentLocalTime() - dtStartQ).toString().data());
    q.fetch();
    if (q.eof()) {
        assign(strRowName, *pEMPTY);
    }
    else {
        UpdateLink ul(atP(L"UPDATE_LINK"), strDetailPage, strWritePage, strThisPageEnc, strListPageEnc);
        RecentIcon ri(atP(L"RECENT"), __nRecentHour);
        RowGroup rg(atP(L"RGROUP"), __nGroup);
 
        MessageTree mt(__nReplyDepth);
        int nNo = 1;
        if (!__bNoAsc)
            nNo = nTotalRecord - ((nCurrentPart - 1) * nUsingRecord);
        int nCol = 1;   // for GRID
        int nRow = 1;
        do {
            SQLFields& fields = q.fields();
 
            int nMessageID = fields.byName(L"MESSAGE_ID").asInteger();
            int64_t nReplyID = fields.byName(L"REPLY_ID").asInt64();
            String strMessageID = String::valueOf(nMessageID);
 
            MessageTree::Position rPos;
            mt.getPosition(nReplyID, rPos);
 
            TextTemplate* pDest = NULL;;
            if (rPos.nDepthIndex > 0) {
                pDest = pREPLY;
 
                StringBuilder strIndent;
                for(int i = 0; i < rPos.nDepthIndex; i++)
                    strIndent += L"&nbsp; ";
                pDest->assign(L"INDENT", strIndent);
            }
            else {
                if (IS_NOTICE_ID(nMessageID))
                    pDest = pNOTICE;
                else
                    pDest = pSTART;
            }
 
            ul.assign(pDest, fields, session, strMessageID, strListPage, mt, rPos);
            rg.assign(pDest, nRow++);
 
            pDest->assign(fields, L"&nbsp;");
            pDest->assign(L"NO", String::valueOf(nNo));
            if (__bNoAsc)
                nNo++;
            else
                nNo--;
            pDest->assign(L"WRITE", strWritePage);
            pDest->assign(L"DETAIL", strDetailPage);
            pDest->assign(L"_THIS", strThisPageEnc);
            pDest->assign(L"_LIST", strListPageEnc);
 
            if (__nThumbnail) {
                StringBuilder strThumbnail = Files::dirname(session.__ctx.path());
                SQLField& fTN_ID = fields.byName(L"TN_ID");
                if (fTN_ID.asInteger() == 0)
                    strThumbnail += L"images/default_tn.gif";
                else
                    strThumbnail += L"thumbnail/" + strDsID + L"/"
                        + fTN_ID.asString() + L"-1.dat.jpg";
 
                pDest->assign(L"THUMBNAIL", strThumbnail);
            }
 
            String strSubject;
            int nBodyType = fields.byName(L"BODY_TYPE").asInteger();
            if (nBodyType < 0)
                strSubject = L"삭제됨";
            else {
                strSubject = fields.byName(L"SUBJECT").asString();
                if (strSubject.isEmpty())
                    strSubject = L"제목없음";
            }
            pDest->assign(L"SUBJECT", strSubject);
            if (__nSubjectShort > 0) {
                String strSubjectShort;
                if ((ssize_t) strSubject.length() > __nSubjectShort)
                    strSubjectShort =  strSubject.left(__nSubjectShort) + L"...";
                else
                    strSubjectShort = strSubject;
 
                pDest->assign(L"SUBJECT_SHORT", strSubjectShort);
            }
 
            if (__nBodyLength >= 0) {
                String str = fields.byName(L"BODY_PLAIN").asString();
                if (__nBodyLength > 0 && str.length() > (size_t) __nBodyLength)
                    str = str.left(__nBodyLength) + L"...";
                pDest->assign(L"BODY_PLAIN", str);
            }
 
            DateTime dtUpdate = fields.byName(L"UPDATE_TIME").asDateTime();
            pDest->assign(L"UPDATE_DATE", dtUpdate.date().toString());
            ri.assign(pDest, dtUpdate);
 
            if (__nType == TYPE_GRID) {
                pROW->append(strRecName, *pDest);
                if (nCol == __nCols) {
                    nCol = 1;
                    append(strRowName, *pROW);
                    pROW->reset();
                }
                else
                    nCol++;
            }
            else
                append(strRowName, *pDest);
 
            q.fetch();
        } while(!q.eof());
 
        if (__nType == TYPE_GRID && nCol > 1) {
            for(; nCol <= __nCols; nCol++)
                pROW->append(strRecName, *pPADDING);
 
            append(strRowName, *pROW);
        }
    }
    __DCL_TRACE1(L"LIST_ALL: %ls\n", (DateTime::getCurrentLocalTime() - dtStartA).toString().data());
 
    if (pPART_LINK && nTotalPart > 1) {
        PartLink pl(pPART_LINK, strThisPage, strListPageEnc);
        pl.assign(this, nTotalPart, nCurrentPart, __nParts);
    }
 
    MessageView::onPrint(session);
}
 
__DCL_END_NAMESPACE