pbserver.cpp

tuxede下面的编程

			/*EXEC SQL ROLLBACK;*/
			tpabort(0);
			tux_return(sendbuf,"往表EMP插入记录出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}	

	}
	/*提交*/
	/*EXEC SQL commit work;
	if(sqlca.sqlcode!=0)
	{       
		EXEC SQL ROLLBACK;
		tux_return(sendbuf,"COMMIT WORK 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}*/
	/*commit the transaction*/
	if (tpcommit(0) == -1) 
	{
		tux_return(sendbuf,"tpcommit()出错",0,(char *)tpstrerror(tperrno));	
	}
	tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}



/*EMP_GET SERVICES*/
EMP_GET(TPSVCINFO *rqst)
{
	FBFR32 *sendbuf=NULL;
	FLDLEN32 len=0;
	int i=0;
	int iRet=0;
	int iOc=0;
	int iRows=0;


	/*分配返回缓冲区并初始化*/
	sendbuf = IniSendBuf(20480);
	if(sendbuf==NULL)
	{
		tpreturn( TPFAIL, 0, (char *)sendbuf, 0, 0 );
	}
	
	
	/*从EMP表中取数据*/
	EXEC SQL DECLARE cur_emp_get CURSOR FOR 
		SELECT EMPNO, ENAME,JOB,MGR,to_char(HIREDATE,'yyyy/mm/dd hh24:mi:ss'),SAL,COMM,DEPTNO FROM EMP;
	if(sqlca.sqlcode!=0)
	{ 
		tux_return(sendbuf,"DECLARE CURSOR 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	
	EXEC SQL OPEN cur_emp_get;
	if(sqlca.sqlcode!=0)
	{
		EXEC SQL CLOSE cur_emp_get;
		tux_return(sendbuf,"OPEN CURSOR 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	i = 0;
	while(1)
	{
		al_empno=0;
		strcpy(ac_ename,"");
		strcpy(ac_job,"");
		al_mgr=0;
		strcpy(ac_hiredate,"");
		af_sal=0;
		af_comm=0;
		al_deptno=0;
		/*EXEC SQL FETCH authors INTO :al_empno :ind_empno, :ac_ename :ind_ename,:ac_job :ind_job,:al_mgr :ind_mgr,:ac_hiredate :ind_hiredate,:af_sal :ind_sal,:af_comm :ind_comm,:al_deptno :ind_deptno;
		*/
		EXEC SQL FETCH cur_emp_get INTO :al_empno, :ac_ename,:ac_job,:al_mgr,:ac_hiredate,:af_sal,:af_comm,:al_deptno;
		if( sqlca.sqlcode  == SQLNOTFOUND)
		{
			break;
		}
		/*当取出的值是null时,sqlca.sqlcode = -1405*/
		if ((sqlca.sqlcode != 0)&&(sqlca.sqlcode!= SQLNULL))
		{  	
			/*FETCH CURSOR失败 */
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"FETCH CURSOR 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}	
		
#ifdef _DEBUG_
		 userlog("FETCHED ROW：%d\t%s\t%s\t%d\t%s\t%f\t%f\t%d\n",al_empno,ac_ename,ac_job,al_mgr,ac_hiredate,af_sal,af_comm,al_deptno);
#endif
		 
		len = sizeof(al_empno);
		if(Fchg32( sendbuf, EMPNO, i, (char *)&al_empno, (FLDLEN32)len )<0)
		{	
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(EMPNO) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		len = sizeof(ac_ename);
		if(Fchg32( sendbuf, ENAME, i, ac_ename,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(ENAME) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len = sizeof(ac_job);
		if(Fchg32( sendbuf, JOB, i, ac_job,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(JOB) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len = sizeof(al_mgr);
		if(Fchg32( sendbuf, MGR, i, (char*)&al_mgr,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(MGR) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len = sizeof(ac_hiredate);
		if(Fchg32( sendbuf, HIREDATE, i, ac_hiredate,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(HIREDATE) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len=sizeof(af_sal);
		if(Fchg32( sendbuf, SAL, i, (char *)&af_sal, len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(SAL) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len = sizeof(af_comm);
		if(Fchg32( sendbuf, COMM, i, (char*)&af_comm,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(COMM) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		
		len = sizeof(al_deptno);
		if(Fchg32( sendbuf, DEPTNO, i, (char *)&al_deptno,len )<0)
		{
			EXEC SQL CLOSE cur_emp_get;
			tux_return(sendbuf,"Fchg32(DEPTNO) 出错",0,(char *)Fstrerror32(Ferror32));
		}
		i++;
	}
	EXEC SQL CLOSE cur_emp_get;;
	if (sqlca.sqlcode != 0)
	{  	
		/*CLOSE CURSOR失败*/  
		tux_return(sendbuf,"CLOSE CURSOR 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	
	#ifdef _DEBUG_
		Fprint32(sendbuf); 
	#endif
	tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}




/*EMP_TAB SERVICES*/
EMP_TAB(TPSVCINFO *rqst)
{
	FBFR32 *sendbuf=NULL;
	FLDLEN32 len=0;
	int i=0;
	int iRet=0;
	int iOc=0;
	int iRows=0;
	char szRow[500];
	char szHead[500];
	
	typedef struct
	{
		int iNo;
		char szName[20];
	}str_dept;
	str_dept lstr_dept[50];
	int iDept=0;

	

	/*分配返回缓冲区并初始化*/
	sendbuf = IniSendBuf(20480);
	if(sendbuf==NULL)
	{
		tpreturn( TPFAIL, 0, (char *)sendbuf, 0, 0 );
	}
	
	/*取所有的部门*/
	EXEC SQL DECLARE cur_emp_dept CURSOR FOR 
		SELECT DISTINCT deptno FROM EMP;
	if(sqlca.sqlcode!=0)
	{ 
		tux_return(sendbuf,"DECLARE CURSOR 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	EXEC SQL OPEN cur_emp_dept;
	if(sqlca.sqlcode!=0)
	{
		EXEC SQL CLOSE cur_emp_dept;
		tux_return(sendbuf,"OPEN CURSOR:cur_emp_dept 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	i = 0;
	while(1)
	{
		al_deptno=0;
		EXEC SQL FETCH cur_emp_dept INTO :al_deptno;
		if( sqlca.sqlcode  == SQLNOTFOUND)
		{
			break;
		}
		/*当取出的值是null时,sqlca.sqlcode = -1405*/
		if ((sqlca.sqlcode != 0)&&(sqlca.sqlcode!= SQLNULL))
		{  	
			/*FETCH CURSOR失败 */
			EXEC SQL CLOSE cur_emp_dept;
			tux_return(sendbuf,"FETCH CURSOR:cur_emp_dept 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}	
		
		#ifdef _DEBUG_
		 	userlog("FETCHED dept：%d\n",al_deptno);
		#endif
		
		/*根据部门的代号取名称*/
		c_tmp[0]='\0';
		EXEC SQL select dname into :c_tmp
		from DEPT 
		where deptno = :al_deptno;
		if (sqlca.sqlcode != 0)
		{  	
			tux_return(sendbuf,"select dname from DEPT出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}
		lstr_dept[i].iNo=al_deptno;
		strcpy(lstr_dept[i].szName,c_tmp);
		i++;
		if(i>50)
		{
			EXEC SQL CLOSE cur_emp_dept;
			tux_return(sendbuf,"部门太多！",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}
		
	}		
	EXEC SQL CLOSE cur_emp_dept;
	if (sqlca.sqlcode != 0)
	{  	
		/*CLOSE CURSOR失败*/  
		tux_return(sendbuf,"CLOSE CURSOR:cur_emp_dept 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	/*取出的部门数*/
	iDept = i;
	/*求每个部门的工资总数*/
	sprintf(szHead,"%s","部门名称");
	sprintf(szRow,"%s","工资总数");
	for(i=0;i<iDept;i++)
	{	
		sprintf(szHead,"%s|%13s",szHead,lstr_dept[i].szName);
		
		af_sal =0;
		al_deptno=lstr_dept[i].iNo;
		EXEC SQL select sum(sal) into :af_sal
		from EMP 
		where deptno= :al_deptno;
		if (sqlca.sqlcode != 0)
		{  	
			/*select sum(sal)失败*/  
			tux_return(sendbuf,"select sum(sal)失败",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}
		sprintf(szRow,"%s|%23.2f",szRow,af_sal);
	}
	
	len = sizeof(szHead);
	if(Fchg32(sendbuf, CROSSTAB, 0, szHead, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	len = sizeof(szRow);
	if(Fchg32(sendbuf, CROSSTAB, 1, szRow, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	/*notice: in the PB client the datawindow font must be chinese font
	then this will work ok*/
	userlog("%s\n",szHead);
	userlog("%s\n",szRow);
	tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}


/*EMP_COS SERVICES*/
/*EMP_COS(TPSVCINFO *rqst)
{
	FBFR32 *sendbuf=NULL;
	FBFR32 *rcvbuf=NULL;
	FLDLEN32 len=0;
	int i=0;
	int iRet=0;
	int iOc=0;
	int iRows=0;
	char szHead[2500]="";
	char szNode[2500]="";
	char szAmount[2500]="";
	char szSum[2500]="";
	int iOilTypes=0;
	
	
	
	userlog("begin EMP_COS\n");
	//分配返回缓冲区并初始化
	sendbuf = IniSendBuf(20480);
	if(sendbuf==NULL)
	{
		tpreturn( TPFAIL, 0, 0, 0L, 0 );
	}
	
	userlog("接收客户端来的数据\n");
	//接收客户端来的数据
	rcvbuf = (FBFR32 *)rqst->data;
	#ifdef _DEBUG_
		fprintf(stdout,"EMP_COS begin Fprint32......\n");
		Fprint32(rcvbuf);
		fprintf(stdout,"EMP_COS end Fprint32......\n");
	#endif	
	len = sizeof(ac_nodeno);
	ac_nodeno[0]='\0';
	if(Fget32(rcvbuf,NODENO,0,ac_nodeno,&len)== -1)
	{
		tux_return(sendbuf,"Fget32(NODENO) 出错",0,(char *)Fstrerror32(Ferror32));
		
	}
	
	len = sizeof(ac_begin_date);
	ac_begin_date[0]='\0';
	if(Fget32(rcvbuf,BEGIN_DATE,0,ac_begin_date,&len)== -1)
	{
		tux_return(sendbuf,"Fget32(BEGIN_DATE) 出错",0,(char *)Fstrerror32(Ferror32));
	}

	len = sizeof(ac_end_date);
	ac_end_date[0]='\0';
	if(Fget32(rcvbuf,END_DATE,0,ac_end_date,&len)== -1)
	{
		tux_return(sendbuf,"Fget32(END_DATE) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	userlog("data from client nodeno=%s,begin_date=%s,end_date=%s\n",ac_nodeno,ac_begin_date,ac_end_date);
	
	//select the node name from nodeinfor
	EXEC SQL SELECT nodename into :c_nodename
	from nodeinfor 
	where nodeno = :ac_nodeno;
	if(sqlca.sqlcode!=0)
	{ 
		tux_return(sendbuf,"select the node name from nodeinfor 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	//取油的种类
	EXEC SQL DECLARE cur_oil_type CURSOR FOR 
		SELECT oilno
		FROM nodetotalinfor_new
		where nodeno = :ac_nodeno
		and   time >= :ac_begin_date
		and   time <= :ac_end_date;
	if(sqlca.sqlcode!=0)
	{ 
		tux_return(sendbuf,"DECLARE CURSOR:cur_oil_type 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}
	EXEC SQL OPEN cur_oil_type;
	if(sqlca.sqlcode!=0)
	{
		EXEC SQL CLOSE cur_oil_type;
		tux_return(sendbuf,"OPEN CURSOR:cur_oil_type 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}

	
	sprintf(szHead,"%20s","");
	sprintf(szNode,"%20s","网点名称");
	sprintf(szAmount,"%20s",c_nodename);
	sprintf(szSum, "%20s","总计");

	i = 0;
	while(1)
	{
		c_code[0]='\0';
		c_content[0]='\0';
		EXEC SQL FETCH cur_oil_type INTO :c_code;
		if( sqlca.sqlcode  == SQLNOTFOUND)
		{
			break;
		}
		//当取出的值是null时,sqlca.sqlcode = -1405
		if ((sqlca.sqlcode != 0)&&(sqlca.sqlcode!= SQLNULL))
		{  	
			//FETCH CURSOR失败
			EXEC SQL CLOSE cur_oil_type;
			tux_return(sendbuf,"FETCH CURSOR:cur_oil_type 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}	
		//select oil name
		EXEC SQL SELECT content into :c_content
		from oiltype 
		where code = :c_code;
		if (sqlca.sqlcode != 0)
		{  	
			//SELEFT CONTENT FROM OILTYPE失败
			tux_return(sendbuf,"SELEFT CONTENT FROM OILTYPE失败",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}
		#ifdef _DEBUG_
		 	userlog("FETCHED code=%s,content=%s\n",c_code,c_content);
		#endif
		
		EXEC SQL SELECT sum(amount),sum(litter)
		into :c_amount, :c_litter
		from nodetotalinfor_new
		where nodeno = :ac_nodeno
		and   oilno = :c_code
		and   time >= :ac_begin_date
		and   time <= :ac_end_date;
		if (sqlca.sqlcode != 0)
		{  	
			//select data from nodetotalinfor_new失败
			tux_return(sendbuf,"select data from nodetotalinfor_new失败",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
		}
		userlog("amount=%s,litter=%s\n",c_amount,c_litter);
		
		sprintf(szHead,"%s|%30s",szHead,c_content);
		sprintf(szNode,"%s|%31s",szNode,"数量　　|金额      ");
		sprintf(szAmount,"%s|%15s|%15s",szAmount,c_amount,c_litter);
		sprintf(szSum, "%s|%15s|%15s",szSum,c_amount,c_litter);
		
	}
			
	EXEC SQL CLOSE cur_oil_type;
	if (sqlca.sqlcode != 0)
	{  	
		//CLOSE CURSOR失败
		tux_return(sendbuf,"CLOSE CURSOR:cur_oil_type 出错",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
	}

	len = sizeof(szHead);
	if(Fchg32(sendbuf, CROSSTAB, 0, szHead, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	len = sizeof(szNode);
	if(Fchg32(sendbuf, CROSSTAB, 1, szNode, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	
	len = sizeof(szAmount);
	if(Fchg32(sendbuf, CROSSTAB, 2, szAmount, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	
	len = sizeof(szSum);
	if(Fchg32(sendbuf, CROSSTAB, 3, szSum, (FLDLEN32)len )<0)
	{	
		tux_return(sendbuf,"Fchg32(CROSSTAB) 出错",0,(char *)Fstrerror32(Ferror32));
	}
	userlog("@@@%s\n",szHead);
	userlog("@@@%s\n",szNode);
	userlog("@@@%s\n",szAmount);
	userlog("@@@%s\n",szSum);
	#ifdef _DEBUG_
		Fprint32(sendbuf); 
	#endif
	tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}

	
*/