服务角色职能
| 角色 | 车道代理 | 车道监控 | 浏览器 |
|---|---|---|---|
| 作业 | 接收或修改服务缓存 | 修改发送至指定车道 | <= |
| 车道 | 接收或修改服务缓存 | 修改发送至指定车道 | <= |
| 指令 | 接收 | 发送至指定车道 | <= |
| 车道列表缓存 | / | 接收 | <= |
流程逻辑
Paste_Image.png
车道代理接入
接收部分
监听获取lane
hub.On("reciveLane",data)
data数据格式
#js
data:
{
lane_code:string,
send_time:string,
lane:object
}
#csharp
public class Pf_Message_lane_Object
{
public string lane_code { get; set; }
public string send_time { get; set; }
public object lane { get; set; }
}
监听获取directive
hub.On("reciveDirective",data)
data数据格式
#js
data
{
directive_id:string,
lane_code:string,
lane_name:string,
directive_code:string,
parameters : string [],
send_time: string
}
#csharp
public class pf_Message_Directive
{
public string directive_id { get; set; }
public string lane_code { get; set; }
public string lane_name { get; set; }
public string directive_code { get; set; }
public string[] parameters { get; set; }
public string send_time { get; set; }
}
监听获取queue
hub.On("reciveQueue",data)
data数据格式
#js
data
{
lane_code:string,
lane_name:string,
action: string ,
create_time: string,
send_time : string,
queue: object
}
#csharp
public class Pf_Messge_Queue_Object
{
public string lane_code { get; set; }
public string queue_id { get; set; }
public string action { get; set; }
public string create_time { get; set; }
public string send_time { get; set; }
public object queue { get; set; }
}
发送部分
修改消息服务中的缓存
hub.Invoke("Change",lane_code,message)
message数据格式
#js
message
{
message_type:string
message_content: object
}
#csharp
public class Pf_Message_Obj<T> where T :new()
{
/// <summary>
/// 消息类型 指令或状态或作业
/// </summary>
public string message_type { get; set; }
/// <summary>
/// 消息内容
/// </summary>
public object message_content { get; set; }
public Pf_Message_Obj(string type, T content)
{
message_type = type;
message_content = content;
}
}
车道监控接入
接收部分
获取车道缓存列表
Csharp
Hub.On("GetLaneList",data)
JS
proxy.client.GetLaneList=function(data){ //处理data }
#js
data:[
object,
object,
object
]
#cahsrp
List<Lane> lanes = new List<Lane>()
public class Lane
{
public string lane_code { get; set; }
public string lane_name { get; set; }
public string country_code { get; set; }
public string city_code { get; set; }
public string terminal_code { get; set; }
public string direction { get; set; }
public bool has_truck { get; set; }
public string lane_type { get; set; }
public string led_display { get; set; }
public string barrier { get; set; }
public string update_time { get; set; }
}
获取会话列表
Csharp
hub.On("GetSessionList",data)
JS
proxy.client.GetSessionList=function(data){//处理data}
数据定义
#js
data
[
{
ConnectionID:string,
IPAddress:string,
Port:string,
ClientType:string,
ClientName:string,
ConnectionTime:string
},
{
ConnectionID:string,
IPAddress:string,
Port:string,
ClientType:string,
ClientName:string,
ConnectionTime:string
},
{
ConnectionID:string,
IPAddress:string,
Port:string,
ClientType:string,
ClientName:string,
ConnectionTime:string
},
]
#csharp
public class SessionObj
{
/// <summary>
/// 连接ID
/// </summary>
public string ConnectionID { get; set; }
/// <summary>
/// IP地址
/// </summary>
public string IPAddress { get; set; }
/// <summary>
/// 端口
/// </summary>
public string Port { get; set; }
/// <summary>
/// 会话对象类型
/// </summary>
public string ClientType { get; set; }
/// <summary>
/// 会话对象
/// </summary>
public string ClientName { get; set; }
/// <summary>
/// 首次连接时间。
/// </summary>
public string ConnectionTime { get; set; }
}
获取作业列表
Csharp
hub.on("GetQueueList",data)
JS
proxy.client.GetQueueList=function(data){//data}
数据定义
#js
data
[
{
lane_code:string,
lane_name:string,
queue_id:string,
is_lock:bool,
lock_time:string,
user:string,
start_time:string,
end_time:string,
truck_no:string,
ocr_truck_no:string,
rfid_card_no:string,
total_weight:string,
ic_card_no:string,
container_amount:int,
damage_check_amount:int,
damage_part_amount:int,
submit_amount:int,
truck_pic_url:string,
truck_crop_pic_url :string,
front_top_pic_url :string,
back_top_pic_url:string,
left_front_pic_url:string,
left_back_pic_url :string,
right_front_pic_url:string,
right_back_pic_url :string,
left_damage_pic_url:string,
right_damage_pic_url :string,
top_damage_pic_url :string,
processes:object[],
containers :object[],
update_time:string
},
{
lane_code:string,
lane_name:string,
queue_id:string,
is_lock:bool,
lock_time:string,
user:string,
start_time:string,
end_time:string,
truck_no:string,
ocr_truck_no:string,
rfid_card_no:string,
total_weight:string,
ic_card_no:string,
container_amount:int,
damage_check_amount:int,
damage_part_amount:int,
submit_amount:int,
truck_pic_url:string,
truck_crop_pic_url :string,
front_top_pic_url :string,
back_top_pic_url:string,
left_front_pic_url:string,
left_back_pic_url :string,
right_front_pic_url:string,
right_back_pic_url :string,
left_damage_pic_url:string,
right_damage_pic_url :string,
top_damage_pic_url :string,
processes:object[],
containers :object[],
update_time:string
}
................
]
#csharp
List<Queue> queues = new List<Queue>();
public class Queue
{
public string lane_code { get; set; }
public string lane_name { get; set; }
public string queue_id { get; set; }
public bool is_lock { get; set; }
public string lock_time { get; set; }
public string user { get; set; }
public string start_time { get; set; }
public string end_time { get; set; }
public string truck_no { get; set; }
public string orc_truck_no { get; set; }
public string rfid_truck_no { get; set; }
public string total_weight { get; set; }
public string ic_card_no { get; set; }
public int container_amount { get; set; }
public int damage_check_amount { get; set; }
public int damage_part_amount { get; set; }
public int submit_amount { get; set; }
public string truck_pic_url { get; set; }
public string truck_crop_pic_url { get; set; }
public string front_top_pic_url { get; set; }
public string back_top_pic_url { get; set; }
public string left_front_pic_url { get; set; }
public string left_back_pic_url { get; set; }
public string right_front_pic_url { get; set; }
public string right_back_pic_url { get; set; }
public string left_damage_pic_url { get; set; }
public string right_damage_pic_url { get; set; }
public string top_damage_pic_url { get; set; }
public Queue_Progress[] processes { get; set; }
public Queue_Container[] containers { get; set; }
public string update_time { get; set; }
}
发送部分
Csharp
hub.Invoke("SendMessage",lane_code,message)
JS
hub.server.SendMessage(lane_code,message)
数据定义
#js
message
{
message_type:string,
message_content:object
}
#补充：message_content 的三种类型
public class Pf_Message_lane_Object
{
public string lane_code { get; set; }
public string send_time { get; set; }
public object lane { get; set; }
}
public class Pf_Messge_Queue_Object
{
public string lane_code { get; set; }
public string queue_id { get; set; }
public string action { get; set; }
public string create_time { get; set; }
public string send_time { get; set; }
public object queue { get; set; }
}
public class pf_Message_Directive
{
public string directive_id { get; set; }
public string lane_code { get; set; }
public string lane_name { get; set; }
public string directive_code { get; set; }
public string[] parameters { get; set; }
public string send_time { get; set; }
}
#csharp
public class Pf_Message_Obj<T> where T :new()
{
/// <summary>
/// 消息类型 指令或状态或作业
/// </summary>
public string message_type { get; set; }
/// <summary>
/// 消息内容
/// </summary>
public object message_content { get; set; }
public Pf_Message_Obj(string type, T content)
{
message_type = type;
message_content = content;
}
}
