CPP程序监视plot文件夹并以post方式上传数据

admin

2011年11月09日 17时13分

//#include          // MFC 核心和标准组件

#include 
#include 
#include 
#include 
#include 

void display_post_result(std::string result)
{
    std::cout<OpenRequest(CHttpConnection::HTTP_VERB_POST, pathName.c_str());

        CString strHeaders = "Content-Type: application/x-www-form-urlencoded"; // 请求头

        display_post_result("posting data...");

        pFile->SendRequest(strHeaders,(LPVOID)postData.c_str(),postData.size());
        pFile->QueryInfoStatusCode(dwRet);

        if (dwRet == HTTP_STATUS_OK)
        {
            CString result, newline;

            while(pFile->ReadString(newline))
            {
                result += newline+"\r\n";
            }

            display_post_result(("back:"+result).GetBuffer());
        }
        else
        {
            display_post_result("post 失败！");
            return false;
        }
        delete pFile;
        delete pServer;

    }
    catch (CInternetException* pEx)
    {
        //catch errors from WinInet
        TCHAR pszError[200];
        pEx->GetErrorMessage(pszError, 200);

        display_post_result(pszError);
        return false;
    }
    session.Close();

    return true;
}

bool deal_plot_file(std::string orgine_name, std::string &result)
{
    std::ifstream fin(orgine_name.c_str());
    if(!fin.is_open())
    {
        display_post_result("打开文件"+orgine_name+"失败！");
        return false;
    }

    display_post_result("dealing "+orgine_name+"...");

    result = "";
    std::string linestr, number;

    std::istringstream stringin;
    while(std::getline(fin,linestr))
    {
        stringin.clear();
        stringin.str(linestr);
        if(stringin>>number)
        {
            if(number.size() == 5)
            {
                result += number;
                //读取并丢弃经纬度高度和站点级别信息
                stringin>>number>>number>>number>>number;

                while(stringin>>number)
                {
                    result += ' ' + number;
                }
                //result += "\r\n";

            }
            else
            {
                result += linestr + "\r\n";
            }
        }
    }

    return true;
}

CTime get_last_time()
{
    int year,month,day,hour,minute,second;

    year   = GetPrivateProfileInt("lastest","year",1970,"./scan.ini");
    month  = GetPrivateProfileInt("lastest","month",1,"./scan.ini");
    day    = GetPrivateProfileInt("lastest","day",2,"./scan.ini");
    hour   = GetPrivateProfileInt("lastest","hour",0,"./scan.ini");
    minute = GetPrivateProfileInt("lastest","minute",0,"./scan.ini");
    second = GetPrivateProfileInt("lastest","second",0,"./scan.ini");

    return CTime(year,month,day,hour,minute,second);
}

bool set_latest_time(const CTime &latest)
{
    BOOL year,month,day,hour,minute,second;

    year   = WritePrivateProfileString("lastest","year",latest.Format("%Y"),"./scan.ini");
    month  = WritePrivateProfileString("lastest","month",latest.Format("%#m"),"./scan.ini");
    day    = WritePrivateProfileString("lastest","day",latest.Format("%#d"),"./scan.ini");
    hour   = WritePrivateProfileString("lastest","hour",latest.Format("%#H"),"./scan.ini");
    minute = WritePrivateProfileString("lastest","minute",latest.Format("%#M"),"./scan.ini");
    second = WritePrivateProfileString("lastest","second",latest.Format("%#S"),"./scan.ini");

    return year && month && day && hour && minute && second;
}

std::string get_plot_dir()
{
    char dir_buf[1024] ;
    DWORD result = GetPrivateProfileString("path","plotdir","Z:/surface/plot/",dir_buf,1000,"./scan.ini");

    return dir_buf;
}

bool scan_plot_dir()
{
    CTime last_time = get_last_time();

    CFileFind finder;

    std::string dir = get_plot_dir();
    if('\\' != dir[dir.size()-1 ] && '/' != dir[dir.size()-1 ] )
    {
        dir += '/';
    }
    BOOL bWorking = finder.FindFile( (dir+ "*.000").c_str() );

    CTime lastest(1), ftime;
    std::string result;
    //

    while (bWorking)
    {
        bWorking = finder.FindNextFile();

        if(finder.GetLastWriteTime(ftime) 
            && ftime > last_time 
            && deal_plot_file(finder.GetFilePath().GetBuffer(), result) 
            )
        {
            bool is_post_success = 
                PostHttpPage("current.sinaapp.com","update-mysql-from-post.php","app-content="+result);

            if(!is_post_success) 
            {//有一次post不成功就返回本次dir scan
                display_post_result("post maybe failure...");
                return false;
            }

            lastest = ftime > lastest ? ftime : lastest;

            display_post_result("wait 2 minute...");
            Sleep(2*1000*60);//post成功时等待2分钟
            display_post_result("continue next file find...");
        }
    }

    if(CTime(1) != lastest ) 
    {
        return set_latest_time(lastest);
    }

    return false;
}

int main(void)
{
    std::cout<<"version 1.1  2011-11-09\n"
        <<"-------------------------------------\n";
    while(true)
    {
        scan_plot_dir();

        display_post_result("wait 5 minute...");
        Sleep(5*1000*60);//每次dir scan完成时等待5分钟
        display_post_result("continue next plot dir scan...");
    }

}