C / C++ / MFC

DWORD WINAPI BackgroundMailBoxMonitorThread(LPVOID pParams)
{
  AFX_MANAGE_STATE(AfxGetStaticModuleState());

  BACKGROUNDPARAMSTRUCT *pParamStruct = (BACKGROUNDPARAMSTRUCT *)pParams;

  DBConnection *pDBConn = new DBConnection;

  if (pDBConn)
    {
      int  iRunFrequency = 300;   // default to 5 minutes...

      if (pParamStruct->pApplication->GetUserTagValue("MailBoxMonitorBackgroundThreadRunFrequency",caSQLBuf))
        iRunFrequency = atoi(caSQLBuf);

      if (iRunFrequency < 30)  // check not more frequent than every 30 seconds..
        iRunFrequency = 30;

      pParamStruct->pApplication->GetSQLStatement(6015,caInBoxSQLBuf);

      if (pParamStruct->pApplication->GetSQLStatement(6010,caSQLBuf))
        {
          pParamStruct->pApplication->ParseSQL(caSQLBuf);

          int iSeconds = 0;

          while (!pParamStruct->bTerminateThread)
            {
              iSeconds++;
              if (iSeconds >= iRunFrequency)
                {
                  if (pParamStruct->pApplication->Connect2DB(pDBConn))
                    {
                      DBStatement *pStmt = pDBConn->ExecSQL(caSQLBuf);
                      if (pStmt)
                        {
                          CObList oAccounts;
                          MailBoxAccountInfo *pAccount;

                          while (pStmt->FetchNext())
                            {
                              pAccount = new MailBoxAccountInfo;

                              pAccount->m_lCompanyKey = pStmt->GetLong(1);
                              pAccount->m_cEMailSenderAccount = pStmt->GetString(2);
                              oAccounts.AddTail((CObject *)pAccount);
                            }

                          pStmt->EndSQL();

                          delete pStmt;

                          POSITION pPos = oAccounts.GetHeadPosition();
                          while (pPos)
                            {
                              pAccount = (MailBoxAccountInfo *)oAccounts.GetNext(pPos);
                              if (pAccount)
                                {
                                  // connect to mailbox and process any messages...
                                  CheckMailAccountForActivity(pAccount,pDBConn,caInBoxSQLBuf,pParamStruct->pApplication);

                                  delete pAccount;
                                }
                            }

                          oAccounts.RemoveAll();
                        }

                      pDBConn->Disconnect();

                      iSeconds = 0;
                    }
                }

              Sleep(1000);
            }
        }
      else
        {
          LogBackgroundProcessError(3,"Mailbox Monitor Company List SQL Statement Not Found!",pParamStruct->pApplication);
        }

      delete pDBConn;
    }

  if (!pParamStruct->bTerminateThread)
    pParamStruct->hThread = NULL;

  return 0;
}