开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > 其他嵌入式/单片机内容 > 查看源码
NsIec104Server.c
资源名称：iec104.rar　[点击查看]
上传用户：liao421
上传日期：2013-01-30
资源大小：11k
文件大小：92k
源码类别：

其他嵌入式/单片机内容

开发平台：

C/C++

NsIec104Server.c：源码内容
  1. /*
  3.             Modify Record 
  4.             2002-11-16            Add Network Card Value Geting From nsc200.ini
  5.             2002-12-26            According   Nedd,adding Send chang yc
  7. */
  8. #include <socket.h>
  9. #include <sockLib.h>
  10. #include <stdlib.h>
  11. #include <sysLib.h>
  12. #include <logLib.h>
  13. #include <errno.h>
  14. #include <string.h> 
  15. #include <stdio.h> 
  16. #include <time.h>
  17. #include "wdLib.h"
  18. #include "in.h"
  19. #include "ioLib.h"
  21. #include "constant.h"
  22. #include "NsDataBase.h"
  23. #include "NsExtTime.h"
  24. #include "NsIoFunction.h"
  25. #include "NsCommon.h"
  26. #include "NsReadOnly.h"
  27. #include "ExtDataBase.h"
  29. #include "Project/NsIec104.h"
  31. static NS_IEC104_MAIN      NsIec104Struct;
  34.         void       NsNetServerProcess(void);
  36. static  void       NsIec104Process(void);
  37. static  void       NsIec104Init(unsigned char Card,short Port);
  38. static  void       NsIec104NetInit(void);
  40. static  void       NsIec104Reset(void);
  41. static  void       NsIec104ProcessFormatI(void);
  42. static  void       NsIec104ProcessFormatS(void);
  43. static  void       NsIec104ProcessFormatU(void);
  44. static  void       NsIec104Interrogation(void);
  45. static  void       NsIec104InterrogationGroup(void);
  46. static  void       NsIec104InterrogationAll(void);
  47. static  void       NsIec104ProcessYxGroup(unsigned char Group);
  48. static  void       NsIec104ProcessYcGroup(unsigned char Group);
  49. static  void       NsIec104ProcessCellGroup(unsigned char Group);
  50. static  void       NsIec104ProcessTime(void);
  51. static  void       NsIec104ProcessYkYt(void);
  52. static  void       NsIec104ProcessPulse(void);
  53. static  void       NsIec104DefaultGroup(unsigned char Group);
  54. static  void       NsIec104ProcessPulseData(void);
  55. static  void       NsIec104SendGroup(void);
  57. static  void       NsIec104SendYkMessage(short Who,unsigned char Action);
  58. static  void       NsIec104ReceiveYkReturn(void);
  59. static  void       NsIec104SendYkSelectConfirm(void);
  60. static  void       NsIec104SendYkExeConfirm(void);
  61. static  void       NsIec104SendYkEscConfirm(void);
  62. static  unsigned char        NsIec104SendCosSoe(void);
  63. static  void       NsIec104InitYk(void);
  64. static  void       NsIec104CycleCount(void);
  65. static  void       NsIec104SendChangeYc(void);
  66. /*
  67. static void     Iec104testCosSoe(void);
  68. void  debug104(void);
  69. */
  70. static  void       NsIec104Init(unsigned char Card,short Port)
  71. {
  72.  unsigned short    i;
  73.  int               Result;
  74.  char              Buff[32];
  75.  char              Ip0Buff[64],Ip0Route[64];
  76.  char              Ip1Buff[64],Ip1Route[64];
  77.  NS_SYSTEM_DATA_MODE SysData;
  79.     NsIec104Struct.LinkState=NS_DISCONNECTED;
  80.     NsIec104Struct.NsNewSocketId=0;
  81.     getforsecond(&NsIec104Struct.LinkValidTime);
  82.     NsIec104Struct.ReceiveIndex=0;  
  83.     NsIec104Struct.ReceiveIndexLength=0;  
  84.     NsIec104Struct.SendMeNumber=0;  
  85.     NsIec104Struct.HasSendNumber=0;
  86.     NsIec104Struct.NeedSendNumber=0;
  87.     NsIec104Struct.LeftSendNumber=0;
  88.     NsIec104Struct.Card=Card;
  89.     NsIec104Struct.Port=Port;
  90.     NsIec104Struct.YkStartSign=OFF;
  91.     NsIec104Struct.Table=0;
  92.     NsIec104Struct.NetRunSign=OFF;
  93.     NsIec104Struct.SetNetSign=OFF;
  95.     Result=ReadNsc200Ini("NsIec104","SetTimeFlag",Buff);
  96.     if(Result)
  97.     {
  98.         NsIec104Struct.SetTimeFlag=1;
  99.     }
  101.     for(i=0;i<NS_IEC104_USE_CYCLE;i++) 
  102.     {
  103. getforsecond(&NsIec104Cycle[i].LastTime);
  104. NsIec104Cycle[i].TimeNap= NsIec104Nap[i];
  105.         NsIec104Cycle[i].TimeSign=OFF; 
  106.     }
  108.     for(i=0;i<NS_IEC104_MAX_YC;i++)
  109.         NsIec104Struct.YcNap[i]=5;
  110.     NsIec104Struct.YcChangeCycle=0;
  111.     
  112.      NsIec104Struct.TableNo = NsGetCommTable(Port);
  113. GetSysDataMode(NsIec104Struct.TableNo,&SysData);
  114. /*NsIec104Struct.XYxNum  = SysData.NsYxTableNumber;
  116. NsIec104Struct.XYmNum  = SysData.NsYmTableNumber;*/
  117. NsIec104Struct.XYcNum  = SysData.NsYcTableNumber;
  118. NsIec104Struct.XYcCycleNum = (NsIec104Struct.XYcNum + NS_IEC104_ONCE_YC_COUNT - 1) / NS_IEC104_ONCE_YC_COUNT;
  119.        
  120. }
  123. static  void        NsIec104NetInit(void)
  124. {
  125.  int               Result;
  126.  char              Buff[32];
  127.  char              Ip0Buff[64],Ip0Route[64];
  128.  char              Ip1Buff[64],Ip1Route[64];
  130.     NsTcpServerInit(NsIec104Struct.Card,NsIec104Struct.Port,"10.14.127.200");
  131.     switch(NsIec104Struct.Card)
  132.     {
  133.         case 0:
  134.                 Result=ReadNsc200Ini("NsIec104","Route0Sign",Buff);
  135.                 if(Result)
  136.                 {
  137.                    NsReadIpAddress("NsIec104","Route0Net",Ip0Buff);     
  138.                    NsReadIpAddress("NsIec104","Route0Ip",Ip0Route);  
  139.                    NsAddRoute(Ip0Buff,Ip0Route);   
  140.                 }
  141.                 break;
  142.         case 1:
  143.                 Result=ReadNsc200Ini("NsIec104","Route1Sign",Buff);
  144.                 if(Result)
  145.                 {
  146.                    NsReadIpAddress("NsIec104","Route1Net",Ip1Buff);     
  147.                    NsReadIpAddress("NsIec104","Route1Ip",Ip1Route);     
  148.                    NsAddRoute(Ip1Buff,Ip1Route);   
  149.                 }
  150.                 break;
  151.         default:
  152.                 break;
  153.     }
  154. }
  159. static  void        NsIec104InitYk(void)
  160. {
  162.     NsIec104Struct.YkStartSign=OFF;
  163.     NsIec104Struct.YkNowState=0xff;
  164.     NsIec104Struct.YkCellNumber=0xff;
  165.     NsIec104Struct.YkKgNumber=0xff;
  167. }
  169. void NsNetServerProcessv(void)
  170. {
  172.     while(1)
  173.     {
  174.       taskDelay(88);
  175.     }
  176. }
  179. void NsNetServerProcess(void)
  180. {
  181.  unsigned long     Now,Nap;
  182.  unsigned short    Card;
  183.  int               Result;
  184.  char              Buff[32];
  185.  
  186.    Card=0;
  187.    Result=ReadNsc200Ini("NsTasks","NsServerCard",Buff);
  188.    if(Result)
  189.    {
  190.       Card=Result;
  191.       if(Card<=2&&Card>0)
  192.       {
  193.         Card-=1;
  194.       }
  195.    }
  196.    NsIec104Init(Card,2404);
  197.    for(;;)
  198.    {
  199.         NsIec104Struct.SystemState = NsGetSysParameter(NS_NSCC_STATE);
  200.         NsIec104Struct.NetRunSign  = NsNetConfigState();
  202.         if(NsIec104Struct.NetRunSign==ON&&NsIec104Struct.SetNetSign==OFF&&NsIec104Struct.SystemState==DUTY)
  203.         {
  204.            NsIec104NetInit();
  205.            NsIec104Struct.SetNetSign=ON;
  206.         }
  207.         if(NsIec104Struct.NetRunSign==ON&&NsIec104Struct.SetNetSign==ON&&NsIec104Struct.SystemState==DUTY)
  208.         {
  209.           getforsecond(&Now);
  210.           Nap=DiffMsLong(Now,NsIec104Struct.LinkValidTime);
  211.           if(Nap>NS_IEC104_PERMIT_TIME)
  212.           {
  213.              NsIec104Struct.LinkState=NS_DISCONNECTED;
  214.           }
  215.           if(NsIec104Struct.YkStartSign==ON)
  216.           {
  217.              Nap=DiffMsLong(Now,NsIec104Struct.YkStartTime);
  218.              if(Nap>NS_IEC104_YK_PERMIT_TIME)
  219.              {
  220.                  NsIec104InitYk();
  221.              }
  222.           }
  223.           if(NsIec104Struct.LinkState==NS_DISCONNECTED)
  224.           {
  226.               NsIec104Struct.NsNewSocketId=NsTcpConnect(NsIec104Struct.NsNewSocketId,NsIec104Struct.Card);
  228.               if(NsIec104Struct.NsNewSocketId>0)
  229.               {
  230.                  NsIec104Struct.LinkState=NS_CONNECTED;  
  231.                  NsIec104Struct.SendMeNumber=0;  
  232.                  getforsecond(&NsIec104Struct.LinkValidTime);
  233.               }
  234.               else 
  235.              {
  236.                  /*NsIec104Init(NsIec104Struct.Card,NsIec104Struct.Port);*/
  237.                 
  238.                 /*  NsTcpServerInit(NsIec104Struct.Card,NsIec104Struct.Port,"10.14.8.23");*/
  239.                  NsIec104Struct.LinkState=NS_DISCONNECTED;
  240.                  NsIec104Reset();
  241.                  taskDelay(866);
  242.              }
  243.           }  
  244.           else 
  245.           {
  246.            
  247.           NsIec104Struct.ReceiveIndexLength=recv(NsIec104Struct.NsNewSocketId,&NsIec104Struct.ReceiveBuffer[NsIec104Struct.ReceiveIndex],198,0);
  248.           
  249.              if(NsIec104Struct.ReceiveIndexLength>0)
  250.              {
  251.                 NsIec104Struct.ReceiveLength+=NsIec104Struct.ReceiveIndexLength;
  252.                 if(NsIec104Struct.ReceiveLength<NS_IEC104_RECEIVEBUFFER)
  253.                 {
  254.                     NsIec104Process();
  255.                 }
  256.                 else 
  257.                 {
  258.                     NsIec104Reset();
  259.                 }
  260.                 /*
  261.                 debug104();
  262. Iec104testCosSoe();
  263. */
  264.                 getforsecond(&NsIec104Struct.LinkValidTime);
  265.              }
  266.              
  267.              NsIec104ReceiveYkReturn();
  268.              NsIec104SendGroup();
  270.              if(NsIec104Struct.LeftSendNumber==0)
  271.              {
  272.                   NsIec104Struct.CosSign=NsIec104SendCosSoe();
  273.                   if(NsIec104Struct.CosSign==0)
  274.                   {
  275.                      NsIec104SendChangeYc();
  276.                   }
  277.              }
  278.           }
  279.           NsIec104CycleCount();
  280.       }
  281.       taskDelay(18);
  282.    }
  283. }
  285. static void  NsIec104SendChangeYc(void)
  286. {
  288. unsigned short   General,Index;
  289. unsigned char    *P;
  290. unsigned short   i,RealNumber;
  291.          short   *Pyc,YcValue,YcNap;
  292. float fYc;
  296.           Index=0;
  297.           NsIec104Struct.SendBuffer[Index++]=0x68;
  298.           NsIec104Struct.SendBuffer[Index++]=0x00;
  300.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  301.           P=(unsigned char *)&RealNumber;
  302.           NsIec104Struct.SendBuffer[Index++]=P[0];                                /*     send number       */
  303.           NsIec104Struct.SendBuffer[Index++]=P[1];
  304.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  307.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];  /*     receive number    */
  308.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  310.           NsIec104Struct.SendBuffer[Index++]=9;                        /*    asdu type   */
  311.           NsIec104Struct.SendBuffer[Index++]=0;                  /*    information object count No 7 Byte */
  313.            /*  REASONBYTE  now is two */
  314.           NsIec104Struct.SendBuffer[Index++]=3;                 /*    reason  */
  315.           NsIec104Struct.SendBuffer[Index++]=0x0;                      /*    reason  */
  317.           NsIec104Struct.SendBuffer[Index++]=0x01;
  318.           NsIec104Struct.SendBuffer[Index++]=0x00;
  319. /*             
  320.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  321.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  322. */
  323.           NsIec104Struct.YcLibIndex=NsIec104Struct.YcChangeCycle*NS_IEC104_ONCE_YC_COUNT;
  324.           /*NsIec104Struct.YcChangeCycle=(NsIec104Struct.YcChangeCycle+1)%NS_IEC104_CHANGE_YC_CYCLE;*/
  325.           NsIec104Struct.YcChangeCycle=(NsIec104Struct.YcChangeCycle+1)%NsIec104Struct.XYcCycleNum;
  326.           
  327.           NsIec104Struct.YcChangeCount=0;
  329.           switch(NsIec104Struct.Table)
  330.           {
  331.                  case 0:
  332.                       NsGetDd1Lib(NS_YC_DATA,NsIec104Struct.YcLibIndex,NsIec104Struct.DataBuff,NS_IEC104_ONCE_YC_COUNT);
  333.                       break;
  334.                  case 1:
  335.                       NsGetDd2Lib(NS_YC_DATA,NsIec104Struct.YcLibIndex,NsIec104Struct.DataBuff,NS_IEC104_ONCE_YC_COUNT);
  336.                       break;
  337.                  case 2:
  338.                       NsGetDd3Lib(NS_YC_DATA,NsIec104Struct.YcLibIndex,NsIec104Struct.DataBuff,NS_IEC104_ONCE_YC_COUNT);
  339.                       break;
  340.                  case 3:
  341.                       NsGetDd4Lib(NS_YC_DATA,NsIec104Struct.YcLibIndex,NsIec104Struct.DataBuff,NS_IEC104_ONCE_YC_COUNT);
  342.                       break;
  343.           }
  345.           for(i=0;i<NS_IEC104_ONCE_YC_COUNT;i++)
  346.           {
  347.                  /*Pyc=(short *)&NsIec104Struct.DataBuff[2*i];
  348.                  YcValue= *Pyc;
  349.                  YcNap=YcValue-NsIec104Struct.YcLastValue[NsIec104Struct.YcLibIndex+i];
  350.                  if(YcNap<0)
  351.                       YcNap=NsIec104Struct.YcLastValue[NsIec104Struct.YcLibIndex+i]-YcValue;
  352.  
  353.                  if(YcNap>NsIec104Struct.YcNap[NsIec104Struct.YcLibIndex+i])
  354.                  {
  355.                       NsIec104Struct.YcChangeCount++;
  356.                       NsIec104Struct.YcLastValue[NsIec104Struct.YcLibIndex+i]=YcValue;*/    
  357.                       /* Information Object Address Now Three Bytes */
  358.                       General=0x701+NsIec104Struct.YcLibIndex+i;
  359.                       P=(unsigned char    *)&General;
  360.                       NsIec104Struct.SendBuffer[Index++]=P[0];
  361.                       NsIec104Struct.SendBuffer[Index++]=P[1];
  362.                       NsIec104Struct.SendBuffer[Index++]=0;
  364.                       /*fYc = YcValue * 1.0;
  365.       P=(unsigned char    *)&fYc;
  367.       NsIec104Struct.SendBuffer[Index++]=P[0];
  368.                       NsIec104Struct.SendBuffer[Index++]=P[1];
  369.         NsIec104Struct.SendBuffer[Index++]=P[2];
  370.                       NsIec104Struct.SendBuffer[Index++]=P[3];*/
  371.         NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[2*i];
  372.                       NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[2*i + 1];
  373.                       NsIec104Struct.SendBuffer[Index++]=0x00;  /*qds*/
  374.                   /*}*/
  375.           }
  377.           /* Repair Length  and Count*/
  378.           NsIec104Struct.SendBuffer[1]=Index-2;
  379.           NsIec104Struct.SendBuffer[7]=NsIec104Struct.YcChangeCount;
  380.           if(NsIec104Struct.YcChangeCount>0)
  381.           {/*
  382.              printf("n Co=%d Ind=%dGe=%d",NsIec104Struct.YcChangeCount,NsIec104Struct.YcLibIndex,General);
  383. */
  384.              if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  385.              {
  386.                perror ("Client FirstWrite Error");
  387.              }
  388.           }
  389. }
  392. static void  NsIec104SendGroup(void)
  393. {
  394.   if(NsIec104Struct.NeedSendNumber>0&&NsIec104Struct.HasSendNumber<NS_IEC104_MAX_K)
  395.   {
  396.      /*
  397.            printf("n GroupId=%d",NsIec104Struct.NsNewSocketId);
  398.      */
  399.      if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[NsIec104Struct.LeftSendNumber][0],NsIec104Struct.GroupSendLength[NsIec104Struct.LeftSendNumber],0x0))<0)
  400.      {
  401.         perror ("GRoup Erroe");
  402.      }
  403.      
  404.      NsIec104Struct.LeftSendNumber++;  
  405.      /* 
  406.        printf("n Send Group=%d",NsIec104Struct.SendLength);
  407.       */
  408.     if(NsIec104Struct.LeftSendNumber>=NsIec104Struct.NeedSendNumber)
  409.     {
  410.        NsIec104Struct.HasSendNumber=0;
  411.        NsIec104Struct.NeedSendNumber=0;
  412.        NsIec104Struct.LeftSendNumber=0;
  413.     }
  414.   }
  415.   taskDelay(108);
  417. }
  420. static void  NsIec104Process(void)
  421. {
  422.  int              i;
  424. /*      printf("r:");
  425.       for(i=0;i<NsIec104Struct.ReceiveLength;i++)
  426.           printf("%4x",NsIec104Struct.ReceiveBuffer[i]);
  427.       printf("n");
  428. */      
  429.     if(NsIec104Struct.ReceiveLength>=NS_IEC_104_MIN_LENGTH&&NsIec104Struct.ReceiveBuffer[0]==NS_IEC_104_HEAD)
  430.     {                            
  431.        NsIec104Struct.FormatType=NsIec104Struct.ReceiveBuffer[2]&0x03;
  432.        if(NsIec104Struct.FormatType==0||NsIec104Struct.FormatType==2)            /* I */
  433.        {
  434.               NsIec104ProcessFormatI();
  435.        }
  436.        else 
  437.        {
  438.               if(NsIec104Struct.FormatType==1)     /*  S  */ 
  439.                    NsIec104ProcessFormatS();
  440.               else
  441.               {
  442.                    if(NsIec104Struct.FormatType==3)/*  U  */
  443.                       NsIec104ProcessFormatU();
  444.               }
  445.         }
  446.         NsIec104Reset();
  447.     }
  449. }
  451. static  void  NsIec104ProcessFormatI(void)
  452. {
  453. int i;
  454. unsigned  char   *p;
  455. unsigned  short  NoWay;
  456. /* 
  457.        printf("nFormatI");
  458. */
  459.        NsIec104Struct.ApduLength=NsIec104Struct.ReceiveBuffer[1];
  460.        if(NsIec104Struct.ApduLength>NS_IEC_104_MIN_LENGTH)
  461.        {
  462.           NsIec104Struct.ReceiveHimNumber[0]=NsIec104Struct.ReceiveBuffer[2];
  463.           NsIec104Struct.ReceiveHimNumber[1]=NsIec104Struct.ReceiveBuffer[3];
  464.           NoWay=*(unsigned short *)&NsIec104Struct.ReceiveHimNumber[0];
  465.           NoWay>>=1;
  466.           NoWay+=1;
  467.           NoWay<<=1;
  468.           p=(unsigned char *)&NoWay;
  469.           NsIec104Struct.ReceiveHimNumber[0]=p[0];
  470.           NsIec104Struct.ReceiveHimNumber[1]=p[1];
  472.           NsIec104Struct.AsduType=NsIec104Struct.ReceiveBuffer[6];  
  474.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  475.              NsIec104Struct.TransmitReason[i]=NsIec104Struct.ReceiveBuffer[NS_STARTREASON+i];
  476.          
  477.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  478.              NsIec104Struct.CommonAsduAddress[i]=NsIec104Struct.ReceiveBuffer[NS_STARTASDUADDRESS+i];
  480.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  481.              NsIec104Struct.InformationObject[i]=NsIec104Struct.ReceiveBuffer[NS_STARTINFORMATION+i];
  483.           NsIec104Struct.AsduQualifier=NsIec104Struct.ReceiveBuffer[NS_STARTQUALIFIER];  
  485.           switch(NsIec104Struct.AsduType)
  486.           {
  487.              case 46:
  488.              case 47:
  489.                       NsIec104Struct.YkYtType=NsIec104Struct.AsduType;
  490.                       NsIec104ProcessYkYt();
  491.                       break;
  492.              case 100:  /* Interrogation */
  493.                       NsIec104Interrogation();
  494.                       break;
  495.              case 101:
  496.                       NsIec104ProcessPulse();
  497.                       break;
  498.              case 103:
  499.                       NsIec104ProcessTime();
  500.                       /*
  501.                         printf("n Time1");
  502.                        */
  503.                       break;
  504.              default:
  505.                       break;
  506.           }
  507.        }
  508. }
  511. static  unsigned  char       NsIec104SendCosSoe(void)
  512. {
  513. unsigned short     Number;
  514. NS_SOE_FORMAT      SoeData;
  515. NS_COS_FORMAT      CosData;   
  516. unsigned short     Index,SendCount;
  517. unsigned char      *P,i,CosSendSign;
  518. unsigned short     RealNumber,Object,Msecond;
  520.   Index=0;
  521.   CosSendSign=0;
  522.   Number=NsCheckDd1Cos();
  523.   if(Number>0)
  524.   {
  525.           if(Number>36)
  526.              Number=36;
  527.           SendCount=0;
  528.           Index=0;
  529.           NsIec104Struct.SendBuffer[Index++]=0x68;
  530.           NsIec104Struct.SendBuffer[Index++]=0x00;
  532.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  533.           P=(unsigned char *)&RealNumber;
  534.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  535.           NsIec104Struct.SendBuffer[Index++]=P[1];
  536.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  539.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  540.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  542.           NsIec104Struct.SendBuffer[Index++]=0x01;                 /*    0x01--->0x02 asdu type   */
  543.           NsIec104Struct.SendBuffer[Index++]=1;                  /*    information object count  */
  545.            /*  REASONBYTE  now is two */
  546.           NsIec104Struct.SendBuffer[Index++]=0x03;               /*    reason  */
  547.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  549.              
  550.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  551.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  552.           for(i=0;i<Number;i++)
  553.           {
  554.                if(NsGetDd1CosLib(&CosData)==ON)
  555.                {
  556.                  SendCount++;
  557.                  /* Information Object Address now three byte:  0xc01---0xc80 */
  558.                  Object=CosData.SendNumber+0x01;
  559.                  P=(unsigned char *)&Object;
  560.                  NsIec104Struct.SendBuffer[Index++]=P[0];
  561.                  NsIec104Struct.SendBuffer[Index++]=P[1];
  562.                  NsIec104Struct.SendBuffer[Index++]=0x00;
  563.                  NsIec104Struct.SendBuffer[Index++]=CosData.State;
  564.                }
  566.           }
  567.           
  568.           /* Repair Length */
  569.           NsIec104Struct.SendBuffer[7]=SendCount;  /* vsq number */
  570.           NsIec104Struct.SendBuffer[1]=Index-2;
  572.   }
  573.   else 
  574.   {
  575.       Number=NsCheckDd1Soe();
  576.       if(Number>0)
  577.       {
  578.          if(Number>18)
  579.             Number=18;
  580.           SendCount=0;
  581.           Index=0;
  582.           NsIec104Struct.SendBuffer[Index++]=0x68;
  583.           NsIec104Struct.SendBuffer[Index++]=0x00;
  585.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  586.           P=(unsigned char *)&RealNumber;
  587.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  588.           NsIec104Struct.SendBuffer[Index++]=P[1];
  589.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  592.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  593.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  595.           NsIec104Struct.SendBuffer[Index++]=30;                 /*    asdu type   */
  596.           NsIec104Struct.SendBuffer[Index++]=1;                  /*    information object count  */
  598.            /*  REASONBYTE  now is two */
  599.           NsIec104Struct.SendBuffer[Index++]=0x03;               /*    reason  */
  600.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  602.              
  603.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  604.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  606.           for(i=0;i<Number;i++)
  607.           {
  608.               if(NsGetDd1SoeLib(&SoeData)==ON)
  609.               {               
  610.                  SendCount++;
  611.                  /* Information Object Address now three byte:  0xc01---0xc80 */
  612.                  Object=SoeData.SendNumber+0x01;
  613.                  P=(unsigned char *)&Object;
  614.                  NsIec104Struct.SendBuffer[Index++]=P[0];
  615.                  NsIec104Struct.SendBuffer[Index++]=P[1];
  616.                  NsIec104Struct.SendBuffer[Index++]=0x00;
  617.                  NsIec104Struct.SendBuffer[Index++]=SoeData.State;
  618.                  Msecond=SoeData.Msecond+SoeData.Second*1000;
  619.                  P=(unsigned char *)&Msecond;
  620.                  NsIec104Struct.SendBuffer[Index++]=P[0];
  621.                  NsIec104Struct.SendBuffer[Index++]=P[1];
  622.                  NsIec104Struct.SendBuffer[Index++]=SoeData.Minute;
  623.                  NsIec104Struct.SendBuffer[Index++]=SoeData.Hour;
  624.                  NsIec104Struct.SendBuffer[Index++]=SoeData.Day;
  625.                  NsIec104Struct.SendBuffer[Index++]=SoeData.Month;
  626.                  NsIec104Struct.SendBuffer[Index++]=(SoeData.Year-2000);
  628.               }
  629.            }
  630.           /* Repair Length */
  631.           NsIec104Struct.SendBuffer[7]=SendCount;  /* vsq number */
  632.           NsIec104Struct.SendBuffer[1]=Index-2;
  633.       }
  634.       else 
  635.       {
  636.          if(NsIec104Cycle[0].TimeSign== ON)
  637.          {
  638.                     Index=0;
  639.                     NsIec104Struct.SendBuffer[Index++]=0x68;
  640.                     NsIec104Struct.SendBuffer[Index++]=0x04;
  641.                     NsIec104Struct.SendBuffer[Index++]=0x43;
  642.                     NsIec104Struct.SendBuffer[Index++]=0x00;
  643.                     NsIec104Struct.SendBuffer[Index++]=0x00;
  644.                     NsIec104Struct.SendBuffer[Index++]=0x00;
  645.                     NsIec104Cycle[0].TimeSign=OFF;
  646.          }
  647.       }
  648.   }
  649.   if(Index>0)
  650.   {
  651.      NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0);
  652.      CosSendSign=0x01;
  653.   }
  654.   return CosSendSign;
  655. }
  659. static  void       NsIec104ProcessYkYt(void)
  660. {
  662. unsigned char     YkInformation,YkReason,YkWhat;
  663. unsigned short    YkObject;
  664. unsigned char     Media,YkAction;
  665. NS_RELATION       Dear;
  667. /*
  668.      Information Object Address 0xb01---0xb80  
  669.  for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  670.              NsIec104Struct.TransmitReason[i]=NsIec104Struct.ReceiveBuffer[NS_STARTREASON+i];
  671. for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  672.              NsIec104Struct.InformationObject[i]=NsIec104Struct.ReceiveBuffer[NS_STARTINFORMATION+i];
  674. */
  676.  YkInformation=NsIec104Struct.ReceiveBuffer[NS_STARTINFORMATION+NS_IEC_104_INFORMATIONBYTE];
  677.  YkReason=NsIec104Struct.ReceiveBuffer[NS_STARTREASON];
  679.  YkObject=NsIec104Struct.ReceiveBuffer[NS_STARTINFORMATION]+NsIec104Struct.ReceiveBuffer[NS_STARTINFORMATION+1]*256;
  680.  YkObject-=0xb01;
  682.  YkWhat=0;  /* nothing */ 
  683.  if(YkReason==6)
  684.  {
  685.       if(YkInformation&0x80)    /* YkSelect  */
  686.           YkWhat=1;
  687.       else 
  688.           YkWhat=2;             /*  YkExe*/
  691.  }
  692.  else 
  693.      if(YkReason==8)  /* Esc*/
  694.         YkWhat=3;
  696.  switch(YkWhat)
  697.  {
  698.    case 1:  /* select */
  699.          NsIec104Struct.ReceiveYkId=YkObject;
  700.          YkAction=YkInformation&0x03;
  701.          switch(YkAction)
  702.          {
  703.            case  1:   /* Open */
  704.                   NsIec104Struct.YkCellAction=NS_TRIP;
  705.                   break;
  706.            case  2:    /*  close */
  707.                   NsIec104Struct.YkCellAction=NS_CLOSE;       
  708.                   break;     
  709.            default:
  710.                   break;
  711.          }
  712.          NsIec104Struct.YkCellNumber=NsGetYkCell(NS_YK_CELL_NUMBER,NsIec104Struct.ReceiveYkId);
  713.          NsIec104Struct.YkKgNumber=NsGetYkCell(NS_YK_CELL_KG,NsIec104Struct.ReceiveYkId);
  714.          NsIec104Struct.YkNowState=NS_YK_SELECT;
  715.          Media=NsGetYkCell(NS_YK_CELL_CPU,NsIec104Struct.ReceiveYkId); 
  716.          Dear.NsYkPort=NsIec104Struct.Card+NS_IEC_104_YK_BASE_PORT;
  717.          Dear.NsYkSlavePort=Media;
  718.          NsPutDear(&Dear,6);
  719.          NsIec104SendYkMessage(NS_YK_SELECT,NsIec104Struct.YkCellAction);
  720.          NsIec104Struct.YkStartSign=ON;
  721.          getforsecond(&NsIec104Struct.YkStartTime);
  722.          /*
  723.             printf("n Send Yk SelectId=%d Cell=%d Kg=%d",NsIec104Struct.ReceiveYkId,NsIec104Struct.YkCellNumber,NsIec104Struct.YkKgNumber);
  724.           */
  725.          break;
  726.    case 2:                   /*  YkExe   */
  727.          NsIec104Struct.ReceiveYkId=YkObject;
  728.          YkAction=YkInformation&0x03;
  729.          switch(YkAction)
  730.          {
  731.             case  1:   /* Open */
  732.                   NsIec104Struct.YkCellAction=NS_TRIP;
  733.                   break;
  734.             case  2:    /*  close */
  735.                   NsIec104Struct.YkCellAction=NS_CLOSE;       
  736.                   break;     
  737.             default:
  738.                   NsIec104Struct.YkCellAction=0xff;       
  739.                   break;
  740.           }
  741.           NsIec104Struct.YkCellNumber=NsGetYkCell(NS_YK_CELL_NUMBER,NsIec104Struct.ReceiveYkId);
  742.           NsIec104Struct.YkKgNumber=NsGetYkCell(NS_YK_CELL_KG,NsIec104Struct.ReceiveYkId);
  743.           NsIec104Struct.YkNowState=NS_YK_EXE;
  744.           Media=NsGetYkCell(NS_YK_CELL_CPU,NsIec104Struct.ReceiveYkId); 
  745.           Dear.NsYkPort=NsIec104Struct.Card+NS_IEC_104_YK_BASE_PORT;
  746.           Dear.NsYkSlavePort=Media;
  747.           NsPutDear(&Dear,6);
  748.           NsIec104SendYkMessage(NS_YK_EXE,NsIec104Struct.YkCellAction);
  749.           NsIec104Struct.YkStartSign=ON;
  750.           getforsecond(&NsIec104Struct.YkStartTime);
  751.           /*
  752.            printf("n Send Yk ExeId=%d Cell=%d Kg=%d",NsIec104Struct.ReceiveYkId,NsIec104Struct.YkCellNumber,NsIec104Struct.YkKgNumber);
  753.            */
  754.           break;
  755.    case 3:
  756.           NsIec104Struct.ReceiveYkId=YkObject;
  757.           YkAction=YkInformation&0x03;
  758.           switch(YkAction)
  759.           {
  760.             case  1:   /* Open */
  761.                   NsIec104Struct.YkCellAction=NS_TRIP;
  762.                   break;
  763.             case  2:    /*  close */
  764.                   NsIec104Struct.YkCellAction=NS_CLOSE;       
  765.                   break;     
  766.             default:
  767.                   NsIec104Struct.YkCellAction=0xff;       
  768.                   break;
  769.           }
  770.           NsIec104Struct.YkCellNumber=NsGetYkCell(NS_YK_CELL_NUMBER,NsIec104Struct.ReceiveYkId);
  771.           NsIec104Struct.YkKgNumber=NsGetYkCell(NS_YK_CELL_KG,NsIec104Struct.ReceiveYkId);
  772.           NsIec104Struct.YkNowState=NS_YK_ESC;
  773.           Media=NsGetYkCell(NS_YK_CELL_CPU,NsIec104Struct.ReceiveYkId); 
  774.           Dear.NsYkPort=NsIec104Struct.Card+NS_IEC_104_YK_BASE_PORT;
  775.           Dear.NsYkSlavePort=Media;
  776.           NsPutDear(&Dear,6);
  777.           NsIec104SendYkMessage(NS_YK_ESC,NsIec104Struct.YkCellAction);
  778.           NsIec104Struct.YkStartSign=ON;
  779.           getforsecond(&NsIec104Struct.YkStartTime);
  780.           /*
  781.            printf("n Send Yk EscId=%d Cell=%d Kg=%d",NsIec104Struct.ReceiveYkId,NsIec104Struct.YkCellNumber,NsIec104Struct.YkKgNumber);
  782.            */
  783.           break;
  784.    default:
  785.           break;
  786.   } 
  787. }
  790. static void NsIec104SendYkMessage(short Who,unsigned char Action)
  791. {
  793.      char Dd1Message[16];
  795.      switch(Who)
  796.      {
  797.        case  NS_YK_ESC:
  798.              Dd1Message[0]=SEND_YK_HOST_DD1;     
  799.              Dd1Message[1]=NS_YK_ESC;         
  800.              Dd1Message[2]=NsIec104Struct.YkCellNumber;
  801.              Dd1Message[3]=NsIec104Struct.YkKgNumber;
  802.              Dd1Message[4]=NsIec104Struct.YkCellAction;
  803.              NsHostSendYkMessage(SEND_YK_HOST_DD1,8,Dd1Message);
  804.              break;
  805.        case  NS_YK_EXE:
  806.              Dd1Message[0]=SEND_YK_HOST_DD1;  
  807.              Dd1Message[1]=NS_YK_EXE;      
  808.              Dd1Message[2]=NsIec104Struct.YkCellNumber;
  809.              Dd1Message[3]=NsIec104Struct.YkKgNumber;
  810.              Dd1Message[4]=NsIec104Struct.YkCellAction;
  811.              NsHostSendYkMessage(SEND_YK_HOST_DD1,8,Dd1Message);
  812.              break;
  813.        case  NS_YK_SELECT:
  814.              Dd1Message[0]=SEND_YK_HOST_DD1;  
  815.              Dd1Message[1]=NS_YK_SELECT;      
  816.              Dd1Message[2]=NsIec104Struct.YkCellNumber;
  817.              Dd1Message[3]=NsIec104Struct.YkKgNumber;
  818.              Dd1Message[4]=NsIec104Struct.YkCellAction;
  819.              NsHostSendYkMessage(SEND_YK_HOST_DD1,8,Dd1Message);
  820.              break;
  821.      }
  822. }
  824. static void NsIec104ReceiveYkReturn(void)
  825. {
  826.            char    ReturnMessage[16];
  827.            int     Length,HasMessage;
  828.   NS_RELATION      Dear;
  830.    if(NsIec104Struct.YkStartSign==ON)
  831.    {
  832.        NsGetDear(&Dear);
  833.        if(Dear.NsYkPort==(NsIec104Struct.Card+NS_IEC_104_YK_BASE_PORT))
  834.        {
  835.           /*
  836.             printf("n Yk Return");
  837.            */
  838.           if(NsHostReceiveYkMessage(SEND_YK_HOST_DD1,ReturnMessage)==1)
  839.           {
  841.                /*      
  842.                            printf("nYkMes0=%0x--1=%0x--2=%0x---3=%0x---4=%0x",
  843.                            ReturnMessage[0],ReturnMessage[1],ReturnMessage[2],ReturnMessage[3],ReturnMessage[4]);
  844.                */
  845.                      
  846.               if(ReturnMessage[0]==SEND_YK_HOST_DD1)
  847.               { 
  848.                  if(NsIec104Struct.YkNowState==ReturnMessage[1])
  849.                  {
  850.                     if((ReturnMessage[2]==NsIec104Struct.YkCellNumber)&&
  851.                        (ReturnMessage[3]==NsIec104Struct.YkKgNumber)&&
  852.                        (ReturnMessage[4]==NsIec104Struct.YkCellAction))
  853.                     {
  854.                          NsIec104Struct.YkError=ReturnMessage[5];
  855.                          if(NsIec104Struct.YkNowState==NS_YK_SELECT)
  856.                          {   
  857.                             NsIec104SendYkSelectConfirm();
  858.                             /*
  859.                                printf("n Selec Confim");
  860.                              */
  861.                          }
  862.                          else 
  863.                          {
  864.                            if(NsIec104Struct.YkNowState==NS_YK_EXE)
  865.                               NsIec104SendYkExeConfirm();
  866.                            else 
  867.                            {
  868.                               if(NsIec104Struct.YkNowState==NS_YK_ESC)
  869.                                  NsIec104SendYkEscConfirm();
  870.                            }
  871.                          }
  872.                      } 
  873.                  }
  874.               }
  875.            }
  876.         }
  877.    }
  878. }
  880. static  void       NsIec104SendYkSelectConfirm(void)
  881. {
  884. unsigned short   YkObject,Index;
  885. unsigned char    *P,i;
  886. unsigned short   RealNumber;
  890.           Index=0;
  891.           NsIec104Struct.SendBuffer[Index++]=0x68;
  892.           NsIec104Struct.SendBuffer[Index++]=0x00;
  894.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  895.           P=(unsigned char *)&RealNumber;
  896.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  897.           NsIec104Struct.SendBuffer[Index++]=P[1];
  898.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  901.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  902.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  904.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.YkYtType;          /*    asdu type   */
  905.           NsIec104Struct.SendBuffer[Index++]=1;           /*    information object count  */
  907.            /*  REASONBYTE  now is two */
  908.           NsIec104Struct.SendBuffer[Index++]=0x07;          /*    reason  */
  909.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  911.              
  912.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  913.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  915.           /* Information Object Address now three byte:  0xc01---0xc80 */
  916.           YkObject=NsIec104Struct.ReceiveYkId+0xb01;
  917.           P=(unsigned char *)&YkObject;
  918.           NsIec104Struct.SendBuffer[Index++]=P[0];
  919.           NsIec104Struct.SendBuffer[Index++]=P[1];
  920.           NsIec104Struct.SendBuffer[Index++]=0x00;
  921.               /* Value  */
  922.           if(NsIec104Struct.YkCellAction==NS_TRIP)
  923.              NsIec104Struct.SendBuffer[Index++]=0x81;
  924.           else 
  925.                if(NsIec104Struct.YkCellAction==NS_CLOSE)
  926.                   NsIec104Struct.SendBuffer[Index++]=0x82;
  927.                else 
  928.                   NsIec104Struct.YkCellAction=0xff;       
  929.          
  930.           /* Repair Length */
  931.           NsIec104Struct.SendBuffer[1]=Index-2;
  932.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  933.           {
  934.               perror ("Client FirstWrite Error");
  935.           }
  936. }
  938. static  void       NsIec104SendYkExeConfirm(void)
  939. {
  942. unsigned short   YkObject,Index;
  943. unsigned char    *P,i;
  944. unsigned short   RealNumber;
  947.           /* YkExe Confirm */
  948.           Index=0;
  949.           NsIec104Struct.SendBuffer[Index++]=0x68;
  950.           NsIec104Struct.SendBuffer[Index++]=0x00;
  952.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  953.           P=(unsigned char *)&RealNumber;
  954.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  955.           NsIec104Struct.SendBuffer[Index++]=P[1];
  956.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  959.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  960.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  962.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.YkYtType;                 /*    asdu type   */
  963.           NsIec104Struct.SendBuffer[Index++]=1;           /*    information object count  */
  965.            /*  REASONBYTE  now is two */
  966.           NsIec104Struct.SendBuffer[Index++]=0x07;          /*    reason  */
  967.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  969.              
  970.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  971.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  973.           /* Information Object Address now three byte:  0xc01---0xc80 */
  974.           YkObject=NsIec104Struct.ReceiveYkId+0xb01;
  975.           P=(unsigned char *)&YkObject;
  976.           NsIec104Struct.SendBuffer[Index++]=P[0];
  977.           NsIec104Struct.SendBuffer[Index++]=P[1];
  978.           NsIec104Struct.SendBuffer[Index++]=0x00;
  979.               /* Value  */
  980.           if(NsIec104Struct.YkCellAction==NS_TRIP)
  981.              NsIec104Struct.SendBuffer[Index++]=0x01;
  982.           else 
  983.                if(NsIec104Struct.YkCellAction==NS_CLOSE)
  984.                   NsIec104Struct.SendBuffer[Index++]=0x02;
  985.                else 
  986.                   NsIec104Struct.YkCellAction=0xff;       
  987.          
  988.           /* Repair Length */
  989.           NsIec104Struct.SendBuffer[1]=Index-2;
  990.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  991.           {
  992.               perror ("Client FirstWrite Error");
  993.           }
  994.           taskDelay(100);
  995.           /* YkExe  End */
  996.           Index=0;
  997.           NsIec104Struct.SendBuffer[Index++]=0x68;
  998.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1000.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1001.           P=(unsigned char *)&RealNumber;
  1002.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1003.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1004.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1007.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1008.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1010.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.YkYtType;                 /*    asdu type   */
  1011.           NsIec104Struct.SendBuffer[Index++]=1;           /*    information object count  */
  1013.            /*  REASONBYTE  now is two */
  1014.           NsIec104Struct.SendBuffer[Index++]=10;          /*    reason  */
  1015.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  1017.              
  1018.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1019.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1021.           /* Information Object Address now three byte:  0xc01---0xc80 */
  1022.           YkObject=NsIec104Struct.ReceiveYkId+0xb01;
  1023.           P=(unsigned char *)&YkObject;
  1024.           NsIec104Struct.SendBuffer[Index++]=P[0];
  1025.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1026.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1027.               /* Value  */
  1028.           if(NsIec104Struct.YkCellAction==NS_TRIP)
  1029.              NsIec104Struct.SendBuffer[Index++]=0x01;
  1030.           else 
  1031.                if(NsIec104Struct.YkCellAction==NS_CLOSE)
  1032.                   NsIec104Struct.SendBuffer[Index++]=0x02;
  1033.                else 
  1034.                   NsIec104Struct.YkCellAction=0xff;       
  1035.          
  1036.           /* Repair Length */
  1037.           NsIec104Struct.SendBuffer[1]=Index-2;
  1038.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1039.           {
  1040.               perror ("Client FirstWrite Error");
  1041.           }
  1042.           taskDelay(8);
  1043. }
  1045. static  void       NsIec104SendYkEscConfirm(void)
  1046. {
  1049. unsigned short   YkObject,Index;
  1050. unsigned char    *P,i;
  1051. unsigned short   RealNumber;
  1053.           Index=0;
  1054.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1055.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1057.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1058.           P=(unsigned char *)&RealNumber;
  1059.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1060.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1061.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1064.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1065.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1067.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.YkYtType;                 /*    asdu type   */
  1068.           NsIec104Struct.SendBuffer[Index++]=1;                  /*    information object count  */
  1070.            /*  REASONBYTE  now is two */
  1071.           NsIec104Struct.SendBuffer[Index++]=0x09;               /*    reason  */
  1072.           NsIec104Struct.SendBuffer[Index++]=0x00;               /*    reason  */
  1074.              
  1075.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1076.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1078.           /* Information Object Address now three byte:  0xc01---0xc80 */
  1079.           YkObject=NsIec104Struct.ReceiveYkId+0xb01;
  1080.           P=(unsigned char *)&YkObject;
  1081.           NsIec104Struct.SendBuffer[Index++]=P[0];
  1082.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1083.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1084.               /* Value  */
  1085.           if(NsIec104Struct.YkCellAction==NS_TRIP)
  1086.              NsIec104Struct.SendBuffer[Index++]=0x81;
  1087.           else 
  1088.                if(NsIec104Struct.YkCellAction==NS_CLOSE)
  1089.                   NsIec104Struct.SendBuffer[Index++]=0x82;
  1090.                else 
  1091.                   NsIec104Struct.YkCellAction=0xff;       
  1092.          
  1093.           /* Repair Length */
  1094.           NsIec104Struct.SendBuffer[1]=Index-2;
  1095.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1096.           {
  1097.               perror ("Client FirstWrite Error");
  1098.           }
  1099. }
  1103. static  void       NsIec104ProcessPulseAck(void)
  1104. {
  1105. unsigned short   i,Index,RealNumber;
  1106. unsigned char    *P;
  1108.           /*  First Send  Confirm */
  1109.           Index=0;
  1110.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1111.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1113.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1114.           P=(unsigned char *)&RealNumber;
  1115.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1116.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1117.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1121.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1122.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1125.           NsIec104Struct.SendBuffer[Index++]=101;
  1126.           NsIec104Struct.SendBuffer[Index++]=1;
  1128.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1129.                NsIec104Struct.SendBuffer[Index++]=0x07;
  1130.              
  1131.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1132.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1135.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1136.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1138.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.Qcc;
  1140.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1141.           {
  1142.                perror ("Client Write Error");
  1143.           }
  1146. }
  1148. static  void       NsIec104ProcessPulseEnd(void)
  1149. {
  1150. unsigned short   i,Index,RealNumber;
  1151. unsigned char    *P;
  1153.           /*  end confirm*/
  1154.           taskDelay(16);
  1155.           Index=0;
  1156.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1157.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1159.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1160.           P=(unsigned char *)&RealNumber;
  1161.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1162.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1163.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1166.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1167.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1169.           NsIec104Struct.SendBuffer[Index++]=101;
  1170.           NsIec104Struct.SendBuffer[Index++]=1;
  1172.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1173.                NsIec104Struct.SendBuffer[Index++]=10;
  1174.              
  1175.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1176.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1179.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1180.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1182.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.Qcc;
  1184.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0)) < 0)
  1185.           {
  1186.                perror ("Client Write Error");
  1187.           }
  1189. }
  1192. static  void       NsIec104ProcessPulse(void)
  1193. {
  1194. unsigned short   General,Index;
  1195. unsigned char    *P;
  1196. unsigned short    i,j,RealNumber;
  1200.      NsIec104Struct.Qcc=NsIec104Struct.ReceiveBuffer[NS_IEC_104_QCC_POSITION];  
  1201.      NsIec104Struct.FreezeSign=NsIec104Struct.Qcc&0xc0;
  1202.      
  1203.      NsIec104Struct.FreezeSign>>=6;
  1204.      NsIec104Struct.PulseGroup=NsIec104Struct.Qcc&0x3f;
  1206.      switch(NsIec104Struct.FreezeSign)
  1207.      {
  1208.         case 0:
  1209.                NsIec104ProcessPulseData();
  1210.                break;
  1211.         case 1:
  1212.         case 2:
  1213.         case 3:
  1214.                NsIec104ProcessPulseAck();
  1215.                break;
  1216.      }           
  1217. }
  1219. static  void       NsIec104ProcessPulseGroup(void)
  1220. {
  1221. unsigned short   General,Index;
  1222. unsigned char    *P,start;
  1223. unsigned short    i,j,RealNumber,YmLib;
  1226.      for(start=0;start<2;start++)
  1227.      {
  1228.           Index=0;
  1229.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1230.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1232.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1233.           P=(unsigned char *)&RealNumber;
  1234.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1235.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1236.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1239.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1240.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1242.           NsIec104Struct.SendBuffer[Index++]=15;                 /*    asdu type   */
  1243.           NsIec104Struct.SendBuffer[Index++]=16;           /*    information object count  */
  1245.            /*  REASONBYTE  now is two */
  1246.           NsIec104Struct.SendBuffer[Index++]=37+NsIec104Struct.PulseGroup;          /*    reason  */
  1247.           NsIec104Struct.SendBuffer[Index++]=0x0;               /*    reason  */
  1249.              
  1250.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1251.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1252.           YmLib=start*16+32*(NsIec104Struct.PulseGroup-1);
  1253.           switch(NsIec104Struct.Table)
  1254.           {
  1255.            case 0:
  1256.                  NsGetDd1Lib(NS_YM_DATA,YmLib,NsIec104Struct.DataBuff,16);
  1257.                  break;
  1258.            case 1:
  1259.                  NsGetDd2Lib(NS_YM_DATA,YmLib,NsIec104Struct.DataBuff,16);
  1260.                  break;
  1261.            case 2:
  1262.                  NsGetDd3Lib(NS_YM_DATA,YmLib,NsIec104Struct.DataBuff,16);
  1263.                  break;
  1264.            case 3:
  1265.                  NsGetDd4Lib(NS_YM_DATA,YmLib,NsIec104Struct.DataBuff,16);
  1266.                  break;
  1267.           }
  1269.           for(i=0;i<16;i++)
  1270.           {
  1271.               /* Information Object Address now three byte:  0xc01---0xc80 */
  1273.               NsIec104Struct.SendBuffer[Index++]=0x80+i+start*16+32*(NsIec104Struct.PulseGroup-1);
  1274.               NsIec104Struct.SendBuffer[Index++]=0x0c;
  1275.               NsIec104Struct.SendBuffer[Index++]=0;
  1276.               /* Value  */
  1277.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[4*i];
  1278.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[4*i+1];
  1279.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[4*i+2];
  1280.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[4*i+3];
  1281.               /* sequence number  */
  1282.               NsIec104Struct.SendBuffer[Index++]=start*16+i;
  1283.           }  
  1284.           /* Repair Length */
  1285.           NsIec104Struct.SendBuffer[1]=Index-2;
  1286.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1287.           {
  1288.                perror ("Client FirstWrite Error");
  1289.           }
  1290.      }
  1291. }
  1293. static  void       NsIec104ProcessPulseAll(void)
  1294. {
  1295. unsigned short      General,Index;
  1296. unsigned char       *P,GroupIndex,start;
  1297. unsigned short      i,j,RealNumber;
  1298. unsigned long       InformationObject;
  1301.    GroupIndex=0;
  1302.    NsIec104Struct.NeedSendNumber=0;
  1303.    NsIec104Struct.HasSendNumber=0;
  1304.    NsIec104Struct.LeftSendNumber=0;
  1306.    /*  First Send  Confirm */
  1307.    Index=0;
  1308.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  1309.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0e;
  1311.    RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1312.    P=(unsigned char *)&RealNumber;
  1313.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[0];              /*     send number       */
  1314.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[1];
  1315.    NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1317.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1318.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1320.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=101;
  1321.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=1;
  1323.    for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1324.        NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x07;
  1325.              
  1326.    for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1327.        NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  1329.    for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1330.        NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.InformationObject[i];
  1332.    NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.Qcc;
  1333.    NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  1335.    GroupIndex++;
  1336.    NsIec104Struct.NeedSendNumber++;
  1337.    
  1338.    for(start=0;start<NS_IEC_104_TOTAL_YM_TIMES;start++)           /* total 128 ym send 8 times */            
  1339.    {
  1340.           Index=0;
  1341.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  1342.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x00;
  1344.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1345.           P=(unsigned char *)&RealNumber;
  1346.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[0];              /*     send number       */
  1347.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[1];
  1348.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1350.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1351.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1353.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=15;                            /*    asdu type   */
  1354.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NS_IEC_104_ONCE_YM ;           /*    information object count  */
  1356.            /*  REASONBYTE  now is two */
  1357.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=37  ;          /*    reason  */
  1358.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0;               /*    reason  */
  1360.              
  1361.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1362.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  1364.           switch(NsIec104Struct.Table)
  1365.           {
  1366.            case 0:
  1367.                  NsGetDd1Lib(NS_YM_DATA,start*NS_IEC_104_ONCE_YM,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YM);
  1368.                  break;
  1369.            case 1:
  1370.                  NsGetDd2Lib(NS_YM_DATA,start*NS_IEC_104_ONCE_YM,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YM);
  1371.                  break;
  1372.            case 2:
  1373.                  NsGetDd3Lib(NS_YM_DATA,start*NS_IEC_104_ONCE_YM,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YM);
  1374.                  break;
  1375.            case 3:
  1376.                  NsGetDd4Lib(NS_YM_DATA,start*NS_IEC_104_ONCE_YM,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YM);
  1377.                  break;
  1378.           }
  1379.           for(i=0;i<NS_IEC_104_ONCE_YM;i++)
  1380.           {
  1381.               /* Information Object Address now three byte:  0xc01---0xc80 */
  1382.               InformationObject=0xc01+i+start*NS_IEC_104_ONCE_YM;
  1383.               P=(unsigned char *)&InformationObject;
  1384.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[0];
  1385.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[1];
  1386.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[2];
  1387.               /* Value  */
  1388.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[4*i];
  1389.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[4*i+1];
  1390.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[4*i+2];
  1391.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[4*i+3];
  1392.               /* sequence number  */
  1393.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=i;
  1394.           }  
  1395.           /* Repair Length */
  1396.           NsIec104Struct.GroupSendBuffer[GroupIndex][1]=Index-2;
  1397.           NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  1398.           /*
  1399.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[GroupIndex][0],NsIec104Struct.GroupSendLength,0x0))<0)
  1400.           {
  1401.                perror ("Client FirstWrite Error");
  1402.           }
  1403.            */
  1404.           GroupIndex++;
  1405.           NsIec104Struct.NeedSendNumber++;
  1407.     }
  1408.     /* Send Pulse End Packet */
  1409.     Index=0;
  1410.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  1411.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0e;
  1413.     RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1414.     P=(unsigned char *)&RealNumber;
  1415.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[0];              /*     send number       */
  1416.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=P[1];
  1417.     NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1420.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1421.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1423.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=101;
  1424.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=1;
  1426.     for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1427.         NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=10;
  1428.              
  1429.     for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1430.         NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  1433.     for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1434.         NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.InformationObject[i];
  1436.     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.Qcc;
  1437.     NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  1438.     /*
  1439.     if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[GroupIndex][0],NsIec104Struct.GroupSendLength,0x0)) < 0)
  1440.     {
  1441.                perror ("Client Write Error");
  1442.     }
  1443.     */
  1444. /* mask 2003-01-24
  1445.     GroupIndex++;
  1446.     NsIec104Struct.NeedSendNumber++;
  1447. */
  1448. }
  1450. static  void       NsIec104ProcessPulseData(void)
  1451. {
  1454.      switch(NsIec104Struct.PulseGroup)
  1455.      {
  1456.         case 1:
  1457.         case 2:
  1458.         case 3:
  1459.         case 4:
  1460.                NsIec104ProcessPulseAck();
  1461.                NsIec104ProcessPulseGroup();
  1462.                NsIec104ProcessPulseEnd();
  1463.                break;
  1464.         case 5:
  1465.                NsIec104ProcessPulseAll();
  1466.                break;
  1467.      }
  1468. }
  1470. static  void     NsIec104ProcessTime(void)
  1471. {
  1473. unsigned short   i,Index,RealNumber,Mmsecond;
  1474. unsigned char    *P,Year,Month,Day,Hour,Minute,Second;
  1475. struct tm        NowTime;
  1477.           /*  First Send  Confirm */
  1478.           for(i=0;i<7;i++)
  1479.           {
  1480.                NsIec104Struct.TimeSave[i]=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+i];
  1481.           /*     
  1482.                    printf("n Time=%d",NsIec104Struct.TimeSave[i]);
  1483.             */   
  1484.           }
  1485.           Mmsecond=(NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION]
  1486.                     +256*NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+1])%1000; 
  1488.           Second=(NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION]
  1489.                     +256*NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+1])/1000; 
  1490.           Minute=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+2]&0x3f;
  1491.           Hour=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+3]&0x1f;
  1492.           Day=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+4]&0x1f;
  1493.           Month=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+5]&0x0f;
  1494.           Year=NsIec104Struct.ReceiveBuffer[NS_IEC_104_TIME_POSITION+6]&0x7f;
  1495. /*
  1496.           if(NsIec104Struct.SetTimeFlag)
  1497.           {
  1498.               NowTime.tm_sec   = Second;
  1499.               NowTime.tm_min   = Minute;
  1500.               NowTime.tm_hour  = Hour;
  1501.               NowTime.tm_mday  = Day;
  1502.               NowTime.tm_mon   = Month; 
  1503.               NowTime.tm_year  = Year + 2000; 
  1504.               setvxTime(&NowTime);
  1505.           }
  1506. */
  1507.           /*
  1508.               printf("n Year=%d Month=%d Day=%d Hour=%d Min=%d Sec=%d Msec=%d",
  1509.                          Year,Month,Day,Hour,Minute,Second,Mmsecond);
  1510.            */
  1511.           Index=0;
  1512.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1513.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1515.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1516.           P=(unsigned char *)&RealNumber;
  1517.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1518.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1519.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1523.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1524.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1527.           NsIec104Struct.SendBuffer[Index++]=103;
  1528.           NsIec104Struct.SendBuffer[Index++]=1;
  1530.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1531.                NsIec104Struct.SendBuffer[Index++]=0x07;
  1532.              
  1533.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1534.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1537.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1538.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1540.           for(i=0;i<7;i++)
  1541.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.TimeSave[i];
  1543.           NsIec104Struct.SendBuffer[1]=Index-2;
  1544.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1545.           {
  1546.                perror ("Client Write Error");
  1547.           }
  1548. }
  1555. static void     NsIec104Interrogation(void)
  1556. {
  1559.      switch(NsIec104Struct.AsduQualifier)
  1560.      {
  1561.          case 20:   /*  All Interrogation */
  1562.                   NsIec104InterrogationAll();
  1563.                   break;
  1564.         
  1565.          default:
  1566.                   NsIec104InterrogationGroup();
  1567.                   break;
  1568.      }
  1570. }
  1572. static void     NsIec104InterrogationGroup(void)
  1573. {
  1574.  unsigned  char  WhichGroup;
  1577.   if(NsIec104Struct.AsduQualifier>=NS_IEC104_GROUP_BEGIN&&NsIec104Struct.AsduQualifier<=NS_IEC104_GROUP_END)
  1578.   {
  1579.      WhichGroup=NsIec104Struct.ReceiveBuffer[NS_IEC_104_GROUP_BYTE];
  1580.      WhichGroup-=21;
  1581.      switch(WhichGroup)
  1582.      {
  1584.          case 0:
  1585.          case 1:
  1586.          case 2:
  1587.          case 3:
  1588.          case 4:
  1589.          case 5:
  1590.          case 6:
  1591.          case 7:
  1592.                  NsIec104ProcessYxGroup(WhichGroup);
  1593.                  break;
  1594.          case 8:
  1595.          case 9:
  1596.          case 10:
  1597.          case 11:
  1598.                  NsIec104ProcessYcGroup(WhichGroup);
  1599.                  break;
  1600.          case 12:             /*  location information  */
  1601.                  NsIec104DefaultGroup(WhichGroup);
  1602.                  break;
  1603.          case 13:             /*  BCD Information  */
  1604.                  NsIec104DefaultGroup(WhichGroup);
  1605.                  break;
  1606.          case 14:             /*  cell state */
  1607.                  NsIec104DefaultGroup(WhichGroup);
  1608.                  break;
  1609.          case 15:             /*  backup use */
  1610.                  NsIec104DefaultGroup(WhichGroup);
  1611.                  break;
  1612.          default:
  1613.                  NsIec104DefaultGroup(WhichGroup);
  1614.                  break;
  1615.      }
  1617.   }
  1619. }
  1621. static void    NsIec104DefaultGroup(unsigned char Group)
  1622. {
  1623. unsigned short   General,Index;
  1624. unsigned char    *P;
  1625. unsigned short    i,j,RealNumber;
  1628.           /*  First Send  Confirm */
  1629.           Index=0;
  1630.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1631.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1633.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1634.           P=(unsigned char *)&RealNumber;
  1635.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1636.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1637.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1641.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1642.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1645.           NsIec104Struct.SendBuffer[Index++]=100;
  1646.           NsIec104Struct.SendBuffer[Index++]=1;
  1648.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1649.                NsIec104Struct.SendBuffer[Index++]=0x07;
  1650.              
  1651.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1652.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1655.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1656.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1658.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1660.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1661.           {
  1662.                perror ("Client Write Error");
  1663.           }
  1665.           taskDelay(6);
  1666.           Index=0;
  1667.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1668.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1670.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1671.           P=(unsigned char *)&RealNumber;
  1672.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1673.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1674.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1677.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1678.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1680.           NsIec104Struct.SendBuffer[Index++]=100;
  1681.           NsIec104Struct.SendBuffer[Index++]=1;
  1683.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1684.                NsIec104Struct.SendBuffer[Index++]=10;
  1685.              
  1686.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1687.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1690.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1691.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1693.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1695.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0)) < 0)
  1696.           {
  1697.                perror ("Client Write Error");
  1698.           }
  1699. }
  1703. static void    NsIec104ProcessYxGroup(unsigned char Group)
  1704. {
  1705. unsigned short     General,Index,YxLibIndex;
  1706. unsigned char      *P,start,YxBit,YxByte;
  1707. unsigned short     i,j,g,RealNumber;
  1710.           /*  Once Gonce need send 64 Yx  8 bytes   Group from 0 begin*/
  1711.           /*  First Send  Confirm */
  1712.           Index=0;
  1713.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1714.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1716.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1717.           P=(unsigned char *)&RealNumber;
  1718.           NsIec104Struct.SendBuffer[Index++]=P[0];                                    /*     send number       */
  1719.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1720.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1724.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];     /*     receive number    */
  1725.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1728.           NsIec104Struct.SendBuffer[Index++]=100;                                    /*      transmit  type    */
  1729.           NsIec104Struct.SendBuffer[Index++]=1;                                      /*      vsq               */ 
  1731.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)                                      /*      reason            */
  1732.                NsIec104Struct.SendBuffer[Index++]=0x07;
  1733.              
  1734.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1735.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1738.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1739.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1741.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1742.           /* 
  1743.              printf("n YxGroup=%d",Group);
  1744.            */
  1746.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1747.           {
  1748.           perror ("Client Write Error");
  1749.           }
  1750.           for(start=0;start<2;start++)
  1751.           {
  1752.             taskDelay(60);          
  1753.             Index=0;
  1754.             NsIec104Struct.SendBuffer[Index++]=0x68;
  1755.             NsIec104Struct.SendBuffer[Index++]=0x00;
  1757.             RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1758.             P=(unsigned char *)&RealNumber;
  1759.             NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1760.             NsIec104Struct.SendBuffer[Index++]=P[1];
  1761.             NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1764.             NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1765.             NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1767.             NsIec104Struct.SendBuffer[Index++]=1;                 /*    asdu type   */
  1768.             NsIec104Struct.SendBuffer[Index++]=64|0x80;           /*    information object d",count  */
  1770.             /*  REASONBYTE  now is two */
  1771.             NsIec104Struct.SendBuffer[Index++]=21+Group;          /*    reason  */
  1772.             NsIec104Struct.SendBuffer[Index++]=0x00;              /*    reason  */
  1774.              
  1775.             for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1776.                NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1778.             /* Information Object Address now three byte*/
  1780.             General=0x01+start*0x40+Group*0x80;
  1781.             P=(unsigned char    *)&General;
  1782.             NsIec104Struct.SendBuffer[Index++]=P[0];
  1783.             NsIec104Struct.SendBuffer[Index++]=P[1];
  1784.             NsIec104Struct.SendBuffer[Index++]=0;
  1785.             YxLibIndex=start*8+Group*16;
  1787.             switch(NsIec104Struct.Table)
  1788.             {
  1789.               case 0:
  1790.                    NsGetDd1Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,8);
  1791.                    break;
  1792.               case 1:
  1793.                    NsGetDd2Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,8);
  1794.                    break;
  1795.               case 2:
  1796.                    NsGetDd3Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,8);
  1797.                    break;
  1798.               case 3:
  1799.                    NsGetDd4Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,8);
  1800.                    break;
  1801.             }
  1802.             for(i=0;i<8;i++)  /* totla 64 yx*/
  1803.             {
  1804.              
  1805.                   YxByte=NsIec104Struct.DataBuff[i]; 
  1806.                   for(g=0;g<8;g++)
  1807.                   {
  1808.                       YxBit=(YxByte>>g)&0x01;
  1809.                       NsIec104Struct.SendBuffer[Index++]=YxBit;
  1810.                   }
  1811.             }
  1812.             /* Repair Length */
  1813.             NsIec104Struct.SendBuffer[1]=Index-2;
  1814.             if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1815.             {
  1816.                perror ("Client FirstWrite Error");
  1817.             }
  1818.          }
  1820.          taskDelay(6);
  1821.          Index=0;
  1822.          NsIec104Struct.SendBuffer[Index++]=0x68;
  1823.          NsIec104Struct.SendBuffer[Index++]=0x0e;
  1825.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1826.           P=(unsigned char *)&RealNumber;
  1827.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1828.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1829.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1832.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1833.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1835.           NsIec104Struct.SendBuffer[Index++]=100;
  1836.           NsIec104Struct.SendBuffer[Index++]=1;
  1838.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1839.                NsIec104Struct.SendBuffer[Index++]=10;
  1840.              
  1841.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1842.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1845.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1846.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1848.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1850.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0)) < 0)
  1851.           {
  1852.                perror ("Client Write Error");
  1853.           }
  1855. }
  1857. static void    NsIec104ProcessYcGroup(unsigned char Group)
  1858. {
  1859. unsigned short   General,Index;
  1860. unsigned char    *P;
  1861. unsigned short   i,RealNumber,YcLibIndex;
  1865.           /*  Once Gonce need send 60 Yc  Group Number is 8 9 10 11 begin from 8 */
  1866.           /*  First Send  Confirm */
  1867.           Index=0;
  1868.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1869.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1871.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1872.           P=(unsigned char *)&RealNumber;
  1873.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1874.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1875.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1879.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1880.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1883.           NsIec104Struct.SendBuffer[Index++]=100;
  1884.           NsIec104Struct.SendBuffer[Index++]=1;
  1886.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1887.                NsIec104Struct.SendBuffer[Index++]=0x07;
  1888.              
  1889.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1890.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1893.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1894.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1896.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1898.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1899.           {
  1900.                perror ("Client Write Error");
  1901.           }
  1903.           taskDelay(60);          
  1904.           Index=0;
  1905.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1906.           NsIec104Struct.SendBuffer[Index++]=0x00;
  1908.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1909.           P=(unsigned char *)&RealNumber;
  1910.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1911.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1912.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1915.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1916.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1918.           NsIec104Struct.SendBuffer[Index++]=9;                 /*    asdu type   */
  1919.           NsIec104Struct.SendBuffer[Index++]=64|0x80;           /*    information object count  */
  1921.            /*  REASONBYTE  now is two */
  1922.           NsIec104Struct.SendBuffer[Index++]=21+Group;          /*    reason  */
  1923.           NsIec104Struct.SendBuffer[Index++]=0x0;               /*    reason  */
  1925.              
  1926.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1927.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1929.           /* Information Object Address now three byte*/
  1930.           General=0x701+Group*0x80;
  1931.           P=(unsigned char    *)&General;
  1932.           NsIec104Struct.SendBuffer[Index++]=P[0];
  1933.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1934.           NsIec104Struct.SendBuffer[Index++]=0;
  1936.           YcLibIndex=0;
  1937.           switch(NsIec104Struct.Table)
  1938.           {
  1939.                  case 0:
  1940.                       NsGetDd1Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,64);
  1941.                       break;
  1942.                  case 1:
  1943.                       NsGetDd2Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,64);
  1944.                       break;
  1945.                  case 2:
  1946.                       NsGetDd3Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,64);
  1947.                       break;
  1948.                  case 3:
  1949.                       NsGetDd4Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,64);
  1950.                       break;
  1951.           }
  1953.           for(i=0;i<64;i++)
  1954.           {
  1955.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[2*i];
  1956.               NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.DataBuff[2*i+1];
  1957.               NsIec104Struct.SendBuffer[Index++]=0x00;  /*qds*/
  1959.           }
  1960.           /* Repair Length */
  1961.           NsIec104Struct.SendBuffer[1]=Index-2;
  1962.           if((NsIec104Struct.SendLength=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0))<0)
  1963.           {
  1964.                perror ("Client FirstWrite Error");
  1965.           }
  1966.           /*
  1967.             printf("nYcGroupFirst=%d",Group);
  1968.            */
  1969.           taskDelay(6);
  1970.           Index=0;
  1971.           NsIec104Struct.SendBuffer[Index++]=0x68;
  1972.           NsIec104Struct.SendBuffer[Index++]=0x0e;
  1974.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  1975.           P=(unsigned char *)&RealNumber;
  1976.           NsIec104Struct.SendBuffer[Index++]=P[0];              /*     send number       */
  1977.           NsIec104Struct.SendBuffer[Index++]=P[1];
  1978.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  1981.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  1982.           NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.ReceiveHimNumber[1];
  1984.           NsIec104Struct.SendBuffer[Index++]=100;
  1985.           NsIec104Struct.SendBuffer[Index++]=1;
  1987.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  1988.                NsIec104Struct.SendBuffer[Index++]=10;
  1989.              
  1990.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  1991.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.CommonAsduAddress[i];
  1994.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  1995.              NsIec104Struct.SendBuffer[Index++]=NsIec104Struct.InformationObject[i];
  1997.           NsIec104Struct.SendBuffer[Index++]=21+Group;
  1999.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],Index,0x0)) < 0)
  2000.           {
  2001.                perror ("Client Write Error");
  2002.           }
  2003.           /*
  2004.             printf("nEndwrite=%d",NsIec104Struct.SendLength);
  2005.            */
  2006. }
  2009. static void    NsIec104ProcessCellGroup(unsigned char Group)
  2010. {
  2014. }
  2018. static void     NsIec104InterrogationAll(void)
  2019. {
  2020. unsigned short    i,Index,start,g;
  2021.          long     ShiftValue;
  2022. unsigned char     *PGive,j,GroupIndex,YxByte,YxBit,*pYc;
  2023. unsigned short    RealNumber,YxLibIndex,YcLibIndex;
  2024. unsigned long     InformationObject;
  2025. unsigned short   sYc;
  2026. float   fYc;
  2029.           /*  First Send  Confirm */
  2030.           GroupIndex=0;
  2031.           NsIec104Struct.NeedSendNumber=0;
  2032.           NsIec104Struct.HasSendNumber=0;
  2033.           NsIec104Struct.LeftSendNumber=0;
  2036.           Index=0;
  2037.           NsIec104Struct.GroupSendBuffer[0][Index++]=0x68;
  2038.           NsIec104Struct.GroupSendBuffer[0][Index++]=0x0e;
  2040.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  2041.           PGive=(unsigned char *)&RealNumber;
  2042.           NsIec104Struct.GroupSendBuffer[0][Index++]=PGive[0];              /*     send number       */
  2043.           NsIec104Struct.GroupSendBuffer[0][Index++]=PGive[1];
  2044.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  2048.           NsIec104Struct.GroupSendBuffer[0][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  2049.           NsIec104Struct.GroupSendBuffer[0][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  2052.           NsIec104Struct.GroupSendBuffer[0][Index++]=100;
  2053.           NsIec104Struct.GroupSendBuffer[0][Index++]=1;
  2055.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  2056.                NsIec104Struct.GroupSendBuffer[0][Index++]=0x07;
  2057.              
  2058.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  2059.              NsIec104Struct.GroupSendBuffer[0][Index++]=NsIec104Struct.CommonAsduAddress[i];
  2062.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  2063.              NsIec104Struct.GroupSendBuffer[0][Index++]=NsIec104Struct.InformationObject[i];
  2065.           NsIec104Struct.GroupSendBuffer[0][Index++]=20;
  2066.           NsIec104Struct.GroupSendLength[0]=Index;
  2067. /*
  2068.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[0][0],NsIec104Struct.GroupSendLength[0],0x0))<0)
  2069.           {
  2070.                perror ("Client Write Error");
  2071.           }
  2072. */
  2074.           /*  Second Send  Yx   total send 1024 yx  */
  2075.           GroupIndex++;
  2076.           NsIec104Struct.NeedSendNumber++;
  2078.           for(start=0;start<NS_IEC_104_TOTAL_YX_TIMES;start++)
  2079.           {
  2080.               Index=0;
  2081.     
  2082.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  2083.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0e;
  2085.               RealNumber=(NsIec104Struct.SendMeNumber<<1);
  2086.               PGive=(unsigned char *)&RealNumber;
  2087.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[0];              /*     send number       */
  2088.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[1];
  2089.               NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  2092.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  2093.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  2095.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=1;      /*    asdu type   */
  2096.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NS_IEC_104_ONCE_YX|0x80;     /*    information object count  */
  2098.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=20;    /*  reason  */
  2099.               NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0;    /*  reason  */
  2101.              
  2102.               for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  2103.                   NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  2105.               InformationObject=0x01+start*NS_IEC_104_ONCE_YX;
  2106.               PGive=(unsigned char *)&InformationObject;
  2107.               for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  2108.               {
  2109.                   NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[i];
  2110.               }
  2112.               YxLibIndex=start*NS_IEC_104_ONCE_YX_BYTES;
  2113.               switch(NsIec104Struct.Table)
  2114.               {
  2115.                 case 0:
  2116.                        NsGetDd1Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YX_BYTES);
  2117.                        break;
  2118.                 case 1:
  2119.                        NsGetDd2Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YX_BYTES);
  2120.                        break;
  2121.                 case 2:
  2122.                        NsGetDd3Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YX_BYTES);
  2123.                        break;
  2124.                 case 3:
  2125.                        NsGetDd4Lib(NS_YX_DATA,YxLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YX_BYTES);
  2126.                        break;
  2127.               }
  2128.               for(j=0;j<NS_IEC_104_ONCE_YX_BYTES;j++)
  2129.               {
  2130.                
  2131.                   YxByte=NsIec104Struct.DataBuff[j]; 
  2132.                   for(g=0;g<8;g++)
  2133.                   {
  2134.                       YxBit=(YxByte>>g)&0x01;
  2135.                       NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=YxBit;
  2136.                   }
  2137.               }
  2139.                                /*
  2140.                                   Debug Yx Message 
  2141.                                   for(j=0;j<NS_IEC_104_ONCE_YX;j++)
  2142.                                   {
  2143.                                     NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x30;
  2144.                                   }
  2145.                                */
  2146.            
  2148.               /* Repair Length */
  2149.               NsIec104Struct.GroupSendBuffer[GroupIndex][1]=Index-2;
  2150.               NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  2151. /*
  2152.               if((NsIec104Struct.GroupSendLength[GroupIndex] = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[GroupIndex][0],NsIec104Struct.GroupSendLength[GroupIndex],0x0)) < 0)
  2153.               {
  2154.                perror ("Client Write Error");
  2155.               }
  2156. */
  2157.               NsIec104Struct.NeedSendNumber++;
  2158.               GroupIndex++;
  2159.           }
  2160.           
  2161.           /*  Third  Send  Yc    */
  2162.           for(start=0;start<NS_IEC_104_TOTAL_YC_TIMES;start++)
  2163.           {
  2165.              Index=0;
  2166.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  2167.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x00;
  2169.              RealNumber=(NsIec104Struct.SendMeNumber<<1);
  2170.              PGive=(unsigned char *)&RealNumber;
  2171.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[0];              /*     send number       */
  2172.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[1];
  2173.              NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  2176.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  2177.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  2179.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=9;                     /* 11->21   sigle yc asdu type   */
  2180.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NS_IEC_104_ONCE_YC|0x80;               /*    information object count  */
  2182.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=20;                    /*    reason  */
  2183.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0;                   /*    reason  */
  2185.              
  2186.              for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  2187.                  NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  2189.               InformationObject=0x701+start*NS_IEC_104_ONCE_YC;
  2190.               PGive=(unsigned char *)&InformationObject;
  2191.               for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  2192.               {
  2193.                   NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[i];
  2194.               }
  2197.               YcLibIndex=start*NS_IEC_104_ONCE_YC;
  2198.               switch(NsIec104Struct.Table)
  2199.               {
  2200.                  case 0:
  2201.                       NsGetDd1Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YC);
  2202.                       break;
  2203.                  case 1:
  2204.                       NsGetDd2Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YC);
  2205.                       break;
  2206.                  case 2:
  2207.                       NsGetDd3Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YC);
  2208.                       break;
  2209.                  case 3:
  2210.                       NsGetDd4Lib(NS_YC_DATA,YcLibIndex,NsIec104Struct.DataBuff,NS_IEC_104_ONCE_YC);
  2211.                       break;
  2212.               }
  2214.               for(j=0;j<NS_IEC_104_ONCE_YC;j++)
  2215.               {
  2216.                  
  2217. /*sYc = *((unsigned short *)&NsIec104Struct.DataBuff[j*2]);
  2218. fYc = sYc * 1.0;
  2219. pYc = (unsigned char *)&fYc;
  2220. NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=pYc[0];
  2221.                  NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=pYc[1];
  2222. NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=pYc[2];
  2223. NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=pYc[3];*/
  2224. NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[2*j];
  2225. NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.DataBuff[2*j + 1];
  2226.                  NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0;                 /*  qds    */
  2227.               }
  2228.               /*
  2229.                   printf("n Yc Send ");
  2230.               */
  2232.               /* Repair Length */
  2233.               NsIec104Struct.GroupSendBuffer[GroupIndex][1]=Index-2;
  2234.               NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  2235. /*
  2236.               if((NsIec104Struct.GroupSendLength[GroupIndex]=send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[GroupIndex][0],NsIec104Struct.GroupSendLength[GroupIndex],0x0))<0)
  2237.               {
  2238.                perror ("Client Write Error");
  2239.               }
  2240. */
  2241.               NsIec104Struct.NeedSendNumber++;
  2242.               GroupIndex++;
  2243.           }
  2246.           /*  Fiveth Send  Over  */
  2247.           Index=0;
  2248.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x68;
  2249.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=0x0e;
  2251.           RealNumber=(NsIec104Struct.SendMeNumber<<1);
  2252.           PGive=(unsigned char *)&RealNumber;
  2253.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[0];              /*     send number       */
  2254.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=PGive[1];
  2255.           NsIec104Struct.SendMeNumber=(NsIec104Struct.SendMeNumber+1)%65535;
  2258.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[0];              /*     receive number    */
  2259.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.ReceiveHimNumber[1];
  2261.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=100;
  2262.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=1;
  2264.           for(i=0;i< NS_IEC_104_REASONBYTE;i++)
  2265.                NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=10;
  2266.              
  2267.           for(i=0;i<NS_IEC_104_ASDUADDRESSBYTE;i++)
  2268.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.CommonAsduAddress[i];
  2271.           for(i=0;i<NS_IEC_104_INFORMATIONBYTE;i++)
  2272.              NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=NsIec104Struct.InformationObject[i];
  2274.           NsIec104Struct.GroupSendBuffer[GroupIndex][Index++]=20;
  2275.           NsIec104Struct.GroupSendLength[GroupIndex]=Index;
  2276. /*
  2277.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.GroupSendBuffer[GroupIndex][0],NsIec104Struct.GroupSendLength[GroupIndex],0x0)) < 0)
  2278.           {
  2279.                perror ("Client Write Error");
  2280.           }
  2281. */
  2284.           NsIec104Struct.NeedSendNumber++;
  2285.           GroupIndex++;
  2288. }
  2291. static  void  NsIec104ProcessFormatS(void)
  2292. {
  2293. int Index;
  2294. /*
  2295.        printf("nFormatS");
  2297.        Index=0;
  2298.        NsIec104Struct.SendBuffer[0]=0x68;
  2299.        NsIec104Struct.SendBuffer[1]=0x04;
  2300.        NsIec104Struct.SendBuffer[2]=0x0b;
  2301.        NsIec104Struct.SendBuffer[3]=0x00;
  2302.        NsIec104Struct.SendBuffer[4]=0x00;
  2303.        NsIec104Struct.SendBuffer[5]=0x00;
  2305.        NsIec104Struct.ReceiveHimNumber[0]=NsIec104Struct.ReceiveBuffer[2];
  2306.        NsIec104Struct.ReceiveHimNumber[1]=NsIec104Struct.ReceiveBuffer[3];
  2308.       if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],6,0x0)) < 0)
  2309.       {
  2310.                perror ("Client Write Error");
  2311.       }
  2312.       printf("nwrite=%d",NsIec104Struct.SendLength);
  2313.   */
  2314. }
  2317. static  void  NsIec104ProcessFormatU(void)
  2318. {
  2319. int Index;
  2320. int i;
  2323.        NsIec104Struct.UCommand=NsIec104Struct.ReceiveBuffer[2];
  2324.        Index=0;
  2325.        if(NsIec104Struct.UCommand&NS_IEC_104_STARTDT)
  2326.        {
  2327.           Index=6;
  2328.           NsIec104Struct.SendBuffer[0]=0x68;
  2329.           NsIec104Struct.SendBuffer[1]=0x04;
  2330.           NsIec104Struct.SendBuffer[2]=0x0b;
  2331.           NsIec104Struct.SendBuffer[3]=0x00;
  2332.           NsIec104Struct.SendBuffer[4]=0x00;
  2333.           NsIec104Struct.SendBuffer[5]=0x00;
  2334.           /*
  2335.           printf("nFormatU STARTDT");
  2336.           */
  2338.           NsIec104Struct.SendMeNumber=0x00;
  2339.           NsIec104Struct.ReceiveHimNumber[0]=0x00;              
  2340.           NsIec104Struct.ReceiveHimNumber[1]=0x00;
  2341.           /*NsIec104Struct.NeedSendNumber=0;
  2342.           NsIec104Struct.HasSendNumber=0;
  2343.           NsIec104Struct.LeftSendNumber=0;*/
  2345.        }
  2346.        else 
  2347.        {
  2348.           if(NsIec104Struct.UCommand&NS_IEC_104_STOPDT)
  2349.           {
  2350.                Index=6;
  2351.                NsIec104Struct.SendBuffer[0]=0x68;
  2352.                NsIec104Struct.SendBuffer[1]=0x04;
  2353.                NsIec104Struct.SendBuffer[2]=0x23;
  2354.                NsIec104Struct.SendBuffer[3]=0x00;
  2355.                NsIec104Struct.SendBuffer[4]=0x00;
  2356.                NsIec104Struct.SendBuffer[5]=0x00;
  2358.                NsIec104Struct.SendMeNumber=0x00;
  2359.                NsIec104Struct.ReceiveHimNumber[0]=0x00;              
  2360.                NsIec104Struct.ReceiveHimNumber[1]=0x00;
  2361.                NsIec104Struct.NeedSendNumber=0;
  2362.                NsIec104Struct.HasSendNumber=0;
  2363.                NsIec104Struct.LeftSendNumber=0;
  2366.           }
  2367.           else 
  2368.           {
  2369.                  if(NsIec104Struct.UCommand&NS_IEC_104_TESTFR)
  2370.                  {
  2371.                     Index=6;
  2372.                     NsIec104Struct.SendBuffer[0]=0x68;
  2373.                     NsIec104Struct.SendBuffer[1]=0x04;
  2374.                     NsIec104Struct.SendBuffer[2]=0x83;
  2375.                     NsIec104Struct.SendBuffer[3]=0x00;
  2376.                     NsIec104Struct.SendBuffer[4]=0x00;
  2377.                     NsIec104Struct.SendBuffer[5]=0x00;
  2378.                  }
  2379.           }
  2381.        }
  2382.        if(Index>0)
  2383.        {
  2384.           if((NsIec104Struct.SendLength = send(NsIec104Struct.NsNewSocketId,&NsIec104Struct.SendBuffer[0],6,0x0)) < 0)
  2385.           {
  2386.                perror ("Client Write Error");
  2387.           }
  2388.           /*
  2389.           printf("ns:");
  2390.           for (i = 0; i < 6; i++)
  2391.            printf("%4x",NsIec104Struct.SendBuffer[i]);
  2392.           printf("n");
  2393.           */
  2394.        }
  2395. }
  2399. static  void  NsIec104Reset(void)
  2400. {
  2402. NsIec104Struct.ReceiveLength=0;
  2403. NsIec104Struct.ReceiveIndexLength=0;
  2404. NsIec104Struct.ReceiveIndex=0;
  2405. NsIec104Struct.HasSendNumber=0;
  2407. }
  2412. static  void       NsIec104CycleCount(void)
  2413. {
  2414. unsigned short i;
  2415. unsigned long  Nap,NowSecond;
  2419.   getforsecond(&NowSecond);
  2420.   for(i=0;i<NS_IEC104_USE_CYCLE;i++) 
  2421.   {
  2422. Nap = DiffMsLong(NowSecond,NsIec104Cycle[i].LastTime);
  2423. if(Nap >= NsIec104Cycle[i].TimeNap) 
  2424.         {
  2425. NsIec104Cycle[i].TimeSign= ON;
  2426. getforsecond(&NsIec104Cycle[i].LastTime);
  2427. }
  2428.   }
  2429. }
  2430. /*
  2431. void debug104(void)
  2432. {
  2433. unsigned char Buff[256];
  2434. short i;
  2436.    for(i=0;i<200;i++)
  2437.       Buff[i]=0;
  2439.    for(i=0;i<96;i+=2)
  2440.      Buff[i]=i+100;
  2442.    NsPutDd1Lib(NS_YC_DATA,0,0,&Buff[0],48);
  2444.       for(i=0;i<12;i++)
  2445.          Buff[i]=0x0f;    
  2446.       NsPutDd1Lib(NS_YX_DATA,0,0,&Buff[0],12);
  2447. }
  2449. static void Iec104testCosSoe(void) {
  2450. struct tm NowTime;
  2451. static i = 0;
  2452. static unsigned char st = 0;
  2453. NS_COS_FORMAT CosValue;
  2454. NS_SOE_FORMAT SoeValue;
  2456. getvxTime(&NowTime);
  2457. for(i=0;i<10;i++){
  2458. SoeValue.SendNumber = i;
  2459. SoeValue.KgNumber = i;
  2460. SoeValue.CellNumber = 0;
  2461. SoeValue.RealAddress = 1;
  2462. SoeValue.Type = 2;
  2463. SoeValue.State = st;
  2465. SoeValue.Year = 2003;
  2466. SoeValue.Month = 7;
  2467. SoeValue.Day = 22;
  2468. SoeValue.Hour = 15;
  2470. SoeValue.Minute = 00;
  2471. SoeValue.Second = i;
  2472. SoeValue.Msecond = 888;
  2474. NsPutNetSoeLib(&SoeValue);
  2475. NsPutDd1SoeLib(&SoeValue);
  2476. NsPutDd2SoeLib(&SoeValue);
  2477. NsPutDd3SoeLib(&SoeValue);
  2478. NsPutAllSoeLib(&SoeValue);
  2480. CosValue.SendNumber =i;
  2481. CosValue.KgNumber = i;
  2482. CosValue.CellNumber = 0;
  2483. CosValue.RealAddress = 1;
  2484. CosValue.Type = 2;
  2485. CosValue.State = st;
  2487. NsPutNetCosLib(&CosValue);
  2488. NsPutDd1CosLib(&CosValue);
  2489. NsPutDd2CosLib(&CosValue);
  2490. NsPutDd3CosLib(&CosValue);
  2491. NsPutAllCosLib(&CosValue);
  2493. }
  2494. if (st == 0) st = 1;
  2495. else  st = 0;
  2496. }
  2497. */