main_0213.ec

证券交易系统

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


jmp_buf    oldenv1;
static void       toolong1();

extern int        htime_out1;
extern WORKER     *wk;
extern $char stockdb1[20];

SEND_NET_0213   send_net_0213;
RECV_NET_0213   recv_net_0213;

int     net_tohost_0213(sockfd,rcv_data_package,snd_data_package)
int     sockfd;
char    *rcv_data_package;
char    *snd_data_package;
{
        int    i,flag,t;
        char   *tmp,*tmp1,amount_p1[15],amount_p2[3];
        char   manager_id[10],*t1,*t2;
        double tmp_amount;
        char   duig_0213_buff[1024];
       $char   tmp_lsh[16];
       $char   worker_4[5];
       $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,"接收数据:\n[%s]",rcv_data_package);

        i = unpknet_stock_0213(rcv_data_package,duig_0213_buff);        
        if(i == - 20)
        {
	       strcpy(snd_data_package,duig_0213_buff);
	       printf("对公数据：[%s]\n",snd_data_package);
	       $disconnect current;
               return(0);
	}

        if (i<0)  {
            WriteLog(LOGFILE,"unpknet_stock  err!");
            strcpy ( send_net_0213.retcode,"8999");
            strcpy ( send_net_0213.errmsg,"解包错误");
            pktonet_stock_0213(snd_data_package);        
	    $disconnect current;
            return( 0 );
        }

        /*  城综网帐户信息校验 (0213)