main_0212.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_0212   send_net_0212;
RECV_NET_0212   recv_net_0212;

int     net_tohost_0212(sockfd,rcv_data_package,snd_data_package)
int     sockfd;
char    *rcv_data_package;
char    *snd_data_package;
{
        int    i,flag;
        char   duig_0212_buff[1024];
        char   *tmp;
        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,"接收数据:\n[%s]",rcv_data_package);

        i = unpknet_stock_0212(rcv_data_package,duig_0212_buff);        
/* add by lyf on 2001.3.27 对公接口*/
        if( i == -20)
        {
              strcpy(snd_data_package,duig_0212_buff);
              printf("对公数据：[%s]\n",snd_data_package);
              return(0);
        }
/* add by lyf on 2001.3.27 对公接口*/
        if (i<0)  {
            WriteLog(LOGFILE,"unpknet_stock  err!");
            strcpy ( send_net_0212.retcode,"8999");
            strcpy ( send_net_0212.errmsg,"解包错误");
            pktonet_stock_0212(snd_data_package);        
            return( 0 );
        }

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