yx1api.c

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

int InsertSndYXDBRec(struct stYXDBRec rec_YX_DB)
{
   	ERROR=0;
    	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 

    	/* EXEC SQL INSERT INTO t_fsyxsj VALUES (:rec_YX_DB); */ 

{
     struct sqlexd sqlstm;

     sqlstm.sqlvsn = 8;
     sqlstm.arrsiz = 4;
     sqlstm.stmt = "insert into t_fsyxsj values (:s1 ,:s2 ,:s3 )";
     sqlstm.iters = (unsigned int  )1;
     sqlstm.offset = (unsigned int  )32;
     sqlstm.cud = sqlcud0;
     sqlstm.sqlest = (unsigned char  *)&sqlca;
     sqlstm.sqlety = (unsigned short)0;
     sqlstm.sqhstv[0] = (unsigned char  *)rec_YX_DB.yxxl;
     sqlstm.sqhstl[0] = (unsigned int  )4;
     sqlstm.sqindv[0] = (         short *)0;
     sqlstm.sqharm[0] = (unsigned int  )0;
     sqlstm.sqhstv[1] = (unsigned char  *)rec_YX_DB.wjbh;
     sqlstm.sqhstl[1] = (unsigned int  )3;
     sqlstm.sqindv[1] = (         short *)0;
     sqlstm.sqharm[1] = (unsigned int  )0;
     sqlstm.sqhstv[2] = (unsigned char  *)&rec_YX_DB.serial_no;
     sqlstm.sqhstl[2] = (unsigned int  )4;
     sqlstm.sqindv[2] = (         short *)0;
     sqlstm.sqharm[2] = (unsigned int  )0;
     sqlstm.sqphsv = sqlstm.sqhstv;
     sqlstm.sqphsl = sqlstm.sqhstl;
     sqlstm.sqpind = sqlstm.sqindv;
     sqlstm.sqparm = sqlstm.sqharm;
     sqlstm.sqparc = sqlstm.sqharc;
     sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
     if (sqlca.sqlcode < 0) sqlerror();
}


	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}

    	return(0);
}


int InsertSndTMPDBRec(long serial_no,int groupid,char *yx_Data)
{
    
   	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 

      
   	/* EXEC SQL INSERT INTO t_zcfssj (fsxh,zh,zcfssj,zzh) VALUES
                   (:serial_no,
                    :groupid,
                    :yx_Data,
                    :total_zh); */ 

{
    struct sqlexd sqlstm;

    sqlstm.sqlvsn = 8;
    sqlstm.arrsiz = 4;
    sqlstm.stmt = "insert into t_zcfssj(fsxh,zh,zcfssj,zzh) values (:b0,:b1\
,:b2,:b3)";
    sqlstm.iters = (unsigned int  )1;
    sqlstm.offset = (unsigned int  )58;
    sqlstm.cud = sqlcud0;
    sqlstm.sqlest = (unsigned char  *)&sqlca;
    sqlstm.sqlety = (unsigned short)0;
    sqlstm.sqhstv[0] = (unsigned char  *)&serial_no;
    sqlstm.sqhstl[0] = (unsigned int  )4;
    sqlstm.sqindv[0] = (         short *)0;
    sqlstm.sqharm[0] = (unsigned int  )0;
    sqlstm.sqhstv[1] = (unsigned char  *)&groupid;
    sqlstm.sqhstl[1] = (unsigned int  )4;
    sqlstm.sqindv[1] = (         short *)0;
    sqlstm.sqharm[1] = (unsigned int  )0;
    sqlstm.sqhstv[2] = (unsigned char  *)yx_Data;
    sqlstm.sqhstl[2] = (unsigned int  )0;
    sqlstm.sqindv[2] = (         short *)0;
    sqlstm.sqharm[2] = (unsigned int  )0;
    sqlstm.sqhstv[3] = (unsigned char  *)&total_zh;
    sqlstm.sqhstl[3] = (unsigned int  )4;
    sqlstm.sqindv[3] = (         short *)0;
    sqlstm.sqharm[3] = (unsigned int  )0;
    sqlstm.sqphsv = sqlstm.sqhstv;
    sqlstm.sqphsl = sqlstm.sqhstl;
    sqlstm.sqpind = sqlstm.sqindv;
    sqlstm.sqparm = sqlstm.sqharm;
    sqlstm.sqparc = sqlstm.sqharc;
    sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
    if (sqlca.sqlcode < 0) sqlerror();
}


    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    	
   	return(0);
 }    
 
void sqlerror()
{
    	/* EXEC SQL WHENEVER SQLERROR CONTINUE; */ 

 	ProcessError(LOG_ERROR,"PCS_Snd_YX1: ", sqlca.sqlerrm.sqlerrmc);
   	ERROR=1;
    	/* EXEC SQL ROLLBACK WORK RELEASE; */ 

{
     struct sqlexd sqlstm;

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


    	return;
}

int CreateSndLogAndHZRec(long *serial_no,char *datatype,char *rcv_province_code,char status)
{
    	/* EXEC SQL SELECT s_fsxh.NEXTVAL INTO :key FROM sys.dual; */ 

{
     struct sqlexd sqlstm;

     sqlstm.sqlvsn = 8;
     sqlstm.arrsiz = 4;
     sqlstm.stmt = "select s_fsxh.nextval  into :b0  from sys.dual ";
     sqlstm.iters = (unsigned int  )1;
     sqlstm.offset = (unsigned int  )102;
     sqlstm.selerr = (unsigned short)1;
     sqlstm.cud = sqlcud0;
     sqlstm.sqlest = (unsigned char  *)&sqlca;
     sqlstm.sqlety = (unsigned short)0;
     sqlstm.sqhstv[0] = (unsigned char  *)&key;
     sqlstm.sqhstl[0] = (unsigned int  )4;
     sqlstm.sqindv[0] = (         short *)0;
     sqlstm.sqharm[0] = (unsigned int  )0;
     sqlstm.sqphsv = sqlstm.sqhstv;
     sqlstm.sqphsl = sqlstm.sqhstl;
     sqlstm.sqpind = sqlstm.sqindv;
     sqlstm.sqparm = sqlstm.sqharm;
     sqlstm.sqparc = sqlstm.sqharc;
     sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
}


    	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 
     /*  SQL error handling */
    	/* EXEC SQL INSERT INTO t_fsrz(fsxh,sjfl,sjzt,jssj) VALUES (
                          :key,
                          :datatype,
                          :status,
                          SYSDATE); */ 

{
     struct sqlexd sqlstm;

     sqlstm.sqlvsn = 8;
     sqlstm.arrsiz = 4;
     sqlstm.stmt = "insert into t_fsrz(fsxh,sjfl,sjzt,jssj) values (:b0,:b1\
,:b2,sysdate )";
     sqlstm.iters = (unsigned int  )1;
     sqlstm.offset = (unsigned int  )120;
     sqlstm.cud = sqlcud0;
     sqlstm.sqlest = (unsigned char  *)&sqlca;
     sqlstm.sqlety = (unsigned short)0;
     sqlstm.sqhstv[0] = (unsigned char  *)&key;
     sqlstm.sqhstl[0] = (unsigned int  )4;
     sqlstm.sqindv[0] = (         short *)0;
     sqlstm.sqharm[0] = (unsigned int  )0;
     sqlstm.sqhstv[1] = (unsigned char  *)datatype;
     sqlstm.sqhstl[1] = (unsigned int  )0;
     sqlstm.sqindv[1] = (         short *)0;
     sqlstm.sqharm[1] = (unsigned int  )0;
     sqlstm.sqhstv[2] = (unsigned char  *)&status;
     sqlstm.sqhstl[2] = (unsigned int  )1;
     sqlstm.sqindv[2] = (         short *)0;
     sqlstm.sqharm[2] = (unsigned int  )0;
     sqlstm.sqphsv = sqlstm.sqhstv;
     sqlstm.sqphsl = sqlstm.sqhstl;
     sqlstm.sqpind = sqlstm.sqindv;
     sqlstm.sqparm = sqlstm.sqharm;
     sqlstm.sqparc = sqlstm.sqharc;
     sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
     if (sqlca.sqlcode < 0) sqlerror();
}


    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    
     	/* EXEC SQL INSERT INTO t_HZ  (fsxh,sjbh,hzjssj,hzzt) VALUES (
                          :key,
                          :rcv_province_code,
                          SYSDATE,
                          :status); */ 

{
      struct sqlexd sqlstm;

      sqlstm.sqlvsn = 8;
      sqlstm.arrsiz = 4;
      sqlstm.stmt = "insert into t_HZ(fsxh,sjbh,hzjssj,hzzt) values (:b0,:b\
1,sysdate ,:b2)";
      sqlstm.iters = (unsigned int  )1;
      sqlstm.offset = (unsigned int  )146;
      sqlstm.cud = sqlcud0;
      sqlstm.sqlest = (unsigned char  *)&sqlca;
      sqlstm.sqlety = (unsigned short)0;
      sqlstm.sqhstv[0] = (unsigned char  *)&key;
      sqlstm.sqhstl[0] = (unsigned int  )4;
      sqlstm.sqindv[0] = (         short *)0;
      sqlstm.sqharm[0] = (unsigned int  )0;
      sqlstm.sqhstv[1] = (unsigned char  *)rcv_province_code;
      sqlstm.sqhstl[1] = (unsigned int  )0;
      sqlstm.sqindv[1] = (         short *)0;
      sqlstm.sqharm[1] = (unsigned int  )0;
      sqlstm.sqhstv[2] = (unsigned char  *)&status;
      sqlstm.sqhstl[2] = (unsigned int  )1;
      sqlstm.sqindv[2] = (         short *)0;
      sqlstm.sqharm[2] = (unsigned int  )0;
      sqlstm.sqphsv = sqlstm.sqhstv;
      sqlstm.sqphsl = sqlstm.sqhstl;
      sqlstm.sqpind = sqlstm.sqindv;
      sqlstm.sqparm = sqlstm.sqharm;
      sqlstm.sqparc = sqlstm.sqharc;
      sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
      if (sqlca.sqlcode < 0) sqlerror();
}


    	*serial_no = key;
    	return(0);
}
                     
            


int UpdateSndLogStatus(long serial_no,char status)
{
   
    	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 
     /*  SQL error handling */
    	/* EXEC SQL UPDATE t_fsrz  SET sjzt = :status  
                       WHERE fsxh = :serial_no; */ 

{
     struct sqlexd sqlstm;

     sqlstm.sqlvsn = 8;
     sqlstm.arrsiz = 4;
     sqlstm.stmt = "update t_fsrz  set sjzt=:b0 where fsxh=:b1";
     sqlstm.iters = (unsigned int  )1;
     sqlstm.offset = (unsigned int  )172;
     sqlstm.cud = sqlcud0;
     sqlstm.sqlest = (unsigned char  *)&sqlca;
     sqlstm.sqlety = (unsigned short)0;
     sqlstm.sqhstv[0] = (unsigned char  *)&status;
     sqlstm.sqhstl[0] = (unsigned int  )1;
     sqlstm.sqindv[0] = (         short *)0;
     sqlstm.sqharm[0] = (unsigned int  )0;
     sqlstm.sqhstv[1] = (unsigned char  *)&serial_no;
     sqlstm.sqhstl[1] = (unsigned int  )4;
     sqlstm.sqindv[1] = (         short *)0;
     sqlstm.sqharm[1] = (unsigned int  )0;
     sqlstm.sqphsv = sqlstm.sqhstv;
     sqlstm.sqphsl = sqlstm.sqhstl;
     sqlstm.sqpind = sqlstm.sqindv;
     sqlstm.sqparm = sqlstm.sqharm;
     sqlstm.sqparc = sqlstm.sqharc;
     sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
     if (sqlca.sqlcode < 0) sqlerror();
}


    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    	return(0);
}