logserial.c

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

	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 12 "logserial.cp"




#define  IVR                    1
#define  AGENT                  2
#define  TERMINAL               5

extern void error_handler();
extern void warning_handler();
extern void notfound_handler();

int DB_GenSerialNo(int *Active, BIG_STRC *bs);
int DB_LogTransaction(int Active, BIG_STRC *bs);

int DB_GenSerialNo(int *Active, BIG_STRC *bs)
{
	
           /*
           ** SQL STATEMENT: 4
           ** EXEC SQL BEGIN DECLARE SECTION;

           */
# line 28 "logserial.cp"

	char WorkDate[10 + 1];
	short CurrLog;
	int  SerialNo;
	
           /*
           ** SQL STATEMENT: 5
           ** EXEC SQL END DECLARE SECTION;

           */
# line 32 "logserial.cp"

           /*
           ** Generated code ends here.
           */
# line 32 "logserial.cp"


        
           /*
           ** SQL STATEMENT: 6
           ** EXEC SQL WHENEVER SQLERROR CALL error_handler() ;
           */
# line 34 "logserial.cp"

        
           /*
           ** SQL STATEMENT: 7
           ** EXEC SQL WHENEVER SQLWARNING CALL warning_handler() ;
           */
# line 35 "logserial.cp"

        
           /*
           ** SQL STATEMENT: 8
           ** EXEC SQL WHENEVER NOT FOUND CALL notfound_handler() ;
           */
# line 36 "logserial.cp"


	
           /*
           ** SQL STATEMENT: 9
           ** EXEC SQL BEGIN TRANSACTION;

           */
# line 38 "logserial.cp"
# line 38 "logserial.cp"
           {
# line 38 "logserial.cp"
                _SQL_CT_HANDLES * _sql;
# line 38 "logserial.cp"
               _sqlinitctx(&_sql, CS_VERSION_125, CS_TRUE, &sqlca, (long 
# line 38 "logserial.cp"
                   *)NULL, (CS_CHAR *)NULL);
# line 38 "logserial.cp"
               if (_sql != (_SQL_CT_HANDLES *) NULL)
# line 38 "logserial.cp"
               {
# line 38 "logserial.cp"
                   _sql->stmtData.persistent = CS_FALSE;
# line 38 "logserial.cp"
                   _sql->stmttype = SQL_TRANS;
# line 38 "logserial.cp"
                   _sql->connName.lnlen = CS_UNUSED;
# line 38 "logserial.cp"
                   if ((_sql->retcode = _sqlprolog(_sql)) == CS_SUCCEED)
# line 38 "logserial.cp"
                   {
# line 38 "logserial.cp"
                       _sql->retcode = ct_command(_sql->conn.command, 
# line 38 "logserial.cp"
                           CS_LANG_CMD, "BEGIN TRANSACTION", 17, CS_UNUSED);
# line 38 "logserial.cp"
                       _sql->retcode = ct_send(_sql->conn.command);
# line 38 "logserial.cp"
                       _sql->retcode = _sqlResults(_sql);
# line 38 "logserial.cp"
                       _sql->retcode = _sqlepilog(_sql);
# line 38 "logserial.cp"
                   }
# line 38 "logserial.cp"
                   
# line 38 "logserial.cp"
                   if (sqlca.sqlcode < 0)
# line 38 "logserial.cp"
                   {
# line 38 "logserial.cp"
                       error_handler();
# line 38 "logserial.cp"
                   }
# line 38 "logserial.cp"
                   
# line 38 "logserial.cp"
                   if (sqlca.sqlwarn[0] == 'W')
# line 38 "logserial.cp"
                   {
# line 38 "logserial.cp"
                       warning_handler();
# line 38 "logserial.cp"
                   }
# line 38 "logserial.cp"
                   
# line 38 "logserial.cp"
                   if (sqlca.sqlcode == 100)
# line 38 "logserial.cp"
                   {
# line 38 "logserial.cp"
                       notfound_handler();
# line 38 "logserial.cp"
                   }
# line 38 "logserial.cp"
                   
# line 38 "logserial.cp"
               }
# line 38 "logserial.cp"
               
# line 38 "logserial.cp"
           }
# line 38 "logserial.cp"
           

           /*
           ** Generated code ends here.
           */
# line 38 "logserial.cp"


	/*EXEC SQL LOCK TABLE daily_switch_ctl IN SHARE MODE;*/

	
           /*
           ** SQL STATEMENT: 10
           ** EXEC SQL SELECT currlog, workdate
           ** 		 INTO   :CurrLog, :WorkDate
           ** 		 FROM   daily_switch_ctl;

           */
# line 44 "logserial.cp"
# line 42 "logserial.cp"
           {
# line 42 "logserial.cp"
                _SQL_CT_HANDLES * _sql;
# line 42 "logserial.cp"
               _sqlinitctx(&_sql, CS_VERSION_125, CS_TRUE, &sqlca, (long 
# line 42 "logserial.cp"
                   *)NULL, (CS_CHAR *)NULL);
# line 42 "logserial.cp"
               if (_sql != (_SQL_CT_HANDLES *) NULL)
# line 42 "logserial.cp"
               {
# line 42 "logserial.cp"
                   _sql->stmtIdlen = CS_UNUSED;
# line 42 "logserial.cp"
                   _sql->stmtData.persistent = CS_FALSE;
# line 42 "logserial.cp"
                   _sql->stmttype = SQL_SELECT_STMT;
# line 42 "logserial.cp"
                   _sql->connName.lnlen = CS_UNUSED;
# line 42 "logserial.cp"
                   if ((_sql->retcode = _sqlprolog(_sql)) == CS_SUCCEED)
# line 42 "logserial.cp"
                   {
# line 42 "logserial.cp"
                       _sql->retcode = ct_command(_sql->conn.command, 
# line 42 "logserial.cp"
                           CS_LANG_CMD, "SELECT currlog, workdate 	"
"	 FROM   daily_switch_ctl", 51, CS_UNUSED);
# line 42 "logserial.cp"
                       _sql->retcode = ct_send(_sql->conn.command);
# line 42 "logserial.cp"
                       _sql->resloop = CS_TRUE;
# line 42 "logserial.cp"
                       while ((_sql->resloop == CS_TRUE) && (_sql->retcode = 
# line 42 "logserial.cp"
                           ct_results(_sql->conn.command, &_sql->restype)) == 
# line 42 "logserial.cp"
                       CS_SUCCEED)
# line 42 "logserial.cp"
                       {
# line 42 "logserial.cp"
                           switch ( _sql->restype )
# line 42 "logserial.cp"
                           {
# line 42 "logserial.cp"
                           case CS_COMPUTE_RESULT:
# line 42 "logserial.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 42 "logserial.cp"
                                   _SQL_INTRERR_25003);
# line 42 "logserial.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 42 "logserial.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           case CS_CURSOR_RESULT:
# line 42 "logserial.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 42 "logserial.cp"
                                   _SQL_INTRERR_25004);
# line 42 "logserial.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 42 "logserial.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           case CS_PARAM_RESULT:
# line 42 "logserial.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 42 "logserial.cp"
                                   _SQL_INTRERR_25005);
# line 42 "logserial.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 42 "logserial.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           case CS_ROW_RESULT:
# line 42 "logserial.cp"
                               _sql->dfmtCS_SMALLINT_TYPE.count = 0;
# line 42 "logserial.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 42 "logserial.cp"
                                       1, &_sql->dfmtCS_SMALLINT_TYPE, 
# line 42 "logserial.cp"
                                       &CurrLog, NULL, NULL);
# line 42 "logserial.cp"
                               _sql->dfmtCS_CHAR_TYPE.count = 0;
# line 42 "logserial.cp"
                               _sql->dfmtCS_CHAR_TYPE.format = 
# line 42 "logserial.cp"
                                   (CS_FMT_NULLTERM | CS_FMT_PADBLANK);
# line 42 "logserial.cp"
                               _sql->dfmtCS_CHAR_TYPE.maxlength = 10 + 1;
# line 42 "logserial.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 42 "logserial.cp"
                                       2, &_sql->dfmtCS_CHAR_TYPE, WorkDate, 
# line 42 "logserial.cp"
                                       NULL, NULL);
# line 42 "logserial.cp"
                               _sql->retcode = ct_fetch(_sql->conn.command, 
# line 42 "logserial.cp"
                                   CS_UNUSED, CS_UNUSED, CS_UNUSED, 
# line 42 "logserial.cp"
                                   &_sql->rowsread);
# line 42 "logserial.cp"
                               if ((_sql->retcode == CS_SUCCEED) || 
# line 42 "logserial.cp"
                                   (_sql->retcode == CS_ROW_FAIL))
# line 42 "logserial.cp"
                               {
# line 42 "logserial.cp"
                                   _sql->retcode = ct_bind(_sql->conn.command, 
# line 42 "logserial.cp"
                                       CS_UNUSED, NULL, NULL, NULL, NULL);
# line 42 "logserial.cp"
                                   _sql->retcode = ct_fetch(_sql->conn.command,
# line 42 "logserial.cp"
                                        CS_UNUSED, CS_UNUSED, CS_UNUSED, 
# line 42 "logserial.cp"
                                       &_sql->rowsread);
# line 42 "logserial.cp"
                               }
# line 42 "logserial.cp"
                               
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           case CS_STATUS_RESULT:
# line 42 "logserial.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 42 "logserial.cp"
                                   _SQL_INTRERR_25009);
# line 42 "logserial.cp"
                               _sql->retcode = ct_cancel(NULL, 
# line 42 "logserial.cp"
                                   _sql->conn.command, CS_CANCEL_CURRENT);
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           case CS_DESCRIBE_RESULT:
# line 42 "logserial.cp"
                               _sqlsetintrerr(_sql, (CS_INT) 
# line 42 "logserial.cp"
                                   _SQL_INTRERR_25010);
# line 42 "logserial.cp"
                           break;
# line 42 "logserial.cp"
                           }
# line 42 "logserial.cp"
                           
# line 42 "logserial.cp"
                       }
# line 42 "logserial.cp"
                       
# line 42 "logserial.cp"
                       if ((_sql->retcode != CS_END_RESULTS) && (_sql->retcode 
# line 42 "logserial.cp"
                           != CS_CANCELED) && (_sql->resloop != CS_FALSE))
# line 42 "logserial.cp"
                       {
# line 42 "logserial.cp"
                           _sql->retcode = ct_cancel(NULL, _sql->conn.command, 
# line 42 "logserial.cp"
                               CS_CANCEL_ALL);
# line 42 "logserial.cp"
                           }
# line 42 "logserial.cp"
                            else {
# line 42 "logserial.cp"
                           if (_sql->retcode != CS_CANCELED)
# line 42 "logserial.cp"
                           {
# line 42 "logserial.cp"
                               _sql->retcode = CS_SUCCEED;
# line 42 "logserial.cp"
                           }
# line 42 "logserial.cp"
                           
# line 42 "logserial.cp"
                       }
# line 42 "logserial.cp"
                       
# line 42 "logserial.cp"
                       _sql->retcode = _sqlepilog(_sql);
# line 42 "logserial.cp"
                   }
# line 42 "logserial.cp"
                   
# line 42 "logserial.cp"
                   if (sqlca.sqlcode < 0)
# line 42 "logserial.cp"
                   {
# line 42 "logserial.cp"
                       error_handler();
# line 42 "logserial.cp"
                   }
# line 42 "logserial.cp"
                   
# line 42 "logserial.cp"
                   if (sqlca.sqlwarn[0] == 'W')
# line 42 "logserial.cp"
                   {
# line 42 "logserial.cp"
                       warning_handler();
# line 42 "logserial.cp"
                   }
# line 42 "logserial.cp"
                   
# line 42 "logserial.cp"
                   if (sqlca.sqlcode == 100)
# line 42 "logserial.cp"
                   {
# line 42 "logserial.cp"
                       notfound_handler();
# line 42 "logserial.cp"
                   }
# line 42 "logserial.cp"
                   
# line 42 "logserial.cp"
               }
# line 42 "logserial.cp"
               
# line 42 "logserial.cp"
           }
# line 42 "logserial.cp"