Parse Non-Delivery Report (NDR) in Visual C++¶

#include "stdafx.h"
#include <windows.h>

#include "eagetmailobj.tlh"
using namespace EAGetMailObjLib;

#import "C:\\Program Files\\Common Files\\System\\ado\\msado15.dll" \
        no_namespace rename("EOF", "ADOEOF")

static bool ParseEmail(LPCTSTR lpszFileName, _ConnectionPtr& oConn)
{
    const int FailureReport = 0;
    const int DeliveryReceipt = 1;
    const int ReadReceipt = 2;
    const int Receipt_Deleted = 3;

    IMailPtr oMail = NULL;
    oMail.CreateInstance(__uuidof(EAGetMailObjLib::Mail));
    oMail->LicenseCode = _T("TryIt");

    oMail->LoadFile(lpszFileName, VARIANT_TRUE);

    // detect if this is a report or receipt
    if (oMail->IsReport == VARIANT_FALSE)
    {
        _tprintf(_T("Not a report or receipt!\r\n"));
        return false;
    }

    IMailReportPtr oReport = oMail->GetReport();
    // we only process failure report
    if (oReport->ReportType != FailureReport)
    {
        _tprintf(_T("Not a failure report!\r\n"));
        return false;
    }

    _tprintf(_T("OriginalRecipient: %s\r\n"), (LPCTSTR)oReport->OriginalRecipient);
    _tprintf(_T("ErrorCode: %s\r\n"), (LPCTSTR)oReport->ErrCode);
    _tprintf(_T("ErrorDesc: %s\r\n"), (LPCTSTR)oReport->ErrDescription);

    TCHAR errorDesc[MAX_PATH + 1];
    // limit maximun length of error description to 250 in database.
    _tcsncpy_s(errorDesc, MAX_PATH, (LPCTSTR)oReport->ErrDescription, _TRUNCATE);

    // INSERT the result to database.
    LPCTSTR lpszSQL = _T("INSERT INTO [dbo].[Failure_Report] ")
        _T(" ([address] ")
        _T(" ,[error_code] ")
        _T(" ,[error_desc] ")
        _T(" ,[error_datetime]) ")
        _T(" VALUES ( @address, @error_code, @error_desc, GETDATE())");

    _CommandPtr oCommand = NULL;
    oCommand.CreateInstance(__uuidof(Command));
    oCommand->ActiveConnection = oConn;
    oCommand->CommandText = lpszSQL;
    oCommand->CommandType = adCmdText;
    oCommand->Prepared = VARIANT_FALSE;

    _variant_t vt = oReport->OriginalRecipient;
    _ParameterPtr oParam = oCommand->CreateParameter(_T("@address"), adBSTR, adParamInput, 0, vt);
    oCommand->Parameters->Append(oParam);
    oParam.Release();

    vt = oReport->ErrCode;
    oParam = oCommand->CreateParameter(_T("@error_code"), adBSTR, adParamInput, 0, vt);
    oCommand->Parameters->Append(oParam);
    oParam.Release();

    vt = errorDesc;
    oParam = oCommand->CreateParameter(_T("@error_desc"), adBSTR, adParamInput, 0, vt);
    oCommand->Parameters->Append(oParam);
    oParam.Release();

    oCommand->Execute(NULL, NULL, adExecuteNoRecords | adCmdText);

    oCommand.Release();

    return true;
}

int _tmain(int argc, _TCHAR* argv[])
{

    if (argc < 2)
    {
        return 0;
    }

    if (_tcslen(argv[1]) > MAX_PATH)
    {
        return 0;
    }

    TCHAR szFolder[MAX_PATH + 1];
    _tcscpy_s(szFolder, MAX_PATH, argv[1]);

    HANDLE hFind = INVALID_HANDLE_VALUE;

    TCHAR szFind[MAX_PATH + 1];
    if (szFolder[_tcslen(szFolder) - 1] == _T('\\'))
    {
        szFolder[_tcslen(szFolder) - 1] = _T('\0');
    }

    ::_sntprintf_s(szFind, MAX_PATH, MAX_PATH - 1, _T("%s\\*.eml"), szFolder);

    WIN32_FIND_DATA findData;
    memset(&findData, 0, sizeof(findData));

    hFind = ::FindFirstFile(szFind, &findData);
    if (hFind == INVALID_HANDLE_VALUE)
        return 0;

    ::CoInitialize(NULL);

    _ConnectionPtr oConn = NULL;
    oConn.CreateInstance(__uuidof(Connection));

    // For more connection string
    // MS SQL Server 2000
    // "Driver={SQL Server};Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2005
    // "Driver={SQL Server Native Client};Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2005 Native Provider
    // "Provider=SQLNCLI;Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2008
    // "Driver={SQL Server Native Client 10.0};Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2008 Native Provider
    // "Provider=SQLNCLI10;Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2012
    // "Driver={SQL Server Native Client 11.0};Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // MS SQL Server 2012 Native Provider
    // "Provider=SQLNCLI11;Server=localhost; Database=myDB;Uid=myUser;Pwd=myPassword;"

    // change it to your sql server address, database, user and password
    // The server/instance name syntax used in the server option is the same for all SQL Server connection strings.
    // e.g.: Server=serveraddress\\instancename;
    // open database connection

    LPCTSTR lpszConn = _T("Driver={SQL Server Native Client 11.0};Server=localhost;Database=myDB;Uid=myUser;Pwd=myPassword;");

    try
    {
        oConn->Open(lpszConn,
            _T(""), _T(""), adConnectUnspecified);
        do
        {
            TCHAR szFile[MAX_PATH + 1];
            ::_sntprintf_s(szFile, MAX_PATH, MAX_PATH - 1, _T("%s\\%s"), szFolder, findData.cFileName);

            if (ParseEmail(szFile, oConn))
            {
                // Delete the local report file
                ::DeleteFile(szFile);
            }

        } while (::FindNextFile(hFind, &findData));

        oConn->Close();
    }
    catch (_com_error &ep)
    {
        ::_tprintf(_T("Error: %s\r\n"), (const TCHAR*)ep.Description());
    }

    return 0;
}