DataManagerProxy.cpp 2.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. #include "DataManagerProxy.h"
  2. #include "RedisClient.h"
  3. DataManagerProxy::DataManagerProxy() {
  4. }
  5. DataManagerInfo DataManagerProxy::loadModuleInfos(int id, std::string app)
  6. {
  7. /*
  8. DataItem objDataItem;
  9. objDataItem.Id = 1;
  10. objDataItem.Code = "CEJINGYI-001.TEMP";
  11. objDataItem.DataName = "1号测径仪温度";
  12. objDataItem.DataType = "Integer";
  13. objDataItem.Description = "1号测径仪温度值";
  14. objDataItem.Displayed = true;
  15. ModuleInfo objModule;
  16. objModule.Id = 1;
  17. objModule.Name = "Modbus000";
  18. objModule.Model = "Modbus Com A0001";
  19. objModule.Code = "Modbus000-1";
  20. objModule.Type = ModuleType::Sensor;
  21. objModule.AssemblyName = "plugins/SampleTemperature.dll";
  22. objModule.ClassName = "Lanpeng.Module.Sensors.Modbus001";
  23. objModule.Version = "1.0";
  24. DeviceInfo objDevice;
  25. objDevice.Id = 1;
  26. objDevice.Name = "测径仪温度传感器";
  27. objDevice.Type = "传感器";
  28. objDevice.Model = "Temperatur Sensor A001";
  29. objDevice.Code = "ASCDSC001221S";
  30. objDevice.Description = "aaaaa";
  31. objDevice.ModuleInfo = objModule;
  32. objDevice.Properties.push_back(objDataItem);
  33. */
  34. RedisClient* redis = new RedisClient();
  35. /*DeviceInfo di;
  36. if( redis != nullptr)
  37. {
  38. ModuleInfo mi;
  39. mi.Code = "alarm";
  40. mi.AssemblyName = app;
  41. DataItem oDT;
  42. oDT.Code = "data";
  43. mi.Properties.push_back(oDT);
  44. QStringList lst = redis->hvals(id.c_str());
  45. foreach (QString str, lst)
  46. {
  47. if( str.isEmpty() )
  48. {
  49. continue;
  50. }
  51. AlarmRuler ar;
  52. if( parse(str,ar) )
  53. {
  54. QString szJson;
  55. szJson += "{";
  56. szJson += QString("\"Operator\":\"%1\",").arg(ar.Operator.c_str());
  57. szJson += QString("\"Operator1\":%1,").arg(ar.dbOperator1);
  58. szJson += QString("\"Operator2\":%1,").arg(ar.dbOperator2);
  59. szJson += QString("\"KeepTimes\":%1").arg(ar.nKeepTimes);
  60. szJson += "}";
  61. Setting oSet;
  62. oSet.Name = ar.NodeCode;
  63. oSet.qValue = szJson;
  64. mi.vSettings.push_back(oSet);
  65. }
  66. }
  67. di.ModuleInfo = mi;
  68. }
  69. return di;
  70. */
  71. ModuleInfo mi;
  72. mi.Name = "RedisSubscriber";
  73. mi.AssemblyName = "plugins/RedisSubscriber.dll";
  74. mi.ClassName = "RedisSubscriber";
  75. ConsumerInfo ci;
  76. ci.name = "TDengine";
  77. ci.AssemblyName = "plugins/TDengine.dll";
  78. ci.ClassName = "TDengine";
  79. ci.SubscribeName = "RedisSubscriber";
  80. DataManagerInfo listDataManageInfo;
  81. listDataManageInfo.consumers.push_back(ci);
  82. listDataManageInfo.modules.push_back(mi);
  83. return listDataManageInfo;
  84. }