xchange.c

UNIX/LINUX平台下面SMS网管原代码

	char pz_num		[ 30 + 1] ;	/* 37  凭证(证件)号码 */
	short source_typ	;		/* 38  来源种类 */ 
	int  source_ser		;		/* 39  来源序号 */   
	char consign_no		[ 20 + 1] ;	/* 40  委托号 */    
	int  purchase_num	;		/* 41  (申购)数量 */ 
	int  detail_num		;		/* 42  明细笔数 */ 
	char address		[ 80 + 1];	/* 43  地址  */
	char rate		[ 10 + 1] ;     /* 44  实时汇率/利率  */
	char name		[ 80 + 1] ;     /* 45  客户名 */  
	char postcode		[  6 + 1] ;	/* 46  邮编   */  
	char tele		[ 20 + 1] ;	/* 47  电话号码  */ 
	char term_no		[ 10 + 1] ;	/* 48  终端号   */    
	char incall_num		[ 30 + 1] ;	/* 49  来电号码 */
	char call_id		[ 30 + 1] ;	/* 50  呼叫ID */
	double money1		;		/* 51  保留余额  */
	double money2		;		/* 52  保留余额  */
	double money3		;		/* 53  保留余额  */
	double money4		;		/* 54  保留余额  */
	char notes1		[ 30 + 1] ;	/* 55  备注   */  
	char notes2		[ 30 + 1] ;	/* 56  备注   */  
	char notes3		[ 30 + 1] ;	/* 57  备注   */  
	char notes4		[ 30 + 1] ;	/* 58  备注   */  
	char notes5		[ 30 + 1] ;	/* 59  备注   */  
	char notes6		[ 256 + 1] ;	/* 60  备注   */  
	char notes7		[ 256 + 1] ;	/* 61  备注   */  
	char notes8		[ 256 + 1] ;	/* 62  备注   */  
	char notes9		[ 256 + 1] ;	/* 63  备注   */  
	char notes10		[ 256 + 1] ;	/* 64  备注   */  
	char city_no		[ 20 + 1] ;	/* 65  城市号   */  
	char trade_brch		[ 20 + 1] ;	/* 66  交易所号   */  
	char date1		[ 10 + 1] ;	/* 67  日期   */  
	char date2		[ 10 + 1] ;	/* 68  日期   */  
	char record		[ 50 + 1] ;	/* 69  语音索引	*/
} SQL_DAILY_TXLOG;

typedef struct{
	char	cid[11 + 1];
	char	account[30 + 1];
	char	link[30 + 1];
	char 	name[60 + 1];
	char    reg_teller[5 + 1];
	char    reg_brch[9 + 1];
	char    reg_date[19 + 1];
	char    mod_teller[5 + 1];
	char    mod_brch[9 + 1];
	char    mod_date[19 + 1];
}SQL_PS_ACC_LINK;



/*
** SQL STATEMENT: 4
** EXEC SQL END DECLARE SECTION;

*/
# line 866 "/usr/agent/incl/bms_sql.h"

/*
** Generated code ends here.
*/
# line 866 "/usr/agent/incl/bms_sql.h"


#endif
# line 13 "xchange.cp"




void pub_insert_str_to_pipe1( int  posi, char *sour, char *str);

int DB_get_businessinfo_tbc( char *ctiinstrument, char *businessinfo, char *custinfo )
{

/*
** SQL STATEMENT: 4
** EXEC SQL BEGIN DECLARE SECTION ;
*/
# line 20 "xchange.cp"

	char S_ctiinstrument[30+1];
	char S_businessinfo[300+1];
	char S_custinfo[300];

/*
** SQL STATEMENT: 5
** EXEC SQL END   DECLARE SECTION ;
*/
# line 24 "xchange.cp"

/*
** Generated code ends here.
*/
# line 24 "xchange.cp"


	memset( S_businessinfo, '\0', sizeof( S_businessinfo ));
	memset( S_ctiinstrument, '\0', sizeof( S_ctiinstrument ));
	memset( S_custinfo, '\0', sizeof(S_custinfo ));

	strcpy( S_ctiinstrument, ctiinstrument );

	
           /*
           ** SQL STATEMENT: 6
           ** EXEC SQL SELECT businessinfo, custinfo into :S_businessinfo, :S_cus
           ** tinfo 		 FROM tbctiexchange
           ** 		 WHERE new_callid = :S_ctiinstrument;
           */
# line 33 "xchange.cp"
# line 32 "xchange.cp"
           {
# line 32 "xchange.cp"
                _SQL_CT_HANDLES * _sql;
# line 32 "xchange.cp"
               _sqlinitctx(&_sql, CS_VERSION_125, CS_TRUE, &sqlca, (long 
# line 32 "xchange.cp"
                   *)NULL, (CS_CHAR *)NULL);
# line 32 "xchange.cp"
               if (_sql != (_SQL_CT_HANDLES *) NULL)
# line 32 "xchange.cp"
               {
# line 32 "xchange.cp"
                   _sql->stmtIdlen = CS_UNUSED;
# line 32 "xchange.cp"
                   _sql->stmtData.persistent = CS_FALSE;
# line 32 "xchange.cp"
                   _sql->stmttype = SQL_SELECT_STMT;
# line 32 "xchange.cp"
                   _sql->connName.lnlen = CS_UNUSED;
# line 32 "xchange.cp"
                   if ((_sql->retcode = _sqlprolog(_sql)) == CS_SUCCEED)
# line 32 "xchange.cp"
                   {
# line 32 "xchange.cp"
                       _sql->retcode = ct_command(_sql->conn.command, 
# line 32 "xchange.cp"
                           CS_LANG_CMD, "SELECT businessinfo, custinfo FROM tbc"
"tiexchange 		 WHERE new_callid = @sql2_S_ctiinstrument ", 93, 
# line 32 "xchange.cp"
                           CS_UNUSED);
# line 32 "xchange.cp"
                       if (_sql->retcode == CS_SUCCEED)
# line 32 "xchange.cp"
                       {
# line 32 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.count = 0;
# line 32 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.format = (CS_FMT_NULLTERM | 
# line 32 "xchange.cp"
                               CS_FMT_PADBLANK);
# line 32 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.maxlength = 30+1;
# line 32 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.status = CS_INPUTVALUE;
# line 32 "xchange.cp"
                           _sql->retcode = ct_param(_sql->conn.command, 
# line 32 "xchange.cp"
                               &_sql->dfmtCS_CHAR_TYPE, _sqlcheckstr(_sql, 
# line 32 "xchange.cp"
                           SQLNULLSTR(S_ctiinstrument)), (CS_INT) CS_NULLTERM, 
# line 32 "xchange.cp"
                               (CS_SMALLINT) 0);
# line 32 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.status = 0;
# line 32 "xchange.cp"
                       }
# line 32 "xchange.cp"
                       
# line 32 "xchange.cp"
                       _sql->retcode = ct_send(_sql->conn.command);
# line 32 "xchange.cp"
                       _sql->resloop = CS_TRUE;
# line 32 "xchange.cp"
                       while ((_sql->resloop == CS_TRUE) && (_sql->retcode = 
# line 32 "xchange.cp"
                           ct_results(_sql->conn.command, &_sql->restype)) == 
# line 32 "xchange.cp"
                       CS_SUCCEED)
# line 32 "xchange.cp"
                       {
# line 32 "xchange.cp"
                           switch ( _sql->restype )
# line 32 "xchange.cp"
                           {
# line 32 "xchange.cp"
                           case CS_COMPUTE_RESULT:
# line 32 "xchange.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 32 "xchange.cp"
                                   _SQL_INTRERR_25003);
# line 32 "xchange.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 32 "xchange.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           case CS_CURSOR_RESULT:
# line 32 "xchange.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 32 "xchange.cp"
                                   _SQL_INTRERR_25004);
# line 32 "xchange.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 32 "xchange.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           case CS_PARAM_RESULT:
# line 32 "xchange.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 32 "xchange.cp"
                                   _SQL_INTRERR_25005);
# line 32 "xchange.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 32 "xchange.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           case CS_ROW_RESULT:
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.count = 0;
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.format = 
# line 32 "xchange.cp"
                                   (CS_FMT_NULLTERM | CS_FMT_PADBLANK);
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.maxlength = 300+1;
# line 32 "xchange.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 32 "xchange.cp"
                                       1, &_sql->dfmtCS_CHAR_TYPE, 
# line 32 "xchange.cp"
                                       S_businessinfo, NULL, NULL);
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.count = 0;
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.format = 
# line 32 "xchange.cp"
                                   (CS_FMT_NULLTERM | CS_FMT_PADBLANK);
# line 32 "xchange.cp"
                               _sql->dfmtCS_CHAR_TYPE.maxlength = 300;
# line 32 "xchange.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 32 "xchange.cp"
                                       2, &_sql->dfmtCS_CHAR_TYPE, S_custinfo, 
# line 32 "xchange.cp"
                                       NULL, NULL);
# line 32 "xchange.cp"
                               _sql->retcode = ct_fetch(_sql->conn.command, 
# line 32 "xchange.cp"
                                   CS_UNUSED, CS_UNUSED, CS_UNUSED, 
# line 32 "xchange.cp"
                                   &_sql->rowsread);
# line 32 "xchange.cp"
                               if ((_sql->retcode == CS_SUCCEED) || 
# line 32 "xchange.cp"
                                   (_sql->retcode == CS_ROW_FAIL))
# line 32 "xchange.cp"
                               {
# line 32 "xchange.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 32 "xchange.cp"
                                       CS_UNUSED, NULL, NULL, NULL, NULL);
# line 32 "xchange.cp"
                                   _sql->retcode = ct_fetch(_sql->conn.command,
# line 32 "xchange.cp"
                                        CS_UNUSED, CS_UNUSED, CS_UNUSED, 
# line 32 "xchange.cp"
                                       &_sql->rowsread);
# line 32 "xchange.cp"
                               }
# line 32 "xchange.cp"
                               
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           case CS_STATUS_RESULT:
# line 32 "xchange.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 32 "xchange.cp"
                                   _SQL_INTRERR_25009);
# line 32 "xchange.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 32 "xchange.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           case CS_DESCRIBE_RESULT:
# line 32 "xchange.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 32 "xchange.cp"
                                   _SQL_INTRERR_25010);
# line 32 "xchange.cp"
                           break;
# line 32 "xchange.cp"
                           }
# line 32 "xchange.cp"
                           
# line 32 "xchange.cp"
                       }
# line 32 "xchange.cp"
                       
# line 32 "xchange.cp"
                       if ((_sql->retcode != CS_END_RESULTS) && (_sql->retcode 
# line 32 "xchange.cp"
                           != CS_CANCELED) && (_sql->resloop != CS_FALSE))
# line 32 "xchange.cp"
                       {
# line 32 "xchange.cp"
                           _sql->retcode = ct_cancel(NULL, _sql->conn.command, 
# line 32 "xchange.cp"
                               CS_CANCEL_ALL);
# line 32 "xchange.cp"
                           }
# line 32 "xchange.cp"
                            else {
# line 32 "xchange.cp"
                           if (_sql->retcode != CS_CANCELED)
# line 32 "xchange.cp"
                           {
# line 32 "xchange.cp"
                               _sql->retcode = CS_SUCCEED;
# line 32 "xchange.cp"
                           }
# line 32 "xchange.cp"
                           
# line 32 "xchange.cp"
                       }
# line 32 "xchange.cp"
                       
# line 32 "xchange.cp"
                       _sql->retcode = _sqlepilog(_sql);
# line 32 "xchange.cp"
                   }
# line 32 "xchange.cp"
                   
# line 32 "xchange.cp"
               }
# line 32 "xchange.cp"
               
# line 32 "xchange.cp"
           }
# line 32 "xchange.cp"
           

           /*
           ** Generated code ends here.
           */
# line 33 "xchange.cp"

	if(sqlca.sqlcode != 0 )
        {
		bms_trace("sqlca.sqlcode[%d]", sqlca.sqlcode);
                return( FAILURE );
        }
	bms_trace("sqlca.sqlerrd[2][%d]", sqlca.sqlerrd[2]);

/*
	EXEC SQL DECLARE sel_cti1 CURSOR FOR 
			SELECT businessinfo,custinfo,serial_no  
			FROM  tbctiexchange 
			WHERE new_callid = :S_ctiinstrument 
			ORDER BY serial_no desc;

	if(sqlca.sqlcode != 0 )
	{
        	bms_trace("DECLARE ret[%d]!", sqlca.sqlcode) ;
		return( FAILURE );
	}

	EXEC SQL OPEN sel_cti1;
	if(sqlca.sqlcode != 0 )
	{
		EXEC SQL FREE sel_cti1;
        	bms_trace("OPEN cur ret[%d]!", sqlca.sqlcode) ;
		return( FAILURE );
	}
	EXEC SQL FETCH sel_cti1 INTO :S_businessinfo, :S_custinfo;
	if(sqlca.sqlcode != 0 )
	{
        	bms_trace("FETCH cur ret[%d]!", sqlca.sqlcode) ;
		return( FAILURE );
	}
	EXEC SQL CLOSE sel_cti1;
	EXEC SQL FREE sel_cti1;

	EXEC SQL DELETE FROM tbctiexchange WHERE new_callid=:S_ctiinstrument ;
*/

	
           /*
           ** SQL STATEMENT: 7
           ** EXEC SQL DELETE FROM tbctiexchange WHERE new_callid=:S_ctiinstrumen
           ** t ;
           */
# line 73 "xchange.cp"
# line 73 "xchange.cp"
           {
# line 73 "xchange.cp"
                _SQL_CT_HANDLES * _sql;
# line 73 "xchange.cp"
               _sqlinitctx(&_sql, CS_VERSION_125, CS_TRUE, &sqlca, (long 
# line 73 "xchange.cp"
                   *)NULL, (CS_CHAR *)NULL);
# line 73 "xchange.cp"
               if (_sql != (_SQL_CT_HANDLES *) NULL)
# line 73 "xchange.cp"
               {
# line 73 "xchange.cp"
                   _sql->stmtIdlen = CS_UNUSED;
# line 73 "xchange.cp"
                   _sql->stmtData.persistent = CS_FALSE;
# line 73 "xchange.cp"
                   _sql->stmttype = SQL_DELETE_SEARCHED;
# line 73 "xchange.cp"
                   _sql->connName.lnlen = CS_UNUSED;
# line 73 "xchange.cp"
                   if ((_sql->retcode = _sqlprolog(_sql)) == CS_SUCCEED)
# line 73 "xchange.cp"
                   {
# line 73 "xchange.cp"
                       _sql->retcode = ct_command(_sql->conn.command, 
# line 73 "xchange.cp"
                           CS_LANG_CMD, "DELETE FROM tbctiexchange WHERE new_ca"
"llid=@sql0_S_ctiinstrument ", 65, CS_UNUSED);
# line 73 "xchange.cp"
                       if (_sql->retcode == CS_SUCCEED)
# line 73 "xchange.cp"
                       {
# line 73 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.count = 0;
# line 73 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.format = (CS_FMT_NULLTERM | 
# line 73 "xchange.cp"
                               CS_FMT_PADBLANK);
# line 73 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.maxlength = 30+1;
# line 73 "xchange.cp"
                           _sql->dfmtCS_CHAR_TYPE.status = CS_INPUTVALUE;
# line 73 "xchange.cp"
                           _sql->retcode = ct_param(_sql->conn.command,