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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > Internet/IE编程 > 查看源码
PrtModbus.cpp
资源名称：IEC101-104RTU.rar　[点击查看]
上传用户：asikq0571
上传日期：2014-07-12
资源大小：528k
文件大小：15k
源码类别：

Internet/IE编程

开发平台：

Visual C++

PrtModbus.cpp：源码内容
  1. // PrtModbus.cpp: implementation of the CPrtModbus class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "Peugeot.h"
  7. #include "PrtModbus.h"
  9. #include "MainFrm.h"
  10. #include "PeugeotDoc.h"
  11. #include "PeugeotView.h"
  13. #ifdef _DEBUG
  14. #undef THIS_FILE
  15. static char THIS_FILE[]=__FILE__;
  16. #define new DEBUG_NEW
  17. #endif
  19. //////////////////////////////////////////////////////////////////////
  20. // Construction/Destruction
  21. //////////////////////////////////////////////////////////////////////
  23. CPrtModbus::CPrtModbus()
  24. {
  25. //初始化成员变量
  26.  m_Addr     = 1;
  27.  m_YXFunc   = 2;
  28.  m_YCFunc   = 3;
  29.  m_YCSize   = 2;
  30.  m_CallIntv = 1000;
  32.  m_CallTimerID  = 0;
  33.      m_CallYXFlag   = true;
  34.      m_bIsTimerStar = false;
  35.  
  36.  int i;
  37.  for (i=0;i<8;i++)
  38.  {
  39.    m_CallYXByte[i]    = 0x00;    //召遥信报文
  40.        m_CallYCByte[i]    = 0x00;    //召遥测报文
  41.        m_SRecByte[i]  = 0x00;    
  42.  }
  44.  for (i=0;i<260;i++)
  45.  {
  46.    m_MRecByte[i]  = 0x00;    
  47.        m_SSendByte[i] = 0x00;    
  48.  }
  50.      m_MReadState = AddrCode;
  51.  m_SReadState = AddrByte;
  52.  m_MInfoIndex = 0;
  54. }
  56. CPrtModbus::~CPrtModbus()
  57. {
  59. }
  61.  //启动主站召唤时钟
  62. void CPrtModbus::StartTimer()
  63. {
  64.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;        //框架窗口指针;
  65.   CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView(); //视图指针
  66.   ASSERT_VALID(pView);
  68.   m_CallTimerID  = pView->SetTimer(1,m_CallIntv,NULL);
  69.   m_bIsTimerStar = true;
  70. }
  72.  //关闭主站召唤时钟
  73. void CPrtModbus::CloseTimer()
  74. {
  75.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;        //框架窗口指针;
  76.   CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView(); //视图指针
  77.   ASSERT_VALID(pView);
  79.   if (m_bIsTimerStar)
  80.   {
  81.      pView->KillTimer(m_CallTimerID);
  82.      m_bIsTimerStar = false;
  83.   }
  84. }
  86. //主站召唤子站数据
  87. void CPrtModbus::MasterSend(UINT nIDEvent)
  88. {
  89.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;        //框架窗口指针;
  90.   CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView(); //视图指针
  91.   ASSERT_VALID(pView);
  93.   DWORD dwBytesSended = 0;
  94.   CString s1 = "" ;  //显示的字符串
  96.   if (m_CallYXFlag)
  97.   {   //发送主站召遥信报文,并显示
  98.      if ( pView->Send(m_CallYXByte,8,dwBytesSended) )  //召遥信
  99.  {
  100.         s1 = "<Send>:Modbus主站召遥信";
  101. s1 = s1 + "rn" + ByteArrayToString(m_CallYXByte,8) + "rn";
  102.         pView->DisplayMsg(s1);     //显示召唤报文
  103.  }
  104.   }
  105.   else
  106.   {  //发送主站召遥测报文,并显示
  107.      if ( pView->Send(m_CallYCByte,8,dwBytesSended) )  //召遥测
  108.  {
  109.         s1 = "<Send>:Modbus主站召遥测";
  110.     s1 = s1 + "rn" + ByteArrayToString(m_CallYCByte,8) + "rn";
  111.         pView->DisplayMsg(s1);     //显示召唤报文
  112.  }
  113.   } 
  114.   
  115.   m_CallYXFlag = !m_CallYXFlag;
  116. }
  118. void CPrtModbus::InitPrt()
  119. {
  120.    MPackYX();     //打包召遥信报文
  121.    MPackYC();     //打包召遥测报文
  122. }
  124. //打包召唤遥信报文
  125. void CPrtModbus::MPackYX()
  126. {
  127.    CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  128.    CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  129.    ASSERT_VALID(pDoc);
  131.    m_CallYXByte[0] = m_Addr;
  132.    m_CallYXByte[1] = m_YXFunc;
  134.    WORD temVar = 0x0000;
  136.    temVar = (WORD)pDoc->m_YXAddr;      //遥信首地址
  137.    m_CallYXByte[2] = HIBYTE(temVar);
  138.    m_CallYXByte[3] = LOBYTE(temVar);
  140.    temVar = (WORD)pDoc->m_YXNum;       //遥信个数
  141.    m_CallYXByte[4] = HIBYTE(temVar);
  142.    m_CallYXByte[5] = LOBYTE(temVar);
  144.    //CRC校验
  145.    WORD CRCWord = GetCRC16Byte(m_CallYXByte,6); //获取CRC校验码
  146.    BYTE CRCHi = HIBYTE(CRCWord);
  147.    BYTE CRCLo = LOBYTE(CRCWord);
  149.    m_CallYXByte[6] = CRCHi;     //CRC校验高字节
  150.    m_CallYXByte[7] = CRCLo;     //CRC校验低字节
  152. }
  154. //打包召唤遥测报文
  155. void CPrtModbus::MPackYC()
  156. {
  157.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  158.   CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  159.   ASSERT_VALID(pDoc);
  161.    m_CallYCByte[0] = m_Addr;
  162.    m_CallYCByte[1] = m_YCFunc;
  164.    WORD temVar = 0x0000;
  166.    temVar = (WORD)pDoc->m_YCAddr;      //遥测首地址
  167.    m_CallYCByte[2] = HIBYTE(temVar);
  168.    m_CallYCByte[3] = LOBYTE(temVar);
  170.    temVar = (WORD)pDoc->m_YCNum;       //遥测个数
  171.    m_CallYCByte[4] = HIBYTE(temVar);
  172.    m_CallYCByte[5] = LOBYTE(temVar);
  174. //CRC校验
  175.    WORD CRCWord = GetCRC16Byte(m_CallYCByte,6); //获取CRC校验码
  176.    BYTE CRCHi = HIBYTE(CRCWord);
  177.    BYTE CRCLo = LOBYTE(CRCWord);
  179.    m_CallYCByte[6] = CRCHi;     //CRC校验高字节
  180.    m_CallYCByte[7] = CRCLo;     //CRC校验低字节
  181. }
  183. //主站接收子站应答报文
  184. void CPrtModbus::MasterRec(BYTE recByte)
  185. {
  186.    switch (m_MReadState)
  187.    {
  188.    case AddrCode:       //地址码
  189.    if (recByte == m_Addr)
  190.    {
  191.    m_MRecByte[0] = recByte;
  192.            m_MReadState  = FuncCode;
  193.    }
  194.    break;
  196.    case FuncCode:       //功能码
  197.        if ( (recByte == m_YXFunc) || (recByte == m_YCFunc) )
  198.    {
  199.    m_MRecByte[1] = recByte;
  200.            m_MReadState  = NumCode;
  201.    }
  202.    else
  203.            m_MReadState  = AddrCode;    //丢弃，重新从地址码读取
  204.    break;
  206.    case NumCode:        //信息体字节数
  207.            m_MRecByte[2] = recByte;
  208.            m_MInfoIndex  = 0;
  209.            m_MReadState  = InfoCode;
  210.    break;
  212.    case InfoCode:       //信息体
  213.        m_MRecByte[3+m_MInfoIndex] = recByte;
  214.    if (m_MInfoIndex < (m_MRecByte[2]-1))   // 如读取的字节数小于信息字节数，则继续读取
  215.    m_MInfoIndex++;
  216.    else
  217.    { 
  218.    m_MReadState = CRCHiCode;
  219.    m_MInfoIndex = 0;
  220.    }
  221.    break;
  223.    case CRCHiCode:
  224.        m_MRecByte[3+m_MRecByte[2]] = recByte;
  225.        m_MReadState = CRCLoCode;
  226.    break;
  228.    case CRCLoCode:
  229.        m_MRecByte[4+m_MRecByte[2]] = recByte;
  230.        m_MReadState  = AddrCode;    //本帧读取结束，下帧从地址码读取
  232.    //读进报文CRC校验
  233.         WORD CRCWord;
  234.         BYTE CRCHi, CRCLo;
  235. CRCWord = GetCRC16Byte(m_MRecByte,(3+m_MRecByte[2]));
  236.     CRCHi   = HIBYTE(CRCWord);
  237.     CRCLo   = LOBYTE(CRCWord);
  238. //////////////////
  239.    if ((m_MRecByte[3+m_MRecByte[2]] == CRCHi) && (m_MRecByte[4+m_MRecByte[2]] == CRCLo))
  240.     MasterUnPack();        //CRC校验正确，解信息报文
  241.    break;
  243.    default:
  244.        m_MReadState  = AddrCode;    //重新从地址码读取
  245.    break;
  246.    }
  248. }
  250. // 信息报文解包，并显示报文
  251. void CPrtModbus::MasterUnPack()
  252. {
  253.    CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd; //框架窗口指针;
  254.    CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView(); //视图指针
  255.    ASSERT_VALID(pView);
  257.    CString s1 = "" ;  //显示的字符串
  259.    if (m_MRecByte[1] == m_YXFunc)
  260. { //遥信数据包
  261.    MUnPackYX();
  262.        s1 = "<Rec>:Modbus子站遥信";
  263. }
  264.     else
  265.     {
  266.        MUnPackYC();
  267.        s1 = "<Rec>:Modbus子站遥测";
  268.     }
  270.      int recnum = 5+m_MRecByte[2];
  271.      s1 = s1 + "rn" + ByteArrayToString(m_MRecByte,recnum) + "rn";
  272.  pView->DisplayMsg(s1);     //显示召唤报文
  273. }
  275. void CPrtModbus::MUnPackYX()
  276. {
  277.     CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  278.     CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  279.     ASSERT_VALID(pDoc);
  280.    
  281. int iyxnum = m_MRecByte[2]*8;
  282. BYTE* pyx   = new BYTE[iyxnum];       //临时存放解包的数据
  284.     int  i;
  285. BYTE tembyte;    //临时变量
  286. for (i=0; i<m_MRecByte[2]; i++)       //按字节解包
  287. {
  288.       tembyte = m_MRecByte[3+i];    
  289. for (int j=0;j<8;j++)             //每个字节取8个遥信量
  290. { //取最低位，提取遥信
  291.   pyx[8*i+j] = 0x01 & tembyte;
  292.           tembyte   = tembyte >> 1;
  293. }
  294. }
  296. if (pDoc->m_pYXData != NULL)
  297. {
  298.        iyxnum > pDoc->m_YXNum ? (iyxnum = pDoc->m_YXNum) : 1;
  299.    for (i=0; i<iyxnum; i++)
  300.    pDoc->m_pYXData[i] = pyx[i];
  301.        pMainFrame->UpdateYXGrid(); //更新电子表格数据
  302. }
  303.       
  304. delete[] pyx;
  305. }
  307. void CPrtModbus::MUnPackYC()
  308. {
  309.     CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  310.     CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  311.     ASSERT_VALID(pDoc);
  313. int iycnum = m_MRecByte[2]>>1;        //需要解包的遥测数量，如有剩余单个字节，不处理该字节
  314. iycnum > pDoc->m_YCNum ? (iycnum = pDoc->m_YCNum) : 1;
  316. if (pDoc->m_pYCData != NULL)
  317. {
  318. for (int i=0; i<iycnum; i++)          //给MODBUS遥测库更新
  319.     pDoc->m_pYCData[i] = m_MRecByte[3+2*i]*256 + m_MRecByte[3+2*i+1];
  320. pMainFrame->UpdateYCGrid();           //更新电子表格数据  HIBYTE
  321. }
  322. }
  324. // 从站接收召唤数据
  325. void CPrtModbus::SlaveRec(BYTE recByte)
  326. {
  327.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;        //框架窗口指针;
  328.   CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView(); //视图指针
  329.   ASSERT_VALID(pView);
  331. switch (m_SReadState)
  332. {
  333. case AddrByte:                       //地址码
  334.         if (recByte == m_Addr)             
  335. {
  336.    m_SRecByte[0] = recByte;
  337.            m_SReadState  = FuncByte;
  338. }
  339. break;
  341. case FuncByte:                       //功能码
  342.         if ( (recByte == m_YXFunc) || (recByte == m_YCFunc) )
  343. {
  344.    m_SRecByte[1] = recByte;
  345.            m_SReadState  = AddrHiByte;
  346. }
  347.     else
  348.            m_SReadState  = AddrByte;     //丢弃，重新从地址码读取
  349. break;
  351. case AddrHiByte:
  352.         m_SRecByte[2] = recByte;
  353.         m_SReadState  = AddrLoByte;
  354. break;
  356. case AddrLoByte:
  357.         m_SRecByte[3] = recByte;
  358.         m_SReadState  = NumHiByte;
  359. break;
  361.     case NumHiByte:
  362.         m_SRecByte[4] = recByte;
  363.         m_SReadState  = NumLoByte;
  364. break;
  366.     case NumLoByte:
  367.         m_SRecByte[5] = recByte;
  368.         m_SReadState  = CRCHiByte;
  369. break;
  371.     case CRCHiByte:
  372.         m_SRecByte[6] = recByte;
  373.         m_SReadState  = CRCLoByte;
  374. break;
  376.     case CRCLoByte:
  377.         m_SRecByte[7] = recByte;
  378.         m_SReadState  = AddrByte;      //本帧读取结束，下帧从地址码读取   
  380.         //读进报文CRC校验
  381.         WORD CRCWord;
  382.         BYTE CRCHi, CRCLo;
  383. CRCWord = GetCRC16Byte(m_SRecByte,6);
  384.     CRCHi   = HIBYTE(CRCWord);
  385.     CRCLo   = LOBYTE(CRCWord);
  386. //////////////////
  387.    if ((m_SRecByte[6] == CRCHi) && (m_SRecByte[7] == CRCLo))
  388.    {  
  389.   CString s1;
  390.   if (m_SRecByte[1] == m_YXFunc)
  391.   s1 = "<Rec>:Modbus主站召遥信";
  392.   else
  393.               s1 = "<Rec>:Modbus主站召遥测";
  394.   s1 = s1 + "rn" + ByteArrayToString(m_SRecByte,8) + "rn";
  395.           pView->DisplayMsg(s1);     //显示召唤报文
  396.   SlaveSend();
  397.    }
  398. break;
  400.     default:
  401.         m_SReadState  = AddrByte;      //重新从地址码读取
  402.     break;
  403. }
  404. }
  406. //从站应答召唤
  407. void CPrtModbus::SlaveSend()
  408. {
  409.   CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  410.   CPeugeotView* pView    = (CPeugeotView*) pMainFrame->GetActiveView();    //视图指针
  411.   ASSERT_VALID(pView);
  412.  // CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  413.  //ASSERT_VALID(pDoc);
  414.   int sendnum = 0;        //发送字节数
  415.   CString s1  = "";       //显示信息
  416.   DWORD dwBytesSended = 0;
  418.   if (m_SRecByte[1] == m_YXFunc)
  419.   {
  420.  SPackYX();
  421.  s1 = "<Send>:Modbus子站遥信";
  422.   }
  423.   else
  424.   {
  425.      SPackYC();
  426.      s1 = "<Send>:Modbus子站遥测";
  427.   }
  428.   
  429.    //CRC校验
  430.     WORD CRCWord = GetCRC16Byte(m_SSendByte,(m_SSendByte[2]+3)); //获取CRC校验码
  431.     BYTE CRCHi = HIBYTE(CRCWord);
  432.     BYTE CRCLo = LOBYTE(CRCWord);
  433.     m_SSendByte[m_SSendByte[2]+3] = CRCHi;     //CRC校验高字节
  434. m_SSendByte[m_SSendByte[2]+4] = CRCLo;     //CRC校验低字节
  436.   sendnum = m_SSendByte[2] + 5;
  437.   if (pView->Send(m_SSendByte,sendnum,dwBytesSended))  //发送应答报文并显示
  438.   {
  439.    s1 = s1 + "rn" + ByteArrayToString(m_SSendByte,sendnum) + "rn";
  440.    pView->DisplayMsg(s1);
  441.   }
  442. }
  444. //从从站打遥信包
  445. void CPrtModbus::SPackYX()
  446. {
  447.    CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  448.    CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  449.    ASSERT_VALID(pDoc);
  451.    m_SSendByte[0] = m_Addr;
  452.    m_SSendByte[1] = m_YXFunc;
  453.    
  454.    WORD yxaddr = (m_SRecByte[2]<<8) | (m_SRecByte[3]);    //遥信首地址
  455.    WORD yxnum  = (m_SRecByte[4]<<8) | (m_SRecByte[5]);    //遥信信息字节数
  456.    yxnum > 0x07F8 ? (yxnum = 0x07F8):1;                   //遥信个数不能超过 255 ×8 
  458.    if ((yxnum & 0x0007) > 0)                              //遥信信息字节数,如余1～7个遥信，则补一个字节
  459.       m_SSendByte[2] = LOBYTE(yxnum>>3)+1;  
  460.    else
  461.       m_SSendByte[2] = LOBYTE(yxnum>>3);  
  462.    
  463.  //读出遥信库中的值，放入字节数组，不足八个的补零
  464.  if (pDoc->m_pYXData != NULL)
  465.  {
  466.    BYTE* pb = NULL;
  467.    
  468.    yxnum = (WORD) pDoc->m_YXNum; 
  469.    if ((yxnum & 0x0007) > 0)         //实时库遥信个数,如余1～7个遥信，则补齐8个（1字节）
  470.        yxnum = (yxnum | 0x0007) + 1;  
  471.   
  472.    pb = new BYTE[yxnum];
  473.    int i = 0; int j = 0; int k = 0;
  474.    
  475.    while(i<yxnum)
  476.    {
  477.  if (i<pDoc->m_YXNum)
  478.    pb[i] = pDoc->m_pYXData[i];
  479.  else
  480.    pb[i] = 0x00;
  481.  i++;
  482.    }
  483.  //////////////////////////////////
  484.    yxnum = yxnum>>3;   
  485.    for (i=0;i<m_SSendByte[2];i++)         //共发送m_SSendByte[2]个遥信信息字节
  486.    {
  487.   m_SSendByte[i+3] = 0x00;            //初始化第（i+3）个字节
  488.   if ( (yxaddr+i)>=(pDoc->m_YXAddr) && (yxaddr+i)<(pDoc->m_YXAddr+yxnum) )
  489.   { //如果在遥信库范围内，则发送信息取值实时遥信库
  490.       k = (yxaddr + i) - pDoc->m_YXAddr;
  491.   for (j=8; j>0; j--)
  492.   {
  493.        m_SSendByte[i+3] = m_SSendByte[i+3]<<1;    //先左移1位，腾出低位填入第j个遥信状态
  494.            m_SSendByte[i+3] = m_SSendByte[i+3] | pb[k*8+j-1];
  495.   }
  496.   }
  497.    }
  498.  delete[] pb;
  499.  }
  500. }
  502. //从从站打遥测包
  503. void CPrtModbus::SPackYC()
  504. {
  505.    CMainFrame* pMainFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;           //框架窗口指针;
  506.    CPeugeotDoc* pDoc      = (CPeugeotDoc*) pMainFrame->GetActiveDocument(); //文档指针
  507.    ASSERT_VALID(pDoc);
  509.    m_SSendByte[0] = m_Addr;
  510.    m_SSendByte[1] = m_YCFunc;
  512.    WORD ycaddr = (m_SRecByte[2]<<8) | (m_SRecByte[3]);    //主站召唤的遥测首地址
  513.    if (m_SRecByte[5] > 0x7F)
  514.        m_SSendByte[2] = 0XFE;              //2个字节组一个遥测时，最多为254个字节
  515.    else
  516.        m_SSendByte[2] = m_SRecByte[5]<<1;  //发送的字节数，一个遥测量两个字节，所以，遥测数×2
  518.    if (pDoc->m_pYCData != NULL)
  519.    {
  520.   int i = 0; int j = 0;
  521.       for (i=0; i<(m_SSendByte[2]>>1); i++)
  522.   {
  523.          if ((ycaddr+i)>=(pDoc->m_YCAddr) && (ycaddr+i)<(pDoc->m_YCAddr+pDoc->m_YCNum))
  524.  {  //如果在遥测库范围内，则发送信息取值实时遥测库
  525.     j = (ycaddr + i) - pDoc->m_YCAddr;
  526.             m_SSendByte[2*i+3] = HIBYTE(pDoc->m_pYCData[j]); //第i个遥测高字节
  527.             m_SSendByte[2*i+4] = LOBYTE(pDoc->m_pYCData[j]); //第i个遥测高字节
  528.  }
  529.  else
  530.  {
  531.             m_SSendByte[2*i+3] = 0x00; //第i个遥测高字节
  532.             m_SSendByte[2*i+4] = 0x00; //第i个遥测高字节
  533.  } 
  534.   }
  535.    } 
  536. }