TCP自定义协议设备如何发送下行透传消息

[bobbyLdsadf]

我已经接入了TCP透传设备到平台，但是我现在想在我的业务系统增加一个给可以给jetlinks平台指定设备发送特定消息，来实现控制，请问有接口吗？如何使用！

[zhou-hao]

jetlinks-community/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceInstanceController.java

Lines 924 to 980 in 54143df

	@PostMapping("/messages")
	@SneakyThrows
	@QueryAction
	@Operation(summary = "批量发送指令到设备")
	@SuppressWarnings("all")
	public Flux<?> sendMessage(@RequestParam(required = false)
	@Parameter(description = "按查询条件发送指令") String where,
	@RequestBody Flux<Map<String, Object>> messages) {
	Lazy<Flux<DeviceOperator>> operators = Lazy.of(() -> {
	if (StringUtils.isEmpty(where)) {
	throw new ValidationException("where", "[where]参数不能为空");
	}
	QueryParamEntity entity = new QueryParamEntity();
	entity.setWhere(where);
	entity.includes("id");
	return service.query(entity)
	.flatMap(device -> registry.getDevice(device.getId()))
	.cache();
	});
	return messages
	.flatMap(message -> {
	DeviceMessage msg = MessageType
	.convertMessage(message)
	.filter(DeviceMessage.class::isInstance)
	.map(DeviceMessage.class::cast)
	.orElseThrow(() -> new UnsupportedOperationException("不支持的消息格式:" + message));
	String deviceId = msg.getDeviceId();
	Flux<DeviceOperator> devices = StringUtils.isEmpty(deviceId)
	? operators.get()
	: registry.getDevice(deviceId).flux();
	return devices
	.flatMap(device -> {
	Map<String, Object> copy = new HashMap<>(message);
	copy.put("deviceId", device.getDeviceId());
	copy.putIfAbsent("messageId", IDGenerator.SNOW_FLAKE_STRING.generate());
	//复制为新的消息,防止冲突
	DeviceMessage copiedMessage = MessageType
	.convertMessage(copy)
	.map(DeviceMessage.class::cast)
	.orElseThrow(() -> new UnsupportedOperationException("不支持的消息格式"));
	return device
	.messageSender()
	.send(copiedMessage)
	.onErrorResume(Exception.class, error -> {
	if (copiedMessage instanceof RepayableDeviceMessage) {
	return Mono.just(
	((RepayableDeviceMessage) copiedMessage).newReply().error(error)
	);
	}
	return Mono.error(error);
	});
	});
	});
	}

[bobbyLdsadf]

有参数文档说明吗，周哥

[zhou-hao]

https://hanta.yuque.com/px7kg1/dev/podp5dllcrd5mqpc 就是 DeviceMessage相关实现类.

[bobbyLdsadf]

这个Flux<Map<String, Object>> messages是不是对应的是产品功能定义的参数啊，然后根据where查询设备

[bobbyLdsadf]

我大概知道了，我研究一下