organization.proto 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196
  1. syntax = "proto3";
  2. package pb;
  3. option go_package = "./pb";
  4. message DcWorkingReq{
  5. int64 project_id = 1;
  6. string device_code = 2;
  7. }
  8. message WorkingUf{
  9. int64 id = 1;
  10. int64 project_id = 2;
  11. string device_code = 3;
  12. double water_temperature = 4; // 水温 摄氏度
  13. double feed_flow = 5; // 进水流量
  14. double con_flow = 6; // 浓水流量
  15. double product_flow = 7; // 产水流量
  16. double feed_pressure = 8; // 进水压力
  17. double con_pressure = 9; // 浓水压力
  18. double product_pressure = 10; // 产水压力
  19. double tmp = 11; // 跨膜压差
  20. double flux = 12; // 膜通量
  21. double feed_wq_turbidity = 13; // 进水浊度
  22. int64 feed_wq_ph = 14; // 进水 PH 值
  23. int64 product_wq_ph = 15; // 产水 PH 值
  24. double feed_wq_al = 16; // 进水水质:铝
  25. double product_wq_al = 17; // 产水水质:铝
  26. double feed_wq_fe = 18; // 进水水质:铁
  27. double product_wq_fe = 19; // 产水水质:铁
  28. double feed_wq_mn = 20; // 进水水质:锰
  29. double product_wq_mn = 21; // 产水水质:锰
  30. double feed_wq_sio2 = 22; // 进水水质:二氧化硅
  31. double product_wq_sio2 = 23; // 产水水质:二氧化硅
  32. double feed_wq_cod = 24; // 进水水质:COD
  33. double product_wq_cod = 25; // 产水水质:COD
  34. double feed_wq_p = 26; // 进水水质:磷
  35. double product_wq_p = 27; // 产水水质:磷
  36. int64 step = 28; // 设备当前步序值
  37. string c_time = 29;
  38. }
  39. message WorkingRo{
  40. int64 id = 1;
  41. int64 project_id = 2;
  42. string device_code = 3;
  43. double water_temperature = 4; // 水温 摄氏度
  44. double feed_flow_1st = 5; // 一段进水流量
  45. double con_flow_1st = 6; // 一段浓水流量
  46. double product_flow_1st = 7; // 一段产水流量
  47. double feed_pressure_1st = 8; // 一段进水压力
  48. double con_pressure_1st = 9; // 一段浓水压力
  49. double product_pressure_1st = 10; // 一段产水压力
  50. double tmp_1st = 11; // 一段跨膜压差
  51. double flux_1st = 12; // 一段膜通量
  52. double permeability_1st = 13; // 一段渗透率
  53. double feed_flow_2nd = 14; // 二段进水流量
  54. double con_flow_2nd = 15; // 二段浓水流量
  55. double product_flow_2nd = 16; // 二段产水流量
  56. double feed_pressure_2nd = 17; // 二段进水压力
  57. double con_pressure_2nd = 18; // 二段浓水压力
  58. double product_pressure_2nd = 19; // 二段产水压力
  59. double tmp_2nd = 20; // 二段压差
  60. double flux_2nd = 21; // 二段通量
  61. double permeability_2nd = 22; // 二段渗透率
  62. double feed_flow_3th = 23; // 三段进水流量
  63. double con_flow_3th = 24; // 三段浓水流量
  64. double product_flow_3th = 25; // 三段产水流量
  65. double feed_pressure_3th = 26; // 三段进水压力
  66. double con_pressure_3th = 27; // 三段浓水压力
  67. double product_pressure_3th = 28; // 三段产水压力
  68. double tmp_3th = 29; // 三段压差
  69. double flux_3th = 30; // 三段通量
  70. double permeability_3th = 31; // 三段渗透率
  71. double feed_wq_turbidity = 32; // 进水浊度
  72. int64 feed_wq_ph = 33; // 进水 PH 值
  73. int64 product_wq_ph = 34; // 产水 PH 值
  74. double feed_wq_al = 35; // 进水水质:铝
  75. double product_wq_al = 36; // 产水水质:铝
  76. double feed_wq_fe = 37; // 进水水质:铁
  77. double product_wq_fe = 38; // 产水水质:铁
  78. double feed_wq_mn = 39; // 进水水质:锰
  79. double product_wq_mn = 40; // 产水水质:锰
  80. double feed_wq_sio2 = 41; // 进水水质:二氧化硅
  81. double product_wq_sio2 = 42; // 产水水质:二氧化硅
  82. double feed_wq_cod = 43; // 进水水质:COD
  83. double product_wq_cod = 44; // 产水水质:COD
  84. double feed_wq_p = 45; // 进水水质:磷
  85. double product_wq_p = 46; // 产水水质:磷
  86. int64 step = 47; // 设备当前步序值
  87. string c_time = 48;
  88. }
  89. message WorkingChest {
  90. int64 id = 1;
  91. int64 project_id = 2;
  92. string device_code = 3;
  93. int64 switch = 4; // 药箱液位开关 0: 关 1: 开
  94. double level = 5; // 液位高度
  95. int64 agitator_status = 6; // 搅拌器运行状态 0: 未运行 1:运行中
  96. int64 agitator_duration = 7; // 搅拌器运行时长
  97. int64 agitator_fault_status = 8; // 搅拌器故障状态 0:正常 1:故障
  98. string c_time = 9;
  99. }
  100. message WorkingPump {
  101. int64 id = 1;
  102. int64 project_id = 2;
  103. string device_code = 3;
  104. double feed_pressure = 4; // 进水压力
  105. double out_pressure = 5; // 出水压力
  106. int64 duration = 6; // 运行时长 单位 s
  107. double current = 7; // 运行电流
  108. double frequency = 8; // 运行频率
  109. double lift = 9; // 工作扬程
  110. double efficiency = 10; // 运行效率
  111. int64 run_status = 11; // 运行状态 0: 停机 1: 运行正常
  112. int64 fault_status = 12; // 故障状态 0: 正常 1: 故障
  113. string c_time = 13;
  114. }
  115. message WorkingValve {
  116. int64 id = 1;
  117. int64 project_id = 2;
  118. string device_code = 3;
  119. int64 adjust = 4; // 是否为调节阀门 0: 否 1: 是
  120. double opening = 5; // 当前阀门的开度
  121. int64 closed = 6; // 关到位 全关 0: 否 1: 是
  122. int64 opened = 7; // 开到位 开到 设置的开度 0: 否 1: 是
  123. int64 fault_status = 8; // 是否故障 0: 否 1: 是
  124. string c_time = 9;
  125. }
  126. message ItemHistoryData {
  127. int64 project_id = 1;
  128. string item_name = 2;
  129. // @gotags: valid:"val"
  130. double val = 3;
  131. string h_time = 4;
  132. }
  133. message MultiAddItemHistoryDataReq {
  134. int64 project_id = 1;
  135. // @gotags: valid:"list"
  136. repeated ItemHistoryData list = 2;
  137. }
  138. message MultiAddItemHistoryDataResp {}
  139. message ItemHistoryDataListReq {
  140. int64 project_id = 1;
  141. string item_name = 2;
  142. string interval = 3; //时间单位 s,minute,h,day
  143. string aggregator = 4; //聚合方式 min,max,avg,sum,realtime, new
  144. string stime = 5;
  145. string etime = 6;
  146. int64 size = 7;
  147. }
  148. message ItemHistoryDataByTimeReq {
  149. int64 project_id = 1;
  150. string item_name = 2;
  151. string stime = 3;
  152. string etime = 4;
  153. }
  154. message ItemHistoryDataMaxMinResp {
  155. // @gotags: json:"max_val"
  156. double max_val = 1;
  157. // @gotags: json:"min_val"
  158. double min_val = 2;
  159. }
  160. message ItemHistoryDataList {
  161. string item_name = 1;
  162. // @gotags: json:"val"
  163. double val = 2;
  164. string h_time = 3;
  165. }
  166. message ItemHistoryDataListResp {
  167. // @gotags: valid:"list"
  168. repeated ItemHistoryDataList list = 1;
  169. }
  170. service Organization {
  171. rpc GetWorkingUfByCode(DcWorkingReq) returns(WorkingUf);
  172. rpc GetWorkingRoByCode(DcWorkingReq) returns(WorkingRo);
  173. rpc GetWorkingChestByCode(DcWorkingReq) returns(WorkingChest);
  174. rpc GetWorkingPumpByCode(DcWorkingReq) returns(WorkingPump);
  175. rpc GetWorkingValueByCode(DcWorkingReq) returns(WorkingValve);
  176. rpc MultiAddItemHistoryData(MultiAddItemHistoryDataReq) returns(MultiAddItemHistoryDataResp);
  177. rpc ItemHistoryDataList(ItemHistoryDataListReq) returns(ItemHistoryDataListResp);
  178. rpc ItemHistoryDataByTime(ItemHistoryDataByTimeReq) returns(ItemHistoryDataListResp);
  179. rpc ItemHistoryDataMaxMinByTime(ItemHistoryDataByTimeReq) returns(ItemHistoryDataMaxMinResp);
  180. }