import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
private Device getNewDevice() {
  DeviceProfile profile = getDeviceProfile();
  if (profile != null) {
    DeviceService service = getDeviceService();
    if (service != null) {
      Addressable addressable = getAddressable();
      if (addressable != null) {
        return getDevice(profile, service, addressable);
      } else {
        logger.error("Cannot create default Mqtt device without an addressable");
      }
    } else {
      logger.error("Cannot create default Mqtt device without the device service");
    }
  } else {
    logger.error("Cannot create default Mqtt device without a profile");
  }
  return null;
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
public void setService(DeviceService srv) {
	service = srv;
	service.setAddressable(srv.getAddressable());
	service.setLabels(srv.getLabels());
	setHost(srv.getAddressable().getAddress());
	setPort(srv.getAddressable().getPort());
	setCallbackUrl(srv.getAddressable().getPath());
	setServiceName(srv.getName());
	setLabels(srv.getLabels());
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
public boolean isServiceLocked(){
	DeviceService srv = getService();
	if (srv == null) {
	  return true;
	}
	return srv.getAdminState().equals(AdminState.LOCKED);
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
@Async
public void updateDeviceServiceLastReportedConnected(String deviceid) {
  if (!updateServiceLastReported) {
    logger.debug("Skipping update of device service connected/reported times for:  " + deviceid);
    return;
  }
  try {
    Device device = deviceClient.deviceForName(deviceid);
    if (device == null) {
      device = deviceClient.device(deviceid);
    }
    if (device != null) {
      Calendar calendar = Calendar.getInstance();
      long time = calendar.getTimeInMillis();
      DeviceService service = device.getService();
      if (service != null) {
        serviceClient.updateLastConnected(service.getId(), time);
        serviceClient.updateLastReported(service.getId(), time);
      } else
        logger.error(
            "Error updating device service connected/reported times.  Unknown device service in device:  "
                + device.getId());
    } else
      logger.error(
          "Error updating device connected/reported times.  Unknown device with identifier of:  "
              + deviceid);
  } catch (Exception e) {
    logger.error("Error updating device service reported/connected times for: " + deviceid + "  ("
        + e.getMessage() + ")");
  }

}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
public void setService(DeviceService srv) {
  service = srv;
  service.setAddressable(srv.getAddressable());
  service.setLabels(srv.getLabels());
  setHost(srv.getAddressable().getAddress());
  setPort(srv.getAddressable().getPort());
  setCallbackUrl(srv.getAddressable().getPath());
  setServiceName(srv.getName());
  setLabels(srv.getLabels());
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
@Before
public void setup() throws Exception {
  deviceClient = new DeviceClientImpl();
  srvClient = new DeviceServiceClientImpl();
  proClient = new DeviceProfileClientImpl();
  addrClient = new AddressableClientImpl();
  commandClient = new CommandClientImpl();
  client = new CmdClientImpl();
  setURL();
  Addressable addressable = AddressableData.newTestInstance();
  addrClient.add(addressable);
  DeviceService service = ServiceData.newTestInstance();
  service.setAddressable(addressable);
  srvClient.add(service);
  Command command = CommandData.newTestInstance();
  commandId = commandClient.add(command);
  DeviceProfile profile = ProfileData.newTestInstance();
  profile.addCommand(command);
  proClient.add(profile);
  Device device = DeviceData.newTestInstance();
  device.setAddressable(addressable);
  device.setProfile(profile);
  device.setService(service);
  id = deviceClient.add(device);
  assertNotNull("CommandDevice did not get created correctly", id);

}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
@After
public void cleanup() {
  List<Device> devices = deviceClient.devices();
  devices.forEach((device) -> deviceClient.delete(device.getId()));
  List<DeviceProfile> profiles = proClient.deviceProfiles();
  profiles.forEach((profile) -> proClient.delete(profile.getId()));
  List<DeviceService> services = srvClient.deviceServices();
  services.forEach((service) -> srvClient.delete(service.getId()));
  List<Addressable> addressables = addrClient.addressables();
  addressables.forEach((addressable) -> addrClient.delete(addressable.getId()));
  List<Command> commands = commandClient.commands();
  commands.forEach((cmd) -> commandClient.delete(cmd.getId()));
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
private Device getDevice(DeviceProfile profile, DeviceService service, Addressable addressable) {
  Device device = new Device();
  device.setAdminState(AdminState.UNLOCKED);
  device.setOperatingState(OperatingState.ENABLED);
  device.setDescription(deviceDescription);
  device.setLabels(deviceLabels);
  device.setName(deviceName);
  device.setProfile(profile);
  device.setService(service);
  device.setAddressable(addressable);
  devClient.add(device);
  return device;
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
private DeviceService getDeviceService() {
  try {
    return dsClient.deviceServiceForName(deviceServiceName);
  } catch (javax.ws.rs.NotFoundException notFound) {
    return null;
  }
}
 

import org.edgexfoundry.domain.meta.DeviceService; //导入依赖的package包/类
public boolean isServiceLocked() {
  DeviceService srv = getService();
  if (srv == null) {
    return true;
  }
  return srv.getAdminState().equals(AdminState.LOCKED);
}