llysgb.cpp

移动梦网平台主程序

			if(strcmp(content,"A")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"B")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"C")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else
			{
				if(strcmp(content,"")==0)
				{
					sprintf(msg,"您回复的内容有错,请查实后正确回复,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1663");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费		
					}
					return 0;				
				}
				if(len!=4)
				{
					sprintf(msg,"请从0-9中任意选择4个数字回复过来,只要选对且顺序正确,就可能获得100元话费,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1663");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费	
					}
					return 0;	
				}
				for(i=0;i<len;i++)
				{
					if(content[i]<'0'||content[i]>'9')
					{
						sprintf(msg,"请从0-9中任意选择4个数字回复过来,只要选对且顺序正确,就可能获得100元话费,咨询电话%s",service_phone);
						sprintf(sp_id_extern,"1663");
						if(state==1)
						{
							SendUser(msisdn,msg,dcode,fee,1);	//点播
						}
						if(state==2)
						{
							SendUser(msisdn,msg,dcode,fee,0);	//免费
						}
						return 0;				
					}
				}
				sprintf(sql,"INSERT INTO LLYS_LT(NUM,MSISDN,REG_DATE) VALUES('%s','%s','%s')",content,msisdn,getnowdate(day));
				if(DoSQL(sql,&myconn)!=0)
				{
					writelog(SELF_TYPE,"插入玲珑乐透出错");
					return 0;
				}
				strcpy(msg,"尊敬的用户,您的数据已被成功受理,祝您好运!");
				strcpy(sp_id_extern,"");
				if(state==1)
				{
					SendUser(msisdn,msg,dcode,fee,1);	//点播
				}
				if(state==2)
				{
					SendUser(msisdn,msg,dcode,fee,0);	//免费	
				}
				return 0;
			}
			break;
		case 4:
			upper(content);
			if(strcmp(content,"A")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"B")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"C")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else
			{	if(strcmp(content,"")==0)
				{
					sprintf(msg,"您回复的内容有错,请查实后正确回复,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1664");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费
					}
					return 0;				
				}			
				dobet(content,msisdn,dcode,fee,type);
			}
			break;
		case 5:	
			upper(content);
			if(strcmp(content,"A")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"B")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"C")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else
			{
				if(strcmp(content,"")==0)
				{
					sprintf(msg,"您回复的内容有错,请查实后正确回复,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1665");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费
					}
					return 0;				
				}
				upper(content);
				if(abs(strcmp(content,"C1"))&&abs(strcmp(content,"C2"))&&abs(strcmp(content,"C3"))&&abs(strcmp(content,"C4"))
					&&abs(strcmp(content,"C5"))&&abs(strcmp(content,"C6")))
				{
					strcpy(content,"C6");
				}
				sprintf(sql,"SELECT %s FROM LLYS_EQ WHERE ID=1",content);
				retval=QuerySQL(sql,&myconn,&res1);
				if(retval!=0)
				{
					writelog(SELF_TYPE,"查询题号出错!");
					return 0;
				}
				if(res1==NULL)
				{
					return 0;
				}
				while(row=mysql_fetch_row(res1))
				{
					strcpy(msg,row[0]);
					
				}	
				mysql_free_result(res1);
				strcpy(sp_id_extern,"");
				if(state==1)
				{
					SendUser(msisdn,msg,dcode,fee,1);	//点播
				}
				if(state==2)
				{
					SendUser(msisdn,msg,dcode,fee,0);	//免费
				}
				return 0;
			}
			break;
		case 6:
			upper(content);
			if(strcmp(content,"A")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"B")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"C")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else
			{	if(strcmp(content,"")==0)
				{
					sprintf(msg,"您回复的内容有错,请查实后正确回复,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1666");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费
					}
					return 0;				
				}		
				dobet(content,msisdn,dcode,fee,type);
			}
			break;
		case 7:
			upper(content);
			if(strcmp(content,"A")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"B")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else if(strcmp(content,"C")==0)
			{
				getcontent(content,type,msisdn,dcode,fee);
			}
			else
			{	if(strcmp(content,"")==0)
				{
					sprintf(msg,"您回复的内容有错,请查实后正确回复,咨询电话%s",service_phone);
					strcpy(sp_id_extern,"1667");
					if(state==1)
					{
						SendUser(msisdn,msg,dcode,fee,1);	//点播
					}
					if(state==2)
					{
						SendUser(msisdn,msg,dcode,fee,0);	//免费
					}
					return 0;				
				}						
				dobet(content,msisdn,dcode,fee,type);
			}
			break;
		default:
			sprintf(msg,"尊敬的用户,您所发的号码错误,请核实后再发!咨询电话%s",service_phone);
			strcpy(sp_id_extern,"");
			if(state==1)
			{
				SendUser(msisdn,msg,dcode,fee,1);	//点播
			}
			if(state==2)
			{
				SendUser(msisdn,msg,dcode,fee,0);	//免费
			}
			return 0;
	}
	if(strcmp(content,"A")==0||strcmp(content,"B")==0||strcmp(content,"C")==0)
	{
		strncpy(today,getnowdate(day),8);
		today[8]='\0';
		sprintf(sql,"SELECT COUNT(*) FROM LLYS_ABC_STAT WHERE DATE='%s'",today);
		retval=QuerySQL(sql,&myconn,&res1);
		if(retval!=0)
		{
			writelog(SELF_TYPE,"查询是不是今天出错");
			return 0;
		}
		if(res1==NULL)
		{
			return 0;
		}
		if(row=mysql_fetch_row(res1))
		{
			flag=atoi(row[0]);
			mysql_free_result(res1);
		}
		else
		{
			mysql_free_result(res1);
			flag=0;
		}
		if(flag<=0)
		{
			sprintf(sql,"INSERT INTO LLYS_ABC_STAT VALUES('','%s','0','0','0')",today);
			if(DoSQL(sql,&myconn) != 0)
			{
				writelog(SELF_TYPE,"插入每日ABC数据出错");
				return 0;
			}
		}
		sprintf(sql,"UPDATE LLYS_ABC_STAT SET NUM%s=NUM%s+1 WHERE DATE='%s'",content,content,today);
		if(DoSQL(sql,&myconn) != 0)
		{
			writelog(SELF_TYPE,"更新每日ABC数据出错");
			return 0;
		}
			
	}
	return 0;
}
static int haveuser(char *msisdn)
{
	MYSQL_ROW row;
	MYSQL_RES *res = NULL;
	char sql[500],flag[2],free_flag[2];
	int retval;
	sprintf(sql,"SELECT FLAG,FREE_FLAG FROM USER_LLYS_POINT WHERE MSISDN='%s' AND SV_CODE='LLYS'",msisdn);
	retval = QuerySQL(sql,&myconn,&res);
	if(retval != 0)
	{
		writelog(SELF_TYPE,"查询指令失败");
		return 0;
	}
	if(res == NULL)
	{
		return 0;
	}
	if( row = mysql_fetch_row(res))
	{
		strcpy(flag,row[0]);
		strcpy(free_flag,row[1]);
		mysql_free_result(res);
		if(strcmp(flag,"1")==0)
		{
			if(strcmp(free_flag,"1")==0)
			{
				return 2;
			}
			else
			{
				return 1;
			}
		}
		else
		{
			return 3;
		}
	}
	else
	{
		mysql_free_result(res);
		return 4;
	}
}

//从LLYS＿MENU中提取内容和模拟操作
static int getcontent(char *content,int type,char *msisdn,char *dcode,float fee)
{
	int retval,flag,state;
	char sql[500];
	MYSQL_ROW row;
	MYSQL_RES *res = NULL;
	char msg[500],day[20];
	char *argv[2];
	
	memset(sql,0,sizeof(sql));
	state=haveuser(msisdn);
	sprintf(sql,"SELECT FLAG%s,%s FROM LLYS_MENU WHERE ID=%d",content,content,type);
	retval=QuerySQL(sql,&myconn,&res);
	if(retval!=0)
	{
		writelog(SELF_TYPE,"查询是插入还是读取出错!");
		return 0;
	}
	if(res==NULL)
	{
		return 0;
	}
	if(row=mysql_fetch_row(res))
	{
		flag=atoi(row[0]);
		strcpy(msg,row[1]);
	}
	mysql_free_result(res);
	if(flag==0)
	{
		sprintf(sp_id_extern,"166%d",type);
		if(state==1)
		{
			SendUser(msisdn,msg,dcode,fee,1);	//点播
		}
		if(state==2)
		{
			SendUser(msisdn,msg,dcode,fee,0);	//免费
		}
		return 0;
	}
	else if(flag==1)
	{
		if(splitarg(msg,argv,2) != 2)
		{
			argv[1] = " ";
		}
		sprintf(sql,"INSERT INTO COM_RECV(ICPID,LINKID,MSGLEVEL,SERVICEID,SERVICECODE,MSGFORMAT,SRCTERMID,ISREPLY,MSGCONTENT,DESTTERMID,TPPID,TPUDHI,RECV_DATE,FLAG)\
	             VALUES('YS','%s',0,'9999','%s',15,'%s',0,'%s','5566',0,0,'%s',0)",
	             linkid,argv[0],msisdn,argv[1],getnowdate(day));
		if(DoSQL(sql,&myconn) != 0)
		{
			writelog(SELF_TYPE,"模拟用户上行出错!");
			return 0;
		}
		return 0;
	}
}
//得到最大ID
static int getmaxid(char *tablename)
{
	int retval,max;
	char sql[500];
	MYSQL_ROW row;
	MYSQL_RES *res = NULL;
	max=0;
	sprintf(sql,"SELECT MAX(ID) FROM %s",tablename);
	retval = QuerySQL(sql,&myconn,&res);
	if(retval != 0)
	{
		writelog(SELF_TYPE,"查询指令失败");
		return 0;
	}
	if(res == NULL)
	{
		return 0;
	}
	if( row = mysql_fetch_row(res))
	{
		max= atoi(row[0]);
	}
	mysql_free_result(res);
	return max;
}
//产生一个随机数
static int getrandnum(int max)
{
	float retval;
	int i;
	retval = (float)(rand())/(float)(RAND_MAX);
	retval = retval * max;
	i = (int)(retval);
	return i;
}