syntax = "proto3"; package pb; option go_package = "./pb"; message DcWorkingReq{ int64 project_id = 1; string device_code = 2; } message WorkingUf{ int64 id = 1; int64 project_id = 2; string device_code = 3; double water_temperature = 4; // 水温 摄氏度 double feed_flow = 5; // 进水流量 double con_flow = 6; // 浓水流量 double product_flow = 7; // 产水流量 double feed_pressure = 8; // 进水压力 double con_pressure = 9; // 浓水压力 double product_pressure = 10; // 产水压力 double tmp = 11; // 跨膜压差 double flux = 12; // 膜通量 double feed_wq_turbidity = 13; // 进水浊度 int64 feed_wq_ph = 14; // 进水 PH 值 int64 product_wq_ph = 15; // 产水 PH 值 double feed_wq_al = 16; // 进水水质：铝 double product_wq_al = 17; // 产水水质：铝 double feed_wq_fe = 18; // 进水水质：铁 double product_wq_fe = 19; // 产水水质：铁 double feed_wq_mn = 20; // 进水水质：锰 double product_wq_mn = 21; // 产水水质：锰 double feed_wq_sio2 = 22; // 进水水质：二氧化硅 double product_wq_sio2 = 23; // 产水水质：二氧化硅 double feed_wq_cod = 24; // 进水水质：COD double product_wq_cod = 25; // 产水水质：COD double feed_wq_p = 26; // 进水水质：磷 double product_wq_p = 27; // 产水水质：磷 int64 step = 28; // 设备当前步序值 string c_time = 29; } message WorkingRo{ int64 id = 1; int64 project_id = 2; string device_code = 3; double water_temperature = 4; // 水温 摄氏度 double feed_flow_1st = 5; // 一段进水流量 double con_flow_1st = 6; // 一段浓水流量 double product_flow_1st = 7; // 一段产水流量 double feed_pressure_1st = 8; // 一段进水压力 double con_pressure_1st = 9; // 一段浓水压力 double product_pressure_1st = 10; // 一段产水压力 double tmp_1st = 11; // 一段跨膜压差 double flux_1st = 12; // 一段膜通量 double permeability_1st = 13; // 一段渗透率 double feed_flow_2nd = 14; // 二段进水流量 double con_flow_2nd = 15; // 二段浓水流量 double product_flow_2nd = 16; // 二段产水流量 double feed_pressure_2nd = 17; // 二段进水压力 double con_pressure_2nd = 18; // 二段浓水压力 double product_pressure_2nd = 19; // 二段产水压力 double tmp_2nd = 20; // 二段压差 double flux_2nd = 21; // 二段通量 double permeability_2nd = 22; // 二段渗透率 double feed_flow_3th = 23; // 三段进水流量 double con_flow_3th = 24; // 三段浓水流量 double product_flow_3th = 25; // 三段产水流量 double feed_pressure_3th = 26; // 三段进水压力 double con_pressure_3th = 27; // 三段浓水压力 double product_pressure_3th = 28; // 三段产水压力 double tmp_3th = 29; // 三段压差 double flux_3th = 30; // 三段通量 double permeability_3th = 31; // 三段渗透率 double feed_wq_turbidity = 32; // 进水浊度 int64 feed_wq_ph = 33; // 进水 PH 值 int64 product_wq_ph = 34; // 产水 PH 值 double feed_wq_al = 35; // 进水水质：铝 double product_wq_al = 36; // 产水水质：铝 double feed_wq_fe = 37; // 进水水质：铁 double product_wq_fe = 38; // 产水水质：铁 double feed_wq_mn = 39; // 进水水质：锰 double product_wq_mn = 40; // 产水水质：锰 double feed_wq_sio2 = 41; // 进水水质：二氧化硅 double product_wq_sio2 = 42; // 产水水质：二氧化硅 double feed_wq_cod = 43; // 进水水质：COD double product_wq_cod = 44; // 产水水质：COD double feed_wq_p = 45; // 进水水质：磷 double product_wq_p = 46; // 产水水质：磷 int64 step = 47; // 设备当前步序值 string c_time = 48; } message WorkingChest { int64 id = 1; int64 project_id = 2; string device_code = 3; int64 switch = 4; // 药箱液位开关 0： 关 1： 开 double level = 5; // 液位高度 int64 agitator_status = 6; // 搅拌器运行状态 0： 未运行 1：运行中 int64 agitator_duration = 7; // 搅拌器运行时长 int64 agitator_fault_status = 8; // 搅拌器故障状态 0：正常 1：故障 string c_time = 9; } message WorkingPump { int64 id = 1; int64 project_id = 2; string device_code = 3; double feed_pressure = 4; // 进水压力 double out_pressure = 5; // 出水压力 int64 duration = 6; // 运行时长 单位 s double current = 7; // 运行电流 double frequency = 8; // 运行频率 double lift = 9; // 工作扬程 double efficiency = 10; // 运行效率 int64 run_status = 11; // 运行状态 0： 停机 1： 运行正常 int64 fault_status = 12; // 故障状态 0： 正常 1： 故障 string c_time = 13; } message WorkingValve { int64 id = 1; int64 project_id = 2; string device_code = 3; int64 adjust = 4; // 是否为调节阀门 0： 否 1： 是 double opening = 5; // 当前阀门的开度 int64 closed = 6; // 关到位 全关 0: 否 1： 是 int64 opened = 7; // 开到位 开到 设置的开度 0: 否 1： 是 int64 fault_status = 8; // 是否故障 0: 否 1： 是 string c_time = 9; } message ItemHistoryData { int64 project_id = 1; string item_name = 2; // @gotags: valid:"val" double val = 3; string h_time = 4; } message MultiAddItemHistoryDataReq { int64 project_id = 1; // @gotags: valid:"list" repeated ItemHistoryData list = 2; } message MultiAddItemHistoryDataResp {} message ItemHistoryDataListReq { int64 project_id = 1; string item_name = 2; string interval = 3; //时间单位 s,minute,h,day string aggregator = 4; //聚合方式 min,max,avg，sum，realtime, new string stime = 5; string etime = 6; int64 size = 7; } message ItemHistoryDataByTimeReq { int64 project_id = 1; string item_name = 2; string stime = 3; string etime = 4; } message ItemHistoryDataMaxMinResp { // @gotags: json:"max_val" double max_val = 1; // @gotags: json:"min_val" double min_val = 2; } message ItemHistoryDataList { string item_name = 1; // @gotags: json:"val" double val = 2; string h_time = 3; } message ItemHistoryDataListResp { // @gotags: valid:"list" repeated ItemHistoryDataList list = 1; } service Organization { rpc GetWorkingUfByCode(DcWorkingReq) returns(WorkingUf); rpc GetWorkingRoByCode(DcWorkingReq) returns(WorkingRo); rpc GetWorkingChestByCode(DcWorkingReq) returns(WorkingChest); rpc GetWorkingPumpByCode(DcWorkingReq) returns(WorkingPump); rpc GetWorkingValueByCode(DcWorkingReq) returns(WorkingValve); rpc MultiAddItemHistoryData(MultiAddItemHistoryDataReq) returns(MultiAddItemHistoryDataResp); rpc ItemHistoryDataList(ItemHistoryDataListReq) returns(ItemHistoryDataListResp); rpc ItemHistoryDataByTime(ItemHistoryDataByTimeReq) returns(ItemHistoryDataListResp); rpc ItemHistoryDataMaxMinByTime(ItemHistoryDataByTimeReq) returns(ItemHistoryDataMaxMinResp); }