main_0206.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_0206   send_net_0206;
RECV_NET_0206   recv_net_0206;

int     net_tohost_0206(sockfd,rcv_data_package,snd_data_package)
int     sockfd;
char    *rcv_data_package;
char    *snd_data_package;
{
        int    i,flag;
        char   *tmp;
        char    duig_0206_buff[1024];
        char   manager_id[10];

        $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]",rcv_data_package);

        memset(duig_0206_buff,0,sizeof(duig_0206_buff));
        i = unpknet_stock_0206(rcv_data_package,duig_0206_buff);        
        if(i == - 20)
        {
	       strcpy(snd_data_package,duig_0206_buff);
	       printf("对公数据：[%s]\n",snd_data_package);
               return(0);
	}

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

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