清除下线车辆

data/dispatchInfo.py

@@ -224,6 +224,12 @@ class DispatchInfo:
                 # add truck
                 truck_state = session_mysql.query(Equipment).filter_by(id=item.truck_id).first()
                 # if truck_state is not None and truck_state.disabled == 1:
+                truck_uuid_to_name_dict = get_value("truck_uuid_to_name_dict")
+                truck_name = truck_uuid_to_name_dict[item.truck_id]
+                key_value_dict = redis2.hgetall(truck_name)
+                is_online = key_value_dict[str_to_byte('online')]
+                if bytes.decode(is_online) not in ["true" or "True"]:
+                    continue
                 if item.group_id not in cls.group_truck_dict.keys():
                     cls.group_truck_dict[item.group_id] = [item.truck_id]
                 else:

equipment/truck.py

@@ -369,6 +369,10 @@ class TruckInfo(WalkManage):
                 session_mysql.commit()
                 truck_id = self.truck_index_to_uuid_dict[i]
                 truck_name = truck_uuid_to_name_dict[truck_id]
+                key_value_dict = redis2.hgetall(truck_name)
+                is_online = key_value_dict[str_to_byte('online')]
+                if bytes.decode(is_online) not in ["true" or "True"]:
+                    continue
                 task = self.truck_current_task[self.truck_index_to_uuid_dict[i]]
 
                 item = (