pcs_snd_yx_p.c

unix 下用pro*c tuxedo 开发的东西

/* Result Sets Interface */
#ifndef SQL_CRSR
#  define SQL_CRSR
  struct sql_cursor
  {
    unsigned int curocn;
    void *ptr1;
    void *ptr2;
    unsigned long magic;
  };
  typedef struct sql_cursor sql_cursor;
  typedef struct sql_cursor SQL_CURSOR;
#endif /* SQL_CRSR */

/* Thread Safety */
typedef void * sql_context;
typedef void * SQL_CONTEXT;

/* File name & Package Name */
struct sqlcxp
{
  unsigned short fillen;
           char  filnam[16];
};
static struct sqlcxp sqlfpn =
{
    15,
    "Pcs_Snd_YX_P.pc"
};


static unsigned long sqlctx = 2559691;


static struct sqlexd {
   unsigned int   sqlvsn;
   unsigned int   arrsiz;
   unsigned int   iters;
   unsigned int   offset;
   unsigned short selerr;
   unsigned short sqlety;
   unsigned int   unused;
            short *cud;
   unsigned char  *sqlest;
            char  *stmt;
   unsigned char  **sqphsv;
   unsigned int   *sqphsl;
            short **sqpind;
   unsigned int   *sqparm;
   unsigned int   **sqparc;
   unsigned char  *sqhstv[3];
   unsigned int   sqhstl[3];
            short *sqindv[3];
   unsigned int   sqharm[3];
   unsigned int   *sqharc[3];
} sqlstm = {8,3};

/* Prototypes */
extern sqlcxt (/*_ void **, unsigned long *,
                   struct sqlexd *, struct sqlcxp * _*/);
extern sqlcx2t(/*_ void **, unsigned long *,
                   struct sqlexd *, struct sqlcxp * _*/);
extern sqlbuft(/*_ void **, char * _*/);
extern sqlgs2t(/*_ void **, char * _*/);
extern sqlorat(/*_ void **, unsigned long *, void * _*/);

/* Forms Interface */
static int IAPSUCC = 0;
static int IAPFAIL = 1403;
static int IAPFTL  = 535;
extern void sqliem(/*_ char *, int * _*/);

 static char *sq0004 = 
"select fsxh  from t_fsrz where (sjfl=:b0 and sjzt=:b1)           ";
typedef struct { unsigned short len; unsigned char arr[1]; } VARCHAR;
typedef struct { unsigned short len; unsigned char arr[1]; } varchar;

/* cud (compilation unit data) array */
static short sqlcud0[] =
{8,4130,
2,0,0,1,0,0,32,50,0,0,0,0,1,0,
16,0,0,2,34,0,4,77,0,1,0,0,1,0,2,97,0,0,
34,0,0,3,68,0,4,93,0,3,2,0,1,0,2,3,0,0,1,1,0,0,1,1,0,0,
60,0,0,4,65,0,9,120,0,2,2,0,1,0,1,1,0,0,1,1,0,0,
82,0,0,4,0,0,13,125,0,1,0,0,1,0,2,3,0,0,
100,0,0,5,0,0,31,139,0,0,0,0,1,0,
114,0,0,6,37,0,2,143,0,1,1,0,1,0,1,3,0,0,
132,0,0,7,0,0,29,144,0,0,0,0,1,0,
146,0,0,4,0,0,15,147,0,0,0,0,1,0,
};


/*******************************************************************************
*	File Name			:	PcsSndYXP.pc 		       *
*	Module ID			:	MD_P15_01		       *
*	Module Name			:	PcsSndYXP.pc		       *
*                                               call PcsSndYX2() send msg to MQ*
*	Auther				:	Gao Lin Li		       *
*	Date Created			:	07/22/1999  		       *
*	Version				:	Version 1.0		       *
*	Environment		 	:	OSF1 Compaq V4.0 (Alpha)       *
*	Portability			:	Unix platform		       *
*	Warnings		 	:				       *
*	References			:	  			       *
*	Calling Syntax		 	:				       *
*	Parameters		  	:				       *
*	Returns			 	:	integer			       *
*                              	0  success				       *
*                       	-1 failure				       *
*	Calling Functions	  	:                                      *
*                                               InitPcsSndYXP()                *
*                                               EndPcsSndYXP()                 *
*   						PcsSndYX2()       	       *
*	Called Functions	  	:       Pcs_Start                      *
*	Data Stores and Usages	：              			       *
*				(a) Input  :    T_FSRZ,T_HZ,T_FSYXSJ,T_ZCFSSJ  *
*				(b) Output :    MQ  YX Message                 *
*	Report				:	none		               *
*	Screens				:	none			       *
*	Message Files			:	none			       *
*									       *
*	Change Log    			:				       *
*	Change No. Date		Auther		Reason for Change	       *
*******************************************************************************/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
/* EXEC SQL INCLUDE SQLCA; 
 */ 
/*
 * $Header: sqlca.h,v 1.3 1994/12/12 19:27:27 jbasu Exp $ sqlca.h 
 */

/* Copyright (c) 1985,1986 by Oracle Corporation. */
 
/*
NAME
  SQLCA : SQL Communications Area.
FUNCTION
  Contains no code. Oracle fills in the SQLCA with status info
  during the execution of a SQL stmt.
NOTES
  **************************************************************
  ***                                                        ***
  *** This file is SOSD.  Porters must change the data types ***
  *** appropriately on their platform.  See notes/pcport.doc ***
  *** for more information.                                  ***
  ***                                                        ***
  **************************************************************

  If the symbol SQLCA_STORAGE_CLASS is defined, then the SQLCA
  will be defined to have this storage class. For example:
 
    #define SQLCA_STORAGE_CLASS extern
 
  will define the SQLCA as an extern.
 
  If the symbol SQLCA_INIT is defined, then the SQLCA will be
  statically initialized. Although this is not necessary in order
  to use the SQLCA, it is a good pgming practice not to have
  unitialized variables. However, some C compilers/OS's don't
  allow automatic variables to be init'd in this manner. Therefore,
  if you are INCLUDE'ing the SQLCA in a place where it would be
  an automatic AND your C compiler/OS doesn't allow this style
  of initialization, then SQLCA_INIT should be left undefined --
  all others can define SQLCA_INIT if they wish.

  If the symbol SQLCA_NONE is defined, then the SQLCA variable will
  not be defined at all.  The symbol SQLCA_NONE should not be defined
  in source modules that have embedded SQL.  However, source modules
  that have no embedded SQL, but need to manipulate a sqlca struct
  passed in as a parameter, can set the SQLCA_NONE symbol to avoid
  creation of an extraneous sqlca variable.
 
MODIFIED
    jbasu      12/12/94 -  Bug 217878: note this is an SOSD file
    losborne   08/11/92 -  No sqlca var if SQLCA_NONE macro set 
  Clare      12/06/84 - Ch SQLCA to not be an extern.
  Clare      10/21/85 - Add initialization.
  Bradbury   01/05/86 - Only initialize when SQLCA_INIT set
  Clare      06/12/86 - Add SQLCA_STORAGE_CLASS option.
*/
 
#ifndef SQLCA
#define SQLCA 1
 
struct   sqlca
         {
         /* ub1 */ char    sqlcaid[8];
         /* b4  */ long    sqlabc;
         /* b4  */ long    sqlcode;
         struct
           {
           /* ub2 */ unsigned short sqlerrml;
           /* ub1 */ char           sqlerrmc[70];
           } sqlerrm;
         /* ub1 */ char    sqlerrp[8];
         /* b4  */ long    sqlerrd[6];
         /* ub1 */ char    sqlwarn[8];
         /* ub1 */ char    sqlext[8];
         };

#ifndef SQLCA_NONE 
#ifdef   SQLCA_STORAGE_CLASS
SQLCA_STORAGE_CLASS struct sqlca sqlca
#else
         struct sqlca sqlca
#endif
 
#ifdef  SQLCA_INIT
         = {
         {'S', 'Q', 'L', 'C', 'A', ' ', ' ', ' '},
         sizeof(struct sqlca),
         0,
         { 0, {0}},
         {'N', 'O', 'T', ' ', 'S', 'E', 'T', ' '},
         {0, 0, 0, 0, 0, 0},
         {0, 0, 0, 0, 0, 0, 0, 0},
         {0, 0, 0, 0, 0, 0, 0, 0}
         }
#endif
         ;
#endif
 
#endif
 
/* end SQLCA */

#include <fcntl.h>
#include <signal.h>
#include "/usr/bkfx/include/myapi.h"
#include "/usr/bkfx/include/Pcs_Snd_YX_P/Pcs_Snd_YX_P.h"
#include "/usr/bkfx/include/Pcs_Snd_YX_P/cmYXStr.h"
#include "/usr/bkfx/include/Pcs_Snd_YX_P/cmdef.h"


int freect()
{
	if( mheader!=NULL )
	free(mheader);
	/* EXEC SQL ROLLBACK WORK RELEASE; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 0;
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )2;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
}


	exit(0);
}

/*  Usage :  PcsSndYXP.x   */ 
main()
{    
   
	int  coun=0; 
	int  flag;
	int  retcode=0;
	char produce_err_str[20];
	char *PID = "Client Txn Clt_Mpt Process(Port 7111)";
	int iTime;
	
	ERROR=0;
	i=0;
        signal(SIGTERM,freect);

	ProcessError(LOG_NORMAL,"PCS_Snd_YX_P: this is NORMAL message", END);
	
	flag=InitPcsSndYXP();
    	if( flag!=0 )
    	{
    		ProcessError(LOG_ERROR,"PCS_Snd_YX_P: error cannot connect database",END);