main_0202.ec

证券交易系统

#include "../incl/bank.h" 
#include <sys/time.h>
$include sqlca;

static	void       toolong1();
jmp_buf    oldenv1;
extern	WORKER   *wk;
extern	int  htime_out1;
extern $char stockdb1[20];

SEND_NET_0202   send_net_0202;
RECV_NET_0202   recv_net_0202;

int     net_tohost_0202(sockfd,rcv_data_package,snd_data_package)
int     sockfd;
char    *rcv_data_package;
char    *snd_data_package;
{
        int    i,flag,t;
        $char    T_hostls[16],t_worker[5];
        char   *tmp,amount_p1[15],amount_p2[3];
        char   manager_id[10],*t1,*t2;
       char    duig_0202_buff[1024];
       $char   tmp_lsh[16];
       $int    T_con;
       $int    t_ans_serial;
       $char   t_trans_type[5];
       $char   t_acco_type[2] ;
       $char   t_account[33];
       $double t_amount;
       $char   t_req_serial[16];
       $char   t_host_serial[7];
       $char   t_time[7];
       $char   t_retcode[5];
       $char   t_errmsg[41];
       $double t_balance;
       $char   t_chongzh_flag[2];

        $connect to $stockdb1;
        if ( sqlca.sqlcode ) {
             WriteLog ( LOGFILE,"Open database stock err![%d]\n",sqlca.sqlcode );
             strcpy ( send_net.retcode,"8999");
             strcpy ( send_net.errmsg,"数据库开启错误");
             return( -1 );
        }

        wk = NULL;

        tmp = rcv_data_package; 

        WriteLog(LOGFILE,"********转入城综网帐户开始*************");
        WriteLog(LOGFILE,"接收数据%s:\n[%s]",rcv_data_package);

        memset(duig_0202_buff,'\0',1024);
        i = unpknet_stock_0202(rcv_data_package,duig_0202_buff);        
        if(i == -20)
	{
             strcpy(snd_data_package,duig_0202_buff);

	}

        else if (i<0)  {
            WriteLog(LOGFILE,"unpknet_stock  err!");
            strcpy ( send_net_0202.retcode,"8999");
            strcpy ( send_net_0202.errmsg,"解包错误");
            pktonet_stock_0201(snd_data_package);
            return( 0 );
        }

if(i != -20)
{
        /*  城综网帐户信息校验 (0202)