xuwang
/
cross_doctor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加台账任务路口列表保存更新配时方案状态方法 

Signed-off-by: yinzijian <yinzijian@haomozhixing.onaliyun.com>
This commit is contained in:
yinzijian 2026-03-04 14:45:42 +08:00
parent 4dda6700ed
commit 432db750fa
4 changed files with 81 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
proto/phase_grpc.py
View File

@ -238,3 +238,21 @@ def GetCrossPhaseDiagnosis(citycode: int, area_id: int, schedule_week: str, tp:
return None, e
finally:
channel.close()
def LedgerTaskDetailPhaseState(citycode: int, crossids: List[str]):
"""
路口台账更新台账任务路口中配时方案状态
citycode = 130200
crossids = ['crossid1','crossid2']
"""
stub, channel = channel_stub()
try:
request_params = phase_server_pb2.LedgerTaskDetailPhaseStateUpdateRequest(citycode=citycode,crossids=crossids)
response = stub.LedgerTaskDetailPhaseStateUpdate(request_params, timeout=30)
if response.code != 0:
raise Exception(response.msg)
return response, None
except Exception as e:
return None, e
finally:
channel.close()

12
proto/phase_server.proto
View File

@ -32,6 +32,8 @@ service PhaseService {
rpc UpdateCrossPhaseDiagnosis (UpdateCrossPhaseDiagnosisRequest) returns (UpdateCrossPhaseDiagnosisResponse);
//根据城市查询所有路口配时方案诊断数据
rpc CrossPhaseDiagnosisByCity (CrossPhaseDiagnosisByCityRequest) returns (CrossPhaseDiagnosisByCityResponse);
//更新台账任务中相关路口列表配时方案状态
rpc LedgerTaskDetailPhaseStateUpdate (LedgerTaskDetailPhaseStateUpdateRequest) returns (LedgerTaskDetailPhaseStateUpdateResponse);
}
message EmptyRequest {}
@ -416,3 +418,13 @@ message CrossPhaseDiagnosisByCityResponse {
}
}
message LedgerTaskDetailPhaseStateUpdateRequest {
int32 citycode = 1;
repeated string crossids = 2;
}
message LedgerTaskDetailPhaseStateUpdateResponse {
int32 code = 1;
string msg = 2;
}

10
proto/phase_server_pb2.py
View File

File diff suppressed because one or more lines are too long

44
proto/phase_server_pb2_grpc.py
View File

@ -109,6 +109,11 @@ class PhaseServiceStub(object):
request_serializer=phase__server__pb2.CrossPhaseDiagnosisByCityRequest.SerializeToString,
response_deserializer=phase__server__pb2.CrossPhaseDiagnosisByCityResponse.FromString,
_registered_method=True)
self.LedgerTaskDetailPhaseStateUpdate = channel.unary_unary(
'/phase_server.PhaseService/LedgerTaskDetailPhaseStateUpdate',
request_serializer=phase__server__pb2.LedgerTaskDetailPhaseStateUpdateRequest.SerializeToString,
response_deserializer=phase__server__pb2.LedgerTaskDetailPhaseStateUpdateResponse.FromString,
_registered_method=True)
class PhaseServiceServicer(object):
@ -219,6 +224,13 @@ class PhaseServiceServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def LedgerTaskDetailPhaseStateUpdate(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 = {
@ -297,6 +309,11 @@ def add_PhaseServiceServicer_to_server(servicer, server):
request_deserializer=phase__server__pb2.CrossPhaseDiagnosisByCityRequest.FromString,
response_serializer=phase__server__pb2.CrossPhaseDiagnosisByCityResponse.SerializeToString,
),
'LedgerTaskDetailPhaseStateUpdate': grpc.unary_unary_rpc_method_handler(
servicer.LedgerTaskDetailPhaseStateUpdate,
request_deserializer=phase__server__pb2.LedgerTaskDetailPhaseStateUpdateRequest.FromString,
response_serializer=phase__server__pb2.LedgerTaskDetailPhaseStateUpdateResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'phase_server.PhaseService', rpc_method_handlers)
@ -712,3 +729,30 @@ class PhaseService(object):
timeout,
metadata,
_registered_method=True)
@staticmethod
def LedgerTaskDetailPhaseStateUpdate(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/LedgerTaskDetailPhaseStateUpdate',
phase__server__pb2.LedgerTaskDetailPhaseStateUpdateRequest.SerializeToString,
phase__server__pb2.LedgerTaskDetailPhaseStateUpdateResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)