datarecovery_impl.cpp

oracle下调用数据泵接口进行远程数据导出和导入（数据恢复）的CORBA服务

//		      				{
//		      						nRecordCount++;
//		      						cout << nRecordCount << ":";
//		      						for(int j=0; j<m_nFieldCount; j++)
//											{
//												cout<<"\t"<<test_values[i][j];
//											}
//											cout<<endl;
//									}
//						  }
//      		}
//      }
//			
			
									//注意，由于nBeginGetData的时候已经拿到了第一批数据，所以应该在第一批数据拿到之后，将数据加载入库

						 	   	
						 	   	break;
 	   	           
 	   	           
//   	   case 1:   //上海
//   	   	         CSH_DataRecovery   m_pSHDataRecovery = new CSH_DataRecovery();
//   	   	         rc = m_pSHDataRecovery->nBeginGetData(m_blockId,m_time,m_strProvinceCode,m_TableName, \
//   	   	                                    m_blockId,"/LostData/",DEFAULT_FILE_SIZE,DEFAULT_TIME_OUT);
//   	   	         break;
//   	   case 2:   //广州
//   	   	         CGZ_DataRecovery   m_pGZDataRecovery = new CGZ_DataRecovery();
//   	   	         rc = m_pGZDataRecovery->nBeginGetData(m_blockId,m_time,m_strProvinceCode,m_TableName, \
//   	   	                                    m_blockId,"/LostData/",DEFAULT_FILE_SIZE,DEFAULT_TIME_OUT);
   	   	         break;
   	   case 3:   //没有哪个中心有可恢复的数据
   	   					 rc = ERR_DRecovery_CANNOT_FIND_SOURCE;
   	   					 break;
   	   default:  //代表程序返回值有错误！
   	   	         cout<<"THE LOST DATA :"<<m_blockId<<"  CANN'T BE ACHIEVED FROM ANY  DATA AGENTS. "<<endl;
   	   	         rc = ERR_DRecovery_GET_SOURCEID;
    }
    
    if(rc == SUCCESS)
       //rc = m_pDdmServer -> RecoveryOK ( m_blockId, m_time, m_strProvinceCode,m_TableName, my_id);
       cout << "test success" << endl;
		//如果没有恢复成功，就算了？
		
		return rc;
}

int DataRecovery_impl::nRefuse()
{
		int rc;
		rc = m_pDdmServer -> RefuseData(m_blockId,m_time,m_strProvinceCode,m_TableName, my_id);    //这里LocationID这么填写对么
		return rc;	
}


int DataRecovery_impl::nLoadIn()
{
		int rc = SUCCESS;
		char Recoverd_data[20000];    //这个长度应该是RECOVERED_DATA文件的大小，日后需要调整。
		char tmpRecord[10000];        //由于考虑到引号的问题，这个长度应该是单条记录的最大长度的两倍
		int i,j,k,ii;
		int curStartIndex;
		int innerLen = m_nSDataLen + 2 + m_nDXX_TABLE_FIELD-1 + 2*(m_nDXX_TABLE_FIELD);
		char tmpStr[1000];					//由于考虑到引号的问题，这个长度应该是单个字段的最大长度的两倍
		ifstream datafile;
		fstream  writefile;
		int curInnerStartIndex = 0;                      //用于Recoverd_data
		int tmpStrIndex;                                 //用于tmpStr，代表在tmpStr中当前游标位置
		int tmplen;           													 //tmpStr的长度
		int DataCount = 0;
		//先把记录从文件中读取出来，组织成符合加载接口的字符串格式
		//由于自己已经知道表名和字段长，所以直接顺序读出来就行了
		//datafile.open(RECOVERY_FILE_PATH);

		//1.先把记录从文件中读取出来，组织成符合加载接口的字符串格式
		//由于自己已经知道表名和字段长，所以直接顺序读出来就行了
		datafile.open("RECOVERED_DATA");
		//1.1.取到一条没有被封装的记录
		while(datafile.getline(tmpRecord, m_nSDataLen))
		{
				DataCount ++ ;
				curStartIndex = 0;                               //用于tmpRecord，代表当前字段的起始位置
		
				//1.2.从记录中，分别取出每个字段进行分析、封装
				//先在单条记录之前加上 (
				//strcpy( Recoverd_data+curInnerStartIndex++, "\(" );
				for (i=0;i<m_nDXX_TABLE_FIELD;i++)
				{
						
						tmpStrIndex = 999-1;                        //1000是包括了字符串结束付的，减去1，因该是有999个字符，最后一个下标为998
						//每次执行之前都需要将tmpStr清空一遍
						for (ii=0;ii<1000-1;ii++)
						{
								tmpStr[ii] = ' ';
						}
						tmpStr[ii] = '\0';     //最后一个字符是不是一定要为空？				
						//采用逆序法，从最后一个字符开始组织每个字段
						//循环结束后应该得到一个将单引号变成2个单引号的字符串tmpStr，注意，原有记录中为了填充字段用的的空格也一起拷贝了下来
		    			//for (j=m_DXX_TABLE[i]-1;j>=0;j--)
						for (j=m_DXX_TABLE[i]-2;j>=0;j--)               //table_sturct的定义中算入了字符串结束符，所以要在多减1
		    		{		
		
		    				//先扫描每个字段里面有没有单引号 ' 	
								if( tmpRecord[curStartIndex+j] == '\'' )       //tmpRecord+curStartIndex+j代表在tmpRecord中当前的游标位置
	    					{
	    							//如果有单引号，则将当前字符和下一个字符都写成单引号，即两个单引号
										//不能这样做，"\'\'"实际是上"\'\'\0"，这么做会把原来\'后面跟着的字符冲掉
								    //strcpy(tmpStr+ (tmpStrIndex - (m_DXX_TABLE[i]-1-1-j) - 1), "\'\'");           //tmpStr算入了字符串结束符，所以要在多减1
	    							tmpStr[tmpStrIndex - (m_DXX_TABLE[i]-1-1-j) - 1] = '\'';
										tmpStr[tmpStrIndex - (m_DXX_TABLE[i]-1-1-j)    ] = '\'';
								    //同时游标也要跟着移动2
										tmpStrIndex--;
	    					}
								//如果没有单引号，则将tmpRecord中的当前字符写入tmpStr相应的位置中
	    					else 
	    					{
	    							tmpStr[ tmpStrIndex- (m_DXX_TABLE[i]-1-1-j)] = tmpRecord[curStartIndex+j];    //tmpStr算入了字符串结束符，所以要在多减1
	    							//tmpStrIndex--;
	    					}
		    		}
						//由于空格也算字符，考虑到将要调用的加载服务，将单引号变成两个单引号之后，可能使字符串的长度超过每个字段的规定值
						//致使字段无法正常加入，所以在加入到Recoverd_data之前，先将tmpStr中第一个不为空格的字符前的所有“空格”全部去掉
						//对于极限情况，即所有字符都是单引号时，tmpStr应该为规定的最大字段长度的两倍，但是这在oracle加载时是不会报超出字段长度的
						//错误的。
						//执行完循环之后，k代表第一个不为空格的字符的下标
	    			for (k=0; k<1000; k++)
	    			{
	    					if(tmpStr[k] != ' ')
								break;
	    			}
	    			
	    			//1.3.接下来将tmpStr进行封装，加入到Recoverd_data中去
						//先加单引号 '
	    			//strcpy( Recoverd_data+curInnerStartIndex++, "\'" ); 
						//再把记录加上
						tmplen = strlen(tmpStr+k);
						switch (m_nTableType)
						{
								case 1:
										if (i==0) strcpy(m_DzfxDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_DzfxDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_DzfxDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_DzfxDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_DzfxDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_DzfxDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_DzfxDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_DzfxDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_DzfxDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_DzfxDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_DzfxDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_DzfxDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_DzfxDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_DzfxDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_DzfxDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_DzfxDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_DzfxDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_DzfxDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_DzfxDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_DzfxDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_DzfxDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_DzfxDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_DzfxDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_DzfxDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_DzfxDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 2:
										if (i==0) strcpy(m_DzfdDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_DzfdDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_DzfdDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_DzfdDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_DzfdDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_DzfdDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_DzfdDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_DzfdDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_DzfdDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_DzfdDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_DzfdDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_DzfdDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_DzfdDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_DzfdDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_DzfdDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_DzfdDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_DzfdDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_DzfdDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_DzfdDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_DzfdDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_DzfdDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_DzfdDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_DzfdDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_DzfdDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_DzfdDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 3:
										if (i==0) strcpy(m_NrfdDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_NrfdDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_NrfdDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_NrfdDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_NrfdDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_NrfdDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_NrfdDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_NrfdDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_NrfdDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_NrfdDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_NrfdDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_NrfdDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_NrfdDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_NrfdDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_NrfdDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_NrfdDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_NrfdDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_NrfdDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_NrfdDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_NrfdDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_NrfdDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_NrfdDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_NrfdDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_NrfdDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_NrfdDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 4:
										if (i==0) strcpy(m_DzctDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_DzctDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_DzctDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_DzctDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_DzctDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_DzctDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_DzctDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_DzctDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_DzctDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_DzctDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_DzctDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_DzctDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_DzctDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_DzctDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_DzctDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_DzctDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_DzctDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_DzctDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_DzctDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_DzctDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_DzctDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_DzctDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_DzctDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_DzctDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_DzctDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 5:
										if (i==0) strcpy(m_NrctDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_NrctDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_NrctDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_NrctDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_NrctDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_NrctDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_NrctDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_NrctDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_NrctDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_NrctDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_NrctDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_NrctDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_NrctDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_NrctDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_NrctDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_NrctDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_NrctDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_NrctDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_NrctDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_NrctDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_NrctDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_NrctDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_NrctDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_NrctDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_NrctDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 6:
										if (i==0) strcpy(m_NrjcDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_NrjcDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_NrjcDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_NrjcDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_NrjcDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_NrjcDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_NrjcDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_NrjcDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_NrjcDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_NrjcDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_NrjcDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_NrjcDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_NrjcDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_NrjcDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_NrjcDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_NrjcDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_NrjcDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_NrjcDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_NrjcDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_NrjcDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_NrjcDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_NrjcDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_NrjcDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_NrjcDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_NrjcDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 7:
										if (i==0) strcpy(m_DzjsDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_DzjsDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_DzjsDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_DzjsDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_DzjsDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_DzjsDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_DzjsDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_DzjsDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_DzjsDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_DzjsDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_DzjsDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_DzjsDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_DzjsDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_DzjsDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_DzjsDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_DzjsDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_DzjsDxx[DataCount-1].dxlx = atoi(tmpStr);
					  				        else if (i==17) m_DzjsDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_DzjsDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_DzjsDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_DzjsDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_DzjsDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_DzjsDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_DzjsDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_DzjsDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;										
								case 8:
										if (i==0) strcpy(m_NrjsDxx[DataCount-1].id, tmpStr+k);
										else if (i==1) m_NrjsDxx[DataCount-1].zx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_NrjsDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==3) m_NrjsDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==4) strcpy(m_NrjsDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==5) strcpy(m_NrjsDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==6) strcpy(m_NrjsDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==7) strcpy(m_NrjsDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==8) strcpy(m_NrjsDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==9) strcpy(m_NrjsDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==10) strcpy(m_NrjsDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==11) strcpy(m_NrjsDxx[DataCount-1].mddz_sd, tmpStr+k);
										else if (i==12) strcpy(m_NrjsDxx[DataCount-1].fxr_szd, tmpStr+k);
										else if (i==13) strcpy(m_NrjsDxx[DataCount-1].sxr_szd, tmpStr+k);
										else if (i==14) m_NrjsDxx[DataCount-1].fx_dxzx = atoi(tmpStr);
										else if (i==15) m_NrjsDxx[DataCount-1].sx_dxzx = atoi(tmpStr);
										else if (i==16) m_NrjsDxx[DataCount-1].dxlx = atoi(tmpStr);
					  					else if (i==17) m_NrjsDxx[DataCount-1].bmlx = tmpStr[k];
										else if (i==18) m_NrjsDxx[DataCount-1].sf_zt = tmpStr[k];
										else if (i==19) m_NrjsDxx[DataCount-1].sf_dzfd = tmpStr[k];
										else if (i==20) m_NrjsDxx[DataCount-1].sf_nrfd = tmpStr[k];	
										else if (i==21) m_NrjsDxx[DataCount-1].sf_dzct = tmpStr[k];
										else if (i==22) m_NrjsDxx[DataCount-1].sf_nrct = tmpStr[k];
										else if (i==23) m_NrjsDxx[DataCount-1].sf_dzjc = tmpStr[k];
										else if (i==24) m_NrjsDxx[DataCount-1].sf_nrjc = tmpStr[k];
										break;
								case 9:
										if (i==0) strcpy(m_JmDxx[DataCount-1].fssj, tmpStr+k);
										else if (i==1) m_JmDxx[DataCount-1].dxzx_id = atoi(tmpStr);
										else if (i==2) strcpy(m_JmDxx[DataCount-1].fwq_ip, tmpStr+k);
										else if (i==3) strcpy(m_JmDxx[DataCount-1].dx_xh, tmpStr+k);
										else if (i==4) strcpy(m_JmDxx[DataCount-1].dxx_block_id, tmpStr+k);
										else if (i==5) strcpy(m_JmDxx[DataCount-1].ydz, tmpStr+k);
										else if (i==6) strcpy(m_JmDxx[DataCount-1].mddz, tmpStr+k);
										else if (i==7) strcpy(m_JmDxx[DataCount-1].dxnr, tmpStr+k);
										else if (i==8) strcpy(m_JmDxx[DataCount-1].ydz_sd, tmpStr+k);
										else if (i==9) strcpy(m_JmDxx[DataCount-1].mddz_sd, tmpStr+k);