ewsdmpt1.c

西门子EWSD程控交换机OMC接口通讯程序源代码

#include <stdio.h>
#include <fcntl.h>
#include <signal.h>
#include <sys/termio.h>
#include "init.h"

#define MINCHAR    13 
#define C_SIZE	86
#define  L_SIZE  128

int	mapfd,port;
struct  configst	conf[MAX_PORT_NO];
char	portname[20];
char    comm[L_SIZE];
char Krelease_char,Kconnect_char,Ksend_char;


main(argc,argv)
int argc;
char *argv[];
{
int	i;
int	fp;
int	pid;
	init();
	signal(SIGCLD,SIG_IGN);
	if((pid=get_pid1("mpt"))>0&&pid!=getpid()) 
	{
	 printf("mpt is already exist!pid=%d\n",pid);
	 exit(0);
	}
	portchar();
	if((fp=initport())<=0) exit(0);
	portchar();
	for(i=0;;i++)
	{
          printf("###############################################\n");
          printf("##########exec time %d #######################\n",i);
          printf("###############################################\n");
          		
	  exec_comm(fp,"19.\n");
	  scanok();
	  
	  printf("###############################################\n");
          printf("##########exec time %d #######################\n",i);
          printf("###############################################\n");
	  
	  exec_comm(fp,"19;\n");
	  scanok();
 	}
	
}
/****************************************************************/
initport()
{
struct termio 	t;
int	nn;
int 	fdd;
int	n;
char	c,str[80];
FILE	*confd;
char    porttype[5][20]={"TRAFFIC","TRAFFIC","OPERATION","TRAFFIC","TRAFFIC"};
int     porttype_no;

	if ((confd=fopen(CONFIGFILE,"rb"))==NULL){
		perror("config open");
		exit(1);
	}
	if((n=fread(conf,CONFIGLEN,MAX_PORT_NO,confd))<0){
		perror("fread");
		exit(0);
	}
	if(n==0){
		printf("there is no defined port!\n");
		exit(0);
	}
	fclose(confd);
   
	for(;;){
	system("clear");
	printf("\n                         EWSD     PORT    LIST\n");
	printf("                        ========================\n");
	printf("\n\n");
	for(port=0;port<n;port++){
		porttype_no=conf[port].data_type;
		printf("		        %d%d :  %s    %s (%s:%s) \n",port/10,port%10,conf[port].office_name,conf[port].omcport,conf[port].iogtype,porttype[porttype_no]);
	}
	printf("\n        please press 0 - %d to select exchange port(or q to exit) :",n-1);
	scanf("%s",str);
		if(strlen(str)==0)continue;
		if(str[0]=='q'||str[0]=='Q') {
			system("clear");
			system("stty sane");
			exit(0);
		}
		sscanf(str,"%d",&port);
		if(port>=0&&port<n)
			{
			 if(conf[port].data_type!=OPERAT)
				{
				printf("this is not operation port!!\n");
				printf("you should change to operat type,reactive COMIR and INFPHD!!\n");
				sleep(1);
				continue;
				}
			else break;
			}
		else {
			printf("out of range !!!\n");
			sleep(1);
			continue;
			}
	}

	system("clear");
	setbuf(stdout,(char *)0);
	system("stty -echo -isig -icanon");
	system("stty min 1");
	
	sprintf(portname,"/dev/%s",conf[port].omcport);
	
	if((fdd=open(portname,O_RDWR))<0) { perror("Open"); return(-1); }
	if((nn=ioctl(fdd,TCGETA,&t))<0) {
	  perror("Ioctl"); close(fdd); return(-1);
	  }
	t.c_lflag=0; 
/*
	t.c_cflag = B1200 | CS7 | CREAD | CLOCAL | PARENB ;
*/
	t.c_cflag=conf[port].speed | conf[port].bit_len | conf[port].paraenb | CREAD | CLOCAL;
	t.c_iflag=BRKINT | BRKINT | IGNPAR | IGNCR | IXON | IXOFF | IXANY ;
	t.c_oflag=0;
	t.c_line=0;
	t.c_cc[7]=255;
	t.c_cc[4]=1;
	t.c_cc[5]=0;

	if((nn=ioctl(fdd,TCSETA,&t))<0) {
		perror("Ioctl");
		close(fdd);
		return(-1);
	}
		c=Kconnect_char;
		write(fdd,&c,1);
	return(fdd);
}
/****************************************************************/
send_file(int spc,char *comm)
{
  char send_char;
  int  i,len;
  
  printf("send_file==>%s",comm);
  len=strlen(comm);
  for(i=0;i<len;i++) comm[i]=toupper(comm[i]);
  comm[len-1]=Ksend_char; /* send command */
  if (write(spc,comm,nn)!=nn)
  {
   perror("comis write file");
   exit(0);
  }
}  
/****************************************************************/

/****************************************************************/
init()
{

	setbuf(stdout,(char *)0);
	system("stty -echo -isig -icanon");
	system("stty min 1");
	if ((mapfd=open("/dev/vga",O_RDWR))<0){
		perror("Fault");
		exit(0);
	}
	ch_mod(mapfd);
}
/****************************************************************/
portchar()
{
struct configst	conff[MAX_PORT_NO];
int	n,port=0;
FILE	*confd;

if ((confd=fopen(CONFIGFILE,"rb"))==NULL)
{
 perror("config open");
 exit(1);
}
if((n=fread(conff,CONFIGLEN,MAX_PORT_NO,confd))<=0)
{
 perror("fread");
 exit(0);
}
fclose(confd);
for(port=0;port<n;port++)
{
 if (conff[port].data_type==OPERAT)
  {
   sprintf(ttyname[use_scrn],"/dev/%s",conff[port].omcport);
   if ((fd[use_scrn]=open(ttyname[use_scrn],O_WRONLY))<0)
   {
    perror("comis	open");
    exit(1);
   }
   conf[use_scrn].release_char=conff[port].release_char;
   Krelease_char=conff[port].release_char;
   conf[use_scrn].connect_char=conff[port].connect_char;
   Kconnect_char=conff[port].connect_char;
   conf[use_scrn].send_char=conff[port].send_char;
   Ksend_char=conff[port].send_char;
   strcpy(conf[use_scrn].iogtype,conff[port].iogtype);
   use_scrn++;
  }  /* if  */
}  /* for */
return(use_scrn);
}
/****************************************************************/
exec_comm(int fd1,char *comm)
{int i,t,resul;
 char c;


star:
  t=0;
  resul=0;
 while(resul<=0 && t<10)
 {	
  resul=justsend(">",0);
  if(resul<0 || t>1)
  {
   c=Kconnect_char;
   write(fd1,&c,1);
   nap(1000);
  } 
  resul=justsend("USERID:",0)+justsend("<",0);
   /* printf("scan userid or < is==%d\n",resul);*/
  i=0;
  while(resul==0 && i<5)
  {
   i++;
   nap(1000);
   /*  printf("scan USERID or  <  ==%d time /n",i); */
   resul=justsend("USERID:",0)+justsend("<",0);
  }
   t++;
 } /* send mm to connect the SWITCH */ 
 if(resul==0) return(0);
 resul=justsend("USERID:",0);
 if(resul>0)
 {
  send_file(fd1,PASSUSER);
  nap(1000);
  resul=justsend("PASSWORD:",0);
  i=0;
  while(resul==0 && i<10)
  {
   i++;
   nap(1000);
   /*  printf("scan USERID or  <  ==%d time /n",i); */
   resul=justsend("PASSWORD:",0);
  }
  if(resul>0)  send_file(fd1,PASSUSER);
  else goto star;
  nap(1000);
 }  /*** sent userid and password  ***/
  resul=justsend("<",0);
  i=0;
  while(resul==0 && i<10)
  {
   i++;
   nap(1000);
   /*  printf("scan USERID or  <  ==%d time /n",i); */
   resul=justsend("<",0);
  }
  if(resul>0)  
  {
   send_file(fd1,comm);
   nap(3000);
   i=0;
   resul=0;
   while(resul==0 && i<10)
   {
    i++;
    nap(2000);
    resul=justsend(">",0);
   }
   return(1);
  } 
  else goto star;
}
/****************************************************************/
justsend(str,mod)
char *str;
int mod;
{char buff[L_SIZE],endbuff[L_SIZE],portname[6];
 int resul;
 FILE   *fp;
 char   fname[50];
 long	time(),lg;
 struct	tm *localtime(),*tim;

 lg=time(&lg);
 tim=localtime(&lg);
 strcpy(portname,conf[port].omcport);
 sprintf(fname,"%s/data/%sO%s_%d%d%d%d%d",PATH,conf[port].office_name,&portname[3],tim->tm_year,(tim->tm_mon+1)/10,(tim->tm_mon+1)%10,tim->tm_mday/10,tim->tm_mday%10);
/*
 printf("%s\n",fname);
*/
 if((fp=fopen(fname,"r"))==NULL)
 {printf("open rawfile error ! \n");
  fclose(fp);
  nap(30000);
  return(-1);
 }

 fgets(endbuff,L_SIZE,fp);
 while(!feof(fp))
 {
   strcpy(buff,endbuff);
   fgets(endbuff,L_SIZE,fp);
  }
 fclose(fp);
 printf("*******scan %s********************************\n",str);
 printf("raw buff:%s\n",buff);
 printf("raw endbuff:%s\n\n",endbuff);
 if(mod==1) strcpy(endbuff,buff);
 resul=sub_str(endbuff,str);
 /*  printf("sub_str(%s,%s)=%d)\n",endbuff,str,resul);  */
 if(resul>=0)
    return(1);
 else
    return(0);
}

/****************************************************************/
scanok(int teleno)
{char portname[6],rawbuff[21][L_SIZE];
 FILE   *fp;
 char   fname[50],hour[6],tjtime[L_SIZE];
 long	time(),lg;
 struct	tm *localtime(),*tim;
 int i,lastok,succok,teleok;
 int yy,mm,dd;
 char mon_name[12][4]={"Jan","Feb","Mar","Apr","May","Jun","Jul","Aug","Sep","Oct","Nov","Dec"};


 lg=time(&lg);
 tim=localtime(&lg);
 strcpy(portname,conf[port].omcport);
 sprintf(fname,"%s/data/%sO%s_%d%d%d%d%d",PATH,conf[port].office_name,&portname[3],tim->tm_year,(tim->tm_mon+1)/10,(tim->tm_mon+1)%10,tim->tm_mday/10,tim->tm_mday%10);
 printf("%s\n",fname);
 if((fp=fopen(fname,"r"))==NULL)
 {printf("open rawfile error ! \n");
  fclose(fp);
  nap(30000);
  return(-1);
 }
 for(i=0;i<21;i++)
   if(!feof(fp))
     fgets(rawbuff[i],L_SIZE,fp);
   else
     break;
 for(;!feof(fp);)
 {
  for(i=1;i<21;i++)
     strcpy(rawbuff[i-1],rawbuff[i]);
  if(!feof(fp))   fgets(rawbuff[20],L_SIZE,fp);
 }
 fclose(fp);
 for(i=0;i<21;i++)
     printf("%s",rawbuff[i]);
 lastok=0;
 teleok=0;
 succok=0;
 for(i=0;i<20;i++)
 { if(sub_str(rawbuff[i],"LAST REPORT")>0)  lastok=1;
   if(sub_str(rawbuff[i],teleno)>0)  teleok=1;
   if(sub_str(rawbuff[i],"SUCCESSFUL")>0)
   {
    succok=1;
    if(sub_str(rawbuff[i],"NOT SUCCESSFUL")>0)  succok=2;
   }
   if(sub_str(rawbuff[i],"YULIN")>0)
   {sscanf(rawbuff[i],"%*s %4d-%2d-%2d %5s",&yy,&mm,&dd,hour);
    sprintf(tjtime,"%d %s %d %5s:00",yy,mon_name[mm-1],dd,hour); 
   }
 }
 printf("lastok=%d,teleok=%d,succok=%d,time=%s\n",lastok,teleok,succok,tjtime);
 /****1 is success,2 is not success,3 is can't know  */
 if(lastok==1&&teleok==1&&succok==1)
    return(1);
 else
   if(lastok==1&&teleok==1&&succok==2)
      return(2);
   else
      return(3);
}

/****************************************************************/
 sub_str(str1,str2)
char *str1,*str2;
{
	int l1,l2,i;
	l1=strlen(str1);
	l2=strlen(str2);
	if(l1<l2) return(-1);
	for(i=0;i<l1;i++) {
		if(l1-i<l2) return(-1);
		if(!strncmp(str1+i,str2,l2)) return(i);
	}
	return(-1);
}