xltsm.cpp

小灵通（网通）短信接口程序

// xltsm.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include "smset.h"
#include "smei.h"
#include "SendSM.h"
#include "ChkQueue.h"

int  nLclPort	  = 9988;        // 本地端口
char szServerIP[65] = "202.108.250.176"; // 远程网关地址
int	 nServerPort  = 9890;        // 网关端口号
char szCngpUser[32] = "Bjzhx";	 // 登录用户名
char szCngpPwd[32] = "1234";	 // 登录口令
char szIcpNbr[9] = "94011";		 // 特服号
char szCorpId[11] = "3001888882"; // 企业代码
int nDeliverWait = 5;	// 扫描间隔

char szCorp[20]="";		// 智响通讯
char szTel[20]="";		// 公司电话
char szWeb[50]="";		// 公司主页
char szCmccTest[50] = ""; // CMCC信息
char szCmdSet[161]="";		// 当用户发送无效命令字时提示

static CMyDatabase db; // 数据库连接

void EnrollFlag()
{
	static char Mark[8] = { '|', '/', '-', '\\', '|', '/', '-', '\\' };
	static int Index = 0;
	cprintf("\b%c", Mark[Index]);
	Index = (Index + 1) % 8;
	return;
}

int main()
{
	LPCSTR lpcszPhsCfgFile = "xltsm.ini";
	LPCSTR lpcszIsmrCfgFile = "e2hismr.ini";

	SetConsoleTitle("网通小灵通短信接口Ｖ１·０"); // 由于要移动标题，为简化处理，要求全是全角字符或汉字

	printf("\n网通小灵通短信接口 版本1.0 版权（C）归北京智响通讯技术有限公司所有\n");

	printf("\n从文件%s读取PHS配置参数...", lpcszPhsCfgFile);
	GetSetting(lpcszPhsCfgFile, "CNGP", "local_port", 9988, &nLclPort);	// 本地端口
	GetSetting(lpcszPhsCfgFile, "CNGP", "server_ip", "202.108.250.176", szServerIP, sizeof(szServerIP)); // 远程网关地址
	GetSetting(lpcszPhsCfgFile, "CNGP", "server_port", 9890, &nServerPort);			// 网关端口号
	GetSetting(lpcszPhsCfgFile, "CNGP", "user", "Bjzhx", szCngpUser, sizeof(szCngpUser));	// 登录用户名
	GetSetting(lpcszPhsCfgFile, "CNGP", "pwd", "1234", szCngpPwd, sizeof(szCngpPwd));	// 登录口令
	GetSetting(lpcszPhsCfgFile, "CNGP", "icpnbr", "94011", szIcpNbr, sizeof(szIcpNbr));	// 特服号
	GetSetting(lpcszPhsCfgFile, "CNGP", "CorpId", "3001888882", szCorpId, sizeof(szCorpId)); // 企业代码
	GetSetting(lpcszPhsCfgFile, "CNGP", "timeout", 5, &nDeliverWait);
	printf("成功！\n");

	printf("\n从文件%s读取ISMR配置参数...", lpcszIsmrCfgFile);
	GetSetting(lpcszIsmrCfgFile, "Translation", "CTIVR", "智响通讯", szCorp, sizeof(szCorp));
	GetSetting(lpcszIsmrCfgFile, "Translation", "TEL", "010-82856615", szTel, sizeof(szTel));
	GetSetting(lpcszIsmrCfgFile, "Translation", "WEB", "http://www.ctivr.com", szWeb, sizeof(szWeb));
	GetSetting(lpcszIsmrCfgFile, "Translation", "CMCCTEST", "北京，智响通讯，01658，901500", szCmccTest, sizeof(szCmccTest));
	GetSetting(lpcszIsmrCfgFile, "Translation", "CMDSET", "EDU-家校通 TBLX-同步练习 YJJC-有奖竞猜 TBJY-同步记忆 XXCD-学习辞典", szCmdSet, sizeof(szCmdSet));	// 命令菜单
	printf("成功！\n");

	AfxSocketInit();

	mkdir("./phsqueue");

	SOCKET sktDeliver = _login(szServerIP, nServerPort, szCngpUser, szCngpPwd, LOGINMODE_DELIVER);
	if (sktDeliver == INVALID_SOCKET){
		printf("\n登录CNGP网关失败。\n");
		return FALSE;
	}

	printf("\n程序开始等待并处理短信...成功！\n"); 

	for ( ; ; ) {
		try {
			if (_delivery(sktDeliver, nDeliverWait) != ERROR_SUCCESS){
				_logout(sktDeliver);
				do {
					Sleep(5000);
					printf("\n重连CNGP网关...");
					sktDeliver = _login(szServerIP, nServerPort, szCngpUser, szCngpPwd, LOGINMODE_DELIVER);
				} while (sktDeliver == INVALID_SOCKET);
				printf("成功！\n");
			}
			_submit(szServerIP, nServerPort, szCngpUser, szCngpPwd);
			if (!ProcDelivery(0)){
				CheckMonthTable(db);
			}
			EnrollFlag();
			/*
			if (_activetest(sktDeliver) != ERROR_SUCCESS) throw (const char *)"reconnect";
			Sleep(nDeliverWait * 1000);
			*/
		} 
		catch(const char *e){
			if (!strcmp(e, "reconnect")){
				sktDeliver = _login(szServerIP, nServerPort, szCngpUser, szCngpPwd, LOGINMODE_DELIVER);
				if (sktDeliver == INVALID_SOCKET){
					printf("\n重连CNGP网关...失败");
					Sleep(nDeliverWait);
					continue;
				}
			} else {
				printf("\n关键错误：%s。", e);
			}
			Sleep(nDeliverWait * 1000);
		}
		catch(...){
			printf("\n内存访问非法。");
		}
	}

	_logout(sktDeliver);

	printf("\n信息：服务被成功终止!\n");

	return 0;
}