#include <stdio.h>#include <string.h>#include <stdlib.h>#include <sqlca.h>#include <oraca.h>#include <signal.h>#include "sp_file.h"#include "util.h"#include "acct_util.h"#define  TMP_SP_FILE_PATH	"../tmp_file/"#define  SP_FILE_PATH      "../sp_file/"int fileAttr = 0;char connStr[32];void main(int argc, char** argv){  int  ret;  int  pid;  char gs_local_net[7];  int li_ret;       memset(connStr,0x00,sizeof(connStr));    if(argc != 3){	printf("用法：命令 文件屬性(1掌上股市   數(shù)據(jù)庫鏈接串\n");	return;  }    fileAttr = atoi(argv[1]);  strcpy(connStr,argv[2]);	    strcpy(gs_local_net,"831");  li_ret = init_sqlca_info(connStr,gs_local_net);  if(li_ret != 0)  {	printf("以公共用戶登錄數(shù)據(jù)庫，初始化全局變量出錯！");	return;  }  	  pid = fork();  if(pid == -1){  	printf("創(chuàng)建企業(yè)新時空進程錯誤!\n");  	exit(-1);  }  if(pid > 0)  	exit(0);  	  pid = setsid();  if(pid == -1){  	printf("改變企業(yè)新時空進程屬性錯誤!\n");  	exit(-1);  }  /*設置UNIX下的信號無效*/  signal(SIGINT, SIG_IGN);  signal(SIGTERM, SIG_IGN);  signal(SIGQUIT, SIG_IGN);  signal(SIGCLD, SIG_IGN);   if(fileAttr == 1)		xsk_file();  else	printf("文件屬性參數(shù)無效\n");	    return;}/*企業(yè)新時空*/void xsk_file(){  int  ret;  char totalRecord[20];     char fileDateTime[15];  char fileName[128];  char command[32];    char deviceNumber[65];   char status_code[6];  char remarks[20];  int record_seri =0;    FILE *fd = NULL;    memset(command,0x00,sizeof(command));  memset(fileDateTime,0x00,sizeof(fileDateTime));  memset(fileName,0x00,sizeof(fileName));    EXEC SQL WHENEVER SQLERROR DO sql_error("function:dinner_send");  EXEC SQL CONNECT :sqlca_ib.log_id IDENTIFIED BY :sqlca_ib.log_pass USING :sqlca_ib.serv_name;    EXEC SQL SELECT TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS') INTO :fileDateTime FROM DUAL;  PackString(fileDateTime);      sprintf(fileName,"%sNCF-%s.req",TMP_SP_FILE_PATH,fileDateTime);  PackString(fileName);  if((fd = fopen(fileName,"a")) == NULL){    printf("open file error\n");    return;  }              	/*EXEC SQL DECLARE cur_smg_sp CURSOR for		select device_number,decode(status_code,'101','1','0'),decode(status_code,'101','開機','停機')		from info_busi		where  device_number like '89234%' and flag = '0' and tele_type = 'LOCAL';*/		  EXEC SQL DECLARE cur_smg_sp CURSOR for	  select a.device_number,decode(b.status_code,'101','1','0'),decode(b.status_code,'101','開機','停機') from INFO_NEW_SPACE_TIM a,info_user b	 		where a.flag = '0' and a.user_no = b.user_no and b.flag = '0';        EXEC SQL OPEN cur_smg_sp;  while(1){  	memset(deviceNumber,0x00,sizeof(deviceNumber));  	  	memset(status_code,0x00,sizeof(status_code));  	memset(remarks,0x00,sizeof(remarks));  			EXEC SQL FETCH cur_smg_sp 					INTO :deviceNumber,						 :status_code,						 :remarks;		if(sqlca.sqlcode == 1403)	break;				record_seri++;			PackString(deviceNumber);		PackString(status_code);		PackString(remarks);				fprintf(fd,"%d|%s|%s|%s|%s|\n",		record_seri,deviceNumber,status_code,fileDateTime,remarks);	fflush(fd);  }    EXEC SQL CLOSE cur_smg_sp;		      fprintf(fd,"%s\n","END");	fflush(fd);	  fclose(fd);    WriteLog(" 創(chuàng)建企業(yè)新時空文件 success\n");    sprintf(command,"mv %s/*.* %s/",TMP_SP_FILE_PATH,SP_FILE_PATH);  system(command);    return;      }void sql_error(char *msg){	EXEC SQL WHENEVER SQLERROR CONTINUE;	printf("%s:%s\n",msg,sqlca.sqlerrm.sqlerrmc);    EXEC SQL ROLLBACK RELEASE;	exit(1);}