someThing about thread

// SynThirdMgr.cpp: implementation of the CSynThirdMgr class.

//

//////////////////////////////////////////////////////////////////////

//----------------------------------------------------------------------------

// 程序名称：   SynThirdMgr.h

// 程序说明：   业务处理类

// 程序作者：   林江

// 开始日期：   2009-10-26

//----------------------------------------------------------------------------

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <strstream>

#include <fstream>

#include <windows.h>

#include <direct.h>

#include <io.h>

#include<time.h> ///

#include "SynThirdMgr.h"

#include "ConfigFile.h"

#include "shlwapi.h"

#include   <imagehlp.h>   

HANDLE mMutex;

//////////////////////////////////////////////////////////////////////

// Construction/Destruction                                         //

//////////////////////////////////////////////////////////////////////

CSynThirdMgr::CSynThirdMgr()

{

}

CSynThirdMgr::~CSynThirdMgr()

{

//to do destroy

}

//----------------------------------------------------------------------------

//////////////////////////////////////////////////////////////////////

// Private Function                                                 //

//////////////////////////////////////////////////////////////////////

//////////////////////////////////////////////////////////////////////

// Public Function                                                  //

//////////////////////////////////////////////////////////////////////

//----------------------------------------------------------------------------

// 函数原型： prepare

// 函数功能： 返回结果值

// 传入参数： 无

// 传出参数： 无

// 函数返回： 无

// 注意事项：

//----------------------------------------------------------------------------

bool CSynThirdMgr::prepare()

{

int iRet=0;

char pstrResMsg[500];

if(m_ConnectPool.Connect(m_strTnsName)==1)

{

sprintf(pstrResMsg,(char *)"数据库连接成功!");

writeStatuslog(m_nProType,"0",0,pstrResMsg);

cerr<< pstrResMsg <<endl;

}

else{

sprintf(pstrResMsg,(char *)"数据库连接失败!!!");

writeErrlog(m_nProType,"0",0,pstrResMsg);

cerr<< pstrResMsg <<endl;

return false;

}

return true;

}

//----------------------------------------------------------------------------

// 函数原型： finish

// 函数功能： 返回结果值

// 传入参数： 无

// 传出参数： 无

// 函数返回： 无

// 注意事项：

//----------------------------------------------------------------------------

void CSynThirdMgr::finish()

{

return;

}

//----------------------------------------------------------------------------

// 函数原型： handle

// 函数功能： 返回结果值

// 传入参数： 无

// 传出参数： 无

// 函数返回： 无

// 注意事项：

//----------------------------------------------------------------------------

DWORD WINAPI ReadDataProc(LPVOID lpParamter)

{

CSynThirdMgr *pCSynThirdMgr=(CSynThirdMgr*)lpParamter;

/*if(0==m_ConnectPool.ReadData(

m_strRealFile,

pfile,

m_strUserLabelTable,

nFlag,

lckID)) /// the second param is groupid

*/

if(0==pCSynThirdMgr->m_ConnectPool.ReadData(pCSynThirdMgr->m_strRealFile,pCSynThirdMgr->m_pfile,pCSynThirdMgr->m_strUserLabelTable,pCSynThirdMgr->m_nFlag,pCSynThirdMgr->m_n64ID))

{

//cout<<"数据写入成功,文件名"<<szFileName<<endl;

cout<<"手机字段:"<<pCSynThirdMgr->m_nFlag<<"\t写入成功"<<endl;

//pfile->close();

//continue;

return 0;

}

else{

cerr << "DB Exception!!!" << endl;

//pCSynThirdMgr->writeErrlog(pCSynThirdMgr->m_nProType,pCSynThirdMgr->m_n64ID,0,"DB Exception!!!");

return -1;

}

}

void CSynThirdMgr::handle()

{

char szID[64]={0};

char szFilePath[512]={0};

char szFileName[128]={0};

char szDealedLine[16]={0}; 

char szOldFullName[1024]={0};

char szNewFullName[1024]={0};

char szLogBuf[1024]={0};

//char szFileRealName[256]={0}; ///file name will be writed

int  lReadLine=0;

//long lckID=0;

__int64 lckID;

char szStatue[]="0";

long lDownNum=0; ///need to bedown

//

char str_timeBeg[100];

char str_timeEnd[100];

struct tm *localTimeBeg=NULL;

struct tm *localTimeEnd=NULL;

//std::ofstream *pfile=new ofstream(); ///a point to file

cerr <<"Program Running"<< endl;

//download file

//int nRet = m_ConnectPool.GetDownLoadFile(m_strPlatForm,m_strSrcTable,szID,szFilePath,szFileName,szDealedLine,m_nProType,m_nTotNumer);

bool bRet=m_ConnectPool.bckDownLoadData(m_strCkTable,szStatue,&lReadLine,&lckID);

if(bRet)

{

time_t tm_beg,tm_end;

double result=0;

tm_beg=time(NULL);

localTimeBeg=localtime(&tm_beg);

strftime(str_timeBeg, sizeof(str_timeBeg), "%Y-%m-%d,%H:%M:%S", localTimeBeg);

//文件名格式 userlabel_YYYYMMDD24HHMISS+.txt

char szTimeNow[64]; 

time_t t = time(0); 

strftime( szTimeNow, sizeof(szTimeNow), "%Y%m%d%H%M%S",localtime(&t) ); 

sprintf(szFileName,"userlabel_%s.txt",szTimeNow);

sprintf(m_strRealFile,"%s\\%s",m_strSucFilePath,szFileName);/// 成功文件路径

//pfile->open(m_strRealFile,ios_base::in|ios_base::app);

mMutex=CreateMutex(NULL,FALSE,NULL);

m_pfile->open(m_strRealFile,ios_base::in|ios_base::app);

//for(int nFlag=lReadLine;nFlag<=99;nFlag++)

//int m_nFlag=0;

m_nFlag=0;

while(m_nFlag<99)

{

m_nFlag++;

// cout<<"**********\r\n"<<nFlag<<"\r\n**********"<<endl;

// time_t t = time(0); 

//按时间

/* char szTimeNow[64]; 

strftime( szTimeNow, sizeof(szTimeNow), "%Y%m%d%H%M%S",localtime(&t) ); 

sprintf(szFileName,"userlabel_%s.txt",szTimeNow);

sprintf(m_strRealFile,"%s\\%s",m_strSucFilePath,szFileName);/// 成功文件路径

*/

///end time

//vfile.open(szFileRealName,ios_base::in|ios_base::app); //if file no exit create,others append the data

/*pfile->open(m_strRealFile,ios_base::in|ios_base::app);*/

// if(!(*pfile))

if(!(*m_pfile))

{

cout<<"open file error!"<<endl;

writeErrlog(m_nProType,szID,0,"Open File error!");

m_pfile->close();

delete m_pfile;

}

HANDLE thread1,thread2;

m_n64ID=lckID;

thread1=CreateThread(NULL,0,ReadDataProc,NULL,0,NULL);

thread2=CreateThread(NULL,0,ReadDataProc,NULL,0,NULL);

CloseHandle(thread1);

CloseHandle(thread2);

/*

if(0==m_ConnectPool.ReadData(

m_strRealFile,

pfile,

m_strUserLabelTable,

nFlag,

lckID)) /// the second param is groupid

{

//cout<<"数据写入成功,文件名"<<szFileName<<endl;

cout<<"手机字段:"<<nFlag<<"\t写入成功"<<endl;

//pfile->close();

continue;

}

else{

cerr << "DB Exception!!!" << endl;

writeErrlog(m_nProType,szID,0,"DB Exception!!!");

}

*/

}

tm_end=time(NULL);

localTimeEnd=localtime(&tm_end);

//无论之前的时间取值是多少。在这里如果开始、结束连在一起的话可就没有时间差了

strftime(str_timeEnd, sizeof(str_timeEnd), "%Y-%m-%d,%H:%M:%S", localTimeEnd);

printf("***\nbegin_time:%s\t end_time:%s\n***\n",str_timeBeg,str_timeEnd);

result=difftime(tm_end,tm_beg);

printf("********\n耗费时间:%f  秒\n***********\n",result);

sprintf(szLogBuf,"数据写入文件完成,最后一个文件名:%s",szFileName);

writeStatuslog(m_nProType,szID,0,szLogBuf);

}

else if(bRet!=true){

// cerr << "Finish or DB Exception!!!" << endl;

// writeErrlog(m_nProType,szID,0,"DB Exception!!!");

cout<<"Finish!!!\r\n"<<endl;

}

return;

}

//----------------------------------------------------------------------------

// 函数原型： initialize

// 函数功能： 返回结果值

// 传入参数： 无

// 传出参数： 无

// 函数返回： 无

// 注意事项：

//----------------------------------------------------------------------------

int CSynThirdMgr::initialize(int argc,char* argv[])

{

char strTemp[512]={0};

char strCfgFileName[512];

char strnumber[20]={0};

if(strcmp(argv[1],"-stop") == 0 && argc == 3)

{

strcpy(strCfgFileName, argv[2]);

}

else if(strcmp(argv[1],"-start") == 0 && argc == 4)

{

strcpy(strCfgFileName, argv[3]);

}

else

{

cerr << "missing parameter" << endl;

return -1;

}

if( m_cConfigFile.Open(strCfgFileName) < 0 )

{

cerr << "Can not open " << strCfgFileName << endl;

return -1;

}

if (initCommon(argc,argv,m_cConfigFile)!=0)

{

return -1;

}

//------------------------------------[配置文件]-------------------

//应用程序号  

if(m_cConfigFile.GetValue((char *)"APPINFO",(char *)"ProgramID",strTemp)!=0)

{

cerr << "没有找到配置文件中的ProgramID的数据!"<<endl;

return  FAIL;

}

m_nProgramID = atoi(strTemp);

//应用名称

if(m_cConfigFile.GetValue((char *)"APPINFO",(char *)"ProgramName",m_strProgramName)!=0)

{

cerr << "没有找到配置文件中的ProgramName的数据!"<<endl;

return  FAIL;

}

//应用版本号

if( m_cConfigFile.GetValue((char *)"APPINFO",(char *)"Version",m_strVersion)!=0 )

{

cerr << "没有找到配置文件中的Version的数据!"<<endl;

return  FAIL;

}

//应用所在路径

if( m_cConfigFile.GetValue((char *)"APPINFO",(char *)"AppPath",m_strAppPath)!=0 )

{

cerr << "没有找到配置文件中的AppPath的数据!"<<endl;

return  FAIL;

}

MakeSureDirectoryPathExists(m_strAppPath);

if( m_cConfigFile.GetValue((char *)"APPINFO",(char *)"PlatForm",m_strPlatForm)!=0 )

{

cerr << "没有找到配置文件中的PlatForm的数据!"<<endl;

return  FAIL;

}

//休眠时间

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"SleepTime",strTemp)!=0 )

{

cerr << "没有找到配置文件中的SleepTime的数据!"<<endl;

return  FAIL;

}

m_nSleepTime = atoi(strTemp);

//进程号

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"ProType",strTemp) !=0 )

{

cerr << "没有找到配置文件中的ProType的数据!"<<endl;

return  FAIL;

}

m_nProType = atoi(strTemp);

//总的进程数

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"TotNumer",strTemp) !=0 )

{

cerr << "没有找到配置文件中的TotNumer的数据!"<<endl;

return  FAIL;

}

m_nTotNumer = atoi(strTemp);

//源文件路径

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"SrcFilePath",m_strSrcFilePath) !=0 )

{

cerr << "没有找到配置文件中的SrcFilePath的数据!"<<endl;

return  FAIL;

}

MakeSureDirectoryPathExists(m_strSrcFilePath);

//成功日志文件路径

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"SucFilePath",m_strSucFilePath) !=0 )

{

cerr << "没有找到配置文件中的SucFilePath的数据!"<<endl;

return  FAIL;

}

MakeSureDirectoryPathExists(m_strSucFilePath);

//错误日志文件路径

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"BadFilePath",m_strBadFilePath) !=0 )

{

cerr << "没有找到配置文件中的BadFilePath的数据!"<<endl;

return  FAIL;

}

MakeSureDirectoryPathExists(m_strBadFilePath);

//备份文件路径

if( m_cConfigFile.GetValue((char *)"GLOBAL",(char *)"CopyFilePath",m_strCopyFilePath) !=0 )

{

cerr << "没有找到配置文件中的CopyFilePath的数据!"<<endl;

return  FAIL;

}

MakeSureDirectoryPathExists(m_strCopyFilePath);

//TNS

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"TnsName",m_strTnsName) !=0 )

{

cerr << "没有找到配置文件中的TnsName的数据!"<<endl;

return  FAIL;

}

//源数据表

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"SrcTable",m_strSrcTable) !=0 )

{

cerr << "没有找到配置文件中的SrcTable的数据!"<<endl;

return  FAIL;

}

//控制表 

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"CkTable",m_strCkTable) !=0 )

{

cerr << "没有找到配置文件中的CkTable的数据!"<<endl;

return  FAIL;

}

//用户标签表

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"UserTable",m_strUserLabelTable) !=0 )

{

cerr << "没有找到配置文件中的UserTable的数据!"<<endl;

return  FAIL;

}

//异常表

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"ExceptionTable",m_strExceptionTable) !=0 )

{

cerr << "没有找到配置文件中的ExceptionTable的数据!"<<endl;

return  FAIL;

}

if( m_cConfigFile.GetValue((char *)"DATABASE",(char *)"CommitRow",strTemp)!=0 )

{

cerr << "没有找到配置文件中的CommitRow的数据!"<<endl;

return  FAIL;

}

m_nCommitRow = atoi(strTemp);

//监控路径

if( m_cConfigFile.GetValue((char *)"MONITOR",(char *)"MonPath",m_strMonPath) !=0 )

{

cerr << "没有找到配置文件中的MonPath的数据!"<<endl;

return  FAIL;

}

//慢时间间隔

if( m_cConfigFile.GetValue((char *)"MONITOR",(char *)"Interval1",strTemp) !=0 )

{

cerr << "没有找到配置文件中的Interval1的数据!"<<endl;

return  FAIL;

}

m_nInterval1 = atoi(strTemp);

//挂死时间间隔

if( m_cConfigFile.GetValue((char *)"MONITOR",(char *)"Interval2",strTemp) !=0 )

{

cerr << "没有找到配置文件中的Interval2的数据!"<<endl;

return  FAIL;

}

m_nInterval2 = atoi(strTemp);

//日志等级

if( m_cConfigFile.GetValue((char *)"MONITOR",(char *)"LogLevel",strTemp) !=0 )

{

cerr << "没有找到配置文件中的LogLevel的数据!"<<endl;

return  FAIL;

}

m_nLogLevel = atoi(strTemp);

//------------------------------------[配置文件]-------------------  

m_cConfigFile.Close();

cout << "初始化成功!" <<endl;

return 0;

}

int  CSynThirdMgr::writeErrlog(int m_intPro_type,char *str_id,int flag_type,char *pstrResMsg)

{   

try

{   

fstream fBad;

char strBadFileName[512]={0}; //错误日志文件名

char strQZBadFilePath[256]={0};     //前缀错误日志路径

char strZGBadLogFileName[512]={0};  //整个错误日志路径文件名

char strSysdate_pro[15]={0};

char strResMsg[1024]={0};

//获得写日志的时间

time_t lTime;

struct tm *rNewTime;  

time(&lTime);

rNewTime = localtime(&lTime);  

sprintf(strSysdate_pro,"%04d-%02d-%02d",rNewTime->tm_year+1900,rNewTime->tm_mon+1,rNewTime->tm_mday);         

sprintf(strBadFileName,(char *)"%d_%s%s",m_nProgramID,strSysdate_pro,LOGFILE_APPEND);

sprintf(strQZBadFilePath,(char *)"%s",m_strBadFilePath);

sprintf(strZGBadLogFileName,(char *)"%s%s",strQZBadFilePath,strBadFileName);

locale loc = locale::global(locale(""));//将全局区域设为操作系统默认区域//lin

fBad.open(strZGBadLogFileName,ios::out|ios::app);

locale::global(loc);//还原全局区域设定//linlocale("C")

fBad <<"时间:"<<strSysdate_pro;

fBad <<"进程:"<<m_intPro_type<<" 处理文件id:"<<str_id;

if (flag_type==0)

{

fBad <<"  "<<pstrResMsg<<endl;

}

else

{

fBad <<"  文件打开失败!!!"<<endl;

}

fBad.close();

}

catch(char *Err)

{

sprintf(pstrResMsg,(char *)" -401 写文件异常：%s",(char *)Err);

return -401;

}

sprintf(pstrResMsg,(char *)"OK");

return 0;

}

int  CSynThirdMgr::writeStatuslog(int m_intPro_type,char *str_id,int flag_type,char *pstrResMsg)

{   

try

{   

fstream fSuc;

char strSucFileName[512]={0}; //状态日志文件名

char strQZSucFilePath[256]={0};     //前缀状态日志路径

char strZGSucLogFileName[512]={0};  //整个状态日志路径文件名

char strSysdate_pro[15]={0};

char strResMsg[1024]={0};

//获得写日志的时间

time_t lTime;

struct tm *rNewTime;  

time(&lTime);

rNewTime = localtime(&lTime);  

sprintf(strSysdate_pro,"%04d-%02d-%02d",rNewTime->tm_year+1900,rNewTime->tm_mon+1,rNewTime->tm_mday);         

sprintf(strSucFileName,(char *)"%d_%s%s",m_nProgramID,strSysdate_pro,STAFILE_APPEND);

sprintf(strQZSucFilePath,(char *)"%s",m_strSucFilePath);

sprintf(strZGSucLogFileName,(char *)"%s%s",strQZSucFilePath,strSucFileName);

locale loc = locale::global(locale(""));//将全局区域设为操作系统默认区域//lin

fSuc.open(strZGSucLogFileName,ios::out|ios::app);

locale::global(loc);//还原全局区域设定//linlocale("C")

fSuc <<"时间:"<<strSysdate_pro;

fSuc <<"进程:"<<m_intPro_type<<" 处理文件id:"<<str_id;

if (flag_type==0)

{

fSuc <<"  "<<pstrResMsg<<endl;

}

else

{

fSuc <<"  文件打开失败!!!"<<endl;

}

fSuc.close();

}

catch(char *Err)

{

sprintf(pstrResMsg,(char *)" -401 写文件异常：%s",(char *)Err);

return -401;

}

sprintf(pstrResMsg,(char *)"OK");

return 0;

}

//.h

// SynThirdMgr.h: interface for the CSynThirdMgr class.

//

//////////////////////////////////////////////////////////////////////

//----------------------------------------------------------------------------

// 程序名称：   SynThirdMgr.h

// 程序说明：   业务处理类

// 程序作者：   林江

// 开始日期：   2009-10-26

//----------------------------------------------------------------------------

#ifndef WQF_SYNTHIRDMGR_H__20040919__INCLUDED_

#define WQF_SYNTHIRDMGR_H__20040919__INCLUDED_

#include "FlowCtrl.h"

class CSynThirdMgr : public CFlowCtrl

{

public:

CSynThirdMgr();

virtual ~CSynThirdMgr();

bool prepare();

//退出

void finish();

//一个周期中的所有处理，如处理完一个文件，提交;如果出严重错误，抛出异常

void handle();

int initialize(int argc,char* argv[]);

//private:

public:   

//----------开始------------------------------------

//应用程序号

int m_nProgramID;

//应用名称

char m_strProgramName[128];

//应用版本号

char m_strVersion[128];

//应用所在路径

char m_strAppPath[512];

//平台ID

char m_strPlatForm[32];

//休眠时间

int m_nSleepTime;

//进程号

int m_nProType;

//总的进程数

int m_nTotNumer;

//源文件路径

char m_strSrcFilePath[512];

//成功日志文件路径

char m_strSucFilePath[512];

//错误日志文件路径

char m_strBadFilePath[512];

//备份文件路径

char m_strCopyFilePath[512];

//完整文件名

char m_strRealFile[256];

//数据库连接串

char m_strTnsName[512];

//源数据表

char m_strSrcTable[128];

//入库表

char m_strUserLabelTable[128];

//control table

char m_strCkTable[128];

//storage data table

char m_strDownTable[128];

//异常表

char m_strExceptionTable[128];

//多少条提交一次

int m_nCommitRow;

//监控路径

char m_strMonPath[512];

//慢时间间隔

int m_nInterval1;

//挂死时间间隔

int m_nInterval2;

//日志等级

int m_nLogLevel;

//是否有效

bool m_bDownFlag;

//---------------结束---------------------------------

CConfigFile    m_cConfigFile;

int writeErrlog(int m_intPro_type,char *str_id,int flag_type,char *pstrResMsg);

int writeStatuslog(int m_intPro_type,char *str_id,int flag_type,char *pstrResMsg);

DWORD WINAPI uploadDataThread(LPVOID lpParamter);

public:

int m_nFlag; //控制标识

std::ofstream *m_pfile;//=new ofstream();

__int64 m_n64ID;

};

#endif // WQF_SYNTHIRDMGR_H__20040919__INCLUDED_