//////////////////////////////////////////////////////////////////////////////////////////								最新潮流//////////////////////////////////////////////////////////////////////////////////////////								/////////////////////////////////////////////////////////////////////////////////////////說明：//	(1) DCODE :ZXNY   FEE :15.00  //	(2) 9193   MSG: NY//										CL//						            06.07.27		///////////////////////////////////////////////////////////////////////////////////////	#include <stdio.h>#include <string.h>#include <stdlib.h>//#define  WINDOWS_NT#ifdef   WINDOWS_NT#include <winsock.h>#pragma comment (lib,"ws2_32.lib")#include  <mysql.h>#pragma comment(lib,"libmySQL.lib")#include "./include/define.h"#include "./include/sm_tools.h"#include "./include/sm_db.h"#define INIFILE "./config/sm.ini"#define sleep    Sleep#else#define  GetProfileStringMe GetProfileString#include <unistd.h>#include "mysql/mysql.h"#include "../include/define.h"#include "../include/sm_tools.h"#include "../include/sm_db.h" #define INIFILE "../config/sm.ini" #endif#define DEBUG  #define SELF_TYPE 	"zxcl"//來自main.cppextern MYSQL *myconn;                                   //主函數(shù)已經(jīng)初始化,所有的模塊共用一個長連接         extern char  SP_ID[24];               			//特服號,在這里是5566//只在本文件中所用的全局變量,用static 修飾:static char service_phone[24];      			//客服電話 static char linkid[32];static char msisdntype[4];static char sp_id_extern[24];                           //servicecode //只在本文件中所用的函數(shù),用static 修飾:static int ScanMsgSession();                                                    		//本模塊只是從com_recv_session表中取出相關(guān)信息static int DoScanMsgSession(char *servicecode,char *srctermid,char *msg,char *dcode,char *feetype,float fee);static int SendUser(char *msisdn,char *msg,char *dcode,float fee,char *fee_msisdn,int flag);static int InsertUser(char *msisdn,char *msgcontent);static int InsertUserCan(char *msisdn,char *msgcontent);//初始化本業(yè)務(wù),放入主線程的InitPara()模塊中int InitZxcl(){	GetProfileStringMe(INIFILE,"COMMON","TELEPHONE","",service_phone);        //從配置文件讀取客服電話	return 0;}//本業(yè)務(wù)入口,放入主線程的 DoThread()模塊,在main.h中聲明int DoZxcl(){	int retval;		retval=ScanMsgSession();         //處理COM_RECV_SESSION	sleep(1);		return retval;}	//從COM_RECV_SESSION中取的數(shù)據(jù)static int ScanMsgSession(){	MYSQL_RES *res =NULL;	MYSQL_ROW row;	int  id;	char sql[512];	char servicecode[12];	char srctermid[24];	char msg[256];	char dcode[]="ZXNY";	char feetype[]="03";	float fee=12.0;	memset(sql,0,sizeof(sql));        sprintf(sql,"SELECT ID,SRCTERMID,UPPER(MSGCONTENT),LINKID\	              FROM COM_RECV RECV\				  WHERE RECV.FLAG ='0' AND (UPPER(MSGCONTENT)='NY' OR UPPER(MSGCONTENT)='TDNY' OR  MSGCONTENT='0')  LIMIT 20"); 	//puts(sql);	if(QuerySQL(sql,&myconn,&res)!=0)		{		writelog(SELF_TYPE,"查詢COM_RECV_SESSION失敗");		return -1; 		}	if(res ==NULL)		{		return -1;		}	while(row =mysql_fetch_row(res))		{		id =atoi(row[0]);		strcpy(srctermid,row[1]);		strcpy(msg,row[2]);		strcpy(linkid,row[3]);		//puts(srctermid);		//puts(msg);				memset(sql,0,sizeof(sql));		sprintf(sql,"UPDATE COM_RECV SET FLAG=1,DEAL_DATE=now()+0 WHERE ID=%d",id);		if(DoSQL(sql,&myconn)!=0)			{			writelog(SELF_TYPE,"更新COM_RECV_SESSION失敗");			mysql_free_result(res);			return -1;			}		DoScanMsgSession(servicecode,srctermid,msg,dcode,feetype,fee);		}	mysql_free_result(res);	return 0;}//處理COM_RECV_SESSION中取得的信息static int  DoScanMsgSession(char *servicecode,char *srctermid,char *msg,char *dcode,char *feetype,float fee){	      	int  num =0;                             //選手的編號	int  total=0;	char sql[1024];	char msgcontent[256];	memset(sql,0,sizeof(sql));	memset(msgcontent,0,sizeof(msgcontent));	chop(msg);	trim(msg,' ');	if(*msg=='0')		{		sprintf(msgcontent,"回復(fù)QY測試前世界情緣,回復(fù)XY參加校園在線，回復(fù)QN參加知心女友，回復(fù)YS參加飲食健康，詢：02586070434");		}	else if(strcmp(msg,"NY")==0)		{		InsertUser(srctermid,msgcontent);		SendUser(srctermid,msgcontent,dcode,fee,srctermid,0);		strcpy(linkid,"");		sprintf(msgcontent,"夏季是女孩子最喜愛的季節(jié).喜歡的印花、曼妙飛舞的蝴蝶,混合各種面料如錦織和鉤花編織,繡花與亮片等奢華細(xì)節(jié),那是一種難以忘記的美麗.");		SendUser(srctermid,msgcontent,dcode,fee,srctermid,0);		return 0;		}     	else if(strcmp(msg,"TDNY")==0)		{		InsertUserCan(srctermid,msgcontent);				}		SendUser(srctermid,msgcontent,dcode,fee,srctermid,0);        	return 0;}//處理定制static int InsertUser(char *msisdn,char *msgcontent){	MYSQL_RES *res=NULL;	MYSQL_ROW row;	char sql[512];	int  flag=0;	memset(sql,0,sizeof(sql));	sprintf(sql,"SELECT FLAG FROM USER_ZXCL WHERE MSISDN='%s' LIMIT 1",msisdn);		if(QuerySQL(sql,&myconn,&res)!=0)		{		writelog(SELF_TYPE,"查詢USER_ZXCL失敗");		return -1; 		}	if(row=mysql_fetch_row(res))		{		flag =atoi(row[0]);		if(flag ==0)              		{			flag =2;              		}		}		mysql_free_result(res);	if(flag ==1)		{		sprintf(msgcontent,"您已經(jīng)定制了此業(yè)務(wù)無須再定制，謝謝!");		return 1;		}        if(flag ==2)               {		sprintf(sql,"UPDATE USER_ZXCL SET FLAG =1,REG_DATE=now()+0 WHERE MSISDN='%s' ",msisdn);		puts(sql);        	if(DoSQL(sql,&myconn)!=0)			{			writelog(SELF_TYPE,"寫UPDATE 失敗");			return 0;			}		sprintf(msgcontent,"您好，您已成功定制由江蘇三棱科技提供的知心女友業(yè)務(wù)，資費12元/每月,退定方式發(fā)送TDNY到9193,客服電話:02586070434");		return 1;               }	sprintf(sql,"INSERT INTO USER_ZXCL(ICPID,MSISDN,RECV_NUM,REG_DATE,FLAG)\                     VALUES('MO','%s',1,now()+0,'1')",\		     msisdn		     );	if(DoSQL(sql,&myconn)!=0)		{		writelog(SELF_TYPE,"插入USER表失敗");		return 0;		}	sprintf(msgcontent,"您好，您已成功定制由江蘇三棱科技提供的知心女友業(yè)務(wù)，資費12元/每月,退定方式發(fā)送TDNY到9193,客服電話:02586070434");	return 0;}//處理取消static int InsertUserCan(char *msisdn,char *msgcontent){	MYSQL_RES *res=NULL;	MYSQL_ROW row;	char sql[512];	int  flag=0;	memset(sql,0,sizeof(sql));	sprintf(sql,"SELECT FLAG FROM USER_ZXCL WHERE MSISDN='%s' LIMIT 1",msisdn);	if(QuerySQL(sql,&myconn,&res)!=0)		{		writelog(SELF_TYPE,"查詢USER_QGJL失敗");		return -1; 		}	if(row=mysql_fetch_row(res))		{		flag =atoi(row[0]);		}	mysql_free_result(res);	if(flag ==0)		{		sprintf(msgcontent,"您已經(jīng)取消了此業(yè)務(wù)無須再取消，謝謝!");		return 1;		}	sprintf(sql,"UPDATE USER_ZXCL SET FLAG =0, CANCEL_DATE=now()+0 WHERE MSISDN='%s' ",msisdn); 	puts(sql);		if(DoSQL(sql,&myconn)!=0)		{		writelog(SELF_TYPE,"更新USER表失敗");		return 0;		}	sprintf(msgcontent,"您好，您已經(jīng)成功退定由江蘇三棱科技提供的知心女友業(yè)務(wù)，回復(fù)0可查詢更多業(yè)務(wù)，客服電話:02586070434");	return 0;}//發(fā)送模塊static int SendUser(char *msisdn,char *msg,char *dcode,float fee,char *fee_msisdn,int flag){	SEND_STRUC sendstruc;	int linkid_flag;	memset(&sendstruc,0,sizeof(sendstruc));		if(strcmp(msisdn,fee_msisdn) == 0)		{		sendstruc.cFeeUserType=0;		strcpy(sendstruc.sFeeTerminalID,"");		}	else		{		sendstruc.cFeeUserType=3;		strcpy(sendstruc.sFeeTerminalID,fee_msisdn);		}	strcpy(sendstruc.icpid,"MO");	sendstruc.nMsgLevel = 3;	strcpy(sendstruc.sServiceID,dcode);	sendstruc.nMsgFormat = 15;	strcpy(sendstruc.sValidTime,"");	strcpy(sendstruc.sAtTime,"");	strcpy(sendstruc.sSrcTermID,SP_ID);	strcat(sendstruc.sSrcTermID,sp_id_extern);	strcpy(sendstruc.sDesTermID,msisdn);	sendstruc.sFeeCode = fee;	sendstruc.cTpPid = 0;	sendstruc.cTpUdhi = 0;	strcpy(sendstruc.step,"9");	getnowdate(sendstruc.Send_Date);	strcpy(sendstruc.sMsgContent,msg);	checksql(sendstruc.sMsgContent);	strcpy(sendstruc.linkid,linkid);//	strcpy(sendstruc.DesTermIDType,msisdntype);	linkid_flag=1;	switch(flag)		{		case 0:		//免費、錯誤信息		//	strcpy(sendstruc.sServiceID,"FREE");			strcpy(sendstruc.sFeeType,"01");			sendstruc.nNeedReply = 0;			break;		case 2:		//按條點播(收費)			strcpy(sendstruc.sFeeType,"02");			sendstruc.nNeedReply = 0;			break;		case 3:		//包月點播(不收費的)			strcpy(sendstruc.sFeeType,"03");			sendstruc.nNeedReply = 0;			break;		case 5:		//包月扣費			strcpy(sendstruc.sFeeType,"03");			sendstruc.nNeedReply = 2;			break;			default:	//其它						strcpy(sendstruc.sServiceID,"FREE");			strcpy(sendstruc.sFeeType,"01");			sendstruc.nNeedReply = 0;			break;		}	SendMsg(&sendstruc,&myconn);	return 0;}