查询

#include "salerpt.h" #include <math.h>

/******************************************* 功能号： 401201 函数描述： 函数作者： 修改记录:

账户委托查询_(汇总) chaoh zhaol

1.1

20100223

20100507

1.2

*******************************************/ void CAcctOrderAppRpt::AcctOrderAppRpt() { "

if (m_sWhereStr[0] != 0X00) {

//if (m_cIsHistory == '0') //{

// //查询当前

// sSql += " from "DB_SALE"sale_stat_trd "; //} //else //{ //}

CheckMaxDate("busidate",m_sWhereStr); //查询历史

/*sSql += " from h_stat_trd "; if (!XASelect(QUERY_DB_TEXT,DB_TYPE)) { }*/

BusRaiseException(-9999,1,"切换历史数据库失败"); return;

" businesstype, businesscode, businesscode as businessname, fundcode, " " sharetype, fundname, currencytype, ordtimessucc, "

" ordtimesfault, (ordtimessucc + ordtimesfault) as ordtimestotal,ordqtysucc, " ordamtfault, acktimessucc, acktimesfault, ackqtysucc, " " ackqtyfault, ackamtsucc, ackamtfault, ackamtjsucc, " " ackcharge "

" from "DB_SALE"v_stat_trd ";

string sSql = "select distributorcode, busidate, tano, taname, paycenterid, channelid, string sWhere; stringstream oss;

ordqtyfault, ordamtsucc, "

}

}

oss << " and businesstype = "<<STAT_TRD_BUSINESSTYPE_ZHWT; sWhere = string(m_sWhereStr) + oss.str(); string(m_sWhereStr) = sWhere;

//TA代码

//AppBatchSql(sSql,m_sWhereStr,"busidate,tano,businesscode");

else { }

oss << " where businesstype = "<<STAT_TRD_BUSINESSTYPE_ZHWT; sWhere = oss.str();

string(m_sWhereStr) = sWhere;

//TA代码

AppBatchSql(sSql,sWhere.c_str(),"busidate,tano,businesscode,channelid"); Execute(sSql);

if (m_sPosition[0]==0x00||m_sPosition[0]==0x20) { }

kcpd_stream s_stream(GetKcpdConnect()); sSql.assign("");

sSql += "select sum(1) as rcdcount from "DB_SALE"v_stat_trd "; sSql.append(sWhere.c_str()); s_stream.close();

s_stream.open(sSql.c_str(),1); s_stream.execute(); MakeResultSet(s_stream);

if (m_LogPub.InitLogOrConfirmInfo(true) != KCPD_SUCCESS) { }

m_LogPub.SetLogInfo("账户委托查询_(汇总)"); m_LogPub.WriteLogOrConfirmInfo(); Commit();

BusRaiseException(-401201010, 1, m_LogPub.ErrMsg.c_str()); return;

/******************************************* 功能号： 401202 函数描述： 函数作者：

账户确认查询_(汇总) chaoh

1.1

20100223

*******************************************/

void CAcctOrderAckRpt::AcctOrderAckRpt() {

string sSql =

"select distributorcode, busidate, tano, taname, paycenterid,

channelid,"

" businesstype, businesscode,businesscode as businessname, fundcode, " " sharetype, fundname, currencytype, ordtimessucc, " " ordtimesfault, ordqtysucc, ordqtyfault, ordamtsucc, "

" ordamtfault, acktimessucc, acktimesfault, (acktimessucc +

acktimesfault) as acktimestotal,ackqtysucc, "

" ackqtyfault, ackamtsucc, ackamtfault, ackamtjsucc, " " ackcharge "

" from "DB_SALE"v_stat_trd ";

if (m_sPosition[0]==0x00||m_sPosition[0]==0x20) {

kcpd_stream s_stream(GetKcpdConnect()); sSql.assign("");

sSql += "select sum(1) as rcdcount from "DB_SALE"v_stat_trd "; sSql.append(sWhere.c_str()); s_stream.close();

s_stream.open(sSql.c_str(),1); s_stream.execute();

AppBatchSql(sSql,sWhere.c_str(),"tano,businesscode,busidate,channelid"); Execute(sSql);

if (m_sWhereStr[0] != 0X00) { } else { }

oss << " where businesstype = "<<STAT_TRD_BUSINESSTYPE_ZHQR; sWhere = oss.str();

string(m_sWhereStr) = sWhere;

//TA代码

oss << " and businesstype = "<<STAT_TRD_BUSINESSTYPE_ZHQR; sWhere = string(m_sWhereStr) + oss.str(); string(m_sWhereStr) = sWhere;

//TA代码

//AppBatchSql(sSql,m_sWhereStr,"tano,businesscode,busidate");

CheckMaxDate("busidate",m_sWhereStr); string sWhere; stringstream oss;

}

}

if (m_LogPub.InitLogOrConfirmInfo(true) != KCPD_SUCCESS) { }

m_LogPub.SetLogInfo("账户确认查询_(汇总)"); m_LogPub.WriteLogOrConfirmInfo(); Commit();

BusRaiseException(-401201010, 1, m_LogPub.ErrMsg.c_str()); return;

/******************************************* 功能号： 401203 函数描述： 函数作者：

交易申请查询_(汇总) chaoh

1.1

20100223

*******************************************/ void CTransOrderAppRpt::TransOrderAppRpt() {

string sSql =

"select distributorcode, busidate, tano, taname, paycenterid,

channelid, "

" businesstype, businesscode, businesscode as businessname, fundcode, " " sharetype, fundcode as fundname, currencytype, ordtimessucc, " " ordtimesfault, (ordtimessucc + ordtimesfault) as ordtimestotal, "

"

ordqtysucc, ordqtyfault, (ordqtysucc + ordqtyfault) as ordqtytotal,

ordamtsucc, "

" ordamtfault, (ordamtsucc + ordamtfault) as ordamttotal,acktimessucc,

acktimesfault, ackqtysucc, "

" ackqtyfault, ackamtsucc, ackamtfault, ackamtjsucc, " " ackcharge "

" from "DB_SALE"v_stat_trd ";

if (m_sWhereStr[0] != 0X00) {

oss << " and businesstype = "<<STAT_TRD_BUSINESSTYPE_JYWT; sWhere = string(m_sWhereStr) + oss.str(); CheckMaxDate("busidate",m_sWhereStr); string sWhere; stringstream oss;

}

}

else { }

oss << " where businesstype = "<<STAT_TRD_BUSINESSTYPE_JYWT; sWhere = oss.str();

string(m_sWhereStr) = sWhere;

//TA代码

AppBatchSql(sSql,sWhere.c_str(),"busidate,tano,fundcode,sharetype,businesscode,channeliExecute(sSql);

d");

if (m_sPosition[0]==0x00||m_sPosition[0]==0x20) { }

kcpd_stream s_stream(GetKcpdConnect()); sSql.assign("");

sSql += "select sum(1) as rcdcount from "DB_SALE"v_stat_trd "; sSql.append(sWhere.c_str()); s_stream.close();

s_stream.open(sSql.c_str(),1); s_stream.execute(); MakeResultSet(s_stream);

if (m_LogPub.InitLogOrConfirmInfo(true) != KCPD_SUCCESS) { }

m_LogPub.SetLogInfo("交易申请查询_(汇总)"); m_LogPub.WriteLogOrConfirmInfo(); Commit();

BusRaiseException(-401201010, 1, m_LogPub.ErrMsg.c_str()); return;

/******************************************* 功能号： 401204 函数描述： 函数作者：

交易确认查询_(汇总) chaoh

1.1

20100223

*******************************************/ void CTransOrderAckRpt::TransOrderAckRpt() {