job.cpp

这个一个联通短信网关程序.并且在SP已经运行稳定.很有学习价值

// Job.cpp : 实现文件
//

#include "stdafx.h"
#include "moUniteService.h"
#include "Job.h"


// CJob

IMPLEMENT_DYNAMIC(CJob, CWnd)
CJob::CJob()
{
}

CJob::~CJob()
{
}


BEGIN_MESSAGE_MAP(CJob, CWnd)
END_MESSAGE_MAP()

void CJob::ProcessMO(CString strCmd,CString strCPhone,BOOL blSource)
{
	CString strCommand		=strCmd.Mid(0,4);
	CString strClientPhone	=strCPhone;
	CTime time=time.GetCurrentTime();
	CString strCurrentTime;
	CString strSource="1259197";
	CString strMsg="";
	CADODatabase mo_db;
	CADORecordset rsc(&mo_db);
	CADORecordset rs(&mo_db);
	if(mo_db.OpenSQLServerDirect(MyReg::GetDBIP(),MyReg::GetDBUserID(),MyReg::GetDBPassword(),"ewsv3"))
	{
		CString str="订阅";
		CString strSql="select * from Mh_SMS_Log where 1=0";
		rs.Open(strSql);
		rs.AddNew();
		rs.SetFieldValue("UserPhone",strClientPhone);
		rs.SetFieldValue("SmsType",str);
		rs.SetFieldValue("Content",strCmd);		
		rs.Update();
		rs.Close();
		if(strCommand.GetLength()>3)
		{
			CString strDYType="0";
			rs.Open("select * from Mh_SMS_ZPDYUser where userphone='"+strClientPhone+"' and DYDM='"+strCommand+"'");
			if(rs.IsEOF())
			{
				rs.AddNew();
				rs.SetFieldValue("UserPhone",strClientPhone);
				rs.SetFieldValue("DYDM",strCommand);
				if(blSource)rs.SetFieldValue("Resource",strSource);
				rs.SetFieldValue("DYType",strDYType);
				rs.Update();
				rs.Close();	
				::SGIP_SendBY("ZPZY",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
					MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
					"订阅招聘",3,"1500",3,3);
				::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
					MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
					"订阅招聘信息成功，15元/月。取消订阅发短信QX11到8765。手机短信，信息互动，一机在手，前程美好。",MyReg::GetPayTypeUnion(),"25");
				
			}
			else
			{
				::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
					MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
					"您已经订阅了招聘信息。取消订阅发短信QX11到8765。手机短信，信息互动，一机在手，前程美好。",MyReg::GetPayTypeUnion(),"25");				
			}
		}
		else
		{			
			::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
				MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
				"定制失败，您没有发送职位代码，请重新发送短信定制！",MyReg::GetPayTypeUnion(),"25");
		}	
		mo_db.Close();
	}
	else
	{		
		::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
			MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
			"定制失败，请重新发送短信定制！",MyReg::GetPayTypeUnion(),"25");
	}

}
//查询职位
void CJob::ProcessRequery(CString strCmd,CString strCPhone,BOOL blSource)
{
	CADODatabase mo_db;
	CADORecordset rsc(&mo_db);
	CADORecordset rs(&mo_db);
	CString strQuery="";
	strQuery=strCmd.Mid(3);
	CString strSql="";
	CString strCorpName,strContract,strTele,strFcontent,strContent,strKnowledge;
	CString strMsg="";
	CString strClientPhone=strCPhone;
	CString str="查询";
	
		if(mo_db.OpenSQLServerDirect(MyReg::GetDBIP(),MyReg::GetDBUserID(),MyReg::GetDBPassword(),"ewsv3"))
		{
			if(strQuery.GetLength()>0)
			{
				
				strSql="select * from Mh_SMS_Log where 1=0";
				rs.Open(strSql);
				rs.AddNew();
				rs.SetFieldValue("UserPhone",strClientPhone);
				rs.SetFieldValue("SmsType",str);
				rs.SetFieldValue("Content",strCmd);				
				rs.Update();
				rs.Close();
				strSql="select j.Knowledge,e.corpname,e.contract,e.telephone,m.content as FContent,b.content from Mh_JobInfo j,Mh_BaseFunction m,Mh_BaseJob b,Mh_Enterprise e where e.corpcode=j.corpcode and j.jobcode=b.jobcode and j.functioncode=m.functioncode and (m.content like '%"+strQuery+"%' or b.content like '%"+strQuery+"%')";
				rs.Open(strSql);
				if(!rs.IsEOF())
				{
					while(!rs.IsEOF())
					{
						rs.GetFieldValue("corpname",strCorpName);
						rs.GetFieldValue("contract",strContract);
						rs.GetFieldValue("telephone",strTele);
						rs.GetFieldValue("content",strContent);
						rs.GetFieldValue("Knowledge",strKnowledge);
						strMsg.Format("%s招聘：%s 学历要求：%s 联系人：%s 联系电话：%s",strCorpName,strContent,strKnowledge,strContract,strTele);
						::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
							MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
							strMsg,MyReg::GetPayTypeUnion(),"20");
						str="发送";
						rsc.Open("select * from Mh_SMS_Log where 1=0");						
						rsc.AddNew();
						rsc.SetFieldValue("UserPhone",strClientPhone);
						rsc.SetFieldValue("SmsType",str);
						rsc.SetFieldValue("Content",strMsg);
						rsc.SetFieldValue("MOMT",1);
						rsc.Update();
						rsc.Close();
						rs.MoveNext();
					}
				}
				else
				{
					::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
						MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
						"没有您要查询的职位。请查询其他的职位。",MyReg::GetPayTypeUnion(),"20");
					str="发送";
					rsc.Open("select * from Mh_SMS_Log where 1=0");						
					rsc.AddNew();
					rsc.SetFieldValue("UserPhone",strClientPhone);
					rsc.SetFieldValue("SmsType",str);
					str="没有您要查询的职位。请查询其他的职位。";
					rsc.SetFieldValue("Content",str);
					rsc.SetFieldValue("MOMT",1);
					rsc.Update();
					rsc.Close();
				}
				rs.Close();
			}
			else
			{
				::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
					MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
					"您没有输入要查询的关键字，请重新发送短信查询！查询信息每条0.20元。",MyReg::GetPayTypeUnion(),"10");
				str="发送";
				rsc.Open("select * from Mh_SMS_Log where 1=0");						
				rsc.AddNew();
				rsc.SetFieldValue("UserPhone",strClientPhone);
				rsc.SetFieldValue("SmsType",str);
				str="您没有输入要查询的关键字，请重新发送短信查询！查询信息每条0.20元。";
				rsc.SetFieldValue("Content",str);
				rsc.SetFieldValue("MOMT",1);
				rsc.Update();
				rsc.Close();
				
			}
			mo_db.Close();
		}
		else
		{
			::SGIP_Send("ZPZD",MyReg::GetUnionSPNumber(),strClientPhone,MyReg::GetUnionUsername(),
				MyReg::GetUnionPassword(),MyReg::GetUnionIP(),MyReg::GetUnionPort(),strClientPhone,
				"查询招聘信息失败，请重新发送短信查询！每条0.20元。",MyReg::GetPayTypeUnion(),"10");					
		}
	
}



// CJob 消息处理程序