sjcjphzh.sqc

本人写的在AIX下的用SQLC开发的处理DB2数据库中业务的程序

      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }
      
      /*1101 可用数目调整，已经有货币代码了,可用金额用资金余额代替*/
      if ((strcmp(m_zydm,"1101")==0))
      {
      
        EXEC SQL SELECT CREDIT_END_DATE 
        	into :m_dqrq from KS.FUND
        	where CUST_NO=:m_cust_no and CURRENCY_TYPE=:m_currency_type;
      
        trim(m_dqrq);
        
      	sprintf(data,"0%s,%c,%.2f,%.2f,%s,%06d,%s,%s", m_cust_no,m_xkm_hbdm[1],m_amt17,m_amt7,m_dqrq,icntfetch,m_oldzydm,m_oldzymc);
      	
        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }

      /*1201 利息调整，已经有货币代码了,可用金额用资金余额代替*/      
      if ((strcmp(m_zydm,"1201")==0))
      {
      	sprintf(data,"0%s,%c,%.2f,%.2f,%06d,%s,%s", m_cust_no,m_xkm_hbdm[1],m_amt17,m_amt7,icntfetch,m_oldzydm,m_oldzymc);

        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }

      /*1401 股票临时冻结解冻*/      
      if ((strcmp(m_zydm,"1401")==0))
      {
      	sprintf(data,"0%s,%.2f,%.2f,%s", m_cust_no,m_amt17,m_amt7,m_oldzymc);

        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }

      /*2005 查询/委托收费*/
      if (strcmp(m_zydm,"2005")==0)
      {
      	sprintf(data,"0%s,,%.2f,%.2f,%s,%06d,%s,%s", m_cust_no,m_amt17,m_amt7,m_xkm_gddm,icntfetch,m_oldzydm,m_oldzymc);
      	
        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }
      
      /*3001-3009 股票存入取出，调入调出*/
      if ((strcmp(m_zydm,"3001")==0) || (strcmp(m_zydm,"3002")==0) || (strcmp(m_zydm,"3003")==0) || (strcmp(m_zydm,"3004")==0) || (strcmp(m_zydm,"3008")==0) || (strcmp(m_zydm,"3009")==0))
      {
        
        if (strcmp(m_zydm,"3001")==0)
        	sprintf(m_oldzymc,"%s%s%f",m_stock_code,"调入",m_amt17);
        if (strcmp(m_zydm,"3002")==0)
        	sprintf(m_oldzymc,"%s%s%f",m_stock_code,"调出",m_amt17);
        if (strcmp(m_zydm,"3003")==0)
        	sprintf(m_oldzymc,"%s%s%d",m_stock_code,"转入",m_sec_chg);
        if (strcmp(m_zydm,"3004")==0)
        	sprintf(m_oldzymc,"%s%s%d",m_stock_code,"转出",m_sec_chg);
        if (strcmp(m_zydm,"3008")==0)
        {
        	if (strcmp(m_market_code,"2")==0)
        		sprintf(m_oldzymc,"%s%s%d",m_stock_code,"配股上市",m_sec_chg);
        	if (strcmp(m_market_code,"1")==0)
        	{
       		        EXEC SQL SELECT SEC_SHORT_NAME into :m_sec_name from ks.sec_code
	        	where MARKET_CODE=:m_market_code and SEC_CODE=:m_sec_code;
			trim(m_sec_name);
			if (strcmp(m_sec_name,"")!=0)
	        		sprintf(m_oldzymc,"%s%s","买入",m_sec_name);
	        	else
	        		sprintf(m_oldzymc,"%s%s","买入",m_sec_code);
        	}
        	if (strcmp(m_market_code,"4")==0)
        		sprintf(m_oldzymc,"%s%s%d",m_stock_code,"配股上市",m_sec_chg);
        	if (strcmp(m_market_code,"3")==0)
        	{
       		        EXEC SQL SELECT SEC_SHORT_NAME into :m_sec_name from ks.sec_code
	        	where MARKET_CODE=:m_market_code and SEC_CODE=:m_sec_code;
			trim(m_sec_name);
			if (strcmp(m_sec_name,"")!=0)
	        		sprintf(m_oldzymc,"%s%s","买入",m_sec_name);
	        	else
	        		sprintf(m_oldzymc,"%s%s","买入",m_sec_code);
        	}
        }
        if (strcmp(m_zydm,"3009")==0)
        	sprintf(m_oldzymc,"%s%s%d",m_stock_code,"新股上市",m_sec_chg);
        	
      	sprintf(data,"0%s,%s,%s,%s,%d,%d,%s,%s,%06d", m_cust_no,m_xkm_gddm,m_stock_code,m_xkm_scbm,m_sec_chg,m_sec_bal,m_oldzymc,m_oldzydm,icntfetch);
        
        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }

      /*3010,3011 股票冻结解冻*/
      if ((strcmp(m_zydm,"3010")==0) || (strcmp(m_zydm,"3011")==0))
      {
        if (strcmp(m_zydm,"3010")==0)
      		sprintf(m_oldzymc,"%s%s%f",m_stock_code,"协冻-",m_amt17);
        if (strcmp(m_zydm,"3011")==0)
      		sprintf(m_oldzymc,"%s%s%f",m_stock_code,"协解-",m_amt17);
      		
      	sprintf(data,"0%s,%s,%s,%s,%d,%d,%s,%s,%06d", m_cust_no,m_xkm_scbm,m_xkm_gddm,m_stock_code,m_sec_chg,m_sec_bal,m_oldzymc,m_oldzydm,icntfetch);

        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }
      
      /*9999 特殊处理*/
      if (strcmp(m_zydm,"9999")==0)
      {
	if ((strcmp(m_market_code,"1")==0) || (strcmp(m_market_code,"2")==0))
	{
        	EXEC SQL SELECT RPT_CONTRACT_NO,DONE_PRICE,COMMISION,STAMP_TAX,CHG_OWNER_FEE into :m_order,:m_amt2,:m_yj,:m_yhs,:m_ghf from ks.his_done 
        	where SERIAL_NO=:m_lsh and OCCUR_DATE=:m_occur_date and CUST_NO=:m_cust_no;
	}
	else
	{
        	EXEC SQL SELECT RPT_CONTRACT_NO,DONE_PRICE,COMMISION,STAMP_TAX,CHG_OWNER_FEE into :m_order,:m_amt2,:m_yj,:m_yhs,:m_ghf from ks.his_done 
        	where SERIAL_NO=:m_join_lsh and OCCUR_DATE=:m_join_date and CUST_NO=:m_cust_no;
	}
        trim(m_order);
        
      	sprintf(data,"0%s,%s,%s,%s,%d,%d,%.2f,%.2f,%s,%.2f,%s,%s,%s,%.2f,%.2f,%.2f,%06d", 
      	m_cust_no,m_xkm_gddm,m_stock_code,m_xkm_scbm,m_sec_chg,m_sec_bal,m_amt17,m_amt7,m_order,m_amt2,m_oldzydm,m_oldzymc,m_bdlb,m_yj,m_yhs,m_ghf,icntfetch);
      	
        len = strlen(data);
      	
      	fprintf(fp,"1%07d",icntfetch);
      	fprintf(fp,"%4s",m_zydm);
      	fprintf(fp,"%04d",len);
      	fprintf(fp,"%8s",m_occur_date);
      	memset(outtime,0x0,sizeof(outtime));
      	outtime[0]=m_occur_time[0];
      	outtime[1]=m_occur_time[1];
      	outtime[2]=m_occur_time[3];
      	outtime[3]=m_occur_time[4];
      	outtime[4]=m_occur_time[6];
      	outtime[5]=m_occur_time[7];
      	outtime[6]='0';
      	outtime[7]='0';
      	fprintf(fp,"%8s",outtime);
      	fprintf(fp,"%c",m_xkm_hbdm[1]);
      	fprintf(fp,"0%s",(char*) (m_emp_code+3));
      	fprintf(fp,",%s%c%c",data,0x0d,0x0a);
      }
   }
   EXEC SQL CLOSE c1;
   
   EXEC SQL DECLARE c4 CURSOR FOR
       SELECT CUST_NO,SERIAL_NO,OCCUR_DATE,OCCUR_TIME,HOLDER_ACC_NO,SEC_CODE,MARKET_CODE,SEC_CHG,SEC_BAL,FUND_CHG,FUND_BAL,
       		BUSINESS_CODE,CHANGE_TYPE,CURRENCY_TYPE,OP_EMP,BANK_CODE,BANK_ACC_NO,BILL_NO 
       FROM KS.UNDLVR_FND_STK_CHG  
       where BRANCH_CODE=:m_branch_code and OCCUR_DATE=:m_today ORDER by SERIAL_NO;
   EXEC SQL OPEN c4;
   while(1)
   {
   EXEC SQL FETCH c4 INTO
       :m_cust_no,:m_lsh,:m_occur_date,:m_occur_time,:m_holder_acc_no,:m_stock_code,:m_market_code,:m_sec_chg,:m_sec_bal,:m_amt17,:m_amt7,
       :m_business_code,:m_change_type,:m_currency_type,:m_emp_code,:m_yhdm,:m_yhzh,:m_bill_no;
       
   if (SQLCODE) break;
   
      icntfetch++;
      memset(data,0x0,sizeof(data));
      TransBusinessCode(m_business_code,m_market_code,m_zydm,m_zymc,m_bdlb,m_oldzydm,m_oldzymc);

      printf("%s,%s,%s,%s,%s\n",m_branch_code,m_today,m_business_code,m_market_code,m_zydm);
      printf("%d\n",strlen(m_zydm));
      trim(m_cust_no);
      trim(m_lsh);
      trim(m_occur_date);
      trim(m_holder_acc_no);
      trim(m_occur_time);
      trim(m_stock_code);
      trim(m_market_code);
      trim(m_business_code);
      trim(m_change_type);
      trim(m_currency_type);
      trim(m_emp_code);
      trim(m_yhdm);
      trim(m_yhzh);
      trim(m_bcsm);
      trim(m_zydm);
      trim(m_zymc);
      trim(m_bdlb);
      trim(m_oldzydm);
      trim(m_oldzymc);
      trim(m_sec_code);
      trim(m_bill_no);
      
      if ((strcmp(m_emp_code,"SYSTEM")==0) || (strcmp(m_emp_code,"")==0))
      	strcpy(m_emp_code,"000SYS");
      if (strcmp(m_currency_type,"01")==0)
        strcpy(m_xkm_hbdm,"00");
      if (strcmp(m_currency_type,"03")==0)
        strcpy(m_xkm_hbdm,"01");
      if (strcmp(m_currency_type,"02")==0)
        strcpy(m_xkm_hbdm,"02");
      if (strcmp(m_currency_type,"")==0)
        strcpy(m_xkm_hbdm,"  ");
        
      if (strcmp(m_market_code,"1")==0)
        strcpy(m_xkm_scbm,"1");
      if (strcmp(m_market_code,"2")==0)
        strcpy(m_xkm_scbm,"0");
      if (strcmp(m_market_code,"3")==0)
        strcpy(m_xkm_scbm,"3");
      if (strcmp(m_market_code,"4")==0)
        strcpy(m_xkm_scbm,"2");
      if (strcmp(m_market_code,"")==0)
        strcpy(m_xkm_scbm,"");
        
      if ((strcmp(m_market_code,"3")==0) || (strcmp(m_market_code,"1")==0))
        strcpy(m_xkm_gddm,(char*)(m_holder_acc_no+1));
      else
        strcpy(m_xkm_gddm,m_holder_acc_no);
        
        EXEC SQL SELECT RPT_CONTRACT_NO,DONE_PRICE,COMMISION,STAMP_TAX,CHG_OWNER_FEE,SEC_TYPE,SEC_CODE,SEC_SHORT_NAME 
        	into :m_order,:m_amt2,:m_yj,:m_yhs,:m_ghf,:m_sec_type,:m_sec_code,:m_sec_name from ks.UNDELIVER_DONE
        	where SERIAL_NO=:m_lsh and OCCUR_DATE=:m_occur_date and CUST_NO=:m_cust_no;
        	
        trim(m_order);
        trim(m_sec_code);
        trim(m_sec_name);
        trim(m_sec_type);
        
       	strncpy(m_zqlb,m_sec_type,1);
       	m_scdm[0]=m_market_code[0];
       	m_scdm[1]=0x0;

	if (strstr("3,4",m_scdm)!=NULL)	/*如果是B股*/
	{
		if (strcmp(m_zqlb,"6")==0)
			strncpy(m_zqlb,"Z",1);
		else if (strcmp(m_zqlb,"A")==0)
			strncpy(m_zqlb,"Y",1);
	}
	m_bdlb[0]=m_scdm[0];
	m_bdlb[1]=m_zqlb[0];
	if (strcmp(m_zydm,"0001")==0)
	{
		sprintf(m_oldzymc,"%s%s","买入",m_sec_name);
	}
	if (strcmp(m_zydm,"0002")==0)
	{
		sprintf(m_oldzymc,"%s%s","卖出",m_sec_name);
		if (strcmp(m_stock_code,"FY8888")==0)
		{
			strcpy(m_zydm,"9999");
			strcpy(m_oldzydm,"FHPX");
			strcpy(m_occur_time,m_nowtime);
		}
	}
	m_bdlb[2]=0x0;
	
      	sprintf(data,"0%s,%s,%s,%s,%d,%d,%.2f,%.