main_0201.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_0201   send_net_0201;
RECV_NET_0201   recv_net_0201;

int     net_tohost_0201(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_0201_buff[1024];
       $int    T_con;
       $char   tmp_lsh[16];
       $char   t_trans_type[5];
       $char   t_acco_type[2] ;
       $char   t_account[33];
       $double t_amount;
       $char   t_req_serial[16];
       $int    t_ans_serial;
       $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_0201(rcv_data_package,duig_0201_buff);        
        if(i == - 20)
        {
	       strcpy(snd_data_package,duig_0201_buff);
	       printf("对公数据：[%s]\n",snd_data_package);
	}

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

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