snap7_communication_base.h 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. //
  2. // Created by huli on 2020/9/25.
  3. //
  4. #ifndef NNXX_TESTS_SNAP7_E_BASE_H
  5. #define NNXX_TESTS_SNAP7_E_BASE_H
  6. #include <s7_client.h>
  7. #include <mutex>
  8. #include <map>
  9. #include <glog/logging.h>
  10. #include "../error_code/error_code.h"
  11. #include "../tool/thread_condition.h"
  12. #include "snap7_buf.h"
  13. #include "s7_plc.h"
  14. class Snap7_communication_base
  15. {
  16. public:
  17. //snap7的通信延时, 默认50ms
  18. #define SNAP7_COMMUNICATION_DELAY_TIME_MS 10
  19. //snap7的通信参数路径
  20. #define SNAP7_COMMUNICATION_PARAMETER_PATH "../setting/snap7_communication.prototxt"
  21. //通信状态
  22. enum Snap7_communication_statu
  23. {
  24. SNAP7_COMMUNICATION_UNKNOWN =0, //通信状态 未知
  25. SNAP7_COMMUNICATION_READY =1, //通信状态 正常
  26. SNAP7_COMMUNICATION_RECEIVE =2, //接受
  27. SNAP7_COMMUNICATION_SEND =3, //发送
  28. SNAP7_COMMUNICATION_DISCONNECT =4, //断连
  29. SNAP7_COMMUNICATION_FAULT =10, //通信状态 错误
  30. };
  31. public:
  32. Snap7_communication_base();
  33. Snap7_communication_base(const Snap7_communication_base& other)= default;
  34. Snap7_communication_base& operator =(const Snap7_communication_base& other)= default;
  35. ~Snap7_communication_base();
  36. public://API functions
  37. //初始化 通信 模块。如下三选一
  38. virtual Error_manager communication_init(std::string ip);
  39. //反初始化 通信 模块。
  40. virtual Error_manager communication_uninit();
  41. //唤醒s7通信线程
  42. virtual Error_manager communication_start();
  43. //停止s7通信线程
  44. virtual Error_manager communication_stop();
  45. public://get or set member variable
  46. Snap7_communication_statu get_status();
  47. //接受数据, 读取DB块,
  48. Error_manager read_data_buf(Snap7_buf& snap7_buf);
  49. //发送数据, 写入DB块,
  50. Error_manager write_data_buf(Snap7_buf& snap7_buf);
  51. protected://member functions
  52. //通信连接
  53. Error_manager communication_connect(std::string ip_string);
  54. //启动通信, run thread
  55. Error_manager communication_run();
  56. //通信断连
  57. Error_manager communication_disconnect();
  58. //mp_communication_thread线程的执行函数, 负责进行s7的通信
  59. void communication_thread();
  60. //数据颠倒
  61. Error_manager reverse_byte(void* p_buf_in, void* p_buf_out, int size);
  62. //更新数据
  63. virtual Error_manager updata_receive_buf();
  64. virtual Error_manager updata_send_buf();
  65. protected://member variable
  66. public:
  67. //状态
  68. Snap7_communication_statu m_communication_status; //通信状态
  69. std::string m_ip_string; //通信ip
  70. //通信模块
  71. std::mutex m_communication_lock; //通信锁
  72. TSnap7Client m_snap7_client; //通信的客户端
  73. int m_communication_delay_time_ms;//通信延时, 单位ms
  74. //注:s7协议通信很不稳定, 在每次使用 TSnap7Client 之后, 都需要加延时
  75. //数据
  76. std::mutex m_receive_buf_lock; //接受的锁
  77. std::map<int, Snap7_buf> m_receive_buf_map; //接受的map容器
  78. std::mutex m_send_buf_lock; //发送的锁
  79. std::map<int, Snap7_buf> m_send_buf_map; //发送的map容器
  80. //线程, snap7的通信核心就是对 发送和接受内存的 周期性读写, 所以使用一个线程即可.
  81. std::thread* mp_communication_thread; //通信的线程指针
  82. Thread_condition m_communication_condition; //通信的条件变量
  83. private:
  84. };
  85. #endif //NNXX_TESTS_SNAP7_E_BASE_H