diff --git a/proto/phase_server.proto b/proto/phase_server.proto new file mode 100644 index 0000000..93cc7ae --- /dev/null +++ b/proto/phase_server.proto @@ -0,0 +1,314 @@ +syntax = "proto3"; + +package phase_server; + +service PhaseService { + //获取异常路口 + rpc ExceptionPhaseCross (EmptyRequest) returns (ExceptionPhaseCrossResponse); + //异常路口详情列表 + rpc ExceptionPhaseCrossInfo (ExceptionPhaseCrossInfoRequest) returns (ExceptionPhaseCrossInfoResponse); + //根据路口ID返回异常配时 + rpc ExceptionPhaseByCrossIDs (ExceptionPhaseByCrossIDsRequest) returns (ExceptionPhaseByCrossIDsResponse); + //根据路口ID返回路口配时方案详情 + rpc GetCrossPhaseDetailByCrossIDs (GetCrossPhaseDetailByCrossIDsRequest) returns (GetCrossPhaseDetailByCrossIDsResponse); + //获取有配时方案路口列表 + rpc GetPhaseCrossID (EmptyRequest) returns (GetPhaseCrossIDResponse); + //获取配时方案协调/非协调方向绿灯时长比 + rpc PhaseGreenRatio (PhaseGreenRatioRequest) returns (PhaseGreenRatioResponse); + //获取配时方案协调/非协调方向绿灯时长比 + rpc CrossList (CrossListRequest) returns (CrossListResponse); + //依据日期，时刻查询多路口配时方案与相对相位差 + rpc QueryCrossPhaseRelativeOffset (QueryCrossPhaseRelativeOffsetRequest) returns (QueryCrossPhaseRelativeOffsetResponse); + //单条绿波配时方案时段与路口配时方案时段校验 + rpc GreenWaveCrossPhaseTpCheck (GreenWaveCrossPhaseTpCheckRequest) returns (GreenWaveCrossPhaseTpCheckResponse); + //路口运行中的配时方案 + rpc CrossRunningPhase (CrossRunningPhaseRequest) returns (CrossRunningPhaseResponse); + //路口配时方案诊断列表 + rpc CrossPhaseDiagnosis (CrossPhaseDiagnosisRequest) returns (CrossPhaseDiagnosisResponse); +} + +message EmptyRequest {} + +message ExceptionPhaseCrossResponse { + int32 code = 1; + string msg = 2; + repeated List data = 4; + message List { + int32 nodeid = 1; + string crossid = 2; + } +} + +message ExceptionPhaseCrossInfoRequest { + repeated int32 citycode = 1; +} + +message ExceptionPhaseCrossInfoResponse { + int32 code = 1; + string msg = 2; + int32 total = 3; + int32 cross_total = 4; + repeated List data = 5; + message List { + int32 citycode = 1; + string crossid = 2; + int32 scheduleid = 3; + int32 planid = 4; + string plan_name = 5; + string tp_start = 6; + string days = 7; + string type = 8; + } +} + +message ExceptionPhaseByCrossIDsRequest { + int32 citycode = 1; + repeated string crossid = 2; +} + +message ExceptionPhaseByCrossIDsResponse { + int32 code = 1; + string msg = 2; + repeated List data = 5; + message List { + int32 citycode = 1; + string crossid = 2; + string cross_name = 3; + int32 scheduleid = 4; + int32 planid = 5; + string plan_name = 6; + string tp_start = 7; + string date = 8; + string week = 9; + string type = 10; + } +} + +message GetCrossPhaseDetailByCrossIDsRequest { + int32 citycode = 1; + repeated string crossids = 2; + string gw_src_dir = 3; + string tp_start = 4; + string tp_end = 5; + string week = 6; + string wave_id = 7; +} + +message GetCrossPhaseDetailByCrossIDsResponse { + int32 code = 1; + string msg = 2; + int32 cycle = 3; //公共周期 + repeated List data = 4; + message List { + string crossid = 1; + int32 green_forward = 2; //正向绿灯时长 + int32 green_revers = 3; //逆向绿灯时长 + int32 offset = 4; //正向相位差 + int32 offset_r = 5; //正向相位差 + int32 cycle = 6; //周期 + int32 day = 7; //天 + int32 month = 8; //月 + int32 weekday = 9; //周 + int32 scheduleid = 10; //计划号 + int32 planid = 11; //方案号 + string plan_name = 12; //方案名称 + int32 coord_phaseid = 13; //协调相位号 + string type = 14; //类型：weekday（周），date（特殊日），month（月） + } +} + +message GetPhaseCrossIDResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + int32 citycode = 1; + string crossid = 2; + } +} + +message PhaseGreenRatioRequest { + int32 citycode = 1; + repeated string crossids = 2; + string gw_src_dir = 3; + string tp_start = 4; + string tp_end = 5; + string week = 6; //周 + string wave_id = 7; +} + +message PhaseGreenRatioResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + string crossid = 1; + float s2l = 2; //协直/协左 + string s2l_remark = 3; + int32 s2l_s_green = 4; + int32 s2l_l_green = 5; + float s2unl = 6; //协直/非协左 + string s2unl_remark = 7; + int32 s2unl_s_green = 8; + int32 s2unl_unl_green = 9; + float s2uns = 10; //协直/非协直 + string s2uns_remark = 11; + int32 s2uns_s_green = 12; + int32 s2uns_uns_green = 13; + float fwd2rev = 14; //协直正/反 + string fwd2rev_remark = 15; + int32 fwd2rev_fwd_green = 16; + int32 fwd2rev_rev_green = 17; + int32 planid = 18; //方案号 + int32 day = 19; //天 + int32 month = 20; //月 + int32 weekday = 21; //周 + int32 scheduleid = 22; //计划号 + string plan_name = 23; //方案名称 + string type = 24; //类型：weekday（周），date（特殊日），month（月） + } +} + +message CrossListRequest { + int32 nodeid = 1; +} + +message CrossListResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + string crossid = 1; + int32 type = 2; + string name = 3; + string location = 4; + repeated string src_dir = 5; + } +} + +message QueryCrossPhaseRelativeOffsetRequest { + repeated string crossids = 1; + int32 citycode = 2; + string tp = 3; + string day = 4; +} + +message QueryCrossPhaseRelativeOffsetResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + string crossid = 1; + int32 day = 2; //天 + int32 month = 3; //月 + int32 weekday = 4; //周 + int32 scheduleid = 5; + string tp_start = 6; + string control_mode = 7; + int32 planid = 8; + string plan_name = 9; + int32 cycle = 10; + int32 offset = 11; + int32 relative_offset = 12; + string type = 13; + int32 coord_phaseid = 14; + repeated stage_data stages = 15; + } + + message stage_data { + int32 stageid = 1; + string stage_name = 2; + int32 stage_duration = 3; + int32 green = 4; + int32 yellow = 5; + int32 allred = 6; + int32 redyellow = 7; + string phaseids = 8; + string phaseid_names = 9; + } +} + +message GreenWaveCrossPhaseTpCheckRequest { + string waveid = 1; + int32 citycode = 2; +} + +message GreenWaveCrossPhaseTpCheckResponse { + int32 code = 1; + string msg = 2; +} + +message CrossRunningPhaseRequest { + int32 citycode = 1; + repeated string crossids = 2; +} + +message CrossRunningPhaseResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + int32 citycode = 1; + string crossid = 2; + string jj_crossid = 3; + int32 scheduleid = 4; + string schedule_week = 5; + string schedule_name = 6; + repeated tps_list tps = 7; + } + message tps_list { + string tp_start = 1; + string tp_end = 2; + int32 planid = 3; + string plan_name = 4; + string control_mode = 5; + int32 cycle = 6; + int32 coord_phaseid = 7; + int32 offset = 8; + repeated stages stage_list = 9; + } + message stages { + int32 stageid = 1; + int32 stage_duration = 2; + string stage_name = 3; + int32 green = 4; + int32 yellow = 5; + int32 allred = 6; + string phases = 7; + string phases_name = 8; + int32 min_green = 9; + int32 max_green = 10; + } +} + +message CrossPhaseDiagnosisRequest { + int32 citycode = 1; + string crossid = 2; + repeated string date_list = 3; +} + +message CrossPhaseDiagnosisResponse { + int32 code = 1; + string msg = 2; + repeated List data = 3; + message List { + string item = 1; + repeated details detail_list = 2; + string suggestions = 3; + string reason = 4; + } + message details { + repeated item_detail detail = 1; + } + message item_detail { + string text = 1; + string crossid = 2; + int32 nodeid = 3; + string color = 5; + int32 scheduleid = 6; + string schedule_week = 7; + string schedule_name = 8; + int32 plan_id = 9; + string plan_name = 10; + } +} \ No newline at end of file diff --git a/proto/phase_server_pb2.py b/proto/phase_server_pb2.py new file mode 100644 index 0000000..6fdaa88 --- /dev/null +++ b/proto/phase_server_pb2.py @@ -0,0 +1,108 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE +# source: phase_server.proto +# Protobuf Python Version: 5.29.0 +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version +from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 29, + 0, + '', + 'phase_server.proto' +) +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12phase_server.proto\x12\x0cphase_server\"\x0e\n\x0c\x45mptyRequest\"\x9f\x01\n\x1b\x45xceptionPhaseCrossResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12<\n\x04\x64\x61ta\x18\x04 \x03(\x0b\x32..phase_server.ExceptionPhaseCrossResponse.List\x1a\'\n\x04List\x12\x0e\n\x06nodeid\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\"2\n\x1e\x45xceptionPhaseCrossInfoRequest\x12\x10\n\x08\x63itycode\x18\x01 \x03(\x05\"\xb3\x02\n\x1f\x45xceptionPhaseCrossInfoResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\r\n\x05total\x18\x03 \x01(\x05\x12\x13\n\x0b\x63ross_total\x18\x04 \x01(\x05\x12@\n\x04\x64\x61ta\x18\x05 \x03(\x0b\x32\x32.phase_server.ExceptionPhaseCrossInfoResponse.List\x1a\x8e\x01\n\x04List\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\x12\x12\n\nscheduleid\x18\x03 \x01(\x05\x12\x0e\n\x06planid\x18\x04 \x01(\x05\x12\x11\n\tplan_name\x18\x05 \x01(\t\x12\x10\n\x08tp_start\x18\x06 \x01(\t\x12\x0c\n\x04\x64\x61ys\x18\x07 \x01(\t\x12\x0c\n\x04type\x18\x08 \x01(\t\"D\n\x1f\x45xceptionPhaseByCrossIDsRequest\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x03(\t\"\xb3\x02\n ExceptionPhaseByCrossIDsResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\x41\n\x04\x64\x61ta\x18\x05 \x03(\x0b\x32\x33.phase_server.ExceptionPhaseByCrossIDsResponse.List\x1a\xb0\x01\n\x04List\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\x12\x12\n\ncross_name\x18\x03 \x01(\t\x12\x12\n\nscheduleid\x18\x04 \x01(\x05\x12\x0e\n\x06planid\x18\x05 \x01(\x05\x12\x11\n\tplan_name\x18\x06 \x01(\t\x12\x10\n\x08tp_start\x18\x07 \x01(\t\x12\x0c\n\x04\x64\x61te\x18\x08 \x01(\t\x12\x0c\n\x04week\x18\t \x01(\t\x12\x0c\n\x04type\x18\n \x01(\t\"\x9f\x01\n$GetCrossPhaseDetailByCrossIDsRequest\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x10\n\x08\x63rossids\x18\x02 \x03(\t\x12\x12\n\ngw_src_dir\x18\x03 \x01(\t\x12\x10\n\x08tp_start\x18\x04 \x01(\t\x12\x0e\n\x06tp_end\x18\x05 \x01(\t\x12\x0c\n\x04week\x18\x06 \x01(\t\x12\x0f\n\x07wave_id\x18\x07 \x01(\t\"\x9a\x03\n%GetCrossPhaseDetailByCrossIDsResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\r\n\x05\x63ycle\x18\x03 \x01(\x05\x12\x46\n\x04\x64\x61ta\x18\x04 \x03(\x0b\x32\x38.phase_server.GetCrossPhaseDetailByCrossIDsResponse.List\x1a\xfe\x01\n\x04List\x12\x0f\n\x07\x63rossid\x18\x01 \x01(\t\x12\x15\n\rgreen_forward\x18\x02 \x01(\x05\x12\x14\n\x0cgreen_revers\x18\x03 \x01(\x05\x12\x0e\n\x06offset\x18\x04 \x01(\x05\x12\x10\n\x08offset_r\x18\x05 \x01(\x05\x12\r\n\x05\x63ycle\x18\x06 \x01(\x05\x12\x0b\n\x03\x64\x61y\x18\x07 \x01(\x05\x12\r\n\x05month\x18\x08 \x01(\x05\x12\x0f\n\x07weekday\x18\t \x01(\x05\x12\x12\n\nscheduleid\x18\n \x01(\x05\x12\x0e\n\x06planid\x18\x0b \x01(\x05\x12\x11\n\tplan_name\x18\x0c \x01(\t\x12\x15\n\rcoord_phaseid\x18\r \x01(\x05\x12\x0c\n\x04type\x18\x0e \x01(\t\"\x99\x01\n\x17GetPhaseCrossIDResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\x38\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32*.phase_server.GetPhaseCrossIDResponse.List\x1a)\n\x04List\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\"\x91\x01\n\x16PhaseGreenRatioRequest\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x10\n\x08\x63rossids\x18\x02 \x03(\t\x12\x12\n\ngw_src_dir\x18\x03 \x01(\t\x12\x10\n\x08tp_start\x18\x04 \x01(\t\x12\x0e\n\x06tp_end\x18\x05 \x01(\t\x12\x0c\n\x04week\x18\x06 \x01(\t\x12\x0f\n\x07wave_id\x18\x07 \x01(\t\"\xce\x04\n\x17PhaseGreenRatioResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\x38\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32*.phase_server.PhaseGreenRatioResponse.List\x1a\xdd\x03\n\x04List\x12\x0f\n\x07\x63rossid\x18\x01 \x01(\t\x12\x0b\n\x03s2l\x18\x02 \x01(\x02\x12\x12\n\ns2l_remark\x18\x03 \x01(\t\x12\x13\n\x0bs2l_s_green\x18\x04 \x01(\x05\x12\x13\n\x0bs2l_l_green\x18\x05 \x01(\x05\x12\r\n\x05s2unl\x18\x06 \x01(\x02\x12\x14\n\x0cs2unl_remark\x18\x07 \x01(\t\x12\x15\n\rs2unl_s_green\x18\x08 \x01(\x05\x12\x17\n\x0fs2unl_unl_green\x18\t \x01(\x05\x12\r\n\x05s2uns\x18\n \x01(\x02\x12\x14\n\x0cs2uns_remark\x18\x0b \x01(\t\x12\x15\n\rs2uns_s_green\x18\x0c \x01(\x05\x12\x17\n\x0fs2uns_uns_green\x18\r \x01(\x05\x12\x0f\n\x07\x66wd2rev\x18\x0e \x01(\x02\x12\x16\n\x0e\x66wd2rev_remark\x18\x0f \x01(\t\x12\x19\n\x11\x66wd2rev_fwd_green\x18\x10 \x01(\x05\x12\x19\n\x11\x66wd2rev_rev_green\x18\x11 \x01(\x05\x12\x0e\n\x06planid\x18\x12 \x01(\x05\x12\x0b\n\x03\x64\x61y\x18\x13 \x01(\x05\x12\r\n\x05month\x18\x14 \x01(\x05\x12\x0f\n\x07weekday\x18\x15 \x01(\x05\x12\x12\n\nscheduleid\x18\x16 \x01(\x05\x12\x11\n\tplan_name\x18\x17 \x01(\t\x12\x0c\n\x04type\x18\x18 \x01(\t\"\"\n\x10\x43rossListRequest\x12\x0e\n\x06nodeid\x18\x01 \x01(\x05\"\xba\x01\n\x11\x43rossListResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\x32\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32$.phase_server.CrossListResponse.List\x1aV\n\x04List\x12\x0f\n\x07\x63rossid\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\x05\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08location\x18\x04 \x01(\t\x12\x0f\n\x07src_dir\x18\x05 \x03(\t\"c\n$QueryCrossPhaseRelativeOffsetRequest\x12\x10\n\x08\x63rossids\x18\x01 \x03(\t\x12\x10\n\x08\x63itycode\x18\x02 \x01(\x05\x12\n\n\x02tp\x18\x03 \x01(\t\x12\x0b\n\x03\x64\x61y\x18\x04 \x01(\t\"\x94\x05\n%QueryCrossPhaseRelativeOffsetResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\x46\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32\x38.phase_server.QueryCrossPhaseRelativeOffsetResponse.List\x1a\xd0\x02\n\x04List\x12\x0f\n\x07\x63rossid\x18\x01 \x01(\t\x12\x0b\n\x03\x64\x61y\x18\x02 \x01(\x05\x12\r\n\x05month\x18\x03 \x01(\x05\x12\x0f\n\x07weekday\x18\x04 \x01(\x05\x12\x12\n\nscheduleid\x18\x05 \x01(\x05\x12\x10\n\x08tp_start\x18\x06 \x01(\t\x12\x14\n\x0c\x63ontrol_mode\x18\x07 \x01(\t\x12\x0e\n\x06planid\x18\x08 \x01(\x05\x12\x11\n\tplan_name\x18\t \x01(\t\x12\r\n\x05\x63ycle\x18\n \x01(\x05\x12\x0e\n\x06offset\x18\x0b \x01(\x05\x12\x17\n\x0frelative_offset\x18\x0c \x01(\x05\x12\x0c\n\x04type\x18\r \x01(\t\x12\x15\n\rcoord_phaseid\x18\x0e \x01(\x05\x12N\n\x06stages\x18\x0f \x03(\x0b\x32>.phase_server.QueryCrossPhaseRelativeOffsetResponse.stage_data\x1a\xb4\x01\n\nstage_data\x12\x0f\n\x07stageid\x18\x01 \x01(\x05\x12\x12\n\nstage_name\x18\x02 \x01(\t\x12\x16\n\x0estage_duration\x18\x03 \x01(\x05\x12\r\n\x05green\x18\x04 \x01(\x05\x12\x0e\n\x06yellow\x18\x05 \x01(\x05\x12\x0e\n\x06\x61llred\x18\x06 \x01(\x05\x12\x11\n\tredyellow\x18\x07 \x01(\x05\x12\x10\n\x08phaseids\x18\x08 \x01(\t\x12\x15\n\rphaseid_names\x18\t \x01(\t\"E\n!GreenWaveCrossPhaseTpCheckRequest\x12\x0e\n\x06waveid\x18\x01 \x01(\t\x12\x10\n\x08\x63itycode\x18\x02 \x01(\x05\"?\n\"GreenWaveCrossPhaseTpCheckResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\">\n\x18\x43rossRunningPhaseRequest\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x10\n\x08\x63rossids\x18\x02 \x03(\t\"\xd7\x05\n\x19\x43rossRunningPhaseResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12:\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32,.phase_server.CrossRunningPhaseResponse.List\x1a\xbe\x01\n\x04List\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\x12\x12\n\njj_crossid\x18\x03 \x01(\t\x12\x12\n\nscheduleid\x18\x04 \x01(\x05\x12\x15\n\rschedule_week\x18\x05 \x01(\t\x12\x15\n\rschedule_name\x18\x06 \x01(\t\x12=\n\x03tps\x18\x07 \x03(\x0b\x32\x30.phase_server.CrossRunningPhaseResponse.tps_list\x1a\xdf\x01\n\x08tps_list\x12\x10\n\x08tp_start\x18\x01 \x01(\t\x12\x0e\n\x06tp_end\x18\x02 \x01(\t\x12\x0e\n\x06planid\x18\x03 \x01(\x05\x12\x11\n\tplan_name\x18\x04 \x01(\t\x12\x14\n\x0c\x63ontrol_mode\x18\x05 \x01(\t\x12\r\n\x05\x63ycle\x18\x06 \x01(\x05\x12\x15\n\rcoord_phaseid\x18\x07 \x01(\x05\x12\x0e\n\x06offset\x18\x08 \x01(\x05\x12\x42\n\nstage_list\x18\t \x03(\x0b\x32..phase_server.CrossRunningPhaseResponse.stages\x1a\xbf\x01\n\x06stages\x12\x0f\n\x07stageid\x18\x01 \x01(\x05\x12\x16\n\x0estage_duration\x18\x02 \x01(\x05\x12\x12\n\nstage_name\x18\x03 \x01(\t\x12\r\n\x05green\x18\x04 \x01(\x05\x12\x0e\n\x06yellow\x18\x05 \x01(\x05\x12\x0e\n\x06\x61llred\x18\x06 \x01(\x05\x12\x0e\n\x06phases\x18\x07 \x01(\t\x12\x13\n\x0bphases_name\x18\x08 \x01(\t\x12\x11\n\tmin_green\x18\t \x01(\x05\x12\x11\n\tmax_green\x18\n \x01(\x05\"R\n\x1a\x43rossPhaseDiagnosisRequest\x12\x10\n\x08\x63itycode\x18\x01 \x01(\x05\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\x12\x11\n\tdate_list\x18\x03 \x03(\t\"\x80\x04\n\x1b\x43rossPhaseDiagnosisResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12<\n\x04\x64\x61ta\x18\x03 \x03(\x0b\x32..phase_server.CrossPhaseDiagnosisResponse.List\x1a\x81\x01\n\x04List\x12\x0c\n\x04item\x18\x01 \x01(\t\x12\x46\n\x0b\x64\x65tail_list\x18\x02 \x03(\x0b\x32\x31.phase_server.CrossPhaseDiagnosisResponse.details\x12\x13\n\x0bsuggestions\x18\x03 \x01(\t\x12\x0e\n\x06reason\x18\x04 \x01(\t\x1aP\n\x07\x64\x65tails\x12\x45\n\x06\x64\x65tail\x18\x01 \x03(\x0b\x32\x35.phase_server.CrossPhaseDiagnosisResponse.item_detail\x1a\xb1\x01\n\x0bitem_detail\x12\x0c\n\x04text\x18\x01 \x01(\t\x12\x0f\n\x07\x63rossid\x18\x02 \x01(\t\x12\x0e\n\x06nodeid\x18\x03 \x01(\x05\x12\r\n\x05\x63olor\x18\x05 \x01(\t\x12\x12\n\nscheduleid\x18\x06 \x01(\x05\x12\x15\n\rschedule_week\x18\x07 \x01(\t\x12\x15\n\rschedule_name\x18\x08 \x01(\t\x12\x0f\n\x07plan_id\x18\t \x01(\x05\x12\x11\n\tplan_name\x18\n \x01(\t2\xcc\t\n\x0cPhaseService\x12\\\n\x13\x45xceptionPhaseCross\x12\x1a.phase_server.EmptyRequest\x1a).phase_server.ExceptionPhaseCrossResponse\x12v\n\x17\x45xceptionPhaseCrossInfo\x12,.phase_server.ExceptionPhaseCrossInfoRequest\x1a-.phase_server.ExceptionPhaseCrossInfoResponse\x12y\n\x18\x45xceptionPhaseByCrossIDs\x12-.phase_server.ExceptionPhaseByCrossIDsRequest\x1a..phase_server.ExceptionPhaseByCrossIDsResponse\x12\x88\x01\n\x1dGetCrossPhaseDetailByCrossIDs\x12\x32.phase_server.GetCrossPhaseDetailByCrossIDsRequest\x1a\x33.phase_server.GetCrossPhaseDetailByCrossIDsResponse\x12T\n\x0fGetPhaseCrossID\x12\x1a.phase_server.EmptyRequest\x1a%.phase_server.GetPhaseCrossIDResponse\x12^\n\x0fPhaseGreenRatio\x12$.phase_server.PhaseGreenRatioRequest\x1a%.phase_server.PhaseGreenRatioResponse\x12L\n\tCrossList\x12\x1e.phase_server.CrossListRequest\x1a\x1f.phase_server.CrossListResponse\x12\x88\x01\n\x1dQueryCrossPhaseRelativeOffset\x12\x32.phase_server.QueryCrossPhaseRelativeOffsetRequest\x1a\x33.phase_server.QueryCrossPhaseRelativeOffsetResponse\x12\x7f\n\x1aGreenWaveCrossPhaseTpCheck\x12/.phase_server.GreenWaveCrossPhaseTpCheckRequest\x1a\x30.phase_server.GreenWaveCrossPhaseTpCheckResponse\x12\x64\n\x11\x43rossRunningPhase\x12&.phase_server.CrossRunningPhaseRequest\x1a\'.phase_server.CrossRunningPhaseResponse\x12j\n\x13\x43rossPhaseDiagnosis\x12(.phase_server.CrossPhaseDiagnosisRequest\x1a).phase_server.CrossPhaseDiagnosisResponseb\x06proto3') + +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'phase_server_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + DESCRIPTOR._loaded_options = None + _globals['_EMPTYREQUEST']._serialized_start=36 + _globals['_EMPTYREQUEST']._serialized_end=50 + _globals['_EXCEPTIONPHASECROSSRESPONSE']._serialized_start=53 + _globals['_EXCEPTIONPHASECROSSRESPONSE']._serialized_end=212 + _globals['_EXCEPTIONPHASECROSSRESPONSE_LIST']._serialized_start=173 + _globals['_EXCEPTIONPHASECROSSRESPONSE_LIST']._serialized_end=212 + _globals['_EXCEPTIONPHASECROSSINFOREQUEST']._serialized_start=214 + _globals['_EXCEPTIONPHASECROSSINFOREQUEST']._serialized_end=264 + _globals['_EXCEPTIONPHASECROSSINFORESPONSE']._serialized_start=267 + _globals['_EXCEPTIONPHASECROSSINFORESPONSE']._serialized_end=574 + _globals['_EXCEPTIONPHASECROSSINFORESPONSE_LIST']._serialized_start=432 + _globals['_EXCEPTIONPHASECROSSINFORESPONSE_LIST']._serialized_end=574 + _globals['_EXCEPTIONPHASEBYCROSSIDSREQUEST']._serialized_start=576 + _globals['_EXCEPTIONPHASEBYCROSSIDSREQUEST']._serialized_end=644 + _globals['_EXCEPTIONPHASEBYCROSSIDSRESPONSE']._serialized_start=647 + _globals['_EXCEPTIONPHASEBYCROSSIDSRESPONSE']._serialized_end=954 + _globals['_EXCEPTIONPHASEBYCROSSIDSRESPONSE_LIST']._serialized_start=778 + _globals['_EXCEPTIONPHASEBYCROSSIDSRESPONSE_LIST']._serialized_end=954 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSREQUEST']._serialized_start=957 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSREQUEST']._serialized_end=1116 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSRESPONSE']._serialized_start=1119 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSRESPONSE']._serialized_end=1529 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSRESPONSE_LIST']._serialized_start=1275 + _globals['_GETCROSSPHASEDETAILBYCROSSIDSRESPONSE_LIST']._serialized_end=1529 + _globals['_GETPHASECROSSIDRESPONSE']._serialized_start=1532 + _globals['_GETPHASECROSSIDRESPONSE']._serialized_end=1685 + _globals['_GETPHASECROSSIDRESPONSE_LIST']._serialized_start=432 + _globals['_GETPHASECROSSIDRESPONSE_LIST']._serialized_end=473 + _globals['_PHASEGREENRATIOREQUEST']._serialized_start=1688 + _globals['_PHASEGREENRATIOREQUEST']._serialized_end=1833 + _globals['_PHASEGREENRATIORESPONSE']._serialized_start=1836 + _globals['_PHASEGREENRATIORESPONSE']._serialized_end=2426 + _globals['_PHASEGREENRATIORESPONSE_LIST']._serialized_start=1949 + _globals['_PHASEGREENRATIORESPONSE_LIST']._serialized_end=2426 + _globals['_CROSSLISTREQUEST']._serialized_start=2428 + _globals['_CROSSLISTREQUEST']._serialized_end=2462 + _globals['_CROSSLISTRESPONSE']._serialized_start=2465 + _globals['_CROSSLISTRESPONSE']._serialized_end=2651 + _globals['_CROSSLISTRESPONSE_LIST']._serialized_start=2565 + _globals['_CROSSLISTRESPONSE_LIST']._serialized_end=2651 + _globals['_QUERYCROSSPHASERELATIVEOFFSETREQUEST']._serialized_start=2653 + _globals['_QUERYCROSSPHASERELATIVEOFFSETREQUEST']._serialized_end=2752 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE']._serialized_start=2755 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE']._serialized_end=3415 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE_LIST']._serialized_start=2896 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE_LIST']._serialized_end=3232 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE_STAGE_DATA']._serialized_start=3235 + _globals['_QUERYCROSSPHASERELATIVEOFFSETRESPONSE_STAGE_DATA']._serialized_end=3415 + _globals['_GREENWAVECROSSPHASETPCHECKREQUEST']._serialized_start=3417 + _globals['_GREENWAVECROSSPHASETPCHECKREQUEST']._serialized_end=3486 + _globals['_GREENWAVECROSSPHASETPCHECKRESPONSE']._serialized_start=3488 + _globals['_GREENWAVECROSSPHASETPCHECKRESPONSE']._serialized_end=3551 + _globals['_CROSSRUNNINGPHASEREQUEST']._serialized_start=3553 + _globals['_CROSSRUNNINGPHASEREQUEST']._serialized_end=3615 + _globals['_CROSSRUNNINGPHASERESPONSE']._serialized_start=3618 + _globals['_CROSSRUNNINGPHASERESPONSE']._serialized_end=4345 + _globals['_CROSSRUNNINGPHASERESPONSE_LIST']._serialized_start=3735 + _globals['_CROSSRUNNINGPHASERESPONSE_LIST']._serialized_end=3925 + _globals['_CROSSRUNNINGPHASERESPONSE_TPS_LIST']._serialized_start=3928 + _globals['_CROSSRUNNINGPHASERESPONSE_TPS_LIST']._serialized_end=4151 + _globals['_CROSSRUNNINGPHASERESPONSE_STAGES']._serialized_start=4154 + _globals['_CROSSRUNNINGPHASERESPONSE_STAGES']._serialized_end=4345 + _globals['_CROSSPHASEDIAGNOSISREQUEST']._serialized_start=4347 + _globals['_CROSSPHASEDIAGNOSISREQUEST']._serialized_end=4429 + _globals['_CROSSPHASEDIAGNOSISRESPONSE']._serialized_start=4432 + _globals['_CROSSPHASEDIAGNOSISRESPONSE']._serialized_end=4944 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_LIST']._serialized_start=4553 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_LIST']._serialized_end=4682 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_DETAILS']._serialized_start=4684 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_DETAILS']._serialized_end=4764 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_ITEM_DETAIL']._serialized_start=4767 + _globals['_CROSSPHASEDIAGNOSISRESPONSE_ITEM_DETAIL']._serialized_end=4944 + _globals['_PHASESERVICE']._serialized_start=4947 + _globals['_PHASESERVICE']._serialized_end=6175 +# @@protoc_insertion_point(module_scope) diff --git a/proto/phase_server_pb2_grpc.py b/proto/phase_server_pb2_grpc.py new file mode 100644 index 0000000..6f99f1a --- /dev/null +++ b/proto/phase_server_pb2_grpc.py @@ -0,0 +1,538 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc +import warnings + +import phase_server_pb2 as phase__server__pb2 + +GRPC_GENERATED_VERSION = '1.71.0' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in phase_server_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) + + +class PhaseServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.ExceptionPhaseCross = channel.unary_unary( + '/phase_server.PhaseService/ExceptionPhaseCross', + request_serializer=phase__server__pb2.EmptyRequest.SerializeToString, + response_deserializer=phase__server__pb2.ExceptionPhaseCrossResponse.FromString, + _registered_method=True) + self.ExceptionPhaseCrossInfo = channel.unary_unary( + '/phase_server.PhaseService/ExceptionPhaseCrossInfo', + request_serializer=phase__server__pb2.ExceptionPhaseCrossInfoRequest.SerializeToString, + response_deserializer=phase__server__pb2.ExceptionPhaseCrossInfoResponse.FromString, + _registered_method=True) + self.ExceptionPhaseByCrossIDs = channel.unary_unary( + '/phase_server.PhaseService/ExceptionPhaseByCrossIDs', + request_serializer=phase__server__pb2.ExceptionPhaseByCrossIDsRequest.SerializeToString, + response_deserializer=phase__server__pb2.ExceptionPhaseByCrossIDsResponse.FromString, + _registered_method=True) + self.GetCrossPhaseDetailByCrossIDs = channel.unary_unary( + '/phase_server.PhaseService/GetCrossPhaseDetailByCrossIDs', + request_serializer=phase__server__pb2.GetCrossPhaseDetailByCrossIDsRequest.SerializeToString, + response_deserializer=phase__server__pb2.GetCrossPhaseDetailByCrossIDsResponse.FromString, + _registered_method=True) + self.GetPhaseCrossID = channel.unary_unary( + '/phase_server.PhaseService/GetPhaseCrossID', + request_serializer=phase__server__pb2.EmptyRequest.SerializeToString, + response_deserializer=phase__server__pb2.GetPhaseCrossIDResponse.FromString, + _registered_method=True) + self.PhaseGreenRatio = channel.unary_unary( + '/phase_server.PhaseService/PhaseGreenRatio', + request_serializer=phase__server__pb2.PhaseGreenRatioRequest.SerializeToString, + response_deserializer=phase__server__pb2.PhaseGreenRatioResponse.FromString, + _registered_method=True) + self.CrossList = channel.unary_unary( + '/phase_server.PhaseService/CrossList', + request_serializer=phase__server__pb2.CrossListRequest.SerializeToString, + response_deserializer=phase__server__pb2.CrossListResponse.FromString, + _registered_method=True) + self.QueryCrossPhaseRelativeOffset = channel.unary_unary( + '/phase_server.PhaseService/QueryCrossPhaseRelativeOffset', + request_serializer=phase__server__pb2.QueryCrossPhaseRelativeOffsetRequest.SerializeToString, + response_deserializer=phase__server__pb2.QueryCrossPhaseRelativeOffsetResponse.FromString, + _registered_method=True) + self.GreenWaveCrossPhaseTpCheck = channel.unary_unary( + '/phase_server.PhaseService/GreenWaveCrossPhaseTpCheck', + request_serializer=phase__server__pb2.GreenWaveCrossPhaseTpCheckRequest.SerializeToString, + response_deserializer=phase__server__pb2.GreenWaveCrossPhaseTpCheckResponse.FromString, + _registered_method=True) + self.CrossRunningPhase = channel.unary_unary( + '/phase_server.PhaseService/CrossRunningPhase', + request_serializer=phase__server__pb2.CrossRunningPhaseRequest.SerializeToString, + response_deserializer=phase__server__pb2.CrossRunningPhaseResponse.FromString, + _registered_method=True) + self.CrossPhaseDiagnosis = channel.unary_unary( + '/phase_server.PhaseService/CrossPhaseDiagnosis', + request_serializer=phase__server__pb2.CrossPhaseDiagnosisRequest.SerializeToString, + response_deserializer=phase__server__pb2.CrossPhaseDiagnosisResponse.FromString, + _registered_method=True) + + +class PhaseServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def ExceptionPhaseCross(self, request, context): + """获取异常路口 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def ExceptionPhaseCrossInfo(self, request, context): + """异常路口详情列表 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def ExceptionPhaseByCrossIDs(self, request, context): + """根据路口ID返回异常配时 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def GetCrossPhaseDetailByCrossIDs(self, request, context): + """根据路口ID返回路口配时方案详情 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def GetPhaseCrossID(self, request, context): + """获取有配时方案路口列表 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def PhaseGreenRatio(self, request, context): + """获取配时方案协调/非协调方向绿灯时长比 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def CrossList(self, request, context): + """获取配时方案协调/非协调方向绿灯时长比 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def QueryCrossPhaseRelativeOffset(self, request, context): + """依据日期，时刻查询多路口配时方案与相对相位差 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def GreenWaveCrossPhaseTpCheck(self, request, context): + """单条绿波配时方案时段与路口配时方案时段校验 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def CrossRunningPhase(self, request, context): + """路口运行中的配时方案 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def CrossPhaseDiagnosis(self, request, context): + """路口配时方案诊断列表 + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_PhaseServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'ExceptionPhaseCross': grpc.unary_unary_rpc_method_handler( + servicer.ExceptionPhaseCross, + request_deserializer=phase__server__pb2.EmptyRequest.FromString, + response_serializer=phase__server__pb2.ExceptionPhaseCrossResponse.SerializeToString, + ), + 'ExceptionPhaseCrossInfo': grpc.unary_unary_rpc_method_handler( + servicer.ExceptionPhaseCrossInfo, + request_deserializer=phase__server__pb2.ExceptionPhaseCrossInfoRequest.FromString, + response_serializer=phase__server__pb2.ExceptionPhaseCrossInfoResponse.SerializeToString, + ), + 'ExceptionPhaseByCrossIDs': grpc.unary_unary_rpc_method_handler( + servicer.ExceptionPhaseByCrossIDs, + request_deserializer=phase__server__pb2.ExceptionPhaseByCrossIDsRequest.FromString, + response_serializer=phase__server__pb2.ExceptionPhaseByCrossIDsResponse.SerializeToString, + ), + 'GetCrossPhaseDetailByCrossIDs': grpc.unary_unary_rpc_method_handler( + servicer.GetCrossPhaseDetailByCrossIDs, + request_deserializer=phase__server__pb2.GetCrossPhaseDetailByCrossIDsRequest.FromString, + response_serializer=phase__server__pb2.GetCrossPhaseDetailByCrossIDsResponse.SerializeToString, + ), + 'GetPhaseCrossID': grpc.unary_unary_rpc_method_handler( + servicer.GetPhaseCrossID, + request_deserializer=phase__server__pb2.EmptyRequest.FromString, + response_serializer=phase__server__pb2.GetPhaseCrossIDResponse.SerializeToString, + ), + 'PhaseGreenRatio': grpc.unary_unary_rpc_method_handler( + servicer.PhaseGreenRatio, + request_deserializer=phase__server__pb2.PhaseGreenRatioRequest.FromString, + response_serializer=phase__server__pb2.PhaseGreenRatioResponse.SerializeToString, + ), + 'CrossList': grpc.unary_unary_rpc_method_handler( + servicer.CrossList, + request_deserializer=phase__server__pb2.CrossListRequest.FromString, + response_serializer=phase__server__pb2.CrossListResponse.SerializeToString, + ), + 'QueryCrossPhaseRelativeOffset': grpc.unary_unary_rpc_method_handler( + servicer.QueryCrossPhaseRelativeOffset, + request_deserializer=phase__server__pb2.QueryCrossPhaseRelativeOffsetRequest.FromString, + response_serializer=phase__server__pb2.QueryCrossPhaseRelativeOffsetResponse.SerializeToString, + ), + 'GreenWaveCrossPhaseTpCheck': grpc.unary_unary_rpc_method_handler( + servicer.GreenWaveCrossPhaseTpCheck, + request_deserializer=phase__server__pb2.GreenWaveCrossPhaseTpCheckRequest.FromString, + response_serializer=phase__server__pb2.GreenWaveCrossPhaseTpCheckResponse.SerializeToString, + ), + 'CrossRunningPhase': grpc.unary_unary_rpc_method_handler( + servicer.CrossRunningPhase, + request_deserializer=phase__server__pb2.CrossRunningPhaseRequest.FromString, + response_serializer=phase__server__pb2.CrossRunningPhaseResponse.SerializeToString, + ), + 'CrossPhaseDiagnosis': grpc.unary_unary_rpc_method_handler( + servicer.CrossPhaseDiagnosis, + request_deserializer=phase__server__pb2.CrossPhaseDiagnosisRequest.FromString, + response_serializer=phase__server__pb2.CrossPhaseDiagnosisResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'phase_server.PhaseService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('phase_server.PhaseService', rpc_method_handlers) + + + # This class is part of an EXPERIMENTAL API. +class PhaseService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def ExceptionPhaseCross(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/ExceptionPhaseCross', + phase__server__pb2.EmptyRequest.SerializeToString, + phase__server__pb2.ExceptionPhaseCrossResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def ExceptionPhaseCrossInfo(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/ExceptionPhaseCrossInfo', + phase__server__pb2.ExceptionPhaseCrossInfoRequest.SerializeToString, + phase__server__pb2.ExceptionPhaseCrossInfoResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def ExceptionPhaseByCrossIDs(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/ExceptionPhaseByCrossIDs', + phase__server__pb2.ExceptionPhaseByCrossIDsRequest.SerializeToString, + phase__server__pb2.ExceptionPhaseByCrossIDsResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def GetCrossPhaseDetailByCrossIDs(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/GetCrossPhaseDetailByCrossIDs', + phase__server__pb2.GetCrossPhaseDetailByCrossIDsRequest.SerializeToString, + phase__server__pb2.GetCrossPhaseDetailByCrossIDsResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def GetPhaseCrossID(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/GetPhaseCrossID', + phase__server__pb2.EmptyRequest.SerializeToString, + phase__server__pb2.GetPhaseCrossIDResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def PhaseGreenRatio(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/PhaseGreenRatio', + phase__server__pb2.PhaseGreenRatioRequest.SerializeToString, + phase__server__pb2.PhaseGreenRatioResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def CrossList(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/CrossList', + phase__server__pb2.CrossListRequest.SerializeToString, + phase__server__pb2.CrossListResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def QueryCrossPhaseRelativeOffset(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/QueryCrossPhaseRelativeOffset', + phase__server__pb2.QueryCrossPhaseRelativeOffsetRequest.SerializeToString, + phase__server__pb2.QueryCrossPhaseRelativeOffsetResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def GreenWaveCrossPhaseTpCheck(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/GreenWaveCrossPhaseTpCheck', + phase__server__pb2.GreenWaveCrossPhaseTpCheckRequest.SerializeToString, + phase__server__pb2.GreenWaveCrossPhaseTpCheckResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def CrossRunningPhase(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/CrossRunningPhase', + phase__server__pb2.CrossRunningPhaseRequest.SerializeToString, + phase__server__pb2.CrossRunningPhaseResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def CrossPhaseDiagnosis(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/phase_server.PhaseService/CrossPhaseDiagnosis', + phase__server__pb2.CrossPhaseDiagnosisRequest.SerializeToString, + phase__server__pb2.CrossPhaseDiagnosisResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True)